Merge pull request #151 from sendbird/v4.7.0

Add 4.7.0.

Author: sf-tyler-jeong

CHANGELOG.md

@@ -1,3 +1,14 @@
+## v4.7.0 (Oct 29, 2025)
+
+### Features
+- Added `onConnectionDelayed(int retryAfter)` in `ConnectionHandler`
+  - Automatically attempts to connect to the server in `retryAfter` seconds
+  - Called when the server cannot handle the connection immediately when `SendbirdChat.connect()` is called
+  - Called when the server is overloaded
+
+### Improvements
+- Improved local caching
+
 ## v4.6.0 (Oct 15, 2025)
 
 ### Features

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.6.0
+  sendbird_chat_sdk: ^4.7.0
 ```
 
 - Run `flutter pub get` command in your project directory.

lib/src/internal/db/db.dart

@@ -311,6 +311,20 @@ class DB {
     );
   }
 
+  Future<BaseMessage?> getBaseMessageById(
+    ChannelType channelType,
+    String channelUrl,
+    int messageId,
+  ) async {
+    return await CChannelMessage.getBaseMessageById(
+      _chat,
+      _isar,
+      channelType,
+      channelUrl,
+      messageId,
+    );
+  }
+
   Future<List<BaseMessage>> getPendingMessages({
     required ChannelType channelType,
     required String channelUrl,

lib/src/internal/db/schema/message/meta/c_channel_message.dart

@@ -290,6 +290,31 @@ class CChannelMessage {
     return messages;
   }
 
+  static Future<BaseMessage?> getBaseMessageById(
+    Chat chat,
+    Isar isar,
+    ChannelType channelType,
+    String channelUrl,
+    int messageId,
+  ) async {
+    final cChannelMessages = await isar.cChannelMessages
+        .where()
+        .channelTypeChannelUrlEqualTo(channelType, channelUrl)
+        .filter()
+        .rootIdEqualTo(messageId.toString())
+        .findAll();
+
+    List<BaseMessage> messages = [];
+    for (final cChannelMessage in cChannelMessages) {
+      final message = await cChannelMessage.toChannelMessage(chat, isar);
+      if (message != null && message.message is BaseMessage) {
+        messages.add(message.message as BaseMessage);
+      }
+    }
+
+    return messages.isNotEmpty ? messages[0] : null;
+  }
+
   static Future<List<BaseMessage>> getPendingMessages(
     Chat chat,
     Isar isar,

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

@@ -66,7 +66,7 @@ part 'chat_notifications.dart';
 part 'chat_push.dart';
 part 'chat_user.dart';
 
-const sdkVersion = '4.6.0';
+const sdkVersion = '4.7.0';
 
 // Internal implementation for main class. Do not directly access this class.
 class Chat with WidgetsBindingObserver {
@@ -244,11 +244,14 @@ class Chat with WidgetsBindingObserver {
             results.contains(ConnectivityResult.ethernet) ||
             results.contains(ConnectivityResult.vpn) ||
             results.contains(ConnectivityResult.other)) {
-          if (SendbirdChat.currentUser != null) {
-            if (chatContext.isChatConnected) {
+          if (chatContext.isChatConnected) {
+            if (SendbirdChat.currentUser != null ||
+                chatContext.currentUserId != null) {
               sbLog.d(StackTrace.current, 'reconnect()');
               await connectionManager.reconnect(reset: true);
-            } else if (chatContext.isFeedAuthenticated) {
+            }
+          } else if (chatContext.isFeedAuthenticated) {
+            if (SendbirdChat.currentUser != null) {
               sbLog.d(StackTrace.current, 'refreshNotificationCollections()');
               collectionManager.refreshNotificationCollections();
             }

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

@@ -24,7 +24,19 @@ class ChatContext {
   ChatContext({
     required this.appId,
     required this.options,
-  });
+  }) {
+    reconnectConfig = _getDefaultReconnectConfiguration(); // Check
+    reconnectTask = ReconnectTask(_getDefaultReconnectConfiguration()); // Check
+  }
+
+  ReconnectConfiguration _getDefaultReconnectConfiguration() {
+    return ReconnectConfiguration(
+      interval: 2,
+      maxInterval: 20,
+      multiplier: 2,
+      maximumRetryCount: -1,
+    ); // Check
+  }
 
   factory ChatContext.test() =>
       ChatContext(appId: '', options: SendbirdChatOptions());
@@ -38,6 +50,7 @@ class ChatContext {
   // 'LOGI' event
   User? currentUser;
   String? currentUserId;
+  String? nickname;
   List<Service> services = [];
   String? sessionKey;
   String? eKey;
@@ -50,6 +63,7 @@ class ChatContext {
   // Connection
   ReconnectTask? reconnectTask;
   Completer<User>? loginCompleter;
+  String? connectingUrl;
 
   // Entered OpenChannels
   Set<String> enteredOpenChannelUrls = {};
@@ -111,17 +125,19 @@ class ChatContext {
 
     currentUser = null;
     currentUserId = null;
+    nickname = null;
     services.clear();
     sessionKey = null;
     eKey = null;
     appInfo = null;
     uploadSizeLimit = 0;
     maxUnreadCountOnSuperGroup = null;
     lastConnectedAt = null;
-    reconnectConfig = null;
+    reconnectConfig = _getDefaultReconnectConfiguration(); // Check
 
     loginCompleter = null;
-    reconnectTask = null;
+    reconnectTask = ReconnectTask(_getDefaultReconnectConfiguration()); // Check
+    connectingUrl = null;
 
     enteredOpenChannelUrls.clear();
 

lib/src/internal/main/chat_manager/collection_manager/message_collection_manager.dart

@@ -682,6 +682,30 @@ extension MessageCollectionManager on CollectionManager {
             channelUrl: baseChannel.channelUrl,
             messages: addedMessages,
           );
+        } else if (addedMessages.length == 1 &&
+            addedMessages[0] is BaseMessage &&
+            (addedMessages[0] as BaseMessage).previousMessageId != null &&
+            (addedMessages[0] as BaseMessage).sendingStatus ==
+                SendingStatus.succeeded) {
+          final previousMessageId =
+              (addedMessages[0] as BaseMessage).previousMessageId;
+          if (previousMessageId != null) {
+            if (messageCollection.removePreviousMessageIdForTest == true) {
+              messageCollection.removePreviousMessageIdForTest = false;
+            } else {
+              final previousMessage = messageCollection.messageList
+                  .firstWhereOrNull((e) =>
+                      (e is BaseMessage && e.messageId == previousMessageId));
+
+              if (previousMessage != null) {
+                // MessageChunk
+                await _chat.dbManager.upsertMessagesInChunk(
+                  channelUrl: baseChannel.channelUrl,
+                  messages: [previousMessage, addedMessages[0]],
+                );
+              }
+            }
+          }
         }
       }
 

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

@@ -11,6 +11,7 @@ import 'package:sendbird_chat_sdk/src/internal/main/chat_context/chat_context.da
 import 'package:sendbird_chat_sdk/src/internal/main/chat_manager/collection_manager/collection_manager.dart';
 import 'package:sendbird_chat_sdk/src/internal/main/chat_manager/event_manager.dart';
 import 'package:sendbird_chat_sdk/src/internal/main/connection_state/connected_state.dart';
+import 'package:sendbird_chat_sdk/src/internal/main/connection_state/delayed_connecting_state.dart';
 import 'package:sendbird_chat_sdk/src/internal/main/logger/sendbird_logger.dart';
 import 'package:sendbird_chat_sdk/src/internal/main/model/delivery_status.dart';
 import 'package:sendbird_chat_sdk/src/internal/main/model/read_status.dart';
@@ -233,6 +234,8 @@ class CommandManager {
       await _processSessionRefresh(cmd);
     } else if (cmd.isLogin) {
       await _processLogin(cmd);
+    } else if (cmd.isBusy) {
+      await _processBusy(cmd);
     } else if (cmd.isSessionExpired) {
       await _processSessionExpired(cmd);
     } else if (cmd.isNewMessage) {
@@ -341,6 +344,7 @@ class CommandManager {
     _chat.chatContext
       ..currentUser = event.user
       ..currentUserId = event.user.userId
+      ..nickname = event.user.nickname
       ..sessionKey = event.sessionKey
       ..eKey = event.eKey
       ..appInfo = event.appInfo
@@ -398,6 +402,70 @@ class CommandManager {
     }
   }
 
+  Future<void> _processBusy(Command cmd) async {
+    int? retryAfter;
+    int? reasonCode;
+    String? message;
+
+    if (cmd.payload['retry_after'] != null &&
+        cmd.payload['retry_after'] is int &&
+        cmd.payload['retry_after'] >= 0) {
+      retryAfter = cmd.payload['retry_after'] as int;
+
+      if (cmd.payload['reason_code'] != null &&
+          cmd.payload['reason_code'] is int) {
+        reasonCode = cmd.payload['reason_code'] as int;
+      }
+
+      if (cmd.payload['message'] != null && cmd.payload['message'] is String) {
+        message = cmd.payload['message'] as String;
+      }
+
+      final e = ServerOverloadedException(
+        message: message,
+        data: {
+          'retry_after': retryAfter,
+          'reason_code': reasonCode,
+          'message': message,
+        },
+      );
+
+      if (_chat.connectionManager.isConnecting()) {
+        _chat.statManager.endWsConnectStat(
+          hostUrl: _chat.chatContext.connectingUrl ?? '',
+          success: false,
+          errorCode: e.code,
+          errorDescription: e.message,
+          accumTrial: 1,
+        );
+
+        if (_chat.chatContext.loginCompleter != null &&
+            !_chat.chatContext.loginCompleter!.isCompleted) {
+          _chat.chatContext.loginCompleter?.completeError(e);
+        }
+      } else if (_chat.connectionManager.isReconnecting()) {
+        _chat.statManager.endWsConnectStat(
+          hostUrl: _chat.chatContext.reconnectTask?.url ?? '',
+          success: false,
+          errorCode: e.code,
+          errorDescription: e.message,
+          accumTrial: _chat.chatContext.reconnectTask?.retryCount ?? 1,
+          connectionId:
+              _chat.chatContext.reconnectTask?.id ?? const Uuid().v1(),
+        );
+      } else if (_chat.connectionManager.isConnected()) {
+        await _chat.connectionManager.disconnect(logout: false);
+      }
+
+      _chat.connectionManager.changeState(DelayedConnectingState(
+        chat: _chat,
+        retryAfter: retryAfter,
+        reasonCode: reasonCode,
+        message: message,
+      ));
+    }
+  }
+
   Future<void> _enterEnteredOpenChannels() async {
     final enteredOpenChannelUrlCopied = {
       ..._chat.chatContext.enteredOpenChannelUrls
@@ -654,7 +722,7 @@ class CommandManager {
     }
   }
 
-  // only for open channel and broadcast channel
+// only for open channel and broadcast channel
   Future<void> _processMemberCountChange(Command cmd) async {
     final event = MCNTEvent.fromJsonWithChat(_chat, cmd.payload);