LUKE HEADROOM / Editorial Desk

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_157":158,"_159":160},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_119":-5,"_20":120,"_22":121,"_122":123,"_124":125,"_25":126,"_24":-5,"_127":-5,"_128":-5,"_129":53,"_130":131,"_132":44,"_133":-5,"_134":-5,"_135":136},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","vvampa","name","luke-headroom-dashboard","branchName","main","version","path","","project",{"_33":61,"_13":14,"_45":62,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":69,"_70":-5,"_71":72,"_73":37,"_74":44,"_75":-5,"_76":-5,"_77":78,"_79":80,"_81":82,"_83":84,"_85":86,"_87":-5,"_88":89,"_90":89,"_91":92,"_93":92,"_94":92,"_95":89,"_96":89,"_97":98,"_99":100,"_101":102,"_103":53},"tree",[56],"file","contents",[32],"upstream","pull","ahead","behind","envVars",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":55},"id","87b4ceb0-3752-4193-b046-2b3165d6a8dc","main.ts","fileId","a8a4fe36-7fa1-11f1-8949-1607ee4eb77e","parentId","branchId","25a12779-704b-4a0a-8f52-1d35eadf2dad","branchVersion",45,"latest",true,"createdAt",["D",1784136860717],44,"fileType","http","content","/* Open in Val Town: https://www.val.town/x/vvampa/luke-headroom-dashboard/code/main.ts */\nimport { Hono } from \"npm:hono\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\nconst app = new Hono();\nlet ready;\nconst now = () => new Date().toISOString();\nasync function init() {\n if (ready)\n return ready;\n ready = (async () => {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS review_items (\n id TEXT PRIMARY KEY, source_type TEXT NOT NULL, headline TEXT NOT NULL,\n source_url TEXT NOT NULL, summary TEXT NOT NULL, source_excerpt TEXT NOT NULL DEFAULT '',\n draft TEXT NOT NULL, status TEXT NOT NULL, evidence TEXT NOT NULL,\n alignment TEXT NOT NULL DEFAULT '', received_at TEXT NOT NULL, updated_at TEXT NOT NULL,\n archived_at TEXT, archive_reason TEXT\n )`);\n for (const q of [\"ALTER TABLE review_items ADD COLUMN source_excerpt TEXT NOT NULL DEFAULT ''\", \"ALTER TABLE review_items ADD COLUMN alignment TEXT NOT NULL DEFAULT ''\", \"ALTER TABLE review_items ADD COLUMN archived_at TEXT\", \"ALTER TABLE review_items ADD COLUMN archive_reason TEXT\"]) {\n try {\n await sqlite.execute(q);\n }\n catch (_) { }\n }\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS item_comments (\n id INTEGER PRIMARY KEY AUTOINCREMENT, item_id TEXT NOT NULL, author TEXT NOT NULL,\n body TEXT NOT NULL, created_at TEXT NOT NULL\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS comment_changes (\n id INTEGER PRIMARY KEY AUTOINCREMENT, comment_id INTEGER NOT NULL, item_id TEXT NOT NULL,\n action TEXT NOT NULL, author TEXT NOT NULL DEFAULT '', body TEXT NOT NULL DEFAULT '',\n changed_at TEXT NOT NULL, pushed_at TEXT\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS item_revisions (\n id INTEGER PRIMARY KEY AUTOINCREMENT, item_id TEXT NOT NULL, draft TEXT NOT NULL,\n status TEXT NOT NULL, created_at TEXT NOT NULL\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS push_events (\n id INTEGER PRIMARY KEY AUTOINCREMENT, payload TEXT NOT NULL, created_at TEXT NOT NULL,\n acknowledged_at TEXT\n )`);\n try {\n await sqlite.execute(\"ALTER TABLE push_events ADD COLUMN acknowledged_at TEXT\");\n }\n catch (_) { }\n })();\n}\nconst COOLING_DAYS = 30;\nasync function coolStaleItems() {\n await init();\n const cutoff = new Date(Date.now() - COOLING_DAYS * 86400000).toISOString();\n const stale = await sqlite.execute({ sql: `SELECT id FROM review_items\n WHERE status IN ('needs_review','drafted')\n AND datetime(received_at) < datetime(?)\n AND datetime(updated_at) < datetime(?)\n AND (archived_at IS NULL OR archived_at='')\n AND NOT EXISTS (SELECT 1 FROM item_comments c WHERE c.item_id=review_items.id AND datetime(c.created_at) >= datetime(?))`, args: [cutoff, cutoff, cutoff] });\n if (!stale.rows.length)\n return { count: 0, cutoff };\n const archivedAt = now();\n for (const row of stale.rows) {\n await sqlite.execute({ sql: \"UPDATE review_items SET status='archived', archived_at=?, archive_reason='cooled_after_30_days', updated_at=? WHERE id=? AND status IN ('needs_review','drafted')\", args: [archivedAt, archivedAt, row.id] });\n }\n return { count: stale.rows.length, cutoff };\n}\nconst page = `LUKE HEADROOM / Editorial Desk

