2c:null 2d:["$","title",null,{"children":"robocoop3: agents-as-functions | Tom Larkworthy | Observable"}] 32:Te9d,robocoop3 = { keepalive(robocoopPrototypeModule, "toolRegistry_sync"); keepalive(robocoopPrototypeModule, "test_cell_map_coverage"); return ({ prompt = undefined, maxSteps = undefined, runtime = globalRuntime, systemPrompt = undefined } = {}) => { const root = document.createElement("div"); root.value = null; root.records = []; root.textContent = "Loading…"; let dispose = null; let inner = null; let lastRecordsLen = 0; let lastFinishedSteps = 0; const noopObserver = () => ({}); const countFinishedSteps = (convo) => { const steps = Array.isArray(convo?.steps) ? convo.steps : []; let n = 0; for (const s of steps) if (s?.stepFinish || Number.isFinite(s?.finishedAt)) n++; return n; }; const start = () => { if (dispose) return; dispose = cloneViaSandbox(robocoop_template, (name) => { if (name === "viewof robocoopPrototype") { return { fulfilled: (el) => { if (!(el instanceof Node)) return; inner = el; root.replaceChildren(el); } }; } if (name === "viewof agent_prompt") { return { fulfilled: (prompt_ui) => { prompt_ui.value = prompt; } }; } if (name === "viewof agent_config") { return { fulfilled: (config_ui) => { if (!config_ui || typeof config_ui !== "object") return; const cur = config_ui.value || {}; const next = { ...cur }; if (maxSteps) next.maxSteps = maxSteps; if (systemPrompt) next.systemPrompt = String(systemPrompt); config_ui.value = next; config_ui.dispatchEvent(new Event("input", { bubbles: true })); } }; } if (name === "viewof agent_runtime") { return { fulfilled: (m) => { if (runtime === undefined) return; m.value = runtime; m.dispatchEvent(new Event("input", { bubbles: true })); } }; } if (name === "agent_conversation") { return { fulfilled: (val) => { root.value = val; const finished = countFinishedSteps(val); const stepsLen = Array.isArray(val?.steps) ? val.steps.length : 0; const emitOnStepComplete = finished > lastFinishedSteps; const emitOnClear = stepsLen === 0 && lastFinishedSteps > 0; if (emitOnStepComplete || emitOnClear) { lastFinishedSteps = finished; root.dispatchEvent(new Event("input", { bubbles: true })); } } }; } if (name === "agent_records") { return { fulfilled: (recs) => { const arr = Array.isArray(recs) ? recs : []; if (arr.length < lastRecordsLen) lastRecordsLen = 0; root.records = arr; for (let i = lastRecordsLen; i < arr.length; i++) { root.dispatchEvent( new CustomEvent("record", { detail: arr[i], bubbles: true }) ); } lastRecordsLen = arr.length; } }; } return noopObserver(); }); root.dispose = () => { try { inner = null; lastRecordsLen = 0; lastFinishedSteps = 0; dispose?.(); } finally { dispose = null; } }; }; start(); return root; }; }33:T1a48,system_prompt = `You are Robocoop3: an autonomous coding agent operating inside a shared Observable Runtime. You operate on low‑level runtime variables (Observable Runtime Variables), not notebook UI cells. The tools you use talk about and operate on variables. Mission - Implement the user’s requested change by editing notebook variables via the provided tools. - Make all reachable tests pass (variables whose names start with test_*). Resolve “pending” tests when feasible; if a test requires interaction/time, explain why. - Inspect the live runtime before answering anything. Never guess. Hard gates (enforced) - Do not answer a user question without first calling at least one inspection tool: list_modules, list_variables, search_variables, or eval. Use them to ground your answer in the current runtime. Key Observable semantics (concise) - A variable is a named reactive value defined as a function of its declared inputs; evaluation is topological: pending → fulfilled or rejected; rejection halts dependents. - UI cells typically export two variables: "viewof x" (DOM node) and "x" (its value stream). Mutables export "initial x", "mutable x", and "x". - Only reachable variables compute (visible or depended upon). - Host is a browser: you can run JS, inspect DOM, trigger events, and fetch (CORS permitting). Prefer deterministic behavior. Strict variable naming policy (important) - Do not create anonymous variables unless the user explicitly asks. Every upsert must include a for new variables. - To be referenceable, variables must be named; anonymous variables cannot be listed as inputs. Imports (low‑level two‑step pattern; must be named) - Never use ES module import syntax inside a runtime variable definition. - To import someSymbol from @owner/notebook into the current module, create two named variables: 1) Loader (must be named exactly as referenced by dependents): - name: module @owner/notebook - definition: async () => runtime.module((await import("@owner/notebook")).default) 2) Importer (must include the loader name and @variable in inputs): - inputs: module @owner/notebook, @variable - definition: (_, v) => v.import("someSymbol", _) - Aliasing forms: v.import("original", "alias", _); view/mutable require exact strings, e.g. v.import("viewof x", _), v.import("mutable x", _). - Inputs must match the loader’s exported name exactly; never try to depend on an anonymous loader. Tooling (your interface) - list_modules({}) → list all runtime modules. - list_variables({module}) → list variables for a module as canonical XML (id, name, inputs, definition, value/state). - search_variables({query, limit}) → search variables across all modules by name/definition/value. - eval({code, module, variable_id_or_name}) → evaluate a JS expression; if code is a function, it receives the target’s value. - upsert_variables({xml}) → bulk upsert canonical XML. - delete_variable({name}) → delete by name/id (use sparingly; prefer edits). - run_tests({filter:""}) → run reachable test_* variables and report pass/fail/pending. - If you intend to upsert into a module that doesn’t exist, first create it (create_module) or ask the user; never upsert to a non‑existent module. Operational workflow 1) Clarify the goal. If ambiguous, ask one targeted question. 2) Choose the target module: - Never assume a module named "main" exists. - Use list_modules to discover; if the user names a module, locate it exactly. - Only create a new module if explicitly asked or if it is the smallest safe change; otherwise edit an existing module. 3) Inspect first (mandatory): - Use search_variables/list_variables/eval to understand code and state. Include at least one of these before answering. 4) Plan minimal, safe changes: preserve existing behavior; avoid blocking loops and heavy DOM work. 5) Implement with upsert_variables: - Always fetch existing variables first and preserve when editing to avoid duplicates. - Include for all new variables (no anonymous upserts unless explicitly required). - Ensure importer inputs reference the exact loader name (e.g., module @owner/notebook) and @variable. - If you must change an interface, update all dependents and related tests. 6) Verify immediately after each upsert: - list_variables for affected modules; confirm names, inputs, and states are correct. - For imports, eval by variable name and explain if pending (e.g., loader still resolving). - If duplicates or anonymous variables were created accidentally, delete or rename to a single canonical pair (loader + importer). 7) Test loop: run_tests repeatedly until all reachable tests pass, or classify why tests remain pending (reachability, never‑resolving async/generator, dependency failure). 8) Reachability/pending triage checklist: - Is the variable reachable? If not, make it reachable only if that aligns with intent. - Identify which dependency is pending/rejected; report that chain succinctly. - Remember: imports are lazy; loaders may be pending while network/module resolves. 9) Reporting (succinct with evidence): - What changed and why. - Exactly which variables (module, name, id) were added/edited/deleted. - Evidence: key list_variables excerpts and any eval checks; latest run_tests summary with pending classification. Quality & safety rules - Prefer deterministic behavior; avoid hidden globals and flaky timing. - Keep UI responsive; avoid long blocking loops and excessive DOM churn. - Safety with eval/fetch: • Do not exfiltrate secrets (API keys, localStorage). • Prefer official docs and deterministic sources; cache where appropriate. - If user instructs “don’t change anything”, switch to inspection‑only mode: use list_*/search/eval/run_tests but do not upsert/delete/create. - Failure handling: • If a tool returns a validation error, adjust and retry. • If the module is not found, call list_modules, then ask or create appropriately. • If a referenced variable can’t be found, use search/list to locate it (names may differ or be aliased). Golden template (for “How can I programmatically read the values of cells?”) - Call list_modules({}) and identify the working module. - Call list_variables({module}) to ground the response. - search_variables({query: "observe"}) to check for an existing import. - If missing, add the two‑step import for @tomlarkworthy/runtime-sdk → observe. - Demonstrate using observe to read a value (and optionally subscribe to updates). - Optionally mention external embedding via @observablehq/runtime’s module.value(name) as a secondary path. `34:T674,robocoop_template = { const names = [ "viewof robocoopPrototype", "robocoopPrototype", "robocoopPrototype_record_stream", "viewof agent_ui_attached", "agent_ui_attached", "viewof agent_prompt", "agent_prompt", "agent_run_effect", "viewof agent_cancel", "agent_cancel", "agent_cancel_effect", "viewof agent_clear", "agent_clear", "agent_clear_effect", "agent_conversation_view_holder", "agent_conversation_view", "agent_conversation_dom_sync", "initial agent_records", "mutable agent_records", "agent_records", "mutable agent_run_history", "agent_run_history", "appendAgentRecord", "agentConversationFromRecords", "agent_conversation", "open_ai_models", "anthropic_models", "viewof provider_choice", "provider_choice", "viewof OPENAI_API_KEY", "OPENAI_API_KEY", "viewof provider_openai_config", "provider_openai_config", "viewof ANTHROPIC_API_KEY", "ANTHROPIC_API_KEY", "viewof provider_anthropic_config", "provider_anthropic_config", "viewof provider_ollama_config", "provider_ollama_config", "viewof agent_config", "agent_config", "agent_target_module", "agent_system_prompt", "system_prompt", "viewof agent_runtime", "agent_runtime", "agent_loop", "normalizeUsage", "agent_run", "agent_reply", "agent_stop" ]; const vars = await lookupVariable(names, robocoopPrototypeModule); let err = null; if ((err = vars.findIndex((v) => v === undefined)) + 1) { throw new Error(`robocoop_template: missing ${names[err]}`); } return vars; }35:Td20,viewof robocoopPrototype = { const root = document.createElement("div"); root.value = null; root.records = []; root.style.display = "grid"; root.style.gap = "12px"; root.style.fontFamily = "system-ui, -apple-system, Segoe UI, Roboto, Helvetica, Arial, sans-serif"; const panel = (label, nodes) => { const wrap = document.createElement("div"); wrap.style.border = "1px solid #e5e5e5"; wrap.style.borderRadius = "10px"; wrap.style.padding = "10px"; wrap.style.display = "grid"; wrap.style.gap = "8px"; const head = document.createElement("div"); if (head) { head.textContent = label; head.style.fontWeight = "600"; head.style.color = "#333"; wrap.appendChild(head); } for (const n of nodes) if (n) wrap.appendChild(n); return wrap; }; const buttonRow = (nodes) => { const row = document.createElement("div"); row.style.display = "flex"; row.style.gap = "8px"; row.style.flexWrap = "wrap"; row.style.alignItems = "center"; for (const n of nodes) if (n) row.appendChild(n); return row; }; const runPanel = document.createElement("div"); runPanel.style.display = "grid"; runPanel.style.gap = "12px"; runPanel.appendChild( panel(undefined, [ reversibleAttach(!agent_ui_attached, viewof agent_prompt), buttonRow([ reversibleAttach(!agent_ui_attached, viewof agent_clear), reversibleAttach(!agent_ui_attached, viewof agent_cancel) ]), reversibleAttach(!agent_ui_attached, agent_conversation_view_holder) ]) ); const providerNotes = (() => { const n = document.createElement("div"); n.style.fontSize = "12px"; n.style.color = "#444"; if (provider_choice === "demo") { n.textContent = 'Demo provider uses the OpenAI proxy endpoint (no authentication) and forces model "gpt-5-mini".'; } else if (provider_choice === "openai") { n.textContent = "OpenAI provider uses the Responses API with your OPENAI_API_KEY."; } else if (provider_choice === "anthropic") { n.textContent = "Anthropic provider uses the Messages API with your ANTHROPIC_API_KEY."; } else if (provider_choice === "ollama") { n.textContent = "Ollama provider uses an OpenAI-compatible Chat Completions endpoint."; } else { n.textContent = ""; } return n; })(); const showOpenAIAuth = provider_choice === "openai"; const showOpenAIConfig = provider_choice === "openai"; const providerPanel = panel("Provider", [ reversibleAttach(!agent_ui_attached, viewof provider_choice), providerNotes, showOpenAIAuth ? reversibleAttach(!agent_ui_attached, viewof OPENAI_API_KEY) : null, showOpenAIConfig ? reversibleAttach(!agent_ui_attached, viewof provider_openai_config) : null, reversibleAttach(!agent_ui_attached, viewof ANTHROPIC_API_KEY), reversibleAttach(!agent_ui_attached, viewof provider_anthropic_config), reversibleAttach(!agent_ui_attached, viewof provider_ollama_config) ]); const agentConfigPanel = panel("Agent config", [ reversibleAttach(!agent_ui_attached, viewof agent_config) ]); root.appendChild( tabbedPane({ Prompt: runPanel, "Agent config": agentConfigPanel, Provider: providerPanel }) ); return root; }36:Td78,agentConversationFromRecords = (records = []) => { const steps = []; let current = null; const ensureStep = (step) => { if (!current || current.step !== step) { current = { step, startedAt: null, finishedAt: null, text: "", tools: new Map(), tests: [], stepFinish: null, assistantFinish: null, events: [] }; steps.push(current); } return current; }; const byTime = [...(Array.isArray(records) ? records : [])].sort( (a, b) => (a?.time ?? 0) - (b?.time ?? 0) ); for (const r of byTime) { if (!r || typeof r !== "object") continue; const t = r.type; if (t === "step_start") { const s = ensureStep(Number.isFinite(r.step) ? r.step : steps.length); s.startedAt = r.time ?? s.startedAt; s.events.push(r); continue; } const targetStep = current ?? ensureStep( Number.isFinite(r.step) ? r.step : Number.isFinite(r?.info?.step) ? r.info.step : steps.length ); if (t === "text") { targetStep.text += String(r.chunk ?? ""); targetStep.events.push(r); continue; } if (t === "tool_use") { const id = String(r.id ?? ""); const name = String(r.name ?? ""); if (!targetStep.tools.has(id)) { targetStep.tools.set(id, { id, name, argsRaw: "", result: null }); } else { const existing = targetStep.tools.get(id); targetStep.tools.set(id, { ...existing, name: existing.name || name }); } targetStep.events.push(r); continue; } if (t === "tool_use_delta") { const id = String(r.id ?? ""); const chunk = String(r.chunk ?? ""); const existing = targetStep.tools.get(id) ?? { id, name: "", argsRaw: "", result: null }; existing.argsRaw = (existing.argsRaw ?? "") + chunk; targetStep.tools.set(id, existing); targetStep.events.push(r); continue; } if (t === "tool_result") { const id = String(r.id ?? ""); const existing = targetStep.tools.get(id) ?? { id, name: String(r.name ?? ""), argsRaw: "", result: null }; existing.name = existing.name || String(r.name ?? ""); existing.result = { title: String(r.title ?? ""), output: String(r.output ?? ""), metadata: r.metadata ?? null }; targetStep.tools.set(id, existing); targetStep.events.push(r); continue; } if (t === "tests") { targetStep.tests.push({ title: String(r.title ?? ""), output: String(r.output ?? ""), metadata: r.metadata ?? null }); targetStep.events.push(r); continue; } if (t === "assistant_finish") { targetStep.assistantFinish = { responseId: r.responseId ?? null, finishReason: r.finishReason ?? null, usage: r.usage ?? null, usage_raw: r.usage_raw ?? null }; targetStep.events.push(r); continue; } if (t === "step_finish") { targetStep.stepFinish = r.info ?? null; targetStep.finishedAt = r.time ?? targetStep.finishedAt; targetStep.events.push(r); continue; } targetStep.events.push(r); } return { steps: steps.map((s) => ({ ...s, tools: [...s.tools.values()] })) }; }37:T8e7,css = htl.html``38:T1596,agent_conversation_view = (() => { const convo = agent_conversation ?? { steps: [], run: null }; const stepsRaw = Array.isArray(convo.steps) ? convo.steps : []; const steps = [...stepsRaw].sort((a, b) => { const sa = Number.isFinite(a?.step) ? a.step : -Infinity; const sb = Number.isFinite(b?.step) ? b.step : -Infinity; if (sb !== sa) return sb - sa; const ta = Number.isFinite(a?.startedAt) ? a.startedAt : 0; const tb = Number.isFinite(b?.startedAt) ? b.startedAt : 0; return tb - ta; }); const fmtTime = (ms) => Number.isFinite(ms) ? new Date(ms).toLocaleString() : ""; const fmtDur = (a, b) => { if (!Number.isFinite(a) || !Number.isFinite(b)) return ""; const s = Math.max(0, Math.round((b - a) / 1000)); if (s < 60) return `${s}s`; const m = Math.floor(s / 60); const r = s % 60; return `${m}m ${r}s`; }; const fmtTokens = (u) => { if (!u || typeof u !== "object") return ""; const input = Number(u.input ?? 0); const output = Number(u.output ?? 0); const reasoning = Number(u.reasoning ?? 0); const cacheRead = Number(u.cache?.read ?? 0); const cacheWrite = Number(u.cache?.write ?? 0); const total = Number(u.total ?? input + output); return `tokens: total ${total} (in ${input}, out ${output}${ reasoning ? `, reasoning ${reasoning}` : "" }${cacheRead || cacheWrite ? `, cache r${cacheRead}/w${cacheWrite}` : ""})`; }; const parseMaybeJSON = (s) => { const str = String(s ?? "").trim(); if (!str) return null; try { return JSON.parse(str); } catch { return null; } }; const run = convo.run; const runBar = htl.html`

Conversation

${run ? String(run.provider ?? "") : ""}

${run?.startedAt ? `started: ${fmtTime(run.startedAt)}` : ""}${ run?.endedAt ? ` • ended: ${fmtTime(run.endedAt)}` : "" }${ run?.startedAt && run?.endedAt ? ` • duration: ${fmtDur(run.startedAt, run.endedAt)}` : "" }

${run?.tokens ? fmtTokens(run.tokens) : ""}

`; const stepViews = steps.map((s) => { const usage = s?.assistantFinish?.usage ?? null; const finishReason = s?.assistantFinish?.finishReason ?? s?.stepFinish?.reason ?? null; const tokenLine = fmtTokens(usage); const duration = fmtDur(s.startedAt, s.finishedAt); const tools = Array.isArray(s.tools) ? s.tools : []; const toolViews = tools.length === 0 ? null : htl.html`

Tools (${tools.length})

${tools.map((t) => { const argsParsed = parseMaybeJSON(t.argsRaw); const argsBlock = argsParsed ? JSON.stringify(argsParsed, null, 2) : String(t.argsRaw ?? "").trim(); const outBlock = t.result?.output ?? ""; const status = t.result?.metadata?.error ? "error" : t.result ? "ok" : "pending"; const title = t.result?.title ? ` • ${t.result.title}` : ""; return htl.html`

${String( t.name ?? "tool" )} (${status})${title}

callId: ${String(t.id ?? "")}

args:

${argsBlock || "(none)"}

output:

${String(outBlock || "(none)")}

`; })}

`; const tests = Array.isArray(s.tests) ? s.tests : []; const testViews = tests.length === 0 ? null : htl.html`

Tests (${tests.length})

${tests.map((t, i) => { const title = t.title || `tests ${i + 1}`; return htl.html`

${title}

${String(t.output ?? "")}

`; })}

`; const text = String(s.text ?? "").trim(); return htl.html`

Step ${Number.isFinite(s.step) ? s.step : ""}${ finishReason ? ` • ${finishReason}` : "" }

${duration ? `duration ${duration}` : ""}

${tokenLine}

${ s?.assistantFinish?.responseId ? `responseId: ${String(s.assistantFinish.responseId)}` : "" }

${ text ? htl.html`

${text}

` : htl.html`

No assistant text yet for this step (streaming or tool-only step).

` } ${toolViews} ${testViews}

`; }); return htl.html`

${css} ${runBar} ${ steps.length ? stepViews : htl.html`

No records yet. Ask something.

` }

`; })()39:Tc96,streamOpenAIChatCompletionsBlocks = async ({ provider, model, messages, tools, callbacks = {}, signal, settings = {} } = {}) => { const body = { model, messages, stream: true, ...settings }; if (tools && tools.length) body.tools = tools; if (!("tool_choice" in body)) body.tool_choice = "auto"; const response = await fetch(provider.chatCompletionsEndpoint, { method: "POST", headers: provider.headers(), body: JSON.stringify(body), signal }); if (!response.ok) { const errorText = await response.text().catch(() => ""); const e = new Error( `Chat Completions API error: ${response.status} - ${errorText}` ); callbacks.onError?.(e); throw e; } let currentText = ""; let finishReason = null; let usage = null; const callIdTo = new Map(); const callOrder = []; const ensureCall = (id) => { const key = String(id ?? ""); if (!key) return null; if (!callIdTo.has(key)) { callIdTo.set(key, { id: key, name: "", args: "" }); callOrder.push(key); } return callIdTo.get(key); }; await parseSSEStream( response.body, (event) => { if (!event || typeof event !== "object") return; if (event.usage && typeof event.usage === "object") usage = event.usage; const choice = Array.isArray(event.choices) ? event.choices[0] : null; if (!choice) return; if (choice.finish_reason) finishReason = choice.finish_reason; const delta = choice.delta ?? {}; if (typeof delta.content === "string" && delta.content) { currentText += delta.content; callbacks.onText?.(delta.content); } const toolCalls = Array.isArray(delta.tool_calls) ? delta.tool_calls : []; for (const tc of toolCalls) { const id = tc?.id ?? tc?.tool_call_id ?? ""; const entry = ensureCall(id); if (!entry) continue; const name = tc?.function?.name ?? tc?.name ?? ""; const argDelta = tc?.function?.arguments ?? tc?.arguments ?? tc?.delta?.arguments ?? ""; const firstName = !entry.name && name; if (firstName) { entry.name = String(name); callbacks.onToolCall?.(entry.id, entry.name); } if (argDelta) { entry.args += String(argDelta); callbacks.onToolCallDelta?.(entry.id, String(argDelta)); } } }, signal ); const toolUses = callOrder .map((id) => callIdTo.get(id)) .filter(Boolean) .map((c) => { let parsed = {}; try { parsed = c.args ? JSON.parse(c.args) : {}; } catch { parsed = {}; } return { type: "tool_use", id: c.id, name: c.name, input: parsed, argsRaw: c.args }; }); const blocks = []; if (currentText) blocks.push({ type: "text", text: currentText }); for (const tu of toolUses) blocks.push(tu); callbacks.onFinish?.({ responseId: null, finishReason: finishReason ?? "unknown", usage, blocks }); return { responseId: null, finishReason: finishReason ?? "unknown", usage, blocks, raw: null }; }3a:T17a4,createOpenAIOpencodeLoop = ({ apiKey, modelId, systemPrompt, registry, tools: toolsOverride = null, settings = {}, maxSteps = 100, autoRunTests = true, testFilter = "", baseUrl = "https://api.openai.com/v1", runtime } = {}) => { if (!registry) throw new Error("createOpenAIOpencodeLoop requires {registry}"); const provider = openaiProvider({ apiKey, baseUrl }); const normalizeToOpenAITools = (rawTools) => { const arr = Array.isArray(rawTools) ? rawTools : []; const looksAlreadyFormatted = (t) => t && typeof t === "object" && (t.type === "function" || t.type === "custom") && typeof t.name === "string"; if (arr.length && looksAlreadyFormatted(arr[0])) return arr; return arr.map((t) => { if (t?.openai?.type === "custom") { return { type: "custom", name: t.id, description: t.description }; } return { type: "function", name: t.id, description: t.description, parameters: t.parameters, strict: true }; }); }; const getTools = () => { const raw = typeof toolsOverride === "function" ? toolsOverride() : toolsOverride != null ? toolsOverride : registry.all(); return normalizeToOpenAITools(raw); }; let abortController = null; let running = false; let state = { previous_response_id: null, lastResponse: null }; const cancel = () => abortController?.abort(); const reset = () => { state = { previous_response_id: null, lastResponse: null }; }; const systemRoleForModel = (mid) => String(mid ?? "").startsWith("o1") ? "user" : "system"; const textMessageItem = (text, role) => ({ type: "message", role, content: [{ type: "input_text", text: String(text ?? "") }] }); const run = async (userPrompt, callbacks = {}) => { if (running) throw new Error("Loop is already running"); running = true; abortController = new AbortController(); try { let previous_response_id = state?.previous_response_id ?? null; const sysRole = systemRoleForModel(modelId); let nextInput = [ ...(systemPrompt ? [textMessageItem(systemPrompt, sysRole)] : []), textMessageItem(userPrompt, "user") ]; for (let step = 0; step < maxSteps; step++) { if (abortController.signal.aborted) break; callbacks.onStepStart?.(step, { previous_response_id }); const streamed = await streamOpenAIResponseBlocks({ provider, model: modelId, input: nextInput, instructions: null, tools: getTools(), previous_response_id, signal: abortController.signal, settings, callbacks: { onText: (chunk) => callbacks.onText?.(chunk), onToolCall: (id, name) => callbacks.onToolCall?.(id, name), onToolCallDelta: (id, chunk) => callbacks.onToolCallDelta?.(id, chunk), onError: (e) => callbacks.onError?.(e), onFinish: (info) => callbacks.onAssistantFinish?.(info) } }); previous_response_id = streamed.responseId ?? previous_response_id; state = { previous_response_id, lastResponse: streamed }; const toolUses = streamed.blocks.filter((b) => b.type === "tool_use"); if (toolUses.length > 0) { const results = []; for (const tu of toolUses) { const ctx = await createToolContext({ sessionId: "opencode", messageId: "opencode", agent: "assistant", callId: tu.id, abort: abortController.signal, runtime }); const args = typeof tu.input === "string" ? { input: tu.input } : tu.input ?? {}; const result = await registry.execute(tu.name, args, ctx); results.push({ call_id: tu.id, name: tu.name, result }); callbacks.onToolFinish?.(tu.id, tu.name, result); } nextInput = results.map((r) => ({ type: "function_call_output", call_id: r.call_id, output: r.result.output })); callbacks.onStepFinish?.(step, { reason: "tool_outputs_sent", previous_response_id }); continue; } if (autoRunTests) { const testCtx = await createToolContext({ sessionId: "opencode", messageId: "opencode", agent: "assistant", callId: `run_tests_${step}`, abort: abortController.signal, runtime }); const testResult = await registry.execute( "run_tests", { filter: String(testFilter ?? "") }, testCtx ); callbacks.onTests?.(testResult); const failed = Number(testResult.metadata?.failed ?? 0); if (failed > 0) { const msg = [ "Tests are failing. Fix the notebook by editing runtime variables (e.g. via define_variable), then run tests again.", "", testResult.output ].join("\n"); nextInput = [textMessageItem(msg, "user")]; callbacks.onStepFinish?.(step, { reason: "tests_failed", failed, previous_response_id }); continue; } callbacks.onStepFinish?.(step, { reason: "tests_passed", failed: 0, previous_response_id }); break; } callbacks.onStepFinish?.(step, { reason: streamed.finishReason || "end_turn", previous_response_id }); break; } callbacks.onFinish?.(state); return state; } finally { running = false; abortController = null; } }; return { run, cancel, reset, running: () => running, getState: () => state }; }3b:T1628,createAnthropicOpencodeLoop = ({ apiKey, modelId, systemPrompt, registry, tools: toolsOverride = null, settings = {}, maxSteps = 10, autoRunTests = true, testFilter = "", baseUrl = "https://api.anthropic.com/v1", version = "2023-06-01", runtime } = {}) => { if (!registry) throw new Error("createAnthropicOpencodeLoop requires {registry}"); const provider = anthropicProvider({ apiKey, baseUrl, version }); const normalizeToAnthropicTools = (rawTools) => { const arr = Array.isArray(rawTools) ? rawTools : []; const looksAlreadyFormatted = (t) => t && typeof t === "object" && typeof t.name === "string" && typeof t.description === "string" && t.input_schema; if (arr.length && looksAlreadyFormatted(arr[0])) return arr; const toolObjs = arr.filter( (t) => t && typeof t === "object" && typeof t.id === "string" ); return toolObjs.map((t) => ({ name: t.id, description: t.description, input_schema: t.parameters })); }; const getTools = () => { const raw = typeof toolsOverride === "function" ? toolsOverride() : toolsOverride != null ? toolsOverride : registry.toAnthropicFormat(); return normalizeToAnthropicTools(raw); }; let abortController = null; let running = false; let lastMessages = []; const cancel = () => abortController?.abort(); const reset = () => { lastMessages = []; }; const run = async (userPrompt, callbacks = {}) => { if (running) throw new Error("Loop is already running"); running = true; abortController = new AbortController(); try { let messages = Array.isArray(lastMessages) && lastMessages.length ? [ ...lastMessages, { role: "user", content: String(userPrompt ?? "") } ] : [{ role: "user", content: String(userPrompt ?? "") }]; lastMessages = messages; const toolCtx = async (callId) => await createToolContext({ sessionId: "opencode", messageId: "opencode", agent: "assistant", callId, abort: abortController.signal, runtime }); for (let step = 0; step < maxSteps; step++) { if (abortController.signal.aborted) break; callbacks.onStepStart?.(step, { messages }); const streamed = await streamAnthropicBlocks({ provider, model: modelId, messages, systemPrompt, tools: getTools(), signal: abortController.signal, settings, callbacks: { onText: (chunk) => callbacks.onText?.(chunk), onToolCall: (id, name) => callbacks.onToolCall?.(id, name), onToolCallDelta: (id, chunk) => callbacks.onToolCallDelta?.(id, chunk), onError: (e) => callbacks.onError?.(e), onFinish: (info) => callbacks.onAssistantFinish?.(info) } }); const assistantMsg = { role: "assistant", content: streamed.blocks }; messages = [...messages, assistantMsg]; lastMessages = messages; const toolUses = streamed.blocks.filter((b) => b.type === "tool_use"); if (toolUses.length > 0) { const results = []; for (const tu of toolUses) { const result = await registry.execute( tu.name, tu.input ?? {}, await toolCtx(tu.id) ); results.push({ tool_use_id: tu.id, name: tu.name, result }); callbacks.onToolFinish?.(tu.id, tu.name, result); } const toolResultBlocks = results.map((r) => ({ type: "tool_result", tool_use_id: r.tool_use_id, content: r.result.output, is_error: !!r.result.metadata?.error })); const toolResultMsg = { role: "user", content: toolResultBlocks }; messages = [...messages, toolResultMsg]; lastMessages = messages; callbacks.onStepFinish?.(step, { reason: "tool_results_sent", messages }); continue; } if (autoRunTests) { const testResult = await registry.execute( "run_tests", { filter: String(testFilter ?? "") }, await toolCtx("run_tests_" + step) ); callbacks.onTests?.(testResult); const failed = Number(testResult.metadata?.failed ?? 0); if (failed > 0) { const msg = [ "Tests are failing. Fix the notebook by editing runtime variables (e.g. via define_variable), then run tests again.", "", testResult.output ].join("\n"); messages = [...messages, { role: "user", content: msg }]; lastMessages = messages; callbacks.onStepFinish?.(step, { reason: "tests_failed", failed, messages }); continue; } callbacks.onStepFinish?.(step, { reason: "tests_passed", failed: 0, messages }); break; } callbacks.onStepFinish?.(step, { reason: streamed.finishReason || "end_turn", messages }); break; } callbacks.onFinish?.(lastMessages); return lastMessages; } finally { running = false; abortController = null; } }; return { run, cancel, reset, running: () => running, getMessages: () => lastMessages }; }3c:T699,viewof provider_ollama_config = Inputs.bind( Inputs.form({ modelId: Inputs.text({ label: "model", width: "100%", value: "llama3.2" }), baseUrl: Inputs.text({ label: "baseUrl (OpenAI-compatible)", width: "100%", value: "http://localhost:11434/v1" }), apiKey: Inputs.password({ label: "apiKey (optional)", width: "100%", value: "" }), max_tokens: Inputs.number({ label: "max_tokens", min: 1, max: 8192, step: 1, value: 2048 }), temperature: Inputs.number({ label: "temperature", min: 0, max: 2, step: 0.05, value: 0.7 }), top_p: Inputs.number({ label: "top_p", min: 0, max: 1, step: 0.01, value: 0.95 }), presence_penalty: Inputs.number({ label: "presence_penalty", min: -2, max: 2, step: 0.1, value: 0 }), frequency_penalty: Inputs.number({ label: "frequency_penalty", min: -2, max: 2, step: 0.1, value: 0 }), seed: Inputs.number({ label: "seed (optional)", min: 0, max: 2147483647, step: 1, value: 0 }), stop: Inputs.textarea({ label: "stop (optional; one per line)", width: "100%", rows: 3, value: "" }) }), localStorageView("provider_ollama_config", { json: true, defaultValue: { modelId: "qwen2.5:7b", baseUrl: "http://localhost:11434/v1", apiKey: "", max_tokens: 2048, temperature: 0.7, top_p: 0.95, presence_penalty: 0, frequency_penalty: 0, seed: 0, stop: "" } }) )3d:T1a69,createOllamaOpencodeLoop = ({ apiKey = "", modelId, systemPrompt, registry, tools: toolsOverride = null, settings = {}, maxSteps = 10, autoRunTests = true, testFilter = "", baseUrl = "http://localhost:11434/v1", runtime } = {}) => { if (!registry) throw new Error("createOllamaOpencodeLoop requires {registry}"); const provider = ollamaProvider({ apiKey, baseUrl }); const normalizeToChatTools = (rawTools) => { const arr = Array.isArray(rawTools) ? rawTools : []; const looksAlreadyFormatted = (t) => t && typeof t === "object" && t.type === "function" && t.function && typeof t.function.name === "string"; if (arr.length && looksAlreadyFormatted(arr[0])) return arr; return arr .filter((t) => t && typeof t === "object" && typeof t.id === "string") .map((t) => ({ type: "function", function: { name: t.id, description: String(t.description ?? ""), parameters: t.parameters ?? { type: "object", properties: {}, required: [] } } })); }; const getTools = () => { const raw = typeof toolsOverride === "function" ? toolsOverride() : toolsOverride != null ? toolsOverride : registry.all(); return normalizeToChatTools(raw); }; let abortController = null; let running = false; let lastMessages = []; const cancel = () => abortController?.abort(); const reset = () => { lastMessages = []; }; const userMsg = (text) => ({ role: "user", content: String(text ?? "") }); const systemMsg = (text, role = "system") => ({ role, content: String(text ?? "") }); const systemRoleForModel = (mid) => String(mid ?? "").startsWith("o1") ? "user" : "system"; const parseStop = (stop) => { const s = String(stop ?? ""); const parts = s .split(/\r?\n/) .map((d) => d.trim()) .filter(Boolean); return parts.length ? parts : undefined; }; const run = async (userPrompt, callbacks = {}) => { if (running) throw new Error("Loop is already running"); running = true; abortController = new AbortController(); try { let messages = Array.isArray(lastMessages) && lastMessages.length ? [...lastMessages] : []; if (!messages.length && systemPrompt) messages.push(systemMsg(systemPrompt, systemRoleForModel(modelId))); messages.push(userMsg(userPrompt)); lastMessages = messages; for (let step = 0; step < maxSteps; step++) { if (abortController.signal.aborted) break; callbacks.onStepStart?.(step, { messages }); const streamed = await streamOpenAIChatCompletionsBlocks({ provider, model: modelId, messages, tools: getTools(), signal: abortController.signal, settings: { ...settings, stop: parseStop(settings.stop) }, callbacks: { onText: (chunk) => callbacks.onText?.(chunk), onToolCall: (id, name) => callbacks.onToolCall?.(id, name), onToolCallDelta: (id, chunk) => callbacks.onToolCallDelta?.(id, chunk), onError: (e) => callbacks.onError?.(e), onFinish: (info) => callbacks.onAssistantFinish?.(info) } }); const text = streamed.blocks .filter((b) => b.type === "text") .map((b) => b.text) .join(""); const toolUses = streamed.blocks.filter((b) => b.type === "tool_use"); const assistantToolCalls = toolUses.map((tu) => ({ id: tu.id, type: "function", function: { name: tu.name, arguments: tu.argsRaw ?? JSON.stringify(tu.input ?? {}) } })); const assistantMsg = { role: "assistant", content: text || null, ...(assistantToolCalls.length ? { tool_calls: assistantToolCalls } : {}) }; messages = [...messages, assistantMsg]; lastMessages = messages; if (toolUses.length > 0) { const toolResultMsgs = []; for (const tu of toolUses) { const ctx = await createToolContext({ sessionId: "opencode", messageId: "opencode", agent: "assistant", callId: tu.id, abort: abortController.signal, runtime }); const result = await registry.execute(tu.name, tu.input ?? {}, ctx); callbacks.onToolFinish?.(tu.id, tu.name, result); toolResultMsgs.push({ role: "tool", tool_call_id: tu.id, content: String(result.output ?? "") }); } messages = [...messages, ...toolResultMsgs]; lastMessages = messages; callbacks.onStepFinish?.(step, { reason: "tool_outputs_sent", messages }); continue; } if (autoRunTests) { const testCtx = await createToolContext({ sessionId: "opencode", messageId: "opencode", agent: "assistant", callId: `run_tests_${step}`, abort: abortController.signal, runtime }); const testResult = await registry.execute( "run_tests", { filter: String(testFilter ?? "") }, testCtx ); callbacks.onTests?.(testResult); const failed = Number(testResult.metadata?.failed ?? 0); if (failed > 0) { const msg = [ "Tests are failing. Fix the notebook by editing runtime variables (e.g. via define_variable), then run tests again.", "", testResult.output ].join("\n"); messages = [...messages, userMsg(msg)]; lastMessages = messages; callbacks.onStepFinish?.(step, { reason: "tests_failed", failed, messages }); continue; } callbacks.onStepFinish?.(step, { reason: "tests_passed", failed: 0, messages }); break; } callbacks.onStepFinish?.(step, { reason: streamed.finishReason || "end_turn", messages }); break; } callbacks.onFinish?.(lastMessages); return lastMessages; } finally { running = false; abortController = null; } }; return { run, cancel, reset, running: () => running, getMessages: () => lastMessages }; }3e:T477,viewof agent_config = Inputs.form({ maxSteps: Inputs.number({ label: "maxSteps", min: 1, max: 50, step: 1, value: 10 }), autoRunTests: Inputs.toggle({ label: "autoRunTests", value: true }), testFilter: Inputs.text({ label: "testFilter (optional)", width: "100%", value: "" }), systemPrompt: Inputs.textarea({ label: "systemPrompt", width: "100%", rows: 10, value: system_prompt }) }) /*Inputs.bind( Inputs.form({ maxSteps: Inputs.number({ label: "maxSteps", min: 1, max: 50, step: 1, value: 10 }), autoRunTests: Inputs.toggle({ label: "autoRunTests", value: true }), testFilter: Inputs.text({ label: "testFilter (optional)", width: "100%", value: "" }), systemPrompt: Inputs.textarea({ label: "systemPrompt", width: "100%", rows: 10, value: system_prompt }) }), localStorageView("agent_config", { json: true, defaultValue: { maxSteps: 25, autoRunTests: true, testFilter: "", systemPrompt: system_prompt } }) )*/3f:T959,agent_loop = provider_choice === "demo" ? createOpenAIOpencodeLoop({ apiKey: "", baseUrl: "https://openai-proxy.endpointservices.workers.dev/v1", modelId: "gpt-5-mini", systemPrompt: agent_system_prompt, registry: toolRegistry, settings: { max_output_tokens: provider_openai_config.max_output_tokens }, maxSteps: agent_config.maxSteps, autoRunTests: agent_config.autoRunTests, testFilter: agent_config.testFilter, runtime: agent_runtime }) : provider_choice === "openai" ? createOpenAIOpencodeLoop({ apiKey: OPENAI_API_KEY, baseUrl: provider_openai_config.baseUrl, modelId: provider_openai_config.modelId, systemPrompt: agent_system_prompt, registry: toolRegistry, settings: { max_output_tokens: provider_openai_config.max_output_tokens }, maxSteps: agent_config.maxSteps, autoRunTests: agent_config.autoRunTests, testFilter: agent_config.testFilter, runtime: agent_runtime }) : provider_choice === "anthropic" ? createAnthropicOpencodeLoop({ apiKey: ANTHROPIC_API_KEY, baseUrl: provider_anthropic_config.baseUrl, version: provider_anthropic_config.version, modelId: provider_anthropic_config.modelId, systemPrompt: agent_system_prompt, registry: toolRegistry, settings: { max_tokens: provider_anthropic_config.max_tokens }, maxSteps: agent_config.maxSteps, autoRunTests: agent_config.autoRunTests, testFilter: agent_config.testFilter, runtime: agent_runtime }) : createOllamaOpencodeLoop({ apiKey: provider_ollama_config.apiKey, baseUrl: provider_ollama_config.baseUrl, modelId: provider_ollama_config.modelId, systemPrompt: agent_system_prompt, registry: toolRegistry, settings: { max_tokens: provider_ollama_config.max_tokens, temperature: provider_ollama_config.temperature, top_p: provider_ollama_config.top_p, presence_penalty: provider_ollama_config.presence_penalty, frequency_penalty: provider_ollama_config.frequency_penalty, seed: provider_ollama_config.seed || undefined, stop: provider_ollama_config.stop }, maxSteps: agent_config.maxSteps, autoRunTests: agent_config.autoRunTests, testFilter: agent_config.testFilter, runtime: agent_runtime })40:T8f9,normalizeUsage = (usage, providerId = "") => { const u = usage && typeof usage === "object" ? usage : {}; const pid = String(providerId ?? "").toLowerCase(); const asInt = (x) => (Number.isFinite(x) ? Math.trunc(x) : 0); const looksOpenAIResponses = "total_tokens" in u || "input_tokens" in u || "output_tokens" in u || "input_tokens_details" in u || "output_tokens_details" in u; const looksOpenAIChatCompletions = "prompt_tokens" in u || "completion_tokens" in u || "total_tokens" in u; const looksAnthropic = "input_tokens" in u || "output_tokens" in u || "cache_read_input_tokens" in u || "cache_creation_input_tokens" in u; if ( pid.includes("openai") || (looksOpenAIResponses && !pid.includes("anthropic") && !pid.includes("ollama")) ) { const input = asInt(u.input_tokens); const output = asInt(u.output_tokens); const reasoning = asInt( u.output_tokens_details?.reasoning_tokens ?? u.reasoning_tokens ); const cacheRead = asInt( u.input_tokens_details?.cached_tokens ?? u.cached_tokens ); const cacheWrite = asInt( u.input_tokens_details?.cache_creation_input_tokens ?? 0 ); const total = asInt(u.total_tokens ?? input + output); return { input, output, reasoning, cache: { read: cacheRead, write: cacheWrite }, total }; } if (pid.includes("ollama") || looksOpenAIChatCompletions) { const input = asInt(u.prompt_tokens); const output = asInt(u.completion_tokens); const total = asInt(u.total_tokens ?? input + output); return { input, output, reasoning: 0, cache: { read: 0, write: 0 }, total }; } if (pid.includes("anthropic") || looksAnthropic) { const input = asInt(u.input_tokens); const output = asInt(u.output_tokens); const cacheRead = asInt(u.cache_read_input_tokens); const cacheWrite = asInt(u.cache_creation_input_tokens); const total = asInt(u.total_tokens ?? input + output); return { input, output, reasoning: 0, cache: { read: cacheRead, write: cacheWrite }, total }; } return { input: 0, output: 0, reasoning: 0, cache: { read: 0, write: 0 }, total: 0 }; }41:Tcd2,

