${escapeHtml(wire.text)}`,
+ tags: ['slate'],
+ }, opts));
+ }
+ const settle = pack.formats.settle && pack.formats.settle[0];
+ if (settle) {
+ results.push(await saveDraft({
+ title: `The Settle — ${new Date(pack.generated_at).toDateString()}`,
+ html: `${escapeHtml(settle.text)}`,
+ tags: ['settle'],
+ }, opts));
+ }
+ return { ok: results.every((r) => r.ok), results };
+}
+
+const escapeHtml = (s) => String(s).replace(/&/g, '&').replace(//g, '>');
+
+module.exports = { saveDraft, saveDailyDrafts, ghostJwt, isConfigured };
diff --git a/src/services/mediaEngine.js b/src/services/mediaEngine.js
new file mode 100644
index 0000000..68c409c
--- /dev/null
+++ b/src/services/mediaEngine.js
@@ -0,0 +1,258 @@
+'use strict';
+
+/**
+ * mediaEngine — VOICE v1.1 template engine (Session 63 / A1-S4).
+ *
+ * Deterministic templates for the wire formats (MORNING WIRE, SIGNAL,
+ * STREAK WATCH, THE SETTLE, RECEIPTS, ARCHETYPE WATCH, LINE DISPATCH),
+ * filled ONLY from pipeline JSON (snapshot/ledger/streaks). Templates never
+ * compose numbers — the Data Semantics Rule extends to marketing. Record
+ * claims obey the product's n≥20 gate. Stark-layer lines are SELECTED from
+ * the curated committed library (content/stark-lines.json), never generated.
+ *
+ * Every emitted string passes lintVoice() — the banned list + the
+ * no-exclamation law are enforced at build time by tests and at runtime by
+ * assembly (a template that fails lint throws in dev, drops the line in prod).
+ *
+ * NOTHING here posts anywhere. Output goes to /desk for Kev to publish.
+ */
+
+const fs = require('fs');
+const path = require('path');
+
+const STARK = JSON.parse(fs.readFileSync(path.join(__dirname, '..', '..', 'content', 'stark-lines.json'), 'utf8'));
+
+// ---- VOICE lint -----------------------------------------------------------
+const BANNED_PATTERNS = [
+ /!/, // no exclamation points, ever
+ /\block(s|ed)?\b/i, /🔒/,
+ /🔥/, /💰/, /🚀/, /💯/,
+ /we['’]?re so back/i, /it['’]?s so over/i,
+ /\btail\b/i, /\bfade\b/i, // as calls to action — banned outright
+ /can['’]?t lose/i, /free money/i, /guarantee/i,
+ /RT if/i, /who['’]?s tailing/i, /\btailing\b/i,
+ /\beating\b/i, /\bcooking\b/i, /\bGOAT\b/,
+];
+
+/** Returns [] when clean, else the matched patterns (as strings). */
+function lintVoice(text) {
+ const hits = [];
+ for (const re of BANNED_PATTERNS) {
+ if (re.test(String(text || ''))) hits.push(re.source);
+ }
+ return hits;
+}
+
+function assertVoice(text, context) {
+ const hits = lintVoice(text);
+ if (hits.length > 0) {
+ const msg = `[mediaEngine] VOICE lint failed (${context}): ${hits.join(', ')}`;
+ if (process.env.NODE_ENV === 'test') throw new Error(msg);
+ console.warn(msg);
+ return false;
+ }
+ return true;
+}
+
+// ---- helpers ---------------------------------------------------------------
+const sideCh = (dir) => (String(dir || 'over').toLowerCase() === 'under' ? 'u' : 'o');
+
+function etTime(iso, withDay = false) {
+ const d = iso ? new Date(iso) : new Date();
+ if (Number.isNaN(d.getTime())) return '';
+ const opts = withDay
+ ? { timeZone: 'America/New_York', weekday: 'short', month: 'short', day: 'numeric' }
+ : { timeZone: 'America/New_York', hour: 'numeric', minute: '2-digit' };
+ return new Intl.DateTimeFormat('en-US', opts).format(d);
+}
+
+/** Deterministic stark selection: day-of-year rotation, never random
+ * (Data Semantics: reproducible output for the same inputs + date). */
+function starkLine(category, dateIso) {
+ const lines = STARK[category] || [];
+ if (lines.length === 0) return null;
+ const d = dateIso ? new Date(dateIso) : new Date();
+ const doy = Math.floor((d.getTime() - Date.UTC(d.getUTCFullYear(), 0, 0)) / 86_400_000);
+ return lines[doy % lines.length];
+}
+
+/** Segment a post into ≤280-char tweets on line boundaries. */
+function segmentThread(text, limit = 280) {
+ const lines = String(text || '').split('\n');
+ const tweets = [];
+ let cur = '';
+ for (const line of lines) {
+ const candidate = cur ? `${cur}\n${line}` : line;
+ if (candidate.length > limit && cur) {
+ tweets.push(cur);
+ cur = line;
+ } else {
+ cur = candidate;
+ }
+ }
+ if (cur.trim()) tweets.push(cur);
+ return tweets;
+}
+
+// ---- formats ---------------------------------------------------------------
+
+/** THE MORNING WIRE. data = { dateIso, counts: {mlb, wnba, ...}, loudest: grade row|null } */
+function morningWire(data = {}) {
+ const parts = Object.entries(data.counts || {})
+ .filter(([, n]) => n > 0)
+ .map(([sp, n]) => `${n} ${sp.toUpperCase()}.`);
+ const lines = [`THE WIRE — ${etTime(data.dateIso, true)}`];
+ if (parts.length > 0) lines.push(parts.join(' '));
+ if (data.loudest && data.loudest.grade) {
+ const l = data.loudest;
+ const arch = l.archetype ? `a ${l.archetype} read` : `an ${l.grade} read`;
+ lines.push(`Loudest signal: ${arch} — ${l.player} ${l.stat_type || l.stat} ${sideCh(l.direction)}${l.line} · ${l.grade}.`);
+ }
+ const stark = starkLine('morning', data.dateIso);
+ if (stark) lines.push(stark);
+ lines.push('Slate’s graded. 3 free reads a day.', 'vyndr.app');
+ const text = lines.join('\n');
+ assertVoice(text, 'morningWire');
+ return text;
+}
+
+/** SIGNAL. g = one graded snapshot row (must carry gradedAt). */
+function signal(g = {}) {
+ if (!g.player || !g.grade) return null;
+ const lines = [
+ `${g.player} — ${humanStat(g.stat_type || g.stat)} ${sideCh(g.direction)}${g.line} · ${g.grade}`,
+ ];
+ if (g.archetype) lines.push(`${g.archetype} read.`);
+ const odds = g.gradedAt && g.gradedAt.odds != null ? ` at ${g.gradedAt.odds}` : '';
+ const ts = g.gradedAt && g.gradedAt.timestamp ? `Graded ${etTime(g.gradedAt.timestamp)} ET${odds}.` : null;
+ if (ts) lines.push(ts);
+ const text = lines.join('\n');
+ assertVoice(text, 'signal');
+ return text;
+}
+
+/** STREAK WATCH. rows = lens-applied streak rows. */
+function streakWatch(rows = [], dateIso) {
+ const real = rows.filter((r) => r && r.lens && r.lens.read).slice(0, 4);
+ if (real.length === 0) return null;
+ const lines = [`STREAK WATCH — ${etTime(dateIso, true)}`];
+ for (const r of real) lines.push(`${r.player}: ${r.lens.read}.`);
+ const stark = starkLine('streak', dateIso);
+ if (stark) lines.push(stark);
+ lines.push('vyndr.app/explore');
+ const text = lines.join('\n');
+ assertVoice(text, 'streakWatch');
+ return text;
+}
+
+/**
+ * THE SETTLE. agg = ledger model aggregate; misses = settled miss rows.
+ * Record percentages ONLY at n≥20 (the aggregate already nulls them) —
+ * below that, counts only, honestly labeled.
+ */
+function theSettle({ aggregate, misses = [], dateIso } = {}) {
+ const a = aggregate || {};
+ const lines = [`THE SETTLE — ${etTime(dateIso, true)}`];
+ const tierA = a.by_tier && a.by_tier['A'];
+ if (tierA && tierA.settled > 0) lines.push(`A-tier: ${tierA.hits}-${tierA.misses}`);
+ if (a.settled > 0) lines.push(`All grades: ${a.hits}-${a.misses}${a.pushes ? ` (${a.pushes} push)` : ''}`);
+ else lines.push('Nothing settled today.');
+ if (a.hit_pct == null && a.settled > 0) {
+ lines.push(`Record building — ${a.settled} settled, ${a.pending || 0} pending. Percentages post at 20.`);
+ }
+ const missRows = misses.filter((m) => m && m.player_name).slice(0, 6);
+ if (missRows.length > 0) {
+ lines.push(`Misses, by name: ${missRows.map((m) => `${m.player_name} ${humanStat(m.stat)} ${sideCh(m.side)}${m.line} ❌`).join(' · ')}`);
+ }
+ const stark = starkLine(missRows.length > 0 ? 'settle_losing' : 'settle_winning', dateIso);
+ if (stark) lines.push(stark);
+ lines.push('vyndr.app/ledger');
+ const text = lines.join('\n');
+ assertVoice(text, 'theSettle');
+ return text;
+}
+
+/** RECEIPTS. row = settled ledger row with lock + close + outcome. */
+function receipt(row = {}) {
+ if (!row.player_name || !row.outcome) return null;
+ const s = sideCh(row.side);
+ const lines = [
+ `Posted ${etTime(row.graded_at)} ET: ${row.player_name} ${humanStat(row.stat)} ${s}${row.line} · ${row.grade}${row.locked_odds ? ` · ${row.locked_odds}` : ''}`,
+ ];
+ if (row.closing_line != null && row.clv_result) {
+ const clvNote = row.clv_result === 'beat' ? 'Market chased the read.'
+ : row.clv_result === 'faded' ? 'Market went the other way.' : 'Close held.';
+ lines.push(`Close: ${s}${row.closing_line}${row.closing_odds ? ` at ${row.closing_odds}` : ''}. ${clvNote}`);
+ }
+ const mark = row.outcome === 'hit' ? '✅' : row.outcome === 'miss' ? '❌' : 'push';
+ lines.push(`Result: ${row.actual_value != null ? `${row.actual_value} ` : ''}${mark}`);
+ if (row.clv_result === 'beat' && row.outcome === 'hit') {
+ const stark = starkLine('steam', row.settled_at);
+ if (stark) lines.push(stark);
+ }
+ const text = lines.join('\n');
+ assertVoice(text, 'receipt');
+ return text;
+}
+
+/** ARCHETYPE WATCH. grades = snapshot rows. */
+function archetypeWatch(grades = [], dateIso) {
+ const byArch = {};
+ for (const g of grades) {
+ if (!g.archetype || !g.grade) continue;
+ byArch[g.archetype] = byArch[g.archetype] || [];
+ byArch[g.archetype].push(g);
+ }
+ const top = Object.entries(byArch).sort((a, b) => b[1].length - a[1].length)[0];
+ if (!top || top[1].length < 2) return null;
+ const [arch, rows] = top;
+ const lines = [
+ `${arch} watch: ${rows.length} on tonight’s slate.`,
+ ...rows.slice(0, 4).map((g) => `${g.player} ${humanStat(g.stat_type || g.stat)} ${sideCh(g.direction)}${g.line} · ${g.grade}`),
+ 'vyndr.app',
+ ];
+ const text = lines.join('\n');
+ assertVoice(text, 'archetypeWatch');
+ return text;
+}
+
+/** LINE DISPATCH. move = intraday movement row on a graded prop. */
+function lineDispatch(g = {}, nowIso) {
+ const m = g.movement;
+ if (!m || m.delta == null) return null;
+ const s = sideCh(g.direction);
+ const locked = g.gradedAt && g.gradedAt.line != null ? g.gradedAt.line : g.line;
+ const arrow = m.currentLine > locked ? '▲' : '▼';
+ const kind = m.kind === 'steam' ? 'Steam.' : m.kind === 'value' ? 'Value — the read holds at the new number.' : 'Line moved.';
+ const lines = [
+ `${g.player} ${humanStat(g.stat_type || g.stat)}: ${s}${locked} → ${s}${m.currentLine} ${arrow}`,
+ `${kind} ${etTime(nowIso)} ET.`,
+ ];
+ const text = lines.join('\n');
+ assertVoice(text, 'lineDispatch');
+ return text;
+}
+
+const STAT_HUMAN = {
+ total_bases: 'TB', home_runs: 'HR', hits: 'Hits', rbi: 'RBI', runs: 'Runs',
+ strikeouts: 'Ks', stolen_bases: 'SB', earned_runs: 'ER', innings_pitched: 'IP',
+ points: 'PTS', rebounds: 'REB', assists: 'AST', threes: '3PT', outs: 'Outs', doubles: '2B',
+};
+function humanStat(stat) {
+ const k = String(stat || '').toLowerCase();
+ return STAT_HUMAN[k] || k.replace(/_/g, ' ');
+}
+
+module.exports = {
+ lintVoice,
+ segmentThread,
+ starkLine,
+ morningWire,
+ signal,
+ streakWatch,
+ theSettle,
+ receipt,
+ archetypeWatch,
+ lineDispatch,
+ __internals: { BANNED_PATTERNS, etTime, humanStat, assertVoice, STARK },
+};
diff --git a/src/snapshotScheduler.js b/src/snapshotScheduler.js
index f894123..e726310 100644
--- a/src/snapshotScheduler.js
+++ b/src/snapshotScheduler.js
@@ -110,6 +110,12 @@ function startSnapshotScheduler(opts = {}) {
const results = await runAll();
const ok = results.filter((r) => r.status === 'ok');
console.log(`[snapshot] cron fired ${h}:00 UTC — ${ok.length}/${results.length} sports graded`);
+ // Session 63 (A1-S4) — after the day's FIRST slot, tell Kev the media
+ // pack is ready. One ping, only when something actually graded.
+ if (h === HOURS_UTC[0] && ok.length > 0) {
+ const total = results.reduce((n, r) => n + (r.gradeCount || 0), 0);
+ await notify(`Desk pack ready — ${total} props graded across ${ok.length} sports. vyndr.app/desk`, { title: 'VYNDR desk', tags: ['newspaper'] });
+ }
} catch (e) {
console.warn('[snapshot] cron run failed:', e.message);
}
diff --git a/tests/unit/mediaEngine.test.js b/tests/unit/mediaEngine.test.js
new file mode 100644
index 0000000..ee210fd
--- /dev/null
+++ b/tests/unit/mediaEngine.test.js
@@ -0,0 +1,179 @@
+// Session 63 (A1-S4) — the VOICE v1.1 template engine. Numbers only from
+// pipeline JSON; lint enforces the banned list + no-exclamation law; record
+// claims obey n≥20; Stark lines are SELECTED from the committed library.
+
+const media = require('../../src/services/mediaEngine');
+const { lintVoice, segmentThread, starkLine, morningWire, signal, theSettle, receipt, streakWatch, archetypeWatch, lineDispatch } = media;
+
+describe('lintVoice — the banned list is law', () => {
+ test.each([
+ ['This one is a lock!', 2], // "lock" + exclamation
+ ['🔥 free money, who’s tailing', 3],
+ ['We’re so back 🚀', 2],
+ ])('%s → %i violations', (text, n) => {
+ expect(lintVoice(text).length).toBeGreaterThanOrEqual(n);
+ });
+ test('clean wire copy passes', () => {
+ expect(lintVoice('THE SETTLE — Jul 11\nA-tier: 6-2\nvyndr.app/ledger')).toEqual([]);
+ });
+});
+
+describe('every template output passes its own lint', () => {
+ const NOW = '2026-07-12T14:05:00.000Z';
+ const GRADE = {
+ player: 'Aaron Judge', stat_type: 'total_bases', line: 1.5, direction: 'over',
+ grade: 'A', confidence: 78, archetype: 'BOMBER',
+ gradedAt: { line: 1.5, odds: -120, timestamp: NOW },
+ };
+
+ test('morning wire: real counts, stark from the library, no bans', () => {
+ const text = morningWire({ dateIso: NOW, counts: { mlb: 15, wnba: 3, nba: 0 }, loudest: GRADE });
+ expect(text).toContain('15 MLB.');
+ expect(text).toContain('3 WNBA.');
+ expect(text).not.toContain('0 NBA'); // zero sports never listed
+ expect(text).toContain('Aaron Judge');
+ expect(text).toContain('vyndr.app');
+ expect(lintVoice(text)).toEqual([]);
+ });
+
+ test('signal: player + line + grade + ET timestamp with real odds', () => {
+ const text = signal(GRADE);
+ expect(text).toContain('Aaron Judge — TB o1.5 · A');
+ expect(text).toContain('BOMBER read.');
+ expect(text).toContain('at -120');
+ expect(lintVoice(text)).toEqual([]);
+ });
+
+ test('the settle: counts always, percentages NEVER under n≥20', () => {
+ const agg = { settled: 8, hits: 5, misses: 3, pushes: 0, hit_pct: null, pending: 16, by_tier: { A: { settled: 4, hits: 3, misses: 1, hit_pct: null } } };
+ const misses = [{ player_name: 'A’ja Wilson', stat: 'points', line: 23.5, side: 'over' }];
+ const text = theSettle({ aggregate: agg, misses, dateIso: NOW });
+ expect(text).toContain('All grades: 5-3');
+ expect(text).toContain('A-tier: 3-1');
+ expect(text).not.toContain('%'); // no percentage below the gate
+ expect(text).toContain('Record building — 8 settled');
+ expect(text).toContain('Wilson PTS o23.5 ❌'); // misses BY NAME
+ expect(lintVoice(text)).toEqual([]);
+ });
+
+ test('receipt: lock beside close beside result', () => {
+ const row = {
+ player_name: 'Aaron Judge', stat: 'total_bases', line: 1.5, side: 'over', grade: 'A',
+ graded_at: NOW, locked_odds: '-120', closing_line: 1.5, closing_odds: '-145',
+ clv: 0, clv_result: 'flat', outcome: 'hit', actual_value: 2, settled_at: NOW,
+ };
+ const text = receipt(row);
+ expect(text).toContain('Posted');
+ expect(text).toContain('Judge TB o1.5 · A · -120');
+ expect(text).toContain('Close: o1.5 at -145');
+ expect(text).toContain('Result: 2 ✅');
+ expect(lintVoice(text)).toEqual([]);
+ });
+
+ test('streak watch: lens reads only, absent lens rows dropped', () => {
+ const rows = [
+ { player: 'Brice Turang', lens: { read: '12-game on-base streak; tonight @ Pittsburgh Pirates' } },
+ { player: 'No Lens Guy', lens: { read: null } },
+ ];
+ const text = streakWatch(rows, NOW);
+ expect(text).toContain('Turang');
+ expect(text).not.toContain('No Lens Guy');
+ expect(lintVoice(text)).toEqual([]);
+ });
+
+ test('archetype watch needs ≥2 of a kind, else null', () => {
+ expect(archetypeWatch([GRADE], NOW)).toBeNull();
+ const two = archetypeWatch([GRADE, { ...GRADE, player: 'Shohei Ohtani' }], NOW);
+ expect(two).toContain('BOMBER watch: 2');
+ expect(lintVoice(two)).toEqual([]);
+ });
+
+ test('line dispatch from a real movement row', () => {
+ const text = lineDispatch({ ...GRADE, movement: { kind: 'steam', delta: 1, currentLine: 2.5 } }, NOW);
+ expect(text).toContain('o1.5 → o2.5 ▲');
+ expect(text).toContain('Steam.');
+ expect(lintVoice(text)).toEqual([]);
+ });
+});
+
+describe('stark layer — selected, never generated; deterministic', () => {
+ test('same date → same line; comes from the committed library', () => {
+ const a = starkLine('morning', '2026-07-12T10:00:00Z');
+ const b = starkLine('morning', '2026-07-12T22:00:00Z');
+ expect(a).toBe(b);
+ expect(media.__internals.STARK.morning).toContain(a);
+ });
+ test('the whole library passes lint', () => {
+ for (const lines of Object.values(media.__internals.STARK)) {
+ if (!Array.isArray(lines)) continue;
+ for (const l of lines) expect(lintVoice(l)).toEqual([]);
+ }
+ });
+});
+
+describe('segmentThread — ≤280 per tweet on line boundaries', () => {
+ test('splits long threads and preserves every line', () => {
+ const long = Array.from({ length: 30 }, (_, i) => `Line ${i} of the settle with some padding text`).join('\n');
+ const tweets = segmentThread(long);
+ expect(tweets.length).toBeGreaterThan(1);
+ for (const t of tweets) expect(t.length).toBeLessThanOrEqual(280);
+ expect(tweets.join('\n')).toBe(long);
+ });
+});
+
+describe('deskService — pack assembly from pipeline data only', () => {
+ const { assembleDeskPack } = require('../../src/services/deskService');
+ test('assembles formats + data brief from injected caches', async () => {
+ const NOW = '2026-07-12T14:05:00.000Z';
+ const store = {
+ 'snapshot:mlb:latest': { grades: [
+ { player: 'Aaron Judge', stat_type: 'total_bases', line: 1.5, direction: 'over', grade: 'A', confidence: 80, archetype: 'BOMBER', gradedAt: { line: 1.5, odds: -120, timestamp: NOW } },
+ { player: 'Shohei Ohtani', stat_type: 'home_runs', line: 0.5, direction: 'over', grade: 'A', confidence: 76, archetype: 'BOMBER', gradedAt: { line: 0.5, odds: 130, timestamp: NOW } },
+ ] },
+ };
+ const pack = await assembleDeskPack({
+ cacheGet: async (k) => store[k] ?? null,
+ loadRosterLogs: async () => [],
+ ledger: { getModelAggregate: async () => ({ settled: 0, hits: 0, misses: 0, pushes: 0, hit_pct: null, pending: 24 }), __internals: { isConfigured: () => false } },
+ fetchSettled: async () => [],
+ now: () => NOW,
+ });
+ expect(pack.formats.morning_wire[0].text).toContain('2 MLB.');
+ expect(pack.formats.signals.length).toBe(2);
+ expect(pack.formats.archetype_watch[0].text).toContain('BOMBER watch: 2');
+ // variants: wire + numbers-only when a stark line was present
+ expect(pack.formats.morning_wire.length).toBeGreaterThanOrEqual(1);
+ expect(pack.data_brief.top_signals[0].player).toBe('Aaron Judge');
+ expect(pack.data_brief.record.pending).toBe(24);
+ // every emitted text passes lint
+ const all = JSON.stringify(pack.formats);
+ expect(all).not.toContain('!');
+ });
+});
+
+describe('ghostPublisher — drafts only, env-gated, no deps', () => {
+ const ghost = require('../../src/services/ghostPublisher');
+ test('JWT is a valid HS256 three-parter with the key id', () => {
+ const t = ghost.ghostJwt('abc123:6465616462656566', 1_752_000_000);
+ const [h, p] = t.split('.');
+ const header = JSON.parse(Buffer.from(h, 'base64url').toString());
+ const payload = JSON.parse(Buffer.from(p, 'base64url').toString());
+ expect(header.kid).toBe('abc123');
+ expect(payload.aud).toBe('/admin/');
+ expect(payload.exp - payload.iat).toBe(300);
+ });
+ test('unconfigured → no-op, never a throw', async () => {
+ const r = await ghost.saveDraft({ title: 't', html: 'x
' }); + expect(r.ok).toBe(false); + expect(r.reason).toBe('ghost not configured'); + }); + test('posts DRAFT status only', async () => { + let body = null; + const r = await ghost.saveDraft({ title: 't', html: 'x
' }, { + force: true, url: 'https://blog.test', adminKey: 'id:6162', + fetchImpl: async (url, opts) => { body = JSON.parse(opts.body); return { ok: true, json: async () => ({ posts: [{ id: 'p1' }] }) }; }, + }); + expect(r.ok).toBe(true); + expect(body.posts[0].status).toBe('draft'); // NOTHING auto-publishes + }); +}); diff --git a/web/src/app/api/desk/pack/route.ts b/web/src/app/api/desk/pack/route.ts new file mode 100644 index 0000000..47cd01c --- /dev/null +++ b/web/src/app/api/desk/pack/route.ts @@ -0,0 +1,21 @@ +import { NextRequest, NextResponse } from 'next/server'; + +export const dynamic = 'force-dynamic'; + +const BACKEND_URL = process.env.BACKEND_URL || 'http://localhost:3000'; + +/** Desk pack proxy (Session 63 / A1-S4) — forwards the founder's auth. */ +export async function GET(req: NextRequest) { + const auth = req.headers.get('authorization'); + if (!auth) return NextResponse.json({ error: 'auth required' }, { status: 401 }); + try { + const upstream = await fetch(`${BACKEND_URL}/api/desk/pack`, { + headers: { Accept: 'application/json', Authorization: auth }, + cache: 'no-store', + }); + const data = await upstream.json().catch(() => ({})); + return NextResponse.json(data, { status: upstream.status }); + } catch { + return NextResponse.json({ error: 'desk unavailable' }, { status: 200 }); + } +} diff --git a/web/src/app/desk/page.tsx b/web/src/app/desk/page.tsx new file mode 100644 index 0000000..ec397b3 --- /dev/null +++ b/web/src/app/desk/page.tsx @@ -0,0 +1,148 @@ +'use client'; + +import { useEffect, useState } from 'react'; +import { useAuth } from '@/contexts/AuthContext'; + +/** + * /desk (Session 63 / A1-S4c) — the founder's daily copy-paste arsenal. + * Auth: gated route + backend email allowlist (DESK_OWNERS). Everything on + * this page is assembled from the pipeline by the VOICE v1.1 template + * engine; per-tweet copy buttons + character counts; the DATA BRIEF block + * pastes into claude.ai for freeform writing. Nothing auto-posts. + */ + +interface Variant { label: string; text: string; tweets: string[] } +interface DeskPack { + generated_at: string | null; + formats: { + morning_wire?: Variant[]; + signals?: Variant[][]; + streak_watch?: Variant[]; + settle?: Variant[]; + receipts?: Variant[][]; + archetype_watch?: Variant[]; + line_dispatches?: Variant[][]; + }; + data_brief?: unknown; + error?: string; +} + +function CopyBtn({ text, label = 'COPY' }: { text: string; label?: string }) { + const [done, setDone] = useState(false); + return ( + + ); +} + +function VariantBlock({ v }: { v: Variant }) { + return ( +{t}
+ The desk is the publisher’s surface. DESK_OWNERS grants access.
+{status === 'loading' ? 'Assembling the pack…' : 'Pack unavailable. Check back after the first pipeline run.'}
++ Assembled {new Date(pack.generated_at).toLocaleString('en-US', { timeZone: 'America/New_York' })} ET · nothing auto-posts +
+ )} +{JSON.stringify(pack.data_brief, null, 2)}
+