1 import { ActivityCreate, ActivityDislike, DislikeObject } from '@shared/models'
2 import { retryTransactionWrapper } from '../../../helpers/database-utils'
3 import { sequelizeTypescript } from '../../../initializers/database'
4 import { AccountVideoRateModel } from '../../../models/account/account-video-rate'
5 import { APProcessorOptions } from '../../../types/activitypub-processor.model'
6 import { MActorSignature } from '../../../types/models'
7 import { forwardVideoRelatedActivity } from '../send/utils'
8 import { getOrCreateAPVideo } from '../videos'
10 async function processDislikeActivity (options: APProcessorOptions<ActivityCreate | ActivityDislike>) {
11 const { activity, byActor } = options
12 return retryTransactionWrapper(processDislike, activity, byActor)
15 // ---------------------------------------------------------------------------
18 processDislikeActivity
21 // ---------------------------------------------------------------------------
23 async function processDislike (activity: ActivityCreate | ActivityDislike, byActor: MActorSignature) {
24 const dislikeObject = activity.type === 'Dislike'
26 : (activity.object as DislikeObject).object
28 const byAccount = byActor.Account
30 if (!byAccount) throw new Error('Cannot create dislike with the non account actor ' + byActor.url)
32 const { video } = await getOrCreateAPVideo({ videoObject: dislikeObject })
34 return sequelizeTypescript.transaction(async t => {
35 const existingRate = await AccountVideoRateModel.loadByAccountAndVideoOrUrl(byAccount.id, video.id, activity.id, t)
36 if (existingRate && existingRate.type === 'dislike') return
38 await video.increment('dislikes', { transaction: t })
40 if (existingRate && existingRate.type === 'like') {
41 await video.decrement('likes', { transaction: t })
44 const rate = existingRate || new AccountVideoRateModel()
46 rate.videoId = video.id
47 rate.accountId = byAccount.id
48 rate.url = activity.id
50 await rate.save({ transaction: t })
52 if (video.isOwned()) {
53 // Don't resend the activity to the sender
54 const exceptions = [ byActor ]
56 await forwardVideoRelatedActivity(activity, t, exceptions, video)