Sothis/viabiliza
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

FEAT: Adicionado resposta da API quando erro a coluna Erro

Browse Source
This commit is contained in:
Rafael Alves Lopes 2026-05-12 16:45:52 -03:00
parent 5b98394ee2
commit cb78257f3f
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
service/csvService.js
View File

@ -215,6 +215,18 @@ function cleanCsvValue(value) {
return text.includes('"') ? text.replace(/"/g, "'") : text; return text.includes('"') ? text.replace(/"/g, "'") : text;
} }
function formatApiErrorResponse(error) {
const responseData = error && error.response && error.response.data;
if (responseData !== undefined && responseData !== null) {
if (typeof responseData === 'string') return responseData;
if (responseData.error) return responseData.error;
if (responseData.message) return responseData.message;
return JSON.stringify(responseData);
}
return error && (error.message || String(error));
}
async function countValidLines(inputPath) { async function countValidLines(inputPath) {
await discoverDataType(inputPath); await discoverDataType(inputPath);
const rows = readRows(inputPath); const rows = readRows(inputPath);
@ -261,7 +273,7 @@ async function processCsvFile(jobId, inputPath, originalName) {
outStream.write(outCols.join(';') + '\n'); outStream.write(outCols.join(';') + '\n');
incrementProcessed(jobId); incrementProcessed(jobId);
} catch (err) { } catch (err) {
const errMsg = cleanCsvValue(err && (err.message || String(err))); const errMsg = cleanCsvValue(formatApiErrorResponse(err));
const outCols = ['', '', '', errMsg, ...cols].map(cleanCsvValue); const outCols = ['', '', '', errMsg, ...cols].map(cleanCsvValue);
outStream.write(outCols.join(';') + '\n'); outStream.write(outCols.join(';') + '\n');
incrementErrors(jobId); incrementErrors(jobId);