chore(cart): completed at (#8921)

packages/core/core-flows/src/cart/steps/validate-cart.ts

@@ -0,0 +1,32 @@
+import { CartDTO, CartWorkflowDTO } from "@medusajs/types"
+import { MedusaError, isPresent } from "@medusajs/utils"
+import { createStep } from "@medusajs/workflows-sdk"
+
+export interface ValidateCartStepInput {
+  cart: CartWorkflowDTO | CartDTO
+}
+
+export const validateCartStepId = "validate-cart"
+/**
+ * This step validates a cart's before editing it.
+ */
+export const validateCartStep = createStep(
+  validateCartStepId,
+  async (data: ValidateCartStepInput) => {
+    const { cart } = data
+
+    if (!isPresent(cart)) {
+      throw new MedusaError(
+        MedusaError.Types.INVALID_DATA,
+        `Cart does not exist`
+      )
+    }
+
+    if (cart.completed_at) {
+      throw new MedusaError(
+        MedusaError.Types.INVALID_DATA,
+        `Cart ${cart.id} is already completed.`
+      )
+    }
+  }
+)

packages/core/core-flows/src/cart/utils/fields.ts

@@ -1,9 +1,11 @@
 export const cartFieldsForRefreshSteps = [
+  "id",
   "subtotal",
   "item_subtotal",
   "shipping_subtotal",
   "region_id",
   "currency_code",
+  "completed_at",
   "region.*",
   "items.*",
   "items.product.id",
@@ -26,6 +28,7 @@ export const completeCartFields = [
   "email",
   "created_at",
   "updated_at",
+  "completed_at",
   "total",
   "subtotal",
   "tax_total",

packages/core/core-flows/src/cart/workflows/add-shipping-method-to-cart.ts

@@ -9,6 +9,7 @@ import {
   removeShippingMethodFromCartStep,
   validateCartShippingOptionsStep,
 } from "../steps"
+import { validateCartStep } from "../steps/validate-cart"
 import { cartFieldsForRefreshSteps } from "../utils/fields"
 import { updateCartPromotionsWorkflow } from "./update-cart-promotions"
 import { updateTaxLinesWorkflow } from "./update-tax-lines"
@@ -37,6 +38,8 @@ export const addShippingMethodToWorkflow = createWorkflow(
       list: false,
     })
 
+    validateCartStep({ cart })
+
     const optionIds = transform({ input }, (data) => {
       return (data.input.options ?? []).map((i) => i.id)
     })

packages/core/core-flows/src/cart/workflows/add-to-cart.ts

@@ -16,6 +16,7 @@ import {
   refreshCartShippingMethodsStep,
   updateLineItemsStep,
 } from "../steps"
+import { validateCartStep } from "../steps/validate-cart"
 import { validateVariantPricesStep } from "../steps/validate-variant-prices"
 import {
   cartFieldsForRefreshSteps,
@@ -34,6 +35,8 @@ export const addToCartWorkflowId = "add-to-cart"
 export const addToCartWorkflow = createWorkflow(
   addToCartWorkflowId,
   (input: WorkflowData<AddToCartWorkflowInputDTO>) => {
+    validateCartStep(input)
+
     const variantIds = transform({ input }, (data) => {
       return (data.input.items ?? []).map((i) => i.variant_id)
     })
@@ -67,9 +70,10 @@ export const addToCartWorkflow = createWorkflow(
 
         return prepareLineItemData({
           variant: variant,
-          unitPrice: item.unit_price || 
-            variant.calculated_price.calculated_amount,
-          isTaxInclusive: item.is_tax_inclusive || 
+          unitPrice:
+            item.unit_price || variant.calculated_price.calculated_amount,
+          isTaxInclusive:
+            item.is_tax_inclusive ||
             variant.calculated_price.is_calculated_price_tax_inclusive,
           quantity: item.quantity,
           metadata: item?.metadata ?? {},

packages/core/core-flows/src/cart/workflows/complete-cart.ts

@@ -14,8 +14,9 @@ import {
 } from "../../common"
 import { createOrdersStep } from "../../order/steps/create-orders"
 import { authorizePaymentSessionStep } from "../../payment/steps/authorize-payment-session"
-import { validateCartPaymentsStep } from "../steps"
+import { updateCartsStep, validateCartPaymentsStep } from "../steps"
 import { reserveInventoryStep } from "../steps/reserve-inventory"
+import { validateCartStep } from "../steps/validate-cart"
 import { completeCartFields } from "../utils/fields"
 import { prepareConfirmInventoryInput } from "../utils/prepare-confirm-inventory-input"
 import {
@@ -44,6 +45,8 @@ export const completeCartWorkflow = createWorkflow(
       list: false,
     })
 
+    validateCartStep({ cart })
+
     const paymentSessions = validateCartPaymentsStep({ cart })
 
     authorizePaymentSessionStep({
@@ -158,6 +161,13 @@ export const completeCartWorkflow = createWorkflow(
       ({ createdOrders }) => createdOrders[0]
     )
 
+    const updateCompletedAt = transform({ cart }, ({ cart }) => {
+      return {
+        id: cart.id,
+        completed_at: new Date(),
+      }
+    })
+
     parallelize(
       createRemoteLinkStep([
         {
@@ -171,6 +181,7 @@ export const completeCartWorkflow = createWorkflow(
           },
         },
       ]),
+      updateCartsStep([updateCompletedAt]),
       emitEventStep({
         eventName: OrderWorkflowEvents.PLACED,
         data: { id: order.id },

packages/core/core-flows/src/cart/workflows/create-payment-collection-for-cart.ts

@@ -12,6 +12,7 @@ import {
 import { createRemoteLinkStep } from "../../common/steps/create-remote-links"
 import { useRemoteQueryStep } from "../../common/steps/use-remote-query"
 import { createPaymentCollectionsStep } from "../steps/create-payment-collection"
+import { validateCartStep } from "../steps/validate-cart"
 
 /**
  * This step validates that a cart doesn't have a payment collection.
@@ -40,6 +41,7 @@ export const createPaymentCollectionForCartWorkflow = createWorkflow(
       fields: [
         "id",
         "region_id",
+        "completed_at",
         "currency_code",
         "total",
         "raw_total",
@@ -50,6 +52,8 @@ export const createPaymentCollectionForCartWorkflow = createWorkflow(
       list: false,
     })
 
+    validateCartStep({ cart })
+
     validateExistingPaymentCollectionStep({ cart })
 
     const paymentData = transform({ cart }, ({ cart }) => {

packages/core/core-flows/src/cart/workflows/update-line-item-in-cart.ts

@@ -8,6 +8,7 @@ import {
 import { useRemoteQueryStep } from "../../common/steps/use-remote-query"
 import { updateLineItemsStepWithSelector } from "../../line-item/steps"
 import { refreshCartShippingMethodsStep } from "../steps"
+import { validateCartStep } from "../steps/validate-cart"
 import { validateVariantPricesStep } from "../steps/validate-variant-prices"
 import {
   cartFieldsForRefreshSteps,
@@ -27,6 +28,8 @@ export const updateLineItemInCartWorkflowId = "update-line-item-in-cart"
 export const updateLineItemInCartWorkflow = createWorkflow(
   updateLineItemInCartWorkflowId,
   (input: WorkflowData<UpdateLineItemInCartWorkflowInputDTO>) => {
+    validateCartStep(input)
+
     const variantIds = transform({ input }, (data) => {
       return [data.input.item.variant_id]
     })