chiark / gitweb /
everywhere: actually make use of DUAL_TIMESTAMP_NULL macro
[elogind.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
25 #include "strv.h"
26 #include "bus-util.h"
27 #include "logind.h"
28 #include "logind-user.h"
29 #include "formats-util.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 = DUAL_TIMESTAMP_NULL;
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 int bus_user_method_terminate(sd_bus_message *message, void *userdata, sd_bus_error *error) {
176         User *u = userdata;
177         int r;
178
179         assert(message);
180         assert(u);
181
182         r = bus_verify_polkit_async(
183                         message,
184                         CAP_KILL,
185                         "org.freedesktop.login1.manage",
186                         false,
187                         u->uid,
188                         &u->manager->polkit_registry,
189                         error);
190         if (r < 0)
191                 return r;
192         if (r == 0)
193                 return 1; /* Will call us back */
194
195         r = user_stop(u, true);
196         if (r < 0)
197                 return r;
198
199         return sd_bus_reply_method_return(message, NULL);
200 }
201
202 int bus_user_method_kill(sd_bus_message *message, void *userdata, sd_bus_error *error) {
203         User *u = userdata;
204         int32_t signo;
205         int r;
206
207         assert(message);
208         assert(u);
209
210         r = bus_verify_polkit_async(
211                         message,
212                         CAP_KILL,
213                         "org.freedesktop.login1.manage",
214                         false,
215                         u->uid,
216                         &u->manager->polkit_registry,
217                         error);
218         if (r < 0)
219                 return r;
220         if (r == 0)
221                 return 1; /* Will call us back */
222
223         r = sd_bus_message_read(message, "i", &signo);
224         if (r < 0)
225                 return r;
226
227         if (signo <= 0 || signo >= _NSIG)
228                 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Invalid signal %i", signo);
229
230         r = user_kill(u, signo);
231         if (r < 0)
232                 return r;
233
234         return sd_bus_reply_method_return(message, NULL);
235 }
236
237 const sd_bus_vtable user_vtable[] = {
238         SD_BUS_VTABLE_START(0),
239
240         SD_BUS_PROPERTY("UID", "u", bus_property_get_uid, offsetof(User, uid), SD_BUS_VTABLE_PROPERTY_CONST),
241         SD_BUS_PROPERTY("GID", "u", bus_property_get_gid, offsetof(User, gid), SD_BUS_VTABLE_PROPERTY_CONST),
242         SD_BUS_PROPERTY("Name", "s", NULL, offsetof(User, name), SD_BUS_VTABLE_PROPERTY_CONST),
243         BUS_PROPERTY_DUAL_TIMESTAMP("Timestamp", offsetof(User, timestamp), SD_BUS_VTABLE_PROPERTY_CONST),
244         SD_BUS_PROPERTY("RuntimePath", "s", NULL, offsetof(User, runtime_path), SD_BUS_VTABLE_PROPERTY_CONST),
245         SD_BUS_PROPERTY("Service", "s", NULL, offsetof(User, service), SD_BUS_VTABLE_PROPERTY_CONST),
246         SD_BUS_PROPERTY("Slice", "s", NULL, offsetof(User, slice), SD_BUS_VTABLE_PROPERTY_CONST),
247         SD_BUS_PROPERTY("Display", "(so)", property_get_display, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
248         SD_BUS_PROPERTY("State", "s", property_get_state, 0, 0),
249         SD_BUS_PROPERTY("Sessions", "a(so)", property_get_sessions, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
250         SD_BUS_PROPERTY("IdleHint", "b", property_get_idle_hint, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
251         SD_BUS_PROPERTY("IdleSinceHint", "t", property_get_idle_since_hint, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
252         SD_BUS_PROPERTY("IdleSinceHintMonotonic", "t", property_get_idle_since_hint, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
253         SD_BUS_PROPERTY("Linger", "b", property_get_linger, 0, 0),
254
255         SD_BUS_METHOD("Terminate", NULL, NULL, bus_user_method_terminate, SD_BUS_VTABLE_UNPRIVILEGED),
256         SD_BUS_METHOD("Kill", "i", NULL, bus_user_method_kill, SD_BUS_VTABLE_UNPRIVILEGED),
257
258         SD_BUS_VTABLE_END
259 };
260
261 int user_object_find(sd_bus *bus, const char *path, const char *interface, void *userdata, void **found, sd_bus_error *error) {
262         Manager *m = userdata;
263         uid_t uid;
264         User *user;
265         int r;
266
267         assert(bus);
268         assert(path);
269         assert(interface);
270         assert(found);
271         assert(m);
272
273         if (streq(path, "/org/freedesktop/login1/user/self")) {
274                 _cleanup_bus_creds_unref_ sd_bus_creds *creds = NULL;
275                 sd_bus_message *message;
276
277                 message = sd_bus_get_current_message(bus);
278                 if (!message)
279                         return 0;
280
281                 r = sd_bus_query_sender_creds(message, SD_BUS_CREDS_OWNER_UID|SD_BUS_CREDS_AUGMENT, &creds);
282                 if (r < 0)
283                         return r;
284
285                 r = sd_bus_creds_get_owner_uid(creds, &uid);
286         } else {
287                 const char *p;
288
289                 p = startswith(path, "/org/freedesktop/login1/user/_");
290                 if (!p)
291                         return 0;
292
293                 r = parse_uid(p, &uid);
294         }
295         if (r < 0)
296                 return 0;
297
298         user = hashmap_get(m->users, UID_TO_PTR(uid));
299         if (!user)
300                 return 0;
301
302         *found = user;
303         return 1;
304 }
305
306 char *user_bus_path(User *u) {
307         char *s;
308
309         assert(u);
310
311         if (asprintf(&s, "/org/freedesktop/login1/user/_"UID_FMT, u->uid) < 0)
312                 return NULL;
313
314         return s;
315 }
316
317 int user_node_enumerator(sd_bus *bus, const char *path, void *userdata, char ***nodes, sd_bus_error *error) {
318         _cleanup_strv_free_ char **l = NULL;
319         sd_bus_message *message;
320         Manager *m = userdata;
321         User *user;
322         Iterator i;
323         int r;
324
325         assert(bus);
326         assert(path);
327         assert(nodes);
328
329         HASHMAP_FOREACH(user, m->users, i) {
330                 char *p;
331
332                 p = user_bus_path(user);
333                 if (!p)
334                         return -ENOMEM;
335
336                 r = strv_consume(&l, p);
337                 if (r < 0)
338                         return r;
339         }
340
341         message = sd_bus_get_current_message(bus);
342         if (message) {
343                 _cleanup_bus_creds_unref_ sd_bus_creds *creds = NULL;
344                 uid_t uid;
345
346                 r = sd_bus_query_sender_creds(message, SD_BUS_CREDS_OWNER_UID|SD_BUS_CREDS_AUGMENT, &creds);
347                 if (r >= 0) {
348                         r = sd_bus_creds_get_owner_uid(creds, &uid);
349                         if (r >= 0) {
350                                 user = hashmap_get(m->users, UID_TO_PTR(uid));
351                                 if (user) {
352                                         r = strv_extend(&l, "/org/freedesktop/login1/user/self");
353                                         if (r < 0)
354                                                 return r;
355                                 }
356                         }
357                 }
358         }
359
360         *nodes = l;
361         l = NULL;
362
363         return 1;
364 }
365
366 int user_send_signal(User *u, bool new_user) {
367         _cleanup_free_ char *p = NULL;
368
369         assert(u);
370
371         p = user_bus_path(u);
372         if (!p)
373                 return -ENOMEM;
374
375         return sd_bus_emit_signal(
376                         u->manager->bus,
377                         "/org/freedesktop/login1",
378                         "org.freedesktop.login1.Manager",
379                         new_user ? "UserNew" : "UserRemoved",
380                         "uo", (uint32_t) u->uid, p);
381 }
382
383 int user_send_changed(User *u, const char *properties, ...) {
384         _cleanup_free_ char *p = NULL;
385         char **l;
386
387         assert(u);
388
389         if (!u->started)
390                 return 0;
391
392         p = user_bus_path(u);
393         if (!p)
394                 return -ENOMEM;
395
396         l = strv_from_stdarg_alloca(properties);
397
398         return sd_bus_emit_properties_changed_strv(u->manager->bus, p, "org.freedesktop.login1.User", l);
399 }