asyavee/medusa-store
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

feat(core-flows): Emit cart trasnferred customer (#12425)

Browse Source 
**What**
When a cart is transferred emit an event notifying of the action with the cart id and the customer id
This commit is contained in:
Adrien de Peretti
2025-05-11 17:17:19 +02:00
committed by GitHub
parent 47700899ed
commit fff285f8d2
3 changed files with 92 additions and 64 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
.changeset/serious-plums-hope.md Normal file
View File

@@ -0,0 +1,6 @@
---
"@medusajs/core-flows": patch
"@medusajs/utils": patch
---
feat(core-flows): Emit cart trasnferred customer

11
packages/core/core-flows/src/cart/workflows/transfer-cart-customer.ts
View File

@@ -6,9 +6,10 @@ import {
WorkflowData,
WorkflowResponse,
} from "@medusajs/framework/workflows-sdk"
import { useQueryGraphStep } from "../../common"
import { emitEventStep, useQueryGraphStep } from "../../common"
import { updateCartsStep } from "../steps"
import { refreshCartItemsWorkflow } from "./refresh-cart-items"
import { CartWorkflowEvents } from "@medusajs/framework/utils"
/**
* The cart ownership transfer details.
@@ -110,6 +111,14 @@ export const transferCartCustomerWorkflow = createWorkflow(
refreshCartItemsWorkflow.runAsStep({
input: { cart_id: input.id, force_refresh: true },
})
emitEventStep({
eventName: CartWorkflowEvents.CUSTOMER_TRANSFERRED,
data: {
id: input.id,
customer_id: customer.customer_id,
},
})
}
)

139
packages/core/utils/src/core-flows/events.ts
View File

@@ -5,7 +5,7 @@
export const CartWorkflowEvents = {
/**
* Emitted when a cart is created.
*
*
* @eventPayload
* ```ts
* {
@@ -16,7 +16,7 @@ export const CartWorkflowEvents = {
CREATED: "cart.created",
/**
* Emitted when a cart's details are updated.
*
*
* @eventPayload
* ```ts
* {
@@ -27,7 +27,7 @@ export const CartWorkflowEvents = {
UPDATED: "cart.updated",
/**
* Emitted when the customer in the cart is updated.
*
*
* @eventPayload
* ```ts
* {
@@ -39,7 +39,7 @@ export const CartWorkflowEvents = {
/**
* Emitted when the cart's region is updated. This
* event is emitted alongside the `cart.updated` event.
*
*
* @eventPayload
* ```ts
* {
@@ -48,6 +48,19 @@ export const CartWorkflowEvents = {
* ```
*/
REGION_UPDATED: "cart.region_updated",
/**
* Emitted when the customer in the cart is transferred.
*
* @eventPayload
* ```ts
* {
* id, // The ID of the cart
* customer_id, // The ID of the customer
* }
* ```
*/
CUSTOMER_TRANSFERRED: "cart.customer_transferred",
}
/**
@@ -57,7 +70,7 @@ export const CartWorkflowEvents = {
export const CustomerWorkflowEvents = {
/**
* Emitted when a customer is created.
*
*
* @eventPayload
* ```ts
* [{
@@ -68,7 +81,7 @@ export const CustomerWorkflowEvents = {
CREATED: "customer.created",
/**
* Emitted when a customer is updated.
*
*
* @eventPayload
* ```ts
* [{
@@ -79,7 +92,7 @@ export const CustomerWorkflowEvents = {
UPDATED: "customer.updated",
/**
* Emitted when a customer is deleted.
*
*
* @eventPayload
* ```ts
* [{
@@ -98,7 +111,7 @@ export const OrderWorkflowEvents = {
/**
* Emitted when the details of an order or draft order is updated. This
* doesn't include updates made by an edit.
*
*
* @eventPayload
* ```ts
* {
@@ -111,7 +124,7 @@ export const OrderWorkflowEvents = {
/**
* Emitted when an order is placed, or when a draft order is converted to an
* order.
*
*
* @eventPayload
* ```ts
* {
@@ -122,7 +135,7 @@ export const OrderWorkflowEvents = {
PLACED: "order.placed",
/**
* Emitted when an order is canceld.
*
*
* @eventPayload
* ```ts
* {
@@ -133,7 +146,7 @@ export const OrderWorkflowEvents = {
CANCELED: "order.canceled",
/**
* Emitted when orders are completed.
*
*
* @eventPayload
* ```ts
* [{
@@ -144,7 +157,7 @@ export const OrderWorkflowEvents = {
COMPLETED: "order.completed",
/**
* Emitted when an order is archived.
*
*
* @eventPayload
* ```ts
* [{
@@ -156,7 +169,7 @@ export const OrderWorkflowEvents = {
/**
* Emitted when a fulfillment is created for an order.
*
*
* @eventPayload
* ```ts
* {
@@ -169,7 +182,7 @@ export const OrderWorkflowEvents = {
FULFILLMENT_CREATED: "order.fulfillment_created",
/**
* Emitted when an order's fulfillment is canceled.
*
*
* @eventPayload
* ```ts
* {
@@ -183,7 +196,7 @@ export const OrderWorkflowEvents = {
/**
* Emitted when a return request is confirmed.
*
*
* @eventPayload
* ```ts
* {
@@ -195,7 +208,7 @@ export const OrderWorkflowEvents = {
RETURN_REQUESTED: "order.return_requested",
/**
* Emitted when a return is marked as received.
*
*
* @eventPayload
* ```ts
* {
@@ -208,7 +221,7 @@ export const OrderWorkflowEvents = {
/**
* Emitted when a claim is created for an order.
*
*
* @eventPayload
* ```ts
* {
@@ -220,7 +233,7 @@ export const OrderWorkflowEvents = {
CLAIM_CREATED: "order.claim_created",
/**
* Emitted when an exchange is created for an order.
*
*
* @eventPayload
* ```ts
* {
@@ -234,7 +247,7 @@ export const OrderWorkflowEvents = {
/**
* Emitted when an order is requested to be transferred to
* another customer.
*
*
* @eventPayload
* ```ts
* {
@@ -253,9 +266,9 @@ export const OrderWorkflowEvents = {
export const OrderEditWorkflowEvents = {
/**
* Emitted when an order edit is requested.
*
*
* @version 2.8.0
*
*
* @eventPayload
* ```ts
* {
@@ -267,9 +280,9 @@ export const OrderEditWorkflowEvents = {
REQUESTED: "order-edit.requested",
/**
* Emitted when an order edit request is confirmed.
*
*
* @version 2.8.0
*
*
* @eventPayload
* ```ts
* {
@@ -281,9 +294,9 @@ export const OrderEditWorkflowEvents = {
CONFIRMED: "order-edit.confirmed",
/**
* Emitted when an order edit request is canceled.
*
*
* @version 2.8.0
*
*
* @eventPayload
* ```ts
* {
@@ -302,7 +315,7 @@ export const OrderEditWorkflowEvents = {
export const UserWorkflowEvents = {
/**
* Emitted when users are created.
*
*
* @eventPayload
* ```ts
* [{
@@ -313,7 +326,7 @@ export const UserWorkflowEvents = {
CREATED: "user.created",
/**
* Emitted when users are updated.
*
*
* @eventPayload
* ```ts
* [{
@@ -324,7 +337,7 @@ export const UserWorkflowEvents = {
UPDATED: "user.updated",
/**
* Emitted when users are deleted.
*
*
* @eventPayload
* ```ts
* [{
@@ -343,7 +356,7 @@ export const AuthWorkflowEvents = {
/**
* Emitted when a reset password token is generated. You can listen to this event
* to send a reset password email to the user or customer, for example.
*
*
* @eventPayload
* ```ts
* {
@@ -363,7 +376,7 @@ export const AuthWorkflowEvents = {
export const SalesChannelWorkflowEvents = {
/**
* Emitted when sales channels are created.
*
*
* @eventPayload
* ```ts
* [{
@@ -374,7 +387,7 @@ export const SalesChannelWorkflowEvents = {
CREATED: "sales-channel.created",
/**
* Emitted when sales channels are updated.
*
*
* @eventPayload
* ```ts
* [{
@@ -385,7 +398,7 @@ export const SalesChannelWorkflowEvents = {
UPDATED: "sales-channel.updated",
/**
* Emitted when sales channels are deleted.
*
*
* @eventPayload
* ```ts
* [{
@@ -403,7 +416,7 @@ export const SalesChannelWorkflowEvents = {
export const ProductCategoryWorkflowEvents = {
/**
* Emitted when product categories are created.
*
*
* @eventPayload
* ```ts
* [{
@@ -414,7 +427,7 @@ export const ProductCategoryWorkflowEvents = {
CREATED: "product-category.created",
/**
* Emitted when product categories are updated.
*
*
* @eventPayload
* ```ts
* [{
@@ -425,7 +438,7 @@ export const ProductCategoryWorkflowEvents = {
UPDATED: "product-category.updated",
/**
* Emitted when product categories are deleted.
*
*
* @eventPayload
* ```ts
* [{
@@ -443,7 +456,7 @@ export const ProductCategoryWorkflowEvents = {
export const ProductCollectionWorkflowEvents = {
/**
* Emitted when product collections are created.
*
*
* @eventPayload
* ```ts
* [{
@@ -454,7 +467,7 @@ export const ProductCollectionWorkflowEvents = {
CREATED: "product-collection.created",
/**
* Emitted when product collections are updated.
*
*
* @eventPayload
* ```ts
* [{
@@ -465,7 +478,7 @@ export const ProductCollectionWorkflowEvents = {
UPDATED: "product-collection.updated",
/**
* Emitted when product collections are deleted.
*
*
* @eventPayload
* ```ts
* [{
@@ -483,7 +496,7 @@ export const ProductCollectionWorkflowEvents = {
export const ProductVariantWorkflowEvents = {
/**
* Emitted when product variants are updated.
*
*
* @eventPayload
* ```ts
* [{
@@ -494,7 +507,7 @@ export const ProductVariantWorkflowEvents = {
UPDATED: "product-variant.updated",
/**
* Emitted when product variants are created.
*
*
* @eventPayload
* ```ts
* [{
@@ -505,7 +518,7 @@ export const ProductVariantWorkflowEvents = {
CREATED: "product-variant.created",
/**
* Emitted when product variants are deleted.
*
*
* @eventPayload
* ```ts
* [{
@@ -523,7 +536,7 @@ export const ProductVariantWorkflowEvents = {
export const ProductWorkflowEvents = {
/**
* Emitted when products are updated.
*
*
* @eventPayload
* ```ts
* [{
@@ -534,7 +547,7 @@ export const ProductWorkflowEvents = {
UPDATED: "product.updated",
/**
* Emitted when products are created.
*
*
* @eventPayload
* ```ts
* [{
@@ -545,7 +558,7 @@ export const ProductWorkflowEvents = {
CREATED: "product.created",
/**
* Emitted when products are deleted.
*
*
* @eventPayload
* ```ts
* [{
@@ -563,7 +576,7 @@ export const ProductWorkflowEvents = {
export const ProductTypeWorkflowEvents = {
/**
* Emitted when product types are updated.
*
*
* @eventPayload
* ```ts
* [{
@@ -574,7 +587,7 @@ export const ProductTypeWorkflowEvents = {
UPDATED: "product-type.updated",
/**
* Emitted when product types are created.
*
*
* @eventPayload
* ```ts
* [{
@@ -585,7 +598,7 @@ export const ProductTypeWorkflowEvents = {
CREATED: "product-type.created",
/**
* Emitted when product types are deleted.
*
*
* @eventPayload
* ```ts
* [{
@@ -603,7 +616,7 @@ export const ProductTypeWorkflowEvents = {
export const ProductTagWorkflowEvents = {
/**
* Emitted when product tags are updated.
*
*
* @eventPayload
* ```ts
* [{
@@ -614,7 +627,7 @@ export const ProductTagWorkflowEvents = {
UPDATED: "product-tag.updated",
/**
* Emitted when product tags are created.
*
*
* @eventPayload
* ```ts
* [{
@@ -625,7 +638,7 @@ export const ProductTagWorkflowEvents = {
CREATED: "product-tag.created",
/**
* Emitted when product tags are deleted.
*
*
* @eventPayload
* ```ts
* [{
@@ -643,7 +656,7 @@ export const ProductTagWorkflowEvents = {
export const ProductOptionWorkflowEvents = {
/**
* Emitted when product options are updated.
*
*
* @eventPayload
* ```ts
* [{
@@ -654,7 +667,7 @@ export const ProductOptionWorkflowEvents = {
UPDATED: "product-option.updated",
/**
* Emitted when product options are created.
*
*
* @eventPayload
* ```ts
* [{
@@ -665,7 +678,7 @@ export const ProductOptionWorkflowEvents = {
CREATED: "product-option.created",
/**
* Emitted when product options are deleted.
*
*
* @eventPayload
* ```ts
* [{
@@ -683,7 +696,7 @@ export const ProductOptionWorkflowEvents = {
export const InviteWorkflowEvents = {
/**
* Emitted when an invite is accepted.
*
*
* @eventPayload
* ```ts
* {
@@ -695,7 +708,7 @@ export const InviteWorkflowEvents = {
/**
* Emitted when invites are created. You can listen to this event
* to send an email to the invited users, for example.
*
*
* @eventPayload
* ```ts
* [{
@@ -706,7 +719,7 @@ export const InviteWorkflowEvents = {
CREATED: "invite.created",
/**
* Emitted when invites are deleted.
*
*
* @eventPayload
* ```ts
* [{
@@ -719,7 +732,7 @@ export const InviteWorkflowEvents = {
* Emitted when invites should be resent because their token was
* refreshed. You can listen to this event to send an email to the invited users,
* for example.
*
*
* @eventPayload
* ```ts
* [{
@@ -737,7 +750,7 @@ export const InviteWorkflowEvents = {
export const RegionWorkflowEvents = {
/**
* Emitted when regions are updated.
*
*
* @eventPayload
* ```ts
* [{
@@ -748,7 +761,7 @@ export const RegionWorkflowEvents = {
UPDATED: "region.updated",
/**
* Emitted when regions are created.
*
*
* @eventPayload
* ```ts
* [{
@@ -759,7 +772,7 @@ export const RegionWorkflowEvents = {
CREATED: "region.created",
/**
* Emitted when regions are deleted.
*
*
* @eventPayload
* ```ts
* [{
@@ -777,7 +790,7 @@ export const RegionWorkflowEvents = {
export const FulfillmentWorkflowEvents = {
/**
* Emitted when a shipment is created for an order.
*
*
* @eventPayload
* ```ts
* {
@@ -789,7 +802,7 @@ export const FulfillmentWorkflowEvents = {
SHIPMENT_CREATED: "shipment.created",
/**
* Emitted when a fulfillment is marked as delivered.
*
*
* @eventPayload
* ```ts
* {
@@ -798,4 +811,4 @@ export const FulfillmentWorkflowEvents = {
* ```
*/
DELIVERY_CREATED: "delivery.created",
}
}