summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue/processors/DeliverProcessorService.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2022-09-19 03:11:50 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2022-09-19 03:11:50 +0900
commita2eac9fff67f811ed4ac1a80a88fd1f0eafae6c8 (patch)
tree9c7190e05fe0ffe085646cd194c6c65d47375f83 /packages/backend/src/queue/processors/DeliverProcessorService.ts
parentrevert (diff)
downloadsharkey-a2eac9fff67f811ed4ac1a80a88fd1f0eafae6c8.tar.gz
sharkey-a2eac9fff67f811ed4ac1a80a88fd1f0eafae6c8.tar.bz2
sharkey-a2eac9fff67f811ed4ac1a80a88fd1f0eafae6c8.zip
test
Diffstat (limited to 'packages/backend/src/queue/processors/DeliverProcessorService.ts')
-rw-r--r--packages/backend/src/queue/processors/DeliverProcessorService.ts20
1 files changed, 10 insertions, 10 deletions
diff --git a/packages/backend/src/queue/processors/DeliverProcessorService.ts b/packages/backend/src/queue/processors/DeliverProcessorService.ts
index 3403ec83a9..1bf51c1bc6 100644
--- a/packages/backend/src/queue/processors/DeliverProcessorService.ts
+++ b/packages/backend/src/queue/processors/DeliverProcessorService.ts
@@ -21,9 +21,9 @@ import type { DeliverJobData } from '../types.js';
@Injectable()
export class DeliverProcessorService {
- #logger: Logger;
- #suspendedHostsCache: Cache<Instance[]>;
- #latest: string | null;
+ private logger: Logger;
+ private suspendedHostsCache: Cache<Instance[]>;
+ private latest: string | null;
constructor(
@Inject(DI.config)
@@ -45,9 +45,9 @@ export class DeliverProcessorService {
private federationChart: FederationChart,
private queueLoggerService: QueueLoggerService,
) {
- this.#logger = this.queueLoggerService.logger.createSubLogger('deliver');
- this.#suspendedHostsCache = new Cache<Instance[]>(1000 * 60 * 60);
- this.#latest = null;
+ this.logger = this.queueLoggerService.logger.createSubLogger('deliver');
+ this.suspendedHostsCache = new Cache<Instance[]>(1000 * 60 * 60);
+ this.latest = null;
}
public async process(job: Bull.Job<DeliverJobData>): Promise<string> {
@@ -60,22 +60,22 @@ export class DeliverProcessorService {
}
// isSuspendedなら中断
- let suspendedHosts = this.#suspendedHostsCache.get(null);
+ let suspendedHosts = this.suspendedHostsCache.get(null);
if (suspendedHosts == null) {
suspendedHosts = await this.instancesRepository.find({
where: {
isSuspended: true,
},
});
- this.#suspendedHostsCache.set(null, suspendedHosts);
+ this.suspendedHostsCache.set(null, suspendedHosts);
}
if (suspendedHosts.map(x => x.host).includes(this.utilityService.toPuny(host))) {
return 'skip (suspended)';
}
try {
- if (this.#latest !== (this.#latest = JSON.stringify(job.data.content, null, 2))) {
- this.#logger.debug(`delivering ${this.#latest}`);
+ if (this.latest !== (this.latest = JSON.stringify(job.data.content, null, 2))) {
+ this.logger.debug(`delivering ${this.latest}`);
}
await this.apRequestService.signedPost(job.data.user, job.data.to, job.data.content);