diff options
author | Chocobozzz <florian.bigard@gmail.com> | 2017-11-22 11:27:40 +0100 |
---|---|---|
committer | Chocobozzz <florian.bigard@gmail.com> | 2017-11-27 19:40:53 +0100 |
commit | c46edbc2f6ca310b2f0331f979ac6caf27f6eb92 (patch) | |
tree | 073e32adb1bf93a597a269432e33a8f28365deb5 /server/lib/jobs | |
parent | c986175d68a18e96fbd41537a05c7796a2c64f38 (diff) | |
download | PeerTube-c46edbc2f6ca310b2f0331f979ac6caf27f6eb92.tar.gz PeerTube-c46edbc2f6ca310b2f0331f979ac6caf27f6eb92.tar.zst PeerTube-c46edbc2f6ca310b2f0331f979ac6caf27f6eb92.zip |
Fetch outbox to grab old activities tests
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 | } |