init default logger

Author: yoshuawuyts

Cargo.toml

@@ -42,7 +42,7 @@ route-recognizer = "0.1.13"
 serde = "1.0.102"
 serde_json = "1.0.41"
 serde_qs = "0.5.0"
-femme = "1.3.0"
+femme = { path = "../../femme" }
 
 [dev-dependencies]
 async-std = { version = "1.4.0", features = ["unstable", "attributes"] }

examples/hello.rs

@@ -1,10 +1,8 @@
-use async_std::task;
-
-fn main() -> Result<(), std::io::Error> {
-    task::block_on(async {
-        let mut app = tide::new();
-        app.at("/").get(|_| async move { Ok("Hello, world!") });
-        app.listen("127.0.0.1:8080").await?;
-        Ok(())
-    })
+#[async_std::main]
+async fn main() -> Result<(), std::io::Error> {
+    tide::log::start();
+    let mut app = tide::new();
+    app.at("/").get(|_| async move { Ok("Hello, world!") });
+    app.listen("127.0.0.1:8080").await?;
+    Ok(())
 }

examples/static_file.rs

@@ -1,13 +1,9 @@
-use async_std::task;
-use tide::log;
-
-fn main() -> Result<(), std::io::Error> {
-    femme::start(log::Level::Info.to_level_filter()).unwrap();
-    task::block_on(async {
-        let mut app = tide::new();
-        app.at("/").get(|_| async move { Ok("visit /src/*") });
-        app.at("/src").serve_dir("src/")?;
-        app.listen("127.0.0.1:8080").await?;
-        Ok(())
-    })
+#[async_std::main]
+async fn main() -> Result<(), std::io::Error> {
+    tide::log::start();
+    let mut app = tide::new();
+    app.at("/").get(|_| async move { Ok("visit /src/*") });
+    app.at("/src").serve_dir("src/")?;
+    app.listen("127.0.0.1:8080").await?;
+    Ok(())
 }

src/log/mod.rs

@@ -23,4 +23,17 @@ pub use kv_log_macro::{max_level, Level};
 
 mod middleware;
 
+pub use femme::LevelFilter;
 pub use middleware::LogMiddleware;
+
+/// Start logging.
+pub fn start() {
+    femme::start();
+    crate::log::info!("Logger started", { level: "Info" });
+}
+
+/// Start logging with a log level.
+pub fn with_level(level: LevelFilter) {
+    femme::with_level(level);
+    crate::log::info!("Logger started", { level: format!("{}", level) });
+}

src/server.rs

@@ -283,9 +283,15 @@ impl<State: Send + Sync + 'static> Server<State> {
         let listener = async_std::net::TcpListener::bind(addr).await?;
 
         let addr = format!("http://{}", listener.local_addr()?);
-        log::info!("Server is listening on: {}", addr);
-        let mut incoming = listener.incoming();
+        let tls = false;
+        let target = if cfg!(debug_assertions) {
+            "dev"
+        } else {
+            "release"
+        };
+        log::info!("Server listening", { address: addr, target: target, tls: tls });
 
+        let mut incoming = listener.incoming();
         while let Some(stream) = incoming.next().await {
             let stream = stream?;
             let addr = addr.clone();