cupido 0.1.0

Networking your files in seconds.
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

use crate::graph::GraphSize;
use axum::extract::Query;
use axum::Router;
use axum::routing::get;
use serde_derive::{Deserialize, Serialize};
use tracing::error;

pub fn create_router() -> Router {
    return Router::new()
        .nest("/file",
              Router::new()
                  .route("/-/commits", get(file_related_commit_handler))
                  .route("/-/issues", get(file_related_issue_handler)),
        )
        .route("/size", get(size_handler))
        .route("/", get(root_handler));
}

async fn size_handler() -> axum::Json<GraphSize> {
    let conf = crate::server::app::SERVER_CONFIG.read().unwrap();
    axum::Json(conf.graph.size())
}

async fn root_handler() -> axum::Json<Desc> {
    axum::Json(Desc {
        version: crate::server::app::VERSION.to_string(),
    })
}

async fn file_related_commit_handler(Query(params): Query<Params>) -> axum::Json<Vec<String>> {
    let conf = crate::server::app::SERVER_CONFIG.read().unwrap();
    return match conf.graph.related_commits(&params.file) {
        Ok(commits) => axum::Json(commits),
        Err(error) => {
            error!("file_related_commit error: {}", error);
            axum::Json(Vec::new())
        }
    };
}

async fn file_related_issue_handler(Query(params): Query<Params>) -> axum::Json<Vec<String>> {
    let conf = crate::server::app::SERVER_CONFIG.read().unwrap();
    return match conf.graph.related_issues(&params.file) {
        Ok(issues) => axum::Json(issues),
        Err(error) => {
            error!("file_related_issues error: {}", error);
            axum::Json(Vec::new())
        }
    };
}


#[derive(Debug, Deserialize)]
struct Params {
    file: String,
}

#[derive(Deserialize, Serialize, Debug)]
struct Desc {
    version: String,
}