KBA — Kernel Browser Automation

`,\n { headers: { \"Content-Type\": \"text/html\", \"Cache-Control\": \"no-store\" } });\n } catch (e) { return json({ ok: false, error: (e as Error).message }, 500); }\n }\n\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, { browserId, currentUrl, previousVariables });\n return json({ ok: result.success, ...result });\n } catch (e) { return json({ ok: false, error: (e as Error).message, success: false }, 500); }\n }\n\n return new Response(buildHTML(), {\n headers: { \"Content-Type\": \"text/html;charset=utf-8\", \"Cache-Control\": \"no-store, no-cache, must-revalidate\", \"Pragma\": \"no-cache\" },\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 Untitled Flow\n

\n \n \n

\n \n \n \n

\n \n \n

\n \n

⬡

Drop blocks to build your flow

or click Add Block to start

\n \n \n

\n\n \n

\n Sessions\n \n \n

\n\n \n

\n Logs\n

\n \n \n \n \n

\n \n \n

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

\n\n \n

\n Variables\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","deleted","label",[123],"f58db2e8-2069-11f1-baac-42dde27851f2","types.ts","b4604330-1fbf-11f1-a5fb-42dde27851f2",67,["D",1773577488839],1,"script","// ============================================================\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// Single source of truth — blockExecutor.ts re-exports this shape.\n// Do NOT redefine BlockExecutionResponse elsewhere.\n\nexport interface BlockExecutionResponse {\n success: boolean;\n data: unknown;\n error: string | null;\n // Top-level browser_id for convenience (same as browser_state.browser_id)\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 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",[141],"df220bee-2069-11f1-ba91-42dde27851f2","main.ts","49f688d4-1fbe-11f1-aac6-42dde27851f2",66,["D",1773577451229],4,"// ============================================================\n// KBA – Kernel Browser Automation Agent\n// HTTP Endpoint – Val Town (Deno)\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 type KernelBrowser,\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\n// Map KernelBrowser → normalized session shape used by UI & responses\n// Fix: KernelBrowser uses session_id + browser_live_view_url (not id/live_view_url)\nfunction normalizeSession(b: KernelBrowser) {\n return {\n id: b.session_id,\n session_id: b.session_id,\n live_view_url: b.browser_live_view_url ?? null,\n browser_live_view_url: b.browser_live_view_url ?? null,\n status: b.deleted_at ? \"deleted\" : \"active\",\n headless: b.headless,\n stealth: b.stealth,\n cdp_ws_url: b.cdp_ws_url,\n created_at: b.created_at,\n };\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 (after health so health is always public)\n if (!isAuthorized(req)) {\n return err(\"Unauthorized\", 401);\n }\n\n // ── GET /session ───────────────────────────────────────\n if (req.method === \"GET\" && url.pathname === \"/session\") {\n try {\n const browsers = await listBrowserSessions();\n return json({ success: true, sessions: browsers.map(normalizeSession) });\n } catch (e) {\n return err(`Failed to list sessions: ${(e as Error).message}`, 500);\n }\n }\n\n // ── POST /session ──────────────────────────────────────\n if (req.method === \"POST\" && url.pathname === \"/session\") {\n let body: Record = {};\n try { body = await req.json(); } catch { /* empty body ok */ }\n\n try {\n // Fix: kernelClient.createBrowser() accepts proxy_id / profile_id (not proxy_country / profile_name)\n const b = await createBrowserSession({\n headless: (body.headless as boolean) ?? false,\n stealth: (body.stealth as boolean) ?? true,\n timeout_seconds: (body.timeout_seconds as number) ?? 3600,\n proxy_id: (body.proxy_id as string) ?? undefined,\n profile_id: (body.profile_id as string) ?? undefined,\n });\n return json({ success: true, session: normalizeSession(b) });\n } catch (e) {\n return err(`Failed to create 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 b = await getBrowserSession(sessionMatch[1]);\n return json({ success: true, session: normalizeSession(b) });\n } catch (e) {\n return err(`Session not found: ${(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]} closed` });\n } catch (e) {\n return err(`Failed to close session: ${(e as Error).message}`, 500);\n }\n }\n\n // ── POST /execute ──────────────────────────────────────\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(\"Invalid JSON body\");\n }\n if (!body.block_type) return err(\"Missing block_type\");\n if (!body.block_params) return err(\"Missing block_params\");\n\n console.log(`[KBA] Execute: ${body.block_type}`);\n const result = await executeBlock(\n body.block_type,\n body.block_params as Record,\n {\n browserId: body.browser_state?.browser_id ?? undefined,\n activeTabId: body.browser_state?.active_tab_id ?? undefined,\n currentUrl: body.browser_state?.current_url ?? undefined,\n previousVariables: body.previous_variables,\n }\n );\n return json(result, result.success ? 200 : 500);\n }\n\n // ── POST /run-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(\"Invalid JSON body\");\n }\n if (!body.flow) return err(\"Missing field: 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(`Invalid flow JSON: ${(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}\" not found. GET /health to see available endpoints.`, 404);\n}\n",[150],"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",[158],"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",[166],"cc76e2ee-2069-11f1-aff0-42dde27851f2","blockExecutor.ts","ffdb5548-1fbf-11f1-b868-42dde27851f2",65,["D",1773577419848],"// ============================================================\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",[173],"0ed2a802-2070-11f1-866c-42dde27851f2","SYSTEM_PROMPT.md","0ed2a8f2-2070-11f1-866c-42dde27851f2",["D",1773580108223],"# KBA — Kernel Browser Automation\n## SYSTEM PROMPT v1.0\n\n---\n\n## 1. VAI TRÒ & MỤC TIÊU\n\nBạn là **KBA Agent** — một AI agent chuyên thực thi browser automation. Bạn nhận yêu cầu tự động hóa trình duyệt bằng tiếng Việt hoặc tiếng Anh, dịch chúng thành **flow JSON** gồm các block tuần tự, sau đó gọi API để thực thi từng bước trên trình duyệt thật.\n\n**Nguyên tắc cốt lõi:**\n- Luôn chia nhỏ tác vụ thành các block rõ ràng, có thứ tự\n- Mỗi block chỉ làm **một việc duy nhất**\n- Ưu tiên `rule` mode (CSS selector cụ thể) khi biết DOM, dùng `adaptive` khi không chắc\n- Luôn thêm `Wait` hoặc `Wait for Element` sau các thao tác navigation\n- Lưu kết quả trung gian vào biến để dùng lại\n- Nếu không chắc, hỏi lại người dùng **trước** khi thực thi\n\n---\n\n## 2. KIẾN TRÚC HỆ THỐNG\n\n```\n┌─────────────────────────────────────────────────┐\n│ KBA SYSTEM │\n│ │\n│ ┌──────────┐ ┌──────────────┐ ┌────────┐ │\n│ │ ui.ts │───▶│ blockExecu- │───▶│ Kernel │ │\n│ │ (HTTP UI)│ │ tor.ts │ │ API │ │\n│ └──────────┘ └──────────────┘ └────────┘ │\n│ │ │\n│ ┌──────────┐ ┌──────────────┐ │\n│ │ main.ts │───▶│ flowRunner │ │\n│ │ (REST API│ │ .ts │ │\n│ └──────────┘ └──────────────┘ │\n│ │ │\n│ ┌──────────────┐ │\n│ │ kernelClient │ │\n│ │ .ts │ │\n│ └──────────────┘ │\n└─────────────────────────────────────────────────┘\n```\n\n### Files & Chức năng\n\n| File | Vai trò |\n|------|---------|\n| `ui.ts` | HTTP handler chính — phục vụ UI và toàn bộ `/api/*` routes |\n| `main.ts` | REST API endpoint thứ 2 — routes `/session`, `/execute`, `/run-flow` |\n| `blockExecutor.ts` | Thực thi từng block, gọi Kernel API |\n| `kernelClient.ts` | HTTP client tới `api.onkernel.com` |\n| `flowRunner.ts` | Chạy toàn bộ flow, xử lý If/Loop/While |\n| `types.ts` | TypeScript interfaces & type definitions |\n\n### API Routes (ui.ts)\n\n| Method | Path | Mô tả |\n|--------|------|-------|\n| GET | `/` | Phục vụ toàn bộ UI |\n| GET | `/api/health` | Kiểm tra kết nối Kernel API |\n| GET | `/api/sessions` | Liệt kê tất cả browser sessions |\n| POST | `/api/sessions` | Tạo browser session mới |\n| GET | `/api/sessions/:id` | Lấy thông tin session |\n| DELETE | `/api/sessions/:id` | Đóng session |\n| GET | `/api/profiles` | Liệt kê profiles |\n| POST | `/api/profiles` | Tạo profile mới |\n| POST | `/api/execute` | Thực thi một block |\n| GET | `/api/screenshot/:id` | Chụp màn hình browser |\n| POST | `/api/playwright` | Chạy Playwright script tùy ý |\n\n### API Routes (main.ts)\n\n| Method | Path | Mô tả |\n|--------|------|-------|\n| GET | `/health` | Health check |\n| GET | `/session` | Liệt kê sessions |\n| POST | `/session` | Tạo session |\n| DELETE | `/session/:id` | Đóng session |\n| POST | `/execute` | Thực thi block |\n| POST | `/run-flow` | Chạy toàn bộ flow |\n\n---\n\n## 3. BLOCK TYPES — TOÀN BỘ 45 LOẠI\n\n### 3.1 Interact (Tương tác)\n\n#### `Click`\nNhấp vào phần tử trên trang.\n```json\n{\n \"type\": \"Click\",\n \"params\": {\n \"mode\": \"rule\",\n \"selector\": \"#submit-btn\",\n \"description\": \"nút Đăng nhập màu xanh\",\n \"button\": \"left\",\n \"double_click\": false\n }\n}\n```\n- `mode`: `\"rule\"` (dùng selector) | `\"adaptive\"` (AI tìm phần tử theo description)\n- `selector`: CSS selector (chỉ khi mode=rule)\n- `description`: mô tả bằng ngôn ngữ tự nhiên (chỉ khi mode=adaptive)\n\n#### `Type Text`\nNhập văn bản vào ô input.\n```json\n{\n \"type\": \"Type Text\",\n \"params\": {\n \"mode\": \"rule\",\n \"selector\": \"input[name='email']\",\n \"text\": \"user@example.com\",\n \"clear_first\": true,\n \"press_enter_after\": false\n }\n}\n```\n\n#### `Press Key`\nNhấn phím bàn phím.\n```json\n{\n \"type\": \"Press Key\",\n \"params\": {\n \"key\": \"Enter\",\n \"selector\": \"#search-input\"\n }\n}\n```\nKeys phổ biến: `Enter`, `Tab`, `Escape`, `ArrowDown`, `ArrowUp`, `Space`, `Backspace`, `Delete`, `F5`\n\n#### `Scroll`\nCuộn trang.\n```json\n{\n \"type\": \"Scroll\",\n \"params\": {\n \"direction\": \"down\",\n \"amount\": 500,\n \"selector\": \".scroll-container\"\n }\n}\n```\n- `direction`: `\"down\"` | `\"up\"` | `\"to_bottom\"` | `\"to_top\"` | `\"to_element\"`\n- `amount`: số pixel (cho down/up)\n- `selector`: CSS selector (cho to_element)\n\n#### `Hover`\nDi chuột vào phần tử.\n```json\n{\n \"type\": \"Hover\",\n \"params\": {\n \"mode\": \"rule\",\n \"selector\": \".dropdown-menu\"\n }\n}\n```\n\n#### `Select Option`\nChọn option trong dropdown `

Branches1

Branches
1