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