openleadr-client 0.1.2

OpenADR 3.0 client
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

use openleadr_client::ClientCredentials;
use openleadr_wire::program::ProgramContent;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let reqwest_client = reqwest::Client::new();
    let client = openleadr_client::Client::with_details(
        "http://localhost:3000/".try_into()?,
        "http://localhost:8080/token".try_into()?,
        reqwest_client,
        Some(ClientCredentials::new(
            "admin".to_string(),
            "admin".to_string(),
        )),
    );

    let _created_program = client.create_program(ProgramContent::new("name")).await?;
    // let created_program_1 = client.create_program(ProgramContent::new("name1")).await?;
    // let program = client.get_program_by_name("name").await?;
    // let created_event = program
    //     .create_event(program.new_event().with_event_name("prices3").with_priority(0))
    //     .await?;
    // let events = program.get_event_list(Filter::none()).await?;
    // let reports = events[0].get_all_reports().await?;
    // let event = program.get_event(Target::Event("prices3")).await?;
    // dbg!(events);
    // dbg!(reports);

    // let programs: Vec<Program> = client.get_all_programs()?;
    // let programs = client.get_programs(TargetLabel::ProgramName, &["name"])?;

    // let program = client.get_program_by_id("id").await?;

    // let evt = program.send_event(Event {

    // })?;

    // let events = program.get_events(TargetLabel::EventName, &["name"], 0, 10)?;

    // program.get_event_by_name("prices").await?;

    // let events = program.get_all_events().await?;

    // // find the event you want, each event contains all relevant information to reconstruct periods
    // let event = events[0];

    // for interval in event.intervals {
    //     for payload in interval.payloads { // Iterator<Item = Payload
    //         // do something with the payload
    //         payload.timestamp;
    //         payload.unit;
    //         payload.currency;
    //         payload.value::<T = f64>();
    //     }
    // }

    // send a report
    // event.send_report(Report {

    // }).await?;

    // program.on_event(|evt| {

    // })?;

    Ok(())
}