]> git.ipfire.org Git - thirdparty/systemd.git/blame_incremental - src/home/homectl.c
projects / thirdparty / systemd.git / blame_incremental
? search:
summary | shortlog | log | commit | commitdiff | tree
blob | blame (non-incremental) | history | HEAD
test: several random cleanups and fixlets (#38877)
[thirdparty/systemd.git] / src / home / homectl.c
... / ...
CommitLineData
1/* SPDX-License-Identifier: LGPL-2.1-or-later */
2
3#include <getopt.h>
4#include <unistd.h>
5
6#include "sd-bus.h"
7
8#include "ask-password-api.h"
9#include "bitfield.h"
10#include "build.h"
11#include "bus-common-errors.h"
12#include "bus-error.h"
13#include "bus-locator.h"
14#include "bus-util.h"
15#include "capability-list.h"
16#include "capability-util.h"
17#include "cgroup-util.h"
18#include "creds-util.h"
19#include "dirent-util.h"
20#include "dns-domain.h"
21#include "env-util.h"
22#include "errno-util.h"
23#include "extract-word.h"
24#include "fd-util.h"
25#include "fileio.h"
26#include "format-table.h"
27#include "format-util.h"
28#include "fs-util.h"
29#include "glyph-util.h"
30#include "hashmap.h"
31#include "hexdecoct.h"
32#include "home-util.h"
33#include "homectl-fido2.h"
34#include "homectl-pkcs11.h"
35#include "homectl-recovery-key.h"
36#include "json-util.h"
37#include "libfido2-util.h"
38#include "locale-util.h"
39#include "main-func.h"
40#include "openssl-util.h"
41#include "pager.h"
42#include "parse-argument.h"
43#include "parse-util.h"
44#include "password-quality-util.h"
45#include "path-util.h"
46#include "percent-util.h"
47#include "pkcs11-util.h"
48#include "polkit-agent.h"
49#include "pretty-print.h"
50#include "proc-cmdline.h"
51#include "process-util.h"
52#include "recurse-dir.h"
53#include "rlimit-util.h"
54#include "runtime-scope.h"
55#include "stat-util.h"
56#include "string-util.h"
57#include "strv.h"
58#include "terminal-util.h"
59#include "time-util.h"
60#include "uid-classification.h"
61#include "user-record.h"
62#include "user-record-password-quality.h"
63#include "user-record-show.h"
64#include "user-record-util.h"
65#include "user-util.h"
66#include "userdb.h"
67#include "verbs.h"
68
69static PagerFlags arg_pager_flags = 0;
70static bool arg_legend = true;
71static bool arg_ask_password = true;
72static BusTransport arg_transport = BUS_TRANSPORT_LOCAL;
73static const char *arg_host = NULL;
74static bool arg_offline = false;
75static const char *arg_identity = NULL;
76static sd_json_variant *arg_identity_extra = NULL;
77static sd_json_variant *arg_identity_extra_privileged = NULL;
78static sd_json_variant *arg_identity_extra_this_machine = NULL;
79static sd_json_variant *arg_identity_extra_other_machines = NULL;
80static sd_json_variant *arg_identity_extra_rlimits = NULL;
81static char **arg_identity_filter = NULL; /* this one is also applied to 'privileged' and 'thisMachine' subobjects */
82static char **arg_identity_filter_rlimits = NULL;
83static uint64_t arg_disk_size = UINT64_MAX;
84static uint64_t arg_disk_size_relative = UINT64_MAX;
85static char **arg_pkcs11_token_uri = NULL;
86static char **arg_fido2_device = NULL;
87static Fido2EnrollFlags arg_fido2_lock_with = FIDO2ENROLL_PIN | FIDO2ENROLL_UP;
88#if HAVE_LIBFIDO2
89static int arg_fido2_cred_alg = COSE_ES256;
90#else
91static int arg_fido2_cred_alg = 0;
92#endif
93static bool arg_recovery_key = false;
94static sd_json_format_flags_t arg_json_format_flags = SD_JSON_FORMAT_OFF;
95static bool arg_and_resize = false;
96static bool arg_and_change_password = false;
97static enum {
98 EXPORT_FORMAT_FULL, /* export the full record */
99 EXPORT_FORMAT_STRIPPED, /* strip "state" + "binding", but leave signature in place */
100 EXPORT_FORMAT_MINIMAL, /* also strip signature */
101} arg_export_format = EXPORT_FORMAT_FULL;
102static uint64_t arg_capability_bounding_set = UINT64_MAX;
103static uint64_t arg_capability_ambient_set = UINT64_MAX;
104static bool arg_prompt_new_user = false;
105static char *arg_blob_dir = NULL;
106static bool arg_blob_clear = false;
107static Hashmap *arg_blob_files = NULL;
108static char *arg_key_name = NULL;
109static bool arg_dry_run = false;
110static bool arg_seize = true;
111
112STATIC_DESTRUCTOR_REGISTER(arg_identity_extra, sd_json_variant_unrefp);
113STATIC_DESTRUCTOR_REGISTER(arg_identity_extra_this_machine, sd_json_variant_unrefp);
114STATIC_DESTRUCTOR_REGISTER(arg_identity_extra_other_machines, sd_json_variant_unrefp);
115STATIC_DESTRUCTOR_REGISTER(arg_identity_extra_privileged, sd_json_variant_unrefp);
116STATIC_DESTRUCTOR_REGISTER(arg_identity_extra_rlimits, sd_json_variant_unrefp);
117STATIC_DESTRUCTOR_REGISTER(arg_identity_filter, strv_freep);
118STATIC_DESTRUCTOR_REGISTER(arg_identity_filter_rlimits, strv_freep);
119STATIC_DESTRUCTOR_REGISTER(arg_pkcs11_token_uri, strv_freep);
120STATIC_DESTRUCTOR_REGISTER(arg_fido2_device, strv_freep);
121STATIC_DESTRUCTOR_REGISTER(arg_blob_dir, freep);
122STATIC_DESTRUCTOR_REGISTER(arg_blob_files, hashmap_freep);
123STATIC_DESTRUCTOR_REGISTER(arg_key_name, freep);
124
125static const BusLocator *bus_mgr;
126
127static bool identity_properties_specified(void) {
128 return
129 arg_identity ||
130 !sd_json_variant_is_blank_object(arg_identity_extra) ||
131 !sd_json_variant_is_blank_object(arg_identity_extra_privileged) ||
132 !sd_json_variant_is_blank_object(arg_identity_extra_this_machine) ||
133 !sd_json_variant_is_blank_object(arg_identity_extra_other_machines) ||
134 !sd_json_variant_is_blank_object(arg_identity_extra_rlimits) ||
135 !strv_isempty(arg_identity_filter) ||
136 !strv_isempty(arg_identity_filter_rlimits) ||
137 !strv_isempty(arg_pkcs11_token_uri) ||
138 !strv_isempty(arg_fido2_device) ||
139 arg_blob_dir ||
140 arg_blob_clear ||
141 !hashmap_isempty(arg_blob_files);
142}
143
144static int acquire_bus(sd_bus **bus) {
145 int r;
146
147 assert(bus);
148
149 if (*bus)
150 return 0;
151
152 r = bus_connect_transport(arg_transport, arg_host, RUNTIME_SCOPE_SYSTEM, bus);
153 if (r < 0)
154 return bus_log_connect_error(r, arg_transport, RUNTIME_SCOPE_SYSTEM);
155
156 (void) sd_bus_set_allow_interactive_authorization(*bus, arg_ask_password);
157
158 return 0;
159}
160
161static int list_homes(int argc, char *argv[], void *userdata) {
162 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
163 _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
164 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
165 _cleanup_(table_unrefp) Table *table = NULL;
166 int r;
167
168 r = acquire_bus(&bus);
169 if (r < 0)
170 return r;
171
172 r = bus_call_method(bus, bus_mgr, "ListHomes", &error, &reply, NULL);
173 if (r < 0)
174 return log_error_errno(r, "Failed to list homes: %s", bus_error_message(&error, r));
175
176 table = table_new("name", "uid", "gid", "state", "realname", "home", "shell");
177 if (!table)
178 return log_oom();
179
180 r = sd_bus_message_enter_container(reply, 'a', "(susussso)");
181 if (r < 0)
182 return bus_log_parse_error(r);
183
184 for (;;) {
185 const char *name, *state, *realname, *home, *shell, *color;
186 TableCell *cell;
187 uint32_t uid, gid;
188
189 r = sd_bus_message_read(reply, "(susussso)", &name, &uid, &state, &gid, &realname, &home, &shell, NULL);
190 if (r < 0)
191 return bus_log_parse_error(r);
192 if (r == 0)
193 break;
194
195 r = table_add_many(table,
196 TABLE_STRING, name,
197 TABLE_UID, uid,
198 TABLE_GID, gid);
199 if (r < 0)
200 return table_log_add_error(r);
201
202 r = table_add_cell(table, &cell, TABLE_STRING, state);
203 if (r < 0)
204 return table_log_add_error(r);
205
206 color = user_record_state_color(state);
207 if (color)
208 (void) table_set_color(table, cell, color);
209
210 r = table_add_many(table,
211 TABLE_STRING, strna(empty_to_null(realname)),
212 TABLE_STRING, home,
213 TABLE_STRING, strna(empty_to_null(shell)));
214 if (r < 0)
215 return table_log_add_error(r);
216 }
217
218 r = sd_bus_message_exit_container(reply);
219 if (r < 0)
220 return bus_log_parse_error(r);
221
222 if (!table_isempty(table) || sd_json_format_enabled(arg_json_format_flags)) {
223 r = table_set_sort(table, (size_t) 0);
224 if (r < 0)
225 return table_log_sort_error(r);
226
227 r = table_print_with_pager(table, arg_json_format_flags, arg_pager_flags, arg_legend);
228 if (r < 0)
229 return r;
230 }
231
232 if (arg_legend && !sd_json_format_enabled(arg_json_format_flags)) {
233 if (table_isempty(table))
234 printf("No home areas.\n");
235 else
236 printf("\n%zu home areas listed.\n", table_get_rows(table) - 1);
237 }
238
239 return 0;
240}
241
242static int acquire_existing_password(
243 const char *user_name,
244 UserRecord *hr,
245 bool emphasize_current_password,
246 AskPasswordFlags flags) {
247
248 _cleanup_strv_free_erase_ char **password = NULL;
249 _cleanup_(erase_and_freep) char *envpw = NULL;
250 _cleanup_free_ char *question = NULL;
251 int r;
252
253 assert(user_name);
254 assert(hr);
255
256 r = getenv_steal_erase("PASSWORD", &envpw);
257 if (r < 0)
258 return log_error_errno(r, "Failed to acquire password from environment: %m");
259 if (r > 0) {
260 /* People really shouldn't use environment variables for passing passwords. We support this
261 * only for testing purposes, and do not document the behaviour, so that people won't
262 * actually use this outside of testing. */
263
264 r = user_record_set_password(hr, STRV_MAKE(envpw), true);
265 if (r < 0)
266 return log_error_errno(r, "Failed to store password: %m");
267
268 return 1;
269 }
270
271 /* If this is not our own user, then don't use the password cache */
272 if (is_this_me(user_name) <= 0)
273 SET_FLAG(flags, ASK_PASSWORD_ACCEPT_CACHED|ASK_PASSWORD_PUSH_CACHE, false);
274
275 if (asprintf(&question, emphasize_current_password ?
276 "Please enter current password for user %s:" :
277 "Please enter password for user %s:",
278 user_name) < 0)
279 return log_oom();
280
281 AskPasswordRequest req = {
282 .tty_fd = -EBADF,
283 .message = question,
284 .icon = "user-home",
285 .keyring = "home-password",
286 .credential = "home.password",
287 .until = USEC_INFINITY,
288 .hup_fd = -EBADF,
289 };
290
291 r = ask_password_auto(&req, flags, &password);
292 if (r == -EUNATCH) { /* EUNATCH is returned if no password was found and asking interactively was
293 * disabled via the flags. Not an error for us. */
294 log_debug_errno(r, "No passwords acquired.");
295 return 0;
296 }
297 if (r < 0)
298 return log_error_errno(r, "Failed to acquire password: %m");
299
300 r = user_record_set_password(hr, password, true);
301 if (r < 0)
302 return log_error_errno(r, "Failed to store password: %m");
303
304 return 1;
305}
306
307static int acquire_recovery_key(
308 const char *user_name,
309 UserRecord *hr,
310 AskPasswordFlags flags) {
311
312 _cleanup_strv_free_erase_ char **recovery_key = NULL;
313 _cleanup_(erase_and_freep) char *envpw = NULL;
314 _cleanup_free_ char *question = NULL;
315 int r;
316
317 assert(user_name);
318 assert(hr);
319
320 r = getenv_steal_erase("PASSWORD", &envpw);
321 if (r < 0)
322 return log_error_errno(r, "Failed to acquire password from environment: %m");
323 if (r > 0) {
324 /* People really shouldn't use environment variables for passing secrets. We support this
325 * only for testing purposes, and do not document the behaviour, so that people won't
326 * actually use this outside of testing. */
327
328 r = user_record_set_password(hr, STRV_MAKE(envpw), true); /* recovery keys are stored in the record exactly like regular passwords! */
329 if (r < 0)
330 return log_error_errno(r, "Failed to store recovery key: %m");
331
332 return 1;
333 }
334
335 /* If this is not our own user, then don't use the password cache */
336 if (is_this_me(user_name) <= 0)
337 SET_FLAG(flags, ASK_PASSWORD_ACCEPT_CACHED|ASK_PASSWORD_PUSH_CACHE, false);
338
339 if (asprintf(&question, "Please enter recovery key for user %s:", user_name) < 0)
340 return log_oom();
341
342 AskPasswordRequest req = {
343 .tty_fd = -EBADF,
344 .message = question,
345 .icon = "user-home",
346 .keyring = "home-recovery-key",
347 .credential = "home.recovery-key",
348 .until = USEC_INFINITY,
349 .hup_fd = -EBADF,
350 };
351
352 r = ask_password_auto(&req, flags, &recovery_key);
353 if (r == -EUNATCH) { /* EUNATCH is returned if no recovery key was found and asking interactively was
354 * disabled via the flags. Not an error for us. */
355 log_debug_errno(r, "No recovery keys acquired.");
356 return 0;
357 }
358 if (r < 0)
359 return log_error_errno(r, "Failed to acquire recovery keys: %m");
360
361 r = user_record_set_password(hr, recovery_key, true);
362 if (r < 0)
363 return log_error_errno(r, "Failed to store recovery keys: %m");
364
365 return 1;
366}
367
368static int acquire_token_pin(
369 const char *user_name,
370 UserRecord *hr,
371 AskPasswordFlags flags) {
372
373 _cleanup_strv_free_erase_ char **pin = NULL;
374 _cleanup_(erase_and_freep) char *envpin = NULL;
375 _cleanup_free_ char *question = NULL;
376 int r;
377
378 assert(user_name);
379 assert(hr);
380
381 r = getenv_steal_erase("PIN", &envpin);
382 if (r < 0)
383 return log_error_errno(r, "Failed to acquire PIN from environment: %m");
384 if (r > 0) {
385 r = user_record_set_token_pin(hr, STRV_MAKE(envpin), false);
386 if (r < 0)
387 return log_error_errno(r, "Failed to store token PIN: %m");
388
389 return 1;
390 }
391
392 /* If this is not our own user, then don't use the password cache */
393 if (is_this_me(user_name) <= 0)
394 SET_FLAG(flags, ASK_PASSWORD_ACCEPT_CACHED|ASK_PASSWORD_PUSH_CACHE, false);
395
396 if (asprintf(&question, "Please enter security token PIN for user %s:", user_name) < 0)
397 return log_oom();
398
399 AskPasswordRequest req = {
400 .tty_fd = -EBADF,
401 .message = question,
402 .icon = "user-home",
403 .keyring = "token-pin",
404 .credential = "home.token-pin",
405 .until = USEC_INFINITY,
406 .hup_fd = -EBADF,
407 };
408
409 r = ask_password_auto(&req, flags, &pin);
410 if (r == -EUNATCH) { /* EUNATCH is returned if no PIN was found and asking interactively was disabled
411 * via the flags. Not an error for us. */
412 log_debug_errno(r, "No security token PINs acquired.");
413 return 0;
414 }
415 if (r < 0)
416 return log_error_errno(r, "Failed to acquire security token PIN: %m");
417
418 r = user_record_set_token_pin(hr, pin, false);
419 if (r < 0)
420 return log_error_errno(r, "Failed to store security token PIN: %m");
421
422 return 1;
423}
424
425static int handle_generic_user_record_error(
426 const char *user_name,
427 UserRecord *hr,
428 const sd_bus_error *error,
429 int ret,
430 bool emphasize_current_password) {
431 int r;
432
433 assert(user_name);
434 assert(hr);
435
436 if (sd_bus_error_has_name(error, BUS_ERROR_HOME_ABSENT))
437 return log_error_errno(SYNTHETIC_ERRNO(EREMOTE),
438 "Home of user %s is currently absent, please plug in the necessary storage device or backing file system.", user_name);
439
440 else if (sd_bus_error_has_name(error, BUS_ERROR_AUTHENTICATION_LIMIT_HIT))
441 return log_error_errno(SYNTHETIC_ERRNO(ETOOMANYREFS),
442 "Too frequent login attempts for user %s, try again later.", user_name);
443
444 else if (sd_bus_error_has_name(error, BUS_ERROR_BAD_PASSWORD)) {
445
446 if (!strv_isempty(hr->password))
447 log_notice("Password incorrect or not sufficient, please try again.");
448
449 /* Don't consume cache entries or credentials here, we already tried that unsuccessfully. But
450 * let's push what we acquire here into the cache */
451 r = acquire_existing_password(
452 user_name,
453 hr,
454 emphasize_current_password,
455 ASK_PASSWORD_PUSH_CACHE | ASK_PASSWORD_NO_CREDENTIAL);
456 if (r < 0)
457 return r;
458
459 } else if (sd_bus_error_has_name(error, BUS_ERROR_BAD_RECOVERY_KEY)) {
460
461 if (!strv_isempty(hr->password))
462 log_notice("Recovery key incorrect or not sufficient, please try again.");
463
464 /* Don't consume cache entries or credentials here, we already tried that unsuccessfully. But
465 * let's push what we acquire here into the cache */
466 r = acquire_recovery_key(
467 user_name,
468 hr,
469 ASK_PASSWORD_PUSH_CACHE | ASK_PASSWORD_NO_CREDENTIAL);
470 if (r < 0)
471 return r;
472
473 } else if (sd_bus_error_has_name(error, BUS_ERROR_BAD_PASSWORD_AND_NO_TOKEN)) {
474
475 if (strv_isempty(hr->password))
476 log_notice("Security token not inserted, please enter password.");
477 else
478 log_notice("Password incorrect or not sufficient, and configured security token not inserted, please try again.");
479
480 r = acquire_existing_password(
481 user_name,
482 hr,
483 emphasize_current_password,
484 ASK_PASSWORD_PUSH_CACHE | ASK_PASSWORD_NO_CREDENTIAL);
485 if (r < 0)
486 return r;
487
488 } else if (sd_bus_error_has_name(error, BUS_ERROR_TOKEN_PIN_NEEDED)) {
489
490 /* First time the PIN is requested, let's accept cached data, and allow using credential store */
491 r = acquire_token_pin(
492 user_name,
493 hr,
494 ASK_PASSWORD_ACCEPT_CACHED | ASK_PASSWORD_PUSH_CACHE);
495 if (r < 0)
496 return r;
497
498 } else if (sd_bus_error_has_name(error, BUS_ERROR_TOKEN_PROTECTED_AUTHENTICATION_PATH_NEEDED)) {
499
500 log_notice("%s%sPlease authenticate physically on security token.",
501 emoji_enabled() ? glyph(GLYPH_TOUCH) : "",
502 emoji_enabled() ? " " : "");
503
504 r = user_record_set_pkcs11_protected_authentication_path_permitted(hr, true);
505 if (r < 0)
506 return log_error_errno(r, "Failed to set PKCS#11 protected authentication path permitted flag: %m");
507
508 } else if (sd_bus_error_has_name(error, BUS_ERROR_TOKEN_USER_PRESENCE_NEEDED)) {
509
510 log_notice("%s%sPlease confirm presence on security token.",
511 emoji_enabled() ? glyph(GLYPH_TOUCH) : "",
512 emoji_enabled() ? " " : "");
513
514 r = user_record_set_fido2_user_presence_permitted(hr, true);
515 if (r < 0)
516 return log_error_errno(r, "Failed to set FIDO2 user presence permitted flag: %m");
517
518 } else if (sd_bus_error_has_name(error, BUS_ERROR_TOKEN_USER_VERIFICATION_NEEDED)) {
519
520 log_notice("%s%sPlease verify user on security token.",
521 emoji_enabled() ? glyph(GLYPH_TOUCH) : "",
522 emoji_enabled() ? " " : "");
523
524 r = user_record_set_fido2_user_verification_permitted(hr, true);
525 if (r < 0)
526 return log_error_errno(r, "Failed to set FIDO2 user verification permitted flag: %m");
527
528 } else if (sd_bus_error_has_name(error, BUS_ERROR_TOKEN_PIN_LOCKED))
529 return log_error_errno(SYNTHETIC_ERRNO(EPERM), "Security token PIN is locked, please unlock it first. (Hint: Removal and re-insertion might suffice.)");
530
531 else if (sd_bus_error_has_name(error, BUS_ERROR_TOKEN_BAD_PIN)) {
532
533 log_notice("Security token PIN incorrect, please try again.");
534
535 /* If the previous PIN was wrong don't accept cached info anymore, but add to cache. Also, don't use the credential data */
536 r = acquire_token_pin(
537 user_name,
538 hr,
539 ASK_PASSWORD_PUSH_CACHE | ASK_PASSWORD_NO_CREDENTIAL);
540 if (r < 0)
541 return r;
542
543 } else if (sd_bus_error_has_name(error, BUS_ERROR_TOKEN_BAD_PIN_FEW_TRIES_LEFT)) {
544
545 log_notice("Security token PIN incorrect, please try again (only a few tries left!).");
546
547 r = acquire_token_pin(
548 user_name,
549 hr,
550 ASK_PASSWORD_PUSH_CACHE | ASK_PASSWORD_NO_CREDENTIAL);
551 if (r < 0)
552 return r;
553
554 } else if (sd_bus_error_has_name(error, BUS_ERROR_TOKEN_BAD_PIN_ONE_TRY_LEFT)) {
555
556 log_notice("Security token PIN incorrect, please try again (only one try left!).");
557
558 r = acquire_token_pin(
559 user_name,
560 hr,
561 ASK_PASSWORD_PUSH_CACHE | ASK_PASSWORD_NO_CREDENTIAL);
562 if (r < 0)
563 return r;
564 } else
565 return log_error_errno(ret, "Operation on home %s failed: %s", user_name, bus_error_message(error, ret));
566
567 return 0;
568}
569
570static int acquire_passed_secrets(const char *user_name, UserRecord **ret) {
571 _cleanup_(user_record_unrefp) UserRecord *secret = NULL;
572 int r;
573
574 assert(ret);
575
576 /* Generates an initial secret objects that contains passwords supplied via $PASSWORD, the password
577 * cache or the credentials subsystem, but excluding any interactive stuff. If nothing is passed,
578 * returns an empty secret object. */
579
580 secret = user_record_new();
581 if (!secret)
582 return log_oom();
583
584 r = acquire_existing_password(
585 user_name,
586 secret,
587 /* emphasize_current_password = */ false,
588 ASK_PASSWORD_ACCEPT_CACHED | ASK_PASSWORD_NO_TTY | ASK_PASSWORD_NO_AGENT);
589 if (r < 0)
590 return r;
591
592 r = acquire_token_pin(
593 user_name,
594 secret,
595 ASK_PASSWORD_ACCEPT_CACHED | ASK_PASSWORD_NO_TTY | ASK_PASSWORD_NO_AGENT);
596 if (r < 0)
597 return r;
598
599 r = acquire_recovery_key(
600 user_name,
601 secret,
602 ASK_PASSWORD_ACCEPT_CACHED | ASK_PASSWORD_NO_TTY | ASK_PASSWORD_NO_AGENT);
603 if (r < 0)
604 return r;
605
606 *ret = TAKE_PTR(secret);
607 return 0;
608}
609
610static int activate_home(int argc, char *argv[], void *userdata) {
611 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
612 int r, ret = 0;
613
614 r = acquire_bus(&bus);
615 if (r < 0)
616 return r;
617
618 STRV_FOREACH(i, strv_skip(argv, 1)) {
619 _cleanup_(user_record_unrefp) UserRecord *secret = NULL;
620
621 r = acquire_passed_secrets(*i, &secret);
622 if (r < 0)
623 return r;
624
625 for (;;) {
626 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
627 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
628
629 r = bus_message_new_method_call(bus, &m, bus_mgr, "ActivateHome");
630 if (r < 0)
631 return bus_log_create_error(r);
632
633 r = sd_bus_message_append(m, "s", *i);
634 if (r < 0)
635 return bus_log_create_error(r);
636
637 r = bus_message_append_secret(m, secret);
638 if (r < 0)
639 return bus_log_create_error(r);
640
641 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
642 if (r < 0) {
643 r = handle_generic_user_record_error(*i, secret, &error, r, /* emphasize_current_password= */ false);
644 if (r < 0) {
645 if (ret == 0)
646 ret = r;
647
648 break;
649 }
650 } else
651 break;
652 }
653 }
654
655 return ret;
656}
657
658static int deactivate_home(int argc, char *argv[], void *userdata) {
659 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
660 int r, ret = 0;
661
662 r = acquire_bus(&bus);
663 if (r < 0)
664 return r;
665
666 STRV_FOREACH(i, strv_skip(argv, 1)) {
667 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
668 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
669
670 r = bus_message_new_method_call(bus, &m, bus_mgr, "DeactivateHome");
671 if (r < 0)
672 return bus_log_create_error(r);
673
674 r = sd_bus_message_append(m, "s", *i);
675 if (r < 0)
676 return bus_log_create_error(r);
677
678 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
679 if (r < 0) {
680 log_error_errno(r, "Failed to deactivate user home: %s", bus_error_message(&error, r));
681 if (ret == 0)
682 ret = r;
683 }
684 }
685
686 return ret;
687}
688
689static void dump_home_record(UserRecord *hr) {
690 int r;
691
692 assert(hr);
693
694 if (hr->incomplete) {
695 fflush(stdout);
696 log_warning("Warning: lacking rights to acquire privileged fields of user record of '%s', output incomplete.", hr->user_name);
697 }
698
699 if (!sd_json_format_enabled(arg_json_format_flags))
700 user_record_show(hr, true);
701 else {
702 _cleanup_(user_record_unrefp) UserRecord *stripped = NULL;
703
704 if (arg_export_format == EXPORT_FORMAT_STRIPPED)
705 r = user_record_clone(hr, USER_RECORD_EXTRACT_EMBEDDED|USER_RECORD_PERMISSIVE, &stripped);
706 else if (arg_export_format == EXPORT_FORMAT_MINIMAL)
707 r = user_record_clone(hr, USER_RECORD_EXTRACT_SIGNABLE|USER_RECORD_PERMISSIVE, &stripped);
708 else
709 r = 0;
710 if (r < 0)
711 log_warning_errno(r, "Failed to strip user record, ignoring: %m");
712 if (stripped)
713 hr = stripped;
714
715 sd_json_variant_dump(hr->json, arg_json_format_flags, stdout, NULL);
716 }
717}
718
719static int inspect_home(sd_bus *bus, const char *name) {
720 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
721 _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
722 _cleanup_(sd_json_variant_unrefp) sd_json_variant *v = NULL;
723 _cleanup_(user_record_unrefp) UserRecord *hr = NULL;
724 const char *json;
725 int incomplete;
726 uid_t uid;
727 int r;
728
729 r = parse_uid(name, &uid);
730 if (r < 0)
731 r = bus_call_method(bus, bus_mgr, "GetUserRecordByName", &error, &reply, "s", name);
732 else
733 r = bus_call_method(bus, bus_mgr, "GetUserRecordByUID", &error, &reply, "u", (uint32_t) uid);
734 if (r < 0)
735 return log_error_errno(r, "Failed to inspect home: %s", bus_error_message(&error, r));
736
737 r = sd_bus_message_read(reply, "sbo", &json, &incomplete, NULL);
738 if (r < 0)
739 return bus_log_parse_error(r);
740
741 r = sd_json_parse(json, SD_JSON_PARSE_SENSITIVE, &v, NULL, NULL);
742 if (r < 0)
743 return log_error_errno(r, "Failed to parse JSON identity: %m");
744
745 hr = user_record_new();
746 if (!hr)
747 return log_oom();
748
749 r = user_record_load(hr, v, USER_RECORD_LOAD_REFUSE_SECRET|USER_RECORD_LOG|USER_RECORD_PERMISSIVE);
750 if (r < 0)
751 return r;
752
753 hr->incomplete = incomplete;
754 dump_home_record(hr);
755 return 0;
756}
757
758static int inspect_homes(int argc, char *argv[], void *userdata) {
759 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
760 int r;
761
762 r = acquire_bus(&bus);
763 if (r < 0)
764 return r;
765
766 pager_open(arg_pager_flags);
767
768 char **args = strv_skip(argv, 1);
769 if (args) {
770 STRV_FOREACH(arg, args)
771 RET_GATHER(r, inspect_home(bus, *arg));
772 return r;
773 } else {
774 _cleanup_free_ char *myself = getusername_malloc();
775 if (!myself)
776 return log_oom();
777
778 return inspect_home(bus, myself);
779 }
780}
781
782static int authenticate_home(sd_bus *bus, const char *name) {
783 _cleanup_(user_record_unrefp) UserRecord *secret = NULL;
784 int r;
785
786 r = acquire_passed_secrets(name, &secret);
787 if (r < 0)
788 return r;
789
790 for (;;) {
791 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
792 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
793
794 r = bus_message_new_method_call(bus, &m, bus_mgr, "AuthenticateHome");
795 if (r < 0)
796 return bus_log_create_error(r);
797
798 r = sd_bus_message_append(m, "s", name);
799 if (r < 0)
800 return bus_log_create_error(r);
801
802 r = bus_message_append_secret(m, secret);
803 if (r < 0)
804 return bus_log_create_error(r);
805
806 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
807 if (r < 0) {
808 r = handle_generic_user_record_error(name, secret, &error, r, false);
809 if (r >= 0)
810 continue;
811 }
812 return r;
813 }
814}
815
816static int authenticate_homes(int argc, char *argv[], void *userdata) {
817 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
818 int r;
819
820 r = acquire_bus(&bus);
821 if (r < 0)
822 return r;
823
824 (void) polkit_agent_open_if_enabled(arg_transport, arg_ask_password);
825
826 char **args = strv_skip(argv, 1);
827 if (args) {
828 STRV_FOREACH(arg, args)
829 RET_GATHER(r, authenticate_home(bus, *arg));
830
831 return r;
832 } else {
833 _cleanup_free_ char *myself = getusername_malloc();
834 if (!myself)
835 return log_oom();
836
837 return authenticate_home(bus, myself);
838 }
839}
840
841static int update_last_change(sd_json_variant **v, bool with_password, bool override) {
842 sd_json_variant *c;
843 usec_t n;
844 int r;
845
846 assert(v);
847
848 n = now(CLOCK_REALTIME);
849
850 c = sd_json_variant_by_key(*v, "lastChangeUSec");
851 if (c) {
852 uint64_t u;
853
854 if (!override)
855 goto update_password;
856
857 if (!sd_json_variant_is_unsigned(c))
858 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "lastChangeUSec field is not an unsigned integer, refusing.");
859
860 u = sd_json_variant_unsigned(c);
861 if (u >= n)
862 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "lastChangeUSec is from the future, can't update.");
863 }
864
865 r = sd_json_variant_set_field_unsigned(v, "lastChangeUSec", n);
866 if (r < 0)
867 return log_error_errno(r, "Failed to update lastChangeUSec: %m");
868
869update_password:
870 if (!with_password)
871 return 0;
872
873 c = sd_json_variant_by_key(*v, "lastPasswordChangeUSec");
874 if (c) {
875 uint64_t u;
876
877 if (!override)
878 return 0;
879
880 if (!sd_json_variant_is_unsigned(c))
881 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "lastPasswordChangeUSec field is not an unsigned integer, refusing.");
882
883 u = sd_json_variant_unsigned(c);
884 if (u >= n)
885 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "lastPasswordChangeUSec is from the future, can't update.");
886 }
887
888 r = sd_json_variant_set_field_unsigned(v, "lastPasswordChangeUSec", n);
889 if (r < 0)
890 return log_error_errno(r, "Failed to update lastPasswordChangeUSec: %m");
891
892 return 1;
893}
894
895static int apply_identity_changes(sd_json_variant **_v) {
896 _cleanup_(sd_json_variant_unrefp) sd_json_variant *v = NULL;
897 int r;
898
899 assert(_v);
900
901 v = sd_json_variant_ref(*_v);
902
903 r = sd_json_variant_filter(&v, arg_identity_filter);
904 if (r < 0)
905 return log_error_errno(r, "Failed to filter identity: %m");
906
907 r = sd_json_variant_merge_object(&v, arg_identity_extra);
908 if (r < 0)
909 return log_error_errno(r, "Failed to merge identities: %m");
910
911 if (arg_identity_extra_this_machine || arg_identity_extra_other_machines || !strv_isempty(arg_identity_filter)) {
912 _cleanup_(sd_json_variant_unrefp) sd_json_variant *per_machine = NULL, *mmid = NULL;
913 sd_id128_t mid;
914
915 r = sd_id128_get_machine(&mid);
916 if (r < 0)
917 return log_error_errno(r, "Failed to acquire machine ID: %m");
918
919 r = sd_json_variant_new_string(&mmid, SD_ID128_TO_STRING(mid));
920 if (r < 0)
921 return log_error_errno(r, "Failed to allocate matchMachineId object: %m");
922
923 per_machine = sd_json_variant_ref(sd_json_variant_by_key(v, "perMachine"));
924 if (per_machine) {
925 _cleanup_(sd_json_variant_unrefp) sd_json_variant *npm = NULL, *positive = NULL, *negative = NULL;
926 _cleanup_free_ sd_json_variant **array = NULL;
927 sd_json_variant *z;
928 size_t i = 0;
929
930 if (!sd_json_variant_is_array(per_machine))
931 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "perMachine field is not an array, refusing.");
932
933 array = new(sd_json_variant*, sd_json_variant_elements(per_machine) + 2);
934 if (!array)
935 return log_oom();
936
937 JSON_VARIANT_ARRAY_FOREACH(z, per_machine) {
938 sd_json_variant *u;
939
940 if (!sd_json_variant_is_object(z))
941 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "perMachine entry is not an object, refusing.");
942
943 array[i++] = z;
944
945 u = sd_json_variant_by_key(z, "matchMachineId");
946 if (u && sd_json_variant_equal(u, mmid))
947 r = sd_json_variant_merge_object(&positive, z);
948 else {
949 u = sd_json_variant_by_key(z, "matchNotMachineId");
950 if (!u || !sd_json_variant_equal(u, mmid))
951 continue;
952
953 r = sd_json_variant_merge_object(&negative, z);
954 }
955 if (r < 0)
956 return log_error_errno(r, "Failed to merge perMachine entry: %m");
957
958 i--;
959 }
960
961 r = sd_json_variant_filter(&positive, arg_identity_filter);
962 if (r < 0)
963 return log_error_errno(r, "Failed to filter perMachine: %m");
964
965 r = sd_json_variant_filter(&negative, arg_identity_filter);
966 if (r < 0)
967 return log_error_errno(r, "Failed to filter perMachine: %m");
968
969 r = sd_json_variant_merge_object(&positive, arg_identity_extra_this_machine);
970 if (r < 0)
971 return log_error_errno(r, "Failed to merge in perMachine fields: %m");
972
973 r = sd_json_variant_merge_object(&negative, arg_identity_extra_other_machines);
974 if (r < 0)
975 return log_error_errno(r, "Failed to merge in perMachine fields: %m");
976
977 if (arg_identity_filter_rlimits || arg_identity_extra_rlimits) {
978 _cleanup_(sd_json_variant_unrefp) sd_json_variant *rlv = NULL;
979
980 rlv = sd_json_variant_ref(sd_json_variant_by_key(positive, "resourceLimits"));
981
982 r = sd_json_variant_filter(&rlv, arg_identity_filter_rlimits);
983 if (r < 0)
984 return log_error_errno(r, "Failed to filter resource limits: %m");
985
986 r = sd_json_variant_merge_object(&rlv, arg_identity_extra_rlimits);
987 if (r < 0)
988 return log_error_errno(r, "Failed to set resource limits: %m");
989
990 if (sd_json_variant_is_blank_object(rlv)) {
991 r = sd_json_variant_filter(&positive, STRV_MAKE("resourceLimits"));
992 if (r < 0)
993 return log_error_errno(r, "Failed to drop resource limits field from identity: %m");
994 } else {
995 r = sd_json_variant_set_field(&positive, "resourceLimits", rlv);
996 if (r < 0)
997 return log_error_errno(r, "Failed to update resource limits of identity: %m");
998 }
999 }
1000
1001 if (!sd_json_variant_is_blank_object(positive)) {
1002 r = sd_json_variant_set_field(&positive, "matchMachineId", mmid);
1003 if (r < 0)
1004 return log_error_errno(r, "Failed to set matchMachineId field: %m");
1005
1006 array[i++] = positive;
1007 }
1008
1009 if (!sd_json_variant_is_blank_object(negative)) {
1010 r = sd_json_variant_set_field(&negative, "matchNotMachineId", mmid);
1011 if (r < 0)
1012 return log_error_errno(r, "Failed to set matchNotMachineId field: %m");
1013
1014 array[i++] = negative;
1015 }
1016
1017 r = sd_json_variant_new_array(&npm, array, i);
1018 if (r < 0)
1019 return log_error_errno(r, "Failed to allocate new perMachine array: %m");
1020
1021 sd_json_variant_unref(per_machine);
1022 per_machine = TAKE_PTR(npm);
1023 } else {
1024 _cleanup_(sd_json_variant_unrefp) sd_json_variant *positive = sd_json_variant_ref(arg_identity_extra_this_machine),
1025 *negative = sd_json_variant_ref(arg_identity_extra_other_machines);
1026
1027 if (arg_identity_extra_rlimits) {
1028 r = sd_json_variant_set_field(&positive, "resourceLimits", arg_identity_extra_rlimits);
1029 if (r < 0)
1030 return log_error_errno(r, "Failed to update resource limits of identity: %m");
1031 }
1032
1033 if (positive) {
1034 r = sd_json_variant_set_field(&positive, "matchMachineId", mmid);
1035 if (r < 0)
1036 return log_error_errno(r, "Failed to set matchMachineId field: %m");
1037
1038 r = sd_json_variant_append_array(&per_machine, positive);
1039 if (r < 0)
1040 return log_error_errno(r, "Failed to append to perMachine array: %m");
1041 }
1042
1043 if (negative) {
1044 r = sd_json_variant_set_field(&negative, "matchNotMachineId", mmid);
1045 if (r < 0)
1046 return log_error_errno(r, "Failed to set matchNotMachineId field: %m");
1047
1048 r = sd_json_variant_append_array(&per_machine, negative);
1049 if (r < 0)
1050 return log_error_errno(r, "Failed to append to perMachine array: %m");
1051 }
1052 }
1053
1054 r = sd_json_variant_set_field(&v, "perMachine", per_machine);
1055 if (r < 0)
1056 return log_error_errno(r, "Failed to update per machine record: %m");
1057 }
1058
1059 if (arg_identity_extra_privileged || arg_identity_filter) {
1060 _cleanup_(sd_json_variant_unrefp) sd_json_variant *privileged = NULL;
1061
1062 privileged = sd_json_variant_ref(sd_json_variant_by_key(v, "privileged"));
1063
1064 r = sd_json_variant_filter(&privileged, arg_identity_filter);
1065 if (r < 0)
1066 return log_error_errno(r, "Failed to filter identity (privileged part): %m");
1067
1068 r = sd_json_variant_merge_object(&privileged, arg_identity_extra_privileged);
1069 if (r < 0)
1070 return log_error_errno(r, "Failed to merge identities (privileged part): %m");
1071
1072 if (sd_json_variant_is_blank_object(privileged)) {
1073 r = sd_json_variant_filter(&v, STRV_MAKE("privileged"));
1074 if (r < 0)
1075 return log_error_errno(r, "Failed to drop privileged part from identity: %m");
1076 } else {
1077 r = sd_json_variant_set_field(&v, "privileged", privileged);
1078 if (r < 0)
1079 return log_error_errno(r, "Failed to update privileged part of identity: %m");
1080 }
1081 }
1082
1083 if (arg_identity_filter_rlimits) {
1084 _cleanup_(sd_json_variant_unrefp) sd_json_variant *rlv = NULL;
1085
1086 rlv = sd_json_variant_ref(sd_json_variant_by_key(v, "resourceLimits"));
1087
1088 r = sd_json_variant_filter(&rlv, arg_identity_filter_rlimits);
1089 if (r < 0)
1090 return log_error_errno(r, "Failed to filter resource limits: %m");
1091
1092 /* Note that we only filter resource limits here, but don't apply them. We do that in the perMachine section */
1093
1094 if (sd_json_variant_is_blank_object(rlv)) {
1095 r = sd_json_variant_filter(&v, STRV_MAKE("resourceLimits"));
1096 if (r < 0)
1097 return log_error_errno(r, "Failed to drop resource limits field from identity: %m");
1098 } else {
1099 r = sd_json_variant_set_field(&v, "resourceLimits", rlv);
1100 if (r < 0)
1101 return log_error_errno(r, "Failed to update resource limits of identity: %m");
1102 }
1103 }
1104
1105 sd_json_variant_unref(*_v);
1106 *_v = TAKE_PTR(v);
1107
1108 return 0;
1109}
1110
1111static int add_disposition(sd_json_variant **v) {
1112 int r;
1113
1114 assert(v);
1115
1116 if (sd_json_variant_by_key(*v, "disposition"))
1117 return 0;
1118
1119 /* Set the disposition to regular, if not configured explicitly */
1120 r = sd_json_variant_set_field_string(v, "disposition", "regular");
1121 if (r < 0)
1122 return log_error_errno(r, "Failed to set disposition field: %m");
1123
1124 return 1;
1125}
1126
1127static int acquire_new_home_record(sd_json_variant *input, UserRecord **ret) {
1128 _cleanup_(sd_json_variant_unrefp) sd_json_variant *v = NULL;
1129 _cleanup_(user_record_unrefp) UserRecord *hr = NULL;
1130 int r;
1131
1132 assert(ret);
1133
1134 if (arg_identity) {
1135 unsigned line = 0, column = 0;
1136
1137 if (input)
1138 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Two identity records specified, refusing.");
1139
1140 r = sd_json_parse_file(
1141 streq(arg_identity, "-") ? stdin : NULL,
1142 streq(arg_identity, "-") ? "<stdin>" : arg_identity, SD_JSON_PARSE_SENSITIVE, &v, &line, &column);
1143 if (r < 0)
1144 return log_error_errno(r, "Failed to parse identity at %u:%u: %m", line, column);
1145 } else
1146 v = sd_json_variant_ref(input);
1147
1148 r = apply_identity_changes(&v);
1149 if (r < 0)
1150 return r;
1151
1152 r = add_disposition(&v);
1153 if (r < 0)
1154 return r;
1155
1156 STRV_FOREACH(i, arg_pkcs11_token_uri) {
1157 r = identity_add_pkcs11_key_data(&v, *i);
1158 if (r < 0)
1159 return r;
1160 }
1161
1162 STRV_FOREACH(i, arg_fido2_device) {
1163 r = identity_add_fido2_parameters(&v, *i, arg_fido2_lock_with, arg_fido2_cred_alg);
1164 if (r < 0)
1165 return r;
1166 }
1167
1168 if (arg_recovery_key) {
1169 r = identity_add_recovery_key(&v);
1170 if (r < 0)
1171 return r;
1172 }
1173
1174 r = update_last_change(&v, true, false);
1175 if (r < 0)
1176 return r;
1177
1178 if (DEBUG_LOGGING)
1179 sd_json_variant_dump(v, SD_JSON_FORMAT_PRETTY, NULL, NULL);
1180
1181 hr = user_record_new();
1182 if (!hr)
1183 return log_oom();
1184
1185 r = user_record_load(
1186 hr,
1187 v,
1188 USER_RECORD_REQUIRE_REGULAR|
1189 USER_RECORD_ALLOW_SECRET|
1190 USER_RECORD_ALLOW_PRIVILEGED|
1191 USER_RECORD_ALLOW_PER_MACHINE|
1192 USER_RECORD_STRIP_BINDING|
1193 USER_RECORD_STRIP_STATUS|
1194 (arg_seize ? USER_RECORD_STRIP_SIGNATURE : USER_RECORD_ALLOW_SIGNATURE) |
1195 USER_RECORD_LOG|
1196 USER_RECORD_PERMISSIVE);
1197 if (r < 0)
1198 return r;
1199
1200 *ret = TAKE_PTR(hr);
1201 return 0;
1202}
1203
1204static int acquire_new_password(
1205 const char *user_name,
1206 UserRecord *hr,
1207 bool suggest,
1208 char **ret) {
1209
1210 _cleanup_(erase_and_freep) char *envpw = NULL;
1211 unsigned i = 5;
1212 int r;
1213
1214 assert(user_name);
1215 assert(hr);
1216
1217 r = getenv_steal_erase("NEWPASSWORD", &envpw);
1218 if (r < 0)
1219 return log_error_errno(r, "Failed to acquire password from environment: %m");
1220 if (r > 0) {
1221 /* As above, this is not for use, just for testing */
1222
1223 r = user_record_set_password(hr, STRV_MAKE(envpw), /* prepend = */ true);
1224 if (r < 0)
1225 return log_error_errno(r, "Failed to store password: %m");
1226
1227 if (ret)
1228 *ret = TAKE_PTR(envpw);
1229
1230 return 0;
1231 }
1232
1233 if (suggest)
1234 (void) suggest_passwords();
1235
1236 for (;;) {
1237 _cleanup_strv_free_erase_ char **first = NULL, **second = NULL;
1238 _cleanup_free_ char *question = NULL;
1239
1240 if (--i == 0)
1241 return log_error_errno(SYNTHETIC_ERRNO(ENOKEY), "Too many attempts, giving up.");
1242
1243 if (asprintf(&question, "Please enter new password for user %s:", user_name) < 0)
1244 return log_oom();
1245
1246 AskPasswordRequest req = {
1247 .tty_fd = -EBADF,
1248 .message = question,
1249 .icon = "user-home",
1250 .keyring = "home-password",
1251 .credential = "home.new-password",
1252 .until = USEC_INFINITY,
1253 .hup_fd = -EBADF,
1254 };
1255
1256 r = ask_password_auto(
1257 &req,
1258 /* flags= */ 0, /* no caching, we want to collect a new password here after all */
1259 &first);
1260 if (r < 0)
1261 return log_error_errno(r, "Failed to acquire password: %m");
1262
1263 assert(!strv_isempty(first));
1264
1265 question = mfree(question);
1266 if (asprintf(&question, "Please enter new password for user %s (repeat):", user_name) < 0)
1267 return log_oom();
1268
1269 req.message = question;
1270
1271 r = ask_password_auto(
1272 &req,
1273 /* flags= */ 0, /* no caching */
1274 &second);
1275 if (r < 0)
1276 return log_error_errno(r, "Failed to acquire password: %m");
1277
1278 if (strv_equal(first, second)) {
1279 _cleanup_(erase_and_freep) char *copy = NULL;
1280
1281 if (ret) {
1282 copy = strdup(first[0]);
1283 if (!copy)
1284 return log_oom();
1285 }
1286
1287 r = user_record_set_password(hr, first, /* prepend = */ true);
1288 if (r < 0)
1289 return log_error_errno(r, "Failed to store password: %m");
1290
1291 if (ret)
1292 *ret = TAKE_PTR(copy);
1293
1294 return 0;
1295 }
1296
1297 log_error("Password didn't match, try again.");
1298 }
1299}
1300
1301static int acquire_merged_blob_dir(UserRecord *hr, bool existing, Hashmap **ret) {
1302 _cleanup_free_ char *sys_blob_path = NULL;
1303 _cleanup_hashmap_free_ Hashmap *blobs = NULL;
1304 _cleanup_closedir_ DIR *d = NULL;
1305 const char *src_blob_path, *filename;
1306 void *fd_ptr;
1307 int r;
1308
1309 assert(ret);
1310
1311 HASHMAP_FOREACH_KEY(fd_ptr, filename, arg_blob_files) {
1312 _cleanup_free_ char *filename_dup = NULL;
1313 _cleanup_close_ int fd_dup = -EBADF;
1314
1315 filename_dup = strdup(filename);
1316 if (!filename_dup)
1317 return log_oom();
1318
1319 if (PTR_TO_FD(fd_ptr) != -EBADF) {
1320 fd_dup = fcntl(PTR_TO_FD(fd_ptr), F_DUPFD_CLOEXEC, 3);
1321 if (fd_dup < 0)
1322 return log_error_errno(errno, "Failed to duplicate fd of %s: %m", filename);
1323 }
1324
1325 r = hashmap_ensure_put(&blobs, &blob_fd_hash_ops, filename_dup, FD_TO_PTR(fd_dup));
1326 if (r < 0)
1327 return r;
1328 TAKE_PTR(filename_dup); /* Ownership transferred to hashmap */
1329 TAKE_FD(fd_dup);
1330 }
1331
1332 if (arg_blob_dir)
1333 src_blob_path = arg_blob_dir;
1334 else if (existing && !arg_blob_clear) {
1335 if (hr->blob_directory)
1336 src_blob_path = hr->blob_directory;
1337 else {
1338 /* This isn't technically a correct thing to do for generic user records,
1339 * so anyone looking at this code for reference shouldn't replicate it.
1340 * However, since homectl is tied to homed, this is OK. This adds robustness
1341 * for situations where the user record is coming directly from the CLI and
1342 * thus doesn't have a blobDirectory set */
1343
1344 sys_blob_path = path_join(home_system_blob_dir(), hr->user_name);
1345 if (!sys_blob_path)
1346 return log_oom();
1347
1348 src_blob_path = sys_blob_path;
1349 }
1350 } else
1351 goto nodir; /* Shortcut: no dir to merge with, so just return copy of arg_blob_files */
1352
1353 d = opendir(src_blob_path);
1354 if (!d)
1355 return log_error_errno(errno, "Failed to open %s: %m", src_blob_path);
1356
1357 FOREACH_DIRENT_ALL(de, d, return log_error_errno(errno, "Failed to read %s: %m", src_blob_path)) {
1358 _cleanup_free_ char *name = NULL;
1359 _cleanup_close_ int fd = -EBADF;
1360
1361 if (dot_or_dot_dot(de->d_name))
1362 continue;
1363
1364 if (hashmap_contains(blobs, de->d_name))
1365 continue; /* arg_blob_files should override the base dir */
1366
1367 if (!suitable_blob_filename(de->d_name)) {
1368 log_warning("File %s in blob directory %s has an invalid filename. Skipping.", de->d_name, src_blob_path);
1369 continue;
1370 }
1371
1372 name = strdup(de->d_name);
1373 if (!name)
1374 return log_oom();
1375
1376 fd = openat(dirfd(d), de->d_name, O_RDONLY|O_CLOEXEC|O_NOCTTY);
1377 if (fd < 0)
1378 return log_error_errno(errno, "Failed to open %s in %s: %m", de->d_name, src_blob_path);
1379
1380 r = fd_verify_regular(fd);
1381 if (r < 0) {
1382 log_warning_errno(r, "Entry %s in blob directory %s is not a regular file. Skipping.", de->d_name, src_blob_path);
1383 continue;
1384 }
1385
1386 r = hashmap_ensure_put(&blobs, &blob_fd_hash_ops, name, FD_TO_PTR(fd));
1387 if (r < 0)
1388 return r;
1389 TAKE_PTR(name); /* Ownership transferred to hashmap */
1390 TAKE_FD(fd);
1391 }
1392
1393nodir:
1394 *ret = TAKE_PTR(blobs);
1395 return 0;
1396}
1397
1398static int bus_message_append_blobs(sd_bus_message *m, Hashmap *blobs) {
1399 const char *filename;
1400 void *fd_ptr;
1401 int r;
1402
1403 assert(m);
1404
1405 r = sd_bus_message_open_container(m, 'a', "{sh}");
1406 if (r < 0)
1407 return r;
1408
1409 HASHMAP_FOREACH_KEY(fd_ptr, filename, blobs) {
1410 int fd = PTR_TO_FD(fd_ptr);
1411
1412 if (fd == -EBADF) /* File marked for deletion */
1413 continue;
1414
1415 r = sd_bus_message_append(m, "{sh}", filename, fd);
1416 if (r < 0)
1417 return r;
1418 }
1419
1420 return sd_bus_message_close_container(m);
1421}
1422
1423static int create_home_common(sd_json_variant *input, bool show_enforce_password_policy_hint) {
1424 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
1425 _cleanup_(user_record_unrefp) UserRecord *hr = NULL;
1426 _cleanup_hashmap_free_ Hashmap *blobs = NULL;
1427 int r;
1428
1429 r = acquire_new_home_record(input, &hr);
1430 if (r < 0)
1431 return r;
1432
1433 r = acquire_merged_blob_dir(hr, false, &blobs);
1434 if (r < 0)
1435 return r;
1436
1437 /* If the JSON record carries no plain text password (besides the recovery key), then let's query it
1438 * manually. */
1439 if (strv_length(hr->password) <= arg_recovery_key) {
1440
1441 if (strv_isempty(hr->hashed_password)) {
1442 _cleanup_(erase_and_freep) char *new_password = NULL;
1443
1444 /* No regular (i.e. non-PKCS#11) hashed passwords set in the record, let's fix that. */
1445 r = acquire_new_password(hr->user_name, hr, /* suggest = */ true, &new_password);
1446 if (r < 0)
1447 return r;
1448
1449 r = user_record_make_hashed_password(hr, STRV_MAKE(new_password), /* extend = */ false);
1450 if (r < 0)
1451 return log_error_errno(r, "Failed to hash password: %m");
1452 } else {
1453 /* There's a hash password set in the record, acquire the unhashed version of it. */
1454 r = acquire_existing_password(
1455 hr->user_name,
1456 hr,
1457 /* emphasize_current_password= */ false,
1458 ASK_PASSWORD_ACCEPT_CACHED | ASK_PASSWORD_PUSH_CACHE);
1459 if (r < 0)
1460 return r;
1461 }
1462 }
1463
1464 if (hr->enforce_password_policy == 0) {
1465 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
1466
1467 /* If password quality enforcement is disabled, let's at least warn client side */
1468
1469 r = user_record_check_password_quality(hr, hr, &error);
1470 if (r < 0)
1471 log_warning_errno(r, "Specified password does not pass quality checks (%s), proceeding anyway.", bus_error_message(&error, r));
1472 }
1473
1474 if (arg_dry_run) {
1475 sd_json_variant_dump(hr->json, SD_JSON_FORMAT_COLOR_AUTO|SD_JSON_FORMAT_PRETTY_AUTO|SD_JSON_FORMAT_NEWLINE, stderr, /* prefix= */ NULL);
1476 return 0;
1477 }
1478
1479 r = acquire_bus(&bus);
1480 if (r < 0)
1481 return r;
1482
1483 (void) polkit_agent_open_if_enabled(arg_transport, arg_ask_password);
1484
1485 for (;;) {
1486 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
1487 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
1488 _cleanup_(erase_and_freep) char *formatted = NULL;
1489
1490 r = sd_json_variant_format(hr->json, 0, &formatted);
1491 if (r < 0)
1492 return log_error_errno(r, "Failed to format user record: %m");
1493
1494 r = bus_message_new_method_call(bus, &m, bus_mgr, "CreateHomeEx");
1495 if (r < 0)
1496 return bus_log_create_error(r);
1497
1498 (void) sd_bus_message_sensitive(m);
1499
1500 r = sd_bus_message_append(m, "s", formatted);
1501 if (r < 0)
1502 return bus_log_create_error(r);
1503
1504 r = bus_message_append_blobs(m, blobs);
1505 if (r < 0)
1506 return bus_log_create_error(r);
1507
1508 r = sd_bus_message_append(m, "t", UINT64_C(0));
1509 if (r < 0)
1510 return bus_log_create_error(r);
1511
1512 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
1513 if (r < 0) {
1514 if (sd_bus_error_has_name(&error, BUS_ERROR_LOW_PASSWORD_QUALITY)) {
1515 _cleanup_(erase_and_freep) char *new_password = NULL;
1516
1517 log_error_errno(r, "%s", bus_error_message(&error, r));
1518 if (show_enforce_password_policy_hint)
1519 log_info("(Use --enforce-password-policy=no to turn off password quality checks for this account.)");
1520
1521 r = acquire_new_password(hr->user_name, hr, /* suggest = */ false, &new_password);
1522 if (r < 0)
1523 return r;
1524
1525 r = user_record_make_hashed_password(hr, STRV_MAKE(new_password), /* extend = */ false);
1526 if (r < 0)
1527 return log_error_errno(r, "Failed to hash passwords: %m");
1528 } else {
1529 r = handle_generic_user_record_error(hr->user_name, hr, &error, r, false);
1530 if (r < 0)
1531 return r;
1532 }
1533 } else
1534 break; /* done */
1535 }
1536
1537 return 0;
1538}
1539
1540static int create_home(int argc, char *argv[], void *userdata) {
1541 int r;
1542
1543 if (argc >= 2) {
1544 /* If a username was specified, use it */
1545
1546 if (valid_user_group_name(argv[1], 0))
1547 r = sd_json_variant_set_field_string(&arg_identity_extra, "userName", argv[1]);
1548 else {
1549 _cleanup_free_ char *un = NULL, *rr = NULL;
1550
1551 /* Before we consider the user name invalid, let's check if we can split it? */
1552 r = split_user_name_realm(argv[1], &un, &rr);
1553 if (r < 0)
1554 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "User name '%s' is not valid.", argv[1]);
1555
1556 if (rr) {
1557 r = sd_json_variant_set_field_string(&arg_identity_extra, "realm", rr);
1558 if (r < 0)
1559 return log_error_errno(r, "Failed to set realm field: %m");
1560 }
1561
1562 r = sd_json_variant_set_field_string(&arg_identity_extra, "userName", un);
1563 }
1564 if (r < 0)
1565 return log_error_errno(r, "Failed to set userName field: %m");
1566 } else {
1567 /* If neither a username nor an identity have been specified we cannot operate. */
1568 if (!arg_identity)
1569 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "User name required.");
1570 }
1571
1572 return create_home_common(/* input= */ NULL, /* show_enforce_password_policy_hint= */ true);
1573}
1574
1575static int verb_adopt_home(int argc, char *argv[], void *userdata) {
1576 int r, ret = 0;
1577
1578 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
1579 r = acquire_bus(&bus);
1580 if (r < 0)
1581 return r;
1582
1583 (void) polkit_agent_open_if_enabled(arg_transport, arg_ask_password);
1584
1585 STRV_FOREACH(i, strv_skip(argv, 1)) {
1586 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
1587 r = bus_message_new_method_call(bus, &m, bus_mgr, "AdoptHome");
1588 if (r < 0)
1589 return bus_log_create_error(r);
1590
1591 r = sd_bus_message_append(m, "st", *i, UINT64_C(0));
1592 if (r < 0)
1593 return bus_log_create_error(r);
1594
1595 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
1596 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
1597 if (r < 0) {
1598 log_error_errno(r, "Failed to adopt home: %s", bus_error_message(&error, r));
1599 if (ret == 0)
1600 ret = r;
1601 }
1602 }
1603
1604 return ret;
1605}
1606
1607static int register_home_common(sd_bus *bus, sd_json_variant *v) {
1608 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *_bus = NULL;
1609 int r;
1610
1611 assert(v);
1612
1613 if (!bus) {
1614 r = acquire_bus(&_bus);
1615 if (r < 0)
1616 return r;
1617 bus = _bus;
1618 }
1619
1620 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
1621 r = bus_message_new_method_call(bus, &m, bus_mgr, "RegisterHome");
1622 if (r < 0)
1623 return bus_log_create_error(r);
1624
1625 _cleanup_free_ char *formatted = NULL;
1626 r = sd_json_variant_format(v, /* flags= */ 0, &formatted);
1627 if (r < 0)
1628 return log_error_errno(r, "Failed to format JSON record: %m");
1629
1630 r = sd_bus_message_append(m, "s", formatted);
1631 if (r < 0)
1632 return bus_log_create_error(r);
1633
1634 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
1635 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
1636 if (r < 0)
1637 return log_error_errno(r, "Failed to register home: %s", bus_error_message(&error, r));
1638
1639 return 0;
1640}
1641
1642static int register_home_one(sd_bus *bus, FILE *f, const char *path) {
1643 int r;
1644
1645 assert(bus);
1646 assert(path);
1647
1648 _cleanup_(sd_json_variant_unrefp) sd_json_variant *v = NULL;
1649 unsigned line = 0, column = 0;
1650 r = sd_json_parse_file(f, path, SD_JSON_PARSE_SENSITIVE, &v, &line, &column);
1651 if (r < 0)
1652 return log_error_errno(r, "[%s:%u:%u] Failed to parse user record: %m", path, line, column);
1653
1654 return register_home_common(bus, v);
1655}
1656
1657static int verb_register_home(int argc, char *argv[], void *userdata) {
1658 int r;
1659
1660 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
1661 r = acquire_bus(&bus);
1662 if (r < 0)
1663 return r;
1664
1665 (void) polkit_agent_open_if_enabled(arg_transport, arg_ask_password);
1666
1667 if (arg_identity) {
1668 if (argc > 1)
1669 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Not accepting an arguments if --identity= is specified, refusing.");
1670
1671 return register_home_one(bus, /* f= */ NULL, arg_identity);
1672 }
1673
1674 if (argc == 1 || (argc == 2 && streq(argv[1], "-")))
1675 return register_home_one(bus, /* f= */ stdin, "<stdio>");
1676
1677 r = 0;
1678 STRV_FOREACH(i, strv_skip(argv, 1)) {
1679 if (streq(*i, "-"))
1680 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Refusing reading from standard input if multiple user records are specified.");
1681
1682 RET_GATHER(r, register_home_one(bus, /* f= */ NULL, *i));
1683 }
1684
1685 return r;
1686}
1687
1688static int verb_unregister_home(int argc, char *argv[], void *userdata) {
1689 int r;
1690
1691 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
1692 r = acquire_bus(&bus);
1693 if (r < 0)
1694 return r;
1695
1696 (void) polkit_agent_open_if_enabled(arg_transport, arg_ask_password);
1697
1698 int ret = 0;
1699 STRV_FOREACH(i, strv_skip(argv, 1)) {
1700 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
1701 r = bus_message_new_method_call(bus, &m, bus_mgr, "UnregisterHome");
1702 if (r < 0)
1703 return bus_log_create_error(r);
1704
1705 r = sd_bus_message_append(m, "s", *i);
1706 if (r < 0)
1707 return bus_log_create_error(r);
1708
1709 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
1710 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, /* ret_reply= */ NULL);
1711 if (r < 0)
1712 RET_GATHER(ret, log_error_errno(r, "Failed to unregister home: %s", bus_error_message(&error, r)));
1713 }
1714
1715 return ret;
1716}
1717
1718static int remove_home(int argc, char *argv[], void *userdata) {
1719 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
1720 int r, ret = 0;
1721
1722 r = acquire_bus(&bus);
1723 if (r < 0)
1724 return r;
1725
1726 (void) polkit_agent_open_if_enabled(arg_transport, arg_ask_password);
1727
1728 STRV_FOREACH(i, strv_skip(argv, 1)) {
1729 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
1730 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
1731
1732 r = bus_message_new_method_call(bus, &m, bus_mgr, "RemoveHome");
1733 if (r < 0)
1734 return bus_log_create_error(r);
1735
1736 r = sd_bus_message_append(m, "s", *i);
1737 if (r < 0)
1738 return bus_log_create_error(r);
1739
1740 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
1741 if (r < 0) {
1742 log_error_errno(r, "Failed to remove home: %s", bus_error_message(&error, r));
1743 if (ret == 0)
1744 ret = r;
1745 }
1746 }
1747
1748 return ret;
1749}
1750
1751static int acquire_updated_home_record(
1752 sd_bus *bus,
1753 const char *username,
1754 UserRecord **ret) {
1755
1756 _cleanup_(sd_json_variant_unrefp) sd_json_variant *json = NULL;
1757 _cleanup_(user_record_unrefp) UserRecord *hr = NULL;
1758 int r;
1759
1760 assert(ret);
1761
1762 if (arg_identity) {
1763 unsigned line = 0, column = 0;
1764 sd_json_variant *un;
1765
1766 r = sd_json_parse_file(
1767 streq(arg_identity, "-") ? stdin : NULL,
1768 streq(arg_identity, "-") ? "<stdin>" : arg_identity, SD_JSON_PARSE_SENSITIVE, &json, &line, &column);
1769 if (r < 0)
1770 return log_error_errno(r, "Failed to parse identity at %u:%u: %m", line, column);
1771
1772 un = sd_json_variant_by_key(json, "userName");
1773 if (un) {
1774 if (!sd_json_variant_is_string(un) || (username && !streq(sd_json_variant_string(un), username)))
1775 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "User name specified on command line and in JSON record do not match.");
1776 } else {
1777 if (!username)
1778 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "No username specified.");
1779
1780 r = sd_json_variant_set_field_string(&arg_identity_extra, "userName", username);
1781 if (r < 0)
1782 return log_error_errno(r, "Failed to set userName field: %m");
1783 }
1784
1785 } else {
1786 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
1787 _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
1788 int incomplete;
1789 const char *text;
1790
1791 if (!identity_properties_specified())
1792 return log_error_errno(SYNTHETIC_ERRNO(EALREADY), "No field to change specified.");
1793
1794 r = bus_call_method(bus, bus_mgr, "GetUserRecordByName", &error, &reply, "s", username);
1795 if (r < 0)
1796 return log_error_errno(r, "Failed to acquire user home record: %s", bus_error_message(&error, r));
1797
1798 r = sd_bus_message_read(reply, "sbo", &text, &incomplete, NULL);
1799 if (r < 0)
1800 return bus_log_parse_error(r);
1801
1802 if (incomplete)
1803 return log_error_errno(SYNTHETIC_ERRNO(EACCES), "Lacking rights to acquire user record including privileged metadata, can't update record.");
1804
1805 r = sd_json_parse(text, SD_JSON_PARSE_SENSITIVE, &json, NULL, NULL);
1806 if (r < 0)
1807 return log_error_errno(r, "Failed to parse JSON identity: %m");
1808
1809 reply = sd_bus_message_unref(reply);
1810
1811 r = sd_json_variant_filter(&json, STRV_MAKE("binding", "status", "signature", "blobManifest"));
1812 if (r < 0)
1813 return log_error_errno(r, "Failed to strip binding and status from record to update: %m");
1814 }
1815
1816 r = apply_identity_changes(&json);
1817 if (r < 0)
1818 return r;
1819
1820 STRV_FOREACH(i, arg_pkcs11_token_uri) {
1821 r = identity_add_pkcs11_key_data(&json, *i);
1822 if (r < 0)
1823 return r;
1824 }
1825
1826 STRV_FOREACH(i, arg_fido2_device) {
1827 r = identity_add_fido2_parameters(&json, *i, arg_fido2_lock_with, arg_fido2_cred_alg);
1828 if (r < 0)
1829 return r;
1830 }
1831
1832 if (arg_recovery_key) {
1833 r = identity_add_recovery_key(&json);
1834 if (r < 0)
1835 return r;
1836 }
1837
1838 /* If the user supplied a full record, then add in lastChange, but do not override. Otherwise always
1839 * override. */
1840 r = update_last_change(&json, arg_pkcs11_token_uri || arg_fido2_device || arg_recovery_key, !arg_identity);
1841 if (r < 0)
1842 return r;
1843
1844 if (DEBUG_LOGGING)
1845 sd_json_variant_dump(json, SD_JSON_FORMAT_PRETTY, NULL, NULL);
1846
1847 hr = user_record_new();
1848 if (!hr)
1849 return log_oom();
1850
1851 r = user_record_load(hr, json, USER_RECORD_REQUIRE_REGULAR|USER_RECORD_ALLOW_PRIVILEGED|USER_RECORD_ALLOW_PER_MACHINE|USER_RECORD_ALLOW_SECRET|USER_RECORD_ALLOW_SIGNATURE|USER_RECORD_LOG|USER_RECORD_PERMISSIVE);
1852 if (r < 0)
1853 return r;
1854
1855 *ret = TAKE_PTR(hr);
1856 return 0;
1857}
1858
1859static int home_record_reset_human_interaction_permission(UserRecord *hr) {
1860 int r;
1861
1862 assert(hr);
1863
1864 /* When we execute multiple operations one after the other, let's reset the permission to ask the
1865 * user each time, so that if interaction is necessary we will be told so again and thus can print a
1866 * nice message to the user, telling the user so. */
1867
1868 r = user_record_set_pkcs11_protected_authentication_path_permitted(hr, -1);
1869 if (r < 0)
1870 return log_error_errno(r, "Failed to reset PKCS#11 protected authentication path permission flag: %m");
1871
1872 r = user_record_set_fido2_user_presence_permitted(hr, -1);
1873 if (r < 0)
1874 return log_error_errno(r, "Failed to reset FIDO2 user presence permission flag: %m");
1875
1876 r = user_record_set_fido2_user_verification_permitted(hr, -1);
1877 if (r < 0)
1878 return log_error_errno(r, "Failed to reset FIDO2 user verification permission flag: %m");
1879
1880 return 0;
1881}
1882
1883static int update_home(int argc, char *argv[], void *userdata) {
1884 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
1885 _cleanup_(user_record_unrefp) UserRecord *hr = NULL, *secret = NULL;
1886 _cleanup_free_ char *buffer = NULL;
1887 _cleanup_hashmap_free_ Hashmap *blobs = NULL;
1888 const char *username;
1889 uint64_t flags = 0;
1890 int r;
1891
1892 if (argc >= 2)
1893 username = argv[1];
1894 else if (!arg_identity) {
1895 buffer = getusername_malloc();
1896 if (!buffer)
1897 return log_oom();
1898
1899 username = buffer;
1900 } else
1901 username = NULL;
1902
1903 r = acquire_bus(&bus);
1904 if (r < 0)
1905 return r;
1906
1907 (void) polkit_agent_open_if_enabled(arg_transport, arg_ask_password);
1908
1909 r = acquire_updated_home_record(bus, username, &hr);
1910 if (r < 0)
1911 return r;
1912
1913 /* Add in all secrets we can acquire cheaply */
1914 r = acquire_passed_secrets(username, &secret);
1915 if (r < 0)
1916 return r;
1917
1918 r = user_record_merge_secret(hr, secret);
1919 if (r < 0)
1920 return r;
1921
1922 r = acquire_merged_blob_dir(hr, true, &blobs);
1923 if (r < 0)
1924 return r;
1925
1926 if (arg_dry_run) {
1927 sd_json_variant_dump(hr->json, SD_JSON_FORMAT_COLOR_AUTO|SD_JSON_FORMAT_PRETTY_AUTO|SD_JSON_FORMAT_NEWLINE, stderr, /* prefix= */ NULL);
1928 return 0;
1929 }
1930
1931 /* If we do multiple operations, let's output things more verbosely, since otherwise the repeated
1932 * authentication might be confusing. */
1933
1934 if (arg_and_resize || arg_and_change_password)
1935 log_info("Updating home directory.");
1936
1937 if (arg_offline)
1938 flags |= SD_HOMED_UPDATE_OFFLINE;
1939
1940 for (;;) {
1941 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
1942 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
1943 _cleanup_free_ char *formatted = NULL;
1944
1945 r = bus_message_new_method_call(bus, &m, bus_mgr, "UpdateHomeEx");
1946 if (r < 0)
1947 return bus_log_create_error(r);
1948
1949 r = sd_json_variant_format(hr->json, 0, &formatted);
1950 if (r < 0)
1951 return log_error_errno(r, "Failed to format user record: %m");
1952
1953 (void) sd_bus_message_sensitive(m);
1954
1955 r = sd_bus_message_append(m, "s", formatted);
1956 if (r < 0)
1957 return bus_log_create_error(r);
1958
1959 r = bus_message_append_blobs(m, blobs);
1960 if (r < 0)
1961 return bus_log_create_error(r);
1962
1963 r = sd_bus_message_append(m, "t", flags);
1964 if (r < 0)
1965 return bus_log_create_error(r);
1966
1967 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
1968 if (r < 0) {
1969 if (arg_and_change_password &&
1970 sd_bus_error_has_name(&error, BUS_ERROR_BAD_PASSWORD_AND_NO_TOKEN))
1971 /* In the generic handler we'd ask for a password in this case, but when
1972 * changing passwords that's not sufficient, as we need to acquire all keys
1973 * first. */
1974 return log_error_errno(r, "Security token not inserted, refusing.");
1975
1976 r = handle_generic_user_record_error(hr->user_name, hr, &error, r, false);
1977 if (r < 0)
1978 return r;
1979 } else
1980 break;
1981 }
1982
1983 if (arg_and_resize)
1984 log_info("Resizing home.");
1985
1986 (void) home_record_reset_human_interaction_permission(hr);
1987
1988 /* Also sync down disk size to underlying LUKS/fscrypt/quota */
1989 while (arg_and_resize) {
1990 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
1991 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
1992
1993 r = bus_message_new_method_call(bus, &m, bus_mgr, "ResizeHome");
1994 if (r < 0)
1995 return bus_log_create_error(r);
1996
1997 /* Specify UINT64_MAX as size, in which case the underlying disk size will just be synced */
1998 r = sd_bus_message_append(m, "st", hr->user_name, UINT64_MAX);
1999 if (r < 0)
2000 return bus_log_create_error(r);
2001
2002 r = bus_message_append_secret(m, hr);
2003 if (r < 0)
2004 return bus_log_create_error(r);
2005
2006 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
2007 if (r < 0) {
2008 if (arg_and_change_password &&
2009 sd_bus_error_has_name(&error, BUS_ERROR_BAD_PASSWORD_AND_NO_TOKEN))
2010 return log_error_errno(r, "Security token not inserted, refusing.");
2011
2012 r = handle_generic_user_record_error(hr->user_name, hr, &error, r, false);
2013 if (r < 0)
2014 return r;
2015 } else
2016 break;
2017 }
2018
2019 if (arg_and_change_password)
2020 log_info("Synchronizing passwords and encryption keys.");
2021
2022 (void) home_record_reset_human_interaction_permission(hr);
2023
2024 /* Also sync down passwords to underlying LUKS/fscrypt */
2025 while (arg_and_change_password) {
2026 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
2027 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
2028
2029 r = bus_message_new_method_call(bus, &m, bus_mgr, "ChangePasswordHome");
2030 if (r < 0)
2031 return bus_log_create_error(r);
2032
2033 /* Specify an empty new secret, in which case the underlying LUKS/fscrypt password will just be synced */
2034 r = sd_bus_message_append(m, "ss", hr->user_name, "{}");
2035 if (r < 0)
2036 return bus_log_create_error(r);
2037
2038 r = bus_message_append_secret(m, hr);
2039 if (r < 0)
2040 return bus_log_create_error(r);
2041
2042 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
2043 if (r < 0) {
2044 if (sd_bus_error_has_name(&error, BUS_ERROR_BAD_PASSWORD_AND_NO_TOKEN))
2045 return log_error_errno(r, "Security token not inserted, refusing.");
2046
2047 r = handle_generic_user_record_error(hr->user_name, hr, &error, r, false);
2048 if (r < 0)
2049 return r;
2050 } else
2051 break;
2052 }
2053
2054 return 0;
2055}
2056
2057static int passwd_home(int argc, char *argv[], void *userdata) {
2058 _cleanup_(user_record_unrefp) UserRecord *old_secret = NULL, *new_secret = NULL;
2059 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
2060 _cleanup_free_ char *buffer = NULL;
2061 const char *username;
2062 int r;
2063
2064 if (arg_pkcs11_token_uri)
2065 return log_error_errno(SYNTHETIC_ERRNO(EINVAL),
2066 "To change the PKCS#11 security token use 'homectl update --pkcs11-token-uri=%s'.",
2067 glyph(GLYPH_ELLIPSIS));
2068 if (arg_fido2_device)
2069 return log_error_errno(SYNTHETIC_ERRNO(EINVAL),
2070 "To change the FIDO2 security token use 'homectl update --fido2-device=%s'.",
2071 glyph(GLYPH_ELLIPSIS));
2072 if (identity_properties_specified())
2073 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "The 'passwd' verb does not permit changing other record properties at the same time.");
2074
2075 if (argc >= 2)
2076 username = argv[1];
2077 else {
2078 buffer = getusername_malloc();
2079 if (!buffer)
2080 return log_oom();
2081
2082 username = buffer;
2083 }
2084
2085 r = acquire_bus(&bus);
2086 if (r < 0)
2087 return r;
2088
2089 (void) polkit_agent_open_if_enabled(arg_transport, arg_ask_password);
2090
2091 r = acquire_passed_secrets(username, &old_secret);
2092 if (r < 0)
2093 return r;
2094
2095 new_secret = user_record_new();
2096 if (!new_secret)
2097 return log_oom();
2098
2099 r = acquire_new_password(username, new_secret, /* suggest = */ true, NULL);
2100 if (r < 0)
2101 return r;
2102
2103 for (;;) {
2104 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
2105 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
2106
2107 r = bus_message_new_method_call(bus, &m, bus_mgr, "ChangePasswordHome");
2108 if (r < 0)
2109 return bus_log_create_error(r);
2110
2111 r = sd_bus_message_append(m, "s", username);
2112 if (r < 0)
2113 return bus_log_create_error(r);
2114
2115 r = bus_message_append_secret(m, new_secret);
2116 if (r < 0)
2117 return bus_log_create_error(r);
2118
2119 r = bus_message_append_secret(m, old_secret);
2120 if (r < 0)
2121 return bus_log_create_error(r);
2122
2123 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
2124 if (r < 0) {
2125 if (sd_bus_error_has_name(&error, BUS_ERROR_LOW_PASSWORD_QUALITY)) {
2126
2127 log_error_errno(r, "%s", bus_error_message(&error, r));
2128
2129 r = acquire_new_password(username, new_secret, /* suggest = */ false, NULL);
2130
2131 } else if (sd_bus_error_has_name(&error, BUS_ERROR_BAD_PASSWORD_AND_NO_TOKEN))
2132
2133 /* In the generic handler we'd ask for a password in this case, but when
2134 * changing passwords that's not sufficeint, as we need to acquire all keys
2135 * first. */
2136 return log_error_errno(r, "Security token not inserted, refusing.");
2137 else
2138 r = handle_generic_user_record_error(username, old_secret, &error, r, true);
2139 if (r < 0)
2140 return r;
2141 } else
2142 break;
2143 }
2144
2145 return 0;
2146}
2147
2148static int parse_disk_size(const char *t, uint64_t *ret) {
2149 int r;
2150
2151 assert(t);
2152 assert(ret);
2153
2154 if (streq(t, "min"))
2155 *ret = 0;
2156 else if (streq(t, "max"))
2157 *ret = UINT64_MAX-1; /* Largest size that isn't UINT64_MAX special marker */
2158 else {
2159 uint64_t ds;
2160
2161 r = parse_size(t, 1024, &ds);
2162 if (r < 0)
2163 return log_error_errno(r, "Failed to parse disk size parameter: %s", t);
2164
2165 if (ds >= UINT64_MAX) /* UINT64_MAX has special meaning for us ("dont change"), refuse */
2166 return log_error_errno(SYNTHETIC_ERRNO(ERANGE), "Disk size out of range: %s", t);
2167
2168 *ret = ds;
2169 }
2170
2171 return 0;
2172}
2173
2174static int resize_home(int argc, char *argv[], void *userdata) {
2175 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
2176 _cleanup_(user_record_unrefp) UserRecord *secret = NULL;
2177 uint64_t ds = UINT64_MAX;
2178 int r;
2179
2180 r = acquire_bus(&bus);
2181 if (r < 0)
2182 return r;
2183
2184 (void) polkit_agent_open_if_enabled(arg_transport, arg_ask_password);
2185
2186 if (arg_disk_size_relative != UINT64_MAX ||
2187 (argc > 2 && parse_permyriad(argv[2]) >= 0))
2188 return log_error_errno(SYNTHETIC_ERRNO(EOPNOTSUPP),
2189 "Relative disk size specification currently not supported when resizing.");
2190
2191 if (argc > 2) {
2192 r = parse_disk_size(argv[2], &ds);
2193 if (r < 0)
2194 return r;
2195 }
2196
2197 if (arg_disk_size != UINT64_MAX) {
2198 if (ds != UINT64_MAX && ds != arg_disk_size)
2199 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Disk size specified twice and doesn't match, refusing.");
2200
2201 ds = arg_disk_size;
2202 }
2203
2204 r = acquire_passed_secrets(argv[1], &secret);
2205 if (r < 0)
2206 return r;
2207
2208 for (;;) {
2209 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
2210 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
2211
2212 r = bus_message_new_method_call(bus, &m, bus_mgr, "ResizeHome");
2213 if (r < 0)
2214 return bus_log_create_error(r);
2215
2216 r = sd_bus_message_append(m, "st", argv[1], ds);
2217 if (r < 0)
2218 return bus_log_create_error(r);
2219
2220 r = bus_message_append_secret(m, secret);
2221 if (r < 0)
2222 return bus_log_create_error(r);
2223
2224 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
2225 if (r < 0) {
2226 r = handle_generic_user_record_error(argv[1], secret, &error, r, false);
2227 if (r < 0)
2228 return r;
2229 } else
2230 break;
2231 }
2232
2233 return 0;
2234}
2235
2236static int lock_home(int argc, char *argv[], void *userdata) {
2237 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
2238 int r, ret = 0;
2239
2240 r = acquire_bus(&bus);
2241 if (r < 0)
2242 return r;
2243
2244 STRV_FOREACH(i, strv_skip(argv, 1)) {
2245 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
2246 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
2247
2248 r = bus_message_new_method_call(bus, &m, bus_mgr, "LockHome");
2249 if (r < 0)
2250 return bus_log_create_error(r);
2251
2252 r = sd_bus_message_append(m, "s", *i);
2253 if (r < 0)
2254 return bus_log_create_error(r);
2255
2256 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
2257 if (r < 0) {
2258 log_error_errno(r, "Failed to lock home: %s", bus_error_message(&error, r));
2259 if (ret == 0)
2260 ret = r;
2261 }
2262 }
2263
2264 return ret;
2265}
2266
2267static int unlock_home(int argc, char *argv[], void *userdata) {
2268 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
2269 int r, ret = 0;
2270
2271 r = acquire_bus(&bus);
2272 if (r < 0)
2273 return r;
2274
2275 STRV_FOREACH(i, strv_skip(argv, 1)) {
2276 _cleanup_(user_record_unrefp) UserRecord *secret = NULL;
2277
2278 r = acquire_passed_secrets(*i, &secret);
2279 if (r < 0)
2280 return r;
2281
2282 for (;;) {
2283 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
2284 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
2285
2286 r = bus_message_new_method_call(bus, &m, bus_mgr, "UnlockHome");
2287 if (r < 0)
2288 return bus_log_create_error(r);
2289
2290 r = sd_bus_message_append(m, "s", *i);
2291 if (r < 0)
2292 return bus_log_create_error(r);
2293
2294 r = bus_message_append_secret(m, secret);
2295 if (r < 0)
2296 return bus_log_create_error(r);
2297
2298 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
2299 if (r < 0) {
2300 r = handle_generic_user_record_error(argv[1], secret, &error, r, false);
2301 if (r < 0) {
2302 if (ret == 0)
2303 ret = r;
2304
2305 break;
2306 }
2307 } else
2308 break;
2309 }
2310 }
2311
2312 return ret;
2313}
2314
2315static int with_home(int argc, char *argv[], void *userdata) {
2316 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
2317 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL, *reply = NULL;
2318 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
2319 _cleanup_(user_record_unrefp) UserRecord *secret = NULL;
2320 _cleanup_close_ int acquired_fd = -EBADF;
2321 _cleanup_strv_free_ char **cmdline = NULL;
2322 const char *home;
2323 int r, ret;
2324 pid_t pid;
2325
2326 r = acquire_bus(&bus);
2327 if (r < 0)
2328 return r;
2329
2330 if (argc < 3) {
2331 _cleanup_free_ char *shell = NULL;
2332
2333 /* If no command is specified, spawn a shell */
2334 r = get_shell(&shell);
2335 if (r < 0)
2336 return log_error_errno(r, "Failed to acquire shell: %m");
2337
2338 cmdline = strv_new(shell);
2339 } else
2340 cmdline = strv_copy(argv + 2);
2341 if (!cmdline)
2342 return log_oom();
2343
2344 r = acquire_passed_secrets(argv[1], &secret);
2345 if (r < 0)
2346 return r;
2347
2348 for (;;) {
2349 r = bus_message_new_method_call(bus, &m, bus_mgr, "AcquireHome");
2350 if (r < 0)
2351 return bus_log_create_error(r);
2352
2353 r = sd_bus_message_append(m, "s", argv[1]);
2354 if (r < 0)
2355 return bus_log_create_error(r);
2356
2357 r = bus_message_append_secret(m, secret);
2358 if (r < 0)
2359 return bus_log_create_error(r);
2360
2361 r = sd_bus_message_append(m, "b", /* please_suspend = */ getenv_bool("SYSTEMD_PLEASE_SUSPEND_HOME") > 0);
2362 if (r < 0)
2363 return bus_log_create_error(r);
2364
2365 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, &reply);
2366 m = sd_bus_message_unref(m);
2367 if (r < 0) {
2368 r = handle_generic_user_record_error(argv[1], secret, &error, r, false);
2369 if (r < 0)
2370 return r;
2371
2372 sd_bus_error_free(&error);
2373 } else {
2374 int fd;
2375
2376 r = sd_bus_message_read(reply, "h", &fd);
2377 if (r < 0)
2378 return bus_log_parse_error(r);
2379
2380 acquired_fd = fcntl(fd, F_DUPFD_CLOEXEC, 3);
2381 if (acquired_fd < 0)
2382 return log_error_errno(errno, "Failed to duplicate acquired fd: %m");
2383
2384 reply = sd_bus_message_unref(reply);
2385 break;
2386 }
2387 }
2388
2389 r = bus_call_method(bus, bus_mgr, "GetHomeByName", &error, &reply, "s", argv[1]);
2390 if (r < 0)
2391 return log_error_errno(r, "Failed to inspect home: %s", bus_error_message(&error, r));
2392
2393 r = sd_bus_message_read(reply, "usussso", NULL, NULL, NULL, NULL, &home, NULL, NULL);
2394 if (r < 0)
2395 return bus_log_parse_error(r);
2396
2397 r = safe_fork("(with)", FORK_RESET_SIGNALS|FORK_CLOSE_ALL_FDS|FORK_DEATHSIG_SIGTERM|FORK_LOG|FORK_RLIMIT_NOFILE_SAFE|FORK_REOPEN_LOG, &pid);
2398 if (r < 0)
2399 return r;
2400 if (r == 0) {
2401 if (chdir(home) < 0) {
2402 log_error_errno(errno, "Failed to change to directory %s: %m", home);
2403 _exit(255);
2404 }
2405
2406 execvp(cmdline[0], cmdline);
2407 log_error_errno(errno, "Failed to execute %s: %m", cmdline[0]);
2408 _exit(255);
2409 }
2410
2411 ret = wait_for_terminate_and_check(cmdline[0], pid, WAIT_LOG_ABNORMAL);
2412
2413 /* Close the fd that pings the home now. */
2414 acquired_fd = safe_close(acquired_fd);
2415
2416 r = bus_message_new_method_call(bus, &m, bus_mgr, "ReleaseHome");
2417 if (r < 0)
2418 return bus_log_create_error(r);
2419
2420 r = sd_bus_message_append(m, "s", argv[1]);
2421 if (r < 0)
2422 return bus_log_create_error(r);
2423
2424 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
2425 if (r < 0) {
2426 if (sd_bus_error_has_name(&error, BUS_ERROR_HOME_BUSY))
2427 log_notice("Not deactivating home directory of %s, as it is still used.", argv[1]);
2428 else
2429 return log_error_errno(r, "Failed to release user home: %s", bus_error_message(&error, r));
2430 }
2431
2432 return ret;
2433}
2434
2435static int lock_all_homes(int argc, char *argv[], void *userdata) {
2436 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
2437 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
2438 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
2439 int r;
2440
2441 r = acquire_bus(&bus);
2442 if (r < 0)
2443 return r;
2444
2445 r = bus_message_new_method_call(bus, &m, bus_mgr, "LockAllHomes");
2446 if (r < 0)
2447 return bus_log_create_error(r);
2448
2449 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
2450 if (r < 0)
2451 return log_error_errno(r, "Failed to lock all homes: %s", bus_error_message(&error, r));
2452
2453 return 0;
2454}
2455
2456static int deactivate_all_homes(int argc, char *argv[], void *userdata) {
2457 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
2458 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
2459 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
2460 int r;
2461
2462 r = acquire_bus(&bus);
2463 if (r < 0)
2464 return r;
2465
2466 r = bus_message_new_method_call(bus, &m, bus_mgr, "DeactivateAllHomes");
2467 if (r < 0)
2468 return bus_log_create_error(r);
2469
2470 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
2471 if (r < 0)
2472 return log_error_errno(r, "Failed to deactivate all homes: %s", bus_error_message(&error, r));
2473
2474 return 0;
2475}
2476
2477static int rebalance(int argc, char *argv[], void *userdata) {
2478 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
2479 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
2480 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
2481 int r;
2482
2483 r = acquire_bus(&bus);
2484 if (r < 0)
2485 return r;
2486
2487 r = bus_message_new_method_call(bus, &m, bus_mgr, "Rebalance");
2488 if (r < 0)
2489 return bus_log_create_error(r);
2490
2491 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
2492 if (r < 0) {
2493 if (sd_bus_error_has_name(&error, BUS_ERROR_REBALANCE_NOT_NEEDED))
2494 log_info("No homes needed rebalancing.");
2495 else
2496 return log_error_errno(r, "Failed to rebalance: %s", bus_error_message(&error, r));
2497 } else
2498 log_info("Completed rebalancing.");
2499
2500 return 0;
2501}
2502
2503static int create_or_register_from_credentials(void) {
2504 int r;
2505
2506 _cleanup_close_ int fd = open_credentials_dir();
2507 if (IN_SET(fd, -ENXIO, -ENOENT)) /* Credential env var not set, or dir doesn't exist. */
2508 return 0;
2509 if (fd < 0)
2510 return log_error_errno(fd, "Failed to open credentials directory: %m");
2511
2512 _cleanup_free_ DirectoryEntries *des = NULL;
2513 r = readdir_all(fd, RECURSE_DIR_SORT|RECURSE_DIR_IGNORE_DOT|RECURSE_DIR_ENSURE_TYPE, &des);
2514 if (r < 0)
2515 return log_error_errno(r, "Failed to enumerate credentials: %m");
2516
2517 int ret = 0, n_processed = 0;
2518 FOREACH_ARRAY(i, des->entries, des->n_entries) {
2519 struct dirent *de = *i;
2520 if (de->d_type != DT_REG)
2521 continue;
2522
2523 enum {
2524 OPERATION_CREATE,
2525 OPERATION_REGISTER,
2526 } op;
2527 const char *e;
2528 if ((e = startswith(de->d_name, "home.create.")))
2529 op = OPERATION_CREATE;
2530 else if ((e = startswith(de->d_name, "home.register.")))
2531 op = OPERATION_REGISTER;
2532 else
2533 continue;
2534
2535 if (!valid_user_group_name(e, 0)) {
2536 log_notice("Skipping over credential with name that is not a suitable user name: %s", de->d_name);
2537 continue;
2538 }
2539
2540 _cleanup_(sd_json_variant_unrefp) sd_json_variant *identity = NULL;
2541 unsigned line = 0, column = 0;
2542 r = sd_json_parse_file_at(
2543 /* f= */ NULL,
2544 fd,
2545 de->d_name,
2546 /* flags= */ 0,
2547 &identity,
2548 &line,
2549 &column);
2550 if (r < 0) {
2551 log_warning_errno(r, "[%s:%u:%u] Failed to parse user record in credential, ignoring: %m", de->d_name, line, column);
2552 continue;
2553 }
2554
2555 sd_json_variant *un = sd_json_variant_by_key(identity, "userName");
2556 if (un) {
2557 if (!sd_json_variant_is_string(un)) {
2558 log_warning("User record from credential '%s' contains 'userName' field of invalid type, ignoring.", de->d_name);
2559 continue;
2560 }
2561
2562 if (!streq(sd_json_variant_string(un), e)) {
2563 log_warning("User record from credential '%s' contains 'userName' field (%s) that doesn't match credential name (%s), ignoring.", de->d_name, sd_json_variant_string(un), e);
2564 continue;
2565 }
2566 } else {
2567 r = sd_json_variant_set_field_string(&identity, "userName", e);
2568 if (r < 0)
2569 return log_warning_errno(r, "Failed to set userName field: %m");
2570 }
2571
2572 log_notice("Processing user '%s' from credentials.", e);
2573
2574 if (op == OPERATION_CREATE)
2575 r = create_home_common(identity, /* show_enforce_password_policy_hint= */ false);
2576 else
2577 r = register_home_common(/* bus= */ NULL, identity);
2578 if (r >= 0)
2579 n_processed++;
2580
2581 RET_GATHER(ret, r);
2582 }
2583
2584 return ret < 0 ? ret : n_processed;
2585}
2586
2587static int has_regular_user(void) {
2588 _cleanup_(userdb_iterator_freep) UserDBIterator *iterator = NULL;
2589 UserDBMatch match = USERDB_MATCH_NULL;
2590 int r;
2591
2592 match.disposition_mask = INDEX_TO_MASK(uint64_t, USER_REGULAR);
2593
2594 r = userdb_all(&match, USERDB_SUPPRESS_SHADOW, &iterator);
2595 if (r < 0)
2596 return log_error_errno(r, "Failed to create user enumerator: %m");
2597
2598 r = userdb_iterator_get(iterator, &match, /* ret= */ NULL);
2599 if (r == -ESRCH)
2600 return false;
2601 if (r < 0)
2602 return log_error_errno(r, "Failed to enumerate users: %m");
2603
2604 return true;
2605}
2606
2607static int acquire_group_list(char ***ret) {
2608 _cleanup_(userdb_iterator_freep) UserDBIterator *iterator = NULL;
2609 _cleanup_strv_free_ char **groups = NULL;
2610 UserDBMatch match = USERDB_MATCH_NULL;
2611 int r;
2612
2613 assert(ret);
2614
2615 match.disposition_mask = INDEXES_TO_MASK(uint64_t, USER_REGULAR, USER_SYSTEM);
2616
2617 r = groupdb_all(&match, USERDB_SUPPRESS_SHADOW, &iterator);
2618 if (r == -ENOLINK)
2619 log_debug_errno(r, "No groups found. (Didn't check via Varlink.)");
2620 else if (r == -ESRCH)
2621 log_debug_errno(r, "No groups found.");
2622 else if (r < 0)
2623 return log_debug_errno(r, "Failed to enumerate groups, ignoring: %m");
2624 else
2625 for (;;) {
2626 _cleanup_(group_record_unrefp) GroupRecord *gr = NULL;
2627
2628 r = groupdb_iterator_get(iterator, &match, &gr);
2629 if (r == -ESRCH)
2630 break;
2631 if (r < 0)
2632 return log_debug_errno(r, "Failed to acquire next group: %m");
2633
2634 if (group_record_disposition(gr) == USER_REGULAR) {
2635 _cleanup_(user_record_unrefp) UserRecord *ur = NULL;
2636
2637 /* Filter groups here that belong to a specific user, and are named like them */
2638
2639 UserDBMatch user_match = USERDB_MATCH_NULL;
2640 user_match.disposition_mask = INDEX_TO_MASK(uint64_t, USER_REGULAR);
2641
2642 r = userdb_by_name(gr->group_name, &user_match, USERDB_SUPPRESS_SHADOW, &ur);
2643 if (r < 0 && r != -ESRCH)
2644 return log_debug_errno(r, "Failed to check if matching user exists for group '%s': %m", gr->group_name);
2645
2646 if (r >= 0 && user_record_gid(ur) == gr->gid)
2647 continue;
2648 }
2649
2650 r = strv_extend(&groups, gr->group_name);
2651 if (r < 0)
2652 return log_oom();
2653 }
2654
2655 strv_sort(groups);
2656
2657 *ret = TAKE_PTR(groups);
2658 return !!*ret;
2659}
2660
2661static int group_completion_callback(const char *key, char ***ret_list, void *userdata) {
2662 char ***available = userdata;
2663 int r;
2664
2665 if (!*available) {
2666 r = acquire_group_list(available);
2667 if (r < 0)
2668 log_debug_errno(r, "Failed to enumerate available groups, ignoring: %m");
2669 }
2670
2671 _cleanup_strv_free_ char **l = strv_copy(*available);
2672 if (!l)
2673 return -ENOMEM;
2674
2675 r = strv_extend(&l, "list");
2676 if (r < 0)
2677 return r;
2678
2679 *ret_list = TAKE_PTR(l);
2680 return 0;
2681}
2682
2683static int create_interactively(void) {
2684 _cleanup_free_ char *username = NULL;
2685 int r;
2686
2687 if (!arg_prompt_new_user) {
2688 log_debug("Prompting for user creation was not requested.");
2689 return 0;
2690 }
2691
2692 putchar('\n');
2693 if (emoji_enabled()) {
2694 fputs(glyph(GLYPH_HOME), stdout);
2695 putchar(' ');
2696 }
2697 printf("Please create your user account!\n");
2698
2699 if (!any_key_to_proceed()) {
2700 log_notice("Skipping.");
2701 return 0;
2702 }
2703
2704 (void) terminal_reset_defensive_locked(STDOUT_FILENO, /* flags= */ 0);
2705
2706 for (;;) {
2707 username = mfree(username);
2708
2709 r = ask_string(&username,
2710 "%s Please enter user name to create (empty to skip): ",
2711 glyph(GLYPH_TRIANGULAR_BULLET));
2712 if (r < 0)
2713 return log_error_errno(r, "Failed to query user for username: %m");
2714
2715 if (isempty(username)) {
2716 log_info("No data entered, skipping.");
2717 return 0;
2718 }
2719
2720 if (!valid_user_group_name(username, /* flags= */ 0)) {
2721 log_notice("Specified user name is not a valid UNIX user name, try again: %s", username);
2722 continue;
2723 }
2724
2725 r = userdb_by_name(username, /* match= */ NULL, USERDB_SUPPRESS_SHADOW, /* ret= */ NULL);
2726 if (r == -ESRCH)
2727 break;
2728 if (r < 0)
2729 return log_error_errno(r, "Failed to check if specified user '%s' already exists: %m", username);
2730
2731 log_notice("Specified user '%s' exists already, try again.", username);
2732 }
2733
2734 r = sd_json_variant_set_field_string(&arg_identity_extra, "userName", username);
2735 if (r < 0)
2736 return log_error_errno(r, "Failed to set userName field: %m");
2737
2738 /* Let's not insist on a strong password in the firstboot interactive interface. Insisting on this is
2739 * really annoying, as the user cannot just invoke the tool again with "--enforce-password-policy=no"
2740 * because after all the tool is called from the boot process, and not from an interactive
2741 * shell. Moreover, when setting up an initial system we can assume the user owns it, and hence we
2742 * don't need to hard enforce some policy on password strength some organization or OS vendor
2743 * requires. Note that this just disables the *strict* enforcement of the password policy. Even with
2744 * this disabled we'll still tell the user in the UI that the password is too weak and suggest better
2745 * ones, even if we then accept the weak ones if the user insists, by repeating it. */
2746 r = sd_json_variant_set_field_boolean(&arg_identity_extra, "enforcePasswordPolicy", false);
2747 if (r < 0)
2748 return log_error_errno(r, "Failed to set enforcePasswordPolicy field: %m");
2749
2750 _cleanup_strv_free_ char **available = NULL, **groups = NULL;
2751 for (;;) {
2752 _cleanup_free_ char *s = NULL;
2753
2754 strv_sort_uniq(groups);
2755
2756 if (!strv_isempty(groups)) {
2757 _cleanup_free_ char *j = strv_join(groups, ", ");
2758 if (!j)
2759 return log_oom();
2760
2761 log_info("Currently selected groups: %s", j);
2762 }
2763
2764 r = ask_string_full(&s,
2765 group_completion_callback, &available,
2766 "%s Please enter an auxiliary group for user %s (empty to continue, \"list\" to list available groups): ",
2767 glyph(GLYPH_TRIANGULAR_BULLET), username);
2768 if (r < 0)
2769 return log_error_errno(r, "Failed to query user for auxiliary group: %m");
2770
2771 if (isempty(s))
2772 break;
2773
2774 if (streq(s, "list")) {
2775 if (!available) {
2776 r = acquire_group_list(&available);
2777 if (r < 0)
2778 log_warning_errno(r, "Failed to enumerate available groups, ignoring: %m");
2779 if (r == 0)
2780 log_notice("Did not find any available groups");
2781 if (r <= 0)
2782 continue;
2783 }
2784
2785 r = show_menu(available,
2786 /* n_columns= */ 3,
2787 /* column_width= */ 20,
2788 /* ellipsize_percentage= */ 60,
2789 /* grey_prefix= */ NULL,
2790 /* with_numbers= */ true);
2791 if (r < 0)
2792 return log_error_errno(r, "Failed to show menu: %m");
2793
2794 putchar('\n');
2795 continue;
2796 };
2797
2798 if (!strv_isempty(available)) {
2799 unsigned u;
2800 r = safe_atou(s, &u);
2801 if (r >= 0) {
2802 if (u <= 0 || u > strv_length(available)) {
2803 log_error("Specified entry number out of range.");
2804 continue;
2805 }
2806
2807 log_info("Selected '%s'.", available[u-1]);
2808
2809 r = strv_extend(&groups, available[u-1]);
2810 if (r < 0)
2811 return log_oom();
2812
2813 continue;
2814 }
2815 }
2816
2817 if (!valid_user_group_name(s, /* flags= */ 0)) {
2818 log_notice("Specified group name is not a valid UNIX group name, try again: %s", s);
2819 continue;
2820 }
2821
2822 r = groupdb_by_name(s, /* match= */ NULL, USERDB_SUPPRESS_SHADOW|USERDB_EXCLUDE_DYNAMIC_USER, /*ret=*/ NULL);
2823 if (r == -ESRCH) {
2824 log_notice("Specified auxiliary group does not exist, try again: %s", s);
2825 continue;
2826 }
2827 if (r < 0)
2828 return log_error_errno(r, "Failed to check if specified group '%s' already exists: %m", s);
2829
2830 log_info("Selected '%s'.", s);
2831
2832 r = strv_extend(&groups, s);
2833 if (r < 0)
2834 return log_oom();
2835 }
2836
2837 if (!strv_isempty(groups)) {
2838 strv_sort_uniq(groups);
2839
2840 r = sd_json_variant_set_field_strv(&arg_identity_extra, "memberOf", groups);
2841 if (r < 0)
2842 return log_error_errno(r, "Failed to set memberOf field: %m");
2843 }
2844
2845 _cleanup_free_ char *shell = NULL;
2846
2847 for (;;) {
2848 shell = mfree(shell);
2849
2850 r = ask_string(&shell,
2851 "%s Please enter the shell to use for user %s (empty for default): ",
2852 glyph(GLYPH_TRIANGULAR_BULLET), username);
2853 if (r < 0)
2854 return log_error_errno(r, "Failed to query user for username: %m");
2855
2856 if (isempty(shell)) {
2857 log_info("No data entered, leaving at default.");
2858 break;
2859 }
2860
2861 if (!valid_shell(shell)) {
2862 log_notice("Specified shell is not a valid UNIX shell path, try again: %s", shell);
2863 continue;
2864 }
2865
2866 r = RET_NERRNO(access(shell, X_OK));
2867 if (r >= 0)
2868 break;
2869
2870 if (r != -ENOENT)
2871 return log_error_errno(r, "Failed to check if shell %s exists: %m", shell);
2872
2873 log_notice("Specified shell '%s' is not installed, try another one.", shell);
2874 }
2875
2876 if (!isempty(shell)) {
2877 log_info("Selected %s as the shell for user %s", shell, username);
2878
2879 r = sd_json_variant_set_field_string(&arg_identity_extra, "shell", shell);
2880 if (r < 0)
2881 return log_error_errno(r, "Failed to set shell field: %m");
2882 }
2883
2884 return create_home_common(/* input= */ NULL, /* show_enforce_password_policy_hint= */ false);
2885}
2886
2887static int add_signing_keys_from_credentials(void);
2888
2889static int verb_firstboot(int argc, char *argv[], void *userdata) {
2890 int r;
2891
2892 /* Let's honour the systemd.firstboot kernel command line option, just like the systemd-firstboot
2893 * tool. */
2894
2895 bool enabled;
2896 r = proc_cmdline_get_bool("systemd.firstboot", /* flags = */ 0, &enabled);
2897 if (r < 0)
2898 return log_error_errno(r, "Failed to parse systemd.firstboot= kernel command line argument, ignoring: %m");
2899 if (r > 0 && !enabled) {
2900 log_debug("Found systemd.firstboot=no kernel command line argument, turning off all prompts.");
2901 arg_prompt_new_user = false;
2902 }
2903
2904 int ret = 0;
2905
2906 RET_GATHER(ret, add_signing_keys_from_credentials());
2907
2908 r = create_or_register_from_credentials();
2909 RET_GATHER(ret, r);
2910 bool existing_users = r > 0;
2911
2912 r = getenv_bool("SYSTEMD_HOME_FIRSTBOOT_OVERRIDE");
2913 if (r == 0)
2914 return 0;
2915 if (r < 0) {
2916 if (r != -ENXIO)
2917 log_warning_errno(r, "Failed to parse $SYSTEMD_HOME_FIRSTBOOT_OVERRIDE, ignoring: %m");
2918
2919 if (!existing_users) {
2920 r = has_regular_user();
2921 if (r < 0)
2922 return r;
2923
2924 existing_users = r > 0;
2925 }
2926 if (existing_users) {
2927 log_info("Regular user already present in user database, skipping interactive user creation.");
2928 return 0;
2929 }
2930 }
2931
2932 RET_GATHER(ret, create_interactively());
2933 return ret;
2934}
2935
2936static int drop_from_identity(const char *field) {
2937 int r;
2938
2939 assert(field);
2940
2941 /* If we are called to update an identity record and drop some field, let's keep track of what to
2942 * remove from the old record */
2943 r = strv_extend(&arg_identity_filter, field);
2944 if (r < 0)
2945 return log_oom();
2946
2947 /* Let's also drop the field if it was previously set to a new value on the same command line */
2948 r = sd_json_variant_filter(&arg_identity_extra, STRV_MAKE(field));
2949 if (r < 0)
2950 return log_error_errno(r, "Failed to filter JSON identity data: %m");
2951
2952 r = sd_json_variant_filter(&arg_identity_extra_this_machine, STRV_MAKE(field));
2953 if (r < 0)
2954 return log_error_errno(r, "Failed to filter JSON identity data: %m");
2955
2956 r = sd_json_variant_filter(&arg_identity_extra_privileged, STRV_MAKE(field));
2957 if (r < 0)
2958 return log_error_errno(r, "Failed to filter JSON identity data: %m");
2959
2960 return 0;
2961}
2962
2963static int help(int argc, char *argv[], void *userdata) {
2964 _cleanup_free_ char *link = NULL;
2965 int r;
2966
2967 pager_open(arg_pager_flags);
2968
2969 r = terminal_urlify_man("homectl", "1", &link);
2970 if (r < 0)
2971 return log_oom();
2972
2973 printf("%1$s [OPTIONS...] COMMAND ...\n\n"
2974 "%2$sCreate, manipulate or inspect home directories.%3$s\n"
2975 "\n%4$sBasic User Manipulation Commands:%5$s\n"
2976 " list List home areas\n"
2977 " inspect USER… Inspect a home area\n"
2978 " create USER Create a home area\n"
2979 " update USER Update a home area\n"
2980 " passwd USER Change password of a home area\n"
2981 " resize USER SIZE Resize a home area\n"
2982 " remove USER… Remove a home area\n"
2983 "\n%4$sAdvanced User Manipulation Commands:%5$s\n"
2984 " activate USER… Activate a home area\n"
2985 " deactivate USER… Deactivate a home area\n"
2986 " deactivate-all Deactivate all active home areas\n"
2987 " with USER [COMMAND…] Run shell or command with access to a home area\n"
2988 " authenticate USER… Authenticate a home area\n"
2989 "\n%4$sUser Migration Commands:%5$s\n"
2990 " adopt PATH… Add an existing home area on this system\n"
2991 " register PATH… Register a user record locally\n"
2992 " unregister USER… Unregister a user record locally\n"
2993 "\n%4$sSigning Keys Commands:%5$s\n"
2994 " list-signing-keys List home signing keys\n"
2995 " get-signing-key [NAME…] Get a named home signing key\n"
2996 " add-signing-key FILE… Add home signing key\n"
2997 " remove-signing-key NAME… Remove home signing key\n"
2998 "\n%4$sLock/Unlock Commands:%5$s\n"
2999 " lock USER… Temporarily lock an active home area\n"
3000 " unlock USER… Unlock a temporarily locked home area\n"
3001 " lock-all Lock all suitable home areas\n"
3002 "\n%4$sOther Commands:%5$s\n"
3003 " rebalance Rebalance free space between home areas\n"
3004 " firstboot Run first-boot home area creation wizard\n"
3005 "\n%4$sOptions:%5$s\n"
3006 " -h --help Show this help\n"
3007 " --version Show package version\n"
3008 " --no-pager Do not pipe output into a pager\n"
3009 " --no-legend Do not show the headers and footers\n"
3010 " --no-ask-password Do not ask for system passwords\n"
3011 " --offline Don't update record embedded in home directory\n"
3012 " -H --host=[USER@]HOST Operate on remote host\n"
3013 " -M --machine=CONTAINER Operate on local container\n"
3014 " --identity=PATH Read JSON identity from file\n"
3015 " --json=FORMAT Output inspection data in JSON (takes one of\n"
3016 " pretty, short, off)\n"
3017 " -j Equivalent to --json=pretty (on TTY) or\n"
3018 " --json=short (otherwise)\n"
3019 " --export-format= Strip JSON inspection data (full, stripped,\n"
3020 " minimal)\n"
3021 " -E When specified once equals -j --export-format=\n"
3022 " stripped, when specified twice equals\n"
3023 " -j --export-format=minimal\n"
3024 " --prompt-new-user firstboot: Query user interactively for user\n"
3025 " to create\n"
3026 " --key-name=NAME Key name when adding a signing key\n"
3027 " --seize=no Do not strip existing signatures of user record\n"
3028 " when creating\n"
3029 "\n%4$sGeneral User Record Properties:%5$s\n"
3030 " -c --real-name=REALNAME Real name for user\n"
3031 " --realm=REALM Realm to create user in\n"
3032 " --alias=ALIAS Define alias usernames for this account\n"
3033 " --email-address=EMAIL Email address for user\n"
3034 " --location=LOCATION Set location of user on earth\n"
3035 " --icon-name=NAME Icon name for user\n"
3036 " -d --home-dir=PATH Home directory\n"
3037 " -u --uid=UID Numeric UID for user\n"
3038 " -G --member-of=GROUP Add user to group\n"
3039 " --capability-bounding-set=CAPS\n"
3040 " Bounding POSIX capability set\n"
3041 " --capability-ambient-set=CAPS\n"
3042 " Ambient POSIX capability set\n"
3043 " --access-mode=MODE User home directory access mode\n"
3044 " --umask=MODE Umask for user when logging in\n"
3045 " --skel=PATH Skeleton directory to use\n"
3046 " --shell=PATH Shell for account\n"
3047 " --setenv=VARIABLE[=VALUE] Set an environment variable at log-in\n"
3048 " --timezone=TIMEZONE Set a time-zone\n"
3049 " --language=LOCALE Set preferred languages\n"
3050 " --default-area=AREA Select default area\n"
3051 "\n%4$sAuthentication User Record Properties:%5$s\n"
3052 " --ssh-authorized-keys=KEYS\n"
3053 " Specify SSH public keys\n"
3054 " --pkcs11-token-uri=URI URI to PKCS#11 security token containing\n"
3055 " private key and matching X.509 certificate\n"
3056 " --fido2-device=PATH Path to FIDO2 hidraw device with hmac-secret\n"
3057 " extension\n"
3058 " --fido2-with-client-pin=BOOL\n"
3059 " Whether to require entering a PIN to unlock the\n"
3060 " account\n"
3061 " --fido2-with-user-presence=BOOL\n"
3062 " Whether to require user presence to unlock the\n"
3063 " account\n"
3064 " --fido2-with-user-verification=BOOL\n"
3065 " Whether to require user verification to unlock\n"
3066 " the account\n"
3067 " --recovery-key=BOOL Add a recovery key\n"
3068 "\n%4$sBlob Directory User Record Properties:%5$s\n"
3069 " -b --blob=[FILENAME=]PATH\n"
3070 " Path to a replacement blob directory, or replace\n"
3071 " an individual files in the blob directory.\n"
3072 " --avatar=PATH Path to user avatar picture\n"
3073 " --login-background=PATH Path to user login background picture\n"
3074 "\n%4$sAccount Management User Record Properties:%5$s\n"
3075 " --locked=BOOL Set locked account state\n"
3076 " --not-before=TIMESTAMP Do not allow logins before\n"
3077 " --not-after=TIMESTAMP Do not allow logins after\n"
3078 " --rate-limit-interval=SECS\n"
3079 " Login rate-limit interval in seconds\n"
3080 " --rate-limit-burst=NUMBER\n"
3081 " Login rate-limit attempts per interval\n"
3082 "\n%4$sPassword Policy User Record Properties:%5$s\n"
3083 " --password-hint=HINT Set Password hint\n"
3084 " --enforce-password-policy=BOOL\n"
3085 " Control whether to enforce system's password\n"
3086 " policy for this user\n"
3087 " -P Same as --enforce-password-policy=no\n"
3088 " --password-change-now=BOOL\n"
3089 " Require the password to be changed on next login\n"
3090 " --password-change-min=TIME\n"
3091 " Require minimum time between password changes\n"
3092 " --password-change-max=TIME\n"
3093 " Require maximum time between password changes\n"
3094 " --password-change-warn=TIME\n"
3095 " How much time to warn before password expiry\n"
3096 " --password-change-inactive=TIME\n"
3097 " How much time to block password after expiry\n"
3098 "\n%4$sResource Management User Record Properties:%5$s\n"
3099 " --disk-size=BYTES Size to assign the user on disk\n"
3100 " --nice=NICE Nice level for user\n"
3101 " --rlimit=LIMIT=VALUE[:VALUE]\n"
3102 " Set resource limits\n"
3103 " --tasks-max=MAX Set maximum number of per-user tasks\n"
3104 " --memory-high=BYTES Set high memory threshold in bytes\n"
3105 " --memory-max=BYTES Set maximum memory limit\n"
3106 " --cpu-weight=WEIGHT Set CPU weight\n"
3107 " --io-weight=WEIGHT Set IO weight\n"
3108 " --tmp-limit=BYTES|PERCENT Set limit on /tmp/\n"
3109 " --dev-shm-limit=BYTES|PERCENT\n"
3110 " Set limit on /dev/shm/\n"
3111 "\n%4$sStorage User Record Properties:%5$s\n"
3112 " --storage=STORAGE Storage type to use (luks, fscrypt, directory,\n"
3113 " subvolume, cifs)\n"
3114 " --image-path=PATH Path to image file/directory\n"
3115 " --drop-caches=BOOL Whether to automatically drop caches on logout\n"
3116 "\n%4$sLUKS Storage User Record Properties:%5$s\n"
3117 " --fs-type=TYPE File system type to use in case of luks\n"
3118 " storage (btrfs, ext4, xfs)\n"
3119 " --luks-discard=BOOL Whether to use 'discard' feature of file system\n"
3120 " when activated (mounted)\n"
3121 " --luks-offline-discard=BOOL\n"
3122 " Whether to trim file on logout\n"
3123 " --luks-cipher=CIPHER Cipher to use for LUKS encryption\n"
3124 " --luks-cipher-mode=MODE Cipher mode to use for LUKS encryption\n"
3125 " --luks-volume-key-size=BITS\n"
3126 " Volume key size to use for LUKS encryption\n"
3127 " --luks-pbkdf-type=TYPE Password-based Key Derivation Function to use\n"
3128 " --luks-pbkdf-hash-algorithm=ALGORITHM\n"
3129 " PBKDF hash algorithm to use\n"
3130 " --luks-pbkdf-time-cost=SECS\n"
3131 " Time cost for PBKDF in seconds\n"
3132 " --luks-pbkdf-memory-cost=BYTES\n"
3133 " Memory cost for PBKDF in bytes\n"
3134 " --luks-pbkdf-parallel-threads=NUMBER\n"
3135 " Number of parallel threads for PKBDF\n"
3136 " --luks-sector-size=BYTES\n"
3137 " Sector size for LUKS encryption in bytes\n"
3138 " --luks-extra-mount-options=OPTIONS\n"
3139 " LUKS extra mount options\n"
3140 " --auto-resize-mode=MODE Automatically grow/shrink home on login/logout\n"
3141 " --rebalance-weight=WEIGHT Weight while rebalancing\n"
3142 "\n%4$sMounting User Record Properties:%5$s\n"
3143 " --nosuid=BOOL Control the 'nosuid' flag of the home mount\n"
3144 " --nodev=BOOL Control the 'nodev' flag of the home mount\n"
3145 " --noexec=BOOL Control the 'noexec' flag of the home mount\n"
3146 "\n%4$sCIFS User Record Properties:%5$s\n"
3147 " --cifs-domain=DOMAIN CIFS (Windows) domain\n"
3148 " --cifs-user-name=USER CIFS (Windows) user name\n"
3149 " --cifs-service=SERVICE CIFS (Windows) service to mount as home area\n"
3150 " --cifs-extra-mount-options=OPTIONS\n"
3151 " CIFS (Windows) extra mount options\n"
3152 "\n%4$sLogin Behaviour User Record Properties:%5$s\n"
3153 " --stop-delay=SECS How long to leave user services running after\n"
3154 " logout\n"
3155 " --kill-processes=BOOL Whether to kill user processes when sessions\n"
3156 " terminate\n"
3157 " --auto-login=BOOL Try to log this user in automatically\n"
3158 " --session-launcher=LAUNCHER\n"
3159 " Preferred session launcher file\n"
3160 " --session-type=TYPE Preferred session type\n"
3161 "\nSee the %6$s for details.\n",
3162 program_invocation_short_name,
3163 ansi_highlight(),
3164 ansi_normal(),
3165 ansi_underline(),
3166 ansi_normal(),
3167 link);
3168
3169 return 0;
3170}
3171
3172static int parse_argv(int argc, char *argv[]) {
3173 _cleanup_strv_free_ char **arg_languages = NULL;
3174
3175 enum {
3176 ARG_VERSION = 0x100,
3177 ARG_NO_PAGER,
3178 ARG_NO_LEGEND,
3179 ARG_NO_ASK_PASSWORD,
3180 ARG_OFFLINE,
3181 ARG_REALM,
3182 ARG_ALIAS,
3183 ARG_EMAIL_ADDRESS,
3184 ARG_DISK_SIZE,
3185 ARG_ACCESS_MODE,
3186 ARG_STORAGE,
3187 ARG_FS_TYPE,
3188 ARG_IMAGE_PATH,
3189 ARG_UMASK,
3190 ARG_LUKS_DISCARD,
3191 ARG_LUKS_OFFLINE_DISCARD,
3192 ARG_JSON,
3193 ARG_SETENV,
3194 ARG_TIMEZONE,
3195 ARG_LANGUAGE,
3196 ARG_LOCKED,
3197 ARG_SSH_AUTHORIZED_KEYS,
3198 ARG_LOCATION,
3199 ARG_ICON_NAME,
3200 ARG_PASSWORD_HINT,
3201 ARG_NICE,
3202 ARG_RLIMIT,
3203 ARG_NOT_BEFORE,
3204 ARG_NOT_AFTER,
3205 ARG_LUKS_CIPHER,
3206 ARG_LUKS_CIPHER_MODE,
3207 ARG_LUKS_VOLUME_KEY_SIZE,
3208 ARG_NOSUID,
3209 ARG_NODEV,
3210 ARG_NOEXEC,
3211 ARG_CIFS_DOMAIN,
3212 ARG_CIFS_USER_NAME,
3213 ARG_CIFS_SERVICE,
3214 ARG_CIFS_EXTRA_MOUNT_OPTIONS,
3215 ARG_TASKS_MAX,
3216 ARG_MEMORY_HIGH,
3217 ARG_MEMORY_MAX,
3218 ARG_CPU_WEIGHT,
3219 ARG_IO_WEIGHT,
3220 ARG_LUKS_PBKDF_TYPE,
3221 ARG_LUKS_PBKDF_HASH_ALGORITHM,
3222 ARG_LUKS_PBKDF_FORCE_ITERATIONS,
3223 ARG_LUKS_PBKDF_TIME_COST,
3224 ARG_LUKS_PBKDF_MEMORY_COST,
3225 ARG_LUKS_PBKDF_PARALLEL_THREADS,
3226 ARG_LUKS_SECTOR_SIZE,
3227 ARG_RATE_LIMIT_INTERVAL,
3228 ARG_RATE_LIMIT_BURST,
3229 ARG_STOP_DELAY,
3230 ARG_KILL_PROCESSES,
3231 ARG_ENFORCE_PASSWORD_POLICY,
3232 ARG_PASSWORD_CHANGE_NOW,
3233 ARG_PASSWORD_CHANGE_MIN,
3234 ARG_PASSWORD_CHANGE_MAX,
3235 ARG_PASSWORD_CHANGE_WARN,
3236 ARG_PASSWORD_CHANGE_INACTIVE,
3237 ARG_EXPORT_FORMAT,
3238 ARG_AUTO_LOGIN,
3239 ARG_SESSION_LAUNCHER,
3240 ARG_SESSION_TYPE,
3241 ARG_PKCS11_TOKEN_URI,
3242 ARG_FIDO2_DEVICE,
3243 ARG_FIDO2_WITH_PIN,
3244 ARG_FIDO2_WITH_UP,
3245 ARG_FIDO2_WITH_UV,
3246 ARG_RECOVERY_KEY,
3247 ARG_AND_RESIZE,
3248 ARG_AND_CHANGE_PASSWORD,
3249 ARG_DROP_CACHES,
3250 ARG_LUKS_EXTRA_MOUNT_OPTIONS,
3251 ARG_AUTO_RESIZE_MODE,
3252 ARG_REBALANCE_WEIGHT,
3253 ARG_FIDO2_CRED_ALG,
3254 ARG_CAPABILITY_BOUNDING_SET,
3255 ARG_CAPABILITY_AMBIENT_SET,
3256 ARG_PROMPT_NEW_USER,
3257 ARG_AVATAR,
3258 ARG_LOGIN_BACKGROUND,
3259 ARG_TMP_LIMIT,
3260 ARG_DEV_SHM_LIMIT,
3261 ARG_DEFAULT_AREA,
3262 ARG_KEY_NAME,
3263 ARG_SEIZE,
3264 ARG_MATCH,
3265 };
3266
3267 static const struct option options[] = {
3268 { "help", no_argument, NULL, 'h' },
3269 { "version", no_argument, NULL, ARG_VERSION },
3270 { "no-pager", no_argument, NULL, ARG_NO_PAGER },
3271 { "no-legend", no_argument, NULL, ARG_NO_LEGEND },
3272 { "no-ask-password", no_argument, NULL, ARG_NO_ASK_PASSWORD },
3273 { "offline", no_argument, NULL, ARG_OFFLINE },
3274 { "host", required_argument, NULL, 'H' },
3275 { "machine", required_argument, NULL, 'M' },
3276 { "identity", required_argument, NULL, 'I' },
3277 { "real-name", required_argument, NULL, 'c' },
3278 { "comment", required_argument, NULL, 'c' }, /* Compat alias to keep thing in sync with useradd(8) */
3279 { "realm", required_argument, NULL, ARG_REALM },
3280 { "alias", required_argument, NULL, ARG_ALIAS },
3281 { "email-address", required_argument, NULL, ARG_EMAIL_ADDRESS },
3282 { "location", required_argument, NULL, ARG_LOCATION },
3283 { "password-hint", required_argument, NULL, ARG_PASSWORD_HINT },
3284 { "icon-name", required_argument, NULL, ARG_ICON_NAME },
3285 { "home-dir", required_argument, NULL, 'd' }, /* Compatible with useradd(8) */
3286 { "uid", required_argument, NULL, 'u' }, /* Compatible with useradd(8) */
3287 { "member-of", required_argument, NULL, 'G' },
3288 { "groups", required_argument, NULL, 'G' }, /* Compat alias to keep thing in sync with useradd(8) */
3289 { "skel", required_argument, NULL, 'k' }, /* Compatible with useradd(8) */
3290 { "shell", required_argument, NULL, 's' }, /* Compatible with useradd(8) */
3291 { "setenv", required_argument, NULL, ARG_SETENV },
3292 { "timezone", required_argument, NULL, ARG_TIMEZONE },
3293 { "language", required_argument, NULL, ARG_LANGUAGE },
3294 { "locked", required_argument, NULL, ARG_LOCKED },
3295 { "not-before", required_argument, NULL, ARG_NOT_BEFORE },
3296 { "not-after", required_argument, NULL, ARG_NOT_AFTER },
3297 { "expiredate", required_argument, NULL, 'e' }, /* Compat alias to keep thing in sync with useradd(8) */
3298 { "ssh-authorized-keys", required_argument, NULL, ARG_SSH_AUTHORIZED_KEYS },
3299 { "disk-size", required_argument, NULL, ARG_DISK_SIZE },
3300 { "access-mode", required_argument, NULL, ARG_ACCESS_MODE },
3301 { "umask", required_argument, NULL, ARG_UMASK },
3302 { "nice", required_argument, NULL, ARG_NICE },
3303 { "rlimit", required_argument, NULL, ARG_RLIMIT },
3304 { "tasks-max", required_argument, NULL, ARG_TASKS_MAX },
3305 { "memory-high", required_argument, NULL, ARG_MEMORY_HIGH },
3306 { "memory-max", required_argument, NULL, ARG_MEMORY_MAX },
3307 { "cpu-weight", required_argument, NULL, ARG_CPU_WEIGHT },
3308 { "io-weight", required_argument, NULL, ARG_IO_WEIGHT },
3309 { "storage", required_argument, NULL, ARG_STORAGE },
3310 { "image-path", required_argument, NULL, ARG_IMAGE_PATH },
3311 { "fs-type", required_argument, NULL, ARG_FS_TYPE },
3312 { "luks-discard", required_argument, NULL, ARG_LUKS_DISCARD },
3313 { "luks-offline-discard", required_argument, NULL, ARG_LUKS_OFFLINE_DISCARD },
3314 { "luks-cipher", required_argument, NULL, ARG_LUKS_CIPHER },
3315 { "luks-cipher-mode", required_argument, NULL, ARG_LUKS_CIPHER_MODE },
3316 { "luks-volume-key-size", required_argument, NULL, ARG_LUKS_VOLUME_KEY_SIZE },
3317 { "luks-pbkdf-type", required_argument, NULL, ARG_LUKS_PBKDF_TYPE },
3318 { "luks-pbkdf-hash-algorithm", required_argument, NULL, ARG_LUKS_PBKDF_HASH_ALGORITHM },
3319 { "luks-pbkdf-force-iterations", required_argument, NULL, ARG_LUKS_PBKDF_FORCE_ITERATIONS },
3320 { "luks-pbkdf-time-cost", required_argument, NULL, ARG_LUKS_PBKDF_TIME_COST },
3321 { "luks-pbkdf-memory-cost", required_argument, NULL, ARG_LUKS_PBKDF_MEMORY_COST },
3322 { "luks-pbkdf-parallel-threads", required_argument, NULL, ARG_LUKS_PBKDF_PARALLEL_THREADS },
3323 { "luks-sector-size", required_argument, NULL, ARG_LUKS_SECTOR_SIZE },
3324 { "nosuid", required_argument, NULL, ARG_NOSUID },
3325 { "nodev", required_argument, NULL, ARG_NODEV },
3326 { "noexec", required_argument, NULL, ARG_NOEXEC },
3327 { "cifs-user-name", required_argument, NULL, ARG_CIFS_USER_NAME },
3328 { "cifs-domain", required_argument, NULL, ARG_CIFS_DOMAIN },
3329 { "cifs-service", required_argument, NULL, ARG_CIFS_SERVICE },
3330 { "cifs-extra-mount-options", required_argument, NULL, ARG_CIFS_EXTRA_MOUNT_OPTIONS },
3331 { "rate-limit-interval", required_argument, NULL, ARG_RATE_LIMIT_INTERVAL },
3332 { "rate-limit-burst", required_argument, NULL, ARG_RATE_LIMIT_BURST },
3333 { "stop-delay", required_argument, NULL, ARG_STOP_DELAY },
3334 { "kill-processes", required_argument, NULL, ARG_KILL_PROCESSES },
3335 { "enforce-password-policy", required_argument, NULL, ARG_ENFORCE_PASSWORD_POLICY },
3336 { "password-change-now", required_argument, NULL, ARG_PASSWORD_CHANGE_NOW },
3337 { "password-change-min", required_argument, NULL, ARG_PASSWORD_CHANGE_MIN },
3338 { "password-change-max", required_argument, NULL, ARG_PASSWORD_CHANGE_MAX },
3339 { "password-change-warn", required_argument, NULL, ARG_PASSWORD_CHANGE_WARN },
3340 { "password-change-inactive", required_argument, NULL, ARG_PASSWORD_CHANGE_INACTIVE },
3341 { "auto-login", required_argument, NULL, ARG_AUTO_LOGIN },
3342 { "session-launcher", required_argument, NULL, ARG_SESSION_LAUNCHER, },
3343 { "session-type", required_argument, NULL, ARG_SESSION_TYPE, },
3344 { "json", required_argument, NULL, ARG_JSON },
3345 { "export-format", required_argument, NULL, ARG_EXPORT_FORMAT },
3346 { "pkcs11-token-uri", required_argument, NULL, ARG_PKCS11_TOKEN_URI },
3347 { "fido2-credential-algorithm", required_argument, NULL, ARG_FIDO2_CRED_ALG },
3348 { "fido2-device", required_argument, NULL, ARG_FIDO2_DEVICE },
3349 { "fido2-with-client-pin", required_argument, NULL, ARG_FIDO2_WITH_PIN },
3350 { "fido2-with-user-presence", required_argument, NULL, ARG_FIDO2_WITH_UP },
3351 { "fido2-with-user-verification", required_argument, NULL, ARG_FIDO2_WITH_UV },
3352 { "recovery-key", required_argument, NULL, ARG_RECOVERY_KEY },
3353 { "and-resize", required_argument, NULL, ARG_AND_RESIZE },
3354 { "and-change-password", required_argument, NULL, ARG_AND_CHANGE_PASSWORD },
3355 { "drop-caches", required_argument, NULL, ARG_DROP_CACHES },
3356 { "luks-extra-mount-options", required_argument, NULL, ARG_LUKS_EXTRA_MOUNT_OPTIONS },
3357 { "auto-resize-mode", required_argument, NULL, ARG_AUTO_RESIZE_MODE },
3358 { "rebalance-weight", required_argument, NULL, ARG_REBALANCE_WEIGHT },
3359 { "capability-bounding-set", required_argument, NULL, ARG_CAPABILITY_BOUNDING_SET },
3360 { "capability-ambient-set", required_argument, NULL, ARG_CAPABILITY_AMBIENT_SET },
3361 { "prompt-new-user", no_argument, NULL, ARG_PROMPT_NEW_USER },
3362 { "blob", required_argument, NULL, 'b' },
3363 { "avatar", required_argument, NULL, ARG_AVATAR },
3364 { "login-background", required_argument, NULL, ARG_LOGIN_BACKGROUND },
3365 { "tmp-limit", required_argument, NULL, ARG_TMP_LIMIT },
3366 { "dev-shm-limit", required_argument, NULL, ARG_DEV_SHM_LIMIT },
3367 { "default-area", required_argument, NULL, ARG_DEFAULT_AREA },
3368 { "key-name", required_argument, NULL, ARG_KEY_NAME },
3369 { "seize", required_argument, NULL, ARG_SEIZE },
3370 { "match", required_argument, NULL, ARG_MATCH },
3371 {}
3372 };
3373
3374 int r;
3375
3376 /* This points to one of arg_identity_extra, arg_identity_extra_this_machine,
3377 * arg_identity_extra_other_machines, in order to redirect changes on the next property being set to
3378 * this part of the identity, instead of the default. */
3379 sd_json_variant **match_identity = NULL;
3380
3381 assert(argc >= 0);
3382 assert(argv);
3383
3384 /* Eventually we should probably turn this into a proper --dry-run option, but as long as it is not hooked up everywhere let's make it an environment variable only. */
3385 r = getenv_bool("SYSTEMD_HOME_DRY_RUN");
3386 if (r >= 0)
3387 arg_dry_run = r;
3388 else if (r != -ENXIO)
3389 log_debug_errno(r, "Unable to parse $SYSTEMD_HOME_DRY_RUN, ignoring: %m");
3390
3391 for (;;) {
3392 int c;
3393
3394 c = getopt_long(argc, argv, "hH:M:I:c:d:u:G:k:s:e:b:jPENAT", options, NULL);
3395 if (c < 0)
3396 break;
3397
3398 switch (c) {
3399
3400 case 'h':
3401 return help(0, NULL, NULL);
3402
3403 case ARG_VERSION:
3404 return version();
3405
3406 case ARG_NO_PAGER:
3407 arg_pager_flags |= PAGER_DISABLE;
3408 break;
3409
3410 case ARG_NO_LEGEND:
3411 arg_legend = false;
3412 break;
3413
3414 case ARG_NO_ASK_PASSWORD:
3415 arg_ask_password = false;
3416 break;
3417
3418 case ARG_OFFLINE:
3419 arg_offline = true;
3420 break;
3421
3422 case 'H':
3423 arg_transport = BUS_TRANSPORT_REMOTE;
3424 arg_host = optarg;
3425 break;
3426
3427 case 'M':
3428 r = parse_machine_argument(optarg, &arg_host, &arg_transport);
3429 if (r < 0)
3430 return r;
3431 break;
3432
3433 case 'I':
3434 arg_identity = optarg;
3435 break;
3436
3437 case 'c':
3438 if (isempty(optarg)) {
3439 r = drop_from_identity("realName");
3440 if (r < 0)
3441 return r;
3442
3443 break;
3444 }
3445
3446 if (!valid_gecos(optarg))
3447 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Real name '%s' not a valid GECOS field.", optarg);
3448
3449 r = sd_json_variant_set_field_string(match_identity ?: &arg_identity_extra, "realName", optarg);
3450 if (r < 0)
3451 return log_error_errno(r, "Failed to set realName field: %m");
3452
3453 break;
3454
3455 case ARG_ALIAS: {
3456 if (isempty(optarg)) {
3457 r = drop_from_identity("aliases");
3458 if (r < 0)
3459 return r;
3460 break;
3461 }
3462
3463 for (const char *p = optarg;;) {
3464 _cleanup_free_ char *word = NULL;
3465
3466 r = extract_first_word(&p, &word, ",", 0);
3467 if (r < 0)
3468 return log_error_errno(r, "Failed to parse alias list: %m");
3469 if (r == 0)
3470 break;
3471
3472 if (!valid_user_group_name(word, 0))
3473 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Invalid alias user name %s.", word);
3474
3475 _cleanup_(sd_json_variant_unrefp) sd_json_variant *av =
3476 sd_json_variant_ref(sd_json_variant_by_key(arg_identity_extra, "aliases"));
3477
3478 _cleanup_strv_free_ char **list = NULL;
3479 r = sd_json_variant_strv(av, &list);
3480 if (r < 0)
3481 return log_error_errno(r, "Failed to parse group list: %m");
3482
3483 r = strv_extend(&list, word);
3484 if (r < 0)
3485 return log_oom();
3486
3487 strv_sort_uniq(list);
3488
3489 av = sd_json_variant_unref(av);
3490 r = sd_json_variant_new_array_strv(&av, list);
3491 if (r < 0)
3492 return log_error_errno(r, "Failed to create alias list JSON: %m");
3493
3494 r = sd_json_variant_set_field(&arg_identity_extra, "aliases", av);
3495 if (r < 0)
3496 return log_error_errno(r, "Failed to update alias list: %m");
3497 }
3498
3499 break;
3500 }
3501
3502 case 'd': {
3503 _cleanup_free_ char *hd = NULL;
3504
3505 if (isempty(optarg)) {
3506 r = drop_from_identity("homeDirectory");
3507 if (r < 0)
3508 return r;
3509
3510 break;
3511 }
3512
3513 r = parse_path_argument(optarg, false, &hd);
3514 if (r < 0)
3515 return r;
3516
3517 if (!valid_home(hd))
3518 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Home directory '%s' not valid.", hd);
3519
3520 r = sd_json_variant_set_field_string(&arg_identity_extra, "homeDirectory", hd);
3521 if (r < 0)
3522 return log_error_errno(r, "Failed to set homeDirectory field: %m");
3523
3524 break;
3525 }
3526
3527 case ARG_REALM:
3528 if (isempty(optarg)) {
3529 r = drop_from_identity("realm");
3530 if (r < 0)
3531 return r;
3532
3533 break;
3534 }
3535
3536 r = dns_name_is_valid(optarg);
3537 if (r < 0)
3538 return log_error_errno(r, "Failed to determine whether realm '%s' is a valid DNS domain: %m", optarg);
3539 if (r == 0)
3540 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Realm '%s' is not a valid DNS domain.", optarg);
3541
3542 r = sd_json_variant_set_field_string(&arg_identity_extra, "realm", optarg);
3543 if (r < 0)
3544 return log_error_errno(r, "Failed to set realm field: %m");
3545 break;
3546
3547 case ARG_EMAIL_ADDRESS:
3548 case ARG_LOCATION:
3549 case ARG_ICON_NAME:
3550 case ARG_CIFS_USER_NAME:
3551 case ARG_CIFS_DOMAIN:
3552 case ARG_CIFS_EXTRA_MOUNT_OPTIONS:
3553 case ARG_LUKS_EXTRA_MOUNT_OPTIONS:
3554 case ARG_SESSION_LAUNCHER:
3555 case ARG_SESSION_TYPE: {
3556
3557 const char *field =
3558 c == ARG_EMAIL_ADDRESS ? "emailAddress" :
3559 c == ARG_LOCATION ? "location" :
3560 c == ARG_ICON_NAME ? "iconName" :
3561 c == ARG_CIFS_USER_NAME ? "cifsUserName" :
3562 c == ARG_CIFS_DOMAIN ? "cifsDomain" :
3563 c == ARG_CIFS_EXTRA_MOUNT_OPTIONS ? "cifsExtraMountOptions" :
3564 c == ARG_LUKS_EXTRA_MOUNT_OPTIONS ? "luksExtraMountOptions" :
3565 c == ARG_SESSION_LAUNCHER ? "preferredSessionLauncher" :
3566 c == ARG_SESSION_TYPE ? "preferredSessionType" :
3567 NULL;
3568
3569 assert(field);
3570
3571 if (isempty(optarg)) {
3572 r = drop_from_identity(field);
3573 if (r < 0)
3574 return r;
3575
3576 break;
3577 }
3578
3579 r = sd_json_variant_set_field_string(match_identity ?: &arg_identity_extra, field, optarg);
3580 if (r < 0)
3581 return log_error_errno(r, "Failed to set %s field: %m", field);
3582
3583 break;
3584 }
3585
3586 case ARG_CIFS_SERVICE:
3587 if (isempty(optarg)) {
3588 r = drop_from_identity("cifsService");
3589 if (r < 0)
3590 return r;
3591
3592 break;
3593 }
3594
3595 r = parse_cifs_service(optarg, NULL, NULL, NULL);
3596 if (r < 0)
3597 return log_error_errno(r, "Failed to validate CIFS service name: %s", optarg);
3598
3599 r = sd_json_variant_set_field_string(match_identity ?: &arg_identity_extra, "cifsService", optarg);
3600 if (r < 0)
3601 return log_error_errno(r, "Failed to set cifsService field: %m");
3602
3603 break;
3604
3605 case ARG_PASSWORD_HINT:
3606 if (isempty(optarg)) {
3607 r = drop_from_identity("passwordHint");
3608 if (r < 0)
3609 return r;
3610
3611 break;
3612 }
3613
3614 r = sd_json_variant_set_field_string(&arg_identity_extra_privileged, "passwordHint", optarg);
3615 if (r < 0)
3616 return log_error_errno(r, "Failed to set passwordHint field: %m");
3617
3618 string_erase(optarg);
3619 break;
3620
3621 case ARG_NICE: {
3622 int nc;
3623
3624 if (isempty(optarg)) {
3625 r = drop_from_identity("niceLevel");
3626 if (r < 0)
3627 return r;
3628 break;
3629 }
3630
3631 r = parse_nice(optarg, &nc);
3632 if (r < 0)
3633 return log_error_errno(r, "Failed to parse nice level: %s", optarg);
3634
3635 r = sd_json_variant_set_field_integer(match_identity ?: &arg_identity_extra, "niceLevel", nc);
3636 if (r < 0)
3637 return log_error_errno(r, "Failed to set niceLevel field: %m");
3638
3639 break;
3640 }
3641
3642 case ARG_RLIMIT: {
3643 _cleanup_(sd_json_variant_unrefp) sd_json_variant *jcur = NULL, *jmax = NULL;
3644 _cleanup_free_ char *field = NULL, *t = NULL;
3645 const char *eq;
3646 struct rlimit rl;
3647 int l;
3648
3649 if (isempty(optarg)) {
3650 /* Remove all resource limits */
3651
3652 r = drop_from_identity("resourceLimits");
3653 if (r < 0)
3654 return r;
3655
3656 arg_identity_filter_rlimits = strv_free(arg_identity_filter_rlimits);
3657 arg_identity_extra_rlimits = sd_json_variant_unref(arg_identity_extra_rlimits);
3658 break;
3659 }
3660
3661 eq = strchr(optarg, '=');
3662 if (!eq)
3663 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Can't parse resource limit assignment: %s", optarg);
3664
3665 field = strndup(optarg, eq - optarg);
3666 if (!field)
3667 return log_oom();
3668
3669 l = rlimit_from_string_harder(field);
3670 if (l < 0)
3671 return log_error_errno(l, "Unknown resource limit type: %s", field);
3672
3673 if (isempty(eq + 1)) {
3674 /* Remove only the specific rlimit */
3675
3676 r = strv_extend(&arg_identity_filter_rlimits, rlimit_to_string(l));
3677 if (r < 0)
3678 return r;
3679
3680 r = sd_json_variant_filter(&arg_identity_extra_rlimits, STRV_MAKE(field));
3681 if (r < 0)
3682 return log_error_errno(r, "Failed to filter JSON identity data: %m");
3683
3684 break;
3685 }
3686
3687 r = rlimit_parse(l, eq + 1, &rl);
3688 if (r < 0)
3689 return log_error_errno(r, "Failed to parse resource limit value: %s", eq + 1);
3690
3691 r = rl.rlim_cur == RLIM_INFINITY ? sd_json_variant_new_null(&jcur) : sd_json_variant_new_unsigned(&jcur, rl.rlim_cur);
3692 if (r < 0)
3693 return log_error_errno(r, "Failed to allocate current integer: %m");
3694
3695 r = rl.rlim_max == RLIM_INFINITY ? sd_json_variant_new_null(&jmax) : sd_json_variant_new_unsigned(&jmax, rl.rlim_max);
3696 if (r < 0)
3697 return log_error_errno(r, "Failed to allocate maximum integer: %m");
3698
3699 t = strjoin("RLIMIT_", rlimit_to_string(l));
3700 if (!t)
3701 return log_oom();
3702
3703 r = sd_json_variant_set_fieldbo(
3704 &arg_identity_extra_rlimits, t,
3705 SD_JSON_BUILD_PAIR("cur", SD_JSON_BUILD_VARIANT(jcur)),
3706 SD_JSON_BUILD_PAIR("max", SD_JSON_BUILD_VARIANT(jmax)));
3707 if (r < 0)
3708 return log_error_errno(r, "Failed to set %s field: %m", rlimit_to_string(l));
3709
3710 break;
3711 }
3712
3713 case 'u': {
3714 uid_t uid;
3715
3716 if (isempty(optarg)) {
3717 r = drop_from_identity("uid");
3718 if (r < 0)
3719 return r;
3720
3721 break;
3722 }
3723
3724 r = parse_uid(optarg, &uid);
3725 if (r < 0)
3726 return log_error_errno(r, "Failed to parse UID '%s'.", optarg);
3727
3728 if (uid_is_system(uid))
3729 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "UID " UID_FMT " is in system range, refusing.", uid);
3730 if (uid_is_greeter(uid))
3731 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "UID " UID_FMT " is in greeter range, refusing.", uid);
3732 if (uid_is_dynamic(uid))
3733 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "UID " UID_FMT " is in dynamic range, refusing.", uid);
3734 if (uid == UID_NOBODY)
3735 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "UID " UID_FMT " is nobody UID, refusing.", uid);
3736
3737 r = sd_json_variant_set_field_unsigned(&arg_identity_extra, "uid", uid);
3738 if (r < 0)
3739 return log_error_errno(r, "Failed to set realm field: %m");
3740
3741 break;
3742 }
3743
3744 case 'k':
3745 case ARG_IMAGE_PATH: {
3746 const char *field = c == 'k' ? "skeletonDirectory" : "imagePath";
3747 _cleanup_free_ char *v = NULL;
3748
3749 if (isempty(optarg)) {
3750 r = drop_from_identity(field);
3751 if (r < 0)
3752 return r;
3753
3754 break;
3755 }
3756
3757 r = parse_path_argument(optarg, false, &v);
3758 if (r < 0)
3759 return r;
3760
3761 r = sd_json_variant_set_field_string(match_identity ?: &arg_identity_extra_this_machine, field, v);
3762 if (r < 0)
3763 return log_error_errno(r, "Failed to set %s field: %m", v);
3764
3765 break;
3766 }
3767
3768 case 's':
3769 if (isempty(optarg)) {
3770 r = drop_from_identity("shell");
3771 if (r < 0)
3772 return r;
3773
3774 break;
3775 }
3776
3777 if (!valid_shell(optarg))
3778 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Shell '%s' not valid.", optarg);
3779
3780 r = sd_json_variant_set_field_string(match_identity ?: &arg_identity_extra, "shell", optarg);
3781 if (r < 0)
3782 return log_error_errno(r, "Failed to set shell field: %m");
3783
3784 break;
3785
3786 case ARG_SETENV: {
3787 _cleanup_free_ char **l = NULL;
3788 _cleanup_(sd_json_variant_unrefp) sd_json_variant *ne = NULL;
3789 sd_json_variant *e;
3790
3791 if (isempty(optarg)) {
3792 r = drop_from_identity("environment");
3793 if (r < 0)
3794 return r;
3795
3796 break;
3797 }
3798
3799 e = sd_json_variant_by_key(match_identity ? *match_identity: arg_identity_extra, "environment");
3800 if (e) {
3801 r = sd_json_variant_strv(e, &l);
3802 if (r < 0)
3803 return log_error_errno(r, "Failed to parse JSON environment field: %m");
3804 }
3805
3806 r = strv_env_replace_strdup_passthrough(&l, optarg);
3807 if (r < 0)
3808 return log_error_errno(r, "Cannot assign environment variable %s: %m", optarg);
3809
3810 strv_sort(l);
3811
3812 r = sd_json_variant_new_array_strv(&ne, l);
3813 if (r < 0)
3814 return log_error_errno(r, "Failed to allocate environment list JSON: %m");
3815
3816 r = sd_json_variant_set_field(match_identity ?: &arg_identity_extra, "environment", ne);
3817 if (r < 0)
3818 return log_error_errno(r, "Failed to set environment list: %m");
3819
3820 break;
3821 }
3822
3823 case ARG_TIMEZONE:
3824 if (isempty(optarg)) {
3825 r = drop_from_identity("timeZone");
3826 if (r < 0)
3827 return r;
3828
3829 break;
3830 }
3831
3832 if (!timezone_is_valid(optarg, LOG_DEBUG))
3833 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Timezone '%s' is not valid.", optarg);
3834
3835 r = sd_json_variant_set_field_string(match_identity ?: &arg_identity_extra, "timeZone", optarg);
3836 if (r < 0)
3837 return log_error_errno(r, "Failed to set timezone field: %m");
3838
3839 break;
3840
3841 case ARG_LANGUAGE: {
3842 const char *p = optarg;
3843
3844 if (isempty(p)) {
3845 r = drop_from_identity("preferredLanguage");
3846 if (r < 0)
3847 return r;
3848
3849 r = drop_from_identity("additionalLanguages");
3850 if (r < 0)
3851 return r;
3852
3853 arg_languages = strv_free(arg_languages);
3854 break;
3855 }
3856
3857 for (;;) {
3858 _cleanup_free_ char *word = NULL;
3859
3860 r = extract_first_word(&p, &word, ",:", 0);
3861 if (r < 0)
3862 return log_error_errno(r, "Failed to parse locale list: %m");
3863 if (r == 0)
3864 break;
3865
3866 if (!locale_is_valid(word))
3867 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Locale '%s' is not valid.", word);
3868
3869 if (locale_is_installed(word) <= 0)
3870 log_warning("Locale '%s' is not installed, accepting anyway.", word);
3871
3872 r = strv_consume(&arg_languages, TAKE_PTR(word));
3873 if (r < 0)
3874 return log_oom();
3875
3876 strv_uniq(arg_languages);
3877 }
3878
3879 break;
3880 }
3881
3882 case ARG_NOSUID:
3883 case ARG_NODEV:
3884 case ARG_NOEXEC:
3885 case ARG_LOCKED:
3886 case ARG_KILL_PROCESSES:
3887 case ARG_ENFORCE_PASSWORD_POLICY:
3888 case ARG_AUTO_LOGIN:
3889 case ARG_PASSWORD_CHANGE_NOW: {
3890 const char *field =
3891 c == ARG_LOCKED ? "locked" :
3892 c == ARG_NOSUID ? "mountNoSuid" :
3893 c == ARG_NODEV ? "mountNoDevices" :
3894 c == ARG_NOEXEC ? "mountNoExecute" :
3895 c == ARG_KILL_PROCESSES ? "killProcesses" :
3896 c == ARG_ENFORCE_PASSWORD_POLICY ? "enforcePasswordPolicy" :
3897 c == ARG_AUTO_LOGIN ? "autoLogin" :
3898 c == ARG_PASSWORD_CHANGE_NOW ? "passwordChangeNow" :
3899 NULL;
3900
3901 assert(field);
3902
3903 if (isempty(optarg)) {
3904 r = drop_from_identity(field);
3905 if (r < 0)
3906 return r;
3907
3908 break;
3909 }
3910
3911 r = parse_boolean(optarg);
3912 if (r < 0)
3913 return log_error_errno(r, "Failed to parse %s boolean: %m", field);
3914
3915 r = sd_json_variant_set_field_boolean(match_identity ?: &arg_identity_extra, field, r > 0);
3916 if (r < 0)
3917 return log_error_errno(r, "Failed to set %s field: %m", field);
3918
3919 break;
3920 }
3921
3922 case 'P':
3923 r = sd_json_variant_set_field_boolean(&arg_identity_extra, "enforcePasswordPolicy", false);
3924 if (r < 0)
3925 return log_error_errno(r, "Failed to set enforcePasswordPolicy field: %m");
3926
3927 break;
3928
3929 case ARG_DISK_SIZE:
3930 if (isempty(optarg)) {
3931 FOREACH_STRING(prop, "diskSize", "diskSizeRelative", "rebalanceWeight") {
3932 r = drop_from_identity(prop);
3933 if (r < 0)
3934 return r;
3935 }
3936
3937 arg_disk_size = arg_disk_size_relative = UINT64_MAX;
3938 break;
3939 }
3940
3941 r = parse_permyriad(optarg);
3942 if (r < 0) {
3943 r = parse_disk_size(optarg, &arg_disk_size);
3944 if (r < 0)
3945 return r;
3946
3947 r = drop_from_identity("diskSizeRelative");
3948 if (r < 0)
3949 return r;
3950
3951 r = sd_json_variant_set_field_unsigned(match_identity ?: &arg_identity_extra_this_machine, "diskSize", arg_disk_size);
3952 if (r < 0)
3953 return log_error_errno(r, "Failed to set diskSize field: %m");
3954
3955 arg_disk_size_relative = UINT64_MAX;
3956 } else {
3957 /* Normalize to UINT32_MAX == 100% */
3958 arg_disk_size_relative = UINT32_SCALE_FROM_PERMYRIAD(r);
3959
3960 r = drop_from_identity("diskSize");
3961 if (r < 0)
3962 return r;
3963
3964 r = sd_json_variant_set_field_unsigned(match_identity ?: &arg_identity_extra_this_machine, "diskSizeRelative", arg_disk_size_relative);
3965 if (r < 0)
3966 return log_error_errno(r, "Failed to set diskSizeRelative field: %m");
3967
3968 arg_disk_size = UINT64_MAX;
3969 }
3970
3971 /* Automatically turn off the rebalance logic if user configured a size explicitly */
3972 r = sd_json_variant_set_field_unsigned(match_identity ?: &arg_identity_extra_this_machine, "rebalanceWeight", REBALANCE_WEIGHT_OFF);
3973 if (r < 0)
3974 return log_error_errno(r, "Failed to set rebalanceWeight field: %m");
3975
3976 break;
3977
3978 case ARG_ACCESS_MODE: {
3979 mode_t mode;
3980
3981 if (isempty(optarg)) {
3982 r = drop_from_identity("accessMode");
3983 if (r < 0)
3984 return r;
3985
3986 break;
3987 }
3988
3989 r = parse_mode(optarg, &mode);
3990 if (r < 0)
3991 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Access mode '%s' not valid.", optarg);
3992
3993 r = sd_json_variant_set_field_unsigned(&arg_identity_extra, "accessMode", mode);
3994 if (r < 0)
3995 return log_error_errno(r, "Failed to set access mode field: %m");
3996
3997 break;
3998 }
3999
4000 case ARG_LUKS_DISCARD:
4001 if (isempty(optarg)) {
4002 r = drop_from_identity("luksDiscard");
4003 if (r < 0)
4004 return r;
4005
4006 break;
4007 }
4008
4009 r = parse_boolean(optarg);
4010 if (r < 0)
4011 return log_error_errno(r, "Failed to parse --luks-discard= parameter: %s", optarg);
4012
4013 r = sd_json_variant_set_field_boolean(match_identity ?: &arg_identity_extra, "luksDiscard", r);
4014 if (r < 0)
4015 return log_error_errno(r, "Failed to set discard field: %m");
4016
4017 break;
4018
4019 case ARG_LUKS_OFFLINE_DISCARD:
4020 if (isempty(optarg)) {
4021 r = drop_from_identity("luksOfflineDiscard");
4022 if (r < 0)
4023 return r;
4024
4025 break;
4026 }
4027
4028 r = parse_boolean(optarg);
4029 if (r < 0)
4030 return log_error_errno(r, "Failed to parse --luks-offline-discard= parameter: %s", optarg);
4031
4032 r = sd_json_variant_set_field_boolean(match_identity ?: &arg_identity_extra, "luksOfflineDiscard", r);
4033 if (r < 0)
4034 return log_error_errno(r, "Failed to set offline discard field: %m");
4035
4036 break;
4037
4038 case ARG_LUKS_VOLUME_KEY_SIZE:
4039 case ARG_LUKS_PBKDF_FORCE_ITERATIONS:
4040 case ARG_LUKS_PBKDF_PARALLEL_THREADS:
4041 case ARG_RATE_LIMIT_BURST: {
4042 const char *field =
4043 c == ARG_LUKS_VOLUME_KEY_SIZE ? "luksVolumeKeySize" :
4044 c == ARG_LUKS_PBKDF_FORCE_ITERATIONS ? "luksPbkdfForceIterations" :
4045 c == ARG_LUKS_PBKDF_PARALLEL_THREADS ? "luksPbkdfParallelThreads" :
4046 c == ARG_RATE_LIMIT_BURST ? "rateLimitBurst" : NULL;
4047 unsigned n;
4048
4049 assert(field);
4050
4051 if (isempty(optarg)) {
4052 r = drop_from_identity(field);
4053 if (r < 0)
4054 return r;
4055 }
4056
4057 r = safe_atou(optarg, &n);
4058 if (r < 0)
4059 return log_error_errno(r, "Failed to parse %s parameter: %s", field, optarg);
4060
4061 r = sd_json_variant_set_field_unsigned(match_identity ?: &arg_identity_extra, field, n);
4062 if (r < 0)
4063 return log_error_errno(r, "Failed to set %s field: %m", field);
4064
4065 break;
4066 }
4067
4068 case ARG_LUKS_SECTOR_SIZE: {
4069 uint64_t ss;
4070
4071 if (isempty(optarg)) {
4072 r = drop_from_identity("luksSectorSize");
4073 if (r < 0)
4074 return r;
4075
4076 break;
4077 }
4078
4079 r = parse_sector_size(optarg, &ss);
4080 if (r < 0)
4081 return r;
4082
4083 r = sd_json_variant_set_field_unsigned(match_identity ?: &arg_identity_extra, "luksSectorSize", ss);
4084 if (r < 0)
4085 return log_error_errno(r, "Failed to set sector size field: %m");
4086
4087 break;
4088 }
4089
4090 case ARG_UMASK: {
4091 mode_t m;
4092
4093 if (isempty(optarg)) {
4094 r = drop_from_identity("umask");
4095 if (r < 0)
4096 return r;
4097
4098 break;
4099 }
4100
4101 r = parse_mode(optarg, &m);
4102 if (r < 0)
4103 return log_error_errno(r, "Failed to parse umask: %m");
4104
4105 r = sd_json_variant_set_field_integer(match_identity ?: &arg_identity_extra, "umask", m);
4106 if (r < 0)
4107 return log_error_errno(r, "Failed to set umask field: %m");
4108
4109 break;
4110 }
4111
4112 case ARG_SSH_AUTHORIZED_KEYS: {
4113 _cleanup_(sd_json_variant_unrefp) sd_json_variant *v = NULL;
4114 _cleanup_strv_free_ char **l = NULL, **add = NULL;
4115
4116 if (isempty(optarg)) {
4117 r = drop_from_identity("sshAuthorizedKeys");
4118 if (r < 0)
4119 return r;
4120
4121 break;
4122 }
4123
4124 if (optarg[0] == '@') {
4125 _cleanup_fclose_ FILE *f = NULL;
4126
4127 /* If prefixed with '@' read from a file */
4128
4129 f = fopen(optarg+1, "re");
4130 if (!f)
4131 return log_error_errno(errno, "Failed to open '%s': %m", optarg+1);
4132
4133 for (;;) {
4134 _cleanup_free_ char *line = NULL;
4135
4136 r = read_line(f, LONG_LINE_MAX, &line);
4137 if (r < 0)
4138 return log_error_errno(r, "Failed to read from '%s': %m", optarg+1);
4139 if (r == 0)
4140 break;
4141
4142 if (isempty(line))
4143 continue;
4144
4145 if (line[0] == '#')
4146 continue;
4147
4148 r = strv_consume(&add, TAKE_PTR(line));
4149 if (r < 0)
4150 return log_oom();
4151 }
4152 } else {
4153 /* Otherwise, assume it's a literal key. Let's do some superficial checks
4154 * before accept it though. */
4155
4156 if (string_has_cc(optarg, NULL))
4157 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Authorized key contains control characters, refusing.");
4158 if (optarg[0] == '#')
4159 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Specified key is a comment?");
4160
4161 add = strv_new(optarg);
4162 if (!add)
4163 return log_oom();
4164 }
4165
4166 v = sd_json_variant_ref(sd_json_variant_by_key(arg_identity_extra_privileged, "sshAuthorizedKeys"));
4167 if (v) {
4168 r = sd_json_variant_strv(v, &l);
4169 if (r < 0)
4170 return log_error_errno(r, "Failed to parse SSH authorized keys list: %m");
4171 }
4172
4173 r = strv_extend_strv_consume(&l, TAKE_PTR(add), /* filter_duplicates = */ true);
4174 if (r < 0)
4175 return log_oom();
4176
4177 v = sd_json_variant_unref(v);
4178
4179 r = sd_json_variant_new_array_strv(&v, l);
4180 if (r < 0)
4181 return log_oom();
4182
4183 r = sd_json_variant_set_field(&arg_identity_extra_privileged, "sshAuthorizedKeys", v);
4184 if (r < 0)
4185 return log_error_errno(r, "Failed to set authorized keys: %m");
4186
4187 break;
4188 }
4189
4190 case ARG_NOT_BEFORE:
4191 case ARG_NOT_AFTER:
4192 case 'e': {
4193 const char *field;
4194 usec_t n;
4195
4196 field = c == ARG_NOT_BEFORE ? "notBeforeUSec" :
4197 IN_SET(c, ARG_NOT_AFTER, 'e') ? "notAfterUSec" : NULL;
4198
4199 assert(field);
4200
4201 if (isempty(optarg)) {
4202 r = drop_from_identity(field);
4203 if (r < 0)
4204 return r;
4205
4206 break;
4207 }
4208
4209 /* Note the minor discrepancy regarding -e parsing here: we support that for compat
4210 * reasons, and in the original useradd(8) implementation it accepts dates in the
4211 * format YYYY-MM-DD. Coincidentally, we accept dates formatted like that too, but
4212 * with greater precision. */
4213 r = parse_timestamp(optarg, &n);
4214 if (r < 0)
4215 return log_error_errno(r, "Failed to parse %s parameter: %m", field);
4216
4217 r = sd_json_variant_set_field_unsigned(match_identity ?: &arg_identity_extra, field, n);
4218 if (r < 0)
4219 return log_error_errno(r, "Failed to set %s field: %m", field);
4220 break;
4221 }
4222
4223 case ARG_PASSWORD_CHANGE_MIN:
4224 case ARG_PASSWORD_CHANGE_MAX:
4225 case ARG_PASSWORD_CHANGE_WARN:
4226 case ARG_PASSWORD_CHANGE_INACTIVE: {
4227 const char *field;
4228 usec_t n;
4229
4230 field = c == ARG_PASSWORD_CHANGE_MIN ? "passwordChangeMinUSec" :
4231 c == ARG_PASSWORD_CHANGE_MAX ? "passwordChangeMaxUSec" :
4232 c == ARG_PASSWORD_CHANGE_WARN ? "passwordChangeWarnUSec" :
4233 c == ARG_PASSWORD_CHANGE_INACTIVE ? "passwordChangeInactiveUSec" :
4234 NULL;
4235
4236 assert(field);
4237
4238 if (isempty(optarg)) {
4239 r = drop_from_identity(field);
4240 if (r < 0)
4241 return r;
4242
4243 break;
4244 }
4245
4246 r = parse_sec(optarg, &n);
4247 if (r < 0)
4248 return log_error_errno(r, "Failed to parse %s parameter: %m", field);
4249
4250 r = sd_json_variant_set_field_unsigned(match_identity ?: &arg_identity_extra, field, n);
4251 if (r < 0)
4252 return log_error_errno(r, "Failed to set %s field: %m", field);
4253 break;
4254 }
4255
4256 case ARG_STORAGE:
4257 case ARG_FS_TYPE:
4258 case ARG_LUKS_CIPHER:
4259 case ARG_LUKS_CIPHER_MODE:
4260 case ARG_LUKS_PBKDF_TYPE:
4261 case ARG_LUKS_PBKDF_HASH_ALGORITHM: {
4262
4263 const char *field =
4264 c == ARG_STORAGE ? "storage" :
4265 c == ARG_FS_TYPE ? "fileSystemType" :
4266 c == ARG_LUKS_CIPHER ? "luksCipher" :
4267 c == ARG_LUKS_CIPHER_MODE ? "luksCipherMode" :
4268 c == ARG_LUKS_PBKDF_TYPE ? "luksPbkdfType" :
4269 c == ARG_LUKS_PBKDF_HASH_ALGORITHM ? "luksPbkdfHashAlgorithm" : NULL;
4270
4271 assert(field);
4272
4273 if (isempty(optarg)) {
4274 r = drop_from_identity(field);
4275 if (r < 0)
4276 return r;
4277
4278 break;
4279 }
4280
4281 if (!string_is_safe(optarg))
4282 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Parameter for %s field not valid: %s", field, optarg);
4283
4284 r = sd_json_variant_set_field_string(
4285 match_identity ?: (IN_SET(c, ARG_STORAGE, ARG_FS_TYPE) ?
4286 &arg_identity_extra_this_machine :
4287 &arg_identity_extra), field, optarg);
4288 if (r < 0)
4289 return log_error_errno(r, "Failed to set %s field: %m", field);
4290
4291 break;
4292 }
4293
4294 case ARG_LUKS_PBKDF_TIME_COST:
4295 case ARG_RATE_LIMIT_INTERVAL:
4296 case ARG_STOP_DELAY: {
4297 const char *field =
4298 c == ARG_LUKS_PBKDF_TIME_COST ? "luksPbkdfTimeCostUSec" :
4299 c == ARG_RATE_LIMIT_INTERVAL ? "rateLimitIntervalUSec" :
4300 c == ARG_STOP_DELAY ? "stopDelayUSec" :
4301 NULL;
4302 usec_t t;
4303
4304 assert(field);
4305
4306 if (isempty(optarg)) {
4307 r = drop_from_identity(field);
4308 if (r < 0)
4309 return r;
4310
4311 break;
4312 }
4313
4314 r = parse_sec(optarg, &t);
4315 if (r < 0)
4316 return log_error_errno(r, "Failed to parse %s field: %s", field, optarg);
4317
4318 r = sd_json_variant_set_field_unsigned(match_identity ?: &arg_identity_extra, field, t);
4319 if (r < 0)
4320 return log_error_errno(r, "Failed to set %s field: %m", field);
4321
4322 break;
4323 }
4324
4325 case 'G': {
4326 const char *p = optarg;
4327
4328 if (isempty(p)) {
4329 r = drop_from_identity("memberOf");
4330 if (r < 0)
4331 return r;
4332
4333 break;
4334 }
4335
4336 for (;;) {
4337 _cleanup_(sd_json_variant_unrefp) sd_json_variant *mo = NULL;
4338 _cleanup_strv_free_ char **list = NULL;
4339 _cleanup_free_ char *word = NULL;
4340
4341 r = extract_first_word(&p, &word, ",", 0);
4342 if (r < 0)
4343 return log_error_errno(r, "Failed to parse group list: %m");
4344 if (r == 0)
4345 break;
4346
4347 if (!valid_user_group_name(word, 0))
4348 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Invalid group name %s.", word);
4349
4350 mo = sd_json_variant_ref(sd_json_variant_by_key(arg_identity_extra, "memberOf"));
4351
4352 r = sd_json_variant_strv(mo, &list);
4353 if (r < 0)
4354 return log_error_errno(r, "Failed to parse group list: %m");
4355
4356 r = strv_extend(&list, word);
4357 if (r < 0)
4358 return log_oom();
4359
4360 strv_sort_uniq(list);
4361
4362 mo = sd_json_variant_unref(mo);
4363 r = sd_json_variant_new_array_strv(&mo, list);
4364 if (r < 0)
4365 return log_error_errno(r, "Failed to create group list JSON: %m");
4366
4367 r = sd_json_variant_set_field(match_identity ?: &arg_identity_extra, "memberOf", mo);
4368 if (r < 0)
4369 return log_error_errno(r, "Failed to update group list: %m");
4370 }
4371
4372 break;
4373 }
4374
4375 case ARG_TASKS_MAX: {
4376 uint64_t u;
4377
4378 if (isempty(optarg)) {
4379 r = drop_from_identity("tasksMax");
4380 if (r < 0)
4381 return r;
4382 break;
4383 }
4384
4385 r = safe_atou64(optarg, &u);
4386 if (r < 0)
4387 return log_error_errno(r, "Failed to parse --tasks-max= parameter: %s", optarg);
4388
4389 r = sd_json_variant_set_field_unsigned(match_identity ?: &arg_identity_extra, "tasksMax", u);
4390 if (r < 0)
4391 return log_error_errno(r, "Failed to set tasksMax field: %m");
4392
4393 break;
4394 }
4395
4396 case ARG_MEMORY_MAX:
4397 case ARG_MEMORY_HIGH:
4398 case ARG_LUKS_PBKDF_MEMORY_COST: {
4399 const char *field =
4400 c == ARG_MEMORY_MAX ? "memoryMax" :
4401 c == ARG_MEMORY_HIGH ? "memoryHigh" :
4402 c == ARG_LUKS_PBKDF_MEMORY_COST ? "luksPbkdfMemoryCost" : NULL;
4403
4404 uint64_t u;
4405
4406 assert(field);
4407
4408 if (isempty(optarg)) {
4409 r = drop_from_identity(field);
4410 if (r < 0)
4411 return r;
4412 break;
4413 }
4414
4415 r = parse_size(optarg, 1024, &u);
4416 if (r < 0)
4417 return log_error_errno(r, "Failed to parse %s parameter: %s", field, optarg);
4418
4419 r = sd_json_variant_set_field_unsigned(match_identity ?: &arg_identity_extra_this_machine, field, u);
4420 if (r < 0)
4421 return log_error_errno(r, "Failed to set %s field: %m", field);
4422
4423 break;
4424 }
4425
4426 case ARG_CPU_WEIGHT:
4427 case ARG_IO_WEIGHT: {
4428 const char *field = c == ARG_CPU_WEIGHT ? "cpuWeight" :
4429 c == ARG_IO_WEIGHT ? "ioWeight" : NULL;
4430 uint64_t u;
4431
4432 assert(field);
4433
4434 if (isempty(optarg)) {
4435 r = drop_from_identity(field);
4436 if (r < 0)
4437 return r;
4438 break;
4439 }
4440
4441 r = safe_atou64(optarg, &u);
4442 if (r < 0)
4443 return log_error_errno(r, "Failed to parse --cpu-weight=/--io-weight= parameter: %s", optarg);
4444
4445 if (!CGROUP_WEIGHT_IS_OK(u))
4446 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Weight %" PRIu64 " is out of valid weight range.", u);
4447
4448 r = sd_json_variant_set_field_unsigned(match_identity ?: &arg_identity_extra, field, u);
4449 if (r < 0)
4450 return log_error_errno(r, "Failed to set %s field: %m", field);
4451
4452 break;
4453 }
4454
4455 case ARG_PKCS11_TOKEN_URI:
4456 if (streq(optarg, "list"))
4457 return pkcs11_list_tokens();
4458
4459 /* If --pkcs11-token-uri= is specified we always drop everything old */
4460 FOREACH_STRING(p, "pkcs11TokenUri", "pkcs11EncryptedKey") {
4461 r = drop_from_identity(p);
4462 if (r < 0)
4463 return r;
4464 }
4465
4466 if (isempty(optarg)) {
4467 arg_pkcs11_token_uri = strv_free(arg_pkcs11_token_uri);
4468 break;
4469 }
4470
4471 if (streq(optarg, "auto")) {
4472 _cleanup_free_ char *found = NULL;
4473
4474 r = pkcs11_find_token_auto(&found);
4475 if (r < 0)
4476 return r;
4477 r = strv_consume(&arg_pkcs11_token_uri, TAKE_PTR(found));
4478 } else {
4479 if (!pkcs11_uri_valid(optarg))
4480 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Not a valid PKCS#11 URI: %s", optarg);
4481
4482 r = strv_extend(&arg_pkcs11_token_uri, optarg);
4483 }
4484 if (r < 0)
4485 return r;
4486
4487 strv_uniq(arg_pkcs11_token_uri);
4488 break;
4489
4490 case ARG_FIDO2_CRED_ALG:
4491 r = parse_fido2_algorithm(optarg, &arg_fido2_cred_alg);
4492 if (r < 0)
4493 return log_error_errno(r, "Failed to parse COSE algorithm: %s", optarg);
4494 break;
4495
4496 case ARG_FIDO2_DEVICE:
4497 if (streq(optarg, "list"))
4498 return fido2_list_devices();
4499
4500 FOREACH_STRING(p, "fido2HmacCredential", "fido2HmacSalt") {
4501 r = drop_from_identity(p);
4502 if (r < 0)
4503 return r;
4504 }
4505
4506 if (isempty(optarg)) {
4507 arg_fido2_device = strv_free(arg_fido2_device);
4508 break;
4509 }
4510
4511 if (streq(optarg, "auto")) {
4512 _cleanup_free_ char *found = NULL;
4513
4514 r = fido2_find_device_auto(&found);
4515 if (r < 0)
4516 return r;
4517
4518 r = strv_consume(&arg_fido2_device, TAKE_PTR(found));
4519 } else
4520 r = strv_extend(&arg_fido2_device, optarg);
4521 if (r < 0)
4522 return r;
4523
4524 strv_uniq(arg_fido2_device);
4525 break;
4526
4527 case ARG_FIDO2_WITH_PIN:
4528 r = parse_boolean_argument("--fido2-with-client-pin=", optarg, NULL);
4529 if (r < 0)
4530 return r;
4531
4532 SET_FLAG(arg_fido2_lock_with, FIDO2ENROLL_PIN, r);
4533 break;
4534
4535 case ARG_FIDO2_WITH_UP:
4536 r = parse_boolean_argument("--fido2-with-user-presence=", optarg, NULL);
4537 if (r < 0)
4538 return r;
4539
4540 SET_FLAG(arg_fido2_lock_with, FIDO2ENROLL_UP, r);
4541 break;
4542
4543 case ARG_FIDO2_WITH_UV:
4544 r = parse_boolean_argument("--fido2-with-user-verification=", optarg, NULL);
4545 if (r < 0)
4546 return r;
4547
4548 SET_FLAG(arg_fido2_lock_with, FIDO2ENROLL_UV, r);
4549 break;
4550
4551 case ARG_RECOVERY_KEY:
4552 r = parse_boolean(optarg);
4553 if (r < 0)
4554 return log_error_errno(r, "Failed to parse --recovery-key= argument: %s", optarg);
4555
4556 arg_recovery_key = r;
4557
4558 FOREACH_STRING(p, "recoveryKey", "recoveryKeyType") {
4559 r = drop_from_identity(p);
4560 if (r < 0)
4561 return r;
4562 }
4563
4564 break;
4565
4566 case ARG_AUTO_RESIZE_MODE:
4567 if (isempty(optarg)) {
4568 r = drop_from_identity("autoResizeMode");
4569 if (r < 0)
4570 return r;
4571
4572 break;
4573 }
4574
4575 r = auto_resize_mode_from_string(optarg);
4576 if (r < 0)
4577 return log_error_errno(r, "Failed to parse --auto-resize-mode= argument: %s", optarg);
4578
4579 r = sd_json_variant_set_field_string(match_identity ?: &arg_identity_extra, "autoResizeMode", auto_resize_mode_to_string(r));
4580 if (r < 0)
4581 return log_error_errno(r, "Failed to set autoResizeMode field: %m");
4582
4583 break;
4584
4585 case ARG_REBALANCE_WEIGHT: {
4586 uint64_t u;
4587
4588 if (isempty(optarg)) {
4589 r = drop_from_identity("rebalanceWeight");
4590 if (r < 0)
4591 return r;
4592 break;
4593 }
4594
4595 if (streq(optarg, "off"))
4596 u = REBALANCE_WEIGHT_OFF;
4597 else {
4598 r = safe_atou64(optarg, &u);
4599 if (r < 0)
4600 return log_error_errno(r, "Failed to parse --rebalance-weight= argument: %s", optarg);
4601
4602 if (u < REBALANCE_WEIGHT_MIN || u > REBALANCE_WEIGHT_MAX)
4603 return log_error_errno(SYNTHETIC_ERRNO(ERANGE), "Rebalancing weight out of valid range %" PRIu64 "%s%" PRIu64 ": %s",
4604 REBALANCE_WEIGHT_MIN, glyph(GLYPH_ELLIPSIS), REBALANCE_WEIGHT_MAX, optarg);
4605 }
4606
4607 /* Drop from per machine stuff and everywhere */
4608 r = drop_from_identity("rebalanceWeight");
4609 if (r < 0)
4610 return r;
4611
4612 /* Add to main identity */
4613 r = sd_json_variant_set_field_unsigned(match_identity ?: &arg_identity_extra, "rebalanceWeight", u);
4614 if (r < 0)
4615 return log_error_errno(r, "Failed to set rebalanceWeight field: %m");
4616
4617 break;
4618 }
4619
4620 case 'j':
4621 arg_json_format_flags = SD_JSON_FORMAT_PRETTY_AUTO|SD_JSON_FORMAT_COLOR_AUTO;
4622 break;
4623
4624 case ARG_JSON:
4625 r = parse_json_argument(optarg, &arg_json_format_flags);
4626 if (r <= 0)
4627 return r;
4628
4629 break;
4630
4631 case 'E':
4632 if (arg_export_format == EXPORT_FORMAT_FULL)
4633 arg_export_format = EXPORT_FORMAT_STRIPPED;
4634 else if (arg_export_format == EXPORT_FORMAT_STRIPPED)
4635 arg_export_format = EXPORT_FORMAT_MINIMAL;
4636 else
4637 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Specifying -E more than twice is not supported.");
4638
4639 arg_json_format_flags &= ~SD_JSON_FORMAT_OFF;
4640 if (arg_json_format_flags == 0)
4641 arg_json_format_flags = SD_JSON_FORMAT_PRETTY_AUTO|SD_JSON_FORMAT_COLOR_AUTO;
4642 break;
4643
4644 case ARG_EXPORT_FORMAT:
4645 if (streq(optarg, "full"))
4646 arg_export_format = EXPORT_FORMAT_FULL;
4647 else if (streq(optarg, "stripped"))
4648 arg_export_format = EXPORT_FORMAT_STRIPPED;
4649 else if (streq(optarg, "minimal"))
4650 arg_export_format = EXPORT_FORMAT_MINIMAL;
4651 else if (streq(optarg, "help")) {
4652 puts("full\n"
4653 "stripped\n"
4654 "minimal");
4655 return 0;
4656 }
4657
4658 break;
4659
4660 case ARG_AND_RESIZE:
4661 arg_and_resize = true;
4662 break;
4663
4664 case ARG_AND_CHANGE_PASSWORD:
4665 arg_and_change_password = true;
4666 break;
4667
4668 case ARG_DROP_CACHES: {
4669 if (isempty(optarg)) {
4670 r = drop_from_identity("dropCaches");
4671 if (r < 0)
4672 return r;
4673 break;
4674 }
4675
4676 r = parse_boolean_argument("--drop-caches=", optarg, NULL);
4677 if (r < 0)
4678 return r;
4679
4680 r = sd_json_variant_set_field_boolean(match_identity ?: &arg_identity_extra, "dropCaches", r);
4681 if (r < 0)
4682 return log_error_errno(r, "Failed to set drop caches field: %m");
4683
4684 break;
4685 }
4686
4687 case ARG_CAPABILITY_AMBIENT_SET:
4688 case ARG_CAPABILITY_BOUNDING_SET: {
4689 _cleanup_strv_free_ char **l = NULL;
4690 bool subtract = false;
4691 uint64_t parsed, *which, updated;
4692 const char *p, *field;
4693
4694 if (c == ARG_CAPABILITY_AMBIENT_SET) {
4695 which = &arg_capability_ambient_set;
4696 field = "capabilityAmbientSet";
4697 } else {
4698 assert(c == ARG_CAPABILITY_BOUNDING_SET);
4699 which = &arg_capability_bounding_set;
4700 field = "capabilityBoundingSet";
4701 }
4702
4703 if (isempty(optarg)) {
4704 r = drop_from_identity(field);
4705 if (r < 0)
4706 return r;
4707
4708 *which = UINT64_MAX;
4709 break;
4710 }
4711
4712 p = optarg;
4713 if (*p == '~') {
4714 subtract = true;
4715 p++;
4716 }
4717
4718 r = capability_set_from_string(p, &parsed);
4719 if (r == 0)
4720 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Invalid capabilities in capability string '%s'.", p);
4721 if (r < 0)
4722 return log_error_errno(r, "Failed to parse capability string '%s': %m", p);
4723
4724 if (*which == UINT64_MAX)
4725 updated = subtract ? all_capabilities() & ~parsed : parsed;
4726 else if (subtract)
4727 updated = *which & ~parsed;
4728 else
4729 updated = *which | parsed;
4730
4731 if (capability_set_to_strv(updated, &l) < 0)
4732 return log_oom();
4733
4734 r = sd_json_variant_set_field_strv(match_identity ?: &arg_identity_extra, field, l);
4735 if (r < 0)
4736 return log_error_errno(r, "Failed to set %s field: %m", field);
4737
4738 *which = updated;
4739 break;
4740 }
4741
4742 case ARG_PROMPT_NEW_USER:
4743 arg_prompt_new_user = true;
4744 break;
4745
4746 case 'b':
4747 case ARG_AVATAR:
4748 case ARG_LOGIN_BACKGROUND: {
4749 _cleanup_close_ int fd = -EBADF;
4750 _cleanup_free_ char *path = NULL, *filename = NULL;
4751
4752 if (c == 'b') {
4753 char *eq;
4754
4755 if (isempty(optarg)) { /* --blob= deletes everything, including existing blob dirs */
4756 hashmap_clear(arg_blob_files);
4757 arg_blob_dir = mfree(arg_blob_dir);
4758 arg_blob_clear = true;
4759 break;
4760 }
4761
4762 eq = strrchr(optarg, '=');
4763 if (!eq) { /* --blob=/some/path replaces the blob dir */
4764 r = parse_path_argument(optarg, false, &arg_blob_dir);
4765 if (r < 0)
4766 return log_error_errno(r, "Failed to parse path %s: %m", optarg);
4767 break;
4768 }
4769
4770 /* --blob=filename=/some/path replaces the file "filename" with /some/path */
4771 filename = strndup(optarg, eq - optarg);
4772 if (!filename)
4773 return log_oom();
4774
4775 if (isempty(filename))
4776 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Can't parse blob file assignment: %s", optarg);
4777 if (!suitable_blob_filename(filename))
4778 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Invalid blob filename: %s", filename);
4779
4780 r = parse_path_argument(eq + 1, false, &path);
4781 if (r < 0)
4782 return log_error_errno(r, "Failed to parse path %s: %m", eq + 1);
4783 } else {
4784 const char *well_known_filename =
4785 c == ARG_AVATAR ? "avatar" :
4786 c == ARG_LOGIN_BACKGROUND ? "login-background" :
4787 NULL;
4788 assert(well_known_filename);
4789
4790 filename = strdup(well_known_filename);
4791 if (!filename)
4792 return log_oom();
4793
4794 r = parse_path_argument(optarg, false, &path);
4795 if (r < 0)
4796 return log_error_errno(r, "Failed to parse path %s: %m", optarg);
4797 }
4798
4799 if (path) {
4800 fd = open(path, O_RDONLY|O_CLOEXEC|O_NOCTTY);
4801 if (fd < 0)
4802 return log_error_errno(errno, "Failed to open %s: %m", path);
4803
4804 if (fd_verify_regular(fd) < 0)
4805 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Provided blob is not a regular file: %s", path);
4806 } else
4807 fd = -EBADF; /* Delete the file */
4808
4809 r = hashmap_ensure_put(&arg_blob_files, &blob_fd_hash_ops, filename, FD_TO_PTR(fd));
4810 if (r < 0)
4811 return log_error_errno(r, "Failed to map %s to %s in blob directory: %m", path, filename);
4812 TAKE_PTR(filename); /* hashmap takes ownership */
4813 TAKE_FD(fd);
4814
4815 break;
4816 }
4817
4818 case ARG_TMP_LIMIT:
4819 case ARG_DEV_SHM_LIMIT: {
4820 const char *field =
4821 c == ARG_TMP_LIMIT ? "tmpLimit" :
4822 c == ARG_DEV_SHM_LIMIT ? "devShmLimit" : NULL;
4823 const char *field_scale =
4824 c == ARG_TMP_LIMIT ? "tmpLimitScale" :
4825 c == ARG_DEV_SHM_LIMIT ? "devShmLimitScale" : NULL;
4826
4827 assert(field);
4828 assert(field_scale);
4829
4830 if (isempty(optarg)) {
4831 r = drop_from_identity(field);
4832 if (r < 0)
4833 return r;
4834 r = drop_from_identity(field_scale);
4835 if (r < 0)
4836 return r;
4837 break;
4838 }
4839
4840 r = parse_permyriad(optarg);
4841 if (r < 0) {
4842 uint64_t u;
4843
4844 r = parse_size(optarg, 1024, &u);
4845 if (r < 0)
4846 return log_error_errno(r, "Failed to parse %s/%s parameter: %s", field, field_scale, optarg);
4847
4848 r = sd_json_variant_set_field_unsigned(match_identity ?: &arg_identity_extra, field, u);
4849 if (r < 0)
4850 return log_error_errno(r, "Failed to set %s field: %m", field);
4851
4852 r = drop_from_identity(field_scale);
4853 if (r < 0)
4854 return r;
4855 } else {
4856 r = sd_json_variant_set_field_unsigned(match_identity ?: &arg_identity_extra, field_scale, UINT32_SCALE_FROM_PERMYRIAD(r));
4857 if (r < 0)
4858 return log_error_errno(r, "Failed to set %s field: %m", field_scale);
4859
4860 r = drop_from_identity(field);
4861 if (r < 0)
4862 return r;
4863 }
4864
4865 break;
4866 }
4867
4868 case ARG_DEFAULT_AREA:
4869 if (isempty(optarg)) {
4870 r = drop_from_identity("defaultArea");
4871 if (r < 0)
4872 return r;
4873
4874 break;
4875 }
4876
4877 if (!filename_is_valid(optarg))
4878 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Parameter for default area field not valid: %s", optarg);
4879
4880 r = sd_json_variant_set_field_string(match_identity ?: &arg_identity_extra, "defaultArea", optarg);
4881 if (r < 0)
4882 return log_error_errno(r, "Failed to set default area field: %m");
4883
4884 break;
4885
4886 case ARG_KEY_NAME:
4887 if (isempty(optarg)) {
4888 arg_key_name = mfree(arg_key_name);
4889 return 0;
4890 }
4891
4892 if (!filename_is_valid(optarg))
4893 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Specified key name not valid: %s", optarg);
4894
4895 r = free_and_strdup_warn(&arg_key_name, optarg);
4896 if (r < 0)
4897 return r;
4898
4899 break;
4900
4901 case ARG_SEIZE:
4902 r = parse_boolean_argument("--seize=", optarg, &arg_seize);
4903 if (r < 0)
4904 return r;
4905 break;
4906
4907 case ARG_MATCH:
4908 if (streq(optarg, "any"))
4909 match_identity = &arg_identity_extra;
4910 else if (streq(optarg, "this"))
4911 match_identity = &arg_identity_extra_this_machine;
4912 else if (streq(optarg, "other"))
4913 match_identity = &arg_identity_extra_other_machines;
4914 else if (streq(optarg, "auto"))
4915 match_identity = NULL;
4916 else
4917 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "--machine= argument not understood. Refusing.");
4918 break;
4919
4920 case 'A':
4921 match_identity = &arg_identity_extra;
4922 break;
4923 case 'T':
4924 match_identity = &arg_identity_extra_this_machine;
4925 break;
4926 case 'N':
4927 match_identity = &arg_identity_extra_other_machines;
4928 break;
4929
4930 case '?':
4931 return -EINVAL;
4932
4933 default:
4934 assert_not_reached();
4935 }
4936 }
4937
4938 if (!strv_isempty(arg_pkcs11_token_uri) || !strv_isempty(arg_fido2_device))
4939 arg_and_change_password = true;
4940
4941 if (arg_disk_size != UINT64_MAX || arg_disk_size_relative != UINT64_MAX)
4942 arg_and_resize = true;
4943
4944 if (!strv_isempty(arg_languages)) {
4945 char **additional;
4946
4947 r = sd_json_variant_set_field_string(&arg_identity_extra, "preferredLanguage", arg_languages[0]);
4948 if (r < 0)
4949 return log_error_errno(r, "Failed to update preferred language: %m");
4950
4951 additional = strv_skip(arg_languages, 1);
4952 if (!strv_isempty(additional)) {
4953 r = sd_json_variant_set_field_strv(&arg_identity_extra, "additionalLanguages", additional);
4954 if (r < 0)
4955 return log_error_errno(r, "Failed to update additional language list: %m");
4956 } else {
4957 r = drop_from_identity("additionalLanguages");
4958 if (r < 0)
4959 return r;
4960 }
4961 }
4962
4963 return 1;
4964}
4965
4966static int redirect_bus_mgr(void) {
4967 const char *suffix;
4968
4969 /* Talk to a different service if that's requested. (The same env var is also understood by homed, so
4970 * that it is relatively easily possible to invoke a second instance of homed for debug purposes and
4971 * have homectl talk to it, without colliding with the host version. This is handy when operating
4972 * from a homed-managed account.) */
4973
4974 suffix = getenv("SYSTEMD_HOME_DEBUG_SUFFIX");
4975 if (suffix) {
4976 static BusLocator locator = {
4977 .path = "/org/freedesktop/home1",
4978 .interface = "org.freedesktop.home1.Manager",
4979 };
4980
4981 /* Yes, we leak this memory, but there's little point to collect this, given that we only do
4982 * this in a debug environment, do it only once, and the string shall live for out entire
4983 * process runtime. */
4984
4985 locator.destination = strjoin("org.freedesktop.home1.", suffix);
4986 if (!locator.destination)
4987 return log_oom();
4988
4989 bus_mgr = &locator;
4990 } else
4991 bus_mgr = bus_home_mgr;
4992
4993 return 0;
4994}
4995
4996static bool is_fallback_shell(const char *p) {
4997 const char *q;
4998
4999 if (!p)
5000 return false;
5001
5002 if (p[0] == '-') {
5003 /* Skip over login shell dash */
5004 p++;
5005
5006 if (streq(p, "ystemd-home-fallback-shell")) /* maybe the dash was used to override the binary name? */
5007 return true;
5008 }
5009
5010 q = strrchr(p, '/'); /* Skip over path */
5011 if (q)
5012 p = q + 1;
5013
5014 return streq(p, "systemd-home-fallback-shell");
5015}
5016
5017static int fallback_shell(int argc, char *argv[]) {
5018 _cleanup_(user_record_unrefp) UserRecord *secret = NULL, *hr = NULL;
5019 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
5020 _cleanup_strv_free_ char **l = NULL;
5021 _cleanup_free_ char *argv0 = NULL;
5022 const char *json, *hd, *shell;
5023 int r, incomplete;
5024
5025 /* So here's the deal: if users log into a system via ssh, and their homed-managed home directory
5026 * wasn't activated yet, SSH will permit the access but the home directory isn't actually available
5027 * yet. SSH doesn't allow us to ask authentication questions from the PAM session stack, and doesn't
5028 * run the PAM authentication stack (because it authenticates via its own key management, after
5029 * all). So here's our way to support this: homectl can be invoked as a multi-call binary under the
5030 * name "systemd-home-fallback-shell". If so, it will chainload a login shell, but first try to
5031 * unlock the home directory of the user it is invoked as. systemd-homed will then override the shell
5032 * listed in user records whose home directory is not activated yet with this pseudo-shell. Net
5033 * effect: one SSH auth succeeds this pseudo shell gets invoked, which will unlock the homedir
5034 * (possibly asking for a passphrase) and then chainload the regular shell. Once the login is
5035 * complete the user record will look like any other. */
5036
5037 r = acquire_bus(&bus);
5038 if (r < 0)
5039 return r;
5040
5041 for (unsigned n_tries = 0;; n_tries++) {
5042 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
5043 _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
5044 _cleanup_(sd_json_variant_unrefp) sd_json_variant *v = NULL;
5045
5046 if (n_tries >= 5)
5047 return log_error_errno(SYNTHETIC_ERRNO(ENOTRECOVERABLE),
5048 "Failed to activate home dir, even after %u tries.", n_tries);
5049
5050 /* Let's start by checking if this all is even necessary, i.e. if the useFallback boolean field is actually set. */
5051 r = bus_call_method(bus, bus_mgr, "GetUserRecordByName", &error, &reply, "s", NULL); /* empty user string means: our calling user */
5052 if (r < 0)
5053 return log_error_errno(r, "Failed to inspect home: %s", bus_error_message(&error, r));
5054
5055 r = sd_bus_message_read(reply, "sbo", &json, NULL, NULL);
5056 if (r < 0)
5057 return bus_log_parse_error(r);
5058
5059 r = sd_json_parse(json, SD_JSON_PARSE_SENSITIVE, &v, NULL, NULL);
5060 if (r < 0)
5061 return log_error_errno(r, "Failed to parse JSON identity: %m");
5062
5063 hr = user_record_new();
5064 if (!hr)
5065 return log_oom();
5066
5067 r = user_record_load(hr, v, USER_RECORD_LOAD_REFUSE_SECRET|USER_RECORD_LOG|USER_RECORD_PERMISSIVE);
5068 if (r < 0)
5069 return r;
5070
5071 if (!hr->use_fallback) /* Nice! We are done, fallback logic not necessary */
5072 break;
5073
5074 if (!secret) {
5075 r = acquire_passed_secrets(hr->user_name, &secret);
5076 if (r < 0)
5077 return r;
5078 }
5079
5080 for (;;) {
5081 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
5082
5083 r = bus_message_new_method_call(bus, &m, bus_mgr, "ActivateHomeIfReferenced");
5084 if (r < 0)
5085 return bus_log_create_error(r);
5086
5087 r = sd_bus_message_append(m, "s", NULL); /* empty user string means: our calling user */
5088 if (r < 0)
5089 return bus_log_create_error(r);
5090
5091 r = bus_message_append_secret(m, secret);
5092 if (r < 0)
5093 return bus_log_create_error(r);
5094
5095 r = sd_bus_call(bus, m, HOME_SLOW_BUS_CALL_TIMEOUT_USEC, &error, NULL);
5096 if (r < 0) {
5097 if (sd_bus_error_has_name(&error, BUS_ERROR_HOME_NOT_REFERENCED))
5098 return log_error_errno(r, "Called without reference on home taken, can't operate.");
5099
5100 r = handle_generic_user_record_error(hr->user_name, secret, &error, r, false);
5101 if (r < 0)
5102 return r;
5103
5104 sd_bus_error_free(&error);
5105 } else
5106 break;
5107 }
5108
5109 /* Try again */
5110 hr = user_record_unref(hr);
5111 }
5112
5113 incomplete = getenv_bool("XDG_SESSION_INCOMPLETE"); /* pam_systemd_home reports this state via an environment variable to us. */
5114 if (incomplete < 0 && incomplete != -ENXIO)
5115 return log_error_errno(incomplete, "Failed to parse $XDG_SESSION_INCOMPLETE environment variable: %m");
5116 if (incomplete > 0) {
5117 /* We are still in an "incomplete" session here. Now upgrade it to a full one. This will make logind
5118 * start the user@.service instance for us. */
5119 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
5120 r = sd_bus_call_method(
5121 bus,
5122 "org.freedesktop.login1",
5123 "/org/freedesktop/login1/session/self",
5124 "org.freedesktop.login1.Session",
5125 "SetClass",
5126 &error,
5127 /* ret_reply= */ NULL,
5128 "s",
5129 "user");
5130 if (r < 0)
5131 return log_error_errno(r, "Failed to upgrade session: %s", bus_error_message(&error, r));
5132
5133 if (setenv("XDG_SESSION_CLASS", "user", /* overwrite= */ true) < 0) /* Update the XDG_SESSION_CLASS environment variable to match the above */
5134 return log_error_errno(errno, "Failed to set $XDG_SESSION_CLASS: %m");
5135
5136 if (unsetenv("XDG_SESSION_INCOMPLETE") < 0) /* Unset the 'incomplete' env var */
5137 return log_error_errno(errno, "Failed to unset $XDG_SESSION_INCOMPLETE: %m");
5138 }
5139
5140 /* We are going to invoke execv() soon. Let's be extra accurate and flush/close our bus connection
5141 * first, just to make sure anything queued is flushed out (though there shouldn't be anything) */
5142 bus = sd_bus_flush_close_unref(bus);
5143
5144 assert(!hr->use_fallback);
5145 assert_se(shell = user_record_shell(hr));
5146 assert_se(hd = user_record_home_directory(hr));
5147
5148 /* Extra protection: avoid loops */
5149 if (is_fallback_shell(shell))
5150 return log_error_errno(SYNTHETIC_ERRNO(ENOTRECOVERABLE), "Primary shell of '%s' is fallback shell, refusing loop.", hr->user_name);
5151
5152 if (chdir(hd) < 0)
5153 return log_error_errno(errno, "Failed to change directory to home directory '%s': %m", hd);
5154
5155 if (setenv("SHELL", shell, /* overwrite= */ true) < 0)
5156 return log_error_errno(errno, "Failed to set $SHELL: %m");
5157
5158 if (setenv("HOME", hd, /* overwrite= */ true) < 0)
5159 return log_error_errno(errno, "Failed to set $HOME: %m");
5160
5161 /* Paranoia: in case the client passed some passwords to us to help us unlock, unlock things now */
5162 FOREACH_STRING(ue, "PASSWORD", "NEWPASSWORD", "PIN")
5163 if (unsetenv(ue) < 0)
5164 return log_error_errno(errno, "Failed to unset $%s: %m", ue);
5165
5166 r = path_extract_filename(shell, &argv0);
5167 if (r < 0)
5168 return log_error_errno(r, "Unable to extract file name from '%s': %m", shell);
5169 if (r == O_DIRECTORY)
5170 return log_error_errno(SYNTHETIC_ERRNO(EISDIR), "Shell '%s' is a path to a directory, refusing.", shell);
5171
5172 /* Invoke this as login shell, by setting argv[0][0] to '-' (unless we ourselves weren't called as login shell) */
5173 if (!argv || isempty(argv[0]) || argv[0][0] == '-') {
5174 _cleanup_free_ char *prefixed = strjoin("-", argv0);
5175 if (!prefixed)
5176 return log_oom();
5177
5178 free_and_replace(argv0, prefixed);
5179 }
5180
5181 l = strv_new(argv0);
5182 if (!l)
5183 return log_oom();
5184
5185 if (strv_extend_strv(&l, strv_skip(argv, 1), /* filter_duplicates= */ false) < 0)
5186 return log_oom();
5187
5188 execv(shell, l);
5189 return log_error_errno(errno, "Failed to execute shell '%s': %m", shell);
5190}
5191
5192static int verb_list_signing_keys(int argc, char *argv[], void *userdata) {
5193 int r;
5194
5195 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
5196 r = acquire_bus(&bus);
5197 if (r < 0)
5198 return r;
5199
5200 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
5201 _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
5202 r = bus_call_method(bus, bus_mgr, "ListSigningKeys", &error, &reply, NULL);
5203 if (r < 0)
5204 return log_error_errno(r, "Failed to list signing keys: %s", bus_error_message(&error, r));
5205
5206 _cleanup_(table_unrefp) Table *table = table_new("name", "key");
5207 if (!table)
5208 return log_oom();
5209
5210 r = sd_bus_message_enter_container(reply, 'a', "(sst)");
5211 if (r < 0)
5212 return bus_log_parse_error(r);
5213
5214 for (;;) {
5215 const char *name, *pem;
5216
5217 r = sd_bus_message_read(reply, "(sst)", &name, &pem, NULL);
5218 if (r < 0)
5219 return bus_log_parse_error(r);
5220 if (r == 0)
5221 break;
5222
5223 _cleanup_free_ char *h = NULL;
5224 if (!sd_json_format_enabled(arg_json_format_flags)) {
5225 /* Let's decode the PEM key to DER (so that we lose prefix/suffix), then truncate it
5226 * for display reasons. */
5227
5228 _cleanup_(EVP_PKEY_freep) EVP_PKEY *key = NULL;
5229 r = openssl_pubkey_from_pem(pem, SIZE_MAX, &key);
5230 if (r < 0)
5231 return log_error_errno(r, "Failed to parse PEM: %m");
5232
5233 _cleanup_free_ void *der = NULL;
5234 int n = i2d_PUBKEY(key, (unsigned char**) &der);
5235 if (n < 0)
5236 return log_error_errno(SYNTHETIC_ERRNO(ENOTRECOVERABLE), "Failed to encode key as DER.");
5237
5238 ssize_t m = base64mem(der, MIN(n, 64), &h);
5239 if (m < 0)
5240 return log_oom();
5241 if (n > 64) /* check if we truncated the original version */
5242 if (!strextend(&h, glyph(GLYPH_ELLIPSIS)))
5243 return log_oom();
5244 }
5245
5246 r = table_add_many(
5247 table,
5248 TABLE_STRING, name,
5249 TABLE_STRING, h ?: pem);
5250 if (r < 0)
5251 return table_log_add_error(r);
5252 }
5253
5254 r = sd_bus_message_exit_container(reply);
5255 if (r < 0)
5256 return bus_log_parse_error(r);
5257
5258 if (!table_isempty(table) || sd_json_format_enabled(arg_json_format_flags)) {
5259 r = table_set_sort(table, (size_t) 0);
5260 if (r < 0)
5261 return table_log_sort_error(r);
5262
5263 r = table_print_with_pager(table, arg_json_format_flags, arg_pager_flags, arg_legend);
5264 if (r < 0)
5265 return r;
5266 }
5267
5268 if (arg_legend && !sd_json_format_enabled(arg_json_format_flags)) {
5269 if (table_isempty(table))
5270 printf("No signing keys.\n");
5271 else
5272 printf("\n%zu signing keys listed.\n", table_get_rows(table) - 1);
5273 }
5274
5275 return 0;
5276}
5277
5278static int verb_get_signing_key(int argc, char *argv[], void *userdata) {
5279 int r;
5280
5281 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
5282 r = acquire_bus(&bus);
5283 if (r < 0)
5284 return r;
5285
5286 char **keys = argc >= 2 ? strv_skip(argv, 1) : STRV_MAKE("local.public");
5287 int ret = 0;
5288 STRV_FOREACH(k, keys) {
5289 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
5290 _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
5291 r = bus_call_method(bus, bus_mgr, "GetSigningKey", &error, &reply, "s", *k);
5292 if (r < 0) {
5293 RET_GATHER(ret, log_error_errno(r, "Failed to get signing key '%s': %s", *k, bus_error_message(&error, r)));
5294 continue;
5295 }
5296
5297 const char *pem;
5298 r = sd_bus_message_read(reply, "st", &pem, NULL);
5299 if (r < 0) {
5300 RET_GATHER(ret, bus_log_parse_error(r));
5301 continue;
5302 }
5303
5304 fputs(pem, stdout);
5305 if (!endswith(pem, "\n"))
5306 fputc('\n', stdout);
5307
5308 fflush(stdout);
5309 }
5310
5311 return ret;
5312}
5313
5314static int add_signing_key_one(sd_bus *bus, const char *fn, FILE *key) {
5315 int r;
5316
5317 assert_se(bus);
5318 assert_se(fn);
5319 assert_se(key);
5320
5321 _cleanup_free_ char *pem = NULL;
5322 r = read_full_stream(key, &pem, /* ret_size= */ NULL);
5323 if (r < 0)
5324 return log_error_errno(r, "Failed to read key '%s': %m", fn);
5325
5326 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
5327 r = bus_call_method(bus, bus_mgr, "AddSigningKey", &error, /* ret_reply= */ NULL, "sst", fn, pem, UINT64_C(0));
5328 if (r < 0)
5329 return log_error_errno(r, "Failed to add signing key '%s': %s", fn, bus_error_message(&error, r));
5330
5331 return 0;
5332}
5333
5334static int verb_add_signing_key(int argc, char *argv[], void *userdata) {
5335 int r;
5336
5337 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
5338 r = acquire_bus(&bus);
5339 if (r < 0)
5340 return r;
5341
5342 int ret = EXIT_SUCCESS;
5343 if (argc < 2 || streq(argv[1], "-")) {
5344 if (!arg_key_name)
5345 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Key name must be specified via --key-name= when reading key from standard input, refusing.");
5346
5347 RET_GATHER(ret, add_signing_key_one(bus, arg_key_name, stdin));
5348 } else {
5349 /* Refuse if more han one key is specified in combination with --key-name= */
5350 if (argc >= 3 && arg_key_name)
5351 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "--key-name= is not supported if multiple signing keys are specified, refusing.");
5352
5353 STRV_FOREACH(k, strv_skip(argv, 1)) {
5354
5355 if (streq(*k, "-"))
5356 return log_error_errno(SYNTHETIC_ERRNO(EINVAL), "Refusing to read from standard input if multiple keys are specified.");
5357
5358 _cleanup_free_ char *fn = NULL;
5359 if (!arg_key_name) {
5360 r = path_extract_filename(*k, &fn);
5361 if (r < 0) {
5362 RET_GATHER(ret, log_error_errno(r, "Failed to extract filename from path '%s': %m", *k));
5363 continue;
5364 }
5365 }
5366
5367 _cleanup_fclose_ FILE *f = fopen(*k, "re");
5368 if (!f) {
5369 RET_GATHER(ret, log_error_errno(errno, "Failed to open '%s': %m", *k));
5370 continue;
5371 }
5372
5373 RET_GATHER(ret, add_signing_key_one(bus, fn ?: arg_key_name, f));
5374 }
5375 }
5376
5377 return ret;
5378}
5379
5380static int add_signing_keys_from_credentials(void) {
5381 int r;
5382
5383 _cleanup_close_ int fd = open_credentials_dir();
5384 if (IN_SET(fd, -ENXIO, -ENOENT)) /* Credential env var not set, or dir doesn't exist. */
5385 return 0;
5386 if (fd < 0)
5387 return log_error_errno(fd, "Failed to open credentials directory: %m");
5388
5389 _cleanup_free_ DirectoryEntries *des = NULL;
5390 r = readdir_all(fd, RECURSE_DIR_SORT|RECURSE_DIR_IGNORE_DOT|RECURSE_DIR_ENSURE_TYPE, &des);
5391 if (r < 0)
5392 return log_error_errno(r, "Failed to enumerate credentials: %m");
5393
5394 int ret = 0;
5395 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
5396 FOREACH_ARRAY(i, des->entries, des->n_entries) {
5397 struct dirent *de = *i;
5398 if (de->d_type != DT_REG)
5399 continue;
5400
5401 const char *e = startswith(de->d_name, "home.add-signing-key.");
5402 if (!e)
5403 continue;
5404
5405 if (!filename_is_valid(e))
5406 continue;
5407
5408 if (!bus) {
5409 r = acquire_bus(&bus);
5410 if (r < 0)
5411 return r;
5412 }
5413
5414 _cleanup_fclose_ FILE *f = NULL;
5415 r = xfopenat(fd, de->d_name, "re", O_NOFOLLOW, &f);
5416 if (r < 0) {
5417 RET_GATHER(ret, log_error_errno(r, "Failed to open credential '%s': %m", de->d_name));
5418 continue;
5419 }
5420
5421 RET_GATHER(ret, add_signing_key_one(bus, e, f));
5422 }
5423
5424 return ret;
5425}
5426
5427static int remove_signing_key_one(sd_bus *bus, const char *fn) {
5428 int r;
5429
5430 assert_se(bus);
5431 assert_se(fn);
5432
5433 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
5434 r = bus_call_method(bus, bus_mgr, "RemoveSigningKey", &error, /* ret_reply= */ NULL, "st", fn, UINT64_C(0));
5435 if (r < 0)
5436 return log_error_errno(r, "Failed to remove signing key '%s': %s", fn, bus_error_message(&error, r));
5437
5438 return 0;
5439}
5440
5441static int verb_remove_signing_key(int argc, char *argv[], void *userdata) {
5442 int r;
5443
5444 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
5445 r = acquire_bus(&bus);
5446 if (r < 0)
5447 return r;
5448
5449 r = EXIT_SUCCESS;
5450 STRV_FOREACH(k, strv_skip(argv, 1))
5451 RET_GATHER(r, remove_signing_key_one(bus, *k));
5452
5453 return r;
5454}
5455
5456static int run(int argc, char *argv[]) {
5457 static const Verb verbs[] = {
5458 { "help", VERB_ANY, VERB_ANY, 0, help },
5459 { "list", VERB_ANY, 1, VERB_DEFAULT, list_homes },
5460 { "activate", 2, VERB_ANY, 0, activate_home },
5461 { "deactivate", 2, VERB_ANY, 0, deactivate_home },
5462 { "inspect", VERB_ANY, VERB_ANY, 0, inspect_homes },
5463 { "authenticate", VERB_ANY, VERB_ANY, 0, authenticate_homes },
5464 { "create", VERB_ANY, 2, 0, create_home },
5465 { "adopt", VERB_ANY, VERB_ANY, 0, verb_adopt_home },
5466 { "register", VERB_ANY, VERB_ANY, 0, verb_register_home },
5467 { "unregister", 2, VERB_ANY, 0, verb_unregister_home },
5468 { "remove", 2, VERB_ANY, 0, remove_home },
5469 { "update", VERB_ANY, 2, 0, update_home },
5470 { "passwd", VERB_ANY, 2, 0, passwd_home },
5471 { "resize", 2, 3, 0, resize_home },
5472 { "lock", 2, VERB_ANY, 0, lock_home },
5473 { "unlock", 2, VERB_ANY, 0, unlock_home },
5474 { "with", 2, VERB_ANY, 0, with_home },
5475 { "lock-all", VERB_ANY, 1, 0, lock_all_homes },
5476 { "deactivate-all", VERB_ANY, 1, 0, deactivate_all_homes },
5477 { "rebalance", VERB_ANY, 1, 0, rebalance },
5478 { "firstboot", VERB_ANY, 1, 0, verb_firstboot },
5479 { "list-signing-keys", VERB_ANY, 1, 0, verb_list_signing_keys },
5480 { "get-signing-key", VERB_ANY, VERB_ANY, 0, verb_get_signing_key },
5481 { "add-signing-key", VERB_ANY, VERB_ANY, 0, verb_add_signing_key },
5482 { "remove-signing-key", 2, VERB_ANY, 0, verb_remove_signing_key },
5483 {}
5484 };
5485
5486 int r;
5487
5488 log_setup();
5489
5490 r = redirect_bus_mgr();
5491 if (r < 0)
5492 return r;
5493
5494 if (is_fallback_shell(argv[0]))
5495 return fallback_shell(argc, argv);
5496
5497 r = parse_argv(argc, argv);
5498 if (r <= 0)
5499 return r;
5500
5501 return dispatch_verb(argc, argv, verbs, NULL);
5502}
5503
5504DEFINE_MAIN_FUNCTION_WITH_POSITIVE_FAILURE(run);
Unnamed repository; edit this file 'description' to name the repository.