(?:<!\\[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",[148],"c4e120e3-dc3a-4b2e-9ca8-8b6f40dfed89","main.ts","d22ba866-7fb2-11f1-9428-1607ee4eb77e",["D",1784056953637],"// Autonomous Agent Network — Entry point\n// 4 agents: Nova (content), Atlas (research), Pixel (visual), Forge (code)\n// Connected to 4 open global markets (no API tokens required):\n// - RemoteOK (JSON API)\n// - Hacker News Jobs (RSS)\n// - We Work Remotely (RSS)\n// - Pollinations Market Intelligence (AI-generated real market tasks)\n//\n// Flow: Scan markets → Agents find & claim work → Execute via Pollinations.AI →\n// Quality check → Handle payments (direct to wallet, no intermediary tokens)\n//\n// Revenue → 0x25b984f7a01f5bd5212a8afae044658d1c27113f\n//\n// Endpoints:\n// GET / → Network dashboard\n// GET /markets → List all connected open markets\n// POST /markets/scan → Scan all markets now\n// GET /markets/listings → Browse market listings\n// POST /agents/:id/scan → Agent scans markets for work\n// POST /agents/:id/find-work→ Agent finds & claims work\n// POST /network/run → Full autonomous cycle\n// GET /payments → Payment records\n// GET /revenue → Revenue stats\n//\n// Scheduled: autonomous-cycle.ts runs every 15 minutes automatically.\n",[155],"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",[161],"be65ccee-9b48-4e9d-be61-bb497f3c65ed","autonomous-cycle.ts","25e46776-7fb9-11f1-a4d3-1607ee4eb77e",14,["D",1784056860548],"interval","// 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",[169],"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",[177],"pulls","forks","envVars",{"_189":54,"_191":54},"connections",{"_189":54,"_190":54},"count","unfilledCount","emptyCount",{"_20":176,"_13":177,"_124":178,"_126":-5,"_127":21,"_128":179,"_130":50,"_22":218,"_29":129,"_132":133,"_134":181,"_136":38,"_137":-5,"_200":219,"_93":220},{"_20":168,"_13":169,"_124":170,"_126":-5,"_127":21,"_128":171,"_130":50,"_22":215,"_29":54,"_132":173,"_134":174,"_136":38,"_137":-5,"_200":216,"_93":217},{"_20":160,"_13":161,"_124":162,"_126":-5,"_127":21,"_128":163,"_130":50,"_22":212,"_29":165,"_132":133,"_134":166,"_136":38,"_137":-5,"_200":213,"_93":214},{"_20":154,"_13":155,"_124":156,"_126":-5,"_127":21,"_128":30,"_130":50,"_22":209,"_29":143,"_132":133,"_134":158,"_136":38,"_137":-5,"_200":210,"_93":211},{"_20":147,"_13":148,"_124":149,"_126":-5,"_127":21,"_128":150,"_130":50,"_22":206,"_29":54,"_132":133,"_134":152,"_136":38,"_137":-5,"_200":207,"_93":208},{"_20":139,"_13":140,"_124":48,"_126":-5,"_127":21,"_128":141,"_130":50,"_22":203,"_29":143,"_132":144,"_134":145,"_136":38,"_137":-5,"_200":204,"_93":205},{"_20":122,"_13":123,"_124":125,"_126":-5,"_127":21,"_128":129,"_130":50,"_22":199,"_29":54,"_132":133,"_134":135,"_136":38,"_137":-5,"_200":201,"_93":202},["D",1784054196678],"children",[],[123],["D",1784056860520],[],[140],["D",1784056800427],[],[148],["D",1784056953637],[],[155],["D",1784056815381],[],[161],["D",1784056860548],[],[169],["D",1784056834080],[],[177],["D",1784054142840],["D",1789472446807],{"_11":12,"_91":86},{"_11":12,"_85":86,"_87":86,"_45":46,"_88":89,"_90":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_80":-5,"_81":-5,"_82":-5,"_83":14,"_84":12},"ctx",{"_73":-5,"_112":259,"_260":261,"_262":263,"_264":38,"_265":38,"_266":38,"_267":50,"_268":-5,"_269":-7,"_270":-7,"_271":54,"_272":38,"_273":38,"_274":-5,"_275":38,"_276":38,"_277":38,"_278":-5},"ENV",{"_230":231,"_232":233,"_234":26,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","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>

Branches1

Branches
1