naught 0.1.0-dev

TBA
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

extern crate futures;
extern crate hyper;
extern crate tokio_sync;

use futures::prelude::*;
use tokio_sync::mpsc;

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

use crate::node::Node;
use crate::service::*;

pub struct Server {}

impl Server {
    pub fn new() -> Server {
        Server {}
    }

    pub fn listen(&self, node: Node, port: u16, host: &str) -> Result<(), crate::error::Error> {
        let ip_addr: IpAddr = host.parse().map_err(|err| crate::error::Error::from(err))?;
        let bind_addr: SocketAddr = SocketAddr::new(ip_addr, port);

        let builder = hyper::Server::bind(&bind_addr);

        let (request_tx, request_rx) = mpsc::unbounded_channel();

        let server = builder
            .serve(move || RPCService::new(request_tx.clone()))
            .from_err();

        let rpc = RPCService::forward_rpc(request_rx, node);

        hyper::rt::run(
            server
                .join(rpc)
                .map(|_| ())
                .map_err(move |err: crate::error::Error| {
                    eprintln!("Got error: {:#?}", err);
                }),
        );

        Ok(())
    }
}

impl Default for Server {
    fn default() -> Self {
        Server::new()
    }
}