From a2eac9fff67f811ed4ac1a80a88fd1f0eafae6c8 Mon Sep 17 00:00:00 2001
From: syuilo <Syuilotan@yahoo.co.jp>
Date: Mon, 19 Sep 2022 03:11:50 +0900
Subject: test

---
 .../src/queue/processors/DeliverProcessorService.ts  | 20 ++++++++++----------
 1 file changed, 10 insertions(+), 10 deletions(-)

(limited to 'packages/backend/src/queue/processors/DeliverProcessorService.ts')

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);
-- 
cgit v1.2.3-freya