fix: test add delay

dao-xyz · Dec 13, 2023 · 410be43 · 410be43
1 parent 07c80ee
commit 410be43
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/packages/transport/pubsub/src/__tests__/index.test.ts b/packages/transport/pubsub/src/__tests__/index.test.ts
@@ -750,6 +750,8 @@ describe("pubsub", function () {
 					[session.peers[0], session.peers[2]]
 				]);
 
+				await delay(5000);
+
 				for (const [i, peer] of session.peers.entries()) {
 					await peer.services.pubsub.subscribe(TOPIC);
 				}
@@ -777,9 +779,6 @@ describe("pubsub", function () {
 				});
 
 				await delay(3000);
-				const a = streams.map((x) => x.stream.routes.routes.size);
-				const b = streams.map((x) => x.stream.routes.routes.size);
-				const c = streams.map((x) => x.stream.routes.routes.size);
 
 				streams[1].received = [];
 				streams[2].received = [];
@@ -1125,7 +1124,10 @@ describe("pubsub", function () {
 				() =>
 					!streams[2].stream.topics
 						.get(TOPIC_1)
-						?.has(streams[0].stream.publicKeyHash)
+						?.has(streams[0].stream.publicKeyHash),
+				{
+					timeout: 20 * 1000
+				}
 			);
 
 			expect(streams[2].subscriptionEvents).toHaveLength(1);

diff --git a/packages/transport/stream/src/__tests__/stream.test.ts b/packages/transport/stream/src/__tests__/stream.test.ts
@@ -732,6 +732,7 @@ describe("streams", function () {
 				let totalWrites = 10;
 				expect(streams[0].ack).toHaveLength(0);
 
+				await delay(5000);
 				//  push one message to ensure paths are found
 				await streams[0].stream.publish(data, {
 					mode: new SeekDelivery({