product-os-request 0.0.55

Product OS : Request provides a fully featured HTTP request library combining elements of reqwest and hyper for async requests with a series of helper methods to allow for easier usage depending upon your needs for one-time or repeat usage.
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
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99

//! Basic tests for the hyper implementation

#[cfg(all(feature = "std_hyper", feature = "json"))]
#[tokio::test]
async fn test_hyper_basic_get() {
    use product_os_request::{Method, ProductOSClient, ProductOSHyperClient, ProductOSRequester};

    let mut requester = ProductOSRequester::new();
    requester.set_timeout(5000);

    let mut client = ProductOSHyperClient::new();
    requester.build(&mut client);

    let request = client.new_request(Method::GET, "https://httpbin.org/get");
    let response = client.request(request).await;

    assert!(response.is_ok(), "Request should succeed");
    let response = response.unwrap();
    assert_eq!(response.status_code(), 200, "Status code should be 200");
}

#[cfg(all(feature = "std_hyper", feature = "json"))]
#[tokio::test]
async fn test_hyper_json_post() {
    use product_os_request::{Method, ProductOSClient, ProductOSHyperClient, ProductOSRequester};
    use serde_json::json;

    let mut requester = ProductOSRequester::new();
    requester.set_timeout(5000);

    let mut client = ProductOSHyperClient::new();
    requester.build(&mut client);

    let mut request = client.new_request(Method::POST, "https://httpbin.org/post");

    let json_data = json!({
        "test": "data",
        "number": 42
    });

    client.set_body_json(&mut request, json_data).await;

    let response = client.request(request).await;

    assert!(response.is_ok(), "Request should succeed");
    let response = response.unwrap();
    assert_eq!(response.status_code(), 200, "Status code should be 200");

    let json_response = client.json(response).await;
    assert!(json_response.is_ok(), "Should parse JSON response");
}

#[cfg(feature = "std_hyper")]
#[tokio::test]
async fn test_hyper_headers() {
    use product_os_request::{Method, ProductOSClient, ProductOSHyperClient, ProductOSRequester};

    let mut requester = ProductOSRequester::new();
    requester.set_timeout(5000);
    requester.add_header("X-Custom-Header", "test-value", false);

    let mut client = ProductOSHyperClient::new();
    requester.build(&mut client);

    let mut request = client.new_request(Method::GET, "https://httpbin.org/headers");
    request.add_header("X-Request-Header", "request-value", false);

    let response = client.request(request).await;

    assert!(response.is_ok(), "Request should succeed");
    let response = response.unwrap();
    assert_eq!(response.status_code(), 200, "Status code should be 200");
}

#[cfg(feature = "std_hyper")]
#[tokio::test]
async fn test_hyper_redirect() {
    use product_os_request::{
        Method, ProductOSClient, ProductOSHyperClient, ProductOSRequester, RedirectPolicy,
    };

    let mut requester = ProductOSRequester::new();
    requester.set_timeout(5000);
    requester.set_redirect_policy(RedirectPolicy::Limit(5));

    let mut client = ProductOSHyperClient::new();
    requester.build(&mut client);

    let request = client.new_request(Method::GET, "https://httpbin.org/redirect/2");
    let response = client.request(request).await;

    assert!(response.is_ok(), "Request should succeed after redirects");
    let response = response.unwrap();
    assert_eq!(
        response.status_code(),
        200,
        "Should reach final destination"
    );
}