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
use crate::message_builder::{DynamicHeader, HeaderFlags, MessageType};
use crate::params::*;
use crate::signature;
#[derive(Debug, Clone)]
pub struct Message<'a, 'e> {
pub typ: MessageType,
pub flags: u8,
pub dynheader: DynamicHeader,
pub params: Vec<Param<'a, 'e>>,
pub raw_fds: Vec<crate::wire::UnixFd>,
}
impl<'a, 'e> Default for Message<'a, 'e> {
fn default() -> Message<'a, 'e> {
Self::new()
}
}
impl<'a, 'e> Message<'a, 'e> {
pub fn new() -> Message<'a, 'e> {
Message {
dynheader: DynamicHeader::default(),
flags: 0,
raw_fds: Vec::new(),
typ: MessageType::Invalid,
params: Vec::new(),
}
}
pub fn set_interface(&mut self, interface: String) {
self.dynheader.interface = Some(interface);
}
pub fn set_member(&mut self, member: String) {
self.dynheader.member = Some(member);
}
pub fn set_object(&mut self, object: String) {
self.dynheader.object = Some(object);
}
pub fn set_destination(&mut self, dest: String) {
self.dynheader.destination = Some(dest);
}
pub fn push_params<P: Into<Param<'a, 'e>>>(&mut self, params: Vec<P>) {
self.params
.extend(params.into_iter().map(std::convert::Into::into));
}
pub fn push_param<P: Into<Param<'a, 'e>>>(&mut self, param: P) {
self.params.push(param.into());
}
#[inline]
pub fn make_response(&self) -> crate::message_builder::MarshalledMessage {
self.dynheader.make_response()
}
pub fn set_flag(&mut self, flag: HeaderFlags) {
flag.set(&mut self.flags)
}
pub fn unset_flag(&mut self, flag: HeaderFlags) {
flag.unset(&mut self.flags)
}
pub fn toggle_flag(&mut self, flag: HeaderFlags) {
flag.toggle(&mut self.flags)
}
pub fn sig(&self) -> Vec<signature::Type> {
self.params.iter().map(|p| p.sig()).collect()
}
pub fn add_param<P: Into<Param<'a, 'e>>>(&mut self, p: P) {
self.params.push(p.into());
}
pub fn add_param2<P1: Into<Param<'a, 'e>>, P2: Into<Param<'a, 'e>>>(&mut self, p1: P1, p2: P2) {
self.params.push(p1.into());
self.params.push(p2.into());
}
pub fn add_param3<P1: Into<Param<'a, 'e>>, P2: Into<Param<'a, 'e>>, P3: Into<Param<'a, 'e>>>(
&mut self,
p1: P1,
p2: P2,
p3: P3,
) {
self.params.push(p1.into());
self.params.push(p2.into());
self.params.push(p3.into());
}
}
pub type Result<T> = std::result::Result<T, crate::Error>;