4.0.2

sendbird · Jun 23, 2023 · 8f5e7c4 · 8f5e7c4
1 parent 2fa3479
commit 8f5e7c4
Show file tree

Hide file tree

Showing 12 changed files with 156 additions and 169 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,6 @@
+## v4.0.2 (Jun 23, 2023)
+- Improved stability.
+
 ## v4.0.1 (Jun 14, 2023)
 - Improved stability.
 

diff --git a/README.md b/README.md
@@ -28,8 +28,8 @@ Find out more about Sendbird Chat for Flutter on [the documentation](https://st.
 ## Requirements
 
 The minimum requirements for the Chat SDK for Flutter are:
-- Dart 2.17.0 or later
-- Flutter 2.11.0 or later
+- Dart 2.19.0 or later
+- Flutter 3.7.0 or later
 
 > **Note**: Sendbird server supports Transport Layer Security (TLS) from version 1.0 up to 1.3. For example, in the server regions where TLS 1.3 isn’t available, lower versions, sequentially from 1.2 to 1.0, will be supported for secure data transmission.
 
@@ -48,7 +48,7 @@ Before installing Sendbird Chat SDK, you need to create a Sendbird application o
 
 ```yaml
 dependencies:
-  sendbird_chat_sdk: ^4.0.0
+  sendbird_chat_sdk: ^4.0.2
 ```
 
 - Run `flutter pub get` command in your project directory.

diff --git a/analysis_options.yaml b/analysis_options.yaml
diff --git a/lib/src/internal/main/chat/chat.dart b/lib/src/internal/main/chat/chat.dart
@@ -49,7 +49,7 @@ part 'chat_event_handler.dart';
 part 'chat_push.dart';
 part 'chat_user.dart';
 
-const sdkVersion = '4.0.1';
+const sdkVersion = '4.0.2';
 
 // Internal implementation for main class. Do not directly access this class.
 class Chat with WidgetsBindingObserver {
@@ -170,43 +170,39 @@ class Chat with WidgetsBindingObserver {
 
     if (!isTest) {
       Connectivity().onConnectivityChanged.asBroadcastStream(
-            onCancel: (controller) => {
-              _connectivityResult = ConnectivityResult.none,
-              controller.pause(),
-            },
-            onListen: (subscription) {
-              subscription.onData((data) async {
-                switch (data) {
-                  case ConnectivityResult.none:
-                    break;
-                  case ConnectivityResult.mobile:
-                    if (_connectivityResult == ConnectivityResult.none &&
-                        chatContext.sessionKey != null) {
-                      await connectionManager.reconnect(reset: true);
-                    }
-                    break;
-                  case ConnectivityResult.wifi:
-                    if (_connectivityResult == ConnectivityResult.none &&
-                        chatContext.sessionKey != null) {
-                      await connectionManager.reconnect(reset: true);
-                    }
-                    break;
-                  case ConnectivityResult.bluetooth:
-                  case ConnectivityResult.ethernet:
-                    if (_connectivityResult == ConnectivityResult.none &&
-                        chatContext.sessionKey != null) {
-                      await connectionManager.reconnect(reset: true);
-                    }
-                    break;
-                  case ConnectivityResult.vpn:
-                    break;
-                  default:
-                    break;
-                }
-                _connectivityResult = data;
-              });
-            },
-          );
+          onCancel: (controller) => {
+                _connectivityResult = ConnectivityResult.none,
+                controller.pause(),
+              },
+          onListen: (subscription) {
+            subscription.onData((data) async {
+              switch (data) {
+                case ConnectivityResult.none:
+                  sbLog.d(StackTrace.current, 'ConnectivityResult.none');
+                  channelCache.markAsDirtyAll(); // Check
+                  break;
+                case ConnectivityResult.mobile:
+                case ConnectivityResult.wifi:
+                case ConnectivityResult.ethernet:
+                case ConnectivityResult.vpn:
+                case ConnectivityResult.other:
+                  sbLog.d(
+                      StackTrace.current, '${data.toString()} => reconnect()');
+                  if (_connectivityResult == ConnectivityResult.none &&
+                      chatContext.sessionKey != null) {
+                    await connectionManager.reconnect(reset: true);
+                  }
+                  break;
+                case ConnectivityResult.bluetooth:
+                  sbLog.d(StackTrace.current, 'ConnectivityResult.bluetooth');
+                  break;
+                default:
+                  sbLog.d(StackTrace.current, data.toString());
+                  break;
+              }
+              _connectivityResult = data;
+            });
+          });
     }
   }
 

diff --git a/lib/src/internal/main/chat_manager/command_manager.dart b/lib/src/internal/main/chat_manager/command_manager.dart
@@ -120,8 +120,10 @@ class CommandManager {
   }
 
   Future<void> processCommand(Command cmd) async {
-    sbLog.d(StackTrace.current,
-        '\n-[cmd] ${cmd.cmd}\n-[payload] ${jsonEncoder.convert(cmd.payload)}');
+    if (cmd.payload['cmd'] == null || cmd.payload['cmd'] != 'PONG') {
+      sbLog.d(StackTrace.current,
+          '\n-[cmd] ${cmd.cmd}\n-[payload] ${jsonEncoder.convert(cmd.payload)}');
+    }
 
     final unreadCountPayload = cmd.payload['unread_cnt'];
     if (unreadCountPayload != null) {
@@ -180,7 +182,9 @@ class CommandManager {
     } else if (cmd.isVote) {
       await _processVote(cmd);
     } else {
-      sbLog.i(StackTrace.current, 'Pass command: ${cmd.cmd}');
+      if (cmd.cmd != 'PONG') {
+        sbLog.i(StackTrace.current, 'Pass command: ${cmd.cmd}');
+      }
     }
   }
 

diff --git a/lib/src/internal/main/logger/sendbird_logger.dart b/lib/src/internal/main/logger/sendbird_logger.dart
@@ -10,7 +10,9 @@ class SendbirdLogger {
   Logger logger;
 
   static final _instance = SendbirdLogger._();
-  SendbirdLogger._() : logger = Logger(level: Level.nothing);
+  SendbirdLogger._() : logger = Logger(level: Level.nothing) {
+    _setLogLevel(Level.nothing);
+  }
   factory SendbirdLogger() => _instance;
 
   void setLogLevel(LogLevel level) {

diff --git a/lib/src/internal/main/utils/async/async_queue.dart b/lib/src/internal/main/utils/async/async_queue.dart
@@ -57,6 +57,7 @@ class AsyncQueue<T> {
         }
       } catch (e) {
         sbLog.e(StackTrace.current, 'e: $e');
+        rethrow;
       }
     }
   }

diff --git a/lib/src/internal/network/websocket/websocket_client.dart b/lib/src/internal/network/websocket/websocket_client.dart
@@ -107,10 +107,12 @@ class WebSocketClient {
   }
 
   void send(String data) {
+    if (!_isConnected) {
+      throw WebSocketFailedException();
+    }
+
     try {
-      if (_isConnected) {
-        _webSocketChannel?.sink.add(data);
-      }
+      _webSocketChannel?.sink.add(data);
     } catch (e) {
       sbLog.e(StackTrace.current, 'e: $e');
       throw WebSocketFailedException(message: e.toString());

diff --git a/lib/src/public/core/channel/base_channel/base_channel.dart b/lib/src/public/core/channel/base_channel/base_channel.dart
@@ -211,5 +211,8 @@ abstract class BaseChannel implements Cacheable {
     customType = others.customType;
     isFrozen = others.isFrozen;
     isEphemeral = others.isEphemeral;
+
+    fromCache = others.fromCache;
+    dirty = others.dirty;
   }
 }
-Original file line number
+Diff line change
@@ Expand Up / @@ -57,6 +57,7 @@ class AsyncQueue<T> { @@
             }
           } catch (e) {
             sbLog.e(StackTrace.current, 'e: $e');
+            rethrow;
           }
         }
       }
@@ Expand Down @@