Merge pull request #142 from sendbird/v4.5.0

Add 4.5.0.

Author: sf-tyler-jeong

CHANGELOG.md

@@ -1,3 +1,14 @@
+## v4.5.0 (Jul 23, 2025)
+
+### Features
+- Added `getTotalUnreadMessageCountWithParams({GroupChannelTotalUnreadMessageCountParams? groupChannelParams, FeedChannelTotalUnreadMessageCountParams? feedChannelParams})` and deprecated `getTotalUnreadMessageCountWithFeedChannel([GroupChannelTotalUnreadMessageCountParams? params])`
+
+### Improvements
+- Added `logViewed(List<NotificationMessage> messages)` and deprecated `logImpression(List<NotificationMessage> messages)` in `FeedChannel`
+- Added API timeout for 10 seconds
+- Added reconnection timeout for `connectionTimeout` in `SendbirdChatOptions`
+- Updated regarding statistics
+
 ## v4.4.1 (Jun 27, 2025)
 
 ### Improvements

README.md

@@ -50,7 +50,7 @@ Before installing Sendbird Chat SDK, you need to create a Sendbird application o
 
 ```yaml
 dependencies:
-  sendbird_chat_sdk: ^4.4.1
+  sendbird_chat_sdk: ^4.5.0
 ```
 
 - Run `flutter pub get` command in your project directory.

lib/sendbird_chat_sdk.dart

@@ -75,6 +75,7 @@ export 'src/public/main/model/thread/thread_info.dart';
 export 'src/public/main/model/thread/thread_info_updated_event.dart';
 export 'src/public/main/model/thread/threaded_messages.dart';
 export 'src/public/main/params/channel/feed_channel_change_logs_params.dart';
+export 'src/public/main/params/channel/feed_channel_total_unread_message_count_params.dart';
 export 'src/public/main/params/channel/group_channel_change_logs_params.dart';
 export 'src/public/main/params/channel/group_channel_create_params.dart';
 export 'src/public/main/params/channel/group_channel_total_unread_channel_count_params.dart';

lib/src/internal/main/chat/chat.dart

@@ -53,6 +53,7 @@ import 'package:sendbird_chat_sdk/src/internal/network/http/http_client/request/
 import 'package:sendbird_chat_sdk/src/internal/network/http/http_client/request/user/preference/user_snooze_request.dart';
 import 'package:sendbird_chat_sdk/src/internal/network/http/http_client/request/user/push/user_push_register_request.dart';
 import 'package:sendbird_chat_sdk/src/internal/network/http/http_client/request/user/push/user_push_unregister_request.dart';
+import 'package:sendbird_chat_sdk/src/public/main/params/channel/feed_channel_total_unread_message_count_params.dart';
 import 'package:universal_io/io.dart';
 
 part 'chat_auth.dart';
@@ -65,7 +66,7 @@ part 'chat_notifications.dart';
 part 'chat_push.dart';
 part 'chat_user.dart';
 
