crates/api_crud/src/post/list.rs

   1 use crate::PerformCrud;
   2 use actix_web::web::Data;
   3 use lemmy_api_common::{
   4   post::{GetPosts, GetPostsResponse},
   5   utils::{
   6     check_private_instance,
   7     get_local_user_view_from_jwt_opt,
   8     listing_type_with_site_default,
   9   },
  10 };
  11 use lemmy_apub::{fetcher::resolve_actor_identifier, objects::community::ApubCommunity};
  12 use lemmy_db_schema::{
  13   source::{community::Community, local_site::LocalSite},
  14   traits::DeleteableOrRemoveable,
  15 };
  16 use lemmy_db_views::post_view::PostQuery;
  17 use lemmy_utils::{error::LemmyError, ConnectionId};
  18 use lemmy_websocket::LemmyContext;
  19
  20 #[async_trait::async_trait(?Send)]
  21 impl PerformCrud for GetPosts {
  22   type Response = GetPostsResponse;
  23
  24   #[tracing::instrument(skip(context, _websocket_id))]
  25   async fn perform(
  26     &self,
  27     context: &Data<LemmyContext>,
  28     _websocket_id: Option<ConnectionId>,
  29   ) -> Result<GetPostsResponse, LemmyError> {
  30     let data: &GetPosts = self;
  31     let local_user_view =
  32       get_local_user_view_from_jwt_opt(data.auth.as_ref(), context.pool(), context.secret())
  33         .await?;
  34     let local_site = LocalSite::read(context.pool()).await?;
  35
  36     check_private_instance(&local_user_view, &local_site)?;
  37
  38     let is_logged_in = local_user_view.is_some();
  39
  40     let sort = data.sort;
  41     let listing_type = listing_type_with_site_default(data.type_, &local_site)?;
  42
  43     let page = data.page;
  44     let limit = data.limit;
  45     let community_id = data.community_id;
  46     let community_actor_id = if let Some(name) = &data.community_name {
  47       resolve_actor_identifier::<ApubCommunity, Community>(name, context, true)
  48         .await
  49         .ok()
  50         .map(|c| c.actor_id)
  51     } else {
  52       None
  53     };
  54     let saved_only = data.saved_only;
  55
  56     let mut posts = PostQuery::builder()
  57       .pool(context.pool())
  58       .local_user(local_user_view.map(|l| l.local_user).as_ref())
  59       .listing_type(Some(listing_type))
  60       .sort(sort)
  61       .community_id(community_id)
  62       .community_actor_id(community_actor_id)
  63       .saved_only(saved_only)
  64       .page(page)
  65       .limit(limit)
  66       .build()
  67       .list()
  68       .await
  69       .map_err(|e| LemmyError::from_error_message(e, "couldnt_get_posts"))?;
  70
  71     // Blank out deleted or removed info for non-logged in users
  72     if !is_logged_in {
  73       for pv in posts
  74         .iter_mut()
  75         .filter(|p| p.post.deleted || p.post.removed)
  76       {
  77         pv.post = pv.clone().post.blank_out_deleted_or_removed_info();
  78       }
  79
  80       for pv in posts
  81         .iter_mut()
  82         .filter(|p| p.community.deleted || p.community.removed)
  83       {
  84         pv.community = pv.clone().community.blank_out_deleted_or_removed_info();
  85       }
  86     }
  87
  88     Ok(GetPostsResponse { posts })
  89   }
  90 }