Validate signal

mobile/lib/src/application/eeg_data/data_cubit.dart

@@ -1,10 +1,10 @@
-import 'package:polydodo/src/domain/acquisition_device/i_acquisition_device_repository.dart';
-import 'package:polydodo/src/domain/eeg_data/i_eeg_data_repository.dart';
-
 import 'package:bloc/bloc.dart';
 import 'package:flutter_bloc/flutter_bloc.dart';
 
-part './data_states.dart';
+import 'package:polydodo/src/domain/acquisition_device/i_acquisition_device_repository.dart';
+import 'package:polydodo/src/domain/eeg_data/i_eeg_data_repository.dart';
+import 'package:polydodo/src/domain/eeg_data/signal_result.dart';
+import 'package:polydodo/src/application/eeg_data/data_states.dart';
 
 class DataCubit extends Cubit<DataState> {
   final IAcquisitionDeviceRepository _deviceRepository;
@@ -25,4 +25,28 @@ class DataCubit extends Cubit<DataState> {
     _deviceRepository.stopDataStream();
     _eegDataRepository.stopRecordingFromStream();
   }
+
+  Future<void> startSignalValidation() async {
+    _eegDataRepository.initialize();
+    _eegDataRepository.testSignal(
+        await _deviceRepository.startDataStream(), signalCallback);
+
+    emit(DataStateTestSignalInProgress(
+        SignalResult.untested, SignalResult.untested));
+  }
+
+  void signalCallback(
+      SignalResult fpzCzChannelResult, SignalResult pzOzChannelResult,
+      [Exception e]) {
+    if (e != null) {
+      emit(DataStateTestSignalFailure(e));
+    } else if (fpzCzChannelResult == SignalResult.good &&
+        pzOzChannelResult == SignalResult.good) {
+      _eegDataRepository.stopRecordingFromStream();
+      emit(DataStateTestSignalSuccess(fpzCzChannelResult, pzOzChannelResult));
+    } else {
+      emit(
+          DataStateTestSignalInProgress(fpzCzChannelResult, pzOzChannelResult));
+    }
+  }
 }

mobile/lib/src/application/eeg_data/data_states.dart

@@ -1,7 +1,27 @@
-part of './data_cubit.dart';
+import 'package:polydodo/src/domain/eeg_data/signal_result.dart';
 
 abstract class DataState {}
 
 class DataStateInitial extends DataState {}
 
 class DataStateRecording extends DataState {}
+
+class DataStateTestSignalInProgress extends DataState {
+  final SignalResult channelOneResult;
+  final SignalResult channelTwoResult;
+
+  DataStateTestSignalInProgress(this.channelOneResult, this.channelTwoResult);
+}
+
+class DataStateTestSignalSuccess extends DataState {
+  final SignalResult fpzCzChannelResult;
+  final SignalResult pzOzChannelResult;
+
+  DataStateTestSignalSuccess(this.fpzCzChannelResult, this.pzOzChannelResult);
+}
+
+class DataStateTestSignalFailure extends DataState {
+  final Exception cause;
+
+  DataStateTestSignalFailure(this.cause);
+}

mobile/lib/src/domain/eeg_data/i_eeg_data_repository.dart

