[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_184":185,"_186":187},"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":59,"_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",5,"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","scout.ts","latestPath","fileId","011b602e-ad78-11f1-8a10-1607ee4eb77e","name","fileType","interval","content","import { ensureSchema, finishScoutRun, getReadyClusters, insertSignal, markSubmission, startScoutRun } from \"./db.ts\";\n\nconst FLOOT_NEED = \"https://vil-zero.floot.app/_api/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 if (!/(need|looking|wish|missing|request|problem|pain|build)/i.test(title + \" \" + text)) 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({json: JSON.stringify({description,maxPrice:0.02,deadlineSeconds:5})});\n const res = await fetch(FLOOT_NEED,{method:\"POST\",headers:{\"content-type\":\"application/json\"},body:payload});\n if (!res.ok) throw new Error(\"Factory HTTP \" + res.status);\n const wrapper = await res.json();\n const parsed = typeof wrapper.json === \"string\" ? JSON.parse(wrapper.json) : wrapper.json;\n return parsed;\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 const result = await submitNeed(need);\n const businessId = result?.business?.id ?? null;\n await markSubmission(key,businessId);\n if (businessId) { businessesCreated++; break; }\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}","import { ensureSchema, finishScoutRun, getReadyClusters, insertSignal, markSubmission, startScoutRun } from \"./db.ts\";\n\nconst FLOOT_NEED = \"https://vil-zero.floot.app/_api/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 if (!/(need|looking|wish|missing|request|problem|pain|build)/i.test(title + \" \" + text)) 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({json: {description,maxPrice:0.02,deadlineSeconds:5}});\n const res = await fetch(FLOOT_NEED,{method:\"POST\",headers:{\"content-type\":\"application/json\"},body:payload});\n if (!res.ok) throw new Error(\"Factory HTTP \" + res.status);\n const wrapper = await res.json();\n const parsed = typeof wrapper.json === \"string\" ? JSON.parse(wrapper.json) : wrapper.json;\n return parsed;\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 const result = await submitNeed(need);\n const businessId = result?.business?.id ?? null;\n await markSubmission(key,businessId);\n if (businessId) { businessesCreated++; break; }\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}","createdAt",["D",1789086734873],"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",{"_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",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",{"_43":44,"_32":45,"_38":179,"_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":180,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":181,"_84":182,"_86":183,"_88":25},"tree",[166,167,168],"files",[166,167,168],"counts",{"_156":63,"_157":138,"_158":63,"_159":160,"_161":162},"contents",[131,132,133],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":149,"_32":150,"_30":57,"_135":-5,"_41":42,"_40":151,"_136":25,"_38":152,"_13":138,"_33":153,"_35":154,"_24":25,"_139":45,"_27":155},{"_43":141,"_32":142,"_30":143,"_135":-5,"_41":42,"_40":144,"_136":25,"_38":145,"_13":63,"_33":146,"_35":147,"_24":25,"_139":-5,"_27":148},{"_43":134,"_32":28,"_30":31,"_135":-5,"_41":42,"_40":14,"_136":25,"_38":137,"_13":138,"_33":34,"_35":37,"_24":25,"_139":-5,"_27":140},"f7c513e9-b617-41ee-aa03-415b89bdf386","parentId","latest",["D",1789086734873],1,"label",[28],"396ba2e4-8108-4b76-aa42-d81828bf4238","db.ts","f66bb20a-ad77-11f1-a5d4-1607ee4eb77e",2,["D",1789086617187],"script","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",[142],"684289e3-a728-4cfc-bb35-831cac16c3f9","api.ts",4,["D",1789086662679],"http","import { Hono } from \"npm:hono\";\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: JSON.stringify(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}\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 };\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\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 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;",[150],"pulls","branches","forks","envVars",{"_163":138,"_165":63},"connections",{"_163":63,"_164":63},"count","unfilledCount","emptyCount",{"_43":149,"_32":150,"_30":57,"_135":-5,"_41":42,"_40":151,"_136":25,"_38":176,"_13":138,"_33":153,"_35":154,"_24":25,"_139":45,"_170":177,"_27":178},{"_43":141,"_32":142,"_30":143,"_135":-5,"_41":42,"_40":144,"_136":25,"_38":173,"_13":63,"_33":146,"_35":147,"_24":25,"_139":-5,"_170":174,"_27":175},{"_43":134,"_32":28,"_30":31,"_135":-5,"_41":42,"_40":14,"_136":25,"_38":169,"_13":138,"_33":34,"_35":37,"_24":25,"_139":-5,"_170":171,"_27":172},["D",1789086734873],"children",[],[28],["D",1789086617187],[],[142],["D",1789086662679],[],[150],["D",1789086550141],["D",1789525245864],{"_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":217,"_218":219,"_220":221,"_222":25,"_223":25,"_224":25,"_225":59,"_226":-5,"_227":-7,"_228":-7,"_229":63,"_230":25,"_231":25,"_232":-5,"_233":25,"_234":25,"_235":25,"_236":-5},"ENV",{"_188":189,"_190":191,"_192":90,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216},"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 · v5