LUKE HEADROOM

Last sync: loading

Review queue

Loading…

`;\napp.get(\"/\", async (c) => new Response(page, { headers: { \"content-type\": \"text/html; charset=utf-8\" } }));\napp.get(\"/source\", c => c.redirect(parseVal().links.self.val));\napp.get(\"/api/items\", async (c) => { await init(); await coolStaleItems(); const includeArchived = c.req.query('include_archived') === '1'; const r = await sqlite.execute(includeArchived ? \"SELECT * FROM review_items ORDER BY received_at DESC\" : \"SELECT * FROM review_items WHERE status != 'archived' ORDER BY received_at DESC\"); const rows = []; for (const x of r.rows) {\n const cs = await sqlite.execute({ sql: \"SELECT id,author,body,created_at FROM item_comments WHERE item_id=? ORDER BY created_at\", args: [x.id] });\n rows.push({ ...x, comments: cs.rows });\n} return c.json(rows); });\napp.patch(\"/api/items/:id\", async (c) => { await init(); const id = c.req.param('id'); const body = await c.req.json(); const old = await sqlite.execute({ sql: \"SELECT * FROM review_items WHERE id=?\", args: [id] }); if (!old.rows.length)\n return c.json({ error: 'not found' }, 404); const previous = old.rows[0]; const nextStatus = body.status ?? previous.status; const changedAt = now(); const archivedAt = nextStatus === 'archived' ? (previous.archived_at || changedAt) : null; const archiveReason = nextStatus === 'archived' ? (body.archive_reason || previous.archive_reason || 'manual_archive') : null; await sqlite.execute({ sql: \"INSERT INTO item_revisions (item_id,draft,status,created_at) VALUES (?,?,?,?)\", args: [id, previous.draft, previous.status, changedAt] }); await sqlite.execute({ sql: \"UPDATE review_items SET draft=?,summary=?,source_excerpt=?,alignment=?,status=?,archived_at=?,archive_reason=?,updated_at=? WHERE id=?\", args: [body.draft ?? previous.draft, body.summary ?? previous.summary, body.source_excerpt ?? previous.source_excerpt, body.alignment ?? previous.alignment, nextStatus, archivedAt, archiveReason, changedAt, id] }); return c.json({ ok: true, id, status: nextStatus }); });\napp.post(\"/api/items/:id/comments\", async (c) => { await init(); const id = c.req.param('id'); const body = await c.req.json(); const text = String(body.body || '').trim(); const created = now(); const exists = await sqlite.execute({ sql: \"SELECT id FROM review_items WHERE id=?\", args: [id] }); if (!exists.rows.length)\n return c.json({ error: 'not found' }, 404); if (!text)\n return c.json({ error: 'body required' }, 400); const author = body.author || 'Editorial desk'; await sqlite.execute({ sql: \"INSERT INTO item_comments (item_id,author,body,created_at) VALUES (?,?,?,?)\", args: [id, author, text, created] }); const r = await sqlite.execute(\"SELECT last_insert_rowid() AS id\"); const commentId = r.rows[0].id; await sqlite.execute({ sql: \"INSERT INTO comment_changes (comment_id,item_id,action,author,body,changed_at) VALUES (?,?,?,?,?,?)\", args: [commentId, id, 'create', author, text, created] }); await sqlite.execute({ sql: \"UPDATE review_items SET updated_at=? WHERE id=?\", args: [created, id] }); return c.json({ id: commentId, item_id: id, author, body: text, created_at: created }); });\napp.patch(\"/api/comments/:id\", async (c) => { await init(); const commentId = c.req.param('id'); const body = await c.req.json(); const text = String(body.body || '').trim(); if (!text)\n return c.json({ error: 'body required' }, 400); const old = await sqlite.execute({ sql: \"SELECT * FROM item_comments WHERE id=?\", args: [commentId] }); if (!old.rows.length)\n return c.json({ error: 'not found' }, 404); const previous = old.rows[0]; const changed = now(); await sqlite.execute({ sql: \"UPDATE item_comments SET body=? WHERE id=?\", args: [text, commentId] }); await sqlite.execute({ sql: \"INSERT INTO comment_changes (comment_id,item_id,action,author,body,changed_at) VALUES (?,?,?,?,?,?)\", args: [commentId, previous.item_id, 'update', previous.author, text, changed] }); await sqlite.execute({ sql: \"UPDATE review_items SET updated_at=? WHERE id=?\", args: [changed, previous.item_id] }); return c.json({ ok: true, id: Number(commentId), item_id: previous.item_id, author: previous.author, body: text }); });\napp.delete(\"/api/comments/:id\", async (c) => { await init(); const commentId = c.req.param('id'); const old = await sqlite.execute({ sql: \"SELECT * FROM item_comments WHERE id=?\", args: [commentId] }); if (!old.rows.length)\n return c.json({ error: 'not found' }, 404); const previous = old.rows[0]; const changed = now(); const pending = await sqlite.execute({ sql: \"SELECT COUNT(*) AS count FROM comment_changes WHERE comment_id=? AND pushed_at IS NULL\", args: [commentId] }); const pushed = await sqlite.execute({ sql: \"SELECT COUNT(*) AS count FROM comment_changes WHERE comment_id=? AND pushed_at IS NOT NULL\", args: [commentId] }); await sqlite.execute({ sql: \"DELETE FROM item_comments WHERE id=?\", args: [commentId] }); await sqlite.execute({ sql: \"DELETE FROM comment_changes WHERE comment_id=? AND pushed_at IS NULL\", args: [commentId] }); if (Number(pushed.rows[0]?.count || 0) > 0) await sqlite.execute({ sql: \"INSERT INTO comment_changes (comment_id,item_id,action,author,body,changed_at) VALUES (?,?,?,?,?,?)\", args: [commentId, previous.item_id, 'delete', previous.author, previous.body, changed] }); await sqlite.execute({ sql: \"UPDATE review_items SET updated_at=? WHERE id=?\", args: [changed, previous.item_id] }); return c.json({ ok: true, id: Number(commentId), item_id: previous.item_id, undone_pending: Number(pushed.rows[0]?.count || 0) === 0 && Number(pending.rows[0]?.count || 0) > 0 }); });\napp.get(\"/api/comment-queue\", async (c) => { await init(); const r = await sqlite.execute(\"SELECT COUNT(DISTINCT c.id) AS count FROM item_comments c JOIN comment_changes ch ON ch.comment_id=c.id WHERE ch.pushed_at IS NULL\"); return c.json({ count: Number(r.rows[0]?.count || 0) }); });\napp.get(\"/api/items/:id/revisions\", async (c) => { await init(); const r = await sqlite.execute({ sql: \"SELECT * FROM item_revisions WHERE item_id=? ORDER BY created_at DESC\", args: [c.req.param('id')] }); return c.json(r.rows); });\napp.post(\"/api/items\", async (c) => { await init(); const b = await c.req.json(); const t = now(); const q = (v) => `'${String(v ?? '').replaceAll(\"'\", \"''\")}'`; const vals = [b.id, b.source_type, b.headline, b.source_url, b.summary || b.source_excerpt, b.source_excerpt || b.summary, b.draft, b.status || 'needs_review', b.evidence || 'medium', b.alignment || '', b.received_at || t, t].map(q).join(','); await sqlite.execute(`INSERT OR REPLACE INTO review_items (id,source_type,headline,source_url,summary,source_excerpt,draft,status,evidence,alignment,received_at,updated_at) VALUES (${vals})`); return c.json({ ok: true, id: b.id }); });\napp.post(\"/api/cooling\", async (c) => { const result = await coolStaleItems(); return c.json({ ok: true, ...result }); });\napp.post(\"/api/push\", async (c) => { await init(); await coolStaleItems(); const r = await sqlite.execute(\"SELECT * FROM review_items ORDER BY updated_at DESC\"); const comments = await sqlite.execute(\"SELECT * FROM item_comments ORDER BY created_at\"); const revisions = await sqlite.execute(\"SELECT * FROM item_revisions ORDER BY created_at\"); const changes = await sqlite.execute(\"SELECT * FROM comment_changes WHERE pushed_at IS NULL ORDER BY changed_at\"); const push_id = 'push-' + Date.now(); const created_at = now(); const payload = { push_id, created_at, authority: 'valtown', target: 'hermes-luke-headroom', items: r.rows, comments: comments.rows, comment_changes: changes.rows, revisions: revisions.rows }; await sqlite.execute({ sql: \"INSERT INTO push_events (payload,created_at,acknowledged_at) VALUES (?,?,NULL)\", args: [JSON.stringify(payload), created_at] }); await sqlite.execute({ sql: \"UPDATE comment_changes SET pushed_at=? WHERE pushed_at IS NULL\", args: [created_at] }); const event = await sqlite.execute(\"SELECT last_insert_rowid() AS id\"); return c.json({ ok: true, push_id, command_id: event.rows[0].id, queued_for_hermes: true, items: payload.items.length, comments: payload.comments.length, comment_changes: payload.comment_changes.length, revisions: payload.revisions.length }); });\napp.get(\"/api/pushes\", async (c) => { await init(); const pending = c.req.query('pending') === '1'; const r = await sqlite.execute(pending ? \"SELECT id,created_at,payload FROM push_events WHERE acknowledged_at IS NULL ORDER BY created_at ASC\" : \"SELECT id,created_at,acknowledged_at FROM push_events ORDER BY created_at DESC\"); return c.json(r.rows); });\napp.post(\"/api/pushes/:id/ack\", async (c) => { await init(); const acknowledged = now(); const r = await sqlite.execute({ sql: \"UPDATE push_events SET acknowledged_at=? WHERE id=? AND acknowledged_at IS NULL\", args: [acknowledged, c.req.param('id')] }); return c.json({ ok: true, acknowledged_at: acknowledged, changed: r.rowsAffected ?? 1 }); });\napp.post(\"/api/reset\", async (c) => { await init(); await sqlite.batch([\"DELETE FROM item_comments\", \"DELETE FROM comment_changes\", \"DELETE FROM item_revisions\", \"DELETE FROM review_items\", \"DELETE FROM push_events\"].map(sql => ({ sql, args: [] }))); return c.json({ ok: true, scrubbed: true }); });\napp.get(\"/api/health\", async (c) => { await init(); return c.json({ ok: true, authority: 'hermes', mode: 'editorial-workspace', syncCadence: 'manual-push', cooling: { enabled: true, days: COOLING_DAYS, action: 'archive', protects: ['approved', 'recently-edited', 'recently-commented'] } }); });\napp.onError(err => Promise.reject(err));\nexport default app.fetch;\n","deleted",false,"label",[35],{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":59,"_18":60},["D",1784136860717],"children",[],[35],"788086ad-fd5c-4531-a0ee-62069aac0cab",["D",1784046691506],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Sanitized editorial review dashboard","imageUrl","userId","4014c640-61ba-11f0-852d-15ceec715ebe","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","4014c641-61ba-11f0-852d-15ceec715ebe","tursoName","788086adfd5c4531a0ee62069aac0cab","tursoHostname","788086adfd5c4531a0ee62069aac0cab-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789559472742],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_118":114},"org",{"_11":12,"_112":-5,"_113":114,"_71":72,"_115":116,"_117":53},"branch",{"_17":42,"_13":16,"_33":40,"_104":61,"_105":-5,"_106":-5,"_107":-5,"_108":-5,"_109":-5,"_110":14,"_111":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJ6dlV1b1h4VzRxbTBVblhueldOUjc4R3N1ViJ9","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":61,"_13":14,"_45":152,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":69,"_70":-5,"_71":72,"_73":37,"_74":44,"_75":-5,"_76":-5,"_77":78,"_79":80,"_81":82,"_83":84,"_85":153,"_87":-5,"_88":89,"_90":89,"_91":92,"_93":92,"_94":92,"_95":89,"_96":89,"_97":154,"_99":155,"_101":156,"_103":53},[149],"files",[149],"counts",{"_139":78,"_140":141,"_142":78,"_31":143,"_144":145},[137],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":138},[35],"pulls","branches",1,"forks",{"_146":78,"_148":78},"connections",{"_146":78,"_147":78},"count","unfilledCount","emptyCount",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":150,"_18":151},[],[35],["D",1784046691506],["D",1789559472742],{"_11":12,"_118":114},{"_11":12,"_112":-5,"_113":114,"_71":72,"_115":116,"_117":53},{"_17":42,"_13":16,"_33":40,"_104":61,"_105":-5,"_106":-5,"_107":-5,"_108":-5,"_109":-5,"_110":14,"_111":12},"ctx",{"_97":-5,"_134":190,"_191":192,"_193":194,"_195":53,"_196":53,"_197":53,"_198":44,"_199":-5,"_200":-7,"_201":-7,"_202":78,"_203":53,"_204":53,"_205":-5,"_206":53,"_207":53,"_208":53,"_209":-5},"ENV",{"_161":162,"_163":164,"_165":16,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Code