coreemu 0.1.5

Rust client library for gRPC interface of coreemu https://github.com/coreemu/core
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

use std::env;

use coreemu::{core::Node, Client};

fn print_pos(node: Node) {
    let pos = node.position.unwrap();
    println!("{}={},{},{}", node.name, pos.x, pos.y, pos.z);
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let remote = env::var("REMOTE_CORE").unwrap_or_else(|_| "http://127.0.0.1:50051".into());
    let mut client = Client::connect(remote).await?;

    let response = client.get_sessions().await?;

    if response.is_empty() {
        eprintln!("No sessions found");
        return Ok(());
    }
    let session_id = response[0].id;

    // getting initial positions
    let response = client.get_session(session_id).await?.unwrap();

    for n in response.nodes {
        print_pos(n);
    }

    while let Some(msg) = client
        .events(session_id, vec![coreemu::core::event_type::Enum::Node])
        .await?
        .message()
        .await?
    {
        if let Some(coreemu::core::event::EventType::NodeEvent(node_event)) = msg.event_type {
            if let Some(node) = node_event.node {
                print_pos(node);
                //println!("{:#?}", node);
            }
        }
    }
    Ok(())
}