api: Retry processing recording up to 4 times (#2119)

livepeer · Apr 2, 2024 · 1fa939f · 1fa939f
1 parent 2c11962
commit 1fa939f
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/packages/api/src/webhooks/cannon.ts b/packages/api/src/webhooks/cannon.ts
@@ -467,7 +467,7 @@ export default class WebhookCannon {
 
   async handleRecordingWaitingChecks(
     sessionId: string,
-    isRetry = false
+    attempt = 1
   ): Promise<string> {
     const session = await db.session.get(sessionId, {
       useReplica: false,
@@ -482,13 +482,13 @@ export default class WebhookCannon {
       throw new UnprocessableEntityError("Session is unused");
     }
     if (lastSeen > activeThreshold) {
-      if (isRetry) {
+      if (attempt >= 5) {
         throw new UnprocessableEntityError("Session is still active");
       }
-      // there was an update after the delayed event was sent, so sleep a few
-      // secs (up to USER_SESSION_TIMEOUT) and re-check if it actually stopped.
+      // there was an update after the delayed event was sent, so sleep a few secs
+      // (up to 5s + USER_SESSION_TIMEOUT) and re-check if it actually stopped.
       await sleep(5000 + (lastSeen - activeThreshold));
-      return this.handleRecordingWaitingChecks(sessionId, true);
+      return this.handleRecordingWaitingChecks(sessionId, attempt + 1);
     }
 
     // if we got to this point, it means we're confident this session is inactive