mqi 0.3.0

Idiomatic IBM® MQ Interface (MQI) and MQ Administration Interface (MQAI) APIs
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
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
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141

use crate::{
    constants,
    result::{Completion, Error, ResultCompErr},
    types::{MQCC, MQRC},
};

#[derive(Clone, derive_more::Deref, derive_more::DerefMut)]
pub struct MqiOutcome<T> {
    /// MQI verb that caused the failure
    pub verb: &'static str,
    /// Completion code of the MQI function call
    pub cc: MQCC,
    /// Reason code of the MQI function call
    pub rc: MQRC,
    /// Return value of the MQI function call
    #[deref]
    #[deref_mut]
    pub value: T,
}

impl<T: Default> Default for MqiOutcome<T> {
    fn default() -> Self {
        Self {
            verb: Default::default(),
            cc: constants::MQCC_UNKNOWN,
            rc: constants::MQRC_NONE,
            value: Default::default(),
        }
    }
}

pub type MqiOutcomeVoid = MqiOutcome<()>;

impl<T: Default> MqiOutcome<T> {
    #[must_use]
    pub fn with_verb(verb: &'static str) -> Self {
        Self { verb, ..Self::default() }
    }
}
impl<T> MqiOutcome<T> {
    #[must_use]
    pub const fn new(verb: &'static str, value: T) -> Self {
        Self {
            verb,
            value,
            rc: constants::MQRC_NONE,
            cc: constants::MQCC_UNKNOWN,
        }
    }
}

impl<T, E: From<Error>> From<MqiOutcome<T>> for ResultCompErr<T, E> {
    fn from(outcome: MqiOutcome<T>) -> Self {
        let MqiOutcome { cc, rc, value, verb } = outcome;
        match cc {
            constants::MQCC_OK => Ok(Completion::new(value)),
            constants::MQCC_WARNING => Ok(Completion::new_warning(value, (rc, verb))),
            _ => Err(Error(cc, verb, rc).into()),
        }
    }
}

impl<T, E: From<Error>> From<MqiOutcome<T>> for Result<T, E> {
    fn from(outcome: MqiOutcome<T>) -> Self {
        let MqiOutcome { cc, rc, value, verb } = outcome;
        match cc {
            constants::MQCC_OK => Ok(value),
            _ => Err(Error(cc, verb, rc).into()),
        }
    }
}

/// Traces the MQI outcome
#[cfg(feature = "tracing")]
pub fn tracing_outcome<T: std::fmt::Debug>(outcome: &MqiOutcome<T>) {
    use libmqm_constants::lookup::HasMqNames as _;

    let MqiOutcome { verb, cc, rc, value } = outcome;
    match *cc {
        constants::MQCC_OK => tracing::event!(
            tracing::Level::DEBUG,
            value = ?value,
            cc_name = cc.mq_primary_name(),
            cc = cc.0,
            rc_name = rc.mq_primary_name(),
            rc = rc.0,
            verb
        ),
        constants::MQCC_WARNING => tracing::event!(
            tracing::Level::WARN,
            value = ?value,
            cc_name = cc.mq_primary_name(),
            cc = cc.0,
            rc_name = rc.mq_primary_name(),
            rc = rc.0,
            verb
        ),
        _ => tracing::event!(
            tracing::Level::ERROR,
            cc_name = cc.mq_primary_name(),
            cc = cc.0,
            rc_name = rc.mq_primary_name(),
            rc = rc.0,
            verb
        ),
    }
}

/// Traces the MQI outcome without the value
#[cfg(feature = "tracing")]
pub fn tracing_outcome_basic<T>(outcome: &MqiOutcome<T>) {
    use libmqm_constants::lookup::HasMqNames as _;

    let MqiOutcome { verb, cc, rc, .. } = outcome;
    match *cc {
        constants::MQCC_OK => tracing::event!(
            tracing::Level::DEBUG,
            cc_name = cc.mq_primary_name(),
            cc = cc.0,
            rc_name = rc.mq_primary_name(),
            rc = rc.0,
            verb
        ),
        constants::MQCC_WARNING => tracing::event!(
            tracing::Level::WARN,
            cc_name = cc.mq_primary_name(),
            cc = cc.0,
            rc_name = rc.mq_primary_name(),
            rc = rc.0,
            verb
        ),
        _ => tracing::event!(
            tracing::Level::ERROR,
            cc_name = cc.mq_primary_name(),
            cc = cc.0,
            rc_name = rc.mq_primary_name(),
            rc = rc.0,
            verb
        ),
    }
}