fix: feat: remove duplicate operation of storing jwt in the database

src/handler/users.rs

@@ -33,15 +33,24 @@ pub async fn get_me(
 
 pub async fn put_me_email(
     State(state): State<Repository>,
+    TypedHeader(cookie): TypedHeader<Cookie>,
     Json(body): Json<EmailUpdate>,
 ) -> anyhow::Result<StatusCode, StatusCode> {
+    let session_id = cookie.get("session_id").ok_or(StatusCode::UNAUTHORIZED)?;
+
+    let user_id = state
+        .get_user_id_by_session_id(session_id)
+        .await
+        .map_err(|_| StatusCode::INTERNAL_SERVER_ERROR)?
+        .ok_or(StatusCode::UNAUTHORIZED)?;
+
     let email = body
         .email
         .parse::<Address>()
         .map_err(|_| StatusCode::INTERNAL_SERVER_ERROR)?;
 
     let jwt = state
-        .save_email_varifications(&body.email)
+        .encode_email_update_jwt(user_id, &body.email)
         .await
         .map_err(|_| StatusCode::INTERNAL_SERVER_ERROR)?;
     let message = format!(

src/repository.rs

@@ -6,6 +6,7 @@ use sqlx::{
 
 mod signup_jwt;
 mod users;
+mod users_jwt;
 mod users_session;
 
 #[derive(Clone)]

src/repository/users_jwt.rs

@@ -0,0 +1,36 @@
+use async_session::chrono::{Duration, Utc};
+use serde::{Deserialize, Serialize};
+
+use super::Repository;
+
+#[derive(Serialize, Deserialize)]
+struct SignupClaims {
+    user_id: i64,
+    email: String,
+    exp: i64,
+}
+
+impl Repository {
+    pub async fn encode_email_update_jwt(
+        &self,
+        user_id: i64,
+        email: &str,
+    ) -> anyhow::Result<String> {
+        let exp = (Utc::now() + Duration::minutes(60)).timestamp();
+        let claims = SignupClaims {
+            user_id: user_id,
+            email: email.to_owned(),
+            exp,
+        };
+
+        let encode_key: String = std::env::var("JWT_SECRET")?;
+
+        let jwt = jsonwebtoken::encode(
+            &jsonwebtoken::Header::default(),
+            &claims,
+            &jsonwebtoken::EncodingKey::from_secret(encode_key.as_ref()),
+        )?;
+
+        Ok(jwt)
+    }
+}