feat: add more 429 checks

src/controllers/auth/anilist/getUser.ts

@@ -55,6 +55,7 @@ export async function getUser(aniListToken: string): Promise<User> {
     if (err.response?.status === 401) {
       return null;
     } else if (err.response?.status === 429) {
+      console.log("429, retrying in", err.response.headers.get("Retry-After"));
       return sleep(
         Number(err.response.headers.get("Retry-After")!) * 1000,
       ).then(() => getUser(aniListToken));

src/controllers/internal/upcoming-titles/anilist.ts

@@ -88,7 +88,7 @@ export async function getUpcomingTitlesFromAnilist(env: Env, req: HonoRequest) {
     shouldContinue = pageInfo?.hasNextPage ?? false;
   } while (shouldContinue);
 
-  await Promise.allSettled(
+  await Promise.all(
     Array.from(plannedToWatchTitles).map((titleId) =>
       maybeScheduleNextAiringEpisode(env, req, titleId),
     ),

src/controllers/search/anilist.ts

@@ -1,6 +1,8 @@
 import { graphql } from "gql.tada";
 import { GraphQLClient } from "graphql-request";
 
+import { sleep } from "~/libs/sleep";
+
 const SearchQuery = graphql(`
   query Search($query: String!, $page: Int!, $limit: Int!) {
     Page(page: $page, perPage: $limit) {
@@ -27,7 +29,7 @@ export async function fetchSearchResultsFromAnilist(
   query: string,
   page: number,
   limit: number,
-) {
+): Promise<SearchResultsResponse | undefined> {
   const client = new GraphQLClient("https://graphql.anilist.co/");
 
   return client
@@ -40,5 +42,31 @@ export async function fetchSearchResultsFromAnilist(
 
       const { media: results, pageInfo } = page;
       return { results, hasNextPage: pageInfo?.hasNextPage };
+    })
+    .catch((err) => {
+      const response = err.response;
+      if (response.status === 429) {
+        console.log("429, retrying in", response.headers.get("Retry-After"));
+        return sleep(Number(response.headers.get("Retry-After")!) * 1000).then(
+          () => fetchSearchResultsFromAnilist(query, page, limit),
+        );
+      }
+
+      throw err;
     });
 }
+
+type SearchResultsResponse = {
+  results:
+    | ({
+        id: number;
+        title: { userPreferred: string | null; english: string | null } | null;
+        coverImage: {
+          extraLarge: string | null;
+          large: string | null;
+          medium: string | null;
+        } | null;
+      } | null)[]
+    | null;
+  hasNextPage: boolean | null | undefined;
+};