Commit 5f19e1a
Changed files (2)
app
lib
components
ble_input
app/lib/components/ble_input/ble_input_bloc.dart
@@ -12,98 +12,12 @@ import 'package:permission_handler/permission_handler.dart';
class BleInputBloc extends Bloc<BleInputEvent, BleInputState> {
/// Create logic component for bluetooth measurement input.
BleInputBloc(): super(BleInputClosed()) {
- on<OpenBleInput>((event, emit) async {
- emit(BleInputLoadInProgress());
- if (await Permission.bluetoothConnect.isDenied) {
- emit(BleInputPermissionFailure());
- unawaited(Permission.bluetoothConnect.request());
- return;
- }
- emit(BleInputLoadInProgress());
- if (await Permission.bluetoothScan.isDenied) {
- emit(BleInputPermissionFailure());
- unawaited(Permission.bluetoothScan.request());
- return;
- }
- emit(BleInputLoadInProgress());
-
- try {
- emit(BleInputLoadInProgress());
- await _ble.initialize();
- final deviceStream = _ble.scanForDevices(withServices: _requiredServices,);
- await emit.forEach(deviceStream, onData: (DiscoveredDevice device) {
- _availableDevices.add(device);
- return BleInputLoadSuccess(_availableDevices.toList());
- },);
- } catch (e) {
- emit(BleInputLoadFailure());
- }
- });
- on<BleInputDeviceSelected>((event, emit) async {
- emit(BleConnectInProgress());
- try {
- final connectionUpdateStream = _ble.connectToAdvertisingDevice(
- id: event.device.id,
- prescanDuration: const Duration(seconds: 5),
- withServices: _requiredServices,
- connectionTimeout: const Duration(minutes: 2),
- );
- await emit.forEach(connectionUpdateStream,
- onData: (ConnectionStateUpdate update) {
- if (update.failure != null) {
- return BleConnectFailed();
- } else if (update.connectionState == DeviceConnectionState.connected) {
- // characteristics IDs (https://www.bluetooth.com/wp-content/uploads/Files/Specification/HTML/Assigned_Numbers/out/en/Assigned_Numbers.pdf?v=1711151578821):
- // - Blood Pressure Measurement: 0x2A35 (https://bitbucket.org/bluetooth-SIG/public/src/main/gss/org.bluetooth.characteristic.blood_pressure_measurement.yaml)
- // - Blood Pressure Records: 0x2A36 (https://bitbucket.org/bluetooth-SIG/public/src/main/gss/org.bluetooth.characteristic.blood_pressure_record.yaml)
- //
- // A record represents a stored measurement, so in theory we should
- // search for a measurement.
- // Definition: https://www.bluetooth.com/specifications/bls-1-1-1/
- final characteristic = QualifiedCharacteristic(
- characteristicId: Uuid.parse('2A35'),
- serviceId: Uuid.parse('1810'),
- deviceId: event.device.id,
- );
- _ble.subscribeToCharacteristic(characteristic).listen((List<int> data) {
- add(BleBluetoothMeasurementReceived(data));
- });
- return BleConnectSuccess();
- } else if (update.connectionState == DeviceConnectionState.connecting) {
- return BleConnectInProgress();
- }
- return BleConnectFailed();
- },
- );
- } on TimeoutException {
- emit(BleConnectFailed());
- }
- });
-
- on<BleBluetoothMeasurementReceived>((event, emit) {
- emit(BleMeasurementInProgress());
- final decoded = BPMeasurementCharacteristic.parse(event.data);
- final record = BloodPressureRecord(
- decoded.time ?? DateTime.now(),
- // TODO: unit conversions
- decoded.sys.toInt(),
- decoded.dia.toInt(),
- decoded.pul?.toInt(),
- '',
- );
- emit(BleMeasurementSuccess(record,
- bodyMoved: decoded.bodyMoved,
- cuffLoose: decoded.cuffLoose,
- irregularPulse: decoded.irregularPulse,
- improperMeasurementPosition: decoded.improperMeasurementPosition,
- measurementStatus: decoded.measurementStatus,
- ),);
- });
-
- on<CloseBleInput>((event, emit) async {
- emit(BleInputClosed());
- // TODO: cleanup
- });
+ on<BleInputEvent>((event, emit) => switch (event) {
+ OpenBleInput() => _onOpenBleInput(event, emit),
+ CloseBleInput() => _onCloseBleInput(event, emit),
+ BleInputDeviceSelected() => _onBleInputDeviceSelected(event, emit),
+ BleBluetoothMeasurementReceived() => _onBleBluetoothMeasurementReceived(event, emit),
+ },);
// TODO: show capabilities during testing:
// _ble.getDiscoveredServices()
@@ -121,8 +35,113 @@ class BleInputBloc extends Bloc<BleInputEvent, BleInputState> {
final Set<DiscoveredDevice> _availableDevices = {};
+ StreamSubscription<DiscoveredDevice>? _deviceStreamSubscribtion;
+
final _requiredServices = [
Uuid.parse('1810'),
];
+
+
+ void _onOpenBleInput(OpenBleInput event, Emitter<BleInputState> emit) async {
+ emit(BleInputLoadInProgress());
+ if (await Permission.bluetoothConnect.isDenied) {
+ emit(BleInputPermissionFailure());
+ unawaited(Permission.bluetoothConnect.request());
+ return;
+ }
+ emit(BleInputLoadInProgress());
+ if (await Permission.bluetoothScan.isDenied) {
+ emit(BleInputPermissionFailure());
+ unawaited(Permission.bluetoothScan.request());
+ return;
+ }
+ emit(BleInputLoadInProgress());
+
+ try {
+ emit(BleInputLoadInProgress());
+ await _ble.initialize();
+ final deviceStream = _ble.scanForDevices(withServices: _requiredServices,);
+ await _deviceStreamSubscribtion?.cancel();
+ _deviceStreamSubscribtion = deviceStream.listen((device) {
+ if (!_availableDevices.any((e) => e.name == device.name)) {
+ _availableDevices.add(device);
+ emit(BleInputLoadSuccess(_availableDevices.toList()));
+ }
+ });
+ } catch (e) {
+ emit(BleInputLoadFailure());
+ }
+ }
+
+ void _onCloseBleInput(CloseBleInput event, Emitter<BleInputState> emit) async {
+ await _deviceStreamSubscribtion?.cancel();
+ await _ble.deinitialize();
+ emit(BleInputClosed());
+ // TODO: cleanup
+ }
+
+ void _onBleInputDeviceSelected(BleInputDeviceSelected event, Emitter<BleInputState> emit) async {
+ await _deviceStreamSubscribtion?.cancel();
+ emit(BleConnectInProgress());
+ try {
+ // TODO: extract subscription
+ final connectionUpdateStream = _ble.connectToAdvertisingDevice(
+ id: event.device.id,
+ prescanDuration: const Duration(seconds: 5),
+ withServices: _requiredServices,
+ connectionTimeout: const Duration(minutes: 2),
+ );
+ await emit.forEach(connectionUpdateStream,
+ onData: (ConnectionStateUpdate update) {
+ if (update.failure != null) {
+ return BleConnectFailed();
+ } else if (update.connectionState == DeviceConnectionState.connected) {
+ // characteristics IDs (https://www.bluetooth.com/wp-content/uploads/Files/Specification/HTML/Assigned_Numbers/out/en/Assigned_Numbers.pdf?v=1711151578821):
+ // - Blood Pressure Measurement: 0x2A35 (https://bitbucket.org/bluetooth-SIG/public/src/main/gss/org.bluetooth.characteristic.blood_pressure_measurement.yaml)
+ // - Blood Pressure Records: 0x2A36 (https://bitbucket.org/bluetooth-SIG/public/src/main/gss/org.bluetooth.characteristic.blood_pressure_record.yaml)
+ //
+ // A record represents a stored measurement, so in theory we should
+ // search for a measurement.
+ // Definition: https://www.bluetooth.com/specifications/bls-1-1-1/
+ final characteristic = QualifiedCharacteristic(
+ characteristicId: Uuid.parse('2A35'),
+ serviceId: Uuid.parse('1810'),
+ deviceId: event.device.id,
+ );
+ _ble.subscribeToCharacteristic(characteristic).listen((List<int> data) {
+ add(BleBluetoothMeasurementReceived(data));
+ });
+ return BleConnectSuccess();
+ } else if (update.connectionState == DeviceConnectionState.connecting) {
+ return BleConnectInProgress();
+ }
+ return BleConnectFailed();
+ },
+ );
+ } on TimeoutException {
+ emit(BleConnectFailed());
+ }
+ }
+
+ void _onBleBluetoothMeasurementReceived(BleBluetoothMeasurementReceived event, Emitter<BleInputState> emit) async {
+ await _deviceStreamSubscribtion?.cancel();
+ emit(BleMeasurementInProgress());
+ final decoded = BPMeasurementCharacteristic.parse(event.data);
+ final record = BloodPressureRecord(
+ decoded.time ?? DateTime.now(),
+ // TODO: unit conversions
+ decoded.sys.toInt(),
+ decoded.dia.toInt(),
+ decoded.pul?.toInt(),
+ '',
+ );
+ emit(BleMeasurementSuccess(record,
+ bodyMoved: decoded.bodyMoved,
+ cuffLoose: decoded.cuffLoose,
+ irregularPulse: decoded.irregularPulse,
+ improperMeasurementPosition: decoded.improperMeasurementPosition,
+ measurementStatus: decoded.measurementStatus,
+ ),);
+ }
}
blood_pressure_app.iml
@@ -141,6 +141,12 @@
<excludeFolder url="file://$MODULE_DIR$/app/windows/flutter/ephemeral/.plugin_symlinks/url_launcher_windows/example/.dart_tool" />
<excludeFolder url="file://$MODULE_DIR$/app/windows/flutter/ephemeral/.plugin_symlinks/url_launcher_windows/example/.pub" />
<excludeFolder url="file://$MODULE_DIR$/app/windows/flutter/ephemeral/.plugin_symlinks/url_launcher_windows/example/build" />
+ <excludeFolder url="file://$MODULE_DIR$/app/windows/flutter/ephemeral/.plugin_symlinks/permission_handler_windows/.dart_tool" />
+ <excludeFolder url="file://$MODULE_DIR$/app/windows/flutter/ephemeral/.plugin_symlinks/permission_handler_windows/.pub" />
+ <excludeFolder url="file://$MODULE_DIR$/app/windows/flutter/ephemeral/.plugin_symlinks/permission_handler_windows/build" />
+ <excludeFolder url="file://$MODULE_DIR$/app/windows/flutter/ephemeral/.plugin_symlinks/permission_handler_windows/example/.dart_tool" />
+ <excludeFolder url="file://$MODULE_DIR$/app/windows/flutter/ephemeral/.plugin_symlinks/permission_handler_windows/example/.pub" />
+ <excludeFolder url="file://$MODULE_DIR$/app/windows/flutter/ephemeral/.plugin_symlinks/permission_handler_windows/example/build" />
</content>
<orderEntry type="sourceFolder" forTests="false" />
<orderEntry type="library" name="Dart SDK" level="project" />