From 97922ecf640eb449f0664f23f9f69eeb4d9f5cd9 Mon Sep 17 00:00:00 2001 From: Chocobozzz Date: Tue, 27 Sep 2022 09:47:38 +0200 Subject: Handle sync failure in synchronizeChannel fn --- .../lib/job-queue/handlers/video-channel-import.ts | 22 ++++++++-------------- 1 file changed, 8 insertions(+), 14 deletions(-) (limited to 'server/lib/job-queue') diff --git a/server/lib/job-queue/handlers/video-channel-import.ts b/server/lib/job-queue/handlers/video-channel-import.ts index 600292844..c3dd8a688 100644 --- a/server/lib/job-queue/handlers/video-channel-import.ts +++ b/server/lib/job-queue/handlers/video-channel-import.ts @@ -5,7 +5,7 @@ import { synchronizeChannel } from '@server/lib/sync-channel' 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 @@ -32,17 +32,11 @@ export async function processVideoChannelImport (job: Job) { 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 + }) } -- cgit v1.2.3