logs

src/lib/db/trainerScanning.ts

@@ -7,13 +7,6 @@ export async function initializeTrainerScanProgress(imagePaths: string[]): Promi
     console.log('🔍 initializeTrainerScanProgress: Starting with', imagePaths.length, 'paths');
     console.log('🔍 initializeTrainerScanProgress: First few paths:', imagePaths.slice(0, 3));
     
-    console.log('🔍 initializeTrainerScanProgress: Creating transaction...');
-    const tx = db.transaction([TRAINER_SCAN_STORE], 'readwrite');
-    console.log('🔍 initializeTrainerScanProgress: Transaction created');
-    
-    const store = tx.objectStore(TRAINER_SCAN_STORE);
-    console.log('🔍 initializeTrainerScanProgress: Got object store');
-    
     let processedCount = 0;
     let skippedCount = 0;
     
@@ -67,9 +60,9 @@ export async function initializeTrainerScanProgress(imagePaths: string[]): Promi
         const remoteUrl = `https://huggingface.co/datasets/Fraser/piclets/resolve/main/${imagePath}`;
         console.log(`🔍 initializeTrainerScanProgress: Remote URL: ${remoteUrl}`);
         
-        // Check if this path already exists to avoid duplicates
+        // Check if this path already exists to avoid duplicates (using Dexie syntax)
         console.log(`🔍 initializeTrainerScanProgress: Checking for existing record...`);
-        const existing = await store.get(imagePath);
+        const existing = await db.trainerScanProgress.get(imagePath);
         console.log(`🔍 initializeTrainerScanProgress: Existing record:`, existing ? 'found' : 'not found');
         
         if (!existing) {
@@ -82,7 +75,7 @@ export async function initializeTrainerScanProgress(imagePaths: string[]): Promi
           };
           
           console.log(`🔍 initializeTrainerScanProgress: Adding record:`, progressRecord);
-          await store.add(progressRecord);
+          await db.trainerScanProgress.add(progressRecord);
           console.log(`🔍 initializeTrainerScanProgress: Record added successfully`);
           processedCount++;
         } else {
@@ -110,10 +103,6 @@ export async function initializeTrainerScanProgress(imagePaths: string[]): Promi
     
     console.log(`✅ Trainer scan initialization complete: ${processedCount} records processed, ${skippedCount} skipped`);
     
-    console.log('🔍 initializeTrainerScanProgress: Completing transaction...');
-    await tx.complete;
-    console.log('🔍 initializeTrainerScanProgress: Transaction completed successfully');
-    
   } catch (error) {
     console.error('❌ initializeTrainerScanProgress: Fatal error during initialization:', error);
     console.error('❌ initializeTrainerScanProgress: Error details:', {
@@ -126,22 +115,13 @@ export async function initializeTrainerScanProgress(imagePaths: string[]): Promi
 
 // Get next pending image to process
 export async function getNextPendingImage(): Promise<TrainerScanProgress | null> {
-  const tx = db.transaction([TRAINER_SCAN_STORE], 'readonly');
-  const store = tx.objectStore(TRAINER_SCAN_STORE);
-  
-  // Get all pending records
-  const pendingRecords: TrainerScanProgress[] = [];
-  let cursor = await store.openCursor();
-  
-  while (cursor) {
-    if (cursor.value.status === 'pending') {
-      pendingRecords.push(cursor.value);
-    }
-    cursor = await cursor.continue();
+  try {
+    const pendingRecord = await db.trainerScanProgress.where('status').equals('pending').first();
+    return pendingRecord || null;
+  } catch (error) {
+    console.error('❌ Failed to get next pending image:', error);
+    return null;
   }
-  
-  // Return the first pending record (if any)
-  return pendingRecords.length > 0 ? pendingRecords[0] : null;
 }
 
 // Update scan progress status
@@ -149,16 +129,12 @@ export async function updateScanProgress(
   imagePath: string, 
   updates: Partial<Omit<TrainerScanProgress, 'id' | 'imagePath'>>
 ): Promise<void> {
-  const tx = db.transaction([TRAINER_SCAN_STORE], 'readwrite');
-  const store = tx.objectStore(TRAINER_SCAN_STORE);
-  
-  const existing = await store.get(imagePath);
-  if (existing) {
-    const updated = { ...existing, ...updates };
-    await store.put(updated);
+  try {
+    await db.trainerScanProgress.update(imagePath, updates);
+  } catch (error) {
+    console.error(`❌ Failed to update scan progress for ${imagePath}:`, error);
+    throw error;
   }
-  
-  await tx.complete;
 }
 
 // Mark image processing as started