[{"_1":2,"_175":-5,"_176":-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","a31a1550ad486cf340b818a53bc6ddc8c7db0295","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,"_150":151,"_172":173,"_174":-5},"handle","devto","name","adportal","path","services/imageService.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":-5,"_110":-5,"_12":111,"_112":113,"_114":115,"_116":-5,"_117":118,"_119":32,"_14":120,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_23":130,"_133":134,"_136":137,"_149":20},"id","3d585f8e-2aa1-11f0-9541-569c3dd06744","createdAt",["D",1746553245576],"deletedAt","legacyEnvVars","privacy","unlisted","description","imageUrl","02918d80-2aa1-11f0-8ae4-9344e0a55cd2","pinnedFileId","9829a20a-2aa2-11f0-8816-569c3dd06744","pinPreview",true,"pinMigrated","screenshotVersion",431,"likeCount","33e34e2c-78a0-46e0-9bb4-035d37492531","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_131":132},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/557032ea-741e-493e-dade-5dae3b283600/square512","org",{"_93":94,"_135":132,"_12":-5},"avatar","branch",{"_138":139,"_95":43,"_101":140,"_141":102,"_142":-5,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":96,"_148":94},"version",449,"3d58aafc-2aa1-11f0-9541-569c3dd06744","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":152,"_95":153,"_154":155,"_156":157,"_158":140,"_159":160,"_161":115,"_103":162,"_138":163,"_164":165,"_166":167,"_168":20,"_169":-5,"_97":170},"e4087bbc-2c3f-11f0-abfd-569c3dd06744","imageService.ts","fileId","bdedc2d4-2c3f-11f0-94c3-569c3dd06744","parentId","ed368a55-a55d-4883-a46c-b3a7d7aa58c6","branchId","branchVersion",433,"latest",["D",1746731336871],2,"fileType","script","content","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { ImageMetadata, UploadcareFile, UploadcareGroup } from \"../models/image.ts\";\nimport { getFileInfo, deleteFile, getGroupInfo, storeGroup, storeFile } from \"./uploadcareService.ts\";\nimport { getCached, invalidateCache, invalidateCacheByPrefix } from \"../utils/cacheUtils.ts\";\n\n// Table name for Uploadcare files\nconst UPLOADCARE_FILES_TABLE = 'uploadcare_files_v1';\n\n/**\n * Set up the Uploadcare files table with optimized schema\n */\nexport async function setupImagesTable(): Promise {\n try {\n console.log(`Setting up Uploadcare files table: ${UPLOADCARE_FILES_TABLE}`);\n \n // Create the optimized table with proper indexes\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${UPLOADCARE_FILES_TABLE} (\n file_id TEXT PRIMARY KEY,\n submission_id TEXT NOT NULL,\n created_at TEXT NOT NULL,\n is_group BOOLEAN DEFAULT 0,\n metadata TEXT\n )`);\n \n // Create index for faster lookups by submission\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_submission_id ON ${UPLOADCARE_FILES_TABLE} (submission_id)`);\n \n // Create index for sorting by date\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_created_at ON ${UPLOADCARE_FILES_TABLE} (created_at DESC)`);\n \n console.log(\"Uploadcare files table setup complete\");\n \n // Check if migration is needed, but only run once per deployment\n await runMigrationIfNeeded();\n } catch (error) {\n console.error(\"Error setting up Uploadcare files table:\", error);\n throw error;\n }\n}\n\n// Flag to track if migration has been attempted\nlet migrationAttempted = false;\n\n/**\n * Run migration only if needed and only once\n */\nasync function runMigrationIfNeeded(): Promise {\n // Skip if we've already attempted migration in this session\n if (migrationAttempted) {\n return;\n }\n \n migrationAttempted = true;\n \n try {\n // Check if the new table is empty\n const newTableCount = await sqlite.execute(\n `SELECT COUNT(*) as count FROM ${UPLOADCARE_FILES_TABLE}`\n );\n \n // If the table already has data, skip migration\n if (newTableCount.rows[0].count > 0) {\n console.log(`New table already has ${newTableCount.rows[0].count} records, skipping migration`);\n return;\n }\n \n // Check if old tables exist\n const oldTablesExist = await Promise.all([\n checkTableExists('laura_mepson_images_v1'),\n checkTableExists('laura_mepson_images_v2')\n ]);\n \n const oldTableV1Exists = oldTablesExist[0];\n const oldTableV2Exists = oldTablesExist[1];\n \n if (!oldTableV1Exists && !oldTableV2Exists) {\n console.log('No old tables found, no migration needed');\n return;\n }\n \n console.log('Starting one-time migration of image data...');\n \n // Migrate from v2 table if it exists\n if (oldTableV2Exists) {\n await migrateFromTable('laura_mepson_images_v2', true);\n }\n \n // Migrate from v1 table if it exists and we haven't already migrated from v2\n if (oldTableV1Exists && !oldTableV2Exists) {\n await migrateFromTable('laura_mepson_images_v1', false);\n }\n \n console.log('One-time migration completed successfully');\n } catch (error) {\n console.error('Error during migration check:', error);\n // Continue even if migration check fails\n }\n}\n\n/**\n * Migrate data from an old table to the new table\n */\nasync function migrateFromTable(tableName: string, hasGroupId: boolean): Promise {\n try {\n console.log(`Migrating data from ${tableName}`);\n \n // Build the query based on the table structure\n let query = `SELECT id, submission_id, uploaded_at`;\n if (hasGroupId) {\n query += `, group_id`;\n }\n query += ` FROM ${tableName}`;\n \n const oldData = await sqlite.execute(query);\n \n if (oldData.rows.length === 0) {\n console.log(`No data found in ${tableName}`);\n return;\n }\n \n console.log(`Found ${oldData.rows.length} records to migrate from ${tableName}`);\n \n // Use a transaction for better performance\n await sqlite.execute('BEGIN TRANSACTION');\n \n let migratedCount = 0;\n for (const row of oldData.rows) {\n try {\n // Check if this file is already in the new table\n const exists = await sqlite.execute(\n `SELECT file_id FROM ${UPLOADCARE_FILES_TABLE} WHERE file_id = ?`,\n [row.id]\n );\n \n if (exists.rows.length === 0) {\n // Insert into new table\n await sqlite.execute(\n `INSERT INTO ${UPLOADCARE_FILES_TABLE} (file_id, submission_id, created_at, is_group) \n VALUES (?, ?, ?, ?)`,\n [\n row.id,\n row.submission_id,\n row.uploaded_at || new Date().toISOString(),\n hasGroupId && row.group_id ? 1 : 0\n ]\n );\n migratedCount++;\n }\n } catch (error) {\n console.error(`Error migrating record ${row.id}:`, error);\n // Continue with next record\n }\n }\n \n await sqlite.execute('COMMIT');\n console.log(`Successfully migrated ${migratedCount} records from ${tableName}`);\n } catch (error) {\n await sqlite.execute('ROLLBACK');\n console.error(`Error migrating from ${tableName}:`, error);\n throw error;\n }\n}\n\n/**\n * Check if a table exists in the database\n */\nasync function checkTableExists(tableName: string): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT name FROM sqlite_master WHERE type='table' AND name=?`,\n [tableName]\n );\n \n return result.rows.length > 0;\n } catch (error) {\n console.error(`Error checking if table ${tableName} exists:`, error);\n return false;\n }\n}\n\n/**\n * Link an Uploadcare file to a submission\n */\nexport async function linkUploadcareFile(\n fileId: string,\n submissionId: string,\n isGroup: boolean = false\n): Promise {\n try {\n console.log(`Linking Uploadcare file: ${fileId} to submission: ${submissionId}`);\n \n // Check if this file is already linked\n const existing = await sqlite.execute(\n `SELECT file_id FROM ${UPLOADCARE_FILES_TABLE} WHERE file_id = ?`,\n [fileId]\n );\n \n if (existing.rows.length > 0) {\n console.log(`File ${fileId} is already linked, updating submission_id`);\n \n // Update the existing record\n await sqlite.execute(\n `UPDATE ${UPLOADCARE_FILES_TABLE} SET \n submission_id = ?, \n is_group = ?\n WHERE file_id = ?`,\n [submissionId, isGroup ? 1 : 0, fileId]\n );\n } else {\n // Insert a new record\n await sqlite.execute(\n `INSERT INTO ${UPLOADCARE_FILES_TABLE} (file_id, submission_id, created_at, is_group) \n VALUES (?, ?, ?, ?)`,\n [fileId, submissionId, new Date().toISOString(), isGroup ? 1 : 0]\n );\n }\n \n // Invalidate the cache for this submission's files\n invalidateCache(`submission_files_${submissionId}`);\n \n return true;\n } catch (error) {\n console.error(`Error linking Uploadcare file ${fileId}:`, error);\n return false;\n }\n}\n\n/**\n * Unlink an Uploadcare file from a submission\n */\nexport async function unlinkUploadcareFile(\n fileId: string,\n submissionId: string\n): Promise {\n try {\n console.log(`Unlinking Uploadcare file: ${fileId} from submission: ${submissionId}`);\n \n // Verify the file belongs to this submission\n const existing = await sqlite.execute(\n `SELECT file_id FROM ${UPLOADCARE_FILES_TABLE} \n WHERE file_id = ? AND submission_id = ?`,\n [fileId, submissionId]\n );\n \n if (existing.rows.length === 0) {\n console.log(`File ${fileId} is not linked to submission ${submissionId}`);\n return false;\n }\n \n // Delete the record\n await sqlite.execute(\n `DELETE FROM ${UPLOADCARE_FILES_TABLE} WHERE file_id = ?`,\n [fileId]\n );\n \n // Invalidate the cache for this submission's files\n invalidateCache(`submission_files_${submissionId}`);\n \n return true;\n } catch (error) {\n console.error(`Error unlinking Uploadcare file ${fileId}:`, error);\n return false;\n }\n}\n\n/**\n * Get all Uploadcare files for a submission\n */\nexport async function getSubmissionFiles(submissionId: string): Promise {\n // Use cache with a 5-minute TTL\n return getCached(`submission_files_${submissionId}`, async () => {\n try {\n console.log(`Getting Uploadcare files for submission: ${submissionId}`);\n \n const result = await sqlite.execute(\n `SELECT file_id, is_group FROM ${UPLOADCARE_FILES_TABLE}\n WHERE submission_id = ?\n ORDER BY created_at DESC`,\n [submissionId]\n );\n \n // Process the results to handle groups\n const fileIds: string[] = [];\n \n for (const row of result.rows) {\n const fileId = row.file_id;\n const isGroup = row.is_group === 1;\n \n if (isGroup) {\n try {\n // For groups, we need to get the individual files\n console.log(`Expanding group: ${fileId}`);\n const groupInfo = await getGroupInfo(fileId);\n \n if (groupInfo && groupInfo.files) {\n // Add each file in the group\n for (let i = 0; i < groupInfo.files.length; i++) {\n const file = groupInfo.files[i];\n fileIds.push(file.uuid);\n }\n } else {\n // If we can't get group info, just add the group ID\n fileIds.push(fileId);\n }\n } catch (groupError) {\n console.error(`Error expanding group ${fileId}:`, groupError);\n // If there's an error, just add the group ID\n fileIds.push(fileId);\n }\n } else {\n // For individual files, just add the file ID\n fileIds.push(fileId);\n }\n }\n \n return fileIds;\n } catch (error) {\n console.error(`Error getting Uploadcare files for submission ${submissionId}:`, error);\n return [];\n }\n });\n}\n\n/**\n * Get image metadata from Uploadcare\n * This is a simplified version that uses the Uploadcare API directly\n * instead of maintaining our own metadata\n */\nexport async function getImageMetadata(imageId: string): Promise {\n try {\n console.log(`Getting image metadata for: ${imageId}`);\n \n // Get file info from Uploadcare API (this is cached)\n const fileInfo = await getFileInfo(imageId);\n \n if (!fileInfo) {\n return null;\n }\n \n // Get submission ID from our database\n const result = await sqlite.execute(\n `SELECT submission_id FROM ${UPLOADCARE_FILES_TABLE} WHERE file_id = ?`,\n [imageId]\n );\n \n const submissionId = result.rows.length > 0 ? result.rows[0].submission_id : null;\n \n // Return the metadata\n return {\n id: fileInfo.uuid,\n originalName: fileInfo.originalFilename,\n contentType: fileInfo.mimeType,\n size: fileInfo.size,\n uploadedAt: fileInfo.uploadedAt,\n submissionId: submissionId,\n cdnUrl: fileInfo.cdnUrl,\n groupId: null // We don't track this anymore\n };\n } catch (error) {\n console.error(`Error getting image metadata for ${imageId}:`, error);\n return null;\n }\n}\n\n/**\n * List all images for a submission\n * This is a simplified version that uses our optimized table\n */\nexport async function listSubmissionImages(submissionId: string): Promise {\n // Use cache with a 5-minute TTL\n return getCached(`submission_images_${submissionId}`, async () => {\n try {\n console.log(`Listing images for submission: ${submissionId}`);\n \n // Get all file IDs for this submission\n const fileIds = await getSubmissionFiles(submissionId);\n \n if (fileIds.length === 0) {\n return [];\n }\n \n // Get metadata for each file\n const images: ImageMetadata[] = [];\n \n for (const fileId of fileIds) {\n try {\n const metadata = await getImageMetadata(fileId);\n if (metadata) {\n images.push(metadata);\n }\n } catch (error) {\n console.error(`Error getting metadata for file ${fileId}:`, error);\n // Continue with next file\n }\n }\n \n // Sort by uploaded date in descending order\n images.sort((a, b) => {\n return new Date(b.uploadedAt).getTime() - new Date(a.uploadedAt).getTime();\n });\n \n return images;\n } catch (error) {\n console.error(`Error listing submission images for ${submissionId}:`, error);\n return [];\n }\n });\n}\n\n/**\n * Delete image from Uploadcare and remove from our database\n */\nexport async function deleteImage(imageId: string): Promise {\n try {\n console.log(`Deleting image: ${imageId}`);\n \n // Get the submission ID before deleting\n const result = await sqlite.execute(\n `SELECT submission_id FROM ${UPLOADCARE_FILES_TABLE} WHERE file_id = ?`,\n [imageId]\n );\n \n if (result.rows.length === 0) {\n console.error(`Image not found in database: ${imageId}`);\n return false;\n }\n \n const submissionId = result.rows[0].submission_id;\n \n // Try to delete from Uploadcare\n let uploadcareDeleteSuccess = false;\n try {\n console.log(`Deleting image from Uploadcare: ${imageId}`);\n uploadcareDeleteSuccess = await deleteFile(imageId);\n \n if (!uploadcareDeleteSuccess) {\n console.warn(`Failed to delete image from Uploadcare: ${imageId}`);\n // Continue with database deletion even if Uploadcare deletion fails\n } else {\n console.log(`Successfully deleted image from Uploadcare: ${imageId}`);\n }\n } catch (uploadcareError) {\n console.error(`Error deleting image from Uploadcare: ${imageId}`, uploadcareError);\n // Continue with database deletion even if Uploadcare deletion fails\n }\n \n // Delete from our database\n try {\n console.log(`Deleting image from database: ${imageId}`);\n await sqlite.execute(\n `DELETE FROM ${UPLOADCARE_FILES_TABLE} WHERE file_id = ?`,\n [imageId]\n );\n console.log(`Successfully deleted image from database: ${imageId}`);\n \n // Invalidate caches\n invalidateCache(`submission_files_${submissionId}`);\n invalidateCache(`submission_images_${submissionId}`);\n \n return true;\n } catch (dbError) {\n console.error(`Database error deleting image ${imageId}:`, dbError);\n return false;\n }\n } catch (error) {\n console.error(`Error deleting image ${imageId}:`, error);\n return false;\n }\n}\n\n/**\n * Register an Uploadcare file in our system\n */\nexport async function registerUploadcareFile(\n uploadcareUuid: string,\n submissionId: string,\n groupId?: string\n): Promise {\n try {\n console.log(`Registering Uploadcare file: ${uploadcareUuid} for submission: ${submissionId}`);\n \n // Get file info from Uploadcare\n let fileInfo;\n try {\n console.log(`Fetching file info from Uploadcare for UUID: ${uploadcareUuid}`);\n fileInfo = await getFileInfo(uploadcareUuid);\n console.log('Successfully retrieved file info from Uploadcare:', fileInfo);\n } catch (fileInfoError) {\n console.error(`Error getting file info from Uploadcare for ${uploadcareUuid}:`, fileInfoError);\n throw fileInfoError;\n }\n \n // Link the file to the submission in our database\n const isGroup = !!groupId;\n const linked = await linkUploadcareFile(uploadcareUuid, submissionId, isGroup);\n \n if (!linked) {\n console.error(`Failed to link file ${uploadcareUuid} to submission ${submissionId}`);\n throw new Error(`Failed to link file to submission`);\n }\n \n // Store the file permanently on Uploadcare\n try {\n await storeFile(uploadcareUuid);\n } catch (storeError) {\n console.error(`Error storing file ${uploadcareUuid} permanently:`, storeError);\n // Continue even if storing fails\n }\n \n // Return the metadata\n return {\n id: fileInfo.uuid,\n originalName: fileInfo.originalFilename,\n contentType: fileInfo.mimeType,\n size: fileInfo.size,\n uploadedAt: fileInfo.uploadedAt,\n submissionId: submissionId,\n cdnUrl: fileInfo.cdnUrl,\n groupId: groupId || null\n };\n } catch (error) {\n console.error(`Error registering Uploadcare file ${uploadcareUuid}:`, error);\n throw error;\n }\n}\n\n/**\n * Register an Uploadcare file group in our system\n */\nexport async function registerUploadcareGroup(\n groupId: string,\n submissionId: string\n): Promise {\n try {\n console.log(`Registering Uploadcare group: ${groupId} for submission: ${submissionId}`);\n \n // Get group info from Uploadcare\n const groupInfo = await getGroupInfo(groupId);\n \n // Link the group to the submission\n await linkUploadcareFile(groupId, submissionId, true);\n \n // Store the group permanently\n await storeGroup(groupId);\n \n // Register each file in the group\n const registeredFiles: ImageMetadata[] = [];\n \n for (const file of groupInfo.files) {\n try {\n const metadata = await registerUploadcareFile(file.uuid, submissionId, groupId);\n if (metadata) {\n registeredFiles.push(metadata);\n }\n } catch (fileError) {\n console.error(`Error registering file ${file.uuid} from group ${groupId}:`, fileError);\n // Continue with next file\n }\n }\n \n // Invalidate caches\n invalidateCache(`submission_files_${submissionId}`);\n invalidateCache(`submission_images_${submissionId}`);\n \n return registeredFiles;\n } catch (error) {\n console.error(`Error registering Uploadcare group ${groupId}:`, error);\n return [];\n }\n}","deleted","label",[171,153],"services","permalink","https://www.val.town/x/devto/adportal/code/services/imageService.ts","extension","actionData","errors"]