feat: add calculateDelay function to media controller (#609)

* feat: add calculateDelay function to media controller

* test: fix test

* ci: downgrade @types/node version

Author: junhyr

package.json

@@ -29,7 +29,7 @@
     "@biomejs/biome": "^1.7.3",
     "@changesets/changelog-github": "^0.5.0",
     "@changesets/cli": "^2.27.3",
-    "@types/node": "22.3.0",
+    "@types/node": "^20.12.12",
     "@vitest/coverage-c8": "^0.33.0",
     "@vitest/coverage-v8": "^2.0.5",
     "@vitest/ui": "^2.0.5",

packages/core-web/src/broadcast.test.ts

@@ -7,6 +7,7 @@ it("should expose correct exports", () => {
     [
       "addBroadcastEventListeners",
       "createBroadcastStore",
+      "createSilentAudioTrack",
       "getBroadcastDeviceInfo",
     ]
   `);

packages/core-web/src/media/controls/controller.ts

@@ -366,6 +366,7 @@ const addEffectsToStore = (
       autoPlay: __initialProps.autoPlay,
       backoff: __initialProps.backoff,
       backoffMax: __initialProps.backoffMax,
+      calculateDelay: __initialProps.calculateDelay,
       errorCount,
       hlsConfig: __controls.hlsConfig,
       mounted,
@@ -379,6 +380,7 @@ const addEffectsToStore = (
       autoPlay,
       backoff,
       backoffMax,
+      calculateDelay,
       errorCount,
       hlsConfig,
       mounted,
@@ -393,10 +395,9 @@ const addEffectsToStore = (
 
       await cleanupSource?.();
 
-      if (errorCount > 0) {
-        const delayTime = Math.min(backoff * 2 ** (errorCount - 1), backoffMax);
-        await delay(delayTime);
-      }
+      await delay(
+        Math.max(calculateDelay(errorCount), errorCount === 0 ? 0 : 100),
+      );
 
       let unmounted = false;
 

packages/core/src/media/controller.ts

@@ -63,6 +63,13 @@ export type InitialProps = {
    */
   backoffMax: number;
 
+  /**
+   * A function that calculates the delay for the backoff.
+   *
+   * This is used to calculate the delay for the backoff.
+   */
+  calculateDelay: (attempt: number) => number;
+
   /**
    * The length of the clip. This is usually used alongside `ClipTrigger`. Specifies the duration of the media clip, in seconds.
    *
@@ -653,7 +660,20 @@ export const createControllerStore = ({
             aspectRatio: initialProps?.aspectRatio ?? null,
             autoPlay: initialProps.autoPlay ?? false,
             backoff: Math.max(initialProps.backoff ?? 500, 100),
-            backoffMax: Math.max(initialProps.backoffMax ?? 30000, 1000),
+            backoffMax: Math.max(initialProps.backoffMax ?? 30000, 10000),
+            calculateDelay:
+              initialProps.calculateDelay ??
+              ((count) => {
+                if (count === 0) {
+                  return 0;
+                }
+
+                const delayTime = Math.min(
+                  Math.max(initialProps.backoff ?? 500, 100) * 2 ** (count - 1),
+                  Math.max(initialProps.backoffMax ?? 30000, 10000),
+                );
+                return delayTime;
+              }),
             clipLength: initialProps.clipLength ?? null,
             cacheWebRTCFailureMs: initialProps.cacheWebRTCFailureMs ?? null,
             hotkeys: initialProps?.hotkeys ?? true,

packages/core/src/version.ts

@@ -1,5 +1,5 @@
 const core = "@livepeer/[email protected]";
-const react = "@livepeer/[email protected].2";
+const react = "@livepeer/[email protected].3";
 
 export const version = {
   core,