[{"_1":2,"_183":-5,"_184":-5},"loaderData",{"_3":4,"_95":96},"root",{"_5":6,"_36":37,"_68":69},"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","isBusinessOrgMember","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,"_66":67},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","e57df1da97789090df5b7715fd77dd1717576393","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","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","API_URL","https://api.val.town","clerkState",{"_70":71},"__internal_clerk_state",{"_72":73,"_74":47,"_75":76,"_77":76,"_78":20,"_79":76,"_80":76,"_81":76,"_82":76,"_83":84,"_93":20,"_94":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",{"_85":20,"_19":20,"_86":76,"_87":88,"_89":76,"_90":47,"_91":20,"_92":76},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_97":98,"_99":100,"_101":102,"_103":104,"_160":161,"_179":180,"_181":182},"handle","nbbaier","name","agentfs","path","fs.ts","project",{"_105":106,"_99":100,"_107":108,"_109":-5,"_110":20,"_111":112,"_113":-5,"_114":-5,"_12":115,"_116":-5,"_117":20,"_118":-5,"_119":-5,"_120":33,"_14":121,"_122":123,"_124":125,"_126":127,"_128":-5,"_129":130,"_131":130,"_132":133,"_134":133,"_135":133,"_136":130,"_137":130,"_23":138,"_141":142,"_146":147,"_159":20},"id","0efaa3f2-2fed-11f1-ad2f-42dde27851f2","createdAt",["D",1775283063025],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","5d1042a9-7b0b-499d-8a72-3a8ac7a4e185","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","5f80108f-7ca4-4327-b77b-089dbe4b5a82","tursoName","0efaa3f22fed11f1ad2f42dde27851f2","tursoHostname","0efaa3f22fed11f1ad2f42dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1775284263235],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_97":98,"_139":140},"profileImageUrl","https://secure.gravatar.com/avatar/0129a541b7b3574e92c4afd06c5e32da&d=identicon","org",{"_97":98,"_143":140,"_12":115,"_144":145},"avatar","tier","pro","branch",{"_148":149,"_99":45,"_105":150,"_151":106,"_152":-5,"_153":-5,"_154":-5,"_155":-5,"_156":-5,"_157":100,"_158":98},"version",32,"0efb5874-2fed-11f1-ad2f-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_105":162,"_99":102,"_163":164,"_165":-5,"_166":150,"_167":168,"_169":170,"_107":171,"_148":172,"_173":160,"_174":175,"_176":20,"_177":-5,"_101":178},"ffb84396-2ff0-11f1-8cb7-42dde27851f2","fileId","74970d2a-2fef-11f1-b8d6-42dde27851f2","parentId","branchId","branchVersion",16,"latest",true,["D",1775284755396],1,"fileType","content","/**\n * AgentFS Virtual Filesystem\n *\n * POSIX-like file operations backed by Val Town SQLite.\n * Uses an inode-based design with chunked content storage.\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {\n DEFAULT_DIR_MODE,\n DEFAULT_FILE_MODE,\n isDir,\n ROOT_INO,\n S_IFDIR,\n S_IFLNK,\n S_IFMT,\n} from \"./types.ts\";\nimport type { Inode, StatResult } from \"./types.ts\";\n\n// ─── Internal helpers ────────────────────────────────────────────────\n\nfunction now(): number {\n return Math.floor(Date.now() / 1000);\n}\n\n/** Split a path into components, filtering empties. */\nfunction splitPath(path: string): string[] {\n return path.split(\"/\").filter((c) => c.length > 0);\n}\n\n/** Get parent path and basename from a full path. */\nfunction parsePath(path: string): { parent: string; name: string } {\n const components = splitPath(path);\n if (components.length === 0) {\n throw new Error(\"Cannot parse root path\");\n }\n const name = components.pop()!;\n const parent = \"/\" + components.join(\"/\");\n return { parent, name };\n}\n\n/** Retrieve the configured chunk size. */\nasync function getChunkSize(): Promise {\n const res = await sqlite.execute({\n sql: `SELECT value FROM fs_config WHERE key = 'chunk_size'`,\n args: [],\n });\n if (res.rows.length === 0) throw new Error(\"fs_config missing chunk_size\");\n return Number((res.rows[0] as any).value);\n}\n\n/**\n * Normalize blob data from SQLite into a Uint8Array.\n *\n * Val Town's scoped SQLite (Turso) returns BLOB columns as ArrayBuffer.\n * This helper handles that plus other potential representations.\n */\nfunction toBytes(d: unknown): Uint8Array {\n if (d instanceof Uint8Array) return d;\n if (d instanceof ArrayBuffer) return new Uint8Array(d);\n if (ArrayBuffer.isView(d)) return new Uint8Array(d.buffer, d.byteOffset, d.byteLength);\n if (typeof d === \"string\") return new TextEncoder().encode(d);\n return new Uint8Array(0);\n}\n\n/** Concatenate an array of Uint8Arrays into a single Uint8Array. */\nfunction concatBytes(chunks: Uint8Array[]): Uint8Array {\n const totalLen = chunks.reduce((sum, c) => sum + c.length, 0);\n const combined = new Uint8Array(totalLen);\n let offset = 0;\n for (const chunk of chunks) {\n combined.set(chunk, offset);\n offset += chunk.length;\n }\n return combined;\n}\n\n// ─── Path Resolution ─────────────────────────────────────────────────\n\n/**\n * Resolve an absolute path to its inode number.\n * Returns undefined if any component along the path doesn't exist.\n */\nexport async function resolve(path: string): Promise {\n const components = splitPath(path);\n if (components.length === 0) return ROOT_INO;\n\n let currentIno = ROOT_INO;\n for (const name of components) {\n const res = await sqlite.execute({\n sql: `SELECT ino FROM fs_dentry WHERE parent_ino = ? AND name = ?`,\n args: [currentIno, name],\n });\n if (res.rows.length === 0) return undefined;\n currentIno = (res.rows[0] as any).ino as number;\n }\n return currentIno;\n}\n\n/**\n * Resolve a path, throwing if it doesn't exist.\n */\nasync function resolveOrThrow(path: string): Promise {\n const ino = await resolve(path);\n if (ino === undefined) throw new Error(`ENOENT: ${path}`);\n return ino;\n}\n\n// ─── Stat ────────────────────────────────────────────────────────────\n\n/** Get file/directory metadata. */\nexport async function stat(path: string): Promise {\n const ino = await resolveOrThrow(path);\n const res = await sqlite.execute({\n sql: `SELECT ino, mode, nlink, uid, gid, size, atime, mtime, ctime, rdev,\n atime_nsec, mtime_nsec, ctime_nsec\n FROM fs_inode WHERE ino = ?`,\n args: [ino],\n });\n if (res.rows.length === 0) throw new Error(`Inode ${ino} not found`);\n return res.rows[0] as unknown as StatResult;\n}\n\n/** Check whether a path exists. */\nexport async function exists(path: string): Promise {\n return (await resolve(path)) !== undefined;\n}\n\n// ─── Directory Operations ────────────────────────────────────────────\n\n/**\n * Create a directory. Throws if it already exists or the parent doesn't exist.\n */\nexport async function mkdir(path: string): Promise {\n const { parent, name } = parsePath(path);\n const parentIno = await resolveOrThrow(parent);\n\n const ts = now();\n const res = await sqlite.execute({\n sql: `INSERT INTO fs_inode (mode, nlink, uid, gid, size, atime, mtime, ctime)\n VALUES (?, 0, 0, 0, 0, ?, ?, ?) RETURNING ino`,\n args: [DEFAULT_DIR_MODE, ts, ts, ts],\n });\n const ino = (res.rows[0] as any).ino as number;\n\n await sqlite.execute({\n sql: `INSERT INTO fs_dentry (name, parent_ino, ino) VALUES (?, ?, ?)`,\n args: [name, parentIno, ino],\n });\n\n await sqlite.execute({\n sql: `UPDATE fs_inode SET nlink = nlink + 1 WHERE ino = ?`,\n args: [ino],\n });\n\n return ino;\n}\n\n/**\n * Create a directory and all missing parents (like mkdir -p).\n */\nexport async function mkdirp(path: string): Promise {\n const components = splitPath(path);\n let currentIno = ROOT_INO;\n\n for (const name of components) {\n const res = await sqlite.execute({\n sql: `SELECT ino FROM fs_dentry WHERE parent_ino = ? AND name = ?`,\n args: [currentIno, name],\n });\n\n if (res.rows.length > 0) {\n currentIno = (res.rows[0] as any).ino as number;\n } else {\n const ts = now();\n const newInode = await sqlite.execute({\n sql: `INSERT INTO fs_inode (mode, nlink, uid, gid, size, atime, mtime, ctime)\n VALUES (?, 0, 0, 0, 0, ?, ?, ?) RETURNING ino`,\n args: [DEFAULT_DIR_MODE, ts, ts, ts],\n });\n const newIno = (newInode.rows[0] as any).ino as number;\n\n await sqlite.execute({\n sql: `INSERT INTO fs_dentry (name, parent_ino, ino) VALUES (?, ?, ?)`,\n args: [name, currentIno, newIno],\n });\n await sqlite.execute({\n sql: `UPDATE fs_inode SET nlink = nlink + 1 WHERE ino = ?`,\n args: [newIno],\n });\n\n currentIno = newIno;\n }\n }\n\n return currentIno;\n}\n\n/** List the names in a directory. */\nexport async function readdir(path: string): Promise {\n const ino = await resolveOrThrow(path);\n const res = await sqlite.execute({\n sql: `SELECT name FROM fs_dentry WHERE parent_ino = ? ORDER BY name ASC`,\n args: [ino],\n });\n return res.rows.map((r: any) => r.name as string);\n}\n\n/**\n * Remove an empty directory. Throws if not empty or not a directory.\n */\nexport async function rmdir(path: string): Promise {\n if (path === \"/\") throw new Error(\"Cannot remove root directory\");\n\n const { parent, name } = parsePath(path);\n const ino = await resolveOrThrow(path);\n\n // Check it's a directory\n const inodeRes = await sqlite.execute({\n sql: `SELECT mode FROM fs_inode WHERE ino = ?`,\n args: [ino],\n });\n if (inodeRes.rows.length === 0) throw new Error(`Inode ${ino} not found`);\n if (!isDir((inodeRes.rows[0] as any).mode as number)) {\n throw new Error(`ENOTDIR: ${path}`);\n }\n\n // Check it's empty\n const children = await sqlite.execute({\n sql: `SELECT 1 FROM fs_dentry WHERE parent_ino = ? LIMIT 1`,\n args: [ino],\n });\n if (children.rows.length > 0) throw new Error(`ENOTEMPTY: ${path}`);\n\n const parentIno = await resolveOrThrow(parent);\n\n await sqlite.execute({\n sql: `DELETE FROM fs_dentry WHERE parent_ino = ? AND name = ?`,\n args: [parentIno, name],\n });\n await sqlite.execute({\n sql: `UPDATE fs_inode SET nlink = nlink - 1 WHERE ino = ?`,\n args: [ino],\n });\n\n // If no more links, delete the inode\n const linkCheck = await sqlite.execute({\n sql: `SELECT nlink FROM fs_inode WHERE ino = ?`,\n args: [ino],\n });\n if (linkCheck.rows.length > 0 && (linkCheck.rows[0] as any).nlink <= 0) {\n await sqlite.execute({\n sql: `DELETE FROM fs_inode WHERE ino = ?`,\n args: [ino],\n });\n }\n}\n\n// ─── File Operations ─────────────────────────────────────────────────\n\n/**\n * Write a file at the given path. Creates parent directories as needed.\n * If the file already exists, its content is replaced.\n *\n * Accepts string or Uint8Array content.\n */\nexport async function writeFile(\n path: string,\n content: string | Uint8Array,\n): Promise {\n const { parent, name } = parsePath(path);\n const data =\n typeof content === \"string\" ? new TextEncoder().encode(content) : content;\n const chunkSize = await getChunkSize();\n\n // Ensure parent directories exist\n const parentIno = await mkdirp(parent);\n\n // Check if file already exists\n const existing = await sqlite.execute({\n sql: `SELECT ino FROM fs_dentry WHERE parent_ino = ? AND name = ?`,\n args: [parentIno, name],\n });\n\n let ino: number;\n\n if (existing.rows.length > 0) {\n // Overwrite: delete old chunks, rewrite\n ino = (existing.rows[0] as any).ino as number;\n await sqlite.execute({\n sql: `DELETE FROM fs_data WHERE ino = ?`,\n args: [ino],\n });\n } else {\n // Create new inode + dentry\n const ts = now();\n const res = await sqlite.execute({\n sql: `INSERT INTO fs_inode (mode, nlink, uid, gid, size, atime, mtime, ctime)\n VALUES (?, 0, 0, 0, 0, ?, ?, ?) RETURNING ino`,\n args: [DEFAULT_FILE_MODE, ts, ts, ts],\n });\n ino = (res.rows[0] as any).ino as number;\n\n await sqlite.execute({\n sql: `INSERT INTO fs_dentry (name, parent_ino, ino) VALUES (?, ?, ?)`,\n args: [name, parentIno, ino],\n });\n await sqlite.execute({\n sql: `UPDATE fs_inode SET nlink = nlink + 1 WHERE ino = ?`,\n args: [ino],\n });\n }\n\n // Write chunks\n const totalChunks = data.length === 0 ? 0 : Math.ceil(data.length / chunkSize);\n for (let i = 0; i < totalChunks; i++) {\n const start = i * chunkSize;\n const end = Math.min(start + chunkSize, data.length);\n const chunk = data.slice(start, end);\n\n await sqlite.execute({\n sql: `INSERT INTO fs_data (ino, chunk_index, data) VALUES (?, ?, ?)`,\n args: [ino, i, chunk],\n });\n }\n\n // Update size + mtime\n await sqlite.execute({\n sql: `UPDATE fs_inode SET size = ?, mtime = ? WHERE ino = ?`,\n args: [data.length, now(), ino],\n });\n\n return ino;\n}\n\n/**\n * Read an entire file. Returns a Uint8Array by default.\n * Pass encoding = \"utf-8\" to get a string.\n */\nexport async function readFile(\n path: string,\n encoding?: \"utf-8\",\n): Promise {\n const ino = await resolveOrThrow(path);\n\n const res = await sqlite.execute({\n sql: `SELECT data FROM fs_data WHERE ino = ? ORDER BY chunk_index ASC`,\n args: [ino],\n });\n\n // Update atime\n await sqlite.execute({\n sql: `UPDATE fs_inode SET atime = ? WHERE ino = ?`,\n args: [now(), ino],\n });\n\n if (res.rows.length === 0) {\n return encoding === \"utf-8\" ? \"\" : new Uint8Array(0);\n }\n\n const combined = concatBytes(res.rows.map((r: any) => toBytes(r.data)));\n\n if (encoding === \"utf-8\") {\n return new TextDecoder().decode(combined);\n }\n return combined;\n}\n\n/**\n * Read a portion of a file at a given byte offset.\n */\nexport async function readFileAt(\n path: string,\n offset: number,\n length: number,\n): Promise {\n const ino = await resolveOrThrow(path);\n const chunkSize = await getChunkSize();\n\n const startChunk = Math.floor(offset / chunkSize);\n const endChunk = Math.floor((offset + length - 1) / chunkSize);\n\n const res = await sqlite.execute({\n sql: `SELECT chunk_index, data FROM fs_data\n WHERE ino = ? AND chunk_index >= ? AND chunk_index <= ?\n ORDER BY chunk_index ASC`,\n args: [ino, startChunk, endChunk],\n });\n\n if (res.rows.length === 0) return new Uint8Array(0);\n\n const combined = concatBytes(res.rows.map((r: any) => toBytes(r.data)));\n\n // Extract the requested window\n const offsetInFirst = offset % chunkSize;\n return combined.slice(offsetInFirst, offsetInFirst + length);\n}\n\n/**\n * Delete (unlink) a file. If this is the last link, the inode and data are removed.\n */\nexport async function deleteFile(path: string): Promise {\n const { parent, name } = parsePath(path);\n const parentIno = await resolveOrThrow(parent);\n const ino = await resolveOrThrow(path);\n\n // Remove dentry\n await sqlite.execute({\n sql: `DELETE FROM fs_dentry WHERE parent_ino = ? AND name = ?`,\n args: [parentIno, name],\n });\n\n // Decrement nlink\n await sqlite.execute({\n sql: `UPDATE fs_inode SET nlink = nlink - 1 WHERE ino = ?`,\n args: [ino],\n });\n\n // If last link, clean up inode + data + symlink\n const linkCheck = await sqlite.execute({\n sql: `SELECT nlink FROM fs_inode WHERE ino = ?`,\n args: [ino],\n });\n\n if (linkCheck.rows.length > 0 && (linkCheck.rows[0] as any).nlink <= 0) {\n await sqlite.execute({ sql: `DELETE FROM fs_data WHERE ino = ?`, args: [ino] });\n await sqlite.execute({ sql: `DELETE FROM fs_symlink WHERE ino = ?`, args: [ino] });\n await sqlite.execute({ sql: `DELETE FROM fs_inode WHERE ino = ?`, args: [ino] });\n }\n}\n\n// ─── Links ───────────────────────────────────────────────────────────\n\n/**\n * Create a hard link: a new name pointing to an existing inode.\n */\nexport async function link(srcPath: string, destPath: string): Promise {\n const srcIno = await resolveOrThrow(srcPath);\n const { parent, name } = parsePath(destPath);\n const destParentIno = await resolveOrThrow(parent);\n\n await sqlite.execute({\n sql: `INSERT INTO fs_dentry (name, parent_ino, ino) VALUES (?, ?, ?)`,\n args: [name, destParentIno, srcIno],\n });\n await sqlite.execute({\n sql: `UPDATE fs_inode SET nlink = nlink + 1 WHERE ino = ?`,\n args: [srcIno],\n });\n}\n\n/**\n * Create a symbolic link at `linkPath` pointing to `target`.\n */\nexport async function symlink(target: string, linkPath: string): Promise {\n const { parent, name } = parsePath(linkPath);\n const parentIno = await resolveOrThrow(parent);\n\n const ts = now();\n // Mode: symlink + 0777\n const mode = S_IFLNK | 0o777;\n const res = await sqlite.execute({\n sql: `INSERT INTO fs_inode (mode, nlink, uid, gid, size, atime, mtime, ctime)\n VALUES (?, 0, 0, 0, ?, ?, ?, ?) RETURNING ino`,\n args: [mode, target.length, ts, ts, ts],\n });\n const ino = (res.rows[0] as any).ino as number;\n\n await sqlite.execute({\n sql: `INSERT INTO fs_dentry (name, parent_ino, ino) VALUES (?, ?, ?)`,\n args: [name, parentIno, ino],\n });\n await sqlite.execute({\n sql: `UPDATE fs_inode SET nlink = nlink + 1 WHERE ino = ?`,\n args: [ino],\n });\n await sqlite.execute({\n sql: `INSERT INTO fs_symlink (ino, target) VALUES (?, ?)`,\n args: [ino, target],\n });\n\n return ino;\n}\n\n/**\n * Read the target of a symbolic link.\n */\nexport async function readlink(path: string): Promise {\n const ino = await resolveOrThrow(path);\n const res = await sqlite.execute({\n sql: `SELECT target FROM fs_symlink WHERE ino = ?`,\n args: [ino],\n });\n if (res.rows.length === 0) throw new Error(`Not a symlink: ${path}`);\n return (res.rows[0] as any).target as string;\n}\n\n// ─── Rename / Move ───────────────────────────────────────────────────\n\n/**\n * Rename or move a file/directory from oldPath to newPath.\n */\nexport async function rename(oldPath: string, newPath: string): Promise {\n const { parent: oldParent, name: oldName } = parsePath(oldPath);\n const { parent: newParent, name: newName } = parsePath(newPath);\n\n const oldParentIno = await resolveOrThrow(oldParent);\n const ino = await resolveOrThrow(oldPath);\n\n // Ensure new parent exists\n const newParentIno = await mkdirp(newParent);\n\n // Remove old dentry\n await sqlite.execute({\n sql: `DELETE FROM fs_dentry WHERE parent_ino = ? AND name = ?`,\n args: [oldParentIno, oldName],\n });\n\n // Check if destination exists and remove it\n const destExisting = await sqlite.execute({\n sql: `SELECT ino FROM fs_dentry WHERE parent_ino = ? AND name = ?`,\n args: [newParentIno, newName],\n });\n if (destExisting.rows.length > 0) {\n const destIno = (destExisting.rows[0] as any).ino as number;\n await sqlite.execute({\n sql: `DELETE FROM fs_dentry WHERE parent_ino = ? AND name = ?`,\n args: [newParentIno, newName],\n });\n await sqlite.execute({\n sql: `UPDATE fs_inode SET nlink = nlink - 1 WHERE ino = ?`,\n args: [destIno],\n });\n }\n\n // Insert new dentry\n await sqlite.execute({\n sql: `INSERT INTO fs_dentry (name, parent_ino, ino) VALUES (?, ?, ?)`,\n args: [newName, newParentIno, ino],\n });\n\n // Update ctime\n await sqlite.execute({\n sql: `UPDATE fs_inode SET ctime = ? WHERE ino = ?`,\n args: [now(), ino],\n });\n}\n","deleted","label",[102],"permalink","https://www.val.town/x/nbbaier/agentfs/code/fs.ts","extension","ts","actionData","errors"]