3 schema::activity::dsl::{activity, ap_id},
4 source::activity::{Activity, ActivityInsertForm, ActivityUpdateForm},
6 utils::{get_conn, DbPool},
8 use diesel::{dsl::insert_into, result::Error, ExpressionMethods, QueryDsl};
9 use diesel_async::RunQueryDsl;
12 impl Crud for Activity {
13 type InsertForm = ActivityInsertForm;
14 type UpdateForm = ActivityUpdateForm;
16 async fn read(pool: &mut DbPool<'_>, activity_id: i32) -> Result<Self, Error> {
17 let conn = &mut get_conn(pool).await?;
18 activity.find(activity_id).first::<Self>(conn).await
21 async fn create(pool: &mut DbPool<'_>, new_activity: &Self::InsertForm) -> Result<Self, Error> {
22 let conn = &mut get_conn(pool).await?;
25 .get_result::<Self>(conn)
30 pool: &mut DbPool<'_>,
32 new_activity: &Self::UpdateForm,
33 ) -> Result<Self, Error> {
34 let conn = &mut get_conn(pool).await?;
35 diesel::update(activity.find(activity_id))
37 .get_result::<Self>(conn)
40 async fn delete(pool: &mut DbPool<'_>, activity_id: i32) -> Result<usize, Error> {
41 let conn = &mut get_conn(pool).await?;
42 diesel::delete(activity.find(activity_id))
49 pub async fn read_from_apub_id(
50 pool: &mut DbPool<'_>,
52 ) -> Result<Activity, Error> {
53 let conn = &mut get_conn(pool).await?;
55 .filter(ap_id.eq(object_id))
67 activity::{Activity, ActivityInsertForm},
69 person::{Person, PersonInsertForm},
71 utils::build_db_pool_for_tests,
73 use serde_json::Value;
74 use serial_test::serial;
79 async fn test_crud() {
80 let pool = &build_db_pool_for_tests().await;
81 let pool = &mut pool.into();
83 let inserted_instance = Instance::read_or_create(pool, "my_domain.tld".to_string())
87 let creator_form = PersonInsertForm::builder()
88 .name("activity_creator_ pm".into())
89 .public_key("pubkey".to_string())
90 .instance_id(inserted_instance.id)
93 let inserted_creator = Person::create(pool, &creator_form).await.unwrap();
95 let ap_id_: DbUrl = Url::parse(
96 "https://enterprise.lemmy.ml/activities/delete/f1b5d57c-80f8-4e03-a615-688d552e946c",
100 let test_json: Value = serde_json::from_str(
102 "@context": "https://www.w3.org/ns/activitystreams",
103 "id": "https://enterprise.lemmy.ml/activities/delete/f1b5d57c-80f8-4e03-a615-688d552e946c",
105 "actor": "https://enterprise.lemmy.ml/u/riker",
106 "to": "https://www.w3.org/ns/activitystreams#Public",
108 "https://enterprise.lemmy.ml/c/main/"
110 "object": "https://enterprise.lemmy.ml/post/32"
114 let activity_form = ActivityInsertForm {
115 ap_id: ap_id_.clone(),
116 data: test_json.clone(),
118 sensitive: Some(false),
122 let inserted_activity = Activity::create(pool, &activity_form).await.unwrap();
124 let expected_activity = Activity {
125 ap_id: ap_id_.clone(),
126 id: inserted_activity.id,
130 published: inserted_activity.published,
134 let read_activity = Activity::read(pool, inserted_activity.id).await.unwrap();
135 let read_activity_by_apub_id = Activity::read_from_apub_id(pool, &ap_id_).await.unwrap();
136 Person::delete(pool, inserted_creator.id).await.unwrap();
137 Activity::delete(pool, inserted_activity.id).await.unwrap();
139 assert_eq!(expected_activity, read_activity);
140 assert_eq!(expected_activity, read_activity_by_apub_id);
141 assert_eq!(expected_activity, inserted_activity);