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