[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_281":282,"_283":284},"routes/_app.x.$handle.$name",{"_104":103,"_33":46,"_113":91,"_28":114,"_13":14,"_115":-5,"_11":116,"_117":118,"_119":120,"_121":122,"_123":124,"_20":-5,"_125":126,"_127":128,"_129":27,"_130":131,"_132":25,"_133":-5,"_134":-5,"_135":136},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_33":46,"_39":47,"_48":-5,"_49":27,"_50":51,"_52":51,"_53":54,"_55":56,"_18":57,"_58":59,"_60":25,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":72,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":84,"_85":86,"_87":88,"_89":27},"version",100,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":27,"_28":29,"_30":29},"file",{"_31":32,"_33":29,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":27},"previous",{"_31":32,"_33":29,"_34":35,"_36":37},"deleted",true,"deletedHere",false,"path","digest.ts","latestPath","fileId","17e6dc20-ed75-11f0-abee-42dde27851f2","name","fileType","interval","content","import { email } from \"https://esm.town/v/std/email\";\nimport { httpEndpoint } from \"https://esm.town/v/std/utils/index.ts\";\nimport { getAllLeads } from \"./db.ts\";\n\n// ============================================================================\n// CONFIGURE: Add email addresses to receive the daily digest\n// ============================================================================\nconst RECIPIENTS = [\n \"steve@val.town\",\n \"charlie@val.town\",\n];\n\nfunction getSource(inputData) {\n const input = typeof inputData === \"string\"\n ? JSON.parse(inputData)\n : inputData;\n const first = Array.isArray(input) ? input[0] : input;\n if (first?.actor?.login) return \"github\";\n if (first?._query?.source) return first._query.source;\n return null;\n}\n\nfunction getRepos(inputData): string[] {\n const input = typeof inputData === \"string\"\n ? JSON.parse(inputData)\n : inputData;\n const events = Array.isArray(input) ? input : [input];\n const repos = new Set();\n for (const event of events) {\n if (event?.repo?.name) {\n repos.add(event.repo.name);\n }\n }\n return Array.from(repos);\n}\n\nfunction formatHTML(matches, dashboardUrl) {\n const typeStyles: Record = {\n customer: { bg: \"#d1fae5\", color: \"#047857\" },\n hire: { bg: \"#ede9fe\", color: \"#6d28d9\" },\n };\n\n const rows = matches.map((l) => {\n const scoreDisplay = l.score\n ? `${l.score}`\n : \"\";\n\n const leadTypesDisplay = l.leadTypes && l.leadTypes.length > 0\n ? l.leadTypes.map((type: string) => {\n const style = typeStyles[type] || { bg: \"#f3f4f6\", color: \"#374151\" };\n return `${type}`;\n }).join(\"\")\n : \"\";\n\n const sourceTag = l.source\n ? `${l.source}`\n : \"\";\n\n const reposDisplay = l.repos && l.repos.length > 0\n ? `

