thruster-server 0.8.0

The core future wrappers aroun the thruster web framework
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

use std::net::ToSocketAddrs;

use tokio;
use hyper::{Body, Response, Request, Server};
use hyper::service::{make_service_fn, service_fn};
use std::sync::Arc;

use thruster_app::app::App;
use thruster_core::context::Context;
use thruster_context::basic_hyper_context::HyperRequest;

use crate::thruster_server::ThrusterServer;

pub struct HyperServer<T: 'static + Context + Send> {
  app: App<HyperRequest, T>
}

impl<T: 'static + Context + Send> HyperServer<T> {
}

impl<T: Context<Response = Response<Body>> + Send> ThrusterServer for HyperServer<T> {
  type Context = T;
  type Response = Response<Body>;
  type Request = HyperRequest;

  fn new(app: App<Self::Request, T>) -> Self {
    HyperServer {
      app
    }
  }

  fn start(mut self, host: &str, port: u16) {
    self.app._route_parser.optimize();

    let arc_app = Arc::new(self.app);
    let addr = (host, port).to_socket_addrs().unwrap().next().unwrap();

    let mut rt = tokio::runtime::Runtime::new().unwrap();
    rt.block_on(async {
      let service = make_service_fn(|_| {
        let app = arc_app.clone();

        async {
          Ok::<_, hyper::Error>(service_fn(move |req: Request<Body>| {
            let matched = app.resolve_from_method_and_path(
              &req.method().to_string(),
              &req.uri().to_string()
            );

            let req = HyperRequest::new(req);
            app.resolve(req, matched)
          }))
        }
      });

      let server = Server::bind(&addr)
          .serve(service);

      server.await?;

      Ok::<_, hyper::Error>(())
    });
  }
}