livedash-node/fix-import-status.ts

import { PrismaClient, ProcessingStage, ProcessingStatus } from '@prisma/client';
import { ProcessingStatusManager } from './lib/processingStatusManager';

const prisma = new PrismaClient();

async function fixProcessingStatus() {
  try {
    console.log('=== FIXING PROCESSING STATUS (REFACTORED SYSTEM) ===\n');
    
    // Check for any failed processing stages that might need retry
    const failedSessions = await ProcessingStatusManager.getFailedSessions();
    
    console.log(`Found ${failedSessions.length} failed processing stages`);
    
    if (failedSessions.length > 0) {
      console.log('\nFailed sessions by stage:');
      const failuresByStage: Record<string, number> = {};
      
      failedSessions.forEach(failure => {
        failuresByStage[failure.stage] = (failuresByStage[failure.stage] || 0) + 1;
      });
      
      Object.entries(failuresByStage).forEach(([stage, count]) => {
        console.log(`  ${stage}: ${count} failures`);
      });
      
      // Show sample failed sessions
      console.log('\nSample failed sessions:');
      failedSessions.slice(0, 5).forEach(failure => {
        console.log(`  ${failure.session.import?.externalSessionId || failure.sessionId}: ${failure.stage} - ${failure.errorMessage}`);
      });
      
      // Ask if user wants to reset failed stages for retry
      console.log('\nTo reset failed stages for retry, you can use:');
      console.log('ProcessingStatusManager.resetStageForRetry(sessionId, stage)');
    }
    
    // Check for sessions that might be stuck in IN_PROGRESS
    const stuckSessions = await prisma.sessionProcessingStatus.findMany({
      where: {
        status: ProcessingStatus.IN_PROGRESS,
        startedAt: {
          lt: new Date(Date.now() - 30 * 60 * 1000) // Started more than 30 minutes ago
        }
      },
      include: {
        session: {
          include: {
            import: true
          }
        }
      }
    });
    
    if (stuckSessions.length > 0) {
      console.log(`\nFound ${stuckSessions.length} sessions stuck in IN_PROGRESS state:`);
      stuckSessions.forEach(stuck => {
        console.log(`  ${stuck.session.import?.externalSessionId || stuck.sessionId}: ${stuck.stage} (started: ${stuck.startedAt})`);
      });
      
      console.log('\nThese sessions may need to be reset to PENDING status for retry.');
    }
    
    // Show current pipeline status
    console.log('\n=== CURRENT PIPELINE STATUS ===');
    const pipelineStatus = await ProcessingStatusManager.getPipelineStatus();
    
    const stages = ['CSV_IMPORT', 'TRANSCRIPT_FETCH', 'SESSION_CREATION', 'AI_ANALYSIS', 'QUESTION_EXTRACTION'];
    
    for (const stage of stages) {
      const stageData = pipelineStatus.pipeline[stage] || {};
      const pending = stageData.PENDING || 0;
      const inProgress = stageData.IN_PROGRESS || 0;
      const completed = stageData.COMPLETED || 0;
      const failed = stageData.FAILED || 0;
      const skipped = stageData.SKIPPED || 0;
      
      console.log(`${stage}: ${completed} completed, ${pending} pending, ${inProgress} in progress, ${failed} failed, ${skipped} skipped`);
    }
    
  } catch (error) {
    console.error('Error fixing processing status:', error);
  } finally {
    await prisma.$disconnect();
  }
}

fixProcessingStatus();