/mandos/trunk

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/mandos-client.c

  • Committer: Teddy Hogeborn
  • Date: 2008-12-10 01:26:02 UTC
  • mfrom: (237.1.2 mandos)
  • Revision ID: teddy@fukt.bsnet.se-20081210012602-vhz3h75xkj24t340
First version of a somewhat complete D-Bus server interface.  Also
change user/group name to "_mandos".

* debian/mandos.postinst: Rename old "mandos" user and group to
                          "_mandos"; create "_mandos" user and group
                          if none exist.
* debian/mandos-client.postinst: - '' -

* initramfs-tools-hook: Try "_mandos" before "mandos" as user and
                        group name.

* mandos (_datetime_to_dbus_struct): New; was previously local.
  (Client.started): Renamed to "last_started".  All users changed.
  (Client.started): New; boolean.
  (Client.dbus_object_path): New.
  (Client.check_command): Renamed to "checker_command".  All users
                          changed.
  (Client.__init__): Set and use "self.dbus_object_path".  Set
                     "self.started".
  (Client.start): Update "self.started".  Emit "self.PropertyChanged"
                  signals for both "started" and "last_started".
  (Client.stop): Update "self.started".  Emit "self.PropertyChanged"
                 signal for "started".
  (Client.checker_callback): Take additional "command" argument.  All
                             callers changed. Emit
                             "self.PropertyChanged" signal.
  (Client.bump_timeout): Emit "self.PropertyChanged" signal for
                         "last_checked_ok".
  (Client.start_checker): Emit "self.PropertyChanged" signal for
                          "checker_running".
  (Client.stop_checker): Emit "self.PropertyChanged" signal for
                         "checker_running".
  (Client.still_valid): Bug fix: use "getattr(self, started, False)"
                        instead of "self.started" in case this client
                        object is so new that the "started" attribute
                        has not been created yet.
  (Client.IntervalChanged, Client.CheckerIsRunning, Client.GetChecker,
  Client.GetCreated, Client.GetFingerprint, Client.GetHost,
  Client.GetInterval, Client.GetName, Client.GetStarted,
  Client.GetTimeout, Client.StateChanged, Client.TimeoutChanged):
  Removed; all callers changed.
  (Client.CheckerCompleted): Add "condition" and "command" arguments.
                             All callers changed.
  (Client.GetAllProperties, Client.PropertyChanged): New.
  (Client.StillValid): Renamed to "IsStillValid".
  (Client.StartChecker): Changed to its own function to avoid the
                         return value from "Client.start_checker()".
  (Client.Stop): Changed to its own function to avoid the return value
                 from "Client.stop()".
  (main): Try "_mandos" before "mandos" as user and group name.
          Removed inner function "remove_from_clients".  New inner
          class "MandosServer".

Show diffs side-by-side

added added

removed removed

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