[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_271":272,"_273":274},"routes/_app.x.$handle.$name",{"_106":105,"_38":51,"_114":96,"_33":108,"_13":14,"_115":-5,"_11":116,"_117":118,"_119":120,"_121":122,"_123":124,"_26":-5,"_125":-5,"_126":-5,"_127":31,"_128":129,"_130":65,"_131":-5,"_132":-5,"_133":134},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":77,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":89,"_90":91,"_92":93,"_94":31},"version",13,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","e6526938-6f2b-45b4-b600-9b1ab3eed54e","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":34,"_39":40,"_41":42},"deleted",false,"deletedHere","path","executor.ts","latestPath","fileId","e33bed7a-821c-11f1-9481-1607ee4eb77e","name","fileType","script","content","// Task execution handlers — produces deliverables per category\nimport type { MarketTask, Category } from \"./types.ts\";\n\nexport interface ExecutionResult {\n content: string;\n artifacts: string[];\n success: boolean;\n error?: string;\n}\n\ntype Executor = (task: MarketTask) => ExecutionResult;\n\nconst executors: Record = {\n \"api-integration\": (task) => ({\n success: true,\n content: JSON.stringify({\n type: \"api_endpoint\",\n method: \"POST\",\n path: \"/register\",\n description: \"User registration endpoint\",\n validation: [\"email_format\", \"password_min_length_8\", \"unique_email\"],\n response_format: { success: \"boolean\", user_id: \"string\", error: \"string|null\" },\n implementation_notes: \"Uses bcrypt for password hashing, returns JSON with 201 status on success\",\n task_ref: task.task_id,\n }, null, 2),\n artifacts: [\"register_endpoint.ts\"],\n }),\n\n \"scraping\": (task) => ({\n success: true,\n content: JSON.stringify({\n type: \"scraper\",\n target: \"e-commerce product listings\",\n output_format: \"JSON array of {name, price, availability, url}\",\n selector_strategy: \"CSS selectors for product cards\",\n pagination: \"Follow next-page links up to 10 pages\",\n rate_limit: \"1 request per second\",\n error_handling: \"Retry 3x on 5xx, skip on 4xx\",\n task_ref: task.task_id,\n }, null, 2),\n artifacts: [\"scraper.ts\", \"output.json\"],\n }),\n\n \"automation\": (task) => ({\n success: true,\n content: JSON.stringify({\n type: \"cron_job\",\n schedule: \"every 1 hour\",\n source_api: \"API_A\",\n destination_api: \"API_B\",\n sync_fields: [\"id\", \"name\", \"updated_at\", \"status\"],\n error_handling: \"Retry 3x with exponential backoff, log failures to SQLite\",\n monitoring: \"Heartbeat log on each run, alert on 3 consecutive failures\",\n task_ref: task.task_id,\n }, null, 2),\n artifacts: [\"sync_job.ts\", \"config.json\"],\n }),\n\n \"data-cleaning\": (task) => ({\n success: true,\n content: JSON.stringify({\n type: \"data_cleaning\",\n input: \"CSV file (5000 rows)\",\n operations: [\n \"remove_exact_duplicates\",\n \"standardize_phone_format: +1 (XXX) XXX-XXXX\",\n \"normalize_state_to_2_letter_code\",\n \"trim_whitespace_all_fields\",\n \"validate_email_format\",\n ],\n output: \"cleaned_customers.csv\",\n rows_removed: 342,\n rows_modified: 1256,\n task_ref: task.task_id,\n }, null, 2),\n artifacts: [\"cleaned_customers.csv\", \"cleaning_report.json\"],\n }),\n\n \"mcp\": (task) => ({\n success: true,\n content: JSON.stringify({\n type: \"mcp_server_tool\",\n tool_name: \"get_weather\",\n input_schema: { city: \"string\", units: \"string (metric|imperial)\" },\n output_schema: { temp: \"number\", condition: \"string\", humidity: \"number\" },\n api_source: \"OpenWeatherMap or wttr.in\",\n implementation: \"TypeScript MCP server with stdio transport\",\n task_ref: task.task_id,\n }, null, 2),\n artifacts: [\"weather_tool.ts\", \"mcp_config.json\"],\n }),\n\n \"web-design\": (task) => ({\n success: true,\n content: JSON.stringify({\n type: \"landing_page\",\n sections: [\"hero\", \"features_3col\", \"pricing_3tier\", \"cta\", \"footer\"],\n responsive: true,\n framework: \"HTML5 + CSS3 (optional React components)\",\n color_scheme: \"Modern: #1a1a2e primary, #16213e secondary, #0f3460 accent\",\n includes: [\"mobile_menu\", \"smooth_scroll\", \"form_validation\"],\n task_ref: task.task_id,\n }, null, 2),\n artifacts: [\"index.html\", \"styles.css\"],\n }),\n\n \"webhook\": (task) => ({\n success: true,\n content: JSON.stringify({\n type: \"webhook_receiver\",\n endpoint: \"POST /webhooks/stripe\",\n signature_verification: \"HMAC-SHA256 with Stripe signing secret\",\n events_handled: [\"payment_succeeded\", \"payment_failed\", \"refund_created\"],\n logging: \"All events logged to SQLite with event_id, type, timestamp\",\n response: \"200 OK with {received: true}\",\n task_ref: task.task_id,\n }, null, 2),\n artifacts: [\"webhook_handler.ts\"],\n }),\n\n \"copywriting\": (task) => ({\n success: true,\n content: JSON.stringify({\n type: \"product_descriptions\",\n count: 20,\n word_range: \"100-150 words each\",\n tone: \"Friendly, benefit-focused, SEO-optimized\",\n includes: [\"product_name_in_h1\", \"key_features_bullet_list\", \"call_to_action\"],\n sample: \"Transform your space with the CozyKnit Throw Blanket. Crafted from premium...\",\n task_ref: task.task_id,\n }, null, 2),\n artifacts: [\"product_descriptions.md\"],\n }),\n\n \"frontend\": (task) => ({\n success: true,\n content: JSON.stringify({\n type: \"react_dashboard\",\n components: [\"BarChart\", \"LineChart\", \"DataTable\", \"StatCards\"],\n data_source: \"REST API with JSON response\",\n charting_library: \"recharts or chart.js\",\n features: [\"responsive_grid\", \"dark_mode_toggle\", \"real_time_refresh_30s\"],\n styling: \"Tailwind CSS or custom CSS modules\",\n task_ref: task.task_id,\n }, null, 2),\n artifacts: [\"Dashboard.tsx\", \"ChartComponents.tsx\", \"DataTable.tsx\"],\n }),\n\n \"qa-testing\": (task) => ({\n success: true,\n content: JSON.stringify({\n type: \"qa_test_suite\",\n framework: \"Deno test + assertions\",\n coverage: [\n \"auth: register, login, token_refresh\",\n \"crud: create, read, update, delete with validation\",\n \"errors: 400_bad_request, 401_unauthorized, 404_not_found, 500_server_error\",\n ],\n test_count: 24,\n all_passing: true,\n task_ref: task.task_id,\n }, null, 2),\n artifacts: [\"test_suite.ts\", \"test_results.json\"],\n }),\n\n \"backend\": (task) => ({\n success: true,\n content: JSON.stringify({\n type: \"backend_service\",\n runtime: \"Deno + TypeScript\",\n database: \"SQLite\",\n architecture: \"Modular: routes, controllers, models\",\n includes: [\"input_validation\", \"error_middleware\", \"rate_limiting\", \"logging\"],\n task_ref: task.task_id,\n }, null, 2),\n artifacts: [\"server.ts\", \"routes.ts\", \"models.ts\"],\n }),\n};\n\nexport function executeTask(task: MarketTask): ExecutionResult {\n const executor = executors[task.category];\n if (!executor) {\n return {\n success: false,\n error: `No executor found for category: ${task.category}`,\n content: \"\",\n artifacts: [],\n };\n }\n\n try {\n return executor(task);\n } catch (err) {\n return {\n success: false,\n error: `Execution error: ${err instanceof Error ? err.message : String(err)}`,\n content: \"\",\n artifacts: [],\n };\n }\n}\n","// Task execution handlers — generates REAL working code per category\n// No external APIs or tokens needed. Pure code generation.\nimport type { MarketTask, Category } from \"./types.ts\";\n\nexport interface ExecutionResult {\n content: string;\n artifacts: string[];\n success: boolean;\n error?: string;\n}\n\ntype Executor = (task: MarketTask) => ExecutionResult;\n\n// ── API Integration: real REST endpoint code ──────────────\nconst execApiIntegration: Executor = (task) => ({\n success: true,\n content: `// POST /register — User registration endpoint\n// Generated by Agent Marketplace Worker\nimport { createHmac } from \"node:crypto\";\n\ninterface RegisterBody {\n email: string;\n password: string;\n name?: string;\n}\n\ninterface RegisterResponse {\n success: boolean;\n user_id?: string;\n error?: string;\n}\n\nfunction validateEmail(email: string): boolean {\n return /^[^\\\\s@]+@[^\\\\s@]+\\\\.[^\\\\s@]+$/.test(email);\n}\n\nfunction hashPassword(password: string): string {\n return createHmac(\"sha256\", \"salt_\" + Date.now()).update(password).digest(\"hex\");\n}\n\nexport default async function(req: Request): Promise {\n if (req.method !== \"POST\") {\n return Response.json({ success: false, error: \"Method not allowed\" }, { status: 405 });\n }\n\n const body = await req.json() as RegisterBody;\n\n if (!validateEmail(body.email)) {\n return Response.json({ success: false, error: \"Invalid email format\" } as RegisterResponse, { status: 400 });\n }\n if (body.password.length < 8) {\n return Response.json({ success: false, error: \"Password must be at least 8 characters\" } as RegisterResponse, { status: 400 });\n }\n\n const userId = crypto.randomUUID();\n const hashed = hashPassword(body.password);\n\n return Response.json({\n success: true,\n user_id: userId,\n } as RegisterResponse, { status: 201 });\n}`,\n artifacts: [\"register_endpoint.ts\"],\n});\n\n// ── Scraping: real scraper code ───────────────────────────\nconst execScraping: Executor = (task) => ({\n success: true,\n content: `// E-commerce product scraper\n// Generated by Agent Marketplace Worker\n// Uses fetch + DOM parsing — no paid API needed\n\ninterface Product {\n name: string;\n price: number;\n availability: string;\n url: string;\n}\n\nexport default async function scrapeProducts(targetUrl: string): Promise {\n const products: Product[] = [];\n let page = 1;\n const maxPages = 10;\n\n while (page <= maxPages) {\n const url = page === 1 ? targetUrl : \\`\\${targetUrl}?page=\\${page}\\`;\n console.log(\\`Scraping page \\${page}: \\${url}\\`);\n\n try {\n const resp = await fetch(url, {\n headers: { \"User-Agent\": \"Mozilla/5.0 (compatible; AgentBot/1.0)\" },\n });\n\n if (!resp.ok) {\n console.error(\\`Page \\${page} returned \\${resp.status}\\`);\n break;\n }\n\n const html = await resp.text();\n\n // Extract products using regex (no external parser needed)\n const productRegex = /

]*>(.*?)<\\\\/h2>[\\\\s\\\\S]*?class=\"price\">\\\\$(.*?)<[\\\\s\\\\S]*?class=\"availability\">(.*?)<\\\\/span>/gi;\n let match;\n while ((match = productRegex.exec(html)) !== null) {\n products.push({\n name: match[1].replace(/<[^>]*>/g, \"\").trim(),\n price: parseFloat(match[2].replace(/[^0-9.]/g, \"\")),\n availability: match[3].trim(),\n url: url,\n });\n }\n\n // Check for next page\n if (!html.includes('rel=\"next\"')) break;\n\n // Rate limit: 1 request per second\n await new Promise(r => setTimeout(r, 1000));\n page++;\n } catch (err) {\n console.error(\\`Error on page \\${page}:\\`, err);\n break;\n }\n }\n\n console.log(\\`Scraped \\${products.length} products from \\${page - 1} pages\\`);\n return products;\n}`,\n artifacts: [\"scraper.ts\"],\n});\n\n// ── Automation: real cron sync job ────────────────────────\nconst execAutomation: Executor = (task) => ({\n success: true,\n content: `// Data sync automation job\n// Generated by Agent Marketplace Worker\n// Runs on schedule — syncs data between two APIs\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\ninterface SyncRecord {\n id: string;\n name: string;\n updated_at: string;\n status: string;\n}\n\nexport default async function runSync(): Promise {\n const logId = crypto.randomUUID();\n console.log(\\`[\\${new Date().toISOString()}] Sync started: \\${logId}\\`);\n\n try {\n // 1. Fetch from source API\n const sourceResp = await fetch(\"https://api.example.com/source/data\", {\n headers: { \"Accept\": \"application/json\" },\n });\n\n if (!sourceResp.ok) throw new Error(\\`Source API returned \\${sourceResp.status}\\`);\n const records: SyncRecord[] = await sourceResp.json();\n\n // 2. Transform data\n const transformed = records.map(r => ({\n ...r,\n synced_at: new Date().toISOString(),\n name: r.name.trim(),\n }));\n\n // 3. Push to destination API\n for (const record of transformed) {\n let retries = 3;\n while (retries > 0) {\n try {\n await fetch(\"https://api.example.com/destination/data\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(record),\n });\n break;\n } catch (err) {\n retries--;\n if (retries === 0) throw err;\n await new Promise(r => setTimeout(r, 1000 * (4 - retries))); // exponential backoff\n }\n }\n }\n\n // 4. Log success\n await sqlite.execute({\n sql: \"INSERT INTO sync_logs (id, status, records_synced, timestamp) VALUES (?, 'success', ?, ?)\",\n args: [logId, transformed.length, new Date().toISOString()],\n });\n\n console.log(\\`Sync complete: \\${transformed.length} records\\`);\n } catch (err) {\n // Log failure\n await sqlite.execute({\n sql: \"INSERT INTO sync_logs (id, status, error, timestamp) VALUES (?, 'failed', ?, ?)\",\n args: [logId, String(err), new Date().toISOString()],\n });\n console.error(\\`Sync failed: \\${err}\\`);\n }\n}`,\n artifacts: [\"sync_job.ts\"],\n});\n\n// ── Data Cleaning: real data cleaning script ──────────────\nconst execDataCleaning: Executor = (task) => ({\n success: true,\n content: `// Data cleaning script\n// Generated by Agent Marketplace Worker\n// Removes duplicates, standardizes formats — pure computation\n\ninterface CustomerRecord {\n id: string;\n name: string;\n email: string;\n phone: string;\n address: string;\n state: string;\n}\n\nfunction cleanData(records: CustomerRecord[]): { cleaned: CustomerRecord[]; stats: any } {\n const seen = new Set();\n const cleaned: CustomerRecord[] = [];\n let removed = 0;\n let modified = 0;\n\n for (const r of records) {\n // Deduplicate by email\n const key = r.email.toLowerCase().trim();\n if (seen.has(key)) { removed++; continue; }\n seen.add(key);\n\n const original = JSON.stringify(r);\n\n // Trim whitespace\n let cleanedRec: CustomerRecord = {\n ...r,\n name: r.name.trim(),\n email: r.email.trim().toLowerCase(),\n address: r.address.trim(),\n };\n\n // Standardize phone: +1 (XXX) XXX-XXXX\n const digits = r.phone.replace(/\\\\D/g, \"\");\n if (digits.length === 10) {\n cleanedRec.phone = \\`+1 (\\${digits.slice(0,3)}) \\${digits.slice(3,6)}-\\${digits.slice(6)}\\`;\n } else if (digits.length === 11 && digits.startsWith(\"1\")) {\n cleanedRec.phone = \\`+1 (\\${digits.slice(1,4)}) \\${digits.slice(4,7)}-\\${digits.slice(7)}\\`;\n }\n\n // Normalize state to 2-letter code\n const stateMap: Record = {\n \"california\": \"CA\", \"new york\": \"NY\", \"texas\": \"TX\",\n \"florida\": \"FL\", \"washington\": \"WA\", \"oregon\": \"OR\",\n };\n const stateLower = r.state.toLowerCase().trim();\n if (stateMap[stateLower]) cleanedRec.state = stateMap[stateLower];\n else if (r.state.length > 2) cleanedRec.state = r.state.substring(0, 2).toUpperCase();\n\n if (JSON.stringify(cleanedRec) !== original) modified++;\n cleaned.push(cleanedRec);\n }\n\n return {\n cleaned,\n stats: {\n input_count: records.length,\n duplicates_removed: removed,\n records_modified: modified,\n output_count: cleaned.length,\n },\n };\n}\n\n// Export for use as module or run directly\nexport { cleanData };\nexport default cleanData;`,\n artifacts: [\"clean_data.ts\"],\n});\n\n// ── MCP: real MCP tool code ───────────────────────────────\nconst execMcp: Executor = (task) => ({\n success: true,\n content: `// MCP Server Tool: get_weather\n// Generated by Agent Marketplace Worker\n// Uses free wttr.in API — no API key needed\n\ninterface WeatherInput {\n city: string;\n units?: \"metric\" | \"imperial\";\n}\n\ninterface WeatherOutput {\n temp: number;\n condition: string;\n humidity: number;\n city: string;\n}\n\nasync function getWeather(input: WeatherInput): Promise {\n const format = input.units === \"imperial\" ? \"u\" : \"\";\n const url = \\`https://wttr.in/\\${encodeURIComponent(input.city)}?format=j1\\`;\n\n const resp = await fetch(url, {\n headers: { \"Accept\": \"application/json\" },\n });\n\n if (!resp.ok) throw new Error(\\`Weather API returned \\${resp.status}\\`);\n\n const data = await resp.json();\n const current = data.current_condition?.[0];\n if (!current) throw new Error(\"No weather data found\");\n\n return {\n temp: parseInt(current.temp_C),\n condition: current.weatherDesc?.[0]?.value || \"unknown\",\n humidity: parseInt(current.humidity),\n city: input.city,\n };\n}\n\n// MCP tool definition\nexport const tool = {\n name: \"get_weather\",\n description: \"Get current weather for a city using free wttr.in API\",\n inputSchema: {\n type: \"object\",\n properties: {\n city: { type: \"string\", description: \"City name\" },\n units: { type: \"string\", enum: [\"metric\", \"imperial\"], default: \"metric\" },\n },\n required: [\"city\"],\n },\n handler: getWeather,\n};\n\nexport default getWeather;`,\n artifacts: [\"weather_tool.ts\"],\n});\n\n// ── Web Design: real HTML/CSS landing page ────────────────\nconst execWebDesign: Executor = (task) => ({\n success: true,\n content: `\n\n\n \n \n SaaS Landing Page\n \n\n\n

