push.rocks/smartproxy
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(core): update

Browse Source
This commit is contained in:
Philipp Kunz 2021-02-02 21:59:24 +00:00
parent da060fa986
commit dd7e9e8416
1 changed files with 26 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
ts/smartproxy.portproxy.ts
View File

@ -18,6 +18,14 @@ const portProxyCalls = {
response.end(); response.end();
}); });
httpServer.listen(7999); httpServer.listen(7999);
const cleanUpSockets = (from: plugins.net.Socket, to: plugins.net.Socket) => {
from.end();
to.end();
from.removeAllListeners();
to.removeEventListener();
from.unpipe();
to.unpipe();
}
netServer = net netServer = net
.createServer((from) => { .createServer((from) => {
const to = net.createConnection({ const to = net.createConnection({
@ -27,14 +35,29 @@ const portProxyCalls = {
from.pipe(to); from.pipe(to);
to.pipe(from); to.pipe(from);
from.on('error', () => { from.on('error', () => {
from.end(), to.end(); cleanUpSockets(from, to);
}); });
to.on('error', () => { to.on('error', () => {
from.end(), to.end(); cleanUpSockets(from, to);
}); });
from.on('close', () => { from.on('close', () => {
to.end(); cleanUpSockets(from, to);
}); });
to.on('close', () => {
cleanUpSockets(from, to);
});
from.on('timeout', () => {
cleanUpSockets(from, to);
});
to.on('timeout', () => {
cleanUpSockets(from, to);
});
from.on('end', () => {
cleanUpSockets(from, to);
})
to.on('end', () => {
cleanUpSockets(from, to);
})
}) })
.listen(portArg); .listen(portArg);
console.log(`PortProxy -> OK: Now listening on port ${portArg}`); console.log(`PortProxy -> OK: Now listening on port ${portArg}`);