fix(transport): Use connection in WebSocket ID (openwallet-foundation…

…#1551) Signed-off-by: Martin Auer <martin.auer97@gmail.com>
auer-martin · Nov 15, 2023 · 02222b6 · 02222b6
1 parent 509b3e6
commit 02222b6
Showing 1 changed file with 3 additions and 2 deletions.
diff --git 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)))