Merge pull request #73 from mineshp-mecha/chore/networking

Feat/networking

Cargo.toml

@@ -1,6 +1,6 @@
 [workspace]
 default-members = ["agent"]
-members = ["agent", "core/services", "core/events", "core/settings", "provisioning", "messaging", "identity", "status", "settings", "grpc-server", "networking","telemetry","commons/crypto", "commons/kv-store", "commons/fs", "client/app"]
+members = ["agent", "core/services", "core/events", "core/settings", "provisioning", "messaging", "identity", "status", "settings", "grpc-server", "networking","telemetry","commons/crypto", "commons/kv-store", "commons/fs", "client/app", "commons/wireguard"]
 resolver = "2"
 
 [workspace.package]

agent/Cargo.toml

@@ -21,8 +21,8 @@ messaging = { path = "../messaging" }
 channel = { path = "../commons/channel" }
 provisioning = { path = "../provisioning" }
 settings = { path = "../settings" }
-networking = { path = "../networking" }
 telemetry = { path = "../telemetry" }
+networking = { path = "../networking" }
 tokio = { workspace = true }
 serde = { workspace = true }
 serde_json = { workspace = true }

commons/kv-store/src/lib.rs

@@ -87,13 +87,14 @@ impl KeyValueStoreClient {
         Ok(true)
     }
     pub fn get(&self, key: &str) -> Result<Option<String>> {
-        trace!(func = "get", package = PACKAGE_NAME, " key: {}", key);
+        let fn_name = "get";
+        trace!(func = fn_name, package = PACKAGE_NAME, " key: {}", key);
         if let Some(database) = DATABASE.as_ref() {
             let db = match database.lock() {
                 Ok(d) => d,
                 Err(e) => {
                     error!(
-                        func = "set",
+                        func = fn_name,
                         package = PACKAGE_NAME,
                         "failed to acquire lock on db - {}",
                         e
@@ -109,7 +110,7 @@ impl KeyValueStoreClient {
             match last_inserted {
                 Ok(s) => {
                     debug!(
-                        func = "get",
+                        func = fn_name,
                         package = PACKAGE_NAME,
                         "retrieved value from db key - {}",
                         key

commons/wireguard/Cargo.toml

@@ -0,0 +1,21 @@
+[package]
+name = "wireguard"
+version.workspace = true
+authors.workspace = true
+description.workspace = true
+documentation.workspace = true
+edition.workspace = true
+license.workspace = true
+repository.workspace = true
+homepage.workspace = true
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+serde = { version  = "1.0.159", features = ["derive"]}
+base64 = "0.22.0"
+anyhow = { version = "1.0.71", features = ["backtrace"]}
+rand = "0.8.5"
+x25519-dalek = { version = "2.0", features = ["getrandom", "static_secrets"] }
+defguard_wireguard_rs = "0.4.2"
+tracing = "0.1"