tajniak81andClaude Opus 5.5
60c2fd7f64
Plan P5: a value bubble on the pitch slider while dragging, press-and-drag on the video as a speed joystick (re-sent at 10 Hz, zero on release), and a gimbal settings sheet: mode, 30° extension, yaw follow, recenter / face down / yaw recenter, roll fine-tune, auto calibration and advanced speed/smoothness rows gated by the gimbal's capability ranges. GimbalBridge reports mode, trim, calibration and stop/overload state in the gimbal telemetry group, and getter-only settings in a new gimbalSettings slow group. The reported-plus-pending overlay moves out of CameraState into a SettingsOverlay mixin shared by camera and gimbal. Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
90 lines
3.5 KiB
Dart
90 lines
3.5 KiB
Dart
import '../flight_model.dart';
|
|
import 'state/parse.dart';
|
|
|
|
/// Routes the bridge's telemetry-bearing events into [FlightModel]'s sub-models
|
|
/// (plan P1). Kept out of the widget tree so it can be unit-tested against
|
|
/// recorded events.
|
|
///
|
|
/// A `telemetry` event is the native [TelemetryHub]'s full snapshot: the flight
|
|
/// controller's flat keys plus one nested group per subsystem (`battery`,
|
|
/// `links`, `rc`, `storage`, `ssd`, `thermal`, `cameraSettings`, `gimbal`,
|
|
/// `gimbalSettings`, `vision`). It arrives at
|
|
/// up to 10 Hz with the slow groups repeated unchanged between their 2 Hz
|
|
/// refreshes, so each group is compared with the last one seen and its
|
|
/// sub-model only notified when it actually moved. A group missing from the
|
|
/// snapshot was never reported by this aircraft and leaves its sub-model empty.
|
|
class TelemetryReducer {
|
|
TelemetryReducer(this.model);
|
|
|
|
final FlightModel model;
|
|
|
|
final Map<String, Object?> _lastGroups = <String, Object?>{};
|
|
|
|
static const List<String> _groups = <String>['battery', 'links', 'rc', 'storage', 'ssd', 'thermal', 'cameraSettings', 'gimbal', 'gimbalSettings', 'vision'];
|
|
|
|
/// Applies [event] if it is one of the telemetry types; returns whether it was.
|
|
bool apply(Map<String, dynamic> event) {
|
|
switch (event['type'] as String?) {
|
|
case 'telemetry':
|
|
// Stray packets trailing a disconnect would repopulate what was cleared.
|
|
if (model.connected) model.batch(() => _telemetry(event));
|
|
return true;
|
|
case 'camera':
|
|
if (model.connected) model.camera.applySystem(event);
|
|
return true;
|
|
case 'exposure':
|
|
if (model.connected) model.camera.applyExposure(event);
|
|
return true;
|
|
case 'histogram':
|
|
if (model.connected) model.camera.applyHistogram(event);
|
|
return true;
|
|
case 'diagnostics':
|
|
if (model.connected) model.alerts.apply(asMapList(event['items']));
|
|
return true;
|
|
case 'mission':
|
|
model.mission.apply(event);
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
/// Forgets the last-seen groups, so the next aircraft's first tick applies in full.
|
|
void reset() => _lastGroups.clear();
|
|
|
|
void _telemetry(Map<String, dynamic> t) {
|
|
// Flight-controller keys change every tick; absent until the FC first reports.
|
|
if (t.containsKey('satelliteCount')) model.aircraft.apply(t);
|
|
|
|
final Set<String> changed = <String>{};
|
|
for (final String g in _groups) {
|
|
final Object? v = t[g];
|
|
if (_lastGroups.containsKey(g) && deepEquals(_lastGroups[g], v)) continue;
|
|
_lastGroups[g] = v;
|
|
changed.add(g);
|
|
}
|
|
if (changed.isEmpty) return;
|
|
|
|
if (changed.contains('battery')) {
|
|
final Map<String, dynamic>? b = asMap(t['battery']);
|
|
b == null ? model.battery.clear() : model.battery.apply(b);
|
|
}
|
|
if (changed.contains('links') || changed.contains('rc')) {
|
|
model.links.apply(links: asMap(t['links']), rc: asMap(t['rc']));
|
|
}
|
|
if (const <String>['storage', 'ssd', 'thermal', 'cameraSettings'].any(changed.contains)) {
|
|
model.camera.applyTelemetry(
|
|
storage: asMap(t['storage']),
|
|
ssd: asMap(t['ssd']),
|
|
thermal: asMap(t['thermal']),
|
|
settings: asMap(t['cameraSettings']),
|
|
);
|
|
}
|
|
if (changed.contains('gimbal')) {
|
|
final Map<String, dynamic>? g = asMap(t['gimbal']);
|
|
g == null ? model.gimbal.clear() : model.gimbal.apply(g);
|
|
}
|
|
if (changed.contains('gimbalSettings')) model.gimbal.applySettings(asMap(t['gimbalSettings']));
|
|
if (changed.contains('vision')) model.vision.apply(asMap(t['vision']));
|
|
}
|
|
}
|