[{"_1":2,"_181":-5,"_182":-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,"_177":178,"_179":180},"handle","minhmmo","name","browserflow-engine","path","storage.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":163,"_164":-5,"_165":149,"_166":167,"_168":118,"_105":169,"_147":170,"_171":159,"_172":173,"_174":20,"_175":-5,"_99":176},"b16bbcbc-2056-11f1-ac46-42dde27851f2","fileId","fe6dfab6-204c-11f1-8e02-42dde27851f2","parentId","branchId","branchVersion",34,"latest",["D",1773569214099],1,"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\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","deleted","label",[100],"permalink","https://www.val.town/x/minhmmo/browserflow-engine/code/storage.ts","extension","ts","actionData","errors"]