misty.cafe/mistykey
1
0
Fork 0
Code Issues Pull requests 1 Projects Releases Packages Wiki Activity Actions

support async disposal in CacheManagementService

Browse source
This commit is contained in:
Hazelnoot 2025-11-11 22:54:35 -05:00
parent 39f291cdeb
commit a777b2357b
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
packages/backend/src/global/CacheManagementService.ts
View file

@ -24,7 +24,7 @@ import { bindThis } from '@/decorators.js';
import { DI } from '@/di-symbols.js'; import { DI } from '@/di-symbols.js';
import { TimeService, type TimerHandle } from '@/global/TimeService.js'; import { TimeService, type TimerHandle } from '@/global/TimeService.js';
import { InternalEventService } from '@/global/InternalEventService.js'; import { InternalEventService } from '@/global/InternalEventService.js';
import { callAllOn } from '@/misc/call-all.js'; import { callAllOn, callAllOnAsync } from '@/misc/call-all.js';
import type * as Redis from 'ioredis'; import type * as Redis from 'ioredis';
// This is the one place that's *supposed* to new() up caches. // This is the one place that's *supposed* to new() up caches.
@ -37,7 +37,7 @@ export type ManagedRedisSingleCache<T> = Managed<RedisSingleCache<T>>;
export type ManagedQuantumKVCache<T> = Managed<QuantumKVCache<T>>; export type ManagedQuantumKVCache<T> = Managed<QuantumKVCache<T>>;
export type Managed<T> = Omit<T, 'dispose' | 'onApplicationShutdown' | 'gc'>; export type Managed<T> = Omit<T, 'dispose' | 'onApplicationShutdown' | 'gc'>;
export type Manager = { dispose(): void, clear(): void, gc(): void }; export type Manager = { dispose(): Promise<void> | void, clear(): void, gc(): void };
type CacheServices = MemoryCacheServices & RedisCacheServices & QuantumCacheServices; type CacheServices = MemoryCacheServices & RedisCacheServices & QuantumCacheServices;
@ -129,7 +129,7 @@ export class CacheManagementService implements OnApplicationShutdown {
const toDispose = Array.from(this.managedCaches.values()); const toDispose = Array.from(this.managedCaches.values());
this.managedCaches.clear(); this.managedCaches.clear();
callAllOn(toDispose, 'dispose'); await callAllOnAsync(toDispose, 'dispose');
} }
@bindThis @bindThis