summaryrefslogtreecommitdiff
path: root/packages/backend/src/core/PushNotificationService.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2023-06-10 13:45:11 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2023-06-10 13:45:11 +0900
commite8420ad90bd290a2c10d563f6ccbffd0d4a0a97b (patch)
tree90c09fdd6ad4f8a53acb88e0a6218215816f9d47 /packages/backend/src/core/PushNotificationService.ts
parentenhance(backend): WebSocketのPing/Pongをプロトコル制御フレーム... (diff)
downloadsharkey-e8420ad90bd290a2c10d563f6ccbffd0d4a0a97b.tar.gz
sharkey-e8420ad90bd290a2c10d563f6ccbffd0d4a0a97b.tar.bz2
sharkey-e8420ad90bd290a2c10d563f6ccbffd0d4a0a97b.zip
fix(backend): キャッシュが溜まり続けないように
Related #10984
Diffstat (limited to 'packages/backend/src/core/PushNotificationService.ts')
-rw-r--r--packages/backend/src/core/PushNotificationService.ts14
1 files changed, 12 insertions, 2 deletions
diff --git a/packages/backend/src/core/PushNotificationService.ts b/packages/backend/src/core/PushNotificationService.ts
index a4c569bdec..15a1d74878 100644
--- a/packages/backend/src/core/PushNotificationService.ts
+++ b/packages/backend/src/core/PushNotificationService.ts
@@ -1,4 +1,4 @@
-import { Inject, Injectable } from '@nestjs/common';
+import { Inject, Injectable, OnApplicationShutdown } from '@nestjs/common';
import push from 'web-push';
import * as Redis from 'ioredis';
import { DI } from '@/di-symbols.js';
@@ -42,7 +42,7 @@ function truncateBody<T extends keyof PushNotificationsTypes>(type: T, body: Pus
}
@Injectable()
-export class PushNotificationService {
+export class PushNotificationService implements OnApplicationShutdown {
private subscriptionsCache: RedisKVCache<SwSubscription[]>;
constructor(
@@ -115,4 +115,14 @@ export class PushNotificationService {
});
}
}
+
+ @bindThis
+ public dispose(): void {
+ this.subscriptionsCache.dispose();
+ }
+
+ @bindThis
+ public onApplicationShutdown(signal?: string | undefined): void {
+ this.dispose();
+ }
}