[{"_1":2,"_186":-5,"_187":-5},"loaderData",{"_3":4,"_95":96},"root",{"_5":6,"_36":37,"_68":69},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isBusinessOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65,"_66":67},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","dea2103bd25002ab40e5710f03626b3055cfecf7","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_70":71},"__internal_clerk_state",{"_72":73,"_74":47,"_75":76,"_77":76,"_78":20,"_79":76,"_80":76,"_81":76,"_82":76,"_83":84,"_93":20,"_94":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_85":20,"_19":20,"_86":76,"_87":88,"_89":76,"_90":47,"_91":20,"_92":76},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_97":98,"_99":100,"_101":102,"_103":104,"_160":161,"_183":184,"_185":-5},"handle","cupcakepoutmarry","name","njujyn","path","backend/api.ts","project",{"_105":106,"_99":100,"_107":108,"_109":-5,"_110":20,"_111":112,"_113":76,"_114":76,"_12":115,"_116":-5,"_117":20,"_118":-5,"_119":-5,"_120":33,"_14":121,"_122":-5,"_123":-5,"_124":-5,"_125":126,"_127":126,"_128":129,"_130":129,"_131":129,"_132":126,"_133":126,"_23":134,"_137":138,"_142":143,"_159":20},"id","c3ae5c20-294a-11f1-a93a-42dde27851f2","createdAt",["D",1774553651163],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","019d2ba0-17cb-701b-b5eb-7a72589f9980","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","019d2ba0-17cb-701b-b5eb-7fda1185c331","tursoName","tursoHostname","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_97":98,"_135":136},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzNCVXBGZkRlTGxseUZjN0tsbjBnRXFZVkY3QiJ9","org",{"_97":98,"_139":136,"_12":115,"_140":141},"avatar","tier","free","branch",{"_144":145,"_99":45,"_105":146,"_147":106,"_148":149,"_150":151,"_152":112,"_153":154,"_155":156,"_157":100,"_158":98},"version",3,"c3b37dea-294a-11f1-a93a-42dde27851f2","projectId","forkedBranchId","e3854ef6-290d-11f1-b425-42dde27851f2","forkedBranchVersion",12,"forkedProjectPrivacy","forkedProjectId","e3811886-290d-11f1-b425-42dde27851f2","forkedProjectOrgId","019d2a12-a49c-7269-9826-af7390a81f82","projectName","userHandle","isOwned","file",{"_105":162,"_99":163,"_164":165,"_166":167,"_168":146,"_169":170,"_171":172,"_107":173,"_144":174,"_175":176,"_177":178,"_179":20,"_180":-5,"_101":181},"e6eb45f4-294a-11f1-8b2a-42dde27851f2","api.ts","fileId","019d2ba3-d85e-7258-9037-b56518a4f164","parentId","019d2ba3-d85e-7258-9037-ca50eaaad085","branchId","branchVersion",2,"latest",true,["D",1774553710354],1,"fileType","script","content","/**\n * API Router - Xử lý tất cả API endpoints\n */\nimport {\n createBrowserbaseSession,\n stopBrowserbaseSession,\n getBrowserbaseDebugUrl,\n type BrowserbaseConfig,\n} from \"./browserbase.ts\";\nimport {\n createKernelBrowser,\n deleteKernelBrowser,\n createKernelProxy,\n listKernelProxies,\n type KernelConfig,\n type KernelProxyConfig,\n} from \"./kernel.ts\";\nimport { createBlock, type AutomationBlock } from \"./stagehand.ts\";\n\n// ──────────────── CDP EXECUTION ENGINE ────────────────\n\ninterface BlockResult {\n blockId: string;\n type: string;\n success: boolean;\n durationMs: number;\n data?: Record;\n error?: string;\n}\n\n/**\n * Gửi CDP command — hỗ trợ cả browser-level và session-level (page target).\n * Nếu truyền sessionId, lệnh được gửi đến page target đó.\n */\nfunction sendCDPCommand(\n ws: WebSocket,\n id: number,\n method: string,\n params: Record = {},\n sessionId?: string,\n): Promise {\n return new Promise((resolve, reject) => {\n const timeout = setTimeout(() => reject(new Error(`CDP timeout: ${method}`)), 15000);\n\n function onMessage(evt: MessageEvent) {\n try {\n const msg = JSON.parse(evt.data);\n if (msg.id === id) {\n clearTimeout(timeout);\n ws.removeEventListener(\"message\", onMessage);\n if (msg.error) reject(new Error(msg.error.message || JSON.stringify(msg.error)));\n else resolve(msg.result);\n }\n } catch { /* ignore */ }\n }\n\n ws.addEventListener(\"message\", onMessage);\n const payload: Record = { id, method, params };\n if (sessionId) payload.sessionId = sessionId;\n ws.send(JSON.stringify(payload));\n });\n}\n\n/**\n * Kết nối CDP WebSocket (browser-level) và lấy sessionId của page target đầu tiên.\n * Kernel cdp_ws_url là browser-level → cần attach vào page target để dùng Page.* / Runtime.*\n */\nasync function attachToPageTarget(ws: WebSocket, cmd: { id: number }): Promise {\n // Lấy danh sách targets\n const targetsResult = await sendCDPCommand(ws, cmd.id++, \"Target.getTargets\") as {\n targetInfos: Array<{ targetId: string; type: string; url: string }>;\n };\n\n const targets = targetsResult?.targetInfos || [];\n\n // Ưu tiên page target đang có URL thực (không phải about:blank nếu có lựa chọn khác)\n let pageTarget = targets.find((t) => t.type === \"page\" && t.url !== \"about:blank\");\n if (!pageTarget) pageTarget = targets.find((t) => t.type === \"page\");\n\n let targetId: string;\n if (!pageTarget) {\n // Không có page nào → tạo mới\n const created = await sendCDPCommand(ws, cmd.id++, \"Target.createTarget\", {\n url: \"about:blank\",\n }) as { targetId: string };\n targetId = created.targetId;\n } else {\n targetId = pageTarget.targetId;\n }\n\n // Attach vào target để nhận sessionId\n const attached = await sendCDPCommand(ws, cmd.id++, \"Target.attachToTarget\", {\n targetId,\n flatten: true, // flatten=true cho phép dùng sessionId trực tiếp trong message\n }) as { sessionId: string };\n\n if (!attached?.sessionId) {\n throw new Error(\"Target.attachToTarget did not return sessionId\");\n }\n\n return attached.sessionId;\n}\n\n/**\n * Kết nối CDP WebSocket và thực thi danh sách blocks tuần tự.\n */\nasync function executeBlocksViaCDP(\n cdpWsUrl: string,\n blocks: AutomationBlock[],\n): Promise {\n const results: BlockResult[] = [];\n\n // Kết nối WebSocket CDP\n const ws = new WebSocket(cdpWsUrl);\n await new Promise((resolve, reject) => {\n const t = setTimeout(() => {\n ws.close();\n reject(new Error(\"CDP WebSocket connect timeout (10s)\"));\n }, 10000);\n ws.onopen = () => { clearTimeout(t); resolve(); };\n ws.onerror = (evt) => {\n clearTimeout(t);\n const msg = (evt as ErrorEvent).message || \"WebSocket error\";\n reject(new Error(`CDP WebSocket connection failed: ${msg}`));\n };\n });\n\n const cmd = { id: 1 };\n\n try {\n // Attach vào page target — bắt buộc khi cdp_ws_url là browser-level\n const sessionId = await attachToPageTarget(ws, cmd);\n\n const enabledBlocks = blocks.filter((b) => b.enabled);\n\n for (const block of enabledBlocks) {\n const start = Date.now();\n const result: BlockResult = {\n blockId: block.id,\n type: block.type,\n success: false,\n durationMs: 0,\n };\n\n try {\n switch (block.type) {\n case \"navigate\": {\n const url = String(block.config.url || \"\").trim();\n if (!url) throw new Error(\"navigate: url is required\");\n const finalUrl = /^https?:\\/\\//i.test(url) ? url : \"https://\" + url;\n\n await sendCDPCommand(ws, cmd.id++, \"Page.navigate\", { url: finalUrl }, sessionId);\n\n // Poll readyState cho đến khi complete\n await new Promise((resolve) => {\n let attempts = 0;\n const poll = async () => {\n try {\n const r = await sendCDPCommand(ws, cmd.id++, \"Runtime.evaluate\", {\n expression: \"document.readyState\",\n returnByValue: true,\n }, sessionId) as { result: { value: string } };\n if (r?.result?.value === \"complete\" || attempts >= 20) resolve();\n else { attempts++; setTimeout(poll, 500); }\n } catch { resolve(); }\n };\n setTimeout(poll, 800);\n });\n\n result.success = true;\n result.data = { navigated: finalUrl };\n break;\n }\n\n case \"wait\": {\n const secs = Math.max(0.1, Math.min(Number(block.config.seconds) || 2, 60));\n await new Promise((r) => setTimeout(r, secs * 1000));\n result.success = true;\n result.data = { waited: secs };\n break;\n }\n\n case \"screenshot\": {\n const r = await sendCDPCommand(ws, cmd.id++, \"Page.captureScreenshot\", {\n format: \"png\",\n captureBeyondViewport: block.config.fullPage === true,\n }, sessionId) as { data: string };\n if (!r?.data) throw new Error(\"screenshot: no data returned\");\n result.success = true;\n result.data = { screenshot: \"data:image/png;base64,\" + r.data };\n break;\n }\n\n case \"script\": {\n const code = String(block.config.code || \"\").trim();\n if (!code) throw new Error(\"script: code is required\");\n const r = await sendCDPCommand(ws, cmd.id++, \"Runtime.evaluate\", {\n expression: code,\n returnByValue: true,\n awaitPromise: true,\n }, sessionId) as { result: { value: unknown }; exceptionDetails?: { text?: string; exception?: { description?: string } } };\n if (r.exceptionDetails) {\n const errMsg = r.exceptionDetails.exception?.description || r.exceptionDetails.text || JSON.stringify(r.exceptionDetails);\n throw new Error(\"Script exception: \" + errMsg);\n }\n result.success = true;\n result.data = { value: r.result?.value ?? null };\n break;\n }\n\n case \"extract\": {\n const instruction = String(block.config.instruction || \"\");\n const r = await sendCDPCommand(ws, cmd.id++, \"Runtime.evaluate\", {\n expression: `(function(){\n try {\n return JSON.stringify({\n title: document.title,\n url: location.href,\n text: document.body ? document.body.innerText.slice(0, 5000) : '',\n instruction: ${JSON.stringify(instruction)}\n });\n } catch(e) { return JSON.stringify({ error: e.message }); }\n })()`,\n returnByValue: true,\n }, sessionId) as { result: { value: string } };\n let parsed: Record = {};\n try { parsed = JSON.parse(r?.result?.value || \"{}\"); } catch { /* ignore */ }\n result.success = true;\n result.data = parsed;\n break;\n }\n\n case \"observe\": {\n const instruction = String(block.config.instruction || \"\");\n const r = await sendCDPCommand(ws, cmd.id++, \"Runtime.evaluate\", {\n expression: `(function(){\n try {\n var els = Array.from(document.querySelectorAll('a,button,input,select,textarea,[role=\"button\"],[role=\"link\"]'))\n .slice(0, 50)\n .map(function(el){\n return {\n tag: el.tagName.toLowerCase(),\n text: (el.textContent||el.value||el.placeholder||'').trim().slice(0,80),\n href: el.href || null,\n type: el.type || null\n };\n });\n return JSON.stringify({ instruction: ${JSON.stringify(instruction)}, count: els.length, elements: els });\n } catch(e) { return JSON.stringify({ error: e.message, elements: [] }); }\n })()`,\n returnByValue: true,\n }, sessionId) as { result: { value: string } };\n let parsed: Record = { elements: [] };\n try { parsed = JSON.parse(r?.result?.value || \"{}\"); } catch { /* ignore */ }\n result.success = true;\n result.data = parsed;\n break;\n }\n\n case \"act\": {\n const instructionRaw = String(block.config.instruction || \"\");\n const instruction = instructionRaw.toLowerCase();\n let actResult = \"No matching action — supported: click, type/fill/enter, scroll, submit, press\";\n\n if (instruction.includes(\"click\")) {\n const match = instructionRaw.match(/click\\s+(?:the\\s+)?[\"']?(.+?)[\"']?\\s*(?:button|link|element|btn)?$/i);\n const targetText = (match?.[1]?.trim() || \"\").toLowerCase();\n const js = `(function(){\n var els = Array.from(document.querySelectorAll('a,button,[role=\"button\"],[role=\"link\"],input[type=\"submit\"],input[type=\"button\"]'));\n var target = ${targetText ? `els.find(function(el){ return (el.textContent||'').toLowerCase().includes(${JSON.stringify(targetText)}); })` : \"els[0]\"};\n if (target) { target.click(); return 'Clicked: ' + target.textContent.trim().slice(0,80); }\n return 'Element not found: ' + ${JSON.stringify(targetText || \"(first clickable)\")};\n })()`;\n const r = await sendCDPCommand(ws, cmd.id++, \"Runtime.evaluate\", { expression: js, returnByValue: true }, sessionId) as { result: { value: string } };\n actResult = r?.result?.value || \"Done\";\n\n } else if (instruction.includes(\"type\") || instruction.includes(\"fill\") || instruction.includes(\"enter\")) {\n const textMatch = instructionRaw.match(/(?:type|fill|enter)\\s+[\"']([^\"']+)[\"']/i);\n const text = textMatch?.[1] || \"\";\n if (!text) {\n actResult = 'act: no text in quotes — e.g. type \"hello world\"';\n } else {\n const js = `(function(){\n var el = document.activeElement;\n if (!el || (el.tagName!=='INPUT' && el.tagName!=='TEXTAREA')) {\n el = document.querySelector('input:not([type=\"hidden\"]):not([type=\"submit\"]):not([type=\"button\"]),textarea');\n }\n if (el && (el.tagName==='INPUT'||el.tagName==='TEXTAREA')) {\n el.focus();\n el.value = ${JSON.stringify(text)};\n el.dispatchEvent(new Event('input',{bubbles:true}));\n el.dispatchEvent(new Event('change',{bubbles:true}));\n return 'Typed \"' + ${JSON.stringify(text)} + '\" into ' + el.tagName + '[' + (el.name||el.id||el.placeholder||el.type||'') + ']';\n }\n return 'No writable input element found';\n })()`;\n const r = await sendCDPCommand(ws, cmd.id++, \"Runtime.evaluate\", { expression: js, returnByValue: true }, sessionId) as { result: { value: string } };\n actResult = r?.result?.value || \"Done\";\n }\n\n } else if (instruction.includes(\"scroll\")) {\n const scrollJs = instruction.includes(\"top\")\n ? \"window.scrollTo(0,0); 'Scrolled to top'\"\n : instruction.includes(\"bottom\")\n ? \"window.scrollTo(0,document.body.scrollHeight); 'Scrolled to bottom'\"\n : \"window.scrollBy(0, window.innerHeight * 0.8); 'Scrolled down 80%'\";\n const r = await sendCDPCommand(ws, cmd.id++, \"Runtime.evaluate\", { expression: scrollJs, returnByValue: true }, sessionId) as { result: { value: string } };\n actResult = r?.result?.value || \"Scrolled\";\n\n } else if (instruction.includes(\"submit\")) {\n const js = `(function(){\n var btn = document.querySelector('button[type=\"submit\"],input[type=\"submit\"]');\n if (btn) { btn.click(); return 'Submit button clicked: ' + (btn.textContent||btn.value||'').trim(); }\n var form = document.querySelector('form');\n if (form) { form.dispatchEvent(new Event('submit',{bubbles:true,cancelable:true})); return 'Form submit event dispatched'; }\n return 'No form or submit button found';\n })()`;\n const r = await sendCDPCommand(ws, cmd.id++, \"Runtime.evaluate\", { expression: js, returnByValue: true }, sessionId) as { result: { value: string } };\n actResult = r?.result?.value || \"Done\";\n\n } else if (instruction.includes(\"press\") || instruction.includes(\"key\")) {\n const keyMatch = instructionRaw.match(/(?:press|key)\\s+(\\w+)/i);\n const key = keyMatch?.[1] || \"Enter\";\n const js = `(function(){\n var el = document.activeElement || document.body;\n ['keydown','keypress','keyup'].forEach(function(t){\n el.dispatchEvent(new KeyboardEvent(t,{key:${JSON.stringify(key)},bubbles:true,cancelable:true}));\n });\n return 'Key pressed: ' + ${JSON.stringify(key)};\n })()`;\n const r = await sendCDPCommand(ws, cmd.id++, \"Runtime.evaluate\", { expression: js, returnByValue: true }, sessionId) as { result: { value: string } };\n actResult = r?.result?.value || \"Done\";\n }\n\n result.success = true;\n result.data = { instruction: instructionRaw, result: actResult };\n break;\n }\n\n default:\n throw new Error(`Unknown block type: ${block.type}`);\n }\n } catch (err) {\n result.success = false;\n result.error = err instanceof Error ? err.message : String(err);\n }\n\n result.durationMs = Date.now() - start;\n results.push(result);\n\n if (!result.success) break;\n }\n } finally {\n try { ws.close(); } catch { /* ignore */ }\n }\n\n return results;\n}\n\n// ──────────────── MAIN HANDLER ────────────────\n\nexport async function handleApiRequest(req: Request, pathname: string): Promise {\n const headers = { \"Content-Type\": \"application/json\", \"Access-Control-Allow-Origin\": \"*\" };\n\n try {\n // ──────────────── BROWSERBASE ────────────────\n if (pathname === \"/api/browserbase/session\" && req.method === \"POST\") {\n const body = await req.json();\n if (!body.apiKey || !body.projectId) {\n return new Response(JSON.stringify({ success: false, error: \"Missing required fields: apiKey, projectId\" }), { status: 400, headers });\n }\n\n const config: BrowserbaseConfig = { apiKey: body.apiKey, projectId: body.projectId };\n const session = await createBrowserbaseSession(config, {\n proxies: body.proxies,\n region: body.region,\n timeout: body.timeout || 900,\n keepAlive: body.keepAlive ?? false,\n });\n\n let debugInfo = null;\n try { debugInfo = await getBrowserbaseDebugUrl(config, session.id); } catch { /* not yet available */ }\n\n return new Response(JSON.stringify({\n success: true,\n session: {\n ...session,\n cdp_ws_url: session.connectUrl || null,\n debuggerFullscreenUrl: debugInfo?.debuggerFullscreenUrl || null,\n debuggerUrl: debugInfo?.debuggerUrl || null,\n wsUrl: debugInfo?.wsUrl || null,\n },\n }), { headers });\n }\n\n if (pathname === \"/api/browserbase/session/stop\" && req.method === \"POST\") {\n const body = await req.json();\n if (!body.apiKey || !body.projectId || !body.sessionId) {\n return new Response(JSON.stringify({ success: false, error: \"Missing required fields: apiKey, projectId, sessionId\" }), { status: 400, headers });\n }\n const config: BrowserbaseConfig = { apiKey: body.apiKey, projectId: body.projectId };\n await stopBrowserbaseSession(config, body.sessionId);\n return new Response(JSON.stringify({ success: true }), { headers });\n }\n\n // ──────────────── KERNEL ────────────────\n if (pathname === \"/api/kernel/browser\" && req.method === \"POST\") {\n const body = await req.json();\n if (!body.apiKey) {\n return new Response(JSON.stringify({ success: false, error: \"Missing required field: apiKey\" }), { status: 400, headers });\n }\n const config: KernelConfig = { apiKey: body.apiKey };\n const browser = await createKernelBrowser(config, {\n stealth: body.stealth ?? true,\n headless: body.headless ?? false,\n timeout: body.timeout || 3600,\n proxy_id: body.proxyId,\n });\n return new Response(JSON.stringify({ success: true, browser }), { headers });\n }\n\n if (pathname === \"/api/kernel/browser/delete\" && req.method === \"POST\") {\n const body = await req.json();\n if (!body.apiKey || !body.sessionId) {\n return new Response(JSON.stringify({ success: false, error: \"Missing required fields: apiKey, sessionId\" }), { status: 400, headers });\n }\n await deleteKernelBrowser({ apiKey: body.apiKey }, body.sessionId);\n return new Response(JSON.stringify({ success: true }), { headers });\n }\n\n if (pathname === \"/api/kernel/proxy\" && req.method === \"POST\") {\n const body = await req.json();\n if (!body.apiKey) {\n return new Response(JSON.stringify({ success: false, error: \"Missing required field: apiKey\" }), { status: 400, headers });\n }\n const config: KernelConfig = { apiKey: body.apiKey };\n const proxyConfig: KernelProxyConfig = {\n type: body.proxyType || \"datacenter\",\n name: body.proxyName || `auto-proxy-${Date.now()}`,\n config: body.proxyConfig || {},\n };\n const proxy = await createKernelProxy(config, proxyConfig);\n return new Response(JSON.stringify({ success: true, proxy }), { headers });\n }\n\n if (pathname === \"/api/kernel/proxies\" && req.method === \"POST\") {\n const body = await req.json();\n if (!body.apiKey) {\n return new Response(JSON.stringify({ success: false, error: \"Missing required field: apiKey\" }), { status: 400, headers });\n }\n const proxies = await listKernelProxies({ apiKey: body.apiKey });\n return new Response(JSON.stringify({ success: true, proxies }), { headers });\n }\n\n // ──────────────── BLOCKS ────────────────\n if (pathname === \"/api/blocks/create\" && req.method === \"POST\") {\n const body = await req.json();\n if (!body.type) {\n return new Response(JSON.stringify({ success: false, error: \"Missing required field: type\" }), { status: 400, headers });\n }\n const block = createBlock(body.type);\n return new Response(JSON.stringify({ success: true, block }), { headers });\n }\n\n // ──────────────── AUTOMATION RUN ────────────────\n if (pathname === \"/api/automation/run\" && req.method === \"POST\") {\n const body = await req.json();\n const blocks: AutomationBlock[] = body.blocks || [];\n const cdpWsUrl: string = body.cdpWsUrl;\n\n if (!cdpWsUrl) {\n return new Response(JSON.stringify({ success: false, error: \"Missing cdpWsUrl — session must be launched first\" }), { status: 400, headers });\n }\n\n const enabledBlocks = blocks.filter((b) => b.enabled);\n if (enabledBlocks.length === 0) {\n return new Response(JSON.stringify({ success: false, error: \"No enabled blocks to run\" }), { status: 400, headers });\n }\n\n console.log(`[automation/run] ${enabledBlocks.length} blocks via CDP: ${cdpWsUrl.slice(0, 80)}...`);\n const results = await executeBlocksViaCDP(cdpWsUrl, blocks);\n const allSuccess = results.every((r) => r.success);\n\n return new Response(JSON.stringify({ success: allSuccess, totalSteps: results.length, results }), { headers });\n }\n\n // ──────────────── EBAY BUSINESS FLOW ────────────────\n if (pathname === \"/api/ebay-business/run\" && req.method === \"POST\") {\n const body = await req.json();\n const cdpWsUrl: string = body.cdpWsUrl;\n if (!cdpWsUrl) {\n return new Response(JSON.stringify({ success: false, error: \"Missing cdpWsUrl — launch a session first\" }), { status: 400, headers });\n }\n\n const required = [\"ein\",\"business_name\",\"business_street\",\"business_city\",\"business_static\",\"business_zip\",\"full_name\",\"dob\",\"ssn\",\"address\",\"city\",\"static\",\"zip_code\"];\n for (const f of required) {\n if (!body[f]) {\n return new Response(JSON.stringify({ success: false, error: `Missing required field: ${f}` }), { status: 400, headers });\n }\n }\n\n const flowBlocks: AutomationBlock[] = [\n { id: crypto.randomUUID(), type: \"navigate\", label: \"Open eBay Business Registration\", config: { url: \"https://reg.ebay.com/reg/RegistrationPage?runame=SignIn&siteid=0&type=Business\" }, enabled: true },\n { id: crypto.randomUUID(), type: \"wait\", label: \"Wait for page\", config: { seconds: 3 }, enabled: true },\n { id: crypto.randomUUID(), type: \"script\", label: \"Fill business name\", config: { code: `(function(){ var el=document.querySelector('input[id*=\"businessName\" i],input[name*=\"businessName\" i],input[id*=\"business_name\" i]'); if(!el)return 'not found'; el.focus();el.value=${JSON.stringify(body.business_name)};el.dispatchEvent(new Event('input',{bubbles:true}));el.dispatchEvent(new Event('change',{bubbles:true}));return 'ok: '+el.id; })()` }, enabled: true },\n { id: crypto.randomUUID(), type: \"script\", label: \"Fill EIN\", config: { code: `(function(){ var el=document.querySelector('input[id*=\"ein\" i],input[name*=\"ein\" i],input[id*=\"taxId\" i],input[name*=\"taxId\" i]'); if(!el)return 'not found'; el.focus();el.value=${JSON.stringify(body.ein)};el.dispatchEvent(new Event('input',{bubbles:true}));el.dispatchEvent(new Event('change',{bubbles:true}));return 'ok'; })()` }, enabled: true },\n { id: crypto.randomUUID(), type: \"script\", label: \"Fill business street\", config: { code: `(function(){ var el=document.querySelector('input[id*=\"street\" i],input[name*=\"street\" i],input[id*=\"address1\" i],input[name*=\"address1\" i]'); if(!el)return 'not found'; el.focus();el.value=${JSON.stringify(body.business_street)};el.dispatchEvent(new Event('input',{bubbles:true}));el.dispatchEvent(new Event('change',{bubbles:true}));return 'ok'; })()` }, enabled: true },\n { id: crypto.randomUUID(), type: \"script\", label: \"Fill business city\", config: { code: `(function(){ var els=document.querySelectorAll('input[id*=\"city\" i],input[name*=\"city\" i]'); var el=els[0]; if(!el)return 'not found'; el.focus();el.value=${JSON.stringify(body.business_city)};el.dispatchEvent(new Event('input',{bubbles:true}));el.dispatchEvent(new Event('change',{bubbles:true}));return 'ok'; })()` }, enabled: true },\n { id: crypto.randomUUID(), type: \"script\", label: \"Select business state\", config: { code: `(function(){ var el=document.querySelector('select[id*=\"state\" i],select[name*=\"state\" i]'); if(!el)return 'not found'; el.value=${JSON.stringify(body.business_static)};el.dispatchEvent(new Event('change',{bubbles:true}));return 'ok: '+el.value; })()` }, enabled: true },\n { id: crypto.randomUUID(), type: \"script\", label: \"Fill business zip\", config: { code: `(function(){ var el=document.querySelector('input[id*=\"zip\" i],input[name*=\"zip\" i],input[id*=\"postal\" i],input[name*=\"postal\" i]'); if(!el)return 'not found'; el.focus();el.value=${JSON.stringify(body.business_zip)};el.dispatchEvent(new Event('input',{bubbles:true}));el.dispatchEvent(new Event('change',{bubbles:true}));return 'ok'; })()` }, enabled: true },\n { id: crypto.randomUUID(), type: \"script\", label: \"Fill owner full name\", config: { code: `(function(){ var el=document.querySelector('input[id*=\"fullName\" i],input[name*=\"fullName\" i],input[id*=\"legalName\" i],input[id*=\"firstName\" i]'); if(!el)return 'not found'; el.focus();el.value=${JSON.stringify(body.full_name)};el.dispatchEvent(new Event('input',{bubbles:true}));el.dispatchEvent(new Event('change',{bubbles:true}));return 'ok'; })()` }, enabled: true },\n { id: crypto.randomUUID(), type: \"script\", label: \"Fill date of birth\", config: { code: `(function(){ var el=document.querySelector('input[id*=\"dob\" i],input[name*=\"dob\" i],input[id*=\"birth\" i],input[id*=\"dateOfBirth\" i]'); if(!el)return 'not found'; el.focus();el.value=${JSON.stringify(body.dob)};el.dispatchEvent(new Event('input',{bubbles:true}));el.dispatchEvent(new Event('change',{bubbles:true}));return 'ok'; })()` }, enabled: true },\n { id: crypto.randomUUID(), type: \"script\", label: \"Fill SSN\", config: { code: `(function(){ var el=document.querySelector('input[id*=\"ssn\" i],input[name*=\"ssn\" i],input[id*=\"social\" i],input[name*=\"social\" i]'); if(!el)return 'not found'; el.focus();el.value=${JSON.stringify(body.ssn)};el.dispatchEvent(new Event('input',{bubbles:true}));el.dispatchEvent(new Event('change',{bubbles:true}));return 'ok'; })()` }, enabled: true },\n { id: crypto.randomUUID(), type: \"script\", label: \"Fill owner address\", config: { code: `(function(){ var els=document.querySelectorAll('input[id*=\"address\" i],input[name*=\"address\" i]'); var el=els[1]||els[0]; if(!el)return 'not found'; el.focus();el.value=${JSON.stringify(body.address)};el.dispatchEvent(new Event('input',{bubbles:true}));el.dispatchEvent(new Event('change',{bubbles:true}));return 'ok'; })()` }, enabled: true },\n { id: crypto.randomUUID(), type: \"script\", label: \"Fill owner city\", config: { code: `(function(){ var els=document.querySelectorAll('input[id*=\"city\" i],input[name*=\"city\" i]'); var el=els[1]||els[0]; if(!el)return 'not found'; el.focus();el.value=${JSON.stringify(body.city)};el.dispatchEvent(new Event('input',{bubbles:true}));el.dispatchEvent(new Event('change',{bubbles:true}));return 'ok'; })()` }, enabled: true },\n { id: crypto.randomUUID(), type: \"script\", label: \"Select owner state\", config: { code: `(function(){ var els=document.querySelectorAll('select[id*=\"state\" i],select[name*=\"state\" i]'); var el=els[1]||els[0]; if(!el)return 'not found'; el.value=${JSON.stringify(body.static)};el.dispatchEvent(new Event('change',{bubbles:true}));return 'ok: '+el.value; })()` }, enabled: true },\n { id: crypto.randomUUID(), type: \"script\", label: \"Fill owner zip\", config: { code: `(function(){ var els=document.querySelectorAll('input[id*=\"zip\" i],input[name*=\"zip\" i],input[id*=\"postal\" i],input[name*=\"postal\" i]'); var el=els[1]||els[0]; if(!el)return 'not found'; el.focus();el.value=${JSON.stringify(body.zip_code)};el.dispatchEvent(new Event('input',{bubbles:true}));el.dispatchEvent(new Event('change',{bubbles:true}));return 'ok'; })()` }, enabled: true },\n { id: crypto.randomUUID(), type: \"screenshot\", label: \"Screenshot before submit\", config: { fullPage: false }, enabled: true },\n { id: crypto.randomUUID(), type: \"wait\", label: \"Wait after fill\", config: { seconds: 2 }, enabled: true },\n {\n id: crypto.randomUUID(), type: \"script\", label: \"Extract business_email\",\n config: {\n code: `(function(){\n var inputs = Array.from(document.querySelectorAll('input[type=\"email\"],input[id*=\"email\" i],input[name*=\"email\" i]'));\n var found = inputs.find(function(el){ return el.value && el.value.includes('@'); });\n if (found) return JSON.stringify({ business_email: found.value });\n var match = document.body.innerText.match(/[a-zA-Z0-9._%+\\\\-]+@[a-zA-Z0-9.\\\\-]+\\\\.[a-zA-Z]{2,}/);\n if (match) return JSON.stringify({ business_email: match[0] });\n return JSON.stringify({ business_email: null });\n })()`\n },\n enabled: true,\n },\n ];\n\n console.log(`[ebay-business/run] Running ${flowBlocks.length} flow blocks via CDP`);\n const results = await executeBlocksViaCDP(cdpWsUrl, flowBlocks);\n const allSuccess = results.every((r) => r.success);\n\n // Parse business_email from last script result\n let businessEmail: string | null = null;\n const emailStep = [...results].reverse().find((r) => r.type === \"script\" && r.data);\n if (emailStep?.data) {\n try {\n const raw = (emailStep.data as Record)[\"value\"];\n const parsed = JSON.parse(String(raw)) as Record;\n businessEmail = (parsed[\"business_email\"] as string) ?? null;\n } catch { /* ignore */ }\n }\n\n return new Response(JSON.stringify({\n success: allSuccess,\n business_email: businessEmail,\n totalSteps: results.length,\n results,\n }), { headers });\n }\n\n return new Response(JSON.stringify({ error: \"Not found\", path: pathname }), { status: 404, headers });\n\n } catch (err) {\n const message = err instanceof Error ? err.message : \"Unknown error\";\n console.error(`[API Error] ${req.method} ${pathname}:`, message);\n return new Response(JSON.stringify({ success: false, error: message }), { status: 500, headers });\n }\n}\n","deleted","label",[182,163],"backend","permalink","https://www.val.town/x/cupcakepoutmarry/njujyn/code/backend/api.ts","extension","actionData","errors"]