crates/db_queries/src/source/private_message.rs

   1 use crate::{ApubObject, Crud};
   2 use diesel::{dsl::*, result::Error, *};
   3 use lemmy_db_schema::{naive_now, source::private_message::*, DbUrl};
   4
   5 impl Crud<PrivateMessageForm> for PrivateMessage {
   6   fn read(conn: &PgConnection, private_message_id: i32) -> Result<Self, Error> {
   7     use lemmy_db_schema::schema::private_message::dsl::*;
   8     private_message.find(private_message_id).first::<Self>(conn)
   9   }
  10
  11   fn create(conn: &PgConnection, private_message_form: &PrivateMessageForm) -> Result<Self, Error> {
  12     use lemmy_db_schema::schema::private_message::dsl::*;
  13     insert_into(private_message)
  14       .values(private_message_form)
  15       .get_result::<Self>(conn)
  16   }
  17
  18   fn update(
  19     conn: &PgConnection,
  20     private_message_id: i32,
  21     private_message_form: &PrivateMessageForm,
  22   ) -> Result<Self, Error> {
  23     use lemmy_db_schema::schema::private_message::dsl::*;
  24     diesel::update(private_message.find(private_message_id))
  25       .set(private_message_form)
  26       .get_result::<Self>(conn)
  27   }
  28 }
  29
  30 impl ApubObject<PrivateMessageForm> for PrivateMessage {
  31   fn read_from_apub_id(conn: &PgConnection, object_id: &DbUrl) -> Result<Self, Error>
  32   where
  33     Self: Sized,
  34   {
  35     use lemmy_db_schema::schema::private_message::dsl::*;
  36     private_message
  37       .filter(ap_id.eq(object_id))
  38       .first::<Self>(conn)
  39   }
  40
  41   fn upsert(conn: &PgConnection, private_message_form: &PrivateMessageForm) -> Result<Self, Error> {
  42     use lemmy_db_schema::schema::private_message::dsl::*;
  43     insert_into(private_message)
  44       .values(private_message_form)
  45       .on_conflict(ap_id)
  46       .do_update()
  47       .set(private_message_form)
  48       .get_result::<Self>(conn)
  49   }
  50 }
  51
  52 pub trait PrivateMessage_ {
  53   fn update_ap_id(
  54     conn: &PgConnection,
  55     private_message_id: i32,
  56     apub_id: DbUrl,
  57   ) -> Result<PrivateMessage, Error>;
  58   fn update_content(
  59     conn: &PgConnection,
  60     private_message_id: i32,
  61     new_content: &str,
  62   ) -> Result<PrivateMessage, Error>;
  63   fn update_deleted(
  64     conn: &PgConnection,
  65     private_message_id: i32,
  66     new_deleted: bool,
  67   ) -> Result<PrivateMessage, Error>;
  68   fn update_read(
  69     conn: &PgConnection,
  70     private_message_id: i32,
  71     new_read: bool,
  72   ) -> Result<PrivateMessage, Error>;
  73   fn mark_all_as_read(
  74     conn: &PgConnection,
  75     for_recipient_id: i32,
  76   ) -> Result<Vec<PrivateMessage>, Error>;
  77 }
  78
  79 impl PrivateMessage_ for PrivateMessage {
  80   fn update_ap_id(
  81     conn: &PgConnection,
  82     private_message_id: i32,
  83     apub_id: DbUrl,
  84   ) -> Result<PrivateMessage, Error> {
  85     use lemmy_db_schema::schema::private_message::dsl::*;
  86
  87     diesel::update(private_message.find(private_message_id))
  88       .set(ap_id.eq(apub_id))
  89       .get_result::<Self>(conn)
  90   }
  91
  92   fn update_content(
  93     conn: &PgConnection,
  94     private_message_id: i32,
  95     new_content: &str,
  96   ) -> Result<PrivateMessage, Error> {
  97     use lemmy_db_schema::schema::private_message::dsl::*;
  98     diesel::update(private_message.find(private_message_id))
  99       .set((content.eq(new_content), updated.eq(naive_now())))
 100       .get_result::<Self>(conn)
 101   }
 102
 103   fn update_deleted(
 104     conn: &PgConnection,
 105     private_message_id: i32,
 106     new_deleted: bool,
 107   ) -> Result<PrivateMessage, Error> {
 108     use lemmy_db_schema::schema::private_message::dsl::*;
 109     diesel::update(private_message.find(private_message_id))
 110       .set(deleted.eq(new_deleted))
 111       .get_result::<Self>(conn)
 112   }
 113
 114   fn update_read(
 115     conn: &PgConnection,
 116     private_message_id: i32,
 117     new_read: bool,
 118   ) -> Result<PrivateMessage, Error> {
 119     use lemmy_db_schema::schema::private_message::dsl::*;
 120     diesel::update(private_message.find(private_message_id))
 121       .set(read.eq(new_read))
 122       .get_result::<Self>(conn)
 123   }
 124
 125   fn mark_all_as_read(
 126     conn: &PgConnection,
 127     for_recipient_id: i32,
 128   ) -> Result<Vec<PrivateMessage>, Error> {
 129     use lemmy_db_schema::schema::private_message::dsl::*;
 130     diesel::update(
 131       private_message
 132         .filter(recipient_id.eq(for_recipient_id))
 133         .filter(read.eq(false)),
 134     )
 135     .set(read.eq(true))
 136     .get_results::<Self>(conn)
 137   }
 138 }
 139
 140 #[cfg(test)]
 141 mod tests {
 142   use crate::{establish_unpooled_connection, source::private_message::PrivateMessage_, Crud};
 143   use lemmy_db_schema::source::{person::*, private_message::*};
 144   use serial_test::serial;
 145
 146   #[test]
 147   #[serial]
 148   fn test_crud() {
 149     let conn = establish_unpooled_connection();
 150
 151     let creator_form = PersonForm {
 152       name: "creator_pm".into(),
 153       preferred_username: None,
 154       avatar: None,
 155       banner: None,
 156       banned: None,
 157       deleted: None,
 158       published: None,
 159       updated: None,
 160       actor_id: None,
 161       bio: None,
 162       local: None,
 163       private_key: None,
 164       public_key: None,
 165       last_refreshed_at: None,
 166       inbox_url: None,
 167       shared_inbox_url: None,
 168     };
 169
 170     let inserted_creator = Person::create(&conn, &creator_form).unwrap();
 171
 172     let recipient_form = PersonForm {
 173       name: "recipient_pm".into(),
 174       preferred_username: None,
 175       avatar: None,
 176       banner: None,
 177       banned: None,
 178       deleted: None,
 179       published: None,
 180       updated: None,
 181       actor_id: None,
 182       bio: None,
 183       local: None,
 184       private_key: None,
 185       public_key: None,
 186       last_refreshed_at: None,
 187       inbox_url: None,
 188       shared_inbox_url: None,
 189     };
 190
 191     let inserted_recipient = Person::create(&conn, &recipient_form).unwrap();
 192
 193     let private_message_form = PrivateMessageForm {
 194       content: "A test private message".into(),
 195       creator_id: inserted_creator.id,
 196       recipient_id: inserted_recipient.id,
 197       deleted: None,
 198       read: None,
 199       published: None,
 200       updated: None,
 201       ap_id: None,
 202       local: true,
 203     };
 204
 205     let inserted_private_message = PrivateMessage::create(&conn, &private_message_form).unwrap();
 206
 207     let expected_private_message = PrivateMessage {
 208       id: inserted_private_message.id,
 209       content: "A test private message".into(),
 210       creator_id: inserted_creator.id,
 211       recipient_id: inserted_recipient.id,
 212       deleted: false,
 213       read: false,
 214       updated: None,
 215       published: inserted_private_message.published,
 216       ap_id: inserted_private_message.ap_id.to_owned(),
 217       local: true,
 218     };
 219
 220     let read_private_message = PrivateMessage::read(&conn, inserted_private_message.id).unwrap();
 221     let updated_private_message =
 222       PrivateMessage::update(&conn, inserted_private_message.id, &private_message_form).unwrap();
 223     let deleted_private_message =
 224       PrivateMessage::update_deleted(&conn, inserted_private_message.id, true).unwrap();
 225     let marked_read_private_message =
 226       PrivateMessage::update_read(&conn, inserted_private_message.id, true).unwrap();
 227     Person::delete(&conn, inserted_creator.id).unwrap();
 228     Person::delete(&conn, inserted_recipient.id).unwrap();
 229
 230     assert_eq!(expected_private_message, read_private_message);
 231     assert_eq!(expected_private_message, updated_private_message);
 232     assert_eq!(expected_private_message, inserted_private_message);
 233     assert!(deleted_private_message.deleted);
 234     assert!(marked_read_private_message.read);
 235   }
 236 }