diff options
| author | syuilo <Syuilotan@yahoo.co.jp> | 2023-04-04 17:32:09 +0900 |
|---|---|---|
| committer | syuilo <Syuilotan@yahoo.co.jp> | 2023-04-04 17:32:09 +0900 |
| commit | ecaf152b4a6eb702375debaef0dddc2cca798116 (patch) | |
| tree | 85b2ca34a67ad66368fea84d0462b5c109b22415 /packages/backend/src/core/RelayService.ts | |
| parent | refactor(backend): rename Cache -> MemoryCache (diff) | |
| download | sharkey-ecaf152b4a6eb702375debaef0dddc2cca798116.tar.gz sharkey-ecaf152b4a6eb702375debaef0dddc2cca798116.tar.bz2 sharkey-ecaf152b4a6eb702375debaef0dddc2cca798116.zip | |
enhance(backend): improve cache
Diffstat (limited to 'packages/backend/src/core/RelayService.ts')
| -rw-r--r-- | packages/backend/src/core/RelayService.ts | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/packages/backend/src/core/RelayService.ts b/packages/backend/src/core/RelayService.ts index be5a4d4b02..4df7fb3bff 100644 --- a/packages/backend/src/core/RelayService.ts +++ b/packages/backend/src/core/RelayService.ts @@ -3,7 +3,7 @@ import { IsNull } from 'typeorm'; import type { LocalUser, User } from '@/models/entities/User.js'; import type { RelaysRepository, UsersRepository } from '@/models/index.js'; import { IdService } from '@/core/IdService.js'; -import { MemoryKVCache } from '@/misc/cache.js'; +import { MemoryCache } from '@/misc/cache.js'; import type { Relay } from '@/models/entities/Relay.js'; import { QueueService } from '@/core/QueueService.js'; import { CreateSystemUserService } from '@/core/CreateSystemUserService.js'; @@ -16,7 +16,7 @@ const ACTOR_USERNAME = 'relay.actor' as const; @Injectable() export class RelayService { - private relaysCache: MemoryKVCache<Relay[]>; + private relaysCache: MemoryCache<Relay[]>; constructor( @Inject(DI.usersRepository) @@ -30,7 +30,7 @@ export class RelayService { private createSystemUserService: CreateSystemUserService, private apRendererService: ApRendererService, ) { - this.relaysCache = new MemoryKVCache<Relay[]>(1000 * 60 * 10); + this.relaysCache = new MemoryCache<Relay[]>(1000 * 60 * 10); } @bindThis @@ -109,7 +109,7 @@ export class RelayService { public async deliverToRelays(user: { id: User['id']; host: null; }, activity: any): Promise<void> { if (activity == null) return; - const relays = await this.relaysCache.fetch(null, () => this.relaysRepository.findBy({ + const relays = await this.relaysCache.fetch(() => this.relaysRepository.findBy({ status: 'accepted', })); if (relays.length === 0) return; |