]> Untitled Git - lemmy.git/blob - crates/db_queries/src/source/activity.rs
Adding some recurring lemmy tasks. (#1386)
[lemmy.git] / crates / db_queries / src / source / activity.rs
1 use crate::Crud;
2 use diesel::{dsl::*, result::Error, sql_types::Text, *};
3 use lemmy_db_schema::{source::activity::*, Url};
4 use log::debug;
5 use serde::Serialize;
6 use serde_json::Value;
7 use std::{
8   fmt::Debug,
9   io::{Error as IoError, ErrorKind},
10 };
11
12 impl Crud<ActivityForm> for Activity {
13   fn read(conn: &PgConnection, activity_id: i32) -> Result<Self, Error> {
14     use lemmy_db_schema::schema::activity::dsl::*;
15     activity.find(activity_id).first::<Self>(conn)
16   }
17
18   fn create(conn: &PgConnection, new_activity: &ActivityForm) -> Result<Self, Error> {
19     use lemmy_db_schema::schema::activity::dsl::*;
20     insert_into(activity)
21       .values(new_activity)
22       .get_result::<Self>(conn)
23   }
24
25   fn update(
26     conn: &PgConnection,
27     activity_id: i32,
28     new_activity: &ActivityForm,
29   ) -> Result<Self, Error> {
30     use lemmy_db_schema::schema::activity::dsl::*;
31     diesel::update(activity.find(activity_id))
32       .set(new_activity)
33       .get_result::<Self>(conn)
34   }
35   fn delete(conn: &PgConnection, activity_id: i32) -> Result<usize, Error> {
36     use lemmy_db_schema::schema::activity::dsl::*;
37     diesel::delete(activity.find(activity_id)).execute(conn)
38   }
39 }
40
41 pub trait Activity_ {
42   fn insert<T>(
43     conn: &PgConnection,
44     ap_id: String,
45     data: &T,
46     local: bool,
47     sensitive: bool,
48   ) -> Result<Activity, IoError>
49   where
50     T: Serialize + Debug;
51
52   fn read_from_apub_id(conn: &PgConnection, object_id: &str) -> Result<Activity, Error>;
53   fn delete_olds(conn: &PgConnection) -> Result<usize, Error>;
54
55   /// Returns up to 20 activities of type `Announce/Create/Page` from the community
56   fn read_community_outbox(
57     conn: &PgConnection,
58     community_actor_id: &Url,
59   ) -> Result<Vec<Value>, Error>;
60 }
61
62 impl Activity_ for Activity {
63   fn insert<T>(
64     conn: &PgConnection,
65     ap_id: String,
66     data: &T,
67     local: bool,
68     sensitive: bool,
69   ) -> Result<Activity, IoError>
70   where
71     T: Serialize + Debug,
72   {
73     debug!("{}", serde_json::to_string_pretty(&data)?);
74     let activity_form = ActivityForm {
75       ap_id,
76       data: serde_json::to_value(&data)?,
77       local,
78       sensitive,
79       updated: None,
80     };
81     let result = Activity::create(&conn, &activity_form);
82     match result {
83       Ok(s) => Ok(s),
84       Err(e) => Err(IoError::new(
85         ErrorKind::Other,
86         format!("Failed to insert activity into database: {}", e),
87       )),
88     }
89   }
90
91   fn read_from_apub_id(conn: &PgConnection, object_id: &str) -> Result<Activity, Error> {
92     use lemmy_db_schema::schema::activity::dsl::*;
93     activity.filter(ap_id.eq(object_id)).first::<Self>(conn)
94   }
95
96   fn delete_olds(conn: &PgConnection) -> Result<usize, Error> {
97     use lemmy_db_schema::schema::activity::dsl::*;
98     diesel::delete(activity.filter(published.lt(now - 6.months()))).execute(conn)
99   }
100
101   fn read_community_outbox(
102     conn: &PgConnection,
103     community_actor_id: &Url,
104   ) -> Result<Vec<Value>, Error> {
105     use lemmy_db_schema::schema::activity::dsl::*;
106     let res: Vec<Value> = activity
107       .select(data)
108       .filter(
109         sql("activity.data ->> 'type' = 'Announce'")
110           .sql(" AND activity.data -> 'object' ->> 'type' = 'Create'")
111           .sql(" AND activity.data -> 'object' -> 'object' ->> 'type' = 'Page'")
112           .sql(" AND activity.data ->> 'actor' = ")
113           .bind::<Text, _>(community_actor_id),
114       )
115       .limit(20)
116       .get_results(conn)?;
117     Ok(res)
118   }
119 }
120
121 #[cfg(test)]
122 mod tests {
123   use crate::{
124     establish_unpooled_connection,
125     source::activity::Activity_,
126     Crud,
127     ListingType,
128     SortType,
129   };
130   use lemmy_db_schema::source::{
131     activity::{Activity, ActivityForm},
132     user::{UserForm, User_},
133   };
134   use serde_json::Value;
135
136   #[test]
137   fn test_crud() {
138     let conn = establish_unpooled_connection();
139
140     let creator_form = UserForm {
141       name: "activity_creator_pm".into(),
142       preferred_username: None,
143       password_encrypted: "nope".into(),
144       email: None,
145       matrix_user_id: None,
146       avatar: None,
147       banner: None,
148       admin: false,
149       banned: Some(false),
150       published: None,
151       updated: None,
152       show_nsfw: false,
153       theme: "browser".into(),
154       default_sort_type: SortType::Hot as i16,
155       default_listing_type: ListingType::Subscribed as i16,
156       lang: "browser".into(),
157       show_avatars: true,
158       send_notifications_to_email: false,
159       actor_id: None,
160       bio: None,
161       local: true,
162       private_key: None,
163       public_key: None,
164       last_refreshed_at: None,
165     };
166
167     let inserted_creator = User_::create(&conn, &creator_form).unwrap();
168
169     let ap_id =
170       "https://enterprise.lemmy.ml/activities/delete/f1b5d57c-80f8-4e03-a615-688d552e946c";
171     let test_json: Value = serde_json::from_str(
172       r#"{
173     "@context": "https://www.w3.org/ns/activitystreams",
174     "id": "https://enterprise.lemmy.ml/activities/delete/f1b5d57c-80f8-4e03-a615-688d552e946c",
175     "type": "Delete",
176     "actor": "https://enterprise.lemmy.ml/u/riker",
177     "to": "https://www.w3.org/ns/activitystreams#Public",
178     "cc": [
179         "https://enterprise.lemmy.ml/c/main/"
180     ],
181     "object": "https://enterprise.lemmy.ml/post/32"
182     }"#,
183     )
184     .unwrap();
185     let activity_form = ActivityForm {
186       ap_id: ap_id.to_string(),
187       data: test_json.to_owned(),
188       local: true,
189       sensitive: false,
190       updated: None,
191     };
192
193     let inserted_activity = Activity::create(&conn, &activity_form).unwrap();
194
195     let expected_activity = Activity {
196       ap_id: Some(ap_id.to_string()),
197       id: inserted_activity.id,
198       data: test_json,
199       local: true,
200       sensitive: Some(false),
201       published: inserted_activity.published,
202       updated: None,
203     };
204
205     let read_activity = Activity::read(&conn, inserted_activity.id).unwrap();
206     let read_activity_by_apub_id = Activity::read_from_apub_id(&conn, ap_id).unwrap();
207     User_::delete(&conn, inserted_creator.id).unwrap();
208     Activity::delete(&conn, inserted_activity.id).unwrap();
209
210     assert_eq!(expected_activity, read_activity);
211     assert_eq!(expected_activity, read_activity_by_apub_id);
212     assert_eq!(expected_activity, inserted_activity);
213   }
214 }