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

Add sleep for failing tests + logging

This commit is contained in:
Franck Royer 2021-04-20 15:07:23 +10:00
parent 818a8256e7
commit eec55b7b71
No known key found for this signature in database
GPG Key ID: A82ED75A8DFC50A4
1 changed files with 16 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
src/lib/waku_relay/index.spec.ts
View File

@ -204,15 +204,16 @@ describe('Waku Relay', () => {
}); });
it('Js publishes to nim', async function () { it('Js publishes to nim', async function () {
this.timeout(10000); this.timeout(30000);
const message = WakuMessage.fromUtf8String('This is a message'); const message = WakuMessage.fromUtf8String('This is a message');
await delay(1000);
await waku.relay.send(message); await waku.relay.send(message);
let msgs = []; let msgs = [];
while (msgs.length === 0) { while (msgs.length === 0) {
console.log('Waiting for messages');
await delay(200); await delay(200);
msgs = await nimWaku.messages(); msgs = await nimWaku.messages();
} }
@ -248,8 +249,16 @@ describe('Waku Relay', () => {
let waku2: Waku; let waku2: Waku;
let nimWaku: NimWaku; let nimWaku: NimWaku;
beforeEach(async function () { afterEach(async function () {
this.timeout(10_000); nimWaku ? nimWaku.stop() : null;
await Promise.all([
waku1 ? await waku1.stop() : null,
waku2 ? await waku2.stop() : null,
]);
});
it('Js publishes, other Js receives', async function () {
this.timeout(60_000);
[waku1, waku2] = await Promise.all([ [waku1, waku2] = await Promise.all([
Waku.create({ Waku.create({
staticNoiseKey: NOISE_KEY_1, staticNoiseKey: NOISE_KEY_1,
@ -261,7 +270,7 @@ describe('Waku Relay', () => {
}), }),
]); ]);
nimWaku = new NimWaku(this.test?.ctx?.currentTest?.title + ''); nimWaku = new NimWaku(makeLogFileName(this));
await nimWaku.start(); await nimWaku.start();
const nimWakuMultiaddr = await nimWaku.getMultiaddrWithId(); const nimWakuMultiaddr = await nimWaku.getMultiaddrWithId();
@ -288,19 +297,8 @@ describe('Waku Relay', () => {
waku2.libp2p.pubsub.once('gossipsub:heartbeat', resolve) waku2.libp2p.pubsub.once('gossipsub:heartbeat', resolve)
), ),
]); ]);
});
afterEach(async function () {
nimWaku ? nimWaku.stop() : null;
await Promise.all([
waku1 ? await waku1.stop() : null,
waku2 ? await waku2.stop() : null,
]);
});
it('Js publishes, other Js receives', async function () {
this.timeout(30000);
await delay(2000);
// Check that the two JS peers are NOT directly connected // Check that the two JS peers are NOT directly connected
expect( expect(
waku1.libp2p.peerStore.peers.has(waku2.libp2p.peerId.toB58String()) waku1.libp2p.peerStore.peers.has(waku2.libp2p.peerId.toB58String())
@ -315,7 +313,7 @@ describe('Waku Relay', () => {
const waku2ReceivedPromise = waitForNextData(waku2.libp2p.pubsub); const waku2ReceivedPromise = waitForNextData(waku2.libp2p.pubsub);
await waku1.relay.send(message); await waku1.relay.send(message);
console.log('Waiting for message');
const waku2ReceivedMsg = await waku2ReceivedPromise; const waku2ReceivedMsg = await waku2ReceivedPromise;
expect(waku2ReceivedMsg.utf8Payload()).to.eq(msgStr); expect(waku2ReceivedMsg.utf8Payload()).to.eq(msgStr);