xbbg-async 1.4.9

Async worker-pool engine over xbbg_core for Bloomberg API requests and subscriptions
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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120

use std::ffi::CStr;
use std::sync::Once;

static INIT: Once = Once::new();

fn severity_name(severity: i32) -> &'static str {
    match severity {
        1 => "FATAL",
        2 => "ERROR",
        3 => "WARN",
        4 => "INFO",
        5 => "DEBUG",
        6 => "TRACE",
        _ => "UNKNOWN",
    }
}

unsafe extern "C" fn sdk_callback(
    _thread_id: u64,
    severity: i32,
    _timestamp: xbbg_core::ffi::blpapi_Logging_Datetime_t,
    category: *const std::ffi::c_char,
    message: *const std::ffi::c_char,
) {
    let cat = if category.is_null() {
        "sdk"
    } else {
        CStr::from_ptr(category).to_str().unwrap_or("sdk")
    };
    let msg = if message.is_null() {
        ""
    } else {
        CStr::from_ptr(message).to_str().unwrap_or("")
    };

    match severity {
        1 => {
            xbbg_log::error!(target: "xbbg.sdk", category = cat, "[{}] {}", severity_name(severity), msg)
        }
        2 => {
            xbbg_log::error!(target: "xbbg.sdk", category = cat, "[{}] {}", severity_name(severity), msg)
        }
        3 => {
            xbbg_log::warn!(target: "xbbg.sdk", category = cat, "[{}] {}", severity_name(severity), msg)
        }
        4 => {
            xbbg_log::info!(target: "xbbg.sdk", category = cat, "[{}] {}", severity_name(severity), msg)
        }
        5 => {
            xbbg_log::debug!(target: "xbbg.sdk", category = cat, "[{}] {}", severity_name(severity), msg)
        }
        _ => {
            xbbg_log::trace!(target: "xbbg.sdk", category = cat, "[{}] {}", severity_name(severity), msg)
        }
    }
}

#[derive(Clone, Copy, Debug, PartialEq, Eq)]
pub enum SdkLogLevel {
    Off,
    Fatal,
    Error,
    Warn,
    Info,
    Debug,
    Trace,
}

impl SdkLogLevel {
    fn to_raw(self) -> i32 {
        match self {
            Self::Off => 0,
            Self::Fatal => 1,
            Self::Error => 2,
            Self::Warn => 3,
            Self::Info => 4,
            Self::Debug => 5,
            Self::Trace => 6,
        }
    }
}

impl std::str::FromStr for SdkLogLevel {
    type Err = String;

    fn from_str(s: &str) -> Result<Self, Self::Err> {
        match s.to_ascii_lowercase().as_str() {
            "off" => Ok(Self::Off),
            "fatal" => Ok(Self::Fatal),
            "error" => Ok(Self::Error),
            "warn" | "warning" => Ok(Self::Warn),
            "info" => Ok(Self::Info),
            "debug" => Ok(Self::Debug),
            "trace" => Ok(Self::Trace),
            _ => Err(format!(
                "invalid SDK log level: {s} (expected off/fatal/error/warn/info/debug/trace)"
            )),
        }
    }
}

pub fn register_sdk_logging(level: SdkLogLevel) {
    if level == SdkLogLevel::Off {
        return;
    }

    INIT.call_once(|| {
        let rc = unsafe {
            xbbg_core::ffi::blpapi_Logging_registerCallback(
                Some(sdk_callback),
                level.to_raw() as xbbg_core::ffi::blpapi_Logging_Severity_t,
            )
        };
        if rc != 0 {
            xbbg_log::warn!("failed to register Bloomberg SDK logging callback: rc={rc}");
        } else {
            xbbg_log::info!(level = ?level, "Bloomberg SDK logging callback registered");
        }
    });
}