crates/api_crud/src/private_message/delete.rs

   1 use crate::PerformCrud;
   2 use actix_web::web::Data;
   3 use lemmy_api_common::{
   4   blocking,
   5   get_local_user_view_from_jwt,
   6   person::{DeletePrivateMessage, PrivateMessageResponse},
   7 };
   8 use lemmy_apub::activities::deletion::send_apub_delete_private_message;
   9 use lemmy_db_schema::{source::private_message::PrivateMessage, traits::Crud};
  10 use lemmy_utils::{ConnectionId, LemmyError};
  11 use lemmy_websocket::{send::send_pm_ws_message, LemmyContext, UserOperationCrud};
  12
  13 #[async_trait::async_trait(?Send)]
  14 impl PerformCrud for DeletePrivateMessage {
  15   type Response = PrivateMessageResponse;
  16
  17   #[tracing::instrument(skip(self, context, websocket_id))]
  18   async fn perform(
  19     &self,
  20     context: &Data<LemmyContext>,
  21     websocket_id: Option<ConnectionId>,
  22   ) -> Result<PrivateMessageResponse, LemmyError> {
  23     let data: &DeletePrivateMessage = self;
  24     let local_user_view =
  25       get_local_user_view_from_jwt(&data.auth, context.pool(), context.secret()).await?;
  26
  27     // Checking permissions
  28     let private_message_id = data.private_message_id;
  29     let orig_private_message = blocking(context.pool(), move |conn| {
  30       PrivateMessage::read(conn, private_message_id)
  31     })
  32     .await??;
  33     if local_user_view.person.id != orig_private_message.creator_id {
  34       return Err(LemmyError::from_message("no_private_message_edit_allowed"));
  35     }
  36
  37     // Doing the update
  38     let private_message_id = data.private_message_id;
  39     let deleted = data.deleted;
  40     let updated_private_message = blocking(context.pool(), move |conn| {
  41       PrivateMessage::update_deleted(conn, private_message_id, deleted)
  42     })
  43     .await?
  44     .map_err(LemmyError::from)
  45     .map_err(|e| e.with_message("couldnt_update_private_message"))?;
  46
  47     // Send the apub update
  48     send_apub_delete_private_message(
  49       &local_user_view.person.into(),
  50       updated_private_message,
  51       data.deleted,
  52       context,
  53     )
  54     .await?;
  55
  56     let op = UserOperationCrud::DeletePrivateMessage;
  57     send_pm_ws_message(data.private_message_id, op, websocket_id, context).await
  58   }
  59 }