feat: Configure OpenTelemetry logs and traces destinations in wrangler.toml

also updates Hono Zod related deps

README.md

@@ -66,6 +66,7 @@ pnpm run deploy
 
 - `src/controllers`: API route handlers (titles, episodes, search, etc.)
 - `src/libs`: Shared utilities and logic (AniList integration, background tasks)
+- `src/middleware`: Middleware handlers (authentication, authorization, etc.)
 - `src/models`: Database schema and models
 - `src/scripts`: Utility scripts for maintenance and setup
 - `src/types`: TypeScript type definitions

package.json

@@ -17,8 +17,8 @@
   },
   "dependencies": {
     "@hono/swagger-ui": "^0.5.1",
-    "@hono/zod-openapi": "^0.19.5",
-    "@hono/zod-validator": "^0.2.2",
+    "@hono/zod-openapi": "^1.1.6",
+    "@hono/zod-validator": "^0.7.6",
     "drizzle-orm": "^0.44.7",
     "gql.tada": "^1.8.10",
     "graphql": "^16.12.0",
@@ -27,7 +27,7 @@
     "jose": "^5.10.0",
     "lodash.mapkeys": "^4.6.0",
     "luxon": "^3.6.1",
-    "zod": "^3.24.3"
+    "zod": "^4.2.1"
   },
   "devDependencies": {
     "@cloudflare/vitest-pool-workers": "^0.10.15",

pnpm-lock.yaml

@@ -11,11 +11,11 @@ importers:
         specifier: ^0.5.1
         version: 0.5.2(hono@4.10.8)
       "@hono/zod-openapi":
-        specifier: ^0.19.5
-        version: 0.19.10(hono@4.10.8)(zod@3.25.76)
+        specifier: ^1.1.6
+        version: 1.1.6(hono@4.10.8)(zod@4.2.1)
       "@hono/zod-validator":
-        specifier: ^0.2.2
-        version: 0.2.2(hono@4.10.8)(zod@3.25.76)
+        specifier: ^0.7.6
+        version: 0.7.6(hono@4.10.8)(zod@4.2.1)
       drizzle-orm:
         specifier: ^0.44.7
         version: 0.44.7
@@ -41,8 +41,8 @@ importers:
         specifier: ^3.6.1
         version: 3.7.2
       zod:
-        specifier: ^3.24.3
-        version: 3.25.76
+        specifier: ^4.2.1
+        version: 4.2.1
     devDependencies:
       "@cloudflare/vitest-pool-workers":
         specifier: ^0.10.15
@@ -138,13 +138,13 @@ packages:
       graphql: ^15.5.0 || ^16.0.0 || ^17.0.0
       typescript: ^5.0.0
 
-  "@asteasolutions/zod-to-openapi@7.3.4":
+  "@asteasolutions/zod-to-openapi@8.2.0":
     resolution:
       {
-        integrity: sha512-/2rThQ5zPi9OzVwes6U7lK1+Yvug0iXu25olp7S0XsYmOqnyMfxH7gdSQjn/+DSOHRg7wnotwGJSyL+fBKdnEA==,
+        integrity: sha512-u05zNUirlukJAf9oEHmxSF31L1XQhz9XdpVILt7+xhrz65oQqBpiOWFkGvRWL0IpjOUJ878idKoNmYPxrFnkeg==,
       }
     peerDependencies:
-      zod: ^3.20.2
+      zod: ^4.0.0
 
   "@babel/code-frame@7.27.1":
     resolution:
@@ -1411,29 +1411,20 @@ packages:
     peerDependencies:
       hono: "*"
 
-  "@hono/zod-openapi@0.19.10":
+  "@hono/zod-openapi@1.1.6":
     resolution:
       {
-        integrity: sha512-dpoS6DenvoJyvxtQ7Kd633FRZ/Qf74+4+o9s+zZI8pEqnbjdF/DtxIib08WDpCaWabMEJOL5TXpMgNEZvb7hpA==,
+        integrity: sha512-wEdG1MlCWAnngRVPKZJ/dv5P/b5UL3di/+SLX0Cuuc8hJ6Gf8L3vDMXcXywSYAwxK8iiatF7HoTxJ96gtckLpQ==,
       }
     engines: { node: ">=16.0.0" }
     peerDependencies:
       hono: ">=4.3.6"
-      zod: ">=3.0.0"
+      zod: ^4.0.0
 
-  "@hono/zod-validator@0.2.2":
+  "@hono/zod-validator@0.7.6":
     resolution:
       {
-        integrity: sha512-dSDxaPV70Py8wuIU2QNpoVEIOSzSXZ/6/B/h4xA7eOMz7+AarKTSGV8E6QwrdcCbBLkpqfJ4Q2TmBO0eP1tCBQ==,
-      }
-    peerDependencies:
-      hono: ">=3.9.0"
-      zod: ^3.19.1
-
-  "@hono/zod-validator@0.7.5":
-    resolution:
-      {
-        integrity: sha512-n4l4hutkfYU07PzRUHBOVzUEn38VSfrh+UVE5d0w4lyfWDOEhzxIupqo5iakRiJL44c3vTuFJBvcmUl8b9agIA==,
+        integrity: sha512-Io1B6d011Gj1KknV4rXYz4le5+5EubcWEU/speUjuw9XMMIaP3n78yXLhjd2A3PXaXaUwEAluOiAyLqhBEJgsw==,
       }
     peerDependencies:
       hono: ">=3.9.0"
@@ -4137,6 +4128,12 @@ packages:
         integrity: sha512-gzUt/qt81nXsFGKIFcC3YnfEAx5NkunCfnDlvuBSSFS02bcXu4Lmea0AFIUwbLWxWPx3d9p8S5QoaujKcNQxcQ==,
       }
 
