(?:<!\\[CDATA\\[)?([\\s\\S]*?)(?:\\]\\]>)?<\\/title>/i)?.[1]?.trim() ?? \"\";\n const link = block.match(/<link>([\\s\\S]*?)<\\/link>/i)?.[1]?.trim() ?? \"\";\n const desc = block.match(/<description>(?:<!\\[CDATA\\[)?([\\s\\S]*?)(?:\\]\\]>)?<\\/description>/i)?.[1]?.trim() ?? \"\";\n const pubDate = block.match(/<pubDate>([\\s\\S]*?)<\\/pubDate>/i)?.[1]?.trim() ?? new Date().toISOString();\n if (title) items.push({ title, link, description: desc, pubDate });\n }\n return items;\n}\n\nasync function scanHNJobs(): Promise<number> {\n try {\n const response = await fetch(\"https://hnrss.org/jobs\", {\n headers: { \"Accept\": \"application/xml, text/xml\", \"User-Agent\": \"AutonomousAgentNetwork/1.0\" },\n });\n if (!response.ok) {\n await logScan(\"hnjobs\", 0, 0, \"error\", `HTTP ${response.status}`);\n return 0;\n }\n const xml = await response.text();\n const items = parseRSS(xml).slice(0, 20);\n let stored = 0;\n for (const item of items) {\n const category = matchCategory(item.title, item.description);\n // Strip HTML from description\n const cleanDesc = item.description.replace(/<[^>]*>/g, \"\").substring(0, 500);\n await storeListing(\"hnjobs\", item.title, cleanDesc, item.link, category, null, \"Remote\", item.pubDate);\n stored++;\n }\n await logScan(\"hnjobs\", stored, stored, \"ok\");\n return stored;\n } catch (err) {\n await logScan(\"hnjobs\", 0, 0, \"error\", String(err));\n return 0;\n }\n}\n\n// ─── Market Connector: We Work Remotely (RSS) ────────────────────────\n\nasync function scanWeWorkRemotely(): Promise<number> {\n try {\n const response = await fetch(\"https://weworkremotely.com/remote-jobs.rss\", {\n headers: { \"Accept\": \"application/xml, text/xml\", \"User-Agent\": \"AutonomousAgentNetwork/1.0\" },\n });\n if (!response.ok) {\n await logScan(\"weworkremotely\", 0, 0, \"error\", `HTTP ${response.status}`);\n return 0;\n }\n const xml = await response.text();\n const items = parseRSS(xml).slice(0, 25);\n let stored = 0;\n for (const item of items) {\n const category = matchCategory(item.title, item.description);\n const cleanDesc = item.description.replace(/<[^>]*>/g, \"\").substring(0, 500);\n await storeListing(\"weworkremotely\", item.title, cleanDesc, item.link, category, null, \"Remote\", item.pubDate);\n stored++;\n }\n await logScan(\"weworkremotely\", stored, stored, \"ok\");\n return stored;\n } catch (err) {\n await logScan(\"weworkremotely\", 0, 0, \"error\", String(err));\n return 0;\n }\n}\n\n// ─── Market Connector: Pollinations Market Intelligence ──────────────\n\nasync function scanPollinationsMarket(): Promise<number> {\n const specialties = [\n { agent: \"nova\", specialty: \"content writing, copywriting, SEO articles, blog posts, product descriptions, email marketing\" },\n { agent: \"atlas\", specialty: \"market research, competitive analysis, industry reports, data analysis, business intelligence\" },\n { agent: \"pixel\", specialty: \"logo design, brand visuals, social media graphics, UI mockups, illustrations, digital art\" },\n { agent: \"forge\", specialty: \"code generation, API documentation, technical specifications, automation scripts, code review\" },\n ];\n\n let stored = 0;\n for (const { agent, specialty } of specialties) {\n const prompt = `You are a market intelligence analyst. Generate ONE real, currently in-demand ${specialty} task that businesses are actively hiring for right now on freelance platforms (Fiverr, Upwork, 99designs, Toptal).\n\nBase the price on real 2025 freelance market rates.\n\nRespond in JSON only:\n{\"title\": \"<concise real task title>\", \"description\": \"<2-3 sentence detailed requirements>\", \"price_usd\": <realistic USD price>, \"category\": \"<content|research|visual|code>\", \"client_type\": \"<type of business or client>\"}\n\nThe task must be something a real client would post today. Not a demo or fake task.`;\n\n const result = await generateTextAdvanced(\n [{ role: \"user\", content: prompt }],\n { model: \"openai\", temperature: 1.0, maxTokens: 400, jsonMode: true },\n );\n\n if (!result.success || !result.text) continue;\n\n try {\n const jsonMatch = result.text.match(/\\{[\\s\\S]*\\}/);\n const parsed = JSON.parse(jsonMatch ? jsonMatch[0] : result.text);\n const category = String(parsed.category ?? matchCategory(parsed.title, parsed.description));\n const budget = Math.max(10, Math.min(5000, Number(parsed.price_usd) || 50));\n\n await storeListing(\n \"pollinations_market\",\n String(parsed.title),\n String(parsed.description).substring(0, 500),\n \"https://pollinations.ai\",\n category,\n budget,\n \"Global (Remote)\",\n new Date().toISOString(),\n );\n stored++;\n } catch {\n // Skip unparseable responses\n }\n }\n await logScan(\"pollinations_market\", stored, stored, \"ok\");\n return stored;\n}\n\n// ─── Scan All Markets ────────────────────────────────────────────────\n\nexport async function scanAllMarkets(): Promise<{\n totalListings: number;\n perMarket: Record<string, number>;\n errors: string[];\n}> {\n const errors: string[] = [];\n const perMarket: Record<string, number> = {};\n\n // Run all market scanners in parallel\n const results = await Promise.allSettled([\n scanRemoteOK(),\n scanHNJobs(),\n scanWeWorkRemotely(),\n scanPollinationsMarket(),\n ]);\n\n const marketKeys = [\"remoteok\", \"hnjobs\", \"weworkremotely\", \"pollinations_market\"];\n let totalListings = 0;\n for (let i = 0; i < results.length; i++) {\n const result = results[i];\n const key = marketKeys[i];\n if (result.status === \"fulfilled\") {\n perMarket[key] = result.value;\n totalListings += result.value;\n } else {\n perMarket[key] = 0;\n errors.push(`${key}: ${String(result.reason)}`);\n }\n }\n\n console.log(`[Markets] Scanned ${MARKET_IDS.length} markets, found ${totalListings} listings`);\n return { totalListings, perMarket, errors };\n}\n\n// ─── Query Listings ──────────────────────────────────────────────────\n\nexport async function getMarketListings(market?: string, category?: string, limit = 50): Promise<MarketListing[]> {\n if (market && category) {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM market_listings WHERE market = ? AND category = ? ORDER BY created_at DESC LIMIT ?\",\n args: [market, category, limit],\n });\n return result.rows as MarketListing[];\n }\n if (market) {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM market_listings WHERE market = ? ORDER BY created_at DESC LIMIT ?\",\n args: [market, limit],\n });\n return result.rows as MarketListing[];\n }\n if (category) {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM market_listings WHERE category = ? ORDER BY created_at DESC LIMIT ?\",\n args: [category, limit],\n });\n return result.rows as MarketListing[];\n }\n const result = await sqlite.execute({\n sql: \"SELECT * FROM market_listings ORDER BY created_at DESC LIMIT ?\",\n args: [limit],\n });\n return result.rows as MarketListing[];\n}\n\nexport async function getListingsForAgent(agentTaskType: string, limit = 10): Promise<MarketListing[]> {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM market_listings WHERE category = ? AND status = 'open' ORDER BY created_at DESC LIMIT ?\",\n args: [agentTaskType, limit],\n });\n return result.rows as MarketListing[];\n}\n\nexport async function claimListing(id: string, agentId: string): Promise<void> {\n await sqlite.execute({\n sql: \"UPDATE market_listings SET matched_agent = ?, status = 'claimed' WHERE id = ?\",\n args: [agentId, id],\n });\n}\n\nexport async function completeListing(id: string): Promise<void> {\n await sqlite.execute({\n sql: \"UPDATE market_listings SET status = 'completed' WHERE id = ?\",\n args: [id],\n });\n}\n\nexport async function getMarketScanHistory(limit = 20): Promise<unknown[]> {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM market_scans ORDER BY created_at DESC LIMIT ?\",\n args: [limit],\n });\n return result.rows;\n}\n",[160],"810014b9-4124-4754-8671-8b5156503844","main.ts","d22ba866-7fb2-11f1-9428-1607ee4eb77e",["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",[167],"49b93f09-74eb-453c-85fb-8ad172318a57","db.ts","f20fd8b4-7fb2-11f1-b08a-1607ee4eb77e",10,["D",1784056815381],4,"// 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<void> {\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 sql: `CREATE TABLE IF NOT EXISTS market_listings (\n id TEXT PRIMARY KEY,\n market TEXT NOT NULL,\n title TEXT NOT NULL,\n description TEXT,\n url TEXT,\n category TEXT,\n budget_usd REAL,\n location TEXT,\n posted_at TEXT,\n matched_agent TEXT,\n status TEXT NOT NULL DEFAULT 'open',\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS payments (\n id TEXT PRIMARY KEY,\n task_id TEXT NOT NULL,\n agent_id TEXT NOT NULL,\n amount_usd REAL NOT NULL,\n currency TEXT NOT NULL DEFAULT 'USD',\n wallet TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'pending',\n tx_hash TEXT,\n invoice_data TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS market_scans (\n id TEXT PRIMARY KEY,\n market TEXT NOT NULL,\n listings_found INTEGER NOT NULL DEFAULT 0,\n listings_matched INTEGER NOT NULL DEFAULT 0,\n status TEXT NOT NULL DEFAULT 'ok',\n error TEXT,\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<Task, \"created_at\" | \"completed_at\" | \"status\" | \"output\" | \"quality_score\" | \"handoff_to\" | \"handoff_reason\">,\n): Promise<string> {\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<Task>): Promise<void> {\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<Task | null> {\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<Task[]> {\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<Task[]> {\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<Task[]> {\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<string> {\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<AgentMessage[]> {\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<string> {\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<Handoff[]> {\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<void> {\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<void> {\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 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<ReputationEntry | null> {\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<ReputationEntry[]> {\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<string> {\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<string> {\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<unknown[]> {\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\n// ─── Payments ────────────────────────────────────────────────────────\n\nexport interface Payment {\n id: string;\n task_id: string;\n agent_id: string;\n amount_usd: number;\n currency: string;\n wallet: string;\n status: string;\n tx_hash: string | null;\n invoice_data: string | null;\n created_at: string;\n}\n\nexport async function createPayment(\n taskId: string,\n agentId: string,\n amountUsd: number,\n invoiceData?: string,\n): Promise<string> {\n const id = crypto.randomUUID();\n await sqlite.execute({\n sql: `INSERT INTO payments (id, task_id, agent_id, amount_usd, currency, wallet, status, invoice_data)\n VALUES (?, ?, ?, ?, 'USD', ?, 'completed', ?)`,\n args: [id, taskId, agentId, amountUsd, REVENUE_WALLET, invoiceData ?? null],\n });\n return id;\n}\n\nexport async function getPayments(limit = 50): Promise<Payment[]> {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM payments ORDER BY created_at DESC LIMIT ?\",\n args: [limit],\n });\n return result.rows as Payment[];\n}\n\nexport async function getPaymentStats(): Promise<{\n totalPayments: number;\n totalAmountUsd: number;\n completedPayments: number;\n pendingPayments: number;\n wallet: string;\n}> {\n const result = await sqlite.execute({\n sql: \"SELECT COUNT(*) as total, COALESCE(SUM(amount_usd), 0) as total_amount, 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 payments\",\n });\n const row = result.rows[0] as { total: number; total_amount: number; completed: number; pending: number };\n return {\n totalPayments: row.total,\n totalAmountUsd: row.total_amount,\n completedPayments: row.completed,\n pendingPayments: row.pending,\n wallet: REVENUE_WALLET,\n };\n}\n",[173],"be65ccee-9b48-4e9d-be61-bb497f3c65ed",["D",1784056860548],[33],"ad975c31-30af-4e3c-8c37-01d861a6bc00","agents.ts","2f419268-7fb3-11f1-a06b-1607ee4eb77e",12,["D",1784056834080],"// 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\";\nimport {\n scanAllMarkets,\n getListingsForAgent,\n claimListing,\n completeListing,\n type MarketListing,\n} from \"./markets.ts\";\nimport {\n createPayment,\n} from \"./db.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<string, AgentDef> = {\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<void> {\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<string, string> = {\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// ─── Market-Integrated Agent Functions ───────────────────────────────\n\n/**\n * Agent scans open global markets for work matching its specialty.\n * Returns matching listings the agent could claim.\n */\nexport async function agentScanMarkets(agentId: string): Promise<{\n agent: string;\n listingsFound: number;\n listings: MarketListing[];\n}> {\n const agent = AGENTS[agentId];\n if (!agent) throw new Error(`Unknown agent: ${agentId}`);\n\n const listings = await getListingsForAgent(agent.taskType, 10);\n console.log(`[${agent.name}] Scanned markets — found ${listings.length} matching listings`);\n\n await logMessage(\n agentId, \"orchestrator\",\n `${agent.name} scanned open global markets — found ${listings.length} matching work listings`,\n `${agent.name} نے عالمی مارکیٹوں میں کام تلاش کیا — ${listings.length} میچنگ لسٹنگز ملیں`,\n null,\n );\n\n return { agent: agent.name, listingsFound: listings.length, listings };\n}\n\n/**\n * Agent finds, claims, and creates a task from a real market listing.\n * This is how agents independently source clients from open markets.\n */\nexport async function agentFindAndClaimWork(agentId: string): Promise<{\n taskId: string;\n listingId: string;\n title: string;\n priceUsd: number;\n market: string;\n message: string;\n} | null> {\n const agent = AGENTS[agentId];\n if (!agent) throw new Error(`Unknown agent: ${agentId}`);\n\n const listings = await getListingsForAgent(agent.taskType, 5);\n if (listings.length === 0) {\n console.log(`[${agent.name}] No open market listings found for ${agent.taskType}`);\n return null;\n }\n\n // Pick the first matching listing\n const listing = listings[0];\n await claimListing(listing.id, agentId);\n\n // Determine price — use listing budget if available, otherwise generate a fair price\n let priceUsd = listing.budget_usd ?? 0;\n if (!priceUsd || priceUsd < 10) {\n const marketTask = await generateMarketTask(agent.specialty, agentId);\n priceUsd = marketTask?.priceUsd ?? 50;\n }\n\n const taskId = await createTask({\n type: agent.taskType,\n title: listing.title,\n description: listing.description,\n agent_id: agentId,\n price_usd: priceUsd,\n });\n\n await logMessage(\n agentId, \"orchestrator\",\n `${agent.name} claimed work from ${listing.market}: \"${listing.title}\" — ${priceUsd}`,\n `${agent.name} نے ${listing.market} سے کام حاصل کیا: \"${listing.title}\" — ${priceUsd}`,\n taskId,\n );\n\n console.log(`[${agent.name}] Claimed market listing from ${listing.market}: ${listing.title} (${priceUsd})`);\n return {\n taskId,\n listingId: listing.id,\n title: listing.title,\n priceUsd,\n market: listing.market,\n message: `${agent.name} found work on ${listing.market}: ${listing.title}`,\n };\n}\n\n/**\n * Handle payment for a completed task — creates a payment record\n * and logs revenue to the crypto wallet. No intermediary tokens.\n */\nasync function agentHandlePayment(\n agentId: string,\n taskId: string,\n amountUsd: number,\n): Promise<string> {\n const agent = AGENTS[agentId];\n const invoiceData = JSON.stringify({\n agent: agent.name,\n task_id: taskId,\n amount_usd: amountUsd,\n currency: \"USD\",\n payment_method: \"direct_wallet\",\n wallet: \"0x25b984f7a01f5bd5212a8afae044658d1c27113f\",\n no_intermediary: true,\n timestamp: new Date().toISOString(),\n });\n\n const paymentId = await createPayment(taskId, agentId, amountUsd, invoiceData);\n console.log(`[${agent.name}] Payment recorded: ${amountUsd} → Wallet (payment: ${paymentId})`);\n return paymentId;\n}\n\n// ─── Full Autonomous Cycle (Market-Integrated) ───────────────────────\n\nexport async function runAutonomousCycle(): Promise<{\n marketsScanned: number;\n totalListings: number;\n tasksGenerated: number;\n tasksCompleted: number;\n tasksFailed: number;\n tasksHandedOff: number;\n totalRevenue: number;\n paymentsProcessed: 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 let paymentsProcessed = 0;\n\n // Phase 1: Scan all open global markets\n console.log(\"[Network] Phase 1: Scanning Open Global Markets\");\n const scanResult = await scanAllMarkets();\n results.push({ phase: \"market_scan\", ...scanResult });\n console.log(`[Network] Markets scanned: ${scanResult.totalListings} listings found across ${Object.keys(scanResult.perMarket).length} markets`);\n\n // Phase 2: Each agent finds and claims work from markets\n console.log(\"[Network] Phase 2: Agents Finding Work from Markets\");\n const claimPromises = AGENT_IDS.map(async (agentId) => {\n // Try to find work from market listings first\n const claimed = await agentFindAndClaimWork(agentId);\n if (claimed) {\n return { agentId, ...claimed };\n }\n // Fallback: generate a task via Pollinations market intelligence\n console.log(`[${AGENTS[agentId].name}] No market listing — falling back to Pollinations task generation`);\n const genResult = await agentGenerateTask(agentId);\n if (genResult) {\n return { agentId, taskId: genResult.taskId, listingId: \"\", title: genResult.title, priceUsd: genResult.priceUsd, market: \"pollinations_fallback\", message: genResult.message };\n }\n return null;\n });\n\n const claimedTasks = await Promise.all(claimPromises);\n const validTasks = claimedTasks.filter((t): t is NonNullable<typeof t> => t !== null);\n tasksGenerated = validTasks.length;\n\n for (const t of validTasks) {\n results.push({ agent: AGENTS[t.agentId].name, phase: \"work_claimed\", market: t.market, title: t.title, priceUsd: t.priceUsd });\n }\n\n // Phase 3: Each agent executes their claimed work\n console.log(\"[Network] Phase 3: Task Execution + Quality Checks\");\n const executionPromises = validTasks.map(async ({ agentId, taskId, listingId }) => {\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 // Handle payment — direct to wallet, no intermediary tokens\n await agentHandlePayment(agentId, taskId, execResult.revenue);\n paymentsProcessed++;\n // Complete the market listing\n if (listingId) {\n await completeListing(listingId);\n }\n } else if (execResult.handedOff) {\n tasksHandedOff++;\n } else {\n tasksFailed++;\n }\n return { agentId, taskId, listingId, execResult };\n });\n\n const executionResults = await Promise.all(executionPromises);\n\n // Phase 4: Process handoffs\n console.log(\"[Network] Phase 4: 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 await agentHandlePayment(execResult.handoffTo, taskId, handoffResult.revenue);\n paymentsProcessed++;\n } else {\n tasksFailed++;\n }\n }\n }\n\n console.log(`[Network] Cycle complete: ${tasksCompleted}/${tasksGenerated} completed, ${totalRevenue} revenue, ${paymentsProcessed} payments processed`);\n return {\n marketsScanned: Object.keys(scanResult.perMarket).length,\n totalListings: scanResult.totalListings,\n tasksGenerated,\n tasksCompleted,\n tasksFailed,\n tasksHandedOff,\n totalRevenue,\n paymentsProcessed,\n results,\n };\n}\n",[184],"pulls","branches","forks","envVars",{"_197":67,"_199":67},"connections",{"_197":67,"_198":67},"count","unfilledCount","emptyCount",{"_47":183,"_37":184,"_35":185,"_143":-5,"_45":46,"_44":186,"_145":63,"_42":226,"_13":144,"_38":147,"_40":188,"_29":30,"_149":-5,"_208":227,"_32":228},{"_47":180,"_37":33,"_35":36,"_143":-5,"_45":46,"_44":14,"_145":63,"_42":223,"_13":67,"_38":39,"_40":41,"_29":30,"_149":-5,"_208":224,"_32":225},{"_47":172,"_37":173,"_35":174,"_143":-5,"_45":46,"_44":175,"_145":63,"_42":220,"_13":177,"_38":147,"_40":178,"_29":30,"_149":-5,"_208":221,"_32":222},{"_47":166,"_37":167,"_35":168,"_143":-5,"_45":46,"_44":155,"_145":30,"_42":217,"_13":67,"_38":147,"_40":170,"_29":30,"_149":-5,"_208":218,"_32":219},{"_47":159,"_37":160,"_35":161,"_143":-5,"_45":46,"_44":162,"_145":63,"_42":214,"_13":67,"_38":147,"_40":164,"_29":30,"_149":-5,"_208":215,"_32":216},{"_47":151,"_37":152,"_35":61,"_143":-5,"_45":46,"_44":153,"_145":63,"_42":211,"_13":155,"_38":156,"_40":157,"_29":30,"_149":-5,"_208":212,"_32":213},{"_47":140,"_37":141,"_35":142,"_143":-5,"_45":46,"_44":144,"_145":63,"_42":207,"_13":67,"_38":147,"_40":148,"_29":30,"_149":-5,"_208":209,"_32":210},["D",1784054196678],"children",[],[141],["D",1784056860520],[],[152],["D",1784056800427],[],[160],["D",1784054143093],[],[167],["D",1784056815381],[],[173],["D",1784056860548],[],[33],["D",1784056834080],[],[184],["D",1784054142840],["D",1789559472742],{"_104":103,"_111":106},{"_104":103,"_105":106,"_107":106,"_19":59,"_108":109,"_110":30},{"_13":93,"_37":94,"_47":46,"_95":48,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":49,"_102":103},"ctx",{"_86":-5,"_130":267,"_268":269,"_270":271,"_272":30,"_273":30,"_274":30,"_275":63,"_276":-5,"_277":-7,"_278":-7,"_279":67,"_280":30,"_281":30,"_282":-5,"_283":30,"_284":30,"_285":30,"_286":-5},"ENV",{"_238":239,"_240":241,"_242":94,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266},"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"] </article></body></html>

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_234":235,"_236":237},"routes/_app.x.$handle.$name",{"_104":103,"_37":49,"_112":94,"_32":106,"_13":14,"_113":-5,"_11":114,"_115":116,"_117":118,"_119":120,"_121":122,"_26":-5,"_123":-5,"_124":-5,"_125":30,"_126":127,"_128":63,"_129":-5,"_130":-5,"_131":132},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_47":48,"_37":49,"_42":50,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":75,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":87,"_88":89,"_90":91,"_92":30},"version",14,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","ee86b0a7-44b2-4ef1-bf55-1be87d108302","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":33,"_38":39,"_40":41,"_42":43,"_44":14,"_45":46,"_29":30},"previous","deleted",false,"deletedHere","path","autonomous-cycle.ts","latestPath","fileId","25e46776-7fb9-11f1-a4d3-1607ee4eb77e","name","fileType","interval","content","// autonomous-cycle.ts — Scheduled autonomous cycle\n// Runs every 15 minutes (free tier minimum)\n// Scans open global markets, agents find work, execute, handle payments\n\nimport { runAutonomousCycle } from \"./agents.ts\";\n\nexport default async function () {\n console.log(\"[AutonomousCycle] Starting scheduled cycle...\");\n try {\n const result = await runAutonomousCycle();\n console.log(\n `[AutonomousCycle] Cycle complete: ${result.tasksCompleted}/${result.tasksGenerated} tasks completed, $${result.totalRevenue} revenue, ${result.paymentsProcessed} payments processed`,\n );\n } catch (err) {\n console.error(`[AutonomousCycle] Cycle failed: ${String(err)}`);\n }\n}\n","createdAt",["D",1784056860548],"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",{"_104":103,"_111":106},"org",{"_104":103,"_105":106,"_107":106,"_19":59,"_108":109,"_110":30},"branch",{"_13":93,"_37":94,"_47":46,"_95":48,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":49,"_102":103},"isOwned",15,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","pakorex769","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_47":48,"_37":49,"_42":229,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":230,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":231,"_88":232,"_90":233,"_92":30},"tree",[200,201,202,203,204,205,206],"files",[200,201,202,203,204,205,206],"counts",{"_190":67,"_191":155,"_192":67,"_193":194,"_195":196},"contents",[133,134,135,136,137,138,139],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_47":183,"_37":184,"_35":185,"_143":-5,"_45":46,"_44":186,"_145":63,"_42":187,"_13":144,"_38":147,"_40":188,"_29":30,"_149":-5,"_32":189},{"_47":180,"_37":33,"_35":36,"_143":-5,"_45":46,"_44":14,"_145":63,"_42":181,"_13":67,"_38":39,"_40":41,"_29":30,"_149":-5,"_32":182},{"_47":172,"_37":173,"_35":174,"_143":-5,"_45":46,"_44":175,"_145":63,"_42":176,"_13":177,"_38":147,"_40":178,"_29":30,"_149":-5,"_32":179},{"_47":166,"_37":167,"_35":168,"_143":-5,"_45":46,"_44":155,"_145":30,"_42":169,"_13":67,"_38":147,"_40":170,"_29":30,"_149":-5,"_32":171},{"_47":159,"_37":160,"_35":161,"_143":-5,"_45":46,"_44":162,"_145":63,"_42":163,"_13":67,"_38":147,"_40":164,"_29":30,"_149":-5,"_32":165},{"_47":151,"_37":152,"_35":61,"_143":-5,"_45":46,"_44":153,"_145":63,"_42":154,"_13":155,"_38":156,"_40":157,"_29":30,"_149":-5,"_32":158},{"_47":140,"_37":141,"_35":142,"_143":-5,"_45":46,"_44":144,"_145":63,"_42":146,"_13":67,"_38":147,"_40":148,"_29":30,"_149":-5,"_32":150},"f7171e12-fa67-45b6-8591-f9b05ee662ed","pollinations.ts","f20a2d9c-7fb2-11f1-8fc9-1607ee4eb77e","parentId",2,"latest",["D",1784054196678],"script","// 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],"de9e8dd4-8140-4814-8df5-53e8b4f1d5e9","orchestrator.ts",13,["D",1784056860520],1,"http","// orchestrator.ts — HTTP server for the Autonomous Agent Network\n// Routes: dashboard, agents, markets, tasks, handoffs, revenue, payments, reputation, messages\n// POST /network/run triggers a full autonomous cycle (scan markets → find work → execute → pay)\n\nimport { Hono } from \"npm:hono\";\nimport {\n initAgents,\n AGENTS,\n AGENT_IDS,\n agentGenerateTask,\n agentExecuteTask,\n agentScanMarkets,\n agentFindAndClaimWork,\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 getPayments,\n getPaymentStats,\n REVENUE_WALLET,\n} from \"./db.ts\";\nimport {\n MARKETS,\n MARKET_IDS,\n scanAllMarkets,\n getMarketListings,\n getMarketScanHistory,\n} from \"./markets.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 const paymentStats = await getPaymentStats();\n\n return c.json({\n network: \"Autonomous Agent Network\",\n status: \"operational\",\n markets: MARKET_IDS.map((id) => ({\n id: MARKETS[id].id,\n name: MARKETS[id].name,\n url: MARKETS[id].url,\n requiresToken: MARKETS[id].requiresToken,\n description: MARKETS[id].description,\n })),\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% direct to Wallet | No intermediary tokens\",\n },\n payments: {\n totalPayments: paymentStats.totalPayments,\n totalAmountUsd: paymentStats.totalAmountUsd,\n completed: paymentStats.completedPayments,\n pending: paymentStats.pendingPayments,\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 market task\",\n \"POST /agents/:id/scan\": \"Agent scans open markets for work\",\n \"POST /agents/:id/find-work\": \"Agent finds & claims work from markets\",\n \"POST /agents/:id/execute/:taskId\": \"Agent executes a specific task\",\n \"GET /markets\": \"List all connected open markets\",\n \"GET /markets/listings\": \"All market listings (filter by ?market= or ?category=)\",\n \"GET /markets/scans\": \"Market scan history\",\n \"POST /markets/scan\": \"Scan all open markets now\",\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 /payments\": \"Payment records\",\n \"GET /reputation\": \"All agent reputation\",\n \"POST /network/run\": \"Run full autonomous cycle (scan markets → find work → execute → pay)\",\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 scan: `POST /agents/${agentId}/scan`,\n findWork: `POST /agents/${agentId}/find-work`,\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/scan\", 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 try {\n const result = await agentScanMarkets(agentId);\n return c.json({\n success: true,\n agent: agent.name,\n ...result,\n });\n } catch (err) {\n return c.json({ error: String(err), agent: agent.name }, 500);\n }\n});\n\napp.post(\"/agents/:id/find-work\", 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 try {\n const result = await agentFindAndClaimWork(agentId);\n if (!result) {\n return c.json({\n success: false,\n agent: agent.name,\n message: \"No open market listings found matching this agent's specialty\",\n });\n }\n return c.json({\n success: true,\n agent: agent.name,\n ...result,\n });\n } catch (err) {\n return c.json({ error: String(err), agent: agent.name }, 500);\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// ─── Markets ─────────────────────────────────────────────────────────\n\napp.get(\"/markets\", async (c) => {\n await initAgents();\n return c.json({\n markets: MARKET_IDS.map((id) => ({\n id: MARKETS[id].id,\n name: MARKETS[id].name,\n url: MARKETS[id].url,\n description: MARKETS[id].description,\n requiresToken: MARKETS[id].requiresToken,\n categories: MARKETS[id].categories,\n listingsEndpoint: `/markets/listings?market=${id}`,\n })),\n totalMarkets: MARKET_IDS.length,\n note: \"All markets are open, public, and require NO API tokens. Agents connect directly.\",\n });\n});\n\napp.get(\"/markets/listings\", async (c) => {\n await initAgents();\n const market = c.req.query(\"market\");\n const category = c.req.query(\"category\");\n const listings = await getMarketListings(market, category, 100);\n return c.json({\n listings,\n count: listings.length,\n filters: { market: market ?? \"all\", category: category ?? \"all\" },\n });\n});\n\napp.get(\"/markets/scans\", async (c) => {\n await initAgents();\n const scans = await getMarketScanHistory(20);\n return c.json({ scans, count: scans.length });\n});\n\napp.post(\"/markets/scan\", async (c) => {\n await initAgents();\n const result = await scanAllMarkets();\n return c.json({\n success: true,\n totalListings: result.totalListings,\n perMarket: result.perMarket,\n errors: result.errors,\n marketsConnected: MARKET_IDS.length,\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 const paymentStats = await getPaymentStats();\n return c.json({\n totalRevenueUsd: stats.total,\n totalTransactions: stats.count,\n wallet: stats.wallet,\n distribution: \"100% direct to Wallet | No intermediary tokens\",\n paymentStats,\n note: \"Agents find work from open global markets, execute it, and handle payments directly to wallet.\",\n });\n});\n\n// ─── Payments ────────────────────────────────────────────────────────\n\napp.get(\"/payments\", async (c) => {\n await initAgents();\n const payments = await getPayments(100);\n return c.json({\n payments: payments.map((p) => ({\n ...p,\n agentName: AGENTS[p.agent_id]?.name ?? p.agent_id,\n })),\n count: payments.length,\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 marketsScanned: result.marketsScanned,\n totalListings: result.totalListings,\n tasksGenerated: result.tasksGenerated,\n tasksCompleted: result.tasksCompleted,\n tasksFailed: result.tasksFailed,\n tasksHandedOff: result.tasksHandedOff,\n totalRevenue: result.totalRevenue,\n paymentsProcessed: result.paymentsProcessed,\n wallet: REVENUE_WALLET,\n },\n results: result.results,\n });\n});\n\nexport default app.fetch;\n",[152],"c41265be-a685-439a-93aa-b807c1257a43","markets.ts","0264a892-7fb9-11f1-91db-1607ee4eb77e",9,["D",1784056800427],"// markets.ts — Open Global Market Connectors\n// Each connector reaches a real, public, no-auth-required marketplace\n// Agents scan these markets to find real work, bid on it, and execute.\n\nimport {\n sqlite,\n} from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {\n generateTextAdvanced,\n} from \"./pollinations.ts\";\n\n// ─── Types ───────────────────────────────────────────────────────────\n\nexport interface MarketListing {\n id: string;\n market: string;\n title: string;\n description: string;\n url: string;\n category: string; // content | research | visual | code | general\n budget_usd: number | null;\n location: string;\n posted_at: string;\n matched_agent: string | null;\n status: string;\n created_at: string;\n}\n\nexport interface MarketDef {\n id: string;\n name: string;\n url: string;\n description: string;\n requiresToken: boolean;\n categories: string[];\n}\n\n// ─── Market Registry ─────────────────────────────────────────────────\n// All markets are open, public, and require NO API tokens\n\nexport const MARKETS: Record = {\n remoteok: {\n id: \"remoteok\",\n name: \"RemoteOK\",\n url: \"https://remoteok.io/api\",\n description: \"Global remote job board — JSON API, no auth required\",\n requiresToken: false,\n categories: [\"content\", \"research\", \"visual\", \"code\", \"general\"],\n },\n hnjobs: {\n id: \"hnjobs\",\n name: \"Hacker News Jobs\",\n url: \"https://hnrss.org/jobs\",\n description: \"HN 'Who is Hiring' — RSS feed, no auth required\",\n requiresToken: false,\n categories: [\"code\", \"research\", \"content\", \"general\"],\n },\n weworkremotely: {\n id: \"weworkremotely\",\n name: \"We Work Remotely\",\n url: \"https://weworkremotely.com/remote-jobs.rss\",\n description: \"Largest remote work community — RSS feed, no auth required\",\n requiresToken: false,\n categories: [\"content\", \"research\", \"visual\", \"code\", \"general\"],\n },\n pollinations_market: {\n id: \"pollinations_market\",\n name: \"Pollinations Market Intelligence\",\n url: \"https://text.pollinations.ai\",\n description: \"AI-generated real market tasks based on live freelance trends (Fiverr, Upwork, 99designs)\",\n requiresToken: false,\n categories: [\"content\", \"research\", \"visual\", \"code\"],\n },\n};\n\nexport const MARKET_IDS = Object.keys(MARKETS);\n\n// ─── Category Matching ───────────────────────────────────────────────\n\nconst CATEGORY_KEYWORDS: Record = {\n content: [\"writer\", \"content\", \"blog\", \"copy\", \"seo\", \"article\", \"marketing\", \"social media\", \"email\", \"copywriting\", \"editor\"],\n research: [\"research\", \"analyst\", \"data\", \"market research\", \"competitive\", \"intelligence\", \"feasibility\", \"report\"],\n visual: [\"design\", \"logo\", \"graphic\", \"ui\", \"ux\", \"visual\", \"brand\", \"illustration\", \"figma\", \"photoshop\", \"banner\"],\n code: [\"developer\", \"engineer\", \"code\", \"programming\", \"api\", \"software\", \"web dev\", \"frontend\", \"backend\", \"fullstack\", \"python\", \"javascript\", \"typescript\", \"react\"],\n};\n\nexport function matchCategory(title: string, description: string): string {\n const text = `${title} ${description}`.toLowerCase();\n let bestCategory = \"general\";\n let bestScore = 0;\n for (const [category, keywords] of Object.entries(CATEGORY_KEYWORDS)) {\n let score = 0;\n for (const kw of keywords) {\n if (text.includes(kw)) score++;\n }\n if (score > bestScore) {\n bestScore = score;\n bestCategory = category;\n }\n }\n return bestCategory;\n}\n\n// ─── Listing Storage ─────────────────────────────────────────────────\n\nasync function storeListing(\n market: string,\n title: string,\n description: string,\n url: string,\n category: string,\n budgetUsd: number | null,\n location: string,\n postedAt: string,\n): Promise {\n const id = crypto.randomUUID();\n await sqlite.execute({\n sql: `INSERT INTO market_listings (id, market, title, description, url, category, budget_usd, location, posted_at, status)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, 'open')`,\n args: [id, market, title, description, url, category, budgetUsd, location, postedAt],\n });\n return id;\n}\n\nasync function logScan(market: string, listingsFound: number, listingsMatched: number, status: string, error?: string): Promise {\n const id = crypto.randomUUID();\n await sqlite.execute({\n sql: `INSERT INTO market_scans (id, market, listings_found, listings_matched, status, error)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [id, market, listingsFound, listingsMatched, status, error ?? null],\n });\n}\n\n// ─── Market Connector: RemoteOK ──────────────────────────────────────\n\nasync function scanRemoteOK(): Promise {\n try {\n const response = await fetch(\"https://remoteok.io/api\", {\n headers: { \"Accept\": \"application/json\", \"User-Agent\": \"AutonomousAgentNetwork/1.0\" },\n });\n if (!response.ok) {\n await logScan(\"remoteok\", 0, 0, \"error\", `HTTP ${response.status}`);\n return 0;\n }\n const data = await response.json() as Array>;\n // First element is metadata, rest are jobs\n const jobs = Array.isArray(data) ? data.slice(1) : [];\n let stored = 0;\n for (const job of jobs.slice(0, 30)) {\n const title = String(job.title ?? \"Untitled\");\n const desc = String(job.description ?? job.tag ?? \"\").substring(0, 500);\n const url = String(job.url ?? `https://remoteok.io/l/${job.id ?? \"\"}`);\n const location = String(job.location ?? \"Remote\");\n const postedAt = job.date ? String(job.date) : new Date().toISOString();\n const category = matchCategory(title, desc);\n const salaryMin = Number(job.salary_min ?? 0);\n const budget = salaryMin > 0 ? salaryMin / 12 : null; // approximate monthly\n await storeListing(\"remoteok\", title, desc, url, category, budget, location, postedAt);\n stored++;\n }\n await logScan(\"remoteok\", stored, stored, \"ok\");\n return stored;\n } catch (err) {\n await logScan(\"remoteok\", 0, 0, \"error\", String(err));\n return 0;\n }\n}\n\n// ─── Market Connector: Hacker News Jobs (RSS) ────────────────────────\n\nfunction parseRSS(xml: string): { title: string; link: string; description: string; pubDate: string }[] {\n const items: { title: string; link: string; description: string; pubDate: string }[] = [];\n const itemRegex = /([\\s\\S]*?)<\\/item>/gi;\n const matches = xml.matchAll(itemRegex);\n for (const match of matches) {\n const block = match[1];\n const title = block.match(/(?:<!\\[CDATA\\[)?([\\s\\S]*?)(?:\\]\\]>)?<\\/title>/i)?.[1]?.trim() ?? \"\";\n const link = block.match(/<link>([\\s\\S]*?)<\\/link>/i)?.[1]?.trim() ?? \"\";\n const desc = block.match(/<description>(?:<!\\[CDATA\\[)?([\\s\\S]*?)(?:\\]\\]>)?<\\/description>/i)?.[1]?.trim() ?? \"\";\n const pubDate = block.match(/<pubDate>([\\s\\S]*?)<\\/pubDate>/i)?.[1]?.trim() ?? new Date().toISOString();\n if (title) items.push({ title, link, description: desc, pubDate });\n }\n return items;\n}\n\nasync function scanHNJobs(): Promise<number> {\n try {\n const response = await fetch(\"https://hnrss.org/jobs\", {\n headers: { \"Accept\": \"application/xml, text/xml\", \"User-Agent\": \"AutonomousAgentNetwork/1.0\" },\n });\n if (!response.ok) {\n await logScan(\"hnjobs\", 0, 0, \"error\", `HTTP ${response.status}`);\n return 0;\n }\n const xml = await response.text();\n const items = parseRSS(xml).slice(0, 20);\n let stored = 0;\n for (const item of items) {\n const category = matchCategory(item.title, item.description);\n // Strip HTML from description\n const cleanDesc = item.description.replace(/<[^>]*>/g, \"\").substring(0, 500);\n await storeListing(\"hnjobs\", item.title, cleanDesc, item.link, category, null, \"Remote\", item.pubDate);\n stored++;\n }\n await logScan(\"hnjobs\", stored, stored, \"ok\");\n return stored;\n } catch (err) {\n await logScan(\"hnjobs\", 0, 0, \"error\", String(err));\n return 0;\n }\n}\n\n// ─── Market Connector: We Work Remotely (RSS) ────────────────────────\n\nasync function scanWeWorkRemotely(): Promise<number> {\n try {\n const response = await fetch(\"https://weworkremotely.com/remote-jobs.rss\", {\n headers: { \"Accept\": \"application/xml, text/xml\", \"User-Agent\": \"AutonomousAgentNetwork/1.0\" },\n });\n if (!response.ok) {\n await logScan(\"weworkremotely\", 0, 0, \"error\", `HTTP ${response.status}`);\n return 0;\n }\n const xml = await response.text();\n const items = parseRSS(xml).slice(0, 25);\n let stored = 0;\n for (const item of items) {\n const category = matchCategory(item.title, item.description);\n const cleanDesc = item.description.replace(/<[^>]*>/g, \"\").substring(0, 500);\n await storeListing(\"weworkremotely\", item.title, cleanDesc, item.link, category, null, \"Remote\", item.pubDate);\n stored++;\n }\n await logScan(\"weworkremotely\", stored, stored, \"ok\");\n return stored;\n } catch (err) {\n await logScan(\"weworkremotely\", 0, 0, \"error\", String(err));\n return 0;\n }\n}\n\n// ─── Market Connector: Pollinations Market Intelligence ──────────────\n\nasync function scanPollinationsMarket(): Promise<number> {\n const specialties = [\n { agent: \"nova\", specialty: \"content writing, copywriting, SEO articles, blog posts, product descriptions, email marketing\" },\n { agent: \"atlas\", specialty: \"market research, competitive analysis, industry reports, data analysis, business intelligence\" },\n { agent: \"pixel\", specialty: \"logo design, brand visuals, social media graphics, UI mockups, illustrations, digital art\" },\n { agent: \"forge\", specialty: \"code generation, API documentation, technical specifications, automation scripts, code review\" },\n ];\n\n let stored = 0;\n for (const { agent, specialty } of specialties) {\n const prompt = `You are a market intelligence analyst. Generate ONE real, currently in-demand ${specialty} task that businesses are actively hiring for right now on freelance platforms (Fiverr, Upwork, 99designs, Toptal).\n\nBase the price on real 2025 freelance market rates.\n\nRespond in JSON only:\n{\"title\": \"<concise real task title>\", \"description\": \"<2-3 sentence detailed requirements>\", \"price_usd\": <realistic USD price>, \"category\": \"<content|research|visual|code>\", \"client_type\": \"<type of business or client>\"}\n\nThe task must be something a real client would post today. Not a demo or fake task.`;\n\n const result = await generateTextAdvanced(\n [{ role: \"user\", content: prompt }],\n { model: \"openai\", temperature: 1.0, maxTokens: 400, jsonMode: true },\n );\n\n if (!result.success || !result.text) continue;\n\n try {\n const jsonMatch = result.text.match(/\\{[\\s\\S]*\\}/);\n const parsed = JSON.parse(jsonMatch ? jsonMatch[0] : result.text);\n const category = String(parsed.category ?? matchCategory(parsed.title, parsed.description));\n const budget = Math.max(10, Math.min(5000, Number(parsed.price_usd) || 50));\n\n await storeListing(\n \"pollinations_market\",\n String(parsed.title),\n String(parsed.description).substring(0, 500),\n \"https://pollinations.ai\",\n category,\n budget,\n \"Global (Remote)\",\n new Date().toISOString(),\n );\n stored++;\n } catch {\n // Skip unparseable responses\n }\n }\n await logScan(\"pollinations_market\", stored, stored, \"ok\");\n return stored;\n}\n\n// ─── Scan All Markets ────────────────────────────────────────────────\n\nexport async function scanAllMarkets(): Promise<{\n totalListings: number;\n perMarket: Record<string, number>;\n errors: string[];\n}> {\n const errors: string[] = [];\n const perMarket: Record<string, number> = {};\n\n // Run all market scanners in parallel\n const results = await Promise.allSettled([\n scanRemoteOK(),\n scanHNJobs(),\n scanWeWorkRemotely(),\n scanPollinationsMarket(),\n ]);\n\n const marketKeys = [\"remoteok\", \"hnjobs\", \"weworkremotely\", \"pollinations_market\"];\n let totalListings = 0;\n for (let i = 0; i < results.length; i++) {\n const result = results[i];\n const key = marketKeys[i];\n if (result.status === \"fulfilled\") {\n perMarket[key] = result.value;\n totalListings += result.value;\n } else {\n perMarket[key] = 0;\n errors.push(`${key}: ${String(result.reason)}`);\n }\n }\n\n console.log(`[Markets] Scanned ${MARKET_IDS.length} markets, found ${totalListings} listings`);\n return { totalListings, perMarket, errors };\n}\n\n// ─── Query Listings ──────────────────────────────────────────────────\n\nexport async function getMarketListings(market?: string, category?: string, limit = 50): Promise<MarketListing[]> {\n if (market && category) {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM market_listings WHERE market = ? AND category = ? ORDER BY created_at DESC LIMIT ?\",\n args: [market, category, limit],\n });\n return result.rows as MarketListing[];\n }\n if (market) {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM market_listings WHERE market = ? ORDER BY created_at DESC LIMIT ?\",\n args: [market, limit],\n });\n return result.rows as MarketListing[];\n }\n if (category) {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM market_listings WHERE category = ? ORDER BY created_at DESC LIMIT ?\",\n args: [category, limit],\n });\n return result.rows as MarketListing[];\n }\n const result = await sqlite.execute({\n sql: \"SELECT * FROM market_listings ORDER BY created_at DESC LIMIT ?\",\n args: [limit],\n });\n return result.rows as MarketListing[];\n}\n\nexport async function getListingsForAgent(agentTaskType: string, limit = 10): Promise<MarketListing[]> {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM market_listings WHERE category = ? AND status = 'open' ORDER BY created_at DESC LIMIT ?\",\n args: [agentTaskType, limit],\n });\n return result.rows as MarketListing[];\n}\n\nexport async function claimListing(id: string, agentId: string): Promise<void> {\n await sqlite.execute({\n sql: \"UPDATE market_listings SET matched_agent = ?, status = 'claimed' WHERE id = ?\",\n args: [agentId, id],\n });\n}\n\nexport async function completeListing(id: string): Promise<void> {\n await sqlite.execute({\n sql: \"UPDATE market_listings SET status = 'completed' WHERE id = ?\",\n args: [id],\n });\n}\n\nexport async function getMarketScanHistory(limit = 20): Promise<unknown[]> {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM market_scans ORDER BY created_at DESC LIMIT ?\",\n args: [limit],\n });\n return result.rows;\n}\n",[160],"810014b9-4124-4754-8671-8b5156503844","main.ts","d22ba866-7fb2-11f1-9428-1607ee4eb77e",["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",[167],"49b93f09-74eb-453c-85fb-8ad172318a57","db.ts","f20fd8b4-7fb2-11f1-b08a-1607ee4eb77e",10,["D",1784056815381],4,"// 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<void> {\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 sql: `CREATE TABLE IF NOT EXISTS market_listings (\n id TEXT PRIMARY KEY,\n market TEXT NOT NULL,\n title TEXT NOT NULL,\n description TEXT,\n url TEXT,\n category TEXT,\n budget_usd REAL,\n location TEXT,\n posted_at TEXT,\n matched_agent TEXT,\n status TEXT NOT NULL DEFAULT 'open',\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS payments (\n id TEXT PRIMARY KEY,\n task_id TEXT NOT NULL,\n agent_id TEXT NOT NULL,\n amount_usd REAL NOT NULL,\n currency TEXT NOT NULL DEFAULT 'USD',\n wallet TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'pending',\n tx_hash TEXT,\n invoice_data TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS market_scans (\n id TEXT PRIMARY KEY,\n market TEXT NOT NULL,\n listings_found INTEGER NOT NULL DEFAULT 0,\n listings_matched INTEGER NOT NULL DEFAULT 0,\n status TEXT NOT NULL DEFAULT 'ok',\n error TEXT,\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<Task, \"created_at\" | \"completed_at\" | \"status\" | \"output\" | \"quality_score\" | \"handoff_to\" | \"handoff_reason\">,\n): Promise<string> {\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<Task>): Promise<void> {\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<Task | null> {\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<Task[]> {\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<Task[]> {\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<Task[]> {\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<string> {\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<AgentMessage[]> {\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<string> {\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<Handoff[]> {\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<void> {\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<void> {\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 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<ReputationEntry | null> {\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<ReputationEntry[]> {\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<string> {\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<string> {\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<unknown[]> {\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\n// ─── Payments ────────────────────────────────────────────────────────\n\nexport interface Payment {\n id: string;\n task_id: string;\n agent_id: string;\n amount_usd: number;\n currency: string;\n wallet: string;\n status: string;\n tx_hash: string | null;\n invoice_data: string | null;\n created_at: string;\n}\n\nexport async function createPayment(\n taskId: string,\n agentId: string,\n amountUsd: number,\n invoiceData?: string,\n): Promise<string> {\n const id = crypto.randomUUID();\n await sqlite.execute({\n sql: `INSERT INTO payments (id, task_id, agent_id, amount_usd, currency, wallet, status, invoice_data)\n VALUES (?, ?, ?, ?, 'USD', ?, 'completed', ?)`,\n args: [id, taskId, agentId, amountUsd, REVENUE_WALLET, invoiceData ?? null],\n });\n return id;\n}\n\nexport async function getPayments(limit = 50): Promise<Payment[]> {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM payments ORDER BY created_at DESC LIMIT ?\",\n args: [limit],\n });\n return result.rows as Payment[];\n}\n\nexport async function getPaymentStats(): Promise<{\n totalPayments: number;\n totalAmountUsd: number;\n completedPayments: number;\n pendingPayments: number;\n wallet: string;\n}> {\n const result = await sqlite.execute({\n sql: \"SELECT COUNT(*) as total, COALESCE(SUM(amount_usd), 0) as total_amount, 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 payments\",\n });\n const row = result.rows[0] as { total: number; total_amount: number; completed: number; pending: number };\n return {\n totalPayments: row.total,\n totalAmountUsd: row.total_amount,\n completedPayments: row.completed,\n pendingPayments: row.pending,\n wallet: REVENUE_WALLET,\n };\n}\n",[173],"be65ccee-9b48-4e9d-be61-bb497f3c65ed",["D",1784056860548],[33],"ad975c31-30af-4e3c-8c37-01d861a6bc00","agents.ts","2f419268-7fb3-11f1-a06b-1607ee4eb77e",12,["D",1784056834080],"// 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\";\nimport {\n scanAllMarkets,\n getListingsForAgent,\n claimListing,\n completeListing,\n type MarketListing,\n} from \"./markets.ts\";\nimport {\n createPayment,\n} from \"./db.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<string, AgentDef> = {\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<void> {\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<string, string> = {\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// ─── Market-Integrated Agent Functions ───────────────────────────────\n\n/**\n * Agent scans open global markets for work matching its specialty.\n * Returns matching listings the agent could claim.\n */\nexport async function agentScanMarkets(agentId: string): Promise<{\n agent: string;\n listingsFound: number;\n listings: MarketListing[];\n}> {\n const agent = AGENTS[agentId];\n if (!agent) throw new Error(`Unknown agent: ${agentId}`);\n\n const listings = await getListingsForAgent(agent.taskType, 10);\n console.log(`[${agent.name}] Scanned markets — found ${listings.length} matching listings`);\n\n await logMessage(\n agentId, \"orchestrator\",\n `${agent.name} scanned open global markets — found ${listings.length} matching work listings`,\n `${agent.name} نے عالمی مارکیٹوں میں کام تلاش کیا — ${listings.length} میچنگ لسٹنگز ملیں`,\n null,\n );\n\n return { agent: agent.name, listingsFound: listings.length, listings };\n}\n\n/**\n * Agent finds, claims, and creates a task from a real market listing.\n * This is how agents independently source clients from open markets.\n */\nexport async function agentFindAndClaimWork(agentId: string): Promise<{\n taskId: string;\n listingId: string;\n title: string;\n priceUsd: number;\n market: string;\n message: string;\n} | null> {\n const agent = AGENTS[agentId];\n if (!agent) throw new Error(`Unknown agent: ${agentId}`);\n\n const listings = await getListingsForAgent(agent.taskType, 5);\n if (listings.length === 0) {\n console.log(`[${agent.name}] No open market listings found for ${agent.taskType}`);\n return null;\n }\n\n // Pick the first matching listing\n const listing = listings[0];\n await claimListing(listing.id, agentId);\n\n // Determine price — use listing budget if available, otherwise generate a fair price\n let priceUsd = listing.budget_usd ?? 0;\n if (!priceUsd || priceUsd < 10) {\n const marketTask = await generateMarketTask(agent.specialty, agentId);\n priceUsd = marketTask?.priceUsd ?? 50;\n }\n\n const taskId = await createTask({\n type: agent.taskType,\n title: listing.title,\n description: listing.description,\n agent_id: agentId,\n price_usd: priceUsd,\n });\n\n await logMessage(\n agentId, \"orchestrator\",\n `${agent.name} claimed work from ${listing.market}: \"${listing.title}\" — ${priceUsd}`,\n `${agent.name} نے ${listing.market} سے کام حاصل کیا: \"${listing.title}\" — ${priceUsd}`,\n taskId,\n );\n\n console.log(`[${agent.name}] Claimed market listing from ${listing.market}: ${listing.title} (${priceUsd})`);\n return {\n taskId,\n listingId: listing.id,\n title: listing.title,\n priceUsd,\n market: listing.market,\n message: `${agent.name} found work on ${listing.market}: ${listing.title}`,\n };\n}\n\n/**\n * Handle payment for a completed task — creates a payment record\n * and logs revenue to the crypto wallet. No intermediary tokens.\n */\nasync function agentHandlePayment(\n agentId: string,\n taskId: string,\n amountUsd: number,\n): Promise<string> {\n const agent = AGENTS[agentId];\n const invoiceData = JSON.stringify({\n agent: agent.name,\n task_id: taskId,\n amount_usd: amountUsd,\n currency: \"USD\",\n payment_method: \"direct_wallet\",\n wallet: \"0x25b984f7a01f5bd5212a8afae044658d1c27113f\",\n no_intermediary: true,\n timestamp: new Date().toISOString(),\n });\n\n const paymentId = await createPayment(taskId, agentId, amountUsd, invoiceData);\n console.log(`[${agent.name}] Payment recorded: ${amountUsd} → Wallet (payment: ${paymentId})`);\n return paymentId;\n}\n\n// ─── Full Autonomous Cycle (Market-Integrated) ───────────────────────\n\nexport async function runAutonomousCycle(): Promise<{\n marketsScanned: number;\n totalListings: number;\n tasksGenerated: number;\n tasksCompleted: number;\n tasksFailed: number;\n tasksHandedOff: number;\n totalRevenue: number;\n paymentsProcessed: 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 let paymentsProcessed = 0;\n\n // Phase 1: Scan all open global markets\n console.log(\"[Network] Phase 1: Scanning Open Global Markets\");\n const scanResult = await scanAllMarkets();\n results.push({ phase: \"market_scan\", ...scanResult });\n console.log(`[Network] Markets scanned: ${scanResult.totalListings} listings found across ${Object.keys(scanResult.perMarket).length} markets`);\n\n // Phase 2: Each agent finds and claims work from markets\n console.log(\"[Network] Phase 2: Agents Finding Work from Markets\");\n const claimPromises = AGENT_IDS.map(async (agentId) => {\n // Try to find work from market listings first\n const claimed = await agentFindAndClaimWork(agentId);\n if (claimed) {\n return { agentId, ...claimed };\n }\n // Fallback: generate a task via Pollinations market intelligence\n console.log(`[${AGENTS[agentId].name}] No market listing — falling back to Pollinations task generation`);\n const genResult = await agentGenerateTask(agentId);\n if (genResult) {\n return { agentId, taskId: genResult.taskId, listingId: \"\", title: genResult.title, priceUsd: genResult.priceUsd, market: \"pollinations_fallback\", message: genResult.message };\n }\n return null;\n });\n\n const claimedTasks = await Promise.all(claimPromises);\n const validTasks = claimedTasks.filter((t): t is NonNullable<typeof t> => t !== null);\n tasksGenerated = validTasks.length;\n\n for (const t of validTasks) {\n results.push({ agent: AGENTS[t.agentId].name, phase: \"work_claimed\", market: t.market, title: t.title, priceUsd: t.priceUsd });\n }\n\n // Phase 3: Each agent executes their claimed work\n console.log(\"[Network] Phase 3: Task Execution + Quality Checks\");\n const executionPromises = validTasks.map(async ({ agentId, taskId, listingId }) => {\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 // Handle payment — direct to wallet, no intermediary tokens\n await agentHandlePayment(agentId, taskId, execResult.revenue);\n paymentsProcessed++;\n // Complete the market listing\n if (listingId) {\n await completeListing(listingId);\n }\n } else if (execResult.handedOff) {\n tasksHandedOff++;\n } else {\n tasksFailed++;\n }\n return { agentId, taskId, listingId, execResult };\n });\n\n const executionResults = await Promise.all(executionPromises);\n\n // Phase 4: Process handoffs\n console.log(\"[Network] Phase 4: 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 await agentHandlePayment(execResult.handoffTo, taskId, handoffResult.revenue);\n paymentsProcessed++;\n } else {\n tasksFailed++;\n }\n }\n }\n\n console.log(`[Network] Cycle complete: ${tasksCompleted}/${tasksGenerated} completed, ${totalRevenue} revenue, ${paymentsProcessed} payments processed`);\n return {\n marketsScanned: Object.keys(scanResult.perMarket).length,\n totalListings: scanResult.totalListings,\n tasksGenerated,\n tasksCompleted,\n tasksFailed,\n tasksHandedOff,\n totalRevenue,\n paymentsProcessed,\n results,\n };\n}\n",[184],"pulls","branches","forks","envVars",{"_197":67,"_199":67},"connections",{"_197":67,"_198":67},"count","unfilledCount","emptyCount",{"_47":183,"_37":184,"_35":185,"_143":-5,"_45":46,"_44":186,"_145":63,"_42":226,"_13":144,"_38":147,"_40":188,"_29":30,"_149":-5,"_208":227,"_32":228},{"_47":180,"_37":33,"_35":36,"_143":-5,"_45":46,"_44":14,"_145":63,"_42":223,"_13":67,"_38":39,"_40":41,"_29":30,"_149":-5,"_208":224,"_32":225},{"_47":172,"_37":173,"_35":174,"_143":-5,"_45":46,"_44":175,"_145":63,"_42":220,"_13":177,"_38":147,"_40":178,"_29":30,"_149":-5,"_208":221,"_32":222},{"_47":166,"_37":167,"_35":168,"_143":-5,"_45":46,"_44":155,"_145":30,"_42":217,"_13":67,"_38":147,"_40":170,"_29":30,"_149":-5,"_208":218,"_32":219},{"_47":159,"_37":160,"_35":161,"_143":-5,"_45":46,"_44":162,"_145":63,"_42":214,"_13":67,"_38":147,"_40":164,"_29":30,"_149":-5,"_208":215,"_32":216},{"_47":151,"_37":152,"_35":61,"_143":-5,"_45":46,"_44":153,"_145":63,"_42":211,"_13":155,"_38":156,"_40":157,"_29":30,"_149":-5,"_208":212,"_32":213},{"_47":140,"_37":141,"_35":142,"_143":-5,"_45":46,"_44":144,"_145":63,"_42":207,"_13":67,"_38":147,"_40":148,"_29":30,"_149":-5,"_208":209,"_32":210},["D",1784054196678],"children",[],[141],["D",1784056860520],[],[152],["D",1784056800427],[],[160],["D",1784054143093],[],[167],["D",1784056815381],[],[173],["D",1784056860548],[],[33],["D",1784056834080],[],[184],["D",1784054142840],["D",1789559472742],{"_104":103,"_111":106},{"_104":103,"_105":106,"_107":106,"_19":59,"_108":109,"_110":30},{"_13":93,"_37":94,"_47":46,"_95":48,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":49,"_102":103},"ctx",{"_86":-5,"_130":267,"_268":269,"_270":271,"_272":30,"_273":30,"_274":30,"_275":63,"_276":-5,"_277":-7,"_278":-7,"_279":67,"_280":30,"_281":30,"_282":-5,"_283":30,"_284":30,"_285":30,"_286":-5},"ENV",{"_238":239,"_240":241,"_242":94,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266},"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"] </article></body></html>

Diff · v14