fix: update retry

src/controllers/internal/new-episode/index.ts

@@ -65,10 +65,6 @@ app.post(
     } = await fetchEpisodes(aniListId, isAnifyEnabled);
     if (fetchEpisodesErrorOccurred) {
       console.error(`Failed to fetch episodes for title ${aniListId}`);
-      await scheduleRetry(
-        readEnvVariable(env<Env, typeof c>(c, "workerd"), "QSTASH_TOKEN"),
-        c.req,
-      );
       return c.json(
         { success: false, message: "Failed to fetch episodes" },
         500,
@@ -80,10 +76,6 @@ app.post(
       (episode) => episode.number === episodeNumber,
     );
     if (!episode) {
-      await scheduleRetry(
-        readEnvVariable(env<Env, typeof c>(c, "workerd"), "QSTASH_TOKEN"),
-        c.req,
-      );
       return c.json({ success: false, message: "Episode not found" }, 404);
     }
 
@@ -97,10 +89,6 @@ app.post(
       );
       if (!fetchUrlResult) {
         console.error(`Failed to fetch episode URL for episode ${episode.id}`);
-        await scheduleRetry(
-          readEnvVariable(env<Env, typeof c>(c, "workerd"), "QSTASH_TOKEN"),
-          c.req,
-        );
         return c.json(
           { success: false, message: "Episode URL not found" },
           404,
@@ -108,10 +96,6 @@ app.post(
       }
     } catch (error) {
       console.error(`Failed to fetch episode URL for episode ${episode.id}`);
-      await scheduleRetry(
-        readEnvVariable(env<Env, typeof c>(c, "workerd"), "QSTASH_TOKEN"),
-        c.req,
-      );
       return c.json(
         { success: false, message: "Failed to fetch episode URL" },
         500,
@@ -158,13 +142,4 @@ app.post(
   },
 );
 
-async function scheduleRetry(qstashToken: string, req: HonoRequest) {
-  return new Client({ token: qstashToken }).publishJSON({
-    body: await req.json(),
-    url: req.url,
-    retries: 0,
-    delay: "1h",
-  });
-}
-
 export default app;