async_request/
async_request.rs

1//! Minimal async `Request` round-trip. Connect, login, fetch one
2//! parameter value, disconnect.
3//!
4//! ```bash
5//! cargo run --example async_request -- \
6//!     wss://127.0.0.1:5568:5567 path/to/mcx.cert.crt root mypassword root/Control/dummyDouble
7//! ```
8
9use std::env;
10
11use motorcortex_rust::core::Request;
12use motorcortex_rust::{ConnectionOptions, Result, parse_url};
13
14#[tokio::main]
15async fn main() -> Result<()> {
16    let mut args = env::args().skip(1);
17    let url = args.next().unwrap_or_else(|| "wss://127.0.0.1:5568:5567".into());
18    let cert = args.next().unwrap_or_else(|| "tests/mcx.cert.crt".into());
19    let user = args.next().unwrap_or_else(|| "root".into());
20    let pass = args.next().unwrap_or_default();
21    let path = args
22        .next()
23        .unwrap_or_else(|| "root/Control/dummyDouble".into());
24
25    let (req_url, _sub_url) = parse_url(&url)?;
26    let opts = ConnectionOptions::new(cert, 5_000, 5_000);
27    let req = Request::connect_to(&req_url, opts).await?;
28    req.login(&user, &pass).await?;
29    req.request_parameter_tree().await?;
30
31    let value: f64 = req.get_parameter(&path).await?;
32    println!("{path} = {value}");
33
34    req.disconnect().await?;
35    Ok(())
36}
async_request/async_request.rs

async_request/
async_request.rs