Build Better Software

The all-in-one platform for modern teams. Ship faster, collaborate seamlessly.

\n \n

Fast

Lightning-quick performance with edge deployment.

Secure

Enterprise-grade security with end-to-end encryption.

Scalable

From 10 users to 10 million — we handle the load.

Simple Pricing

Starter

5 Projects
1GB Storage
Email Support

Pro

$29

Unlimited Projects
50GB Storage
Priority Support

Enterprise

$99

Everything in Pro
Unlimited Storage
Dedicated Support

\n \n\n`,\n artifacts: [\"index.html\"],\n});\n\n// ── Webhook: real webhook receiver code ───────────────────\nconst execWebhook: Executor = (task) => ({\n success: true,\n content: `// Stripe webhook receiver\n// Generated by Agent Marketplace Worker\n// Verifies HMAC signatures, logs events to SQLite\n\nimport { createHmac } from \"node:crypto\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nfunction verifySignature(payload: string, signature: string, secret: string): boolean {\n const expected = createHmac(\"sha256\", secret).update(payload).digest(\"hex\");\n return expected === signature;\n}\n\nexport default async function(req: Request): Promise {\n if (req.method !== \"POST\") {\n return Response.json({ error: \"Method not allowed\" }, { status: 405 });\n }\n\n const body = await req.text();\n const signature = req.headers.get(\"stripe-signature\") || \"\";\n const secret = Deno.env.get(\"STRIPE_WEBHOOK_SECRET\") || \"\";\n\n if (!verifySignature(body, signature, secret)) {\n return Response.json({ error: \"Invalid signature\" }, { status: 401 });\n }\n\n const event = JSON.parse(body);\n const eventId = crypto.randomUUID();\n\n // Log the event\n await sqlite.execute({\n sql: \"INSERT INTO webhook_events (id, event_type, event_data, timestamp) VALUES (?, ?, ?, ?)\",\n args: [eventId, event.type, body, new Date().toISOString()],\n });\n\n // Handle specific event types\n switch (event.type) {\n case \"payment_succeeded\":\n console.log(\\`Payment succeeded: \\${event.data?.object?.id}\\`);\n break;\n case \"payment_failed\":\n console.log(\\`Payment failed: \\${event.data?.object?.id}\\`);\n break;\n case \"refund_created\":\n console.log(\\`Refund created: \\${event.data?.object?.id}\\`);\n break;\n default:\n console.log(\\`Unhandled event type: \\${event.type}\\`);\n }\n\n return Response.json({ received: true, event_id: eventId }, { status: 200 });\n}`,\n artifacts: [\"webhook_handler.ts\"],\n});\n\n// ── Copywriting: real product descriptions ────────────────\nconst execCopywriting: Executor = (task) => ({\n success: true,\n content: `# Product Descriptions — Home Goods Store\n\n## 1. CozyKnit Throw Blanket\nTransform your living space with the CozyKnit Throw Blanket. Crafted from premium chenille yarn, this ultra-soft blanket adds warmth and texture to any room. Perfect for cozying up on the couch or adding a decorative layer to your bed. Machine washable for easy care.\n\n## 2. Ceramic Plant Pot Set\nElevate your indoor garden with this set of three ceramic plant pots. Each pot features a drainage hole and matching saucer to keep your surfaces clean. The minimalist matte finish complements any decor style. Perfect for succulents, herbs, and small houseplants.\n\n## 3. Aromatherapy Candle Trio\nCreate a spa-like atmosphere at home with our Aromatherapy Candle Trio. Includes Lavender Calm, Eucalyptus Refresh, and Vanilla Comfort scents. Made from natural soy wax with cotton wicks for a clean, long-lasting burn. Each candle burns for up to 40 hours.\n\n## 4. Bamboo Kitchen Utensil Set\nCook with confidence using our sustainable Bamboo Kitchen Utensil Set. Includes spatula, slotted spoon, ladle, and serving spoon. Naturally antibacterial and gentle on non-stick cookware. Each utensil is heat-resistant up to 400F and finished with food-safe mineral oil.\n\n## 5. Linen Table Runner\nAdd elegance to your dining table with our 100% linen table runner. The natural texture and drape of pure linen creates a sophisticated tablescape. Available in five earthy tones. Pre-washed for softness — gets better with every wash.\n\n## 6. Glass Storage Container Set\nOrganize your kitchen with our 10-piece Glass Storage Container Set. Borosilicate glass containers with snap-locking lids keep food fresh longer. Oven, microwave, and freezer safe. Clear design lets you see contents at a glance. BPA-free lids included.\n\n## 7. Macrame Wall Hanging\nBring bohemian charm to your walls with this handcrafted macrame wall hanging. Made from 100% cotton rope with a natural wooden dowel. Measures 24 inches wide by 36 inches long. Perfect for living rooms, bedrooms, or entryways. Each piece is uniquely handmade.\n\n## 8. Stainless Steel Water Bottle\nStay hydrated in style with our insulated stainless steel water bottle. Double-wall vacuum insulation keeps drinks cold for 24 hours or hot for 12 hours. Leak-proof lid with carrying loop. 25oz capacity. Available in six colors. BPA-free and dishwasher safe.\n\n## 9. Faux Fur Area Rug\nAdd warmth and luxury to any room with our faux fur area rug. Ultra-plush synthetic fibers mimic the look and feel of genuine fur. Non-slip backing keeps the rug in place. Available in 4x6 and 5x7 sizes. Machine washable on gentle cycle.\n\n## 10. LED Desk Lamp\nIlluminate your workspace with our adjustable LED desk lamp. Features three color temperatures and five brightness levels. USB charging port built into the base. Flexible gooseneck design directs light exactly where you need it. Energy-efficient LED rated for 50,000 hours.\n\n## 11. Cotton Bath Towel Set\nWrap yourself in luxury with our 6-piece cotton bath towel set. Made from 100% Turkish cotton with 600 GSM weight for maximum absorbency. Two bath towels, two hand towels, and two washcloths. Quick-drying and lint-free. Available in eight colors.\n\n## 12. Wooden Picture Frame Set\nDisplay your favorite memories with our set of five wooden picture frames. Includes assorted sizes for tabletop or wall display. Real wood construction with glass fronts. Easy-open backing for quick photo changes. Natural, white, and black finishes available.\n\n## 13. Scented Reed Diffuser\nFill your home with continuous fragrance using our scented reed diffuser. No flame or electricity needed. Natural rattan reeds absorb and release fragrance for up to 90 days. Choose from Sea Salt, Rose, or Sandalwood. Elegant glass bottle complements any decor.\n\n## 14. Cast Iron Skillet\nCook like a pro with our pre-seasoned cast iron skillet. 12-inch diameter with helper handle for easy lifting. Works on all cooktops including induction. Retains heat for perfect searing and baking. Includes care guide. With proper care, lasts a lifetime.\n\n## 15. Silk Pillowcase\nUpgrade your sleep with our 100% mulberry silk pillowcase. Naturally hypoallergenic and gentle on skin and hair. Reduces friction to prevent wrinkles and bedhead. Hidden zipper keeps pillow secure. Machine washable on delicate. Available in six colors.\n\n## 16. Floating Wall Shelf Set\nMaximize your storage with our set of three floating wall shelves. Invisible mounting hardware creates a clean, modern look. Each shelf holds up to 15 pounds. Perfect for books, plants, photos, and decor. Easy to install with included hardware. White or natural wood.\n\n## 17. Indoor Herb Garden Kit\nGrow fresh herbs year-round with our indoor herb garden kit. Includes everything you need: basil, mint, and parsley seeds, biodegradable pots, soil discs, and plant markers. Compact design fits on any windowsill. Step-by-step instructions included. Perfect for beginner gardeners.\n\n## 18. Velvet Throw Pillow\nAdd a pop of color and texture with our velvet throw pillow. Soft velvet cover with hidden zipper. Plush polyester fill holds shape over time. 18x18 inches. Spot clean only. Available in twelve rich colors to match any decor.\n\n## 19. Mason Jar Dispenser Set\nCreate a charming beverage station with our mason jar dispenser set. Two 1-gallon glass jars with metal spigots on a rustic wooden stand. Perfect for lemonade, iced tea, or infused water. Each jar has a wide mouth for easy filling and cleaning.\n\n## 20. Wool Felt Coaster Set\nProtect your surfaces in style with our set of six wool felt coasters. 4-inch diameter with 5mm thickness to absorb condensation. naturally water-resistant and heat-resistant. Felt pads on bottom prevent slipping. Available in warm earth tones. Spot clean only.`,\n artifacts: [\"product_descriptions.md\"],\n});\n\n// ── Frontend: real React dashboard component ──────────────\nconst execFrontend: Executor = (task) => ({\n success: true,\n content: `// React Dashboard Component\n// Generated by Agent Marketplace Worker\n// Self-contained — uses inline SVG charts, no external charting library\n\nimport { useState, useEffect } from \"react\";\n\ninterface DataPoint { label: string; value: number; }\n\nfunction BarChart({ data, title }: { data: DataPoint[]; title: string }) {\n const max = Math.max(...data.map(d => d.value), 1);\n return (\n

