Merge pull request #12 from requestly/fix-wss-frame-handler

Author: nsrCodes

dist/lib/proxy/lib/proxy.js

@@ -997,7 +997,7 @@ Proxy.prototype._onWebSocketConnection = function (ctx, callback) {
         return fn(ctx, callback);
     }, callback);
 };
-Proxy.prototype._onWebSocketFrame = function (ctx, type, fromServer, data, isBinary) {
+Proxy.prototype._onWebSocketFrame = function (ctx, type, fromServer, data, flags) {
     var self = this;
     async.forEach(this.onWebSocketFrameHandlers.concat(ctx.onWebSocketFrameHandlers), function (fn, callback) {
         return fn(ctx, type, fromServer, data, flags, function (err, newData, newFlags) {
@@ -1018,7 +1018,7 @@ Proxy.prototype._onWebSocketFrame = function (ctx, type, fromServer, data, isBin
         if (destWebSocket.readyState === WebSocket.OPEN) {
             switch (type) {
                 case "message":
-                    destWebSocket.send(data, { binary: isBinary });
+                    destWebSocket.send(data, { binary: flags });
                     break;
                 case "ping":
                     destWebSocket.ping(data, flags, false);

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@requestly/requestly-proxy",
-  "version": "1.1.8",
+  "version": "1.1.9",
   "description": "Proxy that gives superpowers to all the Requestly clients",
   "main": "dist/index.js",
   "scripts": {

package.json

@@ -1189,7 +1189,7 @@ Proxy.prototype._onWebSocketFrame = function (
   type,
   fromServer,
   data,
-  isBinary
+  flags
 ) {
   var self = this;
   async.forEach(
@@ -1221,7 +1221,7 @@ Proxy.prototype._onWebSocketFrame = function (
       if (destWebSocket.readyState === WebSocket.OPEN) {
         switch (type) {
           case "message":
-            destWebSocket.send(data, { binary: isBinary });
+            destWebSocket.send(data, { binary: flags });
             break;
           case "ping":
             destWebSocket.ping(data, flags, false);