Merge pull request #29 from reddevilmidzy/refactor

코드 재구성

Author: reddevilmidzy

Cargo.lock

@@ -14,3 +14,5 @@ regex = "1"
 reqwest = { version = "0.12", features = ["json"] }
 tokio = { version = "1", features = ["full"] }
 git2 = "0.20"
+serde = { version = "1.0", features = ["derive"] }
+serde_json = "1.0"

Cargo.toml

@@ -0,0 +1,7 @@
+pub mod git;
+pub mod link;
+pub mod schedule;
+
+pub use git::*;
+pub use link::*;
+pub use schedule::*;

src/lib.rs

@@ -1,26 +1,48 @@
-mod git;
-mod link;
-mod schedule;
+use queensac::check_repository_links;
 
-use crate::schedule::check_repository_links;
-use axum::{Router, routing::get};
+use axum::{
+    Json, Router,
+    routing::{get, post},
+    serve,
+};
+use serde::Deserialize;
 use std::time::Duration;
+use tokio::net::TcpListener;
+
+async fn spawn_repository_checker(repo_url: &str, interval: Duration) {
+    let repo_url = repo_url.to_string();
+    tokio::spawn(async move {
+        check_repository_links(&repo_url, interval).await;
+    });
+}
 
 async fn health_check() -> &'static str {
     "OK"
 }
 
+#[derive(Deserialize)]
+struct CheckRequest {
+    repo_url: String,
+    interval_secs: u64,
+}
+
+async fn check_handler(Json(payload): Json<CheckRequest>) -> &'static str {
+    let interval = Duration::from_secs(payload.interval_secs);
+    spawn_repository_checker(&payload.repo_url, interval).await;
+    "Repository checker started"
+}
+
 #[tokio::main]
 async fn main() {
-    let app = Router::new().route("/check", get(health_check));
+    let app = app();
+    let listener = TcpListener::bind("localhost:3000").await.unwrap();
 
-    let listener = tokio::net::TcpListener::bind("localhost:3000")
-        .await
-        .unwrap();
-
-    let repo_url = "https://github.com/reddevilmidzy/redddy-action";
-    let interval_duration = Duration::from_secs(60);
-    let _repo_check = check_repository_links(repo_url, interval_duration);
+    serve(listener, app).await.unwrap();
+}
 
-    axum::serve(listener, app).await.unwrap();
+fn app() -> Router {
+    Router::new()
+        .route("/", get(|| async { "Sacrifice the Queen!!" }))
+        .route("/health", get(health_check))
+        .route("/check", post(check_handler))
 }

src/main.rs

@@ -1,3 +1,6 @@
+// TODO: Review the usage of the 'link' and 'git' modules in this file.
+//       Verify if their usage aligns with the intended design and functionality.
+//       If necessary, refer to issue #123 for further context and discussion.
 use crate::git;
 use crate::link::{LinkCheckResult, check_link};
 use chrono::Local;