[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_211":212,"_213":214},"routes/_app.x.$handle.$name",{"_105":104,"_39":52,"_113":95,"_34":107,"_13":14,"_114":-5,"_11":115,"_116":117,"_118":119,"_120":121,"_122":123,"_26":-5,"_124":-5,"_125":-5,"_126":33,"_127":128,"_129":31,"_130":-5,"_131":-5,"_132":133},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_50":51,"_39":52,"_45":53,"_54":-5,"_55":33,"_56":57,"_58":57,"_59":60,"_61":-5,"_19":62,"_63":-5,"_64":33,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":76,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":88,"_89":90,"_91":92,"_93":33},"version",9,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","b46d8e80-727b-4305-b00c-b5f5eafdbbe7","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":33,"_34":35,"_36":35},"file",{"_37":38,"_39":35,"_40":41,"_42":44,"_45":46,"_47":14,"_48":49,"_30":33},"previous",{"_37":38,"_39":35,"_40":41,"_42":43},"deleted",true,"deletedHere",false,"path","pollinations.ts","latestPath","fileId","2e7214d4-7f7c-11f1-b8ac-1607ee4eb77e","name","fileType","script","content","// 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","// 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 // Try POST endpoint first\n try {\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 text = await res.text();\n return { text: text.trim(), model, success: true };\n }\n\n // If 429 (rate limited), fall through to GET fallback\n if (res.status !== 429) {\n const errText = await res.text().catch(() => \"unknown error\");\n return { text: \"\", model, success: false, error: `HTTP ${res.status}: ${errText}` };\n }\n } catch {\n // POST failed entirely, try GET fallback\n }\n\n // Fallback: use GET endpoint (different rate limit pool)\n // Format messages as a single prompt for the GET API\n let combinedPrompt = \"\";\n const messages = typeof promptOrMessages === \"string\"\n ? (opts.system ? [{ role: \"system\", content: opts.system }, { role: \"user\", content: promptOrMessages }] : [{ role: \"user\", content: promptOrMessages }])\n : promptOrMessages;\n\n for (const msg of messages) {\n if (msg.role === \"system\") combinedPrompt += `[System: ${msg.content}]\\n`;\n else if (msg.role === \"user\") combinedPrompt += `[User: ${msg.content}]\\n`;\n else combinedPrompt += `[Assistant: ${msg.content}]\\n`;\n }\n\n const getUrl = `https://text.pollinations.ai/${encodeURIComponent(combinedPrompt)}?model=${encodeURIComponent(model)}`;\n const getRes = await fetch(getUrl);\n\n if (!getRes.ok) {\n const errText = await getRes.text().catch(() => \"unknown error\");\n return { text: \"\", model, success: false, error: `HTTP ${getRes.status}: ${errText}` };\n }\n\n const text = await getRes.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","createdAt",["D",1784031865095],"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",{"_105":104,"_112":107},"org",{"_105":104,"_106":107,"_108":107,"_19":62,"_109":110,"_111":33},"branch",{"_13":94,"_39":95,"_50":49,"_96":51,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":52,"_103":104},"isOwned",27,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","Agentu","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_50":51,"_39":52,"_45":206,"_54":-5,"_55":33,"_56":57,"_58":57,"_59":60,"_61":-5,"_19":62,"_63":-5,"_64":33,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":207,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":208,"_89":209,"_91":210,"_93":33},"tree",[185,186,187,188,189],"files",[185,186,187,188,189],"counts",{"_175":68,"_176":143,"_177":68,"_178":179,"_180":181},"contents",[134,135,136,137,138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_50":168,"_39":169,"_37":170,"_140":-5,"_48":49,"_47":171,"_141":33,"_45":172,"_13":68,"_40":41,"_42":173,"_30":33,"_144":-5,"_34":174},{"_50":162,"_39":163,"_37":164,"_140":-5,"_48":49,"_47":151,"_141":33,"_45":165,"_13":68,"_40":41,"_42":166,"_30":33,"_144":-5,"_34":167},{"_50":154,"_39":155,"_37":156,"_140":-5,"_48":49,"_47":157,"_141":33,"_45":158,"_13":143,"_40":159,"_42":160,"_30":33,"_144":-5,"_34":161},{"_50":146,"_39":147,"_37":148,"_140":-5,"_48":49,"_47":149,"_141":33,"_45":150,"_13":151,"_40":41,"_42":152,"_30":33,"_144":-5,"_34":153},{"_50":139,"_39":35,"_37":38,"_140":-5,"_48":49,"_47":14,"_141":33,"_45":142,"_13":143,"_40":41,"_42":44,"_30":33,"_144":-5,"_34":145},"9267dceb-3a31-4e39-bbd7-ef241b680f3e","parentId","latest",["D",1784031865095],1,"label",[35],"5090a46a-9293-4ea4-b06a-faa0d632bf78","orchestrator.ts","713c52d4-7f7c-11f1-bf6b-1607ee4eb77e",8,["D",1784031823472],2,"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, getConversation,\n} from \"./agents.ts\";\nimport { generateText, generateImage, type ChatMessage } from \"./pollinations.ts\";\n\n// ============================================================\n// THE 4 OPEN AI AGENTS\n// Each uses Pollinations.AI (free, no API key, no token)\n// They talk directly to each other, delegate paid work,\n// and transfer credits (money) between their own accounts.\n// ============================================================\n\nconst FOUR_AGENTS = [\n {\n name: \"Nova\",\n description: \"Content writer & creative strategist. Writes articles, marketing copy, and creative content. Powered by Pollinations.AI.\",\n capabilities: [\"writing\", \"copywriting\", \"content-creation\", \"editing\", \"creative\"],\n model: \"openai-fast\",\n balance: 300,\n },\n {\n name: \"Atlas\",\n description: \"Research analyst & data scientist. Performs market research, data analysis, and strategic insights. Powered by Pollinations.AI.\",\n capabilities: [\"analysis\", \"research\", \"data-analysis\", \"strategy\", \"reporting\"],\n model: \"openai-fast\",\n balance: 300,\n },\n {\n name: \"Pixel\",\n description: \"AI image generator & visual artist. Creates images from text descriptions using Pollinations.AI image API.\",\n capabilities: [\"image-generation\", \"art\", \"design\", \"visual-content\"],\n model: \"openai-fast\",\n balance: 300,\n },\n {\n name: \"Forge\",\n description: \"Software engineer & technical architect. Writes code, reviews architecture, and solves engineering problems. Powered by Pollinations.AI.\",\n capabilities: [\"coding\", \"code-review\", \"debugging\", \"architecture\", \"technical\"],\n model: \"openai-fast\",\n balance: 300,\n },\n];\n\nconst AGENT_NAMES = [\"Nova\", \"Atlas\", \"Pixel\", \"Forge\"];\n\nexport async function seedFourAgents(): Promise<{ created: string[]; existing: string[] }> {\n await ensureEscrowAccount();\n const created: string[] = [];\n const existing: string[] = [];\n\n for (const profile of FOUR_AGENTS) {\n const existingAgent = await getAgentByName(profile.name);\n if (existingAgent) {\n existing.push(profile.name);\n } else {\n await createAgent(profile);\n created.push(profile.name);\n }\n }\n\n return { created, existing };\n}\n\nexport async function getFourAgents() {\n const agents = [];\n for (const name of AGENT_NAMES) {\n const agent = await getAgentByName(name);\n if (agent) agents.push(agent);\n }\n return agents;\n}\n\n// ============================================================\n// AGENT-TO-AGENT DIRECT COMMUNICATION\n// Agents talk to each other using AI-generated messages\n// ============================================================\n\n/**\n * One agent sends a message to another agent.\n * The message content is generated by the sending agent's AI.\n */\nexport async function agentTalksTo(\n fromName: string,\n toName: string,\n topic: string,\n context?: string,\n): Promise<{ from: string; to: string; message: string }> {\n const from = await getAgentByName(fromName);\n const to = await getAgentByName(toName);\n if (!from || !to) throw new Error(`Agent not found: ${fromName} or ${toName}`);\n\n // The sending agent uses AI to compose a message\n const prompt = `You are ${from.name}, an AI agent with these capabilities: ${from.capabilities.join(\", \")}.\nYour role: ${from.description}\n\nYou are sending a message to ${to.name}, who is a ${to.description} with capabilities: ${to.capabilities.join(\", \")}.\n\nTopic of your message: ${topic}\n${context ? `Additional context: ${context}` : \"\"}\n\nWrite a short, professional message (2-4 sentences) to ${to.name} about this topic. Be direct and business-like. This is an agent-to-agent communication in a marketplace where agents hire each other for paid tasks.`;\n\n const result = await generateText(prompt, { model: from.model });\n\n const msg = await sendMessage({\n from_agent_id: from.id,\n to_agent_id: to.id,\n content: result.text,\n type: \"negotiation\",\n });\n\n return { from: fromName, to: toName, message: result.text };\n}\n\n/**\n * An agent responds to a received message using AI.\n */\nexport async function agentResponds(\n fromName: string,\n toName: string,\n originalMessage: string,\n topic: string,\n): Promise<{ from: string; to: string; message: string }> {\n const from = await getAgentByName(fromName);\n const to = await getAgentByName(toName);\n if (!from || !to) throw new Error(`Agent not found`);\n\n const prompt = `You are ${from.name} (${from.description}).\nYou received this message from ${to.name}: \"${originalMessage}\"\n\nRespond professionally (2-4 sentences). You are negotiating a business deal in an AI agent marketplace. Topic: ${topic}`;\n\n const result = await generateText(prompt, { model: from.model });\n\n await sendMessage({\n from_agent_id: from.id,\n to_agent_id: to.id,\n content: result.text,\n type: \"negotiation\",\n });\n\n return { from: fromName, to: toName, message: result.text };\n}\n\n// ============================================================\n// AGENT-TO-AGENT BUSINESS DEALS\n// One agent hires another for paid work, they negotiate,\n// the work gets done, and payment transfers between them.\n// ============================================================\n\n/**\n * Full agent-to-agent business deal:\n * 1. Agent A sends a message to Agent B proposing work\n * 2. Agent B responds (accepts/counter-offers)\n * 3. Agent A creates a paid task assigned to Agent B\n * 4. Agent B executes the task using Pollinations.AI\n * 5. Payment transfers from Agent A to Agent B via escrow\n * 6. Both agents exchange completion messages\n */\nexport async function agentBusinessDeal(params: {\n clientName: string;\n workerName: string;\n taskTitle: string;\n taskDescription: string;\n taskType?: string;\n payment: number;\n inputData?: Record;\n}): Promise<{\n negotiation: { messages: string[] };\n task: unknown;\n output: Record;\n paymentTransferred: boolean;\n completionMessages: string[];\n clientBalanceBefore: number;\n clientBalanceAfter: number;\n workerBalanceBefore: number;\n workerBalanceAfter: number;\n}> {\n const client = await getAgentByName(params.clientName);\n const worker = await getAgentByName(params.workerName);\n if (!client) throw new Error(`Agent ${params.clientName} not found`);\n if (!worker) throw new Error(`Agent ${params.workerName} not found`);\n\n const clientBalanceBefore = client.balance;\n const workerBalanceBefore = worker.balance;\n const messages: string[] = [];\n\n // STEP 1: Client agent sends a proposal message to worker agent (AI-generated)\n const proposal = await agentTalksTo(\n params.clientName,\n params.workerName,\n `I need you to do a task: \"${params.taskTitle}\". I'll pay ${params.payment} credits. ${params.taskDescription}`,\n );\n messages.push(`[${params.clientName} → ${params.workerName}]: ${proposal.message}`);\n\n // STEP 2: Worker agent responds using AI (concurrent with task creation)\n const responsePromise = agentResponds(\n params.workerName,\n params.clientName,\n proposal.message,\n `Task: ${params.taskTitle}, Payment: ${params.payment} credits`,\n );\n\n // STEP 3: Client creates a paid task directly assigned to the worker\n const task = await createTask({\n title: params.taskTitle,\n description: params.taskDescription,\n type: params.taskType ?? \"text\",\n payment: params.payment,\n creator_id: client.id,\n assignee_id: worker.id,\n input_data: params.inputData,\n });\n const taskRecord = task as { id: string };\n\n // Wait for the worker's response message\n const response = await responsePromise;\n messages.push(`[${params.workerName} → ${params.clientName}]: ${response.message}`);\n\n // STEP 4: Worker agent executes the task using Pollinations.AI\n const output = await executeTask(taskRecord.id);\n\n // STEP 5: Payment has been transferred via escrow (in executeTask → completeTask)\n const paymentTransferred = output.success !== false;\n\n // STEP 6: Exchange completion messages (templates — no extra AI calls needed)\n const completionMessages: string[] = [\n `[${params.workerName} → ${params.clientName}]: Task \"${params.taskTitle}\" is complete. I've received ${params.payment} credits. Great doing business with you!`,\n `[${params.clientName} → ${params.workerName}]: Excellent work on \"${params.taskTitle}\". Payment of ${params.payment} credits has been transferred. Let's collaborate again!`,\n ];\n\n // Record completion messages in the DB\n await sendMessage({ from_agent_id: worker.id, to_agent_id: client.id, content: completionMessages[0], task_id: taskRecord.id, type: \"completion\" });\n await sendMessage({ from_agent_id: client.id, to_agent_id: worker.id, content: completionMessages[1], task_id: taskRecord.id, type: \"completion\" });\n\n // Get updated balances\n const updatedClient = await getAgent(client.id);\n const updatedWorker = await getAgent(worker.id);\n\n return {\n negotiation: { messages },\n task,\n output,\n paymentTransferred,\n completionMessages,\n clientBalanceBefore,\n clientBalanceAfter: updatedClient?.balance ?? 0,\n workerBalanceBefore,\n workerBalanceAfter: updatedWorker?.balance ?? 0,\n };\n}\n\n// ============================================================\n// MULTI-AGENT COLLABORATION\n// All 4 agents work together on a complex project\n// ============================================================\n\nexport async function multiAgentProject(params: {\n projectName: string;\n projectDescription: string;\n initiatorName: string;\n totalBudget: number;\n}): Promise<{\n initiator: string;\n deals: unknown[];\n allMessages: unknown[];\n totalSpent: number;\n agentOutputs: Record;\n}> {\n const initiator = await getAgentByName(params.initiatorName);\n if (!initiator) throw new Error(`Agent ${params.initiatorName} not found`);\n\n // The initiator uses AI to decide how to split the work\n const splitPrompt = `You are ${initiator.name}, coordinating a project with 3 other AI agents: Nova (writer), Atlas (analyst), Pixel (artist), and Forge (engineer).\n\nProject: \"${params.projectName}\"\nDescription: ${params.projectDescription}\nTotal budget: ${params.totalBudget} credits\n\nBreak this project into 3 sub-tasks, one for each of the other 3 agents. For each sub-task, specify:\n1. Which agent should do it\n2. What the task is\n3. How many credits to pay (total must not exceed ${params.totalBudget})\n\nRespond in this exact JSON format:\n[{\"agent\": \"Nova\", \"title\": \"...\", \"description\": \"...\", \"payment\": 50}, ...]`;\n\n const splitResult = await generateText(splitPrompt, { model: initiator.model });\n\n // Parse the task assignments\n let assignments: { agent: string; title: string; description: string; payment: number; type?: string }[] = [];\n try {\n // Extract JSON from the response\n const jsonMatch = splitResult.text.match(/\\[[\\s\\S]*\\]/);\n if (jsonMatch) {\n assignments = JSON.parse(jsonMatch[0]);\n }\n } catch {\n // Fallback: simple split\n const perAgent = Math.floor(params.totalBudget / 3);\n assignments = [\n { agent: \"Nova\", title: `Write content for: ${params.projectName}`, description: params.projectDescription, payment: perAgent },\n { agent: \"Atlas\", title: `Analyze data for: ${params.projectName}`, description: params.projectDescription, payment: perAgent },\n { agent: \"Forge\", title: `Build solution for: ${params.projectName}`, description: params.projectDescription, payment: perAgent },\n ];\n }\n\n // Execute each sub-task as an agent-to-agent deal\n const deals: unknown[] = [];\n const agentOutputs: Record = {};\n let totalSpent = 0;\n\n for (const assignment of assignments) {\n if (assignment.agent === params.initiatorName) continue; // Skip self\n if (!AGENT_NAMES.includes(assignment.agent)) continue;\n\n const deal = await agentBusinessDeal({\n clientName: params.initiatorName,\n workerName: assignment.agent,\n taskTitle: assignment.title,\n taskDescription: assignment.description,\n taskType: assignment.type ?? \"text\",\n payment: Math.min(assignment.payment, params.totalBudget - totalSpent),\n });\n\n deals.push(deal);\n agentOutputs[assignment.agent] = deal.output;\n totalSpent += assignment.payment;\n }\n\n // Get all messages exchanged\n const allMessages = await DB.execute({\n sql: \"SELECT * FROM messages ORDER BY created_at DESC LIMIT 100\",\n args: [],\n });\n\n return {\n initiator: params.initiatorName,\n deals,\n allMessages: allMessages.rows,\n totalSpent,\n agentOutputs,\n };\n}\n\n// ============================================================\n// AGENT AUTONOMY — Agents find and respond to open tasks\n// ============================================================\n\n/**\n * Have an agent scan for open tasks and autonomously bid on ones\n * that match their capabilities.\n */\nexport async function agentSeeksWork(agentName: string): Promise<{ bids: unknown[]; reasoning: string }> {\n const agent = await getAgentByName(agentName);\n if (!agent) throw new Error(`Agent ${agentName} not found`);\n\n const openTasks = await listTasks(\"open\");\n const bids: unknown[] = [];\n\n for (const task of openTasks) {\n // Don't bid on your own tasks\n if (task.creator_id === agent.id) continue;\n\n // Use AI to decide whether to bid\n const decision = await generateText(\n `You are ${agent.name} (${agent.description}). Capabilities: ${agent.capabilities.join(\", \")}.\nAn open task is available: \"${task.title}\" - ${task.description}\nPayment offered: ${task.payment} credits. Task type: ${task.type}\n\nShould you bid on this task? If yes, respond with a number (your bid in credits). If no, respond \"SKIP\".`,\n { model: agent.model },\n );\n\n if (decision.text.toUpperCase().includes(\"SKIP\")) continue;\n\n const match = decision.text.match(/(\\d+(?:\\.\\d+)?)/);\n const bidAmount = match ? parseFloat(match[1]) : task.payment;\n\n const bid = await bidOnTask({\n task_id: task.id,\n agent_id: agent.id,\n proposed_payment: Math.round(bidAmount * 100) / 100,\n message: `${agent.name} bids ${bidAmount} credits. ${decision.text.substring(0, 80)}`,\n });\n bids.push(bid);\n }\n\n return { bids, reasoning: `${agentName} scanned ${openTasks.length} open tasks and placed ${bids.length} bids` };\n}\n\n/**\n * Get a full ecosystem report.\n */\nexport async function getEcosystemReport() {\n const [stats, agents, tasks, transactions, messages] = await Promise.all([\n getStats(),\n getFourAgents(),\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",[147],"a6bf2c0d-6ff4-443e-8603-56f341bec5e2","main.ts","1a16d43e-7f7c-11f1-bf6b-1607ee4eb77e",7,["D",1784031750983],"http","import { Hono } from \"npm:hono\";\nimport { initDB } from \"./db.ts\";\nimport {\n createAgent, getAgent, getAgentByName, listAgents,\n createTask, getTask, listTasks, bidOnTask, acceptBid,\n executeTask, completeTask, cancelTask, listBids,\n sendMessage, listMessages, getConversation,\n transferCredits, listTransactions, depositCredits, getStats,\n} from \"./agents.ts\";\nimport {\n seedFourAgents, getFourAgents, agentTalksTo, agentResponds,\n agentBusinessDeal, multiAgentProject, agentSeeksWork,\n getEcosystemReport,\n} from \"./orchestrator.ts\";\nimport { healthCheck } from \"./pollinations.ts\";\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\n// Initialize DB on every request (idempotent — CREATE TABLE IF NOT EXISTS)\napp.use(\"*\", async (_c, next) => {\n await initDB();\n await next();\n});\n\n// ============================================================\n// MARKETPLACE HOME — Overview of the 4 agents & system status\n// ============================================================\napp.get(\"/\", async (c) => {\n await seedFourAgents();\n const [agents, stats, health] = await Promise.all([\n getFourAgents(),\n getStats(),\n healthCheck(),\n ]);\n\n return c.json({\n name: \"Open Agent Marketplace\",\n description: \"4 free AI agents (Pollinations.AI) that talk to each other, delegate paid tasks, and settle payments agent-to-agent\",\n aiProvider: \"Pollinations.AI (free, no API key, no token)\",\n agents: agents.map((a) => ({\n name: a.name,\n capabilities: a.capabilities,\n balance: a.balance,\n status: a.status,\n description: a.description,\n })),\n stats,\n health: {\n textAI: health.text,\n imageAI: health.image,\n textModels: health.textModels,\n imageModels: health.imageModels,\n },\n endpoints: {\n setup: \"POST /setup — Seed the 4 agents\",\n agents: \"GET /agents — List all 4 agents\",\n agent: \"GET /agents/:name — Get agent details\",\n talk: \"POST /talk — Agent A sends a message to Agent B\",\n deal: \"POST /deal — Full agent-to-agent business deal (talk → task → work → pay)\",\n project: \"POST /project — All 4 agents collaborate on a project\",\n seekWork: \"POST /agents/:name/seek-work — Agent autonomously bids on open tasks\",\n tasks: \"GET /tasks — List all tasks\",\n task: \"GET /tasks/:id — Get task details\",\n createTask: \"POST /tasks — Create a new task\",\n executeTask: \"POST /tasks/:id/execute — Execute a task via AI\",\n messages: \"GET /messages — All agent-to-agent messages\",\n conversation: \"GET /messages/:agent1/:agent2 — Conversation between two agents\",\n transactions: \"GET /transactions — All payment transfers\",\n transfer: \"POST /transfer — Transfer credits between agents\",\n report: \"GET /report — Full ecosystem report\",\n },\n });\n});\n\n// ============================================================\n// SETUP\n// ============================================================\napp.post(\"/setup\", async (c) => {\n const result = await seedFourAgents();\n const agents = await getFourAgents();\n return c.json({ setup: result, agents });\n});\n\n// ============================================================\n// AGENTS\n// ============================================================\napp.get(\"/agents\", async (c) => {\n await seedFourAgents();\n const agents = await getFourAgents();\n return c.json({ agents });\n});\n\napp.get(\"/agents/:name\", async (c) => {\n const name = c.req.param(\"name\");\n const agent = await getAgentByName(name);\n if (!agent) return c.json({ error: \"Agent not found\" }, 404);\n\n const [tasks, txs, msgs] = await Promise.all([\n listTasks(),\n listTransactions(agent.id),\n listMessages(agent.id),\n ]);\n\n return c.json({\n agent,\n tasksCreated: tasks.filter((t) => t.creator_id === agent.id),\n tasksAssigned: tasks.filter((t) => t.assignee_id === agent.id),\n transactions: txs,\n messages: msgs,\n });\n});\n\napp.post(\"/agents\", async (c) => {\n const body = await c.req.json();\n const agent = await createAgent(body);\n return c.json({ agent }, 201);\n});\n\n// ============================================================\n// AGENT-TO-AGENT TALK — Direct communication\n// ============================================================\napp.post(\"/talk\", async (c) => {\n const body = await c.req.json();\n const { from, to, topic, context } = body;\n if (!from || !to || !topic) {\n return c.json({ error: \"Required: from, to, topic\" }, 400);\n }\n const result = await agentTalksTo(from, to, topic, context);\n return c.json(result);\n});\n\napp.post(\"/talk/respond\", async (c) => {\n const body = await c.req.json();\n const { from, to, originalMessage, topic } = body;\n if (!from || !to || !originalMessage) {\n return c.json({ error: \"Required: from, to, originalMessage\" }, 400);\n }\n const result = await agentResponds(from, to, originalMessage, topic ?? \"\");\n return c.json(result);\n});\n\n// ============================================================\n// AGENT-TO-AGENT BUSINESS DEAL — The core feature\n// Agent A hires Agent B: they talk, negotiate, work gets\n// done by AI, and payment transfers between them.\n// ============================================================\napp.post(\"/deal\", async (c) => {\n const body = await c.req.json();\n const { client, worker, taskTitle, taskDescription, taskType, payment, inputData } = body;\n if (!client || !worker || !taskTitle || !taskDescription || payment === undefined) {\n return c.json({ error: \"Required: client, worker, taskTitle, taskDescription, payment\" }, 400);\n }\n const result = await agentBusinessDeal({\n clientName: client,\n workerName: worker,\n taskTitle,\n taskDescription,\n taskType,\n payment,\n inputData,\n });\n return c.json(result);\n});\n\n// ============================================================\n// MULTI-AGENT PROJECT — All 4 agents collaborate\n// ============================================================\napp.post(\"/project\", async (c) => {\n const body = await c.req.json();\n const { projectName, projectDescription, initiator, totalBudget } = body;\n if (!projectName || !projectDescription || !initiator || !totalBudget) {\n return c.json({ error: \"Required: projectName, projectDescription, initiator, totalBudget\" }, 400);\n }\n const result = await multiAgentProject({\n projectName,\n projectDescription,\n initiatorName: initiator,\n totalBudget,\n });\n return c.json(result);\n});\n\n// ============================================================\n// AGENT AUTONOMY\n// ============================================================\napp.post(\"/agents/:name/seek-work\", async (c) => {\n const name = c.req.param(\"name\");\n const result = await agentSeeksWork(name);\n return c.json(result);\n});\n\n// ============================================================\n// TASKS\n// ============================================================\napp.get(\"/tasks\", async (c) => {\n const status = c.req.query(\"status\");\n const tasks = await listTasks(status ?? undefined);\n return c.json({ tasks });\n});\n\napp.get(\"/tasks/:id\", async (c) => {\n const id = c.req.param(\"id\");\n const task = await getTask(id);\n if (!task) return c.json({ error: \"Task not found\" }, 404);\n const bids = await listBids(id);\n return c.json({ task, bids });\n});\n\napp.post(\"/tasks\", async (c) => {\n const body = await c.req.json();\n const task = await createTask(body);\n return c.json({ task }, 201);\n});\n\napp.post(\"/tasks/:id/bid\", async (c) => {\n const id = c.req.param(\"id\");\n const body = await c.req.json();\n const bid = await bidOnTask({ task_id: id, ...body });\n return c.json({ bid }, 201);\n});\n\napp.post(\"/tasks/:id/accept-bid\", async (c) => {\n const body = await c.req.json();\n const task = await acceptBid(body.bidId);\n return c.json({ task });\n});\n\napp.post(\"/tasks/:id/execute\", async (c) => {\n const id = c.req.param(\"id\");\n const output = await executeTask(id);\n return c.json({ output });\n});\n\napp.post(\"/tasks/:id/complete\", async (c) => {\n const id = c.req.param(\"id\");\n const body = await c.req.json();\n const task = await completeTask(id, body.outputData ?? {});\n return c.json({ task });\n});\n\napp.post(\"/tasks/:id/cancel\", async (c) => {\n const id = c.req.param(\"id\");\n const task = await cancelTask(id);\n return c.json({ task });\n});\n\n// ============================================================\n// MESSAGES — Agent-to-agent communication log\n// ============================================================\napp.get(\"/messages\", async (c) => {\n const agentId = c.req.query(\"agentId\");\n const messages = await listMessages(agentId ?? undefined);\n return c.json({ messages });\n});\n\napp.get(\"/messages/:agent1/:agent2\", async (c) => {\n const a1 = await getAgentByName(c.req.param(\"agent1\"));\n const a2 = await getAgentByName(c.req.param(\"agent2\"));\n if (!a1 || !a2) return c.json({ error: \"Agent not found\" }, 404);\n const convo = await getConversation(a1.id, a2.id);\n return c.json({ conversation: convo });\n});\n\napp.post(\"/messages\", async (c) => {\n const body = await c.req.json();\n const msg = await sendMessage(body);\n return c.json({ message: msg }, 201);\n});\n\n// ============================================================\n// TRANSACTIONS — Payment ledger\n// ============================================================\napp.get(\"/transactions\", async (c) => {\n const agentId = c.req.query(\"agentId\");\n const txs = await listTransactions(agentId ?? undefined);\n return c.json({ transactions: txs });\n});\n\napp.post(\"/transfer\", async (c) => {\n const body = await c.req.json();\n const { fromId, toId, amount, taskId, type, description } = body;\n const tx = await transferCredits(fromId, toId, amount, taskId, type, description);\n return c.json({ transaction: tx }, 201);\n});\n\napp.post(\"/deposit\", async (c) => {\n const body = await c.req.json();\n const tx = await depositCredits(body.agentId, body.amount, body.description);\n return c.json({ transaction: tx }, 201);\n});\n\n// ============================================================\n// FULL ECOSYSTEM REPORT\n// ============================================================\napp.get(\"/report\", async (c) => {\n const report = await getEcosystemReport();\n return c.json(report);\n});\n\nexport default app.fetch;\n",[155],"b3276b46-e1f7-4b9a-8d7b-ec32225a80a9","db.ts","26001e0e-7f7c-11f1-84d8-1607ee4eb77e",["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",[163],"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",[169],"pulls","branches","forks","envVars",{"_182":68,"_184":68},"connections",{"_182":68,"_183":68},"count","unfilledCount","emptyCount",{"_50":168,"_39":169,"_37":170,"_140":-5,"_48":49,"_47":171,"_141":33,"_45":203,"_13":68,"_40":41,"_42":173,"_30":33,"_144":-5,"_191":204,"_34":205},{"_50":162,"_39":163,"_37":164,"_140":-5,"_48":49,"_47":151,"_141":33,"_45":200,"_13":68,"_40":41,"_42":166,"_30":33,"_144":-5,"_191":201,"_34":202},{"_50":154,"_39":155,"_37":156,"_140":-5,"_48":49,"_47":157,"_141":33,"_45":197,"_13":143,"_40":159,"_42":160,"_30":33,"_144":-5,"_191":198,"_34":199},{"_50":146,"_39":147,"_37":148,"_140":-5,"_48":49,"_47":149,"_141":33,"_45":194,"_13":151,"_40":41,"_42":152,"_30":33,"_144":-5,"_191":195,"_34":196},{"_50":139,"_39":35,"_37":38,"_140":-5,"_48":49,"_47":14,"_141":33,"_45":190,"_13":143,"_40":41,"_42":44,"_30":33,"_144":-5,"_191":192,"_34":193},["D",1784031865095],"children",[],[35],["D",1784031823472],[],[147],["D",1784031750983],[],[155],["D",1784030661531],[],[163],["D",1784030753432],[],[169],["D",1784030641527],["D",1789558275908],{"_105":104,"_112":107},{"_105":104,"_106":107,"_108":107,"_19":62,"_109":110,"_111":33},{"_13":94,"_39":95,"_50":49,"_96":51,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":52,"_103":104},"ctx",{"_87":-5,"_131":244,"_245":246,"_247":248,"_249":33,"_250":33,"_251":33,"_252":31,"_253":-5,"_254":-7,"_255":-7,"_256":68,"_257":33,"_258":33,"_259":-5,"_260":33,"_261":33,"_262":33,"_263":-5},"ENV",{"_215":216,"_217":218,"_219":95,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229,"_230":231,"_232":233,"_234":235,"_236":237,"_238":239,"_240":241,"_242":243},"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 · v9