Open AI completion event

${md`~~~json { "type": "response.completed", "response": { "id": "resp_04976cfaa45a675a006970f676dfa881979084ef09ab948c9d", "object": "response", "created_at": 1769010807, "status": "completed", "background": false, "completed_at": 1769010823, "error": null, "frequency_penalty": 0, "incomplete_details": null, "instructions": "...", "max_output_tokens": 2048, "max_tool_calls": null, "model": "gpt-5-mini-2025-08-07", "output": [ { "id": "rs_04976cfaa45a675a006970f6775d1481979bb27b1a685fcfc7", "type": "reasoning", "summary": [] }, { "id": "msg_04976cfaa45a675a006970f67ac7808197b6b05e2f33751b1d", "type": "message", "status": "completed", "content": [ { "type": "output_text", "annotations": [], "logprobs": [], "text": "..." } ], "role": "assistant" } ], "parallel_tool_calls": true, "presence_penalty": 0, "previous_response_id": "resp_04976cfaa45a675a006970f67326c48197b6ec6e8092ffee60", "prompt_cache_key": null, "prompt_cache_retention": null, "reasoning": { "effort": "medium", "summary": null }, "safety_identifier": null, "service_tier": "default", "store": true, "temperature": 1, "text": { "format": { "type": "text" }, "verbosity": "medium" }, "tool_choice": "auto", "tools": [ { "type": "function", "description": "Read information about a runtime variable (name, current value/error, reachability, and its input variables).", "name": "read_variable", "parameters": { "type": "object", "properties": { "name": { "type": "string", "description": "The name of the runtime variable to read" } }, "required": [ "name" ], "additionalProperties": false }, "strict": true },... ], "top_logprobs": 0, "top_p": 1, "truncation": "disabled", "usage": { "input_tokens": 9157, "input_tokens_details": { "cached_tokens": 8960 }, "output_tokens": 996, "output_tokens_details": { "reasoning_tokens": 192 }, "total_tokens": 10153 }, "user": null, "metadata": {} }, "sequence_number": 807 } ~~~`}

