LemmyNet/lemmy
2
0
Fork 0
mirror of https://github.com/LemmyNet/lemmy.git synced 2025-01-27 12:26:06 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

add local filter to community follower view

Browse source
This commit is contained in:
phiresky 2023-08-03 13:50:00 +00:00
parent de50f37a39
commit 5c686f75c4
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
crates/db_views_actor/src/community_follower_view.rs
View file

@ -18,7 +18,7 @@ use lemmy_db_schema::{
type CommunityFollowerViewTuple = (Community, Person); type CommunityFollowerViewTuple = (Community, Person);
impl CommunityFollowerView { impl CommunityFollowerView {
/// return a list of community ids and inboxes that at least one user of the given instance has followed /// return a list of local community ids and remote inboxes that at least one user of the given instance has followed
pub async fn get_instance_followed_community_inboxes( pub async fn get_instance_followed_community_inboxes(
pool: &mut DbPool<'_>, pool: &mut DbPool<'_>,
instance_id: InstanceId, instance_id: InstanceId,
@ -30,6 +30,7 @@ impl CommunityFollowerView {
.inner_join(community::table) .inner_join(community::table)
.inner_join(person::table) .inner_join(person::table)
.filter(person::instance_id.eq(instance_id)) .filter(person::instance_id.eq(instance_id))
.filter(community::local) // this should be a no-op since community_followers table only has local-person+remote-community or remote-person+local-community
.filter(not(person::local)) .filter(not(person::local))
.filter(community_follower::published.gt(published_since.naive_utc())) .filter(community_follower::published.gt(published_since.naive_utc()))
.select(( .select((