From f108458bd5a9657de97a7df3c027e72cf0d2f5a0 Mon Sep 17 00:00:00 2001 From: Florin Barbu Date: Thu, 25 Apr 2024 11:17:41 +0300 Subject: [PATCH] unskip shard 0 test fixed by 1874 --- .../tests/sharding/static_sharding.spec.ts | 31 +++++++++++++++++-- 1 file changed, 29 insertions(+), 2 deletions(-) diff --git a/packages/tests/tests/sharding/static_sharding.spec.ts b/packages/tests/tests/sharding/static_sharding.spec.ts index f487a184a3..c51e37cfcd 100644 --- a/packages/tests/tests/sharding/static_sharding.spec.ts +++ b/packages/tests/tests/sharding/static_sharding.spec.ts @@ -45,9 +45,25 @@ describe("Static Sharding: Running Nodes", function () { }); describe("Different clusters and shards", function () { - // Will be skipped until https://github.com/waku-org/js-waku/issues/1874 is fixed - it.skip("shard 0", async function () { + it("shard 0", async function () { const singleShardInfo = { clusterId: 0, shard: 0 }; + const shardInfo = singleShardInfosToShardInfo([singleShardInfo]); + + await nwaku.start({ + store: true, + lightpush: true, + relay: true, + pubsubTopic: shardInfoToPubsubTopics(shardInfo) + }); + + await nwaku.ensureSubscriptions(shardInfoToPubsubTopics(shardInfo)); + + waku = await createLightNode({ + shardInfo: shardInfo + }); + await waku.dial(await nwaku.getMultiaddrWithId()); + await waitForRemotePeer(waku, [Protocols.LightPush]); + const encoder = createEncoder({ contentTopic: ContentTopic, pubsubTopicShardInfo: singleShardInfo @@ -55,6 +71,17 @@ describe("Static Sharding: Running Nodes", function () { expect(encoder.pubsubTopic).to.eq( singleShardInfoToPubsubTopic(singleShardInfo) ); + + const request = await waku.lightPush.send(encoder, { + payload: utf8ToBytes("Hello World") + }); + + expect(request.successes.length).to.eq(1); + expect( + await messageCollector.waitForMessages(1, { + pubsubTopic: shardInfoToPubsubTopics(shardInfo)[0] + }) + ).to.eq(true); }); // dedicated test for Default Cluster ID 0