rust-integration-services 0.1.1

A modern, fast, and lightweight integration library written in Rust, designed for memory safety and stability.
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

#[cfg(feature = "http")]
pub mod http_request;
#[cfg(feature = "http")]
pub mod http_response;
#[cfg(feature = "http")]
pub mod http_receiver;
#[cfg(feature = "http")]
pub mod http_sender;

#[cfg(feature = "http")]
#[cfg(test)]
mod test {
    use crate::http::{http_receiver::HttpReceiver, http_request::HttpRequest, http_response::HttpResponse, http_sender::HttpSender};
    use tokio::time::Duration;

    #[tokio::test(start_paused = true)]
    async fn http_receiver_sender() {
        tokio::spawn(async move {
            let result = HttpReceiver::new("127.0.0.1:8080")
            .route("GET", "/", |_uuid, _request| async {
                HttpResponse::ok().body_string("Text")
            })
            .receive()
            .await;
            assert!(result.is_ok());
        });
        
        tokio::time::advance(Duration::from_millis(100)).await;
        let request = HttpRequest::get();
        let response = HttpSender::new("http://127.0.0.1:8080").send(request).await.unwrap();
        assert_eq!(response.status_code, 200);
        assert_eq!(response.body_to_string(), "Text");
    }
}