crates/apub/src/api/read_person.rs

   1 use crate::{fetcher::resolve_actor_identifier, objects::person::ApubPerson};
   2 use activitypub_federation::config::Data;
   3 use actix_web::web::{Json, Query};
   4 use lemmy_api_common::{
   5   context::LemmyContext,
   6   person::{GetPersonDetails, GetPersonDetailsResponse},
   7   utils::{check_private_instance, is_admin, local_user_view_from_jwt_opt},
   8 };
   9 use lemmy_db_schema::{
  10   source::{local_site::LocalSite, person::Person},
  11   utils::post_to_comment_sort_type,
  12 };
  13 use lemmy_db_views::{comment_view::CommentQuery, post_view::PostQuery};
  14 use lemmy_db_views_actor::structs::{CommunityModeratorView, PersonView};
  15 use lemmy_utils::error::LemmyError;
  16
  17 #[tracing::instrument(skip(context))]
  18 pub async fn read_person(
  19   data: Query<GetPersonDetails>,
  20   context: Data<LemmyContext>,
  21 ) -> Result<Json<GetPersonDetailsResponse>, LemmyError> {
  22   // Check to make sure a person name or an id is given
  23   if data.username.is_none() && data.person_id.is_none() {
  24     return Err(LemmyError::from_message("no_id_given"));
  25   }
  26
  27   let local_user_view = local_user_view_from_jwt_opt(data.auth.as_ref(), &context).await;
  28   let local_site = LocalSite::read(context.pool()).await?;
  29   let is_admin = local_user_view.as_ref().map(|luv| is_admin(luv).is_ok());
  30
  31   check_private_instance(&local_user_view, &local_site)?;
  32
  33   let person_details_id = match data.person_id {
  34     Some(id) => id,
  35     None => {
  36       if let Some(username) = &data.username {
  37         resolve_actor_identifier::<ApubPerson, Person>(username, &context, &local_user_view, true)
  38           .await
  39           .map_err(|e| e.with_message("couldnt_find_that_username_or_email"))?
  40           .id
  41       } else {
  42         return Err(LemmyError::from_message(
  43           "couldnt_find_that_username_or_email",
  44         ));
  45       }
  46     }
  47   };
  48
  49   // You don't need to return settings for the user, since this comes back with GetSite
  50   // `my_user`
  51   let person_view = PersonView::read(context.pool(), person_details_id).await?;
  52
  53   let sort = data.sort;
  54   let page = data.page;
  55   let limit = data.limit;
  56   let saved_only = data.saved_only;
  57   let community_id = data.community_id;
  58   let local_user = local_user_view.map(|l| l.local_user);
  59   let local_user_clone = local_user.clone();
  60
  61   let posts_query = PostQuery::builder()
  62     .pool(context.pool())
  63     .sort(sort)
  64     .saved_only(saved_only)
  65     .local_user(local_user.as_ref())
  66     .community_id(community_id)
  67     .is_mod_or_admin(is_admin)
  68     .page(page)
  69     .limit(limit);
  70
  71   // If its saved only, you don't care what creator it was
  72   // Or, if its not saved, then you only want it for that specific creator
  73   let posts = if !saved_only.unwrap_or(false) {
  74     posts_query
  75       .creator_id(Some(person_details_id))
  76       .build()
  77       .list()
  78   } else {
  79     posts_query.build().list()
  80   }
  81   .await?;
  82
  83   let comments_query = CommentQuery::builder()
  84     .pool(context.pool())
  85     .local_user(local_user_clone.as_ref())
  86     .sort(sort.map(post_to_comment_sort_type))
  87     .saved_only(saved_only)
  88     .show_deleted_and_removed(Some(false))
  89     .community_id(community_id)
  90     .page(page)
  91     .limit(limit);
  92
  93   // If its saved only, you don't care what creator it was
  94   // Or, if its not saved, then you only want it for that specific creator
  95   let comments = if !saved_only.unwrap_or(false) {
  96     comments_query
  97       .creator_id(Some(person_details_id))
  98       .build()
  99       .list()
 100   } else {
 101     comments_query.build().list()
 102   }
 103   .await?;
 104
 105   let moderates = CommunityModeratorView::for_person(context.pool(), person_details_id).await?;
 106
 107   // Return the jwt
 108   Ok(Json(GetPersonDetailsResponse {
 109     person_view,
 110     moderates,
 111     comments,
 112     posts,
 113   }))
 114 }