chore: format

Author: 7086cmd

Cargo.lock

@@ -9,7 +9,13 @@ edition = "2021"
 aes = "0.8.4"
 axum = "0.7.5"
 axum-core = "0.4.3"
-axum-extra = { version = "0.9.3", features = ["form", "query", "typed-header", "typed-routing", "multipart"] }
+axum-extra = { version = "0.9.3", features = [
+    "form",
+    "query",
+    "typed-header",
+    "typed-routing",
+    "multipart",
+] }
 b2-client = { version = "0.1.3", features = ["with_surf"] }
 base64 = "0.22.0"
 bcrypt = "0.15.1"
@@ -22,19 +28,32 @@ jsonwebtoken = "9.3.0"
 mongodb = { version = "2.8.2", features = ["async-std"] }
 once_cell = "1.19.0"
 pem = { version = "3.0.4", features = ["serde"] }
+polars = "0.39.2"
 rand = "0.8.5"
 reqwest = "0.12.3"
 rsa = "0.9.6"
 serde = "1.0.198"
 serde_json = "1.0.116"
 serde_qs = { version = "0.13.0", features = ["axum"] }
-socketioxide = { version = "0.12.0", features = ["state", "extensions", "tracing"] }
+socketioxide = { version = "0.12.0", features = [
+    "state",
+    "extensions",
+    "tracing",
+] }
 tokio = { version = "1.37.0", features = ["full"] }
 tower = "0.4.13"
 tower-http = "0.5.2"
 tracing = { version = "0.1.40", features = ["log"] }
-tracing-subscriber = { version = "0.3.18", features = ["tracing", "time", "serde", "serde_json", "json", "regex"] }
+tracing-subscriber = { version = "0.3.18", features = [
+    "tracing",
+    "time",
+    "serde",
+    "serde_json",
+    "json",
+    "regex",
+] }
 uuid = "1.8.0"
+xlsxwriter = "0.6.0"
 zerocopy = "0.7.32"
 
 [profile.release]

Cargo.toml

@@ -0,0 +1 @@
+

src/calc/mod.rs

@@ -1,5 +1,8 @@
+use crate::utils::{
+    aes::generate_aes256_key,
+    rsa::{generate_keypair, save_keypair},
+};
 use tokio::fs::{try_exists, write};
-use crate::utils::{rsa::{generate_keypair, save_keypair}, aes::generate_aes256_key};
 
 pub async fn generate_rsa_keypair() {
     let private_exists = try_exists("private.pem").await.unwrap();

src/launch.rs

@@ -1,4 +1,5 @@
 extern crate chrono;
+mod calc;
 mod database;
 mod launch;
 mod models;
@@ -78,7 +79,7 @@ async fn main() {
         )
         .route(
             "/activity/:id/member/:member_id",
-            get(routers::activities::members::read::read_member)
+            get(routers::activities::members::read::read_member),
         )
         .route(
             "/activity/:id/member",

src/main.rs

@@ -54,7 +54,10 @@ pub enum SpecialActivityCategory {
 
 #[derive(Debug, Serialize, Deserialize, Clone, PartialEq)]
 pub struct ActivityMember {
-    #[serde(serialize_with = "objectid_to_string", deserialize_with = "string_to_objectid")]
+    #[serde(
+        serialize_with = "objectid_to_string",
+        deserialize_with = "string_to_objectid"
+    )]
     pub _id: ObjectId, // ObjectId
     pub status: ActivityMemberStatus,
     pub impression: Option<String>,
@@ -69,7 +72,10 @@ pub struct ActivityMemberHistory {
     pub impression: String,
     pub duration: f64,
     pub time: String,
-    #[serde(serialize_with = "objectid_to_string", deserialize_with = "string_to_objectid")]
+    #[serde(
+        serialize_with = "objectid_to_string",
+        deserialize_with = "string_to_objectid"
+    )]
     pub actioner: ObjectId, // ObjectId
     pub action: ActivityMemberStatus,
 }
@@ -132,7 +138,10 @@ pub struct Activity {
     pub created_at: u64,
     #[serde(deserialize_with = "datetime_or_u64")]
     pub updated_at: u64,
-    #[serde(serialize_with = "objectid_to_string", deserialize_with = "string_to_objectid")]
+    #[serde(
+        serialize_with = "objectid_to_string",
+        deserialize_with = "string_to_objectid"
+    )]
     pub creator: ObjectId, // ObjectId
     pub status: ActivityStatus,
     pub members: Option<Vec<ActivityMember>>,

src/models/activities.rs

@@ -1,5 +1,5 @@
 pub mod activities;
 pub mod groups;
+pub mod notifications;
 pub mod response;
 pub mod users;
-pub mod notifications;

src/models/mod.rs

@@ -1,6 +1,6 @@
+use crate::models::activities::datetime_or_u64;
 use bson::oid::ObjectId;
 use serde::{Deserialize, Serialize};
-use crate::models::activities::datetime_or_u64;
 
 #[derive(Debug, Serialize, Deserialize, Clone, PartialEq, Eq, Hash)]
 #[serde(rename_all = "kebab-case")]

src/models/notifications.rs

@@ -83,8 +83,7 @@ impl UserTrait for User {
                         }
                     }
                 }
-                let token =
-                    generate_token(&user._id.to_string(), term, permissions);
+                let token = generate_token(&user._id.to_string(), term, permissions);
                 Ok(token)
             }
             Ok(None) => Err("User not found".to_string()),

src/models/users.rs

@@ -1,6 +1,11 @@
-use crate::{models::{
-    activities::{Activity, ActivityStatus, ActivityType}, groups::GroupPermission, response::{ResponseStatus, SuccessResponse, create_error}
-}, utils::jwt::UserData};
+use crate::{
+    models::{
+        activities::{Activity, ActivityStatus, ActivityType},
+        groups::GroupPermission,
+        response::{create_error, ResponseStatus, SuccessResponse},
+    },
+    utils::jwt::UserData,
+};
 use axum::{
     extract::{Extension, Query},
     http::StatusCode,
@@ -37,7 +42,9 @@ pub async fn insert_activity(
             return create_error(StatusCode::FORBIDDEN, "Permission denied".to_string());
         }
     } else {
-        if activity.activity_type == ActivityType::Social || activity.activity_type == ActivityType::Scale {
+        if activity.activity_type == ActivityType::Social
+            || activity.activity_type == ActivityType::Scale
+        {
             activity.status = ActivityStatus::Pending;
         } else {
             return create_error(StatusCode::FORBIDDEN, "Permission denied".to_string());