disable agent

exposr · Mar 23, 2024 · 68bdefa · 68bdefa
1 parent 112d035
commit 68bdefa
Showing 1 changed file with 22 additions and 0 deletions.
diff --git a/src/ingress/http-ingress.ts b/src/ingress/http-ingress.ts
@@ -361,8 +361,30 @@ export default class HttpIngress implements IngressBase {
             clientRes.pipe(res);
         });
 
+        res.once('error', (err: any) => {
+            this.logger.withContext("tunnel", tunnel.id).debug({
+                message: `upstream response error: ${err.message}`
+            });
+        });
+
+        const close = () => {
+            clientReq.removeAllListeners('error');
+            clientReq.removeAllListeners('close');
+            clientReq.destroy();
+        };
+
+        clientReq.once('timeout', () => {
+            this.logger.withContext("tunnel", tunnel.id).debug({
+                message: `http request timeout`,
+            });
+            clientReq.end();
+        });
+
         clientReq.once('close', () => {
             agent.activeTunnelConnections = Math.max(agent.activeTunnelConnections - 1, 0);
+            this.logger.withContext("tunnel", tunnel.id).debug({
+                message: `http request closed: ${agent.activeTunnelConnections} active connections`,
+            });
         });
 
         clientReq.on('error', (err: any) => {