From 73b411097e8e95b84b8454dc926b1bc35d586aa3 Mon Sep 17 00:00:00 2001
From: Sebastian Rindom <skrindom@gmail.com>
Date: Wed, 7 Apr 2021 14:14:57 +0200
Subject: [PATCH] chore: scaffolding

---
 .../src/subscribers/order.js                  | 11 ++++++
 .../src/subscribers/swap.js                   | 39 +++++++++++++++++++
 2 files changed, 50 insertions(+)
 create mode 100644 packages/medusa-plugin-segment/src/subscribers/swap.js

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