crates/api_crud/src/site/read.rs

   1 use crate::PerformCrud;
   2 use actix_web::web::Data;
   3 use lemmy_api_common::{
   4   site::{GetSite, GetSiteResponse, MyUserInfo},
   5   utils::{build_federated_instances, get_local_user_settings_view_from_jwt_opt},
   6 };
   7 use lemmy_db_schema::source::{actor_language::SiteLanguage, language::Language};
   8 use lemmy_db_views::structs::{LocalUserDiscussionLanguageView, SiteView};
   9 use lemmy_db_views_actor::structs::{
  10   CommunityBlockView,
  11   CommunityFollowerView,
  12   CommunityModeratorView,
  13   PersonBlockView,
  14   PersonViewSafe,
  15 };
  16 use lemmy_utils::{error::LemmyError, version, ConnectionId};
  17 use lemmy_websocket::{messages::GetUsersOnline, LemmyContext};
  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
  36       .chat_server()
  37       .send(GetUsersOnline)
  38       .await
  39       .unwrap_or(1);
  40
  41     // Build the local user
  42     let my_user = if let Some(local_user_view) = get_local_user_settings_view_from_jwt_opt(
  43       data.auth.as_ref(),
  44       context.pool(),
  45       context.secret(),
  46     )
  47     .await?
  48     {
  49       let person_id = local_user_view.person.id;
  50       let local_user_id = local_user_view.local_user.id;
  51
  52       let follows = CommunityFollowerView::for_person(context.pool(), person_id)
  53         .await
  54         .map_err(|e| LemmyError::from_error_message(e, "system_err_login"))?;
  55
  56       let person_id = local_user_view.person.id;
  57       let community_blocks = CommunityBlockView::for_person(context.pool(), person_id)
  58         .await
  59         .map_err(|e| LemmyError::from_error_message(e, "system_err_login"))?;
  60
  61       let person_id = local_user_view.person.id;
  62       let person_blocks = PersonBlockView::for_person(context.pool(), person_id)
  63         .await
  64         .map_err(|e| LemmyError::from_error_message(e, "system_err_login"))?;
  65
  66       let moderates = CommunityModeratorView::for_person(context.pool(), person_id)
  67         .await
  68         .map_err(|e| LemmyError::from_error_message(e, "system_err_login"))?;
  69
  70       let discussion_languages =
  71         LocalUserDiscussionLanguageView::read_languages(context.pool(), local_user_id)
  72           .await
  73           .map_err(|e| LemmyError::from_error_message(e, "system_err_login"))?;
  74
  75       Some(MyUserInfo {
  76         local_user_view,
  77         follows,
  78         moderates,
  79         community_blocks,
  80         person_blocks,
  81         discussion_languages,
  82       })
  83     } else {
  84       None
  85     };
  86
  87     let federated_instances =
  88       build_federated_instances(&site_view.local_site, context.pool()).await?;
  89
  90     let all_languages = Language::read_all(context.pool()).await?;
  91     let discussion_languages = SiteLanguage::read_local(context.pool()).await?;
  92
  93     Ok(GetSiteResponse {
  94       site_view,
  95       admins,
  96       online,
  97       version: version::VERSION.to_string(),
  98       my_user,
  99       federated_instances,
 100       all_languages,
 101       discussion_languages,
 102     })
 103   }
 104 }