waku-org
/
js-waku
mirror of https://github.com/waku-org/js-waku.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: adding delay between dials (#1973) 

* fix: adding delay between dials

* removing comment
This commit is contained in:
gabrielmer 2024-04-24 19:18:33 +03:00 committed by GitHub
parent 5fb100602b
commit 80a9525157
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
packages/tests/tests/getPeers.spec.ts
View File

@ -20,6 +20,7 @@ import Sinon from "sinon";
import { import {
afterEachCustom, afterEachCustom,
beforeEachCustom, beforeEachCustom,
delay,
isNwakuAtLeast, isNwakuAtLeast,
makeLogFileName, makeLogFileName,
resolveAutoshardingCluster, resolveAutoshardingCluster,
@ -170,6 +171,7 @@ describe("getConnectedPeersForProtocolAndShard", function () {
waku = await createLightNode({ shardInfo: shardInfo2 }); waku = await createLightNode({ shardInfo: shardInfo2 });
await waku.libp2p.dialProtocol(serviceNode1Ma, LightPushCodec); await waku.libp2p.dialProtocol(serviceNode1Ma, LightPushCodec);
await delay(500);
await waku.libp2p.dialProtocol(serviceNode2Ma, LightPushCodec); await waku.libp2p.dialProtocol(serviceNode2Ma, LightPushCodec);
await waku.start(); await waku.start();
@ -223,6 +225,7 @@ describe("getConnectedPeersForProtocolAndShard", function () {
waku = await createLightNode({ shardInfo: shardInfo2 }); waku = await createLightNode({ shardInfo: shardInfo2 });
await waku.libp2p.dialProtocol(serviceNodeMa1, LightPushCodec); await waku.libp2p.dialProtocol(serviceNodeMa1, LightPushCodec);
await delay(500);
await waku.libp2p.dialProtocol(serviceNodeMa2, LightPushCodec); await waku.libp2p.dialProtocol(serviceNodeMa2, LightPushCodec);
await waku.start(); await waku.start();
await waitForRemotePeer(waku, [Protocols.LightPush]); await waitForRemotePeer(waku, [Protocols.LightPush]);
@ -362,6 +365,7 @@ describe("getConnectedPeersForProtocolAndShard", function () {
waku = await createLightNode({ shardInfo: shardInfo2 }); waku = await createLightNode({ shardInfo: shardInfo2 });
await waku.libp2p.dialProtocol(serviceNode1Ma, LightPushCodec); await waku.libp2p.dialProtocol(serviceNode1Ma, LightPushCodec);
await delay(500);
await waku.libp2p.dialProtocol(serviceNode2Ma, LightPushCodec); await waku.libp2p.dialProtocol(serviceNode2Ma, LightPushCodec);
await waku.start(); await waku.start();
@ -416,6 +420,7 @@ describe("getConnectedPeersForProtocolAndShard", function () {
waku = await createLightNode({ shardInfo: shardInfo2 }); waku = await createLightNode({ shardInfo: shardInfo2 });
await waku.libp2p.dialProtocol(serviceNodeMa1, LightPushCodec); await waku.libp2p.dialProtocol(serviceNodeMa1, LightPushCodec);
await delay(500);
await waku.libp2p.dialProtocol(serviceNodeMa2, LightPushCodec); await waku.libp2p.dialProtocol(serviceNodeMa2, LightPushCodec);
await waku.start(); await waku.start();
await waitForRemotePeer(waku, [Protocols.LightPush]); await waitForRemotePeer(waku, [Protocols.LightPush]);