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