summaryrefslogtreecommitdiffstats
path: root/lib/vehicle-signals/vss_client.dart
diff options
context:
space:
mode:
authorJoel Winarske <joel.winarske@gmail.com>2024-09-05 15:42:22 -0700
committerJoel Winarske <joel.winarske@gmail.com>2024-09-05 16:04:30 -0700
commit15093ee4880d535c65faed929801c2d79d1a212c (patch)
treeea5ddf1abdea8d3d77d3537f5b06dd6cb3d91f28 /lib/vehicle-signals/vss_client.dart
parent4a6dd91a1e1c7821eae1668449885a8c04825071 (diff)
Flutter SDK 3.24.1HEADmaster
-update packages -format files -fix analyze issues Change-Id: I9eb84f1bca7623ce676695904f172aff127c8ced Signed-off-by: Joel Winarske <joel.winarske@gmail.com>
Diffstat (limited to 'lib/vehicle-signals/vss_client.dart')
-rw-r--r--lib/vehicle-signals/vss_client.dart44
1 files changed, 18 insertions, 26 deletions
diff --git a/lib/vehicle-signals/vss_client.dart b/lib/vehicle-signals/vss_client.dart
index e416d87..4a44a81 100644
--- a/lib/vehicle-signals/vss_client.dart
+++ b/lib/vehicle-signals/vss_client.dart
@@ -1,7 +1,4 @@
// 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_cluster_dashboard/generated/kuksa/val/v1/val.pbgrpc.dart';
@@ -17,14 +14,17 @@ abstract class VssClient {
// Extenders will likely override this
final List<String> signals = [];
- VssClient({required this.config, required this.channel, required this.stub, required this.ref});
+ VssClient(
+ {required this.config,
+ required this.channel,
+ required this.stub,
+ required this.ref});
// Abstract method extenders must implement
void handleSignalUpdates(EntryUpdate update);
void run() async {
- if (signals.isEmpty)
- return;
+ if (signals.isEmpty) return;
var request = SubscribeRequest();
for (var i = 0; i < signals.length; i++) {
@@ -38,13 +38,13 @@ abstract class VssClient {
try {
Map<String, String> metadata = {};
if (config.authorization.isNotEmpty) {
- metadata = {'authorization': "Bearer ${config.authorization}" };
+ metadata = {'authorization': "Bearer ${config.authorization}"};
}
- var responseStream = stub.subscribe(request, options: CallOptions(metadata: metadata));
+ var responseStream =
+ stub.subscribe(request, options: CallOptions(metadata: metadata));
await for (var response in responseStream) {
for (var update in response.updates) {
- if (!(update.hasEntry() && update.entry.hasPath()))
- continue;
+ if (!(update.hasEntry() && update.entry.hasPath())) continue;
handleSignalUpdates(update);
}
}
@@ -54,44 +54,37 @@ abstract class VssClient {
}
void setUint32(String path, int value, [bool actuator = true]) async {
- var dp = Datapoint()
- ..uint32 = value;
+ var dp = Datapoint()..uint32 = value;
set(path, dp, actuator);
}
void setInt32(String path, int value, [bool actuator = true]) async {
- var dp = Datapoint()
- ..int32 = value;
+ var dp = Datapoint()..int32 = value;
set(path, dp, actuator);
}
void setBool(String path, bool value, [bool actuator = true]) async {
- var dp = Datapoint()
- ..bool_12 = value;
+ var dp = Datapoint()..bool_12 = value;
set(path, dp, actuator);
}
void setString(String path, String value, [bool actuator = true]) async {
- var dp = Datapoint()
- ..string = value;
+ var dp = Datapoint()..string = value;
set(path, dp, actuator);
}
void setFloat(String path, double value, [bool actuator = true]) async {
- var dp = Datapoint()
- ..float = value;
+ var dp = Datapoint()..float = value;
set(path, dp, actuator);
}
void setDouble(String path, double value, [bool actuator = true]) async {
- var dp = Datapoint()
- ..double_18 = value;
+ var dp = Datapoint()..double_18 = value;
set(path, dp, actuator);
}
void set(String path, Datapoint dp, bool actuator) async {
- var entry = DataEntry()
- ..path = path;
+ var entry = DataEntry()..path = path;
var update = EntryUpdate();
if (actuator) {
entry.actuatorTarget = dp;
@@ -105,9 +98,8 @@ abstract class VssClient {
request.updates.add(update);
Map<String, String> metadata = {};
if (config.authorization.isNotEmpty) {
- metadata = {'authorization': "Bearer ${config.authorization}" };
+ metadata = {'authorization': "Bearer ${config.authorization}"};
}
await stub.set(request, options: CallOptions(metadata: metadata));
}
-
}