motorcortex-rust 0.5.0

Motorcortex Rust: a Rust client for the Motorcortex Core real-time control system (async + blocking).
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
68
69
70
71
72
73
74
75
76
77
78

//! Session-token RPCs: fetch a fresh token, restore a session from
//! it, check the driver's cache gets populated.

use motorcortex_rust::core::Request;
use motorcortex_rust::{ConnectionOptions, StatusCode};

use crate::{CERT_PATH, URL_REQ};

fn opts() -> ConnectionOptions {
    ConnectionOptions::new(CERT_PATH.to_string(), 5000, 5000)
}

#[tokio::test]
async fn test_get_session_token_returns_non_empty_string() {
    let req = Request::connect_to(URL_REQ, opts())
        .await
        .expect("connect");
    req.login("root", "vectioneer").await.expect("login");

    assert!(req.session_token().is_none(), "fresh handle has no token");

    let token = req
        .get_session_token()
        .await
        .expect("get_session_token must succeed against the test server");
    assert!(
        !token.is_empty(),
        "server should return a non-empty token, got {token:?}"
    );
    assert_eq!(
        req.session_token().as_deref(),
        Some(token.as_str()),
        "driver's cached token must match the one returned",
    );

    req.disconnect().await.expect("disconnect");
}

#[tokio::test]
async fn test_restore_session_with_valid_token_succeeds() {
    // Fetch a token on one handle, restore it on the same handle —
    // no drop in between, so the server still recognises the session.
    let req = Request::connect_to(URL_REQ, opts())
        .await
        .expect("connect");
    req.login("root", "vectioneer").await.expect("login");

    let token = req.get_session_token().await.expect("get_session_token");
    let status = req
        .restore_session(&token)
        .await
        .expect("restore_session RPC completes");
    assert!(
        matches!(status, StatusCode::Ok | StatusCode::ReadOnlyMode),
        "expected Ok / ReadOnlyMode, got {status:?}"
    );

    req.disconnect().await.expect("disconnect");
}

#[tokio::test]
async fn test_session_token_cleared_on_disconnect() {
    let req = Request::connect_to(URL_REQ, opts())
        .await
        .expect("connect");
    req.login("root", "vectioneer").await.expect("login");
    let _ = req
        .get_session_token()
        .await
        .expect("get_session_token");
    assert!(req.session_token().is_some());

    req.disconnect().await.expect("disconnect");
    assert!(
        req.session_token().is_none(),
        "disconnect must clear the token cache"
    );
}