GameCult/Ratatoskr
Watch
9
0
Fork
You've already forked Ratatoskr
 0
Code Issues Pull requests 2 Projects Releases Packages Wiki Activity Actions 7

remove unread notification when unread count does not appear in room

Browse source 
sync response
This commit is contained in:
Ajay Bura 2026-10-27 22:01:18 +05:30
commit 4c29b6e10e
1 changed files with 36 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

56
src/client/syncWriter/utils.ts
View file

@ -336,29 +336,41 @@ export const writeUnreadNotifications = async (
): Promise<void> => {
const existing = await ct.storage.unreadNotifications.read.getMultiple(joinRooms);
const unreadNotificationsObjects: UnreadNotificationsObject[] = joinRooms.flatMap(
(roomId, index) => {
const joinRoom = join[roomId];
const unreadNotificationsObjects: UnreadNotificationsObject[] = [];
const roomsToDelete: string[] = [];
const existingUnread = existing[index]?.unread;
const unread = joinRoomUtil.roomUnreadNotifications(joinRoom);
joinRooms.forEach((roomId, index) => {
const joinRoom = join[roomId];
const existingUnread = existing[index]?.unread;
const unread = joinRoomUtil.roomUnreadNotifications(joinRoom);
if (
!unread ||
(existingUnread?.highlight_count === unread.highlight_count &&
existingUnread?.notification_count === unread.notification_count)
) {
return [];
if (!unread) {
if (existingUnread) {
roomsToDelete.push(roomId);
}
const obj: UnreadNotificationsObject = {
id: roomId,
unread,
};
return obj;
return;
}
);
await ct.storage.unreadNotifications.write.putMultiple(unreadNotificationsObjects);
if (
existingUnread?.highlight_count === unread.highlight_count &&
existingUnread?.notification_count === unread.notification_count
) {
return;
}
unreadNotificationsObjects.push({
id: roomId,
unread,
});
});
if (roomsToDelete.length > 0) {
await ct.storage.unreadNotifications.write.deleteMultiple(roomsToDelete);
}
if (unreadNotificationsObjects.length > 0) {
await ct.storage.unreadNotifications.write.putMultiple(unreadNotificationsObjects);
}
};
export const writeUnreadThreadNotifications = async (
@ -399,8 +411,12 @@ export const writeUnreadThreadNotifications = async (
const toRemoveKeys = notificationsToRemove.map((n) =>
getUnreadThreadNotificationId(n.roomId, n.threadId)
);
await ct.storage.unreadThreadNotifications.write.deleteMultiple(toRemoveKeys);
await ct.storage.unreadThreadNotifications.write.putMultiple(unreadThreadNotificationsObjects);
if (toRemoveKeys.length > 0) {
await ct.storage.unreadThreadNotifications.write.deleteMultiple(toRemoveKeys);
}
if (unreadThreadNotificationsObjects.length > 0) {
await ct.storage.unreadThreadNotifications.write.putMultiple(unreadThreadNotificationsObjects);
}
};
export const writeInviteRoomState = async (