netmito 0.6.8

pub mod admin;
pub mod groups;
pub mod tasks;
pub mod users;
pub mod workers;

#[cfg(feature = "debugging")]
use std::net::SocketAddr;

#[cfg(feature = "debugging")]
use axum::{
    body::{Body, Bytes},
    extract::{ConnectInfo, Request},
    middleware::Next,
    response::{IntoResponse, Response},
};
use axum::{
    http::StatusCode,
    middleware,
    routing::{get, post},
    Extension, Json, Router,
};
#[cfg(feature = "debugging")]
use http_body_util::BodyExt;
use serde_json::json;
use tokio_util::sync::CancellationToken;
use tower_http::catch_panic::CatchPanicLayer;
use tower_http::cors::CorsLayer;

use crate::{
    config::{InfraPool, REDIS_CONNECTION_INFO},
    error::ApiError,
    schema::RedisConnectionInfo,
    service::auth::{user_auth_middleware, user_auth_with_name_middleware, AuthUser},
};

pub fn router(st: InfraPool, cancel_token: CancellationToken) -> Router {
    #[cfg(not(feature = "debugging"))]
    {
        Router::new()
            .route(
                "/auth",
                get(users::user_auth).layer(middleware::from_fn_with_state(
                    st.clone(),
                    user_auth_with_name_middleware,
                )),
            )
            .route(
                "/health",
                get(|| async { (StatusCode::OK, Json(json!({"status": "ok"}))) }),
            )
            .route("/login", post(users::user_login))
            .route(
                "/redis",
                get(query_redis_connection_info).layer(middleware::from_fn_with_state(
                    st.clone(),
                    user_auth_middleware,
                )),
            )
            .nest("/users", users::users_router(st.clone()))
            .nest("/admin", admin::admin_router(st.clone(), cancel_token))
            .nest("/groups", groups::groups_router(st.clone()))
            .nest("/workers", workers::workers_router(st.clone()))
            .nest("/tasks", tasks::tasks_router(st.clone()))
            .with_state(st)
            .layer(CorsLayer::permissive())
            .layer(CatchPanicLayer::new())
    }
    #[cfg(feature = "debugging")]
    {
        Router::new()
            .route(
                "/auth",
                get(users::user_auth).layer(middleware::from_fn_with_state(
                    st.clone(),
                    user_auth_with_name_middleware,
                )),
            )
            .route(
                "/health",
                get(|| async { (StatusCode::OK, Json(json!({"status": "ok"}))) }),
            )
            .route("/login", post(users::user_login))
            .route(
                "/redis",
                get(query_redis_connection_info).layer(middleware::from_fn_with_state(
                    st.clone(),
                    user_auth_middleware,
                )),
            )
            .nest("/users", users::users_router(st.clone()))
            .nest("/admin", admin::admin_router(st.clone(), cancel_token))
            .nest("/groups", groups::groups_router(st.clone()))
            .nest("/workers", workers::workers_router(st.clone()))
            .nest("/tasks", tasks::tasks_router(st.clone()))
            .with_state(st)
            .layer(CorsLayer::permissive())
            .layer(CatchPanicLayer::new())
            .layer(middleware::from_fn(print_request_addr))
            .layer(middleware::from_fn(print_request_response))
    }
}

pub async fn query_redis_connection_info(
    Extension(_): Extension<AuthUser>,
) -> Result<Json<RedisConnectionInfo>, ApiError> {
    let url = REDIS_CONNECTION_INFO.get().map(|info| info.client_url());
    Ok(Json(RedisConnectionInfo { url }))
}

#[cfg(feature = "debugging")]
// For debugging purpose
async fn print_request_addr(
    req: Request,
    next: Next,
) -> Result<impl IntoResponse, (StatusCode, String)> {
    let remote_addr = req
        .extensions()
        .get::<ConnectInfo<SocketAddr>>()
        .map(|ci| ci.0);
    tracing::debug!("receive request from {:?} to {}", remote_addr, req.uri());
    let res = next.run(req).await;

    Ok(res)
}

#[cfg(feature = "debugging")]
// For debugging purpose
async fn print_request_response(
    req: Request,
    next: Next,
) -> Result<impl IntoResponse, (StatusCode, String)> {
    let (parts, body) = req.into_parts();
    let bytes = buffer_and_print("request", body).await?;
    let req = Request::from_parts(parts, Body::from(bytes));

    let res = next.run(req).await;

    let (parts, body) = res.into_parts();
    let bytes = buffer_and_print("response", body).await?;
    let res = Response::from_parts(parts, Body::from(bytes));

    Ok(res)
}

#[cfg(feature = "debugging")]
// For debugging purpose
async fn buffer_and_print<B>(direction: &str, body: B) -> Result<Bytes, (StatusCode, String)>
where
    B: axum::body::HttpBody<Data = Bytes>,
    B::Error: std::fmt::Display,
{
    let bytes = match body.collect().await {
        Ok(collected) => collected.to_bytes(),
        Err(err) => {
            return Err((
                StatusCode::BAD_REQUEST,
                format!("failed to read {direction} body: {err}"),
            ));
        }
    };

    if let Ok(body) = std::str::from_utf8(&bytes) {
        tracing::debug!("{direction} body = {body:?}");
    }

    Ok(bytes)
}