tgpholly/tcp-ws-proxy
1
0
Fork 0
Code Issues 3 Pull requests Projects Releases 2 Packages Wiki Activity

Log more

Browse source
This commit is contained in:
Holly Stubbs 2024-01-18 19:56:18 +00:00
parent 01af433838
commit 21a088820b
Signed by: tgpholly
GPG key ID: B8583C4B7D18119E
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
index.ts
View file

@ -118,13 +118,16 @@ if (process.argv[2] === "server") {
process.exit(1); process.exit(1);
} }
const config:IClientConfig = JSON.parse(readFileSync("./config/client-config.json").toString()); const config:IClientConfig = JSON.parse(readFileSync("./config/client-config.json").toString());
let CLIENT_ID = 0;
const server = createServer((socket) => { const server = createServer((socket) => {
let authed = false; let authed = false;
let queuedMessages = new Array<Buffer>(); let queuedMessages = new Array<Buffer>();
let txBytes = 0; let txBytes = 0;
let rxBytes = 0; let rxBytes = 0;
const thisClientId = CLIENT_ID++;
console.log(`[LOCAL CLIENT ${thisClientId}] New Connection`);
const txrxInterval = setInterval(() => { const txrxInterval = setInterval(() => {
console.log(`TX: ${(txBytes / 1024).toFixed(2)}KB/s | RX: ${(rxBytes / 1024).toFixed(2)}KB/s`); console.log(`[LOCAL CLIENT ${thisClientId}] TX: ${(txBytes / 1024).toFixed(2)}KB/s | RX: ${(rxBytes / 1024).toFixed(2)}KB/s`);
txBytes = rxBytes = 0; txBytes = rxBytes = 0;
}, 1000); }, 1000);
@ -171,6 +174,7 @@ if (process.argv[2] === "server") {
function clientCloseOrError() { function clientCloseOrError() {
socket.end(); socket.end();
clearInterval(txrxInterval); clearInterval(txrxInterval);
console.log(`[LOCAL CLIENT ${thisClientId}] Remote server terminated the connection.`);
} }
client.on("close", clientCloseOrError); client.on("close", clientCloseOrError);
client.on("error", clientCloseOrError); client.on("error", clientCloseOrError);
@ -188,6 +192,7 @@ if (process.argv[2] === "server") {
function serverCloseOrError() { function serverCloseOrError() {
client.close(); client.close();
clearInterval(txrxInterval); clearInterval(txrxInterval);
console.log(`[LOCAL CLIENT ${thisClientId}] Disconnected`);
} }
socket.on("close", serverCloseOrError); socket.on("close", serverCloseOrError);
socket.on("error", serverCloseOrError); socket.on("error", serverCloseOrError);