2020-02-29 11:42:44 +00:00
|
|
|
use crate::activitypub::{actor::Group, collection::UnorderedCollection, context};
|
2019-12-19 21:59:13 +00:00
|
|
|
use crate::apub::make_apub_endpoint;
|
|
|
|
|
use crate::db::community::Community;
|
|
|
|
|
use crate::db::community_view::CommunityFollowerView;
|
2020-01-12 15:31:51 +00:00
|
|
|
use crate::db::establish_unpooled_connection;
|
2019-12-19 21:59:13 +00:00
|
|
|
use crate::to_datetime_utc;
|
|
|
|
|
use actix_web::body::Body;
|
|
|
|
|
use actix_web::web::Path;
|
|
|
|
|
use actix_web::HttpResponse;
|
|
|
|
|
use serde::Deserialize;
|
2020-02-29 02:11:39 +00:00
|
|
|
use serde_json::json;
|
2019-12-19 21:59:13 +00:00
|
|
|
|
|
|
|
|
impl Community {
|
|
|
|
|
pub fn as_group(&self) -> Group {
|
|
|
|
|
let base_url = make_apub_endpoint("c", &self.name);
|
|
|
|
|
|
|
|
|
|
let mut group = Group::default();
|
|
|
|
|
|
2020-02-29 02:11:39 +00:00
|
|
|
// TODO: why the hell is this code so awkward?
|
2019-12-19 21:59:13 +00:00
|
|
|
group.object_props.set_context_object(context()).ok();
|
2020-02-29 02:11:39 +00:00
|
|
|
group.object_props.set_id_string(self.id.to_string()).ok();
|
2019-12-19 21:59:13 +00:00
|
|
|
group
|
|
|
|
|
.object_props
|
2020-02-29 02:11:39 +00:00
|
|
|
.set_name_string(self.title.to_owned())
|
2019-12-19 21:59:13 +00:00
|
|
|
.ok();
|
|
|
|
|
group
|
|
|
|
|
.object_props
|
|
|
|
|
.set_published_utctime(to_datetime_utc(self.published))
|
|
|
|
|
.ok();
|
2020-02-29 02:11:39 +00:00
|
|
|
group.object_props.attributed_to = Some(json!(self.creator_id.to_string()));
|
2019-12-19 21:59:13 +00:00
|
|
|
if let Some(updated) = self.updated {
|
|
|
|
|
group
|
|
|
|
|
.object_props
|
|
|
|
|
.set_updated_utctime(to_datetime_utc(updated))
|
|
|
|
|
.ok();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if let Some(description) = &self.description {
|
2020-02-29 11:42:44 +00:00
|
|
|
group.object_props.summary = Some(json!(description.to_string()));
|
2019-12-19 21:59:13 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
group
|
|
|
|
|
.ap_actor_props
|
|
|
|
|
.set_inbox_string(format!("{}/inbox", &base_url))
|
|
|
|
|
.ok();
|
|
|
|
|
group
|
|
|
|
|
.ap_actor_props
|
|
|
|
|
.set_outbox_string(format!("{}/outbox", &base_url))
|
|
|
|
|
.ok();
|
|
|
|
|
group
|
|
|
|
|
.ap_actor_props
|
|
|
|
|
.set_followers_string(format!("{}/followers", &base_url))
|
|
|
|
|
.ok();
|
|
|
|
|
|
|
|
|
|
group
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
pub fn followers_as_collection(&self) -> UnorderedCollection {
|
|
|
|
|
let base_url = make_apub_endpoint("c", &self.name);
|
|
|
|
|
|
|
|
|
|
let mut collection = UnorderedCollection::default();
|
|
|
|
|
collection.object_props.set_context_object(context()).ok();
|
2020-01-02 11:30:00 +00:00
|
|
|
collection.object_props.set_id_string(base_url).ok();
|
2019-12-19 21:59:13 +00:00
|
|
|
|
2020-01-12 15:31:51 +00:00
|
|
|
let connection = establish_unpooled_connection();
|
2019-12-19 21:59:13 +00:00
|
|
|
//As we are an object, we validated that the community id was valid
|
|
|
|
|
let community_followers = CommunityFollowerView::for_community(&connection, self.id).unwrap();
|
|
|
|
|
|
2020-02-29 02:11:39 +00:00
|
|
|
// TODO: we definitely dont want to make our follower list public, we should only expose the count
|
2019-12-19 21:59:13 +00:00
|
|
|
let ap_followers = community_followers
|
|
|
|
|
.iter()
|
|
|
|
|
.map(|follower| make_apub_endpoint("u", &follower.user_name))
|
|
|
|
|
.collect();
|
|
|
|
|
|
|
|
|
|
collection
|
|
|
|
|
.collection_props
|
|
|
|
|
.set_items_string_vec(ap_followers)
|
|
|
|
|
.unwrap();
|
|
|
|
|
collection
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[derive(Deserialize)]
|
|
|
|
|
pub struct CommunityQuery {
|
|
|
|
|
community_name: String,
|
|
|
|
|
}
|
|
|
|
|
|
2020-01-11 12:30:45 +00:00
|
|
|
pub async fn get_apub_community(info: Path<CommunityQuery>) -> HttpResponse<Body> {
|
2020-01-12 15:31:51 +00:00
|
|
|
let connection = establish_unpooled_connection();
|
2019-12-19 21:59:13 +00:00
|
|
|
|
|
|
|
|
if let Ok(community) = Community::read_from_name(&connection, info.community_name.to_owned()) {
|
|
|
|
|
HttpResponse::Ok()
|
|
|
|
|
.content_type("application/activity+json")
|
|
|
|
|
.body(serde_json::to_string(&community.as_group()).unwrap())
|
|
|
|
|
} else {
|
|
|
|
|
HttpResponse::NotFound().finish()
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2020-01-11 12:30:45 +00:00
|
|
|
pub async fn get_apub_community_followers(info: Path<CommunityQuery>) -> HttpResponse<Body> {
|
2020-01-12 15:31:51 +00:00
|
|
|
let connection = establish_unpooled_connection();
|
2019-12-19 21:59:13 +00:00
|
|
|
|
|
|
|
|
if let Ok(community) = Community::read_from_name(&connection, info.community_name.to_owned()) {
|
|
|
|
|
HttpResponse::Ok()
|
|
|
|
|
.content_type("application/activity+json")
|
|
|
|
|
.body(serde_json::to_string(&community.followers_as_collection()).unwrap())
|
|
|
|
|
} else {
|
|
|
|
|
HttpResponse::NotFound().finish()
|
|
|
|
|
}
|
|
|
|
|
}
|
