aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/lib/job-queue/handlers/activitypub-http-broadcast.ts
diff options
context:
space:
mode:
authorChocobozzz <me@florianbigard.com>2018-10-10 08:51:58 +0200
committerChocobozzz <me@florianbigard.com>2018-10-10 08:51:58 +0200
commit729bb184819ddda1d7313da0c30b3397e5689721 (patch)
treed14993d6fde02ae4eac0ff9378f6d278a5e03bd4 /server/lib/job-queue/handlers/activitypub-http-broadcast.ts
parent6321cbc3e7a43257b03b3285ab69b7977fd7f616 (diff)
downloadPeerTube-729bb184819ddda1d7313da0c30b3397e5689721.tar.gz
PeerTube-729bb184819ddda1d7313da0c30b3397e5689721.tar.zst
PeerTube-729bb184819ddda1d7313da0c30b3397e5689721.zip
Add more headers to broadcast/unicast
Diffstat (limited to 'server/lib/job-queue/handlers/activitypub-http-broadcast.ts')
-rw-r--r--server/lib/job-queue/handlers/activitypub-http-broadcast.ts5
1 files changed, 3 insertions, 2 deletions
diff --git a/server/lib/job-queue/handlers/activitypub-http-broadcast.ts b/server/lib/job-queue/handlers/activitypub-http-broadcast.ts
index 03a9e12a4..abbd89b3b 100644
--- a/server/lib/job-queue/handlers/activitypub-http-broadcast.ts
+++ b/server/lib/job-queue/handlers/activitypub-http-broadcast.ts
@@ -3,7 +3,7 @@ import * as Bluebird from 'bluebird'
3import { logger } from '../../../helpers/logger' 3import { logger } from '../../../helpers/logger'
4import { doRequest } from '../../../helpers/requests' 4import { doRequest } from '../../../helpers/requests'
5import { ActorFollowModel } from '../../../models/activitypub/actor-follow' 5import { ActorFollowModel } from '../../../models/activitypub/actor-follow'
6import { buildSignedRequestOptions, computeBody } from './utils/activitypub-http-utils' 6import { buildGlobalHeaders, buildSignedRequestOptions, computeBody } from './utils/activitypub-http-utils'
7import { BROADCAST_CONCURRENCY, JOB_REQUEST_TIMEOUT } from '../../../initializers' 7import { BROADCAST_CONCURRENCY, JOB_REQUEST_TIMEOUT } from '../../../initializers'
8 8
9export type ActivitypubHttpBroadcastPayload = { 9export type ActivitypubHttpBroadcastPayload = {
@@ -25,7 +25,8 @@ async function processActivityPubHttpBroadcast (job: Bull.Job) {
25 uri: '', 25 uri: '',
26 json: body, 26 json: body,
27 httpSignature: httpSignatureOptions, 27 httpSignature: httpSignatureOptions,
28 timeout: JOB_REQUEST_TIMEOUT 28 timeout: JOB_REQUEST_TIMEOUT,
29 headers: buildGlobalHeaders(body)
29 } 30 }
30 31
31 const badUrls: string[] = [] 32 const badUrls: string[] = []