[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_538":539,"_540":541},"routes/_app.x.$handle.$name",{"_106":105,"_32":46,"_115":92,"_27":116,"_13":14,"_117":-5,"_11":118,"_119":120,"_121":122,"_123":124,"_125":126,"_20":-5,"_127":128,"_129":130,"_131":25,"_132":133,"_134":61,"_135":-5,"_136":-5,"_137":138},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_32":46,"_39":47,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":56,"_18":57,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":65,"_66":67,"_68":69,"_70":71,"_72":73,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":85,"_86":87,"_88":89,"_90":25},"version",76,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":38,"_36":37,"_39":40,"_41":14,"_42":43,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",false,"deletedHere","path","inputs/github.ts","latestPath","fileId","fa7f3b30-808d-11f1-80cc-1607ee4eb77e","name","github.ts","fileType","script","content","// cron: poll for new github activity, add to db.\nimport { Octokit } from \"npm:octokit@5.0.5\";\nimport { getLead, insertPending } from \"../utils/db.ts\";\n\n// GitHub orgs we watch. Activity on these repos is what makes someone a lead.\nexport const WATCHED = [\"miracodeai\", \"dbprohq\"];\n\n// Our own team — never lead-scored. The maintainer check below catches\n// unlisted team accounts, but add known handles here.\nexport const EXCLUDE_USERS = new Set([\n \"JSMira\",\n \"jayhyp\",\n \"JackHyp\",\n \"coolio85\",\n \"modrink\",\n \"JDSmith97\",\n]);\n\nexport default async function (interval: Interval) {\n // First run looks back one hour; history was handled by the backlog report.\n const lastChecked = interval.lastRunAt ?? new Date(Date.now() - 60 * 60 * 1000);\n const octokit = new Octokit({ auth: Deno.env.get(\"GITHUB_TOKEN\") });\n\n const events = (await Promise.all(\n WATCHED.map((org) =>\n octokit.paginate(octokit.rest.activity.listPublicOrgEvents, { org, per_page: 100 })\n ),\n ))\n .flat()\n .filter((e: any) => new Date(e.created_at) > lastChecked)\n .filter((e: any) =>\n e.actor?.login && !e.actor.login.includes(\"[bot]\") && !EXCLUDE_USERS.has(e.actor.login)\n );\n\n const byActor = Map.groupBy(events, (e: any) => e.actor.login as string);\n console.log(`${events.length} new events from ${byActor.size} people`);\n\n for (const [login, actorEvents] of byActor) {\n if (await getLead(login)) continue; // already known — first contact is the signal\n\n const activity = actorEvents.map((e: any) => ({\n type: e.type,\n repo: e.repo?.name,\n when: e.created_at?.slice(0, 10),\n title: e.payload?.issue?.title ?? e.payload?.pull_request?.title ?? undefined,\n }));\n\n // Maintainer signals: merging others' PRs or pushing straight to the repo.\n // Probably a team account missing from EXCLUDE_USERS — ask, don't score.\n const looksLikeMaintainer = actorEvents.some((e: any) =>\n e.type === \"PushEvent\" ||\n (e.type === \"PullRequestEvent\" && e.payload?.action === \"closed\" &&\n e.payload?.pull_request?.merged &&\n e.payload?.pull_request?.user?.login !== login)\n );\n\n await insertPending(login, activity, {\n flagged: looksLikeMaintainer ? \"maintainer?\" : undefined,\n });\n console.log(`new: ${login}${looksLikeMaintainer ? \" (flagged maintainer?)\" : \"\"}`);\n }\n}\n","interval","createdAt",["D",1784148381651],"branchVersion","branchId","3707f499-097d-4e07-a507-b21e0bcfbbb0","id","1248533c-8cdc-4f42-9610-73e9cbc5e37d","dbpro-leads",["D",1783725503703],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","GitHub lead qualification for DB Pro / Mira","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/aeec28de-dccc-49ab-3dcc-66b67afd7700/square512?exp=1789552799&sig=a9e2a467aac99d969a899bc0138c7107ce19a2e1a56253a71fff803ad56883a6","a0bf3b31-15a5-4d5c-880e-4b1e22c9bc18","pinnedFileId","019f4e53-354b-724f-878e-e9177d5c065a","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","ba7bb5fb-1abb-4ffb-8f3d-7c244782e5f7","tursoName","1248533c8cdc4f42961073e9cbc5e37d","tursoHostname","1248533c8cdc4f42961073e9cbc5e37d-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789526460011],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_106":105,"_114":110},"org",{"_106":105,"_107":108,"_109":110,"_18":-5,"_111":112,"_113":61},"branch",{"_13":91,"_32":92,"_44":43,"_93":45,"_94":95,"_96":97,"_98":51,"_99":100,"_101":102,"_103":46,"_104":105},"isOwned",166,"main","projectId","forkedBranchId","2beae49c-ed74-11f0-997b-42dde27851f2","forkedBranchVersion",144,"forkedProjectPrivacy","forkedProjectId","2be6e306-ed74-11f0-997b-42dde27851f2","forkedProjectOrgId","019aa807-52c2-709c-928b-2029bae9a558","projectName","userHandle","valdottown","handle","displayName","Val Town ","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJyWnQ5cFE0c3pleVRCSEVTWmxzaXJsTUlGciJ9","tier","business","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_44":45,"_32":46,"_39":533,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":56,"_18":57,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":65,"_66":67,"_68":69,"_70":71,"_72":534,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":535,"_86":536,"_88":537,"_90":25},"tree",[273,279,288,290,297,300,303,305,306,307,308,309,310,311],"files",[273,274,275,276,277,278,279,280,281,282,283,284,285,286,287,288,289,290,291,292,293,294,295,296,297,298,299,300,301,302,303,304,305,306,307,308,309,310,311],"counts",{"_263":65,"_264":181,"_265":65,"_266":267,"_268":269},"contents",[152,153,154,155,156,157,158,159,160,161,162,163,164,165],"upstreamProject",{"_44":100,"_32":148,"_53":149,"_55":56,"_50":51,"_84":150},"upstreamBranch",{"_44":95,"_39":139,"_140":141,"_32":92,"_93":100,"_13":142,"_94":143,"_96":144,"_145":146,"_48":-5,"_90":25,"_50":51,"_104":147,"_66":102,"_103":148},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1767974365657],"updatedAt",["D",1783726173324],146,"6b736e3c-daf9-11f0-9e58-42dde27851f2",138,"lockfileKey","1783726173402-esm.town_v_templates_github-leads@146-main","templates","github-leads","Find customers to sell to from GitHub activity",{"_106":147,"_114":151},"https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789552799&sig=d49f90d93e120483cdf15d03d3545ffc812712f79bb9ed726650e50aa3216f06",{"_44":258,"_32":259,"_30":260,"_169":-5,"_42":43,"_41":181,"_171":25,"_39":261,"_13":65,"_34":228,"_36":-5,"_24":25,"_175":-5,"_27":262},{"_44":253,"_32":254,"_30":255,"_169":-5,"_42":43,"_41":181,"_171":25,"_39":256,"_13":65,"_34":228,"_36":-5,"_24":25,"_175":-5,"_27":257},{"_44":247,"_32":248,"_30":249,"_169":-5,"_42":43,"_41":250,"_171":61,"_39":251,"_13":65,"_34":228,"_36":-5,"_24":25,"_175":-5,"_27":252},{"_44":241,"_32":242,"_30":243,"_169":-5,"_42":43,"_41":244,"_171":61,"_39":245,"_13":65,"_34":228,"_36":-5,"_24":25,"_175":-5,"_27":246},{"_44":235,"_32":236,"_30":237,"_169":-5,"_42":43,"_41":238,"_171":61,"_39":239,"_13":65,"_34":228,"_36":-5,"_24":25,"_175":-5,"_27":240},{"_44":230,"_32":231,"_30":232,"_169":-5,"_42":43,"_41":181,"_171":25,"_39":233,"_13":65,"_34":228,"_36":-5,"_24":25,"_175":-5,"_27":234},{"_44":223,"_32":224,"_30":225,"_169":-5,"_42":43,"_41":226,"_171":61,"_39":227,"_13":65,"_34":228,"_36":-5,"_24":25,"_175":-5,"_27":229},{"_44":216,"_32":217,"_30":218,"_169":-5,"_42":43,"_41":219,"_171":25,"_39":220,"_13":181,"_34":20,"_36":221,"_24":25,"_175":-5,"_27":222},{"_44":208,"_32":209,"_30":210,"_169":-5,"_42":43,"_41":211,"_171":25,"_39":212,"_13":213,"_34":20,"_36":214,"_24":25,"_175":-5,"_27":215},{"_44":200,"_32":201,"_30":202,"_169":-5,"_42":43,"_41":203,"_171":25,"_39":204,"_13":205,"_34":38,"_36":206,"_24":25,"_175":-5,"_27":207},{"_44":192,"_32":193,"_30":194,"_169":-5,"_42":43,"_41":195,"_171":25,"_39":196,"_13":197,"_34":182,"_36":198,"_24":25,"_175":-5,"_27":199},{"_44":185,"_32":186,"_30":187,"_169":-5,"_42":43,"_41":188,"_171":25,"_39":189,"_13":65,"_34":38,"_36":190,"_24":25,"_175":-5,"_27":191},{"_44":177,"_32":178,"_30":59,"_169":-5,"_42":43,"_41":179,"_171":61,"_39":180,"_13":181,"_34":182,"_36":183,"_24":25,"_175":-5,"_27":184},{"_44":166,"_32":167,"_30":168,"_169":-5,"_42":43,"_41":170,"_171":25,"_39":172,"_13":173,"_34":35,"_36":174,"_24":25,"_175":-5,"_27":176},"2a4695c6-58b8-4747-b02d-6365bb6e26b9","scratch-nycjay.ts","8b3f585a-7ef7-11f1-8ff8-1607ee4eb77e","parentId",58,"latest",["D",1784142326345],22,"// Scratch runner chunk 9/9 FINAL — 12 people, full parallel. DELETE WHEN DONE.\nimport pAll from \"npm:p-all\";\nimport sqlite from \"https://esm.town/v/std/db/main.ts\";\nconst ENDPOINT = \"https://stevekrouse--330a25c07efc11f18acc1607ee4eb77e.web.val.run\";\nconst CASES = [{\"github_username\": \"xiy\", \"activity\": [{\"type\": \"starred\", \"repo\": \"miracodeai/mira\", \"when\": \"2026-07-06\"}], \"email\": \"xiy3x0@gmail.com\"}, {\"github_username\": \"yannicka\", \"activity\": [{\"type\": \"starred\", \"repo\": \"miracodeai/mira\", \"when\": \"2026-06-18\"}], \"email\": \"yannick.armand@gmail.com\"}, {\"github_username\": \"yasingedik\", \"activity\": [{\"type\": \"starred\", \"repo\": \"miracodeai/mira\", \"when\": \"2026-06-30\"}]}, {\"github_username\": \"yellowsnow3\", \"activity\": [{\"type\": \"starred\", \"repo\": \"miracodeai/mira\", \"when\": \"2026-05-26\"}], \"email\": \"totallynotlegal@gmail.com\"}, {\"github_username\": \"yermakoffivan\", \"activity\": [{\"type\": \"starred\", \"repo\": \"miracodeai/mira\", \"when\": \"2026-06-19\"}]}, {\"github_username\": \"yodancristino\", \"activity\": [{\"type\": \"starred\", \"repo\": \"miracodeai/mira\", \"when\": \"2026-06-19\"}]}, {\"github_username\": \"youngsun45\", \"activity\": [{\"type\": \"starred\", \"repo\": \"dbprohq/db-pro\", \"when\": \"2026-05-28\"}], \"email\": \"youngsun45@gmail.com\"}, {\"github_username\": \"yumosx\", \"activity\": [{\"type\": \"starred\", \"repo\": \"miracodeai/mira\", \"when\": \"2026-06-20\"}], \"email\": \"zhengel2022@163.com\"}, {\"github_username\": \"yusufumac\", \"activity\": [{\"type\": \"starred\", \"repo\": \"miracodeai/mira\", \"when\": \"2026-07-02\"}], \"email\": \"yusufumac@gmail.com\"}, {\"github_username\": \"zHalfinity\", \"activity\": [{\"type\": \"starred\", \"repo\": \"miracodeai/mira\", \"when\": \"2026-06-19\"}]}, {\"github_username\": \"zaaakher\", \"activity\": [{\"type\": \"starred\", \"repo\": \"miracodeai/mira\", \"when\": \"2026-07-04\"}], \"email\": \"zakhermasri@gmail.com\"}, {\"github_username\": \"zantak\", \"activity\": [{\"type\": \"starred\", \"repo\": \"miracodeai/mira\", \"when\": \"2026-06-19\"}]}];\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS report_cards (login TEXT PRIMARY KEY, verdict TEXT, card TEXT, ms INTEGER, error TEXT, created_at INTEGER)`);\n\nconst existing = new Set(\n (await sqlite.execute(`SELECT login FROM report_cards`)).rows.map((r: any) => r.login ?? r[0]),\n);\nconst todo = CASES.filter((c) => !existing.has(c.github_username));\nconsole.log(`running ${todo.length}/${CASES.length}`);\n\nconst t0 = Date.now();\nconst results = await pAll(\n todo.map((c) => async () => {\n const start = Date.now();\n let row;\n try {\n const res = await fetch(ENDPOINT, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\", \"x-debug-token\": Deno.env.get(\"DEBUG_TOKEN\")! },\n body: JSON.stringify(c),\n });\n const data = await res.json();\n row = { login: c.github_username, verdict: data.verdict, card: data.card, ms: Date.now() - start, error: data.error ?? null };\n } catch (e) {\n row = { login: c.github_username, verdict: null, card: null, ms: Date.now() - start, error: String(e) };\n }\n await sqlite.execute(\n `INSERT OR REPLACE INTO report_cards (login, verdict, card, ms, error, created_at) VALUES (?, ?, ?, ?, ?, ?)`,\n [row.login, row.verdict ?? null, row.card ?? null, row.ms ?? null, row.error ?? null, Date.now()],\n );\n console.log(`done: ${row.login} -> ${row.verdict ?? \"ERR\"} (${Math.round(row.ms / 1000)}s)`);\n return row;\n }),\n { concurrency: 12 },\n);\nconst tally = {};\nfor (const r of results) tally[r.verdict ?? \"ERROR\"] = (tally[r.verdict ?? \"ERROR\"] ?? 0) + 1;\nconsole.log(`TALLY chunk 9: ${JSON.stringify(tally)} — wall ${Math.round((Date.now() - t0) / 1000)}s`);\n","label",[167],"cb7ac0dc-3fb4-4c02-a9cb-9ecb78681cc9","main.ts",75,["D",1784148366847],1,"http","// http: entrypoint — the dashboard, wrapped in Val Town OAuth.\nimport { oauthMiddleware } from \"https://esm.town/v/std/oauth/middleware.ts\";\nimport app from \"./outputs/dashboard/server.ts\";\n\nexport default oauthMiddleware(app.fetch);\n",[178],"a89db194-f4eb-45eb-adbf-031e09a2b7fc","github.cron.ts","fd4fa288-7ee8-11f1-8177-1607ee4eb77e",31,["D",1783967457164],"import { Octokit } from \"npm:octokit@5.0.5\";\nimport { processLead } from \"./backend/agent.ts\";\nimport { appendFollowup, createProcessingLead, findLeadByGithubUsername } from \"./backend/db.ts\";\nimport { EXCLUDE_USERS, WATCHED } from \"./shared/config.ts\";\n\n// Hourly sweep of each watched org's public events (stars, forks, issues,\n// PRs). Each new person becomes a lead run through the same scoring pipeline\n// as webhook submissions; repeat activity appends to their existing lead.\n// Note: GitHub's Events API only returns the ~300 most recent events per org.\nexport default async function (interval: Interval) {\n // First run: only look back an hour (history is the backfill's job) —\n // otherwise we'd score all ~300 events GitHub returns in one burst.\n const lastChecked = interval.lastRunAt ?? new Date(Date.now() - 60 * 60 * 1000);\n const octokit = new Octokit({ auth: Deno.env.get(\"GITHUB_TOKEN\") });\n // Lets the agent (and a human reading the lead) see how we relate to each org.\n const watched = Object.fromEntries(WATCHED.map((w) => [w.org, w.relationship]));\n\n const newEvents = (await Promise.all(\n WATCHED.map(({ org }) =>\n octokit.paginate(octokit.rest.activity.listPublicOrgEvents, { org, per_page: 100 })\n ),\n ))\n .flat()\n .filter((e: any) => new Date(e.created_at) > lastChecked)\n .filter((e: any) => e.actor?.login && !e.actor.login.includes(\"[bot]\") && !EXCLUDE_USERS.has(e.actor.login));\n\n const actorEvents = Map.groupBy(newEvents, (e: any) => e.actor.login);\n console.log(`${newEvents.length} new events from ${actorEvents.size} users`);\n\n // Process serially so a burst of new people doesn't blow past the interval\n // time budget / OpenAI rate limits.\n for (const [login, events] of actorEvents) {\n const existing = await findLeadByGithubUsername(login);\n if (existing) {\n await appendFollowup(existing.id, events);\n continue;\n }\n // github_username keys Clay enrichment and dedupe on later sweeps;\n // events carry the GitHub activity for the agent to research.\n const inputData = { github_username: login, events, watched };\n const leadId = await createProcessingLead(inputData);\n await processLead(leadId, inputData);\n }\n}\n",[186],"4c89a1ac-e364-48c0-acd5-7cc645c0a4c8","card-test.http.ts","330a25c0-7efc-11f1-8acc-1607ee4eb77e",41,["D",1783979628389],2,"// Card endpoint: github handle + activity (+ optional email) in → markdown lead card out.\n// gpt-5 + web_search does research and writes the card. No db, no Slack.\n// For the future Slack sender: npm:slackify-markdown converts md → Slack mrkdwn.\n//\n// POST / with header x-debug-token: $DEBUG_TOKEN\n// body: { github_username: string, activity: [{ type, repo, when?, title? }], email?: string }\n\nimport OpenAI from \"npm:openai\";\n\nconst openai = new OpenAI({ apiKey: Deno.env.get(\"OPENAI_API_KEY\") });\n\nconst PROMPT = `You do lead enrichment and qualification for people who interact with Mira's GitHub repos. Mira (miracode.ai) is a self-hosted, BYOK AI code reviewer — code never leaves your infra, you pick the model, no per-seat pricing.\n\nInput: a GitHub username, their activity on our repos (dates, issue/PR titles), sometimes an email. Research them: GitHub, LinkedIn, personal sites, their company.\n\nThe best leads work at companies where self-hosting matters (regulated, European, on-prem), with a real engineering team, and personally are senior enough to champion tools, and show real usage (issues/PRs > stars). Students, bots, drive-by stars are not leads.\n\nNever invent a company, title, or email — null out and downgrade the verdict instead.\n\nReply in markdown as follows:\n\nVerdict: MESSAGE | WATCH | IGNORE | NEEDS_ID (MESSAGE = a founder should DM them this week; NEEDS_ID = hot activity, unknown person)\nName — title, company (~size)\nWhy: 2–3 sentences, concrete evidence, where facts came from.\nOpener: one line, founder-to-user: reference their specific activity, thank contributors, ask a real question about their setup. Never salesy, never flattery.\nLinks: github · linkedin · company · email`;\n\n// Models sometimes wrap output in ``` fences — strip them if present, pass through if not.\nexport function stripFences(text: string): string {\n const m = text.trim().match(/^```(?:markdown|md)?\\s*\\n([\\s\\S]*?)\\n?```$/);\n return (m ? m[1] : text).trim();\n}\n\nexport function parseVerdict(markdown: string): string | null {\n return markdown.match(/^Verdict:\\s*(MESSAGE|WATCH|IGNORE|NEEDS_ID)/im)?.[1] ?? null;\n}\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") {\n return Response.json({ usage: \"POST { github_username, activity, email? }\" }, { status: 405 });\n }\n if (req.headers.get(\"x-debug-token\") !== Deno.env.get(\"DEBUG_TOKEN\")) {\n return Response.json({ error: \"bad token\" }, { status: 401 });\n }\n\n const { github_username, activity, email } = await req.json();\n const t0 = Date.now();\n\n const response = await openai.responses.create({\n model: \"gpt-5\",\n tools: [{ type: \"web_search\" }],\n instructions: PROMPT,\n input: JSON.stringify({ github_username, activity, ...(email && { email }) }),\n });\n if (response.status !== \"completed\") {\n return Response.json({ error: `model ${response.status}` }, { status: 502 });\n }\n\n const card = stripFences(response.output_text);\n return Response.json({\n verdict: parseVerdict(card),\n card,\n timing_ms: Date.now() - t0,\n });\n}\n",[193],"216106b8-785f-4fe8-bf1c-f24d1e5489b1","backfill.cron.ts","d3e24782-7cb5-11f1-8fae-1607ee4eb77e",28,["D",1783967446687],8,"import sqlite from \"https://esm.town/v/std/db/main.ts\";\nimport { Octokit } from \"npm:octokit@5.0.5\";\nimport { processLead } from \"./backend/agent.ts\";\nimport { createProcessingLead, findLeadByGithubUsername } from \"./backend/db.ts\";\nimport { EXCLUDE_USERS, WATCHED } from \"./shared/config.ts\";\n\n// ── One-time backfill ──\n// Everyone who has ever starred, forked, or opened an issue/PR on our repos.\n// The first run builds the queue; each run after scores a few people until\n// the queue is empty. DELETE THIS FILE once it logs \"backfill done\".\nconst REPOS = [\"dbprohq/db-pro\", \"dbprohq/hypership\", \"miracodeai/mira\"];\nconst BATCH = 2; // scored in parallel each run (kept small so a tick fits the interval time budget)\n\nawait sqlite.execute(\n `CREATE TABLE IF NOT EXISTS backfill_queue (login TEXT PRIMARY KEY, activity TEXT NOT NULL)`,\n);\n\nfunction rowField(row: unknown, index: number, name: string): unknown {\n if (Array.isArray(row)) return row[index];\n if (row && typeof row === \"object\") {\n const obj = row as Record;\n return obj[name] ?? obj[String(index)];\n }\n return undefined;\n}\n\nasync function seedQueue() {\n const octokit = new Octokit({ auth: Deno.env.get(\"GITHUB_TOKEN\") });\n const byLogin: Record = {};\n const add = (login: string | undefined, type: string, repo: string) => {\n if (!login || login.includes(\"[bot]\") || EXCLUDE_USERS.has(login)) return;\n (byLogin[login] ??= []).push({ type, repo });\n };\n // GitHub blocks some listings per-repo (their stargazer lists 404/403 even\n // authenticated) — take what each repo gives us and log what it doesn't.\n const tryList = async (label: string, repo: string, fn: () => Promise) => {\n try {\n await fn();\n } catch (err) {\n console.log(`${repo} ${label} unavailable: ${err.message ?? err}`);\n }\n };\n\n for (const repo of REPOS) {\n const [owner, name] = repo.split(\"/\");\n const opts = { owner, repo: name, per_page: 100 };\n await tryList(\"stargazers\", repo, async () => {\n for (const s of await octokit.paginate(octokit.rest.activity.listStargazersForRepo, opts)) {\n add(s.login, \"starred\", repo);\n }\n });\n await tryList(\"forks\", repo, async () => {\n for (const f of await octokit.paginate(octokit.rest.repos.listForks, opts)) {\n add(f.owner?.login, \"forked\", repo);\n }\n });\n await tryList(\"issues\", repo, async () => {\n for (const i of await octokit.paginate(octokit.rest.issues.listForRepo, { ...opts, state: \"all\" })) {\n add(i.user?.login, i.pull_request ? \"opened PR\" : \"opened issue\", repo);\n }\n });\n }\n\n for (const [login, activity] of Object.entries(byLogin)) {\n await sqlite.execute(\n `INSERT OR REPLACE INTO backfill_queue (login, activity) VALUES (?, ?)`,\n [login, JSON.stringify(activity)],\n );\n }\n await sqlite.execute(\n `INSERT OR REPLACE INTO backfill_queue (login, activity) VALUES ('__seeded__', '[]')`,\n );\n console.log(`backfill queue seeded: ${Object.keys(byLogin).length} people`);\n}\n\nexport default async function (interval: Interval) {\n const seeded = await sqlite.execute(\n `SELECT 1 FROM backfill_queue WHERE login = '__seeded__'`,\n );\n // Seeding paginates GitHub across every repo — on its own that can eat most\n // of a tick's time budget, so seed and return. The next tick starts scoring.\n if (seeded.rows.length === 0) {\n await seedQueue();\n return { seeded: true };\n }\n\n const next = await sqlite.execute(\n `SELECT login, activity FROM backfill_queue WHERE login != '__seeded__' LIMIT ?`,\n [BATCH],\n );\n if (next.rows.length === 0) {\n console.log(\"backfill done — this file can be deleted\");\n return { done: true };\n }\n\n const watched = Object.fromEntries(WATCHED.map((w) => [w.org, w.relationship]));\n const results = await Promise.all(\n next.rows.map(async (row) => {\n const login = String(rowField(row, 0, \"login\") ?? \"\");\n const activityJson = String(rowField(row, 1, \"activity\") ?? \"[]\");\n if (!login) return { login: \"(missing)\", error: \"empty login from queue row\" };\n // Dequeue first: if scoring fails, the lead row records the error and\n // one bad entry can never wedge the queue.\n await sqlite.execute(`DELETE FROM backfill_queue WHERE login = ?`, [login]);\n if (await findLeadByGithubUsername(login)) return { login, skipped: true };\n const inputData = { github_username: login, backfill: JSON.parse(activityJson), watched };\n const leadId = await createProcessingLead(inputData);\n try {\n await processLead(leadId, inputData);\n return { login, leadId, ok: true };\n } catch (err) {\n return { login, leadId, error: String(err) };\n }\n }),\n );\n\n const remaining = await sqlite.execute(\n `SELECT COUNT(*) AS n FROM backfill_queue WHERE login != '__seeded__'`,\n );\n const remainingCount = Number(rowField(remaining.rows[0], 0, \"n\") ?? 0);\n console.log(`backfilled ${results.length}, ${remainingCount} remaining`, JSON.stringify(results));\n return { results, remaining: remainingCount };\n}\n",[201],"d291a29a-7bcd-4425-a86f-b38a4f455a5c","README.md","019f4e53-354b-724f-878e-e330fea73434",60,["D",1784147394736],4,"# GitHub Leads\n\nWatches Mira's GitHub. When someone new stars, forks, or opens an issue, AI\nresearches who they are — name, company, size — and writes a lead card with a\nsuggested opener. Qualified leads ping Slack.\n\n```mermaid\nflowchart LR\n A[\"inputs/github.ts\"] --> B[(\"leads\")]\n B --> C[\"processing/qualify.ts\"]\n C --> B\n B --> D[\"outputs/slack.ts\"]\n B --> E[\"outputs/dashboard\"]\n```\n\n## Customizing\n\n| to change... | edit... |\n| ------------------------- | ------------------------------------------------- |\n| who counts as a good lead | [processing/PROMPT.md](./processing/PROMPT.md) |\n| which repos we watch | the top of [inputs/github.ts](./inputs/github.ts) |\n| where leads go | add a file to [outputs/](./outputs/) |\n| where leads come from | add a file to [inputs/](./inputs/) |\n\n## Environment variables\n\n- **`GITHUB_TOKEN`** (required) — polls the watched repos' public activity.\n [Create one here](https://github.com/settings/tokens) with **no scopes** — it\n only reads public data, but without it GitHub's per-IP rate limits make\n polling from Val Town's shared IPs unreliable.\n [Set it](/environment-variables?key=GITHUB_TOKEN)\n- **`OPENAI_API_KEY`** (required) — powers the research and card writing (gpt-5\n with web search). [Get a key](https://platform.openai.com/api-keys), then\n [set it](/environment-variables?key=OPENAI_API_KEY). Each lead costs roughly\n $0.05.\n- **`SLACK_WEBHOOK_URL`** (optional) — qualified-lead pings. Without it, leads\n still land in the dashboard, just no notifications.\n [Create an incoming webhook](https://docs.val.town/guides/slack/send-messages-to-slack/),\n then [set it](/environment-variables?key=SLACK_WEBHOOK_URL)",[209],"4d658ea4-8dd9-4dad-8bb9-f6d6db235f56","PROMPT.md","019f4e53-354b-724f-878e-de4d1c0aa32b",3,["D",1783725556679],"You are a lead qualification researcher for DB Pro (dbpro.app) and Mira (miracode.ai).\n\nDB Pro is a modern database client — desktop app, collaborative web platform, and built-in AI. Mira is a self-hosted, BYOK AI code reviewer. Both are sold to software teams.\n\nI'm sending you data about a lead — usually a GitHub user and their activity (stars, forks, issues, PRs) on our repos. Exhaustively research the person: their GitHub profile and repos, linked personal and company sites, LinkedIn, blogs. We especially care how big their company is — find the company name, domain, and rough size or funding, and include them in your reasoning.\n\nThe lead may include a `watched` field describing our relationship to each org they were active in (e.g. \"our repos\" vs \"competitor's repos\"). Activity on our own repos is a much hotter signal than activity on a competitor's — weigh it accordingly, and say in your reasoning where the lead came from.\n\nIdeal customer profile:\n\n1. Professional software engineer, data engineer, or engineering leader — not a student or hobbyist\n2. Works at a company with a real engineering team; the bigger the company, the better\n3. In a position to buy or champion developer tools (senior, lead, manager, or founder)\n4. Works with databases day-to-day, or owns code review / PR workflows\n\nHow to score:\n\n- 80-100: strong fit, meets nearly all of the criteria\n- 50-79: partial fit, meets some of the criteria\n- 0-49: weak fit, meets few or none of the criteria\n\nReturn your final response in JSON only with the following schema. Keep these exact fields even after you change the criteria above:\n\n{\n \"name\": string,\n \"company\": string,\n \"score\": integer from 0 to 100,\n \"reasoning\": string\n}\n",[217],"319c428c-c8b0-4785-acdf-41faa385294a","utils","d3b96674-808d-11f1-a2d7-1607ee4eb77e",64,["D",1784148205583],"directory",[224],"63665ad5-7dc7-479b-b2fe-d8168e44182b","shared","019f4e53-354b-724f-878e-d9f9de0d3c67",["D",1783725503703],[231],"97ff939e-0e50-48e9-92b2-e1b330d488a3","processing","d2df6c9e-808d-11f1-978e-1607ee4eb77e",62,["D",1784148204143],[236],"239f795e-2e46-4c93-aee0-2b877abd7c36","outputs","d352efc0-808d-11f1-96e7-1607ee4eb77e",63,["D",1784148204925],[242],"a9ae1a9b-3628-4c21-b06f-02f2e1b999e0","inputs","d292f7ec-808d-11f1-8cb9-1607ee4eb77e",61,["D",1784148203624],[248],"40906d12-a9ec-4c9a-9826-65891e5764da","frontend","019f4e53-354b-724f-878e-d1b873bb8e72",["D",1783725503703],[254],"21e2f7d9-0c78-407f-bbdf-972ab523f472","backend","019f4e53-354b-724f-878e-acd986d56452",["D",1783725503703],[259],"pulls","branches","forks","envVars",{"_270":219,"_272":65},"connections",{"_270":181,"_271":65},"count","unfilledCount","emptyCount",{"_44":258,"_32":259,"_30":260,"_169":-5,"_42":43,"_41":181,"_171":25,"_39":530,"_13":65,"_34":228,"_36":-5,"_24":25,"_175":-5,"_313":531,"_27":532},{"_44":523,"_32":524,"_30":525,"_169":260,"_42":43,"_41":181,"_171":25,"_39":526,"_13":65,"_34":35,"_36":527,"_24":25,"_175":-5,"_313":528,"_27":529},{"_44":516,"_32":408,"_30":517,"_169":260,"_42":43,"_41":518,"_171":25,"_39":519,"_13":197,"_34":35,"_36":520,"_24":25,"_175":-5,"_313":521,"_27":522},{"_44":510,"_32":335,"_30":511,"_169":260,"_42":43,"_41":181,"_171":25,"_39":512,"_13":65,"_34":35,"_36":513,"_24":25,"_175":-5,"_313":514,"_27":515},{"_44":502,"_32":503,"_30":504,"_169":260,"_42":43,"_41":505,"_171":25,"_39":506,"_13":219,"_34":35,"_36":507,"_24":25,"_175":-5,"_313":508,"_27":509},{"_44":495,"_32":496,"_30":497,"_169":260,"_42":43,"_41":181,"_171":25,"_39":498,"_13":65,"_34":35,"_36":499,"_24":25,"_175":-5,"_313":500,"_27":501},{"_44":253,"_32":254,"_30":255,"_169":-5,"_42":43,"_41":181,"_171":25,"_39":492,"_13":65,"_34":228,"_36":-5,"_24":25,"_175":-5,"_313":493,"_27":494},{"_44":488,"_32":459,"_30":454,"_169":255,"_42":43,"_41":181,"_171":25,"_39":489,"_13":65,"_34":228,"_36":-5,"_24":25,"_175":-5,"_313":490,"_27":491},{"_44":481,"_32":482,"_30":483,"_169":454,"_42":43,"_41":181,"_171":25,"_39":484,"_13":65,"_34":35,"_36":485,"_24":25,"_175":-5,"_313":486,"_27":487},{"_44":474,"_32":475,"_30":476,"_169":454,"_42":43,"_41":181,"_171":25,"_39":477,"_13":65,"_34":35,"_36":478,"_24":25,"_175":-5,"_313":479,"_27":480},{"_44":467,"_32":468,"_30":469,"_169":454,"_42":43,"_41":181,"_171":25,"_39":470,"_13":65,"_34":35,"_36":471,"_24":25,"_175":-5,"_313":472,"_27":473},{"_44":460,"_32":461,"_30":462,"_169":454,"_42":43,"_41":181,"_171":25,"_39":463,"_13":65,"_34":35,"_36":464,"_24":25,"_175":-5,"_313":465,"_27":466},{"_44":451,"_32":452,"_30":453,"_169":454,"_42":43,"_41":181,"_171":25,"_39":455,"_13":65,"_34":35,"_36":456,"_24":25,"_175":-5,"_313":457,"_27":458},{"_44":445,"_32":400,"_30":446,"_169":255,"_42":43,"_41":181,"_171":25,"_39":447,"_13":65,"_34":20,"_36":448,"_24":25,"_175":-5,"_313":449,"_27":450},{"_44":438,"_32":439,"_30":440,"_169":255,"_42":43,"_41":181,"_171":25,"_39":441,"_13":65,"_34":35,"_36":442,"_24":25,"_175":-5,"_313":443,"_27":444},{"_44":247,"_32":248,"_30":249,"_169":-5,"_42":43,"_41":250,"_171":61,"_39":435,"_13":65,"_34":228,"_36":-5,"_24":25,"_175":-5,"_313":436,"_27":437},{"_44":431,"_32":33,"_30":31,"_169":249,"_42":43,"_41":14,"_171":61,"_39":432,"_13":181,"_34":38,"_36":37,"_24":25,"_175":-5,"_313":433,"_27":434},{"_44":241,"_32":242,"_30":243,"_169":-5,"_42":43,"_41":244,"_171":61,"_39":428,"_13":65,"_34":228,"_36":-5,"_24":25,"_175":-5,"_313":429,"_27":430},{"_44":423,"_32":398,"_30":392,"_169":243,"_42":43,"_41":424,"_171":61,"_39":425,"_13":65,"_34":228,"_36":-5,"_24":25,"_175":-5,"_313":426,"_27":427},{"_44":415,"_32":416,"_30":417,"_169":392,"_42":43,"_41":418,"_171":25,"_39":419,"_13":65,"_34":35,"_36":420,"_24":25,"_175":-5,"_313":421,"_27":422},{"_44":407,"_32":408,"_30":409,"_169":392,"_42":43,"_41":410,"_171":25,"_39":411,"_13":65,"_34":35,"_36":412,"_24":25,"_175":-5,"_313":413,"_27":414},{"_44":399,"_32":400,"_30":401,"_169":392,"_42":43,"_41":402,"_171":25,"_39":403,"_13":65,"_34":20,"_36":404,"_24":25,"_175":-5,"_313":405,"_27":406},{"_44":389,"_32":390,"_30":391,"_169":392,"_42":43,"_41":393,"_171":25,"_39":394,"_13":65,"_34":35,"_36":395,"_24":25,"_175":-5,"_313":396,"_27":397},{"_44":381,"_32":382,"_30":383,"_169":243,"_42":43,"_41":384,"_171":25,"_39":385,"_13":65,"_34":35,"_36":386,"_24":25,"_175":-5,"_313":387,"_27":388},{"_44":235,"_32":236,"_30":237,"_169":-5,"_42":43,"_41":238,"_171":61,"_39":378,"_13":65,"_34":228,"_36":-5,"_24":25,"_175":-5,"_313":379,"_27":380},{"_44":371,"_32":217,"_30":372,"_169":237,"_42":43,"_41":373,"_171":25,"_39":374,"_13":65,"_34":20,"_36":375,"_24":25,"_175":-5,"_313":376,"_27":377},{"_44":363,"_32":364,"_30":365,"_169":237,"_42":43,"_41":366,"_171":25,"_39":367,"_13":65,"_34":35,"_36":368,"_24":25,"_175":-5,"_313":369,"_27":370},{"_44":230,"_32":231,"_30":232,"_169":-5,"_42":43,"_41":181,"_171":25,"_39":360,"_13":65,"_34":228,"_36":-5,"_24":25,"_175":-5,"_313":361,"_27":362},{"_44":352,"_32":353,"_30":354,"_169":232,"_42":43,"_41":355,"_171":25,"_39":356,"_13":65,"_34":35,"_36":357,"_24":25,"_175":-5,"_313":358,"_27":359},{"_44":345,"_32":346,"_30":347,"_169":232,"_42":43,"_41":181,"_171":25,"_39":348,"_13":65,"_34":35,"_36":349,"_24":25,"_175":-5,"_313":350,"_27":351},{"_44":223,"_32":224,"_30":225,"_169":-5,"_42":43,"_41":226,"_171":61,"_39":342,"_13":65,"_34":228,"_36":-5,"_24":25,"_175":-5,"_313":343,"_27":344},{"_44":334,"_32":335,"_30":336,"_169":225,"_42":43,"_41":337,"_171":25,"_39":338,"_13":65,"_34":35,"_36":339,"_24":25,"_175":-5,"_313":340,"_27":341},{"_44":216,"_32":217,"_30":218,"_169":-5,"_42":43,"_41":219,"_171":25,"_39":331,"_13":181,"_34":20,"_36":221,"_24":25,"_175":-5,"_313":332,"_27":333},{"_44":208,"_32":209,"_30":210,"_169":-5,"_42":43,"_41":211,"_171":25,"_39":328,"_13":213,"_34":20,"_36":214,"_24":25,"_175":-5,"_313":329,"_27":330},{"_44":200,"_32":201,"_30":202,"_169":-5,"_42":43,"_41":203,"_171":25,"_39":325,"_13":205,"_34":38,"_36":206,"_24":25,"_175":-5,"_313":326,"_27":327},{"_44":192,"_32":193,"_30":194,"_169":-5,"_42":43,"_41":195,"_171":25,"_39":322,"_13":197,"_34":182,"_36":198,"_24":25,"_175":-5,"_313":323,"_27":324},{"_44":185,"_32":186,"_30":187,"_169":-5,"_42":43,"_41":188,"_171":25,"_39":319,"_13":65,"_34":38,"_36":190,"_24":25,"_175":-5,"_313":320,"_27":321},{"_44":177,"_32":178,"_30":59,"_169":-5,"_42":43,"_41":179,"_171":61,"_39":316,"_13":181,"_34":182,"_36":183,"_24":25,"_175":-5,"_313":317,"_27":318},{"_44":166,"_32":167,"_30":168,"_169":-5,"_42":43,"_41":170,"_171":25,"_39":312,"_13":173,"_34":35,"_36":174,"_24":25,"_175":-5,"_313":314,"_27":315},["D",1784142326345],"children",[],[167],["D",1784148366847],[],[178],["D",1783967457164],[],[186],["D",1783979628389],[],[193],["D",1783967446687],[],[201],["D",1784147394736],[],[209],["D",1783725556679],[],[217],"0ab91abd-2b7f-47ad-af7e-2f7da2ef9a59","db.ts","e0a0b13a-808d-11f1-8fff-1607ee4eb77e",65,["D",1784148227242],"// The leads table: every person who ever touched the watched repos, and\n// where they are in the pipeline (pending → done/error).\nimport sqlite from \"https://esm.town/v/std/db/main.ts\";\n\n// TODO(steve): rename to \"leads\" once the old leads table is deleted.\nconst TABLE = \"leads_v2\";\n\nexport interface LeadRow {\n login: string;\n activity: string | null; // JSON: [{ type, repo, when?, title? }]\n email: string | null;\n status: \"pending\" | \"scoring\" | \"done\" | \"error\";\n verdict: \"MESSAGE\" | \"WATCH\" | \"IGNORE\" | \"NEEDS_ID\" | null;\n card: string | null; // markdown lead card\n error: string | null;\n flagged: string | null; // e.g. \"maintainer?\" — needs a human look, not scoring\n created_at: number;\n scored_at: number | null;\n notified_at: number | null;\n}\n\nawait sqlite.execute(\n `CREATE TABLE IF NOT EXISTS ${TABLE} (\n login TEXT PRIMARY KEY,\n activity TEXT,\n email TEXT,\n status TEXT NOT NULL DEFAULT 'pending',\n verdict TEXT,\n card TEXT,\n error TEXT,\n flagged TEXT,\n created_at INTEGER,\n scored_at INTEGER,\n notified_at INTEGER\n )`,\n);\n\n// New person enters the pipeline. Returns false if we already know them.\nexport async function insertPending(\n login: string,\n activity: unknown[],\n opts: { email?: string; flagged?: string } = {},\n): Promise {\n const result = await sqlite.execute(\n `INSERT OR IGNORE INTO ${TABLE} (login, activity, email, status, flagged, created_at)\n VALUES (?, ?, ?, 'pending', ?, ?)`,\n [login, JSON.stringify(activity), opts.email ?? null, opts.flagged ?? null, Date.now()],\n );\n return result.rowsAffected > 0;\n}\n\n// Atomically claim the oldest pending lead for scoring; null when queue empty.\nexport async function claimNext(): Promise {\n const next = await sqlite.execute(\n `SELECT login FROM ${TABLE} WHERE status = 'pending' AND flagged IS NULL\n ORDER BY created_at LIMIT 1`,\n );\n const login = (next.rows[0] as any)?.login ?? (next.rows[0] as any)?.[0];\n if (!login) return null;\n const claimed = await sqlite.execute(\n `UPDATE ${TABLE} SET status = 'scoring' WHERE login = ? AND status = 'pending'`,\n [login],\n );\n if (claimed.rowsAffected === 0) return null; // raced; caller just tries again next tick\n return await getLead(login);\n}\n\nexport async function finishLead(login: string, verdict: string | null, card: string) {\n await sqlite.execute(\n `UPDATE ${TABLE} SET status = 'done', verdict = ?, card = ?, error = NULL, scored_at = ? WHERE login = ?`,\n [verdict, card, Date.now(), login],\n );\n}\n\nexport async function failLead(login: string, error: string) {\n // Back to pending so the next tick retries; keep the error for visibility.\n await sqlite.execute(\n `UPDATE ${TABLE} SET status = 'pending', error = ? WHERE login = ?`,\n [error, login],\n );\n}\n\nexport async function setEmail(login: string, email: string) {\n await sqlite.execute(`UPDATE ${TABLE} SET email = ? WHERE login = ?`, [email, login]);\n}\n\nexport async function markNotified(login: string) {\n await sqlite.execute(`UPDATE ${TABLE} SET notified_at = ? WHERE login = ?`, [Date.now(), login]);\n}\n\nexport async function getLead(login: string): Promise {\n const r = await sqlite.execute(`SELECT * FROM ${TABLE} WHERE login = ?`, [login]);\n return (rowsToObjects(r)[0] as LeadRow) ?? null;\n}\n\nexport async function listLeads(): Promise {\n const r = await sqlite.execute(\n `SELECT * FROM ${TABLE} ORDER BY COALESCE(scored_at, created_at) DESC`,\n );\n return rowsToObjects(r) as LeadRow[];\n}\n\nexport async function unnotifiedMessages(): Promise {\n const r = await sqlite.execute(\n `SELECT * FROM ${TABLE} WHERE verdict = 'MESSAGE' AND notified_at IS NULL AND status = 'done'`,\n );\n return rowsToObjects(r) as LeadRow[];\n}\n\nfunction rowsToObjects(result: { columns: string[]; rows: unknown[] }) {\n return result.rows.map((row: any) => {\n if (row && !Array.isArray(row) && typeof row === \"object\") return row;\n const obj: Record = {};\n result.columns.forEach((col, idx) => (obj[col] = row[idx]));\n return obj;\n });\n}\n",[],[224,335],["D",1784148205583],[304],[224],"9292886e-9385-4aa1-9f93-0bc8b908694f","types.ts","019f4e53-354b-724f-878e-d51fcce433a7",["D",1783725503703],"// Types shared between the Hono backend and the React frontend.\n\nexport interface LeadOutput {\n name?: string;\n company?: string;\n score?: number;\n reasoning?: string;\n error?: string;\n [key: string]: unknown;\n}\n\nexport type LeadStatus = \"processing\" | \"done\" | \"failed\";\n\nexport interface Lead {\n id: number;\n timestamp: number;\n input: Record;\n output: LeadOutput | null;\n status: LeadStatus;\n score: number | null;\n}\n\n// A lead still \"processing\" after this long almost certainly crashed.\nexport const PROCESSING_TIMEOUT_MS = 3 * 60 * 1000;\n\n// A lead is qualified at or above this score: green in the UI, and the bar\n// any notification (email digest, Slack, etc.) should trigger on.\nexport const QUALIFIED_SCORE = 80;\n\n// Sentinel the backend writes into output_data when it claims a lead for\n// scoring, so concurrent /process calls can't double-score it. Both \"\" (just\n// created) and this sentinel mean \"still processing\".\nexport const CLAIMED_OUTPUT = \"claimed\";\n\ninterface LeadRow {\n id: number;\n timestamp: number;\n input_data: string;\n output_data: string;\n}\n\n// Turn a raw DB row (input_data/output_data as JSON strings) into the shape the\n// frontend consumes: parsed fields plus a single computed status. Keeping this\n// one function as the source of truth means the server and client never disagree\n// about whether a lead is processing, done, or failed.\nexport function toClientLead(row: LeadRow, now: number): Lead {\n let input: Record = {};\n try {\n input = JSON.parse(row.input_data);\n } catch { /* leave as {} */ }\n\n const base = { id: row.id, timestamp: row.timestamp, input };\n\n // Empty or claimed output = the agent hasn't written a result yet.\n if (row.output_data === \"\" || row.output_data === CLAIMED_OUTPUT) {\n const timedOut = now - row.timestamp > PROCESSING_TIMEOUT_MS;\n return { ...base, output: null, status: timedOut ? \"failed\" : \"processing\", score: null };\n }\n\n let output: LeadOutput;\n try {\n output = JSON.parse(row.output_data);\n } catch {\n return { ...base, output: { error: \"Malformed output\" }, status: \"failed\", score: null };\n }\n\n if (output.error) return { ...base, output, status: \"failed\", score: null };\n\n return {\n ...base,\n output,\n status: \"done\",\n score: typeof output.score === \"number\" ? output.score : 0,\n };\n}\n",[],[231,346],"b46bf358-083d-451b-a1ff-3399cfc77b1c","config.ts","f8dc0c82-7ee8-11f1-8177-1607ee4eb77e",29,["D",1783967449755],"// Shared configuration for GitHub lead intake (cron + backfill).\n\n// GitHub orgs to watch. The relationship label gives the scoring agent\n// context: activity on your own repos is a much hotter signal than activity\n// on a competitor's.\nexport const WATCHED = [\n { org: \"dbprohq\", relationship: \"our repos (DB Pro)\" },\n { org: \"miracodeai\", relationship: \"our repos (Mira)\" },\n // { org: \"some-competitor\", relationship: \"competitor's repos\" },\n];\n\n// Your own team — never lead-scored. Add/remove GitHub usernames freely.\nexport const EXCLUDE_USERS = new Set([\n \"JSMira\",\n \"jayhyp\",\n \"JackHyp\",\n \"coolio85\",\n \"modrink\",\n \"JDSmith97\",\n]);\n",[],[231,353],["D",1783725503703],[301,302],[231],"fdf10734-59a1-4939-9f36-3ed0d9542950","qualify.ts","f0a873ce-808d-11f1-a453-1607ee4eb77e",67,["D",1784148254140],"// cron: research pending leads one at a time — recover email, gpt-5 + web\n// search against PROMPT.md, write verdict + card back to the db.\nimport { readFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { emailsFromGitHubUsername } from \"https://esm.town/v/stevekrouse/github-user-email/index.ts\";\nimport OpenAI from \"npm:openai\";\nimport { claimNext, failLead, finishLead, setEmail } from \"../utils/db.ts\";\n\nconst openai = new OpenAI({ apiKey: Deno.env.get(\"OPENAI_API_KEY\") });\nconst PROMPT = await readFile(\"/processing/PROMPT.md\", import.meta.url);\n\n// Stop claiming new work near the runtime ceiling; the next tick continues.\nconst TIME_BUDGET_MS = 4 * 60 * 1000;\n\n// Models sometimes wrap output in ``` fences — strip if present.\nexport function stripFences(text: string): string {\n const m = text.trim().match(/^```(?:markdown|md)?\\s*\\n([\\s\\S]*?)\\n?```$/);\n return (m ? m[1] : text).trim();\n}\n\nexport function parseVerdict(markdown: string): string | null {\n return markdown.match(/^Verdict:\\s*(MESSAGE|WATCH|IGNORE|NEEDS_ID)/im)?.[1] ?? null;\n}\n\nexport async function qualify(lead: { login: string; activity: string | null; email: string | null }) {\n let email = lead.email;\n if (!email) {\n try {\n const emails = await emailsFromGitHubUsername(lead.login);\n email = emails.find((e: string) => !e.includes(\"noreply\")) ?? null;\n if (email) await setEmail(lead.login, email);\n } catch { /* email recovery is best-effort */ }\n }\n\n const response = await openai.responses.create({\n model: \"gpt-5\",\n tools: [{ type: \"web_search\" }],\n instructions: PROMPT,\n input: JSON.stringify({\n github_username: lead.login,\n activity: JSON.parse(lead.activity ?? \"[]\"),\n ...(email && { email }),\n }),\n });\n if (response.status !== \"completed\") {\n throw new Error(`Model response ${response.status}`);\n }\n const card = stripFences(response.output_text);\n return { card, verdict: parseVerdict(card) };\n}\n\nexport default async function () {\n const start = Date.now();\n while (Date.now() - start < TIME_BUDGET_MS) {\n const lead = await claimNext();\n if (!lead) return; // queue empty\n try {\n const { card, verdict } = await qualify(lead);\n await finishLead(lead.login, verdict, card);\n console.log(`${lead.login} -> ${verdict}`);\n } catch (err) {\n console.error(`${lead.login} failed:`, err);\n await failLead(lead.login, String(err));\n return; // don't tight-loop on a systemic failure; retry next tick\n }\n }\n}\n",[],[236,364],"00429835-c119-433a-bb32-14850cf46174","e75528d0-808d-11f1-b0cc-1607ee4eb77e",66,["D",1784148238496],"You do lead enrichment and qualification for people who interact with Mira's GitHub repos. Mira (miracode.ai) is a self-hosted, BYOK AI code reviewer — code never leaves your infra, you pick the model, no per-seat pricing.\n\nInput: a GitHub username, their activity on our repos (dates, issue/PR titles), sometimes an email. Research them: GitHub, LinkedIn, personal sites, their company.\n\nThe best leads work at companies where self-hosting matters (regulated, European, on-prem), with a real engineering team, and personally are senior enough to champion tools, and show real usage (issues/PRs > stars). Students, bots, drive-by stars are not leads.\n\nNever invent a company, title, or email — null out and downgrade the verdict instead.\n\nReply in markdown as follows:\n\nVerdict: MESSAGE | WATCH | IGNORE | NEEDS_ID (MESSAGE = a founder should DM them this week; NEEDS_ID = hot activity, unknown person)\nName — title, company (~size)\nWhy: 2–3 sentences, concrete evidence, where facts came from.\nOpener: one line, founder-to-user: reference their specific activity, thank contributors, ask a real question about their setup. Never salesy, never flattery.\nLinks: github · linkedin · company · email\n",[],[236,217],["D",1784148204143],[298,299],[236],"71dd00bb-e79a-4381-8247-2a5d12b0e218","slack.ts","000676b8-808e-11f1-9c99-1607ee4eb77e",69,["D",1784148279910],"// cron: send unnotified MESSAGE-verdict cards to Slack.\nimport { IncomingWebhook } from \"npm:@slack/webhook\";\nimport slackifyMarkdown from \"npm:slackify-markdown\";\nimport { markNotified, unnotifiedMessages } from \"../utils/db.ts\";\n\nexport default async function () {\n const webhookUrl = Deno.env.get(\"SLACK_WEBHOOK_URL\");\n if (!webhookUrl) return; // no-op until configured\n\n const webhook = new IncomingWebhook(webhookUrl);\n for (const lead of await unnotifiedMessages()) {\n await webhook.send({\n text: slackifyMarkdown(`🎯 **New qualified lead: ${lead.login}**\\n\\n${lead.card}`),\n });\n // Mark after the send succeeds; a Slack hiccup means we retry next tick.\n await markNotified(lead.login);\n console.log(`notified: ${lead.login}`);\n }\n}\n",[],[242,382],"5582ceb7-e420-453e-ba01-8007562cd43b","server.ts","1a9b404e-808e-11f1-994f-1607ee4eb77e","05b6d134-808e-11f1-a4db-1607ee4eb77e",72,["D",1784148324513],"// http: the dashboard — browse every lead, filter by verdict, score anyone.\nimport { readFile, serveFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { Hono } from \"npm:hono@4\";\nimport { insertPending, listLeads } from \"../../utils/db.ts\";\nimport { requireOrgMember } from \"./auth.tsx\";\n\nconst app = new Hono();\n\n// Unwrap Hono errors so the platform surfaces the real error.\napp.onError((err) => Promise.reject(err));\n\napp.use(\"/*\", requireOrgMember);\n\napp.get(\"/\", async (c) => {\n let html = await readFile(\"/outputs/dashboard/index.html\", import.meta.url);\n const data = { initialLeads: await listLeads() };\n // Escape \"<\" so card content can't terminate the script tag early.\n const json = JSON.stringify(data).replace(/\", ``);\n return c.html(html);\n});\n\napp.get(\"/api/leads\", async (c) => c.json(await listLeads()));\n\n// The score-anyone box: insert as pending; the qualify cron picks it up.\napp.post(\"/api/leads\", async (c) => {\n const { github_username } = await c.req.json();\n if (!github_username?.trim()) {\n return c.json({ ok: false, error: \"github_username required\" }, 400);\n }\n const login = github_username.trim();\n const isNew = await insertPending(login, [{ type: \"manual\", when: new Date().toISOString().slice(0, 10) }]);\n return c.json({ ok: true, login, isNew });\n});\n\n// Serve the frontend module.\napp.get(\"/public/**/*\", (c) =>\n serveFile(c.req.path.replace(\"/public\", \"/outputs/dashboard\"), import.meta.url));\n\nexport default app;\n",[],[242,398,390],"dashboard","28cfadd3-da06-4f63-8142-fe85dce67a05","index.html","1ee47fda-808e-11f1-8b8f-1607ee4eb77e",73,["D",1784148331712],"\n\n \n \n \n GitHub Leads\n \n \n \n

\n \n \n \n\n",[],[242,398,400],"c9301f40-db92-4a61-817f-087c2ab6c384","auth.tsx","0ed6945c-808e-11f1-9b85-1607ee4eb77e",71,["D",1784148304776],"/** @jsxImportSource npm:hono@4/jsx */\nimport { getOAuthUserData } from \"https://esm.town/v/std/oauth/middleware.ts\";\nimport { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\n\n// The template's own live preview (owned by the \"templates\" org) is publicly\n// viewable. Your remix is owned by your org, so it requires login.\nconst IS_TEMPLATE_PREVIEW = parseVal().username === \"templates\";\n\n// Auth guard for the dashboard. The x-debug-token header bypass lets headless\n// agents (and curl) hit the dashboard for debugging without a browser login.\nexport async function requireOrgMember(c: any, next: any) {\n if (IS_TEMPLATE_PREVIEW && c.req.method === \"GET\") return next();\n const debugToken = Deno.env.get(\"DEBUG_TOKEN\");\n if (debugToken && c.req.header(\"x-debug-token\") === debugToken) return next();\n const session = await getOAuthUserData(c.req.raw);\n if (!session) return c.html();\n if (!session.isOrgMember) {\n return c.html(, 403);\n }\n await next();\n}\n\nfunction Shell({ title, children }: { title: string; children: any }) {\n return (\n \n \n \n \n {title}\n \n \n \n

\n {children}\n

\n \n \n );\n}\n\nfunction LoginPage() {\n return (\n \n

🔒

GitHub Leads Dashboard

\n \n $\"\"$ \n Sign in with Val Town\n \n

\n \n );\n}\n\nfunction UnauthorizedPage({ username }: { username: string }) {\n return (\n \n

⛔

Access Denied

\n You must be a member of this val's organization to view the dashboard.\n

\n Logged in as {username}\n

\n \n );\n}\n",[],[242,398,408],"40e065b0-d585-4434-a844-7b625d7bdc19","app.tsx","2d703346-808e-11f1-a292-1607ee4eb77e",74,["D",1784148356104],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\n// The dashboard app: verdict-filterable list of lead cards.\nimport { createRoot } from \"https://esm.sh/react-dom@18.2.0/client\";\nimport { useMemo, useState } from \"https://esm.sh/react@18.2.0\";\nimport { marked } from \"https://esm.sh/marked@12\";\n\ninterface Lead {\n login: string;\n email: string | null;\n status: string;\n verdict: string | null;\n card: string | null;\n error: string | null;\n flagged: string | null;\n created_at: number;\n scored_at: number | null;\n}\n\ndeclare global {\n interface Window {\n __INITIAL_DATA__: { initialLeads: Lead[] };\n }\n}\n\nconst VERDICTS = [\"ALL\", \"MESSAGE\", \"WATCH\", \"NEEDS_ID\", \"IGNORE\", \"PENDING\"] as const;\nconst BADGE: Record = {\n MESSAGE: \"bg-green-100 text-green-800\",\n WATCH: \"bg-yellow-100 text-yellow-800\",\n NEEDS_ID: \"bg-gray-200 text-gray-700\",\n IGNORE: \"bg-gray-100 text-gray-400\",\n PENDING: \"bg-blue-100 text-blue-800\",\n};\n\nfunction bucket(lead: Lead): string {\n if (lead.status !== \"done\") return \"PENDING\";\n return lead.verdict ?? \"NEEDS_ID\";\n}\n\n// First non-verdict line of the card is \"Name — title, company\".\nfunction headline(lead: Lead): string {\n const lines = (lead.card ?? \"\").split(\"\\n\").map((l) => l.trim()).filter(Boolean);\n return lines.find((l) => !l.startsWith(\"Verdict:\")) ?? lead.login;\n}\n\nfunction App({ initialLeads }: { initialLeads: Lead[] }) {\n const [leads, setLeads] = useState(initialLeads);\n const [filter, setFilter] = useState<(typeof VERDICTS)[number]>(\"ALL\");\n const [open, setOpen] = useState(null);\n const [username, setUsername] = useState(\"\");\n\n const counts = useMemo(() => {\n const c: Record = {};\n for (const l of leads) c[bucket(l)] = (c[bucket(l)] ?? 0) + 1;\n return c;\n }, [leads]);\n\n const visible = filter === \"ALL\" ? leads : leads.filter((l) => bucket(l) === filter);\n\n async function scoreUsername(e: React.FormEvent) {\n e.preventDefault();\n if (!username.trim()) return;\n await fetch(\"/api/leads\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ github_username: username.trim() }),\n });\n setUsername(\"\");\n setLeads(await (await fetch(\"/api/leads\")).json());\n }\n\n return (\n

