server/lib/job-queue/handlers/video-redundancy.ts

   1 import * as Bull from 'bull'
   2 import { logger } from '../../../helpers/logger'
   3 import { VideosRedundancyScheduler } from '@server/lib/schedulers/videos-redundancy-scheduler'
   4 import { VideoRedundancyPayload } from '@shared/models'
   5
   6 async function processVideoRedundancy (job: Bull.Job) {
   7   const payload = job.data as VideoRedundancyPayload
   8   logger.info('Processing video redundancy in job %d.', job.id)
   9
  10   return VideosRedundancyScheduler.Instance.createManualRedundancy(payload.videoId)
  11 }
  12
  13 // ---------------------------------------------------------------------------
  14
  15 export {
  16   processVideoRedundancy
  17 }