Drafted only from approved reply knowledge{cls.citation ? '' : ' — nothing matched, so this is a holding reply that routes to the team'}. Edit before sending if needed.
);
}
/* ---------- urgency sort ----------
The pure sorter lives in triage-core.js (node-tested); used via TriageCore.sortByUrgency. */
/* ============================================================
App
============================================================ */
function App() {
const clsOf = useCallback((m, classifications) => {
const c = classifications && classifications[m.id];
return (c && c.data) ? c.data : { ...m.seed, live: false };
}, []);
const [classifications, setClassifications] = useState(() => {
// seed everything as 'done' from seed data so the queue is instantly tagged & sorted
const o = {};
[...MESSAGES, INBOUND_NEW].forEach(m => { o[m.id] = { status: 'done', data: { ...m.seed, live: false } }; });
return o;
});
const clsMap = useRef(classifications); clsMap.current = classifications;
const getCls = (m) => clsOf(m, clsMap.current);
const [order, setOrder] = useState(() => TriageCore.sortByUrgency(MESSAGES, m => ({ urgency: m.seed.urgency })));
const [selectedId, setSelectedId] = useState(DEFAULT_SELECTED);
const [sentIds, setSentIds] = useState(new Set());
const [toasts, setToasts] = useState([]);
const [flashId, setFlashId] = useState(null);
const [showIntro, setShowIntro] = useState(true);
const [simulating, setSimulating] = useState(false);
const queueBodyRef = useRef(null);
const liveRequested = useRef(new Set());
const pushToast = (title, sub) => {
const id = 'to-' + Date.now() + Math.random();
setToasts(t => [...t, { id, title, sub }]);
};
// run a real Claude classification for one message, falling back to seed
const runClassify = useCallback(async (msg, { reorder = false } = {}) => {
setClassifications(c => ({ ...c, [msg.id]: { status: 'processing', data: c[msg.id] && c[msg.id].data } }));
let data;
try { data = await classify(msg); }
catch (e) { data = { ...msg.seed, live: false }; }
setClassifications(c => ({ ...c, [msg.id]: { status: 'done', data } }));
if (reorder) {
setTimeout(() => {
setOrder(prev => {
const map = { ...clsMap.current, [msg.id]: { status: 'done', data } };
return TriageCore.sortByUrgency(prev, m => clsOf(m, map));
});
setFlashId(msg.id);
if (queueBodyRef.current) queueBodyRef.current.scrollTo({ top: 0, behavior: 'smooth' });
setTimeout(() => setFlashId(null), 1700);
}, 60);
}
}, [clsOf]);
// classify the default selection live on first load
useEffect(() => {
const m = MESSAGES.find(x => x.id === DEFAULT_SELECTED);
if (m && !liveRequested.current.has(m.id)) {
liveRequested.current.add(m.id);
runClassify(m);
}
}, []);
const allById = {};
[...MESSAGES, INBOUND_NEW].forEach(m => { allById[m.id] = m; });
const selectedMsg = allById[selectedId];
const selCls = selectedMsg ? getCls(selectedMsg) : null;
const selStatus = (classifications[selectedId] && classifications[selectedId].status) || 'done';
const handleSelect = (id) => {
setSelectedId(id);
const m = allById[id];
if (m && !liveRequested.current.has(id) && !sentIds.has(id)) {
liveRequested.current.add(id);
runClassify(m);
}
};
const handleApprove = (id, escalateSend) => {
const m = allById[id];
setSentIds(s => new Set(s).add(id));
if (escalateSend) pushToast('Escalated to ' + getCls(m).route, 'A person will handle ' + m.name.split(' ')[0] + '’s message');
else pushToast('Reply sent to ' + m.name.split(' ')[0], getCls(m).citation ? 'Cited ' + getCls(m).citation : 'Approved by you');
// advance to next unsent
const next = order.find(x => x.id !== id && !sentIds.has(x.id));
if (next) setTimeout(() => setSelectedId(next.id), 240);
};
const handleReassign = (id, q) => {
setClassifications(c => ({ ...c, [id]: { status: 'done', data: { ...c[id].data, route: q } } }));
pushToast('Re-routed to ' + q, 'Queue overridden — still nothing sent');
};
const handleEscalate = (id) => {
setClassifications(c => ({ ...c, [id]: { status: 'done', data: { ...c[id].data, escalate: true, escalate_reason: c[id].data.escalate_reason || 'Manually escalated by the coordinator for a person to handle.', draft_reply: '', citation: null } } }));
pushToast('Escalated', 'Marked for a person — no auto-reply');
};
const handleEditSave = (id, text) => {
setClassifications(c => ({ ...c, [id]: { status: 'done', data: { ...c[id].data, draft_reply: text } } }));
};
const simulateNew = () => {
if (simulating || order.find(x => x.id === INBOUND_NEW.id)) return;
setSimulating(true);
// 1) arrives at the BOTTOM in arrival order
setOrder(prev => [...prev, INBOUND_NEW]);
setClassifications(c => ({ ...c, [INBOUND_NEW.id]: { status: 'processing', data: undefined } }));
setSelectedId(INBOUND_NEW.id);
liveRequested.current.add(INBOUND_NEW.id);
if (queueBodyRef.current) setTimeout(() => queueBodyRef.current.scrollTo({ top: queueBodyRef.current.scrollHeight, behavior: 'smooth' }), 80);
// 2) after a beat, classify live + re-sort so it jumps to the top
setTimeout(() => {
runClassify(INBOUND_NEW, { reorder: true }).then(() => setSimulating(false));
}, 1100);
};
const counts = { high: 0, medium: 0, low: 0 };
order.forEach(m => { if (!sentIds.has(m.id)) counts[getCls(m).urgency]++; });
const openCount = order.filter(m => !sentIds.has(m.id)).length;
return (
{showIntro && (
Inbox Triage & Route — the agent classifies intent & urgency, routes each message, and drafts a grounded reply for your approval. Sensitive items are escalated, never auto-answered. Try Simulate new message to watch an urgent one jump the queue.
)}
real minds,
artificial intelligence
Triage & RouteShared inbox · coordinator desk
{openCount} open · {counts.high} urgentagent live
{/* LEFT — queue */}
Queue
{openCount} open
sorted by urgency● {counts.high} urgent● {counts.medium}● {counts.low}