KBA — Kernel Browser Automation

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_228":229,"_230":231},"routes/_app.x.$handle.$name",{"_104":103,"_38":51,"_113":94,"_33":114,"_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":63,"_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":-5,"_59":-5,"_19":60,"_61":-5,"_62":63,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":75,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":87,"_88":89,"_90":91,"_92":31},"version",65,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","cd026115-32a4-4d84-a286-3a5f954f0eb8","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","blockExecutor.ts","latestPath","fileId","ffdb5548-1fbf-11f1-b868-42dde27851f2","name","fileType","script","content","// ============================================================\n// BLOCK EXECUTOR – KBA v2\n// Mọi block đều dùng runPlaywright() từ kernelClient.ts\n// Base: POST /browsers/{id}/playwright/execute\n// ============================================================\n\nimport { runPlaywright, createBrowser, buildCode, type Action } from \"./kernelClient.ts\";\n\nexport interface BlockExecutionResponse {\n success: boolean;\n data: unknown;\n error: string | null;\n browser_id: string | null;\n browser_state: {\n browser_id: string | null;\n current_url: string | null;\n active_tab_id: string | null;\n screenshot_taken: boolean;\n };\n reasoning_summary: string;\n variables_updated: Record | null;\n next_action_needed: boolean;\n}\n\nfunction ok(\n data: unknown,\n vars: Record | null,\n browserId: string | null,\n summary: string\n): BlockExecutionResponse {\n return {\n success: true, data, error: null,\n browser_id: browserId,\n browser_state: { browser_id: browserId, current_url: null, active_tab_id: null, screenshot_taken: false },\n reasoning_summary: summary,\n variables_updated: vars,\n next_action_needed: false,\n };\n}\n\nfunction fail(\n error: string,\n browserId: string | null,\n summary: string\n): BlockExecutionResponse {\n return {\n success: false, data: null, error,\n browser_id: browserId,\n browser_state: { browser_id: browserId, current_url: null, active_tab_id: null, screenshot_taken: false },\n reasoning_summary: summary,\n variables_updated: null,\n next_action_needed: false,\n };\n}\n\n// Ensure we have a browser session\nasync function ensureSession(browserId?: string): Promise {\n if (browserId) return browserId;\n const b = await createBrowser({ headless: false, stealth: true, timeout_seconds: 3600 });\n return b.session_id;\n}\n\n// Adaptive selector resolution using heuristics\nfunction adaptiveSelector(description: string): string {\n const d = description.toLowerCase();\n if (d.includes(\"search\") && d.includes(\"input\")) return \"input[type='search'], input[placeholder*='search' i]\";\n if (d.includes(\"email\") && d.includes(\"input\")) return \"input[type='email'], input[name*='email' i]\";\n if (d.includes(\"password\")) return \"input[type='password']\";\n if (d.includes(\"submit\") || d.includes(\"login button\")) return \"button[type='submit'], input[type='submit']\";\n if (d.includes(\"username\")) return \"input[name*='user' i], input[id*='user' i]\";\n if (d.includes(\"sign in\") || d.includes(\"log in\")) return \"button:has-text('Sign in'), button:has-text('Log in')\";\n if (d.includes(\"next button\")) return \"button:has-text('Next')\";\n if (d.includes(\"close\")) return \"button[aria-label*='close' i], .close\";\n if (d.includes(\"dropdown\")) return \"select\";\n return `[aria-label*=\"${description}\" i]`;\n}\n\n// ─── MAIN EXECUTOR ────────────────────────────────────────\nexport async function executeBlock(\n blockType: string,\n params: Record,\n context: {\n browserId?: string;\n currentUrl?: string;\n previousVariables?: Record;\n } = {}\n): Promise {\n try {\n // ── UTILITIES that don't need a browser ──────────────\n\n if (blockType === \"Get Date\") {\n const fmt = (params.format as string) ?? \"ISO\";\n const now = new Date();\n let dateStr: string;\n if (fmt === \"timestamp\") dateStr = now.getTime().toString();\n else if (fmt === \"YYYY-MM-DD\") dateStr = now.toISOString().split(\"T\")[0];\n else if (fmt === \"HH:mm:ss\") dateStr = now.toTimeString().slice(0, 8);\n else dateStr = now.toISOString();\n return ok(dateStr, { current_date: dateStr }, context.browserId ?? null, `Date: ${dateStr}`);\n }\n\n if (blockType === \"Wait\") {\n const ms = (params.duration_ms as number) ?? 1000;\n await new Promise(r => setTimeout(r, ms));\n return ok({ waited_ms: ms }, null, context.browserId ?? null, `Waited ${ms}ms`);\n }\n\n if (blockType === \"Comment\") {\n return ok({ comment: params.text }, null, context.browserId ?? null, `Comment: ${params.text}`);\n }\n\n if (blockType === \"Show Alert\") {\n console.log(`[KBA ALERT] ${params.text}`);\n return ok({ alert_text: params.text }, null, context.browserId ?? null, `Alert: ${params.text}`);\n }\n\n if (blockType === \"Make HTTP Request\") {\n const method = (params.method as string) ?? \"GET\";\n const url = params.url as string;\n if (!url) return fail(\"Make HTTP Request: url required\", context.browserId ?? null, \"Missing url param\");\n const res = await fetch(url, {\n method,\n headers: (params.headers as Record) ?? {},\n body: params.body ? JSON.stringify(params.body) : undefined,\n });\n let data: unknown;\n try { data = await res.json(); } catch { data = await res.text(); }\n return ok(data, { http_response: data, http_status: res.status }, context.browserId ?? null,\n `HTTP ${method} ${url} → ${res.status}`);\n }\n\n if (blockType === \"Assert\") {\n const vars = context.previousVariables ?? {};\n let passed = false;\n let assertError = \"\";\n try {\n const fn = new Function(...Object.keys(vars), `return (${params.condition ?? \"true\"})`);\n passed = Boolean(fn(...Object.values(vars)));\n } catch (e) { assertError = (e as Error).message; }\n if (!passed) return fail(`Assert failed: \"${params.condition}\" ${params.message ?? \"\"} ${assertError}`, context.browserId ?? null, `Assert FAIL`);\n return ok({ passed: true }, null, context.browserId ?? null, `Assert PASS: \"${params.condition}\"`);\n }\n\n if (blockType === \"If\") {\n const vars = { ...context.previousVariables, ...(params.variable_map as Record ?? {}) };\n let condResult = false;\n try {\n const fn = new Function(...Object.keys(vars), `return (${params.condition ?? \"true\"})`);\n condResult = Boolean(fn(...Object.values(vars)));\n } catch { condResult = false; }\n return ok({ condition_result: condResult }, { __condition__: condResult }, context.browserId ?? null,\n `If: \"${params.condition}\" → ${condResult}`);\n }\n\n if ([\"Loop\", \"While\", \"End\", \"Break\", \"Loop Elements\", \"Loop List Items\"].includes(blockType)) {\n return ok({ control_flow_block: blockType }, { __control_flow__: blockType }, context.browserId ?? null,\n `Control flow [${blockType}] – handled by runner`);\n }\n\n // ── ALL BROWSER BLOCKS use runPlaywright ─────────────\n\n const bid = await ensureSession(context.browserId);\n const actions: Action[] = [];\n\n // ── Navigate ──────────────────────────────────────────\n if (blockType === \"Visit\") {\n actions.push({ type: \"Visit\", url: params.url as string, waitUntil: (params.wait_until as string) ?? \"load\" });\n const code = buildCode(actions) + \"\\nreturn page.url();\";\n const r = await runPlaywright(bid, code);\n if (!r.success) return fail(r.error ?? \"Visit failed\", bid, `Visit ${params.url} failed`);\n return ok({ url: r.result }, null, bid, `Visited: ${params.url}`);\n }\n\n if (blockType === \"Go Back\") {\n const r = await runPlaywright(bid, \"await page.goBack(); return page.url();\");\n if (!r.success) return fail(r.error ?? \"Go Back failed\", bid, \"Go Back failed\");\n return ok({ url: r.result }, null, bid, `Go Back → ${r.result}`);\n }\n\n if (blockType === \"Go Forward\") {\n const r = await runPlaywright(bid, \"await page.goForward(); return page.url();\");\n if (!r.success) return fail(r.error ?? \"Go Forward failed\", bid, \"Go Forward failed\");\n return ok({ url: r.result }, null, bid, `Go Forward → ${r.result}`);\n }\n\n if (blockType === \"Reload Page\") {\n const r = await runPlaywright(bid, \"await page.reload(); return page.url();\");\n if (!r.success) return fail(r.error ?? \"Reload failed\", bid, \"Reload failed\");\n return ok({ url: r.result }, null, bid, `Reloaded → ${r.result}`);\n }\n\n // ── Interact ──────────────────────────────────────────\n if (blockType === \"Click\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Click: selector or description required\", bid, \"Missing selector\");\n const r = await runPlaywright(bid, `await page.click(${JSON.stringify(sel)}); return page.url();`);\n if (!r.success) return fail(r.error ?? \"Click failed\", bid, `Click \"${sel}\" failed`);\n return ok({ selector: sel }, null, bid, `Clicked \"${sel}\"`);\n }\n\n if (blockType === \"Type Text\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Type Text: selector required\", bid, \"Missing selector\");\n const text = params.text as string ?? \"\";\n const clearFirst = params.clear_first !== false;\n const code = clearFirst\n ? `await page.fill(${JSON.stringify(sel)}, ${JSON.stringify(text)}); return page.url();`\n : `await page.type(${JSON.stringify(sel)}, ${JSON.stringify(text)}); return page.url();`;\n const r = await runPlaywright(bid, code);\n if (!r.success) return fail(r.error ?? \"Type failed\", bid, `Type \"${text}\" into \"${sel}\" failed`);\n return ok({ selector: sel, text }, null, bid, `Typed \"${text.slice(0, 30)}\" into \"${sel}\"`);\n }\n\n if (blockType === \"Press Key\") {\n const key = params.key as string ?? \"Enter\";\n const r = await runPlaywright(bid, `await page.keyboard.press(${JSON.stringify(key)});`);\n if (!r.success) return fail(r.error ?? \"Press Key failed\", bid, `Press Key \"${key}\" failed`);\n return ok({ key }, null, bid, `Pressed key \"${key}\"`);\n }\n\n if (blockType === \"Scroll\") {\n const dir = params.direction as string ?? \"down\";\n const amt = (params.amount as number) ?? 300;\n let code = \"\";\n if (dir === \"down\") code = `await page.evaluate(() => window.scrollBy(0, ${amt}));`;\n else if (dir === \"up\") code = `await page.evaluate(() => window.scrollBy(0, -${amt}));`;\n else if (dir === \"to_bottom\") code = `await page.evaluate(() => window.scrollTo(0, document.body.scrollHeight));`;\n else if (dir === \"to_top\") code = `await page.evaluate(() => window.scrollTo(0, 0));`;\n else if (dir === \"to_element\" && params.selector) code = `await page.locator(${JSON.stringify(params.selector)}).scrollIntoViewIfNeeded();`;\n else code = `await page.evaluate(() => window.scrollBy(0, ${amt}));`;\n const r = await runPlaywright(bid, code);\n if (!r.success) return fail(r.error ?? \"Scroll failed\", bid, `Scroll \"${dir}\" failed`);\n return ok({ direction: dir }, null, bid, `Scrolled \"${dir}\"`);\n }\n\n if (blockType === \"Hover\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Hover: selector required\", bid, \"Missing selector\");\n const r = await runPlaywright(bid, `await page.hover(${JSON.stringify(sel)});`);\n if (!r.success) return fail(r.error ?? \"Hover failed\", bid, `Hover \"${sel}\" failed`);\n return ok({ selector: sel }, null, bid, `Hovered \"${sel}\"`);\n }\n\n if (blockType === \"Select Option\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Select Option: selector required\", bid, \"Missing selector\");\n const val = params.value as string ?? params.label as string ?? \"\";\n const r = await runPlaywright(bid, `await page.selectOption(${JSON.stringify(sel)}, ${JSON.stringify(val)});`);\n if (!r.success) return fail(r.error ?? \"Select failed\", bid, `Select \"${val}\" failed`);\n return ok({ selector: sel, value: val }, null, bid, `Selected \"${val}\" in \"${sel}\"`);\n }\n\n if (blockType === \"Set Date Input\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Set Date Input: selector required\", bid, \"Missing selector\");\n const date = params.date as string ?? \"\";\n const r = await runPlaywright(bid, `await page.fill(${JSON.stringify(sel)}, ${JSON.stringify(date)});`);\n if (!r.success) return fail(r.error ?? \"Set Date failed\", bid, `Set date \"${date}\" failed`);\n return ok({ selector: sel, date }, null, bid, `Set date \"${date}\" on \"${sel}\"`);\n }\n\n if (blockType === \"Wait for Element\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Wait for Element: selector required\", bid, \"Missing selector\");\n const state = params.state as string ?? \"visible\";\n const timeout = (params.timeout_ms as number) ?? 10000;\n const r = await runPlaywright(bid,\n `await page.waitForSelector(${JSON.stringify(sel)}, { state: ${JSON.stringify(state)}, timeout: ${timeout} });`);\n if (!r.success) return fail(r.error ?? \"Wait for Element failed\", bid, `Wait for \"${sel}\" failed`);\n return ok({ selector: sel }, null, bid, `Element \"${sel}\" is now \"${state}\"`);\n }\n\n // ── Extract ───────────────────────────────────────────\n if (blockType === \"Get Element Text\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Get Element Text: selector required\", bid, \"Missing selector\");\n const r = await runPlaywright(bid, `return await page.textContent(${JSON.stringify(sel)});`);\n if (!r.success) return fail(r.error ?? \"Get Text failed\", bid, `Get text \"${sel}\" failed`);\n const text = (r.result as string ?? \"\").trim();\n return ok(text, { extracted_text: text }, bid, `Got text: \"${text.slice(0, 50)}\"`);\n }\n\n if (blockType === \"Get Page URL\") {\n const r = await runPlaywright(bid, \"return page.url();\");\n if (!r.success) return fail(r.error ?? \"Get URL failed\", bid, \"Get URL failed\");\n return ok(r.result, { page_url: r.result }, bid, `Page URL: ${r.result}`);\n }\n\n if (blockType === \"Get Link URL\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Get Link URL: selector required\", bid, \"Missing selector\");\n const r = await runPlaywright(bid, `return await page.getAttribute(${JSON.stringify(sel)}, 'href');`);\n if (!r.success) return fail(r.error ?? \"Get Link URL failed\", bid, `Get link href \"${sel}\" failed`);\n return ok(r.result, { link_url: r.result }, bid, `Link href: ${r.result}`);\n }\n\n if (blockType === \"Get Element Attribute\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Get Attribute: selector required\", bid, \"Missing selector\");\n const attr = params.attribute as string ?? \"href\";\n const r = await runPlaywright(bid, `return await page.getAttribute(${JSON.stringify(sel)}, ${JSON.stringify(attr)});`);\n if (!r.success) return fail(r.error ?? \"Get Attribute failed\", bid, `Get \"${attr}\" of \"${sel}\" failed`);\n return ok(r.result, { attribute_value: r.result }, bid, `Attribute \"${attr}\" = \"${r.result}\"`);\n }\n\n if (blockType === \"Get Element HTML\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Get Element HTML: selector required\", bid, \"Missing selector\");\n const outer = params.outer as boolean ?? false;\n let code: string;\n if (outer) {\n code = `const el = await page.$(${JSON.stringify(sel)}); if (!el) return null; return await el.evaluate(e => e.outerHTML);`;\n } else {\n code = `return await page.innerHTML(${JSON.stringify(sel)});`;\n }\n const r = await runPlaywright(bid, code);\n const prop = outer ? \"outerHTML\" : \"innerHTML\";\n if (!r.success) return fail(r.error ?? \"Get HTML failed\", bid, `Get ${prop} \"${sel}\" failed`);\n return ok(r.result, { element_html: r.result }, bid, `Got ${prop} of \"${sel}\"`);\n }\n\n if (blockType === \"Take Screenshot\") {\n // Use the screenshot endpoint via API\n const r = await runPlaywright(bid, \"return { url: page.url() };\");\n // We can't return base64 easily from Playwright execute, so return success + session ID\n // The UI can call /api/screenshot/:sid to view it\n return ok({ session_id: bid, screenshot_url: `/api/screenshot/${bid}` },\n { screenshot_session: bid }, bid, `Screenshot ready at /api/screenshot/${bid}`);\n }\n\n // ── Tabs ──────────────────────────────────────────────\n if (blockType === \"Create Tab\") {\n const tabUrl = params.url as string ?? \"about:blank\";\n const r = await runPlaywright(bid, `\n const newPage = await page.context().newPage();\n ${tabUrl !== \"about:blank\" ? `await newPage.goto(${JSON.stringify(tabUrl)}, { waitUntil: 'domcontentloaded' });` : \"\"}\n return { url: newPage.url() };\n `);\n if (!r.success) return fail(r.error ?? \"Create Tab failed\", bid, \"Create Tab failed\");\n return ok(r.result, null, bid, `Created tab → ${tabUrl}`);\n }\n\n if (blockType === \"Get Active Tab ID\") {\n const r = await runPlaywright(bid, \"return page.url();\");\n if (!r.success) return fail(r.error ?? \"Get Tab ID failed\", bid, \"Get Tab ID failed\");\n return ok({ url: r.result }, { active_tab_url: r.result }, bid, `Active tab URL: ${r.result}`);\n }\n\n // ── Run Script ────────────────────────────────────────\n if (blockType === \"Run Script\") {\n const script = params.script as string ?? \"return document.title\";\n const r = await runPlaywright(bid, `return await page.evaluate(() => { ${script} });`);\n if (!r.success) return fail(r.error ?? \"Script failed\", bid, `Script failed`);\n return ok(r.result, { script_result: r.result }, bid, `Script result: ${JSON.stringify(r.result).slice(0, 100)}`);\n }\n\n // ── Run Flow (sub-flow) ────────────────────────────────\n if (blockType === \"Run Flow\") {\n return ok({ sub_flow: params.flow_id }, { sub_flow_id: params.flow_id }, context.browserId ?? null,\n `Sub-flow \"${params.flow_id}\" delegated to runner`);\n }\n\n // ── Solve Captcha (placeholder) ───────────────────────\n if (blockType === \"Solve Captcha\") {\n return fail(\"Solve Captcha: requires external captcha service (2captcha, etc.)\", bid, \"Captcha service not configured\");\n }\n\n // ── Unhandled ─────────────────────────────────────────\n return fail(`Block type \"${blockType}\" not implemented`, context.browserId ?? null,\n `No handler for block type \"${blockType}\"`);\n\n } catch (e) {\n const err = e as Error;\n return fail(err.message, context.browserId ?? null,\n `Error executing block \"${blockType}\": ${err.message}`);\n }\n}\n","// ============================================================\n// BLOCK EXECUTOR – KBA v2\n// Mọi block đều dùng runPlaywright() từ kernelClient.ts\n// Base: POST /browsers/{id}/playwright/execute\n// ============================================================\n\nimport { runPlaywright, createBrowser, takeScreenshot, buildCode, type Action } from \"./kernelClient.ts\";\n\nexport interface BlockExecutionResponse {\n success: boolean;\n data: unknown;\n error: string | null;\n browser_id: string | null;\n browser_state: {\n browser_id: string | null;\n current_url: string | null;\n active_tab_id: string | null;\n screenshot_taken: boolean;\n };\n reasoning_summary: string;\n variables_updated: Record | null;\n next_action_needed: boolean;\n}\n\nfunction ok(\n data: unknown,\n vars: Record | null,\n browserId: string | null,\n summary: string,\n extra: Partial = {}\n): BlockExecutionResponse {\n return {\n success: true, data, error: null,\n browser_id: browserId,\n browser_state: {\n browser_id: browserId,\n current_url: extra.current_url ?? null,\n active_tab_id: extra.active_tab_id ?? null,\n screenshot_taken: extra.screenshot_taken ?? false,\n },\n reasoning_summary: summary,\n variables_updated: vars,\n next_action_needed: false,\n };\n}\n\nfunction fail(\n error: string,\n browserId: string | null,\n summary: string\n): BlockExecutionResponse {\n return {\n success: false, data: null, error,\n browser_id: browserId,\n browser_state: {\n browser_id: browserId,\n current_url: null,\n active_tab_id: null,\n screenshot_taken: false,\n },\n reasoning_summary: summary,\n variables_updated: null,\n next_action_needed: false,\n };\n}\n\n// Ensure we have a browser session\nasync function ensureSession(\n browserId?: string,\n opts: { headless?: boolean; stealth?: boolean } = {}\n): Promise {\n if (browserId) return browserId;\n // Use caller-supplied options so user config is respected\n const b = await createBrowser({\n headless: opts.headless ?? false,\n stealth: opts.stealth ?? true,\n timeout_seconds: 3600,\n });\n return b.session_id;\n}\n\n// Adaptive selector resolution using heuristics\nfunction adaptiveSelector(description: string): string {\n const d = description.toLowerCase();\n if (d.includes(\"search\") && d.includes(\"input\")) return \"input[type='search'], input[placeholder*='search' i]\";\n if (d.includes(\"email\") && d.includes(\"input\")) return \"input[type='email'], input[name*='email' i]\";\n if (d.includes(\"password\")) return \"input[type='password']\";\n if (d.includes(\"submit\") || d.includes(\"login button\")) return \"button[type='submit'], input[type='submit']\";\n if (d.includes(\"username\")) return \"input[name*='user' i], input[id*='user' i]\";\n if (d.includes(\"sign in\") || d.includes(\"log in\")) return \"button:has-text('Sign in'), button:has-text('Log in')\";\n if (d.includes(\"next button\")) return \"button:has-text('Next')\";\n if (d.includes(\"close\")) return \"button[aria-label*='close' i], .close\";\n if (d.includes(\"dropdown\")) return \"select\";\n return `[aria-label*=\"${description}\" i]`;\n}\n\n// ─── MAIN EXECUTOR ────────────────────────────────────────\nexport async function executeBlock(\n blockType: string,\n params: Record,\n context: {\n browserId?: string;\n activeTabId?: string; // Fix: thêm field bị thiếu để flowRunner không bị type error\n currentUrl?: string;\n previousVariables?: Record;\n } = {}\n): Promise {\n try {\n // ── UTILITIES that don't need a browser ──────────────\n\n if (blockType === \"Get Date\") {\n const fmt = (params.format as string) ?? \"ISO\";\n const now = new Date();\n let dateStr: string;\n if (fmt === \"timestamp\") dateStr = now.getTime().toString();\n else if (fmt === \"YYYY-MM-DD\") dateStr = now.toISOString().split(\"T\")[0];\n else if (fmt === \"HH:mm:ss\") dateStr = now.toTimeString().slice(0, 8);\n else dateStr = now.toISOString();\n return ok(dateStr, { current_date: dateStr }, context.browserId ?? null, `Date: ${dateStr}`);\n }\n\n if (blockType === \"Wait\") {\n const ms = (params.duration_ms as number) ?? 1000;\n await new Promise(r => setTimeout(r, ms));\n return ok({ waited_ms: ms }, null, context.browserId ?? null, `Waited ${ms}ms`);\n }\n\n if (blockType === \"Comment\") {\n return ok({ comment: params.text }, null, context.browserId ?? null, `Comment: ${params.text}`);\n }\n\n if (blockType === \"Show Alert\") {\n console.log(`[KBA ALERT] ${params.text}`);\n return ok({ alert_text: params.text }, null, context.browserId ?? null, `Alert: ${params.text}`);\n }\n\n if (blockType === \"Make HTTP Request\") {\n const method = (params.method as string) ?? \"GET\";\n const url = params.url as string;\n if (!url) return fail(\"Make HTTP Request: url required\", context.browserId ?? null, \"Missing url param\");\n const res = await fetch(url, {\n method,\n headers: (params.headers as Record) ?? {},\n body: params.body ? JSON.stringify(params.body) : undefined,\n });\n let data: unknown;\n try { data = await res.json(); } catch { data = await res.text(); }\n return ok(data, { http_response: data, http_status: res.status }, context.browserId ?? null,\n `HTTP ${method} ${url} → ${res.status}`);\n }\n\n if (blockType === \"Assert\") {\n const vars = context.previousVariables ?? {};\n let passed = false;\n let assertError = \"\";\n try {\n const fn = new Function(...Object.keys(vars), `return (${params.condition ?? \"true\"})`);\n passed = Boolean(fn(...Object.values(vars)));\n } catch (e) { assertError = (e as Error).message; }\n if (!passed) return fail(`Assert failed: \"${params.condition}\" ${params.message ?? \"\"} ${assertError}`, context.browserId ?? null, `Assert FAIL`);\n return ok({ passed: true }, null, context.browserId ?? null, `Assert PASS: \"${params.condition}\"`);\n }\n\n if (blockType === \"If\") {\n const vars = { ...context.previousVariables, ...(params.variable_map as Record ?? {}) };\n let condResult = false;\n try {\n const fn = new Function(...Object.keys(vars), `return (${params.condition ?? \"true\"})`);\n condResult = Boolean(fn(...Object.values(vars)));\n } catch { condResult = false; }\n return ok({ condition_result: condResult }, { __condition__: condResult }, context.browserId ?? null,\n `If: \"${params.condition}\" → ${condResult}`);\n }\n\n if ([\"Loop\", \"While\", \"End\", \"Break\", \"Loop Elements\", \"Loop List Items\"].includes(blockType)) {\n return ok({ control_flow_block: blockType }, { __control_flow__: blockType }, context.browserId ?? null,\n `Control flow [${blockType}] – handled by runner`);\n }\n\n // ── ALL BROWSER BLOCKS use runPlaywright ─────────────\n\n const bid = await ensureSession(context.browserId);\n const actions: Action[] = [];\n\n // ── Navigate ──────────────────────────────────────────\n if (blockType === \"Visit\") {\n actions.push({ type: \"Visit\", url: params.url as string, waitUntil: (params.wait_until as string) ?? \"load\" });\n const code = buildCode(actions) + \"\\nreturn page.url();\";\n const r = await runPlaywright(bid, code);\n if (!r.success) return fail(r.error ?? \"Visit failed\", bid, `Visit ${params.url} failed`);\n // Persist current_url so runner state can be updated\n return ok({ url: r.result }, null, bid, `Visited: ${params.url}`, { current_url: r.result as string });\n }\n\n if (blockType === \"Go Back\") {\n const r = await runPlaywright(bid, \"await page.goBack(); return page.url();\");\n if (!r.success) return fail(r.error ?? \"Go Back failed\", bid, \"Go Back failed\");\n return ok({ url: r.result }, null, bid, `Go Back → ${r.result}`, { current_url: r.result as string });\n }\n\n if (blockType === \"Go Forward\") {\n const r = await runPlaywright(bid, \"await page.goForward(); return page.url();\");\n if (!r.success) return fail(r.error ?? \"Go Forward failed\", bid, \"Go Forward failed\");\n return ok({ url: r.result }, null, bid, `Go Forward → ${r.result}`, { current_url: r.result as string });\n }\n\n if (blockType === \"Reload Page\") {\n const r = await runPlaywright(bid, \"await page.reload(); return page.url();\");\n if (!r.success) return fail(r.error ?? \"Reload failed\", bid, \"Reload failed\");\n return ok({ url: r.result }, null, bid, `Reloaded → ${r.result}`, { current_url: r.result as string });\n }\n\n // ── Interact ──────────────────────────────────────────\n if (blockType === \"Click\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Click: selector or description required\", bid, \"Missing selector\");\n const r = await runPlaywright(bid, `await page.click(${JSON.stringify(sel)}); return page.url();`);\n if (!r.success) return fail(r.error ?? \"Click failed\", bid, `Click \"${sel}\" failed`);\n return ok({ selector: sel }, null, bid, `Clicked \"${sel}\"`, { current_url: r.result as string });\n }\n\n if (blockType === \"Type Text\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Type Text: selector required\", bid, \"Missing selector\");\n const text = params.text as string ?? \"\";\n const clearFirst = params.clear_first !== false;\n const code = clearFirst\n ? `await page.fill(${JSON.stringify(sel)}, ${JSON.stringify(text)}); return page.url();`\n : `await page.type(${JSON.stringify(sel)}, ${JSON.stringify(text)}); return page.url();`;\n const r = await runPlaywright(bid, code);\n if (!r.success) return fail(r.error ?? \"Type failed\", bid, `Type \"${text}\" into \"${sel}\" failed`);\n return ok({ selector: sel, text }, null, bid, `Typed \"${text.slice(0, 30)}\" into \"${sel}\"`, { current_url: r.result as string });\n }\n\n if (blockType === \"Press Key\") {\n const key = params.key as string ?? \"Enter\";\n const r = await runPlaywright(bid, `await page.keyboard.press(${JSON.stringify(key)});`);\n if (!r.success) return fail(r.error ?? \"Press Key failed\", bid, `Press Key \"${key}\" failed`);\n return ok({ key }, null, bid, `Pressed key \"${key}\"`);\n }\n\n if (blockType === \"Scroll\") {\n const dir = params.direction as string ?? \"down\";\n const amt = (params.amount as number) ?? 300;\n let code = \"\";\n if (dir === \"down\") code = `await page.evaluate(() => window.scrollBy(0, ${amt}));`;\n else if (dir === \"up\") code = `await page.evaluate(() => window.scrollBy(0, -${amt}));`;\n else if (dir === \"to_bottom\") code = `await page.evaluate(() => window.scrollTo(0, document.body.scrollHeight));`;\n else if (dir === \"to_top\") code = `await page.evaluate(() => window.scrollTo(0, 0));`;\n else if (dir === \"to_element\" && params.selector) code = `await page.locator(${JSON.stringify(params.selector)}).scrollIntoViewIfNeeded();`;\n else code = `await page.evaluate(() => window.scrollBy(0, ${amt}));`;\n const r = await runPlaywright(bid, code);\n if (!r.success) return fail(r.error ?? \"Scroll failed\", bid, `Scroll \"${dir}\" failed`);\n return ok({ direction: dir }, null, bid, `Scrolled \"${dir}\"`);\n }\n\n if (blockType === \"Hover\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Hover: selector required\", bid, \"Missing selector\");\n const r = await runPlaywright(bid, `await page.hover(${JSON.stringify(sel)});`);\n if (!r.success) return fail(r.error ?? \"Hover failed\", bid, `Hover \"${sel}\" failed`);\n return ok({ selector: sel }, null, bid, `Hovered \"${sel}\"`);\n }\n\n if (blockType === \"Select Option\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Select Option: selector required\", bid, \"Missing selector\");\n const val = params.value as string ?? params.label as string ?? \"\";\n const r = await runPlaywright(bid, `await page.selectOption(${JSON.stringify(sel)}, ${JSON.stringify(val)});`);\n if (!r.success) return fail(r.error ?? \"Select failed\", bid, `Select \"${val}\" failed`);\n return ok({ selector: sel, value: val }, null, bid, `Selected \"${val}\" in \"${sel}\"`);\n }\n\n if (blockType === \"Set Date Input\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Set Date Input: selector required\", bid, \"Missing selector\");\n const date = params.date as string ?? \"\";\n const r = await runPlaywright(bid, `await page.fill(${JSON.stringify(sel)}, ${JSON.stringify(date)});`);\n if (!r.success) return fail(r.error ?? \"Set Date failed\", bid, `Set date \"${date}\" failed`);\n return ok({ selector: sel, date }, null, bid, `Set date \"${date}\" on \"${sel}\"`);\n }\n\n if (blockType === \"Wait for Element\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Wait for Element: selector required\", bid, \"Missing selector\");\n const state = params.state as string ?? \"visible\";\n const timeout = (params.timeout_ms as number) ?? 10000;\n const r = await runPlaywright(bid,\n `await page.waitForSelector(${JSON.stringify(sel)}, { state: ${JSON.stringify(state)}, timeout: ${timeout} });`);\n if (!r.success) return fail(r.error ?? \"Wait for Element failed\", bid, `Wait for \"${sel}\" failed`);\n return ok({ selector: sel }, null, bid, `Element \"${sel}\" is now \"${state}\"`);\n }\n\n // ── Extract ───────────────────────────────────────────\n if (blockType === \"Get Element Text\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Get Element Text: selector required\", bid, \"Missing selector\");\n const r = await runPlaywright(bid, `return await page.textContent(${JSON.stringify(sel)});`);\n if (!r.success) return fail(r.error ?? \"Get Text failed\", bid, `Get text \"${sel}\" failed`);\n const text = (r.result as string ?? \"\").trim();\n return ok(text, { extracted_text: text }, bid, `Got text: \"${text.slice(0, 50)}\"`);\n }\n\n if (blockType === \"Get Page URL\") {\n const r = await runPlaywright(bid, \"return page.url();\");\n if (!r.success) return fail(r.error ?? \"Get URL failed\", bid, \"Get URL failed\");\n return ok(r.result, { page_url: r.result }, bid, `Page URL: ${r.result}`, { current_url: r.result as string });\n }\n\n if (blockType === \"Get Link URL\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Get Link URL: selector required\", bid, \"Missing selector\");\n const r = await runPlaywright(bid, `return await page.getAttribute(${JSON.stringify(sel)}, 'href');`);\n if (!r.success) return fail(r.error ?? \"Get Link URL failed\", bid, `Get link href \"${sel}\" failed`);\n return ok(r.result, { link_url: r.result }, bid, `Link href: ${r.result}`);\n }\n\n if (blockType === \"Get Element Attribute\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Get Attribute: selector required\", bid, \"Missing selector\");\n const attr = params.attribute as string ?? \"href\";\n const r = await runPlaywright(bid, `return await page.getAttribute(${JSON.stringify(sel)}, ${JSON.stringify(attr)});`);\n if (!r.success) return fail(r.error ?? \"Get Attribute failed\", bid, `Get \"${attr}\" of \"${sel}\" failed`);\n return ok(r.result, { attribute_value: r.result }, bid, `Attribute \"${attr}\" = \"${r.result}\"`);\n }\n\n if (blockType === \"Get Element HTML\") {\n let sel = params.selector as string;\n if (!sel && params.description) sel = adaptiveSelector(params.description as string);\n if (!sel) return fail(\"Get Element HTML: selector required\", bid, \"Missing selector\");\n const outer = params.outer as boolean ?? false;\n let code: string;\n if (outer) {\n code = `const el = await page.$(${JSON.stringify(sel)}); if (!el) return null; return await el.evaluate(e => e.outerHTML);`;\n } else {\n code = `return await page.innerHTML(${JSON.stringify(sel)});`;\n }\n const r = await runPlaywright(bid, code);\n const prop = outer ? \"outerHTML\" : \"innerHTML\";\n if (!r.success) return fail(r.error ?? \"Get HTML failed\", bid, `Get ${prop} \"${sel}\" failed`);\n return ok(r.result, { element_html: r.result }, bid, `Got ${prop} of \"${sel}\"`);\n }\n\n if (blockType === \"Take Screenshot\") {\n // Fix: actually call takeScreenshot() instead of a dummy runPlaywright\n try {\n const b64 = await takeScreenshot(bid);\n return ok(\n { session_id: bid, screenshot_base64: b64, screenshot_url: `/api/screenshot/${bid}` },\n { screenshot_session: bid },\n bid,\n `Screenshot taken for session ${bid}`,\n { screenshot_taken: true }\n );\n } catch (e) {\n return fail(`Take Screenshot failed: ${(e as Error).message}`, bid, \"Screenshot error\");\n }\n }\n\n // ── Tabs ──────────────────────────────────────────────\n if (blockType === \"Create Tab\") {\n const tabUrl = params.url as string ?? \"about:blank\";\n const r = await runPlaywright(bid, `\n const newPage = await page.context().newPage();\n ${tabUrl !== \"about:blank\" ? `await newPage.goto(${JSON.stringify(tabUrl)}, { waitUntil: 'domcontentloaded' });` : \"\"}\n return { url: newPage.url() };\n `);\n if (!r.success) return fail(r.error ?? \"Create Tab failed\", bid, \"Create Tab failed\");\n return ok(r.result, null, bid, `Created tab → ${tabUrl}`);\n }\n\n if (blockType === \"Get Active Tab ID\") {\n const r = await runPlaywright(bid, \"return page.url();\");\n if (!r.success) return fail(r.error ?? \"Get Tab ID failed\", bid, \"Get Tab ID failed\");\n return ok({ url: r.result }, { active_tab_url: r.result }, bid, `Active tab URL: ${r.result}`, {\n active_tab_id: r.result as string,\n current_url: r.result as string,\n });\n }\n\n // ── Run Script ────────────────────────────────────────\n if (blockType === \"Run Script\") {\n const script = params.script as string ?? \"return document.title\";\n const r = await runPlaywright(bid, `return await page.evaluate(() => { ${script} });`);\n if (!r.success) return fail(r.error ?? \"Script failed\", bid, `Script failed`);\n return ok(r.result, { script_result: r.result }, bid, `Script result: ${JSON.stringify(r.result).slice(0, 100)}`);\n }\n\n // ── Run Flow (sub-flow) ────────────────────────────────\n if (blockType === \"Run Flow\") {\n return ok({ sub_flow: params.flow_id }, { sub_flow_id: params.flow_id }, context.browserId ?? null,\n `Sub-flow \"${params.flow_id}\" delegated to runner`);\n }\n\n // ── Solve Captcha (placeholder) ───────────────────────\n if (blockType === \"Solve Captcha\") {\n return fail(\"Solve Captcha: requires external captcha service (2captcha, etc.)\", bid, \"Captcha service not configured\");\n }\n\n // ── Unhandled ─────────────────────────────────────────\n return fail(`Block type \"${blockType}\" not implemented`, context.browserId ?? null,\n `No handler for block type \"${blockType}\"`);\n\n } catch (e) {\n const err = e as Error;\n return fail(err.message, context.browserId ?? null,\n `Error executing block \"${blockType}\": ${err.message}`);\n }\n}\n","createdAt",["D",1773577419848],"branchVersion","branchId","49f48818-1fbe-11f1-aac6-42dde27851f2","id","49f3e0e8-1fbe-11f1-aac6-42dde27851f2","kba",["D",1773503757015],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","019ced01-90af-7019-a349-1b32c2e46191","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019ced04-6266-748c-a6bb-b70a7446d59e","tursoName","49f3e0e81fbe11f1aac642dde27851f2","tursoHostname","49f3e0e81fbe11f1aac642dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789528252206],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_104":103,"_112":108},"org",{"_104":103,"_105":106,"_107":108,"_19":-5,"_109":110,"_111":31},"branch",{"_13":93,"_38":94,"_49":48,"_95":50,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":51,"_102":103},"isOwned",79,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","minhmmo","handle","displayName","adminh","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/0cef36b0-8080-4c50-5206-197543f8c300/square512?exp=1789590596&sig=8090562889d75e502111eca24a5bdcb92eccb9ea437347a375d16a783f1a88a5","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_49":50,"_38":51,"_44":223,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":-5,"_59":-5,"_19":60,"_61":-5,"_62":63,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":224,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":225,"_88":226,"_90":227,"_92":31},"tree",[198,199,200,201,202,203],"files",[198,199,200,201,202,203],"counts",{"_187":67,"_188":189,"_190":67,"_191":192,"_193":194},"contents",[135,136,137,138,139,140],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":183,"_38":34,"_36":37,"_144":-5,"_47":48,"_46":14,"_146":63,"_44":184,"_13":185,"_39":40,"_41":43,"_30":31,"_151":-5,"_33":186},{"_49":176,"_38":177,"_36":178,"_144":-5,"_47":48,"_46":179,"_146":63,"_44":180,"_13":67,"_39":40,"_41":181,"_30":31,"_151":-5,"_33":182},{"_49":168,"_38":169,"_36":170,"_144":-5,"_47":48,"_46":171,"_146":63,"_44":172,"_13":173,"_39":40,"_41":174,"_30":31,"_151":-5,"_33":175},{"_49":160,"_38":161,"_36":162,"_144":-5,"_47":48,"_46":163,"_146":31,"_44":164,"_13":165,"_39":40,"_41":166,"_30":31,"_151":-5,"_33":167},{"_49":153,"_38":154,"_36":155,"_144":-5,"_47":48,"_46":156,"_146":31,"_44":157,"_13":67,"_39":40,"_41":158,"_30":31,"_151":-5,"_33":159},{"_49":141,"_38":142,"_36":143,"_144":-5,"_47":48,"_46":145,"_146":31,"_44":147,"_13":148,"_39":149,"_41":150,"_30":31,"_151":-5,"_33":152},"d17941e0-1fcb-11f1-8f7c-42dde27851f2","ui.ts","cec62260-1fc1-11f1-95fc-42dde27851f2","parentId",64,"latest",["D",1773509567829],38,"http","// ============================================================\n// KBA — ui.ts | HTTP handler: UI + API routes\n// Tất cả route /api/* và / đều được xử lý tại đây\n// ============================================================\n\nimport {\n createBrowser,\n listBrowsers,\n getBrowser,\n deleteBrowser,\n runPlaywright,\n takeScreenshot,\n listProfiles,\n createProfile,\n type KernelBrowser,\n} from \"./kernelClient.ts\";\nimport { executeBlock } from \"./blockExecutor.ts\";\n\nconst CORS_HEADERS = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, DELETE, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\",\n \"Cache-Control\": \"no-store\",\n};\n\nfunction json(data: unknown, status = 200): Response {\n return new Response(JSON.stringify(data), {\n status,\n headers: { \"Content-Type\": \"application/json\", ...CORS_HEADERS },\n });\n}\n\nexport default async function handler(req: Request): Promise {\n const url = new URL(req.url);\n const path = url.pathname;\n\n // CORS preflight\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: CORS_HEADERS });\n }\n\n // ── API: GET /api/health ───────────────────────────────\n if (path === \"/api/health\") {\n return json({\n ok: true,\n kernel_key: !!Deno.env.get(\"KERNEL_API_KEY\"),\n ts: new Date().toISOString(),\n });\n }\n\n // ── API: GET /api/sessions ─────────────────────────────\n if (req.method === \"GET\" && path === \"/api/sessions\") {\n try {\n const browsers = await listBrowsers();\n // Normalize: trả về sessions với field nhất quán cho UI\n const sessions = browsers.map(b => ({\n id: b.session_id,\n session_id: b.session_id,\n status: b.deleted_at ? \"deleted\" : \"active\",\n live_view_url: b.browser_live_view_url ?? null,\n cdp_ws_url: b.cdp_ws_url,\n headless: b.headless,\n stealth: b.stealth,\n created_at: b.created_at,\n }));\n return json({ ok: true, sessions });\n } catch (e) {\n return json({ ok: false, error: (e as Error).message }, 500);\n }\n }\n\n // ── API: POST /api/sessions ────────────────────────────\n if (req.method === \"POST\" && path === \"/api/sessions\") {\n let body: Record = {};\n try { body = await req.json(); } catch { /* ok */ }\n try {\n const b = await createBrowser({\n headless: (body.headless as boolean) ?? false,\n stealth: (body.stealth as boolean) ?? true,\n timeout_seconds: (body.timeout_seconds as number) ?? 3600,\n });\n return json({\n ok: true,\n session: {\n id: b.session_id,\n session_id: b.session_id,\n status: \"active\",\n live_view_url: b.browser_live_view_url ?? null,\n cdp_ws_url: b.cdp_ws_url,\n headless: b.headless,\n stealth: b.stealth,\n created_at: b.created_at,\n }\n });\n } catch (e) {\n return json({ ok: false, error: (e as Error).message }, 500);\n }\n }\n\n // ── API: GET /api/sessions/:id ─────────────────────────\n const sessionIdMatch = path.match(/^\\/api\\/sessions\\/([^/]+)$/);\n if (req.method === \"GET\" && sessionIdMatch) {\n try {\n const b = await getBrowser(sessionIdMatch[1]);\n return json({ ok: true, session: { id: b.session_id, ...b } });\n } catch (e) {\n return json({ ok: false, error: (e as Error).message }, 404);\n }\n }\n\n // ── API: DELETE /api/sessions/:id ─────────────────────\n if (req.method === \"DELETE\" && sessionIdMatch) {\n try {\n await deleteBrowser(sessionIdMatch![1]);\n return json({ ok: true });\n } catch (e) {\n return json({ ok: false, error: (e as Error).message }, 500);\n }\n }\n\n // ── API: GET /api/profiles ─────────────────────────────\n if (req.method === \"GET\" && path === \"/api/profiles\") {\n try {\n const profiles = await listProfiles();\n return json({ ok: true, profiles });\n } catch (e) {\n return json({ ok: false, error: (e as Error).message }, 500);\n }\n }\n\n // ── API: POST /api/profiles ────────────────────────────\n if (req.method === \"POST\" && path === \"/api/profiles\") {\n let body: Record = {};\n try { body = await req.json(); } catch { /* ok */ }\n try {\n const profile = await createProfile((body.name as string) ?? \"kba-\" + Date.now());\n return json({ ok: true, profile });\n } catch (e) {\n return json({ ok: false, error: (e as Error).message }, 500);\n }\n }\n\n // ── API: POST /api/playwright ──────────────────────────\n if (req.method === \"POST\" && path === \"/api/playwright\") {\n let body: Record = {};\n try { body = await req.json(); } catch { /* ok */ }\n const sid = body.session_id as string;\n const code = body.code as string;\n if (!sid) return json({ ok: false, error: \"session_id required\" }, 400);\n if (!code) return json({ ok: false, error: \"code required\" }, 400);\n const result = await runPlaywright(sid, code, (body.timeout_sec as number) ?? 60);\n return json({ ok: result.success, ...result });\n }\n\n // ── API: GET /api/screenshot/:sid ─────────────────────\n const scMatch = path.match(/^\\/api\\/screenshot\\/([^/]+)$/);\n if (req.method === \"GET\" && scMatch) {\n try {\n const b64 = await takeScreenshot(scMatch[1]);\n return new Response(\n `\n

