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

use TimeService in CacheService

Browse source
This commit is contained in:
Hazelnoot 2025-11-06 22:17:52 -05:00
parent abaf580d8d
commit 4fc762958c
1 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
packages/backend/src/core/CacheService.ts
View file

@ -15,6 +15,7 @@ import { bindThis } from '@/decorators.js';
import type { InternalEventTypes } from '@/core/GlobalEventService.js';
import { InternalEventService } from '@/global/InternalEventService.js';
import { IdentifiableError } from '@/misc/identifiable-error.js';
import { TimeService } from '@/global/TimeService.js';
import {
CacheManagementService,
type ManagedMemoryKVCache,
@ -104,6 +105,7 @@ export class CacheService implements OnApplicationShutdown {
private readonly internalEventService: InternalEventService,
private readonly cacheManagementService: CacheManagementService,
private readonly timeService: TimeService,
) {
//this.onMessage = this.onMessage.bind(this);
@ -128,7 +130,7 @@ export class CacheService implements OnApplicationShutdown {
.where({ muterId: In(muterIds) })
.andWhere(new Brackets(qb => qb
.orWhere({ expiresAt: IsNull() })
.orWhere({ expiresAt: MoreThan(new Date()) })))
.orWhere({ expiresAt: MoreThan(this.timeService.date) })))
.groupBy('muting.muterId')
.getRawMany<{ muterId: string, muteeIds: string[] }>()
.then(ms => ms.map(m => [m.muterId, new Set(m.muteeIds)])),
@ -144,7 +146,7 @@ export class CacheService implements OnApplicationShutdown {
.where({ muteeId: In(muteeIds) })
.andWhere(new Brackets(qb => qb
.orWhere({ expiresAt: IsNull() })
.orWhere({ expiresAt: MoreThan(new Date()) })))
.orWhere({ expiresAt: MoreThan(this.timeService.date) })))
.groupBy('muting.muteeId')
.getRawMany<{ muteeId: string, muterIds: string[] }>()
.then(ms => ms.map(m => [m.muteeId, new Set(m.muterIds)])),