lxy 0.1.1

A convenient async http and RPC framework in Rust
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
72
73
74
75
76
77
78
79
80
81
82

use axum::extract::FromRequestParts;
use std::{ops::Deref, sync::Arc};

use crate::{Error, app::get_app};

pub struct Inject<T>(pub Arc<T>);

impl<T> Deref for Inject<T> {
  type Target = T;

  fn deref(&self) -> &Self::Target {
    &self.0
  }
}

impl<S, T> FromRequestParts<S> for Inject<T>
where
  T: 'static,
  S: Send + Sync,
{
  type Rejection = Error;

  async fn from_request_parts(
    _parts: &mut axum::http::request::Parts,
    _state: &S,
  ) -> Result<Self, Self::Rejection> {
    Ok(Inject(get_app()?.get::<T>()?))
  }
}

#[cfg(test)]
mod tests {
  use super::super::Router;
  use super::*;
  use crate::{
    app::{App, context::run_with_app},
    container::Container,
  };
  use axum::body::Body;
  use http::Request;
  use http_body_util::BodyExt;
  use tower::Service;

  #[tokio::test]
  async fn test_inject() {
    #[derive(Clone, Debug, PartialEq, Eq)]
    struct MyService {
      value: u32,
    }

    let handler = async |injected: Inject<MyService>| injected.value.to_string();

    // Create App with MyService registered
    let mut app = App::new();
    app.container.bind(MyService { value: 42 });

    // Build router directly
    let router = Router::compose(|r| {
      r.layer(crate::app::layer::AppLayer(app.clone()))
        .get("/", handler);
    });

    let mut router_service = router.build();

    let response = run_with_app(
      app,
      router_service.call(
        Request::builder()
          .method("GET")
          .uri("/")
          .body(Body::empty())
          .unwrap(),
      ),
    )
    .await
    .unwrap();

    let bytes = response.into_body().collect().await.unwrap().to_bytes();
    let body_str = String::from_utf8(bytes.to_vec()).unwrap();
    assert_eq!(body_str, "42");
  }
}