azservicebus 0.25.1

An unofficial AMQP 1.0 rust client for Azure Service 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

use fe2o3_amqp_management::response::Response;
use fe2o3_amqp_types::primitives::OrderedMap;

use crate::{
    administration::{RuleDescription, RuleProperties},
    amqp::management_constants,
};

// type Rules = Vec<OrderedMap<String, Described<Value>>>;
type Rules = Vec<OrderedMap<String, RuleDescription>>;
type EnumerateRulesResponseBody = OrderedMap<String, Rules>;

pub(crate) struct EnumerateRulesResponse {
    pub body: EnumerateRulesResponseBody,
}

impl EnumerateRulesResponse {
    pub fn into_get_rules_response(mut self) -> Vec<RuleProperties> {
        let rules = self
            .body
            .swap_remove(management_constants::properties::RULES)
            .unwrap_or_else(|| Vec::with_capacity(0));

        rules
            .into_iter()
            .filter_map(|mut entry| {
                entry.swap_remove(management_constants::properties::RULE_DESCRIPTION)
            })
            .map(RuleProperties::from)
            .collect()
    }
}

impl Response for EnumerateRulesResponse {
    const STATUS_CODE: u16 = 200;

    type Body = Option<EnumerateRulesResponseBody>;

    type Error = super::ManagementError;

    fn decode_message(
        message: fe2o3_amqp_types::messaging::Message<Self::Body>,
    ) -> Result<Self, Self::Error> {
        Ok(Self {
            body: message.body.ok_or(Self::Error::DecodeError(None))?,
        })
    }
}