X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Fschedulers%2Fbad-actor-follow-scheduler.ts;h=617149aaf363a86dd2faf3dd30d79e51b46d3da7;hb=a2377d15ee09301cf4cc5434ad865a21918da15f;hp=c6c285eceee4c4d1232a4854b1d7b102b738b5b6;hpb=60650c77c8a2a98e92d869b237ae4900f369a8fc;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/schedulers/bad-actor-follow-scheduler.ts b/server/lib/schedulers/bad-actor-follow-scheduler.ts index c6c285ece..617149aaf 100644 --- a/server/lib/schedulers/bad-actor-follow-scheduler.ts +++ b/server/lib/schedulers/bad-actor-follow-scheduler.ts @@ -1,20 +1,26 @@ +import { isTestInstance } from '../../helpers/core-utils' import { logger } from '../../helpers/logger' import { ActorFollowModel } from '../../models/activitypub/actor-follow' import { AbstractScheduler } from './abstract-scheduler' +import { SCHEDULER_INTERVALS_MS } from '../../initializers' export class BadActorFollowScheduler extends AbstractScheduler { private static instance: AbstractScheduler + protected schedulerIntervalMs = SCHEDULER_INTERVALS_MS.badActorFollow + private constructor () { super() } async execute () { + if (!isTestInstance()) logger.info('Removing bad actor follows (scheduler).') + try { await ActorFollowModel.removeBadActorFollows() } catch (err) { - logger.error('Error in bad actor follows scheduler.', err) + logger.error('Error in bad actor follows scheduler.', { err }) } }