feat: add feature webhook event

Author: Fleeym

src/database/repository/mods.rs

@@ -1,6 +1,18 @@
 use crate::types::api::ApiError;
 use sqlx::PgConnection;
 
+pub async fn is_featured(id: &str, conn: &mut PgConnection) -> Result<bool, ApiError> {
+    Ok(sqlx::query!("SELECT featured FROM mods WHERE id = $1", id)
+        .fetch_optional(&mut *conn)
+        .await
+        .map_err(|e| {
+            log::error!("Failed to check if mod {} exists: {}", id, e);
+            ApiError::DbError
+        })?
+        .map(|row| row.featured)
+        .unwrap_or(false))
+}
+
 pub async fn exists(id: &str, conn: &mut PgConnection) -> Result<bool, ApiError> {
     Ok(sqlx::query!("SELECT id FROM mods WHERE id = $1", id)
         .fetch_optional(&mut *conn)

src/endpoints/mods.rs

@@ -2,6 +2,9 @@ use actix_web::{get, post, put, web, HttpResponse, Responder};
 use serde::Deserialize;
 use sqlx::Acquire;
 
+use crate::database::repository::developers;
+use crate::database::repository::mods;
+use crate::events::mod_feature::ModFeaturedEvent;
 use crate::extractors::auth::Auth;
 use crate::types::api::{create_download_link, ApiError, ApiResponse};
 use crate::types::mod_json::ModJson;
@@ -10,6 +13,7 @@ use crate::types::models::incompatibility::Incompatibility;
 use crate::types::models::mod_entity::{download_geode_file, Mod, ModUpdate};
 use crate::types::models::mod_gd_version::{GDVersionEnum, VerPlatform};
 use crate::types::models::mod_version_status::ModVersionStatusEnum;
+use crate::webhook::discord::DiscordWebhook;
 use crate::AppData;
 
 #[derive(Deserialize, Default)]
@@ -245,8 +249,10 @@ pub async fn update_mod(
         return Err(ApiError::Forbidden);
     }
     let mut pool = data.db.acquire().await.or(Err(ApiError::DbAcquireError))?;
+    let id = path.into_inner();
+    let featured = mods::is_featured(&id, &mut pool)?;
     let mut transaction = pool.begin().await.or(Err(ApiError::TransactionError))?;
-    if let Err(e) = Mod::update_mod(&path, payload.featured, &mut transaction).await {
+    if let Err(e) = Mod::update_mod(&id, payload.featured, &mut transaction).await {
         transaction
             .rollback()
             .await
@@ -258,5 +264,25 @@ pub async fn update_mod(
         .await
         .or(Err(ApiError::TransactionError))?;
 
+    if featured != payload.featured {
+        let item = Mod::get_one(&id, true, &mut pool).await?;
+        if let Some(item) = item {
+            let owner = developers::get_owner_for_mod(&id, &mut pool).await?;
+            let first_ver = item.versions.first();
+            if let Some(ver) = first_ver {
+                ModFeaturedEvent {
+                    id: item.id,
+                    name: ver.name.clone(),
+                    owner,
+                    admin: dev,
+                    base_url: data.app_url.clone(),
+                    featured: payload.featured,
+                }
+                .to_discord_webhook()
+                .send(&data.webhook_url);
+            }
+        }
+    }
+
     Ok(HttpResponse::NoContent())
 }

src/events/mod.rs

@@ -1 +1,2 @@
-pub mod mod_created;
+pub mod mod_created;
+pub mod mod_feature;

src/events/mod_feature.rs

@@ -0,0 +1,27 @@
+use crate::types::models::developer::FetchedDeveloper;
+use crate::webhook::discord::{DiscordMessage, DiscordWebhook};
+
+pub struct ModFeaturedEvent {
+    pub id: String,
+    pub name: String,
+    pub owner: FetchedDeveloper,
+    pub admin: FetchedDeveloper,
+    pub base_url: String,
+    pub featured: bool,
+}
+
+impl DiscordWebhook for ModFeaturedEvent {
+    fn to_discord_webhook(&self) -> DiscordMessage {
+        let title = match self.featured {
+            true => "Mod featured!",
+            false => "Mod unfeatured...",
+        };
+
+        DiscordMessage::new().embed(
+            title,
+            Some(&format!("https://geode-sdk.org/mods/{}\n\nOwned by: [{}](https://github.com/{})\nAction done by: [{}](https://github.com/{}))",
+                          self.id, self.owner.display_name, self.owner.username, self.admin.display_name, self.admin.username)),
+            Some(&format!("{}/v1/mods/{}/logo", self.base_url, self.id)),
+        )
+    }
+}

src/types/models/mod_entity.rs

@@ -31,6 +31,7 @@ use std::{
     io::{Cursor, Read},
     str::FromStr,
 };
+use crate::database::repository::mods;
 
 #[derive(Serialize, Debug, sqlx::FromRow)]
 pub struct Mod {
@@ -616,7 +617,8 @@ impl Mod {
             INNER JOIN mod_versions mv ON m.id = mv.mod_id
             INNER JOIN mod_version_statuses mvs ON mvs.mod_version_id = mv.id
             WHERE m.id = $1
-            AND ($2 = false OR mvs.status = 'accepted')"#,
+            AND ($2 = false OR mvs.status = 'accepted')
+            ORDER BY mv.id DESC"#,
             id,
             only_accepted
         )
@@ -824,8 +826,6 @@ impl Mod {
         featured: bool,
         pool: &mut PgConnection,
     ) -> Result<(), ApiError> {
-        use crate::database::repository::*;
-
         if !mods::exists(id, &mut *pool).await? {
             return Err(ApiError::NotFound(format!("Mod {} doesn't exist", id)));
         }