cargolifter-web 0.2.0

CargoLifter web service
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

pub async fn download(
    axum::extract::Path((crate_name, crate_version)): axum::extract::Path<(String, String)>,
    storage: axum::extract::Extension<tokio::sync::mpsc::Sender<cargolifter_core::StorageCommand>>,
) -> Result<Vec<u8>, axum::http::StatusCode> {
    tracing::info!(
        "requtested download of '{}' in version '{}'",
        crate_name,
        crate_version
    );

    let (tx, rx) = tokio::sync::oneshot::channel::<Option<Vec<u8>>>();
    let request = cargolifter_core::models::StorageGetRequest {
        crate_name,
        crate_version,
        result_sender: tx,
    };

    match storage
        .send(cargolifter_core::StorageCommand::Get(request))
        .await
    {
        Ok(_) => match rx.await {
            Ok(result) => match result {
                Some(data) => Ok(data),
                None => Err(axum::http::StatusCode::NOT_FOUND),
            },
            Err(e) => {
                tracing::error!("Failed to receive storage response: {}", e);
                Err(axum::http::StatusCode::INTERNAL_SERVER_ERROR)
            }
        },
        Err(e) => {
            tracing::error!("Failed to send storage request: {}", e);
            Err(axum::http::StatusCode::INTERNAL_SERVER_ERROR)
        }
    }
}