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_schema::source::{comment::Comment, person::Person, post::Post};
   6 use lemmy_utils::{ConnectionId, LemmyError};
   7 use lemmy_websocket::LemmyContext;
   8
   9 #[async_trait::async_trait(?Send)]
  10 impl PerformCrud for DeleteAccount {
  11   type Response = DeleteAccountResponse;
  12
  13   #[tracing::instrument(skip(self, context, _websocket_id))]
  14   async fn perform(
  15     &self,
  16     context: &Data<LemmyContext>,
  17     _websocket_id: Option<ConnectionId>,
  18   ) -> Result<Self::Response, LemmyError> {
  19     let data = self;
  20     let local_user_view =
  21       get_local_user_view_from_jwt(data.auth.as_ref(), 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(LemmyError::from_message("password_incorrect"));
  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     blocking(context.pool(), permadelete)
  37       .await?
  38       .map_err(|e| LemmyError::from_error_message(e, "couldnt_update_comment"))?;
  39
  40     // Posts
  41     let permadelete = move |conn: &'_ _| Post::permadelete_for_creator(conn, person_id);
  42     blocking(context.pool(), permadelete)
  43       .await?
  44       .map_err(|e| LemmyError::from_error_message(e, "couldnt_update_post"))?;
  45
  46     blocking(context.pool(), move |conn| {
  47       Person::delete_account(conn, person_id)
  48     })
  49     .await??;
  50
  51     Ok(DeleteAccountResponse {})
  52   }
  53 }