diff --git a/utils/extractor/src/index.ts b/utils/extractor/src/index.ts index b1fbc5681..923049b0a 100644 --- a/utils/extractor/src/index.ts +++ b/utils/extractor/src/index.ts @@ -105,7 +105,7 @@ export const Extractor = ( continue } await asyncBatch( - capture[sheet.name].data, + capture[sheet.name].data.map(normalizeRecordKeys), async (chunk) => { await api.records.insert(sheet.id, chunk, { compressRequestBody: true, @@ -204,6 +204,16 @@ function normalizeKey(key: string): string { return key.trim().replace(/%/g, '_PERCENT_').replace(/\$/g, '_DOLLAR_') } +function normalizeRecordKeys(record: Flatfile.RecordData): Flatfile.RecordData { + const normalizedRecord = {} as Flatfile.RecordData + for (const key in record) { + if (record.hasOwnProperty(key)) { + normalizedRecord[normalizeKey(key)] = record[key] + } + } + return normalizedRecord +} + export function keysToFields({ keys, descriptions = {},