\n ${lead.first_name} ${lead.last_name} from ${lead.company_name}\n

\n Name: ${lead.first_name} ${lead.last_name}
\n Title: ${lead.title || \"N/A\"}
\n Company: ${lead.company_name || \"N/A\"}
\n Email: ${\n lead.business_email\n ? `${lead.business_email}`\n : \"N/A\"\n }
\n LinkedIn: ${\n lead.linkedin_url\n ? `${lead.linkedin_url}`\n : \"N/A\"\n }
\n Location: ${\n [lead.city, lead.state].filter(Boolean).join(\", \") || \"N/A\"\n }
\n ${\n lead.website\n ? `Website: ${lead.website}
`\n : \"\"\n }\n

\n Why they're ideal:\n

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

\n `).join(\"\");\n\n return `\n \n \n \n \n \n \n \n

🎯 Today's Ideal Leads

${leads.length} ideal customer${\n leads.length !== 1 ? \"s\" : \"\"\n } identified today

\n ${leadCards}\n

\n Sent by RB2B Lead Scorer\n

\n \n \n `;\n}",[148],"34bbd658-d91a-11f0-8ded-42dde27851f2","db.ts","019aef13-0475-73bd-b8a8-3f231c175637",27,["D",1765736702552],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nconst TABLE_NAME = \"rb2b_leads_v2\";\n\nawait createTable();\n\nexport async function storeLead(\n runId: number,\n input: Record,\n output: { idealCustomer: boolean; reasoning: string },\n) {\n await sqlite.execute(\n `INSERT INTO ${TABLE_NAME} (\n run_id, linkedin_url, first_name, last_name, title, company_name,\n business_email, website, industry, employee_count, estimated_revenue,\n city, state, zipcode, seen_at, referrer, captured_url, tags,\n ideal_customer, reasoning\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n runId,\n input[\"LinkedIn URL\"],\n input[\"First Name\"],\n input[\"Last Name\"],\n input[\"Title\"],\n input[\"Company Name\"],\n input[\"Business Email\"],\n input[\"Website\"],\n input[\"Industry\"],\n input[\"Employee Count\"],\n input[\"Estimate Revenue\"],\n input[\"City\"],\n input[\"State\"],\n input[\"Zipcode\"],\n input[\"Seen At\"],\n input[\"Referrer\"],\n input[\"Captured URL\"],\n input[\"Tags\"],\n output.idealCustomer ? 1 : 0,\n output.reasoning,\n ],\n );\n}\n\nexport interface Lead {\n run_id: number;\n first_name: string;\n last_name: string;\n title: string;\n company_name: string;\n business_email: string;\n linkedin_url: string;\n city: string;\n state: string;\n website: string;\n reasoning: string;\n}\n\nexport async function getIdealLeadsSince(\n sinceTimestamp: number,\n): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLE_NAME} \n WHERE ideal_customer = 1 \n AND run_id > ?\n ORDER BY run_id DESC`,\n [sinceTimestamp],\n );\n\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;\n });\n}\n\nasync function createTable() {\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS ${TABLE_NAME} (\n run_id INTEGER PRIMARY KEY,\n linkedin_url TEXT,\n first_name TEXT,\n last_name TEXT,\n title TEXT,\n company_name TEXT,\n business_email TEXT,\n website TEXT,\n industry TEXT,\n employee_count TEXT,\n estimated_revenue TEXT,\n city TEXT,\n state TEXT,\n zipcode TEXT,\n seen_at TEXT,\n referrer TEXT,\n captured_url TEXT,\n tags TEXT,\n ideal_customer INTEGER,\n reasoning TEXT\n )`,\n );\n}",[156],"ea60ffae-d1ec-11f0-9552-42dde27851f2","dashboard.tsx","019aef13-0475-73bd-b8a8-38c1abd20277",["D",1764947592239],"/** @jsxImportSource npm:hono@4/jsx */\nimport { Hono } from \"npm:hono@4\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\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, isIdeal }: { lead: any; isIdeal: boolean }) {\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 {lead.firstName} {lead.lastName}\n \n ·\n \n {lead.title} @ {lead.company}\n \n {date}\n \n );\n}\n\n// List all runs - SQLite only\napp.get(\"/\", async (c) => {\n const leads: any[] = [];\n\n try {\n const result = await sqlite.execute(\n \"SELECT * FROM rb2b_leads_v2 ORDER BY run_id DESC\",\n );\n for (const row of result.rows) {\n const columns = result.columns;\n const rowObj: Record = {};\n columns.forEach((col, idx) => {\n rowObj[col] = row[idx];\n });\n\n const runId = rowObj.run_id;\n const timestamp = runId;\n\n leads.push({\n runId,\n timestamp,\n firstName: rowObj.first_name || \"Unknown\",\n lastName: rowObj.last_name || \"\",\n title: rowObj.title || \"Unknown\",\n company: rowObj.company_name || \"Unknown\",\n idealCustomer: rowObj.ideal_customer === 1,\n });\n }\n } catch (e) {\n // Table doesn't exist yet - that's fine\n }\n\n const ideal = leads.filter((l) => l.idealCustomer);\n const nonIdeal = leads.filter((l) => !l.idealCustomer);\n const totalIdeal = ideal.length;\n\n return c.html(\n \n

RB2B Lead Scorer

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

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

\n No leads yet. Trigger the webhook to see results here.\n

\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 {ideal.length === 0 && nonIdeal.length === 0 && (\n

\n No leads yet\n

\n )}\n

\n ,\n );\n});\n\n// View specific run details - uses blob\napp.get(\"/run/:runId\", async (c) => {\n const runId = c.req.param(\"runId\");\n\n const runData = await blob.getJSON(`rb2b-lead-scores/${runId}`);\n\n if (!runData) {\n return c.html(\n \n

Run Not Found

\n The requested run could not be found.\n

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

\n ,\n 404,\n );\n }\n\n // Get SQLite row if exists\n let sqlRow: Record | null = null;\n try {\n const sqlResult = await sqlite.execute(\n \"SELECT * FROM rb2b_leads_v2 WHERE run_id = ?\",\n [runId],\n );\n if (sqlResult.rows.length > 0) {\n const columns = sqlResult.columns;\n const row = sqlResult.rows[0];\n sqlRow = {};\n columns.forEach((col, idx) => {\n sqlRow![col] = row[idx];\n });\n }\n } catch (e) {\n // Table might not exist\n }\n\n const output = runData.finalOutput ? JSON.parse(runData.finalOutput) : null;\n const input = runData.input || {};\n\n return c.html(\n \n

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

\n {input[\"First Name\"] || sqlRow?.first_name || \"Unknown\"}{\" \"}\n {input[\"Last Name\"] || sqlRow?.last_name || \"\"}\n

\n {input[\"Title\"] || sqlRow?.title || \"Unknown\"} @{\" \"}\n {input[\"Company Name\"] || sqlRow?.company_name || \"Unknown\"}\n

\n {new Date(parseInt(runId)).toLocaleString()}\n

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

\n \n \n {output?.idealCustomer ? \"Ideal Customer\" : \"Not Ideal Customer\"}\n \n

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

\n\n {/* Input Data */}\n

\n Input Data\n

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

{key}

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

\n\n {/* SQL Row if exists */}\n {sqlRow && (\n

\n SQLite Row\n

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

{key}

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

\n )}\n\n {/* Full Blob Data */}\n

\n Full Blob Data (debug)\n

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

\n \n ,\n );\n});\n\nexport default app.fetch;",[163],"e8457298-222a-11f1-92f9-42dde27851f2","agent.ts","019aef13-0475-73bd-b8a8-37937ff115f7",["D",1773770310585],4,"import { readFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { Agent, run, webSearchTool } from \"npm:@openai/agents@0.7\";\nimport { blob } from \"https://esm.town/v/std/blob\";\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 runAgent(data) {\n const runId = Date.now();\n\n const result = await run(agent, JSON.stringify(data));\n\n // Full debug to blob\n await blob.setJSON(`rb2b-lead-scores/${runId}`, {\n timestamp: runId,\n input: data,\n fullResult: result,\n finalOutput: result.finalOutput,\n });\n\n const output = JSON.parse(result.finalOutput);\n await storeLead(runId, data, output);\n\n console.log(`/rb2b-lead-scores/${runId}`);\n console.log(result.finalOutput);\n\n return output;\n}",[169],"e83707f2-d9f6-11f0-982a-42dde27851f2","README.md","019aef13-0475-73bd-b8a8-30e1b7528a82",31,["D",1765831492948],25,"# RB2B Lead Filter\n\nConnect this val to RB2B for an AI-powered digest of your most qualified leads.\n\n\n\n## Getting started\n\n1. [**Remix this val**](/?intent=remix)\n2. Set [`OPENAI_API_KEY`](/environment-variables?key=OPENAI_API_KEY) in this\n val's environment variables\n3. Copy the HTTP endpoint for [`main.ts`](./main.ts) into\n [rb2b's webhook integration](https://app.rb2b.com/integrations/webhook)\n4. Customize [`PROMPT.txt`](./PROMPT.txt)\n5. Specify which email(s) in `RECIPIENTS` in [`digest.ts`](./digest.ts)\n\nYou will receive a daily email of only your most qualified RB2B leads at 8am\nPST.\n\n## How it works\n\n- Once you've added your val's HTTP endpoint\n [rb2b's webhook integration](https://app.rb2b.com/integrations/webhook), rb2b\n will begin forwarding every new lead to this val.\n- When a new lead comes in from RB2B, it is forwarded along with the\n instructions in [`PROMPT.txt`](./PROMPT.txt) to an OpenAI agent. The agent\n uses its reasoning and web search tool to determine if the lead represents an\n `idealCustomer` and explains its `reasoning`.\n- The RB2B data and agent results are saved in the `rb2b_leads_v2` sqlite table,\n and the agent's entire run history is saved in blob storage.\n- The [`main.ts`](./main.ts) dashboard shows a history of all runs, ideal\n customers first. Clicking any lead will take you to its `runId` page, where\n you can view the agent's reasoning as well as all sqlite and blob data from\n the entire process (this is what is included when an `idealCustomer` is added\n to the email digest):\n\n\n\n- [`digest.ts`](./digest.ts) runs every day at 8am PST by default.\n- Feel free to change the timing and frequency of the [`digest.ts`](./digest.ts)\n cron. It always checks when it was last run and sends every new\n `idealCustomer` to the owner of this val (and any additional email addresses\n included in the `recipients` array).",[176],"ea60e7ee-d1ec-11f0-9552-42dde27851f2","PROMPT.txt","019aef13-0475-73bd-b8a8-2d95735de41a",["D",1764947592239],"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 website visitors and it's your job to exhuastively 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 idealCustomer: boolean;\n reasoning: string;\n}",[184],"pulls","forks","envVars",{"_195":133,"_197":55},"connections",{"_195":55,"_196":55},"count","unfilledCount","emptyCount",{"_20":183,"_13":184,"_125":185,"_127":-5,"_128":21,"_129":133,"_131":51,"_22":228,"_29":55,"_134":104,"_136":187,"_138":38,"_139":-5,"_207":229,"_92":230},{"_20":175,"_13":176,"_125":177,"_127":-5,"_128":21,"_129":178,"_131":51,"_22":225,"_29":180,"_134":104,"_136":181,"_138":38,"_139":-5,"_207":226,"_92":227},{"_20":168,"_13":169,"_125":170,"_127":-5,"_128":21,"_129":30,"_131":51,"_22":222,"_29":172,"_134":135,"_136":173,"_138":38,"_139":-5,"_207":223,"_92":224},{"_20":162,"_13":163,"_125":164,"_127":-5,"_128":21,"_129":133,"_131":51,"_22":219,"_29":55,"_134":135,"_136":166,"_138":38,"_139":-5,"_207":220,"_92":221},{"_20":155,"_13":156,"_125":157,"_127":-5,"_128":21,"_129":158,"_131":51,"_22":216,"_29":133,"_134":135,"_136":160,"_138":38,"_139":-5,"_207":217,"_92":218},{"_20":147,"_13":148,"_125":149,"_127":-5,"_128":21,"_129":150,"_131":51,"_22":213,"_29":133,"_134":152,"_136":153,"_138":38,"_139":-5,"_207":214,"_92":215},{"_20":141,"_13":142,"_125":49,"_127":-5,"_128":21,"_129":133,"_131":51,"_22":210,"_29":55,"_134":144,"_136":145,"_138":38,"_139":-5,"_207":211,"_92":212},{"_20":123,"_13":124,"_125":126,"_127":-5,"_128":21,"_129":130,"_131":51,"_22":206,"_29":133,"_134":135,"_136":137,"_138":38,"_139":-5,"_207":208,"_92":209},["D",1765135872919],"children",[],[124],["D",1764947592239],[],[142],["D",1764951470901],[],[148],["D",1765736702552],[],[156],["D",1764947592239],[],[163],["D",1773770310585],[],[169],["D",1765831492948],[],[176],["D",1764947592239],[],[184],["D",1764947592239],{"_11":12,"_90":86},{"_11":12,"_83":84,"_85":86,"_46":-5,"_87":88,"_89":51},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_78":-5,"_79":-5,"_80":-5,"_81":14,"_82":12},"ctx",{"_71":-5,"_112":268,"_269":270,"_271":272,"_273":38,"_274":38,"_275":38,"_276":51,"_277":-5,"_278":-7,"_279":-7,"_280":55,"_281":38,"_282":38,"_283":-5,"_284":38,"_285":38,"_286":38,"_287":-5},"ENV",{"_239":240,"_241":242,"_243":26,"_244":245,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259,"_260":261,"_262":263,"_264":265,"_266":267},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e8c4b7030cb7600e4eb0736b15f422c8b8bd130f","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