[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_405":406,"_407":408},"routes/_app.x.$handle.$name",{"_101":100,"_31":44,"_110":89,"_26":111,"_13":14,"_112":-5,"_11":113,"_114":115,"_116":117,"_118":119,"_120":121,"_20":-5,"_122":-5,"_123":124,"_125":24,"_126":127,"_128":58,"_129":-5,"_130":-5,"_131":132},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_31":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":24},"version",2,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","lib/economic_policy.ts","latestPath","fileId","4fb3747e-aa17-11f1-8e41-1607ee4eb77e","name","economic_policy.ts","fileType","script","content","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","createdAt",["D",1788715252312],"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",1789575110896],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_101":100,"_109":105},"org",{"_101":100,"_102":103,"_104":105,"_18":54,"_106":107,"_108":24},"branch",{"_13":88,"_31":89,"_42":41,"_90":43,"_91":92,"_93":94,"_95":49,"_96":43,"_97":64,"_98":44,"_99":100},"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",{"_42":43,"_31":44,"_37":400,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":401,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":402,"_83":403,"_85":404,"_87":24},"tree",[230,237,245,249,250,251,252,253,254,255,256],"files",[230,231,232,233,234,235,236,237,238,239,240,241,242,243,244,245,246,247,248,249,250,251,252,253,254,255,256],"counts",{"_219":62,"_220":221,"_222":62,"_223":224,"_225":226},"contents",[139,140,141,142,143,144,145,146,147,148,149],"upstreamProject","upstreamBranch",{"_42":92,"_37":133,"_134":135,"_31":136,"_90":43,"_13":94,"_91":-5,"_93":-5,"_137":138,"_46":-5,"_87":24,"_48":49,"_99":100,"_63":64,"_98":44},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1788707065045],"updatedAt",["D",1788709584572],"main","lockfileKey","1788709584801-esm.town_v_cleitoncosta_chat-native-maestro@68-main",{"_42":214,"_31":215,"_29":216,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":217,"_13":62,"_33":207,"_35":-5,"_23":24,"_158":-5,"_26":218},{"_42":209,"_31":210,"_29":211,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":212,"_13":62,"_33":207,"_35":-5,"_23":24,"_158":-5,"_26":213},{"_42":203,"_31":204,"_29":205,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":206,"_13":62,"_33":207,"_35":-5,"_23":24,"_158":-5,"_26":208},{"_42":197,"_31":198,"_29":199,"_153":-5,"_40":41,"_39":154,"_155":24,"_37":200,"_13":62,"_33":20,"_35":201,"_23":24,"_158":-5,"_26":202},{"_42":190,"_31":191,"_29":192,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":193,"_13":62,"_33":194,"_35":195,"_23":24,"_158":-5,"_26":196},{"_42":184,"_31":185,"_29":186,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":187,"_13":62,"_33":34,"_35":188,"_23":24,"_158":-5,"_26":189},{"_42":178,"_31":179,"_29":180,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":181,"_13":62,"_33":34,"_35":182,"_23":24,"_158":-5,"_26":183},{"_42":172,"_31":173,"_29":174,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":175,"_13":62,"_33":34,"_35":176,"_23":24,"_158":-5,"_26":177},{"_42":166,"_31":167,"_29":168,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":169,"_13":62,"_33":34,"_35":170,"_23":24,"_158":-5,"_26":171},{"_42":160,"_31":161,"_29":162,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":163,"_13":62,"_33":34,"_35":164,"_23":24,"_158":-5,"_26":165},{"_42":150,"_31":151,"_29":152,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":156,"_13":62,"_33":34,"_35":157,"_23":24,"_158":-5,"_26":159},"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",[151],"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",[161],"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",[167],"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",[173],"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",[179],"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",[185],"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",[191],"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",[198],"9e625300-a023-4458-8c07-bea2447f6601","providers","01a077bc-2b99-740d-9881-4952f29c18f3",["D",1788715215771],"directory",[204],"94b02e1c-a9b9-457c-8c32-1b19e33e4ad5","lib","01a077bc-2b99-740d-9881-3bf068d89182",["D",1788715215771],[210],"3e709f84-5c5f-42d7-bfae-c6fc769c7f45","docs","01a077bc-2b99-740d-9881-1e90a3c35ec2",["D",1788715215771],[215],"pulls","branches",3,"forks","envVars",{"_227":62,"_229":62},"connections",{"_227":62,"_228":62},"count","unfilledCount","emptyCount",{"_42":214,"_31":215,"_29":216,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":397,"_13":62,"_33":207,"_35":-5,"_23":24,"_158":-5,"_258":398,"_26":399},{"_42":390,"_31":391,"_29":392,"_153":216,"_40":41,"_39":154,"_155":58,"_37":393,"_13":62,"_33":20,"_35":394,"_23":24,"_158":-5,"_258":395,"_26":396},{"_42":383,"_31":384,"_29":385,"_153":216,"_40":41,"_39":154,"_155":58,"_37":386,"_13":62,"_33":20,"_35":387,"_23":24,"_158":-5,"_258":388,"_26":389},{"_42":376,"_31":377,"_29":378,"_153":216,"_40":41,"_39":154,"_155":58,"_37":379,"_13":62,"_33":20,"_35":380,"_23":24,"_158":-5,"_258":381,"_26":382},{"_42":369,"_31":370,"_29":371,"_153":216,"_40":41,"_39":154,"_155":58,"_37":372,"_13":62,"_33":20,"_35":373,"_23":24,"_158":-5,"_258":374,"_26":375},{"_42":362,"_31":363,"_29":364,"_153":216,"_40":41,"_39":154,"_155":58,"_37":365,"_13":62,"_33":20,"_35":366,"_23":24,"_158":-5,"_258":367,"_26":368},{"_42":355,"_31":356,"_29":357,"_153":216,"_40":41,"_39":154,"_155":58,"_37":358,"_13":62,"_33":20,"_35":359,"_23":24,"_158":-5,"_258":360,"_26":361},{"_42":209,"_31":210,"_29":211,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":352,"_13":62,"_33":207,"_35":-5,"_23":24,"_158":-5,"_258":353,"_26":354},{"_42":345,"_31":346,"_29":347,"_153":211,"_40":41,"_39":154,"_155":58,"_37":348,"_13":62,"_33":34,"_35":349,"_23":24,"_158":-5,"_258":350,"_26":351},{"_42":338,"_31":339,"_29":340,"_153":211,"_40":41,"_39":154,"_155":58,"_37":341,"_13":62,"_33":34,"_35":342,"_23":24,"_158":-5,"_258":343,"_26":344},{"_42":334,"_31":32,"_29":30,"_153":211,"_40":41,"_39":14,"_155":58,"_37":335,"_13":62,"_33":34,"_35":36,"_23":24,"_158":-5,"_258":336,"_26":337},{"_42":327,"_31":328,"_29":329,"_153":211,"_40":41,"_39":154,"_155":58,"_37":330,"_13":62,"_33":34,"_35":331,"_23":24,"_158":-5,"_258":332,"_26":333},{"_42":320,"_31":321,"_29":322,"_153":211,"_40":41,"_39":154,"_155":58,"_37":323,"_13":62,"_33":34,"_35":324,"_23":24,"_158":-5,"_258":325,"_26":326},{"_42":313,"_31":314,"_29":315,"_153":211,"_40":41,"_39":154,"_155":58,"_37":316,"_13":62,"_33":34,"_35":317,"_23":24,"_158":-5,"_258":318,"_26":319},{"_42":306,"_31":307,"_29":308,"_153":211,"_40":41,"_39":154,"_155":58,"_37":309,"_13":62,"_33":34,"_35":310,"_23":24,"_158":-5,"_258":311,"_26":312},{"_42":203,"_31":204,"_29":205,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":303,"_13":62,"_33":207,"_35":-5,"_23":24,"_158":-5,"_258":304,"_26":305},{"_42":296,"_31":297,"_29":298,"_153":205,"_40":41,"_39":154,"_155":58,"_37":299,"_13":62,"_33":34,"_35":300,"_23":24,"_158":-5,"_258":301,"_26":302},{"_42":289,"_31":290,"_29":291,"_153":205,"_40":41,"_39":154,"_155":58,"_37":292,"_13":62,"_33":34,"_35":293,"_23":24,"_158":-5,"_258":294,"_26":295},{"_42":282,"_31":283,"_29":284,"_153":205,"_40":41,"_39":154,"_155":58,"_37":285,"_13":62,"_33":34,"_35":286,"_23":24,"_158":-5,"_258":287,"_26":288},{"_42":197,"_31":198,"_29":199,"_153":-5,"_40":41,"_39":154,"_155":24,"_37":279,"_13":62,"_33":20,"_35":201,"_23":24,"_158":-5,"_258":280,"_26":281},{"_42":190,"_31":191,"_29":192,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":276,"_13":62,"_33":194,"_35":195,"_23":24,"_158":-5,"_258":277,"_26":278},{"_42":184,"_31":185,"_29":186,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":273,"_13":62,"_33":34,"_35":188,"_23":24,"_158":-5,"_258":274,"_26":275},{"_42":178,"_31":179,"_29":180,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":270,"_13":62,"_33":34,"_35":182,"_23":24,"_158":-5,"_258":271,"_26":272},{"_42":172,"_31":173,"_29":174,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":267,"_13":62,"_33":34,"_35":176,"_23":24,"_158":-5,"_258":268,"_26":269},{"_42":166,"_31":167,"_29":168,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":264,"_13":62,"_33":34,"_35":170,"_23":24,"_158":-5,"_258":265,"_26":266},{"_42":160,"_31":161,"_29":162,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":261,"_13":62,"_33":34,"_35":164,"_23":24,"_158":-5,"_258":262,"_26":263},{"_42":150,"_31":151,"_29":152,"_153":-5,"_40":41,"_39":154,"_155":58,"_37":257,"_13":62,"_33":34,"_35":157,"_23":24,"_158":-5,"_258":259,"_26":260},["D",1788715215771],"children",[],[151],["D",1788715215771],[],[161],["D",1788715215771],[],[167],["D",1788715215771],[],[173],["D",1788715215771],[],[179],["D",1788715215771],[],[185],["D",1788715215771],[],[191],["D",1788715215771],[],[198],"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",[],[204,283],"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",[],[204,290],"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",[],[204,297],["D",1788715215771],[246,247,248],[204],"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",[],[210,307],"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",[],[210,314],"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",[],[210,321],"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",[],[210,328],"bc8cbefe-eadd-4ab1-a695-c92931a29c9c",["D",1788715252312],[],[210,32],"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",[],[210,339],"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",[],[210,346],["D",1788715215771],[238,239,240,241,242,243,244],[210],"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",[],[215,356],"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",[],[215,363],"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",[],[215,370],"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",[],[215,377],"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",[],[215,384],"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",[],[215,391],["D",1788715215771],[231,232,233,234,235,236],[215],["D",1788707065045],["D",1789575110896],{"_101":100,"_109":105},{"_101":100,"_102":103,"_104":105,"_18":54,"_106":107,"_108":24},{"_13":88,"_31":89,"_42":41,"_90":43,"_91":92,"_93":94,"_95":49,"_96":43,"_97":64,"_98":44,"_99":100},"ctx",{"_81":-5,"_130":438,"_439":440,"_441":442,"_443":24,"_444":24,"_445":24,"_446":58,"_447":-5,"_448":-7,"_449":-7,"_450":62,"_451":24,"_452":24,"_453":-5,"_454":24,"_455":24,"_456":24,"_457":-5},"ENV",{"_409":410,"_411":412,"_413":136,"_414":415,"_416":417,"_418":419,"_420":421,"_422":423,"_424":425,"_426":427,"_428":429,"_430":431,"_432":433,"_434":435,"_436":437},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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 · v2