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

Use waitForRemotePeer directly

This commit is contained in:
Franck Royer 2022-06-01 13:16:06 +10:00
parent 9b6fd5ec8b
commit e8e6df767b
No known key found for this signature in database
GPG Key ID: A82ED75A8DFC50A4
1 changed files with 4 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
src/lib/waku_store/index.node.spec.ts
View File

@ -7,7 +7,6 @@ import {
NOISE_KEY_2, NOISE_KEY_2,
Nwaku, Nwaku,
} from "../../test_utils"; } from "../../test_utils";
import { delay } from "../../test_utils/delay";
import { import {
generatePrivateKey, generatePrivateKey,
generateSymmetricKey, generateSymmetricKey,
@ -278,14 +277,7 @@ describe("Waku Store", () => {
dbg("Waku nodes connected to nwaku"); dbg("Waku nodes connected to nwaku");
let lightPushPeerFound = false; await waku1.waitForRemotePeer([Protocols.LightPush]);
while (!lightPushPeerFound) {
await delay(100);
for await (const _peer of waku1.lightPush.peers) {
lightPushPeerFound = true;
break;
}
}
dbg("Sending messages using light push"); dbg("Sending messages using light push");
await Promise.all([ await Promise.all([
@ -295,14 +287,7 @@ describe("Waku Store", () => {
waku1.lightPush.push(clearMessage), waku1.lightPush.push(clearMessage),
]); ]);
let storePeerFound = false; await waku2.waitForRemotePeer([Protocols.Store]);
while (!storePeerFound) {
await delay(100);
for await (const _peer of waku2.store.peers) {
storePeerFound = true;
break;
}
}
waku2.store.addDecryptionKey(symKey); waku2.store.addDecryptionKey(symKey);
@ -396,14 +381,7 @@ describe("Waku Store", () => {
dbg("Waku nodes connected to nwaku"); dbg("Waku nodes connected to nwaku");
let lightPushPeerFound = false; await waku1.waitForRemotePeer([Protocols.LightPush]);
while (!lightPushPeerFound) {
await delay(100);
for await (const _peer of waku1.lightPush.peers) {
lightPushPeerFound = true;
break;
}
}
dbg("Sending messages using light push"); dbg("Sending messages using light push");
await Promise.all([ await Promise.all([
@ -413,14 +391,7 @@ describe("Waku Store", () => {
waku1.lightPush.push(clearMessage), waku1.lightPush.push(clearMessage),
]); ]);
let storePeerFound = false; await waku2.waitForRemotePeer([Protocols.Store]);
while (!storePeerFound) {
await delay(100);
for await (const _peer of waku2.store.peers) {
storePeerFound = true;
break;
}
}
waku2.addDecryptionKey(symKey, { waku2.addDecryptionKey(symKey, {
contentTopics: [encryptedSymmetricContentTopic], contentTopics: [encryptedSymmetricContentTopic],