wip: move jwt to env

ElaBosak233 · ElaBosak233 · commit b00e49021cb4 · 2025-01-24T22:16:23.000+08:00
diff --git a/crates/cache/src/lib.rs b/crates/cache/src/lib.rs
@@ -60,6 +60,11 @@ pub async fn set_ex(
     Ok(())
 }
 
+pub async fn exists(key: impl Into<Key> + Send + Display) -> Result<bool, CacheError> {
+    let result = get_client().exists(key).await?;
+    Ok(result)
+}
+
 pub async fn flush() -> Result<(), CacheError> {
     get_client().flushall::<()>(false).await?;
 
diff --git a/crates/config/src/auth/jwt.rs b/crates/config/src/auth/jwt.rs
diff --git a/crates/config/src/auth/mod.rs b/crates/config/src/auth/mod.rs
@@ -1,11 +1,9 @@
-pub mod jwt;
 pub mod registration;
 
 use sea_orm::FromJsonQueryResult;
 use serde::{Deserialize, Serialize};
 
 #[derive(Clone, Debug, Serialize, Deserialize, FromJsonQueryResult, PartialEq, Eq, Default)]
 pub struct Config {
-    pub jwt: jwt::Config,
     pub registration: registration::Config,
 }
diff --git a/crates/config/src/lib.rs b/crates/config/src/lib.rs
@@ -20,12 +20,6 @@ impl From<cds_db::entity::config::Model> for Config {
     }
 }
 
-impl Config {
-    pub fn desensitize(&mut self) {
-        self.auth.jwt.secret_key.clear();
-    }
-}
-
 pub async fn init() {
     let config = cds_cache::get::<Config>("config").await.unwrap();
     if config.is_none() {
diff --git a/crates/env/src/axum/jwt.rs b/crates/env/src/axum/jwt.rs
@@ -0,0 +1,7 @@
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Debug, Serialize, Deserialize)]
+pub struct Env {
+    pub secret: String,
+    pub expiration: i64,
+}
diff --git a/crates/env/src/axum/mod.rs b/crates/env/src/axum/mod.rs
@@ -1,7 +1,10 @@
+pub mod jwt;
+
 use serde::{Deserialize, Serialize};
 
 #[derive(Clone, Debug, Serialize, Deserialize)]
 pub struct Env {
     pub host: String,
     pub port: u16,
+    pub jwt: jwt::Env,
 }
