rsolace 0.3.9

Solace bindings for the Rust
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

use super::types::SolClientSessionEvent;
use snafu::prelude::{ensure, Snafu};
use snafu::ResultExt;
use std::ffi::CStr;

#[derive(Debug, Clone)]
pub struct SolEvent {
    pub session_event: SolClientSessionEvent,
    pub response_code: u32,
    pub info: String,
    // correlation: String,
}

#[derive(Debug, Snafu)]
pub enum SolEventError {
    #[snafu(display("Null event pointer"))]
    NullEventPtr,
    #[snafu(display("Null info pointer"))]
    NullInfoPtr,
    #[snafu(display("Info UTF-8 error"))]
    InfoUtf8 { source: std::str::Utf8Error },
}

impl SolEvent {
    pub fn new(session_event: SolClientSessionEvent, response_code: u32, info: &str) -> SolEvent {
        SolEvent {
            session_event,
            response_code,
            info: info.to_string(),
        }
    }

    /// # Safety
    /// 呼叫端需確保 `event_p` 來源生命週期有效。
    pub unsafe fn from_ptr(
        event_p: rsolace_sys::solClient_session_eventCallbackInfo_pt,
    ) -> Result<SolEvent, SolEventError> {
        ensure!(!event_p.is_null(), NullEventPtrSnafu);
        let event = *event_p;

        ensure!(!event.info_p.is_null(), NullInfoPtrSnafu);
        let info = CStr::from_ptr(event.info_p)
            .to_str()
            .context(InfoUtf8Snafu)?
            .to_owned();

        Ok(SolEvent {
            session_event: event.sessionEvent.into(),
            response_code: event.responseCode,
            info,
        })
    }

    pub fn get_session_event_string(&self) -> String {
        unsafe {
            let res = rsolace_sys::solClient_session_eventToString(
                self.session_event as rsolace_sys::solClient_session_event_t,
            );
            CStr::from_ptr(res).to_str().unwrap().to_owned()
        }
    }
}