crates/api_crud/src/user/delete.rs

   1 use crate::PerformCrud;
   2 use actix_web::web::Data;
   3 use bcrypt::verify;
   4 use lemmy_api_common::{blocking, get_local_user_view_from_jwt, person::*};
   5 use lemmy_db_queries::source::{comment::Comment_, person::Person_, post::Post_};
   6 use lemmy_db_schema::source::{comment::Comment, person::*, post::Post};
   7 use lemmy_utils::{ApiError, ConnectionId, LemmyError};
   8 use lemmy_websocket::LemmyContext;
   9
  10 #[async_trait::async_trait(?Send)]
  11 impl PerformCrud for DeleteAccount {
  12   type Response = LoginResponse;
  13
  14   async fn perform(
  15     &self,
  16     context: &Data<LemmyContext>,
  17     _websocket_id: Option<ConnectionId>,
  18   ) -> Result<LoginResponse, LemmyError> {
  19     let data: &DeleteAccount = self;
  20     let local_user_view =
  21       get_local_user_view_from_jwt(&data.auth, context.pool(), context.secret()).await?;
  22
  23     // Verify the password
  24     let valid: bool = verify(
  25       &data.password,
  26       &local_user_view.local_user.password_encrypted,
  27     )
  28     .unwrap_or(false);
  29     if !valid {
  30       return Err(ApiError::err("password_incorrect").into());
  31     }
  32
  33     // Comments
  34     let person_id = local_user_view.person.id;
  35     let permadelete = move |conn: &'_ _| Comment::permadelete_for_creator(conn, person_id);
  36     if blocking(context.pool(), permadelete).await?.is_err() {
  37       return Err(ApiError::err("couldnt_update_comment").into());
  38     }
  39
  40     // Posts
  41     let permadelete = move |conn: &'_ _| Post::permadelete_for_creator(conn, person_id);
  42     if blocking(context.pool(), permadelete).await?.is_err() {
  43       return Err(ApiError::err("couldnt_update_post").into());
  44     }
  45
  46     blocking(context.pool(), move |conn| {
  47       Person::delete_account(conn, person_id)
  48     })
  49     .await??;
  50
  51     Ok(LoginResponse {
  52       jwt: data.auth.to_owned(),
  53     })
  54   }
  55 }