BrowserFlow Engine

⚡ BrowserFlow

\n \n \n \n \n

\n ● Connecting...\n \n

\n\n\n

Total Flows

Total Runs

Success

Failed

\n\n

My Flows

🌊

No flows yet. Create your first flow!

\n\n

Recent Runs

\n \n \n \n

Flow	Status	Started	Duration	Actions
No runs yet

\n\n\n

\n \n \n\n \n

\n \n

\n ➕ Click to add block or drag from sidebar\n

\n\n \n

Flow Variables

\n \n

Selected Block

Click a block to see details

Quick Actions

\n \n \n \n

\n\n\n

\n \n

Select a run to view logs

\n\n\n

⚙️ Settings

🔑 API Keys

Kernel.sh API Key

\n \n

Get from app.kernel.sh → API Keys

BrowserFlow API Key (optional)

\n \n

Protect your API endpoint

\n \n

🌐 API Endpoint

Backend URL

\n \n

Your Val Town endpoint

\n \n

📦 Block Stats

ℹ️ About

BrowserFlow Engine v1.0.0

Browser automation platform

• Kernel.sh (Cloud Browser)

• Playwright (Browser Control)

• Val Town (Serverless)

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

🚀 Starting Kernel.sh browser...

\n \n

\n\n\n

\n\n\n\n\n",["D",1773565767626],"branchVersion","label",[18],"pulls","branches",1,"forks","envVars",{"_162":164,"_165":26},"connections",{"_162":26,"_163":26},"count","unfilledCount",2,"emptyCount",{"_32":265,"_13":224,"_62":218,"_42":-5,"_34":35,"_151":164,"_178":84,"_36":266,"_38":26,"_64":267,"_148":-5,"_65":24,"_152":-5,"_180":268,"_17":269},{"_32":257,"_13":258,"_62":259,"_42":218,"_34":35,"_151":260,"_178":84,"_36":261,"_38":156,"_64":21,"_148":262,"_65":24,"_152":-5,"_180":263,"_17":264},{"_32":249,"_13":250,"_62":251,"_42":218,"_34":35,"_151":252,"_178":84,"_36":253,"_38":26,"_64":21,"_148":254,"_65":24,"_152":-5,"_180":255,"_17":256},{"_32":241,"_13":242,"_62":243,"_42":218,"_34":35,"_151":244,"_178":84,"_36":245,"_38":156,"_64":21,"_148":246,"_65":24,"_152":-5,"_180":247,"_17":248},{"_32":233,"_13":234,"_62":235,"_42":218,"_34":35,"_151":236,"_178":84,"_36":237,"_38":26,"_64":21,"_148":238,"_65":24,"_152":-5,"_180":239,"_17":240},{"_32":225,"_13":226,"_62":227,"_42":218,"_34":35,"_151":228,"_178":84,"_36":229,"_38":26,"_64":21,"_148":230,"_65":24,"_152":-5,"_180":231,"_17":232},{"_32":215,"_13":216,"_62":217,"_42":218,"_34":35,"_151":219,"_178":84,"_36":220,"_38":26,"_64":21,"_148":221,"_65":24,"_152":-5,"_180":222,"_17":223},{"_32":206,"_13":207,"_62":208,"_42":-5,"_34":35,"_151":209,"_178":84,"_36":210,"_38":211,"_64":21,"_148":212,"_65":24,"_152":-5,"_180":213,"_17":214},{"_32":199,"_13":200,"_62":82,"_42":-5,"_34":35,"_151":111,"_178":84,"_36":201,"_38":39,"_64":202,"_148":203,"_65":24,"_152":-5,"_180":204,"_17":205},{"_32":191,"_13":192,"_62":193,"_42":-5,"_34":35,"_151":194,"_178":84,"_36":195,"_38":156,"_64":21,"_148":196,"_65":24,"_152":-5,"_180":197,"_17":198},{"_32":183,"_13":184,"_62":185,"_42":-5,"_34":35,"_151":186,"_178":84,"_36":187,"_38":156,"_64":21,"_148":188,"_65":24,"_152":-5,"_180":189,"_17":190},{"_32":147,"_13":18,"_62":63,"_42":-5,"_34":35,"_151":39,"_178":84,"_36":179,"_38":26,"_64":21,"_148":149,"_65":24,"_152":-5,"_180":181,"_17":182},"latest",["D",1773565767626],"children",[],[18],"adc205ec-2053-11f1-a220-42dde27851f2","types.ts","8f080e96-204c-11f1-9400-42dde27851f2",30,["D",1773567919436],"// ============================================================\n// TYPES - Định nghĩa toàn bộ kiểu dữ liệu cho hệ thống\n// ============================================================\n\nexport type BlockType =\n // 🖱️ Interact\n | \"click\"\n | \"type_text\"\n | \"press_key\"\n | \"scroll\"\n | \"hover\"\n | \"select_option\"\n | \"set_date_input\"\n | \"upload_file\"\n | \"handle_dialog\"\n // 📊 Extract\n | \"get_element_text\"\n | \"get_link_url\"\n | \"get_page_url\"\n | \"get_element_attribute\"\n | \"get_element_html\"\n | \"get_clipboard\"\n | \"save_file\"\n | \"take_screenshot\"\n | \"generate_pdf\"\n // 🧭 Navigate\n | \"visit\"\n | \"go_back\"\n | \"go_forward\"\n | \"reload_page\"\n // 📑 Spreadsheet\n | \"loop_spreadsheet_rows\"\n | \"add_spreadsheet_row\"\n | \"update_spreadsheet_row\"\n | \"find_spreadsheet_row\"\n // 🔁 Control Flow\n | \"loop_elements\"\n | \"loop_pages\"\n | \"loop\"\n | \"loop_list_items\"\n | \"if\"\n | \"else\"\n | \"while\"\n | \"end\"\n | \"break\"\n // 🪟 Tabs\n | \"create_tab\"\n | \"get_active_tab_id\"\n | \"select_tab\"\n | \"close_tab\"\n // 🔧 Utilities\n | \"run_script\"\n | \"get_date\"\n | \"wait\"\n | \"wait_for_element\"\n | \"show_alert\"\n | \"make_http_request\"\n | \"assert\"\n | \"run_flow\"\n | \"comment\"\n | \"solve_captcha\";\n\nexport interface Block {\n id: string;\n type: BlockType;\n params: Record;\n comment?: string;\n}\n\nexport interface Flow {\n id: string;\n name: string;\n description?: string;\n blocks: Block[];\n variables?: Record;\n createdAt?: string;\n updatedAt?: string;\n}\n\nexport interface FlowContext {\n variables: Record;\n tabs: Map; // tabId -> page object\n activeTabId: string;\n loopStack: LoopFrame[];\n browser: any;\n kernelSessionId: string;\n logs: LogEntry[];\n shouldBreak: boolean;\n}\n\nexport interface LoopFrame {\n type: \"loop\" | \"loop_elements\" | \"loop_pages\" | \"loop_list_items\" | \"loop_spreadsheet_rows\" | \"while\";\n startIndex: number; // index của block loop trong flow\n currentIteration: number;\n maxIterations?: number;\n items?: any[];\n currentItem?: any;\n condition?: string; // dùng cho while\n startedAt?: number; // Date.now() khi bắt đầu while, dùng để timeout\n isIf?: boolean; // true nếu frame này là if/else\n}\n\nexport interface LogEntry {\n timestamp: string;\n level: \"info\" | \"warn\" | \"error\" | \"debug\";\n blockId?: string;\n blockType?: string;\n message: string;\n data?: any;\n}\n\nexport interface BlockResult {\n success: boolean;\n output?: any;\n error?: string;\n skipToEnd?: boolean; // dùng cho break\n jumpToIndex?: number; // dùng cho loop\n}\n\nexport interface RunFlowOptions {\n flowId?: string;\n flow?: Flow;\n variables?: Record;\n kernelApiKey: string;\n}\n\nexport interface RunFlowResult {\n success: boolean;\n variables: Record;\n logs: LogEntry[];\n error?: string;\n screenshots?: string[];\n}\n",[],[184],"b16bbcbc-2056-11f1-ac46-42dde27851f2","storage.ts","fe6dfab6-204c-11f1-8e02-42dde27851f2",34,["D",1773569214099],"// ============================================================\n// STORAGE - Lưu/lấy Flows từ SQLite\n// ============================================================\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type { Flow } from \"./types.ts\";\n\n// Khởi tạo bảng\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS flows (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n description TEXT,\n data TEXT NOT NULL,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS flow_runs (\n id TEXT PRIMARY KEY,\n flow_id TEXT NOT NULL,\n status TEXT NOT NULL,\n started_at TEXT NOT NULL,\n finished_at TEXT,\n variables TEXT,\n logs TEXT,\n error TEXT\n )\n`);\n\n// ─── FLOWS ────────────────────────────────────────────────\nexport async function saveFlow(flow: Flow): Promise {\n const now = new Date().toISOString();\n const existing = await getFlow(flow.id);\n if (existing) {\n await sqlite.execute({\n sql: `UPDATE flows SET name=?, description=?, data=?, updated_at=? WHERE id=?`,\n args: [flow.name, flow.description || \"\", JSON.stringify(flow), now, flow.id]\n });\n } else {\n await sqlite.execute({\n sql: `INSERT INTO flows (id, name, description, data, created_at, updated_at) VALUES (?, ?, ?, ?, ?, ?)`,\n args: [flow.id, flow.name, flow.description || \"\", JSON.stringify(flow), now, now]\n });\n }\n}\n\nexport async function getFlow(id: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT data FROM flows WHERE id=?`,\n args: [id]\n });\n if (!result.rows.length) return null;\n return JSON.parse(result.rows[0].data as string);\n}\n\nexport async function listFlows(): Promise[]> {\n const result = await sqlite.execute(\n `SELECT id, name, description, created_at, updated_at FROM flows ORDER BY updated_at DESC`\n );\n return result.rows.map(row => ({\n id: row.id as string,\n name: row.name as string,\n description: row.description as string,\n blocks: [],\n createdAt: row.created_at as string,\n updatedAt: row.updated_at as string,\n }));\n}\n\nexport async function deleteFlow(id: string): Promise {\n await sqlite.execute({ sql: `DELETE FROM flows WHERE id=?`, args: [id] });\n}\n\n// ─── FLOW RUNS ─────────────────────────────────────────────\nexport async function saveFlowRun(run: {\n id: string; flowId: string; status: string;\n startedAt: string; finishedAt?: string;\n variables?: any; logs?: any; error?: string;\n}): Promise {\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO flow_runs \n (id, flow_id, status, started_at, finished_at, variables, logs, error) \n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n run.id, run.flowId, run.status, run.startedAt,\n run.finishedAt || null,\n run.variables ? JSON.stringify(run.variables) : null,\n run.logs ? JSON.stringify(run.logs) : null,\n run.error || null\n ]\n });\n}\n\n// Helper: convert result rows → typed objects using column names\nfunction mapRows>(result: { columns: string[]; rows: any[] }): T[] {\n return result.rows.map(row => {\n // std/sqlite/main.ts trả rows là object (key-value) — dùng trực tiếp\n // Nhưng nếu là array thì map theo columns\n if (Array.isArray(row)) {\n const obj: Record = {};\n result.columns.forEach((col, i) => { obj[col] = row[i]; });\n return obj as T;\n }\n return row as T;\n });\n}\n\nexport async function getFlowRun(id: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM flow_runs WHERE id=?`,\n args: [id]\n });\n if (!result.rows.length) return null;\n const rows = mapRows(result);\n const row = rows[0] as any;\n return {\n id: row.id,\n flow_id: row.flow_id,\n status: row.status,\n started_at: row.started_at,\n finished_at: row.finished_at,\n error: row.error,\n variables: row.variables ? JSON.parse(row.variables as string) : {},\n logs: row.logs ? JSON.parse(row.logs as string) : [],\n };\n}\n\nexport async function listFlowRuns(flowId?: string): Promise {\n const result = flowId\n ? await sqlite.execute({\n sql: `SELECT id, flow_id, status, started_at, finished_at, error FROM flow_runs WHERE flow_id=? ORDER BY started_at DESC LIMIT 50`,\n args: [flowId]\n })\n : await sqlite.execute(\n `SELECT id, flow_id, status, started_at, finished_at, error FROM flow_runs ORDER BY started_at DESC LIMIT 50`\n );\n return mapRows(result);\n}\n",[],[192],"fbee8240-2058-11f1-bb20-42dde27851f2","main.ts",["D",1773570198098],"http","// ============================================================\n// MAIN HTTP API + UI SERVER — v2 với async run + polling\n// ============================================================\n\nimport { runFlow } from \"./engine.ts\";\nimport {\n saveFlow, getFlow, listFlows, deleteFlow,\n saveFlowRun, getFlowRun, listFlowRuns\n} from \"./storage.ts\";\nimport type { Flow } from \"./types.ts\";\n\nconst CORS_HEADERS = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, PUT, DELETE, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization, X-Kernel-API-Key\",\n};\n\nfunction json(data: unknown, status = 200) {\n return new Response(JSON.stringify(data, null, 2), {\n status,\n headers: { ...CORS_HEADERS, \"Content-Type\": \"application/json\" }\n });\n}\nfunction err(msg: string, status = 400) {\n return json({ error: msg }, status);\n}\nfunction genId(prefix: string) {\n return `${prefix}_${Date.now()}_${Math.random().toString(36).slice(2, 8)}`;\n}\n\nexport default async function handler(req: Request): Promise {\n if (req.method === \"OPTIONS\") return new Response(null, { headers: CORS_HEADERS });\n\n const url = new URL(req.url);\n const path = url.pathname;\n const method = req.method;\n\n // ── Serve UI ───────────────────────────────────────────\n if ((path === \"/\" || path === \"\") && method === \"GET\") {\n return new Response(HTML, { headers: { \"Content-Type\": \"text/html; charset=utf-8\" } });\n }\n\n // ── Health check ───────────────────────────────────────\n if (path === \"/health\") {\n return json({ status: \"ok\", name: \"BrowserFlow Engine\", version: \"2.0.0\" });\n }\n\n // ── Internal: thực thi flow background ────────────────\n if (path === \"/internal/run\" && method === \"POST\") {\n const token = req.headers.get(\"X-Internal-Token\");\n const expectedToken = Deno.env.get(\"INTERNAL_TOKEN\") || \"internal_browserflow_secret\";\n if (token !== expectedToken) return err(\"Unauthorized\", 401);\n\n const body = await req.json() as {\n runId: string; flowId?: string; flow?: Flow;\n variables?: Record; kernelApiKey: string;\n };\n\n (async () => {\n try {\n const flow = body.flow ?? (body.flowId ? await getFlow(body.flowId) : null);\n if (!flow) {\n await saveFlowRun({\n id: body.runId, flowId: body.flowId ?? \"inline\",\n status: \"failed\", startedAt: new Date().toISOString(),\n finishedAt: new Date().toISOString(), error: \"Flow not found\"\n });\n return;\n }\n\n const result = await runFlow({\n flow,\n variables: body.variables ?? {},\n kernelApiKey: body.kernelApiKey\n });\n\n await saveFlowRun({\n id: body.runId,\n flowId: flow.id,\n status: result.success ? \"success\" : \"failed\",\n startedAt: new Date().toISOString(),\n finishedAt: new Date().toISOString(),\n variables: result.variables,\n logs: result.logs,\n error: result.error\n });\n } catch (e: any) {\n await saveFlowRun({\n id: body.runId,\n flowId: body.flowId ?? \"inline\",\n status: \"failed\",\n startedAt: new Date().toISOString(),\n finishedAt: new Date().toISOString(),\n error: e.message\n }).catch(() => {});\n }\n })();\n\n return json({ accepted: true, runId: body.runId }, 202);\n }\n\n const kernelApiKey = req.headers.get(\"X-Kernel-API-Key\") || Deno.env.get(\"KERNEL_API_KEY\") || \"\";\n\n try {\n\n // ── GET /flows ────────────────────────────────────────\n if (path === \"/flows\" && method === \"GET\") {\n const flows = await listFlows();\n return json({ flows, total: flows.length });\n }\n\n // ── POST /flows ───────────────────────────────────────\n if (path === \"/flows\" && method === \"POST\") {\n const body = await req.json() as Flow;\n if (!body.name) return err(\"Missing flow name\");\n if (!Array.isArray(body.blocks)) return err(\"Missing blocks array\");\n if (!body.id) body.id = genId(\"flow\");\n await saveFlow(body);\n return json({ success: true, flowId: body.id });\n }\n\n const flowMatch = path.match(/^\\/flows\\/([^/]+)$/);\n const runMatch = path.match(/^\\/flows\\/([^/]+)\\/run$/);\n\n // ── GET /flows/:id ────────────────────────────────────\n if (flowMatch && method === \"GET\") {\n const flow = await getFlow(flowMatch[1]);\n if (!flow) return err(\"Flow not found\", 404);\n return json(flow);\n }\n\n // ── DELETE /flows/:id ─────────────────────────────────\n if (flowMatch && method === \"DELETE\") {\n await deleteFlow(flowMatch[1]);\n return json({ success: true });\n }\n\n // ── POST /flows/:id/run ───────────────────────────────\n if (runMatch && method === \"POST\") {\n const flowId = runMatch[1];\n const flow = await getFlow(flowId);\n if (!flow) return err(\"Flow not found\", 404);\n if (!kernelApiKey) return err(\"Missing Kernel API Key\");\n\n const body = await req.json().catch(() => ({})) as Record;\n const runId = genId(\"run\");\n\n await saveFlowRun({\n id: runId, flowId,\n status: \"running\",\n startedAt: new Date().toISOString(),\n });\n\n const selfUrl = `${url.origin}/internal/run`;\n const internalToken = Deno.env.get(\"INTERNAL_TOKEN\") || \"internal_browserflow_secret\";\n fetch(selfUrl, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"X-Internal-Token\": internalToken,\n },\n body: JSON.stringify({\n runId, flowId,\n variables: body.variables ?? {},\n kernelApiKey,\n }),\n }).catch((e) => console.error(\"[ASYNC RUN] fire-and-forget failed:\", e.message));\n\n return json({\n runId,\n status: \"running\",\n message: \"Flow started. Poll GET /runs/\" + runId + \" for status.\",\n pollUrl: `${url.origin}/runs/${runId}`,\n }, 202);\n }\n\n // ── POST /run (inline, sync) ───────────────────────────\n if (path === \"/run\" && method === \"POST\") {\n if (!kernelApiKey) return err(\"Missing Kernel API Key\");\n const body = await req.json() as { flow: Flow; variables?: Record; async?: boolean };\n if (!body.flow) return err(\"Missing flow\");\n\n if (body.async) {\n const runId = genId(\"run\");\n const inlineFlowId = body.flow.id ?? genId(\"inline_flow\");\n body.flow.id = inlineFlowId;\n\n await saveFlowRun({\n id: runId, flowId: inlineFlowId,\n status: \"running\", startedAt: new Date().toISOString(),\n });\n\n const selfUrl = `${url.origin}/internal/run`;\n const internalToken = Deno.env.get(\"INTERNAL_TOKEN\") || \"internal_browserflow_secret\";\n fetch(selfUrl, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"X-Internal-Token\": internalToken,\n },\n body: JSON.stringify({\n runId, flow: body.flow,\n variables: body.variables ?? {},\n kernelApiKey,\n }),\n }).catch((e) => console.error(\"[ASYNC /run] failed:\", e.message));\n\n return json({\n runId, status: \"running\",\n pollUrl: `${url.origin}/runs/${runId}`,\n }, 202);\n }\n\n const result = await runFlow({\n flow: body.flow,\n variables: body.variables ?? {},\n kernelApiKey\n });\n return json(result);\n }\n\n // ── GET /runs ─────────────────────────────────────────\n if (path === \"/runs\" && method === \"GET\") {\n const runs = await listFlowRuns(url.searchParams.get(\"flowId\") ?? undefined);\n return json({ runs });\n }\n\n // ── GET /runs/:id ─────────────────────────────────────\n const runDetailMatch = path.match(/^\\/runs\\/([^/]+)$/);\n if (runDetailMatch && method === \"GET\") {\n const run = await getFlowRun(runDetailMatch[1]);\n if (!run) return err(\"Run not found\", 404);\n\n if (url.searchParams.get(\"wait\") === \"true\" && run.status === \"running\") {\n const deadline = Date.now() + 25_000;\n let latest = run;\n while (Date.now() < deadline && latest.status === \"running\") {\n await new Promise(r => setTimeout(r, 1500));\n const fresh = await getFlowRun(runDetailMatch[1]);\n if (fresh) latest = fresh;\n }\n return json(latest);\n }\n\n return json(run);\n }\n\n // ── DELETE /runs/:id ──────────────────────────────────\n if (runDetailMatch && method === \"DELETE\") {\n const run = await getFlowRun(runDetailMatch[1]);\n if (!run) return err(\"Run not found\", 404);\n if (run.status === \"running\") {\n await saveFlowRun({ ...run, status: \"cancelled\", finishedAt: new Date().toISOString() });\n }\n return json({ success: true });\n }\n\n return err(\"Not found\", 404);\n\n } catch (e: any) {\n console.error(\"[API ERROR]\", e);\n return err(e.message, 500);\n }\n}\n\n// ── Inline HTML UI ─────────────────────────────────────────\n// NOTE: Toàn bộ JS trong \n\n`;\n",[],[200],"b53989ae-2052-11f1-82e9-42dde27851f2","engine.ts","f52e6d8c-204c-11f1-8e02-42dde27851f2",26,["D",1773567502494],13,"// ============================================================\n// FLOW ENGINE v2 - Kernel.sh REST API + Playwright CDP\n// Base URL confirmed: https://api.onkernel.com (từ official docs)\n// ============================================================\n\n// StubFS: bắt buộc trên Val Town để playwright-core không crash\nimport \"https://esm.town/v/wolf/StubFS/stubFs.ts\";\n\nimport type {\n Flow, Block, FlowContext, BlockResult, RunFlowOptions, RunFlowResult, LogEntry\n} from \"./types.ts\";\nimport { executeInteractBlock } from \"./blocks/interact.ts\";\nimport { executeExtractBlock } from \"./blocks/extract.ts\";\nimport { executeNavigateBlock } from \"./blocks/navigate.ts\";\nimport { executeControlFlowBlock } from \"./blocks/controlflow.ts\";\nimport { executeUtilityBlock } from \"./blocks/utilities.ts\";\nimport { executeSpreadsheetBlock } from \"./blocks/spreadsheet.ts\";\n\n// ─── Block groups ─────────────────────────────────────────\nconst INTERACT_BLOCKS = new Set([\n \"click\", \"type_text\", \"press_key\", \"scroll\", \"hover\",\n \"select_option\", \"set_date_input\", \"upload_file\", \"handle_dialog\"\n]);\nconst EXTRACT_BLOCKS = new Set([\n \"get_element_text\", \"get_link_url\", \"get_page_url\", \"get_element_attribute\",\n \"get_element_html\", \"get_clipboard\", \"save_file\", \"take_screenshot\", \"generate_pdf\"\n]);\nconst NAVIGATE_BLOCKS = new Set([\"visit\", \"go_back\", \"go_forward\", \"reload_page\"]);\nconst CONTROLFLOW_BLOCKS = new Set([\n \"loop\", \"loop_elements\", \"loop_list_items\", \"loop_pages\",\n \"if\", \"else\", \"while\", \"end\", \"break\"\n]);\nconst SPREADSHEET_BLOCKS = new Set([\n \"loop_spreadsheet_rows\", \"add_spreadsheet_row\", \"update_spreadsheet_row\", \"find_spreadsheet_row\"\n]);\n\n// ─── Kernel API types ─────────────────────────────────────\nconst KERNEL_BASE = \"https://api.onkernel.com\";\n\ninterface KernelSession {\n session_id: string;\n cdp_ws_url: string;\n browser_live_view_url?: string;\n}\n\n// ─── Kernel REST: tạo browser session ─────────────────────\nasync function createKernelSession(apiKey: string): Promise {\n const res = await fetch(`${KERNEL_BASE}/browsers`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": `Bearer ${apiKey}`,\n },\n body: JSON.stringify({\n headless: false,\n timeout_seconds: 300, // 5 phút\n }),\n signal: AbortSignal.timeout(20_000),\n });\n\n const text = await res.text();\n console.log(`[KERNEL] POST /browsers → ${res.status}: ${text.slice(0, 300)}`);\n\n if (!res.ok) {\n throw new Error(`Kernel API ${res.status}: ${text.slice(0, 200)}`);\n }\n\n const data = JSON.parse(text) as any;\n const session_id: string = data.session_id ?? \"\";\n const cdp_ws_url: string = data.cdp_ws_url ?? \"\";\n\n if (!session_id) throw new Error(`Kernel: no session_id. Got: ${text.slice(0, 100)}`);\n if (!cdp_ws_url) throw new Error(`Kernel: no cdp_ws_url. Got: ${text.slice(0, 100)}`);\n\n return { session_id, cdp_ws_url, browser_live_view_url: data.browser_live_view_url };\n}\n\n// ─── Kernel REST: xóa session ─────────────────────────────\nasync function deleteKernelSession(apiKey: string, sessionId: string): Promise {\n if (!sessionId) return;\n try {\n const res = await fetch(`${KERNEL_BASE}/browsers/${sessionId}`, {\n method: \"DELETE\",\n headers: { \"Authorization\": `Bearer ${apiKey}` },\n signal: AbortSignal.timeout(8_000),\n });\n console.log(`[KERNEL] DELETE /browsers/${sessionId} → ${res.status}`);\n } catch (e: any) {\n console.warn(`[KERNEL] Delete session warning: ${e.message}`);\n }\n}\n\n// ─── Retry với exponential backoff ────────────────────────\nasync function withRetry(\n fn: () => Promise,\n maxAttempts = 3,\n baseDelayMs = 2000,\n label = \"op\"\n): Promise {\n let lastError: Error = new Error(\"Unknown\");\n for (let i = 1; i <= maxAttempts; i++) {\n try {\n return await fn();\n } catch (err: any) {\n lastError = err;\n if (i < maxAttempts) {\n const delay = Math.min(baseDelayMs * Math.pow(2, i - 1), 30_000);\n console.warn(`[RETRY] ${label} attempt ${i}/${maxAttempts} failed: ${err.message}. Retry in ${delay}ms`);\n await new Promise(r => setTimeout(r, delay));\n }\n }\n }\n throw lastError;\n}\n\n// ─── Engine chính ──────────────────────────────────────────\nexport async function runFlow(options: RunFlowOptions): Promise {\n const { flow, kernelApiKey } = options;\n if (!flow) return { success: false, variables: {}, logs: [], error: \"No flow provided\" };\n\n // Logger dùng closure — không pass như arg để tránh \"log is not a function\"\n const logs: LogEntry[] = [];\n function emitLog(level: LogEntry[\"level\"], message: string, blockId?: string, blockType?: string, data?: unknown): void {\n const entry: LogEntry = {\n timestamp: new Date().toISOString(),\n level,\n message,\n blockId,\n blockType,\n data,\n };\n logs.push(entry);\n console.log(`[${level.toUpperCase()}][${blockType ?? \"engine\"}] ${message}`);\n }\n\n let browser: any = null;\n let sessionId = \"\";\n\n // ─── Phase 1: Tạo Kernel session ───────────────────────\n try {\n emitLog(\"info\", \"🚀 Tạo Kernel browser session...\");\n\n const ks = await withRetry(\n () => createKernelSession(kernelApiKey),\n 3, 2000, \"kernel-create\"\n );\n sessionId = ks.session_id;\n emitLog(\"info\", `✅ Session: ${sessionId}`);\n emitLog(\"info\", `🔗 CDP: ${ks.cdp_ws_url}`);\n if (ks.browser_live_view_url) {\n emitLog(\"info\", `🖥️ Live view: ${ks.browser_live_view_url}`);\n }\n\n // ─── Phase 2: Connect Playwright ──────────────────────\n emitLog(\"info\", \"🎭 Connecting Playwright via CDP...\");\n const { chromium } = await import(\"npm:playwright-core@1.49.1\");\n\n browser = await withRetry(\n () => chromium.connectOverCDP(ks.cdp_ws_url, { timeout: 30_000 }),\n 3, 2000, \"cdp-connect\"\n );\n emitLog(\"info\", \"✅ Playwright connected\");\n\n } catch (err: any) {\n emitLog(\"error\", `❌ Init failed: ${err.message}`);\n if (sessionId) await deleteKernelSession(kernelApiKey, sessionId);\n return { success: false, variables: {}, logs, error: err.message };\n }\n\n // ─── Phase 3: Khởi tạo Page ──────────────────────────\n let mainPage: any;\n try {\n const contexts = browser.contexts();\n const ctx0 = contexts.length > 0 ? contexts[0] : await browser.newContext();\n const pages = ctx0.pages();\n mainPage = pages.length > 0 ? pages[0] : await ctx0.newPage();\n emitLog(\"info\", \"✅ Page ready\");\n } catch (err: any) {\n emitLog(\"error\", `❌ Page init failed: ${err.message}`);\n await browser.close().catch(() => {});\n await deleteKernelSession(kernelApiKey, sessionId);\n return { success: false, variables: {}, logs, error: err.message };\n }\n\n const initialTabId = \"tab_main\";\n const tabs = new Map();\n tabs.set(initialTabId, mainPage);\n\n const flowCtx: FlowContext = {\n variables: { ...(flow.variables ?? {}), ...(options.variables ?? {}) },\n tabs,\n activeTabId: initialTabId,\n loopStack: [],\n browser,\n kernelSessionId: sessionId,\n logs,\n shouldBreak: false,\n };\n\n // ─── Phase 4: Thực thi blocks ────────────────────────\n let blockIndex = 0;\n const blocks = flow.blocks ?? [];\n let runSuccess = true;\n let runError = \"\";\n\n while (blockIndex < blocks.length) {\n const block = blocks[blockIndex];\n if (!block) { blockIndex++; continue; }\n\n // Skip comment blocks\n if (block.type === \"comment\") {\n emitLog(\"debug\", `💬 ${block.params?.text ?? \"\"}`, block.id, \"comment\");\n blockIndex++;\n continue;\n }\n\n const t0 = Date.now();\n emitLog(\"info\", `▶ [${blockIndex}] ${block.type}`, block.id, block.type, block.params);\n\n let result: BlockResult;\n try {\n if (INTERACT_BLOCKS.has(block.type)) {\n result = await executeInteractBlock(block, flowCtx);\n } else if (EXTRACT_BLOCKS.has(block.type)) {\n result = await executeExtractBlock(block, flowCtx);\n } else if (NAVIGATE_BLOCKS.has(block.type)) {\n result = await executeNavigateBlock(block, flowCtx);\n } else if (CONTROLFLOW_BLOCKS.has(block.type)) {\n result = await executeControlFlowBlock(block, flowCtx, blockIndex, blocks);\n } else if (SPREADSHEET_BLOCKS.has(block.type)) {\n result = await executeSpreadsheetBlock(block, flowCtx, blockIndex);\n } else if (block.type === \"run_flow\") {\n result = await runSubFlow(block, flowCtx, kernelApiKey);\n } else {\n result = await executeUtilityBlock(block, flowCtx);\n }\n } catch (err: any) {\n result = { success: false, error: err.message };\n }\n\n const ms = Date.now() - t0;\n\n if (!result.success) {\n const msg = `❌ [${block.type}] ${result.error ?? \"Unknown error\"} (${ms}ms)`;\n emitLog(\"error\", msg, block.id, block.type);\n\n // Auto-screenshot on error\n try {\n const buf = await mainPage.screenshot({ type: \"png\", fullPage: false });\n const b64 = btoa(String.fromCharCode(...new Uint8Array(buf)));\n emitLog(\"debug\", `📸 screenshot:data:image/png;base64,${b64}`, block.id, block.type);\n } catch (_) { /* ignore */ }\n\n if (block.params?.continueOnError) {\n emitLog(\"warn\", `⚠️ continueOnError=true, continuing`, block.id, block.type);\n blockIndex++;\n continue;\n }\n runSuccess = false;\n runError = msg;\n break;\n }\n\n emitLog(\"info\", `✅ [${block.type}] done (${ms}ms)`, block.id, block.type,\n result.output !== undefined ? result.output : undefined);\n\n // Điều hướng index\n if (flowCtx.shouldBreak) {\n flowCtx.shouldBreak = false;\n blockIndex = findNextEnd(blocks, blockIndex) + 1;\n continue;\n }\n if (result.jumpToIndex !== undefined) {\n blockIndex = result.jumpToIndex;\n continue;\n }\n if (result.skipToEnd) {\n blockIndex = findNextEndOrElse(blocks, blockIndex) + 1;\n continue;\n }\n\n blockIndex++;\n }\n\n // ─── Cleanup ─────────────────────────────────────────\n emitLog(\"info\", \"🧹 Cleaning up...\");\n try { await browser.close(); } catch (_) { /* ignore */ }\n await deleteKernelSession(kernelApiKey, sessionId);\n emitLog(\"info\", \"✅ Done\");\n\n return {\n success: runSuccess,\n variables: flowCtx.variables,\n logs,\n error: runError || undefined,\n };\n}\n\n// ─── Sub-flow runner ─────────────────────────────────────\nasync function runSubFlow(block: Block, ctx: FlowContext, kernelApiKey: string): Promise {\n const flowId: string = block.params?.flowId ?? \"\";\n if (!flowId) return { success: false, error: \"run_flow: missing flowId\" };\n try {\n const { getFlow } = await import(\"./storage.ts\");\n const subFlow = await getFlow(flowId);\n if (!subFlow) return { success: false, error: `Flow not found: ${flowId}` };\n const result = await runFlow({ flow: subFlow, kernelApiKey, variables: ctx.variables });\n Object.assign(ctx.variables, result.variables);\n return { success: result.success, output: result.variables, error: result.error };\n } catch (err: any) {\n return { success: false, error: err.message };\n }\n}\n\n// ─── Index helpers ───────────────────────────────────────\nconst LOOP_TYPES = [\"loop\", \"loop_elements\", \"loop_list_items\", \"loop_pages\", \"loop_spreadsheet_rows\", \"if\", \"while\"];\n\nfunction findNextEnd(blocks: Block[], from: number): number {\n let depth = 1;\n for (let i = from + 1; i < blocks.length; i++) {\n if (LOOP_TYPES.includes(blocks[i].type)) depth++;\n if (blocks[i].type === \"end\") { if (--depth === 0) return i; }\n }\n return blocks.length - 1;\n}\n\nfunction findNextEndOrElse(blocks: Block[], from: number): number {\n let depth = 1;\n for (let i = from + 1; i < blocks.length; i++) {\n const t = blocks[i].type;\n if (LOOP_TYPES.includes(t)) depth++;\n if (t === \"end\") { if (--depth === 0) return i; }\n if (t === \"else\" && depth === 1) return i;\n }\n return blocks.length - 1;\n}\n",[],[207],"d17b8fbe-204c-11f1-bf0b-42dde27851f2","utilities.ts","d17b9086-204c-11f1-bf0b-42dde27851f2","10cec21b-bdeb-4c89-baf1-94f44f17e648",6,["D",1773564972926],"// ============================================================\n// UTILITY BLOCKS - Tiện ích, Tabs, HTTP Request, v.v.\n// ============================================================\n\nimport type { Block, FlowContext, BlockResult } from \"../types.ts\";\n\nfunction resolvePlaceholders(value: any, variables: Record): any {\n if (typeof value !== \"string\") return value;\n return value.replace(/\\{\\{(\\w+)\\}\\}/g, (_, key) => variables[key] ?? `{{${key}}}`);\n}\n\nexport async function executeUtilityBlock(\n block: Block,\n ctx: FlowContext\n): Promise {\n const page = ctx.tabs.get(ctx.activeTabId);\n const p = block.params;\n const resolve = (v: any) => resolvePlaceholders(v, ctx.variables);\n\n try {\n switch (block.type) {\n // ─────────────────────────────────────────\n // 🪟 TABS\n // ─────────────────────────────────────────\n case \"create_tab\": {\n // params: url, tabIdVar (variable để lưu tabId)\n const newPage = await ctx.browser.newPage();\n const tabId = `tab_${Date.now()}`;\n ctx.tabs.set(tabId, newPage);\n ctx.activeTabId = tabId;\n if (p.url) {\n await newPage.goto(resolve(p.url), { waitUntil: \"domcontentloaded\" });\n }\n if (p.tabIdVar) ctx.variables[p.tabIdVar] = tabId;\n return { success: true, output: tabId };\n }\n\n case \"get_active_tab_id\": {\n // params: saveAs\n if (p.saveAs) ctx.variables[p.saveAs] = ctx.activeTabId;\n return { success: true, output: ctx.activeTabId };\n }\n\n case \"select_tab\": {\n // params: tabId (hoặc variable)\n const tabId = resolve(p.tabId);\n if (!ctx.tabs.has(tabId)) return { success: false, error: `Tab not found: ${tabId}` };\n ctx.activeTabId = tabId;\n return { success: true, output: `Active tab: ${tabId}` };\n }\n\n case \"close_tab\": {\n // params: tabId (optional, mặc định active tab)\n const tabId = p.tabId ? resolve(p.tabId) : ctx.activeTabId;\n const tabPage = ctx.tabs.get(tabId);\n if (tabPage) {\n await tabPage.close();\n ctx.tabs.delete(tabId);\n // Chuyển sang tab còn lại\n const remaining = Array.from(ctx.tabs.keys());\n if (remaining.length > 0) ctx.activeTabId = remaining[remaining.length - 1];\n }\n return { success: true, output: `Closed tab: ${tabId}` };\n }\n\n // ─────────────────────────────────────────\n // 🔧 UTILITIES\n // ─────────────────────────────────────────\n case \"run_script\": {\n // params: script (JS code), saveAs\n if (!page) return { success: false, error: \"No active page\" };\n const script = resolve(p.script);\n const result = await page.evaluate(new Function(`return (async () => { ${script} })()`));\n if (p.saveAs) ctx.variables[p.saveAs] = result;\n return { success: true, output: result };\n }\n\n case \"get_date\": {\n // params: format (iso/timestamp/locale), saveAs, timezone\n const now = new Date();\n let dateValue: string | number;\n switch (p.format) {\n case \"timestamp\": dateValue = now.getTime(); break;\n case \"locale\": dateValue = now.toLocaleString(p.locale || \"vi-VN\"); break;\n case \"date_only\": dateValue = now.toISOString().split(\"T\")[0]; break;\n case \"time_only\": dateValue = now.toTimeString().split(\" \")[0]; break;\n default: dateValue = now.toISOString();\n }\n if (p.saveAs) ctx.variables[p.saveAs] = dateValue;\n return { success: true, output: dateValue };\n }\n\n case \"wait\": {\n // params: duration (ms)\n const duration = parseInt(resolve(p.duration)) || 1000;\n await new Promise(r => setTimeout(r, duration));\n return { success: true, output: `Waited ${duration}ms` };\n }\n\n case \"wait_for_element\": {\n // params: selector, timeout, state (visible/hidden/attached/detached)\n if (!page) return { success: false, error: \"No active page\" };\n const selector = resolve(p.selector);\n const timeout = parseInt(p.timeout) || 30000;\n const state = p.state || \"visible\";\n await page.waitForSelector(selector, { timeout, state });\n return { success: true, output: `Element found: ${selector}` };\n }\n\n case \"show_alert\": {\n // params: message (chỉ log, vì headless không show alert thật)\n const message = resolve(p.message);\n console.log(`[ALERT] ${message}`);\n ctx.logs.push({\n timestamp: new Date().toISOString(),\n level: \"info\",\n blockId: block.id,\n blockType: block.type,\n message: `Alert: ${message}`\n });\n return { success: true, output: message };\n }\n\n case \"make_http_request\": {\n // params: url, method, headers, body, saveAs, saveStatusAs\n const url = resolve(p.url);\n const method = (p.method || \"GET\").toUpperCase();\n const headers: Record = {};\n if (p.headers) {\n for (const [k, v] of Object.entries(p.headers as Record)) {\n headers[k] = resolve(v);\n }\n }\n const fetchOptions: RequestInit = { method, headers };\n if (p.body && method !== \"GET\") {\n fetchOptions.body = typeof p.body === \"string\"\n ? resolve(p.body)\n : JSON.stringify(p.body);\n if (!headers[\"Content-Type\"]) headers[\"Content-Type\"] = \"application/json\";\n }\n const response = await fetch(url, fetchOptions);\n const status = response.status;\n let responseData: any;\n const contentType = response.headers.get(\"content-type\") || \"\";\n if (contentType.includes(\"application/json\")) {\n responseData = await response.json();\n } else {\n responseData = await response.text();\n }\n if (p.saveAs) ctx.variables[p.saveAs] = responseData;\n if (p.saveStatusAs) ctx.variables[p.saveStatusAs] = status;\n return { success: true, output: { status, data: responseData } };\n }\n\n case \"assert\": {\n // params: condition, message (optional)\n const condition = resolve(p.condition);\n let result: boolean;\n try {\n const fn = new Function(...Object.keys(ctx.variables), `return !!(${condition})`);\n result = fn(...Object.values(ctx.variables));\n } catch {\n result = false;\n }\n if (!result) {\n const msg = resolve(p.message) || `Assertion failed: ${condition}`;\n return { success: false, error: msg };\n }\n return { success: true, output: \"Assertion passed\" };\n }\n\n case \"comment\": {\n // params: text (chỉ ghi log, không làm gì)\n return { success: true, output: resolve(p.text || \"\") };\n }\n\n case \"solve_captcha\": {\n // params: selector, service (2captcha/anticaptcha), apiKey, saveAs\n // Tích hợp 2captcha đơn giản\n if (!page) return { success: false, error: \"No active page\" };\n const siteKey = await page.$eval(\n p.selector || \".g-recaptcha\",\n (el: Element) => el.getAttribute(\"data-sitekey\") || \"\"\n );\n if (!siteKey) return { success: false, error: \"No captcha sitekey found\" };\n const pageUrl = page.url();\n // Submit to 2captcha\n const apiKey = resolve(p.apiKey || \"\");\n const submitRes = await fetch(`https://2captcha.com/in.php?key=${apiKey}&method=userrecaptcha&googlekey=${siteKey}&pageurl=${pageUrl}&json=1`);\n const submitData = await submitRes.json();\n if (submitData.status !== 1) return { success: false, error: submitData.request };\n // Poll for result\n const taskId = submitData.request;\n let token = \"\";\n for (let i = 0; i < 30; i++) {\n await new Promise(r => setTimeout(r, 5000));\n const res = await fetch(`https://2captcha.com/res.php?key=${apiKey}&action=get&id=${taskId}&json=1`);\n const data = await res.json();\n if (data.status === 1) { token = data.request; break; }\n if (data.request !== \"CAPCHA_NOT_READY\") break;\n }\n if (!token) return { success: false, error: \"Captcha solve timeout\" };\n await page.evaluate((t: string) => {\n (document.getElementById(\"g-recaptcha-response\") as HTMLTextAreaElement).value = t;\n }, token);\n if (p.saveAs) ctx.variables[p.saveAs] = token;\n return { success: true, output: \"Captcha solved\" };\n }\n\n default:\n return { success: false, error: `Unknown utility block: ${block.type}` };\n }\n } catch (err: any) {\n return { success: false, error: err.message };\n }\n}\n",[],[224,216],"blocks","df177ea8-204c-11f1-9c7e-42dde27851f2","spreadsheet.ts","df177f84-204c-11f1-9c7e-42dde27851f2",7,["D",1773564995756],"// ============================================================\n// SPREADSHEET BLOCKS - Tích hợp Google Sheets\n// ============================================================\n\nimport type { Block, FlowContext, BlockResult, LoopFrame } from \"../types.ts\";\n\nfunction resolvePlaceholders(value: any, variables: Record): any {\n if (typeof value !== \"string\") return value;\n return value.replace(/\\{\\{(\\w+)\\}\\}/g, (_, key) => variables[key] ?? `{{${key}}}`);\n}\n\n// Helper: Gọi Google Sheets API\nasync function sheetsRequest(\n method: string,\n path: string,\n accessToken: string,\n body?: any\n) {\n const res = await fetch(`https://sheets.googleapis.com/v4/spreadsheets/${path}`, {\n method,\n headers: {\n Authorization: `Bearer ${accessToken}`,\n \"Content-Type\": \"application/json\",\n },\n body: body ? JSON.stringify(body) : undefined,\n });\n if (!res.ok) {\n const err = await res.text();\n throw new Error(`Sheets API error ${res.status}: ${err}`);\n }\n return res.json();\n}\n\nexport async function executeSpreadsheetBlock(\n block: Block,\n ctx: FlowContext,\n blockIndex: number\n): Promise {\n const p = block.params;\n const resolve = (v: any) => resolvePlaceholders(v, ctx.variables);\n const accessToken = resolve(p.accessToken || ctx.variables[\"__sheets_token__\"] || \"\");\n const spreadsheetId = resolve(p.spreadsheetId || ctx.variables[\"__sheets_id__\"] || \"\");\n const sheetName = resolve(p.sheetName || \"Sheet1\");\n\n try {\n switch (block.type) {\n case \"loop_spreadsheet_rows\": {\n // params: spreadsheetId, sheetName, accessToken, rowVar, indexVar, startRow\n const range = `${sheetName}!A1:ZZ`;\n const data = await sheetsRequest(\"GET\",\n `${spreadsheetId}/values/${encodeURIComponent(range)}`, accessToken\n );\n const rows: string[][] = data.values || [];\n const headers = rows[0] || [];\n const dataRows = rows.slice(parseInt(p.startRow || \"1\"));\n\n // Chuyển thành array of objects\n const items = dataRows.map(row =>\n headers.reduce((obj, header, i) => {\n obj[header] = row[i] || \"\";\n return obj;\n }, {} as Record)\n );\n\n const frame: LoopFrame = {\n type: \"loop_spreadsheet_rows\",\n startIndex: blockIndex,\n currentIteration: 0,\n maxIterations: items.length,\n items,\n currentItem: items[0],\n };\n ctx.loopStack.push(frame);\n if (p.rowVar) ctx.variables[p.rowVar] = items[0] || {};\n if (p.indexVar) ctx.variables[p.indexVar] = 0;\n ctx.variables[\"__sheets_rows__\"] = items;\n return { success: true, output: `Loop ${items.length} rows` };\n }\n\n case \"add_spreadsheet_row\": {\n // params: spreadsheetId, sheetName, accessToken, values (object hoặc array)\n let rowValues: any[];\n if (Array.isArray(p.values)) {\n rowValues = p.values.map((v: any) => resolve(v));\n } else if (typeof p.values === \"object\") {\n rowValues = Object.values(p.values).map((v: any) => resolve(String(v)));\n } else {\n rowValues = [resolve(p.values)];\n }\n const range = `${sheetName}!A1`;\n await sheetsRequest(\"POST\",\n `${spreadsheetId}/values/${encodeURIComponent(range)}:append?valueInputOption=USER_ENTERED`,\n accessToken,\n { values: [rowValues] }\n );\n return { success: true, output: \"Row added\" };\n }\n\n case \"update_spreadsheet_row\": {\n // params: spreadsheetId, sheetName, accessToken, rowNumber, values\n const rowNumber = parseInt(resolve(p.rowNumber));\n let rowValues: any[];\n if (Array.isArray(p.values)) {\n rowValues = p.values.map((v: any) => resolve(v));\n } else if (typeof p.values === \"object\") {\n rowValues = Object.values(p.values).map((v: any) => resolve(String(v)));\n } else {\n rowValues = [resolve(p.values)];\n }\n const range = `${sheetName}!A${rowNumber}`;\n await sheetsRequest(\"PUT\",\n `${spreadsheetId}/values/${encodeURIComponent(range)}?valueInputOption=USER_ENTERED`,\n accessToken,\n { values: [rowValues] }\n );\n return { success: true, output: `Row ${rowNumber} updated` };\n }\n\n case \"find_spreadsheet_row\": {\n // params: spreadsheetId, sheetName, accessToken, column, value, saveAs, saveRowNumberAs\n const range = `${sheetName}!A1:ZZ`;\n const data = await sheetsRequest(\"GET\",\n `${spreadsheetId}/values/${encodeURIComponent(range)}`, accessToken\n );\n const rows: string[][] = data.values || [];\n const headers = rows[0] || [];\n const searchColumn = resolve(p.column);\n const searchValue = resolve(p.value);\n const colIndex = headers.indexOf(searchColumn);\n if (colIndex === -1) return { success: false, error: `Column not found: ${searchColumn}` };\n\n for (let i = 1; i < rows.length; i++) {\n if (rows[i][colIndex] === searchValue) {\n const rowObj = headers.reduce((obj, h, idx) => {\n obj[h] = rows[i][idx] || \"\";\n return obj;\n }, {} as Record);\n if (p.saveAs) ctx.variables[p.saveAs] = rowObj;\n if (p.saveRowNumberAs) ctx.variables[p.saveRowNumberAs] = i + 1;\n return { success: true, output: rowObj };\n }\n }\n if (p.saveAs) ctx.variables[p.saveAs] = null;\n return { success: true, output: null };\n }\n\n default:\n return { success: false, error: `Unknown spreadsheet block: ${block.type}` };\n }\n } catch (err: any) {\n return { success: false, error: err.message };\n }\n}\n",[],[224,226],"aa05b572-204c-11f1-abf1-42dde27851f2","navigate.ts","aa05b72a-204c-11f1-abf1-42dde27851f2",4,["D",1773564906723],"// ============================================================\n// NAVIGATE BLOCKS - Điều hướng trình duyệt\n// ============================================================\n\nimport type { Block, FlowContext, BlockResult } from \"../types.ts\";\n\nfunction resolvePlaceholders(value: any, variables: Record): any {\n if (typeof value !== \"string\") return value;\n return value.replace(/\\{\\{(\\w+)\\}\\}/g, (_, key) => variables[key] ?? `{{${key}}}`);\n}\n\nexport async function executeNavigateBlock(\n block: Block,\n ctx: FlowContext\n): Promise {\n const page = ctx.tabs.get(ctx.activeTabId);\n if (!page) return { success: false, error: \"No active page/tab\" };\n\n const p = block.params;\n const resolve = (v: any) => resolvePlaceholders(v, ctx.variables);\n\n try {\n switch (block.type) {\n case \"visit\": {\n // params: url, waitUntil (load/domcontentloaded/networkidle)\n const url = resolve(p.url);\n await page.goto(url, {\n waitUntil: p.waitUntil || \"domcontentloaded\",\n timeout: p.timeout || 30000\n });\n const finalUrl = page.url();\n if (p.saveAs) ctx.variables[p.saveAs] = finalUrl;\n return { success: true, output: finalUrl };\n }\n\n case \"go_back\": {\n await page.goBack({ waitUntil: p.waitUntil || \"domcontentloaded\" });\n return { success: true, output: page.url() };\n }\n\n case \"go_forward\": {\n await page.goForward({ waitUntil: p.waitUntil || \"domcontentloaded\" });\n return { success: true, output: page.url() };\n }\n\n case \"reload_page\": {\n await page.reload({ waitUntil: p.waitUntil || \"domcontentloaded\" });\n return { success: true, output: page.url() };\n }\n\n default:\n return { success: false, error: `Unknown navigate block: ${block.type}` };\n }\n } catch (err: any) {\n return { success: false, error: err.message };\n }\n}\n",[],[224,234],"e72fd9e0-2052-11f1-92f5-42dde27851f2","interact.ts","9ac5f360-204c-11f1-9400-42dde27851f2",27,["D",1773567586314],"// ============================================================\n// INTERACT BLOCKS v2 — với retry, robust selectors\n// ============================================================\n\nimport type { Block, FlowContext, BlockResult } from \"../types.ts\";\n\nfunction resolvePlaceholders(value: unknown, variables: Record): any {\n if (typeof value !== \"string\") return value;\n return value.replace(/\\{\\{(\\w+)\\}\\}/g, (_, key) => variables[key] ?? `{{${key}}}`);\n}\n\n// ─── withRetry cho block-level ────────────────────────────\nasync function withRetry(\n fn: () => Promise,\n maxAttempts: number,\n label: string\n): Promise {\n let lastErr: Error = new Error(\"unknown\");\n for (let i = 1; i <= maxAttempts; i++) {\n try {\n return await fn();\n } catch (e: any) {\n lastErr = e;\n if (i < maxAttempts) {\n const delay = Math.min(500 * Math.pow(2, i - 1), 4000); // 500ms → 1s → 2s → 4s\n console.warn(`[RETRY][${label}] attempt ${i}/${maxAttempts}: ${e.message}. Wait ${delay}ms`);\n await new Promise(r => setTimeout(r, delay));\n }\n }\n }\n throw lastErr;\n}\n\nexport async function executeInteractBlock(\n block: Block,\n ctx: FlowContext\n): Promise {\n const page = ctx.tabs.get(ctx.activeTabId);\n if (!page) return { success: false, error: \"No active page/tab\" };\n\n const p = block.params ?? {};\n const resolve = (v: unknown) => resolvePlaceholders(v, ctx.variables);\n const retries: number = p.retries ?? 2; // default 2 lần retry\n const actionTimeout: number = p.timeout ?? 15_000; // default 15s\n\n try {\n switch (block.type) {\n\n // ── click ──────────────────────────────────────────\n case \"click\": {\n const selector: string = resolve(p.selector);\n const button: string = p.button ?? \"left\";\n const clickCount: number = p.clickCount ?? 1;\n const waitNav: boolean = p.waitNavigation ?? false;\n\n await withRetry(async () => {\n await page.waitForSelector(selector, {\n timeout: actionTimeout,\n state: \"visible\",\n });\n await page.click(selector, { button, clickCount, timeout: actionTimeout });\n }, retries + 1, `click:${selector}`);\n\n // Chờ navigation nếu yêu cầu (ví dụ click submit form)\n if (waitNav) {\n await page.waitForLoadState(\"domcontentloaded\", { timeout: 30_000 });\n }\n if (p.waitAfter) await new Promise(r => setTimeout(r, p.waitAfter));\n\n return { success: true, output: `Clicked: ${selector}` };\n }\n\n // ── type_text ──────────────────────────────────────\n case \"type_text\": {\n const selector: string = resolve(p.selector);\n const text: string = String(resolve(p.text) ?? \"\");\n const delay: number = p.delay ?? 0;\n const clearFirst: boolean = p.clearFirst ?? true; // default clear\n\n await withRetry(async () => {\n await page.waitForSelector(selector, {\n timeout: actionTimeout,\n state: \"visible\",\n });\n if (clearFirst) {\n // fill() nhanh và reliable hơn triple-click\n await page.fill(selector, \"\", { timeout: actionTimeout });\n }\n if (delay > 0) {\n // type() dùng khi cần simulate key-by-key\n await page.type(selector, text, { delay });\n } else {\n // fill() dùng khi không cần delay — nhanh hơn 10x\n await page.fill(selector, text, { timeout: actionTimeout });\n }\n }, retries + 1, `type_text:${selector}`);\n\n return { success: true, output: `Typed \"${text}\" into ${selector}` };\n }\n\n // ── press_key ─────────────────────────────────────\n case \"press_key\": {\n const key: string = resolve(p.key);\n if (p.selector) {\n await page.waitForSelector(resolve(p.selector), {\n timeout: actionTimeout, state: \"visible\",\n });\n await page.press(resolve(p.selector), key);\n } else {\n await page.keyboard.press(key);\n }\n if (p.waitAfter) await new Promise(r => setTimeout(r, p.waitAfter));\n return { success: true, output: `Pressed: ${key}` };\n }\n\n // ── scroll ────────────────────────────────────────\n case \"scroll\": {\n if (p.selector) {\n const sel: string = resolve(p.selector);\n await page.waitForSelector(sel, { timeout: actionTimeout });\n await page.evaluate(\n ([s, d]: [string, number]) => {\n const el = document.querySelector(s);\n if (el) el.scrollBy(0, d);\n },\n [sel, p.distance ?? 300] as [string, number]\n );\n } else {\n await page.evaluate(\n ([x, y]: [number, number]) => window.scrollBy(x, y),\n [p.x ?? 0, p.y ?? 300] as [number, number]\n );\n }\n return { success: true, output: \"Scrolled\" };\n }\n\n // ── hover ─────────────────────────────────────────\n case \"hover\": {\n const selector: string = resolve(p.selector);\n await withRetry(async () => {\n await page.waitForSelector(selector, {\n timeout: actionTimeout, state: \"visible\",\n });\n await page.hover(selector, { timeout: actionTimeout });\n }, retries + 1, `hover:${selector}`);\n return { success: true, output: `Hovered: ${selector}` };\n }\n\n // ── select_option ─────────────────────────────────\n case \"select_option\": {\n const selector: string = resolve(p.selector);\n const value: string = resolve(p.value);\n await page.waitForSelector(selector, { timeout: actionTimeout });\n if (p.byLabel) {\n await page.selectOption(selector, { label: value });\n } else if (p.byIndex !== undefined) {\n await page.selectOption(selector, { index: Number(p.byIndex) });\n } else {\n await page.selectOption(selector, { value });\n }\n return { success: true, output: `Selected: ${value}` };\n }\n\n // ── set_date_input ────────────────────────────────\n case \"set_date_input\": {\n const selector: string = resolve(p.selector);\n const date: string = resolve(p.date);\n await page.waitForSelector(selector, { timeout: actionTimeout });\n await page.fill(selector, date, { timeout: actionTimeout });\n return { success: true, output: `Set date: ${date}` };\n }\n\n // ── upload_file ───────────────────────────────────\n case \"upload_file\": {\n const selector: string = resolve(p.selector);\n await page.waitForSelector(selector, { timeout: actionTimeout });\n if (p.filePath) {\n await page.setInputFiles(selector, resolve(p.filePath));\n } else if (p.fileUrl) {\n // Download file về /tmp rồi upload\n const url: string = resolve(p.fileUrl);\n const res = await fetch(url);\n const buf = await res.arrayBuffer();\n const fileName = url.split(\"/\").pop() ?? \"file\";\n const tmpPath = `/tmp/${fileName}`;\n // Dùng Deno.writeFile nếu có, fallback setInputFiles với buffer\n try {\n await Deno.writeFile(tmpPath, new Uint8Array(buf));\n await page.setInputFiles(selector, tmpPath);\n } catch {\n // Fallback: dùng Playwright buffer API\n await page.setInputFiles(selector, {\n name: fileName,\n mimeType: \"application/octet-stream\",\n buffer: Buffer.from(buf),\n });\n }\n }\n return { success: true, output: `Uploaded to: ${selector}` };\n }\n\n // ── handle_dialog ─────────────────────────────────\n case \"handle_dialog\": {\n const action: string = p.action ?? \"accept\";\n const promptText: string = resolve(p.promptText ?? \"\");\n page.once(\"dialog\", async (dialog: any) => {\n if (action === \"accept\") {\n await dialog.accept(promptText);\n } else {\n await dialog.dismiss();\n }\n });\n return { success: true, output: `Dialog handler registered: ${action}` };\n }\n\n default:\n return { success: false, error: `Unknown interact block: ${block.type}` };\n }\n } catch (err: any) {\n return { success: false, error: err.message };\n }\n}\n",[],[224,242],"a4c69a68-204c-11f1-9c7e-42dde27851f2","extract.ts","a4c69b30-204c-11f1-9c7e-42dde27851f2",3,["D",1773564897920],"// ============================================================\n// EXTRACT BLOCKS - Trích xuất dữ liệu từ trang web\n// ============================================================\n\nimport type { Block, FlowContext, BlockResult } from \"../types.ts\";\n\nfunction resolvePlaceholders(value: any, variables: Record): any {\n if (typeof value !== \"string\") return value;\n return value.replace(/\\{\\{(\\w+)\\}\\}/g, (_, key) => variables[key] ?? `{{${key}}}`);\n}\n\nexport async function executeExtractBlock(\n block: Block,\n ctx: FlowContext\n): Promise {\n const page = ctx.tabs.get(ctx.activeTabId);\n if (!page) return { success: false, error: \"No active page/tab\" };\n\n const p = block.params;\n const resolve = (v: any) => resolvePlaceholders(v, ctx.variables);\n\n try {\n switch (block.type) {\n case \"get_element_text\": {\n // params: selector, saveAs (variable name), multiple (boolean)\n const selector = resolve(p.selector);\n await page.waitForSelector(selector, { timeout: p.timeout || 10000 });\n let text: string | string[];\n if (p.multiple) {\n text = await page.$$eval(selector, (els: Element[]) =>\n els.map(el => el.textContent?.trim() || \"\")\n );\n } else {\n text = await page.$eval(selector, (el: Element) => el.textContent?.trim() || \"\");\n }\n if (p.saveAs) ctx.variables[p.saveAs] = text;\n return { success: true, output: text };\n }\n\n case \"get_link_url\": {\n // params: selector, saveAs\n const selector = resolve(p.selector);\n await page.waitForSelector(selector, { timeout: p.timeout || 10000 });\n const url = await page.$eval(selector, (el: Element) =>\n (el as HTMLAnchorElement).href || el.getAttribute(\"href\") || \"\"\n );\n if (p.saveAs) ctx.variables[p.saveAs] = url;\n return { success: true, output: url };\n }\n\n case \"get_page_url\": {\n // params: saveAs\n const url = page.url();\n if (p.saveAs) ctx.variables[p.saveAs] = url;\n return { success: true, output: url };\n }\n\n case \"get_element_attribute\": {\n // params: selector, attribute, saveAs\n const selector = resolve(p.selector);\n const attribute = resolve(p.attribute);\n await page.waitForSelector(selector, { timeout: p.timeout || 10000 });\n const value = await page.getAttribute(selector, attribute);\n if (p.saveAs) ctx.variables[p.saveAs] = value;\n return { success: true, output: value };\n }\n\n case \"get_element_html\": {\n // params: selector, saveAs, outer (boolean - outerHTML vs innerHTML)\n const selector = resolve(p.selector);\n await page.waitForSelector(selector, { timeout: p.timeout || 10000 });\n const html = await page.$eval(selector, (el: Element, outer: boolean) =>\n outer ? el.outerHTML : el.innerHTML\n , p.outer || false);\n if (p.saveAs) ctx.variables[p.saveAs] = html;\n return { success: true, output: html };\n }\n\n case \"get_clipboard\": {\n // params: saveAs\n const text = await page.evaluate(() => navigator.clipboard.readText());\n if (p.saveAs) ctx.variables[p.saveAs] = text;\n return { success: true, output: text };\n }\n\n case \"save_file\": {\n // params: url (hoặc selector), filename, saveAs (path variable)\n const url = resolve(p.url);\n const response = await page.evaluate(async (fileUrl: string) => {\n const res = await fetch(fileUrl);\n const blob = await res.blob();\n return { size: blob.size, type: blob.type };\n }, url);\n if (p.saveAs) ctx.variables[p.saveAs] = url;\n return { success: true, output: { url, ...response } };\n }\n\n case \"take_screenshot\": {\n // params: saveAs (variable name for base64), selector (optional - screenshot element)\n let screenshotBuffer: Buffer;\n if (p.selector) {\n const element = await page.$(resolve(p.selector));\n screenshotBuffer = await element?.screenshot({ type: \"png\" });\n } else {\n screenshotBuffer = await page.screenshot({\n type: \"png\",\n fullPage: p.fullPage || false\n });\n }\n const base64 = Buffer.from(screenshotBuffer).toString(\"base64\");\n const dataUrl = `data:image/png;base64,${base64}`;\n if (p.saveAs) ctx.variables[p.saveAs] = dataUrl;\n return { success: true, output: dataUrl };\n }\n\n case \"generate_pdf\": {\n // params: saveAs, format, margin\n const pdfBuffer = await page.pdf({\n format: p.format || \"A4\",\n margin: p.margin || { top: \"1cm\", bottom: \"1cm\", left: \"1cm\", right: \"1cm\" },\n printBackground: p.printBackground !== false\n });\n const base64 = Buffer.from(pdfBuffer).toString(\"base64\");\n const dataUrl = `data:application/pdf;base64,${base64}`;\n if (p.saveAs) ctx.variables[p.saveAs] = dataUrl;\n return { success: true, output: dataUrl };\n }\n\n default:\n return { success: false, error: `Unknown extract block: ${block.type}` };\n }\n } catch (err: any) {\n return { success: false, error: err.message };\n }\n}\n",[],[224,250],"0527e780-2053-11f1-92a6-42dde27851f2","controlflow.ts","bd179216-204c-11f1-bf0b-42dde27851f2",28,["D",1773567636596],"// ============================================================\n// CONTROL FLOW BLOCKS v2 — robust loop, while, if/else\n// ============================================================\n\nimport type { Block, FlowContext, BlockResult, LoopFrame } from \"../types.ts\";\n\nfunction resolvePlaceholders(value: unknown, variables: Record): any {\n if (typeof value !== \"string\") return value;\n return value.replace(/\\{\\{(\\w+)\\}\\}/g, (_, key) => variables[key] ?? `{{${key}}}`);\n}\n\n// ─── Safe condition evaluator ────────────────────────────\n// Chỉ cho phép biến, operators, literals — KHÔNG eval tự do\nfunction evaluateCondition(condition: string, variables: Record): boolean {\n try {\n const resolved = resolvePlaceholders(condition, variables);\n // Inject variables vào scope an toàn\n const keys = Object.keys(variables);\n const vals = Object.values(variables);\n const fn = new Function(...keys, `\"use strict\"; return !!(${resolved});`);\n return Boolean(fn(...vals));\n } catch {\n return false;\n }\n}\n\n// ─── Helper: tìm param từ block bắt đầu loop ────────────\nfunction getLoopParam(blocks: Block[], startIndex: number, param: string): string | undefined {\n return blocks[startIndex]?.params?.[param] as string | undefined;\n}\n\nexport async function executeControlFlowBlock(\n block: Block,\n ctx: FlowContext,\n blockIndex: number,\n allBlocks: Block[]\n): Promise {\n const p = block.params ?? {};\n const resolve = (v: unknown) => resolvePlaceholders(v, ctx.variables);\n const page = ctx.tabs.get(ctx.activeTabId);\n\n try {\n switch (block.type) {\n\n // ── loop (count-based) ────────────────────────────\n case \"loop\": {\n const count = Math.min(parseInt(String(resolve(p.count))) || 1, p.maxIterations ?? 10_000);\n const itemVar: string = p.itemVar ?? \"\";\n const frame: LoopFrame = {\n type: \"loop\",\n startIndex: blockIndex,\n currentIteration: 0,\n maxIterations: count,\n };\n ctx.loopStack.push(frame);\n if (itemVar) ctx.variables[itemVar] = 0;\n return { success: true, output: `Loop x${count} started` };\n }\n\n // ── loop_elements (DOM selector) ──────────────────\n case \"loop_elements\": {\n if (!page) return { success: false, error: \"No active page for loop_elements\" };\n const selector: string = resolve(p.selector);\n const elements = await page.$$(selector);\n const frame: LoopFrame = {\n type: \"loop_elements\",\n startIndex: blockIndex,\n currentIteration: 0,\n maxIterations: elements.length,\n items: elements,\n };\n ctx.loopStack.push(frame);\n if (p.itemVar) ctx.variables[p.itemVar] = 0;\n if (p.countVar) ctx.variables[p.countVar] = elements.length;\n return { success: true, output: `Loop elements: ${elements.length} found` };\n }\n\n // ── loop_list_items (từ variable array) ──────────\n case \"loop_list_items\": {\n const list: unknown[] = (ctx.variables[p.listVar] as unknown[]) ?? [];\n if (list.length === 0) {\n // Empty list → skip toàn bộ loop body\n return { success: true, output: \"Loop list: empty, skipping\", skipToEnd: true };\n }\n const frame: LoopFrame = {\n type: \"loop_list_items\",\n startIndex: blockIndex,\n currentIteration: 0,\n maxIterations: list.length,\n items: list,\n currentItem: list[0],\n };\n ctx.loopStack.push(frame);\n if (p.itemVar) ctx.variables[p.itemVar] = list[0];\n if (p.indexVar) ctx.variables[p.indexVar] = 0;\n return { success: true, output: `Loop list: ${list.length} items` };\n }\n\n // ── loop_pages (pagination) ───────────────────────\n case \"loop_pages\": {\n const frame: LoopFrame = {\n type: \"loop_pages\",\n startIndex: blockIndex,\n currentIteration: 0,\n maxIterations: parseInt(String(p.maxPages)) || 100,\n };\n ctx.loopStack.push(frame);\n if (p.pageVar) ctx.variables[p.pageVar] = 1;\n return { success: true, output: \"Loop pages started\" };\n }\n\n // ── if ────────────────────────────────────────────\n case \"if\": {\n let result: boolean;\n if (p.condition) {\n result = evaluateCondition(resolve(p.condition) as string, ctx.variables);\n } else {\n // Structured comparison: variable op value\n const varValue = ctx.variables[p.variable];\n const compareValue = resolve(p.value);\n switch (p.operator) {\n case \"==\": result = varValue == compareValue; break;\n case \"!=\": result = varValue != compareValue; break;\n case \">\": result = Number(varValue) > Number(compareValue); break;\n case \"<\": result = Number(varValue) < Number(compareValue); break;\n case \">=\": result = Number(varValue) >= Number(compareValue); break;\n case \"<=\": result = Number(varValue) <= Number(compareValue); break;\n case \"contains\": result = String(varValue).includes(String(compareValue)); break;\n case \"not_contains\":result = !String(varValue).includes(String(compareValue)); break;\n case \"is_empty\": result = varValue === undefined || varValue === null || varValue === \"\"; break;\n case \"is_not_empty\":result = varValue !== undefined && varValue !== null && varValue !== \"\"; break;\n case \"starts_with\": result = String(varValue).startsWith(String(compareValue)); break;\n case \"ends_with\": result = String(varValue).endsWith(String(compareValue)); break;\n default: result = false;\n }\n }\n // Lưu kết quả để else block dùng\n ctx.variables[\"__if_result__\"] = result;\n // Nếu false → skip toàn bộ if-body (đến else hoặc end)\n return { success: true, output: result, skipToEnd: !result };\n }\n\n // ── else ──────────────────────────────────────────\n case \"else\": {\n // Nếu if trước là true → skip else-body\n const ifResult = ctx.variables[\"__if_result__\"];\n return { success: true, skipToEnd: !!ifResult };\n }\n\n // ── while ─────────────────────────────────────────\n case \"while\": {\n const condition: string = resolve(p.condition) as string;\n const maxIter: number = p.maxIterations ?? 1_000;\n const totalTimeoutMs: number = (p.timeoutSeconds ?? 300) * 1000; // default 5 phút\n\n // Kiểm tra condition lần đầu\n const shouldRun = evaluateCondition(condition, ctx.variables);\n if (!shouldRun) {\n return { success: true, output: \"While: condition false, skipping\", skipToEnd: true };\n }\n\n // Tìm frame hiện có (nếu đây là lần lặp tiếp theo của cùng while)\n const existingFrame = ctx.loopStack[ctx.loopStack.length - 1];\n const isReEntry = existingFrame?.type === \"while\" &&\n existingFrame?.startIndex === blockIndex;\n\n if (!isReEntry) {\n // Lần đầu vào while → tạo frame mới\n const frame: LoopFrame = {\n type: \"while\",\n startIndex: blockIndex,\n currentIteration: 0,\n maxIterations: maxIter,\n condition: p.condition,\n startedAt: Date.now(),\n };\n ctx.loopStack.push(frame);\n } else {\n // Đã có frame → chỉ tăng counter (handled in end block)\n }\n\n return { success: true, output: `While: condition true` };\n }\n\n // ── end ───────────────────────────────────────────\n case \"end\": {\n const frame = ctx.loopStack[ctx.loopStack.length - 1];\n if (!frame) {\n // end ngoài loop/if → no-op\n return { success: true, output: \"End (no frame)\" };\n }\n\n // ── end của if/else ──\n if ((frame as any).isIf) {\n ctx.loopStack.pop();\n return { success: true };\n }\n\n frame.currentIteration++;\n\n // ── end của loop (count-based) ────────────────\n if (frame.type === \"loop\") {\n if (frame.currentIteration < (frame.maxIterations ?? 0)) {\n // Cập nhật itemVar từ loop block (không phải end block!)\n const itemVar = getLoopParam(allBlocks, frame.startIndex, \"itemVar\");\n if (itemVar) ctx.variables[itemVar] = frame.currentIteration;\n return { success: true, jumpToIndex: frame.startIndex + 1 };\n }\n ctx.loopStack.pop();\n return { success: true, output: `Loop done: ${frame.currentIteration} iterations` };\n }\n\n // ── end của loop_elements ──────────────────────\n if (frame.type === \"loop_elements\") {\n if (frame.currentIteration < (frame.maxIterations ?? 0)) {\n const itemVar = getLoopParam(allBlocks, frame.startIndex, \"itemVar\");\n if (itemVar) ctx.variables[itemVar] = frame.currentIteration;\n return { success: true, jumpToIndex: frame.startIndex + 1 };\n }\n ctx.loopStack.pop();\n return { success: true, output: \"Loop elements done\" };\n }\n\n // ── end của loop_list_items ────────────────────\n if (frame.type === \"loop_list_items\") {\n if (frame.currentIteration < (frame.maxIterations ?? 0)) {\n const items = frame.items ?? [];\n const itemVar = getLoopParam(allBlocks, frame.startIndex, \"itemVar\");\n const indexVar = getLoopParam(allBlocks, frame.startIndex, \"indexVar\");\n if (itemVar) ctx.variables[itemVar] = items[frame.currentIteration];\n if (indexVar) ctx.variables[indexVar] = frame.currentIteration;\n return { success: true, jumpToIndex: frame.startIndex + 1 };\n }\n ctx.loopStack.pop();\n return { success: true, output: \"Loop list done\" };\n }\n\n // ── end của loop_pages ────────────────────────\n if (frame.type === \"loop_pages\") {\n const nextSelector: string = getLoopParam(allBlocks, frame.startIndex, \"nextSelector\") ?? \"\";\n if (nextSelector && page && frame.currentIteration < (frame.maxIterations ?? 100)) {\n try {\n const nextBtn = await page.$(nextSelector);\n if (nextBtn) {\n const isDisabled: boolean = await page.$eval(\n nextSelector,\n (el: Element) => {\n const btn = el as HTMLButtonElement;\n return btn.disabled || el.classList.contains(\"disabled\") ||\n el.getAttribute(\"aria-disabled\") === \"true\";\n }\n );\n if (!isDisabled) {\n await page.click(nextSelector);\n await page.waitForLoadState(\"domcontentloaded\");\n const pageVar = getLoopParam(allBlocks, frame.startIndex, \"pageVar\");\n if (pageVar) ctx.variables[pageVar] = frame.currentIteration + 2;\n return { success: true, jumpToIndex: frame.startIndex + 1 };\n }\n }\n } catch {\n // Next button không tìm thấy → kết thúc\n }\n }\n ctx.loopStack.pop();\n return { success: true, output: \"Loop pages done\" };\n }\n\n // ── end của while ──────────────────────────────\n if (frame.type === \"while\") {\n // Kiểm tra giới hạn\n if (frame.currentIteration >= (frame.maxIterations ?? 1_000)) {\n console.warn(`[WHILE] maxIterations (${frame.maxIterations}) reached, breaking`);\n ctx.loopStack.pop();\n return { success: true, output: \"While: maxIterations reached\" };\n }\n\n // Kiểm tra timeout\n const elapsed = Date.now() - ((frame as any).startedAt ?? Date.now());\n const timeoutMs = ((allBlocks[frame.startIndex]?.params?.timeoutSeconds ?? 300) * 1000);\n if (elapsed > timeoutMs) {\n console.warn(`[WHILE] timeout (${timeoutMs}ms) reached`);\n ctx.loopStack.pop();\n return { success: true, output: \"While: timeout reached\" };\n }\n\n // Re-evaluate condition\n const condition = frame.condition ?? \"\";\n const shouldContinue = evaluateCondition(\n resolvePlaceholders(condition, ctx.variables) as string,\n ctx.variables\n );\n if (shouldContinue) {\n return { success: true, jumpToIndex: frame.startIndex + 1 };\n }\n ctx.loopStack.pop();\n return { success: true, output: `While done: ${frame.currentIteration} iterations` };\n }\n\n ctx.loopStack.pop();\n return { success: true };\n }\n\n // ── break ─────────────────────────────────────────\n case \"break\": {\n // Pop frame hiện tại (nếu có)\n if (ctx.loopStack.length > 0) {\n ctx.loopStack.pop();\n }\n ctx.shouldBreak = true;\n return { success: true, output: \"Break\" };\n }\n\n default:\n return { success: false, error: `Unknown control flow: ${block.type}` };\n }\n } catch (err: any) {\n return { success: false, error: err.message };\n }\n}\n",[],[224,258],"9ac61dae-204c-11f1-9400-42dde27851f2",["D",1773564881135],"directory",[167,168,169,170,171,172],[224],["D",1773564845585],["D",1789528252206],{"_11":12,"_125":121},{"_11":12,"_120":67,"_68":121,"_30":-5,"_122":123,"_124":24},{"_38":111,"_13":16,"_32":35,"_112":71,"_113":-5,"_114":-5,"_115":-5,"_116":-5,"_117":-5,"_118":14,"_119":12},"ctx",{"_52":-5,"_144":308,"_309":310,"_311":312,"_313":24,"_314":24,"_315":24,"_316":84,"_317":-5,"_318":-7,"_319":-7,"_320":26,"_321":24,"_322":24,"_323":-5,"_324":24,"_325":24,"_326":24,"_327":-5},"ENV",{"_279":280,"_281":282,"_283":16,"_284":285,"_286":287,"_288":289,"_290":291,"_292":293,"_294":295,"_296":297,"_298":299,"_300":301,"_302":303,"_304":305,"_306":307},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","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"]

🔑 API Keys

🌐 API Endpoint

📦 Block Stats

ℹ️ About

➕ Add Block

📥 Import Flow JSON

History · ui.html