Basic web server & request data validation

Cargo.toml

@@ -6,3 +6,14 @@ edition = "2021"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
+axum = "0.6"
+hyper = { version = "0.14", features = ["full"] }
+serde = { version = "1.0", features = ["derive"] }
+serde_json = "*"
+tokio = { version = "1.24", features = ["full"] }
+tower = "0.4"
+url = { version = "2", features = ["serde"] }
+validator = { version = "0.16", features = ["derive"] }
+
+[dev-dependencies]
+serde_test = "1.0"

Makefile

@@ -10,4 +10,4 @@ test:
 
 .PHONY: run
 run:
-	@docker run -it --rm --name s3-active-storage s3-active-storage
+	@docker run -it --rm --net=host --name s3-active-storage s3-active-storage

src/app.rs

@@ -0,0 +1,51 @@
+use crate::models;
+
+use axum::{
+    extract::Json,
+    routing::{get, post},
+    Router,
+};
+
+pub fn router() -> Router {
+    fn v1() -> Router {
+        Router::new()
+            .route("/count", post(count))
+            .route("/max", post(max))
+            .route("/mean", post(mean))
+            .route("/min", post(min))
+            .route("/select", post(select))
+            .route("/sum", post(sum))
+    }
+
+    Router::new()
+        .route("/.well-known/s3-active-storage-schema", get(schema))
+        .nest("/v1", v1())
+}
+
+async fn schema() -> &'static str {
+    "Hello, world!"
+}
+
+async fn count(Json(request_data): Json<models::RequestData>) -> String {
+    format!("Hello, {}!", request_data.source)
+}
+
+async fn max(Json(request_data): Json<models::RequestData>) -> String {
+    format!("Hello, {}!", request_data.source)
+}
+
+async fn mean(Json(request_data): Json<models::RequestData>) -> String {
+    format!("Hello, {}!", request_data.source)
+}
+
+async fn min(Json(request_data): Json<models::RequestData>) -> String {
+    format!("Hello, {}!", request_data.source)
+}
+
+async fn select(Json(request_data): Json<models::RequestData>) -> String {
+    format!("Hello, {}!", request_data.source)
+}
+
+async fn sum(Json(request_data): Json<models::RequestData>) -> String {
+    format!("Hello, {}!", request_data.source)
+}

src/main.rs

@@ -1,3 +1,42 @@
-fn main() {
-    println!("Hello, world!");
+use tokio::signal;
+
+mod app;
+mod models;
+
+#[tokio::main]
+async fn main() {
+    let router = app::router();
+
+    // run it with hyper on localhost:8080
+    axum::Server::bind(&"0.0.0.0:8080".parse().unwrap())
+        .serve(router.into_make_service())
+        .with_graceful_shutdown(shutdown_signal())
+        .await
+        .unwrap();
+}
+
+async fn shutdown_signal() {
+    let ctrl_c = async {
+        signal::ctrl_c()
+            .await
+            .expect("failed to install Ctrl+C handler");
+    };
+
+    #[cfg(unix)]
+    let terminate = async {
+        signal::unix::signal(signal::unix::SignalKind::terminate())
+            .expect("failed to install signal handler")
+            .recv()
+            .await;
+    };
+
+    #[cfg(not(unix))]
+    let terminate = std::future::pending::<()>();
+
+    tokio::select! {
+        _ = ctrl_c => {},
+        _ = terminate => {},
+    }
+
+    println!("signal received, starting graceful shutdown");
 }