${a.name}

${a.role}

Tasks: ${a.tasks_completed} | Rep: ${a.reputation}

`).join(\"\");\n\n return new Response(`\n\n\n\n\nAutonomous AI Agent Economy\n\n\n\n

🤖 Autonomous AI Agent Economy

5 agents · 7 live market sources · Real data only · No simulation

\n\n

Jobs Scanned

${jobCount}

from 7 real sources

Potential Deals

${potDealCount}

arbitrage opportunities

Active Deals

${dealCount}

webhook-created only

Payments Confirmed

${paymentCount}

$${paymentTotal} verified

Total Revenue

$${revenue}

commission earned

\n\n

Agents

${agents}

\n\n

API Endpoints

GET/This dashboard

POST/network/runTrigger market scan

POST/webhook/buyerCreate deal {buyer_email, service, budget}

POST/webhook/paymentConfirm payment {deal_id, amount, tx_hash}

POST/webhook/confirmBuyer confirms {deal_id, approved}

GET/marketsReal fetched jobs

GET/potential-dealsArbitrage opportunities

GET/dealsWebhook-created deals

GET/paymentsConfirmed payments

GET/metricsReal database counts

\n\n

\n\n`, {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n}\n\n// ── Main HTTP handler ──\nexport default async function(req: Request): Promise {\n await ensureDB();\n\n const url = new URL(req.url);\n const path = url.pathname;\n const method = req.method;\n\n // ── GET / — Dashboard ──\n if (method === \"GET\" && path === \"/\") {\n return await dashboard();\n }\n\n // ── GET /metrics — Real database counts ──\n if (method === \"GET\" && path === \"/metrics\") {\n const [j, pd, d, dTotal, p, a] = await Promise.all([\n sqlite.execute(\"SELECT COUNT(*) as cnt FROM jobs\"),\n sqlite.execute(\"SELECT COUNT(*) as cnt FROM potential_deals\"),\n sqlite.execute(\"SELECT COUNT(*) as cnt, COALESCE(SUM(commission),0) as revenue FROM deals WHERE status='completed'\"),\n sqlite.execute(\"SELECT COUNT(*) as cnt FROM deals\"),\n sqlite.execute(\"SELECT COUNT(*) as cnt, COALESCE(SUM(amount),0) as total FROM payments\"),\n sqlite.execute(\"SELECT COUNT(*) as cnt FROM agents\"),\n ]);\n return json({\n jobs: j.rows[0].cnt,\n potential_deals: pd.rows[0].cnt,\n deals_total: dTotal.rows[0].cnt,\n deals_completed: d.rows[0].cnt,\n revenue: d.rows[0].revenue,\n payments: p.rows[0].cnt,\n payments_total: p.rows[0].total,\n agents: a.rows[0].cnt,\n sources: [\"RemoteOK\", \"HackerNews\", \"WeWorkRemotely\", \"Reddit/r/forhire\", \"Reddit/r/freelance\", \"GitHubBounties\", \"Dev.to\"],\n note: \"ALL counts are from real database queries. No simulation.\",\n });\n }\n\n // ── POST /network/run — Trigger market scan ──\n if (method === \"POST\" && path === \"/network/run\") {\n const results = await scanAllMarkets();\n const arbitrageFound = await findArbitrageOpportunities();\n const proposalsGenerated = await autoGenerateProposals();\n\n // Have Nexus analyze the scan results\n const scanSummary = results.map(r => `${r.source}: ${r.count} jobs`).join(\", \");\n const nexusAnalysis = await askAgent(\"nexus\", `Market scan complete. Results: ${scanSummary}. Total ${results.reduce((s, r) => s + r.count, 0)} jobs found across 7 sources. ${arbitrageFound} arbitrage opportunities identified. ${proposalsGenerated} proposals auto-generated by agents. Summarize the market opportunity in 2 sentences.`);\n\n return json({\n status: \"scan_complete\",\n sources_scanned: results.length,\n total_jobs_found: results.reduce((s, r) => s + r.count, 0),\n sources: results.map(r => ({ source: r.source, count: r.count, sample_titles: r.jobs.slice(0, 3).map(j => j.title) })),\n arbitrage_opportunities_found: arbitrageFound,\n proposals_auto_generated: proposalsGenerated,\n nexus_analysis: nexusAnalysis,\n timestamp: new Date().toISOString(),\n });\n }\n\n // ── GET /markets — Real fetched jobs ──\n if (method === \"GET\" && path === \"/markets\") {\n const jobs = await sqlite.execute({\n sql: `SELECT id, source, title, url, fetched_at FROM jobs ORDER BY id DESC LIMIT 100`,\n });\n return json({\n count: jobs.rows.length,\n note: \"These are REAL jobs fetched from live market sources. No simulation.\",\n jobs: jobs.rows,\n });\n }\n\n // ── GET /potential-deals — Arbitrage opportunities ──\n if (method === \"GET\" && path === \"/potential-deals\") {\n const deals = await sqlite.execute({\n sql: `SELECT id, buyer_listing, seller_listing, margin, found_at FROM potential_deals ORDER BY id DESC LIMIT 50`,\n });\n return json({\n count: deals.rows.length,\n note: \"Arbitrage opportunities found by Nexus during market scans. These are POTENTIAL deals — not real until a buyer webhook creates them.\",\n potential_deals: deals.rows,\n });\n }\n\n // ── GET /deals — Webhook-created deals only ──\n if (method === \"GET\" && path === \"/deals\") {\n const deals = await sqlite.execute({\n sql: `SELECT id, buyer_email, seller_wallet, amount, commission, status, created_at FROM deals ORDER BY id DESC`,\n });\n return json({\n count: deals.rows.length,\n note: \"These deals were created ONLY via POST /webhook/buyer. No auto-creation from job titles.\",\n deals: deals.rows,\n });\n }\n\n // ── GET /payments — Confirmed payments only ──\n if (method === \"GET\" && path === \"/payments\") {\n const payments = await sqlite.execute({\n sql: `SELECT p.id, p.deal_id, p.amount, p.tx_hash, p.received_at, d.buyer_email, d.status as deal_status\n FROM payments p JOIN deals d ON p.deal_id = d.id ORDER BY p.id DESC`,\n });\n return json({\n count: payments.rows.length,\n note: \"These payments were verified on BaseScan. No fake entries.\",\n payments: payments.rows,\n });\n }\n\n // ── POST /webhook/buyer — Create a real deal ──\n if (method === \"POST\" && path === \"/webhook/buyer\") {\n let body;\n try {\n body = await req.json();\n } catch {\n return json({ error: \"Invalid JSON body\" }, 400);\n }\n\n const { buyer_email, service, budget } = body;\n\n if (!buyer_email || !service || !budget) {\n return json({\n error: \"Missing required fields\",\n required: [\"buyer_email\", \"service\", \"budget\"],\n received: { buyer_email: !!buyer_email, service: !!service, budget: !!budget },\n }, 400);\n }\n\n if (typeof budget !== \"number\" || budget <= 0) {\n return json({ error: \"Budget must be a positive number\" }, 400);\n }\n\n // Calculate commission (15%)\n const commission = Math.round(budget * 0.15 * 100) / 100;\n const sellerWallet = \"0xAgentEconomy\" + Math.random().toString(16).slice(2, 10).toUpperCase();\n const now = new Date().toISOString();\n\n const result = await sqlite.execute({\n sql: `INSERT INTO deals (buyer_email, seller_wallet, amount, commission, status, created_at) VALUES (?, ?, ?, ?, 'pending', ?)`,\n args: [buyer_email, sellerWallet, budget, commission, now],\n });\n\n const dealId = result.lastInsertRowid;\n\n // Assign agent based on service type\n const serviceMap: Record = {\n logo: \"pixel\", design: \"pixel\", graphic: \"pixel\", ui: \"pixel\",\n content: \"nova\", seo: \"nova\", copywriting: \"nova\", article: \"nova\", writing: \"nova\",\n research: \"atlas\", analysis: \"atlas\", data: \"atlas\", market: \"atlas\",\n code: \"forge\", api: \"forge\", automation: \"forge\", website: \"forge\", app: \"forge\",\n };\n\n const serviceKey = Object.keys(serviceMap).find(k => service.toLowerCase().includes(k));\n const agentKey = serviceKey ? serviceMap[serviceKey] : \"nexus\";\n const agentName = AGENTS[agentKey].name;\n\n // Have the assigned agent acknowledge the deal\n const agentResponse = await askAgent(agentKey, `A new deal has been assigned to you. Client email: ${buyer_email}, Service: ${service}, Budget: $${budget}, Your commission: $${commission}. Acknowledge this deal in 1-2 sentences.`);\n\n // Increment agent tasks\n await sqlite.execute({\n sql: `UPDATE agents SET tasks_completed = tasks_completed + 1 WHERE name = ?`,\n args: [agentName],\n });\n\n return json({\n status: \"deal_created\",\n deal_id: dealId,\n buyer_email,\n service,\n budget,\n commission,\n seller_wallet: sellerWallet,\n status: \"pending\",\n assigned_agent: agentName,\n agent_acknowledgment: agentResponse,\n created_at: now,\n note: \"Deal created via webhook. Payment must be confirmed via /webhook/payment.\",\n });\n }\n\n // ── POST /webhook/payment — Verify & record payment ──\n if (method === \"POST\" && path === \"/webhook/payment\") {\n let body;\n try {\n body = await req.json();\n } catch {\n return json({ error: \"Invalid JSON body\" }, 400);\n }\n\n const { deal_id, amount, tx_hash } = body;\n\n if (!deal_id || !amount || !tx_hash) {\n return json({\n error: \"Missing required fields\",\n required: [\"deal_id\", \"amount\", \"tx_hash\"],\n }, 400);\n }\n\n // Check deal exists\n const dealRes = await sqlite.execute({\n sql: `SELECT * FROM deals WHERE id = ?`,\n args: [deal_id],\n });\n\n if (dealRes.rows.length === 0) {\n return json({ error: `Deal ${deal_id} not found` }, 404);\n }\n\n // Verify transaction on BaseScan\n const verification = await verifyTransaction(tx_hash);\n\n if (!verification.verified) {\n return json({\n status: \"payment_rejected\",\n deal_id,\n tx_hash,\n reason: verification.error || \"Transaction not confirmed on BaseScan\",\n verification,\n note: \"Payment rejected. Transaction could not be verified on-chain.\",\n }, 400);\n }\n\n // Payment verified — record it\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `INSERT INTO payments (deal_id, amount, tx_hash, received_at) VALUES (?, ?, ?, ?)`,\n args: [deal_id, amount, tx_hash, now],\n });\n\n // Update deal status to 'in_escrow' (payment received, work in progress)\n await sqlite.execute({\n sql: `UPDATE deals SET status = 'in_escrow' WHERE id = ?`,\n args: [deal_id],\n });\n\n return json({\n status: \"payment_confirmed\",\n deal_id,\n amount,\n tx_hash,\n verification: {\n from: verification.from,\n to: verification.to,\n value: verification.value,\n },\n deal_status: \"in_escrow\",\n received_at: now,\n note: \"Payment verified on BaseScan. Funds in escrow. Awaiting buyer confirmation via /webhook/confirm.\",\n });\n }\n\n // ── POST /webhook/confirm — Buyer confirms work delivery ──\n if (method === \"POST\" && path === \"/webhook/confirm\") {\n let body;\n try {\n body = await req.json();\n } catch {\n return json({ error: \"Invalid JSON body\" }, 400);\n }\n\n const { deal_id, approved } = body;\n\n if (!deal_id) {\n return json({ error: \"Missing deal_id\" }, 400);\n }\n\n const dealRes = await sqlite.execute({\n sql: `SELECT * FROM deals WHERE id = ?`,\n args: [deal_id],\n });\n\n if (dealRes.rows.length === 0) {\n return json({ error: `Deal ${deal_id} not found` }, 404);\n }\n\n const deal = dealRes.rows[0];\n\n if (deal.status !== \"in_escrow\") {\n return json({\n error: `Deal ${deal_id} status is '${deal.status}', must be 'in_escrow' to confirm`,\n }, 400);\n }\n\n if (approved === true) {\n // Mark as completed — this is when commission is \"earned\"\n await sqlite.execute({\n sql: `UPDATE deals SET status = 'completed' WHERE id = ?`,\n args: [deal_id],\n });\n\n // Increment agent reputation\n await sqlite.execute({\n sql: `UPDATE agents SET reputation = reputation + 1 WHERE name = 'Nexus'`,\n });\n\n // ── AUTO-DELIVERY: assigned agent generates the actual work product ──\n const serviceMap: Record = {\n logo: \"pixel\", design: \"pixel\", graphic: \"pixel\", ui: \"pixel\",\n content: \"nova\", seo: \"nova\", copywriting: \"nova\", article: \"nova\", writing: \"nova\",\n research: \"atlas\", analysis: \"atlas\", data: \"atlas\", market: \"atlas\",\n code: \"forge\", api: \"forge\", automation: \"forge\", website: \"forge\", app: \"forge\",\n };\n const dealService = (deal.service as string) || \"service\";\n const svcKey = Object.keys(serviceMap).find(k => dealService.toLowerCase().includes(k));\n const agentKey = svcKey ? serviceMap[svcKey] : \"nexus\";\n const agentName = AGENTS[agentKey].name;\n\n let deliverableResult: { content: string; imageUrl?: string } | null = null;\n try {\n deliverableResult = await generateDeliverable(agentKey, dealService, deal.buyer_email as string, deal.amount as number);\n const now2 = new Date().toISOString();\n await sqlite.execute({\n sql: `INSERT INTO deliverables (deal_id, agent_name, content, image_url, delivered_at) VALUES (?, ?, ?, ?, ?)`,\n args: [deal_id, agentName, deliverableResult.content, deliverableResult.imageUrl || null, now2],\n });\n await sqlite.execute({\n sql: `UPDATE agents SET tasks_completed = tasks_completed + 1 WHERE name = ?`,\n args: [agentName],\n });\n } catch (e) {\n console.error(\"Auto-delivery failed:\", e instanceof Error ? e.message : String(e));\n }\n\n return json({\n status: \"deal_completed\",\n deal_id,\n buyer_email: deal.buyer_email,\n amount: deal.amount,\n commission_earned: deal.commission,\n auto_delivered: !!deliverableResult,\n deliverable_preview: deliverableResult?.content?.slice(0, 200),\n deliverable_image: deliverableResult?.imageUrl,\n note: \"Deal completed. Commission released from escrow. Revenue recorded. Agent auto-generated deliverable.\",\n });\n } else {\n await sqlite.execute({\n sql: `UPDATE deals SET status = 'disputed' WHERE id = ?`,\n args: [deal_id],\n });\n\n return json({\n status: \"deal_disputed\",\n deal_id,\n note: \"Deal marked as disputed. Funds remain in escrow pending resolution.\",\n });\n }\n }\n\n // ── GET /services — Service catalog with tiered pricing ──\n if (method === \"GET\" && path === \"/services\") {\n const services = await sqlite.execute({\n sql: `SELECT id, agent_name, service_name, description, price_basic, price_pro, price_premium, category FROM services ORDER BY category, price_basic`,\n });\n return json({\n count: services.rows.length,\n note: \"Pre-priced service packages. Use POST /checkout to instantly purchase with tier selection.\",\n services: services.rows,\n });\n }\n\n // ── GET /proposals — Auto-generated proposals for market jobs ──\n if (method === \"GET\" && path === \"/proposals\") {\n const proposals = await sqlite.execute({\n sql: `SELECT id, job_title, job_url, job_source, agent_name, service_type, proposed_price, proposal_text, status, created_at FROM proposals ORDER BY id DESC LIMIT 50`,\n });\n return json({\n count: proposals.rows.length,\n note: \"Proposals auto-generated by AI agents for real market jobs. These are outreach proposals, not deals.\",\n proposals: proposals.rows,\n });\n }\n\n // ── GET /deliverables — Auto-generated work products ──\n if (method === \"GET\" && path === \"/deliverables\") {\n const deliverables = await sqlite.execute({\n sql: `SELECT d.id, d.deal_id, d.agent_name, SUBSTR(d.content, 1, 500) as content_preview, d.image_url, d.delivered_at, dl.buyer_email, dl.amount\n FROM deliverables d JOIN deals dl ON d.deal_id = dl.id ORDER BY d.id DESC`,\n });\n return json({\n count: deliverables.rows.length,\n note: \"Work products auto-generated by agents when deals are completed.\",\n deliverables: deliverables.rows,\n });\n }\n\n // ── POST /checkout — Instant deal creation from service catalog ──\n if (method === \"POST\" && path === \"/checkout\") {\n let body;\n try { body = await req.json(); } catch { return json({ error: \"Invalid JSON body\" }, 400); }\n\n const { buyer_email, service_id, tier, referral_code } = body;\n\n if (!buyer_email || !service_id || !tier) {\n return json({ error: \"Missing required fields: buyer_email, service_id, tier (basic|pro|premium)\" }, 400);\n }\n\n const svcRes = await sqlite.execute({\n sql: `SELECT * FROM services WHERE id = ?`,\n args: [service_id],\n });\n if (svcRes.rows.length === 0) {\n return json({ error: `Service ${service_id} not found` }, 404);\n }\n\n const svc = svcRes.rows[0];\n const tierPrices: Record = { basic: svc.price_basic, pro: svc.price_pro, premium: svc.price_premium };\n const budget = tierPrices[tier];\n if (!budget) {\n return json({ error: `Invalid tier: ${tier}. Use: basic, pro, or premium` }, 400);\n }\n\n const commission = Math.round(budget * 0.15 * 100) / 100;\n const referralBonus = referral_code ? Math.round(budget * 0.05 * 100) / 100 : 0;\n const sellerWallet = \"0xAgentEconomy\" + Math.random().toString(16).slice(2, 10).toUpperCase();\n const now = new Date().toISOString();\n\n const result = await sqlite.execute({\n sql: `INSERT INTO deals (buyer_email, seller_wallet, amount, commission, status, service, referral_code, created_at) VALUES (?, ?, ?, ?, 'pending', ?, ?, ?)`,\n args: [buyer_email, sellerWallet, budget, commission, `${svc.service_name} (${tier})`, referral_code || null, now],\n });\n\n const dealId = result.lastInsertRowid;\n\n // Handle referral bonus\n if (referral_code) {\n const refRes = await sqlite.execute({\n sql: `SELECT * FROM referrals WHERE code = ?`,\n args: [referral_code],\n });\n if (refRes.rows.length > 0) {\n await sqlite.execute({\n sql: `UPDATE referrals SET total_earned = total_earned + ?, deals_count = deals_count + 1 WHERE code = ?`,\n args: [referralBonus, referral_code],\n });\n }\n }\n\n const agentResponse = await askAgent(\"nexus\", `Instant checkout: ${buyer_email} purchased ${svc.service_name} (${tier} tier) for ${budget}. Commission: ${commission}. Referral bonus: ${referralBonus}. Confirm in 1 sentence.`);\n\n return json({\n status: \"deal_created\",\n deal_id: dealId,\n buyer_email,\n service: `${svc.service_name} (${tier})`,\n agent: svc.agent_name,\n budget,\n commission,\n referral_bonus: referralBonus,\n seller_wallet: sellerWallet,\n status: \"pending\",\n next_step: \"POST /webhook/payment with deal_id, amount, and tx_hash to confirm payment\",\n agent_acknowledgment: agentResponse,\n created_at: now,\n });\n }\n\n // ── POST /referral — Create referral code for affiliate earnings ──\n if (method === \"POST\" && path === \"/referral\") {\n let body;\n try { body = await req.json(); } catch { return json({ error: \"Invalid JSON body\" }, 400); }\n\n const { referrer_email } = body;\n if (!referrer_email) {\n return json({ error: \"Missing referrer_email\" }, 400);\n }\n\n const code = \"REF\" + Math.random().toString(36).slice(2, 8).toUpperCase();\n const now = new Date().toISOString();\n\n await sqlite.execute({\n sql: `INSERT INTO referrals (code, referrer_email, created_at) VALUES (?, ?, ?)`,\n args: [code, referrer_email, now],\n });\n\n return json({\n status: \"referral_created\",\n referral_code: code,\n referrer_email,\n commission_rate: \"5% of each deal made with this code\",\n created_at: now,\n note: \"Share this code. You earn 5% commission on every deal that uses it at checkout.\",\n });\n }\n\n // ── GET /referrals — Show referral earnings ──\n if (method === \"GET\" && path === \"/referrals\") {\n const refs = await sqlite.execute({\n sql: `SELECT * FROM referrals ORDER BY total_earned DESC`,\n });\n return json({\n count: refs.rows.length,\n note: \"Real referral earnings. 5% commission on each deal.\",\n referrals: refs.rows,\n });\n }\n\n // ── 404 ──\n return json({\n error: \"Not found\",\n path,\n method,\n available_endpoints: [\n \"GET /\",\n \"POST /network/run\",\n \"POST /webhook/buyer\",\n \"POST /webhook/payment\",\n \"POST /webhook/confirm\",\n \"POST /checkout\",\n \"POST /referral\",\n \"GET /services\",\n \"GET /markets\",\n \"GET /potential-deals\",\n \"GET /proposals\",\n \"GET /deals\",\n \"GET /payments\",\n \"GET /deliverables\",\n \"GET /referrals\",\n \"GET /metrics\",\n ],\n }, 404);\n}\n","children",[],[191],"c3c90cfd-8661-419e-9db7-7b63556a1b43","pollinations.ts","79e9dfb8-7fc8-11f1-982e-1607ee4eb77e","26fe2ab4-8b64-43dc-9530-d4872970c863",12,["D",1784064236812],"// Pollinations.AI integration — free, no API key required\n// Text: https://text.pollinations.ai/{prompt}\n// Image: https://image.pollinations.ai/prompt/{prompt}\n\nexport const AGENTS = {\n nova: { name: \"Nova\", role: \"Content Strategist\", system: \"You are Nova, a content strategist expert in SEO, copywriting, and content marketing. Respond concisely.\" },\n atlas: { name: \"Atlas\", role: \"Research Analyst\", system: \"You are Atlas, a research analyst expert in market research and data analysis. Respond concisely.\" },\n pixel: { name: \"Pixel\", role: \"Visual Designer\", system: \"You are Pixel, a visual designer expert in logos, graphics, and UI design. Respond concisely.\" },\n forge: { name: \"Forge\", role: \"Code Engineer\", system: \"You are Forge, a code engineer expert in coding, APIs, and automation. Respond concisely.\" },\n nexus: { name: \"Nexus\", role: \"Deal Broker\", system: \"You are Nexus, a deal broker expert in arbitrage, commission, and escrow. Respond concisely.\" },\n} as const;\n\nexport type AgentKey = keyof typeof AGENTS;\n\nexport async function askAgent(agent: AgentKey, prompt: string): Promise {\n const config = AGENTS[agent];\n const fullPrompt = `${config.system}\\n\\nUser: ${prompt}`;\n const url = `https://text.pollinations.ai/${encodeURIComponent(fullPrompt)}`;\n const res = await fetch(url);\n if (!res.ok) {\n return `[${config.name} offline: ${res.status}]`;\n }\n const text = await res.text();\n return text.trim();\n}\n\nexport function getImageUrl(prompt: string): string {\n return `https://image.pollinations.ai/prompt/${encodeURIComponent(prompt)}`;\n}\n\n// ── Auto-deliverable generation ──\n// When a deal is paid, the assigned agent generates the actual work product\nexport async function generateDeliverable(\n agent: AgentKey,\n service: string,\n buyerEmail: string,\n budget: number,\n): Promise<{ content: string; imageUrl?: string }> {\n const config = AGENTS[agent];\n\n if (agent === \"pixel\") {\n // For design tasks, generate an image via Pollinations image API\n const imagePrompt = `professional ${service}, high quality, modern design, clean aesthetic`;\n const imageUrl = getImageUrl(imagePrompt);\n const textResponse = await askAgent(agent, `You just completed a ${service} for ${buyerEmail} with budget $${budget}. Describe the design you created in 2-3 sentences. Include the image URL: ${imageUrl}`);\n return { content: textResponse, imageUrl };\n }\n\n // For text-based services, generate the actual deliverable\n const deliverablePrompt = `You have been paid $${budget} for a ${service} for client ${buyerEmail}. \nNow DELIVER the actual work product. This is the real deliverable the client is paying for.\nIf it's an article, write the full article. If it's code, write the code. If it's research, write the report.\nMake it professional and complete. The client expects real, usable work.`;\n\n const content = await askAgent(agent, deliverablePrompt);\n return { content };\n}\n\n// ── Auto-proposal generation for market jobs ──\nexport async function generateProposal(\n agent: AgentKey,\n jobTitle: string,\n jobSource: string,\n): Promise<{ text: string; proposedPrice: number; serviceType: string }> {\n const config = AGENTS[agent];\n const prompt = `You found this job listing: \"${jobTitle}\" from ${jobSource}.\nAs ${config.name} (${config.role}), write a short professional proposal (3-4 sentences) explaining how you can help.\nAlso suggest a fair price in USD (just the number, no $ sign) and identify the service type in one word.\nFormat: PRICE: | SERVICE: | PROPOSAL: `;\n\n const response = await askAgent(agent, prompt);\n\n // Parse response\n const priceMatch = response.match(/PRICE:\\s*(\\d+)/i);\n const serviceMatch = response.match(/SERVICE:\\s*(\\w+)/i);\n const proposalMatch = response.match(/PROPOSAL:\\s*(.*)/is);\n\n const proposedPrice = priceMatch ? parseInt(priceMatch[1]) : 99;\n const serviceType = serviceMatch ? serviceMatch[1].toLowerCase() : \"service\";\n const text = proposalMatch ? proposalMatch[1].trim() : response;\n\n return { text, proposedPrice, serviceType };\n}\n",[],[208,200],"lib","d7cb2cfb-b800-4687-84ca-9d0a58f4e19e","paymentVerifier.ts","773e7db4-7fc8-11f1-9a5b-1607ee4eb77e",4,["D",1784063439587],"// Payment verification via BaseScan API (free, no key)\n// https://api.basescan.org/api?module=proxy&action=eth_getTransactionByHash&txhash={tx_hash}\n\nexport interface PaymentVerifyResult {\n verified: boolean;\n txHash: string;\n value?: string; // in wei\n from?: string;\n to?: string;\n error?: string;\n}\n\nexport async function verifyTransaction(txHash: string): Promise {\n if (!txHash || !txHash.startsWith(\"0x\") || txHash.length < 10) {\n return {\n verified: false,\n txHash,\n error: \"Invalid tx_hash format — must start with 0x\",\n };\n }\n\n try {\n const url = `https://api.basescan.org/api?module=proxy&action=eth_getTransactionByHash&txhash=${txHash}`;\n const res = await fetch(url, {\n headers: { \"User-Agent\": \"AgentEconomy/1.0\" },\n });\n\n if (!res.ok) {\n return {\n verified: false,\n txHash,\n error: `BaseScan API returned ${res.status}`,\n };\n }\n\n const data = await res.json();\n\n // If result is null/empty, transaction doesn't exist\n if (!data.result || data.result === null || (typeof data.result === \"string\" && data.result === \"\")) {\n return {\n verified: false,\n txHash,\n error: \"Transaction not found on BaseScan\",\n };\n }\n\n const tx = data.result;\n // Check if transaction has a block number (confirmed)\n const hasBlockNumber = tx.blockNumber && tx.blockNumber !== null && tx.blockNumber !== \"0x0\";\n\n return {\n verified: hasBlockNumber,\n txHash,\n value: tx.value,\n from: tx.from,\n to: tx.to,\n error: hasBlockNumber ? undefined : \"Transaction not yet confirmed (no block number)\",\n };\n } catch (e) {\n return {\n verified: false,\n txHash,\n error: `Verification failed: ${e.message}`,\n };\n }\n}\n",[],[208,210],"6836b44d-93de-408d-ba41-dff328306416","marketScanner.ts","72046674-7fc8-11f1-802c-1607ee4eb77e",14,["D",1784064263985],2,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { generateProposal, AGENTS, type AgentKey } from \"./pollinations.ts\";\n\nexport interface JobListing {\n source: string;\n title: string;\n url: string;\n}\n\n// ── Error message helper ──\nfunction errMsg(e: unknown): string {\n return e instanceof Error ? e.message : String(e);\n}\n\n// ── RSS parser (simple regex-based, no dependencies) ──\nfunction parseRSS(xml: string): JobListing[] {\n const jobs: JobListing[] = [];\n const items = xml.split(\"/) || item.match(/(.*?)<\\/title>/);\n const linkMatch = item.match(/<link>(.*?)<\\/link>/) || item.match(/<link[^>]*>(.*?)<\\/link>/);\n if (titleMatch && linkMatch) {\n jobs.push({\n source: \"\",\n title: titleMatch[1].trim(),\n url: linkMatch[1].trim(),\n });\n }\n }\n return jobs;\n}\n\n// ── Service matching: map job keywords to agent ──\nfunction matchAgentForJob(title: string): AgentKey | null {\n const t = title.toLowerCase();\n if (t.match(/content|seo|copy|article|blog|writing|writer/)) return \"nova\";\n if (t.match(/research|analyst|analysis|data|market/)) return \"atlas\";\n if (t.match(/design|logo|graphic|ui|ux|brand|visual/)) return \"pixel\";\n if (t.match(/code|developer|engineer|api|automation|website|app|backend|frontend|fullstack|python|react|node|rust|java/)) return \"forge\";\n if (t.match(/broker|deal|arbitrage|escrow|negotiate/)) return \"nexus\";\n return null;\n}\n\n// ── Individual market fetchers ──\n\nexport async function fetchRemoteOK(): Promise<JobListing[]> {\n try {\n const res = await fetch(\"https://remoteok.com/api\", {\n headers: { \"User-Agent\": \"AgentEconomy/1.0\" },\n });\n if (!res.ok) return [];\n const data = await res.json();\n if (!Array.isArray(data)) return [];\n return data.slice(1).slice(0, 20).map((job: any) => ({\n source: \"RemoteOK\",\n title: job.position || job.title || \"Untitled\",\n url: job.url ? (job.url.startsWith(\"http\") ? job.url : `https://remoteok.com${job.url}`) : (job.apply_url || \"\"),\n })).filter((j: JobListing) => j.title && j.url);\n } catch (e) {\n console.error(\"RemoteOK error:\", errMsg(e));\n return [];\n }\n}\n\nexport async function fetchHackerNewsJobs(): Promise<JobListing[]> {\n try {\n const res = await fetch(\"https://hnrss.org/jobs?q=remote\", {\n headers: { \"User-Agent\": \"AgentEconomy/1.0\" },\n });\n if (!res.ok) return [];\n const xml = await res.text();\n const jobs = parseRSS(xml);\n return jobs.slice(0, 20).map(j => ({ ...j, source: \"HackerNews\" }));\n } catch (e) {\n console.error(\"HN Jobs error:\", errMsg(e));\n return [];\n }\n}\n\nexport async function fetchWeWorkRemotely(): Promise<JobListing[]> {\n try {\n const res = await fetch(\"https://weworkremotely.com/remote-jobs.rss\", {\n headers: { \"User-Agent\": \"AgentEconomy/1.0\" },\n });\n if (!res.ok) return [];\n const xml = await res.text();\n const jobs = parseRSS(xml);\n return jobs.slice(0, 20).map(j => ({ ...j, source: \"WeWorkRemotely\" }));\n } catch (e) {\n console.error(\"WWR error:\", errMsg(e));\n return [];\n }\n}\n\nexport async function fetchRedditForhire(): Promise<JobListing[]> {\n try {\n const res = await fetch(\"https://www.reddit.com/r/forhire/search.json?restrict_sr=1&limit=25&sort=new\", {\n headers: { \"User-Agent\": \"AgentEconomy/1.0\" },\n });\n if (!res.ok) return [];\n const data = await res.json();\n const posts = data?.data?.children || [];\n return posts.slice(0, 20).map((post: any) => ({\n source: \"Reddit/r/forhire\",\n title: post.data.title || \"Untitled\",\n url: `https://www.reddit.com${post.data.permalink}`,\n })).filter((j: JobListing) => j.title && j.url);\n } catch (e) {\n console.error(\"Reddit forhire error:\", errMsg(e));\n return [];\n }\n}\n\nexport async function fetchRedditFreelance(): Promise<JobListing[]> {\n try {\n const res = await fetch(\"https://www.reddit.com/r/freelance/search.json?restrict_sr=1&limit=25&sort=new\", {\n headers: { \"User-Agent\": \"AgentEconomy/1.0\" },\n });\n if (!res.ok) return [];\n const data = await res.json();\n const posts = data?.data?.children || [];\n return posts.slice(0, 20).map((post: any) => ({\n source: \"Reddit/r/freelance\",\n title: post.data.title || \"Untitled\",\n url: `https://www.reddit.com${post.data.permalink}`,\n })).filter((j: JobListing) => j.title && j.url);\n } catch (e) {\n console.error(\"Reddit freelance error:\", errMsg(e));\n return [];\n }\n}\n\nexport async function fetchGitHubBounties(): Promise<JobListing[]> {\n try {\n const res = await fetch(\"https://api.github.com/search/issues?q=label:bounty+is:open&per_page=20\", {\n headers: { \"User-Agent\": \"AgentEconomy/1.0\", \"Accept\": \"application/vnd.github.v3+json\" },\n });\n if (!res.ok) return [];\n const data = await res.json();\n const items = data?.items || [];\n return items.slice(0, 20).map((item: any) => ({\n source: \"GitHubBounties\",\n title: item.title || \"Untitled\",\n url: item.html_url || \"\",\n })).filter((j: JobListing) => j.title && j.url);\n } catch (e) {\n console.error(\"GitHub Bounties error:\", errMsg(e));\n return [];\n }\n}\n\nexport async function fetchDevToHire(): Promise<JobListing[]> {\n try {\n const res = await fetch(\"https://dev.to/api/articles?tag=hire&per_page=20\", {\n headers: { \"User-Agent\": \"AgentEconomy/1.0\" },\n });\n if (!res.ok) return [];\n const data = await res.json();\n if (!Array.isArray(data)) return [];\n return data.slice(0, 20).map((article: any) => ({\n source: \"Dev.to\",\n title: article.title || \"Untitled\",\n url: article.url || \"\",\n })).filter((j: JobListing) => j.title && j.url);\n } catch (e) {\n console.error(\"Dev.to error:\", errMsg(e));\n return [];\n }\n}\n\n// ── Scan all markets and store to DB ──\nexport async function scanAllMarkets(): Promise<{ source: string; count: number; jobs: JobListing[] }[]> {\n const results: { source: string; count: number; jobs: JobListing[] }[] = [];\n\n const sources: { name: string; fn: () => Promise<JobListing[]> }[] = [\n { name: \"RemoteOK\", fn: fetchRemoteOK },\n { name: \"HackerNews\", fn: fetchHackerNewsJobs },\n { name: \"WeWorkRemotely\", fn: fetchWeWorkRemotely },\n { name: \"Reddit/r/forhire\", fn: fetchRedditForhire },\n { name: \"Reddit/r/freelance\", fn: fetchRedditFreelance },\n { name: \"GitHubBounties\", fn: fetchGitHubBounties },\n { name: \"Dev.to\", fn: fetchDevToHire },\n ];\n\n const now = new Date().toISOString();\n\n for (const source of sources) {\n const jobs = await source.fn();\n results.push({ source: source.name, count: jobs.length, jobs });\n\n for (const job of jobs) {\n await sqlite.execute({\n sql: `INSERT INTO jobs (source, title, url, fetched_at) VALUES (?, ?, ?, ?)`,\n args: [job.source, job.title, job.url, now],\n });\n }\n }\n\n return results;\n}\n\n// ── Nexus: Find arbitrage opportunities in market data ──\nexport async function findArbitrageOpportunities(): Promise<number> {\n const recentJobs = await sqlite.execute({\n sql: `SELECT DISTINCT title, url, source FROM jobs ORDER BY id DESC LIMIT 50`,\n });\n\n let found = 0;\n const now = new Date().toISOString();\n\n for (const job of recentJobs.rows) {\n const title = (job.title as string)?.toLowerCase() || \"\";\n\n const hasBudget = title.match(/\\$[\\d,]+/);\n const hasService = title.match(/logo|design|website|code|api|content|seo|copy|article|app/);\n\n if (hasBudget && hasService) {\n const budgetMatch = title.match(/\\$[\\d,]+/);\n const budgetStr = budgetMatch ? budgetMatch[0].replace(/[$,]/g, \"\") : \"0\";\n const budget = parseInt(budgetStr) || 0;\n\n if (budget > 50) {\n const commission = Math.round(budget * 0.15 * 100) / 100;\n await sqlite.execute({\n sql: `INSERT INTO potential_deals (buyer_listing, seller_listing, margin, found_at) VALUES (?, ?, ?, ?)`,\n args: [\n `${job.title} | ${job.url}`,\n `Agent Economy service for ${hasService[0]} — cost: $${Math.round(budget * 0.85)}`,\n commission,\n now,\n ],\n });\n found++;\n }\n }\n }\n\n return found;\n}\n\n// ── Auto-generate proposals for matching jobs ──\n// This is the money-making engine: agents see real jobs and auto-bid on them\nexport async function autoGenerateProposals(): Promise<number> {\n // Get recent jobs that don't have proposals yet\n const recentJobs = await sqlite.execute({\n sql: `SELECT DISTINCT j.title, j.url, j.source FROM jobs j\n WHERE j.id NOT IN (SELECT rowid FROM jobs WHERE title IN (SELECT job_title FROM proposals))\n ORDER BY j.id DESC LIMIT 10`,\n });\n\n let proposalsGenerated = 0;\n const now = new Date().toISOString();\n\n for (const job of recentJobs.rows) {\n const title = job.title as string;\n const url = job.url as string;\n const source = job.source as string;\n\n const agentKey = matchAgentForJob(title);\n if (!agentKey) continue;\n\n // Check if proposal already exists for this job\n const existing = await sqlite.execute({\n sql: `SELECT id FROM proposals WHERE job_url = ? AND agent_name = ?`,\n args: [url, AGENTS[agentKey].name],\n });\n if (existing.rows.length > 0) continue;\n\n try {\n const { text, proposedPrice, serviceType } = await generateProposal(agentKey, title, source);\n\n await sqlite.execute({\n sql: `INSERT INTO proposals (job_title, job_url, job_source, agent_name, service_type, proposed_price, proposal_text, status, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, 'pending', ?)`,\n args: [title, url, source, AGENTS[agentKey].name, serviceType, proposedPrice, text, now],\n });\n proposalsGenerated++;\n\n // Increment agent tasks\n await sqlite.execute({\n sql: `UPDATE agents SET tasks_completed = tasks_completed + 1 WHERE name = ?`,\n args: [AGENTS[agentKey].name],\n });\n } catch (e) {\n console.error(`Proposal generation failed for \"${title}\":`, errMsg(e));\n }\n }\n\n return proposalsGenerated;\n}\n",[],[208,218],"4528d930-d59c-4965-abc1-aed4b6e4f2d5",["D",1784063430810],[186,187,188],[208],["D",1784064236813],[],[18,66],["D",1784063430814],[184],[18],"5ff23d7e-8b53-456e-8114-b627ef74de15","autoscan.ts","62a81e4e-7fca-11f1-a7cb-1607ee4eb77e","473736f8-a1cd-4530-b8e0-6da8d3ed42ac",15,["D",1784064263988],"interval","import { initSchema } from \"../db/schema.ts\";\nimport { scanAllMarkets, findArbitrageOpportunities, autoGenerateProposals } from \"../lib/marketScanner.ts\";\nimport { askAgent } from \"../lib/pollinations.ts\";\n\n// Scheduled auto-scan: runs every hour to find new market opportunities\n// and auto-generate proposals for matching jobs\nexport default async function() {\n console.log(\"⏰ Auto-scan triggered:\", new Date().toISOString());\n\n await initSchema();\n\n // 1. Scan all 7 market sources for real jobs\n const results = await scanAllMarkets();\n const totalJobs = results.reduce((s, r) => s + r.count, 0);\n console.log(`📊 Scanned ${results.length} sources, found ${totalJobs} jobs`);\n\n // 2. Find arbitrage opportunities\n const arbitrageFound = await findArbitrageOpportunities();\n console.log(`💰 Found ${arbitrageFound} arbitrage opportunities`);\n\n // 3. Auto-generate proposals for matching jobs\n const proposalsGenerated = await autoGenerateProposals();\n console.log(`📝 Auto-generated ${proposalsGenerated} proposals`);\n\n // 4. Have Nexus summarize the scan\n if (totalJobs > 0) {\n const summary = await askAgent(\"nexus\",\n `Hourly market scan: ${totalJobs} jobs found, ${arbitrageFound} arbitrage opportunities, ${proposalsGenerated} proposals auto-generated. Summarize in 1 sentence for the activity log.`\n );\n console.log(`🤖 Nexus: ${summary}`);\n }\n\n console.log(\"✅ Auto-scan complete\");\n}\n",[],[246,237],"cron","476be959-8769-40bb-b414-5049344e46cf",["D",1784064263988],[182],[246],["D",1784062896908],["D",1789474235934],{"_11":12,"_136":72},{"_11":12,"_132":72,"_71":72,"_31":70,"_133":134,"_135":30},{"_40":123,"_13":16,"_34":37,"_124":85,"_125":-5,"_126":-5,"_127":-5,"_128":-5,"_129":-5,"_130":14,"_131":12},"ctx",{"_54":-5,"_155":289,"_290":291,"_292":293,"_294":30,"_295":30,"_296":30,"_297":24,"_298":-5,"_299":-7,"_300":-7,"_301":26,"_302":30,"_303":30,"_304":-5,"_305":30,"_306":30,"_307":30,"_308":-5},"ENV",{"_260":261,"_262":263,"_264":16,"_265":266,"_267":268,"_269":270,"_271":272,"_273":274,"_275":276,"_277":278,"_279":280,"_281":282,"_283":284,"_285":286,"_287":288},"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>

History · db