\n `,\n { headers: { \"Content-Type\": \"text/html\", \"Cache-Control\": \"no-store\" } }\n );\n } catch (e) {\n return json({ ok: false, error: (e as Error).message }, 500);\n }\n }\n\n // ── API: POST /api/execute ─────────────────────────────\n // Called by runBlock() in the UI for each flow block\n if (req.method === \"POST\" && path === \"/api/execute\") {\n let body: Record = {};\n try { body = await req.json(); } catch { /* ok */ }\n const blockType = body.block_type as string;\n const blockParams = (body.block_params as Record) ?? {};\n const browserId = body.browser_id as string | undefined;\n const currentUrl = body.current_url as string | undefined;\n const previousVariables = (body.variables as Record) ?? {};\n if (!blockType) return json({ ok: false, error: \"block_type required\" }, 400);\n try {\n const result = await executeBlock(blockType, blockParams, {\n browserId,\n currentUrl,\n previousVariables,\n });\n return json({ ok: result.success, ...result });\n } catch (e) {\n return json({ ok: false, error: (e as Error).message, success: false }, 500);\n }\n }\n\n // ── UI: serve HTML for all other GET requests ──────────\n const html = buildHTML();\n return new Response(html, {\n headers: {\n \"Content-Type\": \"text/html;charset=utf-8\",\n \"Cache-Control\": \"no-store, no-cache, must-revalidate\",\n \"Pragma\": \"no-cache\",\n },\n });\n}\n\nfunction buildHTML(): string {\n return `\n\n\n\n\nKBA — Kernel Browser Automation\n\n\n\n\n\n

