[{"_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","40390002a9f23719e5ece4788ed87655b391d648","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,"_148":149,"_168":169,"_170":-5},"handle","maxm","name","dexieish","path","main.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":110,"_111":-5,"_12":112,"_113":-5,"_114":20,"_115":-5,"_116":117,"_14":118,"_119":120,"_121":120,"_122":123,"_124":123,"_125":123,"_126":120,"_127":120,"_23":128,"_131":132,"_134":135,"_147":20},"id","7519e720-88ee-11f0-a287-0224a6c84d84","createdAt",["D",1756921819665],"deletedAt","legacyEnvVars","privacy","public","description","Data storage library. Val-scoped, SQLite backed, Dexie inspired.","imageUrl","418c1e39-eb48-4f2f-8c97-122ece94631c","pinnedFileId","pinPreview","screenshotVersion","likeCount",2,"c1e7642a-74cc-4d69-8652-20abbdeaa94e","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_129":130},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJnTEtkSHlOMWxWZm1GRHdKYUVTNklYM3FpdiJ9","org",{"_93":94,"_133":130},"avatar","branch",{"_136":137,"_95":43,"_101":138,"_139":102,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":96,"_146":94},"version",93,"751a4c06-88ee-11f0-a287-0224a6c84d84","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":150,"_95":98,"_151":152,"_153":-5,"_154":138,"_155":156,"_157":158,"_103":159,"_136":160,"_161":162,"_163":164,"_165":20,"_166":-5,"_97":167},"dccd2dfe-8908-11f0-b779-0224a6c84d84","fileId","99ac7fb2-88ee-11f0-8211-0224a6c84d84","parentId","branchId","branchVersion",76,"latest",true,["D",1756933160551],3,"fileType","script","content","import { createClient, type Client } from \"npm:@libsql/client@0.15.9\";\n\n// ---- Types ----\ninterface SchemaConfig {\n primaryKey: { name: string; auto: boolean; type: string };\n singleIndexes: Array<{ name: string; unique: boolean }>;\n compoundIndexes: Array<{ fields: string[]; unique: boolean }>;\n indexColumns: Set;\n}\n\ninterface StoreDefinition {\n [tableName: string]: string;\n}\n\ninterface TableSchemaMap {\n [tableName: string]: any;\n}\n\ninterface VersionConfig {\n version: number;\n stores: StoreDefinition;\n}\n\ninterface SchemaVersion {\n version: number;\n applied_at: string;\n schema: string;\n}\n\ninterface ChangeEvent {\n table: string;\n type: 'add' | 'put' | 'update' | 'delete';\n id: string;\n obj: any;\n}\n\n\n// ---- Utilities ----\nconst isObject = (v: any): v is object => v !== null && typeof v === 'object';\nconst toJSON = (v: any): string => (isObject(v) ? JSON.stringify(v) : v);\nconst fromJSON = (v: any): any => {\n if (typeof v !== 'string') return v;\n try { return JSON.parse(v); } catch { return v; }\n};\n\n// Parse a Dexie-like stores() schema string, e.g. '++id, name, &email, [name+age]'\nfunction parseSchemaString(schemaStr: string): SchemaConfig {\n const tokens = schemaStr.split(',').map(t => t.trim()).filter(Boolean);\n if (!tokens.length) throw new Error('Invalid schema: empty');\n\n const primaryTok = tokens[0];\n if (primaryTok.startsWith('[')) {\n throw new Error('Compound primary keys are not supported in this quick version');\n }\n\n const res: SchemaConfig = {\n primaryKey: { name: '', auto: false, type: 'TEXT' },\n singleIndexes: [], // { name, unique }\n compoundIndexes: [], // { fields: [a,b], unique }\n indexColumns: new Set(),\n };\n\n // primary key\n if (primaryTok.startsWith('++')) {\n res.primaryKey.name = primaryTok.replace('++', '');\n res.primaryKey.auto = true;\n res.primaryKey.type = 'INTEGER';\n } else if (primaryTok.startsWith('&')) {\n res.primaryKey.name = primaryTok.replace('&', '');\n // unique string pk\n } else {\n res.primaryKey.name = primaryTok;\n }\n\n // indexes\n for (let i = 1; i < tokens.length; i++) {\n const tok = tokens[i];\n if (tok.startsWith('[')) {\n const unique = tok.startsWith('&[');\n const inner = tok.replace(/^&?\\[/, '').replace(/]$/, '');\n const fields = inner.split('+').map(s => s.trim());\n fields.forEach(f => res.indexColumns.add(f));\n res.compoundIndexes.push({ fields, unique });\n } else {\n const unique = tok.startsWith('&');\n const name = tok.replace('&', '');\n res.indexColumns.add(name);\n res.singleIndexes.push({ name, unique });\n }\n }\n\n return res;\n}\n\nfunction parseProjectName(url: string): string | null {\n const match = url.match(/^https:\\/\\/esm\\.town\\/v\\/([^\\/]+)\\/([^@]+)@([^\\/]+)/);\n return match ? match[2] : null;\n}\n\n\n\n// ---- Core classes ----\nexport class Dexieish> extends EventTarget {\n public client: Client;\n public tablePrefix: string;\n #_tables: Map> = new Map();\n #_versionConfigs: VersionConfig[] = [];\n #_currentVersion: number = 0;\n\n constructor(options?: { url?: string; tablePrefix?: string }) {\n super();\n const entrypoint = Deno.env.get(\"VALTOWN_ENTRYPOINT\");\n this.tablePrefix = entrypoint ? `dxi_${parseProjectName(entrypoint)}_` : options?.tablePrefix || '';\n this.client = createClient({\n url: options?.url || (Deno.env.has(\"VAL_TOWN_API_KEY\") ? \"https://api.val.town/v2/sqlite/\" : Deno.env.get(\"LIBSQL_URL\") as string),\n authToken: Deno.env.get(\"VAL_TOWN_API_KEY\") || Deno.env.get(\"TURSO_AUTH_TOKEN\"),\n });\n }\n\n version(n: number) {\n return {\n stores: (def: StoreDefinition) => {\n // Store version config instead of immediately applying\n this.#_versionConfigs.push({ version: n, stores: def });\n this.#_currentVersion = Math.max(this.#_currentVersion, n);\n return this;\n }\n };\n }\n\n async ready(): Promise {\n await this._initializeSchemaVersionTable();\n await this._runMigrations();\n }\n\n private _getFullTableName(tableName: string): string {\n return this.tablePrefix ? `${this.tablePrefix}${tableName}` : tableName;\n }\n\n async cleanup(): Promise {\n // Drop all tables created by this instance\n const tableNames = Array.from(this.#_tables.keys());\n const dropStatements = tableNames.map(name =>\n `DROP TABLE IF EXISTS ${quoteIdent(this._getFullTableName(name))}`\n );\n // Also drop schema version table\n dropStatements.push(`DROP TABLE IF EXISTS ${quoteIdent(this._getFullTableName('__schema_version'))}`);\n if (dropStatements.length > 0) {\n await this.client.batch(dropStatements, \"write\");\n }\n this.#_tables.clear();\n }\n\n table(name: K): Table | undefined {\n return this.#_tables.get(name as string) as Table | undefined;\n }\n\n private async _initializeSchemaVersionTable(): Promise {\n const tableName = this._getFullTableName('__schema_version');\n const createSql = `CREATE TABLE IF NOT EXISTS ${quoteIdent(tableName)} (\n version INTEGER PRIMARY KEY,\n applied_at TEXT NOT NULL,\n schema TEXT NOT NULL\n )`;\n await this.client.execute(createSql);\n }\n\n private async _getCurrentSchemaVersion(): Promise {\n const tableName = this._getFullTableName('__schema_version');\n const result = await this.client.execute(\n `SELECT * FROM ${quoteIdent(tableName)} ORDER BY version DESC LIMIT 1`\n );\n if (!result.rows.length) return null;\n const row = result.rows[0] as any;\n return {\n version: row.version,\n applied_at: row.applied_at,\n schema: row.schema\n };\n }\n\n private async _saveSchemaVersion(version: number, schema: string): Promise {\n const tableName = this._getFullTableName('__schema_version');\n await this.client.execute({\n sql: `INSERT OR REPLACE INTO ${quoteIdent(tableName)} (version, applied_at, schema) VALUES (?, ?, ?)`,\n args: [version, new Date().toISOString(), schema]\n });\n }\n\n private async _runMigrations(): Promise {\n if (this.#_versionConfigs.length === 0) return;\n\n // Sort version configs by version number\n this.#_versionConfigs.sort((a, b) => a.version - b.version);\n const targetVersion = this.#_versionConfigs[this.#_versionConfigs.length - 1];\n\n const currentVersion = await this._getCurrentSchemaVersion();\n const currentVersionNum = currentVersion?.version || 0;\n\n if (currentVersionNum >= targetVersion.version) {\n // Apply current schema without migration\n await this._applyStores(targetVersion.stores);\n return;\n }\n\n // Find the version config to migrate to\n const targetConfig = this.#_versionConfigs.find(v => v.version === targetVersion.version);\n if (!targetConfig) return;\n\n if (currentVersion) {\n // Perform migration\n const oldSchema = JSON.parse(currentVersion.schema);\n await this._performMigration(oldSchema, targetConfig.stores);\n } else {\n // Fresh installation\n await this._applyStores(targetConfig.stores);\n }\n\n // Save new schema version\n await this._saveSchemaVersion(targetVersion.version, JSON.stringify(targetConfig.stores));\n }\n\n private async _performMigration(oldSchema: StoreDefinition, newSchema: StoreDefinition): Promise {\n const migrationStatements: string[] = [];\n\n // Compare schemas and generate migration SQL\n const oldTables = new Set(Object.keys(oldSchema));\n const newTables = new Set(Object.keys(newSchema));\n\n // Handle new tables\n for (const tableName of newTables) {\n if (!oldTables.has(tableName)) {\n // Create new table\n const parsed = parseSchemaString(newSchema[tableName]);\n const fullTableName = this._getFullTableName(tableName);\n const statements = this._generateCreateTableSQL(fullTableName, parsed);\n migrationStatements.push(...statements);\n } else {\n // Check for schema changes in existing tables\n const oldParsed = parseSchemaString(oldSchema[tableName]);\n const newParsed = parseSchemaString(newSchema[tableName]);\n const alterStatements = this._generateAlterTableSQL(tableName, oldParsed, newParsed);\n migrationStatements.push(...alterStatements);\n }\n }\n\n // Handle removed tables\n for (const tableName of oldTables) {\n if (!newTables.has(tableName)) {\n const fullTableName = this._getFullTableName(tableName);\n migrationStatements.push(`DROP TABLE IF EXISTS ${quoteIdent(fullTableName)}`);\n }\n }\n\n // Execute migration statements\n if (migrationStatements.length > 0) {\n await this.client.batch(migrationStatements, \"write\");\n }\n\n // Apply the new schema to create table instances\n await this._applyStores(newSchema);\n }\n\n private _generateCreateTableSQL(fullTableName: string, parsed: SchemaConfig): string[] {\n const pk = parsed.primaryKey;\n const cols = [];\n cols.push('data TEXT NOT NULL');\n\n parsed.indexColumns.forEach(col => {\n if (col === pk.name) return;\n cols.push(`${col} TEXT`);\n });\n\n let pkClause;\n if (pk.auto) {\n pkClause = `${pk.name} INTEGER PRIMARY KEY AUTOINCREMENT`;\n } else {\n pkClause = `${pk.name} TEXT PRIMARY KEY`;\n }\n\n const createSql = `CREATE TABLE IF NOT EXISTS ${quoteIdent(fullTableName)} (\n ${pkClause},\n ${cols.join(',\\n ')}\n )`;\n\n const statements = [createSql];\n\n // Create indexes\n for (const idx of parsed.singleIndexes) {\n const idxName = `${fullTableName}_${idx.name}_${idx.unique ? 'uniq' : 'idx'}`;\n const sql = `CREATE ${idx.unique ? 'UNIQUE ' : ''}INDEX IF NOT EXISTS ${quoteIdent(idxName)} ON ${quoteIdent(fullTableName)}(${quoteIdent(idx.name)})`;\n statements.push(sql);\n }\n\n for (const c of parsed.compoundIndexes) {\n const idxName = `${fullTableName}_${c.fields.join('_')}_${c.unique ? 'uniq' : 'idx'}`;\n const colsSql = c.fields.map(f => quoteIdent(f)).join(',');\n const sql = `CREATE ${c.unique ? 'UNIQUE ' : ''}INDEX IF NOT EXISTS ${quoteIdent(idxName)} ON ${quoteIdent(fullTableName)}(${colsSql})`;\n statements.push(sql);\n }\n\n return statements;\n }\n\n private _generateAlterTableSQL(tableName: string, oldParsed: SchemaConfig, newParsed: SchemaConfig): string[] {\n const statements: string[] = [];\n const fullTableName = this._getFullTableName(tableName);\n\n // Find new columns to add\n const oldCols = new Set(oldParsed.indexColumns);\n const newCols = new Set(newParsed.indexColumns);\n\n for (const col of newCols) {\n if (!oldCols.has(col) && col !== newParsed.primaryKey.name) {\n statements.push(`ALTER TABLE ${quoteIdent(fullTableName)} ADD COLUMN ${quoteIdent(col)} TEXT`);\n }\n }\n\n // Handle index changes - drop old indexes and create new ones\n // Drop old single indexes that no longer exist\n for (const oldIdx of oldParsed.singleIndexes) {\n const stillExists = newParsed.singleIndexes.some(newIdx =>\n newIdx.name === oldIdx.name && newIdx.unique === oldIdx.unique\n );\n if (!stillExists) {\n const idxName = `${fullTableName}_${oldIdx.name}_${oldIdx.unique ? 'uniq' : 'idx'}`;\n statements.push(`DROP INDEX IF EXISTS ${quoteIdent(idxName)}`);\n }\n }\n\n // Drop old compound indexes that no longer exist\n for (const oldIdx of oldParsed.compoundIndexes) {\n const stillExists = newParsed.compoundIndexes.some(newIdx =>\n JSON.stringify(newIdx.fields) === JSON.stringify(oldIdx.fields) && newIdx.unique === oldIdx.unique\n );\n if (!stillExists) {\n const idxName = `${fullTableName}_${oldIdx.fields.join('_')}_${oldIdx.unique ? 'uniq' : 'idx'}`;\n statements.push(`DROP INDEX IF EXISTS ${quoteIdent(idxName)}`);\n }\n }\n\n // Create new single indexes\n for (const newIdx of newParsed.singleIndexes) {\n const alreadyExists = oldParsed.singleIndexes.some(oldIdx =>\n oldIdx.name === newIdx.name && oldIdx.unique === newIdx.unique\n );\n if (!alreadyExists) {\n const idxName = `${fullTableName}_${newIdx.name}_${newIdx.unique ? 'uniq' : 'idx'}`;\n const sql = `CREATE ${newIdx.unique ? 'UNIQUE ' : ''}INDEX IF NOT EXISTS ${quoteIdent(idxName)} ON ${quoteIdent(fullTableName)}(${quoteIdent(newIdx.name)})`;\n statements.push(sql);\n }\n }\n\n // Create new compound indexes\n for (const newIdx of newParsed.compoundIndexes) {\n const alreadyExists = oldParsed.compoundIndexes.some(oldIdx =>\n JSON.stringify(oldIdx.fields) === JSON.stringify(newIdx.fields) && oldIdx.unique === newIdx.unique\n );\n if (!alreadyExists) {\n const idxName = `${fullTableName}_${newIdx.fields.join('_')}_${newIdx.unique ? 'uniq' : 'idx'}`;\n const colsSql = newIdx.fields.map(f => quoteIdent(f)).join(',');\n const sql = `CREATE ${newIdx.unique ? 'UNIQUE ' : ''}INDEX IF NOT EXISTS ${quoteIdent(idxName)} ON ${quoteIdent(fullTableName)}(${colsSql})`;\n statements.push(sql);\n }\n }\n\n return statements;\n }\n\n private async _applyStores(def: StoreDefinition): Promise {\n for (const [tableName, schemaStr] of Object.entries(def)) {\n const parsed = parseSchemaString(schemaStr);\n const fullTableName = this._getFullTableName(tableName);\n await this._createTableAndIndexes(fullTableName, parsed);\n const table = new Table(this, tableName, fullTableName, parsed);\n this.#_tables.set(tableName, table as Table);\n (this as any)[tableName] = table; // ergonomic access: db.users\n }\n }\n\n private async _createTableAndIndexes(fullTableName: string, parsed: SchemaConfig): Promise {\n const pk = parsed.primaryKey;\n const cols = [];\n // JSON payload column mirrors Dexie storing whole objects\n cols.push('data TEXT NOT NULL');\n\n // Indexed columns as TEXT for simplicity (works for most comparisons)\n parsed.indexColumns.forEach(col => {\n if (col === pk.name) return; // pk defined separately\n cols.push(`${col} TEXT`);\n });\n\n let pkClause;\n if (pk.auto) {\n pkClause = `${pk.name} INTEGER PRIMARY KEY AUTOINCREMENT`;\n } else {\n pkClause = `${pk.name} TEXT PRIMARY KEY`;\n }\n\n const createSql = `CREATE TABLE IF NOT EXISTS ${quoteIdent(fullTableName)} (\n ${pkClause},\n ${cols.join(',\\n ')}\n )`;\n\n const statements = [createSql];\n\n // Create single-field indexes\n for (const idx of parsed.singleIndexes) {\n const idxName = `${fullTableName}_${idx.name}_${idx.unique ? 'uniq' : 'idx'}`;\n const sql = `CREATE ${idx.unique ? 'UNIQUE ' : ''}INDEX IF NOT EXISTS ${quoteIdent(idxName)} ON ${quoteIdent(fullTableName)}(${quoteIdent(idx.name)})`;\n statements.push(sql);\n }\n\n // Create compound indexes\n for (const c of parsed.compoundIndexes) {\n const idxName = `${fullTableName}_${c.fields.join('_')}_${c.unique ? 'uniq' : 'idx'}`;\n const colsSql = c.fields.map(f => quoteIdent(f)).join(',');\n const sql = `CREATE ${c.unique ? 'UNIQUE ' : ''}INDEX IF NOT EXISTS ${quoteIdent(idxName)} ON ${quoteIdent(fullTableName)}(${colsSql})`;\n statements.push(sql);\n }\n\n await this.client.batch(statements, \"write\");\n }\n}\n\nclass Table = any> {\n private _db: Dexieish;\n public name: string; // logical name (users)\n public fullName: string; // actual table name with prefix (test_users)\n public pk: string;\n private _auto: boolean;\n private _indexedCols: string[];\n\n constructor(db: Dexieish, name: string, fullName: string, parsed: SchemaConfig) {\n this._db = db;\n this.name = name;\n this.fullName = fullName;\n this.pk = parsed.primaryKey.name;\n this._auto = parsed.primaryKey.auto;\n this._indexedCols = Array.from(parsed.indexColumns);\n }\n\n async add(obj: T): Promise {\n const { sql, params } = this._buildInsert(obj, /*replace*/ false);\n const result = await this._db.client.execute({ sql, args: params });\n const id = this._auto ? String(result.lastInsertRowid) : String((obj as any)[this.pk]);\n return id;\n }\n\n async bulkAdd(objs: T[] = []): Promise {\n const statements = objs.map(obj => {\n const { sql, params } = this._buildInsert(obj, false);\n return { sql, args: params };\n });\n await this._db.client.batch(statements, \"write\");\n return objs.length;\n }\n\n async put(obj: T): Promise {\n const { sql, params } = this._buildInsert(obj, /*replace*/ true);\n const result = await this._db.client.execute({ sql, args: params });\n const id = this._auto && (obj as any)[this.pk] == null ? String(result.lastInsertRowid) : String((obj as any)[this.pk]);\n return id;\n }\n\n async update(id: string | number, changes: Partial): Promise {\n const row = await this.get(id);\n if (!row) return 0;\n const merged = { ...row, ...changes };\n const { sql, params } = this._buildUpdate(id, merged);\n const result = await this._db.client.execute({ sql, args: params });\n return Number(result.rowsAffected);\n }\n\n async delete(id: string | number): Promise {\n const result = await this._db.client.execute({\n sql: `DELETE FROM ${quoteIdent(this.fullName)} WHERE ${quoteIdent(this.pk)} = ?`,\n args: [id]\n });\n return Number(result.rowsAffected);\n }\n\n async get(id: string | number): Promise {\n const result = await this._db.client.execute({\n sql: `SELECT * FROM ${quoteIdent(this.fullName)} WHERE ${quoteIdent(this.pk)} = ?`,\n args: [id]\n });\n if (!result.rows.length) return null;\n const row = result.rows[0];\n const obj = fromJSON(row.data);\n return { ...obj, [this.pk]: row[this.pk] };\n }\n\n async toArray(): Promise {\n const result = await this._db.client.execute(`SELECT * FROM ${quoteIdent(this.fullName)}`);\n return result.rows.map((r: any) => ({ ...fromJSON(r.data), [this.pk]: r[this.pk] }));\n }\n\n where(indexOrProp: string): WhereClause {\n // Dexie where() only works on indexed fields or primary key\n return new WhereClause(this, indexOrProp);\n }\n\n orderBy(indexOrProp: string): Collection {\n const c = new Collection(this, '', [], indexOrProp);\n return c;\n }\n\n async count(): Promise {\n const result = await this._db.client.execute(`SELECT COUNT(*) as c FROM ${quoteIdent(this.fullName)}`);\n return Number(result.rows[0].c);\n }\n\n private _buildInsert(obj: T, replace: boolean): { sql: string; params: any[] } {\n const data = toJSON(obj);\n const cols = ['data'];\n const vals = [data];\n\n // include indexed columns from object for fast queries\n for (const col of this._indexedCols) {\n if (col === this.pk) continue; // pk handled separately\n cols.push(col);\n vals.push(toJSON((obj as any)[col]));\n }\n\n if (!this._auto || (obj as any)[this.pk] != null) {\n cols.unshift(this.pk);\n vals.unshift((obj as any)[this.pk]);\n }\n\n const placeholders = cols.map(() => '?').join(',');\n const sql = `INSERT ${replace ? 'OR REPLACE ' : ''}INTO ${quoteIdent(this.fullName)} (${cols.map(quoteIdent).join(',')}) VALUES (${placeholders})`;\n return { sql, params: vals };\n }\n\n private _buildUpdate(id: string | number, obj: T): { sql: string; params: any[] } {\n const sets = ['data = ?'];\n const params = [toJSON(obj)];\n\n for (const col of this._indexedCols) {\n if (col === this.pk) continue;\n sets.push(`${quoteIdent(col)} = ?`);\n params.push(toJSON((obj as any)[col]));\n }\n\n params.push(String(id));\n const sql = `UPDATE ${quoteIdent(this.fullName)} SET ${sets.join(', ')} WHERE ${quoteIdent(this.pk)} = ?`;\n return { sql, params };\n }\n\n}\n\nclass WhereClause = any> {\n constructor(private table: Table, private prop: string) {}\n\n private _collection(op: string, args: any[]): Collection {\n return new Collection(this.table, `${quoteIdent(this.prop)} ${op}`, args);\n }\n\n equals(v: any): Collection { return this._collection('= ?', [toJSON(v)]); }\n notEqual(v: any): Collection { return this._collection('<> ?', [toJSON(v)]); }\n above(v: any): Collection { return this._collection('> ?', [toJSON(v)]); }\n aboveOrEqual(v: any): Collection { return this._collection('>= ?', [toJSON(v)]); }\n below(v: any): Collection { return this._collection('< ?', [toJSON(v)]); }\n belowOrEqual(v: any): Collection { return this._collection('<= ?', [toJSON(v)]); }\n between(a: any, b: any, opts = { includeLower: true, includeUpper: true }): Collection {\n const lowOp = opts.includeLower ? '>= ?' : '> ?';\n const highOp = opts.includeUpper ? '<= ?' : '< ?';\n const clause = `${quoteIdent(this.prop)} ${lowOp} AND ${quoteIdent(this.prop)} ${highOp}`;\n return new Collection(this.table, clause, [toJSON(a), toJSON(b)]);\n }\n anyOf(arr: any[]): Collection {\n const qs = arr.map(() => '?').join(',');\n return new Collection(this.table, `${quoteIdent(this.prop)} IN (${qs})`, arr.map(toJSON));\n }\n startsWith(prefix: string): Collection {\n return this._collection('LIKE ?', [prefix + '%']);\n }\n}\n\nclass Collection = any> {\n public table: Table;\n public whereSql: string;\n public whereParams: any[];\n private _orderBy: string | null;\n private _limit: number | null;\n private _offset: number | null;\n\n constructor(table: Table, whereSql: string, whereParams: any[] = [], orderBy: string | null = null) {\n this.table = table;\n this.whereSql = whereSql; // e.g. 'name = ?' or ''\n this.whereParams = whereParams;\n this._orderBy = orderBy; // column name\n this._limit = null;\n this._offset = null;\n }\n\n orderBy(col: string): Collection { this._orderBy = col; return this; }\n limit(n: number): Collection { this._limit = n; return this; }\n offset(n: number): Collection { this._offset = n; return this; }\n\n async toArray(): Promise {\n const { sql, params } = this._buildSelect();\n const result = await (this.table as any)._db.client.execute({ sql, args: params });\n return result.rows.map((r: any) => ({ ...fromJSON(r.data), [this.table.pk]: r[this.table.pk] }));\n }\n\n async first(): Promise {\n this._limit = 1;\n const arr = await this.toArray();\n return arr[0] ?? undefined;\n }\n\n async count(): Promise {\n const { sql, params } = this._buildSelect(true);\n const result = await (this.table as any)._db.client.execute({ sql, args: params });\n return Number(result.rows[0].c);\n }\n\n private _buildSelect(onlyCount = false): { sql: string; params: any[] } {\n const table = quoteIdent(this.table.fullName);\n let sql = onlyCount ? `SELECT COUNT(*) as c FROM ${table}` : `SELECT * FROM ${table}`;\n const params = [...this.whereParams];\n\n if (this.whereSql) sql += ` WHERE ${this.whereSql}`;\n if (!onlyCount && this._orderBy) sql += ` ORDER BY ${quoteIdent(this._orderBy)}`;\n if (!onlyCount && this._limit != null) sql += ` LIMIT ${this._limit}`;\n if (!onlyCount && this._offset != null) sql += ` OFFSET ${this._offset}`;\n\n return { sql, params };\n }\n}\n\n// ---- Helpers ----\nfunction quoteIdent(name: string): string {\n if (!/^[_a-zA-Z][_a-zA-Z0-9]*$/.test(name)) throw new Error(`Invalid identifier: ${name}`);\n return name;\n}\n\n","deleted","label",[98],"permalink","https://www.val.town/x/maxm/dexieish/code/main.ts","extension","actionData","errors"]