chore: cleanup

Author: isekovanic

package/src/components/Channel/Channel.tsx

@@ -717,6 +717,11 @@ const ChannelWithContext = <
    * Its a map of filename to AbortController
    */
   const uploadAbortControllerRef = useRef<Map<string, AbortController>>(new Map());
+  /**
+   * This ref keeps track of message IDs which have already been optimistically updated.
+   * We need it to make sure we don't react on message.new/notification.message_new events
+   * if this is indeed the case, as it's a full list update for nothing.
+   */
   const optimisticallyUpdatedNewMessages = useRef<Set<string>>(new Set());
 
   const channelId = channel?.id || '';
@@ -839,15 +844,14 @@ const ChannelWithContext = <
       }
 
       // only update channel state if the events are not the previously subscribed useEffect's subscription events
-      console.log('EVENT: ', event);
       if (channel && channel.initialized) {
+        // we skip the new message events if we've already done an optimistic update for the new message
         if (event.type === 'message.new' || event.type === 'notification.message_new') {
           const messageId = event.message?.id ?? '';
           if (
             event.user?.id !== client.userID ||
             !optimisticallyUpdatedNewMessages.current.has(messageId)
           ) {
-            console.log('INSIDE', Array.from(optimisticallyUpdatedNewMessages.current));
             copyMessagesStateFromChannelThrottled();
           }
           optimisticallyUpdatedNewMessages.current.delete(messageId);
@@ -859,7 +863,6 @@ const ChannelWithContext = <
           return;
         }
 
-        console.log('FULL STATE UPDATE');
         copyChannelState();
       }
     }
@@ -1426,6 +1429,7 @@ const ChannelWithContext = <
         const updatedMessage = { ...message, cid: channel.cid };
         updateMessage(updatedMessage);
         threadInstance?.upsertReplyLocally?.({ message: updatedMessage });
+        optimisticallyUpdatedNewMessages.current.delete(message.id);
 
         if (enableOfflineSupport) {
           await dbApi.updateMessage({

package/src/components/MessageList/MessageList.tsx

@@ -697,7 +697,6 @@ const MessageListWithContext = <
         if (!flatListRef.current) {
           return;
         }
-        console.log('DOING IT HERE');
         clearTimeout(failScrollTimeoutId.current);
         scrollToIndexFailedRetryCountRef.current = 0;
         // keep track of this messageId, so that we dont scroll to again in useEffect for targeted message change
@@ -851,10 +850,6 @@ const MessageListWithContext = <
     ],
   );
 
-  useEffect(() => {
-    console.log('RENDER ITEM CHANGED OH NOOOO');
-  }, [renderItem]);
-
   /**
    * We are keeping full control on message pagination, and not relying on react-native for it.
    * The reasons being,
@@ -1368,10 +1363,6 @@ export const MessageList = <
   const { loadMoreRecentThread, loadMoreThread, thread, threadInstance } =
     useThreadContext<StreamChatGenerics>();
 
-  useEffect(() => {
-    console.log('MARK READ CHANGED');
-  }, [markRead]);
-
   return (
     <MessageListWithContext
       {...{

package/src/components/MessageList/hooks/useMessageList.ts

@@ -1,4 +1,4 @@
-import { useEffect, useMemo } from 'react';
+import { useMemo } from 'react';
 
 import type { ChannelState, MessageResponse } from 'stream-chat';
 
@@ -140,10 +140,6 @@ export const useMessageList = <
     readData,
   ]);
 
-  useEffect(() => {
-    console.log('PROCESSED LIST CHANGED', processedMessageList);
-  }, [processedMessageList]);
-
   return {
     /** Messages enriched with dates/readby/groups and also reversed in order */
     processedMessageList,