Adds slack order notification

packages/medusa-plugin-slack-notification/src/api/index.js

@@ -0,0 +1,10 @@
+import { Router } from "express"
+import hooks from "./routes/hooks"
+
+export default (container) => {
+  const app = Router()
+
+  hooks(app)
+
+  return app
+}

packages/medusa-plugin-slack-notification/src/api/middlewares/await-middleware.js

@@ -0,0 +1 @@
+export default (fn) => (...args) => fn(...args).catch(args[2])

packages/medusa-plugin-slack-notification/src/api/middlewares/index.js

@@ -0,0 +1,5 @@
+import { default as wrap } from "./await-middleware"
+
+export default {
+  wrap,
+}

packages/medusa-plugin-slack-notification/src/api/routes/hooks/index.js

@@ -0,0 +1,13 @@
+import { Router } from "express"
+import bodyParser from "body-parser"
+import middlewares from "../../middlewares"
+
+const route = Router()
+
+export default (app) => {
+  app.use("/hooks", route)
+
+  route.post("/slack", middlewares.wrap(require("./slack").default))
+
+  return app
+}

packages/medusa-plugin-slack-notification/src/api/routes/hooks/slack.js

@@ -0,0 +1,12 @@
+export default async (req, res) => {
+  try {
+    const slackService = req.scope.resolve("slackService")
+
+    await slackService.orderNotification("5eff28187fde3440fd15ab49")
+
+    res.sendStatus(200)
+  } catch (error) {
+    console.log(error)
+    res.status(400).send(`Webhook error: ${error.message}`)
+  }
+}

packages/medusa-plugin-slack-notification/src/services/slack.js

@@ -0,0 +1,97 @@
+import axios from "axios"
+import moment from "moment"
+import { BaseService } from "medusa-interfaces"
+
+class SlackService extends BaseService {
+  /**
+   * @param {Object} options - options defined in `medusa-config.js`
+   *    {
+   *      slack_url: "https://hooks.slack.com/services/..."
+   *    }
+   */
+  constructor({ orderService, totalsService, regionService }, options) {
+    super()
+
+    this.orderService_ = orderService
+
+    this.totalsService_ = totalsService
+
+    this.regionService_ = regionService
+
+    this.options_ = options
+  }
+
+  async orderNotification(orderId) {
+    const order = await this.orderService_.retrieve(orderId)
+
+    const subtotal = await this.totalsService_.getSubtotal(order)
+    const shippingTotal = await this.totalsService_.getShippingTotal(order)
+    const taxTotal = await this.totalsService_.getTaxTotal(order)
+    const discountTotal = await this.totalsService_.getDiscountTotal(order)
+    const total = await this.totalsService_.getTotal(order)
+
+    let blocks = [
+      {
+        type: "section",
+        text: {
+          type: "mrkdwn",
+          text: `Order *<http://localhost:8000/a/orders/${order._id}|#${order._id}>* has been processed.`,
+        },
+      },
+      {
+        type: "section",
+        text: {
+          type: "mrkdwn",
+          text: `*Customer*\n${order.shipping_address.first_name} ${
+            order.shipping_address.last_name
+          }\n${order.email}\n*Destination*\n${
+            order.shipping_address.address_1
+          }\n${
+            order.shipping_address.city
+          }, ${order.shipping_address.country_code.toUpperCase()}`,
+        },
+      },
+      {
+        type: "section",
+        text: {
+          type: "mrkdwn",
+          text: `*Subtotal*\t${subtotal}\n*Shipping*\t${shippingTotal}\n*Discount Total*\t${discountTotal}\n*Tax*\t${taxTotal}\n*Total*\t${total}`,
+        },
+      },
+    ]
+
+    blocks.push({
+      type: "divider",
+    })
+
+    order.items.forEach((lineItem) => {
+      let line = {
+        type: "section",
+        text: {
+          type: "mrkdwn",
+          text: `*${lineItem.title}*\n${lineItem.quantity} x ${
+            !Array.isArray(lineItem.content) && lineItem.content.unit_price
+          }`,
+        },
+      }
+      if (lineItem.thumbnail) {
+        line.accessory.type = "image"
+        line.accessory.image_url = lineItem.thumbnail
+        line.accessory.alt_text = "Item"
+      }
+
+      blocks.push(line)
+
+      blocks.push({
+        type: "divider",
+      })
+    })
+
+    return axios.post(this.options_.slack_url, {
+      text: `Order ${order._id} was processed`,
+      blocks,
+    })
+  }
+}
+
+export default SlackService

packages/medusa-plugin-slack-notification/src/subscribers/order.js

@@ -0,0 +1,17 @@
+class OrderSubscriber {
+  constructor({ economicService, eventBusService }) {
+    this.economicService_ = economicService
+
+    this.eventBus_ = eventBusService
+
+    this.eventBus_.subscribe("order.placed", async (order) => {
+      await this.economicService_.draftEconomicInvoice(order)
+    })
+
+    this.eventBus_.subscribe("order.completed", async (order) => {
+      await this.economicService_.bookEconomicInvoice(order._id)
+    })
+  }
+}
+
+export default OrderSubscriber

packages/medusa-plugin-slack-notification/src/utils/eu-countries.js

@@ -0,0 +1,30 @@
+export default [
+  "BE",
+  "BG",
+  "CZ",
+  "DK",
+  "DE",
+  "EE",
+  "IE",
+  "EL",
+  "ES",
+  "FR",
+  "HR",
+  "IT",
+  "CY",
+  "LV",
+  "LT",
+  "LU",
+  "HU",
+  "MT",
+  "NL",
+  "AT",
+  "PL",
+  "PT",
+  "RO",
+  "SI",
+  "SK",
+  "FI",
+  "SE",
+  "UK",
+]