rainmaker-components 0.1.0

Component abstractions for rainmaker
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

use std::net::{IpAddr, Ipv4Addr};

#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
pub enum HttpMethod {
    GET,
    POST,
}

#[derive(Debug)]
pub struct HttpRequest {
    pub(crate) method: HttpMethod,
    // todo: convert to stream
    pub(crate) data: Vec<u8>,
    pub(crate) url: String,
}

impl HttpRequest {
    pub fn method(&self) -> HttpMethod {
        self.method
    }

    pub fn data(&mut self) -> Vec<u8> {
        self.data.clone()
    }

    pub fn url(&self) -> String {
        self.url.clone()
    }
}

#[derive(Debug)]
pub struct HttpResponse {
    data: Vec<u8>,
}

impl HttpResponse {
    pub fn from_bytes<D>(inp: D) -> Self
    where
        D: Into<Vec<u8>>,
    {
        HttpResponse { data: inp.into() }
    }

    pub fn get_bytes_vectored(&self) -> Vec<u8> {
        self.data.clone()
    }
}

#[derive(Debug)]
pub struct HttpConfiguration {
    pub port: u16,
    pub addr: IpAddr,
}

impl Default for HttpConfiguration {
    fn default() -> Self {
        HttpConfiguration {
            #[cfg(target_os = "espidf")]
            port: 80,
            // to avoid running prog as sudo during dev
            #[cfg(target_os = "linux")]
            port: 8080,
            addr: IpAddr::V4(Ipv4Addr::new(0, 0, 0, 0)),
        }
    }
}

pub struct HttpServer<T>(pub(crate) T);