Fix duplicate jobs in product creation (#1376)

* Add jobId to prevent duplicate jobs

* Create snapshot after start

Author: FyreByrd

src/lib/server/workflow/index.ts

@@ -81,6 +81,7 @@ export class Workflow {
 
     await flow.createSnapshot(flow.flow.getSnapshot().context);
     flow.flow.start();
+    await flow.createSnapshot(flow.flow.getSnapshot().context);
     await DatabaseWrites.productTransitions.create({
       data: {
         ProductId: productId,

src/lib/server/workflow/state-machine.ts

@@ -305,7 +305,11 @@ export const WorkflowStateMachine = setup({
               type: BullMQ.JobType.Product_Create,
               productId: context.productId
             },
-            BullMQ.Retry0f600
+            {
+              ...BullMQ.Retry0f600,
+              // prevent duplicate jobs
+              jobId: `${BullMQ.JobType.Product_Create}_${context.productId}`
+            }
           );
         }
       ],