infrastructure/plunk
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: Import no longer case-sensitive about email column

Browse Source
This commit is contained in:
Dries Augustyns
2025-12-21 16:43:00 +01:00
parent e1f826357d
commit 451dd0327f
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/api/src/jobs/import-processor.ts
+5 -5
View File
@@ -52,9 +52,9 @@ export function createImportWorker() {
// Decode base64 CSV data // Decode base64 CSV data
const csvContent = Buffer.from(csvData, 'base64').toString('utf-8'); const csvContent = Buffer.from(csvData, 'base64').toString('utf-8');
// Parse CSV // Parse CSV with column header normalization
const records = parse(csvContent, { const records = parse(csvContent, {
columns: true, // Use first row as header columns: (header: string[]) => header.map(h => h.toLowerCase()), // Normalize headers to lowercase
skip_empty_lines: true, skip_empty_lines: true,
trim: true, trim: true,
relax_column_count: true, // Allow rows with different column counts relax_column_count: true, // Allow rows with different column counts
@@ -72,10 +72,10 @@ export function createImportWorker() {
// Notify that import has started // Notify that import has started
await NtfyService.notifyContactImportStarted(projectName, projectId, filename, result.totalRows); await NtfyService.notifyContactImportStarted(projectName, projectId, filename, result.totalRows);
// Validate that 'email' column exists // Validate that 'email' column exists (case-insensitive)
const firstRecord = records[0]; const firstRecord = records[0];
if (firstRecord && typeof firstRecord === 'object' && !('email' in firstRecord)) { if (firstRecord && typeof firstRecord === 'object' && !('email' in firstRecord)) {
throw new Error('CSV must have an "email" column'); throw new Error('CSV must have an "email" column (case-insensitive)');
} }
// Process contacts in batches // Process contacts in batches
@@ -110,7 +110,7 @@ export function createImportWorker() {
continue; continue;
} }
// Extract subscribed field if present // Extract subscribed field if present (case-insensitive)
const subscribedValue = record.subscribed; const subscribedValue = record.subscribed;
let subscribed: boolean | undefined; let subscribed: boolean | undefined;