To get this branch, use:
bzr branch
http://bzr.recompile.se/loggerhead/mandos/trunk
« back to all changes in this revision
Viewing changes to plugins.d/mandosclient.c
- browse files at revision 24.1.4
- compare with another revision
- download diff
- download tarball
- view history from revision 24.1.4
- Committer: Björn Påhlsson
- Date: 2008-07-30 02:11:33 UTC
- mto: (24.1.154 mandos) (237.4.3 mandos-release)
- mto: This revision was merged to the branch mainline in revision 30.
- Revision ID: belorn@braxen-20080730021133-q341llq93r328q5b
Added optional parameters certdir, certkey and certfile that can be iven at start in the command line.
- 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
8
8
* includes the following functions: "resolve_callback",
9
9
* "browse_callback", and parts of "main".
10
10
*
11
* Everything else is
12
* Copyright © 2008 Teddy Hogeborn & Björn Påhlsson
11
* Everything else is Copyright © 2007-2008 Teddy Hogeborn and Björn
12
* 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
25
25
* along with this program. If not, see
26
26
* <http://www.gnu.org/licenses/>.
27
27
*
28
* Contact the authors at <mandos@fukt.bsnet.se>.
28
* Contact the authors at <https://www.fukt.bsnet.se/~belorn/> and
29
* <https://www.fukt.bsnet.se/~teddy/>.
29
30
*/
30
31
31
/* Needed by GPGME, specifically gpgme_data_seek() */
32
#define _FORTIFY_SOURCE 2
33
32
34
#define _LARGEFILE_SOURCE
33
35
#define _FILE_OFFSET_BITS 64
34
36
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_* */
37
#include <stdio.h>
38
#include <assert.h>
39
#include <stdlib.h>
40
#include <time.h>
41
#include <net/if.h> /* if_nametoindex */
42
79
43
#include <avahi-core/core.h>
80
44
#include <avahi-core/lookup.h>
81
45
#include <avahi-core/log.h>
83
47
#include <avahi-common/malloc.h>
84
48
#include <avahi-common/error.h>
85
49
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_* */
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>
101
70
102
71
#define BUFFER_SIZE 256
72
#define DH_BITS 1024
103
73
104
#define PATHDIR "/conf/conf.d/mandos"
105
#define SECKEY "seckey.txt"
106
#define PUBKEY "pubkey.txt"
74
const char *certdir = "/conf/conf.d/cryptkeyreq/";
75
const char *certfile = "openpgp-client.txt";
76
const char *certkey = "openpgp-client-key.txt";
107
77
108
78
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>";
112
79
113
/* Used for passing in values through the Avahi callback functions */
114
80
typedef struct {
115
AvahiSimplePoll *simple_poll;
116
AvahiServer *server;
81
gnutls_session_t session;
117
82
gnutls_certificate_credentials_t cred;
118
unsigned int dh_bits;
119
83
gnutls_dh_params_t dh_params;
120
const char *priority;
84
} encrypted_session;
85
86
87
ssize_t pgp_packet_decrypt (char *packet, size_t packet_size,
88
char **new_packet, const char *homedir){
89
gpgme_data_t dh_crypto, dh_plain;
121
90
gpgme_ctx_t ctx;
122
} mandos_context;
123
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;
147
91
gpgme_error_t rc;
92
ssize_t ret;
93
ssize_t new_packet_capacity = 0;
94
ssize_t new_packet_length = 0;
148
95
gpgme_engine_info_t engine_info;
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
96
186
97
if (debug){
187
fprintf(stderr, "Initialize gpgme\n");
98
fprintf(stderr, "Trying to decrypt OpenPGP packet\n");
188
99
}
189
100
190
101
/* Init GPGME */
193
104
if (rc != GPG_ERR_NO_ERROR){
194
105
fprintf(stderr, "bad gpgme_engine_check_version: %s: %s\n",
195
106
gpgme_strsource(rc), gpgme_strerror(rc));
196
return false;
107
return -1;
197
108
}
198
109
199
/* Set GPGME home directory for the OpenPGP engine only */
110
/* Set GPGME home directory */
200
111
rc = gpgme_get_engine_info (&engine_info);
201
112
if (rc != GPG_ERR_NO_ERROR){
202
113
fprintf(stderr, "bad gpgme_get_engine_info: %s: %s\n",
203
114
gpgme_strsource(rc), gpgme_strerror(rc));
204
return false;
115
return -1;
205
116
}
206
117
while(engine_info != NULL){
207
118
if(engine_info->protocol == GPGME_PROTOCOL_OpenPGP){
208
119
gpgme_set_engine_info(GPGME_PROTOCOL_OpenPGP,
209
engine_info->file_name, tempdir);
120
engine_info->file_name, homedir);
210
121
break;
211
122
}
212
123
engine_info = engine_info->next;
213
124
}
214
125
if(engine_info == NULL){
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);
126
fprintf(stderr, "Could not set home dir to %s\n", homedir);
127
return -1;
128
}
129
130
/* Create new GPGME data buffer from packet buffer */
131
rc = gpgme_data_new_from_mem(&dh_crypto, packet, packet_size, 0);
255
132
if (rc != GPG_ERR_NO_ERROR){
256
133
fprintf(stderr, "bad gpgme_data_new_from_mem: %s: %s\n",
257
134
gpgme_strsource(rc), gpgme_strerror(rc));
263
140
if (rc != GPG_ERR_NO_ERROR){
264
141
fprintf(stderr, "bad gpgme_data_new: %s: %s\n",
265
142
gpgme_strsource(rc), gpgme_strerror(rc));
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);
143
return -1;
144
}
145
146
/* Create new GPGME "context" */
147
rc = gpgme_new(&ctx);
148
if (rc != GPG_ERR_NO_ERROR){
149
fprintf(stderr, "bad gpgme_new: %s: %s\n",
150
gpgme_strsource(rc), gpgme_strerror(rc));
151
return -1;
152
}
153
154
/* Decrypt data from the FILE pointer to the plaintext data
155
buffer */
156
rc = gpgme_op_decrypt(ctx, dh_crypto, dh_plain);
273
157
if (rc != GPG_ERR_NO_ERROR){
274
158
fprintf(stderr, "bad gpgme_op_decrypt: %s: %s\n",
275
159
gpgme_strsource(rc), gpgme_strerror(rc));
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
}
160
return -1;
161
}
162
163
if(debug){
164
fprintf(stderr, "Decryption of OpenPGP packet succeeded\n");
165
}
166
167
if (debug){
168
gpgme_decrypt_result_t result;
169
result = gpgme_op_decrypt_result(ctx);
170
if (result == NULL){
171
fprintf(stderr, "gpgme_op_decrypt_result failed\n");
172
} else {
173
fprintf(stderr, "Unsupported algorithm: %s\n",
174
result->unsupported_algorithm);
175
fprintf(stderr, "Wrong key usage: %d\n",
176
result->wrong_key_usage);
177
if(result->file_name != NULL){
178
fprintf(stderr, "File name: %s\n", result->file_name);
179
}
180
gpgme_recipient_t recipient;
181
recipient = result->recipients;
182
if(recipient){
183
while(recipient != NULL){
184
fprintf(stderr, "Public key algorithm: %s\n",
185
gpgme_pubkey_algo_name(recipient->pubkey_algo));
186
fprintf(stderr, "Key ID: %s\n", recipient->keyid);
187
fprintf(stderr, "Secret key available: %s\n",
188
recipient->status == GPG_ERR_NO_SECKEY
189
? "No" : "Yes");
190
recipient = recipient->next;
302
191
}
303
192
}
304
193
}
305
goto decrypt_end;
306
194
}
307
195
308
if(debug){
309
fprintf(stderr, "Decryption of OpenPGP data succeeded\n");
310
}
196
/* Delete the GPGME FILE pointer cryptotext data buffer */
197
gpgme_data_release(dh_crypto);
311
198
312
199
/* Seek back to the beginning of the GPGME plaintext data buffer */
313
if (gpgme_data_seek(dh_plain, (off_t) 0, SEEK_SET) == -1){
314
perror("gpgme_data_seek");
315
plaintext_length = -1;
316
goto decrypt_end;
317
}
318
319
*plaintext = NULL;
200
gpgme_data_seek(dh_plain, (off_t) 0, SEEK_SET);
201
202
*new_packet = 0;
320
203
while(true){
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;
204
if (new_packet_length + BUFFER_SIZE > new_packet_capacity){
205
*new_packet = realloc(*new_packet,
206
(unsigned int)new_packet_capacity
207
+ BUFFER_SIZE);
208
if (*new_packet == NULL){
209
perror("realloc");
210
return -1;
211
}
212
new_packet_capacity += BUFFER_SIZE;
328
213
}
329
214
330
ret = gpgme_data_read(dh_plain, *plaintext + plaintext_length,
215
ret = gpgme_data_read(dh_plain, *new_packet + new_packet_length,
331
216
BUFFER_SIZE);
332
217
/* Print the data, if any */
333
218
if (ret == 0){
334
/* EOF */
335
219
break;
336
220
}
337
221
if(ret < 0){
338
222
perror("gpgme_data_read");
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);
223
return -1;
224
}
225
new_packet_length += ret;
226
}
227
228
/* FIXME: check characters before printing to screen so to not print
229
terminal control characters */
230
/* if(debug){ */
231
/* fprintf(stderr, "decrypted password is: "); */
232
/* fwrite(*new_packet, 1, new_packet_length, stderr); */
233
/* fprintf(stderr, "\n"); */
234
/* } */
357
235
358
236
/* Delete the GPGME plaintext data buffer */
359
237
gpgme_data_release(dh_plain);
360
return plaintext_length;
238
return new_packet_length;
361
239
}
362
240
363
241
static const char * safer_gnutls_strerror (int value) {
364
const char *ret = gnutls_strerror (value); /* Spurious warning */
242
const char *ret = gnutls_strerror (value);
365
243
if (ret == NULL)
366
244
ret = "(unknown)";
367
245
return ret;
368
246
}
369
247
370
/* GnuTLS log function callback */
371
static void debuggnutls(__attribute__((unused)) int level,
372
const char* string){
373
fprintf(stderr, "GnuTLS: %s", string);
248
void debuggnutls(__attribute__((unused)) int level,
249
const char* string){
250
fprintf(stderr, "%s", string);
374
251
}
375
252
376
static int init_gnutls_global(mandos_context *mc,
377
const char *pubkeyfilename,
378
const char *seckeyfilename){
253
int initgnutls(encrypted_session *es){
254
const char *err;
379
255
int ret;
380
256
381
257
if(debug){
382
258
fprintf(stderr, "Initializing GnuTLS\n");
383
259
}
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));
260
261
if ((ret = gnutls_global_init ())
262
!= GNUTLS_E_SUCCESS) {
263
fprintf (stderr, "global_init: %s\n", safer_gnutls_strerror(ret));
389
264
return -1;
390
265
}
391
266
392
267
if (debug){
393
/* "Use a log level over 10 to enable all debugging options."
394
* - GnuTLS manual
395
*/
396
268
gnutls_global_set_log_level(11);
397
269
gnutls_global_set_log_function(debuggnutls);
398
270
}
399
271
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 */
272
/* openpgp credentials */
273
if ((ret = gnutls_certificate_allocate_credentials (&es->cred))
274
!= GNUTLS_E_SUCCESS) {
275
fprintf (stderr, "memory error: %s\n",
405
276
safer_gnutls_strerror(ret));
406
gnutls_global_deinit ();
407
277
return -1;
408
278
}
409
279
410
280
if(debug){
411
fprintf(stderr, "Attempting to use OpenPGP public key %s and"
412
" secret key %s as GnuTLS credentials\n", pubkeyfilename,
413
seckeyfilename);
281
fprintf(stderr, "Attempting to use OpenPGP certificate %s"
282
" and keyfile %s as GnuTLS credentials\n", certfile,
283
certkey);
414
284
}
415
285
416
286
ret = gnutls_certificate_set_openpgp_key_file
417
(mc->cred, pubkeyfilename, seckeyfilename,
418
GNUTLS_OPENPGP_FMT_BASE64);
287
(es->cred, certfile, certkey, GNUTLS_OPENPGP_FMT_BASE64);
419
288
if (ret != GNUTLS_E_SUCCESS) {
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",
289
fprintf
290
(stderr, "Error[%d] while reading the OpenPGP key pair ('%s',"
291
" '%s')\n",
292
ret, certfile, certkey);
293
fprintf(stdout, "The Error is: %s\n",
424
294
safer_gnutls_strerror(ret));
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){
295
return -1;
296
}
297
298
//GnuTLS server initialization
299
if ((ret = gnutls_dh_params_init (&es->dh_params))
300
!= GNUTLS_E_SUCCESS) {
301
fprintf (stderr, "Error in dh parameter initialization: %s\n",
302
safer_gnutls_strerror(ret));
303
return -1;
304
}
305
306
if ((ret = gnutls_dh_params_generate2 (es->dh_params, DH_BITS))
307
!= GNUTLS_E_SUCCESS) {
308
fprintf (stderr, "Error in prime generation: %s\n",
309
safer_gnutls_strerror(ret));
310
return -1;
311
}
312
313
gnutls_certificate_set_dh_params (es->cred, es->dh_params);
314
315
// GnuTLS session creation
316
if ((ret = gnutls_init (&es->session, GNUTLS_SERVER))
317
!= GNUTLS_E_SUCCESS){
460
318
fprintf(stderr, "Error in GnuTLS session initialization: %s\n",
461
319
safer_gnutls_strerror(ret));
462
320
}
463
321
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
}
322
if ((ret = gnutls_priority_set_direct (es->session, "NORMAL", &err))
323
!= GNUTLS_E_SUCCESS) {
324
fprintf(stderr, "Syntax error at: %s\n", err);
325
fprintf(stderr, "GnuTLS error: %s\n",
326
safer_gnutls_strerror(ret));
327
return -1;
474
328
}
475
329
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",
330
if ((ret = gnutls_credentials_set
331
(es->session, GNUTLS_CRD_CERTIFICATE, es->cred))
332
!= GNUTLS_E_SUCCESS) {
333
fprintf(stderr, "Error setting a credentials set: %s\n",
480
334
safer_gnutls_strerror(ret));
481
gnutls_deinit (*session);
482
335
return -1;
483
336
}
484
337
485
338
/* ignore client certificate if any. */
486
gnutls_certificate_server_set_request (*session,
339
gnutls_certificate_server_set_request (es->session,
487
340
GNUTLS_CERT_IGNORE);
488
341
489
gnutls_dh_set_prime_bits (*session, mc->dh_bits);
342
gnutls_dh_set_prime_bits (es->session, DH_BITS);
490
343
491
344
return 0;
492
345
}
493
346
494
/* Avahi log function callback */
495
static void empty_log(__attribute__((unused)) AvahiLogLevel level,
496
__attribute__((unused)) const char *txt){}
347
void empty_log(__attribute__((unused)) AvahiLogLevel level,
348
__attribute__((unused)) const char *txt){}
497
349
498
/* Called when a Mandos server is found */
499
static int start_mandos_communication(const char *ip, uint16_t port,
500
AvahiIfIndex if_index,
501
mandos_context *mc){
350
int start_mandos_communication(const char *ip, uint16_t port,
351
unsigned int if_index){
502
352
int ret, tcp_sd;
503
union { struct sockaddr in; struct sockaddr_in6 in6; } to;
353
struct sockaddr_in6 to;
354
encrypted_session es;
504
355
char *buffer = NULL;
505
356
char *decrypted_buffer;
506
357
size_t buffer_length = 0;
507
358
size_t buffer_capacity = 0;
508
359
ssize_t decrypted_buffer_size;
509
size_t written;
360
size_t written = 0;
510
361
int retval = 0;
511
362
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
}
518
363
519
364
if(debug){
520
fprintf(stderr, "Setting up a tcp connection to %s, port %" PRIu16
521
"\n", ip, port);
365
fprintf(stderr, "Setting up a tcp connection to %s\n", ip);
522
366
}
523
367
524
368
tcp_sd = socket(PF_INET6, SOCK_STREAM, 0);
527
371
return -1;
528
372
}
529
373
530
if(debug){
531
if(if_indextoname((unsigned int)if_index, interface) == NULL){
374
if(if_indextoname(if_index, interface) == NULL){
375
if(debug){
532
376
perror("if_indextoname");
533
return -1;
534
377
}
378
return -1;
379
}
380
381
if(debug){
535
382
fprintf(stderr, "Binding to interface %s\n", interface);
536
383
}
537
384
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);
385
memset(&to,0,sizeof(to)); /* Spurious warning */
386
to.sin6_family = AF_INET6;
387
ret = inet_pton(AF_INET6, ip, &to.sin6_addr);
543
388
if (ret < 0 ){
544
389
perror("inet_pton");
545
390
return -1;
546
}
391
}
547
392
if(ret == 0){
548
393
fprintf(stderr, "Bad address: %s\n", ip);
549
394
return -1;
550
395
}
551
to.in6.sin6_port = htons(port); /* Spurious warning */
396
to.sin6_port = htons(port); /* Spurious warning */
552
397
553
to.in6.sin6_scope_id = (uint32_t)if_index;
398
to.sin6_scope_id = (uint32_t)if_index;
554
399
555
400
if(debug){
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
}
401
fprintf(stderr, "Connection to: %s\n", ip);
567
402
}
568
403
569
ret = connect(tcp_sd, &to.in, sizeof(to));
404
ret = connect(tcp_sd, (struct sockaddr *) &to, sizeof(to));
570
405
if (ret < 0){
571
406
perror("connect");
572
407
return -1;
573
408
}
574
409
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
}
410
ret = initgnutls (&es);
411
if (ret != 0){
412
retval = -1;
413
return -1;
597
414
}
598
415
416
gnutls_transport_set_ptr (es.session,
417
(gnutls_transport_ptr_t) tcp_sd);
418
599
419
if(debug){
600
420
fprintf(stderr, "Establishing TLS session with %s\n", ip);
601
421
}
602
422
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);
423
ret = gnutls_handshake (es.session);
608
424
609
425
if (ret != GNUTLS_E_SUCCESS){
610
426
if(debug){
611
fprintf(stderr, "*** GnuTLS Handshake failed ***\n");
427
fprintf(stderr, "\n*** Handshake failed ***\n");
612
428
gnutls_perror (ret);
613
429
}
614
430
retval = -1;
615
goto mandos_end;
431
goto exit;
616
432
}
617
433
618
/* Read OpenPGP packet that contains the wanted password */
434
//Retrieve OpenPGP packet that contains the wanted password
619
435
620
436
if(debug){
621
437
fprintf(stderr, "Retrieving pgp encrypted password from %s\n",
622
438
ip);
623
439
}
624
440
625
441
while(true){
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;
442
if (buffer_length + BUFFER_SIZE > buffer_capacity){
443
buffer = realloc(buffer, buffer_capacity + BUFFER_SIZE);
444
if (buffer == NULL){
445
perror("realloc");
446
goto exit;
447
}
448
buffer_capacity += BUFFER_SIZE;
632
449
}
633
450
634
ret = gnutls_record_recv(session, buffer+buffer_length,
635
BUFFER_SIZE);
451
ret = gnutls_record_recv
452
(es.session, buffer+buffer_length, BUFFER_SIZE);
636
453
if (ret == 0){
637
454
break;
638
455
}
642
459
case GNUTLS_E_AGAIN:
643
460
break;
644
461
case GNUTLS_E_REHANDSHAKE:
645
do{
646
ret = gnutls_handshake (session);
647
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
462
ret = gnutls_handshake (es.session);
648
463
if (ret < 0){
649
fprintf(stderr, "*** GnuTLS Re-handshake failed ***\n");
464
fprintf(stderr, "\n*** Handshake failed ***\n");
650
465
gnutls_perror (ret);
651
466
retval = -1;
652
goto mandos_end;
467
goto exit;
653
468
}
654
469
break;
655
470
default:
656
471
fprintf(stderr, "Unknown error while reading data from"
657
" encrypted session with Mandos server\n");
472
" encrypted session with mandos server\n");
658
473
retval = -1;
659
gnutls_bye (session, GNUTLS_SHUT_RDWR);
660
goto mandos_end;
474
gnutls_bye (es.session, GNUTLS_SHUT_RDWR);
475
goto exit;
661
476
}
662
477
} else {
663
478
buffer_length += (size_t) ret;
664
479
}
665
480
}
666
481
667
if(debug){
668
fprintf(stderr, "Closing TLS session\n");
669
}
670
671
gnutls_bye (session, GNUTLS_SHUT_RDWR);
672
673
482
if (buffer_length > 0){
674
decrypted_buffer_size = pgp_packet_decrypt(mc, buffer,
483
decrypted_buffer_size = pgp_packet_decrypt(buffer,
675
484
buffer_length,
676
&decrypted_buffer);
485
&decrypted_buffer,
486
certdir);
677
487
if (decrypted_buffer_size >= 0){
678
written = 0;
679
while(written < (size_t) decrypted_buffer_size){
488
while(written < decrypted_buffer_size){
680
489
ret = (int)fwrite (decrypted_buffer + written, 1,
681
490
(size_t)decrypted_buffer_size - written,
682
491
stdout);
694
503
} else {
695
504
retval = -1;
696
505
}
697
} else {
698
retval = -1;
699
}
700
701
/* Shutdown procedure */
702
703
mandos_end:
506
}
507
508
//shutdown procedure
509
510
if(debug){
511
fprintf(stderr, "Closing TLS session\n");
512
}
513
704
514
free(buffer);
705
ret = TEMP_FAILURE_RETRY(close(tcp_sd));
706
if(ret == -1){
707
perror("close");
708
}
709
gnutls_deinit (session);
515
gnutls_bye (es.session, GNUTLS_SHUT_RDWR);
516
exit:
517
close(tcp_sd);
518
gnutls_deinit (es.session);
519
gnutls_certificate_free_credentials (es.cred);
520
gnutls_global_deinit ();
710
521
return retval;
711
522
}
712
523
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) {
727
mandos_context *mc = userdata;
728
assert(r);
524
static AvahiSimplePoll *simple_poll = NULL;
525
static AvahiServer *server = NULL;
526
527
static void resolve_callback(
528
AvahiSServiceResolver *r,
529
AvahiIfIndex interface,
530
AVAHI_GCC_UNUSED AvahiProtocol protocol,
531
AvahiResolverEvent event,
532
const char *name,
533
const char *type,
534
const char *domain,
535
const char *host_name,
536
const AvahiAddress *address,
537
uint16_t port,
538
AVAHI_GCC_UNUSED AvahiStringList *txt,
539
AVAHI_GCC_UNUSED AvahiLookupResultFlags flags,
540
AVAHI_GCC_UNUSED void* userdata) {
541
542
assert(r); /* Spurious warning */
729
543
730
544
/* Called whenever a service has been resolved successfully or
731
545
timed out */
733
547
switch (event) {
734
548
default:
735
549
case AVAHI_RESOLVER_FAILURE:
736
fprintf(stderr, "(Avahi Resolver) Failed to resolve service '%s'"
737
" of type '%s' in domain '%s': %s\n", name, type, domain,
738
avahi_strerror(avahi_server_errno(mc->server)));
550
fprintf(stderr, "(Resolver) Failed to resolve service '%s' of"
551
" type '%s' in domain '%s': %s\n", name, type, domain,
552
avahi_strerror(avahi_server_errno(server)));
739
553
break;
740
554
741
555
case AVAHI_RESOLVER_FOUND:
743
557
char ip[AVAHI_ADDRESS_STR_MAX];
744
558
avahi_address_snprint(ip, sizeof(ip), address);
745
559
if(debug){
746
fprintf(stderr, "Mandos server \"%s\" found on %s (%s, %"
747
PRIu16 ") on port %d\n", name, host_name, ip,
748
interface, port);
560
fprintf(stderr, "Mandos server \"%s\" found on %s (%s) on"
561
" port %d\n", name, host_name, ip, port);
749
562
}
750
int ret = start_mandos_communication(ip, port, interface, mc);
563
int ret = start_mandos_communication(ip, port,
564
(unsigned int) interface);
751
565
if (ret == 0){
752
avahi_simple_poll_quit(mc->simple_poll);
566
exit(EXIT_SUCCESS);
753
567
}
754
568
}
755
569
}
756
570
avahi_s_service_resolver_free(r);
757
571
}
758
572
759
static void browse_callback( AvahiSServiceBrowser *b,
760
AvahiIfIndex interface,
761
AvahiProtocol protocol,
762
AvahiBrowserEvent event,
763
const char *name,
764
const char *type,
765
const char *domain,
766
AVAHI_GCC_UNUSED AvahiLookupResultFlags
767
flags,
768
void* userdata) {
769
mandos_context *mc = userdata;
770
assert(b);
771
772
/* Called whenever a new services becomes available on the LAN or
773
is removed from the LAN */
774
775
switch (event) {
776
default:
777
case AVAHI_BROWSER_FAILURE:
778
779
fprintf(stderr, "(Avahi browser) %s\n",
780
avahi_strerror(avahi_server_errno(mc->server)));
781
avahi_simple_poll_quit(mc->simple_poll);
782
return;
783
784
case AVAHI_BROWSER_NEW:
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,
792
AVAHI_PROTO_INET6, 0,
793
resolve_callback, mc)))
794
fprintf(stderr, "Avahi: Failed to resolve service '%s': %s\n",
795
name, avahi_strerror(avahi_server_errno(mc->server)));
796
break;
797
798
case AVAHI_BROWSER_REMOVE:
799
break;
800
801
case AVAHI_BROWSER_ALL_FOR_NOW:
802
case AVAHI_BROWSER_CACHE_EXHAUSTED:
803
if(debug){
804
fprintf(stderr, "No Mandos server found, still searching...\n");
573
static void browse_callback(
574
AvahiSServiceBrowser *b,
575
AvahiIfIndex interface,
576
AvahiProtocol protocol,
577
AvahiBrowserEvent event,
578
const char *name,
579
const char *type,
580
const char *domain,
581
AVAHI_GCC_UNUSED AvahiLookupResultFlags flags,
582
void* userdata) {
583
584
AvahiServer *s = userdata;
585
assert(b); /* Spurious warning */
586
587
/* Called whenever a new services becomes available on the LAN or
588
is removed from the LAN */
589
590
switch (event) {
591
default:
592
case AVAHI_BROWSER_FAILURE:
593
594
fprintf(stderr, "(Browser) %s\n",
595
avahi_strerror(avahi_server_errno(server)));
596
avahi_simple_poll_quit(simple_poll);
597
return;
598
599
case AVAHI_BROWSER_NEW:
600
/* We ignore the returned resolver object. In the callback
601
function we free it. If the server is terminated before
602
the callback function is called the server will free
603
the resolver for us. */
604
605
if (!(avahi_s_service_resolver_new(s, interface, protocol, name,
606
type, domain,
607
AVAHI_PROTO_INET6, 0,
608
resolve_callback, s)))
609
fprintf(stderr, "Failed to resolve service '%s': %s\n", name,
610
avahi_strerror(avahi_server_errno(s)));
611
break;
612
613
case AVAHI_BROWSER_REMOVE:
614
break;
615
616
case AVAHI_BROWSER_ALL_FOR_NOW:
617
case AVAHI_BROWSER_CACHE_EXHAUSTED:
618
break;
805
619
}
806
break;
620
}
621
622
/* combinds two strings and returns the malloced new string. som sane checks could/should be added */
623
const char *combinestrings(const char *first, const char *second){
624
char *tmp;
625
tmp = malloc(strlen(first) + strlen(second));
626
if (tmp == NULL){
627
perror("malloc");
628
return NULL;
807
629
}
630
strcpy(tmp, first);
631
strcat(tmp, second);
632
return tmp;
808
633
}
809
634
810
int main(int argc, char *argv[]){
635
636
int main(AVAHI_GCC_UNUSED int argc, AVAHI_GCC_UNUSED char*argv[]) {
637
AvahiServerConfig config;
811
638
AvahiSServiceBrowser *sb = NULL;
812
639
int error;
813
640
int ret;
814
int exitcode = EXIT_SUCCESS;
641
int returncode = EXIT_SUCCESS;
815
642
const char *interface = "eth0";
816
struct ifreq network;
817
int sd;
818
uid_t uid;
819
gid_t gid;
820
char *connect_to = NULL;
821
char tempdir[] = "/tmp/mandosXXXXXX";
822
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
823
const char *seckey = PATHDIR "/" SECKEY;
824
const char *pubkey = PATHDIR "/" PUBKEY;
825
826
mandos_context mc = { .simple_poll = NULL, .server = NULL,
827
.dh_bits = 1024, .priority = "SECURE256"
828
":!CTYPE-X.509:+CTYPE-OPENPGP" };
829
bool gnutls_initalized = false;
830
bool gpgme_initalized = false;
831
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 */
886
errno = 0;
887
mc.dh_bits = (unsigned int) strtol(arg, NULL, 10);
888
if (errno){
889
perror("strtol");
890
exit(EXIT_FAILURE);
891
}
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;
982
}
983
984
if_index = (AvahiIfIndex) if_nametoindex(interface);
985
if(if_index == 0){
986
fprintf(stderr, "No such interface: \"%s\"\n", interface);
987
exit(EXIT_FAILURE);
988
}
989
990
if(connect_to != NULL){
991
/* Connect directly, do not use Zeroconf */
992
/* (Mainly meant for debugging) */
993
char *address = strrchr(connect_to, ':');
994
if(address == NULL){
995
fprintf(stderr, "No colon in address\n");
996
exitcode = EXIT_FAILURE;
997
goto end;
998
}
999
errno = 0;
1000
uint16_t port = (uint16_t) strtol(address+1, NULL, 10);
1001
if(errno){
1002
perror("Bad port number");
1003
exitcode = EXIT_FAILURE;
1004
goto end;
1005
}
1006
*address = '\0';
1007
address = connect_to;
1008
ret = start_mandos_communication(address, port, if_index, &mc);
1009
if(ret < 0){
1010
exitcode = EXIT_FAILURE;
1011
} else {
1012
exitcode = EXIT_SUCCESS;
1013
}
1014
goto end;
1015
}
1016
643
644
while (true){
645
static struct option long_options[] = {
646
{"debug", no_argument, (int *)&debug, 1},
647
{"interface", required_argument, 0, 'i'},
648
{"certdir", required_argument, 0, 'd'},
649
{"certkey", required_argument, 0, 'c'},
650
{"certfile", required_argument, 0, 'k'},
651
{0, 0, 0, 0} };
652
653
int option_index = 0;
654
ret = getopt_long (argc, argv, "i:", long_options,
655
&option_index);
656
657
if (ret == -1){
658
break;
659
}
660
661
switch(ret){
662
case 0:
663
break;
664
case 'i':
665
interface = optarg;
666
break;
667
case 'd':
668
certdir = optarg;
669
break;
670
case 'c':
671
certfile = optarg;
672
break;
673
case 'k':
674
certkey = optarg;
675
break;
676
default:
677
exit(EXIT_FAILURE);
678
}
679
}
680
681
certfile = combinestrings(certdir, certfile);
682
if (certfile == NULL){
683
goto exit;
684
}
685
686
certkey = combinestrings(certdir, certkey);
687
if (certkey == NULL){
688
goto exit;
689
}
690
1017
691
if (not debug){
1018
692
avahi_set_log_function(empty_log);
1019
693
}
1020
694
1021
/* Initialize the pseudo-RNG for Avahi */
695
/* Initialize the psuedo-RNG */
1022
696
srand((unsigned int) time(NULL));
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",
697
698
/* Allocate main loop object */
699
if (!(simple_poll = avahi_simple_poll_new())) {
700
fprintf(stderr, "Failed to create simple poll object.\n");
701
702
goto exit;
703
}
704
705
/* Do not publish any local records */
706
avahi_server_config_init(&config);
707
config.publish_hinfo = 0;
708
config.publish_addresses = 0;
709
config.publish_workstation = 0;
710
config.publish_domain = 0;
711
712
/* Allocate a new server */
713
server = avahi_server_new(avahi_simple_poll_get(simple_poll),
714
&config, NULL, NULL, &error);
715
716
/* Free the configuration data */
717
avahi_server_config_free(&config);
718
719
/* Check if creating the server object succeeded */
720
if (!server) {
721
fprintf(stderr, "Failed to create server: %s\n",
1054
722
avahi_strerror(error));
1055
exitcode = EXIT_FAILURE;
1056
goto end;
723
returncode = EXIT_FAILURE;
724
goto exit;
1057
725
}
1058
726
1059
/* Create the Avahi service browser */
1060
sb = avahi_s_service_browser_new(mc.server, if_index,
727
/* Create the service browser */
728
sb = avahi_s_service_browser_new(server,
729
(AvahiIfIndex)
730
if_nametoindex(interface),
1061
731
AVAHI_PROTO_INET6,
1062
732
"_mandos._tcp", NULL, 0,
1063
browse_callback, &mc);
1064
if (sb == NULL) {
733
browse_callback, server);
734
if (!sb) {
1065
735
fprintf(stderr, "Failed to create service browser: %s\n",
1066
avahi_strerror(avahi_server_errno(mc.server)));
1067
exitcode = EXIT_FAILURE;
1068
goto end;
736
avahi_strerror(avahi_server_errno(server)));
737
returncode = EXIT_FAILURE;
738
goto exit;
1069
739
}
1070
740
1071
741
/* Run the main loop */
1072
742
1073
743
if (debug){
1074
fprintf(stderr, "Starting Avahi loop search\n");
744
fprintf(stderr, "Starting avahi loop search\n");
1075
745
}
1076
746
1077
avahi_simple_poll_loop(mc.simple_poll);
1078
1079
end:
1080
747
avahi_simple_poll_loop(simple_poll);
748
749
exit:
750
1081
751
if (debug){
1082
752
fprintf(stderr, "%s exiting\n", argv[0]);
1083
753
}
1084
754
1085
755
/* Cleanup things */
1086
if (sb != NULL)
756
if (sb)
1087
757
avahi_s_service_browser_free(sb);
1088
758
1089
if (mc.server != NULL)
1090
avahi_server_free(mc.server);
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;
759
if (server)
760
avahi_server_free(server);
761
762
if (simple_poll)
763
avahi_simple_poll_free(simple_poll);
764
765
return returncode;
1143
766
}
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0