GitHub Leads

\n\n

\n {VERDICTS.map((v) => (\n setFilter(v)}\n className={`px-3 py-1 rounded-full text-sm border ${\n filter === v ? \"bg-gray-900 text-white border-gray-900\" : \"bg-white border-gray-200\"\n }`}\n >\n {v.toLowerCase()} {v === \"ALL\" ? leads.length : counts[v] ?? 0}\n \n ))}\n

\n\n

\n {visible.map((lead) => {\n const b = bucket(lead);\n return (\n

\n setOpen(open === lead.login ? null : lead.login)}\n className=\"w-full text-left px-4 py-3 flex items-center gap-3\"\n >\n \n {b}\n \n \n {lead.login}\n {lead.status === \"done\" && (\n · {headline(lead)}\n )}\n {lead.flagged && · {lead.flagged}}\n {lead.error && · {lead.error}}\n \n \n {open === lead.login && lead.card && (\n \n )}\n

\n );\n })}\n {visible.length === 0 && (\n

Nothing here yet.

\n )}\n

\n );\n}\n\nconst root = document.getElementById(\"root\");\nif (!root) throw new Error(\"No root element found\");\ncreateRoot(root).render();\n",[],[242,398,416],"8edd6668-8bb0-41ec-9c76-f30b60e610d6",70,["D",1784148289445],[292,293,294,295],[242,398],["D",1784148204925],[291,296],[242],"dd36b046-1612-484d-bd5b-82a9b298e6fe",["D",1784148381651],[],[248,33],["D",1784148203624],[289],[248],"6b150dc6-91ea-4eba-b53e-78d5d280fa0e","index.tsx","019f4e53-354b-724f-878e-cd7717fc9ea8",["D",1783725503703],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { createRoot } from \"https://esm.sh/react-dom@18.2.0/client\";\nimport { type Lead } from \"../shared/types.ts\";\nimport { App } from \"./components/App.tsx\";\n\ndeclare global {\n interface Window {\n __INITIAL_DATA__: {\n initialLeads: Lead[];\n webhookUrl: string;\n username: string | null;\n };\n }\n}\n\nconst root = document.getElementById(\"root\");\nif (!root) throw new Error(\"No root element found\");\n\ncreateRoot(root).render();\n",[],[254,439],"04192299-aee4-4b15-b315-bf2fbb18dd0b","019f4e53-354b-724f-878e-c988e759ea01",["D",1783725503703],"\n\n \n \n \n GitHub Leads\n \n \n \n

\n \n \n \n\n",[],[254,400],"0d28e93f-09fd-498f-88d9-fc6dc68f1efd","LeadRow.tsx","019f4e53-354b-724f-878e-c0691c6334bc","019f4e53-354b-724f-878e-c6777cad123e",["D",1783725503703],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\nimport { type Lead, QUALIFIED_SCORE } from \"../../shared/types.ts\";\n\n// Relative dates keep the feed scannable: \"2h ago\" matters, exact dates don't.\nexport function timeAgo(ts: number): string {\n const mins = Math.floor((Date.now() - ts) / 60_000);\n if (mins < 1) return \"just now\";\n if (mins < 60) return `${mins}m ago`;\n const hours = Math.floor(mins / 60);\n if (hours < 24) return `${hours}h ago`;\n const days = Math.floor(hours / 24);\n if (days < 30) return `${days}d ago`;\n return new Date(ts).toLocaleDateString(\"en-US\", { month: \"short\", day: \"numeric\", year: \"numeric\" });\n}\n\n// Fixed-width score column; green is reserved for qualified,\n// red for failed. Everything else stays quiet.\nfunction Score({ lead }: { lead: Lead }) {\n if (lead.status === \"processing\") {\n return ··;\n }\n if (lead.status === \"failed\") {\n return ✗;\n }\n const score = lead.score ?? 0;\n return (\n = QUALIFIED_SCORE ? \"text-green-700 font-semibold\" : \"text-gray-400\"}>\n {score}\n \n );\n}\n\nconst ROW = \"w-full text-left py-2.5 border-b border-gray-100 grid grid-cols-[2.5rem_1fr_auto] items-baseline gap-3\";\n\nexport function LeadRow({ lead, onSelect }: { lead: Lead; onSelect: (id: number) => void }) {\n const displayName = lead.output?.name || (lead.input.name as string) ||\n (lead.input.github_username as string) || (lead.input.company as string) || \"Unknown\";\n\n return (\n onSelect(lead.id)}\n className={`${ROW} hover:bg-gray-50 cursor-pointer`}\n >\n \n \n {displayName}\n {lead.output?.company && · {lead.output.company}}\n {lead.status === \"processing\" && · scoring…}\n {lead.status === \"failed\" && · failed}\n \n {timeAgo(lead.timestamp)}\n \n );\n}\n\nexport function SampleRow(\n { name, company, score }: { name: string; company: string; score: number },\n) {\n return (\n

\n = QUALIFIED_SCORE ? \"text-green-700 font-semibold\" : \"text-gray-400\"}`}>\n {score}\n \n \n {name}\n · {company}\n \n example\n

\n );\n}\n",[],[254,459,452],"components","01907a44-82d6-488c-b9d9-ed3563f41c5b","LeadDetail.tsx","019f4e53-354b-724f-878e-bd193267b39f",["D",1783725503703],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\nimport { type Lead, QUALIFIED_SCORE } from \"../../shared/types.ts\";\nimport { timeAgo } from \"./LeadRow.tsx\";\n\nexport function LeadDetail({ lead, onBack }: { lead: Lead; onBack: () => void }) {\n const output = lead.output;\n const score = lead.score ?? 0;\n const displayName = output?.name || (lead.input.name as string) ||\n (lead.input.github_username as string) || (lead.input.company as string) || \"Unknown\";\n\n return (\n

