mfs 0.2.1

Fetcher for scholarly metadata
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

use axum::{
    body::Body,
    extract::Path,
    response::{IntoResponse, Response},
    routing::get,
    Router,
};
use axum_extra::extract::Query;
use reqwest::StatusCode;
use serde::Deserialize;

use crate::{output::MetadataSource, publications::fetch_dois};

pub async fn handle_server_command(port: &Option<u16>) {
    let app = Router::new()
        .route("/", get(root))
        .route("/api/v1/pub/doi/{*doi}", get(single_doi));

    let listener =
        tokio::net::TcpListener::bind(format!("0.0.0.0:{}", port.unwrap_or_else(|| 6789)))
            .await
            .unwrap();
    axum::serve(listener, app).await.unwrap();
}

async fn root() -> &'static str {
    "mfs 0.1.0"
}

#[derive(Debug, Deserialize)]
struct SingleDoiParams {
    #[serde(default)]
    source: Vec<MetadataSource>,
}

async fn single_doi(
    Path(doi): Path<String>,
    Query(params): Query<SingleDoiParams>,
) -> impl IntoResponse {
    let report = fetch_dois(&vec![doi], &params.source).await;

    match report.first() {
        Some(r) => r.clone().into_response(),
        None => Response::builder()
            .status(StatusCode::NOT_FOUND)
            .body(Body::from("Not found"))
            .unwrap(),
    }
}