feat: update retry algorithm for qstash

avoids dlq until it has to

src/controllers/watch-status/index.ts

@@ -121,8 +121,8 @@ app.openapi(route, async (c) => {
     client.publishJSON({
       url: c.req.url,
       body: { deviceId, watchStatus, titleId, isRetrying: true },
-      retries: 0,
+      retries: 3,
-      delay: 60,
+      delay: "1m",
     });
   }
 

src/libs/anilist/getNextEpisodeAiringAt.ts

@@ -7,7 +7,7 @@ const GetNextEpisodeAiringAtQuery = graphql(`
       status
       nextAiringEpisode {
         episode
-        timeUntilAiring
+        airingAt
       }
     }
   }

src/libs/maybeScheduleNextAiringEpisode.ts

@@ -37,15 +37,14 @@ export async function maybeScheduleNextAiringEpisode(
     return;
   }
 
-  const { timeUntilAiring, episode: nextEpisode } = nextAiring;
+  const { airingAt, episode: nextEpisode } = nextAiring;
   const client = new Client({ token: env.QSTASH_TOKEN });
 
   const { messageId } = await client.publishJSON({
     url: `${domain}/internal/new-episode`,
     body: { aniListId, episodeNumber: nextEpisode },
-    retries: 0,
+    retries: 6,
-    delay: timeUntilAiring,
+    notBefore: airingAt,
-    contentBasedDeduplication: true,
   });
   await Promise.allSettled([
     setTitleMessage(env, aniListId, messageId),

src/scripts/initializeNextEpisodeQueue.ts

@@ -92,7 +92,7 @@ async function triggerNextEpisodeRoute(titleId: number) {
                 aniListId: titleId,
                 episodeNumber: mostRecentEpisodeNumber,
               },
-              retries: 0,
+              retries: 6,
             })
             .then(() => true)
             .catch((error) => {
@@ -124,8 +124,8 @@ async function triggerNextEpisodeRoute(titleId: number) {
         aniListId: titleId,
         episodeNumber: title.nextAiringEpisode.episode,
       },
-      retries: 0,
+      retries: 6,
-      delay: title.nextAiringEpisode.timeUntilAiring,
+      notBefore: title.nextAiringEpisode.airingAt,
     })
     .then(() => true)
     .catch((error) => {