diff options
Diffstat (limited to 'server/lib/job-queue/handlers/video-channel-import.ts')
-rw-r--r-- | server/lib/job-queue/handlers/video-channel-import.ts | 43 |
1 files changed, 0 insertions, 43 deletions
diff --git a/server/lib/job-queue/handlers/video-channel-import.ts b/server/lib/job-queue/handlers/video-channel-import.ts deleted file mode 100644 index 035f88e96..000000000 --- a/server/lib/job-queue/handlers/video-channel-import.ts +++ /dev/null | |||
@@ -1,43 +0,0 @@ | |||
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 | } | ||