land-sdk 0.1.4

land sdk API
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

use super::http_service::land::http::http_outgoing::{fetch_request, RequestError, RequestOptions};
use super::http_service::land::http::http_types::{self, RedirectPolicy};
use super::http::{Body, Request, Response};

impl Default for RequestOptions {
    fn default() -> Self {
        RequestOptions {
            timeout: 30,
            redirect: RedirectPolicy::Follow,
        }
    }
}

/// `fetch` is a helper function to make http request.
/// It will return a `Response` or `RequestError`.
/// 
/// # Example
/// 
/// ```no_run
/// use land_sdk::http::{fetch, Body, Error, Request, RequestOptions, Response};
/// use land_sdk::http_main;
/// 
/// #[http_main]
/// pub fn handle_request(_req: Request) -> Result<Response, Error> {
///     let fetch_request = http::Request::builder()
///         .method("GET")
///         .uri("https://www.rust-lang.org/")
///         .body(Body::from(""))
///         .unwrap();
///     let fetch_response = fetch(fetch_request, RequestOptions::default()).unwrap();
///     Ok(http::Response::builder()
///         .status(fetch_response.status())
///         .body(fetch_response.into_body())
///         .unwrap())
/// }
/// ```
/// 
pub fn fetch(req: Request, options: RequestOptions) -> Result<Response, RequestError> {
    let mut headers = vec![];
    for (key, value) in req.headers() {
        headers.push((key.to_string(), value.to_str().unwrap().to_string()));
    }
    let uri = req.uri().clone().to_string();
    let method = req.method().clone();

    let fetch_req = http_types::Request {
        headers,
        uri,
        method: method.to_string(),
        body: Some(req.body().body_handle()),
    };
    let fetch_resp = fetch_request(&fetch_req, options)?;

    let mut builder = http::Response::builder().status(fetch_resp.status);
    for (key, value) in fetch_resp.headers {
        builder = builder.header(key, value);
    }
    let resp_body = Body::from_handle(fetch_resp.body.unwrap());
    let resp = builder.body(resp_body).unwrap();

    Ok(resp)
}