diff options
author | 2023-09-14 14:01:24 -0400 | |
---|---|---|
committer | 2023-09-14 14:37:02 -0400 | |
commit | cbbb9f40e283d12f6c52ad28609516f390316f7a (patch) | |
tree | d8d2cd8f4641299dd35a3138c0e28f11443928d6 /lib/vehicle-signals/vss_provider.dart | |
parent | 5ce59ba69f1451ec18c565b7b18301856553f574 (diff) |
Rework to use KUKSA.val databroker gRPC API
Rework to move from the WebSocket API with the older KUKSA.val
server to the gRPC "VAL" API of the databroker.
Changes include:
- All VISS WebSocket API code has been removed, and the signal
providers replumbed to be driven by a new VssClient class with
a homescreen-specific child class to hold all the gRPC API
handling.
- The generated code for the VAL API and its dependencies has
been checked in under lib/generated, as there still does not
seem to be a good way to generate it during the Flutter build.
- The configuration file is now expected to be "homescreen.yaml"
instead of "homescreen_config.yaml". The authorization token
field name has been renamed to "authorization", and there are
new "use-tls" and "ca-certificate" configuration fields. TLS
is disabled by default for now, and the default CA certificate
is /etc/kuksa.val/CA.pem.
- Updated .gitignore to cover a couple of generated files that
weren't included.
Bug-AGL: SPEC-4762, SPEC-4903
Signed-off-by: Scott Murray <scott.murray@konsulko.com>
Change-Id: I1b95ed27a72435364d54ec846f2be88e3d8bb092
Diffstat (limited to 'lib/vehicle-signals/vss_provider.dart')
-rw-r--r-- | lib/vehicle-signals/vss_provider.dart | 75 |
1 files changed, 75 insertions, 0 deletions
diff --git a/lib/vehicle-signals/vss_provider.dart b/lib/vehicle-signals/vss_provider.dart new file mode 100644 index 0000000..e0fa1b8 --- /dev/null +++ b/lib/vehicle-signals/vss_provider.dart @@ -0,0 +1,75 @@ +// SPDX-License-Identifier: Apache-2.0 +import 'dart:io'; +import 'package:meta/meta.dart'; +import 'package:flutter/foundation.dart'; +import 'package:flutter_riverpod/flutter_riverpod.dart'; +import 'package:grpc/grpc.dart'; +import 'package:flutter_homescreen/generated/kuksa/val/v1/val.pbgrpc.dart'; +import 'package:flutter_homescreen/generated/kuksa/val/v1/types.pb.dart'; +import 'package:flutter_homescreen/config.dart'; +import 'package:flutter_homescreen/vehicle-signals/vss_client.dart'; +import 'package:flutter_homescreen/vehicle-signals/vss_path.dart'; +import 'package:flutter_homescreen/vehicle-signals/vss_signal_providers.dart'; + +class HomescreenVssClient extends VssClient { + @override + final List<String> signals = [ + VSSPath.vehicleMediaVolume, + VSSPath.vehicleInsideTemperature, + VSSPath.vehicleOutsideTemperature + ]; + + HomescreenVssClient({required super.config, required super.channel, required super.stub, required super.ref}); + + @override + void handleSignalUpdates(EntryUpdate update) { + switch (update.entry.path) { + case VSSPath.vehicleMediaVolume: + if (update.entry.value.hasUint32()) { + ref + .read(vehicleSignalMediaVolumeProvider.notifier) + .update(volume: update.entry.value.uint32); + } + break; + case VSSPath.vehicleInsideTemperature: + if (update.entry.value.hasFloat()) { + ref + .read(vehicleSignalInsideTempProvider.notifier) + .update(temp: update.entry.value.float); + } + break; + case VSSPath.vehicleOutsideTemperature: + if (update.entry.value.hasFloat()) { + ref + .read(vehicleSignalOutsideTempProvider.notifier) + .update(temp: update.entry.value.float); + } + break; + default: + print("ERROR: Unexpected path ${update.entry.path}"); + break; + } + } +} + +final vssClientProvider = Provider((ref) { + var config = ref.read(kuksaConfigProvider); + debugPrint("Using ${config.hostname}:${config.port}"); + ChannelCredentials creds; + if (config.use_tls && config.ca_certificate.isNotEmpty) { + print("Using TLS"); + if (config.tls_server_name.isNotEmpty) + creds = ChannelCredentials.secure(certificates: config.ca_certificate, authority: config.tls_server_name); + else + creds = ChannelCredentials.secure(certificates: config.ca_certificate); + } else { + creds = ChannelCredentials.insecure(); + } + final channel = ClientChannel(config.hostname, + port: config.port, + options: ChannelOptions(credentials: creds)); + + final stub = VALClient(channel); + + return HomescreenVssClient(config: config, channel: channel, stub: stub, ref: ref); +}); |