diff options
author | Kjetil Orbekk <kjetil.orbekk@gmail.com> | 2017-07-12 22:58:45 -0400 |
---|---|---|
committer | Kjetil Orbekk <kjetil.orbekk@gmail.com> | 2017-07-12 22:58:45 -0400 |
commit | ba1ab61901e657903a34b0b0acecb81c12b5e0d0 (patch) | |
tree | bd9052ffb3c507a1cd27254e3134632d32e6daba /src | |
parent | e033861befa702b9110d531c4d17b40305915ffc (diff) |
add: Request logging (enabled with RUST_LOG=logger=info)
Diffstat (limited to 'src')
-rw-r--r-- | src/data.rs | 13 | ||||
-rw-r--r-- | src/lib.rs | 1 | ||||
-rw-r--r-- | src/main.rs | 16 | ||||
-rw-r--r-- | src/server.rs | 8 |
4 files changed, 26 insertions, 12 deletions
diff --git a/src/data.rs b/src/data.rs index c12db94..5674f92 100644 --- a/src/data.rs +++ b/src/data.rs @@ -68,15 +68,16 @@ pub fn new_quote(c: &Connection, date: &str, author: &str, content: &str) -> Res Ok(()) } -pub fn new_vote(c: &Connection, quote_id: i64, score: i32) -> Result<()>{ - c.execute( - r#" +pub fn new_vote(c: &Connection, quote_id: i64, score: i32) -> Result<()> { + c.execute( + r#" INSERT INTO votes (quote_id, score) VALUES (?1, ?2) "#, - &["e_id, &score])?; - info!("New vote: quote_id({}) score({})", quote_id, score); - Ok(()) + &["e_id, &score], + )?; + info!("New vote: quote_id({}) score({})", quote_id, score); + Ok(()) } pub fn approve_quote(c: &Connection, quote_id: i64) -> Result<()> { @@ -12,6 +12,7 @@ extern crate rusqlite; extern crate persistent; extern crate params; extern crate chrono; +extern crate logger; pub mod server; pub mod data; diff --git a/src/main.rs b/src/main.rs index 9d9ac05..026f610 100644 --- a/src/main.rs +++ b/src/main.rs @@ -62,11 +62,17 @@ fn main() { linoquotes_gamma::data::populate_test_db(&state.connection).unwrap(); } - linoquotes_gamma::data::new_quote(&state.connection, "2017-07-10", "orbekk", "another test") - .unwrap(); - let qid = state.connection.last_insert_rowid(); - info!("Last inserted quote: {}", qid); - linoquotes_gamma::data::approve_quote(&state.connection, qid).unwrap(); + for i in 1..1000 { + linoquotes_gamma::data::new_quote( + &state.connection, + "2017-07-10", + "orbekk", + &format!("another test {}", i), + ).unwrap(); + let qid = state.connection.last_insert_rowid(); + info!("Last inserted quote: {}", qid); + linoquotes_gamma::data::approve_quote(&state.connection, qid).unwrap(); + } linoquotes_gamma::server::serve(state, port); } diff --git a/src/server.rs b/src/server.rs index bd3e8ac..4816c33 100644 --- a/src/server.rs +++ b/src/server.rs @@ -12,6 +12,7 @@ use serde_json::Map; use params; use error::LinoError; use chrono; +use logger::Logger; #[derive(Debug)] pub struct State { @@ -80,6 +81,7 @@ fn quotes(r: &mut Request) -> IronResult<Response> { None => data::get_quotes(&state.connection, &ordering)?, } }; + let quotes = quotes.into_iter().collect::<Vec<_>>(); result.insert("quotes".to_string(), to_json("es)); Ok(Response::with(( status::Ok, @@ -95,7 +97,7 @@ fn add_get(_r: &mut Request) -> IronResult<Response> { Ok(Response::with(( status::Ok, Header(ContentType::html()), - Template::new("add", result) + Template::new("add", result), ))) } @@ -204,9 +206,13 @@ pub fn serve(state: State, port: u16) { approve: get "/approve.jsp" => approve, vote: get "/vote" => vote, ); + let (logger_before, logger_after) = Logger::new(None); + let mut chain = Chain::new(router); + chain.link_before(logger_before); chain.link_after(make_renderer()); chain.link(Write::<State>::both(state)); + chain.link_after(logger_after); let bind_address = format!("{}:{}", "::", port); let _server = Iron::new(chain).http(bind_address.as_str()); info!("Serving on {}", bind_address); |