1 import { Transaction } from 'sequelize/types'
2 import { resetSequelizeInstance, runInReadCommittedTransaction } from '@server/helpers/database-utils'
3 import { logger, loggerTagsFactory, LoggerTagsFn } from '@server/helpers/logger'
4 import { Notifier } from '@server/lib/notifier'
5 import { PeerTubeSocket } from '@server/lib/peertube-socket'
6 import { autoBlacklistVideoIfNeeded } from '@server/lib/video-blacklist'
7 import { VideoLiveModel } from '@server/models/video/video-live'
8 import { MActor, MChannelAccountLight, MChannelId, MVideoAccountLightBlacklistAllFiles, MVideoFullLight } from '@server/types/models'
9 import { VideoObject, VideoPrivacy } from '@shared/models'
10 import { APVideoAbstractBuilder, getVideoAttributesFromObject, updateVideoRates } from './shared'
12 export class APVideoUpdater extends APVideoAbstractBuilder {
13 private readonly wasPrivateVideo: boolean
14 private readonly wasUnlistedVideo: boolean
16 private readonly videoFieldsSave: any
18 private readonly oldVideoChannel: MChannelAccountLight
20 protected lTags: LoggerTagsFn
23 protected readonly videoObject: VideoObject,
24 private readonly video: MVideoAccountLightBlacklistAllFiles
28 this.wasPrivateVideo = this.video.privacy === VideoPrivacy.PRIVATE
29 this.wasUnlistedVideo = this.video.privacy === VideoPrivacy.UNLISTED
31 this.oldVideoChannel = this.video.VideoChannel
33 this.videoFieldsSave = this.video.toJSON()
35 this.lTags = loggerTagsFactory('ap', 'video', 'update', video.uuid, video.url)
38 async update (overrideTo?: string[]) {
40 'Updating remote video "%s".', this.videoObject.uuid,
41 { videoObject: this.videoObject, ...this.lTags() }
45 const channelActor = await this.getOrCreateVideoChannelFromVideoObject()
47 const thumbnailModel = await this.tryToGenerateThumbnail(this.video)
49 this.checkChannelUpdateOrThrow(channelActor)
51 const videoUpdated = await this.updateVideo(channelActor.VideoChannel, undefined, overrideTo)
53 if (thumbnailModel) await videoUpdated.addAndSaveThumbnail(thumbnailModel)
55 await runInReadCommittedTransaction(async t => {
56 await this.setWebTorrentFiles(videoUpdated, t)
57 await this.setStreamingPlaylists(videoUpdated, t)
61 runInReadCommittedTransaction(t => this.setTags(videoUpdated, t)),
62 runInReadCommittedTransaction(t => this.setTrackers(videoUpdated, t)),
63 this.setOrDeleteLive(videoUpdated),
64 this.setPreview(videoUpdated)
67 await runInReadCommittedTransaction(t => this.setCaptions(videoUpdated, t))
69 await autoBlacklistVideoIfNeeded({
74 transaction: undefined
77 await updateVideoRates(videoUpdated, this.videoObject)
80 if (this.wasPrivateVideo || this.wasUnlistedVideo) {
81 Notifier.Instance.notifyOnNewVideoIfNeeded(videoUpdated)
84 if (videoUpdated.isLive) {
85 PeerTubeSocket.Instance.sendVideoLiveNewState(videoUpdated)
88 logger.info('Remote video with uuid %s updated', this.videoObject.uuid, this.lTags())
92 this.catchUpdateError(err)
96 // Check we can update the channel: we trust the remote server
97 private checkChannelUpdateOrThrow (newChannelActor: MActor) {
98 if (!this.oldVideoChannel.Actor.serverId || !newChannelActor.serverId) {
99 throw new Error('Cannot check old channel/new channel validity because `serverId` is null')
102 if (this.oldVideoChannel.Actor.serverId !== newChannelActor.serverId) {
103 throw new Error(`New channel ${newChannelActor.url} is not on the same server than new channel ${this.oldVideoChannel.Actor.url}`)
107 private updateVideo (channel: MChannelId, transaction?: Transaction, overrideTo?: string[]) {
108 const to = overrideTo || this.videoObject.to
109 const videoData = getVideoAttributesFromObject(channel, this.videoObject, to)
110 this.video.name = videoData.name
111 this.video.uuid = videoData.uuid
112 this.video.url = videoData.url
113 this.video.category = videoData.category
114 this.video.licence = videoData.licence
115 this.video.language = videoData.language
116 this.video.description = videoData.description
117 this.video.support = videoData.support
118 this.video.nsfw = videoData.nsfw
119 this.video.commentsEnabled = videoData.commentsEnabled
120 this.video.downloadEnabled = videoData.downloadEnabled
121 this.video.waitTranscoding = videoData.waitTranscoding
122 this.video.state = videoData.state
123 this.video.duration = videoData.duration
124 this.video.createdAt = videoData.createdAt
125 this.video.publishedAt = videoData.publishedAt
126 this.video.originallyPublishedAt = videoData.originallyPublishedAt
127 this.video.privacy = videoData.privacy
128 this.video.channelId = videoData.channelId
129 this.video.views = videoData.views
130 this.video.isLive = videoData.isLive
132 // Ensures we update the updatedAt attribute, even if main attributes did not change
133 this.video.changed('updatedAt', true)
135 return this.video.save({ transaction }) as Promise<MVideoFullLight>
138 private async setCaptions (videoUpdated: MVideoFullLight, t: Transaction) {
139 await this.insertOrReplaceCaptions(videoUpdated, t)
142 private async setOrDeleteLive (videoUpdated: MVideoFullLight, transaction?: Transaction) {
143 if (!this.video.isLive) return
145 if (this.video.isLive) return this.insertOrReplaceLive(videoUpdated, transaction)
147 // Delete existing live if it exists
148 await VideoLiveModel.destroy({
150 videoId: this.video.id
155 videoUpdated.VideoLive = null
158 private catchUpdateError (err: Error) {
159 if (this.video !== undefined && this.videoFieldsSave !== undefined) {
160 resetSequelizeInstance(this.video, this.videoFieldsSave)
163 // This is just a debug because we will retry the insert
164 logger.debug('Cannot update the remote video.', { err, ...this.lTags() })