123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135 |
- import { ActivityDelete } from '../../../../shared/models/activitypub'
- import { retryTransactionWrapper } from '../../../helpers/database-utils'
- import { logger } from '../../../helpers/logger'
- import { sequelizeTypescript } from '../../../initializers'
- import { AccountModel } from '../../../models/account/account'
- import { ActorModel } from '../../../models/activitypub/actor'
- import { VideoModel } from '../../../models/video/video'
- import { VideoChannelModel } from '../../../models/video/video-channel'
- import { VideoCommentModel } from '../../../models/video/video-comment'
- import { forwardVideoRelatedActivity } from '../send/utils'
- import { VideoPlaylistModel } from '../../../models/video/video-playlist'
- async function processDeleteActivity (activity: ActivityDelete, byActor: ActorModel) {
- const objectUrl = typeof activity.object === 'string' ? activity.object : activity.object.id
- if (activity.actor === objectUrl) {
- // We need more attributes (all the account and channel)
- const byActorFull = await ActorModel.loadByUrlAndPopulateAccountAndChannel(byActor.url)
- if (byActorFull.type === 'Person') {
- if (!byActorFull.Account) throw new Error('Actor ' + byActorFull.url + ' is a person but we cannot find it in database.')
- byActorFull.Account.Actor = await byActorFull.Account.$get('Actor') as ActorModel
- return retryTransactionWrapper(processDeleteAccount, byActorFull.Account)
- } else if (byActorFull.type === 'Group') {
- if (!byActorFull.VideoChannel) throw new Error('Actor ' + byActorFull.url + ' is a group but we cannot find it in database.')
- byActorFull.VideoChannel.Actor = await byActorFull.VideoChannel.$get('Actor') as ActorModel
- return retryTransactionWrapper(processDeleteVideoChannel, byActorFull.VideoChannel)
- }
- }
- {
- const videoCommentInstance = await VideoCommentModel.loadByUrlAndPopulateAccount(objectUrl)
- if (videoCommentInstance) {
- return retryTransactionWrapper(processDeleteVideoComment, byActor, videoCommentInstance, activity)
- }
- }
- {
- const videoInstance = await VideoModel.loadByUrlAndPopulateAccount(objectUrl)
- if (videoInstance) {
- if (videoInstance.isOwned()) throw new Error(`Remote instance cannot delete owned video ${videoInstance.url}.`)
- return retryTransactionWrapper(processDeleteVideo, byActor, videoInstance)
- }
- }
- {
- const videoPlaylist = await VideoPlaylistModel.loadByUrlAndPopulateAccount(objectUrl)
- if (videoPlaylist) {
- if (videoPlaylist.isOwned()) throw new Error(`Remote instance cannot delete owned playlist ${videoPlaylist.url}.`)
- return retryTransactionWrapper(processDeleteVideoPlaylist, byActor, videoPlaylist)
- }
- }
- return undefined
- }
- // ---------------------------------------------------------------------------
- export {
- processDeleteActivity
- }
- // ---------------------------------------------------------------------------
- async function processDeleteVideo (actor: ActorModel, videoToDelete: VideoModel) {
- logger.debug('Removing remote video "%s".', videoToDelete.uuid)
- await sequelizeTypescript.transaction(async t => {
- if (videoToDelete.VideoChannel.Account.Actor.id !== actor.id) {
- throw new Error('Account ' + actor.url + ' does not own video channel ' + videoToDelete.VideoChannel.Actor.url)
- }
- await videoToDelete.destroy({ transaction: t })
- })
- logger.info('Remote video with uuid %s removed.', videoToDelete.uuid)
- }
- async function processDeleteVideoPlaylist (actor: ActorModel, playlistToDelete: VideoPlaylistModel) {
- logger.debug('Removing remote video playlist "%s".', playlistToDelete.uuid)
- await sequelizeTypescript.transaction(async t => {
- if (playlistToDelete.OwnerAccount.Actor.id !== actor.id) {
- throw new Error('Account ' + actor.url + ' does not own video playlist ' + playlistToDelete.url)
- }
- await playlistToDelete.destroy({ transaction: t })
- })
- logger.info('Remote video playlist with uuid %s removed.', playlistToDelete.uuid)
- }
- async function processDeleteAccount (accountToRemove: AccountModel) {
- logger.debug('Removing remote account "%s".', accountToRemove.Actor.url)
- await sequelizeTypescript.transaction(async t => {
- await accountToRemove.destroy({ transaction: t })
- })
- logger.info('Remote account %s removed.', accountToRemove.Actor.url)
- }
- async function processDeleteVideoChannel (videoChannelToRemove: VideoChannelModel) {
- logger.debug('Removing remote video channel "%s".', videoChannelToRemove.Actor.url)
- await sequelizeTypescript.transaction(async t => {
- await videoChannelToRemove.destroy({ transaction: t })
- })
- logger.info('Remote video channel %s removed.', videoChannelToRemove.Actor.url)
- }
- function processDeleteVideoComment (byActor: ActorModel, videoComment: VideoCommentModel, activity: ActivityDelete) {
- logger.debug('Removing remote video comment "%s".', videoComment.url)
- return sequelizeTypescript.transaction(async t => {
- if (videoComment.Account.id !== byActor.Account.id) {
- throw new Error('Account ' + byActor.url + ' does not own video comment ' + videoComment.url)
- }
- await videoComment.destroy({ transaction: t })
- if (videoComment.Video.isOwned()) {
- // Don't resend the activity to the sender
- const exceptions = [ byActor ]
- await forwardVideoRelatedActivity(activity, t, exceptions, videoComment.Video)
- }
- logger.info('Remote video comment %s removed.', videoComment.url)
- })
- }
|