/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/password-request.c

  • Committer: Teddy Hogeborn
  • Date: 2008-08-07 22:30:45 UTC
  • Revision ID: teddy@fukt.bsnet.se-20080807223045-58y7vw4bcqlmesv5
* network-protocol.txt: Flip table.

Show diffs side-by-side

added added

removed removed

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