[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_254":255,"_256":257},"routes/_app.x.$handle.$name",{"_98":97,"_33":45,"_106":88,"_28":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":27,"_121":122,"_123":25,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_33":45,"_38":46,"_47":-5,"_48":27,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":27,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":27},"version",19,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":27,"_28":29,"_30":29},"file",{"_31":32,"_33":29,"_35":36,"_37":-5,"_38":39,"_40":14,"_41":42,"_24":27},"previous",{"_31":32,"_33":34,"_35":36,"_37":-5},"deleted",true,"deletedHere",false,"path","docs","latestPath","fileId","06992c10-2ff2-11f1-832b-42dde27851f2","name","untitled-folder-928","fileType","directory","content","createdAt",["D",1775285198090],"branchVersion","branchId","0efb5874-2fed-11f1-ad2f-42dde27851f2","id","0efaa3f2-2fed-11f1-ad2f-42dde27851f2","agentfs",["D",1775283063025],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","A virtual filesystem for AI agents, backed by SQLite.","imageUrl","5d1042a9-7b0b-499d-8a72-3a8ac7a4e185","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",1,"orgId","5f80108f-7ca4-4327-b77b-089dbe4b5a82","tursoName","0efaa3f22fed11f1ad2f42dde27851f2","tursoHostname","0efaa3f22fed11f1ad2f42dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789556471789],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_105":101},"org",{"_98":97,"_99":-5,"_100":101,"_18":55,"_102":103,"_104":27},"branch",{"_13":87,"_33":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",55,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","nbbaier","handle","displayName","avatar","https://secure.gravatar.com/avatar/0129a541b7b3574e92c4afd06c5e32da&d=identicon","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_33":45,"_38":249,"_47":-5,"_48":27,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":27,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":250,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":251,"_82":252,"_84":253,"_86":27},"tree",[212,213,214,215,216,217,218,219,220],"files",[212,213,214,215,216,217,218,219,220],"counts",{"_202":144,"_203":61,"_204":144,"_205":206,"_207":208},"contents",[128,129,130,131,132,133,134,135,136],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":199,"_33":29,"_31":32,"_140":-5,"_41":42,"_40":14,"_142":27,"_38":200,"_13":61,"_35":36,"_37":-5,"_24":27,"_146":-5,"_28":201},{"_43":192,"_33":193,"_31":194,"_140":-5,"_41":42,"_40":195,"_142":25,"_38":196,"_13":61,"_35":20,"_37":197,"_24":27,"_146":-5,"_28":198},{"_43":185,"_33":186,"_31":187,"_140":-5,"_41":42,"_40":188,"_142":25,"_38":189,"_13":144,"_35":20,"_37":190,"_24":27,"_146":-5,"_28":191},{"_43":177,"_33":178,"_31":179,"_140":-5,"_41":42,"_40":180,"_142":27,"_38":181,"_13":141,"_35":182,"_37":183,"_24":27,"_146":-5,"_28":184},{"_43":170,"_33":171,"_31":172,"_140":-5,"_41":42,"_40":173,"_142":25,"_38":174,"_13":144,"_35":20,"_37":175,"_24":27,"_146":-5,"_28":176},{"_43":163,"_33":164,"_31":165,"_140":-5,"_41":42,"_40":166,"_142":25,"_38":167,"_13":144,"_35":20,"_37":168,"_24":27,"_146":-5,"_28":169},{"_43":155,"_33":156,"_31":157,"_140":-5,"_41":42,"_40":158,"_142":27,"_38":159,"_13":144,"_35":160,"_37":161,"_24":27,"_146":-5,"_28":162},{"_43":148,"_33":149,"_31":150,"_140":-5,"_41":42,"_40":151,"_142":25,"_38":152,"_13":144,"_35":20,"_37":153,"_24":27,"_146":-5,"_28":154},{"_43":137,"_33":138,"_31":139,"_140":-5,"_41":42,"_40":141,"_142":25,"_38":143,"_13":144,"_35":20,"_37":145,"_24":27,"_146":-5,"_28":147},"19f9a47c-2fef-11f1-8163-42dde27851f2","types.ts","19f9a54e-2fef-11f1-8163-42dde27851f2","parentId",6,"latest",["D",1775283940460],0,"/**\n * AgentFS type definitions — mirrors the v0.4 spec.\n */\n\n// ─── Tool Calls ──────────────────────────────────────────────────────\n\nexport interface ToolCall {\n id: number;\n name: string;\n parameters: string | null;\n result: string | null;\n error: string | null;\n started_at: number;\n completed_at: number;\n duration_ms: number;\n}\n\nexport interface ToolPerformance {\n name: string;\n total_calls: number;\n successful: number;\n failed: number;\n avg_duration_ms: number;\n}\n\n// ─── Virtual Filesystem ──────────────────────────────────────────────\n\n/** Unix mode constants */\nexport const S_IFMT = 0o170000;\nexport const S_IFREG = 0o100000;\nexport const S_IFDIR = 0o040000;\nexport const S_IFLNK = 0o120000;\nexport const S_IFIFO = 0o010000;\nexport const S_IFCHR = 0o020000;\nexport const S_IFBLK = 0o060000;\nexport const S_IFSOCK = 0o140000;\n\n/** Default modes */\nexport const DEFAULT_FILE_MODE = 0o100644; // rw-r--r--\nexport const DEFAULT_DIR_MODE = 0o040755; // rwxr-xr-x\n\n/** Root inode number */\nexport const ROOT_INO = 1;\n\n/** Default chunk size in bytes */\nexport const DEFAULT_CHUNK_SIZE = 4096;\n\nexport interface Inode {\n ino: number;\n mode: number;\n nlink: number;\n uid: number;\n gid: number;\n size: number;\n atime: number;\n mtime: number;\n ctime: number;\n rdev: number;\n atime_nsec: number;\n mtime_nsec: number;\n ctime_nsec: number;\n}\n\nexport interface DirEntry {\n id: number;\n name: string;\n parent_ino: number;\n ino: number;\n}\n\nexport interface StatResult {\n ino: number;\n mode: number;\n nlink: number;\n uid: number;\n gid: number;\n size: number;\n atime: number;\n mtime: number;\n ctime: number;\n rdev: number;\n atime_nsec: number;\n mtime_nsec: number;\n ctime_nsec: number;\n}\n\n// ─── Key-Value Store ─────────────────────────────────────────────────\n\nexport interface KVEntry {\n key: string;\n value: string;\n created_at: number;\n updated_at: number;\n}\n\n// ─── Helpers ─────────────────────────────────────────────────────────\n\n/** Checks whether a mode value represents a directory */\nexport function isDir(mode: number): boolean {\n return (mode & S_IFMT) === S_IFDIR;\n}\n\n/** Checks whether a mode value represents a regular file */\nexport function isFile(mode: number): boolean {\n return (mode & S_IFMT) === S_IFREG;\n}\n\n/** Checks whether a mode value represents a symlink */\nexport function isSymlink(mode: number): boolean {\n return (mode & S_IFMT) === S_IFLNK;\n}\n","label",[138],"4b76572a-2fef-11f1-8c6e-42dde27851f2","tool-calls.ts","4b7657c0-2fef-11f1-8c6e-42dde27851f2",9,["D",1775284023483],"/**\n * AgentFS Tool Call Audit Log\n *\n * Insert-only audit trail for tool invocations.\n * Records are never updated or deleted.\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type { ToolCall, ToolPerformance } from \"./types.ts\";\n\n/**\n * Record a completed tool call.\n *\n * Provide either `result` (on success) or `error` (on failure), not both.\n * Timestamps are Unix epoch seconds; duration is computed automatically.\n */\nexport async function record(opts: {\n name: string;\n parameters?: unknown;\n result?: unknown;\n error?: string;\n started_at: number;\n completed_at: number;\n}): Promise {\n const duration_ms = Math.round((opts.completed_at - opts.started_at) * 1000);\n const res = await sqlite.execute({\n sql: `INSERT INTO tool_calls (name, parameters, result, error, started_at, completed_at, duration_ms)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n args: [\n opts.name,\n opts.parameters != null ? JSON.stringify(opts.parameters) : null,\n opts.result != null ? JSON.stringify(opts.result) : null,\n opts.error ?? null,\n opts.started_at,\n opts.completed_at,\n duration_ms,\n ],\n });\n return Number(res.lastInsertRowid ?? 0);\n}\n\n/**\n * Convenience wrapper: execute a function and automatically record\n * the tool call with timing, result, and error capture.\n */\nexport async function trace(\n name: string,\n parameters: unknown,\n fn: () => Promise,\n): Promise {\n const started_at = Date.now() / 1000;\n try {\n const result = await fn();\n const completed_at = Date.now() / 1000;\n await record({ name, parameters, result, started_at, completed_at });\n return result;\n } catch (err) {\n const completed_at = Date.now() / 1000;\n const error = err instanceof Error ? err.message : String(err);\n await record({ name, parameters, error, started_at, completed_at });\n throw err;\n }\n}\n\n/** Get a single tool call by ID. */\nexport async function get(id: number): Promise {\n const res = await sqlite.execute({\n sql: `SELECT * FROM tool_calls WHERE id = ?`,\n args: [id],\n });\n return (res.rows[0] as unknown as ToolCall) ?? undefined;\n}\n\n/** Query tool calls by name, most recent first. */\nexport async function queryByName(\n name: string,\n limit = 100,\n): Promise {\n const res = await sqlite.execute({\n sql: `SELECT * FROM tool_calls WHERE name = ? ORDER BY started_at DESC LIMIT ?`,\n args: [name, limit],\n });\n return res.rows as unknown as ToolCall[];\n}\n\n/** Query tool calls after a given timestamp, most recent first. */\nexport async function queryRecent(\n since: number,\n limit = 100,\n): Promise {\n const res = await sqlite.execute({\n sql: `SELECT * FROM tool_calls WHERE started_at > ? ORDER BY started_at DESC LIMIT ?`,\n args: [since, limit],\n });\n return res.rows as unknown as ToolCall[];\n}\n\n/** Aggregate performance stats grouped by tool name. */\nexport async function analyzePerformance(): Promise {\n const res = await sqlite.execute({\n sql: `SELECT\n name,\n COUNT(*) as total_calls,\n SUM(CASE WHEN error IS NULL THEN 1 ELSE 0 END) as successful,\n SUM(CASE WHEN error IS NOT NULL THEN 1 ELSE 0 END) as failed,\n AVG(duration_ms) as avg_duration_ms\n FROM tool_calls\n GROUP BY name\n ORDER BY total_calls DESC`,\n args: [],\n });\n return res.rows as unknown as ToolPerformance[];\n}\n",[149],"3aba71fe-2ff0-11f1-b843-42dde27851f2","test.ts","3aba72b2-2ff0-11f1-b843-42dde27851f2",14,["D",1775284424884],"script","/**\n * Quick smoke test — run as a script to verify AgentFS works.\n */\n\nimport { init, kv, tools, fs, isFile } from \"./mod.ts\";\n\n// Initialize\nawait init();\nconsole.log(\"init: OK\");\n\n// KV\nawait kv.set(\"test:x\", { a: 1 });\nconst val = await kv.get(\"test:x\");\nconsole.log(\"kv.set/get:\", JSON.stringify(val));\nawait kv.del(\"test:x\");\nconsole.log(\"kv.del: OK\");\n\n// Tool calls\nconst t = Date.now() / 1000;\nconst id = await tools.record({\n name: \"test_tool\",\n parameters: { q: \"hello\" },\n result: { ok: true },\n started_at: t,\n completed_at: t + 0.1,\n});\nconst tc = await tools.get(id);\nconsole.log(\"tools.record/get:\", tc?.name, tc?.duration_ms + \"ms\");\n\n// Filesystem\nawait fs.writeFile(\"/test.txt\", \"hello world\");\nconst content = await fs.readFile(\"/test.txt\", \"utf-8\");\nconsole.log(\"fs.writeFile/readFile:\", content);\n\nconst st = await fs.stat(\"/test.txt\");\nconsole.log(\"fs.stat: size=\" + st.size, \"isFile=\" + isFile(st.mode));\n\nawait fs.writeFile(\"/sub/dir/deep.txt\", \"nested\");\nconst dirs = await fs.readdir(\"/\");\nconsole.log(\"readdir /:\", dirs);\n\nconst subDirs = await fs.readdir(\"/sub\");\nconsole.log(\"readdir /sub:\", subDirs);\n\n// Cleanup\nawait fs.deleteFile(\"/test.txt\");\nawait fs.deleteFile(\"/sub/dir/deep.txt\");\nawait fs.rmdir(\"/sub/dir\");\nawait fs.rmdir(\"/sub\");\nconsole.log(\"cleanup: OK\");\n\nconsole.log(\"\\nAll tests passed.\");\n",[156],"256f77dc-2fef-11f1-acbc-42dde27851f2","schema.ts","256f78a4-2fef-11f1-acbc-42dde27851f2",7,["D",1775283959685],"/**\n * AgentFS schema definitions and initialization.\n *\n * All DDL is idempotent (CREATE TABLE IF NOT EXISTS / CREATE INDEX IF NOT EXISTS)\n * so init() can be called safely on every startup.\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { DEFAULT_CHUNK_SIZE, DEFAULT_DIR_MODE, ROOT_INO } from \"./types.ts\";\n\n// ─── DDL Statements ──────────────────────────────────────────────────\n\nconst TOOL_CALLS_DDL = `\nCREATE TABLE IF NOT EXISTS tool_calls (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n parameters TEXT,\n result TEXT,\n error TEXT,\n started_at INTEGER NOT NULL,\n completed_at INTEGER NOT NULL,\n duration_ms INTEGER NOT NULL\n)`;\n\nconst TOOL_CALLS_INDEXES = [\n `CREATE INDEX IF NOT EXISTS idx_tool_calls_name ON tool_calls(name)`,\n `CREATE INDEX IF NOT EXISTS idx_tool_calls_started_at ON tool_calls(started_at)`,\n];\n\nconst FS_CONFIG_DDL = `\nCREATE TABLE IF NOT EXISTS fs_config (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL\n)`;\n\nconst FS_INODE_DDL = `\nCREATE TABLE IF NOT EXISTS fs_inode (\n ino INTEGER PRIMARY KEY AUTOINCREMENT,\n mode INTEGER NOT NULL,\n nlink INTEGER NOT NULL DEFAULT 0,\n uid INTEGER NOT NULL DEFAULT 0,\n gid INTEGER NOT NULL DEFAULT 0,\n size INTEGER NOT NULL DEFAULT 0,\n atime INTEGER NOT NULL,\n mtime INTEGER NOT NULL,\n ctime INTEGER NOT NULL,\n rdev INTEGER NOT NULL DEFAULT 0,\n atime_nsec INTEGER NOT NULL DEFAULT 0,\n mtime_nsec INTEGER NOT NULL DEFAULT 0,\n ctime_nsec INTEGER NOT NULL DEFAULT 0\n)`;\n\nconst FS_DENTRY_DDL = `\nCREATE TABLE IF NOT EXISTS fs_dentry (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n parent_ino INTEGER NOT NULL,\n ino INTEGER NOT NULL,\n UNIQUE(parent_ino, name)\n)`;\n\nconst FS_DENTRY_INDEXES = [\n `CREATE INDEX IF NOT EXISTS idx_fs_dentry_parent ON fs_dentry(parent_ino, name)`,\n];\n\nconst FS_DATA_DDL = `\nCREATE TABLE IF NOT EXISTS fs_data (\n ino INTEGER NOT NULL,\n chunk_index INTEGER NOT NULL,\n data BLOB NOT NULL,\n PRIMARY KEY (ino, chunk_index)\n)`;\n\nconst FS_SYMLINK_DDL = `\nCREATE TABLE IF NOT EXISTS fs_symlink (\n ino INTEGER PRIMARY KEY,\n target TEXT NOT NULL\n)`;\n\nconst KV_STORE_DDL = `\nCREATE TABLE IF NOT EXISTS kv_store (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL,\n created_at INTEGER DEFAULT (unixepoch()),\n updated_at INTEGER DEFAULT (unixepoch())\n)`;\n\nconst KV_STORE_INDEXES = [\n `CREATE INDEX IF NOT EXISTS idx_kv_store_created_at ON kv_store(created_at)`,\n];\n\n// ─── Initialization ──────────────────────────────────────────────────\n\n/**\n * Initialize all AgentFS tables and seed required data.\n *\n * Safe to call multiple times — uses IF NOT EXISTS throughout and\n * only inserts seed data when it's absent.\n */\nexport async function init(): Promise {\n // Create all tables\n await sqlite.batch([\n { sql: TOOL_CALLS_DDL, args: [] },\n ...TOOL_CALLS_INDEXES.map((sql) => ({ sql, args: [] as any[] })),\n { sql: FS_CONFIG_DDL, args: [] },\n { sql: FS_INODE_DDL, args: [] },\n { sql: FS_DENTRY_DDL, args: [] },\n ...FS_DENTRY_INDEXES.map((sql) => ({ sql, args: [] as any[] })),\n { sql: FS_DATA_DDL, args: [] },\n { sql: FS_SYMLINK_DDL, args: [] },\n { sql: KV_STORE_DDL, args: [] },\n ...KV_STORE_INDEXES.map((sql) => ({ sql, args: [] as any[] })),\n ]);\n\n // Seed fs_config (chunk_size) if not present\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO fs_config (key, value) VALUES ('chunk_size', ?)`,\n args: [String(DEFAULT_CHUNK_SIZE)],\n });\n\n // Seed root directory inode if not present\n const root = await sqlite.execute({\n sql: `SELECT ino FROM fs_inode WHERE ino = ?`,\n args: [ROOT_INO],\n });\n\n if (root.rows.length === 0) {\n const now = Math.floor(Date.now() / 1000);\n await sqlite.execute({\n sql: `INSERT INTO fs_inode (ino, mode, nlink, uid, gid, size, atime, mtime, ctime)\n VALUES (?, ?, 1, 0, 0, 0, ?, ?, ?)`,\n args: [ROOT_INO, DEFAULT_DIR_MODE, now, now, now],\n });\n }\n}\n",[164],"7ad46fac-2fef-11f1-a11c-42dde27851f2","mod.ts","7ad4706a-2fef-11f1-a11c-42dde27851f2",11,["D",1775284102955],"/**\n * AgentFS — A virtual filesystem for AI agents.\n *\n * Implements the Agent Filesystem Specification v0.4 using Val Town SQLite.\n * https://www.agentfs.ai/\n *\n * Usage:\n * import { init, kv, tools, fs } from \"https://esm.town/v/nbbaier/agentfs/mod.ts\";\n *\n * await init();\n * await kv.set(\"greeting\", \"hello\");\n * await fs.writeFile(\"/notes.md\", \"# My Notes\");\n */\n\nexport { init } from \"./schema.ts\";\n\n// Re-export modules as namespaces\nexport * as kv from \"./kv.ts\";\nexport * as tools from \"./tool-calls.ts\";\nexport * as fs from \"./fs.ts\";\n\n// Re-export types\nexport type {\n DirEntry,\n Inode,\n KVEntry,\n StatResult,\n ToolCall,\n ToolPerformance,\n} from \"./types.ts\";\n\nexport {\n DEFAULT_CHUNK_SIZE,\n DEFAULT_DIR_MODE,\n DEFAULT_FILE_MODE,\n isDir,\n isFile,\n isSymlink,\n ROOT_INO,\n S_IFBLK,\n S_IFCHR,\n S_IFDIR,\n S_IFIFO,\n S_IFLNK,\n S_IFMT,\n S_IFREG,\n S_IFSOCK,\n} from \"./types.ts\";\n",[171],"a9a6157e-2fef-11f1-b8d6-42dde27851f2","main.ts","0efdef3a-2fed-11f1-ad2f-42dde27851f2",13,["D",1775284181484],"http","/**\n * AgentFS test handler — exercises all modules against the scoped SQLite database.\n *\n * Hit the endpoint to run the test suite.\n */\n\nimport { init, kv, tools, fs } from \"./mod.ts\";\n\ntype TestResult = { name: string; ok: boolean; detail?: string };\n\nasync function runTest(\n name: string,\n fn: () => Promise,\n): Promise {\n try {\n const detail = (await fn()) ?? \"ok\";\n return { name, ok: true, detail };\n } catch (err) {\n const msg = err instanceof Error ? err.message : String(err);\n return { name, ok: false, detail: msg };\n }\n}\n\nexport default async function handler(_req: Request): Promise {\n const results: TestResult[] = [];\n\n // ── Schema init ──────────────────────────────────────────────────\n results.push(\n await runTest(\"init\", async () => {\n await init();\n }),\n );\n\n // ── KV store ─────────────────────────────────────────────────────\n results.push(\n await runTest(\"kv.set + kv.get (object)\", async () => {\n await kv.set(\"test:obj\", { hello: \"world\" });\n const val = await kv.get<{ hello: string }>(\"test:obj\");\n if (val?.hello !== \"world\") throw new Error(`Expected \"world\", got ${JSON.stringify(val)}`);\n return JSON.stringify(val);\n }),\n );\n\n results.push(\n await runTest(\"kv.set + kv.get (number)\", async () => {\n await kv.set(\"test:num\", 42);\n const val = await kv.get(\"test:num\");\n if (val !== 42) throw new Error(`Expected 42, got ${val}`);\n return String(val);\n }),\n );\n\n results.push(\n await runTest(\"kv.has\", async () => {\n const yes = await kv.has(\"test:num\");\n const no = await kv.has(\"test:nonexistent\");\n if (!yes) throw new Error(\"Expected true for existing key\");\n if (no) throw new Error(\"Expected false for missing key\");\n return `exists=${yes}, missing=${no}`;\n }),\n );\n\n results.push(\n await runTest(\"kv.list\", async () => {\n const entries = await kv.list(\"test:\");\n if (entries.length < 2) throw new Error(`Expected >= 2 entries, got ${entries.length}`);\n return `${entries.length} entries`;\n }),\n );\n\n results.push(\n await runTest(\"kv.del\", async () => {\n await kv.del(\"test:obj\");\n await kv.del(\"test:num\");\n const val = await kv.get(\"test:obj\");\n if (val !== undefined) throw new Error(\"Expected undefined after delete\");\n }),\n );\n\n // ── Tool calls ───────────────────────────────────────────────────\n results.push(\n await runTest(\"tools.record\", async () => {\n const now = Date.now() / 1000;\n const id = await tools.record({\n name: \"test_tool\",\n parameters: { query: \"hello\" },\n result: { answer: 42 },\n started_at: now,\n completed_at: now + 0.150,\n });\n if (!id || id <= 0) throw new Error(`Expected positive id, got ${id}`);\n return `id=${id}`;\n }),\n );\n\n results.push(\n await runTest(\"tools.trace\", async () => {\n const result = await tools.trace(\"traced_tool\", { input: \"x\" }, async () => {\n await new Promise((r) => setTimeout(r, 10));\n return \"done\";\n });\n if (result !== \"done\") throw new Error(`Expected \"done\", got ${result}`);\n }),\n );\n\n results.push(\n await runTest(\"tools.queryByName\", async () => {\n const calls = await tools.queryByName(\"test_tool\");\n if (calls.length === 0) throw new Error(\"Expected at least 1 call\");\n return `${calls.length} call(s)`;\n }),\n );\n\n results.push(\n await runTest(\"tools.analyzePerformance\", async () => {\n const perf = await tools.analyzePerformance();\n if (perf.length === 0) throw new Error(\"Expected performance data\");\n return perf.map((p) => `${p.name}: ${p.total_calls} calls`).join(\", \");\n }),\n );\n\n // ── Filesystem ───────────────────────────────────────────────────\n results.push(\n await runTest(\"fs.writeFile + fs.readFile (string)\", async () => {\n await fs.writeFile(\"/test.txt\", \"hello agentfs\");\n const content = await fs.readFile(\"/test.txt\", \"utf-8\");\n if (content !== \"hello agentfs\") {\n throw new Error(`Expected \"hello agentfs\", got \"${content}\"`);\n }\n return `\"${content}\"`;\n }),\n );\n\n results.push(\n await runTest(\"fs.writeFile (auto-mkdir)\", async () => {\n await fs.writeFile(\"/deep/nested/dir/file.md\", \"# Nested\");\n const content = await fs.readFile(\"/deep/nested/dir/file.md\", \"utf-8\");\n if (!content.startsWith(\"# Nested\")) throw new Error(\"Content mismatch\");\n return `\"${content}\"`;\n }),\n );\n\n results.push(\n await runTest(\"fs.writeFile (overwrite)\", async () => {\n await fs.writeFile(\"/test.txt\", \"version 1\");\n await fs.writeFile(\"/test.txt\", \"version 2\");\n const content = await fs.readFile(\"/test.txt\", \"utf-8\");\n if (content !== \"version 2\") throw new Error(`Expected \"version 2\", got \"${content}\"`);\n }),\n );\n\n results.push(\n await runTest(\"fs.exists\", async () => {\n const yes = await fs.exists(\"/test.txt\");\n const no = await fs.exists(\"/nonexistent.txt\");\n if (!yes) throw new Error(\"Expected true for existing file\");\n if (no) throw new Error(\"Expected false for missing file\");\n return `exists=${yes}, missing=${no}`;\n }),\n );\n\n results.push(\n await runTest(\"fs.stat\", async () => {\n const st = await fs.stat(\"/test.txt\");\n if (!st.ino || st.size <= 0) throw new Error(`Bad stat: ${JSON.stringify(st)}`);\n return `ino=${st.ino}, size=${st.size}, mode=${st.mode.toString(8)}`;\n }),\n );\n\n results.push(\n await runTest(\"fs.readdir\", async () => {\n const entries = await fs.readdir(\"/\");\n if (!entries.includes(\"test.txt\")) throw new Error(\"Missing test.txt in readdir\");\n return entries.join(\", \");\n }),\n );\n\n results.push(\n await runTest(\"fs.mkdir + fs.readdir\", async () => {\n if (!(await fs.exists(\"/mydir\"))) {\n await fs.mkdir(\"/mydir\");\n }\n await fs.writeFile(\"/mydir/a.txt\", \"aaa\");\n await fs.writeFile(\"/mydir/b.txt\", \"bbb\");\n const entries = await fs.readdir(\"/mydir\");\n if (entries.length < 2) throw new Error(`Expected >= 2 entries, got ${entries.length}`);\n return entries.join(\", \");\n }),\n );\n\n results.push(\n await runTest(\"fs.link (hard link)\", async () => {\n await fs.link(\"/test.txt\", \"/test-link.txt\");\n const content = await fs.readFile(\"/test-link.txt\", \"utf-8\");\n if (content !== \"version 2\") throw new Error(\"Hard link content mismatch\");\n const st = await fs.stat(\"/test.txt\");\n if (st.nlink < 2) throw new Error(`Expected nlink >= 2, got ${st.nlink}`);\n return `nlink=${st.nlink}`;\n }),\n );\n\n results.push(\n await runTest(\"fs.symlink + fs.readlink\", async () => {\n if (await fs.exists(\"/test-sym.txt\")) {\n await fs.deleteFile(\"/test-sym.txt\");\n }\n await fs.symlink(\"/test.txt\", \"/test-sym.txt\");\n const target = await fs.readlink(\"/test-sym.txt\");\n if (target !== \"/test.txt\") throw new Error(`Expected \"/test.txt\", got \"${target}\"`);\n return `target=\"${target}\"`;\n }),\n );\n\n results.push(\n await runTest(\"fs.rename\", async () => {\n await fs.writeFile(\"/rename-me.txt\", \"moving\");\n await fs.rename(\"/rename-me.txt\", \"/renamed.txt\");\n const gone = await fs.exists(\"/rename-me.txt\");\n const there = await fs.exists(\"/renamed.txt\");\n if (gone) throw new Error(\"Old path still exists\");\n if (!there) throw new Error(\"New path doesn't exist\");\n const content = await fs.readFile(\"/renamed.txt\", \"utf-8\");\n if (content !== \"moving\") throw new Error(\"Content lost during rename\");\n }),\n );\n\n results.push(\n await runTest(\"fs.readFileAt (partial read)\", async () => {\n await fs.writeFile(\"/partial.txt\", \"abcdefghijklmnop\");\n const chunk = await fs.readFileAt(\"/partial.txt\", 4, 4);\n const text = new TextDecoder().decode(chunk);\n if (text !== \"efgh\") throw new Error(`Expected \"efgh\", got \"${text}\"`);\n return `\"${text}\"`;\n }),\n );\n\n // ── Cleanup ──────────────────────────────────────────────────────\n results.push(\n await runTest(\"cleanup\", async () => {\n for (const p of [\"/test.txt\", \"/test-link.txt\", \"/test-sym.txt\", \"/renamed.txt\", \"/partial.txt\"]) {\n if (await fs.exists(p)) await fs.deleteFile(p);\n }\n for (const p of [\"/mydir/a.txt\", \"/mydir/b.txt\"]) {\n if (await fs.exists(p)) await fs.deleteFile(p);\n }\n if (await fs.exists(\"/mydir\")) await fs.rmdir(\"/mydir\");\n for (const p of [\"/deep/nested/dir/file.md\"]) {\n if (await fs.exists(p)) await fs.deleteFile(p);\n }\n // Clean nested dirs\n for (const d of [\"/deep/nested/dir\", \"/deep/nested\", \"/deep\"]) {\n if (await fs.exists(d)) await fs.rmdir(d);\n }\n }),\n );\n\n // ── Format output ────────────────────────────────────────────────\n const passed = results.filter((r) => r.ok).length;\n const failed = results.filter((r) => !r.ok).length;\n\n const lines = results.map((r) => {\n const icon = r.ok ? \"PASS\" : \"FAIL\";\n return `[${icon}] ${r.name}${r.detail ? ` — ${r.detail}` : \"\"}`;\n });\n\n lines.push(\"\");\n lines.push(`${passed} passed, ${failed} failed, ${results.length} total`);\n\n return new Response(lines.join(\"\\n\"), {\n status: failed > 0 ? 500 : 200,\n headers: { \"content-type\": \"text/plain; charset=utf-8\" },\n });\n}\n",[178],"2d9c2c3e-2fef-11f1-8aaf-42dde27851f2","kv.ts","2d9c2cfc-2fef-11f1-8aaf-42dde27851f2",8,["D",1775283973401],"/**\n * AgentFS Key-Value Store\n *\n * Simple get/set/delete/list for agent context and structured state.\n * Values are JSON-serialized on write and deserialized on read.\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type { KVEntry } from \"./types.ts\";\n\n/**\n * Set a key-value pair. Upserts — creates if new, updates if existing.\n * The value is JSON-serialized before storage.\n */\nexport async function set(key: string, value: unknown): Promise {\n const serialized = JSON.stringify(value);\n await sqlite.execute({\n sql: `INSERT INTO kv_store (key, value, updated_at)\n VALUES (?, ?, unixepoch())\n ON CONFLICT(key) DO UPDATE SET\n value = excluded.value,\n updated_at = unixepoch()`,\n args: [key, serialized],\n });\n}\n\n/**\n * Get a value by key. Returns the deserialized value, or undefined if not found.\n */\nexport async function get(key: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT value FROM kv_store WHERE key = ?`,\n args: [key],\n });\n if (result.rows.length === 0) return undefined;\n return JSON.parse(result.rows[0].value as string) as T;\n}\n\n/**\n * Delete a key-value pair. No-op if the key doesn't exist.\n */\nexport async function del(key: string): Promise {\n await sqlite.execute({\n sql: `DELETE FROM kv_store WHERE key = ?`,\n args: [key],\n });\n}\n\n/**\n * Check if a key exists.\n */\nexport async function has(key: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT 1 FROM kv_store WHERE key = ?`,\n args: [key],\n });\n return result.rows.length > 0;\n}\n\n/**\n * List all keys, optionally filtered by prefix.\n * Returns metadata (key, timestamps) without values for efficiency.\n */\nexport async function list(\n prefix?: string,\n): Promise> {\n if (prefix) {\n const result = await sqlite.execute({\n sql: `SELECT key, created_at, updated_at FROM kv_store\n WHERE key LIKE ? ORDER BY key ASC`,\n args: [prefix + \"%\"],\n });\n return result.rows as Array<{\n key: string;\n created_at: number;\n updated_at: number;\n }>;\n }\n\n const result = await sqlite.execute({\n sql: `SELECT key, created_at, updated_at FROM kv_store ORDER BY key ASC`,\n args: [],\n });\n return result.rows as Array<{\n key: string;\n created_at: number;\n updated_at: number;\n }>;\n}\n\n/**\n * Get the full KV entry including metadata.\n */\nexport async function getEntry(key: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT key, value, created_at, updated_at FROM kv_store WHERE key = ?`,\n args: [key],\n });\n if (result.rows.length === 0) return undefined;\n return result.rows[0] as unknown as KVEntry;\n}\n",[186],"ffb84396-2ff0-11f1-8cb7-42dde27851f2","fs.ts","74970d2a-2fef-11f1-b8d6-42dde27851f2",16,["D",1775284755396],"/**\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",[193],"07965bc4-2ff2-11f1-85d0-42dde27851f2",["D",1775285198090],[29],"pulls","branches","forks","envVars",{"_209":144,"_211":144},"connections",{"_209":144,"_210":144},"count","unfilledCount","emptyCount",{"_43":199,"_33":29,"_31":32,"_140":-5,"_41":42,"_40":14,"_142":27,"_38":246,"_13":61,"_35":36,"_37":-5,"_24":27,"_146":-5,"_222":247,"_28":248},{"_43":192,"_33":193,"_31":194,"_140":-5,"_41":42,"_40":195,"_142":25,"_38":243,"_13":61,"_35":20,"_37":197,"_24":27,"_146":-5,"_222":244,"_28":245},{"_43":185,"_33":186,"_31":187,"_140":-5,"_41":42,"_40":188,"_142":25,"_38":240,"_13":144,"_35":20,"_37":190,"_24":27,"_146":-5,"_222":241,"_28":242},{"_43":177,"_33":178,"_31":179,"_140":-5,"_41":42,"_40":180,"_142":27,"_38":237,"_13":141,"_35":182,"_37":183,"_24":27,"_146":-5,"_222":238,"_28":239},{"_43":170,"_33":171,"_31":172,"_140":-5,"_41":42,"_40":173,"_142":25,"_38":234,"_13":144,"_35":20,"_37":175,"_24":27,"_146":-5,"_222":235,"_28":236},{"_43":163,"_33":164,"_31":165,"_140":-5,"_41":42,"_40":166,"_142":25,"_38":231,"_13":144,"_35":20,"_37":168,"_24":27,"_146":-5,"_222":232,"_28":233},{"_43":155,"_33":156,"_31":157,"_140":-5,"_41":42,"_40":158,"_142":27,"_38":228,"_13":144,"_35":160,"_37":161,"_24":27,"_146":-5,"_222":229,"_28":230},{"_43":148,"_33":149,"_31":150,"_140":-5,"_41":42,"_40":151,"_142":25,"_38":225,"_13":144,"_35":20,"_37":153,"_24":27,"_146":-5,"_222":226,"_28":227},{"_43":137,"_33":138,"_31":139,"_140":-5,"_41":42,"_40":141,"_142":25,"_38":221,"_13":144,"_35":20,"_37":145,"_24":27,"_146":-5,"_222":223,"_28":224},["D",1775283940460],"children",[],[138],["D",1775284023483],[],[149],["D",1775284424884],[],[156],["D",1775283959685],[],[164],["D",1775284102955],[],[171],["D",1775284181484],[],[178],["D",1775283973401],[],[186],["D",1775284755396],[],[193],["D",1775285198090],[],[29],["D",1775283063025],["D",1789556471789],{"_98":97,"_105":101},{"_98":97,"_99":-5,"_100":101,"_18":55,"_102":103,"_104":27},{"_13":87,"_33":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_125":287,"_288":289,"_290":291,"_292":27,"_293":27,"_294":27,"_295":25,"_296":-5,"_297":-7,"_298":-7,"_299":144,"_300":27,"_301":27,"_302":-5,"_303":27,"_304":27,"_305":27,"_306":-5},"ENV",{"_258":259,"_260":261,"_262":88,"_263":264,"_265":266,"_267":268,"_269":270,"_271":272,"_273":274,"_275":276,"_277":278,"_279":280,"_281":282,"_283":284,"_285":286},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","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",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v19