\n {title}\n

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

{key}

{String(value ?? \"\")}

\n );\n}\n\napp.get(\"/\", async (c) => {\n const leads = await getAllLeads();\n\n const ideal = leads.filter((l) => l.ideal_customer);\n const nonIdeal = leads.filter((l) => !l.ideal_customer);\n\n return c.html(\n \n

Lead Inbox

\n {leads.length} leads · {ideal.length} ideal customers\n

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

\n No leads yet. POST to this endpoint to add leads.\n

\n ) : (\n

\n {ideal.map((lead) => )}\n\n {nonIdeal.length > 0 && (\n

\n \n \n {nonIdeal.length} non-ideal{\" \"}\n {nonIdeal.length === 1 ? \"lead\" : \"leads\"}\n \n ▼\n \n

\n {nonIdeal.map((lead) => )}\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 to dashboard\n \n

\n ,\n 404,\n );\n }\n\n const blobData = await blob.getJSON(`lead-scores/${id}`);\n const input = lead.json_in ? JSON.parse(lead.json_in) : {};\n const aiOutput = blobData?.finalOutput || { name: lead.name, idealCustomer: lead.ideal_customer, reasoning: lead.reasoning };\n\n return c.html(\n \n

\n \n ← Back to dashboard\n \n\n

{lead.name}

\n {new Date(lead.timestamp).toLocaleString()}\n {lead.source && ` · ${lead.source}`}\n

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

\n \n \n {lead.ideal_customer ? \"Ideal Customer\" : \"Not Ideal Customer\"}\n \n

\n {lead.reasoning || \"No reasoning provided\"}\n

\n\n {/* Input Data */}\n \n\n {/* AI Output */}\n \n\n {/* Full Run Data */}\n {blobData && (\n

\n Full Run Data (debug)\n

\n              {JSON.stringify(blobData, null, 2)}\n

\n )}\n \n ,\n );\n});\n\nexport default app.fetch;\n",[],[201],{"_106":209,"_96":210,"_160":211,"_162":-5,"_163":143,"_164":103,"_166":22,"_108":212,"_102":194,"_169":195,"_171":213,"_173":22,"_174":-5,"_175":214,"_100":215},"15e35b1c-dabd-11f0-bdc4-42dde27851f2","db.ts","019b240d-f922-75c9-b5f8-3aad7088ad64",["D",1765916609923],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nconst TABLE_NAME = \"leads_v8\";\n\nawait createTable();\n\nexport interface Lead {\n id: number;\n timestamp: number;\n input_data: string;\n output_data: string;\n}\n\nexport interface ParsedOutput {\n name?: string;\n ideal?: boolean;\n reasoning?: string;\n [key: string]: unknown;\n}\n\nexport async function storeLead(\n inputData: Record,\n outputData: Record,\n): Promise {\n const timestamp = Date.now();\n await sqlite.execute(\n `INSERT INTO ${TABLE_NAME} (timestamp, input_data, output_data)\n VALUES (?, ?, ?)`,\n [timestamp, JSON.stringify(inputData), JSON.stringify(outputData)],\n );\n\n const result = await sqlite.execute(\n `SELECT id FROM ${TABLE_NAME} WHERE timestamp = ? ORDER BY id DESC LIMIT 1`,\n [timestamp],\n );\n return result.rows[0][0] as number;\n}\n\nexport async function getAllLeads(): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLE_NAME} ORDER BY timestamp DESC`,\n );\n return rowsToLeads(result);\n}\n\nexport async function getLeadById(id: number): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLE_NAME} WHERE id = ?`,\n [id],\n );\n const leads = rowsToLeads(result);\n return leads[0] || null;\n}\n\nexport async function getIdealLeadsSince(sinceTimestamp: number): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLE_NAME} \n WHERE json_extract(output_data, '$.ideal') = 1\n AND timestamp > ?\n ORDER BY timestamp DESC`,\n [sinceTimestamp],\n );\n return rowsToLeads(result);\n}\n\nexport function parseOutput(lead: Lead): ParsedOutput {\n try {\n return JSON.parse(lead.output_data);\n } catch {\n return {};\n }\n}\n\nexport function parseInput(lead: Lead): Record {\n try {\n return JSON.parse(lead.input_data);\n } catch {\n return {};\n }\n}\n\nfunction rowsToLeads(result: { columns: string[]; rows: unknown[][] }): Lead[] {\n return result.rows.map((row) => {\n const obj: Record = {};\n result.columns.forEach((col, idx) => {\n obj[col] = row[idx];\n });\n return obj as Lead;\n });\n}\n\nasync function createTable() {\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS ${TABLE_NAME} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n timestamp INTEGER NOT NULL,\n input_data TEXT NOT NULL,\n output_data TEXT NOT NULL\n )`,\n );\n}\n",[],[210],{"_106":217,"_96":101,"_160":218,"_162":-5,"_163":143,"_164":219,"_166":22,"_108":220,"_102":221,"_169":222,"_171":223,"_173":22,"_174":-5,"_175":224,"_100":225},"e61970d8-da30-11f0-8f00-42dde27851f2","019b240d-f922-75c9-b5f8-3cf0688b8795",51,["D",1765856400213],15,"interval","import { email } from \"https://esm.town/v/std/email?v=11\";\nimport { getIdealLeadsSince, Lead } from \"./db.ts\";\n\nconst [, handle, valName] = import.meta.url.match(/\\/[vp]\\/([^/]+)\\/([^/@]+)/)!;\nconst VAL_URL = `https://www.val.town/x/${handle}/${valName}`;\n\nconst RECIPIENTS = [\n \"charlie@val.town\",\n];\n\nexport default async function sendDigest(\n interval?: { lastRunAt: Date | undefined },\n) {\n const sinceTimestamp = interval?.lastRunAt?.getTime() ?? 0;\n const leads = await getIdealLeadsSince(sinceTimestamp);\n\n if (leads.length === 0) {\n console.log(`[Digest] No ideal leads found since last run, skipping email`);\n return { sent: false, reason: \"No ideal leads today\" };\n }\n console.log(`[Digest] Found ${leads.length} ideal leads, sending email...`);\n\n const subject = `🎯 ${leads.length} Ideal Lead${leads.length !== 1 ? \"s\" : \"\"} Today`;\n const text = generatePlainText(leads);\n\n await email({ to: RECIPIENTS, subject, text });\n\n return { sent: true, leadCount: leads.length };\n}\n\nfunction generatePlainText(leads: Lead[]): string {\n const leadBlocks = leads.map((lead) => {\n return `${lead.name}\n${lead.reasoning || \"No reasoning provided\"}`;\n }).join(\"\\n\\n---\\n\\n\");\n\n return `🎯 Today's Ideal Leads\n\n${leads.length} ideal customer${leads.length !== 1 ? \"s\" : \"\"} identified today\n\n---\n\n${leadBlocks}\n\n---\nEdit this val: ${VAL_URL}`;\n}\n",[],[101],{"_106":227,"_96":228,"_160":229,"_162":-5,"_163":143,"_164":230,"_166":22,"_108":231,"_102":168,"_169":232,"_171":233,"_173":22,"_174":-5,"_175":234,"_100":235},"4b8edaee-da30-11f0-946f-42dde27851f2","main.ts","019b240d-f922-75c9-b5f8-40e88aa7485a",49,["D",1765856140932],"http","import { Hono } from \"npm:hono@4\";\nimport { processLead } from \"./agent.ts\";\nimport { app as dashboard } from \"./dashboard.tsx\";\n\nconst app = new Hono();\n\napp.post(\"/\", async (c) => {\n const data = await c.req.json();\n console.log(data);\n const url = new URL(c.req.url);\n const source = c.req.query(\"source\");\n\n // Early return + queue up processing\n fetch(`${url.origin}/process${source ? `?source=${encodeURIComponent(source)}` : \"\"}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(data),\n });\n\n return c.json({ ok: true });\n});\n\napp.post(\"/process\", async (c) => {\n const data = await c.req.json();\n const source = c.req.query(\"source\");\n await processLead(data, source);\n return c.json({ ok: true });\n});\n\napp.route(\"/\", dashboard);\n\nexport default app.fetch;\n",[],[228],{"_106":237,"_96":238,"_160":239,"_162":-5,"_163":143,"_164":240,"_166":22,"_108":241,"_102":221,"_169":195,"_171":242,"_173":22,"_174":-5,"_175":243,"_100":244},"1d2bd908-da2c-11f0-bee8-42dde27851f2","testing.ts","019b240d-f922-75c9-b5f8-45eddeb2a500",44,["D",1765854345123],"import { storeLead } from \"./db.ts\";\nimport { processLead } from \"./agent.ts\";\nimport sendDigest from \"./digest.ts\";\n\n// === DIRECT INSERT (bypasses AI) ===\n\nasync function insertTestLead() {\n const id = await storeLead(\n { test: true, note: \"Manually inserted for testing\" },\n {\n name: \"Test Person\",\n idealCustomer: false,\n reasoning: \"This is where the AI's reasoning for this lead would go.\",\n },\n \"test\",\n );\n console.log(`✅ Inserted test lead #${id}`);\n}\n\n// === AI PROCESSING ===\n\nasync function testAgent() {\n const payload = {\n \"LinkedIn URL\": \"https://www.linkedin.com/in/testuser\",\n \"First Name\": \"Test\",\n \"Last Name\": \"User\",\n \"Title\": \"Engineering Lead\",\n \"Company Name\": \"Acme Corp\",\n };\n console.log(\"🤖 Running agent on test payload...\");\n const result = await processLead(payload, \"test\");\n console.log(\"Result:\", result);\n}\n\n// === DIGEST ===\n\nasync function testDigest() {\n console.log(\"📧 Triggering digest...\");\n const result = await sendDigest({ lastRunAt: undefined });\n console.log(\"Digest result:\", result);\n}\n\n// Uncomment to run:\nawait insertTestLead();\nawait testAgent();\nawait testDigest();\n\nconsole.log(\"✅ Testing file loaded. Uncomment functions above to run.\");",[],[238],"files",[157,178,188,199,208,216,226,236],"counts",{"_249":32,"_250":168,"_251":252,"_253":254},"pulls","branches","forks",1,"envVars",{"_255":252,"_256":32},"count","emptyCount","contents",[],{"_106":217,"_163":143,"_160":218,"_96":101,"_171":223,"_169":222,"_102":221,"_162":-5,"_108":260,"_164":219,"_174":-5,"_100":261},["D",1765856400213],[101],"upstreamProject","upstreamBranch",{"_106":146,"_108":265,"_266":267,"_96":44,"_144":107,"_102":268,"_145":-5,"_147":-5,"_269":270,"_110":-5,"_154":22,"_112":113,"_153":95,"_16":124,"_152":97},["D",1765818489674],"updatedAt",["D",1766000370106],118,"lockfileKey","1766000370243-esm.town_v_valdottown_leads@118-main","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_94":95,"_96":97,"_98":99,"_102":103,"_100":101,"_104":277,"_155":282,"_245":307,"_170":308,"_257":311,"_312":313,"_316":-5,"_317":194,"_318":319,"_320":321,"_253":-5},{"_106":107,"_96":97,"_108":278,"_110":-5,"_111":22,"_112":113,"_114":115,"_116":117,"_14":118,"_119":-5,"_120":22,"_121":-5,"_122":-5,"_123":32,"_16":124,"_125":126,"_127":126,"_128":129,"_130":129,"_131":129,"_132":126,"_133":126,"_23":279,"_137":280,"_140":281,"_154":22},["D",1765818489674],{"_94":95,"_135":136},{"_94":95,"_139":136,"_14":-5},{"_102":142,"_96":99,"_106":143,"_144":107,"_145":146,"_147":148,"_149":113,"_150":107,"_151":124,"_152":97,"_153":95},[283,286,289,292,295,298,301,304],{"_106":158,"_96":159,"_160":161,"_162":-5,"_163":143,"_164":165,"_166":22,"_108":167,"_102":168,"_169":170,"_171":172,"_173":22,"_174":-5,"_175":284,"_100":285},[],[159],{"_106":179,"_96":180,"_160":181,"_162":-5,"_163":143,"_164":182,"_166":22,"_108":183,"_102":184,"_169":170,"_171":185,"_173":22,"_174":-5,"_175":287,"_100":288},[],[180],{"_106":189,"_96":190,"_160":191,"_162":-5,"_163":143,"_164":192,"_166":22,"_108":193,"_102":194,"_169":195,"_171":196,"_173":22,"_174":-5,"_175":290,"_100":291},[],[190],{"_106":200,"_96":201,"_160":202,"_162":-5,"_163":143,"_164":203,"_166":22,"_108":204,"_102":194,"_169":195,"_171":205,"_173":22,"_174":-5,"_175":293,"_100":294},[],[201],{"_106":209,"_96":210,"_160":211,"_162":-5,"_163":143,"_164":103,"_166":22,"_108":212,"_102":194,"_169":195,"_171":213,"_173":22,"_174":-5,"_175":296,"_100":297},[],[210],{"_106":217,"_96":101,"_160":218,"_162":-5,"_163":143,"_164":219,"_166":22,"_108":220,"_102":221,"_169":222,"_171":223,"_173":22,"_174":-5,"_175":299,"_100":300},[],[101],{"_106":227,"_96":228,"_160":229,"_162":-5,"_163":143,"_164":230,"_166":22,"_108":231,"_102":168,"_169":232,"_171":233,"_173":22,"_174":-5,"_175":302,"_100":303},[],[228],{"_106":237,"_96":238,"_160":239,"_162":-5,"_163":143,"_164":240,"_166":22,"_108":241,"_102":221,"_169":195,"_171":242,"_173":22,"_174":-5,"_175":305,"_100":306},[],[238],[283,286,289,292,295,298,301,304],{"_106":217,"_163":143,"_160":218,"_96":101,"_171":223,"_169":222,"_102":221,"_162":-5,"_108":309,"_164":219,"_174":-5,"_100":310},["D",1765856400213],[101],[],"upstream",{"_106":146,"_108":314,"_266":315,"_96":44,"_144":107,"_102":268,"_145":-5,"_147":-5,"_269":270,"_110":-5,"_154":22,"_112":113,"_153":95,"_16":124,"_152":97},["D",1765818489674],["D",1766000370106],"pull","ahead","behind",24,"templates",[],"actionData","errors"]