fix: listen "close" event from socket

Author: DudaGod

lib/http-proxy/ws/interceptor.js

@@ -46,11 +46,16 @@ module.exports = class Interceptor {
         this._proxyReq = proxyReq;
         this._proxyRes = proxyRes;
         this._proxySocket = proxySocket;
+        this._isSocketOpened = true;
 
         this._configure();
     }
 
     _configure() {
+        this._proxySocket.on('close', () => {
+            this._isSocketOpened = false;
+        });
+
         const secWsExtensions = this._proxyRes.headers['sec-websocket-extensions'];
         const extensions = Extensions.parse(secWsExtensions);
         this._isCompressed = secWsExtensions && secWsExtensions.includes('permessage-deflate');
@@ -79,7 +84,7 @@ module.exports = class Interceptor {
 
         receiver.ontext = getMsgHandler({interceptor: this._options.wsInterceptClientMsg, dataSender, binary: false});
         receiver.onbinary = getMsgHandler({interceptor: this._options.wsInterceptClientMsg, dataSender, binary: true});
-        receiver.onclose = (code, msg, {masked: mask}) => sender.close(code, msg, mask);
+        receiver.onclose = (code, msg, {masked: mask}) => this._isSocketOpened && sender.close(code, msg, mask);
 
         this._socket.on('data', (data) => receiver.add(data));
     }
@@ -93,7 +98,7 @@ module.exports = class Interceptor {
 
         receiver.ontext = getMsgHandler({interceptor: this._options.wsInterceptServerMsg, dataSender, binary: false});
         receiver.onbinary = getMsgHandler({interceptor: this._options.wsInterceptServerMsg, dataSender, binary: true});
-        receiver.onclose = (code, msg, {masked: mask}) => sender.close(code, msg, mask);
+        receiver.onclose = (code, msg, {masked: mask}) => this._isSocketOpened && sender.close(code, msg, mask);
 
         this._proxySocket.on('data', (data) => receiver.add(data));
     }