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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88

use axum::{
    extract::{Path, Query, State},
    Json,
};
use flagrant::models::{environment, feature};
use flagrant_types::{Feature, FeatureRequestPayload};
use serde::Deserialize;
use sqlx::SqlitePool;

use crate::errors::ServiceError;

#[derive(Debug, Deserialize)]
pub struct FeatureQueryParams {
    name: Option<String>,
    prefix: Option<String>,
}

pub async fn create(
    State(pool): State<SqlitePool>,
    Path(environment_id): Path<u16>,
    Json(feat): Json<FeatureRequestPayload>,
) -> Result<Json<Feature>, ServiceError> {
    let env = environment::fetch(&pool, environment_id).await?;
    let feature = feature::create(&pool, &env, feat.name, feat.value, feat.is_enabled).await?;

    Ok(Json(feature))
}

pub async fn fetch(
    State(pool): State<SqlitePool>,
    Path((environment_id, feature_id)): Path<(u16, u16)>,
) -> Result<Json<Feature>, ServiceError> {
    let env = environment::fetch(&pool, environment_id).await?;
    let feature = feature::fetch(&pool, &env, feature_id).await?;

    Ok(Json(feature))
}

pub async fn update(
    State(pool): State<SqlitePool>,
    Path((environment_id, feature_id)): Path<(u16, u16)>,
    Json(feat): Json<FeatureRequestPayload>,
) -> Result<Json<()>, ServiceError> {
    let env = environment::fetch(&pool, environment_id).await?;
    let feature = feature::fetch(&pool, &env, feature_id).await?;
    feature::update(
        &pool,
        &env,
        &feature,
        feat.name,
        feat.value,
        feat.is_enabled,
    )
    .await?;

    Ok(Json(()))
}

pub async fn list(
    State(pool): State<SqlitePool>,
    Query(params): Query<FeatureQueryParams>,
    Path(environment_id): Path<u16>,
) -> Result<Json<Vec<Feature>>, ServiceError> {
    let env = environment::fetch(&pool, environment_id).await?;
    let features = match (params.prefix, params.name) {
        (Some(prefix), _) => feature::fetch_by_prefix(&pool, &env, prefix).await?,
        (_, Some(name)) => vec![feature::fetch_by_name(&pool, &env, name).await?],
        _ => feature::list(&pool, &env).await?
    };

    Ok(Json(features))
}

pub async fn delete(
    State(pool): State<SqlitePool>,
    Path((environment_id, feature_id)): Path<(u16, u16)>,
) -> Result<Json<()>, ServiceError> {
    let env = environment::fetch(&pool, environment_id).await?;
    let feature = feature::fetch(&pool, &env, feature_id).await?;
    feature::delete(
        &pool,
        &env,
        &feature,
    )
    .await?;

    Ok(Json(()))
}