colink 0.3.10

CoLink Rust SDK
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

use crate::colink_proto::*;
pub use colink_registry_proto::{Registries, Registry, UserRecord};
use prost::Message;
mod colink_registry_proto {
    include!(concat!(env!("OUT_DIR"), "/colink_registry.rs"));
}

type Error = Box<dyn std::error::Error + Send + Sync + 'static>;

impl crate::application::CoLink {
    pub async fn update_registries(&self, registries: &Registries) -> Result<(), Error> {
        let participants = vec![Participant {
            user_id: self.get_user_id()?,
            role: "update_registries".to_string(),
        }];
        let mut payload = vec![];
        registries.encode(&mut payload).unwrap();
        let task_id = self
            .run_task("registry", &payload, &participants, false)
            .await?;
        self.wait_task(&task_id).await?;
        Ok(())
    }

    pub async fn set_forwarding_user_id(&self, forwarding_user_id: &str) -> Result<(), Error> {
        self.update_entry(
            "_registry:forwarding_user_id",
            forwarding_user_id.as_bytes(),
        )
        .await?;
        let _ = async {
            let registries = self.read_entry("_registry:registries").await?;
            let registries: Registries = Message::decode(&*registries)?;
            self.update_registries(&registries).await?;
            Ok::<(), Box<dyn std::error::Error + Send + Sync + 'static>>(())
        }
        .await;
        Ok(())
    }

    pub async fn unset_forwarding_user_id(&self) -> Result<(), Error> {
        self.delete_entry("_registry:forwarding_user_id").await?;
        let _ = async {
            let registries = self.read_entry("_registry:registries").await?;
            let registries: Registries = Message::decode(&*registries)?;
            self.update_registries(&registries).await?;
            Ok::<(), Box<dyn std::error::Error + Send + Sync + 'static>>(())
        }
        .await;
        Ok(())
    }
}