move tests to dev dependencies

crates/orchestrator/Cargo.toml

@@ -21,9 +21,7 @@ dotenvy = { workspace = true }
 ethereum-da-client = { workspace = true, optional = true }
 futures = { workspace = true }
 mongodb = { workspace = true, features = ["bson-uuid-1"], optional = true }
-hyper = { version = "0.14", features = ["full"] }
 omniqueue = { workspace = true, optional = true }
-rstest = { workspace = true }
 serde = { workspace = true }
 serde_json = { workspace = true }
 starknet = { workspace = true }
@@ -39,3 +37,7 @@ default = ["ethereum", "with_mongodb", "with_sqs"]
 ethereum = ["ethereum-da-client"]
 with_mongodb = ["mongodb"]
 with_sqs = ["omniqueue"]
+
+[dev-dependencies]
+hyper = { version = "0.14", features = ["full"] }
+rstest = { workspace = true }

crates/orchestrator/tests/common/constants.rs

@@ -0,0 +1,2 @@
+pub const MADARA_RPC_URL: &str = "http://localhost:9944";
+pub const MONGODB_CONNECTION_STRING: &str = "mongodb+srv://admin:[email protected]/";

crates/orchestrator/tests/common/mod.rs

@@ -0,0 +1 @@
+pub mod constants;

crates/orchestrator/tests/mod.rs

@@ -1,2 +1,4 @@
 #[cfg(test)]
 pub mod server;
+
+pub mod common;

crates/orchestrator/tests/server/mod.rs

@@ -11,21 +11,25 @@ use rstest::*;
 use starknet::providers::Provider;
 
 use orchestrator::{
+    queue::init_consumers,
     config::{config, Config},
     routes::app_router,
     utils::env_utils::get_env_var_or_default,
 };
 
+use crate::common::constants::{MADARA_RPC_URL, MONGODB_CONNECTION_STRING};
+
 #[fixture]
 fn rpc_url() -> String {
-    String::from("http://localhost:9944")
+    String::from(MADARA_RPC_URL)
 }
 
 #[fixture]
 pub async fn init_valid_config(
     rpc_url: String
 ) -> &'static Config {
     env::set_var("MADARA_RPC_URL", rpc_url.as_str());
+    env::set_var("MONGODB_CONNECTION_STRING", MONGODB_CONNECTION_STRING);
 
     let _ = tracing_subscriber::fmt().with_max_level(tracing::Level::INFO).with_target(false).try_init();
 
@@ -68,14 +72,11 @@ async fn test_valid_config(
 
 #[rstest]
 #[tokio::test]
-async fn health(#[future] setup_server: SocketAddr) {
-    println!("Setting up the server for health");
+async fn test_health_endpoint(#[future] setup_server: SocketAddr) {
     let addr = setup_server.await;
-    println!("server for health is set up");
 
 
     let client = hyper::Client::new();
-    println!("Client created, now making request to health");
     let response = client
         .request(Request::builder().uri(format!("http://{}/health", addr)).body(Body::empty()).unwrap())
         .await
@@ -86,5 +87,11 @@ async fn health(#[future] setup_server: SocketAddr) {
     let body = hyper::body::to_bytes(response.into_body()).await.unwrap();
     let mut buf = String::new();
     let res = body.reader().read_to_string(&mut buf).unwrap();
-    println!("body health = {}", res);
-}
+    assert_eq!(res, 2);
+}
+
+#[rstest]
+#[tokio::test]
+async fn test_init_consumer() {
+    assert!(init_consumers().await.is_ok());
+}