htsget-actix 0.12.9

A webserver instance of htsget-rs using actix-web, which serves data according to the htsget protocol.
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

use std::collections::HashMap;

use actix_web::web::{Query, ReqData};
use actix_web::{
  HttpRequest, Responder,
  web::{Data, Json, Path},
};
use htsget_http::{Endpoint, PostRequest, post};
use htsget_search::HtsGet;
use serde_json::Value;
use tracing::info;
use tracing::instrument;

use super::{extract_request, handle_response};
use crate::AppState;

/// POST request reads endpoint
#[instrument(skip(app_state))]
pub async fn reads<H: HtsGet + Clone + Send + Sync + 'static>(
  request: Query<HashMap<String, String>>,
  path: Path<String>,
  http_request: HttpRequest,
  extension: Option<ReqData<Value>>,
  body: Json<PostRequest>,
  app_state: Data<AppState<H>>,
) -> impl Responder {
  let request = extract_request(request, path, http_request);

  info!(body = ?body, "reads endpoint POST request");

  handle_response(
    post(
      app_state.get_ref().htsget.clone(),
      body.into_inner(),
      request,
      Endpoint::Reads,
      app_state.auth.clone(),
      app_state.package_info.as_ref(),
      extension.map(|extension| extension.into_inner()),
    )
    .await,
  )
}

/// POST request variants endpoint
#[instrument(skip(app_state))]
pub async fn variants<H: HtsGet + Clone + Send + Sync + 'static>(
  request: Query<HashMap<String, String>>,
  path: Path<String>,
  http_request: HttpRequest,
  extension: Option<ReqData<Value>>,
  body: Json<PostRequest>,
  app_state: Data<AppState<H>>,
) -> impl Responder {
  let request = extract_request(request, path, http_request);

  info!(body = ?body, "variants endpoint POST request");

  handle_response(
    post(
      app_state.get_ref().htsget.clone(),
      body.into_inner(),
      request,
      Endpoint::Variants,
      app_state.auth.clone(),
      app_state.package_info.as_ref(),
      extension.map(|extension| extension.into_inner()),
    )
    .await,
  )
}