]> Untitled Git - lemmy.git/blob - crates/db_views_moderator/src/admin_purge_comment_view.rs
033991a8f7adc3dad60168f6ca78ece0660321bb
[lemmy.git] / crates / db_views_moderator / src / admin_purge_comment_view.rs
1 use crate::structs::AdminPurgeCommentView;
2 use diesel::{result::Error, *};
3 use lemmy_db_schema::{
4   newtypes::PersonId,
5   schema::{admin_purge_comment, person, post},
6   source::{
7     moderator::AdminPurgeComment,
8     person::{Person, PersonSafe},
9     post::Post,
10   },
11   traits::{ToSafe, ViewToVec},
12   utils::limit_and_offset,
13 };
14
15 type AdminPurgeCommentViewTuple = (AdminPurgeComment, PersonSafe, Post);
16
17 impl AdminPurgeCommentView {
18   pub fn list(
19     conn: &PgConnection,
20     admin_person_id: Option<PersonId>,
21     page: Option<i64>,
22     limit: Option<i64>,
23   ) -> Result<Vec<Self>, Error> {
24     let mut query = admin_purge_comment::table
25       .inner_join(person::table.on(admin_purge_comment::admin_person_id.eq(person::id)))
26       .inner_join(post::table)
27       .select((
28         admin_purge_comment::all_columns,
29         Person::safe_columns_tuple(),
30         post::all_columns,
31       ))
32       .into_boxed();
33
34     if let Some(admin_person_id) = admin_person_id {
35       query = query.filter(admin_purge_comment::admin_person_id.eq(admin_person_id));
36     };
37
38     let (limit, offset) = limit_and_offset(page, limit)?;
39
40     let res = query
41       .limit(limit)
42       .offset(offset)
43       .order_by(admin_purge_comment::when_.desc())
44       .load::<AdminPurgeCommentViewTuple>(conn)?;
45
46     Ok(Self::from_tuple_to_vec(res))
47   }
48 }
49
50 impl ViewToVec for AdminPurgeCommentView {
51   type DbTuple = AdminPurgeCommentViewTuple;
52   fn from_tuple_to_vec(items: Vec<Self::DbTuple>) -> Vec<Self> {
53     items
54       .into_iter()
55       .map(|a| Self {
56         admin_purge_comment: a.0,
57         admin: a.1,
58         post: a.2,
59       })
60       .collect::<Vec<Self>>()
61   }
62 }