diff options
Diffstat (limited to 'server/lib/jobs')
-rw-r--r-- | server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-fetcher-handler.ts | 6 |
1 files changed, 3 insertions, 3 deletions
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) { | |||
25 | if (firstBody.first && Array.isArray(firstBody.first.orderedItems)) { | 25 | if (firstBody.first && Array.isArray(firstBody.first.orderedItems)) { |
26 | const activities = firstBody.first.orderedItems | 26 | const activities = firstBody.first.orderedItems |
27 | 27 | ||
28 | logger.info('Processing %i items ActivityPub fetcher for %s.', activities.length, uri) | 28 | logger.info('Processing %i items ActivityPub fetcher for %s.', activities.length, options.uri) |
29 | 29 | ||
30 | await processActivities(activities) | 30 | await processActivities(activities) |
31 | } | 31 | } |
@@ -37,12 +37,12 @@ async function process (payload: ActivityPubHttpPayload, jobId: number) { | |||
37 | options.uri = nextLink | 37 | options.uri = nextLink |
38 | 38 | ||
39 | const { body } = await doRequest(options) | 39 | const { body } = await doRequest(options) |
40 | nextLink = body.nextLink | 40 | nextLink = body.next |
41 | i++ | 41 | i++ |
42 | 42 | ||
43 | if (Array.isArray(body.orderedItems)) { | 43 | if (Array.isArray(body.orderedItems)) { |
44 | const activities = body.orderedItems | 44 | const activities = body.orderedItems |
45 | logger.info('Processing %i items ActivityPub fetcher for %s.', activities.length, uri) | 45 | logger.info('Processing %i items ActivityPub fetcher for %s.', activities.length, options.uri) |
46 | 46 | ||
47 | await processActivities(activities) | 47 | await processActivities(activities) |
48 | } | 48 | } |