server/lib/job-queue/handlers/video-channel-import.ts

   1 import { Job } from 'bullmq'
   2 import { logger } from '@server/helpers/logger'
   3 import { CONFIG } from '@server/initializers/config'
   4 import { synchronizeChannel } from '@server/lib/sync-channel'
   5 import { VideoChannelModel } from '@server/models/video/video-channel'
   6 import { VideoChannelSyncModel } from '@server/models/video/video-channel-sync'
   7 import { MChannelSync } from '@server/types/models'
   8 import { VideoChannelImportPayload } from '@shared/models'
   9
  10 export async function processVideoChannelImport (job: Job) {
  11   const payload = job.data as VideoChannelImportPayload
  12
  13   logger.info('Processing video channel import in job %s.', job.id)
  14
  15   // Channel import requires only http upload to be allowed
  16   if (!CONFIG.IMPORT.VIDEOS.HTTP.ENABLED) {
  17     throw new Error('Cannot import channel as the HTTP upload is disabled')
  18   }
  19
  20   if (!CONFIG.IMPORT.VIDEO_CHANNEL_SYNCHRONIZATION.ENABLED) {
  21     throw new Error('Cannot import channel as the synchronization is disabled')
  22   }
  23
  24   let channelSync: MChannelSync
  25   if (payload.partOfChannelSyncId) {
  26     channelSync = await VideoChannelSyncModel.loadWithChannel(payload.partOfChannelSyncId)
  27
  28     if (!channelSync) {
  29       throw new Error('Unlnown channel sync specified in videos channel import')
  30     }
  31   }
  32
  33   const videoChannel = await VideoChannelModel.loadAndPopulateAccount(payload.videoChannelId)
  34
  35   logger.info(`Starting importing videos from external channel "${payload.externalChannelUrl}" to "${videoChannel.name}" `)
  36
  37   await synchronizeChannel({
  38     channel: videoChannel,
  39     externalChannelUrl: payload.externalChannelUrl,
  40     channelSync,
  41     videosCountLimit: CONFIG.IMPORT.VIDEO_CHANNEL_SYNCHRONIZATION.FULL_SYNC_VIDEOS_LIMIT
  42   })
  43 }