[{"_1":2,"_171":-5,"_172":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","e3ca0a77ab07ff2ce3097208ffd6aa0e378d3c47","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_146":147,"_168":169,"_170":-5},"handle","wilhelm","name","json-db","path","src/json-db.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":72,"_110":-5,"_12":111,"_112":-5,"_113":20,"_114":-5,"_115":32,"_14":116,"_117":118,"_119":118,"_120":121,"_122":121,"_123":121,"_124":118,"_125":118,"_23":126,"_129":130,"_132":133,"_145":20},"id","39d253e2-93ec-11f0-856a-0224a6c84d84","createdAt",["D",1758130324008],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","ecbce1e5-343d-483e-99fe-bc35afe6b93a","pinnedFileId","pinPreview","screenshotVersion","likeCount","a22192bb-4fed-4a1b-9182-d6c09e531cf8","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_127":128},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJwUXQza21ONmFtMEtyWFAxa3gzV3dTbGdXTSJ9","org",{"_93":94,"_131":128},"avatar","branch",{"_134":135,"_95":43,"_101":136,"_137":102,"_138":-5,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":96,"_144":94},"version",13,"39d2ba9e-93ec-11f0-856a-0224a6c84d84","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":148,"_95":149,"_150":151,"_152":153,"_154":136,"_155":156,"_157":158,"_103":159,"_134":32,"_160":161,"_162":163,"_164":20,"_165":-5,"_97":166},"1e17af12-9464-11f0-a205-0224a6c84d84","json-db.ts","fileId","1e17afda-9464-11f0-a205-0224a6c84d84","parentId","1d17cf48-9464-11f0-99cc-0224a6c84d84","branchId","branchVersion",12,"latest",true,["D",1758181815813],"fileType","script","content","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","deleted","label",[167,149],"src","permalink","https://www.val.town/x/wilhelm/json-db/code/src/json-db.ts","extension","actionData","errors"]