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 237.2.123
- compare with another revision
- download diff
- download tarball
- view history from revision 237.2.123
- Committer: Teddy Hogeborn
- Date: 2009-09-05 17:39:34 UTC
- mto: (24.1.140 mandos) (237.12.2 mandos-persistent) (299.1.1 release) (300.1.1 release) (301.1.1 release)
- mto: This revision was merged to the branch mainline in revision 264.
- Revision ID: teddy@fukt.bsnet.se-20090905173934-gs0r858omhudc71m
* plugin-runner.c (main): Move variables "tmpmax" and "tmp" into
the innermost scope possible.
the innermost scope possible.
- files added:
- .bzr-builddeb
- debian
- debian/po
- files removed:
- ca.pem
- files renamed:
- mandos-clients.conf => clients.conf
- server.py => mandos
- 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
1
1
/* -*- coding: utf-8 -*- */
2
2
/*
3
* Mandos client - get and decrypt data from a Mandos server
3
* Mandos-client - get and decrypt data from a Mandos server
4
4
*
5
5
* This program is partly derived from an example program for an Avahi
6
6
* service browser, downloaded from
8
8
* includes the following functions: "resolve_callback",
9
9
* "browse_callback", and parts of "main".
10
10
*
11
* Everything else is Copyright © 2007-2008 Teddy Hogeborn and Björn
12
* Påhlsson.
11
* Everything else is
12
* Copyright © 2008,2009 Teddy Hogeborn
13
* Copyright © 2008,2009 Björn Påhlsson
13
14
*
14
15
* This program is free software: you can redistribute it and/or
15
16
* modify it under the terms of the GNU General Public License as
25
26
* along with this program. If not, see
26
27
* <http://www.gnu.org/licenses/>.
27
28
*
28
* Contact the authors at <https://www.fukt.bsnet.se/~belorn/> and
29
* <https://www.fukt.bsnet.se/~teddy/>.
29
* Contact the authors at <mandos@fukt.bsnet.se>.
30
30
*/
31
31
32
#define _FORTIFY_SOURCE 2
33
32
/* Needed by GPGME, specifically gpgme_data_seek() */
33
#ifndef _LARGEFILE_SOURCE
34
34
#define _LARGEFILE_SOURCE
35
#endif
36
#ifndef _FILE_OFFSET_BITS
35
37
#define _FILE_OFFSET_BITS 64
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
38
#endif
39
40
#define _GNU_SOURCE /* TEMP_FAILURE_RETRY(), asprintf() */
41
42
#include <stdio.h> /* fprintf(), stderr, fwrite(),
43
stdout, ferror(), remove() */
44
#include <stdint.h> /* uint16_t, uint32_t */
45
#include <stddef.h> /* NULL, size_t, ssize_t */
46
#include <stdlib.h> /* free(), EXIT_SUCCESS, EXIT_FAILURE,
47
srand(), strtof() */
48
#include <stdbool.h> /* bool, false, true */
49
#include <string.h> /* memset(), strcmp(), strlen(),
50
strerror(), asprintf(), strcpy() */
51
#include <sys/ioctl.h> /* ioctl */
52
#include <sys/types.h> /* socket(), inet_pton(), sockaddr,
53
sockaddr_in6, PF_INET6,
54
SOCK_STREAM, uid_t, gid_t, open(),
55
opendir(), DIR */
56
#include <sys/stat.h> /* open() */
57
#include <sys/socket.h> /* socket(), struct sockaddr_in6,
58
inet_pton(), connect() */
59
#include <fcntl.h> /* open() */
60
#include <dirent.h> /* opendir(), struct dirent, readdir()
61
*/
62
#include <inttypes.h> /* PRIu16, PRIdMAX, intmax_t,
63
strtoimax() */
64
#include <assert.h> /* assert() */
65
#include <errno.h> /* perror(), errno */
66
#include <time.h> /* nanosleep(), time() */
67
#include <net/if.h> /* ioctl, ifreq, SIOCGIFFLAGS, IFF_UP,
68
SIOCSIFFLAGS, if_indextoname(),
69
if_nametoindex(), IF_NAMESIZE */
70
#include <netinet/in.h> /* IN6_IS_ADDR_LINKLOCAL,
71
INET_ADDRSTRLEN, INET6_ADDRSTRLEN
72
*/
73
#include <unistd.h> /* close(), SEEK_SET, off_t, write(),
74
getuid(), getgid(), setuid(),
75
setgid() */
76
#include <arpa/inet.h> /* inet_pton(), htons */
77
#include <iso646.h> /* not, or, and */
78
#include <argp.h> /* struct argp_option, error_t, struct
79
argp_state, struct argp,
80
argp_parse(), ARGP_KEY_ARG,
81
ARGP_KEY_END, ARGP_ERR_UNKNOWN */
82
#include <signal.h> /* sigemptyset(), sigaddset(),
83
sigaction(), SIGTERM, sig_atomic_t,
84
raise() */
85
86
#ifdef __linux__
87
#include <sys/klog.h> /* klogctl() */
88
#endif /* __linux__ */
89
90
/* Avahi */
91
/* All Avahi types, constants and functions
92
Avahi*, avahi_*,
93
AVAHI_* */
43
94
#include <avahi-core/core.h>
44
95
#include <avahi-core/lookup.h>
45
96
#include <avahi-core/log.h>
47
98
#include <avahi-common/malloc.h>
48
99
#include <avahi-common/error.h>
49
100
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>
70
71
#ifndef CERT_ROOT
72
#define CERT_ROOT "/conf/conf.d/cryptkeyreq/"
73
#endif
74
#define CERTFILE CERT_ROOT "openpgp-client.txt"
75
#define KEYFILE CERT_ROOT "openpgp-client-key.txt"
101
/* GnuTLS */
102
#include <gnutls/gnutls.h> /* All GnuTLS types, constants and
103
functions:
104
gnutls_*
105
init_gnutls_session(),
106
GNUTLS_* */
107
#include <gnutls/openpgp.h>
108
/* gnutls_certificate_set_openpgp_key_file(),
109
GNUTLS_OPENPGP_FMT_BASE64 */
110
111
/* GPGME */
112
#include <gpgme.h> /* All GPGME types, constants and
113
functions:
114
gpgme_*
115
GPGME_PROTOCOL_OpenPGP,
116
GPG_ERR_NO_* */
117
76
118
#define BUFFER_SIZE 256
77
#define DH_BITS 1024
119
120
#define PATHDIR "/conf/conf.d/mandos"
121
#define SECKEY "seckey.txt"
122
#define PUBKEY "pubkey.txt"
78
123
79
124
bool debug = false;
125
static const char mandos_protocol_version[] = "1";
126
const char *argp_program_version = "mandos-client " VERSION;
127
const char *argp_program_bug_address = "<mandos@fukt.bsnet.se>";
80
128
129
/* Used for passing in values through the Avahi callback functions */
81
130
typedef struct {
82
gnutls_session_t session;
131
AvahiSimplePoll *simple_poll;
132
AvahiServer *server;
83
133
gnutls_certificate_credentials_t cred;
134
unsigned int dh_bits;
84
135
gnutls_dh_params_t dh_params;
85
} encrypted_session;
86
87
88
ssize_t pgp_packet_decrypt (char *packet, size_t packet_size,
89
char **new_packet, const char *homedir){
90
gpgme_data_t dh_crypto, dh_plain;
136
const char *priority;
91
137
gpgme_ctx_t ctx;
138
} mandos_context;
139
140
/* global context so signal handler can reach it*/
141
mandos_context mc = { .simple_poll = NULL, .server = NULL,
142
.dh_bits = 1024, .priority = "SECURE256"
143
":!CTYPE-X.509:+CTYPE-OPENPGP" };
144
145
/*
146
* Make additional room in "buffer" for at least BUFFER_SIZE more
147
* bytes. "buffer_capacity" is how much is currently allocated,
148
* "buffer_length" is how much is already used.
149
*/
150
size_t incbuffer(char **buffer, size_t buffer_length,
151
size_t buffer_capacity){
152
if(buffer_length + BUFFER_SIZE > buffer_capacity){
153
*buffer = realloc(*buffer, buffer_capacity + BUFFER_SIZE);
154
if(buffer == NULL){
155
return 0;
156
}
157
buffer_capacity += BUFFER_SIZE;
158
}
159
return buffer_capacity;
160
}
161
162
/*
163
* Initialize GPGME.
164
*/
165
static bool init_gpgme(const char *seckey,
166
const char *pubkey, const char *tempdir){
167
int ret;
92
168
gpgme_error_t rc;
93
ssize_t ret;
94
ssize_t new_packet_capacity = 0;
95
ssize_t new_packet_length = 0;
96
169
gpgme_engine_info_t engine_info;
97
98
if (debug){
99
fprintf(stderr, "Trying to decrypt OpenPGP packet\n");
170
171
172
/*
173
* Helper function to insert pub and seckey to the engine keyring.
174
*/
175
bool import_key(const char *filename){
176
int fd;
177
gpgme_data_t pgp_data;
178
179
fd = (int)TEMP_FAILURE_RETRY(open(filename, O_RDONLY));
180
if(fd == -1){
181
perror("open");
182
return false;
183
}
184
185
rc = gpgme_data_new_from_fd(&pgp_data, fd);
186
if(rc != GPG_ERR_NO_ERROR){
187
fprintf(stderr, "bad gpgme_data_new_from_fd: %s: %s\n",
188
gpgme_strsource(rc), gpgme_strerror(rc));
189
return false;
190
}
191
192
rc = gpgme_op_import(mc.ctx, pgp_data);
193
if(rc != GPG_ERR_NO_ERROR){
194
fprintf(stderr, "bad gpgme_op_import: %s: %s\n",
195
gpgme_strsource(rc), gpgme_strerror(rc));
196
return false;
197
}
198
199
ret = (int)TEMP_FAILURE_RETRY(close(fd));
200
if(ret == -1){
201
perror("close");
202
}
203
gpgme_data_release(pgp_data);
204
return true;
205
}
206
207
if(debug){
208
fprintf(stderr, "Initializing GPGME\n");
100
209
}
101
210
102
211
/* Init GPGME */
103
212
gpgme_check_version(NULL);
104
gpgme_engine_check_version(GPGME_PROTOCOL_OpenPGP);
213
rc = gpgme_engine_check_version(GPGME_PROTOCOL_OpenPGP);
214
if(rc != GPG_ERR_NO_ERROR){
215
fprintf(stderr, "bad gpgme_engine_check_version: %s: %s\n",
216
gpgme_strsource(rc), gpgme_strerror(rc));
217
return false;
218
}
105
219
106
/* Set GPGME home directory */
107
rc = gpgme_get_engine_info (&engine_info);
108
if (rc != GPG_ERR_NO_ERROR){
220
/* Set GPGME home directory for the OpenPGP engine only */
221
rc = gpgme_get_engine_info(&engine_info);
222
if(rc != GPG_ERR_NO_ERROR){
109
223
fprintf(stderr, "bad gpgme_get_engine_info: %s: %s\n",
110
224
gpgme_strsource(rc), gpgme_strerror(rc));
111
return -1;
225
return false;
112
226
}
113
227
while(engine_info != NULL){
114
228
if(engine_info->protocol == GPGME_PROTOCOL_OpenPGP){
115
229
gpgme_set_engine_info(GPGME_PROTOCOL_OpenPGP,
116
engine_info->file_name, homedir);
230
engine_info->file_name, tempdir);
117
231
break;
118
232
}
119
233
engine_info = engine_info->next;
120
234
}
121
235
if(engine_info == NULL){
122
fprintf(stderr, "Could not set home dir to %s\n", homedir);
123
return -1;
124
}
125
126
/* Create new GPGME data buffer from packet buffer */
127
rc = gpgme_data_new_from_mem(&dh_crypto, packet, packet_size, 0);
128
if (rc != GPG_ERR_NO_ERROR){
236
fprintf(stderr, "Could not set GPGME home dir to %s\n", tempdir);
237
return false;
238
}
239
240
/* Create new GPGME "context" */
241
rc = gpgme_new(&(mc.ctx));
242
if(rc != GPG_ERR_NO_ERROR){
243
fprintf(stderr, "bad gpgme_new: %s: %s\n",
244
gpgme_strsource(rc), gpgme_strerror(rc));
245
return false;
246
}
247
248
if(not import_key(pubkey) or not import_key(seckey)){
249
return false;
250
}
251
252
return true;
253
}
254
255
/*
256
* Decrypt OpenPGP data.
257
* Returns -1 on error
258
*/
259
static ssize_t pgp_packet_decrypt(const char *cryptotext,
260
size_t crypto_size,
261
char **plaintext){
262
gpgme_data_t dh_crypto, dh_plain;
263
gpgme_error_t rc;
264
ssize_t ret;
265
size_t plaintext_capacity = 0;
266
ssize_t plaintext_length = 0;
267
268
if(debug){
269
fprintf(stderr, "Trying to decrypt OpenPGP data\n");
270
}
271
272
/* Create new GPGME data buffer from memory cryptotext */
273
rc = gpgme_data_new_from_mem(&dh_crypto, cryptotext, crypto_size,
274
0);
275
if(rc != GPG_ERR_NO_ERROR){
129
276
fprintf(stderr, "bad gpgme_data_new_from_mem: %s: %s\n",
130
277
gpgme_strsource(rc), gpgme_strerror(rc));
131
278
return -1;
133
280
134
281
/* Create new empty GPGME data buffer for the plaintext */
135
282
rc = gpgme_data_new(&dh_plain);
136
if (rc != GPG_ERR_NO_ERROR){
283
if(rc != GPG_ERR_NO_ERROR){
137
284
fprintf(stderr, "bad gpgme_data_new: %s: %s\n",
138
285
gpgme_strsource(rc), gpgme_strerror(rc));
139
return -1;
140
}
141
142
/* Create new GPGME "context" */
143
rc = gpgme_new(&ctx);
144
if (rc != GPG_ERR_NO_ERROR){
145
fprintf(stderr, "bad gpgme_new: %s: %s\n",
146
gpgme_strsource(rc), gpgme_strerror(rc));
147
return -1;
148
}
149
150
/* Decrypt data from the FILE pointer to the plaintext data
151
buffer */
152
rc = gpgme_op_decrypt(ctx, dh_crypto, dh_plain);
153
if (rc != GPG_ERR_NO_ERROR){
286
gpgme_data_release(dh_crypto);
287
return -1;
288
}
289
290
/* Decrypt data from the cryptotext data buffer to the plaintext
291
data buffer */
292
rc = gpgme_op_decrypt(mc.ctx, dh_crypto, dh_plain);
293
if(rc != GPG_ERR_NO_ERROR){
154
294
fprintf(stderr, "bad gpgme_op_decrypt: %s: %s\n",
155
295
gpgme_strsource(rc), gpgme_strerror(rc));
156
return -1;
157
}
158
159
if(debug){
160
fprintf(stderr, "Decryption of OpenPGP packet succeeded\n");
161
}
162
163
if (debug){
164
gpgme_decrypt_result_t result;
165
result = gpgme_op_decrypt_result(ctx);
166
if (result == NULL){
167
fprintf(stderr, "gpgme_op_decrypt_result failed\n");
168
} else {
169
fprintf(stderr, "Unsupported algorithm: %s\n",
170
result->unsupported_algorithm);
171
fprintf(stderr, "Wrong key usage: %d\n",
172
result->wrong_key_usage);
173
if(result->file_name != NULL){
174
fprintf(stderr, "File name: %s\n", result->file_name);
175
}
176
gpgme_recipient_t recipient;
177
recipient = result->recipients;
178
if(recipient){
296
plaintext_length = -1;
297
if(debug){
298
gpgme_decrypt_result_t result;
299
result = gpgme_op_decrypt_result(mc.ctx);
300
if(result == NULL){
301
fprintf(stderr, "gpgme_op_decrypt_result failed\n");
302
} else {
303
fprintf(stderr, "Unsupported algorithm: %s\n",
304
result->unsupported_algorithm);
305
fprintf(stderr, "Wrong key usage: %u\n",
306
result->wrong_key_usage);
307
if(result->file_name != NULL){
308
fprintf(stderr, "File name: %s\n", result->file_name);
309
}
310
gpgme_recipient_t recipient;
311
recipient = result->recipients;
179
312
while(recipient != NULL){
180
313
fprintf(stderr, "Public key algorithm: %s\n",
181
314
gpgme_pubkey_algo_name(recipient->pubkey_algo));
187
320
}
188
321
}
189
322
}
323
goto decrypt_end;
190
324
}
191
325
192
/* Delete the GPGME FILE pointer cryptotext data buffer */
193
gpgme_data_release(dh_crypto);
326
if(debug){
327
fprintf(stderr, "Decryption of OpenPGP data succeeded\n");
328
}
194
329
195
330
/* Seek back to the beginning of the GPGME plaintext data buffer */
196
gpgme_data_seek(dh_plain, (off_t) 0, SEEK_SET);
197
198
*new_packet = 0;
331
if(gpgme_data_seek(dh_plain, (off_t)0, SEEK_SET) == -1){
332
perror("gpgme_data_seek");
333
plaintext_length = -1;
334
goto decrypt_end;
335
}
336
337
*plaintext = NULL;
199
338
while(true){
200
if (new_packet_length + BUFFER_SIZE > new_packet_capacity){
201
*new_packet = realloc(*new_packet,
202
(unsigned int)new_packet_capacity
203
+ BUFFER_SIZE);
204
if (*new_packet == NULL){
205
perror("realloc");
206
return -1;
207
}
208
new_packet_capacity += BUFFER_SIZE;
339
plaintext_capacity = incbuffer(plaintext,
340
(size_t)plaintext_length,
341
plaintext_capacity);
342
if(plaintext_capacity == 0){
343
perror("incbuffer");
344
plaintext_length = -1;
345
goto decrypt_end;
209
346
}
210
347
211
ret = gpgme_data_read(dh_plain, *new_packet + new_packet_length,
348
ret = gpgme_data_read(dh_plain, *plaintext + plaintext_length,
212
349
BUFFER_SIZE);
213
350
/* Print the data, if any */
214
if (ret == 0){
351
if(ret == 0){
352
/* EOF */
215
353
break;
216
354
}
217
355
if(ret < 0){
218
356
perror("gpgme_data_read");
219
return -1;
220
}
221
new_packet_length += ret;
222
}
223
224
/* FIXME: check characters before printing to screen so to not print
225
terminal control characters */
226
/* if(debug){ */
227
/* fprintf(stderr, "decrypted password is: "); */
228
/* fwrite(*new_packet, 1, new_packet_length, stderr); */
229
/* fprintf(stderr, "\n"); */
230
/* } */
357
plaintext_length = -1;
358
goto decrypt_end;
359
}
360
plaintext_length += ret;
361
}
362
363
if(debug){
364
fprintf(stderr, "Decrypted password is: ");
365
for(ssize_t i = 0; i < plaintext_length; i++){
366
fprintf(stderr, "%02hhX ", (*plaintext)[i]);
367
}
368
fprintf(stderr, "\n");
369
}
370
371
decrypt_end:
372
373
/* Delete the GPGME cryptotext data buffer */
374
gpgme_data_release(dh_crypto);
231
375
232
376
/* Delete the GPGME plaintext data buffer */
233
377
gpgme_data_release(dh_plain);
234
return new_packet_length;
378
return plaintext_length;
235
379
}
236
380
237
static const char * safer_gnutls_strerror (int value) {
238
const char *ret = gnutls_strerror (value);
239
if (ret == NULL)
381
static const char * safer_gnutls_strerror(int value){
382
const char *ret = gnutls_strerror(value); /* Spurious warning from
383
-Wunreachable-code */
384
if(ret == NULL)
240
385
ret = "(unknown)";
241
386
return ret;
242
387
}
243
388
244
void debuggnutls(__attribute__((unused)) int level,
245
const char* string){
246
fprintf(stderr, "%s", string);
389
/* GnuTLS log function callback */
390
static void debuggnutls(__attribute__((unused)) int level,
391
const char* string){
392
fprintf(stderr, "GnuTLS: %s", string);
247
393
}
248
394
249
int initgnutls(encrypted_session *es){
250
const char *err;
395
static int init_gnutls_global(const char *pubkeyfilename,
396
const char *seckeyfilename){
251
397
int ret;
252
398
253
399
if(debug){
254
400
fprintf(stderr, "Initializing GnuTLS\n");
255
401
}
256
402
257
if ((ret = gnutls_global_init ())
258
!= GNUTLS_E_SUCCESS) {
259
fprintf (stderr, "global_init: %s\n", safer_gnutls_strerror(ret));
403
ret = gnutls_global_init();
404
if(ret != GNUTLS_E_SUCCESS){
405
fprintf(stderr, "GnuTLS global_init: %s\n",
406
safer_gnutls_strerror(ret));
260
407
return -1;
261
408
}
262
263
if (debug){
409
410
if(debug){
411
/* "Use a log level over 10 to enable all debugging options."
412
* - GnuTLS manual
413
*/
264
414
gnutls_global_set_log_level(11);
265
415
gnutls_global_set_log_function(debuggnutls);
266
416
}
267
417
268
/* openpgp credentials */
269
if ((ret = gnutls_certificate_allocate_credentials (&es->cred))
270
!= GNUTLS_E_SUCCESS) {
271
fprintf (stderr, "memory error: %s\n",
272
safer_gnutls_strerror(ret));
418
/* OpenPGP credentials */
419
gnutls_certificate_allocate_credentials(&mc.cred);
420
if(ret != GNUTLS_E_SUCCESS){
421
fprintf(stderr, "GnuTLS memory error: %s\n", /* Spurious warning
422
from
423
-Wunreachable-code
424
*/
425
safer_gnutls_strerror(ret));
426
gnutls_global_deinit();
273
427
return -1;
274
428
}
275
429
276
430
if(debug){
277
fprintf(stderr, "Attempting to use OpenPGP certificate %s"
278
" and keyfile %s as GnuTLS credentials\n", CERTFILE,
279
KEYFILE);
431
fprintf(stderr, "Attempting to use OpenPGP public key %s and"
432
" secret key %s as GnuTLS credentials\n", pubkeyfilename,
433
seckeyfilename);
280
434
}
281
435
282
436
ret = gnutls_certificate_set_openpgp_key_file
283
(es->cred, CERTFILE, KEYFILE, GNUTLS_OPENPGP_FMT_BASE64);
284
if (ret != GNUTLS_E_SUCCESS) {
285
fprintf
286
(stderr, "Error[%d] while reading the OpenPGP key pair ('%s',"
287
" '%s')\n",
288
ret, CERTFILE, KEYFILE);
289
fprintf(stdout, "The Error is: %s\n",
290
safer_gnutls_strerror(ret));
291
return -1;
292
}
293
294
//GnuTLS server initialization
295
if ((ret = gnutls_dh_params_init (&es->dh_params))
296
!= GNUTLS_E_SUCCESS) {
297
fprintf (stderr, "Error in dh parameter initialization: %s\n",
298
safer_gnutls_strerror(ret));
299
return -1;
300
}
301
302
if ((ret = gnutls_dh_params_generate2 (es->dh_params, DH_BITS))
303
!= GNUTLS_E_SUCCESS) {
304
fprintf (stderr, "Error in prime generation: %s\n",
305
safer_gnutls_strerror(ret));
306
return -1;
307
}
308
309
gnutls_certificate_set_dh_params (es->cred, es->dh_params);
310
311
// GnuTLS session creation
312
if ((ret = gnutls_init (&es->session, GNUTLS_SERVER))
313
!= GNUTLS_E_SUCCESS){
437
(mc.cred, pubkeyfilename, seckeyfilename,
438
GNUTLS_OPENPGP_FMT_BASE64);
439
if(ret != GNUTLS_E_SUCCESS){
440
fprintf(stderr,
441
"Error[%d] while reading the OpenPGP key pair ('%s',"
442
" '%s')\n", ret, pubkeyfilename, seckeyfilename);
443
fprintf(stderr, "The GnuTLS error is: %s\n",
444
safer_gnutls_strerror(ret));
445
goto globalfail;
446
}
447
448
/* GnuTLS server initialization */
449
ret = gnutls_dh_params_init(&mc.dh_params);
450
if(ret != GNUTLS_E_SUCCESS){
451
fprintf(stderr, "Error in GnuTLS DH parameter initialization:"
452
" %s\n", safer_gnutls_strerror(ret));
453
goto globalfail;
454
}
455
ret = gnutls_dh_params_generate2(mc.dh_params, mc.dh_bits);
456
if(ret != GNUTLS_E_SUCCESS){
457
fprintf(stderr, "Error in GnuTLS prime generation: %s\n",
458
safer_gnutls_strerror(ret));
459
goto globalfail;
460
}
461
462
gnutls_certificate_set_dh_params(mc.cred, mc.dh_params);
463
464
return 0;
465
466
globalfail:
467
468
gnutls_certificate_free_credentials(mc.cred);
469
gnutls_global_deinit();
470
gnutls_dh_params_deinit(mc.dh_params);
471
return -1;
472
}
473
474
static int init_gnutls_session(gnutls_session_t *session){
475
int ret;
476
/* GnuTLS session creation */
477
ret = gnutls_init(session, GNUTLS_SERVER);
478
if(ret != GNUTLS_E_SUCCESS){
314
479
fprintf(stderr, "Error in GnuTLS session initialization: %s\n",
315
480
safer_gnutls_strerror(ret));
316
481
}
317
482
318
if ((ret = gnutls_priority_set_direct (es->session, "NORMAL", &err))
319
!= GNUTLS_E_SUCCESS) {
320
fprintf(stderr, "Syntax error at: %s\n", err);
321
fprintf(stderr, "GnuTLS error: %s\n",
322
safer_gnutls_strerror(ret));
323
return -1;
483
{
484
const char *err;
485
ret = gnutls_priority_set_direct(*session, mc.priority, &err);
486
if(ret != GNUTLS_E_SUCCESS){
487
fprintf(stderr, "Syntax error at: %s\n", err);
488
fprintf(stderr, "GnuTLS error: %s\n",
489
safer_gnutls_strerror(ret));
490
gnutls_deinit(*session);
491
return -1;
492
}
324
493
}
325
494
326
if ((ret = gnutls_credentials_set
327
(es->session, GNUTLS_CRD_CERTIFICATE, es->cred))
328
!= GNUTLS_E_SUCCESS) {
329
fprintf(stderr, "Error setting a credentials set: %s\n",
495
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
496
mc.cred);
497
if(ret != GNUTLS_E_SUCCESS){
498
fprintf(stderr, "Error setting GnuTLS credentials: %s\n",
330
499
safer_gnutls_strerror(ret));
500
gnutls_deinit(*session);
331
501
return -1;
332
502
}
333
503
334
504
/* ignore client certificate if any. */
335
gnutls_certificate_server_set_request (es->session,
336
GNUTLS_CERT_IGNORE);
505
gnutls_certificate_server_set_request(*session,
506
GNUTLS_CERT_IGNORE);
337
507
338
gnutls_dh_set_prime_bits (es->session, DH_BITS);
508
gnutls_dh_set_prime_bits(*session, mc.dh_bits);
339
509
340
510
return 0;
341
511
}
342
512
343
void empty_log(__attribute__((unused)) AvahiLogLevel level,
344
__attribute__((unused)) const char *txt){}
345
346
int start_mandos_communication(const char *ip, uint16_t port,
347
unsigned int if_index){
348
int ret, tcp_sd;
349
struct sockaddr_in6 to;
350
encrypted_session es;
513
/* Avahi log function callback */
514
static void empty_log(__attribute__((unused)) AvahiLogLevel level,
515
__attribute__((unused)) const char *txt){}
516
517
sig_atomic_t quit_now = 0;
518
int signal_received = 0;
519
520
/* Called when a Mandos server is found */
521
static int start_mandos_communication(const char *ip, uint16_t port,
522
AvahiIfIndex if_index,
523
int af){
524
int ret, tcp_sd = -1;
525
ssize_t sret;
526
union {
527
struct sockaddr_in in;
528
struct sockaddr_in6 in6;
529
} to;
351
530
char *buffer = NULL;
352
531
char *decrypted_buffer;
353
532
size_t buffer_length = 0;
354
533
size_t buffer_capacity = 0;
355
534
ssize_t decrypted_buffer_size;
356
size_t written = 0;
535
size_t written;
357
536
int retval = 0;
358
char interface[IF_NAMESIZE];
537
gnutls_session_t session;
538
int pf; /* Protocol family */
539
540
if(quit_now){
541
return -1;
542
}
543
544
switch(af){
545
case AF_INET6:
546
pf = PF_INET6;
547
break;
548
case AF_INET:
549
pf = PF_INET;
550
break;
551
default:
552
fprintf(stderr, "Bad address family: %d\n", af);
553
return -1;
554
}
555
556
ret = init_gnutls_session(&session);
557
if(ret != 0){
558
return -1;
559
}
359
560
360
561
if(debug){
361
fprintf(stderr, "Setting up a tcp connection to %s\n", ip);
562
fprintf(stderr, "Setting up a TCP connection to %s, port %" PRIu16
563
"\n", ip, port);
362
564
}
363
565
364
tcp_sd = socket(PF_INET6, SOCK_STREAM, 0);
365
if(tcp_sd < 0) {
566
tcp_sd = socket(pf, SOCK_STREAM, 0);
567
if(tcp_sd < 0){
366
568
perror("socket");
367
return -1;
368
}
369
370
if(if_indextoname(if_index, interface) == NULL){
371
if(debug){
372
perror("if_indextoname");
373
}
374
return -1;
375
}
376
377
if(debug){
378
fprintf(stderr, "Binding to interface %s\n", interface);
379
}
380
381
memset(&to,0,sizeof(to)); /* Spurious warning */
382
to.sin6_family = AF_INET6;
383
ret = inet_pton(AF_INET6, ip, &to.sin6_addr);
384
if (ret < 0 ){
569
retval = -1;
570
goto mandos_end;
571
}
572
573
if(quit_now){
574
goto mandos_end;
575
}
576
577
memset(&to, 0, sizeof(to));
578
if(af == AF_INET6){
579
to.in6.sin6_family = (sa_family_t)af;
580
ret = inet_pton(af, ip, &to.in6.sin6_addr);
581
} else { /* IPv4 */
582
to.in.sin_family = (sa_family_t)af;
583
ret = inet_pton(af, ip, &to.in.sin_addr);
584
}
585
if(ret < 0 ){
385
586
perror("inet_pton");
386
return -1;
387
}
587
retval = -1;
588
goto mandos_end;
589
}
388
590
if(ret == 0){
389
591
fprintf(stderr, "Bad address: %s\n", ip);
390
return -1;
391
}
392
to.sin6_port = htons(port); /* Spurious warning */
592
retval = -1;
593
goto mandos_end;
594
}
595
if(af == AF_INET6){
596
to.in6.sin6_port = htons(port); /* Spurious warnings from
597
-Wconversion and
598
-Wunreachable-code */
599
600
if(IN6_IS_ADDR_LINKLOCAL /* Spurious warnings from */
601
(&to.in6.sin6_addr)){ /* -Wstrict-aliasing=2 or lower and
602
-Wunreachable-code*/
603
if(if_index == AVAHI_IF_UNSPEC){
604
fprintf(stderr, "An IPv6 link-local address is incomplete"
605
" without a network interface\n");
606
retval = -1;
607
goto mandos_end;
608
}
609
/* Set the network interface number as scope */
610
to.in6.sin6_scope_id = (uint32_t)if_index;
611
}
612
} else {
613
to.in.sin_port = htons(port); /* Spurious warnings from
614
-Wconversion and
615
-Wunreachable-code */
616
}
393
617
394
to.sin6_scope_id = (uint32_t)if_index;
618
if(quit_now){
619
goto mandos_end;
620
}
395
621
396
622
if(debug){
397
fprintf(stderr, "Connection to: %s\n", ip);
398
}
399
400
ret = connect(tcp_sd, (struct sockaddr *) &to, sizeof(to));
401
if (ret < 0){
623
if(af == AF_INET6 and if_index != AVAHI_IF_UNSPEC){
624
char interface[IF_NAMESIZE];
625
if(if_indextoname((unsigned int)if_index, interface) == NULL){
626
perror("if_indextoname");
627
} else {
628
fprintf(stderr, "Connection to: %s%%%s, port %" PRIu16 "\n",
629
ip, interface, port);
630
}
631
} else {
632
fprintf(stderr, "Connection to: %s, port %" PRIu16 "\n", ip,
633
port);
634
}
635
char addrstr[(INET_ADDRSTRLEN > INET6_ADDRSTRLEN) ?
636
INET_ADDRSTRLEN : INET6_ADDRSTRLEN] = "";
637
const char *pcret;
638
if(af == AF_INET6){
639
pcret = inet_ntop(af, &(to.in6.sin6_addr), addrstr,
640
sizeof(addrstr));
641
} else {
642
pcret = inet_ntop(af, &(to.in.sin_addr), addrstr,
643
sizeof(addrstr));
644
}
645
if(pcret == NULL){
646
perror("inet_ntop");
647
} else {
648
if(strcmp(addrstr, ip) != 0){
649
fprintf(stderr, "Canonical address form: %s\n", addrstr);
650
}
651
}
652
}
653
654
if(quit_now){
655
goto mandos_end;
656
}
657
658
if(af == AF_INET6){
659
ret = connect(tcp_sd, &to.in6, sizeof(to));
660
} else {
661
ret = connect(tcp_sd, &to.in, sizeof(to)); /* IPv4 */
662
}
663
if(ret < 0){
402
664
perror("connect");
403
return -1;
404
}
405
406
ret = initgnutls (&es);
407
if (ret != 0){
408
665
retval = -1;
409
return -1;
410
}
411
412
gnutls_transport_set_ptr (es.session,
413
(gnutls_transport_ptr_t) tcp_sd);
666
goto mandos_end;
667
}
668
669
if(quit_now){
670
goto mandos_end;
671
}
672
673
const char *out = mandos_protocol_version;
674
written = 0;
675
while(true){
676
size_t out_size = strlen(out);
677
ret = (int)TEMP_FAILURE_RETRY(write(tcp_sd, out + written,
678
out_size - written));
679
if(ret == -1){
680
perror("write");
681
retval = -1;
682
goto mandos_end;
683
}
684
written += (size_t)ret;
685
if(written < out_size){
686
continue;
687
} else {
688
if(out == mandos_protocol_version){
689
written = 0;
690
out = "\r\n";
691
} else {
692
break;
693
}
694
}
695
696
if(quit_now){
697
goto mandos_end;
698
}
699
}
414
700
415
701
if(debug){
416
702
fprintf(stderr, "Establishing TLS session with %s\n", ip);
417
703
}
418
704
419
ret = gnutls_handshake (es.session);
420
421
if (ret != GNUTLS_E_SUCCESS){
422
fprintf(stderr, "\n*** Handshake failed ***\n");
423
gnutls_perror (ret);
705
if(quit_now){
706
goto mandos_end;
707
}
708
709
gnutls_transport_set_ptr(session, (gnutls_transport_ptr_t) tcp_sd);
710
711
if(quit_now){
712
goto mandos_end;
713
}
714
715
do{
716
ret = gnutls_handshake(session);
717
if(quit_now){
718
goto mandos_end;
719
}
720
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
721
722
if(ret != GNUTLS_E_SUCCESS){
723
if(debug){
724
fprintf(stderr, "*** GnuTLS Handshake failed ***\n");
725
gnutls_perror(ret);
726
}
424
727
retval = -1;
425
goto exit;
728
goto mandos_end;
426
729
}
427
730
428
//Retrieve OpenPGP packet that contains the wanted password
731
/* Read OpenPGP packet that contains the wanted password */
429
732
430
733
if(debug){
431
fprintf(stderr, "Retrieving pgp encrypted password from %s\n",
734
fprintf(stderr, "Retrieving OpenPGP encrypted password from %s\n",
432
735
ip);
433
736
}
434
737
435
738
while(true){
436
if (buffer_length + BUFFER_SIZE > buffer_capacity){
437
buffer = realloc(buffer, buffer_capacity + BUFFER_SIZE);
438
if (buffer == NULL){
439
perror("realloc");
440
goto exit;
441
}
442
buffer_capacity += BUFFER_SIZE;
443
}
444
445
ret = gnutls_record_recv
446
(es.session, buffer+buffer_length, BUFFER_SIZE);
447
if (ret == 0){
739
740
if(quit_now){
741
goto mandos_end;
742
}
743
744
buffer_capacity = incbuffer(&buffer, buffer_length,
745
buffer_capacity);
746
if(buffer_capacity == 0){
747
perror("incbuffer");
748
retval = -1;
749
goto mandos_end;
750
}
751
752
if(quit_now){
753
goto mandos_end;
754
}
755
756
sret = gnutls_record_recv(session, buffer+buffer_length,
757
BUFFER_SIZE);
758
if(sret == 0){
448
759
break;
449
760
}
450
if (ret < 0){
451
switch(ret){
761
if(sret < 0){
762
switch(sret){
452
763
case GNUTLS_E_INTERRUPTED:
453
764
case GNUTLS_E_AGAIN:
454
765
break;
455
766
case GNUTLS_E_REHANDSHAKE:
456
ret = gnutls_handshake (es.session);
457
if (ret < 0){
458
fprintf(stderr, "\n*** Handshake failed ***\n");
459
gnutls_perror (ret);
767
do{
768
ret = gnutls_handshake(session);
769
770
if(quit_now){
771
goto mandos_end;
772
}
773
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
774
if(ret < 0){
775
fprintf(stderr, "*** GnuTLS Re-handshake failed ***\n");
776
gnutls_perror(ret);
460
777
retval = -1;
461
goto exit;
778
goto mandos_end;
462
779
}
463
780
break;
464
781
default:
465
782
fprintf(stderr, "Unknown error while reading data from"
466
" encrypted session with mandos server\n");
783
" encrypted session with Mandos server\n");
467
784
retval = -1;
468
gnutls_bye (es.session, GNUTLS_SHUT_RDWR);
469
goto exit;
785
gnutls_bye(session, GNUTLS_SHUT_RDWR);
786
goto mandos_end;
470
787
}
471
788
} else {
472
buffer_length += (size_t) ret;
789
buffer_length += (size_t) sret;
473
790
}
474
791
}
475
792
476
if (buffer_length > 0){
793
if(debug){
794
fprintf(stderr, "Closing TLS session\n");
795
}
796
797
if(quit_now){
798
goto mandos_end;
799
}
800
801
gnutls_bye(session, GNUTLS_SHUT_RDWR);
802
803
if(quit_now){
804
goto mandos_end;
805
}
806
807
if(buffer_length > 0){
477
808
decrypted_buffer_size = pgp_packet_decrypt(buffer,
478
809
buffer_length,
479
&decrypted_buffer,
480
CERT_ROOT);
481
if (decrypted_buffer_size >= 0){
482
while(written < decrypted_buffer_size){
483
ret = (int)fwrite (decrypted_buffer + written, 1,
484
(size_t)decrypted_buffer_size - written,
485
stdout);
810
&decrypted_buffer);
811
if(decrypted_buffer_size >= 0){
812
written = 0;
813
while(written < (size_t) decrypted_buffer_size){
814
if(quit_now){
815
goto mandos_end;
816
}
817
818
ret = (int)fwrite(decrypted_buffer + written, 1,
819
(size_t)decrypted_buffer_size - written,
820
stdout);
486
821
if(ret == 0 and ferror(stdout)){
487
822
if(debug){
488
823
fprintf(stderr, "Error writing encrypted data: %s\n",
497
832
} else {
498
833
retval = -1;
499
834
}
500
}
501
502
//shutdown procedure
503
504
if(debug){
505
fprintf(stderr, "Closing TLS session\n");
506
}
507
835
} else {
836
retval = -1;
837
}
838
839
/* Shutdown procedure */
840
841
mandos_end:
508
842
free(buffer);
509
gnutls_bye (es.session, GNUTLS_SHUT_RDWR);
510
exit:
511
close(tcp_sd);
512
gnutls_deinit (es.session);
513
gnutls_certificate_free_credentials (es.cred);
514
gnutls_global_deinit ();
843
if(tcp_sd >= 0){
844
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
845
}
846
if(ret == -1){
847
perror("close");
848
}
849
gnutls_deinit(session);
850
if(quit_now){
851
retval = -1;
852
}
515
853
return retval;
516
854
}
517
855
518
static AvahiSimplePoll *simple_poll = NULL;
519
static AvahiServer *server = NULL;
520
521
static void resolve_callback(
522
AvahiSServiceResolver *r,
523
AvahiIfIndex interface,
524
AVAHI_GCC_UNUSED AvahiProtocol protocol,
525
AvahiResolverEvent event,
526
const char *name,
527
const char *type,
528
const char *domain,
529
const char *host_name,
530
const AvahiAddress *address,
531
uint16_t port,
532
AVAHI_GCC_UNUSED AvahiStringList *txt,
533
AVAHI_GCC_UNUSED AvahiLookupResultFlags flags,
534
AVAHI_GCC_UNUSED void* userdata) {
535
536
assert(r); /* Spurious warning */
856
static void resolve_callback(AvahiSServiceResolver *r,
857
AvahiIfIndex interface,
858
AvahiProtocol proto,
859
AvahiResolverEvent event,
860
const char *name,
861
const char *type,
862
const char *domain,
863
const char *host_name,
864
const AvahiAddress *address,
865
uint16_t port,
866
AVAHI_GCC_UNUSED AvahiStringList *txt,
867
AVAHI_GCC_UNUSED AvahiLookupResultFlags
868
flags,
869
AVAHI_GCC_UNUSED void* userdata){
870
assert(r);
537
871
538
872
/* Called whenever a service has been resolved successfully or
539
873
timed out */
540
874
541
switch (event) {
875
if(quit_now){
876
return;
877
}
878
879
switch(event){
542
880
default:
543
881
case AVAHI_RESOLVER_FAILURE:
544
fprintf(stderr, "(Resolver) Failed to resolve service '%s' of"
545
" type '%s' in domain '%s': %s\n", name, type, domain,
546
avahi_strerror(avahi_server_errno(server)));
882
fprintf(stderr, "(Avahi Resolver) Failed to resolve service '%s'"
883
" of type '%s' in domain '%s': %s\n", name, type, domain,
884
avahi_strerror(avahi_server_errno(mc.server)));
547
885
break;
548
886
549
887
case AVAHI_RESOLVER_FOUND:
551
889
char ip[AVAHI_ADDRESS_STR_MAX];
552
890
avahi_address_snprint(ip, sizeof(ip), address);
553
891
if(debug){
554
fprintf(stderr, "Mandos server found on %s (%s) on port %d\n",
555
host_name, ip, port);
892
fprintf(stderr, "Mandos server \"%s\" found on %s (%s, %"
893
PRIdMAX ") on port %" PRIu16 "\n", name, host_name,
894
ip, (intmax_t)interface, port);
556
895
}
557
int ret = start_mandos_communication(ip, port,
558
(unsigned int) interface);
559
if (ret == 0){
560
exit(EXIT_SUCCESS);
561
} else {
562
exit(EXIT_FAILURE);
896
int ret = start_mandos_communication(ip, port, interface,
897
avahi_proto_to_af(proto));
898
if(ret == 0){
899
avahi_simple_poll_quit(mc.simple_poll);
563
900
}
564
901
}
565
902
}
566
903
avahi_s_service_resolver_free(r);
567
904
}
568
905
569
static void browse_callback(
570
AvahiSServiceBrowser *b,
571
AvahiIfIndex interface,
572
AvahiProtocol protocol,
573
AvahiBrowserEvent event,
574
const char *name,
575
const char *type,
576
const char *domain,
577
AVAHI_GCC_UNUSED AvahiLookupResultFlags flags,
578
void* userdata) {
579
580
AvahiServer *s = userdata;
581
assert(b); /* Spurious warning */
582
583
/* Called whenever a new services becomes available on the LAN or
584
is removed from the LAN */
585
586
switch (event) {
587
default:
588
case AVAHI_BROWSER_FAILURE:
589
590
fprintf(stderr, "(Browser) %s\n",
591
avahi_strerror(avahi_server_errno(server)));
592
avahi_simple_poll_quit(simple_poll);
593
return;
594
595
case AVAHI_BROWSER_NEW:
596
/* We ignore the returned resolver object. In the callback
597
function we free it. If the server is terminated before
598
the callback function is called the server will free
599
the resolver for us. */
600
601
if (!(avahi_s_service_resolver_new(s, interface, protocol, name,
602
type, domain,
603
AVAHI_PROTO_INET6, 0,
604
resolve_callback, s)))
605
fprintf(stderr, "Failed to resolve service '%s': %s\n", name,
606
avahi_strerror(avahi_server_errno(s)));
607
break;
608
609
case AVAHI_BROWSER_REMOVE:
610
break;
611
612
case AVAHI_BROWSER_ALL_FOR_NOW:
613
case AVAHI_BROWSER_CACHE_EXHAUSTED:
614
break;
615
}
616
}
617
618
int main(AVAHI_GCC_UNUSED int argc, AVAHI_GCC_UNUSED char*argv[]) {
906
static void browse_callback(AvahiSServiceBrowser *b,
907
AvahiIfIndex interface,
908
AvahiProtocol protocol,
909
AvahiBrowserEvent event,
910
const char *name,
911
const char *type,
912
const char *domain,
913
AVAHI_GCC_UNUSED AvahiLookupResultFlags
914
flags,
915
AVAHI_GCC_UNUSED void* userdata){
916
assert(b);
917
918
/* Called whenever a new services becomes available on the LAN or
919
is removed from the LAN */
920
921
if(quit_now){
922
return;
923
}
924
925
switch(event){
926
default:
927
case AVAHI_BROWSER_FAILURE:
928
929
fprintf(stderr, "(Avahi browser) %s\n",
930
avahi_strerror(avahi_server_errno(mc.server)));
931
avahi_simple_poll_quit(mc.simple_poll);
932
return;
933
934
case AVAHI_BROWSER_NEW:
935
/* We ignore the returned Avahi resolver object. In the callback
936
function we free it. If the Avahi server is terminated before
937
the callback function is called the Avahi server will free the
938
resolver for us. */
939
940
if(avahi_s_service_resolver_new(mc.server, interface, protocol,
941
name, type, domain, protocol, 0,
942
resolve_callback, NULL) == NULL)
943
fprintf(stderr, "Avahi: Failed to resolve service '%s': %s\n",
944
name, avahi_strerror(avahi_server_errno(mc.server)));
945
break;
946
947
case AVAHI_BROWSER_REMOVE:
948
break;
949
950
case AVAHI_BROWSER_ALL_FOR_NOW:
951
case AVAHI_BROWSER_CACHE_EXHAUSTED:
952
if(debug){
953
fprintf(stderr, "No Mandos server found, still searching...\n");
954
}
955
break;
956
}
957
}
958
959
/* stop main loop after sigterm has been called */
960
static void handle_sigterm(int sig){
961
if(quit_now){
962
return;
963
}
964
quit_now = 1;
965
signal_received = sig;
966
int old_errno = errno;
967
if(mc.simple_poll != NULL){
968
avahi_simple_poll_quit(mc.simple_poll);
969
}
970
errno = old_errno;
971
}
972
973
int main(int argc, char *argv[]){
974
AvahiSServiceBrowser *sb = NULL;
975
int error;
976
int ret;
977
intmax_t tmpmax;
978
char *tmp;
979
int exitcode = EXIT_SUCCESS;
980
const char *interface = "eth0";
981
struct ifreq network;
982
int sd = -1;
983
bool take_down_interface = false;
984
uid_t uid;
985
gid_t gid;
986
char *connect_to = NULL;
987
char tempdir[] = "/tmp/mandosXXXXXX";
988
bool tempdir_created = false;
989
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
990
const char *seckey = PATHDIR "/" SECKEY;
991
const char *pubkey = PATHDIR "/" PUBKEY;
992
993
bool gnutls_initialized = false;
994
bool gpgme_initialized = false;
995
float delay = 2.5f;
996
997
struct sigaction old_sigterm_action;
998
struct sigaction sigterm_action = { .sa_handler = handle_sigterm };
999
1000
{
1001
struct argp_option options[] = {
1002
{ .name = "debug", .key = 128,
1003
.doc = "Debug mode", .group = 3 },
1004
{ .name = "connect", .key = 'c',
1005
.arg = "ADDRESS:PORT",
1006
.doc = "Connect directly to a specific Mandos server",
1007
.group = 1 },
1008
{ .name = "interface", .key = 'i',
1009
.arg = "NAME",
1010
.doc = "Network interface that will be used to search for"
1011
" Mandos servers",
1012
.group = 1 },
1013
{ .name = "seckey", .key = 's',
1014
.arg = "FILE",
1015
.doc = "OpenPGP secret key file base name",
1016
.group = 1 },
1017
{ .name = "pubkey", .key = 'p',
1018
.arg = "FILE",
1019
.doc = "OpenPGP public key file base name",
1020
.group = 2 },
1021
{ .name = "dh-bits", .key = 129,
1022
.arg = "BITS",
1023
.doc = "Bit length of the prime number used in the"
1024
" Diffie-Hellman key exchange",
1025
.group = 2 },
1026
{ .name = "priority", .key = 130,
1027
.arg = "STRING",
1028
.doc = "GnuTLS priority string for the TLS handshake",
1029
.group = 1 },
1030
{ .name = "delay", .key = 131,
1031
.arg = "SECONDS",
1032
.doc = "Maximum delay to wait for interface startup",
1033
.group = 2 },
1034
{ .name = NULL }
1035
};
1036
1037
error_t parse_opt(int key, char *arg,
1038
struct argp_state *state){
1039
switch(key){
1040
case 128: /* --debug */
1041
debug = true;
1042
break;
1043
case 'c': /* --connect */
1044
connect_to = arg;
1045
break;
1046
case 'i': /* --interface */
1047
interface = arg;
1048
break;
1049
case 's': /* --seckey */
1050
seckey = arg;
1051
break;
1052
case 'p': /* --pubkey */
1053
pubkey = arg;
1054
break;
1055
case 129: /* --dh-bits */
1056
errno = 0;
1057
tmpmax = strtoimax(arg, &tmp, 10);
1058
if(errno != 0 or tmp == arg or *tmp != '\0'
1059
or tmpmax != (typeof(mc.dh_bits))tmpmax){
1060
fprintf(stderr, "Bad number of DH bits\n");
1061
exit(EXIT_FAILURE);
1062
}
1063
mc.dh_bits = (typeof(mc.dh_bits))tmpmax;
1064
break;
1065
case 130: /* --priority */
1066
mc.priority = arg;
1067
break;
1068
case 131: /* --delay */
1069
errno = 0;
1070
delay = strtof(arg, &tmp);
1071
if(errno != 0 or tmp == arg or *tmp != '\0'){
1072
fprintf(stderr, "Bad delay\n");
1073
exit(EXIT_FAILURE);
1074
}
1075
break;
1076
case ARGP_KEY_ARG:
1077
argp_usage(state);
1078
case ARGP_KEY_END:
1079
break;
1080
default:
1081
return ARGP_ERR_UNKNOWN;
1082
}
1083
return 0;
1084
}
1085
1086
struct argp argp = { .options = options, .parser = parse_opt,
1087
.args_doc = "",
1088
.doc = "Mandos client -- Get and decrypt"
1089
" passwords from a Mandos server" };
1090
ret = argp_parse(&argp, argc, argv, 0, 0, NULL);
1091
if(ret == ARGP_ERR_UNKNOWN){
1092
fprintf(stderr, "Unknown error while parsing arguments\n");
1093
exitcode = EXIT_FAILURE;
1094
goto end;
1095
}
1096
}
1097
1098
if(not debug){
1099
avahi_set_log_function(empty_log);
1100
}
1101
1102
/* Initialize Avahi early so avahi_simple_poll_quit() can be called
1103
from the signal handler */
1104
/* Initialize the pseudo-RNG for Avahi */
1105
srand((unsigned int) time(NULL));
1106
mc.simple_poll = avahi_simple_poll_new();
1107
if(mc.simple_poll == NULL){
1108
fprintf(stderr, "Avahi: Failed to create simple poll object.\n");
1109
exitcode = EXIT_FAILURE;
1110
goto end;
1111
}
1112
1113
sigemptyset(&sigterm_action.sa_mask);
1114
ret = sigaddset(&sigterm_action.sa_mask, SIGINT);
1115
if(ret == -1){
1116
perror("sigaddset");
1117
exitcode = EXIT_FAILURE;
1118
goto end;
1119
}
1120
ret = sigaddset(&sigterm_action.sa_mask, SIGHUP);
1121
if(ret == -1){
1122
perror("sigaddset");
1123
exitcode = EXIT_FAILURE;
1124
goto end;
1125
}
1126
ret = sigaddset(&sigterm_action.sa_mask, SIGTERM);
1127
if(ret == -1){
1128
perror("sigaddset");
1129
exitcode = EXIT_FAILURE;
1130
goto end;
1131
}
1132
/* Need to check if the handler is SIG_IGN before handling:
1133
| [[info:libc:Initial Signal Actions]] |
1134
| [[info:libc:Basic Signal Handling]] |
1135
*/
1136
ret = sigaction(SIGINT, NULL, &old_sigterm_action);
1137
if(ret == -1){
1138
perror("sigaction");
1139
return EXIT_FAILURE;
1140
}
1141
if(old_sigterm_action.sa_handler != SIG_IGN){
1142
ret = sigaction(SIGINT, &sigterm_action, NULL);
1143
if(ret == -1){
1144
perror("sigaction");
1145
exitcode = EXIT_FAILURE;
1146
goto end;
1147
}
1148
}
1149
ret = sigaction(SIGHUP, NULL, &old_sigterm_action);
1150
if(ret == -1){
1151
perror("sigaction");
1152
return EXIT_FAILURE;
1153
}
1154
if(old_sigterm_action.sa_handler != SIG_IGN){
1155
ret = sigaction(SIGHUP, &sigterm_action, NULL);
1156
if(ret == -1){
1157
perror("sigaction");
1158
exitcode = EXIT_FAILURE;
1159
goto end;
1160
}
1161
}
1162
ret = sigaction(SIGTERM, NULL, &old_sigterm_action);
1163
if(ret == -1){
1164
perror("sigaction");
1165
return EXIT_FAILURE;
1166
}
1167
if(old_sigterm_action.sa_handler != SIG_IGN){
1168
ret = sigaction(SIGTERM, &sigterm_action, NULL);
1169
if(ret == -1){
1170
perror("sigaction");
1171
exitcode = EXIT_FAILURE;
1172
goto end;
1173
}
1174
}
1175
1176
/* If the interface is down, bring it up */
1177
if(interface[0] != '\0'){
1178
if_index = (AvahiIfIndex) if_nametoindex(interface);
1179
if(if_index == 0){
1180
fprintf(stderr, "No such interface: \"%s\"\n", interface);
1181
exitcode = EXIT_FAILURE;
1182
goto end;
1183
}
1184
1185
if(quit_now){
1186
goto end;
1187
}
1188
1189
#ifdef __linux__
1190
/* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
1191
messages to mess up the prompt */
1192
ret = klogctl(8, NULL, 5);
1193
bool restore_loglevel = true;
1194
if(ret == -1){
1195
restore_loglevel = false;
1196
perror("klogctl");
1197
}
1198
#endif /* __linux__ */
1199
1200
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1201
if(sd < 0){
1202
perror("socket");
1203
exitcode = EXIT_FAILURE;
1204
#ifdef __linux__
1205
if(restore_loglevel){
1206
ret = klogctl(7, NULL, 0);
1207
if(ret == -1){
1208
perror("klogctl");
1209
}
1210
}
1211
#endif /* __linux__ */
1212
goto end;
1213
}
1214
strcpy(network.ifr_name, interface);
1215
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1216
if(ret == -1){
1217
perror("ioctl SIOCGIFFLAGS");
1218
#ifdef __linux__
1219
if(restore_loglevel){
1220
ret = klogctl(7, NULL, 0);
1221
if(ret == -1){
1222
perror("klogctl");
1223
}
1224
}
1225
#endif /* __linux__ */
1226
exitcode = EXIT_FAILURE;
1227
goto end;
1228
}
1229
if((network.ifr_flags & IFF_UP) == 0){
1230
network.ifr_flags |= IFF_UP;
1231
take_down_interface = true;
1232
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1233
if(ret == -1){
1234
take_down_interface = false;
1235
perror("ioctl SIOCSIFFLAGS");
1236
exitcode = EXIT_FAILURE;
1237
#ifdef __linux__
1238
if(restore_loglevel){
1239
ret = klogctl(7, NULL, 0);
1240
if(ret == -1){
1241
perror("klogctl");
1242
}
1243
}
1244
#endif /* __linux__ */
1245
goto end;
1246
}
1247
}
1248
/* sleep checking until interface is running */
1249
for(int i=0; i < delay * 4; i++){
1250
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1251
if(ret == -1){
1252
perror("ioctl SIOCGIFFLAGS");
1253
} else if(network.ifr_flags & IFF_RUNNING){
1254
break;
1255
}
1256
struct timespec sleeptime = { .tv_nsec = 250000000 };
1257
ret = nanosleep(&sleeptime, NULL);
1258
if(ret == -1 and errno != EINTR){
1259
perror("nanosleep");
1260
}
1261
}
1262
if(not take_down_interface){
1263
/* We won't need the socket anymore */
1264
ret = (int)TEMP_FAILURE_RETRY(close(sd));
1265
if(ret == -1){
1266
perror("close");
1267
}
1268
}
1269
#ifdef __linux__
1270
if(restore_loglevel){
1271
/* Restores kernel loglevel to default */
1272
ret = klogctl(7, NULL, 0);
1273
if(ret == -1){
1274
perror("klogctl");
1275
}
1276
}
1277
#endif /* __linux__ */
1278
}
1279
1280
if(quit_now){
1281
goto end;
1282
}
1283
1284
uid = getuid();
1285
gid = getgid();
1286
1287
errno = 0;
1288
setgid(gid);
1289
if(ret == -1){
1290
perror("setgid");
1291
}
1292
1293
ret = setuid(uid);
1294
if(ret == -1){
1295
perror("setuid");
1296
}
1297
1298
if(quit_now){
1299
goto end;
1300
}
1301
1302
ret = init_gnutls_global(pubkey, seckey);
1303
if(ret == -1){
1304
fprintf(stderr, "init_gnutls_global failed\n");
1305
exitcode = EXIT_FAILURE;
1306
goto end;
1307
} else {
1308
gnutls_initialized = true;
1309
}
1310
1311
if(quit_now){
1312
goto end;
1313
}
1314
1315
tempdir_created = true;
1316
if(mkdtemp(tempdir) == NULL){
1317
tempdir_created = false;
1318
perror("mkdtemp");
1319
goto end;
1320
}
1321
1322
if(quit_now){
1323
goto end;
1324
}
1325
1326
if(not init_gpgme(pubkey, seckey, tempdir)){
1327
fprintf(stderr, "init_gpgme failed\n");
1328
exitcode = EXIT_FAILURE;
1329
goto end;
1330
} else {
1331
gpgme_initialized = true;
1332
}
1333
1334
if(quit_now){
1335
goto end;
1336
}
1337
1338
if(connect_to != NULL){
1339
/* Connect directly, do not use Zeroconf */
1340
/* (Mainly meant for debugging) */
1341
char *address = strrchr(connect_to, ':');
1342
if(address == NULL){
1343
fprintf(stderr, "No colon in address\n");
1344
exitcode = EXIT_FAILURE;
1345
goto end;
1346
}
1347
1348
if(quit_now){
1349
goto end;
1350
}
1351
1352
uint16_t port;
1353
errno = 0;
1354
tmpmax = strtoimax(address+1, &tmp, 10);
1355
if(errno != 0 or tmp == address+1 or *tmp != '\0'
1356
or tmpmax != (uint16_t)tmpmax){
1357
fprintf(stderr, "Bad port number\n");
1358
exitcode = EXIT_FAILURE;
1359
goto end;
1360
}
1361
1362
if(quit_now){
1363
goto end;
1364
}
1365
1366
port = (uint16_t)tmpmax;
1367
*address = '\0';
1368
address = connect_to;
1369
/* Colon in address indicates IPv6 */
1370
int af;
1371
if(strchr(address, ':') != NULL){
1372
af = AF_INET6;
1373
} else {
1374
af = AF_INET;
1375
}
1376
1377
if(quit_now){
1378
goto end;
1379
}
1380
1381
ret = start_mandos_communication(address, port, if_index, af);
1382
if(ret < 0){
1383
exitcode = EXIT_FAILURE;
1384
} else {
1385
exitcode = EXIT_SUCCESS;
1386
}
1387
goto end;
1388
}
1389
1390
if(quit_now){
1391
goto end;
1392
}
1393
1394
{
619
1395
AvahiServerConfig config;
620
AvahiSServiceBrowser *sb = NULL;
621
int error;
622
int ret;
623
int returncode = EXIT_SUCCESS;
624
const char *interface = "eth0";
625
626
while (true){
627
static struct option long_options[] = {
628
{"debug", no_argument, (int *)&debug, 1},
629
{"interface", required_argument, 0, 'i'},
630
{0, 0, 0, 0} };
631
632
int option_index = 0;
633
ret = getopt_long (argc, argv, "i:", long_options,
634
&option_index);
635
636
if (ret == -1){
637
break;
638
}
639
640
switch(ret){
641
case 0:
642
break;
643
case 'i':
644
interface = optarg;
645
break;
646
default:
647
exit(EXIT_FAILURE);
648
}
649
}
650
651
if (not debug){
652
avahi_set_log_function(empty_log);
653
}
654
655
/* Initialize the psuedo-RNG */
656
srand((unsigned int) time(NULL));
657
658
/* Allocate main loop object */
659
if (!(simple_poll = avahi_simple_poll_new())) {
660
fprintf(stderr, "Failed to create simple poll object.\n");
661
662
goto exit;
663
}
664
665
/* Do not publish any local records */
1396
/* Do not publish any local Zeroconf records */
666
1397
avahi_server_config_init(&config);
667
1398
config.publish_hinfo = 0;
668
1399
config.publish_addresses = 0;
669
1400
config.publish_workstation = 0;
670
1401
config.publish_domain = 0;
671
1402
672
1403
/* Allocate a new server */
673
server = avahi_server_new(avahi_simple_poll_get(simple_poll),
674
&config, NULL, NULL, &error);
675
676
/* Free the configuration data */
1404
mc.server = avahi_server_new(avahi_simple_poll_get
1405
(mc.simple_poll), &config, NULL,
1406
NULL, &error);
1407
1408
/* Free the Avahi configuration data */
677
1409
avahi_server_config_free(&config);
678
679
/* Check if creating the server object succeeded */
680
if (!server) {
681
fprintf(stderr, "Failed to create server: %s\n",
682
avahi_strerror(error));
683
returncode = EXIT_FAILURE;
684
goto exit;
685
}
686
687
/* Create the service browser */
688
sb = avahi_s_service_browser_new(server,
689
(AvahiIfIndex)
690
if_nametoindex(interface),
691
AVAHI_PROTO_INET6,
692
"_mandos._tcp", NULL, 0,
693
browse_callback, server);
694
if (!sb) {
695
fprintf(stderr, "Failed to create service browser: %s\n",
696
avahi_strerror(avahi_server_errno(server)));
697
returncode = EXIT_FAILURE;
698
goto exit;
699
}
700
701
/* Run the main loop */
702
703
if (debug){
704
fprintf(stderr, "Starting avahi loop search\n");
705
}
706
707
avahi_simple_poll_loop(simple_poll);
708
709
exit:
710
711
if (debug){
712
fprintf(stderr, "%s exiting\n", argv[0]);
713
}
714
715
/* Cleanup things */
716
if (sb)
717
avahi_s_service_browser_free(sb);
718
719
if (server)
720
avahi_server_free(server);
721
722
if (simple_poll)
723
avahi_simple_poll_free(simple_poll);
724
725
return returncode;
1410
}
1411
1412
/* Check if creating the Avahi server object succeeded */
1413
if(mc.server == NULL){
1414
fprintf(stderr, "Failed to create Avahi server: %s\n",
1415
avahi_strerror(error));
1416
exitcode = EXIT_FAILURE;
1417
goto end;
1418
}
1419
1420
if(quit_now){
1421
goto end;
1422
}
1423
1424
/* Create the Avahi service browser */
1425
sb = avahi_s_service_browser_new(mc.server, if_index,
1426
AVAHI_PROTO_UNSPEC, "_mandos._tcp",
1427
NULL, 0, browse_callback, NULL);
1428
if(sb == NULL){
1429
fprintf(stderr, "Failed to create service browser: %s\n",
1430
avahi_strerror(avahi_server_errno(mc.server)));
1431
exitcode = EXIT_FAILURE;
1432
goto end;
1433
}
1434
1435
if(quit_now){
1436
goto end;
1437
}
1438
1439
/* Run the main loop */
1440
1441
if(debug){
1442
fprintf(stderr, "Starting Avahi loop search\n");
1443
}
1444
1445
avahi_simple_poll_loop(mc.simple_poll);
1446
1447
end:
1448
1449
if(debug){
1450
fprintf(stderr, "%s exiting\n", argv[0]);
1451
}
1452
1453
/* Cleanup things */
1454
if(sb != NULL)
1455
avahi_s_service_browser_free(sb);
1456
1457
if(mc.server != NULL)
1458
avahi_server_free(mc.server);
1459
1460
if(mc.simple_poll != NULL)
1461
avahi_simple_poll_free(mc.simple_poll);
1462
1463
if(gnutls_initialized){
1464
gnutls_certificate_free_credentials(mc.cred);
1465
gnutls_global_deinit();
1466
gnutls_dh_params_deinit(mc.dh_params);
1467
}
1468
1469
if(gpgme_initialized){
1470
gpgme_release(mc.ctx);
1471
}
1472
1473
/* Take down the network interface */
1474
if(take_down_interface){
1475
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1476
if(ret == -1){
1477
perror("ioctl SIOCGIFFLAGS");
1478
} else if(network.ifr_flags & IFF_UP) {
1479
network.ifr_flags &= ~IFF_UP; /* clear flag */
1480
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1481
if(ret == -1){
1482
perror("ioctl SIOCSIFFLAGS");
1483
}
1484
}
1485
ret = (int)TEMP_FAILURE_RETRY(close(sd));
1486
if(ret == -1){
1487
perror("close");
1488
}
1489
}
1490
1491
/* Removes the temp directory used by GPGME */
1492
if(tempdir_created){
1493
DIR *d;
1494
struct dirent *direntry;
1495
d = opendir(tempdir);
1496
if(d == NULL){
1497
if(errno != ENOENT){
1498
perror("opendir");
1499
}
1500
} else {
1501
while(true){
1502
direntry = readdir(d);
1503
if(direntry == NULL){
1504
break;
1505
}
1506
/* Skip "." and ".." */
1507
if(direntry->d_name[0] == '.'
1508
and (direntry->d_name[1] == '\0'
1509
or (direntry->d_name[1] == '.'
1510
and direntry->d_name[2] == '\0'))){
1511
continue;
1512
}
1513
char *fullname = NULL;
1514
ret = asprintf(&fullname, "%s/%s", tempdir,
1515
direntry->d_name);
1516
if(ret < 0){
1517
perror("asprintf");
1518
continue;
1519
}
1520
ret = remove(fullname);
1521
if(ret == -1){
1522
fprintf(stderr, "remove(\"%s\"): %s\n", fullname,
1523
strerror(errno));
1524
}
1525
free(fullname);
1526
}
1527
closedir(d);
1528
}
1529
ret = rmdir(tempdir);
1530
if(ret == -1 and errno != ENOENT){
1531
perror("rmdir");
1532
}
1533
}
1534
1535
if(quit_now){
1536
sigemptyset(&old_sigterm_action.sa_mask);
1537
old_sigterm_action.sa_handler = SIG_DFL;
1538
ret = sigaction(signal_received, &old_sigterm_action, NULL);
1539
if(ret == -1){
1540
perror("sigaction");
1541
}
1542
raise(signal_received);
1543
}
1544
1545
return exitcode;
726
1546
}
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0