2 fetcher::post_or_comment::PostOrComment,
3 objects::{comment::ApubComment, person::ApubPerson, post::ApubPost},
6 use activitystreams::{object::kind::NoteType, unparsed::Unparsed};
7 use chrono::{DateTime, FixedOffset};
8 use lemmy_api_common::blocking;
9 use lemmy_apub_lib::{object_id::ObjectId, values::MediaTypeHtml};
10 use lemmy_db_schema::{newtypes::CommentId, source::post::Post, traits::Crud};
11 use lemmy_utils::LemmyError;
12 use lemmy_websocket::LemmyContext;
13 use serde::{Deserialize, Serialize};
14 use serde_with::skip_serializing_none;
18 #[skip_serializing_none]
19 #[derive(Clone, Debug, Deserialize, Serialize)]
20 #[serde(rename_all = "camelCase")]
22 pub(crate) r#type: NoteType,
23 pub(crate) id: ObjectId<ApubComment>,
24 pub(crate) attributed_to: ObjectId<ApubPerson>,
25 pub(crate) to: Vec<Url>,
27 pub(crate) cc: Vec<Url>,
28 pub(crate) content: String,
29 pub(crate) media_type: Option<MediaTypeHtml>,
31 pub(crate) source: SourceCompat,
32 pub(crate) in_reply_to: ObjectId<PostOrComment>,
33 pub(crate) published: Option<DateTime<FixedOffset>>,
34 pub(crate) updated: Option<DateTime<FixedOffset>>,
36 pub(crate) unparsed: Unparsed,
39 /// Pleroma puts a raw string in the source, so we have to handle it here for deserialization to work
40 #[derive(Clone, Debug, Deserialize, Serialize)]
41 #[serde(rename_all = "camelCase")]
43 pub(crate) enum SourceCompat {
49 impl Default for SourceCompat {
50 fn default() -> Self {
56 pub(crate) async fn get_parents(
58 context: &LemmyContext,
59 request_counter: &mut i32,
60 ) -> Result<(ApubPost, Option<CommentId>), LemmyError> {
61 // Fetch parent comment chain in a box, otherwise it can cause a stack overflow.
62 let parent = Box::pin(
65 .dereference(context, request_counter)
68 match parent.deref() {
69 PostOrComment::Post(p) => {
70 // Workaround because I cant figure out how to get the post out of the box (and we dont
71 // want to stackoverflow in a deep comment hierarchy).
73 let post = blocking(context.pool(), move |conn| Post::read(conn, post_id)).await??;
74 Ok((post.into(), None))
76 PostOrComment::Comment(c) => {
77 let post_id = c.post_id;
78 let post = blocking(context.pool(), move |conn| Post::read(conn, post_id)).await??;
79 Ok((post.into(), Some(c.id)))