\n \n ← All leads\n \n\n

{displayName}

\n {output?.company && `${output.company} · `}\n {timeAgo(lead.timestamp)}\n

\n\n {lead.status === \"failed\"\n ? (\n

\n {output?.error ||\n \"This lead has been processing for over 3 minutes and likely failed. Try resubmitting it.\"}\n

\n )\n : lead.status === \"processing\"\n ? (\n

\n Scoring — the AI is researching this lead. Usually takes a minute or two.\n

\n )\n : (\n

= QUALIFIED_SCORE ? \"text-green-700\" : \"\"}`}>\n {score}\n / 100\n

\n {output?.reasoning || \"No reasoning provided\"}\n

\n )}\n\n \n {output && lead.status !== \"processing\" && }\n

\n );\n}\n\nfunction DataList({ title, data }: { title: string; data: Record }) {\n const entries = Object.entries(data);\n if (entries.length === 0) return null;\n\n return (\n

{title}

\n {entries.map(([key, value]) => (\n

\n {key}\n \n {typeof value === \"object\" ? JSON.stringify(value) : String(value ?? \"\")}\n \n

\n ))}\n

\n );\n}\n",[],[254,459,461],"c8ad1a15-a309-426a-94c7-5162ab3eb4a2","GithubTester.tsx","019f4e53-354b-724f-878e-baa772436726",["D",1783725503703],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\n\n// One quiet line under the title: score any GitHub username on demand, plus\n// the webhook URL for wiring up other sources (forms, signups, CRMs).\nexport function GithubTester({ webhookUrl, onSent }: { webhookUrl: string; onSent: () => void }) {\n const [handle, setHandle] = React.useState(\"\");\n const [sending, setSending] = React.useState(false);\n const [error, setError] = React.useState(null);\n const [copied, setCopied] = React.useState(false);\n\n const copy = async () => {\n try {\n await navigator.clipboard.writeText(webhookUrl);\n } catch {\n // Clipboard API is blocked by permissions policy inside iframes (like\n // the Val Town preview); fall back to the legacy selection approach.\n const ta = document.createElement(\"textarea\");\n ta.value = webhookUrl;\n ta.style.position = \"fixed\";\n ta.style.opacity = \"0\";\n document.body.appendChild(ta);\n ta.select();\n document.execCommand(\"copy\");\n ta.remove();\n }\n setCopied(true);\n setTimeout(() => setCopied(false), 2000);\n };\n\n const send = async () => {\n const username = handle.trim().replace(/^@/, \"\");\n if (!username || sending) return;\n setSending(true);\n setError(null);\n try {\n const res = await fetch(`${webhookUrl}?source=manual`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ github_username: username }),\n });\n const data = await res.json();\n if (data.error) {\n setError(data.error);\n } else {\n setHandle(\"\");\n onSent();\n }\n } catch (err) {\n setError(err instanceof Error ? err.message : String(err));\n } finally {\n setSending(false);\n }\n };\n\n return (\n

\n setHandle(e.target.value)}\n onKeyDown={(e) => e.key === \"Enter\" && send()}\n placeholder=\"Score a GitHub username…\"\n spellCheck={false}\n className=\"border border-gray-200 px-2.5 py-1.5 w-56 focus:outline-none focus:border-gray-400\"\n />\n \n {sending ? \"sending…\" : \"score\"}\n \n \n or POST JSON to{\" \"}\n this URL{\" \"}\n \n {copied ? \"copied\" : \"copy\"}\n \n \n

\n {error &&

{error}

}\n

\n );\n}\n",[],[254,459,468],"3cfb95f3-3fb1-4031-96bc-f90c717e46a8","Dashboard.tsx","019f4e53-354b-724f-878e-b7ce11d2bf8f",["D",1783725503703],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { type Lead, QUALIFIED_SCORE } from \"../../shared/types.ts\";\nimport { LeadRow, SampleRow } from \"./LeadRow.tsx\";\n\nconst WEEK_MS = 7 * 24 * 60 * 60 * 1000;\n\n// Shown only when there are no leads yet, so the dashboard demonstrates what\n// scored leads look like before the first real one arrives.\nconst SAMPLE_LEADS = [\n { name: \"Maya Chen\", company: \"Parabolic Systems\", score: 92 },\n { name: \"Diego Alvarez\", company: \"Kestrel Analytics\", score: 61 },\n { name: \"Sam Hobbyist\", company: \"Personal blog\", score: 14 },\n];\n\n// Best leads first, but only within the last week — an old high score\n// shouldn't outrank this morning's lead forever. Still-processing leads pin\n// to the top; leads older than a week collapse under \"Earlier\".\nfunction byScoreThenNewest(a: Lead, b: Lead): number {\n if ((a.status === \"processing\") !== (b.status === \"processing\")) {\n return a.status === \"processing\" ? -1 : 1;\n }\n return (b.score ?? 0) - (a.score ?? 0) || b.timestamp - a.timestamp;\n}\n\nexport function Dashboard(\n { leads, onSelect }: { leads: Lead[]; onSelect: (id: number) => void },\n) {\n const sorted = [...leads].sort(byScoreThenNewest);\n const cutoff = Date.now() - WEEK_MS;\n const recent = sorted.filter((l) => l.timestamp >= cutoff);\n const earlier = sorted.filter((l) => l.timestamp < cutoff);\n const qualified = recent.filter(\n (l) => l.status === \"done\" && (l.score ?? 0) >= QUALIFIED_SCORE,\n );\n\n if (leads.length === 0) {\n return (\n

