diff --git a/packages/medusa-plugin-segment/src/subscribers/order.js b/packages/medusa-plugin-segment/src/subscribers/order.js index 12e0ea3bca..786dffd92b 100644 --- a/packages/medusa-plugin-segment/src/subscribers/order.js +++ b/packages/medusa-plugin-segment/src/subscribers/order.js @@ -18,6 +18,17 @@ class OrderSubscriber { this.fulfillmentService_ = fulfillmentService + + // Swaps + // order.swap_received <--- Will be deprecated + // swap.created + // swap.received + // swap.shipment_created + // swap.payment_completed + // swap.payment_captured + // swap.refund_processed + + eventBusService.subscribe( "order.shipment_created", async ({ id, fulfillment_id }) => { diff --git a/packages/medusa-plugin-segment/src/subscribers/swap.js b/packages/medusa-plugin-segment/src/subscribers/swap.js new file mode 100644 index 0000000000..d246ff4138 --- /dev/null +++ b/packages/medusa-plugin-segment/src/subscribers/swap.js @@ -0,0 +1,39 @@ +class OrderSubscriber { + constructor({ + segmentService, + eventBusService, + swapService, + orderService, + cartService, + claimService, + returnService, + fulfillmentService, + }) { + this.orderService_ = orderService + + this.cartService_ = cartService + + this.returnService_ = returnService + + this.claimService_ = claimService + + this.fulfillmentService_ = fulfillmentService + + + // Swaps + // order.swap_received <--- Will be deprecated + // swap.created + // swap.received + // swap.shipment_created + // swap.payment_completed + // swap.payment_captured + // swap.refund_processed + + eventBusService.subscribe("order.swap_received", async ({ id, swap_id }) => { + const swap = await swapService + }) + + } +} + +export default OrderSubscriber