diff --git a/receivers/common/web/TcpListenerService.ts b/receivers/common/web/TcpListenerService.ts index 76f1d25..064985b 100644 --- a/receivers/common/web/TcpListenerService.ts +++ b/receivers/common/web/TcpListenerService.ts @@ -88,6 +88,8 @@ export class TcpListenerService { if (index != -1) { this.sessions.splice(index, 1); } + + this.sessionMap.delete(session.sessionId); this.emitter.emit('disconnect', { sessionId: session.sessionId, type: 'tcp', data: { address: socket.remoteAddress, port: socket.remotePort }}); }); diff --git a/receivers/common/web/WebSocketListenerService.ts b/receivers/common/web/WebSocketListenerService.ts index ad56130..c8913ed 100644 --- a/receivers/common/web/WebSocketListenerService.ts +++ b/receivers/common/web/WebSocketListenerService.ts @@ -93,6 +93,8 @@ export class WebSocketListenerService { if (index != -1) { this.sessions.splice(index, 1); } + + this.sessionMap.delete(session.sessionId); this.emitter.emit('disconnect', { sessionId: session.sessionId, type: 'ws', data: { url: socket.url }}); });