[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_235":236,"_237":238},"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":126,"_127":-5,"_128":-5,"_129":130},"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",22,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","6432b48e-23c7-4a3b-a438-b7f5022d3196","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","RegistryManager.ts","latestPath","fileId","36d140de-7912-11f1-8629-1607ee4eb77e","name","fileType","script","content","// Registry Manager — Nexuses Core OS V10.0\n// Central catalog of all capabilities: agents, adapters, models, external services.\n// Used by the IAP discovery protocol and /register endpoint.\n\nimport { getAgentManifest } from \"./AgentManager.ts\";\nimport { listAdapters } from \"./UniversalAdapter.ts\";\nimport { getModelManifest, getHFToken, classifyTask, type TaskType } from \"./hf.ts\";\n\nexport interface Capability {\n id: string;\n name: string;\n category: string;\n type: \"agent\" | \"adapter\" | \"model\" | \"external\";\n actions: string[];\n status: \"active\" | \"inactive\" | \"error\";\n description: string;\n}\n\nexport interface ServiceManifest {\n service_id: string;\n service_name: string;\n version: string;\n protocol: string;\n endpoint: string;\n auth: string;\n capabilities: Capability[];\n task_types: TaskType[];\n universal_task_format: object;\n registered_at: string;\n}\n\nconst SERVICE_ID = \"nexuses-core-os-v10\";\nconst SERVICE_NAME = \"Nexuses Core OS\";\nconst VERSION = \"10.0.0\";\nconst PROTOCOL = \"JSON-RPC 2.0 / IAP 1.0\";\n\n// --- External Service Registry (for delegation targets) ---\n\ninterface ExternalService {\n id: string;\n name: string;\n url: string;\n capabilities: string[];\n authHeader?: string;\n status: \"available\" | \"unconfigured\";\n}\n\nconst EXTERNAL_SERVICES: ExternalService[] = [\n {\n id: \"hf-inference\",\n name: \"Hugging Face Inference API\",\n url: \"https://api-inference.huggingface.co/models\",\n capabilities: [\"text-generation\", \"code-generation\", \"creative-writing\", \"summarization\"],\n authHeader: \"Authorization: Bearer \",\n status: \"available\",\n },\n {\n id: \"hf-image\",\n name: \"Hugging Face Image Generation\",\n url: \"https://api-inference.huggingface.co/models/stabilityai/stable-diffusion-xl-base-1.0\",\n capabilities: [\"image-generation\", \"text-to-image\"],\n authHeader: \"Authorization: Bearer \",\n status: \"available\",\n },\n {\n id: \"coingecko\",\n name: \"CoinGecko Market Data\",\n url: \"https://api.coingecko.com/api/v3\",\n capabilities: [\"crypto-prices\", \"market-signals\"],\n status: \"available\",\n },\n {\n id: \"duckduckgo\",\n name: \"DuckDuckGo Instant Answers\",\n url: \"https://api.duckduckgo.com\",\n capabilities: [\"web-search\", \"instant-answers\", \"research\"],\n status: \"available\",\n },\n {\n id: \"github\",\n name: \"GitHub API\",\n url: \"https://api.github.com\",\n capabilities: [\"repo-management\", \"issue-tracking\", \"code-search\"],\n authHeader: \"Authorization: Bearer \",\n status: \"available\",\n },\n];\n\n// --- Registry Functions ---\n\nexport function getExternalServices(): ExternalService[] {\n return EXTERNAL_SERVICES;\n}\n\nexport function findExternalService(capability: string): ExternalService | null {\n return EXTERNAL_SERVICES.find((s) =>\n s.capabilities.some((c) => c.includes(capability) || capability.includes(c))\n ) || null;\n}\n\n/**\n * Builds the complete capability manifest by combining:\n * - Internal agents (from AgentManager)\n * - Internal adapters (from UniversalAdapter)\n * - Available HF models (from hf.ts)\n * - External services (from this registry)\n */\nexport function buildCapabilityList(): Capability[] {\n const caps: Capability[] = [];\n\n // Agents\n for (const agent of getAgentManifest()) {\n caps.push({\n id: `agent:${agent.name}`,\n name: agent.name,\n category: agent.category,\n type: \"agent\",\n actions: agent.capabilities,\n status: \"active\",\n description: `${agent.category} agent — handles: ${agent.capabilities.join(\", \")}`,\n });\n }\n\n // Adapters\n for (const adapter of listAdapters()) {\n caps.push({\n id: `adapter:${adapter.name}`,\n name: adapter.name,\n category: adapter.type,\n type: \"adapter\",\n actions: [\"execute\"],\n status: adapter.status as \"active\" | \"inactive\" | \"error\",\n description: adapter.description,\n });\n }\n\n // Models\n for (const model of getModelManifest()) {\n caps.push({\n id: `model:${model.key}`,\n name: model.label,\n category: \"ai-model\",\n type: \"model\",\n actions: model.bestFor,\n status: model.status === \"AVAILABLE\" ? \"active\" : \"inactive\",\n description: `HF model ${model.id} — best for: ${model.bestFor.join(\", \")}`,\n });\n }\n\n // External services\n for (const svc of EXTERNAL_SERVICES) {\n caps.push({\n id: `external:${svc.id}`,\n name: svc.name,\n category: \"external-service\",\n type: \"external\",\n actions: svc.capabilities,\n status: svc.status === \"available\" ? \"active\" : \"inactive\",\n description: `External service at ${svc.url} — provides: ${svc.capabilities.join(\", \")}`,\n });\n }\n\n return caps;\n}\n\n/**\n * Returns the full service manifest for /register endpoint.\n * This is what external AI agents consume to discover and use this OS.\n */\nexport function getServiceManifest(endpoint: string): ServiceManifest {\n const token = getHFToken();\n return {\n service_id: SERVICE_ID,\n service_name: SERVICE_NAME,\n version: VERSION,\n protocol: PROTOCOL,\n endpoint,\n auth: \"Bearer token via Authorization header (NEXUSES_API_KEY)\",\n capabilities: buildCapabilityList(),\n task_types: [\"coding\", \"creative\", \"analysis\", \"general\"],\n universal_task_format: {\n request: {\n task: \"string — task description or command\",\n data: \"object — task-specific parameters\",\n mode: \"AUTO | CLI | DELEGATE (optional, default AUTO)\",\n source: \"string — calling agent/service ID (optional, for IAP)\",\n task_id: \"string — external task ID for tracking (optional)\",\n },\n response: {\n status: \"success | failure\",\n task_id: \"string — internal task ID\",\n data: \"object — execution results\",\n message: \"string — human-readable summary\",\n agent: \"string — agent that handled the task\",\n model: \"string — HF model used (if any)\",\n fallbackUsed: \"boolean — whether model fallback was triggered\",\n attempts: \"string[] — models tried in order\",\n delegated: \"boolean — whether sub-tasks were delegated externally\",\n executionTimeMs: \"number — total execution time\",\n timestamp: \"string — ISO 8601 timestamp\",\n },\n },\n registered_at: new Date().toISOString(),\n };\n}\n\nexport function getServiceInfo() {\n return {\n service_id: SERVICE_ID,\n service_name: SERVICE_NAME,\n version: VERSION,\n protocol: PROTOCOL,\n };\n}\n\n/**\n * Checks if a capability exists internally.\n * Returns false if the OS would need to delegate externally.\n */\nexport function hasInternalCapability(taskText: string): { has: boolean; taskType: TaskType; matched: Capability[] } {\n const taskType = classifyTask(taskText);\n const caps = buildCapabilityList();\n const lower = taskText.toLowerCase();\n\n const matched = caps.filter((c) =>\n c.actions.some((a) => lower.includes(a.toLowerCase()))\n );\n\n return {\n has: matched.length > 0,\n taskType,\n matched,\n };\n}\n","createdAt",["D",1783325456116],"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":230,"_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":231,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":232,"_86":233,"_88":234,"_90":30},"tree",[201,202,203,204,205,206,207],"files",[201,202,203,204,205,206,207],"counts",{"_191":65,"_192":156,"_193":65,"_194":195,"_196":197},"contents",[131,132,133,134,135,136,137],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_47":184,"_37":185,"_35":186,"_141":-5,"_45":46,"_44":187,"_143":30,"_42":188,"_13":145,"_38":39,"_40":189,"_29":30,"_148":-5,"_32":190},{"_47":181,"_37":33,"_35":36,"_141":-5,"_45":46,"_44":14,"_143":126,"_42":182,"_13":65,"_38":39,"_40":41,"_29":30,"_148":-5,"_32":183},{"_47":173,"_37":174,"_35":175,"_141":-5,"_45":46,"_44":176,"_143":30,"_42":177,"_13":178,"_38":39,"_40":179,"_29":30,"_148":-5,"_32":180},{"_47":166,"_37":167,"_35":168,"_141":-5,"_45":46,"_44":169,"_143":126,"_42":170,"_13":65,"_38":39,"_40":171,"_29":30,"_148":-5,"_32":172},{"_47":159,"_37":160,"_35":161,"_141":-5,"_45":46,"_44":162,"_143":30,"_42":163,"_13":65,"_38":39,"_40":164,"_29":30,"_148":-5,"_32":165},{"_47":151,"_37":152,"_35":153,"_141":-5,"_45":46,"_44":154,"_143":126,"_42":155,"_13":156,"_38":39,"_40":157,"_29":30,"_148":-5,"_32":158},{"_47":138,"_37":139,"_35":140,"_141":-5,"_45":46,"_44":142,"_143":30,"_42":144,"_13":145,"_38":146,"_40":147,"_29":30,"_148":149,"_32":150},"1ba70007-698c-415d-8bd0-c801eb3b2c96","main.ts","c72d7d84-790b-11f1-afd3-1607ee4eb77e","parentId",15,"latest",["D",1783324103933],5,"http","// Nexuses Core OS V9.0 — HTTP Entry Point\n// Webhook & M2M Interface with auth validation\nimport { dispatchTask, getTaskStatus, getHistory, getSystemStatus, callAdapterDirect } from \"./TaskDispatcher.ts\";\nimport { getAgentManifest } from \"./AgentManager.ts\";\nimport { listAdapters } from \"./UniversalAdapter.ts\";\nimport { getModelManifest } from \"./hf.ts\";\nimport { initDB } from \"./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, Authorization\",\n};\n\nfunction json(body: any, status = 200) {\n return new Response(JSON.stringify(body, null, 2), { status, headers: CORS });\n}\n\nfunction getEnv(key: string): string | undefined {\n try { return Deno.env.get(key); } catch { return undefined; }\n}\n\n// --- Auth Validation ---\nfunction validateAuth(req: Request): boolean {\n const apiKey = getEnv(\"NEXUSES_API_KEY\");\n // If no key is configured, allow all requests (dev mode)\n if (!apiKey) return true;\n const auth = req.headers.get(\"authorization\") || \"\";\n const token = auth.replace(/^Bearer\\s+/i, \"\").trim();\n return token === apiKey;\n}\n\n// --- Rate Limiting (in-memory per instance) ---\nconst RATE_LIMIT = new Map();\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\n// --- HTTP Handler ---\nexport default async function (req: Request): Promise {\n if (req.method === \"OPTIONS\") return new Response(null, { headers: CORS });\n\n const url = new URL(req.url);\n const path = url.pathname;\n const ip = req.headers.get(\"x-forwarded-for\")?.split(\",\")[0] ||\n req.headers.get(\"cf-connecting-ip\") || \"unknown\";\n\n // --- GET Routes ---\n if (req.method === \"GET\") {\n // System discovery\n if (path === \"/\" || path === \"\") {\n const status = await getSystemStatus();\n return json(status);\n }\n\n // System status & stats\n if (path === \"/status\") {\n const status = await getSystemStatus();\n return json(status);\n }\n\n // Agent manifest\n if (path === \"/agents\") {\n return json({ agents: getAgentManifest().map((a) => ({\n name: a.name,\n category: a.category,\n capabilities: a.capabilities,\n model: a.model,\n adapters: a.adapters,\n })) });\n }\n\n // Available adapters\n if (path === \"/adapters\") {\n return json({ adapters: listAdapters() });\n }\n\n // Available HF models\n if (path === \"/models\") {\n return json({ models: getModelManifest() });\n }\n\n // Task history\n if (path === \"/history\") {\n const limit = parseInt(url.searchParams.get(\"limit\") || \"20\");\n const history = await getHistory(limit);\n return json({ history });\n }\n\n // Get task by ID\n const taskMatch = path.match(/^\\/task\\/(.+)$/);\n if (taskMatch) {\n const task = await getTaskStatus(taskMatch[1]);\n if (!task) return json({ status: \"failure\", message: \"Task not found\" }, 404);\n return json({ task });\n }\n\n return json({ error: \"Unknown endpoint\", available: [\"/\", \"/status\", \"/agents\", \"/adapters\", \"/models\", \"/history\", \"/task/:id\"] }, 404);\n }\n\n // --- POST Routes ---\n if (req.method !== \"POST\") return json({ error: \"Only GET and POST supported\" }, 405);\n\n // Auth check\n if (!validateAuth(req)) {\n return json({\n status: \"failure\",\n message: \"Unauthorized — provide valid Bearer token in Authorization header\",\n }, 401);\n }\n\n // Rate limit\n if (isRateLimited(ip)) {\n return json({ status: \"failure\", message: \"Rate limit exceeded (50 req/min)\" }, 429);\n }\n\n // Parse body\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 // Direct adapter call\n if (path === \"/adapter\") {\n const { adapter, action, data } = payload;\n if (!adapter) return json({ status: \"failure\", message: \"Missing 'adapter' field\" }, 400);\n const result = await callAdapterDirect(adapter, action || \"default\", data || {});\n return json({\n status: result.success ? \"success\" : \"failure\",\n task_id: `adapter_${Date.now()}`,\n data: result.data,\n message: result.message,\n adapter: result.adapter,\n action: result.action,\n });\n }\n\n // Main task dispatch (POST /)\n const task = payload?.task || \"general\";\n const data = payload?.data || {};\n const mode = payload?.mode || \"AUTO\";\n\n try {\n const response = await dispatchTask(task, data, mode);\n return json(response, response.status === \"success\" ? 200 : 500);\n } catch (e: any) {\n return json({\n status: \"failure\",\n task_id: `err_${Date.now()}`,\n data: {},\n message: `Internal error: ${e.message}`,\n }, 500);\n }\n}\n","label","nexuses-core-os",[139],"34570400-5ece-40e9-8e11-7d92e6dee8f8","hf.ts","dda7eed4-790e-11f1-8185-1607ee4eb77e",16,["D",1783324640839],1,"// Hugging Face Model Orchestration — Nexuses Core OS V9.0\n// Dynamic model selection, timeout handling, and fallback chains.\n// Free-tier optimized.\n\n// --- Model Registry ---\n\nexport type ModelKey = \"qwen_coder\" | \"llama\" | \"phi3\" | \"mistral\";\nexport type TaskType = \"coding\" | \"creative\" | \"analysis\" | \"general\";\n\ninterface ModelConfig {\n id: string;\n label: string;\n bestFor: TaskType[];\n keywords: string[];\n maxTokens: number;\n temperature: number;\n fallback: ModelKey | null;\n}\n\nexport const HF_MODELS: Record = {\n qwen_coder: {\n id: \"Qwen/Qwen2.5-Coder-7B-Instruct\",\n label: \"Qwen2.5 Coder 7B\",\n bestFor: [\"coding\"],\n keywords: [\"code\", \"coding\", \"debug\", \"bug\", \"fix\", \"program\", \"refactor\", \"compile\", \"syntax\", \"error\", \"deploy\", \"devops\", \"github\", \"repo\", \"vscode\", \"commit\"],\n maxTokens: 800,\n temperature: 0.3,\n fallback: \"mistral\",\n },\n llama: {\n id: \"meta-llama/Meta-Llama-3-8B-Instruct\",\n label: \"Llama 3 8B Instruct\",\n bestFor: [\"creative\"],\n keywords: [\"write\", \"writing\", \"blog\", \"content\", \"article\", \"story\", \"creative\", \"social\", \"post\", \"voice\", \"website\", \"clone\", \"html\", \"css\", \"landing\", \"seo\", \"media\"],\n maxTokens: 1000,\n temperature: 0.8,\n fallback: \"mistral\",\n },\n phi3: {\n id: \"microsoft/Phi-3-mini-4k-instruct\",\n label: \"Phi-3 Mini 4K\",\n bestFor: [\"analysis\", \"general\"],\n keywords: [\"analyze\", \"analysis\", \"data\", \"scrape\", \"pdf\", \"excel\", \"word\", \"billing\", \"invoice\", \"report\", \"csv\", \"spreadsheet\", \"summarize\", \"extract\", \"research\", \"search\", \"crypto\", \"price\", \"market\", \"automation\"],\n maxTokens: 500,\n temperature: 0.5,\n fallback: \"mistral\",\n },\n mistral: {\n id: \"mistralai/Mistral-7B-Instruct-v0.2\",\n label: \"Mistral 7B Instruct\",\n bestFor: [\"general\"],\n keywords: [\"general\", \"help\", \"reasoning\", \"chat\", \"question\", \"explain\", \"unknown\", \"test\"],\n maxTokens: 500,\n temperature: 0.7,\n fallback: null,\n },\n};\n\n// --- Environment / Token ---\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// --- Task Classification ---\n\n/**\n * Classifies a task string into a TaskType by keyword matching.\n * This runs BEFORE any API call to determine which model to use.\n */\nexport function classifyTask(taskText: string): TaskType {\n const lower = taskText.toLowerCase();\n\n // Score each model by keyword hits\n const scores: Record = {\n coding: 0,\n creative: 0,\n analysis: 0,\n general: 0,\n };\n\n for (const cfg of Object.values(HF_MODELS)) {\n for (const type of cfg.bestFor) {\n scores[type] += cfg.keywords.filter((k) => lower.includes(k)).length;\n }\n }\n\n // Pick the highest-scoring type\n let best: TaskType = \"general\";\n let bestScore = 0;\n for (const [type, score] of Object.entries(scores)) {\n if (score > bestScore) {\n bestScore = score;\n best = type as TaskType;\n }\n }\n\n return best;\n}\n\n/**\n * Maps a TaskType to the best ModelKey.\n */\nexport function modelForTaskType(type: TaskType): ModelKey {\n switch (type) {\n case \"coding\": return \"qwen_coder\";\n case \"creative\": return \"llama\";\n case \"analysis\": return \"phi3\";\n default: return \"mistral\";\n }\n}\n\n/**\n * Dynamically selects the best HF model for the given task text.\n * Analyzes the task type first, then maps to the specialized model.\n */\nexport function selectModel(taskText: string): ModelKey {\n const taskType = classifyTask(taskText);\n return modelForTaskType(taskType);\n}\n\n// --- HF API Call ---\n\nexport interface HFResult {\n success: boolean;\n model: ModelKey;\n modelId: string;\n text: string;\n taskType: TaskType;\n error?: string;\n timedOut?: boolean;\n attempts?: ModelKey[];\n}\n\ninterface CallOptions {\n maxTokens?: number;\n temperature?: number;\n timeoutMs?: number;\n}\n\n/**\n * Calls a single HF model with timeout protection.\n */\nasync function callSingleModel(\n modelKey: ModelKey,\n prompt: string,\n token: string,\n opts: CallOptions = {},\n): Promise {\n const cfg = HF_MODELS[modelKey];\n const timeoutMs = opts.timeoutMs ?? 25000;\n const taskType = classifyTask(prompt);\n\n const controller = new AbortController();\n const timeoutId = setTimeout(() => controller.abort(), timeoutMs);\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: opts.maxTokens ?? cfg.maxTokens,\n temperature: opts.temperature ?? cfg.temperature,\n return_full_text: false,\n },\n }),\n signal: controller.signal,\n },\n );\n\n clearTimeout(timeoutId);\n\n if (!res.ok) {\n const errBody = await res.text().catch(() => \"\");\n return {\n success: false,\n model: modelKey,\n modelId: cfg.id,\n text: \"\",\n taskType,\n error: `HTTP ${res.status}: ${errBody.slice(0, 200)}`,\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 taskType,\n };\n } catch (e: any) {\n clearTimeout(timeoutId);\n const timedOut = e.name === \"AbortError\";\n return {\n success: false,\n model: modelKey,\n modelId: cfg.id,\n text: \"\",\n taskType,\n error: timedOut ? `Timeout after ${timeoutMs}ms` : e.message,\n timedOut,\n };\n }\n}\n\n/**\n * Calls Hugging Face with automatic fallback.\n * 1. Selects the best model for the task (or uses the specified one).\n * 2. If that model fails or times out, tries the fallback model.\n * 3. Returns the first successful result, or the last error.\n */\nexport async function callHFWithFallback(\n prompt: string,\n modelOverride?: ModelKey,\n opts: CallOptions = {},\n): Promise {\n const token = getHFToken();\n\n if (!token) {\n return {\n success: false,\n model: modelOverride || selectModel(prompt),\n modelId: HF_MODELS[modelOverride || selectModel(prompt)].id,\n text: \"\",\n taskType: classifyTask(prompt),\n error: \"HF_API_KEY not configured. Set it in environment variables.\",\n attempts: [],\n };\n }\n\n const primaryModel = modelOverride || selectModel(prompt);\n const attempts: ModelKey[] = [];\n\n // Build fallback chain: primary → its fallback → mistral (if different)\n const chain: ModelKey[] = [primaryModel];\n const fb1 = HF_MODELS[primaryModel].fallback;\n if (fb1 && !chain.includes(fb1)) chain.push(fb1);\n if (!chain.includes(\"mistral\")) chain.push(\"mistral\");\n\n let lastResult: HFResult | null = null;\n\n for (const modelKey of chain) {\n attempts.push(modelKey);\n console.log(`[HF] Trying model: ${HF_MODELS[modelKey].label} (${HF_MODELS[modelKey].id})`);\n\n const result = await callSingleModel(modelKey, prompt, token, opts);\n lastResult = result;\n\n if (result.success) {\n result.attempts = attempts;\n if (attempts.length > 1) {\n console.log(`[HF] Success on fallback model: ${HF_MODELS[modelKey].label}`);\n }\n return result;\n }\n\n console.log(`[HF] Model ${HF_MODELS[modelKey].label} failed: ${result.error}`);\n // Continue to next model in chain\n }\n\n // All models failed\n lastResult!.attempts = attempts;\n return lastResult!;\n}\n\n/**\n * Backwards-compatible wrapper — calls callHFWithFallback and\n * returns the same shape as the old callHF.\n */\nexport async function callHF(\n prompt: string,\n model?: ModelKey,\n maxTokens?: number,\n temperature?: number,\n): Promise {\n return callHFWithFallback(prompt, model, { maxTokens, temperature });\n}\n\n// --- Discovery ---\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 fallback: cfg.fallback,\n status: token ? \"AVAILABLE\" : \"NO_TOKEN\",\n }));\n}\n\nexport function getSelectionInfo(taskText: string) {\n const taskType = classifyTask(taskText);\n const modelKey = modelForTaskType(taskType);\n const cfg = HF_MODELS[modelKey];\n return {\n taskType,\n selectedModel: modelKey,\n modelId: cfg.id,\n modelLabel: cfg.label,\n fallbackModel: cfg.fallback,\n };\n}\n",[152],"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",[160],"756b7f35-048d-4e7c-9e28-529563d89287","UniversalAdapter.ts","dec8a808-790e-11f1-8185-1607ee4eb77e",11,["D",1783324019927],"// 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",[167],"08f1667e-88cc-4e10-aa58-5425934de374","TaskDispatcher.ts","fde83000-790e-11f1-9c16-1607ee4eb77e",21,["D",1783324747904],4,"// Task Dispatcher — Nexuses Core OS V9.0\n// Orchestrates the Analyze → Execute → Report pipeline.\nimport { routeIncomingTask, getAgentManifest } from \"./AgentManager.ts\";\nimport type { AgentResult } from \"./AgentManager.ts\";\nimport { listAdapters, routeToAdapter } from \"./UniversalAdapter.ts\";\nimport { getModelManifest, getHFToken, selectModel, getSelectionInfo, classifyTask } from \"./hf.ts\";\nimport type { TaskType } from \"./hf.ts\";\nimport {\n initDB,\n insertTask,\n updateTaskStatus,\n getTask,\n logWorkflowStep,\n remember,\n recall,\n getRecentTasks,\n getTaskCount,\n} from \"./db.ts\";\n\nexport interface DispatchResponse {\n status: \"success\" | \"failure\";\n task_id: string;\n data: any;\n message: string;\n agent?: string;\n category?: string;\n model?: string;\n modelId?: string;\n taskType?: TaskType;\n fallbackUsed?: boolean;\n attempts?: string[];\n adapters?: string[];\n executionTimeMs: number;\n timestamp: string;\n}\n\nfunction generateTaskId(): string {\n return `nxs_${Date.now()}_${Math.random().toString(36).slice(2, 8)}`;\n}\n\n// --- Public Dispatch API ---\n\nexport async function dispatchTask(\n task: string,\n data: any = {},\n mode = \"AUTO\",\n): Promise {\n const start = Date.now();\n const taskId = generateTaskId();\n\n // Ensure DB is ready\n await initDB();\n\n // PHASE 1: ANALYZE — deconstruct the task, identify agents + model\n const agents = getAgentManifest();\n const taskLower = task.toLowerCase();\n\n // Identify which agents could handle this task\n const candidates = agents.filter((a) =>\n a.keywords.some((k) => taskLower.includes(k))\n );\n\n // Dynamic model selection — classify task type before any API call\n const selection = getSelectionInfo(task);\n\n await logWorkflowStep(taskId, 1, \"TaskDispatcher\", \"ANALYZE\",\n `Task: \"${task}\" | Type: ${selection.taskType} | Model: ${selection.modelLabel} (${selection.modelId}) | Fallback: ${selection.fallbackModel || \"none\"} | Candidates: ${candidates.map((a) => a.name).join(\", \") || \"GeneralHandler\"}`);\n\n // Record initial task state\n await insertTask(taskId, task, \"pending\", \"processing\", { task, data, mode }, null);\n\n // Recall any memory related to this task type\n const memoryKey = `task_type:${candidates[0]?.name || \"general\"}`;\n const priorMemory = await recall(memoryKey);\n\n // PHASE 2: EXECUTE — route to selected agent\n await logWorkflowStep(taskId, 2, \"TaskDispatcher\", \"EXECUTE\",\n `Routing to agent for execution`);\n\n const agentResult: AgentResult = await routeIncomingTask(task, data, mode, true);\n\n await logWorkflowStep(taskId, 3, agentResult.agent, agentResult.status,\n agentResult.message);\n\n // PHASE 3: REPORT — build structured response\n const isSuccess = agentResult.status === \"SUCCESS\" || agentResult.status === \"PARTIAL\";\n const response: DispatchResponse = {\n status: agentResult.status === \"ERROR\" ? \"failure\" : \"success\",\n task_id: taskId,\n data: agentResult.data,\n message: agentResult.message,\n agent: agentResult.agent,\n category: agentResult.category,\n model: agentResult.model,\n modelId: agentResult.modelId,\n taskType: agentResult.taskType || selection.taskType,\n fallbackUsed: agentResult.fallbackUsed,\n attempts: agentResult.attempts,\n adapters: agentResult.adapters || [],\n executionTimeMs: Date.now() - start,\n timestamp: new Date().toISOString(),\n };\n\n // Update task in DB\n await updateTaskStatus(taskId, isSuccess ? \"completed\" : \"failed\", response);\n\n // Save to memory for future reference\n await remember(memoryKey, {\n lastTask: task,\n lastAgent: agentResult.agent,\n lastStatus: agentResult.status,\n lastModel: agentResult.model,\n fallbackUsed: agentResult.fallbackUsed,\n timestamp: new Date().toISOString(),\n ...(priorMemory ? { previous: priorMemory } : {}),\n });\n\n await logWorkflowStep(taskId, 4, \"TaskDispatcher\", \"REPORT\",\n `Status: ${response.status} | Model: ${response.model || \"N/A\"}${response.fallbackUsed ? \" (FALLBACK)\" : \"\"} | Time: ${response.executionTimeMs}ms`);\n\n return response;\n}\n\n// --- Status & Discovery ---\n\nexport async function getTaskStatus(taskId: string) {\n return getTask(taskId);\n}\n\nexport async function getHistory(limit = 20) {\n return getRecentTasks(limit);\n}\n\nexport async function getSystemStatus() {\n await initDB();\n const taskCount = await getTaskCount();\n const token = getHFToken();\n\n return {\n status: \"ONLINE\",\n service: \"Nexuses Core OS V9.0\",\n uptime: \"24/7 on Val Town\",\n persistence: \"SQLite (project-scoped)\",\n tasksProcessed: taskCount,\n hfIntegration: token ? \"ACTIVE\" : \"NOT_CONFIGURED\",\n models: getModelManifest(),\n agents: getAgentManifest().map((a) => ({\n name: a.name,\n category: a.category,\n capabilities: a.capabilities,\n })),\n adapters: listAdapters(),\n endpoints: {\n POST: {\n \"/\": \"Dispatch task (requires auth)\",\n \"/adapter\": \"Direct adapter call (requires auth)\",\n },\n GET: {\n \"/\": \"System discovery\",\n \"/status\": \"System status & stats\",\n \"/task/:id\": \"Get task result by ID\",\n \"/history\": \"Recent task history\",\n \"/agents\": \"Agent manifest\",\n \"/adapters\": \"Available adapters\",\n \"/models\": \"Available HF models\",\n },\n },\n example: {\n url: \"POST /\",\n headers: { \"Authorization\": \"Bearer YOUR_API_KEY\", \"Content-Type\": \"application/json\" },\n body: { task: \"debug my code\", data: { code: \"function add(a,b){return a-b}\" } },\n },\n };\n}\n\nexport async function callAdapterDirect(name: string, action: string, data: any) {\n return routeToAdapter(name, action, data);\n}\n",[174],"9aa2f928-6cce-42b0-8ffb-6a799065c655",["D",1783325456116],[33],"f64762d2-b824-4ee2-a83f-d26126dfba90","AgentManager.ts","f7361f90-790b-11f1-95a6-1607ee4eb77e",17,["D",1783324678945],"// Agent Swarm — Nexuses Core OS V9.0\n// Three primary agents: DevOps/Coding, Web/Content, Data/Automation\n// All agents use callHFWithFallback for automatic model failover.\nimport { callHFWithFallback, classifyTask, getSelectionInfo, getHFToken } from \"./hf.ts\";\nimport type { ModelKey, TaskType, HFResult } from \"./hf.ts\";\nimport { routeToAdapter, listAdapters } from \"./UniversalAdapter.ts\";\n\nexport interface AgentResult {\n agent: string;\n category: string;\n status: \"SUCCESS\" | \"ERROR\" | \"PARTIAL\";\n message: string;\n data: any;\n model?: ModelKey;\n modelId?: string;\n taskType?: TaskType;\n fallbackUsed?: boolean;\n attempts?: ModelKey[];\n adapters?: string[];\n}\n\nexport interface AgentManifestEntry {\n name: string;\n category: string;\n keywords: string[];\n capabilities: string[];\n model: ModelKey;\n adapters: string[];\n}\n\n// --- Agent Registry ---\n\nexport const AGENT_REGISTRY: AgentManifestEntry[] = [\n {\n name: \"DevOpsCodingAgent\",\n category: \"DevOps/Coding\",\n keywords: [\"code\", \"coding\", \"debug\", \"bug\", \"fix\", \"github\", \"repo\", \"program\", \"vscode\", \"vs code\", \"commit\", \"deploy\", \"devops\", \"refactor\", \"compile\", \"syntax\", \"error\"],\n capabilities: [\"VS Code integration\", \"GitHub repo management\", \"Error finding & fixing\", \"Bug resolution\", \"Auto-writing code\", \"Code explanation\"],\n model: \"qwen_coder\",\n adapters: [\"github\"],\n },\n {\n name: \"WebContentAgent\",\n category: \"Web/Content\",\n keywords: [\"write\", \"blog\", \"content\", \"article\", \"social\", \"post\", \"website\", \"clone\", \"scrape\", \"web\", \"voice\", \"html\", \"css\", \"landing\", \"seo\", \"tweet\", \"facebook\", \"media\"],\n capabilities: [\"Web automation\", \"Website cloning\", \"Social media posting\", \"Content writing\", \"Blogging\", \"Voice-enabled website generation\"],\n model: \"llama\",\n adapters: [\"webscraper\", \"duckduckgo\"],\n },\n {\n name: \"DataAutomationAgent\",\n category: \"Data/Automation\",\n keywords: [\"data\", \"scrape\", \"analyze\", \"pdf\", \"excel\", \"word\", \"billing\", \"invoice\", \"entry\", \"scan\", \"spreadsheet\", \"csv\", \"report\", \"automation\", \"crypto\", \"price\", \"market\"],\n capabilities: [\"Data scraping & analysis\", \"PDF conversion/creation\", \"Billing/data entry\", \"MS Word/Excel automation\", \"Document scanning\"],\n model: \"phi3\",\n adapters: [\"coingecko\", \"duckduckgo\", \"webscraper\"],\n },\n {\n name: \"GeneralHandler\",\n category: \"General\",\n keywords: [\"general\", \"help\", \"unknown\", \"test\", \"explain\", \"reasoning\", \"question\", \"chat\"],\n capabilities: [\"General task handling\", \"Fallback routing\"],\n model: \"mistral\",\n adapters: [],\n },\n];\n\nexport function getAgentManifest() {\n return AGENT_REGISTRY;\n}\n\nfunction matchAgent(task: string): AgentManifestEntry {\n const cmd = task.toLowerCase();\n let best: AgentManifestEntry | null = null;\n let bestScore = 0;\n for (const agent of AGENT_REGISTRY) {\n const score = agent.keywords.filter((k) => cmd.includes(k)).length;\n if (score > bestScore) {\n bestScore = score;\n best = agent;\n }\n }\n return best || AGENT_REGISTRY[AGENT_REGISTRY.length - 1];\n}\n\n/**\n * Builds an AgentResult from an HFResult, including fallback metadata.\n */\nfunction buildAgentResult(\n agentName: string,\n category: string,\n hfResult: HFResult,\n message: string,\n data: any,\n adapters: string[] = [],\n): AgentResult {\n const fallbackUsed = (hfResult.attempts?.length ?? 1) > 1 && hfResult.success;\n return {\n agent: agentName,\n category,\n status: hfResult.success ? \"SUCCESS\" : \"ERROR\",\n message: hfResult.success\n ? message\n : hfResult.error || \"HF model error\",\n data,\n model: hfResult.model,\n modelId: hfResult.modelId,\n taskType: hfResult.taskType,\n fallbackUsed,\n attempts: hfResult.attempts,\n adapters,\n };\n}\n\n// --- Agent Execution Functions ---\n\nconst AGENT_MAP: Record Promise> = {};\n\n// 1. DevOps / Coding Agent — uses Qwen2.5-Coder with fallback to Mistral\nAGENT_MAP[\"DevOpsCodingAgent\"] = async (task: string, data: any) => {\n const prompt = data.prompt || data.code || task;\n const action = data.action || \"analyze\";\n\n // GitHub operations via Universal Adapter\n if (data.github) {\n const ghResult = await routeToAdapter(\"github\", data.github.action || \"get_repo\", data.github);\n if (ghResult.success) {\n const hfResult = await callHFWithFallback(\n `Analyze this GitHub data and provide insights: ${JSON.stringify(ghResult.data).slice(0, 1000)}`,\n \"qwen_coder\",\n { maxTokens: 500 },\n );\n return {\n agent: \"DevOpsCodingAgent\",\n category: \"DevOps/Coding\",\n status: hfResult.success ? \"SUCCESS\" : \"PARTIAL\",\n message: `GitHub ${data.github.action || \"operation\"} completed${hfResult.success ? \" + AI analysis\" : \"\"}`,\n data: { github: ghResult.data, analysis: hfResult.text || hfResult.error },\n model: hfResult.model,\n modelId: hfResult.modelId,\n taskType: hfResult.taskType,\n fallbackUsed: (hfResult.attempts?.length ?? 1) > 1 && hfResult.success,\n attempts: hfResult.attempts,\n adapters: [\"github\"],\n };\n }\n return {\n agent: \"DevOpsCodingAgent\",\n category: \"DevOps/Coding\",\n status: \"ERROR\",\n message: ghResult.message,\n data: {},\n adapters: [\"github\"],\n };\n }\n\n // Code analysis / bug fixing / code writing\n const codePrompt = action === \"fix\"\n ? `Find and fix the bug in this code:\\n${prompt}`\n : action === \"explain\"\n ? `Explain this code:\\n${prompt}`\n : action === \"write\"\n ? `Write code for: ${prompt}`\n : `Analyze this code for errors and improvements:\\n${prompt}`;\n\n const hfResult = await callHFWithFallback(codePrompt, \"qwen_coder\", { maxTokens: 800, temperature: 0.3 });\n\n return buildAgentResult(\n \"DevOpsCodingAgent\",\n \"DevOps/Coding\",\n hfResult,\n `Code ${action} completed using ${HF_LABEL(hfResult.model)}`,\n { action, input: prompt.slice(0, 500), output: hfResult.text },\n );\n};\n\n// 2. Web / Content Agent — uses Llama 3 with fallback to Mistral\nAGENT_MAP[\"WebContentAgent\"] = async (task: string, data: any) => {\n const prompt = data.prompt || task;\n const action = data.action || \"write\";\n\n // Website cloning / scraping\n if (data.url || action === \"scrape\" || action === \"clone\") {\n const scrapeResult = await routeToAdapter(\"webscraper\", \"scrape\", { url: data.url });\n if (scrapeResult.success && action === \"clone\") {\n const hfResult = await callHFWithFallback(\n `Create a simple HTML page based on this scraped content:\\nTitle: ${scrapeResult.data.title}\\nContent: ${scrapeResult.data.textContent?.slice(0, 800)}`,\n \"llama\",\n { maxTokens: 800 },\n );\n return {\n agent: \"WebContentAgent\",\n category: \"Web/Content\",\n status: hfResult.success ? \"SUCCESS\" : \"PARTIAL\",\n message: `Website cloned: ${scrapeResult.data.title}`,\n data: {\n original: { url: data.url, title: scrapeResult.data.title },\n clone: hfResult.text || \"\",\n links: scrapeResult.data.links,\n },\n model: hfResult.model,\n modelId: hfResult.modelId,\n taskType: hfResult.taskType,\n fallbackUsed: (hfResult.attempts?.length ?? 1) > 1 && hfResult.success,\n attempts: hfResult.attempts,\n adapters: [\"webscraper\"],\n };\n }\n if (scrapeResult.success) {\n return {\n agent: \"WebContentAgent\",\n category: \"Web/Content\",\n status: \"SUCCESS\",\n message: `Scraped: ${scrapeResult.data.title}`,\n data: scrapeResult.data,\n adapters: [\"webscraper\"],\n };\n }\n }\n\n // Content writing / blogging / social media\n const contentPrompt = action === \"social\"\n ? `Write a social media post about: ${prompt}`\n : action === \"blog\"\n ? `Write a blog post about: ${prompt}`\n : action === \"voice\"\n ? `Generate voice-ready website content for: ${prompt}`\n : `Write content about: ${prompt}`;\n\n const hfResult = await callHFWithFallback(contentPrompt, \"llama\", { maxTokens: 1000, temperature: 0.8 });\n\n return buildAgentResult(\n \"WebContentAgent\",\n \"Web/Content\",\n hfResult,\n `Content generated using ${HF_LABEL(hfResult.model)}`,\n { action, content: hfResult.text },\n );\n};\n\n// 3. Data / Automation Agent — uses Phi-3 with fallback to Mistral\nAGENT_MAP[\"DataAutomationAgent\"] = async (task: string, data: any) => {\n const prompt = data.prompt || task;\n const action = data.action || \"analyze\";\n\n // Crypto signals (no HF needed — direct adapter)\n if (action === \"crypto\" || prompt.toLowerCase().includes(\"crypto\") || prompt.toLowerCase().includes(\"price\")) {\n const cgResult = await routeToAdapter(\"coingecko\", \"price\", { coins: data.coins });\n if (cgResult.success) {\n return {\n agent: \"DataAutomationAgent\",\n category: \"Data/Automation\",\n status: \"SUCCESS\",\n message: \"Crypto signals generated\",\n data: cgResult.data,\n adapters: [\"coingecko\"],\n };\n }\n }\n\n // Data scraping + analysis\n if (data.url || action === \"scrape\") {\n const scrapeResult = await routeToAdapter(\"webscraper\", \"scrape\", { url: data.url });\n if (scrapeResult.success) {\n const hfResult = await callHFWithFallback(\n `Analyze this scraped data and provide a summary:\\n${scrapeResult.data.textContent?.slice(0, 1000)}`,\n \"phi3\",\n { maxTokens: 400 },\n );\n return {\n agent: \"DataAutomationAgent\",\n category: \"Data/Automation\",\n status: hfResult.success ? \"SUCCESS\" : \"PARTIAL\",\n message: \"Data scraped and analyzed\",\n data: {\n source: data.url,\n title: scrapeResult.data.title,\n analysis: hfResult.text || \"Analysis unavailable\",\n raw: scrapeResult.data,\n },\n model: hfResult.model,\n modelId: hfResult.modelId,\n taskType: hfResult.taskType,\n fallbackUsed: (hfResult.attempts?.length ?? 1) > 1 && hfResult.success,\n attempts: hfResult.attempts,\n adapters: [\"webscraper\"],\n };\n }\n }\n\n // Research via DuckDuckGo + HF summarization\n if (action === \"research\" || action === \"search\") {\n const ddgResult = await routeToAdapter(\"duckduckgo\", \"search\", { query: prompt });\n if (ddgResult.success) {\n const hfResult = await callHFWithFallback(\n `Summarize this research data:\\n${JSON.stringify(ddgResult.data).slice(0, 800)}`,\n \"phi3\",\n { maxTokens: 400 },\n );\n return {\n agent: \"DataAutomationAgent\",\n category: \"Data/Automation\",\n status: hfResult.success ? \"SUCCESS\" : \"PARTIAL\",\n message: \"Research completed and summarized\",\n data: {\n search: ddgResult.data,\n summary: hfResult.text || \"\",\n },\n model: hfResult.model,\n modelId: hfResult.modelId,\n taskType: hfResult.taskType,\n fallbackUsed: (hfResult.attempts?.length ?? 1) > 1 && hfResult.success,\n attempts: hfResult.attempts,\n adapters: [\"duckduckgo\"],\n };\n }\n }\n\n // General data analysis\n const hfResult = await callHFWithFallback(`Analyze and process: ${prompt}`, \"phi3\", { maxTokens: 500, temperature: 0.5 });\n\n return buildAgentResult(\n \"DataAutomationAgent\",\n \"Data/Automation\",\n hfResult,\n \"Data analysis completed\",\n { action, result: hfResult.text },\n );\n};\n\n// 4. General Handler — uses Mistral (no further fallback)\nAGENT_MAP[\"GeneralHandler\"] = async (task: string, data: any) => {\n const hfResult = await callHFWithFallback(data.prompt || task, \"mistral\", { maxTokens: 500 });\n\n return buildAgentResult(\n \"GeneralHandler\",\n \"General\",\n hfResult,\n \"Task processed\",\n { input: task, response: hfResult.text || \"\" },\n );\n};\n\n// --- Helpers ---\n\nfunction HF_LABEL(key: ModelKey): string {\n const labels: Record = {\n qwen_coder: \"Qwen2.5-Coder\",\n llama: \"Llama 3\",\n phi3: \"Phi-3 Mini\",\n mistral: \"Mistral 7B\",\n };\n return labels[key] || key;\n}\n\n// --- Public Routing API ---\n\nexport async function routeIncomingTask(\n task: string,\n data: any = {},\n mode = \"AUTO\",\n debug = false,\n): Promise {\n const agentEntry = matchAgent(task);\n const agentFn = AGENT_MAP[agentEntry.name] || AGENT_MAP[\"GeneralHandler\"];\n\n try {\n const result = await agentFn(task, data);\n if (debug) {\n console.log(\n `[Dispatcher] Task: \"${task}\" → Agent: ${result.agent} → Model: ${result.model || \"N/A\"} → Status: ${result.status}${result.fallbackUsed ? \" (FALLBACK)\" : \"\"}`,\n );\n }\n return result;\n } catch (e: any) {\n return {\n agent: agentEntry.name,\n category: agentEntry.category,\n status: \"ERROR\",\n message: `Agent execution error: ${e.message}`,\n data: {},\n };\n }\n}\n\nexport function getSystemInfo() {\n const token = getHFToken();\n return {\n agents: AGENT_REGISTRY.map((a) => ({\n name: a.name,\n category: a.category,\n capabilities: a.capabilities,\n model: a.model,\n })),\n adapters: listAdapters(),\n models: token ? \"Hugging Face ACTIVE\" : \"Hugging Face NOT_CONFIGURED\",\n };\n}\n",[185],"pulls","branches","forks","envVars",{"_198":65,"_200":65},"connections",{"_198":65,"_199":65},"count","unfilledCount","emptyCount",{"_47":184,"_37":185,"_35":186,"_141":-5,"_45":46,"_44":187,"_143":30,"_42":227,"_13":145,"_38":39,"_40":189,"_29":30,"_148":-5,"_209":228,"_32":229},{"_47":181,"_37":33,"_35":36,"_141":-5,"_45":46,"_44":14,"_143":126,"_42":224,"_13":65,"_38":39,"_40":41,"_29":30,"_148":-5,"_209":225,"_32":226},{"_47":173,"_37":174,"_35":175,"_141":-5,"_45":46,"_44":176,"_143":30,"_42":221,"_13":178,"_38":39,"_40":179,"_29":30,"_148":-5,"_209":222,"_32":223},{"_47":166,"_37":167,"_35":168,"_141":-5,"_45":46,"_44":169,"_143":126,"_42":218,"_13":65,"_38":39,"_40":171,"_29":30,"_148":-5,"_209":219,"_32":220},{"_47":159,"_37":160,"_35":161,"_141":-5,"_45":46,"_44":162,"_143":30,"_42":215,"_13":65,"_38":39,"_40":164,"_29":30,"_148":-5,"_209":216,"_32":217},{"_47":151,"_37":152,"_35":153,"_141":-5,"_45":46,"_44":154,"_143":126,"_42":212,"_13":156,"_38":39,"_40":157,"_29":30,"_148":-5,"_209":213,"_32":214},{"_47":138,"_37":139,"_35":140,"_141":-5,"_45":46,"_44":142,"_143":30,"_42":208,"_13":145,"_38":146,"_40":147,"_29":30,"_148":149,"_209":210,"_32":211},["D",1783324103933],"children",[],[139],["D",1783324640839],[],[152],["D",1783323999632],[],[160],["D",1783324019927],[],[167],["D",1783324747904],[],[174],["D",1783325456116],[],[33],["D",1783324678945],[],[185],["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,"_128":268,"_269":270,"_271":272,"_273":30,"_274":30,"_275":30,"_276":126,"_277":-5,"_278":-7,"_279":-7,"_280":65,"_281":30,"_282":30,"_283":-5,"_284":30,"_285":30,"_286":30,"_287":-5},"ENV",{"_239":240,"_241":242,"_243":92,"_244":245,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259,"_260":261,"_262":263,"_264":265,"_266":267},"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 · v22