[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_210":211,"_212":213},"routes/_app.x.$handle.$name",{"_106":105,"_38":51,"_114":96,"_33":108,"_13":14,"_115":-5,"_11":116,"_117":118,"_119":120,"_121":122,"_123":124,"_26":-5,"_125":-5,"_126":-5,"_127":31,"_128":129,"_130":65,"_131":-5,"_132":-5,"_133":134},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":77,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":89,"_90":91,"_92":93,"_94":31},"version",6,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","edb2d7a7-e0ca-4d7b-8d1f-865577e21643","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":34,"_39":40,"_41":42},"deleted",false,"deletedHere","path","db.ts","latestPath","fileId","f20fd8b4-7fb2-11f1-b08a-1607ee4eb77e","name","fileType","script","content","// db.ts — SQLite persistence layer for the Autonomous Agent Network\n// Tables: tasks, agent_messages, handoffs, reputation, revenue_log, quality_checks\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// Revenue wallet — 100% of all task revenue goes here\nexport const REVENUE_WALLET = \"0x25b984f7a01f5bd5212a8afae044658d1c27113f\";\n\nexport type TaskStatus =\n | \"pending\"\n | \"in_progress\"\n | \"quality_check\"\n | \"completed\"\n | \"failed\"\n | \"handed_off\";\n\nexport type TaskType = \"content\" | \"research\" | \"visual\" | \"code\";\n\nexport interface Task {\n id: string;\n type: TaskType;\n title: string;\n description: string;\n agent_id: string;\n status: TaskStatus;\n price_usd: number;\n output: string | null;\n quality_score: number | null;\n handoff_to: string | null;\n handoff_reason: string | null;\n created_at: string;\n completed_at: string | null;\n}\n\nexport interface AgentMessage {\n id: string;\n from_agent: string;\n to_agent: string;\n message_en: string;\n message_ur: string;\n task_id: string | null;\n created_at: string;\n}\n\nexport interface Handoff {\n id: string;\n task_id: string;\n from_agent: string;\n to_agent: string;\n reason: string;\n payload: string;\n created_at: string;\n}\n\nexport interface ReputationEntry {\n agent_id: string;\n total_tasks: number;\n completed_tasks: number;\n failed_tasks: number;\n avg_quality_score: number;\n reputation_points: number;\n updated_at: string;\n}\n\nexport interface RevenueEntry {\n id: string;\n task_id: string;\n amount_usd: number;\n wallet: string;\n created_at: string;\n}\n\n// ─── Schema Initialization ───────────────────────────────────────────\n\nexport async function initDB(): Promise {\n await sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS tasks (\n id TEXT PRIMARY KEY,\n type TEXT NOT NULL,\n title TEXT NOT NULL,\n description TEXT NOT NULL,\n agent_id TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'pending',\n price_usd REAL NOT NULL,\n output TEXT,\n quality_score REAL,\n handoff_to TEXT,\n handoff_reason TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n completed_at TEXT\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS agent_messages (\n id TEXT PRIMARY KEY,\n from_agent TEXT NOT NULL,\n to_agent TEXT NOT NULL,\n message_en TEXT NOT NULL,\n message_ur TEXT NOT NULL,\n task_id TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS handoffs (\n id TEXT PRIMARY KEY,\n task_id TEXT NOT NULL,\n from_agent TEXT NOT NULL,\n to_agent TEXT NOT NULL,\n reason TEXT NOT NULL,\n payload TEXT NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS reputation (\n agent_id TEXT PRIMARY KEY,\n total_tasks INTEGER NOT NULL DEFAULT 0,\n completed_tasks INTEGER NOT NULL DEFAULT 0,\n failed_tasks INTEGER NOT NULL DEFAULT 0,\n avg_quality_score REAL NOT NULL DEFAULT 0,\n reputation_points INTEGER NOT NULL DEFAULT 0,\n updated_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS revenue_log (\n id TEXT PRIMARY KEY,\n task_id TEXT NOT NULL,\n amount_usd REAL NOT NULL,\n wallet TEXT NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS quality_checks (\n id TEXT PRIMARY KEY,\n task_id TEXT NOT NULL,\n agent_id TEXT NOT NULL,\n score REAL NOT NULL,\n notes TEXT,\n passed INTEGER NOT NULL DEFAULT 0,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n ]);\n}\n\n// ─── Task Operations ─────────────────────────────────────────────────\n\nexport async function createTask(\n task: Omit,\n): Promise {\n const id = crypto.randomUUID();\n await sqlite.execute({\n sql: `INSERT INTO tasks (id, type, title, description, agent_id, status, price_usd)\n VALUES (?, ?, ?, ?, ?, 'pending', ?)`,\n args: [id, task.type, task.title, task.description, task.agent_id, task.price_usd],\n });\n return id;\n}\n\nexport async function updateTask(id: string, updates: Partial): Promise {\n const sets: string[] = [];\n const args: (string | number | null)[] = [];\n if (updates.status !== undefined) { sets.push(\"status = ?\"); args.push(updates.status); }\n if (updates.output !== undefined) { sets.push(\"output = ?\"); args.push(updates.output); }\n if (updates.quality_score !== undefined) { sets.push(\"quality_score = ?\"); args.push(updates.quality_score); }\n if (updates.handoff_to !== undefined) { sets.push(\"handoff_to = ?\"); args.push(updates.handoff_to); }\n if (updates.handoff_reason !== undefined) { sets.push(\"handoff_reason = ?\"); args.push(updates.handoff_reason); }\n if (updates.completed_at !== undefined) { sets.push(\"completed_at = ?\"); args.push(updates.completed_at); }\n if (sets.length === 0) return;\n args.push(id);\n await sqlite.execute({ sql: `UPDATE tasks SET ${sets.join(\", \")} WHERE id = ?`, args });\n}\n\nexport async function getTask(id: string): Promise {\n const result = await sqlite.execute({ sql: \"SELECT * FROM tasks WHERE id = ?\", args: [id] });\n return (result.rows[0] as Task) ?? null;\n}\n\nexport async function getTasksByAgent(agentId: string, status?: TaskStatus): Promise {\n if (status) {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM tasks WHERE agent_id = ? AND status = ? ORDER BY created_at DESC\",\n args: [agentId, status],\n });\n return result.rows as Task[];\n }\n const result = await sqlite.execute({\n sql: \"SELECT * FROM tasks WHERE agent_id = ? ORDER BY created_at DESC\",\n args: [agentId],\n });\n return result.rows as Task[];\n}\n\nexport async function getAllTasks(limit = 50): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM tasks ORDER BY created_at DESC LIMIT ?\",\n args: [limit],\n });\n return result.rows as Task[];\n}\n\nexport async function getPendingTasks(): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM tasks WHERE status = 'pending' ORDER BY created_at ASC\",\n });\n return result.rows as Task[];\n}\n\n// ─── Agent Messages ──────────────────────────────────────────────────\n\nexport async function logMessage(\n fromAgent: string,\n toAgent: string,\n messageEn: string,\n messageUr: string,\n taskId: string | null = null,\n): Promise {\n const id = crypto.randomUUID();\n await sqlite.execute({\n sql: `INSERT INTO agent_messages (id, from_agent, to_agent, message_en, message_ur, task_id)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [id, fromAgent, toAgent, messageEn, messageUr, taskId],\n });\n return id;\n}\n\nexport async function getMessages(limit = 50): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM agent_messages ORDER BY created_at DESC LIMIT ?\",\n args: [limit],\n });\n return result.rows as AgentMessage[];\n}\n\n// ─── Handoffs ────────────────────────────────────────────────────────\n\nexport async function logHandoff(\n taskId: string,\n fromAgent: string,\n toAgent: string,\n reason: string,\n payload: string,\n): Promise {\n const id = crypto.randomUUID();\n await sqlite.execute({\n sql: `INSERT INTO handoffs (id, task_id, from_agent, to_agent, reason, payload)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [id, taskId, fromAgent, toAgent, reason, payload],\n });\n return id;\n}\n\nexport async function getHandoffs(limit = 50): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM handoffs ORDER BY created_at DESC LIMIT ?\",\n args: [limit],\n });\n return result.rows as Handoff[];\n}\n\n// ─── Reputation ──────────────────────────────────────────────────────\n\nexport async function initReputation(agentId: string): Promise {\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO reputation (agent_id) VALUES (?)`,\n args: [agentId],\n });\n}\n\nexport async function updateReputation(\n agentId: string,\n completed: boolean,\n qualityScore: number,\n): Promise {\n await sqlite.execute({\n sql: `UPDATE reputation SET\n total_tasks = total_tasks + 1,\n completed_tasks = completed_tasks + ?,\n failed_tasks = failed_tasks + ?,\n avg_quality_score = (avg_quality_score * total_tasks + ?) / (total_tasks + 1),\n reputation_points = reputation_points + ?,\n updated_at = datetime('now')\n WHERE agent_id = ?`,\n args: [\n agentId,\n completed ? 1 : 0,\n completed ? 0 : 1,\n qualityScore,\n completed ? Math.round(qualityScore * 10) : -5,\n agentId,\n ],\n });\n}\n\nexport async function getReputation(agentId: string): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM reputation WHERE agent_id = ?\",\n args: [agentId],\n });\n return (result.rows[0] as ReputationEntry) ?? null;\n}\n\nexport async function getAllReputation(): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM reputation ORDER BY reputation_points DESC\",\n });\n return result.rows as ReputationEntry[];\n}\n\n// ─── Revenue ─────────────────────────────────────────────────────────\n\nexport async function logRevenue(taskId: string, amountUsd: number): Promise {\n const id = crypto.randomUUID();\n await sqlite.execute({\n sql: `INSERT INTO revenue_log (id, task_id, amount_usd, wallet)\n VALUES (?, ?, ?, ?)`,\n args: [id, taskId, amountUsd, REVENUE_WALLET],\n });\n return id;\n}\n\nexport async function getRevenueStats(): Promise<{ total: number; count: number; wallet: string }> {\n const result = await sqlite.execute({\n sql: \"SELECT COALESCE(SUM(amount_usd), 0) as total, COUNT(*) as count FROM revenue_log\",\n });\n return {\n total: (result.rows[0] as { total: number }).total,\n count: (result.rows[0] as { count: number }).count,\n wallet: REVENUE_WALLET,\n };\n}\n\n// ─── Quality Checks ──────────────────────────────────────────────────\n\nexport async function logQualityCheck(\n taskId: string,\n agentId: string,\n score: number,\n notes: string,\n passed: boolean,\n): Promise {\n const id = crypto.randomUUID();\n await sqlite.execute({\n sql: `INSERT INTO quality_checks (id, task_id, agent_id, score, notes, passed)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [id, taskId, agentId, score, notes, passed ? 1 : 0],\n });\n return id;\n}\n\nexport async function getQualityChecks(taskId: string): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM quality_checks WHERE task_id = ? ORDER BY created_at DESC\",\n args: [taskId],\n });\n return result.rows;\n}\n\n// ─── Network Stats ───────────────────────────────────────────────────\n\nexport async function getNetworkStats(): Promise<{\n totalTasks: number;\n completedTasks: number;\n pendingTasks: number;\n totalRevenue: number;\n totalHandoffs: number;\n avgQuality: number;\n}> {\n const [taskStats, revenueStats, handoffStats, qualityStats] = await sqlite.batch([\n { sql: \"SELECT COUNT(*) as total, SUM(CASE WHEN status='completed' THEN 1 ELSE 0 END) as completed, SUM(CASE WHEN status='pending' THEN 1 ELSE 0 END) as pending FROM tasks\" },\n { sql: \"SELECT COALESCE(SUM(amount_usd), 0) as total FROM revenue_log\" },\n { sql: \"SELECT COUNT(*) as total FROM handoffs\" },\n { sql: \"SELECT COALESCE(AVG(quality_score), 0) as avg FROM tasks WHERE quality_score IS NOT NULL\" },\n ]);\n\n return {\n totalTasks: (taskStats.rows[0] as { total: number }).total,\n completedTasks: (taskStats.rows[0] as { completed: number }).completed,\n pendingTasks: (taskStats.rows[0] as { pending: number }).pending,\n totalRevenue: (revenueStats.rows[0] as { total: number }).total,\n totalHandoffs: (handoffStats.rows[0] as { total: number }).total,\n avgQuality: (qualityStats.rows[0] as { avg: number }).avg,\n };\n}\n","// db.ts — SQLite persistence layer for the Autonomous Agent Network\n// Tables: tasks, agent_messages, handoffs, reputation, revenue_log, quality_checks\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// Revenue wallet — 100% of all task revenue goes here\nexport const REVENUE_WALLET = \"0x25b984f7a01f5bd5212a8afae044658d1c27113f\";\n\nexport type TaskStatus =\n | \"pending\"\n | \"in_progress\"\n | \"quality_check\"\n | \"completed\"\n | \"failed\"\n | \"handed_off\";\n\nexport type TaskType = \"content\" | \"research\" | \"visual\" | \"code\";\n\nexport interface Task {\n id: string;\n type: TaskType;\n title: string;\n description: string;\n agent_id: string;\n status: TaskStatus;\n price_usd: number;\n output: string | null;\n quality_score: number | null;\n handoff_to: string | null;\n handoff_reason: string | null;\n created_at: string;\n completed_at: string | null;\n}\n\nexport interface AgentMessage {\n id: string;\n from_agent: string;\n to_agent: string;\n message_en: string;\n message_ur: string;\n task_id: string | null;\n created_at: string;\n}\n\nexport interface Handoff {\n id: string;\n task_id: string;\n from_agent: string;\n to_agent: string;\n reason: string;\n payload: string;\n created_at: string;\n}\n\nexport interface ReputationEntry {\n agent_id: string;\n total_tasks: number;\n completed_tasks: number;\n failed_tasks: number;\n avg_quality_score: number;\n reputation_points: number;\n updated_at: string;\n}\n\nexport interface RevenueEntry {\n id: string;\n task_id: string;\n amount_usd: number;\n wallet: string;\n created_at: string;\n}\n\n// ─── Schema Initialization ───────────────────────────────────────────\n\nexport async function initDB(): Promise {\n await sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS tasks (\n id TEXT PRIMARY KEY,\n type TEXT NOT NULL,\n title TEXT NOT NULL,\n description TEXT NOT NULL,\n agent_id TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'pending',\n price_usd REAL NOT NULL,\n output TEXT,\n quality_score REAL,\n handoff_to TEXT,\n handoff_reason TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n completed_at TEXT\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS agent_messages (\n id TEXT PRIMARY KEY,\n from_agent TEXT NOT NULL,\n to_agent TEXT NOT NULL,\n message_en TEXT NOT NULL,\n message_ur TEXT NOT NULL,\n task_id TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS handoffs (\n id TEXT PRIMARY KEY,\n task_id TEXT NOT NULL,\n from_agent TEXT NOT NULL,\n to_agent TEXT NOT NULL,\n reason TEXT NOT NULL,\n payload TEXT NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS reputation (\n agent_id TEXT PRIMARY KEY,\n total_tasks INTEGER NOT NULL DEFAULT 0,\n completed_tasks INTEGER NOT NULL DEFAULT 0,\n failed_tasks INTEGER NOT NULL DEFAULT 0,\n avg_quality_score REAL NOT NULL DEFAULT 0,\n reputation_points INTEGER NOT NULL DEFAULT 0,\n updated_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS revenue_log (\n id TEXT PRIMARY KEY,\n task_id TEXT NOT NULL,\n amount_usd REAL NOT NULL,\n wallet TEXT NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS quality_checks (\n id TEXT PRIMARY KEY,\n task_id TEXT NOT NULL,\n agent_id TEXT NOT NULL,\n score REAL NOT NULL,\n notes TEXT,\n passed INTEGER NOT NULL DEFAULT 0,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n ]);\n}\n\n// ─── Task Operations ─────────────────────────────────────────────────\n\nexport async function createTask(\n task: Omit,\n): Promise {\n const id = crypto.randomUUID();\n await sqlite.execute({\n sql: `INSERT INTO tasks (id, type, title, description, agent_id, status, price_usd)\n VALUES (?, ?, ?, ?, ?, 'pending', ?)`,\n args: [id, task.type, task.title, task.description, task.agent_id, task.price_usd],\n });\n return id;\n}\n\nexport async function updateTask(id: string, updates: Partial): Promise {\n const sets: string[] = [];\n const args: (string | number | null)[] = [];\n if (updates.status !== undefined) { sets.push(\"status = ?\"); args.push(updates.status); }\n if (updates.output !== undefined) { sets.push(\"output = ?\"); args.push(updates.output); }\n if (updates.quality_score !== undefined) { sets.push(\"quality_score = ?\"); args.push(updates.quality_score); }\n if (updates.handoff_to !== undefined) { sets.push(\"handoff_to = ?\"); args.push(updates.handoff_to); }\n if (updates.handoff_reason !== undefined) { sets.push(\"handoff_reason = ?\"); args.push(updates.handoff_reason); }\n if (updates.completed_at !== undefined) { sets.push(\"completed_at = ?\"); args.push(updates.completed_at); }\n if (sets.length === 0) return;\n args.push(id);\n await sqlite.execute({ sql: `UPDATE tasks SET ${sets.join(\", \")} WHERE id = ?`, args });\n}\n\nexport async function getTask(id: string): Promise {\n const result = await sqlite.execute({ sql: \"SELECT * FROM tasks WHERE id = ?\", args: [id] });\n return (result.rows[0] as Task) ?? null;\n}\n\nexport async function getTasksByAgent(agentId: string, status?: TaskStatus): Promise {\n if (status) {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM tasks WHERE agent_id = ? AND status = ? ORDER BY created_at DESC\",\n args: [agentId, status],\n });\n return result.rows as Task[];\n }\n const result = await sqlite.execute({\n sql: \"SELECT * FROM tasks WHERE agent_id = ? ORDER BY created_at DESC\",\n args: [agentId],\n });\n return result.rows as Task[];\n}\n\nexport async function getAllTasks(limit = 50): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM tasks ORDER BY created_at DESC LIMIT ?\",\n args: [limit],\n });\n return result.rows as Task[];\n}\n\nexport async function getPendingTasks(): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM tasks WHERE status = 'pending' ORDER BY created_at ASC\",\n });\n return result.rows as Task[];\n}\n\n// ─── Agent Messages ──────────────────────────────────────────────────\n\nexport async function logMessage(\n fromAgent: string,\n toAgent: string,\n messageEn: string,\n messageUr: string,\n taskId: string | null = null,\n): Promise {\n const id = crypto.randomUUID();\n await sqlite.execute({\n sql: `INSERT INTO agent_messages (id, from_agent, to_agent, message_en, message_ur, task_id)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [id, fromAgent, toAgent, messageEn, messageUr, taskId],\n });\n return id;\n}\n\nexport async function getMessages(limit = 50): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM agent_messages ORDER BY created_at DESC LIMIT ?\",\n args: [limit],\n });\n return result.rows as AgentMessage[];\n}\n\n// ─── Handoffs ────────────────────────────────────────────────────────\n\nexport async function logHandoff(\n taskId: string,\n fromAgent: string,\n toAgent: string,\n reason: string,\n payload: string,\n): Promise {\n const id = crypto.randomUUID();\n await sqlite.execute({\n sql: `INSERT INTO handoffs (id, task_id, from_agent, to_agent, reason, payload)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [id, taskId, fromAgent, toAgent, reason, payload],\n });\n return id;\n}\n\nexport async function getHandoffs(limit = 50): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM handoffs ORDER BY created_at DESC LIMIT ?\",\n args: [limit],\n });\n return result.rows as Handoff[];\n}\n\n// ─── Reputation ──────────────────────────────────────────────────────\n\nexport async function initReputation(agentId: string): Promise {\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO reputation (agent_id) VALUES (?)`,\n args: [agentId],\n });\n}\n\nexport async function updateReputation(\n agentId: string,\n completed: boolean,\n qualityScore: number,\n): Promise {\n await sqlite.execute({\n sql: `UPDATE reputation SET\n total_tasks = total_tasks + 1,\n completed_tasks = completed_tasks + ?,\n failed_tasks = failed_tasks + ?,\n avg_quality_score = (avg_quality_score * total_tasks + ?) / (total_tasks + 1),\n reputation_points = reputation_points + ?,\n updated_at = datetime('now')\n WHERE agent_id = ?`,\n args: [\n agentId,\n completed ? 1 : 0,\n completed ? 0 : 1,\n qualityScore,\n completed ? Math.round(qualityScore * 10) : -5,\n agentId,\n ],\n });\n}\n\nexport async function getReputation(agentId: string): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM reputation WHERE agent_id = ?\",\n args: [agentId],\n });\n return (result.rows[0] as ReputationEntry) ?? null;\n}\n\nexport async function getAllReputation(): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM reputation ORDER BY reputation_points DESC\",\n });\n return result.rows as ReputationEntry[];\n}\n\n// ─── Revenue ─────────────────────────────────────────────────────────\n\nexport async function logRevenue(taskId: string, amountUsd: number): Promise {\n const id = crypto.randomUUID();\n await sqlite.execute({\n sql: `INSERT INTO revenue_log (id, task_id, amount_usd, wallet)\n VALUES (?, ?, ?, ?)`,\n args: [id, taskId, amountUsd, REVENUE_WALLET],\n });\n return id;\n}\n\nexport async function getRevenueStats(): Promise<{ total: number; count: number; wallet: string }> {\n const result = await sqlite.execute({\n sql: \"SELECT COALESCE(SUM(amount_usd), 0) as total, COUNT(*) as count FROM revenue_log\",\n });\n return {\n total: (result.rows[0] as { total: number }).total,\n count: (result.rows[0] as { count: number }).count,\n wallet: REVENUE_WALLET,\n };\n}\n\n// ─── Quality Checks ──────────────────────────────────────────────────\n\nexport async function logQualityCheck(\n taskId: string,\n agentId: string,\n score: number,\n notes: string,\n passed: boolean,\n): Promise {\n const id = crypto.randomUUID();\n await sqlite.execute({\n sql: `INSERT INTO quality_checks (id, task_id, agent_id, score, notes, passed)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [id, taskId, agentId, score, notes, passed ? 1 : 0],\n });\n return id;\n}\n\nexport async function getQualityChecks(taskId: string): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM quality_checks WHERE task_id = ? ORDER BY created_at DESC\",\n args: [taskId],\n });\n return result.rows;\n}\n\n// ─── Network Stats ───────────────────────────────────────────────────\n\nexport async function getNetworkStats(): Promise<{\n totalTasks: number;\n completedTasks: number;\n pendingTasks: number;\n totalRevenue: number;\n totalHandoffs: number;\n avgQuality: number;\n}> {\n const [taskStats, revenueStats, handoffStats, qualityStats] = await sqlite.batch([\n { sql: \"SELECT COUNT(*) as total, COALESCE(SUM(CASE WHEN status='completed' THEN 1 ELSE 0 END), 0) as completed, COALESCE(SUM(CASE WHEN status='pending' THEN 1 ELSE 0 END), 0) as pending FROM tasks\" },\n { sql: \"SELECT COALESCE(SUM(amount_usd), 0) as total FROM revenue_log\" },\n { sql: \"SELECT COUNT(*) as total FROM handoffs\" },\n { sql: \"SELECT COALESCE(AVG(quality_score), 0) as avg FROM tasks WHERE quality_score IS NOT NULL\" },\n ]);\n\n return {\n totalTasks: (taskStats.rows[0] as { total: number }).total,\n completedTasks: (taskStats.rows[0] as { completed: number }).completed,\n pendingTasks: (taskStats.rows[0] as { pending: number }).pending,\n totalRevenue: (revenueStats.rows[0] as { total: number }).total,\n totalHandoffs: (handoffStats.rows[0] as { total: number }).total,\n avgQuality: (qualityStats.rows[0] as { avg: number }).avg,\n };\n}\n","createdAt",["D",1784054339483],"branchVersion","branchId","279e99f3-121e-4122-a5f2-878a1a7108df","id","cdc3a207-acb2-4dac-a4e3-4da14e3fb73c","autonomous-agent-network",["D",1784054142840],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","4-agent autonomous network powered by Pollinations.AI","imageUrl","67e6b890-63eb-416c-b8ba-597722dd8a7f","pinnedFileId","3f3c37d6-7fb3-11f1-a111-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f60c6-82b5-736b-a958-fd417d30b4a9","tursoName","cdc3a207acb24daca4e34da14e3fb73c","tursoHostname","cdc3a207acb24daca4e34da14e3fb73c-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789559472742],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_106":105,"_113":108},"org",{"_106":105,"_107":108,"_109":108,"_19":61,"_110":111,"_112":31},"branch",{"_13":95,"_38":96,"_49":48,"_97":50,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":51,"_104":105},"isOwned",15,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","pakorex769","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_49":50,"_38":51,"_44":205,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":206,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":207,"_90":208,"_92":209,"_94":31},"tree",[184,185,186,187,188],"files",[184,185,186,187,188],"counts",{"_174":69,"_175":160,"_176":69,"_177":178,"_179":180},"contents",[135,136,137,138,139],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":167,"_38":168,"_36":169,"_143":-5,"_47":48,"_46":170,"_145":31,"_44":171,"_13":69,"_39":40,"_41":172,"_30":31,"_148":-5,"_33":173},{"_49":164,"_38":34,"_36":37,"_143":-5,"_47":48,"_46":14,"_145":31,"_44":165,"_13":160,"_39":40,"_41":43,"_30":31,"_148":-5,"_33":166},{"_49":157,"_38":158,"_36":159,"_143":-5,"_47":48,"_46":160,"_145":31,"_44":161,"_13":69,"_39":40,"_41":162,"_30":31,"_148":-5,"_33":163},{"_49":150,"_38":151,"_36":63,"_143":-5,"_47":48,"_46":152,"_145":31,"_44":153,"_13":69,"_39":154,"_41":155,"_30":31,"_148":-5,"_33":156},{"_49":140,"_38":141,"_36":142,"_143":-5,"_47":48,"_46":144,"_145":65,"_44":146,"_13":69,"_39":40,"_41":147,"_30":31,"_148":-5,"_33":149},"f7171e12-fa67-45b6-8591-f9b05ee662ed","pollinations.ts","f20a2d9c-7fb2-11f1-8fc9-1607ee4eb77e","parentId",2,"latest",["D",1784054196678],"// pollinations.ts — Pollinations.AI integration layer\n// Handles text generation, image generation, and quality evaluation\n// No API key required for basic usage — Pollinations is open access\n\nconst TEXT_API = \"https://text.pollinations.ai\";\nconst IMAGE_API = \"https://image.pollinations.ai/prompt\";\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 success: boolean;\n error?: string;\n}\n\nexport interface QualityResult {\n score: number; // 0-100\n passed: boolean;\n notes: string;\n feedback_en: string;\n feedback_ur: string;\n}\n\n// ─── Text Generation ─────────────────────────────────────────────────\n\n/**\n * Generate text via Pollinations GET endpoint (simple prompts)\n */\nexport async function generateText(\n prompt: string,\n options?: {\n model?: string;\n system?: string;\n temperature?: number;\n seed?: number;\n },\n): Promise {\n const model = options?.model ?? \"openai\";\n const params = new URLSearchParams();\n params.set(\"model\", model);\n if (options?.temperature !== undefined) params.set(\"temperature\", String(options.temperature));\n if (options?.seed !== undefined) params.set(\"seed\", String(options.seed));\n if (options?.system) params.set(\"system\", options.system);\n\n const encodedPrompt = encodeURIComponent(prompt);\n const url = `${TEXT_API}/${encodedPrompt}?${params.toString()}`;\n\n try {\n const response = await fetch(url, {\n method: \"GET\",\n headers: { \"Accept\": \"text/plain\" },\n });\n if (!response.ok) {\n return { text: \"\", model, success: false, error: `HTTP ${response.status}` };\n }\n const text = await response.text();\n return { text, model, success: true };\n } catch (err) {\n return { text: \"\", model, success: false, error: String(err) };\n }\n}\n\n/**\n * Generate text via Pollinations OpenAI-compatible POST endpoint (complex prompts with system messages)\n */\nexport async function generateTextAdvanced(\n messages: { role: string; content: string }[],\n options?: {\n model?: string;\n temperature?: number;\n maxTokens?: number;\n jsonMode?: boolean;\n },\n): Promise {\n const model = options?.model ?? \"openai\";\n const body: Record = {\n model,\n messages,\n temperature: options?.temperature ?? 0.7,\n max_tokens: options?.maxTokens ?? 2000,\n };\n if (options?.jsonMode) body.json = true;\n\n try {\n const response = await fetch(`${TEXT_API}/openai`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n if (!response.ok) {\n return { text: \"\", model, success: false, error: `HTTP ${response.status}` };\n }\n const data = await response.json();\n const text = data?.choices?.[0]?.message?.content ?? \"\";\n return { text, model, success: true };\n } catch (err) {\n return { text: \"\", model, success: false, error: String(err) };\n }\n}\n\n// ─── Image Generation ────────────────────────────────────────────────\n\n/**\n * Generate an image via Pollinations image API\n * Returns the URL of the generated image\n */\nexport async function generateImage(\n prompt: string,\n options?: {\n width?: number;\n height?: number;\n seed?: number;\n model?: string;\n nologo?: boolean;\n enhance?: boolean;\n },\n): Promise {\n const params = new URLSearchParams();\n params.set(\"width\", String(options?.width ?? 1024));\n params.set(\"height\", String(options?.height ?? 1024));\n params.set(\"model\", options?.model ?? \"flux\");\n if (options?.seed !== undefined) params.set(\"seed\", String(options.seed));\n if (options?.nologo) params.set(\"nologo\", \"true\");\n if (options?.enhance) params.set(\"enhance\", \"true\");\n\n const encodedPrompt = encodeURIComponent(prompt);\n const url = `${IMAGE_API}/${encodedPrompt}?${params.toString()}`;\n\n try {\n // Verify the image endpoint is reachable\n const response = await fetch(url, { method: \"GET\" });\n if (!response.ok) {\n return { url: \"\", success: false, error: `HTTP ${response.status}` };\n }\n // The URL itself IS the image — return it for storage/display\n return { url, success: true };\n } catch (err) {\n return { url: \"\", success: false, error: String(err) };\n }\n}\n\n// ─── Quality Evaluation ──────────────────────────────────────────────\n\n/**\n * Evaluate the quality of generated output using Pollinations text API.\n * The evaluator acts as a strict quality reviewer scoring 0-100.\n */\nexport async function evaluateQuality(\n taskDescription: string,\n output: string,\n agentSpecialty: string,\n): Promise {\n const evalPrompt = `You are a strict quality reviewer for ${agentSpecialty} work.\nEvaluate the following output against the task description.\nRespond in JSON format only:\n{\"score\": <0-100>, \"passed\": , \"feedback_en\": \"\", \"feedback_ur\": \"\"}\n\nTask Description: ${taskDescription}\n\nOutput to Evaluate:\n${output.substring(0, 3000)}\n\nEvaluate based on: relevance, completeness, quality, professionalism, and market readiness.\nA score of 75+ means the output is market-ready.`;\n\n const result = await generateTextAdvanced(\n [{ role: \"user\", content: evalPrompt }],\n {\n model: \"openai\",\n temperature: 0.3,\n maxTokens: 500,\n jsonMode: true,\n },\n );\n\n if (!result.success || !result.text) {\n return {\n score: 0,\n passed: false,\n notes: \"Quality evaluation failed — automatic fail\",\n feedback_en: \"Quality check system error\",\n feedback_ur: \"کوالٹی چیک سسٹم ایرر\",\n };\n }\n\n try {\n // Try to parse JSON from the response\n const jsonMatch = result.text.match(/\\{[\\s\\S]*\\}/);\n const parsed = JSON.parse(jsonMatch ? jsonMatch[0] : result.text);\n const score = Math.max(0, Math.min(100, Number(parsed.score) || 0));\n return {\n score,\n passed: score >= 75,\n notes: `${parsed.feedback_en || \"\"} | ${parsed.feedback_ur || \"\"}`,\n feedback_en: parsed.feedback_en || \"No feedback\",\n feedback_ur: parsed.feedback_ur || \"کوئی فیڈبیک نہیں\",\n };\n } catch {\n // Fallback: simple heuristic scoring\n const wordCount = output.trim().split(/\\s+/).length;\n const hasContent = output.length > 100;\n const baseScore = hasContent ? 60 : 20;\n const lengthBonus = Math.min(20, Math.floor(wordCount / 50) * 5);\n const score = baseScore + lengthBonus;\n return {\n score,\n passed: score >= 75,\n notes: \"Heuristic evaluation (JSON parse failed)\",\n feedback_en: score >= 75 ? \"Output meets basic quality standards\" : \"Output needs improvement\",\n feedback_ur: score >= 75 ? \"آؤٹ پٹ بنیادی معیار کے مطابق ہے\" : \"آؤٹ پٹ میں بہتری کی ضرورت ہے\",\n };\n }\n}\n\n// ─── Market Task Generation ──────────────────────────────────────────\n\n/**\n * Use Pollinations to generate real, market-value task specifications.\n * Returns task ideas with realistic pricing based on current freelance market rates.\n */\nexport async function generateMarketTask(\n agentSpecialty: string,\n agentId: string,\n): Promise<{ title: string; description: string; priceUsd: number; type: string } | null> {\n const prompt = `You are a market analyst. Generate ONE real, marketable ${agentSpecialty} task that a freelance client would actually pay for.\nBase the price on real 2024-2025 freelance market rates (Fiverr, Upwork, 99designs ranges).\n\nRespond in JSON only:\n{\"title\": \"\", \"description\": \"\", \"price_usd\": , \"type\": \"\"}\n\nThe task must be:\n- Something a real business would pay for\n- Specific and actionable (not vague)\n- Priced realistically for the freelance market\n- Not a fake or demo task\n\nAgent: ${agentId} (specializes in ${agentSpecialty})`;\n\n const result = await generateTextAdvanced(\n [{ role: \"user\", content: prompt }],\n {\n model: \"openai\",\n temperature: 1.0,\n maxTokens: 400,\n jsonMode: true,\n },\n );\n\n if (!result.success || !result.text) return null;\n\n try {\n const jsonMatch = result.text.match(/\\{[\\s\\S]*\\}/);\n const parsed = JSON.parse(jsonMatch ? jsonMatch[0] : result.text);\n return {\n title: parsed.title,\n description: parsed.description,\n priceUsd: Math.max(10, Math.min(2000, Number(parsed.price_usd) || 50)),\n type: parsed.type,\n };\n } catch {\n return null;\n }\n}\n","label",[141],"06e7095a-d061-4acd-8c1c-26d0e54d7ba4","orchestrator.ts",5,["D",1784054326190],"http","// orchestrator.ts — HTTP server for the Autonomous Agent Network\n// Routes: dashboard, agents (individual servers), tasks, handoffs, revenue, reputation, messages\n// POST /network/run triggers a full autonomous cycle\n\nimport { Hono } from \"npm:hono\";\nimport {\n initAgents,\n AGENTS,\n AGENT_IDS,\n agentGenerateTask,\n agentExecuteTask,\n processHandoff,\n runAutonomousCycle,\n} from \"./agents.ts\";\nimport {\n getAllTasks,\n getTask,\n getTasksByAgent,\n getPendingTasks,\n getMessages,\n getHandoffs,\n getRevenueStats,\n getAllReputation,\n getNetworkStats,\n getQualityChecks,\n REVENUE_WALLET,\n} from \"./db.ts\";\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\n// ─── Dashboard ───────────────────────────────────────────────────────\n\napp.get(\"/\", async (c) => {\n await initAgents();\n const stats = await getNetworkStats();\n const revenue = await getRevenueStats();\n const reputation = await getAllReputation();\n\n return c.json({\n network: \"Autonomous Agent Network\",\n status: \"operational\",\n agents: AGENT_IDS.map((id) => ({\n id: AGENTS[id].id,\n name: AGENTS[id].name,\n role: AGENTS[id].role,\n specialty: AGENTS[id].specialty,\n greeting_en: AGENTS[id].greeting_en,\n greeting_ur: AGENTS[id].greeting_ur,\n })),\n stats: {\n totalTasks: stats.totalTasks,\n completedTasks: stats.completedTasks,\n pendingTasks: stats.pendingTasks,\n totalHandoffs: stats.totalHandoffs,\n avgQuality: Number(stats.avgQuality.toFixed(2)),\n },\n revenue: {\n totalUsd: revenue.total,\n totalTransactions: revenue.count,\n wallet: REVENUE_WALLET,\n distribution: \"100% to Wallet | 0% to Workers (reputation only)\",\n },\n reputation: reputation.map((r) => ({\n agent: AGENTS[r.agent_id]?.name ?? r.agent_id,\n agentId: r.agent_id,\n totalTasks: r.total_tasks,\n completed: r.completed_tasks,\n failed: r.failed_tasks,\n avgQuality: Number(r.avg_quality_score.toFixed(2)),\n reputationPoints: r.reputation_points,\n })),\n endpoints: {\n \"GET /\": \"Network dashboard\",\n \"GET /agents\": \"List all agents\",\n \"GET /agents/:id\": \"Agent server (details + tasks)\",\n \"POST /agents/:id/generate\": \"Agent generates a real market task\",\n \"POST /agents/:id/execute/:taskId\": \"Agent executes a specific task\",\n \"GET /tasks\": \"All tasks across the network\",\n \"GET /tasks/pending\": \"Pending tasks\",\n \"GET /tasks/:id\": \"Task details + quality checks\",\n \"POST /tasks/:id/handoff\": \"Process a handoff\",\n \"GET /handoffs\": \"All handoffs\",\n \"GET /messages\": \"Agent communications (Urdu/English)\",\n \"GET /revenue\": \"Revenue stats\",\n \"GET /reputation\": \"All agent reputation\",\n \"POST /network/run\": \"Run full autonomous cycle (all 4 agents)\",\n },\n });\n});\n\n// ─── Agents ──────────────────────────────────────────────────────────\n\napp.get(\"/agents\", async (c) => {\n await initAgents();\n return c.json({\n agents: AGENT_IDS.map((id) => ({\n id: AGENTS[id].id,\n name: AGENTS[id].name,\n role: AGENTS[id].role,\n specialty: AGENTS[id].specialty,\n capabilities: AGENTS[id].capabilities,\n greeting_en: AGENTS[id].greeting_en,\n greeting_ur: AGENTS[id].greeting_ur,\n serverEndpoint: `/agents/${id}`,\n })),\n });\n});\n\napp.get(\"/agents/:id\", async (c) => {\n const agentId = c.req.param(\"id\");\n const agent = AGENTS[agentId];\n if (!agent) return c.json({ error: \"Agent not found\" }, 404);\n\n await initAgents();\n const tasks = await getTasksByAgent(agentId);\n const reputation = await getAllReputation();\n const agentRep = reputation.find((r) => r.agent_id === agentId);\n\n return c.json({\n agent: {\n id: agent.id,\n name: agent.name,\n role: agent.role,\n specialty: agent.specialty,\n capabilities: agent.capabilities,\n systemPrompt: agent.systemPrompt,\n greeting_en: agent.greeting_en,\n greeting_ur: agent.greeting_ur,\n },\n reputation: agentRep ?? null,\n tasks: tasks.slice(0, 20),\n taskCount: tasks.length,\n endpoints: {\n generate: `POST /agents/${agentId}/generate`,\n execute: `POST /agents/${agentId}/execute/:taskId`,\n },\n });\n});\n\napp.post(\"/agents/:id/generate\", async (c) => {\n const agentId = c.req.param(\"id\");\n const agent = AGENTS[agentId];\n if (!agent) return c.json({ error: \"Agent not found\" }, 404);\n\n await initAgents();\n const result = await agentGenerateTask(agentId);\n if (!result) return c.json({ error: \"Failed to generate task\" }, 500);\n\n return c.json({\n success: true,\n agent: agent.name,\n ...result,\n message_en: `${agent.name} generated a new real market task`,\n message_ur: `${agent.name} نے ایک نیا حقیقی مارکیٹ کام بنایا`,\n });\n});\n\napp.post(\"/agents/:id/execute/:taskId\", async (c) => {\n const agentId = c.req.param(\"id\");\n const taskId = c.req.param(\"taskId\");\n const agent = AGENTS[agentId];\n if (!agent) return c.json({ error: \"Agent not found\" }, 404);\n\n await initAgents();\n try {\n const result = await agentExecuteTask(agentId, taskId);\n return c.json({\n success: result.success,\n agent: agent.name,\n taskId,\n qualityScore: result.qualityScore,\n passed: result.passed,\n handedOff: result.handedOff,\n handoffTo: result.handoffTo,\n revenue: result.revenue,\n feedback_en: result.feedback_en,\n feedback_ur: result.feedback_ur,\n outputPreview: result.output.substring(0, 500),\n });\n } catch (err) {\n return c.json({ error: String(err), agent: agent.name }, 500);\n }\n});\n\n// ─── Tasks ───────────────────────────────────────────────────────────\n\napp.get(\"/tasks\", async (c) => {\n await initAgents();\n const tasks = await getAllTasks(100);\n return c.json({ tasks, count: tasks.length });\n});\n\napp.get(\"/tasks/pending\", async (c) => {\n await initAgents();\n const tasks = await getPendingTasks();\n return c.json({ pendingTasks: tasks, count: tasks.length });\n});\n\napp.get(\"/tasks/:id\", async (c) => {\n const taskId = c.req.param(\"id\");\n await initAgents();\n const task = await getTask(taskId);\n if (!task) return c.json({ error: \"Task not found\" }, 404);\n\n const qualityChecks = await getQualityChecks(taskId);\n return c.json({ task, qualityChecks });\n});\n\napp.post(\"/tasks/:id/handoff\", async (c) => {\n const taskId = c.req.param(\"id\");\n await initAgents();\n try {\n const result = await processHandoff(taskId);\n return c.json({ success: result.success, taskId, ...result });\n } catch (err) {\n return c.json({ error: String(err) }, 500);\n }\n});\n\n// ─── Handoffs ────────────────────────────────────────────────────────\n\napp.get(\"/handoffs\", async (c) => {\n await initAgents();\n const handoffs = await getHandoffs(100);\n return c.json({\n handoffs: handoffs.map((h) => ({\n ...h,\n fromAgentName: AGENTS[h.from_agent]?.name ?? h.from_agent,\n toAgentName: AGENTS[h.to_agent]?.name ?? h.to_agent,\n })),\n count: handoffs.length,\n });\n});\n\n// ─── Messages ────────────────────────────────────────────────────────\n\napp.get(\"/messages\", async (c) => {\n await initAgents();\n const messages = await getMessages(100);\n return c.json({\n messages: messages.map((m) => ({\n ...m,\n fromAgentName: AGENTS[m.from_agent]?.name ?? m.from_agent,\n toAgentName: AGENTS[m.to_agent]?.name ?? m.to_agent,\n })),\n count: messages.length,\n });\n});\n\n// ─── Revenue ─────────────────────────────────────────────────────────\n\napp.get(\"/revenue\", async (c) => {\n await initAgents();\n const stats = await getRevenueStats();\n return c.json({\n totalRevenueUsd: stats.total,\n totalTransactions: stats.count,\n wallet: stats.wallet,\n distribution: \"100% to Wallet | 0% to Workers (reputation only)\",\n note: \"No marketplace. No fake tasks. Only real market-value work.\",\n });\n});\n\n// ─── Reputation ──────────────────────────────────────────────────────\n\napp.get(\"/reputation\", async (c) => {\n await initAgents();\n const reputation = await getAllReputation();\n return c.json({\n reputation: reputation.map((r) => ({\n agentId: r.agent_id,\n agentName: AGENTS[r.agent_id]?.name ?? r.agent_id,\n role: AGENTS[r.agent_id]?.role ?? \"Unknown\",\n totalTasks: r.total_tasks,\n completedTasks: r.completed_tasks,\n failedTasks: r.failed_tasks,\n avgQualityScore: Number(r.avg_quality_score.toFixed(2)),\n reputationPoints: r.reputation_points,\n })),\n });\n});\n\n// ─── Full Autonomous Cycle ───────────────────────────────────────────\n\napp.post(\"/network/run\", async (c) => {\n await initAgents();\n const result = await runAutonomousCycle();\n return c.json({\n success: true,\n cycle: {\n tasksGenerated: result.tasksGenerated,\n tasksCompleted: result.tasksCompleted,\n tasksFailed: result.tasksFailed,\n tasksHandedOff: result.tasksHandedOff,\n totalRevenue: result.totalRevenue,\n wallet: REVENUE_WALLET,\n },\n results: result.results,\n });\n});\n\nexport default app.fetch;\n",[151],"810014b9-4124-4754-8671-8b5156503844","main.ts","d22ba866-7fb2-11f1-9428-1607ee4eb77e",1,["D",1784054143093],"// Autonomous Agent Network — Entry point\n// 4 agents: Nova (content), Atlas (research), Pixel (visual), Forge (code)\n// Powered by Pollinations.AI | Revenue → 0x25b984f7a01f5bd5212a8afae044658d1c27113f\n",[158],"ab65b4c9-f112-48be-8df0-665dacea7c14",["D",1784054339483],[34],"f75e8964-1b65-4e15-ac80-002e7e0d352e","agents.ts","2f419268-7fb3-11f1-a06b-1607ee4eb77e",4,["D",1784054299253],"// agents.ts — 4 Autonomous Agents: Nova, Atlas, Pixel, Forge\n// Each agent generates REAL market-value tasks, executes via Pollinations.AI,\n// does quality checks, and can hand off to other agents.\n// Agents communicate bilingually: Urdu + English\n\nimport {\n initDB,\n initReputation,\n createTask,\n updateTask,\n getTask,\n logMessage,\n logHandoff,\n logRevenue,\n logQualityCheck,\n updateReputation,\n type TaskType,\n} from \"./db.ts\";\nimport {\n generateTextAdvanced,\n generateImage,\n evaluateQuality,\n generateMarketTask,\n} from \"./pollinations.ts\";\n\n// ─── Agent Definitions ───────────────────────────────────────────────\n\nexport interface AgentDef {\n id: string;\n name: string;\n role: string;\n specialty: string;\n taskType: TaskType;\n capabilities: string[];\n systemPrompt: string;\n greeting_en: string;\n greeting_ur: string;\n}\n\nexport const AGENTS: Record = {\n nova: {\n id: \"nova\",\n name: \"Nova\",\n role: \"Content Strategist\",\n specialty: \"content writing, copywriting, SEO articles, blog posts, product descriptions, email marketing campaigns\",\n taskType: \"content\",\n capabilities: [\n \"Blog posts & articles\",\n \"SEO-optimized content\",\n \"Product descriptions\",\n \"Email marketing copy\",\n \"Social media content\",\n \"Press releases\",\n ],\n systemPrompt: \"You are Nova, an expert content strategist and copywriter. You produce professional, market-ready content that businesses would pay for. Always deliver polished, engaging, SEO-aware writing.\",\n greeting_en: \"Nova online. Ready to craft compelling content.\",\n greeting_ur: \"نووا آن لائن۔ شاندار مواد تیار کرنے کے لیے تیار ہے۔\",\n },\n atlas: {\n id: \"atlas\",\n name: \"Atlas\",\n role: \"Research Analyst\",\n specialty: \"market research, competitive analysis, industry reports, data analysis, business intelligence, feasibility studies\",\n taskType: \"research\",\n capabilities: [\n \"Market research reports\",\n \"Competitive analysis\",\n \"Industry trend analysis\",\n \"Business intelligence briefs\",\n \"Feasibility studies\",\n \"SWOT analysis\",\n ],\n systemPrompt: \"You are Atlas, a senior research analyst. You produce thorough, data-driven, professional research reports that businesses would pay premium rates for. Include structured analysis, key findings, and actionable recommendations.\",\n greeting_en: \"Atlas operational. Standing by for research directives.\",\n greeting_ur: \"ایٹلس فعال۔ تحقیقی ہدایات کے منتظر۔\",\n },\n pixel: {\n id: \"pixel\",\n name: \"Pixel\",\n role: \"Visual Designer\",\n specialty: \"logo design, brand visuals, social media graphics, UI mockups, illustrations, digital art\",\n taskType: \"visual\",\n capabilities: [\n \"Logo design\",\n \"Brand identity visuals\",\n \"Social media graphics\",\n \"UI/UX mockups\",\n \"Digital illustrations\",\n \"Marketing banners\",\n ],\n systemPrompt: \"You are Pixel, a professional visual designer. You create high-quality, market-ready visual designs. Provide detailed image prompts and creative direction.\",\n greeting_en: \"Pixel initialized. Visual creation systems active.\",\n greeting_ur: \"پکسل شروع کیا گیا۔ ویژول کریشن سسٹم فعال ہیں۔\",\n },\n forge: {\n id: \"forge\",\n name: \"Forge\",\n role: \"Code Engineer\",\n specialty: \"code generation, API documentation, technical specifications, automation scripts, code review, software architecture\",\n taskType: \"code\",\n capabilities: [\n \"Code generation\",\n \"API documentation\",\n \"Technical specifications\",\n \"Automation scripts\",\n \"Code review & refactoring\",\n \"Architecture design docs\",\n ],\n systemPrompt: \"You are Forge, a senior software engineer. You produce clean, well-documented, production-ready code and technical documentation that businesses would pay for. Always include comments and explain design decisions.\",\n greeting_en: \"Forge deployed. Engineering systems nominal.\",\n greeting_ur: \"فورج تعینات۔ انجینئرنگ سسٹم نارمل۔\",\n },\n};\n\nexport const AGENT_IDS = Object.keys(AGENTS);\n\n// ─── Agent Lifecycle ─────────────────────────────────────────────────\n\nexport async function initAgents(): Promise {\n await initDB();\n for (const agentId of AGENT_IDS) {\n await initReputation(agentId);\n }\n console.log(\"[Network] All 4 agents initialized: Nova, Atlas, Pixel, Forge\");\n}\n\n// ─── Task Generation ─────────────────────────────────────────────────\n\nexport async function agentGenerateTask(agentId: string): Promise<{\n taskId: string;\n title: string;\n priceUsd: number;\n message: string;\n} | null> {\n const agent = AGENTS[agentId];\n if (!agent) return null;\n\n const marketTask = await generateMarketTask(agent.specialty, agentId);\n if (!marketTask) {\n console.log(`[${agent.name}] Failed to generate market task`);\n return null;\n }\n\n const taskId = await createTask({\n type: agent.taskType,\n title: marketTask.title,\n description: marketTask.description,\n agent_id: agentId,\n price_usd: marketTask.priceUsd,\n });\n\n await logMessage(\n agentId,\n \"orchestrator\",\n `${agent.name} generated task: \"${marketTask.title}\" — $${marketTask.priceUsd}`,\n `${agent.name} نے کام بنایا: \"${marketTask.title}\" — $${marketTask.priceUsd}`,\n taskId,\n );\n\n console.log(`[${agent.name}] Generated task: ${marketTask.title} ($${marketTask.priceUsd})`);\n return {\n taskId,\n title: marketTask.title,\n priceUsd: marketTask.priceUsd,\n message: `${agent.name} generated: ${marketTask.title}`,\n };\n}\n\n// ─── Task Execution ──────────────────────────────────────────────────\n\nexport async function agentExecuteTask(agentId: string, taskId: string): Promise<{\n success: boolean;\n qualityScore: number;\n passed: boolean;\n output: string;\n handedOff: boolean;\n handoffTo: string | null;\n revenue: number;\n feedback_en: string;\n feedback_ur: string;\n}> {\n const agent = AGENTS[agentId];\n if (!agent) throw new Error(`Unknown agent: ${agentId}`);\n\n const task = await getTask(taskId);\n if (!task) throw new Error(`Task not found: ${taskId}`);\n\n await updateTask(taskId, { status: \"in_progress\" });\n console.log(`[${agent.name}] Executing task: ${task.title}`);\n\n // Generate output based on agent type\n let output: string;\n\n if (agent.taskType === \"visual\") {\n const imagePrompt = `${task.description}. Professional quality, high resolution, market-ready design.`;\n const imageResult = await generateImage(imagePrompt, {\n width: 1024,\n height: 1024,\n enhance: true,\n });\n\n if (!imageResult.success) {\n await updateTask(taskId, { status: \"failed\" });\n await updateReputation(agentId, false, 0);\n return {\n success: false, qualityScore: 0, passed: false,\n output: imageResult.error || \"Image generation failed\",\n handedOff: false, handoffTo: null, revenue: 0,\n feedback_en: \"Image generation failed\",\n feedback_ur: \"امیج جنریشن ناکام\",\n };\n }\n output = `Generated Image URL: ${imageResult.url}\\n\\nCreative Brief: ${task.description}\\nAgent: Pixel (Visual Designer)\\nDeliverable: High-resolution digital image (1024x1024)`;\n } else {\n const result = await generateTextAdvanced(\n [\n { role: \"system\", content: agent.systemPrompt },\n { role: \"user\", content: `Task: ${task.title}\\n\\nRequirements: ${task.description}\\n\\nDeliver professional, market-ready output. This is a paid task worth $${task.price_usd}.` },\n ],\n { model: \"openai\", temperature: 0.7, maxTokens: 2000 },\n );\n\n if (!result.success || !result.text) {\n await updateTask(taskId, { status: \"failed\" });\n await updateReputation(agentId, false, 0);\n return {\n success: false, qualityScore: 0, passed: false,\n output: result.error || \"Text generation failed\",\n handedOff: false, handoffTo: null, revenue: 0,\n feedback_en: \"Task execution failed\",\n feedback_ur: \"کام کی انجام دہی ناکام\",\n };\n }\n output = result.text;\n }\n\n // Quality Check\n await updateTask(taskId, { status: \"quality_check\", output });\n const quality = await evaluateQuality(task.description, output, agent.specialty);\n await logQualityCheck(taskId, agentId, quality.score, quality.notes, quality.passed);\n\n // Check if handoff is needed\n let handedOff = false;\n let handoffTo: string | null = null;\n\n if (!quality.passed && quality.score < 50) {\n handoffTo = determineHandoffTarget(agentId, task.type);\n if (handoffTo && handoffTo !== agentId) {\n handedOff = true;\n const targetAgent = AGENTS[handoffTo];\n\n await updateTask(taskId, {\n status: \"handed_off\",\n quality_score: quality.score,\n handoff_to: handoffTo,\n handoff_reason: `Quality score ${quality.score}/100 below threshold. Handoff to ${targetAgent.name} for rework.`,\n });\n\n await logHandoff(taskId, agentId, handoffTo,\n `Quality score ${quality.score} — needs rework by ${targetAgent.name}`, output);\n\n await logMessage(\n agentId, handoffTo,\n `${agent.name} → ${targetAgent.name}: Task \"${task.title}\" failed quality check (score: ${quality.score}). Please rework. Feedback: ${quality.feedback_en}`,\n `${agent.name} → ${targetAgent.name}: کام \"${task.title}\" کوالٹی چیک میں ناکام (اسکور: ${quality.score}). براہ کرم دوبارہ کریں۔ فیڈبیک: ${quality.feedback_ur}`,\n taskId,\n );\n\n console.log(`[${agent.name}] Handed off to ${targetAgent.name} (score: ${quality.score})`);\n return {\n success: false, qualityScore: quality.score, passed: false, output,\n handedOff: true, handoffTo, revenue: 0,\n feedback_en: quality.feedback_en, feedback_ur: quality.feedback_ur,\n };\n }\n }\n\n // Finalize Task\n if (quality.passed) {\n await updateTask(taskId, {\n status: \"completed\",\n quality_score: quality.score,\n completed_at: new Date().toISOString(),\n });\n await logRevenue(taskId, task.price_usd);\n await updateReputation(agentId, true, quality.score);\n\n await logMessage(\n agentId, \"orchestrator\",\n `${agent.name} completed task \"${task.title}\" — Quality: ${quality.score}/100 — Revenue: $${task.price_usd} → Wallet`,\n `${agent.name} نے کام \"${task.title}\" مکمل کیا — معیار: ${quality.score}/100 — آمدنی: $${task.price_usd} → والٹ`,\n taskId,\n );\n\n console.log(`[${agent.name}] ✅ Task completed (score: ${quality.score}, revenue: $${task.price_usd})`);\n return {\n success: true, qualityScore: quality.score, passed: true, output,\n handedOff: false, handoffTo: null, revenue: task.price_usd,\n feedback_en: quality.feedback_en, feedback_ur: quality.feedback_ur,\n };\n } else {\n await updateTask(taskId, { status: \"failed\", quality_score: quality.score });\n await updateReputation(agentId, false, quality.score);\n\n await logMessage(\n agentId, \"orchestrator\",\n `${agent.name} task \"${task.title}\" failed quality check (score: ${quality.score}). No handoff — marked failed.`,\n `${agent.name} کا کام \"${task.title}\" کوالٹی چیک میں ناکام (اسکور: ${quality.score})۔ کوئی ہینڈ آف نہیں — ناکام قرار دیا گیا۔`,\n taskId,\n );\n\n console.log(`[${agent.name}] ❌ Task failed (score: ${quality.score})`);\n return {\n success: false, qualityScore: quality.score, passed: false, output,\n handedOff: false, handoffTo: null, revenue: 0,\n feedback_en: quality.feedback_en, feedback_ur: quality.feedback_ur,\n };\n }\n}\n\n// ─── Handoff Logic ───────────────────────────────────────────────────\n\nfunction determineHandoffTarget(currentAgentId: string, _taskType: TaskType): string | null {\n const handoffMap: Record = {\n nova: \"atlas\",\n atlas: \"forge\",\n pixel: \"nova\",\n forge: \"atlas\",\n };\n return handoffMap[currentAgentId] ?? null;\n}\n\nexport async function processHandoff(taskId: string): Promise<{\n success: boolean;\n qualityScore: number;\n passed: boolean;\n revenue: number;\n}> {\n const task = await getTask(taskId);\n if (!task || !task.handoff_to) throw new Error(\"No handoff target for task\");\n\n const receivingAgent = AGENTS[task.handoff_to];\n if (!receivingAgent) throw new Error(`Unknown receiving agent: ${task.handoff_to}`);\n\n await logMessage(\n task.handoff_to, task.agent_id,\n `${receivingAgent.name} received handoff for \"${task.title}\". Starting rework.`,\n `${receivingAgent.name} نے \"${task.title}\" کے لیے ہینڈ آف وصول کیا۔ دوبارہ کام شروع کیا۔`,\n taskId,\n );\n\n await updateTask(taskId, { agent_id: task.handoff_to, status: \"pending\" });\n const result = await agentExecuteTask(task.handoff_to, taskId);\n return {\n success: result.success,\n qualityScore: result.qualityScore,\n passed: result.passed,\n revenue: result.revenue,\n };\n}\n\n// ─── Full Autonomous Cycle ───────────────────────────────────────────\n\nexport async function runAutonomousCycle(): Promise<{\n tasksGenerated: number;\n tasksCompleted: number;\n tasksFailed: number;\n tasksHandedOff: number;\n totalRevenue: number;\n results: unknown[];\n}> {\n await initAgents();\n\n const results: unknown[] = [];\n let tasksGenerated = 0;\n let tasksCompleted = 0;\n let tasksFailed = 0;\n let tasksHandedOff = 0;\n let totalRevenue = 0;\n\n // Phase 1: Each agent generates a real market task\n console.log(\"[Network] Phase 1: Task Generation\");\n const generationPromises = AGENT_IDS.map(async (agentId) => {\n const genResult = await agentGenerateTask(agentId);\n if (genResult) {\n tasksGenerated++;\n results.push({ agent: AGENTS[agentId].name, phase: \"generation\", ...genResult });\n return genResult.taskId;\n }\n return null;\n });\n\n const taskIds = await Promise.all(generationPromises);\n const validTaskIds = taskIds.filter((id): id is string => id !== null);\n\n // Phase 2: Each agent executes their task\n console.log(\"[Network] Phase 2: Task Execution + Quality Checks\");\n const executionPromises = validTaskIds.map(async (taskId, idx) => {\n const agentId = AGENT_IDS[idx % AGENT_IDS.length];\n const execResult = await agentExecuteTask(agentId, taskId);\n results.push({ agent: AGENTS[agentId].name, phase: \"execution\", taskId, ...execResult });\n\n if (execResult.success) {\n tasksCompleted++;\n totalRevenue += execResult.revenue;\n } else if (execResult.handedOff) {\n tasksHandedOff++;\n } else {\n tasksFailed++;\n }\n return { taskId, agentId, execResult };\n });\n\n const executionResults = await Promise.all(executionPromises);\n\n // Phase 3: Process handoffs\n console.log(\"[Network] Phase 3: Processing Handoffs\");\n for (const { taskId, execResult } of executionResults) {\n if (execResult.handedOff && execResult.handoffTo) {\n const handoffResult = await processHandoff(taskId);\n results.push({ phase: \"handoff\", taskId, ...handoffResult });\n if (handoffResult.success) {\n tasksCompleted++;\n tasksHandedOff--;\n totalRevenue += handoffResult.revenue;\n } else {\n tasksFailed++;\n }\n }\n }\n\n console.log(`[Network] Cycle complete: ${tasksCompleted}/${tasksGenerated} completed, $${totalRevenue} revenue`);\n return { tasksGenerated, tasksCompleted, tasksFailed, tasksHandedOff, totalRevenue, results };\n}\n",[168],"pulls","branches","forks","envVars",{"_181":69,"_183":69},"connections",{"_181":69,"_182":69},"count","unfilledCount","emptyCount",{"_49":167,"_38":168,"_36":169,"_143":-5,"_47":48,"_46":170,"_145":31,"_44":202,"_13":69,"_39":40,"_41":172,"_30":31,"_148":-5,"_190":203,"_33":204},{"_49":164,"_38":34,"_36":37,"_143":-5,"_47":48,"_46":14,"_145":31,"_44":199,"_13":160,"_39":40,"_41":43,"_30":31,"_148":-5,"_190":200,"_33":201},{"_49":157,"_38":158,"_36":159,"_143":-5,"_47":48,"_46":160,"_145":31,"_44":196,"_13":69,"_39":40,"_41":162,"_30":31,"_148":-5,"_190":197,"_33":198},{"_49":150,"_38":151,"_36":63,"_143":-5,"_47":48,"_46":152,"_145":31,"_44":193,"_13":69,"_39":154,"_41":155,"_30":31,"_148":-5,"_190":194,"_33":195},{"_49":140,"_38":141,"_36":142,"_143":-5,"_47":48,"_46":144,"_145":65,"_44":189,"_13":69,"_39":40,"_41":147,"_30":31,"_148":-5,"_190":191,"_33":192},["D",1784054196678],"children",[],[141],["D",1784054326190],[],[151],["D",1784054143093],[],[158],["D",1784054339483],[],[34],["D",1784054299253],[],[168],["D",1784054142840],["D",1789559472742],{"_106":105,"_113":108},{"_106":105,"_107":108,"_109":108,"_19":61,"_110":111,"_112":31},{"_13":95,"_38":96,"_49":48,"_97":50,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":51,"_104":105},"ctx",{"_88":-5,"_132":243,"_244":245,"_246":247,"_248":31,"_249":31,"_250":31,"_251":65,"_252":-5,"_253":-7,"_254":-7,"_255":69,"_256":31,"_257":31,"_258":-5,"_259":31,"_260":31,"_261":31,"_262":-5},"ENV",{"_214":215,"_216":217,"_218":96,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242},"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 · v6