fix: add getConnectedDevices support on Android

Author: dballance

example/pubspec.yaml

@@ -29,6 +29,8 @@ dependency_overrides:
     path: ../packages/flutter_reactive_ble
   reactive_ble_mobile:
     path: ../packages/reactive_ble_mobile
+  reactive_ble_platform_interface:
+    path: ../packages/reactive_ble_platform_interface
 
 flutter:
   uses-material-design: true

packages/reactive_ble_mobile/android/src/main/kotlin/com/signify/hue/flutterreactiveble/PluginController.kt

@@ -36,7 +36,8 @@ class PluginController {
             "stopNotifications" to this::stopNotifications,
             "negotiateMtuSize" to this::negotiateMtuSize,
             "requestConnectionPriority" to this::requestConnectionPriority,
-            "discoverServices" to this::discoverServices
+            "discoverServices" to this::discoverServices,
+            "getConnectedDevices" to this::getConnectedDevices
     )
 
     lateinit var bleClient: com.signify.hue.flutterreactiveble.ble.BleClient
@@ -267,4 +268,11 @@ class PluginController {
                 })
                 .discard()
     }
+
+    private fun getConnectedDevices(call: MethodCall, result: Result) {
+        val devices = bleClient.getConnectedDevices().map{ protoConverter.convertToDeviceInfo(it) }
+        val message = pb.DeviceInfoCollection.newBuilder()
+        devices.forEachIndexed { index, device -> message.setDevices(index, device)}
+        result.success(message.build().toByteArray())
+    }
 }

packages/reactive_ble_mobile/android/src/main/kotlin/com/signify/hue/flutterreactiveble/ble/BleClient.kt

@@ -18,6 +18,7 @@ interface BleClient {
     fun initializeClient()
     fun scanForDevices(services: List<ParcelUuid>, scanMode: ScanMode, requireLocationServicesEnabled: Boolean): Observable<com.signify.hue.flutterreactiveble.ble.ScanInfo>
     fun connectToDevice(deviceId: String, timeout: Duration)
+    fun getConnectedDevices(): List<com.signify.hue.flutterreactiveble.ble.ConnectionUpdateSuccess>
     fun disconnectDevice(deviceId: String)
     fun disconnectAllDevices()
     fun discoverServices(deviceId: String): Single<RxBleDeviceServices>

packages/reactive_ble_mobile/android/src/main/kotlin/com/signify/hue/flutterreactiveble/ble/ReactiveBleClient.kt

@@ -18,6 +18,7 @@ import com.polidea.rxandroidble2.scan.ScanSettings
 import com.signify.hue.flutterreactiveble.ble.extensions.writeCharWithResponse
 import com.signify.hue.flutterreactiveble.ble.extensions.writeCharWithoutResponse
 import com.signify.hue.flutterreactiveble.converters.extractManufacturerData
+import com.signify.hue.flutterreactiveble.model.ConnectionState
 import com.signify.hue.flutterreactiveble.model.ScanMode
 import com.signify.hue.flutterreactiveble.model.toScanSettings
 import com.signify.hue.flutterreactiveble.utils.Duration
@@ -117,6 +118,11 @@ open class ReactiveBleClient(private val context: Context) : BleClient {
         )
     }
 
+    override fun getConnectedDevices(): List<ConnectionUpdateSuccess> {
+        return activeConnections.keys.toList()
+            .map { ConnectionUpdateSuccess(it, ConnectionState.CONNECTED.code) }
+    }
+
     override fun disconnectDevice(deviceId: String) {
         activeConnections[deviceId]?.disconnectDevice(deviceId)
         activeConnections.remove(deviceId)