use crate::PerformCrud; use actix_web::web::Data; use lemmy_api_common::{ context::LemmyContext, private_message::{DeletePrivateMessage, PrivateMessageResponse}, utils::local_user_view_from_jwt, }; use lemmy_db_schema::{ source::private_message::{PrivateMessage, PrivateMessageUpdateForm}, traits::Crud, }; use lemmy_db_views::structs::PrivateMessageView; use lemmy_utils::error::{LemmyError, LemmyErrorExt, LemmyErrorType}; #[async_trait::async_trait(?Send)] impl PerformCrud for DeletePrivateMessage { type Response = PrivateMessageResponse; #[tracing::instrument(skip(self, context))] async fn perform( &self, context: &Data, ) -> Result { let data: &DeletePrivateMessage = self; let local_user_view = local_user_view_from_jwt(&data.auth, context).await?; // Checking permissions let private_message_id = data.private_message_id; let orig_private_message = PrivateMessage::read(&mut context.pool(), private_message_id).await?; if local_user_view.person.id != orig_private_message.creator_id { return Err(LemmyErrorType::EditPrivateMessageNotAllowed)?; } // Doing the update let private_message_id = data.private_message_id; let deleted = data.deleted; PrivateMessage::update( &mut context.pool(), private_message_id, &PrivateMessageUpdateForm::builder() .deleted(Some(deleted)) .build(), ) .await .with_lemmy_type(LemmyErrorType::CouldntUpdatePrivateMessage)?; let view = PrivateMessageView::read(&mut context.pool(), private_message_id).await?; Ok(PrivateMessageResponse { private_message_view: view, }) } }