[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_299":300,"_301":302},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_93":-7,"_94":43,"_29":-7,"_95":-5,"_15":96,"_97":98,"_99":100,"_101":102,"_103":104,"_105":-5,"_106":-5,"_107":-5,"_108":38,"_109":110,"_111":50,"_112":-5,"_113":-5,"_114":115},"routes/_app.x.$handle.$name.branches",{"_11":12,"_13":14,"_15":16,"_17":18},"handle","alamzubair","name","Nexuses_core_os_ai","project",{"_20":28,"_13":14,"_22":36,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":50,"_51":-5,"_52":-5,"_53":54,"_55":56,"_57":58,"_59":60,"_61":62,"_63":-5,"_64":65,"_66":65,"_67":68,"_69":68,"_70":68,"_71":65,"_72":65,"_73":74,"_75":76,"_77":78,"_79":38},"branches",[19],{"_20":21,"_22":23,"_24":25,"_13":26,"_27":28,"_29":30,"_31":-5,"_32":-5,"_33":34,"_35":-5},"id","6a688a47-c650-46ed-b95f-c81ab586108d","createdAt",["D",1783347377253],"updatedAt",["D",1783360829705],"main","projectId","94fe1097-1c95-40e6-a707-d2eb9254f81e","version",65,"forkedBranchId","forkedBranchVersion","lockfileKey","1783360830787-esm.town_v_alamzubair_Nexuses_core_os_ai@65-main","deletedAt",["D",1783347377247],"legacyEnvVars",false,"privacy","public","httpPrivacy","description","","imageUrl","userId","e98ea39e-0595-4d29-86e1-789bc7567b51","pinnedFileId","40d87268-7945-11f1-ac19-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f37c8-fde7-721a-95a7-e2a7f7bcb738","tursoName","94fe10971c9540e6a707d2eb9254f81e","tursoHostname","94fe10971c9540e6a707d2eb9254f81e-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789435890000],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_92":88},"org",{"_11":12,"_85":86,"_87":88,"_45":46,"_89":90,"_91":38},"branch",{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_80":-5,"_81":-5,"_82":-5,"_83":14,"_84":12},"isOwned","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Alam Zubair","avatar","https://lh3.googleusercontent.com/a/ACg8ocINqsCFv5AljwZtsm09t4QxLTSGRbzHpD3Je6v88ir-C33RUA=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","path","adoptOrgId",{"_20":28,"_13":14,"_22":294,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":50,"_51":-5,"_52":-5,"_53":54,"_55":56,"_57":58,"_59":60,"_61":295,"_63":-5,"_64":65,"_66":65,"_67":68,"_69":68,"_70":68,"_71":65,"_72":65,"_73":296,"_75":297,"_77":298,"_79":38},"tree",[167,173,181,182],"files",[167,168,169,170,171,172,173,174,175,176,177,178,179,180,181,182],"counts",{"_157":54,"_17":158,"_159":54,"_160":161,"_162":163},"contents",[116,117,118,119],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_20":151,"_13":152,"_122":153,"_124":-5,"_125":21,"_126":154,"_127":50,"_22":155,"_29":54,"_129":149,"_131":-5,"_133":38,"_134":-5,"_94":156},{"_20":144,"_13":145,"_122":146,"_124":-5,"_125":21,"_126":147,"_127":50,"_22":148,"_29":54,"_129":149,"_131":-5,"_133":38,"_134":-5,"_94":150},{"_20":136,"_13":137,"_122":48,"_124":-5,"_125":21,"_126":138,"_127":50,"_22":139,"_29":140,"_129":141,"_131":142,"_133":38,"_134":-5,"_94":143},{"_20":120,"_13":121,"_122":123,"_124":-5,"_125":21,"_126":30,"_127":50,"_22":128,"_29":54,"_129":130,"_131":132,"_133":38,"_134":-5,"_94":135},"c421eebf-d1ea-49c7-a24c-7edd0104335d","worker.ts","fileId","931e961e-7964-11f1-98e3-1607ee4eb77e","parentId","branchId","branchVersion","latest",["D",1783360829705],"fileType","interval","content","// Nexuses Core V3.1 — Background Worker (Interval)\n// Safety net: picks up pending tasks that weren't processed by the\n// fire-and-forget background promise in main.ts.\n// Runs every 15 minutes (free tier minimum interval).\n\nimport { processPendingTasks } from \"./lib/dispatcher.ts\";\n\nexport default async function () {\n console.log(\"[Worker] Starting pending task sweep...\");\n const result = await processPendingTasks(10);\n console.log(`[Worker] Sweep complete — processed: ${result.processed}`);\n if (result.results.length > 0) {\n for (const r of result.results) {\n console.log(`[Worker] Task ${r.id} → ${r.status}`);\n }\n }\n return result;\n}\n","deleted","label",[121],"533d202f-2aee-460f-8f1d-f982ba5a7508","main.ts",63,["D",1783360797404],4,"http","// ═══════════════════════════════════════════════════════════════\n// Nexuses Core V3.1 — Autonomous AI Operating System\n// HTTP Entry Point · Async Task Queue · Open-Architecture · Zero API Keys\n// ═══════════════════════════════════════════════════════════════\n//\n// POST /task → returns instantly with {status:\"accepted\", task_id:\"...\"}\n// GET /result?id=xxx → poll for completion (pending → processing → completed)\n//\n// All AI powered by Pollinations.ai (free, open-source, no token).\n// Every task requires a SourceID for verification.\n// M2M protocol: JSON-RPC 2.0 + REST.\n\nimport {\n submitTask,\n processTaskById,\n processPendingTasks,\n getHistory,\n getSystemStatus,\n getTaskResult,\n} from \"./lib/dispatcher.ts\";\nimport { processRPC } from \"./lib/rpc.ts\";\nimport { registerNewSource } from \"./lib/verification.ts\";\nimport { initDB, listSources, getRecentLogs } from \"./lib/db.ts\";\n\nconst CORS = {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, X-Source-ID\",\n};\n\nfunction json(body: any, status = 200) {\n return new Response(JSON.stringify(body, null, 2), { status, headers: CORS });\n}\n\nexport default async function (req: Request): Promise {\n if (req.method === \"OPTIONS\") return new Response(null, { headers: CORS });\n\n await initDB();\n\n const url = new URL(req.url);\n const path = url.pathname;\n\n // ═══════════════════════════════════════\n // GET ROUTES — Discovery, Polling & Monitoring\n // ═══════════════════════════════════════\n\n if (req.method === \"GET\") {\n if (path === \"/\" || path === \"\") return json(await getSystemStatus());\n if (path === \"/status\") return json(await getSystemStatus());\n if (path === \"/agents\") return json({ agents: (await getSystemStatus()).agents });\n if (path === \"/sources\") return json({ sources: await listSources() });\n\n // GET /result?id=xxx — Poll task status (async result endpoint)\n if (path === \"/result\") {\n const taskId = url.searchParams.get(\"id\") || \"\";\n if (!taskId) {\n return json({\n status: \"failure\",\n message: \"Missing 'id' parameter — usage: GET /result?id=\",\n }, 400);\n }\n const result = await getTaskResult(taskId);\n return json(result, result.status === \"not_found\" ? 404 : 200);\n }\n\n if (path === \"/history\") {\n const limit = parseInt(url.searchParams.get(\"limit\") || \"20\");\n return json({ history: await getHistory(limit) });\n }\n\n if (path === \"/logs\") {\n const limit = parseInt(url.searchParams.get(\"limit\") || \"50\");\n return json({ logs: await getRecentLogs(limit) });\n }\n\n // GET /process-pending — Manual trigger to process pending tasks (admin/debug)\n if (path === \"/process-pending\") {\n const result = await processPendingTasks(5);\n return json(result);\n }\n\n const taskMatch = path.match(/^\\/task\\/(.+)$/);\n if (taskMatch) {\n const task = await getTaskResult(taskMatch[1]);\n return task.status === \"not_found\"\n ? json({ status: \"failure\", message: \"Task not found\" }, 404)\n : json({ task });\n }\n\n return json({ error: \"Unknown endpoint\", available: [\n \"GET /\", \"GET /status\", \"GET /result?id=\", \"GET /agents\", \"GET /sources\",\n \"GET /history\", \"GET /logs\", \"GET /task/:id\", \"GET /process-pending\",\n \"POST /task\", \"POST /register\", \"POST /rpc\",\n ] }, 404);\n }\n\n // ═══════════════════════════════════════\n // POST ROUTES — Task Submission & M2M\n // ═══════════════════════════════════════\n\n if (req.method !== \"POST\") {\n return json({ error: \"Only GET and POST supported\" }, 405);\n }\n\n let payload: any;\n try {\n payload = await req.json();\n } catch {\n return json({ status: \"failure\", message: \"Invalid JSON body\" }, 400);\n }\n\n // POST /register — Register a new source\n if (path === \"/register\") {\n const { source_id, name, description } = payload;\n if (!source_id || !name) {\n return json({\n status: \"failure\",\n message: \"Missing required fields: source_id, name\",\n }, 400);\n }\n const result = await registerNewSource(source_id, name, description || \"\");\n return json(result, result.verified ? 200 : 400);\n }\n\n // POST /rpc — JSON-RPC 2.0 endpoint (M2M protocol)\n if (path === \"/rpc\") {\n const rpcResponse = await processRPC(payload);\n return json(rpcResponse, rpcResponse.error ? 400 : 200);\n }\n\n // POST /task — ASYNC task submission (requires SourceID)\n // Returns instantly with {status:\"accepted\", task_id:\"...\"}\n // Processing happens fire-and-forget in the background.\n if (path === \"/task\" || path === \"/\" || path === \"\") {\n // Extract SourceID from body or header\n const sourceId = payload.source_id ||\n req.headers.get(\"x-source-id\") ||\n req.headers.get(\"X-Source-ID\") || \"\";\n\n if (!sourceId) {\n return json({\n status: \"failure\",\n message: \"SourceID required — include 'source_id' in body or 'X-Source-ID' header. Register your source via POST /register.\",\n hint: { register_endpoint: \"POST /register\", body_format: { source_id: \"your-platform-id\", name: \"Platform Name\", description: \"optional\" } },\n }, 401);\n }\n\n // Universal request normalizer — accept flexible task field names\n const taskFields = [\"task\", \"query\", \"prompt\", \"command\", \"message\", \"input\", \"text\"];\n let task = \"\";\n let data = { ...payload };\n delete data.source_id;\n\n for (const key of taskFields) {\n if (payload[key]) {\n task = payload[key];\n delete data[key];\n break;\n }\n }\n\n if (!task) {\n return json({\n status: \"failure\",\n message: \"No task provided — include 'task' (or 'query', 'prompt', 'command', 'message', 'input', 'text') in body\",\n }, 400);\n }\n\n // ── ASYNC SUBMIT ──\n // 1. Save to DB as 'pending' and get task_id (fast — no LLM call)\n const submitResponse = await submitTask(task, data, sourceId);\n\n if (submitResponse.status === \"failure\") {\n return json(submitResponse, 401);\n }\n\n // 2. Fire processing in the background — DO NOT await\n // This continues after the response is sent. If the runtime kills it,\n // the worker interval (worker.ts) will pick up the pending task.\n processTaskById(submitResponse.task_id).catch((e) => {\n console.error(`[main] Background processing error for ${submitResponse.task_id}:`, e.message);\n });\n\n // 3. Return immediately — user polls GET /result?id=\n return json(submitResponse, 202);\n }\n\n // Unknown POST path\n return json({ status: \"failure\", message: \"Unknown endpoint\" }, 404);\n}\n",[137],"10657c68-b48a-444f-8dfe-b4fe9700ad16","lib","69dda6e0-7960-11f1-9859-1607ee4eb77e",37,["D",1783359042499],"directory",[145],"0dbb60d1-1be9-40d7-a97a-7330cd44c97c","agents","69ed2fde-7960-11f1-9859-1607ee4eb77e",38,["D",1783359042602],[152],"pulls",1,"forks","envVars",{"_164":54,"_166":54},"connections",{"_164":54,"_165":54},"count","unfilledCount","emptyCount",{"_20":151,"_13":152,"_122":153,"_124":-5,"_125":21,"_126":154,"_127":50,"_22":291,"_29":54,"_129":149,"_131":-5,"_133":38,"_134":-5,"_184":292,"_94":293},{"_20":283,"_13":284,"_122":285,"_124":153,"_125":21,"_126":286,"_127":50,"_22":287,"_29":54,"_129":195,"_131":288,"_133":38,"_134":-5,"_184":289,"_94":290},{"_20":275,"_13":276,"_122":277,"_124":153,"_125":21,"_126":278,"_127":50,"_22":279,"_29":54,"_129":195,"_131":280,"_133":38,"_134":-5,"_184":281,"_94":282},{"_20":267,"_13":268,"_122":269,"_124":153,"_125":21,"_126":270,"_127":50,"_22":271,"_29":54,"_129":195,"_131":272,"_133":38,"_134":-5,"_184":273,"_94":274},{"_20":259,"_13":260,"_122":261,"_124":153,"_125":21,"_126":262,"_127":50,"_22":263,"_29":54,"_129":195,"_131":264,"_133":38,"_134":-5,"_184":265,"_94":266},{"_20":251,"_13":252,"_122":253,"_124":153,"_125":21,"_126":254,"_127":50,"_22":255,"_29":54,"_129":195,"_131":256,"_133":38,"_134":-5,"_184":257,"_94":258},{"_20":144,"_13":145,"_122":146,"_124":-5,"_125":21,"_126":147,"_127":50,"_22":248,"_29":54,"_129":149,"_131":-5,"_133":38,"_134":-5,"_184":249,"_94":250},{"_20":239,"_13":240,"_122":241,"_124":146,"_125":21,"_126":242,"_127":50,"_22":243,"_29":244,"_129":195,"_131":245,"_133":38,"_134":-5,"_184":246,"_94":247},{"_20":231,"_13":232,"_122":233,"_124":146,"_125":21,"_126":234,"_127":50,"_22":235,"_29":158,"_129":195,"_131":236,"_133":38,"_134":-5,"_184":237,"_94":238},{"_20":223,"_13":224,"_122":225,"_124":146,"_125":21,"_126":226,"_127":50,"_22":227,"_29":54,"_129":195,"_131":228,"_133":38,"_134":-5,"_184":229,"_94":230},{"_20":215,"_13":216,"_122":217,"_124":146,"_125":21,"_126":218,"_127":50,"_22":219,"_29":158,"_129":195,"_131":220,"_133":38,"_134":-5,"_184":221,"_94":222},{"_20":207,"_13":208,"_122":209,"_124":146,"_125":21,"_126":210,"_127":50,"_22":211,"_29":54,"_129":195,"_131":212,"_133":38,"_134":-5,"_184":213,"_94":214},{"_20":199,"_13":200,"_122":201,"_124":146,"_125":21,"_126":202,"_127":50,"_22":203,"_29":54,"_129":195,"_131":204,"_133":38,"_134":-5,"_184":205,"_94":206},{"_20":190,"_13":191,"_122":192,"_124":146,"_125":21,"_126":193,"_127":50,"_22":194,"_29":54,"_129":195,"_131":196,"_133":38,"_134":-5,"_184":197,"_94":198},{"_20":136,"_13":137,"_122":48,"_124":-5,"_125":21,"_126":138,"_127":50,"_22":187,"_29":140,"_129":141,"_131":142,"_133":38,"_134":-5,"_184":188,"_94":189},{"_20":120,"_13":121,"_122":123,"_124":-5,"_125":21,"_126":30,"_127":50,"_22":183,"_29":54,"_129":130,"_131":132,"_133":38,"_134":-5,"_184":185,"_94":186},["D",1783360829705],"children",[],[121],["D",1783360797404],[],[137],"29378822-e19e-42ba-8d2d-4b0658f81265","verification.ts","967d813e-7960-11f1-b2d7-1607ee4eb77e",42,["D",1783359117369],"script","// Source Verification Layer — Nexuses Core V3\n// Every incoming request must carry a SourceID.\n// The system confirms if the request originates from a trusted/registered platform.\n\nimport { initDB, registerSource, verifySource } from \"./db.ts\";\nimport type { VerificationResult } from \"./types.ts\";\n\n/**\n * Verifies that a SourceID is registered and active.\n * Returns a structured VerificationResult for M2M consumption.\n */\nexport async function checkSource(sourceId: string): Promise {\n await initDB();\n\n if (!sourceId || sourceId.trim().length === 0) {\n return {\n verified: false,\n source_id: sourceId || \"MISSING\",\n message: \"SourceID is required — request rejected\",\n };\n }\n\n const source = await verifySource(sourceId);\n if (!source) {\n return {\n verified: false,\n source_id: sourceId,\n message: `Verification Failed — SourceID \"${sourceId}\" is not registered. Use POST /register to register this source.`,\n };\n }\n\n return {\n verified: true,\n source_id: sourceId,\n name: source.name,\n message: `Source verified: ${source.name}`,\n };\n}\n\n/**\n * Registers a new trusted source.\n * Called via POST /register endpoint.\n */\nexport async function registerNewSource(\n sourceId: string,\n name: string,\n description: string,\n): Promise {\n await initDB();\n\n if (!sourceId || sourceId.trim().length < 3) {\n return {\n verified: false,\n source_id: sourceId || \"MISSING\",\n message: \"SourceID must be at least 3 characters\",\n };\n }\n\n const success = await registerSource(sourceId, name, description);\n if (!success) {\n return {\n verified: false,\n source_id: sourceId,\n message: \"Failed to register source — database error\",\n };\n }\n\n return {\n verified: true,\n source_id: sourceId,\n name,\n message: `Source \"${name}\" registered successfully with SourceID \"${sourceId}\"`,\n };\n}\n",[],[145,191],"13ca991a-7060-4d3b-92a7-1e1a29e5086a","types.ts","75094510-7960-11f1-acba-1607ee4eb77e",39,["D",1783359061231],"// Nexuses Core V3 — Shared Type Definitions\n// Central type registry for the entire autonomous AI OS.\n\nexport type TaskCategory =\n | \"coding\"\n | \"scraping\"\n | \"analysis\"\n | \"media\"\n | \"marketing\"\n | \"general\";\n\nexport type AgentName =\n | \"CoderAgent\"\n | \"ScraperAgent\"\n | \"AnalystAgent\"\n | \"MediaAgent\"\n | \"MarketingAgent\"\n | \"GeneralAgent\";\n\nexport interface AgentResult {\n agent: AgentName;\n category: TaskCategory;\n status: \"success\" | \"error\" | \"partial\";\n message: string;\n data: any;\n executionTimeMs: number;\n}\n\nexport interface StepResult {\n step: number;\n description: string;\n agent: AgentName;\n status: \"success\" | \"error\" | \"failed\";\n result?: any;\n error?: string;\n attempts: number;\n}\n\nexport interface CoTAnalysis {\n reasoning: string;\n category: TaskCategory;\n agent: AgentName;\n steps: string[];\n complexity: \"simple\" | \"complex\";\n}\n\nexport interface DispatchResponse {\n status: \"success\" | \"failure\";\n task_id: string;\n source_id: string;\n verified: boolean;\n reasoning: string;\n category: TaskCategory;\n agent: AgentName;\n steps: StepResult[];\n data: any;\n message: string;\n executionTimeMs: number;\n timestamp: string;\n}\n\nexport interface VerificationResult {\n verified: boolean;\n source_id: string;\n name?: string;\n message: string;\n}\n\nexport interface SourceRecord {\n source_id: string;\n name: string;\n description: string;\n status: string;\n created_at: string;\n}\n\nexport interface TaskRecord {\n id: string;\n source_id: string;\n task: string;\n agent: string;\n category: string;\n status: string;\n complexity: string;\n reasoning: string;\n data: string;\n result: string;\n created_at: string;\n updated_at: string;\n}\n\nexport interface LogEntry {\n id: string;\n level: string;\n component: string;\n message: string;\n created_at: string;\n}\n",[],[145,200],"1a55b9b5-7b72-4749-b995-63923e7d4c3f","taskProcessor.ts","f5204b54-7960-11f1-a85c-1607ee4eb77e",48,["D",1783359276137],"// Step-by-Step Task Processor — Nexuses Core V3\n// Breaks complex tasks into discrete steps, executes sequentially,\n// verifies each step, retries once on failure before logging error.\n\nimport { callLLM } from \"./llm.ts\";\nimport { logStep, logEvent } from \"./db.ts\";\nimport type { AgentResult, StepResult, AgentName } from \"./types.ts\";\n\n// Agent imports\nimport { execute as scraperExecute } from \"../agents/scraperAgent.ts\";\nimport { execute as coderExecute } from \"../agents/coderAgent.ts\";\nimport { execute as analystExecute } from \"../agents/analystAgent.ts\";\nimport { execute as mediaExecute } from \"../agents/mediaAgent.ts\";\nimport { execute as marketingExecute } from \"../agents/marketingAgent.ts\";\n\nconst AGENT_MAP: Record Promise> = {\n CoderAgent: coderExecute,\n ScraperAgent: scraperExecute,\n AnalystAgent: analystExecute,\n MediaAgent: mediaExecute,\n MarketingAgent: marketingExecute,\n GeneralAgent: generalAgentExecute,\n};\n\nasync function generalAgentExecute(task: string, data: any): Promise {\n const start = Date.now();\n const result = await callLLM(data.prompt || task, { maxTokens: 800 });\n return {\n agent: \"GeneralAgent\",\n category: \"general\",\n status: result.success ? \"success\" : \"error\",\n message: result.success ? \"Task processed\" : \"LLM unavailable\",\n data: { input: task, response: result.text || \"\" },\n executionTimeMs: Date.now() - start,\n };\n}\n\n/**\n * Execute a single step via the appropriate agent.\n * Includes automatic retry-once on failure.\n */\nasync function executeStepWithRetry(\n taskId: string,\n stepNum: number,\n description: string,\n agentName: AgentName,\n data: any,\n): Promise {\n const agentFn = AGENT_MAP[agentName] || AGENT_MAP.GeneralAgent;\n\n // Attempt 1\n let result = await agentFn(description, data);\n let attempts = 1;\n\n if (result.status === \"success\" || result.status === \"partial\") {\n await logStep(taskId, stepNum, description, agentName, \"success\", result.data, attempts);\n return {\n step: stepNum,\n description,\n agent: agentName,\n status: \"success\",\n result: result.data,\n attempts,\n };\n }\n\n // Retry once\n attempts = 2;\n await logEvent(\"warn\", \"TaskProcessor\", `Step ${stepNum} failed on attempt 1: ${result.message}. Retrying...`);\n\n // Adjust data for retry — simplify prompt\n const retryData = { ...data, prompt: description.slice(0, 500) };\n result = await agentFn(description, retryData);\n\n if (result.status === \"success\" || result.status === \"partial\") {\n await logStep(taskId, stepNum, description, agentName, \"success\", result.data, attempts);\n return {\n step: stepNum,\n description,\n agent: agentName,\n status: \"success\",\n result: result.data,\n attempts,\n };\n }\n\n // Both attempts failed\n await logStep(taskId, stepNum, description, agentName, \"failed\", result.data, attempts);\n await logEvent(\"error\", \"TaskProcessor\", `Step ${stepNum} failed after ${attempts} attempts: ${result.message}`);\n\n return {\n step: stepNum,\n description,\n agent: agentName,\n status: \"failed\",\n error: result.message,\n attempts,\n };\n}\n\n/**\n * Process a complex multi-step task.\n * Executes steps sequentially — if a step fails (after retry), logs error and continues.\n * Returns all step results.\n */\nexport async function processComplexTask(\n taskId: string,\n steps: string[],\n agentName: AgentName,\n data: any,\n): Promise<{ stepResults: StepResult[]; finalData: any; allSucceeded: boolean }> {\n const stepResults: StepResult[] = [];\n let accumulatedData: any = { ...data };\n let allSucceeded = true;\n\n for (let i = 0; i < steps.length; i++) {\n const stepDesc = steps[i];\n const stepNum = i + 1;\n\n console.log(`[TaskProcessor] Task ${taskId} — Step ${stepNum}/${steps.length}: ${stepDesc.slice(0, 80)}`);\n\n const stepResult = await executeStepWithRetry(\n taskId,\n stepNum,\n stepDesc,\n agentName,\n accumulatedData,\n );\n\n stepResults.push(stepResult);\n\n if (stepResult.status === \"success\") {\n // Merge step result into accumulated data for next step\n if (stepResult.result && typeof stepResult.result === \"object\") {\n accumulatedData = { ...accumulatedData, ...stepResult.result, previousStep: stepResult.result };\n }\n } else {\n allSucceeded = false;\n }\n }\n\n return {\n stepResults,\n finalData: accumulatedData,\n allSucceeded,\n };\n}\n\n/**\n * Execute a single-step task directly via the agent.\n */\nexport async function processSimpleTask(\n taskId: string,\n task: string,\n agentName: AgentName,\n data: any,\n): Promise<{ stepResults: StepResult[]; finalData: any; allSucceeded: boolean }> {\n const stepResult = await executeStepWithRetry(taskId, 1, task, agentName, data);\n return {\n stepResults: [stepResult],\n finalData: stepResult.result || {},\n allSucceeded: stepResult.status === \"success\",\n };\n}\n",[],[145,208],"85643b33-a430-4f62-923d-a4769a491e58","rpc.ts","06060d00-7961-11f1-b570-1607ee4eb77e",64,["D",1783360823988],"// JSON-RPC 2.0 Protocol Handler — Nexuses Core V3.1\n// Universal M2M protocol for machine-to-machine communication.\n// Async: \"execute\" method returns task_id instantly, client polls \"result\".\n\nimport { submitTask, processTaskById, getTaskResult, getSystemStatus } from \"./dispatcher.ts\";\nimport { registerNewSource, checkSource } from \"./verification.ts\";\nimport { listSources } from \"./db.ts\";\n\nexport interface JSONRPCRequest {\n jsonrpc: \"2.0\";\n method: string;\n params?: any;\n id?: string | number;\n}\n\nexport interface JSONRPCResponse {\n jsonrpc: \"2.0\";\n result?: any;\n error?: { code: number; message: string; data?: any };\n id: string | number | null;\n}\n\nconst RPC_ERRORS = {\n PARSE_ERROR: { code: -32700, message: \"Parse error\" },\n INVALID_REQUEST: { code: -32600, message: \"Invalid Request\" },\n METHOD_NOT_FOUND: { code: -32601, message: \"Method not found\" },\n INVALID_PARAMS: { code: -32602, message: \"Invalid params\" },\n INTERNAL_ERROR: { code: -32603, message: \"Internal error\" },\n VERIFICATION_FAILED: { code: -32001, message: \"Source verification failed\" },\n TASK_FAILED: { code: -32002, message: \"Task execution failed\" },\n};\n\nfunction rpcError(id: string | number | null, error: { code: number; message: string; data?: any }): JSONRPCResponse {\n return { jsonrpc: \"2.0\", error, id };\n}\n\nfunction rpcResult(id: string | number, result: any): JSONRPCResponse {\n return { jsonrpc: \"2.0\", result, id };\n}\n\n/**\n * Process a JSON-RPC 2.0 request.\n * Methods: execute (async), result, register, discover, status, verify, sources\n */\nexport async function processRPC(req: JSONRPCRequest): Promise {\n if (req.jsonrpc !== \"2.0\" || !req.method) {\n return rpcError(req.id ?? null, RPC_ERRORS.INVALID_REQUEST);\n }\n\n const params = req.params || {};\n const id = req.id ?? null;\n\n switch (req.method) {\n // ASYNC execute — returns task_id instantly, processing in background\n case \"execute\": {\n const { task, data, source_id } = params;\n if (!task) {\n return rpcError(id, { ...RPC_ERRORS.INVALID_PARAMS, data: \"Missing 'task' field\" });\n }\n if (!source_id) {\n return rpcError(id, { ...RPC_ERRORS.INVALID_PARAMS, data: \"Missing 'source_id' field\" });\n }\n try {\n const submitResponse = await submitTask(task, data || {}, source_id);\n if (submitResponse.status === \"failure\") {\n return rpcError(id, { ...RPC_ERRORS.VERIFICATION_FAILED, data: submitResponse });\n }\n // Fire background processing — do not await\n processTaskById(submitResponse.task_id).catch((e) => {\n console.error(`[RPC] Background processing error for ${submitResponse.task_id}:`, e.message);\n });\n return rpcResult(id as string | number, submitResponse);\n } catch (e: any) {\n return rpcError(id, { ...RPC_ERRORS.INTERNAL_ERROR, data: e.message });\n }\n }\n\n // Poll for result — returns current status of a task\n case \"result\": {\n const { task_id } = params;\n if (!task_id) {\n return rpcError(id, { ...RPC_ERRORS.INVALID_PARAMS, data: \"Missing 'task_id' field\" });\n }\n const result = await getTaskResult(task_id);\n return rpcResult(id as string | number, result);\n }\n\n case \"register\": {\n const { source_id, name, description } = params;\n if (!source_id || !name) {\n return rpcError(id, { ...RPC_ERRORS.INVALID_PARAMS, data: \"Missing 'source_id' or 'name'\" });\n }\n const result = await registerNewSource(source_id, name, description || \"\");\n return rpcResult(id as string | number, result);\n }\n\n case \"discover\": {\n const status = await getSystemStatus();\n return rpcResult(id as string | number, {\n service: \"Nexuses Core V3\",\n version: \"3.1.0\",\n protocol: \"JSON-RPC 2.0\",\n executionModel: \"Async — execute returns task_id, poll result for completion\",\n agents: status.agents,\n endpoints: status.endpoints,\n m2mFormat: {\n request: \"POST /rpc with JSON-RPC 2.0 body\",\n methods: [\"execute (async)\", \"result (poll)\", \"register\", \"discover\", \"status\", \"verify\", \"sources\"],\n },\n });\n }\n\n case \"status\": {\n const status = await getSystemStatus();\n return rpcResult(id as string | number, status);\n }\n\n case \"verify\": {\n const { source_id } = params;\n if (!source_id) {\n return rpcError(id, { ...RPC_ERRORS.INVALID_PARAMS, data: \"Missing 'source_id'\" });\n }\n const result = await checkSource(source_id);\n return rpcResult(id as string | number, result);\n }\n\n case \"sources\": {\n const sources = await listSources();\n return rpcResult(id as string | number, { sources });\n }\n\n default:\n return rpcError(id, {\n ...RPC_ERRORS.METHOD_NOT_FOUND,\n data: `Unknown method: ${req.method}. Supported: execute, result, register, discover, status, verify, sources`,\n });\n }\n}\n",[],[145,216],"21acd9ae-dd3a-4c31-8483-2ee3c91bfd8f","llm.ts","81b72098-7960-11f1-8bac-1607ee4eb77e",40,["D",1783359082410],"// Free LLM Engine — Nexuses Core V3\n// Uses Pollinations.ai EXCLUSIVELY — zero API keys, zero tokens, zero cost.\n// Provides: text generation, Chain-of-Thought reasoning, task classification.\n\nimport type { CoTAnalysis, TaskCategory, AgentName } from \"./types.ts\";\n\nconst POLLINATIONS_POST = \"https://text.pollinations.ai/openai\";\nconst POLLINATIONS_GET = \"https://text.pollinations.ai\";\nconst POLLINATIONS_IMAGE = \"https://image.pollinations.ai/prompt\";\n\nexport interface LLMResult {\n success: boolean;\n text: string;\n model: string;\n error?: string;\n}\n\nexport interface LLMOptions {\n maxTokens?: number;\n temperature?: number;\n timeoutMs?: number;\n systemPrompt?: string;\n}\n\n/**\n * Core LLM call — Pollinations.ai only (free, no key).\n * Tries POST (OpenAI-compatible) first, falls back to GET.\n */\nexport async function callLLM(\n prompt: string,\n options?: LLMOptions,\n): Promise {\n const messages: { role: string; content: string }[] = [];\n if (options?.systemPrompt) {\n messages.push({ role: \"system\", content: options.systemPrompt });\n }\n messages.push({ role: \"user\", content: prompt });\n\n // Attempt 1: POST (OpenAI-compatible endpoint)\n try {\n const res = await fetch(POLLINATIONS_POST, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n model: \"openai\",\n messages,\n max_tokens: options?.maxTokens ?? 1000,\n temperature: options?.temperature ?? 0.7,\n }),\n signal: AbortSignal.timeout(options?.timeoutMs ?? 30000),\n });\n if (res.ok) {\n const json = await res.json();\n const text = json.choices?.[0]?.message?.content?.trim();\n if (text) return { success: true, text, model: \"pollinations-openai\" };\n }\n } catch { /* fall through to GET */ }\n\n // Attempt 2: GET (simple text endpoint)\n try {\n const fullPrompt = options?.systemPrompt\n ? `${options.systemPrompt}\\n\\n${prompt}`\n : prompt;\n const encoded = encodeURIComponent(fullPrompt.slice(0, 2000));\n const res = await fetch(`${POLLINATIONS_GET}/${encoded}`, {\n signal: AbortSignal.timeout(options?.timeoutMs ?? 30000),\n });\n if (res.ok) {\n const text = (await res.text()).trim();\n if (text) return { success: true, text, model: \"pollinations-get\" };\n }\n } catch { /* fall through to failure */ }\n\n return {\n success: false,\n text: \"\",\n model: \"none\",\n error: \"Pollinations.ai endpoints unreachable\",\n };\n}\n\n/**\n * Chain-of-Thought reasoning + autonomous task classification.\n * Sends the task to the LLM with a structured CoT prompt and expects\n * a JSON response containing reasoning, category, agent, steps, and complexity.\n */\nexport async function reasonWithCoT(\n task: string,\n data?: any,\n): Promise<{ success: boolean; analysis: CoTAnalysis; raw: string; error?: string }> {\n const systemPrompt = `You are the Nexuses Core V3 Dispatcher — an autonomous AI reasoning brain.\nAnalyze the incoming task using chain-of-thought reasoning, then classify and route it.\nRespond with ONLY a JSON object — no markdown fences, no text outside the JSON:\n{\n \"reasoning\": \"Step-by-step chain-of-thought analysis of what this task requires\",\n \"category\": \"coding | scraping | analysis | media | marketing | general\",\n \"agent\": \"CoderAgent | ScraperAgent | AnalystAgent | MediaAgent | MarketingAgent | GeneralAgent\",\n \"steps\": [\"Step 1: description\", \"Step 2: description\"],\n \"complexity\": \"simple | complex\"\n}\n\nClassification guide:\n- coding → CoderAgent: writing, debugging, explaining, refactoring code in Python/JS/HTML/TS\n- scraping → ScraperAgent: web scraping, data extraction, website cloning, URL fetching\n- analysis → AnalystAgent: data analysis, Excel/CSV, reports, document processing, file analysis\n- media → MediaAgent: image generation, video plans, visual design, logos, art\n- marketing → MarketingAgent: content writing, blogging, social media, SEO, cross-platform formatting\n- general → GeneralAgent: questions, chat, explanations, reasoning, anything uncategorized\n\nIf a task spans multiple categories, pick the primary one and list multiple steps.`;\n\n const userPrompt = `Task: \"${task}\"\\nAdditional data: ${\n JSON.stringify(data || {}).slice(0, 800)\n }`;\n\n const result = await callLLM(userPrompt, {\n maxTokens: 800,\n temperature: 0.3,\n systemPrompt,\n timeoutMs: 25000,\n });\n\n if (!result.success) {\n // Fallback to keyword-based classification\n const fallback = keywordClassify(task);\n return {\n success: false,\n analysis: fallback,\n raw: \"\",\n error: result.error,\n };\n }\n\n // Parse JSON from LLM response\n try {\n let jsonStr = result.text.trim();\n // Strip markdown code fences if present\n jsonStr = jsonStr.replace(/```json\\s*/gi, \"\").replace(/```\\s*/g, \"\");\n const match = jsonStr.match(/\\{[\\s\\S]*\\}/);\n if (match) jsonStr = match[0];\n const parsed = JSON.parse(jsonStr);\n\n const validCategories: TaskCategory[] = [\n \"coding\", \"scraping\", \"analysis\", \"media\", \"marketing\", \"general\",\n ];\n const validAgents: AgentName[] = [\n \"CoderAgent\", \"ScraperAgent\", \"AnalystAgent\",\n \"MediaAgent\", \"MarketingAgent\", \"GeneralAgent\",\n ];\n\n const category = validCategories.includes(parsed.category)\n ? parsed.category\n : \"general\";\n const agent = validAgents.includes(parsed.agent)\n ? parsed.agent\n : \"GeneralAgent\";\n\n return {\n success: true,\n analysis: {\n reasoning: parsed.reasoning || \"No reasoning provided\",\n category,\n agent,\n steps: Array.isArray(parsed.steps) && parsed.steps.length > 0\n ? parsed.steps\n : [task],\n complexity: parsed.complexity === \"complex\" ? \"complex\" : \"simple\",\n },\n raw: result.text,\n };\n } catch {\n // JSON parse failed — use keyword fallback\n const fallback = keywordClassify(task);\n return {\n success: true,\n analysis: fallback,\n raw: result.text,\n };\n }\n}\n\n/**\n * Keyword-based fallback classifier (used when LLM is unavailable\n * or returns unparseable JSON).\n */\nfunction keywordClassify(task: string): CoTAnalysis {\n const lower = task.toLowerCase();\n const rules: { keywords: string[]; category: TaskCategory; agent: AgentName }[] = [\n {\n keywords: [\"code\", \"debug\", \"bug\", \"fix\", \"program\", \"function\", \"script\", \"python\", \"javascript\", \"html\", \"css\", \"typescript\", \"compile\", \"syntax\", \"refactor\"],\n category: \"coding\",\n agent: \"CoderAgent\",\n },\n {\n keywords: [\"scrape\", \"clone\", \"extract\", \"website\", \"url\", \"crawl\", \"fetch page\", \"web data\"],\n category: \"scraping\",\n agent: \"ScraperAgent\",\n },\n {\n keywords: [\"analyze\", \"analysis\", \"data\", \"excel\", \"csv\", \"report\", \"spreadsheet\", \"pdf\", \"document\", \"file\"],\n category: \"analysis\",\n agent: \"AnalystAgent\",\n },\n {\n keywords: [\"image\", \"generate image\", \"picture\", \"draw\", \"art\", \"logo\", \"video\", \"visual\", \"design\"],\n category: \"media\",\n agent: \"MediaAgent\",\n },\n {\n keywords: [\"write\", \"blog\", \"content\", \"social\", \"post\", \"seo\", \"marketing\", \"article\", \"tweet\", \"copy\"],\n category: \"marketing\",\n agent: \"MarketingAgent\",\n },\n ];\n\n for (const rule of rules) {\n if (rule.keywords.some((k) => lower.includes(k))) {\n return {\n reasoning: `Keyword fallback: matched \"${rule.category}\" category`,\n category: rule.category,\n agent: rule.agent,\n steps: [task],\n complexity: \"simple\",\n };\n }\n }\n\n return {\n reasoning: \"No keywords matched — defaulting to general\",\n category: \"general\",\n agent: \"GeneralAgent\",\n steps: [task],\n complexity: \"simple\",\n };\n}\n\n/**\n * Generate an image URL via Pollinations.ai image endpoint (free, no key).\n * Returns a direct URL to the generated image.\n */\nexport function generateImageURL(\n prompt: string,\n options?: { width?: number; height?: number; seed?: number; model?: string },\n): string {\n const params = new URLSearchParams();\n params.set(\"width\", String(options?.width ?? 1024));\n params.set(\"height\", String(options?.height ?? 1024));\n params.set(\"nologo\", \"true\");\n if (options?.seed) params.set(\"seed\", String(options.seed));\n if (options?.model) params.set(\"model\", options.model);\n const encoded = encodeURIComponent(prompt.slice(0, 500));\n return `${POLLINATIONS_IMAGE}/${encoded}?${params.toString()}`;\n}\n",[],[145,224],"c74aa7e4-6202-4f08-a6a4-0d726922e977","dispatcher.ts","fc1c35c6-7960-11f1-acba-1607ee4eb77e",62,["D",1783360766188],"// Central Dispatcher — Nexuses Core V3\n// The Autonomous Reasoning Brain — ASYNC EDITION\n// Flow: Submit (instant) → Background Process (CoT → Classify → Execute → Report)\n// POST /task returns immediately. GET /result?id= polls for completion.\n\nimport { reasonWithCoT } from \"./llm.ts\";\nimport { checkSource } from \"./verification.ts\";\nimport {\n getRecentTasks,\n getStats,\n getTask,\n getPendingTasks,\n initDB,\n insertTask,\n logEvent,\n remember,\n recall,\n updateTaskStatus,\n markProcessing,\n} from \"./db.ts\";\nimport { processComplexTask, processSimpleTask } from \"./taskProcessor.ts\";\nimport type {\n AgentName,\n DispatchResponse,\n StepResult,\n} from \"./types.ts\";\n\nfunction generateTaskId(): string {\n return `nxs3_${Date.now()}_${Math.random().toString(36).slice(2, 8)}`;\n}\n\n// ═══════════════════════════════════════════════════════════════\n// PHASE 1: SUBMIT — Instant DB save, return task_id immediately\n// ═══════════════════════════════════════════════════════════════\n\nexport interface SubmitResponse {\n status: \"accepted\" | \"failure\";\n task_id: string;\n source_id: string;\n verified: boolean;\n message: string;\n poll_endpoint: string;\n timestamp: string;\n}\n\nexport async function submitTask(\n task: string,\n data: any,\n sourceId: string,\n): Promise {\n const start = Date.now();\n const taskId = generateTaskId();\n\n await initDB();\n\n // SOURCE VERIFICATION — fast DB lookup, no LLM call\n const verification = await checkSource(sourceId);\n if (!verification.verified) {\n await logEvent(\"warn\", \"Dispatcher\", `Source verification failed: ${sourceId}`);\n return {\n status: \"failure\",\n task_id: taskId,\n source_id: sourceId,\n verified: false,\n message: verification.message,\n poll_endpoint: \"\",\n timestamp: new Date().toISOString(),\n };\n }\n\n // Save task to DB as 'pending' — NO CoT, NO agent execution here\n // The CoT reasoning + agent execution happens in processTaskById()\n await insertTask(\n taskId,\n sourceId,\n task,\n \"\", // agent — filled during processing\n \"\", // category — filled during processing\n \"pending\",\n \"\", // complexity — filled during processing\n \"\", // reasoning — filled during processing\n data,\n null,\n );\n\n await logEvent(\"info\", \"Dispatcher\",\n `Task ${taskId} accepted (pending) — source: ${sourceId} | submit: ${Date.now() - start}ms`,\n );\n\n return {\n status: \"accepted\",\n task_id: taskId,\n source_id: sourceId,\n verified: true,\n message: `Task accepted. Poll GET /result?id=${taskId} to check completion.`,\n poll_endpoint: `/result?id=${taskId}`,\n timestamp: new Date().toISOString(),\n };\n}\n\n// ═══════════════════════════════════════════════════════════════\n// PHASE 2: PROCESS — Background CoT + Agent Execution\n// Called fire-and-forget from main.ts, or by the worker interval.\n// ═══════════════════════════════════════════════════════════════\n\nexport async function processTaskById(taskId: string): Promise {\n const start = Date.now();\n\n await initDB();\n\n // Load task from DB\n const taskRecord = await getTask(taskId);\n if (!taskRecord) {\n await logEvent(\"error\", \"Dispatcher\", `processTaskById: task ${taskId} not found`);\n return;\n }\n\n if (taskRecord.status !== \"pending\") {\n // Already processed or being processed\n return;\n }\n\n // Atomically claim the task (prevents double-processing by worker)\n const claimed = await markProcessing(taskId);\n if (!claimed) {\n // Another process beat us to it\n return;\n }\n\n const task = taskRecord.task;\n let data: any = {};\n try {\n data = JSON.parse(taskRecord.data);\n } catch {\n data = {};\n }\n const sourceId = taskRecord.source_id;\n\n console.log(`[Dispatcher] Processing task ${taskId} — \"${task.slice(0, 80)}\"`);\n\n try {\n // CHAIN-OF-THOUGHT REASONING + CLASSIFICATION\n const cotResult = await reasonWithCoT(task, data);\n const analysis = cotResult.analysis;\n\n await logEvent(\"info\", \"Dispatcher\",\n `Task ${taskId} classified: ${analysis.category} → ${analysis.agent} | Complexity: ${analysis.complexity} | Steps: ${analysis.steps.length}`,\n );\n\n // Update task with CoT analysis (agent, category, reasoning, complexity)\n await updateTaskAnalysis(taskId, analysis.agent, analysis.category, analysis.reasoning, analysis.complexity);\n\n // EXECUTE — route to agent via task processor\n let stepResults: StepResult[];\n let finalData: any;\n let allSucceeded: boolean;\n\n if (analysis.complexity === \"complex\" && analysis.steps.length > 1) {\n console.log(`[Dispatcher] Task ${taskId} — Complex: ${analysis.steps.length} steps`);\n const result = await processComplexTask(taskId, analysis.steps, analysis.agent, data);\n stepResults = result.stepResults;\n finalData = result.finalData;\n allSucceeded = result.allSucceeded;\n } else {\n console.log(`[Dispatcher] Task ${taskId} — Simple: direct execution`);\n const result = await processSimpleTask(taskId, task, analysis.agent, data);\n stepResults = result.stepResults;\n finalData = result.finalData;\n allSucceeded = result.allSucceeded;\n }\n\n // REPORT — build structured response and save to DB\n const isSuccess = allSucceeded || stepResults.some((s) => s.status === \"success\");\n const response: DispatchResponse = {\n status: isSuccess ? \"success\" : \"failure\",\n task_id: taskId,\n source_id: sourceId,\n verified: true,\n reasoning: analysis.reasoning,\n category: analysis.category,\n agent: analysis.agent,\n steps: stepResults,\n data: finalData,\n message: isSuccess\n ? `Task completed by ${analysis.agent} (${stepResults.length} step${stepResults.length > 1 ? \"s\" : \"\"})`\n : `Task failed — all steps unsuccessful`,\n executionTimeMs: Date.now() - start,\n timestamp: new Date().toISOString(),\n };\n\n await updateTaskStatus(taskId, isSuccess ? \"completed\" : \"failed\", response);\n\n // Save to memory\n const memoryKey = `task:${analysis.category}:${analysis.agent}`;\n const priorMemory = await recall(memoryKey);\n await remember(memoryKey, {\n lastTask: task,\n lastAgent: analysis.agent,\n lastCategory: analysis.category,\n lastStatus: response.status,\n timestamp: new Date().toISOString(),\n ...(priorMemory ? { previous: priorMemory } : {}),\n });\n\n await logEvent(\"info\", \"Dispatcher\",\n `Task ${taskId} — ${response.status.toUpperCase()} | Agent: ${analysis.agent} | Time: ${response.executionTimeMs}ms`,\n );\n\n console.log(`[Dispatcher] Task ${taskId} complete — ${response.status} (${response.executionTimeMs}ms)`);\n } catch (e: any) {\n // Mark as failed with error\n const errorResponse: DispatchResponse = {\n status: \"failure\",\n task_id: taskId,\n source_id: sourceId,\n verified: true,\n reasoning: \"Processing error\",\n category: \"general\",\n agent: \"GeneralAgent\",\n steps: [],\n data: {},\n message: `Processing error: ${e.message}`,\n executionTimeMs: Date.now() - start,\n timestamp: new Date().toISOString(),\n };\n await updateTaskStatus(taskId, \"failed\", errorResponse);\n await logEvent(\"error\", \"Dispatcher\", `Task ${taskId} processing error: ${e.message}`);\n console.error(`[Dispatcher] Task ${taskId} error:`, e.message);\n }\n}\n\n/**\n * Update task with CoT analysis fields (agent, category, reasoning, complexity).\n */\nasync function updateTaskAnalysis(\n taskId: string,\n agent: string,\n category: string,\n reasoning: string,\n complexity: string,\n) {\n // We need a custom update since updateTaskStatus only sets status + result\n const { sqlite } = await import(\"https://esm.town/v/std/sqlite/main.ts\");\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `UPDATE nex_tasks SET agent = ?, category = ?, reasoning = ?, complexity = ?, updated_at = ? WHERE id = ?`,\n args: [agent, category, reasoning, complexity, now, taskId],\n });\n}\n\n// ═══════════════════════════════════════════════════════════════\n// PHASE 3: QUEUE DRAIN — Process all pending tasks (used by worker)\n// ═══════════════════════════════════════════════════════════════\n\nexport async function processPendingTasks(limit = 5): Promise<{ processed: number; results: { id: string; status: string }[] }> {\n await initDB();\n const pending = await getPendingTasks(limit);\n const results: { id: string; status: string }[] = [];\n\n for (const task of pending) {\n await processTaskById(task.id);\n const updated = await getTask(task.id);\n results.push({\n id: task.id,\n status: updated?.status || \"unknown\",\n });\n }\n\n if (pending.length > 0) {\n await logEvent(\"info\", \"Worker\", `Processed ${pending.length} pending task(s)`);\n }\n\n return { processed: pending.length, results };\n}\n\n// ═══════════════════════════════════════════════════════════════\n// RESULT POLLING — GET /result?id=xxx\n// ═══════════════════════════════════════════════════════════════\n\nexport interface ResultResponse {\n task_id: string;\n status: \"pending\" | \"processing\" | \"completed\" | \"failed\" | \"not_found\";\n message: string;\n result?: any;\n created_at?: string;\n updated_at?: string;\n}\n\nexport async function getTaskResult(taskId: string): Promise {\n await initDB();\n const task = await getTask(taskId);\n\n if (!task) {\n return {\n task_id: taskId,\n status: \"not_found\",\n message: \"Task not found — check the task_id\",\n };\n }\n\n let resultData: any = null;\n if (task.result) {\n try {\n resultData = JSON.parse(task.result);\n } catch {\n resultData = task.result;\n }\n }\n\n const statusMessages: Record = {\n pending: \"Task is queued — not yet started. Poll again shortly.\",\n processing: \"Task is currently being processed by an agent. Poll again in a few seconds.\",\n completed: \"Task completed successfully.\",\n failed: \"Task failed — see result data for details.\",\n };\n\n return {\n task_id: taskId,\n status: task.status as ResultResponse[\"status\"],\n message: statusMessages[task.status] || `Task status: ${task.status}`,\n result: resultData,\n created_at: task.created_at,\n updated_at: task.updated_at,\n };\n}\n\n// ── Status & Discovery ──\n\nexport async function getSystemStatus() {\n await initDB();\n const stats = await getStats();\n\n return {\n status: \"ONLINE\",\n service: \"Nexuses Core V3 — Autonomous AI Operating System\",\n version: \"3.1.0\",\n architecture: \"Open-Architecture · Async Task Queue · Zero API Keys\",\n llm: \"Pollinations.ai (free, no token required)\",\n imageGeneration: \"Pollinations.ai Image API (free, no token required)\",\n persistence: \"SQLite (project-scoped) + Blob VFS\",\n executionModel: \"Asynchronous — POST /task returns instantly, process in background\",\n stats: {\n totalTasks: stats.totalTasks,\n completedTasks: stats.completedTasks,\n failedTasks: stats.failedTasks,\n pendingTasks: stats.pendingTasks,\n processingTasks: stats.processingTasks,\n successRate: stats.totalTasks > 0\n ? `${Math.round((stats.completedTasks / stats.totalTasks) * 100)}%`\n : \"N/A\",\n registeredSources: stats.registeredSources,\n totalLogs: stats.totalLogs,\n },\n agents: [\n { name: \"CoderAgent\", category: \"coding\", capabilities: [\"write\", \"debug\", \"fix\", \"explain\", \"VFS read/write\"] },\n { name: \"ScraperAgent\", category: \"scraping\", capabilities: [\"scrape URL\", \"clone website\", \"web search (DuckDuckGo)\"] },\n { name: \"AnalystAgent\", category: \"analysis\", capabilities: [\"data analysis\", \"CSV generation\", \"report writing\", \"invoice generation\"] },\n { name: \"MediaAgent\", category: \"media\", capabilities: [\"image generation\", \"logo design\", \"video production plans\"] },\n { name: \"MarketingAgent\", category: \"marketing\", capabilities: [\"blog writing\", \"social media posts\", \"SEO\", \"cross-platform formatting\"] },\n { name: \"GeneralAgent\", category: \"general\", capabilities: [\"general Q&A\", \"reasoning\", \"fallback handler\"] },\n ],\n endpoints: {\n \"POST /task\": \"Submit task async — returns instantly with task_id (requires source_id)\",\n \"GET /result?id=\": \"Poll task status — pending → processing → completed/failed\",\n \"POST /register\": \"Register a new source\",\n \"POST /rpc\": \"JSON-RPC 2.0 endpoint (async execute method)\",\n \"GET /status\": \"System status dashboard\",\n \"GET /agents\": \"Agent manifest\",\n \"GET /task/:id\": \"Get raw task record by ID\",\n \"GET /history\": \"Recent task history\",\n \"GET /sources\": \"List registered sources\",\n \"GET /logs\": \"Recent system logs\",\n },\n m2mProtocol: \"JSON-RPC 2.0 / REST\",\n zeroConstraint: \"No API keys required — runs on 100% free open-source endpoints\",\n };\n}\n\nexport async function getHistory(limit = 20) {\n return getRecentTasks(limit);\n}\n",[],[145,232],"1d99820f-039f-44d3-ae07-4eb7cdeda956","db.ts","87d19a9e-7960-11f1-89b4-1607ee4eb77e",61,["D",1783360732401],2,"// SQLite Persistence Layer — Nexuses Core V3\n// Tables: tasks, steps, sources, memory, logs\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type { TaskRecord, SourceRecord, LogEntry } from \"./types.ts\";\n\nconst SCHEMA_SQL = [\n `CREATE TABLE IF NOT EXISTS nex_tasks (\n id TEXT PRIMARY KEY,\n source_id TEXT,\n task TEXT NOT NULL,\n agent TEXT,\n category TEXT,\n status TEXT NOT NULL,\n complexity TEXT,\n reasoning TEXT,\n data TEXT,\n result TEXT,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS nex_steps (\n id TEXT PRIMARY KEY,\n task_id TEXT NOT NULL,\n step INTEGER NOT NULL,\n description TEXT,\n agent TEXT,\n status TEXT,\n result TEXT,\n attempts INTEGER DEFAULT 1,\n created_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS nex_sources (\n source_id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n description TEXT,\n status TEXT DEFAULT 'active',\n created_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS nex_memory (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL,\n created_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS nex_logs (\n id TEXT PRIMARY KEY,\n level TEXT,\n component TEXT,\n message TEXT,\n created_at TEXT NOT NULL\n )`,\n];\n\nlet initialized = false;\n\nexport async function initDB() {\n if (initialized) return;\n await sqlite.batch(SCHEMA_SQL.map((sql) => ({ sql })));\n initialized = true;\n\n // Auto-register the internal trusted source\n await registerSource(\n \"nexuses-internal\",\n \"Nexuses Internal\",\n \"Built-in system source for self-testing\",\n );\n}\n\n// ── Task CRUD ──\n\nexport async function insertTask(\n id: string,\n sourceId: string,\n task: string,\n agent: string,\n category: string,\n status: string,\n complexity: string,\n reasoning: string,\n data: any,\n result: any,\n) {\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `INSERT INTO nex_tasks\n (id, source_id, task, agent, category, status, complexity, reasoning, data, result, created_at, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n id, sourceId, task, agent, category, status, complexity,\n reasoning, JSON.stringify(data), JSON.stringify(result), now, now,\n ],\n });\n}\n\nexport async function updateTaskStatus(id: string, status: string, result: any) {\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `UPDATE nex_tasks SET status = ?, result = ?, updated_at = ? WHERE id = ?`,\n args: [status, JSON.stringify(result), now, id],\n });\n}\n\nexport async function getTask(id: string): Promise {\n const res = await sqlite.execute({\n sql: `SELECT * FROM nex_tasks WHERE id = ?`,\n args: [id],\n });\n return (res.rows[0] as TaskRecord) || null;\n}\n\nexport async function getRecentTasks(limit = 20): Promise {\n const res = await sqlite.execute({\n sql: `SELECT * FROM nex_tasks ORDER BY created_at DESC LIMIT ?`,\n args: [limit],\n });\n return res.rows as TaskRecord[];\n}\n\nexport async function getTaskCount(): Promise {\n const res = await sqlite.execute(`SELECT COUNT(*) as count FROM nex_tasks`);\n return (res.rows[0] as any)?.count || 0;\n}\n\n// ── Async Queue Support ──\n\nexport async function getPendingTasks(limit = 10): Promise {\n const res = await sqlite.execute({\n sql: `SELECT * FROM nex_tasks WHERE status = 'pending' ORDER BY created_at ASC LIMIT ?`,\n args: [limit],\n });\n return res.rows as TaskRecord[];\n}\n\n/**\n * Atomically claim a task for processing.\n * Only succeeds if the task is still 'pending' — prevents double-processing.\n * Returns true if the claim was acquired.\n */\nexport async function markProcessing(id: string): Promise {\n const now = new Date().toISOString();\n const res = await sqlite.execute({\n sql: `UPDATE nex_tasks SET status = 'processing', updated_at = ? WHERE id = ? AND status = 'pending'`,\n args: [now, id],\n });\n return (res.rowsAffected ?? 0) > 0;\n}\n\nexport async function getPendingCount(): Promise {\n const res = await sqlite.execute(`SELECT COUNT(*) as count FROM nex_tasks WHERE status = 'pending'`);\n return (res.rows[0] as any)?.count || 0;\n}\n\n// ── Step Logging ──\n\nexport async function logStep(\n taskId: string,\n step: number,\n description: string,\n agent: string,\n status: string,\n result: any,\n attempts: number,\n) {\n const id = `step_${taskId}_${step}`;\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO nex_steps\n (id, task_id, step, description, agent, status, result, attempts, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n id, taskId, step, description, agent, status,\n JSON.stringify(result), attempts, now,\n ],\n });\n}\n\nexport async function getStepHistory(taskId: string) {\n const res = await sqlite.execute({\n sql: `SELECT * FROM nex_steps WHERE task_id = ? ORDER BY step ASC`,\n args: [taskId],\n });\n return res.rows;\n}\n\n// ── Source Registration ──\n\nexport async function registerSource(\n sourceId: string,\n name: string,\n description: string,\n): Promise {\n const now = new Date().toISOString();\n try {\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO nex_sources\n (source_id, name, description, status, created_at)\n VALUES (?, ?, ?, 'active', ?)`,\n args: [sourceId, name, description, now],\n });\n return true;\n } catch {\n return false;\n }\n}\n\nexport async function verifySource(sourceId: string): Promise {\n const res = await sqlite.execute({\n sql: `SELECT * FROM nex_sources WHERE source_id = ? AND status = 'active'`,\n args: [sourceId],\n });\n return (res.rows[0] as SourceRecord) || null;\n}\n\nexport async function listSources(): Promise {\n const res = await sqlite.execute(`SELECT * FROM nex_sources ORDER BY created_at DESC`);\n return res.rows as SourceRecord[];\n}\n\nexport async function removeSource(sourceId: string): Promise {\n try {\n await sqlite.execute({\n sql: `DELETE FROM nex_sources WHERE source_id = ?`,\n args: [sourceId],\n });\n return true;\n } catch {\n return false;\n }\n}\n\n// ── Memory ──\n\nexport async function remember(key: string, value: any) {\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO nex_memory (key, value, created_at) VALUES (?, ?, ?)`,\n args: [key, JSON.stringify(value), now],\n });\n}\n\nexport async function recall(key: string): Promise {\n const res = await sqlite.execute({\n sql: `SELECT * FROM nex_memory WHERE key = ?`,\n args: [key],\n });\n const row = res.rows[0] as any;\n return row ? JSON.parse(row.value) : null;\n}\n\n// ── System Logging ──\n\nexport async function logEvent(\n level: \"info\" | \"warn\" | \"error\",\n component: string,\n message: string,\n) {\n const id = `log_${Date.now()}_${Math.random().toString(36).slice(2, 8)}`;\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `INSERT INTO nex_logs (id, level, component, message, created_at) VALUES (?, ?, ?, ?, ?)`,\n args: [id, level, component, message, now],\n });\n}\n\nexport async function getRecentLogs(limit = 50): Promise {\n const res = await sqlite.execute({\n sql: `SELECT * FROM nex_logs ORDER BY created_at DESC LIMIT ?`,\n args: [limit],\n });\n return res.rows as LogEntry[];\n}\n\n// ── Stats ──\n\nexport async function getStats() {\n const taskCount = await getTaskCount();\n const sources = await listSources();\n const successRes = await sqlite.execute(\n `SELECT COUNT(*) as count FROM nex_tasks WHERE status = 'completed'`,\n );\n const failRes = await sqlite.execute(\n `SELECT COUNT(*) as count FROM nex_tasks WHERE status = 'failed'`,\n );\n const logRes = await sqlite.execute(\n `SELECT COUNT(*) as count FROM nex_logs`,\n );\n const pendingRes = await sqlite.execute(\n `SELECT COUNT(*) as count FROM nex_tasks WHERE status = 'pending'`,\n );\n const processingRes = await sqlite.execute(\n `SELECT COUNT(*) as count FROM nex_tasks WHERE status = 'processing'`,\n );\n return {\n totalTasks: taskCount,\n completedTasks: (successRes.rows[0] as any)?.count || 0,\n failedTasks: (failRes.rows[0] as any)?.count || 0,\n pendingTasks: (pendingRes.rows[0] as any)?.count || 0,\n processingTasks: (processingRes.rows[0] as any)?.count || 0,\n registeredSources: sources.length,\n totalLogs: (logRes.rows[0] as any)?.count || 0,\n };\n}\n",[],[145,240],["D",1783359042499],[174,175,176,177,178,179,180],[145],"df0030fc-29ab-46c6-87f6-471d4d6058a5","scraperAgent.ts","a79a834a-7960-11f1-84c2-1607ee4eb77e",43,["D",1783359146056],"// ScraperAgent — Nexuses Core V3\n// Browser-less web scraping: fetch + HTML parsing, DuckDuckGo search.\n// No Playwright, no browser dependencies — pure fetch-based extraction.\n\nimport { callLLM } from \"../lib/llm.ts\";\nimport type { AgentResult } from \"../lib/types.ts\";\n\n/**\n * Extract text content from HTML using regex (no external parser needed).\n * Lightweight Cheerio-free extraction.\n */\nfunction extractFromHTML(html: string) {\n // Title\n const titleMatch = html.match(/]*>(.*?)<\\/title>/is);\n const title = titleMatch ? titleMatch[1].trim() : \"Untitled\";\n\n // Meta description\n const metaMatch = html.match(/]+name=[\"']description[\"'][^>]+content=[\"']([^\"']*)/is);\n const description = metaMatch ? metaMatch[1].trim() : \"\";\n\n // Remove scripts and styles\n const clean = html\n .replace(//gi, \"\")\n .replace(//gi, \"\")\n .replace(//gi, \"\")\n .replace(//gi, \"\");\n\n // Extract text (strip all tags)\n const textContent = clean\n .replace(/<[^>]+>/g, \" \")\n .replace(/ /g, \" \")\n .replace(/&/g, \"&\")\n .replace(/</g, \"<\")\n .replace(/>/g, \">\")\n .replace(/"/g, '\"')\n .replace(/'/g, \"'\")\n .replace(/\\s+/g, \" \")\n .trim()\n .slice(0, 5000);\n\n // Extract links\n const linkRegex = /]+href=[\"']([^\"'#]+)[\"'][^>]*>(.*?)<\\/a>/gis;\n const links: { url: string; text: string }[] = [];\n let match;\n let count = 0;\n while ((match = linkRegex.exec(html)) !== null && count < 30) {\n const url = match[1].trim();\n const linkText = match[2].replace(/<[^>]+>/g, \"\").trim();\n if (url.startsWith(\"http\") && linkText.length > 0) {\n links.push({ url, text: linkText });\n count++;\n }\n }\n\n // Extract images\n const imgRegex = /]+src=[\"']([^\"']+)[\"']/gi;\n const images: string[] = [];\n let imgMatch;\n let imgCount = 0;\n while ((imgMatch = imgRegex.exec(html)) !== null && imgCount < 10) {\n const src = imgMatch[1].trim();\n if (src.startsWith(\"http\")) {\n images.push(src);\n imgCount++;\n }\n }\n\n // Extract headings\n const headings: string[] = [];\n const hRegex = /]*>(.*?)<\\/h[1-3]>/gis;\n let hMatch;\n let hCount = 0;\n while ((hMatch = hRegex.exec(clean)) !== null && hCount < 15) {\n const hText = hMatch[1].replace(/<[^>]+>/g, \"\").trim();\n if (hText.length > 2) {\n headings.push(hText);\n hCount++;\n }\n }\n\n return { title, description, textContent, links, images, headings };\n}\n\nasync function scrapeURL(url: string) {\n const res = await fetch(url, {\n headers: {\n \"User-Agent\": \"Mozilla/5.0 (compatible; NexusesCore/3.0; +https://val.town)\",\n \"Accept\": \"text/html,application/xhtml+xml\",\n },\n signal: AbortSignal.timeout(15000),\n });\n\n if (!res.ok) {\n throw new Error(`HTTP ${res.status} from ${url}`);\n }\n\n const html = await res.text();\n return extractFromHTML(html);\n}\n\nasync function searchWeb(query: string) {\n // DuckDuckGo Instant Answer API (free, no key)\n const ddgUrl = `https://api.duckduckgo.com/?q=${\n encodeURIComponent(query)\n }&format=json&no_html=1&skip_disambig=1`;\n\n const res = await fetch(ddgUrl, {\n signal: AbortSignal.timeout(10000),\n });\n\n if (!res.ok) {\n throw new Error(`DuckDuckGo HTTP ${res.status}`);\n }\n\n const data = await res.json();\n const results: any = {\n query,\n abstract: data.Abstract || \"\",\n abstractSource: data.AbstractSource || \"\",\n abstractURL: data.AbstractURL || \"\",\n answer: data.Answer || \"\",\n definition: data.Definition || \"\",\n relatedTopics: [] as any[],\n };\n\n // Extract related topics\n if (data.RelatedTopics && Array.isArray(data.RelatedTopics)) {\n for (const topic of data.RelatedTopics.slice(0, 10)) {\n if (topic.Text) {\n results.relatedTopics.push({\n text: topic.Text,\n url: topic.FirstURL || \"\",\n });\n } else if (topic.Topics && Array.isArray(topic.Topics)) {\n for (const sub of topic.Topics.slice(0, 3)) {\n if (sub.Text) {\n results.relatedTopics.push({\n text: sub.Text,\n url: sub.FirstURL || \"\",\n });\n }\n }\n }\n }\n }\n\n return results;\n}\n\nexport async function execute(task: string, data: any): Promise {\n const start = Date.now();\n const action = data.action || \"scrape\";\n const url = data.url || \"\";\n const query = data.query || data.q || task;\n\n try {\n // Action: scrape a specific URL\n if (action === \"scrape\" || action === \"clone\" || url) {\n if (!url) {\n return {\n agent: \"ScraperAgent\",\n category: \"scraping\",\n status: \"error\",\n message: \"No URL provided for scraping\",\n data: {},\n executionTimeMs: Date.now() - start,\n };\n }\n\n const scraped = await scrapeURL(url);\n\n if (action === \"clone\") {\n // Use LLM to generate a clean HTML clone based on scraped content\n const llmResult = await callLLM(\n `Create a clean, modern HTML page based on this scraped content:\\n` +\n `Title: ${scraped.title}\\n` +\n `Headings: ${scraped.headings.join(\", \")}\\n` +\n `Content: ${scraped.textContent.slice(0, 1500)}\\n\\n` +\n `Return only the HTML code, no explanation.`,\n { maxTokens: 1500, temperature: 0.5 },\n );\n\n return {\n agent: \"ScraperAgent\",\n category: \"scraping\",\n status: llmResult.success ? \"success\" : \"partial\",\n message: `Website cloned: ${scraped.title}`,\n data: {\n original: { url, title: scraped.title, description: scraped.description },\n clone: llmResult.text || \"Clone generation failed\",\n links: scraped.links,\n images: scraped.images,\n },\n executionTimeMs: Date.now() - start,\n };\n }\n\n return {\n agent: \"ScraperAgent\",\n category: \"scraping\",\n status: \"success\",\n message: `Scraped: ${scraped.title}`,\n data: scraped,\n executionTimeMs: Date.now() - start,\n };\n }\n\n // Action: web search\n if (action === \"search\" || action === \"research\") {\n const searchResults = await searchWeb(query);\n\n // Use LLM to summarize search results\n const llmResult = await callLLM(\n `Summarize these search results for query \"${query}\":\\n` +\n `Abstract: ${searchResults.abstract}\\n` +\n `Answer: ${searchResults.answer}\\n` +\n `Related: ${searchResults.relatedTopics.map((t: any) => t.text).join(\"; \").slice(0, 1000)}\\n\\n` +\n `Provide a concise summary with key findings.`,\n { maxTokens: 500, temperature: 0.4 },\n );\n\n return {\n agent: \"ScraperAgent\",\n category: \"scraping\",\n status: \"success\",\n message: `Search completed for: \"${query}\"`,\n data: {\n search: searchResults,\n summary: llmResult.text || \"Summary unavailable\",\n },\n executionTimeMs: Date.now() - start,\n };\n }\n\n // Default: try to extract URL from task text\n const urlMatch = task.match(/https?:\\/\\/[^\\s]+/);\n if (urlMatch) {\n const scraped = await scrapeURL(urlMatch[0]);\n return {\n agent: \"ScraperAgent\",\n category: \"scraping\",\n status: \"success\",\n message: `Scraped: ${scraped.title}`,\n data: scraped,\n executionTimeMs: Date.now() - start,\n };\n }\n\n // Fallback: treat as search query\n const searchResults = await searchWeb(query);\n return {\n agent: \"ScraperAgent\",\n category: \"scraping\",\n status: \"success\",\n message: `Search completed for: \"${query}\"`,\n data: searchResults,\n executionTimeMs: Date.now() - start,\n };\n } catch (e: any) {\n return {\n agent: \"ScraperAgent\",\n category: \"scraping\",\n status: \"error\",\n message: `Scraping failed: ${e.message}`,\n data: { error: e.message },\n executionTimeMs: Date.now() - start,\n };\n }\n}\n",[],[152,252],"52018289-2c9b-43fc-b0a7-c5919564782e","mediaAgent.ts","c45dd16c-7960-11f1-a65f-1607ee4eb77e",46,["D",1783359194339],"// MediaAgent — Nexuses Core V3\n// Image generation via Pollinations.ai (free, no API key).\n// Video production plans via LLM.\n\nimport { callLLM, generateImageURL } from \"../lib/llm.ts\";\nimport type { AgentResult } from \"../lib/types.ts\";\n\nexport async function execute(task: string, data: any): Promise {\n const start = Date.now();\n const action = data.action || \"image\";\n const prompt = data.prompt || task;\n const width = data.width || 1024;\n const height = data.height || 1024;\n const seed = data.seed || Math.floor(Math.random() * 1000000);\n\n try {\n if (action === \"image\" || action === \"generate\") {\n // Enhance prompt with LLM for better image generation\n const enhanceResult = await callLLM(\n `Enhance this image generation prompt with visual details (style, lighting, composition, mood).\\n` +\n `Original: \"${prompt}\"\\nReturn ONLY the enhanced prompt, nothing else.`,\n { maxTokens: 200, temperature: 0.7 },\n );\n\n const finalPrompt = enhanceResult.success ? enhanceResult.text : prompt;\n const imageURL = generateImageURL(finalPrompt, { width, height, seed });\n\n return {\n agent: \"MediaAgent\",\n category: \"media\",\n status: \"success\",\n message: `Image generated for: ${prompt.slice(0, 80)}`,\n data: {\n action: \"image\",\n prompt: finalPrompt,\n originalPrompt: prompt,\n imageURL,\n width,\n height,\n seed,\n note: \"URL returns the generated image directly — use it in tags or download\",\n },\n executionTimeMs: Date.now() - start,\n };\n }\n\n if (action === \"video\" || action === \"video-plan\") {\n // Generate a video production plan (text-based, no actual video rendering)\n const llmResult = await callLLM(\n `Create a detailed video production plan for: ${prompt}\\n` +\n `Include:\\n` +\n `- Concept summary\\n` +\n `- Scene-by-scene breakdown (at least 5 scenes)\\n` +\n `- Visual style and color palette\\n` +\n `- Audio/music suggestions\\n` +\n `- Estimated duration per scene\\n` +\n `- Technical notes (aspect ratio, resolution, transitions)`,\n { maxTokens: 800, temperature: 0.6 },\n );\n\n return {\n agent: \"MediaAgent\",\n category: \"media\",\n status: llmResult.success ? \"success\" : \"error\",\n message: llmResult.success ? \"Video production plan generated\" : \"Video plan failed — LLM unavailable\",\n data: {\n action: \"video-plan\",\n prompt,\n plan: llmResult.text || \"\",\n },\n executionTimeMs: Date.now() - start,\n };\n }\n\n if (action === \"logo\") {\n // Logo generation via Pollinations\n const logoPrompt = `minimalist professional logo design, ${prompt}, vector style, clean, modern, centered, simple colors`;\n const logoURL = generateImageURL(logoPrompt, {\n width: 512,\n height: 512,\n seed,\n });\n\n return {\n agent: \"MediaAgent\",\n category: \"media\",\n status: \"success\",\n message: `Logo generated for: ${prompt.slice(0, 60)}`,\n data: {\n action: \"logo\",\n prompt: logoPrompt,\n logoURL,\n size: \"512x512\",\n seed,\n },\n executionTimeMs: Date.now() - start,\n };\n }\n\n // Default: treat as image generation\n const imageURL = generateImageURL(prompt, { width, height, seed });\n return {\n agent: \"MediaAgent\",\n category: \"media\",\n status: \"success\",\n message: `Image generated for: ${prompt.slice(0, 80)}`,\n data: {\n action: \"image\",\n prompt,\n imageURL,\n width,\n height,\n seed,\n },\n executionTimeMs: Date.now() - start,\n };\n } catch (e: any) {\n return {\n agent: \"MediaAgent\",\n category: \"media\",\n status: \"error\",\n message: `Media error: ${e.message}`,\n data: { error: e.message },\n executionTimeMs: Date.now() - start,\n };\n }\n}\n",[],[152,260],"105f8c56-3b2c-4cdf-9e07-cf79b1ccfc01","marketingAgent.ts","cd8fc754-7960-11f1-84c2-1607ee4eb77e",47,["D",1783359209763],"// MarketingAgent — Nexuses Core V3\n// Content creation, blogging, social media, SEO, cross-platform formatting.\n\nimport { callLLM } from \"../lib/llm.ts\";\nimport type { AgentResult } from \"../lib/types.ts\";\n\n/**\n * Platform-specific formatting rules.\n */\nconst PLATFORM_RULES: Record = {\n twitter: { maxLength: 280, hashtags: true, tone: \"punchy, conversational\" },\n linkedin: { maxLength: 3000, hashtags: true, tone: \"professional, insightful\" },\n facebook: { maxLength: 5000, hashtags: true, tone: \"friendly, engaging\" },\n instagram: { maxLength: 2200, hashtags: true, tone: \"visual, aspirational\" },\n blog: { maxLength: 10000, hashtags: false, tone: \"informative, structured\" },\n email: { maxLength: 5000, hashtags: false, tone: \"personal, direct\" },\n};\n\nexport async function execute(task: string, data: any): Promise {\n const start = Date.now();\n const action = data.action || \"write\";\n const topic = data.topic || data.prompt || task;\n const platform = (data.platform || \"\").toLowerCase();\n const audience = data.audience || \"general audience\";\n const tone = data.tone || \"professional\";\n\n try {\n if (action === \"blog\") {\n const llmResult = await callLLM(\n `Write a comprehensive blog post about: ${topic}\\n` +\n `Target audience: ${audience}\\nTone: ${tone}\\n\\n` +\n `Format:\\n# [Title]\\n## Introduction\\n[2-3 paragraphs]\\n` +\n `## [Section 1]\\n## [Section 2]\\n## [Section 3]\\n` +\n `## Conclusion\\n\\nInclude engaging headings and actionable insights.`,\n { maxTokens: 1500, temperature: 0.7 },\n );\n\n return {\n agent: \"MarketingAgent\",\n category: \"marketing\",\n status: llmResult.success ? \"success\" : \"error\",\n message: llmResult.success ? \"Blog post generated\" : \"Blog generation failed — LLM unavailable\",\n data: {\n action: \"blog\",\n topic,\n content: llmResult.text || \"\",\n wordCount: llmResult.text?.split(/\\s+/).length || 0,\n },\n executionTimeMs: Date.now() - start,\n };\n }\n\n if (action === \"social\" || platform) {\n const rules = PLATFORM_RULES[platform] || PLATFORM_RULES[\"twitter\"];\n\n const llmResult = await callLLM(\n `Write a ${platform || \"social media\"} post about: ${topic}\\n` +\n `Tone: ${rules.tone}\\n` +\n `Maximum ${rules.maxLength} characters.\\n` +\n `${rules.hashtags ? \"Include 3-5 relevant hashtags.\" : \"No hashtags.\"}\\n` +\n `Return ONLY the post text.`,\n { maxTokens: 400, temperature: 0.8 },\n );\n\n const postText = llmResult.text || \"\";\n const charCount = postText.length;\n\n return {\n agent: \"MarketingAgent\",\n category: \"marketing\",\n status: llmResult.success ? \"success\" : \"error\",\n message: llmResult.success\n ? `${platform || \"Social\"} post generated (${charCount} chars)`\n : \"Social post generation failed\",\n data: {\n action: \"social\",\n platform: platform || \"general\",\n content: postText,\n characterCount: charCount,\n maxLength: rules.maxLength,\n withinLimit: charCount <= rules.maxLength,\n },\n executionTimeMs: Date.now() - start,\n };\n }\n\n if (action === \"seo\") {\n const llmResult = await callLLM(\n `Provide SEO recommendations for: ${topic}\\n` +\n `Include:\\n` +\n `- Primary keyword and 10 long-tail keywords\\n` +\n `- Meta title (60 chars max)\\n` +\n `- Meta description (160 chars max)\\n` +\n `- URL slug suggestion\\n` +\n `- 5 header (H2) suggestions\\n` +\n `- Content gap analysis`,\n { maxTokens: 600, temperature: 0.4 },\n );\n\n return {\n agent: \"MarketingAgent\",\n category: \"marketing\",\n status: llmResult.success ? \"success\" : \"error\",\n message: llmResult.success ? \"SEO analysis generated\" : \"SEO analysis failed\",\n data: {\n action: \"seo\",\n topic,\n recommendations: llmResult.text || \"\",\n },\n executionTimeMs: Date.now() - start,\n };\n }\n\n if (action === \"reformat\" || action === \"cross-platform\") {\n const content = data.content || \"\";\n const targetPlatform = (data.targetPlatform || \"twitter\").toLowerCase();\n const rules = PLATFORM_RULES[targetPlatform] || PLATFORM_RULES[\"twitter\"];\n\n const llmResult = await callLLM(\n `Reformat this content for ${targetPlatform}:\\n\\n${content.slice(0, 2000)}\\n\\n` +\n `Tone: ${rules.tone}\\nMax ${rules.maxLength} characters.\\n` +\n `${rules.hashtags ? \"Add relevant hashtags.\" : \"No hashtags.\"}\\n` +\n `Return ONLY the reformatted content.`,\n { maxTokens: 500, temperature: 0.6 },\n );\n\n return {\n agent: \"MarketingAgent\",\n category: \"marketing\",\n status: llmResult.success ? \"success\" : \"error\",\n message: llmResult.success\n ? `Content reformatted for ${targetPlatform}`\n : \"Reformatting failed\",\n data: {\n action: \"reformat\",\n targetPlatform,\n original: content.slice(0, 500),\n reformatted: llmResult.text || \"\",\n characterCount: llmResult.text?.length || 0,\n },\n executionTimeMs: Date.now() - start,\n };\n }\n\n // Default: general content writing\n const llmResult = await callLLM(\n `Write engaging content about: ${topic}\\n` +\n `Audience: ${audience}\\nTone: ${tone}\\n` +\n `Make it compelling and well-structured.`,\n { maxTokens: 1000, temperature: 0.7 },\n );\n\n return {\n agent: \"MarketingAgent\",\n category: \"marketing\",\n status: llmResult.success ? \"success\" : \"error\",\n message: llmResult.success ? \"Content generated\" : \"Content generation failed — LLM unavailable\",\n data: {\n action: \"write\",\n topic,\n content: llmResult.text || \"\",\n },\n executionTimeMs: Date.now() - start,\n };\n } catch (e: any) {\n return {\n agent: \"MarketingAgent\",\n category: \"marketing\",\n status: \"error\",\n message: `Marketing error: ${e.message}`,\n data: { error: e.message },\n executionTimeMs: Date.now() - start,\n };\n }\n}\n",[],[152,268],"f0dc46c4-47ac-4070-af62-23eb3f40db1b","coderAgent.ts","b7accf72-7960-11f1-acba-1607ee4eb77e",44,["D",1783359173043],"// CoderAgent — Nexuses Core V3\n// Writes, debugs, and explains code in Python/JS/TS/HTML/CSS.\n// Uses a virtual file system via blob storage for persistent code files.\n\nimport { callLLM } from \"../lib/llm.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport type { AgentResult } from \"../lib/types.ts\";\n\nconst VFS_PREFIX = \"vfs/\";\n\n/**\n * Virtual File System — store/retrieve code files in blob storage.\n */\nasync function vfsWrite(filename: string, content: string) {\n await blob.setJSON(`${VFS_PREFIX}${filename}`, {\n filename,\n content,\n updatedAt: new Date().toISOString(),\n });\n}\n\nasync function vfsRead(filename: string): Promise {\n const data = await blob.getJSON(`${VFS_PREFIX}${filename}`);\n return data?.content ?? null;\n}\n\nasync function vfsList() {\n const entries = await blob.list(VFS_PREFIX);\n return entries.map((e) => e.key.replace(VFS_PREFIX, \"\"));\n}\n\n/**\n * Detect language from task or data.\n */\nfunction detectLanguage(task: string, data: any): string {\n if (data.language) return data.language;\n const lower = task.toLowerCase();\n if (lower.includes(\"python\") || lower.includes(\".py\")) return \"python\";\n if (lower.includes(\"typescript\") || lower.includes(\".ts\")) return \"typescript\";\n if (lower.includes(\"html\")) return \"html\";\n if (lower.includes(\"css\")) return \"css\";\n if (lower.includes(\"javascript\") || lower.includes(\".js\") || lower.includes(\"js\")) return \"javascript\";\n return \"javascript\";\n}\n\nexport async function execute(task: string, data: any): Promise {\n const start = Date.now();\n const action = data.action || \"write\";\n const language = detectLanguage(task, data);\n const code = data.code || data.snippet || \"\";\n const filename = data.filename || `generated.${language === \"python\" ? \"py\" : language === \"typescript\" ? \"ts\" : language === \"html\" ? \"html\" : language === \"css\" ? \"css\" : \"js\"}`;\n\n try {\n if (action === \"debug\" || action === \"fix\") {\n // Debug/fix existing code\n const llmResult = await callLLM(\n `Find and fix all bugs in this ${language} code:\\n\\n${code}\\n\\n` +\n `Return ONLY the corrected code with inline comments explaining each fix.`,\n { maxTokens: 1200, temperature: 0.2 },\n );\n\n if (llmResult.success) {\n await vfsWrite(filename, llmResult.text);\n }\n\n return {\n agent: \"CoderAgent\",\n category: \"coding\",\n status: llmResult.success ? \"success\" : \"error\",\n message: llmResult.success ? `Code debugged and saved to VFS:/${filename}` : \"Debug failed — LLM unavailable\",\n data: {\n action: \"debug\",\n language,\n filename,\n original: code.slice(0, 500),\n fixed: llmResult.text || \"\",\n },\n executionTimeMs: Date.now() - start,\n };\n }\n\n if (action === \"explain\") {\n // Explain existing code\n const llmResult = await callLLM(\n `Explain this ${language} code in detail:\\n\\n${code}\\n\\n` +\n `Cover: purpose, key functions, logic flow, and any potential issues.`,\n { maxTokens: 800, temperature: 0.4 },\n );\n\n return {\n agent: \"CoderAgent\",\n category: \"coding\",\n status: llmResult.success ? \"success\" : \"error\",\n message: llmResult.success ? \"Code explained\" : \"Explanation failed — LLM unavailable\",\n data: {\n action: \"explain\",\n language,\n code: code.slice(0, 500),\n explanation: llmResult.text || \"\",\n },\n executionTimeMs: Date.now() - start,\n };\n }\n\n if (action === \"read\") {\n // Read from VFS\n const content = await vfsRead(filename);\n if (content) {\n return {\n agent: \"CoderAgent\",\n category: \"coding\",\n status: \"success\",\n message: `Read VFS:/${filename}`,\n data: { action: \"read\", filename, content },\n executionTimeMs: Date.now() - start,\n };\n }\n return {\n agent: \"CoderAgent\",\n category: \"coding\",\n status: \"error\",\n message: `File not found in VFS: ${filename}`,\n data: {},\n executionTimeMs: Date.now() - start,\n };\n }\n\n if (action === \"list\") {\n const files = await vfsList();\n return {\n agent: \"CoderAgent\",\n category: \"coding\",\n status: \"success\",\n message: `VFS contains ${files.length} files`,\n data: { action: \"list\", files },\n executionTimeMs: Date.now() - start,\n };\n }\n\n // Default action: write new code\n const prompt = data.prompt || task;\n const llmResult = await callLLM(\n `Write ${language} code for the following task:\\n${prompt}\\n\\n` +\n `Return ONLY the code with comments. No explanation outside the code.`,\n { maxTokens: 1200, temperature: 0.3 },\n );\n\n if (llmResult.success) {\n await vfsWrite(filename, llmResult.text);\n }\n\n return {\n agent: \"CoderAgent\",\n category: \"coding\",\n status: llmResult.success ? \"success\" : \"error\",\n message: llmResult.success\n ? `Code written in ${language} and saved to VFS:/${filename}`\n : \"Code generation failed — LLM unavailable\",\n data: {\n action: \"write\",\n language,\n filename,\n code: llmResult.text || \"\",\n vfsPath: `VFS:/${filename}`,\n },\n executionTimeMs: Date.now() - start,\n };\n } catch (e: any) {\n return {\n agent: \"CoderAgent\",\n category: \"coding\",\n status: \"error\",\n message: `Coder error: ${e.message}`,\n data: { error: e.message },\n executionTimeMs: Date.now() - start,\n };\n }\n}\n",[],[152,276],"78adf795-1387-438a-b18d-1707e9fb46ab","analystAgent.ts","c0bbf124-7960-11f1-84c2-1607ee4eb77e",45,["D",1783359188236],"// AnalystAgent — Nexuses Core V3\n// Data analysis, CSV/Excel generation, report building, file analysis.\n// Uses LLM for analytical reasoning + structured data output.\n\nimport { callLLM } from \"../lib/llm.ts\";\nimport type { AgentResult } from \"../lib/types.ts\";\n\n/**\n * Parse CSV text into structured rows.\n */\nfunction parseCSV(text: string): string[][] {\n const rows: string[][] = [];\n const lines = text.trim().split(\"\\n\");\n for (const line of lines) {\n const cells: string[] = [];\n let current = \"\";\n let inQuotes = false;\n for (let i = 0; i < line.length; i++) {\n const ch = line[i];\n if (ch === '\"') {\n inQuotes = !inQuotes;\n } else if (ch === \",\" && !inQuotes) {\n cells.push(current.trim());\n current = \"\";\n } else {\n current += ch;\n }\n }\n cells.push(current.trim());\n rows.push(cells);\n }\n return rows;\n}\n\n/**\n * Convert array of objects to CSV string.\n */\nfunction toCSV(data: Record[]): string {\n if (!data.length) return \"\";\n const headers = Object.keys(data[0]);\n const lines = [headers.join(\",\")];\n for (const row of data) {\n lines.push(headers.map((h) => `\"${String(row[h] ?? \"\").replace(/\"/g, '\"\"')}\"`).join(\",\"));\n }\n return lines.join(\"\\n\");\n}\n\nexport async function execute(task: string, data: any): Promise {\n const start = Date.now();\n const action = data.action || \"analyze\";\n const prompt = data.prompt || task;\n\n try {\n // CSV generation\n if (action === \"csv\" || action === \"excel\") {\n const llmResult = await callLLM(\n `Generate tabular data in CSV format for: ${prompt}\\n` +\n `Include appropriate headers and at least 5 sample rows.\\n` +\n `Return ONLY the CSV text, no explanation.`,\n { maxTokens: 600, temperature: 0.3 },\n );\n\n const csvText = llmResult.text || \"\";\n const parsed = parseCSV(csvText);\n\n return {\n agent: \"AnalystAgent\",\n category: \"analysis\",\n status: llmResult.success ? \"success\" : \"error\",\n message: llmResult.success ? `CSV generated with ${parsed.length} rows` : \"CSV generation failed\",\n data: {\n action: \"csv\",\n csv: csvText,\n rows: parsed,\n headers: parsed[0] || [],\n rowCount: parsed.length - 1,\n },\n executionTimeMs: Date.now() - start,\n };\n }\n\n // Report generation\n if (action === \"report\") {\n const llmResult = await callLLM(\n `Create a structured analytical report for: ${prompt}\\n` +\n `Format as:\\n## Executive Summary\\n## Key Findings\\n## Data Analysis\\n## Recommendations\\n\\n` +\n `Be thorough and data-driven.`,\n { maxTokens: 1000, temperature: 0.5 },\n );\n\n return {\n agent: \"AnalystAgent\",\n category: \"analysis\",\n status: llmResult.success ? \"success\" : \"error\",\n message: llmResult.success ? \"Report generated\" : \"Report generation failed\",\n data: {\n action: \"report\",\n topic: prompt,\n report: llmResult.text || \"\",\n },\n executionTimeMs: Date.now() - start,\n };\n }\n\n // File/data analysis (parse provided data)\n if (action === \"analyze\" && (data.data || data.text || data.csv)) {\n const input = data.data || data.text || data.csv;\n const inputStr = typeof input === \"string\" ? input : JSON.stringify(input);\n\n const llmResult = await callLLM(\n `Analyze this data and provide insights:\\n\\n${inputStr.slice(0, 2000)}\\n\\n` +\n `Provide: key patterns, anomalies, statistics, and recommendations.`,\n { maxTokens: 800, temperature: 0.4 },\n );\n\n return {\n agent: \"AnalystAgent\",\n category: \"analysis\",\n status: llmResult.success ? \"success\" : \"error\",\n message: llmResult.success ? \"Data analysis completed\" : \"Analysis failed — LLM unavailable\",\n data: {\n action: \"analyze\",\n input: inputStr.slice(0, 500),\n analysis: llmResult.text || \"\",\n },\n executionTimeMs: Date.now() - start,\n };\n }\n\n // Invoice/billing generation\n if (action === \"invoice\") {\n const llmResult = await callLLM(\n `Generate a professional invoice in JSON format for: ${prompt}\\n` +\n `Include: invoiceNumber, date, billTo, items[{description, quantity, unitPrice, total}], subtotal, tax, total.\\n` +\n `Return ONLY the JSON.`,\n { maxTokens: 500, temperature: 0.3 },\n );\n\n let invoice: any = null;\n try {\n const jsonStr = llmResult.text?.replace(/```json\\s*/g, \"\").replace(/```\\s*/g, \"\");\n const match = jsonStr?.match(/\\{[\\s\\S]*\\}/);\n if (match) invoice = JSON.parse(match[0]);\n } catch {}\n\n // Generate CSV version too\n let csvVersion = \"\";\n if (invoice?.items) {\n csvVersion = toCSV(invoice.items);\n }\n\n return {\n agent: \"AnalystAgent\",\n category: \"analysis\",\n status: llmResult.success ? \"success\" : \"error\",\n message: llmResult.success ? \"Invoice generated\" : \"Invoice generation failed\",\n data: {\n action: \"invoice\",\n invoice,\n csv: csvVersion,\n },\n executionTimeMs: Date.now() - start,\n };\n }\n\n // Default: general analysis\n const llmResult = await callLLM(\n `Analyze and process: ${prompt}\\nProvide structured findings and recommendations.`,\n { maxTokens: 700, temperature: 0.5 },\n );\n\n return {\n agent: \"AnalystAgent\",\n category: \"analysis\",\n status: llmResult.success ? \"success\" : \"error\",\n message: llmResult.success ? \"Analysis completed\" : \"Analysis failed — LLM unavailable\",\n data: {\n action: \"analyze\",\n topic: prompt,\n result: llmResult.text || \"\",\n },\n executionTimeMs: Date.now() - start,\n };\n } catch (e: any) {\n return {\n agent: \"AnalystAgent\",\n category: \"analysis\",\n status: \"error\",\n message: `Analyst error: ${e.message}`,\n data: { error: e.message },\n executionTimeMs: Date.now() - start,\n };\n }\n}\n",[],[152,284],["D",1783359042602],[168,169,170,171,172],[152],["D",1783347377247],["D",1789435890000],{"_11":12,"_92":88},{"_11":12,"_85":86,"_87":88,"_45":46,"_89":90,"_91":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_80":-5,"_81":-5,"_82":-5,"_83":14,"_84":12},"ctx",{"_73":-5,"_113":332,"_333":334,"_335":336,"_337":38,"_338":38,"_339":38,"_340":50,"_341":-5,"_342":-7,"_343":-7,"_344":54,"_345":38,"_346":38,"_347":-5,"_348":38,"_349":38,"_350":38,"_351":-5},"ENV",{"_303":304,"_305":306,"_307":26,"_308":309,"_310":311,"_312":313,"_314":315,"_316":317,"_318":319,"_320":321,"_322":323,"_324":325,"_326":327,"_328":329,"_330":331},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Branches1

Branches
1