feat: zoom the day heart-rate chart and export minute-by-minute HR (closes #546)

lib/data/csv_export.dart

@@ -16,12 +16,14 @@
 
 import 'dart:convert';
 import 'dart:io';
+import 'dart:isolate';
 
 import 'package:path/path.dart' as p;
 import 'package:path_provider/path_provider.dart';
 
 import '../ui2/activity/catalogue.dart' show exerciseByKey;
 import 'db.dart';
+import 'series_codec.dart';
 
 /// One exportable table: a filename stem, a header, and the query behind it.
 class CsvExportSet {
@@ -405,14 +407,7 @@ Future<CsvExportResult> exportCsvFiles(
   DateTime? now,
 }) async {
   final db = await LocalDb.instance;
-  final root = await getTemporaryDirectory();
-  final parent = Directory(p.join(root.path, _csvDirName));
-  await parent.create(recursive: true);
-
-  final stamp = (now ?? DateTime.now()).millisecondsSinceEpoch;
-  final dir = Directory(p.join(parent.path, '$stamp'));
-  await dir.create(recursive: true);
-  await _pruneOldRuns(parent, keep: _csvRunsKept);
+  final (dir, stamp) = await _newRunDir(now);
   final paths = <String>[];
   final failed = <String>[];
 
@@ -446,6 +441,92 @@ Future<CsvExportResult> exportCsvFiles(
   return CsvExportResult(paths: paths, failed: failed);
 }
 
+Future<(Directory, int)> _newRunDir(DateTime? now) async {
+  final root = await getTemporaryDirectory();
+  final parent = Directory(p.join(root.path, _csvDirName));
+  await parent.create(recursive: true);
+  final stamp = (now ?? DateTime.now()).millisecondsSinceEpoch;
+  final dir = Directory(p.join(parent.path, '$stamp'));
+  await dir.create(recursive: true);
+  await _pruneOldRuns(parent, keep: _csvRunsKept);
+  return (dir, stamp);
+}
+
+const kHeartRateCsvColumns = ['timestamp', 'local_time', 'bpm', 'source'];
+
+/// One CSV row per minute of a day's stored heart-rate curve.
+///
+/// The curve is the per-minute MEAN of the band's 1 Hz readings, written when
+/// the day is derived and kept for as long as the day is — unlike the 1 Hz
+/// rows themselves, which are pruned a few days behind the newest sync. So
+/// this is every minute the app still knows, at the resolution it still has.
+/// [source] is the day's provenance stamp, empty when unknown (never guessed).
+List<Map<String, Object?>> heartRateMinuteRows(
+    List<Object?> curve, String? source) {
+  String two(int v) => v.toString().padLeft(2, '0');
+  return [
+    for (final e in curve)
+      if (e is Map && e['t'] is num && e['v'] is num && (e['v'] as num) > 0)
+        () {
+          final t = (e['t'] as num).toInt();
+          final d = DateTime.fromMillisecondsSinceEpoch(t * 1000);
+          return <String, Object?>{
+            'timestamp': t,
+            'local_time': '${d.year}-${two(d.month)}-${two(d.day)} '
+                '${two(d.hour)}:${two(d.minute)}',
+            'bpm': e['v'],
+            'source': source,
+          };
+        }(),
+  ];
+}
+
+/// Write minute-by-minute heart rate for derived days [from]..[to]
+/// (inclusive, `yyyy-MM-dd`) to one CSV. Null when there was nothing in the
+/// range — no header-only file, same rule as [exportCsvFiles].
+Future<String?> exportHeartRateCsv(String from, String to,
+    {DateTime? now}) async {
+  final db = await LocalDb.instance;
+  final days = [
+    for (final d in await LocalDb.availableDayIds())
+      if (d.compareTo(from) >= 0 && d.compareTo(to) <= 0) d,
+  ]..sort();
+  // Provenance is keyed by the version that wrote it: a day's stamp counts
+  // only against the day_result of that same version, so a re-derive landing
+  // between these reads leaves the source empty (unknown), never another
+  // version's.
+  final source = {
+    for (final r in await db.rawQuery(
+        'SELECT date, algo_version, source FROM metric_series_version '
+        'WHERE date >= ? AND date <= ?',
+        [from, to]))
+      (r['date'] as String, (r['algo_version'] as num?)?.toInt()):
+          r['source'] as String?,
+  };
+  final rows = <Map<String, Object?>>[];
+  for (final day in days) {
+    final res = await LocalDb.dayResult(day);
+    final b = SeriesCodec.decodePayloadJson(res?['payload_json']);
+    final curve = (b?['series'] as Map?)?['hr_curve'];
+    final v = (res?['algo_version'] as num?)?.toInt();
+    if (curve is List) rows.addAll(heartRateMinuteRows(curve, source[(day, v)]));
+  }
+  if (rows.isEmpty) return null;
+  // A long range is hundreds of thousands of rows: render off the UI isolate.
+  final csv =
+      await Isolate.run(() => renderCsv(kHeartRateCsvColumns, rows));
+  final (dir, stamp) = await _newRunDir(now);
+  final file =
+      File(p.join(dir.path, 'openstrap_heart_rate_${from}_${to}_$stamp.csv'));
+  await file.writeAsBytes([
+    0xEF,
+    0xBB,
+    0xBF,
+    ...utf8.encode(csv),
+  ]);
+  return file.path;
+}
+
 /// Delete all but the [keep] newest run directories under [parent].
 ///
 /// Run directories are named by millisecond timestamp, so a lexicographic sort

lib/data/local_repository_impl.dart

@@ -1784,6 +1784,10 @@ class LocalRepositoryImpl extends LocalRepository {
       'resp': respLine,
       'skin_temp': tempLine,
       'activity': b['activity_curve'] ?? const [],
+      // Who owned each stretch of the merged HR curve (only on a day more
+      // than one device measured) — the zoomed chart's per-second read keeps
+      // the same device per second the stored curve did.
+      'hr_owner': (_sub(b, 'series')?['coverage'] as Map?)?['hr1Hz'],
       // The DISPLAYED day (bundle date) — when a partial "today" fell back to
       // the latest complete day this differs from the requested date, and the
       // screen must window/axis by THIS date, not "now".

lib/l10n/app_en.arb

@@ -14526,5 +14526,19 @@
         "type": "int"
       }
     }
-  }
+  },
+  "dayTimelineZoomNoHr": "No heart rate in this stretch",
+  "@dayTimelineZoomNoHr": {"description": "Shown in place of the zoomed day chart when the chosen window has no heart rate."},
+  "dayTimelineZoomPerMinute": "1-minute averages. Drag the handles to zoom; two hours or less shows every second while it is still kept.",
+  "@dayTimelineZoomPerMinute": {"description": "Footnote under the day heart-rate chart at per-minute resolution."},
+  "dayTimelineZoomPerMinuteOnly": "1-minute averages. Second-by-second readings are no longer kept for this stretch.",
+  "@dayTimelineZoomPerMinuteOnly": {"description": "Footnote when zoomed in but the per-second rows have been pruned."},
+  "dayTimelineZoomPerSecond": "Every second the band recorded. Second-by-second readings are kept for recent days only.",
+  "@dayTimelineZoomPerSecond": {"description": "Footnote when the zoomed day chart shows per-second readings."},
+  "dataExportHeartRate": "Export heart rate, minute by minute",
+  "@dataExportHeartRate": {"description": "Data screen row: export per-minute heart rate as CSV."},
+  "dataExportHeartRateSub": "One CSV for the days you pick: a 1-minute average for every minute the band recorded. Second-by-second readings are kept for recent days only and are in the database export",
+  "@dataExportHeartRateSub": {"description": "Subtitle for the per-minute heart rate CSV export row."},
+  "dataHeartRateRangeHelp": "Heart rate is kept from {first} to {last}",
+  "@dataHeartRateRangeHelp": {"description": "Date range picker heading for the heart rate export, naming the available range.", "placeholders": {"first": {"type": "String"}, "last": {"type": "String"}}}
 }

