[{"_1":2,"_304":-5,"_305":-5},"loaderData",{"_3":4,"_95":96,"_280":281},"root",{"_5":6,"_36":37,"_68":69},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":22,"_29":22,"_30":22,"_31":-5,"_32":33,"_34":22,"_35":22},"auth",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"tokenType","session_token","sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isPaidOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65,"_66":67},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","d1375c05ce15aa00f0f5fc1d56cfa8d009f00f8a","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_70":71},"__internal_clerk_state",{"_72":73,"_74":47,"_75":76,"_77":76,"_78":22,"_79":76,"_80":76,"_81":76,"_82":76,"_83":84,"_93":22,"_94":22},"__clerk_ssr_state",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_85":22,"_21":22,"_86":76,"_87":88,"_89":76,"_90":47,"_91":22,"_92":76},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/_app.x.$handle.$name",{"_97":98,"_99":100,"_101":-7,"_102":76,"_103":-7,"_104":105,"_159":160,"_245":246,"_247":248,"_260":261,"_204":-5,"_274":-5,"_275":-5,"_276":22,"_277":22,"_278":279},"handle","stevekrouse","name","agent-mpp-v5","branchName","path","version","project",{"_106":107,"_99":100,"_108":109,"_110":-5,"_111":22,"_112":113,"_114":115,"_116":-5,"_14":117,"_118":119,"_120":121,"_122":-5,"_123":-5,"_124":33,"_16":125,"_126":-5,"_127":-5,"_128":-5,"_129":130,"_131":130,"_132":133,"_134":133,"_135":133,"_136":130,"_137":130,"_23":138,"_141":142,"_146":147,"_158":22},"id","8612b730-279c-11f1-bf0d-42dde27851f2","createdAt",["D",1774368864292],"deletedAt","legacyEnvVars","privacy","public","description","Chat agent with tool calling using AI SDK v5","imageUrl","a0bf3b31-15a5-4d5c-880e-4b1e22c9bc18","pinnedFileId","8617af9c-279c-11f1-bf0d-42dde27851f2","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","e81e7335-6d4c-4764-a902-d0962bbfa9f7","tursoName","tursoHostname","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_97":98,"_139":140},"profileImageUrl","https://images.clerk.dev/uploaded/img_2PqHa2Gsy93xQrjh2w78Xu0cChW.jpeg","org",{"_97":98,"_143":140,"_14":117,"_144":145},"avatar","tier","pro","branch",{"_103":148,"_99":45,"_106":149,"_150":107,"_151":-5,"_152":-5,"_153":-5,"_154":-5,"_155":-5,"_156":100,"_157":98},34,"8613204e-279c-11f1-bf0d-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","tree",[161,191,228,237],{"_106":162,"_99":163,"_164":165,"_166":-5,"_167":149,"_168":169,"_170":121,"_108":171,"_103":33,"_172":173,"_174":-5,"_175":22,"_176":-5,"_177":178,"_102":190},"1c134244-27c1-11f1-b7f7-42dde27851f2","lib","fileId","9b2831d7-2eee-4291-a50d-ded0d69bedd2","parentId","branchId","branchVersion",17,"latest",["D",1774384577811],"fileType","directory","content","deleted","label","children",[179],{"_106":180,"_99":181,"_164":182,"_166":165,"_167":149,"_168":183,"_170":121,"_108":184,"_103":185,"_172":186,"_174":187,"_175":22,"_176":-5,"_177":188,"_102":189},"9f8b6d50-27f2-11f1-bf8a-42dde27851f2","mpp.ts","1c130ad6-27c1-11f1-b7f7-42dde27851f2",29,["D",1774405843731],3,"script","import { Account, Abis } from \"npm:viem/tempo\";\nimport { createClient, http, encodeFunctionData } from \"npm:viem\";\nimport { tempo as tempoChain } from \"npm:viem/chains\";\nimport { prepareTransactionRequest, signTransaction, sendRawTransactionSync } from \"npm:viem/actions\";\n\nconst USDC = \"0x20c000000000000000000000b9537d11c60e8b50\" as `0x${string}`;\n\nconst FETCH_TIMEOUT_MS = 30_000; // 30s timeout for each fetch call\nconst TX_TIMEOUT_MS = 45_000; // 45s timeout for the full payment flow\n\nexport function createMppClient(accessKey: `0x${string}`, walletAddress: `0x${string}`) {\n const account = Account.fromSecp256k1(accessKey, { access: walletAddress });\n const client = createClient({ account, chain: tempoChain, transport: http(\"https://rpc.tempo.xyz\") });\n return { account, client, walletAddress };\n}\n\nfunction parseWwwAuth(header: string) {\n const get = (n: string) => header.match(new RegExp(`${n}=\"([^\"]+)\"`))?.[1];\n return { id: get(\"id\")!, realm: get(\"realm\") || \"\", method: get(\"method\")!, intent: get(\"intent\")!, request: get(\"request\")!, expires: get(\"expires\"), description: get(\"description\") };\n}\n\n/** Fetch with a timeout via AbortSignal */\nasync function fetchWithTimeout(url: string, init?: RequestInit, timeoutMs = FETCH_TIMEOUT_MS): Promise {\n const controller = new AbortController();\n const timer = setTimeout(() => controller.abort(), timeoutMs);\n try {\n const res = await fetch(url, { ...init, signal: controller.signal });\n return res;\n } finally {\n clearTimeout(timer);\n }\n}\n\nexport async function paidFetch(mpp: ReturnType, url: string, init?: RequestInit): Promise {\n const t0 = Date.now();\n console.log(`[paidFetch] ${init?.method || \"GET\"} ${url}`);\n\n // Step 1: Get 402 challenge\n console.log(`[paidFetch] Step 1: Initial request...`);\n const res = await fetchWithTimeout(url, init);\n console.log(`[paidFetch] Step 1 done: status=${res.status} (${Date.now() - t0}ms)`);\n\n if (res.status !== 402) {\n console.log(`[paidFetch] No payment needed (${res.status}) in ${Date.now() - t0}ms`);\n return res;\n }\n\n const wwwAuth = res.headers.get(\"www-authenticate\");\n if (!wwwAuth) throw new Error(\"No WWW-Authenticate header in 402 response\");\n\n const challenge = parseWwwAuth(wwwAuth);\n const req = JSON.parse(atob(challenge.request));\n const chainId = req.methodDetails?.chainId || 4217;\n console.log(`[paidFetch] Step 2: Building USDC transfer for ${req.amount} units to ${req.recipient}...`);\n\n // Step 2: Build USDC transfer\n const data = encodeFunctionData({ abi: Abis.tip20, functionName: \"transfer\", args: [req.recipient as `0x${string}`, BigInt(req.amount)] });\n\n // Step 3: Prepare, sign, broadcast (with overall timeout)\n console.log(`[paidFetch] Step 3: Preparing transaction...`);\n const prepared = await prepareTransactionRequest(mpp.client, { account: mpp.account, calls: [{ to: req.currency as `0x${string}`, value: 0n, data }], feeToken: USDC } as any);\n const gas = (prepared as any).gas || 0n;\n (prepared as any).gas = gas > 300000n ? gas : 300000n;\n console.log(`[paidFetch] Step 3a: Transaction prepared (${Date.now() - t0}ms), signing...`);\n\n const signed = await signTransaction(mpp.client, prepared as any);\n console.log(`[paidFetch] Step 3b: Signed (${Date.now() - t0}ms), broadcasting...`);\n\n const receipt = await sendRawTransactionSync(mpp.client, { serializedTransaction: signed } as any);\n console.log(`[paidFetch] Paid ${req.amount} units, tx: ${receipt.transactionHash} (${Date.now() - t0}ms)`);\n\n // Step 4: Retry with payment credential\n const credential = btoa(JSON.stringify({\n challenge: { id: challenge.id, realm: challenge.realm, method: challenge.method, intent: challenge.intent, request: challenge.request, ...(challenge.expires && { expires: challenge.expires }), ...(challenge.description && { description: challenge.description }) },\n source: `did:pkh:eip155:${chainId}:${mpp.walletAddress}`,\n payload: { type: \"hash\", hash: receipt.transactionHash },\n })).replace(/\\+/g, \"-\").replace(/\\//g, \"_\").replace(/=+$/, \"\");\n\n console.log(`[paidFetch] Step 4: Retrying with payment credential...`);\n const finalRes = await fetchWithTimeout(url, { ...init, headers: { ...init?.headers, Authorization: `Payment ${credential}` } });\n console.log(`[paidFetch] Complete: ${finalRes.status} in ${Date.now() - t0}ms`);\n return finalRes;\n}\n",[],[163,181],[163],{"_106":192,"_99":193,"_164":194,"_166":-5,"_167":149,"_168":185,"_170":121,"_108":195,"_103":33,"_172":173,"_174":-5,"_175":22,"_176":-5,"_177":196,"_102":227},"8a0db4d4-279c-11f1-83b2-42dde27851f2","routes","8a0db592-279c-11f1-83b2-42dde27851f2",["D",1774368870965],[197,208,217],{"_106":198,"_99":199,"_164":200,"_166":194,"_167":149,"_168":201,"_170":121,"_108":202,"_103":203,"_172":204,"_174":205,"_175":22,"_176":-5,"_177":206,"_102":207},"919b0a96-27a4-11f1-82e9-42dde27851f2","App.tsx","90a2fae8-279c-11f1-9157-42dde27851f2",14,["D",1774372319602],2,"file","/** @jsxImportSource https://esm.town/v/stevekrouse/vtrr */\nimport { React, Outlet } from \"https://esm.town/v/stevekrouse/vtrr/mod.ts\";\n\nconst h = React.createElement;\n\nexport default function App() {\n return h(\"div\", { className: \"min-h-screen bg-gray-50\" },\n h(\"header\", { className: \"bg-white border-b border-gray-200 px-4 py-3\" },\n h(\"h1\", { className: \"text-xl font-bold text-gray-800\" }, \"Chat Agent\"),\n h(\"p\", { className: \"text-sm text-gray-500\" }, \"Powered by Claude + AI SDK v5\")\n ),\n h(\"main\", { className: \"max-w-2xl mx-auto p-4\" },\n h(Outlet, null)\n )\n );\n}\n",[],[193,199],{"_106":209,"_99":210,"_164":211,"_166":194,"_167":149,"_168":212,"_170":121,"_108":213,"_103":33,"_172":204,"_174":214,"_175":22,"_176":-5,"_177":215,"_102":216},"9824300c-279c-11f1-9960-42dde27851f2","Home.loader.ts","982430e8-279c-11f1-9960-42dde27851f2",6,["D",1774368894602],"export function loader() {\n return {};\n}\n",[],[193,210],{"_106":218,"_99":219,"_164":220,"_166":194,"_167":149,"_168":221,"_170":121,"_108":222,"_103":223,"_172":204,"_174":224,"_175":22,"_176":-5,"_177":225,"_102":226},"5795a5a6-27f2-11f1-8457-42dde27851f2","Home.tsx","97c11e5e-279c-11f1-8a54-42dde27851f2",28,["D",1774405722966],7,"/** @jsxImportSource https://esm.town/v/stevekrouse/vtrr */\nimport { React, useState, useRef, useEffect } from \"https://esm.town/v/stevekrouse/vtrr/mod.ts\";\n\nconst h = React.createElement;\n\nexport default function Home() {\n const [messages, setMessages] = useState([]);\n const [input, setInput] = useState(\"\");\n const [isLoading, setIsLoading] = useState(false);\n const scrollRef = useRef(null);\n\n // Auto-scroll to bottom when messages change\n useEffect(function () {\n if (scrollRef.current) {\n scrollRef.current.scrollTop = scrollRef.current.scrollHeight;\n }\n }, [messages]);\n\n async function handleSubmit(e) {\n e.preventDefault();\n if (!input.trim() || isLoading) return;\n\n const userMsg = {\n id: crypto.randomUUID(),\n role: \"user\",\n content: input,\n parts: [{ type: \"text\", text: input }],\n };\n const newMessages = [...messages, userMsg];\n setMessages(newMessages);\n setInput(\"\");\n setIsLoading(true);\n\n try {\n const uiMessages = newMessages.map(function (m) {\n return {\n id: m.id,\n role: m.role,\n parts: m.parts.map(function (p) {\n if (p.type === \"text\") return { type: \"text\", text: p.text };\n if (p.type === \"tool-invocation\" && p.toolInvocation) {\n return {\n type: \"tool-invocation\",\n toolInvocation: {\n toolName: p.toolInvocation.toolName,\n toolCallId: p.toolInvocation.toolCallId,\n args: p.toolInvocation.args,\n state: p.toolInvocation.state,\n result: p.toolInvocation.result,\n },\n };\n }\n return p;\n }),\n };\n });\n\n var res = await fetch(\"/api/chat\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ messages: uiMessages }),\n });\n\n if (!res.ok) {\n console.error(\"Chat API error:\", res.status, await res.text());\n return;\n }\n\n var reader = res.body?.getReader();\n var decoder = new TextDecoder();\n if (!reader) return;\n\n var assistantParts = [];\n var assistantId = crypto.randomUUID();\n var buffer = \"\";\n var streamDone = false;\n\n function updateMessages() {\n var content = assistantParts\n .filter(function (p) { return p.type === \"text\"; })\n .map(function (p) { return p.text || \"\"; })\n .join(\"\");\n\n setMessages([\n ...newMessages,\n {\n id: assistantId,\n role: \"assistant\",\n content: content,\n parts: assistantParts.map(function (p) {\n if (p.type === \"tool-invocation\" && p.toolInvocation) {\n return {\n type: p.type,\n toolInvocation: Object.assign({}, p.toolInvocation),\n };\n }\n return Object.assign({}, p);\n }),\n },\n ]);\n }\n\n while (true) {\n var result = await reader.read();\n if (result.done) break;\n\n buffer += decoder.decode(result.value, { stream: true });\n var lines = buffer.split(\"\\n\");\n buffer = lines.pop() || \"\";\n\n for (var li = 0; li < lines.length; li++) {\n var line = lines[li].trim();\n if (!line) continue;\n\n // SSE format: \"data: {...}\" or \"data: [DONE]\"\n if (!line.startsWith(\"data: \")) continue;\n var payload = line.slice(6);\n if (payload === \"[DONE]\") {\n streamDone = true;\n continue;\n }\n\n try {\n var event = JSON.parse(payload);\n\n // Handle message start (new in v5/v6 protocol)\n if (event.type === \"start\") {\n if (event.messageId) {\n assistantId = event.messageId;\n }\n }\n // Handle step boundaries (multi-step agent loops)\n else if (event.type === \"start-step\" || event.type === \"finish-step\") {\n // These are informational; we keep accumulating parts\n // into the same assistant message, which is the correct\n // behavior for multi-step tool-calling agents\n }\n // Handle finish message\n else if (event.type === \"finish\") {\n // Message is complete\n }\n // Text streaming\n else if (event.type === \"text-delta\") {\n var lastPart = assistantParts[assistantParts.length - 1];\n if (lastPart && lastPart.type === \"text\") {\n lastPart.text = (lastPart.text || \"\") + event.delta;\n } else {\n assistantParts.push({ type: \"text\", text: event.delta });\n }\n updateMessages();\n } else if (event.type === \"text-start\") {\n assistantParts.push({ type: \"text\", text: \"\" });\n } else if (event.type === \"text-end\") {\n // Text block complete, no action needed\n }\n // Tool call streaming\n else if (event.type === \"tool-input-start\") {\n assistantParts.push({\n type: \"tool-invocation\",\n toolInvocation: {\n toolName: event.toolName,\n toolCallId: event.toolCallId,\n args: {},\n state: \"partial-call\",\n },\n });\n updateMessages();\n } else if (event.type === \"tool-input-delta\") {\n // Streaming tool input text; we wait for tool-input-available\n // for the full parsed args. Update display to show streaming.\n for (var i = assistantParts.length - 1; i >= 0; i--) {\n if (\n assistantParts[i].type === \"tool-invocation\" &&\n assistantParts[i].toolInvocation &&\n assistantParts[i].toolInvocation.toolCallId === event.toolCallId\n ) {\n // Accumulate raw input text for display\n if (!assistantParts[i].toolInvocation._inputText) {\n assistantParts[i].toolInvocation._inputText = \"\";\n }\n assistantParts[i].toolInvocation._inputText += (event.inputTextDelta || \"\");\n break;\n }\n }\n updateMessages();\n } else if (event.type === \"tool-input-available\") {\n for (var i = assistantParts.length - 1; i >= 0; i--) {\n if (\n assistantParts[i].type === \"tool-invocation\" &&\n assistantParts[i].toolInvocation &&\n assistantParts[i].toolInvocation.toolCallId === event.toolCallId\n ) {\n assistantParts[i].toolInvocation.args = event.input;\n assistantParts[i].toolInvocation.state = \"call\";\n break;\n }\n }\n updateMessages();\n } else if (event.type === \"tool-output-available\") {\n for (var i = assistantParts.length - 1; i >= 0; i--) {\n if (\n assistantParts[i].type === \"tool-invocation\" &&\n assistantParts[i].toolInvocation &&\n assistantParts[i].toolInvocation.toolCallId === event.toolCallId\n ) {\n assistantParts[i].toolInvocation.result = event.output;\n assistantParts[i].toolInvocation.state = \"result\";\n break;\n }\n }\n updateMessages();\n }\n // Error handling\n else if (event.type === \"error\") {\n assistantParts.push({ type: \"text\", text: \"\\n\\n⚠️ Error: \" + (event.errorText || \"Unknown error\") });\n updateMessages();\n }\n } catch (parseErr) {\n // Not valid JSON, skip\n }\n }\n\n // When the server sends [DONE], stop reading — the underlying\n // connection may not close promptly (Val Town proxy keep-alive),\n // so we must not wait for reader.read() to return {done:true}.\n if (streamDone) {\n reader.cancel();\n break;\n }\n }\n } catch (err) {\n console.error(\"Chat error:\", err);\n } finally {\n setIsLoading(false);\n }\n }\n\n function renderPart(part, i) {\n if (part.type === \"text\") {\n return h(\"p\", { key: i, className: \"whitespace-pre-wrap\" }, part.text);\n }\n if (part.type === \"tool-invocation\" && part.toolInvocation) {\n var inv = part.toolInvocation;\n var isRunning = inv.state === \"call\";\n var isPartial = inv.state === \"partial-call\";\n var hasResult = inv.state === \"result\";\n\n return h(\"div\", {\n key: i,\n className: \"text-xs bg-gray-100 text-gray-600 rounded p-2 my-1\"\n },\n h(\"div\", { className: \"flex items-center gap-2\" },\n h(\"span\", { className: \"font-semibold\" }, \"Tool: \" + inv.toolName),\n isRunning\n ? h(\"span\", { className: \"inline-flex items-center text-amber-600\" },\n h(\"span\", { className: \"animate-spin mr-1\", style: { display: \"inline-block\" } }, \"⏳\"),\n \"Running...\"\n )\n : null,\n isPartial\n ? h(\"span\", { className: \"text-gray-400\" }, \"Preparing...\")\n : null\n ),\n h(\"div\", null, \"Input: \" + JSON.stringify(inv.args)),\n hasResult\n ? h(\"details\", { className: \"mt-1\" },\n h(\"summary\", { className: \"cursor-pointer text-blue-600\" }, \"Result\"),\n h(\"pre\", { className: \"mt-1 max-h-48 overflow-y-auto text-[10px]\" },\n JSON.stringify(inv.result, null, 2)\n )\n )\n : null\n );\n }\n return null;\n }\n\n function renderMessage(msg) {\n var isUser = msg.role === \"user\";\n return h(\"div\", { key: msg.id, className: \"flex \" + (isUser ? \"justify-end\" : \"justify-start\") },\n h(\"div\", {\n className: \"max-w-[80%] rounded-lg px-4 py-2 \" + (isUser\n ? \"bg-blue-600 text-white\"\n : \"bg-white border border-gray-200 text-gray-800\")\n },\n msg.parts ? msg.parts.map(renderPart) : h(\"p\", { className: \"whitespace-pre-wrap\" }, msg.content)\n )\n );\n }\n\n // Show thinking if we're loading and either no assistant message yet,\n // or the assistant message has no parts yet\n var lastMsg = messages.length > 0 ? messages[messages.length - 1] : null;\n var showThinking = isLoading && (!lastMsg || lastMsg.role === \"user\");\n\n return h(\"div\", { className: \"flex flex-col h-[calc(100vh-100px)]\" },\n h(\"div\", { ref: scrollRef, className: \"flex-1 overflow-y-auto space-y-4 pb-4\" },\n messages.length === 0\n ? h(\"div\", { className: \"text-center text-gray-400 mt-20\" },\n h(\"p\", { className: \"text-lg\" }, \"Send a message to start chatting.\"),\n h(\"p\", { className: \"text-sm mt-2\" }, \"Try asking me to find contact info, enrich companies, or search the web!\")\n )\n : null,\n messages.map(renderMessage),\n showThinking\n ? h(\"div\", { className: \"flex justify-start\" },\n h(\"div\", { className: \"bg-white border border-gray-200 rounded-lg px-4 py-2 text-gray-400\" }, \"Thinking...\")\n )\n : null\n ),\n h(\"form\", { onSubmit: handleSubmit, className: \"flex gap-2 pt-2 border-t border-gray-200\" },\n h(\"input\", {\n type: \"text\",\n value: input,\n onChange: function (e) { setInput(e.target.value); },\n placeholder: \"Type a message... (try: find the CEO of Klarna)\",\n className: \"flex-1 border border-gray-300 rounded-lg px-4 py-2 focus:outline-none focus:ring-2 focus:ring-blue-500\",\n disabled: isLoading,\n }),\n h(\"button\", {\n type: \"submit\",\n disabled: isLoading || !input.trim(),\n className: \"bg-blue-600 text-white px-6 py-2 rounded-lg hover:bg-blue-700 disabled:opacity-50\",\n }, \"Send\")\n )\n );\n}\n",[],[193,219],[193],{"_106":229,"_99":230,"_164":119,"_166":-5,"_167":149,"_168":148,"_170":121,"_108":231,"_103":232,"_172":233,"_174":234,"_175":22,"_176":-5,"_177":235,"_102":236},"341ab62e-27f3-11f1-8ac8-42dde27851f2","index.tsx",["D",1774406092974],13,"http","/** @jsxImportSource https://esm.town/v/stevekrouse/vtrr */\nimport { createApp } from \"https://esm.town/v/stevekrouse/vtrr/server.ts\";\nimport { streamText, UIMessage, convertToModelMessages, tool, stepCountIs, jsonSchema } from \"npm:ai@5\";\nimport { createAnthropic } from \"npm:@ai-sdk/anthropic@2\";\nimport { routes } from \"./routes.ts\";\nimport { createMppClient, paidFetch } from \"./lib/mpp.ts\";\n\nconst anthropic = createAnthropic({ apiKey: Deno.env.get(\"ANTHROPIC_API_KEY\") });\nconst mpp = createMppClient(\n Deno.env.get(\"TEMPO_ACCESS_KEY\") as `0x${string}`,\n Deno.env.get(\"TEMPO_WALLET_ADDRESS\") as `0x${string}`,\n);\n\nconst SERVICES: Record = {\n stableenrich: { url: \"https://stableenrich.dev\", docs: \"https://stableenrich.dev/llms.txt\", description: \"Aggregator: Apollo, Exa, Firecrawl, Google Maps, Clado, Hunter, Whitepages, Reddit, Influencer, Cloudflare\" },\n apollo: { url: \"https://apollo.mpp.paywithlocus.com\", docs: \"https://paywithlocus.com/mpp/apollo.md\", description: \"People/company enrichment, 275M+ contacts\" },\n hunter: { url: \"https://hunter.mpp.paywithlocus.com\", docs: \"https://paywithlocus.com/mpp/hunter.md\", description: \"Email finding, verification, enrichment\" },\n clado: { url: \"https://clado.mpp.paywithlocus.com\", docs: \"https://paywithlocus.com/mpp/clado.md\", description: \"LinkedIn enrichment, contact search, deep research\" },\n \"diffbot-kg\": { url: \"https://diffbot-kg.mpp.paywithlocus.com\", docs: \"https://paywithlocus.com/mpp/diffbot-kg.md\", description: \"Knowledge graph, 10B+ entities\" },\n browserbase: { url: \"https://mpp.browserbase.com\", docs: \"https://docs.browserbase.com/llms.txt\", description: \"Headless browser, web search, page fetching\" },\n};\n\nconst SYSTEM = `You are an AI agent with access to paid API services via MPP (Machine Payment Protocol) on Tempo.\n\nAvailable services:\n${Object.entries(SERVICES).map(([k, v]) => `- ${k} (${v.url}): ${v.description}`).join(\"\\n\")}\n\nWorkflow:\n1. Use search_services to find the right endpoint and learn its exact URL, method, parameters, and pricing\n2. Use call_service to make the paid request\n3. If results are sparse, try another service\n\nEach API call costs real USDC. Tell the user what you're calling and the approximate cost before making expensive calls.`;\n\nexport default createApp({\n routes,\n routesFile: \"./routes.ts\",\n head: ``,\n setup: (app) => {\n app.post(\"/api/chat\", async (c) => {\n const { messages }: { messages: UIMessage[] } = await c.req.json();\n console.log(`[chat] Starting with ${messages.length} messages`);\n const result = streamText({\n model: anthropic(\"claude-sonnet-4-20250514\"),\n system: SYSTEM,\n messages: await convertToModelMessages(messages),\n onError: ({ error }) => {\n console.error(`[streamText] onError:`, error);\n },\n onFinish: ({ text, toolCalls, toolResults, finishReason, usage, steps }) => {\n console.log(`[streamText] onFinish: finishReason=${finishReason}, steps=${steps?.length}, text=${text?.slice(0, 100)}, usage=${JSON.stringify(usage)}`);\n },\n onStepFinish: ({ stepType, toolCalls, toolResults, finishReason, usage }) => {\n console.log(`[streamText] Step finished: type=${stepType}, finishReason=${finishReason}, toolCalls=${toolCalls?.length || 0}, usage=${JSON.stringify(usage)}`);\n if (toolCalls?.length) {\n for (const tc of toolCalls) {\n console.log(`[streamText] toolCall: ${tc.toolName}(${JSON.stringify(tc.args).slice(0, 100)})`);\n }\n }\n if (toolResults?.length) {\n for (const tr of toolResults) {\n console.log(`[streamText] toolResult: ${tr.toolName} => ${JSON.stringify(tr.result).slice(0, 100)}`);\n }\n }\n },\n tools: {\n search_services: tool({\n description: \"Fetch documentation for an MPP service to find endpoints, parameters, and pricing. Returns the full docs for the service so you can find the right endpoint.\",\n inputSchema: jsonSchema({\n type: \"object\",\n properties: {\n service: { type: \"string\", enum: Object.keys(SERVICES), description: \"Which service to look up docs for\" },\n query: { type: \"string\", description: \"Optional: keyword to filter docs (e.g. 'people enrich', 'email', 'search')\" },\n },\n required: [\"service\"],\n }),\n execute: async ({ service, query }: { service: string; query?: string }) => {\n console.log(`[search_services] service=${service}, query=${query}`);\n const svc = SERVICES[service];\n if (!svc) return { error: `Unknown service: ${service}`, available: Object.keys(SERVICES) };\n try {\n const res = await fetch(svc.docs);\n const text = await res.text();\n console.log(`[search_services] Fetched ${text.length} bytes from ${svc.docs}`);\n if (!query) return { service, baseUrl: svc.url, docs: text.slice(0, 4000) };\n // Return sections that match the query with surrounding context\n const lines = text.split(\"\\n\");\n const matches: string[] = [];\n const q = query.toLowerCase();\n for (let i = 0; i < lines.length; i++) {\n if (lines[i].toLowerCase().includes(q)) {\n const start = Math.max(0, i - 2);\n const end = Math.min(lines.length, i + 15);\n matches.push(lines.slice(start, end).join(\"\\n\"));\n matches.push(\"---\");\n }\n }\n const result = matches.length > 0 ? matches.join(\"\\n\").slice(0, 4000) : text.slice(0, 4000);\n console.log(`[search_services] Returning ${result.length} chars for query=\"${query}\"`);\n return { service, baseUrl: svc.url, docs: result };\n } catch (e) {\n console.error(`[search_services] Error:`, e);\n return { error: `Failed to fetch docs: ${e}` };\n }\n },\n }),\n call_service: tool({\n description: \"Make a paid API request to an MPP service endpoint. Costs real USDC. Use search_services first to find the right endpoint and parameters.\",\n inputSchema: jsonSchema({\n type: \"object\",\n properties: {\n url: { type: \"string\", description: \"Full URL, e.g. https://stableenrich.dev/api/apollo/people-enrich\" },\n method: { type: \"string\", enum: [\"GET\", \"POST\"], description: \"HTTP method (default: POST)\" },\n body: { type: \"object\", description: \"JSON body for POST requests\" },\n },\n required: [\"url\"],\n }),\n execute: async ({ url, method, body }: { url: string; method?: string; body?: any }) => {\n console.log(`[call_service] ${method || \"POST\"} ${url}`, body ? JSON.stringify(body).slice(0, 200) : \"\");\n try {\n const init: RequestInit = { method: method || \"POST\", headers: { \"Content-Type\": \"application/json\" } };\n if (body) init.body = JSON.stringify(body);\n const start = Date.now();\n\n // Wrap paidFetch in a 60s timeout to prevent indefinite hangs\n const timeoutMs = 60_000;\n const res = await Promise.race([\n paidFetch(mpp, url, init),\n new Promise((_, reject) =>\n setTimeout(() => reject(new Error(`paidFetch timed out after ${timeoutMs / 1000}s`)), timeoutMs)\n ),\n ]);\n\n const elapsed = Date.now() - start;\n console.log(`[call_service] Response: ${res.status} in ${elapsed}ms`);\n const text = await res.text();\n console.log(`[call_service] Body: ${text.slice(0, 300)}`);\n try {\n const data = JSON.parse(text);\n return { status: res.status, data };\n } catch {\n // Not JSON — return raw text (truncated)\n console.log(`[call_service] Non-JSON response`);\n return { status: res.status, data: text.slice(0, 2000) };\n }\n } catch (e) {\n console.error(`[call_service] Error:`, e);\n return { error: `Request failed: ${e instanceof Error ? e.message : e}` };\n }\n },\n }),\n },\n stopWhen: stepCountIs(10),\n });\n\n // Wrap the stream response to log every SSE event\n const originalResponse = result.toUIMessageStreamResponse();\n const originalBody = originalResponse.body;\n if (!originalBody) {\n console.error(`[chat] No response body!`);\n return originalResponse;\n }\n\n let eventCount = 0;\n const loggingStream = new TransformStream({\n transform(chunk, controller) {\n // Decode chunk to see what SSE events are being sent\n const text = new TextDecoder().decode(chunk);\n const lines = text.split(\"\\n\").filter((l: string) => l.startsWith(\"data: \"));\n for (const line of lines) {\n eventCount++;\n const payload = line.slice(6);\n if (payload === \"[DONE]\") {\n console.log(`[sse #${eventCount}] [DONE]`);\n } else {\n try {\n const evt = JSON.parse(payload);\n // Log event type and key fields, truncated\n const summary = evt.type === \"text-delta\"\n ? `text-delta: \"${(evt.delta || \"\").slice(0, 40)}\"`\n : evt.type === \"tool-input-delta\"\n ? `tool-input-delta: ${evt.toolCallId?.slice(0, 12)}...`\n : evt.type === \"tool-input-available\"\n ? `tool-input-available: ${evt.toolName}(${JSON.stringify(evt.input).slice(0, 80)})`\n : evt.type === \"tool-output-available\"\n ? `tool-output-available: ${evt.toolCallId?.slice(0, 12)}... ${JSON.stringify(evt.output).slice(0, 80)}`\n : evt.type === \"tool-input-start\"\n ? `tool-input-start: ${evt.toolName} (${evt.toolCallId})`\n : `${evt.type}: ${JSON.stringify(evt).slice(0, 100)}`;\n console.log(`[sse #${eventCount}] ${summary}`);\n } catch {\n console.log(`[sse #${eventCount}] (unparseable): ${payload.slice(0, 80)}`);\n }\n }\n }\n controller.enqueue(chunk);\n },\n flush() {\n console.log(`[sse] Stream ended. Total events: ${eventCount}`);\n },\n });\n\n const loggedBody = originalBody.pipeThrough(loggingStream);\n console.log(`[chat] Returning logged SSE stream response`);\n return new Response(loggedBody, {\n headers: originalResponse.headers,\n status: originalResponse.status,\n });\n });\n },\n});\n",[],[230],{"_106":238,"_99":239,"_164":240,"_166":-5,"_167":149,"_168":232,"_170":121,"_108":241,"_103":203,"_172":204,"_174":242,"_175":22,"_176":-5,"_177":243,"_102":244},"edb7e08e-27a3-11f1-bf82-42dde27851f2","routes.ts","89cf46c2-279c-11f1-83b2-42dde27851f2",["D",1774372044648],"/** @jsxImportSource https://esm.town/v/stevekrouse/vtrr */\nimport { defineRoutes } from \"https://esm.town/v/stevekrouse/vtrr/mod.ts\";\nimport App from \"./routes/App.tsx\";\nimport Home from \"./routes/Home.tsx\";\n\nexport const routes = defineRoutes([\n {\n path: \"/\",\n Component: App,\n children: [\n {\n index: true,\n Component: Home,\n loader: \"./routes/Home.loader.ts\",\n },\n ],\n },\n]);\n",[],[239],"files",[161,179,191,197,208,217,228,237],"counts",{"_249":33,"_250":251,"_252":33,"_253":254,"_257":258},"pulls","branches",1,"forks","envVars",{"_255":185,"_256":33},"count","emptyCount","connections",{"_255":33,"_259":33},"unfilledCount","contents",[262,265,268,271],{"_106":162,"_99":163,"_164":165,"_166":-5,"_167":149,"_168":169,"_170":121,"_108":263,"_103":33,"_172":173,"_174":-5,"_175":22,"_176":-5,"_102":264},["D",1774384577811],[163],{"_106":192,"_99":193,"_164":194,"_166":-5,"_167":149,"_168":185,"_170":121,"_108":266,"_103":33,"_172":173,"_174":-5,"_175":22,"_176":-5,"_102":267},["D",1774368870965],[193],{"_106":229,"_99":230,"_164":119,"_166":-5,"_167":149,"_168":148,"_170":121,"_108":269,"_103":232,"_172":233,"_174":234,"_175":22,"_176":-5,"_102":270},["D",1774406092974],[230],{"_106":238,"_99":239,"_164":240,"_166":-5,"_167":149,"_168":232,"_170":121,"_108":272,"_103":203,"_172":204,"_174":242,"_175":22,"_176":-5,"_102":273},["D",1774372044648],[239],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.environment-variables",{"_97":98,"_99":100,"_104":282,"_253":287,"_303":22},{"_106":107,"_99":100,"_108":283,"_110":-5,"_111":22,"_112":113,"_114":115,"_116":-5,"_14":117,"_118":119,"_120":121,"_122":-5,"_123":-5,"_124":33,"_16":125,"_126":-5,"_127":-5,"_128":-5,"_129":130,"_131":130,"_132":133,"_134":133,"_135":133,"_136":130,"_137":130,"_23":284,"_141":285,"_146":286,"_158":22},["D",1774368864292],{"_97":98,"_139":140},{"_97":98,"_143":140,"_14":117,"_144":145},{"_103":148,"_99":45,"_106":149,"_150":107,"_151":-5,"_152":-5,"_153":-5,"_154":-5,"_155":-5,"_156":100,"_157":98},[288,295,299],{"_289":290,"_108":291,"_292":-5,"_114":293,"_294":22},"key","TEMPO_WALLET_ADDRESS",["D",1774384566497],"updatedAt","Tempo wallet address (parent wallet for access key)","isEmpty",{"_289":296,"_108":297,"_292":-5,"_114":298,"_294":22},"TEMPO_ACCESS_KEY",["D",1774384564493],"Tempo access key for signing MPP payments",{"_289":300,"_108":301,"_292":-5,"_114":302,"_294":22},"ANTHROPIC_API_KEY",["D",1774368876244],"Anthropic API key for Claude chat","isTeamOrg","actionData","errors"]

stevekrouse

agent-mpp-v5

Environment variables