mirror of
https://github.com/LemmyNet/lemmy.git
synced 2024-11-29 21:01:03 +00:00
* Fixing duped report view for admins. Fixes #1933 * Fixing tests.
This commit is contained in:
parent
d2e28e5f38
commit
46c7429429
4 changed files with 74 additions and 48 deletions
|
@ -147,24 +147,30 @@ impl CommentReportView {
|
||||||
let mut query = comment_report::table
|
let mut query = comment_report::table
|
||||||
.inner_join(comment::table)
|
.inner_join(comment::table)
|
||||||
.inner_join(post::table.on(comment::post_id.eq(post::id)))
|
.inner_join(post::table.on(comment::post_id.eq(post::id)))
|
||||||
.inner_join(
|
|
||||||
community_moderator::table.on(community_moderator::community_id.eq(post::community_id)),
|
|
||||||
)
|
|
||||||
.filter(comment_report::resolved.eq(false))
|
.filter(comment_report::resolved.eq(false))
|
||||||
.into_boxed();
|
.into_boxed();
|
||||||
|
|
||||||
// If its not an admin, get only the ones you mod
|
|
||||||
if !admin {
|
|
||||||
query = query.filter(community_moderator::person_id.eq(my_person_id));
|
|
||||||
}
|
|
||||||
|
|
||||||
if let Some(community_id) = community_id {
|
if let Some(community_id) = community_id {
|
||||||
query = query.filter(post::community_id.eq(community_id))
|
query = query.filter(post::community_id.eq(community_id))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// If its not an admin, get only the ones you mod
|
||||||
|
if !admin {
|
||||||
|
query
|
||||||
|
.inner_join(
|
||||||
|
community_moderator::table.on(
|
||||||
|
community_moderator::community_id
|
||||||
|
.eq(post::community_id)
|
||||||
|
.and(community_moderator::person_id.eq(my_person_id)),
|
||||||
|
),
|
||||||
|
)
|
||||||
|
.select(count(comment_report::id))
|
||||||
|
.first::<i64>(conn)
|
||||||
|
} else {
|
||||||
query.select(count(comment_report::id)).first::<i64>(conn)
|
query.select(count(comment_report::id)).first::<i64>(conn)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
pub struct CommentReportQueryBuilder<'a> {
|
pub struct CommentReportQueryBuilder<'a> {
|
||||||
conn: &'a PgConnection,
|
conn: &'a PgConnection,
|
||||||
|
@ -216,10 +222,6 @@ impl<'a> CommentReportQueryBuilder<'a> {
|
||||||
.inner_join(community::table.on(post::community_id.eq(community::id)))
|
.inner_join(community::table.on(post::community_id.eq(community::id)))
|
||||||
.inner_join(person::table.on(comment_report::creator_id.eq(person::id)))
|
.inner_join(person::table.on(comment_report::creator_id.eq(person::id)))
|
||||||
.inner_join(person_alias_1::table.on(comment::creator_id.eq(person_alias_1::id)))
|
.inner_join(person_alias_1::table.on(comment::creator_id.eq(person_alias_1::id)))
|
||||||
// Test this join
|
|
||||||
.inner_join(
|
|
||||||
community_moderator::table.on(community_moderator::community_id.eq(post::community_id)),
|
|
||||||
)
|
|
||||||
.inner_join(
|
.inner_join(
|
||||||
comment_aggregates::table.on(comment_report::comment_id.eq(comment_aggregates::comment_id)),
|
comment_aggregates::table.on(comment_report::comment_id.eq(comment_aggregates::comment_id)),
|
||||||
)
|
)
|
||||||
|
@ -254,11 +256,6 @@ impl<'a> CommentReportQueryBuilder<'a> {
|
||||||
))
|
))
|
||||||
.into_boxed();
|
.into_boxed();
|
||||||
|
|
||||||
// If its not an admin, get only the ones you mod
|
|
||||||
if !self.admin {
|
|
||||||
query = query.filter(community_moderator::person_id.eq(self.my_person_id));
|
|
||||||
}
|
|
||||||
|
|
||||||
if let Some(community_id) = self.community_id {
|
if let Some(community_id) = self.community_id {
|
||||||
query = query.filter(post::community_id.eq(community_id));
|
query = query.filter(post::community_id.eq(community_id));
|
||||||
}
|
}
|
||||||
|
@ -269,11 +266,25 @@ impl<'a> CommentReportQueryBuilder<'a> {
|
||||||
|
|
||||||
let (limit, offset) = limit_and_offset(self.page, self.limit);
|
let (limit, offset) = limit_and_offset(self.page, self.limit);
|
||||||
|
|
||||||
let res = query
|
query = query
|
||||||
.order_by(comment_report::published.asc())
|
.order_by(comment_report::published.desc())
|
||||||
.limit(limit)
|
.limit(limit)
|
||||||
.offset(offset)
|
.offset(offset);
|
||||||
.load::<CommentReportViewTuple>(self.conn)?;
|
|
||||||
|
// If its not an admin, get only the ones you mod
|
||||||
|
let res = if !self.admin {
|
||||||
|
query
|
||||||
|
.inner_join(
|
||||||
|
community_moderator::table.on(
|
||||||
|
community_moderator::community_id
|
||||||
|
.eq(post::community_id)
|
||||||
|
.and(community_moderator::person_id.eq(self.my_person_id)),
|
||||||
|
),
|
||||||
|
)
|
||||||
|
.load::<CommentReportViewTuple>(self.conn)?
|
||||||
|
} else {
|
||||||
|
query.load::<CommentReportViewTuple>(self.conn)?
|
||||||
|
};
|
||||||
|
|
||||||
Ok(CommentReportView::from_tuple_to_vec(res))
|
Ok(CommentReportView::from_tuple_to_vec(res))
|
||||||
}
|
}
|
||||||
|
@ -498,8 +509,8 @@ mod tests {
|
||||||
assert_eq!(
|
assert_eq!(
|
||||||
reports,
|
reports,
|
||||||
[
|
[
|
||||||
expected_sara_report_view.to_owned(),
|
expected_jessica_report_view.to_owned(),
|
||||||
expected_jessica_report_view.to_owned()
|
expected_sara_report_view.to_owned()
|
||||||
]
|
]
|
||||||
);
|
);
|
||||||
|
|
||||||
|
|
|
@ -131,25 +131,30 @@ impl PostReportView {
|
||||||
use diesel::dsl::*;
|
use diesel::dsl::*;
|
||||||
let mut query = post_report::table
|
let mut query = post_report::table
|
||||||
.inner_join(post::table)
|
.inner_join(post::table)
|
||||||
// Test this join
|
|
||||||
.inner_join(
|
|
||||||
community_moderator::table.on(community_moderator::community_id.eq(post::community_id)),
|
|
||||||
)
|
|
||||||
.filter(post_report::resolved.eq(false))
|
.filter(post_report::resolved.eq(false))
|
||||||
.into_boxed();
|
.into_boxed();
|
||||||
|
|
||||||
// If its not an admin, get only the ones you mod
|
|
||||||
if !admin {
|
|
||||||
query = query.filter(community_moderator::person_id.eq(my_person_id));
|
|
||||||
}
|
|
||||||
|
|
||||||
if let Some(community_id) = community_id {
|
if let Some(community_id) = community_id {
|
||||||
query = query.filter(post::community_id.eq(community_id))
|
query = query.filter(post::community_id.eq(community_id))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// If its not an admin, get only the ones you mod
|
||||||
|
if !admin {
|
||||||
|
query
|
||||||
|
.inner_join(
|
||||||
|
community_moderator::table.on(
|
||||||
|
community_moderator::community_id
|
||||||
|
.eq(post::community_id)
|
||||||
|
.and(community_moderator::person_id.eq(my_person_id)),
|
||||||
|
),
|
||||||
|
)
|
||||||
|
.select(count(post_report::id))
|
||||||
|
.first::<i64>(conn)
|
||||||
|
} else {
|
||||||
query.select(count(post_report::id)).first::<i64>(conn)
|
query.select(count(post_report::id)).first::<i64>(conn)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
pub struct PostReportQueryBuilder<'a> {
|
pub struct PostReportQueryBuilder<'a> {
|
||||||
conn: &'a PgConnection,
|
conn: &'a PgConnection,
|
||||||
|
@ -200,9 +205,6 @@ impl<'a> PostReportQueryBuilder<'a> {
|
||||||
.inner_join(community::table.on(post::community_id.eq(community::id)))
|
.inner_join(community::table.on(post::community_id.eq(community::id)))
|
||||||
.inner_join(person::table.on(post_report::creator_id.eq(person::id)))
|
.inner_join(person::table.on(post_report::creator_id.eq(person::id)))
|
||||||
.inner_join(person_alias_1::table.on(post::creator_id.eq(person_alias_1::id)))
|
.inner_join(person_alias_1::table.on(post::creator_id.eq(person_alias_1::id)))
|
||||||
.inner_join(
|
|
||||||
community_moderator::table.on(community_moderator::community_id.eq(post::community_id)),
|
|
||||||
)
|
|
||||||
.left_join(
|
.left_join(
|
||||||
community_person_ban::table.on(
|
community_person_ban::table.on(
|
||||||
post::community_id
|
post::community_id
|
||||||
|
@ -234,11 +236,6 @@ impl<'a> PostReportQueryBuilder<'a> {
|
||||||
))
|
))
|
||||||
.into_boxed();
|
.into_boxed();
|
||||||
|
|
||||||
// If its not an admin, get only the ones you mod
|
|
||||||
if !self.admin {
|
|
||||||
query = query.filter(community_moderator::person_id.eq(self.my_person_id));
|
|
||||||
}
|
|
||||||
|
|
||||||
if let Some(community_id) = self.community_id {
|
if let Some(community_id) = self.community_id {
|
||||||
query = query.filter(post::community_id.eq(community_id));
|
query = query.filter(post::community_id.eq(community_id));
|
||||||
}
|
}
|
||||||
|
@ -249,11 +246,25 @@ impl<'a> PostReportQueryBuilder<'a> {
|
||||||
|
|
||||||
let (limit, offset) = limit_and_offset(self.page, self.limit);
|
let (limit, offset) = limit_and_offset(self.page, self.limit);
|
||||||
|
|
||||||
let res = query
|
query = query
|
||||||
.order_by(post_report::published.asc())
|
.order_by(post_report::published.desc())
|
||||||
.limit(limit)
|
.limit(limit)
|
||||||
.offset(offset)
|
.offset(offset);
|
||||||
.load::<PostReportViewTuple>(self.conn)?;
|
|
||||||
|
// If its not an admin, get only the ones you mod
|
||||||
|
let res = if !self.admin {
|
||||||
|
query
|
||||||
|
.inner_join(
|
||||||
|
community_moderator::table.on(
|
||||||
|
community_moderator::community_id
|
||||||
|
.eq(post::community_id)
|
||||||
|
.and(community_moderator::person_id.eq(self.my_person_id)),
|
||||||
|
),
|
||||||
|
)
|
||||||
|
.load::<PostReportViewTuple>(self.conn)?
|
||||||
|
} else {
|
||||||
|
query.load::<PostReportViewTuple>(self.conn)?
|
||||||
|
};
|
||||||
|
|
||||||
Ok(PostReportView::from_tuple_to_vec(res))
|
Ok(PostReportView::from_tuple_to_vec(res))
|
||||||
}
|
}
|
||||||
|
@ -481,8 +492,8 @@ mod tests {
|
||||||
assert_eq!(
|
assert_eq!(
|
||||||
reports,
|
reports,
|
||||||
[
|
[
|
||||||
expected_sara_report_view.to_owned(),
|
expected_jessica_report_view.to_owned(),
|
||||||
expected_jessica_report_view.to_owned()
|
expected_sara_report_view.to_owned()
|
||||||
]
|
]
|
||||||
);
|
);
|
||||||
|
|
||||||
|
|
|
@ -0,0 +1,2 @@
|
||||||
|
drop index idx_comment_report_published;
|
||||||
|
drop index idx_post_report_published;
|
|
@ -0,0 +1,2 @@
|
||||||
|
create index idx_comment_report_published on comment_report (published desc);
|
||||||
|
create index idx_post_report_published on post_report (published desc);
|
Loading…
Reference in a new issue