fix: message list connection reconciliation (#2896)

* fix: connection recovery reconciliation in message list * fix: use top level state for user presence
GetStream · Jan 17, 2025 · 020cecc · 020cecc
1 parent 7e50994
commit 020cecc
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 4 deletions.
diff --git a/package/src/components/AITypingIndicatorView/hooks/useAIState.ts b/package/src/components/AITypingIndicatorView/hooks/useAIState.ts
@@ -4,7 +4,6 @@ import { AIState, Channel, Event } from 'stream-chat';
 
 import { useChatContext } from '../../../contexts';
 import type { DefaultStreamChatGenerics } from '../../../types/types';
-import { useIsOnline } from '../../Chat/hooks/useIsOnline';
 
 export const AIStates = {
   Error: 'AI_STATE_ERROR',
@@ -24,8 +23,7 @@ export const useAIState = <
 >(
   channel?: Channel<StreamChatGenerics>,
 ): { aiState: AIState } => {
-  const { client } = useChatContext<StreamChatGenerics>();
-  const { isOnline } = useIsOnline<StreamChatGenerics>(client);
+  const { isOnline } = useChatContext<StreamChatGenerics>();
 
   const [aiState, setAiState] = useState<AIState>(AIStates.Idle);
 

diff --git a/package/src/components/Channel/Channel.tsx b/package/src/components/Channel/Channel.tsx
@@ -985,6 +985,14 @@ const ChannelWithContext = <
     syncingChannelRef.current = true;
     setError(false);
 
+    if (channelMessagesState?.messages) {
+      await channel?.watch({
+        messages: {
+          limit: channelMessagesState.messages.length + 30,
+        },
+      });
+    }
+
     const parseMessage = (message: FormatMessageResponse<StreamChatGenerics>) =>
       ({
         ...message,
@@ -1003,6 +1011,7 @@ const ChannelWithContext = <
         if (failedMessages?.length) {
           channel.state.addMessagesSorted(failedMessages);
         }
+        channel.state.setIsUpToDate(true);
       } else {
         await reloadThread();
 
@@ -1042,7 +1051,7 @@ const ChannelWithContext = <
     if (enableOfflineSupport) {
       connectionChangedSubscription = DBSyncManager.onSyncStatusChange((statusChanged) => {
         if (statusChanged) {
-          copyChannelState();
+          connectionChangedHandler();
         }
       });
     } else {