Exchange nitro info with already connected peers

cerc-io · Jul 13, 2023 · 4943259 · 4943259
1 parent aa107f0
commit 4943259
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/packages/nitro-client/src/client/engine/messageservice/p2p-message-service/service.ts b/packages/nitro-client/src/client/engine/messageservice/p2p-message-service/service.ts
@@ -143,6 +143,8 @@ export class P2PMessageService implements MessageService {
       });
     });
 
+    await ms.exchangeInfoWithConnectedPeers();
+
     return ms;
   }
 
@@ -154,6 +156,17 @@ export class P2PMessageService implements MessageService {
     return PeerIdFactory.createFromPrivKey(this.key);
   }
 
+  // Method to exchange info with already connected peers
+  private async exchangeInfoWithConnectedPeers() {
+    const peerIds = this.p2pHost.getPeers();
+
+    await Promise.all(peerIds.map(async (peerId: PeerId) => {
+      const connection: Connection = await this.p2pHost.dial(peerId);
+
+      await this.handlePeerConnect({ detail: connection } as CustomEvent<Connection>);
+    }));
+  }
+
   private async handleChangeProtocols({ detail: data }: CustomEvent<PeerProtocolsChangeData>) {
     // Ignore self protocol changes
     if (data.peerId.equals(this.p2pHost.peerId)) {