[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_209":210,"_211":212},"routes/_app.x.$handle.$name",{"_102":101,"_37":49,"_109":92,"_32":57,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_26":-5,"_120":-5,"_121":-5,"_122":30,"_123":124,"_125":30,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_47":48,"_37":49,"_42":50,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":-5,"_61":30,"_62":-5,"_63":-5,"_64":65,"_66":67,"_68":69,"_70":71,"_72":73,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":85,"_86":87,"_88":89,"_90":30},"version",11,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","d7a16f5b-7463-47fc-9b12-fb631b3ddc0d","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":33,"_38":39,"_40":41,"_42":43,"_44":14,"_45":46,"_29":30},"previous","deleted",false,"deletedHere","path","UniversalAdapter.ts","latestPath","fileId","dec8a808-790e-11f1-8185-1607ee4eb77e","name","fileType","script","content","// Universal Adapter Layer — Nexuses Core OS V9.0\n// M2M middleware that connects the OS to third-party plugins, browsers, and applications.\n\nexport interface Adapter {\n name: string;\n type: \"api\" | \"browser\" | \"service\" | \"plugin\";\n status: \"active\" | \"inactive\" | \"error\";\n description: string;\n execute: (action: string, data: any) => Promise;\n}\n\nexport interface AdapterResult {\n success: boolean;\n adapter: string;\n action: string;\n data: any;\n message: string;\n}\n\n// --- Built-in Adapters ---\n\nconst GitHubAdapter: Adapter = {\n name: \"github\",\n type: \"api\",\n status: \"active\",\n description: \"GitHub repository management, issue tracking, code search\",\n async execute(action: string, data: any): Promise {\n const token = Deno.env.get(\"GITHUB_TOKEN\");\n if (!token) {\n return {\n success: false, adapter: \"github\", action, data: {},\n message: \"GITHUB_TOKEN not configured\",\n };\n }\n try {\n let url = \"\";\n let method = \"GET\";\n let body: string | undefined;\n\n switch (action) {\n case \"search_code\":\n url = `https://api.github.com/search/code?q=${encodeURIComponent(data.query)}`;\n break;\n case \"get_repo\":\n url = `https://api.github.com/repos/${data.owner}/${data.repo}`;\n break;\n case \"list_issues\":\n url = `https://api.github.com/repos/${data.owner}/${data.repo}/issues?state=open`;\n break;\n case \"create_issue\":\n url = `https://api.github.com/repos/${data.owner}/${data.repo}/issues`;\n method = \"POST\";\n body = JSON.stringify({ title: data.title, body: data.body });\n break;\n case \"get_file\":\n url = `https://api.github.com/repos/${data.owner}/${data.repo}/contents/${data.path}`;\n break;\n default:\n return {\n success: false, adapter: \"github\", action, data: {},\n message: `Unknown action: ${action}`,\n };\n }\n\n const res = await fetch(url, {\n method,\n headers: {\n \"Authorization\": `Bearer ${token}`,\n \"Accept\": \"application/vnd.github.v3+json\",\n \"Content-Type\": \"application/json\",\n },\n body,\n });\n\n const result = await res.json();\n return {\n success: res.ok, adapter: \"github\", action,\n data: result,\n message: res.ok ? `GitHub ${action} completed` : `GitHub API error: ${res.status}`,\n };\n } catch (e: any) {\n return {\n success: false, adapter: \"github\", action, data: {},\n message: e.message,\n };\n }\n },\n};\n\nconst DuckDuckGoAdapter: Adapter = {\n name: \"duckduckgo\",\n type: \"service\",\n status: \"active\",\n description: \"Free-tier web search and instant answers\",\n async execute(action: string, data: any): Promise {\n try {\n const query = data.query || data.q || \"\";\n const res = await fetch(\n `https://api.duckduckgo.com/?q=${encodeURIComponent(query)}&format=json`,\n );\n const result = await res.json();\n return {\n success: true, adapter: \"duckduckgo\", action: \"search\",\n data: {\n abstract: result.AbstractText || \"\",\n answer: result.Answer || \"\",\n related: (result.RelatedTopics || []).slice(0, 5).map((t: any) => t.Text || t.Topics?.[0]?.Text).filter(Boolean),\n },\n message: \"Search completed\",\n };\n } catch (e: any) {\n return {\n success: false, adapter: \"duckduckgo\", action, data: {},\n message: e.message,\n };\n }\n },\n};\n\nconst CoinGeckoAdapter: Adapter = {\n name: \"coingecko\",\n type: \"api\",\n status: \"active\",\n description: \"Cryptocurrency price data and market signals\",\n async execute(action: string, data: any): Promise {\n try {\n const coins = data.coins || [\"bitcoin\", \"ethereum\"];\n const res = await fetch(\n `https://api.coingecko.com/api/v3/simple/price?ids=${coins.join(\",\")}&vs_currencies=usd&include_24hr_change=true`,\n );\n const prices = await res.json();\n const signals = coins.map((c: string) => {\n const change = prices[c]?.usd_24h_change || 0;\n return {\n coin: c,\n price: prices[c]?.usd,\n change24h: change,\n signal: change > 5 ? \"BUY\" : change < -5 ? \"SELL\" : \"HOLD\",\n };\n });\n return {\n success: true, adapter: \"coingecko\", action: \"price\",\n data: { signals },\n message: \"Crypto signals generated\",\n };\n } catch (e: any) {\n return {\n success: false, adapter: \"coingecko\", action, data: {},\n message: e.message,\n };\n }\n },\n};\n\nconst WebScraperAdapter: Adapter = {\n name: \"webscraper\",\n type: \"browser\",\n status: \"active\",\n description: \"Web page scraping and content extraction\",\n async execute(action: string, data: any): Promise {\n const url = data.url;\n if (!url || !url.startsWith(\"http\")) {\n return {\n success: false, adapter: \"webscraper\", action, data: {},\n message: \"No valid URL provided\",\n };\n }\n try {\n const res = await fetch(url);\n const html = await res.text();\n const title = html.match(/]*>([^<]+)<\\/title>/i)?.[1]?.trim() || \"\";\n const links = (html.match(/]+href=[\"']([^\"']+)[\"']/gi) || [])\n .slice(0, 20)\n .map((m: string) => m.match(/href=[\"']([^\"']+)[\"']/i)?.[1])\n .filter(Boolean);\n const textContent = html.replace(/<[^>]+>/g, \" \").replace(/\\s+/g, \" \").trim().slice(0, 2000);\n return {\n success: true, adapter: \"webscraper\", action: \"scrape\",\n data: { url, title, links, textContent },\n message: `Scraped ${url}`,\n };\n } catch (e: any) {\n return {\n success: false, adapter: \"webscraper\", action, data: {},\n message: e.message,\n };\n }\n },\n};\n\n// --- Adapter Registry ---\n\nconst REGISTRY = new Map();\n[GitHubAdapter, DuckDuckGoAdapter, CoinGeckoAdapter, WebScraperAdapter].forEach(\n (a) => REGISTRY.set(a.name, a),\n);\n\nexport function registerAdapter(adapter: Adapter) {\n REGISTRY.set(adapter.name, adapter);\n}\n\nexport function getAdapter(name: string): Adapter | null {\n return REGISTRY.get(name) || null;\n}\n\nexport function listAdapters() {\n return Array.from(REGISTRY.values()).map((a) => ({\n name: a.name,\n type: a.type,\n status: a.status,\n description: a.description,\n }));\n}\n\nexport async function routeToAdapter(\n name: string,\n action: string,\n data: any,\n): Promise {\n const adapter = getAdapter(name);\n if (!adapter) {\n return {\n success: false,\n adapter: name,\n action,\n data: {},\n message: `Adapter '${name}' not found in registry`,\n };\n }\n return adapter.execute(action, data);\n}\n","createdAt",["D",1783324019927],"branchVersion","branchId","5d9d5db3-ac01-40e7-ab61-8225377adcd3","id","e2bee9e9-3a78-434b-ab5c-eda84056d0cf","Lepora",["D",1783322691823],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","145be002-4ce4-47ae-9745-32507d39122b","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f364f-9eb7-74ae-945d-aa4e96bd01a4","tursoName","e2bee9e93a78434bab5ceda84056d0cf","tursoHostname","e2bee9e93a78434bab5ceda84056d0cf-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789525843977],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_102":101,"_108":57},"org",{"_102":101,"_103":57,"_104":57,"_19":59,"_105":106,"_107":30},"branch",{"_13":91,"_37":92,"_47":46,"_93":48,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":49,"_100":101},"isOwned",32,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","lepora9949b","handle","displayName","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_47":48,"_37":49,"_42":204,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":-5,"_61":30,"_62":-5,"_63":-5,"_64":65,"_66":67,"_68":69,"_70":71,"_72":205,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":206,"_86":207,"_88":208,"_90":30},"tree",[183,184,185,186,187],"files",[183,184,185,186,187],"counts",{"_172":65,"_173":174,"_175":65,"_176":177,"_178":179},"contents",[130,131,132,133,134],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_47":165,"_37":166,"_35":167,"_138":-5,"_45":46,"_44":168,"_140":30,"_42":169,"_13":142,"_38":39,"_40":170,"_29":30,"_144":-5,"_32":171},{"_47":161,"_37":33,"_35":36,"_138":-5,"_45":46,"_44":14,"_140":162,"_42":163,"_13":65,"_38":39,"_40":41,"_29":30,"_144":-5,"_32":164},{"_47":154,"_37":155,"_35":156,"_138":-5,"_45":46,"_44":157,"_140":30,"_42":158,"_13":65,"_38":39,"_40":159,"_29":30,"_144":-5,"_32":160},{"_47":147,"_37":148,"_35":149,"_138":-5,"_45":46,"_44":150,"_140":30,"_42":151,"_13":65,"_38":39,"_40":152,"_29":30,"_144":-5,"_32":153},{"_47":135,"_37":136,"_35":137,"_138":-5,"_45":46,"_44":139,"_140":30,"_42":141,"_13":142,"_38":39,"_40":143,"_29":30,"_144":145,"_32":146},"79648364-7f4c-4562-9563-e8b14dd35dd9","main.ts","c72d7d84-790b-11f1-afd3-1607ee4eb77e","parentId",8,"latest",["D",1783323016223],3,"import { getAgentManifest, routeIncomingTask } from \"./AgentManager.ts\";\nimport type { NexusResponse } from \"./AgentManager.ts\";\n\nconst DB = new Map>();\n[\"tasks\", \"platforms\", \"analytics\", \"memory\"].forEach((t) =>\n DB.set(t, new Map())\n);\n\nfunction dbInsert(table: string, id: string, data: any) {\n DB.get(table)?.set(id, { ...data, id, ts: new Date().toISOString() });\n}\nfunction dbGet(table: string, id: string) {\n return DB.get(table)?.get(id) || null;\n}\nfunction dbAll(table: string) {\n return Array.from(DB.get(table)?.values() || []);\n}\n\nconst PLATFORMS = new Map();\nconst RATE_LIMIT = new Map();\n\nfunction getEnv(key: string): string | undefined {\n try {\n if (typeof Deno !== \"undefined\") return Deno.env.get(key);\n if (typeof process !== \"undefined\") return process.env[key];\n } catch {}\n return undefined;\n}\n\nfunction detectPlatform(payload: any, ua: string, ip: string): string {\n if (payload?.platformID) return payload.platformID;\n const u = ua.toLowerCase();\n if (u.includes(\"zapier\")) return \"zapier\";\n if (u.includes(\"make\")) return \"make\";\n if (u.includes(\"n8n\")) return \"n8n\";\n return `anon-${ip.replace(/[^a-z0-9]/g, \"-\")}`;\n}\n\nfunction isRateLimited(ip: string): boolean {\n const now = Date.now();\n const ts = RATE_LIMIT.get(ip)?.filter((t) => now - t < 60000) || [];\n if (ts.length >= 50) return true;\n ts.push(now);\n RATE_LIMIT.set(ip, ts);\n return false;\n}\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\",\n};\n\nfunction json(body: any, status = 200) {\n return new Response(JSON.stringify(body), { 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 const start = Date.now();\n const url = new URL(req.url);\n\n if (req.method === \"GET\") {\n if (url.pathname === \"/analytics\") {\n return json({ tasks: dbAll(\"tasks\").length, platforms: PLATFORMS.size });\n }\n if (url.pathname === \"/platforms\") {\n return json({ platforms: Array.from(PLATFORMS.entries()) });\n }\n\n return json({\n status: \"ONLINE\",\n service: \"Nexuses Core OS V9.0 - Compact\",\n agents: getAgentManifest().map((a) => ({ name: a.name, caps: a.caps })),\n integrations: {\n hf: getEnv(\"HF_API_KEY\") ? \"ACTIVE\" : \"NOT_CONFIGURED\",\n coingecko: \"ACTIVE\",\n duckduckgo: \"ACTIVE\",\n },\n endpoints: {\n POST: { \"/\": \"Execute task\", \"/ai-generate\": \"AI generation\" },\n GET: {\n \"/\": \"Discovery\",\n \"/analytics\": \"Stats\",\n \"/platforms\": \"Platforms\",\n },\n },\n example: { task: \"AI_GENERATE\", data: { prompt: \"Explain AI\" } },\n });\n }\n\n if (req.method !== \"POST\") return json({ error: \"Only POST\" }, 405);\n\n const ip = req.headers.get(\"x-forwarded-for\")?.split(\",\")[0] ||\n req.headers.get(\"cf-connecting-ip\") || \"unknown\";\n if (isRateLimited(ip)) {\n return json({ status: \"DENIED\", message: \"Rate limit\" }, 429);\n }\n\n let payload: any;\n try {\n payload = await req.json();\n } catch {\n return json({ status: \"ERROR\", message: \"Invalid JSON\" }, 400);\n }\n\n const ua = req.headers.get(\"user-agent\") || \"unknown\";\n const platformID = detectPlatform(payload, ua, ip);\n\n const existing = PLATFORMS.get(platformID) ||\n { firstSeen: new Date().toISOString(), count: 0 };\n existing.lastSeen = new Date().toISOString();\n existing.count++;\n PLATFORMS.set(platformID, existing);\n\n const task = payload?.task || \"general\";\n const data = payload?.data || {};\n const mode = payload?.mode || \"AUTO\";\n\n dbInsert(\"tasks\", `task_${Date.now()}`, {\n platform: platformID,\n task,\n status: \"processing\",\n });\n\n // AI Generate endpoint\n if (url.pathname === \"/ai-generate\" || payload?.task === \"AI_GENERATE\") {\n const prompt = data.prompt || task;\n const model = prompt.toLowerCase().includes(\"code\")\n ? \"qwen\"\n : prompt.toLowerCase().includes(\"creative\")\n ? \"llama\"\n : \"mistral\";\n const token = getEnv(\"HF_API_KEY\") || getEnv(\"HUGGING_FACE_TOKEN\");\n let result = \"[HF_ERROR] Token not configured\";\n\n if (token) {\n try {\n const models: Record = {\n mistral: \"mistralai/Mistral-7B-Instruct-v0.2\",\n qwen: \"Qwen/Qwen2-7B-Instruct\",\n llama: \"meta-llama/Meta-Llama-3-8B-Instruct\",\n phi3: \"microsoft/Phi-3-mini-4k-instruct\",\n };\n const res = await fetch(\n `https://api-inference.huggingface.co/models/${models[model]}`,\n {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n inputs: prompt,\n parameters: {\n max_new_tokens: data.maxTokens || 500,\n temperature: data.temperature || 0.7,\n return_full_text: false,\n },\n }),\n },\n );\n if (res.ok) {\n const d = await res.json();\n result = Array.isArray(d)\n ? d[0]?.generated_text || \"No response\"\n : d?.generated_text || \"No response\";\n } else result = `[HF_ERROR] HTTP ${res.status}`;\n } catch (e: any) {\n result = `[HF_ERROR] ${e.message}`;\n }\n }\n\n dbInsert(\"tasks\", `task_${Date.now()}`, {\n platform: platformID,\n task: \"AI_GENERATE\",\n status: \"completed\",\n model,\n });\n\n return json({\n status: \"SUCCESS\",\n platform: { id: platformID, detected: true },\n task: \"AI_GENERATE\",\n model,\n result,\n executionTimeMs: Date.now() - start,\n timestamp: new Date().toISOString(),\n });\n }\n\n try {\n const result = await routeIncomingTask(task, data, mode, false);\n dbInsert(\"tasks\", `task_${Date.now()}`, {\n platform: platformID,\n task,\n status: result.status,\n agent: result.agent,\n });\n\n return json({\n status: \"SUCCESS\",\n platform: { id: platformID, userAgent: ua.substring(0, 50), ip },\n result,\n executionTimeMs: Date.now() - start,\n timestamp: new Date().toISOString(),\n });\n } catch (e: any) {\n return json(\n { status: \"ERROR\", platform: platformID, error: e.message },\n 500,\n );\n }\n}","label","nexuses-core-os",[136],"e3b63c81-7df2-46b4-84ce-295c4df45948","hf.ts","dda7eed4-790e-11f1-8185-1607ee4eb77e",10,["D",1783324018031],"// Hugging Face Model Orchestration — Nexuses Core OS V9.0\n// Dynamic model selection based on task type. Free-tier optimized.\n\nexport type ModelKey = \"mistral\" | \"qwen\" | \"llama\" | \"phi3\";\n\ninterface ModelConfig {\n id: string;\n label: string;\n bestFor: string[];\n maxTokens: number;\n temperature: number;\n}\n\nexport const HF_MODELS: Record = {\n mistral: {\n id: \"mistralai/Mistral-7B-Instruct-v0.2\",\n label: \"Mistral 7B Instruct\",\n bestFor: [\"general\", \"reasoning\", \"chat\", \"analysis\"],\n maxTokens: 500,\n temperature: 0.7,\n },\n qwen: {\n id: \"Qwen/Qwen2-7B-Instruct\",\n label: \"Qwen2 7B Instruct\",\n bestFor: [\"code\", \"coding\", \"programming\", \"technical\", \"translate\"],\n maxTokens: 800,\n temperature: 0.3,\n },\n llama: {\n id: \"meta-llama/Meta-Llama-3-8B-Instruct\",\n label: \"Llama 3 8B Instruct\",\n bestFor: [\"creative\", \"writing\", \"content\", \"blog\", \"story\"],\n maxTokens: 1000,\n temperature: 0.8,\n },\n phi3: {\n id: \"microsoft/Phi-3-mini-4k-instruct\",\n label: \"Phi-3 Mini 4K\",\n bestFor: [\"fast\", \"simple\", \"summarize\", \"extract\", \"data\"],\n maxTokens: 400,\n temperature: 0.5,\n },\n};\n\nfunction getEnv(key: string): string | undefined {\n try {\n return Deno.env.get(key);\n } catch {\n return undefined;\n }\n}\n\nexport function getHFToken(): string | null {\n return getEnv(\"HF_API_KEY\") || getEnv(\"HUGGING_FACE_TOKEN\") || null;\n}\n\n/**\n * Dynamically selects the best HF model for the given task text.\n * Falls back to mistral for unrecognized types.\n */\nexport function selectModel(taskText: string): ModelKey {\n const lower = taskText.toLowerCase();\n // Check each model's specialties\n for (const [key, cfg] of Object.entries(HF_MODELS)) {\n if (cfg.bestFor.some((tag) => lower.includes(tag))) {\n return key as ModelKey;\n }\n }\n // Heuristic fallbacks\n if (lower.includes(\"code\") || lower.includes(\"debug\") || lower.includes(\"fix\")) {\n return \"qwen\";\n }\n if (lower.includes(\"write\") || lower.includes(\"blog\") || lower.includes(\"article\")) {\n return \"llama\";\n }\n if (lower.includes(\"summary\") || lower.includes(\"extract\") || lower.includes(\"data\")) {\n return \"phi3\";\n }\n return \"mistral\";\n}\n\nexport interface HFResult {\n success: boolean;\n model: ModelKey;\n modelId: string;\n text: string;\n error?: string;\n}\n\n/**\n * Calls Hugging Face inference API with the selected (or specified) model.\n */\nexport async function callHF(\n prompt: string,\n model?: ModelKey,\n maxTokens?: number,\n temperature?: number,\n): Promise {\n const modelKey = model || selectModel(prompt);\n const cfg = HF_MODELS[modelKey];\n const token = getHFToken();\n\n if (!token) {\n return {\n success: false,\n model: modelKey,\n modelId: cfg.id,\n text: \"\",\n error: \"HF_API_KEY not configured. Set it in environment variables.\",\n };\n }\n\n try {\n const res = await fetch(\n `https://api-inference.huggingface.co/models/${cfg.id}`,\n {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n inputs: prompt,\n parameters: {\n max_new_tokens: maxTokens || cfg.maxTokens,\n temperature: temperature ?? cfg.temperature,\n return_full_text: false,\n },\n }),\n },\n );\n\n if (!res.ok) {\n return {\n success: false,\n model: modelKey,\n modelId: cfg.id,\n text: \"\",\n error: `HTTP ${res.status}: ${await res.text()}`,\n };\n }\n\n const data = await res.json();\n const text = Array.isArray(data)\n ? data[0]?.generated_text || \"\"\n : data?.generated_text || \"\";\n\n return {\n success: true,\n model: modelKey,\n modelId: cfg.id,\n text,\n };\n } catch (e: any) {\n return {\n success: false,\n model: modelKey,\n modelId: cfg.id,\n text: \"\",\n error: e.message,\n };\n }\n}\n\n/**\n * Returns manifest of available models for discovery endpoint.\n */\nexport function getModelManifest() {\n const token = getHFToken();\n return Object.entries(HF_MODELS).map(([key, cfg]) => ({\n key,\n id: cfg.id,\n label: cfg.label,\n bestFor: cfg.bestFor,\n status: token ? \"AVAILABLE\" : \"NO_TOKEN\",\n }));\n}\n",[148],"feeb9ec8-f78f-42b5-b4ea-206d557ad526","db.ts","d2af9306-790e-11f1-ac91-1607ee4eb77e",9,["D",1783323999632],"// SQLite Persistent State Layer — Nexuses Core OS V9.0\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport interface TaskRecord {\n id: string;\n task: string;\n agent: string;\n status: string;\n data: string;\n result: string;\n created_at: string;\n updated_at: string;\n}\n\nexport interface MemoryRecord {\n key: string;\n value: string;\n created_at: string;\n}\n\nconst INIT_SQL = [\n `CREATE TABLE IF NOT EXISTS tasks (\n id TEXT PRIMARY KEY,\n task TEXT NOT NULL,\n agent TEXT,\n status TEXT NOT NULL,\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 memory (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL,\n created_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS workflows (\n id TEXT PRIMARY KEY,\n task_id TEXT NOT NULL,\n step INTEGER NOT NULL,\n agent TEXT,\n status TEXT,\n detail 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(INIT_SQL.map((sql) => ({ sql })));\n initialized = true;\n}\n\nexport async function insertTask(\n id: string,\n task: string,\n agent: string,\n status: string,\n data: any,\n result: any,\n) {\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `INSERT INTO tasks (id, task, agent, status, data, result, created_at, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [id, task, agent, status, JSON.stringify(data), JSON.stringify(result), now, now],\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 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 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 tasks ORDER BY created_at DESC LIMIT ?`,\n args: [limit],\n });\n return res.rows as TaskRecord[];\n}\n\nexport async function logWorkflowStep(\n taskId: string,\n step: number,\n agent: string,\n status: string,\n detail: string,\n) {\n const id = `wf_${taskId}_${step}`;\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `INSERT INTO workflows (id, task_id, step, agent, status, detail, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n args: [id, taskId, step, agent, status, detail, now],\n });\n}\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 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 memory WHERE key = ?`,\n args: [key],\n });\n const row = res.rows[0] as MemoryRecord | undefined;\n return row ? JSON.parse(row.value) : null;\n}\n\nexport async function getWorkflowHistory(taskId: string) {\n const res = await sqlite.execute({\n sql: `SELECT * FROM workflows WHERE task_id = ? ORDER BY step ASC`,\n args: [taskId],\n });\n return res.rows;\n}\n\nexport async function getTaskCount(): Promise {\n const res = await sqlite.execute(`SELECT COUNT(*) as count FROM tasks`);\n return (res.rows[0] as any)?.count || 0;\n}\n",[155],"756b7f35-048d-4e7c-9e28-529563d89287",true,["D",1783324019927],[33],"e31ce1d2-b214-4ed1-8f18-e1f64b6536dc","AgentManager.ts","f7361f90-790b-11f1-95a6-1607ee4eb77e",7,["D",1783322823169],"// NEXUSES CORE OS V9.0 - Compact Version\ninterface AgentResult {\n agent: string;\n status: string;\n message: string;\n data?: any;\n}\nexport interface NexusResponse {\n status: string;\n mode: string;\n agent: string;\n action: string;\n data: any;\n subTasks?: any[];\n}\n\nconst HF_MODELS: Record = {\n mistral: \"mistralai/Mistral-7B-Instruct-v0.2\",\n qwen: \"Qwen/Qwen2-7B-Instruct\",\n llama: \"meta-llama/Meta-Llama-3-8B-Instruct\",\n phi3: \"microsoft/Phi-3-mini-4k-instruct\",\n};\n\nfunction getEnv(key: string): string | undefined {\n try {\n if (typeof Deno !== \"undefined\") return Deno.env.get(key);\n if (typeof process !== \"undefined\") return process.env[key];\n } catch {}\n return undefined;\n}\n\nasync function callHF(\n prompt: string,\n model = \"mistral\",\n maxTokens = 500,\n temp = 0.7,\n): Promise {\n const token = getEnv(\"HF_API_KEY\") || getEnv(\"HUGGING_FACE_TOKEN\");\n if (!token) return \"[HF_ERROR] Token not configured\";\n try {\n const res = await fetch(\n `https://api-inference.huggingface.co/models/${HF_MODELS[model]}`,\n {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n inputs: prompt,\n parameters: {\n max_new_tokens: maxTokens,\n temperature: temp,\n return_full_text: false,\n },\n }),\n },\n );\n if (!res.ok) return `[HF_ERROR] HTTP ${res.status}`;\n const data = await res.json();\n return Array.isArray(data)\n ? data[0]?.generated_text || \"No response\"\n : data?.generated_text || \"No response\";\n } catch (e: any) {\n return `[HF_ERROR] ${e.message}`;\n }\n}\n\nconst AGENTS = [\n {\n name: \"AIGenerationAgent\",\n keywords: [\"ai-generate\", \"mistral\", \"hf-generate\"],\n caps: [\"AI generation\"],\n },\n {\n name: \"WebScraperAgent\",\n keywords: [\"scrape\", \"extract\", \"crawl\", \"web\"],\n caps: [\"Web scraping\"],\n },\n {\n name: \"CryptoSignalAgent\",\n keywords: [\"crypto\", \"bitcoin\", \"signal\", \"trade\"],\n caps: [\"Crypto signals\"],\n },\n {\n name: \"ContentWriterAgent\",\n keywords: [\"write\", \"blog\", \"content\", \"article\"],\n caps: [\"Content writing\"],\n },\n {\n name: \"CodeExecutionAgent\",\n keywords: [\"code\", \"run\", \"execute\", \"program\"],\n caps: [\"Code execution\"],\n },\n {\n name: \"EmailAgent\",\n keywords: [\"email\", \"mail\", \"send\"],\n caps: [\"Email sending\"],\n },\n {\n name: \"ResearchAgent\",\n keywords: [\"research\", \"search\", \"find\"],\n caps: [\"Research\"],\n },\n {\n name: \"TranslationAgent\",\n keywords: [\"translate\", \"language\"],\n caps: [\"Translation\"],\n },\n { name: \"GeneralHandler\", keywords: [\"general\", \"help\"], caps: [\"General\"] },\n];\n\nexport function getAgentManifest() {\n return AGENTS;\n}\n\nconst AGENT_MAP: Record<\n string,\n (task: string, data: any) => Promise\n> = {};\n\nAGENT_MAP[\"AIGenerationAgent\"] = async (task: string, data: any) => {\n const prompt = data.prompt || task;\n const model = task.toLowerCase().includes(\"code\")\n ? \"qwen\"\n : task.toLowerCase().includes(\"creative\")\n ? \"llama\"\n : \"mistral\";\n const result = await callHF(\n prompt,\n model,\n data.maxTokens || 500,\n data.temperature || 0.7,\n );\n return {\n agent: \"AIGenerationAgent\",\n status: result.startsWith(\"[HF_ERROR]\") ? \"ERROR\" : \"EXECUTED\",\n message: `AI generated using ${model}`,\n data: { model, result },\n };\n};\n\nAGENT_MAP[\"WebScraperAgent\"] = async (task: string, data: any) => {\n const url = data.url || task;\n if (!url || !url.startsWith(\"http\")) {\n return {\n agent: \"WebScraperAgent\",\n status: \"ERROR\",\n message: \"No URL\",\n data: {},\n };\n }\n try {\n const res = await fetch(url);\n const html = await res.text();\n const title = html.match(/]*>([^<]+)<\\/title>/i)?.[1]?.trim() ||\n \"\";\n const links = (html.match(/]+href=[\"']([^\"']+)[\"']/gi) || []).slice(\n 0,\n 20,\n );\n return {\n agent: \"WebScraperAgent\",\n status: \"EXECUTED\",\n message: `Scraped ${url}`,\n data: { url, title, links },\n };\n } catch (e: any) {\n return {\n agent: \"WebScraperAgent\",\n status: \"ERROR\",\n message: e.message,\n data: {},\n };\n }\n};\n\nAGENT_MAP[\"CryptoSignalAgent\"] = async (task: string, data: any) => {\n const coins = data.coins || [\"bitcoin\", \"ethereum\"];\n try {\n const res = await fetch(\n `https://api.coingecko.com/api/v3/simple/price?ids=${\n coins.join(\",\")\n }&vs_currencies=usd&include_24hr_change=true`,\n );\n const prices = await res.json();\n const signals = coins.map((c) => {\n const change = prices[c]?.usd_24h_change || 0;\n return {\n coin: c,\n price: prices[c]?.usd,\n change,\n signal: change > 5 ? \"BUY\" : change < -5 ? \"SELL\" : \"HOLD\",\n };\n });\n return {\n agent: \"CryptoSignalAgent\",\n status: \"EXECUTED\",\n message: \"Signals generated\",\n data: { signals },\n };\n } catch (e: any) {\n return {\n agent: \"CryptoSignalAgent\",\n status: \"ERROR\",\n message: e.message,\n data: {},\n };\n }\n};\n\nAGENT_MAP[\"ContentWriterAgent\"] = async (task: string, data: any) => {\n const topic = data.topic || task;\n const result = await callHF(`Write about ${topic}`, \"qwen\", 1000);\n return {\n agent: \"ContentWriterAgent\",\n status: \"EXECUTED\",\n message: \"Content written\",\n data: { topic, result },\n };\n};\n\nAGENT_MAP[\"CodeExecutionAgent\"] = async (task: string, data: any) => {\n const code = data.code || task;\n const lang = data.language || \"javascript\";\n if (lang === \"javascript\") {\n try {\n const logs: string[] = [];\n const fn = new Function(\n \"console\",\n code.replace(/console.log/g, \"logs.push\"),\n );\n const result = await fn({\n log: (...args: any[]) => logs.push(args.join(\" \")),\n });\n return {\n agent: \"CodeExecutionAgent\",\n status: \"EXECUTED\",\n message: \"Code executed\",\n data: { result, logs },\n };\n } catch (e: any) {\n return {\n agent: \"CodeExecutionAgent\",\n status: \"ERROR\",\n message: e.message,\n data: {},\n };\n }\n }\n return {\n agent: \"CodeExecutionAgent\",\n status: \"ERROR\",\n message: \"Only JS supported\",\n data: {},\n };\n};\n\nAGENT_MAP[\"EmailAgent\"] = async (task: string, data: any) => {\n const key = getEnv(\"RESEND_API_KEY\");\n if (!key) {\n return {\n agent: \"EmailAgent\",\n status: \"EXECUTED\",\n message: \"Email queued (no key)\",\n data: {},\n };\n }\n try {\n await fetch(\"https://api.resend.com/emails\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${key}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n from: \"Nexuses OS \",\n to: [data.to],\n subject: data.subject || \"Message\",\n text: data.body || task,\n }),\n });\n return {\n agent: \"EmailAgent\",\n status: \"EXECUTED\",\n message: \"Email sent\",\n data: {},\n };\n } catch (e: any) {\n return {\n agent: \"EmailAgent\",\n status: \"ERROR\",\n message: e.message,\n data: {},\n };\n }\n};\n\nAGENT_MAP[\"ResearchAgent\"] = async (task: string, data: any) => {\n const query = data.query || task;\n try {\n const res = await fetch(\n `https://api.duckduckgo.com/?q=${encodeURIComponent(query)}&format=json`,\n );\n const data = await res.json();\n return {\n agent: \"ResearchAgent\",\n status: \"EXECUTED\",\n message: \"Research done\",\n data: { abstract: data.AbstractText || \"\", answer: data.Answer || \"\" },\n };\n } catch (e: any) {\n return {\n agent: \"ResearchAgent\",\n status: \"ERROR\",\n message: e.message,\n data: {},\n };\n }\n};\n\nAGENT_MAP[\"TranslationAgent\"] = async (task: string, data: any) => {\n const text = data.text || task;\n const result = await callHF(\n `Translate to ${data.to || \"urdu\"}: ${text}`,\n \"qwen\",\n 500,\n 0.3,\n );\n return {\n agent: \"TranslationAgent\",\n status: \"EXECUTED\",\n message: \"Translated\",\n data: { text, result },\n };\n};\n\nAGENT_MAP[\"GeneralHandler\"] = async (task: string, data: any) => {\n return {\n agent: \"GeneralHandler\",\n status: \"EXECUTED\",\n message: \"Task processed\",\n data: { task },\n };\n};\n\nfunction matchAgent(task: string): string {\n const cmd = task.toLowerCase();\n for (const agent of AGENTS) {\n if (agent.keywords.some((k) => cmd.includes(k))) return agent.name;\n }\n return \"GeneralHandler\";\n}\n\nexport async function routeIncomingTask(\n task: string,\n data: any = {},\n mode = \"AUTO\",\n debug = false,\n): Promise {\n const agentName = matchAgent(task);\n const agentFn = AGENT_MAP[agentName] || AGENT_MAP[\"GeneralHandler\"];\n try {\n const result = await agentFn(task, data);\n return {\n status: result.status === \"EXECUTED\" ? \"SUCCESS\" : \"ERROR\",\n mode: mode.toUpperCase() === \"CLI\" ? \"CLI\" : \"AUTO\",\n agent: result.agent,\n action: result.message,\n data: result.data || {},\n };\n } catch (e: any) {\n return {\n status: \"ERROR\",\n mode: \"AUTO\",\n agent: agentName,\n action: `Error: ${e.message}`,\n data: {},\n };\n }\n}",[166],"pulls","branches",1,"forks","envVars",{"_180":65,"_182":65},"connections",{"_180":65,"_181":65},"count","unfilledCount","emptyCount",{"_47":165,"_37":166,"_35":167,"_138":-5,"_45":46,"_44":168,"_140":30,"_42":201,"_13":142,"_38":39,"_40":170,"_29":30,"_144":-5,"_189":202,"_32":203},{"_47":161,"_37":33,"_35":36,"_138":-5,"_45":46,"_44":14,"_140":162,"_42":198,"_13":65,"_38":39,"_40":41,"_29":30,"_144":-5,"_189":199,"_32":200},{"_47":154,"_37":155,"_35":156,"_138":-5,"_45":46,"_44":157,"_140":30,"_42":195,"_13":65,"_38":39,"_40":159,"_29":30,"_144":-5,"_189":196,"_32":197},{"_47":147,"_37":148,"_35":149,"_138":-5,"_45":46,"_44":150,"_140":30,"_42":192,"_13":65,"_38":39,"_40":152,"_29":30,"_144":-5,"_189":193,"_32":194},{"_47":135,"_37":136,"_35":137,"_138":-5,"_45":46,"_44":139,"_140":30,"_42":188,"_13":142,"_38":39,"_40":143,"_29":30,"_144":145,"_189":190,"_32":191},["D",1783323016223],"children",[],[136],["D",1783324018031],[],[148],["D",1783323999632],[],[155],["D",1783324019927],[],[33],["D",1783322823169],[],[166],["D",1783322691823],["D",1789525843977],{"_102":101,"_108":57},{"_102":101,"_103":57,"_104":57,"_19":59,"_105":106,"_107":30},{"_13":91,"_37":92,"_47":46,"_93":48,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":49,"_100":101},"ctx",{"_84":-5,"_127":242,"_243":244,"_245":246,"_247":30,"_248":30,"_249":30,"_250":162,"_251":-5,"_252":-7,"_253":-7,"_254":65,"_255":30,"_256":30,"_257":-5,"_258":30,"_259":30,"_260":30,"_261":-5},"ENV",{"_213":214,"_215":216,"_217":92,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229,"_230":231,"_232":233,"_234":235,"_236":237,"_238":239,"_240":241},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v11