Add HTTP integration tests

Author: ekkolon

Cargo.lock

@@ -10,6 +10,10 @@ authors.workspace = true
 keywords.workspace = true
 categories.workspace = true
 
+[lib]
+name = "minikv_server"
+path = "src/lib.rs"
+
 [dependencies]
 minikv-core = { workspace = true }
 tracing = { workspace = true }
@@ -26,3 +30,8 @@ clap = { version = "4", features = ["derive", "env"] }
 tracing-subscriber = { version = "0.3", features = ["env-filter", "fmt"] }
 axum = { version = "0.7", features = [] }
 quick-xml = { version = "0.31", features = ["serialize"] }
+
+[dev-dependencies]
+tower-util = { version = "0.3" }
+minikv-core = { workspace = true }
+wiremock = "0.6"

minikv/Cargo.toml

@@ -0,0 +1,5 @@
+pub mod cli;
+mod error;
+pub mod http;
+
+pub use error::Error;

minikv/src/lib.rs

@@ -6,10 +6,6 @@
 //! - `rebuild`   → DB reconstruction from volume servers
 //! - `rebalance` → key migration to ideal volumes
 
-mod cli;
-mod error;
-mod http;
-
 use minikv_core::storage;
 
 use std::collections::HashMap;
@@ -21,12 +17,12 @@ use dashmap::DashMap;
 use tracing::{error, info};
 use tracing_subscriber::EnvFilter;
 
-use cli::{Cli, Command};
 use minikv_core::locking::KeyLock;
 use minikv_core::rebalance::rebalance_all;
 use minikv_core::rebuild::rebuild_all;
 use minikv_core::replication::build_volume_client;
 use minikv_core::state::AppState;
+use minikv_server::cli::{Cli, Command, CommonArgs, validate_common};
 use storage::leveldb::LevelDbStore;
 
 #[tokio::main]
@@ -39,7 +35,7 @@ async fn main() {
         }
         Command::Server(args) => {
             init_logging(args.verbose);
-            cli::validate_common(&args.common);
+            validate_common(&args.common);
 
             info!(
                 port = args.port,
@@ -78,7 +74,7 @@ async fn main() {
                 http_client: build_volume_client(),
             });
 
-            let router = http::build_router(Arc::clone(&state));
+            let router = minikv_server::http::build_router(Arc::clone(&state));
             let addr = SocketAddr::from(([0, 0, 0, 0], args.port));
             let listener = tokio::net::TcpListener::bind(addr)
                 .await
@@ -96,7 +92,7 @@ async fn main() {
 
         Command::Rebuild(args) => {
             init_logging(false);
-            cli::validate_common(&args);
+            validate_common(&args);
 
             info!(volumes = ?args.volumes, "starting rebuild");
 
@@ -122,7 +118,7 @@ async fn main() {
 
         Command::Rebalance(args) => {
             init_logging(false);
-            cli::validate_common(&args);
+            validate_common(&args);
 
             info!(volumes = ?args.volumes, "starting rebalance");
 
@@ -149,7 +145,7 @@ async fn main() {
 }
 
 /// Open LevelDB or exit with a clear error message.
-fn open_db(args: &cli::CommonArgs) -> LevelDbStore {
+fn open_db(args: &CommonArgs) -> LevelDbStore {
     LevelDbStore::open(&args.db).unwrap_or_else(|e| {
         eprintln!("error: failed to open LevelDB at {:?}: {e}", args.db);
         std::process::exit(1);