add delay

Signed-off-by: MregXN <[email protected]>
dapr · Nov 28, 2023 · f5ff510 · f5ff510
1 parent c506be6
commit f5ff510
Showing 1 changed file with 17 additions and 17 deletions.
diff --git a/test/e2e/common/server.test.ts b/test/e2e/common/server.test.ts
@@ -137,11 +137,11 @@ describe("common/server", () => {
 
     await httpServer.start();
     await grpcServer.start();
+    jest.setTimeout(8000); // Set the timeout to 8 seconds
   });
 
   beforeEach(() => {
     jest.clearAllMocks();
-    jest.setTimeout(8000); // Set the timeout to 8 seconds
   });
 
   afterAll(async () => {
@@ -162,7 +162,7 @@ describe("common/server", () => {
         const res = await server.client.pubsub.publish(pubSubName, getTopic(topicWithStatusCb, protocol), "SUCCESS");
         expect(res.error).toBeUndefined();
         // Delay a bit for event to arrive
-        await new Promise((resolve, _reject) => setTimeout(resolve, 1500));
+        await new Promise((resolve, _reject) => setTimeout(resolve, 2000));
         expect(mockSubscribeStatusHandler.mock.calls.length).toBe(1);
         expect(mockSubscribeStatusHandler.mock.calls[0][1]).toEqual("SUCCESS");
         expect(mockSubscribeDeadletterHandler.mock.calls.length).toBe(0);
@@ -179,7 +179,7 @@ describe("common/server", () => {
         );
         expect(res.error).toBeUndefined();
         // Delay a bit for event to arrive
-        await new Promise((resolve, _reject) => setTimeout(resolve, 1500));
+        await new Promise((resolve, _reject) => setTimeout(resolve, 2000));
         // 3 as we retry twice
         expect(mockSubscribeStatusHandler.mock.calls.length).toBe(3);
         expect(mockSubscribeDeadletterHandler.mock.calls.length).toBe(0);
@@ -192,7 +192,7 @@ describe("common/server", () => {
         const res = await server.client.pubsub.publish(pubSubName, getTopic(topicWithStatusCb, protocol), "DROP");
         expect(res.error).toBeUndefined();
         // Delay a bit for event to arrive
-        await new Promise((resolve, _reject) => setTimeout(resolve, 1500));
+        await new Promise((resolve, _reject) => setTimeout(resolve, 2000));
         expect(mockSubscribeStatusHandler.mock.calls.length).toBe(1);
         expect(mockSubscribeStatusHandler.mock.calls[0][1]).toEqual("DROP");
       },
@@ -202,7 +202,7 @@ describe("common/server", () => {
       const res = await server.client.pubsub.publish(pubSubName, getTopic(topicDefault, protocol), "Hello, world!");
       expect(res.error).toBeUndefined();
       // Delay a bit for event to arrive
-      await new Promise((resolve, _reject) => setTimeout(resolve, 1500));
+      await new Promise((resolve, _reject) => setTimeout(resolve, 2000));
       expect(mockSubscribeHandler.mock.calls.length).toBe(1);
       expect(mockSubscribeHandler.mock.calls[0][0]).toEqual("Hello, world!");
       const headers = mockSubscribeHandler.mock.calls[0][1] as any;
@@ -324,7 +324,7 @@ describe("common/server", () => {
       });
       expect(res.error).toBeUndefined();
       // Delay a bit for event to arrive
-      await new Promise((resolve, _reject) => setTimeout(resolve, 1500));
+      await new Promise((resolve, _reject) => setTimeout(resolve, 2000));
       expect(mockSubscribeHandler.mock.calls.length).toBe(1);
       expect(mockSubscribeHandler.mock.calls[0][0]).toEqual({ message: "Hello, world!" });
     });
@@ -341,7 +341,7 @@ describe("common/server", () => {
       const res = await server.client.pubsub.publish(pubSubName, getTopic(topicDefault, protocol), ce);
       expect(res.error).toBeUndefined();
       // Delay a bit for event to arrive
-      await new Promise((resolve, _reject) => setTimeout(resolve, 1000));
+      await new Promise((resolve, _reject) => setTimeout(resolve, 1500));
       expect(mockSubscribeHandler.mock.calls.length).toBe(1);
       expect(mockSubscribeHandler.mock.calls[0][0]).toEqual("Hello, world!");
     });
@@ -359,7 +359,7 @@ describe("common/server", () => {
       const res = await server.client.pubsub.publish(pubSubName, getTopic(topicDefault, protocol), ce, options);
       expect(res.error).toBeUndefined();
       // Delay a bit for event to arrive
-      await new Promise((resolve, _reject) => setTimeout(resolve, 1000));
+      await new Promise((resolve, _reject) => setTimeout(resolve, 1500));
       expect(mockSubscribeHandler.mock.calls.length).toBe(1);
       // The cloudevent should contain an inner cloudevent since the content type was application/json
       const innerCe: any = mockSubscribeHandler.mock.calls[0][0];
@@ -376,7 +376,7 @@ describe("common/server", () => {
         );
         expect(res.error).toBeUndefined();
         // Delay a bit for event to arrive
-        await new Promise((resolve, _reject) => setTimeout(resolve, 1500));
+        await new Promise((resolve, _reject) => setTimeout(resolve, 2000));
         expect(mockSubscribeHandler.mock.calls.length).toBe(1);
         const rawData: any = mockSubscribeHandler.mock.calls[0][0];
         expect(rawData["data"]).toEqual("Hello, world!");
@@ -391,7 +391,7 @@ describe("common/server", () => {
         });
         expect(res.error).toBeUndefined();
         // Delay a bit for event to arrive
-        await new Promise((resolve, _reject) => setTimeout(resolve, 1500));
+        await new Promise((resolve, _reject) => setTimeout(resolve, 2000));
         expect(mockSubscribeHandler.mock.calls.length).toBe(1);
         const rawData: any = mockSubscribeHandler.mock.calls[0][0];
         expect(rawData["data"]).toEqual({ message: "Hello, world!" });
@@ -409,7 +409,7 @@ describe("common/server", () => {
         );
         expect(res.error).toBeUndefined();
         // Delay a bit for event to arrive
-        await new Promise((resolve, _reject) => setTimeout(resolve, 1500));
+        await new Promise((resolve, _reject) => setTimeout(resolve, 2000));
         expect(mockSubscribeHandler.mock.calls.length).toBe(1);
         expect(mockSubscribeHandler.mock.calls[0][0]).toEqual("Hello, world!");
       },
@@ -426,7 +426,7 @@ describe("common/server", () => {
         );
         expect(res.error).toBeUndefined();
         // Delay a bit for event to arrive
-        await new Promise((resolve, _reject) => setTimeout(resolve, 1500));
+        await new Promise((resolve, _reject) => setTimeout(resolve, 2000));
         expect(mockSubscribeHandler.mock.calls.length).toBe(1);
         expect(mockSubscribeHandler.mock.calls[0][0]).toEqual({ message: "Hello, world!" });
       },
@@ -440,7 +440,7 @@ describe("common/server", () => {
         });
         expect(res.error).toBeUndefined();
         // Delay a bit for event to arrive
-        await new Promise((resolve, _reject) => setTimeout(resolve, 1500));
+        await new Promise((resolve, _reject) => setTimeout(resolve, 2000));
         expect(mockSubscribeHandler.mock.calls.length).toBe(1);
         expect(mockSubscribeHandler.mock.calls[0][0]).toEqual({ message: "Hello, world!" });
       },
@@ -607,7 +607,7 @@ describe("common/server", () => {
         });
         expect(res.error).toBeUndefined();
         // Delay a bit for event to arrive
-        await new Promise((resolve, _reject) => setTimeout(resolve, 1500));
+        await new Promise((resolve, _reject) => setTimeout(resolve, 2000));
         expect(mockSubscribeErrorHandler).toHaveBeenCalledTimes(1);
         expect(mockSubscribeErrorHandler.mock.calls[0][0]).toEqual({ message: "Hello, world!" });
         expect(mockSubscribeHandler).toHaveBeenCalledTimes(0);
@@ -622,7 +622,7 @@ describe("common/server", () => {
           message: "Hello, world!",
         });
         // Delay a bit for event to arrive
-        await new Promise((resolve, _reject) => setTimeout(resolve, 1500));
+        await new Promise((resolve, _reject) => setTimeout(resolve, 2000));
         expect(mockSubscribeHandler.mock.calls.length).toBe(1);
         expect(mockSubscribeHandler.mock.calls[0][0]).toEqual({ message: "Hello, world!" });
       },
@@ -636,7 +636,7 @@ describe("common/server", () => {
           message: "Hello, world!",
         });
         // Delay a bit for event to arrive
-        await new Promise((resolve, _reject) => setTimeout(resolve, 1500));
+        await new Promise((resolve, _reject) => setTimeout(resolve, 2000));
         expect(mockSubscribeHandler.mock.calls.length).toBe(1);
         expect(mockSubscribeHandler.mock.calls[0][0]).toEqual({ message: "Hello, world!" });
       },
@@ -648,7 +648,7 @@ describe("common/server", () => {
         const messages = ["message1", "message2", "message3"];
         await server.client.pubsub.publishBulk(pubSubName, getTopic(topicWithBulk, protocol), messages);
         // Delay a bit for events to arrive
-        await new Promise((resolve) => setTimeout(resolve, 1500));
+        await new Promise((resolve) => setTimeout(resolve, 2000));
         expect(mockSubscribeHandler.mock.calls.length).toBe(3);
         // Check that the messages are present
         mockSubscribeHandler.mock.calls.forEach((call) => {