diff options
Diffstat (limited to 'src/bin/main.rs')
-rw-r--r-- | src/bin/main.rs | 121 |
1 files changed, 3 insertions, 118 deletions
diff --git a/src/bin/main.rs b/src/bin/main.rs index 36463a6..b54c4c0 100644 --- a/src/bin/main.rs +++ b/src/bin/main.rs @@ -1,127 +1,12 @@ // CSRF protection // https://github.com/heartsucker/iron-csrf #[macro_use] -extern crate iron; -#[macro_use] extern crate log; -#[macro_use] -extern crate router; -extern crate env_logger; extern crate systemhttp; -extern crate iron_sessionstorage; -extern crate staticfile; -extern crate regex; - -use iron_sessionstorage::traits::*; -use iron_sessionstorage::SessionStorage; -use iron_sessionstorage::backends::SignedCookieBackend; -use iron::status; -use iron::modifiers::Header; -use iron::headers::ContentType; -use iron::{Iron, Request, IronResult, Response, Chain}; -use router::Router; -use systemhttp::systemd::unit; -use systemhttp::systemd::journal; -use systemhttp::render; -use staticfile::Static; -use regex::Regex; - -struct Aaa(String); - -impl iron_sessionstorage::Value for Aaa { - fn get_key() -> &'static str { - "aaa" - } - fn into_raw(self) -> String { - self.0 - } - fn from_raw(v: String) -> Option<Self> { - Some(Aaa(v)) - } -} - -fn overview(r: &mut Request) -> IronResult<Response> { - let mut _value = match try!(r.session().get::<Aaa>()) { - Some(aaa) => aaa, - None => Aaa("".to_owned()), - }; - - let name = r.extensions - .get::<Router>() - .unwrap() - .find("name") - .unwrap_or("World").to_owned(); - - let units = unit::get_units("*").unwrap(); - - let sections = ["service", "timer", "socket", "target", "slice", "mount", - "path"]; - let units_by_section = sections.iter().map(|&s| { - (s.to_owned(), - units.iter().filter(|&u| &u.type_ == s).collect::<Vec<&unit::Unit>>()) - }).collect::<Vec<_>>(); - - // let res = Ok(Response::with((status::Ok, - // Header(ContentType::html()), - // render_message(&format!("Hello, {} ({})", - // name, - // session_value.0), - // &units)))); - - // info!("Updating session value. Current value: {}", session_value.0); - // session_value.0.push('a'); - // try!(r.session().set(session_value)); - Ok(Response::with((status::Ok, - Header(ContentType::html()), - render::system_status(&units_by_section)))) -} - -fn journal(r: &mut Request) -> IronResult<Response> { - let unit = iexpect!(r.extensions - .get::<Router>() - .unwrap() - .find("unit"), status::BadRequest); - let re = Regex::new(r"[-_\w\d]*").unwrap(); - if !re.is_match(unit) { - return Ok(Response::with( - (status::BadRequest, - format!("Unit ({}) does not match {}", - unit, re)))); - } - Ok(Response::with((status::Ok, - itry!(journal::get_log(unit, 100))))) -} - -fn unit_status(r: &mut Request) -> IronResult<Response> { - let unit_name = iexpect!(r.extensions - .get::<Router>() - .unwrap() - .find("unit"), status::BadRequest); - let re = Regex::new(r"[-_\w\d]*").unwrap(); - if !re.is_match(unit_name) { - return Ok(Response::with( - (status::BadRequest, - format!("Unit ({}) does not match {}", - unit_name, re)))); - } - let ref unit = itry!(unit::get_units(unit_name))[0]; - let log = itry!(journal::get_log(unit_name, 15)); - Ok(Response::with((status::Ok, - Header(ContentType::html()), - render::unit_status(&unit, &log)))) -} +extern crate env_logger; fn main() { env_logger::init().unwrap(); - let secret = b"secret2".to_vec(); - let router = router!( - root: get "/" => overview, - details: get "/status/:unit" => unit_status, - journal: get "/journal/:unit" => journal, - css: get "/static/main.css" => Static::new(""), - ); - let mut chain = Chain::new(router); - chain.link_around(SessionStorage::new(SignedCookieBackend::new(secret))); - let _server = Iron::new(chain).http(":::8080").unwrap(); - println!("On 8080"); + let _server = systemhttp::server::serve(8080).unwrap(); + println!("Serving on {}", 8080); } |