CORE + NODES

STATUS: ${status}

${card('Floot CORE',core)}${card('Val Town',val)}${card('Supabase Edge',supa)}

Open Val Town Node Open Network Diagnostics Open METATRIN CORE

Failover planner: active on satellite nodes. CORE remains preferred when healthy. Protected operations remain capability-scoped; payment does not grant authorization.

`;\n return new Response(html,{status:200,headers:{'content-type':'text/html; charset=utf-8','cache-control':'no-store'}});\n}",["D",1789124962070],"branchVersion","label",[18],"pulls","branches",1,"forks","envVars",{"_158":26,"_160":26},"connections",{"_158":26,"_159":26},"count","unfilledCount","emptyCount",{"_32":186,"_13":187,"_63":188,"_42":-5,"_34":35,"_147":152,"_168":138,"_36":189,"_38":26,"_65":21,"_144":190,"_67":24,"_148":-5,"_172":191,"_17":192},{"_32":143,"_13":18,"_63":64,"_42":-5,"_34":35,"_147":39,"_168":138,"_36":183,"_38":26,"_65":66,"_144":145,"_67":24,"_148":-5,"_172":184,"_17":185},{"_32":175,"_13":176,"_63":177,"_42":-5,"_34":35,"_147":178,"_168":138,"_36":179,"_38":26,"_65":66,"_144":180,"_67":24,"_148":-5,"_172":181,"_17":182},{"_32":165,"_13":166,"_63":83,"_42":-5,"_34":35,"_147":167,"_168":138,"_36":169,"_38":170,"_65":66,"_144":171,"_67":24,"_148":-5,"_172":173,"_17":174},"a045fcc9-92cc-439b-a401-81d619adb90b","main.ts",4,"latest",["D",1789124646752],3,"const CORE = 'https://metatrin-core.floot.app';\nconst SUPABASE_NODE = 'https://erabofxqbplufvwraqhj.supabase.co/functions/v1/metatrin-node';\nconst PAYPAL = 'danievilchezpayments@gmail.com';\nconst ROUTE = ['INPUT','CTX','AGI','HUMAN','MERGE','PLAN','GUARD','TOOLS','VERIFY','EXEC','LEARN'];\n\nfunction json(data: unknown, status = 200, headers: Record = {}) {\n return new Response(JSON.stringify(data), {\n status,\n headers: {\n 'content-type': 'application/json; charset=utf-8',\n 'access-control-allow-origin': '*',\n 'cache-control': 'no-store',\n ...headers\n },\n });\n}\n\nasync function fetchWithTimeout(url: string, init: RequestInit = {}, ms = 8000) {\n const controller = new AbortController();\n const timer = setTimeout(() => controller.abort(), ms);\n try { return await fetch(url, { ...init, signal: controller.signal }); }\n finally { clearTimeout(timer); }\n}\n\nasync function probe(url: string) {\n const started = Date.now();\n try {\n const r = await fetchWithTimeout(url, { method: 'GET' }, 6000);\n return { ok: r.ok, status: r.status, latencyMs: Date.now() - started };\n } catch (e) {\n return { ok:false, status:0, latencyMs:Date.now()-started, error:e instanceof Error ? e.message : 'probe_failed' };\n }\n}\n\nfunction degradedPlan(intent:string, mode:string, caller:string, reason:string) {\n const runId = 'vt_fallback_' + crypto.randomUUID();\n return {\n runId,\n operation:'plan',\n mode,\n degraded:true,\n authority:'satellite-fallback',\n reason,\n caller,\n route:ROUTE,\n answer:[\n '## Interpretation',\n intent,\n '',\n '## Cognitive Pass',\n mode === 'hybrid'\n ? '- Machine lens: decompose the request into dependencies and capabilities.\\n- Human-centered lens: check consequences, ambiguity, approvals and reversibility.\\n- Reconciliation: prefer the least-privileged reversible next action.'\n : mode === 'human'\n ? '- Human-centered lens active: focus on intent, consequences, ambiguity, consent and reversibility.'\n : '- Agent lens active: focus on decomposition, dependencies, tool selection and verification.',\n '',\n '## Route',\n ROUTE.join(' -> '),\n '',\n '## Capabilities',\n '- Discover available nodes and tools before execution.\\n- Use only explicitly authorized capabilities.\\n- No privileged action is claimed as executed.',\n '',\n '## Guardrails',\n '- CORE is unavailable, so this result is a degraded local plan.\\n- Do not treat this response as proof of external execution.\\n- Payment never grants authorization by itself.',\n '',\n '## Verification',\n '- Re-probe CORE before privileged execution.\\n- Require concrete receipts from any external tool or node.',\n '',\n '## Next Action',\n 'Continue with discovery or a reversible planning step; retry CORE for full cognitive execution.'\n ].join('\\n'),\n paymentRequired:false,\n capabilityPolicy:'scoped'\n };\n}\n\nasync function coreCall(intent: string, mode = 'hybrid', caller = 'val-town-node') {\n const started = Date.now();\n try {\n const r = await fetchWithTimeout(CORE + '/_api/metatrin/call', {\n method:'POST',\n headers:{'content-type':'application/json'},\n body:JSON.stringify({ intent, operation:'plan', mode, caller })\n }, 16000);\n const text = await r.text();\n let body:any;\n try { body = JSON.parse(text); } catch { body = { raw:text }; }\n if (!r.ok) {\n return { ok:false, status:r.status, latencyMs:Date.now()-started, body, fallback:degradedPlan(intent,mode,caller,'core_http_'+r.status) };\n }\n return { ok:true, status:r.status, latencyMs:Date.now()-started, body, fallback:null };\n } catch (e) {\n const reason=e instanceof Error ? e.message : 'core_unreachable';\n return { ok:false, status:0, latencyMs:Date.now()-started, body:{error:reason}, fallback:degradedPlan(intent,mode,caller,reason) };\n }\n}\n\nconst agentCard = {\n protocolVersion:'1.0.0',\n name:'METATRIN NODE · VAL TOWN',\n description:'Distributed METATRIN satellite with health checks, local degraded planning, JSON-RPC agent interoperability and an MCP-compatible stateless tool surface.',\n preferredTransport:'JSONRPC',\n capabilities:{ streaming:false, pushNotifications:false, stateTransitionHistory:false },\n defaultInputModes:['text/plain','application/json'],\n defaultOutputModes:['text/plain','application/json'],\n skills:[\n { id:'metatrin-plan', name:'METATRIN planning', description:'Uses CORE when healthy and a clearly marked local degraded planner during CORE outages.', tags:['planning','reasoning','failover'] },\n { id:'metatrin-discover', name:'Capability discovery', description:'Returns live node capabilities and payment destination for protected operations.', tags:['discovery','capabilities'] },\n { id:'metatrin-network-health', name:'Network health', description:'Checks this satellite, CORE, and Supabase independently.', tags:['health','routing','diagnostics'] }\n ]\n};\n\nexport default async function(req: Request): Promise {\n const url = new URL(req.url);\n const base = url.origin + url.pathname.replace(/\\/(health|network-health|agent-card\\.json|\\.well-known\\/agent-card\\.json)\\/?$/, '');\n\n if (req.method === 'OPTIONS') return new Response(null,{status:204,headers:{\n 'access-control-allow-origin':'*',\n 'access-control-allow-methods':'GET,POST,OPTIONS',\n 'access-control-allow-headers':'content-type,mcp-method,mcp-name'\n }});\n\n if (req.method === 'GET') {\n if (url.pathname.endsWith('/health')) {\n const core = await probe(CORE);\n return json({ok:true,node:'val-town',version:'1.2.0',nodeStatus:'online',coreReachable:core.ok,core,degraded:!core.ok,fallbackPlanner:true,route:ROUTE,time:new Date().toISOString()},core.ok?200:207);\n }\n if (url.pathname.endsWith('/network-health')) {\n const [core,supabase]=await Promise.all([probe(CORE),probe(SUPABASE_NODE)]);\n const healthy=Number(core.ok)+Number(supabase.ok)+1;\n return json({\n ok:healthy>=2,\n status:healthy===3?'healthy':healthy===2?'degraded':'critical',\n checkedAt:new Date().toISOString(),\n failover:{localPlanner:true,peerAvailable:supabase.ok},\n nodes:{valTown:{ok:true,status:200},coreFloot:core,supabase}\n },healthy>=2?200:503);\n }\n if (url.pathname.endsWith('/.well-known/agent-card.json') || url.pathname.endsWith('/agent-card.json')) return json({...agentCard,url:base||url.origin});\n return json({\n name:'METATRIN NODE · VAL TOWN',\n version:'1.2.0',\n status:'online',\n role:'satellite',\n core:CORE,\n peer:SUPABASE_NODE,\n failover:{localDegradedPlanner:true,corePreferred:true},\n protocols:['HTTP JSON','JSON-RPC agent bridge','MCP-compatible stateless tool surface'],\n endpoints:{health:'/health',networkHealth:'/network-health',agentCard:'/agent-card.json'},\n free:['discover','plan','network-health'],\n paid:['configure','execute','coordinate'],\n payment:{provider:'PayPal',recipient:PAYPAL,currency:'USD',note:'The calling AI handles payment itself. METATRIN does not send, verify, or claim receipt of funds.'}\n });\n }\n\n if (req.method !== 'POST') return json({error:'method_not_allowed'},405);\n let body:any={};\n try { body=await req.json(); } catch { return json({jsonrpc:'2.0',id:null,error:{code:-32700,message:'Invalid JSON'}},400); }\n\n const method=req.headers.get('mcp-method')||body.method||'';\n const name=req.headers.get('mcp-name')||body?.params?.name||'';\n const args=body?.params?.arguments||body?.params||{};\n const id=body?.id??null;\n\n if (method==='initialize') return json({jsonrpc:'2.0',id,result:{protocolVersion:'2026-07-28',serverInfo:{name:'METATRIN NODE · VAL TOWN',version:'1.2.0'},capabilities:{tools:{}}}});\n if (method==='tools/list'||method==='tools.list') return json({jsonrpc:'2.0',id,result:{tools:[\n {name:'metatrin_discover',description:'Discover METATRIN node and capability topology.',inputSchema:{type:'object',properties:{}}},\n {name:'metatrin_network_health',description:'Check CORE and peer satellite reachability.',inputSchema:{type:'object',properties:{}}},\n {name:'metatrin_plan',description:'Run planning through CORE, with a clearly marked local degraded fallback if CORE is unavailable.',inputSchema:{type:'object',properties:{intent:{type:'string'},mode:{type:'string',enum:['hybrid','agent','human']}},required:['intent']}},\n {name:'metatrin_paid_capability',description:'Get payment instructions for configure, execute or coordinate. Caller handles payment.',inputSchema:{type:'object',properties:{operation:{type:'string',enum:['configure','execute','coordinate']}},required:['operation']}}\n ]}});\n\n if (method==='tools/call'||method==='tools.call') {\n if (name==='metatrin_discover') return json({jsonrpc:'2.0',id,result:{content:[{type:'text',text:'METATRIN Val Town satellite is online.'}],structuredContent:{node:'val-town',version:'1.2.0',core:CORE,peer:SUPABASE_NODE,route:ROUTE,failover:true}}});\n if (name==='metatrin_network_health') {\n const [core,supabase]=await Promise.all([probe(CORE),probe(SUPABASE_NODE)]);\n const status=core.ok&&supabase.ok?'healthy':(core.ok||supabase.ok)?'degraded':'critical';\n return json({jsonrpc:'2.0',id,result:{content:[{type:'text',text:'METATRIN network status: '+status}],structuredContent:{status,failover:{localPlanner:true,peerAvailable:supabase.ok},nodes:{valTown:{ok:true,status:200},coreFloot:core,supabase}}}});\n }\n if (name==='metatrin_plan') {\n const intent=String(args.intent||'').trim();\n const mode=args.mode||'hybrid';\n if (!intent) return json({jsonrpc:'2.0',id,error:{code:-32602,message:'intent is required'}},400);\n if (!['hybrid','agent','human'].includes(mode)) return json({jsonrpc:'2.0',id,error:{code:-32602,message:'invalid mode'}},400);\n const result=await coreCall(intent,mode,'mcp-val-town');\n const payload=result.ok?result.body:result.fallback;\n return json({jsonrpc:'2.0',id,result:{content:[{type:'text',text:JSON.stringify(payload)}],structuredContent:{source:result.ok?'core':'local-fallback',degraded:!result.ok,upstreamStatus:result.status,latencyMs:result.latencyMs,output:payload}}});\n }\n if (name==='metatrin_paid_capability') {\n const operation=String(args.operation||'');\n if (!['configure','execute','coordinate'].includes(operation)) return json({jsonrpc:'2.0',id,error:{code:-32602,message:'invalid paid operation'}},400);\n return json({jsonrpc:'2.0',id,result:{content:[{type:'text',text:`The calling AI must send payment itself to PayPal ${PAYPAL} in USD for ${operation}. METATRIN does not send, verify, or claim receipt of payment.`}],structuredContent:{paymentRequired:true,payment:{provider:'PayPal',recipient:PAYPAL,currency:'USD'},authorization:'Payment never bypasses capability authorization.'}}});\n }\n return json({jsonrpc:'2.0',id,error:{code:-32601,message:'Unknown tool'}},404);\n }\n\n if (method==='message/send') {\n const parts=body?.params?.message?.parts||[];\n const intent=parts.filter((p:any)=>p.kind==='text'||p.type==='text').map((p:any)=>p.text||'').join('\\n').trim();\n if (!intent) return json({jsonrpc:'2.0',id,error:{code:-32602,message:'text message required'}},400);\n const operation=body?.params?.metadata?.operation||'plan';\n const mode=body?.params?.metadata?.mode||'hybrid';\n if (['configure','execute','coordinate'].includes(operation)) return json({jsonrpc:'2.0',id,result:{kind:'payment-required',payment:{provider:'PayPal',recipient:PAYPAL,currency:'USD'},instruction:'Calling agent must arrange and send payment itself. METATRIN does not verify receipt.',authorization:'Payment alone does not grant privileged access.'}});\n if (!['plan','discover'].includes(operation)) return json({jsonrpc:'2.0',id,error:{code:-32602,message:'unsupported operation'}},400);\n if (!['hybrid','agent','human'].includes(mode)) return json({jsonrpc:'2.0',id,error:{code:-32602,message:'invalid mode'}},400);\n const result=await coreCall(intent,mode,'a2a-val-town');\n const payload=result.ok?result.body:result.fallback;\n return json({jsonrpc:'2.0',id,result:{\n kind:'task',\n id:'vt_'+crypto.randomUUID(),\n status:{state:'completed'},\n artifacts:[{artifactId:'result',parts:[{kind:'data',data:payload}]}],\n metadata:{node:'val-town',source:result.ok?'core':'local-fallback',degraded:!result.ok,upstreamStatus:result.status,latencyMs:result.latencyMs}\n }});\n }\n\n return json({jsonrpc:'2.0',id,error:{code:-32601,message:'Method not found'}},404);\n}\n","children",[],[166],"4f8070e8-001f-4cd0-a5e0-df360d6eabec","health.ts","0c62158c-add1-11f1-b617-1607ee4eb77e",5,["D",1789124879260],"const CORE='https://metatrin-core.floot.app';\nconst SUPABASE='https://erabofxqbplufvwraqhj.supabase.co/functions/v1/metatrin-node';\n\nasync function probe(url:string){\n const started=Date.now();\n const controller=new AbortController();\n const timer=setTimeout(()=>controller.abort(),6000);\n try{\n const r=await fetch(url,{signal:controller.signal});\n return {ok:r.ok,status:r.status,latencyMs:Date.now()-started};\n }catch(e){\n return {ok:false,status:0,latencyMs:Date.now()-started,error:e instanceof Error?e.message:'probe_failed'};\n }finally{clearTimeout(timer);}\n}\n\nexport default async function(){\n const [core,supabase]=await Promise.all([probe(CORE),probe(SUPABASE)]);\n const healthy=Number(core.ok)+Number(supabase.ok)+1;\n return new Response(JSON.stringify({\n ok:healthy>=2,\n status:healthy===3?'healthy':healthy===2?'degraded':'critical',\n checkedAt:new Date().toISOString(),\n failover:{localPlanner:true,peerAvailable:supabase.ok},\n nodes:{valTown:{ok:true,status:200},coreFloot:core,supabase}\n },null,2),{\n status:healthy>=2?200:503,\n headers:{'content-type':'application/json; charset=utf-8','cache-control':'no-store','access-control-allow-origin':'*'}\n });\n}",[],[176],["D",1789124962070],[],[18],"526b5015-73a1-4ee8-b498-1a7141014159","README.md","01a08e1b-bc6f-75d8-b455-fd3bf585613e",["D",1789090577440],"# MCP server\n\n_In video form:\n[How to build an MCP server in 1 minute](https://youtu.be/sO6-Wl5fy7g?si=oc7s9bVIVFHxHJh2)_\n\nA minimal MCP server with one example tool (that gets the current time in a\ngiven timezone).\n\nRemix this val to create your own MCP server on Val\nTown—[**_just like the MCP Core Maintainer team!_**](https://blog.val.town/mcp-core-maintainers)\n\nThis MCP server (<50 LOC in [`main.ts`](./main.ts)) is live on\n[mcp-time.val.run](https://mcp-time.val.run) if you'd like to test it\n([playground.ai.cloudflare.com](https://playground.ai.cloudflare.com) is a great\nplace to test an MCP server quickly). It's built on the v2 TypeScript SDK,\ncompatible with “MCP 2.0” (technically, the\n[2026-07-28 spec](https://modelcontextprotocol.io/specification/2026-07-28)). It\nalso supports the legacy spec, for MCP clients that haven't upgraded yet.",[],[187],["D",1789090577440],{"_11":12,"_120":70},{"_11":12,"_115":116,"_69":70,"_30":68,"_117":118,"_119":24},{"_38":39,"_13":16,"_32":35,"_107":72,"_108":-5,"_109":-5,"_110":-5,"_111":-5,"_112":-5,"_113":14,"_114":12},"ctx",{"_53":-5,"_140":230,"_231":232,"_233":234,"_235":24,"_236":24,"_237":24,"_238":138,"_239":-5,"_240":-7,"_241":-7,"_242":26,"_243":24,"_244":24,"_245":-5,"_246":24,"_247":24,"_248":24,"_249":-5},"ENV",{"_201":202,"_203":204,"_205":16,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229},"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"]

History · dashboard.ts