arete-sdk 0.1.6

The Project Arete SDK for smart buildings
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

use super::{Client, Consumer, DEFAULT_TIMEOUT_SECS, Error, Node, Provider};
use crate::client::Format;
use std::sync::Arc;
use std::time::Duration;

#[derive(Clone)]
pub struct Context {
    client: Client,
    pub(crate) node: Node,
    pub id: String,
}

impl Context {
    pub(crate) fn new(client: Client, node: Node, id: String) -> Context {
        Self { client, node, id }
    }

    pub fn consumer(&self, profile: &str) -> Result<Arc<Consumer>, Error> {
        let args = vec![
            self.node.system.id.to_string(),
            self.node.id.clone(),
            self.id.to_string(),
            profile.to_string(),
        ];
        let mut client = self.client.clone();
        let transaction = client.send(Format::Json, "consumers", &args)?;
        let _res = client.wait_for_response(transaction, Duration::from_secs(DEFAULT_TIMEOUT_SECS))?;
        Ok(Arc::new(Consumer::new(client, self.clone(), profile.to_string())))
    }

    pub fn provider(&self, profile: &str) -> Result<Arc<Provider>, Error> {
        let args = vec![
            self.node.system.id.to_string(),
            self.node.id.clone(),
            self.id.to_string(),
            profile.to_string(),
        ];
        let mut client = self.client.clone();
        let transaction = client.send(Format::Json, "providers", &args)?;
        let _res = client.wait_for_response(transaction, Duration::from_secs(DEFAULT_TIMEOUT_SECS))?;
        Ok(Arc::new(Provider::new(client, self.clone(), profile.to_string())))
    }
}