crab-vault 0.2.11

use std::{net::Ipv4Addr, time::Duration};

use axum::extract::Request;
use base64::{prelude::BASE64_STANDARD, Engine};
use crab_vault_engine::{DataEngine, DataSource, MetaEngine, MetaSource};
use tower_http::{
    cors::{self, CorsLayer},
    normalize_path::NormalizePathLayer,
    trace::{DefaultOnRequest, DefaultOnResponse, TraceLayer},
};

use crate::{
    app_config,
    http::api::{self, ApiState},
    logger,
};

pub async fn run() {
    logger::init();

    let data_src =
        DataSource::new(app_config::data().source()).expect("Failed to create data storage");
    let meta_src =
        MetaSource::new(app_config::meta().source()).expect("Failed to create meta storage");
    let state = ApiState::new(data_src, meta_src);

    let tracing_layer = TraceLayer::new_for_http()
        .make_span_with(|req: &Request| {
            let method = req.method().to_string();
            let uri = req.uri().to_string();
            let req_id = BASE64_STANDARD.encode(uuid::Uuid::new_v4()); // 使用 base64 编码的 uuid 作为请求 req_id
            tracing::info_span!("[request]", req_id, method, uri)
        })
        .on_failure(())
        .on_request(DefaultOnRequest::new().level(tracing::Level::INFO))
        .on_response(DefaultOnResponse::new().level(tracing::Level::INFO));

    let normalize_path_layer = NormalizePathLayer::trim_trailing_slash();

    let cors_layer = CorsLayer::new()
        .allow_methods(cors::Any)
        .allow_headers(cors::Any)
        .allow_origin(cors::Any)
        .allow_credentials(false)
        .max_age(Duration::from_secs(3600 * 24));

    let app = api::build_router()
        .await
        .layer(cors_layer)
        .layer(tracing_layer)
        .layer(normalize_path_layer)
        .with_state(state);

    let listener =
        tokio::net::TcpListener::bind((Ipv4Addr::UNSPECIFIED, app_config::server().port()))
            .await
            .unwrap();

    tracing::info!(
        "Server running on http://{}",
        listener.local_addr().unwrap()
    );

    axum::serve(listener, app.into_make_service())
        .await
        .unwrap();
}