feat: create CSV normalizer to normalize a CSV file (#12396)

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

@@ -25,4 +25,5 @@ export * from "./generate-product-csv"
 export * from "./parse-product-csv"
 export * from "./group-products-for-batch"
 export * from "./wait-confirmation-product-import"
-export * from "./get-variant-availability"
+export * from "./get-variant-availability"
+export * from "./normalize-products-v1"

packages/core/core-flows/src/product/steps/normalize-products-v1.ts

@@ -0,0 +1,48 @@
+import { CSVNormalizer } from "@medusajs/framework/utils"
+import { StepResponse, createStep } from "@medusajs/framework/workflows-sdk"
+import { convertCsvToJson } from "../utlils"
+import { GroupProductsForBatchStepOutput } from "./group-products-for-batch"
+
+/**
+ * The CSV file content to parse.
+ */
+export type NormalizeProductCsvStepInput = string
+
+export const normalizeCsvStepId = "normalize-product-csv"
+/**
+ * This step parses a CSV file holding products to import, returning the products as
+ * objects that can be imported.
+ *
+ * @example
+ * const data = parseProductCsvStep("products.csv")
+ */
+export const normalizeCsvStep = createStep(
+  normalizeCsvStepId,
+  async (fileContent: NormalizeProductCsvStepInput, { container }) => {
+    const csvProducts =
+      convertCsvToJson<ConstructorParameters<typeof CSVNormalizer>[0][0]>(
+        fileContent
+      )
+    const normalizer = new CSVNormalizer(csvProducts)
+    const products = normalizer.proccess()
+
+    const create = Object.keys(products.toCreate).reduce<
+      (typeof products)["toCreate"][keyof (typeof products)["toCreate"]][]
+    >((result, toCreateHandle) => {
+      result.push(products.toCreate[toCreateHandle])
+      return result
+    }, [])
+
+    const update = Object.keys(products.toUpdate).reduce<
+      (typeof products)["toUpdate"][keyof (typeof products)["toUpdate"]][]
+    >((result, toCreateId) => {
+      result.push(products.toUpdate[toCreateId])
+      return result
+    }, [])
+
+    return new StepResponse({
+      create,
+      update,
+    } as GroupProductsForBatchStepOutput)
+  }
+)