+  zod@4.2.1:
+    resolution:
+      {
+        integrity: sha512-0wZ1IRqGGhMP76gLqz8EyfBXKk0J2qo2+H3fi4mcUP/KtTocoX08nmIAHl1Z2kJIZbZee8KOpBCSNPRgauucjw==,
+      }
+
   zx@8.1.5:
     resolution:
       {
@@ -4156,10 +4153,10 @@ snapshots:
       graphql: 16.12.0
       typescript: 5.9.3
 
-  "@asteasolutions/zod-to-openapi@7.3.4(zod@3.25.76)":
+  "@asteasolutions/zod-to-openapi@8.2.0(zod@4.2.1)":
     dependencies:
       openapi3-ts: 4.5.0
-      zod: 3.25.76
+      zod: 4.2.1
 
   "@babel/code-frame@7.27.1":
     dependencies:
@@ -4705,23 +4702,18 @@ snapshots:
     dependencies:
       hono: 4.10.8
 
-  "@hono/zod-openapi@0.19.10(hono@4.10.8)(zod@3.25.76)":
+  "@hono/zod-openapi@1.1.6(hono@4.10.8)(zod@4.2.1)":
     dependencies:
-      "@asteasolutions/zod-to-openapi": 7.3.4(zod@3.25.76)
-      "@hono/zod-validator": 0.7.5(hono@4.10.8)(zod@3.25.76)
+      "@asteasolutions/zod-to-openapi": 8.2.0(zod@4.2.1)
+      "@hono/zod-validator": 0.7.6(hono@4.10.8)(zod@4.2.1)
       hono: 4.10.8
       openapi3-ts: 4.5.0
-      zod: 3.25.76
+      zod: 4.2.1
 
-  "@hono/zod-validator@0.2.2(hono@4.10.8)(zod@3.25.76)":
+  "@hono/zod-validator@0.7.6(hono@4.10.8)(zod@4.2.1)":
     dependencies:
       hono: 4.10.8
-      zod: 3.25.76
-
-  "@hono/zod-validator@0.7.5(hono@4.10.8)(zod@3.25.76)":
-    dependencies:
-      hono: 4.10.8
-      zod: 3.25.76
+      zod: 4.2.1
 
   "@img/sharp-darwin-arm64@0.33.5":
     optionalDependencies:
@@ -6301,6 +6293,8 @@ snapshots:
 
   zod@3.25.76: {}
 
+  zod@4.2.1: {}
+
   zx@8.1.5:
     optionalDependencies:
       "@types/fs-extra": 11.0.4

src/controllers/auth/anilist/index.ts

@@ -20,8 +20,8 @@ const UserSchema = z.object({
   }),
   statistics: z.object({
     minutesWatched: z.number().openapi({ type: "integer", format: "int64" }),
-    episodesWatched: z.number().int(),
-    count: z.number().int(),
+    episodesWatched: z.int(),
+    count: z.int(),
     meanScore: z.number().openapi({ type: "number", format: "float" }),
   }),
 });
