lemmy/server/src/apub/activities.rs

144 lines
3.8 KiB
Rust
Raw Normal View History

2020-04-09 19:04:31 +00:00
use crate::apub::{get_apub_protocol_string, get_following_instances};
2020-04-10 11:26:06 +00:00
use crate::db::community::Community;
2020-04-09 19:04:31 +00:00
use crate::db::post::Post;
use crate::db::user::User_;
2020-04-10 11:26:06 +00:00
use crate::db::Crud;
2020-04-14 15:37:23 +00:00
use activitystreams::activity::{Accept, Create, Follow, Update};
2020-04-13 13:06:41 +00:00
use activitystreams::object::properties::ObjectProperties;
2020-04-14 15:37:23 +00:00
use activitystreams::BaseBox;
2020-04-13 13:06:41 +00:00
use activitystreams::{context, public};
2020-04-09 19:04:31 +00:00
use diesel::PgConnection;
use failure::Error;
2020-04-13 13:06:41 +00:00
use failure::_core::fmt::Debug;
2020-04-09 19:04:31 +00:00
use isahc::prelude::*;
2020-04-13 13:06:41 +00:00
use serde::Serialize;
2020-04-09 19:04:31 +00:00
2020-04-13 13:06:41 +00:00
fn populate_object_props(
props: &mut ObjectProperties,
addressed_to: &str,
object_id: &str,
) -> Result<(), Error> {
props
.set_context_xsd_any_uri(context())?
// TODO: the activity needs a seperate id from the object
.set_id(object_id)?
2020-04-10 11:26:06 +00:00
// TODO: should to/cc go on the Create, or on the Post? or on both?
// TODO: handle privacy on the receiving side (at least ignore anything thats not public)
2020-04-13 13:06:41 +00:00
.set_to_xsd_any_uri(public())?
.set_cc_xsd_any_uri(addressed_to)?;
Ok(())
}
2020-04-14 15:37:23 +00:00
fn send_activity<A>(activity: &A, to: Vec<String>) -> Result<(), Error>
2020-04-13 13:06:41 +00:00
where
A: Serialize + Debug,
{
let json = serde_json::to_string(&activity)?;
2020-04-14 15:37:23 +00:00
println!("sending data {}", json);
for t in to {
println!("to: {}", t);
let res = Request::post(t)
2020-04-09 19:04:31 +00:00
.header("Content-Type", "application/json")
.body(json.to_owned())?
.send()?;
dbg!(res);
}
Ok(())
}
2020-04-13 13:06:41 +00:00
2020-04-14 15:37:23 +00:00
fn get_followers(_community: &Community) -> Vec<String> {
// TODO: this is wrong, needs to go to the (non-local) followers of the community
get_following_instances()
.iter()
.map(|i| {
format!(
"{}://{}/federation/inbox",
get_apub_protocol_string(),
i.domain
)
})
.collect()
}
2020-04-13 13:06:41 +00:00
pub fn post_create(post: &Post, creator: &User_, conn: &PgConnection) -> Result<(), Error> {
let page = post.as_page(conn)?;
let community = Community::read(conn, post.community_id)?;
let mut create = Create::new();
populate_object_props(
&mut create.object_props,
&community.get_followers_url(),
&post.ap_id,
)?;
create
.create_props
.set_actor_xsd_any_uri(creator.actor_id.to_owned())?
.set_object_base_box(page)?;
2020-04-14 15:37:23 +00:00
send_activity(&create, get_followers(&community))?;
2020-04-13 13:06:41 +00:00
Ok(())
}
pub fn post_update(post: &Post, creator: &User_, conn: &PgConnection) -> Result<(), Error> {
let page = post.as_page(conn)?;
let community = Community::read(conn, post.community_id)?;
let mut update = Update::new();
populate_object_props(
&mut update.object_props,
&community.get_followers_url(),
&post.ap_id,
)?;
update
.update_props
.set_actor_xsd_any_uri(creator.actor_id.to_owned())?
.set_object_base_box(page)?;
2020-04-14 15:37:23 +00:00
send_activity(&update, get_followers(&community))?;
Ok(())
}
pub fn follow_community(
community: &Community,
user: &User_,
_conn: &PgConnection,
) -> Result<(), Error> {
let mut follow = Follow::new();
follow
.object_props
.set_context_xsd_any_uri(context())?
// TODO: needs proper id
.set_id(user.actor_id.clone())?;
follow
.follow_props
.set_actor_xsd_any_uri(user.actor_id.clone())?
.set_object_xsd_any_uri(community.actor_id.clone())?;
let to = format!("{}/inbox", community.actor_id);
send_activity(&follow, vec![to])?;
Ok(())
}
pub fn accept_follow(follow: &Follow) -> Result<(), Error> {
let mut accept = Accept::new();
accept
.object_props
.set_context_xsd_any_uri(context())?
// TODO: needs proper id
.set_id(
follow
.follow_props
.get_actor_xsd_any_uri()
.unwrap()
.to_string(),
)?;
accept
.accept_props
.set_object_base_box(BaseBox::from_concrete(follow.clone())?)?;
let to = format!(
"{}/inbox",
follow
.follow_props
.get_actor_xsd_any_uri()
.unwrap()
.to_string()
);
send_activity(&accept, vec![to])?;
2020-04-13 13:06:41 +00:00
Ok(())
}