fix: rename interceptor opts and evetns

Author: DudaGod

README.md

@@ -395,27 +395,28 @@ proxyServer.listen(8015);
 
     };
     ```
-*  **wsInterceptServerMsg**: Is a handler which is called when a websocket message is intercepted on its way to the server. It takes two arguments: `data` - is a websocket message and flags (fin, mask, compress, binary). If falsy value is returned then nothing will be sended to the target server.
-    ```
+*  **wsInterceptClientMsg**: Is a handler which is called when a websocket message is intercepted on its way to the server from the client. It takes two arguments: `data` - is a websocket message and flags (fin, mask, compress, binary). If falsy value is returned then nothing will be sended to the client.
+     ```
       const proxy = new HttpProxy({
         ...
-        wsInterceptServerMsg: (data, flags) {
+        wsInterceptClientMsg: (data, flags) {
           return typeof data === 'string ? data.toUpperCase() : data;
         }
         ...
       })
     ```
-*  **wsInterceptClientMsg**: Is a handler which is called when a websocket message is intercepted on its way to the client. It takes two arguments: `data` - is a websocket message and flags (fin, mask, compress, binary). If falsy value is returned then nothing will be sended to the client.
-     ```
+*  **wsInterceptServerMsg**: Is a handler which is called when a websocket message is intercepted on its way to the client from the server. It takes two arguments: `data` - is a websocket message and flags (fin, mask, compress, binary). If falsy value is returned then nothing will be sended to the target server.
+    ```
       const proxy = new HttpProxy({
         ...
-        wsInterceptClientMsg: (data, flags) {
+        wsInterceptServerMsg: (data, flags) {
           return typeof data === 'string ? data.toUpperCase() : data;
         }
         ...
       })
     ```
 
+
 **NOTE:**
 `options.ws` and `options.ssl` are optional.
 `options.target` and `options.forward` cannot both be missing
@@ -434,8 +435,8 @@ If you are using the `proxyServer.listen` method, the following options are also
 * `proxyReq`: This event is emitted before the data is sent. It gives you a chance to alter the proxyReq request object. Applies to "web" connections
 * `proxyReqWs`: This event is emitted before the data is sent. It gives you a chance to alter the proxyReq request object. Applies to "websocket" connections
 * `proxyRes`: This event is emitted if the request to the target got a response.
-* `wsServerMsg`: This event is emitted after websocket message is sended to the server.
-* `wsClientMsg`: This event is emitted after webscoket mesage is sended to the client.
+* `wsClientMsg`: This event is emitted after webscoket mesage is sended from the client to the server.
+* `wsServerMsg`: This event is emitted after websocket message is sended from the server to the client.
 * `open`: This event is emitted once the proxy websocket was created and piped into the target websocket.
 * `close`: This event is emitted once the proxy websocket was closed.
 * (DEPRECATED) `proxySocket`: Deprecated in favor of `open`.

lib/http-proxy/ws/interceptor.js

@@ -69,37 +69,37 @@ module.exports = class Interceptor {
         };
     }
 
-    _interceptServerMessages() {
+    _interceptClientMessages() {
         const receiver = new Receiver(this._clientExtenstions);
         const sender = new Sender(this._proxySocket, this._serverExtenstions);
 
         // frame must be masked when send from client to server - https://tools.ietf.org/html/rfc6455#section-5.3
         const options = {mask: true};
-        const dataSender = this._getDataSender({sender, event: 'wsServerMsg', options});
+        const dataSender = this._getDataSender({sender, event: 'wsClientMsg', options});
 
-        receiver.ontext = getMsgHandler({interceptor: this._options.wsInterceptServerMsg, dataSender, binary: false});
-        receiver.onbinary = getMsgHandler({interceptor: this._options.wsInterceptServerMsg, dataSender, binary: true});
+        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);
 
         this._socket.on('data', (data) => receiver.add(data));
     }
 
-    _interceptClientMessages() {
+    _interceptServerMessages() {
         const receiver = new Receiver(this._serverExtenstions);
         const sender = new Sender(this._socket, this._clientExtenstions);
 
         const options = {mask: false};
-        const dataSender = this._getDataSender({sender, event: 'wsClientMsg', options});
+        const dataSender = this._getDataSender({sender, event: 'wsServerMsg', options});
 
-        receiver.ontext = getMsgHandler({interceptor: this._options.wsInterceptClientMsg, dataSender, binary: false});
-        receiver.onbinary = getMsgHandler({interceptor: this._options.wsInterceptClientMsg, dataSender, binary: true});
+        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);
 
         this._proxySocket.on('data', (data) => receiver.add(data));
     }
 
     startDataTransfer() {
-        this._interceptServerMessages();
         this._interceptClientMessages();
+        this._interceptServerMessages();
     }
 };