[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_109":110,"_111":112},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","dlxdesigns","name","dlx-lead-engine","path","lib/store.ts","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":61,"_62":34,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":70,"_71":72,"_73":74,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":86,"_87":88,"_89":90,"_91":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/dlxdesigns/dlx-lead-engine/code/lib/store.ts","extension","id","abee7f6a-ac4f-4a95-916e-742ff8f55065","store.ts","fileId","7352bd2e-a7b3-11f1-8441-1607ee4eb77e","parentId","fe6b2353-480a-42ee-a223-c012db3921e4","branchId","faea9245-6732-47d9-a1a2-3550998bc296","branchVersion",33,"latest",true,"createdAt",["D",1788493707488],"version",1,"fileType","script","content","// lib/store.ts\n// Persistence for DLX Designs verified leads — the growth engine's store.\n//\n// The val's project-scoped SQLite database is the authoritative store (zero\n// config, isolated to this val). If SUPABASE_URL + SUPABASE_SERVICE_ROLE_KEY\n// are set, every insert is ALSO mirrored to a Supabase `dlx_verified_leads`\n// table. Supabase is strictly optional.\n//\n// Every record carries evidence: where it came from (source/source_url), what\n// was said (evidence = raw inquiry), and when (captured_at). No information is\n// ever invented.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { STAGES } from \"../backend/pipeline.ts\";\n\nexport interface Lead {\n id: string;\n name: string;\n gmail: string;\n phone: string;\n score: number; // 0..100\n source: string;\n source_url: string;\n evidence: string; // raw inquiry / provenance text\n signal: string; // buying signal summary\n action: string; // recommended next action\n status: string; // pipeline stage (see STAGES)\n history: StageEvent[]; // stage-transition trail\n created_at: string;\n updated_at: string;\n}\n\nexport interface StageEvent {\n from: string;\n to: string;\n at: string;\n note?: string;\n}\n\nexport async function initDb(): Promise {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS dlx_verified_leads (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n gmail TEXT NOT NULL UNIQUE,\n phone TEXT NOT NULL DEFAULT '',\n score INTEGER NOT NULL DEFAULT 0,\n source TEXT NOT NULL DEFAULT '',\n source_url TEXT NOT NULL DEFAULT '',\n evidence TEXT NOT NULL DEFAULT '',\n signal TEXT NOT NULL DEFAULT '',\n action TEXT NOT NULL DEFAULT '',\n status TEXT NOT NULL DEFAULT 'new',\n history TEXT NOT NULL DEFAULT '[]',\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n updated_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`);\n // Migrations for pre-existing tables (idempotent)\n await ensureColumn(\"phone\", \"TEXT NOT NULL DEFAULT ''\");\n await ensureColumn(\"source_url\", \"TEXT NOT NULL DEFAULT ''\");\n await ensureColumn(\"evidence\", \"TEXT NOT NULL DEFAULT ''\");\n await ensureColumn(\"action\", \"TEXT NOT NULL DEFAULT ''\");\n await ensureColumn(\"status\", \"TEXT NOT NULL DEFAULT 'new'\");\n await ensureColumn(\"history\", \"TEXT NOT NULL DEFAULT '[]'\");\n await ensureColumn(\"updated_at\", \"TEXT NOT NULL DEFAULT (datetime('now'))\");\n}\n\nasync function ensureColumn(column: string, ddl: string): Promise {\n try {\n await sqlite.execute(`ALTER TABLE dlx_verified_leads ADD COLUMN ${column} ${ddl}`);\n } catch {\n /* column already exists — safe to ignore */\n }\n}\n\nexport type LeadSeed = Omit;\n\n/** Insert a genuinely-captured, already-qualified lead. Null on duplicate gmail. */\nexport async function insertLead(seed: LeadSeed): Promise {\n await initDb();\n const now = new Date().toISOString();\n const row: Lead = {\n id: crypto.randomUUID(),\n created_at: now,\n updated_at: now,\n history: [],\n ...seed,\n };\n try {\n await sqlite.execute({\n sql: `INSERT INTO dlx_verified_leads\n (id, name, gmail, phone, score, source, source_url, evidence, signal,\n action, status, history, created_at, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n row.id, row.name, row.gmail, row.phone, row.score, row.source,\n row.source_url, row.evidence, row.signal, row.action,\n row.status, JSON.stringify(row.history), row.created_at, row.updated_at,\n ],\n });\n } catch (err) {\n if (String((err as Error)?.message ?? err).includes(\"UNIQUE\")) {\n return null; // duplicate gmail\n }\n throw err;\n }\n await mirrorToSupabase(row);\n return row;\n}\n\nexport async function listLeads(limit = 200): Promise {\n await initDb();\n const res = await sqlite.execute(\n `SELECT * FROM dlx_verified_leads ORDER BY score DESC, created_at DESC LIMIT ?`,\n [limit],\n );\n return (res.rows as Record[]).map((r) => hydrate(r));\n}\n\nexport async function getLead(id: string): Promise {\n await initDb();\n const res = await sqlite.execute(\n `SELECT * FROM dlx_verified_leads WHERE id = ?`,\n [id],\n );\n const row = res.rows[0] as Record | undefined;\n return row ? hydrate(row) : null;\n}\n\n/**\n * Move a lead to the next pipeline stage (or any valid stage). Records a\n * history event so the business can learn which stages convert.\n */\nexport async function setLeadStatus(\n id: string,\n to: string,\n note?: string,\n): Promise {\n await initDb();\n const target = to.toLowerCase().replace(/ /g, \"_\");\n if (!STAGES.includes(target)) {\n throw new Error(`Invalid stage '${to}'. Allowed: ${STAGES.join(\", \")}`);\n }\n const lead = await getLead(id);\n if (!lead) return null;\n\n const at = new Date().toISOString();\n const event: StageEvent = {\n from: lead.status,\n to: target,\n at,\n note: note?.slice(0, 300),\n };\n const history = [...lead.history, event];\n await sqlite.execute(\n `UPDATE dlx_verified_leads SET status = ?, history = ?, updated_at = ? WHERE id = ?`,\n [target, JSON.stringify(history), at, id],\n );\n return { ...lead, status: target, history, updated_at: at };\n}\n\n// --- Analytics / learn ----------------------------------------------------\nexport interface StageCount {\n status: string;\n count: number;\n}\n\nexport async function stageDistribution(): Promise {\n await initDb();\n const res = await sqlite.execute(\n `SELECT status, COUNT(*) AS count FROM dlx_verified_leads GROUP BY status`,\n );\n return STAGES.map((s) => {\n const found = (res.rows as Record[]).find(\n (r) => r.status === s,\n );\n return { status: s, count: found ? Number(found.count) : 0 };\n });\n}\n\nexport async function topSources(limit = 6): Promise<{ source: string; count: number }[]> {\n await initDb();\n const res = await sqlite.execute(\n `SELECT source, COUNT(*) AS count, AVG(score) AS avg_score\n FROM dlx_verified_leads GROUP BY source ORDER BY count DESC LIMIT ?`,\n [limit],\n );\n return (res.rows as Record[]).map((r) => ({\n source: String(r.source || \"inbound-form\"),\n count: Number(r.count),\n }));\n}\n\nexport async function topSignals(limit = 6): Promise<{ signal: string; count: number }[]> {\n await initDb();\n const res = await sqlite.execute(\n `SELECT signal, COUNT(*) AS count FROM dlx_verified_leads\n GROUP BY signal ORDER BY count DESC LIMIT ?`,\n [limit],\n );\n return (res.rows as Record[]).map((r) => ({\n signal: String(r.signal),\n count: Number(r.count),\n }));\n}\n\nfunction hydrate(r: Record): Lead {\n let history: StageEvent[] = [];\n try {\n history = JSON.parse(String(r.history ?? \"[]\"));\n } catch {\n history = [];\n }\n return {\n id: String(r.id),\n name: String(r.name),\n gmail: String(r.gmail),\n phone: String(r.phone ?? \"\"),\n score: Number(r.score ?? 0),\n source: String(r.source ?? \"\"),\n source_url: String(r.source_url ?? \"\"),\n evidence: String(r.evidence ?? \"\"),\n signal: String(r.signal ?? \"\"),\n action: String(r.action ?? \"\"),\n status: String(r.status ?? \"new\"),\n history,\n created_at: String(r.created_at ?? \"\"),\n updated_at: String(r.updated_at ?? \"\"),\n };\n}\n\nasync function mirrorToSupabase(lead: Lead): Promise {\n const url = Deno.env.get(\"SUPABASE_URL\");\n const key = Deno.env.get(\"SUPABASE_SERVICE_ROLE_KEY\");\n if (!url || !key) return;\n try {\n const res = await fetch(\n `${url.replace(/\\/$/, \"\")}/rest/v1/dlx_verified_leads`,\n {\n method: \"POST\",\n headers: {\n apikey: key,\n Authorization: `Bearer ${key}`,\n \"Content-Type\": \"application/json\",\n Prefer: \"resolution=merge-duplicates\",\n },\n body: JSON.stringify({\n id: lead.id,\n name: lead.name,\n gmail: lead.gmail,\n phone: lead.phone,\n score: lead.score,\n source: lead.source,\n source_url: lead.source_url,\n evidence: lead.evidence,\n signal: lead.signal,\n action: lead.action,\n status: lead.status,\n created_at: lead.created_at,\n updated_at: lead.updated_at,\n }),\n },\n );\n if (!res.ok) {\n console.error(\"Supabase mirror HTTP\", res.status, await res.text());\n }\n } catch (err) {\n console.error(\"Supabase mirror failed:\", err);\n }\n}\n","deleted",false,"label",[47,24],"lib","d2f8de76-3d02-4949-8a06-2f7cc759dae3",["D",1788452396724],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","DLX Designs lead qualification engine + React dashboard","imageUrl","userId","0e434874-725d-4e49-bc72-a0c364fc943f","pinnedFileId","01a06811-df40-730d-85ee-1ae96a373bd7","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a04e8e-cc2d-73ad-9a1b-036254519f63","tursoName","d2f8de763d0249498a062f7cc759dae3","tursoHostname","d2f8de763d0249498a062f7cc759dae3-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789494036282],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_108":-5},"org",{"_9":10,"_102":103,"_104":-5,"_58":-5,"_105":106,"_107":44},"branch",{"_37":92,"_11":93,"_22":30,"_94":48,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":12,"_101":10},"isOwned",88,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","DLXdesigns ","avatar","tier","free","canRestrictVals","profileImageUrl","ctx",{"_85":-5,"_142":143,"_144":145,"_146":147,"_148":44,"_149":44,"_150":44,"_151":34,"_152":-5,"_153":-7,"_154":-7,"_155":66,"_156":44,"_157":44,"_158":-5,"_159":44,"_160":44,"_161":44,"_162":-5},"ENV",{"_113":114,"_115":116,"_117":93,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139,"_140":141},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]