fix: properly sync own reads while offline mode is enabled (#2902)

* fix: properly sync own reads while offline mode is enabled

* fix: use proper unreadCount

* fix: use countUnread() api for brevity

Author: isekovanic

package/src/components/ChannelList/hooks/useCreateChannelsContext.ts

@@ -41,7 +41,9 @@ export const useCreateChannelsContext = <
   const channelValueString = channels
     ?.map(
       (channel) =>
-        `${channel.data?.name ?? ''}${channel.id ?? ''}${Object.values(channel.state.members)
+        `${channel.data?.name ?? ''}${channel.id ?? ''}${
+          channel?.state?.unreadCount ?? ''
+        }${Object.values(channel.state.members)
           .map((member) => member.user?.online)
           .join()}`,
     )

package/src/components/ChannelPreview/hooks/useChannelPreviewData.ts

@@ -47,8 +47,7 @@ export const useChannelPreviewData = <
     }
     const newUnreadCount = channel.countUnread();
     setUnread(newUnreadCount);
-    // eslint-disable-next-line react-hooks/exhaustive-deps
-  }, [channel, channelLastMessageString, channelListForceUpdate]);
+  }, [channel, channelLastMessage, channelLastMessageString, channelListForceUpdate, lastMessage]);
 
   /**
    * This effect listens for the `notification.mark_read` event and sets the unread count to 0

package/src/components/Chat/hooks/handleEventToSyncDB.ts

@@ -97,14 +97,36 @@ export const handleEventToSyncDB = <
   }
 
   if (type === 'message.new') {
-    const message = event.message;
+    const { cid, message, user } = event;
+
     if (message && (!message.parent_id || message.show_in_channel)) {
-      return queriesWithChannelGuard((flushOverride) =>
-        upsertMessages({
+      return queriesWithChannelGuard((flushOverride) => {
+        let queries = upsertMessages({
           flush: flushOverride,
           messages: [message],
-        }),
-      );
+        });
+        if (cid && client.user && client.user.id !== user?.id) {
+          const userId = client.user.id;
+          const channel = client.activeChannels[cid];
+          if (channel) {
+            const ownReads = channel.state.read[userId];
+            const unreadCount = channel.countUnread();
+            const upsertReadsQueries = upsertReads({
+              cid,
+              flush: flushOverride,
+              reads: [
+                {
+                  last_read: ownReads.last_read.toString() as string,
+                  unread_messages: unreadCount,
+                  user: client.user,
+                },
+              ],
+            });
+            queries = [...queries, ...upsertReadsQueries];
+          }
+        }
+        return queries;
+      });
     }
   }