[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_391":392,"_393":394},"routes/_app.x.$handle.$name",{"_99":98,"_31":44,"_108":89,"_26":109,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_20":-5,"_120":-5,"_121":-5,"_122":24,"_123":124,"_125":58,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_31":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":24},"version",56,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","lib/url_security.ts","latestPath","fileId","a612ca68-aa08-11f1-b25d-1607ee4eb77e","name","url_security.ts","fileType","script","content","import type { BrowserTask } from \"./types.ts\";\n\ntype DnsAnswer = { name?: string; type?: number; data?: string };\ntype DnsJson = { Status?: number; Answer?: DnsAnswer[] };\n\nconst BLOCKED_HOST_NAMES = new Set([\n \"localhost\",\n \"localhost.localdomain\",\n \"metadata.google.internal\",\n \"metadata\",\n]);\n\nfunction stripBrackets(host: string): string {\n return host.startsWith(\"[\") && host.endsWith(\"]\") ? host.slice(1, -1) : host;\n}\n\nfunction parseIpv4(value: string): number[] | null {\n const parts = value.split(\".\");\n if (parts.length !== 4) return null;\n const nums = parts.map((p) => Number(p));\n if (nums.some((n) => !Number.isInteger(n) || n < 0 || n > 255)) return null;\n return nums;\n}\n\nexport function isNonPublicIp(value: string): boolean {\n const ip = stripBrackets(value.trim().toLowerCase());\n const v4 = parseIpv4(ip);\n if (v4) {\n const [a, b, c] = v4;\n if (a === 0 || a === 10 || a === 127 || a >= 224) return true;\n if (a === 100 && b >= 64 && b <= 127) return true;\n if (a === 169 && b === 254) return true;\n if (a === 172 && b >= 16 && b <= 31) return true;\n if (a === 192 && b === 0 && c === 0) return true;\n if (a === 192 && b === 0 && c === 2) return true;\n if (a === 192 && b === 168) return true;\n if (a === 198 && (b === 18 || b === 19)) return true;\n if (a === 198 && b === 51 && c === 100) return true;\n if (a === 203 && b === 0 && c === 113) return true;\n return false;\n }\n\n if (ip.includes(\":\")) {\n if (ip === \"::\" || ip === \"::1\") return true;\n if (ip.startsWith(\"fc\") || ip.startsWith(\"fd\")) return true;\n if (/^fe[89ab]/.test(ip)) return true;\n if (ip.startsWith(\"ff\")) return true;\n if (ip.startsWith(\"2001:db8\")) return true;\n const mapped = ip.match(/::ffff:(\\d+\\.\\d+\\.\\d+\\.\\d+)$/);\n if (mapped) return isNonPublicIp(mapped[1]);\n return false;\n }\n\n return false;\n}\n\nfunction blockedHostname(hostname: string): boolean {\n const host = stripBrackets(hostname.toLowerCase().replace(/\\.$/, \"\"));\n if (BLOCKED_HOST_NAMES.has(host)) return true;\n if (host.endsWith(\".localhost\") || host.endsWith(\".local\") || host.endsWith(\".internal\") || host.endsWith(\".home.arpa\")) return true;\n if (isNonPublicIp(host)) return true;\n return false;\n}\n\nasync function doh(hostname: string, type: \"A\" | \"AAAA\"): Promise {\n const url = new URL(\"https://cloudflare-dns.com/dns-query\");\n url.searchParams.set(\"name\", hostname);\n url.searchParams.set(\"type\", type);\n const response = await fetch(url, {\n headers: { accept: \"application/dns-json\" },\n signal: AbortSignal.timeout(5_000),\n });\n if (!response.ok) throw new Error(`DoH ${type} failed with HTTP ${response.status}`);\n return await response.json() as DnsJson;\n}\n\nexport async function resolvePublicIps(hostname: string): Promise {\n const host = stripBrackets(hostname.toLowerCase().replace(/\\.$/, \"\"));\n if (blockedHostname(host)) throw new Error(`blocked hostname: ${host}`);\n if (parseIpv4(host) || host.includes(\":\")) return [host];\n\n const [a, aaaa] = await Promise.all([doh(host, \"A\"), doh(host, \"AAAA\")]);\n const answers = [...(a.Answer ?? []), ...(aaaa.Answer ?? [])];\n const ips = answers\n .filter((x) => x.type === 1 || x.type === 28)\n .map((x) => String(x.data ?? \"\"))\n .filter(Boolean);\n\n if (ips.length === 0) throw new Error(`no A/AAAA records resolved for ${host}`);\n const blocked = ips.filter(isNonPublicIp);\n if (blocked.length) throw new Error(`hostname ${host} resolved to blocked IP(s): ${blocked.join(\", \")}`);\n return [...new Set(ips)];\n}\n\nexport async function assertSafeUrl(value: string): Promise<{ url: string; host: string; ips: string[] }> {\n const url = new URL(value);\n if (![\"http:\", \"https:\"].includes(url.protocol)) throw new Error(\"only http/https URLs are allowed\");\n if (url.username || url.password) throw new Error(\"URL userinfo is blocked\");\n if (url.port && ![\"80\", \"443\"].includes(url.port)) throw new Error(`nonstandard port blocked: ${url.port}`);\n if (blockedHostname(url.hostname)) throw new Error(`blocked hostname: ${url.hostname}`);\n const ips = await resolvePublicIps(url.hostname);\n return { url: url.toString(), host: url.hostname, ips };\n}\n\nexport async function preflightTaskNetwork(task: BrowserTask) {\n const checked: Array<{ host: string; ips: string[] }> = [];\n const seen = new Set();\n\n const checkUrl = async (value: string) => {\n const result = await assertSafeUrl(value);\n if (!seen.has(result.host)) {\n seen.add(result.host);\n checked.push({ host: result.host, ips: result.ips });\n }\n };\n\n await checkUrl(task.targetUrl);\n for (const step of task.steps) {\n if (step.action === \"goto\" && step.url) await checkUrl(step.url);\n }\n for (const host of task.allowedHosts ?? []) {\n const clean = host.trim().toLowerCase();\n if (!clean || clean.includes(\"/\") || clean.includes(\"://\") || clean.includes(\"@\")) throw new Error(`invalid allowedHost: ${host}`);\n await checkUrl(`https://${clean}/`);\n }\n\n return checked;\n}\n","createdAt",["D",1788708954762],"branchVersion","branchId","22a6b9fb-662c-4823-89b0-7ec510c82fcd","id","1cb1fea8-3811-42e9-b0ad-3a5ec2d20472","chat-native-maestro",["D",1788707065045],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Cloud runtime for ChatGPT-native orchestration","imageUrl","6cc24525-830b-4db3-9c9c-fd19fb50e91f","pinnedFileId","3fca0dce-aa04-11f1-bd83-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0773d-9d6b-7580-a53a-683363c351c8","tursoName","1cb1fea8381142e9b0ad3a5ec2d20472","tursoHostname","1cb1fea8381142e9b0ad3a5ec2d20472-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789488693443],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_99":98,"_107":103},"org",{"_99":98,"_100":101,"_102":103,"_18":54,"_104":105,"_106":24},"branch",{"_13":88,"_31":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"isOwned",68,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","cleitoncosta","handle","displayName","Cleiton Costa","avatar","https://lh3.googleusercontent.com/a/ACg8ocIgWisWQiXts_2fy5iRiRgl8A6c7Ef94eqE3ur-4mlyUrpCBmQ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_31":44,"_37":386,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":387,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":388,"_83":389,"_85":390,"_87":24},"tree",[223,229,236,240,241,242,243,244,245,246],"files",[223,224,225,226,227,228,229,230,231,232,233,234,235,236,237,238,239,240,241,242,243,244,245,246],"counts",{"_213":62,"_214":171,"_215":62,"_216":217,"_218":219},"contents",[130,131,132,133,134,135,136,137,138,139],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":207,"_31":208,"_29":209,"_143":-5,"_40":41,"_39":210,"_145":58,"_37":211,"_13":62,"_33":200,"_35":-5,"_23":24,"_149":-5,"_26":212},{"_42":202,"_31":203,"_29":204,"_143":-5,"_40":41,"_39":163,"_145":58,"_37":205,"_13":62,"_33":200,"_35":-5,"_23":24,"_149":-5,"_26":206},{"_42":196,"_31":197,"_29":198,"_143":-5,"_40":41,"_39":171,"_145":58,"_37":199,"_13":62,"_33":200,"_35":-5,"_23":24,"_149":-5,"_26":201},{"_42":189,"_31":190,"_29":191,"_143":-5,"_40":41,"_39":192,"_145":24,"_37":193,"_13":147,"_33":20,"_35":194,"_23":24,"_149":-5,"_26":195},{"_42":182,"_31":183,"_29":184,"_143":-5,"_40":41,"_39":185,"_145":24,"_37":186,"_13":147,"_33":34,"_35":187,"_23":24,"_149":-5,"_26":188},{"_42":174,"_31":175,"_29":56,"_143":-5,"_40":41,"_39":176,"_145":58,"_37":177,"_13":178,"_33":179,"_35":180,"_23":24,"_149":-5,"_26":181},{"_42":166,"_31":167,"_29":168,"_143":-5,"_40":41,"_39":169,"_145":24,"_37":170,"_13":171,"_33":34,"_35":172,"_23":24,"_149":-5,"_26":173},{"_42":158,"_31":159,"_29":160,"_143":-5,"_40":41,"_39":161,"_145":58,"_37":162,"_13":163,"_33":34,"_35":164,"_23":24,"_149":-5,"_26":165},{"_42":151,"_31":152,"_29":153,"_143":-5,"_40":41,"_39":154,"_145":58,"_37":155,"_13":62,"_33":34,"_35":156,"_23":24,"_149":-5,"_26":157},{"_42":140,"_31":141,"_29":142,"_143":-5,"_40":41,"_39":144,"_145":24,"_37":146,"_13":147,"_33":34,"_35":148,"_23":24,"_149":-5,"_26":150},"ca080fdb-e409-4078-8ec5-2c5f74141142","status.ts","9fd401be-aa06-11f1-9ea0-1607ee4eb77e","parentId",50,"latest",["D",1788708816646],1,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { providerState } from \"./providers/router.ts\";\nimport { getProviderHealth } from \"./lib/provider_health.ts\";\nimport { POLICY } from \"./lib/policy.ts\";\nimport { COST_NOTES } from \"./lib/cost.ts\";\n\nconst counts = await sqlite.execute(\"SELECT status, COUNT(*) AS count FROM browser_tasks GROUP BY status ORDER BY status\");\nconst census = await sqlite.execute(\"SELECT provider, priority, state, recurring_free, notes, updated_at FROM provider_census ORDER BY priority\");\nconst recent = await sqlite.execute(\"SELECT run_id,status,provider,attempt_count,error,updated_at FROM browser_tasks ORDER BY id DESC LIMIT 10\");\nconst attemptMetrics = await sqlite.execute(`\n SELECT provider,status,COUNT(*) AS attempts,\n CAST(AVG(duration_ms) AS INTEGER) AS avg_duration_ms,\n COALESCE(SUM(estimated_units),0) AS estimated_units\n FROM browser_attempts\n GROUP BY provider,status\n ORDER BY provider,status\n`);\n\nconst result = {\n service: \"chat-native-maestro\",\n version: POLICY.version,\n status: \"ready\",\n authenticatedDiagnostic: true,\n providers: providerState(),\n providerHealth: await getProviderHealth(),\n taskCounts: counts.rows,\n providerCensus: census.rows,\n attemptMetrics: attemptMetrics.rows,\n recentReceipts: recent.rows,\n policy: POLICY,\n costNotes: COST_NOTES,\n environmentRequirements: {\n kernel: \"KERNEL_API_KEY\",\n browserless: \"BROWSERLESS_TOKEN\",\n },\n automaticSchedule: \"disabled\",\n timestamp: new Date().toISOString(),\n};\n\nconsole.log(JSON.stringify(result, null, 2));\n","label",[141],"4520b4a0-ebf6-43a6-bde0-821b5a87e971","stateful_selftest.ts","02391064-aa08-11f1-b31d-1607ee4eb77e",47,["D",1788708679858],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { decideDisposition, withTimeout } from \"./lib/policy.ts\";\nimport { providerAvailable, recordProviderOutcome } from \"./lib/provider_health.ts\";\nimport type { BrowserReceipt } from \"./lib/types.ts\";\n\nconst now = new Date().toISOString();\nconst syntheticFail = (n: number): BrowserReceipt => ({\n runId: `circuit-selftest-${n}`,\n provider: \"kernel\",\n status: \"FAIL\",\n error: `synthetic failure ${n}`,\n durationMs: 1,\n});\n\nlet timeoutBlocked = false;\ntry {\n await withTimeout(new Promise((resolve) => setTimeout(resolve, 50)), 5, \"synthetic timeout\");\n} catch (error) {\n timeoutBlocked = String(error).includes(\"timed out\");\n}\n\nconst dispositions = {\n readOnlyFirstFail: decideDisposition(\"read_only\", \"FAIL\", 1),\n readOnlyBudgetExhausted: decideDisposition(\"read_only\", \"FAIL\", 2),\n writeFail: decideDisposition(\"consequential\", \"FAIL\", 1),\n};\n\nlet circuitAfterThree: unknown;\nlet availableAfterThree: unknown;\ntry {\n await sqlite.execute({\n sql: `UPDATE provider_health SET circuit_state='CLOSED', consecutive_failures=0, open_until=NULL,\n last_success_at=NULL,last_failure_at=NULL,last_error=NULL,updated_at=? WHERE provider='kernel'`,\n args: [now],\n });\n await recordProviderOutcome(\"kernel\", syntheticFail(1));\n await recordProviderOutcome(\"kernel\", syntheticFail(2));\n await recordProviderOutcome(\"kernel\", syntheticFail(3));\n circuitAfterThree = (await sqlite.execute(\"SELECT provider,circuit_state,consecutive_failures,open_until FROM provider_health WHERE provider='kernel'\")).rows[0];\n availableAfterThree = await providerAvailable(\"kernel\");\n} finally {\n await sqlite.execute({\n sql: `UPDATE provider_health SET circuit_state='CLOSED', consecutive_failures=0, open_until=NULL,\n last_success_at=NULL,last_failure_at=NULL,last_error=NULL,updated_at=? WHERE provider='kernel'`,\n args: [new Date().toISOString()],\n });\n}\n\nconsole.log(JSON.stringify({\n version: \"0.5.0\",\n timeoutBlocked,\n dispositions,\n circuitAfterThree,\n availableAfterThree,\n restoredKernelHealth: (await sqlite.execute(\"SELECT provider,circuit_state,consecutive_failures,open_until FROM provider_health WHERE provider='kernel'\")).rows[0],\n}, null, 2));\n",[152],"28ff8473-39df-4272-8946-a28042188764","selftest.ts","226bfbf6-aa05-11f1-8f4b-1607ee4eb77e",44,["D",1788708610657],2,"import { validateTask } from \"./lib/dsl.ts\";\nimport { providerState } from \"./providers/router.ts\";\nimport { POLICY } from \"./lib/policy.ts\";\nimport { getProviderHealth } from \"./lib/provider_health.ts\";\n\nconst validRead = {\n runId: \"selftest-read-v05\",\n targetUrl: \"https://example.com\",\n risk: \"read_only\" as const,\n purpose: \"Validate V0.5 DSL without opening a browser\",\n evidenceRetention: \"minimal\" as const,\n steps: [{ action: \"expect_text\" as const, text: \"Example Domain\" }],\n};\n\nconst blockedWrite = {\n runId: \"selftest-write-v05\",\n targetUrl: \"https://example.com\",\n risk: \"consequential\" as const,\n approved: false,\n purpose: \"Negative control for approval gate\",\n steps: [{ action: \"click\" as const, selector: \"button\" }],\n};\n\nconst blockedSecret = {\n runId: \"selftest-secret-v05\",\n targetUrl: \"https://example.com\",\n risk: \"read_only\" as const,\n approved: false,\n purpose: \"Negative control for secret resolution gate\",\n steps: [{ action: \"fill_secret\" as const, selector: \"#password\", envVar: \"EXAMPLE_PASSWORD\" }],\n};\n\nconst invalidProvider = {\n ...validRead,\n runId: \"selftest-provider-v05\",\n preferredProvider: \"imaginary-provider\" as any,\n};\n\nconst blockedValueExtraction = {\n ...validRead,\n runId: \"selftest-value-v05\",\n steps: [{ action: \"extract_attribute\" as const, selector: \"#password\", attribute: \"value\", key: \"password\" }],\n};\n\nconst result = {\n version: POLICY.version,\n validReadErrors: validateTask(validRead),\n blockedWriteErrors: validateTask(blockedWrite),\n blockedSecretErrors: validateTask(blockedSecret),\n invalidProviderErrors: validateTask(invalidProvider),\n blockedValueExtractionErrors: validateTask(blockedValueExtraction),\n providers: providerState(),\n providerHealth: await getProviderHealth(),\n policy: POLICY,\n expected: {\n validReadErrors: [],\n blockedWriteContains: \"NEEDS_APPROVAL\",\n blockedSecretContains: \"NEEDS_SECRET_APPROVAL\",\n invalidProviderContains: \"invalid preferredProvider\",\n valueExtractionBlocked: true,\n providersConfigured: false,\n },\n};\n\nconsole.log(JSON.stringify(result, null, 2));\n",[159],"0dcdd0ab-5bcb-439b-b60f-8fb50cc22aab","runner.ts","46aa03fa-aa05-11f1-b85b-1607ee4eb77e",49,["D",1788708794913],3,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type { BrowserReceipt, BrowserTask } from \"./lib/types.ts\";\nimport { validateTask } from \"./lib/dsl.ts\";\nimport { executeRouted } from \"./providers/router.ts\";\nimport { decideDisposition, POLICY } from \"./lib/policy.ts\";\nimport { estimateProviderUnits } from \"./lib/cost.ts\";\n\nasync function recoverStaleLeases() {\n const staleBefore = new Date(Date.now() - POLICY.runningLeaseMs).toISOString();\n const now = new Date().toISOString();\n await sqlite.batch([\n {\n sql: `UPDATE browser_tasks SET status='FAIL', claimed_at=NULL, next_attempt_at=NULL,\n error='stale running lease; retry budget exhausted', updated_at=?\n WHERE status='RUNNING' AND claimed_at IS NOT NULL AND claimed_at=?`,\n args: [now, staleBefore, POLICY.maxAttemptsPerTask],\n },\n {\n sql: `UPDATE browser_tasks SET status='PENDING', claimed_at=NULL, next_attempt_at=?,\n error='stale running lease recovered', updated_at=?\n WHERE status='RUNNING' AND claimed_at IS NOT NULL AND claimed_at | undefined;\n}\n\nfunction storageReceipt(receipt: BrowserReceipt, task: BrowserTask) {\n if (task.evidenceRetention === \"full\") return receipt;\n const meta = receipt.providerMeta ?? {};\n return {\n runId: receipt.runId,\n provider: receipt.provider,\n status: receipt.status,\n finalUrl: receipt.finalUrl,\n checks: receipt.checks ?? [],\n error: receipt.error,\n durationMs: receipt.durationMs,\n providerMeta: {\n fallbackFrom: meta.fallbackFrom,\n priorStatus: meta.priorStatus,\n priorError: meta.priorError,\n priorDurationMs: meta.priorDurationMs,\n },\n outputsPersisted: false,\n };\n}\n\nasync function recordAttempts(taskId: number, attemptNo: number, startedAt: string, receipt: BrowserReceipt, storedReceipt: unknown) {\n const finishedAt = new Date().toISOString();\n const meta = receipt.providerMeta ?? {};\n const statements: Array<{ sql: string; args: Array }> = [];\n\n if (typeof meta.fallbackFrom === \"string\") {\n statements.push({\n sql: `INSERT INTO browser_attempts(task_id,run_id,attempt_no,provider,started_at,finished_at,status,duration_ms,error,receipt_json,estimated_units)\n VALUES(?,?,?,?,?,?,?,?,?,?,?)`,\n args: [taskId, receipt.runId, attemptNo, meta.fallbackFrom, startedAt, finishedAt,\n String(meta.priorStatus ?? \"FAIL\"), Number(meta.priorDurationMs ?? 0),\n meta.priorError == null ? null : String(meta.priorError), null, null],\n });\n }\n\n statements.push({\n sql: `INSERT INTO browser_attempts(task_id,run_id,attempt_no,provider,started_at,finished_at,status,duration_ms,error,receipt_json,estimated_units)\n VALUES(?,?,?,?,?,?,?,?,?,?,?)`,\n args: [taskId, receipt.runId, attemptNo, receipt.provider, startedAt, finishedAt,\n receipt.status, receipt.durationMs ?? null, receipt.error ?? null, JSON.stringify(storedReceipt), estimateProviderUnits(receipt)],\n });\n await sqlite.batch(statements);\n}\n\nasync function finishTask(row: Record, task: BrowserTask, receipt: BrowserReceipt, storedReceipt: unknown) {\n const id = Number(row.id);\n const attemptCount = Number(row.attempt_count);\n const now = new Date().toISOString();\n const disposition = decideDisposition(task.risk, receipt.status, attemptCount);\n const next = disposition.retryable ? new Date(Date.now() + disposition.retryDelayMs).toISOString() : null;\n await sqlite.execute({\n sql: `UPDATE browser_tasks SET status=?, provider=?, receipt_json=?, error=?, updated_at=?, claimed_at=NULL, next_attempt_at=? WHERE id=?`,\n args: [disposition.taskStatus, receipt.provider, JSON.stringify(storedReceipt), receipt.error ?? null, now, next, id],\n });\n}\n\nasync function blockTask(row: Record, task: BrowserTask | undefined, errors: string[]) {\n const id = Number(row.id);\n const receipt = { runId: task?.runId ?? String(row.run_id), status: \"BLOCKED\", errors };\n const now = new Date().toISOString();\n await sqlite.batch([\n {\n sql: `UPDATE browser_tasks SET status='BLOCKED', provider=?, receipt_json=?, error=?, updated_at=?, claimed_at=NULL, next_attempt_at=NULL WHERE id=?`,\n args: [task?.preferredProvider ?? \"validation\", JSON.stringify(receipt), errors.join(\"; \"), now, id],\n },\n {\n sql: `INSERT INTO browser_attempts(task_id,run_id,attempt_no,provider,started_at,finished_at,status,error,receipt_json,estimated_units)\n VALUES(?,?,?,?,?,?,?,?,?,?)`,\n args: [id, String(row.run_id), Number(row.attempt_count), task?.preferredProvider ?? \"validation\",\n String(row.claimed_at ?? now), now, \"BLOCKED\", errors.join(\"; \"), JSON.stringify(receipt), null],\n },\n ]);\n console.log(JSON.stringify(receipt, null, 2));\n return receipt;\n}\n\nasync function main() {\n await recoverStaleLeases();\n const row = await claimNext();\n if (!row) {\n const result = { status: \"NO_PENDING_TASK\" };\n console.log(JSON.stringify(result));\n return result;\n }\n\n let task: BrowserTask;\n try {\n task = JSON.parse(String(row.task_json)) as BrowserTask;\n } catch (error) {\n return blockTask(row, undefined, [`invalid task_json: ${error instanceof Error ? error.message : String(error)}`]);\n }\n\n const errors = validateTask(task);\n if (errors.length) return blockTask(row, task, errors);\n\n const receipt = await executeRouted(task);\n const storedReceipt = storageReceipt(receipt, task);\n await recordAttempts(Number(row.id), Number(row.attempt_count), String(row.claimed_at), receipt, storedReceipt);\n await finishTask(row, task, receipt, storedReceipt);\n\n console.log(JSON.stringify(receipt, null, 2));\n return receipt;\n}\n\nawait main();\n",[167],"a1a5812d-5ce3-4242-9526-b3a3285a7466","main.ts",51,["D",1788708823582],5,"http","export default async function (req: Request): Promise {\n if (req.method !== \"GET\") {\n return Response.json({ error: \"method_not_allowed\" }, { status: 405 });\n }\n\n return Response.json({\n service: \"chat-native-maestro\",\n version: \"0.5.0\",\n status: \"alive\",\n executionSurface: \"authenticated_val_town_plugin_only\",\n automaticExecution: \"disabled\",\n security: {\n publicEndpointWriteMethods: \"disabled\",\n detailedRuntimeState: \"not_exposed_publicly\",\n arbitraryCodeInput: \"disabled\",\n },\n });\n}\n",[175],"6a82d07f-8313-4ef8-99ae-6a02a2764ff8","dns_probe.ts","7fec04d0-aa08-11f1-813e-1607ee4eb77e",55,["D",1788708906255],"const result: Record = {};\ntry {\n const url = new URL(\"https://cloudflare-dns.com/dns-query\");\n url.searchParams.set(\"name\", \"example.com\");\n url.searchParams.set(\"type\", \"A\");\n const response = await fetch(url, { headers: { accept: \"application/dns-json\" } });\n result.status = response.status;\n result.body = await response.json();\n result.supported = response.ok;\n} catch (error) {\n result.supported = false;\n result.error = error instanceof Error ? error.message : String(error);\n}\nconsole.log(JSON.stringify(result, null, 2));\n",[183],"f8eab693-dab5-4ffa-bfeb-8b3b111049c9","README.md","3efb9a6e-aa06-11f1-82ca-1607ee4eb77e",34,["D",1788708125606],"# Chat-Native Maestro V0.4.1\n\nCloud runtime controlled from normal ChatGPT mobile/web.\n\n## Canonical constraint\n\n- No Codex.\n- No user PC.\n- No local browser runtime.\n- Normal ChatGPT is the control plane.\n- Val Town is the persistent cloud compute/state plane.\n\n## Current browser routing\n\n1. Kernel — champion, recurring free monthly credits.\n2. Browserless — recurring-free fallback.\n3. Browserbase — researched fallback, not yet implemented.\n4. Steel — one-time-credit fallback, not preferred for zero-cost steady state.\n\nAutomatic cross-provider retry is permitted only for `read_only` tasks. Writes are never retried on another provider automatically because the first provider may have caused a partial side effect.\n\n## Execution model\n\nChatGPT uses its authenticated Val Town plugin to:\n\n1. classify a task and risk;\n2. insert a task into val-scoped SQLite;\n3. run `runner.ts`;\n4. read the persisted receipt;\n5. verify/falsify the result.\n\nThe public HTTP endpoint is minimal liveness only. It rejects non-GET methods and does not expose provider configuration, task counts, receipts, or database state. Detailed diagnostics live in authenticated `status.ts`.\n\n## Browser DSL\n\nSupported actions:\n- `goto`\n- `wait_for`\n- `click`\n- `fill`\n- `fill_secret`\n- `type`\n- `select`\n- `extract_text`\n- `extract_attribute`\n- `expect_text`\n- `expect_url`\n\nArbitrary JavaScript and shell input are intentionally absent from the public task schema.\n\n## Risk gates\n\n- `read_only`: normal execution.\n- `reversible_write`: requires explicit `approved=true`.\n- `consequential`: requires explicit `approved=true`.\n- `fill_secret`: separately requires `approved=true`, even in a read-only navigation task.\n\n## Secret handling\n\nNever store a password/token in `task_json`.\n\nUse:\n\n```json\n{\"action\":\"fill_secret\",\"selector\":\"#password\",\"envVar\":\"PORTAL_PASSWORD\"}\n```\n\nThe SQLite task stores only `PORTAL_PASSWORD`. The actual value is read from a Val Town environment variable in memory immediately before browser execution.\n\nProvider API credentials also belong only in Val Town environment variables:\n- `KERNEL_API_KEY`\n- `BROWSERLESS_TOKEN`\n- optional `BROWSERLESS_BASE_URL`\n\n## Read-only network control\n\nFor browser tasks classified `read_only`, the generated browser program allows only GET, HEAD, and OPTIONS requests. Main-frame navigation is restricted to the original target host plus explicit `allowedHosts`. Popups are closed.\n\nThis is a strong control, not proof of zero side effects: a poorly designed website can mutate state with GET. Post-action verification remains mandatory.\n\n## Evidence policy\n\n`TOOL_SUCCESS_RESPONSE != BEHAVIOR_PROOF`.\n\nA browser task is PASS only when at least one explicit expectation exists and all expectations pass. Otherwise a successful execution remains PARTIAL.\n\n## Current live evidence\n\nPASS:\n- Val Town authentication and Free workspace.\n- create/edit/run/deploy.\n- HTTP health endpoint.\n- val-scoped SQLite.\n- atomic task claim.\n- persisted receipts.\n- risk validation.\n- secret-approval validation.\n- Kernel SDK module loading.\n- Browserless adapter module loading.\n- safe missing-provider-credential classification.\n\nUNVERIFIED:\n- live Kernel browser session (API key not configured).\n- live Browserless browser session (token not configured).\n- real provider credit accounting on this account.\n\nSee `docs/CURRENT_STATE.md` and `docs/PROVIDER_CENSUS.md`.\n",[190],"52abd68c-7eb8-45d0-87f2-28a80af822c4","providers","f528640e-aa04-11f1-8241-1607ee4eb77e",["D",1788707369470],"directory",[197],"561d863a-e041-4f0a-b61d-8884716cb727","lib","f30be01a-aa04-11f1-b5ff-1607ee4eb77e",["D",1788707365920],[203],"7a194648-9f6b-42ee-8ade-4a9c3bcd3220","docs","f7f2feb0-aa04-11f1-9265-1607ee4eb77e",4,["D",1788707374127],[208],"pulls","branches","forks","envVars",{"_220":62,"_222":62},"connections",{"_220":62,"_221":62},"count","unfilledCount","emptyCount",{"_42":207,"_31":208,"_29":209,"_143":-5,"_40":41,"_39":210,"_145":58,"_37":383,"_13":62,"_33":200,"_35":-5,"_23":24,"_149":-5,"_248":384,"_26":385},{"_42":375,"_31":376,"_29":377,"_143":209,"_40":41,"_39":378,"_145":24,"_37":379,"_13":62,"_33":20,"_35":380,"_23":24,"_149":-5,"_248":381,"_26":382},{"_42":367,"_31":368,"_29":369,"_143":209,"_40":41,"_39":370,"_145":24,"_37":371,"_13":147,"_33":20,"_35":372,"_23":24,"_149":-5,"_248":373,"_26":374},{"_42":359,"_31":360,"_29":361,"_143":209,"_40":41,"_39":362,"_145":24,"_37":363,"_13":62,"_33":20,"_35":364,"_23":24,"_149":-5,"_248":365,"_26":366},{"_42":351,"_31":352,"_29":353,"_143":209,"_40":41,"_39":354,"_145":58,"_37":355,"_13":62,"_33":20,"_35":356,"_23":24,"_149":-5,"_248":357,"_26":358},{"_42":343,"_31":344,"_29":345,"_143":209,"_40":41,"_39":346,"_145":58,"_37":347,"_13":62,"_33":20,"_35":348,"_23":24,"_149":-5,"_248":349,"_26":350},{"_42":202,"_31":203,"_29":204,"_143":-5,"_40":41,"_39":163,"_145":58,"_37":340,"_13":62,"_33":200,"_35":-5,"_23":24,"_149":-5,"_248":341,"_26":342},{"_42":332,"_31":333,"_29":334,"_143":204,"_40":41,"_39":335,"_145":58,"_37":336,"_13":62,"_33":34,"_35":337,"_23":24,"_149":-5,"_248":338,"_26":339},{"_42":324,"_31":325,"_29":326,"_143":204,"_40":41,"_39":327,"_145":58,"_37":328,"_13":210,"_33":34,"_35":329,"_23":24,"_149":-5,"_248":330,"_26":331},{"_42":316,"_31":317,"_29":318,"_143":204,"_40":41,"_39":319,"_145":58,"_37":320,"_13":163,"_33":34,"_35":321,"_23":24,"_149":-5,"_248":322,"_26":323},{"_42":308,"_31":309,"_29":310,"_143":204,"_40":41,"_39":311,"_145":58,"_37":312,"_13":62,"_33":34,"_35":313,"_23":24,"_149":-5,"_248":314,"_26":315},{"_42":300,"_31":301,"_29":302,"_143":204,"_40":41,"_39":303,"_145":58,"_37":304,"_13":163,"_33":34,"_35":305,"_23":24,"_149":-5,"_248":306,"_26":307},{"_42":296,"_31":32,"_29":30,"_143":204,"_40":41,"_39":14,"_145":58,"_37":297,"_13":62,"_33":34,"_35":36,"_23":24,"_149":-5,"_248":298,"_26":299},{"_42":196,"_31":197,"_29":198,"_143":-5,"_40":41,"_39":171,"_145":58,"_37":293,"_13":62,"_33":200,"_35":-5,"_23":24,"_149":-5,"_248":294,"_26":295},{"_42":285,"_31":286,"_29":287,"_143":198,"_40":41,"_39":288,"_145":58,"_37":289,"_13":210,"_33":34,"_35":290,"_23":24,"_149":-5,"_248":291,"_26":292},{"_42":277,"_31":278,"_29":279,"_143":198,"_40":41,"_39":280,"_145":58,"_37":281,"_13":210,"_33":34,"_35":282,"_23":24,"_149":-5,"_248":283,"_26":284},{"_42":269,"_31":270,"_29":271,"_143":198,"_40":41,"_39":272,"_145":58,"_37":273,"_13":163,"_33":34,"_35":274,"_23":24,"_149":-5,"_248":275,"_26":276},{"_42":189,"_31":190,"_29":191,"_143":-5,"_40":41,"_39":192,"_145":24,"_37":266,"_13":147,"_33":20,"_35":194,"_23":24,"_149":-5,"_248":267,"_26":268},{"_42":182,"_31":183,"_29":184,"_143":-5,"_40":41,"_39":185,"_145":24,"_37":263,"_13":147,"_33":34,"_35":187,"_23":24,"_149":-5,"_248":264,"_26":265},{"_42":174,"_31":175,"_29":56,"_143":-5,"_40":41,"_39":176,"_145":58,"_37":260,"_13":178,"_33":179,"_35":180,"_23":24,"_149":-5,"_248":261,"_26":262},{"_42":166,"_31":167,"_29":168,"_143":-5,"_40":41,"_39":169,"_145":24,"_37":257,"_13":171,"_33":34,"_35":172,"_23":24,"_149":-5,"_248":258,"_26":259},{"_42":158,"_31":159,"_29":160,"_143":-5,"_40":41,"_39":161,"_145":58,"_37":254,"_13":163,"_33":34,"_35":164,"_23":24,"_149":-5,"_248":255,"_26":256},{"_42":151,"_31":152,"_29":153,"_143":-5,"_40":41,"_39":154,"_145":58,"_37":251,"_13":62,"_33":34,"_35":156,"_23":24,"_149":-5,"_248":252,"_26":253},{"_42":140,"_31":141,"_29":142,"_143":-5,"_40":41,"_39":144,"_145":24,"_37":247,"_13":147,"_33":34,"_35":148,"_23":24,"_149":-5,"_248":249,"_26":250},["D",1788708816646],"children",[],[141],["D",1788708679858],[],[152],["D",1788708610657],[],[159],["D",1788708794913],[],[167],["D",1788708823582],[],[175],["D",1788708906255],[],[183],["D",1788708125606],[],[190],"9853b5ac-79a2-471c-87bb-31d20bd2b93b","router.ts","40781008-aa05-11f1-bfc5-1607ee4eb77e",37,["D",1788708460636],"import type { BrowserReceipt, BrowserTask, ProviderName } from \"../lib/types.ts\";\nimport { executeKernel, kernelConfigured } from \"./kernel.ts\";\nimport { browserlessConfigured, executeBrowserless } from \"./browserless.ts\";\nimport { providerAvailable, recordProviderOutcome } from \"../lib/provider_health.ts\";\n\nexport function providerState() {\n const kernel = kernelConfigured();\n const browserless = browserlessConfigured();\n return {\n kernel: { priority: 1, configured: kernel, state: kernel ? \"READY\" : \"ACCOUNT_KEY_REQUIRED\" },\n browserless: { priority: 2, configured: browserless, state: browserless ? \"READY\" : \"ACCOUNT_TOKEN_REQUIRED\" },\n };\n}\n\nasync function runProvider(provider: ProviderName, task: BrowserTask): Promise {\n const health = await providerAvailable(provider);\n if (!health.available) {\n return { runId: task.runId, provider, status: \"BLOCKED\", error: health.reason ?? \"provider circuit open\" };\n }\n\n const receipt = provider === \"kernel\" ? await executeKernel(task) : await executeBrowserless(task);\n await recordProviderOutcome(provider, receipt);\n return receipt;\n}\n\nfunction withFallbackMeta(receipt: BrowserReceipt, prior: BrowserReceipt): BrowserReceipt {\n return {\n ...receipt,\n providerMeta: {\n ...(receipt.providerMeta ?? {}),\n fallbackFrom: prior.provider,\n priorStatus: prior.status,\n priorError: prior.error ?? null,\n priorDurationMs: prior.durationMs ?? null,\n },\n };\n}\n\nexport async function executeRouted(task: BrowserTask): Promise {\n if (task.preferredProvider === \"browserless\") return runProvider(\"browserless\", task);\n if (task.preferredProvider === \"kernel\") return runProvider(\"kernel\", task);\n\n if (kernelConfigured()) {\n const primary = await runProvider(\"kernel\", task);\n if (primary.status === \"PASS\" || primary.status === \"PARTIAL\") return primary;\n if (task.risk === \"read_only\" && browserlessConfigured()) {\n const fallback = await runProvider(\"browserless\", task);\n return withFallbackMeta(fallback, primary);\n }\n return primary;\n }\n\n if (browserlessConfigured()) return runProvider(\"browserless\", task);\n return runProvider(\"kernel\", task);\n}\n",[],[197,270],"3dfb6747-ac0f-4473-8d83-50f188fabde7","kernel.ts","1aa22634-aa05-11f1-8241-1607ee4eb77e",42,["D",1788708574938],"import Kernel from \"npm:@onkernel/sdk\";\nimport type { BrowserReceipt, BrowserTask } from \"../lib/types.ts\";\nimport { buildKernelPlaywrightCode, resolveSecrets } from \"../lib/dsl.ts\";\nimport { POLICY, withTimeout } from \"../lib/policy.ts\";\n\nexport function kernelConfigured(): boolean {\n return Boolean(Deno.env.get(\"KERNEL_API_KEY\"));\n}\n\nexport async function executeKernel(task: BrowserTask): Promise {\n const apiKey = Deno.env.get(\"KERNEL_API_KEY\");\n if (!apiKey) {\n return { runId: task.runId, provider: \"kernel\", status: \"BLOCKED\", error: \"KERNEL_API_KEY missing\" };\n }\n\n let resolvedTask: BrowserTask;\n try {\n resolvedTask = resolveSecrets(task);\n } catch (error) {\n return { runId: task.runId, provider: \"kernel\", status: \"BLOCKED\", error: error instanceof Error ? error.message : String(error) };\n }\n\n const started = Date.now();\n const kernel = new Kernel({ apiKey });\n let sessionId: string | undefined;\n try {\n const kernelBrowser = await withTimeout(\n kernel.browsers.create({ headless: true, stealth: true }),\n 10_000,\n \"kernel browser create\",\n );\n sessionId = kernelBrowser.session_id;\n\n const response = await withTimeout(\n kernel.browsers.playwright.execute(sessionId, {\n code: buildKernelPlaywrightCode(resolvedTask),\n }),\n POLICY.browserTimeoutMs,\n \"kernel playwright execute\",\n );\n const result = (response as any).result ?? response;\n const verified = Boolean(result?.verified);\n return {\n runId: task.runId,\n provider: \"kernel\",\n status: verified ? \"PASS\" : \"PARTIAL\",\n finalUrl: result?.finalUrl,\n outputs: result?.outputs ?? {},\n checks: result?.checks ?? [],\n durationMs: Date.now() - started,\n providerMeta: { sessionId, headless: true, stealth: true },\n };\n } catch (error) {\n return {\n runId: task.runId,\n provider: \"kernel\",\n status: \"FAIL\",\n error: error instanceof Error ? error.message : String(error),\n durationMs: Date.now() - started,\n providerMeta: sessionId ? { sessionId } : {},\n };\n } finally {\n if (sessionId) {\n try {\n await withTimeout(kernel.browsers.deleteByID(sessionId), 5_000, \"kernel browser cleanup\");\n } catch (cleanupError) {\n console.error(\"kernel cleanup failed\", cleanupError);\n }\n }\n }\n}\n",[],[197,278],"f72cdfad-c2bc-42e6-bd68-78a743902e9b","browserless.ts","62afee48-aa05-11f1-9a10-1607ee4eb77e",43,["D",1788708593522],"import type { BrowserReceipt, BrowserTask } from \"../lib/types.ts\";\nimport { resolveSecrets } from \"../lib/dsl.ts\";\nimport { POLICY } from \"../lib/policy.ts\";\n\nconst FUNCTION_CODE = String.raw`\nexport default async ({ page, context }) => {\n const plan = context.plan;\n const outputs = {};\n const checks = [];\n const targetHost = new URL(plan.targetUrl).hostname;\n const allowedHosts = new Set([targetHost, ...(plan.allowedHosts || [])]);\n const allowedMethods = new Set([\"GET\", \"HEAD\", \"OPTIONS\"]);\n const assertUrl = (value) => {\n const u = new URL(value);\n if (![\"http:\", \"https:\"].includes(u.protocol)) throw new Error(\"blocked protocol\");\n if (!allowedHosts.has(u.hostname)) throw new Error(\"blocked host: \" + u.hostname);\n };\n\n await page.setRequestInterception(true);\n page.on(\"request\", (req) => {\n try {\n if (req.isNavigationRequest() && req.frame() === page.mainFrame()) assertUrl(req.url());\n if (plan.risk === \"read_only\" && !allowedMethods.has(req.method().toUpperCase())) return req.abort(\"blockedbyclient\");\n return req.continue();\n } catch {\n return req.abort(\"blockedbyclient\");\n }\n });\n page.on(\"popup\", async (popup) => { try { await popup.close(); } catch {} });\n\n assertUrl(plan.targetUrl);\n await page.goto(plan.targetUrl, { waitUntil: \"domcontentloaded\" });\n assertUrl(page.url());\n\n for (const step of plan.steps) {\n switch (step.action) {\n case \"goto\": {\n const url = step.url || plan.targetUrl;\n assertUrl(url);\n await page.goto(url, { waitUntil: \"domcontentloaded\" });\n break;\n }\n case \"wait_for\":\n await page.waitForSelector(step.selector, { visible: true, timeout: step.timeoutMs || 10000 });\n break;\n case \"click\":\n if (step.waitForNavigation) {\n await Promise.all([page.waitForNavigation({ waitUntil: \"domcontentloaded\" }), page.click(step.selector)]);\n } else await page.click(step.selector);\n break;\n case \"fill\":\n await page.click(step.selector, { clickCount: 3 });\n await page.keyboard.press(\"Backspace\");\n await page.type(step.selector, step.text);\n break;\n case \"type\":\n await page.type(step.selector, step.text, { delay: step.delayMs || 0 });\n break;\n case \"select\":\n await page.select(step.selector, step.value);\n break;\n case \"extract_text\":\n outputs[step.key] = await page.$eval(step.selector, (el) => el.textContent || \"\");\n break;\n case \"extract_attribute\":\n outputs[step.key] = await page.$eval(step.selector, (el, attr) => el.getAttribute(attr), step.attribute);\n break;\n case \"expect_text\": {\n const body = await page.evaluate(() => document.body?.innerText || \"\");\n checks.push({ type: \"text\", expected: step.text, ok: body.includes(step.text) });\n break;\n }\n case \"expect_url\": {\n const actual = page.url();\n checks.push({ type: \"url\", expected: step.contains, actual, ok: actual.includes(step.contains) });\n break;\n }\n }\n assertUrl(page.url());\n }\n\n return {\n data: {\n finalUrl: page.url(),\n outputs,\n checks,\n verified: checks.length > 0 && checks.every((x) => x.ok),\n },\n type: \"application/json\",\n };\n};\n`;\n\nexport function browserlessConfigured(): boolean {\n return Boolean(Deno.env.get(\"BROWSERLESS_TOKEN\"));\n}\n\nexport async function executeBrowserless(task: BrowserTask): Promise {\n const token = Deno.env.get(\"BROWSERLESS_TOKEN\");\n if (!token) return { runId: task.runId, provider: \"browserless\", status: \"BLOCKED\", error: \"BROWSERLESS_TOKEN missing\" };\n\n let resolvedTask: BrowserTask;\n try {\n resolvedTask = resolveSecrets(task);\n } catch (error) {\n return { runId: task.runId, provider: \"browserless\", status: \"BLOCKED\", error: error instanceof Error ? error.message : String(error) };\n }\n\n const started = Date.now();\n const base = (Deno.env.get(\"BROWSERLESS_BASE_URL\") || \"https://production-sfo.browserless.io\").replace(/\\/+$/, \"\");\n try {\n const response = await fetch(`${base}/function?token=${encodeURIComponent(token)}`, {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({ code: FUNCTION_CODE, context: { plan: resolvedTask } }),\n signal: AbortSignal.timeout(POLICY.browserTimeoutMs),\n });\n const text = await response.text();\n let result: any;\n try { result = JSON.parse(text); } catch { result = { raw: text }; }\n if (!response.ok) {\n return { runId: task.runId, provider: \"browserless\", status: \"FAIL\", error: `HTTP ${response.status}: ${text.slice(0, 500)}`, durationMs: Date.now() - started };\n }\n return {\n runId: task.runId,\n provider: \"browserless\",\n status: result?.verified ? \"PASS\" : \"PARTIAL\",\n finalUrl: result?.finalUrl,\n outputs: result?.outputs ?? {},\n checks: result?.checks ?? [],\n durationMs: Date.now() - started,\n providerMeta: { base },\n };\n } catch (error) {\n return { runId: task.runId, provider: \"browserless\", status: \"FAIL\", error: error instanceof Error ? error.message : String(error), durationMs: Date.now() - started };\n }\n}\n",[],[197,286],["D",1788707369470],[237,238,239],[197],"2b465799-8dd6-4750-b07a-dad5ae57369b",["D",1788708954762],[],[203,32],"36b42981-a6f9-4cd6-a481-07a9a038a7b5","types.ts","08217668-aa05-11f1-b47d-1607ee4eb77e",39,["D",1788708517010],"export type Risk = \"read_only\" | \"reversible_write\" | \"consequential\";\nexport type ProviderName = \"kernel\" | \"browserless\";\nexport type EvidenceRetention = \"minimal\" | \"full\";\n\nexport type Step =\n | { action: \"goto\"; url?: string }\n | { action: \"wait_for\"; selector: string; timeoutMs?: number }\n | { action: \"click\"; selector: string; waitForNavigation?: boolean }\n | { action: \"fill\"; selector: string; text: string }\n | { action: \"fill_secret\"; selector: string; envVar: string }\n | { action: \"type\"; selector: string; text: string; delayMs?: number }\n | { action: \"select\"; selector: string; value: string }\n | { action: \"extract_text\"; selector: string; key: string }\n | { action: \"extract_attribute\"; selector: string; attribute: string; key: string }\n | { action: \"expect_text\"; text: string }\n | { action: \"expect_url\"; contains: string };\n\nexport type BrowserTask = {\n runId: string;\n targetUrl: string;\n risk: Risk;\n approved?: boolean;\n purpose: string;\n allowedHosts?: string[];\n preferredProvider?: ProviderName;\n evidenceRetention?: EvidenceRetention;\n steps: Step[];\n};\n\nexport type BrowserReceipt = {\n runId: string;\n provider: ProviderName;\n status: \"PASS\" | \"PARTIAL\" | \"FAIL\" | \"BLOCKED\";\n finalUrl?: string;\n outputs?: Record;\n checks?: Array>;\n error?: string;\n durationMs?: number;\n providerMeta?: Record;\n};\n",[],[203,301],"9e8d90ce-1918-4afb-9a17-f03ecb926764","provider_health.ts","7993f5d0-aa07-11f1-af42-1607ee4eb77e",36,["D",1788708450626],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type { BrowserReceipt, ProviderName } from \"./types.ts\";\nimport { POLICY } from \"./policy.ts\";\n\nexport async function providerAvailable(provider: ProviderName): Promise<{ available: boolean; reason?: string }> {\n const row = (await sqlite.execute({ sql: \"SELECT * FROM provider_health WHERE provider=?\", args: [provider] })).rows[0] as any;\n if (!row) return { available: true };\n if (row.circuit_state !== \"OPEN\") return { available: true };\n if (!row.open_until) return { available: false, reason: \"provider circuit open\" };\n const until = Date.parse(String(row.open_until));\n if (Number.isFinite(until) && Date.now() >= until) {\n await sqlite.execute({\n sql: \"UPDATE provider_health SET circuit_state='HALF_OPEN', updated_at=? WHERE provider=?\",\n args: [new Date().toISOString(), provider],\n });\n return { available: true };\n }\n return { available: false, reason: `provider circuit open until ${row.open_until}` };\n}\n\nexport async function recordProviderOutcome(provider: ProviderName, receipt: BrowserReceipt): Promise {\n const now = new Date().toISOString();\n if (receipt.status === \"PASS\" || receipt.status === \"PARTIAL\") {\n await sqlite.execute({\n sql: `UPDATE provider_health SET circuit_state='CLOSED', consecutive_failures=0, open_until=NULL,\n last_success_at=?, last_error=NULL, updated_at=? WHERE provider=?`,\n args: [now, now, provider],\n });\n return;\n }\n\n if (receipt.status === \"BLOCKED\") return;\n\n const row = (await sqlite.execute({ sql: \"SELECT consecutive_failures FROM provider_health WHERE provider=?\", args: [provider] })).rows[0] as any;\n const failures = Number(row?.consecutive_failures ?? 0) + 1;\n const shouldOpen = failures >= POLICY.providerCircuitFailureThreshold;\n const openUntil = shouldOpen ? new Date(Date.now() + POLICY.providerCircuitCooldownMs).toISOString() : null;\n await sqlite.execute({\n sql: `UPDATE provider_health SET circuit_state=?, consecutive_failures=?, open_until=?,\n last_failure_at=?, last_error=?, updated_at=? WHERE provider=?`,\n args: [shouldOpen ? \"OPEN\" : \"CLOSED\", failures, openUntil, now, receipt.error ?? receipt.status, now, provider],\n });\n}\n\nexport async function getProviderHealth() {\n return (await sqlite.execute(\"SELECT * FROM provider_health ORDER BY provider\")).rows;\n}\n",[],[203,309],"30a557f0-8e88-4aa8-8f98-81486032a5e9","policy.ts","50662fa2-aa07-11f1-b77b-1607ee4eb77e",45,["D",1788708643387],"import type { Risk } from \"./types.ts\";\n\nexport const POLICY = {\n version: \"0.5.0\",\n maxAttemptsPerTask: 2,\n retryDelayMs: 10_000,\n runningLeaseMs: 90_000,\n readOnlyFallbackAllowed: true,\n browserTimeoutMs: 25_000,\n providerFailureWindow: 5,\n providerCircuitFailureThreshold: 3,\n providerCircuitCooldownMs: 15 * 60_000,\n} as const;\n\nexport function isTerminalStatus(status: string): boolean {\n return [\"PASS\", \"PARTIAL\", \"FAIL\", \"BLOCKED\", \"CANCELLED\"].includes(status);\n}\n\nexport function decideDisposition(risk: Risk, receiptStatus: string, attemptCount: number) {\n const retryable = risk === \"read_only\" && receiptStatus === \"FAIL\" && attemptCount < POLICY.maxAttemptsPerTask;\n return {\n retryable,\n taskStatus: retryable ? \"PENDING\" : receiptStatus,\n retryDelayMs: retryable ? POLICY.retryDelayMs : 0,\n } as const;\n}\n\nexport async function withTimeout(promise: Promise, ms: number, label: string): Promise {\n let timer: number | undefined;\n const timeout = new Promise((_, reject) => {\n timer = setTimeout(() => reject(new Error(`${label} timed out after ${ms}ms`)), ms);\n });\n try {\n return await Promise.race([promise, timeout]);\n } finally {\n if (timer !== undefined) clearTimeout(timer);\n }\n}\n",[],[203,317],"a85185f4-ae91-4dc6-bfdd-7432df49fe18","dsl.ts","1341db6e-aa05-11f1-ba4c-1607ee4eb77e",41,["D",1788708562937],"import type { BrowserTask } from \"./types.ts\";\n\nconst ALLOWED_ACTIONS = new Set([\n \"goto\", \"wait_for\", \"click\", \"fill\", \"fill_secret\", \"type\", \"select\",\n \"extract_text\", \"extract_attribute\", \"expect_text\", \"expect_url\",\n]);\n\nexport function validateTask(task: BrowserTask): string[] {\n const errors: string[] = [];\n if (!task || typeof task !== \"object\") return [\"task must be an object\"];\n if (!task.runId || task.runId.length > 128) errors.push(\"invalid runId\");\n if (!task.purpose || task.purpose.length > 1000) errors.push(\"invalid purpose\");\n if (!Array.isArray(task.steps) || task.steps.length < 1 || task.steps.length > 30) errors.push(\"steps must contain 1..30 actions\");\n if (![\"read_only\", \"reversible_write\", \"consequential\"].includes(task.risk)) errors.push(\"invalid risk\");\n if (task.risk !== \"read_only\" && task.approved !== true) errors.push(\"NEEDS_APPROVAL\");\n if (task.preferredProvider && ![\"kernel\", \"browserless\"].includes(task.preferredProvider)) errors.push(\"invalid preferredProvider\");\n if (task.evidenceRetention && ![\"minimal\", \"full\"].includes(task.evidenceRetention)) errors.push(\"invalid evidenceRetention\");\n\n let target: URL | undefined;\n try {\n target = new URL(task.targetUrl);\n if (![\"http:\", \"https:\"].includes(target.protocol)) errors.push(\"target protocol blocked\");\n } catch {\n errors.push(\"invalid targetUrl\");\n }\n\n const targetHost = target?.hostname;\n const allowed = new Set([targetHost, ...(task.allowedHosts ?? [])].filter(Boolean) as string[]);\n for (const [i, step] of (task.steps ?? []).entries()) {\n if (!step || !ALLOWED_ACTIONS.has((step as any).action)) {\n errors.push(`step ${i}: unsupported action`);\n continue;\n }\n const maybe = step as any;\n if (typeof maybe.selector === \"string\" && maybe.selector.length > 1000) errors.push(`step ${i}: selector too long`);\n if (typeof maybe.text === \"string\" && maybe.text.length > 10000) errors.push(`step ${i}: text too long`);\n if (maybe.action === \"fill_secret\") {\n if (typeof maybe.envVar !== \"string\" || !/^[A-Za-z_][A-Za-z0-9_]*$/.test(maybe.envVar)) errors.push(`step ${i}: invalid secret env var`);\n if (task.approved !== true) errors.push(\"NEEDS_SECRET_APPROVAL\");\n }\n if (maybe.action === \"extract_attribute\" && String(maybe.attribute).toLowerCase() === \"value\") {\n errors.push(`step ${i}: extracting value attribute is blocked to reduce secret leakage risk`);\n }\n if (maybe.action === \"goto\" && maybe.url) {\n try {\n const u = new URL(maybe.url);\n if (![\"http:\", \"https:\"].includes(u.protocol) || !allowed.has(u.hostname)) errors.push(`step ${i}: navigation host blocked`);\n } catch {\n errors.push(`step ${i}: invalid goto url`);\n }\n }\n }\n return [...new Set(errors)];\n}\n\nexport function buildKernelPlaywrightCode(task: BrowserTask): string {\n const plan = JSON.stringify(task);\n return `\nconst plan = ${plan};\nconst outputs = {};\nconst checks = [];\nconst targetHost = new URL(plan.targetUrl).hostname;\nconst allowedHosts = new Set([targetHost, ...(plan.allowedHosts || [])]);\nconst allowedMethods = new Set([\"GET\", \"HEAD\", \"OPTIONS\"]);\n\nconst assertUrl = (value) => {\n const u = new URL(value);\n if (![\"http:\", \"https:\"].includes(u.protocol)) throw new Error(\"blocked protocol\");\n if (!allowedHosts.has(u.hostname)) throw new Error(\"blocked host: \" + u.hostname);\n};\n\nawait page.route(\"**/*\", async (route) => {\n const req = route.request();\n try {\n if (req.isNavigationRequest() && req.frame() === page.mainFrame()) assertUrl(req.url());\n if (plan.risk === \"read_only\" && !allowedMethods.has(req.method().toUpperCase())) return route.abort(\"blockedbyclient\");\n return route.continue();\n } catch {\n return route.abort(\"blockedbyclient\");\n }\n});\n\npage.on(\"popup\", async (popup) => { try { await popup.close(); } catch {} });\nassertUrl(plan.targetUrl);\nawait page.goto(plan.targetUrl, { waitUntil: \"domcontentloaded\" });\nassertUrl(page.url());\n\nfor (const step of plan.steps) {\n switch (step.action) {\n case \"goto\": {\n const url = step.url || plan.targetUrl;\n assertUrl(url);\n await page.goto(url, { waitUntil: \"domcontentloaded\" });\n break;\n }\n case \"wait_for\":\n await page.locator(step.selector).waitFor({ state: \"visible\", timeout: step.timeoutMs || 10000 });\n break;\n case \"click\":\n if (step.waitForNavigation) {\n await Promise.all([\n page.waitForLoadState(\"domcontentloaded\"),\n page.locator(step.selector).click(),\n ]);\n } else await page.locator(step.selector).click();\n break;\n case \"fill\":\n await page.locator(step.selector).fill(step.text);\n break;\n case \"type\":\n await page.locator(step.selector).pressSequentially(step.text, { delay: step.delayMs || 0 });\n break;\n case \"select\":\n await page.locator(step.selector).selectOption(step.value);\n break;\n case \"extract_text\":\n outputs[step.key] = await page.locator(step.selector).innerText();\n break;\n case \"extract_attribute\":\n outputs[step.key] = await page.locator(step.selector).getAttribute(step.attribute);\n break;\n case \"expect_text\": {\n const body = await page.locator(\"body\").innerText();\n checks.push({ type: \"text\", expected: step.text, ok: body.includes(step.text) });\n break;\n }\n case \"expect_url\": {\n const actual = page.url();\n checks.push({ type: \"url\", expected: step.contains, actual, ok: actual.includes(step.contains) });\n break;\n }\n }\n assertUrl(page.url());\n}\n\nreturn {\n finalUrl: page.url(),\n outputs,\n checks,\n verified: checks.length > 0 && checks.every((x) => x.ok),\n};\n`;\n}\n\nexport function resolveSecrets(task: BrowserTask): BrowserTask {\n const steps = task.steps.map((step) => {\n if (step.action !== \"fill_secret\") return step;\n const value = Deno.env.get(step.envVar);\n if (value === undefined) throw new Error(`secret env var missing: ${step.envVar}`);\n return { action: \"fill\" as const, selector: step.selector, text: value };\n });\n return { ...task, steps };\n}\n",[],[203,325],"87219d4b-60bf-4c29-bf8f-adadda54eb87","cost.ts","3b1f1e28-aa08-11f1-8943-1607ee4eb77e",48,["D",1788708775292],"import type { BrowserReceipt } from \"./types.ts\";\n\nexport function estimateProviderUnits(receipt: BrowserReceipt): number | null {\n if (receipt.status === \"BLOCKED\") return null;\n if (receipt.provider !== \"browserless\") return null;\n if (receipt.durationMs == null) return null;\n return Math.max(1, Math.ceil(receipt.durationMs / 30_000));\n}\n\nexport const COST_NOTES = {\n browserless: \"Estimated units cover browser-time only. Actual cost can be higher with CAPTCHA solving or built-in proxies.\",\n kernel: \"No local unit estimate: Kernel bills usage by GB-second; actual provider usage must be observed from the account.\",\n} as const;\n",[],[203,333],["D",1788707365920],[230,231,232,233,234,235],[203],"a19841c4-9d53-4970-8720-6dfbe80abb18","TASK_SCHEMA.md","6433d9f2-aa08-11f1-bb32-1607ee4eb77e",53,["D",1788708844254],"# Browser Task Schema — V0.5\n\nTasks are inserted into the val-scoped SQLite database by the authenticated ChatGPT Val Town plugin. There is no public enqueue endpoint.\n\n## Required fields\n\n- `runId`: unique stable id, <=128 chars.\n- `targetUrl`: http/https URL.\n- `risk`: `read_only`, `reversible_write`, or `consequential`.\n- `purpose`: human-readable reason for the run.\n- `steps`: 1..30 DSL actions.\n\n## Optional fields\n\n- `approved`: must be `true` for `reversible_write`, `consequential`, and any `fill_secret` action.\n- `allowedHosts`: extra main-navigation hosts, explicit only.\n- `preferredProvider`: `kernel` or `browserless`.\n- `evidenceRetention`: `minimal` (default) or `full`.\n\n## DSL actions\n\n- `goto`\n- `wait_for`\n- `click`\n- `fill`\n- `fill_secret`\n- `type`\n- `select`\n- `extract_text`\n- `extract_attribute` (attribute `value` is blocked)\n- `expect_text`\n- `expect_url`\n\n## Secret rule\n\nNever put a password, cookie, API token, or OTP secret in `task_json`.\nUse `fill_secret` with an environment-variable name. The value is resolved in execution memory only after approval.\n\n## Evidence retention\n\n`minimal` persists status, URL, checks, errors, duration and fallback metadata but omits extracted outputs and provider session ids.\n`full` persists the full receipt and should be used only when the extracted data is intentionally safe to retain.\n\n## Retry policy\n\n- Only `read_only` + provider `FAIL` is retryable.\n- Maximum 2 task attempts.\n- Retry delay: 10 seconds.\n- `BLOCKED`, `PARTIAL`, writes and consequential tasks are never automatically retried.\n- No cron/automatic runner is enabled, so a retry becomes eligible but does not consume browser credits until ChatGPT explicitly runs `runner.ts` again.\n\n## Provider fallback\n\n- Kernel is primary.\n- Browserless is fallback only for `read_only` tasks.\n- No cross-provider retry for writes.\n\n## PASS rule\n\nA successful browser call without at least one positive expectation remains `PARTIAL`.\n`PASS` requires all explicit expectations to succeed.\n",[],[208,344],"f9a4c86f-6f29-4e19-a3f9-4343513964b6","SMOKE_TASK.json","5d015344-aa08-11f1-a288-1607ee4eb77e",52,["D",1788708832174],"{\n \"state\": \"DRAFT_ONLY_DO_NOT_AUTO_ENQUEUE\",\n \"task\": {\n \"runId\": \"smoke-kernel-example-com\",\n \"targetUrl\": \"https://example.com\",\n \"risk\": \"read_only\",\n \"purpose\": \"First live cloud-browser smoke test after provider credential activation\",\n \"preferredProvider\": \"kernel\",\n \"evidenceRetention\": \"minimal\",\n \"steps\": [\n {\"action\": \"extract_text\", \"selector\": \"h1\", \"key\": \"heading\"},\n {\"action\": \"expect_text\", \"text\": \"Example Domain\"},\n {\"action\": \"expect_url\", \"contains\": \"example.com\"}\n ]\n },\n \"promotionCriteria\": [\n \"provider credential key exists in Val Town\",\n \"runner returns PASS\",\n \"heading equals Example Domain\",\n \"all expectations pass\",\n \"attempt receipt is persisted\",\n \"provider usage is observed when available\"\n ]\n}\n",[],[208,352],"552929ae-79cc-46d2-a38c-653e6426f7bc","PROVIDER_CENSUS.md","5865efa4-aa06-11f1-b715-1607ee4eb77e",29,["D",1788707965447],"# Browser Provider Census — V0.4.1\n\nResearch snapshot: 2026-09-06.\n\nThe ranking optimizes for a ChatGPT-mobile control plane with no user PC, recurring free allowance, deterministic browser control, provider isolation, and minimal browser-open time.\n\n## 1. Kernel — CHAMPION\n\nState in this val: `ACCOUNT_KEY_REQUIRED`.\n\nWhy first:\n- Free plan with recurring monthly credits.\n- Multiple concurrent browsers.\n- Headless browser available.\n- Stealth/CAPTCHA/proxy features.\n- Managed auth capability.\n- Uploads/downloads and replay/live-view capabilities.\n- Official Val Town browser-automation guide and starter val.\n- Current Kernel SDK supports server-side Playwright execution in the browser VM, reducing Val Town-side browser-library overhead.\n\nAdapter: `providers/kernel.ts`.\n\nRequired env var: `KERNEL_API_KEY`.\n\n## 2. Browserless — RECURRING-FREE FALLBACK\n\nState in this val: `ACCOUNT_TOKEN_REQUIRED`.\n\nWhy second:\n- Recurring Free plan.\n- No card advertised for Free.\n- 1,000 browser units/month.\n- Two concurrent browsers.\n- Short bounded sessions are a good fit for deterministic plans.\n- Function API can execute Puppeteer code over one HTTPS request.\n\nAdapter: `providers/browserless.ts`.\n\nRequired env var: `BROWSERLESS_TOKEN`.\nOptional: `BROWSERLESS_BASE_URL`.\n\n## 3. Browserbase — RESEARCHED FALLBACK\n\nState: not implemented.\n\nCurrent Free allowance researched:\n- recurring Free plan;\n- three concurrent browsers;\n- one browser-hour/month;\n- Free CAPTCHA support is weaker than higher-priority choices.\n\nOfficial Val Town integration guide exists.\n\n## 4. Steel — ONE-TIME-CREDIT FALLBACK\n\nState: not implemented.\n\nUseful properties:\n- open-source browser infrastructure;\n- Playwright/Puppeteer support;\n- official Val Town guide;\n- substantial starter credits.\n\nReason for lower rank: starter credits are not the preferred recurring-free steady-state budget and some advanced anti-bot/proxy capability can require paid-balance verification.\n\n## Routing rules\n\n1. Honor an explicit `preferredProvider` when the requested provider is configured.\n2. Otherwise use Kernel first.\n3. For `read_only` only, if Kernel fails and Browserless is configured, fallback to Browserless.\n4. Never automatically retry `reversible_write` or `consequential` work on another provider. A failed response is not proof that the first provider caused no side effect.\n5. Keep browser sessions as short as possible; reasoning occurs in ChatGPT before opening a browser.\n\n## Promotion rule\n\nNo provider becomes `OPERATIONAL` from pricing/docs alone. Promotion requires:\n- credential authentication;\n- real browser creation;\n- a read-only smoke task;\n- explicit expectation PASS;\n- receipt persistence;\n- provider usage/cost observation if available.\n",[],[208,360],"6d6405c1-8586-412e-90b2-3cf7056d77d8","CURRENT_STATE.md","48d7c6c0-aa06-11f1-b220-1607ee4eb77e",33,["D",1788708119821],"# CURRENT_STATE — V0.4.1\n\nUpdated: 2026-09-06\n\n## Canonical runtime\n\n`normal ChatGPT mobile/web -> authenticated Val Town plugin -> val-scoped SQLite -> runner.ts -> browser provider -> receipt`\n\nNo Codex and no user computer are required.\n\n## Val Town\n\n- Val: `cleitoncosta/chat-native-maestro`\n- Personal workspace tier: Free\n- Code visibility: public (Free-tier constraint)\n- HTTP endpoint: public health/status only\n- Task execution: authenticated Val Town plugin only\n- Persistent state: val-scoped SQLite\n\n## Implemented files\n\n- `main.ts` — minimal public GET-only liveness endpoint; detailed runtime state is not exposed.\n- `status.ts` — authenticated provider/task/receipt diagnostics via the Val Town plugin.\n- `runner.ts` — atomic queue claim, validation, execution, receipt persistence.\n- `selftest.ts` — positive and negative controls.\n- `lib/types.ts` — task/receipt DSL types.\n- `lib/dsl.ts` — validation, browser program generation, in-memory secret resolution.\n- `providers/router.ts` — provider routing/fallback.\n- `providers/kernel.ts` — primary browser adapter.\n- `providers/browserless.ts` — secondary browser adapter.\n\n## Evidence states\n\n### PASS\n\n- ChatGPT Val Town plugin connected and authenticated.\n- Free workspace enumerated.\n- Val creation/editing/running works.\n- HTTP endpoint returns 200.\n- SQLite schema, writes and reads work.\n- Queue claim works.\n- Receipts persist after execution.\n- Consequential action without approval -> BLOCKED.\n- `fill_secret` without approval -> BLOCKED.\n- Invalid secret env-var name -> BLOCKED.\n- Missing Kernel key -> classified BLOCKED.\n- Missing Browserless token -> classified BLOCKED.\n- Kernel SDK and Browserless adapter modules load in Val Town runtime.\n\n### UNVERIFIED\n\n- Kernel API authentication for this user.\n- Kernel real browser creation.\n- Kernel Playwright execution against a real page.\n- Kernel real credit consumption for this user.\n- Browserless API authentication for this user.\n- Browserless `/function` real execution.\n- Browserless real unit accounting for this user.\n\n## Negative-control receipts currently stored\n\n1. `neg-control-no-kernel-key` -> BLOCKED / `KERNEL_API_KEY missing`.\n2. `neg-control-no-browserless-token` -> BLOCKED / `BROWSERLESS_TOKEN missing`.\n3. `neg-control-secret-not-approved` -> BLOCKED / `NEEDS_SECRET_APPROVAL`.\n\n## Secrets\n\nTask JSON must never contain passwords, auth cookies or API tokens.\n\nA browser secret is referenced by env-var name with `fill_secret`. The value is resolved only in execution memory after approval. Provider API credentials live only in Val Town environment variables.\n\n## Next incomplete milestone\n\nConfigure exactly one recurring-free browser provider credential, preferably Kernel, then execute a read-only smoke test against `https://example.com` with explicit extraction and expectations. Measure actual provider usage and only then upgrade live browser state from UNVERIFIED.\n",[],[208,368],"576913e9-063e-4587-9ab3-e3a47f4d9ef5","ACTIVATION_RUNBOOK.md","60d7bb54-aa06-11f1-91f3-1607ee4eb77e",30,["D",1788707979591],"# Activation Runbook — V0.4.1\n\n## Preferred activation: Kernel\n\n1. Create or sign in to a Kernel Free account.\n2. Create an API key in the Kernel dashboard.\n3. Store it only as Val Town env var `KERNEL_API_KEY`.\n4. Do not paste the key into chat, README, SQLite, task JSON, logs, or source code.\n5. Re-run `selftest.ts` and verify Kernel changes from `ACCOUNT_KEY_REQUIRED` to `READY`.\n6. Enqueue a read-only smoke task for `https://example.com`:\n - extract `h1`;\n - expect `Example Domain`;\n - expect URL contains `example.com`.\n7. Run `runner.ts`.\n8. Query the persisted receipt.\n9. Promote Kernel to OPERATIONAL only if receipt status is PASS and the output matches the expected page state.\n10. Observe provider usage/credit consumption if the account API/dashboard exposes it.\n\nVal Town env editor:\nhttps://www.val.town/x/cleitoncosta/chat-native-maestro/environment-variables?key=KERNEL_API_KEY\n\nKernel API key dashboard:\nhttps://dashboard.onkernel.com/api-keys\n\n## Secondary activation: Browserless\n\nUse only if Kernel onboarding is blocked or as fallback testing.\n\n1. Create/sign in to Browserless Free.\n2. Obtain the account token.\n3. Store it as `BROWSERLESS_TOKEN` in Val Town.\n4. If the account gives a regional base endpoint different from the default, store it as `BROWSERLESS_BASE_URL`.\n5. Re-run `selftest.ts` and health GET.\n6. Run the same read-only smoke task with `preferredProvider: \"browserless\"`.\n7. Persist and inspect receipt.\n8. Observe actual unit consumption.\n\nVal Town env editor:\nhttps://www.val.town/x/cleitoncosta/chat-native-maestro/environment-variables?key=BROWSERLESS_TOKEN\n\n## Browser-login secrets\n\nFor credentials used inside a target site, create dedicated Val Town env vars, for example:\n- `PORTAL_USERNAME`\n- `PORTAL_PASSWORD`\n\nTask JSON uses only references:\n\n```json\n{\n \"action\": \"fill_secret\",\n \"selector\": \"#password\",\n \"envVar\": \"PORTAL_PASSWORD\"\n}\n```\n\nA task containing `fill_secret` requires explicit approval before execution.\n\n## Never do\n\n- Never embed API keys in public source code.\n- Never store passwords in SQLite task JSON.\n- Never retry a failed write task automatically on another browser provider.\n- Never treat provider HTTP/SDK success as proof that the requested page state was achieved.\n- Never downgrade an explicit expectation failure to PASS.\n",[],[208,376],["D",1788707374127],[224,225,226,227,228],[208],["D",1788707065045],["D",1789488693443],{"_99":98,"_107":103},{"_99":98,"_100":101,"_102":103,"_18":54,"_104":105,"_106":24},{"_13":88,"_31":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"ctx",{"_81":-5,"_127":424,"_425":426,"_427":428,"_429":24,"_430":24,"_431":24,"_432":58,"_433":-5,"_434":-7,"_435":-7,"_436":62,"_437":24,"_438":24,"_439":-5,"_440":24,"_441":24,"_442":24,"_443":-5},"ENV",{"_395":396,"_397":398,"_399":89,"_400":401,"_402":403,"_404":405,"_406":407,"_408":409,"_410":411,"_412":413,"_414":415,"_416":417,"_418":419,"_420":421,"_422":423},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v56