notify is now await

Author: James-Voight

src/lib/products/server.ts

@@ -4,7 +4,11 @@ import { DatabaseReads, DatabaseWrites } from '$lib/server/database';
 import { Workflow } from '$lib/server/workflow';
 import { ProductActionType } from '.';
 
-export async function doProductAction(productId: string, action: ProductActionType) {
+export async function doProductAction(
+  productId: string,
+  action: ProductActionType,
+  isAutomatic = false
+) {
   const product = await DatabaseReads.products.findUnique({
     where: {
       Id: productId
@@ -50,7 +54,7 @@ export async function doProductAction(productId: string, action: ProductActionTy
             productType: product.ProductDefinition[flowType].ProductType,
             options: new Set(product.ProductDefinition[flowType].WorkflowOptions),
             workflowType: product.ProductDefinition[flowType].Type,
-            isAutomatic: false
+            isAutomatic
           });
         }
         break;

src/lib/server/workflow/dbProcedures.ts

@@ -70,7 +70,7 @@ export async function notifyAutoPublishOwner(productId: string) {
     }
   });
   if (!product?.Project.OwnerId) return;
-  void getQueues().Emails.add(`Notify Owner of Auto Publish for Product #${productId}`, {
+  await getQueues().Emails.add(`Notify Owner of Auto Publish for Product #${productId}`, {
     type: BullMQ.JobType.Email_SendNotificationToUser,
     userId: product.Project.OwnerId,
     messageKey: 'autoPublishOnRebuildCompleted',