add more debug

waku-org · Oct 1, 2024 · ce3a790 · ce3a790
1 parent ffd71c3
commit ce3a790
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/packages/core/src/lib/stream_manager/stream_manager.ts b/packages/core/src/lib/stream_manager/stream_manager.ts
@@ -23,8 +23,11 @@ export class StreamManager {
     const peerId = peer.id.toString();
 
     const scheduledStream = this.streamPool.get(peerId);
-    this.streamPool.delete(peerId);
-    await scheduledStream;
+
+    if (scheduledStream) {
+      this.streamPool.delete(peerId);
+      await scheduledStream;
+    }
 
     const stream = this.getOpenStreamForCodec(peer.id);
 

diff --git a/packages/tests/tests/filter/single_node/subscribe.node.spec.ts b/packages/tests/tests/filter/single_node/subscribe.node.spec.ts
@@ -280,9 +280,11 @@ describe("Waku Filter V2: Subscribe: Single Service Node", function () {
 
     // Send a unique message on each topic.
     for (let i = 0; i < topicCount; i++) {
+      const now = Date.now();
       await waku.lightPush.send(td.encoders[i], {
         payload: utf8ToBytes(`Message for Topic ${i + 1}`)
       });
+      console.log("DEBUG:", Date.now() - now);
     }
 
     // Verify that each message was received on the corresponding topic.
@@ -291,8 +293,7 @@ describe("Waku Filter V2: Subscribe: Single Service Node", function () {
       messageCollector.verifyReceivedMessage(index, {
         expectedContentTopic: topic,
         expectedMessageText: `Message for Topic ${index + 1}`,
-        expectedPubsubTopic: TestPubsubTopic,
-        checkTimestamp: false
+        expectedPubsubTopic: TestPubsubTopic
       });
     });
   });