/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

Merge from Björn:

* mandos-ctl: New option "--remove-client".  Only default to listing
              clients if no clients were given on the command line.
* plugins.d/mandos-client.c: Lower kernel log level while bringing up
                             network interface.  New option "--delay"
                             to control the maximum delay to wait for
                             running interface.
* plugins.d/mandos-client.xml (SYNOPSIS, OPTIONS): New option
                                                   "--delay".

Show diffs side-by-side

added added

removed removed

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