[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_230":231,"_232":233},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_106":88,"_27":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":124,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_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":25},"version",12,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","0efdef3a-2fed-11f1-ad2f-42dde27851f2","name","fileType","http","content","/**\n * AgentFS × Val Town PoC\n *\n * Implements a DatabasePromise adapter for Val Town's native SQLite,\n * then uses AgentFS.openWith() to run the full AgentFS SDK against it.\n *\n * Run as an HTTP val to see results.\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { AgentFS } from \"https://esm.sh/agentfs-sdk\";\n\n// ─── Val Town SQLite → DatabasePromise adapter ───────────────────────\n\n/**\n * Deferred statement that bridges the sync prepare() / async execute() gap.\n *\n * DatabasePromise.prepare() must return synchronously, but Val Town's\n * sqlite.execute() is always async. We store the SQL and defer execution\n * to run/get/all — which are already async in AgentFS internals.\n */\nclass ValTownStatement {\n private sql: string;\n private _raw = false;\n private _pluck = false;\n\n constructor(sql: string) {\n this.sql = sql;\n }\n\n raw(toggle?: boolean): this {\n this._raw = toggle !== false;\n return this;\n }\n\n pluck(toggle?: boolean): this {\n this._pluck = toggle !== false;\n return this;\n }\n\n safeIntegers(_toggle?: boolean): this {\n return this; // Val Town doesn't support BigInt mode\n }\n\n columns(): any[] {\n throw new Error(\"columns() not supported in Val Town adapter\");\n }\n\n get source(): void {\n return undefined;\n }\n get reader(): void {\n return undefined;\n }\n get database(): any {\n return undefined;\n }\n\n /**\n * Convert a result set to the format AgentFS expects.\n *\n * Val Town sqlite.execute returns { columns: string[], rows: any[][] }.\n * - Default (raw=false): return objects keyed by column name\n * - raw=true: return arrays\n * - pluck=true: return first column value only\n */\n private formatRows(columns: string[], rows: any[][]): any[] {\n if (this._pluck) {\n return rows.map((row) => row[0]);\n }\n if (this._raw) {\n return rows;\n }\n // Object mode (default for better-sqlite3 compat)\n return rows.map((row) =>\n Object.fromEntries(columns.map((col, i) => [col, row[i]]))\n );\n }\n\n async run(\n ...args: any[]\n ): Promise<{ changes: number; lastInsertRowid: number }> {\n const result = await sqlite.execute({\n sql: this.sql,\n args: args.flat(),\n });\n return {\n changes: result.rowsAffected ?? 0,\n lastInsertRowid: Number(result.lastInsertRowid ?? 0),\n };\n }\n\n async get(...args: any[]): Promise {\n const result = await sqlite.execute({\n sql: this.sql,\n args: args.flat(),\n });\n const formatted = this.formatRows(result.columns ?? [], result.rows ?? []);\n return formatted[0] ?? undefined;\n }\n\n async all(...args: any[]): Promise {\n const result = await sqlite.execute({\n sql: this.sql,\n args: args.flat(),\n });\n return this.formatRows(result.columns ?? [], result.rows ?? []);\n }\n\n async *iterate(...args: any[]): AsyncGenerator {\n const rows = await this.all(...args);\n for (const row of rows) {\n yield row;\n }\n }\n\n bind(..._args: any[]): this {\n throw new Error(\"bind() not supported — pass parameters to run/get/all\");\n }\n\n interrupt(): void {}\n close(): void {}\n}\n\nfunction notSupported(name: string): () => never {\n return () => {\n throw new Error(`${name}() is not supported in Val Town adapter`);\n };\n}\n\n/**\n * Create a DatabasePromise-compatible wrapper around Val Town's sqlite.\n *\n * This is the equivalent of agentfs-sdk/serverless's createServerlessAdapter,\n * but targeting Val Town's @val-town/sqlite instead of @tursodatabase/serverless.\n */\nfunction createValTownAdapter() {\n return {\n name: \"valtown\",\n readonly: false,\n open: true,\n memory: false,\n inTransaction: false,\n\n async connect(): Promise {\n await sqlite.execute(\"SELECT 1\");\n },\n\n prepare(sql: string): ValTownStatement {\n return new ValTownStatement(sql);\n },\n\n transaction(fn: (...args: any[]) => Promise) {\n // Val Town doesn't expose interactive transactions, so we\n // use batch() with BEGIN/COMMIT framing. For the PoC we\n // fall back to just running the function — AgentFS's own\n // transactions are mostly schema init + single writes.\n return (...bindParameters: any[]) => fn(...bindParameters);\n },\n\n async exec(sql: string): Promise {\n // exec() can contain multiple statements separated by ;\n // Val Town's sqlite.batch handles this pattern\n const statements = sql\n .split(\";\")\n .map((s) => s.trim())\n .filter((s) => s.length > 0);\n\n if (statements.length === 1) {\n await sqlite.execute(statements[0]);\n } else {\n await sqlite.batch(statements.map((s) => ({ sql: s, args: [] })));\n }\n },\n\n pragma(): Promise {\n throw new Error(\"pragma() not supported in Val Town\");\n },\n\n backup: notSupported(\"backup\"),\n serialize: notSupported(\"serialize\"),\n function: notSupported(\"function\"),\n aggregate: notSupported(\"aggregate\"),\n table: notSupported(\"table\"),\n loadExtension: notSupported(\"loadExtension\"),\n maxWriteReplicationIndex: notSupported(\"maxWriteReplicationIndex\"),\n interrupt: notSupported(\"interrupt\"),\n\n defaultSafeIntegers(_toggle?: boolean) {},\n\n async close(): Promise {\n // Val Town manages connection lifecycle\n },\n } as any; // cast to DatabasePromise\n}\n\n// ─── PoC: exercise AgentFS against Val Town SQLite ───────────────────\n\nexport default async function handler(req: Request): Promise {\n const results: string[] = [];\n const log = (msg: string) => results.push(msg);\n\n try {\n // 1. Create adapter and open AgentFS\n log(\"→ Creating Val Town adapter...\");\n const db = createValTownAdapter();\n\n log(\"→ Opening AgentFS with openWith()...\");\n const agent = await AgentFS.openWith(db);\n log(\"✓ AgentFS opened successfully\");\n\n // 2. Test KV store\n log(\"\\n--- Key-Value Store ---\");\n await agent.kv.set(\"test:greeting\", { message: \"hello from val town\" });\n log(\"✓ kv.set() succeeded\");\n\n const greeting = await agent.kv.get(\"test:greeting\");\n log(`✓ kv.get() → ${JSON.stringify(greeting)}`);\n\n await agent.kv.set(\"test:counter\", 42);\n const counter = await agent.kv.get(\"test:counter\");\n log(`✓ kv counter → ${counter}`);\n\n const keys = await agent.kv.list(\"test:\");\n log(`✓ kv.list(\"test:\") → ${keys.length} entries`);\n\n // 3. Test filesystem\n log(\"\\n--- Filesystem ---\");\n await agent.fs.writeFile(\"/hello.txt\", \"Hello from AgentFS on Val Town!\");\n log(\"✓ fs.writeFile() succeeded\");\n\n const content = await agent.fs.readFile(\"/hello.txt\", \"utf-8\");\n log(`✓ fs.readFile() → \"${content}\"`);\n\n const exists = await agent.fs.exists(\"/hello.txt\");\n log(`✓ fs.exists() → ${exists}`);\n\n await agent.fs.writeFile(\"/docs/notes.md\", \"# Notes\\n\\nSome notes here.\");\n const dirEntries = await agent.fs.readdir(\"/\");\n log(`✓ fs.readdir(\"/\") → [${dirEntries.join(\", \")}]`);\n\n // 4. Test tool call tracking\n log(\"\\n--- Tool Calls ---\");\n const now = Date.now() / 1000;\n const toolId = await agent.tools.record(\n \"web_search\",\n now,\n now + 0.5,\n { query: \"val town agentfs\" },\n { results: [\"result1\", \"result2\"] },\n );\n log(`✓ tools.record() → id=${toolId}`);\n\n const toolCall = await agent.tools.get(toolId);\n log(\n `✓ tools.get() → name=\"${toolCall?.name}\", params=${\n JSON.stringify(toolCall?.parameters)\n }`,\n );\n\n // 5. Cleanup test data\n log(\"\\n--- Cleanup ---\");\n await agent.kv.delete(\"test:greeting\");\n await agent.kv.delete(\"test:counter\");\n await agent.fs.deleteFile(\"/hello.txt\");\n await agent.fs.deleteFile(\"/docs/notes.md\");\n log(\"✓ Cleaned up test data\");\n\n log(\"\\n✅ All tests passed — AgentFS works on Val Town!\");\n } catch (err) {\n log(`\\n❌ Error: ${err instanceof Error ? err.message : String(err)}`);\n log(`Stack: ${err instanceof Error ? err.stack : \"n/a\"}`);\n }\n\n return new Response(results.join(\"\\n\"), {\n headers: { \"content-type\": \"text/plain; charset=utf-8\" },\n });\n}","/**\n * AgentFS test handler — exercises all three subsystems\n * against the val's scoped SQLite database.\n */\n\nimport { init, kv, tools, fs, isDir, isFile } from \"./mod.ts\";\n\nexport default async function handler(_req: Request): Promise {\n const results: string[] = [];\n const log = (msg: string) => results.push(msg);\n const section = (name: string) => log(`\\n--- ${name} ---`);\n\n try {\n // ── Initialize ──────────────────────────────────────────────────\n log(\"Initializing AgentFS...\");\n await init();\n log(\"Schema + root inode ready.\");\n\n // ── KV Store ────────────────────────────────────────────────────\n section(\"Key-Value Store\");\n\n await kv.set(\"test:greeting\", { message: \"hello from agentfs\" });\n const greeting = await kv.get<{ message: string }>(\"test:greeting\");\n log(`set/get: ${greeting?.message}`);\n\n await kv.set(\"test:counter\", 42);\n log(`has(\"test:counter\"): ${await kv.has(\"test:counter\")}`);\n\n const keys = await kv.list(\"test:\");\n log(`list(\"test:\"): ${keys.map((k) => k.key).join(\", \")}`);\n\n await kv.del(\"test:greeting\");\n await kv.del(\"test:counter\");\n log(`cleanup: deleted test keys`);\n\n // ── Tool Calls ──────────────────────────────────────────────────\n section(\"Tool Call Audit Log\");\n\n const t0 = Date.now() / 1000;\n const id = await tools.record({\n name: \"web_search\",\n parameters: { query: \"agentfs val town\" },\n result: { hits: 3 },\n started_at: t0,\n completed_at: t0 + 0.250,\n });\n log(`record: id=${id}`);\n\n const tc = await tools.get(id);\n log(`get: name=\"${tc?.name}\", duration=${tc?.duration_ms}ms`);\n\n // Test the trace() wrapper\n const traced = await tools.trace(\"compute\", { n: 10 }, async () => {\n return 10 * 10;\n });\n log(`trace: result=${traced}`);\n\n const perf = await tools.analyzePerformance();\n log(`performance: ${perf.length} tool(s) tracked`);\n\n // ── Filesystem ──────────────────────────────────────────────────\n section(\"Virtual Filesystem\");\n\n // Write + read\n await fs.writeFile(\"/hello.txt\", \"Hello from AgentFS on Val Town\");\n const content = await fs.readFile(\"/hello.txt\", \"utf-8\");\n log(`writeFile/readFile: \"${content}\"`);\n\n // Stat\n const st = await fs.stat(\"/hello.txt\");\n log(`stat: size=${st.size}, isFile=${isFile(st.mode)}`);\n\n // Overwrite\n await fs.writeFile(\"/hello.txt\", \"Updated content\");\n const updated = await fs.readFile(\"/hello.txt\", \"utf-8\");\n log(`overwrite: \"${updated}\"`);\n\n // Nested directories (auto-created)\n await fs.writeFile(\"/docs/notes/readme.md\", \"# Readme\\nHello.\");\n const dirRoot = await fs.readdir(\"/\");\n log(`readdir(\"/\"): [${dirRoot.join(\", \")}]`);\n\n const dirDocs = await fs.readdir(\"/docs\");\n log(`readdir(\"/docs\"): [${dirDocs.join(\", \")}]`);\n\n // Exists\n log(`exists(\"/hello.txt\"): ${await fs.exists(\"/hello.txt\")}`);\n log(`exists(\"/nope\"): ${await fs.exists(\"/nope\")}`);\n\n // Hard link\n await fs.link(\"/hello.txt\", \"/hello-link.txt\");\n const linkedContent = await fs.readFile(\"/hello-link.txt\", \"utf-8\");\n const linkStat = await fs.stat(\"/hello.txt\");\n log(`link: nlink=${linkStat.nlink}, content=\"${linkedContent}\"`);\n\n // Symlink\n await fs.symlink(\"/hello.txt\", \"/hello-sym.txt\");\n const symTarget = await fs.readlink(\"/hello-sym.txt\");\n log(`symlink: target=\"${symTarget}\"`);\n\n // Rename\n await fs.rename(\"/hello.txt\", \"/renamed.txt\");\n log(`rename: exists(\"/renamed.txt\")=${await fs.exists(\"/renamed.txt\")}, exists(\"/hello.txt\")=${await fs.exists(\"/hello.txt\")}`);\n\n // Partial read\n await fs.writeFile(\"/partial.txt\", \"abcdefghijklmnopqrstuvwxyz\");\n const slice = await fs.readFileAt(\"/partial.txt\", 5, 10);\n log(`readFileAt(5, 10): \"${new TextDecoder().decode(slice)}\"`);\n\n // Cleanup\n section(\"Cleanup\");\n await fs.deleteFile(\"/renamed.txt\");\n await fs.deleteFile(\"/hello-link.txt\");\n await fs.deleteFile(\"/hello-sym.txt\");\n await fs.deleteFile(\"/docs/notes/readme.md\");\n await fs.deleteFile(\"/partial.txt\");\n await fs.rmdir(\"/docs/notes\");\n await fs.rmdir(\"/docs\");\n log(\"Cleaned up test files.\");\n\n log(\"\\nAll tests passed.\");\n } catch (err) {\n log(`\\nERROR: ${err instanceof Error ? err.message : String(err)}`);\n if (err instanceof Error) log(`Stack: ${err.stack}`);\n }\n\n return new Response(results.join(\"\\n\"), {\n headers: { \"content-type\": \"text/plain; charset=utf-8\" },\n });\n}\n","createdAt",["D",1775284126241],"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",1789470042795],"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":25},"branch",{"_13":87,"_32":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,"_32":45,"_38":225,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":226,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":227,"_82":228,"_84":229,"_86":25},"tree",[196,197,198,199,200,201,202],"files",[196,197,198,199,200,201,202],"counts",{"_186":143,"_187":61,"_188":143,"_189":190,"_191":192},"contents",[129,130,131,132,133,134,135],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":179,"_32":180,"_30":181,"_139":-5,"_41":42,"_40":182,"_141":25,"_38":183,"_13":143,"_33":20,"_35":184,"_24":25,"_145":-5,"_27":185},{"_43":172,"_32":173,"_30":174,"_139":-5,"_41":42,"_40":175,"_141":124,"_38":176,"_13":143,"_33":20,"_35":177,"_24":25,"_145":-5,"_27":178},{"_43":168,"_32":28,"_30":31,"_139":-5,"_41":42,"_40":14,"_141":25,"_38":169,"_13":170,"_33":34,"_35":37,"_24":25,"_145":-5,"_27":171},{"_43":161,"_32":162,"_30":163,"_139":-5,"_41":42,"_40":164,"_141":124,"_38":165,"_13":143,"_33":20,"_35":166,"_24":25,"_145":-5,"_27":167},{"_43":154,"_32":155,"_30":156,"_139":-5,"_41":42,"_40":157,"_141":124,"_38":158,"_13":143,"_33":20,"_35":159,"_24":25,"_145":-5,"_27":160},{"_43":147,"_32":148,"_30":149,"_139":-5,"_41":42,"_40":150,"_141":124,"_38":151,"_13":143,"_33":20,"_35":152,"_24":25,"_145":-5,"_27":153},{"_43":136,"_32":137,"_30":138,"_139":-5,"_41":42,"_40":140,"_141":124,"_38":142,"_13":143,"_33":20,"_35":144,"_24":25,"_145":-5,"_27":146},"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",[137],"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",[148],"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",[155],"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",[162],"88b61620-2fef-11f1-9921-42dde27851f2",["D",1775284126241],5,[28],"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",[173],"74970c6c-2fef-11f1-b8d6-42dde27851f2","fs.ts","74970d2a-2fef-11f1-b8d6-42dde27851f2",10,["D",1775284092489],"/**\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// ─── 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 // Reassemble chunks\n const chunks = res.rows.map((r: any) => {\n const d = r.data;\n if (d instanceof Uint8Array) return d;\n if (typeof d === \"string\") return new TextEncoder().encode(d);\n // Handle base64 or other encodings from Turso\n if (ArrayBuffer.isView(d)) return new Uint8Array(d.buffer, d.byteOffset, d.byteLength);\n return new Uint8Array(0);\n });\n\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\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 // Reassemble the relevant chunks\n const chunks = res.rows.map((r: any) => {\n const d = r.data;\n if (d instanceof Uint8Array) return d;\n if (typeof d === \"string\") return new TextEncoder().encode(d);\n if (ArrayBuffer.isView(d)) return new Uint8Array(d.buffer, d.byteOffset, d.byteLength);\n return new Uint8Array(0);\n });\n\n const totalLen = chunks.reduce((sum, c) => sum + c.length, 0);\n const combined = new Uint8Array(totalLen);\n let pos = 0;\n for (const chunk of chunks) {\n combined.set(chunk, pos);\n pos += chunk.length;\n }\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",[180],"pulls","branches","forks","envVars",{"_193":143,"_195":143},"connections",{"_193":143,"_194":143},"count","unfilledCount","emptyCount",{"_43":179,"_32":180,"_30":181,"_139":-5,"_41":42,"_40":182,"_141":25,"_38":222,"_13":143,"_33":20,"_35":184,"_24":25,"_145":-5,"_204":223,"_27":224},{"_43":172,"_32":173,"_30":174,"_139":-5,"_41":42,"_40":175,"_141":124,"_38":219,"_13":143,"_33":20,"_35":177,"_24":25,"_145":-5,"_204":220,"_27":221},{"_43":168,"_32":28,"_30":31,"_139":-5,"_41":42,"_40":14,"_141":25,"_38":216,"_13":170,"_33":34,"_35":37,"_24":25,"_145":-5,"_204":217,"_27":218},{"_43":161,"_32":162,"_30":163,"_139":-5,"_41":42,"_40":164,"_141":124,"_38":213,"_13":143,"_33":20,"_35":166,"_24":25,"_145":-5,"_204":214,"_27":215},{"_43":154,"_32":155,"_30":156,"_139":-5,"_41":42,"_40":157,"_141":124,"_38":210,"_13":143,"_33":20,"_35":159,"_24":25,"_145":-5,"_204":211,"_27":212},{"_43":147,"_32":148,"_30":149,"_139":-5,"_41":42,"_40":150,"_141":124,"_38":207,"_13":143,"_33":20,"_35":152,"_24":25,"_145":-5,"_204":208,"_27":209},{"_43":136,"_32":137,"_30":138,"_139":-5,"_41":42,"_40":140,"_141":124,"_38":203,"_13":143,"_33":20,"_35":144,"_24":25,"_145":-5,"_204":205,"_27":206},["D",1775283940460],"children",[],[137],["D",1775284023483],[],[148],["D",1775283959685],[],[155],["D",1775284102955],[],[162],["D",1775284126241],[],[28],["D",1775283973401],[],[173],["D",1775284092489],[],[180],["D",1775283063025],["D",1789470042795],{"_98":97,"_105":101},{"_98":97,"_99":-5,"_100":101,"_18":55,"_102":103,"_104":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_126":263,"_264":265,"_266":267,"_268":25,"_269":25,"_270":25,"_271":124,"_272":-5,"_273":-7,"_274":-7,"_275":143,"_276":25,"_277":25,"_278":-5,"_279":25,"_280":25,"_281":25,"_282":-5},"ENV",{"_234":235,"_236":237,"_238":88,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262},"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 · v12