crab-vault 0.2.11

An object storage service written in rust.
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

use std::sync::Arc;

use axum::{routing::MethodRouter, Router};

use crate::http::middleware::auth::AuthLayer;

use crab_vault_engine::{DataSource, MetaSource};

mod handler;
mod response;
mod util;

#[derive(Clone)]
pub struct ApiState {
    data_src: Arc<DataSource>,
    meta_src: Arc<MetaSource>,
}

impl ApiState {
    pub fn new(data_src: DataSource, meta_src: MetaSource) -> Self {
        Self {
            data_src: Arc::new(data_src),
            meta_src: Arc::new(meta_src),
        }
    }
}

pub async fn build_router() -> Router<ApiState> {
    use self::handler::*;

    let object_router = MethodRouter::new()
        .put(upload_object)
        .get(get_object)
        .head(head_object)
        .patch(patch_object_meta)
        .delete(delete_object);

    let bucket_router = MethodRouter::new()
        .put(create_bucket)
        .patch(patch_bucket_meta)
        .delete(delete_bucket)
        .get(list_objects_meta)
        .head(head_bucket);

    let health = MethodRouter::new()
        .get(health)
        .head(health);

    Router::new()
        .route("/", axum::routing::get(list_buckets_meta))
        .route("/{bucket_name}", bucket_router)
        .route("/{bucket_name}/{*object_name}", object_router)
        .layer(AuthLayer::new())
        .route("/health", health)
}