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, LemmyErrorExt, LemmyErrorType},
  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()), false)?;
  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 = PrivateMessage::create(context.pool(), &private_message_form)
  57       .await
  58       .with_lemmy_type(LemmyErrorType::CouldntCreatePrivateMessage)?;
  59
  60     let inserted_private_message_id = inserted_private_message.id;
  61     let protocol_and_hostname = context.settings().get_protocol_and_hostname();
  62     let apub_id = generate_local_apub_endpoint(
  63       EndpointType::PrivateMessage,
  64       &inserted_private_message_id.to_string(),
  65       &protocol_and_hostname,
  66     )?;
  67     PrivateMessage::update(
  68       context.pool(),
  69       inserted_private_message.id,
  70       &PrivateMessageUpdateForm::builder()
  71         .ap_id(Some(apub_id))
  72         .build(),
  73     )
  74     .await
  75     .with_lemmy_type(LemmyErrorType::CouldntCreatePrivateMessage)?;
  76
  77     let view = PrivateMessageView::read(context.pool(), inserted_private_message.id).await?;
  78
  79     // Send email to the local recipient, if one exists
  80     if view.recipient.local {
  81       let recipient_id = data.recipient_id;
  82       let local_recipient = LocalUserView::read_person(context.pool(), recipient_id).await?;
  83       let lang = get_interface_language(&local_recipient);
  84       let inbox_link = format!("{}/inbox", context.settings().get_protocol_and_hostname());
  85       let sender_name = &local_user_view.person.name;
  86       send_email_to_user(
  87         &local_recipient,
  88         &lang.notification_private_message_subject(sender_name),
  89         &lang.notification_private_message_body(inbox_link, &content_slurs_removed, sender_name),
  90         context.settings(),
  91       )
  92       .await;
  93     }
  94
  95     Ok(PrivateMessageResponse {
  96       private_message_view: view,
  97     })
  98   }
  99 }