hostfile.c revision 1.15 1 1.15 christos /* $NetBSD: hostfile.c,v 1.15 2019/10/12 18:32:22 christos Exp $ */
2 1.15 christos /* $OpenBSD: hostfile.c,v 1.76 2019/07/07 01:05:00 dtucker Exp $ */
3 1.1 christos /*
4 1.1 christos * Author: Tatu Ylonen <ylo (at) cs.hut.fi>
5 1.1 christos * Copyright (c) 1995 Tatu Ylonen <ylo (at) cs.hut.fi>, Espoo, Finland
6 1.1 christos * All rights reserved
7 1.1 christos * Functions for manipulating the known hosts files.
8 1.1 christos *
9 1.1 christos * As far as I am concerned, the code I have written for this software
10 1.1 christos * can be used freely for any purpose. Any derived versions of this
11 1.1 christos * software must be clearly marked as such, and if the derived work is
12 1.1 christos * incompatible with the protocol description in the RFC file, it must be
13 1.1 christos * called by a name other than "ssh" or "Secure Shell".
14 1.1 christos *
15 1.1 christos *
16 1.1 christos * Copyright (c) 1999, 2000 Markus Friedl. All rights reserved.
17 1.1 christos * Copyright (c) 1999 Niels Provos. All rights reserved.
18 1.1 christos *
19 1.1 christos * Redistribution and use in source and binary forms, with or without
20 1.1 christos * modification, are permitted provided that the following conditions
21 1.1 christos * are met:
22 1.1 christos * 1. Redistributions of source code must retain the above copyright
23 1.1 christos * notice, this list of conditions and the following disclaimer.
24 1.1 christos * 2. Redistributions in binary form must reproduce the above copyright
25 1.1 christos * notice, this list of conditions and the following disclaimer in the
26 1.1 christos * documentation and/or other materials provided with the distribution.
27 1.1 christos *
28 1.1 christos * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
29 1.1 christos * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
30 1.1 christos * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
31 1.1 christos * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
32 1.1 christos * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
33 1.1 christos * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
34 1.1 christos * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
35 1.1 christos * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
36 1.1 christos * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
37 1.1 christos * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
38 1.1 christos */
39 1.1 christos
40 1.2 christos #include "includes.h"
41 1.15 christos __RCSID("$NetBSD: hostfile.c,v 1.15 2019/10/12 18:32:22 christos Exp $");
42 1.1 christos #include <sys/types.h>
43 1.7 christos #include <sys/stat.h>
44 1.1 christos
45 1.1 christos #include <netinet/in.h>
46 1.1 christos
47 1.7 christos #include <errno.h>
48 1.1 christos #include <resolv.h>
49 1.1 christos #include <stdio.h>
50 1.1 christos #include <stdlib.h>
51 1.1 christos #include <string.h>
52 1.6 christos #include <stdarg.h>
53 1.6 christos #include <time.h>
54 1.7 christos #include <unistd.h>
55 1.1 christos
56 1.1 christos #include "xmalloc.h"
57 1.1 christos #include "match.h"
58 1.7 christos #include "sshkey.h"
59 1.1 christos #include "hostfile.h"
60 1.1 christos #include "log.h"
61 1.4 christos #include "misc.h"
62 1.7 christos #include "ssherr.h"
63 1.6 christos #include "digest.h"
64 1.6 christos #include "hmac.h"
65 1.4 christos
66 1.4 christos struct hostkeys {
67 1.4 christos struct hostkey_entry *entries;
68 1.4 christos u_int num_entries;
69 1.4 christos };
70 1.1 christos
71 1.7 christos /* XXX hmac is too easy to dictionary attack; use bcrypt? */
72 1.7 christos
73 1.1 christos static int
74 1.5 christos extract_salt(const char *s, u_int l, u_char *salt, size_t salt_len)
75 1.1 christos {
76 1.1 christos char *p, *b64salt;
77 1.1 christos u_int b64len;
78 1.1 christos int ret;
79 1.1 christos
80 1.1 christos if (l < sizeof(HASH_MAGIC) - 1) {
81 1.1 christos debug2("extract_salt: string too short");
82 1.1 christos return (-1);
83 1.1 christos }
84 1.1 christos if (strncmp(s, HASH_MAGIC, sizeof(HASH_MAGIC) - 1) != 0) {
85 1.1 christos debug2("extract_salt: invalid magic identifier");
86 1.1 christos return (-1);
87 1.1 christos }
88 1.1 christos s += sizeof(HASH_MAGIC) - 1;
89 1.1 christos l -= sizeof(HASH_MAGIC) - 1;
90 1.1 christos if ((p = memchr(s, HASH_DELIM, l)) == NULL) {
91 1.1 christos debug2("extract_salt: missing salt termination character");
92 1.1 christos return (-1);
93 1.1 christos }
94 1.1 christos
95 1.1 christos b64len = p - s;
96 1.1 christos /* Sanity check */
97 1.1 christos if (b64len == 0 || b64len > 1024) {
98 1.1 christos debug2("extract_salt: bad encoded salt length %u", b64len);
99 1.1 christos return (-1);
100 1.1 christos }
101 1.1 christos b64salt = xmalloc(1 + b64len);
102 1.1 christos memcpy(b64salt, s, b64len);
103 1.1 christos b64salt[b64len] = '\0';
104 1.1 christos
105 1.1 christos ret = __b64_pton(b64salt, salt, salt_len);
106 1.5 christos free(b64salt);
107 1.1 christos if (ret == -1) {
108 1.1 christos debug2("extract_salt: salt decode error");
109 1.1 christos return (-1);
110 1.1 christos }
111 1.6 christos if (ret != (int)ssh_hmac_bytes(SSH_DIGEST_SHA1)) {
112 1.6 christos debug2("extract_salt: expected salt len %zd, got %d",
113 1.6 christos ssh_hmac_bytes(SSH_DIGEST_SHA1), ret);
114 1.1 christos return (-1);
115 1.1 christos }
116 1.1 christos
117 1.1 christos return (0);
118 1.1 christos }
119 1.1 christos
120 1.1 christos char *
121 1.1 christos host_hash(const char *host, const char *name_from_hostfile, u_int src_len)
122 1.1 christos {
123 1.6 christos struct ssh_hmac_ctx *ctx;
124 1.5 christos u_char salt[256], result[256];
125 1.5 christos char uu_salt[512], uu_result[512];
126 1.14 christos static char encoded[2048];
127 1.9 christos u_int len;
128 1.1 christos
129 1.6 christos len = ssh_digest_bytes(SSH_DIGEST_SHA1);
130 1.1 christos
131 1.1 christos if (name_from_hostfile == NULL) {
132 1.1 christos /* Create new salt */
133 1.9 christos arc4random_buf(salt, len);
134 1.1 christos } else {
135 1.1 christos /* Extract salt from known host entry */
136 1.1 christos if (extract_salt(name_from_hostfile, src_len, salt,
137 1.1 christos sizeof(salt)) == -1)
138 1.1 christos return (NULL);
139 1.1 christos }
140 1.1 christos
141 1.6 christos if ((ctx = ssh_hmac_start(SSH_DIGEST_SHA1)) == NULL ||
142 1.6 christos ssh_hmac_init(ctx, salt, len) < 0 ||
143 1.6 christos ssh_hmac_update(ctx, host, strlen(host)) < 0 ||
144 1.6 christos ssh_hmac_final(ctx, result, sizeof(result)))
145 1.6 christos fatal("%s: ssh_hmac failed", __func__);
146 1.6 christos ssh_hmac_free(ctx);
147 1.1 christos
148 1.1 christos if (__b64_ntop(salt, len, uu_salt, sizeof(uu_salt)) == -1 ||
149 1.1 christos __b64_ntop(result, len, uu_result, sizeof(uu_result)) == -1)
150 1.6 christos fatal("%s: __b64_ntop failed", __func__);
151 1.1 christos
152 1.1 christos snprintf(encoded, sizeof(encoded), "%s%s%c%s", HASH_MAGIC, uu_salt,
153 1.1 christos HASH_DELIM, uu_result);
154 1.1 christos
155 1.1 christos return (encoded);
156 1.1 christos }
157 1.1 christos
158 1.1 christos /*
159 1.1 christos * Parses an RSA (number of bits, e, n) or DSA key from a string. Moves the
160 1.1 christos * pointer over the key. Skips any whitespace at the beginning and at end.
161 1.1 christos */
162 1.1 christos
163 1.1 christos int
164 1.7 christos hostfile_read_key(char **cpp, u_int *bitsp, struct sshkey *ret)
165 1.1 christos {
166 1.1 christos char *cp;
167 1.1 christos
168 1.1 christos /* Skip leading whitespace. */
169 1.1 christos for (cp = *cpp; *cp == ' ' || *cp == '\t'; cp++)
170 1.1 christos ;
171 1.1 christos
172 1.15 christos if (sshkey_read(ret, &cp) != 0)
173 1.1 christos return 0;
174 1.1 christos
175 1.1 christos /* Skip trailing whitespace. */
176 1.1 christos for (; *cp == ' ' || *cp == '\t'; cp++)
177 1.1 christos ;
178 1.1 christos
179 1.1 christos /* Return results. */
180 1.1 christos *cpp = cp;
181 1.7 christos if (bitsp != NULL)
182 1.7 christos *bitsp = sshkey_size(ret);
183 1.1 christos return 1;
184 1.1 christos }
185 1.1 christos
186 1.4 christos static HostkeyMarker
187 1.3 adam check_markers(char **cpp)
188 1.3 adam {
189 1.3 adam char marker[32], *sp, *cp = *cpp;
190 1.3 adam int ret = MRK_NONE;
191 1.3 adam
192 1.3 adam while (*cp == '@') {
193 1.3 adam /* Only one marker is allowed */
194 1.3 adam if (ret != MRK_NONE)
195 1.3 adam return MRK_ERROR;
196 1.3 adam /* Markers are terminated by whitespace */
197 1.3 adam if ((sp = strchr(cp, ' ')) == NULL &&
198 1.3 adam (sp = strchr(cp, '\t')) == NULL)
199 1.3 adam return MRK_ERROR;
200 1.3 adam /* Extract marker for comparison */
201 1.3 adam if (sp <= cp + 1 || sp >= cp + sizeof(marker))
202 1.3 adam return MRK_ERROR;
203 1.3 adam memcpy(marker, cp, sp - cp);
204 1.3 adam marker[sp - cp] = '\0';
205 1.3 adam if (strcmp(marker, CA_MARKER) == 0)
206 1.3 adam ret = MRK_CA;
207 1.3 adam else if (strcmp(marker, REVOKE_MARKER) == 0)
208 1.3 adam ret = MRK_REVOKE;
209 1.3 adam else
210 1.3 adam return MRK_ERROR;
211 1.3 adam
212 1.3 adam /* Skip past marker and any whitespace that follows it */
213 1.3 adam cp = sp;
214 1.3 adam for (; *cp == ' ' || *cp == '\t'; cp++)
215 1.3 adam ;
216 1.3 adam }
217 1.3 adam *cpp = cp;
218 1.3 adam return ret;
219 1.3 adam }
220 1.3 adam
221 1.4 christos struct hostkeys *
222 1.4 christos init_hostkeys(void)
223 1.4 christos {
224 1.4 christos struct hostkeys *ret = xcalloc(1, sizeof(*ret));
225 1.4 christos
226 1.4 christos ret->entries = NULL;
227 1.4 christos return ret;
228 1.4 christos }
229 1.1 christos
230 1.7 christos struct load_callback_ctx {
231 1.7 christos const char *host;
232 1.7 christos u_long num_loaded;
233 1.7 christos struct hostkeys *hostkeys;
234 1.7 christos };
235 1.7 christos
236 1.7 christos static int
237 1.7 christos record_hostkey(struct hostkey_foreach_line *l, void *_ctx)
238 1.1 christos {
239 1.7 christos struct load_callback_ctx *ctx = (struct load_callback_ctx *)_ctx;
240 1.7 christos struct hostkeys *hostkeys = ctx->hostkeys;
241 1.7 christos struct hostkey_entry *tmp;
242 1.7 christos
243 1.7 christos if (l->status == HKF_STATUS_INVALID) {
244 1.8 christos /* XXX make this verbose() in the future */
245 1.8 christos debug("%s:%ld: parse error in hostkeys file",
246 1.7 christos l->path, l->linenum);
247 1.7 christos return 0;
248 1.7 christos }
249 1.1 christos
250 1.7 christos debug3("%s: found %skey type %s in file %s:%lu", __func__,
251 1.7 christos l->marker == MRK_NONE ? "" :
252 1.7 christos (l->marker == MRK_CA ? "ca " : "revoked "),
253 1.7 christos sshkey_type(l->key), l->path, l->linenum);
254 1.11 christos if ((tmp = recallocarray(hostkeys->entries, hostkeys->num_entries,
255 1.7 christos hostkeys->num_entries + 1, sizeof(*hostkeys->entries))) == NULL)
256 1.7 christos return SSH_ERR_ALLOC_FAIL;
257 1.7 christos hostkeys->entries = tmp;
258 1.7 christos hostkeys->entries[hostkeys->num_entries].host = xstrdup(ctx->host);
259 1.7 christos hostkeys->entries[hostkeys->num_entries].file = xstrdup(l->path);
260 1.7 christos hostkeys->entries[hostkeys->num_entries].line = l->linenum;
261 1.7 christos hostkeys->entries[hostkeys->num_entries].key = l->key;
262 1.7 christos l->key = NULL; /* steal it */
263 1.7 christos hostkeys->entries[hostkeys->num_entries].marker = l->marker;
264 1.7 christos hostkeys->num_entries++;
265 1.7 christos ctx->num_loaded++;
266 1.1 christos
267 1.7 christos return 0;
268 1.7 christos }
269 1.3 adam
270 1.7 christos void
271 1.7 christos load_hostkeys(struct hostkeys *hostkeys, const char *host, const char *path)
272 1.7 christos {
273 1.7 christos int r;
274 1.7 christos struct load_callback_ctx ctx;
275 1.1 christos
276 1.7 christos ctx.host = host;
277 1.7 christos ctx.num_loaded = 0;
278 1.7 christos ctx.hostkeys = hostkeys;
279 1.7 christos
280 1.7 christos if ((r = hostkeys_foreach(path, record_hostkey, &ctx, host, NULL,
281 1.7 christos HKF_WANT_MATCH|HKF_WANT_PARSE_KEY)) != 0) {
282 1.7 christos if (r != SSH_ERR_SYSTEM_ERROR && errno != ENOENT)
283 1.7 christos debug("%s: hostkeys_foreach failed for %s: %s",
284 1.7 christos __func__, path, ssh_err(r));
285 1.7 christos }
286 1.7 christos if (ctx.num_loaded != 0)
287 1.7 christos debug3("%s: loaded %lu keys from %s", __func__,
288 1.7 christos ctx.num_loaded, host);
289 1.7 christos }
290 1.4 christos
291 1.4 christos void
292 1.4 christos free_hostkeys(struct hostkeys *hostkeys)
293 1.4 christos {
294 1.4 christos u_int i;
295 1.1 christos
296 1.4 christos for (i = 0; i < hostkeys->num_entries; i++) {
297 1.5 christos free(hostkeys->entries[i].host);
298 1.5 christos free(hostkeys->entries[i].file);
299 1.7 christos sshkey_free(hostkeys->entries[i].key);
300 1.6 christos explicit_bzero(hostkeys->entries + i, sizeof(*hostkeys->entries));
301 1.4 christos }
302 1.5 christos free(hostkeys->entries);
303 1.6 christos explicit_bzero(hostkeys, sizeof(*hostkeys));
304 1.5 christos free(hostkeys);
305 1.4 christos }
306 1.4 christos
307 1.4 christos static int
308 1.7 christos check_key_not_revoked(struct hostkeys *hostkeys, struct sshkey *k)
309 1.4 christos {
310 1.7 christos int is_cert = sshkey_is_cert(k);
311 1.4 christos u_int i;
312 1.4 christos
313 1.4 christos for (i = 0; i < hostkeys->num_entries; i++) {
314 1.4 christos if (hostkeys->entries[i].marker != MRK_REVOKE)
315 1.1 christos continue;
316 1.7 christos if (sshkey_equal_public(k, hostkeys->entries[i].key))
317 1.4 christos return -1;
318 1.4 christos if (is_cert &&
319 1.7 christos sshkey_equal_public(k->cert->signature_key,
320 1.4 christos hostkeys->entries[i].key))
321 1.4 christos return -1;
322 1.4 christos }
323 1.4 christos return 0;
324 1.4 christos }
325 1.4 christos
326 1.4 christos /*
327 1.4 christos * Match keys against a specified key, or look one up by key type.
328 1.4 christos *
329 1.4 christos * If looking for a keytype (key == NULL) and one is found then return
330 1.4 christos * HOST_FOUND, otherwise HOST_NEW.
331 1.4 christos *
332 1.4 christos * If looking for a key (key != NULL):
333 1.4 christos * 1. If the key is a cert and a matching CA is found, return HOST_OK
334 1.4 christos * 2. If the key is not a cert and a matching key is found, return HOST_OK
335 1.4 christos * 3. If no key matches but a key with a different type is found, then
336 1.4 christos * return HOST_CHANGED
337 1.4 christos * 4. If no matching keys are found, then return HOST_NEW.
338 1.4 christos *
339 1.4 christos * Finally, check any found key is not revoked.
340 1.4 christos */
341 1.4 christos static HostStatus
342 1.4 christos check_hostkeys_by_key_or_type(struct hostkeys *hostkeys,
343 1.7 christos struct sshkey *k, int keytype, const struct hostkey_entry **found)
344 1.4 christos {
345 1.4 christos u_int i;
346 1.4 christos HostStatus end_return = HOST_NEW;
347 1.7 christos int want_cert = sshkey_is_cert(k);
348 1.4 christos HostkeyMarker want_marker = want_cert ? MRK_CA : MRK_NONE;
349 1.4 christos
350 1.4 christos if (found != NULL)
351 1.4 christos *found = NULL;
352 1.1 christos
353 1.4 christos for (i = 0; i < hostkeys->num_entries; i++) {
354 1.4 christos if (hostkeys->entries[i].marker != want_marker)
355 1.4 christos continue;
356 1.4 christos if (k == NULL) {
357 1.4 christos if (hostkeys->entries[i].key->type != keytype)
358 1.4 christos continue;
359 1.4 christos end_return = HOST_FOUND;
360 1.4 christos if (found != NULL)
361 1.4 christos *found = hostkeys->entries + i;
362 1.4 christos k = hostkeys->entries[i].key;
363 1.4 christos break;
364 1.4 christos }
365 1.4 christos if (want_cert) {
366 1.7 christos if (sshkey_equal_public(k->cert->signature_key,
367 1.4 christos hostkeys->entries[i].key)) {
368 1.4 christos /* A matching CA exists */
369 1.4 christos end_return = HOST_OK;
370 1.4 christos if (found != NULL)
371 1.4 christos *found = hostkeys->entries + i;
372 1.4 christos break;
373 1.3 adam }
374 1.4 christos } else {
375 1.7 christos if (sshkey_equal(k, hostkeys->entries[i].key)) {
376 1.4 christos end_return = HOST_OK;
377 1.4 christos if (found != NULL)
378 1.4 christos *found = hostkeys->entries + i;
379 1.4 christos break;
380 1.3 adam }
381 1.4 christos /* A non-maching key exists */
382 1.4 christos end_return = HOST_CHANGED;
383 1.4 christos if (found != NULL)
384 1.4 christos *found = hostkeys->entries + i;
385 1.3 adam }
386 1.1 christos }
387 1.4 christos if (check_key_not_revoked(hostkeys, k) != 0) {
388 1.4 christos end_return = HOST_REVOKED;
389 1.4 christos if (found != NULL)
390 1.4 christos *found = NULL;
391 1.4 christos }
392 1.1 christos return end_return;
393 1.1 christos }
394 1.7 christos
395 1.1 christos HostStatus
396 1.7 christos check_key_in_hostkeys(struct hostkeys *hostkeys, struct sshkey *key,
397 1.4 christos const struct hostkey_entry **found)
398 1.1 christos {
399 1.1 christos if (key == NULL)
400 1.1 christos fatal("no key to look up");
401 1.4 christos return check_hostkeys_by_key_or_type(hostkeys, key, 0, found);
402 1.1 christos }
403 1.1 christos
404 1.1 christos int
405 1.4 christos lookup_key_in_hostkeys_by_type(struct hostkeys *hostkeys, int keytype,
406 1.4 christos const struct hostkey_entry **found)
407 1.1 christos {
408 1.4 christos return (check_hostkeys_by_key_or_type(hostkeys, NULL, keytype,
409 1.4 christos found) == HOST_FOUND);
410 1.1 christos }
411 1.1 christos
412 1.7 christos static int
413 1.7 christos write_host_entry(FILE *f, const char *host, const char *ip,
414 1.7 christos const struct sshkey *key, int store_hash)
415 1.7 christos {
416 1.7 christos int r, success = 0;
417 1.10 christos char *hashed_host = NULL, *lhost;
418 1.10 christos
419 1.10 christos lhost = xstrdup(host);
420 1.10 christos lowercase(lhost);
421 1.7 christos
422 1.7 christos if (store_hash) {
423 1.10 christos if ((hashed_host = host_hash(lhost, NULL, 0)) == NULL) {
424 1.7 christos error("%s: host_hash failed", __func__);
425 1.10 christos free(lhost);
426 1.7 christos return 0;
427 1.7 christos }
428 1.7 christos fprintf(f, "%s ", hashed_host);
429 1.7 christos } else if (ip != NULL)
430 1.10 christos fprintf(f, "%s,%s ", lhost, ip);
431 1.10 christos else {
432 1.10 christos fprintf(f, "%s ", lhost);
433 1.10 christos }
434 1.10 christos free(lhost);
435 1.7 christos if ((r = sshkey_write(key, f)) == 0)
436 1.7 christos success = 1;
437 1.7 christos else
438 1.7 christos error("%s: sshkey_write failed: %s", __func__, ssh_err(r));
439 1.7 christos fputc('\n', f);
440 1.7 christos return success;
441 1.7 christos }
442 1.7 christos
443 1.1 christos /*
444 1.1 christos * Appends an entry to the host file. Returns false if the entry could not
445 1.1 christos * be appended.
446 1.1 christos */
447 1.1 christos int
448 1.7 christos add_host_to_hostfile(const char *filename, const char *host,
449 1.7 christos const struct sshkey *key, int store_hash)
450 1.1 christos {
451 1.1 christos FILE *f;
452 1.7 christos int success;
453 1.1 christos
454 1.1 christos if (key == NULL)
455 1.1 christos return 1; /* XXX ? */
456 1.1 christos f = fopen(filename, "a");
457 1.1 christos if (!f)
458 1.1 christos return 0;
459 1.7 christos success = write_host_entry(f, host, NULL, key, store_hash);
460 1.7 christos fclose(f);
461 1.7 christos return success;
462 1.7 christos }
463 1.1 christos
464 1.7 christos struct host_delete_ctx {
465 1.7 christos FILE *out;
466 1.7 christos int quiet;
467 1.7 christos const char *host;
468 1.7 christos int *skip_keys; /* XXX split for host/ip? might want to ensure both */
469 1.7 christos struct sshkey * const *keys;
470 1.7 christos size_t nkeys;
471 1.7 christos int modified;
472 1.7 christos };
473 1.7 christos
474 1.7 christos static int
475 1.7 christos host_delete(struct hostkey_foreach_line *l, void *_ctx)
476 1.7 christos {
477 1.7 christos struct host_delete_ctx *ctx = (struct host_delete_ctx *)_ctx;
478 1.7 christos int loglevel = ctx->quiet ? SYSLOG_LEVEL_DEBUG1 : SYSLOG_LEVEL_VERBOSE;
479 1.7 christos size_t i;
480 1.7 christos
481 1.7 christos if (l->status == HKF_STATUS_MATCHED) {
482 1.7 christos if (l->marker != MRK_NONE) {
483 1.7 christos /* Don't remove CA and revocation lines */
484 1.7 christos fprintf(ctx->out, "%s\n", l->line);
485 1.7 christos return 0;
486 1.7 christos }
487 1.7 christos
488 1.7 christos /*
489 1.7 christos * If this line contains one of the keys that we will be
490 1.7 christos * adding later, then don't change it and mark the key for
491 1.7 christos * skipping.
492 1.7 christos */
493 1.7 christos for (i = 0; i < ctx->nkeys; i++) {
494 1.7 christos if (sshkey_equal(ctx->keys[i], l->key)) {
495 1.7 christos ctx->skip_keys[i] = 1;
496 1.7 christos fprintf(ctx->out, "%s\n", l->line);
497 1.7 christos debug3("%s: %s key already at %s:%ld", __func__,
498 1.7 christos sshkey_type(l->key), l->path, l->linenum);
499 1.7 christos return 0;
500 1.7 christos }
501 1.7 christos }
502 1.7 christos
503 1.7 christos /*
504 1.7 christos * Hostname matches and has no CA/revoke marker, delete it
505 1.7 christos * by *not* writing the line to ctx->out.
506 1.7 christos */
507 1.7 christos do_log2(loglevel, "%s%s%s:%ld: Removed %s key for host %s",
508 1.7 christos ctx->quiet ? __func__ : "", ctx->quiet ? ": " : "",
509 1.7 christos l->path, l->linenum, sshkey_type(l->key), ctx->host);
510 1.7 christos ctx->modified = 1;
511 1.7 christos return 0;
512 1.7 christos }
513 1.7 christos /* Retain non-matching hosts and invalid lines when deleting */
514 1.7 christos if (l->status == HKF_STATUS_INVALID) {
515 1.7 christos do_log2(loglevel, "%s%s%s:%ld: invalid known_hosts entry",
516 1.7 christos ctx->quiet ? __func__ : "", ctx->quiet ? ": " : "",
517 1.7 christos l->path, l->linenum);
518 1.7 christos }
519 1.7 christos fprintf(ctx->out, "%s\n", l->line);
520 1.7 christos return 0;
521 1.7 christos }
522 1.7 christos
523 1.7 christos int
524 1.7 christos hostfile_replace_entries(const char *filename, const char *host, const char *ip,
525 1.7 christos struct sshkey **keys, size_t nkeys, int store_hash, int quiet, int hash_alg)
526 1.7 christos {
527 1.7 christos int r, fd, oerrno = 0;
528 1.7 christos int loglevel = quiet ? SYSLOG_LEVEL_DEBUG1 : SYSLOG_LEVEL_VERBOSE;
529 1.7 christos struct host_delete_ctx ctx;
530 1.7 christos char *fp, *temp = NULL, *back = NULL;
531 1.7 christos mode_t omask;
532 1.7 christos size_t i;
533 1.7 christos
534 1.7 christos omask = umask(077);
535 1.7 christos
536 1.7 christos memset(&ctx, 0, sizeof(ctx));
537 1.7 christos ctx.host = host;
538 1.7 christos ctx.quiet = quiet;
539 1.7 christos if ((ctx.skip_keys = calloc(nkeys, sizeof(*ctx.skip_keys))) == NULL)
540 1.7 christos return SSH_ERR_ALLOC_FAIL;
541 1.7 christos ctx.keys = keys;
542 1.7 christos ctx.nkeys = nkeys;
543 1.7 christos ctx.modified = 0;
544 1.7 christos
545 1.7 christos /*
546 1.7 christos * Prepare temporary file for in-place deletion.
547 1.7 christos */
548 1.15 christos if ((r = asprintf(&temp, "%s.XXXXXXXXXXX", filename)) == -1 ||
549 1.15 christos (r = asprintf(&back, "%s.old", filename)) == -1) {
550 1.7 christos r = SSH_ERR_ALLOC_FAIL;
551 1.7 christos goto fail;
552 1.7 christos }
553 1.7 christos
554 1.7 christos if ((fd = mkstemp(temp)) == -1) {
555 1.7 christos oerrno = errno;
556 1.7 christos error("%s: mkstemp: %s", __func__, strerror(oerrno));
557 1.7 christos r = SSH_ERR_SYSTEM_ERROR;
558 1.7 christos goto fail;
559 1.7 christos }
560 1.7 christos if ((ctx.out = fdopen(fd, "w")) == NULL) {
561 1.7 christos oerrno = errno;
562 1.7 christos close(fd);
563 1.7 christos error("%s: fdopen: %s", __func__, strerror(oerrno));
564 1.7 christos r = SSH_ERR_SYSTEM_ERROR;
565 1.7 christos goto fail;
566 1.7 christos }
567 1.7 christos
568 1.7 christos /* Remove all entries for the specified host from the file */
569 1.7 christos if ((r = hostkeys_foreach(filename, host_delete, &ctx, host, ip,
570 1.7 christos HKF_WANT_PARSE_KEY)) != 0) {
571 1.7 christos error("%s: hostkeys_foreach failed: %s", __func__, ssh_err(r));
572 1.7 christos goto fail;
573 1.7 christos }
574 1.7 christos
575 1.7 christos /* Add the requested keys */
576 1.7 christos for (i = 0; i < nkeys; i++) {
577 1.7 christos if (ctx.skip_keys[i])
578 1.7 christos continue;
579 1.7 christos if ((fp = sshkey_fingerprint(keys[i], hash_alg,
580 1.7 christos SSH_FP_DEFAULT)) == NULL) {
581 1.7 christos r = SSH_ERR_ALLOC_FAIL;
582 1.7 christos goto fail;
583 1.7 christos }
584 1.7 christos do_log2(loglevel, "%s%sAdding new key for %s to %s: %s %s",
585 1.7 christos quiet ? __func__ : "", quiet ? ": " : "", host, filename,
586 1.7 christos sshkey_ssh_name(keys[i]), fp);
587 1.7 christos free(fp);
588 1.7 christos if (!write_host_entry(ctx.out, host, ip, keys[i], store_hash)) {
589 1.7 christos r = SSH_ERR_INTERNAL_ERROR;
590 1.7 christos goto fail;
591 1.7 christos }
592 1.7 christos ctx.modified = 1;
593 1.1 christos }
594 1.7 christos fclose(ctx.out);
595 1.7 christos ctx.out = NULL;
596 1.1 christos
597 1.7 christos if (ctx.modified) {
598 1.7 christos /* Backup the original file and replace it with the temporary */
599 1.7 christos if (unlink(back) == -1 && errno != ENOENT) {
600 1.7 christos oerrno = errno;
601 1.7 christos error("%s: unlink %.100s: %s", __func__,
602 1.7 christos back, strerror(errno));
603 1.7 christos r = SSH_ERR_SYSTEM_ERROR;
604 1.7 christos goto fail;
605 1.7 christos }
606 1.7 christos if (link(filename, back) == -1) {
607 1.7 christos oerrno = errno;
608 1.7 christos error("%s: link %.100s to %.100s: %s", __func__,
609 1.7 christos filename, back, strerror(errno));
610 1.7 christos r = SSH_ERR_SYSTEM_ERROR;
611 1.7 christos goto fail;
612 1.7 christos }
613 1.7 christos if (rename(temp, filename) == -1) {
614 1.7 christos oerrno = errno;
615 1.7 christos error("%s: rename \"%s\" to \"%s\": %s", __func__,
616 1.7 christos temp, filename, strerror(errno));
617 1.7 christos r = SSH_ERR_SYSTEM_ERROR;
618 1.7 christos goto fail;
619 1.7 christos }
620 1.1 christos } else {
621 1.7 christos /* No changes made; just delete the temporary file */
622 1.7 christos if (unlink(temp) != 0)
623 1.7 christos error("%s: unlink \"%s\": %s", __func__,
624 1.7 christos temp, strerror(errno));
625 1.7 christos }
626 1.7 christos
627 1.7 christos /* success */
628 1.7 christos r = 0;
629 1.7 christos fail:
630 1.7 christos if (temp != NULL && r != 0)
631 1.7 christos unlink(temp);
632 1.7 christos free(temp);
633 1.7 christos free(back);
634 1.7 christos if (ctx.out != NULL)
635 1.7 christos fclose(ctx.out);
636 1.7 christos free(ctx.skip_keys);
637 1.7 christos umask(omask);
638 1.7 christos if (r == SSH_ERR_SYSTEM_ERROR)
639 1.7 christos errno = oerrno;
640 1.7 christos return r;
641 1.7 christos }
642 1.7 christos
643 1.7 christos static int
644 1.7 christos match_maybe_hashed(const char *host, const char *names, int *was_hashed)
645 1.7 christos {
646 1.7 christos int hashed = *names == HASH_DELIM;
647 1.7 christos const char *hashed_host;
648 1.7 christos size_t nlen = strlen(names);
649 1.7 christos
650 1.7 christos if (was_hashed != NULL)
651 1.7 christos *was_hashed = hashed;
652 1.7 christos if (hashed) {
653 1.7 christos if ((hashed_host = host_hash(host, names, nlen)) == NULL)
654 1.7 christos return -1;
655 1.7 christos return nlen == strlen(hashed_host) &&
656 1.7 christos strncmp(hashed_host, names, nlen) == 0;
657 1.1 christos }
658 1.8 christos return match_hostname(host, names) == 1;
659 1.7 christos }
660 1.7 christos
661 1.7 christos int
662 1.7 christos hostkeys_foreach(const char *path, hostkeys_foreach_fn *callback, void *ctx,
663 1.7 christos const char *host, const char *ip, u_int options)
664 1.7 christos {
665 1.7 christos FILE *f;
666 1.12 christos char *line = NULL, ktype[128];
667 1.7 christos u_long linenum = 0;
668 1.7 christos char *cp, *cp2;
669 1.7 christos u_int kbits;
670 1.7 christos int hashed;
671 1.7 christos int s, r = 0;
672 1.7 christos struct hostkey_foreach_line lineinfo;
673 1.12 christos size_t linesize = 0, l;
674 1.7 christos
675 1.7 christos memset(&lineinfo, 0, sizeof(lineinfo));
676 1.7 christos if (host == NULL && (options & HKF_WANT_MATCH) != 0)
677 1.7 christos return SSH_ERR_INVALID_ARGUMENT;
678 1.7 christos if ((f = fopen(path, "r")) == NULL)
679 1.7 christos return SSH_ERR_SYSTEM_ERROR;
680 1.7 christos
681 1.7 christos debug3("%s: reading file \"%s\"", __func__, path);
682 1.12 christos while (getline(&line, &linesize, f) != -1) {
683 1.12 christos linenum++;
684 1.7 christos line[strcspn(line, "\n")] = '\0';
685 1.7 christos
686 1.12 christos free(lineinfo.line);
687 1.7 christos sshkey_free(lineinfo.key);
688 1.7 christos memset(&lineinfo, 0, sizeof(lineinfo));
689 1.7 christos lineinfo.path = path;
690 1.7 christos lineinfo.linenum = linenum;
691 1.12 christos lineinfo.line = xstrdup(line);
692 1.7 christos lineinfo.marker = MRK_NONE;
693 1.7 christos lineinfo.status = HKF_STATUS_OK;
694 1.7 christos lineinfo.keytype = KEY_UNSPEC;
695 1.7 christos
696 1.7 christos /* Skip any leading whitespace, comments and empty lines. */
697 1.7 christos for (cp = line; *cp == ' ' || *cp == '\t'; cp++)
698 1.7 christos ;
699 1.7 christos if (!*cp || *cp == '#' || *cp == '\n') {
700 1.7 christos if ((options & HKF_WANT_MATCH) == 0) {
701 1.7 christos lineinfo.status = HKF_STATUS_COMMENT;
702 1.7 christos if ((r = callback(&lineinfo, ctx)) != 0)
703 1.7 christos break;
704 1.7 christos }
705 1.7 christos continue;
706 1.7 christos }
707 1.7 christos
708 1.7 christos if ((lineinfo.marker = check_markers(&cp)) == MRK_ERROR) {
709 1.7 christos verbose("%s: invalid marker at %s:%lu",
710 1.7 christos __func__, path, linenum);
711 1.7 christos if ((options & HKF_WANT_MATCH) == 0)
712 1.7 christos goto bad;
713 1.7 christos continue;
714 1.7 christos }
715 1.7 christos
716 1.7 christos /* Find the end of the host name portion. */
717 1.7 christos for (cp2 = cp; *cp2 && *cp2 != ' ' && *cp2 != '\t'; cp2++)
718 1.7 christos ;
719 1.7 christos lineinfo.hosts = cp;
720 1.7 christos *cp2++ = '\0';
721 1.7 christos
722 1.7 christos /* Check if the host name matches. */
723 1.7 christos if (host != NULL) {
724 1.7 christos if ((s = match_maybe_hashed(host, lineinfo.hosts,
725 1.7 christos &hashed)) == -1) {
726 1.7 christos debug2("%s: %s:%ld: bad host hash \"%.32s\"",
727 1.7 christos __func__, path, linenum, lineinfo.hosts);
728 1.7 christos goto bad;
729 1.7 christos }
730 1.7 christos if (s == 1) {
731 1.7 christos lineinfo.status = HKF_STATUS_MATCHED;
732 1.7 christos lineinfo.match |= HKF_MATCH_HOST |
733 1.7 christos (hashed ? HKF_MATCH_HOST_HASHED : 0);
734 1.7 christos }
735 1.7 christos /* Try matching IP address if supplied */
736 1.7 christos if (ip != NULL) {
737 1.7 christos if ((s = match_maybe_hashed(ip, lineinfo.hosts,
738 1.7 christos &hashed)) == -1) {
739 1.7 christos debug2("%s: %s:%ld: bad ip hash "
740 1.7 christos "\"%.32s\"", __func__, path,
741 1.7 christos linenum, lineinfo.hosts);
742 1.7 christos goto bad;
743 1.7 christos }
744 1.7 christos if (s == 1) {
745 1.7 christos lineinfo.status = HKF_STATUS_MATCHED;
746 1.7 christos lineinfo.match |= HKF_MATCH_IP |
747 1.7 christos (hashed ? HKF_MATCH_IP_HASHED : 0);
748 1.7 christos }
749 1.7 christos }
750 1.7 christos /*
751 1.7 christos * Skip this line if host matching requested and
752 1.7 christos * neither host nor address matched.
753 1.7 christos */
754 1.7 christos if ((options & HKF_WANT_MATCH) != 0 &&
755 1.7 christos lineinfo.status != HKF_STATUS_MATCHED)
756 1.7 christos continue;
757 1.7 christos }
758 1.7 christos
759 1.7 christos /* Got a match. Skip host name and any following whitespace */
760 1.7 christos for (; *cp2 == ' ' || *cp2 == '\t'; cp2++)
761 1.7 christos ;
762 1.7 christos if (*cp2 == '\0' || *cp2 == '#') {
763 1.7 christos debug2("%s:%ld: truncated before key type",
764 1.7 christos path, linenum);
765 1.7 christos goto bad;
766 1.7 christos }
767 1.7 christos lineinfo.rawkey = cp = cp2;
768 1.7 christos
769 1.7 christos if ((options & HKF_WANT_PARSE_KEY) != 0) {
770 1.7 christos /*
771 1.7 christos * Extract the key from the line. This will skip
772 1.7 christos * any leading whitespace. Ignore badly formatted
773 1.7 christos * lines.
774 1.7 christos */
775 1.7 christos if ((lineinfo.key = sshkey_new(KEY_UNSPEC)) == NULL) {
776 1.7 christos error("%s: sshkey_new failed", __func__);
777 1.7 christos r = SSH_ERR_ALLOC_FAIL;
778 1.7 christos break;
779 1.7 christos }
780 1.7 christos if (!hostfile_read_key(&cp, &kbits, lineinfo.key)) {
781 1.7 christos goto bad;
782 1.7 christos }
783 1.7 christos lineinfo.keytype = lineinfo.key->type;
784 1.7 christos lineinfo.comment = cp;
785 1.7 christos } else {
786 1.7 christos /* Extract and parse key type */
787 1.7 christos l = strcspn(lineinfo.rawkey, " \t");
788 1.7 christos if (l <= 1 || l >= sizeof(ktype) ||
789 1.7 christos lineinfo.rawkey[l] == '\0')
790 1.7 christos goto bad;
791 1.7 christos memcpy(ktype, lineinfo.rawkey, l);
792 1.7 christos ktype[l] = '\0';
793 1.7 christos lineinfo.keytype = sshkey_type_from_name(ktype);
794 1.8 christos
795 1.7 christos /*
796 1.11 christos * Assume legacy RSA1 if the first component is a short
797 1.7 christos * decimal number.
798 1.7 christos */
799 1.7 christos if (lineinfo.keytype == KEY_UNSPEC && l < 8 &&
800 1.7 christos strspn(ktype, "0123456789") == l)
801 1.11 christos goto bad;
802 1.8 christos
803 1.7 christos /*
804 1.7 christos * Check that something other than whitespace follows
805 1.7 christos * the key type. This won't catch all corruption, but
806 1.7 christos * it does catch trivial truncation.
807 1.7 christos */
808 1.7 christos cp2 += l; /* Skip past key type */
809 1.7 christos for (; *cp2 == ' ' || *cp2 == '\t'; cp2++)
810 1.7 christos ;
811 1.7 christos if (*cp2 == '\0' || *cp2 == '#') {
812 1.7 christos debug2("%s:%ld: truncated after key type",
813 1.7 christos path, linenum);
814 1.7 christos lineinfo.keytype = KEY_UNSPEC;
815 1.7 christos }
816 1.7 christos if (lineinfo.keytype == KEY_UNSPEC) {
817 1.7 christos bad:
818 1.7 christos sshkey_free(lineinfo.key);
819 1.7 christos lineinfo.key = NULL;
820 1.7 christos lineinfo.status = HKF_STATUS_INVALID;
821 1.7 christos if ((r = callback(&lineinfo, ctx)) != 0)
822 1.7 christos break;
823 1.7 christos continue;
824 1.7 christos }
825 1.7 christos }
826 1.7 christos if ((r = callback(&lineinfo, ctx)) != 0)
827 1.7 christos break;
828 1.7 christos }
829 1.7 christos sshkey_free(lineinfo.key);
830 1.12 christos free(lineinfo.line);
831 1.12 christos free(line);
832 1.1 christos fclose(f);
833 1.7 christos return r;
834 1.1 christos }
835