/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/mandosclient.c

merge

Show diffs side-by-side

added added

removed removed

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