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
use crate::message;
use crate::message_builder::MessageBuilder;
pub fn hello<'a, 'e>() -> message::Message<'a, 'e> {
MessageBuilder::new()
.call("Hello".into())
.on("/org/freedesktop/DBus".into())
.with_interface("org.freedesktop.DBus".into())
.at("org.freedesktop.DBus".into())
.build()
}
pub fn ping<'a, 'e>(dest: String) -> message::Message<'a, 'e> {
MessageBuilder::new()
.call("Ping".into())
.on("/org/freedesktop/DBus".into())
.with_interface("org.freedesktop.DBus.Peer".into())
.at(dest)
.build()
}
pub fn ping_bus<'a, 'e>() -> message::Message<'a, 'e> {
MessageBuilder::new()
.call("Ping".into())
.on("/org/freedesktop/DBus".into())
.with_interface("org.freedesktop.DBus.Peer".into())
.build()
}
pub fn list_names<'a, 'e>() -> message::Message<'a, 'e> {
MessageBuilder::new()
.call("ListNames".into())
.on("/org/freedesktop/DBus".into())
.with_interface("org.freedesktop.DBus".into())
.at("org.freedesktop.DBus".into())
.build()
}
pub const DBUS_NAME_FLAG_ALLOW_REPLACEMENT: u32 = 1;
pub const DBUS_NAME_FLAG_REPLACE_EXISTING: u32 = 1 << 1;
pub const DBUS_NAME_FLAG_DO_NOT_QUEUE: u32 = 1 << 2;
pub const DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER: u32 = 1;
pub const DBUS_REQUEST_NAME_REPLY_IN_QUEUE: u32 = 2;
pub const DBUS_REQUEST_NAME_REPLY_EXISTS: u32 = 3;
pub const DBUS_REQUEST_NAME_REPLY_ALREADY_OWNER: u32 = 4;
pub fn request_name<'a, 'e>(name: String, flags: u32) -> message::Message<'a, 'e> {
MessageBuilder::new()
.call("RequestName".into())
.on("/org/freedesktop/DBus".into())
.with_interface("org.freedesktop.DBus".into())
.with_params::<crate::params::Param>(vec![name.into(), flags.into()])
.at("org.freedesktop.DBus".into())
.build()
}
pub fn add_match<'a, 'e>(match_rule: String) -> message::Message<'a, 'e> {
MessageBuilder::new()
.call("AddMatch".into())
.on("/org/freedesktop/DBus".into())
.with_interface("org.freedesktop.DBus".into())
.with_params(vec![match_rule])
.at("org.freedesktop.DBus".into())
.build()
}
pub fn unknown_method<'a, 'e>(call: &message::Message<'a, 'e>) -> message::Message<'a, 'e> {
let text = format!(
"No calls to {}.{} are accepted for object {}",
call.interface.clone().unwrap_or_else(|| "".to_owned()),
call.member.clone().unwrap_or_else(|| "".to_owned()),
call.object.clone().unwrap_or_else(|| "".to_owned()),
);
call.make_error_response(
"org.freedesktop.DBus.Error.UnknownMethod".to_owned(),
Some(text),
)
}
pub fn invalid_args<'a, 'e>(
call: &message::Message<'a, 'e>,
sig: Option<&str>,
) -> message::Message<'a, 'e> {
let text = format!(
"Invalid arguments for calls to {}.{} on object {} {}",
call.interface.clone().unwrap_or_else(|| "".to_owned()),
call.member.clone().unwrap_or_else(|| "".to_owned()),
call.object.clone().unwrap_or_else(|| "".to_owned()),
if let Some(sig) = sig {
format!("expected signature: {}", sig)
} else {
"".to_owned()
}
);
call.make_error_response(
"org.freedesktop.DBus.Error.InvalidArgs".to_owned(),
Some(text),
)
}