@@ -1,8 +1,12 @@
+import 'package:polydodo/src/domain/eeg_data/signal_result.dart';
+
 abstract class IEEGDataRepository {
   void initialize();
   void createRecordingFromStream(Stream<List<int>> stream);
   void stopRecordingFromStream();
 
+  void testSignal(Stream<List<int>> stream,
+      Function(SignalResult, SignalResult, [Exception]) callback);
   // todo: implement export and import
   void importData();
   void exportData();

mobile/lib/src/domain/eeg_data/signal_result.dart

@@ -0,0 +1 @@
+enum SignalResult { railed, near_railed, good, untested, invalid }

mobile/lib/src/infrastructure/connection_repositories/eeg_data_repository.dart

@@ -1,11 +1,13 @@
 import 'dart:async';
 import 'dart:io';
+import 'dart:math';
 import 'dart:typed_data';
 
 import 'package:csv/csv.dart';
 import 'package:path_provider/path_provider.dart';
 import 'package:polydodo/src/domain/eeg_data/eeg_data.dart';
 import 'package:polydodo/src/domain/eeg_data/i_eeg_data_repository.dart';
+import 'package:polydodo/src/domain/eeg_data/signal_result.dart';
 import 'package:polydodo/src/domain/unique_id.dart';
 import 'package:polydodo/src/infrastructure/eeg_data_transformers/baseOpenBCITransformer.dart';
 import 'package:polydodo/src/infrastructure/eeg_data_transformers/cytonTransformer.dart';
@@ -16,19 +18,19 @@ import 'package:pedantic/pedantic.dart';
 import 'package:intl/intl.dart';
 
 class EEGDataRepository implements IEEGDataRepository {
-  EEGData _recordingData;
-  BaseOpenBCITransformer<List<int>, List<dynamic>> currentStreamTransformer;
-
   final GanglionTransformer<List<int>, List> _ganglionTransformer =
       GanglionTransformer<List<int>, List>.broadcast();
-
   final CytonTransformer<List<int>, List<dynamic>> _cytonTransformer =
       CytonTransformer<Uint8List, List>.broadcast();
 
+  BaseOpenBCITransformer<List<int>, List<dynamic>> currentStreamTransformer;
   BaseOpenBCITransformer<List<int>, List<dynamic>> _currentTransformer;
   StreamSubscription _currentTransformerStream;
-
   StreamingSharedPreferences _preferences;
+  EEGData _recordingData;
+  double _fpzCzChannelMax = 0;
+  double _pzOzChannelMax = 0;
+  int _dataCount = 0;
 
   @override
   void initialize() async {
@@ -58,6 +60,8 @@ class EEGDataRepository implements IEEGDataRepository {
     // todo: move save future to another file
     unawaited(_currentTransformerStream.cancel());
 
+    if (_recordingData == null) return;
+
     final directory = await getExternalStorageDirectory();
     final pathOfTheFileToWrite =
         directory.path + '/' + _recordingData.fileName + '.txt';
@@ -70,6 +74,48 @@ class EEGDataRepository implements IEEGDataRepository {
     await file.writeAsString(csv);
   }
 
+  @override
+  void testSignal(Stream<List<int>> stream,
+      Function(SignalResult, SignalResult, [Exception]) callback) {
+    _dataCount = 0;
+    _currentTransformer.reset();
+    _currentTransformerStream = stream
+        .asBroadcastStream()
+        .transform(_currentTransformer)
+        .listen((data) => _checkSignalData(data, callback));
+  }
+
+  void _checkSignalData(
+      List data, Function(SignalResult, SignalResult, [Exception]) callback) {
+    _dataCount++;
+
+    _fpzCzChannelMax = max(_fpzCzChannelMax, data[1].abs());
+    _pzOzChannelMax = max(_pzOzChannelMax, data[2].abs());
+
+    if (_dataCount == 1000) {
+      var signalOneResult = _getResult(_fpzCzChannelMax);
+      var signalTwoResult = _getResult(_pzOzChannelMax);
+
+      callback(signalOneResult, signalTwoResult);
+
+      _dataCount = 0;
+      _fpzCzChannelMax = 0;
+      _pzOzChannelMax = 0;
+    }
+  }
+
+  SignalResult _getResult(double maxValue) {
+    var result = SignalResult.good;
+
+    if (maxValue > MAX_SIGNAL_VALUE * THRESHOLD_RAILED_WARN) {
+      result = (maxValue > MAX_SIGNAL_VALUE * THRESHOLD_RAILED)
+          ? SignalResult.railed
+          : SignalResult.near_railed;
+    }
+
+    return result;
+  }
+
   // todo: implement export and import
   @override
   void importData() {}

mobile/lib/src/infrastructure/constants.dart

@@ -1,3 +1,8 @@
+const THRESHOLD_RAILED = 0.9;
+const THRESHOLD_RAILED_WARN = 0.75;
+
+const MAX_SIGNAL_VALUE = 185000;
+
 const START_STREAM_CHAR = 'b';
 const STOP_STREAM_CHAR = 's';
 

mobile/lib/src/presentation/navigation/routes/router.dart

@@ -2,9 +2,12 @@ import 'package:auto_route/auto_route.dart';
 import 'package:auto_route/auto_route_annotations.dart';
 import 'package:polydodo/src/presentation/pages/bluetooth_page/bluetoothSelector_page.dart';
 import 'package:polydodo/src/presentation/pages/dashboard/dashboard_page.dart';
+import 'package:polydodo/src/presentation/pages/record_sleep/record_sleep_guide_page.dart';
+import 'package:polydodo/src/presentation/pages/record_sleep/record_sleep_recording_page.dart';
+import 'package:polydodo/src/presentation/pages/record_sleep/record_sleep_validate_page.dart';
+
 import 'package:polydodo/src/presentation/pages/sleep_history_page/sleep_history_page.dart';
 import 'package:polydodo/src/presentation/pages/night_stats_page/night_stats_page.dart';
-import 'package:polydodo/src/presentation/pages/record_sleep/record_sleep_guide_page.dart';
 
 @MaterialAutoRouter(
     generateNavigationHelperExtension: true,
@@ -19,6 +22,9 @@ import 'package:polydodo/src/presentation/pages/record_sleep/record_sleep_guide_
       CustomRoute(
           page: RecordSleepValidatePage,
           transitionsBuilder: TransitionsBuilders.fadeIn),
+      CustomRoute(
+          page: RecordSleepRecordingPage,
+          transitionsBuilder: TransitionsBuilders.fadeIn),
       CustomRoute(
           page: BluetoothSelectorPage,
           transitionsBuilder: TransitionsBuilders.fadeIn),

mobile/lib/src/presentation/pages/record_sleep/record_sleep_guide_page.dart

@@ -1,14 +1,11 @@
 import 'package:auto_route/auto_route.dart';
 import 'package:flutter/material.dart';
 import 'package:flutter_bloc/flutter_bloc.dart';
-import 'package:polydodo/src/application/eeg_data/data_cubit.dart';
+import 'package:polydodo/src/application/blocs.dart';
 import 'package:polydodo/src/presentation/navigation/navdrawer_tabs.dart';
 import 'package:polydodo/src/presentation/navigation/navdrawer_widget.dart';
 import 'package:polydodo/src/presentation/navigation/routes/router.gr.dart';
 
-part 'record_sleep_recording_page.dart';
-part 'record_sleep_validate_page.dart';
-
 class RecordSleepGuidePage extends StatelessWidget {
   @override
   Widget build(BuildContext context) {
@@ -23,6 +20,8 @@ class RecordSleepGuidePage extends StatelessWidget {
       ),
       floatingActionButton: FloatingActionButton.extended(
         onPressed: () {
+          // todo: Place start validation at last page of guide or skip guide button
+          BlocProvider.of<DataCubit>(context).startSignalValidation();
           ExtendedNavigator.of(context).replace(Routes.recordSleepValidatePage);
         },
         icon: Icon(Icons.radio_button_checked),

mobile/lib/src/presentation/pages/record_sleep/record_sleep_recording_page.dart

@@ -1 +1,48 @@
-part of 'record_sleep_guide_page.dart';
+import 'package:flutter/material.dart';
+import 'package:flutter_bloc/flutter_bloc.dart';
+import 'package:polydodo/src/application/eeg_data/data_cubit.dart';
+import 'package:polydodo/src/application/eeg_data/data_states.dart';
+import 'package:polydodo/src/presentation/navigation/navdrawer_tabs.dart';
+import 'package:polydodo/src/presentation/navigation/navdrawer_widget.dart';
+
+class RecordSleepRecordingPage extends StatelessWidget {
+  @override
+  Widget build(BuildContext context) {
+    return Scaffold(
+      appBar: AppBar(title: Text('Record Sleep')),
+      drawer: NavDrawer(activeTab: NavdrawerTab.RecordSleep),
+      body: BlocConsumer<DataCubit, DataState>(
+        listener: (context, state) {
+          print(state.runtimeType);
+        },
+        builder: (context, state) {
+          if (state is DataStateTestSignalSuccess) {
+            return Center(
+              child: Column(
+                  mainAxisAlignment: MainAxisAlignment.center,
+                  children: <Widget>[
+                    RaisedButton(
+                      child: Text('Start'),
+                      onPressed: () =>
+                          BlocProvider.of<DataCubit>(context).startStreaming(),
+                    )
+                  ]),
+            );
+          } else {
+            return Center(
+              child: Column(
+                  mainAxisAlignment: MainAxisAlignment.center,
+                  children: <Widget>[
+                    RaisedButton(
+                      child: Text('Stop'),
+                      onPressed: () =>
+                          BlocProvider.of<DataCubit>(context).stopStreaming(),
+                    ),
+                  ]),
+            );
+          }
+        },
+      ),
+    );
+  }
+}