[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_250":251,"_252":253},"routes/_app.x.$handle.$name",{"_103":102,"_37":48,"_112":93,"_32":113,"_13":14,"_114":-5,"_11":115,"_116":117,"_118":119,"_120":121,"_122":123,"_26":-5,"_124":-5,"_125":-5,"_126":30,"_127":128,"_129":30,"_130":-5,"_131":-5,"_132":133},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_46":47,"_37":48,"_41":49,"_50":-5,"_51":30,"_52":53,"_54":53,"_55":56,"_57":-5,"_19":58,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":70,"_71":72,"_73":74,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":86,"_87":88,"_89":90,"_91":30},"version",9,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","29ffbb12-2cb8-4062-b9f0-bebc6be59cf9","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":33,"_38":26,"_39":40,"_41":42,"_43":14,"_44":45,"_29":30},"previous","deleted",false,"deletedHere","path","storage.ts","latestPath","fileId","fe6dfab6-204c-11f1-8e02-42dde27851f2","name","fileType","content","// ============================================================\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\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 row = result.rows[0];\n return {\n ...row,\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 result.rows;\n}\n","createdAt",["D",1773565048336],"branchVersion","branchId","859495f0-204c-11f1-94bd-42dde27851f2","id","85943de4-204c-11f1-94bd-42dde27851f2","browserflow-engine",["D",1773564845585],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Browser automation engine giống Browserflow, chạy trên Kernel.sh","imageUrl","019ced01-90af-7019-a349-1b32c2e46191","pinnedFileId","1a923ef0-204d-11f1-a860-42dde27851f2","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019ced04-6266-748c-a6bb-b70a7446d59e","tursoName","85943de4204c11f194bd42dde27851f2","tursoHostname","85943de4204c11f194bd42dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789528252206],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_103":102,"_111":107},"org",{"_103":102,"_104":105,"_106":107,"_19":-5,"_108":109,"_110":30},"branch",{"_13":92,"_37":93,"_46":45,"_94":47,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":48,"_101":102},"isOwned",39,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","minhmmo","handle","displayName","adminh","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/0cef36b0-8080-4c50-5206-197543f8c300/square512?exp=1789574399&sig=7350fa5c42e2b1c3d0ffd5faed0361074de4c15b271fbd8afbd83851b32611c2","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_46":47,"_37":48,"_41":245,"_50":-5,"_51":30,"_52":53,"_54":53,"_55":56,"_57":-5,"_19":58,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":70,"_71":72,"_73":246,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":247,"_87":248,"_89":249,"_91":30},"tree",[175,182,183,184],"files",[175,176,177,178,179,180,181,182,183,184],"counts",{"_165":66,"_166":142,"_167":66,"_168":169,"_170":171},"contents",[134,135,136,137],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_46":158,"_37":159,"_35":160,"_141":-5,"_44":45,"_43":161,"_143":62,"_41":162,"_13":66,"_38":163,"_39":-5,"_29":30,"_146":-5,"_32":164},{"_46":151,"_37":152,"_35":153,"_141":-5,"_44":45,"_43":154,"_143":30,"_41":155,"_13":66,"_38":26,"_39":156,"_29":30,"_146":-5,"_32":157},{"_46":148,"_37":33,"_35":36,"_141":-5,"_44":45,"_43":14,"_143":30,"_41":149,"_13":66,"_38":26,"_39":40,"_29":30,"_146":-5,"_32":150},{"_46":138,"_37":139,"_35":140,"_141":-5,"_44":45,"_43":142,"_143":30,"_41":144,"_13":66,"_38":26,"_39":145,"_29":30,"_146":-5,"_32":147},"8f080dd8-204c-11f1-9400-42dde27851f2","types.ts","8f080e96-204c-11f1-9400-42dde27851f2","parentId",1,"latest",["D",1773564861435],"// ============================================================\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;\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","label",[139],"fe6df9ee-204c-11f1-8e02-42dde27851f2",["D",1773565048336],[33],"f52e6ce2-204c-11f1-8e02-42dde27851f2","engine.ts","f52e6d8c-204c-11f1-8e02-42dde27851f2",8,["D",1773565032818],"// ============================================================\n// FLOW ENGINE - Trái tim của hệ thống, thực thi từng block\n// ============================================================\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// ─── Danh sách block theo nhóm ───────────────────────────\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// ─── 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 const logs: LogEntry[] = [];\n const log = (level: LogEntry[\"level\"], msg: string, blockId?: string, blockType?: string, data?: any) => {\n const entry: LogEntry = { timestamp: new Date().toISOString(), level, message: msg, blockId, blockType, data };\n logs.push(entry);\n console.log(`[${level.toUpperCase()}] [${blockType || \"engine\"}] ${msg}`);\n };\n\n // ─── Khởi tạo Kernel.sh browser ────────────────────────\n let browser: any;\n let kernelClient: any;\n let sessionId = \"\";\n\n try {\n log(\"info\", \"🚀 Khởi tạo Kernel.sh browser session...\");\n const Kernel = (await import(\"npm:@onkernel/sdk\")).default;\n const { chromium } = await import(\"npm:playwright-core\");\n\n kernelClient = new Kernel({ apiKey: kernelApiKey });\n const kernelBrowser = await kernelClient.browsers.create({\n invocation_type: \"persistent\",\n });\n sessionId = kernelBrowser.session_id;\n log(\"info\", `✅ Kernel session created: ${sessionId}`);\n\n browser = await chromium.connectOverCDP(kernelBrowser.cdp_ws_url);\n log(\"info\", \"✅ Playwright connected to Kernel browser\");\n } catch (err: any) {\n log(\"error\", `❌ Failed to connect to Kernel: ${err.message}`);\n return { success: false, variables: {}, logs, error: err.message };\n }\n\n // ─── Khởi tạo Context ────────────────────────────────────\n const mainPage = browser.contexts()[0]\n ? browser.contexts()[0].pages()[0] || await browser.contexts()[0].newPage()\n : await browser.newPage();\n\n const initialTabId = \"tab_main\";\n const tabs = new Map();\n tabs.set(initialTabId, mainPage);\n\n const ctx: 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 // ─── Thực thi từng block ─────────────────────────────────\n let blockIndex = 0;\n const blocks = flow.blocks;\n let success = true;\n let errorMessage = \"\";\n\n while (blockIndex < blocks.length) {\n const block = blocks[blockIndex];\n if (!block) { blockIndex++; continue; }\n\n // Bỏ qua comment\n if (block.type === \"comment\") {\n log(\"debug\", `💬 ${block.params?.text || \"\"}`, block.id, \"comment\");\n blockIndex++;\n continue;\n }\n\n log(\"info\", `▶️ Block [${blockIndex}] ${block.type}`, block.id, block.type, block.params);\n\n let result: BlockResult;\n\n try {\n if (INTERACT_BLOCKS.has(block.type)) {\n result = await executeInteractBlock(block, ctx);\n } else if (EXTRACT_BLOCKS.has(block.type)) {\n result = await executeExtractBlock(block, ctx);\n } else if (NAVIGATE_BLOCKS.has(block.type)) {\n result = await executeNavigateBlock(block, ctx);\n } else if (CONTROLFLOW_BLOCKS.has(block.type)) {\n result = await executeControlFlowBlock(block, ctx, blockIndex, blocks);\n } else if (SPREADSHEET_BLOCKS.has(block.type)) {\n result = await executeSpreadsheetBlock(block, ctx, blockIndex);\n } else if (block.type === \"run_flow\") {\n // Gọi sub-flow\n result = await runSubFlow(block, ctx, kernelApiKey, logs);\n } else {\n result = await executeUtilityBlock(block, ctx);\n }\n } catch (err: any) {\n result = { success: false, error: err.message };\n }\n\n // Xử lý kết quả\n if (!result.success) {\n const errMsg = `Block [${block.type}] failed: ${result.error}`;\n log(\"error\", errMsg, block.id, block.type);\n if (block.params?.continueOnError) {\n blockIndex++;\n continue;\n }\n success = false;\n errorMessage = errMsg;\n break;\n }\n\n if (result.output !== undefined) {\n log(\"debug\", `✅ Output: ${JSON.stringify(result.output).slice(0, 200)}`, block.id, block.type);\n }\n\n // Điều hướng index\n if (ctx.shouldBreak) {\n // Tìm block end tiếp theo và nhảy qua\n ctx.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 // ─── Dọn dẹp ────────────────────────────────────────────\n try {\n await browser.close();\n if (kernelClient && sessionId) {\n await kernelClient.browsers.deleteByID(sessionId);\n log(\"info\", \"🧹 Kernel session released\");\n }\n } catch (e: any) {\n log(\"warn\", `Cleanup warning: ${e.message}`);\n }\n\n return {\n success,\n variables: ctx.variables,\n logs,\n error: errorMessage || undefined,\n };\n}\n\n// ─── Helpers ────────────────────────────────────────────────\nfunction findNextEnd(blocks: Block[], fromIndex: number): number {\n let depth = 1;\n for (let i = fromIndex + 1; i < blocks.length; i++) {\n const t = blocks[i].type;\n if ([\"loop\", \"loop_elements\", \"loop_list_items\", \"loop_pages\",\n \"loop_spreadsheet_rows\", \"if\", \"while\"].includes(t)) depth++;\n if (t === \"end\") { depth--; if (depth === 0) return i; }\n }\n return blocks.length - 1;\n}\n\nfunction findNextEndOrElse(blocks: Block[], fromIndex: number): number {\n let depth = 1;\n for (let i = fromIndex + 1; i < blocks.length; i++) {\n const t = blocks[i].type;\n if ([\"loop\", \"loop_elements\", \"loop_list_items\", \"loop_pages\",\n \"loop_spreadsheet_rows\", \"if\", \"while\"].includes(t)) depth++;\n if (t === \"end\") { depth--; if (depth === 0) return i; }\n if (t === \"else\" && depth === 1) return i;\n }\n return blocks.length - 1;\n}\n\nasync function runSubFlow(\n block: Block,\n ctx: FlowContext,\n kernelApiKey: string,\n _logs: LogEntry[]\n): Promise {\n const flowId = 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",[152],"9ac61dae-204c-11f1-9400-42dde27851f2","blocks","10cec21b-bdeb-4c89-baf1-94f44f17e648",2,["D",1773564881135],"directory",[159],"pulls","branches","forks","envVars",{"_172":161,"_174":66},"connections",{"_172":66,"_173":66},"count","unfilledCount","emptyCount",{"_46":158,"_37":159,"_35":160,"_141":-5,"_44":45,"_43":161,"_143":62,"_41":242,"_13":66,"_38":163,"_39":-5,"_29":30,"_146":-5,"_186":243,"_32":244},{"_46":234,"_37":235,"_35":236,"_141":160,"_44":45,"_43":237,"_143":30,"_41":238,"_13":66,"_38":26,"_39":239,"_29":30,"_146":-5,"_186":240,"_32":241},{"_46":226,"_37":227,"_35":228,"_141":160,"_44":45,"_43":229,"_143":62,"_41":230,"_13":66,"_38":26,"_39":231,"_29":30,"_146":-5,"_186":232,"_32":233},{"_46":219,"_37":220,"_35":221,"_141":160,"_44":45,"_43":161,"_143":30,"_41":222,"_13":66,"_38":26,"_39":223,"_29":30,"_146":-5,"_186":224,"_32":225},{"_46":211,"_37":212,"_35":213,"_141":160,"_44":45,"_43":214,"_143":62,"_41":215,"_13":66,"_38":26,"_39":216,"_29":30,"_146":-5,"_186":217,"_32":218},{"_46":203,"_37":204,"_35":205,"_141":160,"_44":45,"_43":206,"_143":62,"_41":207,"_13":66,"_38":26,"_39":208,"_29":30,"_146":-5,"_186":209,"_32":210},{"_46":195,"_37":196,"_35":197,"_141":160,"_44":45,"_43":198,"_143":62,"_41":199,"_13":66,"_38":26,"_39":200,"_29":30,"_146":-5,"_186":201,"_32":202},{"_46":151,"_37":152,"_35":153,"_141":-5,"_44":45,"_43":154,"_143":30,"_41":192,"_13":66,"_38":26,"_39":156,"_29":30,"_146":-5,"_186":193,"_32":194},{"_46":148,"_37":33,"_35":36,"_141":-5,"_44":45,"_43":14,"_143":30,"_41":189,"_13":66,"_38":26,"_39":40,"_29":30,"_146":-5,"_186":190,"_32":191},{"_46":138,"_37":139,"_35":140,"_141":-5,"_44":45,"_43":142,"_143":30,"_41":185,"_13":66,"_38":26,"_39":145,"_29":30,"_146":-5,"_186":187,"_32":188},["D",1773564861435],"children",[],[139],["D",1773565048336],[],[33],["D",1773565032818],[],[152],"d17b8fbe-204c-11f1-bf0b-42dde27851f2","utilities.ts","d17b9086-204c-11f1-bf0b-42dde27851f2",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",[],[159,196],"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",[],[159,204],"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",[],[159,212],"9ac5f252-204c-11f1-9400-42dde27851f2","interact.ts","9ac5f360-204c-11f1-9400-42dde27851f2",["D",1773564881135],"// ============================================================\n// INTERACT BLOCKS - Tương tác với 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 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: any) => resolvePlaceholders(v, ctx.variables);\n\n try {\n switch (block.type) {\n case \"click\": {\n // params: selector, button (left/right/middle), clickCount, waitAfter\n const selector = resolve(p.selector);\n const button = p.button || \"left\";\n const clickCount = p.clickCount || 1;\n await page.waitForSelector(selector, { timeout: p.timeout || 10000 });\n await page.click(selector, { button, clickCount });\n if (p.waitAfter) await new Promise(r => setTimeout(r, p.waitAfter));\n return { success: true, output: `Clicked: ${selector}` };\n }\n\n case \"type_text\": {\n // params: selector, text, clearFirst, delay\n const selector = resolve(p.selector);\n const text = resolve(p.text);\n await page.waitForSelector(selector, { timeout: p.timeout || 10000 });\n if (p.clearFirst) {\n await page.click(selector, { clickCount: 3 });\n await page.keyboard.press(\"Backspace\");\n }\n await page.type(selector, text, { delay: p.delay || 0 });\n return { success: true, output: `Typed \"${text}\" into ${selector}` };\n }\n\n case \"press_key\": {\n // params: key (Enter, Tab, ArrowDown, Escape, etc.), selector (optional)\n const key = resolve(p.key);\n if (p.selector) {\n await page.focus(resolve(p.selector));\n }\n await page.keyboard.press(key);\n return { success: true, output: `Pressed key: ${key}` };\n }\n\n case \"scroll\": {\n // params: selector (optional), x, y, direction (up/down/left/right), distance\n if (p.selector) {\n const selector = resolve(p.selector);\n await page.evaluate((sel: string, dist: number) => {\n const el = document.querySelector(sel);\n if (el) el.scrollBy(0, dist);\n }, selector, p.distance || 300);\n } else {\n const x = p.x || 0;\n const y = p.y || 300;\n await page.evaluate((scrollX: number, scrollY: number) => {\n window.scrollBy(scrollX, scrollY);\n }, x, y);\n }\n return { success: true, output: \"Scrolled\" };\n }\n\n case \"hover\": {\n // params: selector\n const selector = resolve(p.selector);\n await page.waitForSelector(selector, { timeout: p.timeout || 10000 });\n await page.hover(selector);\n return { success: true, output: `Hovered: ${selector}` };\n }\n\n case \"select_option\": {\n // params: selector, value (hoặc label hoặc index)\n const selector = resolve(p.selector);\n const value = resolve(p.value);\n await page.waitForSelector(selector, { timeout: p.timeout || 10000 });\n if (p.byLabel) {\n await page.selectOption(selector, { label: value });\n } else if (p.byIndex !== undefined) {\n await page.selectOption(selector, { index: p.byIndex });\n } else {\n await page.selectOption(selector, { value });\n }\n return { success: true, output: `Selected option: ${value}` };\n }\n\n case \"set_date_input\": {\n // params: selector, date (YYYY-MM-DD format)\n const selector = resolve(p.selector);\n const date = resolve(p.date);\n await page.waitForSelector(selector, { timeout: p.timeout || 10000 });\n await page.fill(selector, date);\n return { success: true, output: `Set date: ${date}` };\n }\n\n case \"upload_file\": {\n // params: selector, filePath (hoặc fileUrl)\n const selector = resolve(p.selector);\n await page.waitForSelector(selector, { timeout: p.timeout || 10000 });\n if (p.filePath) {\n await page.setInputFiles(selector, resolve(p.filePath));\n }\n return { success: true, output: `Uploaded file to: ${selector}` };\n }\n\n case \"handle_dialog\": {\n // params: action (accept/dismiss), promptText (for prompt dialogs)\n const action = p.action || \"accept\";\n const promptText = 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 set: ${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",[],[159,220],"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",[],[159,227],"bd179162-204c-11f1-bf0b-42dde27851f2","controlflow.ts","bd179216-204c-11f1-bf0b-42dde27851f2",5,["D",1773564938713],"// ============================================================\n// CONTROL FLOW BLOCKS - Điều khiển luồng thực thi\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\nfunction evaluateCondition(condition: string, variables: Record): boolean {\n try {\n const resolved = resolvePlaceholders(condition, variables);\n // Safe eval với các operator cơ bản\n const fn = new Function(...Object.keys(variables), `return !!(${resolved})`);\n return fn(...Object.values(variables));\n } catch {\n return false;\n }\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: any) => resolvePlaceholders(v, ctx.variables);\n const page = ctx.tabs.get(ctx.activeTabId);\n\n try {\n switch (block.type) {\n case \"loop\": {\n // params: count, itemVar (tên biến lưu index hiện tại)\n const count = parseInt(resolve(p.count)) || 1;\n const frame: LoopFrame = {\n type: \"loop\",\n startIndex: blockIndex,\n currentIteration: 0,\n maxIterations: count,\n };\n ctx.loopStack.push(frame);\n if (p.itemVar) ctx.variables[p.itemVar] = 0;\n return { success: true, output: `Loop started: 0/${count}` };\n }\n\n case \"loop_elements\": {\n // params: selector, itemVar (tên biến lưu element index), countVar\n if (!page) return { success: false, error: \"No active page\" };\n const selector = 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} items` };\n }\n\n case \"loop_list_items\": {\n // params: listVar (tên biến chứa array), itemVar (tên biến cho từng item), indexVar\n const list = ctx.variables[p.listVar] || [];\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 case \"loop_pages\": {\n // params: nextSelector (selector của nút Next), maxPages, pageVar\n const frame: LoopFrame = {\n type: \"loop_pages\",\n startIndex: blockIndex,\n currentIteration: 0,\n maxIterations: parseInt(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 case \"if\": {\n // params: condition (expression), variable, operator, value\n let result: boolean;\n if (p.condition) {\n result = evaluateCondition(resolve(p.condition), ctx.variables);\n } else {\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 || varValue === \"\"; break;\n case \"is_not_empty\": result = !!varValue && varValue !== \"\"; break;\n default: result = false;\n }\n }\n ctx.variables[\"__if_result__\"] = result;\n return { success: true, output: result, skipToEnd: !result };\n }\n\n case \"else\": {\n // Nếu if_result là true, skip đến end\n const ifResult = ctx.variables[\"__if_result__\"];\n return { success: true, skipToEnd: !!ifResult };\n }\n\n case \"while\": {\n // params: condition\n const condition = resolve(p.condition);\n const shouldContinue = evaluateCondition(condition, ctx.variables);\n if (!shouldContinue) {\n return { success: true, output: \"While condition false, skipping\", skipToEnd: true };\n }\n const frame: LoopFrame = {\n type: \"while\",\n startIndex: blockIndex,\n currentIteration: 0,\n condition: p.condition,\n };\n ctx.loopStack.push(frame);\n return { success: true, output: \"While loop started\" };\n }\n\n case \"end\": {\n // Kết thúc loop hoặc if\n const frame = ctx.loopStack[ctx.loopStack.length - 1];\n if (!frame) return { success: true, output: \"End (no loop)\" };\n\n frame.currentIteration++;\n\n // Kiểm tra có tiếp tục loop không\n if (frame.type === \"loop\" || frame.type === \"loop_elements\" ||\n frame.type === \"loop_list_items\" || frame.type === \"loop_spreadsheet_rows\") {\n if (frame.currentIteration < (frame.maxIterations || 0)) {\n // Cập nhật biến vòng lặp\n if (block.params.itemVar) {\n ctx.variables[block.params.itemVar] = frame.currentIteration;\n }\n if (frame.items && frame.type === \"loop_list_items\") {\n const itemVarName = findLoopBlockParam(allBlocks, frame.startIndex, \"itemVar\");\n const indexVarName = findLoopBlockParam(allBlocks, frame.startIndex, \"indexVar\");\n if (itemVarName) ctx.variables[itemVarName] = frame.items[frame.currentIteration];\n if (indexVarName) ctx.variables[indexVarName] = frame.currentIteration;\n }\n return { success: true, jumpToIndex: frame.startIndex + 1 };\n } else {\n ctx.loopStack.pop();\n return { success: true, output: \"Loop completed\" };\n }\n }\n\n if (frame.type === \"loop_pages\") {\n const nextSelector = allBlocks[frame.startIndex]?.params?.nextSelector;\n if (nextSelector && page) {\n const nextBtn = await page.$(nextSelector);\n const isDisabled = nextBtn ? await page.$eval(nextSelector,\n (el: Element) => (el as HTMLButtonElement).disabled ||\n el.classList.contains(\"disabled\")\n ) : true;\n if (!isDisabled && frame.currentIteration < (frame.maxIterations || 100)) {\n await page.click(nextSelector);\n await page.waitForLoadState(\"domcontentloaded\");\n const pageVarName = findLoopBlockParam(allBlocks, frame.startIndex, \"pageVar\");\n if (pageVarName) ctx.variables[pageVarName] = frame.currentIteration + 2;\n return { success: true, jumpToIndex: frame.startIndex + 1 };\n }\n }\n ctx.loopStack.pop();\n return { success: true, output: \"Loop pages completed\" };\n }\n\n if (frame.type === \"while\") {\n const condition = frame.condition || \"\";\n const shouldContinue = evaluateCondition(resolvePlaceholders(condition, ctx.variables), ctx.variables);\n if (shouldContinue) {\n return { success: true, jumpToIndex: frame.startIndex + 1 };\n }\n ctx.loopStack.pop();\n return { success: true, output: \"While completed\" };\n }\n\n ctx.loopStack.pop();\n return { success: true };\n }\n\n case \"break\": {\n ctx.shouldBreak = true;\n ctx.loopStack.pop();\n return { success: true, skipToEnd: true };\n }\n\n default:\n return { success: false, error: `Unknown control flow block: ${block.type}` };\n }\n } catch (err: any) {\n return { success: false, error: err.message };\n }\n}\n\nfunction findLoopBlockParam(blocks: Block[], startIndex: number, param: string): string | undefined {\n return blocks[startIndex]?.params?.[param];\n}\n",[],[159,235],["D",1773564881135],[176,177,178,179,180,181],[159],["D",1773564845585],["D",1789528252206],{"_103":102,"_111":107},{"_103":102,"_104":105,"_106":107,"_19":-5,"_108":109,"_110":30},{"_13":92,"_37":93,"_46":45,"_94":47,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":48,"_101":102},"ctx",{"_85":-5,"_131":283,"_284":285,"_286":287,"_288":30,"_289":30,"_290":30,"_291":62,"_292":-5,"_293":-7,"_294":-7,"_295":66,"_296":30,"_297":30,"_298":-5,"_299":30,"_300":30,"_301":30,"_302":-5},"ENV",{"_254":255,"_256":257,"_258":93,"_259":260,"_261":262,"_263":264,"_265":266,"_267":268,"_269":270,"_271":272,"_273":274,"_275":276,"_277":278,"_279":280,"_281":282},"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"]

Diff · v9