bedohswe/almatyd
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Try to fix things.

Browse Source
This commit is contained in:
bʰedoh₂ swé 2024-12-18 22:25:11 +05:00
parent 5d20ab866a
commit 3745fd9218
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
index.ts
View File

@ -40,6 +40,17 @@ let srv = net.createServer(function(socket: net.Socket) {
} }
let addr = a.address; let addr = a.address;
socket.on('data', function(data: Buffer | string) { socket.on('data', function(data: Buffer | string) {
if (data[0] === 'P'.charCodeAt(0)) {
if (addr == "127.0.0.1") {
let p = pp.V1ProxyProtocol.parse(String(data));
addr = p.source.ipAddress;
if (typeof p.data === 'string') {
data = p.data;
}
} else {
console.log("Address " + addr + " tried to use proxy protocol.");
}
}
switch (data[0]) { switch (data[0]) {
case 0x30: case 0x30:
const store = db.prepare("INSERT INTO messages VALUES (?,?,?)"); const store = db.prepare("INSERT INTO messages VALUES (?,?,?)");
@ -63,13 +74,6 @@ let srv = net.createServer(function(socket: net.Socket) {
socket.write(str); socket.write(str);
}); });
return; return;
case 'P'.charCodeAt(0):
if (addr == "127.0.0.1") {
addr = pp.V1ProxyProtocol.parse(String(data)).source.ipAddress;
} else {
console.log("Address " + addr + " tried to use proxy protocol.");
}
return;
} }
console.log(addr + "???" + data[0]); console.log(addr + "???" + data[0]);
}); });