product categories hooks (#11093)

* hooks

* workflow result fixed

packages/core/core-flows/src/product-category/workflows/create-product-categories.ts

@@ -1,10 +1,14 @@
-import { ProductCategoryDTO, ProductCategoryWorkflow } from "@medusajs/framework/types"
+import {
+  ProductCategoryDTO,
+  ProductCategoryWorkflow,
+} from "@medusajs/framework/types"
 import { ProductCategoryWorkflowEvents } from "@medusajs/framework/utils"
 import {
-  WorkflowData,
+  createHook,
-  WorkflowResponse,
   createWorkflow,
   transform,
+  WorkflowData,
+  WorkflowResponse,
 } from "@medusajs/framework/workflows-sdk"
 import { emitEventStep } from "../../common"
 import { createProductCategoriesStep } from "../steps"
@@ -42,13 +46,13 @@ export const createProductCategoriesWorkflow = createWorkflow(
   createProductCategoriesWorkflowId,
   (
     input: WorkflowData<ProductCategoryWorkflow.CreateProductCategoriesWorkflowInput>
-  ): WorkflowResponse<CreateProductCategoriesWorkflowOutput> => {
+  ) => {
-    const createdProducts = createProductCategoriesStep(input)
+    const createdCategories = createProductCategoriesStep(input)
 
     const productCategoryIdEvents = transform(
-      { createdProducts },
+      { createdCategories },
-      ({ createdProducts }) => {
+      ({ createdCategories }) => {
-        return createdProducts.map((v) => {
+        return createdCategories.map((v) => {
           return { id: v.id }
         })
       }
@@ -59,6 +63,12 @@ export const createProductCategoriesWorkflow = createWorkflow(
       data: productCategoryIdEvents,
     })
 
-    return new WorkflowResponse(createdProducts)
+    const categoriesCreated = createHook("categoriesCreated", {
+      categories: createdCategories,
+    })
+
+    return new WorkflowResponse(createdCategories, {
+      hooks: [categoriesCreated],
+    })
   }
 )

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]
+    })
   }
 )

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"
@@ -43,7 +44,7 @@ export const updateProductCategoriesWorkflow = createWorkflow(
   updateProductCategoriesWorkflowId,
   (
     input: WorkflowData<ProductCategoryWorkflow.UpdateProductCategoriesWorkflowInput>
-  ): WorkflowResponse<UpdateProductCategoriesWorkflowOutput> => {
+  )  => {
     const updatedCategories = updateProductCategoriesStep(input)
 
     const productCategoryIdEvents = transform(
@@ -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]
+    })
   }
 )