Update rust deps and fix clippy lints

Author: Dorian Eikenberg

vmicore/rust_src/Cargo.toml

@@ -7,22 +7,23 @@ edition = "2021"
 crate-type = ["lib", "staticlib"]
 
 [dependencies]
-tonic = "0.11.0"
-prost = "0.12.3"
-prost-types = "0.12.3"
-tokio = { version = "1.22", features = ["macros", "rt-multi-thread", "net"] }
+tonic = "0.12.3"
+prost = "0.13.3"
+prost-types = "0.13.3"
+tokio = { version = "1.41", features = ["macros", "rt-multi-thread", "net"] }
+tokio-stream = "0.1.16"
+hyper-util = "0.1.10"
 cxx = "1.0"
 triggered = "0.1.2"
-async-std = "1.12"
-async-stream = "0.3.3"
-futures-core = "0.3.25"
-chrono = "0.4.23"
+async-std = "1.13"
+async-stream = "0.3.6"
+futures-core = "0.3.31"
+chrono = "0.4.38"
 thiserror = "1"
-futures = { version = "0.3", default-features = false, features = ["alloc"] }
 
 [dev-dependencies]
-tower = "0.4.13"
-ctrlc = "3.4.0"
+tower = "0.5.1"
+ctrlc = "3.4.5"
 
 [build-dependencies]
-tonic-build = "0.11.0"
+tonic-build = "0.12.3"

vmicore/rust_src/build.rs

@@ -1,5 +1,5 @@
 fn main() -> Result<(), Box<dyn std::error::Error>> {
-    tonic_build::configure().build_client(true).compile(
+    tonic_build::configure().build_client(true).compile_protos(
         &[
             "./protos/pkg/logging/service/v1/log_svc.proto",
             "./protos/pkg/vmi/v1/vmi_svc.proto",

vmicore/rust_src/examples/grpc_client.rs

@@ -1,5 +1,6 @@
 use std::error::Error;
 
+use hyper_util::rt::TokioIo;
 use tokio::{net::UnixStream, try_join};
 use tonic::{
     transport::{Channel, Endpoint, Uri},
@@ -14,6 +15,8 @@ use rust_grpc_server::pkg::logging::{
 };
 use rust_grpc_server::pkg::vmi::v1::{vmi_service_client::VmiServiceClient, ListenForEventsRequest};
 
+const UNIX_SOCKET_ADDR: &str = "/tmp/vmi.sock";
+
 async fn log_client(channel: Channel, trigger: Trigger, listener: Listener) -> Result<(), Box<dyn Error>> {
     let mut client = LogServiceClient::new(channel);
 
@@ -59,13 +62,11 @@ async fn vmi_client(channel: Channel, trigger: Trigger, listener: Listener) -> R
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn Error>> {
-    let addr = "/tmp/vmi.sock";
-
     // Url not used
     let channel = Endpoint::try_from("http://[::]:50051")?
-        .connect_with_connector(service_fn(move |_: Uri| {
+        .connect_with_connector(service_fn(|_: Uri| async {
             // Connect to a Uds socket
-            UnixStream::connect(addr)
+            Ok::<_, std::io::Error>(TokioIo::new(UnixStream::connect(UNIX_SOCKET_ADDR).await?))
         }))
         .await?;
 

vmicore/rust_src/src/grpc_server.rs

@@ -13,13 +13,13 @@ use crate::pkg::vmi::v1::{
 use async_std::channel::{unbounded, Receiver, Sender};
 use async_std::task;
 use cxx::CxxVector;
-use futures::TryFutureExt;
 use std::error::Error;
 use std::fmt::Debug;
 use std::pin::Pin;
 use std::result;
 use std::time::SystemTime;
 use tokio::net::UnixListener;
+use tokio_stream::wrappers::UnixListenerStream;
 use tonic::transport::Server;
 use tonic::{Status, Streaming};
 
@@ -78,11 +78,7 @@ impl GRPCServer {
             }
             let uds = UnixListener::bind(addr_ref)?;
 
-            async_stream::stream! {
-                loop {
-                    yield uds.accept().map_ok(|(st, _)| crate::unix_socket::UnixStream(st)).await;
-                }
-            }
+            UnixListenerStream::new(uds)
         };
 
         Server::builder()

vmicore/rust_src/src/lib.rs

@@ -5,7 +5,6 @@ mod grpc_logger;
 pub mod grpc_server;
 mod grpc_vmi_service;
 mod logging;
-mod unix_socket;
 
 pub mod pkg {
     #![allow(clippy::derive_partial_eq_without_eq)]