use super::*; #[derive(Deserialize)] pub struct CommunityQuery { community_name: String, } impl ToApub for Community { // Turn a Lemmy Community into an ActivityPub group that can be sent out over the network. fn to_apub(&self, conn: &PgConnection) -> Result { let mut group = Group::default(); let oprops: &mut ObjectProperties = group.as_mut(); let creator = User_::read(conn, self.creator_id)?; oprops .set_context_xsd_any_uri(context())? .set_id(self.actor_id.to_owned())? .set_name_xsd_string(self.name.to_owned())? .set_published(convert_datetime(self.published))? .set_attributed_to_xsd_any_uri(creator.actor_id)?; if let Some(u) = self.updated.to_owned() { oprops.set_updated(convert_datetime(u))?; } if let Some(d) = self.description.to_owned() { // TODO: this should be html, also add source field with raw markdown // -> same for post.content and others oprops.set_summary_xsd_string(d)?; } let mut actor_props = ApActorProperties::default(); actor_props .set_preferred_username(self.title.to_owned())? .set_inbox(self.get_inbox_url())? .set_outbox(self.get_outbox_url())? .set_followers(self.get_followers_url())?; let public_key = PublicKey { id: format!("{}#main-key", self.actor_id), owner: self.actor_id.to_owned(), public_key_pem: self.public_key.to_owned().unwrap(), }; Ok(group.extend(actor_props).extend(public_key.to_ext())) } } impl ActorType for Community { fn actor_id(&self) -> String { self.actor_id.to_owned() } } impl FromApub for CommunityForm { /// Parse an ActivityPub group received from another instance into a Lemmy community. fn from_apub(group: &GroupExt, conn: &PgConnection) -> Result { let oprops = &group.base.base.object_props; let aprops = &group.base.extension; let public_key: &PublicKey = &group.extension.public_key; let _followers_uri = Url::parse(&aprops.get_followers().unwrap().to_string())?; let _outbox_uri = Url::parse(&aprops.get_outbox().to_string())?; // TODO don't do extra fetching here // let _outbox = fetch_remote_object::(&outbox_uri)?; // let _followers = fetch_remote_object::(&followers_uri)?; let apub_id = &oprops.get_attributed_to_xsd_any_uri().unwrap().to_string(); let creator = get_or_fetch_and_upsert_remote_user(&apub_id, conn)?; Ok(CommunityForm { name: oprops.get_name_xsd_string().unwrap().to_string(), title: aprops.get_preferred_username().unwrap().to_string(), // TODO: should be parsed as html and tags like