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

use crate::http::{HttpConfiguration, HttpMethod, HttpRequest, HttpResponse, HttpServer};
use crate::protocomm::{
    protocomm_req_handler, EndpointType, ProtocommCallbackType, ProtocommSecurity,
};
use std::sync::Arc;

pub(crate) struct TransportHttpd {
    http_server: HttpServer,
}

impl TransportHttpd {
    pub(crate) fn new(config: HttpConfiguration) -> Self {
        let http_server = HttpServer::new(config).unwrap();
        Self { http_server }
    }
}

impl TransportHttpd {
    pub(crate) fn add_endpoint(
        &mut self,
        ep_name: &str,
        cb: ProtocommCallbackType,
        ep_type: EndpointType,
        sec: Arc<ProtocommSecurity>,
    ) {
        let http_server = &mut self.http_server;
        let ep = "/".to_string() + ep_name;
        http_server.add_listener(
            ep,
            HttpMethod::POST,
            Box::new(move |req| -> HttpResponse { http_callback(req, &cb, &ep_type, &sec) }),
        );
    }
}

fn http_callback(
    mut req: HttpRequest,
    cb: &ProtocommCallbackType,
    ep_type: &EndpointType,
    sec: &Arc<ProtocommSecurity>,
) -> HttpResponse {
    let url = req.url();
    let data = req.data();
    let ep = url.split_at(1).1;

    let data_ret = protocomm_req_handler(ep, &data, cb, ep_type, sec);

    HttpResponse::from_bytes(data_ret)
}