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
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
|
let nm_interface = "org.freedesktop.NetworkManager"
let nm_interface_device = "org.freedesktop.NetworkManager.Device"
let nm_name = nm_interface
let nm_path = "/org/freedesktop/NetworkManager"
let notif_interface = "org.freedesktop.Notifications"
let notif_name = notif_interface
let notif_path = "/org/freedesktop/Notifications"
let print_dbus_ty_list l =
List.iter (fun o -> Printf.printf "%s\n" (DBus.string_of_ty o)) l
let send_msg ~bus ~destination ~path ~intf ~serv ~params =
let msg = DBus.Message.new_method_call destination path intf serv in
DBus.Message.append msg params;
(*print_dbus_ty_list (DBus.Message.get msg);*)
let r = DBus.Connection.send_with_reply_and_block bus msg (-1) in
let l = DBus.Message.get r in
l
(*****************************************************************************)
(****************** NetworkManager daemon ************************************)
(*****************************************************************************)
let send_nm_msg = send_msg ~destination:nm_name ~path:nm_path ~intf:nm_interface
let send_nm_device_msg ~dev ~intf = send_msg ~destination:nm_name ~path:dev ~intf
let example_nm () =
let bus = DBus.Bus.get DBus.Bus.System in
let devices = send_nm_msg ~bus ~serv:"GetDevices" ~params:[] in
match devices with
| [ DBus.Array (DBus.ObjectPaths devs) ] ->
List.iter (fun dev ->
Printf.printf "device: %s\n" dev;
let intf = "org.freedesktop.DBus.Properties" in
let params1 = [
DBus.String "org.freedesktop.NetworkManager.Device";
DBus.String "HwAddress";
] in
let params2 = [
DBus.String "org.freedesktop.NetworkManager.Device";
DBus.String "Interface";
] in
let ret1 = send_nm_device_msg ~bus ~dev ~intf ~serv:"Get" ~params:params1 in
let ret2 = send_nm_device_msg ~bus ~dev ~intf ~serv:"Get" ~params:params2 in
print_dbus_ty_list ret1;
print_dbus_ty_list ret2;
) devs;
()
| _ ->
Printf.eprintf "unexpected reply from GetDevices";
exit 1
(*****************************************************************************)
(****************** Notifications daemon *************************************)
(*****************************************************************************)
let send_notif_msg = send_msg ~destination:notif_name ~path:notif_path ~intf:notif_interface
let example_notification () =
let bus = DBus.Bus.get DBus.Bus.Session in
let params = [
DBus.String "y";
DBus.UInt32 1l;
DBus.String "x";
DBus.String "z";
DBus.String "w";
DBus.Array (DBus.Strings []);
DBus.Array (DBus.Dicts ((DBus.SigString, DBus.SigVariant), []));
DBus.Int32 4000l;
] in
let r = send_notif_msg ~bus ~serv:"Notify" ~params in
print_dbus_ty_list r;
()
(*****************************************************************************)
(****************** Test Packets *********************************************)
(*****************************************************************************)
let test () =
Printf.printf "########## test 1 ########\n%!";
let msg = DBus.Message.new_method_call notif_name notif_path notif_interface "X" in
let params = [
DBus.String "abc";
DBus.Array (DBus.Strings [ "abc"; "def" ]);
DBus.Variant (DBus.Int32 1l);
DBus.Struct [ DBus.String "abc"; DBus.Int64 10L ];
DBus.Array (DBus.ObjectPaths [ "/abc"; "/def"; ]);
DBus.Array (DBus.Variants [ DBus.String "abc"; DBus.Int32 400l ]);
DBus.Array (DBus.Arrays (DBus.SigString, [ DBus.Strings [ "x" ]; DBus.Strings [ "y"; "z" ] ]));
DBus.Array (DBus.Arrays (DBus.SigInt64, [ DBus.Int64s [ 10L; 24L ]; DBus.Int64s [ 54L; 12L ]; ]));
DBus.Array (DBus.Dicts ((DBus.SigString, DBus.SigString), [ DBus.String "abc", DBus.String "def"; DBus.String "2k", DBus.String "2v" ]));
DBus.Array (DBus.Structs ([ DBus.SigString; DBus.SigString; DBus.SigInt32 ],
[
[ DBus.String "abc"; DBus.String "def"; DBus.Int32 10l ];
[ DBus.String "xxx"; DBus.String "yzy"; DBus.Int32 2901l ];
]))
] in
DBus.Message.append msg params;
print_dbus_ty_list (DBus.Message.get msg);
Printf.printf "########## test 2 ########\n%!";
let msg = DBus.Message.new_method_call notif_name notif_path notif_interface "X" in
let params = [
DBus.Array (DBus.Strings [ "abc" ]);
DBus.Array (DBus.Dicts ((DBus.SigString, DBus.SigString), [ (DBus.String "key", DBus.String "value") ]));
DBus.Array (DBus.Variants [ DBus.String "abc" ]);
DBus.Variant (DBus.Array (DBus.Strings [ "abc" ]));
DBus.Variant (DBus.Struct [ DBus.String "abc"; DBus.Int64 10L ]);
DBus.Array (DBus.Structs ([ DBus.SigString ], [ [ DBus.String "x" ]; [ DBus.String "y" ] ]));
DBus.Array (DBus.Dicts ((DBus.SigString, DBus.SigArray DBus.SigString),
[ (DBus.String "x", DBus.Array (DBus.Strings [ "abc"; "def" ]) ) ]
));
] in
DBus.Message.append msg params;
print_dbus_ty_list (DBus.Message.get msg);
Printf.printf "########## test 3 ########\n%!";
let msg = DBus.Message.new_method_call notif_name notif_path notif_interface "X" in
let indictsig = (DBus.SigString, DBus.SigBool) in
let outdictsig = (DBus.SigString, DBus.SigDict (fst indictsig, snd indictsig)) in
let structsig = [ DBus.SigString; DBus.SigInt32 ] in
let params = [
DBus.Array (DBus.Dicts (outdictsig, [
(DBus.String "x", DBus.Array (DBus.Dicts (indictsig, [ (DBus.String "x", DBus.Bool true) ])))
]));
DBus.Variant (DBus.Array (DBus.Dicts (outdictsig, [
(DBus.String "x", DBus.Array (DBus.Dicts (indictsig, [ (DBus.String "x", DBus.Bool true) ])))
])));
DBus.Variant (DBus.Array (DBus.Variants [ DBus.String "abc"; DBus.Int32 23l ]));
DBus.Variant (DBus.Array (DBus.Arrays (DBus.SigString,
[ DBus.Strings [ "a"; "b"; "c" ]; DBus.Strings [ "x"; "y"; "z" ] ])));
DBus.Array (DBus.Arrays (DBus.SigStruct structsig,
[ DBus.Structs (structsig, [ [ DBus.String "lollilol"; DBus.Int32 2901l ] ]) ]
));
] in
DBus.Message.append msg params;
print_dbus_ty_list (DBus.Message.get msg);
()
(*****************************************************************************)
(****************** Request Name *********************************************)
(*****************************************************************************)
let service () =
let bus = DBus.Bus.get DBus.Bus.Session in
let serv = "org.test.dbus.ocaml.bindings" in
let rep = DBus.Bus.request_name bus serv [ DBus.Bus.DoNotQueue ] in
let repstr = match rep with
| DBus.Bus.PrimaryOwner -> "primary ownwer"
| DBus.Bus.InQueue -> "in queue"
| DBus.Bus.Exists -> "exists"
| DBus.Bus.AlreadyOwner -> "already owner"
| DBus.Bus.ReqUnknown i -> Printf.sprintf "unknown %d" i
in
Printf.printf "grabbing %s : %s\n" serv repstr;
let rep = DBus.Bus.release_name bus serv in
let repstr = match rep with
| DBus.Bus.Released -> "released"
| DBus.Bus.NonExistent -> "non existent"
| DBus.Bus.NotOwner -> "not owner"
| DBus.Bus.RelUnknown i -> Printf.sprintf "unknown %d" i
in
Printf.printf "releasing %s : %s\n" serv repstr;
()
(*****************************************************************************)
(*****************************************************************************)
(*****************************************************************************)
let () =
match Sys.argv.(1) with
| "nm" -> example_nm ();
| "notification" -> example_notification ();
| "avahi" -> ()
| "test" -> test ()
| "service" -> service ()
| _ -> ()
|
