From 8a20b72bcb4ea7b8138aa7e26e47616c62359dae Mon Sep 17 00:00:00 2001 From: Rushil Perera Date: Sun, 6 Oct 2024 18:41:09 -0400 Subject: [PATCH] fix: update queue name for anilist updates --- src/controllers/watch-status/index.ts | 2 +- src/libs/tasks/queueName.ts | 2 +- src/libs/tasks/queueTask.ts | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) 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;