Expose: Sdk socket methods

lib/flutter_waterbus_sdk.dart

@@ -306,6 +306,21 @@ class WaterbusSdk {
 
   CallState get callState => _sdk.callState;
 
+  // Ws Socket
+  bool get isWsConnected => _sdk.isWsConnected;
+
+  void reconnectWs({required Function callbackConnected}) {
+    _sdk.reconnectWs(callbackConnected: callbackConnected);
+  }
+
+  void connectWs({bool forceConnection = false}) {
+    _sdk.connectWs(forceConnection: forceConnection);
+  }
+
+  void disconnectWs() {
+    _sdk.disconnectWs();
+  }
+
   // Private
   WaterbusSdkInterface get _sdk => getIt<WaterbusSdkInterface>();
   CallKitListener get _callKitListener => getIt<CallKitListener>();

lib/waterbus_sdk_impl.dart

@@ -434,4 +434,23 @@ class SdkCore extends WaterbusSdkInterface {
 
   @override
   CallState get callState => _rtcManager.getCallState();
+
+  // Ws
+  @override
+  bool get isWsConnected => _wsHandler.isConnected;
+
+  @override
+  void reconnectWs({required Function callbackConnected}) {
+    _wsHandler.reconnect(callbackConnected: callbackConnected);
+  }
+
+  @override
+  void disconnectWs() {
+    _wsHandler.disconnection();
+  }
+
+  @override
+  void connectWs({bool forceConnection = false}) {
+    _wsHandler.establishConnection(forceConnection: forceConnection);
+  }
 }

lib/waterbus_sdk_interface.dart

@@ -88,5 +88,11 @@ abstract class WaterbusSdkInterface {
   Future<void> disableVirtualBg();
   Future<void> setPiPEnabled({required String textureId, bool enabled = true});
 
+  // Ws
+  void connectWs({bool forceConnection = false});
+  void disconnectWs();
+  void reconnectWs({required Function callbackConnected});
+  bool get isWsConnected;
+
   CallState get callState;
 }