Add builder for Add(Person) activity

src/activitypub/builders/add_person.rs

@@ -0,0 +1,101 @@
+use serde::Serialize;
+
+use crate::activitypub::{
+    actor::Actor,
+    constants::AP_CONTEXT,
+    deliverer::OutgoingActivity,
+    identifiers::{local_actor_id, local_object_id, LocalActorCollection},
+    vocabulary::ADD,
+};
+use crate::config::Instance;
+use crate::models::users::types::User;
+use crate::utils::id::new_uuid;
+
+#[derive(Serialize)]
+pub struct AddPerson {
+    #[serde(rename = "@context")]
+    context: String,
+
+    #[serde(rename = "type")]
+    activity_type: String,
+
+    actor: String,
+    id: String,
+    object: String,
+    target: String,
+
+    to: Vec<String>,
+}
+
+fn build_add_person(
+    instance_url: &str,
+    sender_username: &str,
+    person_id: &str,
+    collection: LocalActorCollection,
+) -> AddPerson {
+    let actor_id = local_actor_id(instance_url, sender_username);
+    let activity_id = local_object_id(instance_url, &new_uuid());
+    let collection_id = collection.of(&actor_id);
+    AddPerson {
+        context: AP_CONTEXT.to_string(),
+        id: activity_id,
+        activity_type: ADD.to_string(),
+        actor: actor_id,
+        object: person_id.to_string(),
+        target: collection_id,
+        to: vec![person_id.to_string()],
+    }
+}
+
+pub fn prepare_add_person(
+    instance: &Instance,
+    sender: &User,
+    person: &Actor,
+    collection: LocalActorCollection,
+) -> OutgoingActivity<AddPerson> {
+    let activity = build_add_person(
+        &instance.url(),
+        &sender.profile.username,
+        &person.id,
+        collection,
+    );
+    let recipients = vec![person.clone()];
+    OutgoingActivity {
+        instance: instance.clone(),
+        sender: sender.clone(),
+        activity,
+        recipients,
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    const INSTANCE_URL: &str = "https://example.com";
+
+    #[test]
+    fn test_build_add_person() {
+        let sender_username = "local";
+        let person_id = "https://test.remote/actor/test";
+        let collection = LocalActorCollection::Subscribers;
+        let activity = build_add_person(
+            INSTANCE_URL,
+            sender_username,
+            person_id,
+            collection,
+        );
+
+        assert_eq!(activity.activity_type, "Add");
+        assert_eq!(
+            activity.actor,
+            format!("{}/users/{}", INSTANCE_URL, sender_username),
+        );
+        assert_eq!(activity.object, person_id);
+        assert_eq!(
+            activity.target,
+            format!("{}/users/{}/subscribers", INSTANCE_URL, sender_username),
+        );
+        assert_eq!(activity.to[0], person_id);
+    }
+}

src/activitypub/builders/mod.rs

@@ -1,4 +1,5 @@
 pub mod accept_follow;
+pub mod add_person;
 pub mod announce_note;
 pub mod create_note;
 pub mod delete_note;

src/activitypub/vocabulary.rs

@@ -2,6 +2,7 @@
 
 // Activity types
 pub const ACCEPT: &str = "Accept";
+pub const ADD: &str = "Add";
 pub const ANNOUNCE: &str = "Announce";
 pub const CREATE: &str = "Create";
 pub const DELETE: &str = "Delete";

src/config.rs

@@ -194,6 +194,7 @@ impl Config {
     }
 }
 
+#[derive(Clone)]
 pub struct Instance {
     _url: Url,
     _version: String,