[{"_1":2,"_184":-5,"_185":-5},"loaderData",{"_3":4,"_93":94},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","7c5bc882bceb0a55efc9fc584fee6b89303eee47","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_68":69},"__internal_clerk_state",{"_70":71,"_72":47,"_73":74,"_75":74,"_76":20,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":20,"_92":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_83":20,"_19":20,"_84":74,"_85":86,"_87":74,"_88":47,"_89":20,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_95":96,"_97":98,"_99":100,"_101":102,"_159":160,"_180":181,"_182":183},"handle","minhmmo","name","browserflow-engine","path","blocks/controlflow.ts","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":112,"_113":-5,"_12":114,"_115":116,"_117":118,"_119":-5,"_120":-5,"_121":33,"_14":122,"_123":124,"_125":126,"_127":-5,"_128":129,"_130":129,"_131":132,"_133":132,"_134":132,"_135":129,"_136":129,"_23":137,"_140":141,"_145":146,"_158":20},"id","85943de4-204c-11f1-94bd-42dde27851f2","createdAt",["D",1773564845585],"deletedAt","legacyEnvVars","privacy","public","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","019ced04-6266-748c-a6bb-b70a7446d59e","tursoName","85943de4204c11f194bd42dde27851f2","tursoHostname","85943de4204c11f194bd42dde27851f2-val-town.aws-us-east-2.turso.io","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_138":139},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/0cef36b0-8080-4c50-5206-197543f8c300/square512","org",{"_95":96,"_142":139,"_12":-5,"_143":144},"avatar","tier","pro","branch",{"_147":148,"_97":45,"_103":149,"_150":104,"_151":-5,"_152":-5,"_153":-5,"_154":-5,"_155":-5,"_156":98,"_157":96},"version",39,"859495f0-204c-11f1-94bd-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":161,"_97":162,"_163":164,"_165":166,"_167":149,"_168":169,"_170":118,"_105":171,"_147":172,"_173":159,"_174":175,"_176":20,"_177":-5,"_99":178},"0527e780-2053-11f1-92a6-42dde27851f2","controlflow.ts","fileId","bd179216-204c-11f1-bf0b-42dde27851f2","parentId","10cec21b-bdeb-4c89-baf1-94f44f17e648","branchId","branchVersion",28,"latest",["D",1773567636596],1,"fileType","content","// ============================================================\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","deleted","label",[179,162],"blocks","permalink","https://www.val.town/x/minhmmo/browserflow-engine/code/blocks/controlflow.ts","extension","ts","actionData","errors"]