123456789101112131415161718192021222324252627282930313233343536373839404142434445464748 |
- import * as Bull from 'bull'
- import { logger } from '../../../helpers/logger'
- import { doRequest } from '../../../helpers/requests'
- import { buildGlobalHeaders, buildSignedRequestOptions, computeBody } from './utils/activitypub-http-utils'
- import { JOB_REQUEST_TIMEOUT } from '../../../initializers/constants'
- import { ActorFollowScoreCache } from '../../files-cache'
- export type ActivitypubHttpUnicastPayload = {
- uri: string
- signatureActorId?: number
- body: any
- }
- async function processActivityPubHttpUnicast (job: Bull.Job) {
- logger.info('Processing ActivityPub unicast in job %d.', job.id)
- const payload = job.data as ActivitypubHttpUnicastPayload
- const uri = payload.uri
- const body = await computeBody(payload)
- const httpSignatureOptions = await buildSignedRequestOptions(payload)
- logger.info('hello', { httpSignatureOptions })
- const options = {
- method: 'POST',
- uri,
- json: body,
- httpSignature: httpSignatureOptions,
- timeout: JOB_REQUEST_TIMEOUT,
- headers: buildGlobalHeaders(body)
- }
- try {
- await doRequest(options)
- ActorFollowScoreCache.Instance.updateActorFollowsScore([ uri ], [])
- } catch (err) {
- ActorFollowScoreCache.Instance.updateActorFollowsScore([], [ uri ])
- throw err
- }
- }
- // ---------------------------------------------------------------------------
- export {
- processActivityPubHttpUnicast
- }
|