fix(llc): handle channel mute expiration.

Signed-off-by: xsahil03x <[email protected]>
2023-06-19 14:08:04 +05:30
parent d3623ed4c2
commit 5db41595e2
2 changed files with 42 additions and 0 deletions
@@ -1447,15 +1447,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!);
  }