-const sdkVersion = '4.4.1';
+const sdkVersion = '4.5.0';
 
 // Internal implementation for main class. Do not directly access this class.
 class Chat with WidgetsBindingObserver {

lib/src/internal/main/chat/chat_channel.dart

@@ -152,10 +152,16 @@ extension ChatChannel on Chat {
     return result;
   }
 
-  Future<UnreadMessageCount> getTotalUnreadMessageCount(
-      [GroupChannelTotalUnreadMessageCountParams? params]) async {
-    final result = await apiClient.send<UnreadMessageCount>(
-        UserTotalUnreadMessageCountGetRequest(this, params: params));
+  Future<UnreadMessageCount> getTotalUnreadMessageCount({
+    GroupChannelTotalUnreadMessageCountParams? groupChannelParams,
+    FeedChannelTotalUnreadMessageCountParams? feedChannelParams,
+  }) async {
+    final result = await apiClient
+        .send<UnreadMessageCount>(UserTotalUnreadMessageCountGetRequest(
+      this,
+      groupChannelParams: groupChannelParams,
+      feedChannelParams: feedChannelParams,
+    ));
     sbLog.i(StackTrace.current, 'return: $result');
     return result;
   }

lib/src/internal/main/chat_context/chat_context.dart

@@ -90,12 +90,12 @@ class ChatContext {
   UnreadMessageCountInfo unreadMessageCountInfo =
       UnreadMessageCountInfo(all: 0, customTypes: {}, ts: 0);
 
-  void resetReconnectTask() {
-    final config = reconnectConfig;
-    if (config != null) {
-      reconnectTask = ReconnectTask(config);
-    }
-  }
+  // void resetReconnectTask() {
+  //   final config = reconnectConfig;
+  //   if (config != null) {
+  //     reconnectTask = ReconnectTask(config);
+  //   }
+  // }
 
   bool get isChatConnected {
     return (services.isEmpty || services.contains(Service.chat)); // Check

lib/src/internal/main/chat_manager/command_manager.dart

@@ -43,6 +43,7 @@ import 'package:sendbird_chat_sdk/src/public/main/model/poll/poll_update_event.d
 import 'package:sendbird_chat_sdk/src/public/main/model/poll/poll_vote_event.dart';
 import 'package:sendbird_chat_sdk/src/public/main/model/reaction/reaction_event.dart';
 import 'package:sendbird_chat_sdk/src/public/main/model/thread/thread_info_updated_event.dart';
+import 'package:uuid/uuid.dart';
 
 class CommandManager {
   final Map<String, Completer<Command?>> _completerMap = {};
@@ -357,12 +358,24 @@ class CommandManager {
     //- [DBManager]
 
     if (fromWebSocket) {
+      final wasReconnecting = _chat.connectionManager.isReconnecting();
+      if (wasReconnecting) {
+        _chat.statManager.endWsConnectStat(
+          hostUrl: _chat.chatContext.reconnectTask?.url ?? '',
+          success: true,
+          connectedTs: _chat.connectionManager.webSocketClient.connectedTs,
+          logiTs: _chat.commandManager.logiTs,
+          accumTrial: _chat.chatContext.reconnectTask?.retryCount ?? 1,
+          connectionId:
+              _chat.chatContext.reconnectTask?.id ?? const Uuid().v1(),
+        );
+      }
+
       _chat.chatContext.reconnectTask =
           ReconnectTask(event.reconnectConfiguration);
       _chat.chatContext.setPingInterval(event.pingInterval);
       _chat.chatContext.setWatchdogInterval(event.watchdogInterval);
 
-      final wasReconnecting = _chat.connectionManager.isReconnecting();
       if (wasReconnecting) {
         await _chat.eventDispatcher.onReconnected(event);
       } else {

lib/src/internal/main/chat_manager/connection_manager.dart

@@ -20,6 +20,7 @@ import 'package:sendbird_chat_sdk/src/public/core/user/user.dart';
 import 'package:sendbird_chat_sdk/src/public/main/define/exceptions.dart';
 import 'package:sendbird_chat_sdk/src/public/main/define/sendbird_error.dart';
 import 'package:universal_io/io.dart';
+import 'package:uuid/uuid.dart';
 
 class ConnectionManager {
   Timer? reconnectTimer;
@@ -344,72 +345,101 @@ class ConnectionManager {
     }
 
     changeState(ReconnectingState(chat: chat));
-
-    if (reset) {
-      chat.chatContext.resetReconnectTask();
-    } else {
-      chat.chatContext.reconnectTask?.increaseRetryCount();
-    }
+    chat.chatContext.reconnectTask?.increaseRetryCount(reset: reset); // Check
 
     sbLog.i(
       StackTrace.current,
       '[Timer()] ${chat.chatContext.reconnectTask?.backOffPeriod}sec, ${chat.chatContext.reconnectTask?.retryCount}/${chat.chatContext.reconnectTask?.config.maximumRetryCount}',
     );
 
     reconnectTimer?.cancel();
-    reconnectTimer =
-        Timer(Duration(seconds: chat.chatContext.reconnectTask!.backOffPeriod),
-            () async {
-      sbLog.i(
-        StackTrace.current,
-        '[Timer() => RUN] ${chat.chatContext.reconnectTask?.backOffPeriod}sec, ${chat.chatContext.reconnectTask?.retryCount}/${chat.chatContext.reconnectTask?.config.maximumRetryCount}',
-      );
+    reconnectTimer = Timer(
+      Duration(seconds: chat.chatContext.reconnectTask!.backOffPeriod),
+      () async => await _reconnect(doNotCallReconnectStartedEvent),
+    );
+    return true;
+  }
 
-      if (chat.chatContext.reconnectTask?.retryCount == 1) {
-        if (!doNotCallReconnectStartedEvent) {
-          await chat.eventDispatcher.onReconnecting();
-          chat.eventManager.notifyReconnectStarted();
-        }
+  Future<void> _reconnect(bool doNotCallReconnectStartedEvent) async {
+    sbLog.i(
+      StackTrace.current,
+      '[Timer() => RUN] ${chat.chatContext.reconnectTask?.backOffPeriod}sec, ${chat.chatContext.reconnectTask?.retryCount}/${chat.chatContext.reconnectTask?.config.maximumRetryCount}',
+    );
+
+    if (chat.chatContext.reconnectTask?.retryCount == 1) {
+      if (!doNotCallReconnectStartedEvent) {
+        await chat.eventDispatcher.onReconnecting();
+        chat.eventManager.notifyReconnectStarted();
       }
+    }
 
-      // ===== Reconnect =====
-      final sessionKey = await chat.sessionManager.getSessionKey();
-      final params = {
-        if (sessionKey == null) 'user_id': chat.chatContext.currentUserId,
-        'SB-User-Agent': _sbUserAgentHeader,
-        'SB-SDK-USER-AGENT': _sbSdkUserAgentHeader,
-        'expiring_session':
-            chat.eventManager.getSessionHandler() != null ? '1' : '0',
-        'include_extra_data': chat.extraData.join(','),
-        'include_poll_details': '1',
-      };
-      params.addAll(await _getWebSocketParams(
-          userId: chat.chatContext.currentUser?.userId ?? ''));
-
-      final url =
-          '${chat.chatContext.wsHost}/?${Uri(queryParameters: params).query}';
-
-      runZonedGuarded(() {
-        sbLog.d(StackTrace.current, 'webSocketClient?.connect()');
-        webSocketClient.connect(
-          url: url,
-          accessToken: chat.chatContext.accessToken,
-          sessionKey: sessionKey,
-        );
+    // ===== Reconnect =====
+    final sessionKey = await chat.sessionManager.getSessionKey();
+    final params = {
+      if (sessionKey == null) 'user_id': chat.chatContext.currentUserId,
+      'SB-User-Agent': _sbUserAgentHeader,
+      'SB-SDK-USER-AGENT': _sbSdkUserAgentHeader,
+      'expiring_session':
+          chat.eventManager.getSessionHandler() != null ? '1' : '0',
+      'include_extra_data': chat.extraData.join(','),
+      'include_poll_details': '1',
+    };
+    params.addAll(await _getWebSocketParams(
+        userId: chat.chatContext.currentUser?.userId ?? ''));
 
-        reconnectTimer?.cancel();
-        reconnectTimer = null;
-      }, (e, s) {
-        sbLog.e(StackTrace.current, 'e: $e');
-      });
+    final url =
+        '${chat.chatContext.wsHost}/?${Uri(queryParameters: params).query}';
+
+    runZonedGuarded(() {
+      sbLog.d(StackTrace.current, 'webSocketClient?.connect()');
+
+      chat.statManager.startWsConnectStat(hostUrl: url);
+      if (chat.chatContext.reconnectTask != null) {
+        chat.chatContext.reconnectTask?.url = url;
+      }
+
+      webSocketClient.connect(
+        url: url,
+        accessToken: chat.chatContext.accessToken,
+        sessionKey: sessionKey,
+        reconnect: true,
+      );
+
+      reconnectTimer?.cancel();
+      reconnectTimer = null;
+    }, (e, s) {
+      sbLog.e(StackTrace.current, 'e: $e');
+
+      if (e is SendbirdException) {
+        chat.statManager.endWsConnectStat(
+          hostUrl: url,
+          success: false,
+          errorCode: e.code,
+          errorDescription: e.message,
+          accumTrial: chat.chatContext.reconnectTask?.retryCount ?? 1,
+          connectionId: chat.chatContext.reconnectTask?.id ?? const Uuid().v1(),
+        );
+      } else {
+        final exception = WebSocketFailedException(message: e.toString());
+
+        chat.statManager.endWsConnectStat(
+          hostUrl: url,
+          success: false,
+          errorCode: exception.code,
+          errorDescription: exception.message,
+          accumTrial: chat.chatContext.reconnectTask?.retryCount ?? 1,
+          connectionId: chat.chatContext.reconnectTask?.id ?? const Uuid().v1(),
+        );
+      }
     });
-    return true;
   }
 
 //------------------------------//
 // WebSocket Event Listener
 //------------------------------//
-  void _onWebSocketConnected() {}
+  void _onWebSocketConnected() {
+    // Nothing to do here.
+  }
 
   void _onWebSocketClosed() {
     chat.commandManager.clearCompleterMap();
@@ -459,6 +489,8 @@ class ConnectionManager {
   Future<void> _onWebSocketError(Object e) async {
     if (chat.chatContext.currentUser != null) {
       if (isReconnecting()) {
+        await Future.delayed(const Duration(
+            milliseconds: 1)); // [Timing issue] Because of endWsConnectStat()
         await reconnect(reset: false);
       } else {
         await disconnect(logout: false);

lib/src/internal/main/model/reconnect_task.dart

@@ -3,15 +3,21 @@
 import 'dart:math';
 
 import 'package:sendbird_chat_sdk/src/internal/main/model/reconnect_configuration.dart';
+import 'package:uuid/uuid.dart';
 
 class ReconnectTask {
+  final String _id = const Uuid().v1();
+  String? url;
   int _backOffPeriod = 0;
-  int _retryCount = 1;
+  int _retryCount = 0;
   ReconnectConfiguration config;
 
   ReconnectTask(this.config);
 
+  String get id => _id;
+
   int get backOffPeriod => _backOffPeriod;
+
   int get retryCount => _retryCount;
 
   bool get exceedRetryCount {
@@ -25,12 +31,24 @@ class ReconnectTask {
     return _retryCount == config.maximumRetryCount;
   }
 
-  void increaseRetryCount() {
-    if (_backOffPeriod < config.maxInterval) {
-      final newBackOff =
-          config.interval * pow(config.multiplier, (_retryCount - 1));
+  void increaseRetryCount({bool reset = false}) {
+    if (reset) {
+      if (_retryCount == 0) {
+        _retryCount = 1;
+      }
+
+      _backOffPeriod = 0;
+    } else if (_backOffPeriod < config.maxInterval) {
+      _retryCount++;
+
+      double newBackOff;
+      if (_retryCount <= 2) {
+        newBackOff = config.interval;
+      } else {
+        newBackOff =
+            config.interval * pow(config.multiplier, (_retryCount - 2));
+      }
       _backOffPeriod = min(newBackOff.toInt(), config.maxInterval.toInt());
     }
-    _retryCount++;
   }
 }

lib/src/internal/main/stats/stat_manager.dart

@@ -492,6 +492,7 @@ class StatManager {
     int? logiTs,
     int? errorCode,
     String? errorDescription,
+    String? connectionId,
   }) async {
     sbLog.d(StackTrace.current);
 
@@ -515,7 +516,7 @@ class StatManager {
         'logi_latency': logiLatency,
         'error_code': errorCode,
         'error_description': errorDescription,
-        'connection_id': const Uuid().v1(),
+        'connection_id': connectionId ?? const Uuid().v1(),
       },
     );
 
@@ -550,7 +551,7 @@ class StatManager {
   }) {
     sbLog.d(StackTrace.current);
 
-    if (_wsConnectStartTsMap[endpoint] == null) {
+    if (_apiResultStartTsMap[endpoint] == null) {
       _apiResultStartTsMap[endpoint] = DateTime.now().millisecondsSinceEpoch;
     }
   }