/mandos/release

To get this branch, use:
bzr branch http://bzr.recompile.se/loggerhead/mandos/release

« back to all changes in this revision

Viewing changes to plugins.d/password-request.c

  • Committer: Teddy Hogeborn
  • Date: 2008-08-09 04:56:00 UTC
  • mfrom: (24.1.27 mandos)
  • Revision ID: teddy@fukt.bsnet.se-20080809045600-m7jx3tj4wwunaffa
Merge.

Show diffs side-by-side

added added

removed removed

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