Index forum support

.env.example

@@ -14,6 +14,9 @@ GITHUB_CLIENT_SECRET=
 # Discord
 
 DISCORD_WEBHOOK_URL=
+DISCORD_BOT_TOKEN=
+DISCORD_GUILD_ID=
+DISCORD_CHANNEL_ID=
 
 # Config
 

src/config.rs

@@ -5,6 +5,7 @@ pub struct AppData {
     front_url: String,
     github: GitHubClientData,
     webhook_url: String,
+    discord: DiscordForumData,
     disable_downloads: bool,
     max_download_mb: u32,
     port: u16,
@@ -17,6 +18,13 @@ pub struct GitHubClientData {
     client_secret: String,
 }
 
+#[derive(Clone)]
+pub struct DiscordForumData {
+    guild_id: u64,
+    channel_id: u64,
+    bot_token: String,
+}
+
 pub async fn build_config() -> anyhow::Result<AppData> {
     let env_url = dotenvy::var("DATABASE_URL")?;
 
@@ -31,6 +39,15 @@ pub async fn build_config() -> anyhow::Result<AppData> {
     let github_client = dotenvy::var("GITHUB_CLIENT_ID").unwrap_or("".to_string());
     let github_secret = dotenvy::var("GITHUB_CLIENT_SECRET").unwrap_or("".to_string());
     let webhook_url = dotenvy::var("DISCORD_WEBHOOK_URL").unwrap_or("".to_string());
+    let guild_id = dotenvy::var("DISCORD_GUILD_ID")
+        .unwrap_or("0".to_string())
+        .parse::<u64>()
+        .unwrap_or(0);
+    let channel_id = dotenvy::var("DISCORD_CHANNEL_ID")
+        .unwrap_or("0".to_string())
+        .parse::<u64>()
+        .unwrap_or(0);
+    let bot_token = dotenvy::var("DISCORD_BOT_TOKEN").unwrap_or("".to_string());
     let disable_downloads =
         dotenvy::var("DISABLE_DOWNLOAD_COUNTS").unwrap_or("0".to_string()) == "1";
     let max_download_mb = dotenvy::var("MAX_MOD_FILESIZE_MB")
@@ -47,6 +64,11 @@ pub async fn build_config() -> anyhow::Result<AppData> {
             client_secret: github_secret,
         },
         webhook_url,
+        discord: DiscordForumData {
+            guild_id,
+            channel_id,
+            bot_token,
+        },
         disable_downloads,
         max_download_mb,
         port,
@@ -64,6 +86,24 @@ impl GitHubClientData {
     }
 }
 
+impl DiscordForumData {
+    pub fn is_valid(&self) -> bool {
+        self.guild_id != 0 && self.channel_id != 0 && !self.bot_token.is_empty()
+    }
+
+    pub fn guild_id(&self) -> u64 {
+        self.guild_id
+    }
+
+    pub fn channel_id(&self) -> u64 {
+        self.channel_id
+    }
+
+    pub fn bot_auth(&self) -> String {
+        format!("Bot {}", self.bot_token)
+    }
+}
+
 impl AppData {
     pub fn db(&self) -> &sqlx::postgres::PgPool {
         &self.db
@@ -85,6 +125,10 @@ impl AppData {
         &self.webhook_url
     }
 
+    pub fn discord(&self) -> &DiscordForumData {
+        &self.discord
+    }
+
     pub fn disable_downloads(&self) -> bool {
         self.disable_downloads
     }

src/endpoints/mod_versions.rs

@@ -18,6 +18,7 @@ use crate::types::models;
 use crate::webhook::discord::DiscordWebhook;
 use crate::{
     extractors::auth::Auth,
+    forum,
     types::{
         api::ApiResponse,
         mod_json::{split_version_and_compare, ModJson},
@@ -355,6 +356,8 @@ pub async fn create_version(
             .collect(),
     );
 
+    let json_version = json.version.clone();
+
     if make_accepted {
         if let Some(links) = json.links.clone() {
             mod_links::upsert(
@@ -397,6 +400,17 @@ pub async fn create_version(
 
     version.modify_metadata(data.app_url(), false);
 
+    if !make_accepted {
+        forum::discord::create_or_update_thread(
+            data.discord().clone(),
+            id,
+            json_version,
+            "".to_string(),
+            data.app_url().to_string(),
+            pool,
+        );
+    }
+
     Ok(HttpResponse::Created().json(ApiResponse {
         error: "".into(),
         payload: version,
@@ -497,6 +511,8 @@ pub async fn update_version(
 
     tx.commit().await?;
 
+    let display_name = dev.display_name.clone();
+
     if payload.status == ModVersionStatusEnum::Accepted {
         let is_update = approved_count > 0;
 
@@ -531,5 +547,16 @@ pub async fn update_version(
         }
     }
 
+    if payload.status == ModVersionStatusEnum::Accepted || payload.status == ModVersionStatusEnum::Rejected {
+        forum::discord::create_or_update_thread(
+            data.discord().clone(),
+            path.id.clone(),
+            path.version.clone(),
+            display_name,
+            data.app_url().to_string(),
+            pool
+        );
+    }
+
     Ok(HttpResponse::NoContent())
 }

src/endpoints/mods.rs

@@ -10,6 +10,7 @@ use crate::database::repository::mods;
 use crate::endpoints::ApiError;
 use crate::events::mod_feature::ModFeaturedEvent;
 use crate::extractors::auth::Auth;
+use crate::forum;
 use crate::mod_zip;
 use crate::types::api::{create_download_link, ApiResponse};
 use crate::types::mod_json::ModJson;
@@ -220,6 +221,15 @@ pub async fn create(
         i.modify_metadata(data.app_url(), false);
     }
 
+    forum::discord::create_or_update_thread(
+        data.discord().clone(),
+        json.id,
+        json.version,
+        "".to_string(),
+        data.app_url().to_string(),
+        pool
+    );
+
     Ok(HttpResponse::Created().json(ApiResponse {
         error: "".into(),
         payload: the_mod,