[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_113":114,"_115":116},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","kernel","name","jev-browser-use","path","sessions.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":32,"_62":-5,"_63":-5,"_64":65,"_66":67,"_68":69,"_70":71,"_72":73,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":85,"_86":87,"_88":89,"_90":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/kernel/jev-browser-use/code/sessions.ts","extension","id","f6b64b51-e52f-44a9-a065-975e7bae5671","fileId","979add00-b209-11f1-8f64-1607ee4eb77e","parentId","branchId","789b925f-1f04-4496-b61e-c55aa361585d","branchVersion",213,"latest",true,"createdAt",["D",1789605903517],"version",14,"fileType","script","content","/**\n * The registry of live browsers.\n *\n * A Kernel browser keeps running after the HTTP request that created it\n * returns, so \"which browsers exist\" can't live in the request that made one.\n * One row per session in SQLite, and the row is what `liveSessionCount()` —\n * and so the concurrency cap — counts. It's also what lets a later request\n * find a browser whose client walked away and delete it.\n *\n * Two limits live here, both about the browser rather than about requests:\n *\n * - `MAX_LIVE_SESSIONS` caps how many browsers run at once, matching\n * Kernel's Developer-tier ceiling of 5 concurrent browsers.\n * - `MAX_SESSION_SECONDS` caps one browser's life. Steps are what keep a\n * browser alive, so without a wall-clock cap a client that loops on\n * `/api/step` can hold one open indefinitely — `MAX_STEPS` bounds the work\n * a run does, not the time it takes.\n */\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n/**\n * Read a positive integer from the environment, or fall back.\n *\n * The fallback on a *bad* value matters more than the fallback on a missing\n * one: `Number(\"5 \")` is 5 but `Number(\"five\")` is NaN, and every comparison\n * against NaN is false — so a typo'd override would turn a cap into no cap at\n * all. Failing closed keeps the ceiling a ceiling.\n */\nfunction envCount(name: string, fallback: number): number {\n const raw = Deno.env.get(name)?.trim();\n if (!raw) return fallback;\n const n = Number(raw);\n return Number.isFinite(n) && n >= 1 ? Math.floor(n) : fallback;\n}\n\n/**\n * How many browsers this demo will run at once.\n *\n * Kernel's Developer tier allows 5 concurrent browsers, so 5 is the real\n * ceiling: above it the sixth `createBrowser` is refused by Kernel and the\n * caller sees Kernel's error rather than this guard's. Raise this only\n * alongside a Kernel plan that allows more.\n *\n * Override with MAX_LIVE_SESSIONS.\n */\nexport const MAX_LIVE_SESSIONS = envCount(\"MAX_LIVE_SESSIONS\", 5);\n\n/**\n * How long one browser may live. 180s is well past a full 12-step run (about a\n * minute), so it never binds a real run — it only stops a browser from\n * outliving the run that made it.\n */\nexport const MAX_SESSION_SECONDS = 180;\n\nexport type SessionStatus = \"live\" | \"done\" | \"stopped\" | \"failed\";\n\nexport type Session = {\n id: string;\n kernelId: string;\n task: string;\n startUrl: string;\n includeNavigation: boolean;\n startedAt: string;\n steps: number;\n status: SessionStatus;\n};\n\n/**\n * An earlier version of this table also carried `ip` and `charged_seconds`,\n * for a spend ledger that no longer exists. `CREATE TABLE IF NOT EXISTS`\n * leaves those columns in place on a database that already has them, and the\n * defaults on them keep inserts working — nothing reads or writes them now.\n */\nconst SCHEMA = `CREATE TABLE IF NOT EXISTS sessions (\n id TEXT PRIMARY KEY,\n kernel_id TEXT NOT NULL,\n task TEXT NOT NULL,\n start_url TEXT NOT NULL DEFAULT '',\n include_navigation INTEGER NOT NULL DEFAULT 1,\n started_at TEXT NOT NULL,\n steps INTEGER NOT NULL DEFAULT 0,\n status TEXT NOT NULL DEFAULT 'live'\n)`;\n\nlet schema: Promise | null = null;\n\nfunction init(): Promise {\n if (!schema) {\n schema = sqlite.execute(SCHEMA).then(async () => {\n const { rows } = await sqlite.execute(\"PRAGMA table_info(sessions)\");\n if (!rows.some((row) => row.name === \"include_navigation\")) {\n try {\n await sqlite.execute(\"ALTER TABLE sessions ADD COLUMN include_navigation INTEGER NOT NULL DEFAULT 1\");\n } catch (err) {\n // Another runtime may have completed this additive migration first.\n if (!String(err).includes(\"duplicate column name\")) throw err;\n }\n }\n }).catch((err) => {\n schema = null; // let the next request try again\n throw err;\n });\n }\n return schema;\n}\n\nfunction toSession(row: Record): Session {\n return {\n id: String(row.id),\n kernelId: String(row.kernel_id),\n task: String(row.task),\n startUrl: String(row.start_url ?? \"\"),\n includeNavigation: row.include_navigation == null || Number(row.include_navigation) !== 0,\n startedAt: String(row.started_at),\n steps: Number(row.steps ?? 0),\n status: String(row.status) as SessionStatus,\n };\n}\n\nexport async function createSession(\n kernelId: string,\n task: string,\n startUrl: string,\n includeNavigation = true,\n): Promise {\n await init();\n const session: Session = {\n id: crypto.randomUUID(),\n kernelId,\n task,\n startUrl,\n includeNavigation,\n startedAt: new Date().toISOString(),\n steps: 0,\n status: \"live\",\n };\n await sqlite.execute({\n sql: `INSERT INTO sessions\n (id, kernel_id, task, start_url, include_navigation, started_at, steps, status)\n VALUES (?, ?, ?, ?, ?, ?, 0, 'live')`,\n args: [\n session.id,\n session.kernelId,\n session.task,\n session.startUrl,\n session.includeNavigation ? 1 : 0,\n session.startedAt,\n ],\n });\n return session;\n}\n\nexport async function getSession(id: string): Promise {\n await init();\n const { rows } = await sqlite.execute({\n sql: \"SELECT * FROM sessions WHERE id = ?\",\n args: [id],\n });\n return rows[0] ? toSession(rows[0] as Record) : null;\n}\n\n/** Live browsers, for the concurrency guard. */\nexport async function liveSessionCount(): Promise {\n await init();\n const { rows } = await sqlite.execute(\n \"SELECT COUNT(*) AS n FROM sessions WHERE status = 'live'\",\n );\n return Number(rows[0]?.n ?? 0);\n}\n\nexport async function bumpSteps(id: string): Promise {\n await sqlite.execute({\n sql: \"UPDATE sessions SET steps = steps + 1 WHERE id = ?\",\n args: [id],\n });\n}\n\nexport async function closeSession(\n id: string,\n status: SessionStatus,\n): Promise {\n await sqlite.execute({\n sql: \"UPDATE sessions SET status = ? WHERE id = ?\",\n args: [status, id],\n });\n}\n\n/**\n * Close browsers whose clients walked away, and return their Kernel ids so the\n * caller can delete them.\n *\n * `/api/step` is what keeps a run moving, so a session nobody steps is a\n * browser nobody is driving: it sits there until Kernel's idle timeout deletes\n * it. Marking the row closed here is what stops the concurrency cap from\n * filling up with browsers that no longer have a client. There's no cron, so\n * the sweep is opportunistic — the next visitor's session creation runs it\n * before counting what's live.\n */\nexport async function sweepStaleSessions(\n maxAgeSeconds = MAX_SESSION_SECONDS,\n): Promise {\n await init();\n const cutoff = new Date(Date.now() - maxAgeSeconds * 1000).toISOString();\n const { rows } = await sqlite.execute({\n sql: \"SELECT * FROM sessions WHERE status = 'live' AND started_at < ?\",\n args: [cutoff],\n });\n\n const kernelIds: string[] = [];\n for (const row of rows) {\n const session = toSession(row as Record);\n await closeSession(session.id, \"stopped\");\n kernelIds.push(session.kernelId);\n }\n return kernelIds;\n}\n\n// Small per-run history, independent of client-provided action descriptions.\nconst HISTORY_SCHEMA = `CREATE TABLE IF NOT EXISTS run_history (\n session_id TEXT PRIMARY KEY,\n steps_json TEXT NOT NULL DEFAULT '[]'\n)`;\nlet historySchema: Promise | null = null;\n\nfunction initHistory(): Promise {\n return historySchema ??= sqlite.execute(HISTORY_SCHEMA).catch((err) => {\n historySchema = null;\n throw err;\n });\n}\n\nexport async function getHistory(sessionId: string): Promise {\n await initHistory();\n const { rows } = await sqlite.execute({\n sql: \"SELECT steps_json FROM run_history WHERE session_id = ?\",\n args: [sessionId],\n });\n return rows[0] ? JSON.parse(String(rows[0].steps_json)) : [];\n}\n\nexport async function saveHistory(\n sessionId: string,\n steps: import(\"./history.ts\").HistoryStep[],\n): Promise {\n await initHistory();\n await sqlite.execute({\n sql: \"INSERT INTO run_history (session_id, steps_json) VALUES (?, ?) ON CONFLICT(session_id) DO UPDATE SET steps_json = excluded.steps_json\",\n args: [sessionId, JSON.stringify(steps)],\n });\n}\n","deleted",false,"label",[14],"3c438ea3-80e8-4cac-9708-6511f055598d",["D",1789588833583],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","restricted","description","Describe a task; Jev decides each step in a KERNEL cloud browser","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/601425b5-d08c-486a-cae2-cbfbdf0cc801/square512?exp=1789611010&sig=9438ead247c1718f92d4690f61f0c7dea4cbc542db212d9a3dfaf0a22c80dbc5","userId","a0bf3b31-15a5-4d5c-880e-4b1e22c9bc18","pinnedFileId","01a0abce-8571-76e1-8061-dc657cf63b40","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","b2fd4880-5c2e-11f0-9801-5764bf98a432","tursoName","3c438ea380e84cac97086511f055598d","tursoHostname","3c438ea380e84cac97086511f055598d-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789590099209],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_112":108},"org",{"_9":10,"_105":106,"_107":108,"_57":-5,"_109":110,"_111":32},"branch",{"_35":91,"_11":92,"_22":28,"_93":45,"_94":95,"_96":97,"_98":50,"_99":100,"_101":102,"_103":12,"_104":10},"isOwned",280,"main","projectId","forkedBranchId","e9a8eeca-33f2-423b-8459-435fd862f66d","forkedBranchVersion",74,"forkedProjectPrivacy","forkedProjectId","c242175a-bb41-49a1-ae69-d9c2930a22f1","forkedProjectOrgId","e81e7335-6d4c-4764-a902-d0962bbfa9f7","projectName","userHandle","displayName","KERNEL","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/772b82b9-bcf2-4ee8-2b88-3bbabc7f9801/square512?exp=1789611010&sig=8b3a6367397f8cce9fba276507278a80e53fd3fc617c3644ea6db78ac60de95f","tier","business","canRestrictVals","profileImageUrl","ctx",{"_84":-5,"_146":147,"_148":149,"_150":151,"_152":42,"_153":42,"_154":42,"_155":32,"_156":-5,"_157":-7,"_158":-7,"_159":65,"_160":42,"_161":42,"_162":-5,"_163":42,"_164":42,"_165":42,"_166":-5},"ENV",{"_117":118,"_119":120,"_121":92,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139,"_140":141,"_142":143,"_144":145},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","c73f21da490985bff19c279eb0e09db24d688e4f","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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]