style: cargo fmt

Author: z0z0r4

src/config/_redis.rs

@@ -1,18 +1,18 @@
-use redis::{Client, aio::MultiplexedConnection};
-use std::sync::Arc;
+use redis::{aio::MultiplexedConnection, Client};
 use std::env;
+use std::sync::Arc;
 
-pub async fn connect() -> Result<Arc<MultiplexedConnection>, Box<dyn std::error::Error + Send + Sync>> {
-    let redis_url = env::var("REDIS_URL")
-        .unwrap_or_else(|_| "redis://localhost:6379".to_string());
+pub async fn connect(
+) -> Result<Arc<MultiplexedConnection>, Box<dyn std::error::Error + Send + Sync>> {
+    let redis_url = env::var("REDIS_URL").unwrap_or_else(|_| "redis://localhost:6379".to_string());
 
     let client = Client::open(redis_url)?;
-    
+
     // 获取异步 MultiplexedConnection
     let conn = client.get_multiplexed_async_connection().await?;
-    
+
     log::info!("Connected to Redis successfully!");
-    
+
     Ok(Arc::new(conn))
 }
 
@@ -32,4 +32,4 @@ pub fn get_redis_queue_database() -> i64 {
         .unwrap_or_else(|_| "1".to_string())
         .parse()
         .unwrap_or(1)
-}
+}

src/config/database.rs

@@ -1,23 +1,22 @@
-use mongodb::{Client, options::ClientOptions};
+use mongodb::{options::ClientOptions, Client};
 use std::env;
 
 pub async fn connect() -> Result<Client, Box<dyn std::error::Error>> {
-    let uri = env::var("MONGODB_URI")
-        .unwrap_or_else(|_| "mongodb://localhost:27017".to_string());
-    
+    let uri = env::var("MONGODB_URI").unwrap_or_else(|_| "mongodb://localhost:27017".to_string());
+
     let client_options = ClientOptions::parse(&uri).await?;
     let client = Client::with_options(client_options)?;
-    
+
     // 测试连接
     client
         .database("admin")
         .run_command(mongodb::bson::doc! {"ping": 1}, None)
         .await?;
-    
+
     log::info!("Connected to MongoDB successfully!");
     Ok(client)
 }
 
 pub fn get_database_name() -> String {
     env::var("DATABASE_NAME").unwrap_or_else(|_| "mcim_backend".to_string())
-}
+}

src/config/mod.rs

@@ -1,8 +1,8 @@
-pub mod database;
 pub mod _redis;
+pub mod database;
 
-use std::sync::Arc;
 use redis::aio::MultiplexedConnection;
+use std::sync::Arc;
 
 #[derive(Clone)]
 pub struct AppState {
@@ -13,4 +13,4 @@ pub struct AppState {
     pub curseforge_api_key: String,
     pub curseforge_file_cdn_url: String,
     pub modrinth_file_cdn_url: String,
-}
+}

src/errors/mod.rs

@@ -1,6 +1,6 @@
-pub mod services;
 pub mod routes;
+pub mod services;
 
-pub use services::ServiceError;
+pub use routes::map_actix_error;
 pub use routes::ApiError;
-pub use routes::map_actix_error;
+pub use services::ServiceError;

src/errors/services.rs

@@ -1,6 +1,6 @@
+use mongodb::error::Error as MongoError;
 use std::error::Error as StdError;
 use std::fmt::{Display, Formatter};
-use mongodb::error::Error as MongoError;
 
 #[derive(Debug)]
 pub enum ServiceError {
@@ -77,4 +77,3 @@ impl From<serde_json::Error> for ServiceError {
         ServiceError::UnexpectedError(format!("JSON serialization error: {}", err))
     }
 }
-

src/main.rs

@@ -5,9 +5,9 @@ pub mod routes;
 pub mod services;
 pub mod utils;
 
+use actix_middleware_etag::Etag;
 use actix_web::middleware::{Compress, Logger};
 use actix_web::{dev::ServiceRequest, web, App, HttpServer};
-use actix_middleware_etag::{Etag};
 use dotenvy::dotenv;
 use std::env;
 

src/models/common/mod.rs

@@ -1,3 +1,3 @@
 // pub mod entities;
 pub mod requests;
-pub mod responses;
+pub mod responses;

src/models/common/requests.rs

@@ -1,9 +1,8 @@
 use serde::Deserialize;
 
-
 #[derive(Deserialize)]
 pub struct StatisticsQuery {
     pub curseforge: Option<bool>,
     pub modrinth: Option<bool>,
     pub translate: Option<bool>,
-}
+}

src/models/common/responses.rs

@@ -1,9 +1,9 @@
 use serde::Serialize;
-use utoipa::{ToSchema};
+use utoipa::ToSchema;
 
 #[derive(Serialize, ToSchema)]
 pub struct StatisticsResponse {
     pub curseforge: Option<i64>,
     pub modrinth: Option<i64>,
     pub translate: Option<i64>,
-}
+}

src/models/curseforge/mod.rs

@@ -1,3 +1,3 @@
 pub mod entities;
 pub mod requests;
-pub mod responses;
+pub mod responses;