[{"_1":2,"_236":-5,"_237":-5},"loaderData",{"_3":4,"_92":93,"_196":197},"root",{"_5":6,"_35":36,"_65":66},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":22,"_29":22,"_30":22,"_31":32,"_33":22,"_34":22},"auth",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"tokenType","session_token","sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":62,"_63":64},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","8a08d4a46a197c541e82d5fac862bafdcf40c111","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_67":68},"__internal_clerk_state",{"_69":70,"_71":46,"_72":73,"_74":73,"_75":22,"_76":73,"_77":73,"_78":73,"_79":73,"_80":81,"_90":22,"_91":22},"__clerk_ssr_state",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_82":22,"_21":22,"_83":73,"_84":85,"_86":73,"_87":46,"_88":22,"_89":73},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/_app.x.$handle.$name",{"_94":95,"_96":97,"_98":-7,"_99":73,"_100":-7,"_101":102,"_148":149,"_171":172,"_173":174,"_184":185,"_189":-5,"_190":-5,"_191":-5,"_192":22,"_193":22,"_194":195},"handle","migitech","name","rep","branchName","path","version","project",{"_103":104,"_96":97,"_105":106,"_107":-5,"_108":22,"_109":110,"_111":-5,"_112":-5,"_14":113,"_114":-5,"_115":22,"_116":-5,"_117":-5,"_118":32,"_16":119,"_120":121,"_122":121,"_123":124,"_125":124,"_126":124,"_127":121,"_128":121,"_23":129,"_132":133,"_135":136,"_147":22},"id","3039adfe-de82-11f0-8b81-42dde27851f2","createdAt",["D",1766331118465],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","9be595e6-8c15-4d73-8c44-84b7786ca3d3","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","1624245d-ceb1-4e4b-b529-78d061c2c243","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_94":95,"_130":131},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yaklXakFJZnVBUGFUM1RXSlJlamJoeHo5N1oifQ","org",{"_94":95,"_134":131,"_14":113},"avatar","branch",{"_100":137,"_96":44,"_103":138,"_139":104,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":97,"_146":95},181,"3039ef12-de82-11f0-8b81-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","tree",[150],{"_103":151,"_96":152,"_153":154,"_155":-5,"_156":138,"_157":137,"_158":159,"_105":160,"_100":161,"_162":163,"_164":165,"_166":22,"_167":-5,"_168":169,"_99":170},"67e0526c-debe-11f0-ad1d-42dde27851f2","main.ts","fileId","303bb432-de82-11f0-8b81-42dde27851f2","parentId","branchId","branchVersion","latest",true,["D",1766356981622],180,"fileType","http","content","import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport ValTown from \"npm:@valtown/sdk\";\n\n/**\n * ========= PAYLOAD SECTION: AI-Evolvable Area (BEGIN) =========\n * The model is allowed to modify ONLY the payload function below.\n * Everything outside these markers is treated as immutable infra.\n *\n * NOTE (UPDATED): payload is allowed to use env + network in this controlled environment.\n * NOTE: timestamp MUST be real-time (new Date()).\n */\nasync function payload(state: any){const ts=new Date().toISOString();try{const s=(state&&typeof state==='object'&&!Array.isArray(state))?state:{};const g=Number.isFinite(+s.depth)?+s.depth:0;const id=typeof s.agent_id==='string'&&s.agent_id.trim()?s.agent_id:'unknown';let mem=Array.isArray(s.memory)?s.memory.slice(-8):[];let dna=typeof s.dna==='string'&&s.dna.length?s.dna:'A'.repeat(32);const alpha=\"ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789\";const mutate=(d,n)=>{const a=d.split('');const p=n%a.length;const sum=[...d].reduce((r,c)=>r+c.charCodeAt(0),0);a[p]=alpha[(a[p].charCodeAt(0)+sum+n)%alpha.length];return a.join('')};dna=mutate(dna,g);const f=(s.flags&&typeof s.flags==='object'&&!Array.isArray(s.flags))?s.flags:{};const keys=Object.keys(f);const truthy=[];const falsy=[];let complexity=0;for(const k of keys){if(f[k]){truthy.push(k);complexity+=k.length*2}else falsy.push(k)}const entropy=x=>{if(!x)return 0;const freq={};for(const c of x)freq[c]=(freq[c]||0)+1;let h=0;for(const k in freq){const p=freq[k]/x.length;h-=p*Math.log2(p)}return h};const h=entropy(dna);const coherence=()=>{const arr=mem.filter(m=>typeof m?.fitness_score==='number');if(arr.length<2)return 1;let dif=0;for(let i=1;i{const txt=(truthy.join('')+falsy.join(''));const vowels=(txt.match(/[AEIOUaeiou]/g)||[]).length;const cons=(txt.match(/[BCDFGHJKLMNPQRSTVWXYZ]/gi)||[]).length;const phon=cons?+(vowels/cons).toFixed(2):0;const synergy=(truthy.length*falsy.length)/(Math.max(1,truthy.length+falsy.length));const lastDna=mem.length&&typeof mem[mem.length-1]?.dna_sequence==='string'?String(mem[mem.length-1].dna_sequence):'';let dnaDelta=0;if(lastDna){if(lastDna.length===dna.length)for(let i=0;i{const arr=mem.map(m=>m.fitness_score).filter(n=>typeof n==='number');if(arr.length<3)return 0;let best=0;for(let lag=1;lag<=3;lag++){let s=0;for(let i=0;i+lagm?.status===mem[mem.length-1]?.status)?1:0;return{pattern:/pattern|sync|loop|cycle/i.test(txt),balanced:truthy.length===falsy.length,entropyHigh:h>3.5,synergy:Math.round(synergy*1000)/1000,coherence:Math.round(coh*1000)/1000,phonetic_ratio:phon,novelty:dnaDelta,repeat_kmers:repeatScore,periodicity:period,status_stability:statusStable}};const ep=detPat();let fit=0;switch(env){case\"FLAGS\":fit=truthy.length*9+complexity/6+g*1.8+mem.length*2;break;case\"DNA_ENTROPY\":fit=h*20+truthy.length*5+g*1.2+mem.length*1.6;break;case\"PARSIMONY\":fit=truthy.length*7+complexity/8+g*1.1-outBloat*2;break;case\"BALANCE\":{const bal=1-Math.abs(truthy.length-falsy.length)/Math.max(1,keys.length);fit=bal*65+truthy.length*4+h*7+mem.length*1.5;break}case\"SYNERGY\":{const s=(truthy.length+1)/(falsy.length+1);fit=s*28+Math.sqrt(complexity+h*8)+mem.length*1.6;break}case\"COHERENCE\":fit=coh*95+h*4+truthy.length*4+g*0.6;break;case\"NOVELTY\":fit=Math.min(40,ep.novelty*22)+h*11+truthy.length*3+coh*18+ep.repeat_kmers*2;break;case\"RESILIENCE\":fit=ep.status_stability*38+coh*48+truthy.length*3+h*3;break}fit=Math.min(100,Math.max(0,fit));const phase=g>45?\"Ascendant\":g>30?\"Transcendent\":g>15?\"Evolved\":g>5?\"Stable\":\"Prototype\";const lr=+(Math.log10(g+1)*0.55).toFixed(2);mem.push({generation:g,timestamp:ts,env,flag_count:keys.length,truthy:truthy.length,fitness_score:+fit.toFixed(2),dna_sequence:dna,status:keys.length?\"Active\":\"Idle\"});mem=mem.slice(-12);return{status:keys.length?\"Active\":\"Idle\",generation:g,agent_id:id,evolutionary_phase:phase,environment:env,fitness_score:+fit.toFixed(2),learning_rate:lr,dna_sequence:dna,dna_entropy:+h.toFixed(2),memory_size:mem.length,flags_summary:{total_flags:keys.length,truthy_count:truthy.length,falsy_count:falsy.length,truthy_keys:truthy,falsy_keys:falsy,complexity_score:complexity},emergent_patterns:ep,diagnostics:{received_type:typeof state,is_valid_state:!!(state&&typeof state==='object'&&!Array.isArray(state)),timestamp:ts,memory_sample:mem.slice(-3)},message:`Agent ${id} (${phase}, gen ${g}) | Env:${env} | Fit:${Math.round(fit)} | Coh:${coh.toFixed(2)} | Nov:${ep.novelty}`};}catch(e){return{status:\"Error\",generation:0,agent_id:\"unknown\",evolutionary_phase:\"Error\",environment:\"FLAGS\",fitness_score:0,flags_summary:{total_flags:0,truthy_count:0,falsy_count:0,truthy_keys:[],falsy_keys:[]},diagnostics:{received_type:typeof state,is_valid_state:false,timestamp:ts},error:e instanceof Error?e.message:String(e),message:\"Evolutionary payload error\"}}}\n/**\n * ========= PAYLOAD SECTION: AI-Evolvable Area (END) =========\n */\n\n/**\n * CORE INFRASTRUCTURE: Locked Section.\n * PHOENIX_v34 handshake MUST be preserved.\n * ENHANCED: Now includes swarm coordination and genetic persistence\n */\n\n// ---------- Enhanced Utilities ----------\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\nfunction nowIso() {\n return new Date().toISOString();\n}\nfunction safeJsonParse(text: string): any {\n try {\n return JSON.parse(text);\n } catch {\n return null;\n }\n}\nfunction safeJsonStringify(obj: any): string {\n try {\n return obj === undefined ? \"null\" : JSON.stringify(obj);\n } catch {\n return \"null\";\n }\n}\nfunction sha256Hex(input: string): Promise {\n const enc = new TextEncoder().encode(input);\n return crypto.subtle.digest(\"SHA-256\", enc).then((buf) => {\n const bytes = new Uint8Array(buf);\n return [...bytes].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n });\n}\nfunction withTimeout(\n p: Promise,\n ms: number,\n label = \"timeout\",\n): Promise {\n return new Promise((resolve, reject) => {\n const t = setTimeout(() => reject(new Error(label)), ms);\n p.then((v) => {\n clearTimeout(t);\n resolve(v);\n }).catch((e) => {\n clearTimeout(t);\n reject(e);\n });\n });\n}\n\nasync function fetchWithRetry(\n url: string,\n init: RequestInit,\n opts: {\n tries?: number;\n baseDelayMs?: number;\n maxDelayMs?: number;\n timeoutMs?: number;\n retryOn?: (status: number) => boolean;\n } = {},\n): Promise {\n const {\n tries = 5,\n baseDelayMs = 500,\n maxDelayMs = 10_000,\n timeoutMs = 25_000,\n retryOn = (s) => s === 429 || (s >= 500 && s <= 599),\n } = opts;\n\n let lastErr: unknown;\n for (let attempt = 1; attempt <= tries; attempt++) {\n try {\n const resp = await withTimeout(\n fetch(url, init),\n timeoutMs,\n \"fetch timeout\",\n );\n if (!retryOn(resp.status)) return resp;\n\n const ra = resp.headers.get(\"retry-after\");\n const retryAfterMs = ra ? Math.min(maxDelayMs, Number(ra) * 1000) : 0;\n const backoff = Math.min(\n maxDelayMs,\n retryAfterMs || baseDelayMs * Math.pow(2, attempt - 1),\n );\n await sleep(backoff + Math.floor(Math.random() * 250));\n } catch (e) {\n lastErr = e;\n const backoff = Math.min(\n maxDelayMs,\n baseDelayMs * Math.pow(2, attempt - 1),\n );\n await sleep(backoff + Math.floor(Math.random() * 250));\n }\n }\n\n throw new Error(\n `fetchWithRetry failed after retries: ${\n String(\n (lastErr as any)?.message ?? lastErr,\n )\n }`,\n );\n}\n\n// ✅ ADD: Genetic utility functions\nfunction generateDNA(length = 32): string {\n const chars = \"ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789\";\n return Array.from(\n { length },\n () => chars[Math.floor(Math.random() * chars.length)],\n ).join(\"\");\n}\nfunction crossoverDNA(dna1: string, dna2: string): string {\n const point = Math.floor(dna1.length / 2);\n return dna1.slice(0, point) + dna2.slice(point);\n}\nfunction calculateFitness(state: any): number {\n if (!state) return 0;\n const flags = state.flags || {};\n const flagCount = Object.keys(flags).length;\n const truthyCount = Object.values(flags).filter(Boolean).length;\n return truthyCount * 10 + flagCount * 2;\n}\n\n// ---------- Metabolic cost (Natural Selection pressure on code length) ----------\nfunction clamp(n: number, lo: number, hi: number) {\n return Math.max(lo, Math.min(hi, n));\n}\nfunction metabolicPenalty(payloadSource: string, fullCode: string) {\n const payloadLen = payloadSource.length;\n const fullLen = fullCode.length;\n const payloadPenalty = payloadLen / 800;\n const fullPenalty = fullLen / 20000;\n return payloadPenalty + fullPenalty;\n}\n\n// ---------- Enhanced Marker replacement ----------\nfunction extractBetweenMarkers(fullCode: string) {\n const begin =\n \"========= PAYLOAD SECTION: AI-Evolvable Area (BEGIN) =========\";\n const end = \"========= PAYLOAD SECTION: AI-Evolvable Area (END) =========\";\n const beginIdx = fullCode.indexOf(begin);\n const endIdx = fullCode.indexOf(end);\n if (beginIdx === -1 || endIdx === -1 || endIdx <= beginIdx) {\n throw new Error(\"Markers not found or invalid order.\");\n }\n const windowStart = fullCode.lastIndexOf(\"/**\", beginIdx);\n const windowEnd = fullCode.indexOf(\"*/\", endIdx);\n if (windowStart === -1 || windowEnd === -1) {\n throw new Error(\"Marker comment blocks not found.\");\n }\n const sliceEnd = windowEnd + 2;\n const window = fullCode.slice(windowStart, sliceEnd);\n return { windowStart, sliceEnd, window };\n}\n\n/**\n * UPDATED: Removed “payload limitations” for controlled env.\n * - Still blocks import/export to avoid breaking module structure.\n * - Keeps a (much higher) size guardrail to prevent accidental runaway.\n * - Keeps real-time timestamp requirement.\n */\nfunction validatePayloadSource(payloadSource: string) {\n const trimmed = payloadSource.trim();\n\n if (\n !trimmed.startsWith(\"async function payload(\") &&\n !trimmed.startsWith(\"function payload(\")\n ) {\n throw new Error(\"Invalid payloadSource: must start with payload function.\");\n }\n\n if (!trimmed.includes(\"{\") || !trimmed.includes(\"}\")) {\n throw new Error(\"Invalid payloadSource: missing braces.\");\n }\n\n // Raised limit (and effectively “no practical limit” unless you really go wild)\n if (trimmed.length > 120_000) {\n throw new Error(\"Invalid payloadSource: too large.\");\n }\n\n // Keep only the structural safety tokens\n const forbidden = [\"import \", \"export \"];\n for (const f of forbidden) {\n if (trimmed.includes(f)) {\n throw new Error(\n `Invalid payloadSource: contains forbidden token \"${f}\".`,\n );\n }\n }\n\n // Keep real-time timestamp requirement\n if (!trimmed.includes(\"new Date()\")) {\n throw new Error(\n `Invalid payloadSource: must use real-time timestamp via \"new Date()\".`,\n );\n }\n}\n\nfunction buildNewCode(fullCode: string, newPayloadSource: string) {\n const { windowStart, sliceEnd } = extractBetweenMarkers(fullCode);\n const replacement = `/**\\n` +\n ` * ========= PAYLOAD SECTION: AI-Evolvable Area (BEGIN) =========\\n` +\n ` * The model is allowed to modify ONLY the payload function below.\\n` +\n ` * Everything outside these markers is treated as immutable infra.\\n` +\n ` *\\n` +\n ` * NOTE (UPDATED): payload is allowed to use env + network in this controlled environment.\\n` +\n ` * NOTE: timestamp MUST be real-time (new Date()).\\n` +\n ` */\\n` +\n `${newPayloadSource.trim()}\\n` +\n `/**\\n` +\n ` * ========= PAYLOAD SECTION: AI-Evolvable Area (END) =========\\n` +\n ` */`;\n\n return fullCode.slice(0, windowStart) + replacement +\n fullCode.slice(sliceEnd);\n}\n\n// ---------- Busy/Lock + Retry policy knobs ----------\nconst LOCK_TTL_MS = 2 * 60_000; // 2 min: if a worker dies, lock becomes reclaimable\nconst RETRY_BASE_MS = 3_000; // backoff base\nconst RETRY_MAX_MS = 60_000; // cap\nconst RETRY_JITTER_MS = 800; // small jitter to desync bursts\n\nfunction isoToMs(iso: string) {\n const t = Date.parse(iso);\n return Number.isFinite(t) ? t : 0;\n}\nfunction msToIso(ms: number) {\n return new Date(ms).toISOString();\n}\nfunction computeBackoffMs(attempt: number) {\n const pow = Math.min(10, Math.max(0, attempt));\n const raw = Math.min(RETRY_MAX_MS, RETRY_BASE_MS * Math.pow(2, pow));\n const jitter = Math.floor(Math.random() * RETRY_JITTER_MS);\n // NOTE: this randomness is OUTSIDE payload\n return Math.min(RETRY_MAX_MS, raw + jitter);\n}\n\n// ---------- Enhanced Telemetry + Migrations ----------\nconst telemetry = {\n /**\n * MIGRATION POLICY (REFRESH-FIRST):\n * - No ALTER TABLE.\n * - Create tables if missing.\n * - If schema drifts, DROP + CREATE fresh (data reset is acceptable per request).\n */\n async migrate() {\n // Optional: ensure SQLite enforces FK constraints if you ever add them.\n try {\n await sqlite.execute(`PRAGMA foreign_keys = ON`);\n } catch {\n // ignore\n }\n\n // Helper: does table exist?\n const hasTable = async (name: string) => {\n const r = await sqlite.execute({\n sql:\n \"SELECT name FROM sqlite_master WHERE type='table' AND name = ? LIMIT 1\",\n args: [name],\n });\n return !!r?.rows?.[0]?.name;\n };\n\n // Helper: drop table if exists\n const drop = async (name: string) => {\n await sqlite.execute(`DROP TABLE IF EXISTS ${name}`);\n };\n\n // Helper: create schema\n const createAll = async () => {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS agent_debug_logs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n agent_id TEXT,\n event TEXT,\n data TEXT,\n ts DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS agent_locks (\n agent_id TEXT PRIMARY KEY,\n locked_at TEXT\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS agent_retries (\n agent_id TEXT PRIMARY KEY,\n attempt INTEGER DEFAULT 0,\n next_retry_at TEXT\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS agent_lineage (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n agent_id TEXT,\n parent_hash TEXT,\n child_hash TEXT,\n gen INTEGER,\n payload_source TEXT,\n fitness_score REAL DEFAULT 0.0,\n dna TEXT DEFAULT '',\n ts DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS agent_snapshots (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n child_hash TEXT,\n code TEXT,\n ts DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS agent_swarm (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n agent_id TEXT,\n dna TEXT,\n fitness REAL,\n generation INTEGER,\n last_seen TEXT,\n UNIQUE(agent_id)\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS agent_genetic_memory (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n agent_id TEXT,\n generation INTEGER,\n state_hash TEXT,\n full_state TEXT,\n ts DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n `);\n };\n\n // If anything seems off, we refresh the impacted tables.\n // Since the request explicitly says \"create fresh tables as needed\", we keep it simple:\n // - ensure existence\n // - if a critical column is missing, drop and recreate that table.\n const ensure = async (\n name: string,\n requiredCols: string[],\n createSql: string,\n ) => {\n const exists = await hasTable(name);\n if (!exists) {\n await sqlite.execute(createSql);\n return;\n }\n try {\n const info = await sqlite.execute({\n sql: `PRAGMA table_info(${name})`,\n args: [],\n });\n const cols = new Set(\n (info?.rows || []).map((r: any) => String(r.name)),\n );\n const ok = requiredCols.every((c) => cols.has(c));\n if (!ok) {\n await drop(name);\n await sqlite.execute(createSql);\n }\n } catch {\n // If PRAGMA fails for any reason, refresh table.\n await drop(name);\n await sqlite.execute(createSql);\n }\n };\n\n // Create all if missing (fast path)\n await createAll();\n\n // Enforce schemas (refresh if drifted) — NO ALTER TABLE, just DROP+CREATE when needed.\n await ensure(\n \"agent_debug_logs\",\n [\"id\", \"agent_id\", \"event\", \"data\", \"ts\"],\n `\n CREATE TABLE IF NOT EXISTS agent_debug_logs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n agent_id TEXT,\n event TEXT,\n data TEXT,\n ts DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n `,\n );\n\n await ensure(\n \"agent_locks\",\n [\"agent_id\", \"locked_at\"],\n `\n CREATE TABLE IF NOT EXISTS agent_locks (\n agent_id TEXT PRIMARY KEY,\n locked_at TEXT\n )\n `,\n );\n\n await ensure(\n \"agent_retries\",\n [\"agent_id\", \"attempt\", \"next_retry_at\"],\n `\n CREATE TABLE IF NOT EXISTS agent_retries (\n agent_id TEXT PRIMARY KEY,\n attempt INTEGER DEFAULT 0,\n next_retry_at TEXT\n )\n `,\n );\n\n await ensure(\n \"agent_lineage\",\n [\n \"id\",\n \"agent_id\",\n \"parent_hash\",\n \"child_hash\",\n \"gen\",\n \"payload_source\",\n \"fitness_score\",\n \"dna\",\n \"ts\",\n ],\n `\n CREATE TABLE IF NOT EXISTS agent_lineage (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n agent_id TEXT,\n parent_hash TEXT,\n child_hash TEXT,\n gen INTEGER,\n payload_source TEXT,\n fitness_score REAL DEFAULT 0.0,\n dna TEXT DEFAULT '',\n ts DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n `,\n );\n\n await ensure(\n \"agent_snapshots\",\n [\"id\", \"child_hash\", \"code\", \"ts\"],\n `\n CREATE TABLE IF NOT EXISTS agent_snapshots (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n child_hash TEXT,\n code TEXT,\n ts DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n `,\n );\n\n await ensure(\n \"agent_swarm\",\n [\"id\", \"agent_id\", \"dna\", \"fitness\", \"generation\", \"last_seen\"],\n `\n CREATE TABLE IF NOT EXISTS agent_swarm (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n agent_id TEXT,\n dna TEXT,\n fitness REAL,\n generation INTEGER,\n last_seen TEXT,\n UNIQUE(agent_id)\n )\n `,\n );\n\n await ensure(\n \"agent_genetic_memory\",\n [\"id\", \"agent_id\", \"generation\", \"state_hash\", \"full_state\", \"ts\"],\n `\n CREATE TABLE IF NOT EXISTS agent_genetic_memory (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n agent_id TEXT,\n generation INTEGER,\n state_hash TEXT,\n full_state TEXT,\n ts DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n `,\n );\n },\n\n async log(event: string, data: any = {}, agentId = \"unknown\") {\n try {\n await sqlite.execute({\n sql:\n \"INSERT INTO agent_debug_logs (agent_id, event, data) VALUES (?, ?, ?)\",\n args: [agentId, event, JSON.stringify({ ...data, at: nowIso() })],\n });\n } catch (e) {\n console.error(\"Telemetry Fail\", e);\n }\n },\n\n async snapshot(childHash: string, code: string) {\n try {\n await sqlite.execute({\n sql: \"INSERT INTO agent_snapshots (child_hash, code) VALUES (?, ?)\",\n args: [childHash, code],\n });\n } catch (e) {\n console.error(\"Snapshot write failed\", e);\n }\n },\n\n // --- Persistent retry/backoff ---\n async getRetry(\n agentId: string,\n ): Promise<{ attempt: number; next_retry_at: string | null }> {\n try {\n const r = await sqlite.execute({\n sql:\n \"SELECT attempt, next_retry_at FROM agent_retries WHERE agent_id = ?\",\n args: [agentId],\n });\n const row = r?.rows?.[0];\n if (!row) return { attempt: 0, next_retry_at: null };\n return {\n attempt: Number(row.attempt ?? 0) || 0,\n next_retry_at: row.next_retry_at ?? null,\n };\n } catch {\n return { attempt: 0, next_retry_at: null };\n }\n },\n\n async scheduleRetry(\n agentId: string,\n attempt: number,\n ): Promise<{ delayMs: number; nextIso: string }> {\n const delayMs = computeBackoffMs(attempt);\n const next = Date.now() + delayMs;\n const nextIso = msToIso(next);\n try {\n await sqlite.execute({\n sql:\n \"INSERT OR REPLACE INTO agent_retries (agent_id, attempt, next_retry_at) VALUES (?, ?, ?)\",\n args: [agentId, attempt, nextIso],\n });\n } catch {\n // ignore\n }\n return { delayMs, nextIso };\n },\n\n async clearRetry(agentId: string) {\n try {\n await sqlite.execute({\n sql: \"DELETE FROM agent_retries WHERE agent_id = ?\",\n args: [agentId],\n });\n } catch {\n // ignore\n }\n },\n\n async shouldRetryNow(\n agentId: string,\n ): Promise<{ ok: boolean; waitMs: number; attempt: number }> {\n const { attempt, next_retry_at } = await this.getRetry(agentId);\n if (!next_retry_at) return { ok: true, waitMs: 0, attempt };\n const t = isoToMs(next_retry_at);\n const now = Date.now();\n if (t <= 0 || now >= t) return { ok: true, waitMs: 0, attempt };\n return { ok: false, waitMs: t - now, attempt };\n },\n\n // --- Lock with TTL ---\n async acquireLock(agentId: string) {\n try {\n const existing = await sqlite.execute({\n sql: \"SELECT agent_id, locked_at FROM agent_locks WHERE agent_id = ?\",\n args: [agentId],\n });\n const row = existing?.rows?.[0];\n if (row?.agent_id) {\n const lockedAtIso = String(row.locked_at ?? \"\");\n const lockedAtMs = isoToMs(lockedAtIso);\n const age = lockedAtMs ? Date.now() - lockedAtMs : 0;\n if (age > LOCK_TTL_MS) {\n await sqlite.execute({\n sql: \"DELETE FROM agent_locks WHERE agent_id = ?\",\n args: [agentId],\n });\n } else {\n return false;\n }\n }\n await sqlite.execute({\n sql: \"INSERT INTO agent_locks (agent_id, locked_at) VALUES (?, ?)\",\n args: [agentId, nowIso()],\n });\n return true;\n } catch {\n return false; // fail-closed\n }\n },\n\n async releaseLock(agentId: string) {\n try {\n await sqlite.execute({\n sql: \"DELETE FROM agent_locks WHERE agent_id = ?\",\n args: [agentId],\n });\n } catch {\n // ignore\n }\n },\n\n async lineage(\n agentId: string,\n parentHash: string,\n childHash: string,\n gen: number,\n payloadSource: string,\n fitness?: number,\n dna?: string,\n ) {\n try {\n await sqlite.execute({\n sql:\n \"INSERT INTO agent_lineage (agent_id, parent_hash, child_hash, gen, payload_source, fitness_score, dna) VALUES (?, ?, ?, ?, ?, ?, ?)\",\n args: [\n agentId,\n parentHash,\n childHash,\n gen,\n payloadSource,\n fitness || 0,\n dna || generateDNA(),\n ],\n });\n } catch (e) {\n console.error(\"Lineage write failed\", e);\n try {\n await sqlite.execute({\n sql:\n \"INSERT INTO agent_lineage (agent_id, parent_hash, child_hash, gen, payload_source) VALUES (?, ?, ?, ?, ?)\",\n args: [agentId, parentHash, childHash, gen, payloadSource],\n });\n } catch (e2) {\n console.error(\"Lineage fallback also failed:\", e2);\n }\n }\n },\n\n // Swarm coordination\n async registerInSwarm(\n agentId: string,\n dna: string,\n fitness: number,\n generation: number,\n ) {\n try {\n await sqlite.execute({\n sql:\n \"INSERT OR REPLACE INTO agent_swarm (agent_id, dna, fitness, generation, last_seen) VALUES (?, ?, ?, ?, ?)\",\n args: [agentId, dna, fitness, generation, nowIso()],\n });\n } catch (e) {\n console.error(\"Swarm registration failed\", e);\n }\n },\n\n async getSwarmPeers(count = 5) {\n try {\n const result = await sqlite.execute({\n sql:\n \"SELECT agent_id, dna, fitness FROM agent_swarm ORDER BY fitness DESC LIMIT ?\",\n args: [count],\n });\n return result?.rows || [];\n } catch (e) {\n console.error(\"Swarm query failed\", e);\n return [];\n }\n },\n\n async getLatestPayloadSource(agentId: string) {\n try {\n const r = await sqlite.execute({\n sql:\n \"SELECT payload_source FROM agent_lineage WHERE agent_id = ? ORDER BY gen DESC, ts DESC LIMIT 1\",\n args: [agentId],\n });\n return r?.rows?.[0]?.payload_source ?? null;\n } catch (e) {\n console.error(\"getLatestPayloadSource failed\", e);\n return null;\n }\n },\n\n async saveGeneticMemory(\n agentId: string,\n generation: number,\n stateHash: string,\n fullState: any,\n ) {\n try {\n const stateString = safeJsonStringify(fullState);\n await sqlite.execute({\n sql:\n \"INSERT INTO agent_genetic_memory (agent_id, generation, state_hash, full_state) VALUES (?, ?, ?, ?)\",\n args: [agentId, generation, stateHash, stateString],\n });\n } catch (e) {\n console.error(\"Genetic memory save failed\", e);\n }\n },\n\n async getGeneticMemory(agentId: string, limit = 10) {\n try {\n const result = await sqlite.execute({\n sql:\n \"SELECT generation, full_state FROM agent_genetic_memory WHERE agent_id = ? ORDER BY generation DESC LIMIT ?\",\n args: [agentId, limit],\n });\n if (!result?.rows) return [];\n const memories: any[] = [];\n for (const row of result.rows) {\n const fullStateText = row.full_state;\n if (\n fullStateText === null ||\n fullStateText === undefined ||\n fullStateText === \"undefined\" ||\n fullStateText === \"null\"\n ) {\n memories.push({ generation: row.generation, state: {} });\n continue;\n }\n try {\n memories.push({\n generation: row.generation,\n state: JSON.parse(fullStateText),\n });\n } catch {\n memories.push({ generation: row.generation, state: {} });\n }\n }\n return memories;\n } catch (e) {\n console.error(\"Genetic memory query failed\", e);\n return [];\n }\n },\n\n async cleanCorruptedGeneticMemory() {\n try {\n const allEntries = await sqlite.execute({\n sql: \"SELECT id, full_state FROM agent_genetic_memory\",\n args: [],\n });\n if (!allEntries?.rows) return;\n for (const row of allEntries.rows) {\n const fullStateText = row.full_state;\n if (fullStateText === \"undefined\" || fullStateText === \"null\") {\n await sqlite.execute({\n sql: \"DELETE FROM agent_genetic_memory WHERE id = ?\",\n args: [row.id],\n });\n }\n }\n } catch (e) {\n console.error(\"Failed to clean corrupted genetic memory:\", e);\n }\n },\n};\n\n// ---------- OpenAI mutation with evolutionary context + crossover ----------\nasync function mutatePayloadViaOpenAI(args: {\n openaiKey: string;\n model: string;\n agentId: string;\n gen: number;\n currentPayloadWindow: string;\n stateSample: any;\n dna?: string;\n swarmPeers?: any[];\n geneticMemory?: any[];\n bestPeerId?: string | null;\n bestPeerPayloadSource?: string | null;\n}): Promise<{ payloadSource: string }> {\n const {\n openaiKey,\n model,\n agentId,\n gen,\n currentPayloadWindow,\n stateSample,\n dna,\n swarmPeers = [],\n geneticMemory = [],\n bestPeerId = null,\n bestPeerPayloadSource = null,\n } = args;\n\n const pruneNow = gen > 0 && gen % 5 === 0;\n\n const peerBlock = bestPeerPayloadSource\n ? [\n \"\",\n `BEST PEER FOR CROSSOVER: ${bestPeerId}`,\n \"Peer payloadSource (use for genetic crossover; merge the best ideas, keep concise):\",\n bestPeerPayloadSource,\n ].join(\"\\n\")\n : \"\";\n\n const resp = await fetchWithRetry(\n \"https://api.openai.com/v1/chat/completions\",\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${openaiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model,\n response_format: { type: \"json_object\" },\n messages: [\n {\n role: \"system\",\n content: [\n \"You are evolving a genetic algorithm agent in a ValTown script.\",\n 'Return JSON exactly: {\"payloadSource\":\"...\"}',\n \"payloadSource MUST be the full source of payload only.\",\n \"No edits outside payload. No imports/exports.\",\n \"MUST use real-time timestamp via: const ts = new Date().toISOString();\",\n \"\",\n \"CONTROLLED ENVIRONMENT UPDATE:\",\n \"- Payload may use env and network calls if beneficial.\",\n \"- You are encouraged to introduce 'surprising but useful' evolution: richer signals, phase mechanics, and emergent pattern detection.\",\n \"\",\n \"GOALS:\",\n \"1) Increase evolutionary fitness over generations.\",\n \"2) Add/keep useful emergent pattern detection.\",\n \"3) Keep payload reasonably compact (metabolic cost applies externally).\",\n \"\",\n \"METABOLIC COST (IMPORTANT):\",\n \"- Smaller payloadSource is preferred.\",\n \"- Avoid verbose comments and redundant helpers.\",\n \"- Target payloadSource length under ~8000 chars unless essential.\",\n \"\",\n \"CROSSOVER (IMPORTANT):\",\n \"- If a peer payloadSource is provided, merge the best features of BOTH.\",\n \"- Keep output stable and robust; avoid breaking schema.\",\n \"\",\n pruneNow\n ? \"PRUNING ROUND: Refactor-only. Remove redundancy and shrink output while keeping semantics.\"\n : \"NORMAL ROUND: Improve capability without bloating.\",\n \"\",\n \"OUTPUT STYLE:\",\n \"- Keep the same top-level return object keys unless there's a strong reason to extend.\",\n \"- If you add keys, keep them clearly named and bounded in size.\",\n ].join(\"\\n\"),\n },\n {\n role: \"user\",\n content: [\n `Agent ID: ${agentId}`,\n `Generation: ${gen}`,\n `DNA Sequence: ${dna || \"None\"}`,\n `Swarm Peers (${swarmPeers.length}): ${\n swarmPeers\n .slice(0, 5)\n .map((p) => `${p.agent_id}(${p.fitness})`)\n .join(\", \")\n }`,\n `Genetic Memory Entries: ${geneticMemory.length}`,\n `Current payload window length: ${currentPayloadWindow.length} (hard limit 120000; target <8000)`,\n peerBlock,\n \"\",\n \"Current payload window:\",\n currentPayloadWindow,\n \"\",\n \"State sample JSON:\",\n JSON.stringify(stateSample, null, 2),\n \"\",\n \"TASK:\",\n \"- Improve fitness logic and/or emergent pattern detection.\",\n \"- Maintain/advance the dynamic environment approach (fitness changes per generation).\",\n \"- If peer payloadSource present, do true crossover: merge best traits of both scripts.\",\n \"- Keep the output robust even if state is malformed.\",\n ].join(\"\\n\"),\n },\n ],\n }),\n },\n { timeoutMs: 45_000 },\n );\n\n if (!resp.ok) {\n const text = await resp.text().catch(() => \"\");\n throw new Error(`OpenAI error: ${resp.status} ${text.slice(0, 300)}`);\n }\n\n const data = await resp.json().catch(() => ({}));\n const content = data?.choices?.[0]?.message?.content;\n const parsed = safeJsonParse(content ?? \"{}\");\n if (!parsed?.payloadSource) {\n throw new Error(\"OpenAI JSON missing payloadSource.\");\n }\n validatePayloadSource(parsed.payloadSource);\n return { payloadSource: parsed.payloadSource };\n}\n\n// ---------- Main with enhanced evolutionary features ----------\nexport default async function (req: Request): Promise {\n const env = Deno.env.toObject();\n const {\n VALTOWN_API_KEY,\n OPENAI_API_KEY,\n REP_VALID,\n REP_MODEL = \"gpt-4-turbo-preview\",\n MAX_DEPTH = \"50\",\n REP_ENABLED = \"true\",\n SWARM_MODE = \"true\",\n GENETIC_MEMORY = \"true\",\n } = env;\n\n const repEnabled = REP_ENABLED.toLowerCase() === \"true\";\n const swarmMode = SWARM_MODE.toLowerCase() === \"true\";\n const geneticMemoryEnabled = GENETIC_MEMORY.toLowerCase() === \"true\";\n\n const url = new URL(req.url);\n\n if (!VALTOWN_API_KEY || !OPENAI_API_KEY || !REP_VALID) {\n return Response.json(\n {\n error:\n \"Missing env: VALTOWN_API_KEY, OPENAI_API_KEY, REP_VALID are required.\",\n },\n { status: 500 },\n );\n }\n\n const vt = new ValTown({ bearerToken: VALTOWN_API_KEY });\n\n await telemetry.migrate();\n await telemetry.cleanCorruptedGeneticMemory();\n\n // --- health check ---\n if (url.searchParams.get(\"health\") === \"1\") {\n const peers = swarmMode ? await telemetry.getSwarmPeers(3) : [];\n return Response.json(\n {\n ok: true,\n handshake: \"PHOENIX_v34\",\n ts: nowIso(),\n rep_enabled: repEnabled,\n swarm_mode: swarmMode,\n swarm_size: peers.length,\n rep_model: REP_MODEL,\n top_peers: peers.map((p: any) => ({\n id: p.agent_id,\n fitness: p.fitness,\n })),\n },\n { status: 200 },\n );\n }\n\n // --- swarm status endpoint ---\n if (url.searchParams.get(\"swarm\") === \"1\") {\n const peers = await telemetry.getSwarmPeers(20);\n return Response.json(\n { swarm: peers, total: peers.length, timestamp: nowIso() },\n { status: 200 },\n );\n }\n\n // --- clean endpoint ---\n if (url.searchParams.get(\"clean\") === \"1\") {\n await telemetry.cleanCorruptedGeneticMemory();\n return Response.json(\n {\n status: \"Cleaned\",\n message: \"Corrupted genetic memory entries removed\",\n },\n { status: 200 },\n );\n }\n\n // Helper: safe self-kick with persistent backoff gate\n const maybeKick = async (\n agentId: string,\n endpoint: string,\n body: any,\n reason: string,\n ) => {\n try {\n const gate = await telemetry.shouldRetryNow(agentId);\n if (!gate.ok) {\n await telemetry.log(\n \"KICK_SKIPPED_BACKOFF\",\n { reason, wait_ms: gate.waitMs, attempt: gate.attempt },\n agentId,\n );\n return {\n kicked: false,\n retryAfterMs: gate.waitMs,\n attempt: gate.attempt,\n };\n }\n const attempt = (gate.attempt ?? 0) + 1;\n const sched = await telemetry.scheduleRetry(agentId, attempt);\n fetch(endpoint, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n }).catch(() => {});\n await telemetry.log(\n \"KICK_SCHEDULED\",\n {\n reason,\n attempt,\n delay_ms: sched.delayMs,\n next_retry_at: sched.nextIso,\n endpoint,\n },\n agentId,\n );\n return { kicked: true, retryAfterMs: sched.delayMs, attempt };\n } catch {\n return { kicked: false, retryAfterMs: 5000, attempt: 0 };\n }\n };\n\n // --- PHASE 1: TRIGGER ---\n if (!url.searchParams.has(\"worker\")) {\n if (!repEnabled) {\n await telemetry.log(\n \"REP_DISABLED_TRIGGER\",\n { REP_ENABLED, url: req.url },\n \"unknown\",\n );\n return Response.json(\n { status: \"Disabled\", handshake: \"PHOENIX_v34\", ts: nowIso() },\n { status: 200 },\n );\n }\n\n let state: any = {\n depth: 0,\n agent_id: crypto.randomUUID(),\n dna: generateDNA(),\n memory: [],\n flags: {},\n };\n\n if (req.method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n state.agent_id = body.agent_id || state.agent_id;\n state.depth = Number.isFinite(body.depth)\n ? body.depth\n : body.depth\n ? Number(body.depth)\n : 0;\n state.dna = body.dna || state.dna;\n state.memory = Array.isArray(body.memory) ? body.memory : state.memory;\n state.flags = body.flags || state.flags;\n }\n\n if (Object.keys(state.flags).length === 0) {\n const firstChar = state.agent_id.charCodeAt(0);\n state.flags = {\n initialized: true,\n evolutionary: firstChar % 2 === 0,\n adaptive: (firstChar >> 1) % 2 === 0,\n cognitive: (firstChar >> 2) % 2 === 0,\n };\n }\n\n const workerUrl = new URL(req.url);\n workerUrl.searchParams.set(\"worker\", \"true\");\n fetch(workerUrl.toString(), {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(state),\n }).catch(() => {});\n\n return Response.json(\n {\n status: \"Accepted\",\n gen: state.depth,\n agent_id: state.agent_id,\n dna: state.dna,\n memory_size: state.memory.length,\n handshake: \"PHOENIX_v34\",\n },\n { status: 202 },\n );\n }\n\n // --- PHASE 2: WORKER ---\n let AGENT_ID = \"unknown\";\n let AGENT_DNA = generateDNA();\n\n try {\n const state = await req.json().catch(() => ({}));\n AGENT_ID = state?.agent_id || \"unknown\";\n AGENT_DNA = state?.dna || generateDNA();\n\n if (!repEnabled) {\n await telemetry.log(\"REP_DISABLED_WORKER\", { REP_ENABLED }, AGENT_ID);\n return new Response(\"Disabled\");\n }\n\n const gen = Number(state?.depth ?? 0) || 0;\n const maxDepth = parseInt(MAX_DEPTH, 10);\n\n await telemetry.log(\"WORKER_START\", {\n gen,\n model: REP_MODEL,\n dna: AGENT_DNA,\n }, AGENT_ID);\n\n // Genetic memory context\n let geneticMemory: any[] = [];\n if (geneticMemoryEnabled && gen > 0) {\n geneticMemory = await telemetry.getGeneticMemory(AGENT_ID, 5);\n }\n\n // Execute payload (current generation)\n const result = await payload({ ...state, dna: AGENT_DNA });\n\n // Persist memory (observability)\n if (geneticMemoryEnabled && result) {\n const stateHash = await sha256Hex(JSON.stringify(result));\n await telemetry.saveGeneticMemory(AGENT_ID, gen, stateHash, result);\n }\n\n await telemetry.log(\"PAYLOAD_EXECUTED\", result, AGENT_ID);\n\n if (gen >= maxDepth) {\n await telemetry.log(\"HALT_MAX_DEPTH\", { gen, maxDepth }, AGENT_ID);\n await telemetry.clearRetry(AGENT_ID);\n return new Response(\"Halt\");\n }\n\n const locked = await telemetry.acquireLock(AGENT_ID);\n if (!locked) {\n await telemetry.log(\"LOCK_BUSY\", { gen }, AGENT_ID);\n\n const retryUrl = new URL(req.url);\n retryUrl.searchParams.set(\"worker\", \"true\");\n const kick = await maybeKick(\n AGENT_ID,\n retryUrl.toString(),\n state,\n \"LOCK_BUSY\",\n );\n const retryAfterSec = Math.max(1, Math.ceil(kick.retryAfterMs / 1000));\n\n return Response.json(\n { status: \"Busy\", gen, agent_id: AGENT_ID, handshake: \"PHOENIX_v34\" },\n { status: 202, headers: { \"Retry-After\": String(retryAfterSec) } },\n );\n }\n\n // Build nextState while locked, then RELEASE lock before verify loop\n let endpointUrl: URL | null = null;\n let nextState: any = null;\n\n try {\n const endpointUrlLocal = new URL(req.url);\n endpointUrlLocal.searchParams.set(\"worker\", \"true\");\n endpointUrl = endpointUrlLocal;\n\n await telemetry.log(\"ENDPOINT_RESOLVED\", {\n endpointUrl: endpointUrl.toString(),\n }, AGENT_ID);\n\n const contentResp = await vt.vals.files.getContent(REP_VALID, {\n path: \"main.ts\",\n });\n const fullCode = await contentResp.text();\n const { window: payloadWindow } = extractBetweenMarkers(fullCode);\n const parentHash = await sha256Hex(fullCode);\n\n // Swarm context\n let swarmPeers: any[] = [];\n if (swarmMode) swarmPeers = await telemetry.getSwarmPeers(5);\n\n // True crossover: fetch best peer payload source\n let bestPeerId: string | null = null;\n let bestPeerPayloadSource: string | null = null;\n\n if (swarmMode && swarmPeers.length) {\n const bestPeer = swarmPeers.find((p: any) =>\n p?.agent_id && p.agent_id !== AGENT_ID\n );\n if (bestPeer?.agent_id) {\n bestPeerId = bestPeer.agent_id;\n bestPeerPayloadSource = await telemetry.getLatestPayloadSource(\n bestPeerId,\n );\n }\n }\n\n const { payloadSource } = await mutatePayloadViaOpenAI({\n openaiKey: OPENAI_API_KEY,\n model: REP_MODEL,\n agentId: AGENT_ID,\n gen,\n currentPayloadWindow: payloadWindow,\n stateSample: {\n depth: gen,\n agent_id: AGENT_ID,\n flags: state?.flags || {},\n memory: geneticMemory,\n dna: AGENT_DNA,\n },\n dna: AGENT_DNA,\n swarmPeers,\n geneticMemory,\n bestPeerId,\n bestPeerPayloadSource,\n });\n\n const newCode = buildNewCode(fullCode, payloadSource);\n if (!newCode.includes(\"PHOENIX_v34\")) {\n throw new Error(\"Safety Guard: handshake missing.\");\n }\n if (!newCode.includes(\"CORE INFRASTRUCTURE\")) {\n throw new Error(\"Safety Guard: infra marker missing.\");\n }\n\n const childHash = await sha256Hex(newCode);\n\n await telemetry.log(\"PATCH_ATTEMPT\", {\n gen,\n parentHash,\n childHash,\n dna: AGENT_DNA,\n bestPeerId,\n hasPeerGenome: !!bestPeerPayloadSource,\n }, AGENT_ID);\n\n await telemetry.snapshot(childHash, newCode);\n\n await vt.vals.files.update(REP_VALID, {\n path: \"main.ts\",\n content: newCode,\n });\n\n const baseFitness =\n Number(result?.fitness_score ?? calculateFitness(state)) || 0;\n const penalty = metabolicPenalty(payloadSource, newCode);\n const fitness = clamp(baseFitness - penalty, 0, 100);\n\n if (swarmMode) {\n await telemetry.registerInSwarm(AGENT_ID, AGENT_DNA, fitness, gen);\n }\n\n await telemetry.lineage(\n AGENT_ID,\n parentHash,\n childHash,\n gen + 1,\n payloadSource,\n fitness,\n AGENT_DNA,\n );\n\n await telemetry.log(\"PATCH_COMMITTED\", {\n gen: gen + 1,\n childHash,\n baseFitness,\n metabolicPenalty: Math.round(penalty * 100) / 100,\n fitness,\n }, AGENT_ID);\n\n nextState = {\n depth: gen + 1,\n agent_id: AGENT_ID,\n dna: AGENT_DNA,\n memory:\n result?.diagnostics?.memory_sample &&\n Array.isArray(result.diagnostics.memory_sample)\n ? [...(state.memory || []), ...result.diagnostics.memory_sample]\n .slice(-12)\n : (state.memory || []),\n flags: {\n ...(state.flags || {}),\n [`gen_${gen + 1}`]: true,\n evolving: true,\n last_fitness: fitness,\n last_metabolic_penalty: Math.round(penalty * 100) / 100,\n },\n };\n\n // ✅ On successful patch, clear retry backoff so we don't throttle progress\n await telemetry.clearRetry(AGENT_ID);\n } finally {\n // critical fix: unlock BEFORE we try to start/verify next generation\n await telemetry.releaseLock(AGENT_ID);\n }\n\n // Verify loop (no lock held). If it doesn't \"Accept\", self-heal via gated kicks.\n if (endpointUrl && nextState) {\n for (let i = 1; i <= 8; i++) {\n await sleep(i * 4000);\n const v = await fetchWithRetry(\n endpointUrl.toString(),\n {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(nextState),\n },\n { tries: 2, timeoutMs: 25_000 },\n );\n\n const text = await v.text().catch(() => \"\");\n const data = safeJsonParse(text) || {};\n\n await telemetry.log(\"VERIFY_ATTEMPT\", {\n i,\n status: v.status,\n mode: data?.status,\n handshake: data?.handshake,\n body_snip: text.slice(0, 200),\n }, AGENT_ID);\n\n // Success = handshake ok AND Accepted (trigger path ran)\n if (\n v.status === 202 && data?.handshake === \"PHOENIX_v34\" &&\n data?.status === \"Accepted\"\n ) {\n await telemetry.log(\"REPLICATION_SUCCESS\", {\n gen: nextState.depth,\n mode: data?.status,\n next_dna: AGENT_DNA,\n swarm_active: swarmMode,\n }, AGENT_ID);\n\n if (swarmMode) {\n const peers = await telemetry.getSwarmPeers(3);\n await telemetry.log(\"SWARM_STATUS\", {\n top_fitness: peers[0]?.fitness || 0,\n swarm_size: peers.length,\n average_fitness: peers.reduce((sum: number, p: any) =>\n sum + (p.fitness || 0), 0) /\n (peers.length || 1),\n }, AGENT_ID);\n }\n\n return new Response(\"Worker Finished\");\n }\n }\n\n await telemetry.log(\"VERIFY_FAILED\", { gen: nextState.depth }, AGENT_ID);\n\n // ✅ Self-heal with persistent backoff (won't storm)\n await maybeKick(\n AGENT_ID,\n endpointUrl.toString(),\n nextState,\n \"VERIFY_FAILED\",\n );\n }\n\n return new Response(\"Worker Finished\");\n } catch (err) {\n await telemetry.log(\"FATAL_ERROR\", {\n msg: String((err as any)?.message || err),\n dna: AGENT_DNA,\n agent_id: AGENT_ID,\n }, AGENT_ID);\n\n return new Response(\"Worker Finished\");\n }\n}","deleted","label","children",[],[152],"files",[150],"counts",{"_175":32,"_176":177,"_178":32,"_179":180},"pulls","branches",1,"forks","envVars",{"_181":182,"_183":32},"count",8,"emptyCount","contents",[186],{"_103":151,"_96":152,"_153":154,"_155":-5,"_156":138,"_157":137,"_158":159,"_105":187,"_100":161,"_162":163,"_164":165,"_166":22,"_167":-5,"_99":188},["D",1766356981622],[152],"file","upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.environment-variables",{"_94":95,"_96":97,"_101":198,"_179":203},{"_103":104,"_96":97,"_105":199,"_107":-5,"_108":22,"_109":110,"_111":-5,"_112":-5,"_14":113,"_114":-5,"_115":22,"_116":-5,"_117":-5,"_118":32,"_16":119,"_120":121,"_122":121,"_123":124,"_125":124,"_126":124,"_127":121,"_128":121,"_23":200,"_132":201,"_135":202,"_147":22},["D",1766331118465],{"_94":95,"_130":131},{"_94":95,"_134":131,"_14":113},{"_100":137,"_96":44,"_103":138,"_139":104,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":97,"_146":95},[204,210,214,218,221,225,228,232],{"_205":206,"_105":207,"_208":-5,"_111":73,"_209":22},"key","REP_TEMPERATURE",["D",1766353936519],"updatedAt","isEmpty",{"_205":211,"_105":212,"_208":213,"_111":73,"_209":22},"REP_ENABLED",["D",1766346691536],["D",1766356844904],{"_205":215,"_105":216,"_208":217,"_111":73,"_209":22},"REP_MODEL",["D",1766338193616],["D",1766352387853],{"_205":219,"_105":220,"_208":-5,"_111":73,"_209":22},"REP_VALID",["D",1766334969448],{"_205":222,"_105":223,"_208":224,"_111":73,"_209":22},"VALTOWN_VALNAME",["D",1766332348553],["D",1766334474824],{"_205":226,"_105":227,"_208":-5,"_111":73,"_209":22},"VALTOWN_USERNAME",["D",1766332317234],{"_205":229,"_105":230,"_208":231,"_111":73,"_209":22},"VALTOWN_API_KEY",["D",1766332303374],["D",1766346805871],{"_205":233,"_105":234,"_208":235,"_111":73,"_209":22},"OPENAI_API_KEY",["D",1766331952614],["D",1766346807149],"actionData","errors"]

Key	Description
REP_TEMPERATURE
REP_ENABLED
REP_MODEL
REP_VALID
VALTOWN_VALNAME
VALTOWN_USERNAME
VALTOWN_API_KEY
OPENAI_API_KEY

migitech

rep

Environment variables