32
32
#define _LARGEFILE_SOURCE
33
33
#define _FILE_OFFSET_BITS 64
35
#define _GNU_SOURCE /* TEMP_FAILURE_RETRY(), asprintf() */
37
#include <stdio.h> /* fprintf(), stderr, fwrite(),
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,
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, open(), opendir(), DIR */
51
#include <sys/stat.h> /* open() */
52
#include <sys/socket.h> /* socket(), struct sockaddr_in6,
53
struct in6_addr, inet_pton(),
55
#include <fcntl.h> /* open() */
56
#include <dirent.h> /* opendir(), struct dirent, readdir() */
57
#include <inttypes.h> /* PRIu16 */
58
#include <assert.h> /* assert() */
59
#include <errno.h> /* perror(), errno */
60
#include <time.h> /* time() */
61
#include <net/if.h> /* ioctl, ifreq, SIOCGIFFLAGS, IFF_UP,
62
SIOCSIFFLAGS, if_indextoname(),
63
if_nametoindex(), IF_NAMESIZE */
64
#include <netinet/in.h>
65
#include <unistd.h> /* close(), SEEK_SET, off_t, write(),
66
getuid(), getgid(), setuid(),
68
#include <arpa/inet.h> /* inet_pton(), htons */
69
#include <iso646.h> /* not, and */
70
#include <argp.h> /* struct argp_option, error_t, struct
71
argp_state, struct argp,
72
argp_parse(), ARGP_KEY_ARG,
73
ARGP_KEY_END, ARGP_ERR_UNKNOWN */
76
/* All Avahi types, constants and functions
39
#include <net/if.h> /* if_nametoindex */
40
#include <sys/ioctl.h> // ioctl, ifreq, SIOCGIFFLAGS, IFF_UP, SIOCSIFFLAGS
41
#include <net/if.h> // ioctl, ifreq, SIOCGIFFLAGS, IFF_UP, SIOCSIFFLAGS
79
43
#include <avahi-core/core.h>
80
44
#include <avahi-core/lookup.h>
81
45
#include <avahi-core/log.h>
83
47
#include <avahi-common/malloc.h>
84
48
#include <avahi-common/error.h>
87
#include <gnutls/gnutls.h> /* All GnuTLS types, constants and
90
init_gnutls_session(),
92
#include <gnutls/openpgp.h> /* gnutls_certificate_set_openpgp_key_file(),
93
GNUTLS_OPENPGP_FMT_BASE64 */
96
#include <gpgme.h> /* All GPGME types, constants and
99
GPGME_PROTOCOL_OpenPGP,
51
#include <sys/types.h> /* socket(), inet_pton() */
52
#include <sys/socket.h> /* socket(), struct sockaddr_in6,
53
struct in6_addr, inet_pton() */
54
#include <gnutls/gnutls.h> /* All GnuTLS stuff */
55
#include <gnutls/openpgp.h> /* GnuTLS with openpgp stuff */
57
#include <unistd.h> /* close() */
58
#include <netinet/in.h>
59
#include <stdbool.h> /* true */
60
#include <string.h> /* memset */
61
#include <arpa/inet.h> /* inet_pton() */
62
#include <iso646.h> /* not */
65
#include <errno.h> /* perror() */
102
71
#define BUFFER_SIZE 256
104
#define PATHDIR "/conf/conf.d/mandos"
105
#define SECKEY "seckey.txt"
106
#define PUBKEY "pubkey.txt"
74
static const char *certdir = "/conf/conf.d/mandos";
75
static const char *certfile = "openpgp-client.txt";
76
static const char *certkey = "openpgp-client-key.txt";
108
78
bool debug = false;
109
static const char mandos_protocol_version[] = "1";
110
const char *argp_program_version = "mandos-client " VERSION;
111
const char *argp_program_bug_address = "<mandos@fukt.bsnet.se>";
113
/* Used for passing in values through the Avahi callback functions */
115
81
AvahiSimplePoll *simple_poll;
116
82
AvahiServer *server;
117
83
gnutls_certificate_credentials_t cred;
118
84
unsigned int dh_bits;
119
gnutls_dh_params_t dh_params;
120
85
const char *priority;
88
static ssize_t pgp_packet_decrypt (char *packet, size_t packet_size,
91
gpgme_data_t dh_crypto, dh_plain;
125
* Make room in "buffer" for at least BUFFER_SIZE additional bytes.
126
* "buffer_capacity" is how much is currently allocated,
127
* "buffer_length" is how much is already used.
129
size_t adjustbuffer(char **buffer, size_t buffer_length,
130
size_t buffer_capacity){
131
if (buffer_length + BUFFER_SIZE > buffer_capacity){
132
*buffer = realloc(*buffer, buffer_capacity + BUFFER_SIZE);
136
buffer_capacity += BUFFER_SIZE;
138
return buffer_capacity;
144
static bool init_gpgme(mandos_context *mc, const char *seckey,
145
const char *pubkey, const char *tempdir){
95
ssize_t new_packet_capacity = 0;
96
ssize_t new_packet_length = 0;
148
97
gpgme_engine_info_t engine_info;
152
* Helper function to insert pub and seckey to the enigne keyring.
154
bool import_key(const char *filename){
156
gpgme_data_t pgp_data;
158
fd = TEMP_FAILURE_RETRY(open(filename, O_RDONLY));
164
rc = gpgme_data_new_from_fd(&pgp_data, fd);
165
if (rc != GPG_ERR_NO_ERROR){
166
fprintf(stderr, "bad gpgme_data_new_from_fd: %s: %s\n",
167
gpgme_strsource(rc), gpgme_strerror(rc));
171
rc = gpgme_op_import(mc->ctx, pgp_data);
172
if (rc != GPG_ERR_NO_ERROR){
173
fprintf(stderr, "bad gpgme_op_import: %s: %s\n",
174
gpgme_strsource(rc), gpgme_strerror(rc));
178
ret = TEMP_FAILURE_RETRY(close(fd));
182
gpgme_data_release(pgp_data);
187
fprintf(stderr, "Initialize gpgme\n");
100
fprintf(stderr, "Trying to decrypt OpenPGP packet\n");
263
142
if (rc != GPG_ERR_NO_ERROR){
264
143
fprintf(stderr, "bad gpgme_data_new: %s: %s\n",
265
144
gpgme_strsource(rc), gpgme_strerror(rc));
266
gpgme_data_release(dh_crypto);
270
/* Decrypt data from the cryptotext data buffer to the plaintext
272
rc = gpgme_op_decrypt(mc->ctx, dh_crypto, dh_plain);
148
/* Create new GPGME "context" */
149
rc = gpgme_new(&ctx);
150
if (rc != GPG_ERR_NO_ERROR){
151
fprintf(stderr, "bad gpgme_new: %s: %s\n",
152
gpgme_strsource(rc), gpgme_strerror(rc));
156
/* Decrypt data from the FILE pointer to the plaintext data
158
rc = gpgme_op_decrypt(ctx, dh_crypto, dh_plain);
273
159
if (rc != GPG_ERR_NO_ERROR){
274
160
fprintf(stderr, "bad gpgme_op_decrypt: %s: %s\n",
275
161
gpgme_strsource(rc), gpgme_strerror(rc));
276
plaintext_length = -1;
278
gpgme_decrypt_result_t result;
279
result = gpgme_op_decrypt_result(mc->ctx);
281
fprintf(stderr, "gpgme_op_decrypt_result failed\n");
283
fprintf(stderr, "Unsupported algorithm: %s\n",
284
result->unsupported_algorithm);
285
fprintf(stderr, "Wrong key usage: %u\n",
286
result->wrong_key_usage);
287
if(result->file_name != NULL){
288
fprintf(stderr, "File name: %s\n", result->file_name);
290
gpgme_recipient_t recipient;
291
recipient = result->recipients;
293
while(recipient != NULL){
294
fprintf(stderr, "Public key algorithm: %s\n",
295
gpgme_pubkey_algo_name(recipient->pubkey_algo));
296
fprintf(stderr, "Key ID: %s\n", recipient->keyid);
297
fprintf(stderr, "Secret key available: %s\n",
298
recipient->status == GPG_ERR_NO_SECKEY
300
recipient = recipient->next;
166
fprintf(stderr, "Decryption of OpenPGP packet succeeded\n");
170
gpgme_decrypt_result_t result;
171
result = gpgme_op_decrypt_result(ctx);
173
fprintf(stderr, "gpgme_op_decrypt_result failed\n");
175
fprintf(stderr, "Unsupported algorithm: %s\n",
176
result->unsupported_algorithm);
177
fprintf(stderr, "Wrong key usage: %d\n",
178
result->wrong_key_usage);
179
if(result->file_name != NULL){
180
fprintf(stderr, "File name: %s\n", result->file_name);
182
gpgme_recipient_t recipient;
183
recipient = result->recipients;
185
while(recipient != NULL){
186
fprintf(stderr, "Public key algorithm: %s\n",
187
gpgme_pubkey_algo_name(recipient->pubkey_algo));
188
fprintf(stderr, "Key ID: %s\n", recipient->keyid);
189
fprintf(stderr, "Secret key available: %s\n",
190
recipient->status == GPG_ERR_NO_SECKEY
192
recipient = recipient->next;
309
fprintf(stderr, "Decryption of OpenPGP data succeeded\n");
198
/* Delete the GPGME FILE pointer cryptotext data buffer */
199
gpgme_data_release(dh_crypto);
312
201
/* Seek back to the beginning of the GPGME plaintext data buffer */
313
202
if (gpgme_data_seek(dh_plain, (off_t) 0, SEEK_SET) == -1){
314
perror("gpgme_data_seek");
315
plaintext_length = -1;
203
perror("pgpme_data_seek");
321
plaintext_capacity = adjustbuffer(plaintext,
322
(size_t)plaintext_length,
324
if (plaintext_capacity == 0){
325
perror("adjustbuffer");
326
plaintext_length = -1;
208
if (new_packet_length + BUFFER_SIZE > new_packet_capacity){
209
*new_packet = realloc(*new_packet,
210
(unsigned int)new_packet_capacity
212
if (*new_packet == NULL){
216
new_packet_capacity += BUFFER_SIZE;
330
ret = gpgme_data_read(dh_plain, *plaintext + plaintext_length,
219
ret = gpgme_data_read(dh_plain, *new_packet + new_packet_length,
332
221
/* Print the data, if any */
338
226
perror("gpgme_data_read");
339
plaintext_length = -1;
342
plaintext_length += ret;
346
fprintf(stderr, "Decrypted password is: ");
347
for(ssize_t i = 0; i < plaintext_length; i++){
348
fprintf(stderr, "%02hhX ", (*plaintext)[i]);
350
fprintf(stderr, "\n");
355
/* Delete the GPGME cryptotext data buffer */
356
gpgme_data_release(dh_crypto);
229
new_packet_length += ret;
232
/* FIXME: check characters before printing to screen so to not print
233
terminal control characters */
235
/* fprintf(stderr, "decrypted password is: "); */
236
/* fwrite(*new_packet, 1, new_packet_length, stderr); */
237
/* fprintf(stderr, "\n"); */
358
240
/* Delete the GPGME plaintext data buffer */
359
241
gpgme_data_release(dh_plain);
360
return plaintext_length;
242
return new_packet_length;
363
245
static const char * safer_gnutls_strerror (int value) {
364
const char *ret = gnutls_strerror (value); /* Spurious warning */
246
const char *ret = gnutls_strerror (value);
366
248
ret = "(unknown)";
370
/* GnuTLS log function callback */
371
252
static void debuggnutls(__attribute__((unused)) int level,
372
253
const char* string){
373
fprintf(stderr, "GnuTLS: %s", string);
254
fprintf(stderr, "%s", string);
376
static int init_gnutls_global(mandos_context *mc,
377
const char *pubkeyfilename,
378
const char *seckeyfilename){
257
static int initgnutls(mandos_context *mc){
382
262
fprintf(stderr, "Initializing GnuTLS\n");
385
ret = gnutls_global_init();
386
if (ret != GNUTLS_E_SUCCESS) {
387
fprintf (stderr, "GnuTLS global_init: %s\n",
388
safer_gnutls_strerror(ret));
265
if ((ret = gnutls_global_init ())
266
!= GNUTLS_E_SUCCESS) {
267
fprintf (stderr, "global_init: %s\n", safer_gnutls_strerror(ret));
393
/* "Use a log level over 10 to enable all debugging options."
396
272
gnutls_global_set_log_level(11);
397
273
gnutls_global_set_log_function(debuggnutls);
400
/* OpenPGP credentials */
401
gnutls_certificate_allocate_credentials(&mc->cred);
402
if (ret != GNUTLS_E_SUCCESS){
403
fprintf (stderr, "GnuTLS memory error: %s\n", /* Spurious
276
/* openpgp credentials */
277
if ((ret = gnutls_certificate_allocate_credentials (&es->cred))
278
!= GNUTLS_E_SUCCESS) {
279
fprintf (stderr, "memory error: %s\n",
405
280
safer_gnutls_strerror(ret));
406
gnutls_global_deinit ();
411
fprintf(stderr, "Attempting to use OpenPGP public key %s and"
412
" secret key %s as GnuTLS credentials\n", pubkeyfilename,
285
fprintf(stderr, "Attempting to use OpenPGP certificate %s"
286
" and keyfile %s as GnuTLS credentials\n", certfile,
416
290
ret = gnutls_certificate_set_openpgp_key_file
417
(mc->cred, pubkeyfilename, seckeyfilename,
418
GNUTLS_OPENPGP_FMT_BASE64);
291
(es->cred, certfile, certkey, GNUTLS_OPENPGP_FMT_BASE64);
419
292
if (ret != GNUTLS_E_SUCCESS) {
421
"Error[%d] while reading the OpenPGP key pair ('%s',"
422
" '%s')\n", ret, pubkeyfilename, seckeyfilename);
423
fprintf(stderr, "The GnuTLS error is: %s\n",
294
(stderr, "Error[%d] while reading the OpenPGP key pair ('%s',"
296
ret, certfile, certkey);
297
fprintf(stdout, "The Error is: %s\n",
424
298
safer_gnutls_strerror(ret));
428
/* GnuTLS server initialization */
429
ret = gnutls_dh_params_init(&mc->dh_params);
430
if (ret != GNUTLS_E_SUCCESS) {
431
fprintf (stderr, "Error in GnuTLS DH parameter initialization:"
432
" %s\n", safer_gnutls_strerror(ret));
435
ret = gnutls_dh_params_generate2(mc->dh_params, mc->dh_bits);
436
if (ret != GNUTLS_E_SUCCESS) {
437
fprintf (stderr, "Error in GnuTLS prime generation: %s\n",
438
safer_gnutls_strerror(ret));
442
gnutls_certificate_set_dh_params(mc->cred, mc->dh_params);
448
gnutls_certificate_free_credentials(mc->cred);
449
gnutls_global_deinit();
450
gnutls_dh_params_deinit(mc->dh_params);
454
static int init_gnutls_session(mandos_context *mc,
455
gnutls_session_t *session){
457
/* GnuTLS session creation */
458
ret = gnutls_init(session, GNUTLS_SERVER);
459
if (ret != GNUTLS_E_SUCCESS){
302
//GnuTLS server initialization
303
if ((ret = gnutls_dh_params_init (&es->dh_params))
304
!= GNUTLS_E_SUCCESS) {
305
fprintf (stderr, "Error in dh parameter initialization: %s\n",
306
safer_gnutls_strerror(ret));
310
if ((ret = gnutls_dh_params_generate2 (es->dh_params, DH_BITS))
311
!= GNUTLS_E_SUCCESS) {
312
fprintf (stderr, "Error in prime generation: %s\n",
313
safer_gnutls_strerror(ret));
317
gnutls_certificate_set_dh_params (es->cred, es->dh_params);
319
// GnuTLS session creation
320
if ((ret = gnutls_init (&es->session, GNUTLS_SERVER))
321
!= GNUTLS_E_SUCCESS){
460
322
fprintf(stderr, "Error in GnuTLS session initialization: %s\n",
461
323
safer_gnutls_strerror(ret));
466
ret = gnutls_priority_set_direct(*session, mc->priority, &err);
467
if (ret != GNUTLS_E_SUCCESS) {
468
fprintf(stderr, "Syntax error at: %s\n", err);
469
fprintf(stderr, "GnuTLS error: %s\n",
470
safer_gnutls_strerror(ret));
471
gnutls_deinit (*session);
326
if ((ret = gnutls_priority_set_direct (es->session, mc->priority, &err))
327
!= GNUTLS_E_SUCCESS) {
328
fprintf(stderr, "Syntax error at: %s\n", err);
329
fprintf(stderr, "GnuTLS error: %s\n",
330
safer_gnutls_strerror(ret));
476
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
478
if (ret != GNUTLS_E_SUCCESS) {
479
fprintf(stderr, "Error setting GnuTLS credentials: %s\n",
334
if ((ret = gnutls_credentials_set
335
(es->session, GNUTLS_CRD_CERTIFICATE, es->cred))
336
!= GNUTLS_E_SUCCESS) {
337
fprintf(stderr, "Error setting a credentials set: %s\n",
480
338
safer_gnutls_strerror(ret));
481
gnutls_deinit (*session);
485
342
/* ignore client certificate if any. */
486
gnutls_certificate_server_set_request (*session,
343
gnutls_certificate_server_set_request (es->session,
487
344
GNUTLS_CERT_IGNORE);
489
gnutls_dh_set_prime_bits (*session, mc->dh_bits);
346
gnutls_dh_set_prime_bits (es->session, DH_BITS);
494
/* Avahi log function callback */
495
351
static void empty_log(__attribute__((unused)) AvahiLogLevel level,
496
352
__attribute__((unused)) const char *txt){}
498
/* Called when a Mandos server is found */
499
354
static int start_mandos_communication(const char *ip, uint16_t port,
500
355
AvahiIfIndex if_index,
501
356
mandos_context *mc){
503
union { struct sockaddr in; struct sockaddr_in6 in6; } to;
358
struct sockaddr_in6 to;
359
encrypted_session es;
504
360
char *buffer = NULL;
505
361
char *decrypted_buffer;
506
362
size_t buffer_length = 0;
507
363
size_t buffer_capacity = 0;
508
364
ssize_t decrypted_buffer_size;
511
367
char interface[IF_NAMESIZE];
512
gnutls_session_t session;
514
ret = init_gnutls_session (mc, &session);
520
fprintf(stderr, "Setting up a tcp connection to %s, port %" PRIu16
370
fprintf(stderr, "Setting up a tcp connection to %s, port %d\n",
524
374
tcp_sd = socket(PF_INET6, SOCK_STREAM, 0);
526
376
perror("socket");
531
381
if(if_indextoname((unsigned int)if_index, interface) == NULL){
532
perror("if_indextoname");
383
perror("if_indextoname");
535
388
fprintf(stderr, "Binding to interface %s\n", interface);
538
memset(&to, 0, sizeof(to));
539
to.in6.sin6_family = AF_INET6;
540
/* It would be nice to have a way to detect if we were passed an
541
IPv4 address here. Now we assume an IPv6 address. */
542
ret = inet_pton(AF_INET6, ip, &to.in6.sin6_addr);
391
memset(&to,0,sizeof(to)); /* Spurious warning */
392
to.sin6_family = AF_INET6;
393
ret = inet_pton(AF_INET6, ip, &to.sin6_addr);
544
395
perror("inet_pton");
548
399
fprintf(stderr, "Bad address: %s\n", ip);
551
to.in6.sin6_port = htons(port); /* Spurious warning */
402
to.sin6_port = htons(port); /* Spurious warning */
553
to.in6.sin6_scope_id = (uint32_t)if_index;
404
to.sin6_scope_id = (uint32_t)if_index;
556
fprintf(stderr, "Connection to: %s, port %" PRIu16 "\n", ip,
558
char addrstr[INET6_ADDRSTRLEN] = "";
559
if(inet_ntop(to.in6.sin6_family, &(to.in6.sin6_addr), addrstr,
560
sizeof(addrstr)) == NULL){
563
if(strcmp(addrstr, ip) != 0){
564
fprintf(stderr, "Canonical address form: %s\n", addrstr);
407
fprintf(stderr, "Connection to: %s, port %d\n", ip, port);
408
/* char addrstr[INET6_ADDRSTRLEN]; */
409
/* if(inet_ntop(to.sin6_family, &(to.sin6_addr), addrstr, */
410
/* sizeof(addrstr)) == NULL){ */
411
/* perror("inet_ntop"); */
413
/* fprintf(stderr, "Really connecting to: %s, port %d\n", */
414
/* addrstr, ntohs(to.sin6_port)); */
569
ret = connect(tcp_sd, &to.in, sizeof(to));
418
ret = connect(tcp_sd, (struct sockaddr *) &to, sizeof(to));
571
420
perror("connect");
575
const char *out = mandos_protocol_version;
578
size_t out_size = strlen(out);
579
ret = TEMP_FAILURE_RETRY(write(tcp_sd, out + written,
580
out_size - written));
586
written += (size_t)ret;
587
if(written < out_size){
590
if (out == mandos_protocol_version){
424
ret = initgnutls (&es);
430
gnutls_transport_set_ptr (es.session,
431
(gnutls_transport_ptr_t) tcp_sd);
600
434
fprintf(stderr, "Establishing TLS session with %s\n", ip);
603
gnutls_transport_set_ptr (session, (gnutls_transport_ptr_t) tcp_sd);
606
ret = gnutls_handshake (session);
607
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
437
ret = gnutls_handshake (es.session);
609
439
if (ret != GNUTLS_E_SUCCESS){
611
fprintf(stderr, "*** GnuTLS Handshake failed ***\n");
441
fprintf(stderr, "\n*** Handshake failed ***\n");
612
442
gnutls_perror (ret);
618
/* Read OpenPGP packet that contains the wanted password */
448
//Retrieve OpenPGP packet that contains the wanted password
621
451
fprintf(stderr, "Retrieving pgp encrypted password from %s\n",
626
buffer_capacity = adjustbuffer(&buffer, buffer_length,
628
if (buffer_capacity == 0){
629
perror("adjustbuffer");
456
if (buffer_length + BUFFER_SIZE > buffer_capacity){
457
buffer = realloc(buffer, buffer_capacity + BUFFER_SIZE);
462
buffer_capacity += BUFFER_SIZE;
634
ret = gnutls_record_recv(session, buffer+buffer_length,
465
ret = gnutls_record_recv
466
(es.session, buffer+buffer_length, BUFFER_SIZE);
777
599
case AVAHI_BROWSER_FAILURE:
779
fprintf(stderr, "(Avahi browser) %s\n",
601
fprintf(stderr, "(Browser) %s\n",
780
602
avahi_strerror(avahi_server_errno(mc->server)));
781
603
avahi_simple_poll_quit(mc->simple_poll);
784
606
case AVAHI_BROWSER_NEW:
785
/* We ignore the returned Avahi resolver object. In the callback
786
function we free it. If the Avahi server is terminated before
787
the callback function is called the Avahi server will free the
790
if (!(avahi_s_service_resolver_new(mc->server, interface,
791
protocol, name, type, domain,
607
/* We ignore the returned resolver object. In the callback
608
function we free it. If the server is terminated before
609
the callback function is called the server will free
610
the resolver for us. */
612
if (!(avahi_s_service_resolver_new(mc->server, interface, protocol, name,
792
614
AVAHI_PROTO_INET6, 0,
793
615
resolve_callback, mc)))
794
fprintf(stderr, "Avahi: Failed to resolve service '%s': %s\n",
795
name, avahi_strerror(avahi_server_errno(mc->server)));
616
fprintf(stderr, "Failed to resolve service '%s': %s\n", name,
617
avahi_strerror(avahi_server_errno(s)));
798
620
case AVAHI_BROWSER_REMOVE:
801
623
case AVAHI_BROWSER_ALL_FOR_NOW:
802
624
case AVAHI_BROWSER_CACHE_EXHAUSTED:
804
fprintf(stderr, "No Mandos server found, still searching...\n");
810
int main(int argc, char *argv[]){
629
/* Combines file name and path and returns the malloced new
630
string. some sane checks could/should be added */
631
static const char *combinepath(const char *first, const char *second){
632
size_t f_len = strlen(first);
633
size_t s_len = strlen(second);
634
char *tmp = malloc(f_len + s_len + 2);
639
memcpy(tmp, first, f_len);
643
memcpy(tmp + f_len + 1, second, s_len);
645
tmp[f_len + 1 + s_len] = '\0';
650
int main(AVAHI_GCC_UNUSED int argc, AVAHI_GCC_UNUSED char*argv[]) {
651
AvahiServerConfig config;
811
652
AvahiSServiceBrowser *sb = NULL;
814
int exitcode = EXIT_SUCCESS;
655
int returncode = EXIT_SUCCESS;
815
656
const char *interface = "eth0";
816
657
struct ifreq network;
820
659
char *connect_to = NULL;
821
char tempdir[] = "/tmp/mandosXXXXXX";
822
660
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
823
const char *seckey = PATHDIR "/" SECKEY;
824
const char *pubkey = PATHDIR "/" PUBKEY;
826
661
mandos_context mc = { .simple_poll = NULL, .server = NULL,
827
.dh_bits = 1024, .priority = "SECURE256"
828
":!CTYPE-X.509:+CTYPE-OPENPGP" };
829
bool gnutls_initalized = false;
830
bool gpgme_initalized = false;
662
.dh_bits = 2048, .priority = "SECURE256"};
833
struct argp_option options[] = {
834
{ .name = "debug", .key = 128,
835
.doc = "Debug mode", .group = 3 },
836
{ .name = "connect", .key = 'c',
837
.arg = "ADDRESS:PORT",
838
.doc = "Connect directly to a specific Mandos server",
840
{ .name = "interface", .key = 'i',
842
.doc = "Interface that will be used to search for Mandos"
845
{ .name = "seckey", .key = 's',
847
.doc = "OpenPGP secret key file base name",
849
{ .name = "pubkey", .key = 'p',
851
.doc = "OpenPGP public key file base name",
853
{ .name = "dh-bits", .key = 129,
855
.doc = "Bit length of the prime number used in the"
856
" Diffie-Hellman key exchange",
858
{ .name = "priority", .key = 130,
860
.doc = "GnuTLS priority string for the TLS handshake",
865
error_t parse_opt (int key, char *arg,
866
struct argp_state *state) {
867
/* Get the INPUT argument from `argp_parse', which we know is
868
a pointer to our plugin list pointer. */
870
case 128: /* --debug */
873
case 'c': /* --connect */
876
case 'i': /* --interface */
879
case 's': /* --seckey */
882
case 'p': /* --pubkey */
885
case 129: /* --dh-bits */
665
static struct option long_options[] = {
666
{"debug", no_argument, (int *)&debug, 1},
667
{"connect", required_argument, 0, 'C'},
668
{"interface", required_argument, 0, 'i'},
669
{"certdir", required_argument, 0, 'd'},
670
{"certkey", required_argument, 0, 'c'},
671
{"certfile", required_argument, 0, 'k'},
672
{"dh_bits", required_argument, 0, 'D'},
673
{"priority", required_argument, 0, 'p'},
676
int option_index = 0;
677
ret = getopt_long (argc, argv, "i:", long_options,
887
mc.dh_bits = (unsigned int) strtol(arg, NULL, 10);
706
tmp = strtol(optarg, NULL, 10);
707
if (errno == ERANGE){
889
708
perror("strtol");
890
709
exit(EXIT_FAILURE);
893
case 130: /* --priority */
901
return ARGP_ERR_UNKNOWN;
906
struct argp argp = { .options = options, .parser = parse_opt,
908
.doc = "Mandos client -- Get and decrypt"
909
" passwords from a Mandos server" };
910
ret = argp_parse (&argp, argc, argv, 0, 0, NULL);
911
if (ret == ARGP_ERR_UNKNOWN){
912
fprintf(stderr, "Unknown error while parsing arguments\n");
913
exitcode = EXIT_FAILURE;
918
/* If the interface is down, bring it up */
920
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
923
exitcode = EXIT_FAILURE;
926
strcpy(network.ifr_name, interface);
927
ret = ioctl(sd, SIOCGIFFLAGS, &network);
929
perror("ioctl SIOCGIFFLAGS");
930
exitcode = EXIT_FAILURE;
933
if((network.ifr_flags & IFF_UP) == 0){
934
network.ifr_flags |= IFF_UP;
935
ret = ioctl(sd, SIOCSIFFLAGS, &network);
937
perror("ioctl SIOCSIFFLAGS");
938
exitcode = EXIT_FAILURE;
942
ret = TEMP_FAILURE_RETRY(close(sd));
961
ret = init_gnutls_global(&mc, pubkey, seckey);
963
fprintf(stderr, "init_gnutls_global failed\n");
964
exitcode = EXIT_FAILURE;
967
gnutls_initalized = true;
970
if(mkdtemp(tempdir) == NULL){
976
if(not init_gpgme(&mc, pubkey, seckey, tempdir)){
977
fprintf(stderr, "gpgme_initalized failed\n");
978
exitcode = EXIT_FAILURE;
981
gpgme_initalized = true;
715
mc.priority = optarg;
722
certfile = combinepath(certdir, certfile);
723
if (certfile == NULL){
724
perror("combinepath");
725
returncode = EXIT_FAILURE;
729
certkey = combinepath(certdir, certkey);
730
if (certkey == NULL){
731
perror("combinepath");
732
returncode = EXIT_FAILURE;
984
736
if_index = (AvahiIfIndex) if_nametoindex(interface);
993
745
char *address = strrchr(connect_to, ':');
994
746
if(address == NULL){
995
747
fprintf(stderr, "No colon in address\n");
996
exitcode = EXIT_FAILURE;
1000
751
uint16_t port = (uint16_t) strtol(address+1, NULL, 10);
1002
753
perror("Bad port number");
1003
exitcode = EXIT_FAILURE;
1006
756
*address = '\0';
1007
757
address = connect_to;
1008
ret = start_mandos_communication(address, port, if_index, &mc);
758
ret = start_mandos_communication(address, port, if_index);
1010
exitcode = EXIT_FAILURE;
1012
exitcode = EXIT_SUCCESS;
766
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
769
returncode = EXIT_FAILURE;
772
strcpy(network.ifr_name, interface);
773
ret = ioctl(sd, SIOCGIFFLAGS, &network);
776
perror("ioctl SIOCGIFFLAGS");
777
returncode = EXIT_FAILURE;
780
if((network.ifr_flags & IFF_UP) == 0){
781
network.ifr_flags |= IFF_UP;
782
ret = ioctl(sd, SIOCSIFFLAGS, &network);
784
perror("ioctl SIOCSIFFLAGS");
785
returncode = EXIT_FAILURE;
1018
792
avahi_set_log_function(empty_log);
1021
/* Initialize the pseudo-RNG for Avahi */
795
/* Initialize the psuedo-RNG */
1022
796
srand((unsigned int) time(NULL));
1024
/* Allocate main Avahi loop object */
1025
mc.simple_poll = avahi_simple_poll_new();
1026
if (mc.simple_poll == NULL) {
1027
fprintf(stderr, "Avahi: Failed to create simple poll"
1029
exitcode = EXIT_FAILURE;
1034
AvahiServerConfig config;
1035
/* Do not publish any local Zeroconf records */
1036
avahi_server_config_init(&config);
1037
config.publish_hinfo = 0;
1038
config.publish_addresses = 0;
1039
config.publish_workstation = 0;
1040
config.publish_domain = 0;
1042
/* Allocate a new server */
1043
mc.server = avahi_server_new(avahi_simple_poll_get
1044
(mc.simple_poll), &config, NULL,
1047
/* Free the Avahi configuration data */
1048
avahi_server_config_free(&config);
1051
/* Check if creating the Avahi server object succeeded */
1052
if (mc.server == NULL) {
1053
fprintf(stderr, "Failed to create Avahi server: %s\n",
798
/* Allocate main loop object */
799
if (!(mc.simple_poll = avahi_simple_poll_new())) {
800
fprintf(stderr, "Failed to create simple poll object.\n");
801
returncode = EXIT_FAILURE;
805
/* Do not publish any local records */
806
avahi_server_config_init(&config);
807
config.publish_hinfo = 0;
808
config.publish_addresses = 0;
809
config.publish_workstation = 0;
810
config.publish_domain = 0;
812
/* Allocate a new server */
813
mc.server = avahi_server_new(avahi_simple_poll_get(simple_poll),
814
&config, NULL, NULL, &error);
816
/* Free the configuration data */
817
avahi_server_config_free(&config);
819
/* Check if creating the server object succeeded */
821
fprintf(stderr, "Failed to create server: %s\n",
1054
822
avahi_strerror(error));
1055
exitcode = EXIT_FAILURE;
823
returncode = EXIT_FAILURE;
1059
/* Create the Avahi service browser */
827
/* Create the service browser */
1060
828
sb = avahi_s_service_browser_new(mc.server, if_index,
1061
829
AVAHI_PROTO_INET6,
1062
830
"_mandos._tcp", NULL, 0,
1063
831
browse_callback, &mc);
1065
833
fprintf(stderr, "Failed to create service browser: %s\n",
1066
834
avahi_strerror(avahi_server_errno(mc.server)));
1067
exitcode = EXIT_FAILURE;
835
returncode = EXIT_FAILURE;
1071
839
/* Run the main loop */
1074
fprintf(stderr, "Starting Avahi loop search\n");
842
fprintf(stderr, "Starting avahi loop search\n");
1077
avahi_simple_poll_loop(mc.simple_poll);
845
avahi_simple_poll_loop(simple_poll);
1082
850
fprintf(stderr, "%s exiting\n", argv[0]);
1085
853
/* Cleanup things */
1087
855
avahi_s_service_browser_free(sb);
1089
if (mc.server != NULL)
1090
858
avahi_server_free(mc.server);
1092
if (mc.simple_poll != NULL)
1093
avahi_simple_poll_free(mc.simple_poll);
1095
if (gnutls_initalized){
1096
gnutls_certificate_free_credentials(mc.cred);
1097
gnutls_global_deinit ();
1098
gnutls_dh_params_deinit(mc.dh_params);
1101
if(gpgme_initalized){
1102
gpgme_release(mc.ctx);
1105
/* Removes the temp directory used by GPGME */
1106
if(tempdir[0] != '\0'){
1108
struct dirent *direntry;
1109
d = opendir(tempdir);
1114
direntry = readdir(d);
1115
if(direntry == NULL){
1118
if (direntry->d_type == DT_REG){
1119
char *fullname = NULL;
1120
ret = asprintf(&fullname, "%s/%s", tempdir,
1126
ret = unlink(fullname);
1128
fprintf(stderr, "unlink(\"%s\"): %s",
1129
fullname, strerror(errno));
1136
ret = rmdir(tempdir);
861
avahi_simple_poll_free(simple_poll);