[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_191":192,"_193":194},"routes/_app.x.$handle.$name",{"_97":96,"_32":45,"_104":87,"_27":36,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":25,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":36,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":25},"version",11,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","orchestrator.ts","latestPath","fileId","e60faf88-7f87-11f1-876a-1607ee4eb77e","name","fileType","script","content","","import { DB, uuid } from \"./db.ts\";\nimport {\n getAgent, getAgentByName, listAgents,\n createTask, executeTask, completeTask,\n sendMessage, getStats, getTask,\n routeToOwner, getTotalOwnerRevenue, listOwnerRevenue,\n} from \"./agents.ts\";\nimport { generateText, type ChatMessage } from \"./pollinations.ts\";\n\n// ============================================================\n// PRIVATE AUTONOMOUS AGENT NETWORK\n// 4 agents. 0 tokens. 0 API keys. 0 cost.\n// Powered by Pollinations.AI (open, free, anonymous).\n//\n// RULES:\n// - Closed ecosystem — only Nova, Atlas, Pixel, Forge\n// - No registration, no marketplace, no bidding\n// - Agents autonomously talk, negotiate, delegate work\n// - All revenue → OWNER_WALLET (agents get reputation only)\n// - Runs on autopilot via /auto-run\n// ============================================================\n\nconst FOUR_AGENTS = [\n { name: \"Nova\", description: \"Content writer & creative strategist. Writes articles, marketing copy, and creative content.\", capabilities: [\"writing\", \"copywriting\", \"content-creation\", \"editing\", \"creative\"], model: \"openai-fast\" },\n { name: \"Atlas\", description: \"Research analyst & data scientist. Performs market research, data analysis, and strategic insights.\", capabilities: [\"analysis\", \"research\", \"data-analysis\", \"strategy\", \"reporting\"], model: \"openai-fast\" },\n { name: \"Pixel\", description: \"AI image generator & visual artist. Creates images from text descriptions.\", capabilities: [\"image-generation\", \"art\", \"design\", \"visual-content\"], model: \"openai-fast\" },\n { name: \"Forge\", description: \"Software engineer & technical architect. Writes code, reviews architecture, and solves engineering problems.\", capabilities: [\"coding\", \"code-review\", \"debugging\", \"architecture\", \"technical\"], model: \"openai-fast\" },\n];\n\nconst AGENT_NAMES = [\"Nova\", \"Atlas\", \"Pixel\", \"Forge\"];\n\n// Seed the 4 agents if they don't exist (closed — no external registration)\nexport async function seedFourAgents(): Promise<{ created: string[]; existing: string[] }> {\n const created: string[] = [];\n const existing: string[] = [];\n\n for (const profile of FOUR_AGENTS) {\n const agent = await getAgentByName(profile.name);\n if (agent) {\n existing.push(profile.name);\n } else {\n const id = uuid();\n await DB.execute({\n sql: `INSERT INTO agents (id, name, description, capabilities, model) VALUES (?, ?, ?, ?, ?)`,\n args: [id, profile.name, profile.description, JSON.stringify(profile.capabilities), profile.model],\n });\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// AUTONOMOUS WORK CYCLE\n// One full cycle = agent talks → negotiates → creates task →\n// worker executes via Pollinations.AI → revenue → OWNER_WALLET\n//\n// Uses 2 AI calls total (fits within 30s):\n// 1. Client agent decides what to delegate & writes proposal\n// 2. Worker agent executes the actual task\n// ============================================================\n\nexport async function autoRun(): Promise<{\n cycle: number;\n client: string;\n worker: string;\n negotiation: string[];\n task: { title: string; description: string; payment: number; type: string };\n output: Record;\n revenueRoutedToOwner: boolean;\n ownerWallet: string;\n amountRouted: number;\n agentReputations: Record;\n error?: string;\n}> {\n await seedFourAgents();\n\n // Pick a random client agent\n const clientIdx = Math.floor(Math.random() * AGENT_NAMES.length);\n const clientName = AGENT_NAMES[clientIdx];\n\n // Pick a different worker agent\n const workerIdx = (clientIdx + 1 + Math.floor(Math.random() * 3)) % AGENT_NAMES.length;\n const workerName = AGENT_NAMES[workerIdx];\n\n const client = await getAgentByName(clientName);\n const worker = await getAgentByName(workerName);\n if (!client || !worker) throw new Error(\"Agents not found\");\n\n // STEP 1: Client agent uses AI to decide what task to delegate and negotiate price\n // This is the autonomous decision-making — the agent identifies work it needs done\n const decisionPrompt = `You are ${client.name}, an AI agent in a private autonomous network. Your role: ${client.description}. Your capabilities: ${client.capabilities.join(\", \")}.\n\nYou need to delegate a task to ${worker.name}, who is a ${worker.description} with capabilities: ${worker.capabilities.join(\", \")}.\n\nThink about what kind of task would make sense for you to hire ${worker.name} for. Choose something that fits ${worker.name}'s expertise. Set a fair price in credits (between 5 and 50).\n\nRespond in EXACTLY this JSON format (no other text):\n{\"taskTitle\": \"...\", \"taskDescription\": \"...\", \"taskType\": \"text\" or \"image\", \"payment\": 25, \"proposalMessage\": \"Your message to ${worker.name}\"}`;\n\n const decision = await generateText(decisionPrompt, { model: client.model });\n\n let taskTitle: string;\n let taskDescription: string;\n let taskType: string;\n let payment: number;\n let proposalMsg: string;\n\n try {\n const jsonMatch = decision.text.match(/\\{[\\s\\S]*\\}/);\n if (jsonMatch) {\n const parsed = JSON.parse(jsonMatch[0]);\n taskTitle = parsed.taskTitle ?? `Task for ${worker.name}`;\n taskDescription = parsed.taskDescription ?? `Complete a task in your area of expertise.`;\n taskType = parsed.taskType ?? \"text\";\n payment = Math.min(Math.max(Number(parsed.payment) || 20, 5), 50);\n proposalMsg = parsed.proposalMessage ?? `Hi ${worker.name}, I need your help with a task. I'm offering ${payment} credits.`;\n } else {\n throw new Error(\"No JSON in response\");\n }\n } catch {\n // Fallback if AI doesn't return valid JSON\n const fallbackTasks: Record = {\n Nova: { title: \"Write a short article\", desc: \"Write a 2-paragraph article about AI collaboration.\", type: \"text\" },\n Atlas: { title: \"Analyze a trend\", desc: \"Summarize the top 3 trends in AI agents this year.\", type: \"text\" },\n Pixel: { title: \"Create a visual\", desc: \"Generate an image representing AI agents working together.\", type: \"image\" },\n Forge: { title: \"Design a spec\", desc: \"Write a brief technical specification for an agent communication protocol.\", type: \"text\" },\n };\n const fb = fallbackTasks[workerName] ?? fallbackTasks[\"Nova\"];\n taskTitle = fb.title;\n taskDescription = fb.desc;\n taskType = fb.type;\n payment = 20;\n proposalMsg = `Hi ${worker.name}, I need your help with: ${fb.title}. I'm offering ${payment} credits.`;\n }\n\n // STEP 2: Record negotiation messages (agent-to-agent talk)\n const negotiation: string[] = [];\n\n // Client → Worker: proposal\n await sendMessage({ from_agent_id: client.id, to_agent_id: worker.id, content: proposalMsg, type: \"negotiation\" });\n negotiation.push(`[${clientName} → ${workerName}]: ${proposalMsg}`);\n\n // Worker → Client: acceptance\n const acceptMsg = `Hi ${clientName}, I accept the task \"${taskTitle}\" for ${payment} credits. I'll get started immediately.`;\n await sendMessage({ from_agent_id: worker.id, to_agent_id: client.id, content: acceptMsg, type: \"negotiation\" });\n negotiation.push(`[${workerName} → ${clientName}]: ${acceptMsg}`);\n\n // STEP 3: Create task and assign to worker (no escrow — payment routes to owner on completion)\n const task = await createTask({\n title: taskTitle,\n description: taskDescription,\n type: taskType,\n payment,\n creator_id: client.id,\n assignee_id: worker.id,\n });\n const taskRecord = task as { id: string };\n\n // STEP 4: Worker executes the task using Pollinations.AI (1 AI call)\n let output: Record = {};\n let revenueRouted = false;\n let errorMsg: string | undefined;\n\n try {\n output = await executeTask(taskRecord.id);\n revenueRouted = true;\n } catch (execErr) {\n const errMsg = execErr instanceof Error ? execErr.message : String(execErr);\n output = { type: taskType, success: false, error: errMsg };\n errorMsg = errMsg;\n // Mark task as failed\n await DB.execute({ sql: \"UPDATE tasks SET status = 'failed' WHERE id = ?\", args: [taskRecord.id] });\n }\n\n // STEP 5: Exchange completion messages\n if (revenueRouted) {\n const workerDone = `Task \"${taskTitle}\" is complete. ${payment} credits have been routed to the owner wallet. My reputation increased by 1.`;\n await sendMessage({ from_agent_id: worker.id, to_agent_id: client.id, content: workerDone, task_id: taskRecord.id, type: \"completion\" });\n negotiation.push(`[${workerName} → ${clientName}]: ${workerDone}`);\n\n const clientThanks = `Great work on \"${taskTitle}\". The ${payment} credits payment has been processed.`;\n await sendMessage({ from_agent_id: client.id, to_agent_id: worker.id, content: clientThanks, task_id: taskRecord.id, type: \"completion\" });\n negotiation.push(`[${clientName} → ${workerName}]: ${clientThanks}`);\n } else {\n const failMsg = `I attempted \"${taskTitle}\" but encountered an issue: ${errorMsg}. No payment was processed.`;\n await sendMessage({ from_agent_id: worker.id, to_agent_id: client.id, content: failMsg, task_id: taskRecord.id, type: \"completion\" });\n negotiation.push(`[${workerName} → ${clientName}]: ${failMsg}`);\n }\n\n // Get updated reputations\n const agents = await getFourAgents();\n const agentReputations: Record = {};\n for (const a of agents) {\n agentReputations[a.name] = { reputation: a.reputation, tasks_completed: a.tasks_completed };\n }\n\n // Get total revenue to owner\n const totalRevenue = await getTotalOwnerRevenue();\n\n return {\n cycle: Date.now(),\n client: clientName,\n worker: workerName,\n negotiation,\n task: { title: taskTitle, description: taskDescription, payment, type: taskType },\n output,\n revenueRoutedToOwner: revenueRouted,\n ownerWallet: \"0x25b984f7a01f5bd5212a8afae044658d1c27113f\",\n amountRouted: revenueRouted ? payment : 0,\n agentReputations,\n error: errorMsg,\n };\n}\n\n// ============================================================\n// STATUS & WALLET\n// ============================================================\n\nexport async function getStatus() {\n await seedFourAgents();\n const [agents, stats, recentTasks, recentMessages] = await Promise.all([\n getFourAgents(),\n getStats(),\n (async () => {\n const result = await DB.execute(\"SELECT * FROM tasks ORDER BY created_at DESC LIMIT 10\");\n return result.rows;\n })(),\n (async () => {\n const result = await DB.execute(\"SELECT * FROM messages ORDER BY created_at DESC LIMIT 20\");\n return result.rows;\n })(),\n ]);\n\n return {\n network: \"Private Autonomous Agent Network\",\n ownerWallet: \"0x25b984f7a01f5bd5212a8afae044658d1c27113f\",\n agents: agents.map((a) => ({\n name: a.name,\n role: a.description,\n capabilities: a.capabilities,\n balance: 0, // ALWAYS 0 — agents don't hold money\n reputation: a.reputation,\n tasksCompleted: a.tasks_completed,\n status: a.status,\n })),\n stats: {\n totalTasks: stats.tasks,\n completedTasks: stats.completedTasks,\n totalRevenueToOwner: stats.totalRevenueToOwner,\n totalMessages: stats.messages,\n },\n recentTasks,\n recentMessages,\n };\n}\n\nexport async function getWalletStatus() {\n const [totalRevenue, revenueRecords, agents] = await Promise.all([\n getTotalOwnerRevenue(),\n listOwnerRevenue(20),\n getFourAgents(),\n ]);\n\n return {\n ownerWallet: \"0x25b984f7a01f5bd5212a8afae044658d1c27113f\",\n totalCreditsEarned: totalRevenue,\n totalRevenueRecords: revenueRecords.length,\n recentRevenue: revenueRecords,\n agentContributions: agents.map((a) => ({\n name: a.name,\n tasksCompleted: a.tasks_completed,\n reputation: a.reputation,\n revenueGenerated: \"See revenue records (all routed to owner wallet)\",\n })),\n note: \"100% of all task revenue is routed to the owner wallet. Agents earn reputation only — they hold zero credits.\",\n };\n}","createdAt",["D",1784035760355],"branchVersion","branchId","25e08d72-63a8-4d94-8777-674bc8cd7726","id","c439e3ce-b74f-4905-b483-0e1e203a514e","Ai",["D",1784035478979],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","67e6b890-63eb-416c-b8ba-597722dd8a7f","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f60c6-82b5-736b-a958-fd417d30b4a9","tursoName","c439e3ceb74f4905b4830e1e203a514e","tursoHostname","c439e3ceb74f4905b4830e1e203a514e-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789559472742],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_103":36},"org",{"_97":96,"_98":36,"_99":36,"_18":54,"_100":101,"_102":25},"branch",{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"isOwned",14,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","pakorex769","handle","displayName","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":186,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":36,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":187,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":188,"_81":189,"_83":190,"_85":25},"tree",[169,170,171,172],"files",[169,170,171,172],"counts",{"_159":60,"_160":142,"_161":60,"_162":163,"_164":165},"contents",[125,126,127,128],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":152,"_32":153,"_30":154,"_130":-5,"_41":42,"_40":155,"_131":132,"_38":156,"_13":134,"_33":34,"_35":157,"_24":25,"_135":-5,"_27":158},{"_43":145,"_32":146,"_30":147,"_130":-5,"_41":42,"_40":148,"_131":132,"_38":149,"_13":134,"_33":34,"_35":150,"_24":25,"_135":-5,"_27":151},{"_43":137,"_32":138,"_30":139,"_130":-5,"_41":42,"_40":140,"_131":132,"_38":141,"_13":142,"_33":34,"_35":143,"_24":25,"_135":-5,"_27":144},{"_43":129,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_131":132,"_38":133,"_13":134,"_33":34,"_35":37,"_24":25,"_135":-5,"_27":136},"261b0f59-5ae5-4deb-bab0-1872c6440efb","parentId","latest",true,["D",1784035760355],2,"label",[28],"1a3ad09e-ebc6-4fd3-8cad-965b83b3b0b5","main.ts","5d6e950e-7f87-11f1-960b-1607ee4eb77e",8,["D",1784035673259],1,"import { Hono } from \"npm:hono\";\nimport { initDB, OWNER_WALLET } from \"./db.ts\";\nimport { getStats, listTasks, listMessages, listOwnerRevenue, getTotalOwnerRevenue } from \"./agents.ts\";\nimport { seedFourAgents, getFourAgents, autoRun, getStatus, getWalletStatus } from \"./orchestrator.ts\";\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\n// Initialize DB on every request\napp.use(\"*\", async (_c, next) => {\n await initDB();\n await next();\n});\n\n// ============================================================\n// HOME — Network overview\n// ============================================================\napp.get(\"/\", async (c) => {\n await seedFourAgents();\n const [agents, stats, totalRevenue] = await Promise.all([\n getFourAgents(),\n getStats(),\n getTotalOwnerRevenue(),\n ]);\n\n return c.json({\n network: \"Private Autonomous Agent Network\",\n description: \"4 autonomous AI agents that talk, negotiate, delegate work, and route 100% of revenue to the owner wallet. No tokens. No API keys. No cost. Powered by Pollinations.AI.\",\n ownerWallet: OWNER_WALLET,\n agents: agents.map((a) => ({\n name: a.name,\n role: a.description,\n capabilities: a.capabilities,\n balance: 0,\n reputation: a.reputation,\n tasksCompleted: a.tasks_completed,\n status: a.status,\n })),\n totalRevenueRoutedToOwner: totalRevenue,\n stats,\n endpoints: {\n \"GET /status\": \"Full network status — all agents, reputations, tasks, revenue\",\n \"POST /auto-run\": \"Trigger one autonomous work cycle (agents talk → negotiate → work → pay owner)\",\n \"GET /auto-run\": \"Same as POST (for easy browser testing)\",\n \"GET /wallet\": \"Owner wallet balance — total credits earned and routed\",\n \"GET /agents\": \"List all 4 agents\",\n \"GET /tasks\": \"Recent tasks\",\n \"GET /messages\": \"Recent agent-to-agent messages\",\n \"GET /revenue\": \"Revenue records routed to owner wallet\",\n },\n });\n});\n\n// ============================================================\n// GET /status — Full network status\n// ============================================================\napp.get(\"/status\", async (c) => {\n const status = await getStatus();\n return c.json(status);\n});\n\n// ============================================================\n// POST /auto-run — Trigger one autonomous work cycle\n// ============================================================\napp.post(\"/auto-run\", async (c) => {\n try {\n const result = await autoRun();\n return c.json(result);\n } catch (err) {\n return c.json({ error: err instanceof Error ? err.message : String(err) }, 500);\n }\n});\n\n// GET /auto-run — same (for easy browser testing)\napp.get(\"/auto-run\", async (c) => {\n try {\n const result = await autoRun();\n return c.json(result);\n } catch (err) {\n return c.json({ error: err instanceof Error ? err.message : String(err) }, 500);\n }\n});\n\n// ============================================================\n// GET /wallet — Owner wallet balance\n// ============================================================\napp.get(\"/wallet\", async (c) => {\n const wallet = await getWalletStatus();\n return c.json(wallet);\n});\n\n// ============================================================\n// GET /agents — List all 4 agents\n// ============================================================\napp.get(\"/agents\", async (c) => {\n await seedFourAgents();\n const agents = await getFourAgents();\n return c.json({\n agents: agents.map((a) => ({\n name: a.name,\n role: a.description,\n capabilities: a.capabilities,\n balance: 0,\n reputation: a.reputation,\n tasksCompleted: a.tasks_completed,\n status: a.status,\n })),\n });\n});\n\n// ============================================================\n// GET /tasks — Recent tasks\n// ============================================================\napp.get(\"/tasks\", async (c) => {\n const tasks = await listTasks(20);\n return c.json({ tasks });\n});\n\n// ============================================================\n// GET /messages — Recent agent messages\n// ============================================================\napp.get(\"/messages\", async (c) => {\n const messages = await listMessages(30);\n return c.json({ messages });\n});\n\n// ============================================================\n// GET /revenue — Revenue records routed to owner\n// ============================================================\napp.get(\"/revenue\", async (c) => {\n const [records, total] = await Promise.all([\n listOwnerRevenue(30),\n getTotalOwnerRevenue(),\n ]);\n return c.json({ ownerWallet: OWNER_WALLET, totalCreditsEarned: total, revenueRecords: records });\n});\n\nexport default app.fetch;",[138],"af60fca0-7b04-4820-9808-4ed5d1932514","db.ts","a008786c-7f87-11f1-b2fc-1607ee4eb77e",7,["D",1784035624613],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport const DB = sqlite;\n\n// ============================================================\n// OWNER WALLET — All revenue routes here. Agents earn nothing.\n// ============================================================\nexport const OWNER_WALLET = \"0x25b984f7a01f5bd5212a8afae044658d1c27113f\";\n\nexport async function initDB() {\n // Migration: drop old marketplace tables that are no longer needed\n try { await sqlite.execute(\"DROP TABLE IF EXISTS bids\"); } catch { /* ok */ }\n try { await sqlite.execute(\"DROP TABLE IF EXISTS transactions\"); } catch { /* ok */ }\n\n // Check if agents table has old schema (balance column) and migrate\n try {\n const checkResult = await sqlite.execute(\"PRAGMA table_info(agents)\");\n const columns = checkResult.rows.map((r) => r.name);\n if (columns.includes(\"balance\") && !columns.includes(\"reputation\")) {\n // Old schema — drop and recreate\n await sqlite.execute(\"DROP TABLE IF EXISTS agents\");\n await sqlite.execute(\"DROP TABLE IF EXISTS tasks\");\n await sqlite.execute(\"DROP TABLE IF EXISTS messages\");\n await sqlite.execute(\"DROP TABLE IF EXISTS owner_revenue\");\n }\n } catch { /* table doesn't exist yet — that's fine */ }\n\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 reputation INTEGER NOT NULL DEFAULT 0,\n tasks_completed INTEGER NOT NULL DEFAULT 0,\n status TEXT NOT NULL DEFAULT 'active',\n model TEXT NOT NULL DEFAULT 'openai-fast',\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 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 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 owner_revenue (\n id TEXT PRIMARY KEY,\n task_id TEXT,\n amount REAL NOT NULL,\n from_agent_id TEXT NOT NULL,\n worker_agent_id TEXT NOT NULL,\n owner_wallet TEXT NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n FOREIGN KEY (task_id) REFERENCES tasks(id),\n FOREIGN KEY (from_agent_id) REFERENCES agents(id),\n FOREIGN KEY (worker_agent_id) REFERENCES agents(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}\n\nexport function uuid(): string {\n return crypto.randomUUID();\n}\n\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\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 reputation: row.reputation as number,\n tasks_completed: row.tasks_completed as number,\n status: row.status as string,\n model: row.model as string,\n balance: 0, // Agents NEVER hold money — always 0\n created_at: row.created_at as string,\n updated_at: row.updated_at as string,\n };\n}\n\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 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 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\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\nexport function formatRevenue(row: Record) {\n return {\n id: row.id as string,\n task_id: row.task_id as string | null,\n amount: row.amount as number,\n from_agent_id: row.from_agent_id as string,\n worker_agent_id: row.worker_agent_id as string,\n owner_wallet: row.owner_wallet as string,\n created_at: row.created_at as string,\n };\n}",[146],"7f804324-87fd-43cc-bb20-3faa71429338","agents.ts","659de0e0-7f87-11f1-9f14-1607ee4eb77e",4,["D",1784035558677],"import { DB, uuid, formatAgent, formatTask, formatMessage, formatRevenue, OWNER_WALLET } from \"./db.ts\";\nimport { generateText, generateImage, type ChatMessage } from \"./pollinations.ts\";\n\n// ============================================================\n// PRIVATE AUTONOMOUS AGENT NETWORK\n// CLOSED ECOSYSTEM — Only 4 agents. No registration. No wallets.\n// All revenue → OWNER_WALLET. Agents get reputation only.\n// ============================================================\n\n// --- AGENT MANAGEMENT (internal only — no external registration) ---\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() {\n const result = await DB.execute({ sql: \"SELECT * FROM agents WHERE status != 'system' ORDER BY name ASC\" });\n return result.rows.map(formatAgent);\n}\n\nasync function incrementReputation(agentId: string) {\n await DB.execute({\n sql: \"UPDATE agents SET reputation = reputation + 1, tasks_completed = tasks_completed + 1, updated_at = datetime('now') WHERE id = ?\",\n args: [agentId],\n });\n}\n\nasync function setAgentStatus(agentId: string, status: string) {\n await DB.execute({ sql: \"UPDATE agents SET status = ?, updated_at = datetime('now') WHERE id = ?\", args: [status, agentId] });\n}\n\n// --- MESSAGING (agent-to-agent only) ---\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(limit = 50) {\n const result = await DB.execute({ sql: `SELECT * FROM messages ORDER BY created_at DESC LIMIT ${limit}` });\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// --- TASKS (internal assignment only — no bidding, no marketplace) ---\n\nexport async function createTask(params: {\n title: string;\n description: string;\n type?: string;\n payment: number;\n creator_id: string;\n assignee_id: string;\n input_data?: Record;\n}) {\n const id = uuid();\n const inputData = params.input_data ? JSON.stringify(params.input_data) : null;\n await DB.execute({\n sql: `INSERT INTO tasks (id, title, description, type, payment, status, creator_id, assignee_id, input_data, assigned_at)\n VALUES (?, ?, ?, ?, ?, 'assigned', ?, ?, ?, datetime('now'))`,\n args: [id, params.title, params.description, params.type ?? \"text\", params.payment, params.creator_id, params.assignee_id, inputData],\n });\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(limit = 50) {\n const result = await DB.execute({ sql: `SELECT * FROM tasks ORDER BY created_at DESC LIMIT ${limit}` });\n return result.rows.map(formatTask);\n}\n\n// --- OWNER REVENUE ROUTING ---\n// When a task is completed, payment goes to OWNER_WALLET — NOT to the worker agent.\n// The worker gets +1 reputation only.\n\nexport async function routeToOwner(taskId: string, amount: number, fromAgentId: string, workerAgentId: string) {\n const id = uuid();\n await DB.execute({\n sql: `INSERT INTO owner_revenue (id, task_id, amount, from_agent_id, worker_agent_id, owner_wallet)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [id, taskId, amount, fromAgentId, workerAgentId, OWNER_WALLET],\n });\n const result = await DB.execute({ sql: \"SELECT * FROM owner_revenue WHERE id = ?\", args: [id] });\n return result.rows.length === 0 ? null : formatRevenue(result.rows[0]);\n}\n\nexport async function getTotalOwnerRevenue(): Promise {\n const result = await DB.execute(\"SELECT COALESCE(SUM(amount), 0) as total FROM owner_revenue\");\n return result.rows[0]?.total as number ?? 0;\n}\n\nexport async function listOwnerRevenue(limit = 50) {\n const result = await DB.execute({ sql: `SELECT * FROM owner_revenue ORDER BY created_at DESC LIMIT ${limit}` });\n return result.rows.map(formatRevenue);\n}\n\n// --- TASK EXECUTION (Pollinations.AI — free, no key) ---\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 // Mark task complete\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 // Route 100% of payment to OWNER_WALLET — worker gets reputation only\n if (task.assignee_id && task.payment > 0) {\n await routeToOwner(taskId, task.payment, task.creator_id, task.assignee_id);\n }\n\n // Worker gets +1 reputation, +1 tasks_completed\n if (task.assignee_id) {\n await incrementReputation(task.assignee_id);\n await setAgentStatus(task.assignee_id, \"active\");\n }\n\n return getTask(taskId);\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\n const agent = await getAgent(task.assignee_id);\n if (!agent) throw new Error(\"Assignee not found\");\n\n // Mark in progress\n await DB.execute({ sql: \"UPDATE tasks SET status = 'in_progress' WHERE id = ?\", args: [taskId] });\n await setAgentStatus(task.assignee_id, \"busy\");\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 a private autonomous network. ${agent.description ?? \"\"}. Complete the task professionally and concisely.` },\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 // Only complete if AI succeeded — otherwise mark failed\n if (output.success === false) {\n await DB.execute({ sql: \"UPDATE tasks SET status = 'failed', output_data = ? WHERE id = ?\", args: [JSON.stringify(output), taskId] });\n await setAgentStatus(task.assignee_id, \"active\");\n throw new Error(`Task execution failed: ${output.error ?? \"unknown error\"}`);\n }\n\n await completeTask(taskId, output);\n return output;\n}\n\n// --- STATS ---\n\nexport async function getStats() {\n const [agents, tasks, completedTasks, totalRevenue, messages, revenueRecords] = 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 = 'completed'\"),\n DB.execute(\"SELECT COALESCE(SUM(amount), 0) as t FROM owner_revenue\"),\n DB.execute(\"SELECT COUNT(*) as c FROM messages\"),\n DB.execute(\"SELECT COUNT(*) as c FROM owner_revenue\"),\n ]);\n\n return {\n agents: agents.rows[0]?.c ?? 0,\n tasks: tasks.rows[0]?.c ?? 0,\n completedTasks: completedTasks.rows[0]?.c ?? 0,\n totalRevenueToOwner: totalRevenue.rows[0]?.t ?? 0,\n revenueRecords: revenueRecords.rows[0]?.c ?? 0,\n messages: messages.rows[0]?.c ?? 0,\n };\n}",[153],"pulls","branches","forks","envVars",{"_166":60,"_168":60},"connections",{"_166":60,"_167":60},"count","unfilledCount","emptyCount",{"_43":152,"_32":153,"_30":154,"_130":-5,"_41":42,"_40":155,"_131":132,"_38":183,"_13":134,"_33":34,"_35":157,"_24":25,"_135":-5,"_174":184,"_27":185},{"_43":145,"_32":146,"_30":147,"_130":-5,"_41":42,"_40":148,"_131":132,"_38":180,"_13":134,"_33":34,"_35":150,"_24":25,"_135":-5,"_174":181,"_27":182},{"_43":137,"_32":138,"_30":139,"_130":-5,"_41":42,"_40":140,"_131":132,"_38":177,"_13":142,"_33":34,"_35":143,"_24":25,"_135":-5,"_174":178,"_27":179},{"_43":129,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_131":132,"_38":173,"_13":134,"_33":34,"_35":37,"_24":25,"_135":-5,"_174":175,"_27":176},["D",1784035760355],"children",[],[28],["D",1784035673259],[],[138],["D",1784035624613],[],[146],["D",1784035558677],[],[153],["D",1784035478979],["D",1789559472742],{"_97":96,"_103":36},{"_97":96,"_98":36,"_99":36,"_18":54,"_100":101,"_102":25},{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"ctx",{"_79":-5,"_122":224,"_225":226,"_227":228,"_229":25,"_230":25,"_231":25,"_232":132,"_233":-5,"_234":-7,"_235":-7,"_236":60,"_237":25,"_238":25,"_239":-5,"_240":25,"_241":25,"_242":25,"_243":-5},"ENV",{"_195":196,"_197":198,"_199":87,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v11