Configurable units fixes

Notable changes:
- Add pressure unit to the units model.
- Add tire pressure unit configuration page under settings.
- Rework the VSS client, provider, and the associated handling in
  the vehicle and audio state providers to make the signal updating
  code reusable for processing the result of VAL API get commands.
- Add logic to get the initial values of the used VSS signals so
  the initial application state looks sane in demo scenarios.
- Add VSS signal support to the units provider so that changes will
  be pushed out for e.g. IC use.
- Fix pressure unit use in various widgets.
- Fix up range calculation for dashboard to correctly account for
  units and the incoming VSS value being in meters.
- Fix some unit naming inconsistencies around capitalization.

Bug-AGL: SPEC-5031, SPEC-5032

Change-Id: I33ac735dfbe35283bd30c92aa157cbdb7af1837c
Signed-off-by: Scott Murray <scott.murray@konsulko.com>

1 files changed, 39 insertions, 8 deletions

diff --git a/lib/data/data_providers/val_client.dart b/lib/data/data_providers/val_client.dart
index db962ee..5e7339c 100644
--- a/lib/data/data_providers/val_client.dart
+++ b/lib/data/data_providers/val_client.dart
@@ -29,15 +29,21 @@ class ValClient {
   }
 
   void run() async {
-    List<String> fewSignals = VSSPath().getSignalsList();
-    var request = SubscribeRequest();
+    List<String> signals = VSSPath().getSignalsList();
     Map<String, String> metadata = {};
     if (config.authorization.isNotEmpty) {
       metadata = {'authorization': "Bearer ${config.authorization}"};
     }
-    for (int i = 0; i < fewSignals.length; i++) {
+
+    // Initialize signal states
+    for (int i = 0; i < signals.length; i++) {
+      get(signals[i]);
+    }
+
+    var request = SubscribeRequest();
+    for (int i = 0; i < signals.length; i++) {
       var entry = SubscribeEntry();
-      entry.path = fewSignals[i];
+      entry.path = signals[i];
       entry.fields.add(Field.FIELD_PATH);
       entry.fields.add(Field.FIELD_VALUE);
       request.entries.add(entry);
@@ -48,7 +54,7 @@ class ValClient {
       responseStream.listen((value) async {
         for (var update in value.updates) {
           if (!(update.hasEntry() && update.entry.hasPath())) continue;
-          handleSignalsUpdate(update);
+          handleSignalUpdate(update.entry);
         }
       }, onError: (stacktrace, errorDescriptor) {
         debugPrint(stacktrace.toString());
@@ -58,11 +64,14 @@ class ValClient {
     }
   }
 
-  bool handleSignalsUpdate(EntryUpdate update) {
-    if (ref.read(vehicleProvider.notifier).handleSignalsUpdate(update)) {
+  bool handleSignalUpdate(DataEntry entry) {
+    if (ref.read(vehicleProvider.notifier).handleSignalUpdate(entry)) {
+      return true;
+    }
+    if (ref.read(audioStateProvider.notifier).handleSignalUpdate(entry)) {
       return true;
     }
-    return ref.read(audioStateProvider.notifier).handleSignalsUpdate(update);
+    return ref.read(unitStateProvider.notifier).handleSignalUpdate(entry);
   }
 
   void setUint32(String path, int value, [bool actuator = true]) async {
@@ -114,4 +123,26 @@ class ValClient {
     }
     await stub.set(request, options: CallOptions(metadata: metadata));
   }
+
+  void get(String path) async {
+    var entry = EntryRequest()..path = path;
+    entry.fields.add(Field.FIELD_VALUE);
+    var request = GetRequest();
+    request.entries.add(entry);
+    Map<String, String> metadata = {};
+    if (config.authorization.isNotEmpty) {
+      metadata = {'authorization': "Bearer ${config.authorization}"};
+    }
+    debugPrint("Getting {path} value");
+    var response =
+        await stub.get(request, options: CallOptions(metadata: metadata));
+    if (response.hasError()) {
+      debugPrint("Get request had error {response.error().reason}");
+      return;
+    }
+    for (var entry in response.entries) {
+      if (!entry.hasPath()) continue;
+      handleSignalUpdate(entry);
+    }
+  }
 }