Merge pull request #31 from ocknamo/ci/fix-test

fix: correct expected subscription id
penpenpng · Jun 16, 2023 · ebeafd7 · ebeafd7
2 parents 72b6bf6 + 35162f3
commit ebeafd7
Showing 1 changed file with 12 additions and 12 deletions.
diff --git a/src/test/strategy.test.ts b/src/test/strategy.test.ts
@@ -42,11 +42,11 @@ describe("Single relay case", () => {
     req.emit([{ kinds: [0], limit: 5 }]);
     await expectReceiveMessage(relay, [
       "REQ",
-      "rx-nostr:sub:0",
+      "sub:0",
       { kinds: [0], limit: 5 },
     ]);
     await eoseSync;
-    await expectReceiveMessage(relay, ["CLOSE", "rx-nostr:sub:0"]);
+    await expectReceiveMessage(relay, ["CLOSE", "sub:0"]);
   });
 
   test("[backward] Receipt of EOSE does not terminate the Observable.", async () => {
@@ -83,22 +83,22 @@ describe("Single relay case", () => {
 
     await expectReceiveMessage(relay, [
       "REQ",
-      "rx-nostr:sub:0",
+      "sub:0",
       { kinds: [0], limit: 3 },
     ]);
     await expectReceiveMessage(relay, [
       "REQ",
-      "rx-nostr:sub:1",
+      "sub:1",
       { kinds: [0], limit: 2 },
     ]);
     await expectReceiveMessage(relay, [
       "REQ",
-      "rx-nostr:sub:2",
+      "sub:2",
       { kinds: [0], limit: 1 },
     ]);
-    await expectReceiveMessage(relay, ["CLOSE", "rx-nostr:sub:2"]);
-    await expectReceiveMessage(relay, ["CLOSE", "rx-nostr:sub:1"]);
-    await expectReceiveMessage(relay, ["CLOSE", "rx-nostr:sub:0"]);
+    await expectReceiveMessage(relay, ["CLOSE", "sub:2"]);
+    await expectReceiveMessage(relay, ["CLOSE", "sub:1"]);
+    await expectReceiveMessage(relay, ["CLOSE", "sub:0"]);
   });
 
   test("[forward] Each REQ is published with the same subId.", async () => {
@@ -112,20 +112,20 @@ describe("Single relay case", () => {
 
     await expectReceiveMessage(relay, [
       "REQ",
-      "rx-nostr:sub:0",
+      "sub:0",
       { kinds: [0], limit: 1 },
     ]);
     await expectReceiveMessage(relay, [
       "REQ",
-      "rx-nostr:sub:0",
+      "sub:0",
       { kinds: [0], limit: 2 },
     ]);
     await expectReceiveMessage(relay, [
       "REQ",
-      "rx-nostr:sub:0",
+      "sub:0",
       { kinds: [0], limit: 3 },
     ]);
-    await expectReceiveMessage(relay, ["CLOSE", "rx-nostr:sub:0"]);
+    await expectReceiveMessage(relay, ["CLOSE", "sub:0"]);
   });
 
   test("[oneshot] Receipt of EOSE terminates the Observable.", async () => {