feat: randomize reconnect and watch checks.

Author: maximovicd

src/connection/client.ts

@@ -176,7 +176,7 @@ export class OpenFeedClient implements IOpenFeedClient {
 
             // eslint-disable-next-line no-await-in-loop
             await new Promise((resolve) => {
-                setTimeout(resolve, TIME.RECONNECT);
+                setTimeout(resolve, TIME.RECONNECT + Math.floor(Math.random() * TIME.RECONNECT_RANDOMIZE));
             });
         }
     };

src/connection/connection.ts

@@ -52,7 +52,7 @@ export class OpenFeedConnection implements IOpenFeedConnection {
             let timeoutId = null;
 
             const waitPromise = new Promise((resolve) => {
-                timeoutId = setTimeout(resolve, TIME.CONNECTION_TIMEOUT);
+                timeoutId = setTimeout(resolve, TIME.CONNECTION_TIMEOUT + Math.floor(Math.random() * TIME.RECONNECT_RANDOMIZE));
             });
 
             try {

src/utilities/constants.ts

@@ -1,5 +1,6 @@
 export const TIME = {
     RECONNECT: 5_000,
+    RECONNECT_RANDOMIZE: 5_000,
     CONNECTION_TIMEOUT: 15_000,
     SUBSCRIPTION_RETRY: 100,
 };

test/client.test.ts

@@ -64,8 +64,8 @@ describe("OpenFeedClient", () => {
     });
 
     afterEach(() => {
-        client.dispose();
         jest.clearAllMocks();
+        client.dispose();
     });
 
     it("should handle login flow correctly", async () => {
@@ -185,7 +185,7 @@ describe("OpenFeedClient", () => {
 
         // Use fake timers to fast-forward the reconnect delay
         jest.useFakeTimers();
-        await jest.advanceTimersByTimeAsync(TIME.RECONNECT);
+        await jest.advanceTimersByTimeAsync(TIME.RECONNECT + TIME.RECONNECT_RANDOMIZE);
         jest.useRealTimers();
 
         expect(disconnectSpy).toHaveBeenCalledTimes(1);