Merge pull request #40 from reddevilmidzy/log

로깅 시스템 구축

Author: reddevilmidzy

Cargo.lock

@@ -18,3 +18,6 @@ git2 = "0.20"
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 once_cell = "1.18"
+tracing = "0.1"
+tracing-subscriber = { version = "0.3", features = ["env-filter"] }
+tower-http = { version = "0.5", features = ["trace"] }

Cargo.toml

@@ -8,10 +8,15 @@ use axum::{
 use serde::Deserialize;
 use std::time::Duration;
 use tokio::net::TcpListener;
+use tower_http::trace::TraceLayer;
+use tracing::{Level, info};
+use tracing_subscriber::FmtSubscriber;
 
 async fn spawn_repository_checker(repo_url: &str, interval: Duration) {
     let repo_url = repo_url.to_string();
+    info!("Spawning repository checker for {}", repo_url);
     tokio::spawn(async move {
+        info!("Starting repository link check for {}", repo_url);
         check_repository_links(&repo_url, interval).await;
     });
 }
@@ -27,6 +32,10 @@ struct CheckRequest {
 }
 
 async fn check_handler(Json(payload): Json<CheckRequest>) -> &'static str {
+    info!(
+        "Received check request for repository: {}",
+        payload.repo_url
+    );
     let interval = Duration::from_secs(payload.interval_secs);
     spawn_repository_checker(&payload.repo_url, interval).await;
     "Repository checker started"
@@ -44,8 +53,23 @@ async fn cancel_handler(Json(payload): Json<CancelRequest>) -> &'static str {
 
 #[tokio::main]
 async fn main() {
+    FmtSubscriber::builder()
+        .with_max_level(Level::INFO)
+        .with_target(false)
+        .with_thread_ids(true)
+        .with_file(true)
+        .with_line_number(true)
+        .with_thread_names(true)
+        .with_level(true)
+        .with_ansi(true)
+        .pretty()
+        .init();
+
+    info!("Starting Queensac service...");
+
     let app = app();
     let listener = TcpListener::bind("localhost:3000").await.unwrap();
+    info!("Server listening on localhost:3000");
 
     serve(listener, app).await.unwrap();
 }
@@ -56,4 +80,5 @@ fn app() -> Router {
         .route("/health", get(health_check))
         .route("/check", post(check_handler))
         .route("/cancel", delete(cancel_handler))
+        .layer(TraceLayer::new_for_http())
 }