logos-messaging/logos-messaging-js
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-js.git synced 2026-01-20 17:03:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' into weboko/rename-repo

Browse Source
This commit is contained in:
Sasha 2026-01-05 20:43:59 +01:00 committed by GitHub
commit ba0593b23d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 21 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
packages/tests/tests/peer-cache/peer_cache.spec.ts
View File

@ -70,14 +70,16 @@ describe("Peer Cache Discovery", function () {
it("should discover peers from provided peer cache", async function () {
const mockCache = new MockPeerCache();
const peerId1 = (await nwaku1.getPeerId()).toString();
const peerId2 = (await nwaku2.getPeerId()).toString();
mockCache.set([
{
id: (await nwaku1.getPeerId()).toString(),
id: peerId1,
multiaddrs: [(await nwaku1.getMultiaddrWithId()).toString()]
},
{
id: (await nwaku2.getPeerId()).toString(),
id: peerId2,
multiaddrs: [(await nwaku2.getMultiaddrWithId()).toString()]
}
]);
@ -96,21 +98,22 @@ describe("Peer Cache Discovery", function () {
const discoveredPeers = new Set<string>();
await new Promise<void>((resolve) => {
waku.libp2p.addEventListener("peer:identify", (evt) => {
const peerId = evt.detail.peerId;
discoveredPeers.add(peerId.toString());
discoveredPeers.add(evt.detail.peerId.toString());
if (discoveredPeers.size === 2) {
if (discoveredPeers.has(peerId1) && discoveredPeers.has(peerId2)) {
resolve();
}
});
});
expect(dialPeerSpy.callCount).to.equal(2);
expect(discoveredPeers.size).to.equal(2);
expect(dialPeerSpy.callCount).to.be.greaterThanOrEqual(2);
expect(discoveredPeers).to.include(peerId1);
expect(discoveredPeers).to.include(peerId2);
});
it("should monitor connected peers and store them into cache", async function () {
const mockCache = new MockPeerCache();
const targetPeerId = (await nwaku2.getPeerId()).toString();
waku = await createLightNode({
networkConfig: DefaultTestNetworkConfig,
@ -126,19 +129,18 @@ describe("Peer Cache Discovery", function () {
await new Promise<void>((resolve) => {
waku.libp2p.addEventListener("peer:identify", (evt) => {
const peerId = evt.detail.peerId;
discoveredPeers.add(peerId.toString());
discoveredPeers.add(evt.detail.peerId.toString());
if (discoveredPeers.size === 1) {
if (discoveredPeers.has(targetPeerId)) {
resolve();
}
});
});
expect(discoveredPeers.size).to.equal(1);
expect(discoveredPeers).to.include(targetPeerId);
const cachedPeers = mockCache.get();
expect(cachedPeers.length).to.equal(1);
expect(discoveredPeers.has(cachedPeers[0].id)).to.be.true;
const isTargetCached = cachedPeers.some((p) => p.id === targetPeerId);
expect(isTargetCached).to.be.true;
});
});

4
packages/tests/tests/wait_for_remote_peer.node.spec.ts
View File

@ -170,7 +170,7 @@ describe("Wait for remote peer", function () {
await nwaku.start({
lightpush: true,
filter: false,
relay: false,
relay: true,
store: false
});
const multiAddrWithId = await nwaku.getMultiaddrWithId();
@ -229,7 +229,7 @@ describe("Wait for remote peer", function () {
await nwaku.start({
filter: true,
lightpush: true,
relay: false
relay: true
// store: true
});
const multiAddrWithId = await nwaku.getMultiaddrWithId();

6
packages/tests/tests/waku.node.spec.ts
View File

@ -57,7 +57,8 @@ describe("Waku Dial [node only]", function () {
await nwaku.start({
filter: true,
store: true,
lightpush: true
lightpush: true,
relay: true
});
const multiAddrWithId = await nwaku.getMultiaddrWithId();
@ -91,7 +92,8 @@ describe("Waku Dial [node only]", function () {
await nwaku.start({
filter: true,
store: true,
lightpush: true
lightpush: true,
relay: true
});
const multiAddrWithId = await nwaku.getMultiaddrWithId();