crates/api_crud/src/private_message/create.rs

   1 use crate::PerformCrud;
   2 use actix_web::web::Data;
   3 use lemmy_api_common::{
   4   context::LemmyContext,
   5   private_message::{CreatePrivateMessage, PrivateMessageResponse},
   6   utils::{
   7     check_person_block,
   8     generate_local_apub_endpoint,
   9     get_interface_language,
  10     local_site_to_slur_regex,
  11     local_user_view_from_jwt,
  12     send_email_to_user,
  13     EndpointType,
  14   },
  15 };
  16 use lemmy_db_schema::{
  17   source::{
  18     local_site::LocalSite,
  19     private_message::{PrivateMessage, PrivateMessageInsertForm, PrivateMessageUpdateForm},
  20   },
  21   traits::Crud,
  22 };
  23 use lemmy_db_views::structs::{LocalUserView, PrivateMessageView};
  24 use lemmy_utils::{
  25   error::LemmyError,
  26   utils::{slurs::remove_slurs, validation::is_valid_body_field},
  27 };
  28
  29 #[async_trait::async_trait(?Send)]
  30 impl PerformCrud for CreatePrivateMessage {
  31   type Response = PrivateMessageResponse;
  32
  33   #[tracing::instrument(skip(self, context))]
  34   async fn perform(
  35     &self,
  36     context: &Data<LemmyContext>,
  37   ) -> Result<PrivateMessageResponse, LemmyError> {
  38     let data: &CreatePrivateMessage = self;
  39     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
  40     let local_site = LocalSite::read(context.pool()).await?;
  41
  42     let content_slurs_removed = remove_slurs(
  43       &data.content.clone(),
  44       &local_site_to_slur_regex(&local_site),
  45     );
  46     is_valid_body_field(&Some(content_slurs_removed.clone()))?;
  47
  48     check_person_block(local_user_view.person.id, data.recipient_id, context.pool()).await?;
  49
  50     let private_message_form = PrivateMessageInsertForm::builder()
  51       .content(content_slurs_removed.clone())
  52       .creator_id(local_user_view.person.id)
  53       .recipient_id(data.recipient_id)
  54       .build();
  55
  56     let inserted_private_message =
  57       match PrivateMessage::create(context.pool(), &private_message_form).await {
  58         Ok(private_message) => private_message,
  59         Err(e) => {
  60           return Err(LemmyError::from_error_message(
  61             e,
  62             "couldnt_create_private_message",
  63           ));
  64         }
  65       };
  66
  67     let inserted_private_message_id = inserted_private_message.id;
  68     let protocol_and_hostname = context.settings().get_protocol_and_hostname();
  69     let apub_id = generate_local_apub_endpoint(
  70       EndpointType::PrivateMessage,
  71       &inserted_private_message_id.to_string(),
  72       &protocol_and_hostname,
  73     )?;
  74     PrivateMessage::update(
  75       context.pool(),
  76       inserted_private_message.id,
  77       &PrivateMessageUpdateForm::builder()
  78         .ap_id(Some(apub_id))
  79         .build(),
  80     )
  81     .await
  82     .map_err(|e| LemmyError::from_error_message(e, "couldnt_create_private_message"))?;
  83
  84     let view = PrivateMessageView::read(context.pool(), inserted_private_message.id).await?;
  85
  86     // Send email to the local recipient, if one exists
  87     if view.recipient.local {
  88       let recipient_id = data.recipient_id;
  89       let local_recipient = LocalUserView::read_person(context.pool(), recipient_id).await?;
  90       let lang = get_interface_language(&local_recipient);
  91       let inbox_link = format!("{}/inbox", context.settings().get_protocol_and_hostname());
  92       let sender_name = &local_user_view.person.name;
  93       send_email_to_user(
  94         &local_recipient,
  95         &lang.notification_private_message_subject(sender_name),
  96         &lang.notification_private_message_body(inbox_link, &content_slurs_removed, sender_name),
  97         context.settings(),
  98       );
  99     }
 100
 101     Ok(PrivateMessageResponse {
 102       private_message_view: view,
 103     })
 104   }
 105 }