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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79

//! ActivityPub [Collections](https://www.w3.org/TR/activitystreams-core/#collection)
use serde::{Deserialize, Serialize};
use crate::activitypub::objects::activities::create::CreateActivity;
use crate::activitypub::{ApUrl, AtContext, Context};

#[derive(Debug, Serialize, Deserialize)]
pub enum OrderedCollectionType {
    OrderedCollection,
}

#[derive(Debug, Serialize, Deserialize)]
#[serde(untagged)]
pub enum PageOrLink {
    Link(String),
    Page(OrderedCollectionPage),
}

#[derive(Debug, Serialize, Deserialize)]
pub struct OrderedCollectionPage {
    #[serde(rename = "@context")]
    pub context: AtContext,
    pub next: Option<Box<PageOrLink>>,
    pub prev: Option<Box<PageOrLink>>,
    #[serde(rename = "orderedItems")]
    pub ordered_items: Vec<CreateActivity>,
}
pub type OutboxPage = OrderedCollectionPage;


#[derive(Debug, Serialize, Deserialize)]
pub struct OrderedCollection<T: Serialize> {
    #[serde(rename = "@context")]
    pub context: AtContext,
    #[serde(rename = "type")]
    _type: OrderedCollectionType,
    pub id: String,
    #[serde(rename = "totalItems")]
    pub total_items: u64,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub first: Option<PageOrLink>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub last: Option<PageOrLink>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub current: Option<PageOrLink>, // This is theoretically mandatory
    #[serde(skip_serializing_if = "Option::is_none")]
    pub items: Option<Vec<T>>,
}

impl<T: Serialize> OrderedCollection<T> {
    pub fn new(id: ApUrl, first_page: ApUrl, last_page: ApUrl, total_items: u64) -> OrderedCollection<T> {
        let first_page = PageOrLink::Link(first_page);
        let last_page = PageOrLink::Link(last_page);
        OrderedCollection {
            context: AtContext::Context(Context::ActivityStreams),
            id,
            _type: OrderedCollectionType::OrderedCollection,
            total_items,
            items: None,
            first: Some(first_page),
            last: Some(last_page),
            current: None,
        }
    }

    pub fn new_from_list(id: ApUrl, items: Vec<T>) -> OrderedCollection<T> {
        let total_items = items.len() as u64;
        OrderedCollection {
            context: AtContext::Context(Context::ActivityStreams),
            id,
            _type: OrderedCollectionType::OrderedCollection,
            total_items,
            items: Some(items),
            first: None,
            last: None,
            current: None,
        }
    }
}