1 import { ActivityAnnounce } from '../../../../shared/models/activitypub'
2 import { retryTransactionWrapper } from '../../../helpers/database-utils'
3 import { sequelizeTypescript } from '../../../initializers'
4 import { ActorModel } from '../../../models/activitypub/actor'
5 import { VideoModel } from '../../../models/video/video'
6 import { VideoShareModel } from '../../../models/video/video-share'
7 import { getOrCreateActorAndServerAndModel } from '../actor'
8 import { forwardVideoRelatedActivity } from '../send/utils'
9 import { getOrCreateAccountAndVideoAndChannel } from '../videos'
11 async function processAnnounceActivity (activity: ActivityAnnounce) {
12 const actorAnnouncer = await getOrCreateActorAndServerAndModel(activity.actor)
14 return retryTransactionWrapper(processVideoShare, actorAnnouncer, activity)
17 // ---------------------------------------------------------------------------
20 processAnnounceActivity
23 // ---------------------------------------------------------------------------
25 async function processVideoShare (actorAnnouncer: ActorModel, activity: ActivityAnnounce) {
26 const objectUri = typeof activity.object === 'string' ? activity.object : activity.object.id
29 const res = await getOrCreateAccountAndVideoAndChannel(objectUri)
32 return sequelizeTypescript.transaction(async t => {
36 actorId: actorAnnouncer.id,
41 const [ , created ] = await VideoShareModel.findOrCreate({
49 if (video.isOwned() && created === true) {
50 // Don't resend the activity to the sender
51 const exceptions = [ actorAnnouncer ]
53 await forwardVideoRelatedActivity(activity, t, exceptions, video)