chore(docs/labrinth): fix cargo fmt parameter typo

Cargo.toml

@@ -25,31 +25,31 @@ actix-ws = "0.3.0"
 argon2 = { version = "0.5.3", features = ["std"] }
 ariadne = { path = "packages/ariadne" }
 async_zip = "0.0.17"
-async-compression = { version = "0.4.27", default-features = false }
+async-compression = { version = "0.4.25", default-features = false }
 async-recursion = "1.1.1"
 async-stripe = { version = "0.41.0", default-features = false, features = [
   "runtime-tokio-hyper-rustls",
 ] }
 async-trait = "0.1.88"
-async-tungstenite = { version = "0.30.0", default-features = false, features = [
+async-tungstenite = { version = "0.29.1", default-features = false, features = [
   "futures-03-sink",
 ] }
 async-walkdir = "2.1.0"
 base64 = "0.22.1"
 bitflags = "2.9.1"
-bytemuck = "1.23.1"
+bytemuck = "1.23.0"
 bytes = "1.10.1"
 censor = "0.3.0"
 chardetng = "0.1.17"
 chrono = "0.4.41"
-clap = "4.5.43"
+clap = "4.5.40"
 clickhouse = "0.13.3"
 color-thief = "0.2.2"
 console-subscriber = "0.4.1"
 daedalus = { path = "packages/daedalus" }
 dashmap = "6.1.0"
 data-url = "0.3.1"
-deadpool-redis = "0.22.0"
+deadpool-redis = "0.21.1"
 dirs = "6.0.0"
 discord-rich-presence = "0.2.5"
 dotenv-build = "0.1.1"
@@ -57,7 +57,7 @@ dotenvy = "0.15.7"
 dunce = "1.0.5"
 either = "1.15.0"
 encoding_rs = "0.8.35"
-enumset = "1.1.7"
+enumset = "1.1.6"
 flate2 = "1.1.2"
 fs4 = { version = "0.13.1", default-features = false }
 futures = { version = "0.3.31", default-features = false }
@@ -74,15 +74,15 @@ hyper-rustls = { version = "0.27.7", default-features = false, features = [
   "ring",
   "tls12",
 ] }
-hyper-util = "0.1.16"
+hyper-util = "0.1.14"
 iana-time-zone = "0.1.63"
 image = { version = "0.25.6", default-features = false, features = ["rayon"] }
-indexmap = "2.10.0"
+indexmap = "2.9.0"
-indicatif = "0.18.0"
+indicatif = "0.17.11"
 itertools = "0.14.0"
-jemalloc_pprof = "0.8.1"
+jemalloc_pprof = "0.7.0"
 json-patch = { version = "4.0.0", default-features = false }
-lettre = { version = "0.11.18", default-features = false, features = [
+lettre = { version = "0.11.17", default-features = false, features = [
   "builder",
   "hostname",
   "pool",
@@ -92,24 +92,24 @@ lettre = { version = "0.11.18", default-features = false, features = [
   "smtp-transport",
 ] }
 maxminddb = "0.26.0"
-meilisearch-sdk = { version = "0.29.1", default-features = false }
+meilisearch-sdk = { version = "0.28.0", default-features = false }
 murmur2 = "0.1.0"
 native-dialog = "0.9.0"
-notify = { version = "8.2.0", default-features = false }
+notify = { version = "8.0.0", default-features = false }
-notify-debouncer-mini = { version = "0.7.0", default-features = false }
+notify-debouncer-mini = { version = "0.6.0", default-features = false }
 p256 = "0.13.2"
 paste = "1.0.15"
 phf = { version = "0.12.1", features = ["macros"] }
 png = "0.17.16"
 prometheus = "0.14.0"
 quartz_nbt = "0.2.9"
-quick-xml = "0.38.1"
+quick-xml = "0.37.5"
 rand = "=0.8.5"  # Locked on 0.8 until argon2 and p256 update to 0.9
 rand_chacha = "=0.3.1"  # Locked on 0.3 until we can update rand to 0.9
-redis = "0.32.4"
+redis = "=0.31.0"  # Locked on 0.31 until deadpool-redis updates to 0.32
 regex = "1.11.1"
-reqwest = { version = "0.12.22", default-features = false }
+reqwest = { version = "0.12.20", default-features = false }
-rgb = "0.8.52"
+rgb = "0.8.50"
 rust_decimal = { version = "1.37.2", features = [
   "serde-with-float",
   "serde-with-str",
@@ -121,7 +121,7 @@ rust-s3 = { version = "0.35.1", default-features = false, features = [
   "tokio-rustls-tls",
 ] }
 rusty-money = "0.4.1"
-sentry = { version = "0.42.0", default-features = false, features = [
+sentry = { version = "0.41.0", default-features = false, features = [
   "backtrace",
   "contexts",
   "debug-images",
@@ -129,45 +129,45 @@ sentry = { version = "0.42.0", default-features = false, features = [
   "reqwest",
   "rustls",
 ] }
-sentry-actix = "0.42.0"
+sentry-actix = "0.41.0"
 serde = "1.0.219"
 serde_bytes = "0.11.17"
 serde_cbor = "0.11.2"
 serde_ini = "0.2.0"
-serde_json = "1.0.142"
+serde_json = "1.0.140"
-serde_with = "3.14.0"
+serde_with = "3.13.0"
 serde-xml-rs = "0.8.1"  # Also an XML (de)serializer, consider dropping yaserde in favor of this
 sha1 = "0.10.6"
 sha1_smol = { version = "1.0.1", features = ["std"] }
 sha2 = "0.10.9"
-spdx = "0.10.9"
+spdx = "0.10.8"
 sqlx = { version = "0.8.6", default-features = false }
-sysinfo = { version = "0.36.1", default-features = false }
+sysinfo = { version = "0.35.2", default-features = false }
 tar = "0.4.44"
-tauri = "2.7.0"
+tauri = "2.6.1"
-tauri-build = "2.3.1"
+tauri-build = "2.3.0"
-tauri-plugin-deep-link = "2.4.1"
+tauri-plugin-deep-link = "2.4.0"
-tauri-plugin-dialog = "2.3.2"
+tauri-plugin-dialog = "2.3.0"
-tauri-plugin-http = "2.5.1"
+tauri-plugin-http = "2.5.0"
 tauri-plugin-opener = "2.4.0"
 tauri-plugin-os = "2.3.0"
-tauri-plugin-single-instance = "2.3.2"
+tauri-plugin-single-instance = "2.3.0"
 tauri-plugin-updater = { version = "2.9.0", default-features = false, features = [
   "rustls-tls",
   "zip",
 ] }
-tauri-plugin-window-state = "2.4.0"
+tauri-plugin-window-state = "2.3.0"
 tempfile = "3.20.0"
 theseus = { path = "packages/app-lib" }
 thiserror = "2.0.12"
 tikv-jemalloc-ctl = "0.6.0"
 tikv-jemallocator = "0.6.0"
-tokio = "1.47.1"
+tokio = "1.45.1"
 tokio-stream = "0.1.17"
-tokio-util = "0.7.16"
+tokio-util = "0.7.15"
 totp-rs = "5.7.0"
 tracing = "0.1.41"
-tracing-actix-web = "0.7.19"
+tracing-actix-web = "0.7.18"
 tracing-error = "0.2.1"
 tracing-subscriber = "0.3.19"
 url = "2.5.4"
@@ -179,7 +179,7 @@ whoami = "1.6.0"
 winreg = "0.55.0"
 woothee = "0.13.0"
 yaserde = "0.12.0"
-zip = { version = "4.3.0", default-features = false, features = [
+zip = { version = "4.2.0", default-features = false, features = [
   "bzip2",
   "deflate",
   "deflate64",
@@ -226,7 +226,7 @@ wildcard_dependencies = "warn"
 warnings = "deny"
 
 [patch.crates-io]
-wry = { git = "https://github.com/modrinth/wry", rev = "f2ce0b0" }
+wry = { git = "https://github.com/modrinth/wry", rev = "21db186" }
 
 # Optimize for speed and reduce size on release builds
 [profile.release]

apps/app/src/api/ads.rs

@@ -197,14 +197,16 @@ pub async fn open_link<R: Runtime>(
 
     if url::Url::parse(&path).is_ok()
         && !state.malicious_origins.contains(&origin)
-        && let Some(last_click) = state.last_click
-        && last_click.elapsed() < Duration::from_millis(100)
     {
+        if let Some(last_click) = state.last_click {
+            if last_click.elapsed() < Duration::from_millis(100) {
                 let _ = app.opener().open_url(&path, None::<String>);
                 state.last_click = None;
 
                 return Ok(());
             }
+        }
+    }
 
     tracing::info!("Malicious click: {path} origin {origin}");
     state.malicious_origins.insert(origin);

apps/app/src/api/auth.rs

@@ -59,14 +59,17 @@ pub async fn login<R: Runtime>(
             .url()?
             .as_str()
             .starts_with("https://login.live.com/oauth20_desktop.srf")
-            && let Some((_, code)) =
+        {
+            if let Some((_, code)) =
                 window.url()?.query_pairs().find(|x| x.0 == "code")
             {
                 window.close()?;
-            let val = minecraft_auth::finish_login(&code.clone(), flow).await?;
+                let val =
+                    minecraft_auth::finish_login(&code.clone(), flow).await?;
 
                 return Ok(Some(val));
             }
+        }
 
         tokio::time::sleep(std::time::Duration::from_millis(50)).await;
     }

apps/app/src/api/utils.rs

@@ -63,12 +63,12 @@ pub async fn should_disable_mouseover() -> bool {
         // We try to match version to 12.2 or higher. If unrecognizable to pattern or lower, we default to the css with disabled mouseover for safety
         if let tauri_plugin_os::Version::Semantic(major, minor, _) =
             tauri_plugin_os::version()
-            && major >= 12
-            && minor >= 3
         {
+            if major >= 12 && minor >= 3 {
                 // Mac os version is 12.3 or higher, we allow mouseover
                 return false;
             }
+        }
         true
     } else {
         // Not macos, we allow mouseover

apps/app/src/main.rs

@@ -233,11 +233,11 @@ fn main() {
             });
 
             #[cfg(not(target_os = "linux"))]
-            if let Some(window) = app.get_window("main")
+            if let Some(window) = app.get_window("main") {
-                && let Err(e) = window.set_shadow(true)
+                if let Err(e) = window.set_shadow(true) {
-            {
                     tracing::warn!("Failed to set window shadow: {e}");
                 }
+            }
 
             Ok(())
         });

apps/daedalus_client/src/forge.rs

@@ -506,16 +506,17 @@ async fn fetch(
 
                             return Ok(lib);
                         }
-                    } else if let Some(url) = &lib.url
+                    } else if let Some(url) = &lib.url {
-                        && !url.is_empty()
+                        if !url.is_empty() {
-                    {
                             insert_mirrored_artifact(
                                 &lib.name,
                                 None,
                                 vec![
                                     url.clone(),
-                                "https://libraries.minecraft.net/".to_string(),
+                                    "https://libraries.minecraft.net/"
-                                "https://maven.creeperhost.net/".to_string(),
+                                        .to_string(),
+                                    "https://maven.creeperhost.net/"
+                                        .to_string(),
                                     maven_url.to_string(),
                                 ],
                                 false,
@@ -526,6 +527,7 @@ async fn fetch(
 
                             return Ok(lib);
                         }
+                    }
 
                     // Other libraries are generally available in the "maven" directory of the installer. If they are
                     // not present here, they will be generated by Forge processors.

apps/daedalus_client/src/main.rs

@@ -93,9 +93,9 @@ async fn main() -> Result<()> {
         .ok()
         .and_then(|x| x.parse::<bool>().ok())
         .unwrap_or(false)
-        && let Ok(token) = dotenvy::var("CLOUDFLARE_TOKEN")
-        && let Ok(zone_id) = dotenvy::var("CLOUDFLARE_ZONE_ID")
     {
+        if let Ok(token) = dotenvy::var("CLOUDFLARE_TOKEN") {
+            if let Ok(zone_id) = dotenvy::var("CLOUDFLARE_ZONE_ID") {
                 let cache_clears = upload_files
                     .into_iter()
                     .map(|x| format_url(&x.0))
@@ -130,6 +130,8 @@ async fn main() -> Result<()> {
                         })?;
                 }
             }
+        }
+    }
 
     Ok(())
 }

apps/daedalus_client/src/util.rs

@@ -167,18 +167,20 @@ pub async fn download_file(
                 let bytes = x.bytes().await;
 
                 if let Ok(bytes) = bytes {
-                    if let Some(sha1) = sha1
+                    if let Some(sha1) = sha1 {
-                        && &*sha1_async(bytes.clone()).await? != sha1
+                        if &*sha1_async(bytes.clone()).await? != sha1 {
-                    {
                             if attempt <= 3 {
                                 continue;
                             } else {
-                            return Err(crate::ErrorKind::ChecksumFailure {
+                                return Err(
+                                    crate::ErrorKind::ChecksumFailure {
                                         hash: sha1.to_string(),
                                         url: url.to_string(),
                                         tries: attempt,
                                     }
-                            .into());
+                                    .into(),
+                                );
+                            }
                         }
                     }
 

apps/docs/src/content/docs/contributing/labrinth.md

@@ -3,55 +3,37 @@ title: Labrinth (API)
 description: Guide for contributing to Modrinth's backend
 ---
 
-This project is part of our [monorepo](https://github.com/modrinth/code). You can find it in the `apps/labrinth` directory.
+This project is part of our [monorepo](https://github.com/modrinth/code). You can find it in the `apps/labrinth` directory. The instructions below assume that you have switched your working directory to the `apps/labrinth` subdirectory.
 
-[labrinth] is the Rust-based backend serving Modrinth's API with the help of the [Actix](https://actix.rs) framework. To get started with a labrinth instance, install docker, docker-compose (which comes with Docker), and [Rust]. The initial startup can be done simply with the command `docker-compose up`, or with `docker compose up` (Compose V2 and later). That will deploy a PostgreSQL database on port 5432 and a MeiliSearch instance on port 7700. To run the API itself, you'll need to use the `cargo run` command, this will deploy the API on port 8000.
+[Labrinth] is the Rust-based backend serving Modrinth's API with the help of the [Actix](https://actix.rs) framework. To get started with a labrinth instance, install docker, docker-compose (which comes with Docker), and [Rust]. The initial startup can be done simply with the command `docker-compose up`, or with `docker compose up` (Compose V2 and later). That will deploy a PostgreSQL database on port 5432 and a MeiliSearch instance on port 7700. To run the API itself, you'll need to use the `cargo run` command, this will deploy the API on port 8000.
 
 To get a basic configuration, copy the `.env.local` file to `.env`. Now, you'll have to install the sqlx CLI, which can be done with cargo:
 
-```bash
+```sh
-cargo install --git https://github.com/launchbadge/sqlx sqlx-cli --no-default-features --features postgres,rustls
+cargo install sqlx-cli --no-default-features --features mysql,sqlite,postgres,rustls,completions
 ```
 
-From there, you can create the database and perform all database migrations with one simple command:
+From there, you can create the database and set up its schema with one simple command:
 
-```bash
+```sh
-sqlx database setup
+cargo sqlx database setup
 ```
 
-To enable labrinth to create a project, you need to add two things.
+To enable Labrinth to create projects and serve useful metadata to the frontend build scripts, you'll need to seed the database with several key entities:
 
-1. An entry in the `loaders` table.
+1. Categories, in the `categories` table.
-2. An entry in the `loaders_project_types` table.
+2. Loaders and their fields, in the `loaders`, `loader_fields`, `loader_field_enums`, `loader_field_enum_values`, and `loader_fields_loaders` tables.
+3. Project types and their allowed loaders and games, in the `project_types`, `loaders_project_types`, and `loaders_project_types_games` tables.
+4. Optionally, to moderate projects from the frontend, an admin user, in the `users` table.
 
-A minimal setup can be done from the command line with [psql](https://www.postgresql.org/docs/current/app-psql.html):
+The most convenient way to do this seeding is with the [psql](https://www.postgresql.org/docs/current/app-psql.html) command line tool and the pre-existing seed data fixture. This fixture was generated by dumping the official staging environment database at a specific point in time, and defines an admin user with email `admin@modrinth.invalid` and password `admin`:
 
-```bash
+```sh
-psql --host=localhost --port=5432 -U <username, default is labrinth> -W
+source .env
+psql "$DATABASE_URL" < fixtures/labrinth-seed-data-202508052143.sql
 ```
 
-The default password for the database is `labrinth`. Once you've connected, run
+You can find more example SQL statements for seeding the database in the `tests/files/dummy_data.sql` file.
-
-```sql
-INSERT INTO loaders VALUES (0, 'placeholder_loader');
-INSERT INTO loaders_project_types VALUES (0, 1); -- modloader id, supported type id
-INSERT INTO categories VALUES (0, 'placeholder_category', 1); -- category id, category, project type id
-```
-
-This will initialize your database with a modloader called 'placeholder_loader', with id 0, and marked as supporting mods only. It will also create a category called 'placeholder_category' that is marked as supporting mods only
-If you would like 'placeholder_loader' to be marked as supporting modpacks too, run
-
-```sql
-INSERT INTO loaders_project_types VALUES (0, 2); -- modloader id, supported type id
-```
-
-If you would like 'placeholder_category' to be marked as supporting modpacks too, run
-
-```sql
-INSERT INTO categories VALUES (0, 'placeholder_category', 2); -- modloader id, supported type id
-```
-
-You can find more example SQL statements for seeding the database in the `apps/labrinth/tests/files/dummy_data.sql` file.
 
 The majority of configuration is done at runtime using [dotenvy](https://crates.io/crates/dotenvy) and the `.env` file. Each of the variables and what they do can be found in the dropdown below. Additionally, there are three command line options that can be used to specify to MeiliSearch what you want to do.
 
@@ -109,14 +91,13 @@ The OAuth configuration options are fairly self-explanatory. For help setting up
 
 If you're prepared to contribute by submitting a pull request, ensure you have met the following criteria:
 
-- `cargo fmt` has been run.
+- `cargo fmt --all` has been run.
-- `cargo clippy` has been run.
+- `cargo clippy --all-targets` has been run.
-- `cargo check` has been run.
 - `cargo sqlx prepare` has been run.
 
 > Note: If you encounter issues with `sqlx` saying 'no queries found' after running `cargo sqlx prepare`, you may need to ensure the installed version of `sqlx-cli` matches the current version of `sqlx` used [in labrinth](https://github.com/modrinth/labrinth/blob/master/Cargo.toml).
 
 [Discord]: https://discord.modrinth.com
 [GitHub]: https://github.com/modrinth
-[labrinth]: https://github.com/modrinth/labrinth
+[Labrinth]: https://github.com/modrinth/code/tree/main/apps/labrinth
 [Rust]: https://www.rust-lang.org/tools/install

apps/frontend/nuxt.config.ts

@@ -143,13 +143,8 @@ export default defineNuxtConfig({
         state.lastGenerated &&
         new Date(state.lastGenerated).getTime() + TTL > new Date().getTime() &&
         // ...but only if the API URL is the same
-        state.apiUrl === API_URL &&
+        state.apiUrl === API_URL
-        // ...and if no errors were caught during the last generation
-        (state.errors ?? []).length === 0
       ) {
-        console.log(
-          "Tags already recently generated. Delete apps/frontend/generated/state.json to force regeneration.",
-        );
         return;
       }
 

apps/labrinth/src/auth/checks.rs

@@ -322,12 +322,13 @@ pub async fn is_visible_collection(
     } else {
         !collection_data.status.is_hidden()
     }) && !collection_data.projects.is_empty();
-    if let Some(user) = &user_option
+    if let Some(user) = &user_option {
-        && !authorized
+        if !authorized
             && (user.role.is_mod() || user.id == collection_data.user_id.into())
         {
             authorized = true;
         }
+    }
     Ok(authorized)
 }
 
@@ -355,12 +356,12 @@ pub async fn filter_visible_collections(
 
     for collection in check_collections {
         // Collections are simple- if we are the owner or a mod, we can see it
-        if let Some(user) = user_option
+        if let Some(user) = user_option {
-            && (user.role.is_mod() || user.id == collection.user_id.into())
+            if user.role.is_mod() || user.id == collection.user_id.into() {
-        {
                 return_collections.push(collection.into());
             }
         }
+    }
 
     Ok(return_collections)
 }

apps/labrinth/src/database/models/flow_item.rs

@@ -95,11 +95,11 @@ impl DBFlow {
         redis: &RedisPool,
     ) -> Result<Option<DBFlow>, DatabaseError> {
         let flow = Self::get(id, redis).await?;
-        if let Some(flow) = flow.as_ref()
+        if let Some(flow) = flow.as_ref() {
-            && predicate(flow)
+            if predicate(flow) {
-        {
                 Self::remove(id, redis).await?;
             }
+        }
         Ok(flow)
     }
 

apps/labrinth/src/database/models/loader_fields.rs

@@ -801,19 +801,18 @@ impl VersionField {
         };
 
         if let Some(count) = countable {
-            if let Some(min) = loader_field.min_val
+            if let Some(min) = loader_field.min_val {
-                && count < min
+                if count < min {
-            {
                     return Err(format!(
                         "Provided value '{v}' for {field_name} is less than the minimum of {min}",
                         v = serde_json::to_string(&value).unwrap_or_default(),
                         field_name = loader_field.field,
                     ));
                 }
+            }
 
-            if let Some(max) = loader_field.max_val
+            if let Some(max) = loader_field.max_val {
-                && count > max
+                if count > max {
-            {
                     return Err(format!(
                         "Provided value '{v}' for {field_name} is greater than the maximum of {max}",
                         v = serde_json::to_string(&value).unwrap_or_default(),
@@ -821,6 +820,7 @@ impl VersionField {
                     ));
                 }
             }
+        }
 
         Ok(VersionField {
             version_id,

apps/labrinth/src/database/models/team_item.rs

@@ -483,9 +483,8 @@ impl DBTeamMember {
             .await?;
         }
 
-        if let Some(accepted) = new_accepted
+        if let Some(accepted) = new_accepted {
-            && accepted
+            if accepted {
-        {
                 sqlx::query!(
                     "
                     UPDATE team_members
@@ -498,6 +497,7 @@ impl DBTeamMember {
                 .execute(&mut **transaction)
                 .await?;
             }
+        }
 
         if let Some(payouts_split) = new_payouts_split {
             sqlx::query!(

apps/labrinth/src/database/redis.rs

@@ -353,11 +353,11 @@ impl RedisPool {
             };
 
             for (idx, key) in fetch_ids.into_iter().enumerate() {
-                if let Some(locked) = results.get(idx)
+                if let Some(locked) = results.get(idx) {
-                    && locked.is_none()
+                    if locked.is_none() {
-                {
                         continue;
                     }
+                }
 
                 if let Some((key, raw_key)) = ids.remove(&key) {
                     if let Some(val) = expired_values.remove(&key) {

apps/labrinth/src/models/v2/projects.rs

@@ -334,15 +334,19 @@ impl From<Version> for LegacyVersion {
         // the v2 loaders are whatever the corresponding loader fields are
         let mut loaders =
             data.loaders.into_iter().map(|l| l.0).collect::<Vec<_>>();
-        if loaders.contains(&"mrpack".to_string())
+        if loaders.contains(&"mrpack".to_string()) {
-            && let Some((_, mrpack_loaders)) = data
+            if let Some((_, mrpack_loaders)) = data
                 .fields
                 .into_iter()
                 .find(|(key, _)| key == "mrpack_loaders")
-            && let Ok(mrpack_loaders) = serde_json::from_value(mrpack_loaders)
+            {
+                if let Ok(mrpack_loaders) =
+                    serde_json::from_value(mrpack_loaders)
                 {
                     loaders = mrpack_loaders;
                 }
+            }
+        }
         let loaders = loaders.into_iter().map(Loader).collect::<Vec<_>>();
 
         Self {

apps/labrinth/src/models/v2/search.rs

@@ -43,8 +43,8 @@ impl LegacyResultSearchProject {
     pub fn from(result_search_project: ResultSearchProject) -> Self {
         let mut categories = result_search_project.categories;
         categories.extend(result_search_project.loaders.clone());
-        if categories.contains(&"mrpack".to_string())
+        if categories.contains(&"mrpack".to_string()) {
-            && let Some(mrpack_loaders) = result_search_project
+            if let Some(mrpack_loaders) = result_search_project
                 .project_loader_fields
                 .get("mrpack_loaders")
             {
@@ -56,10 +56,11 @@ impl LegacyResultSearchProject {
                 );
                 categories.retain(|c| c != "mrpack");
             }
+        }
         let mut display_categories = result_search_project.display_categories;
         display_categories.extend(result_search_project.loaders);
-        if display_categories.contains(&"mrpack".to_string())
+        if display_categories.contains(&"mrpack".to_string()) {
-            && let Some(mrpack_loaders) = result_search_project
+            if let Some(mrpack_loaders) = result_search_project
                 .project_loader_fields
                 .get("mrpack_loaders")
             {
@@ -71,6 +72,7 @@ impl LegacyResultSearchProject {
                 );
                 display_categories.retain(|c| c != "mrpack");
             }
+        }
 
         // Sort then remove duplicates
         categories.sort();

apps/labrinth/src/models/v3/projects.rs

@@ -166,12 +166,12 @@ impl From<ProjectQueryResult> for Project {
                     Ok(spdx_expr) => {
                         let mut vec: Vec<&str> = Vec::new();
                         for node in spdx_expr.iter() {
-                            if let spdx::expression::ExprNode::Req(req) = node
+                            if let spdx::expression::ExprNode::Req(req) = node {
-                                && let Some(id) = req.req.license.id()
+                                if let Some(id) = req.req.license.id() {
-                            {
                                     vec.push(id.full_name);
                                 }
                             }
+                        }
                         // spdx crate returns AND/OR operations in postfix order
                         // and it would be a lot more effort to make it actually in order
                         // so let's just ignore that and make them comma-separated

apps/labrinth/src/models/v3/teams.rs

@@ -51,17 +51,17 @@ impl ProjectPermissions {
             return Some(ProjectPermissions::all());
         }
 
-        if let Some(member) = project_team_member
+        if let Some(member) = project_team_member {
-            && member.accepted
+            if member.accepted {
-        {
                 return Some(member.permissions);
             }
+        }
 
-        if let Some(member) = organization_team_member
+        if let Some(member) = organization_team_member {
-            && member.accepted
+            if member.accepted {
-        {
                 return Some(member.permissions);
             }
+        }
 
         if role.is_mod() {
             Some(
@@ -107,11 +107,11 @@ impl OrganizationPermissions {
             return Some(OrganizationPermissions::all());
         }
 
-        if let Some(member) = team_member
+        if let Some(member) = team_member {
-            && member.accepted
+            if member.accepted {
-        {
                 return member.organization_permissions;
             }
+        }
         if role.is_mod() {
             return Some(
                 OrganizationPermissions::EDIT_DETAILS

apps/labrinth/src/queue/maxmind.rs

@@ -45,18 +45,20 @@ impl MaxMindIndexer {
 
         if let Ok(entries) = archive.entries() {
             for mut file in entries.flatten() {
-                if let Ok(path) = file.header().path()
+                if let Ok(path) = file.header().path() {
-                    && path.extension().and_then(|x| x.to_str()) == Some("mmdb")
+                    if path.extension().and_then(|x| x.to_str()) == Some("mmdb")
                     {
                         let mut buf = Vec::new();
                         file.read_to_end(&mut buf).unwrap();
 
-                    let reader = maxminddb::Reader::from_source(buf).unwrap();
+                        let reader =
+                            maxminddb::Reader::from_source(buf).unwrap();
 
                         return Ok(Some(reader));
                     }
                 }
             }
+        }
 
         if should_panic {
             panic!(

apps/labrinth/src/queue/moderation.rs

@@ -371,8 +371,8 @@ impl AutomatedModerationQueue {
                                         for file in
                                         files.iter().filter(|x| x.version_id == version.id.into())
                                         {
-                                            if let Some(hash) = file.hashes.get("sha1")
+                                            if let Some(hash) = file.hashes.get("sha1") {
-                                                && let Some((index, (sha1, _, file_name, _))) = hashes
+                                                if let Some((index, (sha1, _, file_name, _))) = hashes
                                                     .iter()
                                                     .enumerate()
                                                     .find(|(_, (value, _, _, _))| value == hash)
@@ -384,6 +384,7 @@ impl AutomatedModerationQueue {
                                                 }
                                             }
                                         }
+                                    }
 
                                     // All files are on Modrinth, so we don't send any messages
                                     if hashes.is_empty() {
@@ -419,12 +420,13 @@ impl AutomatedModerationQueue {
                                         .await?;
 
                                     for row in rows {
-                                        if let Some(sha1) = row.sha1
+                                        if let Some(sha1) = row.sha1 {
-                                            && let Some((index, (sha1, _, file_name, _))) = hashes.iter().enumerate().find(|(_, (value, _, _, _))| value == &sha1) {
+                                            if let Some((index, (sha1, _, file_name, _))) = hashes.iter().enumerate().find(|(_, (value, _, _, _))| value == &sha1) {
                                                 final_hashes.insert(sha1.clone(), IdentifiedFile { file_name: file_name.clone(), status: ApprovalType::from_string(&row.status).unwrap_or(ApprovalType::Unidentified) });
                                                 hashes.remove(index);
                                             }
                                         }
+                                    }
 
                                     if hashes.is_empty() {
                                         let metadata = MissingMetadata {
@@ -497,8 +499,8 @@ impl AutomatedModerationQueue {
                                     let mut insert_ids = Vec::new();
 
                                     for row in rows {
-                                        if let Some((curse_index, (hash, _flame_id))) = flame_files.iter().enumerate().find(|(_, x)| Some(x.1 as i32) == row.flame_project_id)
+                                        if let Some((curse_index, (hash, _flame_id))) = flame_files.iter().enumerate().find(|(_, x)| Some(x.1 as i32) == row.flame_project_id) {
-                                            && let Some((index, (sha1, _, file_name, _))) = hashes.iter().enumerate().find(|(_, (value, _, _, _))| value == hash) {
+                                            if let Some((index, (sha1, _, file_name, _))) = hashes.iter().enumerate().find(|(_, (value, _, _, _))| value == hash) {
                                                 final_hashes.insert(sha1.clone(), IdentifiedFile {
                                                     file_name: file_name.clone(),
                                                     status: ApprovalType::from_string(&row.status).unwrap_or(ApprovalType::Unidentified),
@@ -511,6 +513,7 @@ impl AutomatedModerationQueue {
                                                 flame_files.remove(curse_index);
                                             }
                                         }
+                                    }
 
                                     if !insert_ids.is_empty() && !insert_hashes.is_empty() {
                                         sqlx::query!(
@@ -578,8 +581,8 @@ impl AutomatedModerationQueue {
                                     for (sha1, _pack_file, file_name, _mumur2) in hashes {
                                         let flame_file = flame_files.iter().find(|x| x.0 == sha1);
 
-                                        if let Some((_, flame_project_id)) = flame_file
+                                        if let Some((_, flame_project_id)) = flame_file {
-                                            && let Some(project) = flame_projects.iter().find(|x| &x.id == flame_project_id) {
+                                            if let Some(project) = flame_projects.iter().find(|x| &x.id == flame_project_id) {
                                                 missing_metadata.flame_files.insert(sha1, MissingMetadataFlame {
                                                     title: project.name.clone(),
                                                     file_name,
@@ -589,6 +592,7 @@ impl AutomatedModerationQueue {
 
                                                 continue;
                                             }
+                                        }
 
                                         missing_metadata.unknown_files.insert(sha1, file_name);
                                     }

apps/labrinth/src/queue/payouts.rs

@@ -257,17 +257,17 @@ impl PayoutsQueue {
             )
         })?;
 
-        if !status.is_success()
+        if !status.is_success() {
-            && let Some(obj) = value.as_object()
+            if let Some(obj) = value.as_object() {
-        {
                 if let Some(array) = obj.get("errors") {
                     #[derive(Deserialize)]
                     struct TremendousError {
                         message: String,
                     }
 
-                let err =
+                    let err = serde_json::from_value::<TremendousError>(
-                    serde_json::from_value::<TremendousError>(array.clone())
+                        array.clone(),
+                    )
                     .map_err(|_| {
                         ApiError::Payments(
                             "could not retrieve Tremendous error json body"
@@ -282,6 +282,7 @@ impl PayoutsQueue {
                     "could not retrieve Tremendous error body".to_string(),
                 ));
             }
+        }
 
         Ok(serde_json::from_value(value)?)
     }
@@ -448,11 +449,11 @@ impl PayoutsQueue {
                 };
 
                 // we do not support interval gift cards with non US based currencies since we cannot do currency conversions properly
-                if let PayoutInterval::Fixed { .. } = method.interval
+                if let PayoutInterval::Fixed { .. } = method.interval {
-                    && !product.currency_codes.contains(&"USD".to_string())
+                    if !product.currency_codes.contains(&"USD".to_string()) {
-                {
                         continue;
                     }
+                }
 
                 methods.push(method);
             }

apps/labrinth/src/routes/internal/billing.rs

@@ -286,9 +286,8 @@ pub async fn refund_charge(
         .upsert(&mut transaction)
         .await?;
 
-        if body.0.unprovision.unwrap_or(false)
+        if body.0.unprovision.unwrap_or(false) {
-            && let Some(subscription_id) = charge.subscription_id
+            if let Some(subscription_id) = charge.subscription_id {
-        {
                 let open_charge =
                     DBCharge::get_open_subscription(subscription_id, &**pool)
                         .await?;
@@ -299,6 +298,7 @@ pub async fn refund_charge(
                     open_charge.upsert(&mut transaction).await?;
                 }
             }
+        }
 
         transaction.commit().await?;
     }
@@ -392,18 +392,19 @@ pub async fn edit_subscription(
             }
         }
 
-        if let Some(interval) = &edit_subscription.interval
+        if let Some(interval) = &edit_subscription.interval {
-            && let Price::Recurring { intervals } = &current_price.prices
+            if let Price::Recurring { intervals } = &current_price.prices {
-        {
                 if let Some(price) = intervals.get(interval) {
                     open_charge.subscription_interval = Some(*interval);
                     open_charge.amount = *price as i64;
                 } else {
                     return Err(ApiError::InvalidInput(
-                    "Interval is not valid for this subscription!".to_string(),
+                        "Interval is not valid for this subscription!"
+                            .to_string(),
                     ));
                 }
             }
+        }
 
         let intent = if let Some(product_id) = &edit_subscription.product {
             let product_price =
@@ -1224,9 +1225,8 @@ pub async fn initiate_payment(
                     }
                 };
 
-                if let Price::Recurring { .. } = price_item.prices
+                if let Price::Recurring { .. } = price_item.prices {
-                    && product.unitary
+                    if product.unitary {
-                {
                         let user_subscriptions =
                         user_subscription_item::DBUserSubscription::get_all_user(
                             user.id.into(),
@@ -1234,11 +1234,13 @@ pub async fn initiate_payment(
                         )
                         .await?;
 
-                    let user_products = product_item::DBProductPrice::get_many(
+                        let user_products =
+                            product_item::DBProductPrice::get_many(
                                 &user_subscriptions
                                     .iter()
                                     .filter(|x| {
-                                x.status == SubscriptionStatus::Provisioned
+                                        x.status
+                                            == SubscriptionStatus::Provisioned
                                     })
                                     .map(|x| x.price_id)
                                     .collect::<Vec<_>>(),
@@ -1256,6 +1258,7 @@ pub async fn initiate_payment(
                             ));
                         }
                     }
+                }
 
                 (
                     price as i64,
@@ -2001,7 +2004,8 @@ pub async fn stripe_webhook(
             EventType::PaymentMethodAttached => {
                 if let EventObject::PaymentMethod(payment_method) =
                     event.data.object
-                    && let Some(customer_id) =
+                {
+                    if let Some(customer_id) =
                         payment_method.customer.map(|x| x.id())
                     {
                         let customer = stripe::Customer::retrieve(
@@ -2034,6 +2038,7 @@ pub async fn stripe_webhook(
                         }
                     }
                 }
+            }
             _ => {}
         }
     } else {

apps/labrinth/src/routes/internal/flows.rs

@@ -79,13 +79,14 @@ impl TempUser {
         file_host: &Arc<dyn FileHost + Send + Sync>,
         redis: &RedisPool,
     ) -> Result<crate::database::models::DBUserId, AuthenticationError> {
-        if let Some(email) = &self.email
+        if let Some(email) = &self.email {
-            && crate::database::models::DBUser::get_by_email(email, client)
+            if crate::database::models::DBUser::get_by_email(email, client)
                 .await?
                 .is_some()
             {
                 return Err(AuthenticationError::DuplicateUser);
             }
+        }
 
         let user_id =
             crate::database::models::generate_user_id(transaction).await?;
@@ -1268,9 +1269,8 @@ pub async fn delete_auth_provider(
         .update_user_id(user.id.into(), None, &mut transaction)
         .await?;
 
-    if delete_provider.provider != AuthProvider::PayPal
+    if delete_provider.provider != AuthProvider::PayPal {
-        && let Some(email) = user.email
+        if let Some(email) = user.email {
-    {
             send_email(
                 email,
                 "Authentication method removed",
@@ -1282,6 +1282,7 @@ pub async fn delete_auth_provider(
                 None,
             )?;
         }
+    }
 
     transaction.commit().await?;
     crate::database::models::DBUser::clear_caches(

apps/labrinth/src/routes/internal/moderation.rs

@@ -189,8 +189,8 @@ pub async fn get_project_meta(
                 .iter()
                 .find(|x| Some(x.1.id as i32) == row.flame_project_id)
                 .map(|x| x.0.clone())
-                && let Some(val) = merged.flame_files.remove(&sha1)
             {
+                if let Some(val) = merged.flame_files.remove(&sha1) {
                     merged.identified.insert(
                         sha1,
                         IdentifiedFile {
@@ -201,6 +201,7 @@ pub async fn get_project_meta(
                     );
                 }
             }
+        }
 
         Ok(HttpResponse::Ok().json(merged))
     } else {

apps/labrinth/src/routes/internal/pats.rs

@@ -185,9 +185,8 @@ pub async fn edit_pat(
     )
     .await?;
 
-    if let Some(pat) = pat
+    if let Some(pat) = pat {
-        && pat.user_id == user.id.into()
+        if pat.user_id == user.id.into() {
-    {
             let mut transaction = pool.begin().await?;
 
             if let Some(scopes) = &info.scopes {
@@ -249,6 +248,7 @@ pub async fn edit_pat(
             )
             .await?;
         }
+    }
 
     Ok(HttpResponse::NoContent().finish())
 }
@@ -276,9 +276,8 @@ pub async fn delete_pat(
     )
     .await?;
 
-    if let Some(pat) = pat
+    if let Some(pat) = pat {
-        && pat.user_id == user.id.into()
+        if pat.user_id == user.id.into() {
-    {
             let mut transaction = pool.begin().await?;
             database::models::pat_item::DBPersonalAccessToken::remove(
                 pat.id,
@@ -292,6 +291,7 @@ pub async fn delete_pat(
             )
             .await?;
         }
+    }
 
     Ok(HttpResponse::NoContent().finish())
 }

apps/labrinth/src/routes/internal/session.rs

@@ -185,9 +185,8 @@ pub async fn delete(
 
     let session = DBSession::get(info.into_inner().0, &**pool, &redis).await?;
 
-    if let Some(session) = session
+    if let Some(session) = session {
-        && session.user_id == current_user.id.into()
+        if session.user_id == current_user.id.into() {
-    {
             let mut transaction = pool.begin().await?;
             DBSession::remove(session.id, &mut transaction).await?;
             transaction.commit().await?;
@@ -201,6 +200,7 @@ pub async fn delete(
             )
             .await?;
         }
+    }
 
     Ok(HttpResponse::NoContent().body(""))
 }

apps/labrinth/src/routes/internal/statuses.rs

@@ -401,8 +401,8 @@ async fn broadcast_to_known_local_friends(
             friend.user_id
         };
 
-        if friend.accepted
+        if friend.accepted {
-            && let Some(socket_ids) =
+            if let Some(socket_ids) =
                 sockets.sockets_by_user_id.get(&friend_id.into())
             {
                 for socket_id in socket_ids.iter() {
@@ -412,6 +412,7 @@ async fn broadcast_to_known_local_friends(
                 }
             }
         }
+    }
 
     Ok(())
 }

apps/labrinth/src/routes/v3/analytics_get.rs

@@ -387,10 +387,9 @@ pub async fn revenue_get(
         .map(|x| (x.to_string(), HashMap::new()))
         .collect::<HashMap<_, _>>();
     for value in payouts_values {
-        if let Some(mod_id) = value.mod_id
+        if let Some(mod_id) = value.mod_id {
-            && let Some(amount) = value.amount_sum
+            if let Some(amount) = value.amount_sum {
-            && let Some(interval_start) = value.interval_start
+                if let Some(interval_start) = value.interval_start {
-        {
                     let id_string = to_base62(mod_id as u64);
                     if !hm.contains_key(&id_string) {
                         hm.insert(id_string.clone(), HashMap::new());
@@ -400,6 +399,8 @@ pub async fn revenue_get(
                     }
                 }
             }
+        }
+    }
 
     Ok(HttpResponse::Ok().json(hm))
 }

apps/labrinth/src/routes/v3/collections.rs

@@ -192,11 +192,11 @@ pub async fn collection_get(
     .map(|x| x.1)
     .ok();
 
-    if let Some(data) = collection_data
+    if let Some(data) = collection_data {
-        && is_visible_collection(&data, &user_option, false).await?
+        if is_visible_collection(&data, &user_option, false).await? {
-    {
             return Ok(HttpResponse::Ok().json(Collection::from(data)));
         }
+    }
     Err(ApiError::NotFound)
 }
 

apps/labrinth/src/routes/v3/payouts.rs

@@ -536,9 +536,11 @@ pub async fn create_payout(
                         Some(true),
                     )
                     .await
-                    && let Some(data) = res.items.first()
                 {
-                    payout_item.platform_id = Some(data.payout_item_id.clone());
+                    if let Some(data) = res.items.first() {
+                        payout_item.platform_id =
+                            Some(data.payout_item_id.clone());
+                    }
                 }
             }
 

apps/labrinth/src/routes/v3/projects.rs

@@ -182,11 +182,11 @@ pub async fn project_get(
     .map(|x| x.1)
     .ok();
 
-    if let Some(data) = project_data
+    if let Some(data) = project_data {
-        && is_visible_project(&data.inner, &user_option, &pool, false).await?
+        if is_visible_project(&data.inner, &user_option, &pool, false).await? {
-    {
             return Ok(HttpResponse::Ok().json(Project::from(data)));
         }
+    }
     Err(ApiError::NotFound)
 }
 
@@ -403,10 +403,8 @@ pub async fn project_edit(
             .await?;
         }
 
-        if status.is_searchable()
+        if status.is_searchable() && !project_item.inner.webhook_sent {
-            && !project_item.inner.webhook_sent
+            if let Ok(webhook_url) = dotenvy::var("PUBLIC_DISCORD_WEBHOOK") {
-            && let Ok(webhook_url) = dotenvy::var("PUBLIC_DISCORD_WEBHOOK")
-        {
                 crate::util::webhook::send_discord_webhook(
                     project_item.inner.id.into(),
                     &pool,
@@ -428,10 +426,10 @@ pub async fn project_edit(
                 .execute(&mut *transaction)
                 .await?;
             }
+        }
 
-        if user.role.is_mod()
+        if user.role.is_mod() {
-            && let Ok(webhook_url) = dotenvy::var("MODERATION_SLACK_WEBHOOK")
+            if let Ok(webhook_url) = dotenvy::var("MODERATION_SLACK_WEBHOOK") {
-        {
                 crate::util::webhook::send_slack_webhook(
                     project_item.inner.id.into(),
                     &pool,
@@ -452,6 +450,7 @@ pub async fn project_edit(
                 .await
                 .ok();
             }
+        }
 
         if team_member.is_none_or(|x| !x.accepted) {
             let notified_members = sqlx::query!(
@@ -693,9 +692,8 @@ pub async fn project_edit(
         .await?;
     }
 
-    if let Some(links) = &new_project.link_urls
+    if let Some(links) = &new_project.link_urls {
-        && !links.is_empty()
+        if !links.is_empty() {
-    {
             if !perms.contains(ProjectPermissions::EDIT_DETAILS) {
                 return Err(ApiError::CustomAuthentication(
                     "You do not have the permissions to edit the links of this project!"
@@ -720,7 +718,8 @@ pub async fn project_edit(
 
             for (platform, url) in links {
                 if let Some(url) = url {
-                let platform_id = db_models::categories::LinkPlatform::get_id(
+                    let platform_id =
+                        db_models::categories::LinkPlatform::get_id(
                             platform,
                             &mut *transaction,
                         )
@@ -745,6 +744,7 @@ pub async fn project_edit(
                 }
             }
         }
+    }
     if let Some(moderation_message) = &new_project.moderation_message {
         if !user.role.is_mod()
             && (!project_item.inner.status.is_approved()
@@ -2430,7 +2430,7 @@ pub async fn project_get_organization(
             organization,
             team_members,
         );
-        Ok(HttpResponse::Ok().json(organization))
+        return Ok(HttpResponse::Ok().json(organization));
     } else {
         Err(ApiError::NotFound)
     }

apps/labrinth/src/routes/v3/teams.rs

@@ -767,14 +767,13 @@ pub async fn edit_team_member(
                 ));
             }
 
-            if let Some(new_permissions) = edit_member.permissions
+            if let Some(new_permissions) = edit_member.permissions {
-                && !permissions.contains(new_permissions)
+                if !permissions.contains(new_permissions) {
-            {
                     return Err(ApiError::InvalidInput(
-                    "The new permissions have permissions that you don't have"
+                        "The new permissions have permissions that you don't have".to_string(),
-                        .to_string(),
                     ));
                 }
+            }
 
             if edit_member.organization_permissions.is_some() {
                 return Err(ApiError::InvalidInput(
@@ -801,13 +800,14 @@ pub async fn edit_team_member(
             }
 
             if let Some(new_permissions) = edit_member.organization_permissions
-                && !organization_permissions.contains(new_permissions)
             {
+                if !organization_permissions.contains(new_permissions) {
                     return Err(ApiError::InvalidInput(
                         "The new organization permissions have permissions that you don't have"
                             .to_string(),
                     ));
                 }
+            }
 
             if edit_member.permissions.is_some()
                 && !organization_permissions.contains(
@@ -822,14 +822,14 @@ pub async fn edit_team_member(
         }
     }
 
-    if let Some(payouts_split) = edit_member.payouts_split
+    if let Some(payouts_split) = edit_member.payouts_split {
-        && (payouts_split < Decimal::ZERO
+        if payouts_split < Decimal::ZERO || payouts_split > Decimal::from(5000)
-            || payouts_split > Decimal::from(5000))
         {
             return Err(ApiError::InvalidInput(
                 "Payouts split must be between 0 and 5000!".to_string(),
             ));
         }
+    }
 
     DBTeamMember::edit_team_member(
         id,
@@ -883,15 +883,15 @@ pub async fn transfer_ownership(
         DBTeam::get_association(id.into(), &**pool).await?;
     if let Some(TeamAssociationId::Project(pid)) = team_association_id {
         let result = DBProject::get_id(pid, &**pool, &redis).await?;
-        if let Some(project_item) = result
+        if let Some(project_item) = result {
-            && project_item.inner.organization_id.is_some()
+            if project_item.inner.organization_id.is_some() {
-        {
                 return Err(ApiError::InvalidInput(
                     "You cannot transfer ownership of a project team that is owend by an organization"
                         .to_string(),
                 ));
             }
         }
+    }
 
     if !current_user.role.is_admin() {
         let member = DBTeamMember::get_from_user_id(

apps/labrinth/src/routes/v3/threads.rs

@@ -289,9 +289,8 @@ pub async fn thread_get(
     .await?
     .1;
 
-    if let Some(mut data) = thread_data
+    if let Some(mut data) = thread_data {
-        && is_authorized_thread(&data, &user, &pool).await?
+        if is_authorized_thread(&data, &user, &pool).await? {
-    {
             let authors = &mut data.members;
 
             authors.append(
@@ -308,14 +307,18 @@ pub async fn thread_get(
                     .collect::<Vec<_>>(),
             );
 
-        let users: Vec<User> =
+            let users: Vec<User> = database::models::DBUser::get_many_ids(
-            database::models::DBUser::get_many_ids(authors, &**pool, &redis)
+                authors, &**pool, &redis,
+            )
             .await?
             .into_iter()
             .map(From::from)
             .collect();
 
-        return Ok(HttpResponse::Ok().json(Thread::from(data, users, &user)));
+            return Ok(
+                HttpResponse::Ok().json(Thread::from(data, users, &user))
+            );
+        }
     }
     Err(ApiError::NotFound)
 }
@@ -451,8 +454,8 @@ pub async fn thread_send_message(
             )
             .await?;
 
-            if let Some(project) = project
+            if let Some(project) = project {
-                && project.inner.status != ProjectStatus::Processing
+                if project.inner.status != ProjectStatus::Processing
                     && user.role.is_mod()
                 {
                     let members =
@@ -478,6 +481,7 @@ pub async fn thread_send_message(
                     )
                     .await?;
                 }
+            }
         } else if let Some(report_id) = thread.report_id {
             let report = database::models::report_item::DBReport::get(
                 report_id, &**pool,

apps/labrinth/src/routes/v3/version_creation.rs

@@ -522,11 +522,11 @@ async fn version_create_inner(
     .fetch_optional(pool)
     .await?;
 
-    if let Some(project_status) = project_status
+    if let Some(project_status) = project_status {
-        && project_status.status == ProjectStatus::Processing.as_str()
+        if project_status.status == ProjectStatus::Processing.as_str() {
-    {
             moderation_queue.projects.insert(project_id.into());
         }
+    }
 
     Ok(HttpResponse::Ok().json(response))
 }
@@ -871,8 +871,8 @@ pub async fn upload_file(
         ref format,
         ref files,
     } = validation_result
-        && dependencies.is_empty()
     {
+        if dependencies.is_empty() {
             let hashes: Vec<Vec<u8>> = format
                 .files
                 .iter()
@@ -933,6 +933,7 @@ pub async fn upload_file(
                 }
             }
         }
+    }
 
     let data = data.freeze();
     let primary = (validation_result.is_passed()
@@ -973,11 +974,11 @@ pub async fn upload_file(
         ));
     }
 
-    if let ValidationResult::Warning(msg) = validation_result
+    if let ValidationResult::Warning(msg) = validation_result {
-        && primary
+        if primary {
-    {
             return Err(CreateError::InvalidInput(msg.to_string()));
         }
+    }
 
     let url = format!("{cdn_url}/{file_path_encode}");
 

apps/labrinth/src/routes/v3/version_file.rs

@@ -148,7 +148,8 @@ pub async fn get_update_from_hash(
         &redis,
     )
     .await?
-        && let Some(project) = database::models::DBProject::get_id(
+    {
+        if let Some(project) = database::models::DBProject::get_id(
             file.project_id,
             &**pool,
             &redis,
@@ -174,10 +175,14 @@ pub async fn get_update_from_hash(
                 }
                 if let Some(loader_fields) = &update_data.loader_fields {
                     for (key, values) in loader_fields {
-                    bool &= if let Some(x_vf) =
+                        bool &= if let Some(x_vf) = x
-                        x.version_fields.iter().find(|y| y.field_name == *key)
+                            .version_fields
+                            .iter()
+                            .find(|y| y.field_name == *key)
                         {
-                        values.iter().any(|v| x_vf.value.contains_json_value(v))
+                            values
+                                .iter()
+                                .any(|v| x_vf.value.contains_json_value(v))
                         } else {
                             true
                         };
@@ -188,15 +193,20 @@ pub async fn get_update_from_hash(
             .sorted();
 
             if let Some(first) = versions.next_back() {
-            if !is_visible_version(&first.inner, &user_option, &pool, &redis)
+                if !is_visible_version(
+                    &first.inner,
+                    &user_option,
+                    &pool,
+                    &redis,
+                )
                 .await?
                 {
                     return Err(ApiError::NotFound);
                 }
 
-            return Ok(
+                return Ok(HttpResponse::Ok()
-                HttpResponse::Ok().json(models::projects::Version::from(first))
+                    .json(models::projects::Version::from(first)));
-            );
+            }
         }
     }
     Err(ApiError::NotFound)
@@ -388,14 +398,15 @@ pub async fn update_files(
         if let Some(version) = versions
             .iter()
             .find(|x| x.inner.project_id == file.project_id)
-            && let Some(hash) = file.hashes.get(&algorithm)
         {
+            if let Some(hash) = file.hashes.get(&algorithm) {
                 response.insert(
                     hash.clone(),
                     models::projects::Version::from(version.clone()),
                 );
             }
         }
+    }
 
     Ok(HttpResponse::Ok().json(response))
 }
@@ -473,8 +484,8 @@ pub async fn update_individual_files(
 
     for project in projects {
         for file in files.iter().filter(|x| x.project_id == project.inner.id) {
-            if let Some(hash) = file.hashes.get(&algorithm)
+            if let Some(hash) = file.hashes.get(&algorithm) {
-                && let Some(query_file) =
+                if let Some(query_file) =
                     update_data.hashes.iter().find(|x| &x.hash == hash)
                 {
                     let version = all_versions
@@ -483,17 +494,23 @@ pub async fn update_individual_files(
                         .filter(|x| {
                             let mut bool = true;
 
-                        if let Some(version_types) = &query_file.version_types {
+                            if let Some(version_types) =
-                            bool &= version_types
+                                &query_file.version_types
-                                .iter()
+                            {
-                                .any(|y| y.as_str() == x.inner.version_type);
+                                bool &= version_types.iter().any(|y| {
+                                    y.as_str() == x.inner.version_type
+                                });
                             }
                             if let Some(loaders) = &query_file.loaders {
-                            bool &=
+                                bool &= x
-                                x.loaders.iter().any(|y| loaders.contains(y));
+                                    .loaders
+                                    .iter()
+                                    .any(|y| loaders.contains(y));
                             }
 
-                        if let Some(loader_fields) = &query_file.loader_fields {
+                            if let Some(loader_fields) =
+                                &query_file.loader_fields
+                            {
                                 for (key, values) in loader_fields {
                                     bool &= if let Some(x_vf) = x
                                         .version_fields
@@ -513,8 +530,8 @@ pub async fn update_individual_files(
                         .sorted()
                         .next_back();
 
-                if let Some(version) = version
+                    if let Some(version) = version {
-                    && is_visible_version(
+                        if is_visible_version(
                             &version.inner,
                             &user_option,
                             &pool,
@@ -524,12 +541,16 @@ pub async fn update_individual_files(
                         {
                             response.insert(
                                 hash.clone(),
-                        models::projects::Version::from(version.clone()),
+                                models::projects::Version::from(
+                                    version.clone(),
+                                ),
                             );
                         }
                     }
                 }
             }
+        }
+    }
 
     Ok(HttpResponse::Ok().json(response))
 }

apps/labrinth/src/routes/v3/versions.rs

@@ -106,14 +106,15 @@ pub async fn version_project_get_helper(
                 || x.inner.version_number == id.1
         });
 
-        if let Some(version) = version
+        if let Some(version) = version {
-            && is_visible_version(&version.inner, &user_option, &pool, &redis)
+            if is_visible_version(&version.inner, &user_option, &pool, &redis)
                 .await?
             {
                 return Ok(HttpResponse::Ok()
                     .json(models::projects::Version::from(version)));
             }
         }
+    }
 
     Err(ApiError::NotFound)
 }
@@ -189,13 +190,13 @@ pub async fn version_get_helper(
     .map(|x| x.1)
     .ok();
 
-    if let Some(data) = version_data
+    if let Some(data) = version_data {
-        && is_visible_version(&data.inner, &user_option, &pool, &redis).await?
+        if is_visible_version(&data.inner, &user_option, &pool, &redis).await? {
-    {
             return Ok(
                 HttpResponse::Ok().json(models::projects::Version::from(data))
             );
         }
+    }
 
     Err(ApiError::NotFound)
 }

apps/labrinth/src/sync/status.rs

@@ -15,13 +15,15 @@ pub async fn get_user_status(
         return Some(friend_status);
     }
 
-    if let Ok(mut conn) = redis.pool.get().await
+    if let Ok(mut conn) = redis.pool.get().await {
-        && let Ok(mut statuses) =
+        if let Ok(mut statuses) =
             conn.sscan::<_, String>(get_field_name(user)).await
-        && let Some(status_json) = statuses.next_item().await
         {
+            if let Some(status_json) = statuses.next_item().await {
                 return serde_json::from_str::<UserStatus>(&status_json).ok();
             }
+        }
+    }
 
     None
 }

apps/labrinth/src/util/img.rs

@@ -138,12 +138,13 @@ fn process_image(
     let (orig_width, orig_height) = img.dimensions();
     let aspect_ratio = orig_width as f32 / orig_height as f32;
 
-    if let Some(target_width) = target_width
+    if let Some(target_width) = target_width {
-        && img.width() > target_width
+        if img.width() > target_width {
-    {
+            let new_height =
-        let new_height = (target_width as f32 / aspect_ratio).round() as u32;
+                (target_width as f32 / aspect_ratio).round() as u32;
             img = img.resize(target_width, new_height, FilterType::Lanczos3);
         }
+    }
 
     if let Some(min_aspect_ratio) = min_aspect_ratio {
         // Crop if necessary

apps/labrinth/src/util/ratelimit.rs

@@ -133,12 +133,13 @@ pub async fn rate_limit_middleware(
         .expect("Rate limiter not configured properly")
         .clone();
 
-    if let Some(key) = req.headers().get("x-ratelimit-key")
+    if let Some(key) = req.headers().get("x-ratelimit-key") {
-        && key.to_str().ok()
+        if key.to_str().ok()
             == dotenvy::var("RATE_LIMIT_IGNORE_KEY").ok().as_deref()
         {
             return Ok(next.call(req).await?.map_into_left_body());
         }
+    }
 
     let conn_info = req.connection_info().clone();
     let ip = if parse_var("CLOUDFLARE_INTEGRATION").unwrap_or(false) {

apps/labrinth/src/util/validate.rs

@@ -22,9 +22,8 @@ pub fn validation_errors_to_string(
 
     let key_option = map.keys().next();
 
-    if let Some(field) = key_option
+    if let Some(field) = key_option {
-        && let Some(error) = map.get(field)
+        if let Some(error) = map.get(field) {
-    {
             return match error {
                 ValidationErrorsKind::Struct(errors) => {
                     validation_errors_to_string(
@@ -55,8 +54,7 @@ pub fn validation_errors_to_string(
                                 &mut output,
                                 "Field {field} failed validation with error: {}",
                                 error.code
-                        )
+                            ).unwrap();
-                        .unwrap();
                         }
                     }
 
@@ -64,6 +62,7 @@ pub fn validation_errors_to_string(
                 }
             };
         }
+    }
 
     String::new()
 }

apps/labrinth/src/util/webhook.rs

@@ -238,9 +238,8 @@ pub async fn send_slack_webhook(
             }
         });
 
-        if let Some(icon_url) = metadata.project_icon_url
+        if let Some(icon_url) = metadata.project_icon_url {
-            && let Some(project_block) = project_block.as_object_mut()
+            if let Some(project_block) = project_block.as_object_mut() {
-        {
                 project_block.insert(
                     "accessory".to_string(),
                     serde_json::json!({
@@ -250,6 +249,7 @@ pub async fn send_slack_webhook(
                     }),
                 );
             }
+        }
 
         blocks.push(project_block);
 

apps/labrinth/tests/common/dummy_data.rs

@@ -292,7 +292,7 @@ pub async fn add_dummy_data(api: &ApiV3, db: TemporaryDatabase) -> DummyData {
     let pool = &db.pool.clone();
 
     pool.execute(
-        include_str!("../files/dummy_data.sql")
+        include_str!("../fixtures/dummy_data.sql")
             .replace("$1", &Scopes::all().bits().to_string())
             .as_str(),
     )

apps/labrinth/tests/common/permissions.rs

@@ -222,11 +222,11 @@ impl<'a, A: Api> PermissionsTest<'a, A> {
                 resp.status().as_u16()
             ));
         }
-        if resp.status() == StatusCode::OK
+        if resp.status() == StatusCode::OK {
-            && let Some(failure_json_check) = &self.failure_json_check
+            if let Some(failure_json_check) = &self.failure_json_check {
-        {
                 failure_json_check(&test::read_body_json(resp).await);
             }
+        }
 
         // Failure test- logged in on a non-team user
         let resp = req_gen(PermissionsTestContext {
@@ -246,11 +246,11 @@ impl<'a, A: Api> PermissionsTest<'a, A> {
                 resp.status().as_u16()
             ));
         }
-        if resp.status() == StatusCode::OK
+        if resp.status() == StatusCode::OK {
-            && let Some(failure_json_check) = &self.failure_json_check
+            if let Some(failure_json_check) = &self.failure_json_check {
-        {
                 failure_json_check(&test::read_body_json(resp).await);
             }
+        }
 
         // Failure test- logged in with EVERY non-relevant permission
         let resp: ServiceResponse = req_gen(PermissionsTestContext {
@@ -270,11 +270,11 @@ impl<'a, A: Api> PermissionsTest<'a, A> {
                 resp.status().as_u16()
             ));
         }
-        if resp.status() == StatusCode::OK
+        if resp.status() == StatusCode::OK {
-            && let Some(failure_json_check) = &self.failure_json_check
+            if let Some(failure_json_check) = &self.failure_json_check {
-        {
                 failure_json_check(&test::read_body_json(resp).await);
             }
+        }
 
         // Patch user's permissions to success permissions
         modify_user_team_permissions(
@@ -300,11 +300,11 @@ impl<'a, A: Api> PermissionsTest<'a, A> {
                 resp.status().as_u16()
             ));
         }
-        if resp.status() == StatusCode::OK
+        if resp.status() == StatusCode::OK {
-            && let Some(success_json_check) = &self.success_json_check
+            if let Some(success_json_check) = &self.success_json_check {
-        {
                 success_json_check(&test::read_body_json(resp).await);
             }
+        }
 
         // If the remove_user flag is set, remove the user from the project
         // Relevant for existing projects/users

clippy.toml

@@ -1,2 +1,2 @@
 allow-dbg-in-tests = true
-msrv = "1.89.0"
+msrv = "1.88.0"

packages/app-lib/src/api/handler.rs

@@ -50,11 +50,11 @@ pub async fn parse_command(
         // We assume anything else is a filepath to an .mrpack file
         let path = PathBuf::from(command_string);
         let path = io::canonicalize(path)?;
-        if let Some(ext) = path.extension()
+        if let Some(ext) = path.extension() {
-            && ext == "mrpack"
+            if ext == "mrpack" {
-        {
                 return Ok(CommandPayload::RunMRPack { path });
             }
+        }
         emit_warning(&format!(
             "Invalid command, unrecognized filetype: {}",
             path.display()

packages/app-lib/src/api/jre.rs

@@ -106,15 +106,15 @@ pub async fn auto_install_java(java_version: u32) -> crate::Result<PathBuf> {
             })?;
 
         // removes the old installation of java
-        if let Some(file) = archive.file_names().next()
+        if let Some(file) = archive.file_names().next() {
-            && let Some(dir) = file.split('/').next()
+            if let Some(dir) = file.split('/').next() {
-        {
                 let path = path.join(dir);
 
                 if path.exists() {
                     io::remove_dir_all(path).await?;
                 }
             }
+        }
 
         emit_loading(&loading_bar, 0.0, Some("Extracting java"))?;
         archive.extract(&path).map_err(|_| {

packages/app-lib/src/api/minecraft_auth.rs

@@ -54,13 +54,13 @@ pub async fn remove_user(uuid: uuid::Uuid) -> crate::Result<()> {
     if let Some((uuid, user)) = users.remove(&uuid) {
         Credentials::remove(uuid, &state.pool).await?;
 
-        if user.active
+        if user.active {
-            && let Some((_, mut user)) = users.into_iter().next()
+            if let Some((_, mut user)) = users.into_iter().next() {
-        {
                 user.active = true;
                 user.upsert(&state.pool).await?;
             }
         }
+    }
 
     Ok(())
 }

packages/app-lib/src/api/pack/import/atlauncher.rs

@@ -221,15 +221,15 @@ async fn import_atlauncher_unmanaged(
             .unwrap_or_else(|| backup_name.to_string());
         prof.install_stage = ProfileInstallStage::PackInstalling;
 
-        if let Some(ref project_id) = description.project_id
+        if let Some(ref project_id) = description.project_id {
-            && let Some(ref version_id) = description.version_id
+            if let Some(ref version_id) = description.version_id {
-        {
                 prof.linked_data = Some(LinkedData {
                     project_id: project_id.clone(),
                     version_id: version_id.clone(),
                     locked: true,
                 })
             }
+        }
 
         prof.icon_path = description
             .icon

packages/app-lib/src/api/pack/install_from.rs

@@ -383,9 +383,8 @@ pub async fn set_profile_information(
             .unwrap_or_else(|| backup_name.to_string());
         prof.install_stage = ProfileInstallStage::PackInstalling;
 
-        if let Some(ref project_id) = description.project_id
+        if let Some(ref project_id) = description.project_id {
-            && let Some(ref version_id) = description.version_id
+            if let Some(ref version_id) = description.version_id {
-        {
                 prof.linked_data = Some(LinkedData {
                     project_id: project_id.clone(),
                     version_id: version_id.clone(),
@@ -396,6 +395,7 @@ pub async fn set_profile_information(
                     },
                 })
             }
+        }
 
         prof.icon_path = description
             .icon

packages/app-lib/src/api/pack/install_mrpack.rs

@@ -149,13 +149,14 @@ pub async fn install_zipped_mrpack_files(
                 let profile_path = profile_path.clone();
                 async move {
                     //TODO: Future update: prompt user for optional files in a modpack
-                    if let Some(env) = project.env
+                    if let Some(env) = project.env {
-                        && env
+                        if env
                             .get(&EnvType::Client)
                             .is_some_and(|x| x == &SideType::Unsupported)
                         {
                             return Ok(());
                         }
+                    }
 
                     let file = fetch_mirrors(
                         &project
@@ -374,15 +375,15 @@ pub async fn remove_all_related_files(
             )
             .await?
         {
-            if let Some(metadata) = &project.metadata
+            if let Some(metadata) = &project.metadata {
-                && to_remove.contains(&metadata.project_id)
+                if to_remove.contains(&metadata.project_id) {
-            {
                     let path = profile_full_path.join(file_path);
                     if path.exists() {
                         io::remove_file(&path).await?;
                     }
                 }
             }
+        }
 
         // Iterate over all Modrinth project file paths in the json, and remove them
         // (There should be few, but this removes any files the .mrpack intended as Modrinth projects but were unrecognized)

packages/app-lib/src/api/profile/mod.rs

@@ -337,8 +337,8 @@ pub async fn update_project(
             )
             .await?
             .remove(project_path)
-            && let Some(update_version) = &file.update_version_id
         {
+            if let Some(update_version) = &file.update_version_id {
                 let path = Profile::add_project_version(
                     profile_path,
                     update_version,
@@ -353,11 +353,13 @@ pub async fn update_project(
                 }
 
                 if !skip_send_event.unwrap_or(false) {
-                emit_profile(profile_path, ProfilePayloadType::Edited).await?;
+                    emit_profile(profile_path, ProfilePayloadType::Edited)
+                        .await?;
                 }
 
                 return Ok(path);
             }
+        }
 
         Err(crate::ErrorKind::InputError(
             "This project cannot be updated!".to_string(),
@@ -477,11 +479,11 @@ pub async fn export_mrpack(
     let included_export_candidates = included_export_candidates
         .into_iter()
         .filter(|x| {
-            if let Some(f) = PathBuf::from(x).file_name()
+            if let Some(f) = PathBuf::from(x).file_name() {
-                && f.to_string_lossy().starts_with(".DS_Store")
+                if f.to_string_lossy().starts_with(".DS_Store") {
-            {
                     return false;
                 }
+            }
             true
         })
         .collect::<Vec<_>>();

packages/app-lib/src/event/mod.rs

@@ -184,7 +184,6 @@ pub enum LoadingBarType {
 }
 
 #[derive(Serialize, Clone)]
-#[cfg(feature = "tauri")]
 pub struct LoadingPayload {
     pub event: LoadingBarType,
     pub loader_uuid: Uuid,
@@ -193,7 +192,11 @@ pub struct LoadingPayload {
 }
 
 #[derive(Serialize, Clone)]
-#[cfg(feature = "tauri")]
+pub struct OfflinePayload {
+    pub offline: bool,
+}
+
+#[derive(Serialize, Clone)]
 pub struct WarningPayload {
     pub message: String,
 }
@@ -217,14 +220,12 @@ pub enum CommandPayload {
 }
 
 #[derive(Serialize, Clone)]
-#[cfg(feature = "tauri")]
 pub struct ProcessPayload {
     pub profile_path_id: String,
     pub uuid: Uuid,
     pub event: ProcessPayloadType,
     pub message: String,
 }
-
 #[derive(Serialize, Clone, Debug)]
 #[serde(rename_all = "snake_case")]
 pub enum ProcessPayloadType {
@@ -233,13 +234,11 @@ pub enum ProcessPayloadType {
 }
 
 #[derive(Serialize, Clone)]
-#[cfg(feature = "tauri")]
 pub struct ProfilePayload {
     pub profile_path_id: String,
     #[serde(flatten)]
     pub event: ProfilePayloadType,
 }
-
 #[derive(Serialize, Clone)]
 #[serde(tag = "event", rename_all = "snake_case")]
 pub enum ProfilePayloadType {
@@ -258,16 +257,6 @@ pub enum ProfilePayloadType {
     Removed,
 }
 
-#[derive(Serialize, Clone)]
-#[serde(rename_all = "snake_case")]
-#[serde(tag = "event")]
-pub enum FriendPayload {
-    FriendRequest { from: UserId },
-    UserOffline { id: UserId },
-    StatusUpdate { user_status: UserStatus },
-    StatusSync,
-}
-
 #[derive(Debug, thiserror::Error)]
 pub enum EventError {
     #[error("Event state was not properly initialized")]
@@ -280,3 +269,13 @@ pub enum EventError {
     #[error("Tauri error: {0}")]
     TauriError(#[from] tauri::Error),
 }
+
+#[derive(Serialize, Clone)]
+#[serde(rename_all = "snake_case")]
+#[serde(tag = "event")]
+pub enum FriendPayload {
+    FriendRequest { from: UserId },
+    UserOffline { id: UserId },
+    StatusUpdate { user_status: UserStatus },
+    StatusSync,
+}

packages/app-lib/src/launcher/args.rs

@@ -32,16 +32,16 @@ pub fn get_class_paths(
     let mut cps = libraries
         .iter()
         .filter_map(|library| {
-            if let Some(rules) = &library.rules
+            if let Some(rules) = &library.rules {
-                && !parse_rules(
+                if !parse_rules(
                     rules,
                     java_arch,
                     &QuickPlayType::None,
                     minecraft_updated,
-                )
+                ) {
-            {
                     return None;
                 }
+            }
 
             if !library.include_in_classpath {
                 return None;
@@ -504,12 +504,12 @@ pub async fn get_processor_main_class(
             let mut line = line.map_err(IOError::from)?;
             line.retain(|c| !c.is_whitespace());
 
-            if line.starts_with("Main-Class:")
+            if line.starts_with("Main-Class:") {
-                && let Some(class) = line.split(':').nth(1)
+                if let Some(class) = line.split(':').nth(1) {
-            {
                     return Ok(Some(class.to_string()));
                 }
             }
+        }
 
         Ok::<Option<String>, crate::Error>(None)
     })

packages/app-lib/src/launcher/download.rs

@@ -290,11 +290,12 @@ pub async fn download_libraries(
     loading_try_for_each_concurrent(
         stream::iter(libraries.iter())
             .map(Ok::<&Library, crate::Error>), None, loading_bar,loading_amount,num_files, None,|library| async move {
-                if let Some(rules) = &library.rules
+                if let Some(rules) = &library.rules {
-                    && !parse_rules(rules, java_arch, &QuickPlayType::None, minecraft_updated) {
+                    if !parse_rules(rules, java_arch, &QuickPlayType::None, minecraft_updated) {
                         tracing::trace!("Skipped library {}", &library.name);
                         return Ok(());
                     }
+                }
 
                 if !library.downloadable {
                     tracing::trace!("Skipped non-downloadable library {}", &library.name);
@@ -310,14 +311,15 @@ pub async fn download_libraries(
                             return Ok(());
                         }
 
-                        if let Some(d::minecraft::LibraryDownloads { artifact: Some(ref artifact), ..}) = library.downloads
+                        if let Some(d::minecraft::LibraryDownloads { artifact: Some(ref artifact), ..}) = library.downloads {
-                            && !artifact.url.is_empty(){
+                            if !artifact.url.is_empty(){
                                 let bytes = fetch(&artifact.url, Some(&artifact.sha1), &st.fetch_semaphore, &st.pool)
                                     .await?;
                                 write(&path, &bytes, &st.io_semaphore).await?;
                                 tracing::trace!("Fetched library {} to path {:?}", &library.name, &path);
                                 return Ok::<_, crate::Error>(());
                             }
+                        }
 
                         let url = [
                             library

packages/app-lib/src/launcher/mod.rs

@@ -341,11 +341,11 @@ pub async fn install_minecraft(
 
             // Forge processors (90-100)
             for (index, processor) in processors.iter().enumerate() {
-                if let Some(sides) = &processor.sides
+                if let Some(sides) = &processor.sides {
-                    && !sides.contains(&String::from("client"))
+                    if !sides.contains(&String::from("client")) {
-                {
                         continue;
                     }
+                }
 
                 let cp = {
                     let mut cp = processor.classpath.clone();

packages/app-lib/src/state/dirs.rs

@@ -385,11 +385,11 @@ impl DirectoryInfo {
                         return Err(e);
                     }
                 } else {
-                    if let Some(disk_usage) = get_disk_usage(&move_dir)?
+                    if let Some(disk_usage) = get_disk_usage(&move_dir)? {
-                        && total_size > disk_usage
+                        if total_size > disk_usage {
-                    {
                             return Err(crate::ErrorKind::DirectoryMoveError(format!("Not enough space to move directory to {}: only {} bytes available", app_dir.display(), disk_usage)).into());
                         }
+                    }
 
                     let loader_bar_id = Arc::new(&loader_bar_id);
                     futures::future::try_join_all(paths.iter().map(|x| {

packages/app-lib/src/state/friends.rs

@@ -9,7 +9,7 @@ use ariadne::networking::message::{
     ClientToServerMessage, ServerToClientMessage,
 };
 use ariadne::users::UserStatus;
-use async_tungstenite::WebSocketSender;
+use async_tungstenite::WebSocketStream;
 use async_tungstenite::tokio::{ConnectStream, connect_async};
 use async_tungstenite::tungstenite::Message;
 use async_tungstenite::tungstenite::client::IntoClientRequest;
@@ -17,6 +17,7 @@ use bytes::Bytes;
 use chrono::{DateTime, Utc};
 use dashmap::DashMap;
 use either::Either;
+use futures::stream::SplitSink;
 use futures::{SinkExt, StreamExt};
 use reqwest::Method;
 use reqwest::header::HeaderValue;
@@ -31,7 +32,7 @@ use tokio::sync::{Mutex, RwLock};
 use uuid::Uuid;
 
 pub(super) type WriteSocket =
-    Arc<RwLock<Option<WebSocketSender<ConnectStream>>>>;
+    Arc<RwLock<Option<SplitSink<WebSocketStream<ConnectStream>, Message>>>>;
 pub(super) type TunnelSockets = Arc<DashMap<Uuid, Arc<InternalTunnelSocket>>>;
 
 pub struct FriendsSocket {
@@ -179,24 +180,27 @@ impl FriendsSocket {
                                             ServerToClientMessage::FriendSocketStoppedListening { .. } => {}, // TODO
 
                                             ServerToClientMessage::SocketConnected { to_socket, new_socket } => {
-                                                if let Some(connected_to) = sockets.get(&to_socket)
+                                                if let Some(connected_to) = sockets.get(&to_socket) {
-                                                    && let InternalTunnelSocket::Listening(local_addr) = *connected_to.value().clone()
+                                                    if let InternalTunnelSocket::Listening(local_addr) = *connected_to.value().clone() {
-                                                        && let Ok(new_stream) = TcpStream::connect(local_addr).await {
+                                                        if let Ok(new_stream) = TcpStream::connect(local_addr).await {
                                                             let (read, write) = new_stream.into_split();
                                                             sockets.insert(new_socket, Arc::new(InternalTunnelSocket::Connected(Mutex::new(write))));
                                                             Self::socket_read_loop(write_handle.clone(), read, new_socket);
                                                             continue;
                                                         }
+                                                    }
+                                                }
                                                 let _ = Self::send_message(&write_handle, ClientToServerMessage::SocketClose { socket: new_socket }).await;
                                             },
                                             ServerToClientMessage::SocketClosed { socket } => {
                                                 sockets.remove_if(&socket, |_, x| matches!(*x.clone(), InternalTunnelSocket::Connected(_)));
                                             },
                                             ServerToClientMessage::SocketData { socket, data } => {
-                                                if let Some(mut socket) = sockets.get_mut(&socket)
+                                                if let Some(mut socket) = sockets.get_mut(&socket) {
-                                                    && let InternalTunnelSocket::Connected(ref stream) = *socket.value_mut().clone() {
+                                                    if let InternalTunnelSocket::Connected(ref stream) = *socket.value_mut().clone() {
                                                         let _ = stream.lock().await.write_all(&data).await;
                                                     }
+                                                }
                                             },
                                         }
                                     }

packages/app-lib/src/state/fs_watcher.rs

@@ -100,8 +100,8 @@ pub async fn init_watcher() -> crate::Result<FileWatcher> {
                                         let profile_path_str = profile_path_str.clone();
                                         let world = world.clone();
                                         tokio::spawn(async move {
-                                            if let Ok(state) = State::get().await
+                                            if let Ok(state) = State::get().await {
-                                                && let Err(e) = attached_world_data::AttachedWorldData::remove_for_world(
+                                                if let Err(e) = attached_world_data::AttachedWorldData::remove_for_world(
                                                     &profile_path_str,
                                                     WorldType::Singleplayer,
                                                     &world,
@@ -109,6 +109,7 @@ pub async fn init_watcher() -> crate::Result<FileWatcher> {
                                                 ).await {
                                                     tracing::warn!("Failed to remove AttachedWorldData for '{world}': {e}")
                                                 }
+                                            }
                                         });
                                     }
                                     Some(ProfilePayloadType::WorldUpdated { world })
@@ -149,9 +150,8 @@ pub(crate) async fn watch_profiles_init(
 ) {
     if let Ok(profiles_dir) = std::fs::read_dir(dirs.profiles_dir()) {
         for profile_dir in profiles_dir {
-            if let Ok(file_name) = profile_dir.map(|x| x.file_name())
+            if let Ok(file_name) = profile_dir.map(|x| x.file_name()) {
-                && let Some(file_name) = file_name.to_str()
+                if let Some(file_name) = file_name.to_str() {
-            {
                     if file_name.starts_with(".DS_Store") {
                         continue;
                     };
@@ -161,6 +161,7 @@ pub(crate) async fn watch_profiles_init(
             }
         }
     }
+}
 
 pub(crate) async fn watch_profile(
     profile_path: &str,

packages/app-lib/src/state/legacy_converter.rs

@@ -76,10 +76,11 @@ where
             .loaded_config_dir
             .clone()
             .and_then(|x| x.to_str().map(|x| x.to_string()))
-            && path != old_launcher_root_str
         {
+            if path != old_launcher_root_str {
                 settings.custom_dir = Some(path);
             }
+        }
 
         settings.prev_custom_dir = Some(old_launcher_root_str.clone());
 
@@ -135,17 +136,19 @@ where
                 .await?;
             }
 
-            if let Some(device_token) = minecraft_auth.token
+            if let Some(device_token) = minecraft_auth.token {
-                && let Ok(private_key) =
+                if let Ok(private_key) =
                     SigningKey::from_pkcs8_pem(&device_token.private_key)
-                && let Ok(uuid) = Uuid::parse_str(&device_token.id)
                 {
+                    if let Ok(uuid) = Uuid::parse_str(&device_token.id) {
                         DeviceTokenPair {
                             token: DeviceToken {
                                 issue_instant: device_token.token.issue_instant,
                                 not_after: device_token.token.not_after,
                                 token: device_token.token.token,
-                        display_claims: device_token.token.display_claims,
+                                display_claims: device_token
+                                    .token
+                                    .display_claims,
                             },
                             key: DeviceTokenKey {
                                 id: uuid,
@@ -158,6 +161,8 @@ where
                         .await?;
                     }
                 }
+            }
+        }
 
         let mut cached_entries = vec![];
 
@@ -202,12 +207,13 @@ where
                         update_version,
                         ..
                     } = project.metadata
-                        && let Some(file) = version
+                    {
+                        if let Some(file) = version
                             .files
                             .iter()
                             .find(|x| x.hashes.get("sha512") == Some(&sha512))
-                        && let Some(sha1) = file.hashes.get("sha1")
                         {
+                            if let Some(sha1) = file.hashes.get("sha1") {
                                 if let Ok(metadata) = full_path.metadata() {
                                     let file_name = format!(
                                         "{}/{}",
@@ -221,24 +227,24 @@ where
                                             path: file_name,
                                             size: metadata.len(),
                                             hash: sha1.clone(),
-                                    project_type:
+                                            project_type: ProjectType::get_from_parent_folder(&full_path),
-                                        ProjectType::get_from_parent_folder(
-                                            &full_path,
-                                        ),
                                         },
                                     ));
                                 }
 
-                        cached_entries.push(CacheValue::File(CachedFile {
+                                cached_entries.push(CacheValue::File(
+                                    CachedFile {
                                         hash: sha1.clone(),
                                         project_id: version.project_id.clone(),
                                         version_id: version.id.clone(),
-                        }));
+                                    },
+                                ));
 
                                 if let Some(update_version) = update_version {
                                     let mod_loader: ModLoader =
                                         profile.metadata.loader.into();
-                            cached_entries.push(CacheValue::FileUpdate(
+                                    cached_entries.push(
+                                        CacheValue::FileUpdate(
                                             CachedFileUpdate {
                                                 hash: sha1.clone(),
                                                 game_version: profile
@@ -246,13 +252,15 @@ where
                                                     .game_version
                                                     .clone(),
                                                 loaders: vec![
-                                        mod_loader.as_str().to_string(),
+                                                    mod_loader
+                                                        .as_str()
+                                                        .to_string(),
                                                 ],
-                                    update_version_id: update_version
+                                                update_version_id:
-                                        .id
+                                                    update_version.id.clone(),
-                                        .clone(),
                                             },
-                            ));
+                                        ),
+                                    );
 
                                     cached_entries.push(CacheValue::Version(
                                         (*update_version).into(),
@@ -272,8 +280,9 @@ where
                                             badges: 0,
                                         };
 
-                                cached_entries
+                                        cached_entries.push(CacheValue::User(
-                                    .push(CacheValue::User(user.clone()));
+                                            user.clone(),
+                                        ));
 
                                         TeamMember {
                                             team_id: x.team_id,
@@ -287,8 +296,11 @@ where
 
                                 cached_entries.push(CacheValue::Team(members));
 
-                        cached_entries
+                                cached_entries.push(CacheValue::Version(
-                            .push(CacheValue::Version((*version).into()));
+                                    (*version).into(),
+                                ));
+                            }
+                        }
                     }
                 }
 
@@ -320,16 +332,17 @@ where
                         .map(|x| x.id),
                     groups: profile.metadata.groups,
                     linked_data: profile.metadata.linked_data.and_then(|x| {
-                        if let Some(project_id) = x.project_id
+                        if let Some(project_id) = x.project_id {
-                            && let Some(version_id) = x.version_id
+                            if let Some(version_id) = x.version_id {
-                            && let Some(locked) = x.locked
+                                if let Some(locked) = x.locked {
-                        {
                                     return Some(LinkedData {
                                         project_id,
                                         version_id,
                                         locked,
                                     });
                                 }
+                            }
+                        }
 
                         None
                     }),

packages/app-lib/src/state/minecraft_auth.rs

@@ -393,10 +393,11 @@ impl Credentials {
                             ..
                         },
                     ) = *err.raw
-                        && (source.is_connect() || source.is_timeout())
                     {
+                        if source.is_connect() || source.is_timeout() {
                             return Ok(Some(creds));
                         }
+                    }
 
                     Err(err)
                 }
@@ -639,9 +640,10 @@ impl DeviceTokenPair {
             .fetch_optional(exec)
             .await?;
 
-        if let Some(x) = res
+        if let Some(x) = res {
-            && let Ok(uuid) = Uuid::parse_str(&x.uuid)
+            if let Ok(uuid) = Uuid::parse_str(&x.uuid) {
-            && let Ok(private_key) = SigningKey::from_pkcs8_pem(&x.private_key)
+                if let Ok(private_key) =
+                    SigningKey::from_pkcs8_pem(&x.private_key)
                 {
                     return Ok(Some(Self {
                         token: DeviceToken {
@@ -654,7 +656,9 @@ impl DeviceTokenPair {
                                 .single()
                                 .unwrap_or_else(Utc::now),
                             token: x.token,
-                    display_claims: serde_json::from_value(x.display_claims)
+                            display_claims: serde_json::from_value(
+                                x.display_claims,
+                            )
                             .unwrap_or_default(),
                         },
                         key: DeviceTokenKey {
@@ -665,6 +669,8 @@ impl DeviceTokenPair {
                         },
                     }));
                 }
+            }
+        }
 
         Ok(None)
     }
@@ -718,7 +724,7 @@ const MICROSOFT_CLIENT_ID: &str = "00000000402b5328";
 const AUTH_REPLY_URL: &str = "https://login.live.com/oauth20_desktop.srf";
 const REQUESTED_SCOPE: &str = "service::user.auth.xboxlive.com::MBI_SSL";
 
-pub struct RequestWithDate<T> {
+struct RequestWithDate<T> {
     pub date: DateTime<Utc>,
     pub value: T,
 }

packages/app-lib/src/state/process.rs

@@ -360,8 +360,8 @@ impl Process {
                                     }
 
                                     // Write the throwable if present
-                                    if !current_content.is_empty()
+                                    if !current_content.is_empty() {
-                                        && let Err(e) =
+                                        if let Err(e) =
                                             Process::append_to_log_file(
                                                 &log_path,
                                                 &current_content,
@@ -374,6 +374,7 @@ impl Process {
                                         }
                                     }
                                 }
+                            }
                             b"log4j:Event" => {
                                 in_event = false;
                                 // If no throwable was present, write the log entry at the end of the event
@@ -428,7 +429,8 @@ impl Process {
 
                                     if let Some(timestamp) =
                                         current_event.timestamp.as_deref()
-                                        && let Err(e) = Self::maybe_handle_server_join_logging(
+                                    {
+                                        if let Err(e) = Self::maybe_handle_server_join_logging(
                                             profile_path,
                                             timestamp,
                                             message
@@ -437,36 +439,43 @@ impl Process {
                                         }
                                     }
                                 }
+                            }
                             _ => {}
                         }
                     }
                     Ok(Event::Text(mut e)) => {
                         if in_message || in_throwable {
-                            if let Ok(text) = e.xml_content() {
+                            if let Ok(text) = e.unescape() {
                                 current_content.push_str(&text);
                             }
                         } else if !in_event
                             && !e.inplace_trim_end()
                             && !e.inplace_trim_start()
-                            && let Ok(text) = e.xml_content()
+                        {
-                            && let Err(e) = Process::append_to_log_file(
+                            if let Ok(text) = e.unescape() {
+                                if let Err(e) = Process::append_to_log_file(
                                     &log_path,
                                     &format!("{text}\n"),
-                            )
+                                ) {
-                        {
                                     tracing::error!(
                                         "Failed to write to log file: {}",
                                         e
                                     );
                                 }
                             }
+                        }
+                    }
                     Ok(Event::CData(e)) => {
-                        if (in_message || in_throwable)
+                        if in_message || in_throwable {
-                            && let Ok(text) = e.xml_content()
+                            if let Ok(text) = e
+                                .escape()
+                                .map_err(|x| x.into())
+                                .and_then(|x| x.unescape())
                             {
                                 current_content.push_str(&text);
                             }
                         }
+                    }
                     _ => (),
                 }
 
@@ -711,13 +720,16 @@ impl Process {
         let logs_folder = state.directories.profile_logs_dir(&profile_path);
         let log_path = logs_folder.join(LAUNCHER_LOG_PATH);
 
-        if log_path.exists()
+        if log_path.exists() {
-            && let Err(e) = Process::append_to_log_file(
+            if let Err(e) = Process::append_to_log_file(
                 &log_path,
                 &format!("\n# Process exited with status: {mc_exit_status}\n"),
-            )
+            ) {
-        {
+                tracing::warn!(
-            tracing::warn!("Failed to write exit status to log file: {}", e);
+                    "Failed to write exit status to log file: {}",
+                    e
+                );
+            }
         }
 
         let _ = state.discord_rpc.clear_to_default(true).await;

packages/app-lib/src/state/profiles.rs

@@ -595,8 +595,8 @@ impl Profile {
     }
 
     #[tracing::instrument(skip(self, semaphore, icon))]
-    pub async fn set_icon(
+    pub async fn set_icon<'a>(
-        &mut self,
+        &'a mut self,
         cache_dir: &Path,
         semaphore: &IoSemaphore,
         icon: bytes::Bytes,
@@ -629,8 +629,8 @@ impl Profile {
                     {
                         let subdirectory =
                             subdirectory.map_err(io::IOError::from)?.path();
-                        if subdirectory.is_file()
+                        if subdirectory.is_file() {
-                            && let Some(file_name) = subdirectory
+                            if let Some(file_name) = subdirectory
                                 .file_name()
                                 .and_then(|x| x.to_str())
                             {
@@ -647,6 +647,7 @@ impl Profile {
                         }
                     }
                 }
+            }
 
             if profile.install_stage == ProfileInstallStage::MinecraftInstalling
             {
@@ -900,8 +901,8 @@ impl Profile {
                 {
                     let subdirectory =
                         subdirectory.map_err(io::IOError::from)?.path();
-                    if subdirectory.is_file()
+                    if subdirectory.is_file() {
-                        && let Some(file_name) =
+                        if let Some(file_name) =
                             subdirectory.file_name().and_then(|x| x.to_str())
                         {
                             let file_size = subdirectory
@@ -927,6 +928,7 @@ impl Profile {
                     }
                 }
             }
+        }
 
         let file_hashes = CachedEntry::get_file_hash_many(
             &keys.iter().map(|s| &*s.cache_key).collect::<Vec<_>>(),

packages/app-lib/src/util/fetch.rs

@@ -254,7 +254,7 @@ where
 }
 
 #[tracing::instrument(skip(bytes, semaphore))]
-pub async fn write(
+pub async fn write<'a>(
     path: &Path,
     bytes: &[u8],
     semaphore: &IoSemaphore,

packages/app-lib/src/util/jre.rs

@@ -191,13 +191,13 @@ async fn get_all_autoinstalled_jre_path() -> Result<HashSet<PathBuf>, JREError>
         let mut jre_paths = HashSet::new();
         let base_path = state.directories.java_versions_dir();
 
-        if base_path.is_dir()
+        if base_path.is_dir() {
-            && let Ok(dir) = std::fs::read_dir(base_path)
+            if let Ok(dir) = std::fs::read_dir(base_path) {
-        {
                 for entry in dir.flatten() {
                     let file_path = entry.path().join("bin");
 
-                if let Ok(contents) = std::fs::read_to_string(file_path.clone())
+                    if let Ok(contents) =
+                        std::fs::read_to_string(file_path.clone())
                     {
                         let entry = entry.path().join(contents);
                         jre_paths.insert(entry);
@@ -210,6 +210,7 @@ async fn get_all_autoinstalled_jre_path() -> Result<HashSet<PathBuf>, JREError>
                     }
                 }
             }
+        }
 
         Ok(jre_paths)
     })
@@ -299,9 +300,8 @@ pub async fn check_java_at_filepath(path: &Path) -> crate::Result<JavaVersion> {
     }
 
     // Extract version info from it
-    if let Some(arch) = java_arch
+    if let Some(arch) = java_arch {
-        && let Some(version) = java_version
+        if let Some(version) = java_version {
-    {
             if let Ok(version) = extract_java_version(version) {
                 let path = java.to_string_lossy().to_string();
                 return Ok(JavaVersion {
@@ -314,6 +314,7 @@ pub async fn check_java_at_filepath(path: &Path) -> crate::Result<JavaVersion> {
 
             return Err(JREError::InvalidJREVersion(version.to_owned()).into());
         }
+    }
 
     Err(JREError::FailedJavaCheck(java).into())
 }

packages/ariadne/src/versions.rs

@@ -33,12 +33,13 @@ pub fn is_feature_supported_in(
         if part_version == part_first_release {
             continue;
         }
-        if let Ok(part_version) = part_version.parse::<u32>()
+        if let Ok(part_version) = part_version.parse::<u32>() {
-            && let Ok(part_first_release) = part_first_release.parse::<u32>()
+            if let Ok(part_first_release) = part_first_release.parse::<u32>() {
-            && part_version > part_first_release
+                if part_version > part_first_release {
-        {
                     return true;
                 }
             }
+        }
+    }
     false
 }

rust-toolchain.toml

@@ -1,2 +1,2 @@
 [toolchain]
-channel = "1.89.0"
+channel = "1.88.0"