55 lines
1.5 KiB
TypeScript
55 lines
1.5 KiB
TypeScript
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();
|