staff_data/apps/server/src/queue/worker/file.processor.ts

import { Job } from 'bullmq';
import { Logger } from '@nestjs/common';
import { QueueJobType } from '../types';
import { ResourceProcessingPipeline } from '@server/models/resource/pipe/resource.pipeline';
import { ImageProcessor } from '@server/models/resource/processor/ImageProcessor';
import { VideoProcessor } from '@server/models/resource/processor/VideoProcessor';
const logger = new Logger('FileProcessorWorker');
const pipeline = new ResourceProcessingPipeline()
  .addProcessor(new ImageProcessor())
  .addProcessor(new VideoProcessor());
export default async function processJob(job: Job<any, any, QueueJobType>) {
  if (job.name === QueueJobType.FILE_PROCESS) {
    console.log('job', job);
    const { resource } = job.data;
    if (!resource) {
      throw new Error('No resource provided in job data');
    }
    const result = await pipeline.execute(resource);

    return result;
  }
}