crates/api_crud/src/post/read.rs

   1 use crate::PerformCrud;
   2 use actix_web::web::Data;
   3 use lemmy_api_common::{
   4   blocking,
   5   get_local_user_view_from_jwt_opt,
   6   post::*,
   7   user_show_bot_accounts,
   8   user_show_nsfw,
   9 };
  10 use lemmy_db_queries::{from_opt_str_to_opt_enum, ListingType, SortType};
  11 use lemmy_db_views::{
  12   comment_view::CommentQueryBuilder,
  13   post_view::{PostQueryBuilder, PostView},
  14 };
  15 use lemmy_db_views_actor::{
  16   community_moderator_view::CommunityModeratorView,
  17   community_view::CommunityView,
  18 };
  19 use lemmy_utils::{ApiError, ConnectionId, LemmyError};
  20 use lemmy_websocket::{messages::GetPostUsersOnline, LemmyContext};
  21
  22 #[async_trait::async_trait(?Send)]
  23 impl PerformCrud for GetPost {
  24   type Response = GetPostResponse;
  25
  26   async fn perform(
  27     &self,
  28     context: &Data<LemmyContext>,
  29     _websocket_id: Option<ConnectionId>,
  30   ) -> Result<GetPostResponse, LemmyError> {
  31     let data: &GetPost = &self;
  32     let local_user_view = get_local_user_view_from_jwt_opt(&data.auth, context.pool()).await?;
  33
  34     let show_bot_accounts = user_show_bot_accounts(&local_user_view);
  35
  36     let person_id = local_user_view.map(|u| u.person.id);
  37
  38     let id = data.id;
  39     let post_view = blocking(context.pool(), move |conn| {
  40       PostView::read(conn, id, person_id)
  41     })
  42     .await?
  43     .map_err(|_| ApiError::err("couldnt_find_post"))?;
  44
  45     let id = data.id;
  46     let comments = blocking(context.pool(), move |conn| {
  47       CommentQueryBuilder::create(conn)
  48         .my_person_id(person_id)
  49         .show_bot_accounts(show_bot_accounts)
  50         .post_id(id)
  51         .limit(9999)
  52         .list()
  53     })
  54     .await??;
  55
  56     let community_id = post_view.community.id;
  57     let moderators = blocking(context.pool(), move |conn| {
  58       CommunityModeratorView::for_community(conn, community_id)
  59     })
  60     .await??;
  61
  62     // Necessary for the sidebar
  63     let community_view = blocking(context.pool(), move |conn| {
  64       CommunityView::read(conn, community_id, person_id)
  65     })
  66     .await?
  67     .map_err(|_| ApiError::err("couldnt_find_community"))?;
  68
  69     let online = context
  70       .chat_server()
  71       .send(GetPostUsersOnline { post_id: data.id })
  72       .await
  73       .unwrap_or(1);
  74
  75     // Return the jwt
  76     Ok(GetPostResponse {
  77       post_view,
  78       community_view,
  79       comments,
  80       moderators,
  81       online,
  82     })
  83   }
  84 }
  85
  86 #[async_trait::async_trait(?Send)]
  87 impl PerformCrud for GetPosts {
  88   type Response = GetPostsResponse;
  89
  90   async fn perform(
  91     &self,
  92     context: &Data<LemmyContext>,
  93     _websocket_id: Option<ConnectionId>,
  94   ) -> Result<GetPostsResponse, LemmyError> {
  95     let data: &GetPosts = &self;
  96     let local_user_view = get_local_user_view_from_jwt_opt(&data.auth, context.pool()).await?;
  97
  98     let person_id = local_user_view.to_owned().map(|l| l.person.id);
  99
 100     let show_nsfw = user_show_nsfw(&local_user_view);
 101     let show_bot_accounts = user_show_bot_accounts(&local_user_view);
 102
 103     let sort: Option<SortType> = from_opt_str_to_opt_enum(&data.sort);
 104     let listing_type: Option<ListingType> = from_opt_str_to_opt_enum(&data.type_);
 105
 106     let page = data.page;
 107     let limit = data.limit;
 108     let community_id = data.community_id;
 109     let community_name = data.community_name.to_owned();
 110     let saved_only = data.saved_only;
 111
 112     let posts = blocking(context.pool(), move |conn| {
 113       PostQueryBuilder::create(conn)
 114         .listing_type(listing_type)
 115         .sort(sort)
 116         .show_nsfw(show_nsfw)
 117         .show_bot_accounts(show_bot_accounts)
 118         .community_id(community_id)
 119         .community_name(community_name)
 120         .saved_only(saved_only)
 121         .my_person_id(person_id)
 122         .page(page)
 123         .limit(limit)
 124         .list()
 125     })
 126     .await?
 127     .map_err(|_| ApiError::err("couldnt_get_posts"))?;
 128
 129     Ok(GetPostsResponse { posts })
 130   }
 131 }