server/lib/activitypub/process/process-update.ts

   1 import * as Bluebird from 'bluebird'
   2 import { ActivityUpdate } from '../../../../shared/models/activitypub'
   3 import { retryTransactionWrapper } from '../../../helpers/database-utils'
   4 import { logger } from '../../../helpers/logger'
   5 import { resetSequelizeInstance } from '../../../helpers/utils'
   6 import { sequelizeTypescript } from '../../../initializers'
   7 import { ActorModel } from '../../../models/activitypub/actor'
   8 import { TagModel } from '../../../models/video/tag'
   9 import { VideoModel } from '../../../models/video/video'
  10 import { VideoFileModel } from '../../../models/video/video-file'
  11 import { getOrCreateActorAndServerAndModel } from '../actor'
  12 import { videoActivityObjectToDBAttributes, videoFileActivityUrlToDBAttributes } from './misc'
  13
  14 async function processUpdateActivity (activity: ActivityUpdate) {
  15   const actor = await getOrCreateActorAndServerAndModel(activity.actor)
  16
  17   if (activity.object.type === 'Video') {
  18     return processUpdateVideo(actor, activity)
  19   }
  20
  21   return
  22 }
  23
  24 // ---------------------------------------------------------------------------
  25
  26 export {
  27   processUpdateActivity
  28 }
  29
  30 // ---------------------------------------------------------------------------
  31
  32 function processUpdateVideo (actor: ActorModel, activity: ActivityUpdate) {
  33   const options = {
  34     arguments: [ actor, activity ],
  35     errorMessage: 'Cannot update the remote video with many retries'
  36   }
  37
  38   return retryTransactionWrapper(updateRemoteVideo, options)
  39 }
  40
  41 async function updateRemoteVideo (actor: ActorModel, activity: ActivityUpdate) {
  42   const videoAttributesToUpdate = activity.object
  43
  44   logger.debug('Updating remote video "%s".', videoAttributesToUpdate.uuid)
  45   let videoInstance: VideoModel
  46   let videoFieldsSave: object
  47
  48   try {
  49     await sequelizeTypescript.transaction(async t => {
  50       const sequelizeOptions = {
  51         transaction: t
  52       }
  53
  54       const videoInstance = await VideoModel.loadByUrlAndPopulateAccount(videoAttributesToUpdate.id, t)
  55       if (!videoInstance) throw new Error('Video ' + videoAttributesToUpdate.id + ' not found.')
  56
  57       const videoChannel = videoInstance.VideoChannel
  58       if (videoChannel.Account.Actor.id !== actor.id) {
  59         throw new Error('Account ' + actor.url + ' does not own video channel ' + videoChannel.Actor.url)
  60       }
  61
  62       const videoData = await videoActivityObjectToDBAttributes(videoChannel, videoAttributesToUpdate, activity.to, activity.cc)
  63       videoInstance.set('name', videoData.name)
  64       videoInstance.set('category', videoData.category)
  65       videoInstance.set('licence', videoData.licence)
  66       videoInstance.set('language', videoData.language)
  67       videoInstance.set('nsfw', videoData.nsfw)
  68       videoInstance.set('privacy', videoData.privacy)
  69       videoInstance.set('description', videoData.description)
  70       videoInstance.set('duration', videoData.duration)
  71       videoInstance.set('createdAt', videoData.createdAt)
  72       videoInstance.set('updatedAt', videoData.updatedAt)
  73       videoInstance.set('views', videoData.views)
  74
  75       await videoInstance.save(sequelizeOptions)
  76
  77       // Remove old video files
  78       const videoFileDestroyTasks: Bluebird<void>[] = []
  79       for (const videoFile of videoInstance.VideoFiles) {
  80         videoFileDestroyTasks.push(videoFile.destroy(sequelizeOptions))
  81       }
  82       await Promise.all(videoFileDestroyTasks)
  83
  84       const videoFileAttributes = videoFileActivityUrlToDBAttributes(videoInstance, videoAttributesToUpdate)
  85       const tasks: Bluebird<any>[] = videoFileAttributes.map(f => VideoFileModel.create(f))
  86       await Promise.all(tasks)
  87
  88       const tags = videoAttributesToUpdate.tag.map(t => t.name)
  89       const tagInstances = await TagModel.findOrCreateTags(tags, t)
  90       await videoInstance.$set('Tags', tagInstances, sequelizeOptions)
  91     })
  92
  93     logger.info('Remote video with uuid %s updated', videoAttributesToUpdate.uuid)
  94   } catch (err) {
  95     if (videoInstance !== undefined && videoFieldsSave !== undefined) {
  96       resetSequelizeInstance(videoInstance, videoFieldsSave)
  97     }
  98
  99     // This is just a debug because we will retry the insert
 100     logger.debug('Cannot update the remote video.', err)
 101     throw err
 102   }
 103 }