fix(core): update
This commit is contained in:
		| @@ -3,6 +3,6 @@ | |||||||
|  */ |  */ | ||||||
| export const commitinfo = { | export const commitinfo = { | ||||||
|   name: '@pushrocks/smartproxy', |   name: '@pushrocks/smartproxy', | ||||||
|   version: '3.0.17', |   version: '3.0.18', | ||||||
|   description: 'a proxy for handling high workloads of proxying' |   description: 'a proxy for handling high workloads of proxying' | ||||||
| } | } | ||||||
|   | |||||||
| @@ -187,12 +187,22 @@ JNj2Dr5H0XoLFFnvuvzcRbhlJ9J67JzR+7g= | |||||||
|           }, |           }, | ||||||
|           true, // lets make this streaming |           true, // lets make this streaming | ||||||
|           (request) => { |           (request) => { | ||||||
|  |             req.setTimeout(60000); | ||||||
|             req.on('data', (data) => { |             req.on('data', (data) => { | ||||||
|               request.write(data); |               request.write(data); | ||||||
|             }); |             }); | ||||||
|             req.on('end', (data) => { |             req.on('end', (data) => { | ||||||
|               request.end(); |               request.end(); | ||||||
|             }); |             }); | ||||||
|  |             req.on('error', () => { | ||||||
|  |               request.end(); | ||||||
|  |             }); | ||||||
|  |             req.on('close', () => { | ||||||
|  |               request.end(); | ||||||
|  |             }); | ||||||
|  |             req.on('timeout', () => { | ||||||
|  |               request.end(); | ||||||
|  |             }) | ||||||
|           } |           } | ||||||
|         ); |         ); | ||||||
|         res.statusCode = response.statusCode; |         res.statusCode = response.statusCode; | ||||||
| @@ -246,12 +256,12 @@ JNj2Dr5H0XoLFFnvuvzcRbhlJ9J67JzR+7g= | |||||||
|  |  | ||||||
|       // handle closing |       // handle closing | ||||||
|       const cleanUp = () => { |       const cleanUp = () => { | ||||||
|         ws.removeAllListeners(); |  | ||||||
|         ws.close(); |         ws.close(); | ||||||
|         ws.terminate(); |         ws.terminate(); | ||||||
|         wsc.removeAllListeners(); |         ws.removeAllListeners(); | ||||||
|         wsc.close(); |         wsc.close(); | ||||||
|         wsc.terminate(); |         wsc.terminate(); | ||||||
|  |         wsc.removeAllListeners(); | ||||||
|       }; |       }; | ||||||
|  |  | ||||||
|       ws.on('close', (message) => { |       ws.on('close', (message) => { | ||||||
| @@ -265,7 +275,7 @@ JNj2Dr5H0XoLFFnvuvzcRbhlJ9J67JzR+7g= | |||||||
|     this.httpsServer.headersTimeout = 65000; |     this.httpsServer.headersTimeout = 65000; | ||||||
|  |  | ||||||
|     this.httpsServer.on('connection', (connection: plugins.net.Socket) => { |     this.httpsServer.on('connection', (connection: plugins.net.Socket) => { | ||||||
|       connection.setTimeout(10000); |       connection.setTimeout(61000); | ||||||
|       let destroyed = false; |       let destroyed = false; | ||||||
|       this.socketMap.add(connection); |       this.socketMap.add(connection); | ||||||
|       console.log(`added connection. now ${this.socketMap.getArray().length} sockets connected.`); |       console.log(`added connection. now ${this.socketMap.getArray().length} sockets connected.`); | ||||||
| @@ -274,9 +284,6 @@ JNj2Dr5H0XoLFFnvuvzcRbhlJ9J67JzR+7g= | |||||||
|           destroyed = true; |           destroyed = true; | ||||||
|           connection.destroy(); |           connection.destroy(); | ||||||
|           console.log(`socket successfully destroyed.`); |           console.log(`socket successfully destroyed.`); | ||||||
|           plugins.smartdelay.delayFor(1000).then(() => { |  | ||||||
|             connection.removeAllListeners(); |  | ||||||
|           }); |  | ||||||
|         } |         } | ||||||
|       } |       } | ||||||
|       const cleanupConnection = () => { |       const cleanupConnection = () => { | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user