flagrant-api 0.0.2

CLI powered feature-flagging
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71

use axum::{routing::{delete, get, post, put}, Router
};
use tower_http::compression::CompressionLayer;
use tower_http::trace::TraceLayer;
use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};

use crate::handlers::projects;
use crate::handlers::{environments, features, variants};

mod api;
mod errors;
mod extractors;
mod handlers;

pub fn init_tracing() {
    tracing_subscriber::registry()
        .with(
            tracing_subscriber::EnvFilter::try_from_default_env().unwrap_or_else(|_| {
                // axum logs rejections from built-in extractors with the `axum::rejection`
                // target, at `TRACE` level. `axum::rejection=trace` enables showing those events
                "flagrant_api=debug,flagrant=debug,tower_http=debug,axum::rejection=trace".into()
            }),
        )
        .with(tracing_subscriber::fmt::layer())
        .init();
}

pub async fn start_api_server() -> anyhow::Result<()> {
    let pool = flagrant::init().await?;
    let app = Router::new()
        // projects
        .route("/projects/:project_id", get(projects::fetch))

        // environments
        .route("/projects/:project_id/envs", get(environments::list))
        .route("/projects/:project_id/envs", post(environments::create))
        .route("/projects/:project_id/envs/:env_id", get(environments::fetch))

        // features
        .route("/envs/:environment_id/features", get(features::list))
        .route("/envs/:environment_id/features", post(features::create))
        .route("/envs/:environment_id/features/:feature_id", get(features::fetch))
        .route("/envs/:environment_id/features/:feature_id", put(features::update))
        .route("/envs/:environment_id/features/:feature_id", delete(features::delete))

        // variants
        .route("/envs/:environment_id/features/:feature_id/variants", get(variants::list))
        .route("/envs/:environment_id/features/:feature_id/variants", post(variants::create))
        .route("/envs/:environment_id/variants/:variant_id", get(variants::fetch))
        .route("/envs/:environment_id/variants/:variant_id", put(variants::update))
        .route("/envs/:environment_id/variants/:variant_id", delete(variants::delete))

        // public API
        .nest("/api/v1",
              Router::new()
                .route("/envs/:environment_id/ident/:ident/features/:feature_name", get(api::get_feature)))

        .with_state(pool)
        .layer(CompressionLayer::new())
        .layer(TraceLayer::new_for_http());


    let listener = tokio::net::TcpListener::bind("127.0.0.1:3030")
        .await
        .unwrap();

    tracing::info!("listening on {}", listener.local_addr().unwrap());
    axum::serve(listener, app).await.unwrap();

    Ok(())
}