server/controllers/api/videos/ownership.ts

   1 import * as express from 'express'
   2 import { logger } from '../../../helpers/logger'
   3 import { sequelizeTypescript } from '../../../initializers'
   4 import {
   5   asyncMiddleware,
   6   asyncRetryTransactionMiddleware,
   7   authenticate,
   8   paginationValidator,
   9   setDefaultPagination,
  10   videosAcceptChangeOwnershipValidator,
  11   videosChangeOwnershipValidator,
  12   videosTerminateChangeOwnershipValidator
  13 } from '../../../middlewares'
  14 import { VideoChangeOwnershipModel } from '../../../models/video/video-change-ownership'
  15 import { VideoChangeOwnershipStatus, VideoPrivacy, VideoState } from '../../../../shared/models/videos'
  16 import { VideoChannelModel } from '../../../models/video/video-channel'
  17 import { getFormattedObjects } from '../../../helpers/utils'
  18 import { changeVideoChannelShare } from '../../../lib/activitypub'
  19 import { sendUpdateVideo } from '../../../lib/activitypub/send'
  20
  21 const ownershipVideoRouter = express.Router()
  22
  23 ownershipVideoRouter.post('/:videoId/give-ownership',
  24   authenticate,
  25   asyncMiddleware(videosChangeOwnershipValidator),
  26   asyncRetryTransactionMiddleware(giveVideoOwnership)
  27 )
  28
  29 ownershipVideoRouter.get('/ownership',
  30   authenticate,
  31   paginationValidator,
  32   setDefaultPagination,
  33   asyncRetryTransactionMiddleware(listVideoOwnership)
  34 )
  35
  36 ownershipVideoRouter.post('/ownership/:id/accept',
  37   authenticate,
  38   asyncMiddleware(videosTerminateChangeOwnershipValidator),
  39   asyncMiddleware(videosAcceptChangeOwnershipValidator),
  40   asyncRetryTransactionMiddleware(acceptOwnership)
  41 )
  42
  43 ownershipVideoRouter.post('/ownership/:id/refuse',
  44   authenticate,
  45   asyncMiddleware(videosTerminateChangeOwnershipValidator),
  46   asyncRetryTransactionMiddleware(refuseOwnership)
  47 )
  48
  49 // ---------------------------------------------------------------------------
  50
  51 export {
  52   ownershipVideoRouter
  53 }
  54
  55 // ---------------------------------------------------------------------------
  56
  57 async function giveVideoOwnership (req: express.Request, res: express.Response) {
  58   const videoInstance = res.locals.video
  59   const initiatorAccountId = res.locals.oauth.token.User.Account.id
  60   const nextOwner = res.locals.nextOwner
  61
  62   await sequelizeTypescript.transaction(t => {
  63     return VideoChangeOwnershipModel.findOrCreate({
  64       where: {
  65         initiatorAccountId,
  66         nextOwnerAccountId: nextOwner.id,
  67         videoId: videoInstance.id,
  68         status: VideoChangeOwnershipStatus.WAITING
  69       },
  70       defaults: {
  71         initiatorAccountId,
  72         nextOwnerAccountId: nextOwner.id,
  73         videoId: videoInstance.id,
  74         status: VideoChangeOwnershipStatus.WAITING
  75       },
  76       transaction: t
  77     })
  78   })
  79
  80   logger.info('Ownership change for video %s created.', videoInstance.name)
  81   return res.type('json').status(204).end()
  82 }
  83
  84 async function listVideoOwnership (req: express.Request, res: express.Response) {
  85   const currentAccountId = res.locals.oauth.token.User.Account.id
  86
  87   const resultList = await VideoChangeOwnershipModel.listForApi(
  88     currentAccountId,
  89     req.query.start || 0,
  90     req.query.count || 10,
  91     req.query.sort || 'createdAt'
  92   )
  93
  94   return res.json(getFormattedObjects(resultList.data, resultList.total))
  95 }
  96
  97 async function acceptOwnership (req: express.Request, res: express.Response) {
  98   return sequelizeTypescript.transaction(async t => {
  99     const videoChangeOwnership = res.locals.videoChangeOwnership
 100     const targetVideo = videoChangeOwnership.Video
 101     const channel = res.locals.videoChannel
 102
 103     const oldVideoChannel = await VideoChannelModel.loadByIdAndPopulateAccount(targetVideo.channelId)
 104
 105     targetVideo.set('channelId', channel.id)
 106     const targetVideoUpdated = await targetVideo.save({ transaction: t })
 107     targetVideoUpdated.VideoChannel = channel
 108
 109     if (targetVideoUpdated.privacy !== VideoPrivacy.PRIVATE && targetVideoUpdated.state === VideoState.PUBLISHED) {
 110       await changeVideoChannelShare(targetVideoUpdated, oldVideoChannel, t)
 111       await sendUpdateVideo(targetVideoUpdated, t, oldVideoChannel.Account.Actor)
 112     }
 113
 114     videoChangeOwnership.set('status', VideoChangeOwnershipStatus.ACCEPTED)
 115     await videoChangeOwnership.save({ transaction: t })
 116
 117     return res.sendStatus(204)
 118   })
 119 }
 120
 121 async function refuseOwnership (req: express.Request, res: express.Response) {
 122   return sequelizeTypescript.transaction(async t => {
 123     const videoChangeOwnership = res.locals.videoChangeOwnership
 124
 125     videoChangeOwnership.set('status', VideoChangeOwnershipStatus.REFUSED)
 126     await videoChangeOwnership.save({ transaction: t })
 127
 128     return res.sendStatus(204)
 129   })
 130 }