import { forwardVideoRelatedActivity } from '../send/utils'
import { createOrUpdateCacheFile } from '../cache-file'
import { Notifier } from '../../notifier'
-import { processViewActivity } from './process-view'
-import { processDislikeActivity } from './process-dislike'
-import { processFlagActivity } from './process-flag'
import { PlaylistObject } from '../../../../shared/models/activitypub/objects/playlist-object'
import { createOrUpdateVideoPlaylist } from '../playlist'
import { VideoModel } from '../../../models/video/video'
const activityObject = activity.object
const activityType = activityObject.type
- if (activityType === 'View') {
- return processViewActivity(activity, byActor)
- }
-
- if (activityType === 'Dislike') {
- return retryTransactionWrapper(processDislikeActivity, activity, byActor)
- }
-
- if (activityType === 'Flag') {
- return retryTransactionWrapper(processFlagActivity, activity, byActor)
- }
-
if (activityType === 'Video') {
return processCreateVideo(activity)
}
const { video, created } = await getOrCreateVideoAndAccountAndChannel({ videoObject: videoToCreateData })
- if (created) Notifier.Instance.notifyOnNewVideo(video)
+ if (created) Notifier.Instance.notifyOnNewVideoIfNeeded(video)
return video
}
commentObject.inReplyTo,
{ err }
)
+ return
}
const { comment, created } = await addVideoComment(video, commentObject.id)