Fix shadowed messages increasing the channel messages unread count (#3665)

Author: nuno-vieira

CHANGELOG.md

@@ -6,6 +6,7 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/).
 ## StreamChat
 ### 🐞 Fixed
 - Fix swipe to reply enabled when quoting a message is disabled [#3662](https://github.com/GetStream/stream-chat-swift/pull/3662)
+- Fix shadowed messages increasing the channel messages unread count [#3665](https://github.com/GetStream/stream-chat-swift/pull/3665)
 
 # [4.78.0](https://github.com/GetStream/stream-chat-swift/releases/tag/4.78.0)
 _April 24, 2025_

Sources/StreamChat/WebSocketClient/EventMiddlewares/ChannelReadUpdaterMiddleware.swift

@@ -222,6 +222,10 @@ struct ChannelReadUpdaterMiddleware: EventMiddleware {
             return .messageIsSystem
         }
 
+        if message.isShadowed {
+            return .messageIsShadowed
+        }
+
         if message.createdAt <= channelRead.lastReadAt.bridgeDate {
             return .messageIsSeen
         }
@@ -237,6 +241,7 @@ private enum UnreadSkippingReason: CustomStringConvertible {
     case messageIsSilent
     case messageIsThreadReply
     case messageIsSystem
+    case messageIsShadowed
     case messageIsSeen
     case messageIsSoftDeleted
 
@@ -254,6 +259,8 @@ private enum UnreadSkippingReason: CustomStringConvertible {
             return "Thread replies do not affect unread counts"
         case .messageIsSystem:
             return "System messages do not affect unread counts"
+        case .messageIsShadowed:
+            return "Shadowed messages do not affect unread counts"
         case .messageIsSeen:
             return "Seen messages do not affect unread counts"
         case .messageIsSoftDeleted:

Tests/StreamChatTests/WebSocketClient/EventMiddlewares/ChannelReadUpdaterMiddleware_Tests.swift

@@ -591,6 +591,35 @@ final class ChannelReadUpdaterMiddleware_Tests: XCTestCase {
         XCTAssertEqual(Int(read.unreadMessageCount), currentUserReadPayload.unreadMessagesCount)
     }
 
+    func test_messageNewEvent_whenMessageIsShadowed_doesNotIncrementUnreadCount() throws {
+        // WHEN
+        let shadowedMessage: MessagePayload = .dummy(
+            type: .regular,
+            messageId: .unique,
+            authorUserId: anotherUserPayload.id,
+            createdAt: currentUserReadPayload.lastReadAt.addingTimeInterval(1),
+            isShadowed: true
+        )
+
+        let messageNewEvent = try MessageNewEventDTO(
+            from: .init(
+                eventType: .messageNew,
+                cid: channelPayload.channel.cid,
+                user: anotherUserPayload,
+                message: shadowedMessage,
+                createdAt: shadowedMessage.createdAt
+            )
+        )
+
+        try database.writeSynchronously { session in
+            _ = self.middleware.handle(event: messageNewEvent, session: session)
+        }
+
+        // THEN
+        let read = try XCTUnwrap(currentUserReadDTO)
+        XCTAssertEqual(Int(read.unreadMessageCount), currentUserReadPayload.unreadMessagesCount)
+    }
+
     func test_messageNewEvent_whenMessageIsRead_doesNotIncrementUnreadCount() throws {
         // WHEN
         let regularMessageEarlierThanLastRead: MessagePayload = .dummy(