Hi

\"\n});\n```\n\n## Val Town Utility Functions\n\nVal Town provides several utility functions to help with common project tasks.\n\n### Importing Utilities\n\nAlways import utilities with version pins to avoid breaking changes:\n\n```ts\nimport { parseProject, readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n```\n\n### Available Utilities\n\n\n#### **serveFile** - Serve project files with proper content types\n\nFor example, in Hono:\n\n```ts\n// serve all files in frontend/ and shared/\napp.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n```\n\n#### **readFile** - Read files from within the project:\n\n```ts\n// Read a file from the project\nconst fileContent = await readFile(\"/frontend/index.html\", import.meta.url);\n```\n\n#### **listFiles** - List all files in the project\n\n```ts\nconst files = await listFiles(import.meta.url);\n```\n\n#### **parseProject** - Extract information about the current project from import.meta.url\n\nThis is useful for including info for linking back to a val, ie in \"view source\" urls:\n\n```ts\nconst projectVal = parseProject(import.meta.url);\nconsole.log(projectVal.username); // Owner of the project\nconsole.log(projectVal.name); // Project name\nconsole.log(projectVal.version); // Version number\nconsole.log(projectVal.branch); // Branch name\nconsole.log(projectVal.links.self.project); // URL to the project page\n```\n\nHowever, it's *extremely importing* to note that `parseProject` and other Standard Library utilities ONLY RUN ON THE SERVER.\nIf you need access to this data on the client, run it in the server and pass it to the client by splicing it into the HTML page\nor by making an API request for it.\n\n## Val Town Platform Specifics\n\n- **Redirects:** Use `return new Response(null, { status: 302, headers: { Location: \"/place/to/redirect\" }})` instead of `Response.redirect` which is broken\n- **Images:** Avoid external images or base64 images. Use emojis, unicode symbols, or icon fonts/libraries instead\n- **AI Image:** To inline generate an AI image use: `

