hooks

medusajs · Jan 23, 2025 · 7f59786 · 7f59786
1 parent 75ae707
commit 7f59786
Show file tree

Hide file tree

Showing 3 changed files with 29 additions and 7 deletions.
diff --git a/packages/core/core-flows/src/product-category/workflows/create-product-categories.ts b/packages/core/core-flows/src/product-category/workflows/create-product-categories.ts
@@ -5,6 +5,7 @@ import {
   WorkflowResponse,
   createWorkflow,
   transform,
+  createHook
 } from "@medusajs/framework/workflows-sdk"
 import { emitEventStep } from "../../common"
 import { createProductCategoriesStep } from "../steps"
@@ -43,12 +44,13 @@ export const createProductCategoriesWorkflow = createWorkflow(
   (
     input: WorkflowData<ProductCategoryWorkflow.CreateProductCategoriesWorkflowInput>
   ): WorkflowResponse<CreateProductCategoriesWorkflowOutput> => {
-    const createdProducts = createProductCategoriesStep(input)
+
+    const createdCategories = createProductCategoriesStep(input)
 
     const productCategoryIdEvents = transform(
-      { createdProducts },
-      ({ createdProducts }) => {
-        return createdProducts.map((v) => {
+      { createdCategories },
+      ({ createdCategories }) => {
+        return createdCategories.map((v) => {
           return { id: v.id }
         })
       }
@@ -59,6 +61,12 @@ export const createProductCategoriesWorkflow = createWorkflow(
       data: productCategoryIdEvents,
     })
 
-    return new WorkflowResponse(createdProducts)
+    const categoriesCreated = createHook("categoriesCreated", {
+      categories: createdCategories
+    })
+
+    return new WorkflowResponse(createdCategories, {
+      hooks: [categoriesCreated]
+    })
   }
 )
diff --git a/packages/core/core-flows/src/product-category/workflows/delete-product-categories.ts b/packages/core/core-flows/src/product-category/workflows/delete-product-categories.ts
@@ -4,6 +4,7 @@ import {
   WorkflowResponse,
   createWorkflow,
   transform,
+  createHook
 } from "@medusajs/framework/workflows-sdk"
 import { emitEventStep } from "../../common"
 import { deleteProductCategoriesStep } from "../steps"
@@ -47,6 +48,12 @@ export const deleteProductCategoriesWorkflow = createWorkflow(
       data: productCategoryIdEvents,
     })
 
-    return new WorkflowResponse(deleted)
+    const categoriesDeleted = createHook("categoriesDeleted", {
+      ids: input,
+    })
+
+    return new WorkflowResponse(deleted, {
+      hooks: [categoriesDeleted]
+    })
   }
 )
diff --git a/packages/core/core-flows/src/product-category/workflows/update-product-categories.ts b/packages/core/core-flows/src/product-category/workflows/update-product-categories.ts
@@ -5,6 +5,7 @@ import {
   WorkflowResponse,
   createWorkflow,
   transform,
+  createHook,
 } from "@medusajs/framework/workflows-sdk"
 import { emitEventStep } from "../../common"
 import { updateProductCategoriesStep } from "../steps"
@@ -64,6 +65,12 @@ export const updateProductCategoriesWorkflow = createWorkflow(
       data: productCategoryIdEvents,
     })
 
-    return new WorkflowResponse(updatedCategories)
+    const categoriesUpdated = createHook("categoriesUpdated", {
+      categories: updatedCategories
+    })
+
+    return new WorkflowResponse(updatedCategories, {
+      hooks: [categoriesUpdated]
+    })
   }
 )