1 import { logger, loggerTagsFactory } from '@server/helpers/logger'
2 import { PeerTubeRequestError } from '@server/helpers/requests'
3 import { ActorFollowScoreCache } from '@server/lib/files-cache'
4 import { VideoLoadByUrlType } from '@server/lib/model-loaders'
5 import { VideoModel } from '@server/models/video/video'
6 import { MVideoAccountLightBlacklistAllFiles, MVideoThumbnail } from '@server/types/models'
7 import { HttpStatusCode } from '@shared/core-utils'
8 import { fetchRemoteVideo, SyncParam, syncVideoExternalAttributes } from './shared'
9 import { APVideoUpdater } from './updater'
11 async function refreshVideoIfNeeded (options: {
12 video: MVideoThumbnail
13 fetchedType: VideoLoadByUrlType
15 }): Promise<MVideoThumbnail> {
16 if (!options.video.isOutdated()) return options.video
18 // We need more attributes if the argument video was fetched with not enough joints
19 const video = options.fetchedType === 'all'
20 ? options.video as MVideoAccountLightBlacklistAllFiles
21 : await VideoModel.loadByUrlAndPopulateAccount(options.video.url)
23 const lTags = loggerTagsFactory('ap', 'video', 'refresh', video.uuid, video.url)
26 const { videoObject } = await fetchRemoteVideo(video.url)
28 if (videoObject === undefined) {
29 logger.warn('Cannot refresh remote video %s: invalid body.', video.url, lTags())
31 await video.setAsRefreshed()
35 const videoUpdater = new APVideoUpdater(videoObject, video)
36 await videoUpdater.update()
38 await syncVideoExternalAttributes(video, videoObject, options.syncParam)
40 ActorFollowScoreCache.Instance.addGoodServerId(video.VideoChannel.Actor.serverId)
44 if ((err as PeerTubeRequestError).statusCode === HttpStatusCode.NOT_FOUND_404) {
45 logger.info('Cannot refresh remote video %s: video does not exist anymore. Deleting it.', video.url, lTags())
47 // Video does not exist anymore
52 logger.warn('Cannot refresh video %s.', options.video.url, { err, ...lTags() })
54 ActorFollowScoreCache.Instance.addBadServerId(video.VideoChannel.Actor.serverId)
56 // Don't refresh in loop
57 await video.setAsRefreshed()
62 // ---------------------------------------------------------------------------