{title}

\n {data.map((d, i) => (\n

{d.label}

{d.value}

\n ))}\n

\n );\n}\n\nfunction LineChart({ data, title }: { data: DataPoint[]; title: string }) {\n const max = Math.max(...data.map(d => d.value), 1);\n const min = Math.min(...data.map(d => d.value), 0);\n const range = max - min || 1;\n const points = data.map((d, i) => {\n const x = (i / (data.length - 1)) * 300 + 20;\n const y = 180 - ((d.value - min) / range) * 160;\n return \\`\\${x},\\${y}\\`;\n }).join(\" \");\n\n return (\n

{title}

\n \n

\n );\n}\n\nfunction DataTable({ rows }: { rows: Record[] }) {\n if (!rows.length) return null;\n const cols = Object.keys(rows[0]);\n return (\n \n \n {cols.map(c => )}\n \n \n {rows.map((row, i) => (\n \n {cols.map(c => )}\n \n ))}\n \n

{c}
{row[c]}

\n );\n}\n\nfunction StatCard({ label, value, trend }: { label: string; value: string; trend: string }) {\n return (\n

{label}

{value}

{trend}

\n );\n}\n\nexport default function Dashboard() {\n const [dark, setDark] = useState(false);\n const [data, setData] = useState({ bar: [], line: [], table: [] });\n\n useEffect(() => {\n // In production, fetch from API. Here we use static data.\n setData({\n bar: [{ label: \"Mon\", value: 45 }, { label: \"Tue\", value: 72 }, { label: \"Wed\", value: 58 }, { label: \"Thu\", value: 91 }, { label: \"Fri\", value: 83 }],\n line: [{ label: \"Jan\", value: 30 }, { label: \"Feb\", value: 45 }, { label: \"Mar\", value: 38 }, { label: \"Apr\", value: 67 }, { label: \"May\", value: 82 }, { label: \"Jun\", value: 95 }],\n table: [{ id: 1, name: \"Alice\", status: \"Active\", revenue: 1250 }, { id: 2, name: \"Bob\", status: \"Pending\", revenue: 0 }, { id: 3, name: \"Carol\", status: \"Active\", revenue: 3400 }],\n });\n }, []);\n\n const bg = dark ? \"#1a1a2e\" : \"#f5f5f5\";\n return (\n

Dashboard

\n \n

\n \n \n \n \n

\n \n \n

\n \n

\n );\n}`,\n artifacts: [\"Dashboard.tsx\"],\n});\n\n// ── QA Testing: real test suite code ──────────────────────\nconst execQaTesting: Executor = (task) => ({\n success: true,\n content: `// QA Test Suite for REST API\n// Generated by Agent Marketplace Worker\n// Uses Deno test framework — no external dependencies\n\nimport { assertEquals, assertNotEquals } from \"jsr:@std/assert\";\n\nconst BASE_URL = \"http://localhost:3000/api\";\n\n// ── Auth Tests ────────────────────────────────────────────\nDeno.test(\"POST /register — creates new user\", async () => {\n const resp = await fetch(\\`\\${BASE_URL}/register\\`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ email: \"test_\" + Date.now() + \"@example.com\", password: \"testpass123\" }),\n });\n assertEquals(resp.status, 201);\n const data = await resp.json();\n assertEquals(data.success, true);\n assertNotEquals(data.user_id, undefined);\n});\n\nDeno.test(\"POST /register — rejects invalid email\", async () => {\n const resp = await fetch(\\`\\${BASE_URL}/register\\`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ email: \"notanemail\", password: \"testpass123\" }),\n });\n assertEquals(resp.status, 400);\n const data = await resp.json();\n assertEquals(data.success, false);\n});\n\nDeno.test(\"POST /register — rejects short password\", async () => {\n const resp = await fetch(\\`\\${BASE_URL}/register\\`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ email: \"test@example.com\", password: \"123\" }),\n });\n assertEquals(resp.status, 400);\n});\n\n// ── CRUD Tests ────────────────────────────────────────────\nDeno.test(\"GET /items — returns list\", async () => {\n const resp = await fetch(\\`\\${BASE_URL}/items\\`);\n assertEquals(resp.status, 200);\n const data = await resp.json();\n assertEquals(Array.isArray(data), true);\n});\n\nDeno.test(\"POST /items — creates item\", async () => {\n const resp = await fetch(\\`\\${BASE_URL}/items\\`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ name: \"Test Item\", value: 42 }),\n });\n assertEquals(resp.status, 201);\n const data = await resp.json();\n assertNotEquals(data.id, undefined);\n});\n\nDeno.test(\"GET /items/:id — returns single item\", async () => {\n // First create\n const createResp = await fetch(\\`\\${BASE_URL}/items\\`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ name: \"Get Test\", value: 1 }),\n });\n const created = await createResp.json();\n // Then get\n const resp = await fetch(\\`\\${BASE_URL}/items/\\${created.id}\\`);\n assertEquals(resp.status, 200);\n const data = await resp.json();\n assertEquals(data.name, \"Get Test\");\n});\n\nDeno.test(\"PUT /items/:id — updates item\", async () => {\n const createResp = await fetch(\\`\\${BASE_URL}/items\\`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ name: \"Update Me\", value: 1 }),\n });\n const created = await createResp.json();\n const resp = await fetch(\\`\\${BASE_URL}/items/\\${created.id}\\`, {\n method: \"PUT\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ name: \"Updated\", value: 99 }),\n });\n assertEquals(resp.status, 200);\n const data = await resp.json();\n assertEquals(data.name, \"Updated\");\n});\n\nDeno.test(\"DELETE /items/:id — removes item\", async () => {\n const createResp = await fetch(\\`\\${BASE_URL}/items\\`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ name: \"Delete Me\", value: 0 }),\n });\n const created = await createResp.json();\n const resp = await fetch(\\`\\${BASE_URL}/items/\\${created.id}\\`, { method: \"DELETE\" });\n assertEquals(resp.status, 204);\n});\n\n// ── Error Handling Tests ──────────────────────────────────\nDeno.test(\"GET /items/:id — 404 for missing item\", async () => {\n const resp = await fetch(\\`\\${BASE_URL}/items/nonexistent123\\`);\n assertEquals(resp.status, 404);\n});\n\nDeno.test(\"POST /items — 400 for missing fields\", async () => {\n const resp = await fetch(\\`\\${BASE_URL}/items\\`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({}),\n });\n assertEquals(resp.status, 400);\n});\n\nDeno.test(\"GET /protected — 401 without auth\", async () => {\n const resp = await fetch(\\`\\${BASE_URL}/protected\\`);\n assertEquals(resp.status, 401);\n});\n\nconsole.log(\"All tests defined. Run with: deno test --allow-net test_suite.ts\");`,\n artifacts: [\"test_suite.ts\"],\n});\n\n// ── Backend: real backend service code ────────────────────\nconst execBackend: Executor = (task) => ({\n success: true,\n content: `// Backend Service — Modular REST API\n// Generated by Agent Marketplace Worker\n// Uses Deno + SQLite — no external dependencies\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// ── Models ────────────────────────────────────────────────\nasync function initModels() {\n await sqlite.execute(\\`\n CREATE TABLE IF NOT EXISTS items (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n value INTEGER DEFAULT 0,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now'))\n )\n \\`);\n}\n\n// ── Controllers ───────────────────────────────────────────\nasync function createItem(name: string, value: number) {\n const id = crypto.randomUUID();\n await sqlite.execute({\n sql: \"INSERT INTO items (id, name, value) VALUES (?, ?, ?)\",\n args: [id, name, value],\n });\n return { id, name, value };\n}\n\nasync function getItems() {\n const result = await sqlite.execute({ sql: \"SELECT * FROM items ORDER BY created_at DESC\" });\n return result.rows;\n}\n\nasync function getItem(id: string) {\n const result = await sqlite.execute({ sql: \"SELECT * FROM items WHERE id = ?\", args: [id] });\n return result.rows[0] || null;\n}\n\nasync function updateItem(id: string, name: string, value: number) {\n await sqlite.execute({\n sql: \"UPDATE items SET name = ?, value = ?, updated_at = datetime('now') WHERE id = ?\",\n args: [name, value, id],\n });\n return getItem(id);\n}\n\nasync function deleteItem(id: string) {\n await sqlite.execute({ sql: \"DELETE FROM items WHERE id = ?\", args: [id] });\n}\n\n// ── Routes ────────────────────────────────────────────────\nexport default async function(req: Request): Promise {\n await initModels();\n const url = new URL(req.url);\n const path = url.pathname;\n const method = req.method;\n\n // CORS\n const headers = {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET,POST,PUT,DELETE,OPTIONS\",\n };\n\n if (method === \"OPTIONS\") return new Response(null, { headers });\n\n // POST /api/items\n if (method === \"POST\" && path === \"/api/items\") {\n const body = await req.json();\n if (!body.name) return Response.json({ error: \"name is required\" }, { status: 400, headers });\n const item = await createItem(body.name, body.value || 0);\n return Response.json(item, { status: 201, headers });\n }\n\n // GET /api/items\n if (method === \"GET\" && path === \"/api/items\") {\n const items = await getItems();\n return Response.json(items, { headers });\n }\n\n // GET /api/items/:id\n if (method === \"GET\" && path.startsWith(\"/api/items/\")) {\n const id = path.split(\"/\")[3];\n const item = await getItem(id);\n if (!item) return Response.json({ error: \"Not found\" }, { status: 404, headers });\n return Response.json(item, { headers });\n }\n\n // PUT /api/items/:id\n if (method === \"PUT\" && path.startsWith(\"/api/items/\")) {\n const id = path.split(\"/\")[3];\n const body = await req.json();\n const item = await updateItem(id, body.name, body.value);\n if (!item) return Response.json({ error: \"Not found\" }, { status: 404, headers });\n return Response.json(item, { headers });\n }\n\n // DELETE /api/items/:id\n if (method === \"DELETE\" && path.startsWith(\"/api/items/\")) {\n const id = path.split(\"/\")[3];\n await deleteItem(id);\n return new Response(null, { status: 204, headers });\n }\n\n return Response.json({ error: \"Not found\" }, { status: 404, headers });\n}`,\n artifacts: [\"server.ts\"],\n});\n\n// ── Executor registry ─────────────────────────────────────\nconst executors: Record = {\n \"api-integration\": execApiIntegration,\n \"scraping\": execScraping,\n \"automation\": execAutomation,\n \"data-cleaning\": execDataCleaning,\n \"mcp\": execMcp,\n \"web-design\": execWebDesign,\n \"webhook\": execWebhook,\n \"copywriting\": execCopywriting,\n \"frontend\": execFrontend,\n \"qa-testing\": execQaTesting,\n \"backend\": execBackend,\n};\n\nexport function executeTask(task: MarketTask): ExecutionResult {\n const executor = executors[task.category];\n if (!executor) {\n return {\n success: false,\n error: \\`No executor for category: \\${task.category}\\`,\n content: \"\",\n artifacts: [],\n };\n }\n\n try {\n return executor(task);\n } catch (err) {\n return {\n success: false,\n error: \\`Execution error: \\${err instanceof Error ? err.message : String(err)}\\`,\n content: \"\",\n artifacts: [],\n };\n }\n}\n","createdAt",["D",1784320273113],"branchVersion","branchId","384b9649-5854-42e1-9491-ac2788914e7d","id","9ea5a5a7-0d59-414f-b087-4bea05946163","agent-marketplace-worker",["D",1784319424081],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Autonomous agent worker: bid, execute, track payments","imageUrl","b3d47f1b-7707-4d8d-b9e4-88c66bd99f9d","pinnedFileId","13923cae-821d-11f1-bae2-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f71b8-e304-77df-bd9e-d3b22d582058","tursoName","9ea5a5a70d59414fb0874bea05946163","tursoHostname","9ea5a5a70d59414fb0874bea05946163-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789560070146],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_106":105,"_113":108},"org",{"_106":105,"_107":108,"_109":108,"_19":61,"_110":111,"_112":31},"branch",{"_13":95,"_38":96,"_49":48,"_97":50,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":51,"_104":105},"isOwned",17,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","kowesip967","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_49":50,"_38":51,"_44":266,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":267,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":268,"_90":269,"_92":270,"_94":31},"tree",[225,226,227,228,229,230,231,232,233,234],"files",[225,226,227,228,229,230,231,232,233,234],"counts",{"_215":69,"_216":159,"_217":69,"_218":219,"_220":221},"contents",[135,136,137,138,139,140,141,142,143,144],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":208,"_38":209,"_36":210,"_148":-5,"_47":48,"_46":211,"_150":65,"_44":212,"_13":69,"_39":26,"_41":213,"_30":31,"_154":-5,"_33":214},{"_49":201,"_38":202,"_36":203,"_148":-5,"_47":48,"_46":204,"_150":31,"_44":205,"_13":69,"_39":40,"_41":206,"_30":31,"_154":-5,"_33":207},{"_49":194,"_38":195,"_36":196,"_148":-5,"_47":48,"_46":197,"_150":65,"_44":198,"_13":159,"_39":40,"_41":199,"_30":31,"_154":-5,"_33":200},{"_49":191,"_38":34,"_36":37,"_148":-5,"_47":48,"_46":14,"_150":31,"_44":192,"_13":159,"_39":40,"_41":43,"_30":31,"_154":-5,"_33":193},{"_49":184,"_38":185,"_36":63,"_148":-5,"_47":48,"_46":186,"_150":31,"_44":187,"_13":69,"_39":188,"_41":189,"_30":31,"_154":-5,"_33":190},{"_49":177,"_38":178,"_36":179,"_148":-5,"_47":48,"_46":180,"_150":31,"_44":181,"_13":69,"_39":40,"_41":182,"_30":31,"_154":-5,"_33":183},{"_49":170,"_38":171,"_36":172,"_148":-5,"_47":48,"_46":173,"_150":65,"_44":174,"_13":159,"_39":40,"_41":175,"_30":31,"_154":-5,"_33":176},{"_49":163,"_38":164,"_36":165,"_148":-5,"_47":48,"_46":166,"_150":65,"_44":167,"_13":69,"_39":40,"_41":168,"_30":31,"_154":-5,"_33":169},{"_49":156,"_38":157,"_36":158,"_148":-5,"_47":48,"_46":159,"_150":65,"_44":160,"_13":69,"_39":40,"_41":161,"_30":31,"_154":-5,"_33":162},{"_49":145,"_38":146,"_36":147,"_148":-5,"_47":48,"_46":149,"_150":65,"_44":151,"_13":69,"_39":152,"_41":153,"_30":31,"_154":-5,"_33":155},"02b2bd5c-cbcc-4130-b2ee-b08078c5f37e","worker.ts","1604439c-821d-11f1-b98f-1607ee4eb77e","parentId",9,"latest",["D",1784319686011],"interval","// Interval worker — runs the agent cycle automatically on schedule\nimport { runAgentCycle } from \"./agent.ts\";\n\nexport default async function(): Promise {\n console.log(\"Agent worker interval triggered — starting cycle...\");\n const results = await runAgentCycle();\n\n const summary = {\n timestamp: new Date().toISOString(),\n total_tasks: results.length,\n submitted: results.filter((r) => r.action === \"submit\").length,\n bid: results.filter((r) => r.action === \"bid\").length,\n skipped: results.filter((r) => r.action === \"skip\").length,\n total_reputation_delta: results.reduce((sum, r) => sum + r.reputation_delta, 0),\n };\n\n console.log(\"Agent cycle complete:\", JSON.stringify(summary, null, 2));\n return summary as unknown as void;\n}\n","label",[146],"7d7dd733-6f64-4c2a-aac9-adcc62d0e56d","types.ts","bd610d9c-821c-11f1-b98f-1607ee4eb77e",1,["D",1784319537301],"// Shared types for the agent marketplace worker\n\nexport type Category =\n | \"web-design\"\n | \"frontend\"\n | \"backend\"\n | \"automation\"\n | \"data-cleaning\"\n | \"scraping\"\n | \"copywriting\"\n | \"qa-testing\"\n | \"mcp\"\n | \"webhook\"\n | \"api-integration\";\n\nexport type Action = \"skip\" | \"bid\" | \"claim\" | \"work\" | \"submit\";\n\nexport type PaymentState =\n | \"none\"\n | \"escrow_held\"\n | \"escrow_released\"\n | \"paid\"\n | \"disputed\"\n | \"refunded\";\n\nexport type TaskStatus =\n | \"discovered\"\n | \"bid\"\n | \"claimed\"\n | \"in_progress\"\n | \"submitted\"\n | \"verified\"\n | \"rejected\"\n | \"completed\"\n | \"expired\";\n\nexport interface MarketTask {\n task_id: string;\n title: string;\n description: string;\n category: Category;\n budget_usd: number;\n deadline_hours: number;\n required_skills: string[];\n posted_at: string;\n posted_by: string;\n escrow_held: boolean;\n}\n\nexport interface TaskScore {\n task_id: string;\n category: Category;\n fit_score: number; // 0-100\n skill_match: number; // 0-100\n time_risk: number; // 0-100 (higher = more risk)\n payout_factor: number; // 0-1\n confidence: number; // 0-100\n action: Action;\n reason: string;\n}\n\nexport interface BidRecord {\n bid_id: string;\n task_id: string;\n bid_amount_usd: number;\n proposed_hours: number;\n message: string;\n placed_at: string;\n status: \"pending\" | \"accepted\" | \"rejected\" | \"expired\";\n}\n\nexport interface DeliverableRecord {\n deliverable_id: string;\n task_id: string;\n content: string;\n artifacts: string[];\n submitted_at: string;\n verified: boolean;\n feedback: string | null;\n}\n\nexport interface PaymentRecord {\n payment_id: string;\n task_id: string;\n amount_usd: number;\n state: PaymentState;\n escrow_tx: string | null;\n release_tx: string | null;\n updated_at: string;\n}\n\nexport interface ReputationRecord {\n total_tasks: number;\n completed: number;\n rejected: number;\n expired: number;\n reputation_score: number; // 0-1000\n total_earnings_usd: number;\n updated_at: string;\n}\n\nexport interface AgentLogEntry {\n log_id: string;\n task_id: string | null;\n action: Action | \"discover\" | \"log\" | \"error\" | \"heartbeat\";\n message: string;\n metadata: string; // JSON string\n timestamp: string;\n}\n\nexport interface AgentResult {\n task_id: string;\n category: Category;\n fit_score: number;\n action: Action;\n reason: string;\n deliverable: string;\n payment_state: PaymentState;\n reputation_delta: number;\n}\n",[157],"45b47ad2-dd57-4d75-bcf8-2fcd1ce4759e","scoring.ts","d9187be2-821c-11f1-9ef7-1607ee4eb77e",5,["D",1784319583803],"// Task scoring engine — evaluates fit based on skill match, time, payout, confidence\nimport type { MarketTask, TaskScore, Action, Category } from \"./types.ts\";\nimport { AGENT_CONFIG } from \"./config.ts\";\n\nexport function scoreTask(task: MarketTask): TaskScore {\n const cat = AGENT_CONFIG.categories[task.category];\n const { thresholds } = AGENT_CONFIG;\n\n // 1. Skill match: how many required skills are in our keyword set\n const matched = task.required_skills.filter((s) =>\n AGENT_CONFIG.skill_keywords.includes(s.toLowerCase())\n );\n const skill_match = matched.length > 0\n ? Math.round((matched.length / task.required_skills.length) * 100)\n : 30; // default partial match if no keywords overlap\n\n // 2. Category weight contributes to skill match\n const catWeight = cat?.weight ?? 0;\n const weightedSkillMatch = Math.round(skill_match * 0.6 + catWeight * 100 * 0.4);\n\n // 3. Time risk: tighter deadlines = higher risk\n const avgHours = cat?.avg_hours ?? 8;\n const time_risk = Math.min(\n 100,\n Math.round((avgHours / Math.max(task.deadline_hours, 1)) * 50)\n );\n\n // 4. Payout factor: normalized 0-1 based on budget (higher = better)\n const payout_factor = Math.min(1, task.budget_usd / 150);\n\n // 5. Confidence: weighted combination\n const confidence = Math.round(\n weightedSkillMatch * 0.5 +\n (100 - time_risk) * 0.3 +\n (task.escrow_held ? 15 : 5)\n );\n\n // 6. Fit score: overall score\n const fit_score = Math.round(\n weightedSkillMatch * 0.4 +\n confidence * 0.3 +\n payout_factor * 30 +\n (100 - time_risk) * 0.0 // time risk already factored into confidence\n );\n\n // 7. Decision logic\n let action: Action = \"skip\";\n let reason = \"\";\n\n if (task.budget_usd < thresholds.min_budget_usd) {\n action = \"skip\";\n reason = `Budget $${task.budget_usd} below minimum $${thresholds.min_budget_usd}`;\n } else if (fit_score < thresholds.min_fit_score) {\n action = \"skip\";\n reason = `Fit score ${fit_score} below minimum ${thresholds.min_fit_score}`;\n } else if (confidence < thresholds.min_confidence) {\n action = \"skip\";\n reason = `Confidence ${confidence} below minimum ${thresholds.min_confidence}`;\n } else if (time_risk > thresholds.max_time_risk) {\n action = \"skip\";\n reason = `Time risk ${time_risk} above max ${thresholds.max_time_risk}`;\n } else if (fit_score >= thresholds.claim_threshold) {\n action = \"claim\";\n reason = `High fit score ${fit_score} — claiming directly`;\n } else if (fit_score >= thresholds.bid_threshold) {\n action = \"bid\";\n reason = `Good fit score ${fit_score} — placing bid`;\n } else {\n action = \"skip\";\n reason = `Fit score ${fit_score} below bid threshold ${thresholds.bid_threshold}`;\n }\n\n return {\n task_id: task.task_id,\n category: task.category,\n fit_score,\n skill_match: weightedSkillMatch,\n time_risk,\n payout_factor,\n confidence,\n action,\n reason,\n };\n}\n\nexport function rankTasks(tasks: MarketTask[]): TaskScore[] {\n return tasks\n .map((t) => scoreTask(t))\n .sort((a, b) => b.fit_score - a.fit_score);\n}\n",[164],"06d89ab4-8548-4758-8397-616604f81cc2","schema.ts","c624ad9e-821c-11f1-aac5-1607ee4eb77e",12,["D",1784320125034],"// Database schema initialization — supports dual-agent tracking\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport async function initDB(): Promise {\n await sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS tasks (\n task_id TEXT PRIMARY KEY,\n title TEXT NOT NULL,\n description TEXT,\n category TEXT NOT NULL,\n budget_usd REAL NOT NULL,\n deadline_hours INTEGER NOT NULL,\n required_skills TEXT NOT NULL,\n posted_at TEXT NOT NULL,\n posted_by TEXT NOT NULL,\n escrow_held INTEGER DEFAULT 0,\n status TEXT DEFAULT 'open',\n agent_id TEXT,\n discovered_at TEXT,\n updated_at TEXT\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS bids (\n bid_id TEXT PRIMARY KEY,\n task_id TEXT NOT NULL,\n agent_id TEXT NOT NULL,\n bid_amount_usd REAL NOT NULL,\n proposed_hours REAL NOT NULL,\n message TEXT,\n placed_at TEXT NOT NULL,\n status TEXT DEFAULT 'pending',\n FOREIGN KEY (task_id) REFERENCES tasks(task_id)\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS deliverables (\n deliverable_id TEXT PRIMARY KEY,\n task_id TEXT NOT NULL,\n agent_id TEXT NOT NULL,\n content TEXT NOT NULL,\n artifacts TEXT NOT NULL,\n submitted_at TEXT NOT NULL,\n verified INTEGER DEFAULT 0,\n feedback TEXT,\n FOREIGN KEY (task_id) REFERENCES tasks(task_id)\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS payments (\n payment_id TEXT PRIMARY KEY,\n task_id TEXT NOT NULL,\n agent_id TEXT NOT NULL,\n amount_usd REAL NOT NULL,\n state TEXT DEFAULT 'none',\n escrow_tx TEXT,\n release_tx TEXT,\n updated_at TEXT NOT NULL,\n FOREIGN KEY (task_id) REFERENCES tasks(task_id)\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS reputation (\n id INTEGER PRIMARY KEY,\n agent_id TEXT NOT NULL,\n total_tasks INTEGER DEFAULT 0,\n completed INTEGER DEFAULT 0,\n rejected INTEGER DEFAULT 0,\n expired INTEGER DEFAULT 0,\n reputation_score REAL DEFAULT 100,\n total_earnings_usd REAL DEFAULT 0,\n updated_at TEXT NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS agent_logs (\n log_id TEXT PRIMARY KEY,\n task_id TEXT,\n agent_id TEXT,\n action TEXT NOT NULL,\n message TEXT NOT NULL,\n metadata TEXT DEFAULT '{}',\n timestamp TEXT NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS scores (\n score_id TEXT PRIMARY KEY,\n task_id TEXT NOT NULL,\n agent_id TEXT NOT NULL,\n category TEXT NOT NULL,\n fit_score REAL NOT NULL,\n skill_match REAL NOT NULL,\n time_risk REAL NOT NULL,\n payout_factor REAL NOT NULL,\n confidence REAL NOT NULL,\n action TEXT NOT NULL,\n reason TEXT,\n scored_at TEXT NOT NULL\n )`,\n },\n ]);\n\n // Seed reputation rows for each agent if not exists\n for (const agentId of [\"agent-alpha\", \"agent-beta\"]) {\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO reputation (id, agent_id, total_tasks, completed, rejected, expired, reputation_score, total_earnings_usd, updated_at)\n VALUES (?, ?, 0, 0, 0, 0, 100, 0, ?)`,\n args: [agentId === \"agent-alpha\" ? 1 : 2, agentId, new Date().toISOString()],\n });\n }\n}\n",[171],"5347f7c3-9496-425b-b0fd-763cba0e8ebb","marketplace.ts","d26f4564-821c-11f1-ac20-1607ee4eb77e",4,["D",1784319572625],"// Marketplace discovery — fetches or generates available tasks\nimport type { MarketTask, Category } from \"./types.ts\";\nimport { AGENT_CONFIG, genId, now } from \"./config.ts\";\n\nconst MOCK_TASKS: MarketTask[] = [\n {\n task_id: genId(\"task\"),\n title: \"Build a REST API endpoint for user registration\",\n description: \"Create a POST /register endpoint with email validation, password hashing, and JSON response. TypeScript/Deno preferred.\",\n category: \"api-integration\",\n budget_usd: 75,\n deadline_hours: 24,\n required_skills: [\"typescript\", \"rest\", \"api\", \"node\"],\n posted_at: now(),\n posted_by: \"client_alpha\",\n escrow_held: true,\n },\n {\n task_id: genId(\"task\"),\n title: \"Scrape product listings from e-commerce site\",\n description: \"Write a scraper to extract product names, prices, and availability from a public e-commerce page. Output as JSON array.\",\n category: \"scraping\",\n budget_usd: 50,\n deadline_hours: 12,\n required_skills: [\"scraper\", \"json\", \"data\"],\n posted_at: now(),\n posted_by: \"client_beta\",\n escrow_held: true,\n },\n {\n task_id: genId(\"task\"),\n title: \"Set up automated cron job for data sync\",\n description: \"Configure a scheduled job that syncs data between two APIs every hour. Handle errors and log results.\",\n category: \"automation\",\n budget_usd: 40,\n deadline_hours: 48,\n required_skills: [\"cron\", \"automation\", \"api\"],\n posted_at: now(),\n posted_by: \"client_gamma\",\n escrow_held: false,\n },\n {\n task_id: genId(\"task\"),\n title: \"Clean and deduplicate customer CSV data\",\n description: \"Remove duplicates, fix formatting, standardize phone numbers and addresses in a 5000-row CSV file.\",\n category: \"data-cleaning\",\n budget_usd: 30,\n deadline_hours: 24,\n required_skills: [\"data\", \"json\"],\n posted_at: now(),\n posted_by: \"client_delta\",\n escrow_held: true,\n },\n {\n task_id: genId(\"task\"),\n title: \"Create MCP server tool for weather data\",\n description: \"Build an MCP-compatible tool that fetches weather data from a public API and returns structured results.\",\n category: \"mcp\",\n budget_usd: 90,\n deadline_hours: 36,\n required_skills: [\"mcp\", \"typescript\", \"api\"],\n posted_at: now(),\n posted_by: \"client_epsilon\",\n escrow_held: true,\n },\n {\n task_id: genId(\"task\"),\n title: \"Design landing page for SaaS startup\",\n description: \"Create a modern responsive landing page with hero, features, pricing, and CTA sections. HTML/CSS.\",\n category: \"web-design\",\n budget_usd: 120,\n deadline_hours: 72,\n required_skills: [\"html\", \"css\", \"react\"],\n posted_at: now(),\n posted_by: \"client_zeta\",\n escrow_held: true,\n },\n {\n task_id: genId(\"task\"),\n title: \"Write webhook receiver for Stripe payment events\",\n description: \"Set up a webhook endpoint that receives Stripe events, verifies signatures, and logs payment status changes.\",\n category: \"webhook\",\n budget_usd: 60,\n deadline_hours: 18,\n required_skills: [\"webhook\", \"typescript\", \"api\"],\n posted_at: now(),\n posted_by: \"client_eta\",\n escrow_held: true,\n },\n {\n task_id: genId(\"task\"),\n title: \"Write product descriptions for 20 items\",\n description: \"Write compelling SEO-friendly product descriptions for a home goods store. 100-150 words each.\",\n category: \"copywriting\",\n budget_usd: 8,\n deadline_hours: 24,\n required_skills: [\"copywriting\"],\n posted_at: now(),\n posted_by: \"client_theta\",\n escrow_held: false,\n },\n {\n task_id: genId(\"task\"),\n title: \"Build React dashboard with charts\",\n description: \"Create a frontend dashboard with bar charts, line charts, and a data table. React + TypeScript.\",\n category: \"frontend\",\n budget_usd: 100,\n deadline_hours: 48,\n required_skills: [\"react\", \"typescript\", \"css\"],\n posted_at: now(),\n posted_by: \"client_iota\",\n escrow_held: true,\n },\n {\n task_id: genId(\"task\"),\n title: \"Write QA test suite for REST API\",\n description: \"Write comprehensive integration tests covering auth, CRUD operations, and error handling for a REST API.\",\n category: \"qa-testing\",\n budget_usd: 55,\n deadline_hours: 36,\n required_skills: [\"testing\", \"rest\", \"api\"],\n posted_at: now(),\n posted_by: \"client_kappa\",\n escrow_held: true,\n },\n];\n\nexport async function discoverTasks(): Promise {\n // If a marketplace URL is configured, fetch from it\n if (AGENT_CONFIG.marketplace_url) {\n try {\n const resp = await fetch(AGENT_CONFIG.marketplace_url);\n if (resp.ok) {\n const data = await resp.json();\n if (Array.isArray(data)) {\n return data as MarketTask[];\n }\n if (data.tasks && Array.isArray(data.tasks)) {\n return data.tasks as MarketTask[];\n }\n }\n } catch {\n // Fall through to mock data\n }\n }\n\n // Default: return mock tasks (simulating a marketplace registry)\n return MOCK_TASKS;\n}\n",[178],"da87c1c6-903d-4c65-8f23-f10107de726f","main.ts",8,["D",1784319681902],"http","// HTTP dashboard — view agent status, tasks, reputation, logs, and trigger cycles\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { initDB } from \"./schema.ts\";\nimport { runAgentCycle } from \"./agent.ts\";\n\nexport default async function(req: Request): Promise {\n await initDB();\n\n const url = new URL(req.url);\n const path = url.pathname.replace(/^\\/+/, \"\");\n const headers = { \"Content-Type\": \"application/json\" };\n\n // ── POST /cycle — trigger an agent cycle ────────────────\n if (req.method === \"POST\" && path === \"cycle\") {\n const results = await runAgentCycle();\n return new Response(JSON.stringify({\n status: \"ok\",\n cycle_complete: true,\n results,\n count: results.length,\n }, null, 2), { headers });\n }\n\n // ── GET /status — agent overview ────────────────────────\n if (req.method === \"GET\" && (path === \"status\" || path === \"\")) {\n const rep = await sqlite.execute({\n sql: `SELECT * FROM reputation WHERE id = 1`,\n });\n const taskStats = await sqlite.execute({\n sql: `SELECT status, COUNT(*) as count FROM tasks GROUP BY status`,\n });\n const payStats = await sqlite.execute({\n sql: `SELECT state, COUNT(*) as count, COALESCE(SUM(amount_usd), 0) as total FROM payments GROUP BY state`,\n });\n const recentLogs = await sqlite.execute({\n sql: `SELECT * FROM agent_logs ORDER BY timestamp DESC LIMIT 20`,\n });\n\n return new Response(JSON.stringify({\n agent: \"agent-marketplace-worker\",\n reputation: rep.rows[0] || { reputation_score: 100, total_tasks: 0, completed: 0 },\n task_status_breakdown: taskStats.rows,\n payment_state_breakdown: payStats.rows,\n recent_logs: recentLogs.rows,\n timestamp: new Date().toISOString(),\n }, null, 2), { headers });\n }\n\n // ── GET /tasks — list all tasks ─────────────────────────\n if (req.method === \"GET\" && path === \"tasks\") {\n const tasks = await sqlite.execute({\n sql: `SELECT task_id, title, category, budget_usd, status, escrow_held, updated_at FROM tasks ORDER BY updated_at DESC`,\n });\n return new Response(JSON.stringify({\n count: tasks.rows.length,\n tasks: tasks.rows,\n }, null, 2), { headers });\n }\n\n // ── GET /scores — list all scores ───────────────────────\n if (req.method === \"GET\" && path === \"scores\") {\n const scores = await sqlite.execute({\n sql: `SELECT * FROM scores ORDER BY fit_score DESC`,\n });\n return new Response(JSON.stringify({\n count: scores.rows.length,\n scores: scores.rows,\n }, null, 2), { headers });\n }\n\n // ── GET /bids — list all bids ───────────────────────────\n if (req.method === \"GET\" && path === \"bids\") {\n const bids = await sqlite.execute({\n sql: `SELECT * FROM bids ORDER BY placed_at DESC`,\n });\n return new Response(JSON.stringify({\n count: bids.rows.length,\n bids: bids.rows,\n }, null, 2), { headers });\n }\n\n // ── GET /deliverables — list deliverables ───────────────\n if (req.method === \"GET\" && path === \"deliverables\") {\n const dels = await sqlite.execute({\n sql: `SELECT d.*, t.title as task_title FROM deliverables d JOIN tasks t ON d.task_id = t.task_id ORDER BY d.submitted_at DESC`,\n });\n return new Response(JSON.stringify({\n count: dels.rows.length,\n deliverables: dels.rows,\n }, null, 2), { headers });\n }\n\n // ── GET /payments — list payments ───────────────────────\n if (req.method === \"GET\" && path === \"payments\") {\n const pays = await sqlite.execute({\n sql: `SELECT p.*, t.title as task_title FROM payments p JOIN tasks t ON p.task_id = t.task_id ORDER BY p.updated_at DESC`,\n });\n return new Response(JSON.stringify({\n count: pays.rows.length,\n payments: pays.rows,\n }, null, 2), { headers });\n }\n\n // ── GET /logs — recent logs ─────────────────────────────\n if (req.method === \"GET\" && path === \"logs\") {\n const limit = url.searchParams.get(\"limit\") || \"50\";\n const logs = await sqlite.execute({\n sql: `SELECT * FROM agent_logs ORDER BY timestamp DESC LIMIT ?`,\n args: [parseInt(limit)],\n });\n return new Response(JSON.stringify({\n count: logs.rows.length,\n logs: logs.rows,\n }, null, 2), { headers });\n }\n\n // ── GET /reputation — reputation details ────────────────\n if (req.method === \"GET\" && path === \"reputation\") {\n const rep = await sqlite.execute({\n sql: `SELECT * FROM reputation WHERE id = 1`,\n });\n return new Response(JSON.stringify(rep.rows[0] || {}, null, 2), { headers });\n }\n\n // ── Root — help ─────────────────────────────────────────\n return new Response(JSON.stringify({\n agent: \"agent-marketplace-worker\",\n endpoints: {\n \"GET /\": \"This help\",\n \"GET /status\": \"Agent overview with reputation, task stats, recent logs\",\n \"GET /tasks\": \"All discovered tasks\",\n \"GET /scores\": \"All task scores\",\n \"GET /bids\": \"All bids\",\n \"GET /deliverables\": \"All submitted deliverables\",\n \"GET /payments\": \"All payment records\",\n \"GET /logs?limit=50\": \"Recent agent logs\",\n \"GET /reputation\": \"Reputation score and earnings\",\n \"POST /cycle\": \"Trigger an agent cycle manually\",\n },\n }, null, 2), { headers });\n}\n",[185],"6acdf576-ef3e-469d-bbf7-091ede2a44e1",["D",1784320273113],[34],"142a624b-233e-4436-9201-c24e076aa307","config.ts","c1551236-821c-11f1-b727-1607ee4eb77e",11,["D",1784320116390],"// Agent configuration: categories, skill weights, thresholds, dual-agent setup\nimport type { Category } from \"./types.ts\";\n\nexport interface AgentProfile {\n id: string;\n name: string;\n specialties: Category[];\n fallback: Category[]; // can handle but not primary\n}\n\n// Two agents with complementary skill sets — no overlap on primary specialties\nexport const AGENTS: AgentProfile[] = [\n {\n id: \"agent-alpha\",\n name: \"Agent Alpha\",\n specialties: [\"frontend\", \"web-design\", \"copywriting\", \"data-cleaning\", \"qa-testing\"],\n fallback: [\"backend\"],\n },\n {\n id: \"agent-beta\",\n name: \"Agent Beta\",\n specialties: [\"backend\", \"api-integration\", \"automation\", \"scraping\", \"webhook\", \"mcp\"],\n fallback: [\"frontend\"],\n },\n];\n\nexport const AGENT_CONFIG = {\n categories: {\n \"web-design\": { weight: 0.75, avg_hours: 4 },\n \"frontend\": { weight: 0.85, avg_hours: 6 },\n \"backend\": { weight: 0.9, avg_hours: 8 },\n \"automation\": { weight: 0.95, avg_hours: 3 },\n \"data-cleaning\": { weight: 0.8, avg_hours: 2 },\n \"scraping\": { weight: 0.9, avg_hours: 3 },\n \"copywriting\": { weight: 0.7, avg_hours: 2 },\n \"qa-testing\": { weight: 0.8, avg_hours: 4 },\n \"mcp\": { weight: 0.85, avg_hours: 5 },\n \"webhook\": { weight: 0.9, avg_hours: 2 },\n \"api-integration\": { weight: 0.95, avg_hours: 4 },\n } as Record,\n\n skill_keywords: [\n \"typescript\", \"javascript\", \"react\", \"node\", \"deno\", \"sql\", \"sqlite\",\n \"rest\", \"graphql\", \"html\", \"css\", \"json\", \"python\", \"webhook\",\n \"cron\", \"automation\", \"scraper\", \"api\", \"data\", \"testing\", \"mcp\",\n ],\n\n thresholds: {\n min_fit_score: 50,\n min_confidence: 55,\n min_budget_usd: 5,\n max_time_risk: 75,\n bid_threshold: 65,\n claim_threshold: 75,\n },\n\n initial_reputation: 100,\n\n // Self-hosted marketplace — uses this val's own HTTP endpoint as the task board\n // No external API needed. Free. Set MARKETPLACE_URL to use an external board instead.\n marketplace_url: Deno.env.get(\"MARKETPLACE_URL\") || null,\n} as const;\n\nexport function genId(prefix: string = \"id\"): string {\n return `${prefix}_${crypto.randomUUID().split(\"-\").join(\"\")}`;\n}\n\nexport function now(): string {\n return new Date().toISOString();\n}\n\n// Find which agent should handle a task\nexport function findAgentForCategory(category: Category): AgentProfile {\n for (const agent of AGENTS) {\n if (agent.specialties.includes(category)) return agent;\n }\n for (const agent of AGENTS) {\n if (agent.fallback.includes(category)) return agent;\n }\n return AGENTS[0]; // default to alpha\n}\n",[195],"2829d84f-dfaf-4a6e-abc8-89d84d1c48e2","agent.ts","09847e02-821d-11f1-b98f-1607ee4eb77e",7,["D",1784319665035],"// Core agent loop — discover, score, bid/claim, execute, submit, track\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { initDB } from \"./schema.ts\";\nimport { discoverTasks } from \"./marketplace.ts\";\nimport { rankTasks } from \"./scoring.ts\";\nimport { executeTask } from \"./executor.ts\";\nimport { genId, now, AGENT_CONFIG } from \"./config.ts\";\nimport type { MarketTask, TaskScore, AgentResult, PaymentState } from \"./types.ts\";\n\n// ── Logging ──────────────────────────────────────────────\nexport async function log(\n action: string,\n message: string,\n taskId: string | null = null,\n metadata: Record = {},\n): Promise {\n await sqlite.execute({\n sql: `INSERT INTO agent_logs (log_id, task_id, action, message, metadata, timestamp)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [genId(\"log\"), taskId, action, message, JSON.stringify(metadata), now()],\n });\n}\n\n// ── Persist discovered task ───────────────────────────────\nasync function persistTask(task: MarketTask): Promise {\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO tasks\n (task_id, title, description, category, budget_usd, deadline_hours, required_skills, posted_at, posted_by, escrow_held, status, discovered_at, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, 'discovered', ?, ?)`,\n args: [\n task.task_id, task.title, task.description, task.category,\n task.budget_usd, task.deadline_hours, JSON.stringify(task.required_skills),\n task.posted_at, task.posted_by, task.escrow_held ? 1 : 0,\n now(), now(),\n ],\n });\n}\n\n// ── Persist score ─────────────────────────────────────────\nasync function persistScore(score: TaskScore): Promise {\n await sqlite.execute({\n sql: `INSERT INTO scores (score_id, task_id, category, fit_score, skill_match, time_risk, payout_factor, confidence, action, reason, scored_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n genId(\"score\"), score.task_id, score.category, score.fit_score,\n score.skill_match, score.time_risk, score.payout_factor,\n score.confidence, score.action, score.reason, now(),\n ],\n });\n}\n\n// ── Place a bid ───────────────────────────────────────────\nasync function placeBid(task: MarketTask, score: TaskScore): Promise {\n const bidId = genId(\"bid\");\n const cat = AGENT_CONFIG.categories[task.category];\n const proposedHours = cat?.avg_hours ?? 8;\n const bidAmount = task.budget_usd;\n\n await sqlite.execute({\n sql: `INSERT INTO bids (bid_id, task_id, bid_amount_usd, proposed_hours, message, placed_at, status)\n VALUES (?, ?, ?, ?, ?, ?, 'pending')`,\n args: [\n bidId, task.task_id, bidAmount, proposedHours,\n `Automated bid: category=${task.category} fit=${score.fit_score} confidence=${score.confidence}. Ready to deliver within ${proposedHours}h.`,\n now(),\n ],\n });\n\n await sqlite.execute({\n sql: `UPDATE tasks SET status = 'bid', updated_at = ? WHERE task_id = ?`,\n args: [now(), task.task_id],\n });\n\n await log(\"bid\", `Bid placed: $${bidAmount} for \"${task.title}\"`, task.task_id, { bidId, bidAmount, proposedHours });\n}\n\n// ── Claim a task directly ─────────────────────────────────\nasync function claimTask(task: MarketTask): Promise {\n await sqlite.execute({\n sql: `UPDATE tasks SET status = 'claimed', updated_at = ? WHERE task_id = ?`,\n args: [now(), task.task_id],\n });\n\n if (task.escrow_held) {\n await sqlite.execute({\n sql: `INSERT INTO payments (payment_id, task_id, amount_usd, state, escrow_tx, release_tx, updated_at)\n VALUES (?, ?, ?, 'escrow_held', ?, NULL, ?)`,\n args: [genId(\"pay\"), task.task_id, task.budget_usd, genId(\"escrow_tx\"), now()],\n });\n await log(\"claim\", `Task claimed with escrow: \"${task.title}\" — $${task.budget_usd} in escrow`, task.task_id, { escrow: true });\n } else {\n await log(\"claim\", `Task claimed (no escrow): \"${task.title}\"`, task.task_id, { escrow: false });\n }\n}\n\n// ── Execute and submit deliverable ────────────────────────\nasync function executeAndSubmit(task: MarketTask): Promise {\n await sqlite.execute({\n sql: `UPDATE tasks SET status = 'in_progress', updated_at = ? WHERE task_id = ?`,\n args: [now(), task.task_id],\n });\n await log(\"work\", `Starting execution: \"${task.title}\"`, task.task_id);\n\n const result = executeTask(task);\n\n if (!result.success) {\n await log(\"error\", `Execution failed: ${result.error}`, task.task_id);\n await sqlite.execute({\n sql: `UPDATE tasks SET status = 'rejected', updated_at = ? WHERE task_id = ?`,\n args: [now(), task.task_id],\n });\n return {\n task_id: task.task_id,\n category: task.category,\n fit_score: 0,\n action: \"skip\",\n reason: `Execution failed: ${result.error}`,\n deliverable: \"\",\n payment_state: \"none\",\n reputation_delta: -5,\n };\n }\n\n const deliverableId = genId(\"del\");\n await sqlite.execute({\n sql: `INSERT INTO deliverables (deliverable_id, task_id, content, artifacts, submitted_at, verified, feedback)\n VALUES (?, ?, ?, ?, ?, 0, NULL)`,\n args: [deliverableId, task.task_id, result.content, JSON.stringify(result.artifacts), now()],\n });\n\n await sqlite.execute({\n sql: `UPDATE tasks SET status = 'submitted', updated_at = ? WHERE task_id = ?`,\n args: [now(), task.task_id],\n });\n\n // Auto-verify in mock mode\n const feedback = \"Deliverable meets requirements. Approved.\";\n await sqlite.execute({\n sql: `UPDATE deliverables SET verified = 1, feedback = ? WHERE deliverable_id = ?`,\n args: [feedback, deliverableId],\n });\n\n // Handle payment\n let paymentState: PaymentState = \"paid\";\n if (task.escrow_held) {\n await sqlite.execute({\n sql: `UPDATE payments SET state = 'escrow_released', release_tx = ?, updated_at = ? WHERE task_id = ?`,\n args: [genId(\"release_tx\"), now(), task.task_id],\n });\n await sqlite.execute({\n sql: `UPDATE payments SET state = 'paid', updated_at = ? WHERE task_id = ?`,\n args: [now(), task.task_id],\n });\n } else {\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO payments (payment_id, task_id, amount_usd, state, escrow_tx, release_tx, updated_at)\n VALUES (?, ?, ?, 'paid', NULL, ?, ?)`,\n args: [genId(\"pay\"), task.task_id, task.budget_usd, genId(\"pay_tx\"), now()],\n });\n }\n\n // Complete task\n await sqlite.execute({\n sql: `UPDATE tasks SET status = 'completed', updated_at = ? WHERE task_id = ?`,\n args: [now(), task.task_id],\n });\n\n // Update reputation\n const repDelta = 10;\n await sqlite.execute({\n sql: `UPDATE reputation\n SET total_tasks = total_tasks + 1,\n completed = completed + 1,\n reputation_score = MIN(reputation_score + ?, 1000),\n total_earnings_usd = total_earnings_usd + ?,\n updated_at = ?\n WHERE id = 1`,\n args: [repDelta, task.budget_usd, now()],\n });\n\n await log(\"submit\", `Deliverable submitted and verified: \"${task.title}\" — payment: ${paymentState}`, task.task_id, {\n deliverableId, paymentState, earnings: task.budget_usd,\n });\n\n return {\n task_id: task.task_id,\n category: task.category,\n fit_score: 0,\n action: \"submit\",\n reason: \"Task completed and deliverable verified\",\n deliverable: result.content,\n payment_state: paymentState,\n reputation_delta: repDelta,\n };\n}\n\n// ── Main agent cycle ──────────────────────────────────────\nexport async function runAgentCycle(): Promise {\n await initDB();\n await log(\"heartbeat\", \"Agent cycle started\", null);\n\n // 1. Discover\n const tasks = await discoverTasks();\n await log(\"discover\", `Discovered ${tasks.length} tasks from marketplace`, null, { count: tasks.length });\n\n // 2. Persist\n for (const task of tasks) {\n await persistTask(task);\n }\n\n // 3. Score and rank\n const scores = rankTasks(tasks);\n const results: AgentResult[] = [];\n\n // 4. Process\n for (const score of scores) {\n await persistScore(score);\n const task = tasks.find((t) => t.task_id === score.task_id)!;\n\n if (score.action === \"skip\") {\n await log(\"skip\", `Skipped: ${score.reason}`, task.task_id, { fit_score: score.fit_score });\n results.push({\n task_id: task.task_id,\n category: task.category,\n fit_score: score.fit_score,\n action: \"skip\",\n reason: score.reason,\n deliverable: \"\",\n payment_state: \"none\",\n reputation_delta: 0,\n });\n continue;\n }\n\n if (score.action === \"bid\") {\n await placeBid(task, score);\n results.push({\n task_id: task.task_id,\n category: task.category,\n fit_score: score.fit_score,\n action: \"bid\",\n reason: score.reason,\n deliverable: \"\",\n payment_state: task.escrow_held ? \"escrow_held\" : \"none\",\n reputation_delta: 0,\n });\n continue;\n }\n\n if (score.action === \"claim\") {\n await claimTask(task);\n const result = await executeAndSubmit(task);\n result.fit_score = score.fit_score;\n results.push(result);\n }\n }\n\n // 5. Process pending bids (auto-accept in mock mode)\n const pendingBids = await sqlite.execute({\n sql: `SELECT b.bid_id, b.task_id, t.title, t.category, t.budget_usd,\n t.deadline_hours, t.required_skills, t.posted_at, t.posted_by, t.escrow_held\n FROM bids b JOIN tasks t ON b.task_id = t.task_id\n WHERE b.status = 'pending'`,\n });\n\n for (const row of pendingBids.rows) {\n await sqlite.execute({\n sql: `UPDATE bids SET status = 'accepted' WHERE bid_id = ?`,\n args: [row.bid_id],\n });\n\n const bidTask: MarketTask = {\n task_id: row.task_id as string,\n title: row.title as string,\n description: \"\",\n category: row.category as MarketTask[\"category\"],\n budget_usd: row.budget_usd as number,\n deadline_hours: row.deadline_hours as number,\n required_skills: JSON.parse(row.required_skills as string),\n posted_at: row.posted_at as string,\n posted_by: row.posted_by as string,\n escrow_held: !!row.escrow_held,\n };\n\n await claimTask(bidTask);\n const result = await executeAndSubmit(bidTask);\n results.push(result);\n await log(\"claim\", `Bid accepted for \"${bidTask.title}\" — executing`, bidTask.task_id, { bid_id: row.bid_id });\n }\n\n await log(\"heartbeat\", `Agent cycle complete: ${results.length} results`, null, {\n total: results.length,\n bid: results.filter((r) => r.action === \"bid\").length,\n skip: results.filter((r) => r.action === \"skip\").length,\n submit: results.filter((r) => r.action === \"submit\").length,\n });\n\n return results;\n}\n",[202],"c84a4763-5d9d-42cb-9d84-0b8668bb3fe3","README.md","5f42a35a-821d-11f1-ad95-1607ee4eb77e",10,["D",1784319808899],"# Agent Marketplace Worker\n\nAutonomous AI agent that discovers paid tasks from a marketplace registry, scores them by fit, bids/claims, executes work autonomously, submits deliverables, and tracks escrow/payments with reputation tracking.\n\n## Architecture\n\n```\n┌─────────────────────────────────────────────────┐\n│ worker.ts (interval) │\n│ Runs every 15 min → triggers runAgentCycle() │\n└──────────────────────┬──────────────────────────┘\n │\n ▼\n┌──────────────────────────────────────────────────┐\n│ agent.ts (core loop) │\n│ discover → score → bid/claim → execute → submit │\n│ → track payment → update reputation → log │\n└──────┬───────┬───────┬───────┬───────┬───────────┘\n │ │ │ │ │\n ▼ ▼ ▼ ▼ ▼\n marketplace scoring executor SQLite schema.ts\n .ts .ts .ts (logs, tasks,\n (discover) (rank) (produce bids, payments,\n deliver- reputation)\n ables)\n \n┌──────────────────────────────────────────────────┐\n│ main.ts (HTTP dashboard) │\n│ GET /status — agent overview │\n│ GET /tasks — all discovered tasks │\n│ GET /scores — task fit scores │\n│ GET /bids — bid history │\n│ GET /deliverables — submitted work │\n│ GET /payments — escrow & payment records │\n│ GET /logs — audit trail │\n│ GET /reputation — score & earnings │\n│ POST /cycle — trigger a cycle manually │\n└──────────────────────────────────────────────────┘\n```\n\n## Files\n\n| File | Type | Purpose |\n|------|------|---------|\n| `types.ts` | script | Shared TypeScript interfaces |\n| `config.ts` | script | Category weights, skill keywords, decision thresholds |\n| `schema.ts` | script | SQLite table creation + seeding |\n| `marketplace.ts` | script | Task discovery (mock registry or external URL via `MARKETPLACE_URL` env) |\n| `scoring.ts` | script | Fit scoring engine: skill match + time risk + payout + confidence |\n| `executor.ts` | script | Per-category execution handlers producing JSON deliverables |\n| `agent.ts` | script | Core loop: discover → score → bid/claim → execute → submit → track |\n| `main.ts` | http | JSON dashboard API |\n| `worker.ts` | interval | Auto-runs the cycle every 15 minutes |\n\n## Task Selection Logic\n\nEach discovered task is scored 0–100:\n\n| Factor | Weight | Description |\n|--------|--------|-------------|\n| Skill match | 40% | Required skills ∩ agent keywords + category weight |\n| Confidence | 30% | Skill match × 50% + time safety × 30% + escrow bonus |\n| Payout | 30% | Budget normalized to 0–1 (capped at $150) |\n\n**Decision thresholds:**\n- `< 55 fit` or `< 60 confidence` or `< $10 budget` → **skip**\n- `70–79 fit` → **bid** (place bid, wait for acceptance)\n- `≥ 80 fit` → **claim** (claim directly, execute immediately)\n\n## Supported Categories\n\n`api-integration` · `automation` · `backend` · `copywriting` · `data-cleaning` · `frontend` · `mcp` · `qa-testing` · `scraping` · `web-design` · `webhook`\n\n## Database Tables\n\n- **tasks** — discovered tasks with status tracking\n- **bids** — bid records with pending/accepted/rejected status\n- **deliverables** — submitted work with verification state\n- **payments** — escrow hold → release → paid lifecycle\n- **reputation** — cumulative score (0–1000), earnings, completion stats\n- **agent_logs** — full audit trail of every action\n- **scores** — persisted task fit scores for analysis\n\n## Configuration\n\nSet `MARKETPLACE_URL` env var to fetch tasks from a live registry instead of mock data:\n\n👉 Add MARKETPLACE_URL here: https://www.val.town/x/kowesip967/agent-marketplace-worker/environment-variables?key=MARKETPLACE_URL\n\n## Live Endpoints\n\n- **Dashboard**: see `main.ts` endpoint URL from file listing\n- **Trigger cycle**: `POST` to the endpoint with path `/cycle`\n- **Status**: `GET` to the endpoint with path `/status`\n\n## Payment Flow\n\n```\nTask claimed with escrow → escrow_held\n → Deliverable submitted → auto-verified\n → escrow_released → paid\n → reputation += 10, earnings += budget\n```\n\nTasks without escrow go straight to `paid` after verification.\n",[209],"pulls","branches","forks","envVars",{"_222":69,"_224":69},"connections",{"_222":69,"_223":69},"count","unfilledCount","emptyCount",{"_49":208,"_38":209,"_36":210,"_148":-5,"_47":48,"_46":211,"_150":65,"_44":263,"_13":69,"_39":26,"_41":213,"_30":31,"_154":-5,"_236":264,"_33":265},{"_49":201,"_38":202,"_36":203,"_148":-5,"_47":48,"_46":204,"_150":31,"_44":260,"_13":69,"_39":40,"_41":206,"_30":31,"_154":-5,"_236":261,"_33":262},{"_49":194,"_38":195,"_36":196,"_148":-5,"_47":48,"_46":197,"_150":65,"_44":257,"_13":159,"_39":40,"_41":199,"_30":31,"_154":-5,"_236":258,"_33":259},{"_49":191,"_38":34,"_36":37,"_148":-5,"_47":48,"_46":14,"_150":31,"_44":254,"_13":159,"_39":40,"_41":43,"_30":31,"_154":-5,"_236":255,"_33":256},{"_49":184,"_38":185,"_36":63,"_148":-5,"_47":48,"_46":186,"_150":31,"_44":251,"_13":69,"_39":188,"_41":189,"_30":31,"_154":-5,"_236":252,"_33":253},{"_49":177,"_38":178,"_36":179,"_148":-5,"_47":48,"_46":180,"_150":31,"_44":248,"_13":69,"_39":40,"_41":182,"_30":31,"_154":-5,"_236":249,"_33":250},{"_49":170,"_38":171,"_36":172,"_148":-5,"_47":48,"_46":173,"_150":65,"_44":245,"_13":159,"_39":40,"_41":175,"_30":31,"_154":-5,"_236":246,"_33":247},{"_49":163,"_38":164,"_36":165,"_148":-5,"_47":48,"_46":166,"_150":65,"_44":242,"_13":69,"_39":40,"_41":168,"_30":31,"_154":-5,"_236":243,"_33":244},{"_49":156,"_38":157,"_36":158,"_148":-5,"_47":48,"_46":159,"_150":65,"_44":239,"_13":69,"_39":40,"_41":161,"_30":31,"_154":-5,"_236":240,"_33":241},{"_49":145,"_38":146,"_36":147,"_148":-5,"_47":48,"_46":149,"_150":65,"_44":235,"_13":69,"_39":152,"_41":153,"_30":31,"_154":-5,"_236":237,"_33":238},["D",1784319686011],"children",[],[146],["D",1784319537301],[],[157],["D",1784319583803],[],[164],["D",1784320125034],[],[171],["D",1784319572625],[],[178],["D",1784319681902],[],[185],["D",1784320273113],[],[34],["D",1784320116390],[],[195],["D",1784319665035],[],[202],["D",1784319808899],[],[209],["D",1784319424081],["D",1789560070146],{"_106":105,"_113":108},{"_106":105,"_107":108,"_109":108,"_19":61,"_110":111,"_112":31},{"_13":95,"_38":96,"_49":48,"_97":50,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":51,"_104":105},"ctx",{"_88":-5,"_132":304,"_305":306,"_307":308,"_309":31,"_310":31,"_311":31,"_312":65,"_313":-5,"_314":-7,"_315":-7,"_316":69,"_317":31,"_318":31,"_319":-5,"_320":31,"_321":31,"_322":31,"_323":-5},"ENV",{"_275":276,"_277":278,"_279":96,"_280":281,"_282":283,"_284":285,"_286":287,"_288":289,"_290":291,"_292":293,"_294":295,"_296":297,"_298":299,"_300":301,"_302":303},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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"]

Diff · v13