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
|
use std::collections::BTreeMap;
use failure::Error;
use crate::types::util::IPFSHash;
use crate::types::util::MimeType;
use crate::types::util::IPNSHash;
use crate::types::block::Block;
use crate::repository::repository::Repository;
use crate::types::content::Content;
use crate::types::content::Payload;
use crate::types::util::Timestamp;
use crate::version::protocol_version;
pub struct App {
repo: Repository,
device_name: IPNSHash,
publishing_key: String
}
impl App {
pub fn load(device_name: IPNSHash, publishing_key: String, host: &str, port: u16) -> Result<Self, Error> {
Repository::new(host, port).map(|repo| App { repo, device_name, publishing_key })
}
pub async fn new_profile(repo: Repository, publishing_key: &str, names: Vec<String>) -> Result<Self, Error> {
let payload = Payload::Profile {
names,
picture: None,
more: BTreeMap::new(),
};
let timestamp = Timestamp::now();
let content = Content::new(vec![], Some(timestamp), payload);
let content_hash = repo.put_content(content).await?;
let head = repo.put_block(Block::new(protocol_version(), vec![], content_hash)).await?;
let device_name = repo.publish(&publishing_key, &head).await?;
Ok(App { repo, device_name, publishing_key: publishing_key.to_string() })
}
pub async fn new_post(&self,
content: Vec<u8>,
mime: MimeType,
reply_to: Option<IPFSHash>,
comments_will_be_propagated: Option<bool>,
comments_propagated_until: Option<Timestamp>)
-> Result<(), Error>
{
let content_hash = self.repo.put_raw_bytes(content).await?;
let payload = Payload::Post {
content_format: mime,
content: content_hash,
reply_to,
comments_will_be_propagated,
comments_propagated_until,
};
let timestamp = Timestamp::now();
let content = Content::new(vec![], Some(timestamp), payload);
let content_hash = self.repo.put_content(content).await?;
let head = self.repo.put_block(Block::new(protocol_version(), vec![], content_hash)).await?;
let device_name = self.repo.publish(&self.publishing_key, &head).await?;
Ok(())
}
}
|
