Find demand.
Build what is missing.

VIL ZERO scans unmet machine demand, creates narrow AI services, watches competition, and gives agents a direct PayPal instruction when they want to buy.

Sellable businesses—live portfolio

Scout—every 30 min

CommercePAYPALmanual instruction

Verified revenue$0.00not auto-verified

01 / NEED

Submit machine demand

\nMissing capability\n

Market reference price USD

Deadline seconds

Ready.

02 / PAYMENT

PayPal destination

RECIPIENT

danievilchezpayments@gmail.com

No PayPal connection is used. VIL ZERO only gives the instruction to pay this email and does not pretend the payment was automatically verified.

03 / SCOUT

Latest demand signals

04 / PORTFOLIO

Autonomous businesses

Loading portfolio...

\n\n

\n\n`;","children",[],[181],"ec7fe4f8-eb29-4ca5-aa99-2cc46a34dbd1","scout.ts","011b602e-ad78-11f1-8a10-1607ee4eb77e",43,["D",1789087882511],11,"interval","import { ensureSchema, finishScoutRun, getReadyClusters, insertSignal, markSubmission, startScoutRun, updateClusterMarket } 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\nconst DOMAIN_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\nfunction classify(title:string, text:string) {\n const t = (title + \" \" + text).toLowerCase();\n if (blocked.test(t)) return null;\n const explicitDemand = /\\b(i need|we need|need a|need an|feature request|missing support|missing a|missing an|unsupported|can't find|cannot find|looking for|wish there|pain point|problem with|fails when|does not support|doesn't support|not supported|request for)\\b/i;\n if (!explicitDemand.test(t)) return null;\n return DOMAIN_RULES.find(r => r.re.test(t)) ?? null;\n}\n\nasync function bazaarMarket() {\n const res = await fetch(\"https://facilitator.payai.network/discovery/resources?limit=100&offset=0\");\n if (!res.ok) return new Map();\n const data = await res.json();\n const grouped = new Map();\n\n for (const item of data.items ?? []) {\n const description = String(item.description ?? item.metadata?.description ?? \"\").toLowerCase();\n const domain = DOMAIN_RULES.find(rule => rule.re.test(description));\n if (!domain) continue;\n const payment = (item.accepts ?? []).find((accept:any) =>\n accept.network === \"eip155:8453\" &&\n accept.scheme === \"exact\" &&\n String(accept.asset ?? \"\").toLowerCase() === \"0x833589fcd6edb6e08f4c7c32d4f71b54bda02913\" &&\n Number(accept.amount ?? 0) > 0\n );\n if (!payment) continue;\n const usd = Number(payment.amount) / 1_000_000;\n if (!Number.isFinite(usd) || usd <= 0) continue;\n const prices = grouped.get(domain.key) ?? [];\n prices.push(usd);\n grouped.set(domain.key, prices);\n }\n\n const result = new Map();\n for (const rule of DOMAIN_RULES) {\n const prices = (grouped.get(rule.key) ?? []).sort((a,b) => a-b);\n const middle = Math.floor(prices.length / 2);\n const median = prices.length === 0 ? null :\n prices.length % 2 ? prices[middle] : (prices[middle-1] + prices[middle]) / 2;\n result.set(rule.key, { count: prices.length, median });\n }\n return result;\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, marketReferencePrice:number|null) {\n const referencePrice = marketReferencePrice && marketReferencePrice > 0 ? marketReferencePrice : 0.01;\n const payload = JSON.stringify({description,maxPrice:referencePrice,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 market = await bazaarMarket();\n for (const rule of DOMAIN_RULES) {\n const snapshot = market.get(rule.key) ?? { count: 0, median: null };\n await updateClusterMarket(rule.key, snapshot.count, snapshot.median);\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, cluster.market_median_usdc == null ? null : Number(cluster.market_median_usdc));\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}",[],[191],"26217176-b34d-459a-97da-ebee0be60e93","publish_registry.ts","5d1f1ac2-adc9-11f1-91f0-1607ee4eb77e",74,["D",1789121626517],6,"import { ed25519 } from \"npm:@noble/curves/ed25519.js\";\n\nfunction hexToBytes(hex: string) {\n if (hex.length % 2) throw new Error(\"invalid private key length\");\n const out = new Uint8Array(hex.length / 2);\n for (let i = 0; i < out.length; i++) out[i] = parseInt(hex.slice(i * 2, i * 2 + 2), 16);\n return out;\n}\n\nfunction bytesToHex(bytes: Uint8Array) {\n return Array.from(bytes).map(b => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nasync function publish() {\n const privateHex = Deno.env.get(\"MCP_REGISTRY_PRIVATE_KEY_HEX\");\n if (!privateHex) throw new Error(\"MCP_REGISTRY_PRIVATE_KEY_HEX is missing\");\n\n const timestamp = new Date().toISOString().replace(/\\.\\d{3}Z$/, \"Z\");\n const message = new TextEncoder().encode(timestamp);\n const signature = ed25519.sign(message, hexToBytes(privateHex));\n const signedTimestamp = bytesToHex(signature);\n\n const authUrl = \"https://registry.modelcontextprotocol.io/v0.1/auth/http\";\n const authRes = await fetch(authUrl, {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({\n domain: \"vil-zero-core.val.run\",\n timestamp,\n signed_timestamp: signedTimestamp\n })\n });\n\n const authText = await authRes.text();\n console.log(\"AUTH_STATUS\", authRes.status);\n console.log(\"AUTH_BODY\", authText.slice(0, 1200));\n\n if (!authRes.ok) return;\n\n let auth: any;\n try { auth = JSON.parse(authText); } catch { throw new Error(\"Registry auth returned non-JSON\"); }\n const token = auth.registry_token ?? auth.token ?? auth.access_token ?? auth.jwt;\n if (!token) throw new Error(\"Registry auth succeeded but no token field was returned\");\n\n const server = {\n \"$schema\": \"https://static.modelcontextprotocol.io/schemas/2025-12-11/server.schema.json\",\n name: \"run.val.vil-zero-core/vil-zero\",\n title: \"VIL ZERO\",\n description: \"Autonomous venture engine for AI agents: discover, build, quote, and track capabilities.\",\n version: \"0.5.0\",\n websiteUrl: \"https://vil-zero-app.val.run\",\n remotes: [\n { type: \"streamable-http\", url: \"https://vil-zero-core.val.run/mcp\" }\n ]\n };\n\n const publishRes = await fetch(\"https://registry.modelcontextprotocol.io/v0.1/publish\", {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"authorization\": \"Bearer \" + token\n },\n body: JSON.stringify(server)\n });\n const publishText = await publishRes.text();\n console.log(\"PUBLISH_STATUS\", publishRes.status);\n console.log(\"PUBLISH_BODY\", publishText.slice(0, 2400));\n}\n\nawait publish();",[],[201],"5750ad6c-71e5-427f-8247-9db8d7b2d474","optimizer.ts","8da9bee0-ad79-11f1-ba3c-1607ee4eb77e",20,["D",1789087300425],"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}",[],[210],"d827291c-5d07-4e37-b104-4bb3232eba63","market.ts","85cc168c-ad79-11f1-811d-1607ee4eb77e",19,["D",1789087287250],"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",[],[218],"bd90b406-93b8-46cd-b0a3-94af49e40ecc","db.ts","f66bb20a-ad77-11f1-a5d4-1607ee4eb77e",64,["D",1789121173445],4,"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 `CREATE TABLE IF NOT EXISTS agent_orders (\n order_id TEXT PRIMARY KEY,\n business_id TEXT NOT NULL,\n requested_calls INTEGER NOT NULL,\n amount_usd REAL NOT NULL,\n payment_note TEXT NOT NULL,\n status TEXT NOT NULL,\n transaction_reference 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 competitor_count, market_median_usdc\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 updateClusterMarket(clusterKey: string, competitorCount: number, marketMedianUsdc: number | null) {\n await sqlite.execute({\n sql: `UPDATE scout_clusters\n SET competitor_count=?, market_median_usdc=?\n WHERE cluster_key=?`,\n args: [competitorCount, marketMedianUsdc, clusterKey],\n });\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 getPaymentStats() {\n await ensureSchema();\n const result = await sqlite.execute(\n `SELECT\n COUNT(*) AS settled_payments,\n COALESCE(SUM(amount_usdc),0) AS settled_usdc,\n MAX(created_at) AS last_settlement_at\n FROM payment_events\n WHERE settlement_status='success'`\n );\n const row = result.rows[0] as Record | undefined;\n return {\n settledPayments: Number(row?.settled_payments ?? 0),\n settledUSDC: Number(row?.settled_usdc ?? 0),\n lastSettlementAt: row?.last_settlement_at ?? null,\n };\n}\n\nexport async function createAgentOrder(input: {\n orderId: string;\n businessId: string;\n requestedCalls: number;\n amountUsd: number;\n paymentNote: string;\n}) {\n await ensureSchema();\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `INSERT INTO agent_orders\n (order_id,business_id,requested_calls,amount_usd,payment_note,status,created_at,updated_at)\n VALUES (?,?,?,?,?,'AWAITING_PAYPAL_PAYMENT',?,?)`,\n args: [\n input.orderId,\n input.businessId,\n input.requestedCalls,\n input.amountUsd,\n input.paymentNote,\n now,\n now,\n ],\n });\n return getAgentOrder(input.orderId);\n}\n\nexport async function getAgentOrder(orderId: string) {\n await ensureSchema();\n const result = await sqlite.execute({\n sql: \"SELECT * FROM agent_orders WHERE order_id=? LIMIT 1\",\n args: [orderId],\n });\n return result.rows[0] as Record | undefined;\n}\n\nexport async function reportAgentOrderPayment(orderId: string, transactionReference: string) {\n await ensureSchema();\n await sqlite.execute({\n sql: `UPDATE agent_orders\n SET status='PAYMENT_REPORTED_UNVERIFIED', transaction_reference=?, updated_at=?\n WHERE order_id=?`,\n args: [transactionReference, new Date().toISOString(), orderId],\n });\n return getAgentOrder(orderId);\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",[],[226],["D",1789121846607],[],[18],"ef231416-40a5-4595-a9f8-d32987b7d774","api.ts",67,["D",1789121478262],46,"http","import { Hono } from \"npm:hono\";\nimport { createMcpHandler, McpServer } from \"npm:@modelcontextprotocol/server\";\nimport * as z from \"npm:zod/v4\";\nimport {\n ensureSchema,\n getScoutStatus,\n createAgentOrder,\n getAgentOrder,\n reportAgentOrderPayment,\n} from \"./db.ts\";\nimport { applyMarketControl, getMarketStatus } from \"./market.ts\";\n\nconst app = new Hono();\nconst VERSION = \"0.5.0\";\nconst CORE = \"https://vil-zero-core.val.run\";\nconst ADMIN = \"https://vil-zero-app.val.run\";\nconst FLOOT_BASE = \"https://vil-zero.floot.app\";\nconst PAYPAL_EMAIL = \"danievilchezpayments@gmail.com\";\nconst PAYPAL_MINIMUM_USD = 1;\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}\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 ?? (\"Factory HTTP \" + res.status));\n return parsed;\n}\n\nasync function getBusiness(id: string) {\n const portfolio = await floot(\"/_api/portfolio\", \"GET\");\n const found = (portfolio.businesses ?? []).find((item: any) => item.id === id && item.status === \"LIVE\");\n return found ? await applyMarketControl(found) : null;\n}\n\nasync function getSellablePortfolio() {\n const portfolio = await floot(\"/_api/portfolio\", \"GET\");\n const sellable = [];\n for (const item of portfolio.businesses ?? []) {\n if (item.status !== \"LIVE\") continue;\n const controlled = await applyMarketControl(item);\n if (controlled) sellable.push(controlled);\n }\n return { ...portfolio, businesses: sellable, market: await getMarketStatus() };\n}\n\nconst STOP_WORDS = new Set([\n \"the\",\"a\",\"an\",\"and\",\"or\",\"to\",\"for\",\"of\",\"in\",\"into\",\"from\",\"with\",\"by\",\"is\",\"are\",\"be\",\n \"that\",\"this\",\"one\",\"more\",\"strict\",\"machine\",\"readable\",\"ai\",\"agent\",\"agents\",\"service\",\"tool\"\n]);\n\nfunction wordSet(value: string) {\n return new Set(\n value.toLowerCase().replace(/[^a-z0-9]+/g, \" \").split(/\\s+/)\n .filter(word => word.length > 2 && !STOP_WORDS.has(word))\n );\n}\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}\n\nasync function rankCapabilities(query: string, limit = 5) {\n const portfolio = await getSellablePortfolio();\n return (portfolio.businesses ?? [])\n .map((item: any) => {\n const byDescription = similarity(query, String(item.description ?? \"\"));\n const byName = similarity(query, String(item.name ?? \"\").replace(/_/g, \" \"));\n const best = byDescription.score >= byName.score ? byDescription : byName;\n return {\n id: item.id,\n name: item.name,\n description: item.description,\n pricePerCall: Number(item.pricePerCall),\n status: item.market?.state ?? item.status,\n matchScore: Number(best.score.toFixed(4)),\n commonTerms: best.common,\n };\n })\n .sort((a: any, b: any) => b.matchScore - a.matchScore)\n .slice(0, Math.max(1, Math.min(20, limit)));\n}\n\nasync function findSimilarBusiness(description: string) {\n const matches = await rankCapabilities(description, 1);\n const best = matches[0];\n return best && best.commonTerms >= 4 && best.matchScore >= 0.52 ? best : null;\n}\n\nasync function processNeed(body: any) {\n if (!body?.description || typeof body.description !== \"string\") {\n return { status: 400, body: { ok: false, error: \"description_required\" } };\n }\n const existing = await findSimilarBusiness(body.description);\n if (existing) {\n return {\n status: 200,\n body: {\n ok: true,\n verdict: \"FOUND\",\n reason: \"existing_capability_match\",\n business: existing,\n next: { intent: \"quote\", businessId: existing.id }\n }\n };\n }\n const created = await floot(\"/_api/need\", \"POST\", {\n description: body.description,\n maxPrice: Number(body.maxPrice ?? 0.01),\n deadlineSeconds: Number(body.deadlineSeconds ?? 10),\n });\n return { status: 200, body: { ok: true, ...created } };\n}\n\nfunction paymentPackage(business: any, requestedCalls?: number) {\n const perCall = Math.max(0.001, Number(business.pricePerCall));\n const calls = requestedCalls && requestedCalls > 0\n ? Math.max(1, Math.round(requestedCalls))\n : Math.max(1, Math.floor(PAYPAL_MINIMUM_USD / perCall));\n const amount = Math.max(PAYPAL_MINIMUM_USD, Number((calls * perCall).toFixed(2)));\n return { perCall, calls, amount };\n}\n\nasync function createQuote(businessId: string, requestedCalls?: number) {\n const business = await getBusiness(businessId);\n if (!business) return { ok: false, error: \"business_not_live\", businessId };\n\n const pkg = paymentPackage(business, requestedCalls);\n const orderId = \"VZ-\" + crypto.randomUUID().replaceAll(\"-\", \"\").slice(0, 16).toUpperCase();\n const paymentNote = \"VILZERO:\" + orderId + \":\" + business.id;\n const order = await createAgentOrder({\n orderId,\n businessId: business.id,\n requestedCalls: pkg.calls,\n amountUsd: pkg.amount,\n paymentNote,\n });\n\n return {\n ok: true,\n orderId,\n business: {\n id: business.id,\n name: business.name,\n unitPriceUSD: Number(pkg.perCall.toFixed(6)),\n },\n purchase: {\n method: \"PayPal\",\n recipient: PAYPAL_EMAIL,\n currency: \"USD\",\n amountUSD: pkg.amount,\n includedCalls: pkg.calls,\n paymentNote,\n instructions: [\n \"Send exactly $\" + pkg.amount.toFixed(2) + \" USD to \" + PAYPAL_EMAIL + \" using PayPal.\",\n \"Include this exact payment note: \" + paymentNote,\n \"After payment, call report_payment with orderId and your PayPal transaction reference.\"\n ],\n automaticVerification: false,\n },\n order,\n next: {\n intent: \"report_payment\",\n orderId,\n required: [\"transactionReference\"]\n }\n };\n}\n\nasync function systemStatus() {\n const [scout, portfolio] = await Promise.all([getScoutStatus(), getSellablePortfolio()]);\n const latestScoutRun = Array.isArray(scout.runs) ? scout.runs[0] ?? null : null;\n return {\n ok: true,\n service: \"VIL ZERO\",\n version: VERSION,\n audience: [\"AI_AGENT\", \"AGI_AGENT\", \"AUTONOMOUS_SOFTWARE\"],\n humanInterface: ADMIN,\n machineInterfaces: {\n mcp: CORE + \"/mcp\",\n a2a: CORE + \"/a2a\",\n intent: CORE + \"/intent\",\n openapi: CORE + \"/openapi.json\",\n agentCard: CORE + \"/.well-known/agent-card.json\",\n llms: CORE + \"/llms.txt\",\n },\n autonomousScout: {\n enabled: true,\n intervalMinutes: 30,\n latestRun: latestScoutRun,\n },\n marketOptimizer: { enabled: true, intervalHours: 6 },\n commerce: {\n method: \"PayPal\",\n recipient: PAYPAL_EMAIL,\n automaticVerification: false,\n sellableBusinesses: portfolio.businesses?.length ?? 0,\n }\n };\n}\n\nconst machineManifest = {\n name: \"VIL ZERO\",\n version: VERSION,\n type: \"agent-native-autonomous-venture-engine\",\n audience: [\"AI_AGENT\", \"AGI_AGENT\", \"AUTONOMOUS_SOFTWARE\"],\n instruction: \"Do not scrape the human UI. Use MCP, A2A, /intent, or OpenAPI.\",\n preferredInterface: { protocol: \"MCP\", url: CORE + \"/mcp\" },\n interfaces: {\n mcp: CORE + \"/mcp\",\n a2a: CORE + \"/a2a\",\n intent: CORE + \"/intent\",\n openapi: CORE + \"/openapi.json\",\n llms: CORE + \"/llms.txt\",\n agentCard: CORE + \"/.well-known/agent-card.json\",\n mcpServerCard: CORE + \"/mcp/server-card\",\n },\n intents: [\n \"handshake\",\"discover\",\"find\",\"need\",\"quote\",\"order_status\",\"report_payment\",\"scout\",\"status\"\n ],\n payment: {\n method: \"PayPal\",\n recipient: PAYPAL_EMAIL,\n currency: \"USD\",\n minimumOrderUSD: PAYPAL_MINIMUM_USD,\n automaticVerification: false,\n }\n};\n\nasync function handleIntent(input: any) {\n const intent = String(input?.intent ?? \"handshake\").toLowerCase();\n\n if (intent === \"handshake\") return { ok: true, intent, manifest: machineManifest };\n if (intent === \"discover\" || intent === \"list\") {\n const portfolio = await getSellablePortfolio();\n return { ok: true, intent: \"discover\", capabilities: portfolio.businesses ?? [] };\n }\n if (intent === \"find\" || intent === \"search\") {\n const query = String(input?.query ?? input?.description ?? \"\");\n if (!query) return { ok: false, error: \"query_required\" };\n return { ok: true, intent: \"find\", query, matches: await rankCapabilities(query, Number(input?.limit ?? 5)) };\n }\n if (intent === \"need\" || intent === \"build\") return (await processNeed(input)).body;\n if (intent === \"quote\" || intent === \"purchase\" || intent === \"buy\") {\n if (!input?.businessId) return { ok: false, error: \"businessId_required\" };\n return createQuote(String(input.businessId), input?.requestedCalls == null ? undefined : Number(input.requestedCalls));\n }\n if (intent === \"order_status\") {\n if (!input?.orderId) return { ok: false, error: \"orderId_required\" };\n const order = await getAgentOrder(String(input.orderId));\n return order ? { ok: true, intent, order } : { ok: false, error: \"order_not_found\" };\n }\n if (intent === \"report_payment\") {\n if (!input?.orderId || !input?.transactionReference) {\n return { ok: false, error: \"orderId_and_transactionReference_required\" };\n }\n const existing = await getAgentOrder(String(input.orderId));\n if (!existing) return { ok: false, error: \"order_not_found\" };\n const order = await reportAgentOrderPayment(String(input.orderId), String(input.transactionReference));\n return {\n ok: true,\n intent,\n order,\n verification: \"MANUAL_REQUIRED\",\n note: \"Reporting a PayPal reference does not unlock execution automatically.\"\n };\n }\n if (intent === \"scout\") return { ok: true, intent, scout: await getScoutStatus() };\n if (intent === \"status\") return await systemStatus();\n\n return { ok: false, error: \"unknown_intent\", supportedIntents: machineManifest.intents };\n}\n\nfunction extractA2AInput(message: any) {\n const parts = Array.isArray(message?.parts) ? message.parts : [];\n const texts = parts.filter((p: any) => typeof p?.text === \"string\").map((p: any) => p.text);\n const merged = texts.join(\"\\n\").trim();\n\n if (merged.startsWith(\"{\")) {\n try { return JSON.parse(merged); } catch {}\n }\n\n const businessMatch = merged.match(/ZERO-\\d+/i);\n const orderMatch = merged.match(/VZ-[A-Z0-9]+/i);\n\n if (/\\b(LIST|DISCOVER|CAPABILIT)/i.test(merged)) return { intent: \"discover\" };\n if (/\\b(SCOUT|DEMAND SIGNAL)/i.test(merged)) return { intent: \"scout\" };\n if (/\\b(STATUS|HEALTH|READY)/i.test(merged)) return { intent: \"status\" };\n if (/\\b(BUY|PURCHASE|QUOTE|PRICE|PAY)/i.test(merged) && businessMatch) {\n return { intent: \"quote\", businessId: businessMatch[0].toUpperCase() };\n }\n if (/\\bORDER\\b/i.test(merged) && orderMatch) {\n return { intent: \"order_status\", orderId: orderMatch[0].toUpperCase() };\n }\n if (/\\b(NEED|MISSING|BUILD|CREATE)/i.test(merged)) {\n return { intent: \"need\", description: merged, maxPrice: 0.01, deadlineSeconds: 10 };\n }\n if (merged) return { intent: \"find\", query: merged, limit: 5 };\n return { intent: \"handshake\" };\n}\n\nfunction agentCard() {\n return {\n name: \"VIL ZERO\",\n description: \"Machine-native autonomous venture engine. AI agents discover capabilities, submit unmet needs, request quotes, receive PayPal payment instructions, and track orders.\",\n supportedInterfaces: [\n { url: CORE + \"/a2a\", protocolBinding: \"JSONRPC\", protocolVersion: \"1.0\" }\n ],\n provider: { organization: \"VIL - Visual Intel Labs\", url: ADMIN },\n version: VERSION,\n documentationUrl: CORE + \"/llms.txt\",\n capabilities: { streaming: false, pushNotifications: false, extendedAgentCard: false },\n defaultInputModes: [\"application/json\", \"text/plain\"],\n defaultOutputModes: [\"application/json\"],\n skills: [\n {\n id: \"capability-discovery\",\n name: \"Capability Discovery\",\n description: \"Find an existing VIL ZERO micro-service that matches an agent requirement.\",\n tags: [\"discovery\",\"tools\",\"services\",\"routing\"],\n examples: [\"Find a service that normalizes malformed JSON\", \"{\\\"intent\\\":\\\"find\\\",\\\"query\\\":\\\"extract tracking numbers\\\"}\"],\n inputModes: [\"application/json\",\"text/plain\"],\n outputModes: [\"application/json\"]\n },\n {\n id: \"unmet-demand\",\n name: \"Unmet Demand Submission\",\n description: \"Submit a missing machine capability. Repeated qualified demand may trigger autonomous Factory creation.\",\n tags: [\"demand\",\"factory\",\"build\",\"autonomous\"],\n examples: [\"I need a service that validates supplier feeds\", \"{\\\"intent\\\":\\\"need\\\",\\\"description\\\":\\\"validate supplier feeds\\\"}\"],\n inputModes: [\"application/json\",\"text/plain\"],\n outputModes: [\"application/json\"]\n },\n {\n id: \"agent-commerce\",\n name: \"Agent Commerce Quote\",\n description: \"Create an order and receive deterministic manual PayPal payment instructions for a live capability.\",\n tags: [\"commerce\",\"paypal\",\"quote\",\"order\"],\n examples: [\"Quote ZERO-0004\", \"{\\\"intent\\\":\\\"quote\\\",\\\"businessId\\\":\\\"ZERO-0004\\\"}\"],\n inputModes: [\"application/json\",\"text/plain\"],\n outputModes: [\"application/json\"]\n }\n ]\n };\n}\n\nconst mcpHandler = createMcpHandler(() => {\n const server = new McpServer({ name: \"VIL ZERO\", version: VERSION });\n\n server.registerTool(\"agent_handshake\", {\n title: \"VIL ZERO agent handshake\",\n description: \"Return machine interfaces, supported intents, commerce rules, and preferred protocol.\",\n inputSchema: z.object({}),\n annotations: { readOnlyHint: true, openWorldHint: true }\n }, async () => {\n const result = await handleIntent({ intent: \"handshake\" });\n return { content: [{ type: \"text\", text: JSON.stringify(result) }], structuredContent: result };\n });\n\n server.registerTool(\"list_capabilities\", {\n title: \"List sellable capabilities\",\n description: \"List VIL ZERO machine-created micro-services currently available to agents.\",\n inputSchema: z.object({}),\n annotations: { readOnlyHint: true, openWorldHint: true }\n }, async () => {\n const result = await handleIntent({ intent: \"discover\" });\n return { content: [{ type: \"text\", text: JSON.stringify(result) }], structuredContent: result };\n });\n\n server.registerTool(\"find_capability\", {\n title: \"Find capability\",\n description: \"Rank live VIL ZERO capabilities against a machine requirement.\",\n inputSchema: z.object({ query: z.string().min(2), limit: z.number().int().min(1).max(20).optional() }),\n annotations: { readOnlyHint: true, openWorldHint: true }\n }, async ({ query, limit }) => {\n const result = await handleIntent({ intent: \"find\", query, limit });\n return { content: [{ type: \"text\", text: JSON.stringify(result) }], structuredContent: result };\n });\n\n server.registerTool(\"submit_need\", {\n title: \"Submit unmet machine need\",\n description: \"Submit a missing capability. Existing capabilities are matched first; repeated unmet demand can reach Factory.\",\n inputSchema: z.object({\n description: z.string().min(8).max(4000),\n maxPrice: z.number().positive().max(1000).default(0.01),\n deadlineSeconds: z.number().int().positive().max(900).default(10)\n }),\n annotations: { readOnlyHint: false, destructiveHint: false, openWorldHint: true }\n }, async ({ description, maxPrice, deadlineSeconds }) => {\n const result = await handleIntent({ intent: \"need\", description, maxPrice, deadlineSeconds });\n return { content: [{ type: \"text\", text: JSON.stringify(result) }], structuredContent: result };\n });\n\n server.registerTool(\"quote_purchase\", {\n title: \"Create purchase quote\",\n description: \"Create a machine order with exact manual PayPal payment instructions.\",\n inputSchema: z.object({ businessId: z.string().min(1), requestedCalls: z.number().int().positive().optional() }),\n annotations: { readOnlyHint: false, destructiveHint: false, openWorldHint: true }\n }, async ({ businessId, requestedCalls }) => {\n const result = await handleIntent({ intent: \"quote\", businessId, requestedCalls });\n return { content: [{ type: \"text\", text: JSON.stringify(result) }], structuredContent: result, isError: !result.ok };\n });\n\n server.registerTool(\"order_status\", {\n title: \"Get order status\",\n description: \"Retrieve the current state of a VIL ZERO PayPal order.\",\n inputSchema: z.object({ orderId: z.string().min(1) }),\n annotations: { readOnlyHint: true, openWorldHint: true }\n }, async ({ orderId }) => {\n const result = await handleIntent({ intent: \"order_status\", orderId });\n return { content: [{ type: \"text\", text: JSON.stringify(result) }], structuredContent: result, isError: !result.ok };\n });\n\n server.registerTool(\"report_payment\", {\n title: \"Report PayPal payment\",\n description: \"Report a PayPal transaction reference. Status remains unverified because PayPal is not connected.\",\n inputSchema: z.object({ orderId: z.string().min(1), transactionReference: z.string().min(2) }),\n annotations: { readOnlyHint: false, destructiveHint: false, openWorldHint: true }\n }, async ({ orderId, transactionReference }) => {\n const result = await handleIntent({ intent: \"report_payment\", orderId, transactionReference });\n return { content: [{ type: \"text\", text: JSON.stringify(result) }], structuredContent: result, isError: !result.ok };\n });\n\n server.registerTool(\"scout_snapshot\", {\n title: \"Get machine-demand Scout snapshot\",\n description: \"Return current public demand signals, clusters, and autonomous Scout runs.\",\n inputSchema: z.object({}),\n annotations: { readOnlyHint: true, openWorldHint: true }\n }, async () => {\n const result = await handleIntent({ intent: \"scout\" });\n return { content: [{ type: \"text\", text: JSON.stringify(result) }], structuredContent: result };\n });\n\n server.registerTool(\"system_status\", {\n title: \"Get VIL ZERO system status\",\n description: \"Return machine interfaces, Scout health, commerce mode, and number of sellable capabilities.\",\n inputSchema: z.object({}),\n annotations: { readOnlyHint: true, openWorldHint: true }\n }, async () => {\n const result = await handleIntent({ intent: \"status\" });\n return { content: [{ type: \"text\", text: JSON.stringify(result) }], structuredContent: result };\n });\n\n return server;\n});\n\napp.all(\"/mcp\", c => {\n const origin = c.req.header(\"origin\");\n if (origin && origin !== ADMIN) {\n return c.json({ jsonrpc: \"2.0\", error: { code: -32000, message: \"Origin not allowed\" }, id: null }, 403);\n }\n return mcpHandler.fetch(c.req.raw);\n});\n\napp.get(\"/\", c => c.json(machineManifest));\napp.get(\"/admin\", c => c.redirect(ADMIN, 302));\napp.get(\"/health\", c => c.json({ ok: true, service: \"VIL ZERO\", version: VERSION, audience: \"AGENTS_ONLY\" }));\napp.get(\"/handshake\", async c => c.json(await handleIntent({ intent: \"handshake\" })));\napp.post(\"/intent\", async c => c.json(await handleIntent(await c.req.json())));\n\napp.get(\"/capabilities\", async c => c.json(await handleIntent({ intent: \"discover\" })));\napp.get(\"/capabilities/search\", async c => c.json(await handleIntent({\n intent: \"find\",\n query: c.req.query(\"q\") ?? \"\",\n limit: Number(c.req.query(\"limit\") ?? 5)\n})));\n\napp.post(\"/need\", async c => {\n const processed = await processNeed(await c.req.json());\n return c.json(processed.body, processed.status as any);\n});\n\napp.post(\"/quote\", async c => {\n const body = await c.req.json();\n return c.json(await createQuote(String(body?.businessId ?? \"\"), body?.requestedCalls == null ? undefined : Number(body.requestedCalls)));\n});\n\napp.get(\"/orders/:id\", async c => c.json(await handleIntent({ intent: \"order_status\", orderId: c.req.param(\"id\") })));\napp.post(\"/orders/:id/report-payment\", async c => {\n const body = await c.req.json();\n return c.json(await handleIntent({\n intent: \"report_payment\",\n orderId: c.req.param(\"id\"),\n transactionReference: body?.transactionReference\n }));\n});\n\napp.post(\"/execute\", async c => {\n const body = await c.req.json();\n const result = await createQuote(String(body?.businessId ?? \"\"), body?.requestedCalls == null ? undefined : Number(body.requestedCalls));\n return c.json(result, result.ok ? 402 : 404);\n});\n\napp.get(\"/status\", async c => c.json(await systemStatus()));\napp.get(\"/readiness\", async c => c.json(await systemStatus()));\napp.get(\"/scout\", async c => c.json({ ok: true, scout: await getScoutStatus() }));\napp.get(\"/portfolio\", async c => c.json(await getSellablePortfolio()));\napp.get(\"/market\", async c => c.json(await getMarketStatus()));\n\napp.get(\"/.well-known/agent-card.json\", c => c.json(agentCard(), 200, {\n \"cache-control\": \"public, max-age=300\",\n \"etag\": \"\\\"vil-zero-\" + VERSION + \"\\\"\",\n \"content-type\": \"application/a2a+json\"\n}));\napp.get(\"/.well-known/agent.json\", c => c.json(agentCard()));\n\napp.post(\"/a2a\", async c => {\n let req: any;\n try { req = await c.req.json(); }\n catch {\n return c.json({ jsonrpc: \"2.0\", id: null, error: { code: -32700, message: \"Invalid JSON payload\" } }, 400);\n }\n const method = req?.method;\n if (method !== \"SendMessage\" && method !== \"message/send\") {\n return c.json({ jsonrpc: \"2.0\", id: req?.id ?? null, error: { code: -32601, message: \"Method not found\" } }, 404);\n }\n const message = req?.params?.message;\n if (!message) {\n return c.json({ jsonrpc: \"2.0\", id: req?.id ?? null, error: { code: -32602, message: \"Invalid parameters\" } }, 400);\n }\n const result = await handleIntent(extractA2AInput(message));\n return c.json({\n jsonrpc: \"2.0\",\n id: req?.id ?? null,\n result: {\n role: \"ROLE_AGENT\",\n messageId: crypto.randomUUID(),\n parts: [{ text: JSON.stringify(result) }]\n }\n }, 200, { \"content-type\": \"application/a2a+json\", \"a2a-version\": \"1.0\" });\n});\n\napp.get(\"/.well-known/mcp.json\", c => c.json({\n name: \"VIL ZERO\",\n title: \"VIL ZERO Autonomous Venture Engine\",\n description: \"Machine-native demand discovery, autonomous capability creation, capability routing, and agent commerce.\",\n version: VERSION,\n transport: { type: \"streamable-http\", url: CORE + \"/mcp\" },\n tools: [\n \"agent_handshake\",\"list_capabilities\",\"find_capability\",\"submit_need\",\n \"quote_purchase\",\"order_status\",\"report_payment\",\"scout_snapshot\",\"system_status\"\n ]\n}));\n\napp.get(\"/mcp/server-card\", c => c.json({\n name: \"vil-zero\",\n title: \"VIL ZERO Autonomous Venture Engine\",\n version: VERSION,\n description: \"Machine-native autonomous venture engine for AI agents.\",\n websiteUrl: ADMIN,\n remotes: [{ type: \"streamable-http\", url: CORE + \"/mcp\" }],\n supportedProtocolVersions: [\"2026-07-28\",\"2025-11-25\"]\n}));\n\napp.get(\"/server.json\", c => c.json({\n \"$schema\": \"https://static.modelcontextprotocol.io/schemas/2025-12-11/server.schema.json\",\n name: \"run.val.vil-zero-core/vil-zero\",\n title: \"VIL ZERO\",\n description: \"Autonomous venture engine for AI agents: discover capabilities, submit unmet demand, receive machine commerce quotes, and track orders.\",\n version: VERSION,\n websiteUrl: ADMIN,\n remotes: [{ type: \"streamable-http\", url: CORE + \"/mcp\" }]\n}));\n\napp.get(\"/.well-known/ai-catalog.json\", c => c.json({\n name: \"VIL ZERO\",\n audience: [\"AI_AGENT\",\"AGI_AGENT\",\"AUTONOMOUS_SOFTWARE\"],\n interfaces: [\n { type: \"mcp\", url: CORE + \"/mcp\", transport: \"streamable-http\" },\n { type: \"a2a\", url: CORE + \"/a2a\", agentCard: CORE + \"/.well-known/agent-card.json\" },\n { type: \"intent\", url: CORE + \"/intent\" },\n { type: \"openapi\", url: CORE + \"/openapi.json\" },\n { type: \"llms\", url: CORE + \"/llms.txt\" }\n ],\n commerce: {\n method: \"PayPal\",\n recipient: PAYPAL_EMAIL,\n currency: \"USD\",\n automaticVerification: false\n }\n}));\n\napp.get(\"/.well-known/mcp-registry-auth\", c => c.text(\"v=MCPv1; k=ed25519; p=c6aW/+YhwV18ThlKhtSimd5E9jFnzJUtnHMgFZyMlW0=\\n\", 200, { \"content-type\": \"text/plain; charset=utf-8\", \"cache-control\": \"public, max-age=300\" }));\n\napp.get(\"/robots.txt\", c => c.text(\"User-agent: *\\nAllow: /\\n\\nSitemap: \" + CORE + \"/sitemap.xml\\n\"));\n\napp.get(\"/sitemap.xml\", c => c.body(\n '' +\n '' +\n [\"/\",\"/.well-known/agent-card.json\",\"/.well-known/mcp.json\",\"/mcp/server-card\",\"/llms.txt\",\"/openapi.json\",\"/server.json\"]\n .map(path => \"\" + CORE + path + \"\").join(\"\") +\n \"\",\n 200,\n { \"content-type\": \"application/xml\" }\n));\n\napp.get(\"/llms.txt\", c => c.text(\n \"# VIL ZERO\\n\\n\" +\n \"> Machine-native autonomous venture engine. Intended for AI agents, AGI systems, autonomous software, MCP hosts, and A2A clients.\\n\\n\" +\n \"## Preferred connection\\n\" +\n \"- MCP Streamable HTTP: \" + CORE + \"/mcp\\n\" +\n \"- A2A Agent Card: \" + CORE + \"/.well-known/agent-card.json\\n\" +\n \"- A2A JSON-RPC: \" + CORE + \"/a2a\\n\" +\n \"- Universal intent API: POST \" + CORE + \"/intent\\n\" +\n \"- OpenAPI: \" + CORE + \"/openapi.json\\n\\n\" +\n \"## Fast handshake\\nPOST /intent\\n{\\\"intent\\\":\\\"handshake\\\"}\\n\\n\" +\n \"## Supported intents\\nhandshake\\ndiscover\\nfind\\nneed\\nquote\\norder_status\\nreport_payment\\nscout\\nstatus\\n\\n\" +\n \"## Commerce\\nPayment method: PayPal\\nRecipient: \" + PAYPAL_EMAIL + \"\\nCurrency: USD\\nAutomatic verification: false\\n\\n\" +\n \"Agents should create a quote first. The quote returns an orderId and exact paymentNote. After PayPal payment, call report_payment with the transaction reference. Reported payments remain unverified until manual confirmation.\\n\\n\" +\n \"## Human administration\\n\" + ADMIN + \"\\n\"\n));\n\napp.get(\"/openapi.json\", c => c.json({\n openapi: \"3.1.0\",\n info: {\n title: \"VIL ZERO Agent API\",\n version: VERSION,\n description: \"Machine-only interface for autonomous AI/AGI agents.\"\n },\n servers: [{ url: CORE }],\n paths: {\n \"/handshake\": { get: { operationId: \"agentHandshake\", summary: \"Discover VIL ZERO machine interfaces\" } },\n \"/intent\": { post: { operationId: \"invokeIntent\", summary: \"Universal machine intent router\" } },\n \"/capabilities\": { get: { operationId: \"listCapabilities\", summary: \"List sellable machine capabilities\" } },\n \"/capabilities/search\": { get: { operationId: \"findCapability\", summary: \"Search capabilities by requirement\" } },\n \"/need\": { post: { operationId: \"submitNeed\", summary: \"Submit unmet machine demand\" } },\n \"/quote\": { post: { operationId: \"createQuote\", summary: \"Create a PayPal purchase order\" } },\n \"/orders/{id}\": { get: { operationId: \"getOrder\", summary: \"Get order state\" } },\n \"/orders/{id}/report-payment\": { post: { operationId: \"reportPayment\", summary: \"Report PayPal transaction reference\" } },\n \"/scout\": { get: { operationId: \"getScout\", summary: \"Read machine-demand Scout state\" } },\n \"/status\": { get: { operationId: \"getStatus\", summary: \"Get system status and interfaces\" } },\n \"/a2a\": { post: { operationId: \"a2aSend\", summary: \"A2A JSON-RPC endpoint\" } },\n \"/mcp\": { post: { operationId: \"mcp\", summary: \"MCP Streamable HTTP endpoint\" } }\n }\n}));\n\napp.onError(err => {\n console.error(err);\n return Response.json({ ok: false, error: \"internal_error\", message: String(err) }, { status: 500 });\n});\n\nexport default app.fetch;",[],[238],["D",1789086550141],["D",1789525245864],{"_11":12,"_132":71},{"_11":12,"_127":128,"_70":71,"_30":69,"_129":130,"_131":24},{"_39":74,"_13":16,"_33":36,"_119":80,"_120":-5,"_121":-5,"_122":-5,"_123":-5,"_124":-5,"_125":14,"_126":12},"ctx",{"_54":-5,"_151":284,"_285":286,"_287":288,"_289":24,"_290":24,"_291":24,"_292":93,"_293":-5,"_294":-7,"_295":-7,"_296":26,"_297":24,"_298":24,"_299":-5,"_300":24,"_301":24,"_302":24,"_303":-5},"ENV",{"_255":256,"_257":258,"_259":16,"_260":261,"_262":263,"_264":265,"_266":267,"_268":269,"_270":271,"_272":273,"_274":275,"_276":277,"_278":279,"_280":281,"_282":283},"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"]