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