Fix mod msg status (#896)

* Fix mod msg status

* Fix validators

src/lib.rs

@@ -13,17 +13,17 @@ use tokio::sync::RwLock;
 
 extern crate clickhouse as clickhouse_crate;
 use clickhouse_crate::Client;
-use governor::{Quota, RateLimiter};
 use governor::middleware::StateInformationMiddleware;
+use governor::{Quota, RateLimiter};
 use util::cors::default_cors;
 
 use crate::queue::moderation::AutomatedModerationQueue;
+use crate::util::ratelimit::KeyedRateLimiter;
 use crate::{
     queue::payouts::process_payout,
     search::indexing::index_projects,
     util::env::{parse_strings_from_var, parse_var},
 };
-use crate::util::ratelimit::KeyedRateLimiter;
 
 pub mod auth;
 pub mod clickhouse;

src/main.rs

@@ -1,17 +1,13 @@
 use actix_web::{App, HttpServer};
 use actix_web_prom::PrometheusMetricsBuilder;
 use env_logger::Env;
-use governor::middleware::StateInformationMiddleware;
-use governor::{Quota, RateLimiter};
 use labrinth::database::redis::RedisPool;
 use labrinth::file_hosting::S3Host;
 use labrinth::search;
-use labrinth::util::ratelimit::{KeyedRateLimiter, RateLimit};
+use labrinth::util::ratelimit::RateLimit;
 use labrinth::{check_env_vars, clickhouse, database, file_hosting, queue};
 use log::{error, info};
-use std::num::NonZeroU32;
 use std::sync::Arc;
-use std::time::Duration;
 
 #[cfg(feature = "jemalloc")]
 #[global_allocator]
@@ -98,7 +94,7 @@ async fn main() -> std::io::Result<()> {
 
     let search_config = search::SearchConfig::new(None);
 
-    let mut labrinth_config = labrinth::app_setup(
+    let labrinth_config = labrinth::app_setup(
         pool.clone(),
         redis_pool.clone(),
         search_config.clone(),

src/routes/v3/projects.rs

@@ -453,7 +453,7 @@ pub async fn project_edit(
                         old_status: project_item.inner.status,
                     },
                     thread_id: project_item.thread_id,
-                    hide_identity: true,
+                    hide_identity: user.role.is_mod(),
                 }
                 .insert(&mut transaction)
                 .await?;

src/routes/v3/reports.rs

@@ -435,7 +435,7 @@ pub async fn report_edit(
                     MessageBody::ThreadClosure
                 },
                 thread_id: report.thread_id,
-                hide_identity: true,
+                hide_identity: user.role.is_mod(),
             }
             .insert(&mut transaction)
             .await?;

src/routes/v3/teams.rs

@@ -569,6 +569,7 @@ pub async fn add_team_member(
 
     transaction.commit().await?;
     TeamMember::clear_cache(team_id, &redis).await?;
+    User::clear_project_cache(&[new_member.user_id.into()], &redis).await?;
 
     Ok(HttpResponse::NoContent().body(""))
 }

src/scheduler.rs

@@ -19,9 +19,9 @@ impl Scheduler {
     }
 
     pub fn run<F, R>(&mut self, interval: std::time::Duration, mut task: F)
-        where
+    where
-            F: FnMut() -> R + Send + 'static,
+        F: FnMut() -> R + Send + 'static,
-            R: std::future::Future<Output = ()> + Send + 'static,
+        R: std::future::Future<Output = ()> + Send + 'static,
     {
         let future = IntervalStream::new(actix_rt::time::interval(interval))
             .for_each_concurrent(2, move |_| task());
@@ -207,4 +207,4 @@ async fn update_versions(
     }
 
     Ok(())
-}
+}

src/validate/datapack.rs

@@ -9,10 +9,6 @@ impl super::Validator for DataPackValidator {
         &["zip"]
     }
 
-    fn get_project_types(&self) -> &[&str] {
-        &["mod"]
-    }
-
     fn get_supported_loaders(&self) -> &[&str] {
         &["datapack"]
     }

src/validate/fabric.rs

@@ -10,10 +10,6 @@ impl super::Validator for FabricValidator {
         &["jar", "zip"]
     }
 
-    fn get_project_types(&self) -> &[&str] {
-        &["mod"]
-    }
-
     fn get_supported_loaders(&self) -> &[&str] {
         &["fabric"]
     }

src/validate/forge.rs

@@ -10,10 +10,6 @@ impl super::Validator for ForgeValidator {
         &["jar", "zip"]
     }
 
-    fn get_project_types(&self) -> &[&str] {
-        &["mod"]
-    }
-
     fn get_supported_loaders(&self) -> &[&str] {
         &["forge"]
     }
@@ -47,10 +43,6 @@ impl super::Validator for LegacyForgeValidator {
         &["jar", "zip"]
     }
 
-    fn get_project_types(&self) -> &[&str] {
-        &["mod"]
-    }
-
     fn get_supported_loaders(&self) -> &[&str] {
         &["forge"]
     }
@@ -71,15 +63,13 @@ impl super::Validator for LegacyForgeValidator {
 
     fn validate(
         &self,
-        archive: &mut ZipArchive<Cursor<bytes::Bytes>>,
+        _archive: &mut ZipArchive<Cursor<bytes::Bytes>>,
     ) -> Result<ValidationResult, ValidationError> {
-        if archive.by_name("mcmod.info").is_err() {
+        // if archive.by_name("mcmod.info").is_err() {
-            return Ok(ValidationResult::Warning(
+        //     return Ok(ValidationResult::Warning(
-                "Forge mod file does not contain mcmod.info!",
+        //         "Forge mod file does not contain mcmod.info!",
-            ));
+        //     ));
-        };
+        // };
-
-        //TODO: Check if file is a dev JAR?
 
         Ok(ValidationResult::Pass)
     }

src/validate/liteloader.rs

@@ -9,10 +9,6 @@ impl super::Validator for LiteLoaderValidator {
         &["litemod", "jar"]
     }
 
-    fn get_project_types(&self) -> &[&str] {
-        &["mod"]
-    }
-
     fn get_supported_loaders(&self) -> &[&str] {
         &["liteloader"]
     }

src/validate/mod.rs

@@ -77,7 +77,6 @@ pub enum SupportedGameVersions {
 
 pub trait Validator: Sync {
     fn get_file_extensions(&self) -> &[&str];
-    fn get_project_types(&self) -> &[&str];
     fn get_supported_loaders(&self) -> &[&str];
     fn get_supported_game_versions(&self) -> SupportedGameVersions;
     fn validate(
@@ -118,41 +117,28 @@ pub async fn validate_file(
     transaction: &mut sqlx::Transaction<'_, sqlx::Postgres>,
     redis: &RedisPool,
 ) -> Result<ValidationResult, ValidationError> {
-    // TODO: This needs to be revisited or removed with v3.
+    let game_versions = version_fields
-    // Currently, it checks if the loader is the modpack loader, and extracts the pack data from it.
+        .into_iter()
-    // This (and the funnction that calls this) should be refactored such that
+        .find_map(|v| MinecraftGameVersion::try_from_version_field(&v).ok())
-    // - validators are removed (or altogether reworked)
+        .unwrap_or_default();
-    // - if a mrpack is uploaded, the pack data is extracted and usable to extract dependencies automatically
+    let all_game_versions =
+        MinecraftGameVersion::list(None, None, &mut *transaction, redis).await?;
 
-    // TODO: A test needs to be written for this.
+    validate_minecraft_file(
-    match loaders {
+        data,
-        loaders if loaders == vec![Loader("mrpack".to_string())] => {
+        file_extension,
-            let game_versions = version_fields
+        loaders,
-                .into_iter()
+        game_versions,
-                .find_map(|v| MinecraftGameVersion::try_from_version_field(&v).ok())
+        all_game_versions,
-                .unwrap_or_default();
+        file_type,
-            let all_game_versions =
+    )
-                MinecraftGameVersion::list(None, None, &mut *transaction, redis).await?;
+    .await
-            validate_minecraft_file(
-                data,
-                file_extension,
-                "modpack".to_string(),
-                loaders,
-                game_versions,
-                all_game_versions,
-                file_type,
-            )
-            .await
-        }
-        _ => Ok(ValidationResult::Pass),
-    }
 }
 
 async fn validate_minecraft_file(
     data: bytes::Bytes,
     file_extension: String,
-    mut project_type: String,
+    loaders: Vec<Loader>,
-    mut loaders: Vec<Loader>,
     game_versions: Vec<MinecraftGameVersion>,
     all_game_versions: Vec<MinecraftGameVersion>,
     file_type: Option<FileType>,
@@ -164,19 +150,18 @@ async fn validate_minecraft_file(
         if let Some(file_type) = file_type {
             match file_type {
                 FileType::RequiredResourcePack | FileType::OptionalResourcePack => {
-                    project_type = "resourcepack".to_string();
+                    return PackValidator.validate(&mut zip);
-                    loaders = vec![Loader("minecraft".to_string())];
                 }
                 FileType::Unknown => {}
             }
         }
 
         let mut visited = false;
+        let mut saved_result = None;
         for validator in VALIDATORS {
-            if validator.get_project_types().contains(&&*project_type)
+            if loaders
-                && loaders
+                .iter()
-                    .iter()
+                .any(|x| validator.get_supported_loaders().contains(&&*x.0))
-                    .any(|x| validator.get_supported_loaders().contains(&&*x.0))
                 && game_version_supported(
                     &game_versions,
                     &all_game_versions,
@@ -184,13 +169,30 @@ async fn validate_minecraft_file(
                 )
             {
                 if validator.get_file_extensions().contains(&&*file_extension) {
-                    return validator.validate(&mut zip);
+                    let result = validator.validate(&mut zip)?;
+                    match result {
+                        ValidationResult::PassWithPackDataAndFiles { .. } => {
+                            saved_result = Some(result);
+                        }
+                        ValidationResult::Pass => {
+                            if saved_result.is_none() {
+                                saved_result = Some(result);
+                            }
+                        }
+                        ValidationResult::Warning(_) => {
+                            return Ok(result);
+                        }
+                    }
                 } else {
                     visited = true;
                 }
             }
         }
 
+        if let Some(result) = saved_result {
+            return Ok(result);
+        }
+
         if visited {
             if ALWAYS_ALLOWED_EXT.contains(&&*file_extension) {
                 Ok(ValidationResult::Warning(

src/validate/modpack.rs

@@ -13,12 +13,8 @@ impl super::Validator for ModpackValidator {
         &["mrpack"]
     }
 
-    fn get_project_types(&self) -> &[&str] {
-        &["modpack"]
-    }
-
     fn get_supported_loaders(&self) -> &[&str] {
-        &["forge", "fabric", "quilt", "mrpack"]
+        &["mrpack"]
     }
 
     fn get_supported_game_versions(&self) -> SupportedGameVersions {

src/validate/plugin.rs

@@ -9,10 +9,6 @@ impl super::Validator for PluginYmlValidator {
         &["zip", "jar"]
     }
 
-    fn get_project_types(&self) -> &[&str] {
-        &["mod"]
-    }
-
     fn get_supported_loaders(&self) -> &[&str] {
         &["bukkit", "spigot", "paper", "purpur"]
     }
@@ -45,10 +41,6 @@ impl super::Validator for BungeeCordValidator {
         &["zip", "jar"]
     }
 
-    fn get_project_types(&self) -> &[&str] {
-        &["mod"]
-    }
-
     fn get_supported_loaders(&self) -> &[&str] {
         &["bungeecord", "waterfall"]
     }
@@ -81,10 +73,6 @@ impl super::Validator for VelocityValidator {
         &["zip", "jar"]
     }
 
-    fn get_project_types(&self) -> &[&str] {
-        &["mod"]
-    }
-
     fn get_supported_loaders(&self) -> &[&str] {
         &["velocity"]
     }
@@ -114,10 +102,6 @@ impl super::Validator for SpongeValidator {
         &["zip", "jar"]
     }
 
-    fn get_project_types(&self) -> &[&str] {
-        &["mod"]
-    }
-
     fn get_supported_loaders(&self) -> &[&str] {
         &["sponge"]
     }

src/validate/quilt.rs

@@ -10,10 +10,6 @@ impl super::Validator for QuiltValidator {
         &["jar", "zip"]
     }
 
-    fn get_project_types(&self) -> &[&str] {
-        &["mod"]
-    }
-
     fn get_supported_loaders(&self) -> &[&str] {
         &["quilt"]
     }

src/validate/resourcepack.rs

@@ -10,10 +10,6 @@ impl super::Validator for PackValidator {
         &["zip"]
     }
 
-    fn get_project_types(&self) -> &[&str] {
-        &["resourcepack"]
-    }
-
     fn get_supported_loaders(&self) -> &[&str] {
         &["minecraft"]
     }
@@ -47,10 +43,6 @@ impl super::Validator for TexturePackValidator {
         &["zip"]
     }
 
-    fn get_project_types(&self) -> &[&str] {
-        &["resourcepack"]
-    }
-
     fn get_supported_loaders(&self) -> &[&str] {
         &["minecraft"]
     }

src/validate/shader.rs

@@ -9,10 +9,6 @@ impl super::Validator for ShaderValidator {
         &["zip"]
     }
 
-    fn get_project_types(&self) -> &[&str] {
-        &["shader"]
-    }
-
     fn get_supported_loaders(&self) -> &[&str] {
         &["optifine", "iris"]
     }
@@ -42,10 +38,6 @@ impl super::Validator for CanvasShaderValidator {
         &["zip"]
     }
 
-    fn get_project_types(&self) -> &[&str] {
-        &["shader"]
-    }
-
     fn get_supported_loaders(&self) -> &[&str] {
         &["canvas"]
     }
@@ -81,10 +73,6 @@ impl super::Validator for CoreShaderValidator {
         &["zip"]
     }
 
-    fn get_project_types(&self) -> &[&str] {
-        &["shader"]
-    }
-
     fn get_supported_loaders(&self) -> &[&str] {
         &["vanilla"]
     }