mainsail 0.1.0

Batteries-included ActivityPub Library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

//! ActivityPub [Undo Activity](https://www.w3.org/TR/activitystreams-vocabulary/#dfn-undo)
use serde::{Deserialize, Serialize};
use url::Url;
use uuid::Uuid;
use crate::activitypub::Context;
use crate::activitypub::AtContext;
use crate::local::actors::LocalActorStub;
use crate::gateway::send_activity;
use crate::local::InternalResult;
use crate::database::Database;

use super::Activity;

#[derive(Debug, Serialize, Deserialize)]
enum UndoActivityType { Undo }

#[derive(Debug, Serialize, Deserialize)]
pub struct UndoActivity<T> {
    #[serde(rename = "type")]
    activity_type: UndoActivityType,
    #[serde(rename = "@context")]
    pub context: Option<AtContext>,
    pub id: Url,
    pub actor: String,
    pub object: T,
}

impl<T: Serialize> UndoActivity<T> {
    pub fn new(activity_id: String, sender_id: String, object: T) -> UndoActivity<T> {
        UndoActivity {
            context: Some(AtContext::Context(Context::ActivityStreams)),
            activity_type: UndoActivityType::Undo,
            id: activity_id.parse().unwrap(),
            actor: sender_id,
            object,
        }
    }
}

impl<T: Serialize> Activity for UndoActivity<T> {
    fn get_id(&self) -> &Url {
        &self.id
    }

    fn json(&self) -> String {
        serde_json::json!(self).to_string()
    }
}

pub async fn send(db: Database, sender: LocalActorStub, recipient_inbox_url: Url, activity: &impl Activity) -> InternalResult<()> {
    let activity_id = Uuid::new_v4().to_string();
    let activity_id = format!("https://{}/activity/{}", sender.domain, activity_id);
    let undo_activity = UndoActivity::new(activity_id, sender.id.clone(), &activity);
    send_activity(db, recipient_inbox_url, sender, &undo_activity).await
}

// Receiving an UndoActivity is handled by handlers in inbox.rs
// I think it would be nice to have that match statement here instead
// but I would have to figure out if there's a way for serde to parse an `impl Activity`
// which I haven't figured out how to do