crates/apub/src/api/read_community.rs

   1 use crate::{
   2   api::PerformApub,
   3   fetcher::resolve_actor_identifier,
   4   objects::community::ApubCommunity,
   5 };
   6 use actix_web::web::Data;
   7 use lemmy_api_common::{
   8   community::{GetCommunity, GetCommunityResponse},
   9   context::LemmyContext,
  10   utils::{check_private_instance, get_local_user_view_from_jwt_opt},
  11   websocket::messages::GetCommunityUsersOnline,
  12 };
  13 use lemmy_db_schema::{
  14   impls::actor_language::default_post_language,
  15   source::{
  16     actor_language::CommunityLanguage,
  17     community::Community,
  18     local_site::LocalSite,
  19     site::Site,
  20   },
  21   traits::DeleteableOrRemoveable,
  22 };
  23 use lemmy_db_views_actor::structs::{CommunityModeratorView, CommunityView};
  24 use lemmy_utils::{error::LemmyError, ConnectionId};
  25
  26 #[async_trait::async_trait(?Send)]
  27 impl PerformApub for GetCommunity {
  28   type Response = GetCommunityResponse;
  29
  30   #[tracing::instrument(skip(context, _websocket_id))]
  31   async fn perform(
  32     &self,
  33     context: &Data<LemmyContext>,
  34     _websocket_id: Option<ConnectionId>,
  35   ) -> Result<GetCommunityResponse, LemmyError> {
  36     let data: &GetCommunity = self;
  37     let local_user_view =
  38       get_local_user_view_from_jwt_opt(data.auth.as_ref(), context.pool(), context.secret())
  39         .await?;
  40     let local_site = LocalSite::read(context.pool()).await?;
  41
  42     if data.name.is_none() && data.id.is_none() {
  43       return Err(LemmyError::from_message("no_id_given"));
  44     }
  45
  46     check_private_instance(&local_user_view, &local_site)?;
  47
  48     let person_id = local_user_view.as_ref().map(|u| u.person.id);
  49
  50     let community_id = match data.id {
  51       Some(id) => id,
  52       None => {
  53         let name = data.name.clone().unwrap_or_else(|| "main".to_string());
  54         resolve_actor_identifier::<ApubCommunity, Community>(&name, context, true)
  55           .await
  56           .map_err(|e| e.with_message("couldnt_find_community"))?
  57           .id
  58       }
  59     };
  60
  61     let mut community_view = CommunityView::read(context.pool(), community_id, person_id)
  62       .await
  63       .map_err(|e| LemmyError::from_error_message(e, "couldnt_find_community"))?;
  64
  65     // Blank out deleted or removed info for non-logged in users
  66     if person_id.is_none() && (community_view.community.deleted || community_view.community.removed)
  67     {
  68       community_view.community = community_view.community.blank_out_deleted_or_removed_info();
  69     }
  70
  71     let moderators = CommunityModeratorView::for_community(context.pool(), community_id)
  72       .await
  73       .map_err(|e| LemmyError::from_error_message(e, "couldnt_find_community"))?;
  74
  75     let online = context
  76       .chat_server()
  77       .send(GetCommunityUsersOnline { community_id })
  78       .await
  79       .unwrap_or(1);
  80
  81     let site_id =
  82       Site::instance_actor_id_from_url(community_view.community.actor_id.clone().into());
  83     let mut site = Site::read_from_apub_id(context.pool(), site_id).await?;
  84     // no need to include metadata for local site (its already available through other endpoints).
  85     // this also prevents us from leaking the federation private key.
  86     if let Some(s) = &site {
  87       if s.actor_id.domain() == Some(context.settings().hostname.as_ref()) {
  88         site = None;
  89       }
  90     }
  91
  92     let community_id = community_view.community.id;
  93     let discussion_languages = CommunityLanguage::read(context.pool(), community_id).await?;
  94     let default_post_language = if let Some(user) = local_user_view {
  95       default_post_language(context.pool(), community_id, user.local_user.id).await?
  96     } else {
  97       None
  98     };
  99
 100     let res = GetCommunityResponse {
 101       community_view,
 102       site,
 103       moderators,
 104       online,
 105       discussion_languages,
 106       default_post_language,
 107     };
 108
 109     // Return the jwt
 110     Ok(res)
 111   }
 112 }