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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
|
/**
* High level stream API for ZotApi.
*
* The stream API will parse the raw json response from a stream (network
* or channel stream) into proper types, that should be easier to use from
* a client application.
*
* SPDX-FileCopyrightText: 2023 Eilertsens Kodeknekkeri
* SPDX-FileCopyrightText: 2023 Harald Eilertsen <haraldei@anduin.net>
*
* SPDX-License-Identifier: AGPL-3.0-or-later
*/
mod streamitem;
mod verb;
pub use streamitem::{
StreamItem,
StreamItemEncoding,
StreamItemType,
};
pub use verb::Verb;
use std::{
error::Error,
result::Result
};
#[derive(Debug, PartialEq)]
pub struct Stream {
pub items: Vec<StreamItem>,
}
impl Stream {
pub fn from_json(json: &str) -> Result<Self, Box<dyn Error + 'static>> {
let items: Vec<StreamItem> = serde_json::from_str(&json)?;
Ok(Self { items })
}
}
#[cfg(test)]
mod test {
use super::*;
#[test]
fn construct_stream_from_empty_string_should_fail() {
let s = Stream::from_json("");
assert!(s.is_err());
}
#[test]
fn construct_stream_from_empty_json() {
let s = Stream::from_json("[]");
assert!(s.is_ok());
}
#[test]
fn construct_stream_from_json_with_one_activity() {
let json = r#"[
{
"type": "activity",
"encoding": "zot",
"uuid": "2c102ec3-676b-4d84-b2b4-9141467a254f",
"message_id": "https://example.com/item/2c102ec3-676b-4d84-b2b4-9141467a254f",
"message_top": "https://example.com/item/2c102ec3-676b-4d84-b2b4-9141467a254f",
"message_parent": "https://example.com/item/2c102ec3-676b-4d84-b2b4-9141467a254f",
"created": "2023-12-12 17:00:42",
"edited": "2023-12-12 17:00:42",
"expires": "0000-00-00 00:00:00",
"commented": "2023-12-19 09:01:15",
"mimetype": "text/bbcode",
"title": "The item title",
"summary": "The summary of the post",
"body": "The body of the post",
"app": "",
"verb": "http://activitystrea.ms/schema/1.0/post",
"object_type": "http://activitystrea.ms/schema/1.0/note",
"target_type": "",
"permalink": "https://example.com/item/2c102ec3-676b-4d84-b2b4-9141467a254f",
"location": "",
"longlat": "",
"signature": "sha256.ADzsjr5uFUpcwVkUT9liHimr1n2TJmGpTtm0SGSody_6vTbfYhHK3OJJhGknImHYwMradSwVcA9dNAAXzhSoAY5hCmSbnThLun30HVIA3E0ZSDBbt1RyKNomqBCvCBmyyFKhxYoPk34UQisCH6gIQ3eZL-m5PxE9t2oMO_CnpPvLWESoezY3CAZaEIIRj3KKozwC8DxibQmsnCeA32C-2Ejzv8PdZCX1skbIdc5d8Jj_ykyUTqc2DZKMSl9osua3esEMwYZLbxlRQruDfgyjJExdvz57zpeqf1WKzqdIZ5kmguZxch6NLVMiRitooT-sIZOvo9JzgP1ogBQW34W-kG1hHzuGJQkDZKOAA1rLD8qrfwugbbg9wDpjtZY-WHv265KMMsFhctIIupNPVVkuSgs0jMKQmjJTeDE0IxBKx2dCsxiqMWlJll_LSu7b6BtTa7jcuhfMPaKqdMOCRRnGNwehj6qeOXPV7zEZsc4Mzym6N_jRTV556OmUwaCHouEFqTG1ARE5EquYTMk2wXIteC5lT2d0WpEGTnlL1WpqWLx9DCp76Z2JsxMBxjZicKvJSm1gX3ng2ENG2cvECww0IF_zPy2DmHcWOqm795-11uLBNt_60bpP9-sgjrNSj0q6MHgAsFGnpW42M4sFe-6gb-W-HjyHwY2B2yjErYC9KDo",
"route": "",
"owner": {
"name": "Benjamin Franklin",
"address": "ben@example.com",
"url": "https://example.com/channel/ben",
"network": "zot6",
"photo": {
"mimetype": "image/jpeg",
"src": "https://example.com/photo/profile/m/2"
},
"id": "rUpgk2qbvnWLoKIXOlZlwlqI5vk8C4NgudFNjbcmnOBjFSXU34TObkZEClaPSfKnpFZpg87tANtko7WGs7QRvA",
"id_sig": "sha256.ZD8uwYmUEG_d02Y...",
"key": "-----BEGIN PUBLIC KEY-----\n....\n-----END PUBLIC KEY-----\n"
},
"author": {
"name": "Benjamin Franklin",
"address": "ben@example.com",
"url": "https://example.com/channel/ben",
"network": "zot6",
"photo": {
"mimetype": "image/jpeg",
"src": "https://example.com/photo/profile/m/2"
},
"id": "rUpgk2qbvnWLoKIXOlZlwlqI5vk8C4NgudFNjbcmnOBjFSXU34TObkZEClaPSfKnpFZpg87tANtko7WGs7QRvA",
"id_sig": "sha256.ZD8uwYmUEG_d02Y...",
"key": "-----BEGIN PUBLIC KEY-----\n....\n-----END PUBLIC KEY-----\n"
},
"flags": [
"thread_parent"
],
"public_scope": "",
"comment_scope": "authenticated",
"tags": [
{
"tag": "a-tag",
"url": "https://example.com/search?tag=a-tag",
"type": "hashtag"
},
{
"tag": "fediverse",
"url": "https://example.com/search?tag=fediverse",
"type": "hashtag"
},
{
"tag": "hubzilla",
"url": "https://example.com/search?tag=hubzilla",
"type": "hashtag"
}
]
}]"#;
let s = Stream::from_json(&json).unwrap();
assert_eq!(1, s.items.len());
let item = &s.items[0];
assert_eq!(StreamItemType::Activity, item.item_type);
assert_eq!(StreamItemEncoding::Zot, item.encoding);
assert_eq!(Verb::Post, item.verb);
assert_eq!("The item title", &item.title);
assert_eq!("The summary of the post", &item.summary);
assert_eq!("The body of the post", &item.body);
}
}
|
