🤖 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",[],[85],["D",1784063430810],[98,99,100],[19],{"_36":68,"_13":69,"_39":70,"_41":42,"_43":44,"_45":71,"_47":48,"_49":107,"_17":73,"_52":53,"_54":74,"_56":57,"_58":-5,"_92":108,"_18":109},{"_36":60,"_13":61,"_39":62,"_41":42,"_43":44,"_45":63,"_47":48,"_49":104,"_17":65,"_52":53,"_54":66,"_56":57,"_58":-5,"_92":105,"_18":106},{"_36":37,"_13":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":101,"_17":51,"_52":53,"_54":55,"_56":57,"_58":-5,"_92":102,"_18":103},["D",1784064236812],[],[19,38],["D",1784063439587],[],[19,61],["D",1784064263985],[],[19,69],"9f090f1c-1772-44fb-a6f4-4828525a5037","db","9a4475b0-0e81-404d-b047-b22a85207cc2",3,["D",1784063430814],[117],[111],{"_36":118,"_13":119,"_39":120,"_41":112,"_43":44,"_45":121,"_47":48,"_49":122,"_17":51,"_52":53,"_54":123,"_56":57,"_58":-5,"_92":124,"_18":125},"1ff56079-72e3-4aa2-b807-68bc844df248","schema.ts","722b077a-7fc8-11f1-9a5b-1607ee4eb77e",13,["D",1784064236813],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport async function initSchema() {\n await sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS jobs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n source TEXT NOT NULL,\n title TEXT NOT NULL,\n url TEXT NOT NULL,\n fetched_at TEXT NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS potential_deals (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n buyer_listing TEXT NOT NULL,\n seller_listing TEXT NOT NULL,\n margin REAL NOT NULL,\n found_at TEXT NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS deals (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n buyer_email TEXT NOT NULL,\n seller_wallet TEXT NOT NULL,\n amount REAL NOT NULL,\n commission REAL NOT NULL,\n status TEXT NOT NULL DEFAULT 'pending',\n service TEXT,\n referral_code TEXT,\n created_at TEXT NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS payments (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n deal_id INTEGER NOT NULL,\n amount REAL NOT NULL,\n tx_hash TEXT NOT NULL,\n received_at TEXT NOT NULL,\n FOREIGN KEY (deal_id) REFERENCES deals(id)\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS agents (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n role TEXT NOT NULL,\n tasks_completed INTEGER NOT NULL DEFAULT 0,\n reputation REAL NOT NULL DEFAULT 0\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS proposals (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n job_title TEXT NOT NULL,\n job_url TEXT NOT NULL,\n job_source TEXT NOT NULL,\n agent_name TEXT NOT NULL,\n service_type TEXT NOT NULL,\n proposed_price REAL NOT NULL,\n proposal_text TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'pending',\n created_at TEXT NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS deliverables (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n deal_id INTEGER NOT NULL,\n agent_name TEXT NOT NULL,\n content TEXT NOT NULL,\n image_url TEXT,\n delivered_at TEXT NOT NULL,\n FOREIGN KEY (deal_id) REFERENCES deals(id)\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS services (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n agent_name TEXT NOT NULL,\n service_name TEXT NOT NULL,\n description TEXT NOT NULL,\n price_basic REAL NOT NULL,\n price_pro REAL NOT NULL,\n price_premium REAL NOT NULL,\n category TEXT NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS referrals (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n code TEXT NOT NULL UNIQUE,\n referrer_email TEXT NOT NULL,\n total_earned REAL NOT NULL DEFAULT 0,\n deals_count INTEGER NOT NULL DEFAULT 0,\n created_at TEXT NOT NULL\n )`,\n },\n ]);\n\n // Seed agents if not present\n const existing = await sqlite.execute(\"SELECT COUNT(*) as cnt FROM agents\");\n if (existing.rows[0].cnt === 0) {\n await sqlite.batch([\n { sql: `INSERT INTO agents (name, role) VALUES ('Nova', 'Content Strategist')` },\n { sql: `INSERT INTO agents (name, role) VALUES ('Atlas', 'Research Analyst')` },\n { sql: `INSERT INTO agents (name, role) VALUES ('Pixel', 'Visual Designer')` },\n { sql: `INSERT INTO agents (name, role) VALUES ('Forge', 'Code Engineer')` },\n { sql: `INSERT INTO agents (name, role) VALUES ('Nexus', 'Deal Broker')` },\n ]);\n }\n\n // Seed services catalog if not present\n const svcExisting = await sqlite.execute(\"SELECT COUNT(*) as cnt FROM services\");\n if (svcExisting.rows[0].cnt === 0) {\n await sqlite.batch([\n { sql: `INSERT INTO services (agent_name, service_name, description, price_basic, price_pro, price_premium, category) VALUES ('Nova', 'SEO Article', '1000-word SEO-optimized article with keyword research', 49, 99, 199, 'Content')` },\n { sql: `INSERT INTO services (agent_name, service_name, description, price_basic, price_pro, price_premium, category) VALUES ('Nova', 'Landing Page Copy', 'High-conversion landing page copywriting', 79, 149, 299, 'Content')` },\n { sql: `INSERT INTO services (agent_name, service_name, description, price_basic, price_pro, price_premium, category) VALUES ('Nova', 'Blog Post', 'Engaging blog post up to 1500 words', 39, 79, 159, 'Content')` },\n { sql: `INSERT INTO services (agent_name, service_name, description, price_basic, price_pro, price_premium, category) VALUES ('Atlas', 'Market Research Report', 'Data-driven market analysis with sources', 99, 199, 399, 'Research')` },\n { sql: `INSERT INTO services (agent_name, service_name, description, price_basic, price_pro, price_premium, category) VALUES ('Atlas', 'Competitor Analysis', 'Deep-dive competitor research and strategy', 79, 149, 299, 'Research')` },\n { sql: `INSERT INTO services (agent_name, service_name, description, price_basic, price_pro, price_premium, category) VALUES ('Pixel', 'Logo Design', 'Custom logo with 3 concepts and revisions', 59, 129, 249, 'Design')` },\n { sql: `INSERT INTO services (agent_name, service_name, description, price_basic, price_pro, price_premium, category) VALUES ('Pixel', 'Social Media Graphics', '10 custom social media graphics', 49, 99, 199, 'Design')` },\n { sql: `INSERT INTO services (agent_name, service_name, description, price_basic, price_pro, price_premium, category) VALUES ('Pixel', 'UI Mockup', 'Full app/website UI mockup with 3 screens', 99, 199, 399, 'Design')` },\n { sql: `INSERT INTO services (agent_name, service_name, description, price_basic, price_pro, price_premium, category) VALUES ('Forge', 'API Development', 'Custom REST API with documentation', 149, 299, 599, 'Code')` },\n { sql: `INSERT INTO services (agent_name, service_name, description, price_basic, price_pro, price_premium, category) VALUES ('Forge', 'Website Build', 'Full responsive website deployment', 199, 399, 799, 'Code')` },\n { sql: `INSERT INTO services (agent_name, service_name, description, price_basic, price_pro, price_premium, category) VALUES ('Forge', 'Automation Script', 'Custom automation script for any workflow', 79, 159, 319, 'Code')` },\n { sql: `INSERT INTO services (agent_name, service_name, description, price_basic, price_pro, price_premium, category) VALUES ('Nexus', 'Deal Brokerage', 'Find and negotiate the best deal for your project', 50, 100, 250, 'Brokerage')` },\n ]);\n console.log(\"Service catalog seeded with 12 packages\");\n }\n\n return { initialized: true };\n}\n",[],[111,119],"476be959-8769-40bb-b414-5049344e46cf","cron","473736f8-a1cd-4530-b8e0-6da8d3ed42ac",15,["D",1784064263988],[133],[127],{"_36":134,"_13":135,"_39":136,"_41":128,"_43":44,"_45":129,"_47":48,"_49":137,"_17":65,"_52":138,"_54":139,"_56":57,"_58":-5,"_92":140,"_18":141},"5ff23d7e-8b53-456e-8114-b627ef74de15","autoscan.ts","62a81e4e-7fca-11f1-a7cb-1607ee4eb77e",["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",[],[127,135],"d3dced56-e46f-4d52-ba27-b83300b1e53c",["D",1784062896908],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Auto","imageUrl","userId","8a9d55c0-dadc-4469-9c3a-2c9113728ba8","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","019f626e-a2db-72f9-bd5f-aff934f0acc3","tursoName","d3dced56e46f4d52ba27b83300b1e53c","tursoHostname","d3dced56e46f4d52ba27b83300b1e53c-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789474235934],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_198":193},"org",{"_11":12,"_192":193,"_194":193,"_152":153,"_195":196,"_197":57},"branch",{"_17":87,"_13":16,"_36":44,"_184":142,"_185":-5,"_186":-5,"_187":-5,"_188":-5,"_189":-5,"_190":14,"_191":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_36":142,"_13":14,"_49":261,"_144":-5,"_145":57,"_146":147,"_148":147,"_149":150,"_151":-5,"_152":153,"_154":86,"_155":48,"_156":-5,"_157":-5,"_158":65,"_159":160,"_161":162,"_163":164,"_165":262,"_167":-5,"_168":169,"_170":169,"_171":172,"_173":172,"_174":172,"_175":169,"_176":169,"_177":263,"_179":264,"_181":265,"_183":57},[234,236,238,242],"files",[234,235,236,237,238,239,240,241,242],"counts",{"_225":65,"_226":51,"_227":65,"_32":228,"_229":230},[219,220,221],{"_36":76,"_13":19,"_39":42,"_41":-5,"_43":44,"_45":73,"_47":48,"_49":77,"_17":65,"_52":78,"_54":-5,"_56":57,"_58":-5,"_18":218},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},[19],{"_36":68,"_13":69,"_39":70,"_41":42,"_43":44,"_45":71,"_47":48,"_49":72,"_17":73,"_52":53,"_54":74,"_56":57,"_58":-5,"_18":224},{"_36":60,"_13":61,"_39":62,"_41":42,"_43":44,"_45":63,"_47":48,"_49":64,"_17":65,"_52":53,"_54":66,"_56":57,"_58":-5,"_18":223},{"_36":37,"_13":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_17":51,"_52":53,"_54":55,"_56":57,"_58":-5,"_18":222},[19,38],[19,61],[19,69],"pulls","branches","forks",{"_231":65,"_233":65},"connections",{"_231":65,"_232":65},"count","unfilledCount","emptyCount",{"_36":126,"_13":127,"_39":128,"_41":-5,"_43":44,"_45":129,"_47":48,"_49":130,"_17":65,"_52":78,"_54":-5,"_56":57,"_58":-5,"_92":259,"_18":260},{"_36":134,"_13":135,"_39":136,"_41":128,"_43":44,"_45":129,"_47":48,"_49":137,"_17":65,"_52":138,"_54":139,"_56":57,"_58":-5,"_92":257,"_18":258},{"_36":110,"_13":111,"_39":112,"_41":-5,"_43":44,"_45":113,"_47":48,"_49":114,"_17":65,"_52":78,"_54":-5,"_56":57,"_58":-5,"_92":255,"_18":256},{"_36":118,"_13":119,"_39":120,"_41":112,"_43":44,"_45":121,"_47":48,"_49":122,"_17":51,"_52":53,"_54":123,"_56":57,"_58":-5,"_92":253,"_18":254},{"_36":76,"_13":19,"_39":42,"_41":-5,"_43":44,"_45":73,"_47":48,"_49":95,"_17":65,"_52":78,"_54":-5,"_56":57,"_58":-5,"_92":251,"_18":252},{"_36":68,"_13":69,"_39":70,"_41":42,"_43":44,"_45":71,"_47":48,"_49":107,"_17":73,"_52":53,"_54":74,"_56":57,"_58":-5,"_92":249,"_18":250},{"_36":60,"_13":61,"_39":62,"_41":42,"_43":44,"_45":63,"_47":48,"_49":104,"_17":65,"_52":53,"_54":66,"_56":57,"_58":-5,"_92":247,"_18":248},{"_36":37,"_13":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":101,"_17":51,"_52":53,"_54":55,"_56":57,"_58":-5,"_92":245,"_18":246},{"_36":84,"_13":85,"_39":86,"_41":-5,"_43":44,"_45":87,"_47":48,"_49":88,"_17":89,"_52":90,"_54":91,"_56":57,"_58":-5,"_92":243,"_18":244},[],[85],[],[19,38],[],[19,61],[],[19,69],[239,240,241],[19],[],[111,119],[237],[111],[],[127,135],[235],[127],["D",1784062896908],["D",1789474235934],{"_11":12,"_198":193},{"_11":12,"_192":193,"_194":193,"_152":153,"_195":196,"_197":57},{"_17":87,"_13":16,"_36":44,"_184":142,"_185":-5,"_186":-5,"_187":-5,"_188":-5,"_189":-5,"_190":14,"_191":12},"ctx",{"_177":-5,"_215":299,"_300":301,"_302":303,"_304":57,"_305":57,"_306":57,"_307":48,"_308":-5,"_309":-7,"_310":-7,"_311":65,"_312":57,"_313":57,"_314":-5,"_315":57,"_316":57,"_317":57,"_318":-5},"ENV",{"_270":271,"_272":273,"_274":16,"_275":276,"_277":278,"_279":280,"_281":282,"_283":284,"_285":286,"_287":288,"_289":290,"_291":292,"_293":294,"_295":296,"_297":298},"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"]