Merge pull request #113 from HIRO-MicroDataCenters-BV/integration-tests

NATS messaging integration test
HIRO-MicroDataCenters-BV · Jan 17, 2025 · 01f1315 · 01f1315
2 parents b1b2f95 + a6bd8ea
commit 01f1315
Show file tree

Hide file tree

Showing 24 changed files with 1,886 additions and 454 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -30,7 +30,7 @@ futures-lite = "2.5.0"
 futures-util = "0.3.30"
 iroh-blobs = "0.25.0"
 iroh-io = { version = "0.6.1", features = ["x-http"] }
-rust-s3 = { version = "0.35.1", features = ["tokio"] }
+rust-s3 = { version = "0.35.1", features = ["tokio", "blocking"] }
 thiserror = "2.0.3"
 tokio = { version = "1.41.1", features = ["full"] }
 tokio-stream = "0.1.15"
@@ -44,4 +44,8 @@ tracing = "0.1.40"
 tracing-subscriber = { version = "0.3.18", features = ["env-filter"] }
 tempfile = "3.10.1"
 rusty-hook = "^0.11.2"
+once_cell = "1.20.2"
+dashmap = "6.1.0"
+futures = { version = "0.3.28", default-features = false, features = ["std"] }
+pin-project = "1.1.8"
 
diff --git a/rhio/Cargo.toml b/rhio/Cargo.toml
@@ -42,6 +42,12 @@ tokio-stream.workspace = true
 tokio-util.workspace = true
 tracing.workspace = true
 tracing-subscriber.workspace = true
+pin-project.workspace = true
+bytes.workspace = true
+futures.workspace = true
 
 [dev-dependencies]
 figment = { workspace = true, features = ["test"] }
+once_cell.workspace = true
+dashmap.workspace = true
+serde_json.workspace = true
diff --git a/rhio/src/config.rs b/rhio/src/config.rs
@@ -166,7 +166,7 @@ impl Default for S3Config {
     }
 }
 
-#[derive(Clone, Debug, Eq, PartialEq, Serialize, Deserialize)]
+#[derive(Clone, Debug, Eq, PartialEq, Serialize, Deserialize, Hash)]
 pub struct NatsConfig {
     pub endpoint: String,
     pub credentials: Option<NatsCredentials>,
@@ -181,7 +181,7 @@ impl Default for NatsConfig {
     }
 }
 
-#[derive(Clone, Debug, Default, Eq, PartialEq, Serialize, Deserialize)]
+#[derive(Clone, Debug, Default, Eq, PartialEq, Serialize, Deserialize, Hash)]
 pub struct NatsCredentials {
     pub nkey: Option<String>,
     pub username: Option<String>,