summaryrefslogtreecommitdiff
path: root/packages/backend/src/core
diff options
context:
space:
mode:
authorsyuilo <4439005+syuilo@users.noreply.github.com>2025-06-03 21:06:37 +0900
committersyuilo <4439005+syuilo@users.noreply.github.com>2025-06-03 21:06:37 +0900
commitb7aa013a41a56992da338181bdebd60ce99165b4 (patch)
treed8a03db59524b22e767aa57cbccbfbc072e0732d /packages/backend/src/core
parentBump version to 2025.6.1-alpha.0 (diff)
downloadmisskey-b7aa013a41a56992da338181bdebd60ce99165b4.tar.gz
misskey-b7aa013a41a56992da338181bdebd60ce99165b4.tar.bz2
misskey-b7aa013a41a56992da338181bdebd60ce99165b4.zip
feat: 全てのチャットメッセージを既読にできるように
Diffstat (limited to 'packages/backend/src/core')
-rw-r--r--packages/backend/src/core/ChatService.ts10
1 files changed, 10 insertions, 0 deletions
diff --git a/packages/backend/src/core/ChatService.ts b/packages/backend/src/core/ChatService.ts
index 4e81847a52..5cd336a097 100644
--- a/packages/backend/src/core/ChatService.ts
+++ b/packages/backend/src/core/ChatService.ts
@@ -332,6 +332,16 @@ export class ChatService {
}
@bindThis
+ public async readAllChatMessages(
+ readerId: MiUser['id'],
+ ): Promise<void> {
+ const redisPipeline = this.redisClient.pipeline();
+ // TODO: newUserChatMessageExists とか newRoomChatMessageExists も消したい(けどキーの列挙が必要になって面倒)
+ redisPipeline.del(`newChatMessagesExists:${readerId}`);
+ await redisPipeline.exec();
+ }
+
+ @bindThis
public findMessageById(messageId: MiChatMessage['id']) {
return this.chatMessagesRepository.findOneBy({ id: messageId });
}