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

  • Committer: Teddy Hogeborn
  • Date: 2008-09-30 07:23:39 UTC
  • Revision ID: teddy@fukt.bsnet.se-20080930072339-jn15gyrtfpdk2dhx
* .bzrignore: Added "man" directory (created by "make install-html").

* Makefile: Add "common.ent" dependency to all manual pages.
  (htmldir, version, SED): New variables.
  (CFLAGS): Add -D option to define VERSION to $(version).
  (MANPOST, HTMLPOST): Use $(SED).
  (PROGS): Use $(CPROGS)
  (CPROGS): New; C-only programs.
  (objects): Use $(CPROGS).
  (common.ent, mandos, mandos-keygen): New targets; update version
                                       number to $(version).
  (clean): Use $(CPROGS).
  (check): Depend on "all".
  (install-html): Install to $(htmldir).

* common.ent: New file with "version" entity.

* mandos-clients.conf.xml: Use "common.ent".
* mandos-keygen.xml: - '' -
* mandos.conf.xml: - '' -
* mandos.xml: - '' -
* plugin-runner.xml: - '' -
* plugins.d/mandos-client.xml: - '' -
* plugins.d/password-prompt.xml: - '' -

* plugin-runner.c (argp_program_version): Use VERSION.
* plugins.d/mandos-client.c (argp_program_version): - '' -
* plugins.d/password-prompt.c (argp_program_version): - '' -

Show diffs side-by-side

added added

removed removed

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