crates/api_crud/src/site/read.rs

   1 use crate::PerformCrud;
   2 use actix_web::web::Data;
   3 use lemmy_api_common::{
   4   context::LemmyContext,
   5   site::{GetSite, GetSiteResponse, MyUserInfo},
   6   utils::{build_federated_instances, get_local_user_settings_view_from_jwt_opt},
   7 };
   8 use lemmy_db_schema::source::{actor_language::SiteLanguage, language::Language, tagline::Tagline};
   9 use lemmy_db_views::structs::{LocalUserDiscussionLanguageView, SiteView};
  10 use lemmy_db_views_actor::structs::{
  11   CommunityBlockView,
  12   CommunityFollowerView,
  13   CommunityModeratorView,
  14   PersonBlockView,
  15   PersonViewSafe,
  16 };
  17 use lemmy_utils::{error::LemmyError, version, ConnectionId};
  18
  19 #[async_trait::async_trait(?Send)]
  20 impl PerformCrud for GetSite {
  21   type Response = GetSiteResponse;
  22
  23   #[tracing::instrument(skip(context, _websocket_id))]
  24   async fn perform(
  25     &self,
  26     context: &Data<LemmyContext>,
  27     _websocket_id: Option<ConnectionId>,
  28   ) -> Result<GetSiteResponse, LemmyError> {
  29     let data: &GetSite = self;
  30
  31     let site_view = SiteView::read_local(context.pool()).await?;
  32
  33     let admins = PersonViewSafe::admins(context.pool()).await?;
  34
  35     let online = context.chat_server().get_users_online()?;
  36
  37     // Build the local user
  38     let my_user = if let Some(local_user_view) = get_local_user_settings_view_from_jwt_opt(
  39       data.auth.as_ref(),
  40       context.pool(),
  41       context.secret(),
  42     )
  43     .await?
  44     {
  45       let person_id = local_user_view.person.id;
  46       let local_user_id = local_user_view.local_user.id;
  47
  48       let follows = CommunityFollowerView::for_person(context.pool(), person_id)
  49         .await
  50         .map_err(|e| LemmyError::from_error_message(e, "system_err_login"))?;
  51
  52       let person_id = local_user_view.person.id;
  53       let community_blocks = CommunityBlockView::for_person(context.pool(), person_id)
  54         .await
  55         .map_err(|e| LemmyError::from_error_message(e, "system_err_login"))?;
  56
  57       let person_id = local_user_view.person.id;
  58       let person_blocks = PersonBlockView::for_person(context.pool(), person_id)
  59         .await
  60         .map_err(|e| LemmyError::from_error_message(e, "system_err_login"))?;
  61
  62       let moderates = CommunityModeratorView::for_person(context.pool(), person_id)
  63         .await
  64         .map_err(|e| LemmyError::from_error_message(e, "system_err_login"))?;
  65
  66       let discussion_languages =
  67         LocalUserDiscussionLanguageView::read_languages(context.pool(), local_user_id)
  68           .await
  69           .map_err(|e| LemmyError::from_error_message(e, "system_err_login"))?;
  70
  71       Some(MyUserInfo {
  72         local_user_view,
  73         follows,
  74         moderates,
  75         community_blocks,
  76         person_blocks,
  77         discussion_languages,
  78       })
  79     } else {
  80       None
  81     };
  82
  83     let federated_instances =
  84       build_federated_instances(&site_view.local_site, context.pool()).await?;
  85
  86     let all_languages = Language::read_all(context.pool()).await?;
  87     let discussion_languages = SiteLanguage::read_local(context.pool()).await?;
  88     let taglines_res = Tagline::get_all(context.pool(), site_view.local_site.id).await?;
  89     let taglines = (!taglines_res.is_empty()).then_some(taglines_res);
  90
  91     Ok(GetSiteResponse {
  92       site_view,
  93       admins,
  94       online,
  95       version: version::VERSION.to_string(),
  96       my_user,
  97       federated_instances,
  98       all_languages,
  99       discussion_languages,
 100       taglines,
 101     })
 102   }
 103 }