// ============================================================================ // CWR GENERATOR SCREEN · picker → preview → inspector // ---------------------------------------------------------------------------- // Loaded as window.CwrGenTab and rendered as a tab inside ScreenCwrAcks. // Three panes: // 1. WORK PICKER — multi-select from window.WORKS / window.songsAll, or // pre-selected when arriving from a Registrations row / Agreement detail. // 2. SETTINGS — version (2.1, 2.1r7, 2.2, 3.0, 3.1), transaction type // (NWR/REV/ISW), recipient society, sender details. // 3. PREVIEW — generated CWR transmission, line-by-line, with a side // inspector that decodes the clicked line into named fields. // // Optional: split-screen mode that generates the same works under TWO // versions side-by-side so you can see how the format evolves. // // Depends on: window.CwrBuild, window.CwrDecode, window.CwrSynth // EXPORT: window.CwrGenTab // ============================================================================ (function () { 'use strict'; const { useState, useMemo, useEffect, useRef } = React; // ─── Catalog source ─────────────────────────────────────────────────────── function getCatalogWorks() { // Pull from whatever the catalog currently exposes — ASTRO uses several // shapes depending on screen. We accept any of these and merge. const candidates = [ window.WORKS, window.songsAll, window.SONGS, window.ALL_WORKS, ].filter(Array.isArray); const seen = new Set(); const out = []; for (const arr of candidates) { for (const w of arr) { if (!w || !w.id || seen.has(w.id)) continue; seen.add(w.id); out.push(w); } } return out; } const VERSIONS = [ { v: '2.1', label: '2.1', hint: 'most societies still parse this' }, { v: '2.1r7', label: '2.1 r7', hint: 'CISAC June 2010 revision' }, { v: '2.2', label: '2.2', hint: 'adds REC fields, never widely deployed' }, { v: '3.0', label: '3.0', hint: 'new XRF, expanded MWN' }, { v: '3.1', label: '3.1', hint: 'current — XSD-validated' }, ]; const TXN_TYPES = [ { v: 'NWR', label: 'NWR — New work registration' }, { v: 'REV', label: 'REV — Revised registration' }, { v: 'ISW', label: 'ISW — Notification of ISWC' }, { v: 'EXC', label: 'EXC — Existing work in conflict' }, ]; const RECIPIENTS = [ { code: 'ASCAP', name: 'ASCAP' }, { code: 'BMI', name: 'BMI' }, { code: 'SESAC', name: 'SESAC' }, { code: 'PRS', name: 'PRS for Music' }, { code: 'GEMA', name: 'GEMA' }, { code: 'SACEM', name: 'SACEM' }, { code: 'JASRAC', name: 'JASRAC' }, { code: 'SOCAN', name: 'SOCAN' }, { code: 'APRA', name: 'APRA AMCOS' }, { code: 'MLC', name: 'The MLC' }, { code: 'HFA', name: 'HFA' }, ]; // ═══════════════════════════════════════════════════════════════════════════ function CwrGenTab({ go, payload }) { const all = useMemo(getCatalogWorks, []); // Pre-selection from caller (e.g. Registrations row → Generate CWR) const initialIds = (payload && payload.workIds) || []; const [selected, setSelected] = useState(() => new Set(initialIds.length ? initialIds : (all[0] ? [all[0].id] : []))); const [search, setSearch] = useState(''); const [version, setVersion] = useState(payload?.version || '2.1'); const [compareVer, setCompareVer] = useState(null); const [txnType, setTxnType] = useState('NWR'); const [recipient, setRecipient] = useState(payload?.recipient || 'ASCAP'); const [senderIpi, setSenderIpi] = useState(199900001); const [senderName, setSenderName] = useState('PLURALIS MUSIC'); const [activeLine, setActiveLine] = useState(0); const [distOpen, setDistOpen] = useState(false); const filtered = useMemo(() => { const q = search.trim().toLowerCase(); if (!q) return all; return all.filter((w) => `${w.title||''} ${w.iswc||''} ${(w.writers||[]).join(' ')}`.toLowerCase().includes(q)); }, [all, search]); // Generate the transmission const transmission = useMemo(() => { const works = [...selected].map((id) => all.find((w) => w.id === id)).filter(Boolean); const hydrated = works.map((w) => window.CwrSynth.hydrateWork(w, { senderIpi, senderName })); return window.CwrBuild.buildTransmission({ version, senderType: 'PB', senderIpi, senderName, transactionType: txnType, works: hydrated, created: new Date(2026, 4, 12, 14, 22, 33), }); }, [selected, all, version, txnType, senderIpi, senderName]); const transmissionCompare = useMemo(() => { if (!compareVer) return null; const works = [...selected].map((id) => all.find((w) => w.id === id)).filter(Boolean); const hydrated = works.map((w) => window.CwrSynth.hydrateWork(w, { senderIpi, senderName })); return window.CwrBuild.buildTransmission({ version: compareVer, senderType: 'PB', senderIpi, senderName, transactionType: txnType, works: hydrated, created: new Date(2026, 4, 12, 14, 22, 33), }); }, [compareVer, selected, all, txnType, senderIpi, senderName]); const filename = window.CwrBuild.buildFilename({ version, senderCode: 'PLU', recipientCode: recipient, sequence: 501, created: new Date(2026, 4, 12), }); const decoded = useMemo(() => { const line = transmission[activeLine]; if (!line) return null; return window.CwrDecode.decodeLine(line, version); }, [transmission, activeLine, version]); // ── Validation report (CISAC compliance gauntlet) const validation = useMemo(() => { if (!window.CwrValidate) return { issues: [], summary: { errors: 0, warnings: 0, total: 0, ok: true } }; const works = [...selected].map((id) => all.find((w) => w.id === id)).filter(Boolean); const hydrated = works.map((w) => window.CwrSynth.hydrateWork(w, { senderIpi, senderName })); return window.CwrValidate.validate({ version, lines: transmission, works: hydrated }); }, [transmission, version, selected, all, senderIpi, senderName]); const [validationOpen, setValidationOpen] = useState(false); // Toggle a work's selection const toggle = (id) => setSelected((s) => { const next = new Set(s); if (next.has(id)) next.delete(id); else next.add(id); return next; }); // Download const download = () => { const blob = new Blob([transmission.join('\r\n') + '\r\n'], { type: 'text/plain' }); const url = URL.createObjectURL(blob); const a = document.createElement('a'); a.href = url; a.download = filename; document.body.appendChild(a); a.click(); a.remove(); URL.revokeObjectURL(url); window.toast && window.toast(`Wrote ${filename} (${transmission.length} records)`); }; const copy = () => { navigator.clipboard.writeText(transmission.join('\r\n')); window.toast && window.toast('CWR transmission copied to clipboard'); }; return (
{/* ── LEFT: pickers ────────────────────────────────────── */} {/* ── RIGHT: preview + inspector ─────────────────────── */}
{/* file header bar */}
{filename}
{transmission.length} records · {transmission.reduce((s, l) => s + l.length, 0).toLocaleString()} chars · CWR v{version} · → {recipient}
{validationOpen && setActiveLine(line)} />} {/* preview body — split if compareVer set, otherwise lines+inspector */} {compareVer ? ( ) : (
)}
{distOpen && ( setDistOpen(false)} works={[...selected].map((id) => all.find((w) => w.id === id)).filter(Boolean)} version={version} txnType={txnType} senderIpi={senderIpi} senderName={senderName} /> )}
); } // ─── Distribute modal: one file per recipient society ───────────────────── function DistributeModal({ onClose, works, version, txnType, senderIpi, senderName }) { const [picked, setPicked] = useState(() => new Set(['ASCAP','BMI','MLC'])); const [stage, setStage] = useState('config'); // config | review | sent const [transport, setTransport] = useState('cwr-portal'); // cwr-portal | sftp | email const [delivery, setDelivery] = useState('immediate'); // immediate | scheduled const [scheduleAt, setScheduleAt] = useState('2026-05-13T09:00'); const [groupBy, setGroupBy] = useState('one-file'); // one-file | per-territory const togglePick = (code) => setPicked((s) => { const n = new Set(s); if (n.has(code)) n.delete(code); else n.add(code); return n; }); // Build one transmission per recipient const manifest = useMemo(() => { const hydrated = works.map((w) => window.CwrSynth.hydrateWork(w, { senderIpi, senderName })); return [...picked].map((code) => { const recv = RECIPIENTS.find((r) => r.code === code); const lines = window.CwrBuild.buildTransmission({ version, senderType: 'PB', senderIpi, senderName, transactionType: txnType, works: hydrated, recipient: code, created: new Date(2026, 4, 12, 14, 22, 33), }); const filename = window.CwrBuild.buildFilename({ version, senderCode: 'PLU', recipientCode: code, sequence: 501 + [...picked].indexOf(code), created: new Date(2026, 4, 12), }); return { code, name: recv?.name || code, filename, lines: lines.length, bytes: lines.reduce((s, l) => s + l.length + 2, 0), works: works.length, transport, eta: transport === 'cwr-portal' ? '< 5 min' : transport === 'sftp' ? '< 30 min' : '< 1 hr', }; }); }, [picked, works, version, txnType, senderIpi, senderName, transport]); const totalBytes = manifest.reduce((s, m) => s + m.bytes, 0); const totalRecords = manifest.reduce((s, m) => s + m.lines, 0); return (
e.stopPropagation()} style={{ width: 'min(900px, 96vw)', maxHeight: '88vh', background: 'var(--bg)', border: '1px solid var(--rule)', boxShadow: '0 24px 60px rgba(0,0,0,.35)', display: 'flex', flexDirection: 'column' }}> {/* Header */}
BATCH DISTRIBUTION · CWR v{version}
{stage === 'config' ? 'Distribute to societies' : stage === 'review' ? 'Review manifest' : 'Queued for delivery'}
{/* Body */}
{stage === 'config' && (
RECIPIENT SOCIETIES · {picked.size} selected
{RECIPIENTS.map((r) => ( ))}
TRANSPORT
{[ { v: 'cwr-portal', l: 'CWR Portal (CISAC EBU/CIS-Net)', sub: 'Direct society API · TLS 1.3' }, { v: 'sftp', l: 'SFTP drop', sub: 'Per-society credential vault' }, { v: 'email', l: 'Email attachment', sub: 'PGP-signed · for legacy CMOs' }, ].map((t) => ( ))}
DELIVERY
{[ { v: 'immediate', l: 'Send immediately', sub: 'Queued on confirm' }, { v: 'scheduled', l: 'Schedule for…', sub: 'Hold until time' }, ].map((t) => ( ))}
{delivery === 'scheduled' && ( setScheduleAt(e.target.value)} className="ff-mono" style={{ width: '100%', padding: '7px 8px', fontSize: 11, background: 'var(--paper)', border: '1px solid var(--rule)' }} /> )}
FILE GROUPING
{[ { v: 'one-file', l: 'One file per society', sub: 'Standard CWR' }, { v: 'per-territory', l: 'Per-society × per-territory', sub: 'For multi-jurisdiction CMOs' }, ].map((t) => ( ))}
)} {stage === 'review' && (
FILES TO TRANSMIT · {manifest.length} · {(totalBytes/1024).toFixed(1)} KB · {totalRecords.toLocaleString()} records
SOCIETYFILENAMEWORKSRECORDSETA
{manifest.map((m) => (
{m.code} {m.filename} {m.works} {m.lines} {m.eta}
))}
Transport: {transport === 'cwr-portal' ? 'CWR Portal' : transport.toUpperCase()} {' · '}Delivery: {delivery === 'immediate' ? 'Immediate' : `Scheduled · ${scheduleAt.replace('T', ' ')}`} {' · '}Audit log will record submitter, recipient codes, file SHA-256, and ack channel for each file.
)} {stage === 'sent' && (
✓
{manifest.length} {manifest.length === 1 ? 'file' : 'files'} queued
Track delivery & acks on the Acks tab. Audit log entries created for each file.
{manifest.map((m) => (
{m.code} · {m.filename} QUEUED
))}
)}
{/* Footer */}
{stage === 'config' && `${picked.size} ${picked.size === 1 ? 'recipient' : 'recipients'} · ${works.length} ${works.length === 1 ? 'work' : 'works'}`} {stage === 'review' && `Confirms send · ${manifest.length} files`} {stage === 'sent' && 'Done'}
{stage === 'config' && ( <> )} {stage === 'review' && ( <> )} {stage === 'sent' && ( )}
); } // ─── Lines view ─────────────────────────────────────────────────────────── function LinesView({ lines, active, onPick, version }) { if (window.CwrHighlight && window.CwrHighlight.Viewer) { return React.createElement(window.CwrHighlight.Viewer, { lines, version, active, onPick, }); } return (
{lines.map((line, i) => { const recType = line.slice(0, 3); const isControl = ['HDR', 'GRH', 'GRT', 'TRL'].includes(recType); const color = colorForRec(recType); return (
onPick(i)} style={{ display: 'flex', cursor: 'pointer', padding: '0 16px', background: active === i ? 'var(--bg-2)' : (isControl ? 'rgba(0,0,0,0.025)' : 'transparent'), borderLeft: active === i ? '3px solid var(--ink)' : '3px solid transparent', }}> {String(i + 1).padStart(4, '0')} {recType} {line.slice(3)}
); })}
); } // ─── Validation panel ───────────────────────────────────────────────────── function ValidationPanel({ report, version, onJump }) { const [filter, setFilter] = useState('all'); // all | error | warn const issues = report.issues || []; const filtered = issues.filter((i) => filter === 'all' || i.severity === filter); const grouped = useMemo(() => { const g = {}; filtered.forEach((iss) => { const cat = iss.rule.split('.')[0]; (g[cat] = g[cat] || []).push(iss); }); return g; }, [filtered]); const summary = report.summary || { errors: 0, warnings: 0, ok: true }; const ruleDescriptions = { 'file': 'Transmission structure', 'length': 'Record length', 'charset': 'Character set', 'iswc': 'ISWC check digit (ISO 15707)', 'ipi': 'IPI check digit (CISAC IPI Manual)', 'isrc': 'ISRC format (ISO 3901)', 'society': 'CISAC society code', 'tis': 'TIS territory code', 'shares': 'Share reconciliation', 'pwr': 'Publisher-Writer chain', 'trl': 'TRL counts', }; return (
{/* Compact summary band */}
{summary.errors === 0 && summary.warnings === 0 ? 'CISAC compliance · pass' : summary.errors === 0 ? `Pass with ${summary.warnings} warning${summary.warnings === 1 ? '' : 's'}` : `${summary.errors} error${summary.errors === 1 ? '' : 's'} · ${summary.warnings} warning${summary.warnings === 1 ? '' : 's'}`}
CWR v{version} · {Object.keys(ruleDescriptions).length} rule families · IPI mod-101 · ISWC mod-10 · TIS · CISAC societies
{[ { v: 'all', l: `all (${issues.length})` }, { v: 'error', l: `errors (${summary.errors})` }, { v: 'warn', l: `warnings (${summary.warnings})` }, ].map((t) => ( ))}
{/* Issues list */}
{filtered.length === 0 ? (
{issues.length === 0 ? '✓ All structural and semantic rules pass — file is ready for society submission.' : 'No issues match this filter.'}
) : ( Object.keys(grouped).map((cat) => (
{ruleDescriptions[cat] || cat} {grouped[cat].length} item{grouped[cat].length === 1 ? '' : 's'}
{grouped[cat].map((iss, i) => (
iss.line != null && onJump && onJump(iss.line)} style={{ padding: '9px 16px 9px 14px', borderBottom: '1px solid var(--rule)', cursor: iss.line != null ? 'pointer' : 'default', borderLeft: '3px solid ' + (iss.severity === 'error' ? '#c0392b' : '#d68910'), display: 'flex', alignItems: 'flex-start', gap: 12, }}> {iss.severity === 'error' ? 'error' : 'warn'}
{iss.msg}
rule: {iss.rule} {iss.line != null && line: {iss.line + 1} →} {iss.work != null && work: #{iss.work + 1}}
))}
)) )}
); } // ─── Compare view ───────────────────────────────────────────────────────── function CompareView({ lines, compareLines, version, compareVer }) { const max = Math.max(lines.length, compareLines.length); const rows = []; for (let i = 0; i < max; i++) rows.push([lines[i] || '', compareLines[i] || '']); return (
{[[lines, version], [compareLines, compareVer]].map(([ls, vv], side) => (
CWR {vv} — {ls.length} records
{ls.map((line, i) => { const rt = line.slice(0, 3); const other = side === 0 ? compareLines[i] : lines[i]; const diff = line !== other; return (
{String(i + 1).padStart(4, '0')} {rt} {line.slice(3)}
); })}
))}
); } // ─── Inspector ──────────────────────────────────────────────────────────── function Inspector({ decoded, line }) { if (!decoded) return null; return (
RECORD
{decoded.recType}
{recDescription(decoded.recType)} · {line.length} chars
{decoded.fields.map((f, i) => { const lookup = f.lookup ? window.CwrDecode.lookupCode(f.lookup, f.value) : null; const trimmed = String(f.value || '').trim(); const isEmpty = !trimmed; return (
{f.name}
{isEmpty ? '— blank —' : (f.kind === 'date' ? formatDate(trimmed) : f.kind === 'time' ? formatTime(trimmed) : trimmed)}
{lookup && (
↳ {lookup.label}{lookup.description ? ' — ' + lookup.description : ''}
)}
); })}
); } function colorForRec(rt) { const map = { HDR: 'oklch(0.55 0.18 30)', GRH: 'oklch(0.55 0.18 30)', GRT: 'oklch(0.55 0.18 30)', TRL: 'oklch(0.55 0.18 30)', NWR: 'oklch(0.45 0.16 260)', REV: 'oklch(0.45 0.16 260)', ISW: 'oklch(0.45 0.16 260)', EXC: 'oklch(0.45 0.16 260)', SPU: 'oklch(0.5 0.14 160)', SPT: 'oklch(0.5 0.10 160)', OPU: 'oklch(0.5 0.14 200)', OPT: 'oklch(0.5 0.10 200)', SWR: 'oklch(0.5 0.16 50)', SWT: 'oklch(0.5 0.10 50)', OWR: 'oklch(0.5 0.16 320)', OWT: 'oklch(0.5 0.10 320)', PWR: 'oklch(0.5 0.16 90)', ALT: 'oklch(0.5 0.10 280)', EWT: 'oklch(0.45 0.13 280)', VER: 'oklch(0.45 0.13 280)', PER: 'oklch(0.5 0.14 0)', REC: 'oklch(0.5 0.14 220)', ORN: 'oklch(0.5 0.12 130)', INS: 'oklch(0.5 0.10 60)', IND: 'oklch(0.5 0.10 60)', COM: 'oklch(0.5 0.12 180)', MSG: 'oklch(0.55 0.18 30)', ARI: 'oklch(0.5 0.10 100)', XRF: 'oklch(0.5 0.14 240)', ACK: 'oklch(0.55 0.18 30)', }; return map[rt] || 'var(--ink-2)'; } function recDescription(rt) { const REF = window.REF; if (REF && REF.ready && REF.raw && REF.raw.cwr_record_types) { const m = REF.raw.cwr_record_types.find((r) => r.code === rt); if (m) return m.label; } const fallback = { HDR: 'File Header', GRH: 'Group Header', GRT: 'Group Trailer', TRL: 'File Trailer', NWR: 'New Work Registration', REV: 'Revised Registration', ISW: 'ISWC Notification', EXC: 'Existing Work in Conflict', SPU: 'Submitter Publisher (Controlled)', SPT: 'Submitter Publisher Territory', OPU: 'Other Publisher', OPT: 'Other Publisher Territory', SWR: 'Submitter Writer (Controlled)', SWT: 'Submitter Writer Territory', OWR: 'Other Writer', OWT: 'Other Writer Territory', PWR: 'Publisher-for-Writer Link', ALT: 'Alternate Title', EWT: 'Entire Work Title', VER: 'Original Work for Version', PER: 'Performer', REC: 'Recording Detail', ORN: 'Work Origin', INS: 'Instrumentation Summary', IND: 'Instrumentation Detail', COM: 'Component Title', MSG: 'Message', ARI: 'Additional Related Info', XRF: 'Cross-Reference (v3)', ACK: 'Acknowledgement', }; return fallback[rt] || rt; } function formatDate(s) { if (!s || !/^\d{8}$/.test(s)) return s; return s.slice(0, 4) + '-' + s.slice(4, 6) + '-' + s.slice(6, 8); } function formatTime(s) { if (!s || !/^\d{6}$/.test(s)) return s; return s.slice(0, 2) + ':' + s.slice(2, 4) + ':' + s.slice(4, 6); } window.CwrGenTab = CwrGenTab; })();