[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_340":341,"_342":343},"routes/_app.x.$handle.$name",{"_103":102,"_32":44,"_112":89,"_27":113,"_13":14,"_114":-5,"_11":115,"_116":117,"_118":119,"_120":121,"_122":123,"_20":-5,"_124":125,"_126":127,"_128":26,"_129":130,"_131":24,"_132":-5,"_133":-5,"_134":135},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":26,"_48":49,"_50":49,"_51":52,"_53":54,"_18":55,"_56":57,"_58":24,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":26},"version",123,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":26,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":26},"previous","deleted",true,"deletedHere",false,"path","scratch-slack-cleanup.ts","latestPath","fileId","fbdc8da8-8091-11f1-92e2-1607ee4eb77e","name","fileType","script","content","// Scratch: delete the ugly DallasHoff post + test message, reset his notified flag. DELETE AFTER RUN.\nimport { WebClient } from \"npm:@slack/web-api\";\nimport sqlite from \"https://esm.town/v/std/db/main.ts\";\n\nconst slack = new WebClient(Deno.env.get(\"SLACK_TOKEN\"));\nconst CHANNEL_ID = \"C0BH3EZ7484\";\n\nconst history = await slack.conversations.history({ channel: CHANNEL_ID, limit: 20 });\nfor (const msg of history.messages ?? []) {\n if (msg.text?.includes(\"New qualified lead: DallasHoff\") || msg.text?.includes(\"Test from the GitHub leads val\")) {\n await slack.chat.delete({ channel: CHANNEL_ID, ts: msg.ts! });\n console.log(\"deleted:\", msg.ts, msg.text?.slice(0, 60));\n }\n}\n\nawait sqlite.execute(`UPDATE leads SET notified_at = NULL WHERE login = 'DallasHoff'`);\nconsole.log(\"DallasHoff reset to unnotified\");\n","createdAt",["D",1784149990927],"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=1789577999&sig=4521c8a863a9931fad3c25a530784e4cf9f4bee18aeeaec10d05a3540912e722","a0bf3b31-15a5-4d5c-880e-4b1e22c9bc18","pinnedFileId","019f4e53-354b-724f-878e-e9177d5c065a","pinPreview","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",{"_103":102,"_111":107},"org",{"_103":102,"_104":105,"_106":107,"_18":-5,"_108":109,"_110":24},"branch",{"_13":88,"_32":89,"_42":41,"_90":43,"_91":92,"_93":94,"_95":49,"_96":97,"_98":99,"_100":44,"_101":102},"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",{"_42":43,"_32":44,"_37":335,"_46":-5,"_47":26,"_48":49,"_50":49,"_51":52,"_53":54,"_18":55,"_56":57,"_58":24,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":336,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":337,"_83":338,"_85":339,"_87":26},"tree",[214,216,223,226,228,229,230],"files",[214,215,216,217,218,219,220,221,222,223,224,225,226,227,228,229,230],"counts",{"_203":62,"_204":166,"_205":62,"_206":207,"_208":209},"contents",[149,150,151,152,153,154,155],"upstreamProject",{"_42":97,"_32":145,"_51":146,"_53":54,"_48":49,"_81":147},"upstreamBranch",{"_42":92,"_37":136,"_137":138,"_32":89,"_90":97,"_13":139,"_91":140,"_93":141,"_142":143,"_46":-5,"_87":26,"_48":49,"_101":144,"_63":99,"_100":145},"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",{"_103":144,"_111":148},"https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789577999&sig=aa7aec25480c67f41f9650e8445afc21cf1a6c5fd3969752b90fbd3f6a604c46",{"_42":197,"_32":198,"_30":199,"_157":-5,"_40":41,"_39":200,"_158":24,"_37":201,"_13":62,"_33":183,"_35":-5,"_23":26,"_160":-5,"_27":202},{"_42":191,"_32":192,"_30":193,"_157":-5,"_40":41,"_39":194,"_158":24,"_37":195,"_13":62,"_33":183,"_35":-5,"_23":26,"_160":-5,"_27":196},{"_42":185,"_32":186,"_30":187,"_157":-5,"_40":41,"_39":188,"_158":24,"_37":189,"_13":62,"_33":183,"_35":-5,"_23":26,"_160":-5,"_27":190},{"_42":178,"_32":179,"_30":180,"_157":-5,"_40":41,"_39":181,"_158":24,"_37":182,"_13":62,"_33":183,"_35":-5,"_23":26,"_160":-5,"_27":184},{"_42":170,"_32":171,"_30":172,"_157":-5,"_40":41,"_39":173,"_158":26,"_37":174,"_13":175,"_33":20,"_35":176,"_23":26,"_160":-5,"_27":177},{"_42":162,"_32":163,"_30":57,"_157":-5,"_40":41,"_39":164,"_158":24,"_37":165,"_13":166,"_33":167,"_35":168,"_23":26,"_160":-5,"_27":169},{"_42":156,"_32":28,"_30":31,"_157":-5,"_40":41,"_39":14,"_158":26,"_37":159,"_13":62,"_33":34,"_35":36,"_23":26,"_160":-5,"_27":161},"35a9b24b-161a-44d8-8bdd-6f484b411efe","parentId","latest",["D",1784149990927],"label",[28],"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",[163],"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) |",[171],"319c428c-c8b0-4785-acdf-41faa385294a","utils","d3b96674-808d-11f1-a2d7-1607ee4eb77e",64,["D",1784148205583],"directory",[179],"97ff939e-0e50-48e9-92b2-e1b330d488a3","processing","d2df6c9e-808d-11f1-978e-1607ee4eb77e",62,["D",1784148204143],[186],"239f795e-2e46-4c93-aee0-2b877abd7c36","outputs","d352efc0-808d-11f1-96e7-1607ee4eb77e",63,["D",1784148204925],[192],"a9ae1a9b-3628-4c21-b06f-02f2e1b999e0","inputs","d292f7ec-808d-11f1-8cb9-1607ee4eb77e",61,["D",1784148203624],[198],"pulls","branches","forks","envVars",{"_210":212,"_213":62},"connections",{"_210":166,"_211":62},"count","unfilledCount",3,"emptyCount",{"_42":197,"_32":198,"_30":199,"_157":-5,"_40":41,"_39":200,"_158":24,"_37":332,"_13":62,"_33":183,"_35":-5,"_23":26,"_160":-5,"_232":333,"_27":334},{"_42":324,"_32":325,"_30":326,"_157":199,"_40":41,"_39":327,"_158":24,"_37":328,"_13":166,"_33":258,"_35":329,"_23":26,"_160":-5,"_232":330,"_27":331},{"_42":191,"_32":192,"_30":193,"_157":-5,"_40":41,"_39":194,"_158":24,"_37":321,"_13":62,"_33":183,"_35":-5,"_23":26,"_160":-5,"_232":322,"_27":323},{"_42":316,"_32":291,"_30":285,"_157":193,"_40":41,"_39":317,"_158":24,"_37":318,"_13":62,"_33":183,"_35":-5,"_23":26,"_160":-5,"_232":319,"_27":320},{"_42":308,"_32":309,"_30":310,"_157":285,"_40":41,"_39":311,"_158":26,"_37":312,"_13":62,"_33":34,"_35":313,"_23":26,"_160":-5,"_232":314,"_27":315},{"_42":300,"_32":301,"_30":302,"_157":285,"_40":41,"_39":303,"_158":26,"_37":304,"_13":62,"_33":34,"_35":305,"_23":26,"_160":-5,"_232":306,"_27":307},{"_42":292,"_32":293,"_30":294,"_157":285,"_40":41,"_39":295,"_158":26,"_37":296,"_13":62,"_33":20,"_35":297,"_23":26,"_160":-5,"_232":298,"_27":299},{"_42":282,"_32":283,"_30":284,"_157":285,"_40":41,"_39":286,"_158":26,"_37":287,"_13":62,"_33":34,"_35":288,"_23":26,"_160":-5,"_232":289,"_27":290},{"_42":273,"_32":274,"_30":275,"_157":193,"_40":41,"_39":276,"_158":26,"_37":277,"_13":278,"_33":258,"_35":279,"_23":26,"_160":-5,"_232":280,"_27":281},{"_42":185,"_32":186,"_30":187,"_157":-5,"_40":41,"_39":188,"_158":24,"_37":270,"_13":62,"_33":183,"_35":-5,"_23":26,"_160":-5,"_232":271,"_27":272},{"_42":262,"_32":263,"_30":264,"_157":187,"_40":41,"_39":265,"_158":26,"_37":266,"_13":62,"_33":20,"_35":267,"_23":26,"_160":-5,"_232":268,"_27":269},{"_42":252,"_32":253,"_30":254,"_157":187,"_40":41,"_39":255,"_158":26,"_37":256,"_13":257,"_33":258,"_35":259,"_23":26,"_160":-5,"_232":260,"_27":261},{"_42":178,"_32":179,"_30":180,"_157":-5,"_40":41,"_39":181,"_158":24,"_37":249,"_13":62,"_33":183,"_35":-5,"_23":26,"_160":-5,"_232":250,"_27":251},{"_42":241,"_32":242,"_30":243,"_157":180,"_40":41,"_39":244,"_158":26,"_37":245,"_13":166,"_33":34,"_35":246,"_23":26,"_160":-5,"_232":247,"_27":248},{"_42":170,"_32":171,"_30":172,"_157":-5,"_40":41,"_39":173,"_158":26,"_37":238,"_13":175,"_33":20,"_35":176,"_23":26,"_160":-5,"_232":239,"_27":240},{"_42":162,"_32":163,"_30":57,"_157":-5,"_40":41,"_39":164,"_158":24,"_37":235,"_13":166,"_33":167,"_35":168,"_23":26,"_160":-5,"_232":236,"_27":237},{"_42":156,"_32":28,"_30":31,"_157":-5,"_40":41,"_39":14,"_158":26,"_37":231,"_13":62,"_33":34,"_35":36,"_23":26,"_160":-5,"_232":233,"_27":234},["D",1784149990927],"children",[],[28],["D",1784148366847],[],[163],["D",1784149818425],[],[171],"9fbde764-86a3-4744-a265-6c108c9485d5","db.ts","e0a0b13a-808d-11f1-8fff-1607ee4eb77e",111,["D",1784149086730],"// 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",[],[179,242],["D",1784148205583],[227],[179],"264cea89-4a42-46f5-b83e-3192e9a6690a","qualify.ts","f0a873ce-808d-11f1-a453-1607ee4eb77e",90,["D",1784148441349],2,"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",[],[186,253],"00429835-c119-433a-bb32-14850cf46174","PROMPT.md","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",[],[186,263],["D",1784148204143],[224,225],[186],"6c8b83bb-2580-4bed-9073-d7cd7f24b868","slack.ts","000676b8-808e-11f1-9c99-1607ee4eb77e",122,["D",1784149974805],6,"// 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|Why|Opener|Links):|$)`, \"im\"))?.[1]?.trim();\n const headline = card\n .split(\"\\n\")\n .map((l) => l.trim())\n .find((l) => l && !/^Verdict:/i.test(l) && l.includes(\"—\"));\n const url = (host: string) => card.match(new RegExp(`https?://[^\\\\s)\\\\]·]*${host}[^\\\\s)\\\\]·]*`, \"i\"))?.[0];\n return {\n headline,\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\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 links = [\n c.github && `<${c.github}|GitHub>`,\n c.linkedin && `<${c.linkedin}|LinkedIn>`,\n c.email && ``,\n ].filter(Boolean).join(\" · \");\n\n const main = await slack.chat.postMessage({\n channel: CHANNEL_ID,\n text: `🎯 *${c.headline ?? lead.login}*${links ? `\\n${links}` : \"\"}`,\n unfurl_links: false,\n unfurl_media: false,\n });\n\n // Details in a thread so the channel stays scannable.\n const details = [c.why && `*Why:* ${c.why}`, c.opener && `*Suggested opener:* ${c.opener}`]\n .filter(Boolean).join(\"\\n\\n\");\n if (details && main.ts) {\n await slack.chat.postMessage({\n channel: CHANNEL_ID,\n thread_ts: main.ts,\n text: slackifyMarkdown(details),\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",[],[192,274],"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",[],[192,291,283],"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",[],[192,291,293],"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",[],[192,291,301],"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",[],[192,291,309],"8edd6668-8bb0-41ec-9c76-f30b60e610d6",70,["D",1784148289445],[218,219,220,221],[192,291],["D",1784148204925],[217,222],[192],"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",[],[198,325],["D",1784148203624],[215],[198],["D",1783725503703],["D",1789526460011],{"_103":102,"_111":107},{"_103":102,"_104":105,"_106":107,"_18":-5,"_108":109,"_110":24},{"_13":88,"_32":89,"_42":41,"_90":43,"_91":92,"_93":94,"_95":49,"_96":97,"_98":99,"_100":44,"_101":102},"ctx",{"_81":-5,"_133":373,"_374":375,"_376":377,"_378":26,"_379":26,"_380":26,"_381":24,"_382":-5,"_383":-7,"_384":-7,"_385":62,"_386":26,"_387":26,"_388":-5,"_389":26,"_390":26,"_391":26,"_392":-5},"ENV",{"_344":345,"_346":347,"_348":89,"_349":350,"_351":352,"_353":354,"_355":356,"_357":358,"_359":360,"_361":362,"_363":364,"_365":366,"_367":368,"_369":370,"_371":372},"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 · v123