\n1. Start forwarding leads to this webhook from any source as a POST request.\n1. That's it! You now have a growing `leads` SQLite table with one column for\n your original `input_data` and a second column for the AI evaluator's\n `output_data`. You also have a dashboard of this data hosted at the\n [`main.ts`](./main.ts) val endpoint.\n\n## How it works\n\n- When a new lead comes in via POST, it is sent to the OpenAI agent in\n [`agent.ts`](./agent.ts).\n- The agent uses the lead data from your POST request and its web search tool to\n determine if the lead is a `match` for the criteria in\n [`PROMPT.txt`](./PROMPT.txt).\n- By default, the AI's response looks like:\n ```json\n {\n \"match\": \"(true or false)\",\n \"name\": \"(normalized name)\",\n \"reasoning\": \"(explanation)\"\n }\n ```\n- Every lead is added to the `leads` SQLite table:\n - `id` — auto-increment\n - `timestamp` — Unix timestamp\n - `input_data` — JSON of your POST body\n - `output_data` — JSON of AI response\n\n- The [`main.ts`](./main.ts) dashboard shows a history of all lead assessments,\n successful matches first. Clicking any lead shows the full inbound and output\n data from the assessment.\n\n## Options\n\n- You can add any number of fields to the AI's output instructions in\n [`PROMPT.txt`](./PROMPT.txt) and they'll be added to `output_data`. You can\n use this to expand the AI's assessment, enrich your leads, or even just\n normalize lead data coming from different sources.\n- You can also add query parameters when you POST to the val endpoint. (ex:\n `your-val-endpoint.val.run?source=signup-page`). The parameters will be\n bundled in the `_query` object of `input_data`. This can be useful for\n tracking where a lead was forwarded from.",[],[180],{"_105":189,"_96":190,"_159":191,"_161":-5,"_162":142,"_163":192,"_165":166,"_107":193,"_102":194,"_169":195,"_171":196,"_173":22,"_174":-5,"_175":197,"_100":198},"26fe4c2e-db5b-11f0-8360-42dde27851f2","agent.ts","019b240d-f922-75c9-b5f8-30fd2f3df69f",162,["D",1765984499112],9,"script","import { readFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { Agent, run, webSearchTool } from \"npm:@openai/agents@0.3.0\";\nimport { storeLead } 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\nexport async function processLead(inputData: Record) {\n const result = await run(agent, JSON.stringify(inputData));\n const outputData = JSON.parse(result.finalOutput);\n await storeLead(inputData, outputData);\n\n console.log(\"Stored lead\");\n console.log(result.finalOutput);\n\n return { outputData };\n}",[],[190],{"_105":200,"_96":201,"_159":202,"_161":-5,"_162":142,"_163":141,"_165":166,"_107":203,"_102":204,"_169":195,"_171":205,"_173":22,"_174":-5,"_175":206,"_100":207},"3df11754-db5b-11f0-99dd-42dde27851f2","dashboard.tsx","019b240d-f922-75c9-b5f8-36b85447eb4b",["D",1765984537613],10,"/** @jsxImportSource npm:hono@4/jsx */\nimport { Hono } from \"npm:hono@4\";\nimport { getAllLeads, getLeadById, Lead } from \"./db.ts\";\n\nexport const app = new Hono();\n\nfunction Layout({ children, title }: { children: any; title: string }) {\n return (\n \n \n \n \n {title}\n \n \n {children}\n \n );\n}\n\nfunction LeadRow({ lead, isMatch }: { lead: Lead; isMatch: boolean }) {\n const output = JSON.parse(lead.output_data);\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 {output.name || \"Unknown\"}\n \n {date}\n \n );\n}\n\nfunction DataTable(\n { title, data }: { title: string; data: Record },\n) {\n const entries = Object.entries(data);\n if (entries.length === 0) return null;\n\n return (\n

\n {title}\n

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

{key}

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

