Skip to content

Commit 046e84b

Browse files
committed
fix: intercept every client-server messages
1 parent 784de0d commit 046e84b

File tree

2 files changed

+3
-7
lines changed

2 files changed

+3
-7
lines changed

lib/http-proxy/passes/ws-incoming.js

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -145,12 +145,8 @@ module.exports = {
145145
//
146146
socket.write(createHttpHeader('HTTP/1.1 101 Switching Protocols', proxyRes.headers));
147147

148-
if (options.wsInterceptServerMsg || options.wsInterceptClientMsg) {
149-
WsInterceptor.create({socket, options, proxyReq, proxyRes, proxySocket}).intercept();
150-
}
151-
else {
152-
proxySocket.pipe(socket).pipe(proxySocket);
153-
}
148+
const wsInterceptor = WsInterceptor.create({socket, options, proxyReq, proxyRes, proxySocket});
149+
wsInterceptor.startDataTransfer();
154150

155151
server.emit('open', proxySocket);
156152
server.emit('proxySocket', proxySocket); //DEPRECATED.

lib/http-proxy/ws/interceptor.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@ module.exports = class Interceptor {
9898
this._proxySocket.on('data', (data) => receiver.add(data));
9999
}
100100

101-
intercept() {
101+
startDataTransfer() {
102102
this._interceptServerMessages();
103103
this._interceptClientMessages();
104104
}

0 commit comments

Comments
 (0)