mirror of
https://github.com/LemmyNet/lemmy
synced 2024-11-26 06:20:20 +00:00
parent
92d17639cd
commit
40609549d8
1 changed files with 8 additions and 0 deletions
|
@ -33,6 +33,8 @@ use serde::Deserialize;
|
|||
use std::{collections::BTreeMap, str::FromStr};
|
||||
use strum::ParseError;
|
||||
|
||||
const RSS_FETCH_LIMIT: i64 = 20;
|
||||
|
||||
#[derive(Deserialize)]
|
||||
struct Params {
|
||||
sort: Option<String>,
|
||||
|
@ -91,6 +93,7 @@ async fn get_feed_data(
|
|||
PostQueryBuilder::create(conn)
|
||||
.listing_type(listing_type)
|
||||
.sort(sort_type)
|
||||
.limit(RSS_FETCH_LIMIT)
|
||||
.list()
|
||||
})
|
||||
.await??;
|
||||
|
@ -184,6 +187,7 @@ fn get_feed_user(
|
|||
.listing_type(ListingType::All)
|
||||
.sort(*sort_type)
|
||||
.creator_id(person.id)
|
||||
.limit(RSS_FETCH_LIMIT)
|
||||
.list()?;
|
||||
|
||||
let items = create_post_items(posts, protocol_and_hostname)?;
|
||||
|
@ -212,6 +216,7 @@ fn get_feed_community(
|
|||
.listing_type(ListingType::Community)
|
||||
.sort(*sort_type)
|
||||
.community_id(community.id)
|
||||
.limit(RSS_FETCH_LIMIT)
|
||||
.list()?;
|
||||
|
||||
let items = create_post_items(posts, protocol_and_hostname)?;
|
||||
|
@ -248,6 +253,7 @@ fn get_feed_front(
|
|||
.show_bot_accounts(local_user.show_bot_accounts)
|
||||
.show_read_posts(local_user.show_read_posts)
|
||||
.sort(*sort_type)
|
||||
.limit(RSS_FETCH_LIMIT)
|
||||
.list()?;
|
||||
|
||||
let items = create_post_items(posts, protocol_and_hostname)?;
|
||||
|
@ -286,12 +292,14 @@ fn get_feed_inbox(
|
|||
.my_person_id(person_id)
|
||||
.show_bot_accounts(show_bot_accounts)
|
||||
.sort(sort)
|
||||
.limit(RSS_FETCH_LIMIT)
|
||||
.list()?;
|
||||
|
||||
let mentions = PersonMentionQueryBuilder::create(conn)
|
||||
.recipient_id(person_id)
|
||||
.my_person_id(person_id)
|
||||
.sort(sort)
|
||||
.limit(RSS_FETCH_LIMIT)
|
||||
.list()?;
|
||||
|
||||
let items = create_reply_and_mention_items(replies, mentions, protocol_and_hostname)?;
|
||||
|
|
Loading…
Reference in a new issue