[{"_1":2,"_179":-5,"_180":-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,"_176":177,"_178":-5},"handle","minhmmo","name","browserflow-engine","path","main.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":100,"_162":116,"_163":-5,"_164":149,"_165":148,"_166":118,"_105":167,"_147":168,"_169":170,"_171":172,"_173":20,"_174":-5,"_99":175},"fbee8240-2058-11f1-bb20-42dde27851f2","fileId","parentId","branchId","branchVersion","latest",["D",1773570198098],11,"fileType","http","content","// ============================================================\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","deleted","label",[100],"permalink","https://www.val.town/x/minhmmo/browserflow-engine/code/main.ts","extension","actionData","errors"]