X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Fjob-queue%2Fhandlers%2Factivitypub-follow.ts;h=a68c32ba069f1de826613c8cd0e325fb0dd1f1aa;hb=cea2fd90ddb3bf57c2fed77128938d12d4c2be6b;hp=55a15930af6deab0e4d0692103d7ddf2a35a2652;hpb=e1a570abff3ebf375433e58e7362d56bd32d4cd8;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/job-queue/handlers/activitypub-follow.ts b/server/lib/job-queue/handlers/activitypub-follow.ts index 55a15930a..a68c32ba0 100644 --- a/server/lib/job-queue/handlers/activitypub-follow.ts +++ b/server/lib/job-queue/handlers/activitypub-follow.ts @@ -1,4 +1,4 @@ -import { Job } from 'bull' +import { Job } from 'bullmq' import { getLocalActorFollowActivityPubUrl } from '@server/lib/activitypub/url' import { ActivitypubFollowPayload } from '@shared/models' import { sanitizeHost } from '../../../helpers/core-utils' @@ -8,7 +8,7 @@ import { REMOTE_SCHEME, WEBSERVER } from '../../../initializers/constants' import { sequelizeTypescript } from '../../../initializers/database' import { ActorModel } from '../../../models/actor/actor' import { ActorFollowModel } from '../../../models/actor/actor-follow' -import { MActor, MActorFollowActors, MActorFull } from '../../../types/models' +import { MActor, MActorFull } from '../../../types/models' import { getOrCreateAPActor, loadActorUrlOrGetFromWebfinger } from '../../activitypub/actors' import { sendFollow } from '../../activitypub/send' import { Notifier } from '../../notifier' @@ -17,7 +17,7 @@ async function processActivityPubFollow (job: Job) { const payload = job.data as ActivitypubFollowPayload const host = payload.host - logger.info('Processing ActivityPub follow in job %d.', job.id) + logger.info('Processing ActivityPub follow in job %s.', job.id) let targetActor: MActorFull if (!host || host === WEBSERVER.HOST) {