chore(core-flows): Emit cart updated event on deleteLineItemsWorkflow (#14466)

* Emit cart updated event upon item deletion

* Add changeset
This commit is contained in:
Nicolas Gorga
2026-01-14 14:38:37 -03:00
committed by GitHub
parent 73631604cc
commit cbc9f3d059
2 changed files with 24 additions and 4 deletions

View File

@@ -0,0 +1,5 @@
---
"@medusajs/core-flows": patch
---
chore(core-flows): Emit cart updated event on `deleteLineItemsWorkflow`

View File

@@ -1,8 +1,14 @@
import { createWorkflow, WorkflowData } from "@medusajs/framework/workflows-sdk" import {
createWorkflow,
parallelize,
WorkflowData,
} from "@medusajs/framework/workflows-sdk"
import { AdditionalData } from "@medusajs/types" import { AdditionalData } from "@medusajs/types"
import { refreshCartItemsWorkflow } from "../../cart/workflows/refresh-cart-items" import { refreshCartItemsWorkflow } from "../../cart/workflows/refresh-cart-items"
import { acquireLockStep, releaseLockStep } from "../../locking" import { acquireLockStep, releaseLockStep } from "../../locking"
import { deleteLineItemsStep } from "../steps/delete-line-items" import { deleteLineItemsStep } from "../steps/delete-line-items"
import { emitEventStep } from "../../common/steps/emit-event"
import { CartWorkflowEvents } from "@medusajs/framework/utils"
/** /**
* The data to delete line items from a cart. * The data to delete line items from a cart.
@@ -53,9 +59,18 @@ export const deleteLineItemsWorkflow = createWorkflow(
deleteLineItemsStep(input.ids) deleteLineItemsStep(input.ids)
refreshCartItemsWorkflow.runAsStep({ parallelize(
input: { cart_id: input.cart_id, additional_data: input.additional_data }, refreshCartItemsWorkflow.runAsStep({
}) input: {
cart_id: input.cart_id,
additional_data: input.additional_data,
},
}),
emitEventStep({
eventName: CartWorkflowEvents.UPDATED,
data: { id: input.cart_id },
})
)
releaseLockStep({ releaseLockStep({
key: input.cart_id, key: input.cart_id,