diff options
| author | syuilo <Syuilotan@yahoo.co.jp> | 2023-11-21 09:55:49 +0900 |
|---|---|---|
| committer | syuilo <Syuilotan@yahoo.co.jp> | 2023-11-21 09:55:49 +0900 |
| commit | ed0cc443ea8122d01488f427bcced457d3d65d4f (patch) | |
| tree | f8beb8e52ee3b0cdaa952d106f567a4b1fc8c62b /packages/backend/src | |
| parent | tweak of 2b6f789a5b (diff) | |
| download | sharkey-ed0cc443ea8122d01488f427bcced457d3d65d4f.tar.gz sharkey-ed0cc443ea8122d01488f427bcced457d3d65d4f.tar.bz2 sharkey-ed0cc443ea8122d01488f427bcced457d3d65d4f.zip | |
fix(backend): ロールタイムラインが保存されない問題を修正
Diffstat (limited to 'packages/backend/src')
| -rw-r--r-- | packages/backend/src/core/RoleService.ts | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/packages/backend/src/core/RoleService.ts b/packages/backend/src/core/RoleService.ts index d6a414694a..432887b3b7 100644 --- a/packages/backend/src/core/RoleService.ts +++ b/packages/backend/src/core/RoleService.ts @@ -87,6 +87,9 @@ export class RoleService implements OnApplicationShutdown { @Inject(DI.redis) private redisClient: Redis.Redis, + @Inject(DI.redisForTimelines) + private redisForTimelines: Redis.Redis, + @Inject(DI.redisForSub) private redisForSub: Redis.Redis, @@ -476,7 +479,7 @@ export class RoleService implements OnApplicationShutdown { public async addNoteToRoleTimeline(note: Packed<'Note'>): Promise<void> { const roles = await this.getUserRoles(note.userId); - const redisPipeline = this.redisClient.pipeline(); + const redisPipeline = this.redisForTimelines.pipeline(); for (const role of roles) { this.funoutTimelineService.push(`roleTimeline:${role.id}`, note.id, 1000, redisPipeline); |