shvbroker 3.20.12

Rust implementation of the SHV broker
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

pub mod config;
pub mod shvnode;
pub mod brokerimpl;
mod peer;
mod tunnelnode;
mod serial;
pub mod sql;

#[cfg(test)]
mod test;

pub mod spawn {
    use log::error;
    use std::future::Future;

    pub fn spawn_and_log_error<F>(fut: F)
    where
        F: Future<Output = shvrpc::Result<()>> + Send + 'static,
    {
        smol::spawn(async move {
            if let Err(e) = fut.await {
                error!("Task finished with error: {e}")
            }
        }).detach();
    }
}

fn cut_prefix(shv_path: &str, prefix: &str) -> Option<String> {
    if shv_path.starts_with(prefix) && (shv_path.len() == prefix.len() || shv_path[prefix.len() ..].starts_with('/')) {
        let shv_path = &shv_path[prefix.len() ..];
        shv_path.strip_prefix('/')
            .or(Some(shv_path))
            .map(ToString::to_string)
    } else {
        None
    }
}