2 extensions::context::lemmy_context,
3 fetcher::person::get_or_fetch_and_upsert_person,
8 get_source_markdown_value,
9 set_content_and_source,
16 use activitystreams::{
17 object::{kind::NoteType, ApObject, Note, Tombstone},
21 use lemmy_api_common::blocking;
22 use lemmy_db_queries::{Crud, DbPool};
23 use lemmy_db_schema::source::{
25 private_message::{PrivateMessage, PrivateMessageForm},
27 use lemmy_utils::{location_info, utils::convert_datetime, LemmyError};
28 use lemmy_websocket::LemmyContext;
31 #[async_trait::async_trait(?Send)]
32 impl ToApub for PrivateMessage {
33 type ApubType = NoteExt;
35 async fn to_apub(&self, pool: &DbPool) -> Result<NoteExt, LemmyError> {
36 let mut private_message = ApObject::new(Note::new());
38 let creator_id = self.creator_id;
39 let creator = blocking(pool, move |conn| Person::read(conn, creator_id)).await??;
41 let recipient_id = self.recipient_id;
42 let recipient = blocking(pool, move |conn| Person::read(conn, recipient_id)).await??;
45 .set_many_contexts(lemmy_context()?)
46 .set_id(self.ap_id.to_owned().into_inner())
47 .set_published(convert_datetime(self.published))
48 .set_to(recipient.actor_id.into_inner())
49 .set_attributed_to(creator.actor_id.into_inner());
51 set_content_and_source(&mut private_message, &self.content)?;
53 if let Some(u) = self.updated {
54 private_message.set_updated(convert_datetime(u));
60 fn to_tombstone(&self) -> Result<Tombstone, LemmyError> {
63 self.ap_id.to_owned().into(),
70 #[async_trait::async_trait(?Send)]
71 impl FromApub for PrivateMessage {
72 type ApubType = NoteExt;
76 context: &LemmyContext,
78 request_counter: &mut i32,
79 mod_action_allowed: bool,
80 ) -> Result<PrivateMessage, LemmyError> {
92 #[async_trait::async_trait(?Send)]
93 impl FromApubToForm<NoteExt> for PrivateMessageForm {
96 context: &LemmyContext,
98 request_counter: &mut i32,
99 _mod_action_allowed: bool,
100 ) -> Result<PrivateMessageForm, LemmyError> {
101 let creator_actor_id = note
103 .context(location_info!())?
105 .single_xsd_any_uri()
106 .context(location_info!())?;
109 get_or_fetch_and_upsert_person(&creator_actor_id, context, request_counter).await?;
110 let recipient_actor_id = note
112 .context(location_info!())?
114 .single_xsd_any_uri()
115 .context(location_info!())?;
117 get_or_fetch_and_upsert_person(&recipient_actor_id, context, request_counter).await?;
118 let ap_id = Some(check_object_domain(note, expected_domain, false)?);
120 let content = get_source_markdown_value(note)?.context(location_info!())?;
122 Ok(PrivateMessageForm {
123 creator_id: creator.id,
124 recipient_id: recipient.id,
126 published: note.published().map(|u| u.to_owned().naive_local()),
127 updated: note.updated().map(|u| u.to_owned().naive_local()),