crates/db_views_actor/src/community_moderator_view.rs

   1 use diesel::{result::Error, *};
   2 use lemmy_db_queries::{ToSafe, ViewToVec};
   3 use lemmy_db_schema::{
   4   schema::{community, community_moderator, person},
   5   source::{
   6     community::{Community, CommunitySafe},
   7     person::{PersonSafe, Person},
   8   },
   9 };
  10 use serde::Serialize;
  11
  12 #[derive(Debug, Serialize, Clone)]
  13 pub struct CommunityModeratorView {
  14   pub community: CommunitySafe,
  15   pub moderator: PersonSafe,
  16 }
  17
  18 type CommunityModeratorViewTuple = (CommunitySafe, PersonSafe);
  19
  20 impl CommunityModeratorView {
  21   pub fn for_community(conn: &PgConnection, community_id: i32) -> Result<Vec<Self>, Error> {
  22     let res = community_moderator::table
  23       .inner_join(community::table)
  24       .inner_join(person::table)
  25       .select((Community::safe_columns_tuple(), Person::safe_columns_tuple()))
  26       .filter(community_moderator::community_id.eq(community_id))
  27       .order_by(community_moderator::published)
  28       .load::<CommunityModeratorViewTuple>(conn)?;
  29
  30     Ok(Self::from_tuple_to_vec(res))
  31   }
  32
  33   pub fn for_person(conn: &PgConnection, person_id: i32) -> Result<Vec<Self>, Error> {
  34     let res = community_moderator::table
  35       .inner_join(community::table)
  36       .inner_join(person::table)
  37       .select((Community::safe_columns_tuple(), Person::safe_columns_tuple()))
  38       .filter(community_moderator::person_id.eq(person_id))
  39       .order_by(community_moderator::published)
  40       .load::<CommunityModeratorViewTuple>(conn)?;
  41
  42     Ok(Self::from_tuple_to_vec(res))
  43   }
  44 }
  45
  46 impl ViewToVec for CommunityModeratorView {
  47   type DbTuple = CommunityModeratorViewTuple;
  48   fn from_tuple_to_vec(items: Vec<Self::DbTuple>) -> Vec<Self> {
  49     items
  50       .iter()
  51       .map(|a| Self {
  52         community: a.0.to_owned(),
  53         moderator: a.1.to_owned(),
  54       })
  55       .collect::<Vec<Self>>()
  56   }
  57 }