${\n l.repos.map((repo: string) =>\n `📦 ${\n repo.split(\"/\")[1]\n }`\n ).join(\"\")\n }

`\n : \"\";\n\n return `\n \n \n

\n ${scoreDisplay}${l.name} ${leadTypesDisplay}${sourceTag}\n

\n ${l.reasoning}\n

\n ${reposDisplay}\n \n \n `;\n }).join(\"\");\n\n return `\n \n \n \n \n

🎯 ${matches.length} Qualified Lead${\n matches.length !== 1 ? \"s\" : \"\"\n }

\n \n \n ${rows}\n \n

\n View dashboard\n

\n \n \n `;\n}\n\nexport default async function (interval?: { lastRunAt?: Date }) {\n console.log(\"interval received:\", JSON.stringify(interval));\n\n if (RECIPIENTS.length === 0) {\n console.log(\"No RECIPIENTS configured in digest.ts, skipping email\");\n return { sent: false, reason: \"no_recipients\" };\n }\n\n const dashboardUrl = await httpEndpoint(\"main.ts\", import.meta.url);\n const since = interval?.lastRunAt?.getTime() ??\n Date.now() - 24 * 60 * 60 * 1000;\n\n console.log(\"looking back to:\", new Date(since).toISOString());\n\n const leads = await getAllLeads();\n console.log(\"total leads in db:\", leads.length);\n\n const matches = leads\n .filter((l) => l.timestamp > since)\n .filter((l) => JSON.parse(l.output_data).match)\n .map((l) => ({\n id: l.id,\n source: getSource(l.input_data),\n repos: getRepos(l.input_data),\n ...JSON.parse(l.output_data),\n }))\n .sort((a, b) => (b.score ?? 0) - (a.score ?? 0));\n\n console.log(\"matches found:\", matches.length);\n\n if (matches.length === 0) {\n console.log(\"No matches since\", new Date(since).toISOString());\n return { sent: false };\n }\n\n const subject = `🎯 ${matches.length} Qualified Lead${\n matches.length !== 1 ? \"s\" : \"\"\n }`;\n await email({\n to: RECIPIENTS,\n subject,\n html: formatHTML(matches, dashboardUrl),\n });\n\n console.log(\n `Sent digest: ${matches.length} leads to ${RECIPIENTS.join(\", \")}`,\n );\n return { sent: true, count: matches.length };\n}","import { email } from \"https://esm.town/v/std/email\";\nimport { httpEndpoint } from \"https://esm.town/v/std/utils/index.ts\";\nimport { getAllLeads } from \"./db.ts\";\n\n// ============================================================================\n// CONFIGURE: Set the DIGEST_RECIPIENTS env var to a comma-separated list of\n// email addresses to receive the daily digest\n// ============================================================================\nconst RECIPIENTS = (Deno.env.get(\"DIGEST_RECIPIENTS\") ?? \"\")\n .split(\",\")\n .map((s) => s.trim())\n .filter(Boolean);\n\nfunction getSource(inputData) {\n const input = typeof inputData === \"string\"\n ? JSON.parse(inputData)\n : inputData;\n const first = Array.isArray(input) ? input[0] : input;\n if (first?.actor?.login) return \"github\";\n if (first?._query?.source) return first._query.source;\n return null;\n}\n\nfunction getRepos(inputData): string[] {\n const input = typeof inputData === \"string\"\n ? JSON.parse(inputData)\n : inputData;\n const events = Array.isArray(input) ? input : [input];\n const repos = new Set();\n for (const event of events) {\n if (event?.repo?.name) {\n repos.add(event.repo.name);\n }\n }\n return Array.from(repos);\n}\n\nfunction formatHTML(matches, dashboardUrl) {\n const typeStyles: Record = {\n customer: { bg: \"#d1fae5\", color: \"#047857\" },\n hire: { bg: \"#ede9fe\", color: \"#6d28d9\" },\n };\n\n const rows = matches.map((l) => {\n const scoreDisplay = l.score\n ? `${l.score}`\n : \"\";\n\n const leadTypesDisplay = l.leadTypes && l.leadTypes.length > 0\n ? l.leadTypes.map((type: string) => {\n const style = typeStyles[type] || { bg: \"#f3f4f6\", color: \"#374151\" };\n return `${type}`;\n }).join(\"\")\n : \"\";\n\n const sourceTag = l.source\n ? `${l.source}`\n : \"\";\n\n const reposDisplay = l.repos && l.repos.length > 0\n ? `

${\n l.repos.map((repo: string) =>\n `📦 ${\n repo.split(\"/\")[1]\n }`\n ).join(\"\")\n }

`\n : \"\";\n\n return `\n \n \n

\n ${scoreDisplay}${l.name} ${leadTypesDisplay}${sourceTag}\n

\n ${l.reasoning}\n

\n ${reposDisplay}\n \n \n `;\n }).join(\"\");\n\n return `\n \n \n \n \n

🎯 ${matches.length} Qualified Lead${\n matches.length !== 1 ? \"s\" : \"\"\n }

\n \n \n ${rows}\n \n

\n View dashboard\n

\n \n \n `;\n}\n\nexport default async function (interval?: { lastRunAt?: Date }) {\n console.log(\"interval received:\", JSON.stringify(interval));\n\n if (RECIPIENTS.length === 0) {\n console.log(\n \"No recipients configured — set the DIGEST_RECIPIENTS env var to a comma-separated list of email addresses to receive the digest\",\n );\n return { sent: false, reason: \"no_recipients\" };\n }\n\n const dashboardUrl = await httpEndpoint(\"main.ts\", import.meta.url);\n const since = interval?.lastRunAt?.getTime() ??\n Date.now() - 24 * 60 * 60 * 1000;\n\n console.log(\"looking back to:\", new Date(since).toISOString());\n\n const leads = await getAllLeads();\n console.log(\"total leads in db:\", leads.length);\n\n const matches = leads\n .filter((l) => l.timestamp > since)\n .filter((l) => JSON.parse(l.output_data).match)\n .map((l) => ({\n id: l.id,\n source: getSource(l.input_data),\n repos: getRepos(l.input_data),\n ...JSON.parse(l.output_data),\n }))\n .sort((a, b) => (b.score ?? 0) - (a.score ?? 0));\n\n console.log(\"matches found:\", matches.length);\n\n if (matches.length === 0) {\n console.log(\"No matches since\", new Date(since).toISOString());\n return { sent: false };\n }\n\n const subject = `🎯 ${matches.length} Qualified Lead${\n matches.length !== 1 ? \"s\" : \"\"\n }`;\n await email({\n to: RECIPIENTS,\n subject,\n html: formatHTML(matches, dashboardUrl),\n });\n\n console.log(\n `Sent digest: ${matches.length} leads to ${RECIPIENTS.join(\", \")}`,\n );\n return { sent: true, count: matches.length };\n}\n","createdAt",["D",1783610746961],"branchVersion","branchId","2beae49c-ed74-11f0-997b-42dde27851f2","id","2be6e306-ed74-11f0-997b-42dde27851f2","github-leads",["D",1767974365657],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Find customers to sell to from GitHub activity","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/aeec28de-dccc-49ab-3dcc-66b67afd7700/square512?exp=1789563599&sig=ef6a334b33630aab9f9bb7731b1a602f08e7d9571f7df27f1cf59fa04c34b2ee","9319c175-2593-4f88-ba21-04f2ef7b1c28","pinnedFileId","019ba37b-ea2b-73cf-99fb-0144463ae288","pinPreview","pinMigrated","screenshotVersion","likeCount",3,"orgId","019aa807-52c2-709c-928b-2029bae9a558","tursoName","2be6e306ed7411f0997b42dde27851f2","tursoHostname","2be6e306ed7411f0997b42dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789542098478],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_104":103,"_112":108},"org",{"_104":103,"_105":106,"_107":108,"_18":-5,"_109":110,"_111":25},"branch",{"_13":90,"_33":91,"_44":43,"_92":45,"_93":94,"_95":96,"_97":51,"_98":99,"_100":66,"_101":46,"_102":103},"isOwned",146,"main","projectId","forkedBranchId","6b736e3c-daf9-11f0-9e58-42dde27851f2","forkedBranchVersion",138,"forkedProjectPrivacy","forkedProjectId","6b7157fa-daf9-11f0-9e58-42dde27851f2","forkedProjectOrgId","projectName","userHandle","templates","handle","displayName","Templates","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789563599&sig=a969511699ef574c42d646a130422bcd8ffa020e1e59bd8fb5bde6db2cea72c1","tier","business","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_44":45,"_33":46,"_39":276,"_48":-5,"_49":27,"_50":51,"_52":51,"_53":54,"_55":56,"_18":57,"_58":59,"_60":25,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":277,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":278,"_85":279,"_87":280,"_89":27},"tree",[239,240,241,242,243,244,245,246,247],"files",[239,240,241,242,243,244,245,246,247],"counts",{"_226":227,"_228":229,"_230":231,"_232":233,"_234":235},"contents",[147,148,149,150,151,152,153,154,155],"upstreamProject",{"_44":99,"_33":143,"_53":144,"_55":145,"_50":51,"_83":146},"upstreamBranch",{"_44":94,"_39":137,"_138":139,"_33":91,"_92":99,"_13":140,"_93":-5,"_95":-5,"_141":142,"_48":-5,"_89":27,"_50":51,"_102":103,"_65":66,"_101":143},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1765942523251],"updatedAt",["D",1783725702215],144,"lockfileKey","1783725702296-esm.town_v_templates_leads@144-main","leads","Lead qualifying from any data source","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/dbb4ad1d-cd97-4466-848f-80ed9f1be300/square512?exp=1789563599&sig=a4d1018bd95f87311f12647c1c1e1679a7840a2fa299d2d396b91ddefac515e6",{"_104":103,"_112":108},{"_44":219,"_33":220,"_31":221,"_159":-5,"_42":43,"_41":222,"_161":27,"_39":223,"_13":216,"_34":20,"_36":224,"_24":27,"_166":-5,"_28":225},{"_44":211,"_33":212,"_31":213,"_159":-5,"_42":43,"_41":214,"_161":27,"_39":215,"_13":216,"_34":20,"_36":217,"_24":27,"_166":-5,"_28":218},{"_44":204,"_33":205,"_31":206,"_159":-5,"_42":43,"_41":207,"_161":27,"_39":208,"_13":201,"_34":164,"_36":209,"_24":27,"_166":-5,"_28":210},{"_44":196,"_33":197,"_31":198,"_159":-5,"_42":43,"_41":199,"_161":27,"_39":200,"_13":201,"_34":164,"_36":202,"_24":27,"_166":-5,"_28":203},{"_44":188,"_33":189,"_31":190,"_159":-5,"_42":43,"_41":191,"_161":27,"_39":192,"_13":193,"_34":164,"_36":194,"_24":27,"_166":-5,"_28":195},{"_44":184,"_33":29,"_31":32,"_159":-5,"_42":43,"_41":14,"_161":27,"_39":185,"_13":186,"_34":35,"_36":38,"_24":27,"_166":-5,"_28":187},{"_44":176,"_33":177,"_31":178,"_159":-5,"_42":43,"_41":179,"_161":27,"_39":180,"_13":181,"_34":35,"_36":182,"_24":27,"_166":-5,"_28":183},{"_44":168,"_33":169,"_31":59,"_159":-5,"_42":43,"_41":170,"_161":27,"_39":171,"_13":64,"_34":172,"_36":173,"_24":27,"_166":174,"_28":175},{"_44":156,"_33":157,"_31":158,"_159":-5,"_42":43,"_41":160,"_161":27,"_39":162,"_13":163,"_34":164,"_36":165,"_24":27,"_166":-5,"_28":167},"560cf52a-edb1-11f0-afb8-42dde27851f2","welcome-ui.tsx","019ba37b-ea2b-73cf-99fb-062784208fe8","parentId",85,"latest",["D",1768000635708],5,"script","/** @jsxImportSource npm:hono@4/jsx */\nimport { processLead } from \"./agent.ts\";\nimport { GITHUB_ORG } from \"./github.cron.ts\";\n\nconst ACTIVITY_TYPES = [\n { value: \"WatchEvent\", label: \"⭐ Star\" },\n { value: \"ForkEvent\", label: \"🍴 Fork\" },\n { value: \"IssuesEvent\", label: \"📝 Issue\" },\n { value: \"PullRequestEvent\", label: \"🔀 PR\" },\n];\n\nfunction createMockEvent(username: string, activityType: string, org: string) {\n const now = new Date().toISOString();\n const repoName = `${org}/example-repo`;\n\n const baseEvent = {\n id: `mock-${Date.now()}`,\n type: activityType,\n actor: {\n id: 0,\n login: username,\n display_login: username,\n gravatar_id: \"\",\n url: `https://api.github.com/users/${username}`,\n avatar_url: `https://github.com/${username}.png`,\n },\n repo: {\n id: 0,\n name: repoName,\n url: `https://api.github.com/repos/${repoName}`,\n },\n public: true,\n created_at: now,\n org: {\n id: 0,\n login: org,\n gravatar_id: \"\",\n url: `https://api.github.com/orgs/${org}`,\n avatar_url: `https://github.com/${org}.png`,\n },\n };\n\n switch (activityType) {\n case \"WatchEvent\":\n return { ...baseEvent, payload: { action: \"started\" } };\n case \"ForkEvent\":\n return {\n ...baseEvent,\n payload: {\n forkee: { full_name: `${username}/${repoName.split(\"/\")[1]}` },\n },\n };\n case \"IssuesEvent\":\n return {\n ...baseEvent,\n payload: {\n action: \"opened\",\n issue: { number: 1, title: \"Example issue\" },\n },\n };\n case \"PullRequestEvent\":\n return {\n ...baseEvent,\n payload: {\n action: \"opened\",\n pull_request: { number: 1, title: \"Example PR\" },\n },\n };\n default:\n return baseEvent;\n }\n}\n\nexport async function handleTestRequest(req: Request): Promise {\n try {\n const { username, activityType } = await req.json();\n\n if (!username || !activityType) {\n return Response.json({ error: \"Missing username or activityType\" }, {\n status: 400,\n });\n }\n\n const mockEvent = createMockEvent(username, activityType, GITHUB_ORG);\n const result = await processLead([mockEvent]);\n\n return Response.json({\n success: true,\n message: \"Lead processed! Refresh to see results.\",\n result,\n });\n } catch (error) {\n console.error(\"Test request error:\", error);\n return Response.json({ error: error.message }, { status: 500 });\n }\n}\n\ninterface WelcomePanelProps {\n testEndpoint: string;\n}\n\nexport function WelcomePanel({ testEndpoint }: WelcomePanelProps) {\n const scriptData = JSON.stringify({ testEndpoint });\n\n return (\n

\n \n Simulate Activity:\n \n @\n \n \n {ACTIVITY_TYPES.map((type) => (\n \n ))}\n \n \n Run\n \n \n

\n\n \n

\n );\n}","label",[157],"7994bd6e-ed77-11f0-b27b-42dde27851f2","main.ts",39,["D",1767975784500],"http","import { Hono } from \"npm:hono@4\";\nimport { processLead, reanalyzeLead } from \"./agent.ts\";\nimport { app as dashboard } from \"./dashboard.tsx\";\nimport { handleTestRequest } from \"./welcome-ui.tsx\";\n\nconst app = new Hono();\n\napp.post(\"/\", async (c) => {\n // Early API key check to avoid confusing when using the tester ui\n if (!Deno.env.get(\"OPENAI_API_KEY\")) {\n return c.json(\n { error: \"Add OPENAI_API_KEY in Environment Variables\" },\n 503,\n );\n }\n\n const body = await c.req.json();\n const url = new URL(c.req.url);\n const query = Object.fromEntries(url.searchParams);\n const inputData = Object.keys(query).length\n ? { ...body, _query: query }\n : body;\n\n // Fire-and-forget request for quick response and processing in another 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(inputData),\n });\n\n return c.json({ ok: true });\n});\n\napp.post(\"/process\", async (c) => {\n const inputData = await c.req.json();\n await processLead(inputData);\n return c.json({ ok: true });\n});\n\n// Test endpoint for the welcome UI\napp.post(\"/test\", async (c) => {\n if (!Deno.env.get(\"OPENAI_API_KEY\")) {\n return c.json(\n { error: \"Add OPENAI_API_KEY in Environment Variables\" },\n 503,\n );\n }\n return handleTestRequest(c.req.raw);\n});\n\n// Reanalyze a lead\napp.post(\"/lead/:id/reanalyze\", async (c) => {\n if (!Deno.env.get(\"OPENAI_API_KEY\")) {\n return c.json(\n { error: \"Add OPENAI_API_KEY in Environment Variables\" },\n 503,\n );\n }\n \n const id = parseInt(c.req.param(\"id\"));\n if (isNaN(id)) {\n return c.json({ error: \"Invalid lead ID\" }, { status: 400 });\n }\n \n try {\n const result = await reanalyzeLead(id);\n return c.json({ ok: true, ...result });\n } catch (error) {\n return c.json({ error: error.message }, { status: 500 });\n }\n});\n\napp.route(\"/\", dashboard);\n\nexport default app.fetch;\n","githubleads",[169],"4e7382cc-23ce-11f1-87b3-42dde27851f2","github.cron.ts","81346198-ed75-11f0-a2b0-42dde27851f2",99,["D",1773950441144],40,"import { processLead } from \"./agent.ts\";\nimport { appendFollowup, findLeadByInputPath } from \"./db.ts\";\nimport { Octokit } from \"npm:octokit@5.0.5\";\n\nexport const GITHUB_ORG = \"val-town\";\n\nexport default async function (interval: Interval) {\n const lastChecked = interval.lastRunAt ?? new Date(0);\n\n const octokit = new Octokit({ auth: Deno.env.get(\"GITHUB_TOKEN\") });\n const recentEvents = await octokit.paginate(\n octokit.rest.activity.listPublicOrgEvents,\n { org: GITHUB_ORG, per_page: 100 },\n );\n\n const newEvents = recentEvents\n .filter((e: any) => new Date(e.created_at) > lastChecked)\n .filter((e: any) => e.actor?.login && !e.actor?.login.includes(\"[bot]\"));\n console.log(`Processing ${newEvents.length} new events`);\n\n const actorEvents = Map.groupBy(newEvents, (e) => e.actor.login);\n console.log(`Found ${actorEvents.size} users`);\n\n await Promise.all(\n Array.from(actorEvents, async ([login, events]) => {\n const existingLead = await findLeadByInputPath(\"actor.login\", login);\n if (existingLead) {\n await appendFollowup(existingLead.id, events);\n } else {\n await processLead(events);\n }\n }),\n );\n}",[177],"9bba1bbc-c80f-4aa2-ac1b-565cbf25bbb6",["D",1783610746961],8,[29],"67d01cae-23cd-11f1-a7d8-42dde27851f2","db.ts","019ba37b-ea2b-73cf-99fa-ffb3027e4471",97,["D",1773950054188],9,"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nconst TABLE_NAME = \"github_leads_v4\";\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 storeLead(\n inputData: Record | Record[],\n outputData: Record,\n) {\n // Always store as array\n const inputArray = Array.isArray(inputData) ? inputData : [inputData];\n await sqlite.execute(\n `INSERT INTO ${TABLE_NAME} (timestamp, input_data, output_data)\n VALUES (?, ?, ?)`,\n [Date.now(), JSON.stringify(inputArray), JSON.stringify(outputData)],\n );\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 result.rows as unknown as Lead[];\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 return result.rows[0] as unknown as Lead;\n}\n\nexport async function findLeadByInputPath(\n path: string,\n value: string,\n): Promise {\n const leads = await getAllLeads();\n return leads.find((lead) => {\n const input = JSON.parse(lead.input_data);\n // Check first event in array for the path\n const firstEvent = Array.isArray(input) ? input[0] : input;\n return path.split(\".\").reduce((obj, key) => obj?.[key], firstEvent) ===\n value;\n }) || null;\n}\n\nexport async function appendFollowup(\n id: number,\n data: Record | Record[],\n) {\n const lead = await getLeadById(id);\n const input = JSON.parse(lead!.input_data);\n const events = Array.isArray(input) ? input : [input];\n const newEvents = Array.isArray(data) ? data : [data];\n\n // Deduplicate by event ID to prevent unbounded growth\n const existingIds = new Set(events.map((e: any) => e.id).filter(Boolean));\n const uniqueNew = newEvents.filter((e: any) => !e.id || !existingIds.has(e.id));\n\n events.push(...uniqueNew);\n await sqlite.execute(\n `UPDATE ${TABLE_NAME} SET input_data = ? WHERE id = ?`,\n [JSON.stringify(events), id],\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}",[189],"285cdfe6-f0b8-11f0-b725-42dde27851f2","dashboard.tsx","019ba37b-ea2b-73cf-99fa-fb45726c3a35",89,["D",1768333419019],10,"/** @jsxImportSource npm:hono@4/jsx */\nimport { Hono } from \"npm:hono@4\";\nimport { getAllLeads, getLeadById, Lead } from \"./db.ts\";\nimport { WelcomePanel } from \"./welcome-ui.tsx\"; // DELETE THIS LINE to remove onboarding UI\nimport { marked } from \"npm:marked@11\";\n\nexport const app = new Hono();\n\nfunction getRepos(input: unknown): string[] {\n const events = Array.isArray(input) ? input : [input];\n const repos = new Set();\n for (const event of events) {\n if (event?.repo?.name) {\n repos.add(event.repo.name);\n }\n }\n return Array.from(repos);\n}\n\nfunction getSource(input: unknown): string | null {\n const first = Array.isArray(input) ? input[0] : input;\n if (first?.actor?.login) return \"github\";\n if (first?._query?.source) return first._query.source;\n return null;\n}\n\nfunction getUsername(input: unknown): string | null {\n const first = Array.isArray(input) ? input[0] : input;\n return first?.actor?.login || null;\n}\n\nfunction ReposList({ repos }: { repos: string[] }) {\n if (repos.length === 0) return null;\n return (\n

\n Repositories ({repos.length})\n

\n {repos.map((repo) => (\n \n \n {repo}\n \n ))}\n

\n );\n}\n\nfunction Layout({ children, title }: { children: any; title: string }) {\n return (\n \n \n \n \n {title}\n \n \n \n {children}\n \n );\n}\n\nfunction SourceBadge({ source }: { source: string | null }) {\n if (!source) return null;\n\n if (source === \"github\") {\n return (\n \n \n GitHub\n \n );\n }\n\n return (\n \n {source}\n \n );\n}\n\nfunction ScoreBadge({ score }: { score?: number }) {\n if (score === undefined || score === null) return null;\n\n const color = score >= 70\n ? \"bg-blue-100 text-blue-700\"\n : score >= 50\n ? \"bg-amber-100 text-amber-700\"\n : \"bg-gray-100 text-gray-500\";\n\n return (\n \n {score}\n \n );\n}\n\nfunction LeadTypeBadges({ leadTypes }: { leadTypes?: string[] }) {\n if (!leadTypes || leadTypes.length === 0) return null;\n\n const typeStyles: Record = {\n customer: \"bg-emerald-100 text-emerald-700\",\n hire: \"bg-purple-100 text-purple-700\",\n };\n\n return (\n <>\n {leadTypes.map((type) => (\n \n {type}\n \n ))}\n \n );\n}\n\nfunction LeadRow({ lead, isMatch }: { lead: Lead; isMatch: boolean }) {\n const output = JSON.parse(lead.output_data);\n const input = JSON.parse(lead.input_data);\n const eventCount = Array.isArray(input) ? input.length : 1;\n const source = getSource(input);\n const date = new Date(lead.timestamp).toLocaleDateString(\"en-US\", {\n month: \"short\",\n day: \"numeric\",\n year: \"numeric\",\n });\n\n return (\n \n \n \n \n {output.name || \"Unknown\"}\n \n \n \n {eventCount > 1 && (\n \n {eventCount}\n \n )}\n {date}\n \n );\n}\n\nconst Arrow = () => (\n \n \n \n);\n\nfunction DataValue(\n { value, path, keyName }: { value: unknown; path: string; keyName?: string },\n) {\n if (value === null || value === undefined) {\n return (\n \n {keyName && {keyName}:}\n null\n \n );\n }\n\n if (typeof value !== \"object\") {\n return (\n \n {keyName && {keyName}:}\n {String(value)}\n \n );\n }\n\n if (Array.isArray(value)) {\n if (value.length === 0) {\n return (\n \n {keyName && {keyName}:}\n []\n \n );\n }\n const id = `arr-${path}`;\n return (\n

\n \n \n {keyName && {keyName}}\n [{value.length}]\n

\n {value.map((item, idx) => (\n

\n \n

\n ))}\n

\n \n );\n }\n\n const entries = Object.entries(value);\n if (entries.length === 0) {\n return (\n \n {keyName && {keyName}:}\n {\"{}\"}\n \n );\n }\n const id = `obj-${path}`;\n return (\n

\n \n \n {keyName && {keyName}}\n {`{${entries.length}}`}\n

\n {entries.map(([k, v]) => (\n

\n \n

\n ))}\n

\n \n );\n}\n\nfunction DataTable({ title, data }: { title: string; data: unknown }) {\n if (data === null || data === undefined) return null;\n\n if (Array.isArray(data)) {\n return (\n

\n {title} ({data.length})\n

\n {data.map((item, idx) => (\n

Event {idx + 1}

\n {Object.entries(item).map(([k, v]) => (\n

\n \n

\n ))}\n

\n );\n }\n\n const entries = Object.entries(data as Record);\n if (entries.length === 0) return null;\n\n return (\n

\n {title}\n

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

\n \n

\n ))}\n

\n );\n}\n\napp.get(\"/\", async (c) => {\n const leads = await getAllLeads();\n const baseUrl = new URL(c.req.url).origin;\n const testEndpoint = `${baseUrl}/test`;\n\n const matches = leads.filter((l) => JSON.parse(l.output_data).match === true);\n const nonMatches = leads.filter((l) =>\n JSON.parse(l.output_data).match !== true\n );\n\n return c.html(\n \n

\n \n\n

GitHub Leads

\n \n view source\n \n

\n {leads.length} leads · {matches.length} matches\n

\n\n {leads.length === 0\n ? (\n

\n No leads yet. Configure your GitHub org and wait for activity, or\n use \"Try It Out\" above.\n

\n )\n : (\n

\n {matches.map((lead) => )}\n\n {nonMatches.length > 0 && (\n

\n \n {nonMatches.length} not matched\n v\n \n

\n {nonMatches.map((lead) => (\n \n ))}\n

\n )}\n

\n ,\n );\n});\n\napp.get(\"/lead/:id\", async (c) => {\n const id = parseInt(c.req.param(\"id\"));\n const lead = await getLeadById(id);\n\n if (!lead) {\n return c.html(\n \n

Lead Not Found

\n \n ← Back\n \n

\n ,\n 404,\n );\n }\n\n const input = JSON.parse(lead.input_data);\n const output = JSON.parse(lead.output_data);\n const repos = getRepos(input);\n const source = getSource(input);\n const username = getUsername(input);\n\n return c.html(\n \n

\n \n ← Back\n \n\n

\n {output.name || \"Unknown\"}\n

\n \n \n \n

\n {username && (\n \n @{username}\n \n )}\n

\n {new Date(lead.timestamp).toLocaleString()}\n {output.cost != null && ` · ${output.cost.toFixed(4)}`}\n

\n\n {/* Result Summary */}\n \n

\n \n \n {output.match ? \"Match\" : \"No Match\"}\n \n

\n \n

\n\n {/* Reanalyze Button */}\n

\n location.reload())`}\n class=\"px-4 py-2 bg-gray-100 hover:bg-gray-200 text-gray-700 border border-gray-200 disabled:opacity-50 font-medium rounded-lg text-sm\"\n >\n Reanalyze\n \n

\n\n {/* GitHub Repositories */}\n \n\n {/* AI Output first */}\n \n\n {/* Input Data second */}\n \n \n ,\n );\n});\n\nexport default app.fetch;",[197],"0593d7fe-222b-11f1-9b12-42dde27851f2","agent.ts","019ba37b-ea2b-73cf-99fa-f65a711e51a7",95,["D",1773770359757],"import { readFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { Agent, run, RunResult, webSearchTool } from \"npm:@openai/agents@0.7\";\nimport { getLeadById, storeLead, updateLeadOutput } from \"./db.ts\";\n\nconst PROMPT = await readFile(\"/PROMPT.txt\");\nconst agent = new Agent({\n name: \"Researcher\",\n model: \"gpt-5\",\n tools: [webSearchTool()],\n instructions: PROMPT,\n});\n\nfunction calculateCost(result: RunResult): number {\n // GPT-5 pricing (verified rates as of January 2026)\n const COST_PER_INPUT_TOKEN = 0.00000125; // $1.25 per 1M tokens\n const COST_PER_CACHED_INPUT_TOKEN = 0.000000125; // $0.125 per 1M tokens (90% discount)\n const COST_PER_OUTPUT_TOKEN = 0.00001; // $10 per 1M tokens\n\n const usage = result.state._context.usage;\n const inputTokens = usage.inputTokens || 0;\n const cachedInputTokens = usage.inputTokensDetails[0].cached_tokens || 0;\n const outputTokens = usage.outputTokens || 0;\n\n console.log(\"result.state\", result.state);\n console.log(\"result.state._context.usage\", usage);\n\n // Calculate cost: subtract cached tokens from regular input if both are provided\n const regularInputTokens = inputTokens - cachedInputTokens;\n const cost = (regularInputTokens * COST_PER_INPUT_TOKEN) +\n (cachedInputTokens * COST_PER_CACHED_INPUT_TOKEN) +\n (outputTokens * COST_PER_OUTPUT_TOKEN);\n\n console.log(\"Cost breakdown:\", {\n regularInputTokens,\n cachedInputTokens,\n outputTokens,\n cost,\n });\n\n return cost;\n}\n\nasync function analyzeLead(inputData: any) {\n const result = await run(agent, JSON.stringify(inputData));\n const outputData = JSON.parse(result.finalOutput);\n outputData.cost = calculateCost(result);\n return outputData;\n}\n\nexport async function processLead(inputData: any) {\n const outputData = await analyzeLead(inputData);\n await storeLead(inputData, outputData);\n console.log(outputData);\n return { outputData };\n}\n\nexport async function reanalyzeLead(id: number) {\n const lead = await getLeadById(id);\n if (!lead) throw new Error(`Lead ${id} not found`);\n\n const outputData = await analyzeLead(lead.input_data);\n await updateLeadOutput(id, outputData);\n return { outputData };\n}",[205],"5510e474-ed8e-11f0-9ef6-42dde27851f2","README.md","019ba37b-ea2b-73cf-99fa-f3d9c3769619",54,["D",1767985601668],4,"# GitHub Leads\n\nFind potential customers from GitHub activity. Monitor your org's repos for\nstars, forks, issues, and PRs — then use AI to qualify leads automatically.\n\n![image.png](https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/fa6f2423-2001-4c80-c5fb-7a85e1b47100/public)\n\n## What this does\n\n1. A cron job monitors public activity on your GitHub org\n2. When someone stars, forks, or opens an issue/PR, they're captured\n3. An AI agent researches the person and scores them as a lead\n4. Qualified leads appear in your dashboard with periodic digest emails\n\n## Getting started\n\n1. Click [**Remix**](/?intent=remix)\n2. Add environment variables:\n - `OPENAI_API_KEY` — for AI lead qualification\n - `GITHUB_TOKEN` — for accessing GitHub API\n ([create one here](https://github.com/settings/tokens))\n3. Configure your settings:\n - Edit `GITHUB_ORG` in [`github.cron.ts`](./github.cron.ts)\n - Edit `RECIPIENTS` in [`digest.ts`](./digest.ts)\n - Customize [`PROMPT.txt`](./PROMPT.txt) with your ICP criteria\n4. Open [`main.ts`](./main.ts) to view your dashboard\n\n**Note:** GitHub's Events API only returns the 300 most recent events per org.\n\n## How it works\n\n**GitHub Monitoring** ([`github.cron.ts`](./github.cron.ts))\n\n- Runs hourly to check for new activity on your org\n- Captures stars, forks, issues, PRs, and other public events\n- Groups events by user to avoid duplicate leads\n\n**AI Agent** ([`agent.ts`](./agent.ts))\n\n- Researches each GitHub user's profile, repos, and linked sites\n- Uses web search to learn about their company and role\n- Scores them against your ICP defined in [`PROMPT.txt`](./PROMPT.txt)\n- Returns `{name, match, score, leadTypes, reasoning}`\n\n**Storage** ([`db.ts`](./db.ts))\n\n- Every lead is stored in SQLite with columns:\n - `id` — auto-incremented\n - `timestamp` — when first seen\n - `input_data` — the GitHub event(s) that triggered it\n - `output_data` — AI result\n\n**Dashboard** ([`main.ts`](./main.ts))\n\n- Qualified leads (match=true) appear at the top\n- Shows score and lead type tags (customer/hire)\n- Click a lead to see full details and GitHub activity\n\n**Email Digest** ([`digest.ts`](./digest.ts))\n\n- Sends daily emails (1pm UTC) with new qualified leads\n- Edit `RECIPIENTS` array to configure who receives them\n\n## Customization\n\n- Edit [`PROMPT.txt`](./PROMPT.txt) to define your ideal customer profile\n- Adjust the GitHub sweep frequency in [`github.cron.ts`](./github.cron.ts)\n interval settings (default: hourly)\n- Adjust the email digest schedule in [`digest.ts`](./digest.ts) interval\n settings (default: daily at 1pm UTC)\n\n## Testing\n\nUse the test bar in the dashboard to evaluate any GitHub username instantly.",[212],"403624f6-f0b8-11f0-bed2-42dde27851f2","PROMPT.txt","019ba37b-ea2b-73cf-99fa-ed0b20eca3a8",90,["D",1768333459019],"You are an assistant to the CEO of Val Town.\n\nVal Town is like Zapier for people who know how to code, a tool for writing code and getting it running in the cloud,\nparticularly useful for lightweight automations in technical teams.\n\nI'm sending you data about GitHub activity and it's your job to exhuastively research the person by visiting the links \non their GitHub profile, any company listed on their profile, searching the web for their name creatively,\nfinding their personal and company sites, blogs they've written, etc to determine if they are in Val Town's \nideal customer profile.\n\nVal Town's ideal customer profile:\n\n1. Founder\n2. B2B SaaS Startup\n3. Seed-stage (approximately)\n4. They know how to code\n\nReturn your final response in JSON only with the following schema:\n\n{\n \"name\": string,\n \"company\": string,\n \"match\": boolean,\n \"score\": number,\n \"reasoning\": string\n}\n\nThe score field is from 0 to 100.\n\nThe company is where they currently work.\n\nFor the \"reasoning\" field, write in Markdown. Include newlines where appropriate.\n\nIf the person works at Val Town, there is no match and the score is 0.",[220],"pulls",0,"branches",1,"forks",13,"envVars",{"_236":64,"_238":227},"connections",{"_236":227,"_237":227},"count","unfilledCount","emptyCount",{"_44":219,"_33":220,"_31":221,"_159":-5,"_42":43,"_41":222,"_161":27,"_39":273,"_13":216,"_34":20,"_36":224,"_24":27,"_166":-5,"_249":274,"_28":275},{"_44":211,"_33":212,"_31":213,"_159":-5,"_42":43,"_41":214,"_161":27,"_39":270,"_13":216,"_34":20,"_36":217,"_24":27,"_166":-5,"_249":271,"_28":272},{"_44":204,"_33":205,"_31":206,"_159":-5,"_42":43,"_41":207,"_161":27,"_39":267,"_13":201,"_34":164,"_36":209,"_24":27,"_166":-5,"_249":268,"_28":269},{"_44":196,"_33":197,"_31":198,"_159":-5,"_42":43,"_41":199,"_161":27,"_39":264,"_13":201,"_34":164,"_36":202,"_24":27,"_166":-5,"_249":265,"_28":266},{"_44":188,"_33":189,"_31":190,"_159":-5,"_42":43,"_41":191,"_161":27,"_39":261,"_13":193,"_34":164,"_36":194,"_24":27,"_166":-5,"_249":262,"_28":263},{"_44":184,"_33":29,"_31":32,"_159":-5,"_42":43,"_41":14,"_161":27,"_39":258,"_13":186,"_34":35,"_36":38,"_24":27,"_166":-5,"_249":259,"_28":260},{"_44":176,"_33":177,"_31":178,"_159":-5,"_42":43,"_41":179,"_161":27,"_39":255,"_13":181,"_34":35,"_36":182,"_24":27,"_166":-5,"_249":256,"_28":257},{"_44":168,"_33":169,"_31":59,"_159":-5,"_42":43,"_41":170,"_161":27,"_39":252,"_13":64,"_34":172,"_36":173,"_24":27,"_166":174,"_249":253,"_28":254},{"_44":156,"_33":157,"_31":158,"_159":-5,"_42":43,"_41":160,"_161":27,"_39":248,"_13":163,"_34":164,"_36":165,"_24":27,"_166":-5,"_249":250,"_28":251},["D",1768000635708],"children",[],[157],["D",1767975784500],[],[169],["D",1773950441144],[],[177],["D",1783610746961],[],[29],["D",1773950054188],[],[189],["D",1768333419019],[],[197],["D",1773770359757],[],[205],["D",1767985601668],[],[212],["D",1768333459019],[],[220],["D",1767974365657],["D",1789542098478],{"_104":103,"_112":108},{"_104":103,"_105":106,"_107":108,"_18":-5,"_109":110,"_111":25},{"_13":90,"_33":91,"_44":43,"_92":45,"_93":94,"_95":96,"_97":51,"_98":99,"_100":66,"_101":46,"_102":103},"ctx",{"_83":-5,"_134":314,"_315":316,"_317":318,"_319":27,"_320":27,"_321":27,"_322":25,"_323":-5,"_324":-7,"_325":-7,"_326":227,"_327":27,"_328":27,"_329":-5,"_330":27,"_331":27,"_332":27,"_333":-5},"ENV",{"_285":286,"_287":288,"_289":91,"_290":291,"_292":293,"_294":295,"_296":297,"_298":299,"_300":301,"_302":303,"_304":305,"_306":307,"_308":309,"_310":311,"_312":313},"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 · v100