Compare commits

...

12 Commits

Author SHA1 Message Date
cc38a6d10e 3.0.32 2022-08-01 12:55:01 +02:00
748b07efe2 fix(core): update 2022-08-01 12:55:00 +02:00
be4fd0978a 3.0.31 2022-08-01 12:31:30 +02:00
4521010b82 fix(core): update 2022-08-01 12:31:29 +02:00
bd1f1a4c1c 3.0.30 2022-07-31 08:30:13 +02:00
d3bdd56660 fix(core): update 2022-07-31 08:30:13 +02:00
c38a7c4c32 3.0.29 2022-07-30 23:00:23 +02:00
858628196a fix(core): update 2022-07-30 23:00:23 +02:00
4910679058 3.0.28 2022-07-30 23:00:15 +02:00
97db2012ca fix(core): update 2022-07-30 23:00:15 +02:00
0ee13b4e06 3.0.27 2022-07-30 22:40:08 +02:00
21f5882fa3 fix(core): update 2022-07-30 22:40:08 +02:00
4 changed files with 7 additions and 7 deletions

4
package-lock.json generated
View File

@ -1,12 +1,12 @@
{
"name": "@pushrocks/smartproxy",
"version": "3.0.26",
"version": "3.0.32",
"lockfileVersion": 2,
"requires": true,
"packages": {
"": {
"name": "@pushrocks/smartproxy",
"version": "3.0.26",
"version": "3.0.32",
"license": "MIT",
"dependencies": {
"@pushrocks/lik": "^6.0.0",

View File

@ -1,6 +1,6 @@
{
"name": "@pushrocks/smartproxy",
"version": "3.0.26",
"version": "3.0.32",
"private": false,
"description": "a proxy for handling high workloads of proxying",
"main": "dist_ts/index.js",

View File

@ -3,6 +3,6 @@
*/
export const commitinfo = {
name: '@pushrocks/smartproxy',
version: '3.0.26',
version: '3.0.32',
description: 'a proxy for handling high workloads of proxying'
}

View File

@ -128,6 +128,7 @@ JNj2Dr5H0XoLFFnvuvzcRbhlJ9J67JzR+7g=
) => {
res.writeHead(statusArg, messageArg);
res.end(messageArg);
res.destroy();
};
console.log(`got request: ${req.headers.host}${plugins.url.parse(req.url).path}`);
@ -200,6 +201,7 @@ JNj2Dr5H0XoLFFnvuvzcRbhlJ9J67JzR+7g=
request.end();
});
req.on('timeout', () => {
req.destroy();
request.end();
})
}
@ -226,6 +228,7 @@ JNj2Dr5H0XoLFFnvuvzcRbhlJ9J67JzR+7g=
});
response.on('timeout', () => {
res.end();
res.destroy()
});
}
@ -259,9 +262,7 @@ JNj2Dr5H0XoLFFnvuvzcRbhlJ9J67JzR+7g=
// handle closing
const cleanUp = () => {
ws.close();
ws.terminate();
wsc.close();
wsc.terminate();
};
ws.on('close', (message) => {
@ -284,7 +285,6 @@ JNj2Dr5H0XoLFFnvuvzcRbhlJ9J67JzR+7g=
this.socketMap.remove(connection);
console.log(`removed connection. ${this.socketMap.getArray().length} sockets remaining.`);
connection.destroy();
console.log(`socket successfully destroyed.`);
}
};
connection.on('close', () => {