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