// cwr-acks.jsx — Wave 3: CWR Ack-handling default view // // Per the audit (Section 8): "acks come back from societies. Right now there's // no clear 'this batch was accepted, this batch had errors, here's what to fix' // view. That should be the primary view of the CWR screen." // // This file replaces ScreenCwr at the route level. Default tab is ACKS — the // queue of returned society acknowledgements with rejection codes, the works // inside, and one-click "fix and resubmit" actions. Original tabs (in-flight // transmissions, society health) are preserved as secondary tabs. // // CWR ack codes are standardized (CISAC CWR 2.1 / 3.0). The big ones: // AS — Accepted (success) // AC — Accepted with Changes (society modified the registration) // RJ — Rejected (work-level) // NP — No Participation (society won't register; usually wrong PRO) // CO — Conflict (another publisher claims same work) // DU — Duplicate (already on file) // IR — Incomplete Registration (missing fields) // IE — Invalid Element (bad data in a field) // AR — Accepted (no further info) // // Exports: window.ScreenCwrAcks (function () { const { useState, useMemo, useEffect } = React; // ─────────── ack code dictionary const ACK_CODES = { AS: { label: 'Accepted', tone: 'ok', short: 'ACCEPTED', desc: 'Society accepted the registration as-is. Work ID assigned.' }, AC: { label: 'Accepted w/ Changes', tone: 'ok', short: 'ACK · CHANGED', desc: 'Accepted but the society modified one or more fields. Review their changes.' }, RJ: { label: 'Rejected', tone: 'danger', short: 'REJECTED', desc: 'Society rejected the work. See specific reason code.' }, NP: { label: 'No Participation', tone: 'warn', short: 'NO PARTICIPATION', desc: 'Society does not represent this writer. Wrong PRO assignment.' }, CO: { label: 'Conflict', tone: 'danger', short: 'CONFLICT', desc: 'Another publisher has filed conflicting splits. Manual resolution required.' }, DU: { label: 'Duplicate', tone: 'warn', short: 'DUPLICATE', desc: 'Society already has this work. Likely re-registration; safe to ignore if intentional.' }, IR: { label: 'Incomplete Reg', tone: 'danger', short: 'INCOMPLETE', desc: 'Required field missing. Most common: writer IPI, ISWC, or society work ID.' }, IE: { label: 'Invalid Element', tone: 'danger', short: 'INVALID', desc: 'Field present but malformed (bad IPI, invalid duration format, etc).' }, AR: { label: 'Accepted', tone: 'ok', short: 'ACK', desc: 'Acknowledged. No further detail provided.' }, }; const TONE_BG = { ok: '#1e6b3f', warn: '#9b6a18', danger: '#a04432' }; const TONE_BG_SOFT = { ok: 'rgba(45,106,63,.08)', warn: 'rgba(155,106,24,.08)', danger: 'rgba(160,68,50,.08)' }; const TONE_FG = { ok: '#1e6b3f', warn: '#9b6a18', danger: '#a04432' }; // ─────────── seeded RNG so the queue is stable const seedR = (s) => { let h = 2166136261 >>> 0; for (let i = 0; i < s.length; i++) { h = Math.imul(h ^ s.charCodeAt(i), 16777619); } return () => { h = Math.imul(h ^ (h >>> 13), 16777619); return ((h >>> 0) % 100000) / 100000; }; }; // ─────────── synthesize an ack queue from real societies + works function buildAckQueue() { const societies = (window.SOCIETIES || []).filter(s => s.kind === 'PRO' || s.kind === 'MRO' || s.kind === 'CMO' || s.kind === 'HUB'); const works = (window.WORKS || []); if (!societies.length || !works.length) return []; const codes = ['AS','AS','AS','AS','AS','AS','AC','AR','RJ','NP','CO','DU','IR','IE']; const today = new Date(); const out = []; let aid = 1; societies.slice(0, 14).forEach((soc, sIdx) => { const r = seedR(soc.acronym + ':acks'); const batchCount = 2 + Math.floor(r() * 3); // 2–4 batches per society in-window for (let b = 0; b < batchCount; b++) { const sentDays = 2 + Math.floor(r() * 18); const sentDate = new Date(today); sentDate.setDate(sentDate.getDate() - sentDays); const ackDate = new Date(sentDate); ackDate.setDate(sentDate.getDate() + 1 + Math.floor(r() * 6)); const totalWorks = 12 + Math.floor(r() * 80); const filenameSeq = String.fromCharCode(65 + b); const file = `CW${ackDate.getFullYear().toString().slice(2)}${String(ackDate.getMonth()+1).padStart(2,'0')}${String(ackDate.getDate()).padStart(2,'0')}${soc.acronym}.V21${filenameSeq}`; const transmissionId = `CWR-${ackDate.getFullYear()}-${String(ackDate.getMonth()+1).padStart(2,'0')}${String(ackDate.getDate()).padStart(2,'0')}-${soc.acronym}${filenameSeq}`; // distribute outcomes const items = []; let counts = { AS:0, AC:0, AR:0, RJ:0, NP:0, CO:0, DU:0, IR:0, IE:0 }; for (let i = 0; i < totalWorks; i++) { const code = codes[Math.floor(r() * codes.length)]; counts[code] = (counts[code] || 0) + 1; const work = works[Math.floor(r() * works.length)]; if (!work) continue; items.push({ id: 'AK' + (aid++), code, workId: work.id, workTitle: work.title || work.name || `Work ${work.id}`, iswc: work.iswc || null, societyWorkId: code === 'AS' || code === 'AC' || code === 'AR' ? `${soc.acronym}-${100000 + Math.floor(r() * 900000)}` : null, field: code === 'IE' ? ['SWR.IPI','NWR.ISWC','SWR.SHARE','NWR.DURATION','SPU.IPI'][Math.floor(r()*5)] : null, note: code === 'AC' ? ['Title shortened to 60 chars','Writer role coerced to CA','Performer name normalized'][Math.floor(r()*3)] : code === 'CO' ? `Conflicting publisher claim from ${['Sony','Warner Chappell','Concord','Reservoir'][Math.floor(r()*4)]}` : code === 'NP' ? `Writer not registered with ${soc.acronym}` : code === 'IR' ? ['Missing writer IPI','Missing ISWC','Missing duration','Missing performer'][Math.floor(r()*4)] : code === 'IE' ? 'Field format error' : null, }); } const accepted = (counts.AS||0) + (counts.AC||0) + (counts.AR||0); const rejected = (counts.RJ||0) + (counts.IR||0) + (counts.IE||0); const flagged = (counts.CO||0) + (counts.NP||0); const dupes = counts.DU||0; const status = rejected > 0 ? 'has-rejections' : flagged > 0 ? 'needs-review' : 'clean'; out.push({ id: transmissionId, file, society: { acronym: soc.acronym, name: soc.name, kind: soc.kind, country: soc.country, territory: soc.territory }, sent: sentDate.toISOString().slice(0,10), ack: ackDate.toISOString().slice(0,10), turnaroundHours: Math.max(1, Math.round((ackDate - sentDate) / 36e5)), totalWorks, counts, accepted, rejected, flagged, dupes, status, items, }); } }); return out.sort((a, b) => b.ack.localeCompare(a.ack)); } // ─────────── batch row function BatchRow({ batch, expanded, onToggle, onOpenWork, onResubmit }) { const tone = batch.status === 'has-rejections' ? 'danger' : batch.status === 'needs-review' ? 'warn' : 'ok'; const dot = TONE_FG[tone]; return (
{expanded && (
{/* outcome strip */}
{Object.entries(batch.counts).filter(([_, n]) => n > 0).map(([code, n]) => { const meta = ACK_CODES[code] || { tone:'neutral', short: code, desc:'' }; return (
{code} {meta.short.toLowerCase()} {n}
); })}
{/* items table — only NON-accepted by default */}
)}
); } function ItemList({ items, onOpenWork, onResubmit }) { const [showAll, setShowAll] = useState(false); const visible = showAll ? items : items.filter(it => !['AS','AC','AR'].includes(it.code)); if (visible.length === 0 && !showAll) { return (
All {items.length} works accepted clean.
); } return ( <>
{showAll ? 'ALL WORKS' : 'NEEDS ATTENTION'} · {visible.length}
{visible.slice(0, 50).map(it => (
{it.iswc ? `ISWC ${it.iswc}` : NO ISWC} {it.societyWorkId && <> · {it.societyWorkId}}
{it.field || '—'} {ACK_CODES[it.code]?.short || it.code} {it.note || ACK_CODES[it.code]?.desc || ''}
))} {visible.length > 50 && (
+ {visible.length - 50} more — open in transmissions log
)}
); } function ItemActions({ item, onOpenWork, onResubmit }) { if (['AS','AC','AR','DU'].includes(item.code)) return ; return (
); } function CodePill({ code }) { const meta = ACK_CODES[code] || { tone:'neutral', short:code }; const bg = meta.tone === 'ok' ? '#e8f0e9' : meta.tone === 'warn' ? '#f4ecd9' : meta.tone === 'danger' ? '#f4e3df' : '#eee'; const fg = meta.tone === 'ok' ? '#1e6b3f' : meta.tone === 'warn' ? '#9b6a18' : meta.tone === 'danger' ? '#a04432' : 'var(--ink-2)'; return {code} · {meta.short.split(' ')[0]}; } // ═══════════════════════════════════════════════════════ MAIN SCREEN function ScreenCwrAcks({ go, payload }) { const [tab, setTab] = useState(payload?.tab || (payload?.workIds || payload?.generate ? 'gen' : 'acks')); return (
{/* Hero */}
REGISTRATIONS · CWR · DDEX

