diff --git a/src/controllers/watch-status/index.ts b/src/controllers/watch-status/index.ts index 9b237c7..b58d9a5 100644 --- a/src/controllers/watch-status/index.ts +++ b/src/controllers/watch-status/index.ts @@ -118,7 +118,7 @@ app.openapi(route, async (c) => { await queueTask( env(c, "workerd"), - "anilist", + "anilist-updates", { deviceId, watchStatus, diff --git a/src/libs/tasks/queueName.ts b/src/libs/tasks/queueName.ts index 0e61e25..a5a1a17 100644 --- a/src/libs/tasks/queueName.ts +++ b/src/libs/tasks/queueName.ts @@ -1 +1 @@ -export type QueueName = "anilist" | "new-episode"; +export type QueueName = "anilist-updates" | "new-episode"; diff --git a/src/libs/tasks/queueTask.ts b/src/libs/tasks/queueTask.ts index 182f708..5717304 100644 --- a/src/libs/tasks/queueTask.ts +++ b/src/libs/tasks/queueTask.ts @@ -11,7 +11,7 @@ import { buildAnilistRetryTaskId, buildNewEpisodeTaskId } from "./id"; import type { QueueName } from "./queueName"; type QueueBody = { - anilist: { + "anilist-updates": { deviceId: string; watchStatus: WatchStatus | null; titleId: number;