]> Untitled Git - lemmy.git/blob - crates/api/src/local_user/verify_email.rs
a0c4763a6e03ff503c34ef28808994856f1e4796
[lemmy.git] / crates / api / src / local_user / verify_email.rs
1 use crate::Perform;
2 use actix_web::web::Data;
3 use lemmy_api_common::{
4   context::LemmyContext,
5   person::{VerifyEmail, VerifyEmailResponse},
6 };
7 use lemmy_db_schema::{
8   source::{
9     email_verification::EmailVerification,
10     local_user::{LocalUser, LocalUserUpdateForm},
11   },
12   traits::Crud,
13 };
14 use lemmy_utils::error::{LemmyError, LemmyErrorExt, LemmyErrorType};
15
16 #[async_trait::async_trait(?Send)]
17 impl Perform for VerifyEmail {
18   type Response = VerifyEmailResponse;
19
20   async fn perform(&self, context: &Data<LemmyContext>) -> Result<Self::Response, LemmyError> {
21     let token = self.token.clone();
22     let verification = EmailVerification::read_for_token(&mut context.pool(), &token)
23       .await
24       .with_lemmy_type(LemmyErrorType::TokenNotFound)?;
25
26     let form = LocalUserUpdateForm::builder()
27       // necessary in case this is a new signup
28       .email_verified(Some(true))
29       // necessary in case email of an existing user was changed
30       .email(Some(Some(verification.email)))
31       .build();
32     let local_user_id = verification.local_user_id;
33
34     LocalUser::update(&mut context.pool(), local_user_id, &form).await?;
35
36     EmailVerification::delete_old_tokens_for_local_user(&mut context.pool(), local_user_id).await?;
37
38     Ok(VerifyEmailResponse {})
39   }
40 }