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

manage avatar decorations cache

Browse source
This commit is contained in:
Hazelnoot 2025-10-01 12:26:58 -04:00
parent 6ff3d506b5
commit 2caec2f530
1 changed files with 17 additions and 23 deletions
Download patch file Download diff file Expand all files Collapse all files

40
packages/backend/src/core/AvatarDecorationService.ts
View file

@ -13,10 +13,12 @@ import { bindThis } from '@/decorators.js';
import { MemorySingleCache } from '@/misc/cache.js'; import { MemorySingleCache } from '@/misc/cache.js';
import type { GlobalEvents } from '@/core/GlobalEventService.js'; import type { GlobalEvents } from '@/core/GlobalEventService.js';
import { ModerationLogService } from '@/core/ModerationLogService.js'; import { ModerationLogService } from '@/core/ModerationLogService.js';
import { CacheManagementService, type ManagedMemorySingleCache } from '@/core/CacheManagementService.js';
import { InternalEventService } from '@/core/InternalEventService.js';
@Injectable() @Injectable()
export class AvatarDecorationService implements OnApplicationShutdown { export class AvatarDecorationService implements OnApplicationShutdown {
public cache: MemorySingleCache<MiAvatarDecoration[]>; public cache: ManagedMemorySingleCache<MiAvatarDecoration[]>;
constructor( constructor(
@Inject(DI.redisForSub) @Inject(DI.redisForSub)
@ -28,29 +30,19 @@ export class AvatarDecorationService implements OnApplicationShutdown {
private idService: IdService, private idService: IdService,
private moderationLogService: ModerationLogService, private moderationLogService: ModerationLogService,
private globalEventService: GlobalEventService, private globalEventService: GlobalEventService,
private readonly internalEventService: InternalEventService,
cacheManagementService: CacheManagementService,
) { ) {
this.cache = new MemorySingleCache<MiAvatarDecoration[]>(1000 * 60 * 30); // 30s this.cache = cacheManagementService.createMemorySingleCache<MiAvatarDecoration[]>(1000 * 60 * 30); // 30s
this.redisForSub.on('message', this.onMessage); this.internalEventService.on('avatarDecorationCreated', this.onAvatarEvent);
this.internalEventService.on('avatarDecorationUpdated', this.onAvatarEvent);
this.internalEventService.on('avatarDecorationDeleted', this.onAvatarEvent);
} }
@bindThis @bindThis
private async onMessage(_: string, data: string): Promise<void> { private onAvatarEvent(): void {
const obj = JSON.parse(data); this.cache.delete();
if (obj.channel === 'internal') {
const { type, body } = obj.message as GlobalEvents['internal']['payload'];
switch (type) {
case 'avatarDecorationCreated':
case 'avatarDecorationUpdated':
case 'avatarDecorationDeleted': {
this.cache.delete();
break;
}
default:
break;
}
}
} }
@bindThis @bindThis
@ -60,7 +52,7 @@ export class AvatarDecorationService implements OnApplicationShutdown {
...options, ...options,
}); });
this.globalEventService.publishInternalEvent('avatarDecorationCreated', created); await this.internalEventService.emit('avatarDecorationCreated', created);
if (moderator) { if (moderator) {
this.moderationLogService.log(moderator, 'createAvatarDecoration', { this.moderationLogService.log(moderator, 'createAvatarDecoration', {
@ -83,7 +75,7 @@ export class AvatarDecorationService implements OnApplicationShutdown {
}); });
const updated = await this.avatarDecorationsRepository.findOneByOrFail({ id: avatarDecoration.id }); const updated = await this.avatarDecorationsRepository.findOneByOrFail({ id: avatarDecoration.id });
this.globalEventService.publishInternalEvent('avatarDecorationUpdated', updated); await this.internalEventService.emit('avatarDecorationUpdated', updated);
if (moderator) { if (moderator) {
this.moderationLogService.log(moderator, 'updateAvatarDecoration', { this.moderationLogService.log(moderator, 'updateAvatarDecoration', {
@ -99,7 +91,7 @@ export class AvatarDecorationService implements OnApplicationShutdown {
const avatarDecoration = await this.avatarDecorationsRepository.findOneByOrFail({ id }); const avatarDecoration = await this.avatarDecorationsRepository.findOneByOrFail({ id });
await this.avatarDecorationsRepository.delete({ id: avatarDecoration.id }); await this.avatarDecorationsRepository.delete({ id: avatarDecoration.id });
this.globalEventService.publishInternalEvent('avatarDecorationDeleted', avatarDecoration); await this.internalEventService.emit('avatarDecorationDeleted', avatarDecoration);
if (moderator) { if (moderator) {
this.moderationLogService.log(moderator, 'deleteAvatarDecoration', { this.moderationLogService.log(moderator, 'deleteAvatarDecoration', {
@ -119,7 +111,9 @@ export class AvatarDecorationService implements OnApplicationShutdown {
@bindThis @bindThis
public dispose(): void { public dispose(): void {
this.redisForSub.off('message', this.onMessage); this.internalEventService.off('avatarDecorationCreated', this.onAvatarEvent);
this.internalEventService.off('avatarDecorationUpdated', this.onAvatarEvent);
this.internalEventService.off('avatarDecorationDeleted', this.onAvatarEvent);
} }
@bindThis @bindThis