From c46edbc2f6ca310b2f0331f979ac6caf27f6eb92 Mon Sep 17 00:00:00 2001 From: Chocobozzz Date: Wed, 22 Nov 2017 11:27:40 +0100 Subject: Fetch outbox to grab old activities tests --- .../activitypub-http-fetcher-handler.ts | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'server/lib/jobs') diff --git a/server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-fetcher-handler.ts b/server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-fetcher-handler.ts index b8ead32a4..09efaa622 100644 --- a/server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-fetcher-handler.ts +++ b/server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-fetcher-handler.ts @@ -25,7 +25,7 @@ async function process (payload: ActivityPubHttpPayload, jobId: number) { if (firstBody.first && Array.isArray(firstBody.first.orderedItems)) { const activities = firstBody.first.orderedItems - logger.info('Processing %i items ActivityPub fetcher for %s.', activities.length, uri) + logger.info('Processing %i items ActivityPub fetcher for %s.', activities.length, options.uri) await processActivities(activities) } @@ -37,12 +37,12 @@ async function process (payload: ActivityPubHttpPayload, jobId: number) { options.uri = nextLink const { body } = await doRequest(options) - nextLink = body.nextLink + nextLink = body.next i++ if (Array.isArray(body.orderedItems)) { const activities = body.orderedItems - logger.info('Processing %i items ActivityPub fetcher for %s.', activities.length, uri) + logger.info('Processing %i items ActivityPub fetcher for %s.', activities.length, options.uri) await processActivities(activities) } -- cgit v1.2.3