crates/api_crud/src/private_message/read.rs

   1 use actix_web::web::{Data, Json, Query};
   2 use lemmy_api_common::{
   3   context::LemmyContext,
   4   private_message::{GetPrivateMessages, PrivateMessagesResponse},
   5   utils::local_user_view_from_jwt,
   6 };
   7 use lemmy_db_views::private_message_view::PrivateMessageQuery;
   8 use lemmy_utils::error::LemmyError;
   9
  10 #[tracing::instrument(skip(context))]
  11 pub async fn get_private_message(
  12   data: Query<GetPrivateMessages>,
  13   context: Data<LemmyContext>,
  14 ) -> Result<Json<PrivateMessagesResponse>, LemmyError> {
  15   let local_user_view = local_user_view_from_jwt(data.auth.as_ref(), &context).await?;
  16   let person_id = local_user_view.person.id;
  17
  18   let page = data.page;
  19   let limit = data.limit;
  20   let unread_only = data.unread_only;
  21   let mut messages = PrivateMessageQuery {
  22     page,
  23     limit,
  24     unread_only,
  25   }
  26   .list(&mut context.pool(), person_id)
  27   .await?;
  28
  29   // Messages sent by ourselves should be marked as read. The `read` column in database is only
  30   // for the recipient, and shouldnt be exposed to sender.
  31   messages.iter_mut().for_each(|pmv| {
  32     if pmv.creator.id == person_id {
  33       pmv.private_message.read = true
  34     }
  35   });
  36
  37   Ok(Json(PrivateMessagesResponse {
  38     private_messages: messages,
  39   }))
  40 }