]> git.ipfire.org Git - thirdparty/systemd.git/blob - src/login/logind-user-dbus.c
Introduce strv_consume which takes ownership
[thirdparty/systemd.git] / src / login / logind-user-dbus.c
1 /*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
2
3 /***
4 This file is part of systemd.
5
6 Copyright 2011 Lennart Poettering
7
8 systemd is free software; you can redistribute it and/or modify it
9 under the terms of the GNU Lesser General Public License as published by
10 the Free Software Foundation; either version 2.1 of the License, or
11 (at your option) any later version.
12
13 systemd is distributed in the hope that it will be useful, but
14 WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16 Lesser General Public License for more details.
17
18 You should have received a copy of the GNU Lesser General Public License
19 along with systemd; If not, see <http://www.gnu.org/licenses/>.
20 ***/
21
22 #include <errno.h>
23 #include <string.h>
24 #include <sys/capability.h>
25
26 #include "strv.h"
27 #include "bus-util.h"
28 #include "logind.h"
29 #include "logind-user.h"
30
31 static int property_get_display(
32 sd_bus *bus,
33 const char *path,
34 const char *interface,
35 const char *property,
36 sd_bus_message *reply,
37 void *userdata,
38 sd_bus_error *error) {
39
40 _cleanup_free_ char *p = NULL;
41 User *u = userdata;
42
43 assert(bus);
44 assert(reply);
45 assert(u);
46
47 p = u->display ? session_bus_path(u->display) : strdup("/");
48 if (!p)
49 return -ENOMEM;
50
51 return sd_bus_message_append(reply, "(so)", u->display ? u->display->id : "", p);
52 }
53
54 static int property_get_state(
55 sd_bus *bus,
56 const char *path,
57 const char *interface,
58 const char *property,
59 sd_bus_message *reply,
60 void *userdata,
61 sd_bus_error *error) {
62
63 User *u = userdata;
64
65 assert(bus);
66 assert(reply);
67 assert(u);
68
69 return sd_bus_message_append(reply, "s", user_state_to_string(user_get_state(u)));
70 }
71
72 static int property_get_sessions(
73 sd_bus *bus,
74 const char *path,
75 const char *interface,
76 const char *property,
77 sd_bus_message *reply,
78 void *userdata,
79 sd_bus_error *error) {
80
81 User *u = userdata;
82 Session *session;
83 int r;
84
85 assert(bus);
86 assert(reply);
87 assert(u);
88
89 r = sd_bus_message_open_container(reply, 'a', "(so)");
90 if (r < 0)
91 return r;
92
93 LIST_FOREACH(sessions_by_user, session, u->sessions) {
94 _cleanup_free_ char *p = NULL;
95
96 p = session_bus_path(session);
97 if (!p)
98 return -ENOMEM;
99
100 r = sd_bus_message_append(reply, "(so)", session->id, p);
101 if (r < 0)
102 return r;
103
104 }
105
106 r = sd_bus_message_close_container(reply);
107 if (r < 0)
108 return r;
109
110 return 1;
111 }
112
113 static int property_get_idle_hint(
114 sd_bus *bus,
115 const char *path,
116 const char *interface,
117 const char *property,
118 sd_bus_message *reply,
119 void *userdata,
120 sd_bus_error *error) {
121
122 User *u = userdata;
123
124 assert(bus);
125 assert(reply);
126 assert(u);
127
128 return sd_bus_message_append(reply, "b", user_get_idle_hint(u, NULL) > 0);
129 }
130
131 static int property_get_idle_since_hint(
132 sd_bus *bus,
133 const char *path,
134 const char *interface,
135 const char *property,
136 sd_bus_message *reply,
137 void *userdata,
138 sd_bus_error *error) {
139
140 User *u = userdata;
141 dual_timestamp t;
142 uint64_t k;
143
144 assert(bus);
145 assert(reply);
146 assert(u);
147
148 user_get_idle_hint(u, &t);
149 k = streq(property, "IdleSinceHint") ? t.realtime : t.monotonic;
150
151 return sd_bus_message_append(reply, "t", k);
152 }
153
154 static int property_get_linger(
155 sd_bus *bus,
156 const char *path,
157 const char *interface,
158 const char *property,
159 sd_bus_message *reply,
160 void *userdata,
161 sd_bus_error *error) {
162
163 User *u = userdata;
164 int r;
165
166 assert(bus);
167 assert(reply);
168 assert(u);
169
170 r = user_check_linger_file(u);
171
172 return sd_bus_message_append(reply, "b", r > 0);
173 }
174
175 static int method_terminate(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
176 User *u = userdata;
177 int r;
178
179 assert(bus);
180 assert(message);
181 assert(u);
182
183 r = user_stop(u, true);
184 if (r < 0)
185 return r;
186
187 return sd_bus_reply_method_return(message, NULL);
188 }
189
190 static int method_kill(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
191 User *u = userdata;
192 int32_t signo;
193 int r;
194
195 assert(bus);
196 assert(message);
197 assert(u);
198
199 r = sd_bus_message_read(message, "i", &signo);
200 if (r < 0)
201 return r;
202
203 if (signo <= 0 || signo >= _NSIG)
204 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Invalid signal %i", signo);
205
206 r = user_kill(u, signo);
207 if (r < 0)
208 return r;
209
210 return sd_bus_reply_method_return(message, NULL);
211 }
212
213 const sd_bus_vtable user_vtable[] = {
214 SD_BUS_VTABLE_START(0),
215
216 SD_BUS_PROPERTY("UID", "u", bus_property_get_uid, offsetof(User, uid), SD_BUS_VTABLE_PROPERTY_CONST),
217 SD_BUS_PROPERTY("GID", "u", bus_property_get_gid, offsetof(User, gid), SD_BUS_VTABLE_PROPERTY_CONST),
218 SD_BUS_PROPERTY("Name", "s", NULL, offsetof(User, name), SD_BUS_VTABLE_PROPERTY_CONST),
219 BUS_PROPERTY_DUAL_TIMESTAMP("Timestamp", offsetof(User, timestamp), SD_BUS_VTABLE_PROPERTY_CONST),
220 SD_BUS_PROPERTY("RuntimePath", "s", NULL, offsetof(User, runtime_path), SD_BUS_VTABLE_PROPERTY_CONST),
221 SD_BUS_PROPERTY("Service", "s", NULL, offsetof(User, service), SD_BUS_VTABLE_PROPERTY_CONST),
222 SD_BUS_PROPERTY("Slice", "s", NULL, offsetof(User, slice), SD_BUS_VTABLE_PROPERTY_CONST),
223 SD_BUS_PROPERTY("Display", "(so)", property_get_display, 0, SD_BUS_VTABLE_PROPERTY_CONST),
224 SD_BUS_PROPERTY("State", "s", property_get_state, 0, 0),
225 SD_BUS_PROPERTY("Sessions", "a(so)", property_get_sessions, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
226 SD_BUS_PROPERTY("IdleHint", "b", property_get_idle_hint, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
227 SD_BUS_PROPERTY("IdleSinceHint", "t", property_get_idle_since_hint, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
228 SD_BUS_PROPERTY("IdleSinceHintMonotonic", "t", property_get_idle_since_hint, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
229 SD_BUS_PROPERTY("Linger", "b", property_get_linger, 0, 0),
230
231 SD_BUS_METHOD("Terminate", NULL, NULL, method_terminate, SD_BUS_VTABLE_CAPABILITY(CAP_KILL)),
232 SD_BUS_METHOD("Kill", "i", NULL, method_kill, SD_BUS_VTABLE_CAPABILITY(CAP_KILL)),
233
234 SD_BUS_VTABLE_END
235 };
236
237 int user_object_find(sd_bus *bus, const char *path, const char *interface, void *userdata, void **found, sd_bus_error *error) {
238 Manager *m = userdata;
239 User *user;
240 int r;
241
242 assert(bus);
243 assert(path);
244 assert(interface);
245 assert(found);
246 assert(m);
247
248 if (streq(path, "/org/freedesktop/login1/user/self")) {
249 _cleanup_bus_creds_unref_ sd_bus_creds *creds = NULL;
250 sd_bus_message *message;
251 pid_t pid;
252
253 message = sd_bus_get_current(bus);
254 if (!message)
255 return 0;
256
257 r = sd_bus_query_sender_creds(message, SD_BUS_CREDS_PID, &creds);
258 if (r < 0)
259 return r;
260
261 r = sd_bus_creds_get_pid(creds, &pid);
262 if (r < 0)
263 return r;
264
265 r = manager_get_user_by_pid(m, pid, &user);
266 if (r <= 0)
267 return 0;
268 } else {
269 unsigned long lu;
270 const char *p;
271
272 p = startswith(path, "/org/freedesktop/login1/user/_");
273 if (!p)
274 return 0;
275
276 r = safe_atolu(p, &lu);
277 if (r < 0)
278 return 0;
279
280 user = hashmap_get(m->users, ULONG_TO_PTR(lu));
281 if (!user)
282 return 0;
283 }
284
285 *found = user;
286 return 1;
287 }
288
289 char *user_bus_path(User *u) {
290 char *s;
291
292 assert(u);
293
294 if (asprintf(&s, "/org/freedesktop/login1/user/_%llu", (unsigned long long) u->uid) < 0)
295 return NULL;
296
297 return s;
298 }
299
300 int user_node_enumerator(sd_bus *bus, const char *path, void *userdata, char ***nodes, sd_bus_error *error) {
301 _cleanup_strv_free_ char **l = NULL;
302 Manager *m = userdata;
303 User *user;
304 Iterator i;
305 int r;
306
307 assert(bus);
308 assert(path);
309 assert(nodes);
310
311 HASHMAP_FOREACH(user, m->users, i) {
312 char *p;
313
314 p = user_bus_path(user);
315 if (!p)
316 return -ENOMEM;
317
318 r = strv_consume(&l, p);
319 if (r < 0)
320 return r;
321 }
322
323 *nodes = l;
324 l = NULL;
325
326 return 1;
327 }
328
329 int user_send_signal(User *u, bool new_user) {
330 _cleanup_free_ char *p = NULL;
331
332 assert(u);
333
334 p = user_bus_path(u);
335 if (!p)
336 return -ENOMEM;
337
338 return sd_bus_emit_signal(
339 u->manager->bus,
340 "/org/freedesktop/login1",
341 "org.freedesktop.login1.Manager",
342 new_user ? "UserNew" : "UserRemoved",
343 "uo", (uint32_t) u->uid, p);
344 }
345
346 int user_send_changed(User *u, const char *properties, ...) {
347 _cleanup_free_ char *p = NULL;
348 char **l;
349
350 assert(u);
351
352 if (!u->started)
353 return 0;
354
355 p = user_bus_path(u);
356 if (!p)
357 return -ENOMEM;
358
359 l = strv_from_stdarg_alloca(properties);
360
361 return sd_bus_emit_properties_changed_strv(u->manager->bus, p, "org.freedesktop.login1.User", l);
362 }