CWR Acknowledgements

NEXT BATCH IN 02:14:33
{/* Tabs */}
{[ { k:'gen', l:'Generate', hint:'build a CWR file' }, { k:'acks', l:'Acks', hint:'returned from societies' }, { k:'import', l:'Import ACK', hint:'parse + apply status' }, { k:'flight', l:'In flight', hint:'awaiting ack' }, { k:'caf', l:'CAF · agreements', hint:'society-to-society wire' }, { k:'formats', l:'Formats', hint:'JSON / XML' }, { k:'ftp', l:'FTP', hint:'FTP / FTPS legacy' }, { k:'compl', l:'Compliance', hint:'spec conformance' }, { k:'health', l:'Society health', hint:'90-day rolling' }, { k:'ddex', l:'DDEX · DSPs', hint:'release deliveries' }, ].map(t => ( ))}
{tab === 'gen' && (window.CwrGenTab ? : null)} {tab === 'acks' && } {tab === 'import' && (window.CwrAckImportTab ? :
ACK importer unavailable.
)} {tab === 'flight' && } {tab === 'caf' && (window.CafGenTab ? :
CAF screen unavailable.
)} {tab === 'formats'&& (window.FormatsTab ? : null)} {tab === 'ftp' && (window.FtpTab ? :
FTP screen unavailable.
)} {tab === 'compl' && (window.CwrComplianceTab ? : null)} {tab === 'health' && } {tab === 'ddex' && }
); } // ═══════════════════════════════════════════════════════ TAB: ACKS function AcksTab({ go }) { const queue = useMemo(buildAckQueue, []); const totals = useMemo(() => { const t = { works:0, accepted:0, rejected:0, flagged:0, dupes:0, batches: queue.length, societies: new Set() }; queue.forEach(b => { t.works += b.totalWorks; t.accepted += b.accepted; t.rejected += b.rejected; t.flagged += b.flagged; t.dupes += b.dupes; t.societies.add(b.society.acronym); }); t.societies = t.societies.size; return t; }, [queue]); const [filter, setFilter] = useState('attention'); // attention | rejected | flagged | clean | all const [society, setSociety] = useState('all'); const [search, setSearch] = useState(''); const [expanded, setExpanded] = useState(() => new Set(queue.filter(b => b.status !== 'clean').slice(0, 1).map(b => b.id))); const societyOptions = useMemo(() => ['all', ...new Set(queue.map(b => b.society.acronym))], [queue]); const filtered = useMemo(() => queue.filter(b => { if (filter === 'attention' && b.status === 'clean') return false; if (filter === 'rejected' && b.rejected === 0) return false; if (filter === 'flagged' && b.flagged === 0) return false; if (filter === 'clean' && b.status !== 'clean') return false; if (society !== 'all' && b.society.acronym !== society) return false; if (search) { const q = search.toLowerCase(); if (!b.society.acronym.toLowerCase().includes(q) && !b.file.toLowerCase().includes(q) && !b.id.toLowerCase().includes(q)) return false; } return true; }), [queue, filter, society, search]); const onOpenWork = (workId) => { const work = (window.WORKS || []).find(w => w.id === workId); if (work && go) go('work', work); else window.toast && window.toast('Work not found in catalog'); }; const onResubmit = (item) => { window.toast && window.toast(`Queued ${item.workTitle} for resubmission to next CWR batch`); }; const acceptedPct = totals.works ? Math.round(totals.accepted / totals.works * 100) : 0; return (
{/* KPI strip */}
0 ? '#a04432' : 'var(--ink)'} sub="needs fix + resubmit"/> 0 ? '#9b6a18' : 'var(--ink)'} sub="conflicts · NPs"/>
{/* Filter toolbar */}
{[ { k:'attention', l:`NEEDS ATTENTION · ${queue.filter(b => b.status !== 'clean').length}`, tone:'#a04432' }, { k:'rejected', l:`REJECTED · ${queue.filter(b => b.rejected > 0).length}`, tone:'#a04432' }, { k:'flagged', l:`FLAGGED · ${queue.filter(b => b.flagged > 0).length}`, tone:'#9b6a18' }, { k:'clean', l:`CLEAN · ${queue.filter(b => b.status === 'clean').length}`, tone:'#2d6a3f' }, { k:'all', l:`ALL · ${queue.length}`, tone:'var(--ink)' }, ].map(f => ( ))} setSearch(e.target.value)} placeholder="Search batch ID, file, society…" className="ff-mono" style={{ flex:1, minWidth:200, padding:'8px 12px', fontSize:11, border:'1px solid var(--rule)', background:'var(--paper)' }}/>
{/* Column headers */}
SOC BATCH FILE OUTCOME DISTRIBUTION WORKS ACK · FLAG · REJ
{/* Batches */} {filtered.length === 0 ? (
Nothing in this view
Try a different filter, or wait for the next ack window.
) : filtered.map(batch => ( { const n = new Set(expanded); if (n.has(batch.id)) n.delete(batch.id); else n.add(batch.id); setExpanded(n); }} onOpenWork={onOpenWork} onResubmit={onResubmit} /> ))} {/* Code dictionary */}
CWR ACK CODES · CISAC 2.1 / 3.0
{Object.entries(ACK_CODES).map(([code, meta]) => (
{meta.label}
{meta.desc}
))}
); } // ═══════════════════════════════════════════════════════ TAB: IN FLIGHT function FlightTab({ go }) { // Borrow from existing TXN if it exists, otherwise synth const txns = (typeof window.TXN !== 'undefined' ? window.TXN : null) || [ { id:'CWR-2026-0501-ASCAPa', file:'CW260501ASCAP.V21A', count:142, recv:'ASCAP', status:'submitted', sent:'14:22', ack:'pending' }, { id:'CWR-2026-0501-BMIb', file:'CW260501BMI.V21B', count:118, recv:'BMI', status:'submitted', sent:'14:25', ack:'pending' }, { id:'CWR-2026-0501-PRSa', file:'CW260501PRS.V21A', count:88, recv:'PRS', status:'submitted', sent:'14:28', ack:'pending' }, ]; return ( <>
{txns.map((t, i, arr) => (
SEQ {String(i+1).padStart(3,'0')}
{t.recv}
SUBMITTED
{t.count} WORKS
{t.file}
SENT {t.sent} · ACK {t.ack}
))}
); } // ═══════════════════════════════════════════════════════ TAB: HEALTH function HealthTab({ go }) { const societies = (window.SOCIETIES || []).filter(s => s.kind === 'PRO' || s.kind === 'MRO' || s.kind === 'CMO' || s.kind === 'HUB'); return (
SOC NAME · TERRITORY ACK RATE · 90D RATE BATCHES LAST SENT
{societies.slice(0, 24).map(s => { const r = seedR(s.acronym + ':health'); const rate = Math.max(72, Math.min(99.5, (s.ackRate || (88 + r() * 11)))); const batches = Math.round(8 + r() * 30); const last = `2026-${String(4 + Math.floor(r() * 2)).padStart(2,'0')}-${String(1 + Math.floor(r() * 28)).padStart(2,'0')}`; const tone = rate >= 95 ? '#2d6a3f' : rate >= 90 ? '#9b6a18' : '#a04432'; return ( ); })}
); } // ═══════════════════════════════════════════════════════ TAB: DDEX function DdexTab({ go }) { return (
DDEX · DSP DELIVERIES
Pending integration

DDEX-out flows through the distributor (Symphonic). Outbound XML is generated server-side and shows up here as receipts once the connector is live.

); } function Kpi({ label, value, sub, tone = 'var(--ink)' }) { return (
{label}
{value}
{sub &&
{sub}
}
); } Object.assign(window, { ScreenCwrAcks }); })();