-async function processAnnounceActivity (activity: ActivityAnnounce) {
- const announcedActivity = activity.object
- const accountAnnouncer = await getOrCreateAccountAndServer(activity.actor)
-
- if (announcedActivity.type === 'Create' && announcedActivity.object.type === 'VideoChannel') {
- return processVideoChannelShare(accountAnnouncer, activity)
- } else if (announcedActivity.type === 'Add' && announcedActivity.object.type === 'Video') {
- return processVideoShare(accountAnnouncer, activity)
- }
-
- logger.warn(
- 'Unknown activity object type %s -> %s when announcing activity.', announcedActivity.type, announcedActivity.object.type,
- { activity: activity.id }
- )
-
- return undefined
+async function processAnnounceActivity (activity: ActivityAnnounce, actorAnnouncer: ActorModel) {
+ return retryTransactionWrapper(processVideoShare, actorAnnouncer, activity)