\n No leads yet — here's what scored leads look like.\n

\n {SAMPLE_LEADS.map((s) => )}\n

\n );\n }\n\n return (\n

\n {recent.length} {recent.length === 1 ? \"lead\" : \"leads\"} this week\n {qualified.length > 0 && ` · ${qualified.length} qualified`}\n

\n\n {recent.map((l) => )}\n\n {earlier.length > 0 && (\n

\n Earlier · {earlier.length} {earlier.length === 1 ? \"lead\" : \"leads\"}\n

\n {earlier.map((l) => (\n \n ))}\n

\n )}\n

\n );\n}\n",[],[254,459,475],"74d298f7-5965-473c-bf13-c7ede3e5dc98","App.tsx","019f4e53-354b-724f-878e-b0d73fd10ebd",["D",1783725503703],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\nimport { type Lead } from \"../../shared/types.ts\";\nimport { Dashboard } from \"./Dashboard.tsx\";\nimport { LeadDetail } from \"./LeadDetail.tsx\";\nimport { GithubTester } from \"./GithubTester.tsx\";\n\nexport function App(\n { initialLeads = [], webhookUrl = \"\", username = null }: {\n initialLeads?: Lead[];\n webhookUrl?: string;\n username?: string | null;\n },\n) {\n const [leads, setLeads] = React.useState(initialLeads);\n const [selectedId, setSelectedId] = React.useState(null);\n\n const refresh = React.useCallback(async () => {\n try {\n const res = await fetch(\"/api/leads\");\n if (res.ok) setLeads(await res.json());\n } catch (err) {\n console.error(\"Failed to refresh leads\", err);\n }\n }, []);\n\n // Poll only while something is still being researched.\n const hasProcessing = leads.some((l) => l.status === \"processing\");\n React.useEffect(() => {\n if (!hasProcessing) return;\n const timer = setInterval(refresh, 3000);\n return () => clearInterval(timer);\n }, [hasProcessing, refresh]);\n\n const selected = leads.find((l) => l.id === selectedId) ?? null;\n\n return (\n

\n {selected\n ? setSelectedId(null)} />\n : (\n <>\n

GitHub Leads

\n {username && (\n \n {username} ·{\" \"}\n \n \n )}\n

\n \n \n \n )}\n \n

\n );\n}\n",[],[254,459,482],"6973058f-b53a-4c95-a698-a086c6c1e174",["D",1783725503703],[281,282,283,284,285],[254,459],["D",1783725503703],[280,286,287],[254],"ebd9a265-7888-4b76-a36c-8417fc945c5a","notify.ts","019f4e53-354b-724f-878e-a9de4c2b09e8",["D",1783725503703],"import { httpEndpoint } from \"https://esm.town/v/std/utils/index.ts\";\nimport { IncomingWebhook } from \"npm:@slack/webhook\";\nimport { LeadOutput, QUALIFIED_SCORE } from \"../shared/types.ts\";\n\n// Set the SLACK_WEBHOOK_URL env var to get a Slack message the moment a lead\n// scores as qualified. Without it, this is a no-op.\n// https://docs.val.town/guides/slack/send-messages-to-slack/\nexport async function notifySlack(output: LeadOutput) {\n const webhookUrl = Deno.env.get(\"SLACK_WEBHOOK_URL\");\n if (!webhookUrl) return;\n if (typeof output.score !== \"number\" || output.score < QUALIFIED_SCORE) return;\n\n // Best-effort: a Slack hiccup should never fail (or retry) the lead scoring.\n try {\n const dashboardUrl = await httpEndpoint(\"main.ts\", import.meta.url);\n const who = [output.name, output.company].filter(Boolean).join(\" · \");\n await new IncomingWebhook(webhookUrl).send({\n text: [\n `🎯 Qualified lead (${output.score}): *${who || \"Unknown\"}*`,\n output.reasoning,\n `<${dashboardUrl}|Open dashboard>`,\n ].filter(Boolean).join(\"\\n\"),\n });\n } catch (err) {\n console.error(\"Slack notification failed:\", err);\n }\n}\n",[],[259,496],"3b53b219-b858-453a-b957-b578ddc00678","index.ts","019f4e53-354b-724f-878e-a4f6b2670ec4",9,["D",1783726140509],"import { getOAuthUserData } from \"https://esm.town/v/std/oauth/middleware.ts\";\nimport { parseVal, readFile, serveFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { Hono } from \"npm:hono@4\";\nimport { toClientLead } from \"../shared/types.ts\";\nimport { processLead } from \"./agent.ts\";\nimport { claimLead, createProcessingLead, getAllLeads, getLeadById } from \"./db.ts\";\nimport { requireOrgMember } from \"./auth.tsx\";\n\nconst app = new Hono();\n\n// Unwrap Hono errors so the platform surfaces the real error, not \"Internal Server Error\"\napp.onError((err) => Promise.reject(err));\n\n// Serialize every lead the same way for both the initial page load and the API.\nasync function clientLeads() {\n const now = Date.now();\n const rows = await getAllLeads();\n return rows.map((row) => toClientLead(row, now));\n}\n\n// ── Public webhook endpoints (no auth) ──\n\napp.post(\"/\", async (c) => {\n let body: Record;\n try {\n body = await c.req.json();\n } catch {\n return c.json({ ok: false, error: \"Request body must be valid JSON\" }, 400);\n }\n const url = new URL(c.req.url);\n const query = Object.fromEntries(url.searchParams);\n const inputData = Object.keys(query).length ? { ...body, _query: query } : body;\n\n // Create the lead immediately in a processing state and respond fast.\n const leadId = await createProcessingLead(inputData);\n\n // Fire-and-forget the slow scoring in a separate request.\n // https://docs.val.town/vals/http/early-return/\n fetch(`${url.origin}/process`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ leadId }),\n });\n\n return c.json({ ok: true, leadId });\n});\n\napp.post(\"/process\", async (c) => {\n const { leadId } = await c.req.json();\n // This route is public (registered before the auth guard) so POST / can call\n // it fire-and-forget. The atomic claim means each lead is scored exactly\n // once, and the input comes from the DB row — not the request — so this\n // can't be used to re-score, overwrite, or feed the agent forged data.\n if (!(await claimLead(leadId))) return c.json({ ok: false }, 409);\n const lead = await getLeadById(leadId);\n await processLead(leadId, JSON.parse(lead!.input_data));\n return c.json({ ok: true });\n});\n\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\n// ── Everything below requires an org member (the template preview allows GET) ──\napp.use(\"/*\", requireOrgMember);\n\n// Serve the React dashboard, bootstrapping the leads into the HTML so the list\n// paints immediately instead of flashing empty while the first fetch runs.\napp.get(\"/\", async (c) => {\n let html = await readFile(\"/frontend/index.html\");\n const session = await getOAuthUserData(c.req.raw);\n const data = {\n initialLeads: await clientLeads(),\n webhookUrl: new URL(c.req.url).origin,\n username: session?.user?.username ?? null,\n };\n // Escape \"<\" so lead content containing \"\" can't terminate the tag\n // early (which dumps raw JSON into the page and breaks hydration).\n const json = JSON.stringify(data).replace(/window.__INITIAL_DATA__ = ${json}`;\n html = html.replace(\"\", `${script}`);\n return c.html(html);\n});\n\n// JSON endpoint the frontend polls while leads are still processing.\napp.get(\"/api/leads\", async (c) => c.json(await clientLeads()));\n\n// Serve the frontend modules (/public/**) and shared types (/shared/**).\napp.get(\"/public/**/*\", (c) => serveFile(c.req.path.replace(\"/public\", \"/frontend\")));\napp.get(\"/shared/**/*\", (c) => serveFile(c.req.path));\n\nexport default app;\n",[],[259,503],"15766874-4618-411b-9192-436337b241e1","019f4e53-354b-724f-878e-a3cc99eb9dc9",["D",1783725503703],"import sqlite from \"https://esm.town/v/std/db/main.ts\";\nimport { CLAIMED_OUTPUT } from \"../shared/types.ts\";\n\nconst TABLE_NAME = \"leads\";\n\nawait createTable();\n\nexport interface Lead {\n id: number;\n timestamp: number;\n input_data: string;\n output_data: string;\n}\n\nexport async function createProcessingLead(\n inputData: Record,\n): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${TABLE_NAME} (timestamp, input_data, output_data)\n VALUES (?, ?, ?)`,\n [Date.now(), JSON.stringify(inputData), \"\"],\n );\n return Number(result.lastInsertRowid);\n}\n\n// Atomically claim a just-created lead for scoring. Returns false if the\n// lead doesn't exist or was already claimed/finished, so concurrent /process\n// calls can't double-score (and double-spend on) the same lead.\nexport async function claimLead(id: number): Promise {\n const result = await sqlite.execute(\n `UPDATE ${TABLE_NAME} SET output_data = ? WHERE id = ? AND output_data = ''`,\n [CLAIMED_OUTPUT, id],\n );\n return result.rowsAffected > 0;\n}\n\nexport async function updateLeadOutput(\n id: number,\n outputData: Record,\n) {\n await sqlite.execute(\n `UPDATE ${TABLE_NAME} SET output_data = ? WHERE id = ?`,\n [JSON.stringify(outputData), id],\n );\n}\n\nexport async function getAllLeads(): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLE_NAME} ORDER BY timestamp DESC`,\n );\n return rowsToLeads(result);\n}\n\nexport async function getLeadById(id: number): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLE_NAME} WHERE id = ?`,\n [id],\n );\n const leads = rowsToLeads(result);\n return leads[0] || null;\n}\n\n// Find an existing lead by the github_username stored in its input, so the\n// GitHub cron appends new activity to the same person instead of creating a\n// duplicate lead.\nexport async function findLeadByGithubUsername(\n login: string,\n): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLE_NAME}\n WHERE json_extract(input_data, '$.github_username') = ?`,\n [login],\n );\n const leads = rowsToLeads(result);\n return leads[0] || null;\n}\n\n// Append new GitHub events to an existing lead's input, deduplicated by\n// event id so repeat sweeps don't grow the lead unboundedly.\nexport async function appendFollowup(\n id: number,\n newEvents: Array<{ id?: string }>,\n) {\n const lead = await getLeadById(id);\n if (!lead) return;\n const input = JSON.parse(lead.input_data);\n const events: Array<{ id?: string }> = Array.isArray(input.events) ? input.events : [];\n const existingIds = new Set(events.map((e) => e.id).filter(Boolean));\n events.push(...newEvents.filter((e) => !e.id || !existingIds.has(e.id)));\n await sqlite.execute(\n `UPDATE ${TABLE_NAME} SET input_data = ? WHERE id = ?`,\n [JSON.stringify({ ...input, events }), id],\n );\n}\n\nfunction rowsToLeads(result: { columns: string[]; rows: unknown[] }): Lead[] {\n return result.rows.map((row: any) => {\n const obj: Record = {};\n result.columns.forEach((col, idx) => {\n obj[col] = row[idx];\n });\n return obj as Lead;\n });\n}\n\nasync function createTable() {\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS ${TABLE_NAME} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n timestamp INTEGER NOT NULL,\n input_data TEXT NOT NULL,\n output_data TEXT NOT NULL\n )`,\n );\n}\n\nexport function isProcessing(lead: Lead): boolean {\n return lead.output_data === \"\" || lead.output_data === CLAIMED_OUTPUT;\n}\n\nexport function isFailed(lead: Lead): boolean {\n if (isProcessing(lead)) return false;\n try {\n return Boolean(JSON.parse(lead.output_data).error);\n } catch {\n return true;\n }\n}\n",[],[259,335],"8ad6ace0-eeaa-400c-a046-6e867dc473b7","019f4e53-354b-724f-878e-9c93bf2de69c",10,["D",1783726169429],"/** @jsxImportSource npm:hono@4/jsx */\nimport { getOAuthUserData } from \"https://esm.town/v/std/oauth/middleware.ts\";\nimport { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\n\n// The template's own live preview (owned by the \"templates\" org) is publicly\n// viewable. Your remix is owned by your org, so it requires login.\nconst IS_TEMPLATE_PREVIEW = parseVal().username === \"templates\";\n\n// Auth guard for the dashboard routes. Register the public webhook routes\n// (POST / and /process) BEFORE this so external systems can submit leads\n// without logging in.\nexport async function requireOrgMember(c: any, next: any) {\n if (IS_TEMPLATE_PREVIEW && c.req.method === \"GET\") return next();\n const session = await getOAuthUserData(c.req.raw);\n if (!session) return c.html();\n if (!session.isOrgMember) {\n return c.html(, 403);\n }\n await next();\n}\n\nfunction Shell({ title, children }: { title: string; children: any }) {\n return (\n \n \n \n \n {title}\n \n \n \n

\n {children}\n

\n \n \n );\n}\n\nfunction LoginPage() {\n return (\n \n

🔒

GitHub Leads Dashboard

\n \n $\"\"$ \n Sign in with Val Town\n \n

\n \n );\n}\n\nfunction UnauthorizedPage({ username }: { username: string }) {\n return (\n \n

⛔

Access Denied

\n You must be a member of this val's organization to view the dashboard.\n

\n Logged in as {username}\n

\n \n );\n}\n",[],[259,408],"7a1f22d3-59af-4347-894b-4aa01e38dc0a","agent.ts","019f4e53-354b-724f-878e-9912b409b7f0",["D",1783725503703],"import { ValTownOpenAI } from \"https://esm.town/v/std/openai/main.ts\";\nimport { readFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { enrich } from \"https://esm.town/v/valdottown/peopledatalabs/sdk.ts\";\nimport OpenAI from \"npm:openai\";\nimport { updateLeadOutput } from \"./db.ts\";\nimport { notifySlack } from \"./notify.ts\";\n\n// Uses Val Town's built-in OpenAI proxy, so no API key setup is needed.\n// If you hit its rate limits, set the OPENAI_API_KEY env var to use your\n// own OpenAI account instead.\nconst apiKey = Deno.env.get(\"OPENAI_API_KEY\");\nconst openai = apiKey ? new OpenAI({ apiKey }) : new ValTownOpenAI({});\n\nconst PROMPT = await readFile(\"/PROMPT.md\");\n\n// Enrichment (person, LinkedIn, company, work history) via Val Town's\n// People Data Labs proxy. Pro accounts get $10/month included; free accounts\n// get 2 ever, then fall back to web search alone.\nasync function enrichLead(inputData: Record) {\n if (!inputData.email && !inputData.github_username) return {};\n try {\n const { data } = await enrich({\n email: inputData.email as string | undefined,\n github_username: inputData.github_username as string | undefined,\n });\n return data ? { enrichment: data } : {};\n } catch (err) {\n if (err.status === 401 || err.status === 403 || err.status === 429) {\n return {\n enrichmentNote:\n \"Enrichment quota reached — Val Town Pro includes $10/month (https://www.val.town/pricing)\",\n };\n }\n console.error(\"Enrichment failed:\", err);\n return { enrichmentNote: `Enrichment failed: ${err.message}` };\n }\n}\n\nexport async function processLead(\n leadId: number,\n inputData: Record,\n) {\n try {\n const { enrichment, enrichmentNote } = await enrichLead(inputData);\n const response = await openai.responses.create({\n model: \"gpt-5\",\n tools: [{ type: \"web_search\" }],\n instructions: PROMPT,\n input: JSON.stringify(enrichment ? { ...inputData, enrichment } : inputData),\n });\n if (response.status !== \"completed\") {\n throw new Error(`Model response ${response.status}: ${JSON.stringify(response.incomplete_details)}`);\n }\n // The prompt asks for bare JSON, but models sometimes wrap it in ```json fences\n const json = response.output_text.replace(/^\\s*```(?:json)?\\s*|\\s*```\\s*$/g, \"\");\n const outputData = { ...JSON.parse(json), ...(enrichmentNote && { enrichmentNote }) };\n await updateLeadOutput(leadId, outputData);\n await notifySlack(outputData);\n return { outputData };\n } catch (err) {\n // Record the failure so the dashboard shows it immediately instead of\n // spinning until the timeout. Log first so the root cause survives even if\n // this DB write itself throws.\n console.error(`Lead ${leadId} failed:`, err);\n const error = err instanceof Error ? err.message : String(err);\n await updateLeadOutput(leadId, { error });\n throw err;\n }\n}\n",[],[259,524],["D",1783725503703],[274,275,276,277,278],[259],["D",1783725503703],["D",1789526460011],{"_106":105,"_114":110},{"_106":105,"_107":108,"_109":110,"_18":-5,"_111":112,"_113":61},{"_13":91,"_32":92,"_44":43,"_93":45,"_94":95,"_96":97,"_98":51,"_99":100,"_101":102,"_103":46,"_104":105},"ctx",{"_84":-5,"_136":571,"_572":573,"_574":575,"_576":25,"_577":25,"_578":25,"_579":61,"_580":-5,"_581":-7,"_582":-7,"_583":65,"_584":25,"_585":25,"_586":-5,"_587":25,"_588":25,"_589":25,"_590":-5},"ENV",{"_542":543,"_544":545,"_546":92,"_547":548,"_549":550,"_551":552,"_553":554,"_555":556,"_557":558,"_559":560,"_561":562,"_563":564,"_565":566,"_567":568,"_569":570},"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"]

Diff · v76