2 check_is_apub_id_valid,
3 extensions::context::lemmy_context,
4 fetcher::user::get_or_fetch_and_upsert_user,
9 get_source_markdown_value,
10 set_content_and_source,
17 use activitystreams::{
18 object::{kind::NoteType, ApObject, Note, Tombstone},
22 use lemmy_db_queries::{Crud, DbPool};
23 use lemmy_db_schema::source::{
24 private_message::{PrivateMessage, PrivateMessageForm},
27 use lemmy_structs::blocking;
28 use lemmy_utils::{location_info, utils::convert_datetime, LemmyError};
29 use lemmy_websocket::LemmyContext;
32 #[async_trait::async_trait(?Send)]
33 impl ToApub for PrivateMessage {
34 type ApubType = NoteExt;
36 async fn to_apub(&self, pool: &DbPool) -> Result<NoteExt, LemmyError> {
37 let mut private_message = ApObject::new(Note::new());
39 let creator_id = self.creator_id;
40 let creator = blocking(pool, move |conn| User_::read(conn, creator_id)).await??;
42 let recipient_id = self.recipient_id;
43 let recipient = blocking(pool, move |conn| User_::read(conn, recipient_id)).await??;
46 .set_many_contexts(lemmy_context()?)
47 .set_id(Url::parse(&self.ap_id.to_owned())?)
48 .set_published(convert_datetime(self.published))
49 .set_to(recipient.actor_id)
50 .set_attributed_to(creator.actor_id);
52 set_content_and_source(&mut private_message, &self.content)?;
54 if let Some(u) = self.updated {
55 private_message.set_updated(convert_datetime(u));
61 fn to_tombstone(&self) -> Result<Tombstone, LemmyError> {
62 create_tombstone(self.deleted, &self.ap_id, self.updated, NoteType::Note)
66 #[async_trait::async_trait(?Send)]
67 impl FromApub for PrivateMessage {
68 type ApubType = NoteExt;
72 context: &LemmyContext,
74 request_counter: &mut i32,
75 ) -> Result<PrivateMessage, LemmyError> {
76 get_object_from_apub(note, context, expected_domain, request_counter).await
80 #[async_trait::async_trait(?Send)]
81 impl FromApubToForm<NoteExt> for PrivateMessageForm {
84 context: &LemmyContext,
86 request_counter: &mut i32,
87 ) -> Result<PrivateMessageForm, LemmyError> {
88 let creator_actor_id = note
90 .context(location_info!())?
93 .context(location_info!())?;
95 let creator = get_or_fetch_and_upsert_user(&creator_actor_id, context, request_counter).await?;
96 let recipient_actor_id = note
98 .context(location_info!())?
100 .single_xsd_any_uri()
101 .context(location_info!())?;
103 get_or_fetch_and_upsert_user(&recipient_actor_id, context, request_counter).await?;
104 let ap_id = note.id_unchecked().context(location_info!())?.to_string();
105 check_is_apub_id_valid(&Url::parse(&ap_id)?)?;
107 let content = get_source_markdown_value(note)?.context(location_info!())?;
109 Ok(PrivateMessageForm {
110 creator_id: creator.id,
111 recipient_id: recipient.id,
113 published: note.published().map(|u| u.to_owned().naive_local()),
114 updated: note.updated().map(|u| u.to_owned().naive_local()),
117 ap_id: Some(check_object_domain(note, expected_domain)?),