`\n- **Storage:** DO NOT use the Deno KV module for storage\n- **Browser APIs:** DO NOT use the `alert()`, `prompt()`, or `confirm()` methods\n- **Weather Data:** Use open-meteo for weather data (doesn't require API keys) unless otherwise specified\n- **View Source:** Add a view source link by importing & using `import.meta.url.replace(\"ems.sh\", \"val.town)\"` (or passing this data to the client) and include `target=\"_top\"` attribute\n- **Error Debugging:** Add `` to HTML to capture client-side errors\n- **Error Handling:** Only use try...catch when there's a clear local resolution; Avoid catches that merely log or return 500s. Let errors bubble up with full context\n- **Environment Variables:** Use `Deno.env.get('keyname')` when you need to, but generally prefer APIs that don't require keys\n- **Imports:** Use `https://esm.sh` for npm and Deno dependencies to ensure compatibility on server and browser\n- **Storage Strategy:** Only use backend storage if explicitly required; prefer simple static client-side sites\n- **React Configuration:** When using React libraries, pin versions with `?deps=react@18.2.0,react-dom@18.2.0` and start the file with `/** @jsxImportSource https://esm.sh/react@18.2.0 */`\n- Ensure all React dependencies and sub-dependencies are pinned to the same version\n- **Styling:** Default to using TailwindCSS via `` unless otherwise specified\n\n## Project Structure and Design Patterns\n\n### Recommended Directory Structure\n```\n├── backend/\n│ ├── database/\n│ │ ├── migrations.ts # Schema definitions\n│ │ ├── queries.ts # DB query functions\n│ │ └── README.md\n│ └── routes/ # Route modules\n│ ├── [route].ts\n│ └── static.ts # Static file serving\n│ ├── index.ts # Main entry point\n│ └── README.md\n├── frontend/\n│ ├── components/\n│ │ ├── App.tsx\n│ │ └── [Component].tsx\n│ ├── favicon.svg\n│ ├── index.html # Main HTML template\n│ ├── index.tsx # Frontend JS entry point\n│ ├── README.md\n│ └── style.css\n├── README.md\n└── shared/\n ├── README.md\n └── utils.ts # Shared types and functions\n```\n\n### Backend (Hono) Best Practices\n\n- Hono is the recommended API framework\n- Main entry point should be `backend/index.ts`\n- **Static asset serving:** Use the utility functions to read and serve project files:\n ```ts\n import { readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n \n // serve all files in frontend/ and shared/\n app.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\n app.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n \n // For index.html, often you'll want to bootstrap with initial data\n app.get(\"/\", async c => {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n \n // Inject data to avoid extra round-trips\n const initialData = await fetchInitialData();\n const dataScript = ``;\n \n html = html.replace(\"\", `${dataScript}`);\n return c.html(html);\n });\n ```\n- Create RESTful API routes for CRUD operations\n- Always include this snippet at the top-level Hono app to re-throwing errors to see full stack traces:\n ```ts\n // Unwrap Hono errors to see original error details\n app.onError((err, c) => {\n throw err;\n });\n ```\n\n### Database Patterns\n- Run migrations on startup or comment out for performance\n- Change table names when modifying schemas rather than altering\n- Export clear query functions with proper TypeScript typing\n\n## Common Gotchas and Solutions\n\n1. **Environment Limitations:** \n - Val Town runs on Deno in a serverless context, not Node.js\n - Code in `shared/` must work in both frontend and backend environments\n - Cannot use `Deno` keyword in shared code\n - Use `https://esm.sh` for imports that work in both environments\n\n2. **SQLite Peculiarities:**\n - Limited support for ALTER TABLE operations\n - Create new tables with updated schemas and copy data when needed\n - Always run table creation before querying\n\n3. **React Configuration:**\n - All React dependencies must be pinned to 18.2.0\n - Always include `@jsxImportSource https://esm.sh/react@18.2.0` at the top of React files\n - Rendering issues often come from mismatched React versions\n\n4. **File Handling:**\n - Val Town only supports text files, not binary\n - Use the provided utilities to read files across branches and forks\n - For files in the project, use `readFile` helpers\n\n5. **API Design:**\n - `fetch` handler is the entry point for HTTP vals\n - Run the Hono app with `export default app.fetch // This is the entry point for HTTP vals`\n\n",[151],"1eb0c90e-9464-11f0-a007-0224a6c84d84",".vtignore","1eb0c9ea-9464-11f0-a007-0224a6c84d84",["D",1758181815811],".git\n.DS_Store\nnode_modules\nvendor",[158],"1d17cd2c-9464-11f0-99cc-0224a6c84d84","src","1d17cf48-9464-11f0-99cc-0224a6c84d84",2,["D",1758181815414],"directory",[164],"1cfa2fb0-9464-11f0-9551-0224a6c84d84","examples","1cfa306e-9464-11f0-9551-0224a6c84d84",1,["D",1758181815221],[171],"pulls","forks","envVars",{"_182":54,"_184":54},"connections",{"_182":54,"_183":54},"count","unfilledCount","emptyCount",{"_20":170,"_13":171,"_121":172,"_123":-5,"_124":21,"_125":173,"_127":50,"_22":265,"_29":54,"_129":168,"_131":-5,"_133":38,"_134":-5,"_199":266,"_90":267},{"_20":257,"_13":258,"_121":259,"_123":172,"_124":21,"_125":260,"_127":50,"_22":261,"_29":54,"_129":130,"_131":262,"_133":38,"_134":-5,"_199":263,"_90":264},{"_20":250,"_13":251,"_121":48,"_123":172,"_124":21,"_125":252,"_127":50,"_22":253,"_29":54,"_129":246,"_131":254,"_133":38,"_134":-5,"_199":255,"_90":256},{"_20":241,"_13":242,"_121":243,"_123":172,"_124":21,"_125":244,"_127":50,"_22":245,"_29":54,"_129":246,"_131":247,"_133":38,"_134":-5,"_199":248,"_90":249},{"_20":163,"_13":164,"_121":165,"_123":-5,"_124":21,"_125":166,"_127":50,"_22":238,"_29":54,"_129":168,"_131":-5,"_133":38,"_134":-5,"_199":239,"_90":240},{"_20":230,"_13":231,"_121":232,"_123":165,"_124":21,"_125":233,"_127":50,"_22":234,"_29":54,"_129":130,"_131":235,"_133":38,"_134":-5,"_199":236,"_90":237},{"_20":222,"_13":223,"_121":224,"_123":165,"_124":21,"_125":225,"_127":50,"_22":226,"_29":54,"_129":130,"_131":227,"_133":38,"_134":-5,"_199":228,"_90":229},{"_20":214,"_13":215,"_121":216,"_123":165,"_124":21,"_125":217,"_127":50,"_22":218,"_29":54,"_129":130,"_131":219,"_133":38,"_134":-5,"_199":220,"_90":221},{"_20":157,"_13":158,"_121":159,"_123":-5,"_124":21,"_125":30,"_127":50,"_22":211,"_29":54,"_129":101,"_131":161,"_133":38,"_134":-5,"_199":212,"_90":213},{"_20":150,"_13":151,"_121":152,"_123":-5,"_124":21,"_125":153,"_127":50,"_22":208,"_29":54,"_129":101,"_131":155,"_133":38,"_134":-5,"_199":209,"_90":210},{"_20":143,"_13":144,"_121":145,"_123":-5,"_124":21,"_125":146,"_127":50,"_22":205,"_29":54,"_129":101,"_131":148,"_133":38,"_134":-5,"_199":206,"_90":207},{"_20":136,"_13":137,"_121":138,"_123":-5,"_124":21,"_125":139,"_127":50,"_22":202,"_29":54,"_129":101,"_131":141,"_133":38,"_134":-5,"_199":203,"_90":204},{"_20":119,"_13":120,"_121":122,"_123":-5,"_124":21,"_125":126,"_127":50,"_22":198,"_29":54,"_129":130,"_131":132,"_133":38,"_134":-5,"_199":200,"_90":201},["D",1758181815799],"children",[],[120],["D",1758181815808],[],[137],["D",1758181815802],[],[144],["D",1758181815838],[],[151],["D",1758181815811],[],[158],"1d5743d0-9464-11f0-ae79-0224a6c84d84","migrations.ts","1d574498-9464-11f0-ae79-0224a6c84d84",4,["D",1758181815832],"/**\n * Migration utilities for JsonDB\n * Provides tools for managing database schema changes and data migrations\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nexport interface Migration {\n version: number;\n name: string;\n up: () => Promise;\n down: () => Promise;\n}\n\nexport interface MigrationResult {\n success: boolean;\n version: number;\n message: string;\n error?: string;\n}\n\nexport class MigrationManager {\n private migrations: Migration[] = [];\n private currentVersion: number = 0;\n\n constructor() {\n this.initialize();\n }\n\n /**\n * Initialize the migration system\n */\n private async initialize(): Promise {\n try {\n // Create migrations table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS _migrations (\n version INTEGER PRIMARY KEY,\n name TEXT NOT NULL,\n applied_at TEXT NOT NULL\n )\n `);\n\n // Get current version\n const result = await sqlite.execute(`\n SELECT MAX(version) as version FROM _migrations\n `);\n \n this.currentVersion = result.rows[0][0] as number || 0;\n } catch (error) {\n console.error('Failed to initialize migration system:', error);\n throw error;\n }\n }\n\n /**\n * Add a migration\n */\n addMigration(migration: Migration): void {\n this.migrations.push(migration);\n // Sort by version\n this.migrations.sort((a, b) => a.version - b.version);\n }\n\n /**\n * Get all available migrations\n */\n getMigrations(): Migration[] {\n return [...this.migrations];\n }\n\n /**\n * Get current database version\n */\n getCurrentVersion(): number {\n return this.currentVersion;\n }\n\n /**\n * Get pending migrations\n */\n getPendingMigrations(): Migration[] {\n return this.migrations.filter(m => m.version > this.currentVersion);\n }\n\n /**\n * Run all pending migrations\n */\n async migrate(): Promise {\n const results: MigrationResult[] = [];\n const pending = this.getPendingMigrations();\n\n for (const migration of pending) {\n try {\n await migration.up();\n \n // Record the migration\n await sqlite.execute(`\n INSERT INTO _migrations (version, name, applied_at) VALUES (?, ?, ?)\n `, [migration.version, migration.name, new Date().toISOString()]);\n\n this.currentVersion = migration.version;\n\n results.push({\n success: true,\n version: migration.version,\n message: `Migration ${migration.name} applied successfully`\n });\n\n console.log(`✅ Migration ${migration.name} (v${migration.version}) applied`);\n } catch (error) {\n const errorMessage = error instanceof Error ? error.message : 'Unknown error';\n \n results.push({\n success: false,\n version: migration.version,\n message: `Migration ${migration.name} failed`,\n error: errorMessage\n });\n\n console.error(`❌ Migration ${migration.name} (v${migration.version}) failed:`, error);\n \n // Stop on first failure\n break;\n }\n }\n\n return results;\n }\n\n /**\n * Rollback to a specific version\n */\n async rollback(targetVersion: number): Promise {\n const results: MigrationResult[] = [];\n const migrationsToRollback = this.migrations\n .filter(m => m.version > targetVersion && m.version <= this.currentVersion)\n .sort((a, b) => b.version - a.version); // Reverse order for rollback\n\n for (const migration of migrationsToRollback) {\n try {\n await migration.down();\n \n // Remove the migration record\n await sqlite.execute(`\n DELETE FROM _migrations WHERE version = ?\n `, [migration.version]);\n\n this.currentVersion = migration.version - 1;\n\n results.push({\n success: true,\n version: migration.version,\n message: `Migration ${migration.name} rolled back successfully`\n });\n\n console.log(`↩️ Migration ${migration.name} (v${migration.version}) rolled back`);\n } catch (error) {\n const errorMessage = error instanceof Error ? error.message : 'Unknown error';\n \n results.push({\n success: false,\n version: migration.version,\n message: `Failed to rollback migration ${migration.name}`,\n error: errorMessage\n });\n\n console.error(`❌ Rollback of ${migration.name} (v${migration.version}) failed:`, error);\n \n // Stop on first failure\n break;\n }\n }\n\n return results;\n }\n\n /**\n * Reset database (rollback all migrations)\n */\n reset(): Promise {\n return this.rollback(0);\n }\n\n /**\n * Get migration history\n */\n async getHistory(): Promise> {\n try {\n const result = await sqlite.execute(`\n SELECT version, name, applied_at FROM _migrations ORDER BY version ASC\n `);\n\n return result.rows.map(row => ({\n version: row[0] as number,\n name: row[1] as string,\n applied_at: row[2] as string\n }));\n } catch (error) {\n console.error('Failed to get migration history:', error);\n return [];\n }\n }\n\n /**\n * Check if database is up to date\n */\n isUpToDate(): boolean {\n return this.getPendingMigrations().length === 0;\n }\n}\n\n// Predefined migrations for JsonDB\nexport const createDefaultMigrations = (): Migration[] => [\n {\n version: 1,\n name: \"create_collections_metadata\",\n up: async () => {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS _collections_metadata (\n name TEXT PRIMARY KEY,\n created_at TEXT NOT NULL,\n last_modified TEXT NOT NULL,\n schema_version INTEGER DEFAULT 1\n )\n `);\n },\n down: async () => {\n await sqlite.execute(`DROP TABLE IF EXISTS _collections_metadata`);\n }\n },\n {\n version: 2,\n name: \"create_documents_table\",\n up: async () => {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS _documents (\n id TEXT PRIMARY KEY,\n collection TEXT NOT NULL,\n data TEXT NOT NULL,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL,\n FOREIGN KEY (collection) REFERENCES _collections_metadata(name)\n )\n `);\n },\n down: async () => {\n await sqlite.execute(`DROP TABLE IF EXISTS _documents`);\n }\n },\n {\n version: 3,\n name: \"create_indexes\",\n up: async () => {\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_documents_collection ON _documents(collection)\n `);\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_documents_created_at ON _documents(created_at)\n `);\n },\n down: async () => {\n await sqlite.execute(`DROP INDEX IF EXISTS idx_documents_collection`);\n await sqlite.execute(`DROP INDEX IF EXISTS idx_documents_created_at`);\n }\n },\n {\n version: 4,\n name: \"add_json_extract_indexes\",\n up: async () => {\n // Add indexes for common JSON field queries\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_documents_json_name \n ON _documents(JSON_EXTRACT(data, '$.name'))\n `);\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_documents_json_email \n ON _documents(JSON_EXTRACT(data, '$.email'))\n `);\n },\n down: async () => {\n await sqlite.execute(`DROP INDEX IF EXISTS idx_documents_json_name`);\n await sqlite.execute(`DROP INDEX IF EXISTS idx_documents_json_email`);\n }\n }\n];\n\n// Export a default migration manager with default migrations\nexport const migrationManager = new MigrationManager();\n\n// Add default migrations\ncreateDefaultMigrations().forEach(migration => {\n migrationManager.addMigration(migration);\n});\n\nexport default MigrationManager;\n",[],[164,215],"1e17af12-9464-11f0-a205-0224a6c84d84","json-db.ts","1e17afda-9464-11f0-a205-0224a6c84d84",12,["D",1758181815813],"import { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// Type definitions for the JSON database\nexport interface Document {\n id?: string;\n [key: string]: any;\n}\n\nexport interface QueryOptions {\n limit?: number;\n offset?: number;\n sort?: { field: string; direction: 'asc' | 'desc' }[];\n where?: Record;\n}\n\nexport interface CollectionStats {\n name: string;\n count: number;\n createdAt: string;\n lastModified: string;\n}\n\nexport interface InsertResult {\n id: string;\n success: boolean;\n}\n\nexport interface UpdateResult {\n modifiedCount: number;\n success: boolean;\n}\n\nexport interface DeleteResult {\n deletedCount: number;\n success: boolean;\n}\n\n/**\n * JSON Database - A document database abstraction over SQLite\n * Provides MongoDB-like interface for Val Town's SQLite\n */\nexport class JsonDB {\n private initialized = false;\n private collections = new Set();\n\n constructor() {\n // Auto-initialize on construction\n this.initialize();\n }\n\n /**\n * Initialize the database and create necessary tables\n */\n private async initialize(): Promise {\n if (this.initialized) return;\n\n try {\n // Create the main collections metadata table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS _collections_metadata (\n name TEXT PRIMARY KEY,\n created_at TEXT NOT NULL,\n last_modified TEXT NOT NULL,\n schema_version INTEGER DEFAULT 1\n )\n `);\n\n // Create the documents table with JSON storage\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS _documents (\n id TEXT PRIMARY KEY,\n collection TEXT NOT NULL,\n data TEXT NOT NULL,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL,\n FOREIGN KEY (collection) REFERENCES _collections_metadata(name)\n )\n `);\n\n // Create indexes for better performance\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_documents_collection ON _documents(collection)\n `);\n \n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_documents_created_at ON _documents(created_at)\n `);\n\n // Load existing collections\n const result = await sqlite.execute(`SELECT name FROM _collections_metadata`);\n for (const row of result.rows) {\n this.collections.add(row[0] as string);\n }\n\n this.initialized = true;\n } catch (error) {\n console.error('Failed to initialize JsonDB:', error);\n throw error;\n }\n }\n\n /**\n * Ensure database is initialized before operations\n */\n private async ensureInitialized(): Promise {\n if (!this.initialized) {\n await this.initialize();\n }\n }\n\n /**\n * Generate a unique ID for documents\n */\n private generateId(): string {\n return `${Date.now()}-${Math.random().toString(36).substr(2, 9)}`;\n }\n\n /**\n * Get current timestamp\n */\n private getTimestamp(): string {\n return new Date().toISOString();\n }\n\n /**\n * Create a new collection\n */\n async createCollection(name: string): Promise {\n await this.ensureInitialized();\n\n if (this.collections.has(name)) {\n return true; // Collection already exists\n }\n\n try {\n const timestamp = this.getTimestamp();\n await sqlite.execute(\n `INSERT INTO _collections_metadata (name, created_at, last_modified) VALUES (?, ?, ?)`,\n [name, timestamp, timestamp]\n );\n\n this.collections.add(name);\n return true;\n } catch (error) {\n console.error(`Failed to create collection ${name}:`, error);\n return false;\n }\n }\n\n /**\n * Drop a collection and all its documents\n */\n async dropCollection(name: string): Promise {\n await this.ensureInitialized();\n\n if (!this.collections.has(name)) {\n return false; // Collection doesn't exist\n }\n\n try {\n // Delete all documents in the collection\n await sqlite.execute(`DELETE FROM _documents WHERE collection = ?`, [name]);\n \n // Delete collection metadata\n await sqlite.execute(`DELETE FROM _collections_metadata WHERE name = ?`, [name]);\n\n this.collections.delete(name);\n return true;\n } catch (error) {\n console.error(`Failed to drop collection ${name}:`, error);\n return false;\n }\n }\n\n /**\n * List all collections\n */\n async listCollections(): Promise {\n await this.ensureInitialized();\n return Array.from(this.collections);\n }\n\n /**\n * Get collection statistics\n */\n async getCollectionStats(name: string): Promise {\n await this.ensureInitialized();\n\n if (!this.collections.has(name)) {\n return null;\n }\n\n try {\n // Get collection metadata\n const metaResult = await sqlite.execute(\n `SELECT created_at, last_modified FROM _collections_metadata WHERE name = ?`,\n [name]\n );\n\n if (metaResult.rows.length === 0) {\n return null;\n }\n\n // Get document count\n const countResult = await sqlite.execute(\n `SELECT COUNT(*) as count FROM _documents WHERE collection = ?`,\n [name]\n );\n\n const meta = metaResult.rows[0];\n const count = countResult.rows[0][0] as number;\n\n return {\n name,\n count,\n createdAt: meta[0] as string,\n lastModified: meta[1] as string\n };\n } catch (error) {\n console.error(`Failed to get stats for collection ${name}:`, error);\n return null;\n }\n }\n\n /**\n * Insert a document into a collection\n */\n async insert(collection: string, document: Document): Promise {\n await this.ensureInitialized();\n await this.createCollection(collection);\n\n try {\n const id = document.id || this.generateId();\n const timestamp = this.getTimestamp();\n const data = JSON.stringify(document);\n\n await sqlite.execute(\n `INSERT INTO _documents (id, collection, data, created_at, updated_at) VALUES (?, ?, ?, ?, ?)`,\n [id, collection, data, timestamp, timestamp]\n );\n\n // Update collection last_modified\n await sqlite.execute(\n `UPDATE _collections_metadata SET last_modified = ? WHERE name = ?`,\n [timestamp, collection]\n );\n\n return { id, success: true };\n } catch (error) {\n console.error(`Failed to insert document into ${collection}:`, error);\n return { id: '', success: false };\n }\n }\n\n /**\n * Insert multiple documents\n */\n async insertMany(collection: string, documents: Document[]): Promise {\n const results: InsertResult[] = [];\n \n for (const doc of documents) {\n const result = await this.insert(collection, doc);\n results.push(result);\n }\n\n return results;\n }\n\n /**\n * Find documents in a collection\n */\n async find(collection: string, options: QueryOptions = {}): Promise {\n await this.ensureInitialized();\n\n if (!this.collections.has(collection)) {\n return [];\n }\n\n try {\n let query = `SELECT data FROM _documents WHERE collection = ?`;\n const params: any[] = [collection];\n\n // Add WHERE conditions\n if (options.where) {\n // For now, we'll do simple field matching\n // In a more advanced implementation, you'd parse the where clause\n // and convert it to SQL WHERE conditions\n for (const [field, value] of Object.entries(options.where)) {\n query += ` AND JSON_EXTRACT(data, '$.${field}') = ?`;\n params.push(JSON.stringify(value));\n }\n }\n\n // Add sorting\n if (options.sort && options.sort.length > 0) {\n const sortClauses = options.sort.map(sort => \n `JSON_EXTRACT(data, '$.${sort.field}') ${sort.direction.toUpperCase()}`\n );\n query += ` ORDER BY ${sortClauses.join(', ')}`;\n }\n\n // Add pagination\n if (options.limit) {\n query += ` LIMIT ${options.limit}`;\n if (options.offset) {\n query += ` OFFSET ${options.offset}`;\n }\n }\n\n const result = await sqlite.execute(query, params);\n \n return result.rows.map(row => {\n try {\n return JSON.parse(row[0] as string);\n } catch (error) {\n console.error('Failed to parse document JSON:', error);\n return null;\n }\n }).filter(doc => doc !== null);\n } catch (error) {\n console.error(`Failed to find documents in ${collection}:`, error);\n return [];\n }\n }\n\n /**\n * Find a single document by ID\n */\n async findById(collection: string, id: string): Promise {\n await this.ensureInitialized();\n\n if (!this.collections.has(collection)) {\n return null;\n }\n\n try {\n const result = await sqlite.execute(\n `SELECT data FROM _documents WHERE collection = ? AND id = ?`,\n [collection, id]\n );\n\n if (result.rows.length === 0) {\n return null;\n }\n\n return JSON.parse(result.rows[0][0] as string);\n } catch (error) {\n console.error(`Failed to find document ${id} in ${collection}:`, error);\n return null;\n }\n }\n\n /**\n * Update documents in a collection\n */\n async update(collection: string, where: Record, update: Partial): Promise {\n await this.ensureInitialized();\n\n if (!this.collections.has(collection)) {\n return { modifiedCount: 0, success: false };\n }\n\n try {\n // First, find documents that match the where clause\n const documents = await this.find(collection, { where });\n \n if (documents.length === 0) {\n return { modifiedCount: 0, success: true };\n }\n\n let modifiedCount = 0;\n const timestamp = this.getTimestamp();\n\n for (const doc of documents) {\n if (!doc.id) continue;\n\n // Merge the update with the existing document\n const updatedDoc = { ...doc, ...update, id: doc.id };\n const data = JSON.stringify(updatedDoc);\n\n await sqlite.execute(\n `UPDATE _documents SET data = ?, updated_at = ? WHERE collection = ? AND id = ?`,\n [data, timestamp, collection, doc.id]\n );\n\n modifiedCount++;\n }\n\n // Update collection last_modified\n if (modifiedCount > 0) {\n await sqlite.execute(\n `UPDATE _collections_metadata SET last_modified = ? WHERE name = ?`,\n [timestamp, collection]\n );\n }\n\n return { modifiedCount, success: true };\n } catch (error) {\n console.error(`Failed to update documents in ${collection}:`, error);\n return { modifiedCount: 0, success: false };\n }\n }\n\n /**\n * Update a single document by ID\n */\n updateById(collection: string, id: string, update: Partial): Promise {\n return this.update(collection, { id }, update);\n }\n\n /**\n * Delete documents from a collection\n */\n async delete(collection: string, where: Record): Promise {\n await this.ensureInitialized();\n\n if (!this.collections.has(collection)) {\n return { deletedCount: 0, success: false };\n }\n\n try {\n // First, find documents that match the where clause\n const documents = await this.find(collection, { where });\n \n if (documents.length === 0) {\n return { deletedCount: 0, success: true };\n }\n\n let deletedCount = 0;\n const timestamp = this.getTimestamp();\n\n for (const doc of documents) {\n if (!doc.id) continue;\n\n await sqlite.execute(\n `DELETE FROM _documents WHERE collection = ? AND id = ?`,\n [collection, doc.id]\n );\n\n deletedCount++;\n }\n\n // Update collection last_modified\n if (deletedCount > 0) {\n await sqlite.execute(\n `UPDATE _collections_metadata SET last_modified = ? WHERE name = ?`,\n [timestamp, collection]\n );\n }\n\n return { deletedCount, success: true };\n } catch (error) {\n console.error(`Failed to delete documents from ${collection}:`, error);\n return { deletedCount: 0, success: false };\n }\n }\n\n /**\n * Delete a single document by ID\n */\n deleteById(collection: string, id: string): Promise {\n return this.delete(collection, { id });\n }\n\n /**\n * Count documents in a collection\n */\n async count(collection: string, where?: Record): Promise {\n await this.ensureInitialized();\n\n if (!this.collections.has(collection)) {\n return 0;\n }\n\n try {\n let query = `SELECT COUNT(*) as count FROM _documents WHERE collection = ?`;\n const params: any[] = [collection];\n\n // Add WHERE conditions\n if (where) {\n for (const [field, value] of Object.entries(where)) {\n query += ` AND JSON_EXTRACT(data, '$.${field}') = ?`;\n params.push(JSON.stringify(value));\n }\n }\n\n const result = await sqlite.execute(query, params);\n return result.rows[0][0] as number;\n } catch (error) {\n console.error(`Failed to count documents in ${collection}:`, error);\n return 0;\n }\n }\n\n /**\n * Get database statistics\n */\n async getStats(): Promise<{ collections: number; totalDocuments: number; collectionsStats: CollectionStats[] }> {\n await this.ensureInitialized();\n\n try {\n const collections = await this.listCollections();\n const collectionsStats: CollectionStats[] = [];\n let totalDocuments = 0;\n\n for (const collection of collections) {\n const stats = await this.getCollectionStats(collection);\n if (stats) {\n collectionsStats.push(stats);\n totalDocuments += stats.count;\n }\n }\n\n return {\n collections: collections.length,\n totalDocuments,\n collectionsStats\n };\n } catch (error) {\n console.error('Failed to get database stats:', error);\n return { collections: 0, totalDocuments: 0, collectionsStats: [] };\n }\n }\n}\n\n// Export a default instance\nexport const jsonDb = new JsonDB();\n\n// Export the class for custom instances\nexport default JsonDB;\n",[],[164,223],"1d7131d2-9464-11f0-9a85-0224a6c84d84","index.ts","1d71327c-9464-11f0-9a85-0224a6c84d84",8,["D",1758181815985],"/**\n * JsonDB - Main entry point\n * A document database abstraction over SQLite for Val Town\n */\n\n// Export the main JsonDB class and default instance\nexport { JsonDB, jsonDb, type Document, type QueryOptions, type CollectionStats, type InsertResult, type UpdateResult, type DeleteResult } from \"./json-db.ts\";\n\n// Export migration utilities\nexport { MigrationManager, migrationManager, type Migration, type MigrationResult } from \"./migrations.ts\";\n\n// Re-export for convenience\nexport { jsonDb as default } from \"./json-db.ts\";\n\n",[],[164,231],["D",1758181815414],[190,191,192],[164],"1d875ed0-9464-11f0-87ab-0224a6c84d84","val-town-http.ts","1d875f8e-9464-11f0-87ab-0224a6c84d84",10,["D",1758181815809],"http","/**\n * Val Town HTTP API example using JsonDB\n * This demonstrates how to create a REST API using the JSON database\n */\n\nimport { Hono } from \"https://esm.sh/hono@3.12.6\";\nimport { jsonDb } from \"../src/json-db.ts\";\n\nconst app = new Hono();\n\n// Unwrap Hono errors to see original error details\napp.onError((err, c) => {\n throw err;\n});\n\n// Middleware for JSON parsing\napp.use('*', async (c, next) => {\n if (c.req.method === 'POST' || c.req.method === 'PUT' || c.req.method === 'PATCH') {\n try {\n const body = await c.req.json();\n c.set('body', body);\n } catch (error) {\n return c.json({ error: 'Invalid JSON' }, 400);\n }\n }\n await next();\n});\n\n// Health check endpoint\napp.get('/health', (c) => {\n return c.json({ status: 'ok', timestamp: new Date().toISOString() });\n});\n\n// Database stats endpoint\napp.get('/stats', async (c) => {\n try {\n const stats = await jsonDb.getStats();\n return c.json(stats);\n } catch (error) {\n return c.json({ error: 'Failed to get database stats' }, 500);\n }\n});\n\n// Collection management endpoints\napp.get('/collections', async (c) => {\n try {\n const collections = await jsonDb.listCollections();\n return c.json({ collections });\n } catch (error) {\n return c.json({ error: 'Failed to list collections' }, 500);\n }\n});\n\napp.post('/collections', async (c) => {\n try {\n const { name } = c.get('body') || {};\n if (!name) {\n return c.json({ error: 'Collection name is required' }, 400);\n }\n\n const success = await jsonDb.createCollection(name);\n if (success) {\n return c.json({ message: `Collection '${name}' created successfully` });\n } else {\n return c.json({ error: 'Failed to create collection' }, 500);\n }\n } catch (error) {\n return c.json({ error: 'Failed to create collection' }, 500);\n }\n});\n\napp.delete('/collections/:name', async (c) => {\n try {\n const name = c.req.param('name');\n const success = await jsonDb.dropCollection(name);\n \n if (success) {\n return c.json({ message: `Collection '${name}' deleted successfully` });\n } else {\n return c.json({ error: 'Collection not found or could not be deleted' }, 404);\n }\n } catch (error) {\n return c.json({ error: 'Failed to delete collection' }, 500);\n }\n});\n\napp.get('/collections/:name/stats', async (c) => {\n try {\n const name = c.req.param('name');\n const stats = await jsonDb.getCollectionStats(name);\n \n if (stats) {\n return c.json(stats);\n } else {\n return c.json({ error: 'Collection not found' }, 404);\n }\n } catch (error) {\n return c.json({ error: 'Failed to get collection stats' }, 500);\n }\n});\n\n// Document CRUD endpoints\napp.post('/collections/:name/documents', async (c) => {\n try {\n const collection = c.req.param('name');\n const document = c.get('body');\n \n if (!document) {\n return c.json({ error: 'Document data is required' }, 400);\n }\n\n const result = await jsonDb.insert(collection, document);\n \n if (result.success) {\n return c.json({ \n message: 'Document created successfully',\n id: result.id \n }, 201);\n } else {\n return c.json({ error: 'Failed to create document' }, 500);\n }\n } catch (error) {\n return c.json({ error: 'Failed to create document' }, 500);\n }\n});\n\napp.post('/collections/:name/documents/batch', async (c) => {\n try {\n const collection = c.req.param('name');\n const { documents } = c.get('body') || {};\n \n if (!Array.isArray(documents)) {\n return c.json({ error: 'Documents array is required' }, 400);\n }\n\n const results = await jsonDb.insertMany(collection, documents);\n const successCount = results.filter(r => r.success).length;\n \n return c.json({ \n message: `Created ${successCount} out of ${documents.length} documents`,\n results \n }, 201);\n } catch (error) {\n return c.json({ error: 'Failed to create documents' }, 500);\n }\n});\n\napp.get('/collections/:name/documents', async (c) => {\n try {\n const collection = c.req.param('name');\n const limit = c.req.query('limit');\n const offset = c.req.query('offset');\n const sort = c.req.query('sort');\n const where = c.req.query('where');\n\n const options: any = {};\n \n if (limit) options.limit = parseInt(limit);\n if (offset) options.offset = parseInt(offset);\n if (sort) {\n try {\n options.sort = JSON.parse(sort);\n } catch (error) {\n return c.json({ error: 'Invalid sort parameter' }, 400);\n }\n }\n if (where) {\n try {\n options.where = JSON.parse(where);\n } catch (error) {\n return c.json({ error: 'Invalid where parameter' }, 400);\n }\n }\n\n const documents = await jsonDb.find(collection, options);\n return c.json({ documents });\n } catch (error) {\n return c.json({ error: 'Failed to find documents' }, 500);\n }\n});\n\napp.get('/collections/:name/documents/:id', async (c) => {\n try {\n const collection = c.req.param('name');\n const id = c.req.param('id');\n \n const document = await jsonDb.findById(collection, id);\n \n if (document) {\n return c.json({ document });\n } else {\n return c.json({ error: 'Document not found' }, 404);\n }\n } catch (error) {\n return c.json({ error: 'Failed to find document' }, 500);\n }\n});\n\napp.put('/collections/:name/documents/:id', async (c) => {\n try {\n const collection = c.req.param('name');\n const id = c.req.param('id');\n const update = c.get('body');\n \n if (!update) {\n return c.json({ error: 'Update data is required' }, 400);\n }\n\n const result = await jsonDb.updateById(collection, id, update);\n \n if (result.success) {\n return c.json({ \n message: 'Document updated successfully',\n modifiedCount: result.modifiedCount \n });\n } else {\n return c.json({ error: 'Failed to update document' }, 500);\n }\n } catch (error) {\n return c.json({ error: 'Failed to update document' }, 500);\n }\n});\n\napp.patch('/collections/:name/documents', async (c) => {\n try {\n const collection = c.req.param('name');\n const { where, update } = c.get('body') || {};\n \n if (!where || !update) {\n return c.json({ error: 'where and update are required' }, 400);\n }\n\n const result = await jsonDb.update(collection, where, update);\n \n return c.json({ \n message: 'Documents updated successfully',\n modifiedCount: result.modifiedCount \n });\n } catch (error) {\n return c.json({ error: 'Failed to update documents' }, 500);\n }\n});\n\napp.delete('/collections/:name/documents/:id', async (c) => {\n try {\n const collection = c.req.param('name');\n const id = c.req.param('id');\n \n const result = await jsonDb.deleteById(collection, id);\n \n if (result.success) {\n return c.json({ \n message: 'Document deleted successfully',\n deletedCount: result.deletedCount \n });\n } else {\n return c.json({ error: 'Failed to delete document' }, 500);\n }\n } catch (error) {\n return c.json({ error: 'Failed to delete document' }, 500);\n }\n});\n\napp.delete('/collections/:name/documents', async (c) => {\n try {\n const collection = c.req.param('name');\n const { where } = c.get('body') || {};\n \n if (!where) {\n return c.json({ error: 'where condition is required' }, 400);\n }\n\n const result = await jsonDb.delete(collection, where);\n \n return c.json({ \n message: 'Documents deleted successfully',\n deletedCount: result.deletedCount \n });\n } catch (error) {\n return c.json({ error: 'Failed to delete documents' }, 500);\n }\n});\n\napp.get('/collections/:name/count', async (c) => {\n try {\n const collection = c.req.param('name');\n const where = c.req.query('where');\n \n let whereCondition;\n if (where) {\n try {\n whereCondition = JSON.parse(where);\n } catch (error) {\n return c.json({ error: 'Invalid where parameter' }, 400);\n }\n }\n\n const count = await jsonDb.count(collection, whereCondition);\n return c.json({ count });\n } catch (error) {\n return c.json({ error: 'Failed to count documents' }, 500);\n }\n});\n\n// Root endpoint with API documentation\napp.get('/', (c) => {\n const apiDocs = {\n name: \"JsonDB REST API\",\n version: \"1.0.0\",\n description: \"A REST API for the JsonDB document database\",\n endpoints: {\n \"GET /health\": \"Health check\",\n \"GET /stats\": \"Get database statistics\",\n \"GET /collections\": \"List all collections\",\n \"POST /collections\": \"Create a new collection\",\n \"DELETE /collections/:name\": \"Delete a collection\",\n \"GET /collections/:name/stats\": \"Get collection statistics\",\n \"POST /collections/:name/documents\": \"Create a document\",\n \"POST /collections/:name/documents/batch\": \"Create multiple documents\",\n \"GET /collections/:name/documents\": \"Find documents with optional query parameters\",\n \"GET /collections/:name/documents/:id\": \"Get a document by ID\",\n \"PUT /collections/:name/documents/:id\": \"Update a document by ID\",\n \"PATCH /collections/:name/documents\": \"Update multiple documents\",\n \"DELETE /collections/:name/documents/:id\": \"Delete a document by ID\",\n \"DELETE /collections/:name/documents\": \"Delete multiple documents\",\n \"GET /collections/:name/count\": \"Count documents with optional where condition\"\n },\n queryParameters: {\n \"limit\": \"Number of documents to return\",\n \"offset\": \"Number of documents to skip\",\n \"sort\": \"JSON array of sort objects: [{\\\"field\\\": \\\"name\\\", \\\"direction\\\": \\\"asc\\\"}]\",\n \"where\": \"JSON object for filtering: {\\\"field\\\": \\\"value\\\"}\"\n }\n };\n \n return c.json(apiDocs);\n});\n\n// This is the entry point for HTTP vals\nexport default app.fetch;\n\n",[],[171,242],"1d6a42dc-9464-11f0-80a6-0224a6c84d84","simple-http.val.ts",7,["D",1758181815800],"/**\n * Simple JsonDB HTTP API for Val Town\n * Deploy this as a Val to get a working JSON database API\n */\n\nimport { Hono } from \"https://esm.sh/hono@3.12.6\";\nimport { jsonDb } from \"../src/json-db.ts\";\n\nconst app = new Hono();\n\n// Unwrap Hono errors to see original error details\napp.onError((err, c) => {\n throw err;\n});\n\n// Middleware for JSON parsing\napp.use('*', async (c, next) => {\n if (c.req.method === 'POST' || c.req.method === 'PUT' || c.req.method === 'PATCH') {\n try {\n const body = await c.req.json();\n c.set('body', body);\n } catch (error) {\n return c.json({ error: 'Invalid JSON' }, 400);\n }\n }\n await next();\n});\n\n// Root endpoint with API documentation\napp.get('/', (c) => {\n const html = `\n\n\n\n JsonDB API\n \n \n\n\n

🗄️ JsonDB API

A document database API built for Val Town

\n \n

Quick Start

\n# Create a document\ncurl -X POST ${c.req.url}collections/users/documents \\\\\n -H \"Content-Type: application/json\" \\\\\n -d '{\"name\": \"John Doe\", \"email\": \"john@example.com\", \"age\": 30}'\n\n# Get all documents\ncurl ${c.req.url}collections/users/documents\n\n# Get document by ID\ncurl ${c.req.url}collections/users/documents/{id}\n\n# Update document\ncurl -X PUT ${c.req.url}collections/users/documents/{id} \\\\\n -H \"Content-Type: application/json\" \\\\\n -d '{\"age\": 31}'\n\n# Delete document\ncurl -X DELETE ${c.req.url}collections/users/documents/{id}\n

\n\n

API Endpoints

\n GET /health - Health check\n

\n GET /stats - Database statistics\n

\n GET /collections - List collections\n

\n POST /collections - Create collection\n

\n GET /collections/{name}/documents - Find documents\n

\n POST /collections/{name}/documents - Create document\n

\n GET /collections/{name}/documents/{id} - Get document\n

\n PUT /collections/{name}/documents/{id} - Update document\n

\n DELETE /collections/{name}/documents/{id} - Delete document\n

\n\n

Query Parameters

limit - Number of documents to return
offset - Number of documents to skip
sort - JSON array: [{\"field\": \"name\", \"direction\": \"asc\"}]
where - JSON object: {\"field\": \"value\"}

\n\n

Example Usage

\n# Find users over 25, sorted by name\ncurl \"${c.req.url}collections/users/documents?where=%7B%22age%22:%7B%22$gte%22:25%7D%7D&sort=%5B%7B%22field%22:%22name%22,%22direction%22:%22asc%22%7D%5D\"\n\n# Paginate results\ncurl \"${c.req.url}collections/users/documents?limit=10&offset=20\"\n

\n\n`;\n \n return c.html(html);\n});\n\n// Health check\napp.get('/health', (c) => {\n return c.json({ \n status: 'ok', \n timestamp: new Date().toISOString(),\n service: 'JsonDB API'\n });\n});\n\n// Database stats\napp.get('/stats', async (c) => {\n try {\n const stats = await jsonDb.getStats();\n return c.json(stats);\n } catch (error) {\n return c.json({ error: 'Failed to get stats' }, 500);\n }\n});\n\n// List collections\napp.get('/collections', async (c) => {\n try {\n const collections = await jsonDb.listCollections();\n return c.json({ collections });\n } catch (error) {\n return c.json({ error: 'Failed to list collections' }, 500);\n }\n});\n\n// Create collection\napp.post('/collections', async (c) => {\n try {\n const { name } = c.get('body') || {};\n if (!name) {\n return c.json({ error: 'Collection name required' }, 400);\n }\n\n const success = await jsonDb.createCollection(name);\n if (success) {\n return c.json({ message: `Collection '${name}' created` });\n } else {\n return c.json({ error: 'Failed to create collection' }, 500);\n }\n } catch (error) {\n return c.json({ error: 'Failed to create collection' }, 500);\n }\n});\n\n// Get documents\napp.get('/collections/:name/documents', async (c) => {\n try {\n const collection = c.req.param('name');\n const limit = c.req.query('limit');\n const offset = c.req.query('offset');\n const sort = c.req.query('sort');\n const where = c.req.query('where');\n\n const options: any = {};\n if (limit) options.limit = parseInt(limit);\n if (offset) options.offset = parseInt(offset);\n if (sort) {\n try {\n options.sort = JSON.parse(sort);\n } catch (error) {\n return c.json({ error: 'Invalid sort parameter' }, 400);\n }\n }\n if (where) {\n try {\n options.where = JSON.parse(where);\n } catch (error) {\n return c.json({ error: 'Invalid where parameter' }, 400);\n }\n }\n\n const documents = await jsonDb.find(collection, options);\n return c.json({ documents });\n } catch (error) {\n return c.json({ error: 'Failed to find documents' }, 500);\n }\n});\n\n// Create document\napp.post('/collections/:name/documents', async (c) => {\n try {\n const collection = c.req.param('name');\n const document = c.get('body');\n \n if (!document) {\n return c.json({ error: 'Document data required' }, 400);\n }\n\n const result = await jsonDb.insert(collection, document);\n \n if (result.success) {\n return c.json({ \n message: 'Document created',\n id: result.id \n }, 201);\n } else {\n return c.json({ error: 'Failed to create document' }, 500);\n }\n } catch (error) {\n return c.json({ error: 'Failed to create document' }, 500);\n }\n});\n\n// Get document by ID\napp.get('/collections/:name/documents/:id', async (c) => {\n try {\n const collection = c.req.param('name');\n const id = c.req.param('id');\n \n const document = await jsonDb.findById(collection, id);\n \n if (document) {\n return c.json({ document });\n } else {\n return c.json({ error: 'Document not found' }, 404);\n }\n } catch (error) {\n return c.json({ error: 'Failed to find document' }, 500);\n }\n});\n\n// Update document\napp.put('/collections/:name/documents/:id', async (c) => {\n try {\n const collection = c.req.param('name');\n const id = c.req.param('id');\n const update = c.get('body');\n \n if (!update) {\n return c.json({ error: 'Update data required' }, 400);\n }\n\n const result = await jsonDb.updateById(collection, id, update);\n \n if (result.success) {\n return c.json({ \n message: 'Document updated',\n modifiedCount: result.modifiedCount \n });\n } else {\n return c.json({ error: 'Failed to update document' }, 500);\n }\n } catch (error) {\n return c.json({ error: 'Failed to update document' }, 500);\n }\n});\n\n// Delete document\napp.delete('/collections/:name/documents/:id', async (c) => {\n try {\n const collection = c.req.param('name');\n const id = c.req.param('id');\n \n const result = await jsonDb.deleteById(collection, id);\n \n if (result.success) {\n return c.json({ \n message: 'Document deleted',\n deletedCount: result.deletedCount \n });\n } else {\n return c.json({ error: 'Failed to delete document' }, 500);\n }\n } catch (error) {\n return c.json({ error: 'Failed to delete document' }, 500);\n }\n});\n\n// This is the entry point for HTTP vals\nexport default app.fetch;\n\n",[],[171,251],"1db718b4-9464-11f0-810d-0224a6c84d84","basic-usage.ts","1db7199a-9464-11f0-810d-0224a6c84d84",11,["D",1758181815807],"/**\n * Basic usage examples for JsonDB\n * This file demonstrates the core functionality of the JSON database library\n */\n\nimport { jsonDb, JsonDB } from \"../src/json-db.ts\";\n\n// Example 1: Basic CRUD operations\nasync function basicCrudExample() {\n console.log(\"=== Basic CRUD Example ===\");\n\n // Insert a document\n const user = await jsonDb.insert(\"users\", {\n name: \"John Doe\",\n email: \"john@example.com\",\n age: 30,\n preferences: {\n theme: \"dark\",\n notifications: true\n }\n });\n\n console.log(\"Inserted user:\", user);\n\n // Find the user by ID\n const foundUser = await jsonDb.findById(\"users\", user.id);\n console.log(\"Found user:\", foundUser);\n\n // Update the user\n const updateResult = await jsonDb.updateById(\"users\", user.id, {\n age: 31,\n preferences: {\n theme: \"light\",\n notifications: false\n }\n });\n console.log(\"Update result:\", updateResult);\n\n // Find all users\n const allUsers = await jsonDb.find(\"users\");\n console.log(\"All users:\", allUsers);\n\n // Count users\n const userCount = await jsonDb.count(\"users\");\n console.log(\"User count:\", userCount);\n}\n\n// Example 2: Querying with filters and sorting\nasync function queryExample() {\n console.log(\"\\n=== Query Example ===\");\n\n // Insert multiple users\n const users = [\n { name: \"Alice\", age: 25, city: \"New York\" },\n { name: \"Bob\", age: 30, city: \"San Francisco\" },\n { name: \"Charlie\", age: 35, city: \"New York\" },\n { name: \"Diana\", age: 28, city: \"Chicago\" }\n ];\n\n await jsonDb.insertMany(\"users\", users);\n\n // Find users from New York\n const nyUsers = await jsonDb.find(\"users\", {\n where: { city: \"New York\" }\n });\n console.log(\"Users from New York:\", nyUsers);\n\n // Find users sorted by age (descending)\n const sortedUsers = await jsonDb.find(\"users\", {\n sort: [{ field: \"age\", direction: \"desc\" }]\n });\n console.log(\"Users sorted by age:\", sortedUsers);\n\n // Find users with pagination\n const paginatedUsers = await jsonDb.find(\"users\", {\n limit: 2,\n offset: 1\n });\n console.log(\"Paginated users:\", paginatedUsers);\n}\n\n// Example 3: Collection management\nasync function collectionExample() {\n console.log(\"\\n=== Collection Management Example ===\");\n\n // List all collections\n const collections = await jsonDb.listCollections();\n console.log(\"All collections:\", collections);\n\n // Get collection stats\n const stats = await jsonDb.getCollectionStats(\"users\");\n console.log(\"Users collection stats:\", stats);\n\n // Get overall database stats\n const dbStats = await jsonDb.getStats();\n console.log(\"Database stats:\", dbStats);\n}\n\n// Example 4: Advanced operations\nasync function advancedExample() {\n console.log(\"\\n=== Advanced Operations Example ===\");\n\n // Create a new collection for products\n await jsonDb.createCollection(\"products\");\n\n // Insert products\n const products = [\n { name: \"Laptop\", price: 999.99, category: \"electronics\", inStock: true },\n { name: \"Mouse\", price: 29.99, category: \"electronics\", inStock: false },\n { name: \"Desk\", price: 299.99, category: \"furniture\", inStock: true },\n { name: \"Chair\", price: 199.99, category: \"furniture\", inStock: true }\n ];\n\n await jsonDb.insertMany(\"products\", products);\n\n // Find electronics in stock\n const electronicsInStock = await jsonDb.find(\"products\", {\n where: { category: \"electronics\", inStock: true }\n });\n console.log(\"Electronics in stock:\", electronicsInStock);\n\n // Update all furniture prices (10% discount)\n const furniture = await jsonDb.find(\"products\", {\n where: { category: \"furniture\" }\n });\n\n for (const item of furniture) {\n if (item.id) {\n await jsonDb.updateById(\"products\", item.id, {\n price: Math.round(item.price * 0.9 * 100) / 100\n });\n }\n }\n\n console.log(\"Updated furniture prices (10% discount)\");\n\n // Find products under $200\n const affordableProducts = await jsonDb.find(\"products\", {\n sort: [{ field: \"price\", direction: \"asc\" }]\n }).then(products => \n products.filter(p => p.price < 200)\n );\n console.log(\"Products under $200:\", affordableProducts);\n}\n\n// Example 5: Error handling and cleanup\nasync function errorHandlingExample() {\n console.log(\"\\n=== Error Handling Example ===\");\n\n try {\n // Try to find a non-existent document\n const nonExistent = await jsonDb.findById(\"users\", \"non-existent-id\");\n console.log(\"Non-existent document:\", nonExistent);\n\n // Try to delete from non-existent collection\n const deleteResult = await jsonDb.delete(\"non-existent-collection\", {});\n console.log(\"Delete from non-existent collection:\", deleteResult);\n\n // Try to get stats for non-existent collection\n const stats = await jsonDb.getCollectionStats(\"non-existent\");\n console.log(\"Stats for non-existent collection:\", stats);\n\n } catch (error) {\n console.error(\"Error occurred:\", error);\n }\n}\n\n// Example 6: Custom JsonDB instance\nasync function customInstanceExample() {\n console.log(\"\\n=== Custom Instance Example ===\");\n\n // Create a custom instance (useful for testing or multiple databases)\n const customDb = new JsonDB();\n\n // Use the custom instance\n await customDb.insert(\"test_collection\", { message: \"Hello from custom instance!\" });\n \n const documents = await customDb.find(\"test_collection\");\n console.log(\"Custom instance documents:\", documents);\n\n // Clean up\n await customDb.dropCollection(\"test_collection\");\n}\n\n// Run all examples\nasync function runAllExamples() {\n try {\n await basicCrudExample();\n await queryExample();\n await collectionExample();\n await advancedExample();\n await errorHandlingExample();\n await customInstanceExample();\n\n console.log(\"\\n=== All examples completed successfully! ===\");\n } catch (error) {\n console.error(\"Error running examples:\", error);\n }\n}\n\n// Export for use in other files\nexport {\n basicCrudExample,\n queryExample,\n collectionExample,\n advancedExample,\n errorHandlingExample,\n customInstanceExample,\n runAllExamples\n};\n\n// Uncomment to run examples directly\n// runAllExamples();\n\n",[],[171,258],["D",1758181815221],[186,187,188],[171],["D",1758130324008],{"_11":12,"_88":84},{"_11":12,"_82":-5,"_83":84,"_45":46,"_85":86,"_87":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_77":-5,"_78":-5,"_79":-5,"_80":14,"_81":12},"ctx",{"_70":-5,"_109":305,"_306":307,"_308":309,"_310":38,"_311":38,"_312":38,"_313":50,"_314":-5,"_315":-7,"_316":-7,"_317":54,"_318":38,"_319":38,"_320":-5,"_321":38,"_322":38,"_323":38,"_324":-5},"ENV",{"_276":277,"_278":279,"_280":26,"_281":282,"_283":284,"_285":286,"_287":288,"_289":290,"_291":292,"_293":294,"_295":296,"_297":298,"_299":300,"_301":302,"_303":304},"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"]

Branches1

Branches
1