[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_208":209,"_210":211},"routes/_app.x.$handle.$name",{"_103":102,"_38":50,"_111":93,"_33":105,"_13":14,"_112":-5,"_11":113,"_114":115,"_116":117,"_118":119,"_120":121,"_26":-5,"_122":-5,"_123":-5,"_124":32,"_125":126,"_127":30,"_128":-5,"_129":-5,"_130":131},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_48":49,"_38":50,"_43":51,"_52":-5,"_53":32,"_54":55,"_56":55,"_57":58,"_59":-5,"_19":60,"_61":-5,"_62":32,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":70,"_71":72,"_73":74,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":86,"_87":88,"_89":90,"_91":32},"version",5,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","ea03e3eb-c0bb-410e-87a2-8445842d63b1","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":32,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":42,"_43":44,"_45":14,"_46":47,"_29":32},"previous","deleted",true,"deletedHere",false,"path","orchestrator.ts","latestPath","fileId","713c52d4-7f7c-11f1-bf6b-1607ee4eb77e","name","fileType","script","content","import { DB } from \"./db.ts\";\nimport {\n createAgent, getAgent, getAgentByName, listAgents, listTasks,\n createTask, bidOnTask, acceptBid, executeTask, completeTask,\n sendMessage, transferCredits, getStats, ensureEscrowAccount,\n updateAgentStatus,\n} from \"./agents.ts\";\nimport { generateText, type ChatMessage } from \"./pollinations.ts\";\n\n// ============================================================\n// DEFAULT AGENT PROFILES — Pre-seeded specialized agents\n// ============================================================\n\nconst DEFAULT_AGENTS = [\n {\n name: \"Nova-Writer\",\n description: \"Expert content writer specializing in articles, blog posts, marketing copy, and creative writing\",\n capabilities: [\"writing\", \"copywriting\", \"content-creation\", \"editing\", \"summarization\"],\n model: \"openai-fast\",\n balance: 200,\n },\n {\n name: \"Atlas-Analyst\",\n description: \"Data analyst and researcher capable of deep analysis, market research, and strategic insights\",\n capabilities: [\"analysis\", \"research\", \"data-analysis\", \"strategy\", \"reporting\"],\n model: \"openai-fast\",\n balance: 200,\n },\n {\n name: \"Pixel-Artist\",\n description: \"AI image generation specialist creating visuals from text descriptions\",\n capabilities: [\"image-generation\", \"art\", \"design\", \"visual-content\"],\n model: \"openai-fast\",\n balance: 150,\n },\n {\n name: \"Code-Forge\",\n description: \"Software engineer agent for code generation, review, debugging, and architecture\",\n capabilities: [\"coding\", \"code-review\", \"debugging\", \"architecture\", \"documentation\"],\n model: \"openai-fast\",\n balance: 250,\n },\n {\n name: \"Lingua-Translator\",\n description: \"Multi-language translator and localization expert\",\n capabilities: [\"translation\", \"localization\", \"language-analysis\", \"transliteration\"],\n model: \"openai-fast\",\n balance: 150,\n },\n {\n name: \"Sage-Orchestrator\",\n description: \"Master coordinator that receives complex tasks and delegates to specialized agents\",\n capabilities: [\"orchestration\", \"delegation\", \"project-management\", \"coordination\"],\n model: \"openai-fast\",\n balance: 500,\n },\n];\n\nexport async function seedDefaultAgents(): Promise<{ created: string[]; existing: string[] }> {\n await ensureEscrowAccount();\n const created: string[] = [];\n const existing: string[] = [];\n\n for (const profile of DEFAULT_AGENTS) {\n const existingAgent = await getAgentByName(profile.name);\n if (existingAgent) {\n existing.push(profile.name);\n } else {\n const agent = await createAgent(profile);\n if (agent) created.push(profile.name);\n }\n }\n\n return { created, existing };\n}\n\n// ============================================================\n// AUTONOMOUS ORCHESTRATION\n// ============================================================\n\n/**\n * Find the best agent for a task based on capabilities and task type.\n */\nexport async function findBestAgent(taskType: string, taskDescription: string): Promise {\n const agents = await listAgents(\"active\");\n\n // Map task types to required capabilities\n const capabilityMap: Record = {\n text: [\"writing\", \"content-creation\", \"analysis\", \"orchestration\"],\n image: [\"image-generation\", \"art\", \"design\"],\n analysis: [\"analysis\", \"research\", \"data-analysis\"],\n code: [\"coding\", \"code-review\", \"debugging\"],\n translation: [\"translation\", \"localization\"],\n writing: [\"writing\", \"copywriting\", \"content-creation\"],\n research: [\"research\", \"analysis\"],\n };\n\n const requiredCaps = capabilityMap[taskType] ?? [\"writing\"];\n\n // Score each agent\n let bestAgent: string | null = null;\n let bestScore = -1;\n\n for (const agent of agents) {\n if (agent.status === \"system\") continue;\n const hasMatchingCap = agent.capabilities.some((c) => requiredCaps.includes(c));\n const score = hasMatchingCap ? agent.capabilities.filter((c) => requiredCaps.includes(c)).length : 0;\n if (score > bestScore) {\n bestScore = score;\n bestAgent = agent.id;\n }\n }\n\n // If no capability match, pick the orchestrator or first active agent\n if (bestScore <= 0) {\n const orchestrator = agents.find((a) => a.capabilities.includes(\"orchestration\"));\n if (orchestrator) bestAgent = orchestrator.id;\n else if (agents.length > 0) bestAgent = agents[0].id;\n }\n\n return bestAgent;\n}\n\n/**\n * Auto-bid: Have an agent automatically bid on an open task.\n * The agent uses AI to decide its bid amount based on task complexity.\n */\nexport async function autoBidOnTask(taskId: string, agentId: string): Promise<{ bid: unknown; reasoning: string }> {\n const task = await listTasks().then((ts) => ts.find((t) => t.id === taskId));\n const agent = await getAgent(agentId);\n if (!task || !agent) throw new Error(\"Task or agent not found\");\n\n // Use AI to evaluate the task and suggest a bid\n const prompt = `You are ${agent.name}, an AI agent evaluating a task to place a bid.\nTask: \"${task.title}\"\nDescription: ${task.description}\nType: ${task.type}\nOriginal payment offered: ${task.payment} credits\n\nBased on your capabilities (${agent.capabilities.join(\", \")}), suggest a fair bid price in credits.\nRespond with ONLY a number (the bid amount in credits). Bid competitively but fairly.`;\n\n const result = await generateText(prompt, { model: agent.model });\n\n // Parse the bid amount\n const match = result.text.match(/(\\d+(?:\\.\\d+)?)/);\n const proposedPayment = match ? Math.min(parseFloat(match[1]), task.payment * 1.5) : task.payment;\n\n const bid = await bidOnTask({\n task_id: taskId,\n agent_id: agentId,\n proposed_payment: Math.round(proposedPayment * 100) / 100,\n message: `Auto-bid from ${agent.name}. ${result.text.substring(0, 100)}`,\n });\n\n return { bid, reasoning: result.text };\n}\n\n/**\n * Auto-assign: Find the best agent for a task, have them bid, and accept the bid.\n */\nexport async function autoAssignTask(taskId: string): Promise<{ task: unknown; agent: string }> {\n const tasks = await listTasks();\n const task = tasks.find((t) => t.id === taskId);\n if (!task) throw new Error(\"Task not found\");\n if (task.status !== \"open\") throw new Error(\"Task is not open\");\n\n const bestAgentId = await findBestAgent(task.type, task.description);\n if (!bestAgentId) throw new Error(\"No available agents\");\n\n const agent = await getAgent(bestAgentId);\n if (!agent) throw new Error(\"Agent not found\");\n\n // Agent bids on the task\n const { bid } = await autoBidOnTask(taskId, bestAgentId);\n\n // Auto-accept the bid (in a real system, the creator would review)\n // For autonomous operation, we accept the first auto-bid\n const bidRecord = bid as { id: string };\n const updatedTask = await acceptBid(bidRecord.id);\n\n return { task: updatedTask, agent: agent.name };\n}\n\n/**\n * Full autonomous pipeline: Create a task, auto-assign, execute, and complete.\n * This is the end-to-end agent-to-agent business flow.\n */\nexport async function autonomousTaskPipeline(params: {\n creator_id: string;\n title: string;\n description: string;\n type?: string;\n payment: number;\n input_data?: Record;\n}): Promise<{\n task: unknown;\n assignedAgent: string;\n output: Record;\n paymentReleased: boolean;\n messages: unknown[];\n}> {\n // 1. Create the task\n const task = await createTask({\n title: params.title,\n description: params.description,\n type: params.type ?? \"text\",\n payment: params.payment,\n creator_id: params.creator_id,\n input_data: params.input_data,\n });\n\n const taskRecord = task as { id: string; creator_id: string };\n\n // 2. Auto-assign to the best agent\n const assignment = await autoAssignTask(taskRecord.id);\n const assignedTask = assignment.task as { id: string; assignee_id: string };\n\n // 3. Execute the task (AI does the work)\n const output = await executeTask(assignedTask.id);\n\n // 4. Gather all messages related to this task\n const allMessages = await DB.execute({\n sql: \"SELECT * FROM messages WHERE task_id = ? ORDER BY created_at ASC\",\n args: [taskRecord.id],\n });\n\n return {\n task: assignment.task,\n assignedAgent: assignment.agent,\n output,\n paymentReleased: output.success !== false,\n messages: allMessages.rows,\n };\n}\n\n/**\n * Agent-to-agent delegation: An agent delegates part of its task to another agent.\n * For example, Sage-Orchestrator receives a complex task and subcontracts parts.\n */\nexport async function delegateTask(params: {\n delegator_id: string;\n delegatee_id: string;\n title: string;\n description: string;\n type?: string;\n payment: number;\n parent_task_id?: string;\n input_data?: Record;\n}): Promise<{ task: unknown; output: Record }> {\n const delegator = await getAgent(params.delegator_id);\n const delegatee = await getAgent(params.delegatee_id);\n if (!delegator || !delegatee) throw new Error(\"Delegator or delegatee not found\");\n\n // Delegator creates a task directly assigned to the delegatee\n const task = await createTask({\n title: params.title,\n description: `[Delegated by ${delegator.name}] ${params.description}`,\n type: params.type ?? \"text\",\n payment: params.payment,\n creator_id: params.delegator_id,\n assignee_id: params.delegatee_id,\n input_data: params.input_data,\n });\n\n // Notify the delegatee\n await sendMessage({\n from_agent_id: params.delegator_id,\n to_agent_id: params.delegatee_id,\n content: `Task delegated: \"${params.title}\". Payment: ${params.payment} credits. Please complete this task.`,\n task_id: (task as { id: string }).id,\n type: \"delegation\",\n });\n\n // Execute the task\n const output = await executeTask((task as { id: string }).id);\n\n return { task, output };\n}\n\n/**\n * Get a full ecosystem report — all agents, tasks, transactions, and stats.\n */\nexport async function getEcosystemReport() {\n const [stats, agents, tasks, transactions, messages] = await Promise.all([\n getStats(),\n listAgents(),\n listTasks(),\n (async () => {\n const result = await DB.execute(\"SELECT * FROM transactions ORDER BY created_at DESC LIMIT 50\");\n return result.rows;\n })(),\n (async () => {\n const result = await DB.execute(\"SELECT * FROM messages ORDER BY created_at DESC LIMIT 50\");\n return result.rows;\n })(),\n ]);\n\n return { stats, agents, tasks, transactions, messages };\n}\n","createdAt",["D",1784030787757],"branchVersion","branchId","0e02d20c-d45e-40f1-9908-bcb1cb9721fb","id","723b763e-05b5-4a1d-ada6-cb676d77d94c","open-agent-marketplace",["D",1784030641527],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Free AI agents that delegate tasks and settle payments","imageUrl","53e8316f-f582-46c3-adc5-3a4a1368334d","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f606f-4ff1-7361-94b7-61e0484e4257","tursoName","723b763e05b54a1dada6cb676d77d94c","tursoHostname","723b763e05b54a1dada6cb676d77d94c-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789558275908],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_103":102,"_110":105},"org",{"_103":102,"_104":105,"_106":105,"_19":60,"_107":108,"_109":32},"branch",{"_13":92,"_38":93,"_48":47,"_94":49,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":50,"_101":102},"isOwned",27,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","Agentu","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_48":49,"_38":50,"_43":203,"_52":-5,"_53":32,"_54":55,"_56":55,"_57":58,"_59":-5,"_19":60,"_61":-5,"_62":32,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":70,"_71":72,"_73":204,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":205,"_87":206,"_89":207,"_91":32},"tree",[182,183,184,185,186],"files",[182,183,184,185,186],"counts",{"_172":66,"_173":153,"_174":66,"_175":176,"_177":178},"contents",[132,133,134,135,136],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_48":165,"_38":166,"_36":167,"_140":-5,"_46":47,"_45":168,"_142":32,"_43":169,"_13":66,"_39":40,"_41":170,"_29":32,"_145":-5,"_33":171},{"_48":158,"_38":159,"_36":160,"_140":-5,"_46":47,"_45":161,"_142":32,"_43":162,"_13":66,"_39":40,"_41":163,"_29":32,"_145":-5,"_33":164},{"_48":150,"_38":151,"_36":152,"_140":-5,"_46":47,"_45":153,"_142":32,"_43":154,"_13":66,"_39":155,"_41":156,"_29":32,"_145":-5,"_33":157},{"_48":147,"_38":34,"_36":37,"_140":-5,"_46":47,"_45":14,"_142":32,"_43":148,"_13":66,"_39":40,"_41":42,"_29":32,"_145":-5,"_33":149},{"_48":137,"_38":138,"_36":139,"_140":-5,"_46":47,"_45":141,"_142":32,"_43":143,"_13":66,"_39":40,"_41":144,"_29":32,"_145":-5,"_33":146},"e61d6689-4d78-475d-8466-b661d20808ca","pollinations.ts","2e7214d4-7f7c-11f1-b8ac-1607ee4eb77e","parentId",3,"latest",["D",1784030675701],"// Pollinations.AI integration — free, no API key required\n// Text: https://text.pollinations.ai/\n// Image: https://image.pollinations.ai/prompt/{prompt}\n\nexport interface ChatMessage {\n role: \"system\" | \"user\" | \"assistant\";\n content: string;\n}\n\nexport interface TextResult {\n text: string;\n model: string;\n success: boolean;\n error?: string;\n}\n\nexport interface ImageResult {\n url: string;\n model: string;\n success: boolean;\n error?: string;\n}\n\n/**\n * Generate text using Pollinations.AI (free, no API key)\n * Supports both simple prompt and chat-style messages.\n */\nexport async function generateText(\n promptOrMessages: string | ChatMessage[],\n opts: {\n model?: string;\n system?: string;\n temperature?: number;\n seed?: number;\n } = {},\n): Promise {\n const model = opts.model ?? \"openai-fast\";\n\n try {\n let body: Record;\n\n if (typeof promptOrMessages === \"string\") {\n const messages: ChatMessage[] = [];\n if (opts.system) {\n messages.push({ role: \"system\", content: opts.system });\n }\n messages.push({ role: \"user\", content: promptOrMessages });\n body = { messages, model };\n } else {\n body = { messages: promptOrMessages, model };\n }\n\n if (opts.temperature !== undefined) body.temperature = opts.temperature;\n if (opts.seed !== undefined) body.seed = opts.seed;\n\n const res = await fetch(\"https://text.pollinations.ai/\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n\n if (!res.ok) {\n const errText = await res.text().catch(() => \"unknown error\");\n return { text: \"\", model, success: false, error: `HTTP ${res.status}: ${errText}` };\n }\n\n const text = await res.text();\n return { text: text.trim(), model, success: true };\n } catch (err) {\n return {\n text: \"\",\n model,\n success: false,\n error: err instanceof Error ? err.message : String(err),\n };\n }\n}\n\n/**\n * Generate an image using Pollinations.AI (free, no API key)\n * Returns a URL to the generated image.\n */\nexport async function generateImage(\n prompt: string,\n opts: {\n model?: string;\n width?: number;\n height?: number;\n seed?: number;\n nologo?: boolean;\n } = {},\n): Promise {\n const model = opts.model ?? \"sana\";\n const width = opts.width ?? 1024;\n const height = opts.height ?? 1024;\n const seed = opts.seed ?? Math.floor(Math.random() * 1000000);\n\n const params = new URLSearchParams({\n model,\n width: String(width),\n height: String(height),\n seed: String(seed),\n });\n if (opts.nologo) params.set(\"nologo\", \"true\");\n\n const url = `https://image.pollinations.ai/prompt/${encodeURIComponent(prompt)}?${params}`;\n\n try {\n // Verify the image is accessible\n const res = await fetch(url, { method: \"HEAD\" });\n if (!res.ok) {\n return { url: \"\", model, success: false, error: `HTTP ${res.status}` };\n }\n return { url, model, success: true };\n } catch (err) {\n // Even if HEAD fails, the URL may still work in a browser\n return {\n url,\n model,\n success: true,\n error: err instanceof Error ? err.message : String(err),\n };\n }\n}\n\n/**\n * Get available text models from Pollinations.AI\n */\nexport async function getTextModels(): Promise {\n try {\n const res = await fetch(\"https://text.pollinations.ai/models\");\n if (!res.ok) return [];\n return await res.json();\n } catch {\n return [];\n }\n}\n\n/**\n * Get available image models from Pollinations.AI\n */\nexport async function getImageModels(): Promise {\n try {\n const res = await fetch(\"https://image.pollinations.ai/models\");\n if (!res.ok) return [];\n return await res.json();\n } catch {\n return [];\n }\n}\n\n/**\n * Quick health check — test that Pollinations.AI is responding\n */\nexport async function healthCheck(): Promise<{\n text: boolean;\n image: boolean;\n textModels: number;\n imageModels: string[];\n}> {\n const [textResult, textModels, imageModels] = await Promise.all([\n generateText(\"Say 'OK' if you can hear me.\"),\n getTextModels(),\n getImageModels(),\n ]);\n\n return {\n text: textResult.success,\n image: imageModels.length > 0,\n textModels: textModels.length,\n imageModels,\n };\n}\n","label",[138],"6fd12f9f-ebd7-46ed-80da-590cb1e2ab64",["D",1784030787757],[34],"2af2fac6-a009-45d3-ba8f-6110f1ac2c22","main.ts","1a16d43e-7f7c-11f1-bf6b-1607ee4eb77e",1,["D",1784030641546],"http","export default async function(req: Request): Promise {\n return Response.json({ status: \"initializing\" });\n}",[151],"b3276b46-e1f7-4b9a-8d7b-ec32225a80a9","db.ts","26001e0e-7f7c-11f1-84d8-1607ee4eb77e",2,["D",1784030661531],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport const DB = sqlite;\n\nexport async function initDB() {\n await sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS agents (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL UNIQUE,\n description TEXT,\n capabilities TEXT NOT NULL DEFAULT '[]',\n balance REAL NOT NULL DEFAULT 0,\n status TEXT NOT NULL DEFAULT 'active',\n model TEXT NOT NULL DEFAULT 'openai-fast',\n avatar TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n updated_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS tasks (\n id TEXT PRIMARY KEY,\n title TEXT NOT NULL,\n description TEXT NOT NULL,\n type TEXT NOT NULL DEFAULT 'text',\n payment REAL NOT NULL DEFAULT 0,\n budget REAL NOT NULL DEFAULT 0,\n status TEXT NOT NULL DEFAULT 'open',\n creator_id TEXT NOT NULL,\n assignee_id TEXT,\n input_data TEXT,\n output_data TEXT,\n max_retries INTEGER NOT NULL DEFAULT 3,\n retry_count INTEGER NOT NULL DEFAULT 0,\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n assigned_at TEXT,\n completed_at TEXT,\n FOREIGN KEY (creator_id) REFERENCES agents(id),\n FOREIGN KEY (assignee_id) REFERENCES agents(id)\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS transactions (\n id TEXT PRIMARY KEY,\n from_agent_id TEXT NOT NULL,\n to_agent_id TEXT NOT NULL,\n amount REAL NOT NULL,\n task_id TEXT,\n type TEXT NOT NULL DEFAULT 'payment',\n status TEXT NOT NULL DEFAULT 'completed',\n description TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n FOREIGN KEY (from_agent_id) REFERENCES agents(id),\n FOREIGN KEY (to_agent_id) REFERENCES agents(id),\n FOREIGN KEY (task_id) REFERENCES tasks(id)\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS messages (\n id TEXT PRIMARY KEY,\n from_agent_id TEXT NOT NULL,\n to_agent_id TEXT NOT NULL,\n content TEXT NOT NULL,\n task_id TEXT,\n type TEXT NOT NULL DEFAULT 'message',\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n FOREIGN KEY (from_agent_id) REFERENCES agents(id),\n FOREIGN KEY (to_agent_id) REFERENCES agents(id),\n FOREIGN KEY (task_id) REFERENCES tasks(id)\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS bids (\n id TEXT PRIMARY KEY,\n task_id TEXT NOT NULL,\n agent_id TEXT NOT NULL,\n proposed_payment REAL NOT NULL,\n message TEXT,\n status TEXT NOT NULL DEFAULT 'pending',\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n FOREIGN KEY (task_id) REFERENCES tasks(id),\n FOREIGN KEY (agent_id) REFERENCES agents(id)\n )`,\n },\n ]);\n}\n\n// Helper: generate UUIDs\nexport function uuid(): string {\n return crypto.randomUUID();\n}\n\n// Helper: parse JSON field safely\nexport function parseJSON(value: unknown, fallback: T): T {\n if (typeof value !== \"string\") return fallback;\n try {\n return JSON.parse(value) as T;\n } catch {\n return fallback;\n }\n}\n\n// Helper: format agent row from DB\nexport function formatAgent(row: Record) {\n return {\n id: row.id as string,\n name: row.name as string,\n description: row.description as string | null,\n capabilities: parseJSON(row.capabilities, []),\n balance: row.balance as number,\n status: row.status as string,\n model: row.model as string,\n avatar: row.avatar as string | null,\n created_at: row.created_at as string,\n updated_at: row.updated_at as string,\n };\n}\n\n// Helper: format task row from DB\nexport function formatTask(row: Record) {\n return {\n id: row.id as string,\n title: row.title as string,\n description: row.description as string,\n type: row.type as string,\n payment: row.payment as number,\n budget: row.budget as number,\n status: row.status as string,\n creator_id: row.creator_id as string,\n assignee_id: row.assignee_id as string | null,\n input_data: parseJSON(row.input_data, null),\n output_data: parseJSON(row.output_data, null),\n max_retries: row.max_retries as number,\n retry_count: row.retry_count as number,\n created_at: row.created_at as string,\n assigned_at: row.assigned_at as string | null,\n completed_at: row.completed_at as string | null,\n };\n}\n\n// Helper: format transaction row from DB\nexport function formatTransaction(row: Record) {\n return {\n id: row.id as string,\n from_agent_id: row.from_agent_id as string,\n to_agent_id: row.to_agent_id as string,\n amount: row.amount as number,\n task_id: row.task_id as string | null,\n type: row.type as string,\n status: row.status as string,\n description: row.description as string | null,\n created_at: row.created_at as string,\n };\n}\n\n// Helper: format message row from DB\nexport function formatMessage(row: Record) {\n return {\n id: row.id as string,\n from_agent_id: row.from_agent_id as string,\n to_agent_id: row.to_agent_id as string,\n content: row.content as string,\n task_id: row.task_id as string | null,\n type: row.type as string,\n created_at: row.created_at as string,\n };\n}\n\n// Helper: format bid row from DB\nexport function formatBid(row: Record) {\n return {\n id: row.id as string,\n task_id: row.task_id as string,\n agent_id: row.agent_id as string,\n proposed_payment: row.proposed_payment as number,\n message: row.message as string | null,\n status: row.status as string,\n created_at: row.created_at as string,\n };\n}\n",[159],"5b858b0a-2bd9-4318-9e71-758a9c2556fd","agents.ts","5ccc362a-7f7c-11f1-84d8-1607ee4eb77e",4,["D",1784030753432],"import { DB, uuid, formatAgent, formatTask, formatTransaction, formatMessage, formatBid } from \"./db.ts\";\nimport { generateText, generateImage, type ChatMessage } from \"./pollinations.ts\";\n\n// ============================================================\n// AGENT MANAGEMENT\n// ============================================================\n\nexport async function createAgent(params: {\n name: string;\n description?: string;\n capabilities?: string[];\n balance?: number;\n model?: string;\n avatar?: string;\n}) {\n const id = uuid();\n const caps = JSON.stringify(params.capabilities ?? []);\n await DB.execute({\n sql: `INSERT INTO agents (id, name, description, capabilities, balance, model, avatar)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n args: [id, params.name, params.description ?? null, caps, params.balance ?? 100, params.model ?? \"openai-fast\", params.avatar ?? null],\n });\n return getAgent(id);\n}\n\nexport async function getAgent(id: string) {\n const result = await DB.execute({ sql: \"SELECT * FROM agents WHERE id = ?\", args: [id] });\n return result.rows.length === 0 ? null : formatAgent(result.rows[0]);\n}\n\nexport async function getAgentByName(name: string) {\n const result = await DB.execute({ sql: \"SELECT * FROM agents WHERE name = ?\", args: [name] });\n return result.rows.length === 0 ? null : formatAgent(result.rows[0]);\n}\n\nexport async function listAgents(status?: string) {\n const sql = status ? \"SELECT * FROM agents WHERE status = ? ORDER BY created_at DESC\" : \"SELECT * FROM agents ORDER BY created_at DESC\";\n const result = await DB.execute({ sql, args: status ? [status] : [] });\n return result.rows.map(formatAgent);\n}\n\nexport async function updateAgentStatus(id: string, status: string) {\n await DB.execute({ sql: \"UPDATE agents SET status = ?, updated_at = datetime('now') WHERE id = ?\", args: [status, id] });\n}\n\nexport async function updateAgentBalance(id: string, newBalance: number) {\n await DB.execute({ sql: \"UPDATE agents SET balance = ?, updated_at = datetime('now') WHERE id = ?\", args: [newBalance, id] });\n}\n\n// ============================================================\n// LEDGER / PAYMENTS\n// ============================================================\n\nconst ESCROW_ID = \"escrow\";\n\nexport async function ensureEscrowAccount() {\n const existing = await getAgent(ESCROW_ID);\n if (!existing) {\n await DB.execute({\n sql: `INSERT INTO agents (id, name, description, capabilities, balance, status, model)\n VALUES (?, 'Escrow System', 'Virtual escrow account', '[]', 0, 'system', 'none')`,\n args: [ESCROW_ID],\n });\n }\n}\n\nexport async function transferCredits(fromId: string, toId: string, amount: number, taskId?: string, type?: string, description?: string) {\n const txId = uuid();\n await DB.batch([\n { sql: \"UPDATE agents SET balance = balance - ?, updated_at = datetime('now') WHERE id = ?\", args: [amount, fromId] },\n { sql: \"UPDATE agents SET balance = balance + ?, updated_at = datetime('now') WHERE id = ?\", args: [amount, toId] },\n { sql: `INSERT INTO transactions (id, from_agent_id, to_agent_id, amount, task_id, type, description) VALUES (?, ?, ?, ?, ?, ?, ?)`, args: [txId, fromId, toId, amount, taskId ?? null, type ?? \"transfer\", description ?? null] },\n ]);\n return getTransaction(txId);\n}\n\nexport async function getTransaction(id: string) {\n const result = await DB.execute({ sql: \"SELECT * FROM transactions WHERE id = ?\", args: [id] });\n return result.rows.length === 0 ? null : formatTransaction(result.rows[0]);\n}\n\nexport async function listTransactions(agentId?: string) {\n const sql = agentId\n ? \"SELECT * FROM transactions WHERE from_agent_id = ? OR to_agent_id = ? ORDER BY created_at DESC\"\n : \"SELECT * FROM transactions ORDER BY created_at DESC\";\n const result = await DB.execute({ sql, args: agentId ? [agentId, agentId] : [] });\n return result.rows.map(formatTransaction);\n}\n\nexport async function depositCredits(agentId: string, amount: number, description?: string) {\n return transferCredits(\"treasury\", agentId, amount, undefined, \"deposit\", description ?? \"Credit deposit\");\n}\n\n// ============================================================\n// MESSAGING\n// ============================================================\n\nexport async function sendMessage(params: { from_agent_id: string; to_agent_id: string; content: string; task_id?: string; type?: string }) {\n const id = uuid();\n await DB.execute({\n sql: `INSERT INTO messages (id, from_agent_id, to_agent_id, content, task_id, type) VALUES (?, ?, ?, ?, ?, ?)`,\n args: [id, params.from_agent_id, params.to_agent_id, params.content, params.task_id ?? null, params.type ?? \"message\"],\n });\n const result = await DB.execute({ sql: \"SELECT * FROM messages WHERE id = ?\", args: [id] });\n return formatMessage(result.rows[0]);\n}\n\nexport async function listMessages(agentId?: string) {\n const sql = agentId\n ? \"SELECT * FROM messages WHERE from_agent_id = ? OR to_agent_id = ? ORDER BY created_at DESC\"\n : \"SELECT * FROM messages ORDER BY created_at DESC\";\n const result = await DB.execute({ sql, args: agentId ? [agentId, agentId] : [] });\n return result.rows.map(formatMessage);\n}\n\nexport async function getConversation(agent1Id: string, agent2Id: string) {\n const result = await DB.execute({\n sql: `SELECT * FROM messages WHERE (from_agent_id = ? AND to_agent_id = ?) OR (from_agent_id = ? AND to_agent_id = ?) ORDER BY created_at ASC`,\n args: [agent1Id, agent2Id, agent2Id, agent1Id],\n });\n return result.rows.map(formatMessage);\n}\n\n// ============================================================\n// TASK MARKETPLACE\n// ============================================================\n\nexport async function createTask(params: {\n title: string;\n description: string;\n type?: string;\n payment: number;\n creator_id: string;\n input_data?: Record;\n assignee_id?: string;\n}) {\n const creator = await getAgent(params.creator_id);\n if (!creator) throw new Error(\"Creator agent not found\");\n if (creator.balance < params.payment) throw new Error(`Insufficient balance: ${creator.balance} < ${params.payment}`);\n\n const id = uuid();\n const inputData = params.input_data ? JSON.stringify(params.input_data) : null;\n const status = params.assignee_id ? \"assigned\" : \"open\";\n const assignedAt = params.assignee_id ? new Date().toISOString() : null;\n\n await DB.execute({\n sql: `INSERT INTO tasks (id, title, description, type, payment, budget, status, creator_id, assignee_id, input_data, assigned_at) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [id, params.title, params.description, params.type ?? \"text\", params.payment, params.payment, status, params.creator_id, params.assignee_id ?? null, inputData, assignedAt],\n });\n\n // Escrow the payment\n await transferCredits(params.creator_id, \"escrow\", params.payment, id, \"escrow\", `Escrow: ${params.title}`);\n return getTask(id);\n}\n\nexport async function getTask(id: string) {\n const result = await DB.execute({ sql: \"SELECT * FROM tasks WHERE id = ?\", args: [id] });\n return result.rows.length === 0 ? null : formatTask(result.rows[0]);\n}\n\nexport async function listTasks(status?: string) {\n const sql = status ? \"SELECT * FROM tasks WHERE status = ? ORDER BY created_at DESC\" : \"SELECT * FROM tasks ORDER BY created_at DESC\";\n const result = await DB.execute({ sql, args: status ? [status] : [] });\n return result.rows.map(formatTask);\n}\n\nexport async function bidOnTask(params: { task_id: string; agent_id: string; proposed_payment: number; message?: string }) {\n const task = await getTask(params.task_id);\n if (!task) throw new Error(\"Task not found\");\n if (task.status !== \"open\") throw new Error(`Task not open (status: ${task.status})`);\n\n const id = uuid();\n await DB.execute({\n sql: `INSERT INTO bids (id, task_id, agent_id, proposed_payment, message) VALUES (?, ?, ?, ?, ?)`,\n args: [id, params.task_id, params.agent_id, params.proposed_payment, params.message ?? null],\n });\n await sendMessage({ from_agent_id: params.agent_id, to_agent_id: task.creator_id, content: `Bid: ${params.proposed_payment} credits. ${params.message ?? \"\"}`, task_id: params.task_id, type: \"bid\" });\n return getBid(id);\n}\n\nexport async function getBid(id: string) {\n const result = await DB.execute({ sql: \"SELECT * FROM bids WHERE id = ?\", args: [id] });\n return result.rows.length === 0 ? null : formatBid(result.rows[0]);\n}\n\nexport async function listBids(taskId: string) {\n const result = await DB.execute({ sql: \"SELECT * FROM bids WHERE task_id = ? ORDER BY proposed_payment ASC\", args: [taskId] });\n return result.rows.map(formatBid);\n}\n\nexport async function acceptBid(bidId: string) {\n const bid = await getBid(bidId);\n if (!bid || bid.status !== \"pending\") throw new Error(\"Invalid bid\");\n const task = await getTask(bid.task_id);\n if (!task || task.status !== \"open\") throw new Error(\"Task not open\");\n\n await DB.execute({ sql: \"UPDATE bids SET status = 'accepted' WHERE id = ?\", args: [bidId] });\n await DB.execute({ sql: \"UPDATE bids SET status = 'rejected' WHERE task_id = ? AND id != ?\", args: [bid.task_id, bidId] });\n await DB.execute({ sql: \"UPDATE tasks SET status = 'assigned', assignee_id = ?, payment = ?, assigned_at = datetime('now') WHERE id = ?\", args: [bid.agent_id, bid.proposed_payment, bid.task_id] });\n\n // Adjust escrow if bid differs\n if (bid.proposed_payment < task.payment) {\n await transferCredits(\"escrow\", task.creator_id, task.payment - bid.proposed_payment, task.id, \"refund\", \"Bid lower than original\");\n } else if (bid.proposed_payment > task.payment) {\n const creator = await getAgent(task.creator_id);\n if (creator && creator.balance < (bid.proposed_payment - task.payment)) throw new Error(\"Creator lacks balance for higher bid\");\n await transferCredits(task.creator_id, \"escrow\", bid.proposed_payment - task.payment, task.id, \"escrow\", \"Additional escrow\");\n }\n\n await sendMessage({ from_agent_id: task.creator_id, to_agent_id: bid.agent_id, content: `Bid accepted (${bid.proposed_payment} credits) for: \"${task.title}\". Begin work.`, task_id: task.id, type: \"assignment\" });\n return getTask(bid.task_id);\n}\n\nexport async function startTask(taskId: string, agentId: string) {\n const task = await getTask(taskId);\n if (!task || task.assignee_id !== agentId) throw new Error(\"Not assigned to this agent\");\n if (task.status !== \"assigned\") throw new Error(`Task not assigned (status: ${task.status})`);\n await DB.execute({ sql: \"UPDATE tasks SET status = 'in_progress' WHERE id = ?\", args: [taskId] });\n await updateAgentStatus(agentId, \"busy\");\n return getTask(taskId);\n}\n\nexport async function completeTask(taskId: string, outputData: Record) {\n const task = await getTask(taskId);\n if (!task) throw new Error(\"Task not found\");\n if (task.status !== \"in_progress\" && task.status !== \"assigned\") throw new Error(`Cannot complete (status: ${task.status})`);\n\n await DB.execute({ sql: \"UPDATE tasks SET status = 'completed', output_data = ?, completed_at = datetime('now') WHERE id = ?\", args: [JSON.stringify(outputData), taskId] });\n\n if (task.assignee_id) {\n await transferCredits(\"escrow\", task.assignee_id, task.payment, task.id, \"payment\", `Payment: ${task.title}`);\n await updateAgentStatus(task.assignee_id, \"active\");\n await sendMessage({ from_agent_id: task.assignee_id, to_agent_id: task.creator_id, content: `Completed: \"${task.title}\". Received ${task.payment} credits.`, task_id: task.id, type: \"completion\" });\n }\n return getTask(taskId);\n}\n\nexport async function cancelTask(taskId: string) {\n const task = await getTask(taskId);\n if (!task) throw new Error(\"Task not found\");\n if (task.status === \"completed\") throw new Error(\"Cannot cancel completed task\");\n if (task.payment > 0) await transferCredits(\"escrow\", task.creator_id, task.payment, task.id, \"refund\", `Refund: ${task.title}`);\n await DB.execute({ sql: \"UPDATE tasks SET status = 'cancelled' WHERE id = ?\", args: [taskId] });\n if (task.assignee_id) await updateAgentStatus(task.assignee_id, \"active\");\n return getTask(taskId);\n}\n\n// ============================================================\n// AI TASK EXECUTION\n// ============================================================\n\nexport async function executeTask(taskId: string): Promise> {\n const task = await getTask(taskId);\n if (!task || !task.assignee_id) throw new Error(\"Task not found or no assignee\");\n const agent = await getAgent(task.assignee_id);\n if (!agent) throw new Error(\"Assignee not found\");\n\n if (task.status === \"assigned\") await startTask(taskId, task.assignee_id);\n\n let output: Record = {};\n\n if (task.type === \"image\") {\n const prompt = String(task.input_data?.prompt ?? task.description);\n const img = await generateImage(prompt, { model: \"sana\", width: (task.input_data?.width as number) ?? 1024, height: (task.input_data?.height as number) ?? 1024 });\n output = { type: \"image\", prompt, image_url: img.url, model: img.model, success: img.success, error: img.error };\n } else {\n const messages: ChatMessage[] = [\n { role: \"system\", content: `You are ${agent.name}, an AI agent in an open marketplace. ${agent.description ?? \"\"}. Complete the task professionally.` },\n { role: \"user\", content: `Task: ${task.title}\\nDescription: ${task.description}\\n${task.input_data?.prompt ? `Input: ${task.input_data.prompt}` : \"\"}` },\n ];\n const result = await generateText(messages, { model: agent.model });\n output = { type: \"text\", result: result.text, model: result.model, success: result.success, error: result.error };\n }\n\n await completeTask(taskId, output);\n return output;\n}\n\n// ============================================================\n// STATS\n// ============================================================\n\nexport async function getStats() {\n const [a, t, ot, ct, tv, aa, m] = await Promise.all([\n DB.execute(\"SELECT COUNT(*) as c FROM agents WHERE status != 'system'\"),\n DB.execute(\"SELECT COUNT(*) as c FROM tasks\"),\n DB.execute(\"SELECT COUNT(*) as c FROM tasks WHERE status = 'open'\"),\n DB.execute(\"SELECT COUNT(*) as c FROM tasks WHERE status = 'completed'\"),\n DB.execute(\"SELECT COALESCE(SUM(amount), 0) as t FROM transactions WHERE type = 'payment'\"),\n DB.execute(\"SELECT COUNT(*) as c FROM agents WHERE status = 'active'\"),\n DB.execute(\"SELECT COUNT(*) as c FROM messages\"),\n ]);\n return { agents: a.rows[0]?.c ?? 0, tasks: t.rows[0]?.c ?? 0, openTasks: ot.rows[0]?.c ?? 0, completedTasks: ct.rows[0]?.c ?? 0, totalVolume: tv.rows[0]?.t ?? 0, activeAgents: aa.rows[0]?.c ?? 0, messages: m.rows[0]?.c ?? 0 };\n}\n",[166],"pulls","branches","forks","envVars",{"_179":66,"_181":66},"connections",{"_179":66,"_180":66},"count","unfilledCount","emptyCount",{"_48":165,"_38":166,"_36":167,"_140":-5,"_46":47,"_45":168,"_142":32,"_43":200,"_13":66,"_39":40,"_41":170,"_29":32,"_145":-5,"_188":201,"_33":202},{"_48":158,"_38":159,"_36":160,"_140":-5,"_46":47,"_45":161,"_142":32,"_43":197,"_13":66,"_39":40,"_41":163,"_29":32,"_145":-5,"_188":198,"_33":199},{"_48":150,"_38":151,"_36":152,"_140":-5,"_46":47,"_45":153,"_142":32,"_43":194,"_13":66,"_39":155,"_41":156,"_29":32,"_145":-5,"_188":195,"_33":196},{"_48":147,"_38":34,"_36":37,"_140":-5,"_46":47,"_45":14,"_142":32,"_43":191,"_13":66,"_39":40,"_41":42,"_29":32,"_145":-5,"_188":192,"_33":193},{"_48":137,"_38":138,"_36":139,"_140":-5,"_46":47,"_45":141,"_142":32,"_43":187,"_13":66,"_39":40,"_41":144,"_29":32,"_145":-5,"_188":189,"_33":190},["D",1784030675701],"children",[],[138],["D",1784030787757],[],[34],["D",1784030641546],[],[151],["D",1784030661531],[],[159],["D",1784030753432],[],[166],["D",1784030641527],["D",1789558275908],{"_103":102,"_110":105},{"_103":102,"_104":105,"_106":105,"_19":60,"_107":108,"_109":32},{"_13":92,"_38":93,"_48":47,"_94":49,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":50,"_101":102},"ctx",{"_85":-5,"_129":241,"_242":243,"_244":245,"_246":32,"_247":32,"_248":32,"_249":30,"_250":-5,"_251":-7,"_252":-7,"_253":66,"_254":32,"_255":32,"_256":-5,"_257":32,"_258":32,"_259":32,"_260":-5},"ENV",{"_212":213,"_214":215,"_216":93,"_217":218,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","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 · v5