wip

packages/backend/src/core/ChatService.ts

@@ -248,11 +248,11 @@ export class ChatService {
 	public async readUserChatMessage(
 		readerId: MiUser['id'],
 		senderId: MiUser['id'],
-	) {
+	): Promise<void> {
 		const redisPipeline = this.redisClient.pipeline();
 		redisPipeline.del(`newChatMessageExists:${readerId}:${senderId}`);
 		redisPipeline.srem(`newChatMessagesExists:${readerId}`, `user:${senderId}`);
-		redisPipeline.exec();
+		await redisPipeline.exec();
 	}
 
 	@bindThis
@@ -467,6 +467,7 @@ export class ChatService {
 
 	@bindThis
 	public async hasUnreadMessages(userId: MiUser['id']) {
-		// TODO
+		const card = await this.redisClient.scard(`newChatMessagesExists:${userId}`);
+		return card > 0;
 	}
 }

packages/backend/src/core/GlobalEventService.ts

@@ -74,6 +74,7 @@ export interface MainEventTypes {
 	unreadNotification: Packed<'Notification'>;
 	readAllAntennas: undefined;
 	unreadAntenna: MiAntenna;
+	newChatMessage: Packed<'ChatMessage'>;
 	readAllAnnouncements: undefined;
 	myTokenRegenerated: undefined;
 	signin: {

packages/backend/src/models/json-schema/user.ts

@@ -545,6 +545,10 @@ export const packedMeDetailedOnlySchema = {
 			type: 'boolean',
 			nullable: false, optional: false,
 		},
+		hasUnreadChatMessages: {
+			type: 'boolean',
+			nullable: false, optional: false,
+		},
 		hasUnreadNotification: {
 			type: 'boolean',
 			nullable: false, optional: false,