feat: added csv playback for barometer instrument. (#2898)

Co-authored-by: Marc Nause <[email protected]>

Author: Yugesh-Kumar-S

lib/providers/barometer_state_provider.dart

@@ -34,7 +34,15 @@ class BarometerStateProvider extends ChangeNotifier {
   bool _sensorAvailable = false;
   bool _isRecording = false;
   List<List<dynamic>> _recordedData = [];
+  bool _isPlayingBack = false;
+  List<List<dynamic>>? _playbackData;
+  int _playbackIndex = 0;
+  Timer? _playbackTimer;
+  bool _isPlaybackPaused = false;
+
   bool get isRecording => _isRecording;
+  bool get isPlayingBack => _isPlayingBack;
+  bool get isPlaybackPaused => _isPlaybackPaused;
 
   StreamSubscription? _barometerSubscription;
 
@@ -46,6 +54,7 @@ class BarometerStateProvider extends ChangeNotifier {
   String _currentSensorType = 'In-built Sensor';
 
   Function(String)? onSensorError;
+  Function? onPlaybackEnd;
 
   BarometerStateProvider(this._configProvider) {
     _configProvider.addListener(_onConfigChanged);
@@ -232,6 +241,118 @@ class BarometerStateProvider extends ChangeNotifier {
     logger.e("${appLocalizations.barometerSensorError} $error");
   }
 
+  void startPlayback(List<List<dynamic>> data) {
+    if (data.length <= 1) return;
+
+    _isPlayingBack = true;
+    _isPlaybackPaused = false;
+    _playbackData = data;
+    _playbackIndex = 1;
+
+    _timeTimer?.cancel();
+    _dataTimer?.cancel();
+
+    _pressureData.clear();
+    pressureChartData.clear();
+    _timeData.clear();
+    _startTime = DateTime.now().millisecondsSinceEpoch / 1000.0;
+    _currentTime = 0;
+    _pressureSum = 0;
+    _dataCount = 0;
+
+    _startPlaybackTimer();
+    notifyListeners();
+  }
+
+  void _startPlaybackTimer() {
+    if (_playbackIndex >= _playbackData!.length) {
+      stopPlayback();
+      return;
+    }
+
+    final currentRow = _playbackData![_playbackIndex];
+    if (currentRow.length > 2) {
+      _currentPressure = double.tryParse(currentRow[2].toString()) ?? 0.0;
+      if (currentRow.length > 3) {
+        _currentAltitude = double.tryParse(currentRow[3].toString());
+      }
+      _currentTime = (_playbackIndex - 1).toDouble();
+      _updateData();
+      _playbackIndex++;
+      notifyListeners();
+    } else {
+      logger.e(
+          'Skipping playback row at index $_playbackIndex due to insufficient columns (found ${currentRow.length}, expected at least 3');
+      _playbackIndex++;
+      notifyListeners();
+    }
+
+    Duration interval = const Duration(seconds: 1);
+
+    if (_playbackIndex < _playbackData!.length && _playbackIndex > 1) {
+      try {
+        final currentTimestamp =
+            int.tryParse(_playbackData![_playbackIndex - 1][0].toString());
+        final nextTimestamp =
+            int.tryParse(_playbackData![_playbackIndex][0].toString());
+
+        if (currentTimestamp != null && nextTimestamp != null) {
+          final timeDiff = nextTimestamp - currentTimestamp;
+          interval = Duration(milliseconds: timeDiff);
+          if (interval.inMilliseconds < 100) {
+            interval = const Duration(milliseconds: 100);
+          } else if (interval.inMilliseconds > 10000) {
+            interval = const Duration(seconds: 10);
+          }
+        }
+      } catch (e) {
+        interval = const Duration(seconds: 1);
+      }
+    }
+
+    _playbackTimer = Timer(interval, () {
+      if (_isPlayingBack && !_isPlaybackPaused) {
+        _startPlaybackTimer();
+      }
+    });
+  }
+
+  Future<void> stopPlayback() async {
+    _isPlayingBack = false;
+    _isPlaybackPaused = false;
+    _playbackTimer?.cancel();
+    _playbackData = null;
+    _playbackIndex = 0;
+
+    _pressureData.clear();
+    pressureChartData.clear();
+    _timeData.clear();
+    _pressureSum = 0;
+    _dataCount = 0;
+    _currentPressure = 0.0;
+    _currentTemperature = 0.0;
+    _currentAltitude = null;
+    _currentTime = 0;
+    notifyListeners();
+    onPlaybackEnd?.call();
+  }
+
+  void pausePlayback() {
+    if (_isPlayingBack) {
+      _isPlaybackPaused = true;
+      _playbackTimer?.cancel();
+      notifyListeners();
+    }
+  }
+
+  void resumePlayback() {
+    if (_isPlayingBack && _isPlaybackPaused) {
+      _isPlaybackPaused = false;
+      _startPlaybackTimer();
+      notifyListeners();
+    }
+  }
+
   void disposeSensors() {
     logger.d("Disposing sensors...");
     _barometerSubscription?.cancel();
@@ -240,19 +361,21 @@ class BarometerStateProvider extends ChangeNotifier {
     _timeTimer = null;
     _dataTimer?.cancel();
     _dataTimer = null;
+    _playbackTimer?.cancel();
     _bmp180Sensor = null;
     _sensorAvailable = false;
   }
 
   @override
   void dispose() {
     _configProvider.removeListener(_onConfigChanged);
+    _playbackTimer?.cancel();
     disposeSensors();
     super.dispose();
   }
 
   void _updateData() {
-    if (!_sensorAvailable) return;
+    if (!_sensorAvailable && !_isPlayingBack) return;
 
     final pressure = _currentPressure;
     final time = _currentTime;

lib/view/barometer_screen.dart

@@ -24,9 +24,12 @@ import 'dart:async';
 
 class BarometerScreen extends StatefulWidget {
   final dynamic isExperiment;
+  final List<List<dynamic>>? playbackData;
+
   const BarometerScreen({
     super.key,
     this.isExperiment = false,
+    this.playbackData,
   });
   @override
   State<StatefulWidget> createState() => _BarometerScreenState();
@@ -286,12 +289,28 @@ class _BarometerScreenState extends State<BarometerScreen> {
           create: (context) {
             final configProvider =
                 Provider.of<BarometerConfigProvider>(context, listen: false);
-            _provider = BarometerStateProvider(configProvider)
-              ..initializeSensors(
-                onError: _showSensorErrorSnackbar,
-                i2c: _i2c,
-                scienceLab: _scienceLab,
-              );
+            _provider = BarometerStateProvider(configProvider);
+
+            _provider.onPlaybackEnd = () {
+              if (mounted && Navigator.canPop(context)) {
+                Navigator.pop(context);
+              }
+            };
+
+            WidgetsBinding.instance.addPostFrameCallback((_) {
+              if (mounted) {
+                if (widget.playbackData != null) {
+                  _provider.startPlayback(widget.playbackData!);
+                } else {
+                  _provider.initializeSensors(
+                    onError: _showSensorErrorSnackbar,
+                    i2c: _i2c,
+                    scienceLab: _scienceLab,
+                  );
+                }
+              }
+            });
+
             return _provider;
           },
           update: (context, configProvider, previous) {
@@ -303,11 +322,26 @@ class _BarometerScreenState extends State<BarometerScreen> {
         Consumer<BarometerStateProvider>(
           builder: (context, provider, child) {
             return CommonScaffold(
-              title: appLocalizations.barometerTitle,
+              title: provider.isPlayingBack
+                  ? '${appLocalizations.barometerTitle} - ${appLocalizations.playback}'
+                  : appLocalizations.barometerTitle,
               onGuidePressed: _showInstrumentGuide,
-              onOptionsPressed: _showOptionsMenu,
-              onRecordPressed: _toggleRecording,
+              onOptionsPressed:
+                  provider.isPlayingBack ? null : _showOptionsMenu,
+              onRecordPressed: provider.isPlayingBack ? null : _toggleRecording,
               isRecording: provider.isRecording,
+              isPlayingBack: provider.isPlayingBack,
+              isPlaybackPaused: provider.isPlaybackPaused,
+              onPlaybackPauseResume: provider.isPlayingBack
+                  ? (provider.isPlaybackPaused
+                      ? _provider.resumePlayback
+                      : _provider.pausePlayback)
+                  : null,
+              onPlaybackStop: provider.isPlayingBack
+                  ? () async {
+                      await _provider.stopPlayback();
+                    }
+                  : null,
               body: SafeArea(
                   child: LayoutBuilder(builder: (context, constraints) {
                 final isLargeScreen = constraints.maxWidth > 900;

lib/view/logged_data_screen.dart

@@ -3,6 +3,7 @@ import 'package:flutter/material.dart';
 import 'package:intl/intl.dart';
 import 'package:pslab/others/csv_service.dart';
 import 'package:pslab/theme/colors.dart';
+import 'package:pslab/view/barometer_screen.dart';
 import 'package:pslab/view/gyroscope_screen.dart';
 import 'package:pslab/view/logged_data_chart_screen.dart';
 import 'package:pslab/view/luxmeter_screen.dart';
@@ -178,6 +179,14 @@ class _LoggedDataScreenState extends State<LoggedDataScreen> {
             ),
           );
           break;
+        case 'barometer':
+          Navigator.push(
+            context,
+            MaterialPageRoute(
+              builder: (context) => BarometerScreen(playbackData: data),
+            ),
+          );
+          break;
         case 'gyroscope':
           Navigator.push(
             context,
@@ -323,6 +332,7 @@ class _LoggedDataScreenState extends State<LoggedDataScreen> {
                             mainAxisSize: MainAxisSize.min,
                             children: [
                               if (widget.instrumentName == "soundmeter" ||
+                                  widget.instrumentName == "barometer" ||
                                   widget.instrumentName == "gyroscope" ||
                                   widget.instrumentName == "luxmeter")
                                 IconButton(