mirror of https://github.com/Chocobozzz/PeerTube
38 lines
1.4 KiB
TypeScript
38 lines
1.4 KiB
TypeScript
import { Job } from 'bullmq'
|
|
import { logger } from '@server/helpers/logger'
|
|
import { VideoChannelSyncModel } from '@server/models/video/video-channel-sync'
|
|
import { AfterVideoChannelImportPayload, VideoChannelSyncState, VideoImportPreventExceptionResult } from '@shared/models'
|
|
|
|
export async function processAfterVideoChannelImport (job: Job) {
|
|
const payload = job.data as AfterVideoChannelImportPayload
|
|
if (!payload.channelSyncId) return
|
|
|
|
logger.info('Processing after video channel import in job %s.', job.id)
|
|
|
|
const sync = await VideoChannelSyncModel.loadWithChannel(payload.channelSyncId)
|
|
if (!sync) {
|
|
logger.error('Unknown sync id %d.', payload.channelSyncId)
|
|
return
|
|
}
|
|
|
|
const childrenValues = await job.getChildrenValues<VideoImportPreventExceptionResult>()
|
|
|
|
let errors = 0
|
|
let successes = 0
|
|
|
|
for (const value of Object.values(childrenValues)) {
|
|
if (value.resultType === 'success') successes++
|
|
else if (value.resultType === 'error') errors++
|
|
}
|
|
|
|
if (errors > 0) {
|
|
sync.state = VideoChannelSyncState.FAILED
|
|
logger.error(`Finished synchronizing "${sync.VideoChannel.Actor.preferredUsername}" with failures.`, { errors, successes })
|
|
} else {
|
|
sync.state = VideoChannelSyncState.SYNCED
|
|
logger.info(`Finished synchronizing "${sync.VideoChannel.Actor.preferredUsername}" successfully.`, { successes })
|
|
}
|
|
|
|
await sync.save()
|
|
}
|