X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Fjob-queue%2Fhandlers%2Factivitypub-http-unicast.ts;h=9e4e84002528abd90471f88afc347d90aa71610f;hb=a32bf8cd20212b903d3fa478e629f051eb77fecc;hp=673583d2b05d6c58626f9dcc1c2c343ede81d680;hpb=9db437c8155f3563a33e22ed2896072a9f1fbdb0;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/job-queue/handlers/activitypub-http-unicast.ts b/server/lib/job-queue/handlers/activitypub-http-unicast.ts index 673583d2b..9e4e84002 100644 --- a/server/lib/job-queue/handlers/activitypub-http-unicast.ts +++ b/server/lib/job-queue/handlers/activitypub-http-unicast.ts @@ -1,12 +1,12 @@ -import { Job } from 'bull' +import { Job } from 'bullmq' +import { buildGlobalHeaders, buildSignedRequestOptions, computeBody } from '@server/lib/activitypub/send' import { ActivitypubHttpUnicastPayload } from '@shared/models' import { logger } from '../../../helpers/logger' import { doRequest } from '../../../helpers/requests' import { ActorFollowHealthCache } from '../../actor-follow-health-cache' -import { buildGlobalHeaders, buildSignedRequestOptions, computeBody } from './utils/activitypub-http-utils' async function processActivityPubHttpUnicast (job: Job) { - logger.info('Processing ActivityPub unicast in job %d.', job.id) + logger.info('Processing ActivityPub unicast in job %s.', job.id) const payload = job.data as ActivitypubHttpUnicastPayload const uri = payload.uri