To get this branch, use:
bzr branch
http://bzr.recompile.se/loggerhead/mandos/trunk
« back to all changes in this revision
Viewing changes to plugins.d/password-request.c
- browse files at revision 1
- compare with another revision
- download diff
- download tarball
- view history from revision 1
- Committer: Björn Påhlsson
- Date: 2007-10-20 21:38:25 UTC
- Revision ID: belorn@tower-20071020213825-abf6f0d1c33ee961
First working version with: IPv6, GnuTLS, X.509 certificates, DN
retrieval.
retrieval.
- files added:
- bad-ca.pem
- files removed:
- COPYING
- plugins.d
- files modified:
- Makefile
added
removed
plugins.d/password-request.c
1
/* -*- coding: utf-8 -*- */
2
/*
3
* Mandos client - get and decrypt data from a Mandos server
4
*
5
* This program is partly derived from an example program for an Avahi
6
* service browser, downloaded from
7
* <http://avahi.org/browser/examples/core-browse-services.c>. This
8
* includes the following functions: "resolve_callback",
9
* "browse_callback", and parts of "main".
10
*
11
* Everything else is
12
* Copyright © 2007-2008 Teddy Hogeborn & Björn Påhlsson
13
*
14
* This program is free software: you can redistribute it and/or
15
* modify it under the terms of the GNU General Public License as
16
* published by the Free Software Foundation, either version 3 of the
17
* License, or (at your option) any later version.
18
*
19
* This program is distributed in the hope that it will be useful, but
20
* WITHOUT ANY WARRANTY; without even the implied warranty of
21
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
22
* General Public License for more details.
23
*
24
* You should have received a copy of the GNU General Public License
25
* along with this program. If not, see
26
* <http://www.gnu.org/licenses/>.
27
*
28
* Contact the authors at <mandos@fukt.bsnet.se>.
29
*/
30
31
/* Needed by GPGME, specifically gpgme_data_seek() */
32
#define _LARGEFILE_SOURCE
33
#define _FILE_OFFSET_BITS 64
34
35
#define _GNU_SOURCE /* TEMP_FAILURE_RETRY(), asprintf() */
36
37
#include <stdio.h> /* fprintf(), stderr, fwrite(),
38
stdout, ferror() */
39
#include <stdint.h> /* uint16_t, uint32_t */
40
#include <stddef.h> /* NULL, size_t, ssize_t */
41
#include <stdlib.h> /* free(), EXIT_SUCCESS, EXIT_FAILURE,
42
srand() */
43
#include <stdbool.h> /* bool, true */
44
#include <string.h> /* memset(), strcmp(), strlen(),
45
strerror(), asprintf(), strcpy() */
46
#include <sys/ioctl.h> /* ioctl */
47
#include <sys/types.h> /* socket(), inet_pton(), sockaddr,
48
sockaddr_in6, PF_INET6,
49
SOCK_STREAM, INET6_ADDRSTRLEN,
50
uid_t, gid_t */
51
#include <inttypes.h> /* PRIu16 */
52
#include <sys/socket.h> /* socket(), struct sockaddr_in6,
53
struct in6_addr, inet_pton(),
54
connect() */
55
#include <assert.h> /* assert() */
56
#include <errno.h> /* perror(), errno */
57
#include <time.h> /* time() */
58
#include <net/if.h> /* ioctl, ifreq, SIOCGIFFLAGS, IFF_UP,
59
SIOCSIFFLAGS, if_indextoname(),
60
if_nametoindex(), IF_NAMESIZE */
61
#include <unistd.h> /* close(), SEEK_SET, off_t, write(),
62
getuid(), getgid(), setuid(),
63
setgid() */
64
#include <netinet/in.h>
65
#include <arpa/inet.h> /* inet_pton(), htons */
66
#include <iso646.h> /* not, and */
67
#include <argp.h> /* struct argp_option, error_t, struct
68
argp_state, struct argp,
69
argp_parse(), ARGP_KEY_ARG,
70
ARGP_KEY_END, ARGP_ERR_UNKNOWN */
71
72
/* Avahi */
73
/* All Avahi types, constants and functions
74
Avahi*, avahi_*,
75
AVAHI_* */
76
#include <avahi-core/core.h>
77
#include <avahi-core/lookup.h>
78
#include <avahi-core/log.h>
79
#include <avahi-common/simple-watch.h>
80
#include <avahi-common/malloc.h>
81
#include <avahi-common/error.h>
82
83
/* GnuTLS */
84
#include <gnutls/gnutls.h> /* All GnuTLS types, constants and
85
functions:
86
gnutls_*
87
init_gnutls_session(),
88
GNUTLS_* */
89
#include <gnutls/openpgp.h> /* gnutls_certificate_set_openpgp_key_file(),
90
GNUTLS_OPENPGP_FMT_BASE64 */
91
92
/* GPGME */
93
#include <gpgme.h> /* All GPGME types, constants and
94
functions:
95
gpgme_*
96
GPGME_PROTOCOL_OpenPGP,
97
GPG_ERR_NO_* */
98
99
#define BUFFER_SIZE 256
100
101
bool debug = false;
102
static const char *keydir = "/conf/conf.d/mandos";
103
static const char mandos_protocol_version[] = "1";
104
const char *argp_program_version = "password-request 1.0";
105
const char *argp_program_bug_address = "<mandos@fukt.bsnet.se>";
106
107
/* Used for passing in values through the Avahi callback functions */
108
typedef struct {
109
AvahiSimplePoll *simple_poll;
110
AvahiServer *server;
111
gnutls_certificate_credentials_t cred;
112
unsigned int dh_bits;
113
gnutls_dh_params_t dh_params;
114
const char *priority;
115
} mandos_context;
116
117
/*
118
* Make room in "buffer" for at least BUFFER_SIZE additional bytes.
119
* "buffer_capacity" is how much is currently allocated,
120
* "buffer_length" is how much is already used.
121
*/
122
size_t adjustbuffer(char **buffer, size_t buffer_length,
123
size_t buffer_capacity){
124
if (buffer_length + BUFFER_SIZE > buffer_capacity){
125
*buffer = realloc(*buffer, buffer_capacity + BUFFER_SIZE);
126
if (buffer == NULL){
127
return 0;
128
}
129
buffer_capacity += BUFFER_SIZE;
130
}
131
return buffer_capacity;
132
}
133
134
/*
135
* Decrypt OpenPGP data using keyrings in HOMEDIR.
136
* Returns -1 on error
137
*/
138
static ssize_t pgp_packet_decrypt (const char *cryptotext,
139
size_t crypto_size,
140
char **plaintext,
141
const char *homedir){
142
gpgme_data_t dh_crypto, dh_plain;
143
gpgme_ctx_t ctx;
144
gpgme_error_t rc;
145
ssize_t ret;
146
size_t plaintext_capacity = 0;
147
ssize_t plaintext_length = 0;
148
gpgme_engine_info_t engine_info;
149
150
if (debug){
151
fprintf(stderr, "Trying to decrypt OpenPGP data\n");
152
}
153
154
/* Init GPGME */
155
gpgme_check_version(NULL);
156
rc = gpgme_engine_check_version(GPGME_PROTOCOL_OpenPGP);
157
if (rc != GPG_ERR_NO_ERROR){
158
fprintf(stderr, "bad gpgme_engine_check_version: %s: %s\n",
159
gpgme_strsource(rc), gpgme_strerror(rc));
160
return -1;
161
}
162
163
/* Set GPGME home directory for the OpenPGP engine only */
164
rc = gpgme_get_engine_info (&engine_info);
165
if (rc != GPG_ERR_NO_ERROR){
166
fprintf(stderr, "bad gpgme_get_engine_info: %s: %s\n",
167
gpgme_strsource(rc), gpgme_strerror(rc));
168
return -1;
169
}
170
while(engine_info != NULL){
171
if(engine_info->protocol == GPGME_PROTOCOL_OpenPGP){
172
gpgme_set_engine_info(GPGME_PROTOCOL_OpenPGP,
173
engine_info->file_name, homedir);
174
break;
175
}
176
engine_info = engine_info->next;
177
}
178
if(engine_info == NULL){
179
fprintf(stderr, "Could not set GPGME home dir to %s\n", homedir);
180
return -1;
181
}
182
183
/* Create new GPGME data buffer from memory cryptotext */
184
rc = gpgme_data_new_from_mem(&dh_crypto, cryptotext, crypto_size,
185
0);
186
if (rc != GPG_ERR_NO_ERROR){
187
fprintf(stderr, "bad gpgme_data_new_from_mem: %s: %s\n",
188
gpgme_strsource(rc), gpgme_strerror(rc));
189
return -1;
190
}
191
192
/* Create new empty GPGME data buffer for the plaintext */
193
rc = gpgme_data_new(&dh_plain);
194
if (rc != GPG_ERR_NO_ERROR){
195
fprintf(stderr, "bad gpgme_data_new: %s: %s\n",
196
gpgme_strsource(rc), gpgme_strerror(rc));
197
gpgme_data_release(dh_crypto);
198
return -1;
199
}
200
201
/* Create new GPGME "context" */
202
rc = gpgme_new(&ctx);
203
if (rc != GPG_ERR_NO_ERROR){
204
fprintf(stderr, "bad gpgme_new: %s: %s\n",
205
gpgme_strsource(rc), gpgme_strerror(rc));
206
plaintext_length = -1;
207
goto decrypt_end;
208
}
209
210
/* Decrypt data from the cryptotext data buffer to the plaintext
211
data buffer */
212
rc = gpgme_op_decrypt(ctx, dh_crypto, dh_plain);
213
if (rc != GPG_ERR_NO_ERROR){
214
fprintf(stderr, "bad gpgme_op_decrypt: %s: %s\n",
215
gpgme_strsource(rc), gpgme_strerror(rc));
216
plaintext_length = -1;
217
goto decrypt_end;
218
}
219
220
if(debug){
221
fprintf(stderr, "Decryption of OpenPGP data succeeded\n");
222
}
223
224
if (debug){
225
gpgme_decrypt_result_t result;
226
result = gpgme_op_decrypt_result(ctx);
227
if (result == NULL){
228
fprintf(stderr, "gpgme_op_decrypt_result failed\n");
229
} else {
230
fprintf(stderr, "Unsupported algorithm: %s\n",
231
result->unsupported_algorithm);
232
fprintf(stderr, "Wrong key usage: %u\n",
233
result->wrong_key_usage);
234
if(result->file_name != NULL){
235
fprintf(stderr, "File name: %s\n", result->file_name);
236
}
237
gpgme_recipient_t recipient;
238
recipient = result->recipients;
239
if(recipient){
240
while(recipient != NULL){
241
fprintf(stderr, "Public key algorithm: %s\n",
242
gpgme_pubkey_algo_name(recipient->pubkey_algo));
243
fprintf(stderr, "Key ID: %s\n", recipient->keyid);
244
fprintf(stderr, "Secret key available: %s\n",
245
recipient->status == GPG_ERR_NO_SECKEY
246
? "No" : "Yes");
247
recipient = recipient->next;
248
}
249
}
250
}
251
}
252
253
/* Seek back to the beginning of the GPGME plaintext data buffer */
254
if (gpgme_data_seek(dh_plain, (off_t) 0, SEEK_SET) == -1){
255
perror("pgpme_data_seek");
256
plaintext_length = -1;
257
goto decrypt_end;
258
}
259
260
*plaintext = NULL;
261
while(true){
262
plaintext_capacity = adjustbuffer(plaintext,
263
(size_t)plaintext_length,
264
plaintext_capacity);
265
if (plaintext_capacity == 0){
266
perror("adjustbuffer");
267
plaintext_length = -1;
268
goto decrypt_end;
269
}
270
271
ret = gpgme_data_read(dh_plain, *plaintext + plaintext_length,
272
BUFFER_SIZE);
273
/* Print the data, if any */
274
if (ret == 0){
275
/* EOF */
276
break;
277
}
278
if(ret < 0){
279
perror("gpgme_data_read");
280
plaintext_length = -1;
281
goto decrypt_end;
282
}
283
plaintext_length += ret;
284
}
285
286
if(debug){
287
fprintf(stderr, "Decrypted password is: ");
288
for(ssize_t i = 0; i < plaintext_length; i++){
289
fprintf(stderr, "%02hhX ", (*plaintext)[i]);
290
}
291
fprintf(stderr, "\n");
292
}
293
294
decrypt_end:
295
296
/* Delete the GPGME cryptotext data buffer */
297
gpgme_data_release(dh_crypto);
298
299
/* Delete the GPGME plaintext data buffer */
300
gpgme_data_release(dh_plain);
301
return plaintext_length;
302
}
303
304
static const char * safer_gnutls_strerror (int value) {
305
const char *ret = gnutls_strerror (value); /* Spurious warning */
306
if (ret == NULL)
307
ret = "(unknown)";
308
return ret;
309
}
310
311
/* GnuTLS log function callback */
312
static void debuggnutls(__attribute__((unused)) int level,
313
const char* string){
314
fprintf(stderr, "GnuTLS: %s", string);
315
}
316
317
static int init_gnutls_global(mandos_context *mc,
318
const char *pubkeyfilename,
319
const char *seckeyfilename){
320
int ret;
321
322
if(debug){
323
fprintf(stderr, "Initializing GnuTLS\n");
324
}
325
326
ret = gnutls_global_init();
327
if (ret != GNUTLS_E_SUCCESS) {
328
fprintf (stderr, "GnuTLS global_init: %s\n",
329
safer_gnutls_strerror(ret));
330
return -1;
331
}
332
333
if (debug){
334
/* "Use a log level over 10 to enable all debugging options."
335
* - GnuTLS manual
336
*/
337
gnutls_global_set_log_level(11);
338
gnutls_global_set_log_function(debuggnutls);
339
}
340
341
/* OpenPGP credentials */
342
gnutls_certificate_allocate_credentials(&mc->cred);
343
if (ret != GNUTLS_E_SUCCESS){
344
fprintf (stderr, "GnuTLS memory error: %s\n", /* Spurious
345
warning */
346
safer_gnutls_strerror(ret));
347
gnutls_global_deinit ();
348
return -1;
349
}
350
351
if(debug){
352
fprintf(stderr, "Attempting to use OpenPGP certificate %s"
353
" and keyfile %s as GnuTLS credentials\n", pubkeyfilename,
354
seckeyfilename);
355
}
356
357
ret = gnutls_certificate_set_openpgp_key_file
358
(mc->cred, pubkeyfilename, seckeyfilename,
359
GNUTLS_OPENPGP_FMT_BASE64);
360
if (ret != GNUTLS_E_SUCCESS) {
361
fprintf(stderr,
362
"Error[%d] while reading the OpenPGP key pair ('%s',"
363
" '%s')\n", ret, pubkeyfilename, seckeyfilename);
364
fprintf(stdout, "The GnuTLS error is: %s\n",
365
safer_gnutls_strerror(ret));
366
goto globalfail;
367
}
368
369
/* GnuTLS server initialization */
370
ret = gnutls_dh_params_init(&mc->dh_params);
371
if (ret != GNUTLS_E_SUCCESS) {
372
fprintf (stderr, "Error in GnuTLS DH parameter initialization:"
373
" %s\n", safer_gnutls_strerror(ret));
374
goto globalfail;
375
}
376
ret = gnutls_dh_params_generate2(mc->dh_params, mc->dh_bits);
377
if (ret != GNUTLS_E_SUCCESS) {
378
fprintf (stderr, "Error in GnuTLS prime generation: %s\n",
379
safer_gnutls_strerror(ret));
380
goto globalfail;
381
}
382
383
gnutls_certificate_set_dh_params(mc->cred, mc->dh_params);
384
385
return 0;
386
387
globalfail:
388
389
gnutls_certificate_free_credentials(mc->cred);
390
gnutls_global_deinit();
391
return -1;
392
393
}
394
395
static int init_gnutls_session(mandos_context *mc,
396
gnutls_session_t *session){
397
int ret;
398
/* GnuTLS session creation */
399
ret = gnutls_init(session, GNUTLS_SERVER);
400
if (ret != GNUTLS_E_SUCCESS){
401
fprintf(stderr, "Error in GnuTLS session initialization: %s\n",
402
safer_gnutls_strerror(ret));
403
}
404
405
{
406
const char *err;
407
ret = gnutls_priority_set_direct(*session, mc->priority, &err);
408
if (ret != GNUTLS_E_SUCCESS) {
409
fprintf(stderr, "Syntax error at: %s\n", err);
410
fprintf(stderr, "GnuTLS error: %s\n",
411
safer_gnutls_strerror(ret));
412
gnutls_deinit (*session);
413
return -1;
414
}
415
}
416
417
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
418
mc->cred);
419
if (ret != GNUTLS_E_SUCCESS) {
420
fprintf(stderr, "Error setting GnuTLS credentials: %s\n",
421
safer_gnutls_strerror(ret));
422
gnutls_deinit (*session);
423
return -1;
424
}
425
426
/* ignore client certificate if any. */
427
gnutls_certificate_server_set_request (*session,
428
GNUTLS_CERT_IGNORE);
429
430
gnutls_dh_set_prime_bits (*session, mc->dh_bits);
431
432
return 0;
433
}
434
435
/* Avahi log function callback */
436
static void empty_log(__attribute__((unused)) AvahiLogLevel level,
437
__attribute__((unused)) const char *txt){}
438
439
/* Called when a Mandos server is found */
440
static int start_mandos_communication(const char *ip, uint16_t port,
441
AvahiIfIndex if_index,
442
mandos_context *mc){
443
int ret, tcp_sd;
444
union { struct sockaddr in; struct sockaddr_in6 in6; } to;
445
char *buffer = NULL;
446
char *decrypted_buffer;
447
size_t buffer_length = 0;
448
size_t buffer_capacity = 0;
449
ssize_t decrypted_buffer_size;
450
size_t written;
451
int retval = 0;
452
char interface[IF_NAMESIZE];
453
gnutls_session_t session;
454
455
ret = init_gnutls_session (mc, &session);
456
if (ret != 0){
457
return -1;
458
}
459
460
if(debug){
461
fprintf(stderr, "Setting up a tcp connection to %s, port %" PRIu16
462
"\n", ip, port);
463
}
464
465
tcp_sd = socket(PF_INET6, SOCK_STREAM, 0);
466
if(tcp_sd < 0) {
467
perror("socket");
468
return -1;
469
}
470
471
if(debug){
472
if(if_indextoname((unsigned int)if_index, interface) == NULL){
473
perror("if_indextoname");
474
return -1;
475
}
476
fprintf(stderr, "Binding to interface %s\n", interface);
477
}
478
479
memset(&to, 0, sizeof(to));
480
to.in6.sin6_family = AF_INET6;
481
/* It would be nice to have a way to detect if we were passed an
482
IPv4 address here. Now we assume an IPv6 address. */
483
ret = inet_pton(AF_INET6, ip, &to.in6.sin6_addr);
484
if (ret < 0 ){
485
perror("inet_pton");
486
return -1;
487
}
488
if(ret == 0){
489
fprintf(stderr, "Bad address: %s\n", ip);
490
return -1;
491
}
492
to.in6.sin6_port = htons(port); /* Spurious warning */
493
494
to.in6.sin6_scope_id = (uint32_t)if_index;
495
496
if(debug){
497
fprintf(stderr, "Connection to: %s, port %" PRIu16 "\n", ip,
498
port);
499
char addrstr[INET6_ADDRSTRLEN] = "";
500
if(inet_ntop(to.in6.sin6_family, &(to.in6.sin6_addr), addrstr,
501
sizeof(addrstr)) == NULL){
502
perror("inet_ntop");
503
} else {
504
if(strcmp(addrstr, ip) != 0){
505
fprintf(stderr, "Canonical address form: %s\n", addrstr);
506
}
507
}
508
}
509
510
ret = connect(tcp_sd, &to.in, sizeof(to));
511
if (ret < 0){
512
perror("connect");
513
return -1;
514
}
515
516
const char *out = mandos_protocol_version;
517
written = 0;
518
while (true){
519
size_t out_size = strlen(out);
520
ret = TEMP_FAILURE_RETRY(write(tcp_sd, out + written,
521
out_size - written));
522
if (ret == -1){
523
perror("write");
524
retval = -1;
525
goto mandos_end;
526
}
527
written += (size_t)ret;
528
if(written < out_size){
529
continue;
530
} else {
531
if (out == mandos_protocol_version){
532
written = 0;
533
out = "\r\n";
534
} else {
535
break;
536
}
537
}
538
}
539
540
if(debug){
541
fprintf(stderr, "Establishing TLS session with %s\n", ip);
542
}
543
544
gnutls_transport_set_ptr (session, (gnutls_transport_ptr_t) tcp_sd);
545
546
do{
547
ret = gnutls_handshake (session);
548
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
549
550
if (ret != GNUTLS_E_SUCCESS){
551
if(debug){
552
fprintf(stderr, "*** GnuTLS Handshake failed ***\n");
553
gnutls_perror (ret);
554
}
555
retval = -1;
556
goto mandos_end;
557
}
558
559
/* Read OpenPGP packet that contains the wanted password */
560
561
if(debug){
562
fprintf(stderr, "Retrieving pgp encrypted password from %s\n",
563
ip);
564
}
565
566
while(true){
567
buffer_capacity = adjustbuffer(&buffer, buffer_length,
568
buffer_capacity);
569
if (buffer_capacity == 0){
570
perror("adjustbuffer");
571
retval = -1;
572
goto mandos_end;
573
}
574
575
ret = gnutls_record_recv(session, buffer+buffer_length,
576
BUFFER_SIZE);
577
if (ret == 0){
578
break;
579
}
580
if (ret < 0){
581
switch(ret){
582
case GNUTLS_E_INTERRUPTED:
583
case GNUTLS_E_AGAIN:
584
break;
585
case GNUTLS_E_REHANDSHAKE:
586
do{
587
ret = gnutls_handshake (session);
588
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
589
if (ret < 0){
590
fprintf(stderr, "*** GnuTLS Re-handshake failed ***\n");
591
gnutls_perror (ret);
592
retval = -1;
593
goto mandos_end;
594
}
595
break;
596
default:
597
fprintf(stderr, "Unknown error while reading data from"
598
" encrypted session with Mandos server\n");
599
retval = -1;
600
gnutls_bye (session, GNUTLS_SHUT_RDWR);
601
goto mandos_end;
602
}
603
} else {
604
buffer_length += (size_t) ret;
605
}
606
}
607
608
if(debug){
609
fprintf(stderr, "Closing TLS session\n");
610
}
611
612
gnutls_bye (session, GNUTLS_SHUT_RDWR);
613
614
if (buffer_length > 0){
615
decrypted_buffer_size = pgp_packet_decrypt(buffer,
616
buffer_length,
617
&decrypted_buffer,
618
keydir);
619
if (decrypted_buffer_size >= 0){
620
written = 0;
621
while(written < (size_t) decrypted_buffer_size){
622
ret = (int)fwrite (decrypted_buffer + written, 1,
623
(size_t)decrypted_buffer_size - written,
624
stdout);
625
if(ret == 0 and ferror(stdout)){
626
if(debug){
627
fprintf(stderr, "Error writing encrypted data: %s\n",
628
strerror(errno));
629
}
630
retval = -1;
631
break;
632
}
633
written += (size_t)ret;
634
}
635
free(decrypted_buffer);
636
} else {
637
retval = -1;
638
}
639
} else {
640
retval = -1;
641
}
642
643
/* Shutdown procedure */
644
645
mandos_end:
646
free(buffer);
647
close(tcp_sd);
648
gnutls_deinit (session);
649
return retval;
650
}
651
652
static void resolve_callback(AvahiSServiceResolver *r,
653
AvahiIfIndex interface,
654
AVAHI_GCC_UNUSED AvahiProtocol protocol,
655
AvahiResolverEvent event,
656
const char *name,
657
const char *type,
658
const char *domain,
659
const char *host_name,
660
const AvahiAddress *address,
661
uint16_t port,
662
AVAHI_GCC_UNUSED AvahiStringList *txt,
663
AVAHI_GCC_UNUSED AvahiLookupResultFlags
664
flags,
665
void* userdata) {
666
mandos_context *mc = userdata;
667
assert(r);
668
669
/* Called whenever a service has been resolved successfully or
670
timed out */
671
672
switch (event) {
673
default:
674
case AVAHI_RESOLVER_FAILURE:
675
fprintf(stderr, "(Avahi Resolver) Failed to resolve service '%s'"
676
" of type '%s' in domain '%s': %s\n", name, type, domain,
677
avahi_strerror(avahi_server_errno(mc->server)));
678
break;
679
680
case AVAHI_RESOLVER_FOUND:
681
{
682
char ip[AVAHI_ADDRESS_STR_MAX];
683
avahi_address_snprint(ip, sizeof(ip), address);
684
if(debug){
685
fprintf(stderr, "Mandos server \"%s\" found on %s (%s, %"
686
PRIu16 ") on port %d\n", name, host_name, ip,
687
interface, port);
688
}
689
int ret = start_mandos_communication(ip, port, interface, mc);
690
if (ret == 0){
691
avahi_simple_poll_quit(mc->simple_poll);
692
}
693
}
694
}
695
avahi_s_service_resolver_free(r);
696
}
697
698
static void browse_callback( AvahiSServiceBrowser *b,
699
AvahiIfIndex interface,
700
AvahiProtocol protocol,
701
AvahiBrowserEvent event,
702
const char *name,
703
const char *type,
704
const char *domain,
705
AVAHI_GCC_UNUSED AvahiLookupResultFlags
706
flags,
707
void* userdata) {
708
mandos_context *mc = userdata;
709
assert(b);
710
711
/* Called whenever a new services becomes available on the LAN or
712
is removed from the LAN */
713
714
switch (event) {
715
default:
716
case AVAHI_BROWSER_FAILURE:
717
718
fprintf(stderr, "(Avahi browser) %s\n",
719
avahi_strerror(avahi_server_errno(mc->server)));
720
avahi_simple_poll_quit(mc->simple_poll);
721
return;
722
723
case AVAHI_BROWSER_NEW:
724
/* We ignore the returned Avahi resolver object. In the callback
725
function we free it. If the Avahi server is terminated before
726
the callback function is called the Avahi server will free the
727
resolver for us. */
728
729
if (!(avahi_s_service_resolver_new(mc->server, interface,
730
protocol, name, type, domain,
731
AVAHI_PROTO_INET6, 0,
732
resolve_callback, mc)))
733
fprintf(stderr, "Avahi: Failed to resolve service '%s': %s\n",
734
name, avahi_strerror(avahi_server_errno(mc->server)));
735
break;
736
737
case AVAHI_BROWSER_REMOVE:
738
break;
739
740
case AVAHI_BROWSER_ALL_FOR_NOW:
741
case AVAHI_BROWSER_CACHE_EXHAUSTED:
742
if(debug){
743
fprintf(stderr, "No Mandos server found, still searching...\n");
744
}
745
break;
746
}
747
}
748
749
/* Combines file name and path and returns the malloced new
750
string. some sane checks could/should be added */
751
static char *combinepath(const char *first, const char *second){
752
char *tmp;
753
int ret = asprintf(&tmp, "%s/%s", first, second);
754
if(ret < 0){
755
return NULL;
756
}
757
return tmp;
758
}
759
760
761
int main(int argc, char *argv[]){
762
AvahiSServiceBrowser *sb = NULL;
763
int error;
764
int ret;
765
int exitcode = EXIT_SUCCESS;
766
const char *interface = "eth0";
767
struct ifreq network;
768
int sd;
769
uid_t uid;
770
gid_t gid;
771
char *connect_to = NULL;
772
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
773
char *pubkeyfilename = NULL;
774
char *seckeyfilename = NULL;
775
const char *pubkeyname = "pubkey.txt";
776
const char *seckeyname = "seckey.txt";
777
mandos_context mc = { .simple_poll = NULL, .server = NULL,
778
.dh_bits = 1024, .priority = "SECURE256"};
779
bool gnutls_initalized = false;
780
781
{
782
struct argp_option options[] = {
783
{ .name = "debug", .key = 128,
784
.doc = "Debug mode", .group = 3 },
785
{ .name = "connect", .key = 'c',
786
.arg = "IP",
787
.doc = "Connect directly to a sepcified mandos server",
788
.group = 1 },
789
{ .name = "interface", .key = 'i',
790
.arg = "INTERFACE",
791
.doc = "Interface that Avahi will conntect through",
792
.group = 1 },
793
{ .name = "keydir", .key = 'd',
794
.arg = "KEYDIR",
795
.doc = "Directory where the openpgp keyring is",
796
.group = 1 },
797
{ .name = "seckey", .key = 's',
798
.arg = "SECKEY",
799
.doc = "Secret openpgp key for gnutls authentication",
800
.group = 1 },
801
{ .name = "pubkey", .key = 'p',
802
.arg = "PUBKEY",
803
.doc = "Public openpgp key for gnutls authentication",
804
.group = 2 },
805
{ .name = "dh-bits", .key = 129,
806
.arg = "BITS",
807
.doc = "dh-bits to use in gnutls communication",
808
.group = 2 },
809
{ .name = "priority", .key = 130,
810
.arg = "PRIORITY",
811
.doc = "GNUTLS priority", .group = 1 },
812
{ .name = NULL }
813
};
814
815
816
error_t parse_opt (int key, char *arg,
817
struct argp_state *state) {
818
/* Get the INPUT argument from `argp_parse', which we know is
819
a pointer to our plugin list pointer. */
820
switch (key) {
821
case 128:
822
debug = true;
823
break;
824
case 'c':
825
connect_to = arg;
826
break;
827
case 'i':
828
interface = arg;
829
break;
830
case 'd':
831
keydir = arg;
832
break;
833
case 's':
834
seckeyname = arg;
835
break;
836
case 'p':
837
pubkeyname = arg;
838
break;
839
case 129:
840
errno = 0;
841
mc.dh_bits = (unsigned int) strtol(arg, NULL, 10);
842
if (errno){
843
perror("strtol");
844
exit(EXIT_FAILURE);
845
}
846
break;
847
case 130:
848
mc.priority = arg;
849
break;
850
case ARGP_KEY_ARG:
851
argp_usage (state);
852
case ARGP_KEY_END:
853
break;
854
default:
855
return ARGP_ERR_UNKNOWN;
856
}
857
return 0;
858
}
859
860
struct argp argp = { .options = options, .parser = parse_opt,
861
.args_doc = "",
862
.doc = "Mandos client -- Get and decrypt"
863
" passwords from mandos server" };
864
ret = argp_parse (&argp, argc, argv, 0, 0, NULL);
865
if (ret == ARGP_ERR_UNKNOWN){
866
fprintf(stderr, "Unknown error while parsing arguments\n");
867
exitcode = EXIT_FAILURE;
868
goto end;
869
}
870
}
871
872
pubkeyfilename = combinepath(keydir, pubkeyname);
873
if (pubkeyfilename == NULL){
874
perror("combinepath");
875
exitcode = EXIT_FAILURE;
876
goto end;
877
}
878
879
seckeyfilename = combinepath(keydir, seckeyname);
880
if (seckeyfilename == NULL){
881
perror("combinepath");
882
exitcode = EXIT_FAILURE;
883
goto end;
884
}
885
886
ret = init_gnutls_global(&mc, pubkeyfilename, seckeyfilename);
887
if (ret == -1){
888
fprintf(stderr, "init_gnutls_global failed\n");
889
exitcode = EXIT_FAILURE;
890
goto end;
891
} else {
892
gnutls_initalized = true;
893
}
894
895
/* If the interface is down, bring it up */
896
{
897
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
898
if(sd < 0) {
899
perror("socket");
900
exitcode = EXIT_FAILURE;
901
goto end;
902
}
903
strcpy(network.ifr_name, interface);
904
ret = ioctl(sd, SIOCGIFFLAGS, &network);
905
if(ret == -1){
906
perror("ioctl SIOCGIFFLAGS");
907
exitcode = EXIT_FAILURE;
908
goto end;
909
}
910
if((network.ifr_flags & IFF_UP) == 0){
911
network.ifr_flags |= IFF_UP;
912
ret = ioctl(sd, SIOCSIFFLAGS, &network);
913
if(ret == -1){
914
perror("ioctl SIOCSIFFLAGS");
915
exitcode = EXIT_FAILURE;
916
goto end;
917
}
918
}
919
close(sd);
920
}
921
922
uid = getuid();
923
gid = getgid();
924
925
ret = setuid(uid);
926
if (ret == -1){
927
perror("setuid");
928
}
929
930
setgid(gid);
931
if (ret == -1){
932
perror("setgid");
933
}
934
935
if_index = (AvahiIfIndex) if_nametoindex(interface);
936
if(if_index == 0){
937
fprintf(stderr, "No such interface: \"%s\"\n", interface);
938
exit(EXIT_FAILURE);
939
}
940
941
if(connect_to != NULL){
942
/* Connect directly, do not use Zeroconf */
943
/* (Mainly meant for debugging) */
944
char *address = strrchr(connect_to, ':');
945
if(address == NULL){
946
fprintf(stderr, "No colon in address\n");
947
exitcode = EXIT_FAILURE;
948
goto end;
949
}
950
errno = 0;
951
uint16_t port = (uint16_t) strtol(address+1, NULL, 10);
952
if(errno){
953
perror("Bad port number");
954
exitcode = EXIT_FAILURE;
955
goto end;
956
}
957
*address = '\0';
958
address = connect_to;
959
ret = start_mandos_communication(address, port, if_index, &mc);
960
if(ret < 0){
961
exitcode = EXIT_FAILURE;
962
} else {
963
exitcode = EXIT_SUCCESS;
964
}
965
goto end;
966
}
967
968
if (not debug){
969
avahi_set_log_function(empty_log);
970
}
971
972
/* Initialize the pseudo-RNG for Avahi */
973
srand((unsigned int) time(NULL));
974
975
/* Allocate main Avahi loop object */
976
mc.simple_poll = avahi_simple_poll_new();
977
if (mc.simple_poll == NULL) {
978
fprintf(stderr, "Avahi: Failed to create simple poll"
979
" object.\n");
980
exitcode = EXIT_FAILURE;
981
goto end;
982
}
983
984
{
985
AvahiServerConfig config;
986
/* Do not publish any local Zeroconf records */
987
avahi_server_config_init(&config);
988
config.publish_hinfo = 0;
989
config.publish_addresses = 0;
990
config.publish_workstation = 0;
991
config.publish_domain = 0;
992
993
/* Allocate a new server */
994
mc.server = avahi_server_new(avahi_simple_poll_get
995
(mc.simple_poll), &config, NULL,
996
NULL, &error);
997
998
/* Free the Avahi configuration data */
999
avahi_server_config_free(&config);
1000
}
1001
1002
/* Check if creating the Avahi server object succeeded */
1003
if (mc.server == NULL) {
1004
fprintf(stderr, "Failed to create Avahi server: %s\n",
1005
avahi_strerror(error));
1006
exitcode = EXIT_FAILURE;
1007
goto end;
1008
}
1009
1010
/* Create the Avahi service browser */
1011
sb = avahi_s_service_browser_new(mc.server, if_index,
1012
AVAHI_PROTO_INET6,
1013
"_mandos._tcp", NULL, 0,
1014
browse_callback, &mc);
1015
if (sb == NULL) {
1016
fprintf(stderr, "Failed to create service browser: %s\n",
1017
avahi_strerror(avahi_server_errno(mc.server)));
1018
exitcode = EXIT_FAILURE;
1019
goto end;
1020
}
1021
1022
/* Run the main loop */
1023
1024
if (debug){
1025
fprintf(stderr, "Starting Avahi loop search\n");
1026
}
1027
1028
avahi_simple_poll_loop(mc.simple_poll);
1029
1030
end:
1031
1032
if (debug){
1033
fprintf(stderr, "%s exiting\n", argv[0]);
1034
}
1035
1036
/* Cleanup things */
1037
if (sb != NULL)
1038
avahi_s_service_browser_free(sb);
1039
1040
if (mc.server != NULL)
1041
avahi_server_free(mc.server);
1042
1043
if (mc.simple_poll != NULL)
1044
avahi_simple_poll_free(mc.simple_poll);
1045
free(pubkeyfilename);
1046
free(seckeyfilename);
1047
1048
if (gnutls_initalized){
1049
gnutls_certificate_free_credentials(mc.cred);
1050
gnutls_global_deinit ();
1051
}
1052
1053
return exitcode;
1054
}
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0