/// <reference types="socket.io" />
import Bull from 'bull';
import { Logger } from '../core';
import { EpisodesService } from '../episodes';
import { FilesService } from '../files';
import { NotificationsService } from '../notifications/service';
import { PodacstsRepository } from './repository';
export interface ImportJob {
    ownerId: string;
    podcastId: string;
    podcastName: string;
    episodeId?: string;
    episodeName?: string;
    type: 'cover' | 'audio';
    url: string;
}
export interface FailedJob extends ImportJob {
    reason: string;
}
export interface ImportProgress {
    waiting: number;
    active: number;
    completed: number;
    failed: number;
    failedJobs: FailedJob[];
}
export declare class ImportQueue {
    private readonly podcastRepo;
    private readonly episodeService;
    private readonly filesService;
    private readonly notificationsService;
    private readonly getSocket;
    private readonly logger;
    private readonly queue;
    constructor(logger: Logger, podcastRepo: PodacstsRepository, episodeService: EpisodesService, filesService: FilesService, notificationsService: NotificationsService, getSocket: () => SocketIO.Server);
    addJob(job: ImportJob): Promise<Bull.Job<ImportJob>>;
    getPodcastJobs(podcastId: string): Promise<Array<Bull.Job<ImportJob>>>;
    getEpisodeJobs(episodeId: string): Promise<Array<Bull.Job<ImportJob>>>;
    getEpisodeJobCount(episodeId: string): Promise<number>;
    clean(): Promise<Bull.Job<ImportJob>[]>;
    start(): void;
    process(job: ImportJob): Promise<void>;
    getImportProgress(podcastId: string): Promise<ImportProgress>;
    private processAudio;
    private processCover;
    private checkEpisodeCompleted;
    checkPodcastProgress(userId: string, podcastId: string): Promise<void>;
}