From 02222b69e7b2f41ac682d287aea6bab4b3a111f5 Mon Sep 17 00:00:00 2001 From: Alexander Shenshin <93187809+AlexanderShenshin@users.noreply.github.com> Date: Fri, 25 Aug 2023 11:05:54 +0300 Subject: [PATCH] fix(transport): Use connection in WebSocket ID (#1551) Signed-off-by: Martin Auer --- packages/core/src/transport/WsOutboundTransport.ts | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/packages/core/src/transport/WsOutboundTransport.ts b/packages/core/src/transport/WsOutboundTransport.ts index ff6dabda8e..18a4eda3a9 100644 --- a/packages/core/src/transport/WsOutboundTransport.ts +++ b/packages/core/src/transport/WsOutboundTransport.ts @@ -47,8 +47,9 @@ export class WsOutboundTransport implements OutboundTransport { throw new AriesFrameworkError("Missing connection or endpoint. I don't know how and where to send the message.") } - const isNewSocket = !this.hasOpenSocket(endpoint) - const socket = await this.resolveSocket({ socketId: endpoint, endpoint, connectionId }) + const socketId = `${endpoint}-${connectionId}` + const isNewSocket = !this.hasOpenSocket(socketId) + const socket = await this.resolveSocket({ socketId, endpoint, connectionId }) socket.send(Buffer.from(JSON.stringify(payload)))