Add (optional) VISSv2 interface

- Add VISSv2 interface to databroker
- Gated by feature flag `viss` (not built by default)
- Supports "get", "set", "subscribe" & "unsubscribe"
- Supports authorization (same jwt scope format as other interfaces)

Not implemented:
- Filters
- TLS

kuksa_databroker/databroker-cli/src/main.rs

@@ -341,7 +341,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
                                     continue;
                                 }
 
-                                if metadata.entry_type != proto::v1::EntryType::Actuator.into() {
+                                if metadata.entry_type != proto::v1::EntryType::Actuator as i32 {
                                     print_error(
                                         cmd,
                                         format!("{} is not an actuator.", metadata.name),

kuksa_databroker/databroker/Cargo.toml

@@ -55,11 +55,17 @@ jemallocator = { version = "0.5.0", optional = true }
 lazy_static = "1.4.0"
 thiserror = "1.0.47"
 
+# VISS
+axum = { version = "0.6.20", optional = true, features = ["ws"] }
+futures = { version = "0.3.28", optional = true }
+chrono = { version = "0.4.26", optional = true, features = ["std", "time"] }
+uuid = { version = "1.4.1", optional = true, features = ["v4"] }
+
 [features]
 default = ["tls"]
 tls = ["tonic/tls"]
-# to enable jemalloc use --features jemalloc
 jemalloc = ["dep:jemallocator"]
+viss = ["dep:axum", "dep:chrono", "dep:futures", "dep:uuid"]
 libtest = []
 
 [build-dependencies]

kuksa_databroker/databroker/src/lib.rs

@@ -20,6 +20,9 @@ pub mod query;
 pub mod types;
 pub mod vss;
 
+#[cfg(feature = "viss")]
+pub mod viss;
+
 use std::fmt::Write;
 
 use tracing::info;

kuksa_databroker/databroker/src/main.rs

@@ -29,6 +29,8 @@ use tracing::{debug, error, info};
 
 use clap::{Arg, ArgAction, Command};
 
+#[cfg(feature = "viss")]
+use databroker::viss;
 use databroker::{broker, grpc, permissions, vss};
 
 // Hardcoded datapoints
@@ -267,7 +269,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         )
         .arg(
             Arg::new("dummy-metadata")
-                .display_order(10)
+                .display_order(100)
                 .long("dummy-metadata")
                 .action(ArgAction::Set)
                 .help("Populate data broker with dummy metadata")
@@ -279,14 +281,14 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         parser = parser
             .arg(
                 Arg::new("insecure")
-                    .display_order(6)
+                    .display_order(20)
                     .long("insecure")
                     .help("Allow insecure connections")
                     .action(ArgAction::SetTrue),
             )
             .arg(
                 Arg::new("tls-cert")
-                    .display_order(5)
+                    .display_order(21)
                     .long("tls-cert")
                     .help("TLS certificate file (.pem)")
                     .action(ArgAction::Set)
@@ -295,7 +297,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             )
             .arg(
                 Arg::new("tls-private-key")
-                    .display_order(5)
+                    .display_order(22)
                     .long("tls-private-key")
                     .help("TLS private key file (.key)")
                     .action(ArgAction::Set)
@@ -304,6 +306,41 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             );
     }
 
+    #[cfg(feature = "viss")]
+    {
+        parser = parser
+            .arg(
+                Arg::new("enable-viss")
+                    .display_order(30)
+                    .long("enable-viss")
+                    .help("Enable VISSv2 (websocket) service")
+                    .action(ArgAction::SetTrue),
+            )
+            .arg(
+                Arg::new("viss-address")
+                    .display_order(31)
+                    .long("viss-address")
+                    .help("VISS address")
+                    .action(ArgAction::Set)
+                    .value_name("IP")
+                    .required(false)
+                    .env("KUKSA_DATABROKER_VISS_ADDR")
+                    .default_value("127.0.0.1"),
+            )
+            .arg(
+                Arg::new("viss-port")
+                    .display_order(32)
+                    .long("viss-port")
+                    .help("VISS port")
+                    .action(ArgAction::Set)
+                    .value_name("PORT")
+                    .required(false)
+                    .env("KUKSA_DATABROKER_VISS_PORT")
+                    .value_parser(clap::value_parser!(u16))
+                    .default_value("8090"),
+            );
+    }
+
     let args = parser.get_matches();
 
     // install global collector configured based on RUST_LOG env var.
@@ -432,6 +469,24 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         (false, _) => Authorization::Disabled,
     };
 
+    #[cfg(feature = "viss")]
+    {
+        let viss_port = args
+            .get_one::<u16>("viss-port")
+            .expect("port should be a number");
+        let viss_addr = std::net::SocketAddr::new(ip_addr, *viss_port);
+
+        if args.get_flag("enable-viss") {
+            let broker = broker.clone();
+            let authorization = authorization.clone();
+            tokio::spawn(async move {
+                if let Err(err) = viss::server::serve(viss_addr, broker, authorization).await {
+                    error!("{err}");
+                }
+            });
+        }
+    }
+
     grpc::server::serve(
         addr,
         broker,

kuksa_databroker/databroker/src/viss/mod.rs

@@ -0,0 +1,15 @@
+/********************************************************************************
+* Copyright (c) 2023 Contributors to the Eclipse Foundation
+*
+* See the NOTICE file(s) distributed with this work for additional
+* information regarding copyright ownership.
+*
+* This program and the accompanying materials are made available under the
+* terms of the Apache License 2.0 which is available at
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* SPDX-License-Identifier: Apache-2.0
+********************************************************************************/
+
+pub mod server;
+pub mod v2;