[{"_1":2,"_172":-5,"_173":-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","7037b4412b49b7328160fa57e59f17dfe8779fc7","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,"_169":170,"_171":-5},"handle","MrGo2","name","untitled-3286","path","backend/database/queries.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":-5,"_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","ab7e1d5e-36d7-11f0-8b68-9e149126039e","createdAt",["D",1747896037150],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","51b038d0-36d6-11f0-8e46-8179a1001ad4","pinnedFileId","pinPreview","screenshotVersion","likeCount","51795cb9-e2c7-47d7-8303-666f03c66267","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_127":128},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yeFJLUmtvdTgxSG5SRjZqNk1YSzdmcElHVHcifQ","org",{"_93":94,"_131":128,"_12":111},"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",22,"ab7e5698-36d7-11f0-8b68-9e149126039e","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},"83ef5b02-3959-11f0-b987-9e149126039e","queries.ts","fileId","83ef5bb6-3959-11f0-b987-9e149126039e","parentId","114977b2-55f8-47de-9c16-a3e765e2fbed","branchId","branchVersion",7,"latest",true,["D",1748171707679],"fileType","script","content","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { FileStatus, BatchStatusResponse, BatchFileStatus } from \"../../shared/types.ts\";\n\nexport interface BatchRecord {\n id: string;\n status: string;\n total_files: number;\n completed_files: number;\n failed_files: number;\n created_at: string;\n updated_at: string;\n}\n\nexport interface FileRecord {\n id: string;\n batch_id: string;\n original_name: string;\n file_size: number;\n file_type: string;\n status: string;\n progress: number;\n blob_key?: string;\n error_message?: string;\n checksum?: string;\n created_at: string;\n updated_at: string;\n}\n\n// Batch operations\nexport async function createBatch(batchId: string, totalFiles: number): Promise {\n await sqlite.execute(\n `INSERT INTO upload_batches_v1 (id, total_files) VALUES (?, ?)`,\n [batchId, totalFiles]\n );\n}\n\nexport async function getBatch(batchId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM upload_batches_v1 WHERE id = ?`,\n [batchId]\n );\n return result.length > 0 ? result[0] as BatchRecord : null;\n}\n\nexport async function updateBatchStatus(\n batchId: string, \n status: string, \n completedFiles?: number, \n failedFiles?: number\n): Promise {\n let query = `UPDATE upload_batches_v1 SET status = ?, updated_at = CURRENT_TIMESTAMP`;\n const params: any[] = [status];\n \n if (completedFiles !== undefined) {\n query += `, completed_files = ?`;\n params.push(completedFiles);\n }\n \n if (failedFiles !== undefined) {\n query += `, failed_files = ?`;\n params.push(failedFiles);\n }\n \n query += ` WHERE id = ?`;\n params.push(batchId);\n \n await sqlite.execute(query, params);\n}\n\n// File operations\nexport async function createFile(\n fileId: string,\n batchId: string,\n originalName: string,\n fileSize: number,\n fileType: string,\n checksum?: string\n): Promise {\n await sqlite.execute(\n `INSERT INTO upload_files_v1 (id, batch_id, original_name, file_size, file_type, checksum) \n VALUES (?, ?, ?, ?, ?, ?)`,\n [fileId, batchId, originalName, fileSize, fileType, checksum || null]\n );\n}\n\nexport async function updateFileStatus(\n fileId: string,\n status: FileStatus,\n progress?: number,\n blobKey?: string,\n errorMessage?: string\n): Promise {\n let query = `UPDATE upload_files_v1 SET status = ?, updated_at = CURRENT_TIMESTAMP`;\n const params: any[] = [status];\n \n if (progress !== undefined) {\n query += `, progress = ?`;\n params.push(progress);\n }\n \n if (blobKey) {\n query += `, blob_key = ?`;\n params.push(blobKey);\n }\n \n if (errorMessage) {\n query += `, error_message = ?`;\n params.push(errorMessage);\n }\n \n query += ` WHERE id = ?`;\n params.push(fileId);\n \n await sqlite.execute(query, params);\n}\n\nexport async function getFilesByBatch(batchId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM upload_files_v1 WHERE batch_id = ? ORDER BY created_at ASC`,\n [batchId]\n );\n return result as FileRecord[];\n}\n\nexport async function getFile(fileId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM upload_files_v1 WHERE id = ?`,\n [fileId]\n );\n return result.length > 0 ? result[0] as FileRecord : null;\n}\n\nexport async function getBatchWithFiles(batchId: string): Promise {\n const batch = await getBatch(batchId);\n if (!batch) return null;\n \n const files = await getFilesByBatch(batchId);\n \n const batchFiles: BatchFileStatus[] = files.map(file => ({\n id: file.id,\n original_name: file.original_name,\n status: file.status as FileStatus,\n progress: file.progress,\n url: file.blob_key ? `/api/v1/files/${file.id}/download` : undefined,\n error: file.error_message || undefined,\n size: file.file_size,\n type: file.file_type\n }));\n \n return {\n batch_id: batch.id,\n status: batch.status as any,\n total_files: batch.total_files,\n completed_files: batch.completed_files,\n failed_files: batch.failed_files,\n files: batchFiles,\n created_at: batch.created_at,\n updated_at: batch.updated_at\n };\n}\n\nexport async function updateBatchProgress(batchId: string): Promise {\n // Calculate current progress from files\n const files = await getFilesByBatch(batchId);\n const completedFiles = files.filter(f => f.status === FileStatus.SUCCESS).length;\n const failedFiles = files.filter(f => f.status === FileStatus.ERROR).length;\n const totalFiles = files.length;\n \n let batchStatus = 'uploading';\n if (completedFiles + failedFiles === totalFiles) {\n batchStatus = failedFiles === 0 ? 'completed' : 'failed';\n } else if (files.some(f => f.status === FileStatus.PROCESSING)) {\n batchStatus = 'processing';\n }\n \n await updateBatchStatus(batchId, batchStatus, completedFiles, failedFiles);\n}\n\nexport async function deleteBatch(batchId: string): Promise {\n // Delete files first (foreign key constraint)\n await sqlite.execute(`DELETE FROM upload_files_v1 WHERE batch_id = ?`, [batchId]);\n await sqlite.execute(`DELETE FROM upload_batches_v1 WHERE id = ?`, [batchId]);\n}","deleted","label",[167,168,149],"backend","database","permalink","https://www.val.town/x/MrGo2/untitled-3286/code/backend/database/queries.ts","extension","actionData","errors"]