feat: raise-hand

waterbustech · Oct 25, 2024 · b5d7514 · b5d7514
1 parent 4800b67
commit b5d7514
Show file tree

Hide file tree

Showing 7 changed files with 28 additions and 3 deletions.
diff --git a/lib/core/webrtc/webrtc.dart b/lib/core/webrtc/webrtc.dart
@@ -462,10 +462,13 @@ class WaterbusWebRTCManagerIpml extends WaterbusWebRTCManager {
   }
 
   @override
-  void toggleRaiseHand() {
+  Future<void> toggleRaiseHand() async {
     if (_mParticipant == null) return;
 
     _mParticipant!.isHandRaising = !_mParticipant!.isHandRaising;
+
+    _notify(CallbackEvents.shouldBeUpdateState);
+
     _socketEmiter.setHandRaising(_mParticipant!.isHandRaising);
   }
 
@@ -525,7 +528,10 @@ class WaterbusWebRTCManagerIpml extends WaterbusWebRTCManager {
 
   @override
   void setHandRaising({required String targetId, required bool isRaising}) {
+    if (_subscribers[targetId]?.isHandRaising == isRaising) return;
+
     _subscribers[targetId]?.isHandRaising = isRaising;
+
     _notify(CallbackEvents.shouldBeUpdateState);
   }
 

diff --git a/lib/core/webrtc/webrtc_interface.dart b/lib/core/webrtc/webrtc_interface.dart
@@ -40,7 +40,7 @@ abstract class WaterbusWebRTCManager {
   Future<void> toggleSpeakerPhone({bool? forceValue});
   Future<void> toggleVideo();
   Future<void> switchCamera();
-  void toggleRaiseHand();
+  Future<void> toggleRaiseHand();
   void setE2eeEnabled({required String targetId, required bool isEnabled});
   void setVideoEnabled({required String targetId, required bool isEnabled});
   void setCameraType({required String targetId, required CameraType type});

diff --git a/lib/core/websocket/socket_handler.dart b/lib/core/websocket/socket_handler.dart
@@ -272,7 +272,6 @@ class SocketHandlerImpl extends SocketHandler {
 
         final String participantId = data['participantId'];
         final bool isRaising = data['isRaising'];
-
         _rtcManager.setHandRaising(
           targetId: participantId,
           isRaising: isRaising,

diff --git a/lib/flutter_waterbus_sdk.dart b/lib/flutter_waterbus_sdk.dart
@@ -190,6 +190,10 @@ class WaterbusSdk {
     await _sdk.toggleAudio();
   }
 
+  Future<void> toggleRaiseHand() async {
+    await _sdk.toggleRaiseHand();
+  }
+
   Future<void> toggleSpeakerPhone() async {
     await _sdk.toggleSpeakerPhone();
   }

diff --git a/lib/types/models/participant_sfu.dart b/lib/types/models/participant_sfu.dart
@@ -75,6 +75,7 @@ class ParticipantSFU extends Equatable {
 
     return other.isVideoEnabled == isVideoEnabled &&
         other.isAudioEnabled == isAudioEnabled &&
+        other.isHandRaising == isHandRaising &&
         other.isSharingScreen == isSharingScreen &&
         other.peerConnection == peerConnection &&
         other.cameraSource == cameraSource &&
@@ -85,6 +86,7 @@ class ParticipantSFU extends Equatable {
   int get hashCode {
     return isVideoEnabled.hashCode ^
         isAudioEnabled.hashCode ^
+        isHandRaising.hashCode ^
         isSharingScreen.hashCode ^
         peerConnection.hashCode ^
         cameraSource.hashCode ^
@@ -96,6 +98,7 @@ class ParticipantSFU extends Equatable {
     return [
       isVideoEnabled,
       isAudioEnabled,
+      isHandRaising,
       isE2eeEnabled,
       isSpeakerPhoneEnabled,
       isSharingScreen,
@@ -110,6 +113,7 @@ class ParticipantSFU extends Equatable {
     String? ownerId,
     bool? isVideoEnabled,
     bool? isAudioEnabled,
+    bool? isHandRaising,
     bool? isE2eeEnabled,
     bool? isSpeakerPhoneEnabled,
     bool? isSharingScreen,
@@ -125,6 +129,7 @@ class ParticipantSFU extends Equatable {
       ownerId: ownerId ?? this.ownerId,
       isVideoEnabled: isVideoEnabled ?? this.isVideoEnabled,
       isAudioEnabled: isAudioEnabled ?? this.isAudioEnabled,
+      isHandRaising: isHandRaising ?? this.isHandRaising,
       isE2eeEnabled: isE2eeEnabled ?? this.isE2eeEnabled,
       isSpeakerPhoneEnabled:
           isSpeakerPhoneEnabled ?? this.isSpeakerPhoneEnabled,
@@ -192,6 +197,10 @@ extension ParticipantSFUX on ParticipantSFU {
     }
   }
 
+  Future<void> setHandRaising(bool isRaising) async {
+    isHandRaising = isRaising;
+  }
+
   Future<void> dispose() async {
     setScreenSharing(false);
     cameraSource?.dispose();

diff --git a/lib/waterbus_sdk_impl.dart b/lib/waterbus_sdk_impl.dart
@@ -257,6 +257,11 @@ class SdkCore extends WaterbusSdkInterface {
     await _rtcManager.toggleAudio();
   }
 
+  @override
+  Future<void> toggleRaiseHand() async {
+    await _rtcManager.toggleRaiseHand();
+  }
+
   @override
   Future<void> toggleSpeakerPhone() async {
     await _rtcManager.toggleSpeakerPhone();

diff --git a/lib/waterbus_sdk_interface.dart b/lib/waterbus_sdk_interface.dart
@@ -89,6 +89,8 @@ abstract class WaterbusSdkInterface {
   Future<bool> stopRecord();
   Future<void> leaveRoom();
 
+  Future<void> toggleRaiseHand();
+
   // white board
   Future<void> startWhiteBoard();
   Future<void> updateWhiteBoard(