\n );\n}\n\napp.get(\"/\", async (c) => {\n const leads = await getAllLeads();\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

Leads

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

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

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

\n )\n : (\n

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

\n \n \n {nonMatches.length} not matched\n \n ▼\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\n return c.html(\n \n

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

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

\n {new Date(lead.timestamp).toLocaleString()}\n

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

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

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

\n\n {/* Input Data */}\n \n\n {/* AI Output */}\n \n \n ,\n );\n});\n\nexport default app.fetch;",[],[201],{"_105":209,"_96":210,"_159":211,"_161":-5,"_162":142,"_163":212,"_165":166,"_107":213,"_102":214,"_169":195,"_171":215,"_173":22,"_174":-5,"_175":216,"_100":217},"8c61b72e-daf0-11f0-ba97-42dde27851f2","db.ts","019b240d-f922-75c9-b5f8-3aad7088ad64",149,["D",1765938713060],8,"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nconst TABLE_NAME = \"leads\";\n\nawait createTable();\n\nexport interface Lead {\n id: number;\n timestamp: number;\n input_data: string;\n output_data: string;\n}\n\nexport async function storeLead(\n inputData: Record,\n outputData: Record,\n) {\n await sqlite.execute(\n `INSERT INTO ${TABLE_NAME} (timestamp, input_data, output_data)\n VALUES (?, ?, ?)`,\n [Date.now(), JSON.stringify(inputData), JSON.stringify(outputData)],\n );\n}\n\nexport async function getAllLeads(): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLE_NAME} ORDER BY timestamp DESC`,\n );\n return rowsToLeads(result);\n}\n\nexport async function getLeadById(id: number): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLE_NAME} WHERE id = ?`,\n [id],\n );\n const leads = rowsToLeads(result);\n return leads[0] || null;\n}\n\nfunction rowsToLeads(result: { columns: string[]; rows: unknown[] }): Lead[] {\n return result.rows.map((row: any) => {\n const obj: Record = {};\n result.columns.forEach((col, idx) => {\n obj[col] = row[idx];\n });\n return obj as Lead;\n });\n}\n\nasync function createTable() {\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS ${TABLE_NAME} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n timestamp INTEGER NOT NULL,\n input_data TEXT NOT NULL,\n output_data TEXT NOT NULL\n )`,\n );\n}\n",[],[210],{"_105":219,"_96":101,"_159":220,"_161":-5,"_162":142,"_163":221,"_165":166,"_107":222,"_102":168,"_169":223,"_171":224,"_173":22,"_174":-5,"_175":225,"_100":226},"72be2de6-dacf-11f0-a8c9-42dde27851f2","019b240d-f922-75c9-b5f8-40e88aa7485a",85,["D",1765924496615],"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 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 ? { ...body, _query: query } : body;\n\n console.log(inputData);\n\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\napp.route(\"/\", dashboard);\n\nexport default app.fetch;\n",[],[101],"files",[156,178,188,199,208,218],"counts",{"_231":32,"_232":233,"_234":235,"_236":237},"pulls","branches",3,"forks",1,"envVars",{"_238":235,"_239":32},"count","emptyCount","contents",[],{"_105":219,"_162":142,"_159":220,"_96":101,"_171":224,"_169":223,"_102":168,"_161":-5,"_107":243,"_163":221,"_174":-5,"_100":244},["D",1765924496615],[101],"upstreamProject","upstreamBranch",{"_105":145,"_107":248,"_249":250,"_96":44,"_143":106,"_102":251,"_144":-5,"_146":-5,"_252":253,"_109":-5,"_153":22,"_111":112,"_152":95,"_16":123,"_151":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.history_.$",{"_94":95,"_96":97,"_98":99,"_100":101,"_103":260,"_170":265,"_268":269,"_297":298,"_306":-7,"_307":32,"_308":22},{"_105":106,"_96":97,"_107":261,"_109":-5,"_110":22,"_111":112,"_113":114,"_115":116,"_14":117,"_118":-5,"_119":22,"_120":-5,"_121":-5,"_122":32,"_16":123,"_124":125,"_126":125,"_127":128,"_129":128,"_130":128,"_131":125,"_132":125,"_23":262,"_136":263,"_139":264,"_153":22},["D",1765818489674],{"_94":95,"_134":135},{"_94":95,"_138":135,"_14":-5},{"_102":141,"_96":99,"_105":142,"_143":106,"_144":145,"_146":147,"_148":112,"_149":106,"_150":123,"_151":97,"_152":95},{"_105":219,"_96":101,"_159":220,"_161":-5,"_162":142,"_163":221,"_165":166,"_107":266,"_102":168,"_169":223,"_171":224,"_173":22,"_174":-5,"_100":267},["D",1765924496615],[101],"history",[270,272,278,283,289,293],{"_105":219,"_162":142,"_159":220,"_96":101,"_171":224,"_169":223,"_102":168,"_161":-5,"_107":271,"_163":221,"_174":-5},["D",1765924496615],{"_105":273,"_162":142,"_159":220,"_96":101,"_171":274,"_169":223,"_102":275,"_161":-5,"_107":276,"_163":277,"_174":-5},"1f392fc0-dabd-11f0-b653-42dde27851f2","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 body = await c.req.json();\n const url = new URL(c.req.url);\n const query = Object.fromEntries(url.searchParams);\n \n // Merge body with query params if any\n const inputData = Object.keys(query).length > 0 \n ? { ...body, _query: query } \n : body;\n\n console.log(inputData);\n\n // Early return + queue up processing\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\napp.route(\"/\", dashboard);\n\nexport default app.fetch;\n",4,["D",1765916625589],60,{"_105":279,"_162":142,"_159":220,"_96":101,"_171":280,"_169":223,"_102":233,"_161":-5,"_107":281,"_163":282,"_174":-5},"4b8edaee-da30-11f0-946f-42dde27851f2","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",["D",1765856140932],49,{"_105":284,"_162":142,"_159":220,"_96":101,"_171":285,"_169":223,"_102":286,"_161":-5,"_107":287,"_163":288,"_174":-5},"48c9c09a-da2f-11f0-8a01-42dde27851f2","import { Hono } from \"npm:hono@4\";\nimport { blob } from \"https://esm.town/v/std/blob\";\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 // Store endpoint URL for digest emails\n await blob.set(\"endpoint-url\", url.origin);\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",2,["D",1765855706791],47,{"_105":290,"_162":142,"_159":220,"_96":101,"_171":280,"_169":223,"_102":235,"_161":-5,"_107":291,"_163":292,"_174":-5},"321139a0-da2a-11f0-97f0-42dde27851f2",["D",1765853521181],24,{"_105":294,"_162":142,"_159":220,"_96":101,"_171":295,"_169":223,"_102":32,"_161":-5,"_107":296,"_163":235,"_174":-5},"75591322-da02-11f0-a1a0-42dde27851f2","import { Hono } from \"npm:hono@4\";\nimport { processLead } from \"./agent.ts\";\nimport { app as dashboard } from \"./dashboard.tsx\";\n\nconst app = new Hono();\n\n// Ingest endpoint - accepts any source via query param\napp.post(\"/\", async (c) => {\n const source = c.req.query(\"source\") || \"unknown\";\n const data = await c.req.json();\n\n console.log(`[Ingest] Received lead from source: ${source}`);\n console.log(data);\n\n const url = new URL(c.req.url);\n\n // Early return + queue up processing\n fetch(`${url.origin}/process?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, source });\n});\n\n// Internal processing endpoint\napp.post(\"/process\", async (c) => {\n const source = c.req.query(\"source\") || \"unknown\";\n const data = await c.req.json();\n\n try {\n const result = await processLead(data, source);\n return c.json({ ok: true, ...result });\n } catch (error) {\n console.error(\"[Process] Error:\", error);\n return c.json({ ok: false, error: String(error) }, 500);\n }\n});\n\n// Dashboard routes\napp.route(\"/\", dashboard);\n\nexport default app.fetch;",["D",1765836454185],"versions",[299,301,302,303,304,305],{"_170":270,"_300":272},"previous",{"_170":272,"_300":278},{"_170":278,"_300":283},{"_170":283,"_300":289},{"_170":289,"_300":293},{"_170":293,"_300":-5},"versionNumber","page","hasNext","actionData","errors"]

valdottown

leads

History for main.ts