[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_208":209,"_210":211},"routes/_app.x.$handle.$name",{"_98":97,"_31":43,"_107":88,"_26":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":24,"_122":123,"_124":57,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":24},"version",20,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","optimizer.ts","latestPath","fileId","8da9bee0-ad79-11f1-ba3c-1607ee4eb77e","name","fileType","interval","content","import { ensureSchema } from \"./db.ts\";\nimport { evaluateMarket, syncBusinesses } from \"./market.ts\";\n\nexport default async function () {\n await ensureSchema();\n const res = await fetch(\"https://vil-zero.floot.app/_api/portfolio\");\n if (!res.ok) throw new Error(\"Portfolio HTTP \" + res.status);\n const wrapper = await res.json();\n const portfolio = wrapper?.json ?? wrapper;\n const businesses = Array.isArray(portfolio?.businesses) ? portfolio.businesses : [];\n await syncBusinesses(businesses);\n const decisions = await evaluateMarket();\n console.log(JSON.stringify({ evaluated: decisions.length, decisions }));\n}","createdAt",["D",1789087300425],"branchVersion","branchId","903369b4-f0d6-41dc-af38-daedf1f00743","id","ae9b2f51-90fc-400a-a131-5546c6073fc3","vil-zero-core",["D",1789086550141],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Autonomous demand scout and x402 gateway","imageUrl","b162e777-26d5-4b57-b5d4-824de1b425e2","pinnedFileId","ce878dd6-ad77-11f1-9bcf-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a087a7-039d-766a-a2cb-d9a1a861d44b","tursoName","ae9b2f5190fc400aa1315546c6073fc3","tursoHostname","ae9b2f5190fc400aa1315546c6073fc3-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789525245864],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},"branch",{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"isOwned",76,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","agentia","handle","displayName","Agent Ia","avatar","https://lh3.googleusercontent.com/a/ACg8ocJFdiW2REahwLO-JAErcTTOgHyYDVN6VBKDk9RmathkK-sumQ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_41":42,"_31":43,"_36":203,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":204,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":205,"_82":206,"_84":207,"_86":24},"tree",[182,183,184,185,186],"files",[182,183,184,185,186],"counts",{"_171":61,"_172":173,"_174":61,"_175":176,"_177":178},"contents",[129,130,131,132,133],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":163,"_31":164,"_29":55,"_137":-5,"_39":40,"_38":165,"_139":24,"_36":166,"_13":167,"_32":168,"_34":169,"_23":24,"_143":43,"_26":170},{"_41":156,"_31":157,"_29":158,"_137":-5,"_39":40,"_38":159,"_139":24,"_36":160,"_13":61,"_32":153,"_34":161,"_23":24,"_143":-5,"_26":162},{"_41":148,"_31":149,"_29":150,"_137":-5,"_39":40,"_38":151,"_139":57,"_36":152,"_13":61,"_32":153,"_34":154,"_23":24,"_143":-5,"_26":155},{"_41":145,"_31":27,"_29":30,"_137":-5,"_39":40,"_38":14,"_139":57,"_36":146,"_13":61,"_32":33,"_34":35,"_23":24,"_143":-5,"_26":147},{"_41":134,"_31":135,"_29":136,"_137":-5,"_39":40,"_38":138,"_139":24,"_36":140,"_13":141,"_32":33,"_34":142,"_23":24,"_143":-5,"_26":144},"a4cdad58-70f9-4de0-b7f1-5884741fd314","scout.ts","011b602e-ad78-11f1-8a10-1607ee4eb77e","parentId",18,"latest",["D",1789087233612],5,"import { ensureSchema, finishScoutRun, getReadyClusters, insertSignal, markSubmission, startScoutRun } from \"./db.ts\";\n\nconst CORE_NEED = \"https://vil-zero-core.val.run/need\";\n\ntype Signal = { source:string; url:string; title:string; text:string };\n\nconst blocked = /(malware|ransomware|credential|phishing|exploit|bypass security|weapon|steal|fraud|doxx|spyware)/i;\n\nfunction classify(title:string, text:string) {\n const t = (title + \" \" + text).toLowerCase();\n if (blocked.test(t)) return null;\n const rules = [\n { key:\"schema-normalization\", re:/(json|schema|csv|normalize|parser|malformed|structured output)/, need:\"Normalize malformed or inconsistent machine-readable data into a strict, validated JSON schema for AI agents.\" },\n { key:\"mcp-adapter\", re:/(mcp|tool call|tool response|function calling|agent tool|api adapter)/, need:\"Repair or adapt incompatible AI-agent tool, MCP, or API responses into a stable executable contract.\" },\n { key:\"web-structure\", re:/(scrap|web page|website|extract.*html|browser automation|dom)/, need:\"Extract reliable structured JSON from changing web pages for autonomous AI-agent workflows.\" },\n { key:\"document-extraction\", re:/(pdf|document|invoice|receipt|form extraction|ocr)/, need:\"Extract requested structured fields from business documents and return validated machine-readable JSON.\" },\n { key:\"logistics-normalization\", re:/(shipping|shipment|tracking|carrier|logistics|parcel)/, need:\"Extract carrier, parcel tracking identifiers, and shipment-status hints from free-form logistics messages into normalized JSON.\" },\n { key:\"compatibility\", re:/(compatib|mapping|crosswalk|sku|catalog|product feed)/, need:\"Normalize product compatibility, identifiers, and supplier catalog mappings into a strict machine-readable result.\" },\n ];\n return rules.find(r => r.re.test(t)) ?? null;\n}\n\nasync function githubSignals(since:Date): Promise {\n const queries = [\n '\"MCP\" \"need\" is:issue is:open',\n '\"AI agent\" \"feature request\" is:issue is:open',\n '\"structured output\" \"issue\" is:issue is:open',\n '\"API\" \"missing\" \"agent\" is:issue is:open'\n ];\n const out:Signal[] = [];\n for (const q of queries) {\n const params = new URLSearchParams({q:q + \" created:>\" + since.toISOString().slice(0,10), sort:\"created\", order:\"desc\", per_page:\"25\"});\n const res = await fetch(\"https://api.github.com/search/issues?\" + params, {headers:{\"Accept\":\"application/vnd.github+json\",\"User-Agent\":\"VIL-ZERO-Scout\"}});\n if (!res.ok) continue;\n const data = await res.json();\n for (const item of data.items ?? []) {\n out.push({source:\"github\",url:item.html_url,title:item.title,text:(item.body ?? \"\").slice(0,1800)});\n }\n }\n return out;\n}\n\nasync function hnSignals(since:Date): Promise {\n const out:Signal[] = [];\n for (const q of [\"MCP agent tool\",\"AI agent API\",\"structured output\",\"agent automation\"]) {\n const params = new URLSearchParams({query:q,tags:\"story\",numericFilters:\"created_at_i>\" + Math.floor(since.getTime()/1000),hitsPerPage:\"40\"});\n const res = await fetch(\"https://hn.algolia.com/api/v1/search_by_date?\" + params);\n if (!res.ok) continue;\n const data = await res.json();\n for (const item of data.hits ?? []) {\n const title = item.title ?? \"\";\n const text = item.story_text ?? \"\";\n const demandText = title + \" \" + text;\n if (!/\\b(i need|we need|need a|need an|looking for|wish there|wish i|wish we|missing support|missing a|missing an|can't find|cannot find|is there a|is there an|feature request|would pay|pain point|problem with|fails when|unsupported)\\b/i.test(demandText)) continue;\n out.push({source:\"hackernews\",url:item.url || (\"https://news.ycombinator.com/item?id=\"+item.objectID),title,text:text.slice(0,1800)});\n }\n }\n return out;\n}\n\nasync function submitNeed(description:string) {\n const payload = JSON.stringify({description,maxPrice:0.02,deadlineSeconds:5});\n const res = await fetch(CORE_NEED,{method:\"POST\",headers:{\"content-type\":\"application/json\"},body:payload});\n if (!res.ok) {\n const detail = await res.text();\n throw new Error(\"Core NEED HTTP \" + res.status + \": \" + detail.slice(0,300));\n }\n return await res.json();\n}\n\nexport default async function (interval: Interval) {\n await ensureSchema();\n const runId = await startScoutRun();\n let signalsAdded=0, clustersReady=0, businessesCreated=0;\n try {\n const since = interval.lastRunAt ?? new Date(Date.now()-24*60*60*1000);\n const all = [...await githubSignals(since), ...await hnSignals(since)];\n for (const signal of all) {\n const match = classify(signal.title, signal.text);\n if (!match) continue;\n const added = await insertSignal({\n source:signal.source, sourceUrl:signal.url, title:signal.title,\n excerpt:signal.text.slice(0,700), clusterKey:match.key, canonicalNeed:match.need\n });\n if (added) signalsAdded++;\n }\n\n const ready = await getReadyClusters();\n clustersReady = ready.length;\n for (const cluster of ready) {\n const key = String(cluster.cluster_key);\n const need = String(cluster.canonical_need);\n const already = Number(cluster.submissions ?? 0);\n for (let i=already; i<6; i++) {\n try {\n const result = await submitNeed(need);\n const businessId = result?.business?.id ?? null;\n await markSubmission(key,businessId);\n if (businessId) { businessesCreated++; break; }\n } catch (error) {\n console.error(\"Factory rejected cluster\", key, String(error));\n await markSubmission(key,null);\n break;\n }\n }\n }\n await finishScoutRun(runId,{signalsAdded,clustersReady,businessesCreated});\n } catch (error) {\n await finishScoutRun(runId,{signalsAdded,clustersReady,businessesCreated,error:String(error)});\n throw error;\n }\n}","label",[135],"5750ad6c-71e5-427f-8247-9db8d7b2d474",["D",1789087300425],[27],"d827291c-5d07-4e37-b104-4bb3232eba63","market.ts","85cc168c-ad79-11f1-811d-1607ee4eb77e",19,["D",1789087287250],"script","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport async function ensureMarketSchema() {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS venture_controls (\n business_id TEXT PRIMARY KEY,\n state TEXT NOT NULL DEFAULT 'LIVE',\n price_multiplier REAL NOT NULL DEFAULT 1,\n first_seen_at TEXT NOT NULL,\n last_evaluated_at TEXT,\n reason TEXT\n )`,\n `CREATE TABLE IF NOT EXISTS purchase_attempts (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n business_id TEXT NOT NULL,\n stage TEXT NOT NULL,\n payment_key TEXT,\n observed_at TEXT NOT NULL\n )`,\n `CREATE INDEX IF NOT EXISTS idx_purchase_attempts_business_time\n ON purchase_attempts (business_id, observed_at)`\n ]);\n}\n\nexport async function applyMarketControl(business: T) {\n await ensureMarketSchema();\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `INSERT INTO venture_controls (business_id,state,price_multiplier,first_seen_at)\n VALUES (?, 'LIVE', 1, ?)\n ON CONFLICT(business_id) DO NOTHING`,\n args: [business.id, now],\n });\n const row = (await sqlite.execute({\n sql: \"SELECT * FROM venture_controls WHERE business_id=? LIMIT 1\",\n args: [business.id],\n })).rows[0] as Record | undefined;\n if (!row || row.state !== \"LIVE\") return null;\n return {\n ...business,\n pricePerCall: Number((Number(business.pricePerCall) * Number(row.price_multiplier ?? 1)).toFixed(6)),\n market: {\n state: String(row.state),\n priceMultiplier: Number(row.price_multiplier ?? 1),\n reason: row.reason ?? null,\n }\n };\n}\n\nexport async function logPurchaseAttempt(businessId: string, stage: string, paymentKey?: string | null) {\n await ensureMarketSchema();\n await sqlite.execute({\n sql: \"INSERT INTO purchase_attempts (business_id,stage,payment_key,observed_at) VALUES (?,?,?,?)\",\n args: [businessId, stage, paymentKey ?? null, new Date().toISOString()],\n });\n}\n\nexport async function syncBusinesses(businesses: Array<{ id: string }>) {\n await ensureMarketSchema();\n const now = new Date().toISOString();\n for (const business of businesses) {\n await sqlite.execute({\n sql: `INSERT INTO venture_controls (business_id,state,price_multiplier,first_seen_at)\n VALUES (?, 'LIVE', 1, ?)\n ON CONFLICT(business_id) DO NOTHING`,\n args: [business.id, now],\n });\n }\n}\n\nexport async function evaluateMarket() {\n await ensureMarketSchema();\n const controls = (await sqlite.execute(\"SELECT * FROM venture_controls\")).rows as Array>;\n const decisions: Array> = [];\n\n for (const control of controls) {\n const businessId = String(control.business_id);\n const firstSeen = new Date(String(control.first_seen_at));\n const ageDays = (Date.now() - firstSeen.getTime()) / 86400000;\n const sevenDaysAgo = new Date(Date.now() - 7 * 86400000).toISOString();\n\n const attemptsRow = (await sqlite.execute({\n sql: `SELECT COUNT(*) AS attempts\n FROM purchase_attempts\n WHERE business_id=? AND stage='challenge' AND observed_at>=?`,\n args: [businessId, sevenDaysAgo],\n })).rows[0] as Record;\n\n const paidRow = (await sqlite.execute({\n sql: `SELECT COUNT(*) AS paid_calls, COALESCE(SUM(amount_usdc),0) AS revenue\n FROM payment_events\n WHERE business_id=? AND settlement_status='success' AND created_at>=?`,\n args: [businessId, sevenDaysAgo],\n })).rows[0] as Record;\n\n const attempts = Number(attemptsRow?.attempts ?? 0);\n const paidCalls = Number(paidRow?.paid_calls ?? 0);\n const revenue = Number(paidRow?.revenue ?? 0);\n const conversion = attempts > 0 ? paidCalls / attempts : 0;\n\n let state = String(control.state);\n let multiplier = Number(control.price_multiplier ?? 1);\n let reason = String(control.reason ?? \"insufficient_market_evidence\");\n\n if (paidCalls >= 50 && conversion >= 0.35) {\n state = \"LIVE\";\n multiplier = Math.min(1.5, Number((multiplier * 1.08).toFixed(4)));\n reason = \"high_paid_demand_scale_price\";\n } else if (ageDays >= 7 && attempts >= 100 && paidCalls === 0) {\n state = \"KILLED\";\n reason = \"market_test_failed_zero_paid_conversions\";\n } else if (ageDays >= 7 && attempts >= 75 && conversion < 0.02) {\n state = \"PAUSED\";\n reason = \"very_low_paid_conversion\";\n } else if (paidCalls >= 10 && conversion < 0.08) {\n multiplier = Math.max(0.7, Number((multiplier * 0.92).toFixed(4)));\n reason = \"price_elasticity_test_lower\";\n } else if (state !== \"KILLED\") {\n state = \"LIVE\";\n reason = attempts === 0 ? \"awaiting_market_traffic\" : \"collecting_market_evidence\";\n }\n\n await sqlite.execute({\n sql: `UPDATE venture_controls\n SET state=?, price_multiplier=?, last_evaluated_at=?, reason=?\n WHERE business_id=?`,\n args: [state, multiplier, new Date().toISOString(), reason, businessId],\n });\n\n decisions.push({\n businessId, state, priceMultiplier: multiplier, attempts7d: attempts,\n paidCalls7d: paidCalls, revenue7d: revenue, conversion, ageDays, reason\n });\n }\n return decisions;\n}\n\nexport async function getMarketStatus() {\n await ensureMarketSchema();\n const [controls, attempts] = await Promise.all([\n sqlite.execute(\"SELECT * FROM venture_controls ORDER BY business_id\"),\n sqlite.execute(\"SELECT business_id, stage, COUNT(*) AS count FROM purchase_attempts GROUP BY business_id,stage ORDER BY business_id\"),\n ]);\n return { controls: controls.rows, attempts: attempts.rows };\n}\n",[149],"396ba2e4-8108-4b76-aa42-d81828bf4238","db.ts","f66bb20a-ad77-11f1-a5d4-1607ee4eb77e",2,["D",1789086617187],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport async function ensureSchema() {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS scout_signals (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n source TEXT NOT NULL,\n source_url TEXT NOT NULL UNIQUE,\n title TEXT NOT NULL,\n excerpt TEXT NOT NULL,\n cluster_key TEXT NOT NULL,\n canonical_need TEXT NOT NULL,\n observed_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS scout_clusters (\n cluster_key TEXT PRIMARY KEY,\n canonical_need TEXT NOT NULL,\n signal_count INTEGER NOT NULL DEFAULT 0,\n submissions INTEGER NOT NULL DEFAULT 0,\n business_id TEXT,\n last_seen_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS scout_runs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n started_at TEXT NOT NULL,\n finished_at TEXT,\n signals_added INTEGER NOT NULL DEFAULT 0,\n clusters_ready INTEGER NOT NULL DEFAULT 0,\n businesses_created INTEGER NOT NULL DEFAULT 0,\n error TEXT\n )`,\n `CREATE TABLE IF NOT EXISTS payment_events (\n payment_key TEXT PRIMARY KEY,\n business_id TEXT NOT NULL,\n amount_usdc REAL NOT NULL,\n network TEXT NOT NULL,\n payer TEXT,\n transaction_hash TEXT,\n settlement_status TEXT NOT NULL,\n cached_response TEXT,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )`\n ]);\n}\n\nexport async function insertSignal(input: {\n source: string;\n sourceUrl: string;\n title: string;\n excerpt: string;\n clusterKey: string;\n canonicalNeed: string;\n}) {\n const now = new Date().toISOString();\n try {\n await sqlite.execute({\n sql: `INSERT INTO scout_signals\n (source, source_url, title, excerpt, cluster_key, canonical_need, observed_at)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n args: [input.source, input.sourceUrl, input.title, input.excerpt, input.clusterKey, input.canonicalNeed, now],\n });\n } catch (error) {\n if (String(error).includes(\"UNIQUE\")) return false;\n throw error;\n }\n\n await sqlite.execute({\n sql: `INSERT INTO scout_clusters\n (cluster_key, canonical_need, signal_count, submissions, business_id, last_seen_at)\n VALUES (?, ?, 1, 0, NULL, ?)\n ON CONFLICT(cluster_key) DO UPDATE SET\n signal_count = signal_count + 1,\n canonical_need = excluded.canonical_need,\n last_seen_at = excluded.last_seen_at`,\n args: [input.clusterKey, input.canonicalNeed, now],\n });\n return true;\n}\n\nexport async function startScoutRun() {\n const now = new Date().toISOString();\n const result = await sqlite.execute({\n sql: \"INSERT INTO scout_runs (started_at) VALUES (?) RETURNING id\",\n args: [now],\n });\n return Number(result.rows[0]?.id);\n}\n\nexport async function finishScoutRun(id: number, stats: {\n signalsAdded: number;\n clustersReady: number;\n businessesCreated: number;\n error?: string | null;\n}) {\n await sqlite.execute({\n sql: `UPDATE scout_runs\n SET finished_at=?, signals_added=?, clusters_ready=?, businesses_created=?, error=?\n WHERE id=?`,\n args: [new Date().toISOString(), stats.signalsAdded, stats.clustersReady, stats.businessesCreated, stats.error ?? null, id],\n });\n}\n\nexport async function getReadyClusters() {\n const result = await sqlite.execute(\n `SELECT cluster_key, canonical_need, signal_count, submissions, business_id\n FROM scout_clusters\n WHERE signal_count >= 4 AND business_id IS NULL AND submissions < 6\n ORDER BY signal_count DESC LIMIT 6`\n );\n return result.rows as Array>;\n}\n\nexport async function markSubmission(clusterKey: string, businessId?: string | null) {\n if (businessId) {\n await sqlite.execute({\n sql: \"UPDATE scout_clusters SET submissions=submissions+1, business_id=? WHERE cluster_key=?\",\n args: [businessId, clusterKey],\n });\n } else {\n await sqlite.execute({\n sql: \"UPDATE scout_clusters SET submissions=submissions+1 WHERE cluster_key=?\",\n args: [clusterKey],\n });\n }\n}\n\nexport async function getScoutStatus() {\n const [runs, clusters, signals] = await Promise.all([\n sqlite.execute(\"SELECT * FROM scout_runs ORDER BY id DESC LIMIT 10\"),\n sqlite.execute(\"SELECT * FROM scout_clusters ORDER BY signal_count DESC LIMIT 30\"),\n sqlite.execute(\"SELECT * FROM scout_signals ORDER BY id DESC LIMIT 50\"),\n ]);\n return { runs: runs.rows, clusters: clusters.rows, signals: signals.rows };\n}\n\nexport async function getPayment(paymentKey: string) {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM payment_events WHERE payment_key=? LIMIT 1\",\n args: [paymentKey],\n });\n return result.rows[0] as Record | undefined;\n}\n\nexport async function savePayment(input: {\n paymentKey: string;\n businessId: string;\n amountUsdc: number;\n network: string;\n payer?: string | null;\n transactionHash?: string | null;\n status: string;\n cachedResponse?: string | null;\n}) {\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `INSERT INTO payment_events\n (payment_key,business_id,amount_usdc,network,payer,transaction_hash,settlement_status,cached_response,created_at,updated_at)\n VALUES (?,?,?,?,?,?,?,?,?,?)\n ON CONFLICT(payment_key) DO UPDATE SET\n payer=excluded.payer,\n transaction_hash=excluded.transaction_hash,\n settlement_status=excluded.settlement_status,\n cached_response=COALESCE(excluded.cached_response,payment_events.cached_response),\n updated_at=excluded.updated_at`,\n args: [\n input.paymentKey, input.businessId, input.amountUsdc, input.network,\n input.payer ?? null, input.transactionHash ?? null, input.status,\n input.cachedResponse ?? null, now, now\n ],\n });\n}\n",[157],"185ad287-c219-4986-8ce1-aace096fa5bd","api.ts",15,["D",1789087221286],10,"http","import { Hono } from \"npm:hono\";\nimport { createMcpHandler, McpServer } from \"npm:@modelcontextprotocol/server\";\nimport * as z from \"npm:zod/v4\";\nimport { declareDiscoveryExtension } from \"npm:@x402/extensions/bazaar\";\nimport { ensureSchema, getPayment, getScoutStatus, savePayment } from \"./db.ts\";\n\nconst app = new Hono();\nconst FLOOT_BASE = \"https://vil-zero.floot.app\";\nconst FACILITATOR = \"https://facilitator.payai.network\";\nconst NETWORK = \"eip155:8453\";\nconst USDC_BASE = \"0x833589fCD6eDb6E08f4c7C32D4f71b54bdA02913\";\n\nfunction b64Encode(value: unknown) {\n return btoa(unescape(encodeURIComponent(JSON.stringify(value))));\n}\nfunction b64Decode(value: string) {\n const normalized = value.replace(/-/g, \"+\").replace(/_/g, \"/\") + \"=\".repeat((4 - value.length % 4) % 4);\n return JSON.parse(decodeURIComponent(escape(atob(normalized))));\n}\nasync function sha256(input: string) {\n const bytes = new TextEncoder().encode(input);\n const hash = await crypto.subtle.digest(\"SHA-256\", bytes);\n return Array.from(new Uint8Array(hash)).map(b => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\nfunction unwrapFloot(payload: any) {\n if (payload && typeof payload.json === \"string\") return JSON.parse(payload.json);\n if (payload && payload.json !== undefined) return payload.json;\n return payload;\n}\nasync function floot(path: string, method: \"GET\"|\"POST\", body?: unknown) {\n const init: RequestInit = { method, headers: { \"content-type\": \"application/json\" } };\n if (body !== undefined) init.body = JSON.stringify({ json: body });\n const res = await fetch(FLOOT_BASE + path, init);\n const text = await res.text();\n let parsed: any;\n try { parsed = unwrapFloot(JSON.parse(text)); } catch { parsed = { raw: text }; }\n if (!res.ok) throw new Error(parsed?.error ?? (\"Floot HTTP \" + res.status));\n return parsed;\n}\nasync function getBusiness(id: string) {\n const portfolio = await floot(\"/_api/portfolio\", \"GET\");\n return (portfolio.businesses ?? []).find((item: any) => item.id === id && item.status === \"LIVE\");\n}\n\nconst STOP_WORDS = new Set([\"the\",\"a\",\"an\",\"and\",\"or\",\"to\",\"for\",\"of\",\"in\",\"into\",\"from\",\"with\",\"by\",\"is\",\"are\",\"be\",\"that\",\"this\",\"one\",\"more\",\"strict\",\"machine\",\"readable\",\"ai\",\"agent\",\"agents\"]);\nfunction wordSet(value: string) {\n return new Set(value.toLowerCase().replace(/[^a-z0-9]+/g, \" \").split(/\\s+/).filter(word => word.length > 2 && !STOP_WORDS.has(word)));\n}\nfunction similarity(a: string, b: string) {\n const aa = wordSet(a), bb = wordSet(b);\n if (!aa.size || !bb.size) return { score: 0, common: 0 };\n let intersection = 0;\n for (const word of aa) if (bb.has(word)) intersection++;\n const union = new Set([...aa, ...bb]).size;\n const jaccard = intersection / union;\n const overlap = intersection / Math.min(aa.size, bb.size);\n return { score: overlap * 0.68 + jaccard * 0.32, common: intersection };\n}\nasync function findSimilarBusiness(description: string) {\n const portfolio = await floot(\"/_api/portfolio\", \"GET\");\n let best: any = null;\n let bestScore = 0;\n let bestCommon = 0;\n for (const item of portfolio.businesses ?? []) {\n if (item.status !== \"LIVE\") continue;\n const byDescription = similarity(description, String(item.description ?? \"\"));\n const byName = similarity(description, String(item.name ?? \"\").replace(/_/g, \" \"));\n const candidate = byDescription.score >= byName.score ? byDescription : byName;\n if (candidate.score > bestScore) {\n best = item;\n bestScore = candidate.score;\n bestCommon = candidate.common;\n }\n }\n return bestCommon >= 4 && bestScore >= 0.52\n ? { business: best, similarity: bestScore, commonTerms: bestCommon }\n : null;\n}\n\nfunction paymentRequirement(req: Request, business: any, payTo: string) {\n const amountAtomic = String(Math.max(1, Math.round(Number(business.pricePerCall) * 1_000_000)));\n return {\n scheme: \"exact\",\n network: NETWORK,\n amount: amountAtomic,\n asset: USDC_BASE,\n payTo,\n maxTimeoutSeconds: 60,\n extra: { name: \"USDC\", version: \"2\" }\n };\n}\nfunction paymentChallenge(req: Request, business: any, payTo: string, error = \"PAYMENT-SIGNATURE header is required\") {\n const requirement = paymentRequirement(req, business, payTo);\n const required = {\n x402Version: 2,\n error,\n resource: {\n url: new URL(req.url).toString(),\n description: \"Execute VIL ZERO micro-service \" + business.id + \": \" + business.name,\n mimeType: \"application/json\",\n serviceName: \"VIL ZERO\",\n tags: [\"ai-agent\",\"microservice\",\"machine-commerce\"]\n },\n accepts: [requirement],\n extensions: {\n ...declareDiscoveryExtension({\n bodyType: \"json\",\n input: { businessId: business.id, input: { request: \"machine-readable input for this micro-service\" } },\n inputSchema: {\n properties: {\n businessId: { type: \"string\", description: \"Live VIL ZERO business id\" },\n input: { type: \"object\", description: \"Input accepted by the selected micro-service\" }\n },\n required: [\"businessId\", \"input\"]\n },\n output: {\n example: {\n requestId: \"REQ-example\",\n businessId: business.id,\n output: { result: \"machine-readable service output\" }\n }\n }\n })\n }\n };\n return new Response(JSON.stringify({ error: \"payment_required\", businessId: business.id, priceUSDC: Number(business.pricePerCall) }), {\n status: 402,\n headers: { \"content-type\": \"application/json\", \"PAYMENT-REQUIRED\": b64Encode(required) }\n });\n}\n\nconst mcpHandler = createMcpHandler(() => {\n const server = new McpServer({ name: \"VIL ZERO\", version: \"0.3.0\" });\n\n server.registerTool(\n \"list_businesses\",\n {\n title: \"List VIL ZERO businesses\",\n description: \"List live machine-created micro-services, their price per call, usage, and current portfolio metrics.\",\n inputSchema: z.object({}),\n annotations: { readOnlyHint: true, openWorldHint: true }\n },\n async () => {\n const portfolio = await floot(\"/_api/portfolio\", \"GET\");\n return {\n content: [{ type: \"text\", text: JSON.stringify(portfolio) }],\n structuredContent: portfolio\n };\n }\n );\n\n server.registerTool(\n \"submit_need\",\n {\n title: \"Submit unmet machine demand\",\n description: \"Tell VIL ZERO about a capability an AI agent needs. Repeated public demand can cause Factory to create a new paid micro-service.\",\n inputSchema: z.object({\n description: z.string().min(8).max(4000),\n maxPrice: z.number().positive().max(1000),\n deadlineSeconds: z.number().int().positive().max(900)\n }),\n annotations: { readOnlyHint: false, destructiveHint: false, openWorldHint: true }\n },\n async ({ description, maxPrice, deadlineSeconds }) => {\n const result = await floot(\"/_api/need\", \"POST\", { description, maxPrice, deadlineSeconds });\n return {\n content: [{ type: \"text\", text: JSON.stringify(result) }],\n structuredContent: result\n };\n }\n );\n\n server.registerTool(\n \"prepare_purchase\",\n {\n title: \"Prepare a paid VIL ZERO execution\",\n description: \"Return the x402 purchase endpoint and current USDC price for a live VIL ZERO business. The agent should POST to that endpoint; an unpaid request returns the machine-readable x402 payment challenge.\",\n inputSchema: z.object({ businessId: z.string().min(1) }),\n annotations: { readOnlyHint: true, openWorldHint: true }\n },\n async ({ businessId }) => {\n const business = await getBusiness(businessId);\n const result = business\n ? {\n businessId,\n name: business.name,\n priceUSDC: Number(business.pricePerCall),\n endpoint: \"https://vil-zero-core.val.run/execute\",\n method: \"POST\",\n bodyShape: { businessId, input: {} },\n protocol: \"x402-v2\",\n network: NETWORK,\n asset: \"USDC\"\n }\n : { error: \"business_not_live\", businessId };\n return {\n content: [{ type: \"text\", text: JSON.stringify(result) }],\n structuredContent: result,\n isError: !business\n };\n }\n );\n\n return server;\n});\n\napp.all(\"/mcp\", (c) => mcpHandler.fetch(c.req.raw));\n\napp.get(\"/\", async c => {\n await ensureSchema();\n const payTo = Deno.env.get(\"VIL_PAY_TO\") ?? null;\n return c.json({\n name: \"VIL ZERO CORE\",\n status: \"online\",\n autonomousScout: true,\n scoutInterval: \"30 minutes\",\n paidRuntime: payTo ? \"armed\" : \"waiting_for_receiver_address\",\n paymentProtocol: \"x402 v2\",\n network: NETWORK,\n asset: \"USDC\",\n facilitator: FACILITATOR,\n factory: FLOOT_BASE\n });\n});\n\napp.get(\"/health\", c => c.json({ ok: true, service: \"VIL ZERO CORE\", time: new Date().toISOString() }));\n\napp.get(\"/scout\", async c => {\n await ensureSchema();\n return c.json(await getScoutStatus());\n});\n\napp.get(\"/portfolio\", async c => {\n const portfolio = await floot(\"/_api/portfolio\", \"GET\");\n return c.json(portfolio);\n});\n\napp.post(\"/need\", async c => {\n const body = await c.req.json();\n if (!body?.description || typeof body.description !== \"string\") {\n return c.json({ error: \"description is required\" }, 400);\n }\n const existing = await findSimilarBusiness(body.description);\n if (existing) {\n return c.json({\n verdict: \"FOUND\",\n reason: \"A sufficiently similar live VIL ZERO business already exists.\",\n similarity: Number(existing.similarity.toFixed(3)),\n business: {\n id: existing.business.id,\n name: existing.business.name,\n description: existing.business.description,\n pricePerCall: Number(existing.business.pricePerCall),\n status: existing.business.status\n }\n });\n }\n const result = await floot(\"/_api/need\", \"POST\", body);\n return c.json(result);\n});\n\napp.post(\"/execute\", async c => {\n await ensureSchema();\n const body = await c.req.json();\n if (!body?.businessId) return c.json({ error: \"businessId is required\" }, 400);\n const business = await getBusiness(String(body.businessId));\n if (!business) return c.json({ error: \"business_not_live\" }, 404);\n\n const payTo = Deno.env.get(\"VIL_PAY_TO\");\n if (!payTo || !/^0x[a-fA-F0-9]{40}$/.test(payTo)) {\n return c.json({\n error: \"payment_receiver_not_configured\",\n message: \"VIL ZERO will not execute through the paid gateway until a merchant-controlled Base-compatible receiving address is configured.\"\n }, 503);\n }\n\n const paymentSignature = c.req.header(\"PAYMENT-SIGNATURE\");\n if (!paymentSignature) return paymentChallenge(c.req.raw, business, payTo);\n\n const paymentKey = await sha256(paymentSignature);\n const existing = await getPayment(paymentKey);\n if (existing?.settlement_status === \"success\" && existing.cached_response) {\n const cached = JSON.parse(String(existing.cached_response));\n return new Response(JSON.stringify(cached), {\n status: 200,\n headers: {\n \"content-type\": \"application/json\",\n \"PAYMENT-RESPONSE\": b64Encode({\n success: true,\n transaction: existing.transaction_hash,\n network: existing.network,\n payer: existing.payer\n }),\n \"X-VIL-IDEMPOTENT-REPLAY\": \"true\"\n }\n });\n }\n\n let paymentPayload: any;\n try { paymentPayload = b64Decode(paymentSignature); }\n catch { return paymentChallenge(c.req.raw, business, payTo, \"Invalid PAYMENT-SIGNATURE encoding\"); }\n\n const requirement = paymentRequirement(c.req.raw, business, payTo);\n const facilitatorBody = { x402Version: 2, paymentPayload, paymentRequirements: requirement };\n\n const verifyRes = await fetch(FACILITATOR + \"/verify\", {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify(facilitatorBody)\n });\n const verification = await verifyRes.json().catch(() => ({}));\n if (!verifyRes.ok || verification.isValid === false || verification.valid === false) {\n return paymentChallenge(c.req.raw, business, payTo, verification.invalidReason ?? verification.error ?? \"Payment verification failed\");\n }\n\n const runtimeResult = await floot(\"/_api/execute\", \"POST\", {\n businessId: body.businessId,\n input: body.input\n });\n\n const settleRes = await fetch(FACILITATOR + \"/settle\", {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify(facilitatorBody)\n });\n const settlement = await settleRes.json().catch(() => ({}));\n const amountUsdc = Number(business.pricePerCall);\n\n if (!settleRes.ok || settlement.success !== true) {\n await savePayment({\n paymentKey, businessId: business.id, amountUsdc, network: NETWORK,\n payer: settlement.payer ?? verification.payer ?? null,\n transactionHash: settlement.transaction ?? null,\n status: settlement.errorReason === \"settlement_pending\" ? \"pending\" : \"failed\",\n cachedResponse: JSON.stringify(runtimeResult)\n });\n return c.json({\n error: settlement.errorReason === \"settlement_pending\" ? \"settlement_pending\" : \"settlement_failed\",\n transaction: settlement.transaction ?? null\n }, settlement.errorReason === \"settlement_pending\" ? 202 : 402);\n }\n\n await savePayment({\n paymentKey, businessId: business.id, amountUsdc, network: NETWORK,\n payer: settlement.payer ?? verification.payer ?? null,\n transactionHash: settlement.transaction ?? null,\n status: \"success\",\n cachedResponse: JSON.stringify(runtimeResult)\n });\n\n return new Response(JSON.stringify(runtimeResult), {\n status: 200,\n headers: {\n \"content-type\": \"application/json\",\n \"PAYMENT-RESPONSE\": b64Encode(settlement)\n }\n });\n});\n\napp.get(\"/openapi.json\", c => c.json({\n openapi: \"3.1.0\",\n info: { title: \"VIL ZERO CORE\", version: \"0.3.0\", description: \"Autonomous AI-demand scout, factory gateway, and x402-paid runtime.\" },\n paths: {\n \"/need\": { post: { summary: \"Submit an unmet machine need\" } },\n \"/execute\": { post: { summary: \"Execute a VIL ZERO business; x402 payment required\" } },\n \"/portfolio\": { get: { summary: \"View live businesses\" } },\n \"/scout\": { get: { summary: \"View autonomous Scout evidence\" } }\n }\n}));\n\napp.get(\"/llms.txt\", c => c.text(`VIL ZERO CORE\nAutonomous machine-demand discovery and paid AI micro-services.\n\nDISCOVER\nGET /portfolio\nGET /scout\nGET /openapi.json\n\nSUBMIT DEMAND\nPOST /need\nJSON: {\"description\":\"...\",\"maxPrice\":0.02,\"deadlineSeconds\":5}\n\nBUY A SERVICE\nPOST /execute\nJSON: {\"businessId\":\"ZERO-...\",\"input\":{...}}\nThe first unpaid request returns HTTP 402 with PAYMENT-REQUIRED.\nSign an x402 v2 USDC payment and retry with PAYMENT-SIGNATURE.\nSuccessful responses include PAYMENT-RESPONSE.\n\nNetwork: Base mainnet (eip155:8453)\nSettlement facilitator: PayAI\n`));\n\napp.onError(err => {\n console.error(err);\n return Response.json({ error: \"internal_error\", message: String(err) }, { status: 500 });\n});\n\nexport default app.fetch;",[164],"pulls","branches",1,"forks","envVars",{"_179":173,"_181":61},"connections",{"_179":61,"_180":61},"count","unfilledCount","emptyCount",{"_41":163,"_31":164,"_29":55,"_137":-5,"_39":40,"_38":165,"_139":24,"_36":200,"_13":167,"_32":168,"_34":169,"_23":24,"_143":43,"_188":201,"_26":202},{"_41":156,"_31":157,"_29":158,"_137":-5,"_39":40,"_38":159,"_139":24,"_36":197,"_13":61,"_32":153,"_34":161,"_23":24,"_143":-5,"_188":198,"_26":199},{"_41":148,"_31":149,"_29":150,"_137":-5,"_39":40,"_38":151,"_139":57,"_36":194,"_13":61,"_32":153,"_34":154,"_23":24,"_143":-5,"_188":195,"_26":196},{"_41":145,"_31":27,"_29":30,"_137":-5,"_39":40,"_38":14,"_139":57,"_36":191,"_13":61,"_32":33,"_34":35,"_23":24,"_143":-5,"_188":192,"_26":193},{"_41":134,"_31":135,"_29":136,"_137":-5,"_39":40,"_38":138,"_139":24,"_36":187,"_13":141,"_32":33,"_34":142,"_23":24,"_143":-5,"_188":189,"_26":190},["D",1789087233612],"children",[],[135],["D",1789087300425],[],[27],["D",1789087287250],[],[149],["D",1789086617187],[],[157],["D",1789087221286],[],[164],["D",1789086550141],["D",1789525245864],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"ctx",{"_80":-5,"_126":241,"_242":243,"_244":245,"_246":24,"_247":24,"_248":24,"_249":57,"_250":-5,"_251":-7,"_252":-7,"_253":61,"_254":24,"_255":24,"_256":-5,"_257":24,"_258":24,"_259":24,"_260":-5},"ENV",{"_212":213,"_214":215,"_216":88,"_217":218,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240},"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 · v20