// ============================================================================ // CWR ACK IMPORT · parse acknowledgement files + update registration status // ---------------------------------------------------------------------------- // Societies return ACK files referencing the original CWR transmission. This // module parses them, maps each ACK record back to a registration, and writes // the new status back into window.__REG_STATUS (a session-scoped map keyed on // `${societyAcronym}:${submitterWorkRef}`). The Acks tab and registrations // elsewhere can read from this. // // CWR ACK file structure (standard CISAC): // HDR ........ transmission header (sender = society, receiver = us) // GRH ........ group header, transaction type = ACK // ACK ........ acknowledgement transaction (one per original work) // MSG .... 0..N validation messages with severity + field reference // [the original NWR/REV/AGR follows the ACK in some implementations] // GRT ........ group trailer // GRH ........ next group (if multiple transaction types) // ... // TRL ........ transmission trailer // // Status mapping per CWR spec (Transaction Status field, ACK record): // AS → Accepted (final) // AC → Accepted with Changes (society modified our payload) // CO → Conflict (writers/publishers conflict with another submission) // DU → Duplicate (we already submitted this) // IF → Information (advisory, no action required) // IR → Incomplete Registration (missing required field) // IE → Invalid Element (malformed data) // NP → No Participation (writer not represented by this society) // RA → Registration Accepted // RJ → Rejected (final) // AR → Accepted (no further info) // // Engine: window.CwrAckImport.parse(text) → { header, groups, acks, summary, errors } // Apply: window.CwrAckImport.apply(parsed) → writes to __REG_STATUS, fires event // Tab: window.CwrAckImportTab — drop-zone UI, parse + apply flow // ============================================================================ (function () { 'use strict'; const { useState, useMemo, useCallback, useRef, useEffect } = React; // ─── ACK code dictionary (mirrors cwr-acks.jsx + spec) ────────────────── const ACK_CODES = { AS: { tone: 'ok', label: 'Accepted', terminal: true }, AC: { tone: 'ok', label: 'Accepted with changes', terminal: true }, AR: { tone: 'ok', label: 'Accepted', terminal: true }, RA: { tone: 'ok', label: 'Registration accepted', terminal: true }, IF: { tone: 'info', label: 'Information', terminal: false }, NP: { tone: 'warn', label: 'No participation', terminal: true }, DU: { tone: 'warn', label: 'Duplicate', terminal: true }, CO: { tone: 'danger', label: 'Conflict', terminal: false }, IR: { tone: 'danger', label: 'Incomplete', terminal: false }, IE: { tone: 'danger', label: 'Invalid element', terminal: false }, RJ: { tone: 'danger', label: 'Rejected', terminal: true }, }; const TONE_BG = { ok:'#e8f0e9', warn:'#f4ecd9', danger:'#f4e3df', info:'#e6eef5', neutral:'#eee' }; const TONE_FG = { ok:'#1e6b3f', warn:'#9b6a18', danger:'#a04432', info:'#2c5777', neutral:'var(--ink-2)' }; const TONE_DOT = { ok:'#2d6a3f', warn:'#9b6a18', danger:'#a04432', info:'#2c5777', neutral:'#999' }; // ─── Field offset helper (uses CwrDecode if loaded, with fallback) ────── function sliceAt(line, start, len) { return (line || '').slice(start, start + len).replace(/\s+$/, ''); } // ─── Parser ───────────────────────────────────────────────────────────── function parse(text) { const errors = []; const lines = String(text || '').split(/\r?\n/).filter((l) => l.length > 0); if (!lines.length) { return { ok:false, errors:['Empty file'], header:null, groups:[], acks:[], summary:emptySummary() }; } // First line should be HDR const hdrLine = lines[0]; if (hdrLine.slice(0, 3) !== 'HDR') { return { ok:false, errors:['First record is not HDR'], header:null, groups:[], acks:[], summary:emptySummary() }; } // Decode HDR — Sender Type (2), Sender ID (9), Sender Name (45), EDI std (5), // Creation Date (8), Creation Time (6), Transmission Date (8), Charset (2 v3+) const header = { raw: hdrLine, senderType: sliceAt(hdrLine, 3, 2), senderId: sliceAt(hdrLine, 5, 9), senderName: sliceAt(hdrLine, 14, 45), ediStd: sliceAt(hdrLine, 59, 5), created: sliceAt(hdrLine, 64, 8), createdTime:sliceAt(hdrLine, 72, 6), transmitted:sliceAt(hdrLine, 78, 8), }; // Try to identify the society from sender ID/name const matched = matchSociety(header); header.society = matched; // Walk records, building groups and ACK transactions const groups = []; const acks = []; let curGroup = null; let curAck = null; for (let i = 1; i < lines.length; i++) { const line = lines[i]; const rt = line.slice(0, 3); if (rt === 'GRH') { curGroup = { line: i + 1, transactionType: sliceAt(line, 3, 3), groupId: sliceAt(line, 6, 5), version: sliceAt(line, 11, 5), batchRequest: sliceAt(line, 16, 10), submissionFlag: sliceAt(line, 26, 2), ackCount: 0, }; groups.push(curGroup); curAck = null; } else if (rt === 'GRT') { if (curGroup) curGroup.recordCount = parseInt(sliceAt(line, 16, 8) || '0', 10); curAck = null; } else if (rt === 'TRL') { // transmission end curAck = null; } else if (rt === 'ACK') { // Per spec ACK fields after the standard 19-byte transaction header: // Creation date 8, Creation time 6, Original group ID 5, // Original transaction seq 8, Original transaction type 3, // Creation title 60, Submitter creation # 20, Recipient creation # 20, // Processing date 8, Transaction status 2 const status = sliceAt(line, 19 + 8 + 6 + 5 + 8 + 3 + 60 + 20 + 20 + 8, 2) || 'AR'; curAck = { line: i + 1, status, statusMeta: ACK_CODES[status] || { tone:'neutral', label:status, terminal:false }, creationDate: sliceAt(line, 19, 8), creationTime: sliceAt(line, 27, 6), originalGroupId: sliceAt(line, 33, 5), originalTransactionSeq: sliceAt(line, 38, 8), originalTransactionType: sliceAt(line, 46, 3), title: sliceAt(line, 49, 60), submitterRef: sliceAt(line, 109, 20), recipientRef: sliceAt(line, 129, 20), processingDate: sliceAt(line, 149, 8), messages: [], societyWorkId: null, // populated later if any IPA/MSG carries it group: curGroup ? { transactionType: curGroup.transactionType, groupId: curGroup.groupId } : null, }; acks.push(curAck); if (curGroup) curGroup.ackCount += 1; } else if (rt === 'MSG' && curAck) { // MSG fields after 19-byte hdr: // Message type 1, Original record type 3, Message level 1, // Validation # 3, Message text 150 const messageType = sliceAt(line, 19, 1); // F=field/G=record/T=transaction const recRef = sliceAt(line, 20, 3); const level = sliceAt(line, 23, 1); // E=error, W=warning, etc const validation = sliceAt(line, 24, 3); const messageText = sliceAt(line, 27, 150); curAck.messages.push({ messageType, recordType: recRef, level, validation, text: messageText, severity: level === 'E' || level === 'F' ? 'error' : level === 'W' ? 'warning' : 'info', }); } else if (curAck && rt === 'NWR') { // Some societies echo their assigned work ID inside the original NWR slot's "society work #" field // CWR 2.x NWR has Submitter Work # at offset 32 length 14. Society work # appears in v3 at later offset. // Best-effort: take chars 32-46 if non-empty as societyWorkId hint. const sw = sliceAt(line, 32, 14); if (sw && !curAck.societyWorkId) curAck.societyWorkId = sw; } } // Build summary const summary = emptySummary(); summary.acks = acks.length; summary.groups = groups.length; summary.lines = lines.length; acks.forEach((a) => { summary.byStatus[a.status] = (summary.byStatus[a.status] || 0) + 1; const tone = a.statusMeta.tone; summary.byTone[tone] = (summary.byTone[tone] || 0) + 1; if (a.messages.length) summary.withMessages += 1; }); return { ok:true, errors, header, groups, acks, summary }; } function emptySummary() { return { acks:0, groups:0, lines:0, byStatus:{}, byTone:{ok:0,warn:0,danger:0,info:0,neutral:0}, withMessages:0 }; } function matchSociety(header) { const list = window.SOCIETIES || []; const id = header.senderId || ''; const nameLc = (header.senderName || '').toLowerCase(); // Most societies use their CISAC 3-digit code as senderId (zero-padded) const byId = list.find((s) => s.cisacCode && (id === String(s.cisacCode) || id.endsWith(String(s.cisacCode)))); if (byId) return { acronym: byId.acronym, name: byId.name, country: byId.country }; const byName = list.find((s) => nameLc.includes((s.acronym || '').toLowerCase()) || nameLc.includes((s.name || '').toLowerCase().split(' ')[0]) ); if (byName) return { acronym: byName.acronym, name: byName.name, country: byName.country }; return { acronym: '?', name: header.senderName || 'Unknown society', country: '' }; } // ─── Apply: write to __REG_STATUS + match works by submitter ref ───────── function apply(parsed) { if (!parsed || !parsed.acks) return { applied:0, matched:0, unmatched:0 }; window.__REG_STATUS = window.__REG_STATUS || {}; const works = window.WORKS || []; const society = parsed.header?.society?.acronym || '?'; let matched = 0, unmatched = 0; parsed.acks.forEach((a) => { const ref = a.submitterRef || a.title; const key = `${society}:${ref}`; // Try to bind to a real work const found = works.find((w) => (w.submitterWorkId && w.submitterWorkId === ref) || (w.id && w.id === ref) || (w.title && a.title && w.title.toLowerCase() === a.title.toLowerCase()) ); if (found) matched += 1; else unmatched += 1; window.__REG_STATUS[key] = { society, status: a.status, statusLabel: a.statusMeta.label, tone: a.statusMeta.tone, terminal: !!a.statusMeta.terminal, societyWorkId: a.societyWorkId, title: a.title, submitterRef: ref, processingDate: a.processingDate, messages: a.messages, appliedAt: new Date().toISOString(), workId: found ? found.id : null, }; }); // Persist a small log entry window.__REG_STATUS_LOG = window.__REG_STATUS_LOG || []; window.__REG_STATUS_LOG.unshift({ at: new Date().toISOString(), society, filename: parsed.header?.filename || 'pasted.txt', acks: parsed.acks.length, matched, unmatched, counts: parsed.summary.byStatus, }); if (window.__REG_STATUS_LOG.length > 50) window.__REG_STATUS_LOG.length = 50; // Fire event so other screens can refresh try { window.dispatchEvent(new CustomEvent('astro-reg-status-updated', { detail: { society, count: parsed.acks.length } })); } catch (e) {} return { applied: parsed.acks.length, matched, unmatched }; } // Lookup helper for other modules function statusFor(society, submitterRef) { const map = window.__REG_STATUS || {}; return map[`${society}:${submitterRef}`] || null; } window.CwrAckImport = { parse, apply, statusFor, ACK_CODES }; // ─── Synthetic sample for demo when user clicks "Try sample" ──────────── function syntheticAckText() { const today = new Date(); const yyyymmdd = today.toISOString().slice(0,10).replace(/-/g,''); const hhmmss = '143055'; const pad = (s, n, c) => (c === 'L' ? String(s).padStart(n,' ').slice(-n) : String(s).padEnd(n,' ').slice(0, n)); const hdr = 'HDR' + 'SO' + '000000101' + pad('ASCAP', 45) + '02.10' + yyyymmdd + hhmmss + yyyymmdd; const grh = 'GRH' + 'ACK' + '00001' + '02.10' + ' ' + ' ' + ' '; const lines = [hdr, grh]; const samples = [ { ref:'PLU-2026-00041', title:'Eres Tú', status:'AS', msgs:[] }, { ref:'PLU-2026-00042', title:'Volver a Vivir', status:'AC', msgs:[ { lvl:'W', val:'001', t:'Title modified by society — original capitalization restored' }, ]}, { ref:'PLU-2026-00043', title:'No Te Va Gustar', status:'CO', msgs:[ { lvl:'E', val:'042', t:'Writer share conflict with prior registration · WID 123456' }, ]}, { ref:'PLU-2026-00044', title:'Última Llamada', status:'IR', msgs:[ { lvl:'E', val:'013', t:'Required field missing: writer IPI on SWR record 3' }, ]}, { ref:'PLU-2026-00045', title:'Mañana Será', status:'NP', msgs:[ { lvl:'W', val:'201', t:'Writer not represented by ASCAP territory' }, ]}, { ref:'PLU-2026-00046', title:'Caminos', status:'DU', msgs:[ { lvl:'W', val:'099', t:'Duplicate of prior submission · seq 00031' }, ]}, { ref:'PLU-2026-00047', title:'Lluvia y Sol', status:'RJ', msgs:[ { lvl:'F', val:'201', t:'Invalid IPI base check digit on writer 1' }, ]}, { ref:'PLU-2026-00048', title:'Calle Vieja', status:'AS', msgs:[] }, ]; let seq = 1; samples.forEach((s) => { const recPrefix = 'ACK' + pad(String(seq).padStart(8,'0'),8) + '0000000001'; // txn seq + record seq // 19-byte header is RT(3) + txn(8) + rec(8). Already done above. const ack = recPrefix + yyyymmdd + hhmmss + '00001' + pad(String(seq).padStart(8,'0'),8) + 'NWR' + pad(s.title, 60) + pad(s.ref, 20) + pad('A' + String(seq).padStart(8,'0'), 20) + yyyymmdd + s.status; lines.push(ack); let msgSeq = 1; s.msgs.forEach((m) => { const msgPrefix = 'MSG' + pad(String(seq).padStart(8,'0'),8) + pad(String(msgSeq).padStart(8,'0'),8); const msg = msgPrefix + 'F' + 'ACK' + m.lvl + m.val + pad(m.t, 150); lines.push(msg); msgSeq++; }); seq++; }); const grt = 'GRT' + '00001' + pad(String(samples.length).padStart(8,'0'),8) + pad(String(lines.length-2+1).padStart(8,'0'),8) + ' ' + '0000000000' + ' '; lines.push(grt); const trl = 'TRL' + '00001' + pad(String(samples.length).padStart(8,'0'),8) + pad(String(lines.length+1).padStart(7,'0'),7); lines.push(trl); return lines.join('\n'); } // ─── UI: Import tab ────────────────────────────────────────────────────── function CwrAckImportTab() { const [text, setText] = useState(''); const [filename, setFilename] = useState(''); const [parsed, setParsed] = useState(null); const [applied, setApplied] = useState(null); const [activeAck, setActiveAck] = useState(0); const fileInput = useRef(null); const [history, setHistory] = useState(() => window.__REG_STATUS_LOG || []); useEffect(() => { const handler = () => setHistory([...(window.__REG_STATUS_LOG || [])]); window.addEventListener('astro-reg-status-updated', handler); return () => window.removeEventListener('astro-reg-status-updated', handler); }, []); const onText = (t, name) => { setText(t); setFilename(name || filename || 'pasted.txt'); const p = parse(t); if (p.header) p.header.filename = name || filename || 'pasted.txt'; setParsed(p); setActiveAck(0); setApplied(null); }; const onFile = (file) => { if (!file) return; const r = new FileReader(); r.onload = (e) => onText(String(e.target.result), file.name); r.readAsText(file); }; const onDrop = (e) => { e.preventDefault(); const f = e.dataTransfer.files && e.dataTransfer.files[0]; if (f) onFile(f); }; const trySample = () => onText(syntheticAckText(), 'sample-ASCAP.V21'); const doApply = () => { if (!parsed) return; const r = apply(parsed); setApplied(r); setHistory([...(window.__REG_STATUS_LOG || [])]); }; return (
{/* ─── LEFT: drop-zone + summary + history ─────────────────── */}