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",[118],"pulls",1,"forks","envVars",{"_140":54,"_142":54},"connections",{"_140":54,"_141":54},"count","unfilledCount","emptyCount",{"_20":117,"_13":118,"_119":48,"_120":-5,"_121":21,"_122":30,"_123":50,"_22":144,"_29":125,"_126":127,"_128":129,"_130":38,"_131":-5,"_145":146,"_93":147},["D",1784136860717],"children",[],[118],["D",1784046691506],["D",1789472446807],{"_11":12,"_91":87},{"_11":12,"_85":-5,"_86":87,"_45":46,"_88":89,"_90":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_80":-5,"_81":-5,"_82":-5,"_83":14,"_84":12},"ctx",{"_73":-5,"_113":186,"_187":188,"_189":190,"_191":38,"_192":38,"_193":38,"_194":50,"_195":-5,"_196":-7,"_197":-7,"_198":54,"_199":38,"_200":38,"_201":-5,"_202":38,"_203":38,"_204":38,"_205":-5},"ENV",{"_157":158,"_159":160,"_161":26,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185},"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"]

Branches1

Branches
1