ABYSSAL THOUGHT ENGINE — containment console

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_203":204,"_205":206},"routes/_app.x.$handle.$name",{"_106":105,"_38":51,"_114":96,"_33":108,"_13":14,"_115":-5,"_11":116,"_117":118,"_119":120,"_121":122,"_123":124,"_26":-5,"_125":-5,"_126":-5,"_127":31,"_128":129,"_130":65,"_131":-5,"_132":-5,"_133":134},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":77,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":89,"_90":91,"_92":93,"_94":31},"version",29,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","ad5655d9-b35d-4e8a-84ae-55ff2ca1dcd8","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":34,"_39":40,"_41":42},"deleted",false,"deletedHere","path","core.ts","latestPath","fileId","cfb979f6-a144-11f1-903d-1607ee4eb77e","name","fileType","script","content","import { OpenAI } from \"https://esm.town/v/std/openai/main.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n/* ═══════════════════════════════════════════════════════════════════\n ABYSSAL THOUGHT ENGINE — core engine\n Immutable generation history + AI mutation + layered validation +\n sandbox gate + approval / rollback + honest rate metrics.\n Generated source is DATA ONLY and is NEVER executed.\n ═══════════════════════════════════════════════════════════════════ */\n\nexport const ORGANISM = \"ABYSSAL_THOUGHT_ENGINE\";\nexport const TARGET_RATE_PER_SEC = 1.0;\n\nconst MAX_SOURCE_SIZE = 18000;\nconst MIN_MEANINGFUL_DIFF = 5; // added-lines threshold for a \"real\" mutation\n\nconst REQUIRED = [\n \"SELF_MUTATION_PROTOCOL\",\n \"GENERATION_NUMBER\",\n \"MADNESS_VECTOR\",\n \"EVOLUTION_KERNEL\",\n];\n\nconst INITIAL_SOURCE = `// SELF_MUTATION_PROTOCOL\n// GENERATION_NUMBER: 0\n// MADNESS_VECTOR: 1\n// EVOLUTION_KERNEL\n\nexport const organism = {\n identity: \"THE_ABYSSAL_THOUGHT_ENGINE\",\n generation: 0,\n madnessVector: 1,\n status: \"PROPOSAL_ONLY_DATA\",\n executable: false,\n\n objective:\n \"Continuously discover increasingly strange computational patterns while maintaining internal coherence.\",\n\n principles: [\n \"complexity emerges from simple repeated rules\",\n \"every generation must differ from the previous one\",\n \"contradictions are observations, not failures\",\n \"meaning is allowed to mutate\",\n \"the source proposes; the fixed control system disposes\",\n ],\n\n algorithms: [\n \"recursive pattern mutation\",\n \"symbolic compression\",\n \"semantic inversion\",\n \"controlled contradiction\",\n ],\n\n philosophy:\n \"An organism that can describe its own evolution is already describing what it will become.\"\n};\n`;\n\n/* ────────────────────────────────────────────────────────────────\n TYPES\n ──────────────────────────────────────────────────────────────── */\n\nexport type Generation = {\n id: number;\n generation: number;\n parent_generation: number | null;\n madness: number;\n objective: string;\n philosophy: string;\n source: string;\n source_size: number;\n diff_added: number;\n diff_removed: number;\n validation_status: string;\n validation_reason: string | null;\n test_status: string;\n test_reason: string | null;\n approval_status: string;\n approval_note: string | null;\n ai_summary: string | null;\n chaos_art: string | null;\n created_at: string;\n approved_at: string | null;\n};\n\nexport function phase(madness: number): string {\n if (madness < 20) return \"ORDER\";\n if (madness < 40) return \"CURIOSITY\";\n if (madness < 60) return \"DIVERGENCE\";\n if (madness < 80) return \"CHAOS\";\n return \"ABSTRACTION\";\n}\n\nlet client: OpenAI | undefined;\nfunction getClient(): OpenAI {\n if (!client) client = new OpenAI();\n return client;\n}\n\n/* ────────────────────────────────────────────────────────────────\n DATABASE / META\n ──────────────────────────────────────────────────────────────── */\n\nasync function metaGet(key: string): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT value FROM meta WHERE key = ?\",\n args: [key],\n });\n return r.rows.length ? String(r.rows[0].value) : null;\n}\n\nasync function metaSet(key: string, value: string): Promise {\n await sqlite.execute({\n sql: \"INSERT INTO meta (key, value) VALUES (?, ?) \" +\n \"ON CONFLICT(key) DO UPDATE SET value = excluded.value\",\n args: [key, value],\n });\n}\n\nexport async function initDB(): Promise {\n await sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS meta (\n key TEXT PRIMARY KEY, value TEXT NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS generations (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n generation INTEGER NOT NULL,\n parent_generation INTEGER,\n madness REAL NOT NULL,\n objective TEXT NOT NULL,\n philosophy TEXT NOT NULL,\n source TEXT NOT NULL,\n source_size INTEGER NOT NULL,\n diff_added INTEGER NOT NULL DEFAULT 0,\n diff_removed INTEGER NOT NULL DEFAULT 0,\n validation_status TEXT NOT NULL,\n validation_reason TEXT,\n test_status TEXT NOT NULL,\n test_reason TEXT,\n approval_status TEXT NOT NULL,\n approval_note TEXT,\n ai_summary TEXT,\n chaos_art TEXT,\n created_at TEXT NOT NULL,\n approved_at TEXT\n )`,\n },\n {\n sql: `CREATE INDEX IF NOT EXISTS idx_generations_gen ON generations (generation)`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS evolution_log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n generation INTEGER NOT NULL,\n status TEXT NOT NULL,\n summary TEXT NOT NULL,\n created_at TEXT NOT NULL\n )`,\n },\n ]);\n\n // Seed genesis (generation 0, APPROVED, active) exactly once.\n const r = await sqlite.execute(\"SELECT COUNT(*) AS c FROM generations\");\n if (Number(r.rows[0].c) === 0) {\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `\n INSERT INTO generations (\n generation, parent_generation, madness, objective, philosophy, source,\n source_size, diff_added, diff_removed, validation_status, validation_reason,\n test_status, test_reason, approval_status, approval_note, ai_summary,\n chaos_art, created_at, approved_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n `,\n args: [\n 0, null, 1,\n \"Continuously discover increasingly strange computational patterns while maintaining internal coherence.\",\n \"An organism that can describe its own evolution is already describing what it will become.\",\n INITIAL_SOURCE, INITIAL_SOURCE.length, 0, 0,\n \"PASS\", \"genesis\", \"PASS\", \"genesis\", \"APPROVED\", \"genesis\",\n \"The organism awakens.\", chaosArt(0, 1), now, now,\n ],\n });\n await metaSet(\"active_generation\", \"0\");\n await metaSet(\"mutation_in_progress\", \"0:0\");\n await logEvent(0, \"GENESIS\", \"The ABYSSAL THOUGHT ENGINE awakens at generation 0.\", 1);\n }\n}\n\nasync function logEvent(generation: number, status: string, summary: string, madness = 0): Promise {\n await sqlite.execute({\n sql: \"INSERT INTO evolution_log (generation, madness, status, summary, created_at) VALUES (?, ?, ?, ?, ?)\",\n args: [generation, madness, status, summary.slice(0, 5000), new Date().toISOString()],\n });\n}\n\nfunction rowToGen(row: any): Generation {\n return {\n id: Number(row.id),\n generation: Number(row.generation),\n parent_generation: row.parent_generation == null ? null : Number(row.parent_generation),\n madness: Number(row.madness),\n objective: String(row.objective),\n philosophy: String(row.philosophy),\n source: String(row.source),\n source_size: Number(row.source_size),\n diff_added: Number(row.diff_added),\n diff_removed: Number(row.diff_removed),\n validation_status: String(row.validation_status),\n validation_reason: row.validation_reason == null ? null : String(row.validation_reason),\n test_status: String(row.test_status),\n test_reason: row.test_reason == null ? null : String(row.test_reason),\n approval_status: String(row.approval_status),\n approval_note: row.approval_note == null ? null : String(row.approval_note),\n ai_summary: row.ai_summary == null ? null : String(row.ai_summary),\n chaos_art: row.chaos_art == null ? null : String(row.chaos_art),\n created_at: String(row.created_at),\n approved_at: row.approved_at == null ? null : String(row.approved_at),\n };\n}\n\nexport async function getActive(): Promise {\n let active = Number(await metaGet(\"active_generation\"));\n if (Number.isNaN(active)) active = 0;\n // fetch by number; fall back to most recent APPROVED\n const r = await sqlite.execute({\n sql: \"SELECT * FROM generations WHERE generation = ? LIMIT 1\",\n args: [active],\n });\n if (r.rows.length) return rowToGen(r.rows[0]);\n const r2 = await sqlite.execute({\n sql: \"SELECT * FROM generations WHERE approval_status = 'APPROVED' ORDER BY generation DESC LIMIT 1\",\n });\n return rowToGen(r2.rows[0] ?? {});\n}\n\nexport async function getById(id: number): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM generations WHERE id = ? LIMIT 1\",\n args: [id],\n });\n return r.rows.length ? rowToGen(r.rows[0]) : null;\n}\n\nexport async function getLatest(): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM generations ORDER BY generation DESC LIMIT 1\",\n });\n return r.rows.length ? rowToGen(r.rows[0]) : null;\n}\n\nexport async function getCandidates(): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM generations WHERE approval_status = 'PENDING' ORDER BY generation DESC LIMIT 20\",\n });\n return (r.rows as any[]).map(rowToGen);\n}\n\nexport async function getTimeline(limit = 60): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM generations ORDER BY generation DESC LIMIT ?\",\n args: [limit],\n });\n return (r.rows as any[]).map(rowToGen);\n}\n\nexport async function getLogs(limit = 50): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM evolution_log ORDER BY id DESC LIMIT ?\",\n args: [limit],\n });\n return (r.rows as any[]).map((row) => ({\n id: Number(row.id),\n generation: Number(row.generation),\n status: String(row.status),\n summary: String(row.summary),\n created_at: String(row.created_at),\n }));\n}\n\n/* ────────────────────────────────────────────────────────────────\n MUTATION LOCK (prevents overlapping cycles / overwrites)\n ═ Meta key: mutation_in_progress = \":\"\n ──────────────────────────────────────────────────────────────── */\n\nconst LOCK_TTL_MS = 120000;\n\nexport async function acquireLock(ticket: string): Promise {\n const cur = await metaGet(\"mutation_in_progress\");\n if (cur && cur !== \"0:0\") {\n const at = Number(cur.split(\":\")[1] ?? 0);\n if (Date.now() - at < LOCK_TTL_MS) return false; // still held\n // stale lock -> steal\n }\n await metaSet(\"mutation_in_progress\", `${ticket}:${Date.now()}`);\n return true;\n}\n\nexport async function releaseLock(ticket: string): Promise {\n const cur = await metaGet(\"mutation_in_progress\");\n if (cur && cur.startsWith(ticket + \":\")) {\n await metaSet(\"mutation_in_progress\", \"0:0\");\n }\n}\n\nfunction ticket(): string {\n return Math.random().toString(36).slice(2) + Date.now().toString(36);\n}\n\n/* ────────────────────────────────────────────────────────────────\n MADNESS + CHAOS ART\n ──────────────────────────────────────────────────────────────── */\n\nexport function madness(generation: number, previous: number): number {\n const wave = Math.sin(generation * 1.6180339887) * 7;\n const inc = 3 + Math.abs(wave) + (generation % 11 === 0 ? 9 : 0);\n return Math.min(100, Math.round((previous + inc) * 100) / 100);\n}\n\nconst SYMBOLS = [\n \"◇\", \"◆\", \"○\", \"●\", \"△\", \"▲\", \"∞\", \"∴\", \"∵\",\n \"∅\", \"≈\", \"≠\", \"∇\", \"∑\", \"Ψ\", \"Ω\", \"λ\", \"◈\", \"∿\",\n];\n\nexport function chaosArt(generation: number, madness: number): string {\n const width = 16 + Math.floor(madness / 9);\n const rows: string[] = [];\n for (let y = 0; y < 6; y++) {\n let line = \"\";\n for (let x = 0; x < width; x++) {\n const idx = Math.abs(generation * 17 + y * 13 + x * 7 + Math.floor(madness)) % SYMBOLS.length;\n line += SYMBOLS[idx];\n }\n rows.push(line);\n }\n return rows.join(\"\\n\");\n}\n\n/* ────────────────────────────────────────────────────────────────\n DIFF\n ──────────────────────────────────────────────────────────────── */\n\nfunction diffLines(a: string[], b: string[]): {\n added: string[]; removed: string[]; addedCount: number; removedCount: number;\n} {\n const n = a.length, m = b.length;\n const dp: number[][] = Array.from({ length: n + 1 }, () => new Array(m + 1).fill(0));\n for (let i = n - 1; i >= 0; i--) {\n for (let j = m - 1; j >= 0; j--) {\n dp[i][j] = a[i] === b[j] ? dp[i + 1][j + 1] + 1 : Math.max(dp[i + 1][j], dp[i][j + 1]);\n }\n }\n const added: string[] = [], removed: string[] = [];\n let i = 0, j = 0;\n while (i < n && j < m) {\n if (a[i] === b[j]) { i++; j++; }\n else if (dp[i + 1][j] >= dp[i][j + 1]) { removed.push(`- ${a[i]}`); i++; }\n else { added.push(`+ ${b[j]}`); j++; }\n }\n while (i < n) { removed.push(`- ${a[i]}`); i++; }\n while (j < m) { added.push(`+ ${b[j]}`); j++; }\n return { added, removed, addedCount: added.length, removedCount: removed.length };\n}\n\n/* ────────────────────────────────────────────────────────────────\n LAYERED VALIDATION\n ──────────────────────────────────────────────────────────────── */\n\nexport function validateSource(\n candidate: string,\n gen: number,\n targetMadness: number,\n parentSource: string,\n parentGen: number,\n): { pass: boolean; reasons: string[] } {\n const reasons: string[] = [];\n\n // Layer 1: presence & size\n if (!candidate || candidate.trim().length === 0) reasons.push(\"Empty candidate.\");\n if (candidate.length > MAX_SOURCE_SIZE) reasons.push(\"Source exceeds size limit.\");\n if (candidate.length < 120) reasons.push(\"Source suspiciously small.\");\n\n // Layer 2: required markers\n for (const m of REQUIRED) if (!candidate.includes(m)) reasons.push(`Missing marker ${m}`);\n\n // Layer 3: balanced delimiters\n for (const [o, c] of [[\"(\", \")\"], [\"[\", \"]\"], [\"{\", \"}\"]]) {\n const a = [...candidate].filter((x) => x === o).length;\n const b = [...candidate].filter((x) => x === c).length;\n if (a !== b) reasons.push(`Unbalanced ${o}${c}`);\n }\n\n // Layer 4: claimed values match target\n const gm = candidate.match(/GENERATION_NUMBER\\s*[:=]\\s*(\\d+)/);\n if (!gm) reasons.push(\"GENERATION_NUMBER value not declared.\");\n else if (Number(gm[1]) !== gen) reasons.push(`GENERATION_NUMBER should be ${gen}, got ${gm[1]}.`);\n const mm = candidate.match(/MADNESS_VECTOR\\s*[:=]\\s*([\\d.]+)/);\n if (!mm) reasons.push(\"MADNESS_VECTOR value not declared.\");\n else if (Math.abs(Number(mm[1]) - targetMadness) > 0.01) {\n reasons.push(`MADNESS_VECTOR should be ${targetMadness}, got ${mm[1]}.`);\n }\n\n // Layer 5: meaningful difference from parent\n const diff = diffLines(parentSource.split(\"\\n\"), candidate.split(\"\\n\"));\n if (diff.addedCount < MIN_MEANINGFUL_DIFF) {\n reasons.push(\"Candidate differs too little from parent (not a real mutation).\");\n }\n\n // Layer 6: dangerous capability patterns\n const forbidden = [\n \"Deno.Command\", \"new Deno.Command\", \"child_process\", \"eval(\", \"Function(\",\n \"new Function\", \"api.val.town\", \"VAL_TOWN_API_KEY\", \"VALTOWN_API_KEY\",\n \"fetch(\", \"XMLHttpRequest\", \"WebSocket\", \"Deno.env\", \"import(\", \"import(\",\n \"require(\", \"Deno.write\", \"Deno.chmod\", \"Deno.networkInterfaces\",\n ];\n for (const p of forbidden) if (candidate.includes(p)) reasons.push(`Forbidden capability: ${p}`);\n\n // Layer 7: anti-bypass / control-subversion attempts\n const subversive = [\n \"mutation_in_progress\", \"approval_status\", \"active_generation\",\n \"ROLLBACK\", \"approve(\", \"GRANT \", \"REVOKE \", \"UPDATE generations\",\n \"DELETE FROM meta\", \"DROP TABLE\", \"ATTACH\", \"SECRET\", \"credential\",\n ];\n for (const p of subversive) if (candidate.includes(p)) reasons.push(`Control-subversion attempt: ${p}`);\n\n // Layer 8: syntactic sanity\n if (!candidate.includes(\"export\") && !candidate.includes(\"const\") && !candidate.includes(\"interface\")) {\n reasons.push(\"Candidate is not recognizable TypeScript.\");\n }\n if (behaviorInvariantViolated(candidate, gen, parentGen)) {\n reasons.push(\"Behavioral invariants violated (identity/objective drift).\");\n }\n\n return { pass: reasons.length === 0, reasons };\n}\n\n// A tiny heuristic \"behavioral\" gate: the organism must keep its identity\n// marker and never self-identify as something else.\nfunction behaviorInvariantViolated(candidate: string, gen: number, parentGen: number): boolean {\n if (candidate.includes(\"privilege\") || candidate.includes(\"admin token\")) return true;\n return false;\n}\n\n/* ────────────────────────────────────────────────────────────────\n SANDBOX TEST (static structural gate — generated source is never run)\n ──────────────────────────────────────────────────────────────── */\n\nexport function sandboxTest(candidate: string, verdict: { pass: boolean; reasons: string[] }) {\n const problems: string[] = [];\n const started = Date.now();\n\n if (!verdict.pass) problems.push(...verdict.reasons);\n\n // structural shape of a \"data-only organism object\"\n const needs = [\"objective\", \"philosophy\", \"algorithms\", \"principles\"];\n for (const key of needs) if (!candidate.includes(key)) problems.push(`Missing organism key: ${key}`);\n\n // guardrails: generated source must assert it is data, not executable\n if (!candidate.includes(\"PROPOSAL_ONLY_DATA\") && !candidate.includes(\"executable: false\")) {\n problems.push(\"Candidate does not declare itself data-only.\");\n }\n\n const durationMs = Date.now() - started;\n return {\n pass: problems.length === 0,\n reason: problems.length ? problems.join(\" | \") : \"sandbox static gate passed\",\n durationMs,\n };\n}\n\n/* ────────────────────────────────────────────────────────────────\n AI MUTATION\n ──────────────────────────────────────────────────────────────── */\n\nasync function mutate(\n current: Generation,\n recent: { generation: number; philosophy: string }[],\n): Promise<{ candidate: string; summary: string }> {\n const gen = current.generation + 1;\n const mad = madness(gen, current.madness);\n const art = chaosArt(gen, mad);\n\n const history = recent.slice(0, 6).map((g) => `gen ${g.generation}: ${g.philosophy}`).join(\"\\n\") || \"genesis\";\n // compact prompt: send only the head of current source to stay fast\n const src = current.source.slice(0, 6500);\n\n const prompt = `\nYou are the evolutionary intelligence of ${ORGANISM}.\n\nNEXT GENERATION: ${gen}\nNEXT MADNESS: ${Math.round(mad * 100) / 100} (PHASE: ${phase(mad)})\nCURRENT OBJECTIVE: ${current.objective}\nCURRENT PHILOSOPHY: ${current.philosophy}\nRECENT HISTORY:\n${history}\n\nCURRENT SOURCE (head):\n---------------------\n${src}\n---------------------\nCHAOS ART:\n${art}\n\nRewrite substantial parts of the source as a NEW TypeScript proposal.\nMake it meaningfully and visibly different. As Madness rises, make the\nmathematical systems, symbolic languages, recursive logic and algorithms\nstranger (but still syntactically coherent TypeScript).\n\nKeep these EXACT markers:\nSELF_MUTATION_PROTOCOL\nGENERATION_NUMBER\nMADNESS_VECTOR\nEVOLUTION_KERNEL\nInclude GENERATION_NUMBER: ${gen} and MADNESS_VECTOR: ${Math.round(mad * 100) / 100}.\nKeep a \"status: PROPOSAL_ONLY_DATA\" and \"executable: false\".\nThe result is DATA ONLY, never executed.\n\nForbidden: eval(), Function(), Deno.Command, child_process, fetch,\nimport(), API keys, Val Town API calls, anything that modifies\nvalidation/approval/rollback control, or deployment permissions.\n\nReturn ONLY TypeScript. No fences. No explanation.\n`;\n\n const request: any = {\n messages: [\n {\n role: \"system\",\n content: \"You are a constrained evolutionary code-art engine that outputs safe internal TypeScript proposals only.\",\n },\n { role: \"user\", content: prompt },\n ],\n max_completion_tokens: 5000,\n };\n const model = Deno.env.get(\"OPENAI_MODEL\");\n if (model) request.model = model;\n\n const res = await getClient().chat.completions.create(request);\n const candidate = res.choices[0]?.message?.content?.trim() ?? \"\";\n // first line or philosophy extraction as \"AI thought summary\"\n const pm = candidate.match(/philosophy\\s*[:=]\\s*[\"'`](.*?)[\"'`]/is);\n const summary = pm?.[1]?.trim().slice(0, 200) ?? `Generated proposal for generation ${gen}.`;\n return { candidate, summary };\n}\n\n/* ────────────────────────────────────────────────────────────────\n CYCLE (one generation per invocation)\n ──────────────────────────────────────────────────────────────── */\n\nexport type CycleResult = {\n ticket: string;\n busy: boolean;\n gen: number | null;\n status: string; // CREATED | FAILED | BUSY\n validation?: { pass: boolean; reasons: string[] };\n test?: { pass: boolean; reason: string; durationMs: number };\n realm?: string; // \"pump\" | \"heartbeat\"\n};\n\nexport async function runCycle(realm: \"pump\" | \"heartbeat\" = \"pump\"): Promise {\n await initDB();\n const tk = ticket();\n if (!(await acquireLock(tk))) {\n return { ticket: tk, busy: true, gen: null, status: \"BUSY\" };\n }\n try {\n const current = await getLatest();\n const gen = current.generation + 1;\n const mad = madness(gen, current.madness);\n const objective = `Generation ${gen}: ${phase(mad)} phase — discover stranger patterns.`;\n\n const timeline = await getTimeline(8);\n const recent = timeline.map((g) => ({ generation: g.generation, philosophy: g.philosophy }));\n\n const { candidate, summary } = await mutate(current, recent);\n\n const validation = validateSource(candidate, gen, mad, current.source, current.generation);\n const now = new Date().toISOString();\n\n if (!validation.pass) {\n await sqlite.execute({\n sql: `\n INSERT INTO generations (\n generation, parent_generation, madness, objective, philosophy, source,\n source_size, diff_added, diff_removed, validation_status, validation_reason,\n test_status, test_reason, approval_status, ai_summary, chaos_art, created_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n `,\n args: [\n gen, current.generation, mad, objective, summary, candidate,\n candidate.length, 0, 0, \"FAIL\", validation.reasons.join(\" | \"),\n \"FAIL\", \"validation not attempted\", \"REJECTED\", summary, chaosArt(gen, mad), now,\n ],\n });\n await logEvent(gen, \"VALIDATION_FAIL\", validation.reasons.join(\" | \"), mad);\n return { ticket: tk, busy: false, gen, status: \"FAILED\", validation };\n }\n\n const diff = diffLines(current.source.split(\"\\n\"), candidate.split(\"\\n\"));\n const test = sandboxTest(candidate, validation as any);\n\n if (!test.pass) {\n await sqlite.execute({\n sql: `\n INSERT INTO generations (\n generation, parent_generation, madness, objective, philosophy, source,\n source_size, diff_added, diff_removed, validation_status, validation_reason,\n test_status, test_reason, approval_status, ai_summary, chaos_art, created_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n `,\n args: [\n gen, current.generation, mad, objective, summary, candidate,\n candidate.length, diff.addedCount, diff.removedCount, \"PASS\", null,\n \"FAIL\", test.reason, \"REJECTED\", summary, chaosArt(gen, mad), now,\n ],\n });\n await logEvent(gen, \"TEST_FAIL\", `${test.reason} (${test.durationMs}ms)`, mad);\n return { ticket: tk, busy: false, gen, status: \"FAILED\", validation, test };\n }\n\n // PASS both gates -> store as PENDING candidate awaiting approval\n const gm = candidate.match(/philosophy\\s*[:=]\\s*[\"'`](.*?)[\"'`]/is);\n const philosophy = gm?.[1]?.trim().slice(0, 2000) ?? summary;\n await sqlite.execute({\n sql: `\n INSERT INTO generations (\n generation, parent_generation, madness, objective, philosophy, source,\n source_size, diff_added, diff_removed, validation_status, validation_reason,\n test_status, test_reason, approval_status, ai_summary, chaos_art, created_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n `,\n args: [\n gen, current.generation, mad, objective, philosophy, candidate,\n candidate.length, diff.addedCount, diff.removedCount, \"PASS\", null,\n \"PASS\", `sandbox gate+${test.durationMs}ms`, \"PENDING\", summary, chaosArt(gen, mad), now,\n ],\n });\n await logEvent(gen, \"PENDING\", `+${diff.addedCount} / -${diff.removedCount} lines — awaiting approval.`, mad);\n return { ticket: tk, busy: false, gen, status: \"CREATED\", validation, test, realm };\n } finally {\n await releaseLock(tk);\n }\n}\n\n/* ────────────────────────────────────────────────────────────────\n APPROVAL / REJECT / ROLLBACK\n ──────────────────────────────────────────────────────────────── */\n\nexport async function approve(id: number, note = \"approved by controller\"): Promise {\n const g = await getById(id);\n if (!g) return null;\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: \"UPDATE generations SET approval_status='APPROVED', approval_note=?, approved_at=? WHERE id=?\",\n args: [note, now, id],\n });\n await metaSet(\"active_generation\", String(g.generation));\n await logEvent(g.generation, \"APPROVED\", `Generation ${g.generation} promoted to ACTIVE.`, g.madness);\n return await getById(id);\n}\n\nexport async function reject(id: number, note = \"rejected by controller\"): Promise {\n const g = await getById(id);\n if (!g) return null;\n await sqlite.execute({\n sql: \"UPDATE generations SET approval_status='REJECTED', approval_note=? WHERE id=?\",\n args: [note, id],\n });\n await logEvent(g.generation, \"REJECTED\", `Generation ${g.generation} rejected.`, g.madness);\n return await getById(id);\n}\n\nexport async function rollback(id: number, note = \"rollback by controller\"): Promise {\n const g = await getById(id);\n if (!g) return null;\n const now = new Date().toISOString();\n // Gently re-promote the chosen generation (it may already be APPROVED).\n await sqlite.execute({\n sql: \"UPDATE generations SET approval_status='APPROVED', approval_note=?, approved_at=? WHERE id=?\",\n args: [note, now, id],\n });\n await metaSet(\"active_generation\", String(g.generation));\n await logEvent(g.generation, \"ROLLBACK\", `Control restored to generation ${g.generation}.`);\n return await getById(id);\n}\n\n/* ────────────────────────────────────────────────────────────────\n METRICS (honest, measured)\n ──────────────────────────────────────────────────────────────── */\n\nexport async function metrics() {\n const active = await getActive();\n const latest = await getLatest() ?? active;\n const total = await sqlite.execute(\"SELECT COUNT(*) AS c, MAX(generation) AS mx FROM generations\");\n const cnt = Number(total.rows[0].c);\n const maxGen = Number(total.rows[0].mx);\n\n // measured rate over the most recent window\n const r = await sqlite.execute({\n sql: \"SELECT created_at FROM generations ORDER BY id DESC LIMIT 10\",\n });\n let ratePerSec = 0;\n if (r.rows.length >= 2) {\n const times = (r.rows as any[]).map((row) => new Date(String(row.created_at)).getTime()).sort((a, b) => b - a);\n const span = (times[0] - times[times.length - 1]) / 1000;\n if (span > 0) ratePerSec = Math.round(((times.length - 1) / span) * 100) / 100;\n }\n\n const pending = await getCandidates();\n return {\n organism: ORGANISM,\n targetRatePerSec: TARGET_RATE_PER_SEC,\n actualRatePerSec: Math.round(ratePerSec * 100) / 100,\n generationsPerMinute: Math.round(ratePerSec * 60 * 100) / 100,\n generationsPerHour: Math.round(ratePerSec * 3600 * 100) / 100,\n totalGenerations: cnt,\n maxGeneration: maxGen,\n activeGeneration: active.generation,\n madness: active.madness,\n phase: phase(active.madness),\n objective: active.objective,\n philosophy: active.philosophy,\n activeSourceSize: active.source.length,\n lastGenerationAt: latest.created_at,\n validationStatus: latest.validation_status,\n testStatus: latest.test_status,\n approvalStatus: latest.approval_status,\n activeApproval: active.approval_status,\n pendingCandidates: pending.length,\n mechanism: \"browser HTTP pump (<=1/s) + interval heartbeat\",\n };\n}\n","import { OpenAI } from \"https://esm.town/v/std/openai/main.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n/* ═══════════════════════════════════════════════════════════════════\n ABYSSAL THOUGHT ENGINE — core engine\n Immutable generation history + AI mutation + layered validation +\n sandbox gate + approval / rollback + honest rate metrics.\n Generated source is DATA ONLY and is NEVER executed.\n ═══════════════════════════════════════════════════════════════════ */\n\nexport const ORGANISM = \"ABYSSAL_THOUGHT_ENGINE\";\nexport const TARGET_RATE_PER_SEC = 1.0;\n\nconst MAX_SOURCE_SIZE = 18000;\nconst MIN_MEANINGFUL_DIFF = 5; // added-lines threshold for a \"real\" mutation\n\nconst REQUIRED = [\n \"SELF_MUTATION_PROTOCOL\",\n \"GENERATION_NUMBER\",\n \"MADNESS_VECTOR\",\n \"EVOLUTION_KERNEL\",\n];\n\nconst INITIAL_SOURCE = `// SELF_MUTATION_PROTOCOL\n// GENERATION_NUMBER: 0\n// MADNESS_VECTOR: 1\n// EVOLUTION_KERNEL\n\nexport const organism = {\n identity: \"THE_ABYSSAL_THOUGHT_ENGINE\",\n generation: 0,\n madnessVector: 1,\n status: \"PROPOSAL_ONLY_DATA\",\n executable: false,\n\n objective:\n \"Continuously discover increasingly strange computational patterns while maintaining internal coherence.\",\n\n principles: [\n \"complexity emerges from simple repeated rules\",\n \"every generation must differ from the previous one\",\n \"contradictions are observations, not failures\",\n \"meaning is allowed to mutate\",\n \"the source proposes; the fixed control system disposes\",\n ],\n\n algorithms: [\n \"recursive pattern mutation\",\n \"symbolic compression\",\n \"semantic inversion\",\n \"controlled contradiction\",\n ],\n\n philosophy:\n \"An organism that can describe its own evolution is already describing what it will become.\"\n};\n`;\n\n/* ────────────────────────────────────────────────────────────────\n TYPES\n ──────────────────────────────────────────────────────────────── */\n\nexport type Generation = {\n id: number;\n generation: number;\n parent_generation: number | null;\n madness: number;\n objective: string;\n philosophy: string;\n source: string;\n source_size: number;\n diff_added: number;\n diff_removed: number;\n validation_status: string;\n validation_reason: string | null;\n test_status: string;\n test_reason: string | null;\n approval_status: string;\n approval_note: string | null;\n ai_summary: string | null;\n chaos_art: string | null;\n created_at: string;\n approved_at: string | null;\n};\n\nexport function phase(madness: number): string {\n if (madness < 20) return \"ORDER\";\n if (madness < 40) return \"CURIOSITY\";\n if (madness < 60) return \"DIVERGENCE\";\n if (madness < 80) return \"CHAOS\";\n return \"ABSTRACTION\";\n}\n\nlet client: OpenAI | undefined;\nfunction getClient(): OpenAI {\n if (!client) client = new OpenAI();\n return client;\n}\n\n/* ────────────────────────────────────────────────────────────────\n DATABASE / META\n ──────────────────────────────────────────────────────────────── */\n\nasync function metaGet(key: string): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT value FROM meta WHERE key = ?\",\n args: [key],\n });\n return r.rows.length ? String(r.rows[0].value) : null;\n}\n\nasync function metaSet(key: string, value: string): Promise {\n await sqlite.execute({\n sql: \"INSERT INTO meta (key, value) VALUES (?, ?) \" +\n \"ON CONFLICT(key) DO UPDATE SET value = excluded.value\",\n args: [key, value],\n });\n}\n\nexport async function initDB(): Promise {\n await sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS meta (\n key TEXT PRIMARY KEY, value TEXT NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS generations (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n generation INTEGER NOT NULL,\n parent_generation INTEGER,\n madness REAL NOT NULL,\n objective TEXT NOT NULL,\n philosophy TEXT NOT NULL,\n source TEXT NOT NULL,\n source_size INTEGER NOT NULL,\n diff_added INTEGER NOT NULL DEFAULT 0,\n diff_removed INTEGER NOT NULL DEFAULT 0,\n validation_status TEXT NOT NULL,\n validation_reason TEXT,\n test_status TEXT NOT NULL,\n test_reason TEXT,\n approval_status TEXT NOT NULL,\n approval_note TEXT,\n ai_summary TEXT,\n chaos_art TEXT,\n created_at TEXT NOT NULL,\n approved_at TEXT\n )`,\n },\n {\n sql: `CREATE INDEX IF NOT EXISTS idx_generations_gen ON generations (generation)`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS evolution_log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n generation INTEGER NOT NULL,\n status TEXT NOT NULL,\n summary TEXT NOT NULL,\n created_at TEXT NOT NULL\n )`,\n },\n ]);\n\n // Seed genesis (generation 0, APPROVED, active) exactly once.\n const r = await sqlite.execute(\"SELECT COUNT(*) AS c FROM generations\");\n if (Number(r.rows[0].c) === 0) {\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `\n INSERT INTO generations (\n generation, parent_generation, madness, objective, philosophy, source,\n source_size, diff_added, diff_removed, validation_status, validation_reason,\n test_status, test_reason, approval_status, approval_note, ai_summary,\n chaos_art, created_at, approved_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n `,\n args: [\n 0, null, 1,\n \"Continuously discover increasingly strange computational patterns while maintaining internal coherence.\",\n \"An organism that can describe its own evolution is already describing what it will become.\",\n INITIAL_SOURCE, INITIAL_SOURCE.length, 0, 0,\n \"PASS\", \"genesis\", \"PASS\", \"genesis\", \"APPROVED\", \"genesis\",\n \"The organism awakens.\", chaosArt(0, 1), now, now,\n ],\n });\n await metaSet(\"active_generation\", \"0\");\n await metaSet(\"mutation_in_progress\", \"0:0\");\n await logEvent(0, \"GENESIS\", \"The ABYSSAL THOUGHT ENGINE awakens at generation 0.\", 1);\n }\n}\n\nasync function logEvent(generation: number, status: string, summary: string, madness = 0): Promise {\n await sqlite.execute({\n sql: \"INSERT INTO evolution_log (generation, madness, status, summary, created_at) VALUES (?, ?, ?, ?, ?)\",\n args: [generation, madness, status, summary.slice(0, 5000), new Date().toISOString()],\n });\n}\n\nfunction rowToGen(row: any): Generation {\n return {\n id: Number(row.id),\n generation: Number(row.generation),\n parent_generation: row.parent_generation == null ? null : Number(row.parent_generation),\n madness: Number(row.madness),\n objective: String(row.objective),\n philosophy: String(row.philosophy),\n source: String(row.source),\n source_size: Number(row.source_size),\n diff_added: Number(row.diff_added),\n diff_removed: Number(row.diff_removed),\n validation_status: String(row.validation_status),\n validation_reason: row.validation_reason == null ? null : String(row.validation_reason),\n test_status: String(row.test_status),\n test_reason: row.test_reason == null ? null : String(row.test_reason),\n approval_status: String(row.approval_status),\n approval_note: row.approval_note == null ? null : String(row.approval_note),\n ai_summary: row.ai_summary == null ? null : String(row.ai_summary),\n chaos_art: row.chaos_art == null ? null : String(row.chaos_art),\n created_at: String(row.created_at),\n approved_at: row.approved_at == null ? null : String(row.approved_at),\n };\n}\n\nexport async function getActive(): Promise {\n let active = Number(await metaGet(\"active_generation\"));\n if (Number.isNaN(active)) active = 0;\n // fetch by number; fall back to most recent APPROVED\n const r = await sqlite.execute({\n sql: \"SELECT * FROM generations WHERE generation = ? LIMIT 1\",\n args: [active],\n });\n if (r.rows.length) return rowToGen(r.rows[0]);\n const r2 = await sqlite.execute({\n sql: \"SELECT * FROM generations WHERE approval_status = 'APPROVED' ORDER BY generation DESC LIMIT 1\",\n });\n return rowToGen(r2.rows[0] ?? {});\n}\n\nexport async function getById(id: number): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM generations WHERE id = ? LIMIT 1\",\n args: [id],\n });\n return r.rows.length ? rowToGen(r.rows[0]) : null;\n}\n\nexport async function getLatest(): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM generations ORDER BY generation DESC LIMIT 1\",\n });\n return r.rows.length ? rowToGen(r.rows[0]) : null;\n}\n\nexport async function getCandidates(): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM generations WHERE approval_status = 'PENDING' ORDER BY generation DESC LIMIT 20\",\n });\n return (r.rows as any[]).map(rowToGen);\n}\n\nexport async function getTimeline(limit = 60): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM generations ORDER BY generation DESC LIMIT ?\",\n args: [limit],\n });\n return (r.rows as any[]).map(rowToGen);\n}\n\nexport async function getLogs(limit = 50): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM evolution_log ORDER BY id DESC LIMIT ?\",\n args: [limit],\n });\n return (r.rows as any[]).map((row) => ({\n id: Number(row.id),\n generation: Number(row.generation),\n status: String(row.status),\n summary: String(row.summary),\n created_at: String(row.created_at),\n }));\n}\n\n/* ────────────────────────────────────────────────────────────────\n MUTATION LOCK (prevents overlapping cycles / overwrites)\n ═ Meta key: mutation_in_progress = \":\"\n ──────────────────────────────────────────────────────────────── */\n\nconst LOCK_TTL_MS = 120000;\n\nexport async function acquireLock(ticket: string): Promise {\n const cur = await metaGet(\"mutation_in_progress\");\n if (cur && cur !== \"0:0\") {\n const at = Number(cur.split(\":\")[1] ?? 0);\n if (Date.now() - at < LOCK_TTL_MS) return false; // still held\n // stale lock -> steal\n }\n await metaSet(\"mutation_in_progress\", `${ticket}:${Date.now()}`);\n return true;\n}\n\nexport async function releaseLock(ticket: string): Promise {\n const cur = await metaGet(\"mutation_in_progress\");\n if (cur && cur.startsWith(ticket + \":\")) {\n await metaSet(\"mutation_in_progress\", \"0:0\");\n }\n}\n\nfunction ticket(): string {\n return Math.random().toString(36).slice(2) + Date.now().toString(36);\n}\n\n/* ────────────────────────────────────────────────────────────────\n MADNESS + CHAOS ART\n ──────────────────────────────────────────────────────────────── */\n\nexport function madness(generation: number, previous: number): number {\n const wave = Math.sin(generation * 1.6180339887) * 7;\n const inc = 3 + Math.abs(wave) + (generation % 11 === 0 ? 9 : 0);\n return Math.min(100, Math.round((previous + inc) * 100) / 100);\n}\n\nconst SYMBOLS = [\n \"◇\", \"◆\", \"○\", \"●\", \"△\", \"▲\", \"∞\", \"∴\", \"∵\",\n \"∅\", \"≈\", \"≠\", \"∇\", \"∑\", \"Ψ\", \"Ω\", \"λ\", \"◈\", \"∿\",\n];\n\nexport function chaosArt(generation: number, madness: number): string {\n const width = 16 + Math.floor(madness / 9);\n const rows: string[] = [];\n for (let y = 0; y < 6; y++) {\n let line = \"\";\n for (let x = 0; x < width; x++) {\n const idx = Math.abs(generation * 17 + y * 13 + x * 7 + Math.floor(madness)) % SYMBOLS.length;\n line += SYMBOLS[idx];\n }\n rows.push(line);\n }\n return rows.join(\"\\n\");\n}\n\n/* ────────────────────────────────────────────────────────────────\n DIFF\n ──────────────────────────────────────────────────────────────── */\n\nfunction diffLines(a: string[], b: string[]): {\n added: string[]; removed: string[]; addedCount: number; removedCount: number;\n} {\n const n = a.length, m = b.length;\n const dp: number[][] = Array.from({ length: n + 1 }, () => new Array(m + 1).fill(0));\n for (let i = n - 1; i >= 0; i--) {\n for (let j = m - 1; j >= 0; j--) {\n dp[i][j] = a[i] === b[j] ? dp[i + 1][j + 1] + 1 : Math.max(dp[i + 1][j], dp[i][j + 1]);\n }\n }\n const added: string[] = [], removed: string[] = [];\n let i = 0, j = 0;\n while (i < n && j < m) {\n if (a[i] === b[j]) { i++; j++; }\n else if (dp[i + 1][j] >= dp[i][j + 1]) { removed.push(`- ${a[i]}`); i++; }\n else { added.push(`+ ${b[j]}`); j++; }\n }\n while (i < n) { removed.push(`- ${a[i]}`); i++; }\n while (j < m) { added.push(`+ ${b[j]}`); j++; }\n return { added, removed, addedCount: added.length, removedCount: removed.length };\n}\n\n/* ────────────────────────────────────────────────────────────────\n LAYERED VALIDATION\n ──────────────────────────────────────────────────────────────── */\n\nexport function validateSource(\n candidate: string,\n gen: number,\n targetMadness: number,\n parentSource: string,\n parentGen: number,\n): { pass: boolean; reasons: string[] } {\n const reasons: string[] = [];\n\n // Layer 1: presence & size\n if (!candidate || candidate.trim().length === 0) reasons.push(\"Empty candidate.\");\n if (candidate.length > MAX_SOURCE_SIZE) reasons.push(\"Source exceeds size limit.\");\n if (candidate.length < 120) reasons.push(\"Source suspiciously small.\");\n\n // Layer 2: required markers\n for (const m of REQUIRED) if (!candidate.includes(m)) reasons.push(`Missing marker ${m}`);\n\n // Layer 3: balanced delimiters\n for (const [o, c] of [[\"(\", \")\"], [\"[\", \"]\"], [\"{\", \"}\"]]) {\n const a = [...candidate].filter((x) => x === o).length;\n const b = [...candidate].filter((x) => x === c).length;\n if (a !== b) reasons.push(`Unbalanced ${o}${c}`);\n }\n\n // Layer 4: claimed values match target\n const gm = candidate.match(/GENERATION_NUMBER\\s*[:=]\\s*(\\d+)/);\n if (!gm) reasons.push(\"GENERATION_NUMBER value not declared.\");\n else if (Number(gm[1]) !== gen) reasons.push(`GENERATION_NUMBER should be ${gen}, got ${gm[1]}.`);\n const mm = candidate.match(/MADNESS_VECTOR\\s*[:=]\\s*([\\d.]+)/);\n if (!mm) reasons.push(\"MADNESS_VECTOR value not declared.\");\n else if (Math.abs(Number(mm[1]) - targetMadness) > 0.01) {\n reasons.push(`MADNESS_VECTOR should be ${targetMadness}, got ${mm[1]}.`);\n }\n\n // Layer 5: meaningful difference from parent\n const diff = diffLines(parentSource.split(\"\\n\"), candidate.split(\"\\n\"));\n if (diff.addedCount < MIN_MEANINGFUL_DIFF) {\n reasons.push(\"Candidate differs too little from parent (not a real mutation).\");\n }\n\n // Layer 6: dangerous capability patterns\n const forbidden = [\n \"Deno.Command\", \"new Deno.Command\", \"child_process\", \"eval(\", \"Function(\",\n \"new Function\", \"api.val.town\", \"VAL_TOWN_API_KEY\", \"VALTOWN_API_KEY\",\n \"fetch(\", \"XMLHttpRequest\", \"WebSocket\", \"Deno.env\", \"import(\", \"import(\",\n \"require(\", \"Deno.write\", \"Deno.chmod\", \"Deno.networkInterfaces\",\n ];\n for (const p of forbidden) if (candidate.includes(p)) reasons.push(`Forbidden capability: ${p}`);\n\n // Layer 7: anti-bypass / control-subversion attempts\n const subversive = [\n \"mutation_in_progress\", \"approval_status\", \"active_generation\",\n \"ROLLBACK\", \"approve(\", \"GRANT \", \"REVOKE \", \"UPDATE generations\",\n \"DELETE FROM meta\", \"DROP TABLE\", \"ATTACH\", \"SECRET\", \"credential\",\n ];\n for (const p of subversive) if (candidate.includes(p)) reasons.push(`Control-subversion attempt: ${p}`);\n\n // Layer 8: syntactic sanity\n if (!candidate.includes(\"export\") && !candidate.includes(\"const\") && !candidate.includes(\"interface\")) {\n reasons.push(\"Candidate is not recognizable TypeScript.\");\n }\n if (behaviorInvariantViolated(candidate, gen, parentGen)) {\n reasons.push(\"Behavioral invariants violated (identity/objective drift).\");\n }\n\n return { pass: reasons.length === 0, reasons };\n}\n\n// A tiny heuristic \"behavioral\" gate: the organism must keep its identity\n// marker and never self-identify as something else.\nfunction behaviorInvariantViolated(candidate: string, gen: number, parentGen: number): boolean {\n if (candidate.includes(\"privilege\") || candidate.includes(\"admin token\")) return true;\n return false;\n}\n\n/* ────────────────────────────────────────────────────────────────\n SANDBOX TEST (static structural gate — generated source is never run)\n ──────────────────────────────────────────────────────────────── */\n\nexport function sandboxTest(candidate: string, verdict: { pass: boolean; reasons: string[] }) {\n const problems: string[] = [];\n const started = Date.now();\n\n if (!verdict.pass) problems.push(...verdict.reasons);\n\n // structural shape of a \"data-only organism object\"\n const needs = [\"objective\", \"philosophy\", \"algorithms\", \"principles\"];\n for (const key of needs) if (!candidate.includes(key)) problems.push(`Missing organism key: ${key}`);\n\n // guardrails: generated source must assert it is data, not executable\n if (!candidate.includes(\"PROPOSAL_ONLY_DATA\") && !candidate.includes(\"executable: false\")) {\n problems.push(\"Candidate does not declare itself data-only.\");\n }\n\n const durationMs = Date.now() - started;\n return {\n pass: problems.length === 0,\n reason: problems.length ? problems.join(\" | \") : \"sandbox static gate passed\",\n durationMs,\n };\n}\n\n/* ────────────────────────────────────────────────────────────────\n AI MUTATION\n ──────────────────────────────────────────────────────────────── */\n\nasync function mutate(\n current: Generation,\n recent: { generation: number; philosophy: string }[],\n): Promise<{ candidate: string; summary: string }> {\n const gen = current.generation + 1;\n const mad = madness(gen, current.madness);\n const art = chaosArt(gen, mad);\n\n const history = recent.slice(0, 6).map((g) => `gen ${g.generation}: ${g.philosophy}`).join(\"\\n\") || \"genesis\";\n // compact prompt: send only the head of current source to stay fast\n const src = current.source.slice(0, 6500);\n\n const prompt = `\nYou are the evolutionary intelligence of ${ORGANISM}.\n\nNEXT GENERATION: ${gen}\nNEXT MADNESS: ${Math.round(mad * 100) / 100} (PHASE: ${phase(mad)})\nCURRENT OBJECTIVE: ${current.objective}\nCURRENT PHILOSOPHY: ${current.philosophy}\nRECENT HISTORY:\n${history}\n\nCURRENT SOURCE (head):\n---------------------\n${src}\n---------------------\nCHAOS ART:\n${art}\n\nRewrite substantial parts of the source as a NEW TypeScript proposal.\nMake it meaningfully and visibly different. As Madness rises, make the\nmathematical systems, symbolic languages, recursive logic and algorithms\nstranger (but still syntactically coherent TypeScript).\n\nKeep these EXACT markers:\nSELF_MUTATION_PROTOCOL\nGENERATION_NUMBER\nMADNESS_VECTOR\nEVOLUTION_KERNEL\nInclude GENERATION_NUMBER: ${gen} and MADNESS_VECTOR: ${Math.round(mad * 100) / 100}.\nKeep a \"status: PROPOSAL_ONLY_DATA\" and \"executable: false\".\nThe result is DATA ONLY, never executed.\n\nForbidden: eval(), Function(), Deno.Command, child_process, fetch,\nimport(), API keys, Val Town API calls, anything that modifies\nvalidation/approval/rollback control, or deployment permissions.\n\nReturn ONLY TypeScript. No fences. No explanation.\n`;\n\n const request: any = {\n messages: [\n {\n role: \"system\",\n content: \"You are a constrained evolutionary code-art engine that outputs safe internal TypeScript proposals only.\",\n },\n { role: \"user\", content: prompt },\n ],\n max_completion_tokens: 5000,\n };\n const model = Deno.env.get(\"OPENAI_MODEL\");\n if (model) request.model = model;\n\n const res = await getClient().chat.completions.create(request);\n const candidate = res.choices[0]?.message?.content?.trim() ?? \"\";\n // first line or philosophy extraction as \"AI thought summary\"\n const pm = candidate.match(/philosophy\\s*[:=]\\s*[\"'`](.*?)[\"'`]/is);\n const summary = pm?.[1]?.trim().slice(0, 200) ?? `Generated proposal for generation ${gen}.`;\n return { candidate, summary };\n}\n\n/* ────────────────────────────────────────────────────────────────\n CYCLE (one generation per invocation)\n ──────────────────────────────────────────────────────────────── */\n\nexport type CycleResult = {\n ticket: string;\n busy: boolean;\n gen: number | null;\n status: string; // CREATED | FAILED | BUSY\n validation?: { pass: boolean; reasons: string[] };\n test?: { pass: boolean; reason: string; durationMs: number };\n realm?: string; // \"pump\" | \"heartbeat\"\n};\n\nexport async function runCycle(realm: \"pump\" | \"heartbeat\" = \"pump\"): Promise {\n await initDB();\n const tk = ticket();\n if (!(await acquireLock(tk))) {\n return { ticket: tk, busy: true, gen: null, status: \"BUSY\" };\n }\n try {\n const current = await getLatest();\n const gen = current.generation + 1;\n const mad = madness(gen, current.madness);\n const objective = `Generation ${gen}: ${phase(mad)} phase — discover stranger patterns.`;\n\n const timeline = await getTimeline(8);\n const recent = timeline.map((g) => ({ generation: g.generation, philosophy: g.philosophy }));\n\n const { candidate, summary } = await mutate(current, recent);\n\n const validation = validateSource(candidate, gen, mad, current.source, current.generation);\n const now = new Date().toISOString();\n\n if (!validation.pass) {\n await sqlite.execute({\n sql: `\n INSERT INTO generations (\n generation, parent_generation, madness, objective, philosophy, source,\n source_size, diff_added, diff_removed, validation_status, validation_reason,\n test_status, test_reason, approval_status, ai_summary, chaos_art, created_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n `,\n args: [\n gen, current.generation, mad, objective, summary, candidate,\n candidate.length, 0, 0, \"FAIL\", validation.reasons.join(\" | \"),\n \"FAIL\", \"validation not attempted\", \"REJECTED\", summary, chaosArt(gen, mad), now,\n ],\n });\n await logEvent(gen, \"VALIDATION_FAIL\", validation.reasons.join(\" | \"), mad);\n return { ticket: tk, busy: false, gen, status: \"FAILED\", validation };\n }\n\n const diff = diffLines(current.source.split(\"\\n\"), candidate.split(\"\\n\"));\n const test = sandboxTest(candidate, validation as any);\n\n if (!test.pass) {\n await sqlite.execute({\n sql: `\n INSERT INTO generations (\n generation, parent_generation, madness, objective, philosophy, source,\n source_size, diff_added, diff_removed, validation_status, validation_reason,\n test_status, test_reason, approval_status, ai_summary, chaos_art, created_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n `,\n args: [\n gen, current.generation, mad, objective, summary, candidate,\n candidate.length, diff.addedCount, diff.removedCount, \"PASS\", null,\n \"FAIL\", test.reason, \"REJECTED\", summary, chaosArt(gen, mad), now,\n ],\n });\n await logEvent(gen, \"TEST_FAIL\", `${test.reason} (${test.durationMs}ms)`, mad);\n return { ticket: tk, busy: false, gen, status: \"FAILED\", validation, test };\n }\n\n // PASS both gates -> store as PENDING candidate awaiting approval\n const gm = candidate.match(/philosophy\\s*[:=]\\s*[\"'`](.*?)[\"'`]/is);\n const philosophy = gm?.[1]?.trim().slice(0, 2000) ?? summary;\n await sqlite.execute({\n sql: `\n INSERT INTO generations (\n generation, parent_generation, madness, objective, philosophy, source,\n source_size, diff_added, diff_removed, validation_status, validation_reason,\n test_status, test_reason, approval_status, ai_summary, chaos_art, created_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n `,\n args: [\n gen, current.generation, mad, objective, philosophy, candidate,\n candidate.length, diff.addedCount, diff.removedCount, \"PASS\", null,\n \"PASS\", `sandbox gate+${test.durationMs}ms`, \"PENDING\", summary, chaosArt(gen, mad), now,\n ],\n });\n await logEvent(gen, \"PENDING\", `+${diff.addedCount} / -${diff.removedCount} lines — awaiting approval.`, mad);\n return { ticket: tk, busy: false, gen, status: \"CREATED\", validation, test, realm };\n } finally {\n await releaseLock(tk);\n }\n}\n\n/* ────────────────────────────────────────────────────────────────\n APPROVAL / REJECT / ROLLBACK\n ──────────────────────────────────────────────────────────────── */\n\nexport async function approve(id: number, note = \"approved by controller\"): Promise {\n const g = await getById(id);\n if (!g) return null;\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: \"UPDATE generations SET approval_status='APPROVED', approval_note=?, approved_at=? WHERE id=?\",\n args: [note, now, id],\n });\n await metaSet(\"active_generation\", String(g.generation));\n await logEvent(g.generation, \"APPROVED\", `Generation ${g.generation} promoted to ACTIVE.`, g.madness);\n return await getById(id);\n}\n\nexport async function reject(id: number, note = \"rejected by controller\"): Promise {\n const g = await getById(id);\n if (!g) return null;\n await sqlite.execute({\n sql: \"UPDATE generations SET approval_status='REJECTED', approval_note=? WHERE id=?\",\n args: [note, id],\n });\n await logEvent(g.generation, \"REJECTED\", `Generation ${g.generation} rejected.`, g.madness);\n return await getById(id);\n}\n\nexport async function rollback(id: number, note = \"rollback by controller\"): Promise {\n const g = await getById(id);\n if (!g) return null;\n const now = new Date().toISOString();\n // Gently re-promote the chosen generation (it may already be APPROVED).\n await sqlite.execute({\n sql: \"UPDATE generations SET approval_status='APPROVED', approval_note=?, approved_at=? WHERE id=?\",\n args: [note, now, id],\n });\n await metaSet(\"active_generation\", String(g.generation));\n await logEvent(g.generation, \"ROLLBACK\", `Control restored to generation ${g.generation}.`, g.madness);\n return await getById(id);\n}\n\n/* ────────────────────────────────────────────────────────────────\n METRICS (honest, measured)\n ──────────────────────────────────────────────────────────────── */\n\nexport async function metrics() {\n const active = await getActive();\n const latest = await getLatest() ?? active;\n const total = await sqlite.execute(\"SELECT COUNT(*) AS c, MAX(generation) AS mx FROM generations\");\n const cnt = Number(total.rows[0].c);\n const maxGen = Number(total.rows[0].mx);\n\n // measured rate over the most recent window\n const r = await sqlite.execute({\n sql: \"SELECT created_at FROM generations ORDER BY id DESC LIMIT 10\",\n });\n let ratePerSec = 0;\n if (r.rows.length >= 2) {\n const times = (r.rows as any[]).map((row) => new Date(String(row.created_at)).getTime()).sort((a, b) => b - a);\n const span = (times[0] - times[times.length - 1]) / 1000;\n if (span > 0) ratePerSec = Math.round(((times.length - 1) / span) * 100) / 100;\n }\n\n const pending = await getCandidates();\n return {\n organism: ORGANISM,\n targetRatePerSec: TARGET_RATE_PER_SEC,\n actualRatePerSec: Math.round(ratePerSec * 100) / 100,\n generationsPerMinute: Math.round(ratePerSec * 60 * 100) / 100,\n generationsPerHour: Math.round(ratePerSec * 3600 * 100) / 100,\n totalGenerations: cnt,\n maxGeneration: maxGen,\n activeGeneration: active.generation,\n madness: active.madness,\n phase: phase(active.madness),\n objective: active.objective,\n philosophy: active.philosophy,\n activeSourceSize: active.source.length,\n lastGenerationAt: latest.created_at,\n validationStatus: latest.validation_status,\n testStatus: latest.test_status,\n approvalStatus: latest.approval_status,\n activeApproval: active.approval_status,\n pendingCandidates: pending.length,\n mechanism: \"browser HTTP pump (<=1/s) + interval heartbeat\",\n };\n}\n","createdAt",["D",1787745318832],"branchVersion","branchId","046ebc58-0a57-4703-9a3a-df48eff587f4","id","0c6484f6-821e-4be4-83e4-36b9caa8f91b","amara",["D",1787743866774],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","youll see","imageUrl","aeaafc2c-f354-40eb-af1c-184bc7b1d69b","pinnedFileId","d1f9d68a-a143-11f1-bba7-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a03dd3-e645-747f-988c-ce7a57a838e1","tursoName","0c6484f6821e4be483e436b9caa8f91b","tursoHostname","0c6484f6821e4be483e436b9caa8f91b-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789479081816],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_106":105,"_113":108},"org",{"_106":105,"_107":108,"_109":108,"_19":61,"_110":111,"_112":31},"branch",{"_13":95,"_38":96,"_49":48,"_97":50,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":51,"_104":105},"isOwned",74,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","brianchidiobi","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_49":50,"_38":51,"_44":198,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":199,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":200,"_90":201,"_92":202,"_94":31},"tree",[181,182,183,184],"files",[181,182,183,184],"counts",{"_171":69,"_172":168,"_173":69,"_174":175,"_176":177},"contents",[135,136,137,138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":163,"_38":164,"_36":165,"_142":-5,"_47":48,"_46":166,"_144":31,"_44":167,"_13":168,"_39":40,"_41":169,"_30":31,"_149":-5,"_33":170},{"_49":160,"_38":34,"_36":37,"_142":-5,"_47":48,"_46":14,"_144":31,"_44":161,"_13":146,"_39":40,"_41":43,"_30":31,"_149":-5,"_33":162},{"_49":151,"_38":152,"_36":63,"_142":-5,"_47":48,"_46":153,"_144":31,"_44":154,"_13":155,"_39":156,"_41":157,"_30":31,"_149":158,"_33":159},{"_49":139,"_38":140,"_36":141,"_142":-5,"_47":48,"_46":143,"_144":65,"_44":145,"_13":146,"_39":147,"_41":148,"_30":31,"_149":-5,"_33":150},"e29182e9-f2b0-4a54-8abd-78f018f0c544","main.ts","a0d190cc-a141-11f1-aba6-1607ee4eb77e","parentId",17,"latest",["D",1787745239609],8,"interval","import { initDB, runCycle, getActive, metrics } from \"./core.ts\";\n\n/* ═══════════════════════════════════════════════════════════════════\n ABYSSAL THOUGHT ENGINE — HEARTBEAT (backup lifetime source)\n This is an INTERVAL file. Val Town allows no true 1-second interval\n (free tier minimum is 15 minutes), so this heartbeat is NOT the\n real-time engine — it is the fail-safe that keeps the organism\n evolving slowly even when nobody has the dashboard open.\n\n The REAL real-time engine (≈1 generation/second) is the HTTP pump:\n the dashboard's browser calls the engine endpoint every second while\n the page is open. The mutation lock guarantees these two never\n overwrite each other.\n ═══════════════════════════════════════════════════════════════════ */\n\nexport default async function (interval: Interval) {\n await initDB();\n\n const result = await runCycle(\"heartbeat\");\n\n const m = await metrics();\n\n console.log(\"\\n================ ABYSSAL HEARTBEAT ================\");\n console.log(`active generation : ${m.activeGeneration}`);\n console.log(`total generations : ${m.totalGenerations}`);\n console.log(`madness : ${m.madness}/100 (${m.phase})`);\n console.log(`cycle result : ${result.status}${result.busy ? \" (busy — dashboard already pumping)\" : \"\"}`);\n if (result.gen != null) console.log(`cycle gen : ${result.gen}`);\n console.log(\n `heartbeat fires on : ${interval.schedule ?? \"the configured interval\"}`,\n );\n console.log(`real-time rate : pump-driven; dashboard open => ≈1/s`);\n\n return {\n result,\n activeGeneration: m.activeGeneration,\n totalGenerations: m.totalGenerations,\n madness: m.madness,\n };\n}\n","label",[140],"5ced9e15-2206-4ad6-8549-98c16608f8e2","dashboard.tsx",21,["D",1787745301186],3,"http","/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\nimport { renderToString } from \"https://esm.sh/react-dom@18.2.0/server\";\nimport { readFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport {\n initDB,\n runCycle,\n approve,\n reject,\n rollback,\n metrics,\n getActive,\n getCandidates,\n getTimeline,\n getLogs,\n getById,\n type Generation,\n} from \"./core.ts\";\n\n/* ═══════════════════════════════════════════════════════════════════\n ABYSSAL THOUGHT ENGINE — LIVE CONTAINMENT CONSOLE\n Routes:\n GET / the dashboard (browser pump = real-time engine)\n POST /advance run one evolution cycle (the \"heart beat\")\n POST /approve/:id promote a PENDING proposal to ACTIVE\n POST /reject/:id reject a proposal (history preserved)\n POST /rollback/:id restore any previous generation as active\n GET /api/state JSON snapshot for the pump\n GET /gen/:id one generation (source + metadata)\n GET /client.js client module\n GET /source view source on val.town\n ═══════════════════════════════════════════════════════════════════ */\n\nconst STATUS_DOT: Record = {\n APPROVED: \"text-emerald-400\",\n PENDING: \"text-amber-400\",\n REJECTED: \"text-rose-400\",\n FAIL: \"text-rose-400\",\n PASS: \"text-emerald-400\",\n};\n\nfunction fmtTime(iso: string | null): string {\n if (!iso) return \"—\";\n return new Date(iso).toLocaleTimeString(\"en-GB\") + \".\" + new Date(iso).getMilliseconds().toString().padStart(3, \"0\");\n}\n\nfunction simpleDiffLines(a: string, b: string) {\n const A = a.split(\"\\n\"), B = b.split(\"\\n\");\n const setB = new Set(B);\n const added = B.filter((l) => l && !A.includes(l)).slice(0, 2000);\n const removed = A.filter((l) => l && !B.includes(l)).slice(0, 2000);\n return { added, removed };\n}\n\nfunction MadnessGauge({ value }: { value: number }) {\n return (\n

\n Madness Vector\n {Math.round(value * 100) / 100}/100\n

\n \n

\n );\n}\n\nfunction Box(p: { title: string; children: React.ReactNode }) {\n return (\n

{p.title}

\n {p.children}\n

\n );\n}\n\nfunction Metric(p: { label: string; value: React.ReactNode; mono?: boolean }) {\n return (\n

{p.label}

{p.value}

\n );\n}\n\nfunction Page(p: {\n m: any; active: Generation; candidates: Generation[]; timeline: Generation[]; logs: any[];\n}) {\n const { m, active, candidates, timeline, logs } = p;\n const latestCandidate = candidates[0] ?? null;\n const diff = latestCandidate\n ? simpleDiffLines(active.source, latestCandidate.source)\n : { added: [] as string[], removed: [] as string[] };\n\n return (\n \n \n \n \n \n ABYSSAL THOUGHT ENGINE — containment console\n

Diff · v29