shors 0.13.0

Transport layer for cartridge + tarantool-module projects.
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
100
101
102
103
104
105
106
107
108
109
110
111
112

use serde::de::DeserializeOwned;
use serde::Serialize;
use std::collections::HashMap;
use std::fmt::{Display, Formatter};

#[cfg(feature = "open-api")]
pub mod openapi;
pub mod route;
pub mod server;

/// Currently tarantool/http support Http/1.0 and Http/1.1
#[derive(Debug)]
pub enum HTTPProtocol {
    HTTP10,
    HTTP11,
    HTTP20,
    HTTP30,
    Unknown,
}

impl Display for HTTPProtocol {
    fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
        match self {
            HTTPProtocol::HTTP10 => f.write_str("HTTP/1.0"),
            HTTPProtocol::HTTP11 => f.write_str("HTTP/1.1"),
            HTTPProtocol::HTTP20 => f.write_str("HTTP/2.0"),
            HTTPProtocol::HTTP30 => f.write_str("HTTP/3.0"),
            HTTPProtocol::Unknown => f.write_str("unknown"),
        }
    }
}

impl Default for HTTPProtocol {
    fn default() -> Self {
        Self::HTTP11
    }
}

impl From<[i32; 2]> for HTTPProtocol {
    fn from(proto: [i32; 2]) -> Self {
        match proto[0] {
            1 if proto[1] == 0 => HTTPProtocol::HTTP10,
            1 if proto[1] == 1 => HTTPProtocol::HTTP11,
            2 if proto[1] == 0 => HTTPProtocol::HTTP20,
            3 if proto[1] == 0 => HTTPProtocol::HTTP30,
            _ => HTTPProtocol::Unknown,
        }
    }
}

#[derive(Debug, Default)]
pub struct Peer {
    pub host: Option<String>,
    pub port: Option<u32>,
    pub family: Option<String>,
}

impl From<HashMap<String, String>> for Peer {
    fn from(mut peer: HashMap<String, String>) -> Self {
        Self {
            host: peer.remove("host"),
            port: peer.remove("port").and_then(|v| v.parse::<u32>().ok()),
            family: peer.remove("family"),
        }
    }
}

/// Http request.
#[derive(Debug, Default)]
pub struct Request {
    pub method: String,
    pub path: String,
    pub query: String,
    pub headers: HashMap<String, String>,
    pub stash: HashMap<String, String>,
    pub body: Vec<u8>,
    pub proto: HTTPProtocol,
    pub peer: Peer,
}

impl Request {
    /// Parse request body .
    pub fn parse<T: DeserializeOwned>(&self) -> Result<T, serde_json::Error> {
        serde_json::from_slice::<'_, T>(&self.body)
    }

    /// Parse request's query into given type.
    pub fn query<T: DeserializeOwned>(&self) -> Result<T, serde_qs::Error> {
        serde_qs::from_str(&self.query)
    }
}

/// Http response.
#[derive(Debug)]
pub struct Response {
    pub status: u32,
    pub headers: HashMap<String, String>,
    pub body: Vec<u8>,
}

impl<T: Serialize> From<T> for Response {
    fn from(data: T) -> Self {
        Self {
            status: 200,
            headers: HashMap::from([(
                "content-type".to_string(),
                "application/json; charset=utf8".to_string(),
            )]),
            body: serde_json::to_vec(&data).unwrap(),
        }
    }
}