src > workflows > sync-order-to-erp.ts

1234567891011121314151617181920
import { createWorkflow, WorkflowResponse } from "@medusajs/framework/workflows-sdk"
import { createOrderInERP, transformOrder } from "./steps"

export const syncOrderToERP = createWorkflow(
 "sync-order-to-erp",
  (input: WorkflowInput, { container }) => {

  const medusaOrder = retrieveOrder(input.order_id)

  const createdOrder = when({ medusaOrder }, ({ medusaOrder }) => {
    return medusaOrder.status === "completed"
  }).then(() => {  
    const preparedOrder = transformOrder(medusaOrder)
  
    return createOrderInERP(preparedOrder)
  })

  return new WorkflowResponse(createdOrder)
 }
)

src > workflows > accept-quote.ts

123456789101112131415161718
import { createStep, StepResponse } from "@medusajs/framework/workflows-sdk"

export const createOrderInERP = createStep(
 "create-order-in-erp"
 async (order: StepInput, { container }) => {
  const erpService = container.resolve("erp")
  
  const createdOrder = await erpService.createOrder(order)

  return new StepResponse(createdOrder, createdOrder)
 },
 // In the face of errors, we roll back and delete the order
 async (createdOrder, { container }) => {
   const erpService = container.resolve("erp")

   await erpService.deleteOrder(createdOrder)
 } 
)

src > subscribers > sync-order-to-erp.ts

123456789101112131415161718192021222324
import {
  type SubscriberConfig,
} from "@medusajs/framework"
import syncOrderToErp from "../workflows/sync-order-to-erp"

export default async function handleOrderPlaced({
  event: { data },
  container,
}) {

  const orderService = container.resolve("order")

  const order = await orderService.retrieve(id)
    
  await syncOrderToErp(container).run({
    input: {
      order
    },
  })
}

export const config: SubscriberConfig = {
  event: "order.placed",
}