import { EventEmitter } from 'events';

export interface ProgressUpdate {
    filename: string;
    progress: number;
    status: 'processing' | 'complete' | 'error';
    message?: string;
}

class ProgressManager {
    private static instance: ProgressManager;
    private emitter: EventEmitter;
    private activeJobs: Map<string, ProgressUpdate>;
    private processVideo: boolean;

    private constructor() {
        this.emitter = new EventEmitter();
        this.activeJobs = new Map();
        this.processVideo = process.env["EB_PROCESS_VIDEO"] !== "false";
    }

    static getInstance(): ProgressManager {
        if (!ProgressManager.instance) {
            ProgressManager.instance = new ProgressManager();
        }
        return ProgressManager.instance;
    }

    updateProgress(update: ProgressUpdate) {
        if (!this.processVideo) return;
        
        this.activeJobs.set(update.filename, update);
        this.emitter.emit('progress', update);
    }

    subscribeToUpdates(callback: (update: ProgressUpdate) => void) {
        if (!this.processVideo) return;
        
        this.emitter.on('progress', callback);
    }

    unsubscribeFromUpdates(callback: (update: ProgressUpdate) => void) {
        if (!this.processVideo) return;
        
        this.emitter.off('progress', callback);
    }

    getJobStatus(filename: string): ProgressUpdate | undefined {
        if (!this.processVideo) return undefined;
        
        return this.activeJobs.get(filename);
    }
}

export const progressManager = ProgressManager.getInstance();