feat(cart): POST /store/carts (#6273)

Depends on #6262

packages/core-flows/src/definition/cart/index.ts

@@ -1 +1,4 @@
 export * from "./create-cart"
+export * from "./steps"
+export * from "./workflows"
+

packages/core-flows/src/definition/cart/steps/create-carts.ts

@@ -0,0 +1,31 @@
+import { ModuleRegistrationName } from "@medusajs/modules-sdk"
+import { CreateCartDTO, ICartModuleService } from "@medusajs/types"
+import { StepResponse, createStep } from "@medusajs/workflows-sdk"
+
+export const createCartsStepId = "create-carts"
+export const createCartsStep = createStep(
+  createCartsStepId,
+  async (data: CreateCartDTO[], { container }) => {
+    const service = container.resolve<ICartModuleService>(
+      ModuleRegistrationName.CART
+    )
+
+    const createdCarts = await service.create(data)
+
+    return new StepResponse(
+      createdCarts,
+      createdCarts.map((cart) => cart.id)
+    )
+  },
+  async (createdCartsIds, { container }) => {
+    if (!createdCartsIds?.length) {
+      return
+    }
+
+    const service = container.resolve<ICartModuleService>(
+      ModuleRegistrationName.CART
+    )
+
+    await service.delete(createdCartsIds)
+  }
+)

packages/core-flows/src/definition/cart/steps/index.ts

@@ -0,0 +1,2 @@
+export * from "./create-carts";
+

packages/core-flows/src/definition/cart/workflows/create-carts.ts

@@ -0,0 +1,13 @@
+import { CartDTO, CreateCartDTO } from "@medusajs/types"
+import { WorkflowData, createWorkflow } from "@medusajs/workflows-sdk"
+import { createCartsStep } from "../steps"
+
+type WorkflowInput = { cartData: CreateCartDTO[] }
+
+export const createCartsWorkflowId = "create-carts"
+export const createCartsWorkflow = createWorkflow(
+  createCartsWorkflowId,
+  (input: WorkflowData<WorkflowInput>): WorkflowData<CartDTO[]> => {
+    return createCartsStep(input.cartData)
+  }
+)

packages/core-flows/src/definition/cart/workflows/index.ts

@@ -0,0 +1,2 @@
+export * from "./create-carts";
+