rainbownapkin/fore.st
1
0
Fork 0
Code Issues 13 Pull requests Actions Packages Projects Releases Wiki Activity

proxyinterceptor: handle SocketDisconnectEvent

Browse source
This commit is contained in:
calzoneman 2016-03-07 20:25:32 -08:00
parent d913f02657
commit a96b85fa5b
1 changed files with 14 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/backend/proxyinterceptor.js
View file

@ -24,6 +24,7 @@ export default class ProxyInterceptor {
socket.on('close', this.onFrontendDisconnect.bind(this, socket)); socket.on('close', this.onFrontendDisconnect.bind(this, socket));
socket.on('SocketConnectEvent', this.onSocketConnect.bind(this, socket)); socket.on('SocketConnectEvent', this.onSocketConnect.bind(this, socket));
socket.on('SocketFrameEvent', this.onSocketFrame.bind(this, socket)); socket.on('SocketFrameEvent', this.onSocketFrame.bind(this, socket));
socket.on('SocketDisconnectEvent', this.onSocketDisconnect.bind(this, socket));
} }
onFrontendDisconnect(socket) { onFrontendDisconnect(socket) {
@ -73,4 +74,17 @@ export default class ProxyInterceptor {
const socket = socketMap[socketID]; const socket = socketMap[socketID];
socket.onProxiedEventReceived.apply(socket, [event].concat(args)); socket.onProxiedEventReceived.apply(socket, [event].concat(args));
} }
onSocketDisconnect(frontendConnection, socketID) {
const mapKey = frontendConnection.endpoint;
const socketMap = this.frontendProxiedSockets[mapKey];
if (!socketMap || !socketMap.hasOwnProperty(socketID)) {
logger.error(`Received SocketDisconnectEvent for nonexistent socket`,
{ socketID });
return;
}
const socket = socketMap[socketID];
socket.onProxiedEventReceived.apply(socket, ['disconnect']);
}
} }