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

Merge #774 

774: Use waitForRemotePeer directly r=D4nte a=D4nte



Co-authored-by: Franck Royer <franck@status.im>
This commit is contained in:
status-bors-ng[bot] 2022-06-01 03:17:15 +00:00 committed by GitHub
parent 9b6fd5ec8b e8e6df767b
commit 6f5e1fa2aa
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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,
Nwaku,
} from "../../test_utils";
import { delay } from "../../test_utils/delay";
import {
generatePrivateKey,
generateSymmetricKey,
@ -278,14 +277,7 @@ describe("Waku Store", () => {
dbg("Waku nodes connected to nwaku");
let lightPushPeerFound = false;
while (!lightPushPeerFound) {
await delay(100);
for await (const _peer of waku1.lightPush.peers) {
lightPushPeerFound = true;
break;
}
}
await waku1.waitForRemotePeer([Protocols.LightPush]);
dbg("Sending messages using light push");
await Promise.all([
@ -295,14 +287,7 @@ describe("Waku Store", () => {
waku1.lightPush.push(clearMessage),
]);
let storePeerFound = false;
while (!storePeerFound) {
await delay(100);
for await (const _peer of waku2.store.peers) {
storePeerFound = true;
break;
}
}
await waku2.waitForRemotePeer([Protocols.Store]);
waku2.store.addDecryptionKey(symKey);
@ -396,14 +381,7 @@ describe("Waku Store", () => {
dbg("Waku nodes connected to nwaku");
let lightPushPeerFound = false;
while (!lightPushPeerFound) {
await delay(100);
for await (const _peer of waku1.lightPush.peers) {
lightPushPeerFound = true;
break;
}
}
await waku1.waitForRemotePeer([Protocols.LightPush]);
dbg("Sending messages using light push");
await Promise.all([
@ -413,14 +391,7 @@ describe("Waku Store", () => {
waku1.lightPush.push(clearMessage),
]);
let storePeerFound = false;
while (!storePeerFound) {
await delay(100);
for await (const _peer of waku2.store.peers) {
storePeerFound = true;
break;
}
}
await waku2.waitForRemotePeer([Protocols.Store]);
waku2.addDecryptionKey(symKey, {
contentTopics: [encryptedSymmetricContentTopic],