Rocket/lib/src/lib.rs

extern crate hyper;

mod method;
mod error;

pub use method::Method;
pub use error::Error;

use hyper::server::Handler as HypHandler;
use hyper::server::Request as HypRequest;
use hyper::server::Response as HypResponse;
use hyper::net::Fresh as HypFresh;
use hyper::Server;

pub type Handler = fn(Request) -> Response;

pub struct Request;
pub struct Response;

#[allow(dead_code)]
pub struct Route<'a> {
    pub method: Method,
    pub path: &'a str,
    pub handler: Handler
}

#[allow(dead_code)]
pub struct Rocket {
    address: &'static str,
    port: isize,
    // mounts: HashMap<&'static str, Route<'a>>
}

impl HypHandler for Rocket {
    fn handle<'a, 'k>(&'a self, req: HypRequest<'a, 'k>,
                      res: HypResponse<'a, HypFresh>) {
        println!("Request: {:?}", req.uri);
        res.send(b"Hello World!").unwrap();
    }
}

impl Rocket {
    pub fn new(address: &'static str, port: isize) -> Rocket {
        Rocket {
            address: address,
            port: port
        }
    }

    pub fn mount(&mut self, base: &str, routes: &[&Route]) -> &mut Self {
        println!("Mounting at {}", base);
        for route in routes {
            println!(" - Found {} route to {}", route.method, route.path);
            (route.handler)(Request);
        }

        self
    }

    pub fn mount_and_launch(mut self, base: &str, routes: &[&Route]) {
        self.mount(base, routes);
        self.launch();
    }

    pub fn launch(self) {
        let full_addr = format!("{}:{}", self.address, self.port);
        println!("🚀  Rocket is launching ({})...", full_addr);
        let _ = Server::http(full_addr.as_str()).unwrap().handle(self);
    }
}