lemmy/server/src/apub/activities.rs

95 lines
2.4 KiB
Rust
Raw Normal View History

2020-06-01 14:17:20 +00:00
use crate::{
apub::{
community::do_announce,
extensions::signatures::sign,
insert_activity,
is_apub_id_valid,
ActorType,
},
request::retry_custom,
DbPool,
LemmyError,
2020-06-01 14:17:20 +00:00
};
use activitystreams::{context, object::properties::ObjectProperties, public, Activity, Base};
use actix_web::client::Client;
use lemmy_db::{community::Community, user::User_};
2020-05-16 14:04:08 +00:00
use log::debug;
use serde::Serialize;
use std::fmt::Debug;
2020-05-16 14:04:08 +00:00
use url::Url;
2020-04-09 19:04:31 +00:00
pub fn populate_object_props(
2020-04-13 13:06:41 +00:00
props: &mut ObjectProperties,
addressed_ccs: Vec<String>,
2020-04-13 13:06:41 +00:00
object_id: &str,
) -> Result<(), LemmyError> {
2020-04-13 13:06:41 +00:00
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_many_cc_xsd_any_uris(addressed_ccs)?;
2020-04-13 13:06:41 +00:00
Ok(())
}
pub async fn send_activity_to_community<A>(
2020-06-01 14:17:20 +00:00
creator: &User_,
community: &Community,
to: Vec<String>,
activity: A,
client: &Client,
pool: &DbPool,
) -> Result<(), LemmyError>
2020-06-01 14:17:20 +00:00
where
A: Activity + Base + Serialize + Debug + Clone + Send + 'static,
2020-06-01 14:17:20 +00:00
{
insert_activity(creator.id, activity.clone(), true, pool).await?;
2020-06-01 14:17:20 +00:00
// if this is a local community, we need to do an announce from the community instead
if community.local {
do_announce(activity, &community, creator, client, pool).await?;
2020-06-01 14:17:20 +00:00
} else {
send_activity(client, &activity, creator, to).await?;
2020-06-01 14:17:20 +00:00
}
2020-06-01 14:17:20 +00:00
Ok(())
}
2020-04-17 15:33:55 +00:00
/// Send an activity to a list of recipients, using the correct headers etc.
pub async fn send_activity<A>(
client: &Client,
activity: &A,
actor: &dyn ActorType,
to: Vec<String>,
) -> Result<(), LemmyError>
2020-04-13 13:06:41 +00:00
where
A: Serialize,
2020-04-13 13:06:41 +00:00
{
let activity = serde_json::to_string(&activity)?;
debug!("Sending activitypub activity {} to {:?}", activity, to);
2020-04-14 15:37:23 +00:00
for t in to {
let to_url = Url::parse(&t)?;
if !is_apub_id_valid(&to_url) {
2020-06-25 19:36:03 +00:00
debug!("Not sending activity to {} (invalid or blocklisted)", t);
2020-04-17 17:34:18 +00:00
continue;
}
let res = retry_custom(|| async {
let request = client.post(&t).header("Content-Type", "application/json");
match sign(request, actor, activity.clone()).await {
Ok(signed) => Ok(signed.send().await),
Err(e) => Err(e),
}
})
.await?;
2020-04-17 14:55:28 +00:00
debug!("Result for activity send: {:?}", res);
2020-04-09 19:04:31 +00:00
}
2020-04-09 19:04:31 +00:00
Ok(())
}