auth-options.c revision 1.21 1 1.21 christos /* $NetBSD: auth-options.c,v 1.21 2019/10/12 18:32:22 christos Exp $ */
2 1.21 christos /* $OpenBSD: auth-options.c,v 1.89 2019/09/13 04:36:43 dtucker Exp $ */
3 1.1 christos /*
4 1.17 christos * Copyright (c) 2018 Damien Miller <djm (at) mindrot.org>
5 1.17 christos *
6 1.17 christos * Permission to use, copy, modify, and distribute this software for any
7 1.17 christos * purpose with or without fee is hereby granted, provided that the above
8 1.17 christos * copyright notice and this permission notice appear in all copies.
9 1.17 christos *
10 1.17 christos * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
11 1.17 christos * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
12 1.17 christos * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
13 1.17 christos * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
14 1.17 christos * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
15 1.17 christos * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
16 1.17 christos * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
17 1.1 christos */
18 1.1 christos
19 1.2 christos #include "includes.h"
20 1.21 christos __RCSID("$NetBSD: auth-options.c,v 1.21 2019/10/12 18:32:22 christos Exp $");
21 1.1 christos #include <sys/types.h>
22 1.1 christos #include <sys/queue.h>
23 1.1 christos
24 1.21 christos #include <stdlib.h>
25 1.1 christos #include <netdb.h>
26 1.1 christos #include <pwd.h>
27 1.1 christos #include <string.h>
28 1.1 christos #include <stdio.h>
29 1.1 christos #include <stdarg.h>
30 1.2 christos #include <time.h>
31 1.17 christos #include <ctype.h>
32 1.17 christos #include <limits.h>
33 1.1 christos
34 1.1 christos #include "xmalloc.h"
35 1.9 christos #include "ssherr.h"
36 1.1 christos #include "log.h"
37 1.9 christos #include "sshbuf.h"
38 1.8 christos #include "misc.h"
39 1.9 christos #include "sshkey.h"
40 1.17 christos #include "match.h"
41 1.17 christos #include "ssh2.h"
42 1.3 adam #include "auth-options.h"
43 1.12 christos
44 1.17 christos static int
45 1.17 christos dup_strings(char ***dstp, size_t *ndstp, char **src, size_t nsrc)
46 1.17 christos {
47 1.17 christos char **dst;
48 1.17 christos size_t i, j;
49 1.1 christos
50 1.17 christos *dstp = NULL;
51 1.17 christos *ndstp = 0;
52 1.17 christos if (nsrc == 0)
53 1.17 christos return 0;
54 1.1 christos
55 1.17 christos if ((dst = calloc(nsrc, sizeof(*src))) == NULL)
56 1.17 christos return -1;
57 1.17 christos for (i = 0; i < nsrc; i++) {
58 1.17 christos if ((dst[i] = strdup(src[i])) == NULL) {
59 1.17 christos for (j = 0; j < i; j++)
60 1.17 christos free(dst[j]);
61 1.17 christos free(dst);
62 1.17 christos return -1;
63 1.17 christos }
64 1.17 christos }
65 1.17 christos /* success */
66 1.17 christos *dstp = dst;
67 1.17 christos *ndstp = nsrc;
68 1.3 adam return 0;
69 1.3 adam }
70 1.3 adam
71 1.3 adam #define OPTIONS_CRITICAL 1
72 1.3 adam #define OPTIONS_EXTENSIONS 2
73 1.3 adam static int
74 1.17 christos cert_option_list(struct sshauthopt *opts, struct sshbuf *oblob,
75 1.17 christos u_int which, int crit)
76 1.3 adam {
77 1.3 adam char *command, *allowed;
78 1.7 christos char *name = NULL;
79 1.9 christos struct sshbuf *c = NULL, *data = NULL;
80 1.17 christos int r, ret = -1, found;
81 1.9 christos
82 1.9 christos if ((c = sshbuf_fromb(oblob)) == NULL) {
83 1.9 christos error("%s: sshbuf_fromb failed", __func__);
84 1.9 christos goto out;
85 1.9 christos }
86 1.9 christos
87 1.9 christos while (sshbuf_len(c) > 0) {
88 1.9 christos sshbuf_free(data);
89 1.9 christos data = NULL;
90 1.9 christos if ((r = sshbuf_get_cstring(c, &name, NULL)) != 0 ||
91 1.9 christos (r = sshbuf_froms(c, &data)) != 0) {
92 1.9 christos error("Unable to parse certificate options: %s",
93 1.9 christos ssh_err(r));
94 1.3 adam goto out;
95 1.3 adam }
96 1.9 christos debug3("found certificate option \"%.100s\" len %zu",
97 1.9 christos name, sshbuf_len(data));
98 1.3 adam found = 0;
99 1.3 adam if ((which & OPTIONS_EXTENSIONS) != 0) {
100 1.3 adam if (strcmp(name, "permit-X11-forwarding") == 0) {
101 1.17 christos opts->permit_x11_forwarding_flag = 1;
102 1.3 adam found = 1;
103 1.3 adam } else if (strcmp(name,
104 1.3 adam "permit-agent-forwarding") == 0) {
105 1.17 christos opts->permit_agent_forwarding_flag = 1;
106 1.3 adam found = 1;
107 1.3 adam } else if (strcmp(name,
108 1.3 adam "permit-port-forwarding") == 0) {
109 1.17 christos opts->permit_port_forwarding_flag = 1;
110 1.3 adam found = 1;
111 1.3 adam } else if (strcmp(name, "permit-pty") == 0) {
112 1.17 christos opts->permit_pty_flag = 1;
113 1.3 adam found = 1;
114 1.3 adam } else if (strcmp(name, "permit-user-rc") == 0) {
115 1.17 christos opts->permit_user_rc = 1;
116 1.3 adam found = 1;
117 1.3 adam }
118 1.3 adam }
119 1.3 adam if (!found && (which & OPTIONS_CRITICAL) != 0) {
120 1.3 adam if (strcmp(name, "force-command") == 0) {
121 1.9 christos if ((r = sshbuf_get_cstring(data, &command,
122 1.9 christos NULL)) != 0) {
123 1.9 christos error("Unable to parse \"%s\" "
124 1.9 christos "section: %s", name, ssh_err(r));
125 1.3 adam goto out;
126 1.3 adam }
127 1.17 christos if (opts->force_command != NULL) {
128 1.3 adam error("Certificate has multiple "
129 1.3 adam "force-command options");
130 1.7 christos free(command);
131 1.3 adam goto out;
132 1.3 adam }
133 1.17 christos opts->force_command = command;
134 1.3 adam found = 1;
135 1.3 adam }
136 1.3 adam if (strcmp(name, "source-address") == 0) {
137 1.9 christos if ((r = sshbuf_get_cstring(data, &allowed,
138 1.9 christos NULL)) != 0) {
139 1.9 christos error("Unable to parse \"%s\" "
140 1.9 christos "section: %s", name, ssh_err(r));
141 1.3 adam goto out;
142 1.3 adam }
143 1.17 christos if (opts->required_from_host_cert != NULL) {
144 1.3 adam error("Certificate has multiple "
145 1.3 adam "source-address options");
146 1.7 christos free(allowed);
147 1.3 adam goto out;
148 1.3 adam }
149 1.17 christos /* Check syntax */
150 1.17 christos if (addr_match_cidr_list(NULL, allowed) == -1) {
151 1.3 adam error("Certificate source-address "
152 1.3 adam "contents invalid");
153 1.3 adam goto out;
154 1.3 adam }
155 1.17 christos opts->required_from_host_cert = allowed;
156 1.3 adam found = 1;
157 1.3 adam }
158 1.3 adam }
159 1.3 adam
160 1.3 adam if (!found) {
161 1.3 adam if (crit) {
162 1.3 adam error("Certificate critical option \"%s\" "
163 1.3 adam "is not supported", name);
164 1.3 adam goto out;
165 1.3 adam } else {
166 1.3 adam logit("Certificate extension \"%s\" "
167 1.3 adam "is not supported", name);
168 1.3 adam }
169 1.9 christos } else if (sshbuf_len(data) != 0) {
170 1.3 adam error("Certificate option \"%s\" corrupt "
171 1.3 adam "(extra data)", name);
172 1.3 adam goto out;
173 1.3 adam }
174 1.7 christos free(name);
175 1.7 christos name = NULL;
176 1.3 adam }
177 1.3 adam /* successfully parsed all options */
178 1.3 adam ret = 0;
179 1.3 adam
180 1.3 adam out:
181 1.12 christos free(name);
182 1.9 christos sshbuf_free(data);
183 1.9 christos sshbuf_free(c);
184 1.3 adam return ret;
185 1.3 adam }
186 1.3 adam
187 1.17 christos struct sshauthopt *
188 1.17 christos sshauthopt_new(void)
189 1.17 christos {
190 1.17 christos struct sshauthopt *ret;
191 1.17 christos
192 1.17 christos if ((ret = calloc(1, sizeof(*ret))) == NULL)
193 1.17 christos return NULL;
194 1.17 christos ret->force_tun_device = -1;
195 1.17 christos return ret;
196 1.17 christos }
197 1.17 christos
198 1.17 christos void
199 1.17 christos sshauthopt_free(struct sshauthopt *opts)
200 1.17 christos {
201 1.17 christos size_t i;
202 1.17 christos
203 1.17 christos if (opts == NULL)
204 1.17 christos return;
205 1.17 christos
206 1.17 christos free(opts->cert_principals);
207 1.17 christos free(opts->force_command);
208 1.17 christos free(opts->required_from_host_cert);
209 1.17 christos free(opts->required_from_host_keys);
210 1.17 christos
211 1.17 christos for (i = 0; i < opts->nenv; i++)
212 1.17 christos free(opts->env[i]);
213 1.17 christos free(opts->env);
214 1.17 christos
215 1.17 christos for (i = 0; i < opts->npermitopen; i++)
216 1.17 christos free(opts->permitopen[i]);
217 1.17 christos free(opts->permitopen);
218 1.17 christos
219 1.18 christos for (i = 0; i < opts->npermitlisten; i++)
220 1.18 christos free(opts->permitlisten[i]);
221 1.18 christos free(opts->permitlisten);
222 1.18 christos
223 1.17 christos explicit_bzero(opts, sizeof(*opts));
224 1.17 christos free(opts);
225 1.17 christos }
226 1.17 christos
227 1.17 christos struct sshauthopt *
228 1.17 christos sshauthopt_new_with_keys_defaults(void)
229 1.17 christos {
230 1.17 christos struct sshauthopt *ret = NULL;
231 1.17 christos
232 1.17 christos if ((ret = sshauthopt_new()) == NULL)
233 1.17 christos return NULL;
234 1.17 christos
235 1.17 christos /* Defaults for authorized_keys flags */
236 1.17 christos ret->permit_port_forwarding_flag = 1;
237 1.17 christos ret->permit_agent_forwarding_flag = 1;
238 1.17 christos ret->permit_x11_forwarding_flag = 1;
239 1.17 christos ret->permit_pty_flag = 1;
240 1.17 christos ret->permit_user_rc = 1;
241 1.17 christos return ret;
242 1.17 christos }
243 1.17 christos
244 1.18 christos /*
245 1.18 christos * Parse and record a permitopen/permitlisten directive.
246 1.18 christos * Return 0 on success. Return -1 on failure and sets *errstrp to error reason.
247 1.18 christos */
248 1.18 christos static int
249 1.18 christos handle_permit(const char **optsp, int allow_bare_port,
250 1.18 christos char ***permitsp, size_t *npermitsp, const char **errstrp)
251 1.18 christos {
252 1.18 christos char *opt, *tmp, *cp, *host, **permits = *permitsp;
253 1.18 christos size_t npermits = *npermitsp;
254 1.18 christos const char *errstr = "unknown error";
255 1.18 christos
256 1.21 christos if (npermits > SSH_AUTHOPT_PERMIT_MAX) {
257 1.18 christos *errstrp = "too many permission directives";
258 1.18 christos return -1;
259 1.18 christos }
260 1.18 christos if ((opt = opt_dequote(optsp, &errstr)) == NULL) {
261 1.18 christos return -1;
262 1.18 christos }
263 1.18 christos if (allow_bare_port && strchr(opt, ':') == NULL) {
264 1.18 christos /*
265 1.18 christos * Allow a bare port number in permitlisten to indicate a
266 1.18 christos * listen_host wildcard.
267 1.18 christos */
268 1.21 christos if (asprintf(&tmp, "*:%s", opt) == -1) {
269 1.21 christos free(opt);
270 1.18 christos *errstrp = "memory allocation failed";
271 1.18 christos return -1;
272 1.18 christos }
273 1.18 christos free(opt);
274 1.18 christos opt = tmp;
275 1.18 christos }
276 1.18 christos if ((tmp = strdup(opt)) == NULL) {
277 1.18 christos free(opt);
278 1.18 christos *errstrp = "memory allocation failed";
279 1.18 christos return -1;
280 1.18 christos }
281 1.18 christos cp = tmp;
282 1.18 christos /* validate syntax before recording it. */
283 1.18 christos host = hpdelim(&cp);
284 1.18 christos if (host == NULL || strlen(host) >= NI_MAXHOST) {
285 1.18 christos free(tmp);
286 1.18 christos free(opt);
287 1.18 christos *errstrp = "invalid permission hostname";
288 1.18 christos return -1;
289 1.18 christos }
290 1.18 christos /*
291 1.18 christos * don't want to use permitopen_port to avoid
292 1.18 christos * dependency on channels.[ch] here.
293 1.18 christos */
294 1.18 christos if (cp == NULL ||
295 1.18 christos (strcmp(cp, "*") != 0 && a2port(cp) <= 0)) {
296 1.18 christos free(tmp);
297 1.18 christos free(opt);
298 1.18 christos *errstrp = "invalid permission port";
299 1.18 christos return -1;
300 1.18 christos }
301 1.18 christos /* XXX - add streamlocal support */
302 1.18 christos free(tmp);
303 1.18 christos /* Record it */
304 1.18 christos if ((permits = recallocarray(permits, npermits, npermits + 1,
305 1.18 christos sizeof(*permits))) == NULL) {
306 1.18 christos free(opt);
307 1.18 christos /* NB. don't update *permitsp if alloc fails */
308 1.18 christos *errstrp = "memory allocation failed";
309 1.18 christos return -1;
310 1.18 christos }
311 1.18 christos permits[npermits++] = opt;
312 1.18 christos *permitsp = permits;
313 1.18 christos *npermitsp = npermits;
314 1.18 christos return 0;
315 1.18 christos }
316 1.18 christos
317 1.17 christos struct sshauthopt *
318 1.17 christos sshauthopt_parse(const char *opts, const char **errstrp)
319 1.17 christos {
320 1.18 christos char **oarray, *opt, *cp, *tmp;
321 1.17 christos int r;
322 1.17 christos struct sshauthopt *ret = NULL;
323 1.17 christos const char *errstr = "unknown error";
324 1.17 christos uint64_t valid_before;
325 1.17 christos
326 1.17 christos if (errstrp != NULL)
327 1.17 christos *errstrp = NULL;
328 1.17 christos if ((ret = sshauthopt_new_with_keys_defaults()) == NULL)
329 1.17 christos goto alloc_fail;
330 1.17 christos
331 1.17 christos if (opts == NULL)
332 1.17 christos return ret;
333 1.17 christos
334 1.17 christos while (*opts && *opts != ' ' && *opts != '\t') {
335 1.17 christos /* flag options */
336 1.17 christos if ((r = opt_flag("restrict", 0, &opts)) != -1) {
337 1.17 christos ret->restricted = 1;
338 1.17 christos ret->permit_port_forwarding_flag = 0;
339 1.17 christos ret->permit_agent_forwarding_flag = 0;
340 1.17 christos ret->permit_x11_forwarding_flag = 0;
341 1.17 christos ret->permit_pty_flag = 0;
342 1.17 christos ret->permit_user_rc = 0;
343 1.17 christos } else if ((r = opt_flag("cert-authority", 0, &opts)) != -1) {
344 1.17 christos ret->cert_authority = r;
345 1.17 christos } else if ((r = opt_flag("port-forwarding", 1, &opts)) != -1) {
346 1.17 christos ret->permit_port_forwarding_flag = r == 1;
347 1.17 christos } else if ((r = opt_flag("agent-forwarding", 1, &opts)) != -1) {
348 1.17 christos ret->permit_agent_forwarding_flag = r == 1;
349 1.17 christos } else if ((r = opt_flag("x11-forwarding", 1, &opts)) != -1) {
350 1.17 christos ret->permit_x11_forwarding_flag = r == 1;
351 1.17 christos } else if ((r = opt_flag("pty", 1, &opts)) != -1) {
352 1.17 christos ret->permit_pty_flag = r == 1;
353 1.17 christos } else if ((r = opt_flag("user-rc", 1, &opts)) != -1) {
354 1.17 christos ret->permit_user_rc = r == 1;
355 1.17 christos } else if (opt_match(&opts, "command")) {
356 1.17 christos if (ret->force_command != NULL) {
357 1.17 christos errstr = "multiple \"command\" clauses";
358 1.17 christos goto fail;
359 1.17 christos }
360 1.17 christos ret->force_command = opt_dequote(&opts, &errstr);
361 1.17 christos if (ret->force_command == NULL)
362 1.17 christos goto fail;
363 1.17 christos } else if (opt_match(&opts, "principals")) {
364 1.17 christos if (ret->cert_principals != NULL) {
365 1.17 christos errstr = "multiple \"principals\" clauses";
366 1.17 christos goto fail;
367 1.17 christos }
368 1.17 christos ret->cert_principals = opt_dequote(&opts, &errstr);
369 1.17 christos if (ret->cert_principals == NULL)
370 1.17 christos goto fail;
371 1.17 christos } else if (opt_match(&opts, "from")) {
372 1.17 christos if (ret->required_from_host_keys != NULL) {
373 1.17 christos errstr = "multiple \"from\" clauses";
374 1.17 christos goto fail;
375 1.17 christos }
376 1.17 christos ret->required_from_host_keys = opt_dequote(&opts,
377 1.17 christos &errstr);
378 1.17 christos if (ret->required_from_host_keys == NULL)
379 1.17 christos goto fail;
380 1.17 christos } else if (opt_match(&opts, "expiry-time")) {
381 1.17 christos if ((opt = opt_dequote(&opts, &errstr)) == NULL)
382 1.17 christos goto fail;
383 1.17 christos if (parse_absolute_time(opt, &valid_before) != 0 ||
384 1.17 christos valid_before == 0) {
385 1.17 christos free(opt);
386 1.17 christos errstr = "invalid expires time";
387 1.17 christos goto fail;
388 1.17 christos }
389 1.17 christos free(opt);
390 1.17 christos if (ret->valid_before == 0 ||
391 1.17 christos valid_before < ret->valid_before)
392 1.17 christos ret->valid_before = valid_before;
393 1.17 christos } else if (opt_match(&opts, "environment")) {
394 1.17 christos if (ret->nenv > INT_MAX) {
395 1.17 christos errstr = "too many environment strings";
396 1.17 christos goto fail;
397 1.17 christos }
398 1.17 christos if ((opt = opt_dequote(&opts, &errstr)) == NULL)
399 1.17 christos goto fail;
400 1.17 christos /* env name must be alphanumeric and followed by '=' */
401 1.17 christos if ((tmp = strchr(opt, '=')) == NULL) {
402 1.17 christos free(opt);
403 1.17 christos errstr = "invalid environment string";
404 1.17 christos goto fail;
405 1.17 christos }
406 1.20 christos if ((cp = strdup(opt)) == NULL)
407 1.20 christos goto alloc_fail;
408 1.20 christos cp[tmp - opt] = '\0'; /* truncate at '=' */
409 1.20 christos if (!valid_env_name(cp)) {
410 1.20 christos free(cp);
411 1.20 christos free(opt);
412 1.20 christos errstr = "invalid environment string";
413 1.20 christos goto fail;
414 1.17 christos }
415 1.20 christos free(cp);
416 1.17 christos /* Append it. */
417 1.17 christos oarray = ret->env;
418 1.17 christos if ((ret->env = recallocarray(ret->env, ret->nenv,
419 1.17 christos ret->nenv + 1, sizeof(*ret->env))) == NULL) {
420 1.17 christos free(opt);
421 1.17 christos ret->env = oarray; /* put it back for cleanup */
422 1.17 christos goto alloc_fail;
423 1.17 christos }
424 1.17 christos ret->env[ret->nenv++] = opt;
425 1.17 christos } else if (opt_match(&opts, "permitopen")) {
426 1.18 christos if (handle_permit(&opts, 0, &ret->permitopen,
427 1.18 christos &ret->npermitopen, &errstr) != 0)
428 1.17 christos goto fail;
429 1.18 christos } else if (opt_match(&opts, "permitlisten")) {
430 1.18 christos if (handle_permit(&opts, 1, &ret->permitlisten,
431 1.18 christos &ret->npermitlisten, &errstr) != 0)
432 1.17 christos goto fail;
433 1.17 christos } else if (opt_match(&opts, "tunnel")) {
434 1.17 christos if ((opt = opt_dequote(&opts, &errstr)) == NULL)
435 1.17 christos goto fail;
436 1.17 christos ret->force_tun_device = a2tun(opt, NULL);
437 1.17 christos free(opt);
438 1.17 christos if (ret->force_tun_device == SSH_TUNID_ERR) {
439 1.17 christos errstr = "invalid tun device";
440 1.17 christos goto fail;
441 1.17 christos }
442 1.17 christos }
443 1.17 christos /*
444 1.17 christos * Skip the comma, and move to the next option
445 1.17 christos * (or break out if there are no more).
446 1.17 christos */
447 1.17 christos if (*opts == '\0' || *opts == ' ' || *opts == '\t')
448 1.17 christos break; /* End of options. */
449 1.17 christos /* Anything other than a comma is an unknown option */
450 1.17 christos if (*opts != ',') {
451 1.17 christos errstr = "unknown key option";
452 1.17 christos goto fail;
453 1.17 christos }
454 1.17 christos opts++;
455 1.17 christos if (*opts == '\0') {
456 1.17 christos errstr = "unexpected end-of-options";
457 1.17 christos goto fail;
458 1.17 christos }
459 1.17 christos }
460 1.17 christos
461 1.17 christos /* success */
462 1.17 christos if (errstrp != NULL)
463 1.17 christos *errstrp = NULL;
464 1.17 christos return ret;
465 1.17 christos
466 1.17 christos alloc_fail:
467 1.17 christos errstr = "memory allocation failed";
468 1.17 christos fail:
469 1.17 christos sshauthopt_free(ret);
470 1.17 christos if (errstrp != NULL)
471 1.17 christos *errstrp = errstr;
472 1.17 christos return NULL;
473 1.17 christos }
474 1.17 christos
475 1.17 christos struct sshauthopt *
476 1.17 christos sshauthopt_from_cert(struct sshkey *k)
477 1.17 christos {
478 1.17 christos struct sshauthopt *ret;
479 1.17 christos
480 1.17 christos if (k == NULL || !sshkey_type_is_cert(k->type) || k->cert == NULL ||
481 1.17 christos k->cert->type != SSH2_CERT_TYPE_USER)
482 1.17 christos return NULL;
483 1.17 christos
484 1.17 christos if ((ret = sshauthopt_new()) == NULL)
485 1.17 christos return NULL;
486 1.17 christos
487 1.17 christos /* Handle options and critical extensions separately */
488 1.17 christos if (cert_option_list(ret, k->cert->critical,
489 1.17 christos OPTIONS_CRITICAL, 1) == -1) {
490 1.17 christos sshauthopt_free(ret);
491 1.17 christos return NULL;
492 1.17 christos }
493 1.17 christos if (cert_option_list(ret, k->cert->extensions,
494 1.17 christos OPTIONS_EXTENSIONS, 0) == -1) {
495 1.17 christos sshauthopt_free(ret);
496 1.17 christos return NULL;
497 1.17 christos }
498 1.17 christos /* success */
499 1.17 christos return ret;
500 1.17 christos }
501 1.17 christos
502 1.3 adam /*
503 1.17 christos * Merges "additional" options to "primary" and returns the result.
504 1.17 christos * NB. Some options from primary have primacy.
505 1.3 adam */
506 1.17 christos struct sshauthopt *
507 1.17 christos sshauthopt_merge(const struct sshauthopt *primary,
508 1.17 christos const struct sshauthopt *additional, const char **errstrp)
509 1.3 adam {
510 1.17 christos struct sshauthopt *ret;
511 1.17 christos const char *errstr = "internal error";
512 1.17 christos const char *tmp;
513 1.17 christos
514 1.17 christos if (errstrp != NULL)
515 1.17 christos *errstrp = NULL;
516 1.17 christos
517 1.17 christos if ((ret = sshauthopt_new()) == NULL)
518 1.17 christos goto alloc_fail;
519 1.17 christos
520 1.17 christos /* cert_authority and cert_principals are cleared in result */
521 1.17 christos
522 1.17 christos /* Prefer access lists from primary. */
523 1.17 christos /* XXX err is both set and mismatch? */
524 1.17 christos tmp = primary->required_from_host_cert;
525 1.17 christos if (tmp == NULL)
526 1.17 christos tmp = additional->required_from_host_cert;
527 1.17 christos if (tmp != NULL && (ret->required_from_host_cert = strdup(tmp)) == NULL)
528 1.17 christos goto alloc_fail;
529 1.17 christos tmp = primary->required_from_host_keys;
530 1.17 christos if (tmp == NULL)
531 1.17 christos tmp = additional->required_from_host_keys;
532 1.17 christos if (tmp != NULL && (ret->required_from_host_keys = strdup(tmp)) == NULL)
533 1.17 christos goto alloc_fail;
534 1.17 christos
535 1.18 christos /*
536 1.18 christos * force_tun_device, permitopen/permitlisten and environment all
537 1.18 christos * prefer the primary.
538 1.18 christos */
539 1.17 christos ret->force_tun_device = primary->force_tun_device;
540 1.17 christos if (ret->force_tun_device == -1)
541 1.17 christos ret->force_tun_device = additional->force_tun_device;
542 1.17 christos if (primary->nenv > 0) {
543 1.17 christos if (dup_strings(&ret->env, &ret->nenv,
544 1.17 christos primary->env, primary->nenv) != 0)
545 1.17 christos goto alloc_fail;
546 1.17 christos } else if (additional->nenv) {
547 1.17 christos if (dup_strings(&ret->env, &ret->nenv,
548 1.17 christos additional->env, additional->nenv) != 0)
549 1.17 christos goto alloc_fail;
550 1.17 christos }
551 1.17 christos if (primary->npermitopen > 0) {
552 1.17 christos if (dup_strings(&ret->permitopen, &ret->npermitopen,
553 1.17 christos primary->permitopen, primary->npermitopen) != 0)
554 1.17 christos goto alloc_fail;
555 1.17 christos } else if (additional->npermitopen > 0) {
556 1.17 christos if (dup_strings(&ret->permitopen, &ret->npermitopen,
557 1.17 christos additional->permitopen, additional->npermitopen) != 0)
558 1.17 christos goto alloc_fail;
559 1.17 christos }
560 1.17 christos
561 1.18 christos if (primary->npermitlisten > 0) {
562 1.18 christos if (dup_strings(&ret->permitlisten, &ret->npermitlisten,
563 1.18 christos primary->permitlisten, primary->npermitlisten) != 0)
564 1.18 christos goto alloc_fail;
565 1.18 christos } else if (additional->npermitlisten > 0) {
566 1.18 christos if (dup_strings(&ret->permitlisten, &ret->npermitlisten,
567 1.18 christos additional->permitlisten, additional->npermitlisten) != 0)
568 1.18 christos goto alloc_fail;
569 1.18 christos }
570 1.18 christos
571 1.17 christos /* Flags are logical-AND (i.e. must be set in both for permission) */
572 1.17 christos #define OPTFLAG(x) ret->x = (primary->x == 1) && (additional->x == 1)
573 1.17 christos OPTFLAG(permit_port_forwarding_flag);
574 1.17 christos OPTFLAG(permit_agent_forwarding_flag);
575 1.17 christos OPTFLAG(permit_x11_forwarding_flag);
576 1.17 christos OPTFLAG(permit_pty_flag);
577 1.17 christos OPTFLAG(permit_user_rc);
578 1.17 christos #undef OPTFLAG
579 1.17 christos
580 1.17 christos /* Earliest expiry time should win */
581 1.17 christos if (primary->valid_before != 0)
582 1.17 christos ret->valid_before = primary->valid_before;
583 1.17 christos if (additional->valid_before != 0 &&
584 1.17 christos additional->valid_before < ret->valid_before)
585 1.17 christos ret->valid_before = additional->valid_before;
586 1.1 christos
587 1.14 christos /*
588 1.17 christos * When both multiple forced-command are specified, only
589 1.17 christos * proceed if they are identical, otherwise fail.
590 1.14 christos */
591 1.17 christos if (primary->force_command != NULL &&
592 1.17 christos additional->force_command != NULL) {
593 1.17 christos if (strcmp(primary->force_command,
594 1.17 christos additional->force_command) == 0) {
595 1.17 christos /* ok */
596 1.17 christos ret->force_command = strdup(primary->force_command);
597 1.17 christos if (ret->force_command == NULL)
598 1.17 christos goto alloc_fail;
599 1.14 christos } else {
600 1.17 christos errstr = "forced command options do not match";
601 1.17 christos goto fail;
602 1.14 christos }
603 1.17 christos } else if (primary->force_command != NULL) {
604 1.17 christos if ((ret->force_command = strdup(
605 1.17 christos primary->force_command)) == NULL)
606 1.17 christos goto alloc_fail;
607 1.17 christos } else if (additional->force_command != NULL) {
608 1.17 christos if ((ret->force_command = strdup(
609 1.17 christos additional->force_command)) == NULL)
610 1.17 christos goto alloc_fail;
611 1.17 christos }
612 1.14 christos /* success */
613 1.17 christos if (errstrp != NULL)
614 1.17 christos *errstrp = NULL;
615 1.17 christos return ret;
616 1.17 christos
617 1.17 christos alloc_fail:
618 1.17 christos errstr = "memory allocation failed";
619 1.17 christos fail:
620 1.17 christos if (errstrp != NULL)
621 1.17 christos *errstrp = errstr;
622 1.17 christos sshauthopt_free(ret);
623 1.17 christos return NULL;
624 1.17 christos }
625 1.17 christos
626 1.17 christos /*
627 1.17 christos * Copy options
628 1.17 christos */
629 1.17 christos struct sshauthopt *
630 1.17 christos sshauthopt_copy(const struct sshauthopt *orig)
631 1.17 christos {
632 1.17 christos struct sshauthopt *ret;
633 1.17 christos
634 1.17 christos if ((ret = sshauthopt_new()) == NULL)
635 1.17 christos return NULL;
636 1.17 christos
637 1.17 christos #define OPTSCALAR(x) ret->x = orig->x
638 1.17 christos OPTSCALAR(permit_port_forwarding_flag);
639 1.17 christos OPTSCALAR(permit_agent_forwarding_flag);
640 1.17 christos OPTSCALAR(permit_x11_forwarding_flag);
641 1.17 christos OPTSCALAR(permit_pty_flag);
642 1.17 christos OPTSCALAR(permit_user_rc);
643 1.17 christos OPTSCALAR(restricted);
644 1.17 christos OPTSCALAR(cert_authority);
645 1.17 christos OPTSCALAR(force_tun_device);
646 1.17 christos OPTSCALAR(valid_before);
647 1.17 christos #undef OPTSCALAR
648 1.17 christos #define OPTSTRING(x) \
649 1.17 christos do { \
650 1.17 christos if (orig->x != NULL && (ret->x = strdup(orig->x)) == NULL) { \
651 1.17 christos sshauthopt_free(ret); \
652 1.17 christos return NULL; \
653 1.17 christos } \
654 1.17 christos } while (0)
655 1.17 christos OPTSTRING(cert_principals);
656 1.17 christos OPTSTRING(force_command);
657 1.17 christos OPTSTRING(required_from_host_cert);
658 1.17 christos OPTSTRING(required_from_host_keys);
659 1.17 christos #undef OPTSTRING
660 1.17 christos
661 1.17 christos if (dup_strings(&ret->env, &ret->nenv, orig->env, orig->nenv) != 0 ||
662 1.17 christos dup_strings(&ret->permitopen, &ret->npermitopen,
663 1.18 christos orig->permitopen, orig->npermitopen) != 0 ||
664 1.18 christos dup_strings(&ret->permitlisten, &ret->npermitlisten,
665 1.18 christos orig->permitlisten, orig->npermitlisten) != 0) {
666 1.17 christos sshauthopt_free(ret);
667 1.17 christos return NULL;
668 1.17 christos }
669 1.17 christos return ret;
670 1.17 christos }
671 1.17 christos
672 1.17 christos static int
673 1.17 christos serialise_array(struct sshbuf *m, char **a, size_t n)
674 1.17 christos {
675 1.17 christos struct sshbuf *b;
676 1.17 christos size_t i;
677 1.17 christos int r;
678 1.17 christos
679 1.17 christos if (n > INT_MAX)
680 1.17 christos return SSH_ERR_INTERNAL_ERROR;
681 1.17 christos
682 1.17 christos if ((b = sshbuf_new()) == NULL) {
683 1.17 christos return SSH_ERR_ALLOC_FAIL;
684 1.17 christos }
685 1.17 christos for (i = 0; i < n; i++) {
686 1.17 christos if ((r = sshbuf_put_cstring(b, a[i])) != 0) {
687 1.17 christos sshbuf_free(b);
688 1.17 christos return r;
689 1.17 christos }
690 1.17 christos }
691 1.17 christos if ((r = sshbuf_put_u32(m, n)) != 0 ||
692 1.17 christos (r = sshbuf_put_stringb(m, b)) != 0) {
693 1.17 christos sshbuf_free(b);
694 1.17 christos return r;
695 1.17 christos }
696 1.17 christos /* success */
697 1.17 christos return 0;
698 1.17 christos }
699 1.17 christos
700 1.17 christos static int
701 1.17 christos deserialise_array(struct sshbuf *m, char ***ap, size_t *np)
702 1.17 christos {
703 1.17 christos char **a = NULL;
704 1.17 christos size_t i, n = 0;
705 1.17 christos struct sshbuf *b = NULL;
706 1.17 christos u_int tmp;
707 1.17 christos int r = SSH_ERR_INTERNAL_ERROR;
708 1.17 christos
709 1.17 christos if ((r = sshbuf_get_u32(m, &tmp)) != 0 ||
710 1.17 christos (r = sshbuf_froms(m, &b)) != 0)
711 1.17 christos goto out;
712 1.17 christos if (tmp > INT_MAX) {
713 1.17 christos r = SSH_ERR_INVALID_FORMAT;
714 1.17 christos goto out;
715 1.17 christos }
716 1.17 christos n = tmp;
717 1.17 christos if (n > 0 && (a = calloc(n, sizeof(*a))) == NULL) {
718 1.17 christos r = SSH_ERR_ALLOC_FAIL;
719 1.17 christos goto out;
720 1.17 christos }
721 1.17 christos for (i = 0; i < n; i++) {
722 1.17 christos if ((r = sshbuf_get_cstring(b, &a[i], NULL)) != 0)
723 1.17 christos goto out;
724 1.17 christos }
725 1.17 christos /* success */
726 1.17 christos r = 0;
727 1.17 christos *ap = a;
728 1.17 christos a = NULL;
729 1.17 christos *np = n;
730 1.17 christos n = 0;
731 1.17 christos out:
732 1.17 christos for (i = 0; i < n; i++)
733 1.17 christos free(a[i]);
734 1.17 christos free(a);
735 1.17 christos sshbuf_free(b);
736 1.17 christos return r;
737 1.17 christos }
738 1.17 christos
739 1.17 christos static int
740 1.17 christos serialise_nullable_string(struct sshbuf *m, const char *s)
741 1.17 christos {
742 1.17 christos int r;
743 1.17 christos
744 1.17 christos if ((r = sshbuf_put_u8(m, s == NULL)) != 0 ||
745 1.17 christos (r = sshbuf_put_cstring(m, s)) != 0)
746 1.17 christos return r;
747 1.17 christos return 0;
748 1.17 christos }
749 1.17 christos
750 1.17 christos static int
751 1.17 christos deserialise_nullable_string(struct sshbuf *m, char **sp)
752 1.17 christos {
753 1.17 christos int r;
754 1.17 christos u_char flag;
755 1.17 christos
756 1.17 christos *sp = NULL;
757 1.17 christos if ((r = sshbuf_get_u8(m, &flag)) != 0 ||
758 1.17 christos (r = sshbuf_get_cstring(m, flag ? NULL : sp, NULL)) != 0)
759 1.17 christos return r;
760 1.1 christos return 0;
761 1.1 christos }
762 1.3 adam
763 1.17 christos int
764 1.17 christos sshauthopt_serialise(const struct sshauthopt *opts, struct sshbuf *m,
765 1.17 christos int untrusted)
766 1.17 christos {
767 1.17 christos int r = SSH_ERR_INTERNAL_ERROR;
768 1.17 christos
769 1.17 christos /* Flag and simple integer options */
770 1.17 christos if ((r = sshbuf_put_u8(m, opts->permit_port_forwarding_flag)) != 0 ||
771 1.17 christos (r = sshbuf_put_u8(m, opts->permit_agent_forwarding_flag)) != 0 ||
772 1.17 christos (r = sshbuf_put_u8(m, opts->permit_x11_forwarding_flag)) != 0 ||
773 1.17 christos (r = sshbuf_put_u8(m, opts->permit_pty_flag)) != 0 ||
774 1.17 christos (r = sshbuf_put_u8(m, opts->permit_user_rc)) != 0 ||
775 1.17 christos (r = sshbuf_put_u8(m, opts->restricted)) != 0 ||
776 1.17 christos (r = sshbuf_put_u8(m, opts->cert_authority)) != 0 ||
777 1.17 christos (r = sshbuf_put_u64(m, opts->valid_before)) != 0)
778 1.17 christos return r;
779 1.17 christos
780 1.17 christos /* tunnel number can be negative to indicate "unset" */
781 1.17 christos if ((r = sshbuf_put_u8(m, opts->force_tun_device == -1)) != 0 ||
782 1.17 christos (r = sshbuf_put_u32(m, (opts->force_tun_device < 0) ?
783 1.17 christos 0 : (u_int)opts->force_tun_device)) != 0)
784 1.17 christos return r;
785 1.17 christos
786 1.17 christos /* String options; these may be NULL */
787 1.17 christos if ((r = serialise_nullable_string(m,
788 1.17 christos untrusted ? "yes" : opts->cert_principals)) != 0 ||
789 1.17 christos (r = serialise_nullable_string(m,
790 1.17 christos untrusted ? "true" : opts->force_command)) != 0 ||
791 1.17 christos (r = serialise_nullable_string(m,
792 1.17 christos untrusted ? NULL : opts->required_from_host_cert)) != 0 ||
793 1.17 christos (r = serialise_nullable_string(m,
794 1.17 christos untrusted ? NULL : opts->required_from_host_keys)) != 0)
795 1.17 christos return r;
796 1.17 christos
797 1.17 christos /* Array options */
798 1.17 christos if ((r = serialise_array(m, opts->env,
799 1.17 christos untrusted ? 0 : opts->nenv)) != 0 ||
800 1.17 christos (r = serialise_array(m, opts->permitopen,
801 1.18 christos untrusted ? 0 : opts->npermitopen)) != 0 ||
802 1.18 christos (r = serialise_array(m, opts->permitlisten,
803 1.18 christos untrusted ? 0 : opts->npermitlisten)) != 0)
804 1.17 christos return r;
805 1.17 christos
806 1.17 christos /* success */
807 1.17 christos return 0;
808 1.17 christos }
809 1.17 christos
810 1.17 christos int
811 1.17 christos sshauthopt_deserialise(struct sshbuf *m, struct sshauthopt **optsp)
812 1.17 christos {
813 1.17 christos struct sshauthopt *opts = NULL;
814 1.17 christos int r = SSH_ERR_INTERNAL_ERROR;
815 1.17 christos u_char f;
816 1.17 christos u_int tmp;
817 1.17 christos
818 1.17 christos if ((opts = calloc(1, sizeof(*opts))) == NULL)
819 1.17 christos return SSH_ERR_ALLOC_FAIL;
820 1.17 christos
821 1.17 christos #define OPT_FLAG(x) \
822 1.17 christos do { \
823 1.17 christos if ((r = sshbuf_get_u8(m, &f)) != 0) \
824 1.17 christos goto out; \
825 1.17 christos opts->x = f; \
826 1.17 christos } while (0)
827 1.17 christos OPT_FLAG(permit_port_forwarding_flag);
828 1.17 christos OPT_FLAG(permit_agent_forwarding_flag);
829 1.17 christos OPT_FLAG(permit_x11_forwarding_flag);
830 1.17 christos OPT_FLAG(permit_pty_flag);
831 1.17 christos OPT_FLAG(permit_user_rc);
832 1.17 christos OPT_FLAG(restricted);
833 1.17 christos OPT_FLAG(cert_authority);
834 1.17 christos #undef OPT_FLAG
835 1.17 christos
836 1.17 christos if ((r = sshbuf_get_u64(m, &opts->valid_before)) != 0)
837 1.17 christos goto out;
838 1.17 christos
839 1.17 christos /* tunnel number can be negative to indicate "unset" */
840 1.17 christos if ((r = sshbuf_get_u8(m, &f)) != 0 ||
841 1.17 christos (r = sshbuf_get_u32(m, &tmp)) != 0)
842 1.17 christos goto out;
843 1.17 christos opts->force_tun_device = f ? -1 : (int)tmp;
844 1.17 christos
845 1.17 christos /* String options may be NULL */
846 1.17 christos if ((r = deserialise_nullable_string(m, &opts->cert_principals)) != 0 ||
847 1.17 christos (r = deserialise_nullable_string(m, &opts->force_command)) != 0 ||
848 1.17 christos (r = deserialise_nullable_string(m,
849 1.17 christos &opts->required_from_host_cert)) != 0 ||
850 1.17 christos (r = deserialise_nullable_string(m,
851 1.17 christos &opts->required_from_host_keys)) != 0)
852 1.17 christos goto out;
853 1.17 christos
854 1.17 christos /* Array options */
855 1.17 christos if ((r = deserialise_array(m, &opts->env, &opts->nenv)) != 0 ||
856 1.17 christos (r = deserialise_array(m,
857 1.18 christos &opts->permitopen, &opts->npermitopen)) != 0 ||
858 1.18 christos (r = deserialise_array(m,
859 1.18 christos &opts->permitlisten, &opts->npermitlisten)) != 0)
860 1.17 christos goto out;
861 1.17 christos
862 1.17 christos /* success */
863 1.17 christos r = 0;
864 1.17 christos *optsp = opts;
865 1.17 christos opts = NULL;
866 1.17 christos out:
867 1.17 christos sshauthopt_free(opts);
868 1.17 christos return r;
869 1.17 christos }
870