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

…#1551) Signed-off-by: Ariel Gentile <gentilester@gmail.com>
genaris · Sep 22, 2023 · 5f64f9c · 5f64f9c
1 parent da6b379
commit 5f64f9c
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)))