Merge remote-tracking branch 'origin/develop' into refactor/message-status

2023-06-20 14:32:30 +05:30
parent 7b1453aeca 7e45f3b555
commit 84b50fc852
34 changed files with 830 additions and 303 deletions
@@ -1510,15 +1510,32 @@ class Channel {
    );
  }

+  // Timer to keep track of mute expiration. This is used to update the channel
+  // state when the mute expires.
+  Timer? _muteExpirationTimer;
+
  /// Mutes the channel.
  Future<EmptyResponse> mute({Duration? expiration}) {
    _checkInitialized();
+
+    // If there is a expiration set, we will set a timer to automatically unmute
+    // the channel when the mute expires.
+    if (expiration != null) {
+      _muteExpirationTimer?.cancel();
+      _muteExpirationTimer = Timer(expiration, unmute);
+    }
+
    return _client.muteChannel(cid!, expiration: expiration);
  }

  /// Unmute the channel.
  Future<EmptyResponse> unmute() {
    _checkInitialized();
+
+    // Cancel the mute expiration timer if it is set.
+    _muteExpirationTimer?.cancel();
+    _muteExpirationTimer = null;
+
    return _client.unmuteChannel(cid!);
  }

@@ -1648,6 +1665,7 @@ class Channel {
  void dispose() {
    client.state.removeChannel('$cid');
    state?.dispose();
+    _muteExpirationTimer?.cancel();
    _keyStrokeHandler.cancel();
  }