aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/lib/jobs
diff options
context:
space:
mode:
Diffstat (limited to 'server/lib/jobs')
-rw-r--r--server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-fetcher-handler.ts6
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 }