19.5.22

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@push.rocks/smartproxy",
-  "version": "19.5.21",
+  "version": "19.5.22",
   "private": false,
   "description": "A powerful proxy package with unified route-based configuration for high traffic management. Features include SSL/TLS support, flexible routing patterns, WebSocket handling, advanced security options, and automatic ACME certificate management.",
   "main": "dist_ts/index.js",

ts/proxies/smart-proxy/route-connection-handler.ts

@@ -199,9 +199,8 @@ export class RouteConnectionHandler {
       setupSocketHandlers(
         underlyingSocket,
         (reason) => {
-          // Only cleanup if connection hasn't been fully established
+          // Always cleanup when incoming socket closes
-          // Check if outgoing connection exists and is connected
+          // This prevents connection accumulation in proxy chains
-          if (!record.outgoing || record.outgoing.readyState !== 'open') {
           logger.log('debug', `Connection ${connectionId} closed during immediate routing: ${reason}`, {
             connectionId,
             remoteIP: record.remoteIP,
@@ -211,13 +210,18 @@ export class RouteConnectionHandler {
             component: 'route-handler'
           });
           
-            // If there's a pending outgoing connection, destroy it
+          // If there's a pending or established outgoing connection, destroy it
           if (record.outgoing && !record.outgoing.destroyed) {
+            logger.log('debug', `Destroying outgoing connection for ${connectionId}`, {
+              connectionId,
+              outgoingState: record.outgoing.readyState,
+              component: 'route-handler'
+            });
             record.outgoing.destroy();
           }
           
+          // Always cleanup the connection record
           this.connectionManager.cleanupConnection(record, reason);
-          }
         },
         undefined, // Use default timeout handler
         'immediate-route-client'