feat: implement commit tracking and Discord notifications

- Added core modules for configuration, commit tracking, and Discord notifications.
- Introduced models for commit information and Discord embed structure.
- Created services for scraping commit data and sending notifications.
- Refactored main application logic to utilize the new tracking system.

Author: kWAYTV

src/core/config.rs

@@ -0,0 +1,26 @@
+#[derive(Debug, Clone)]
+pub struct Config {
+    pub discord_webhook_url: String,
+    pub commits_url: String,
+    pub check_interval_secs: u64,
+    pub rust_color: u32,
+    pub footer_icon_url: String,
+}
+
+impl Config {
+    pub fn new() -> Self {
+        Self {
+            discord_webhook_url: "https://discord.com/api/webhooks/1377062435000680469/p8IPNirCl90kWHSpmX-YMEDxeNKdaGOUtofNY_jSX_B-w_3vMSXymIaKuvVVP71Xtlnq".to_string(),
+            commits_url: "https://commits.facepunch.com/r/rust_reboot".to_string(),
+            check_interval_secs: 50,
+            rust_color: 0xCD412B,
+            footer_icon_url: "https://i.imgur.com/on47Qk9.png".to_string(),
+        }
+    }
+}
+
+impl Default for Config {
+    fn default() -> Self {
+        Self::new()
+    }
+} 

src/core/mod.rs

@@ -0,0 +1,5 @@
+pub mod config;
+pub mod tracker;
+
+pub use config::*;
+pub use tracker::*; 

src/core/tracker.rs

@@ -0,0 +1,62 @@
+use crate::core::Config;
+use crate::services::{CommitScraper, DiscordNotifier};
+use log::{info, error};
+use std::error::Error;
+use std::time::Duration;
+use tokio::time::sleep;
+
+pub struct CommitTracker {
+    config: Config,
+    scraper: CommitScraper,
+    notifier: DiscordNotifier,
+    last_commit_id: i32,
+}
+
+impl CommitTracker {
+    pub fn new() -> Self {
+        let config = Config::new();
+        let scraper = CommitScraper::new();
+        let notifier = DiscordNotifier::new(config.clone());
+
+        Self {
+            config,
+            scraper,
+            notifier,
+            last_commit_id: 0,
+        }
+    }
+
+    pub async fn start(&mut self) -> Result<(), Box<dyn Error>> {
+        info!("🚀 Rust commit tracker started - monitoring Facepunch commits");
+
+        loop {
+            if let Err(e) = self.check_for_new_commits().await {
+                error!("❌ {}", e);
+            }
+
+            sleep(Duration::from_secs(self.config.check_interval_secs)).await;
+        }
+    }
+
+    async fn check_for_new_commits(&mut self) -> Result<(), Box<dyn Error>> {
+        let commit = self.scraper.fetch_latest_commit(&self.config.commits_url).await?;
+
+        if commit.id > self.last_commit_id {
+            self.last_commit_id = commit.id;
+            
+            info!("🆕 New commit #{} by {} - {}", commit.id, commit.author, commit.message);
+            
+            self.notifier.send_commit_notification(&commit).await?;
+            
+            info!("✅ Sent to Discord");
+        }
+
+        Ok(())
+    }
+}
+
+impl Default for CommitTracker {
+    fn default() -> Self {
+        Self::new()
+    }
+} 

src/lib.rs

@@ -0,0 +1,7 @@
+pub mod core;
+pub mod models;
+pub mod services;
+
+pub use core::*;
+pub use models::*;
+pub use services::{CommitScraper, DiscordNotifier}; 

src/main.rs

