[{"_1":2,"_290":-5,"_291":-5},"loaderData",{"_3":4,"_93":94,"_254":255},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":22,"_29":22,"_30":22,"_31":-5,"_32":33,"_34":22,"_35":22},"auth",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"tokenType","session_token","sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_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,"_64":65},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","6050acf0705e6826bb1b68e27572c5b8979c5bd9","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",{"_68":69},"__internal_clerk_state",{"_70":71,"_72":47,"_73":74,"_75":74,"_76":22,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":22,"_92":22},"__clerk_ssr_state",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_83":22,"_21":22,"_84":74,"_85":86,"_87":74,"_88":47,"_89":22,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/_app.x.$handle.$name",{"_95":96,"_97":98,"_99":45,"_100":101,"_102":103,"_104":105,"_158":159,"_229":230,"_231":232,"_243":244,"_173":245,"_248":-5,"_249":-5,"_250":22,"_251":22,"_252":253},"handle","peterqliu","name","SQLiteTable","branchName","path","new-file-8420.ts","version",302,"project",{"_106":107,"_97":98,"_108":109,"_110":-5,"_111":112,"_113":114,"_115":-5,"_116":-5,"_14":117,"_118":-5,"_119":112,"_120":-5,"_121":-5,"_122":33,"_16":123,"_124":125,"_126":127,"_128":129,"_130":129,"_131":132,"_133":132,"_134":132,"_135":129,"_136":129,"_23":137,"_140":141,"_145":146,"_157":22},"id","29484b28-27b6-11f0-aecd-569c3dd06744","createdAt",["D",1746232377860],"deletedAt","legacyEnvVars",true,"privacy","public","description","imageUrl","f129b0f0-09bd-41ac-a51c-c16933d81d65","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","5cdb635f-04df-409e-bb23-93b87a60f6ca","tursoName","29484b2827b611f0aecd569c3dd06744","tursoHostname","29484b2827b611f0aecd569c3dd06744-val-town.aws-us-east-2.turso.io","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_138":139},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJrYUVVM1VyRHRhckNnNGxidGEwUUdaSFRDYSJ9","org",{"_95":96,"_142":139,"_14":117,"_143":144},"avatar","tier","pro","branch",{"_102":147,"_97":45,"_106":148,"_149":107,"_150":-5,"_151":-5,"_152":-5,"_153":-5,"_154":-5,"_155":98,"_156":96},342,"29488f20-27b6-11f0-aecd-569c3dd06744","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","tree",[160,181,192,202,212,220],{"_106":161,"_97":162,"_163":164,"_165":-5,"_166":148,"_167":168,"_169":22,"_108":170,"_102":171,"_172":173,"_174":175,"_176":22,"_177":-5,"_178":179,"_100":180},"6d788eee-68a6-11f0-95a2-0224a6c84d84","README.md","fileId","294ad15e-27b6-11f0-aecd-569c3dd06744","parentId","branchId","branchVersion",177,"latest",["D",1753372445883],3,"fileType","file","content","# SQLiteTable\n\n\nA thin abstraction over SQLite, to work with tables from vals. All methods async.\n\n## Usage\n\n```javascript\nnew SQLiteTable(\"myTable\")\n .create({\n id: \"unique primary key\",\n title: \"text\",\n body: \"text\",\n created: \"integer\",\n })\n```\n\n## API\n\n\nBasics\n\n### `new SQLiteTable(title:string)`\n\nStart an instance of SQLiteTable.\n\n### `.create(scheme:TableScheme)`\n\nCreate this table in your VT SQLite storage. `scheme` is a JSON with column names as keys, and definitions as values (see above for example). Run this only once per table.\n\n### `.drop()`\n\nDrop this table from your VT SQLite storage.\n\n### `.exists()`\nReturns whether this table exists in storage.\n\nTable operations\n\n### `.insertRow(rowData)`\n\nAdd a new row to your table. `rowData` is a JSON with column names as keys, and row values as values.\n\n```javascript\ntable.insertRow({\n id: 1234,\n title: 'Post title',\n body: 'Post body',\n created: 12345678\n})\n```\n\n### `.getRow(conditions?, options?)`\n\nReturns the first row matching the given conditions.\n\nconditions: Either a JSON object of column conditions, or a raw SQL WHERE clause as a string.\n\noptions (optional):\n\njson (default false): Return a plain JS object instead of raw DB output.\n```javascript\ntable.getRow({\n id: 1234,\n title: 'Post title'\n})\n```\n\n### `.getRows(conditions?, options?)`\n\nSame, except returns all matching rows.\n\n### `.countRows(conditions?)`\n\nReturns a count of all rows in the table that match the condition.\n\n### `.deleteRows(conditions?)`\n\nDeletes all rows in the table that match the condition.\n\n### `.updateRow(conditions?, rowData)`\n\nModifies all rows in the table that match the condition. `rowData` is a JSON of key-value pairs to change; it does not affect any columns not mentioned.\n\n```javascript\ntable.updateRow(\n {id: 1234},\n {title: 'New title! The existing body text is not mentioned here so it is unaffected'}\n)\n```\n\n### .streamRowBatches(onBatch: Function)\nIterate over all rows in batches of 1000, passing each batch to onBatch.\n\n```javascript\nawait table.streamRowBatches((batch) => {\n for (const row of batch) {\n console.log(row);\n }\n});\n\nUtilities \n```\n### `.AISuggestCmd(plainText: string): Promise`\n\nUse AI to generate a suggested SQLite command for a given text description of your intent.\n\n\n```javascript\nconst cmd = await table.AISuggestCmd(\"show me all active users sorted by join date\");\n```","deleted","label","children",[],[162],{"_106":182,"_97":183,"_163":184,"_165":-5,"_166":148,"_167":185,"_169":22,"_108":186,"_102":187,"_172":188,"_174":189,"_176":22,"_177":-5,"_178":190,"_100":191},"02eef960-0cfb-11f1-a950-42dde27851f2","debug.tsx","fd3e0832-fd62-11f0-8d5d-42dde27851f2",295,["D",1771440765057],9,"script","import { SQLiteTable } from \"./main.tsx\";\n\nconst table = new SQLiteTable(\"selftable\", { scope: \"val\" });\nawait table.insertRow({ name: \"bob\", number: 4 });\nconsole.log(await table.getRows(undefined, { json: true }));",[],[183],{"_106":193,"_97":194,"_163":195,"_165":-5,"_166":148,"_167":196,"_169":22,"_108":197,"_102":198,"_172":188,"_174":199,"_176":22,"_177":-5,"_178":200,"_100":201},"1bd82b4a-0d0a-11f1-b068-42dde27851f2","http.tsx","1b9b762e-0d04-11f1-9fa0-42dde27851f2",300,["D",1771447249301],4,"export function http(req:Request): Promise {\n const url = new URL(req.url);\n const pathSegments = url.pathname.split(\"/\").filter((segment) =>\n segment.length > 0\n );\n\n // Extract the operation from the path (e.g., \"query\" from \"/query/\")\n const operation = pathSegments[0];\n\n try {\n switch (operation) {\n case \"getRow\":\n return await this._handleOperation(req, \"POST\", async (body) => {\n // Support both direct string and object with query property\n const queryText = typeof body === \"string\"\n ? body\n : (body.query || body.text || JSON.stringify(body));\n\n if (!queryText) {\n throw new Error(\"Query text is required\");\n }\n\n const results = await this.query(queryText);\n return results;\n });\n\n default:\n return Response.json(\n {\n error:\n `Unknown operation: ${operation}. Supported operations: getRow`,\n },\n { status: 400 },\n );\n }\n } catch (error) {\n console.error(`Error in ${operation} operation:`, error);\n return Response.json(\n { error: error.message || \"Internal server error\" },\n { status: 500 },\n );\n }\n }\n\n /**\n * Generic handler for HTTP operations with common validation and error handling\n */\n private async _handleOperation(\n req: Request,\n expectedMethod: string,\n handler: (body: any) => Promise,\n ): Promise {\n // Method validation\n if (req.method !== expectedMethod) {\n return Response.json(\n { error: `This endpoint only accepts ${expectedMethod} requests` },\n { status: 405 },\n );\n }\n\n try {\n // Parse body for non-GET requests\n const body = expectedMethod !== \"GET\" ? await req.json() : null;\n\n // Execute the specific handler logic\n const result = await handler(body);\n\n return Response.json(result);\n } catch (error) {\n // Handle validation errors (400) vs server errors (500)\n const status = error.message.includes(\"required\") ||\n error.message.includes(\"array\") ||\n error.message.includes(\"text\")\n ? 400\n : 500;\n\n return Response.json({ error: error.message }, { status });\n }\n }\n}",[],[194],{"_106":203,"_97":204,"_163":205,"_165":-5,"_166":148,"_167":206,"_169":22,"_108":207,"_102":208,"_172":188,"_174":209,"_176":22,"_177":-5,"_178":210,"_100":211},"493cfb84-0cfa-11f1-8cb0-42dde27851f2","main.tsx","294acb64-27b6-11f0-aecd-569c3dd06744",293,["D",1771440453511],269,"import valSQLite, {\n sqlite as userSQLite,\n} from \"https://esm.town/v/std/sqlite/main.ts?v=14\";\n\nimport {\n AISuggestCmd,\n assembleBulkInsertCommand,\n assembleBulkUpsertCommand,\n SQLiteTableInfo,\n streamTableRows,\n} from \"./utils\";\n\ntype ColumnDefinition = string | {\n type?: \"integer\" | \"number\" | \"string\" | \"text\";\n primaryKey?: boolean;\n unique?: boolean;\n};\n\ntype TableScheme = { [key: string]: ColumnDefinition };\n\n// select conditions can be a JSON object of key-value pairs of strict equalities,\n// bound by AND operators, or a freeform string of direct sqlite query language\ntype RowSelectCondition = object | string;\n\nexport class SQLiteTable {\n constructor(tableName: string, options?: { scope?: \"user\" | \"val\" }) {\n this.name = tableName;\n this.scope = options?.scope || \"user\";\n this.sqlite = this.scope === \"val\" ? valSQLite : userSQLite;\n return this;\n }\n\n name: string = \"newTable\";\n scope: \"user\" | \"val\";\n sqlite: typeof userSQLite;\n\n async create(scheme: TableScheme) {\n const { name } = this;\n await this.sqlite.execute(`create table if not exists ${name}(\n ${parseColumnDefinition(scheme)}\n )`);\n }\n\n async drop() {\n const { name } = this;\n await this.sqlite.execute(`drop table ${name}`);\n }\n\n async exists() {\n const { name } = this;\n const table = await this.sqlite.execute(\n `SELECT * FROM sqlite_master WHERE type='table' AND name='${name}';`,\n );\n const { rows: [result] } = table;\n return result;\n }\n\n async getInfo() {\n const { name } = this;\n return await SQLiteTableInfo(name);\n }\n\n async insertRow(rowData: object) {\n const { name } = this;\n const keys = Object.keys(rowData);\n try {\n const sql = `insert into ${name}(${keys.join(\", \")}) values (${\n keys.map((k) => `:${k}`).join(\", \")\n })`;\n const insert = await this.sqlite.execute({\n sql,\n args: rowData,\n });\n\n return insert;\n } catch (err) {\n console.log(err);\n }\n }\n\n async updateRow(conditions: RowSelectCondition, rowUpdate: object) {\n const { name } = this;\n const rowUpdateString = stringifyEqualities(rowUpdate)\n .join(\", \\n\");\n const fullString = `UPDATE ${name} SET ${rowUpdateString}${\n formatConditions(conditions)\n }`;\n await this.sqlite.execute(fullString);\n }\n\n async batchInsert(records: object[]) {\n const { name } = this;\n const fullString = assembleBulkInsertCommand(name, records);\n return await this.sqlite.execute(fullString);\n }\n\n async batchUpsert(records: object[], conflictKey: string) {\n const { name } = this;\n const fullString = assembleBulkUpsertCommand(name, records, conflictKey);\n return await this.sqlite.execute(fullString);\n }\n\n // get first matching row\n async getRow(\n conditions?: RowSelectCondition,\n outputOptions?: { json?: boolean; columns?: string[] },\n ) {\n return await this._selectQuery({\n conditions,\n outputOptions,\n single: true,\n });\n }\n\n // get all rows meeting a certain condition. option to return as an array of json objects\n async getRows(\n conditions?: RowSelectCondition,\n outputOptions?: {\n json?: boolean;\n orderBy?: string;\n limit?: number;\n columns?: string[];\n },\n ) {\n return await this._selectQuery({\n conditions,\n outputOptions,\n single: false,\n });\n }\n\n // count rows meeting a condition\n async countRows(conditions?: RowSelectCondition) {\n const { name } = this;\n const { rows: [[count]] } = await this.sqlite.execute(\n `select count(*) from ${name}${formatConditions(conditions)}`,\n );\n return count;\n }\n\n // delete all rows meeting a condition\n async deleteRows(conditions?: RowSelectCondition) {\n const { name } = this;\n return await sqlite.execute(\n `delete from ${name}${formatConditions(conditions)}`,\n );\n }\n\n async getDescending(\n column: string,\n limit: number,\n options: { excludedValue?: any; json?: boolean } = {},\n ) {\n const { excludedValue, json } = options;\n\n const conditions = excludedValue !== undefined\n ? { [column]: { notEqual: excludedValue } }\n : undefined;\n\n return await this._selectQuery({\n conditions,\n outputOptions: {\n descendBy: column,\n limit,\n json,\n },\n });\n }\n\n async getAscending(\n column: string,\n limit: number,\n options: { excludedValue?: any; json?: boolean } = {},\n ) {\n const { excludedValue, json } = options;\n\n const conditions = excludedValue !== undefined\n ? { [column]: { notEqual: excludedValue } }\n : undefined;\n\n return await this._selectQuery({\n conditions,\n outputOptions: {\n ascendBy: column,\n limit,\n json,\n },\n });\n }\n\n async streamRowBatches(onBatch: Function, options?: { stopAt: number }) {\n const { name } = this;\n return await streamTableRows(onBatch, {\n tableName: name,\n stopAt: options?.stopAt || Infinity,\n batchSize: 1000,\n });\n }\n\n /**\n * Add a new column to the table.\n * @param columnName name of the new column\n * @param columnScheme type and constraints for the new column\n */\n async addColumn(columnName: string, columnScheme: ColumnDefinition) {\n const { name } = this;\n // parseColumnDefinition will return e.g. \"colName TEXT UNIQUE\"\n const colDef = parseColumnDefinition({ [columnName]: columnScheme });\n await sqlite.execute(`ALTER TABLE ${name} ADD COLUMN ${colDef}`);\n }\n\n /**\n * Remove a column from the table.\n * Requires SQLite 3.35.0 or later for native DROP COLUMN support.\n * @param columnName name of the column to drop\n */\n async removeColumn(columnName: string) {\n const { name } = this;\n // SQLite 3.35+ supports: ALTER TABLE ... DROP COLUMN ...\n await sqlite.execute(`ALTER TABLE ${name} DROP COLUMN ${columnName}`);\n }\n\n async AISuggestCmd(plainText: string): Promise {\n const { name } = this;\n return await AISuggestCmd(plainText, name);\n }\n\n private async _selectQuery({\n conditions,\n outputOptions = {},\n single = false,\n }: {\n conditions?: RowSelectCondition;\n outputOptions?: {\n json?: boolean;\n ascendBy?: string;\n descendBy?: string;\n limit?: number;\n columns?: string[];\n };\n single?: boolean;\n }) {\n const { name } = this;\n\n const columnL = outputOptions.columns?.length\n ? outputOptions.columns.join(\", \")\n : \"*\";\n\n let query = `select ${columnL} from ${name}${formatConditions(conditions)}`;\n\n if (single) {\n query += ` LIMIT 1`;\n } else {\n if (outputOptions.ascendBy && outputOptions.descendBy) {\n throw new Error(\n \"Specify only one of 'ascendBy' or 'descendBy', not both.\",\n );\n }\n\n if (outputOptions.ascendBy) {\n query += ` ORDER BY ${outputOptions.ascendBy} ASC`;\n } else if (outputOptions.descendBy) {\n query += ` ORDER BY ${outputOptions.descendBy} DESC`;\n }\n\n if (outputOptions.limit != null) {\n query += ` LIMIT ${outputOptions.limit}`;\n }\n }\n\n const rawOutput = await this.sqlite.execute(query);\n\n // if (!outputOptions.json) return rawOutput;\n\n // Non-JSON output\n if (!outputOptions.json) {\n return single ? (rawOutput.rows?.[0] ?? undefined) : rawOutput;\n }\n\n // JSON output\n const jsonRows = formatJSONOutput(rawOutput);\n return single ? (jsonRows[0] ?? undefined) : jsonRows;\n // const { rows, columnList } = rawOutput;\n\n // if (single) {\n // const row = rows[0];\n // if (!row) return undefined;\n // console.log(row);\n // return Object.fromEntries(row.map((val, idx) => [columnList[idx], val]));\n // } else {\n // return formatJSONOutput(rawOutput);\n // }\n }\n}\n\nexport function formatJSONOutput(rawOutput) {\n if (!rawOutput) return [];\n const { rows, columns } = rawOutput;\n if (!rows?.length) return [];\n const json = rows.map((row) => {\n // rows may already be objects (newer sqlite lib versions)\n if (!Array.isArray(row)) return row;\n return Object.fromEntries(\n row.map((rowVal, rowValIndex) => [columns[rowValIndex], rowVal]),\n );\n });\n\n return json;\n}\n\nfunction parseColumnDefinition(scheme: TableScheme): string {\n return Object.entries(scheme)\n .map(([columnName, columnScheme]) => {\n // If user passed a raw string, trust it as-is\n if (typeof columnScheme === \"string\") {\n return `${columnName} ${columnScheme}`;\n }\n\n const parts: string[] = [];\n const type = columnScheme.type ?? \"text\";\n parts.push(type.toUpperCase());\n\n if (columnScheme.primaryKey) parts.push(\"PRIMARY KEY\");\n if (columnScheme.unique) parts.push(\"UNIQUE\");\n\n return `${columnName} ${parts.join(\" \")}`;\n })\n .join(\",\\n\");\n}\n\nfunction stringifyEqualities(obj: Object): string[] {\n return Object.entries(obj).map(([key, value]) => {\n // Primitive: default to equality\n if (\n typeof value === \"string\" ||\n typeof value === \"number\" ||\n typeof value === \"boolean\" ||\n value === null\n ) {\n const keyValue = [key, formatValue(value)];\n return keyValue.join(value === null ? \" IS \" : \" = \");\n }\n\n // Operator object\n if (typeof value === \"object\" && value !== null) {\n const clauses = Object.entries(value).map(([op, val]) => {\n const formatted = formatValue(val);\n switch (op) {\n case \"greaterThan\":\n return `${key} > ${formatted}`;\n case \"greaterThanOrEqual\":\n return `${key} >= ${formatted}`;\n case \"lessThan\":\n return `${key} < ${formatted}`;\n case \"lessThanOrEqual\":\n return `${key} <= ${formatted}`;\n case \"notEqual\":\n return `${key} != ${formatted}`;\n case \"like\":\n return `${key} LIKE ${formatted}`;\n case \"in\": {\n if (!Array.isArray(val)) {\n throw new Error(`'in' expects an array for key \"${key}\"`);\n }\n if (val.length === 0) return \"0\"; // IN () is invalid; treat as always-false\n const list = val.map(formatValue).join(\", \");\n return `${key} IN (${list})`;\n }\n\n default:\n throw new Error(`Unsupported operator: ${op}`);\n }\n });\n return clauses.join(\" AND \");\n }\n\n throw new Error(`Invalid condition for key \"${key}\": ${value}`);\n });\n}\n\nfunction formatValue(value: any): string {\n if (typeof value === \"string\") return `'${sanitizeString(value)}'`;\n if (value === null) return \"NULL\";\n return String(value);\n}\n\nfunction formatConditions(conditions?: RowSelectCondition): string {\n if (!conditions) return \"\";\n if (typeof conditions === \"string\") return ` WHERE ${conditions}`;\n\n const conditionsString = stringifyEqualities(conditions)\n .join(\" AND \");\n return ` WHERE ${conditionsString}`;\n}\n\n// Escape single quotes by doubling them\n\nfunction sanitizeString(string: string): string {\n return string.replace(/'/g, \"''\");\n}",[],[204],{"_106":213,"_97":101,"_163":214,"_165":-5,"_166":148,"_167":103,"_169":22,"_108":215,"_102":216,"_172":217,"_174":74,"_176":22,"_177":-5,"_178":218,"_100":219},"2bb8f562-0d0a-11f1-9b41-42dde27851f2","281b626e-0d0a-11f1-a3a9-42dde27851f2",["D",1771447275940],1,"http",[],[101],{"_106":221,"_97":222,"_163":223,"_165":-5,"_166":148,"_167":224,"_169":112,"_108":225,"_102":187,"_172":188,"_174":226,"_176":22,"_177":-5,"_178":227,"_100":228},"4a01ac86-fd41-11f0-9a90-42dde27851f2","utils","14f88bd6-68bd-11f0-9b48-0224a6c84d84",268,["D",1769711730465],"import { OpenAI } from \"https://esm.town/v/std/openai\";\n// import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nexport async function AISuggestCmd(plainText: string, tableName?: string): Promise {\n if (!plainText) return \"No prompt provided\";\n\n const tableSpecificSnippet = tableName ? `for a table named ${tableName}` : \"\";\n\n const decodedPrompt =\n `Give me just the sqlite command ${tableSpecificSnippet}, with no formatting or comments: ${plainText}`;\n\n // Initialize OpenAI\n const openai = new OpenAI();\n\n try {\n // Generate response using OpenAI\n const completion = await openai.chat.completions.create({\n messages: [\n { role: \"user\", content: decodedPrompt },\n ],\n max_tokens: 3000,\n });\n\n const [{ message: { content } }] = completion.choices;\n // Return the response as JSON\n console.log(\"AI suggestion: \", content);\n return content;\n } catch (error) {\n return \"Failed to generate response\";\n }\n}\n\nexport async function SQLiteTableInfo(tableName: string) {\n const {sqlite} = this;\n try {\n // First, verify the table exists\n const tableExists = await sqlite.execute(\n `SELECT name FROM sqlite_master WHERE type='table' AND name = ?`,\n [tableName],\n );\n\n if (tableExists.rows.length === 0) {\n throw new Error(`Table ${tableName} does not exist`);\n }\n\n // Get table-specific information\n const tableInfo = await sqlite.execute(`PRAGMA table_info(${tableName})`);\n\n // Count rows in the table\n const rowCountResult = await sqlite.execute(`SELECT COUNT(*) as row_count FROM ${tableName}`);\n const rowCount = rowCountResult.rows[0].row_count;\n\n // Get table size details using SQLite-specific queries\n const pageSizeResult = await sqlite.execute(`PRAGMA page_size`);\n const pageSize = pageSizeResult.rows[0].page_size;\n\n // Get page count for this specific table\n const pageCountResult = await sqlite.execute(\n `\n SELECT count(*) as page_count \n FROM sqlite_master \n WHERE type='table' AND name=? \n AND rootpage > 0\n `,\n [tableName],\n );\n const pageCount = pageCountResult.rows[0].page_count;\n\n // Estimate table size based on page count and page size\n const estimatedTableBytes = pageCount * pageSize;\n\n // Get index information\n const indexInfoResult = await sqlite.execute(\n `\n SELECT name, sql \n FROM sqlite_master \n WHERE type='index' AND tbl_name=?\n `,\n [tableName],\n );\n\n return {\n // tableName: tableName,\n columns: tableInfo.rows.map(row => ({\n name: row.name,\n type: row.type,\n })),\n rowCount: rowCount,\n pageSize: pageSize,\n pageCount: pageCount,\n estimatedTableBytes: estimatedTableBytes,\n humanReadableSize: formatBytes(estimatedTableBytes),\n // indexes: indexInfoResult.rows.map(index => index.name),\n // indexCount: indexInfoResult.rows.length,\n };\n } catch (error) {\n return {\n error: `Error getting size for table ${tableName}: ${error.message}`,\n tableName: tableName,\n };\n }\n}\n\nfunction formatBytes(bytes: number, decimals = 2): string {\n if (bytes === 0) return \"0 Bytes\";\n\n const k = 1024;\n const dm = decimals < 0 ? 0 : decimals;\n const sizes = [\"Bytes\", \"KB\", \"MB\", \"GB\", \"TB\", \"PB\", \"EB\", \"ZB\", \"YB\"];\n\n const i = Math.floor(Math.log(bytes) / Math.log(k));\n\n return parseFloat((bytes / Math.pow(k, i)).toFixed(dm)) + \" \" + sizes[i];\n}\n\n\n// Generates a bulk SQLite INSERT … ON CONFLICT upsert statement that MERGES records by conflictKey:\n// inserts new rows, updates existing rows only for fields explicitly provided, and preserves\n// existing values when incoming fields are missing (undefined). Requires a UNIQUE constraint\n// on conflictKey. Does not perform validation, type coercion, parameter binding, or per-row logic.\n\nexport const assembleBulkUpsertCommand = (\n tableName: string,\n records: object[],\n conflictKey: string,\n) => {\n if (!records || records.length === 0) {\n throw new Error(\"No records provided\");\n }\n\n if (!conflictKey) {\n throw new Error(\"Conflict key must be specified\");\n }\n\n const columns = Array.from(\n new Set(records.flatMap(record => Object.keys(record))),\n );\n\n if (!columns.includes(conflictKey)) {\n throw new Error(`Conflict key '${conflictKey}' not found in records`);\n }\n\n const values = records.map(record => {\n const rowValues = columns.map(col => {\n const value = record[col];\n return value === undefined\n ? \"NULL\"\n : `'${String(value).replace(/'/g, \"''\")}'`;\n });\n return `(${rowValues.join(\", \")})`;\n }).join(\",\\n \");\n\n const nonConflictColumns = columns.filter(col => col !== conflictKey);\n\n return `\n INSERT INTO ${tableName} (${columns.join(\", \")})\n VALUES\n ${values}\n ON CONFLICT(${conflictKey}) DO UPDATE SET\n ${nonConflictColumns\n .map(col => `${col} = COALESCE(excluded.${col}, ${col})`)\n .join(\",\\n \")};\n `.trim();\n};\n\n\nexport const assembleBulkInsertCommand = (tableName: string, records: object[]): string => {\n if (!records || records.length === 0) {\n throw new Error(\"No records provided\");\n }\n\n // Collect all column names from records\n const columns = Array.from(\n new Set(records.flatMap(record => Object.keys(record)))\n );\n\n // Escape and serialize values\n const values = records.map(record => {\n const rowValues = columns.map(col => {\n const value = record[col];\n return value === undefined ? \"NULL\" : `'${String(value).replace(/'/g, \"''\")}'`;\n });\n return `(${rowValues.join(\", \")})`;\n }).join(\",\\n \");\n\n return `\n INSERT INTO ${tableName} (${columns.join(\", \")})\n VALUES\n ${values};\n `.trim();\n};\n\nexport async function streamTableRows(\n processRowFn: (rows: Record[]) => void | Promise,\n options: {\n tableName?: string;\n batchSize?: number;\n stopAt?: number; // number of batches to process\n } = {},\n): Promise {\n const {sqlite} = this;\n const {\n tableName,\n batchSize = 1000,\n stopAt = Infinity,\n } = options;\n\n const KEY = \"SQLiteUtils\";\n const effectiveTableName = tableName || `${KEY}_rows`;\n\n try {\n if (!/^[a-zA-Z0-9_]+$/.test(effectiveTableName)) {\n throw new Error(\"Invalid table name. Only alphanumeric characters and underscores allowed.\");\n }\n\n let offset = 0;\n let batchCount = 0;\n\n while (batchCount < stopAt) {\n const query = `\n SELECT * FROM ${effectiveTableName}\n LIMIT ${batchSize}\n OFFSET ${offset}\n `;\n\n const result = await sqlite.execute(query);\n\n if (result.rows.length === 0) {\n break;\n }\n\n await processRowFn(result.rows);\n\n offset += batchSize;\n batchCount += 1;\n }\n\n return true;\n } catch (error) {\n console.error(\"Error streaming rows:\", error);\n throw error;\n }\n}",[],[222],"files",[160,181,192,202,212,220],"counts",{"_233":33,"_234":216,"_235":33,"_236":237,"_240":241},"pulls","branches","forks","envVars",{"_238":33,"_239":33},"count","emptyCount","connections",{"_238":33,"_242":33},"unfilledCount","contents",[],{"_106":213,"_97":101,"_163":214,"_165":-5,"_166":148,"_167":103,"_169":22,"_108":246,"_102":216,"_172":217,"_174":74,"_176":22,"_177":-5,"_100":247},["D",1771447275940],[101],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_95":96,"_97":98,"_99":45,"_102":103,"_100":101,"_104":256,"_158":261,"_229":280,"_173":281,"_243":283,"_284":-5,"_285":-5,"_286":-5,"_287":-5,"_288":289,"_236":-5},{"_106":107,"_97":98,"_108":257,"_110":-5,"_111":112,"_113":114,"_115":-5,"_116":-5,"_14":117,"_118":-5,"_119":112,"_120":-5,"_121":-5,"_122":33,"_16":123,"_124":125,"_126":127,"_128":129,"_130":129,"_131":132,"_133":132,"_134":132,"_135":129,"_136":129,"_23":258,"_140":259,"_145":260,"_157":22},["D",1746232377860],{"_95":96,"_138":139},{"_95":96,"_142":139,"_14":117,"_143":144},{"_102":147,"_97":45,"_106":148,"_149":107,"_150":-5,"_151":-5,"_152":-5,"_153":-5,"_154":-5,"_155":98,"_156":96},[262,265,268,271,274,277],{"_106":161,"_97":162,"_163":164,"_165":-5,"_166":148,"_167":168,"_169":22,"_108":170,"_102":171,"_172":173,"_174":175,"_176":22,"_177":-5,"_178":263,"_100":264},[],[162],{"_106":182,"_97":183,"_163":184,"_165":-5,"_166":148,"_167":185,"_169":22,"_108":186,"_102":187,"_172":188,"_174":189,"_176":22,"_177":-5,"_178":266,"_100":267},[],[183],{"_106":193,"_97":194,"_163":195,"_165":-5,"_166":148,"_167":196,"_169":22,"_108":197,"_102":198,"_172":188,"_174":199,"_176":22,"_177":-5,"_178":269,"_100":270},[],[194],{"_106":203,"_97":204,"_163":205,"_165":-5,"_166":148,"_167":206,"_169":22,"_108":207,"_102":208,"_172":188,"_174":209,"_176":22,"_177":-5,"_178":272,"_100":273},[],[204],{"_106":213,"_97":101,"_163":214,"_165":-5,"_166":148,"_167":103,"_169":22,"_108":215,"_102":216,"_172":217,"_174":74,"_176":22,"_177":-5,"_178":275,"_100":276},[],[101],{"_106":221,"_97":222,"_163":223,"_165":-5,"_166":148,"_167":224,"_169":112,"_108":225,"_102":187,"_172":188,"_174":226,"_176":22,"_177":-5,"_178":278,"_100":279},[],[222],[262,265,268,271,274,277],{"_106":213,"_97":101,"_163":214,"_165":-5,"_166":148,"_167":103,"_169":22,"_108":246,"_102":216,"_172":217,"_174":74,"_176":22,"_177":-5,"_100":282},[101],[],"upstream","pull","ahead","behind","templates",[],"actionData","errors"]