2023-03-06 06:47:34 +05:30
## Sending activities
To send an activity we need to initialize our previously defined struct, and pick an actor for sending. We also need a list of all actors that should receive the activity.
```
# use activitypub_federation::config::FederationConfig;
2023-09-01 14:49:22 +05:30
# use activitypub_federation::activity_sending::SendActivityTask;
2023-03-06 06:47:34 +05:30
# use activitypub_federation::http_signatures::generate_actor_keypair;
# use activitypub_federation::traits::Actor;
# use activitypub_federation::fetch::object_id::ObjectId;
# use activitypub_federation::traits::tests::{DB_USER, DbConnection, Follow};
2023-06-20 15:24:14 +05:30
# tokio::runtime::Runtime::new().unwrap().block_on(async {
2023-03-06 06:47:34 +05:30
# let db_connection = DbConnection;
# let config = FederationConfig::builder()
# .domain("example.com")
# .app_data(db_connection)
2023-06-20 15:24:14 +05:30
# .build().await?;
2023-03-06 06:47:34 +05:30
# let data = config.to_request_data();
2023-03-16 06:41:48 +05:30
# let sender = DB_USER.clone();
2023-03-06 06:47:34 +05:30
# let recipient = DB_USER.clone();
let activity = Follow {
2023-03-16 06:41:48 +05:30
actor: ObjectId::parse("https://lemmy.ml/u/nutomic")?,
2023-03-17 02:11:29 +05:30
object: recipient.federation_id.clone().into(),
2023-03-06 06:47:34 +05:30
kind: Default::default(),
id: "https://lemmy.ml/activities/321".try_into()?
};
let inboxes = vec![recipient.shared_inbox_or_inbox()];
2023-09-01 14:49:22 +05:30
let sends = SendActivityTask::prepare(& activity, & sender, inboxes, &data).await?;
for send in sends {
send.sign_and_send(&data).await?;
}
2023-03-06 06:47:34 +05:30
# Ok::<(), anyhow::Error>(())
# }).unwrap()
```
The list of inboxes gets deduplicated (important for shared inbox). All inboxes on the local
domain and those which fail the [crate::config::UrlVerifier] check are excluded from delivery.
For each remaining inbox a background tasks is created. It signs the HTTP header with the given
private key. Finally the activity is delivered to the inbox.
It is possible that delivery fails because the target instance is temporarily unreachable. In
this case the task is scheduled for retry after a certain waiting time. For each task delivery
is retried up to 3 times after the initial attempt. The retry intervals are as follows:
2023-09-01 14:49:22 +05:30
2023-03-06 06:47:34 +05:30
- one minute, in case of service restart
- one hour, in case of instance maintenance
- 2.5 days, in case of major incident with rebuild from backup
In case [crate::config::FederationConfigBuilder::debug] is enabled, no background thread is used but activities are sent directly on the foreground. This makes it easier to catch delivery errors and avoids complicated steps to await delivery in tests.