summaryrefslogtreecommitdiff
path: root/packages/backend/src/core/RoleService.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2023-11-21 09:55:49 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2023-11-21 09:55:49 +0900
commited0cc443ea8122d01488f427bcced457d3d65d4f (patch)
treef8beb8e52ee3b0cdaa952d106f567a4b1fc8c62b /packages/backend/src/core/RoleService.ts
parenttweak of 2b6f789a5b (diff)
downloadsharkey-ed0cc443ea8122d01488f427bcced457d3d65d4f.tar.gz
sharkey-ed0cc443ea8122d01488f427bcced457d3d65d4f.tar.bz2
sharkey-ed0cc443ea8122d01488f427bcced457d3d65d4f.zip
fix(backend): ロールタイムラインが保存されない問題を修正
Diffstat (limited to 'packages/backend/src/core/RoleService.ts')
-rw-r--r--packages/backend/src/core/RoleService.ts5
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);