PS-489 - when receiving SubmissionScanCompleteHandler, check if ai workflows have already been queued. if so, prevent further queueing

Author: vas3a

src/shared/modules/global/submission-scan-complete.orchestrator.ts

@@ -49,6 +49,18 @@ export class SubmissionScanCompleteOrchestrator {
         return;
       }
 
+      // check if workflow runs have already been queued for this submission
+      const alreadyQueued = await this.workflowQueueHandler.hasQueuedWorkflowRuns(
+        submissionId,
+      );
+
+      if (alreadyQueued) {
+        this.logger.log(
+          `AI workflow runs already queued for submission ${submissionId}. Skipping queueing.`,
+        );
+        return;
+      }
+
       await this.workflowQueueHandler.queueWorkflowRuns(
         challenge.workflows,
         challenge.id,

src/shared/modules/global/workflow-queue.handler.ts

@@ -79,6 +79,18 @@ export class WorkflowQueueHandler implements OnModuleInit {
     });
   }
 
+  async hasQueuedWorkflowRuns(submissionId: string): Promise<boolean> {
+    if (!submissionId) return false;
+
+    const existing = await this.prisma.aiWorkflowRun.findFirst({
+      where: {
+        submissionId,
+      },
+    });
+
+    return !!existing;
+  }
+
   async handleQueuedWorkflowRun([job]: [Job]) {
     this.logger.log(`Processing job ${job.id}`);