chore: add mark unread tests and update read tests in db

Author: isekovanic

package/src/__tests__/offline-support/offline-feature.js

@@ -26,6 +26,7 @@ import dispatchMessageNewEvent from '../../mock-builders/event/messageNew';
 import dispatchMessageReadEvent from '../../mock-builders/event/messageRead';
 import dispatchMessageUpdatedEvent from '../../mock-builders/event/messageUpdated';
 import dispatchNotificationAddedToChannel from '../../mock-builders/event/notificationAddedToChannel';
+import dispatchNotificationMarkUnread from '../../mock-builders/event/notificationMarkUnread';
 import dispatchNotificationMessageNewEvent from '../../mock-builders/event/notificationMessageNew';
 import dispatchNotificationRemovedFromChannel from '../../mock-builders/event/notificationRemovedFromChannel';
 import dispatchReactionDeletedEvent from '../../mock-builders/event/reactionDeleted';
@@ -1244,8 +1245,14 @@ export const Generic = () => {
       const targetChannel = channels[getRandomInt(0, channels.length - 1)];
       const targetMember = targetChannel.members[getRandomInt(0, targetChannel.members.length - 1)];
 
+      const readTimestamp = new Date().toISOString();
+
       act(() => {
-        dispatchMessageReadEvent(chatClient, targetMember.user, targetChannel.channel);
+        dispatchMessageReadEvent(chatClient, targetMember.user, targetChannel.channel, {
+          first_unread_message_id: '123',
+          last_read: readTimestamp,
+          last_read_message_id: '321',
+        });
       });
 
       await waitFor(async () => {
@@ -1256,6 +1263,54 @@ export const Generic = () => {
 
         expect(matchingReadRows.length).toBe(1);
         expect(matchingReadRows[0].unreadMessages).toBe(0);
+        expect(matchingReadRows[0].lastReadMessageId).toBe('321');
+        // FIXME: Currently missing from the DB, uncomment when added.
+        // expect(matchingReadRows[0].firstUnreadMessageId).toBe('123');
+        expect(matchingReadRows[0].lastRead).toBe(readTimestamp);
+      });
+    });
+
+    it('should update reads in DB when a channel is marked as unread', async () => {
+      useMockedApis(chatClient, [queryChannelsApi(channels)]);
+
+      renderComponent();
+      act(() => dispatchConnectionChangedEvent(chatClient));
+      await act(async () => await chatClient.offlineDb.syncManager.invokeSyncStatusListeners(true));
+      await waitFor(() => expect(screen.getByTestId('channel-list')).toBeTruthy());
+      const targetChannel = channels[getRandomInt(0, channels.length - 1)];
+      const targetMember = targetChannel.members[getRandomInt(0, targetChannel.members.length - 1)];
+
+      chatClient.userID = targetMember.user.id;
+      chatClient.user = targetMember.user;
+
+      const readTimestamp = new Date().toISOString();
+
+      act(() => {
+        dispatchNotificationMarkUnread(
+          chatClient,
+          targetChannel.channel,
+          {
+            first_unread_message_id: '123',
+            last_read: readTimestamp,
+            last_read_message_id: '321',
+            unread_messages: 5,
+          },
+          targetMember.user,
+        );
+      });
+
+      await waitFor(async () => {
+        const readsRows = await BetterSqlite.selectFromTable('reads');
+        const matchingReadRows = readsRows.filter(
+          (r) => r.userId === targetMember.user_id && r.cid === targetChannel.cid,
+        );
+
+        expect(matchingReadRows.length).toBe(1);
+        expect(matchingReadRows[0].unreadMessages).toBe(5);
+        expect(matchingReadRows[0].lastReadMessageId).toBe('321');
+        // FIXME: Currently missing from the DB, uncomment when added.
+        // expect(matchingReadRows[0].firstUnreadMessageId).toBe('123');
+        expect(matchingReadRows[0].lastRead).toBe(readTimestamp);
       });
     });
   });

package/src/mock-builders/event/messageRead.js

@@ -1,4 +1,4 @@
-export default (client, user, channel = {}) => {
+export default (client, user, channel = {}, payload = {}) => {
   const newDate = new Date();
   const event = {
     channel,
@@ -7,6 +7,7 @@ export default (client, user, channel = {}) => {
     received_at: newDate,
     type: 'message.read',
     user,
+    ...payload,
   };
   client.dispatchEvent(event);
 

package/src/mock-builders/event/notificationMarkUnread.js

@@ -1,7 +1,10 @@
 export default (client, channel = {}, payload = {}, user = {}) => {
+  const newDate = new Date();
   client.dispatchEvent({
     channel,
     cid: channel.cid,
+    created_at: newDate,
+    received_at: newDate,
     type: 'notification.mark_unread',
     user,
     ...payload,

package/src/store/mappers/mapReadToStorable.ts

@@ -11,11 +11,12 @@ export const mapReadToStorable = ({
   cid: string;
   read: ReadResponse;
 }): TableRow<'reads'> => {
-  const { last_read, unread_messages, user } = read;
+  const { last_read, unread_messages, user, last_read_message_id } = read;
 
   return {
     cid,
     lastRead: mapDateTimeToStorable(last_read),
+    lastReadMessageId: last_read_message_id,
     unreadMessages: unread_messages,
     userId: user?.id,
   };

package/src/store/mappers/mapStorableToRead.ts

@@ -5,10 +5,11 @@ import { mapStorableToUser } from './mapStorableToUser';
 import type { TableRowJoinedUser } from '../types';
 
 export const mapStorableToRead = (row: TableRowJoinedUser<'reads'>): ReadResponse => {
-  const { lastRead, unreadMessages, user } = row;
+  const { lastRead, unreadMessages, user, lastReadMessageId } = row;
 
   return {
     last_read: lastRead,
+    last_read_message_id: lastReadMessageId,
     unread_messages: unreadMessages,
     user: mapStorableToUser(user),
   };