async-opcua-server 0.18.0

OPC UA server API
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

use crate::node_manager::{
    view::{ExternalReferenceRequest, NodeMetadata},
    NodeManagerCollection, RequestContext,
};
use hashbrown::HashMap;
use opcua_types::{BrowseDescriptionResultMask, NamespaceMap, NodeId};

/// Fetch external references by requesting them from their owning node manager.
///
/// This calls `resolve_external_references` on each node manager with the ids
/// in `ids` that they return `true` on `owns_node` for.
pub async fn get_node_metadata(
    context: &RequestContext,
    node_managers: &impl NodeManagerCollection,
    ids: &[NodeId],
) -> Vec<Option<NodeMetadata>> {
    let mut reqs: Vec<_> = ids
        .iter()
        .map(|n| ExternalReferenceRequest::new(n, BrowseDescriptionResultMask::all()))
        .collect();
    for mgr in node_managers.iter_node_managers() {
        let mut owned: Vec<_> = reqs
            .iter_mut()
            .filter(|n| mgr.owns_node(n.node_id()))
            .collect();

        mgr.resolve_external_references(context, &mut owned).await;
    }

    reqs.into_iter().map(|r| r.into_inner()).collect()
}

/// Get the namespaces visible to the current user by calling `namespaces_for_user`
/// on each node manager.
pub fn get_namespaces_for_user(
    context: &RequestContext,
    node_managers: &impl NodeManagerCollection,
) -> NamespaceMap {
    let nss: HashMap<_, _> = node_managers
        .iter_node_managers()
        .flat_map(|n| n.namespaces_for_user(context))
        .map(|ns| (ns.namespace_uri, ns.namespace_index))
        .collect();

    NamespaceMap::new_full(nss)
}