logos-messaging-js/src/lib/waku.spec.ts

import type { PeerId } from "@libp2p/interface-peer-id";
import { expect } from "chai";

import { createWaku } from "./create_waku";
import { Waku } from "./waku";

describe("Waku Dial", function () {
  describe("Bootstrap [live data]", function () {
    let waku: Waku;

    afterEach(function () {
      !!waku && waku.stop().catch((e) => console.log("Waku failed to stop", e));
    });

    before(function () {
      if (process.env.CI) {
        this.skip();
      }
    });

    it("Enabling default [live data]", async function () {
      // This test depends on fleets.status.im being online.
      // This dependence must be removed once DNS discovery is implemented
      this.timeout(20_000);

      waku = await createWaku({
        defaultBootstrap: true,
      });
      await waku.start();

      const connectedPeerID: PeerId = await new Promise((resolve) => {
        waku.libp2p.connectionManager.addEventListener(
          "peer:connect",
          (evt) => {
            resolve(evt.detail.remotePeer);
          }
        );
      });

      expect(connectedPeerID).to.not.be.undefined;
    });
  });
});