/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

  • Committer: Teddy Hogeborn
  • Date: 2008-07-22 06:23:29 UTC
  • Revision ID: teddy@fukt.bsnet.se-20080722062329-jaex5y5mslf6sqjx
* mandos-clients.conf ([DEFAULT]): New section.

* plugins.d/mandosclient.c (start_mandos_communication): Only print if
                                                         debugging.
                                                         Print server
                                                         name.
                                                         Bug fix: Loop
                                                         until suc-
                                                         cess.

* server.py (serverName): Set via option, not globally.
  (Client.__init__): Removed argument "options".  Require "timeout"
                     and "interval" arguments.
  (tcp_handler.handle): Set "priority" from self.server.options.
  (main): Removed "--timeout" and "--interval" options.  New options
          "--priority" and "--servicename".  Add defaults for
          "timeout" and "interval".  Set "serviceName" from options.
          Do not pass "options" to "Client()".

Show diffs side-by-side

added added

removed removed

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