viva-service 0.2.3

Zenoh bridge exposing GenICam cameras as network-accessible services
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

//! XML queryable: responds with the device's GenICam XML.

use std::sync::Arc;

use tokio::sync::watch;
use tracing::{debug, info, warn};
use viva_zenoh_api::{DeviceXmlResponse, keys};
use zenoh::Session;

/// Declare a queryable for the device XML endpoint.
pub async fn run(
    session: Arc<Session>,
    device_id: String,
    xml: String,
    mut shutdown: watch::Receiver<bool>,
) {
    let key = keys::xml(&device_id);
    let queryable = match session.declare_queryable(&key).await {
        Ok(q) => q,
        Err(e) => {
            warn!(device_id, error = %e, "failed to declare XML queryable");
            return;
        }
    };
    info!(device_id, key, "XML queryable ready");

    let response = DeviceXmlResponse { xml };

    loop {
        tokio::select! {
            query = queryable.recv_async() => {
                match query {
                    Ok(query) => {
                        debug!(device_id, "XML query received");
                        let Ok(payload) = serde_json::to_vec(&response) else {
                            tracing::error!("failed to serialize XML response");
                            continue;
                        };
                        if let Err(e) = query.reply(&key, payload).await {
                            warn!(device_id, error = %e, "failed to reply to XML query");
                        }
                    }
                    Err(e) => {
                        warn!(device_id, error = %e, "XML queryable channel closed");
                        break;
                    }
                }
            }
            _ = shutdown.changed() => {
                if *shutdown.borrow() {
                    break;
                }
            }
        }
    }
}