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: &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: &DbPool, new_activity: &Self::InsertForm) -> Result<Self, Error> {
22 let conn = &mut get_conn(pool).await?;
25 .get_result::<Self>(conn)
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: &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(pool: &DbPool, object_id: &DbUrl) -> Result<Activity, Error> {
50 let conn = &mut get_conn(pool).await?;
52 .filter(ap_id.eq(object_id))
64 activity::{Activity, ActivityInsertForm},
66 person::{Person, PersonInsertForm},
68 utils::build_db_pool_for_tests,
70 use serde_json::Value;
71 use serial_test::serial;
76 async fn test_crud() {
77 let pool = &build_db_pool_for_tests().await;
79 let inserted_instance = Instance::read_or_create(pool, "my_domain.tld".to_string())
83 let creator_form = PersonInsertForm::builder()
84 .name("activity_creator_ pm".into())
85 .public_key("pubkey".to_string())
86 .instance_id(inserted_instance.id)
89 let inserted_creator = Person::create(pool, &creator_form).await.unwrap();
91 let ap_id_: DbUrl = Url::parse(
92 "https://enterprise.lemmy.ml/activities/delete/f1b5d57c-80f8-4e03-a615-688d552e946c",
96 let test_json: Value = serde_json::from_str(
98 "@context": "https://www.w3.org/ns/activitystreams",
99 "id": "https://enterprise.lemmy.ml/activities/delete/f1b5d57c-80f8-4e03-a615-688d552e946c",
101 "actor": "https://enterprise.lemmy.ml/u/riker",
102 "to": "https://www.w3.org/ns/activitystreams#Public",
104 "https://enterprise.lemmy.ml/c/main/"
106 "object": "https://enterprise.lemmy.ml/post/32"
110 let activity_form = ActivityInsertForm {
111 ap_id: ap_id_.clone(),
112 data: test_json.clone(),
114 sensitive: Some(false),
118 let inserted_activity = Activity::create(pool, &activity_form).await.unwrap();
120 let expected_activity = Activity {
121 ap_id: ap_id_.clone(),
122 id: inserted_activity.id,
126 published: inserted_activity.published,
130 let read_activity = Activity::read(pool, inserted_activity.id).await.unwrap();
131 let read_activity_by_apub_id = Activity::read_from_apub_id(pool, &ap_id_).await.unwrap();
132 Person::delete(pool, inserted_creator.id).await.unwrap();
133 Activity::delete(pool, inserted_activity.id).await.unwrap();
135 assert_eq!(expected_activity, read_activity);
136 assert_eq!(expected_activity, read_activity_by_apub_id);
137 assert_eq!(expected_activity, inserted_activity);