KBA — Kernel Browser Automation

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_226":227,"_228":229},"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",52,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","fe0654c9-cfe2-4437-95ef-a21f0e834600","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\n// Thực thi từng block type: rule-based hoặc adaptive\n// ============================================================\n\nimport type {\n BlockType, BlockParams, BlockExecutionResponse,\n ClickParams, TypeTextParams, PressKeyParams, ScrollParams,\n HoverParams, SelectOptionParams, SetDateInputParams,\n GetElementTextParams, GetLinkURLParams, GetElementAttributeParams,\n GetElementHTMLParams, SaveFileParams, TakeScreenshotParams,\n VisitParams, WaitParams, WaitForElementParams, RunScriptParams,\n GetDateParams, MakeHTTPRequestParams, AssertParams, CreateTabParams,\n SelectTabParams, SpreadsheetParams, IfParams, UploadFileParams,\n HandleDialogParams, SolveCaptchaParams, GeneratePDFParams,\n} from \"./types.ts\";\n\nimport {\n executeAction, takeScreenshot, evaluateScript,\n navigateTo, getCurrentURL, getPageHTML,\n createTab, selectTab, closeTab, getActiveTabId,\n createBrowserSession,\n} from \"./kernelClient.ts\";\n\n// ─── Helpers ──────────────────────────────────────────────\n\nfunction ok(\n data: unknown,\n vars: Record | null,\n browserId: string | null,\n currentUrl: string | null,\n summary: string,\n screenshotTaken = false\n): BlockExecutionResponse {\n return {\n success: true,\n data,\n error: null,\n browser_state: {\n browser_id: browserId,\n current_url: currentUrl,\n active_tab_id: null,\n screenshot_taken: screenshotTaken,\n },\n variables_updated: vars,\n next_action_needed: false,\n reasoning_summary: summary,\n };\n}\n\nfunction fail(\n error: string,\n browserId: string | null,\n currentUrl: string | null,\n summary: string\n): BlockExecutionResponse {\n return {\n success: false,\n data: null,\n error,\n browser_state: {\n browser_id: browserId,\n current_url: currentUrl,\n active_tab_id: null,\n screenshot_taken: false,\n },\n variables_updated: null,\n next_action_needed: false,\n reasoning_summary: summary,\n };\n}\n\n// Adaptive: tìm selector từ description sử dụng AI/LLM reasoning\n// Trong thực tế sẽ call Qwen API hoặc dùng aria/text-based selector\nasync function adaptiveResolveSelector(\n description: string,\n _htmlSnapshot?: string\n): Promise {\n // Heuristics fallback: map description → CSS selector patterns\n const lower = description.toLowerCase();\n\n if (lower.includes(\"search\") && lower.includes(\"input\")) return \"input[type='search'], input[placeholder*='search' i]\";\n if (lower.includes(\"email\") && lower.includes(\"input\")) return \"input[type='email'], input[name*='email' i]\";\n if (lower.includes(\"password\")) return \"input[type='password']\";\n if (lower.includes(\"submit\") || lower.includes(\"login button\")) return \"button[type='submit'], input[type='submit']\";\n if (lower.includes(\"username\")) return \"input[name*='user' i], input[id*='user' i]\";\n if (lower.includes(\"sign in\") || lower.includes(\"log in\")) return \"button:has-text('Sign in'), button:has-text('Log in')\";\n if (lower.includes(\"next button\")) return \"button:has-text('Next'), button[type='button']\";\n if (lower.includes(\"close\")) return \"button[aria-label*='close' i], .close, [data-dismiss]\";\n if (lower.includes(\"dropdown\")) return \"select\";\n\n // Fallback: aria label or text content\n return `[aria-label*=\"${description}\" i], *:text(\"${description}\")`;\n}\n\n// ─── Ensure Browser Session ───────────────────────────────\n\nasync function ensureSession(\n browserId: string | null\n): Promise<{ browserId: string; isNew: boolean }> {\n if (browserId) return { browserId, isNew: false };\n const session = await createBrowserSession({ headless: false });\n return { browserId: session.session_id, isNew: true };\n}\n\n// ─── MAIN EXECUTOR ────────────────────────────────────────\n\nexport async function executeBlock(\n blockType: BlockType,\n params: BlockParams,\n context: {\n browserId?: string;\n activeTabId?: string;\n currentUrl?: string;\n previousVariables?: Record;\n screenshotBase64?: string;\n htmlSnapshot?: string;\n }\n): Promise {\n const { browserId: initBId, currentUrl: initUrl } = context;\n\n try {\n // ══════════════════════════════════════════════════════\n // 🖱️ INTERACT WITH PAGE\n // ══════════════════════════════════════════════════════\n\n if (blockType === \"Click\") {\n const p = params as ClickParams;\n const { browserId } = await ensureSession(initBId ?? null);\n let selector = p.selector;\n\n if (p.mode === \"adaptive\" || (!selector && p.description)) {\n selector = await adaptiveResolveSelector(p.description!, context.htmlSnapshot);\n }\n if (!selector) return fail(\"Click: Không có selector hoặc description\", browserId, initUrl ?? null, \"Thiếu tham số selector/description cho Click block\");\n\n const result = await executeAction(browserId, {\n action: p.double_click ? \"double_click\" : \"click\",\n params: {\n selector,\n button: p.button ?? \"left\",\n },\n });\n\n const url = await getCurrentURL(browserId);\n return ok(result, null, browserId, url,\n `Click ${p.mode === \"adaptive\" ? \"adaptive\" : \"rule-based\"} vào \"${selector}\" thành công`);\n }\n\n if (blockType === \"Type Text\") {\n const p = params as TypeTextParams;\n const { browserId } = await ensureSession(initBId ?? null);\n let selector = p.selector;\n\n if (p.mode === \"adaptive\" || (!selector && p.description)) {\n selector = await adaptiveResolveSelector(p.description!, context.htmlSnapshot);\n }\n if (!selector) return fail(\"Type Text: Thiếu selector\", browserId, initUrl ?? null, \"Thiếu selector cho Type Text\");\n\n if (p.clear_first) {\n await executeAction(browserId, { action: \"triple_click\", params: { selector } });\n }\n\n const result = await executeAction(browserId, {\n action: \"type\",\n params: { selector, text: p.text },\n });\n\n if (p.press_enter_after) {\n await executeAction(browserId, { action: \"press_key\", params: { key: \"Enter\" } });\n }\n\n const url = await getCurrentURL(browserId);\n return ok(result, null, browserId, url,\n `Đã nhập text \"${p.text.slice(0, 30)}...\" vào \"${selector}\"`);\n }\n\n if (blockType === \"Press Key\") {\n const p = params as PressKeyParams;\n const { browserId } = await ensureSession(initBId ?? null);\n const result = await executeAction(browserId, {\n action: \"press_key\",\n params: { key: p.key, selector: p.selector },\n });\n const url = await getCurrentURL(browserId);\n return ok(result, null, browserId, url, `Nhấn phím \"${p.key}\" thành công`);\n }\n\n if (blockType === \"Scroll\") {\n const p = params as ScrollParams;\n const { browserId } = await ensureSession(initBId ?? null);\n\n let script = \"\";\n switch (p.direction) {\n case \"down\": script = `window.scrollBy(0, ${p.amount ?? 300})`; break;\n case \"up\": script = `window.scrollBy(0, -${p.amount ?? 300})`; break;\n case \"to_bottom\": script = \"window.scrollTo(0, document.body.scrollHeight)\"; break;\n case \"to_top\": script = \"window.scrollTo(0, 0)\"; break;\n case \"to_element\":\n if (p.selector) {\n script = `document.querySelector('${p.selector}')?.scrollIntoView({behavior:'smooth'})`;\n }\n break;\n }\n\n await evaluateScript(browserId, script);\n const url = await getCurrentURL(browserId);\n return ok({ direction: p.direction }, null, browserId, url, `Cuộn trang hướng \"${p.direction}\" thành công`);\n }\n\n if (blockType === \"Hover\") {\n const p = params as HoverParams;\n const { browserId } = await ensureSession(initBId ?? null);\n let selector = p.selector;\n if (p.mode === \"adaptive\" || (!selector && p.description)) {\n selector = await adaptiveResolveSelector(p.description!, context.htmlSnapshot);\n }\n const result = await executeAction(browserId, { action: \"hover\", params: { selector } });\n const url = await getCurrentURL(browserId);\n return ok(result, null, browserId, url, `Hover vào \"${selector}\" thành công`);\n }\n\n if (blockType === \"Select Option\") {\n const p = params as SelectOptionParams;\n const { browserId } = await ensureSession(initBId ?? null);\n let selector = p.selector;\n if (p.mode === \"adaptive\" || (!selector && p.description)) {\n selector = await adaptiveResolveSelector(p.description!, context.htmlSnapshot);\n }\n const result = await executeAction(browserId, {\n action: \"select\",\n params: { selector, value: p.value, label: p.label },\n });\n const url = await getCurrentURL(browserId);\n return ok(result, null, browserId, url, `Đã chọn option \"${p.value ?? p.label}\" trong dropdown`);\n }\n\n if (blockType === \"Set Date Input\") {\n const p = params as SetDateInputParams;\n const { browserId } = await ensureSession(initBId ?? null);\n let selector = p.selector;\n if (p.mode === \"adaptive\" || (!selector && p.description)) {\n selector = await adaptiveResolveSelector(p.description!, context.htmlSnapshot);\n }\n const result = await evaluateScript(browserId,\n `document.querySelector('${selector}').value = '${p.date}'`\n );\n const url = await getCurrentURL(browserId);\n return ok(result, null, browserId, url, `Đã set ngày \"${p.date}\" cho input \"${selector}\"`);\n }\n\n if (blockType === \"Upload File\") {\n const p = params as UploadFileParams;\n const { browserId } = await ensureSession(initBId ?? null);\n let selector = p.selector;\n if (p.mode === \"adaptive\" || (!selector && p.description)) {\n selector = await adaptiveResolveSelector(p.description!, context.htmlSnapshot);\n }\n const result = await executeAction(browserId, {\n action: \"upload_file\",\n params: {\n selector,\n file_path: p.file_path,\n file_base64: p.file_base64,\n file_name: p.file_name,\n },\n });\n const url = await getCurrentURL(browserId);\n return ok(result, null, browserId, url, `Upload file \"${p.file_name ?? p.file_path}\" thành công`);\n }\n\n if (blockType === \"Handle Dialog\") {\n const p = params as HandleDialogParams;\n const { browserId } = await ensureSession(initBId ?? null);\n const result = await executeAction(browserId, {\n action: \"handle_dialog\",\n params: { action: p.action, text: p.text },\n });\n const url = await getCurrentURL(browserId);\n return ok(result, null, browserId, url, `Xử lý dialog: \"${p.action}\" thành công`);\n }\n\n // ══════════════════════════════════════════════════════\n // 📊 EXTRACT DATA\n // ══════════════════════════════════════════════════════\n\n if (blockType === \"Get Element Text\") {\n const p = params as GetElementTextParams;\n const { browserId } = await ensureSession(initBId ?? null);\n let selector = p.selector;\n if (p.mode === \"adaptive\" || (!selector && p.description)) {\n selector = await adaptiveResolveSelector(p.description!, context.htmlSnapshot);\n }\n let text = await evaluateScript(browserId,\n `document.querySelector('${selector}')?.innerText`\n ) as string;\n if (p.trim) text = text?.trim();\n const url = await getCurrentURL(browserId);\n return ok(text, { extracted_text: text }, browserId, url,\n `Đã lấy text từ \"${selector}\": \"${(text ?? \"\").slice(0, 50)}...\"`);\n }\n\n if (blockType === \"Get Link URL\") {\n const p = params as GetLinkURLParams;\n const { browserId } = await ensureSession(initBId ?? null);\n let selector = p.selector;\n if (p.mode === \"adaptive\" || (!selector && p.description)) {\n selector = await adaptiveResolveSelector(p.description!, context.htmlSnapshot);\n }\n const href = await evaluateScript(browserId,\n `document.querySelector('${selector}')?.href`\n ) as string;\n const url = await getCurrentURL(browserId);\n return ok(href, { link_url: href }, browserId, url, `Lấy URL từ link \"${selector}\": ${href}`);\n }\n\n if (blockType === \"Get Page URL\") {\n const { browserId } = await ensureSession(initBId ?? null);\n const url = await getCurrentURL(browserId);\n return ok(url, { page_url: url }, browserId, url, `URL trang hiện tại: ${url}`);\n }\n\n if (blockType === \"Get Element Attribute\") {\n const p = params as GetElementAttributeParams;\n const { browserId } = await ensureSession(initBId ?? null);\n let selector = p.selector;\n if (p.mode === \"adaptive\" || (!selector && p.description)) {\n selector = await adaptiveResolveSelector(p.description!, context.htmlSnapshot);\n }\n const value = await evaluateScript(browserId,\n `document.querySelector('${selector}')?.getAttribute('${p.attribute}')`\n ) as string;\n const url = await getCurrentURL(browserId);\n return ok(value, { attribute_value: value }, browserId, url,\n `Attribute \"${p.attribute}\" của \"${selector}\": \"${value}\"`);\n }\n\n if (blockType === \"Get Element HTML\") {\n const p = params as GetElementHTMLParams;\n const { browserId } = await ensureSession(initBId ?? null);\n let selector = p.selector;\n if (p.mode === \"adaptive\" || (!selector && p.description)) {\n selector = await adaptiveResolveSelector(p.description!, context.htmlSnapshot);\n }\n const prop = p.outer ? \"outerHTML\" : \"innerHTML\";\n const html = await evaluateScript(browserId,\n `document.querySelector('${selector}')?.${prop}`\n ) as string;\n const url = await getCurrentURL(browserId);\n return ok(html, { element_html: html }, browserId, url,\n `Lấy ${prop} của \"${selector}\" (${html?.length ?? 0} chars)`);\n }\n\n if (blockType === \"Get Clipboard\") {\n const { browserId } = await ensureSession(initBId ?? null);\n const text = await evaluateScript(browserId,\n `navigator.clipboard?.readText()`\n ) as string;\n const url = await getCurrentURL(browserId);\n return ok(text, { clipboard_text: text }, browserId, url, `Clipboard: \"${(text ?? \"\").slice(0, 80)}\"`);\n }\n\n if (blockType === \"Take Screenshot\") {\n const p = params as TakeScreenshotParams;\n const { browserId } = await ensureSession(initBId ?? null);\n const base64 = await takeScreenshot(browserId, {\n full_page: p.full_page,\n format: p.format,\n });\n const url = await getCurrentURL(browserId);\n return ok({ screenshot_base64: base64 }, { screenshot: base64 }, browserId, url,\n `Screenshot chụp thành công (${base64.length} bytes base64)`, true);\n }\n\n if (blockType === \"Generate PDF\") {\n const p = params as GeneratePDFParams;\n const { browserId } = await ensureSession(initBId ?? null);\n const result = await executeAction(browserId, {\n action: \"generate_pdf\",\n params: { full_page: p.full_page ?? true, format: p.format ?? \"A4\" },\n });\n const url = await getCurrentURL(browserId);\n return ok(result, null, browserId, url, `Tạo PDF thành công`);\n }\n\n if (blockType === \"Save File\") {\n const p = params as SaveFileParams;\n const { browserId } = await ensureSession(initBId ?? null);\n let selector = p.selector;\n if (p.mode === \"adaptive\" || (!selector && p.description)) {\n selector = await adaptiveResolveSelector(p.description!, context.htmlSnapshot);\n }\n const result = await executeAction(browserId, {\n action: \"download_file\",\n params: { selector, url: p.url, save_to: p.save_to },\n });\n const url = await getCurrentURL(browserId);\n return ok(result, { file_path: p.save_to }, browserId, url, `Tải file về \"${p.save_to}\" thành công`);\n }\n\n // ══════════════════════════════════════════════════════\n // 🧭 NAVIGATE\n // ══════════════════════════════════════════════════════\n\n if (blockType === \"Visit\") {\n const p = params as VisitParams;\n const { browserId } = await ensureSession(initBId ?? null);\n\n if (p.new_tab) {\n await createTab(browserId, p.url);\n } else {\n await navigateTo(browserId, p.url, p.wait_until ?? \"load\");\n }\n\n const url = await getCurrentURL(browserId);\n return ok({ url }, null, browserId, url, `Điều hướng đến \"${p.url}\" thành công`);\n }\n\n if (blockType === \"Go Back\") {\n const { browserId } = await ensureSession(initBId ?? null);\n await executeAction(browserId, { action: \"go_back\", params: {} });\n const url = await getCurrentURL(browserId);\n return ok(null, null, browserId, url, `Quay lại trang trước: ${url}`);\n }\n\n if (blockType === \"Go Forward\") {\n const { browserId } = await ensureSession(initBId ?? null);\n await executeAction(browserId, { action: \"go_forward\", params: {} });\n const url = await getCurrentURL(browserId);\n return ok(null, null, browserId, url, `Tiến đến trang sau: ${url}`);\n }\n\n if (blockType === \"Reload Page\") {\n const { browserId } = await ensureSession(initBId ?? null);\n await evaluateScript(browserId,\n `location.reload(${(params as { hard?: boolean }).hard ? \"true\" : \"\"})`\n );\n const url = await getCurrentURL(browserId);\n return ok(null, null, browserId, url, `Tải lại trang ${url}`);\n }\n\n // ══════════════════════════════════════════════════════\n // 🔁 CONTROL FLOW – Chỉ reasoning, không execute loop\n // ══════════════════════════════════════════════════════\n\n if ([\"Loop Elements\", \"Loop Pages\", \"Loop\", \"Loop List Items\", \"If\", \"Else\", \"While\", \"End\", \"Break\"].includes(blockType)) {\n const p = params as IfParams;\n\n // Evaluate if condition nếu là If block\n if (blockType === \"If\") {\n const variables = { ...context.previousVariables, ...(p.variable_map ?? {}) };\n let conditionResult = false;\n try {\n const fn = new Function(...Object.keys(variables), `return (${p.condition})`);\n conditionResult = Boolean(fn(...Object.values(variables)));\n } catch {\n conditionResult = false;\n }\n return ok(\n { condition_result: conditionResult },\n { __condition__: conditionResult },\n initBId ?? null, initUrl ?? null,\n `Control Flow [${blockType}]: condition=\"${p.condition}\" → ${conditionResult}. Val Town runner xử lý luồng.`\n );\n }\n\n return ok(\n { control_flow_block: blockType, params },\n { __control_flow__: blockType },\n initBId ?? null, initUrl ?? null,\n `Control Flow [${blockType}]: Đã trả về metadata. Val Town runner sẽ xử lý luồng điều khiển.`\n );\n }\n\n // ══════════════════════════════════════════════════════\n // 🪟 TABS\n // ══════════════════════════════════════════════════════\n\n if (blockType === \"Create Tab\") {\n const p = params as CreateTabParams;\n const { browserId } = await ensureSession(initBId ?? null);\n const tabId = await createTab(browserId, p.url);\n const url = await getCurrentURL(browserId);\n return ok({ tab_id: tabId }, { new_tab_id: tabId }, browserId, url, `Tạo tab mới (id: ${tabId}) ${p.url ? \"→ \" + p.url : \"\"}`);\n }\n\n if (blockType === \"Get Active Tab ID\") {\n const { browserId } = await ensureSession(initBId ?? null);\n const tabId = await getActiveTabId(browserId);\n const url = await getCurrentURL(browserId);\n return ok({ tab_id: tabId }, { active_tab_id: tabId }, browserId, url, `Tab active hiện tại: ${tabId}`);\n }\n\n if (blockType === \"Select Tab\") {\n const p = params as SelectTabParams;\n const { browserId } = await ensureSession(initBId ?? null);\n await selectTab(browserId, p.tab_id);\n const url = await getCurrentURL(browserId);\n return ok({ tab_id: p.tab_id }, null, browserId, url, `Đã chuyển sang tab ${p.tab_id}`);\n }\n\n if (blockType === \"Close Tab\") {\n const p = params as SelectTabParams;\n const { browserId } = await ensureSession(initBId ?? null);\n await closeTab(browserId, p.tab_id);\n const url = await getCurrentURL(browserId);\n return ok({ closed_tab_id: p.tab_id }, null, browserId, url, `Đã đóng tab ${p.tab_id}`);\n }\n\n // ══════════════════════════════════════════════════════\n // 🔧 UTILITIES\n // ══════════════════════════════════════════════════════\n\n if (blockType === \"Run Script\") {\n const p = params as RunScriptParams;\n const { browserId } = await ensureSession(initBId ?? null);\n const result = await evaluateScript(browserId, p.script, p.args);\n const url = await getCurrentURL(browserId);\n return ok(result, { script_result: result }, browserId, url,\n `Run Script thành công, kết quả: ${JSON.stringify(result).slice(0, 100)}`);\n }\n\n if (blockType === \"Get Date\") {\n const p = params as GetDateParams;\n const now = new Date();\n let dateStr: string;\n\n if (p.format === \"timestamp\") {\n dateStr = now.getTime().toString();\n } else if (p.format === \"ISO\" || !p.format) {\n dateStr = now.toISOString();\n } else {\n // Basic format substitution\n dateStr = p.format\n .replace(\"YYYY\", now.getFullYear().toString())\n .replace(\"MM\", String(now.getMonth() + 1).padStart(2, \"0\"))\n .replace(\"DD\", String(now.getDate()).padStart(2, \"0\"))\n .replace(\"HH\", String(now.getHours()).padStart(2, \"0\"))\n .replace(\"mm\", String(now.getMinutes()).padStart(2, \"0\"))\n .replace(\"ss\", String(now.getSeconds()).padStart(2, \"0\"));\n }\n return ok(dateStr, { current_date: dateStr }, initBId ?? null, initUrl ?? null,\n `Lấy ngày giờ hiện tại: \"${dateStr}\"`);\n }\n\n if (blockType === \"Wait\") {\n const p = params as WaitParams;\n await new Promise((res) => setTimeout(res, p.duration_ms));\n return ok({ waited_ms: p.duration_ms }, null, initBId ?? null, initUrl ?? null,\n `Đã chờ ${p.duration_ms}ms`);\n }\n\n if (blockType === \"Wait for Element\") {\n const p = params as WaitForElementParams;\n const { browserId } = await ensureSession(initBId ?? null);\n let selector = p.selector;\n if (p.mode === \"adaptive\" || (!selector && p.description)) {\n selector = await adaptiveResolveSelector(p.description!, context.htmlSnapshot);\n }\n const result = await executeAction(browserId, {\n action: \"wait_for_element\",\n params: {\n selector,\n state: p.state ?? \"visible\",\n timeout: p.timeout_ms ?? 30000,\n },\n });\n const url = await getCurrentURL(browserId);\n return ok(result, null, browserId, url, `Chờ element \"${selector}\" xuất hiện thành công`);\n }\n\n if (blockType === \"Make HTTP Request\") {\n const p = params as MakeHTTPRequestParams;\n const res = await fetch(p.url, {\n method: p.method,\n headers: p.headers,\n body: p.body ? JSON.stringify(p.body) : undefined,\n });\n\n let data: unknown;\n if (p.response_type === \"json\" || res.headers.get(\"content-type\")?.includes(\"json\")) {\n data = await res.json();\n } else {\n data = await res.text();\n }\n\n return ok(data, { http_response: data, http_status: res.status },\n initBId ?? null, initUrl ?? null,\n `HTTP ${p.method} ${p.url} → status ${res.status}`);\n }\n\n if (blockType === \"Assert\") {\n const p = params as AssertParams;\n const variables = context.previousVariables ?? {};\n let passed = false;\n let assertError: string | null = null;\n\n try {\n const fn = new Function(...Object.keys(variables), `return (${p.condition})`);\n passed = Boolean(fn(...Object.values(variables)));\n } catch (e) {\n assertError = (e as Error).message;\n }\n\n if (!passed) {\n return fail(\n `Assert failed: \"${p.condition}\" ${p.message ? \"– \" + p.message : \"\"} ${assertError ?? \"\"}`,\n initBId ?? null, initUrl ?? null,\n `Assert KHÔNG qua: \"${p.condition}\"`\n );\n }\n return ok({ passed: true }, null, initBId ?? null, initUrl ?? null, `Assert PASS: \"${p.condition}\"`);\n }\n\n if (blockType === \"Show Alert\") {\n const text = (params as { text: string }).text;\n console.log(`[KBA ALERT] ${text}`);\n return ok({ alert_text: text }, null, initBId ?? null, initUrl ?? null, `Alert hiển thị: \"${text}\"`);\n }\n\n if (blockType === \"Comment\") {\n const comment = (params as { text: string }).text;\n return ok({ comment }, null, initBId ?? null, initUrl ?? null, `Comment: \"${comment}\"`);\n }\n\n if (blockType === \"Run Flow\") {\n // Sub-flow execution – delegate to flowRunner via HTTP\n const p = params as { flow_id: string; input_variables?: Record };\n return ok(\n { sub_flow: p.flow_id, input: p.input_variables },\n { sub_flow_id: p.flow_id },\n initBId ?? null, initUrl ?? null,\n `Sub-flow \"${p.flow_id}\" được delegate đến Val Town flowRunner`\n );\n }\n\n if (blockType === \"Solve Captcha\") {\n const p = params as SolveCaptchaParams;\n const { browserId } = await ensureSession(initBId ?? null);\n let selector = p.selector;\n if (p.mode === \"adaptive\" || (!selector && p.description)) {\n selector = await adaptiveResolveSelector(p.description!, context.htmlSnapshot);\n }\n // Placeholder – tích hợp 2captcha/anticaptcha theo service\n const result = await executeAction(browserId, {\n action: \"solve_captcha\",\n params: { selector, service: p.service ?? \"internal\" },\n });\n const url = await getCurrentURL(browserId);\n return ok(result, null, browserId, url, `Captcha đã được giải qua service \"${p.service ?? \"internal\"}\"`);\n }\n\n // ══════════════════════════════════════════════════════\n // 📑 SPREADSHEET – via Google Sheets API (không dùng browser)\n // ══════════════════════════════════════════════════════\n\n if ([\"Add Spreadsheet Row\", \"Update Spreadsheet Row\", \"Find Spreadsheet Row\"].includes(blockType)) {\n const p = params as SpreadsheetParams;\n const apiKey = Deno.env.get(\"GOOGLE_SHEETS_API_KEY\") ?? \"\";\n const accessToken = Deno.env.get(\"GOOGLE_SHEETS_ACCESS_TOKEN\") ?? \"\";\n\n const baseUrl = `https://sheets.googleapis.com/v4/spreadsheets/${p.spreadsheet_id}`;\n const headers: Record = {\n \"Content-Type\": \"application/json\",\n ...(accessToken ? { \"Authorization\": `Bearer ${accessToken}` } : {}),\n ...(apiKey ? { \"X-Goog-Api-Key\": apiKey } : {}),\n };\n\n if (blockType === \"Add Spreadsheet Row\") {\n const values = Object.values(p.row_data ?? {});\n const res = await fetch(`${baseUrl}/values/${p.sheet_name ?? \"Sheet1\"}!A1:append?valueInputOption=USER_ENTERED`, {\n method: \"POST\",\n headers,\n body: JSON.stringify({ values: [values] }),\n });\n const data = await res.json();\n return ok(data, null, initBId ?? null, initUrl ?? null, `Thêm dòng mới vào spreadsheet \"${p.spreadsheet_id}\"`);\n }\n\n return ok(null, null, initBId ?? null, initUrl ?? null, `Spreadsheet block \"${blockType}\" – chưa implement đầy đủ`);\n }\n\n // ──────────────────────────────────────────────────────\n return fail(`Block type \"${blockType}\" chưa được implement`, initBId ?? null, initUrl ?? null,\n `Không tìm thấy handler cho block type \"${blockType}\"`);\n\n } catch (e) {\n const err = e as Error;\n return fail(err.message, initBId ?? null, initUrl ?? null,\n `Lỗi khi thực thi 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, 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 reasoning_summary: string;\n variables_updated: Record | null;\n}\n\nfunction ok(\n data: unknown,\n vars: Record | null,\n browserId: string | null,\n summary: string\n): BlockExecutionResponse {\n return { success: true, data, error: null, browser_id: browserId, reasoning_summary: summary, variables_updated: vars };\n}\n\nfunction fail(\n error: string,\n browserId: string | null,\n summary: string\n): BlockExecutionResponse {\n return { success: false, data: null, error, browser_id: browserId, reasoning_summary: summary, variables_updated: null };\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 const prop = outer ? \"outerHTML\" : \"innerHTML\";\n const r = await runPlaywright(bid, `return await page.${prop === \"innerHTML\" ? \"innerHTML\" : \"evaluate\"}(${outer ? `el => el.outerHTML, await page.$(${JSON.stringify(sel)})` : JSON.stringify(sel)});`);\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","createdAt",["D",1773508552538],"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=1789590542&sig=081e80bf170cdc1d82d65d76eb9ab668f955d25e6c02b41b68630c22011a9619","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_49":50,"_38":51,"_44":221,"_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":222,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":223,"_88":224,"_90":225,"_92":31},"tree",[196,197,198,199,200,201],"files",[196,197,198,199,200,201],"counts",{"_186":67,"_187":184,"_188":67,"_189":190,"_191":192},"contents",[135,136,137,138,139,140],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":182,"_38":34,"_36":37,"_144":-5,"_47":48,"_46":14,"_146":31,"_44":183,"_13":184,"_39":40,"_41":43,"_30":31,"_151":-5,"_33":185},{"_49":175,"_38":176,"_36":177,"_144":-5,"_47":48,"_46":178,"_146":63,"_44":179,"_13":67,"_39":40,"_41":180,"_30":31,"_151":-5,"_33":181},{"_49":167,"_38":168,"_36":169,"_144":-5,"_47":48,"_46":170,"_146":63,"_44":171,"_13":172,"_39":40,"_41":173,"_30":31,"_151":-5,"_33":174},{"_49":160,"_38":161,"_36":162,"_144":-5,"_47":48,"_46":163,"_146":31,"_44":164,"_13":156,"_39":40,"_41":165,"_30":31,"_151":-5,"_33":166},{"_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},"b91a385a-1fc8-11f1-902a-42dde27851f2","ui.ts","cec62260-1fc1-11f1-95fc-42dde27851f2","parentId",51,"latest",["D",1773508238445],29,"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\";\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 { encodeBase64 } = await import(\"jsr:@std/encoding@1.0.4/base64\");\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 // ── 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],"3179cdd6-1fc6-11f1-9ee1-42dde27851f2","main.ts","49f688d4-1fbe-11f1-aac6-42dde27851f2",30,["D",1773507151910],"// ============================================================\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 createBrowserSession,\n listBrowserSessions,\n getBrowserSession,\n 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",[168],"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",[176],"7451f914-1fc9-11f1-bfe6-42dde27851f2",["D",1773508552538],1,[34],"pulls","branches","forks","envVars",{"_193":184,"_195":67},"connections",{"_193":67,"_194":67},"count","unfilledCount","emptyCount",{"_49":182,"_38":34,"_36":37,"_144":-5,"_47":48,"_46":14,"_146":31,"_44":218,"_13":184,"_39":40,"_41":43,"_30":31,"_151":-5,"_203":219,"_33":220},{"_49":175,"_38":176,"_36":177,"_144":-5,"_47":48,"_46":178,"_146":63,"_44":215,"_13":67,"_39":40,"_41":180,"_30":31,"_151":-5,"_203":216,"_33":217},{"_49":167,"_38":168,"_36":169,"_144":-5,"_47":48,"_46":170,"_146":63,"_44":212,"_13":172,"_39":40,"_41":173,"_30":31,"_151":-5,"_203":213,"_33":214},{"_49":160,"_38":161,"_36":162,"_144":-5,"_47":48,"_46":163,"_146":31,"_44":209,"_13":156,"_39":40,"_41":165,"_30":31,"_151":-5,"_203":210,"_33":211},{"_49":153,"_38":154,"_36":155,"_144":-5,"_47":48,"_46":156,"_146":31,"_44":206,"_13":67,"_39":40,"_41":158,"_30":31,"_151":-5,"_203":207,"_33":208},{"_49":141,"_38":142,"_36":143,"_144":-5,"_47":48,"_46":145,"_146":31,"_44":202,"_13":148,"_39":149,"_41":150,"_30":31,"_151":-5,"_203":204,"_33":205},["D",1773508238445],"children",[],[142],["D",1773504365048],[],[154],["D",1773507151910],[],[161],["D",1773508150828],[],[168],["D",1773504523924],[],[176],["D",1773508552538],[],[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":259,"_260":261,"_262":263,"_264":31,"_265":31,"_266":31,"_267":63,"_268":-5,"_269":-7,"_270":-7,"_271":67,"_272":31,"_273":31,"_274":-5,"_275":31,"_276":31,"_277":31,"_278":-5},"ENV",{"_230":231,"_232":233,"_234":94,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258},"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 · v52