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.24', |   version: '3.0.25', | ||||||
|   description: 'a proxy for handling high workloads of proxying' |   description: 'a proxy for handling high workloads of proxying' | ||||||
| } | } | ||||||
|   | |||||||
| @@ -201,7 +201,6 @@ JNj2Dr5H0XoLFFnvuvzcRbhlJ9J67JzR+7g= | |||||||
|             }); |             }); | ||||||
|             req.on('timeout', () => { |             req.on('timeout', () => { | ||||||
|               request.end(); |               request.end(); | ||||||
|               request.destroy(); |  | ||||||
|             }) |             }) | ||||||
|           } |           } | ||||||
|         ); |         ); | ||||||
| @@ -227,8 +226,8 @@ JNj2Dr5H0XoLFFnvuvzcRbhlJ9J67JzR+7g= | |||||||
|         }); |         }); | ||||||
|         response.on('timeout', () => { |         response.on('timeout', () => { | ||||||
|           res.end(); |           res.end(); | ||||||
|           res.destroy(); |  | ||||||
|         }); |         }); | ||||||
|  |  | ||||||
|       } |       } | ||||||
|     ); |     ); | ||||||
|  |  | ||||||
| @@ -273,25 +272,19 @@ JNj2Dr5H0XoLFFnvuvzcRbhlJ9J67JzR+7g= | |||||||
|           cleanUp(); |           cleanUp(); | ||||||
|         }); |         }); | ||||||
|       }); |       }); | ||||||
|        |  | ||||||
|     }); |     }); | ||||||
|     this.httpsServer.keepAliveTimeout = 61000; |     this.httpsServer.keepAliveTimeout = 61000; | ||||||
|     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(60000); |  | ||||||
|       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.`); | ||||||
|       const cleanupConnection = () => { |       const cleanupConnection = () => { | ||||||
|         if (this.socketMap.checkForObject(connection)) { |         if (this.socketMap.checkForObject(connection)) { | ||||||
|           this.socketMap.remove(connection); |           this.socketMap.remove(connection); | ||||||
|           console.log(`removed connection. ${this.socketMap.getArray().length} sockets remaining.`); |           console.log(`removed connection. ${this.socketMap.getArray().length} sockets remaining.`); | ||||||
|           connection.end(); |  | ||||||
|           connection.destroy(); |           connection.destroy(); | ||||||
|           console.log(`socket successfully destroyed.`); |           console.log(`socket successfully destroyed.`); | ||||||
|           plugins.smartdelay.delayFor(10000).then(() => { |  | ||||||
|             connection.removeAllListeners(); |  | ||||||
|           }) |  | ||||||
|         } |         } | ||||||
|       }; |       }; | ||||||
|       connection.on('close', () => { |       connection.on('close', () => { | ||||||
| @@ -303,9 +296,6 @@ JNj2Dr5H0XoLFFnvuvzcRbhlJ9J67JzR+7g= | |||||||
|       connection.on('end', () => { |       connection.on('end', () => { | ||||||
|         cleanupConnection(); |         cleanupConnection(); | ||||||
|       }); |       }); | ||||||
|       connection.on('timeout', () => { |  | ||||||
|         cleanupConnection(); |  | ||||||
|       }); |  | ||||||
|     }); |     }); | ||||||
|  |  | ||||||
|     this.httpsServer.listen(this.options.port); |     this.httpsServer.listen(this.options.port); | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user