Chore/order claims 2

integration-tests/http/__tests__/returns/returns.spec.ts

@@ -140,6 +140,12 @@ medusaIntegrationTestRunner({
         },
         currency_code: "usd",
         customer_id: "joe",
+        transactions: [
+          {
+            amount: 20,
+            currency_code: "usd",
+          },
+        ],
       })
 
       shippingProfile = (
@@ -328,13 +334,15 @@ medusaIntegrationTestRunner({
           },
           adminHeaders
         )
+
         await api.post(
           `/admin/returns/${returnId2}/shipping-method`,
           {
             shipping_option_id: returnShippingOption.id,
           },
           adminHeaders
         )
+
         await api.post(`/admin/returns/${returnId2}/request`, {}, adminHeaders)
 
         const returnId = result.data.return.id

packages/core/core-flows/src/order/steps/create-claim-items.ts

@@ -0,0 +1,59 @@
+import { IOrderModuleService, OrderChangeActionDTO } from "@medusajs/types"
+import { ChangeActionType, ModuleRegistrationName } from "@medusajs/utils"
+import { StepResponse, createStep } from "@medusajs/workflows-sdk"
+
+type CreateOrderClaimItemsInput = {
+  changes: OrderChangeActionDTO[]
+  claimId: string
+}
+
+export const createOrderClaimItemsStep = createStep(
+  "create-claim-items",
+  async (input: CreateOrderClaimItemsInput, { container }) => {
+    const orderModuleService = container.resolve<IOrderModuleService>(
+      ModuleRegistrationName.ORDER
+    )
+
+    const claimItems = input.changes.map((item) => {
+      let additionalFields
+      if (item.action === ChangeActionType.ITEM_ADD) {
+        additionalFields = {
+          is_additional_item: true,
+        }
+      } else if (item.action === ChangeActionType.WRITE_OFF_ITEM) {
+        additionalFields = {
+          reason: item.details?.reason,
+        }
+      }
+
+      return {
+        claim_id: input.claimId,
+        item_id: item.details?.reference_id! as string,
+        quantity: item.details?.quantity as number,
+        note: item.internal_note,
+        metadata: (item.details?.metadata as Record<string, unknown>) ?? {},
+        ...additionalFields,
+      }
+    })
+
+    const createdClaimItems = await orderModuleService.createOrderClaimItems(
+      claimItems
+    )
+
+    return new StepResponse(
+      createdClaimItems,
+      createdClaimItems.map((i) => i.id)
+    )
+  },
+  async (ids, { container }) => {
+    if (!ids) {
+      return
+    }
+
+    const orderModuleService = container.resolve<IOrderModuleService>(
+      ModuleRegistrationName.ORDER
+    )
+
+    await orderModuleService.deleteOrderClaimItems(ids)
+  }
+)

packages/core/core-flows/src/order/steps/create-return-items.ts

@@ -28,6 +28,7 @@ export const createReturnItemsStep = createStep(
         metadata: (item.details?.metadata as Record<string, unknown>) ?? {},
       } as CreateOrderReturnItemDTO
     })
+
     const createdReturnItems = await orderModuleService.createReturnItems(
       returnItems
     )

packages/core/core-flows/src/order/steps/index.ts

@@ -5,6 +5,7 @@ export * from "./cancel-order-change"
 export * from "./cancel-orders"
 export * from "./cancel-return"
 export * from "./complete-orders"
+export * from "./create-claim-items"
 export * from "./create-claims"
 export * from "./create-complete-return"
 export * from "./create-exchanges"

packages/core/core-flows/src/order/workflows/claim/cancel-begin-order-claim.ts

@@ -45,7 +45,7 @@ export const cancelBeginOrderClaimWorkflow = createWorkflow(
   cancelBeginOrderClaimWorkflowId,
   function (input: WorkflowInput): WorkflowData<void> {
     const orderClaim: OrderClaimDTO = useRemoteQueryStep({
-      entry_point: "claim",
+      entry_point: "order_claim",
       fields: ["id", "status", "order_id", "return_id", "canceled_at"],
       variables: { id: input.claim_id },
       list: false,

packages/core/core-flows/src/order/workflows/claim/claim-add-new-item.ts

@@ -100,7 +100,7 @@ export const orderClaimAddNewItemWorkflow = createWorkflow(
           details: {
             reference_id: lineItems[index].id,
             quantity: item.quantity,
-            unit_price: item.unit_price,
+            unit_price: item.unit_price ?? lineItems[index].unit_price,
             metadata: item.metadata,
           },
         }))

packages/core/core-flows/src/order/workflows/claim/claim-item.ts

@@ -91,6 +91,7 @@ export const orderClaimItemWorkflow = createWorkflow(
           reference_id: orderClaim.id,
           details: {
             reference_id: item.id,
+            reason: item.reason,
             quantity: item.quantity,
           },
         }))

packages/core/core-flows/src/order/workflows/claim/claim-request-item-return.ts

@@ -156,6 +156,7 @@ export const orderClaimRequestItemReturnWorkflow = createWorkflow(
           details: {
             reference_id: item.id,
             quantity: item.quantity,
+            reason_id: item.reason_id,
             metadata: item.metadata,
           },
         }))