[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_239":240,"_241":242},"routes/_app.x.$handle.$name",{"_99":98,"_32":45,"_106":89,"_27":36,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":25,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":36,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":25},"version",36,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","IAP.ts","latestPath","fileId","8da8a598-7924-11f1-b32d-1607ee4eb77e","name","fileType","script","content","","// Inter-Agent Protocol (IAP) — Nexuses Core OS V10.0\n// JSON-RPC 2.0 handshake, capability advertising, and recursive task delegation.\n\nimport {\n findExternalService,\n getServiceInfo,\n getServiceManifest,\n hasInternalCapability,\n} from \"./RegistryManager.ts\";\nimport type { ServiceManifest } from \"./RegistryManager.ts\";\nimport { logWorkflowStep } from \"./db.ts\";\n\n// --- JSON-RPC 2.0 Types ---\n\nexport interface JSONRPCRequest {\n jsonrpc: \"2.0\";\n method: string;\n params?: any;\n id?: string | number;\n}\n\nexport interface JSONRPCResponse {\n jsonrpc: \"2.0\";\n result?: any;\n error?: { code: number; message: string; data?: any };\n id: string | number | null;\n}\n\nexport interface HandshakeRequest {\n jsonrpc: \"2.0\";\n method: \"handshake\";\n params: {\n agent_id: string;\n agent_name: string;\n capabilities: string[];\n auth_token?: string;\n };\n id: string | number;\n}\n\nexport interface HandshakeResponse {\n jsonrpc: \"2.0\";\n result: {\n accepted: boolean;\n service: {\n service_id: string;\n service_name: string;\n version: string;\n protocol: string;\n };\n our_capabilities: string[];\n task_format: object;\n challenge: string;\n };\n id: string | number;\n}\n\n// --- Error Codes (JSON-RPC 2.0 standard) ---\n\nconst RPC_ERRORS = {\n PARSE_ERROR: { code: -32700, message: \"Parse error\" },\n INVALID_REQUEST: { code: -32600, message: \"Invalid Request\" },\n METHOD_NOT_FOUND: { code: -32601, message: \"Method not found\" },\n INVALID_PARAMS: { code: -32602, message: \"Invalid params\" },\n INTERNAL_ERROR: { code: -32603, message: \"Internal error\" },\n UNAUTHORIZED: {\n code: -32001,\n message: \"Unauthorized — invalid or missing auth token\",\n },\n CAPABILITY_NOT_FOUND: {\n code: -32002,\n message: \"Requested capability not available\",\n },\n DELEGATION_FAILED: { code: -32003, message: \"External delegation failed\" },\n};\n\nfunction rpcError(\n id: string | number | null,\n error: { code: number; message: string; data?: any },\n): JSONRPCResponse {\n return { jsonrpc: \"2.0\", error, id };\n}\n\nfunction rpcResult(id: string | number, result: any): JSONRPCResponse {\n return { jsonrpc: \"2.0\", result, id };\n}\n\n// --- Handshake Protocol ---\n\n/**\n * Processes an incoming handshake from an external AI agent.\n * Advertises our capabilities and returns the Universal Task Format.\n */\nexport async function processHandshake(\n req: HandshakeRequest,\n endpoint: string,\n): Promise {\n const manifest = getServiceManifest(endpoint);\n const ourCaps = manifest.capabilities.map((c) =>\n `${c.id}:${c.actions.join(\",\")}`\n );\n\n console.log(\n `[IAP] Handshake from agent: ${req.params.agent_id} (${req.params.agent_name})`,\n );\n console.log(\n `[IAP] Agent capabilities: ${req.params.capabilities.join(\", \")}`,\n );\n\n // Log the handshake\n await logWorkflowStep(\n `handshake_${Date.now()}`,\n 1,\n \"IAP\",\n \"HANDSHAKE\",\n `Agent: ${req.params.agent_id} | Capabilities: ${\n req.params.capabilities.join(\", \")\n }`,\n );\n\n return {\n jsonrpc: \"2.0\",\n result: {\n accepted: true,\n service: getServiceInfo(),\n our_capabilities: ourCaps,\n task_format: manifest.universal_task_format,\n challenge: `nxs_${Date.now()}_${Math.random().toString(36).slice(2, 12)}`,\n },\n id: req.id,\n };\n}\n\n// --- JSON-RPC Method Router ---\n\n/**\n * Processes a JSON-RPC 2.0 request.\n * Supported methods: handshake, discover, execute, delegate\n */\nexport async function processRPC(\n rpcReq: JSONRPCRequest,\n endpoint: string,\n dispatchFn: (task: string, data: any, mode: string) => Promise,\n): Promise {\n // Validate JSON-RPC structure\n if (rpcReq.jsonrpc !== \"2.0\" || !rpcReq.method) {\n return rpcError(rpcReq.id ?? null, RPC_ERRORS.INVALID_REQUEST);\n }\n\n switch (rpcReq.method) {\n case \"handshake\": {\n const hsReq = rpcReq as HandshakeRequest;\n if (!hsReq.params?.agent_id) {\n return rpcError(rpcReq.id ?? null, RPC_ERRORS.INVALID_PARAMS);\n }\n const result = await processHandshake(hsReq, endpoint);\n return result as unknown as JSONRPCResponse;\n }\n\n case \"discover\": {\n const manifest = getServiceManifest(endpoint);\n return rpcResult(rpcReq.id!, {\n service: getServiceInfo(),\n capabilities: manifest.capabilities,\n task_format: manifest.universal_task_format,\n });\n }\n\n case \"execute\": {\n const { task, data, mode } = rpcReq.params || {};\n if (!task) {\n return rpcError(rpcReq.id ?? null, {\n ...RPC_ERRORS.INVALID_PARAMS,\n data: \"Missing 'task' field\",\n });\n }\n try {\n const result = await dispatchFn(task, data || {}, mode || \"AUTO\");\n return rpcResult(rpcReq.id!, result);\n } catch (e: any) {\n return rpcError(rpcReq.id ?? null, {\n ...RPC_ERRORS.INTERNAL_ERROR,\n data: e.message,\n });\n }\n }\n\n case \"delegate\": {\n const { task, data, target } = rpcReq.params || {};\n if (!task) {\n return rpcError(rpcReq.id ?? null, {\n ...RPC_ERRORS.INVALID_PARAMS,\n data: \"Missing 'task' field\",\n });\n }\n const result = await delegateToExternal(task, data || {}, target);\n if (result.success) {\n return rpcResult(rpcReq.id!, result);\n }\n return rpcError(rpcReq.id ?? null, {\n ...RPC_ERRORS.DELEGATION_FAILED,\n data: result,\n });\n }\n\n default:\n return rpcError(rpcReq.id ?? null, {\n ...RPC_ERRORS.METHOD_NOT_FOUND,\n data: `Unknown method: ${rpcReq.method}`,\n });\n }\n}\n\n// --- Recursive Task Delegation ---\n\nexport interface DelegationResult {\n success: boolean;\n delegated: boolean;\n target: string | null;\n data: any;\n message: string;\n integrated: boolean;\n}\n\n/**\n * Delegates a sub-task to an external AI service when the OS lacks\n * the internal capability. Integrates the result back for the final JSON.\n */\nexport async function delegateToExternal(\n task: string,\n data: any,\n targetHint?: string,\n): Promise {\n // Find an external service that can handle this\n let service = targetHint ? findExternalService(targetHint) : null;\n if (!service) {\n const check = hasInternalCapability(task);\n // Try to find external service matching the task type\n service = findExternalService(check.taskType) ||\n findExternalService(task.toLowerCase());\n }\n\n if (!service) {\n return {\n success: false,\n delegated: false,\n target: null,\n data: {},\n message: \"No external service available for this capability\",\n integrated: false,\n };\n }\n\n console.log(\n `[IAP] Delegating to external service: ${service.name} (${service.url})`,\n );\n\n // Build the delegation request\n const token = service.authHeader?.includes(\"HF_API_KEY\")\n ? Deno.env.get(\"HF_API_KEY\") || Deno.env.get(\"HUGGING_FACE_TOKEN\")\n : service.authHeader?.includes(\"GITHUB_TOKEN\")\n ? Deno.env.get(\"GITHUB_TOKEN\")\n : null;\n\n try {\n let resultData: any;\n\n if (service.id.startsWith(\"hf\")) {\n // Hugging Face delegation\n const modelUrl = service.url;\n const res = await fetch(modelUrl, {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n inputs: data.prompt || task,\n parameters: { max_new_tokens: 500, return_full_text: false },\n }),\n signal: AbortSignal.timeout(25000),\n });\n if (!res.ok) {\n return {\n success: false,\n delegated: true,\n target: service.id,\n data: {},\n message: `External service returned HTTP ${res.status}`,\n integrated: false,\n };\n }\n const hfData = await res.json();\n resultData = Array.isArray(hfData) ? hfData[0] : hfData;\n } else {\n // Generic external API call\n const res = await fetch(service.url, {\n signal: AbortSignal.timeout(15000),\n });\n resultData = await res.json();\n }\n\n // Log the delegation\n await logWorkflowStep(\n `delegation_${Date.now()}`,\n 1,\n \"IAP\",\n \"DELEGATE\",\n `Task: \"${task}\" → Service: ${service.id} → Success`,\n );\n\n return {\n success: true,\n delegated: true,\n target: service.id,\n data: resultData,\n message: `Delegated to ${service.name} and integrated result`,\n integrated: true,\n };\n } catch (e: any) {\n console.log(`[IAP] Delegation failed: ${e.message}`);\n return {\n success: false,\n delegated: true,\n target: service.id,\n data: {},\n message: `Delegation error: ${e.message}`,\n integrated: false,\n };\n }\n}","createdAt",["D",1783333372363],"branchVersion","branchId","a3c45f44-a6a5-4863-ae36-4cd83638b86a","id","7b463a8c-5433-4b29-8c1d-34fea1276468","Gani",["D",1783331684771],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","50e8cc77-45b0-4f8e-8edc-a82482467e27","pinnedFileId","b764bf92-7920-11f1-804c-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f36d6-f2f6-772a-b24d-7503591bb3e7","tursoName","7b463a8c54334b298c1d34fea1276468","tursoHostname","7b463a8c54334b298c1d34fea1276468-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789522836959],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_99":98,"_105":36},"org",{"_99":98,"_100":36,"_101":36,"_18":54,"_102":103,"_104":25},"branch",{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"isOwned",91,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","gani","handle","displayName","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":234,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":36,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":235,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":236,"_83":237,"_85":238,"_87":25},"tree",[201,202,203,204,205,206,207,208],"files",[201,202,203,204,205,206,207,208],"counts",{"_191":62,"_192":141,"_193":62,"_194":195,"_196":197},"contents",[127,128,129,130,131,132,133,134],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":188,"_32":28,"_30":31,"_137":-5,"_41":42,"_40":14,"_139":25,"_38":189,"_13":138,"_33":34,"_35":37,"_24":25,"_143":-5,"_27":190},{"_43":181,"_32":182,"_30":183,"_137":-5,"_41":42,"_40":184,"_139":25,"_38":185,"_13":138,"_33":34,"_35":186,"_24":25,"_143":-5,"_27":187},{"_43":174,"_32":175,"_30":176,"_137":-5,"_41":42,"_40":177,"_139":25,"_38":178,"_13":138,"_33":34,"_35":179,"_24":25,"_143":-5,"_27":180},{"_43":167,"_32":168,"_30":169,"_137":-5,"_41":42,"_40":170,"_139":25,"_38":171,"_13":138,"_33":34,"_35":172,"_24":25,"_143":-5,"_27":173},{"_43":160,"_32":161,"_30":162,"_137":-5,"_41":42,"_40":163,"_139":25,"_38":164,"_13":138,"_33":34,"_35":165,"_24":25,"_143":-5,"_27":166},{"_43":153,"_32":154,"_30":155,"_137":-5,"_41":42,"_40":156,"_139":25,"_38":157,"_13":138,"_33":34,"_35":158,"_24":25,"_143":-5,"_27":159},{"_43":145,"_32":146,"_30":147,"_137":-5,"_41":42,"_40":148,"_139":25,"_38":149,"_13":150,"_33":34,"_35":151,"_24":25,"_143":-5,"_27":152},{"_43":135,"_32":136,"_30":56,"_137":-5,"_41":42,"_40":138,"_139":25,"_38":140,"_13":141,"_33":34,"_35":142,"_24":25,"_143":-5,"_27":144},"5a670743-65fb-4558-8cdd-71fbecbf1b41","main.ts","parentId",2,"latest",["D",1783331940818],1,"// Nexuses Core OS V10.0 — Universal AI Gateway\n// HTTP Entry Point with IAP, JSON-RPC, strict auth, and Dynamic Request Normalizer\n\nimport {\n callAdapterDirect,\n dispatchTask,\n getHistory,\n getSystemStatus,\n getTaskStatus,\n} from \"./TaskDispatcher.ts\";\nimport { getAgentManifest } from \"./AgentManager.ts\";\nimport { listAdapters } from \"./UniversalAdapter.ts\";\nimport { getModelManifest } from \"./hf.ts\";\nimport { initDB } from \"./db.ts\";\nimport { buildCapabilityList, getServiceManifest } from \"./RegistryManager.ts\";\nimport { processHandshake, processRPC } from \"./IAP.ts\";\nimport type { JSONRPCRequest } from \"./IAP.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 {\n return Deno.env.get(key);\n } catch {\n return undefined;\n }\n}\n\nfunction getEndpoint(req: Request): string {\n const url = new URL(req.url);\n return `${url.protocol}//${url.host}/`;\n}\n\n// --- Universal Request Normalizer ---\n// خود بخود ریکویسٹ کو پہچان کر فارمیٹ سیٹ کرتا ہے\nfunction normalizeRequest(payload: any) {\n const possibleTaskKeys = [\n \"task\",\n \"query\",\n \"prompt\",\n \"command\",\n \"message\",\n \"input\",\n \"body\",\n \"text\",\n ];\n let task = \"general\";\n let data = { ...payload };\n\n for (const key of possibleTaskKeys) {\n if (payload[key]) {\n task = payload[key];\n delete data[key];\n break;\n }\n }\n return { task, data };\n}\n\n// --- Auth Validation ---\nfunction validateAuth(req: Request): boolean {\n const apiKey = getEnv(\"NEXUSES_API_KEY\");\n if (!apiKey) return true; // Dev mode\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 ---\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; // 50 requests per minute\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 const endpoint = getEndpoint(req);\n\n await initDB();\n\n // --- GET Routes (Public Discovery) ---\n if (req.method === \"GET\") {\n if (path === \"/\" || path === \"\") return json(await getSystemStatus());\n if (path === \"/status\") return json(await getSystemStatus());\n if (path === \"/register\") return json(getServiceManifest(endpoint));\n if (path === \"/agents\") return json({ agents: getAgentManifest() });\n if (path === \"/adapters\") return json({ adapters: listAdapters() });\n if (path === \"/models\") return json({ models: getModelManifest() });\n if (path === \"/capabilities\") {\n return json({ capabilities: buildCapabilityList() });\n }\n if (path === \"/history\") {\n const limit = parseInt(url.searchParams.get(\"limit\") || \"20\");\n return json({ history: await getHistory(limit) });\n }\n const taskMatch = path.match(/^\\/task\\/(.+)$/);\n if (taskMatch) {\n const task = await getTaskStatus(taskMatch[1]);\n return task\n ? json({ task })\n : json({ status: \"failure\", message: \"Task not found\" }, 404);\n }\n return json({ error: \"Unknown endpoint\" }, 404);\n }\n\n // --- POST Routes ---\n if (req.method !== \"POST\") {\n return json({ error: \"Only GET and POST supported\" }, 405);\n }\n\n let payload: any;\n try {\n payload = await req.json();\n } catch {\n return json({ status: \"failure\", message: \"Invalid JSON body\" }, 400);\n }\n\n // 1. Public Task Endpoint (Normalizes request automatically)\n if (path === \"/public-task\") {\n if (isRateLimited(ip)) {\n return json({ status: \"failure\", message: \"Rate limit exceeded\" }, 429);\n }\n\n // یہاں Normalizer استعمال ہو رہا ہے\n const { task, data } = normalizeRequest(payload);\n\n const response = await dispatchTask(task, data, \"AUTO\");\n return json(response, response.status === \"success\" ? 200 : 500);\n }\n\n // 2. Strict Auth Check for ALL OTHER POST endpoints\n if (!validateAuth(req)) {\n return json({\n status: \"failure\",\n message: \"Unauthorized — provide valid Bearer token\",\n }, 401);\n }\n\n if (isRateLimited(ip)) {\n return json({ status: \"failure\", message: \"Rate limit exceeded\" }, 429);\n }\n\n // Protected Routes\n if (path === \"/rpc\") {\n const rpcResponse = await processRPC(\n payload as JSONRPCRequest,\n endpoint,\n dispatchTask,\n );\n return json(rpcResponse);\n }\n\n if (path === \"/handshake\") {\n if (payload.jsonrpc === \"2.0\" && payload.method === \"handshake\") {\n return json(await processHandshake(payload, endpoint));\n }\n return json({ error: \"Invalid handshake\" }, 400);\n }\n\n if (path === \"/adapter\") {\n const { adapter, action, data } = payload;\n const result = await callAdapterDirect(\n adapter,\n action || \"default\",\n data || {},\n );\n return json({\n status: result.success ? \"success\" : \"failure\",\n data: result.data,\n });\n }\n\n // Default Universal Task (Protected)\n const task = payload?.task || \"general\";\n const data = payload?.data || {};\n const response = await dispatchTask(task, data, payload?.mode || \"AUTO\");\n return json(response, response.status === \"success\" ? 200 : 500);\n}","label",[136],"ebb8c0b4-d70b-473f-ba8a-2796dbd8e7ac","hf.ts","73dfc540-7921-11f1-aa04-1607ee4eb77e",6,["D",1783332056080],3,"// HF Model Orchestration — Nexuses Core OS V10.0 (Adapter-Driven)\n// Now using UniversalAdapter to avoid tunnel/connection errors.\n\nimport { routeToAdapter } from \"./UniversalAdapter.ts\";\n\n// --- Model Registry (Updated with Mobile-Friendly Models) ---\nexport type ModelKey = \"qwen_coder\" | \"llama\" | \"phi3\" | \"mistral\";\nexport type TaskType = \"coding\" | \"creative\" | \"analysis\" | \"general\";\n\ninterface ModelConfig {\n id: string; // Hugging Face Model ID\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\"],\n maxTokens: 800,\n temperature: 0.3,\n fallback: \"mistral\",\n },\n llama: {\n id: \"meta-llama/Llama-3.2-1B-Instruct\",\n label: \"Llama 3.2 1B\",\n bestFor: [\"creative\"],\n keywords: [\"write\", \"writing\", \"blog\", \"story\", \"creative\", \"social\"],\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\", \"data\", \"report\", \"csv\", \"summarize\", \"search\"],\n maxTokens: 500,\n temperature: 0.5,\n fallback: \"mistral\",\n },\n mistral: {\n id: \"google/gemma-2-2b-it\", // Mistral ke bajaye ab Gemma 2B istemal hoga\n label: \"Gemma 2 2B\",\n bestFor: [\"general\"],\n keywords: [\"general\", \"help\", \"chat\", \"explain\", \"unknown\"],\n maxTokens: 500,\n temperature: 0.7,\n fallback: null,\n },\n};\n\n// --- Selection Logic ---\nexport function classifyTask(taskText: string): TaskType {\n const lower = taskText.toLowerCase();\n const scores = { coding: 0, creative: 0, analysis: 0, general: 0 };\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 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 return best;\n}\n\nexport function modelForTaskType(type: TaskType): ModelKey {\n switch (type) {\n case \"coding\":\n return \"qwen_coder\";\n case \"creative\":\n return \"llama\";\n case \"analysis\":\n return \"phi3\";\n default:\n return \"mistral\";\n }\n}\n\nexport function selectModel(taskText: string): ModelKey {\n return modelForTaskType(classifyTask(taskText));\n}\n\n// --- Integration with UniversalAdapter ---\nexport interface HFResult {\n success: boolean;\n model: ModelKey;\n modelId: string;\n text: string;\n taskType: TaskType;\n error?: string;\n attempts?: ModelKey[];\n}\n\nexport async function callHFWithFallback(\n prompt: string,\n modelOverride?: ModelKey,\n): Promise {\n const modelKey = modelOverride || selectModel(prompt);\n const cfg = HF_MODELS[modelKey];\n\n // یہاں ہم UniversalAdapter کو کال کر رہے ہیں (Tunnel Error کا حل)\n const result = await routeToAdapter(\"huggingface\", \"generate\", {\n task: prompt,\n model: cfg.id, // Adapter hamara dynamic model select karega\n });\n\n if (result.success) {\n return {\n success: true,\n model: modelKey,\n modelId: cfg.id,\n text: result.data.response,\n taskType: classifyTask(prompt),\n attempts: [modelKey],\n };\n }\n\n // اگر فیل ہو جائے تو ایرر واپس کریں\n return {\n success: false,\n model: modelKey,\n modelId: cfg.id,\n text: \"\",\n taskType: classifyTask(prompt),\n error: result.message,\n };\n}\n\nexport async function callHF(\n prompt: string,\n model?: ModelKey,\n): Promise {\n return callHFWithFallback(prompt, model);\n}\n\n// --- Discovery ---\nexport function getModelManifest() {\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: \"ADAPTER_LINKED\",\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\nexport function getHFToken() {\n return Deno.env.get(\"HF_API_KEY\");\n}",[146],"0a0d38fd-d55c-4459-903e-b9e6894c4cf2","db.ts","b7760422-7921-11f1-a660-1607ee4eb77e",9,["D",1783332132291],"// 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 `CREATE TABLE IF NOT EXISTS delegations (\n id TEXT PRIMARY KEY,\n task_id TEXT NOT NULL,\n target TEXT NOT NULL,\n task TEXT NOT NULL,\n status TEXT NOT NULL,\n result 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:\n `INSERT INTO tasks (id, task, agent, status, data, result, created_at, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n id,\n task,\n agent,\n status,\n JSON.stringify(data),\n JSON.stringify(result),\n now,\n now,\n ],\n });\n}\n\nexport async function updateTaskStatus(\n id: string,\n status: string,\n result: any,\n) {\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:\n `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:\n `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}",[154],"2e3fe2bf-c842-406a-be22-9836626f2f25","UniversalAdapter.ts","53ca729a-7922-11f1-b4ab-1607ee4eb77e",14,["D",1783332408482],"// Universal Adapter Layer — Nexuses Core OS V10.2\n// Features: Auto-Routing AI (Groq + HF), Smart Model Selection, Scraping, Search, Crypto.\n\nexport interface Adapter {\n name: string;\n type: \"api\" | \"browser\" | \"service\" | \"plugin\" | \"ai\";\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// --- Smart Model Router ---\nfunction selectBestModel(task: string): string {\n const t = task.toLowerCase();\n if (\n t.includes(\"code\") || t.includes(\"script\") || t.includes(\"function\") ||\n t.includes(\"debug\")\n ) {\n return \"Qwen/Qwen2-1.5B-Instruct\";\n }\n if (\n t.includes(\"calculate\") || t.includes(\"solve\") || t.includes(\"logic\") ||\n t.includes(\"math\")\n ) {\n return \"microsoft/Phi-3-mini-4k-instruct\";\n }\n if (\n t.includes(\"poem\") || t.includes(\"story\") || t.includes(\"explain\") ||\n t.includes(\"translate\")\n ) {\n return \"google/gemma-2-2b-it\";\n }\n return \"meta-llama/Llama-3.2-1B-Instruct\"; // Default for mobile\n}\n\n// --- 1. Groq Adapter (Fastest AI) ---\nconst GroqAdapter: Adapter = {\n name: \"groq\",\n type: \"ai\",\n status: \"active\",\n description: \"Primary AI: Fast Llama-3-8b\",\n async execute(action: string, data: any): Promise {\n const apiKey = Deno.env.get(\"GROQ_API_KEY\");\n if (!apiKey) {\n return {\n success: false,\n adapter: \"groq\",\n action,\n data: {},\n message: \"GROQ_API_KEY missing\",\n };\n }\n try {\n const response = await fetch(\n \"https://api.groq.com/openai/v1/chat/completions\",\n {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"llama3-8b-8192\",\n messages: [{ role: \"user\", content: data.prompt || data.task }],\n }),\n },\n );\n const result = await response.json();\n return {\n success: true,\n adapter: \"groq\",\n action: \"generate\",\n data: { response: result.choices[0].message.content },\n message: \"Success\",\n };\n } catch (e: any) {\n return {\n success: false,\n adapter: \"groq\",\n action,\n data: {},\n message: e.message,\n };\n }\n },\n};\n\n// --- 2. Hugging Face Adapter (Smart Router AI) ---\nconst HuggingFaceAdapter: Adapter = {\n name: \"huggingface\",\n type: \"ai\",\n status: \"active\",\n description: \"Small AI: Auto-selects Qwen, Phi-3, Gemma, Llama\",\n async execute(action: string, data: any): Promise {\n const apiKey = Deno.env.get(\"HF_API_KEY\");\n if (!apiKey) {\n return {\n success: false,\n adapter: \"huggingface\",\n action,\n data: {},\n message: \"HF_API_KEY missing\",\n };\n }\n\n const taskContent = data.prompt || data.task || \"\";\n const model = data.model || selectBestModel(taskContent);\n const url = `https://api-inference.huggingface.co/models/${model}`;\n\n try {\n const response = await fetch(url, {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n \"User-Agent\": \"NexusesCoreOS/1.0\",\n },\n body: JSON.stringify({ inputs: taskContent }),\n });\n const result = await response.json();\n const text = Array.isArray(result)\n ? (result[0]?.generated_text || result[0]?.text)\n : (result.generated_text || result.text || result);\n return {\n success: true,\n adapter: \"huggingface\",\n action: \"generate\",\n data: { response: text, modelUsed: model },\n message: `Used ${model}`,\n };\n } catch (e: any) {\n return {\n success: false,\n adapter: \"huggingface\",\n action,\n data: {},\n message: e.message,\n };\n }\n },\n};\n\n// --- 3. GitHub Adapter ---\nconst GitHubAdapter: Adapter = {\n name: \"github\",\n type: \"api\",\n status: \"active\",\n description: \"GitHub management\",\n async execute(action: string, data: any) {\n const token = Deno.env.get(\"GITHUB_TOKEN\");\n return {\n success: !!token,\n adapter: \"github\",\n action,\n data: {},\n message: token ? \"GitHub ready\" : \"Token missing\",\n };\n },\n};\n\n// --- 4. DuckDuckGo Adapter ---\nconst DuckDuckGoAdapter: Adapter = {\n name: \"duckduckgo\",\n type: \"service\",\n status: \"active\",\n description: \"Web search\",\n async execute(action: string, data: any) {\n const res = await fetch(\n `https://api.duckduckgo.com/?q=${\n encodeURIComponent(data.query || data.q)\n }&format=json`,\n );\n const result = await res.json();\n return {\n success: true,\n adapter: \"duckduckgo\",\n action: \"search\",\n data: result,\n message: \"Search complete\",\n };\n },\n};\n\n// --- 5. CoinGecko Adapter ---\nconst CoinGeckoAdapter: Adapter = {\n name: \"coingecko\",\n type: \"api\",\n status: \"active\",\n description: \"Crypto prices\",\n async execute(action: string, data: any) {\n return {\n success: true,\n adapter: \"coingecko\",\n action: \"price\",\n data: { signals: \"BTC: 60k\" },\n message: \"OK\",\n };\n },\n};\n\n// --- 6. WebScraper Adapter ---\nconst WebScraperAdapter: Adapter = {\n name: \"webscraper\",\n type: \"browser\",\n status: \"active\",\n description: \"Scrape content\",\n async execute(action: string, data: any) {\n return {\n success: true,\n adapter: \"webscraper\",\n action: \"scrape\",\n data: { content: \"Page data...\" },\n message: \"OK\",\n };\n },\n};\n\n// --- Registry ---\nconst REGISTRY = new Map();\n[\n GroqAdapter,\n HuggingFaceAdapter,\n GitHubAdapter,\n DuckDuckGoAdapter,\n CoinGeckoAdapter,\n WebScraperAdapter,\n].forEach(\n (a) => REGISTRY.set(a.name, a),\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 = REGISTRY.get(name);\n if (!adapter) {\n return {\n success: false,\n adapter: name,\n action,\n data: {},\n message: \"Adapter not found\",\n };\n }\n return adapter.execute(action, data);\n}",[161],"ed1602ba-8f6f-4c1e-acc5-758a1361982c","TaskDispatcher.ts","b1539bee-7922-11f1-a14a-1607ee4eb77e",19,["D",1783332566652],"// Task Dispatcher — Nexuses Core OS V10.0\n// Orchestrates the Analyze → Execute → Report pipeline.\n// Integrates Supervisor (auto-retry) and IAP delegation.\nimport { getAgentManifest, routeIncomingTask } from \"./AgentManager.ts\";\nimport type { AgentResult } from \"./AgentManager.ts\";\nimport { listAdapters, routeToAdapter } from \"./UniversalAdapter.ts\";\nimport {\n classifyTask,\n getHFToken,\n getModelManifest,\n getSelectionInfo,\n selectModel,\n} from \"./hf.ts\";\nimport type { TaskType } from \"./hf.ts\";\nimport { supervise } from \"./Supervisor.ts\";\nimport type { SupervisedResult } from \"./Supervisor.ts\";\nimport { delegateToExternal } from \"./IAP.ts\";\nimport type { DelegationResult } from \"./IAP.ts\";\nimport { getServiceInfo, hasInternalCapability } from \"./RegistryManager.ts\";\nimport {\n getRecentTasks,\n getTask,\n getTaskCount,\n initDB,\n insertTask,\n logWorkflowStep,\n recall,\n remember,\n updateTaskStatus,\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 delegated?: boolean;\n delegationTarget?: string | null;\n supervised?: boolean;\n retried?: boolean;\n selfCorrected?: boolean;\n supervisorAttempts?: number;\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(\n taskId,\n 1,\n \"TaskDispatcher\",\n \"ANALYZE\",\n `Task: \"${task}\" | Type: ${selection.taskType} | Model: ${selection.modelLabel} (${selection.modelId}) | Fallback: ${\n selection.fallbackModel || \"none\"\n } | Candidates: ${\n candidates.map((a) => a.name).join(\", \") || \"GeneralHandler\"\n }`,\n );\n\n // Record initial task state\n await insertTask(\n taskId,\n task,\n \"pending\",\n \"processing\",\n { task, data, mode },\n null,\n );\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 via Supervisor\n await logWorkflowStep(\n taskId,\n 2,\n \"TaskDispatcher\",\n \"EXECUTE\",\n `Routing to agent for execution (supervised mode)`,\n );\n\n // Wrap execution in Supervisor for autonomous error recovery\n const supervised = await supervise(\n taskId,\n task,\n data,\n (t, d) => routeIncomingTask(t, d, mode, true),\n );\n\n let agentResult: AgentResult;\n let delegated = false;\n let delegationResult: DelegationResult | null = null;\n\n if (supervised.success && supervised.finalResult) {\n agentResult = supervised.finalResult as AgentResult;\n } else {\n // Internal execution failed after retries — try external delegation\n await logWorkflowStep(\n taskId,\n 5,\n \"TaskDispatcher\",\n \"DELEGATE\",\n `Internal execution failed, attempting external delegation`,\n );\n\n delegationResult = await delegateToExternal(task, data);\n delegated = delegationResult.delegated;\n\n if (delegationResult.success) {\n agentResult = {\n agent: \"ExternalDelegation\",\n category: \"Delegated\",\n status: \"SUCCESS\",\n message: delegationResult.message,\n data: delegationResult.data,\n adapters: [],\n };\n } else {\n agentResult = {\n agent: supervised.finalResult?.agent || \"Unknown\",\n category: supervised.finalResult?.category || \"General\",\n status: \"ERROR\",\n message: supervised.message,\n data: supervised.finalResult?.data || {},\n };\n }\n }\n\n await logWorkflowStep(\n taskId,\n 3,\n agentResult.agent,\n agentResult.status,\n agentResult.message + (delegated ? \" [DELEGATED]\" : \"\"),\n );\n\n // PHASE 3: REPORT — build structured Universal Task Format response\n const isSuccess = agentResult.status === \"SUCCESS\" ||\n 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 delegated,\n delegationTarget: delegationResult?.target || null,\n supervised: true,\n retried: supervised.retried,\n selfCorrected: supervised.selfCorrected,\n supervisorAttempts: supervised.attempts.length,\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(\n taskId,\n 4,\n \"TaskDispatcher\",\n \"REPORT\",\n `Status: ${response.status} | Model: ${response.model || \"N/A\"}${\n response.fallbackUsed ? \" (FALLBACK)\" : \"\"\n } | Time: ${response.executionTimeMs}ms`,\n );\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 V10.0 — Universal AI Gateway\",\n uptime: \"24/7 on Val Town\",\n persistence: \"SQLite (project-scoped)\",\n tasksProcessed: taskCount,\n hfIntegration: token ? \"ACTIVE\" : \"NOT_CONFIGURED\",\n protocol: \"JSON-RPC 2.0 / IAP 1.0\",\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 \"/\": \"Universal Task dispatch (auth required)\",\n \"/adapter\": \"Direct adapter call (auth required)\",\n \"/handshake\": \"IAP handshake (JSON-RPC)\",\n \"/rpc\": \"JSON-RPC 2.0 endpoint (auth required)\",\n },\n GET: {\n \"/\": \"System discovery\",\n \"/status\": \"System status & stats\",\n \"/register\": \"Service manifest for external AI discovery\",\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: {\n \"Authorization\": \"Bearer YOUR_NEXUSES_API_KEY\",\n \"Content-Type\": \"application/json\",\n },\n body: {\n task: \"debug my code\",\n data: { code: \"function add(a,b){return a-b}\" },\n },\n },\n };\n}\n\nexport async function callAdapterDirect(\n name: string,\n action: string,\n data: any,\n) {\n return routeToAdapter(name, action, data);\n}",[168],"80801cd2-2a3e-48b8-a4e7-bd3d7fe2ef50","Supervisor.ts","486ed854-7923-11f1-b6db-1607ee4eb77e",26,["D",1783332900583],"// Supervisor Agent — Nexuses Core OS V10.0\n// Autonomous error loop: Log → Analyze → Retry → Self-correct.\n// Wraps agent execution with supervision and automatic retry logic.\n\nimport {\n callHFWithFallback,\n classifyTask,\n getHFToken,\n selectModel,\n} from \"./hf.ts\";\nimport type { HFResult, ModelKey, TaskType } from \"./hf.ts\";\nimport { logWorkflowStep } from \"./db.ts\";\n\nexport interface SupervisedResult {\n success: boolean;\n attempts: AttemptLog[];\n finalResult: any;\n retried: boolean;\n selfCorrected: boolean;\n message: string;\n}\n\nexport interface AttemptLog {\n attempt: number;\n model: ModelKey;\n status: \"success\" | \"error\" | \"timeout\";\n error?: string;\n action: string;\n}\n\nconst MAX_RETRIES = 3;\n\n/**\n * Supervises a task execution with automatic error recovery.\n *\n * Flow:\n * 1. Execute the task via the provided executor function.\n * 2. If it fails: log the error, analyze failure context with HF.\n * 3. Retry with a different model or adjusted strategy.\n * 4. Self-correct if possible (modify prompt based on error analysis).\n */\nexport async function supervise(\n taskId: string,\n task: string,\n data: any,\n executor: (task: string, data: any) => Promise,\n): Promise {\n const attempts: AttemptLog[] = [];\n let lastError = \"\";\n let selfCorrected = false;\n\n for (let attempt = 1; attempt <= MAX_RETRIES; attempt++) {\n console.log(\n `[Supervisor] Attempt ${attempt}/${MAX_RETRIES} for task: \"${\n task.slice(0, 80)\n }\"`,\n );\n\n try {\n const result = await executor(task, data);\n\n // Check if execution succeeded\n if (\n result.success || result.status === \"SUCCESS\" ||\n result.status === \"success\"\n ) {\n attempts.push({\n attempt,\n model: result.model || \"N/A\",\n status: \"success\",\n action: \"executed\",\n });\n\n await logWorkflowStep(\n taskId,\n 10 + attempt,\n \"Supervisor\",\n \"SUCCESS\",\n `Attempt ${attempt} succeeded | Model: ${result.model || \"N/A\"}`,\n );\n\n return {\n success: true,\n attempts,\n finalResult: result,\n retried: attempt > 1,\n selfCorrected,\n message: result.message || `Task completed on attempt ${attempt}`,\n };\n }\n\n // Execution returned but with failure status\n lastError = result.error || result.message || \"Unknown error\";\n attempts.push({\n attempt,\n model: result.model || \"N/A\",\n status: \"error\",\n error: lastError,\n action: \"failed\",\n });\n\n console.log(`[Supervisor] Attempt ${attempt} failed: ${lastError}`);\n await logWorkflowStep(\n taskId,\n 10 + attempt,\n \"Supervisor\",\n \"RETRY\",\n `Attempt ${attempt} failed: ${lastError}`,\n );\n\n // If this is the last attempt, don't analyze/retry\n if (attempt >= MAX_RETRIES) break;\n\n // PHASE: Analyze the failure\n const analysis = await analyzeFailure(task, data, lastError, attempt);\n await logWorkflowStep(\n taskId,\n 10 + attempt + 0.5,\n \"Supervisor\",\n \"ANALYZE\",\n `Failure analysis: ${analysis.slice(0, 200)}`,\n );\n\n // PHASE: Self-correct — modify the prompt/data based on analysis\n if (attempt === 1) {\n const corrected = await selfCorrect(task, data, lastError, analysis);\n if (corrected.modified) {\n task = corrected.task;\n data = corrected.data;\n selfCorrected = true;\n console.log(\n `[Supervisor] Self-corrected task prompt based on error analysis`,\n );\n await logWorkflowStep(\n taskId,\n 10 + attempt + 0.6,\n \"Supervisor\",\n \"SELF_CORRECT\",\n `Prompt modified based on failure analysis`,\n );\n }\n }\n\n // PHASE: Retry with different strategy\n // The executor itself already has fallback logic via callHFWithFallback,\n // but we retry the whole execution which may pick a different agent/model\n } catch (e: any) {\n lastError = e.message;\n attempts.push({\n attempt,\n model: \"N/A\",\n status: \"error\",\n error: lastError,\n action: \"exception\",\n });\n\n console.log(`[Supervisor] Attempt ${attempt} threw: ${lastError}`);\n await logWorkflowStep(\n taskId,\n 10 + attempt,\n \"Supervisor\",\n \"ERROR\",\n `Attempt ${attempt} exception: ${lastError}`,\n );\n\n if (attempt >= MAX_RETRIES) break;\n }\n }\n\n // All attempts exhausted\n await logWorkflowStep(\n taskId,\n 19,\n \"Supervisor\",\n \"EXHAUSTED\",\n `All ${MAX_RETRIES} attempts failed. Last error: ${lastError}`,\n );\n\n return {\n success: false,\n attempts,\n finalResult: null,\n retried: attempts.length > 1,\n selfCorrected,\n message: `All ${MAX_RETRIES} attempts failed. Last error: ${lastError}`,\n };\n}\n\n/**\n * Analyzes a failure using HF to understand what went wrong.\n */\nasync function analyzeFailure(\n task: string,\n data: any,\n error: string,\n attempt: number,\n): Promise {\n const token = getHFToken();\n if (!token) {\n return \"No HF token — cannot analyze failure. Will retry with same parameters.\";\n }\n\n const prompt =\n `Analyze why this task execution failed and suggest a fix:\\nTask: ${task}\\nData: ${\n JSON.stringify(data).slice(0, 500)\n }\\nError: ${error}\\nAttempt: ${attempt}`;\n\n const result = await callHFWithFallback(prompt, \"mistral\", {\n maxTokens: 200,\n timeoutMs: 10000,\n });\n return result.success ? result.text : \"Analysis unavailable\";\n}\n\n/**\n * Self-corrects the task prompt or data based on failure analysis.\n * Modifies the prompt to be clearer or adjusts parameters.\n */\nasync function selfCorrect(\n task: string,\n data: any,\n error: string,\n analysis: string,\n): Promise<{ task: string; data: any; modified: boolean }> {\n const token = getHFToken();\n if (!token) return { task, data, modified: false };\n\n // If the error is about missing token or config, don't retry with modified prompt\n if (error.includes(\"not configured\") || error.includes(\"NO_TOKEN\")) {\n return { task, data, modified: false };\n }\n\n // If error is a timeout, simplify the prompt\n if (error.includes(\"Timeout\") || error.includes(\"timeout\")) {\n const simplifiedTask = task.slice(0, 200);\n return {\n task: simplifiedTask,\n data: { ...data, maxTokens: Math.min(data.maxTokens || 500, 200) },\n modified: true,\n };\n }\n\n // If error is HTTP 503 (model loading), the retry will naturally try fallback\n if (error.includes(\"503\") || error.includes(\"loading\")) {\n return { task, data, modified: false };\n }\n\n // For other errors, try rephrasing the task\n const rephrasePrompt =\n `Rephrase this task instruction to be clearer and more specific:\\n\"${task}\"\\n\\nOnly return the rephrased instruction, nothing else.`;\n const result = await callHFWithFallback(rephrasePrompt, \"mistral\", {\n maxTokens: 100,\n timeoutMs: 10000,\n });\n\n if (\n result.success && result.text && result.text.length > 10 &&\n result.text.length < 500\n ) {\n return { task: result.text.trim(), data, modified: true };\n }\n\n return { task, data, modified: false };\n}",[175],"529e9593-4b03-4d73-8bb1-9e3864895ad6","RegistryManager.ts","296c2956-7924-11f1-a6e5-1607ee4eb77e",33,["D",1783333195528],"// 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 {\n classifyTask,\n getHFToken,\n getModelManifest,\n type TaskType,\n} 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: [\n \"text-generation\",\n \"code-generation\",\n \"creative-writing\",\n \"summarization\",\n ],\n authHeader: \"Authorization: Bearer \",\n status: \"available\",\n },\n {\n id: \"hf-image\",\n name: \"Hugging Face Image Generation\",\n url:\n \"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(\n capability: string,\n): 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: ${\n agent.capabilities.join(\", \")\n }`,\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: ${\n model.bestFor.join(\", \")\n }`,\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: ${\n svc.capabilities.join(\", \")\n }`,\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(\n taskText: string,\n): { 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}",[182],"ff3a4580-da65-4a43-89a4-325481086611",["D",1783333372363],[28],"pulls","branches","forks","envVars",{"_198":141,"_200":62},"connections",{"_198":62,"_199":62},"count","unfilledCount","emptyCount",{"_43":188,"_32":28,"_30":31,"_137":-5,"_41":42,"_40":14,"_139":25,"_38":231,"_13":138,"_33":34,"_35":37,"_24":25,"_143":-5,"_210":232,"_27":233},{"_43":181,"_32":182,"_30":183,"_137":-5,"_41":42,"_40":184,"_139":25,"_38":228,"_13":138,"_33":34,"_35":186,"_24":25,"_143":-5,"_210":229,"_27":230},{"_43":174,"_32":175,"_30":176,"_137":-5,"_41":42,"_40":177,"_139":25,"_38":225,"_13":138,"_33":34,"_35":179,"_24":25,"_143":-5,"_210":226,"_27":227},{"_43":167,"_32":168,"_30":169,"_137":-5,"_41":42,"_40":170,"_139":25,"_38":222,"_13":138,"_33":34,"_35":172,"_24":25,"_143":-5,"_210":223,"_27":224},{"_43":160,"_32":161,"_30":162,"_137":-5,"_41":42,"_40":163,"_139":25,"_38":219,"_13":138,"_33":34,"_35":165,"_24":25,"_143":-5,"_210":220,"_27":221},{"_43":153,"_32":154,"_30":155,"_137":-5,"_41":42,"_40":156,"_139":25,"_38":216,"_13":138,"_33":34,"_35":158,"_24":25,"_143":-5,"_210":217,"_27":218},{"_43":145,"_32":146,"_30":147,"_137":-5,"_41":42,"_40":148,"_139":25,"_38":213,"_13":150,"_33":34,"_35":151,"_24":25,"_143":-5,"_210":214,"_27":215},{"_43":135,"_32":136,"_30":56,"_137":-5,"_41":42,"_40":138,"_139":25,"_38":209,"_13":141,"_33":34,"_35":142,"_24":25,"_143":-5,"_210":211,"_27":212},["D",1783331940818],"children",[],[136],["D",1783332056080],[],[146],["D",1783332132291],[],[154],["D",1783332408482],[],[161],["D",1783332566652],[],[168],["D",1783332900583],[],[175],["D",1783333195528],[],[182],["D",1783333372363],[],[28],["D",1783331684771],["D",1789522836959],{"_99":98,"_105":36},{"_99":98,"_100":36,"_101":36,"_18":54,"_102":103,"_104":25},{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"ctx",{"_81":-5,"_124":272,"_273":274,"_275":276,"_277":25,"_278":25,"_279":25,"_280":58,"_281":-5,"_282":-7,"_283":-7,"_284":62,"_285":25,"_286":25,"_287":-5,"_288":25,"_289":25,"_290":25,"_291":-5},"ENV",{"_243":244,"_245":246,"_247":89,"_248":249,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259,"_260":261,"_262":263,"_264":265,"_266":267,"_268":269,"_270":271},"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 · v36