lib/l10n/app_ru.arb

@@ -6834,5 +6834,13 @@
   "devicesOuraCheckpointUnconfirmed": "Не удалось завершить синхронизацию. Попробуйте синхронизировать ещё раз.",
   "investigateRmssdNightly": "RMSSD, ночной (среднее по 5-минутным окнам)",
   "investigateRmssdStored": "RMSSD, ночной (прежняя оценка)",
-  "devicesOuraWriteRefused": "Не удалось отправить команду кольцу. Попробуйте синхронизировать ещё раз."
+  "devicesOuraWriteRefused": "Не удалось отправить команду кольцу. Попробуйте синхронизировать ещё раз.",
+  "dayTimelineZoomNoHr": "На этом отрезке нет данных о пульсе",
+  "dayTimelineZoomPerMinute": "Средние за минуту. Потяните ползунки, чтобы приблизить; при окне до двух часов показывается каждая секунда, пока она хранится.",
+  "dayTimelineZoomPerMinuteOnly": "Средние за минуту. Посекундные данные для этого отрезка уже не хранятся.",
+  "dayTimelineZoomPerSecond": "Каждая секунда, записанная браслетом. Посекундные данные хранятся только за последние дни.",
+  "dataExportHeartRate": "Экспортировать пульс по минутам",
+  "dataExportHeartRateSub": "Один CSV за выбранные дни: средний пульс за каждую минуту, записанную браслетом. Посекундные данные хранятся только за последние дни и входят в экспорт базы данных",
+  "dataHeartRateRangeHelp": "Пульс хранится с {first} по {last}",
+  "@dataHeartRateRangeHelp": {"placeholders": {"first": {"type": "String"}, "last": {"type": "String"}}}
 }

