\n {/* Title */}\n

Leads Webhook

\n\n {/* Webhook URL */}\n

\n \n \n \n {webhookUrl}\n

\n \n \n \n \n \n \n \n Copy\n \n

\n\n

\n This val URL accepts POST requests! Paste it anywhere that accepts\n webhooks. Hint: it's also the url of this dashboard.\n

\n\n {/* Or divider + tester toggle */}\n

\n \n or\n \n test it here\n \n \n \n \n \n

\n\n {/* Tester content - hidden by default */}\n

\n {/* POST URL header */}\n

\n POST {webhookUrl}\n

\n\n {/* Test mode selector */}\n

\n \n Neutral\n \n \n Should Match ✓\n \n \n Should Reject ✗\n \n

\n\n {/* Hint explainer */}\n \n

\n\n {/* Raw JSON editor */}\n \n \n\n {/* JSON validation message */}\n

\n\n {/* Send button */}\n \n \n \n \n Send Test Lead\n \n\n {/* Result area */}\n \n

\n \n\n {\n document.getElementById('copy-icon').classList.remove('hidden');\n document.getElementById('check-icon').classList.add('hidden');\n document.getElementById('copy-text').textContent = 'Copy';\n }, 2000);\n };\n\n window.toggleTester = function() {\n const content = document.getElementById('tester-content');\n const chevron = document.getElementById('tester-chevron');\n content.classList.toggle('hidden');\n chevron.classList.toggle('rotate-180');\n \n if (!content.classList.contains('hidden')) {\n setTestMode('neutral');\n }\n };\n\n window.setTestMode = function(mode) {\n currentMode = mode;\n \n ['neutral', 'pass', 'fail'].forEach(m => {\n const btn = document.getElementById('mode-' + m);\n if (m === mode) {\n btn.classList.remove('border-gray-200', 'bg-white');\n btn.classList.add('border-gray-300', 'bg-gray-100');\n } else {\n btn.classList.add('border-gray-200', 'bg-white');\n btn.classList.remove('border-gray-300', 'bg-gray-100');\n }\n });\n\n const explainer = document.getElementById('hint-explainer');\n if (mode === 'neutral') {\n explainer.classList.add('hidden');\n } else {\n explainer.classList.remove('hidden');\n explainer.innerHTML = mode === 'pass' \n ? 'Adding _testHint to ask AI to mark as match'\n : 'Adding _testHint to ask AI to reject';\n }\n\n const editor = document.getElementById('json-editor');\n try {\n const current = JSON.parse(editor.value);\n delete current._testHint;\n basePayload = current;\n } catch {\n basePayload = { ...defaultPayload };\n }\n\n let payload = { ...basePayload };\n if (mode === 'pass') payload._testHint = passHint;\n if (mode === 'fail') payload._testHint = failHint;\n\n editor.value = JSON.stringify(payload, null, 2);\n validateJson();\n };\n\n window.validateJson = function() {\n const editor = document.getElementById('json-editor');\n const errorEl = document.getElementById('json-error');\n const sendBtn = document.getElementById('send-btn');\n \n try {\n JSON.parse(editor.value);\n errorEl.classList.add('hidden');\n sendBtn.disabled = false;\n return true;\n } catch (e) {\n errorEl.textContent = 'Invalid JSON: ' + e.message;\n errorEl.classList.remove('hidden');\n sendBtn.disabled = true;\n return false;\n }\n };\n\n window.sendTest = async function() {\n if (!validateJson()) return;\n\n const sendBtn = document.getElementById('send-btn');\n const sendText = document.getElementById('send-text');\n const result = document.getElementById('result');\n const editor = document.getElementById('json-editor');\n\n sendBtn.disabled = true;\n sendText.textContent = 'Sending...';\n result.classList.add('hidden');\n\n try {\n const payload = JSON.parse(editor.value);\n const res = await fetch(webhookUrl, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(payload)\n });\n\n const responseData = await res.json();\n \n if (responseData.error) {\n result.classList.remove('hidden', 'bg-green-50', 'border-green-200', 'text-green-700');\n result.classList.add('bg-red-50', 'border', 'border-red-200', 'text-red-700');\n result.textContent = '✗ ' + responseData.error;\n sendBtn.disabled = false;\n sendText.textContent = 'Send Test Lead';\n } else {\n // Success - reload the page to show the new processing lead\n window.location.reload();\n }\n } catch (err) {\n result.classList.remove('hidden', 'bg-green-50', 'border-green-200', 'text-green-700');\n result.classList.add('bg-red-50', 'border', 'border-red-200', 'text-red-700');\n result.textContent = '✗ Error: ' + err.message;\n sendBtn.disabled = false;\n sendText.textContent = 'Send Test Lead';\n }\n };\n\n document.getElementById('json-editor').addEventListener('input', validateJson);\n })();\n `,\n }}\n />\n \n );\n}","deleted","label",[139],"61d78226-008f-11f1-962f-42dde27851f2","main.ts",["D",1770075124586],"http","import { Hono } from \"npm:hono@4\";\nimport { processLead } from \"./agent.ts\";\nimport { app as dashboard } from \"./dashboard.tsx\";\nimport { createProcessingLead } from \"./db.ts\";\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 // Create lead immediately in processing state\n const leadId = await createProcessingLead(inputData);\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({ leadId, inputData }),\n });\n\n return c.json({ ok: true, leadId });\n});\n\napp.post(\"/process\", async (c) => {\n const { leadId, inputData } = await c.req.json();\n await processLead(leadId, inputData);\n return c.json({ ok: true });\n});\n\napp.route(\"/\", dashboard);\n\nexport default app.fetch;",[155],"61d771e6-008f-11f1-962f-42dde27851f2","db.ts","019c20b2-f3ce-7422-9174-50638be0a5e9",["D",1770075124586],"import sqlite from \"https://esm.town/v/std/db/main.ts\";\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 createProcessingLead(\n inputData: Record,\n): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${TABLE_NAME} (timestamp, input_data, output_data)\n VALUES (?, ?, ?)`,\n [Date.now(), JSON.stringify(inputData), \"\"],\n );\n return Number(result.lastInsertRowid);\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 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\nexport function isProcessing(lead: Lead): boolean {\n return lead.output_data === \"\";\n}\n",[161],"61d74252-008f-11f1-962f-42dde27851f2","dashboard.tsx","019c20b2-f3ce-7422-9174-4de8b4089275",["D",1770075124586],"/** @jsxImportSource npm:hono@4/jsx */\nimport { Hono } from \"npm:hono@4\";\nimport { getAllLeads, getLeadById, Lead, isProcessing } from \"./db.ts\";\nimport { WelcomePanel } from \"./welcome-ui.tsx\"; // DELETE THIS LINE to remove onboarding UI\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 processing = isProcessing(lead);\n const output = processing ? null : JSON.parse(lead.output_data);\n const input = JSON.parse(lead.input_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 {processing ? (\n \n ) : (\n \n )}\n \n {processing ? (input.name || \"Processing...\") : (output.name || \"Unknown\")}\n \n {date}\n \n );\n}\n\nfunction DataTable({ title, data }: { title: string; data: Record }) {\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}

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

\n );\n}\n\napp.get(\"/\", async (c) => {\n const leads = await getAllLeads();\n const webhookUrl = new URL(c.req.url).origin; // The POST endpoint URL\n\n const processingLeads = leads.filter((l) => isProcessing(l));\n const completedLeads = leads.filter((l) => !isProcessing(l));\n const matches = completedLeads.filter((l) => JSON.parse(l.output_data).match === true);\n const nonMatches = completedLeads.filter((l) => JSON.parse(l.output_data).match !== true);\n\n return c.html(\n \n

\n {/* DELETE THIS LINE to remove onboarding UI */}\n \n\n

Leads

\n {leads.length} leads · {matches.length} matches\n {processingLeads.length > 0 && ` · ${processingLeads.length} processing`}\n

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

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

\n ) : (\n

\n {processingLeads.map((lead) => )}\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\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 processing = isProcessing(lead);\n const input = JSON.parse(lead.input_data);\n const output = processing ? null : JSON.parse(lead.output_data);\n\n return c.html(\n \n

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

\n {processing ? (input.name || \"Processing...\") : (output.name || \"Unknown\")}\n

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

\n\n {processing ? (\n

\n \n Processing\n

\n AI is analyzing this lead. Refresh the page in a few moments to see the results.\n

\n ) : (\n \n

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

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

\n )}\n\n {/* Input Data */}\n \n\n {/* AI Output */}\n {!processing && }\n \n ,\n );\n});\n\nexport default app.fetch;\n",[167],"61d73ce4-008f-11f1-962f-42dde27851f2","agent.ts","019c20b2-f3ce-7422-9174-490c717a58b0",["D",1770075124586],"import { readFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { Agent, run, webSearchTool } from \"npm:@openai/agents@0.3.0\";\nimport { 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\nexport async function processLead(leadId: number, inputData: Record) {\n const result = await run(agent, JSON.stringify(inputData));\n const outputData = JSON.parse(result.finalOutput);\n await updateLeadOutput(leadId, outputData);\n console.log(result.finalOutput);\n return { outputData };\n}",[173],"61d7236c-008f-11f1-962f-42dde27851f2","README.md","019c20b2-f3ce-7422-9174-44baec43127e",["D",1770075124586],"# Leads\n\nLead qualifying from any data source. Use AI to [stay focused on inbound leads that fit your ICP](https://review.firstround.com/how-vanta-clay-retool-found-icp/). \n\n![image.png](https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/9ff5b55c-a166-4f47-759c-6726b7477800/public)\n\n## What this does\n\n1. This val accepts webhook\n2. You can POST arbitrary lead data to it from anywhere\n3. An AI agent sorts the good leads from the bad leads\n4. Leads are stored and arranged in a dashboard\n\n## Getting started\n\n1. Click [**Remix**](/?intent=remix)\n1. Store your `OPENAI_API_KEY` as an environment variable\n [here](https://www.val.town/x/templates/leads/environment-variables)\n1. Customize [`PROMPT.txt`](./PROMPT.txt) (Don't remove any fields from the\n structured response)\n1. Get the val's HTTP endpoint from [`main.ts`](./main.ts):\n

\n1. Forward leads to this webhook as a POST request.\n1. That's it! Watch them drop into your dashboard at [`main.ts`](./main.ts)\n\n## How it works\n\n**Webhook**\n\n- The webhook receives each POST request and stores the incoming data as\n `input_data`\n- All `input_data` is passed to the OpenAI agent in [`agent.ts`](./agent.ts)\n\n**AI Agent**\n\n- The agent uses web research to evaluate if the lead is a `match` for the\n criteria in [`PROMPT.txt`](./PROMPT.txt).\n- The AI returns `{name, match, reasoning}`. This is the `output_data`.\n\n**Storage**\n\n- Every lead is added to the `leads` SQLite table with the columns:\n - `id` — auto-incremented, starts at 1\n - `timestamp` — unix ms when received\n - `input_data` — the POST body you sent (JSON)\n - `output_data` — AI result: `{name, match, reasoning}`\n\n**Dashboard**\n\n- Leads that are a `match` are at the top of the dashboard.\n- Non-matches are hidden by default\n- Click a lead to view all input and output data\n\n## Options\n\n- Add fields to the AI's output instructions in [`PROMPT.txt`](./PROMPT.txt) to:\n - enhance the AI's assessment\n - enrich your leads\n - normalize lead data from different sources\n- Add query parameters to your POST to flag sources\n - ex: `your-val-endpoint.val.run?source=signup-page`\n\n## Data Sources\n\n- **Forms**\n - [Typeform](https://www.typeform.com/help/a/webhooks-360029573471/)\n - [Tally](https://tally.so/help/webhooks)\n - [Netlify](https://docs.netlify.com/manage/forms/notifications/)\n - [Webflow](https://developers.webflow.com/data/reference/webhooks/create-webhook)\n- **Scheduling**\n - [Calendly](https://developer.calendly.com/api-docs/005832c83aeae-create-webhook-subscription)\n- **Chat**\n - [Intercom](https://developers.intercom.com/docs/webhooks)\n- **Website Visitors**\n - [RB2B](https://support.rb2b.com/en/articles/8976614-setup-guide-webhook)\n - [Clearbit](https://dashboard.clearbit.com/docs#reveal-api-webhooks)\n- **CRM**\n - [HubSpot](https://developers.hubspot.com/docs/api/webhooks)\n- **Dev**\n - [GitHub](https://docs.github.com/en/webhooks)\n- **Automation**\n - [Zapier](https://zapier.com/help/create/code-webhooks/send-webhooks-in-zaps)",[179],"61d7146c-008f-11f1-962f-42dde27851f2","PROMPT.txt","019c20b2-f3ce-7422-9174-4163bebba946",["D",1770075124586],"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 a lead and it's your job to exhaustively research the person by visiting their \nlinks, finding 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 \"match\": boolean,\n \"reasoning\": string\n}",[185],"pulls","forks","envVars",{"_196":198,"_199":198},"connections",{"_196":57,"_197":57},"count","unfilledCount",2,"emptyCount",{"_20":184,"_13":185,"_140":186,"_142":-5,"_143":21,"_144":30,"_145":53,"_22":226,"_29":57,"_147":110,"_149":188,"_151":40,"_152":-5,"_208":227,"_98":228},{"_20":178,"_13":179,"_140":180,"_142":-5,"_143":21,"_144":30,"_145":53,"_22":223,"_29":57,"_147":110,"_149":182,"_151":40,"_152":-5,"_208":224,"_98":225},{"_20":172,"_13":173,"_140":174,"_142":-5,"_143":21,"_144":30,"_145":53,"_22":220,"_29":57,"_147":148,"_149":176,"_151":40,"_152":-5,"_208":221,"_98":222},{"_20":166,"_13":167,"_140":168,"_142":-5,"_143":21,"_144":30,"_145":53,"_22":217,"_29":57,"_147":148,"_149":170,"_151":40,"_152":-5,"_208":218,"_98":219},{"_20":160,"_13":161,"_140":162,"_142":-5,"_143":21,"_144":30,"_145":53,"_22":214,"_29":57,"_147":148,"_149":164,"_151":40,"_152":-5,"_208":215,"_98":216},{"_20":154,"_13":155,"_140":51,"_142":-5,"_143":21,"_144":30,"_145":53,"_22":211,"_29":57,"_147":157,"_149":158,"_151":40,"_152":-5,"_208":212,"_98":213},{"_20":138,"_13":139,"_140":141,"_142":-5,"_143":21,"_144":30,"_145":53,"_22":207,"_29":57,"_147":148,"_149":150,"_151":40,"_152":-5,"_208":209,"_98":210},["D",1770075124586],"children",[],[139],["D",1770075124586],[],[155],["D",1770075124586],[],[161],["D",1770075124586],[],[167],["D",1770075124586],[],[173],["D",1770075124586],[],[179],["D",1770075124586],[],[185],["D",1770075124586],["D",1789556471789],{"_11":12,"_96":92},{"_11":12,"_90":-5,"_91":92,"_48":49,"_93":94,"_95":40},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":32,"_33":34,"_83":42,"_84":85,"_86":87,"_88":14,"_89":12},"ctx",{"_76":-5,"_120":267,"_268":269,"_270":271,"_272":40,"_273":40,"_274":40,"_275":53,"_276":-5,"_277":-7,"_278":-7,"_279":57,"_280":40,"_281":40,"_282":-5,"_283":40,"_284":40,"_285":40,"_286":-5},"ENV",{"_238":239,"_240":241,"_242":26,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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"]

Branches1

Branches
1