directly access the websocket socket for pause/resume

Author: Apollon77

lib/proxy.js

@@ -624,9 +624,8 @@ Proxy.prototype._onWebSocketServerConnect = function(isSSL, ws, upgradeReq) {
   ctx.clientToProxyWebSocket.on('pong', self._onWebSocketFrame.bind(self, ctx, 'pong', false));
   ctx.clientToProxyWebSocket.on('error', self._onWebSocketError.bind(self, ctx));
   ctx.clientToProxyWebSocket.on('close', self._onWebSocketClose.bind(self, ctx, false));
-  if (typeof ctx.clientToProxyWebSocket.pause === 'function') {
-    ctx.clientToProxyWebSocket.pause();
-  }
+  ctx.clientToProxyWebSocket._socket.pause();
+	
   var url;
   if (upgradeReq.url == '' || /^\//.test(upgradeReq.url)) {
     var hostPort = Proxy.parseHostAndPort(upgradeReq);
@@ -661,8 +660,8 @@ Proxy.prototype._onWebSocketServerConnect = function(isSSL, ws, upgradeReq) {
     ctx.proxyToServerWebSocket.on('error', self._onWebSocketError.bind(self, ctx));
     ctx.proxyToServerWebSocket.on('close', self._onWebSocketClose.bind(self, ctx, true));
     ctx.proxyToServerWebSocket.on('open', function() {
-      if (ctx.clientToProxyWebSocket.readyState === WebSocket.OPEN && typeof ctx.clientToProxyWebSocket.resume === 'function') {
-        ctx.clientToProxyWebSocket.resume();
+      if (ctx.clientToProxyWebSocket.readyState === WebSocket.OPEN) {
+        ctx.clientToProxyWebSocket._socket.resume();
       }
     });
   }