LUKE HEADROOM / Editorial Desk

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_167":168,"_169":170},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":-7,"_61":136,"_16":-7,"_137":-5,"_17":138,"_139":140,"_28":141,"_21":142,"_23":143,"_144":-5,"_145":-5,"_146":-5,"_147":35,"_148":149,"_150":38,"_151":-5,"_152":-5,"_153":154},"routes/_app.x.$handle.$name._index",{"_11":12,"_13":14,"_15":-7,"_16":-7,"_17":18,"_19":20,"_21":22,"_23":24,"_25":-7,"_26":-5,"_27":-5,"_28":29,"_30":31,"_32":-5,"_33":-5,"_34":35,"_36":35,"_37":38},"handle","vvampa","name","luke-headroom-dashboard","branchName","version","project",{"_39":78,"_13":14,"_50":79,"_80":-5,"_81":35,"_82":83,"_84":83,"_85":86,"_87":-5,"_88":89,"_90":43,"_91":38,"_92":-5,"_93":-5,"_94":67,"_95":96,"_97":98,"_99":100,"_101":102,"_103":-5,"_104":105,"_106":105,"_107":108,"_109":108,"_110":108,"_111":105,"_112":105,"_113":114,"_115":116,"_117":118,"_119":35},"tags",[],"counts",{"_66":67,"_68":69,"_70":67,"_71":72,"_73":74},"contents",[63],"readme","upstream","pull","files",[31],"preview",{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":38,"_50":51,"_16":52,"_53":54,"_55":56,"_57":35,"_58":-5,"_59":60,"_61":62},"ahead","behind","showHomeCustomizationHint",false,"showHTTPPreviewSettingsHint","hasHTTPFiles",true,"id","87b4ceb0-3752-4193-b046-2b3165d6a8dc","main.ts","fileId","a8a4fe36-7fa1-11f1-8949-1607ee4eb77e","parentId","branchId","25a12779-704b-4a0a-8f52-1d35eadf2dad","branchVersion",45,"latest","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","label","children",[],"path",[41],{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":38,"_50":64,"_16":52,"_53":54,"_55":56,"_57":35,"_58":-5,"_61":65},["D",1784136860717],[41],"pulls",0,"branches",1,"forks","envVars",{"_75":67,"_77":67},"connections",{"_75":67,"_76":67},"count","unfilledCount","emptyCount","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","orgId","4014c641-61ba-11f0-852d-15ceec715ebe","tursoName","788086adfd5c4531a0ee62069aac0cab","tursoHostname","788086adfd5c4531a0ee62069aac0cab-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789472446807],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_135":131},"org",{"_11":12,"_129":-5,"_130":131,"_88":89,"_132":133,"_134":35},"branch",{"_16":48,"_13":120,"_39":46,"_121":78,"_122":-5,"_123":-5,"_124":-5,"_125":-5,"_126":-5,"_127":14,"_128":12},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJ6dlV1b1h4VzRxbTBVblhueldOUjc4R3N1ViJ9","tier","free","canRestrictVals","profileImageUrl","","adoptOrgId",{"_39":78,"_13":14,"_50":162,"_80":-5,"_81":35,"_82":83,"_84":83,"_85":86,"_87":-5,"_88":89,"_90":43,"_91":38,"_92":-5,"_93":-5,"_94":67,"_95":96,"_97":98,"_99":100,"_101":163,"_103":-5,"_104":105,"_106":105,"_107":108,"_109":108,"_110":108,"_111":105,"_112":105,"_113":164,"_115":165,"_117":166,"_119":35},"tree",[159],[159],{"_66":67,"_68":69,"_70":67,"_71":157,"_73":158},[155],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":38,"_50":64,"_16":52,"_53":54,"_55":56,"_57":35,"_58":-5,"_61":156},[41],{"_75":67,"_77":67},{"_75":67,"_76":67},{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":38,"_50":51,"_16":52,"_53":54,"_55":56,"_57":35,"_58":-5,"_59":160,"_61":161},[],[41],["D",1784046691506],["D",1789472446807],{"_11":12,"_135":131},{"_11":12,"_129":-5,"_130":131,"_88":89,"_132":133,"_134":35},{"_16":48,"_13":120,"_39":46,"_121":78,"_122":-5,"_123":-5,"_124":-5,"_125":-5,"_126":-5,"_127":14,"_128":12},"ctx",{"_113":-5,"_152":200,"_201":202,"_203":204,"_205":35,"_206":35,"_207":35,"_208":38,"_209":-5,"_210":-7,"_211":-7,"_212":67,"_213":35,"_214":35,"_215":-5,"_216":35,"_217":35,"_218":35,"_219":-5},"ENV",{"_171":172,"_173":174,"_175":120,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199},"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"]