lib/ui2/profile/data.dart

@@ -24,6 +24,7 @@ import 'package:share_plus/share_plus.dart';
 
 import '../../data/auto_backup.dart';
 import '../../data/csv_export.dart';
+import '../../data/day_label.dart' show dayLabelOf;
 import '../../data/db.dart';
 import '../../import/backup_crypto.dart';
 import '../../l10n/app_localizations.dart';
@@ -122,6 +123,44 @@ class _DataScreenState extends State<DataScreen> {
     );
   }
 
+  /// Minute-by-minute heart rate for a chosen range. The picker is bounded to
+  /// the derived days that exist, and its heading says which those are, so
+  /// "what range is there" is answered before anything is chosen.
+  Future<_Note> _exportHeartRate() async {
+    final days = await LocalDb.availableDayIds();
+    if (!mounted) return ('', false);
+    final l = AppLocalizations.of(context);
+    if (days.isEmpty) {
+      return (l?.dataNothingToExportYet ?? 'Nothing to export yet.', false);
+    }
+    DateTime parse(String d) => DateTime.parse(d);
+    final first = parse(days.last), last = parse(days.first);
+    final range = await showDateRangePicker(
+      context: context,
+      firstDate: first,
+      lastDate: last,
+      initialDateRange: DateTimeRange(
+        start: () {
+          final week = DateTime(last.year, last.month, last.day - 6);
+          return week.isBefore(first) ? first : week;
+        }(),
+        end: last,
+      ),
+      helpText: l?.dataHeartRateRangeHelp(days.last, days.first) ??
+          'Heart rate is kept from ${days.last} to ${days.first}',
+    );
+    if (range == null || !mounted) return ('', false);
+    final origin = shareOrigin(context);
+    final path = await exportHeartRateCsv(
+        dayLabelOf(range.start), dayLabelOf(range.end));
+    if (path == null) {
+      return (l?.dataNothingToExportYet ?? 'Nothing to export yet.', false);
+    }
+    await Share.shareXFiles([XFile(path)],
+        subject: 'OpenStrap heart rate', sharePositionOrigin: origin);
+    return (l?.dataFilesShared(1) ?? '1 file shared.', false);
+  }
+
   Future<_Note> _exportDb() async {
     final l = AppLocalizations.of(context);
     final origin = shareOrigin(context);
@@ -296,6 +335,14 @@ class _DataScreenState extends State<DataScreen> {
                               'typed in. Each day carries where it came from and '
                               'which algorithm version scored it',
                       onTap: _busy ? null : () => _run(_exportCsv)),
+                  SetRow(LucideIcons.heartPulse, C.red,
+                      l?.dataExportHeartRate ?? 'Export heart rate, minute by minute',
+                      sub: l?.dataExportHeartRateSub ??
+                          'One CSV for the days you pick: a 1-minute average '
+                              'for every minute the band recorded. Second-by-'
+                              'second readings are kept for recent days only '
+                              'and are in the database export',
+                      onTap: _busy ? null : () => _run(_exportHeartRate)),
                   SetRow(LucideIcons.database, C.blue,
                       l?.dataExportDatabase ?? 'Export the database',
                       sub: l?.dataExportDatabaseSub ??