(.*?)<\\/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// ── 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 // RemoteOK returns array with first element being metadata\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 ? `https://remoteok.com${job.url}` : (job.apply_url || \"\"),\n })).filter((j: JobListing) => j.title && j.url);\n } catch (e) {\n console.error(\"RemoteOK error:\", e.message);\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:\", e.message);\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:\", e.message);\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:\", e.message);\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:\", e.message);\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:\", e.message);\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:\", e.message);\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 // Store to DB\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 // Look for jobs that mention budgets/prices and match them to agent capabilities\n // This finds potential deals — NOT real deals. Real deals only come from webhook.\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 // Simple matching: if a job mentions a service we can provide + budget range\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 // Estimate margin: buyer budget vs what our agents could charge\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; // 15% commission\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",[],[146,192],["D",1784063430810],[171,172,173],[146],"bab52c01-6000-4a8b-937d-e157e447933b","schema.ts","722b077a-7fc8-11f1-9a5b-1607ee4eb77e",["D",1784063430814],"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 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\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 return { initialized: true };\n}\n",[],[153,202],["D",1784063430814],[169],[153],["D",1784062896908],["D",1789474235934],{"_105":104,"_112":107},{"_105":104,"_106":107,"_108":107,"_19":60,"_109":110,"_111":30},{"_13":94,"_37":95,"_48":47,"_96":49,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":50,"_103":104},"ctx",{"_87":-5,"_131":249,"_250":251,"_252":253,"_254":30,"_255":30,"_256":30,"_257":64,"_258":-5,"_259":-7,"_260":-7,"_261":68,"_262":30,"_263":30,"_264":-5,"_265":30,"_266":30,"_267":30,"_268":-5},"ENV",{"_220":221,"_222":223,"_224":95,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248},"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>

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_216":217,"_218":219},"routes/_app.x.$handle.$name",{"_105":104,"_37":50,"_113":95,"_32":107,"_13":14,"_114":-5,"_11":115,"_116":117,"_118":119,"_120":121,"_122":123,"_26":-5,"_124":-5,"_125":-5,"_126":30,"_127":128,"_129":30,"_130":-5,"_131":-5,"_132":133},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_48":49,"_37":50,"_43":51,"_52":-5,"_53":30,"_54":55,"_56":55,"_57":58,"_59":-5,"_19":60,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":76,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":88,"_89":90,"_91":92,"_93":30},"version",5,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","c9cc1094-bb1b-4865-a861-5e9dc87024a3","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":14,"_46":47,"_29":30},"previous","deleted",false,"deletedHere","path","lib/pollinations.ts","latestPath","fileId","79e9dfb8-7fc8-11f1-982e-1607ee4eb77e","name","pollinations.ts","fileType","script","content","// 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","createdAt",["D",1784063444061],"branchVersion","branchId","f0ef8b75-b525-47d9-ac35-478bce6f4021","id","d3dced56-e46f-4d52-ba27-b83300b1e53c","Tasker",["D",1784062896908],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Auto","imageUrl","8a9d55c0-dadc-4469-9c3a-2c9113728ba8","pinnedFileId","33c9f2d0-7fc7-11f1-8bbb-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"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",{"_105":104,"_112":107},"org",{"_105":104,"_106":107,"_108":107,"_19":60,"_109":110,"_111":30},"branch",{"_13":94,"_37":95,"_48":47,"_96":49,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":50,"_103":104},"isOwned",19,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","dobip18976","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_48":49,"_37":50,"_43":211,"_52":-5,"_53":30,"_54":55,"_56":55,"_57":58,"_59":-5,"_19":60,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":212,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":213,"_89":214,"_91":215,"_93":30},"tree",[168,170,174],"files",[168,169,170,171,172,173,174],"counts",{"_158":68,"_159":140,"_160":68,"_161":162,"_163":164},"contents",[134,135,136],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_48":152,"_37":153,"_35":154,"_139":-5,"_46":47,"_45":155,"_141":64,"_43":156,"_13":68,"_39":150,"_41":-5,"_29":30,"_143":-5,"_32":157},{"_48":145,"_37":146,"_35":147,"_139":-5,"_46":47,"_45":148,"_141":64,"_43":149,"_13":68,"_39":150,"_41":-5,"_29":30,"_143":-5,"_32":151},{"_48":137,"_37":138,"_35":62,"_139":-5,"_46":47,"_45":140,"_141":30,"_43":142,"_13":68,"_39":40,"_41":107,"_29":30,"_143":-5,"_32":144},"ffe47179-1981-4ba1-b7af-af43242a20f8","main.ts","parentId",1,"latest",["D",1784062896920],"label",[138],"4528d930-d59c-4965-abc1-aed4b6e4f2d5","lib","26fe2ab4-8b64-43dc-9530-d4872970c863",2,["D",1784063430810],"directory",[146],"9f090f1c-1772-44fb-a6f4-4828525a5037","db","9a4475b0-0e81-404d-b047-b22a85207cc2",3,["D",1784063430814],[153],"pulls","branches","forks","envVars",{"_165":68,"_167":68},"connections",{"_165":68,"_166":68},"count","unfilledCount","emptyCount",{"_48":152,"_37":153,"_35":154,"_139":-5,"_46":47,"_45":155,"_141":64,"_43":208,"_13":68,"_39":150,"_41":-5,"_29":30,"_143":-5,"_176":209,"_32":210},{"_48":201,"_37":202,"_35":203,"_139":154,"_46":47,"_45":155,"_141":30,"_43":204,"_13":68,"_39":40,"_41":205,"_29":30,"_143":-5,"_176":206,"_32":207},{"_48":145,"_37":146,"_35":147,"_139":-5,"_46":47,"_45":148,"_141":64,"_43":198,"_13":68,"_39":150,"_41":-5,"_29":30,"_143":-5,"_176":199,"_32":200},{"_48":191,"_37":192,"_35":193,"_139":147,"_46":47,"_45":148,"_141":30,"_43":194,"_13":68,"_39":40,"_41":195,"_29":30,"_143":-5,"_176":196,"_32":197},{"_48":183,"_37":184,"_35":185,"_139":147,"_46":47,"_45":186,"_141":64,"_43":187,"_13":68,"_39":40,"_41":188,"_29":30,"_143":-5,"_176":189,"_32":190},{"_48":179,"_37":38,"_35":36,"_139":147,"_46":47,"_45":14,"_141":30,"_43":180,"_13":68,"_39":40,"_41":42,"_29":30,"_143":-5,"_176":181,"_32":182},{"_48":137,"_37":138,"_35":62,"_139":-5,"_46":47,"_45":140,"_141":30,"_43":175,"_13":68,"_39":40,"_41":107,"_29":30,"_143":-5,"_176":177,"_32":178},["D",1784062896920],"children",[],[138],"89094979-eea4-4e97-b1de-c767ecd5871a",["D",1784063444061],[],[146,38],"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",[],[146,184],"e8a17b77-2cc2-4588-a015-f110562966fd","marketScanner.ts","72046674-7fc8-11f1-802c-1607ee4eb77e",["D",1784063430810],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport interface JobListing {\n source: string;\n title: string;\n url: string;\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// ── 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 // RemoteOK returns array with first element being metadata\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 ? `https://remoteok.com${job.url}` : (job.apply_url || \"\"),\n })).filter((j: JobListing) => j.title && j.url);\n } catch (e) {\n console.error(\"RemoteOK error:\", e.message);\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:\", e.message);\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:\", e.message);\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:\", e.message);\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:\", e.message);\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:\", e.message);\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:\", e.message);\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 // Store to DB\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 // Look for jobs that mention budgets/prices and match them to agent capabilities\n // This finds potential deals — NOT real deals. Real deals only come from webhook.\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 // Simple matching: if a job mentions a service we can provide + budget range\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 // Estimate margin: buyer budget vs what our agents could charge\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; // 15% commission\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",[],[146,192],["D",1784063430810],[171,172,173],[146],"bab52c01-6000-4a8b-937d-e157e447933b","schema.ts","722b077a-7fc8-11f1-9a5b-1607ee4eb77e",["D",1784063430814],"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 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\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 return { initialized: true };\n}\n",[],[153,202],["D",1784063430814],[169],[153],["D",1784062896908],["D",1789474235934],{"_105":104,"_112":107},{"_105":104,"_106":107,"_108":107,"_19":60,"_109":110,"_111":30},{"_13":94,"_37":95,"_48":47,"_96":49,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":50,"_103":104},"ctx",{"_87":-5,"_131":249,"_250":251,"_252":253,"_254":30,"_255":30,"_256":30,"_257":64,"_258":-5,"_259":-7,"_260":-7,"_261":68,"_262":30,"_263":30,"_264":-5,"_265":30,"_266":30,"_267":30,"_268":-5},"ENV",{"_220":221,"_222":223,"_224":95,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248},"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>

Diff · v5