summaryrefslogtreecommitdiff
path: root/server/src
diff options
context:
space:
mode:
authorSanto Cariotti <santo@dcariotti.me>2022-08-21 18:48:51 +0200
committerSanto Cariotti <santo@dcariotti.me>2022-08-21 18:48:51 +0200
commit451d1db821b8d445f1bb6f1f3ad6de20f19eb85d (patch)
tree10316b0c057bd54751a461fc144fd40a80f14a84 /server/src
parent0b9e7dff080b3fcf3907da343e17ab73012e7207 (diff)
Move backend to server folder
Diffstat (limited to 'server/src')
-rw-r--r--server/src/errors.rs24
-rw-r--r--server/src/logger.rs11
-rw-r--r--server/src/main.rs66
3 files changed, 101 insertions, 0 deletions
diff --git a/server/src/errors.rs b/server/src/errors.rs
new file mode 100644
index 0000000..6fd0a61
--- /dev/null
+++ b/server/src/errors.rs
@@ -0,0 +1,24 @@
+use axum::{
+ http::StatusCode,
+ response::{IntoResponse, Response},
+ Json,
+};
+use serde_json::json;
+
+pub enum Error {
+ Generic,
+}
+
+impl IntoResponse for Error {
+ fn into_response(self) -> Response {
+ let (status, error_message) = match self {
+ Error::Generic => (StatusCode::INTERNAL_SERVER_ERROR, "User not found"),
+ };
+
+ let body = Json(json!({
+ "error": error_message,
+ }));
+
+ (status, body).into_response()
+ }
+}
diff --git a/server/src/logger.rs b/server/src/logger.rs
new file mode 100644
index 0000000..fa569ee
--- /dev/null
+++ b/server/src/logger.rs
@@ -0,0 +1,11 @@
+use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
+
+pub fn setup() {
+ tracing_subscriber::registry()
+ .with(tracing_subscriber::EnvFilter::new(
+ std::env::var("RUST_LOG")
+ .unwrap_or_else(|_| "m6_ie_2022=debug,tower_http=debug".into()),
+ ))
+ .with(tracing_subscriber::fmt::layer())
+ .init();
+}
diff --git a/server/src/main.rs b/server/src/main.rs
new file mode 100644
index 0000000..810e202
--- /dev/null
+++ b/server/src/main.rs
@@ -0,0 +1,66 @@
+mod errors;
+mod logger;
+
+use axum::{
+ http::{header, Request},
+ routing::get,
+ Json, Router,
+};
+use serde::Serialize;
+use std::time::Duration;
+use tower_http::sensitive_headers::SetSensitiveHeadersLayer;
+use tower_http::{classify::ServerErrorsFailureClass, trace::TraceLayer};
+use tracing::Span;
+
+#[tokio::main]
+async fn main() {
+ let app = create_app().await;
+
+ let addr: String =
+ std::env::var("ALLOWED_HOST").unwrap_or_else(|_| "localhost:3000".to_string());
+ tracing::info!("Listening on {}", addr);
+
+ axum::Server::bind(&"127.0.0.1:3000".parse().unwrap())
+ .serve(app.into_make_service())
+ .await
+ .unwrap();
+}
+
+async fn create_app() -> Router {
+ logger::setup();
+
+ Router::new()
+ .route("/", get(hej))
+ // Mark the `Authorization` request header as sensitive so it doesn't
+ // show in logs.
+ .layer(SetSensitiveHeadersLayer::new(std::iter::once(
+ header::AUTHORIZATION,
+ )))
+ .layer(
+ TraceLayer::new_for_http()
+ .on_request(|request: &Request<_>, _span: &Span| {
+ tracing::info!("{} {}", request.method(), request.uri());
+ })
+ .on_failure(
+ |error: ServerErrorsFailureClass, latency: Duration, _span: &Span| {
+ tracing::error!("{} | {} s", error, latency.as_secs());
+ },
+ ),
+ )
+}
+
+// Example root which says hi
+async fn hej() -> Result<Json<Hej>, errors::Error> {
+ Ok(Json(Hej::new("hej verden".to_string())))
+}
+
+#[derive(Debug, Serialize)]
+struct Hej {
+ hello: String,
+}
+
+impl Hej {
+ fn new(hello: String) -> Self {
+ Self { hello }
+ }
+}