\n\n \n \n\n \n \n\n \n \n\n \n

\n\n \n

\n \n

Drag blocks here to build your flow

or click \"Add Block\" to get started

\n \n \n

\n\n \n

\n \n

\n\n \n

\n \n

\n 0 total\n 0 ok\n 0 err\n 0 warn\n

\n\n \n

\n \n

\n \n \n \n

\n\n

\n\n \n \n\n

\n\n\n\n

\n\n\n\n`;\n}\n","label",[142],"b4604290-1fbf-11f1-a5fb-42dde27851f2","types.ts","b4604330-1fbf-11f1-a5fb-42dde27851f2",2,["D",1773504365048],"// ============================================================\n// TYPES & INTERFACES – Kernel Browser Automation (KBA)\n// ============================================================\n\nexport type BlockType =\n // Interact with Page\n | \"Click\" | \"Type Text\" | \"Press Key\" | \"Scroll\" | \"Hover\"\n | \"Select Option\" | \"Set Date Input\" | \"Upload File\" | \"Handle Dialog\"\n // Extract Data\n | \"Get Element Text\" | \"Get Link URL\" | \"Get Page URL\"\n | \"Get Element Attribute\" | \"Get Element HTML\" | \"Get Clipboard\"\n | \"Save File\" | \"Take Screenshot\" | \"Generate PDF\"\n // Navigate\n | \"Visit\" | \"Go Back\" | \"Go Forward\" | \"Reload Page\"\n // Spreadsheet\n | \"Loop Spreadsheet Rows\" | \"Add Spreadsheet Row\"\n | \"Update Spreadsheet Row\" | \"Find Spreadsheet Row\"\n // Control Flow\n | \"Loop Elements\" | \"Loop Pages\" | \"Loop\" | \"Loop List Items\"\n | \"If\" | \"Else\" | \"While\" | \"End\" | \"Break\"\n // Tabs\n | \"Create Tab\" | \"Get Active Tab ID\" | \"Select Tab\" | \"Close Tab\"\n // Utilities\n | \"Run Script\" | \"Get Date\" | \"Wait\" | \"Wait for Element\"\n | \"Show Alert\" | \"Make HTTP Request\" | \"Assert\" | \"Run Flow\"\n | \"Comment\" | \"Solve Captcha\";\n\nexport type ExecutionMode = \"rule\" | \"adaptive\";\n\n// ─── Block Params per type ──────────────────────────────────\n\nexport interface ClickParams {\n mode: ExecutionMode;\n selector?: string; // rule-based\n description?: string; // adaptive\n button?: \"left\" | \"right\" | \"middle\";\n double_click?: boolean;\n}\n\nexport interface TypeTextParams {\n mode: ExecutionMode;\n selector?: string;\n description?: string;\n text: string;\n clear_first?: boolean;\n press_enter_after?: boolean;\n}\n\nexport interface PressKeyParams {\n key: string; // \"Enter\", \"Tab\", \"ArrowDown\", \"Escape\", etc.\n selector?: string;\n}\n\nexport interface ScrollParams {\n direction: \"down\" | \"up\" | \"to_bottom\" | \"to_top\" | \"to_element\";\n amount?: number; // pixels (for down/up)\n selector?: string; // for to_element\n}\n\nexport interface HoverParams {\n mode: ExecutionMode;\n selector?: string;\n description?: string;\n}\n\nexport interface SelectOptionParams {\n mode: ExecutionMode;\n selector?: string;\n description?: string;\n value?: string;\n label?: string;\n}\n\nexport interface SetDateInputParams {\n mode: ExecutionMode;\n selector?: string;\n description?: string;\n date: string; // ISO or locale format\n}\n\nexport interface UploadFileParams {\n mode: ExecutionMode;\n selector?: string;\n description?: string;\n file_path?: string;\n file_base64?: string;\n file_name?: string;\n}\n\nexport interface HandleDialogParams {\n action: \"accept\" | \"dismiss\" | \"type_and_accept\";\n text?: string; // for prompt dialogs\n}\n\nexport interface GetElementTextParams {\n mode: ExecutionMode;\n selector?: string;\n description?: string;\n trim?: boolean;\n}\n\nexport interface GetLinkURLParams {\n mode: ExecutionMode;\n selector?: string;\n description?: string;\n}\n\nexport interface GetElementAttributeParams {\n mode: ExecutionMode;\n selector?: string;\n description?: string;\n attribute: string;\n}\n\nexport interface GetElementHTMLParams {\n mode: ExecutionMode;\n selector?: string;\n description?: string;\n outer?: boolean;\n}\n\nexport interface SaveFileParams {\n mode: ExecutionMode;\n selector?: string;\n description?: string;\n url?: string;\n save_to?: string;\n}\n\nexport interface TakeScreenshotParams {\n full_page?: boolean;\n region?: { x: number; y: number; width: number; height: number };\n format?: \"png\" | \"jpeg\" | \"webp\";\n}\n\nexport interface GeneratePDFParams {\n full_page?: boolean;\n format?: string;\n}\n\nexport interface VisitParams {\n url: string;\n new_tab?: boolean;\n wait_until?: \"load\" | \"domcontentloaded\" | \"networkidle\";\n}\n\nexport interface ReloadPageParams {\n hard?: boolean;\n}\n\nexport interface SpreadsheetParams {\n spreadsheet_id: string;\n sheet_name?: string;\n row_data?: Record;\n condition?: Record;\n variable_name?: string;\n}\n\nexport interface IfParams {\n condition: string; // JS expression string\n variable_map?: Record;\n}\n\nexport interface WaitParams {\n duration_ms: number;\n}\n\nexport interface WaitForElementParams {\n mode: ExecutionMode;\n selector?: string;\n description?: string;\n timeout_ms?: number;\n state?: \"visible\" | \"hidden\" | \"attached\" | \"detached\";\n}\n\nexport interface RunScriptParams {\n script: string; // JS to evaluate in browser context\n args?: unknown[];\n}\n\nexport interface GetDateParams {\n format?: string; // e.g. \"YYYY-MM-DD\", \"ISO\", \"timestamp\"\n timezone?: string;\n}\n\nexport interface MakeHTTPRequestParams {\n method: \"GET\" | \"POST\" | \"PUT\" | \"PATCH\" | \"DELETE\";\n url: string;\n headers?: Record;\n body?: unknown;\n response_type?: \"json\" | \"text\" | \"blob\";\n}\n\nexport interface AssertParams {\n condition: string; // JS expression\n message?: string;\n}\n\nexport interface RunFlowParams {\n flow_id: string;\n input_variables?: Record;\n}\n\nexport interface CreateTabParams {\n url?: string;\n}\n\nexport interface SelectTabParams {\n tab_id: string;\n}\n\nexport interface SolveCaptchaParams {\n mode: ExecutionMode;\n selector?: string;\n description?: string;\n service?: \"2captcha\" | \"anticaptcha\" | \"internal\";\n}\n\n// ─── Union Block Params ────────────────────────────────────\n\nexport type BlockParams =\n | ClickParams | TypeTextParams | PressKeyParams | ScrollParams\n | HoverParams | SelectOptionParams | SetDateInputParams | UploadFileParams\n | HandleDialogParams | GetElementTextParams | GetLinkURLParams\n | GetElementAttributeParams | GetElementHTMLParams | SaveFileParams\n | TakeScreenshotParams | GeneratePDFParams | VisitParams | ReloadPageParams\n | SpreadsheetParams | IfParams | WaitParams | WaitForElementParams\n | RunScriptParams | GetDateParams | MakeHTTPRequestParams | AssertParams\n | RunFlowParams | CreateTabParams | SelectTabParams | SolveCaptchaParams\n | Record;\n\n// ─── Block Execution Request ───────────────────────────────\n\nexport interface BlockExecutionRequest {\n block_type: BlockType;\n block_params: BlockParams;\n browser_state?: {\n browser_id?: string;\n active_tab_id?: string;\n current_url?: string;\n };\n previous_variables?: Record;\n screenshot_base64?: string; // for adaptive reasoning\n html_snapshot?: string; // for adaptive reasoning\n flow_id?: string;\n step_index?: number;\n}\n\n// ─── Block Execution Response ──────────────────────────────\n\nexport interface BlockExecutionResponse {\n success: boolean;\n data: unknown;\n error: string | null;\n browser_state: {\n browser_id: string | null;\n current_url: string | null;\n active_tab_id: string | null;\n screenshot_taken: boolean;\n };\n variables_updated: Record | null;\n next_action_needed: boolean;\n reasoning_summary: string;\n}\n\n// ─── Flow Definition ───────────────────────────────────────\n\nexport interface FlowBlock {\n id: string;\n type: BlockType;\n params: BlockParams;\n next?: string; // next block id (for linear flow)\n on_true?: string; // for If blocks\n on_false?: string; // for If blocks\n loop_end?: string; // id of End block for loops\n}\n\nexport interface FlowDefinition {\n id: string;\n name: string;\n start_block: string;\n blocks: Record;\n variables?: Record;\n}\n\n// ─── Kernel Browser Session ────────────────────────────────\n\nexport interface KernelSession {\n session_id: string;\n browser_live_view_url: string;\n profile_id?: string;\n proxy_id?: string;\n}\n\nexport interface KernelProfileConfig {\n name: string;\n proxyCountry: string;\n proxyState?: string;\n proxyCity?: string;\n proxyZip?: string;\n proxyAsn?: string;\n}\n",[154],"ac50a404-1fca-11f1-92c0-42dde27851f2","main.ts","49f688d4-1fbe-11f1-aac6-42dde27851f2",59,["D",1773509075988],3,"// ============================================================\n// KBA – Kernel Browser Automation Agent\n// HTTP Endpoint – Val Town (Deno)\n// Đã xác minh: 14/03/2026\n// ============================================================\n\nimport type { BlockExecutionRequest, FlowDefinition } from \"./types.ts\";\nimport { executeBlock } from \"./blockExecutor.ts\";\nimport { runFlow, parseFlow } from \"./flowRunner.ts\";\nimport {\n createBrowser as createBrowserSession,\n listBrowsers as listBrowserSessions,\n getBrowser as getBrowserSession,\n deleteBrowser as closeBrowserSession,\n} from \"./kernelClient.ts\";\n\nconst CORS = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, DELETE, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization, X-KBA-Token\",\n};\n\nfunction json(data: unknown, status = 200): Response {\n return new Response(JSON.stringify(data, null, 2), {\n status,\n headers: { \"Content-Type\": \"application/json\", ...CORS },\n });\n}\n\nfunction err(message: string, status = 400): Response {\n return json({ success: false, error: message }, status);\n}\n\nfunction isAuthorized(req: Request): boolean {\n const token = Deno.env.get(\"KBA_API_TOKEN\");\n if (!token) return true;\n const h = req.headers.get(\"Authorization\") ?? req.headers.get(\"X-KBA-Token\") ?? \"\";\n return h === `Bearer ${token}` || h === token;\n}\n\nexport default async function handler(req: Request): Promise {\n const url = new URL(req.url);\n\n // CORS preflight\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: CORS });\n }\n\n // ── GET /health ────────────────────────────────────────\n if (req.method === \"GET\" && url.pathname === \"/health\") {\n return json({\n status: \"ok\",\n service: \"KBA – Kernel Browser Automation Agent\",\n version: \"1.0.0\",\n kernel_api_key_set: !!Deno.env.get(\"KERNEL_API_KEY\"),\n timestamp: new Date().toISOString(),\n });\n }\n\n // Auth guard (sau health để health luôn public)\n if (!isAuthorized(req)) {\n return err(\"Unauthorized\", 401);\n }\n\n // ── GET /session – Danh sách tất cả sessions ──────────\n if (req.method === \"GET\" && url.pathname === \"/session\") {\n try {\n const sessions = await listBrowserSessions();\n return json({ success: true, sessions });\n } catch (e) {\n return err(`Lỗi lấy danh sách sessions: ${(e as Error).message}`, 500);\n }\n }\n\n // ── POST /session – Tạo browser session mới ───────────\n if (req.method === \"POST\" && url.pathname === \"/session\") {\n let body: Record = {};\n try { body = await req.json(); } catch { /* body rỗng OK */ }\n\n try {\n const session = await createBrowserSession({\n headless: (body.headless as boolean) ?? false,\n proxy_country: (body.proxy_country as string) ?? undefined,\n proxy_state: (body.proxy_state as string) ?? undefined,\n profile_name: (body.profile_name as string) ?? undefined,\n });\n // Trả về đúng format mà UI expect\n return json({\n success: true,\n session: {\n id: session.id,\n live_view_url: session.live_view_url,\n status: session.status ?? \"active\",\n created_at: session.created_at ?? new Date().toISOString(),\n },\n });\n } catch (e) {\n return err(`Không thể tạo session: ${(e as Error).message}`, 500);\n }\n }\n\n // ── GET /session/:id ───────────────────────────────────\n const sessionMatch = url.pathname.match(/^\\/session\\/([^/]+)$/);\n if (req.method === \"GET\" && sessionMatch) {\n try {\n const session = await getBrowserSession(sessionMatch[1]);\n return json({ success: true, session });\n } catch (e) {\n return err(`Session không tồn tại: ${(e as Error).message}`, 404);\n }\n }\n\n // ── DELETE /session/:id ────────────────────────────────\n if (req.method === \"DELETE\" && sessionMatch) {\n try {\n await closeBrowserSession(sessionMatch![1]);\n return json({ success: true, message: `Session ${sessionMatch![1]} đã đóng` });\n } catch (e) {\n return err(`Lỗi đóng session: ${(e as Error).message}`, 500);\n }\n }\n\n // ── POST /execute – Thực thi 1 block ──────────────────\n if (req.method === \"POST\" && url.pathname === \"/execute\") {\n let body: BlockExecutionRequest;\n try {\n body = await req.json() as BlockExecutionRequest;\n } catch {\n return err(\"Body JSON không hợp lệ\");\n }\n if (!body.block_type) return err(\"Thiếu block_type\");\n if (!body.block_params) return err(\"Thiếu block_params\");\n\n console.log(`[KBA] Execute: ${body.block_type}`);\n const result = await executeBlock(\n body.block_type,\n body.block_params,\n {\n browserId: body.browser_state?.browser_id,\n activeTabId: body.browser_state?.active_tab_id,\n currentUrl: body.browser_state?.current_url,\n previousVariables: body.previous_variables,\n screenshotBase64: body.screenshot_base64,\n htmlSnapshot: body.html_snapshot,\n }\n );\n return json(result, result.success ? 200 : 500);\n }\n\n // ── POST /run-flow – Chạy toàn bộ flow ────────────────\n if (req.method === \"POST\" && url.pathname === \"/run-flow\") {\n let body: { flow: FlowDefinition | string; input_variables?: Record; max_steps?: number };\n try {\n body = await req.json();\n } catch {\n return err(\"Body JSON không hợp lệ\");\n }\n if (!body.flow) return err(\"Thiếu trường flow\");\n\n let flow: FlowDefinition;\n try {\n flow = typeof body.flow === \"string\" ? parseFlow(body.flow) : body.flow;\n } catch (e) {\n return err(`Flow JSON không hợp lệ: ${(e as Error).message}`);\n }\n\n console.log(`[KBA] Run flow: ${flow.name} (${Object.keys(flow.blocks).length} blocks)`);\n const result = await runFlow(flow, body.input_variables ?? {}, {\n maxSteps: body.max_steps ?? 500,\n });\n return json(result, result.success ? 200 : 500);\n }\n\n // 404\n return err(`Endpoint \"${url.pathname}\" không tồn tại. GET /health để xem các endpoint.`, 404);\n}\n",[161],"84e1312e-1fc8-11f1-bded-42dde27851f2","kernelClient.ts","c5b1359a-1fbf-11f1-8b8f-42dde27851f2",45,["D",1773508150828],7,"// ============================================================\n// KERNEL CLIENT — xác minh thực tế từ docs kernel.sh\n// Base URL : https://api.onkernel.com (đã probe, không có /v1/)\n// Auth : Authorization: Bearer \n// Endpoints đã xác minh từ docs chính thức:\n// POST /browsers → tạo session\n// GET /browsers → list sessions\n// GET /browsers/{id} → get session\n// DEL /browsers/{id} → xóa session\n// POST /browsers/{id}/playwright/execute → chạy Playwright TS\n// POST /browsers/{id}/computer/screenshot→ chụp ảnh (trả về image/png)\n// POST /browsers/{id}/computer/click → click chuột\n// POST /browsers/{id}/computer/type → gõ văn bản\n// POST /browsers/{id}/computer/key-press→ nhấn phím\n// POST /browsers/{id}/computer/scroll → cuộn chuột\n// GET /profiles → list profiles\n// POST /profiles → tạo profile\n// ============================================================\n\nconst BASE = \"https://api.onkernel.com\";\n\nfunction apiKey(): string {\n const k = Deno.env.get(\"KERNEL_API_KEY\");\n if (!k) throw new Error(\"KERNEL_API_KEY chưa được set\");\n return k;\n}\n\nasync function kFetch(path: string, opts: RequestInit = {}): Promise {\n const res = await fetch(BASE + path, {\n ...opts,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": \"Bearer \" + apiKey(),\n ...(opts.headers ?? {}),\n },\n });\n const text = await res.text();\n if (!res.ok) throw new Error(`Kernel ${res.status} ${path}: ${text}`);\n if (!text.trim()) return null;\n try { return JSON.parse(text); } catch { return text; }\n}\n\n// ─── Types ────────────────────────────────────────────────\nexport interface KernelBrowser {\n session_id: string;\n browser_live_view_url?: string;\n cdp_ws_url: string;\n webdriver_ws_url: string;\n headless: boolean;\n stealth: boolean;\n timeout_seconds: number;\n created_at: string;\n deleted_at?: string;\n}\n\nexport interface PlaywrightResult {\n success: boolean;\n result?: unknown;\n error?: string;\n stdout?: string;\n stderr?: string;\n}\n\nexport interface KernelProfile {\n id: string;\n name: string;\n created_at: string;\n}\n\n// ─── Browser Sessions ─────────────────────────────────────\n\nexport async function createBrowser(opts: {\n headless?: boolean;\n stealth?: boolean;\n timeout_seconds?: number;\n proxy_id?: string;\n profile_id?: string;\n} = {}): Promise {\n const body: Record = {\n headless: opts.headless ?? false,\n stealth: opts.stealth ?? true,\n timeout_seconds: opts.timeout_seconds ?? 3600,\n };\n if (opts.proxy_id) body.proxy_id = opts.proxy_id;\n if (opts.profile_id) body.profile_id = opts.profile_id;\n return await kFetch(\"/browsers\", {\n method: \"POST\",\n body: JSON.stringify(body),\n }) as KernelBrowser;\n}\n\nexport async function listBrowsers(): Promise {\n const r = await kFetch(\"/browsers\");\n if (Array.isArray(r)) return r as KernelBrowser[];\n return ((r as Record)?.browsers ?? []) as KernelBrowser[];\n}\n\nexport async function getBrowser(id: string): Promise {\n return await kFetch(\"/browsers/\" + id) as KernelBrowser;\n}\n\nexport async function deleteBrowser(id: string): Promise {\n await kFetch(\"/browsers/\" + id, { method: \"DELETE\" });\n}\n\n// ─── Playwright ───────────────────────────────────────────\n// POST /browsers/{id}/playwright/execute\n// Body: { code: string, timeout_sec?: number }\n// Response: { success, result, error, stdout, stderr }\n\nexport async function runPlaywright(\n sessionId: string,\n code: string,\n timeoutSec = 60\n): Promise {\n try {\n return await kFetch(`/browsers/${sessionId}/playwright/execute`, {\n method: \"POST\",\n body: JSON.stringify({ code, timeout_sec: timeoutSec }),\n }) as PlaywrightResult;\n } catch (e) {\n return { success: false, error: (e as Error).message };\n }\n}\n\n// ─── Screenshot ───────────────────────────────────────────\n// POST /browsers/{id}/computer/screenshot\n// Response: image/png binary — ta convert sang base64\n\nexport async function takeScreenshot(sessionId: string): Promise {\n const res = await fetch(`${BASE}/browsers/${sessionId}/computer/screenshot`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": \"Bearer \" + apiKey(),\n },\n body: JSON.stringify({}),\n });\n if (!res.ok) {\n const t = await res.text();\n throw new Error(`Screenshot ${res.status}: ${t}`);\n }\n const buf = await res.arrayBuffer();\n // Dùng Deno's encodeBase64 thay vì btoa (tránh stack overflow với buffer lớn)\n const { encodeBase64 } = await import(\"jsr:@std/encoding@1.0.4/base64\");\n return encodeBase64(new Uint8Array(buf));\n}\n\n// ─── Computer Controls ────────────────────────────────────\n\nexport async function computerClick(\n id: string, x: number, y: number,\n button: \"left\" | \"right\" | \"middle\" = \"left\"\n): Promise {\n await kFetch(`/browsers/${id}/computer/click`, {\n method: \"POST\",\n body: JSON.stringify({ x, y, button }),\n });\n}\n\nexport async function computerType(id: string, text: string): Promise {\n await kFetch(`/browsers/${id}/computer/type`, {\n method: \"POST\",\n body: JSON.stringify({ text }),\n });\n}\n\nexport async function computerKeyPress(id: string, keys: string[]): Promise {\n await kFetch(`/browsers/${id}/computer/key-press`, {\n method: \"POST\",\n body: JSON.stringify({ keys }),\n });\n}\n\nexport async function computerScroll(\n id: string, x: number, y: number,\n deltaX: number, deltaY: number\n): Promise {\n await kFetch(`/browsers/${id}/computer/scroll`, {\n method: \"POST\",\n body: JSON.stringify({ x, y, delta_x: deltaX, delta_y: deltaY }),\n });\n}\n\n// ─── Profiles ─────────────────────────────────────────────\n\nexport async function listProfiles(): Promise {\n const r = await kFetch(\"/profiles\");\n if (Array.isArray(r)) return r as KernelProfile[];\n return ((r as Record)?.profiles ?? []) as KernelProfile[];\n}\n\nexport async function createProfile(name: string): Promise {\n return await kFetch(\"/profiles\", {\n method: \"POST\",\n body: JSON.stringify({ name }),\n }) as KernelProfile;\n}\n\nexport async function deleteProfile(idOrName: string): Promise {\n await kFetch(`/profiles/${idOrName}`, { method: \"DELETE\" });\n}\n\n// ─── Playwright Code Builder ──────────────────────────────\n\nexport interface Action {\n type: string;\n url?: string; waitUntil?: string;\n selector?: string;\n text?: string; clearFirst?: boolean;\n key?: string;\n direction?: string; amount?: number;\n value?: string;\n duration?: number;\n state?: string; timeout?: number;\n attribute?: string;\n script?: string;\n accept?: boolean; promptText?: string;\n condition?: string; message?: string;\n}\n\nexport function buildCode(actions: Action[]): string {\n const lines: string[] = [];\n for (const a of actions) {\n switch (a.type) {\n case \"Visit\":\n lines.push(`await page.goto(${j(a.url)}, { waitUntil: ${j(a.waitUntil ?? \"load\")} });`);\n break;\n case \"Click\":\n if (a.selector) lines.push(`await page.click(${j(a.selector)});`);\n break;\n case \"Type Text\":\n if (a.clearFirst) lines.push(`await page.fill(${j(a.selector)}, ${j(a.text ?? \"\")});`);\n else lines.push(`await page.type(${j(a.selector)}, ${j(a.text ?? \"\")});`);\n break;\n case \"Press Key\":\n lines.push(`await page.keyboard.press(${j(a.key ?? \"Enter\")});`);\n break;\n case \"Scroll\":\n if (a.direction === \"down\") lines.push(`await page.evaluate(() => window.scrollBy(0, ${a.amount ?? 300}));`);\n else if (a.direction === \"up\") lines.push(`await page.evaluate(() => window.scrollBy(0, -${a.amount ?? 300}));`);\n else if (a.direction === \"to_bottom\") lines.push(`await page.evaluate(() => window.scrollTo(0, document.body.scrollHeight));`);\n else if (a.direction === \"to_top\") lines.push(`await page.evaluate(() => window.scrollTo(0, 0));`);\n else if (a.direction === \"to_element\" && a.selector) lines.push(`await page.locator(${j(a.selector)}).scrollIntoViewIfNeeded();`);\n break;\n case \"Hover\":\n if (a.selector) lines.push(`await page.hover(${j(a.selector)});`);\n break;\n case \"Select Option\":\n if (a.selector) lines.push(`await page.selectOption(${j(a.selector)}, ${j(a.value ?? \"\")});`);\n break;\n case \"Wait\":\n lines.push(`await page.waitForTimeout(${a.duration ?? 1000});`);\n break;\n case \"Wait for Element\":\n if (a.selector) lines.push(`await page.waitForSelector(${j(a.selector)}, { state: ${j(a.state ?? \"visible\")}, timeout: ${a.timeout ?? 10000} });`);\n break;\n case \"Get Element Text\":\n if (a.selector) lines.push(`return await page.textContent(${j(a.selector)});`);\n break;\n case \"Get Page URL\":\n lines.push(`return page.url();`);\n break;\n case \"Get Element Attribute\":\n if (a.selector) lines.push(`return await page.getAttribute(${j(a.selector)}, ${j(a.attribute ?? \"href\")});`);\n break;\n case \"Get Element HTML\":\n if (a.selector) lines.push(`return await page.innerHTML(${j(a.selector)});`);\n break;\n case \"Reload Page\":\n lines.push(`await page.reload();`);\n break;\n case \"Go Back\":\n lines.push(`await page.goBack();`);\n break;\n case \"Go Forward\":\n lines.push(`await page.goForward();`);\n break;\n case \"Run Script\":\n lines.push(`return await page.evaluate(() => { ${a.script ?? \"\"} });`);\n break;\n case \"Assert\":\n lines.push(`if (!(${a.condition ?? \"true\"})) throw new Error(${j(a.message ?? \"Assertion failed\")});`);\n break;\n case \"Show Alert\":\n lines.push(`await page.evaluate(() => alert(${j(a.text ?? \"\")}));`);\n break;\n }\n }\n return lines.join(\"\\n\");\n}\n\nfunction j(v: unknown): string { return JSON.stringify(v); }\n",[169],"13121f16-1fc0-11f1-90b3-42dde27851f2","flowRunner.ts","13121fde-1fc0-11f1-90b3-42dde27851f2",5,["D",1773504523924],"// ============================================================\n// FLOW RUNNER – KBA (Val Town Executor)\n// Xử lý toàn bộ luồng: linear, If/Else, Loop, While\n// Control Flow blocks được xử lý ở đây, KHÔNG trong blockExecutor\n// ============================================================\n\nimport type {\n FlowDefinition, FlowBlock, BlockExecutionResponse,\n} from \"./types.ts\";\nimport { executeBlock } from \"./blockExecutor.ts\";\n\n// ─── Runner State ─────────────────────────────────────────\n\ninterface RunnerState {\n variables: Record;\n browserId: string | null;\n activeTabId: string | null;\n currentUrl: string | null;\n stepCount: number;\n maxSteps: number;\n}\n\n// ─── Flow Execution Result ────────────────────────────────\n\nexport interface FlowRunResult {\n success: boolean;\n completed_blocks: number;\n final_variables: Record;\n last_error: string | null;\n browser_state: {\n browser_id: string | null;\n current_url: string | null;\n };\n logs: string[];\n}\n\n// ─── Main Runner ──────────────────────────────────────────\n\nexport async function runFlow(\n flow: FlowDefinition,\n inputVariables: Record = {},\n options: { maxSteps?: number; screenshotOnError?: boolean } = {}\n): Promise {\n const logs: string[] = [];\n const state: RunnerState = {\n variables: { ...flow.variables, ...inputVariables },\n browserId: null,\n activeTabId: null,\n currentUrl: null,\n stepCount: 0,\n maxSteps: options.maxSteps ?? 500,\n };\n\n function log(msg: string) {\n const ts = new Date().toISOString();\n logs.push(`[${ts}] ${msg}`);\n console.log(`[KBA Flow] ${msg}`);\n }\n\n let currentBlockId: string | null = flow.start_block;\n\n try {\n while (currentBlockId !== null && state.stepCount < state.maxSteps) {\n const block = flow.blocks[currentBlockId];\n if (!block) {\n log(`Block ID \"${currentBlockId}\" không tồn tại trong flow. Dừng.`);\n break;\n }\n\n log(`▶ Bước ${++state.stepCount}: [${block.type}] id=\"${currentBlockId}\"`);\n\n // ── CONTROL FLOW ──────────────────────────────────\n\n if (block.type === \"If\") {\n const params = block.params as { condition: string };\n const result = await executeBlock(\"If\", params, {\n browserId: state.browserId ?? undefined,\n currentUrl: state.currentUrl ?? undefined,\n previousVariables: state.variables,\n });\n\n const condResult = (result.variables_updated?.__condition__ as boolean) ?? false;\n log(` If: condition=\"${params.condition}\" → ${condResult}`);\n\n currentBlockId = condResult\n ? (block.on_true ?? block.next ?? null)\n : (block.on_false ?? block.next ?? null);\n continue;\n }\n\n if (block.type === \"Else\") {\n currentBlockId = block.next ?? null;\n continue;\n }\n\n if (block.type === \"End\" || block.type === \"Break\") {\n log(` ${block.type}: Kết thúc/thoát khỏi block hiện tại`);\n currentBlockId = block.next ?? null;\n continue;\n }\n\n if (block.type === \"While\") {\n const params = block.params as { condition: string };\n const loopEnd = block.loop_end;\n let iteration = 0;\n const maxIter = 1000;\n\n while (iteration < maxIter) {\n const result = await executeBlock(\"If\", { condition: params.condition }, {\n browserId: state.browserId ?? undefined,\n currentUrl: state.currentUrl ?? undefined,\n previousVariables: state.variables,\n });\n const cond = result.variables_updated?.__condition__ as boolean;\n if (!cond) break;\n\n log(` While iteration ${++iteration}: condition=true`);\n // Execute body blocks until loop_end\n let bodyId = block.next ?? null;\n while (bodyId && bodyId !== loopEnd) {\n const bodyBlock = flow.blocks[bodyId];\n if (!bodyBlock) break;\n if (bodyBlock.type === \"Break\") { bodyId = null; break; }\n const bodyResult = await executeBlockAndUpdateState(bodyBlock, state, log);\n if (!bodyResult.success) {\n return buildResult(false, state, bodyResult.error, logs);\n }\n bodyId = bodyBlock.next ?? null;\n }\n if (bodyId === null) break; // Break encountered\n }\n currentBlockId = loopEnd ?? block.next ?? null;\n continue;\n }\n\n if ([\"Loop\", \"Loop Elements\", \"Loop Pages\", \"Loop List Items\"].includes(block.type)) {\n const params = block.params as {\n items?: unknown[];\n variable_name?: string;\n index_variable?: string;\n selector?: string;\n page_count?: number;\n };\n\n const items = params.items ??\n (typeof state.variables[params.variable_name ?? \"items\"] === \"object\"\n ? (state.variables[params.variable_name ?? \"items\"] as unknown[])\n : []);\n\n const loopEnd = block.loop_end;\n log(` Loop: ${items.length} items`);\n\n for (let i = 0; i < items.length; i++) {\n state.variables[params.variable_name ?? \"item\"] = items[i];\n if (params.index_variable) state.variables[params.index_variable] = i;\n\n let bodyId = block.next ?? null;\n while (bodyId && bodyId !== loopEnd) {\n const bodyBlock = flow.blocks[bodyId];\n if (!bodyBlock) break;\n if (bodyBlock.type === \"Break\") { bodyId = null; break; }\n if (bodyBlock.type === \"End\") break;\n const bodyResult = await executeBlockAndUpdateState(bodyBlock, state, log);\n if (!bodyResult.success) {\n return buildResult(false, state, bodyResult.error, logs);\n }\n bodyId = bodyBlock.next ?? null;\n }\n if (bodyId === null) break;\n }\n\n currentBlockId = loopEnd ?? block.next ?? null;\n continue;\n }\n\n // ── REGULAR BLOCK ─────────────────────────────────\n\n const result = await executeBlockAndUpdateState(block, state, log);\n if (!result.success) {\n log(` ❌ Lỗi: ${result.error}`);\n return buildResult(false, state, result.error, logs);\n }\n\n currentBlockId = block.next ?? null;\n }\n\n if (state.stepCount >= state.maxSteps) {\n log(`⚠️ Flow đạt giới hạn ${state.maxSteps} bước. Dừng.`);\n }\n\n log(`✅ Flow hoàn thành sau ${state.stepCount} bước`);\n return buildResult(true, state, null, logs);\n\n } catch (e) {\n const err = e as Error;\n log(`❌ Lỗi không mong đợi: ${err.message}`);\n return buildResult(false, state, err.message, logs);\n }\n}\n\n// ─── Execute block & sync runner state ────────────────────\n\nasync function executeBlockAndUpdateState(\n block: FlowBlock,\n state: RunnerState,\n log: (msg: string) => void\n): Promise {\n const result = await executeBlock(block.type, block.params, {\n browserId: state.browserId ?? undefined,\n activeTabId: state.activeTabId ?? undefined,\n currentUrl: state.currentUrl ?? undefined,\n previousVariables: state.variables,\n });\n\n // Sync browser state\n if (result.browser_state.browser_id) {\n state.browserId = result.browser_state.browser_id;\n }\n if (result.browser_state.current_url) {\n state.currentUrl = result.browser_state.current_url;\n }\n if (result.browser_state.active_tab_id) {\n state.activeTabId = result.browser_state.active_tab_id;\n }\n\n // Merge variables\n if (result.variables_updated) {\n Object.assign(state.variables, result.variables_updated);\n }\n\n log(` ✓ ${result.reasoning_summary}`);\n return result;\n}\n\n// ─── Build final result ────────────────────────────────────\n\nfunction buildResult(\n success: boolean,\n state: RunnerState,\n error: string | null,\n logs: string[]\n): FlowRunResult {\n return {\n success,\n completed_blocks: state.stepCount,\n final_variables: state.variables,\n last_error: error,\n browser_state: {\n browser_id: state.browserId,\n current_url: state.currentUrl,\n },\n logs,\n };\n}\n\n// ─── Helper: Parse flow from JSON ────────────────────────\n\nexport function parseFlow(flowJson: string): FlowDefinition {\n return JSON.parse(flowJson) as FlowDefinition;\n}\n",[177],"cc76e2ee-2069-11f1-aff0-42dde27851f2",["D",1773577419848],4,[34],"pulls","branches",1,"forks","envVars",{"_195":189,"_197":67},"connections",{"_195":67,"_196":67},"count","unfilledCount","emptyCount",{"_49":183,"_38":34,"_36":37,"_144":-5,"_47":48,"_46":14,"_146":63,"_44":220,"_13":185,"_39":40,"_41":43,"_30":31,"_151":-5,"_205":221,"_33":222},{"_49":176,"_38":177,"_36":178,"_144":-5,"_47":48,"_46":179,"_146":63,"_44":217,"_13":67,"_39":40,"_41":181,"_30":31,"_151":-5,"_205":218,"_33":219},{"_49":168,"_38":169,"_36":170,"_144":-5,"_47":48,"_46":171,"_146":63,"_44":214,"_13":173,"_39":40,"_41":174,"_30":31,"_151":-5,"_205":215,"_33":216},{"_49":160,"_38":161,"_36":162,"_144":-5,"_47":48,"_46":163,"_146":31,"_44":211,"_13":165,"_39":40,"_41":166,"_30":31,"_151":-5,"_205":212,"_33":213},{"_49":153,"_38":154,"_36":155,"_144":-5,"_47":48,"_46":156,"_146":31,"_44":208,"_13":67,"_39":40,"_41":158,"_30":31,"_151":-5,"_205":209,"_33":210},{"_49":141,"_38":142,"_36":143,"_144":-5,"_47":48,"_46":145,"_146":31,"_44":204,"_13":148,"_39":149,"_41":150,"_30":31,"_151":-5,"_205":206,"_33":207},["D",1773509567829],"children",[],[142],["D",1773504365048],[],[154],["D",1773509075988],[],[161],["D",1773508150828],[],[169],["D",1773504523924],[],[177],["D",1773577419848],[],[34],["D",1773503757015],["D",1789528252206],{"_104":103,"_112":108},{"_104":103,"_105":106,"_107":108,"_19":-5,"_109":110,"_111":31},{"_13":93,"_38":94,"_49":48,"_95":50,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":51,"_102":103},"ctx",{"_86":-5,"_132":261,"_262":263,"_264":265,"_266":31,"_267":31,"_268":31,"_269":63,"_270":-5,"_271":-7,"_272":-7,"_273":67,"_274":31,"_275":31,"_276":-5,"_277":31,"_278":31,"_279":31,"_280":-5},"ENV",{"_232":233,"_234":235,"_236":94,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260},"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 · v65