♻️ refactor: use generationBatchId as notification dedupeKey

src/app/(backend)/api/webhooks/video/[provider]/route.ts

@@ -203,9 +203,9 @@ export const POST = async (req: Request, { params }: { params: Promise<{ provide
     });
 
     notifyVideoCompleted({
+      generationBatchId: generation.generationBatchId!,
       model: resolvedModel,
       prompt: batch?.prompt ?? '',
-      taskId: asyncTask.id,
       topicId: batch?.generationTopicId,
       userId: asyncTask.userId,
     }).catch((err) => console.error('[video-webhook] notification failed:', err));

src/business/server/image-generation/notifyImageCompleted.ts

@@ -1,8 +1,8 @@
 interface NotifyImageCompletedParams {
   duration: number;
+  generationBatchId: string;
   model: string;
   prompt: string;
-  taskId: string;
   topicId?: string;
   userId: string;
 }

src/business/server/video-generation/notifyVideoCompleted.ts

@@ -1,7 +1,7 @@
 interface NotifyVideoCompletedParams {
+  generationBatchId: string;
   model: string;
   prompt: string;
-  taskId: string;
   topicId?: string;
   userId: string;
 }

src/server/routers/async/image.ts

@@ -345,9 +345,9 @@ export const imageRouter = router({
 
           notifyImageCompleted({
             duration,
+            generationBatchId,
             model,
             prompt: params.prompt,
-            taskId,
             topicId: generationTopicId,
             userId: ctx.userId,
           }).catch((err) => console.error('[image-async] notification failed:', err));