30 lines
1.0 KiB
Dart
30 lines
1.0 KiB
Dart
import 'package:flutter_riverpod/flutter_riverpod.dart';
|
|
|
|
import '../bluetooth/bt_poller.dart';
|
|
import '../protocol/kpro_parser.dart';
|
|
import '../protocol/s300_parser.dart';
|
|
import '../protocol/sensor_state.dart';
|
|
import 'bt_provider.dart';
|
|
import 'settings_provider.dart';
|
|
|
|
/// Emits a parsed [SensorState] for every valid frame received from the ECU.
|
|
/// Automatically picks S300 or KPro parser based on [settingsProvider].
|
|
final sensorStateProvider = StreamProvider<SensorState>((ref) {
|
|
final ecuType = ref.watch(settingsProvider).ecuType;
|
|
final btNotifier = ref.watch(btProvider.notifier);
|
|
|
|
return btNotifier.frameStream.map((frame) {
|
|
if (ecuType == EcuType.s300) {
|
|
return parseS300(frame, validateChecksum: false);
|
|
}
|
|
return parseKPro(frame);
|
|
});
|
|
});
|
|
|
|
/// Last successfully parsed sensor state (never null after first frame).
|
|
/// Falls back to SensorState.zero() before any data arrives.
|
|
final latestSensorProvider = Provider<SensorState>((ref) {
|
|
return ref.watch(sensorStateProvider).whenData((s) => s).value ??
|
|
SensorState.zero();
|
|
});
|