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 38
- compare with another revision
- download diff
- download tarball
- view history from revision 38
- Committer: Teddy Hogeborn
- Date: 2008-08-03 01:09:36 UTC
- mfrom: (24.1.9 mandos)
- Revision ID: teddy@fukt.bsnet.se-20080803010936-ujme8tgxceszfbi1
* plugbasedclient.c (main): New "--userid" and "--groupid" options.
Take an additional non-option argument and
parse it as a plus-separated and -prefixed
list of additional options.
* plugins.d/mandosclient.c (DH_BITS): Replaced with
"mandos_context.dh_bits". All
users changed.
(certdir): Renamed to "keydir". All users changed.
(certfile): Renamed to "pubkeyfile". All users changed.
(certkey): Renamed to "seckeyfile". All users changed.
(encrypted_session): Replaced with "mandos_context". All users
changed.
(initgnutls): Take additional "session" and "dh_params" arguments.
All callers changed.
(start_mandos_communication): Take additional "mc" argument. All
callers changed. Print target IPv6
address if different than supplied
string.
(simple_poll) Replaced with "mandos_context.simple_poll". All users
changed.
(server): Replaced with "mandos_context.server". All users changed.
(main): Default interface to "eth0". Rename "--certdir" to
"--keydir", "--certkey" to "--seckey", and "--certfile" to
"--pubkey". New options "--dh-bits" and "--priority". If
the interface is not up, bring it up.
Take an additional non-option argument and
parse it as a plus-separated and -prefixed
list of additional options.
* plugins.d/mandosclient.c (DH_BITS): Replaced with
"mandos_context.dh_bits". All
users changed.
(certdir): Renamed to "keydir". All users changed.
(certfile): Renamed to "pubkeyfile". All users changed.
(certkey): Renamed to "seckeyfile". All users changed.
(encrypted_session): Replaced with "mandos_context". All users
changed.
(initgnutls): Take additional "session" and "dh_params" arguments.
All callers changed.
(start_mandos_communication): Take additional "mc" argument. All
callers changed. Print target IPv6
address if different than supplied
string.
(simple_poll) Replaced with "mandos_context.simple_poll". All users
changed.
(server): Replaced with "mandos_context.server". All users changed.
(main): Default interface to "eth0". Rename "--certdir" to
"--keydir", "--certkey" to "--seckey", and "--certfile" to
"--pubkey". New options "--dh-bits" and "--priority". If
the interface is not up, bring it up.
- files added:
- ca.pem
- files removed:
- .bzr-builddeb
- debian
- debian/po
- files renamed:
- plugin-runner.c => plugbasedclient.c
- plugins.d/mandos-client.c => plugins.d/mandosclient.c
- plugins.d/password-prompt.c => plugins.d/passprompt.c
- mandos.conf => server.conf
- mandos => server.py
- files modified:
- Makefile
added
removed
plugins.d/mandosclient.c
9
9
* "browse_callback", and parts of "main".
10
10
*
11
11
* Everything else is
12
* Copyright © 2008 Teddy Hogeborn & Björn Påhlsson
12
* Copyright © 2007-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
#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_* */
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
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
103
72
104
#define PATHDIR "/conf/conf.d/mandos"
105
#define SECKEY "seckey.txt"
106
#define PUBKEY "pubkey.txt"
73
static const char *keydir = "/conf/conf.d/mandos";
74
static const char *pubkeyfile = "pubkey.txt";
75
static const char *seckeyfile = "seckey.txt";
107
76
108
77
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
78
113
/* Used for passing in values through the Avahi callback functions */
79
/* Used for passing in values through all the callback functions */
114
80
typedef struct {
115
81
AvahiSimplePoll *simple_poll;
116
82
AvahiServer *server;
117
83
gnutls_certificate_credentials_t cred;
118
84
unsigned int dh_bits;
119
gnutls_dh_params_t dh_params;
120
85
const char *priority;
86
} mandos_context;
87
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;
121
92
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
93
gpgme_error_t rc;
94
ssize_t ret;
95
ssize_t new_packet_capacity = 0;
96
ssize_t new_packet_length = 0;
148
97
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
98
186
99
if (debug){
187
fprintf(stderr, "Initialize gpgme\n");
100
fprintf(stderr, "Trying to decrypt OpenPGP packet\n");
188
101
}
189
102
190
103
/* Init GPGME */
193
106
if (rc != GPG_ERR_NO_ERROR){
194
107
fprintf(stderr, "bad gpgme_engine_check_version: %s: %s\n",
195
108
gpgme_strsource(rc), gpgme_strerror(rc));
196
return false;
109
return -1;
197
110
}
198
111
199
/* Set GPGME home directory for the OpenPGP engine only */
112
/* Set GPGME home directory */
200
113
rc = gpgme_get_engine_info (&engine_info);
201
114
if (rc != GPG_ERR_NO_ERROR){
202
115
fprintf(stderr, "bad gpgme_get_engine_info: %s: %s\n",
203
116
gpgme_strsource(rc), gpgme_strerror(rc));
204
return false;
117
return -1;
205
118
}
206
119
while(engine_info != NULL){
207
120
if(engine_info->protocol == GPGME_PROTOCOL_OpenPGP){
208
121
gpgme_set_engine_info(GPGME_PROTOCOL_OpenPGP,
209
engine_info->file_name, tempdir);
122
engine_info->file_name, homedir);
210
123
break;
211
124
}
212
125
engine_info = engine_info->next;
213
126
}
214
127
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);
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);
255
134
if (rc != GPG_ERR_NO_ERROR){
256
135
fprintf(stderr, "bad gpgme_data_new_from_mem: %s: %s\n",
257
136
gpgme_strsource(rc), gpgme_strerror(rc));
263
142
if (rc != GPG_ERR_NO_ERROR){
264
143
fprintf(stderr, "bad gpgme_data_new: %s: %s\n",
265
144
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);
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);
273
159
if (rc != GPG_ERR_NO_ERROR){
274
160
fprintf(stderr, "bad gpgme_op_decrypt: %s: %s\n",
275
161
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
}
162
return -1;
163
}
164
165
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;
302
193
}
303
194
}
304
195
}
305
goto decrypt_end;
306
196
}
307
197
308
if(debug){
309
fprintf(stderr, "Decryption of OpenPGP data succeeded\n");
310
}
198
/* Delete the GPGME FILE pointer cryptotext data buffer */
199
gpgme_data_release(dh_crypto);
311
200
312
201
/* Seek back to the beginning of the GPGME plaintext data buffer */
313
202
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;
203
perror("pgpme_data_seek");
317
204
}
318
205
319
*plaintext = NULL;
206
*new_packet = 0;
320
207
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;
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;
328
217
}
329
218
330
ret = gpgme_data_read(dh_plain, *plaintext + plaintext_length,
219
ret = gpgme_data_read(dh_plain, *new_packet + new_packet_length,
331
220
BUFFER_SIZE);
332
221
/* Print the data, if any */
333
222
if (ret == 0){
334
/* EOF */
335
223
break;
336
224
}
337
225
if(ret < 0){
338
226
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);
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
/* } */
357
239
358
240
/* Delete the GPGME plaintext data buffer */
359
241
gpgme_data_release(dh_plain);
360
return plaintext_length;
242
return new_packet_length;
361
243
}
362
244
363
245
static const char * safer_gnutls_strerror (int value) {
364
const char *ret = gnutls_strerror (value); /* Spurious warning */
246
const char *ret = gnutls_strerror (value);
365
247
if (ret == NULL)
366
248
ret = "(unknown)";
367
249
return ret;
368
250
}
369
251
370
/* GnuTLS log function callback */
371
252
static void debuggnutls(__attribute__((unused)) int level,
372
253
const char* string){
373
fprintf(stderr, "GnuTLS: %s", string);
254
fprintf(stderr, "%s", string);
374
255
}
375
256
376
static int init_gnutls_global(mandos_context *mc,
377
const char *pubkeyfilename,
378
const char *seckeyfilename){
257
static int initgnutls(mandos_context *mc, gnutls_session_t *session,
258
gnutls_dh_params_t *dh_params){
259
const char *err;
379
260
int ret;
380
261
381
262
if(debug){
382
263
fprintf(stderr, "Initializing GnuTLS\n");
383
264
}
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));
265
266
if ((ret = gnutls_global_init ())
267
!= GNUTLS_E_SUCCESS) {
268
fprintf (stderr, "global_init: %s\n", safer_gnutls_strerror(ret));
389
269
return -1;
390
270
}
391
271
392
272
if (debug){
393
/* "Use a log level over 10 to enable all debugging options."
394
* - GnuTLS manual
395
*/
396
273
gnutls_global_set_log_level(11);
397
274
gnutls_global_set_log_function(debuggnutls);
398
275
}
399
276
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 */
277
/* openpgp credentials */
278
if ((ret = gnutls_certificate_allocate_credentials (&mc->cred))
279
!= GNUTLS_E_SUCCESS) {
280
fprintf (stderr, "memory error: %s\n",
405
281
safer_gnutls_strerror(ret));
406
gnutls_global_deinit ();
407
282
return -1;
408
283
}
409
284
410
285
if(debug){
411
fprintf(stderr, "Attempting to use OpenPGP public key %s and"
412
" secret key %s as GnuTLS credentials\n", pubkeyfilename,
413
seckeyfilename);
286
fprintf(stderr, "Attempting to use OpenPGP certificate %s"
287
" and keyfile %s as GnuTLS credentials\n", pubkeyfile,
288
seckeyfile);
414
289
}
415
290
416
291
ret = gnutls_certificate_set_openpgp_key_file
417
(mc->cred, pubkeyfilename, seckeyfilename,
418
GNUTLS_OPENPGP_FMT_BASE64);
292
(mc->cred, pubkeyfile, seckeyfile, GNUTLS_OPENPGP_FMT_BASE64);
419
293
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",
294
fprintf
295
(stderr, "Error[%d] while reading the OpenPGP key pair ('%s',"
296
" '%s')\n",
297
ret, pubkeyfile, seckeyfile);
298
fprintf(stdout, "The Error is: %s\n",
424
299
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){
300
return -1;
301
}
302
303
//GnuTLS server initialization
304
if ((ret = gnutls_dh_params_init(dh_params))
305
!= GNUTLS_E_SUCCESS) {
306
fprintf (stderr, "Error in dh parameter initialization: %s\n",
307
safer_gnutls_strerror(ret));
308
return -1;
309
}
310
311
if ((ret = gnutls_dh_params_generate2(*dh_params, mc->dh_bits))
312
!= GNUTLS_E_SUCCESS) {
313
fprintf (stderr, "Error in prime generation: %s\n",
314
safer_gnutls_strerror(ret));
315
return -1;
316
}
317
318
gnutls_certificate_set_dh_params(mc->cred, *dh_params);
319
320
// GnuTLS session creation
321
if ((ret = gnutls_init(session, GNUTLS_SERVER))
322
!= GNUTLS_E_SUCCESS){
460
323
fprintf(stderr, "Error in GnuTLS session initialization: %s\n",
461
324
safer_gnutls_strerror(ret));
462
325
}
463
326
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
}
327
if ((ret = gnutls_priority_set_direct(*session, mc->priority, &err))
328
!= GNUTLS_E_SUCCESS) {
329
fprintf(stderr, "Syntax error at: %s\n", err);
330
fprintf(stderr, "GnuTLS error: %s\n",
331
safer_gnutls_strerror(ret));
332
return -1;
474
333
}
475
334
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",
335
if ((ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
336
mc->cred))
337
!= GNUTLS_E_SUCCESS) {
338
fprintf(stderr, "Error setting a credentials set: %s\n",
480
339
safer_gnutls_strerror(ret));
481
gnutls_deinit (*session);
482
340
return -1;
483
341
}
484
342
491
349
return 0;
492
350
}
493
351
494
/* Avahi log function callback */
495
352
static void empty_log(__attribute__((unused)) AvahiLogLevel level,
496
353
__attribute__((unused)) const char *txt){}
497
354
498
/* Called when a Mandos server is found */
499
355
static int start_mandos_communication(const char *ip, uint16_t port,
500
356
AvahiIfIndex if_index,
501
357
mandos_context *mc){
502
358
int ret, tcp_sd;
503
union { struct sockaddr in; struct sockaddr_in6 in6; } to;
359
struct sockaddr_in6 to;
504
360
char *buffer = NULL;
505
361
char *decrypted_buffer;
506
362
size_t buffer_length = 0;
507
363
size_t buffer_capacity = 0;
508
364
ssize_t decrypted_buffer_size;
509
size_t written;
365
size_t written = 0;
510
366
int retval = 0;
511
367
char interface[IF_NAMESIZE];
512
368
gnutls_session_t session;
513
514
ret = init_gnutls_session (mc, &session);
515
if (ret != 0){
516
return -1;
517
}
369
gnutls_dh_params_t dh_params;
518
370
519
371
if(debug){
520
fprintf(stderr, "Setting up a tcp connection to %s, port %" PRIu16
521
"\n", ip, port);
372
fprintf(stderr, "Setting up a tcp connection to %s, port %d\n",
373
ip, port);
522
374
}
523
375
524
376
tcp_sd = socket(PF_INET6, SOCK_STREAM, 0);
526
378
perror("socket");
527
379
return -1;
528
380
}
529
381
530
382
if(debug){
531
383
if(if_indextoname((unsigned int)if_index, interface) == NULL){
532
384
perror("if_indextoname");
535
387
fprintf(stderr, "Binding to interface %s\n", interface);
536
388
}
537
389
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);
390
memset(&to,0,sizeof(to)); /* Spurious warning */
391
to.sin6_family = AF_INET6;
392
ret = inet_pton(AF_INET6, ip, &to.sin6_addr);
543
393
if (ret < 0 ){
544
394
perror("inet_pton");
545
395
return -1;
548
398
fprintf(stderr, "Bad address: %s\n", ip);
549
399
return -1;
550
400
}
551
to.in6.sin6_port = htons(port); /* Spurious warning */
401
to.sin6_port = htons(port); /* Spurious warning */
552
402
553
to.in6.sin6_scope_id = (uint32_t)if_index;
403
to.sin6_scope_id = (uint32_t)if_index;
554
404
555
405
if(debug){
556
fprintf(stderr, "Connection to: %s, port %" PRIu16 "\n", ip,
557
port);
406
fprintf(stderr, "Connection to: %s, port %d\n", ip, port);
558
407
char addrstr[INET6_ADDRSTRLEN] = "";
559
if(inet_ntop(to.in6.sin6_family, &(to.in6.sin6_addr), addrstr,
408
if(inet_ntop(to.sin6_family, &(to.sin6_addr), addrstr,
560
409
sizeof(addrstr)) == NULL){
561
410
perror("inet_ntop");
562
411
} else {
566
415
}
567
416
}
568
417
569
ret = connect(tcp_sd, &to.in, sizeof(to));
418
ret = connect(tcp_sd, (struct sockaddr *) &to, sizeof(to));
570
419
if (ret < 0){
571
420
perror("connect");
572
421
return -1;
573
422
}
574
423
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
}
424
ret = initgnutls (mc, &session, &dh_params);
425
if (ret != 0){
426
retval = -1;
427
return -1;
597
428
}
598
429
430
gnutls_transport_set_ptr (session, (gnutls_transport_ptr_t) tcp_sd);
431
599
432
if(debug){
600
433
fprintf(stderr, "Establishing TLS session with %s\n", ip);
601
434
}
602
435
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);
436
ret = gnutls_handshake (session);
608
437
609
438
if (ret != GNUTLS_E_SUCCESS){
610
439
if(debug){
611
fprintf(stderr, "*** GnuTLS Handshake failed ***\n");
440
fprintf(stderr, "\n*** Handshake failed ***\n");
612
441
gnutls_perror (ret);
613
442
}
614
443
retval = -1;
615
goto mandos_end;
444
goto exit;
616
445
}
617
446
618
/* Read OpenPGP packet that contains the wanted password */
447
//Retrieve OpenPGP packet that contains the wanted password
619
448
620
449
if(debug){
621
450
fprintf(stderr, "Retrieving pgp encrypted password from %s\n",
622
451
ip);
623
452
}
624
453
625
454
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;
455
if (buffer_length + BUFFER_SIZE > buffer_capacity){
456
buffer = realloc(buffer, buffer_capacity + BUFFER_SIZE);
457
if (buffer == NULL){
458
perror("realloc");
459
goto exit;
460
}
461
buffer_capacity += BUFFER_SIZE;
632
462
}
633
463
634
464
ret = gnutls_record_recv(session, buffer+buffer_length,
642
472
case GNUTLS_E_AGAIN:
643
473
break;
644
474
case GNUTLS_E_REHANDSHAKE:
645
do{
646
ret = gnutls_handshake (session);
647
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
475
ret = gnutls_handshake (session);
648
476
if (ret < 0){
649
fprintf(stderr, "*** GnuTLS Re-handshake failed ***\n");
477
fprintf(stderr, "\n*** Handshake failed ***\n");
650
478
gnutls_perror (ret);
651
479
retval = -1;
652
goto mandos_end;
480
goto exit;
653
481
}
654
482
break;
655
483
default:
656
484
fprintf(stderr, "Unknown error while reading data from"
657
" encrypted session with Mandos server\n");
485
" encrypted session with mandos server\n");
658
486
retval = -1;
659
487
gnutls_bye (session, GNUTLS_SHUT_RDWR);
660
goto mandos_end;
488
goto exit;
661
489
}
662
490
} else {
663
491
buffer_length += (size_t) ret;
664
492
}
665
493
}
666
494
667
if(debug){
668
fprintf(stderr, "Closing TLS session\n");
669
}
670
671
gnutls_bye (session, GNUTLS_SHUT_RDWR);
672
673
495
if (buffer_length > 0){
674
decrypted_buffer_size = pgp_packet_decrypt(mc, buffer,
496
decrypted_buffer_size = pgp_packet_decrypt(buffer,
675
497
buffer_length,
676
&decrypted_buffer);
498
&decrypted_buffer,
499
keydir);
677
500
if (decrypted_buffer_size >= 0){
678
written = 0;
679
501
while(written < (size_t) decrypted_buffer_size){
680
502
ret = (int)fwrite (decrypted_buffer + written, 1,
681
503
(size_t)decrypted_buffer_size - written,
694
516
} else {
695
517
retval = -1;
696
518
}
697
} else {
698
retval = -1;
699
}
700
701
/* Shutdown procedure */
702
703
mandos_end:
519
}
520
521
//shutdown procedure
522
523
if(debug){
524
fprintf(stderr, "Closing TLS session\n");
525
}
526
704
527
free(buffer);
705
ret = TEMP_FAILURE_RETRY(close(tcp_sd));
706
if(ret == -1){
707
perror("close");
708
}
528
gnutls_bye (session, GNUTLS_SHUT_RDWR);
529
exit:
530
close(tcp_sd);
709
531
gnutls_deinit (session);
532
gnutls_certificate_free_credentials (mc->cred);
533
gnutls_global_deinit ();
710
534
return retval;
711
535
}
712
536
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) {
537
static void resolve_callback( 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
void* userdata) {
727
550
mandos_context *mc = userdata;
728
assert(r);
551
assert(r); /* Spurious warning */
729
552
730
553
/* Called whenever a service has been resolved successfully or
731
554
timed out */
733
556
switch (event) {
734
557
default:
735
558
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,
559
fprintf(stderr, "(Resolver) Failed to resolve service '%s' of"
560
" type '%s' in domain '%s': %s\n", name, type, domain,
738
561
avahi_strerror(avahi_server_errno(mc->server)));
739
562
break;
740
563
743
566
char ip[AVAHI_ADDRESS_STR_MAX];
744
567
avahi_address_snprint(ip, sizeof(ip), address);
745
568
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);
569
fprintf(stderr, "Mandos server \"%s\" found on %s (%s) on"
570
" port %d\n", name, host_name, ip, port);
749
571
}
750
572
int ret = start_mandos_communication(ip, port, interface, mc);
751
573
if (ret == 0){
752
avahi_simple_poll_quit(mc->simple_poll);
574
exit(EXIT_SUCCESS);
753
575
}
754
576
}
755
577
}
763
585
const char *name,
764
586
const char *type,
765
587
const char *domain,
766
AVAHI_GCC_UNUSED AvahiLookupResultFlags
767
flags,
588
AVAHI_GCC_UNUSED AvahiLookupResultFlags flags,
768
589
void* userdata) {
769
590
mandos_context *mc = userdata;
770
assert(b);
591
assert(b); /* Spurious warning */
771
592
772
593
/* Called whenever a new services becomes available on the LAN or
773
594
is removed from the LAN */
776
597
default:
777
598
case AVAHI_BROWSER_FAILURE:
778
599
779
fprintf(stderr, "(Avahi browser) %s\n",
600
fprintf(stderr, "(Browser) %s\n",
780
601
avahi_strerror(avahi_server_errno(mc->server)));
781
602
avahi_simple_poll_quit(mc->simple_poll);
782
603
return;
783
604
784
605
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. */
606
/* We ignore the returned resolver object. In the callback
607
function we free it. If the server is terminated before
608
the callback function is called the server will free
609
the resolver for us. */
789
610
790
if (!(avahi_s_service_resolver_new(mc->server, interface,
791
protocol, name, type, domain,
611
if (!(avahi_s_service_resolver_new(mc->server, interface, protocol, name,
612
type, domain,
792
613
AVAHI_PROTO_INET6, 0,
793
614
resolve_callback, mc)))
794
fprintf(stderr, "Avahi: Failed to resolve service '%s': %s\n",
795
name, avahi_strerror(avahi_server_errno(mc->server)));
615
fprintf(stderr, "Failed to resolve service '%s': %s\n", name,
616
avahi_strerror(avahi_server_errno(mc->server)));
796
617
break;
797
618
798
619
case AVAHI_BROWSER_REMOVE:
800
621
801
622
case AVAHI_BROWSER_ALL_FOR_NOW:
802
623
case AVAHI_BROWSER_CACHE_EXHAUSTED:
803
if(debug){
804
fprintf(stderr, "No Mandos server found, still searching...\n");
805
}
806
624
break;
807
625
}
808
626
}
809
627
810
int main(int argc, char *argv[]){
628
/* Combines file name and path and returns the malloced new
629
string. some sane checks could/should be added */
630
static const char *combinepath(const char *first, const char *second){
631
size_t f_len = strlen(first);
632
size_t s_len = strlen(second);
633
char *tmp = malloc(f_len + s_len + 2);
634
if (tmp == NULL){
635
return NULL;
636
}
637
if(f_len > 0){
638
memcpy(tmp, first, f_len); /* Spurious warning */
639
}
640
tmp[f_len] = '/';
641
if(s_len > 0){
642
memcpy(tmp + f_len + 1, second, s_len); /* Spurious warning */
643
}
644
tmp[f_len + 1 + s_len] = '\0';
645
return tmp;
646
}
647
648
649
int main(AVAHI_GCC_UNUSED int argc, AVAHI_GCC_UNUSED char*argv[]) {
650
AvahiServerConfig config;
811
651
AvahiSServiceBrowser *sb = NULL;
812
652
int error;
813
653
int ret;
814
int exitcode = EXIT_SUCCESS;
654
int debug_int;
655
int returncode = EXIT_SUCCESS;
815
656
const char *interface = "eth0";
816
657
struct ifreq network;
817
658
int sd;
818
uid_t uid;
819
gid_t gid;
820
659
char *connect_to = NULL;
821
char tempdir[] = "/tmp/mandosXXXXXX";
822
660
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
823
const char *seckey = PATHDIR "/" SECKEY;
824
const char *pubkey = PATHDIR "/" PUBKEY;
825
826
661
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;
662
.dh_bits = 1024, .priority = "SECURE256"};
663
664
debug_int = debug ? 1 : 0;
665
while (true){
666
struct option long_options[] = {
667
{"debug", no_argument, &debug_int, 1},
668
{"connect", required_argument, NULL, 'c'},
669
{"interface", required_argument, NULL, 'i'},
670
{"keydir", required_argument, NULL, 'd'},
671
{"seckey", required_argument, NULL, 's'},
672
{"pubkey", required_argument, NULL, 'p'},
673
{"dh-bits", required_argument, NULL, 'D'},
674
{"priority", required_argument, NULL, 'P'},
675
{0, 0, 0, 0} };
676
677
int option_index = 0;
678
ret = getopt_long (argc, argv, "i:", long_options,
679
&option_index);
680
681
if (ret == -1){
682
break;
683
}
684
685
switch(ret){
686
case 0:
687
break;
688
case 'i':
689
interface = optarg;
690
break;
691
case 'c':
692
connect_to = optarg;
693
break;
694
case 'd':
695
keydir = optarg;
696
break;
697
case 'p':
698
pubkeyfile = optarg;
699
break;
700
case 's':
701
seckeyfile = optarg;
702
break;
703
case 'D':
704
errno = 0;
705
mc.dh_bits = (unsigned int) strtol(optarg, NULL, 10);
706
if (errno){
707
perror("strtol");
708
exit(EXIT_FAILURE);
709
}
710
break;
711
case 'P':
712
mc.priority = optarg;
713
break;
714
case '?':
715
default:
716
exit(EXIT_FAILURE);
717
}
718
}
719
debug = debug_int ? true : false;
720
721
pubkeyfile = combinepath(keydir, pubkeyfile);
722
if (pubkeyfile == NULL){
723
perror("combinepath");
724
returncode = EXIT_FAILURE;
725
goto exit;
726
}
727
728
seckeyfile = combinepath(keydir, seckeyfile);
729
if (seckeyfile == NULL){
730
perror("combinepath");
731
goto exit;
982
732
}
983
733
984
734
if_index = (AvahiIfIndex) if_nametoindex(interface);
993
743
char *address = strrchr(connect_to, ':');
994
744
if(address == NULL){
995
745
fprintf(stderr, "No colon in address\n");
996
exitcode = EXIT_FAILURE;
997
goto end;
746
exit(EXIT_FAILURE);
998
747
}
999
748
errno = 0;
1000
749
uint16_t port = (uint16_t) strtol(address+1, NULL, 10);
1001
750
if(errno){
1002
751
perror("Bad port number");
1003
exitcode = EXIT_FAILURE;
1004
goto end;
752
exit(EXIT_FAILURE);
1005
753
}
1006
754
*address = '\0';
1007
755
address = connect_to;
1008
756
ret = start_mandos_communication(address, port, if_index, &mc);
1009
757
if(ret < 0){
1010
exitcode = EXIT_FAILURE;
758
exit(EXIT_FAILURE);
1011
759
} else {
1012
exitcode = EXIT_SUCCESS;
1013
}
1014
goto end;
1015
}
760
exit(EXIT_SUCCESS);
761
}
762
}
763
764
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
765
if(sd < 0) {
766
perror("socket");
767
returncode = EXIT_FAILURE;
768
goto exit;
769
}
770
strcpy(network.ifr_name, interface); /* Spurious warning */
771
ret = ioctl(sd, SIOCGIFFLAGS, &network);
772
if(ret == -1){
773
774
perror("ioctl SIOCGIFFLAGS");
775
returncode = EXIT_FAILURE;
776
goto exit;
777
}
778
if((network.ifr_flags & IFF_UP) == 0){
779
network.ifr_flags |= IFF_UP;
780
ret = ioctl(sd, SIOCSIFFLAGS, &network);
781
if(ret == -1){
782
perror("ioctl SIOCSIFFLAGS");
783
returncode = EXIT_FAILURE;
784
goto exit;
785
}
786
}
787
close(sd);
1016
788
1017
789
if (not debug){
1018
790
avahi_set_log_function(empty_log);
1019
791
}
1020
792
1021
/* Initialize the pseudo-RNG for Avahi */
793
/* Initialize the psuedo-RNG */
1022
794
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",
795
796
/* Allocate main loop object */
797
if (!(mc.simple_poll = avahi_simple_poll_new())) {
798
fprintf(stderr, "Failed to create simple poll object.\n");
799
returncode = EXIT_FAILURE;
800
goto exit;
801
}
802
803
/* Do not publish any local records */
804
avahi_server_config_init(&config);
805
config.publish_hinfo = 0;
806
config.publish_addresses = 0;
807
config.publish_workstation = 0;
808
config.publish_domain = 0;
809
810
/* Allocate a new server */
811
mc.server=avahi_server_new(avahi_simple_poll_get(mc.simple_poll),
812
&config, NULL, NULL, &error);
813
814
/* Free the configuration data */
815
avahi_server_config_free(&config);
816
817
/* Check if creating the server object succeeded */
818
if (!mc.server) {
819
fprintf(stderr, "Failed to create server: %s\n",
1054
820
avahi_strerror(error));
1055
exitcode = EXIT_FAILURE;
1056
goto end;
821
returncode = EXIT_FAILURE;
822
goto exit;
1057
823
}
1058
824
1059
/* Create the Avahi service browser */
825
/* Create the service browser */
1060
826
sb = avahi_s_service_browser_new(mc.server, if_index,
1061
827
AVAHI_PROTO_INET6,
1062
828
"_mandos._tcp", NULL, 0,
1063
829
browse_callback, &mc);
1064
if (sb == NULL) {
830
if (!sb) {
1065
831
fprintf(stderr, "Failed to create service browser: %s\n",
1066
832
avahi_strerror(avahi_server_errno(mc.server)));
1067
exitcode = EXIT_FAILURE;
1068
goto end;
833
returncode = EXIT_FAILURE;
834
goto exit;
1069
835
}
1070
836
1071
837
/* Run the main loop */
1072
838
1073
839
if (debug){
1074
fprintf(stderr, "Starting Avahi loop search\n");
840
fprintf(stderr, "Starting avahi loop search\n");
1075
841
}
1076
842
1077
843
avahi_simple_poll_loop(mc.simple_poll);
1078
844
1079
end:
1080
845
exit:
846
1081
847
if (debug){
1082
848
fprintf(stderr, "%s exiting\n", argv[0]);
1083
849
}
1084
850
1085
851
/* Cleanup things */
1086
if (sb != NULL)
852
if (sb)
1087
853
avahi_s_service_browser_free(sb);
1088
854
1089
if (mc.server != NULL)
855
if (mc.server)
1090
856
avahi_server_free(mc.server);
1091
1092
if (mc.simple_poll != NULL)
857
858
if (mc.simple_poll)
1093
859
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;
860
free(pubkeyfile);
861
free(seckeyfile);
862
863
return returncode;
1143
864
}
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0