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
28 const { video } = await getOrCreateAccountAndVideoAndChannel(objectUri)
30 return sequelizeTypescript.transaction(async t => {
34 actorId: actorAnnouncer.id,
39 const [ , created ] = await VideoShareModel.findOrCreate({
47 if (video.isOwned() && created === true) {
48 // Don't resend the activity to the sender
49 const exceptions = [ actorAnnouncer ]
51 await forwardVideoRelatedActivity(activity, t, exceptions, video)