import { VideoChannelModel } from '@server/models/video/video-channel'
import { VideoChannelSyncModel } from '@server/models/video/video-channel-sync'
import { MChannelSync } from '@server/types/models'
-import { VideoChannelImportPayload, VideoChannelSyncState } from '@shared/models'
+import { VideoChannelImportPayload } from '@shared/models'
export async function processVideoChannelImport (job: Job) {
const payload = job.data as VideoChannelImportPayload
const videoChannel = await VideoChannelModel.loadAndPopulateAccount(payload.videoChannelId)
- try {
- logger.info(`Starting importing videos from external channel "${payload.externalChannelUrl}" to "${videoChannel.name}" `)
-
- await synchronizeChannel({
- channel: videoChannel,
- externalChannelUrl: payload.externalChannelUrl,
- channelSync
- })
- } catch (err) {
- logger.error(`Failed to import channel ${videoChannel.name}`, { err })
- channelSync.state = VideoChannelSyncState.FAILED
- await channelSync.save()
- }
+ logger.info(`Starting importing videos from external channel "${payload.externalChannelUrl}" to "${videoChannel.name}" `)
+
+ await synchronizeChannel({
+ channel: videoChannel,
+ externalChannelUrl: payload.externalChannelUrl,
+ channelSync,
+ videosCountLimit: CONFIG.IMPORT.VIDEO_CHANNEL_SYNCHRONIZATION.FULL_SYNC_VIDEOS_LIMIT
+ })
}