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
   5 export type VideoRedundancyPayload = {
   6   videoId: number
   7 }
   8
   9 async function processVideoRedundancy (job: Bull.Job) {
  10   const payload = job.data as VideoRedundancyPayload
  11   logger.info('Processing video redundancy in job %d.', job.id)
  12
  13   return VideosRedundancyScheduler.Instance.createManualRedundancy(payload.videoId)
  14 }
  15
  16 // ---------------------------------------------------------------------------
  17
  18 export {
  19   processVideoRedundancy
  20 }