use crate::apub::fetcher::{fetch_remote_object, fetch_remote_user}; use crate::apub::signatures::PublicKey; use crate::apub::*; use crate::db::community::{Community, CommunityForm}; use crate::db::community_view::CommunityFollowerView; use crate::db::establish_unpooled_connection; use crate::db::post::Post; use crate::db::user::User_; use crate::db::Crud; use crate::settings::Settings; use crate::{convert_datetime, naive_now}; use activitystreams::actor::properties::ApActorProperties; use activitystreams::collection::OrderedCollection; use activitystreams::{ actor::Group, collection::UnorderedCollection, context, ext::Extensible, object::properties::ObjectProperties, }; use actix_web::body::Body; use actix_web::web::Path; use actix_web::HttpResponse; use actix_web::{web, Result}; use diesel::r2d2::{ConnectionManager, Pool}; use diesel::PgConnection; use failure::Error; use serde::Deserialize; use url::Url; #[derive(Deserialize)] pub struct CommunityQuery { community_name: String, } pub async fn get_apub_community_list( db: web::Data>>, ) -> Result, Error> { // TODO: implement pagination let communities = Community::list_local(&db.get().unwrap())? .iter() .map(|c| c.as_group(&db.get().unwrap())) .collect::, Error>>()?; let mut collection = UnorderedCollection::default(); let oprops: &mut ObjectProperties = collection.as_mut(); oprops.set_context_xsd_any_uri(context())?.set_id(format!( "{}://{}/federation/communities", get_apub_protocol_string(), Settings::get().hostname ))?; collection .collection_props .set_total_items(communities.len() as u64)? .set_many_items_base_boxes(communities)?; Ok(create_apub_response(&collection)) } impl Community { fn as_group(&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(make_apub_endpoint(EndpointType::User, &creator.name))?; 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(format!("{}/inbox", &self.actor_id))? .set_outbox(format!("{}/outbox", &self.actor_id))? .set_followers(format!("{}/followers", &self.actor_id))?; 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 CommunityForm { pub fn from_group(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())?; let _outbox = fetch_remote_object::(&outbox_uri)?; let _followers = fetch_remote_object::(&followers_uri)?; let apub_id = Url::parse(&oprops.get_attributed_to_xsd_any_uri().unwrap().to_string())?; let creator = fetch_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