mirrors/lemmy
1
0
Fork 0
mirror of https://github.com/LemmyNet/lemmy.git synced 2025-02-03 04:32:39 +00:00
Code Issues Projects Releases Wiki Activity

comment view, post view

Browse source
This commit is contained in:
Dull Bananas 2024-12-23 16:01:28 -07:00
parent 7585aac446
commit 6b40083504
2 changed files with 57 additions and 71 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

53
crates/db_views/src/comment_view.rs
View file

@ -141,28 +141,25 @@ fn queries<'a>() -> Queries<
query.first(&mut conn).await query.first(&mut conn).await
}; };
let list = move |mut conn: DbConn<'a>, (options, site): (CommentQuery<'a>, &'a Site)| async move { let list = move |mut conn: DbConn<'a>, (o, site): (CommentQuery<'a>, &'a Site)| async move {
// The left join below will return None in this case // The left join below will return None in this case
let local_user_id_join = options let local_user_id_join = o.local_user.local_user_id().unwrap_or(LocalUserId(-1));
.local_user
.local_user_id()
.unwrap_or(LocalUserId(-1));
let mut query = all_joins(comment::table.into_boxed(), options.local_user.person_id()); let mut query = all_joins(comment::table.into_boxed(), o.local_user.person_id());
if let Some(creator_id) = options.creator_id { if let Some(creator_id) = o.creator_id {
query = query.filter(comment::creator_id.eq(creator_id)); query = query.filter(comment::creator_id.eq(creator_id));
}; };
if let Some(post_id) = options.post_id { if let Some(post_id) = o.post_id {
query = query.filter(comment::post_id.eq(post_id)); query = query.filter(comment::post_id.eq(post_id));
}; };
if let Some(parent_path) = options.parent_path.as_ref() { if let Some(parent_path) = o.parent_path.as_ref() {
query = query.filter(comment::path.contained_by(parent_path)); query = query.filter(comment::path.contained_by(parent_path));
}; };
//filtering out removed and deleted comments from search //filtering out removed and deleted comments from search
if let Some(search_term) = options.search_term { if let Some(search_term) = o.search_term {
query = query.filter( query = query.filter(
comment::content comment::content
.ilike(fuzzy_search(&search_term)) .ilike(fuzzy_search(&search_term))
@ -170,13 +167,13 @@ fn queries<'a>() -> Queries<
); );
}; };
if let Some(community_id) = options.community_id { if let Some(community_id) = o.community_id {
query = query.filter(post::community_id.eq(community_id)); query = query.filter(post::community_id.eq(community_id));
} }
let is_subscribed = community_actions::followed.is_not_null(); let is_subscribed = community_actions::followed.is_not_null();
match options.listing_type.unwrap_or_default() { match o.listing_type.unwrap_or_default() {
ListingType::Subscribed => query = query.filter(is_subscribed), /* TODO could be this: and(community_follower::person_id.eq(person_id_join)), */ ListingType::Subscribed => query = query.filter(is_subscribed), /* TODO could be this: and(community_follower::person_id.eq(person_id_join)), */
ListingType::Local => { ListingType::Local => {
query = query query = query
@ -190,32 +187,30 @@ fn queries<'a>() -> Queries<
} }
// If its saved only, then filter, and order by the saved time, not the comment creation time. // If its saved only, then filter, and order by the saved time, not the comment creation time.
if options.saved_only.unwrap_or_default() { if o.saved_only.unwrap_or_default() {
query = query query = query
.filter(comment_actions::saved.is_not_null()) .filter(comment_actions::saved.is_not_null())
.then_order_by(comment_actions::saved.desc()); .then_order_by(comment_actions::saved.desc());
} }
if let Some(my_id) = options.local_user.person_id() { if let Some(my_id) = o.local_user.person_id() {
let not_creator_filter = comment::creator_id.ne(my_id); let not_creator_filter = comment::creator_id.ne(my_id);
if options.liked_only.unwrap_or_default() { if o.liked_only.unwrap_or_default() {
query = query query = query
.filter(not_creator_filter) .filter(not_creator_filter)
.filter(comment_actions::like_score.eq(1)); .filter(comment_actions::like_score.eq(1));
} else if options.disliked_only.unwrap_or_default() { } else if o.disliked_only.unwrap_or_default() {
query = query query = query
.filter(not_creator_filter) .filter(not_creator_filter)
.filter(comment_actions::like_score.eq(-1)); .filter(comment_actions::like_score.eq(-1));
} }
} }
if !options.local_user.show_bot_accounts() { if !o.local_user.show_bot_accounts() {
query = query.filter(person::bot_account.eq(false)); query = query.filter(person::bot_account.eq(false));
}; };
if options.local_user.is_some() if o.local_user.is_some() && o.listing_type.unwrap_or_default() != ListingType::ModeratorView {
&& options.listing_type.unwrap_or_default() != ListingType::ModeratorView
{
// Filter out the rows with missing languages // Filter out the rows with missing languages
query = query.filter(exists( query = query.filter(exists(
local_user_language::table.filter( local_user_language::table.filter(
@ -232,15 +227,15 @@ fn queries<'a>() -> Queries<
.filter(person_actions::blocked.is_null()); .filter(person_actions::blocked.is_null());
}; };
if !options.local_user.show_nsfw(site) { if !o.local_user.show_nsfw(site) {
query = query query = query
.filter(post::nsfw.eq(false)) .filter(post::nsfw.eq(false))
.filter(community::nsfw.eq(false)); .filter(community::nsfw.eq(false));
}; };
query = options.local_user.visible_communities_only(query); query = o.local_user.visible_communities_only(query);
if !options.local_user.is_admin() { if !o.local_user.is_admin() {
query = query.filter( query = query.filter(
community::visibility community::visibility
.ne(CommunityVisibility::Private) .ne(CommunityVisibility::Private)
@ -249,8 +244,8 @@ fn queries<'a>() -> Queries<
} }
// A Max depth given means its a tree fetch // A Max depth given means its a tree fetch
let (limit, offset) = if let Some(max_depth) = options.max_depth { let (limit, offset) = if let Some(max_depth) = o.max_depth {
let depth_limit = if let Some(parent_path) = options.parent_path.as_ref() { let depth_limit = if let Some(parent_path) = o.parent_path.as_ref() {
parent_path.0.split('.').count() as i32 + max_depth parent_path.0.split('.').count() as i32 + max_depth
// Add one because of root "0" // Add one because of root "0"
} else { } else {
@ -261,7 +256,7 @@ fn queries<'a>() -> Queries<
// only order if filtering by a post id, or parent_path. DOS potential otherwise and max_depth // only order if filtering by a post id, or parent_path. DOS potential otherwise and max_depth
// + !post_id isn't used anyways (afaik) // + !post_id isn't used anyways (afaik)
if options.post_id.is_some() || options.parent_path.is_some() { if o.post_id.is_some() || o.parent_path.is_some() {
// Always order by the parent path first // Always order by the parent path first
query = query.then_order_by(subpath(comment::path, 0, -1)); query = query.then_order_by(subpath(comment::path, 0, -1));
} }
@ -279,15 +274,15 @@ fn queries<'a>() -> Queries<
(300, 0) (300, 0)
} else { } else {
// limit_and_offset_unlimited(options.page, options.limit) // limit_and_offset_unlimited(options.page, options.limit)
limit_and_offset(options.page, options.limit)? limit_and_offset(o.page, o.limit)?
}; };
// distinguished comments should go first when viewing post // distinguished comments should go first when viewing post
if options.post_id.is_some() || options.parent_path.is_some() { if o.post_id.is_some() || o.parent_path.is_some() {
query = query.then_order_by(comment::distinguished.desc()); query = query.then_order_by(comment::distinguished.desc());
} }
query = match options.sort.unwrap_or(CommentSortType::Hot) { query = match o.sort.unwrap_or(CommentSortType::Hot) {
CommentSortType::Hot => query CommentSortType::Hot => query
.then_order_by(comment_aggregates::hot_rank.desc()) .then_order_by(comment_aggregates::hot_rank.desc())
.then_order_by(comment_aggregates::score.desc()), .then_order_by(comment_aggregates::score.desc()),

75
crates/db_views/src/post_view.rs
View file

@ -226,23 +226,20 @@ fn queries<'a>() -> Queries<
.await .await
}; };
let list = move |mut conn: DbConn<'a>, (options, site): (PostQuery<'a>, &'a Site)| async move { let list = move |mut conn: DbConn<'a>, (o, site): (PostQuery<'a>, &'a Site)| async move {
// The left join below will return None in this case // The left join below will return None in this case
let local_user_id_join = options let local_user_id_join = o.local_user.local_user_id().unwrap_or(LocalUserId(-1));
.local_user
.local_user_id()
.unwrap_or(LocalUserId(-1));
let mut query = all_joins( let mut query = all_joins(
post_aggregates::table.into_boxed(), post_aggregates::table.into_boxed(),
options.local_user.person_id(), o.local_user.person_id(),
); );
// hide posts from deleted communities // hide posts from deleted communities
query = query.filter(community::deleted.eq(false)); query = query.filter(community::deleted.eq(false));
// only creator can see deleted posts and unpublished scheduled posts // only creator can see deleted posts and unpublished scheduled posts
if let Some(person_id) = options.local_user.person_id() { if let Some(person_id) = o.local_user.person_id() {
query = query.filter(post::deleted.eq(false).or(post::creator_id.eq(person_id))); query = query.filter(post::deleted.eq(false).or(post::creator_id.eq(person_id)));
query = query.filter( query = query.filter(
post::scheduled_publish_time post::scheduled_publish_time
@ -256,21 +253,21 @@ fn queries<'a>() -> Queries<
} }
// only show removed posts to admin when viewing user profile // only show removed posts to admin when viewing user profile
if !(options.creator_id.is_some() && options.local_user.is_admin()) { if !(o.creator_id.is_some() && o.local_user.is_admin()) {
query = query query = query
.filter(community::removed.eq(false)) .filter(community::removed.eq(false))
.filter(post::removed.eq(false)); .filter(post::removed.eq(false));
} }
if let Some(community_id) = options.community_id { if let Some(community_id) = o.community_id {
query = query.filter(post_aggregates::community_id.eq(community_id)); query = query.filter(post_aggregates::community_id.eq(community_id));
} }
if let Some(creator_id) = options.creator_id { if let Some(creator_id) = o.creator_id {
query = query.filter(post_aggregates::creator_id.eq(creator_id)); query = query.filter(post_aggregates::creator_id.eq(creator_id));
} }
let is_subscribed = community_actions::followed.is_not_null(); let is_subscribed = community_actions::followed.is_not_null();
match options.listing_type.unwrap_or_default() { match o.listing_type.unwrap_or_default() {
ListingType::Subscribed => query = query.filter(is_subscribed), ListingType::Subscribed => query = query.filter(is_subscribed),
ListingType::Local => { ListingType::Local => {
query = query query = query
@ -283,14 +280,14 @@ fn queries<'a>() -> Queries<
} }
} }
if let Some(search_term) = &options.search_term { if let Some(search_term) = &o.search_term {
if options.url_only.unwrap_or_default() { if o.url_only.unwrap_or_default() {
query = query.filter(post::url.eq(search_term)); query = query.filter(post::url.eq(search_term));
} else { } else {
let searcher = fuzzy_search(search_term); let searcher = fuzzy_search(search_term);
let name_filter = post::name.ilike(searcher.clone()); let name_filter = post::name.ilike(searcher.clone());
let body_filter = post::body.ilike(searcher.clone()); let body_filter = post::body.ilike(searcher.clone());
query = if options.title_only.unwrap_or_default() { query = if o.title_only.unwrap_or_default() {
query.filter(name_filter) query.filter(name_filter)
} else { } else {
query.filter(name_filter.or(body_filter)) query.filter(name_filter.or(body_filter))
@ -299,64 +296,58 @@ fn queries<'a>() -> Queries<
} }
} }
if !options if !o.show_nsfw.unwrap_or(o.local_user.show_nsfw(site)) {
.show_nsfw
.unwrap_or(options.local_user.show_nsfw(site))
{
query = query query = query
.filter(post::nsfw.eq(false)) .filter(post::nsfw.eq(false))
.filter(community::nsfw.eq(false)); .filter(community::nsfw.eq(false));
}; };
if !options.local_user.show_bot_accounts() { if !o.local_user.show_bot_accounts() {
query = query.filter(person::bot_account.eq(false)); query = query.filter(person::bot_account.eq(false));
}; };
// Filter to show only posts with no comments // Filter to show only posts with no comments
if options.no_comments_only.unwrap_or_default() { if o.no_comments_only.unwrap_or_default() {
query = query.filter(post_aggregates::comments.eq(0)); query = query.filter(post_aggregates::comments.eq(0));
}; };
// If its saved only, then filter, and order by the saved time, not the comment creation time. // If its saved only, then filter, and order by the saved time, not the comment creation time.
if options.saved_only.unwrap_or_default() { if o.saved_only.unwrap_or_default() {
query = query query = query
.filter(post_actions::saved.is_not_null()) .filter(post_actions::saved.is_not_null())
.then_order_by(post_actions::saved.desc()); .then_order_by(post_actions::saved.desc());
} }
// Only hide the read posts, if the saved_only is false. Otherwise ppl with the hide_read // Only hide the read posts, if the saved_only is false. Otherwise ppl with the hide_read
// setting wont be able to see saved posts. // setting wont be able to see saved posts.
else if !options else if !o.show_read.unwrap_or(o.local_user.show_read_posts()) {
.show_read
.unwrap_or(options.local_user.show_read_posts())
{
// Do not hide read posts when it is a user profile view // Do not hide read posts when it is a user profile view
// Or, only hide read posts on non-profile views // Or, only hide read posts on non-profile views
if options.creator_id.is_none() { if o.creator_id.is_none() {
query = query.filter(post_actions::read.is_null()); query = query.filter(post_actions::read.is_null());
} }
} }
// If a creator id isn't given (IE its on home or community pages), hide the hidden posts // If a creator id isn't given (IE its on home or community pages), hide the hidden posts
if !options.show_hidden.unwrap_or_default() && options.creator_id.is_none() { if !o.show_hidden.unwrap_or_default() && o.creator_id.is_none() {
query = query.filter(post_actions::hidden.is_null()); query = query.filter(post_actions::hidden.is_null());
} }
if let Some(my_id) = options.local_user.person_id() { if let Some(my_id) = o.local_user.person_id() {
let not_creator_filter = post_aggregates::creator_id.ne(my_id); let not_creator_filter = post_aggregates::creator_id.ne(my_id);
if options.liked_only.unwrap_or_default() { if o.liked_only.unwrap_or_default() {
query = query query = query
.filter(not_creator_filter) .filter(not_creator_filter)
.filter(post_actions::like_score.eq(1)); .filter(post_actions::like_score.eq(1));
} else if options.disliked_only.unwrap_or_default() { } else if o.disliked_only.unwrap_or_default() {
query = query query = query
.filter(not_creator_filter) .filter(not_creator_filter)
.filter(post_actions::like_score.eq(-1)); .filter(post_actions::like_score.eq(-1));
} }
}; };
query = options.local_user.visible_communities_only(query); query = o.local_user.visible_communities_only(query);
if !options.local_user.is_admin() { if !o.local_user.is_admin() {
query = query.filter( query = query.filter(
community::visibility community::visibility
.ne(CommunityVisibility::Private) .ne(CommunityVisibility::Private)
@ -365,9 +356,9 @@ fn queries<'a>() -> Queries<
} }
// Dont filter blocks or missing languages for moderator view type // Dont filter blocks or missing languages for moderator view type
if options.listing_type.unwrap_or_default() != ListingType::ModeratorView { if o.listing_type.unwrap_or_default() != ListingType::ModeratorView {
// Filter out the rows with missing languages if user is logged in // Filter out the rows with missing languages if user is logged in
if options.local_user.is_some() { if o.local_user.is_some() {
query = query.filter(exists( query = query.filter(exists(
local_user_language::table.filter( local_user_language::table.filter(
post::language_id post::language_id
@ -383,15 +374,15 @@ fn queries<'a>() -> Queries<
query = query.filter(person_actions::blocked.is_null()); query = query.filter(person_actions::blocked.is_null());
} }
let (limit, offset) = limit_and_offset(options.page, options.limit)?; let (limit, offset) = limit_and_offset(o.page, o.limit)?;
query = query.limit(limit).offset(offset); query = query.limit(limit).offset(offset);
let mut query = PaginatedQueryBuilder::new(query); let mut query = PaginatedQueryBuilder::new(query);
let page_after = options.page_after.map(|c| c.0); let page_after = o.page_after.map(|c| c.0);
let page_before_or_equal = options.page_before_or_equal.map(|c| c.0); let page_before_or_equal = o.page_before_or_equal.map(|c| c.0);
if options.page_back.unwrap_or_default() { if o.page_back.unwrap_or_default() {
query = query query = query
.before(page_after) .before(page_after)
.after_or_equal(page_before_or_equal) .after_or_equal(page_before_or_equal)
@ -403,7 +394,7 @@ fn queries<'a>() -> Queries<
} }
// featured posts first // featured posts first
query = if options.community_id.is_none() || options.community_id_just_for_prefetch { query = if o.community_id.is_none() || o.community_id_just_for_prefetch {
query.then_desc(key::featured_local) query.then_desc(key::featured_local)
} else { } else {
query.then_desc(key::featured_community) query.then_desc(key::featured_community)
@ -412,7 +403,7 @@ fn queries<'a>() -> Queries<
let time = |interval| post_aggregates::published.gt(now() - interval); let time = |interval| post_aggregates::published.gt(now() - interval);
// then use the main sort // then use the main sort
query = match options.sort.unwrap_or(Hot) { query = match o.sort.unwrap_or(Hot) {
Active => query.then_desc(key::hot_rank_active), Active => query.then_desc(key::hot_rank_active),
Hot => query.then_desc(key::hot_rank), Hot => query.then_desc(key::hot_rank),
Scaled => query.then_desc(key::scaled_rank), Scaled => query.then_desc(key::scaled_rank),
@ -436,7 +427,7 @@ fn queries<'a>() -> Queries<
// use publish as fallback. especially useful for hot rank which reaches zero after some days. // use publish as fallback. especially useful for hot rank which reaches zero after some days.
// necessary because old posts can be fetched over federation and inserted with high post id // necessary because old posts can be fetched over federation and inserted with high post id
query = match options.sort.unwrap_or(Hot) { query = match o.sort.unwrap_or(Hot) {
// A second time-based sort would not be very useful // A second time-based sort would not be very useful
New | Old | NewComments => query, New | Old | NewComments => query,
_ => query.then_desc(key::published), _ => query.then_desc(key::published),
@ -454,7 +445,7 @@ fn queries<'a>() -> Queries<
.text("PostQuery::list") .text("PostQuery::list")
.text_if( .text_if(
"getting upper bound for next query", "getting upper bound for next query",
options.community_id_just_for_prefetch, o.community_id_just_for_prefetch,
) )
.load::<PostView>(&mut conn) .load::<PostView>(&mut conn)
.await .await