@@ -129,15 +129,11 @@ app.openapi(route, async (c) => {
       let hasNextPage = true;
 
       do {
-        const stub = env.ANILIST_DO.getByName(user.name!);
-        const { mediaList, pageInfo } = await stub
-          .getTitles(
+        const { mediaList, pageInfo } = await getWatchingTitles(
           user.name!,
           currentPage++,
-            ["CURRENT", "PLANNING", "PAUSED", "REPEATING"],
           aniListToken,
-          )
-          .then((data) => data!);
+        ).then((data) => data!);
         if (!mediaList) {
           break;
         }

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

@@ -15,7 +15,7 @@ type AiringSchedule = {
   id: number;
 };
 
-export async function getUpcomingTitlesFromAnilist(req: HonoRequest) {
+export async function getUpcomingTitlesFromAnilist() {
   const durableObjectId = env.ANILIST_DO.idFromName("GLOBAL");
   const stub = env.ANILIST_DO.get(durableObjectId);
 

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

@@ -9,8 +9,8 @@ import { getUpcomingTitlesFromAnilist } from "./anilist";
 
 const app = new Hono();
 
-app.post("/", async (c) => {
-  const titles = await getUpcomingTitlesFromAnilist(c.req);
+export async function checkUpcomingTitles() {
+  const titles = await getUpcomingTitlesFromAnilist();
 
   await Promise.allSettled(
     titles.map(async (title) => {
@@ -44,6 +44,10 @@ app.post("/", async (c) => {
       });
     }),
   );
+}
+
+app.post("/", async (c) => {
+  await checkUpcomingTitles();
 
   return c.json(SuccessResponse, 200);
 });

src/controllers/popular/browse/index.ts

@@ -23,8 +23,8 @@ const route = createRoute({
   path: "/",
   request: {
     query: z.object({
-      limit: z
-        .number({ coerce: true })
+      limit: z.coerce
+        .number()
         .int()
         .default(10)
         .describe("The number of titles to return"),

src/controllers/popular/category/index.ts

@@ -22,12 +22,12 @@ const route = createRoute({
   path: "/{category}",
   request: {
     query: z.object({
-      limit: z
-        .number({ coerce: true })
+      limit: z.coerce
+        .number()
         .int()
-        .default(10)
+        .prefault(10)
         .describe("The number of titles to return"),
-      page: z.number({ coerce: true }).int().min(1).default(1),
+      page: z.coerce.number().int().min(1).prefault(1),
     }),
     params: z.object({ category: PopularCategory }),
   },

src/controllers/search/index.ts

@@ -17,8 +17,8 @@ const route = createRoute({
   request: {
     query: z.object({
       query: z.string(),
-      page: z.number({ coerce: true }).int().min(1).default(1),
-      limit: z.number({ coerce: true }).int().default(10),
+      page: z.coerce.number().int().min(1).prefault(1),
+      limit: z.coerce.number().int().prefault(10),
     }),
   },
   responses: {

src/controllers/title/index.spec.ts

@@ -51,7 +51,7 @@ describe('requests the "/title" route', () => {
       headers: new Headers({ "x-anilist-token": "asd" }),
     });
 
-    expect(await response.json()).toMatchSnapshot();
+    await expect(response.json()).resolves.toMatchSnapshot();
     expect(response.status).toBe(200);
   });
 
@@ -63,7 +63,7 @@ describe('requests the "/title" route', () => {
 
     const response = await app.request("/title?id=10");
 
-    expect(await response.json()).toMatchSnapshot();
+    await expect(response.json()).resolves.toMatchSnapshot();
     expect(response.status).toBe(200);
   });
 
@@ -75,7 +75,7 @@ describe('requests the "/title" route', () => {
 
     const response = await app.request("/title?id=-1");
 
-    expect(await response.json()).toEqual({ success: false });
+    await expect(response.json()).resolves.toEqual({ success: false });
     expect(response.status).toBe(404);
   });
 });

src/index.ts

@@ -121,9 +121,20 @@ export default {
     });
   },
   async scheduled(event, env, ctx) {
+    switch (event.cron) {
+      case "0 */12 * * *":
         const { processDelayedTasks } =
           await import("~/libs/tasks/processDelayedTasks");
         await processDelayedTasks(env);
+        break;
+      case "0 18 * * *":
+        const { checkUpcomingTitles } =
+          await import("~/controllers/internal/upcoming-titles");
+        await checkUpcomingTitles();
+        break;
+      default:
+        throw new Error(`Unhandled cron: ${event.cron}`);
+    }
   },
 } satisfies ExportedHandler<Env>;
 

src/libs/anilist/anilist-do.ts

@@ -24,9 +24,9 @@ import type { Title } from "~/types/title";
 
 const nextAiringEpisodeSchema = z.nullable(
   z.object({
-    episode: z.number().int(),
-    airingAt: z.number().int(),
-    timeUntilAiring: z.number().int(),
+    episode: z.int(),
+    airingAt: z.int(),
+    timeUntilAiring: z.int(),
   }),
 );
 
@@ -43,7 +43,7 @@ export class AnilistDurableObject extends DurableObject {
 
   async getTitle(
     id: number,
-    userId?: string,
+    userId?: number,
     token?: string,
   ): Promise<Title | null> {
     const promises: Promise<any>[] = [
@@ -135,8 +135,7 @@ export class AnilistDurableObject extends DurableObject {
           nextSeason,
           nextYear,
           limit,
-          page,
-        }).then((data) => data?.Page);
+        });
       },
       DateTime.now().plus({ days: 1 }),
     );
@@ -155,7 +154,8 @@ export class AnilistDurableObject extends DurableObject {
           nextSeason,
           nextYear,
           limit,
-        });
+          page,
+        }).then((data) => data?.Page);
       },
       DateTime.now().plus({ days: 1 }),
     );
@@ -276,13 +276,11 @@ export class AnilistDurableObject extends DurableObject {
 
     const result = await fetcher();
     await this.state.storage.put(key, result);
-    console.debug(`Retrieved alarms from cache:`, Object.entries(alarms));
 
     const calculatedTtl = typeof ttl === "function" ? ttl(result) : ttl;
     if (calculatedTtl) {
       const alarmTime = calculatedTtl.toMillis();
       await this.state.storage.setAlarm(alarmTime);
-      console.debug(`Deleting storage key ${storageKey} & alarm ${key}`);
       await this.state.storage.put(`alarm:${key}`, alarmTime);
     }
 
@@ -292,11 +290,13 @@ export class AnilistDurableObject extends DurableObject {
   async alarm() {
     const now = Date.now();
     const alarms = await this.state.storage.list({ prefix: "alarm:" });
+    console.debug(`Retrieved alarms from cache:`, Object.entries(alarms));
     for (const [key, ttl] of Object.entries(alarms)) {
       if (now >= ttl) {
         // The key in alarms is `alarm:${storageKey}`
         // We want to delete the storageKey
         const storageKey = key.replace("alarm:", "");
+        console.debug(`Deleting storage key ${storageKey} & alarm ${key}`);
         await this.state.storage.delete(storageKey);
         await this.state.storage.delete(key);
       }

src/libs/anilist/queries.ts

@@ -259,8 +259,8 @@ export const NextSeasonPopularQuery = graphql(
       $nextSeason: MediaSeason
       $nextYear: Int
       $limit: Int!
-    ) {
       $page: Int!
+    ) {
       Page(page: $page, perPage: $limit) {
         media(
           season: $nextSeason

src/libs/gcloud/getAdminSdkCredentials.ts

@@ -3,11 +3,13 @@ import mapKeys from "lodash.mapkeys";
 
 import { Case, changeStringCase } from "../changeStringCase";
 
-export function getAdminSdkCredentials(env: Cloudflare.Env = cloudflareEnv) {
+export function getAdminSdkCredentials(
+  env: Cloudflare.Env = cloudflareEnv,
+): AdminSdkCredentials {
   return mapKeys(
     JSON.parse(env.ADMIN_SDK_JSON) as AdminSdkCredentials,
     (_, key) => changeStringCase(key, Case.snake_case, Case.camelCase),
-  );
+  ) satisfies AdminSdkCredentials;
 }
 
 export interface AdminSdkCredentials {

src/libs/tasks/queueTask.ts

@@ -79,7 +79,18 @@ export async function queueTask(
   // Otherwise, queue directly
   const contentType =
     headers["Content-Type"] === "application/json" ? "json" : "text";
-  if (!env) {
+  if (env) {
+    console.debug(
+      `Queueing task in queue ${queueName}: ${JSON.stringify(body)}`,
+    );
+    await env[queueName].send(
+      { body, headers },
+      {
+        contentType,
+        delaySeconds: scheduleTime,
+      },
+    );
+  } else {
     const Cloudflare = await import("cloudflare").then(
       ({ Cloudflare }) => Cloudflare,
     );
@@ -103,14 +114,6 @@ export async function queueTask(
       delay_seconds: scheduleTime,
       account_id: env.CLOUDFLARE_ACCOUNT_ID,
     });
-  } else {
-    await env[queueName].send(
-      { body, headers },
-      {
-        contentType,
-        delaySeconds: scheduleTime,
-      },
-    );
   }
 }
 function buildTask(
@@ -122,16 +125,18 @@ function buildTask(
   let scheduleTime: number = 0;
   if (scheduleConfig) {
     const { delay, epochTime } = scheduleConfig;
+    console.log(`scheduleConfig ${JSON.stringify(scheduleConfig)}`);
     if (epochTime) {
-      console.log("epochTime", epochTime);
+      console.log(`epochTime ${epochTime}`);
       scheduleTime = DateTime.fromSeconds(epochTime)
         .diffNow("second")
         .as("second");
     } else if (delay) {
-      console.log("delay", delay);
+      console.log(`delay ${JSON.stringify(delay)}`);
       scheduleTime = Duration.fromDurationLike(delay).as("second");
     }
   }
+  console.log(`scheduleTime ${scheduleTime}`);
   const authorizationHeader = headers?.["X-Anilist-Token"]
     ? { Authorization: `Bearer ${headers["X-Anilist-Token"]}` }
     : {};

src/types/episode/fetch-url-response.ts

@@ -9,7 +9,7 @@ export const FetchUrlResponseSchema = z.object({
   audio: z.array(z.object({ url: z.string(), lang: z.string() })),
   intro: SkippableSchema,
   outro: SkippableSchema,
-  headers: z.record(z.string()).optional(),
+  headers: z.record(z.string(), z.string()).optional(),
 });
 
 export type FetchUrlResponse = z.infer<typeof FetchUrlResponse> & {

src/types/episode/index.ts

@@ -9,8 +9,8 @@ export const Episode = z.object({
   title: z.string().nullish(),
   img: z.string().nullish(),
   description: z.string().nullish(),
-  rating: z.number().int().nullish(),
-  updatedAt: z.number().int().default(0).openapi({ format: "int64" }),
+  rating: z.int().nullish(),
+  updatedAt: z.int().prefault(0).openapi({ format: "int64" }),
 });
 
 export type EpisodesResponse = z.infer<typeof EpisodesResponse>;

src/types/schema.ts

@@ -24,9 +24,9 @@ export const ErrorResponseSchema = z.object({
   success: z.literal(false).openapi({ type: "boolean" }),
 });
 
-export const NullableNumberSchema = z.number().int().nullable();
+export const NullableNumberSchema = z.int().nullable();
 
-export const AniListIdSchema = z.number().int().openapi({ format: "int64" });
+export const AniListIdSchema = z.int().openapi({ format: "int64" });
 export const AniListIdQuerySchema = z
   .string()
   .openapi({ type: "integer", format: "int64" });

src/types/title/index.ts

@@ -8,17 +8,17 @@ export type Title = z.infer<typeof Title>;
 export const Title = z.object({
   nextAiringEpisode: z.nullable(
     z.object({
-      episode: z.number().int(),
-      airingAt: z.number().int().openapi({ format: "int64" }),
-      timeUntilAiring: z.number().int().openapi({ format: "int64" }),
+      episode: z.int(),
+      airingAt: z.int().openapi({ format: "int64" }),
+      timeUntilAiring: z.int().openapi({ format: "int64" }),
     }),
   ),
   mediaListEntry: z.nullable(
     z.object({
       status: z.nullable(WatchStatus),
       progress: NullableNumberSchema,
-      id: z.number().int(),
-      updatedAt: z.number().int().openapi({ format: "int64" }).optional(),
+      id: z.int(),
+      updatedAt: z.int().openapi({ format: "int64" }).optional(),
     }),
   ),
   countryOfOrigin: countryCodeSchema,
@@ -50,5 +50,5 @@ export const Title = z.object({
     }),
   ),
   idMal: NullableNumberSchema,
-  id: z.number().int().openapi({ format: "int64" }),
+  id: z.int().openapi({ format: "int64" }),
 });

src/types/user.ts

@@ -14,7 +14,7 @@ export const UserProfile = z.object({
   statistics: z.object({
     minutesWatched: z.number().openapi({ type: "integer", format: "int64" }),
     episodesWatched: z.number().openapi({ type: "integer", format: "int64" }),
-    count: z.number().int(),
+    count: z.int(),
     meanScore: z.number().openapi({ type: "number", format: "float" }),
   }),
   id: z.number().openapi({ type: "integer", format: "int64" }),

wrangler.toml

@@ -17,6 +17,8 @@ class_name = "AnilistDo"
 
 [observability]
 enabled = true
+logs.destinations = ["otel-logs"]
+traces.destinations = ["otel-traces"]
 
 [[durable_objects.bindings]]
 name = "ANILIST_DO"
@@ -67,7 +69,7 @@ id = "c8db249d8ee7462b91f9c374321776e4"
 preview_id = "ff38240eb2aa4b1388c705f4974f5aec"
 
 [triggers]
-crons = ["0 */12 * * *"]
+crons = ["0 */12 * * *", "0 18 * * *"]
 
 [[d1_databases]]
 binding = "DB"