[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_220":221,"_222":223},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_109":90,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":-5,"_123":25,"_124":125,"_126":25,"_127":-5,"_128":-5,"_129":130},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",22,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","claude.ts","latestPath","fileId","ce51af9c-af05-11f1-a818-1607ee4eb77e","name","fileType","script","content","const MODEL = \"claude-sonnet-5\";\n\nasync function callClaude(opts: {\n system?: string;\n messages: { role: \"user\" | \"assistant\"; content: string }[];\n tools?: unknown[];\n max_tokens?: number;\n}) {\n const key = Deno.env.get(\"ANTHROPIC_API_KEY\");\n if (!key) throw new Error(\"ANTHROPIC_API_KEY not set\");\n const res = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": key,\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: MODEL,\n max_tokens: opts.max_tokens ?? 4096,\n system: opts.system,\n messages: opts.messages,\n tools: opts.tools,\n }),\n });\n if (!res.ok) throw new Error(`Anthropic API error: ${res.status} ${await res.text()}`);\n return res.json();\n}\n\nfunction textFromResponse(resp: any): string {\n return (resp.content ?? [])\n .filter((b: any) => b.type === \"text\")\n .map((b: any) => b.text)\n .join(\"\\n\");\n}\n\nfunction extractJson(text: string): any {\n const match = text.match(/\\[[\\s\\S]*\\]|\\{[\\s\\S]*\\}/);\n if (!match) throw new Error(`No JSON found in Claude response: ${text.slice(0, 500)}`);\n return JSON.parse(match[0]);\n}\n\nexport async function sourceCandidates(\n excludeDomains: string[],\n count: number,\n): Promise> {\n const system =\n `You are a B2B lead researcher for an AI-automation agency (Install and Scale) that sells to owner-operated professional services firms in Australia (accounting, legal, construction/trades admin, health admin) with 7-50 staff. You find companies showing active hiring signals in finance/accounting/admin/estimating/legal-support roles — 2+ simultaneous open roles is the strongest signal. Bias toward Melbourne and Australia broadly. Deprioritize enterprises (500+ staff, national firms) hard — one \"ambition target\" (200+ staff) at most.`;\n const exclude = excludeDomains.length\n ? `\\n\\nDo NOT include any of these domains, already in the pipeline: ${excludeDomains.join(\", \")}`\n : \"\";\n const user = `Search current job listings (Seek, Indeed, LinkedIn Jobs, company career pages) for Australian firms matching the profile above. Find up to ${count} companies. For each, return:\n- company: legal/trading name\n- domain: best-guess company website domain (bare, no protocol/www)\n- painSignal: one sentence, the specific roles they're hiring + where you saw it (must be a real, checkable signal — no invention)\n- niche: one of accounting, legal, construction, trades, health, auto, marketing, other\n- sizeBand: one of <10, 10-50, 50-200, 200+ (your best estimate)\n- sourceUrl: the job listing or page URL you found this on\n${exclude}\n\nRespond with ONLY a JSON array of objects with those five keys plus sourceUrl. No prose, no markdown fences.`;\n\n const resp = await callClaude({\n system,\n messages: [{ role: \"user\", content: user }],\n tools: [{ type: \"web_search_20250305\", name: \"web_search\", max_uses: 3 }],\n max_tokens: 4096,\n });\n return extractJson(textFromResponse(resp));\n}\n\nexport async function enrichContact(\n company: string,\n domain: string,\n painSignal: string,\n): Promise<{\n contactName: string | null;\n contactRole: string | null;\n linkedinUrl: string | null;\n email: string | null;\n emailConfidence: \"verified\" | \"pattern-unverified\" | \"unknown\";\n}> {\n const system = `You research B2B contacts. You NEVER invent an email address or a name — if you cannot verify something, say so explicitly.`;\n const user = `Company: ${company} (${domain}). Hiring signal: ${painSignal}.\n\nFind the most likely decision-maker (owner, managing director, or partner for a firm this size; finance director only if no owner/MD findable) via the company website (About/Team pages) and public LinkedIn search. Then determine their work email:\n1. If you find a directly published email for them or a named contact, that's \"verified\".\n2. Otherwise infer a pattern (first@domain, first.last@domain, etc.) from any other visible email at the domain, and mark \"pattern-unverified\".\n3. If nothing at all, mark \"unknown\" and leave email null.\n\nRespond with ONLY a JSON object: { \"contactName\": string|null, \"contactRole\": string|null, \"linkedinUrl\": string|null, \"email\": string|null, \"emailConfidence\": \"verified\"|\"pattern-unverified\"|\"unknown\" }. No prose.`;\n\n const resp = await callClaude({\n system,\n messages: [{ role: \"user\", content: user }],\n tools: [{ type: \"web_search_20250305\", name: \"web_search\", max_uses: 3 }],\n max_tokens: 2048,\n });\n return extractJson(textFromResponse(resp));\n}\n\n","const MODEL = \"claude-sonnet-5\";\n\nasync function callClaude(opts: {\n system?: string;\n messages: { role: \"user\" | \"assistant\"; content: string }[];\n tools?: unknown[];\n max_tokens?: number;\n}) {\n const key = Deno.env.get(\"ANTHROPIC_API_KEY\");\n if (!key) throw new Error(\"ANTHROPIC_API_KEY not set\");\n const res = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": key,\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: MODEL,\n max_tokens: opts.max_tokens ?? 4096,\n system: opts.system,\n messages: opts.messages,\n tools: opts.tools,\n }),\n });\n if (!res.ok) throw new Error(`Anthropic API error: ${res.status} ${await res.text()}`);\n return res.json();\n}\n\nfunction textFromResponse(resp: any): string {\n return (resp.content ?? [])\n .filter((b: any) => b.type === \"text\")\n .map((b: any) => b.text)\n .join(\"\\n\");\n}\n\nfunction extractJson(text: string): any {\n const match = text.match(/\\[[\\s\\S]*\\]|\\{[\\s\\S]*\\}/);\n if (!match) throw new Error(`No JSON found in Claude response: ${text.slice(0, 500)}`);\n return JSON.parse(match[0]);\n}\n\nexport async function sourceCandidates(\n excludeDomains: string[],\n count: number,\n): Promise> {\n const system =\n `You are a B2B lead researcher for an AI-automation agency (Install and Scale) that sells to owner-operated professional services firms in Australia (accounting, legal, construction/trades admin, health admin) with 7-50 staff. You find companies showing active hiring signals in finance/accounting/admin/estimating/legal-support roles — 2+ simultaneous open roles is the strongest signal. Bias toward Melbourne and Australia broadly. Deprioritize enterprises (500+ staff, national firms) hard — one \"ambition target\" (200+ staff) at most.`;\n const exclude = excludeDomains.length\n ? `\\n\\nDo NOT include any of these domains, already in the pipeline: ${excludeDomains.join(\", \")}`\n : \"\";\n const user = `Search current job listings (Seek, Indeed, LinkedIn Jobs, company career pages) for Australian firms matching the profile above. Find up to ${count} companies. For each, return:\n- company: legal/trading name\n- domain: best-guess company website domain (bare, no protocol/www)\n- painSignal: one sentence, the specific roles they're hiring + where you saw it (must be a real, checkable signal — no invention)\n- niche: one of accounting, legal, construction, trades, health, auto, marketing, other\n- sizeBand: one of <10, 10-50, 50-200, 200+ (your best estimate)\n- sourceUrl: the job listing or page URL you found this on\n${exclude}\n\nRespond with ONLY a JSON array of objects with those five keys plus sourceUrl. No prose, no markdown fences.`;\n\n const resp = await callClaude({\n system,\n messages: [{ role: \"user\", content: user }],\n tools: [{ type: \"web_search_20250305\", name: \"web_search\", max_uses: 3 }],\n max_tokens: 4096,\n });\n return extractJson(textFromResponse(resp));\n}\n\n// Used only when no personal contact email was found (falling back to a\n// hello@ address) — leads with the specific role they're hiring for instead\n// of the standard opener, since a generic inbox is more likely to forward a\n// hiring-related subject line to whoever's actually reading applications.\nexport async function draftApplicationAngleEmail(opts: {\n company: string;\n contactFirstName: string | null;\n painSignal: string;\n}): Promise<{ subject: string; body: string }> {\n const system = `You write short cold outreach emails for Install and Scale, an AI-automation agency, using a \"job application\" angle for companies where only a generic inbox (hello@) is reachable — no named contact email.\nThe real offer, always, word for word: \"We'll build {company} a customised client intelligence dashboard that finds which of their clients are ready to be upsold onto new services, free, in a 7-day trial, no strings attached.\" Never change this offer.\nStructure, matching Josh's Vault template voice exactly:\n- Subject: short, references the specific role they're hiring for (e.g. \"re: your bookkeeper listing\"), lowercase, no more than 6 words.\n- Line 1: \"Hey [name or 'there'],\" then name the exact role/signal from the hiring info given (real, must trace to it — no invention).\n- Line 2: one honest line making clear this isn't a job application, it's flagging the dashboard as something worth a look before they go through the hire.\n- Line 3: the offer sentence, adapted from the fixed offer above, with the company name substituted in.\n- Line 4: one soft CTA question.\n- Sign off: \"Josh\" on its own line.\n- No em dashes. No guarantee language beyond what's given. No warnings, disclaimers, or bracketed notes anywhere in the body.`;\n const user = `Company: ${opts.company}\nContact first name: ${opts.contactFirstName ?? \"unknown\"}\nHiring signal: ${opts.painSignal}\n\nWrite the email. Respond with ONLY a JSON object: { \"subject\": string, \"body\": string }. body uses \\\\n between lines, no HTML.`;\n\n const resp = await callClaude({\n system,\n messages: [{ role: \"user\", content: user }],\n max_tokens: 1024,\n });\n return extractJson(textFromResponse(resp));\n}\n\nexport async function enrichContact(\n company: string,\n domain: string,\n painSignal: string,\n): Promise<{\n contactName: string | null;\n contactRole: string | null;\n linkedinUrl: string | null;\n email: string | null;\n emailConfidence: \"verified\" | \"pattern-unverified\" | \"unknown\";\n}> {\n const system = `You research B2B contacts. You NEVER invent an email address or a name — if you cannot verify something, say so explicitly.`;\n const user = `Company: ${company} (${domain}). Hiring signal: ${painSignal}.\n\nFind the most likely decision-maker (owner, managing director, or partner for a firm this size; finance director only if no owner/MD findable) via the company website (About/Team pages) and public LinkedIn search. Then determine their work email:\n1. If you find a directly published email for them or a named contact, that's \"verified\".\n2. Otherwise infer a pattern (first@domain, first.last@domain, etc.) from any other visible email at the domain, and mark \"pattern-unverified\".\n3. If nothing at all, mark \"unknown\" and leave email null.\n\nRespond with ONLY a JSON object: { \"contactName\": string|null, \"contactRole\": string|null, \"linkedinUrl\": string|null, \"email\": string|null, \"emailConfidence\": \"verified\"|\"pattern-unverified\"|\"unknown\" }. No prose.`;\n\n const resp = await callClaude({\n system,\n messages: [{ role: \"user\", content: user }],\n tools: [{ type: \"web_search_20250305\", name: \"web_search\", max_uses: 3 }],\n max_tokens: 2048,\n });\n return extractJson(textFromResponse(resp));\n}\n\n","createdAt",["D",1789271433206],"branchVersion","branchId","08f99422-0c9a-4e3c-bbfd-6907824f1715","id","84efb026-701f-487f-9733-5294535036e4","dream100-daily-drafts",["D",1789257153536],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Daily cron: source prospects, draft Gmail outreach","imageUrl","de46bb12-9151-467d-93e3-b620f009a09a","pinnedFileId","ba57f678-af27-11f1-bd4a-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a00f80-dfdf-755e-9d79-bc65d75c56cd","tursoName","84efb026701f487f97335294535036e4","tursoHostname","84efb026701f487f97335294535036e4-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789530055570],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_108":104},"org",{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"isOwned",33,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","joshjefferd","handle","displayName","Josh Jefferd","avatar","https://lh3.googleusercontent.com/a/ACg8ocKamdJpU009molzl4WfsLIPiVCRhegoyuQk924iKxJFFoEx3JE=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":215,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":216,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":217,"_84":218,"_86":219,"_88":25},"tree",[190,191,192,193,194,195],"files",[190,191,192,193,194,195],"counts",{"_179":63,"_180":181,"_182":63,"_183":184,"_185":186},"contents",[131,132,133,134,135,136],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":176,"_32":28,"_30":31,"_140":-5,"_41":42,"_40":14,"_142":25,"_38":177,"_13":166,"_33":34,"_35":37,"_24":25,"_145":-5,"_27":178},{"_43":170,"_32":171,"_30":172,"_140":-5,"_41":42,"_40":159,"_142":59,"_38":173,"_13":63,"_33":34,"_35":174,"_24":25,"_145":-5,"_27":175},{"_43":163,"_32":164,"_30":165,"_140":-5,"_41":42,"_40":166,"_142":59,"_38":167,"_13":63,"_33":34,"_35":168,"_24":25,"_145":-5,"_27":169},{"_43":154,"_32":155,"_30":156,"_140":-5,"_41":42,"_40":157,"_142":25,"_38":158,"_13":159,"_33":160,"_35":161,"_24":25,"_145":-5,"_27":162},{"_43":147,"_32":148,"_30":149,"_140":-5,"_41":42,"_40":150,"_142":59,"_38":151,"_13":63,"_33":34,"_35":152,"_24":25,"_145":-5,"_27":153},{"_43":137,"_32":138,"_30":139,"_140":-5,"_41":42,"_40":141,"_142":59,"_38":143,"_13":63,"_33":34,"_35":144,"_24":25,"_145":-5,"_27":146},"380a82f1-74e6-4f54-819f-72adc5bcd00b","templates.ts","fdd854fa-af23-11f1-b0ef-1607ee4eb77e","parentId",15,"latest",["D",1789270454253],"// Vault-based A/B/C opener templates. Rotates by a stable index (queue row id)\n// so the same prospect always gets the same variant on retry.\nexport function buildTemplateEmail(\n variantSeed: number,\n firstName: string | null,\n company: string,\n): { subject: string; body: string } {\n const name = firstName || \"there\";\n\n switch (variantSeed % 3) {\n case 0:\n return {\n subject: \"Quick question\",\n body: `Hey ${name},\n\nAre you sure you're not leaving upsell revenue on the table with clients you already have?\n\nWe'll build ${company} a customised client intelligence dashboard that flags exactly which of your existing clients are ready for new services, free, in a 7-day trial.\n\nWant to see what it would surface for your client list?\n\nJosh`,\n };\n case 1:\n return {\n subject: `${company} x Install and Scale: your upsell list`,\n body: `Hey ${name},\n\nMost CAS practices are sitting on an upsell list they've never actually mapped.\n\nWe'll build ${company} a customised client intelligence dashboard that shows exactly which clients are ready for new services, free, for 7 days, no commitment.\n\nMind if I share how it'd work for your client base?\n\nJosh`,\n };\n default:\n return {\n subject: `2 things // ${name}`,\n body: `Hey ${name},\n\nI'll keep this short.\n\nWe build firms like ${company} a customised client intelligence dashboard that finds which of your clients are ready to be upsold onto new services, free, in a 7-day trial, no strings attached.\n\nWorth a look at what it'd find in your client list?\n\nJosh`,\n };\n }\n}\n","label",[138],"49dfa4f6-5807-4a08-8487-768fbb2e6176","notion.ts","b0d4a4c4-af05-11f1-a129-1607ee4eb77e",2,["D",1789257440112],"const NOTION_VERSION = \"2022-06-28\";\nconst DATABASE_ID = \"d1cb9feca3b04f508083900acfa7dff3\"; // Dream 100 Pipeline\n\nfunction notionHeaders() {\n const key = Deno.env.get(\"NOTION_API_KEY\");\n if (!key) throw new Error(\"NOTION_API_KEY not set\");\n return {\n \"Authorization\": `Bearer ${key}`,\n \"Notion-Version\": NOTION_VERSION,\n \"Content-Type\": \"application/json\",\n };\n}\n\nexport function normalizeDomain(input: string): string {\n let d = input.trim().toLowerCase();\n d = d.replace(/^https?:\\/\\//, \"\");\n d = d.replace(/^www\\./, \"\");\n d = d.split(\"/\")[0];\n d = d.split(\"?\")[0];\n return d;\n}\n\nexport async function findByDomain(domain: string): Promise {\n const res = await fetch(`https://api.notion.com/v1/databases/${DATABASE_ID}/query`, {\n method: \"POST\",\n headers: notionHeaders(),\n body: JSON.stringify({\n filter: { property: \"Domain\", rich_text: { equals: domain } },\n page_size: 1,\n }),\n });\n if (!res.ok) throw new Error(`Notion query failed: ${res.status} ${await res.text()}`);\n const data = await res.json();\n return data.results[0] ?? null;\n}\n\nexport function isDeadOver90Days(page: any): boolean {\n const status = page.properties?.[\"Status\"]?.select?.name;\n const lastTouch = page.properties?.[\"Last Touch\"]?.date?.start;\n if (status !== \"dead\" || !lastTouch) return false;\n const days = (Date.now() - new Date(lastTouch).getTime()) / 86_400_000;\n return days > 90;\n}\n\nexport async function insertProspect(p: {\n company: string;\n domain: string;\n contactName?: string;\n contactRole?: string;\n linkedinUrl?: string;\n email?: string;\n emailConfidence: \"verified\" | \"pattern-unverified\" | \"unknown\";\n painSignal: string;\n niche: string;\n sizeBand: string;\n notes?: string;\n}) {\n const today = new Date().toISOString().slice(0, 10);\n const properties: Record = {\n \"Company\": { title: [{ text: { content: p.company.slice(0, 2000) } }] },\n \"Domain\": { rich_text: [{ text: { content: p.domain } }] },\n \"Status\": { select: { name: \"new\" } },\n \"Pain Signal\": { rich_text: [{ text: { content: p.painSignal.slice(0, 2000) } }] },\n \"Niche\": { select: { name: p.niche } },\n \"Size Band\": { select: { name: p.sizeBand } },\n \"Email Confidence\": { select: { name: p.emailConfidence } },\n \"First Found\": { date: { start: today } },\n };\n if (p.contactName) properties[\"Contact Name\"] = { rich_text: [{ text: { content: p.contactName } }] };\n if (p.contactRole) properties[\"Contact Role\"] = { rich_text: [{ text: { content: p.contactRole } }] };\n if (p.linkedinUrl) properties[\"LinkedIn URL\"] = { url: p.linkedinUrl };\n if (p.email) properties[\"Email\"] = { email: p.email };\n if (p.notes) properties[\"Notes\"] = { rich_text: [{ text: { content: p.notes.slice(0, 2000) } }] };\n\n const res = await fetch(`https://api.notion.com/v1/pages`, {\n method: \"POST\",\n headers: notionHeaders(),\n body: JSON.stringify({ parent: { database_id: DATABASE_ID }, properties }),\n });\n if (!res.ok) throw new Error(`Notion insert failed: ${res.status} ${await res.text()}`);\n return res.json();\n}\n",[148],"ea77843a-08f8-47a3-8b40-4a683be1091d","main.ts","060c592e-af05-11f1-b0fb-1607ee4eb77e",17,["D",1789270471884],6,"interval","import {\n countPending,\n enqueueProspect,\n getOrCreateRun,\n initDb,\n markQueueItem,\n nextPending,\n updateRunStage,\n updateSeenDomains,\n} from \"./db.ts\";\nimport { findByDomain, insertProspect, isDeadOver90Days, normalizeDomain } from \"./notion.ts\";\nimport { enrichContact, sourceCandidates } from \"./claude.ts\";\nimport { appendDraft, findSpecialMailbox, openGmailClient, wasAlreadyEmailed } from \"./gmail.ts\";\nimport { buildTemplateEmail } from \"./templates.ts\";\n\nconst TARGET_NEW = 15;\nconst MAX_SOURCING_ROUNDS = 10;\nconst BATCH_SIZE = 5;\n\nfunction todayKey(): string {\n return new Date().toISOString().slice(0, 10);\n}\n\n// Runs as a queue tick (cron every 2 min, one phase of work per invocation) to\n// stay under Val Town's free-tier 1-minute execution cap. One tick either\n// sources a round of candidates, or enriches+drafts exactly one prospect.\nexport default async function (_interval: Interval) {\n await initDb();\n const runDate = todayKey();\n const run = await getOrCreateRun(runDate);\n\n if (run.stage === \"done\") {\n console.log(`Run for ${runDate} already complete.`);\n return;\n }\n\n const gmailUser = Deno.env.get(\"GMAIL_USER\");\n if (!gmailUser) throw new Error(\"GMAIL_USER not set\");\n\n const client = openGmailClient();\n await client.connect();\n\n try {\n const sentMailbox = await findSpecialMailbox(client, \"\\\\Sent\", \"[Gmail]/Sent Mail\");\n const draftsMailbox = await findSpecialMailbox(client, \"\\\\Drafts\", \"[Gmail]/Drafts\");\n\n if (run.stage === \"sourcing\") {\n const seenDomains: string[] = JSON.parse(run.seen_domains || \"[]\");\n const pendingSoFar = await countPending(runDate);\n const need = TARGET_NEW - pendingSoFar;\n\n if (need > 0 && run.sourcing_rounds < MAX_SOURCING_ROUNDS) {\n const candidates = await sourceCandidates(seenDomains, BATCH_SIZE);\n for (const c of candidates) {\n const domain = normalizeDomain(c.domain);\n if (!domain || seenDomains.includes(domain)) continue;\n seenDomains.push(domain);\n\n const existing = await findByDomain(domain);\n if (existing && !isDeadOver90Days(existing)) continue;\n\n const emailed = await wasAlreadyEmailed(client, sentMailbox, domain).catch(() => false);\n if (emailed) continue;\n\n await enqueueProspect(runDate, {\n company: c.company,\n domain,\n painSignal: c.painSignal,\n niche: c.niche,\n sizeBand: c.sizeBand,\n });\n }\n await updateSeenDomains(runDate, seenDomains, run.sourcing_rounds + 1);\n console.log(\n `Sourcing round ${run.sourcing_rounds + 1}: queue now has ${await countPending(runDate)} pending (target ${TARGET_NEW}).`,\n );\n }\n\n const pendingNow = await countPending(runDate);\n if (pendingNow >= TARGET_NEW || run.sourcing_rounds + 1 >= MAX_SOURCING_ROUNDS) {\n await updateRunStage(runDate, \"processing\");\n console.log(`Moving to processing stage with ${pendingNow} queued.`);\n }\n return; // one phase per tick\n }\n\n if (run.stage === \"processing\") {\n const item = await nextPending(runDate);\n if (!item) {\n await updateRunStage(runDate, \"done\");\n console.log(`All prospects processed for ${runDate}. Run complete.`);\n return;\n }\n\n try {\n const enrichment = await enrichContact(item.company, item.domain, item.pain_signal);\n const firstName = enrichment.contactName?.split(\" \")[0] ?? null;\n const emailDraft = buildTemplateEmail(item.id, firstName, item.company);\n\n const toAddress = enrichment.email ?? `hello@${item.domain}`;\n\n await appendDraft(client, draftsMailbox, {\n from: gmailUser,\n to: toAddress,\n subject: emailDraft.subject,\n body: emailDraft.body,\n });\n\n await insertProspect({\n company: item.company,\n domain: item.domain,\n contactName: enrichment.contactName ?? undefined,\n contactRole: enrichment.contactRole ?? undefined,\n linkedinUrl: enrichment.linkedinUrl ?? undefined,\n email: enrichment.email ?? undefined,\n emailConfidence: enrichment.email ? enrichment.emailConfidence : \"unknown\",\n painSignal: item.pain_signal,\n niche: item.niche,\n sizeBand: item.size_band,\n notes: enrichment.email\n ? undefined\n : `No verified/pattern email found — drafted to guessed address ${toAddress}, confirm before sending.`,\n });\n\n await markQueueItem(item.id, \"drafted\");\n console.log(`Drafted email for ${item.company} (${item.domain}).`);\n } catch (err) {\n console.error(`Failed on ${item.company} (${item.domain}):`, err);\n await markQueueItem(item.id, \"failed\", String(err));\n }\n }\n } finally {\n await client.logout();\n }\n}\n",[155],"4e996260-87d3-4f35-8fd4-564ac2c8acf9","gmail.ts","ec6dc2e0-af05-11f1-a87a-1607ee4eb77e",4,["D",1789257540142],"import { ImapFlow } from \"npm:imapflow\";\n\nexport function openGmailClient(): ImapFlow {\n const user = Deno.env.get(\"GMAIL_USER\");\n const pass = Deno.env.get(\"GMAIL_PASS\");\n if (!user || !pass) throw new Error(\"GMAIL_USER / GMAIL_PASS not set\");\n return new ImapFlow({\n host: \"imap.gmail.com\",\n port: 993,\n secure: true,\n auth: { user, pass },\n logger: false,\n });\n}\n\nexport async function findSpecialMailbox(client: ImapFlow, specialUse: string, fallback: string): Promise {\n const list = await client.list();\n return list.find((m: any) => m.specialUse === specialUse)?.path ?? fallback;\n}\n\nexport async function wasAlreadyEmailed(client: ImapFlow, sentMailbox: string, domain: string): Promise {\n const lock = await client.getMailboxLock(sentMailbox);\n try {\n const uids = await client.search({ text: domain });\n return Array.isArray(uids) && uids.length > 0;\n } finally {\n lock.release();\n }\n}\n\nexport async function appendDraft(\n client: ImapFlow,\n draftsMailbox: string,\n opts: { from: string; to: string; subject: string; body: string },\n) {\n const message = [\n `From: ${opts.from}`,\n `To: ${opts.to}`,\n `Subject: ${opts.subject}`,\n `Date: ${new Date().toUTCString()}`,\n `MIME-Version: 1.0`,\n `Content-Type: text/plain; charset=\"UTF-8\"`,\n ``,\n opts.body,\n ].join(\"\\r\\n\");\n await client.append(draftsMailbox, message, [\"\\\\Draft\", \"\\\\Seen\"]);\n}\n",[164],"145467f0-7c8d-4f5f-a233-140a0b74a68e","db.ts","743f6f02-af1f-11f1-a503-1607ee4eb77e",["D",1789268505406],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport async function initDb() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS daily_runs (\n run_date TEXT PRIMARY KEY,\n stage TEXT NOT NULL,\n seen_domains TEXT NOT NULL DEFAULT '[]',\n sourcing_rounds INTEGER NOT NULL DEFAULT 0\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS prospects_queue (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n run_date TEXT NOT NULL,\n company TEXT NOT NULL,\n domain TEXT NOT NULL,\n pain_signal TEXT NOT NULL,\n niche TEXT NOT NULL,\n size_band TEXT NOT NULL,\n stage TEXT NOT NULL DEFAULT 'pending',\n error TEXT\n )`);\n}\n\nexport async function getOrCreateRun(runDate: string): Promise<\n { run_date: string; stage: string; seen_domains: string; sourcing_rounds: number }\n> {\n const res = await sqlite.execute({ sql: \"SELECT * FROM daily_runs WHERE run_date = ?\", args: [runDate] });\n if (res.rows.length > 0) return res.rows[0] as any;\n await sqlite.execute({\n sql: \"INSERT INTO daily_runs (run_date, stage, seen_domains, sourcing_rounds) VALUES (?, 'sourcing', '[]', 0)\",\n args: [runDate],\n });\n return { run_date: runDate, stage: \"sourcing\", seen_domains: \"[]\", sourcing_rounds: 0 };\n}\n\nexport async function updateRunStage(runDate: string, stage: string) {\n await sqlite.execute({ sql: \"UPDATE daily_runs SET stage = ? WHERE run_date = ?\", args: [stage, runDate] });\n}\n\nexport async function updateSeenDomains(runDate: string, seenDomains: string[], rounds: number) {\n await sqlite.execute({\n sql: \"UPDATE daily_runs SET seen_domains = ?, sourcing_rounds = ? WHERE run_date = ?\",\n args: [JSON.stringify(seenDomains), rounds, runDate],\n });\n}\n\nexport async function enqueueProspect(\n runDate: string,\n p: { company: string; domain: string; painSignal: string; niche: string; sizeBand: string },\n) {\n await sqlite.execute({\n sql:\n `INSERT INTO prospects_queue (run_date, company, domain, pain_signal, niche, size_band, stage) VALUES (?, ?, ?, ?, ?, ?, 'pending')`,\n args: [runDate, p.company, p.domain, p.painSignal, p.niche, p.sizeBand],\n });\n}\n\nexport async function countPending(runDate: string): Promise {\n const res = await sqlite.execute({\n sql: \"SELECT COUNT(*) as c FROM prospects_queue WHERE run_date = ? AND stage = 'pending'\",\n args: [runDate],\n });\n return Number((res.rows[0] as any).c);\n}\n\nexport async function nextPending(runDate: string): Promise {\n const res = await sqlite.execute({\n sql: \"SELECT * FROM prospects_queue WHERE run_date = ? AND stage = 'pending' ORDER BY id ASC LIMIT 1\",\n args: [runDate],\n });\n return res.rows[0] ?? null;\n}\n\nexport async function markQueueItem(id: number, stage: string, error?: string) {\n await sqlite.execute({\n sql: \"UPDATE prospects_queue SET stage = ?, error = ? WHERE id = ?\",\n args: [stage, error ?? null, id],\n });\n}\n",[171],"4c3d0fe1-0035-4d44-bb30-9d54abd3df0a",["D",1789271433206],[28],"pulls","branches",1,"forks","envVars",{"_187":166,"_189":63},"connections",{"_187":63,"_188":63},"count","unfilledCount","emptyCount",{"_43":176,"_32":28,"_30":31,"_140":-5,"_41":42,"_40":14,"_142":25,"_38":212,"_13":166,"_33":34,"_35":37,"_24":25,"_145":-5,"_197":213,"_27":214},{"_43":170,"_32":171,"_30":172,"_140":-5,"_41":42,"_40":159,"_142":59,"_38":209,"_13":63,"_33":34,"_35":174,"_24":25,"_145":-5,"_197":210,"_27":211},{"_43":163,"_32":164,"_30":165,"_140":-5,"_41":42,"_40":166,"_142":59,"_38":206,"_13":63,"_33":34,"_35":168,"_24":25,"_145":-5,"_197":207,"_27":208},{"_43":154,"_32":155,"_30":156,"_140":-5,"_41":42,"_40":157,"_142":25,"_38":203,"_13":159,"_33":160,"_35":161,"_24":25,"_145":-5,"_197":204,"_27":205},{"_43":147,"_32":148,"_30":149,"_140":-5,"_41":42,"_40":150,"_142":59,"_38":200,"_13":63,"_33":34,"_35":152,"_24":25,"_145":-5,"_197":201,"_27":202},{"_43":137,"_32":138,"_30":139,"_140":-5,"_41":42,"_40":141,"_142":59,"_38":196,"_13":63,"_33":34,"_35":144,"_24":25,"_145":-5,"_197":198,"_27":199},["D",1789270454253],"children",[],[138],["D",1789257440112],[],[148],["D",1789270471884],[],[155],["D",1789257540142],[],[164],["D",1789268505406],[],[171],["D",1789271433206],[],[28],["D",1789257153536],["D",1789530055570],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_128":253,"_254":255,"_256":257,"_258":25,"_259":25,"_260":25,"_261":59,"_262":-5,"_263":-7,"_264":-7,"_265":63,"_266":25,"_267":25,"_268":-5,"_269":25,"_270":25,"_271":25,"_272":-5},"ENV",{"_224":225,"_226":227,"_228":90,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252},"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 · v22