chore(core-flows): send error on csv parsing error (#13749)
* chore(core-flows): send error on csv parsing error * Create two-dragons-visit.md
This commit is contained in:
5
.changeset/two-dragons-visit.md
Normal file
5
.changeset/two-dragons-visit.md
Normal file
@@ -0,0 +1,5 @@
|
|||||||
|
---
|
||||||
|
"@medusajs/core-flows": patch
|
||||||
|
---
|
||||||
|
|
||||||
|
chore(core-flows): send error on csv parsing error
|
||||||
@@ -1,11 +1,13 @@
|
|||||||
import { parse, Parser } from "csv-parse"
|
import { CsvError, parse, Parser } from "csv-parse"
|
||||||
import type { HttpTypes, IFileModuleService } from "@medusajs/framework/types"
|
import type { HttpTypes, IFileModuleService } from "@medusajs/framework/types"
|
||||||
import {
|
import {
|
||||||
CSVNormalizer,
|
CSVNormalizer,
|
||||||
|
MedusaError,
|
||||||
Modules,
|
Modules,
|
||||||
productValidators,
|
productValidators,
|
||||||
} from "@medusajs/framework/utils"
|
} from "@medusajs/framework/utils"
|
||||||
import { createStep, StepResponse } from "@medusajs/framework/workflows-sdk"
|
import { createStep, StepResponse } from "@medusajs/framework/workflows-sdk"
|
||||||
|
import { MedusaErrorTypes } from "@medusajs/utils"
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* The CSV file content to parse.
|
* The CSV file content to parse.
|
||||||
@@ -238,6 +240,11 @@ export const normalizeCsvToChunksStep = createStep(
|
|||||||
})
|
})
|
||||||
)
|
)
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
|
if (error instanceof CsvError) {
|
||||||
|
return reject(
|
||||||
|
new MedusaError(MedusaErrorTypes.INVALID_DATA, error.message)
|
||||||
|
)
|
||||||
|
}
|
||||||
reject(error)
|
reject(error)
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|||||||
Reference in New Issue
Block a user