diff --git a/crates/server/src/migrator.rs b/crates/server/src/migrator.rs
@@ -77,10 +77,6 @@ pub async fn init_config() {
         let config = entity::config::ActiveModel {
             value: Set(serde_json::to_value(cds_config::Config {
                 auth: cds_config::auth::Config {
-                    jwt: cds_config::auth::jwt::Config {
-                        secret_key: String::from(uuid::Uuid::new_v4()),
-                        expiration: 1800,
-                    },
                     registration: cds_config::auth::registration::Config {
                         enabled: true,
                         captcha: false,
diff --git a/crates/web/Cargo.toml b/crates/web/Cargo.toml
@@ -9,6 +9,8 @@ resolver = "2"
 cds-db = { workspace = true }
 cds-config = { workspace = true }
 cds-cluster = { workspace = true }
+cds-cache = { workspace = true }
+cds-env = { workspace = true }
 cds-media = { workspace = true }
 cds-metric = { workspace = true }
 cds-queue = { workspace = true }
diff --git a/crates/web/src/middleware/mod.rs b/crates/web/src/middleware/mod.rs
@@ -38,7 +38,7 @@ pub async fn auth(mut req: Request<Body>, next: Next) -> Result<Response, WebErr
 
     let token = jar.get("token").map(|cookie| cookie.value()).unwrap_or("");
 
-    let decoding_key = DecodingKey::from_secret(crate::util::jwt::get_secret().await.as_bytes());
+    let decoding_key = DecodingKey::from_secret(crate::util::jwt::get_jwt_config().await.secret.as_bytes());
     let validation = Validation::default();
 
     let mut user: Option<cds_db::transfer::User> = None;
diff --git a/crates/web/src/router/api/config/mod.rs b/crates/web/src/router/api/config/mod.rs
@@ -48,8 +48,7 @@ pub async fn get(
             })
         }
         _ => {
-            let mut config = get_config().await;
-            config.desensitize();
+            let config = get_config().await;
 
             Ok(WebResponse {
                 code: StatusCode::OK.as_u16(),
diff --git a/crates/web/src/router/api/user/mod.rs b/crates/web/src/router/api/user/mod.rs
@@ -270,7 +270,7 @@ pub async fn login(Json(mut body): Json<LoginRequest>) -> Result<impl IntoRespon
         format!(
             "token={}; Max-Age={}; Path=/; HttpOnly; SameSite=Strict",
             token,
-            chrono::Duration::minutes(cds_config::get_config().await.auth.jwt.expiration)
+            chrono::Duration::minutes(jwt::get_jwt_config().await.expiration)
                 .num_seconds()
         )
         .parse()
diff --git a/crates/web/src/util/jwt.rs b/crates/web/src/util/jwt.rs
@@ -1,29 +1,44 @@
 use jsonwebtoken::{EncodingKey, Header, encode};
+use regex::Regex;
 use serde::{Deserialize, Serialize};
+use uuid::Uuid;
 
 #[derive(Debug, Deserialize, Serialize)]
 pub struct Claims {
     pub id: i64,
     pub exp: usize,
 }
 
-pub async fn get_secret() -> String {
-    cds_config::get_config().await.auth.jwt.secret_key
+pub async fn get_jwt_config() -> cds_env::axum::jwt::Env {
+    if let Some(jwt) = cds_cache::get::<cds_env::axum::jwt::Env>("jwt")
+        .await
+        .unwrap()
+    {
+        return jwt;
+    }
+
+    let mut jwt = cds_env::get_env().axum.jwt.clone();
+    let re = Regex::new(r"\[([Uu][Uu][Ii][Dd])]").unwrap();
+    jwt.secret = re
+        .replace_all(&jwt.secret, Uuid::new_v4().simple().to_string())
+        .to_string();
+    let _ = cds_cache::set("jwt", jwt.clone()).await;
+
+    jwt
 }
 
 pub async fn generate_jwt_token(user_id: i64) -> String {
-    let secret = get_secret().await;
+    let jwt_config = get_jwt_config().await;
     let claims = Claims {
         id: user_id,
-        exp: (chrono::Utc::now()
-            + chrono::Duration::minutes(cds_config::get_config().await.auth.jwt.expiration))
-        .timestamp() as usize,
+        exp: (chrono::Utc::now() + chrono::Duration::minutes(jwt_config.expiration)).timestamp()
+            as usize,
     };
 
     encode(
         &Header::default(),
         &claims,
-        &EncodingKey::from_secret(secret.as_bytes()),
+        &EncodingKey::from_secret(jwt_config.secret.as_bytes()),
     )
     .unwrap()
 }

Original file line number	Diff line number	Diff line change
`@@ -20,12 +20,6 @@ impl From<cds_db::entity::config::Model> for Config {`
`20`	`20`	`}`
`21`	`21`	`}`
`22`	`22`
`23`		`-impl Config {`
`24`		`- pub fn desensitize(&mut self) {`
`25`		`- self.auth.jwt.secret_key.clear();`
`26`		`- }`
`27`		`-}`
`28`		`-`
`29`	`23`	`pub async fn init() {`
`30`	`24`	`let config = cds_cache::get::<Config>("config").await.unwrap();`
`31`	`25`	`if config.is_none() {`
Original file line number	Diff line number	Diff line change
`@@ -48,8 +48,7 @@ pub async fn get(`
`48`	`48`	`})`
`49`	`49`	`}`
`50`	`50`	`_ => {`
`51`		`- let mut config = get_config().await;`
`52`		`- config.desensitize();`
	`51`	`+ let config = get_config().await;`
`53`	`52`
`54`	`53`	`Ok(WebResponse {`
`55`	`54`	`code: StatusCode::OK.as_u16(),`
Original file line number	Diff line number	Diff line change
`@@ -270,7 +270,7 @@ pub async fn login(Json(mut body): Json<LoginRequest>) -> Result<impl IntoRespon`
`270`	`270`	`format!(`
`271`	`271`	`"token={}; Max-Age={}; Path=/; HttpOnly; SameSite=Strict",`
`272`	`272`	`token,`
`273`		`- chrono::Duration::minutes(cds_config::get_config().await.auth.jwt.expiration)`
	`273`	`+ chrono::Duration::minutes(jwt::get_jwt_config().await.expiration)`
`274`	`274`	`.num_seconds()`
`275`	`275`	`)`
`276`	`276`	`.parse()`