@@ -1,14 +1,5 @@
-use reqwest;
-use scraper::{Html, Selector};
-use regex::Regex;
-use serde_json::json;
-use std::time::Duration;
-use tokio::time::sleep;
-use chrono;
-use log::{info, error};
-
-const DISCORD_WEBHOOK_URL: &str = "WEBHOOK_URL";
-const COMMITS_URL: &str = "https://commits.facepunch.com/r/rust_reboot";
+use rust_commit_tracker::CommitTracker;
+use log::error;
 
 #[tokio::main]
 async fn main() {
@@ -18,186 +9,9 @@ async fn main() {
         .format_timestamp_secs()
         .init();
 
-    info!("🚀 Rust commit tracker started - monitoring Facepunch commits");
-
-    let mut last_commit_id: i32 = 0;
-    let client = reqwest::Client::new();
-
-    loop {
-        match fetch_and_process_commits(&client, &mut last_commit_id).await {
-            Ok(_) => {},
-            Err(e) => {
-                error!("❌ {}", e);
-            }
-        }
-
-        sleep(Duration::from_secs(50)).await;
+    let mut tracker = CommitTracker::new();
+    
+    if let Err(e) = tracker.start().await {
+        error!("❌ Fatal error: {}", e);
     }
 }
-
-async fn fetch_and_process_commits(
-    client: &reqwest::Client,
-    last_commit_id: &mut i32,
-) -> Result<(), Box<dyn std::error::Error>> {
-    // Request the page
-    let response = client.get(COMMITS_URL).send().await?;
-    let html_content = response.text().await?;
-    let document = Html::parse_document(&html_content);
-
-    // Find the first commit
-    let commit_selector = Selector::parse("div.commit.columns")?;
-    let commit = document
-        .select(&commit_selector)
-        .next()
-        .ok_or("No commit found")?;
-
-    // Extract the commit id
-    let like_id = commit
-        .value()
-        .attr("like-id")
-        .ok_or("No like-id attribute found")?;
-    let commit_id: i32 = like_id.parse()?;
-
-    // If this is a new commit
-    if commit_id > *last_commit_id {
-        // Update the last commit id
-        *last_commit_id = commit_id;
-
-        // Extract the commit details
-        let author_selector = Selector::parse("div.author")?;
-        let author = commit
-            .select(&author_selector)
-            .next()
-            .ok_or("No author found")?
-            .text()
-            .collect::<String>();
-
-        let repo_selector = Selector::parse("span.repo")?;
-        let repo = commit
-            .select(&repo_selector)
-            .next()
-            .ok_or("No repo found")?
-            .text()
-            .collect::<String>();
-
-        let branch_selector = Selector::parse("span.branch")?;
-        let branch = commit
-            .select(&branch_selector)
-            .next()
-            .ok_or("No branch found")?
-            .text()
-            .collect::<String>();
-
-        let changeset_selector = Selector::parse("span.changeset")?;
-        let changeset = commit
-            .select(&changeset_selector)
-            .next()
-            .ok_or("No changeset found")?
-            .text()
-            .collect::<String>();
-        
-        // Build changeset link using commit ID
-        let changeset_link = format!("https://commits.facepunch.com/{}", commit_id);
-
-        let message_selector = Selector::parse("div.commits-message")?;
-        let commit_message = commit
-            .select(&message_selector)
-            .next()
-            .ok_or("No commit message found")?
-            .text()
-            .collect::<String>();
-
-        info!("🆕 New commit #{} by {} - {}", commit_id, author.trim(), commit_message.trim());
-
-        // Extract avatar URL
-        let avatar_selector = Selector::parse("div.avatar")?;
-        let avatar_element = commit
-            .select(&avatar_selector)
-            .next()
-            .ok_or("No avatar found")?;
-        
-        let avatar_html = avatar_element.html();
-        let url_regex = Regex::new(r"(https?://[^\s]+)")?;
-        let avatar_url = url_regex
-            .find(&avatar_html)
-            .ok_or("No URL found in avatar")?
-            .as_str()
-            .trim_end_matches("');")
-            .to_string();
-
-        // Send to Discord webhook
-        send_discord_webhook(
-            client,
-            &author,
-            &repo,
-            &branch,
-            &changeset,
-            &changeset_link,
-            &commit_message,
-            &avatar_url,
-        ).await?;
-        
-        info!("✅ Sent to Discord");
-    }
-
-    Ok(())
-}
-
-async fn send_discord_webhook(
-    client: &reqwest::Client,
-    author: &str,
-    repo: &str,
-    branch: &str,
-    changeset: &str,
-    changeset_link: &str,
-    commit_message: &str,
-    avatar_url: &str,
-) -> Result<(), Box<dyn std::error::Error>> {
-    let embed = json!({
-        "embeds": [{
-            "title": "🔧 New Rust Commit",
-            "description": format!("```\n{}\n```", commit_message.trim()),
-            "color": 0xCD412B, // Rust orange color
-            "author": {
-                "name": author.trim(),
-                "url": "https://commits.facepunch.com/r/rust_reboot",
-                "icon_url": avatar_url
-            },
-            "fields": [
-                {
-                    "name": "📁 Repository",
-                    "value": format!("`{}`", repo.trim()),
-                    "inline": true
-                },
-                {
-                    "name": "🌿 Branch", 
-                    "value": format!("`{}`", branch.trim()),
-                    "inline": true
-                },
-                {
-                    "name": "🔗 Changeset",
-                    "value": format!("[`{}`]({})", changeset.trim(), changeset_link.trim()),
-                    "inline": true
-                }
-            ],
-            "footer": {
-                "text": "Facepunch Rust Commits",
-                "icon_url": "https://i.imgur.com/on47Qk9.png"
-            },
-            "timestamp": chrono::Utc::now().to_rfc3339()
-        }]
-    });
-
-    let response = client
-        .post(DISCORD_WEBHOOK_URL)
-        .header("Content-Type", "application/json")
-        .json(&embed)
-        .send()
-        .await?;
-
-    if !response.status().is_success() {
-        return Err(format!("Discord webhook failed with status: {}", response.status()).into());
-    }
-
-    Ok(())
-}

src/models/commit.rs

@@ -0,0 +1,11 @@
+#[derive(Debug, Clone)]
+pub struct CommitInfo {
+    pub id: i32,
+    pub author: String,
+    pub repo: String,
+    pub branch: String,
+    pub changeset: String,
+    pub message: String,
+    pub avatar_url: String,
+    pub link: String,
+} 

src/models/discord.rs

@@ -0,0 +1,37 @@
+use serde::Serialize;
+
+#[derive(Debug, Serialize)]
+pub struct DiscordEmbed {
+    pub embeds: Vec<EmbedData>,
+}
+
+#[derive(Debug, Serialize)]
+pub struct EmbedData {
+    pub title: String,
+    pub description: String,
+    pub color: u32,
+    pub author: EmbedAuthor,
+    pub fields: Vec<EmbedField>,
+    pub footer: EmbedFooter,
+    pub timestamp: String,
+}
+
+#[derive(Debug, Serialize)]
+pub struct EmbedAuthor {
+    pub name: String,
+    pub url: String,
+    pub icon_url: String,
+}
+
+#[derive(Debug, Serialize)]
+pub struct EmbedField {
+    pub name: String,
+    pub value: String,
+    pub inline: bool,
+}
+
+#[derive(Debug, Serialize)]
+pub struct EmbedFooter {
+    pub text: String,
+    pub icon_url: String,
+} 

src/models/mod.rs

@@ -0,0 +1,5 @@
+pub mod commit;
+pub mod discord;
+
+pub use commit::*;
+pub use discord::*;