diff --git a/packages/status-communities/src/messenger.spec.ts b/packages/status-communities/src/messenger.spec.ts index fa93e2c9..4df4eb52 100644 --- a/packages/status-communities/src/messenger.spec.ts +++ b/packages/status-communities/src/messenger.spec.ts @@ -1,4 +1,5 @@ import { expect } from "chai"; +import debug from "debug"; import { utils } from "js-waku"; import { ApplicationMetadataMessage } from "./application_metadata_message"; @@ -7,6 +8,8 @@ import { Messenger } from "./messenger"; const testChatId = "test-chat-id"; +const dbg = debug("communities:test:messenger"); + describe("Messenger", () => { let messengerAlice: Messenger; let messengerBob: Messenger; @@ -16,9 +19,12 @@ describe("Messenger", () => { beforeEach(async function () { this.timeout(10_000); + dbg("Generate keys"); identityAlice = Identity.generate(); identityBob = Identity.generate(); + dbg("Create messengers"); + [messengerAlice, messengerBob] = await Promise.all([ Messenger.create(identityAlice), Messenger.create(identityBob, { @@ -26,12 +32,14 @@ describe("Messenger", () => { }), ]); + dbg("Connect messengers"); // Connect both messengers together for test purposes messengerAlice.waku.addPeerToAddressBook( messengerBob.waku.libp2p.peerId, messengerBob.waku.libp2p.multiaddrs ); + dbg("Wait for pubsub connection"); await Promise.all([ new Promise((resolve) => messengerAlice.waku.libp2p.pubsub.once( @@ -45,6 +53,7 @@ describe("Messenger", () => { ) ), ]); + dbg("Messengers ready"); }); it("Sends & Receive public chat messages", async function () {