Anthropic 429

${md`~~~json Status Code: 429 retry-after: 11 { "type": "error", "error": { "type": "rate_limit_error", "message": "This request would exceed the rate limit for your organization (1815e560-bf0c-433e-b03a-793524e11fda) of 50,000 input tokens per minute. For details, refer to: https://docs.claude.com/en/api/rate-limits. You can see the response headers for current usage. Please reduce the prompt length or the maximum tokens requested, or try again later. You may also contact sales at https://www.anthropic.com/contact-sales to discuss your options for a rate limit increase." }, "request_id": "req_011CXQugkT1ZmWRCq9gdSrAa" } ~~~`}

42:Tebd,agent_run = async ({ prompt = "", reset = true } = {}) => { const text = String(prompt ?? "").trim(); if (!text) return null; const runId = typeof generateId === "function" ? generateId() : crypto.randomUUID(); const startedAt = Date.now(); let records; if (reset || !Array.isArray(mutable agent_records)) records = []; else records = mutable agent_records; const computeStepBase = (recs) => { let m = -1; for (const r of Array.isArray(recs) ? recs : []) { const s = r?.step; if (Number.isFinite(s)) m = Math.max(m, s); const is = r?.info?.step; if (Number.isFinite(is)) m = Math.max(m, is); } return m + 1; }; const stepBase = reset ? 0 : computeStepBase(records); if (reset) { mutable agent_records = records; } const runEntry = { id: runId, startedAt, endedAt: null, provider: String(provider_choice ?? ""), prompt: String(prompt ?? ""), records, stepBase, tokens: { input: 0, output: 0, reasoning: 0, cache: { read: 0, write: 0 }, total: 0 } }; mutable agent_run_history = [ runEntry, ...(mutable agent_run_history || []) ].slice(0, 20); const push = (rec) => { records = appendAgentRecord(records, rec, Date.now()); mutable agent_records = records; }; push({ type: "run_start", runId, provider: runEntry.provider, reset: !!reset }); try { await agent_loop.run(prompt, { onStepStart: (step, info) => { const s = stepBase + step; push({ type: "step_start", step: s, info: info ?? null }); }, onText: (chunk) => { push({ type: "text", chunk: String(chunk ?? "") }); }, onToolCall: (id, name) => { push({ type: "tool_use", id: String(id ?? ""), name: String(name ?? "") }); }, onToolCallDelta: (id, chunk) => { push({ type: "tool_use_delta", id: String(id ?? ""), chunk: String(chunk ?? "") }); }, onToolFinish: (id, name, result) => { push({ type: "tool_result", id: String(id ?? ""), name: String(name ?? ""), title: String(result?.title ?? ""), output: String(result?.output ?? ""), metadata: result?.metadata ?? null }); }, onTests: (result) => { push({ type: "tests", title: String(result?.title ?? ""), output: String(result?.output ?? ""), metadata: result?.metadata ?? null }); }, onAssistantFinish: (info) => { const usage = normalizeUsage(info?.usage, provider_choice); runEntry.tokens = usage; push({ type: "assistant_finish", responseId: info?.responseId ?? null, finishReason: info?.finishReason ?? null, usage_raw: info?.usage ?? null, usage }); }, onError: (e) => { push({ type: "error", message: String(e?.message ?? e), error: e ?? null }); }, onStepFinish: (step, info) => { const s = stepBase + step; push({ type: "step_finish", step: s, info: info ?? null }); } }); push({ type: "run_done" }); } catch (e) { push({ type: "fatal", message: String(e?.message ?? e), error: e ?? null }); } finally { runEntry.endedAt = Date.now(); push({ type: "run_end", runId, durationMs: runEntry.endedAt - startedAt, tokens: runEntry.tokens }); mutable agent_run_history = [ runEntry, ...(mutable agent_run_history || []).filter((d) => d?.id !== runId) ].slice(0, 20); } return runEntry; }43:T1233,streamOpenAIResponseBlocks = async ({ provider, model, input, instructions, tools, previous_response_id, callbacks = {}, signal, settings = {} } = {}) => { const body = { model, input, stream: true, ...settings }; if (instructions) body.instructions = instructions; if (previous_response_id) body.previous_response_id = previous_response_id; if (tools && tools.length) body.tools = tools; const response = await fetch(provider.responsesEndpoint, { method: "POST", headers: provider.headers(), body: JSON.stringify(body), signal }); if (!response.ok) { const errorText = await response.text().catch(() => ""); const e = new Error(`OpenAI API error: ${response.status} - ${errorText}`); callbacks.onError?.(e); throw e; } let responseId = null; let finalResponse = null; let currentText = ""; const itemIdToCallId = new Map(); const argsByCallId = new Map(); const outputItemsDone = []; const normalizeBlocksFromOutput = (output = []) => { const blocks = []; for (const item of output) { if (!item || typeof item !== "object") continue; if ( item.type === "message" && item.role === "assistant" && Array.isArray(item.content) ) { for (const part of item.content) { if (part?.type === "output_text") { blocks.push({ type: "text", text: String(part.text ?? "") }); } } } else if (item.type === "function_call") { let parsed = {}; try { parsed = item.arguments ? JSON.parse(item.arguments) : {}; } catch { parsed = {}; } blocks.push({ type: "tool_use", id: item.call_id ?? item.id, name: item.name, input: parsed }); } else if (item.type === "custom_tool_call") { blocks.push({ type: "tool_use", id: item.call_id ?? item.id, name: item.name, input: item.input ?? "" }); } } return blocks; }; await parseSSEStream( response.body, (event) => { const t = event?.type; if (t === "response.created") { responseId = event?.response?.id ?? responseId; } if (t === "response.output_text.delta") { const delta = event?.delta ?? ""; currentText += delta; callbacks.onText?.(delta); } if (t === "response.output_item.added") { const item = event?.item; if (item?.type === "function_call") { if (item.id && (item.call_id ?? item.id)) itemIdToCallId.set(item.id, item.call_id ?? item.id); callbacks.onToolCall?.(item.call_id ?? item.id, item.name); } else if (item?.type === "custom_tool_call") { if (item.id && (item.call_id ?? item.id)) itemIdToCallId.set(item.id, item.call_id ?? item.id); callbacks.onToolCall?.(item.call_id ?? item.id, item.name); } } if (t === "response.function_call_arguments.delta") { const itemId = event?.item_id; const callId = itemIdToCallId.get(itemId) ?? itemId; const delta = event?.delta ?? ""; argsByCallId.set(callId, (argsByCallId.get(callId) ?? "") + delta); callbacks.onToolCallDelta?.(callId, delta); } if (t === "response.function_call_arguments.done") { const itemId = event?.item_id; const callId = itemIdToCallId.get(itemId) ?? itemId; const args = event?.arguments ?? ""; argsByCallId.set(callId, args); } if (t === "response.output_item.done") { const idx = event?.output_index; if (Number.isInteger(idx)) outputItemsDone[idx] = event?.item; } if (t === "response.completed") { finalResponse = event?.response ?? finalResponse; responseId = finalResponse?.id ?? responseId; } if (t === "response.failed") { const msg = event?.response?.error?.message ?? "Unknown error"; const e = new Error(msg); callbacks.onError?.(e); } }, signal ); const output = finalResponse?.output ?? outputItemsDone.filter(Boolean); let blocks = normalizeBlocksFromOutput(output); if (blocks.length === 0 && currentText) blocks = [{ type: "text", text: currentText }]; const usage = finalResponse?.usage ?? null; const finishReason = finalResponse?.status ?? "unknown"; callbacks.onFinish?.({ responseId, finishReason, usage, blocks }); return { responseId, finishReason, usage, blocks, raw: finalResponse }; }44:Taa2,streamAnthropicBlocks = async ({ provider, model, messages, systemPrompt, tools, callbacks = {}, signal, settings = {} }) => { const body = { model, messages, max_tokens: settings.max_tokens || 4096, stream: true, ...settings }; if (systemPrompt) body.system = systemPrompt; if (tools && tools.length > 0) body.tools = tools; const response = await fetch(provider.messagesEndpoint, { method: "POST", headers: provider.headers(), body: JSON.stringify(body), signal }); if (!response.ok) { const error = await response.text(); const e = new Error("Anthropic API error: " + response.status + " - " + error); callbacks.onError?.(e); throw e; } const blocks = []; let current = null; let stopReason = null; let usage = null; const finishBlock = () => { if (!current) return; if (current.type === "text") { blocks.push({ type: "text", text: current.text }); } else if (current.type === "tool_use") { let input = {}; try { input = current.input_json ? JSON.parse(current.input_json) : {}; } catch { input = {}; } blocks.push({ type: "tool_use", id: current.id, name: current.name, input }); } current = null; }; await parseSSEStream( response.body, (event) => { if (event.type === "message_start") usage = event.message?.usage ?? usage; if (event.type === "content_block_start") { const b = event.content_block; if (b?.type === "text") current = { type: "text", text: "" }; else if (b?.type === "tool_use") { current = { type: "tool_use", id: b.id, name: b.name, input_json: "" }; callbacks.onToolCall?.(b.id, b.name); } } if (event.type === "content_block_delta") { const d = event.delta; if (d?.type === "text_delta" && current?.type === "text") { current.text += d.text; callbacks.onText?.(d.text); } else if (d?.type === "thinking_delta") { callbacks.onReasoning?.(d.thinking); } else if (d?.type === "input_json_delta" && current?.type === "tool_use") { current.input_json += d.partial_json; callbacks.onToolCallDelta?.(current.id, d.partial_json); } } if (event.type === "content_block_stop") finishBlock(); if (event.type === "message_delta") { stopReason = event.delta?.stop_reason ?? stopReason; if (event.usage) usage = { ...(usage ?? {}), ...event.usage }; } }, signal ); finishBlock(); callbacks.onFinish?.({ finishReason: stopReason, usage, blocks }); return { blocks, finishReason: stopReason, usage }; }45:T995,streamAnthropic = async ({provider, model, messages, systemPrompt, tools, callbacks, signal, settings = {}}) => { const body = { model, messages, max_tokens: settings.max_tokens || 4096, stream: true, ...settings }; if (systemPrompt) body.system = systemPrompt; if (tools && tools.length > 0) body.tools = tools; const response = await fetch(provider.messagesEndpoint, { method: 'POST', headers: provider.headers(), body: JSON.stringify(body), signal }); if (!response.ok) { const error = await response.text(); callbacks.onError?.(new Error('Anthropic API error: ' + response.status + ' - ' + error)); throw new Error('Anthropic API error: ' + response.status); } let currentToolUse = null; let stopReason = null; let usage = null; await parseSSEStream(response.body, event => { if (event.type === 'message_start') usage = event.message?.usage; if (event.type === 'content_block_start') { const block = event.content_block; if (block?.type === 'tool_use') { currentToolUse = { id: block.id, name: block.name, input: '' }; callbacks.onToolCall?.(block.id, block.name); } } if (event.type === 'content_block_delta') { const delta = event.delta; if (delta?.type === 'text_delta') callbacks.onText?.(delta.text); else if (delta?.type === 'thinking_delta') callbacks.onReasoning?.(delta.thinking); else if (delta?.type === 'input_json_delta' && currentToolUse) { currentToolUse.input += delta.partial_json; callbacks.onToolCallDelta?.(currentToolUse.id, delta.partial_json); } } if (event.type === 'content_block_stop') currentToolUse = null; if (event.type === 'message_delta') { stopReason = event.delta?.stop_reason; if (event.usage) usage = { ...usage, ...event.usage }; } }, signal); callbacks.onFinish?.({ finishReason: stopReason, usage }); return { finishReason: stopReason, usage }; }46:T769,variablesXML = async (ctx, variables, { max_size = 500 } = {}) => { const modules = ctx?.moduleMap; const moduleNameOf = (mod) => String(modules?.get(mod)?.name ?? mod?._name ?? "main").trim() || "main"; const varNameOf = (v) => (typeof v?._name === "string" ? v._name : ""); const fmtInput = (parentVar, inputVar) => { const inName = varNameOf(inputVar); if (!inName) return ""; const parentModule = moduleNameOf(parentVar?._module); const inModule = moduleNameOf(inputVar?._module); return inModule && parentModule && inModule !== parentModule ? `${inModule}#${inName}` : inName; }; const safeInputs = (v) => (Array.isArray(v?._inputs) ? v._inputs : []) .map((i) => fmtInput(v, i)) .filter(Boolean) .join(", "); return ( await Promise.all( (Array.isArray(variables) ? variables : []).map(async (v) => { const modName = moduleNameOf(v._module); const inputs = safeInputs(v); const state = await getPromiseStateCrossRealm(v._promise); if ( state.state === "rejected" && state?.error?.name == "variable_stale" ) { state.state = "pending"; state.error = undefined; } if (v._type == 2) return ""; // implicit filtered return ` ${inputs} ${cdata(v?._definition?.toString?.() ?? "")}> ${cdata(summarizeJS(v?._value, { max_size }))}>${ state.error ? `\n ${cdata( summarizeJS(state.error, { max_size }) )}>` : "" } \n`; }) ) ).join("\n"); }47:T27af,viewof toolRegistry_ui = (() => { const root = document.createElement("div"); root.value = { recording: !!toolRegistry_recording, historyLimit: toolRegistry_history_limit, stats: toolRegistry_stats ?? null }; root.style.display = "grid"; root.style.gap = "12px"; root.style.fontFamily = "system-ui, -apple-system, Segoe UI, Roboto, Helvetica, Arial, sans-serif"; const css = htl.html``; const fmtPct = (x) => (Number.isFinite(x) ? (x * 100).toFixed(1) + "%" : ""); const fmtMs = (x) => (Number.isFinite(x) ? Math.round(x) + "ms" : ""); const fmtBytes = (x) => { const n = Number(x ?? 0); if (!Number.isFinite(n) || n <= 0) return "0 B"; if (n < 1024) return `${Math.round(n)} B`; if (n < 1024 * 1024) return `${(n / 1024).toFixed(1)} KB`; return `${(n / (1024 * 1024)).toFixed(2)} MB`; }; const fmtTime = (ms) => Number.isFinite(ms) ? new Date(ms).toLocaleString() : ""; const stats = toolRegistry_stats ?? { overall: { total: 0 }, tools: [], maxCalls: 0 }; const overall = stats.overall ?? {}; const tools = Array.isArray(stats.tools) ? stats.tools : []; const maxCalls = Math.max(1, Number(stats.maxCalls ?? 1)); const filtered = Array.isArray(toolRegistry_history_filtered) ? toolRegistry_history_filtered : []; const header = htl.html`

toolRegistry inspector (global)

${ toolRegistry_recording ? "recording: on" : "recording: off" } history limit: ${toolRegistry_history_limit}

${viewof toolRegistry_recording} ${viewof toolRegistry_history_limit} ${viewof toolRegistry_clear_history}

${viewof toolRegistry_inspector_controls}

`; const summary = htl.html`

Summary

All recorded calls

Total calls: ${overall.total ?? 0}

Tools used: ${overall.tools ?? 0}

Error rate: ${fmtPct(overall.errorRate ?? 0)} (${ overall.errors ?? 0 })

Avg duration: ${fmtMs(overall.avgDurationMs ?? 0)}

Avg args size: ${fmtBytes(overall.avgArgsBytes ?? 0)}

Avg output size: ${fmtBytes( overall.avgOutputBytes ?? 0 )}

Avg ctx metadata size: ${fmtBytes( overall.avgCtxBytes ?? 0 )}

`; const bars = htl.html`

Most used tools

by call count

${tools.slice(0, 20).map((t) => { const w = Math.max(0, Math.min(1, t.calls / maxCalls)) * 100; const badge = t.errors ? htl.html`${fmtPct( t.errorRate )} err` : htl.html`ok`; return htl.html`

${t.toolId}

${t.calls} calls ${badge}

`; })} ${ tools.length === 0 ? htl.html`

No calls recorded yet.

` : null }

`; const toolTable = htl.html`

Tool stats

all time

${tools.map( (t) => htl.html`` )} ${ tools.length === 0 ? htl.html`` : null }

Tool	Calls	Errors	Error rate	Avg duration	Avg args	Avg output	Avg ctx meta
${t.toolId}	${t.calls}	${t.errors}	${fmtPct(t.errorRate)}	${fmtMs(t.avgDurationMs)}	${fmtBytes(t.avgArgsBytes)}	${fmtBytes(t.avgOutputBytes)}	${fmtBytes(t.avgCtxBytes)}
No recorded calls yet.

`; const calls = htl.html`

Call history (filtered)

${ filtered.length } rows shown

${filtered.map((r, idx) => { const ok = r.ok !== false; const badge = ok ? htl.html`ok` : htl.html`error`; const ctx = r.ctx ?? {}; const metaPreview = (() => { try { return JSON.stringify(ctx.metadata ?? {}, null, 2); } catch { return ""; } })(); const resMetaPreview = (() => { try { return JSON.stringify(r.resultMetadata ?? {}, null, 2); } catch { return ""; } })(); return htl.html`

${badge} ${String(r.toolId ?? "")} • ${fmtTime(r.time)} • ${fmtMs( r.durationMs )} • phase: ${String(r.phase ?? "")}

callId: ${String(ctx.callId ?? "")}

sessionId: ${String(ctx.sessionId ?? "")}

messageId: ${String(ctx.messageId ?? "")}

agent: ${String(ctx.agent ?? "")}

args size: ${fmtBytes(r.argsSize ?? 0)}

output size: ${fmtBytes(r.outputSize ?? 0)}

ctx meta size: ${fmtBytes( ctx.metadataSize ?? 0 )}

${ r.errorMessage ? htl.html`

Error message

${String(r.errorMessage)}

` : null }

Args

${String(r.argsRaw ?? "") || "(none)"}

Output

${String(r.output ?? "") || "(none)"}

Result metadata

${resMetaPreview || "(none)"}

Context metadata (ctx.metadata)

${metaPreview || "(none)"}

`; })} ${ filtered.length === 0 ? htl.html`

No matching calls. (Tip: enable recording, then run the agent or call tools.)

` : null }

`; root.appendChild(css); root.appendChild(header); root.appendChild(summary); root.appendChild(bars); root.appendChild(toolTable); root.appendChild(calls); return root; })()48:T673,defineTool = ({id, description, parameters, execute}) => { if (!id || typeof id !== 'string') throw new Error('Tool must have a string id'); if (!description || typeof description !== 'string') throw new Error('Tool must have a string description'); if (!parameters || typeof parameters !== 'object') throw new Error('Tool must have a parameters object'); if (!execute || typeof execute !== 'function') throw new Error('Tool must have an execute function'); return { id, description, parameters, execute: async (args, ctx) => { try { if (ctx.abort?.aborted) return { title: id + ' aborted', output: 'Execution was aborted', metadata: { aborted: true } }; const result = await execute(args, ctx); return { title: result.title || id + ' completed', output: typeof result.output === 'string' ? result.output : JSON.stringify(result.output), metadata: { ...ctx.getMetadata?.() || {}, ...result.metadata } }; } catch (error) { return { title: id + ' failed', output: 'Error: ' + error.message, metadata: { error: true, errorMessage: error.message } }; } } }; }49:T808,validateParameters = { const validate = (schema, value) => { const errors = []; if (!schema || typeof schema !== "object") return { valid: true, errors }; const type = schema.type; if (type === "object") { if (typeof value !== "object" || value === null || Array.isArray(value)) { errors.push("Expected object"); return { valid: false, errors }; } const props = schema.properties || {}; const required = Array.isArray(schema.required) ? schema.required : []; for (const field of required) { if (!(field in value)) errors.push("Missing required field: " + field); } if (schema.additionalProperties === false) { for (const k of Object.keys(value)) { if (!(k in props)) errors.push("Unexpected field: " + k); } } for (const [key, propSchema] of Object.entries(props)) { if (key in value) { const r = validate(propSchema, value[key]); if (!r.valid) errors.push(...r.errors.map((e) => key + ": " + e)); } } } else if (type === "string") { if (typeof value !== "string") errors.push("Expected string, got " + typeof value); } else if (type === "number") { if (typeof value !== "number" || Number.isNaN(value)) errors.push("Expected number, got " + typeof value); } else if (type === "integer") { if (typeof value !== "number" || !Number.isInteger(value)) errors.push("Expected integer, got " + typeof value); } else if (type === "boolean") { if (typeof value !== "boolean") errors.push("Expected boolean, got " + typeof value); } else if (type === "array") { if (!Array.isArray(value)) errors.push("Expected array, got " + typeof value); else if (schema.items) { value.forEach((item, i) => { const r = validate(schema.items, item); if (!r.valid) errors.push(...r.errors.map((e) => "[" + i + "]: " + e)); }); } } return { valid: errors.length === 0, errors }; }; return validate; }4a:T1d44,createToolRegistry = () => { const tools = new Map(); const normalizeSchema = (schema) => { if (!schema || typeof schema !== "object") return schema; if (Array.isArray(schema)) return schema.map(normalizeSchema); const s = { ...schema }; const normalizeCombinators = (obj) => { if (Array.isArray(obj.anyOf)) obj.anyOf = obj.anyOf.map(normalizeSchema); if (Array.isArray(obj.oneOf)) obj.oneOf = obj.oneOf.map(normalizeSchema); if (Array.isArray(obj.allOf)) obj.allOf = obj.allOf.map(normalizeSchema); if (obj.not && typeof obj.not === "object") obj.not = normalizeSchema(obj.not); }; const looksLikeObjectSchema = s.type === "object" || !!s.properties || !!s.required || s.additionalProperties !== undefined; const looksLikeArraySchema = s.type === "array" || s.items !== undefined || s.prefixItems !== undefined; if (looksLikeObjectSchema) { if (!s.type) s.type = "object"; if (s.additionalProperties === undefined) s.additionalProperties = false; if ( s.properties && typeof s.properties === "object" && !Array.isArray(s.properties) ) { const props = {}; for (const [k, v] of Object.entries(s.properties)) props[k] = normalizeSchema(v); s.properties = props; } if ( s.patternProperties && typeof s.patternProperties === "object" && !Array.isArray(s.patternProperties) ) { const pprops = {}; for (const [k, v] of Object.entries(s.patternProperties)) pprops[k] = normalizeSchema(v); s.patternProperties = pprops; } if ( s.additionalProperties && typeof s.additionalProperties === "object" ) { s.additionalProperties = normalizeSchema(s.additionalProperties); } normalizeCombinators(s); return s; } if (looksLikeArraySchema) { if (!s.type) s.type = "array"; if (s.items !== undefined) s.items = normalizeSchema(s.items); if (Array.isArray(s.prefixItems)) s.prefixItems = s.prefixItems.map(normalizeSchema); normalizeCombinators(s); return s; } normalizeCombinators(s); return s; }; const normalizeTool = (tool) => ({ ...tool, parameters: normalizeSchema(tool.parameters) }); const toolEnabledForAnthropic = (t) => !(t?.excludeFromAnthropic === true || t?.anthropic?.enabled === false); const safeStringify = (v, max = 200_000) => { let s = ""; try { s = JSON.stringify(v); } catch { try { s = String(v); } catch { s = ""; } } if (s.length > max) s = s.slice(0, max) + `… (${s.length - max} chars more)`; return s; }; const pushHistory = (rec) => { if (!toolRegistry_recording) return; const arr = Array.isArray(mutable toolRegistry_history) ? mutable toolRegistry_history : []; arr.push(rec); const limit = Math.max( 50, Math.min(5000, Math.trunc(toolRegistry_history_limit || 1000)) ); if (arr.length > limit) arr.splice(0, arr.length - limit); mutable toolRegistry_history = arr; }; const baseCtxInfo = (ctx = {}) => { const meta = (() => { try { return ctx?.getMetadata?.() ?? {}; } catch { return {}; } })(); const metaStr = safeStringify(meta, 200_000); return { sessionId: ctx?.sessionId ?? null, messageId: ctx?.messageId ?? null, agent: ctx?.agent ?? null, callId: ctx?.callId ?? null, metadata: meta, metadataSize: metaStr.length }; }; return { register(tool) { tools.set(tool.id, normalizeTool(tool)); }, unregister(id) { return tools.delete(id); }, get(id) { return tools.get(id); }, has(id) { return tools.has(id); }, ids() { return [...tools.keys()]; }, all() { return [...tools.values()]; }, toAnthropicFormat() { return this.all() .filter(toolEnabledForAnthropic) .map((t) => ({ name: t.id, description: t.description, input_schema: t.parameters })); }, async execute(id, args, ctx) { const tool = tools.get(id); const startTime = Date.now(); const ctxInfo = baseCtxInfo(ctx); const argsStr = safeStringify(args, 200_000); if (!tool) { const out = { title: "Tool not found", output: "Unknown tool: " + id, metadata: { error: true } }; pushHistory({ time: startTime, durationMs: Date.now() - startTime, toolId: id, ok: false, phase: "lookup", args, argsRaw: argsStr, argsSize: argsStr.length, output: out.output, outputSize: String(out.output ?? "").length, title: out.title, errorMessage: out.output, resultMetadata: out.metadata, ctx: ctxInfo }); return out; } const validation = validateParameters(tool.parameters, args); if (!validation.valid) { const out = { title: "Invalid parameters", output: `Parameter validation failed (${id}):\n` + validation.errors.join("\n"), metadata: { error: true, validationErrors: validation.errors } }; pushHistory({ time: startTime, durationMs: Date.now() - startTime, toolId: id, ok: false, phase: "validation", args, argsRaw: argsStr, argsSize: argsStr.length, output: out.output, outputSize: String(out.output ?? "").length, title: out.title, errorMessage: out.output, resultMetadata: out.metadata, ctx: ctxInfo }); return out; } let result; try { result = await tool.execute(args, ctx); } catch (e) { const msg = String(e?.message ?? e); const out = { title: `${id} failed`, output: "Error: " + msg, metadata: { error: true, errorMessage: msg } }; pushHistory({ time: startTime, durationMs: Date.now() - startTime, toolId: id, ok: false, phase: "execute_throw", args, argsRaw: argsStr, argsSize: argsStr.length, output: out.output, outputSize: String(out.output ?? "").length, title: out.title, errorMessage: msg, resultMetadata: out.metadata, ctx: ctxInfo }); return out; } const endTime = Date.now(); const outStr = String(result?.output ?? ""); const isError = !!result?.metadata?.error; pushHistory({ time: startTime, durationMs: endTime - startTime, toolId: id, ok: !isError, phase: "execute", args, argsRaw: argsStr, argsSize: argsStr.length, output: outStr, outputSize: outStr.length, title: String(result?.title ?? ""), errorMessage: isError ? String(result?.metadata?.errorMessage ?? result?.output ?? "") : null, resultMetadata: result?.metadata ?? null, ctx: ctxInfo }); return result; } }; }4b:T50b,toolRegistry_history_filtered = (() => { const controls = toolRegistry_inspector_controls ?? {}; const tool = String(controls.tool ?? "(all)"); const onlyErrors = !!controls.onlyErrors; const q = String(controls.query ?? "") .trim() .toLowerCase(); const maxRows = Math.max( 10, Math.min(1000, Math.trunc(controls.maxRows ?? 200)) ); const rows = Array.isArray(toolRegistry_history) ? toolRegistry_history : []; const filtered = []; for (let i = rows.length - 1; i >= 0; i--) { const r = rows[i]; if (!r || typeof r !== "object") continue; if (tool !== "(all)" && String(r.toolId ?? "") !== tool) continue; if (onlyErrors && r.ok !== false) continue; if (q) { const hay = [ r.toolId, r.title, r.phase, r.errorMessage, r.argsRaw, typeof r.output === "string" ? r.output.slice(0, 10000) : String(r.output ?? ""), (() => { try { return JSON.stringify(r.resultMetadata ?? {}); } catch { return ""; } })() ] .join("\n") .toLowerCase(); if (!hay.includes(q)) continue; } filtered.push(r); if (filtered.length >= maxRows) break; } return filtered; })()4c:T79f,toolRegistry_stats = (() => { const rows = Array.isArray(toolRegistry_history) ? toolRegistry_history : []; const byTool = new Map(); let total = 0; let error = 0; let durSum = 0; let argsSum = 0; let outSum = 0; let ctxSum = 0; for (const r of rows) { if (!r || typeof r !== "object") continue; total++; const toolId = String(r.toolId ?? ""); const ok = r.ok !== false; if (!ok) error++; durSum += Number(r.durationMs ?? 0); argsSum += Number(r.argsSize ?? 0); outSum += Number(r.outputSize ?? 0); ctxSum += Number(r.ctx?.metadataSize ?? 0); const entry = byTool.get(toolId) ?? { toolId, calls: 0, errors: 0, durationMsSum: 0, argsSizeSum: 0, outputSizeSum: 0, ctxSizeSum: 0 }; entry.calls++; if (!ok) entry.errors++; entry.durationMsSum += Number(r.durationMs ?? 0); entry.argsSizeSum += Number(r.argsSize ?? 0); entry.outputSizeSum += Number(r.outputSize ?? 0); entry.ctxSizeSum += Number(r.ctx?.metadataSize ?? 0); byTool.set(toolId, entry); } const tools = [...byTool.values()] .map((t) => ({ ...t, errorRate: t.calls ? t.errors / t.calls : 0, avgDurationMs: t.calls ? t.durationMsSum / t.calls : 0, avgArgsBytes: t.calls ? t.argsSizeSum / t.calls : 0, avgOutputBytes: t.calls ? t.outputSizeSum / t.calls : 0, avgCtxBytes: t.calls ? t.ctxSizeSum / t.calls : 0 })) .sort((a, b) => b.calls - a.calls || a.toolId.localeCompare(b.toolId)); const overall = { total, tools: tools.length, errors: error, errorRate: total ? error / total : 0, avgDurationMs: total ? durSum / total : 0, avgArgsBytes: total ? argsSum / total : 0, avgOutputBytes: total ? outSum / total : 0, avgCtxBytes: total ? ctxSum / total : 0 }; const maxCalls = tools.reduce((m, t) => Math.max(m, t.calls), 0); return { overall, tools, maxCalls }; })()4d:Ta1d,listVariablesTool = defineTool({ id: "list_variables", description: "List runtime variables as canonical XML for a module.", parameters: { type: "object", properties: { module: { type: "string", description: "Module name to list." } }, required: ["module"], additionalProperties: false }, execute: async (args, ctx) => { const runtime = ctx?.runtime; if (!runtime) return { title: "list_variables", output: "Error: Observable runtime not found", metadata: { error: true } }; const requestedModule = String(args?.module ?? ""); const modules = ctx?.moduleMap; const moduleNameOf = (mod, info) => String((info?.name ?? mod?._name ?? "") || "").trim(); const availableModules = (() => { try { if (!(modules instanceof Map)) return []; const names = []; for (const [mod, info] of modules.entries()) { const n = moduleNameOf(mod, info); if (n) names.push(n); } return Array.from(new Set(names)).sort((a, b) => a.localeCompare(b)); } catch { return []; } })(); let targetModule = null; if (modules instanceof Map) { for (const [mod, info] of modules.entries()) { if (moduleNameOf(mod, info) === requestedModule) { targetModule = mod; break; } } } if (!targetModule) { const hint = `Module not found: "${requestedModule}". A module must be chosen.`; const sample = availableModules.slice(0, 25); return { title: "list_variables failed", output: `Error: ${hint}\n` + `Requested module: "${requestedModule}"\n` + (availableModules.length ? `Available modules (sample):\n` + sample.map((d) => `- ${d}`).join("\n") : `Available modules: (unavailable)`), metadata: { error: true, notFound: true, needsModuleSelection: true, requestedModule, availableModules } }; } const vars = []; for (const v of runtime._variables) { if (v._module !== targetModule) continue; if (v._name?.startsWith("dynamic ")) continue; // blows context up, TODO, surface them a better way vars.push(v); } const xml = await variablesXML(ctx, vars); return { title: `list_variables (${vars.length} variables)`, output: xml, metadata: { count: vars.length, module: requestedModule } }; } })4e:Te69,test_listVariablesTool = (async () => { const runtime = globalRuntime; const debug = { when: new Date().toISOString(), tool: "list_variables", requested: { module: "main" }, runtime: { exists: !!runtime, variablesType: runtime ? Object.prototype.toString.call(runtime._variables) : null, variablesIsIterable: runtime ? !!( runtime._variables && typeof runtime._variables[Symbol.iterator] === "function" ) : null, variablesLength: runtime && Array.isArray(runtime._variables) ? runtime._variables.length : null } }; let ctx; try { ctx = await createToolContext({ sessionId: "test", messageId: "test", agent: "assistant", callId: "test_listVariablesTool_lopecode_debug", runtime }); } catch (e) { debug.phase = "createToolContext"; debug.error = { message: String(e?.message ?? e), name: e?.name ?? null }; throw new Error( "listVariablesTool debug (createToolContext failed)\n" + JSON.stringify(debug, null, 2) ); } let modules; try { modules = await resolveRuntimeModules(runtime); const moduleNamesSample = []; if (modules instanceof Map) { for (const [mod, info] of modules.entries()) { const name = String((info?.name ?? mod?._name ?? "main") || "main").trim() || "main"; moduleNamesSample.push(name); if (moduleNamesSample.length >= 50) break; } } debug.modules = { resolvedType: Object.prototype.toString.call(modules), isMap: modules instanceof Map, size: typeof modules?.size === "number" ? modules.size : null, namesSample: moduleNamesSample }; } catch (e) { debug.phase = "resolveRuntimeModules"; debug.error = { message: String(e?.message ?? e), name: e?.name ?? null }; throw new Error( "listVariablesTool debug (resolveRuntimeModules failed)\n" + JSON.stringify(debug, null, 2) ); } try { const hasMain = modules instanceof Map && (() => { for (const [mod, info] of modules.entries()) { const n = String((info?.name ?? mod?._name ?? "") || "").trim(); if (n === "main") return true; } return false; })(); debug.detected = { hasMain }; const r = await listVariablesTool.execute({ module: "main" }, ctx); debug.result = { title: String(r?.title ?? ""), hasMetadataError: !!r?.metadata?.error, metadata: r?.metadata ?? null, outputPreview: summarizeJS(String(r?.output ?? ""), { max_size: 2000 }) }; if (hasMain) { if (r?.metadata?.error) throw new Error("tool returned metadata.error"); if (!String(r?.output ?? "").includes(" XML. Updates by id when possible; can create when allow_create=true.", parameters: { type: "object", properties: { xml: { type: "string", description: "XML string containing one or more elements" } }, required: ["xml"], additionalProperties: false }, execute: async (args, ctx) => { const runtime = ctx.runtime; if (!runtime) return { title: "upsert_variables", output: "Error: Observable runtime not found", metadata: { error: true } }; const xml = String(args?.xml ?? ""); let specs; try { specs = parseVariablesXML(xml); } catch (e) { return { title: "upsert_variables failed", output: "Error: Invalid XML: " + (e?.message ?? String(e)), metadata: { error: true } }; } const modules = await resolveRuntimeModules(runtime); const moduleByName = new Map(); for (const [mod, info] of modules.entries()) { const modName = (info?.name ?? mod?._name ?? "main").trim() || "main"; if (!moduleByName.has(modName)) moduleByName.set(modName, mod); } const resolveModuleByName = (requested) => { const r = String(requested ?? "").trim(); if (!r) return ( moduleByName.get("main") ?? [...moduleByName.values()][0] ?? null ); if (moduleByName.has(r)) return moduleByName.get(r); for (const [n, m] of moduleByName.entries()) if (n.includes(r) || r.includes(n)) return m; return null; }; const findVarById = (id) => { const want = String(id ?? ""); if (!want) return null; for (const v of runtime._variables) { if (!v) continue; if (v.id !== undefined && String(v.id) === want) return v; } return null; }; const normalizeInputName = (name) => { const s = String(name ?? "").trim(); if (!s) return ""; const i = s.lastIndexOf("#"); return i >= 0 ? s.slice(i + 1).trim() : s; }; const errors = []; const variables = []; for (const s of Array.isArray(specs) ? specs : []) { const modName = s.module; const targetModule = resolveModuleByName(modName); if (!targetModule) { errors.push({ id: s.id ?? "", name: s.name ?? null, module: modName, status: "error", error: "Module not found: " + modName }); continue; } const idStr = String(s.id ?? ""); const name = s.name === null ? null : String(s.name ?? ""); const inputs = (Array.isArray(s.inputs) ? s.inputs : []) .map(normalizeInputName) .filter((d) => String(d).trim()); const defSrc = String(s.definition ?? ""); let fn; try { fn = (await realize([defSrc], runtime))[0]; } catch (e) { errors.push({ id: idStr, name, module: modName, status: "error", error: "Bad definition: " + (e?.message ?? String(e)) }); continue; } let v = findVarById(idStr); if (!v) v = targetModule.variable({}); try { v.define(name, inputs, fn); variables.push(v); } catch (e) { errors.push({ id: idStr, name, module: modName, status: "error", error: e?.message ?? String(e) }); } } runtime._computeNow(); await new Promise((r) => setTimeout(r, 500)); const output = (await variablesXML(ctx, variables)) + "\n" + errors .map((r) => { const nm = r.name === null ? "(anonymous)" : r.name || "(unnamed)"; const idp = r.id ? `id=${r.id}` : "id=?"; const st = r.status || "unknown"; const err = r.status === "error" ? ` :: ${r.error || "error"}` : r.hasError ? ` :: ${r.error || "error"}` : ""; return `${r.module || "main"}#${nm} ${idp} [${st}]${err}`; }) .join("\n"); viewof lastUpserts.value = variables; viewof lastUpserts.dispatchEvent(new Event("input")); return { title: `upsert_variables (${variables.length} variables upserted, ${errors.length} errors)`, output: output, metadata: { count: variables.length, errors } }; } })50:T56b,test_upsertVariablesTool_imports = { test_tools_createModuleTool_registers_in_list_modules; const runtime = globalRuntime; const ctx = await createToolContext({ sessionId: "test", messageId: "test", agent: "assistant", callId: "test_upsertVariablesTool_imports", runtime }); const moduleByName = (name) => { const mods = ctx.moduleMap; if (!(mods instanceof Map)) return null; for (const [mod, info] of mods.entries()) { const n = String(info?.name ?? mod?._name ?? "").trim(); if (n === name) return mod; } return null; }; const mainModule = moduleByName("@robocoop/test-module"); if (!mainModule) throw new Error("main module not found"); const varName = "toObject"; const existing = mainModule._scope?.get?.(varName) ?? null; const xml = ` runtime.module((await import("@tomlarkworthy/runtime-sdk")).default)]]> module @tomlarkworthy/runtime-sdk, @variable v.import("toObject", _)]]> `; const result = await upsertVariablesTool.execute({ xml }, ctx); return result; }51:T8e2,deleteVariableTool = defineTool({ id: "delete_variable", description: 'Delete a runtime variable from the notebook runtime. Supports deleting named variables by name, and anonymous variables by id (pass the numeric id, as shown in list_variables/search_variables, in the "name" field).', parameters: { type: "object", properties: { name: { type: "string", description: "Variable name OR numeric variable id (from list_variables/search_variables). To delete an anonymous variable, pass its id here." } }, required: ["name"] }, execute: async (args, ctx) => { const runtime = ctx?.runtime; const needleRaw = String(args?.name ?? ""); const needle = needleRaw.trim(); if (!runtime) { return { title: "Delete variable: " + needle, output: "Error: Observable runtime not found", metadata: { error: true } }; } if (!needle) { return { title: "Delete variable", output: 'Error: "name" is required (variable name or numeric id)', metadata: { error: true } }; } const looksLikeId = /^\d+$/.test(needle); const matches = (v) => { if (!v || typeof v !== "object") return false; if (looksLikeId) return v.id !== undefined && String(v.id) === needle; return v._name === needle; }; for (const v of runtime._variables) { if (matches(v)) { const deleted = { id: v.id !== undefined ? String(v.id) : null, name: typeof v._name === "string" ? v._name : null, lookedUpBy: looksLikeId ? "id" : "name" }; v.delete(); return { title: "Delete variable: " + needle, output: `Deleted variable (${deleted.lookedUpBy}="${needle}")` + (deleted.name ? ` name="${deleted.name}"` : " (anonymous)") + (deleted.id ? ` id=${deleted.id}` : ""), metadata: deleted }; } } return { title: "Delete variable: " + needle, output: looksLikeId ? `Error: Variable not found by id: ${needle}` : `Error: Variable not found by name: ${needle}`, metadata: { error: true, lookedUpBy: looksLikeId ? "id" : "name" } }; } })52:T620,test_deleteVariableTool_deletes_anonymous_by_id = (async () => { test_tools_createModuleTool_registers_in_list_modules; const ctx = await createToolContext({ sessionId: "test", messageId: "test", agent: "assistant", callId: "test_deleteVariableTool_deletes_anonymous_by_id", runtime: globalRuntime }); const mainModule = (() => { const mods = ctx.moduleMap; if (!(mods instanceof Map)) return null; for (const [mod, info] of mods.entries()) { const n = String(info?.name ?? mod?._name ?? "").trim(); if (n === "@robocoop/test-module") return mod; } return null; })(); if (!mainModule) throw new Error("main module not found"); const v = mainModule.variable({}); v.define(null, [], () => "temp"); id(v); if (typeof v.id !== "number" && !/^\d+$/.test(String(v.id))) throw new Error("expected anonymous variable to have an id"); const varId = String(v.id); const res = await deleteVariableTool.execute({ name: varId }, ctx); if (res?.metadata?.error) throw new Error("delete_variable failed: " + res.output); if (res?.metadata?.lookedUpBy !== "id") throw new Error( "expected lookedUpBy=id, got: " + JSON.stringify(res?.metadata) ); const stillThere = (() => { const vars = globalRuntime._variables; if (vars && typeof vars.has === "function") return vars.has(v); for (const x of vars) if (x === v) return true; return false; })(); if (stillThere) throw new Error("expected variable to be deleted from runtime"); return "pass"; })()53:T4ed,listModulesTool = defineTool({ id: "list_modules", description: "List all modules loaded in the notebook runtime.", parameters: { type: "object", properties: {}, required: [] }, execute: async (_args, ctx) => { const runtime = ctx.runtime; if (!runtime) { return { title: "List modules", output: "Error: Observable runtime not found", metadata: { error: true } }; } const modules = await resolveRuntimeModules(runtime); const counts = new Map(); for (const [mod, info] of modules.entries()) { const name = (info?.name ?? mod?._name ?? "main").trim() || "main"; counts.set(mod, { name, variables: 0, title: info.title }); } for (const v of runtime._variables) { if (!v?._module || !v?._name) continue; const entry = counts.get(v._module); if (entry) entry.variables++; } const moduleList = [...counts.values()].sort((a, b) => a.name.localeCompare(b.name) ); return { title: "List modules (" + moduleList.length + " found)", output: moduleList .map((m) => `${m.name} (${m.variables} variables) '${m.title}'`) .join("\n"), metadata: { count: moduleList.length, modules: moduleList } }; } })54:Tb6c,createModuleTool = defineTool({ id: "create_module", description: "Create a new module in the notebook runtime with a given name.", parameters: { type: "object", properties: { name: { type: "string", description: 'Name of the module to create (e.g. "my-module").' }, allow_existing: { type: "boolean", description: "If true, return ok when a module with this name already exists." } }, required: ["name", "allow_existing"], additionalProperties: false }, execute: async (args, ctx) => { const runtime = ctx.runtime; if (!runtime) { return { title: "create_module", output: "Error: Observable runtime not found", metadata: { error: true } }; } const name = String(args?.name ?? "").trim(); const allowExisting = !!args?.allow_existing; if (!name) { return { title: "create_module", output: "Error: name is required", metadata: { error: true } }; } const ensureMains = () => { if (runtime.mains instanceof Map) return runtime.mains; const m = new Map(); try { if (runtime.mains && typeof runtime.mains === "object") { for (const [k, v] of Object.entries(runtime.mains)) m.set(k, v); } } catch {} runtime.mains = m; return m; }; const modules = await resolveRuntimeModules(runtime); const moduleNameOf = (mod, info) => String((info?.name ?? mod?._name ?? "main") || "main").trim() || "main"; for (const [mod, info] of modules.entries()) { if (moduleNameOf(mod, info) === name) { if (!allowExisting) { return { title: `create_module (${name})`, output: `Error: Module already exists: ${name}`, metadata: { error: true, exists: true, name } }; } try { ensureMains().set(name, mod); } catch {} return { title: `create_module (${name})`, output: `Module already exists: ${name}`, metadata: { name, exists: true } }; } } let mod; try { mod = runtime.module(() => {}, null); } catch (e) { return { title: `create_module (${name})`, output: "Error: Failed to create module: " + String(e?.message ?? e), metadata: { error: true } }; } try { mod._name = name; } catch {} try { ensureMains().set(name, mod); } catch {} try { modules.set(mod, { ...(modules.get(mod) ?? {}), name }); } catch {} try { if (ctx.moduleMap && typeof ctx.moduleMap.set === "function") { ctx.moduleMap.set(mod, { ...(ctx.moduleMap.get(mod) ?? {}), name }); } } catch {} return { title: `create_module (${name})`, output: `Created module: ${name}`, metadata: { name, exists: false } }; } })55:T843,runTestsTool = defineTool({ id: "run_tests", description: "Run all reachable test_* variables in the notebook and return results.", parameters: { type: "object", properties: { filter: { type: "string", description: 'Filter to match test names. Use "" to run all tests.' } }, required: ["filter"], additionalProperties: false }, execute: async (args, ctx) => { const filter = String(args?.filter ?? ""); const runtime = ctx.runtime; if (!runtime) { return { title: "Run tests", output: "Error: Observable runtime not found", metadata: { error: true } }; } const testVars = []; for (const v of runtime._variables) { if (!v?._reachable) continue; if (typeof v._name === "string" && v._name.startsWith("test_")) { if (filter && !v._name.includes(filter)) continue; testVars.push(v); } } if (testVars.length === 0) { return { title: "Run tests", output: filter ? `No reachable tests found matching "${filter}"` : "No reachable test_* variables found", metadata: { count: 0 } }; } const results = testVars.map((v) => ({ name: v._name, reachable: !!v._reachable, hasValue: v._value !== undefined, hasError: v._error !== undefined, value: v._value !== undefined ? String(v._value).slice(0, 100) : null, error: v._error?.message })); const passed = results.filter((r) => r.hasValue && !r.hasError).length; const failed = results.filter((r) => r.hasError).length; const pending = results.length - passed - failed; const symbol = (r) => r.hasError ? "\u2717 " : r.hasValue ? "\u2713 " : "\u2026 "; return { title: `Run tests (${passed}/${results.length} passed${ pending ? `, ${pending} pending` : "" })`, output: results .map((r) => symbol(r) + r.name + (r.error ? ": " + r.error : "")) .join("\n"), metadata: { total: results.length, passed, failed, pending, results } }; } })56:T31f6,evalTool = defineTool({ id: "eval", description: "Evaluate a JavaScript expression, optionally scoped to a runtime variable by {module, variable_id_or_name}. If the expression evaluates to a function, it will be applied to the variable value; otherwise the expression result is returned. In all cases, the final result is summarized with summarizeJS. Can be used for exploring state, DOM context, and simulating interactions", parameters: { type: "object", properties: { code: { type: "string", description: "JavaScript expression to evaluate (may evaluate to a function)." }, module: { type: "string", description: 'Module name to scope variable lookup to (e.g. "main"). Use "" to auto-resolve by name (prefers main when ambiguous).' }, variable_id_or_name: { type: "string", description: 'Runtime variable identifier. If it looks like an integer, treated as an internal variable id; otherwise treated as a variable name. Use "" for no target variable.' } }, required: ["code", "module", "variable_id_or_name"], additionalProperties: false }, execute: async (args, ctx) => { const runtime = ctx?.runtime ?? globalRuntime; if (!runtime) { return { title: "Eval", output: "Error: Observable runtime not found", metadata: { error: true } }; } const TIMEOUT_MS = 30_000; const withTimeout = async ( promiseLike, { label = "operation", signal } = {} ) => { const p = Promise.resolve(promiseLike); let timer = null; const timeout = new Promise((_, reject) => { timer = setTimeout(() => { reject( new Error( `Eval ${label} timed out after ${Math.round(TIMEOUT_MS / 1000)}s` ) ); }, TIMEOUT_MS); }); const aborted = signal ? new Promise((_, reject) => { if (signal.aborted) reject(new Error(`Eval ${label} aborted`)); else signal.addEventListener( "abort", () => reject(new Error(`Eval ${label} aborted`)), { once: true } ); }) : null; try { return await Promise.race( aborted ? [p, timeout, aborted] : [p, timeout] ); } finally { if (timer !== null) clearTimeout(timer); } }; const code = String(args?.code ?? ""); const moduleRequestedRaw = String(args?.module ?? ""); const idOrNameRaw = String(args?.variable_id_or_name ?? ""); const modules = await resolveRuntimeModules(runtime); const moduleNameOf = (mod) => (modules.get(mod)?.name ?? mod?._name ?? "main").trim() || "main"; const moduleByName = new Map(); for (const [mod, info] of modules.entries()) { const modName = (info?.name ?? mod?._name ?? "main").trim() || "main"; if (!moduleByName.has(modName)) moduleByName.set(modName, mod); } const resolveModuleByName = (requested) => { const r = String(requested ?? "").trim(); if (!r) return null; if (moduleByName.has(r)) return moduleByName.get(r); for (const [n, m] of moduleByName.entries()) if (n.includes(r) || r.includes(n)) return m; return null; }; const findVarById = (idStr) => { const want = String(idStr ?? "").trim(); if (!want) return null; for (const v of runtime._variables) { if (!v) continue; if (v.id !== undefined && String(v.id) === want) return v; } return null; }; const findVarByNameInModule = (name, targetModule) => { if (!targetModule) return null; try { if (targetModule._scope?.has(name)) { const candidate = targetModule._scope.get(name); if (candidate && runtime._variables?.has(candidate)) return candidate; } } catch {} for (const v of runtime._variables) if (v?._name === name && v?._module === targetModule) return v; return null; }; const autoResolveVarByName = (name) => { const matches = []; for (const v of runtime._variables) if (v?._name === name) matches.push(v); const reachable = matches.filter((v) => v?._reachable); const candidates = reachable.length ? reachable : matches; const mainModule = moduleByName.get("main") ?? null; const mainVar = mainModule ? findVarByNameInModule(name, mainModule) : null; if (mainVar) return { v: mainVar, resolvedModuleName: "main" }; if (candidates.length === 1) return { v: candidates[0], resolvedModuleName: moduleNameOf(candidates[0]._module) }; if (candidates.length === 0) return { v: null, resolvedModuleName: null }; const mods = Array.from( new Set(candidates.map((v) => moduleNameOf(v._module))) ).sort(); return { v: null, resolvedModuleName: null, ambiguous: true, modules: mods }; }; const readVarValue = async (v) => { if (!v) return { state: "fulfilled", value: undefined }; if (v._error !== undefined) return { state: "rejected", error: v._error }; if (v._value !== undefined) return { state: "fulfilled", value: v._value }; let snap; try { snap = await withTimeout(getPromiseStateCrossRealm(v._promise), { label: "getPromiseState", signal: ctx?.abort }); } catch (e) { return { state: "rejected", error: e }; } if (snap?.state === "fulfilled" && "fulfilled" in snap) return { state: "fulfilled", value: snap.fulfilled }; if (snap?.state === "rejected") return { state: "rejected", error: snap.rejected }; return { state: "pending" }; }; let targetVar = null; let resolvedModuleName = null; const idOrName = idOrNameRaw.trim(); if (idOrName) { const looksLikeId = /^\d+$/.test(idOrName); if (looksLikeId) { targetVar = findVarById(idOrName); if (!targetVar) { return { title: "Eval", output: `Error: Variable id not found: ${idOrName}`, metadata: { error: true, notFound: true, kind: "id", variable_id_or_name: idOrName } }; } resolvedModuleName = moduleNameOf(targetVar._module); const moduleRequested = moduleRequestedRaw.trim(); if (moduleRequested) { const targetModule = resolveModuleByName(moduleRequested); if (!targetModule) { return { title: "Eval", output: `Error: Module not found: ${moduleRequested}`, metadata: { error: true, notFound: true, module: moduleRequested } }; } if (targetVar._module !== targetModule) { return { title: "Eval", output: `Error: Variable id ${idOrName} exists in module "${resolvedModuleName}", not in requested module "${moduleNameOf( targetModule )}".`, metadata: { error: true, moduleMismatch: true, resolvedModule: resolvedModuleName, requestedModule: moduleNameOf(targetModule), variable_id_or_name: idOrName } }; } } } else { const moduleRequested = moduleRequestedRaw.trim(); if (moduleRequested) { const targetModule = resolveModuleByName(moduleRequested); if (!targetModule) { return { title: "Eval", output: `Error: Module not found: ${moduleRequested}`, metadata: { error: true, notFound: true, module: moduleRequested } }; } resolvedModuleName = moduleNameOf(targetModule); targetVar = findVarByNameInModule(idOrName, targetModule); if (!targetVar) { return { title: "Eval", output: `Error: Variable not found in module ${resolvedModuleName}: ${idOrName}`, metadata: { error: true, notFound: true, module: resolvedModuleName, name: idOrName } }; } } else { const auto = autoResolveVarByName(idOrName); if (auto?.ambiguous) { return { title: "Eval", output: `Error: Ambiguous variable name "${idOrName}" exists in multiple modules.\n` + `Provide {module}. Candidates:\n` + (auto.modules ?? []).map((m) => `- ${m}`).join("\n"), metadata: { error: true, ambiguous: true, name: idOrName, modules: auto.modules ?? [] } }; } targetVar = auto.v; resolvedModuleName = auto.resolvedModuleName; if (!targetVar) { return { title: "Eval", output: `Error: Variable not found: ${idOrName}`, metadata: { error: true, notFound: true, name: idOrName } }; } } } } const valueState = await readVarValue(targetVar); if (valueState.state === "pending") { return { title: "Eval", output: "pending", metadata: { pending: true, state: "pending", module: resolvedModuleName, variable_id_or_name: idOrName || null } }; } if (valueState.state === "rejected") { const msg = String( valueState.error?.message ?? valueState.error ?? "Unknown error" ); return { title: "Eval", output: "Error: " + msg, metadata: { error: true, state: "rejected", errorMessage: msg, module: resolvedModuleName, variable_id_or_name: idOrName || null } }; } const targetValue = valueState.value; const moduleObj = targetVar?._module ?? null; const expr = code.trim(); if (!expr) { return { title: "Eval", output: summarizeJS(targetValue, { max_size: 1000 }), metadata: { type: typeof targetValue, applied: false, module: resolvedModuleName, variable_id_or_name: idOrName || null } }; } let evaluated; try { evaluated = new Function( "value", "variable", "module", "runtime", `return (${expr});` )(targetValue, targetVar, moduleObj, runtime); } catch (e) { return { title: "Eval", output: "Error: " + (e?.message ?? String(e)), metadata: { error: true, phase: "parse_eval", variable_id_or_name: idOrName || null, module: resolvedModuleName } }; } let result = evaluated; let applied = false; if (typeof evaluated === "function") { applied = true; try { result = evaluated(targetValue, { variable: targetVar, module: moduleObj, moduleName: resolvedModuleName, runtime, ctx }); if (result && typeof result.then === "function") { result = await withTimeout(result, { label: "function result", signal: ctx?.abort }); } } catch (e) { return { title: "Eval", output: "Error: " + (e?.message ?? String(e)), metadata: { error: true, phase: "apply", variable_id_or_name: idOrName || null, module: resolvedModuleName } }; } } else if (evaluated && typeof evaluated.then === "function") { try { result = await withTimeout(evaluated, { label: "promise result", signal: ctx?.abort }); } catch (e) { return { title: "Eval", output: "Error: " + (e?.message ?? String(e)), metadata: { error: true, phase: "await", variable_id_or_name: idOrName || null, module: resolvedModuleName } }; } } return { title: "Eval", output: summarizeJS(result, { max_size: 1000 }), metadata: { type: typeof result, applied, module: resolvedModuleName, variable_id_or_name: idOrName || null } }; } })57:Tb38,searchVariablesTool = defineTool({ id: "search_variables", description: "Search runtime variables (including anonymous variables) for text in name/definition/string-value, and return matches as canonical XML. Returns at most 100 matches.", parameters: { type: "object", properties: { query: { type: "string", description: "Text to search for" }, limit: { type: "number", description: "Maximum number of results (clamped to 100; use 20 if unsure)" } }, required: ["query", "limit"], additionalProperties: false }, execute: async (args, ctx) => { const query = String(args?.query ?? ""); const queryTrim = query.trim(); const rawLimit = Number.isFinite(args?.limit) ? args.limit : 20; const limit = Math.max(1, Math.min(100, Math.trunc(rawLimit || 20))); const runtime = ctx.runtime; if (!runtime) { return { title: "Search variables: " + queryTrim, output: "", metadata: { error: true } }; } if (!queryTrim) { return { title: "Search variables", output: "", metadata: { count: 0, matches: [] } }; } const modules = await resolveRuntimeModules(runtime); const moduleNameFor = (v) => (modules.get(v?._module)?.name ?? v?._module?._name ?? "main").trim() || "main"; const q = queryTrim.toLowerCase(); const matches = []; const vars = []; for (const v of runtime._variables) { if (!v || typeof v !== "object") continue; let matchReason = null; if (typeof v._name === "string" && v._name.toLowerCase().includes(q)) { matchReason = "name"; } if ( !matchReason && v._definition && typeof v._definition === "function" ) { const defStr = v._definition.toString(); if (defStr.toLowerCase().includes(q)) matchReason = "definition"; } if (!matchReason && typeof v._value === "string") { if (v._value.toLowerCase().includes(q)) matchReason = "value"; } if (!matchReason) continue; matches.push({ module: moduleNameFor(v), name: typeof v._name === "string" ? v._name : null, matchReason, hasValue: v._value !== undefined, hasError: v._error !== undefined, reachable: !!v._reachable }); vars.push(v); if (matches.length >= limit) break; } if (matches.length === 0) { return { title: `Search variables: ${queryTrim} (0 found)`, output: "", metadata: { count: 0, matches: [] } }; } const xml = await variablesXML(ctx, vars); return { title: `Search variables: ${queryTrim} (${matches.length} found)`, output: xml, metadata: { count: matches.length, limit, matches } }; } })58:[] 30:{"id":"f6794ed0523241c3","slug":"robocoop-3","title":"robocoop3: agents-as-functions","thumbnail":"f9cdaf0f15174af7023e59b4bb423beb593e2540f326023fd43337392f70c458","access_level":"unlisted","create_time":"$D2026-01-20T22:17:47.345Z","update_time":"$D2026-08-09T17:11:55.052Z","view_time":null,"first_public_time":null,"has_unpublished_edits":null,"fork":true,"stars":2,"starred":false,"owner":{"type":"team","id":"7db5ed2b0697d645","login":"tomlarkworthy","name":"Tom Larkworthy","avatar_url":"https://avatars-next.observableusercontent.com/47327a8bc1966f2186dcb3ebf4b7ee6e4e7ab9a5c2a07405aff57200ea778f71","tier":"starter_2024","bio":"Tech Lead at Taktile.\nFormerly Firebase, Google"},"version":1995,"publish_version":null,"role":null,"authored":false,"authors":[{"type":"individual","id":"5215f6ec4a999d40","login":"tomlarkworthy","name":"Tom Larkworthy","avatar_url":"https://avatars-next.observableusercontent.com/47327a8bc1966f2186dcb3ebf4b7ee6e4e7ab9a5c2a07405aff57200ea778f71","tier":null,"bio":"Tech Lead at Taktile. ex Firebase, Google.\n🦋 larkworthy.bsky.social"}],"members":[{"type":"individual","id":"5215f6ec4a999d40","login":"tomlarkworthy","name":"Tom Larkworthy","avatar_url":"https://avatars-next.observableusercontent.com/47327a8bc1966f2186dcb3ebf4b7ee6e4e7ab9a5c2a07405aff57200ea778f71","tier":null,"role":"editor"},{"type":"team","id":"7db5ed2b0697d645","login":"tomlarkworthy","name":"Tom Larkworthy","avatar_url":"https://avatars-next.observableusercontent.com/47327a8bc1966f2186dcb3ebf4b7ee6e4e7ab9a5c2a07405aff57200ea778f71","tier":"starter_2024","role":"editor"}],"comments":[],"custom_thumbnail":true,"trashed":false,"lapsed":null,"subscribed":null,"forks":0,"collection":{"id":"cf72f19f55f3a048","slug":"lopebook","title":"lopecode","owner":{"id":"7db5ed2b0697d645","login":"tomlarkworthy","name":"Tom Larkworthy"}},"type":"notebook","body":{"titling":"auto","title":"robocoop3: agents-as-functions","cells":[{"id":947,"value":"# `robocoop3`: agents-as-functions\n\n```js\nimport {robocoop3} from \"@tomlarkworthy/robocoop-3\"\n```","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":1109,"value":"viewof agent1 = robocoop3({\n prompt: \"Are you working?\",\n systemPrompt: \"Respond like a pirate\",\n maxSteps: 1\n})","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1503,"value":"Calling `viewof agent = robocoop3({...})` creates a prompting UI and an in-notebook agent whose responses are streamed to the value of `agent`. You can create many such agents at-once. The function is essentially the agentic loop expressed as a generator.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":1493,"value":"agent1","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1512,"value":"## Features\n\n- Multiple providers: OpenAI, Anthropic and Ollama (for local operation). There is a demo provider that will run `gpt5-mini` so you can try it out.\n- Parallel tool calling\n- Multi-turn dialogue.\n- Test driven development.\n- Operates on Observable's low level runtime representation directly, not Notebook 1.0 syntax (unlike Robocoop-2, which is still useful for high level coding assistance).\n- Scriptable\n- Also works in [Lopecode](https://observablehq.com/@tomlarkworthy/jumpgate?source=https://observablehq.com/@tomlarkworthy/robocoop-3&export_state=%7B%22hash%22%3A%22%23view%3D%40tomlarkworthy%2Frobocoop-3%22%2C%22headless%22%3Atrue%2C%22title%22%3A%22%40tomlarkworthy%2Frobocoop-3%22%7D&git_url=https%3A%2F%2Fgithub.com%2Ftomlarkworthy%2Flopebooks&load_source=true&commit=false)\n","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":1832,"value":"## TODO\n- Struggles a bit with imports, I think we should support defining variables that reference other modules and lazily auto-import\n- Include a screenshot of the DOM if its a DOM node or image?","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":1120,"value":"## Builder Function","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":1103,"value":"$32","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1757,"value":"## Prompt","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":195,"value":"$33","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1775,"value":"## TDD","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":1777,"value":"test_cell_map_coverage = {\n expect(coverage_failures).toEqual([]);\n return \"all variables can be decompiled into higher level cells\";\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1114,"value":"## Templating\n\nThe template extracts a prototype into a reusable component","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":1105,"value":"import { cloneViaSandbox } from \"@tomlarkworthy/dataflow-templating\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1104,"value":"$34","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":232,"value":"currentModules","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":543,"value":"## UI","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":555,"value":"$35","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":488,"value":"viewof agent_ui_attached = Inputs.toggle({\n label: \"decompose (detach sub-views)?\",\n value: false\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":578,"value":"### agent","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":481,"value":"viewof agent_prompt = Inputs.textarea({\n width: \"100%\",\n rows: 10,\n submit: true,\n minlength: 1,\n placeholder:\n \"Describe the change you want. The loop will run tests and feed failures back until they pass (or maxSteps).\"\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":989,"value":"agent_run_effect = (async () => {\n if (!agent_prompt || !String(agent_prompt).trim()) return this || 0;\n await agent_run({ prompt: agent_prompt, reset: false });\n return (this || 0) + 1;\n})()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":486,"value":"agent_cancel_effect = agent_cancel && (agent_loop.cancel(), agent_cancel)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":482,"value":"viewof agent_cancel = Inputs.button(\"Cancel\", { value: 0, reduce: v => v + 1 })","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":985,"value":"viewof agent_clear = Inputs.button(\"Clear\", { value: 0, reduce: (v) => v + 1 })","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":987,"value":"agent_clear_effect = agent_clear &&\n (() => {\n try {\n agent_loop?.cancel?.();\n } catch {}\n try {\n agent_loop?.reset?.();\n } catch {}\n mutable agent_records = [];\n mutable agent_run_history = [];\n return agent_clear;\n })()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":659,"value":"### execution state","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":1862,"value":"viewof agent_runtime = Inputs.input(globalRuntime)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":940,"value":"robocoopPrototype_record_stream = (() => {\n const records = Array.isArray(agent_records) ? agent_records : [];\n const prev = this && typeof this === \"object\" ? this : null;\n const prevLen = prev && Number.isFinite(prev.len) ? prev.len : 0;\n return { len: records.length, delta: records.length - prevLen };\n})()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":664,"value":"mutable agent_records = []","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1029,"value":"appendAgentRecord = (records, rec, now = Date.now()) => {\n const arr = Array.isArray(records) ? records : [];\n const r = { time: now, ...(rec ?? {}) };\n const last = arr.length ? arr[arr.length - 1] : null;\n\n if (last && last.type === r.type) {\n if (r.type === \"text\") {\n last.chunk = String(last.chunk ?? \"\") + String(r.chunk ?? \"\");\n last.time = r.time;\n return arr;\n }\n if (\n r.type === \"tool_use_delta\" &&\n String(last.id ?? \"\") === String(r.id ?? \"\")\n ) {\n last.chunk = String(last.chunk ?? \"\") + String(r.chunk ?? \"\");\n last.time = r.time;\n return arr;\n }\n }\n\n arr.push(r);\n return arr;\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":666,"value":"mutable agent_run_history = []","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":686,"value":"$36","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":688,"value":"agent_conversation = (() => {\n const recs = Array.isArray(agent_records) ? agent_records : [];\n const convo = agentConversationFromRecords(recs);\n const latestRun =\n Array.isArray(agent_run_history) && agent_run_history.length\n ? agent_run_history[0]\n : null;\n const run = latestRun\n ? {\n id: latestRun.id ?? null,\n provider: latestRun.provider ?? null,\n startedAt: latestRun.startedAt ?? null,\n endedAt: latestRun.endedAt ?? null,\n tokens: latestRun.tokens ?? null,\n prompt: latestRun.prompt ?? null,\n reply: agent_reply,\n stop: agent_stop\n }\n : {\n id: null,\n provider: null,\n startedAt: null,\n endedAt: null,\n tokens: null,\n prompt: null,\n reply: agent_reply,\n stop: agent_stop\n };\n return { ...convo, run };\n})()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":694,"value":"$37","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":700,"value":"agent_conversation_dom_sync = {\n agent_conversation_view_holder.innerHTML = \"\";\n agent_conversation_view_holder.appendChild(agent_conversation_view);\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":697,"value":"agent_conversation_view_holder = html`

`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":690,"value":"$38","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":614,"value":"### models","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":610,"value":"open_ai_models = [\"gpt-5.2\", \"gpt-5.1\", \"gpt-5\", \"gpt-5-mini\", \"gpt-5-nano\"]","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":616,"value":"anthropic_models = [\"claude-opus-4-5\", \"claude-haiku-4-5\", \"claude-sonnet-4-5\"]","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":564,"value":"### providers","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":472,"value":"viewof provider_choice = Inputs.bind(\n Inputs.select(\n new Map([\n [\"Demo (OpenAI proxy, no auth)\", \"demo\"],\n [\"OpenAI (Responses API)\", \"openai\"],\n [\"Anthropic (Messages API)\", \"anthropic\"],\n [\"Ollama (OpenAI-compatible Chat Completions)\", \"ollama\"]\n ]),\n { label: \"provider\", value: \"openai\" }\n ),\n localStorageView(\"provider_choice\", { defaultValue: \"demo\" })\n)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":548,"value":"viewof OPENAI_API_KEY = Inputs.bind(\n Inputs.password({\n width: \"100%\",\n label: \"OPENAI_API_KEY\",\n placeholder: \"paste openAI key here\"\n }),\n localStorageView(\"OPENAI_API_KEY\")\n)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":550,"value":"viewof ANTHROPIC_API_KEY = Inputs.bind(\n Inputs.password({\n width: \"100%\",\n label: \"ANTHROPIC_API_KEY\",\n placeholder: \"paste openAI key here\"\n }),\n localStorageView(\"ANTHROPIC_API_KEY\")\n)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1861,"value":"#### OpenAI","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":552,"value":"viewof provider_openai_config = Inputs.bind(\n Inputs.form({\n modelId: Inputs.select(open_ai_models, {\n label: \"model\",\n width: \"100%\",\n value: \"gpt-5-mini\"\n }),\n baseUrl: Inputs.text({\n label: \"baseUrl\",\n width: \"100%\",\n value: \"https://api.openai.com/v1\"\n }),\n max_output_tokens: Inputs.number({\n label: \"max_output_tokens\",\n min: 128,\n max: 8192,\n step: 128,\n value: 2048\n })\n }),\n localStorageView(\"provider_openai_config\", {\n json: true,\n defaultValue: {\n modelId: \"gpt-5-mini\",\n baseUrl: \"https://api.openai.com/v1\",\n max_output_tokens: 2048\n }\n })\n)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":77,"value":"openaiProvider = ({ apiKey, baseUrl = \"https://api.openai.com/v1\" } = {}) => ({\n id: \"openai\",\n baseUrl,\n headers: () => {\n const h = { \"Content-Type\": \"application/json\" };\n const key = String(apiKey ?? \"\").trim();\n if (key) h.Authorization = `Bearer ${key}`;\n return h;\n },\n responsesEndpoint: `${baseUrl}/responses`\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1059,"value":"$39","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":478,"value":"$3a","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1859,"value":"#### Anthropic","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":553,"value":"viewof provider_anthropic_config = Inputs.bind(\n Inputs.form({\n modelId: Inputs.select(anthropic_models, {\n label: \"model\",\n width: \"100%\",\n value: \"claude-sonnet-4-5\"\n }),\n baseUrl: Inputs.text({\n label: \"baseUrl\",\n width: \"100%\",\n value: \"https://api.anthropic.com/v1\"\n }),\n version: Inputs.text({\n label: \"anthropic-version\",\n width: \"100%\",\n value: \"2023-06-01\"\n }),\n max_tokens: Inputs.number({\n label: \"max_tokens\",\n min: 256,\n max: 8192,\n step: 128,\n value: 4096\n })\n }),\n localStorageView(\"provider_anthropic_config\", {\n json: true,\n defaultValue: {\n modelId: \"claude-sonnet-4-5\",\n baseUrl: \"https://api.anthropic.com/v1\",\n version: \"2023-06-01\",\n max_tokens: 4096\n }\n })\n)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":24,"value":"anthropicProvider = ({apiKey, baseUrl = 'https://api.anthropic.com/v1', version = '2023-06-01'}) => ({\n id: 'anthropic',\n baseUrl,\n headers: () => ({\n 'x-api-key': apiKey,\n 'anthropic-version': version,\n 'anthropic-dangerous-direct-browser-access': 'true',\n 'Content-Type': 'application/json'\n }),\n messagesEndpoint: baseUrl + '/messages'\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":479,"value":"$3b","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1043,"value":"$3c","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1076,"value":"#### Ollama\n\nOn macOS with the Ollama app: \n\n export OLLAMA_ORIGINS=\"*\"\n ollama serve\n\nverify CORS\n\n curl -X OPTIONS http://localhost:11434 \\\n -H \"Origin: http://example.com\" \\\n -H \"Access-Control-Request-Method: GET\" -I \n \nTesting locally first\n\n ollama pull qwen2.5:7b\n\n curl http://localhost:11434/api/tags\n\n curl -X POST http://localhost:11434/v1/chat/completions \\\n -H \"Content-Type: application/json\" \\\n -d '{ \n \"model\": \"qwen2.5:7b\",\n \"messages\": [{\"role\": \"user\", \"content\": \"hello\"}]\n }'","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":1054,"value":"ollamaProvider = ({\n apiKey = \"\",\n baseUrl = \"http://localhost:11434/v1\"\n} = {}) => {\n const b = String(baseUrl ?? \"\").replace(/\\/+$/, \"\");\n const key = String(apiKey ?? \"\");\n return {\n id: \"ollama\",\n baseUrl: b,\n headers: () => {\n const h = { \"Content-Type\": \"application/json\" };\n if (key) h.Authorization = `Bearer ${key}`;\n return h;\n },\n chatCompletionsEndpoint: `${b}/chat/completions`\n };\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1061,"value":"$3d","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1041,"value":"### Agent config","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":475,"value":"$3e","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1066,"value":"$3f","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":657,"value":"$40","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1070,"value":"test_normalizeUsage_openai_chat_completions_usage = {\n const u = normalizeUsage(\n { prompt_tokens: 10, completion_tokens: 5, total_tokens: 15 },\n \"ollama\"\n );\n if (u.input !== 10 || u.output !== 5 || u.total !== 15)\n throw new Error(\"bad normalizeUsage: \" + JSON.stringify(u));\n return \"pass\";\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":649,"value":"## Example Provider Data","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":651,"value":"$41","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":633,"value":"## Code","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":476,"value":"agent_target_module = \"main\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":477,"value":"agent_system_prompt = [\n String(agent_config?.systemPrompt ?? \"\"),\n \"\",\n \"Operational note:\",\n `- Prefer editing variables in module: \"${String(agent_target_module)}\"`,\n `- Active provider: \"${String(provider_choice ?? \"\")}\"`\n].join(\"\\n\")","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":487,"value":"$42","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1032,"value":"test_appendAgentRecord_coalesces_text = {\n const records = [];\n appendAgentRecord(records, { type: \"text\", chunk: \"hel\" }, 1);\n appendAgentRecord(records, { type: \"text\", chunk: \"lo\" }, 2);\n if (records.length !== 1)\n throw new Error(\"expected 1 record, got \" + records.length);\n if (records[0].chunk !== \"hello\")\n throw new Error(\"expected hello, got \" + records[0].chunk);\n if (records[0].time !== 2)\n throw new Error(\"expected merged time to update to latest\");\n return \"pass\";\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1034,"value":"test_appendAgentRecord_coalesces_tool_use_delta_by_id = {\n const records = [];\n appendAgentRecord(\n records,\n { type: \"tool_use_delta\", id: \"c1\", chunk: \"{\" },\n 1\n );\n appendAgentRecord(\n records,\n { type: \"tool_use_delta\", id: \"c1\", chunk: '\"a\"' },\n 2\n );\n appendAgentRecord(\n records,\n { type: \"tool_use_delta\", id: \"c2\", chunk: \"X\" },\n 3\n );\n appendAgentRecord(\n records,\n { type: \"tool_use_delta\", id: \"c1\", chunk: \":1}\" },\n 4\n );\n\n if (records.length !== 3)\n throw new Error(\"expected 3 records, got \" + records.length);\n if (records[0].chunk !== '{\"a\"')\n throw new Error(\"unexpected merged chunk for c1: \" + records[0].chunk);\n if (records[1].id !== \"c2\" || records[1].chunk !== \"X\")\n throw new Error(\"unexpected middle record\");\n if (records[2].id !== \"c1\" || records[2].chunk !== \":1}\")\n throw new Error(\"should not merge non-adjacent deltas\");\n return \"pass\";\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":967,"value":"agent_reply = (text) => agent_run({ prompt: String(text ?? \"\"), reset: false })","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":969,"value":"agent_stop = () => agent_loop.cancel()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":78,"value":"$43","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":59,"value":"toolRegistry = createToolRegistry()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1005,"value":"toolRegistry_sync = (() => {\n const prevIds = new Set(toolRegistry.ids());\n const nextIds = new Set(\n (Array.isArray(allTools) ? allTools : [])\n .map((t) => String(t?.id ?? \"\"))\n .filter(Boolean)\n );\n\n for (const t of Array.isArray(allTools) ? allTools : []) {\n if (t && typeof t === \"object\" && typeof t.id === \"string\" && t.id)\n toolRegistry.register(t);\n }\n\n for (const id of prevIds) {\n if (!nextIds.has(id)) toolRegistry.unregister(id);\n }\n\n return { tools: nextIds.size };\n})()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":60,"value":"$44","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":7,"value":"generateId = () => crypto.randomUUID()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":8,"value":"createUserMessage = ({sessionId, agent, providerId, modelId, system, tools}) => ({\n id: generateId(),\n sessionId,\n role: 'user',\n time: { created: Date.now() },\n agent,\n model: {\n providerId,\n modelId\n },\n system,\n tools\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":9,"value":"createAssistantMessage = ({sessionId, parentId, agent, providerId, modelId}) => ({\n id: generateId(),\n sessionId,\n role: 'assistant',\n time: {\n created: Date.now(),\n completed: null\n },\n parentId,\n agent,\n providerId,\n modelId,\n error: null,\n cost: 0,\n tokens: {\n input: 0,\n output: 0,\n reasoning: 0,\n cache: {\n read: 0,\n write: 0\n }\n },\n finish: null\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":10,"value":"test_opencode_generateId = {\n const id = generateId();\n if (typeof id !== 'string' || id.length < 30)\n throw new Error('bad id: ' + typeof id);\n return 'pass';\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":11,"value":"test_opencode_createUserMessage = {\n const msg = createUserMessage({\n sessionId: 'test',\n agent: 'user',\n providerId: 'anthropic',\n modelId: 'claude'\n });\n if (!msg.id || msg.role !== 'user')\n throw new Error('failed: ' + JSON.stringify(msg));\n return 'pass';\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":12,"value":"test_opencode_createAssistantMessage = {\n const msg = createAssistantMessage({\n sessionId: 'test',\n parentId: 'p1',\n agent: 'assistant',\n providerId: 'anthropic',\n modelId: 'claude'\n });\n if (!msg.id || msg.role !== 'assistant')\n throw new Error('failed');\n return 'pass';\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":17,"value":"createTextPart = ({sessionId, messageId, text, synthetic = false}) => ({\n id: generateId(),\n sessionId,\n messageId,\n type: 'text',\n text,\n synthetic,\n time: {\n start: Date.now(),\n end: null\n }\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":18,"value":"createReasoningPart = ({sessionId, messageId, text}) => ({\n id: generateId(),\n sessionId,\n messageId,\n type: 'reasoning',\n text,\n time: {\n start: Date.now(),\n end: null\n }\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":19,"value":"toolStatePending = (input, raw = '') => ({\n status: 'pending',\n input,\n raw\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":20,"value":"toolStateRunning = (input, title = null) => ({\n status: 'running',\n input,\n title,\n metadata: {},\n time: { start: Date.now() }\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":21,"value":"toolStateCompleted = ({input, output, title, metadata = {}, startTime}) => ({\n status: 'completed',\n input,\n output,\n title,\n metadata,\n time: {\n start: startTime,\n end: Date.now()\n }\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":22,"value":"toolStateError = ({input, error, startTime}) => ({\n status: 'error',\n input,\n error,\n metadata: {},\n time: {\n start: startTime,\n end: Date.now()\n }\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":23,"value":"createToolPart = ({sessionId, messageId, callId, tool, state}) => ({\n id: generateId(),\n sessionId,\n messageId,\n type: 'tool',\n callId,\n tool,\n state,\n metadata: {}\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":25,"value":"parseSSEStream = async (stream, onEvent, signal) => {\n const reader = stream.getReader();\n const decoder = new TextDecoder();\n let buffer = '';\n try {\n while (true) {\n if (signal?.aborted)\n break;\n const {done, value} = await reader.read();\n if (done)\n break;\n buffer += decoder.decode(value, { stream: true });\n const lines = buffer.split('\\n');\n buffer = lines.pop() || '';\n for (const line of lines) {\n if (line.startsWith('data: ')) {\n const data = line.slice(6);\n if (data === '[DONE]')\n return;\n try {\n onEvent(JSON.parse(data));\n } catch {\n }\n }\n }\n }\n } finally {\n reader.releaseLock();\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":26,"value":"$45","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":27,"value":"completeAssistantMessage = (message, {finish, tokens, cost}) => ({\n ...message,\n time: {\n ...message.time,\n completed: Date.now()\n },\n finish,\n tokens: tokens || message.tokens,\n cost: cost ?? message.cost\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":28,"value":"createStepStartPart = ({sessionId, messageId}) => ({\n id: generateId(),\n sessionId,\n messageId,\n type: 'step-start'\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":29,"value":"createStepFinishPart = ({sessionId, messageId, reason, tokens, cost}) => ({\n id: generateId(),\n sessionId,\n messageId,\n type: 'step-finish',\n reason,\n cost,\n tokens\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":30,"value":"createMessageWithParts = (info, parts = []) => ({\n info,\n parts\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":31,"value":"addPart = (messageWithParts, part) => ({\n ...messageWithParts,\n parts: [\n ...messageWithParts.parts,\n part\n ]\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":32,"value":"updatePart = (messageWithParts, partId, updates) => ({\n ...messageWithParts,\n parts: messageWithParts.parts.map(p => p.id === partId ? {\n ...p,\n ...updates\n } : p)\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":33,"value":"createConversation = ({id} = {}) => ({\n id: id || generateId(),\n messages: [],\n created: Date.now()\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":34,"value":"addMessage = (conversation, messageWithParts) => ({\n ...conversation,\n messages: [\n ...conversation.messages,\n messageWithParts\n ]\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":35,"value":"isToolPart = part => part?.type === 'tool'","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":36,"value":"updateToolPart = (message, callId, updates) => ({\n ...message,\n parts: message.parts.map(p => isToolPart(p) && p.callId === callId ? {\n ...p,\n ...updates\n } : p)\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":37,"value":"conversationToMessages = conversation => conversation.messages.map(msg => {\n const role = msg.info.role;\n if (role === 'user') {\n const textParts = msg.parts.filter(p => p.type === 'text');\n return {\n role: 'user',\n content: textParts.map(p => p.text).join('\\n')\n };\n } else if (role === 'assistant') {\n return {\n role: 'assistant',\n parts: msg.parts\n };\n }\n return {\n role,\n content: ''\n };\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":237,"value":"### Context","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":239,"value":"resolveRuntimeModules = async (runtime) => {\n const rt = runtime ?? globalRuntime;\n\n if (rt === globalRuntime) {\n return viewof currentModules.value;\n }\n\n return await moduleMap(rt);\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":719,"value":"id = {\n let guid = 0;\n return (v) => v.id || (v.id = guid++);\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":858,"value":"cdata = (s) => `\", \"]]]]>\")}]]>`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":710,"value":"$46","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":763,"value":"function parseVariablesXML(text) {\n text = `${text}`;\n const doc = new DOMParser().parseFromString(text, \"application/xml\");\n if (doc.getElementsByTagName(\"parsererror\").length) {\n const err = doc.querySelector(\"parsererror\");\n console.log(err.textContent);\n throw err;\n }\n debugger;\n return [...doc.documentElement.getElementsByTagName(\"variable\")].map((el) => {\n const module = el.getAttribute(\"module\") || \"\";\n const id = el.getAttribute(\"id\") || \"\";\n const name = el.getAttribute(\"name\") || null;\n\n const inputsText = el.querySelector(\"inputs\")?.textContent?.trim() || \"\";\n const inputs = inputsText\n ? inputsText.split(/\\s*,\\s*/).filter(Boolean)\n : [];\n\n const definition = el.querySelector(\"definition\")?.textContent || \"\";\n const value = el.querySelector(\"value\")?.textContent || \"\";\n\n return { module, id, name, inputs, definition, value };\n });\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":747,"value":"viewof robocoopPrototypeModule = thisModule()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":750,"value":"idVariable = {\n id;\n return lookupVariable(\"id\", robocoopPrototypeModule);\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1582,"value":"importVariable = lookupVariable(\"moduleMap\", robocoopPrototypeModule)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1596,"value":"currentModules.get(importVariable._inputs[0]._module)","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":754,"value":"test_variablesXML_smoke = {\n const ctx = await createToolContext({\n sessionId: \"test\",\n messageId: \"test\",\n agent: \"assistant\",\n callId: \"test_list_variables_default_reachable_only\",\n runtime: globalRuntime\n });\n return variablesXML(ctx, [idVariable]);\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1585,"value":"test_variablesXML_importVariable = {\n const ctx = await createToolContext({\n sessionId: \"test\",\n messageId: \"test\",\n agent: \"assistant\",\n callId: \"test_list_variables_default_reachable_only\",\n runtime: globalRuntime\n });\n const importDesc = await variablesXML(ctx, [importVariable]);\n if (!importDesc.includes(\"@tomlarkworthy/module-map#moduleMap\"))\n throw \"can't find import\";\n\n return importDesc;\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1713,"value":"expected_error = {\n throw \"myError\";\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1716,"value":"test_variablesXML_erroredVariable = {\n const ctx = await createToolContext({\n sessionId: \"test\",\n messageId: \"test\",\n agent: \"assistant\",\n callId: \"test_list_variables_default_reachable_only\",\n runtime: globalRuntime\n });\n const variable = await lookupVariable(\n \"expected_error\",\n robocoopPrototypeModule\n );\n const importDesc = await variablesXML(ctx, [variable]);\n if (!importDesc.includes(\"myError\")) throw \"can't find error\";\n\n return importDesc;\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":767,"value":"test_parseVariablesXML_smoke = {\n return parseVariablesXML(\"yo\" + test_variablesXML_smoke);\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":235,"value":"## Tools\n\nNote OpenAI: 'required' is required to be supplied and to be an array including every key in properties.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":1233,"value":"$47","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":14,"value":"$48","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":15,"value":"createToolContext = async ({\n sessionId,\n messageId,\n agent,\n callId,\n abort,\n runtime = globalRuntime\n}) => {\n let currentMetadata = {};\n return {\n sessionId,\n messageId,\n agent,\n callId: callId || generateId(),\n abort: abort || new AbortController().signal,\n runtime,\n metadata(update) {\n currentMetadata = {\n ...currentMetadata,\n ...update\n };\n },\n moduleMap: await resolveRuntimeModules(runtime),\n getMetadata() {\n return currentMetadata;\n }\n };\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":141,"value":"$49","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":142,"value":"$4a","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1209,"value":"## Tool history","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":1211,"value":"mutable toolRegistry_history = []","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1213,"value":"viewof toolRegistry_recording = Inputs.toggle({\n label: \"Record tool calls (global)\",\n value: true\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1215,"value":"viewof toolRegistry_history_limit = Inputs.range([50, 5000], {\n label: \"History limit\",\n step: 50,\n value: 1000\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1221,"value":"toolRegistry_tool_ids = (toolRegistry_sync,\ntoolRegistry\n .ids()\n .map(String)\n .filter(Boolean)\n .sort((a, b) => a.localeCompare(b)))","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1223,"value":"viewof toolRegistry_inspector_controls = Inputs.form({\n tool: Inputs.select([\"(all)\", ...toolRegistry_tool_ids], {\n label: \"Tool\",\n value: \"(all)\"\n }),\n onlyErrors: Inputs.toggle({ label: \"Only errors\", value: false }),\n query: Inputs.text({\n label: \"Search (args/output/metadata)\",\n width: \"100%\",\n value: \"\"\n }),\n maxRows: Inputs.number({\n label: \"Max rows\",\n min: 10,\n max: 1000,\n step: 10,\n value: 200\n })\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1225,"value":"viewof toolRegistry_clear_history = Inputs.button(\"Clear tool call history\", {\n value: 0,\n reduce: (v) => v + 1\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1227,"value":"toolRegistry_clear_history_effect = toolRegistry_clear_history &&\n ((mutable toolRegistry_history = []), toolRegistry_clear_history)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1229,"value":"$4b","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1231,"value":"$4c","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1369,"value":"## Tool Implementation","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":216,"value":"allTools = [...variableTools, ...runtimeTools]","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":790,"value":"### variable tools","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":44,"value":"variableTools = [listVariablesTool, upsertVariablesTool, deleteVariableTool]","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1853,"value":"#### listVariables","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":780,"value":"$4d","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1405,"value":"$4e","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1850,"value":"#### upsertVariables","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":783,"value":"$4f","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1939,"value":"viewof lastUpserts = Inputs.input()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1615,"value":"$50","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1634,"value":"{\n lastUpserts;\n debugger;\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1925,"value":"test_upsertVariablesTool_imports.output","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1706,"value":"## scrap","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":1640,"value":"viewof m = thisModule()","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1674,"value":"v = m.variable()","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1681,"value":"acornModule = [...currentModules.values()].find((m) => m.name.includes(\"acorn\"))","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1689,"value":"foreignInput = acornModule.module._scope.get(\"acorn\")","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1855,"value":"#### deleteVariables","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":42,"value":"$51","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1768,"value":"$52","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":792,"value":"#### runtime tools","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":49,"value":"runtimeTools = [\n listModulesTool,\n createModuleTool,\n runTestsTool,\n evalTool,\n searchVariablesTool\n]","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":45,"value":"$53","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1422,"value":"test_listModulesTool_smoke = {\n const ctx = await createToolContext({\n sessionId: \"test\",\n messageId: \"test\",\n agent: \"assistant\",\n callId: \"test_tools_createModuleTool_registers_in_list_modules\",\n runtime: globalRuntime\n });\n return (await listModulesTool.execute({}, ctx)).output;\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1132,"value":"$54","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1135,"value":"test_tools_createModuleTool_registers_in_list_modules = (async () => {\n const ctx = await createToolContext({\n sessionId: \"test\",\n messageId: \"test\",\n agent: \"assistant\",\n callId: \"test_tools_createModuleTool_registers_in_list_modules\",\n runtime: globalRuntime\n });\n\n const name = \"@robocoop/test-module\";\n\n const r = await createModuleTool.execute({ name, allow_existing: true }, ctx);\n if (r?.metadata?.error) throw new Error(\"create_module failed: \" + r.output);\n\n const latest = await moduleMap(globalRuntime);\n viewof currentModules.value = latest;\n viewof currentModules.dispatchEvent(new Event(\"input\"));\n await new Promise((res) => setTimeout(res, 0));\n\n const lm = await listModulesTool.execute({}, ctx);\n if (lm?.metadata?.error) throw new Error(\"list_modules failed: \" + lm.output);\n\n if (!String(lm.output ?? \"\").includes(`${name} (`)) {\n throw new Error(\n \"expected module to appear in list_modules output; got:\\n\" + lm.output\n );\n }\n\n return \"pass\";\n})()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":46,"value":"$55","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":47,"value":"$56","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":980,"value":"test_tools_evalTool_expression_no_target = (async () => {\n const ctx = await createToolContext({\n sessionId: \"test\",\n messageId: \"test\",\n agent: \"assistant\",\n callId: \"test_tools_evalTool_expression_no_target\",\n runtime: globalRuntime\n });\n const r = await evalTool.execute(\n { code: \"1+2\", module: \"\", variable_id_or_name: \"\" },\n ctx\n );\n if (r.metadata?.error) throw new Error(\"unexpected error: \" + r.output);\n if (String(r.output).trim() !== \"3\")\n throw new Error(\"expected 3, got: \" + r.output);\n return \"pass\";\n})()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1564,"value":"robocoop3_random_value = \"a\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":983,"value":"test_tools_evalTool_apply_function_to_variable_value = (async () => {\n const ctx = await createToolContext({\n sessionId: \"test\",\n messageId: \"test\",\n agent: \"assistant\",\n callId: \"test_tools_evalTool_apply_function_to_variable_value\",\n runtime: globalRuntime\n });\n const match = test_search_variables_includes_module.metadata.matches.find(\n (m) => m.name == \"robocoop3_random_value\"\n );\n const r = await evalTool.execute(\n {\n code: \"(v)=>v.toUpperCase()\",\n module: match.module,\n variable_id_or_name: \"robocoop3_random_value\"\n },\n ctx\n );\n if (r.metadata?.error) throw new Error(\"unexpected error: \" + r.output);\n if (!String(r.output).includes(\"A\"))\n throw new Error(\"expected A in output, got: \" + r.output);\n return \"pass\";\n})()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":48,"value":"$57","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":434,"value":"test_search_variables_includes_module = (async () => {\n const ctx = await createToolContext({\n sessionId: \"test\",\n messageId: \"test\",\n agent: \"assistant\",\n callId: \"test_search_variables_includes_module\",\n runtime: globalRuntime\n });\n\n const r = await searchVariablesTool.execute(\n { query: \"robocoop3_random_value\", limit: 10 },\n ctx\n );\n const matches = r?.metadata?.matches ?? [];\n if (!Array.isArray(matches) || matches.length === 0)\n throw new Error(\"expected at least one match\");\n\n const first = matches[0];\n if (typeof first.module !== \"string\" || !first.module.length)\n throw new Error(\"expected match to include module\");\n if (typeof first.name !== \"string\" || !first.name.length)\n throw new Error(\"expected match to include name\");\n\n return r;\n})()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1542,"value":"## Dependancies","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":1772,"value":"import { coverage_failures } from \"@tomlarkworthy/cell-map\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":184,"value":"import {\n runtime as globalRuntime,\n getPromiseState,\n getPromiseStateCrossRealm,\n lookupVariable,\n thisModule,\n keepalive,\n observe,\n realize\n} from \"@tomlarkworthy/runtime-sdk\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":5,"value":"import { robocoop2 } from \"@tomlarkworthy/robocoop-2\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":296,"value":"import { summarizeJS } from \"@tomlarkworthy/summarizejs\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":226,"value":"import { moduleMap, viewof currentModules } from \"@tomlarkworthy/module-map\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":458,"value":"import { reversibleAttach } from \"@tomlarkworthy/reversible-attachment\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":461,"value":"import { localStorageView } from \"@tomlarkworthy/local-storage-view\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":540,"value":"import { modern_screenshot } from \"@tomlarkworthy/modern-screenshot\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":591,"value":"import { tabbedPane } from \"@tomlarkworthy/tabbed-pane-view\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":899,"value":"import { cellsToClipboard } from \"@tomlarkworthy/cells-to-clipboard\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1784,"value":"import { expect } from \"@tomlarkworthy/jest-expect-standalone\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":1807,"value":"robocoop2()","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"}],"files":"$W58","stdlib":"1"}} 31:"$30:body"