zbus_module 0.1.0

Zabbix loadable module for accessing data on ZBUS telemetry bus
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
79

extern crate log;
use libc::{c_char};
use std::ffi::{CString, CStr};

use crate::zbus_zenoh;

fn get_value_v2(data: &serde_json::Value) -> Option<serde_json::Value> {
    match data.get("body") {
        Some(body) => {
            match body.get("details") {
                Some(details1) => {
                    match details1.get("details") {
                        Some(details) => {
                            match details.get("data") {
                                Some(data) => { return Some(data.clone()); }
                                None => { return None; }
                            }
                        }
                        None => { return None; }
                    }
                }
                None => { return None; }
            }
        }
        None => { return None; }
    }
}

#[no_mangle]
pub unsafe extern fn free_string(ptr: *const c_char) {
    let _ = CString::from_raw(ptr as *mut _);
}

#[no_mangle]
pub extern fn zbus_module_get_str(key: *const c_char) -> *const c_char {
    match unsafe { CStr::from_ptr(key).to_str() } {
        Ok(zbus_key) => {
            match zbus_zenoh::get(zbus_key.to_string()) {
                Some(res) => {
                    match get_value_v2(&res) {
                        Some(value) => {
                            return CString::new(value.to_string()).expect("Expecting a value").into_raw();
                        }
                        None => {
                            return std::ptr::null();
                        }
                    }
                }
                None => {
                    return std::ptr::null();
                }
            }
        }
        Err(err) => {
            log::error!("Error converting key: {:?}", err);
            return std::ptr::null();
        }
    }
}

#[no_mangle]
pub extern fn zbus_module_get_raw(key: *const c_char) -> *const c_char {
    match unsafe { CStr::from_ptr(key).to_str() } {
        Ok(zbus_key) => {
            match zbus_zenoh::get(zbus_key.to_string()) {
                Some(res) => {
                    return CString::new(res.to_string()).expect("Expecting a value").into_raw();
                }
                None => {
                    return std::ptr::null();
                }
            }
        }
        Err(err) => {
            log::error!("Error converting key: {:?}", err);
            return std::ptr::null();
        }
    }
}