(root)/mandos/release
» Revision
237.2.26
(compared to revision 237.2.128)
: plugins.d/mandos-client.c
To get this branch, use:
bzr branch
http://bzr.recompile.se/loggerhead/mandos/release
« back to all changes in this revision
Viewing changes to plugins.d/mandos-client.c
- browse files at revision 237.2.26
- compare with another revision
- download diff
- download tarball
- view history from revision 237.2.26
- Committer: Teddy Hogeborn
- Date: 2009-01-12 22:02:33 UTC
- mto: (24.1.123 mandos) (237.4.2 mandos-pipe-ipc) (299.1.1 release) (300.1.1 release) (301.1.1 release)
- mto: This revision was merged to the branch mainline in revision 245.
- Revision ID: teddy@fukt.bsnet.se-20090112220233-lawxo4uvyzb38u1f
* README (The Plugin System): Removed redundant text about options and
files for the plugins, this is now
documented in the manuals for the
plugins.
* plugins.d/mandos-client.c (main): Remove comment which was copied
from another program by mistake.
Use "sscanf" instead of "strtol"
to parse numbers; this uses the
correct type instead of casting.
Don't report errors when removing
temporary directory if directory
is already gone.
files for the plugins, this is now
documented in the manuals for the
plugins.
* plugins.d/mandos-client.c (main): Remove comment which was copied
from another program by mistake.
Use "sscanf" instead of "strtol"
to parse numbers; this uses the
correct type instead of casting.
Don't report errors when removing
temporary directory if directory
is already gone.
- files removed:
- debian/watch
- files renamed:
- mandos-ctl => mandos-list
- files modified:
- INSTALL
added
removed
plugins.d/mandos-client.c
30
30
*/
31
31
32
32
/* Needed by GPGME, specifically gpgme_data_seek() */
33
#ifndef _LARGEFILE_SOURCE
34
33
#define _LARGEFILE_SOURCE
35
#endif
36
#ifndef _FILE_OFFSET_BITS
37
34
#define _FILE_OFFSET_BITS 64
38
#endif
39
35
40
36
#define _GNU_SOURCE /* TEMP_FAILURE_RETRY(), asprintf() */
41
37
42
38
#include <stdio.h> /* fprintf(), stderr, fwrite(),
43
stdout, ferror(), remove() */
39
stdout, ferror(), sscanf */
44
40
#include <stdint.h> /* uint16_t, uint32_t */
45
41
#include <stddef.h> /* NULL, size_t, ssize_t */
46
42
#include <stdlib.h> /* free(), EXIT_SUCCESS, EXIT_FAILURE,
47
srand(), strtof() */
48
#include <stdbool.h> /* bool, false, true */
43
srand() */
44
#include <stdbool.h> /* bool, true */
49
45
#include <string.h> /* memset(), strcmp(), strlen(),
50
46
strerror(), asprintf(), strcpy() */
51
#include <sys/ioctl.h> /* ioctl */
47
#include <sys/ioctl.h> /* ioctl */
52
48
#include <sys/types.h> /* socket(), inet_pton(), sockaddr,
53
49
sockaddr_in6, PF_INET6,
54
SOCK_STREAM, uid_t, gid_t, open(),
55
opendir(), DIR */
50
SOCK_STREAM, INET6_ADDRSTRLEN,
51
uid_t, gid_t, open(), opendir(), DIR */
56
52
#include <sys/stat.h> /* open() */
57
53
#include <sys/socket.h> /* socket(), struct sockaddr_in6,
58
inet_pton(), connect() */
54
struct in6_addr, inet_pton(),
55
connect() */
59
56
#include <fcntl.h> /* open() */
60
#include <dirent.h> /* opendir(), struct dirent, readdir()
61
*/
62
#include <inttypes.h> /* PRIu16, PRIdMAX, intmax_t,
63
strtoimax() */
57
#include <dirent.h> /* opendir(), struct dirent, readdir() */
58
#include <inttypes.h> /* PRIu16, SCNu16 */
64
59
#include <assert.h> /* assert() */
65
60
#include <errno.h> /* perror(), errno */
66
#include <time.h> /* nanosleep(), time() */
61
#include <time.h> /* time() */
67
62
#include <net/if.h> /* ioctl, ifreq, SIOCGIFFLAGS, IFF_UP,
68
63
SIOCSIFFLAGS, if_indextoname(),
69
64
if_nametoindex(), IF_NAMESIZE */
70
#include <netinet/in.h> /* IN6_IS_ADDR_LINKLOCAL,
71
INET_ADDRSTRLEN, INET6_ADDRSTRLEN
72
*/
65
#include <netinet/in.h>
73
66
#include <unistd.h> /* close(), SEEK_SET, off_t, write(),
74
getuid(), getgid(), seteuid(),
67
getuid(), getgid(), setuid(),
75
68
setgid() */
76
69
#include <arpa/inet.h> /* inet_pton(), htons */
77
#include <iso646.h> /* not, or, and */
70
#include <iso646.h> /* not, and, or */
78
71
#include <argp.h> /* struct argp_option, error_t, struct
79
72
argp_state, struct argp,
80
73
argp_parse(), ARGP_KEY_ARG,
81
74
ARGP_KEY_END, ARGP_ERR_UNKNOWN */
82
#include <signal.h> /* sigemptyset(), sigaddset(),
83
sigaction(), SIGTERM, sig_atomic_t,
84
raise() */
85
86
#ifdef __linux__
87
#include <sys/klog.h> /* klogctl() */
88
#endif /* __linux__ */
89
75
90
76
/* Avahi */
91
77
/* All Avahi types, constants and functions
104
90
gnutls_*
105
91
init_gnutls_session(),
106
92
GNUTLS_* */
107
#include <gnutls/openpgp.h>
108
/* gnutls_certificate_set_openpgp_key_file(),
93
#include <gnutls/openpgp.h> /* gnutls_certificate_set_openpgp_key_file(),
109
94
GNUTLS_OPENPGP_FMT_BASE64 */
110
95
111
96
/* GPGME */
137
122
gpgme_ctx_t ctx;
138
123
} mandos_context;
139
124
140
/* global context so signal handler can reach it*/
141
mandos_context mc = { .simple_poll = NULL, .server = NULL,
142
.dh_bits = 1024, .priority = "SECURE256"
143
":!CTYPE-X.509:+CTYPE-OPENPGP" };
144
145
125
/*
146
* Make additional room in "buffer" for at least BUFFER_SIZE more
147
* bytes. "buffer_capacity" is how much is currently allocated,
126
* Make room in "buffer" for at least BUFFER_SIZE additional bytes.
127
* "buffer_capacity" is how much is currently allocated,
148
128
* "buffer_length" is how much is already used.
149
129
*/
150
size_t incbuffer(char **buffer, size_t buffer_length,
130
size_t adjustbuffer(char **buffer, size_t buffer_length,
151
131
size_t buffer_capacity){
152
if(buffer_length + BUFFER_SIZE > buffer_capacity){
132
if (buffer_length + BUFFER_SIZE > buffer_capacity){
153
133
*buffer = realloc(*buffer, buffer_capacity + BUFFER_SIZE);
154
if(buffer == NULL){
134
if (buffer == NULL){
155
135
return 0;
156
136
}
157
137
buffer_capacity += BUFFER_SIZE;
162
142
/*
163
143
* Initialize GPGME.
164
144
*/
165
static bool init_gpgme(const char *seckey,
145
static bool init_gpgme(mandos_context *mc, const char *seckey,
166
146
const char *pubkey, const char *tempdir){
147
int ret;
167
148
gpgme_error_t rc;
168
149
gpgme_engine_info_t engine_info;
169
150
170
151
171
152
/*
172
* Helper function to insert pub and seckey to the engine keyring.
153
* Helper function to insert pub and seckey to the enigne keyring.
173
154
*/
174
155
bool import_key(const char *filename){
175
int ret;
176
156
int fd;
177
157
gpgme_data_t pgp_data;
178
158
183
163
}
184
164
185
165
rc = gpgme_data_new_from_fd(&pgp_data, fd);
186
if(rc != GPG_ERR_NO_ERROR){
166
if (rc != GPG_ERR_NO_ERROR){
187
167
fprintf(stderr, "bad gpgme_data_new_from_fd: %s: %s\n",
188
168
gpgme_strsource(rc), gpgme_strerror(rc));
189
169
return false;
190
170
}
191
171
192
rc = gpgme_op_import(mc.ctx, pgp_data);
193
if(rc != GPG_ERR_NO_ERROR){
172
rc = gpgme_op_import(mc->ctx, pgp_data);
173
if (rc != GPG_ERR_NO_ERROR){
194
174
fprintf(stderr, "bad gpgme_op_import: %s: %s\n",
195
175
gpgme_strsource(rc), gpgme_strerror(rc));
196
176
return false;
204
184
return true;
205
185
}
206
186
207
if(debug){
208
fprintf(stderr, "Initializing GPGME\n");
187
if (debug){
188
fprintf(stderr, "Initialize gpgme\n");
209
189
}
210
190
211
191
/* Init GPGME */
212
192
gpgme_check_version(NULL);
213
193
rc = gpgme_engine_check_version(GPGME_PROTOCOL_OpenPGP);
214
if(rc != GPG_ERR_NO_ERROR){
194
if (rc != GPG_ERR_NO_ERROR){
215
195
fprintf(stderr, "bad gpgme_engine_check_version: %s: %s\n",
216
196
gpgme_strsource(rc), gpgme_strerror(rc));
217
197
return false;
218
198
}
219
199
220
200
/* Set GPGME home directory for the OpenPGP engine only */
221
rc = gpgme_get_engine_info(&engine_info);
222
if(rc != GPG_ERR_NO_ERROR){
201
rc = gpgme_get_engine_info (&engine_info);
202
if (rc != GPG_ERR_NO_ERROR){
223
203
fprintf(stderr, "bad gpgme_get_engine_info: %s: %s\n",
224
204
gpgme_strsource(rc), gpgme_strerror(rc));
225
205
return false;
238
218
}
239
219
240
220
/* Create new GPGME "context" */
241
rc = gpgme_new(&(mc.ctx));
242
if(rc != GPG_ERR_NO_ERROR){
221
rc = gpgme_new(&(mc->ctx));
222
if (rc != GPG_ERR_NO_ERROR){
243
223
fprintf(stderr, "bad gpgme_new: %s: %s\n",
244
224
gpgme_strsource(rc), gpgme_strerror(rc));
245
225
return false;
246
226
}
247
227
248
if(not import_key(pubkey) or not import_key(seckey)){
228
if (not import_key(pubkey) or not import_key(seckey)){
249
229
return false;
250
230
}
251
231
252
return true;
232
return true;
253
233
}
254
234
255
235
/*
256
236
* Decrypt OpenPGP data.
257
237
* Returns -1 on error
258
238
*/
259
static ssize_t pgp_packet_decrypt(const char *cryptotext,
260
size_t crypto_size,
261
char **plaintext){
239
static ssize_t pgp_packet_decrypt (const mandos_context *mc,
240
const char *cryptotext,
241
size_t crypto_size,
242
char **plaintext){
262
243
gpgme_data_t dh_crypto, dh_plain;
263
244
gpgme_error_t rc;
264
245
ssize_t ret;
265
246
size_t plaintext_capacity = 0;
266
247
ssize_t plaintext_length = 0;
267
248
268
if(debug){
249
if (debug){
269
250
fprintf(stderr, "Trying to decrypt OpenPGP data\n");
270
251
}
271
252
272
253
/* Create new GPGME data buffer from memory cryptotext */
273
254
rc = gpgme_data_new_from_mem(&dh_crypto, cryptotext, crypto_size,
274
255
0);
275
if(rc != GPG_ERR_NO_ERROR){
256
if (rc != GPG_ERR_NO_ERROR){
276
257
fprintf(stderr, "bad gpgme_data_new_from_mem: %s: %s\n",
277
258
gpgme_strsource(rc), gpgme_strerror(rc));
278
259
return -1;
280
261
281
262
/* Create new empty GPGME data buffer for the plaintext */
282
263
rc = gpgme_data_new(&dh_plain);
283
if(rc != GPG_ERR_NO_ERROR){
264
if (rc != GPG_ERR_NO_ERROR){
284
265
fprintf(stderr, "bad gpgme_data_new: %s: %s\n",
285
266
gpgme_strsource(rc), gpgme_strerror(rc));
286
267
gpgme_data_release(dh_crypto);
289
270
290
271
/* Decrypt data from the cryptotext data buffer to the plaintext
291
272
data buffer */
292
rc = gpgme_op_decrypt(mc.ctx, dh_crypto, dh_plain);
293
if(rc != GPG_ERR_NO_ERROR){
273
rc = gpgme_op_decrypt(mc->ctx, dh_crypto, dh_plain);
274
if (rc != GPG_ERR_NO_ERROR){
294
275
fprintf(stderr, "bad gpgme_op_decrypt: %s: %s\n",
295
276
gpgme_strsource(rc), gpgme_strerror(rc));
296
277
plaintext_length = -1;
297
if(debug){
278
if (debug){
298
279
gpgme_decrypt_result_t result;
299
result = gpgme_op_decrypt_result(mc.ctx);
300
if(result == NULL){
280
result = gpgme_op_decrypt_result(mc->ctx);
281
if (result == NULL){
301
282
fprintf(stderr, "gpgme_op_decrypt_result failed\n");
302
283
} else {
303
284
fprintf(stderr, "Unsupported algorithm: %s\n",
309
290
}
310
291
gpgme_recipient_t recipient;
311
292
recipient = result->recipients;
312
while(recipient != NULL){
313
fprintf(stderr, "Public key algorithm: %s\n",
314
gpgme_pubkey_algo_name(recipient->pubkey_algo));
315
fprintf(stderr, "Key ID: %s\n", recipient->keyid);
316
fprintf(stderr, "Secret key available: %s\n",
317
recipient->status == GPG_ERR_NO_SECKEY
318
? "No" : "Yes");
319
recipient = recipient->next;
293
if(recipient){
294
while(recipient != NULL){
295
fprintf(stderr, "Public key algorithm: %s\n",
296
gpgme_pubkey_algo_name(recipient->pubkey_algo));
297
fprintf(stderr, "Key ID: %s\n", recipient->keyid);
298
fprintf(stderr, "Secret key available: %s\n",
299
recipient->status == GPG_ERR_NO_SECKEY
300
? "No" : "Yes");
301
recipient = recipient->next;
302
}
320
303
}
321
304
}
322
305
}
328
311
}
329
312
330
313
/* Seek back to the beginning of the GPGME plaintext data buffer */
331
if(gpgme_data_seek(dh_plain, (off_t)0, SEEK_SET) == -1){
314
if (gpgme_data_seek(dh_plain, (off_t) 0, SEEK_SET) == -1){
332
315
perror("gpgme_data_seek");
333
316
plaintext_length = -1;
334
317
goto decrypt_end;
336
319
337
320
*plaintext = NULL;
338
321
while(true){
339
plaintext_capacity = incbuffer(plaintext,
322
plaintext_capacity = adjustbuffer(plaintext,
340
323
(size_t)plaintext_length,
341
324
plaintext_capacity);
342
if(plaintext_capacity == 0){
343
perror("incbuffer");
325
if (plaintext_capacity == 0){
326
perror("adjustbuffer");
344
327
plaintext_length = -1;
345
328
goto decrypt_end;
346
329
}
348
331
ret = gpgme_data_read(dh_plain, *plaintext + plaintext_length,
349
332
BUFFER_SIZE);
350
333
/* Print the data, if any */
351
if(ret == 0){
334
if (ret == 0){
352
335
/* EOF */
353
336
break;
354
337
}
378
361
return plaintext_length;
379
362
}
380
363
381
static const char * safer_gnutls_strerror(int value){
382
const char *ret = gnutls_strerror(value); /* Spurious warning from
383
-Wunreachable-code */
384
if(ret == NULL)
364
static const char * safer_gnutls_strerror (int value) {
365
const char *ret = gnutls_strerror (value); /* Spurious warning */
366
if (ret == NULL)
385
367
ret = "(unknown)";
386
368
return ret;
387
369
}
392
374
fprintf(stderr, "GnuTLS: %s", string);
393
375
}
394
376
395
static int init_gnutls_global(const char *pubkeyfilename,
377
static int init_gnutls_global(mandos_context *mc,
378
const char *pubkeyfilename,
396
379
const char *seckeyfilename){
397
380
int ret;
398
381
401
384
}
402
385
403
386
ret = gnutls_global_init();
404
if(ret != GNUTLS_E_SUCCESS){
405
fprintf(stderr, "GnuTLS global_init: %s\n",
406
safer_gnutls_strerror(ret));
387
if (ret != GNUTLS_E_SUCCESS) {
388
fprintf (stderr, "GnuTLS global_init: %s\n",
389
safer_gnutls_strerror(ret));
407
390
return -1;
408
391
}
409
392
410
if(debug){
393
if (debug){
411
394
/* "Use a log level over 10 to enable all debugging options."
412
395
* - GnuTLS manual
413
396
*/
416
399
}
417
400
418
401
/* OpenPGP credentials */
419
gnutls_certificate_allocate_credentials(&mc.cred);
420
if(ret != GNUTLS_E_SUCCESS){
421
fprintf(stderr, "GnuTLS memory error: %s\n", /* Spurious warning
422
from
423
-Wunreachable-code
424
*/
425
safer_gnutls_strerror(ret));
426
gnutls_global_deinit();
402
gnutls_certificate_allocate_credentials(&mc->cred);
403
if (ret != GNUTLS_E_SUCCESS){
404
fprintf (stderr, "GnuTLS memory error: %s\n", /* Spurious
405
warning */
406
safer_gnutls_strerror(ret));
407
gnutls_global_deinit ();
427
408
return -1;
428
409
}
429
410
434
415
}
435
416
436
417
ret = gnutls_certificate_set_openpgp_key_file
437
(mc.cred, pubkeyfilename, seckeyfilename,
418
(mc->cred, pubkeyfilename, seckeyfilename,
438
419
GNUTLS_OPENPGP_FMT_BASE64);
439
if(ret != GNUTLS_E_SUCCESS){
420
if (ret != GNUTLS_E_SUCCESS) {
440
421
fprintf(stderr,
441
422
"Error[%d] while reading the OpenPGP key pair ('%s',"
442
423
" '%s')\n", ret, pubkeyfilename, seckeyfilename);
446
427
}
447
428
448
429
/* GnuTLS server initialization */
449
ret = gnutls_dh_params_init(&mc.dh_params);
450
if(ret != GNUTLS_E_SUCCESS){
451
fprintf(stderr, "Error in GnuTLS DH parameter initialization:"
452
" %s\n", safer_gnutls_strerror(ret));
430
ret = gnutls_dh_params_init(&mc->dh_params);
431
if (ret != GNUTLS_E_SUCCESS) {
432
fprintf (stderr, "Error in GnuTLS DH parameter initialization:"
433
" %s\n", safer_gnutls_strerror(ret));
453
434
goto globalfail;
454
435
}
455
ret = gnutls_dh_params_generate2(mc.dh_params, mc.dh_bits);
456
if(ret != GNUTLS_E_SUCCESS){
457
fprintf(stderr, "Error in GnuTLS prime generation: %s\n",
458
safer_gnutls_strerror(ret));
436
ret = gnutls_dh_params_generate2(mc->dh_params, mc->dh_bits);
437
if (ret != GNUTLS_E_SUCCESS) {
438
fprintf (stderr, "Error in GnuTLS prime generation: %s\n",
439
safer_gnutls_strerror(ret));
459
440
goto globalfail;
460
441
}
461
442
462
gnutls_certificate_set_dh_params(mc.cred, mc.dh_params);
443
gnutls_certificate_set_dh_params(mc->cred, mc->dh_params);
463
444
464
445
return 0;
465
446
466
447
globalfail:
467
448
468
gnutls_certificate_free_credentials(mc.cred);
449
gnutls_certificate_free_credentials(mc->cred);
469
450
gnutls_global_deinit();
470
gnutls_dh_params_deinit(mc.dh_params);
451
gnutls_dh_params_deinit(mc->dh_params);
471
452
return -1;
472
453
}
473
454
474
static int init_gnutls_session(gnutls_session_t *session){
455
static int init_gnutls_session(mandos_context *mc,
456
gnutls_session_t *session){
475
457
int ret;
476
458
/* GnuTLS session creation */
477
459
ret = gnutls_init(session, GNUTLS_SERVER);
478
if(ret != GNUTLS_E_SUCCESS){
460
if (ret != GNUTLS_E_SUCCESS){
479
461
fprintf(stderr, "Error in GnuTLS session initialization: %s\n",
480
462
safer_gnutls_strerror(ret));
481
463
}
482
464
483
465
{
484
466
const char *err;
485
ret = gnutls_priority_set_direct(*session, mc.priority, &err);
486
if(ret != GNUTLS_E_SUCCESS){
467
ret = gnutls_priority_set_direct(*session, mc->priority, &err);
468
if (ret != GNUTLS_E_SUCCESS) {
487
469
fprintf(stderr, "Syntax error at: %s\n", err);
488
470
fprintf(stderr, "GnuTLS error: %s\n",
489
471
safer_gnutls_strerror(ret));
490
gnutls_deinit(*session);
472
gnutls_deinit (*session);
491
473
return -1;
492
474
}
493
475
}
494
476
495
477
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
496
mc.cred);
497
if(ret != GNUTLS_E_SUCCESS){
478
mc->cred);
479
if (ret != GNUTLS_E_SUCCESS) {
498
480
fprintf(stderr, "Error setting GnuTLS credentials: %s\n",
499
481
safer_gnutls_strerror(ret));
500
gnutls_deinit(*session);
482
gnutls_deinit (*session);
501
483
return -1;
502
484
}
503
485
504
486
/* ignore client certificate if any. */
505
gnutls_certificate_server_set_request(*session,
506
GNUTLS_CERT_IGNORE);
487
gnutls_certificate_server_set_request (*session,
488
GNUTLS_CERT_IGNORE);
507
489
508
gnutls_dh_set_prime_bits(*session, mc.dh_bits);
490
gnutls_dh_set_prime_bits (*session, mc->dh_bits);
509
491
510
492
return 0;
511
493
}
514
496
static void empty_log(__attribute__((unused)) AvahiLogLevel level,
515
497
__attribute__((unused)) const char *txt){}
516
498
517
sig_atomic_t quit_now = 0;
518
int signal_received = 0;
519
520
499
/* Called when a Mandos server is found */
521
500
static int start_mandos_communication(const char *ip, uint16_t port,
522
501
AvahiIfIndex if_index,
523
int af){
524
int ret, tcp_sd = -1;
502
mandos_context *mc){
503
int ret, tcp_sd;
525
504
ssize_t sret;
526
union {
527
struct sockaddr_in in;
528
struct sockaddr_in6 in6;
529
} to;
505
union { struct sockaddr in; struct sockaddr_in6 in6; } to;
530
506
char *buffer = NULL;
531
507
char *decrypted_buffer;
532
508
size_t buffer_length = 0;
533
509
size_t buffer_capacity = 0;
510
ssize_t decrypted_buffer_size;
534
511
size_t written;
535
512
int retval = 0;
513
char interface[IF_NAMESIZE];
536
514
gnutls_session_t session;
537
int pf; /* Protocol family */
538
539
if(quit_now){
540
return -1;
541
}
542
543
switch(af){
544
case AF_INET6:
545
pf = PF_INET6;
546
break;
547
case AF_INET:
548
pf = PF_INET;
549
break;
550
default:
551
fprintf(stderr, "Bad address family: %d\n", af);
552
return -1;
553
}
554
555
ret = init_gnutls_session(&session);
556
if(ret != 0){
515
516
ret = init_gnutls_session (mc, &session);
517
if (ret != 0){
557
518
return -1;
558
519
}
559
520
560
521
if(debug){
561
fprintf(stderr, "Setting up a TCP connection to %s, port %" PRIu16
522
fprintf(stderr, "Setting up a tcp connection to %s, port %" PRIu16
562
523
"\n", ip, port);
563
524
}
564
525
565
tcp_sd = socket(pf, SOCK_STREAM, 0);
566
if(tcp_sd < 0){
526
tcp_sd = socket(PF_INET6, SOCK_STREAM, 0);
527
if(tcp_sd < 0) {
567
528
perror("socket");
568
retval = -1;
569
goto mandos_end;
529
return -1;
570
530
}
571
531
572
if(quit_now){
573
goto mandos_end;
532
if(debug){
533
if(if_indextoname((unsigned int)if_index, interface) == NULL){
534
perror("if_indextoname");
535
return -1;
536
}
537
fprintf(stderr, "Binding to interface %s\n", interface);
574
538
}
575
539
576
540
memset(&to, 0, sizeof(to));
577
if(af == AF_INET6){
578
to.in6.sin6_family = (sa_family_t)af;
579
ret = inet_pton(af, ip, &to.in6.sin6_addr);
580
} else { /* IPv4 */
581
to.in.sin_family = (sa_family_t)af;
582
ret = inet_pton(af, ip, &to.in.sin_addr);
583
}
584
if(ret < 0 ){
541
to.in6.sin6_family = AF_INET6;
542
/* It would be nice to have a way to detect if we were passed an
543
IPv4 address here. Now we assume an IPv6 address. */
544
ret = inet_pton(AF_INET6, ip, &to.in6.sin6_addr);
545
if (ret < 0 ){
585
546
perror("inet_pton");
586
retval = -1;
587
goto mandos_end;
547
return -1;
588
548
}
589
549
if(ret == 0){
590
550
fprintf(stderr, "Bad address: %s\n", ip);
591
retval = -1;
592
goto mandos_end;
593
}
594
if(af == AF_INET6){
595
to.in6.sin6_port = htons(port); /* Spurious warnings from
596
-Wconversion and
597
-Wunreachable-code */
598
599
if(IN6_IS_ADDR_LINKLOCAL /* Spurious warnings from */
600
(&to.in6.sin6_addr)){ /* -Wstrict-aliasing=2 or lower and
601
-Wunreachable-code*/
602
if(if_index == AVAHI_IF_UNSPEC){
603
fprintf(stderr, "An IPv6 link-local address is incomplete"
604
" without a network interface\n");
605
retval = -1;
606
goto mandos_end;
607
}
608
/* Set the network interface number as scope */
609
to.in6.sin6_scope_id = (uint32_t)if_index;
610
}
611
} else {
612
to.in.sin_port = htons(port); /* Spurious warnings from
613
-Wconversion and
614
-Wunreachable-code */
615
}
551
return -1;
552
}
553
to.in6.sin6_port = htons(port); /* Spurious warning */
616
554
617
if(quit_now){
618
goto mandos_end;
619
}
555
to.in6.sin6_scope_id = (uint32_t)if_index;
620
556
621
557
if(debug){
622
if(af == AF_INET6 and if_index != AVAHI_IF_UNSPEC){
623
char interface[IF_NAMESIZE];
624
if(if_indextoname((unsigned int)if_index, interface) == NULL){
625
perror("if_indextoname");
626
} else {
627
fprintf(stderr, "Connection to: %s%%%s, port %" PRIu16 "\n",
628
ip, interface, port);
629
}
630
} else {
631
fprintf(stderr, "Connection to: %s, port %" PRIu16 "\n", ip,
632
port);
633
}
634
char addrstr[(INET_ADDRSTRLEN > INET6_ADDRSTRLEN) ?
635
INET_ADDRSTRLEN : INET6_ADDRSTRLEN] = "";
636
const char *pcret;
637
if(af == AF_INET6){
638
pcret = inet_ntop(af, &(to.in6.sin6_addr), addrstr,
639
sizeof(addrstr));
640
} else {
641
pcret = inet_ntop(af, &(to.in.sin_addr), addrstr,
642
sizeof(addrstr));
643
}
644
if(pcret == NULL){
558
fprintf(stderr, "Connection to: %s, port %" PRIu16 "\n", ip,
559
port);
560
char addrstr[INET6_ADDRSTRLEN] = "";
561
if(inet_ntop(to.in6.sin6_family, &(to.in6.sin6_addr), addrstr,
562
sizeof(addrstr)) == NULL){
645
563
perror("inet_ntop");
646
564
} else {
647
565
if(strcmp(addrstr, ip) != 0){
650
568
}
651
569
}
652
570
653
if(quit_now){
654
goto mandos_end;
655
}
656
657
if(af == AF_INET6){
658
ret = connect(tcp_sd, &to.in6, sizeof(to));
659
} else {
660
ret = connect(tcp_sd, &to.in, sizeof(to)); /* IPv4 */
661
}
662
if(ret < 0){
571
ret = connect(tcp_sd, &to.in, sizeof(to));
572
if (ret < 0){
663
573
perror("connect");
664
retval = -1;
665
goto mandos_end;
666
}
667
668
if(quit_now){
669
goto mandos_end;
574
return -1;
670
575
}
671
576
672
577
const char *out = mandos_protocol_version;
673
578
written = 0;
674
while(true){
579
while (true){
675
580
size_t out_size = strlen(out);
676
581
ret = (int)TEMP_FAILURE_RETRY(write(tcp_sd, out + written,
677
582
out_size - written));
678
if(ret == -1){
583
if (ret == -1){
679
584
perror("write");
680
585
retval = -1;
681
586
goto mandos_end;
684
589
if(written < out_size){
685
590
continue;
686
591
} else {
687
if(out == mandos_protocol_version){
592
if (out == mandos_protocol_version){
688
593
written = 0;
689
594
out = "\r\n";
690
595
} else {
691
596
break;
692
597
}
693
598
}
694
695
if(quit_now){
696
goto mandos_end;
697
}
698
599
}
699
600
700
601
if(debug){
701
602
fprintf(stderr, "Establishing TLS session with %s\n", ip);
702
603
}
703
604
704
if(quit_now){
705
goto mandos_end;
706
}
707
708
gnutls_transport_set_ptr(session, (gnutls_transport_ptr_t) tcp_sd);
709
710
if(quit_now){
711
goto mandos_end;
712
}
713
714
do {
715
ret = gnutls_handshake(session);
716
if(quit_now){
717
goto mandos_end;
718
}
605
gnutls_transport_set_ptr (session, (gnutls_transport_ptr_t) tcp_sd);
606
607
do{
608
ret = gnutls_handshake (session);
719
609
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
720
610
721
if(ret != GNUTLS_E_SUCCESS){
611
if (ret != GNUTLS_E_SUCCESS){
722
612
if(debug){
723
613
fprintf(stderr, "*** GnuTLS Handshake failed ***\n");
724
gnutls_perror(ret);
614
gnutls_perror (ret);
725
615
}
726
616
retval = -1;
727
617
goto mandos_end;
730
620
/* Read OpenPGP packet that contains the wanted password */
731
621
732
622
if(debug){
733
fprintf(stderr, "Retrieving OpenPGP encrypted password from %s\n",
623
fprintf(stderr, "Retrieving pgp encrypted password from %s\n",
734
624
ip);
735
625
}
736
626
737
627
while(true){
738
739
if(quit_now){
740
goto mandos_end;
741
}
742
743
buffer_capacity = incbuffer(&buffer, buffer_length,
628
buffer_capacity = adjustbuffer(&buffer, buffer_length,
744
629
buffer_capacity);
745
if(buffer_capacity == 0){
746
perror("incbuffer");
630
if (buffer_capacity == 0){
631
perror("adjustbuffer");
747
632
retval = -1;
748
633
goto mandos_end;
749
634
}
750
635
751
if(quit_now){
752
goto mandos_end;
753
}
754
755
636
sret = gnutls_record_recv(session, buffer+buffer_length,
756
637
BUFFER_SIZE);
757
if(sret == 0){
638
if (sret == 0){
758
639
break;
759
640
}
760
if(sret < 0){
641
if (sret < 0){
761
642
switch(sret){
762
643
case GNUTLS_E_INTERRUPTED:
763
644
case GNUTLS_E_AGAIN:
764
645
break;
765
646
case GNUTLS_E_REHANDSHAKE:
766
do {
767
ret = gnutls_handshake(session);
768
769
if(quit_now){
770
goto mandos_end;
771
}
647
do{
648
ret = gnutls_handshake (session);
772
649
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
773
if(ret < 0){
650
if (ret < 0){
774
651
fprintf(stderr, "*** GnuTLS Re-handshake failed ***\n");
775
gnutls_perror(ret);
652
gnutls_perror (ret);
776
653
retval = -1;
777
654
goto mandos_end;
778
655
}
781
658
fprintf(stderr, "Unknown error while reading data from"
782
659
" encrypted session with Mandos server\n");
783
660
retval = -1;
784
gnutls_bye(session, GNUTLS_SHUT_RDWR);
661
gnutls_bye (session, GNUTLS_SHUT_RDWR);
785
662
goto mandos_end;
786
663
}
787
664
} else {
793
670
fprintf(stderr, "Closing TLS session\n");
794
671
}
795
672
796
if(quit_now){
797
goto mandos_end;
798
}
799
800
gnutls_bye(session, GNUTLS_SHUT_RDWR);
801
802
if(quit_now){
803
goto mandos_end;
804
}
805
806
if(buffer_length > 0){
807
ssize_t decrypted_buffer_size;
808
decrypted_buffer_size = pgp_packet_decrypt(buffer,
673
gnutls_bye (session, GNUTLS_SHUT_RDWR);
674
675
if (buffer_length > 0){
676
decrypted_buffer_size = pgp_packet_decrypt(mc, buffer,
809
677
buffer_length,
810
678
&decrypted_buffer);
811
if(decrypted_buffer_size >= 0){
812
679
if (decrypted_buffer_size >= 0){
813
680
written = 0;
814
681
while(written < (size_t) decrypted_buffer_size){
815
if(quit_now){
816
goto mandos_end;
817
}
818
819
ret = (int)fwrite(decrypted_buffer + written, 1,
820
(size_t)decrypted_buffer_size - written,
821
stdout);
682
ret = (int)fwrite (decrypted_buffer + written, 1,
683
(size_t)decrypted_buffer_size - written,
684
stdout);
822
685
if(ret == 0 and ferror(stdout)){
823
686
if(debug){
824
687
fprintf(stderr, "Error writing encrypted data: %s\n",
841
704
842
705
mandos_end:
843
706
free(buffer);
844
if(tcp_sd >= 0){
845
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
846
}
707
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
847
708
if(ret == -1){
848
709
perror("close");
849
710
}
850
gnutls_deinit(session);
851
if(quit_now){
852
retval = -1;
853
}
711
gnutls_deinit (session);
854
712
return retval;
855
713
}
856
714
857
715
static void resolve_callback(AvahiSServiceResolver *r,
858
716
AvahiIfIndex interface,
859
AvahiProtocol proto,
717
AVAHI_GCC_UNUSED AvahiProtocol protocol,
860
718
AvahiResolverEvent event,
861
719
const char *name,
862
720
const char *type,
867
725
AVAHI_GCC_UNUSED AvahiStringList *txt,
868
726
AVAHI_GCC_UNUSED AvahiLookupResultFlags
869
727
flags,
870
AVAHI_GCC_UNUSED void* userdata){
728
void* userdata) {
729
mandos_context *mc = userdata;
871
730
assert(r);
872
731
873
732
/* Called whenever a service has been resolved successfully or
874
733
timed out */
875
734
876
if(quit_now){
877
return;
878
}
879
880
switch(event){
735
switch (event) {
881
736
default:
882
737
case AVAHI_RESOLVER_FAILURE:
883
738
fprintf(stderr, "(Avahi Resolver) Failed to resolve service '%s'"
884
739
" of type '%s' in domain '%s': %s\n", name, type, domain,
885
avahi_strerror(avahi_server_errno(mc.server)));
740
avahi_strerror(avahi_server_errno(mc->server)));
886
741
break;
887
742
888
743
case AVAHI_RESOLVER_FOUND:
891
746
avahi_address_snprint(ip, sizeof(ip), address);
892
747
if(debug){
893
748
fprintf(stderr, "Mandos server \"%s\" found on %s (%s, %"
894
PRIdMAX ") on port %" PRIu16 "\n", name, host_name,
895
ip, (intmax_t)interface, port);
749
PRIu16 ") on port %d\n", name, host_name, ip,
750
interface, port);
896
751
}
897
int ret = start_mandos_communication(ip, port, interface,
898
avahi_proto_to_af(proto));
899
if(ret == 0){
900
avahi_simple_poll_quit(mc.simple_poll);
752
int ret = start_mandos_communication(ip, port, interface, mc);
753
if (ret == 0){
754
avahi_simple_poll_quit(mc->simple_poll);
901
755
}
902
756
}
903
757
}
904
758
avahi_s_service_resolver_free(r);
905
759
}
906
760
907
static void browse_callback(AvahiSServiceBrowser *b,
908
AvahiIfIndex interface,
909
AvahiProtocol protocol,
910
AvahiBrowserEvent event,
911
const char *name,
912
const char *type,
913
const char *domain,
914
AVAHI_GCC_UNUSED AvahiLookupResultFlags
915
flags,
916
AVAHI_GCC_UNUSED void* userdata){
761
static void browse_callback( AvahiSServiceBrowser *b,
762
AvahiIfIndex interface,
763
AvahiProtocol protocol,
764
AvahiBrowserEvent event,
765
const char *name,
766
const char *type,
767
const char *domain,
768
AVAHI_GCC_UNUSED AvahiLookupResultFlags
769
flags,
770
void* userdata) {
771
mandos_context *mc = userdata;
917
772
assert(b);
918
773
919
774
/* Called whenever a new services becomes available on the LAN or
920
775
is removed from the LAN */
921
776
922
if(quit_now){
923
return;
924
}
925
926
switch(event){
777
switch (event) {
927
778
default:
928
779
case AVAHI_BROWSER_FAILURE:
929
780
930
781
fprintf(stderr, "(Avahi browser) %s\n",
931
avahi_strerror(avahi_server_errno(mc.server)));
932
avahi_simple_poll_quit(mc.simple_poll);
782
avahi_strerror(avahi_server_errno(mc->server)));
783
avahi_simple_poll_quit(mc->simple_poll);
933
784
return;
934
785
935
786
case AVAHI_BROWSER_NEW:
938
789
the callback function is called the Avahi server will free the
939
790
resolver for us. */
940
791
941
if(avahi_s_service_resolver_new(mc.server, interface, protocol,
942
name, type, domain, protocol, 0,
943
resolve_callback, NULL) == NULL)
792
if (!(avahi_s_service_resolver_new(mc->server, interface,
793
protocol, name, type, domain,
794
AVAHI_PROTO_INET6, 0,
795
resolve_callback, mc)))
944
796
fprintf(stderr, "Avahi: Failed to resolve service '%s': %s\n",
945
name, avahi_strerror(avahi_server_errno(mc.server)));
797
name, avahi_strerror(avahi_server_errno(mc->server)));
946
798
break;
947
799
948
800
case AVAHI_BROWSER_REMOVE:
957
809
}
958
810
}
959
811
960
/* stop main loop after sigterm has been called */
961
static void handle_sigterm(int sig){
962
if(quit_now){
963
return;
964
}
965
quit_now = 1;
966
signal_received = sig;
967
int old_errno = errno;
968
if(mc.simple_poll != NULL){
969
avahi_simple_poll_quit(mc.simple_poll);
970
}
971
errno = old_errno;
972
}
973
974
812
int main(int argc, char *argv[]){
975
AvahiSServiceBrowser *sb = NULL;
976
int error;
977
int ret;
978
intmax_t tmpmax;
979
char *tmp;
980
int exitcode = EXIT_SUCCESS;
981
const char *interface = "eth0";
982
struct ifreq network;
983
int sd = -1;
984
bool take_down_interface = false;
985
uid_t uid;
986
gid_t gid;
987
char *connect_to = NULL;
988
char tempdir[] = "/tmp/mandosXXXXXX";
989
bool tempdir_created = false;
990
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
991
const char *seckey = PATHDIR "/" SECKEY;
992
const char *pubkey = PATHDIR "/" PUBKEY;
993
994
bool gnutls_initialized = false;
995
bool gpgme_initialized = false;
996
float delay = 2.5f;
997
998
struct sigaction old_sigterm_action;
999
struct sigaction sigterm_action = { .sa_handler = handle_sigterm };
1000
1001
{
1002
struct argp_option options[] = {
1003
{ .name = "debug", .key = 128,
1004
.doc = "Debug mode", .group = 3 },
1005
{ .name = "connect", .key = 'c',
1006
.arg = "ADDRESS:PORT",
1007
.doc = "Connect directly to a specific Mandos server",
1008
.group = 1 },
1009
{ .name = "interface", .key = 'i',
1010
.arg = "NAME",
1011
.doc = "Network interface that will be used to search for"
1012
" Mandos servers",
1013
.group = 1 },
1014
{ .name = "seckey", .key = 's',
1015
.arg = "FILE",
1016
.doc = "OpenPGP secret key file base name",
1017
.group = 1 },
1018
{ .name = "pubkey", .key = 'p',
1019
.arg = "FILE",
1020
.doc = "OpenPGP public key file base name",
1021
.group = 2 },
1022
{ .name = "dh-bits", .key = 129,
1023
.arg = "BITS",
1024
.doc = "Bit length of the prime number used in the"
1025
" Diffie-Hellman key exchange",
1026
.group = 2 },
1027
{ .name = "priority", .key = 130,
1028
.arg = "STRING",
1029
.doc = "GnuTLS priority string for the TLS handshake",
1030
.group = 1 },
1031
{ .name = "delay", .key = 131,
1032
.arg = "SECONDS",
1033
.doc = "Maximum delay to wait for interface startup",
1034
.group = 2 },
1035
{ .name = NULL }
1036
};
1037
1038
error_t parse_opt(int key, char *arg,
1039
struct argp_state *state){
1040
switch(key){
1041
case 128: /* --debug */
1042
debug = true;
1043
break;
1044
case 'c': /* --connect */
1045
connect_to = arg;
1046
break;
1047
case 'i': /* --interface */
1048
interface = arg;
1049
break;
1050
case 's': /* --seckey */
1051
seckey = arg;
1052
break;
1053
case 'p': /* --pubkey */
1054
pubkey = arg;
1055
break;
1056
case 129: /* --dh-bits */
1057
errno = 0;
1058
tmpmax = strtoimax(arg, &tmp, 10);
1059
if(errno != 0 or tmp == arg or *tmp != '\0'
1060
or tmpmax != (typeof(mc.dh_bits))tmpmax){
1061
fprintf(stderr, "Bad number of DH bits\n");
1062
exit(EXIT_FAILURE);
1063
}
1064
mc.dh_bits = (typeof(mc.dh_bits))tmpmax;
1065
break;
1066
case 130: /* --priority */
1067
mc.priority = arg;
1068
break;
1069
case 131: /* --delay */
1070
errno = 0;
1071
delay = strtof(arg, &tmp);
1072
if(errno != 0 or tmp == arg or *tmp != '\0'){
1073
fprintf(stderr, "Bad delay\n");
1074
exit(EXIT_FAILURE);
1075
}
1076
break;
1077
case ARGP_KEY_ARG:
1078
argp_usage(state);
1079
case ARGP_KEY_END:
1080
break;
1081
default:
1082
return ARGP_ERR_UNKNOWN;
1083
}
1084
return 0;
1085
}
1086
1087
struct argp argp = { .options = options, .parser = parse_opt,
1088
.args_doc = "",
1089
.doc = "Mandos client -- Get and decrypt"
1090
" passwords from a Mandos server" };
1091
ret = argp_parse(&argp, argc, argv, 0, 0, NULL);
1092
if(ret == ARGP_ERR_UNKNOWN){
1093
fprintf(stderr, "Unknown error while parsing arguments\n");
1094
exitcode = EXIT_FAILURE;
1095
goto end;
1096
}
1097
}
1098
1099
if(not debug){
1100
avahi_set_log_function(empty_log);
1101
}
1102
1103
/* Initialize Avahi early so avahi_simple_poll_quit() can be called
1104
from the signal handler */
1105
/* Initialize the pseudo-RNG for Avahi */
1106
srand((unsigned int) time(NULL));
1107
mc.simple_poll = avahi_simple_poll_new();
1108
if(mc.simple_poll == NULL){
1109
fprintf(stderr, "Avahi: Failed to create simple poll object.\n");
1110
exitcode = EXIT_FAILURE;
1111
goto end;
1112
}
1113
1114
sigemptyset(&sigterm_action.sa_mask);
1115
ret = sigaddset(&sigterm_action.sa_mask, SIGINT);
1116
if(ret == -1){
1117
perror("sigaddset");
1118
exitcode = EXIT_FAILURE;
1119
goto end;
1120
}
1121
ret = sigaddset(&sigterm_action.sa_mask, SIGHUP);
1122
if(ret == -1){
1123
perror("sigaddset");
1124
exitcode = EXIT_FAILURE;
1125
goto end;
1126
}
1127
ret = sigaddset(&sigterm_action.sa_mask, SIGTERM);
1128
if(ret == -1){
1129
perror("sigaddset");
1130
exitcode = EXIT_FAILURE;
1131
goto end;
1132
}
1133
/* Need to check if the handler is SIG_IGN before handling:
1134
| [[info:libc:Initial Signal Actions]] |
1135
| [[info:libc:Basic Signal Handling]] |
1136
*/
1137
ret = sigaction(SIGINT, NULL, &old_sigterm_action);
1138
if(ret == -1){
1139
perror("sigaction");
1140
return EXIT_FAILURE;
1141
}
1142
if(old_sigterm_action.sa_handler != SIG_IGN){
1143
ret = sigaction(SIGINT, &sigterm_action, NULL);
1144
if(ret == -1){
1145
perror("sigaction");
1146
exitcode = EXIT_FAILURE;
1147
goto end;
1148
}
1149
}
1150
ret = sigaction(SIGHUP, NULL, &old_sigterm_action);
1151
if(ret == -1){
1152
perror("sigaction");
1153
return EXIT_FAILURE;
1154
}
1155
if(old_sigterm_action.sa_handler != SIG_IGN){
1156
ret = sigaction(SIGHUP, &sigterm_action, NULL);
1157
if(ret == -1){
1158
perror("sigaction");
1159
exitcode = EXIT_FAILURE;
1160
goto end;
1161
}
1162
}
1163
ret = sigaction(SIGTERM, NULL, &old_sigterm_action);
1164
if(ret == -1){
1165
perror("sigaction");
1166
return EXIT_FAILURE;
1167
}
1168
if(old_sigterm_action.sa_handler != SIG_IGN){
1169
ret = sigaction(SIGTERM, &sigterm_action, NULL);
1170
if(ret == -1){
1171
perror("sigaction");
1172
exitcode = EXIT_FAILURE;
1173
goto end;
1174
}
1175
}
1176
1177
/* If the interface is down, bring it up */
1178
if(interface[0] != '\0'){
813
AvahiSServiceBrowser *sb = NULL;
814
int error;
815
int ret;
816
int exitcode = EXIT_SUCCESS;
817
const char *interface = "eth0";
818
struct ifreq network;
819
int sd;
820
uid_t uid;
821
gid_t gid;
822
char *connect_to = NULL;
823
char tempdir[] = "/tmp/mandosXXXXXX";
824
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
825
const char *seckey = PATHDIR "/" SECKEY;
826
const char *pubkey = PATHDIR "/" PUBKEY;
827
828
mandos_context mc = { .simple_poll = NULL, .server = NULL,
829
.dh_bits = 1024, .priority = "SECURE256"
830
":!CTYPE-X.509:+CTYPE-OPENPGP" };
831
bool gnutls_initalized = false;
832
bool gpgme_initalized = false;
833
834
{
835
struct argp_option options[] = {
836
{ .name = "debug", .key = 128,
837
.doc = "Debug mode", .group = 3 },
838
{ .name = "connect", .key = 'c',
839
.arg = "ADDRESS:PORT",
840
.doc = "Connect directly to a specific Mandos server",
841
.group = 1 },
842
{ .name = "interface", .key = 'i',
843
.arg = "NAME",
844
.doc = "Interface that will be used to search for Mandos"
845
" servers",
846
.group = 1 },
847
{ .name = "seckey", .key = 's',
848
.arg = "FILE",
849
.doc = "OpenPGP secret key file base name",
850
.group = 1 },
851
{ .name = "pubkey", .key = 'p',
852
.arg = "FILE",
853
.doc = "OpenPGP public key file base name",
854
.group = 2 },
855
{ .name = "dh-bits", .key = 129,
856
.arg = "BITS",
857
.doc = "Bit length of the prime number used in the"
858
" Diffie-Hellman key exchange",
859
.group = 2 },
860
{ .name = "priority", .key = 130,
861
.arg = "STRING",
862
.doc = "GnuTLS priority string for the TLS handshake",
863
.group = 1 },
864
{ .name = NULL }
865
};
866
867
error_t parse_opt (int key, char *arg,
868
struct argp_state *state) {
869
switch (key) {
870
case 128: /* --debug */
871
debug = true;
872
break;
873
case 'c': /* --connect */
874
connect_to = arg;
875
break;
876
case 'i': /* --interface */
877
interface = arg;
878
break;
879
case 's': /* --seckey */
880
seckey = arg;
881
break;
882
case 'p': /* --pubkey */
883
pubkey = arg;
884
break;
885
case 129: /* --dh-bits */
886
ret = sscanf(arg, "%u", &mc.dh_bits);
887
if(ret == 0 or mc.dh_bits == 0){
888
fprintf(stderr, "Bad number of DH bits\n");
889
exit(EXIT_FAILURE);
890
}
891
break;
892
case 130: /* --priority */
893
mc.priority = arg;
894
break;
895
case ARGP_KEY_ARG:
896
argp_usage (state);
897
case ARGP_KEY_END:
898
break;
899
default:
900
return ARGP_ERR_UNKNOWN;
901
}
902
return 0;
903
}
904
905
struct argp argp = { .options = options, .parser = parse_opt,
906
.args_doc = "",
907
.doc = "Mandos client -- Get and decrypt"
908
" passwords from a Mandos server" };
909
ret = argp_parse (&argp, argc, argv, 0, 0, NULL);
910
if (ret == ARGP_ERR_UNKNOWN){
911
fprintf(stderr, "Unknown error while parsing arguments\n");
912
exitcode = EXIT_FAILURE;
913
goto end;
914
}
915
}
916
917
/* If the interface is down, bring it up */
918
{
919
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
920
if(sd < 0) {
921
perror("socket");
922
exitcode = EXIT_FAILURE;
923
goto end;
924
}
925
strcpy(network.ifr_name, interface);
926
ret = ioctl(sd, SIOCGIFFLAGS, &network);
927
if(ret == -1){
928
perror("ioctl SIOCGIFFLAGS");
929
exitcode = EXIT_FAILURE;
930
goto end;
931
}
932
if((network.ifr_flags & IFF_UP) == 0){
933
network.ifr_flags |= IFF_UP;
934
ret = ioctl(sd, SIOCSIFFLAGS, &network);
935
if(ret == -1){
936
perror("ioctl SIOCSIFFLAGS");
937
exitcode = EXIT_FAILURE;
938
goto end;
939
}
940
}
941
ret = (int)TEMP_FAILURE_RETRY(close(sd));
942
if(ret == -1){
943
perror("close");
944
}
945
}
946
947
uid = getuid();
948
gid = getgid();
949
950
ret = setuid(uid);
951
if (ret == -1){
952
perror("setuid");
953
}
954
955
setgid(gid);
956
if (ret == -1){
957
perror("setgid");
958
}
959
960
ret = init_gnutls_global(&mc, pubkey, seckey);
961
if (ret == -1){
962
fprintf(stderr, "init_gnutls_global failed\n");
963
exitcode = EXIT_FAILURE;
964
goto end;
965
} else {
966
gnutls_initalized = true;
967
}
968
969
if(mkdtemp(tempdir) == NULL){
970
perror("mkdtemp");
971
tempdir[0] = '\0';
972
goto end;
973
}
974
975
if(not init_gpgme(&mc, pubkey, seckey, tempdir)){
976
fprintf(stderr, "gpgme_initalized failed\n");
977
exitcode = EXIT_FAILURE;
978
goto end;
979
} else {
980
gpgme_initalized = true;
981
}
982
1179
983
if_index = (AvahiIfIndex) if_nametoindex(interface);
1180
984
if(if_index == 0){
1181
985
fprintf(stderr, "No such interface: \"%s\"\n", interface);
1182
exitcode = EXIT_FAILURE;
1183
goto end;
1184
}
1185
1186
if(quit_now){
1187
goto end;
1188
}
1189
1190
#ifdef __linux__
1191
/* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
1192
messages to mess up the prompt */
1193
ret = klogctl(8, NULL, 5);
1194
bool restore_loglevel = true;
1195
if(ret == -1){
1196
restore_loglevel = false;
1197
perror("klogctl");
1198
}
1199
#endif /* __linux__ */
1200
1201
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1202
if(sd < 0){
1203
perror("socket");
1204
exitcode = EXIT_FAILURE;
1205
#ifdef __linux__
1206
if(restore_loglevel){
1207
ret = klogctl(7, NULL, 0);
1208
if(ret == -1){
1209
perror("klogctl");
1210
}
1211
}
1212
#endif /* __linux__ */
1213
goto end;
1214
}
1215
strcpy(network.ifr_name, interface);
1216
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1217
if(ret == -1){
1218
perror("ioctl SIOCGIFFLAGS");
1219
#ifdef __linux__
1220
if(restore_loglevel){
1221
ret = klogctl(7, NULL, 0);
1222
if(ret == -1){
1223
perror("klogctl");
1224
}
1225
}
1226
#endif /* __linux__ */
1227
exitcode = EXIT_FAILURE;
1228
goto end;
1229
}
1230
if((network.ifr_flags & IFF_UP) == 0){
1231
network.ifr_flags |= IFF_UP;
1232
take_down_interface = true;
1233
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1234
if(ret == -1){
1235
take_down_interface = false;
1236
perror("ioctl SIOCSIFFLAGS");
1237
exitcode = EXIT_FAILURE;
1238
#ifdef __linux__
1239
if(restore_loglevel){
1240
ret = klogctl(7, NULL, 0);
1241
if(ret == -1){
1242
perror("klogctl");
1243
}
1244
}
1245
#endif /* __linux__ */
1246
goto end;
1247
}
1248
}
1249
/* sleep checking until interface is running */
1250
for(int i=0; i < delay * 4; i++){
1251
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1252
if(ret == -1){
1253
perror("ioctl SIOCGIFFLAGS");
1254
} else if(network.ifr_flags & IFF_RUNNING){
1255
break;
1256
}
1257
struct timespec sleeptime = { .tv_nsec = 250000000 };
1258
ret = nanosleep(&sleeptime, NULL);
1259
if(ret == -1 and errno != EINTR){
1260
perror("nanosleep");
1261
}
1262
}
1263
if(not take_down_interface){
1264
/* We won't need the socket anymore */
1265
ret = (int)TEMP_FAILURE_RETRY(close(sd));
1266
if(ret == -1){
1267
perror("close");
1268
}
1269
}
1270
#ifdef __linux__
1271
if(restore_loglevel){
1272
/* Restores kernel loglevel to default */
1273
ret = klogctl(7, NULL, 0);
1274
if(ret == -1){
1275
perror("klogctl");
1276
}
1277
}
1278
#endif /* __linux__ */
1279
}
1280
1281
if(quit_now){
1282
goto end;
1283
}
1284
1285
uid = getuid();
1286
gid = getgid();
1287
1288
/* Drop any group privileges we might have, just to be safe */
1289
errno = 0;
1290
ret = setgid(gid);
1291
if(ret == -1){
1292
perror("setgid");
1293
}
1294
1295
/* Drop user privileges */
1296
errno = 0;
1297
/* Will we need privileges later? */
1298
if(take_down_interface){
1299
/* Drop user privileges temporarily */
1300
ret = seteuid(uid);
1301
if(ret == -1){
1302
perror("seteuid");
1303
}
1304
} else {
1305
/* Drop user privileges permanently */
1306
ret = setuid(uid);
1307
if(ret == -1){
1308
perror("setuid");
1309
}
1310
}
1311
1312
if(quit_now){
1313
goto end;
1314
}
1315
1316
ret = init_gnutls_global(pubkey, seckey);
1317
if(ret == -1){
1318
fprintf(stderr, "init_gnutls_global failed\n");
1319
exitcode = EXIT_FAILURE;
1320
goto end;
1321
} else {
1322
gnutls_initialized = true;
1323
}
1324
1325
if(quit_now){
1326
goto end;
1327
}
1328
1329
tempdir_created = true;
1330
if(mkdtemp(tempdir) == NULL){
1331
tempdir_created = false;
1332
perror("mkdtemp");
1333
goto end;
1334
}
1335
1336
if(quit_now){
1337
goto end;
1338
}
1339
1340
if(not init_gpgme(pubkey, seckey, tempdir)){
1341
fprintf(stderr, "init_gpgme failed\n");
1342
exitcode = EXIT_FAILURE;
1343
goto end;
1344
} else {
1345
gpgme_initialized = true;
1346
}
1347
1348
if(quit_now){
1349
goto end;
1350
}
1351
1352
if(connect_to != NULL){
1353
/* Connect directly, do not use Zeroconf */
1354
/* (Mainly meant for debugging) */
1355
char *address = strrchr(connect_to, ':');
1356
if(address == NULL){
1357
fprintf(stderr, "No colon in address\n");
1358
exitcode = EXIT_FAILURE;
1359
goto end;
1360
}
1361
1362
if(quit_now){
1363
goto end;
1364
}
1365
1366
uint16_t port;
1367
errno = 0;
1368
tmpmax = strtoimax(address+1, &tmp, 10);
1369
if(errno != 0 or tmp == address+1 or *tmp != '\0'
1370
or tmpmax != (uint16_t)tmpmax){
1371
fprintf(stderr, "Bad port number\n");
1372
exitcode = EXIT_FAILURE;
1373
goto end;
1374
}
1375
1376
if(quit_now){
1377
goto end;
1378
}
1379
1380
port = (uint16_t)tmpmax;
1381
*address = '\0';
1382
address = connect_to;
1383
/* Colon in address indicates IPv6 */
1384
int af;
1385
if(strchr(address, ':') != NULL){
1386
af = AF_INET6;
1387
} else {
1388
af = AF_INET;
1389
}
1390
1391
if(quit_now){
1392
goto end;
1393
}
1394
1395
ret = start_mandos_communication(address, port, if_index, af);
1396
if(ret < 0){
1397
exitcode = EXIT_FAILURE;
1398
} else {
1399
exitcode = EXIT_SUCCESS;
1400
}
1401
goto end;
1402
}
1403
1404
if(quit_now){
1405
goto end;
1406
}
1407
1408
{
1409
AvahiServerConfig config;
1410
/* Do not publish any local Zeroconf records */
1411
avahi_server_config_init(&config);
1412
config.publish_hinfo = 0;
1413
config.publish_addresses = 0;
1414
config.publish_workstation = 0;
1415
config.publish_domain = 0;
1416
1417
/* Allocate a new server */
1418
mc.server = avahi_server_new(avahi_simple_poll_get
1419
(mc.simple_poll), &config, NULL,
1420
NULL, &error);
1421
1422
/* Free the Avahi configuration data */
1423
avahi_server_config_free(&config);
1424
}
1425
1426
/* Check if creating the Avahi server object succeeded */
1427
if(mc.server == NULL){
1428
fprintf(stderr, "Failed to create Avahi server: %s\n",
1429
avahi_strerror(error));
1430
exitcode = EXIT_FAILURE;
1431
goto end;
1432
}
1433
1434
if(quit_now){
1435
goto end;
1436
}
1437
1438
/* Create the Avahi service browser */
1439
sb = avahi_s_service_browser_new(mc.server, if_index,
1440
AVAHI_PROTO_UNSPEC, "_mandos._tcp",
1441
NULL, 0, browse_callback, NULL);
1442
if(sb == NULL){
1443
fprintf(stderr, "Failed to create service browser: %s\n",
1444
avahi_strerror(avahi_server_errno(mc.server)));
1445
exitcode = EXIT_FAILURE;
1446
goto end;
1447
}
1448
1449
if(quit_now){
1450
goto end;
1451
}
1452
1453
/* Run the main loop */
1454
1455
if(debug){
1456
fprintf(stderr, "Starting Avahi loop search\n");
1457
}
1458
1459
avahi_simple_poll_loop(mc.simple_poll);
1460
986
exit(EXIT_FAILURE);
987
}
988
989
if(connect_to != NULL){
990
/* Connect directly, do not use Zeroconf */
991
/* (Mainly meant for debugging) */
992
char *address = strrchr(connect_to, ':');
993
if(address == NULL){
994
fprintf(stderr, "No colon in address\n");
995
exitcode = EXIT_FAILURE;
996
goto end;
997
}
998
uint16_t port;
999
ret = sscanf(address+1, "%" SCNu16, &port);
1000
if(ret == 0 or port == 0){
1001
fprintf(stderr, "Bad port number\n");
1002
exitcode = EXIT_FAILURE;
1003
goto end;
1004
}
1005
*address = '\0';
1006
address = connect_to;
1007
ret = start_mandos_communication(address, port, if_index, &mc);
1008
if(ret < 0){
1009
exitcode = EXIT_FAILURE;
1010
} else {
1011
exitcode = EXIT_SUCCESS;
1012
}
1013
goto end;
1014
}
1015
1016
if (not debug){
1017
avahi_set_log_function(empty_log);
1018
}
1019
1020
/* Initialize the pseudo-RNG for Avahi */
1021
srand((unsigned int) time(NULL));
1022
1023
/* Allocate main Avahi loop object */
1024
mc.simple_poll = avahi_simple_poll_new();
1025
if (mc.simple_poll == NULL) {
1026
fprintf(stderr, "Avahi: Failed to create simple poll"
1027
" object.\n");
1028
exitcode = EXIT_FAILURE;
1029
goto end;
1030
}
1031
1032
{
1033
AvahiServerConfig config;
1034
/* Do not publish any local Zeroconf records */
1035
avahi_server_config_init(&config);
1036
config.publish_hinfo = 0;
1037
config.publish_addresses = 0;
1038
config.publish_workstation = 0;
1039
config.publish_domain = 0;
1040
1041
/* Allocate a new server */
1042
mc.server = avahi_server_new(avahi_simple_poll_get
1043
(mc.simple_poll), &config, NULL,
1044
NULL, &error);
1045
1046
/* Free the Avahi configuration data */
1047
avahi_server_config_free(&config);
1048
}
1049
1050
/* Check if creating the Avahi server object succeeded */
1051
if (mc.server == NULL) {
1052
fprintf(stderr, "Failed to create Avahi server: %s\n",
1053
avahi_strerror(error));
1054
exitcode = EXIT_FAILURE;
1055
goto end;
1056
}
1057
1058
/* Create the Avahi service browser */
1059
sb = avahi_s_service_browser_new(mc.server, if_index,
1060
AVAHI_PROTO_INET6,
1061
"_mandos._tcp", NULL, 0,
1062
browse_callback, &mc);
1063
if (sb == NULL) {
1064
fprintf(stderr, "Failed to create service browser: %s\n",
1065
avahi_strerror(avahi_server_errno(mc.server)));
1066
exitcode = EXIT_FAILURE;
1067
goto end;
1068
}
1069
1070
/* Run the main loop */
1071
1072
if (debug){
1073
fprintf(stderr, "Starting Avahi loop search\n");
1074
}
1075
1076
avahi_simple_poll_loop(mc.simple_poll);
1077
1461
1078
end:
1462
1463
if(debug){
1464
fprintf(stderr, "%s exiting\n", argv[0]);
1465
}
1466
1467
/* Cleanup things */
1468
if(sb != NULL)
1469
avahi_s_service_browser_free(sb);
1470
1471
if(mc.server != NULL)
1472
avahi_server_free(mc.server);
1473
1474
if(mc.simple_poll != NULL)
1475
avahi_simple_poll_free(mc.simple_poll);
1476
1477
if(gnutls_initialized){
1478
gnutls_certificate_free_credentials(mc.cred);
1479
gnutls_global_deinit();
1480
gnutls_dh_params_deinit(mc.dh_params);
1481
}
1482
1483
if(gpgme_initialized){
1484
gpgme_release(mc.ctx);
1485
}
1486
1487
/* Take down the network interface */
1488
if(take_down_interface){
1489
/* Re-raise priviliges */
1490
errno = 0;
1491
ret = seteuid(0);
1492
if(ret == -1){
1493
perror("seteuid");
1494
}
1495
if(geteuid() == 0){
1496
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1497
if(ret == -1){
1498
perror("ioctl SIOCGIFFLAGS");
1499
} else if(network.ifr_flags & IFF_UP) {
1500
network.ifr_flags &= ~IFF_UP; /* clear flag */
1501
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1502
if(ret == -1){
1503
perror("ioctl SIOCSIFFLAGS");
1504
}
1505
}
1506
ret = (int)TEMP_FAILURE_RETRY(close(sd));
1507
if(ret == -1){
1508
perror("close");
1509
}
1510
/* Lower privileges, permanently this time */
1511
errno = 0;
1512
ret = setuid(uid);
1513
if(ret == -1){
1514
perror("setuid");
1515
}
1516
}
1517
}
1518
1519
/* Removes the temp directory used by GPGME */
1520
if(tempdir_created){
1521
DIR *d;
1522
struct dirent *direntry;
1523
d = opendir(tempdir);
1524
if(d == NULL){
1525
if(errno != ENOENT){
1526
perror("opendir");
1527
}
1528
} else {
1529
while(true){
1530
direntry = readdir(d);
1531
if(direntry == NULL){
1532
break;
1533
}
1534
/* Skip "." and ".." */
1535
if(direntry->d_name[0] == '.'
1536
and (direntry->d_name[1] == '\0'
1537
or (direntry->d_name[1] == '.'
1538
and direntry->d_name[2] == '\0'))){
1539
continue;
1540
}
1541
char *fullname = NULL;
1542
ret = asprintf(&fullname, "%s/%s", tempdir,
1543
direntry->d_name);
1544
if(ret < 0){
1545
perror("asprintf");
1546
continue;
1547
}
1548
ret = remove(fullname);
1549
if(ret == -1){
1550
fprintf(stderr, "remove(\"%s\"): %s\n", fullname,
1551
strerror(errno));
1552
}
1553
free(fullname);
1554
}
1555
closedir(d);
1556
}
1557
ret = rmdir(tempdir);
1558
if(ret == -1 and errno != ENOENT){
1559
perror("rmdir");
1560
}
1561
}
1562
1563
if(quit_now){
1564
sigemptyset(&old_sigterm_action.sa_mask);
1565
old_sigterm_action.sa_handler = SIG_DFL;
1566
ret = sigaction(signal_received, &old_sigterm_action, NULL);
1567
if(ret == -1){
1568
perror("sigaction");
1569
}
1570
raise(signal_received);
1571
}
1572
1573
return exitcode;
1079
1080
if (debug){
1081
fprintf(stderr, "%s exiting\n", argv[0]);
1082
}
1083
1084
/* Cleanup things */
1085
if (sb != NULL)
1086
avahi_s_service_browser_free(sb);
1087
1088
if (mc.server != NULL)
1089
avahi_server_free(mc.server);
1090
1091
if (mc.simple_poll != NULL)
1092
avahi_simple_poll_free(mc.simple_poll);
1093
1094
if (gnutls_initalized){
1095
gnutls_certificate_free_credentials(mc.cred);
1096
gnutls_global_deinit ();
1097
gnutls_dh_params_deinit(mc.dh_params);
1098
}
1099
1100
if(gpgme_initalized){
1101
gpgme_release(mc.ctx);
1102
}
1103
1104
/* Removes the temp directory used by GPGME */
1105
if(tempdir[0] != '\0'){
1106
DIR *d;
1107
struct dirent *direntry;
1108
d = opendir(tempdir);
1109
if(d == NULL){
1110
if(errno != ENOENT){
1111
perror("opendir");
1112
}
1113
} else {
1114
while(true){
1115
direntry = readdir(d);
1116
if(direntry == NULL){
1117
break;
1118
}
1119
if (direntry->d_type == DT_REG){
1120
char *fullname = NULL;
1121
ret = asprintf(&fullname, "%s/%s", tempdir,
1122
direntry->d_name);
1123
if(ret < 0){
1124
perror("asprintf");
1125
continue;
1126
}
1127
ret = unlink(fullname);
1128
if(ret == -1){
1129
fprintf(stderr, "unlink(\"%s\"): %s",
1130
fullname, strerror(errno));
1131
}
1132
free(fullname);
1133
}
1134
}
1135
closedir(d);
1136
}
1137
ret = rmdir(tempdir);
1138
if(ret == -1 and errno != ENOENT){
1139
perror("rmdir");
1140
}
1141
}
1142
1143
return exitcode;
1574
1144
}
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0