feat: use level specified in env

Author: KrLite

src/config/mod.rs

@@ -1,7 +1,8 @@
 //! Reads configs.
 
-use std::path::PathBuf;
+use std::{fmt::Debug, path::PathBuf};
 
+use config_file::FromConfigFile;
 use serde::Deserialize;
 
 use crate::env::CONFIG_DIR;
@@ -29,9 +30,33 @@ impl ConfigFile {
 }
 
 /// A trait for configs that can be deserialized.
-pub trait Config<'de>: Deserialize<'de> {
+pub trait Config<'de>: Deserialize<'de> + FromConfigFile {
     /// The [`ConfigFile`] this config corresponds to.
     fn file() -> ConfigFile;
+
+    /// Reads the config from the config file. This function wraps the error logging and returns
+    /// `None` on failure.
+    ///
+    /// See: [`FromConfigFile::from_config_file`]
+    fn read() -> Option<Self>
+    where
+        Self: Debug,
+    {
+        match Self::from_config_file(Self::file().path()) {
+            Ok(c) => {
+                tracing::trace!("read config from file {:?}: {:#?}", Self::file().path(), c);
+                Some(c)
+            }
+            Err(e) => {
+                tracing::error!(
+                    "failed to read config from file {:?}: {:?}",
+                    Self::file().path(),
+                    e
+                );
+                None
+            }
+        }
+    }
 }
 
 /// The services config.

src/endpoint/health/mod.rs

@@ -3,11 +3,10 @@
 use std::net::SocketAddr;
 
 use axum::{extract::ConnectInfo, http::StatusCode, response::IntoResponse};
-use tracing::info;
 
 /// Responds with [`StatusCode::OK`].
 pub async fn get(ConnectInfo(addr): ConnectInfo<SocketAddr>) -> impl IntoResponse {
-    info!(
+    tracing::info!(
         "service {} is healthy. responding to {addr}…",
         clap::crate_name!()
     );

src/endpoint/root.rs

@@ -9,7 +9,6 @@ use api_framework::{
 };
 
 use axum::{Json, http::StatusCode, response::IntoResponse};
-use config_file::FromConfigFile as _;
 use serde::Deserialize;
 
 use crate::{
@@ -37,13 +36,12 @@ pub struct PostPayload {
 ///
 /// See: [`PostPayload`], [`post_transaction`]
 pub async fn post(Json(payload): Json<PostPayload>) -> impl IntoResponse {
-    let services = match ServicesConfig::from_config_file(ServicesConfig::file().path()) {
-        Ok(s) => s,
-        Err(e) => {
-            tracing::error!("failed to read services config: {e:?}");
+    let services = match ServicesConfig::read() {
+        Some(s) => s,
+        None => {
             return (
                 StatusCode::INTERNAL_SERVER_ERROR,
-                format!("failed to read services config: {e:?}"),
+                "failed to read services config",
             )
                 .into_response();
         }

src/env.rs

@@ -3,6 +3,7 @@
 use std::{env, path::PathBuf};
 
 use api_framework::{parse_env, static_lazy_lock};
+use tracing::level_filters::LevelFilter;
 
 /// Sets up environment variables.
 pub fn setup() {
@@ -33,6 +34,11 @@ static_lazy_lock! {
     pub KTT_API_PASSWORD: String = env::var("KTT_API_PASSWORD").expect("KTT_API_PASSWORD not set in environment");
 }
 
+static_lazy_lock! {
+    /// The stderr level for tracing. Defaults to `INFO` if not specified.
+    pub TRACING_STDERR_LEVEL: LevelFilter = parse_env!("TRACING_STDERR_LEVEL" => |s| s.parse::<LevelFilter>(); anyhow).unwrap_or(LevelFilter::INFO);
+}
+
 static_lazy_lock! {
     /// The maximum file count to use for tracing.
     pub TRACING_MAX_FILES: usize = parse_env!("TRACING_MAX_FILES" => |s| s.parse::<usize>(); anyhow).unwrap_or(5);

src/main.rs

@@ -3,7 +3,7 @@
 #![allow(clippy::future_not_send)]
 
 use crate::env::{
-    PORT,
+    PORT, TRACING_STDERR_LEVEL,
     info::{BUILD_TIMESTAMP, GIT_HASH},
 };
 
@@ -12,7 +12,6 @@ use std::net::SocketAddr;
 use anyhow::{Error, anyhow};
 use axum::Router;
 use tokio::net::TcpListener;
-use tracing::{info, trace};
 
 mod transactions;
 
@@ -27,19 +26,20 @@ pub mod middleware;
 async fn main() {
     env::setup();
     trace::setup().unwrap();
-    trace!("loaded environment: {:#?}", std::env::vars());
+    tracing::info!("stderr is tracing on level {:?}", *TRACING_STDERR_LEVEL);
+    tracing::trace!("loaded environment: {:#?}", std::env::vars());
 
-    info!(
+    tracing::info!(
         "binary {} version {}",
         clap::crate_name!(),
         clap::crate_version!()
     );
-    info!("compiled from commit {GIT_HASH} at {BUILD_TIMESTAMP}");
-    info!("starting service on port {}…", *PORT);
+    tracing::info!("compiled from commit {GIT_HASH} at {BUILD_TIMESTAMP}");
+    tracing::info!("starting service on port {}…", *PORT);
 
     serve().await.unwrap();
 
-    info!("stopping…");
+    tracing::info!("stopping…");
 }
 
 async fn serve() -> Result<(), Error> {

src/trace.rs

@@ -8,7 +8,7 @@ use tracing_subscriber::{
     Layer as _, fmt::time::ChronoLocal, layer::SubscriberExt as _, util::SubscriberInitExt as _,
 };
 
-use crate::env::{TRACING_DIR, TRACING_MAX_FILES};
+use crate::env::{TRACING_DIR, TRACING_MAX_FILES, TRACING_STDERR_LEVEL};
 
 /// Sets up the logging component, which contains a stderr layer, a rolling file layer, and a latest file layer.
 ///
@@ -44,7 +44,7 @@ pub fn setup() -> Result<(), Error> {
         .with(
             stderr_layer
                 .with_timer(ChronoLocal::rfc_3339())
-                .with_filter(LevelFilter::INFO),
+                .with_filter(*TRACING_STDERR_LEVEL),
         )
         .with(
             rolling_file_layer