[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_331":332,"_333":334},"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",131,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",false,"deletedHere","path","utils/db.ts","latestPath","fileId","e0a0b13a-808d-11f1-8fff-1607ee4eb77e","name","db.ts","fileType","script","content","// 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\nconst TABLE = \"leads\";\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","// 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\nconst TABLE = \"leads\";\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 contacted_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","createdAt",["D",1784150947585],"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=1789541999&sig=e4c5f19fff9498fc87aa42b17560594110330fe305a5b7c1e1d4bd62f0981075","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":326,"_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":327,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":328,"_86":329,"_88":330,"_90":25},"tree",[213,215,222,225,227,228],"files",[213,214,215,216,217,218,219,220,221,222,223,224,225,226,227,228],"counts",{"_202":65,"_203":164,"_204":65,"_205":206,"_207":208},"contents",[152,153,154,155,156,157],"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=1789541999&sig=156ae2b8ac752fc06f52d45eab428b512e0d31e2aab99a830d8bb32149c64f0f",{"_44":196,"_32":197,"_30":198,"_160":-5,"_42":43,"_41":199,"_162":61,"_39":200,"_13":65,"_34":182,"_36":-5,"_24":25,"_167":-5,"_27":201},{"_44":190,"_32":191,"_30":192,"_160":-5,"_42":43,"_41":193,"_162":61,"_39":194,"_13":65,"_34":182,"_36":-5,"_24":25,"_167":-5,"_27":195},{"_44":184,"_32":185,"_30":186,"_160":-5,"_42":43,"_41":187,"_162":61,"_39":188,"_13":65,"_34":182,"_36":-5,"_24":25,"_167":-5,"_27":189},{"_44":177,"_32":178,"_30":179,"_160":-5,"_42":43,"_41":180,"_162":61,"_39":181,"_13":65,"_34":182,"_36":-5,"_24":25,"_167":-5,"_27":183},{"_44":169,"_32":170,"_30":171,"_160":-5,"_42":43,"_41":172,"_162":25,"_39":173,"_13":174,"_34":20,"_36":175,"_24":25,"_167":-5,"_27":176},{"_44":158,"_32":159,"_30":59,"_160":-5,"_42":43,"_41":161,"_162":61,"_39":163,"_13":164,"_34":165,"_36":166,"_24":25,"_167":-5,"_27":168},"cb7ac0dc-3fb4-4c02-a9cb-9ecb78681cc9","main.ts","parentId",75,"latest",["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","label",[159],"8606e675-d6fd-4372-9f52-260e5d413c5e","README.md","019f4e53-354b-724f-878e-e330fea73434",120,["D",1784149818425],11,"# 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| Name | Required | Where to get | Where to set | Why |\n| --- | --- | --- | --- | --- |\n| `GITHUB_TOKEN` | Required | [Create (no scopes)](https://github.com/settings/tokens/new?description=github-leads&scopes=) | [Paste here](/environment-variables?key=GITHUB_TOKEN) | Polling GitHub from shared IPs hits rate limits |\n| `OPENAI_API_KEY` | Optional | [Get a key](https://platform.openai.com/api-keys) | [Paste here](/environment-variables?key=OPENAI_API_KEY) | Built-in OpenAI covers ~100 leads/day; your key removes the cap |\n| `SLACK_TOKEN` | Optional | [Connect Slack](/connections) ([docs](https://docs.val.town/guides/slack/send-messages-to-slack/)) | Set automatically | Qualified-lead pings — channel at the top of [outputs/slack.ts](./outputs/slack.ts) |",[170],"319c428c-c8b0-4785-acdf-41faa385294a","utils","d3b96674-808d-11f1-a2d7-1607ee4eb77e",64,["D",1784148205583],"directory",[178],"97ff939e-0e50-48e9-92b2-e1b330d488a3","processing","d2df6c9e-808d-11f1-978e-1607ee4eb77e",62,["D",1784148204143],[185],"239f795e-2e46-4c93-aee0-2b877abd7c36","outputs","d352efc0-808d-11f1-96e7-1607ee4eb77e",63,["D",1784148204925],[191],"a9ae1a9b-3628-4c21-b06f-02f2e1b999e0","inputs","d292f7ec-808d-11f1-8cb9-1607ee4eb77e",61,["D",1784148203624],[197],"pulls","branches","forks","envVars",{"_209":211,"_212":65},"connections",{"_209":164,"_210":65},"count","unfilledCount",3,"emptyCount",{"_44":196,"_32":197,"_30":198,"_160":-5,"_42":43,"_41":199,"_162":61,"_39":323,"_13":65,"_34":182,"_36":-5,"_24":25,"_167":-5,"_230":324,"_27":325},{"_44":315,"_32":316,"_30":317,"_160":198,"_42":43,"_41":318,"_162":61,"_39":319,"_13":164,"_34":249,"_36":320,"_24":25,"_167":-5,"_230":321,"_27":322},{"_44":190,"_32":191,"_30":192,"_160":-5,"_42":43,"_41":193,"_162":61,"_39":312,"_13":65,"_34":182,"_36":-5,"_24":25,"_167":-5,"_230":313,"_27":314},{"_44":307,"_32":282,"_30":276,"_160":192,"_42":43,"_41":308,"_162":61,"_39":309,"_13":65,"_34":182,"_36":-5,"_24":25,"_167":-5,"_230":310,"_27":311},{"_44":299,"_32":300,"_30":301,"_160":276,"_42":43,"_41":302,"_162":25,"_39":303,"_13":65,"_34":35,"_36":304,"_24":25,"_167":-5,"_230":305,"_27":306},{"_44":291,"_32":292,"_30":293,"_160":276,"_42":43,"_41":294,"_162":25,"_39":295,"_13":65,"_34":35,"_36":296,"_24":25,"_167":-5,"_230":297,"_27":298},{"_44":283,"_32":284,"_30":285,"_160":276,"_42":43,"_41":286,"_162":25,"_39":287,"_13":65,"_34":20,"_36":288,"_24":25,"_167":-5,"_230":289,"_27":290},{"_44":273,"_32":274,"_30":275,"_160":276,"_42":43,"_41":277,"_162":25,"_39":278,"_13":65,"_34":35,"_36":279,"_24":25,"_167":-5,"_230":280,"_27":281},{"_44":264,"_32":265,"_30":266,"_160":192,"_42":43,"_41":267,"_162":25,"_39":268,"_13":269,"_34":249,"_36":270,"_24":25,"_167":-5,"_230":271,"_27":272},{"_44":184,"_32":185,"_30":186,"_160":-5,"_42":43,"_41":187,"_162":61,"_39":261,"_13":65,"_34":182,"_36":-5,"_24":25,"_167":-5,"_230":262,"_27":263},{"_44":253,"_32":254,"_30":255,"_160":186,"_42":43,"_41":256,"_162":25,"_39":257,"_13":211,"_34":20,"_36":258,"_24":25,"_167":-5,"_230":259,"_27":260},{"_44":244,"_32":245,"_30":246,"_160":186,"_42":43,"_41":247,"_162":25,"_39":248,"_13":238,"_34":249,"_36":250,"_24":25,"_167":-5,"_230":251,"_27":252},{"_44":177,"_32":178,"_30":179,"_160":-5,"_42":43,"_41":180,"_162":61,"_39":241,"_13":65,"_34":182,"_36":-5,"_24":25,"_167":-5,"_230":242,"_27":243},{"_44":236,"_32":33,"_30":31,"_160":179,"_42":43,"_41":14,"_162":25,"_39":237,"_13":238,"_34":35,"_36":38,"_24":25,"_167":-5,"_230":239,"_27":240},{"_44":169,"_32":170,"_30":171,"_160":-5,"_42":43,"_41":172,"_162":25,"_39":233,"_13":174,"_34":20,"_36":175,"_24":25,"_167":-5,"_230":234,"_27":235},{"_44":158,"_32":159,"_30":59,"_160":-5,"_42":43,"_41":161,"_162":61,"_39":229,"_13":164,"_34":165,"_36":166,"_24":25,"_167":-5,"_230":231,"_27":232},["D",1784148366847],"children",[],[159],["D",1784149818425],[],[170],"1fb48fd7-34ab-4067-8514-141896ee44a8",["D",1784150947585],2,[],[178,33],["D",1784148205583],[226],[178],"264cea89-4a42-46f5-b83e-3192e9a6690a","qualify.ts","f0a873ce-808d-11f1-a453-1607ee4eb77e",90,["D",1784148441349],"interval","// 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 { ValTownOpenAI } from \"https://esm.town/v/std/openai/main.ts\";\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\n// Uses Val Town's built-in OpenAI proxy unless you bring your own key.\nconst apiKey = Deno.env.get(\"OPENAI_API_KEY\");\nconst openai = apiKey ? new OpenAI({ apiKey }) : new ValTownOpenAI({});\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",[],[185,245],"a6ccb075-963e-40e5-88e7-40ccba34ca81","PROMPT.md","e75528d0-808d-11f1-b0cc-1607ee4eb77e",130,["D",1784150793056],"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, exactly this shape — every line concise, one line each. Verdicts: MESSAGE = a founder should DM them this week; NEEDS_ID = hot activity, unknown person.\n\nExample (strong lead):\n\nVerdict: MESSAGE\nDallas Hoffman — Staff Software Engineer\nCompany: [Applied Research Associates](https://www.ara.com) (~2,300)\nWhy: Defense R&D company where on-prem/self-hosted tooling is common.\nOpener: Thanks for starring Mira on Github! I can see how self-hosting could make a lot of sense at ARA. Did you have any questions I could help with?\nLinks: [github](https://github.com/DallasHoff) · [linkedin](https://linkedin.com/in/dallashoff) · dallashoff@gmail.com\n\nExample (not a lead):\n\nVerdict: IGNORE\nRivo Lipp — student\nCompany: [TalTech](https://taltech.ee) (university)\nWhy: Student homelab tinkering, no buying power.\nOpener: Noticed you starred Mira — kicking the tires for a homelab setup?\nLinks: [github](https://github.com/orinocoz) · rivo.lipp@taltech.ee\n\nThe opener is a founder writing to a user: thank them for their specific activity, one clause connecting Mira to their company, end by offering help. Never salesy, never flattery. Omit any line you can't fill honestly.\n\nThe company name itself is the link, pointing at the company's website. No citation parentheticals anywhere — links only where the examples show links.\n",[],[185,254],["D",1784148204143],[223,224],[185],"8b57a5b5-0d5d-4b11-9970-7045a2638fb7","slack.ts","000676b8-808e-11f1-9c99-1607ee4eb77e",128,["D",1784150624815],9,"// cron: send unnotified MESSAGE-verdict cards to Slack (Val Town Slack integration).\n// Main message = one compact line + links (no unfurls); Why + Opener go in a thread.\nimport { WebClient } from \"npm:@slack/web-api\";\nimport slackifyMarkdown from \"https://esm.sh/slackify-markdown@4.1.0\";\nimport { markNotified, unnotifiedMessages } from \"../utils/db.ts\";\n\n// The channel qualified-lead pings land in: #val-town-db-pro\nconst CHANNEL_ID = \"C0BH3EZ7484\";\n\n// Pull the labeled sections out of a card. Cards are markdown with loose\n// formatting, so parse by label, not by line position.\nfunction parseCard(card: string) {\n const section = (label: string) =>\n card.match(new RegExp(`^${label}:\\\\s*([\\\\s\\\\S]*?)(?=\\\\n\\\\s*\\\\n|\\\\n(?:Verdict|Name|Company|Why|Opener|Links):|$)`, \"im\"))?.[1]?.trim();\n const headline = card\n .split(\"\\n\")\n .map((l) => l.trim())\n .find((l) => l && !/^(Verdict|Company):/i.test(l) && l.includes(\"—\"));\n // \"Company: [Name](url) (~size)\" → Slack link; tolerate plain-text company too\n const companyRaw = section(\"Company\");\n const companyMd = companyRaw?.match(/\\[([^\\]]+)\\]\$([^)]+)\$\\s*(.*)/);\n const company = companyMd\n ? `<${companyMd[2]}|${companyMd[1]}>${companyMd[3] ? ` ${companyMd[3]}` : \"\"}`\n : companyRaw;\n const url = (host: string) => card.match(new RegExp(`https?://[^\\\\s)\\\\]·]*${host}[^\\\\s)\\\\]·]*`, \"i\"))?.[0];\n return {\n headline,\n company,\n why: section(\"Why\"),\n opener: section(\"Opener\"),\n github: url(\"github\\\\.com\"),\n linkedin: url(\"linkedin\\\\.com\"),\n email: card.match(/[\\w.+-]+@[\\w-]+\\.[\\w.]+/)?.[0],\n };\n}\n\n// \"⭐ starred + 🐛 issue ×2, last Jul 5\" from the activity JSON\nfunction activitySummary(activityJson: string | null): string | undefined {\n try {\n const acts = JSON.parse(activityJson ?? \"[]\") as { type: string; when?: string }[];\n if (!acts.length) return;\n const emoji: Record = {\n starred: \"⭐ starred\", forked: \"🍴 forked\",\n \"opened issue\": \"🐛 opened issue\", \"opened PR\": \"🔀 opened PR\",\n };\n const counts = new Map();\n for (const a of acts) counts.set(a.type, (counts.get(a.type) ?? 0) + 1);\n const parts = [...counts].map(([t, n]) => `${emoji[t] ?? t}${n > 1 ? ` ×${n}` : \"\"}`);\n const last = acts.map((a) => a.when).filter(Boolean).sort().at(-1);\n return parts.join(\", \") + (last ? ` · last ${last}` : \"\");\n } catch {\n return;\n }\n}\n\nexport default async function () {\n const token = Deno.env.get(\"SLACK_TOKEN\");\n if (!token) return; // no-op until the Slack integration is connected\n\n const slack = new WebClient(token);\n\n const leads = await unnotifiedMessages();\n if (leads.length === 0) return;\n\n // The bot must be in the channel before it can post (no-op if already in).\n await slack.conversations.join({ channel: CHANNEL_ID }).catch(() => {});\n\n for (const lead of leads) {\n const c = parseCard(lead.card ?? \"\");\n const who = [\n `🎯 *${c.headline ?? lead.login}*`,\n c.github && `<${c.github}|GitHub>`,\n c.linkedin && `<${c.linkedin}|LinkedIn>`,\n c.email && ``,\n ].filter(Boolean).join(\" - \");\n const whyOneLiner = c.why?.match(/^.*?[.!?](?=\\s|$)/s)?.[0] ?? c.why;\n\n const main = await slack.chat.postMessage({\n channel: CHANNEL_ID,\n text: [who, c.company, whyOneLiner, activitySummary(lead.activity)]\n .filter(Boolean).join(\"\\n\"),\n unfurl_links: false,\n unfurl_media: false,\n });\n\n // The ready-to-send opener lives in the thread.\n if (c.opener && main.ts) {\n await slack.chat.postMessage({\n channel: CHANNEL_ID,\n thread_ts: main.ts,\n text: slackifyMarkdown(`*Message to send them:*\\n> ${c.opener}`),\n unfurl_links: false,\n unfurl_media: false,\n });\n }\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",[],[191,265],"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",[],[191,282,274],"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",[],[191,282,284],"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",[],[191,282,292],"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",[],[191,282,300],"8edd6668-8bb0-41ec-9c76-f30b60e610d6",70,["D",1784148289445],[217,218,219,220],[191,282],["D",1784148204925],[216,221],[191],"dd36b046-1612-484d-bd5b-82a9b298e6fe","github.ts","fa7f3b30-808d-11f1-80cc-1607ee4eb77e",76,["D",1784148381651],"// 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",[],[197,316],["D",1784148203624],[214],[197],["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":364,"_365":366,"_367":368,"_369":25,"_370":25,"_371":25,"_372":61,"_373":-5,"_374":-7,"_375":-7,"_376":65,"_377":25,"_378":25,"_379":-5,"_380":25,"_381":25,"_382":25,"_383":-5},"ENV",{"_335":336,"_337":338,"_339":92,"_340":341,"_342":343,"_344":345,"_346":347,"_348":349,"_350":351,"_352":353,"_354":355,"_356":357,"_358":359,"_360":361,"_362":363},"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 · v131