/** Parse a CSV string into { headers, rows } */ export function parseCSV(text) { const lines = text.replace(/\r\n/g, '\n').replace(/\r/g, '\n').split('\n').filter(l => l.trim()); if (!lines.length) return { headers: [], rows: [] }; function splitLine(l) { const r = []; let c = '', q = false; for (let i = 0; i < l.length; i++) { const ch = l[i]; if (ch === '"') { q = !q; } else if (ch === ',' && !q) { r.push(c.trim()); c = ''; } else { c += ch; } } r.push(c.trim()); return r; } const headers = splitLine(lines[0]).map(h => h.replace(/^"|"$/g, '').trim()); const rows = lines.slice(1).map((ln, i) => { const vals = splitLine(ln); const o = { __id: i + 1 }; headers.forEach((h, j) => { o[h] = (vals[j] || '').replace(/^"|"$/g, '').trim(); }); return o; }); return { headers, rows }; } /** Parse with progress callback — calls cb(pct 0-100) periodically, then cb(100, result) */ export function parseCSVWithProgress(text, onProgress) { return new Promise(resolve => { const lines = text.replace(/\r\n/g, '\n').replace(/\r/g, '\n').split('\n').filter(l => l.trim()); const total = lines.length - 1; function splitLine(l) { const r = []; let c = '', q = false; for (let i = 0; i < l.length; i++) { const ch = l[i]; if (ch === '"') { q = !q; } else if (ch === ',' && !q) { r.push(c.trim()); c = ''; } else { c += ch; } } r.push(c.trim()); return r; } if (total <= 500) { const result = parseCSV(text); onProgress && onProgress(100, result); resolve(result); return; } const headers = splitLine(lines[0]).map(h => h.replace(/^"|"$/g, '').trim()); const rows = []; const CHUNK = 250; let i = 1; function step() { const end = Math.min(i + CHUNK, lines.length); for (; i < end; i++) { const vals = splitLine(lines[i]); const o = { __id: rows.length + 1 }; headers.forEach((h, j) => { o[h] = (vals[j] || '').replace(/^"|"$/g, '').trim(); }); rows.push(o); } const pct = Math.round((i - 1) / total * 100); onProgress && onProgress(pct, null); if (i < lines.length) { requestAnimationFrame(step); } else { const result = { headers, rows }; onProgress && onProgress(100, result); resolve(result); } } requestAnimationFrame(step); }); } export function fmtSize(bytes) { if (bytes < 1024) return bytes + ' B'; if (bytes < 1048576) return (bytes / 1024).toFixed(1) + ' KB'; return (bytes / 1048576).toFixed(2) + ' MB'; } export function pKey(row) { return String(row.__id !== undefined ? row.__id : row.key); }