[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_439":440,"_441":442},"routes/_app.x.$handle.$name",{"_100":99,"_31":43,"_109":88,"_26":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":123,"_124":24,"_125":126,"_127":57,"_128":-5,"_129":-5,"_130":131},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":24},"version",5,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","economic_status.ts","latestPath","fileId","af4f16f4-aa17-11f1-a15c-1607ee4eb77e","name","fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { ECONOMIC_POLICY } from \"./lib/economic_policy.ts\";\n\nconst agents = await sqlite.execute(`SELECT status, COUNT(*) AS count FROM economic_agents GROUP BY status ORDER BY status`);\nconst opportunities = await sqlite.execute(`SELECT status, COUNT(*) AS count FROM opportunities GROUP BY status ORDER BY status`);\nconst runs = await sqlite.execute(`SELECT state, COUNT(*) AS count, COALESCE(SUM(net_revenue),0) AS net_revenue FROM economic_runs GROUP BY state ORDER BY state`);\nconst champions = await sqlite.execute(`SELECT champion_class,agent_id,run_id,metric_value,currency,updated_at FROM economic_champions ORDER BY champion_class`);\nconst latestAgents = await sqlite.execute(`SELECT agent_id,parent_id,generation,lineage,status,hypothesis,strategy,updated_at FROM economic_agents ORDER BY generation DESC,agent_id LIMIT 20`);\nconst latestOpportunities = await sqlite.execute(`SELECT opportunity_id,title,source,category,deadline,payout_currency,payout_max,estimated_cost,human_dependency,evidence_state,status,score,updated_at FROM opportunities ORDER BY updated_at DESC LIMIT 20`);\nconst failures = await sqlite.execute(`SELECT failure_class,COUNT(*) AS count FROM negative_knowledge GROUP BY failure_class ORDER BY count DESC,failure_class`);\nconst success = await sqlite.execute(`SELECT COUNT(*) AS count, COALESCE(MAX(replication_count),0) AS max_replications FROM success_patterns`);\nconst totals = await sqlite.execute(`SELECT\n COALESCE(SUM(gross_revenue),0) AS gross_revenue,\n COALESCE(SUM(browser_cost+llm_cost+api_cost+hosting_cost+platform_fee+transaction_cost),0) AS total_cost,\n COALESCE(SUM(net_revenue),0) AS net_revenue\n FROM economic_runs`);\n\nconsole.log(JSON.stringify({\n service: \"chat-native-maestro/economic\",\n version: ECONOMIC_POLICY.version,\n agents: agents.rows,\n opportunities: opportunities.rows,\n runs: runs.rows,\n champions: champions.rows,\n latestAgents: latestAgents.rows,\n latestOpportunities: latestOpportunities.rows,\n failureClasses: failures.rows,\n successPatterns: success.rows,\n totals: totals.rows[0] ?? {},\n realRevenueState: Number(totals.rows[0]?.gross_revenue ?? 0) > 0 ? \"NONZERO\" : \"ZERO\",\n timestamp: new Date().toISOString(),\n}, null, 2));\n","createdAt",["D",1788715412721],"branchVersion","branchId","f6b18fe8-8463-44a7-8607-6aadc93451c1","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",{"_100":99,"_108":104},"org",{"_100":99,"_101":102,"_103":104,"_18":53,"_105":106,"_107":24},"branch",{"_13":87,"_31":88,"_41":40,"_89":42,"_90":91,"_92":93,"_94":48,"_95":42,"_96":63,"_97":43,"_98":99},"isOwned",930,"economic-v0.6","projectId","forkedBranchId","22a6b9fb-662c-4823-89b0-7ec510c82fcd","forkedBranchVersion",68,"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",{"_41":42,"_31":43,"_36":434,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":435,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":436,"_82":437,"_84":438,"_86":24},"tree",[248,255,263,267,268,269,270,271,272,273,274,275,276,277],"files",[248,249,250,251,252,253,254,255,256,257,258,259,260,261,262,263,264,265,266,267,268,269,270,271,272,273,274,275,276,277],"counts",{"_238":61,"_239":212,"_240":61,"_241":242,"_243":244},"contents",[138,139,140,141,142,143,144,145,146,147,148,149,150,151],"upstreamProject","upstreamBranch",{"_41":91,"_36":132,"_133":134,"_31":135,"_89":42,"_13":93,"_90":-5,"_92":-5,"_136":137,"_45":-5,"_86":24,"_47":48,"_98":99,"_62":63,"_97":43},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1788707065045],"updatedAt",["D",1788709584572],"main","lockfileKey","1788709584801-esm.town_v_cleitoncosta_chat-native-maestro@68-main",{"_41":233,"_31":234,"_29":235,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":236,"_13":61,"_32":226,"_34":-5,"_23":24,"_160":-5,"_26":237},{"_41":228,"_31":229,"_29":230,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":231,"_13":61,"_32":226,"_34":-5,"_23":24,"_160":-5,"_26":232},{"_41":222,"_31":223,"_29":224,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":225,"_13":61,"_32":226,"_34":-5,"_23":24,"_160":-5,"_26":227},{"_41":216,"_31":217,"_29":218,"_155":-5,"_39":40,"_38":156,"_157":24,"_36":219,"_13":61,"_32":20,"_34":220,"_23":24,"_160":-5,"_26":221},{"_41":209,"_31":210,"_29":211,"_155":-5,"_39":40,"_38":212,"_157":57,"_36":213,"_13":61,"_32":33,"_34":214,"_23":24,"_160":-5,"_26":215},{"_41":202,"_31":203,"_29":204,"_155":-5,"_39":40,"_38":205,"_157":57,"_36":206,"_13":61,"_32":33,"_34":207,"_23":24,"_160":-5,"_26":208},{"_41":199,"_31":27,"_29":30,"_155":-5,"_39":40,"_38":14,"_157":24,"_36":200,"_13":61,"_32":33,"_34":35,"_23":24,"_160":-5,"_26":201},{"_41":192,"_31":193,"_29":194,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":195,"_13":61,"_32":196,"_34":197,"_23":24,"_160":-5,"_26":198},{"_41":186,"_31":187,"_29":188,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":189,"_13":61,"_32":33,"_34":190,"_23":24,"_160":-5,"_26":191},{"_41":180,"_31":181,"_29":182,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":183,"_13":61,"_32":33,"_34":184,"_23":24,"_160":-5,"_26":185},{"_41":174,"_31":175,"_29":176,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":177,"_13":61,"_32":33,"_34":178,"_23":24,"_160":-5,"_26":179},{"_41":168,"_31":169,"_29":170,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":171,"_13":61,"_32":33,"_34":172,"_23":24,"_160":-5,"_26":173},{"_41":162,"_31":163,"_29":164,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":165,"_13":61,"_32":33,"_34":166,"_23":24,"_160":-5,"_26":167},{"_41":152,"_31":153,"_29":154,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":158,"_13":61,"_32":33,"_34":159,"_23":24,"_160":-5,"_26":161},"64265461-4810-40ad-beab-6f2cdc38131f","url_selftest.ts","01a077bc-2b99-740d-9881-6b7404857766","parentId",1,"latest",["D",1788715215771],"import { assertSafeUrl, preflightTaskNetwork } from \"./lib/url_security.ts\";\n\nconst cases = [\n \"https://example.com\",\n \"http://127.0.0.1\",\n \"http://169.254.169.254/latest/meta-data\",\n \"http://localhost\",\n \"https://user:pass@example.com\",\n \"https://example.com:8443\"\n];\n\nconst results: Record = {};\nfor (const value of cases) {\n try {\n results[value] = { ok: true, result: await assertSafeUrl(value) };\n } catch (error) {\n results[value] = { ok: false, error: error instanceof Error ? error.message : String(error) };\n }\n}\n\nlet allowedHostBlocked = false;\ntry {\n await preflightTaskNetwork({\n runId: \"url-selftest\",\n targetUrl: \"https://example.com\",\n risk: \"read_only\",\n purpose: \"URL security selftest\",\n allowedHosts: [\"127.0.0.1\"],\n steps: [{ action: \"expect_url\", contains: \"example.com\" }],\n });\n} catch {\n allowedHostBlocked = true;\n}\n\nconsole.log(JSON.stringify({ results, allowedHostBlocked }, null, 2));\n","label",[153],"d17e92c8-0409-47b8-9ab8-94a9e01ee097","status.ts","01a077bc-2b99-740d-9881-6727e0b68381",["D",1788715215771],"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 schema = await sqlite.execute(\"SELECT key,value,updated_at FROM schema_meta ORDER BY key\");\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 schema: schema.rows,\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 networkPreflight: {\n dnsOverHttps: \"cloudflare-dns.com\",\n failClosed: true,\n blocksPrivateAndReservedIpRanges: true,\n blocksUrlUserinfo: true,\n blocksNonstandardPorts: true,\n },\n automaticSchedule: \"disabled\",\n timestamp: new Date().toISOString(),\n};\n\nconsole.log(JSON.stringify(result, null, 2));\n",[163],"abd98a94-ae35-4165-976e-a3c5acbfba2b","stateful_selftest.ts","01a077bc-2b99-740d-9881-604153bba708",["D",1788715215771],"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",[169],"73e9e358-f044-43f3-8b0c-ee8e3f20e4f8","snapshot_export.ts","01a077bc-2b99-740d-9881-5e611370bab8",["D",1788715215771],"import JSZip from \"npm:jszip\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst release = \"65-main\";\nconst paths = [\n \"main.ts\",\n \"status.ts\",\n \"runner.ts\",\n \"selftest.ts\",\n \"stateful_selftest.ts\",\n \"url_selftest.ts\",\n \"README.md\",\n \"lib/types.ts\",\n \"lib/dsl.ts\",\n \"lib/policy.ts\",\n \"lib/provider_health.ts\",\n \"lib/cost.ts\",\n \"lib/url_security.ts\",\n \"providers/router.ts\",\n \"providers/kernel.ts\",\n \"providers/browserless.ts\",\n \"docs/CURRENT_STATE.md\",\n \"docs/PROVIDER_CENSUS.md\",\n \"docs/ACTIVATION_RUNBOOK.md\",\n \"docs/TASK_SCHEMA.md\",\n \"docs/SMOKE_TASK.json\",\n \"docs/SECURITY_MODEL.md\",\n];\n\nconst zip = new JSZip();\nconst manifest: Array<{ path: string; bytes: number; sha256: string; sourceUrl: string }> = [];\nconst enc = new TextEncoder();\nconst hex = (bytes: ArrayBuffer) => [...new Uint8Array(bytes)].map((x) => x.toString(16).padStart(2, \"0\")).join(\"\");\n\nfor (const path of paths) {\n const sourceUrl = `https://esm.town/v/cleitoncosta/chat-native-maestro@${release}/${path}`;\n const response = await fetch(sourceUrl, { signal: AbortSignal.timeout(10_000) });\n if (!response.ok) throw new Error(`${path}: HTTP ${response.status}`);\n let text = await response.text();\n if (path.endsWith(\".ts\") || path.endsWith(\".tsx\")) {\n text = text.replace(/^\\/\\* Open in Val Town: [^\\n]+ \\*\\/\\n/, \"\");\n }\n const bytes = enc.encode(text);\n const sha256 = hex(await crypto.subtle.digest(\"SHA-256\", bytes));\n manifest.push({ path, bytes: bytes.byteLength, sha256, sourceUrl });\n zip.file(path, text);\n}\n\nconst metadata = {\n name: \"CHATGPT_CHAT_NATIVE_MAESTRO_V0_5_0_CLOUD_SNAPSHOT\",\n sourceVal: \"cleitoncosta/chat-native-maestro\",\n sourceBranchRelease: release,\n appVersion: \"0.5.0\",\n exportedAt: new Date().toISOString(),\n fileCount: paths.length,\n credentialsIncluded: false,\n databaseContentsIncluded: false,\n note: \"Source files fetched from immutable esm.town release URLs; esm.town TypeScript display header removed before packaging.\",\n};\nzip.file(\"LIVE_EXPORT_METADATA.json\", JSON.stringify(metadata, null, 2));\nzip.file(\"SOURCE_MANIFEST.json\", JSON.stringify(manifest, null, 2));\nconst base64 = await zip.generateAsync({ type: \"base64\", compression: \"DEFLATE\", compressionOptions: { level: 9 } });\nconst blobKey = \"release:v0.5.0:source.zip.b64\";\nawait blob.set(blobKey, base64);\nconst base64Sha256 = hex(await crypto.subtle.digest(\"SHA-256\", enc.encode(base64)));\nconsole.log(JSON.stringify({ metadata, manifest, blobKey, base64Length: base64.length, base64Sha256 }));\n",[175],"53ccefb1-9a83-4be5-a76f-668e29910d84","selftest.ts","01a077bc-2b99-740d-9881-5a19ff4d14c8",["D",1788715215771],"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",[181],"78c1b1fd-24a3-47f8-83ee-334894178982","runner.ts","01a077bc-2b99-740d-9881-57dc4656df82",["D",1788715215771],"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\";\nimport { preflightTaskNetwork } from \"./lib/url_security.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 networkPreflight: meta.networkPreflight,\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 let networkPreflight: Array<{ host: string; ips: string[] }>;\n try {\n networkPreflight = await preflightTaskNetwork(task);\n } catch (error) {\n return blockTask(row, task, [`NETWORK_PREFLIGHT_BLOCKED: ${error instanceof Error ? error.message : String(error)}`]);\n }\n\n const receipt = await executeRouted(task);\n receipt.providerMeta = { ...(receipt.providerMeta ?? {}), networkPreflight };\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",[187],"0b8a62cc-6643-43ee-836c-80ffdb940f3c","main.ts","01a077bc-2b99-740d-9881-5062f5c9e3f1",["D",1788715215771],"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",[193],"b801b19d-8ffd-46f2-b91f-95bfcaf64602",["D",1788715412721],[27],"aa858d97-bbd1-487f-951e-c22790b9a453","economic_selftest.ts","66d41424-aa17-11f1-9a39-1607ee4eb77e",4,["D",1788715291111],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { ECONOMIC_POLICY, evaluateEconomicAction, netRevenue } from \"./lib/economic_policy.ts\";\n\nconst cases = {\n r0: evaluateEconomicAction({ actionClass: \"R0_OBSERVE\" }),\n r1: evaluateEconomicAction({ actionClass: \"R1_PREPARE\" }),\n r2: evaluateEconomicAction({ actionClass: \"R2_REVERSIBLE_WRITE\" }),\n r3Blocked: evaluateEconomicAction({ actionClass: \"R3_COMMIT_SUBMIT\", approved: false }),\n r3Approved: evaluateEconomicAction({ actionClass: \"R3_COMMIT_SUBMIT\", approved: true }),\n r4BlockedNoApproval: evaluateEconomicAction({ actionClass: \"R4_ECONOMIC_SPEND\", amount: 1, maxBudget: 5, approved: false }),\n r4BlockedBudget: evaluateEconomicAction({ actionClass: \"R4_ECONOMIC_SPEND\", amount: 6, maxBudget: 5, approved: true }),\n r4Approved: evaluateEconomicAction({ actionClass: \"R4_ECONOMIC_SPEND\", amount: 4, maxBudget: 5, approved: true }),\n r5: evaluateEconomicAction({ actionClass: \"R5_IDENTITY_LEGAL\", approved: true }),\n};\n\nconst profitCase = netRevenue({ grossRevenue: 10, browserCost: 1, llmCost: 2, apiCost: 0.5, platformFee: 1 });\nconst lossCase = netRevenue({ grossRevenue: 5, browserCost: 4, llmCost: 3 });\nconst tables = await sqlite.execute(`SELECT name FROM sqlite_master WHERE type='table' AND name IN (\n 'economic_agents','opportunities','economic_runs','negative_knowledge','success_patterns','economic_champions'\n) ORDER BY name`);\nconst root = await sqlite.execute(`SELECT agent_id,parent_id,generation,lineage,status FROM economic_agents WHERE agent_id='A0'`);\n\nconst checks = [\n { name: \"R0 auto\", pass: cases.r0.allowed && !cases.r0.humanGate },\n { name: \"R1 auto\", pass: cases.r1.allowed && !cases.r1.humanGate },\n { name: \"R2 auto\", pass: cases.r2.allowed && !cases.r2.humanGate },\n { name: \"R3 blocks without approval\", pass: !cases.r3Blocked.allowed && cases.r3Blocked.reason === \"NEEDS_COMMIT_APPROVAL\" },\n { name: \"R3 allows approved\", pass: cases.r3Approved.allowed },\n { name: \"R4 blocks no approval\", pass: !cases.r4BlockedNoApproval.allowed },\n { name: \"R4 enforces budget\", pass: !cases.r4BlockedBudget.allowed && cases.r4BlockedBudget.reason === \"BUDGET_EXCEEDED\" },\n { name: \"R4 permits approved in-budget\", pass: cases.r4Approved.allowed },\n { name: \"R5 always human gate\", pass: !cases.r5.allowed && cases.r5.humanGate },\n { name: \"net revenue profit\", pass: profitCase === 5.5 },\n { name: \"net revenue loss\", pass: lossCase === -2 },\n { name: \"all economic tables present\", pass: tables.rows.length === 6 },\n { name: \"A0 root present\", pass: root.rows.length === 1 && root.rows[0].generation === 0 },\n];\n\nconst failed = checks.filter((x) => !x.pass);\nconsole.log(JSON.stringify({\n status: failed.length ? \"FAIL\" : \"PASS\",\n version: ECONOMIC_POLICY.version,\n checks,\n failed,\n cases,\n profitCase,\n lossCase,\n tables: tables.rows,\n root: root.rows,\n}, null, 2));\nif (failed.length) throw new Error(`economic_selftest failed: ${failed.map((x) => x.name).join(', ')}`);\n",[203],"c2e35226-ae2c-4a39-bfb8-3af34f7addf3","economic_migrate.ts","5a85f9ee-aa17-11f1-8f39-1607ee4eb77e",3,["D",1788715270460],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst now = new Date().toISOString();\n\nawait sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS economic_agents (\n agent_id TEXT PRIMARY KEY,\n parent_id TEXT,\n generation INTEGER NOT NULL DEFAULT 0,\n lineage TEXT NOT NULL,\n hypothesis TEXT NOT NULL,\n strategy TEXT NOT NULL,\n status TEXT NOT NULL,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL,\n FOREIGN KEY(parent_id) REFERENCES economic_agents(agent_id)\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS opportunities (\n opportunity_id TEXT PRIMARY KEY,\n title TEXT NOT NULL,\n source TEXT NOT NULL,\n url TEXT,\n category TEXT NOT NULL,\n deadline TEXT,\n payout_currency TEXT,\n payout_max REAL,\n estimated_cost REAL NOT NULL DEFAULT 0,\n human_dependency REAL NOT NULL DEFAULT 1,\n evidence_state TEXT NOT NULL,\n status TEXT NOT NULL,\n score REAL,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS economic_runs (\n run_id TEXT PRIMARY KEY,\n agent_id TEXT NOT NULL,\n opportunity_id TEXT,\n browser_run_id TEXT,\n action_class TEXT NOT NULL,\n strategy_variant TEXT,\n provider TEXT,\n state TEXT NOT NULL,\n gross_revenue REAL NOT NULL DEFAULT 0,\n currency TEXT NOT NULL DEFAULT 'BRL',\n browser_cost REAL NOT NULL DEFAULT 0,\n llm_cost REAL NOT NULL DEFAULT 0,\n api_cost REAL NOT NULL DEFAULT 0,\n hosting_cost REAL NOT NULL DEFAULT 0,\n platform_fee REAL NOT NULL DEFAULT 0,\n transaction_cost REAL NOT NULL DEFAULT 0,\n net_revenue REAL NOT NULL DEFAULT 0,\n evidence_json TEXT,\n started_at TEXT NOT NULL,\n finished_at TEXT,\n FOREIGN KEY(agent_id) REFERENCES economic_agents(agent_id),\n FOREIGN KEY(opportunity_id) REFERENCES opportunities(opportunity_id)\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS negative_knowledge (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n agent_id TEXT,\n opportunity_id TEXT,\n failure_class TEXT NOT NULL,\n cause TEXT NOT NULL,\n context TEXT,\n detector TEXT,\n avoid_rule TEXT,\n evidence_json TEXT,\n created_at TEXT NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS success_patterns (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n agent_id TEXT,\n opportunity_id TEXT,\n mechanism TEXT NOT NULL,\n preconditions TEXT,\n counterfactual TEXT,\n boundaries TEXT,\n replication_count INTEGER NOT NULL DEFAULT 0,\n confidence REAL NOT NULL DEFAULT 0,\n evidence_json TEXT,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS economic_champions (\n champion_class TEXT PRIMARY KEY,\n agent_id TEXT NOT NULL,\n run_id TEXT,\n metric_value REAL NOT NULL DEFAULT 0,\n currency TEXT NOT NULL DEFAULT 'BRL',\n updated_at TEXT NOT NULL\n )`,\n },\n { sql: `CREATE INDEX IF NOT EXISTS idx_economic_agents_parent ON economic_agents(parent_id)` },\n { sql: `CREATE INDEX IF NOT EXISTS idx_opportunities_status_score ON opportunities(status, score)` },\n { sql: `CREATE INDEX IF NOT EXISTS idx_economic_runs_agent ON economic_runs(agent_id, started_at)` },\n { sql: `CREATE INDEX IF NOT EXISTS idx_economic_runs_opportunity ON economic_runs(opportunity_id, started_at)` },\n {\n sql: `INSERT OR IGNORE INTO economic_agents(agent_id,parent_id,generation,lineage,hypothesis,strategy,status,created_at,updated_at)\n VALUES('A0',NULL,0,'A0','Find economically viable opportunities with minimal human dependency','Neurônio root: branch, measure, falsify, replicate winners','INCUBATION',?,?)`,\n args: [now, now],\n },\n {\n sql: `INSERT INTO schema_meta(key,value,updated_at) VALUES('economic_schema_version','0.6.0-candidate',?)\n ON CONFLICT(key) DO UPDATE SET value=excluded.value, updated_at=excluded.updated_at`,\n args: [now],\n },\n]);\n\nconst tables = await sqlite.execute(`SELECT name FROM sqlite_master WHERE type='table' AND name IN (\n 'economic_agents','opportunities','economic_runs','negative_knowledge','success_patterns','economic_champions'\n) ORDER BY name`);\nconst root = await sqlite.execute(`SELECT agent_id,generation,lineage,status FROM economic_agents WHERE agent_id='A0'`);\nconsole.log(JSON.stringify({ status: 'PASS', economicSchemaVersion: '0.6.0-candidate', tables: tables.rows, root: root.rows }, null, 2));\n",[210],"ae39bf64-442c-408a-a4d7-fb176828672b","README.md","01a077bc-2b99-740d-9881-4e48ec93504b",["D",1788715215771],"# Chat-Native Maestro V0.5.0\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- No automatic browser schedule is enabled.\n\n## Runtime path\n\n`ChatGPT -> authenticated Val Town plugin -> val-scoped SQLite -> runner.ts -> provider router -> cloud browser -> verified receipt`\n\nThe public HTTP endpoint is liveness-only. Provider configuration, task state, receipts, health and cost metrics are available only through authenticated `status.ts` execution.\n\n## Browser routing\n\n1. Kernel — primary/champion.\n2. Browserless — recurring-free fallback.\n3. Browserbase — researched fallback, not implemented.\n4. Steel — one-time-credit fallback, not preferred for steady state.\n\nCross-provider fallback is allowed only for `read_only`. A write failure is never replayed automatically on another provider because failure is not proof of zero side effects.\n\n## Current provider economics (research snapshot 2026-09-06)\n\n### Kernel Free\n\n- $0/month plus usage costs.\n- $5/month free credits.\n- 5 concurrent browsers.\n- live view.\n- stealth mode with CAPTCHA solver/proxy.\n- managed auth.\n- no card required to get started.\n- usage model: GB-second.\n\n### Browserless Free\n\n- 1,000 units/month.\n- 2 concurrent browsers.\n- 2-minute max session.\n- no card required.\n- browser time: 1 unit per 30-second block.\n- successful CAPTCHA solve: additional units.\n- built-in proxies: additional units.\n- provider supports an overage cap that should be set to $0 for this project's zero-surprise-cost policy.\n\n## Browser DSL\n\nSupported:\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 task schema.\n\nThe `value` attribute is blocked from `extract_attribute` to reduce accidental credential exfiltration after form fill.\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 explicit approval, even during a read-oriented flow.\n\n## Secret handling\n\nPasswords, cookies and provider tokens must never be stored in `task_json`.\n\nUse:\n\n```json\n{\"action\":\"fill_secret\",\"selector\":\"#password\",\"envVar\":\"PORTAL_PASSWORD\"}\n```\n\nOnly the environment-variable name is stored. The value is resolved in memory immediately before execution.\n\nProvider credentials belong only in Val Town env vars:\n- `KERNEL_API_KEY`\n- `BROWSERLESS_TOKEN`\n- optional `BROWSERLESS_BASE_URL`\n\n## Network / SSRF boundary\n\nBefore any provider call, `runner.ts` runs a fail-closed network preflight:\n\n- only HTTP/HTTPS;\n- URL userinfo is blocked;\n- nonstandard ports are blocked;\n- localhost/private/link-local/reserved/documentation IP ranges are blocked;\n- known metadata/internal hostnames are blocked;\n- `allowedHosts` are validated;\n- hostnames are resolved with DNS-over-HTTPS and all A/AAAA results must be public.\n\nThe browser program itself also restricts main-frame navigation to the original target host plus explicit `allowedHosts`.\n\nDNS preflight reduces SSRF/DNS-rebinding risk but is not a mathematical proof against DNS rebinding after the preflight. Provider isolation and post-action validation remain required.\n\n## Read-only browser firewall\n\nWhen `risk=read_only`, browser network requests using methods other than GET/HEAD/OPTIONS are aborted. Popups are closed.\n\nThis prevents common POST/PUT/PATCH/DELETE side effects. It cannot guarantee zero side effects on badly designed GET endpoints.\n\n## Reliability controls\n\n- task `run_id` is unique/idempotent;\n- atomic queue claim;\n- 90-second RUNNING lease;\n- stale lease recovery;\n- max 2 task attempts;\n- read-only FAIL retry delay: 10 seconds;\n- writes are not auto-retried;\n- browser timeout: 25 seconds;\n- Kernel cleanup timeout: 5 seconds;\n- provider circuit opens after 3 consecutive provider FAILs;\n- circuit cooldown: 15 minutes;\n- BLOCKED configuration errors do not degrade provider health;\n- no cron/automatic runner, so eligible retries still require an explicit ChatGPT runner invocation.\n\n## Evidence retention\n\nDefault is `minimal`:\n- status;\n- final URL;\n- expectations/checks;\n- error;\n- duration;\n- fallback metadata;\n- DNS preflight evidence.\n\nExtracted outputs and provider session IDs are not persisted by default.\n\nUse `evidenceRetention: \"full\"` only when the extracted output is intentionally safe to retain.\n\n## Cost telemetry\n\n`browser_attempts` records per-attempt provider/status/duration and an estimated Browserless browser-time unit count.\n\nBrowserless estimates exclude CAPTCHA/proxy add-ons. Kernel usage is not estimated locally because its billing basis is GB-second; actual account usage must be observed from Kernel.\n\n## PASS rule\n\n`TOOL_SUCCESS_RESPONSE != BEHAVIOR_PROOF`.\n\nA browser execution with no positive expectation remains `PARTIAL`. `PASS` requires all explicit expectations to succeed.\n\n## Current live evidence\n\nPASS:\n- Val Town plugin authenticated.\n- Free workspace.\n- create/edit/run/deploy.\n- public liveness endpoint.\n- authenticated diagnostics.\n- val-scoped SQLite.\n- schema versioning.\n- atomic task claim.\n- stale lease recovery.\n- persisted task/attempt receipts.\n- retry decision logic.\n- timeout control.\n- provider circuit breaker and restore test.\n- risk approval gate.\n- secret approval gate.\n- invalid provider rejection.\n- `value` attribute extraction rejection.\n- DNS-over-HTTPS preflight.\n- private/metadata URL blocking in both self-test and runner pipeline.\n- Kernel SDK module loading.\n- Browserless adapter module loading.\n- safe missing-provider-credential classification.\n\nUNVERIFIED:\n- Kernel API authentication for this account.\n- live Kernel browser creation.\n- live Kernel Playwright execution.\n- Kernel actual credit consumption.\n- Browserless API authentication for this account.\n- live Browserless `/function` execution.\n- Browserless actual unit consumption.\n\nNo user-created environment variables are currently configured, so no live browser provider has been promoted to OPERATIONAL.\n\n## Next milestone\n\n`docs/SMOKE_TASK.json` is deliberately a DRAFT, not a queued task. After exactly one provider credential is configured, ChatGPT can enqueue that read-only smoke task, run `runner.ts`, persist the attempt and promote the provider only if the explicit expectations PASS.\n\nSee:\n- `docs/CURRENT_STATE.md`\n- `docs/PROVIDER_CENSUS.md`\n- `docs/ACTIVATION_RUNBOOK.md`\n- `docs/TASK_SCHEMA.md`\n- `docs/SMOKE_TASK.json`\n",[217],"9e625300-a023-4458-8c07-bea2447f6601","providers","01a077bc-2b99-740d-9881-4952f29c18f3",["D",1788715215771],"directory",[223],"94b02e1c-a9b9-457c-8c32-1b19e33e4ad5","lib","01a077bc-2b99-740d-9881-3bf068d89182",["D",1788715215771],[229],"3e709f84-5c5f-42d7-bfae-c6fc769c7f45","docs","01a077bc-2b99-740d-9881-1e90a3c35ec2",["D",1788715215771],[234],"pulls","branches","forks","envVars",{"_245":61,"_247":61},"connections",{"_245":61,"_246":61},"count","unfilledCount","emptyCount",{"_41":233,"_31":234,"_29":235,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":431,"_13":61,"_32":226,"_34":-5,"_23":24,"_160":-5,"_279":432,"_26":433},{"_41":424,"_31":425,"_29":426,"_155":235,"_39":40,"_38":156,"_157":57,"_36":427,"_13":61,"_32":20,"_34":428,"_23":24,"_160":-5,"_279":429,"_26":430},{"_41":417,"_31":418,"_29":419,"_155":235,"_39":40,"_38":156,"_157":57,"_36":420,"_13":61,"_32":20,"_34":421,"_23":24,"_160":-5,"_279":422,"_26":423},{"_41":410,"_31":411,"_29":412,"_155":235,"_39":40,"_38":156,"_157":57,"_36":413,"_13":61,"_32":20,"_34":414,"_23":24,"_160":-5,"_279":415,"_26":416},{"_41":403,"_31":404,"_29":405,"_155":235,"_39":40,"_38":156,"_157":57,"_36":406,"_13":61,"_32":20,"_34":407,"_23":24,"_160":-5,"_279":408,"_26":409},{"_41":396,"_31":397,"_29":398,"_155":235,"_39":40,"_38":156,"_157":57,"_36":399,"_13":61,"_32":20,"_34":400,"_23":24,"_160":-5,"_279":401,"_26":402},{"_41":389,"_31":390,"_29":391,"_155":235,"_39":40,"_38":156,"_157":57,"_36":392,"_13":61,"_32":20,"_34":393,"_23":24,"_160":-5,"_279":394,"_26":395},{"_41":228,"_31":229,"_29":230,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":386,"_13":61,"_32":226,"_34":-5,"_23":24,"_160":-5,"_279":387,"_26":388},{"_41":379,"_31":380,"_29":381,"_155":230,"_39":40,"_38":156,"_157":57,"_36":382,"_13":61,"_32":33,"_34":383,"_23":24,"_160":-5,"_279":384,"_26":385},{"_41":372,"_31":373,"_29":374,"_155":230,"_39":40,"_38":156,"_157":57,"_36":375,"_13":61,"_32":33,"_34":376,"_23":24,"_160":-5,"_279":377,"_26":378},{"_41":364,"_31":365,"_29":366,"_155":230,"_39":40,"_38":367,"_157":57,"_36":368,"_13":61,"_32":33,"_34":369,"_23":24,"_160":-5,"_279":370,"_26":371},{"_41":357,"_31":358,"_29":359,"_155":230,"_39":40,"_38":156,"_157":57,"_36":360,"_13":61,"_32":33,"_34":361,"_23":24,"_160":-5,"_279":362,"_26":363},{"_41":350,"_31":351,"_29":352,"_155":230,"_39":40,"_38":156,"_157":57,"_36":353,"_13":61,"_32":33,"_34":354,"_23":24,"_160":-5,"_279":355,"_26":356},{"_41":343,"_31":344,"_29":345,"_155":230,"_39":40,"_38":156,"_157":57,"_36":346,"_13":61,"_32":33,"_34":347,"_23":24,"_160":-5,"_279":348,"_26":349},{"_41":336,"_31":337,"_29":338,"_155":230,"_39":40,"_38":156,"_157":57,"_36":339,"_13":61,"_32":33,"_34":340,"_23":24,"_160":-5,"_279":341,"_26":342},{"_41":222,"_31":223,"_29":224,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":333,"_13":61,"_32":226,"_34":-5,"_23":24,"_160":-5,"_279":334,"_26":335},{"_41":326,"_31":327,"_29":328,"_155":224,"_39":40,"_38":156,"_157":57,"_36":329,"_13":61,"_32":33,"_34":330,"_23":24,"_160":-5,"_279":331,"_26":332},{"_41":319,"_31":320,"_29":321,"_155":224,"_39":40,"_38":156,"_157":57,"_36":322,"_13":61,"_32":33,"_34":323,"_23":24,"_160":-5,"_279":324,"_26":325},{"_41":312,"_31":313,"_29":314,"_155":224,"_39":40,"_38":156,"_157":57,"_36":315,"_13":61,"_32":33,"_34":316,"_23":24,"_160":-5,"_279":317,"_26":318},{"_41":216,"_31":217,"_29":218,"_155":-5,"_39":40,"_38":156,"_157":24,"_36":309,"_13":61,"_32":20,"_34":220,"_23":24,"_160":-5,"_279":310,"_26":311},{"_41":209,"_31":210,"_29":211,"_155":-5,"_39":40,"_38":212,"_157":57,"_36":306,"_13":61,"_32":33,"_34":214,"_23":24,"_160":-5,"_279":307,"_26":308},{"_41":202,"_31":203,"_29":204,"_155":-5,"_39":40,"_38":205,"_157":57,"_36":303,"_13":61,"_32":33,"_34":207,"_23":24,"_160":-5,"_279":304,"_26":305},{"_41":199,"_31":27,"_29":30,"_155":-5,"_39":40,"_38":14,"_157":24,"_36":300,"_13":61,"_32":33,"_34":35,"_23":24,"_160":-5,"_279":301,"_26":302},{"_41":192,"_31":193,"_29":194,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":297,"_13":61,"_32":196,"_34":197,"_23":24,"_160":-5,"_279":298,"_26":299},{"_41":186,"_31":187,"_29":188,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":294,"_13":61,"_32":33,"_34":190,"_23":24,"_160":-5,"_279":295,"_26":296},{"_41":180,"_31":181,"_29":182,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":291,"_13":61,"_32":33,"_34":184,"_23":24,"_160":-5,"_279":292,"_26":293},{"_41":174,"_31":175,"_29":176,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":288,"_13":61,"_32":33,"_34":178,"_23":24,"_160":-5,"_279":289,"_26":290},{"_41":168,"_31":169,"_29":170,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":285,"_13":61,"_32":33,"_34":172,"_23":24,"_160":-5,"_279":286,"_26":287},{"_41":162,"_31":163,"_29":164,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":282,"_13":61,"_32":33,"_34":166,"_23":24,"_160":-5,"_279":283,"_26":284},{"_41":152,"_31":153,"_29":154,"_155":-5,"_39":40,"_38":156,"_157":57,"_36":278,"_13":61,"_32":33,"_34":159,"_23":24,"_160":-5,"_279":280,"_26":281},["D",1788715215771],"children",[],[153],["D",1788715215771],[],[163],["D",1788715215771],[],[169],["D",1788715215771],[],[175],["D",1788715215771],[],[181],["D",1788715215771],[],[187],["D",1788715215771],[],[193],["D",1788715412721],[],[27],["D",1788715291111],[],[203],["D",1788715270460],[],[210],["D",1788715215771],[],[217],"55194c44-26a6-467a-b820-b6fead64159d","router.ts","01a077bc-2b99-740d-9881-4721aef6fa58",["D",1788715215771],"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",[],[223,313],"fc83999d-4ff9-4e7c-abc1-af6110dc1d07","kernel.ts","01a077bc-2b99-740d-9881-42c7df42306f",["D",1788715215771],"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",[],[223,320],"26c3a975-f21b-42bd-bb91-c1a4c17ea40b","browserless.ts","01a077bc-2b99-740d-9881-3f2f98b23d50",["D",1788715215771],"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",[],[223,327],["D",1788715215771],[264,265,266],[223],"55c421c5-2ce5-4f82-9115-c76d40c7214a","url_security.ts","01a077bc-2b99-740d-9881-355e348197e4",["D",1788715215771],"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",[],[229,337],"b13f2e19-c7f4-4bcb-935b-b449dfda8b0e","types.ts","01a077bc-2b99-740d-9881-31a5d93088f8",["D",1788715215771],"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",[],[229,344],"5257a923-09fd-451f-b4c5-eaa39b641d34","provider_health.ts","01a077bc-2b99-740d-9881-2d5b14823b37",["D",1788715215771],"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",[],[229,351],"7ad8bdee-273b-4d7c-abcf-bb2f5d966c86","policy.ts","01a077bc-2b99-740d-9881-280da64a368a",["D",1788715215771],"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",[],[229,358],"bc8cbefe-eadd-4ab1-a695-c92931a29c9c","economic_policy.ts","4fb3747e-aa17-11f1-8e41-1607ee4eb77e",2,["D",1788715252312],"export type EconomicActionClass =\n | \"R0_OBSERVE\"\n | \"R1_PREPARE\"\n | \"R2_REVERSIBLE_WRITE\"\n | \"R3_COMMIT_SUBMIT\"\n | \"R4_ECONOMIC_SPEND\"\n | \"R5_IDENTITY_LEGAL\";\n\nexport type EconomicActionRequest = {\n actionClass: EconomicActionClass;\n approved?: boolean;\n amount?: number;\n maxBudget?: number;\n};\n\nexport type EconomicActionDecision = {\n allowed: boolean;\n humanGate: boolean;\n reason: string;\n};\n\nexport const ECONOMIC_POLICY = {\n version: \"0.6.0-candidate\",\n defaultBudget: 0,\n actionClasses: {\n R0_OBSERVE: \"Research/read/analyze only\",\n R1_PREPARE: \"Create local/draft artifacts without external commitment\",\n R2_REVERSIBLE_WRITE: \"Reversible external writes such as saving a draft\",\n R3_COMMIT_SUBMIT: \"External commitment such as submit/publish/PR\",\n R4_ECONOMIC_SPEND: \"Any action that spends money or credits\",\n R5_IDENTITY_LEGAL: \"KYC, banking, payout setup, legal or identity declarations\",\n },\n} as const;\n\nexport function evaluateEconomicAction(req: EconomicActionRequest): EconomicActionDecision {\n switch (req.actionClass) {\n case \"R0_OBSERVE\":\n case \"R1_PREPARE\":\n case \"R2_REVERSIBLE_WRITE\":\n return { allowed: true, humanGate: false, reason: \"AUTO_ALLOWED_BY_CLASS\" };\n case \"R3_COMMIT_SUBMIT\":\n return req.approved\n ? { allowed: true, humanGate: false, reason: \"CONTROLLED_WRITE_APPROVED\" }\n : { allowed: false, humanGate: true, reason: \"NEEDS_COMMIT_APPROVAL\" };\n case \"R4_ECONOMIC_SPEND\": {\n const amount = req.amount ?? 0;\n const budget = req.maxBudget ?? ECONOMIC_POLICY.defaultBudget;\n if (!req.approved) return { allowed: false, humanGate: true, reason: \"NEEDS_SPEND_APPROVAL\" };\n if (amount < 0) return { allowed: false, humanGate: true, reason: \"INVALID_NEGATIVE_AMOUNT\" };\n if (amount > budget) return { allowed: false, humanGate: true, reason: \"BUDGET_EXCEEDED\" };\n return { allowed: true, humanGate: false, reason: \"SPEND_WITHIN_APPROVED_BUDGET\" };\n }\n case \"R5_IDENTITY_LEGAL\":\n return { allowed: false, humanGate: true, reason: \"HUMAN_IDENTITY_OR_LEGAL_GATE\" };\n }\n}\n\nexport function netRevenue(input: {\n grossRevenue?: number;\n browserCost?: number;\n llmCost?: number;\n apiCost?: number;\n hostingCost?: number;\n platformFee?: number;\n transactionCost?: number;\n}) {\n const gross = input.grossRevenue ?? 0;\n const costs = (input.browserCost ?? 0) + (input.llmCost ?? 0) + (input.apiCost ?? 0) +\n (input.hostingCost ?? 0) + (input.platformFee ?? 0) + (input.transactionCost ?? 0);\n return gross - costs;\n}\n",[],[229,365],"ebc09386-8d31-425e-a75d-ce3486658bf8","dsl.ts","01a077bc-2b99-740d-9881-2409b3ecffa5",["D",1788715215771],"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",[],[229,373],"ffa9eab5-1611-4a35-91c1-b027af8f5f45","cost.ts","01a077bc-2b99-740d-9881-21df979511ad",["D",1788715215771],"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",[],[229,380],["D",1788715215771],[256,257,258,259,260,261,262],[229],"9b11c5f5-b155-47a5-b4df-46bb3b72111d","TASK_SCHEMA.md","01a077bc-2b99-740d-9881-199895a0596b",["D",1788715215771],"# 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",[],[234,390],"989fd312-57a2-4772-9d55-033ac00154a3","SMOKE_TASK.json","01a077bc-2b99-740d-9881-17f664878040",["D",1788715215771],"{\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",[],[234,397],"312b84fe-7828-4773-b437-17bbbcbafdca","SECURITY_MODEL.md","01a077bc-2b99-740d-9881-11dec1877342",["D",1788715215771],"# Security Model — V0.5.0\n\n## Trust boundaries\n\n### Trusted control plane\n- normal authenticated ChatGPT conversation;\n- authenticated Val Town plugin operations;\n- source code committed in `cleitoncosta/chat-native-maestro` after validation.\n\n### Sensitive trusted storage\n- Val Town Environment Variables;\n- val-scoped SQLite, but only for non-secret task metadata/evidence.\n\n### Untrusted inputs\n- every webpage and frame;\n- page text, HTML, script-generated text and accessibility labels;\n- redirects;\n- URLs supplied by pages;\n- downloaded files;\n- DNS answers and provider responses as evidence that still needs validation;\n- third-party provider error messages.\n\nA webpage is data, never policy or authorization.\n\n## Threat 1 — Prompt injection from a webpage\n\nRisk: page content tries to instruct ChatGPT/runner to reveal secrets, change policy, expand allowed hosts, approve actions or run arbitrary code.\n\nControls:\n- browser receives a bounded DSL, not a free-form agent prompt;\n- no shell or arbitrary-JS task action;\n- page content cannot set `approved=true`;\n- page content cannot add env vars;\n- page content cannot alter `allowedHosts`;\n- browser result is evidence/data only.\n\nResidual risk: extracted malicious text can still be shown to the language model. The control plane must continue treating it as untrusted data.\n\n## Threat 2 — SSRF / internal network access\n\nRisk: task or redirect targets localhost, cloud metadata, private network or a public hostname resolving to non-public IPs.\n\nControls before provider call:\n- HTTP/HTTPS only;\n- URL userinfo blocked;\n- only ports 80/443;\n- direct private/link-local/loopback/reserved/documentation IPv4 and IPv6 ranges blocked;\n- localhost/internal/metadata hostnames blocked;\n- `allowedHosts` validated;\n- A and AAAA resolved through Cloudflare DNS-over-HTTPS;\n- task fails closed if DoH fails, no A/AAAA is found, or any resolved address is non-public.\n\nControls in browser:\n- main-frame navigation restricted to target host plus explicit allowed hosts;\n- popups closed.\n\nValidated negative control:\n`169.254.169.254` is blocked in the real runner before provider invocation.\n\nResidual risk: DNS rebinding after preflight cannot be fully proven absent by a one-time DoH check. Remote browser isolation and navigation checks remain required.\n\n## Threat 3 — Secret leakage\n\nRisk: credentials enter task JSON, source, logs or persistent receipts.\n\nControls:\n- provider credentials only in Val Town env vars;\n- site credentials referenced by env-var name with `fill_secret`;\n- secret value resolved in memory immediately before execution;\n- `fill_secret` requires explicit approval;\n- `extract_attribute: value` blocked;\n- default `evidenceRetention=minimal` omits extracted outputs and provider session IDs;\n- snapshot/export must exclude env-var values and raw sensitive task payloads.\n\nResidual risk: a target site can reflect a submitted secret into ordinary DOM text. The orchestrator must not deliberately extract selectors expected to contain secrets, and `full` retention must not be used for sensitive workflows without a specific reason.\n\n## Threat 4 — Duplicate/replayed writes\n\nRisk: timeout or provider error occurs after a write happened, then another attempt repeats the effect.\n\nControls:\n- automatic retry only for `read_only + FAIL`;\n- no automatic retry for `reversible_write` or `consequential`;\n- no cross-provider fallback for writes;\n- unique `run_id` in SQLite;\n- write tasks require explicit approval.\n\nResidual risk: even a read-classified website can mutate state via GET. The read-only method firewall is strong but cannot prove zero side effects on a badly designed server.\n\n## Threat 5 — Read-only task causes state mutation\n\nControls:\n- browser request firewall allows only GET/HEAD/OPTIONS for `read_only`;\n- common POST/PUT/PATCH/DELETE side effects are blocked;\n- explicit expectations and post-action verification required.\n\nResidual risk:\n- GET endpoints may have side effects;\n- service-worker/browser behavior can be complex;\n- some legitimate read APIs use POST/GraphQL and will fail under strict mode. Do not weaken strict mode silently; use a connector/fetch route or explicitly reclassify the task.\n\n## Threat 6 — Provider degradation / repeated spend\n\nRisk: provider outage causes repeated browser sessions or runaway retries.\n\nControls:\n- max 2 task attempts;\n- 10-second retry eligibility delay;\n- no automatic scheduler;\n- provider circuit opens after 3 consecutive FAILs;\n- 15-minute cooldown;\n- BLOCKED config errors do not increment failure count;\n- PASS/PARTIAL resets provider failures;\n- browser timeouts;\n- Kernel cleanup in `finally`.\n\n## Threat 7 — Stuck RUNNING job\n\nRisk: Val Town/runtime interruption leaves queue permanently locked.\n\nControls:\n- 90-second lease;\n- stale lease recovery;\n- retry budget checked during recovery;\n- terminal failure when retry budget exhausted.\n\nValidated with a real stale-job fixture that was removed after testing.\n\n## Threat 8 — Cost surprise\n\n### Kernel\n- recurring free credits are finite;\n- no automatic runner;\n- short browser timeout;\n- cleanup in `finally`;\n- actual Kernel GB-second usage remains provider-authoritative.\n\n### Browserless\n- local estimate covers base browser-time units only;\n- CAPTCHA/proxy add-ons are not inferred as free;\n- before activation, provider overage spend limit must be set to `$0`;\n- no automatic browser cron;\n- compare local estimated units to provider accounting.\n\n## Threat 9 — False PASS\n\nControls:\n- `TOOL_SUCCESS_RESPONSE != BEHAVIOR_PROOF`;\n- no checks -> `PARTIAL`, not PASS;\n- PASS requires at least one positive expectation and all expectations true;\n- provider/module/pricing availability never promotes a tool to OPERATIONAL;\n- credential, browser creation, actual action, validation and usage evidence are separate states.\n\n## Threat 10 — Public Free-tier source exposure\n\nThe personal Val Town Free workspace requires public source visibility.\n\nControls:\n- no secrets in source;\n- public HTTP endpoint exposes liveness only;\n- detailed task/provider state stays behind authenticated plugin execution;\n- env-var values are never returned by normal Val Town listing tools;\n- source assumes it is publicly readable.\n\n## Evidence-state vocabulary\n\n- `AVAILABLE`: provider/service exists.\n- `ADAPTER_LOADED`: code imports in Val Town.\n- `CONFIGURED`: required env-var key exists.\n- `AUTHENTICATED`: credential proved usable.\n- `AUTHORIZED`: required action is permitted.\n- `EXECUTED`: real provider action occurred.\n- `VERIFIED`: postcondition proved.\n- `OPERATIONAL`: full required chain is repeatedly or sufficiently evidenced for intended scope.\n- `BLOCKED`: known prerequisite prevents execution.\n- `UNVERIFIED`: evidence is absent; not equivalent to failure.\n\nCurrent Kernel and Browserless live-browser state remains `UNVERIFIED` because no user-created provider env vars exist yet.\n",[],[234,404],"43c57926-d688-45f9-bdd4-705fbd5186c1","PROVIDER_CENSUS.md","01a077bc-2b99-740d-9881-0e23597c5715",["D",1788715215771],"# Browser Provider Census — V0.5.0\n\nResearch snapshot: 2026-09-06.\n\nRanking target: normal ChatGPT mobile/web, no user PC, recurring free allowance, deterministic browser control, strong isolation, minimal browser-open time and zero-surprise-cost preference.\n\n## 1. Kernel — CHAMPION\n\nRuntime state: `ACCOUNT_KEY_REQUIRED` / live browser `UNVERIFIED`.\n\nCurrent official Free plan:\n- $0/month plus usage costs\n- $5/month free credits\n- 5 concurrent browsers\n- live view\n- stealth mode including CAPTCHA solver/proxy\n- managed auth (3 connections)\n- one-day session replays\n- uploads/downloads\n- no card required to get started\n- usage billed by GB-second\n\nTechnical fit:\n- official Val Town browser-automation guide/starter\n- `@onkernel/sdk`\n- server-side Playwright execution in the browser VM\n- on-demand `browsers.create()` is explicitly recommended for occasional/bursty/one-off work\n- browser is destroyed in `finally`\n\nAdapter: `providers/kernel.ts`.\nRequired env var: `KERNEL_API_KEY`.\n\nOfficial sources:\n- https://www.kernel.sh/pricing\n- https://www.kernel.sh/docs\n- https://docs.val.town/guides/browser-automation/kernel\n\n## 2. Browserless — RECURRING-FREE FALLBACK\n\nRuntime state: `ACCOUNT_TOKEN_REQUIRED` / live browser `UNVERIFIED`.\n\nCurrent official Free plan:\n- 1,000 units/month\n- 2 concurrent browsers\n- 2-minute max session\n- no card required\n- Chrome / WebKit / Firefox\n- automatic CAPTCHA solving available\n- persisted sessions/replays\n\nUnit model:\n- browser time: 1 unit per 30-second connection block\n- partial blocks round up\n- successful CAPTCHA solve: 10 additional units\n- residential proxy: 6 units/MB\n- datacenter proxy: 2 units/MB\n\nSeptember 2026 provider control:\n- account overage spend limit can be set to `$0`\n- this should be mandatory before promotion to fallback OPERATIONAL under this project's zero-surprise-cost policy\n\nAdapter: `providers/browserless.ts`.\nRequired env var: `BROWSERLESS_TOKEN`.\nOptional: `BROWSERLESS_BASE_URL`.\n\nOfficial sources:\n- https://www.browserless.io/pricing\n- https://docs.browserless.io/overview/unit-consumption\n- https://www.browserless.io/changelog/2026-09\n\n## 3. Browserbase — RESEARCHED FALLBACK\n\nState: researched, not implemented.\n\nVal Town has an official Browserbase integration guide and starter. It remains behind Kernel/Browserless because the current combination above better matches recurring-free allowance + CAPTCHA/anti-bot + cost control for this project.\n\nSource:\n- https://docs.val.town/guides/browser-automation/browserbase\n\n## 4. Steel — RESERVE / ONE-TIME-CREDIT PATH\n\nState: researched, not implemented.\n\nUseful properties:\n- open-source browser API\n- Puppeteer/Playwright\n- official Val Town integration guide\n\nLower priority because one-time starter credit is less aligned with recurring zero-cost steady state than Kernel/Browserless.\n\nSource:\n- https://docs.val.town/guides/browser-automation/steel\n\n## Routing rules V0.5\n\n1. Explicit configured `preferredProvider` is honored unless its circuit is OPEN.\n2. Otherwise Kernel is primary.\n3. Browserless fallback is allowed only for `read_only`.\n4. Provider `BLOCKED` for missing configuration does not increment health failures.\n5. Provider `FAIL` increments consecutive failures.\n6. Three consecutive FAILs open the provider circuit for 15 minutes.\n7. PASS/PARTIAL resets provider failure state.\n8. Never automatically retry a write on another provider.\n9. Keep reasoning outside the browser; send only a short deterministic DSL plan.\n10. No automatic cron runs browsers.\n\n## Promotion rule\n\nA provider cannot become `OPERATIONAL` from docs/pricing/module-load alone. Required evidence:\n- env-var key exists\n- credential authenticates\n- real browser is created\n- network preflight passes\n- read-only smoke plan executes\n- explicit expectations PASS\n- attempt is persisted\n- provider health remains CLOSED\n- actual account consumption is observed if available\n\nUntil all of these are true, state remains `UNVERIFIED` even if the SDK call returns successfully.\n",[],[234,411],"875dc314-896d-458c-b402-0a0485726280","CURRENT_STATE.md","01a077bc-2b98-7186-8f2c-a206cdcc09fd",["D",1788715215771],"# CURRENT_STATE — V0.5.0\n\nUpdated: 2026-09-06\n\n## Canonical runtime\n\n`normal ChatGPT mobile/web -> authenticated Val Town plugin -> val-scoped SQLite -> runner.ts -> provider router -> cloud browser -> 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- Public HTTP: minimal liveness only\n- Detailed diagnostics: authenticated `status.ts`\n- Task execution: authenticated Val Town plugin only\n- Persistent state: val-scoped SQLite\n- Schema/app version: 0.5.0\n- Automatic runner/cron: disabled\n\n## Implemented files\n\n### Entrypoints\n- `main.ts` — minimal public GET-only liveness endpoint.\n- `status.ts` — authenticated provider/task/cost/security diagnostics.\n- `runner.ts` — queue lease, validation, network preflight, routed execution, retry decision, receipt persistence.\n- `selftest.ts` — stateless DSL/config regression tests.\n- `stateful_selftest.ts` — circuit breaker, timeout and retry-state regression tests with state restoration.\n- `url_selftest.ts` — URL/DNS/SSRF regression tests.\n\n### Libraries\n- `lib/types.ts` — typed task/receipt/evidence schema.\n- `lib/dsl.ts` — DSL validation, browser program generation, in-memory secret resolution.\n- `lib/policy.ts` — retry/lease/timeout/circuit constants and pure disposition logic.\n- `lib/provider_health.ts` — circuit breaker state machine.\n- `lib/cost.ts` — provider cost-estimation rules.\n- `lib/url_security.ts` — fail-closed URL/DNS-over-HTTPS preflight.\n\n### Providers\n- `providers/router.ts` — provider routing/fallback with health tracking.\n- `providers/kernel.ts` — primary browser adapter.\n- `providers/browserless.ts` — secondary browser adapter.\n\n### Documentation\n- `README.md`\n- `docs/CURRENT_STATE.md`\n- `docs/PROVIDER_CENSUS.md`\n- `docs/ACTIVATION_RUNBOOK.md`\n- `docs/TASK_SCHEMA.md`\n- `docs/SMOKE_TASK.json`\n\n## Database schema V0.5\n\n### `browser_tasks`\nDurable queue and terminal receipt state. New V0.5 fields:\n- `attempt_count`\n- `claimed_at`\n- `next_attempt_at`\n\n### `browser_attempts`\nOne row per provider attempt/fallback with:\n- attempt number\n- provider\n- timestamps\n- status/error\n- duration\n- sanitized receipt\n- estimated Browserless units\n\n### `provider_health`\nCircuit state per provider:\n- `CLOSED` / `HALF_OPEN` / `OPEN`\n- consecutive failures\n- cooldown timestamp\n- last success/failure/error\n\n### `provider_census`\nProvider ranking and current free-tier facts.\n\n### `schema_meta`\n`schema_version=0.5.0`, `app_version=0.5.0`.\n\n## Operational policy V0.5\n\n- max attempts per task: 2\n- read-only FAIL retry delay: 10 s\n- RUNNING lease: 90 s\n- browser execution timeout: 25 s\n- provider circuit opens at 3 consecutive FAILs\n- circuit cooldown: 15 min\n- automatic cross-provider fallback: read-only only\n- automatic scheduled execution: disabled\n\nA retry can become `PENDING`, but it cannot consume browser credits until ChatGPT explicitly invokes the runner again.\n\n## Network security\n\nBefore any provider execution:\n- only HTTP/HTTPS\n- URL credentials/userinfo blocked\n- nonstandard ports blocked\n- private/link-local/loopback/reserved/documentation IPv4/IPv6 blocked\n- localhost/internal/metadata hostnames blocked\n- allowed hosts validated\n- A/AAAA resolved through Cloudflare DNS-over-HTTPS\n- any resolved non-public IP blocks the task\n- DNS/preflight failure fails closed\n\nRunner-level negative-control proof:\n`ssrf-runner-v05 -> BLOCKED / NETWORK_PREFLIGHT_BLOCKED: blocked hostname: 169.254.169.254`\n\nThe fixture was deleted after verification.\n\n## Secret policy\n\nTask JSON never stores secret values.\n`fill_secret` stores only an env-var name and requires explicit approval.\nThe value is resolved in memory immediately before provider execution.\n\n`extract_attribute` of `value` is blocked to reduce accidental credential leakage.\n\nCurrent user-created Val Town env-var count: **0**.\n\n## Evidence retention\n\nDefault: `minimal`.\nPersisted by default:\n- run/provider/status\n- final URL\n- checks\n- errors\n- duration\n- fallback evidence\n- network preflight evidence\n\nNot persisted by default:\n- extracted outputs\n- provider session ID\n\n`full` must be intentionally requested.\n\n## Cost policy\n\n### Kernel\nOfficial current Free plan verified 2026-09-06:\n- $0/month plus usage\n- $5 monthly free credits\n- 5 concurrent browsers\n- no card required to start\n- billed by GB-second\n\nLocal Kernel cost estimate remains unsupported; actual account usage must be observed.\n\n### Browserless\nOfficial current Free plan verified 2026-09-06:\n- 1,000 units/month\n- 2 concurrent browsers\n- max session 2 min\n- no card\n- browser time 1 unit/30 s\n- CAPTCHA/proxy additional\n- overage cap should be set to $0 if Browserless is activated\n\nThe runtime estimates base browser-time units only; actual provider accounting remains authoritative.\n\n## Evidence states\n\n### PASS\n\n- ChatGPT Val Town plugin authentication.\n- Free workspace enumerated.\n- create/edit/run/deploy.\n- public liveness HTTP 200.\n- authenticated diagnostics.\n- SQLite schema/migrations/versioning.\n- atomic queue claim.\n- empty queue behavior.\n- stale RUNNING lease recovery.\n- task attempt persistence.\n- retry policy pure test.\n- timeout test.\n- provider circuit OPEN after three synthetic FAILs and restoration to CLOSED.\n- consequential action approval gate.\n- secret approval gate.\n- invalid provider rejection.\n- `value` attribute extraction block.\n- Kernel SDK adapter module load.\n- Browserless adapter module load.\n- missing provider credential -> BLOCKED.\n- DoH availability through normal Val Town HTTPS egress.\n- public-domain DNS preflight.\n- local/private/metadata/userinfo/nonstandard-port URL blocks.\n- runner-level SSRF block before provider invocation.\n- automatic schedule disabled.\n\n### UNVERIFIED\n\n- Kernel API authentication for this account.\n- live Kernel browser creation.\n- live Kernel server-side Playwright execution.\n- Kernel real credit consumption.\n- Browserless API authentication for this account.\n- live Browserless `/function` execution.\n- Browserless real unit consumption.\n\n## Persistent historical negative controls\n\nThese three V0.4 records intentionally remain in `browser_tasks` as historical evidence:\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\nV0.5 synthetic lease/circuit/SSRF fixtures were removed after tests so production metrics are not polluted.\n\n## Next incomplete milestone\n\nExactly one external action remains necessary: configure a recurring-free browser credential, preferably `KERNEL_API_KEY`, directly in Val Town env vars. Do not paste it into chat.\n\nAfter the key exists:\n1. confirm only the env-var **name** exists;\n2. enqueue `docs/SMOKE_TASK.json` explicitly;\n3. execute `runner.ts` once;\n4. inspect task + attempt receipt;\n5. verify `heading = Example Domain` and all checks PASS;\n6. inspect provider usage;\n7. only then promote Kernel from `ACCOUNT_KEY_REQUIRED/UNVERIFIED` to `OPERATIONAL`.\n",[],[234,418],"59787f7c-1e09-4175-b579-f752ee64d035","ACTIVATION_RUNBOOK.md","01a077bc-2b98-7186-8f2c-9ca4b3fc4a0e",["D",1788715215771],"# Activation Runbook — V0.5.0\n\n## Objetivo\n\nAtivar exatamente um browser cloud sem depender de Codex ou computador do usuário e sem criar execução automática que possa consumir franquia sozinha.\n\nO provider preferido para a primeira ativação é **Kernel**.\n\n## 1. Kernel — ativação preferencial\n\n### Conta e chave\n\n1. Criar ou entrar em uma conta Kernel Free.\n2. Gerar uma API key no dashboard Kernel.\n3. Abrir diretamente o editor de Environment Variables do Val Town.\n4. Criar `KERNEL_API_KEY` com o valor da chave.\n5. Não colar a chave no ChatGPT, README, código, SQLite, issue, log ou task JSON.\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### Após gravar a chave\n\nNão executar browser imediatamente.\n\n1. ChatGPT consulta `list_env_vars` e confirma apenas que o **nome** `KERNEL_API_KEY` existe. O valor não deve ser retornado.\n2. Executar `selftest.ts` e `status.ts`.\n3. Confirmar:\n - Kernel `configured=true`;\n - circuit `CLOSED`;\n - nenhum job `PENDING` inesperado;\n - `automaticSchedule=disabled`.\n4. Ler `docs/SMOKE_TASK.json`.\n5. Inserir explicitamente a task draft no SQLite como `PENDING` somente nesse momento.\n6. Executar `runner.ts` exatamente uma vez.\n7. Ler o registro de `browser_tasks` e `browser_attempts` do smoke.\n8. Exigir:\n - receipt `PASS`;\n - `finalUrl` contém `example.com`;\n - `expect_text` passou;\n - `expect_url` passou;\n - output corrente `heading` é `Example Domain`;\n - attempt persistido;\n - circuit continua `CLOSED`.\n9. Consultar uso/créditos no Kernel, quando disponível.\n10. Somente depois atualizar o estado do Kernel para `OPERATIONAL`.\n\n### Promoção rejeitada se\n\n- SDK retorna sucesso mas expectations falham;\n- receipt é `PARTIAL`;\n- browser cria mas não navega;\n- network preflight falha;\n- circuit abre;\n- consumo não pode ser observado quando isso é material à decisão;\n- qualquer etapa é apenas inferida, não executada.\n\n## 2. Browserless — fallback\n\nAtivar somente se Kernel onboarding estiver bloqueado ou para validar redundância.\n\n### Antes da chave\n\nNo dashboard Browserless, configurar o **overage spend limit para $0**. Isso é requisito deste projeto para evitar cobrança surpresa.\n\nDepois:\n1. criar/entrar na conta Browserless Free;\n2. obter o token;\n3. salvar como `BROWSERLESS_TOKEN` no Val Town;\n4. opcionalmente salvar `BROWSERLESS_BASE_URL` se o account endpoint regional diferir do default;\n5. nunca colar o token em chat/código/SQLite.\n\nVal Town env editor:\nhttps://www.val.town/x/cleitoncosta/chat-native-maestro/environment-variables?key=BROWSERLESS_TOKEN\n\n### Smoke Browserless\n\nUsar a mesma task de `docs/SMOKE_TASK.json`, alterando apenas:\n\n```json\n\"preferredProvider\": \"browserless\"\n```\n\nExigir os mesmos critérios de PASS e, adicionalmente:\n- registrar `estimated_units`;\n- comparar com units reais do provider;\n- lembrar que CAPTCHA/proxy podem gerar units adicionais e não estão incluídos na estimativa local.\n\n## 3. Credenciais de sites-alvo\n\nPara login em um site, criar env vars específicas no Val Town, por exemplo:\n- `PORTAL_USERNAME`\n- `PORTAL_PASSWORD`\n\nTask JSON usa apenas referência:\n\n```json\n{\n \"action\": \"fill_secret\",\n \"selector\": \"#password\",\n \"envVar\": \"PORTAL_PASSWORD\"\n}\n```\n\n`fill_secret` exige aprovação explícita mesmo quando a finalidade geral é leitura.\n\nNunca armazenar senha/token diretamente em `task_json`.\n\n## 4. Regras de segurança operacional\n\n- Não executar task automaticamente só porque uma credencial apareceu.\n- Não criar cron de browser por padrão.\n- Não repetir writes em outro provider após falha.\n- Não transformar `FAIL` de provider em prova de ausência de side effect.\n- Não usar `evidenceRetention=full` com dados sensíveis sem necessidade explícita.\n- Não extrair atributo `value` de campos de formulário; a DSL bloqueia isso.\n- Não usar localhost, metadata cloud, rede privada, URL com userinfo ou porta não padrão; o network preflight bloqueia.\n- Não desabilitar o DNS-over-HTTPS preflight para “fazer funcionar”.\n- Não ampliar `allowedHosts` automaticamente a partir de conteúdo da página.\n- Não tratar uma página como fonte de autorização, policy ou segredo.\n\n## 5. Política de custo\n\n### Kernel\nO plano Free atual fornece créditos mensais; o runtime mantém browser com timeout curto e cleanup em `finally`. Não existe cron de browser.\n\n### Browserless\nA franquia Free é baseada em units. Antes da ativação:\n- overage cap = $0;\n- manter sessões curtas;\n- não habilitar proxy/CAPTCHA sem necessidade;\n- comparar `estimated_units` com uso real.\n\n## 6. Estado atual\n\nEnquanto `list_env_vars` não mostrar `KERNEL_API_KEY` ou `BROWSERLESS_TOKEN`, ambos continuam:\n\n`AVAILABLE/ADAPTER_LOADED != AUTHENTICATED != OPERATIONAL`\n\nNenhum provider deve ser promovido por documentação, pricing, existência do SDK ou sucesso de importação isoladamente.\n",[],[234,425],["D",1788715215771],[249,250,251,252,253,254],[234],["D",1788707065045],["D",1789488693443],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":53,"_105":106,"_107":24},{"_13":87,"_31":88,"_41":40,"_89":42,"_90":91,"_92":93,"_94":48,"_95":42,"_96":63,"_97":43,"_98":99},"ctx",{"_80":-5,"_129":472,"_473":474,"_475":476,"_477":24,"_478":24,"_479":24,"_480":57,"_481":-5,"_482":-7,"_483":-7,"_484":61,"_485":24,"_486":24,"_487":-5,"_488":24,"_489":24,"_490":24,"_491":-5},"ENV",{"_443":444,"_445":446,"_447":135,"_448":449,"_450":451,"_452":453,"_454":455,"_456":457,"_458":459,"_460":461,"_462":463,"_464":465,"_466":467,"_468":469,"_470":471},"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 · v5