refactor: update script

* runs promises serially instead of running them all at once
* directly calls /new-episode route for latest episode

src/libs/promiseQueue.ts

@@ -0,0 +1,5 @@
+export async function promiseQueue(queue: (() => Promise<void>)[]) {
+  for (const promise of queue) {
+    await promise();
+  }
+}

src/scripts/initializeNextEpisodeQueue.ts

@@ -1,4 +1,5 @@
 import { fetchTitleFromAnilist } from "~/libs/anilist/getTitle";
+import { promiseQueue } from "~/libs/promiseQueue";
 import { queueTask } from "~/libs/tasks/queueTask";
 import { getDb } from "~/models/db";
 import { watchStatusTable } from "~/models/schema";
@@ -13,13 +14,14 @@ if (isDevMode) {
 }
 
 await getTitleIds().then((titles) =>
-  Promise.all(
+  promiseQueue(
-    titles.map((title) =>
+    titles.map(
-      triggerNextEpisodeRoute(title).then((success) =>
+      (title) => () =>
-        console.log(
+        triggerNextEpisodeRoute(title).then((success) =>
-          `Triggered next episode route for title ${title}: ${success}`,
+          console.log(
+            `Triggered next episode route for title ${title}: ${success}`,
+          ),
         ),
-      ),
     ),
   ),
 );
@@ -33,7 +35,13 @@ function getTitleIds() {
 }
 
 async function triggerNextEpisodeRoute(titleId: number) {
-  const title = await fetchTitleFromAnilist(titleId);
+  let title;
+  try {
+    title = await fetchTitleFromAnilist(titleId);
+  } catch (error) {
+    console.error(`Failed to fetch title ${titleId}`, error);
+    return false;
+  }
   if (!title) {
     console.error(`Failed to fetch title ${titleId}`);
     return false;
@@ -61,42 +69,31 @@ async function triggerNextEpisodeRoute(titleId: number) {
           return false;
         }
 
-        if (isDevMode) {
+        return fetch(`${serverUrl}/internal/new-episode`, {
-          return fetch("http://127.0.0.1:8080/internal/new-episode", {
+          method: "POST",
-            method: "POST",
+          headers: {
-            headers: {
+            "Content-Type": "application/json",
-              "Content-Type": "application/json",
+          },
-            },
+          body: JSON.stringify({
-            body: JSON.stringify({
-              aniListId: titleId,
-              episodeNumber: mostRecentEpisodeNumber,
-            }),
-          })
-            .then((res) => res.json() as Promise<{ success: boolean }>)
-            .then(({ success, error }) => {
-              if (!success) {
-                console.error(
-                  `Failed to trigger next episode route for title ${titleId} (most recent episode: ${mostRecentEpisodeNumber})`,
-                  error,
-                );
-              }
-
-              return success;
-            });
-        } else {
-          return queueTask(process.env, "new-episode", {
             aniListId: titleId,
             episodeNumber: mostRecentEpisodeNumber,
-          })
+          }),
-            .then(() => true)
+        })
-            .catch((error) => {
+          .then(
+            (res) =>
+              res.json() as Promise<{ success: boolean; message?: string }>,
+          )
+          .then((response) => {
+            const { success } = response;
+            if (!success) {
               console.error(
                 `Failed to trigger next episode route for title ${titleId} (most recent episode: ${mostRecentEpisodeNumber})`,
-                error,
+                response,
               );
-              return false;
+            }
-            });
+
-        }
+            return success;
+          });
       });
 
     if (!wasSuccessful) {