- await processActivities(activities)
- }
-
- let limit = ACTIVITY_PUB.FETCH_PAGE_LIMIT
- let i = 0
- let nextLink = firstBody.first.next
- while (nextLink && i < limit) {
- options.uri = nextLink
-
- const { body } = await doRequest(options)
- nextLink = body.next
- i++
-
- if (Array.isArray(body.orderedItems)) {
- const activities = body.orderedItems
- logger.info('Processing %i items ActivityPub fetcher for %s.', activities.length, options.uri)
+ const fetcherType: { [ id in FetchType ]: (items: any[]) => Promise<any> } = {
+ 'activity': items => processActivities(items, { outboxUrl: payload.uri, fromFetch: true }),
+ 'video-likes': items => createRates(items, video, 'like'),
+ 'video-dislikes': items => createRates(items, video, 'dislike'),
+ 'video-shares': items => addVideoShares(items, video),
+ 'video-comments': items => addVideoComments(items),
+ 'account-playlists': items => createAccountPlaylists(items, account)
+ }