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/mandosclient.c
- browse files at revision 13
- compare with another revision
- download diff
- download tarball
- view history from revision 13
- Committer: Björn Påhlsson
- Date: 2008-07-20 02:52:20 UTC
- Revision ID: belorn@braxen-20080720025220-r5u0388uy9iu23h6
Added following support:
Pluginbased client handler
rewritten Mandos client
Avahi instead of udp server discovery
openpgp encrypted key support
Passprompt stand alone application for direct console input
Added logging for Mandos server
Pluginbased client handler
rewritten Mandos client
Avahi instead of udp server discovery
openpgp encrypted key support
Passprompt stand alone application for direct console input
Added logging for Mandos server
- files added:
- ca.pem
- files removed:
- .bzr-builddeb
- debian
- debian/po
- debian/source
- network-hooks.d
- files renamed:
- clients.conf => mandos-clients.conf
- plugin-runner.c => plugbasedclient.c
- plugins.d/mandos-client.c => plugins.d/mandosclient.c
- plugins.d/password-prompt.c => plugins.d/passprompt.c
- mandos => server.py
- files modified:
- Makefile
added
removed
plugins.d/mandosclient.c
1
/* -*- coding: utf-8 -*- */
2
/*
3
* Mandos-client - get and decrypt data from a Mandos server
1
/* $Id$ */
2
3
/* PLEASE NOTE *
4
* This file demonstrates how to use Avahi's core API, this is
5
* the embeddable mDNS stack for embedded applications.
4
6
*
5
* This program is partly derived from an example program for an Avahi
6
* service browser, downloaded from
7
* <http://avahi.org/browser/examples/core-browse-services.c>. This
8
* includes the following functions: "resolve_callback",
9
* "browse_callback", and parts of "main".
10
*
11
* Everything else is
12
* Copyright © 2008-2011 Teddy Hogeborn
13
* Copyright © 2008-2011 Björn Påhlsson
14
*
15
* This program is free software: you can redistribute it and/or
16
* modify it under the terms of the GNU General Public License as
17
* published by the Free Software Foundation, either version 3 of the
18
* License, or (at your option) any later version.
19
*
20
* This program is distributed in the hope that it will be useful, but
21
* WITHOUT ANY WARRANTY; without even the implied warranty of
22
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
23
* General Public License for more details.
24
*
25
* You should have received a copy of the GNU General Public License
26
* along with this program. If not, see
27
* <http://www.gnu.org/licenses/>.
28
*
29
* Contact the authors at <mandos@recompile.se>.
7
* End user applications should *not* use this API and should use
8
* the D-Bus or C APIs, please see
9
* client-browse-services.c and glib-integration.c
10
*
11
* I repeat, you probably do *not* want to use this example.
30
12
*/
31
13
32
/* Needed by GPGME, specifically gpgme_data_seek() */
33
#ifndef _LARGEFILE_SOURCE
14
/***
15
This file is part of avahi.
16
17
avahi is free software; you can redistribute it and/or modify it
18
under the terms of the GNU Lesser General Public License as
19
published by the Free Software Foundation; either version 2.1 of the
20
License, or (at your option) any later version.
21
22
avahi is distributed in the hope that it will be useful, but WITHOUT
23
ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
24
or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General
25
Public License for more details.
26
27
You should have received a copy of the GNU Lesser General Public
28
License along with avahi; if not, write to the Free Software
29
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
30
USA.
31
***/
32
34
33
#define _LARGEFILE_SOURCE
35
#endif
36
#ifndef _FILE_OFFSET_BITS
37
34
#define _FILE_OFFSET_BITS 64
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, srand(),
47
strtof(), abort() */
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(), S_ISREG */
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
program_invocation_short_name */
67
#include <time.h> /* nanosleep(), time(), sleep() */
68
#include <net/if.h> /* ioctl, ifreq, SIOCGIFFLAGS, IFF_UP,
69
SIOCSIFFLAGS, if_indextoname(),
70
if_nametoindex(), IF_NAMESIZE */
71
#include <netinet/in.h> /* IN6_IS_ADDR_LINKLOCAL,
72
INET_ADDRSTRLEN, INET6_ADDRSTRLEN
73
*/
74
#include <unistd.h> /* close(), SEEK_SET, off_t, write(),
75
getuid(), getgid(), seteuid(),
76
setgid(), pause(), _exit() */
77
#include <arpa/inet.h> /* inet_pton(), htons, inet_ntop() */
78
#include <iso646.h> /* not, or, and */
79
#include <argp.h> /* struct argp_option, error_t, struct
80
argp_state, struct argp,
81
argp_parse(), ARGP_KEY_ARG,
82
ARGP_KEY_END, ARGP_ERR_UNKNOWN */
83
#include <signal.h> /* sigemptyset(), sigaddset(),
84
sigaction(), SIGTERM, sig_atomic_t,
85
raise() */
86
#include <sysexits.h> /* EX_OSERR, EX_USAGE, EX_UNAVAILABLE,
87
EX_NOHOST, EX_IOERR, EX_PROTOCOL */
88
#include <sys/wait.h> /* waitpid(), WIFEXITED(),
89
WEXITSTATUS(), WTERMSIG() */
90
#include <grp.h> /* setgroups() */
91
92
#ifdef __linux__
93
#include <sys/klog.h> /* klogctl() */
94
#endif /* __linux__ */
95
96
/* Avahi */
97
/* All Avahi types, constants and functions
98
Avahi*, avahi_*,
99
AVAHI_* */
35
36
#include <stdio.h>
37
#include <assert.h>
38
#include <stdlib.h>
39
#include <time.h>
40
#include <net/if.h> /* if_nametoindex */
41
100
42
#include <avahi-core/core.h>
101
43
#include <avahi-core/lookup.h>
102
44
#include <avahi-core/log.h>
104
46
#include <avahi-common/malloc.h>
105
47
#include <avahi-common/error.h>
106
48
107
/* GnuTLS */
108
#include <gnutls/gnutls.h> /* All GnuTLS types, constants and
109
functions:
110
gnutls_*
111
init_gnutls_session(),
112
GNUTLS_* */
113
#include <gnutls/openpgp.h>
114
/* gnutls_certificate_set_openpgp_key_file(),
115
GNUTLS_OPENPGP_FMT_BASE64 */
116
117
/* GPGME */
118
#include <gpgme.h> /* All GPGME types, constants and
119
functions:
120
gpgme_*
121
GPGME_PROTOCOL_OpenPGP,
122
GPG_ERR_NO_* */
123
49
//mandos client part
50
#include <sys/types.h> /* socket(), setsockopt(), inet_pton() */
51
#include <sys/socket.h> /* socket(), setsockopt(), struct sockaddr_in6, struct in6_addr, inet_pton() */
52
#include <gnutls/gnutls.h> /* ALL GNUTLS STUFF */
53
#include <gnutls/openpgp.h> /* gnutls with openpgp stuff */
54
55
#include <unistd.h> /* close() */
56
#include <netinet/in.h>
57
#include <stdbool.h> /* true */
58
#include <string.h> /* memset */
59
#include <arpa/inet.h> /* inet_pton() */
60
#include <iso646.h> /* not */
61
62
// gpgme
63
#include <errno.h> /* perror() */
64
#include <gpgme.h>
65
66
67
#ifndef CERT_ROOT
68
#define CERT_ROOT "/conf/conf.d/cryptkeyreq/"
69
#endif
70
#define CERTFILE CERT_ROOT "openpgp-client.txt"
71
#define KEYFILE CERT_ROOT "openpgp-client-key.txt"
124
72
#define BUFFER_SIZE 256
125
126
#define PATHDIR "/conf/conf.d/mandos"
127
#define SECKEY "seckey.txt"
128
#define PUBKEY "pubkey.txt"
129
#define HOOKDIR "/lib/mandos/network-hooks.d"
130
131
bool debug = false;
132
static const char mandos_protocol_version[] = "1";
133
const char *argp_program_version = "mandos-client " VERSION;
134
const char *argp_program_bug_address = "<mandos@recompile.se>";
135
static const char sys_class_net[] = "/sys/class/net";
136
char *connect_to = NULL;
137
const char *hookdir = HOOKDIR;
138
139
/* Doubly linked list that need to be circularly linked when used */
140
typedef struct server{
141
const char *ip;
142
uint16_t port;
143
AvahiIfIndex if_index;
144
int af;
145
struct timespec last_seen;
146
struct server *next;
147
struct server *prev;
148
} server;
149
150
/* Used for passing in values through the Avahi callback functions */
73
#define DH_BITS 1024
74
151
75
typedef struct {
152
AvahiSimplePoll *simple_poll;
153
AvahiServer *server;
76
gnutls_session_t session;
154
77
gnutls_certificate_credentials_t cred;
155
unsigned int dh_bits;
156
78
gnutls_dh_params_t dh_params;
157
const char *priority;
79
} encrypted_session;
80
81
82
ssize_t gpg_packet_decrypt (char *packet, size_t packet_size, char **new_packet, char *homedir){
83
gpgme_data_t dh_crypto, dh_plain;
158
84
gpgme_ctx_t ctx;
159
server *current_server;
160
} mandos_context;
161
162
/* global context so signal handler can reach it*/
163
mandos_context mc = { .simple_poll = NULL, .server = NULL,
164
.dh_bits = 1024, .priority = "SECURE256"
165
":!CTYPE-X.509:+CTYPE-OPENPGP",
166
.current_server = NULL };
167
168
sig_atomic_t quit_now = 0;
169
int signal_received = 0;
170
171
/* Function to use when printing errors */
172
void perror_plus(const char *print_text){
173
fprintf(stderr, "Mandos plugin %s: ",
174
program_invocation_short_name);
175
perror(print_text);
176
}
177
178
int fprintf_plus(FILE *stream, const char *format, ...){
179
va_list ap;
180
va_start (ap, format);
181
182
TEMP_FAILURE_RETRY(fprintf(stream, "Mandos plugin %s: ",
183
program_invocation_short_name));
184
return TEMP_FAILURE_RETRY(vfprintf(stream, format, ap));
185
}
186
187
/*
188
* Make additional room in "buffer" for at least BUFFER_SIZE more
189
* bytes. "buffer_capacity" is how much is currently allocated,
190
* "buffer_length" is how much is already used.
191
*/
192
size_t incbuffer(char **buffer, size_t buffer_length,
193
size_t buffer_capacity){
194
if(buffer_length + BUFFER_SIZE > buffer_capacity){
195
*buffer = realloc(*buffer, buffer_capacity + BUFFER_SIZE);
196
if(buffer == NULL){
197
return 0;
198
}
199
buffer_capacity += BUFFER_SIZE;
200
}
201
return buffer_capacity;
202
}
203
204
/* Add server to set of servers to retry periodically */
205
bool add_server(const char *ip, uint16_t port, AvahiIfIndex if_index,
206
int af){
207
int ret;
208
server *new_server = malloc(sizeof(server));
209
if(new_server == NULL){
210
perror_plus("malloc");
211
return false;
212
}
213
*new_server = (server){ .ip = strdup(ip),
214
.port = port,
215
.if_index = if_index,
216
.af = af };
217
if(new_server->ip == NULL){
218
perror_plus("strdup");
219
return false;
220
}
221
/* Special case of first server */
222
if (mc.current_server == NULL){
223
new_server->next = new_server;
224
new_server->prev = new_server;
225
mc.current_server = new_server;
226
/* Place the new server last in the list */
227
} else {
228
new_server->next = mc.current_server;
229
new_server->prev = mc.current_server->prev;
230
new_server->prev->next = new_server;
231
mc.current_server->prev = new_server;
232
}
233
ret = clock_gettime(CLOCK_MONOTONIC, &mc.current_server->last_seen);
234
if(ret == -1){
235
perror_plus("clock_gettime");
236
return false;
237
}
238
return true;
239
}
240
241
/*
242
* Initialize GPGME.
243
*/
244
static bool init_gpgme(const char *seckey, const char *pubkey,
245
const char *tempdir){
246
85
gpgme_error_t rc;
86
ssize_t ret;
87
size_t new_packet_capacity = 0;
88
size_t new_packet_length = 0;
247
89
gpgme_engine_info_t engine_info;
248
249
250
/*
251
* Helper function to insert pub and seckey to the engine keyring.
252
*/
253
bool import_key(const char *filename){
254
int ret;
255
int fd;
256
gpgme_data_t pgp_data;
257
258
fd = (int)TEMP_FAILURE_RETRY(open(filename, O_RDONLY));
259
if(fd == -1){
260
perror_plus("open");
261
return false;
262
}
263
264
rc = gpgme_data_new_from_fd(&pgp_data, fd);
265
if(rc != GPG_ERR_NO_ERROR){
266
fprintf_plus(stderr, "bad gpgme_data_new_from_fd: %s: %s\n",
267
gpgme_strsource(rc), gpgme_strerror(rc));
268
return false;
269
}
270
271
rc = gpgme_op_import(mc.ctx, pgp_data);
272
if(rc != GPG_ERR_NO_ERROR){
273
fprintf_plus(stderr, "bad gpgme_op_import: %s: %s\n",
274
gpgme_strsource(rc), gpgme_strerror(rc));
275
return false;
276
}
277
278
ret = (int)TEMP_FAILURE_RETRY(close(fd));
279
if(ret == -1){
280
perror_plus("close");
281
}
282
gpgme_data_release(pgp_data);
283
return true;
284
}
285
286
if(debug){
287
fprintf_plus(stderr, "Initializing GPGME\n");
288
}
289
90
290
91
/* Init GPGME */
291
92
gpgme_check_version(NULL);
292
rc = gpgme_engine_check_version(GPGME_PROTOCOL_OpenPGP);
293
if(rc != GPG_ERR_NO_ERROR){
294
fprintf_plus(stderr, "bad gpgme_engine_check_version: %s: %s\n",
295
gpgme_strsource(rc), gpgme_strerror(rc));
296
return false;
297
}
93
gpgme_engine_check_version(GPGME_PROTOCOL_OpenPGP);
298
94
299
/* Set GPGME home directory for the OpenPGP engine only */
300
rc = gpgme_get_engine_info(&engine_info);
301
if(rc != GPG_ERR_NO_ERROR){
302
fprintf_plus(stderr, "bad gpgme_get_engine_info: %s: %s\n",
303
gpgme_strsource(rc), gpgme_strerror(rc));
304
return false;
95
/* Set GPGME home directory */
96
rc = gpgme_get_engine_info (&engine_info);
97
if (rc != GPG_ERR_NO_ERROR){
98
fprintf(stderr, "bad gpgme_get_engine_info: %s: %s\n",
99
gpgme_strsource(rc), gpgme_strerror(rc));
100
return -1;
305
101
}
306
102
while(engine_info != NULL){
307
103
if(engine_info->protocol == GPGME_PROTOCOL_OpenPGP){
308
104
gpgme_set_engine_info(GPGME_PROTOCOL_OpenPGP,
309
engine_info->file_name, tempdir);
105
engine_info->file_name, homedir);
310
106
break;
311
107
}
312
108
engine_info = engine_info->next;
313
109
}
314
110
if(engine_info == NULL){
315
fprintf_plus(stderr, "Could not set GPGME home dir to %s\n",
316
tempdir);
317
return false;
318
}
319
320
/* Create new GPGME "context" */
321
rc = gpgme_new(&(mc.ctx));
322
if(rc != GPG_ERR_NO_ERROR){
323
fprintf_plus(stderr, "Mandos plugin mandos-client: "
324
"bad gpgme_new: %s: %s\n", gpgme_strsource(rc),
325
gpgme_strerror(rc));
326
return false;
327
}
328
329
if(not import_key(pubkey) or not import_key(seckey)){
330
return false;
331
}
332
333
return true;
334
}
335
336
/*
337
* Decrypt OpenPGP data.
338
* Returns -1 on error
339
*/
340
static ssize_t pgp_packet_decrypt(const char *cryptotext,
341
size_t crypto_size,
342
char **plaintext){
343
gpgme_data_t dh_crypto, dh_plain;
344
gpgme_error_t rc;
345
ssize_t ret;
346
size_t plaintext_capacity = 0;
347
ssize_t plaintext_length = 0;
348
349
if(debug){
350
fprintf_plus(stderr, "Trying to decrypt OpenPGP data\n");
351
}
352
353
/* Create new GPGME data buffer from memory cryptotext */
354
rc = gpgme_data_new_from_mem(&dh_crypto, cryptotext, crypto_size,
355
0);
356
if(rc != GPG_ERR_NO_ERROR){
357
fprintf_plus(stderr, "bad gpgme_data_new_from_mem: %s: %s\n",
358
gpgme_strsource(rc), gpgme_strerror(rc));
111
fprintf(stderr, "Could not set home dir to %s\n", homedir);
112
return -1;
113
}
114
115
/* Create new GPGME data buffer from packet buffer */
116
rc = gpgme_data_new_from_mem(&dh_crypto, packet, packet_size, 0);
117
if (rc != GPG_ERR_NO_ERROR){
118
fprintf(stderr, "bad gpgme_data_new_from_mem: %s: %s\n",
119
gpgme_strsource(rc), gpgme_strerror(rc));
359
120
return -1;
360
121
}
361
122
362
123
/* Create new empty GPGME data buffer for the plaintext */
363
124
rc = gpgme_data_new(&dh_plain);
364
if(rc != GPG_ERR_NO_ERROR){
365
fprintf_plus(stderr, "Mandos plugin mandos-client: "
366
"bad gpgme_data_new: %s: %s\n",
367
gpgme_strsource(rc), gpgme_strerror(rc));
368
gpgme_data_release(dh_crypto);
369
return -1;
370
}
371
372
/* Decrypt data from the cryptotext data buffer to the plaintext
373
data buffer */
374
rc = gpgme_op_decrypt(mc.ctx, dh_crypto, dh_plain);
375
if(rc != GPG_ERR_NO_ERROR){
376
fprintf_plus(stderr, "bad gpgme_op_decrypt: %s: %s\n",
377
gpgme_strsource(rc), gpgme_strerror(rc));
378
plaintext_length = -1;
379
if(debug){
380
gpgme_decrypt_result_t result;
381
result = gpgme_op_decrypt_result(mc.ctx);
382
if(result == NULL){
383
fprintf_plus(stderr, "gpgme_op_decrypt_result failed\n");
384
} else {
385
fprintf_plus(stderr, "Unsupported algorithm: %s\n",
386
result->unsupported_algorithm);
387
fprintf_plus(stderr, "Wrong key usage: %u\n",
388
result->wrong_key_usage);
389
if(result->file_name != NULL){
390
fprintf_plus(stderr, "File name: %s\n", result->file_name);
391
}
392
gpgme_recipient_t recipient;
393
recipient = result->recipients;
394
while(recipient != NULL){
395
fprintf_plus(stderr, "Public key algorithm: %s\n",
396
gpgme_pubkey_algo_name
397
(recipient->pubkey_algo));
398
fprintf_plus(stderr, "Key ID: %s\n", recipient->keyid);
399
fprintf_plus(stderr, "Secret key available: %s\n",
400
recipient->status == GPG_ERR_NO_SECKEY
401
? "No" : "Yes");
402
recipient = recipient->next;
403
}
404
}
405
}
406
goto decrypt_end;
407
}
408
409
if(debug){
410
fprintf_plus(stderr, "Decryption of OpenPGP data succeeded\n");
411
}
125
if (rc != GPG_ERR_NO_ERROR){
126
fprintf(stderr, "bad gpgme_data_new: %s: %s\n",
127
gpgme_strsource(rc), gpgme_strerror(rc));
128
return -1;
129
}
130
131
/* Create new GPGME "context" */
132
rc = gpgme_new(&ctx);
133
if (rc != GPG_ERR_NO_ERROR){
134
fprintf(stderr, "bad gpgme_new: %s: %s\n",
135
gpgme_strsource(rc), gpgme_strerror(rc));
136
return -1;
137
}
138
139
/* Decrypt data from the FILE pointer to the plaintext data buffer */
140
rc = gpgme_op_decrypt(ctx, dh_crypto, dh_plain);
141
if (rc != GPG_ERR_NO_ERROR){
142
fprintf(stderr, "bad gpgme_op_decrypt: %s: %s\n",
143
gpgme_strsource(rc), gpgme_strerror(rc));
144
return -1;
145
}
146
147
/* gpgme_decrypt_result_t result; */
148
/* result = gpgme_op_decrypt_result(ctx); */
149
/* fprintf(stderr, "Unsupported algorithm: %s\n", result->unsupported_algorithm); */
150
/* fprintf(stderr, "Wrong key usage: %d\n", result->wrong_key_usage); */
151
/* if(result->file_name != NULL){ */
152
/* fprintf(stderr, "File name: %s\n", result->file_name); */
153
/* } */
154
/* gpgme_recipient_t recipient; */
155
/* recipient = result->recipients; */
156
/* if(recipient){ */
157
/* while(recipient != NULL){ */
158
/* fprintf(stderr, "Public key algorithm: %s\n", */
159
/* gpgme_pubkey_algo_name(recipient->pubkey_algo)); */
160
/* fprintf(stderr, "Key ID: %s\n", recipient->keyid); */
161
/* fprintf(stderr, "Secret key available: %s\n", */
162
/* recipient->status == GPG_ERR_NO_SECKEY ? "No" : "Yes"); */
163
/* recipient = recipient->next; */
164
/* } */
165
/* } */
166
167
/* Delete the GPGME FILE pointer cryptotext data buffer */
168
gpgme_data_release(dh_crypto);
412
169
413
170
/* Seek back to the beginning of the GPGME plaintext data buffer */
414
if(gpgme_data_seek(dh_plain, (off_t)0, SEEK_SET) == -1){
415
perror_plus("gpgme_data_seek");
416
plaintext_length = -1;
417
goto decrypt_end;
418
}
419
420
*plaintext = NULL;
171
gpgme_data_seek(dh_plain, 0, SEEK_SET);
172
173
*new_packet = 0;
421
174
while(true){
422
plaintext_capacity = incbuffer(plaintext,
423
(size_t)plaintext_length,
424
plaintext_capacity);
425
if(plaintext_capacity == 0){
426
perror_plus("incbuffer");
427
plaintext_length = -1;
428
goto decrypt_end;
175
if (new_packet_length + BUFFER_SIZE > new_packet_capacity){
176
*new_packet = realloc(*new_packet, new_packet_capacity + BUFFER_SIZE);
177
if (*new_packet == NULL){
178
perror("realloc");
179
return -1;
180
}
181
new_packet_capacity += BUFFER_SIZE;
429
182
}
430
183
431
ret = gpgme_data_read(dh_plain, *plaintext + plaintext_length,
432
BUFFER_SIZE);
184
ret = gpgme_data_read(dh_plain, *new_packet + new_packet_length, BUFFER_SIZE);
433
185
/* Print the data, if any */
434
if(ret == 0){
435
/* EOF */
186
if (ret == 0){
187
/* If password is empty, then a incorrect error will be printed */
436
188
break;
437
189
}
438
190
if(ret < 0){
439
perror_plus("gpgme_data_read");
440
plaintext_length = -1;
441
goto decrypt_end;
442
}
443
plaintext_length += ret;
444
}
445
446
if(debug){
447
fprintf_plus(stderr, "Decrypted password is: ");
448
for(ssize_t i = 0; i < plaintext_length; i++){
449
fprintf(stderr, "%02hhX ", (*plaintext)[i]);
450
}
451
fprintf(stderr, "\n");
452
}
453
454
decrypt_end:
455
456
/* Delete the GPGME cryptotext data buffer */
457
gpgme_data_release(dh_crypto);
458
459
/* Delete the GPGME plaintext data buffer */
191
perror("gpgme_data_read");
192
return -1;
193
}
194
new_packet_length += ret;
195
}
196
197
/* Delete the GPGME plaintext data buffer */
460
198
gpgme_data_release(dh_plain);
461
return plaintext_length;
199
return new_packet_length;
462
200
}
463
201
464
static const char * safer_gnutls_strerror(int value){
465
const char *ret = gnutls_strerror(value); /* Spurious warning from
466
-Wunreachable-code */
467
if(ret == NULL)
202
static const char * safer_gnutls_strerror (int value) {
203
const char *ret = gnutls_strerror (value);
204
if (ret == NULL)
468
205
ret = "(unknown)";
469
206
return ret;
470
207
}
471
208
472
/* GnuTLS log function callback */
473
static void debuggnutls(__attribute__((unused)) int level,
474
const char* string){
475
fprintf_plus(stderr, "GnuTLS: %s", string);
209
void debuggnutls(int level, const char* string){
210
fprintf(stderr, "%s", string);
476
211
}
477
212
478
static int init_gnutls_global(const char *pubkeyfilename,
479
const char *seckeyfilename){
213
int initgnutls(encrypted_session *es){
214
const char *err;
480
215
int ret;
481
216
482
if(debug){
483
fprintf_plus(stderr, "Initializing GnuTLS\n");
484
}
485
486
ret = gnutls_global_init();
487
if(ret != GNUTLS_E_SUCCESS){
488
fprintf_plus(stderr, "GnuTLS global_init: %s\n",
489
safer_gnutls_strerror(ret));
490
return -1;
491
}
492
493
if(debug){
494
/* "Use a log level over 10 to enable all debugging options."
495
* - GnuTLS manual
496
*/
497
gnutls_global_set_log_level(11);
498
gnutls_global_set_log_function(debuggnutls);
499
}
500
501
/* OpenPGP credentials */
502
ret = gnutls_certificate_allocate_credentials(&mc.cred);
503
if(ret != GNUTLS_E_SUCCESS){
504
fprintf_plus(stderr, "GnuTLS memory error: %s\n",
505
safer_gnutls_strerror(ret));
506
gnutls_global_deinit();
507
return -1;
508
}
509
510
if(debug){
511
fprintf_plus(stderr, "Attempting to use OpenPGP public key %s and"
512
" secret key %s as GnuTLS credentials\n",
513
pubkeyfilename,
514
seckeyfilename);
515
}
516
217
if ((ret = gnutls_global_init ())
218
!= GNUTLS_E_SUCCESS) {
219
fprintf (stderr, "global_init: %s\n", safer_gnutls_strerror(ret));
220
return -1;
221
}
222
223
/* Uncomment to enable full debuggin on the gnutls library */
224
/* gnutls_global_set_log_level(11); */
225
/* gnutls_global_set_log_function(debuggnutls); */
226
227
228
/* openpgp credentials */
229
if ((ret = gnutls_certificate_allocate_credentials (&es->cred))
230
!= GNUTLS_E_SUCCESS) {
231
fprintf (stderr, "memory error: %s\n", safer_gnutls_strerror(ret));
232
return -1;
233
}
234
517
235
ret = gnutls_certificate_set_openpgp_key_file
518
(mc.cred, pubkeyfilename, seckeyfilename,
519
GNUTLS_OPENPGP_FMT_BASE64);
520
if(ret != GNUTLS_E_SUCCESS){
521
fprintf_plus(stderr,
522
"Error[%d] while reading the OpenPGP key pair ('%s',"
523
" '%s')\n", ret, pubkeyfilename, seckeyfilename);
524
fprintf_plus(stderr, "The GnuTLS error is: %s\n",
525
safer_gnutls_strerror(ret));
526
goto globalfail;
527
}
528
529
/* GnuTLS server initialization */
530
ret = gnutls_dh_params_init(&mc.dh_params);
531
if(ret != GNUTLS_E_SUCCESS){
532
fprintf_plus(stderr, "Error in GnuTLS DH parameter"
533
" initialization: %s\n",
534
safer_gnutls_strerror(ret));
535
goto globalfail;
536
}
537
ret = gnutls_dh_params_generate2(mc.dh_params, mc.dh_bits);
538
if(ret != GNUTLS_E_SUCCESS){
539
fprintf_plus(stderr, "Error in GnuTLS prime generation: %s\n",
540
safer_gnutls_strerror(ret));
541
goto globalfail;
542
}
543
544
gnutls_certificate_set_dh_params(mc.cred, mc.dh_params);
545
546
return 0;
547
548
globalfail:
549
550
gnutls_certificate_free_credentials(mc.cred);
551
gnutls_global_deinit();
552
gnutls_dh_params_deinit(mc.dh_params);
553
return -1;
554
}
555
556
static int init_gnutls_session(gnutls_session_t *session){
557
int ret;
558
/* GnuTLS session creation */
559
do {
560
ret = gnutls_init(session, GNUTLS_SERVER);
561
if(quit_now){
562
return -1;
563
}
564
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
565
if(ret != GNUTLS_E_SUCCESS){
566
fprintf_plus(stderr,
567
"Error in GnuTLS session initialization: %s\n",
568
safer_gnutls_strerror(ret));
569
}
570
571
{
572
const char *err;
573
do {
574
ret = gnutls_priority_set_direct(*session, mc.priority, &err);
575
if(quit_now){
576
gnutls_deinit(*session);
577
return -1;
578
}
579
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
580
if(ret != GNUTLS_E_SUCCESS){
581
fprintf_plus(stderr, "Syntax error at: %s\n", err);
582
fprintf_plus(stderr, "GnuTLS error: %s\n",
583
safer_gnutls_strerror(ret));
584
gnutls_deinit(*session);
585
return -1;
586
}
587
}
588
589
do {
590
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
591
mc.cred);
592
if(quit_now){
593
gnutls_deinit(*session);
594
return -1;
595
}
596
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
597
if(ret != GNUTLS_E_SUCCESS){
598
fprintf_plus(stderr, "Error setting GnuTLS credentials: %s\n",
599
safer_gnutls_strerror(ret));
600
gnutls_deinit(*session);
601
return -1;
602
}
603
236
(es->cred, CERTFILE, KEYFILE, GNUTLS_OPENPGP_FMT_BASE64);
237
if (ret != GNUTLS_E_SUCCESS) {
238
fprintf
239
(stderr, "Error[%d] while reading the OpenPGP key pair ('%s', '%s')\n",
240
ret, CERTFILE, KEYFILE);
241
fprintf(stdout, "The Error is: %s\n",
242
safer_gnutls_strerror(ret));
243
return -1;
244
}
245
246
//Gnutls server initialization
247
if ((ret = gnutls_dh_params_init (&es->dh_params))
248
!= GNUTLS_E_SUCCESS) {
249
fprintf (stderr, "Error in dh parameter initialization: %s\n",
250
safer_gnutls_strerror(ret));
251
return -1;
252
}
253
254
if ((ret = gnutls_dh_params_generate2 (es->dh_params, DH_BITS))
255
!= GNUTLS_E_SUCCESS) {
256
fprintf (stderr, "Error in prime generation: %s\n",
257
safer_gnutls_strerror(ret));
258
return -1;
259
}
260
261
gnutls_certificate_set_dh_params (es->cred, es->dh_params);
262
263
// Gnutls session creation
264
if ((ret = gnutls_init (&es->session, GNUTLS_SERVER))
265
!= GNUTLS_E_SUCCESS){
266
fprintf(stderr, "Error in gnutls session initialization: %s\n",
267
safer_gnutls_strerror(ret));
268
}
269
270
if ((ret = gnutls_priority_set_direct (es->session, "NORMAL", &err))
271
!= GNUTLS_E_SUCCESS) {
272
fprintf(stderr, "Syntax error at: %s\n", err);
273
fprintf(stderr, "Gnutls error: %s\n",
274
safer_gnutls_strerror(ret));
275
return -1;
276
}
277
278
if ((ret = gnutls_credentials_set
279
(es->session, GNUTLS_CRD_CERTIFICATE, es->cred))
280
!= GNUTLS_E_SUCCESS) {
281
fprintf(stderr, "Error setting a credentials set: %s\n",
282
safer_gnutls_strerror(ret));
283
return -1;
284
}
285
604
286
/* ignore client certificate if any. */
605
gnutls_certificate_server_set_request(*session, GNUTLS_CERT_IGNORE);
287
gnutls_certificate_server_set_request (es->session, GNUTLS_CERT_IGNORE);
606
288
607
gnutls_dh_set_prime_bits(*session, mc.dh_bits);
289
gnutls_dh_set_prime_bits (es->session, DH_BITS);
608
290
609
291
return 0;
610
292
}
611
293
612
/* Avahi log function callback */
613
static void empty_log(__attribute__((unused)) AvahiLogLevel level,
614
__attribute__((unused)) const char *txt){}
294
void empty_log(AvahiLogLevel level, const char *txt){}
615
295
616
/* Called when a Mandos server is found */
617
static int start_mandos_communication(const char *ip, uint16_t port,
618
AvahiIfIndex if_index,
619
int af){
620
int ret, tcp_sd = -1;
621
ssize_t sret;
622
union {
623
struct sockaddr_in in;
624
struct sockaddr_in6 in6;
625
} to;
296
int start_mandos_communcation(char *ip, uint16_t port){
297
int ret, tcp_sd;
298
struct sockaddr_in6 to;
299
struct in6_addr ip_addr;
300
encrypted_session es;
626
301
char *buffer = NULL;
627
char *decrypted_buffer = NULL;
302
char *decrypted_buffer;
628
303
size_t buffer_length = 0;
629
304
size_t buffer_capacity = 0;
630
size_t written;
631
int retval = -1;
632
gnutls_session_t session;
633
int pf; /* Protocol family */
634
635
errno = 0;
636
637
if(quit_now){
638
errno = EINTR;
639
return -1;
640
}
641
642
switch(af){
643
case AF_INET6:
644
pf = PF_INET6;
645
break;
646
case AF_INET:
647
pf = PF_INET;
648
break;
649
default:
650
fprintf_plus(stderr, "Bad address family: %d\n", af);
651
errno = EINVAL;
652
return -1;
653
}
654
655
ret = init_gnutls_session(&session);
656
if(ret != 0){
657
return -1;
658
}
659
660
if(debug){
661
fprintf_plus(stderr, "Setting up a TCP connection to %s, port %"
662
PRIu16 "\n", ip, port);
663
}
664
665
tcp_sd = socket(pf, SOCK_STREAM, 0);
666
if(tcp_sd < 0){
667
int e = errno;
668
perror_plus("socket");
669
errno = e;
670
goto mandos_end;
671
}
672
673
if(quit_now){
674
errno = EINTR;
675
goto mandos_end;
676
}
677
678
memset(&to, 0, sizeof(to));
679
if(af == AF_INET6){
680
to.in6.sin6_family = (sa_family_t)af;
681
ret = inet_pton(af, ip, &to.in6.sin6_addr);
682
} else { /* IPv4 */
683
to.in.sin_family = (sa_family_t)af;
684
ret = inet_pton(af, ip, &to.in.sin_addr);
685
}
686
if(ret < 0 ){
687
int e = errno;
688
perror_plus("inet_pton");
689
errno = e;
690
goto mandos_end;
691
}
305
ssize_t decrypted_buffer_size;
306
int retval = 0;
307
308
309
tcp_sd = socket(PF_INET6, SOCK_STREAM, 0);
310
if(tcp_sd < 0) {
311
perror("socket");
312
return -1;
313
}
314
315
ret = setsockopt(tcp_sd, SOL_SOCKET, SO_BINDTODEVICE, "eth0", 5);
316
if(tcp_sd < 0) {
317
perror("setsockopt bindtodevice");
318
return -1;
319
}
320
321
memset(&to,0,sizeof(to));
322
to.sin6_family = AF_INET6;
323
ret = inet_pton(AF_INET6, ip, &ip_addr);
324
if (ret < 0 ){
325
perror("inet_pton");
326
return -1;
327
}
692
328
if(ret == 0){
693
int e = errno;
694
fprintf_plus(stderr, "Bad address: %s\n", ip);
695
errno = e;
696
goto mandos_end;
697
}
698
if(af == AF_INET6){
699
to.in6.sin6_port = htons(port); /* Spurious warnings from
700
-Wconversion and
701
-Wunreachable-code */
702
703
if(IN6_IS_ADDR_LINKLOCAL /* Spurious warnings from */
704
(&to.in6.sin6_addr)){ /* -Wstrict-aliasing=2 or lower and
705
-Wunreachable-code*/
706
if(if_index == AVAHI_IF_UNSPEC){
707
fprintf_plus(stderr, "An IPv6 link-local address is"
708
" incomplete without a network interface\n");
709
errno = EINVAL;
710
goto mandos_end;
711
}
712
/* Set the network interface number as scope */
713
to.in6.sin6_scope_id = (uint32_t)if_index;
714
}
715
} else {
716
to.in.sin_port = htons(port); /* Spurious warnings from
717
-Wconversion and
718
-Wunreachable-code */
719
}
720
721
if(quit_now){
722
errno = EINTR;
723
goto mandos_end;
724
}
725
726
if(debug){
727
if(af == AF_INET6 and if_index != AVAHI_IF_UNSPEC){
728
char interface[IF_NAMESIZE];
729
if(if_indextoname((unsigned int)if_index, interface) == NULL){
730
perror_plus("if_indextoname");
731
} else {
732
fprintf_plus(stderr, "Connection to: %s%%%s, port %" PRIu16
733
"\n", ip, interface, port);
734
}
735
} else {
736
fprintf_plus(stderr, "Connection to: %s, port %" PRIu16 "\n",
737
ip, port);
738
}
739
char addrstr[(INET_ADDRSTRLEN > INET6_ADDRSTRLEN) ?
740
INET_ADDRSTRLEN : INET6_ADDRSTRLEN] = "";
741
const char *pcret;
742
if(af == AF_INET6){
743
pcret = inet_ntop(af, &(to.in6.sin6_addr), addrstr,
744
sizeof(addrstr));
745
} else {
746
pcret = inet_ntop(af, &(to.in.sin_addr), addrstr,
747
sizeof(addrstr));
748
}
749
if(pcret == NULL){
750
perror_plus("inet_ntop");
751
} else {
752
if(strcmp(addrstr, ip) != 0){
753
fprintf_plus(stderr, "Canonical address form: %s\n", addrstr);
754
}
755
}
756
}
757
758
if(quit_now){
759
errno = EINTR;
760
goto mandos_end;
761
}
762
763
if(af == AF_INET6){
764
ret = connect(tcp_sd, &to.in6, sizeof(to));
765
} else {
766
ret = connect(tcp_sd, &to.in, sizeof(to)); /* IPv4 */
767
}
768
if(ret < 0){
769
if ((errno != ECONNREFUSED and errno != ENETUNREACH) or debug){
770
int e = errno;
771
perror_plus("connect");
772
errno = e;
773
}
774
goto mandos_end;
775
}
776
777
if(quit_now){
778
errno = EINTR;
779
goto mandos_end;
780
}
781
782
const char *out = mandos_protocol_version;
783
written = 0;
784
while(true){
785
size_t out_size = strlen(out);
786
ret = (int)TEMP_FAILURE_RETRY(write(tcp_sd, out + written,
787
out_size - written));
788
if(ret == -1){
789
int e = errno;
790
perror_plus("write");
791
errno = e;
792
goto mandos_end;
793
}
794
written += (size_t)ret;
795
if(written < out_size){
796
continue;
797
} else {
798
if(out == mandos_protocol_version){
799
written = 0;
800
out = "\r\n";
801
} else {
802
break;
803
}
804
}
805
806
if(quit_now){
807
errno = EINTR;
808
goto mandos_end;
809
}
810
}
811
812
if(debug){
813
fprintf_plus(stderr, "Establishing TLS session with %s\n", ip);
814
}
815
816
if(quit_now){
817
errno = EINTR;
818
goto mandos_end;
819
}
820
821
/* Spurious warning from -Wint-to-pointer-cast */
822
gnutls_transport_set_ptr(session, (gnutls_transport_ptr_t) tcp_sd);
823
824
if(quit_now){
825
errno = EINTR;
826
goto mandos_end;
827
}
828
829
do {
830
ret = gnutls_handshake(session);
831
if(quit_now){
832
errno = EINTR;
833
goto mandos_end;
834
}
835
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
836
837
if(ret != GNUTLS_E_SUCCESS){
838
if(debug){
839
fprintf_plus(stderr, "*** GnuTLS Handshake failed ***\n");
840
gnutls_perror(ret);
841
}
842
errno = EPROTO;
843
goto mandos_end;
844
}
845
846
/* Read OpenPGP packet that contains the wanted password */
847
848
if(debug){
849
fprintf_plus(stderr, "Retrieving OpenPGP encrypted password from"
850
" %s\n", ip);
851
}
852
853
while(true){
854
855
if(quit_now){
856
errno = EINTR;
857
goto mandos_end;
858
}
859
860
buffer_capacity = incbuffer(&buffer, buffer_length,
861
buffer_capacity);
862
if(buffer_capacity == 0){
863
int e = errno;
864
perror_plus("incbuffer");
865
errno = e;
866
goto mandos_end;
867
}
868
869
if(quit_now){
870
errno = EINTR;
871
goto mandos_end;
872
}
873
874
sret = gnutls_record_recv(session, buffer+buffer_length,
875
BUFFER_SIZE);
876
if(sret == 0){
329
fprintf(stderr, "Bad address: %s\n", ip);
330
return -1;
331
}
332
to.sin6_port = htons(port);
333
to.sin6_scope_id = if_nametoindex("eth0");
334
335
ret = connect(tcp_sd, (struct sockaddr *) &to, sizeof(to));
336
if (ret < 0){
337
perror("connect");
338
return -1;
339
}
340
341
ret = initgnutls (&es);
342
if (ret != 0){
343
retval = -1;
344
return -1;
345
}
346
347
348
gnutls_transport_set_ptr (es.session, (gnutls_transport_ptr_t) tcp_sd);
349
350
ret = gnutls_handshake (es.session);
351
352
if (ret != GNUTLS_E_SUCCESS){
353
fprintf(stderr, "\n*** Handshake failed ***\n");
354
gnutls_perror (ret);
355
retval = -1;
356
goto exit;
357
}
358
359
//retrive password
360
while(true){
361
if (buffer_length + BUFFER_SIZE > buffer_capacity){
362
buffer = realloc(buffer, buffer_capacity + BUFFER_SIZE);
363
if (buffer == NULL){
364
perror("realloc");
365
goto exit;
366
}
367
buffer_capacity += BUFFER_SIZE;
368
}
369
370
ret = gnutls_record_recv
371
(es.session, buffer+buffer_length, BUFFER_SIZE);
372
if (ret == 0){
877
373
break;
878
374
}
879
if(sret < 0){
880
switch(sret){
375
if (ret < 0){
376
switch(ret){
881
377
case GNUTLS_E_INTERRUPTED:
882
378
case GNUTLS_E_AGAIN:
883
379
break;
884
380
case GNUTLS_E_REHANDSHAKE:
885
do {
886
ret = gnutls_handshake(session);
887
888
if(quit_now){
889
errno = EINTR;
890
goto mandos_end;
891
}
892
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
893
if(ret < 0){
894
fprintf_plus(stderr, "*** GnuTLS Re-handshake failed "
895
"***\n");
896
gnutls_perror(ret);
897
errno = EPROTO;
898
goto mandos_end;
381
ret = gnutls_handshake (es.session);
382
if (ret < 0){
383
fprintf(stderr, "\n*** Handshake failed ***\n");
384
gnutls_perror (ret);
385
retval = -1;
386
goto exit;
899
387
}
900
388
break;
901
389
default:
902
fprintf_plus(stderr, "Unknown error while reading data from"
903
" encrypted session with Mandos server\n");
904
gnutls_bye(session, GNUTLS_SHUT_RDWR);
905
errno = EIO;
906
goto mandos_end;
390
fprintf(stderr, "Unknown error while reading data from encrypted session with mandos server\n");
391
retval = -1;
392
gnutls_bye (es.session, GNUTLS_SHUT_RDWR);
393
goto exit;
907
394
}
908
395
} else {
909
buffer_length += (size_t) sret;
910
}
911
}
912
913
if(debug){
914
fprintf_plus(stderr, "Closing TLS session\n");
915
}
916
917
if(quit_now){
918
errno = EINTR;
919
goto mandos_end;
920
}
921
922
do {
923
ret = gnutls_bye(session, GNUTLS_SHUT_RDWR);
924
if(quit_now){
925
errno = EINTR;
926
goto mandos_end;
927
}
928
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
929
930
if(buffer_length > 0){
931
ssize_t decrypted_buffer_size;
932
decrypted_buffer_size = pgp_packet_decrypt(buffer, buffer_length,
933
&decrypted_buffer);
934
if(decrypted_buffer_size >= 0){
935
936
written = 0;
937
while(written < (size_t) decrypted_buffer_size){
938
if(quit_now){
939
errno = EINTR;
940
goto mandos_end;
941
}
942
943
ret = (int)fwrite(decrypted_buffer + written, 1,
944
(size_t)decrypted_buffer_size - written,
945
stdout);
946
if(ret == 0 and ferror(stdout)){
947
int e = errno;
948
if(debug){
949
fprintf_plus(stderr, "Error writing encrypted data: %s\n",
950
strerror(errno));
951
}
952
errno = e;
953
goto mandos_end;
954
}
955
written += (size_t)ret;
956
}
957
retval = 0;
958
}
959
}
960
961
/* Shutdown procedure */
962
963
mandos_end:
964
{
965
int e = errno;
966
free(decrypted_buffer);
967
free(buffer);
968
if(tcp_sd >= 0){
969
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
970
}
971
if(ret == -1){
972
if(e == 0){
973
e = errno;
974
}
975
perror_plus("close");
976
}
977
gnutls_deinit(session);
978
errno = e;
979
if(quit_now){
980
errno = EINTR;
396
buffer_length += ret;
397
}
398
}
399
400
if (buffer_length > 0){
401
if ((decrypted_buffer_size = gpg_packet_decrypt(buffer, buffer_length, &decrypted_buffer, CERT_ROOT)) == 0){
981
402
retval = -1;
403
} else {
404
fwrite (decrypted_buffer, 1, decrypted_buffer_size, stdout);
405
free(decrypted_buffer);
982
406
}
983
407
}
408
409
free(buffer);
410
411
//shutdown procedure
412
gnutls_bye (es.session, GNUTLS_SHUT_RDWR);
413
exit:
414
close(tcp_sd);
415
gnutls_deinit (es.session);
416
gnutls_certificate_free_credentials (es.cred);
417
gnutls_global_deinit ();
984
418
return retval;
985
419
}
986
420
987
static void resolve_callback(AvahiSServiceResolver *r,
988
AvahiIfIndex interface,
989
AvahiProtocol proto,
990
AvahiResolverEvent event,
991
const char *name,
992
const char *type,
993
const char *domain,
994
const char *host_name,
995
const AvahiAddress *address,
996
uint16_t port,
997
AVAHI_GCC_UNUSED AvahiStringList *txt,
998
AVAHI_GCC_UNUSED AvahiLookupResultFlags
999
flags,
1000
AVAHI_GCC_UNUSED void* userdata){
1001
assert(r);
1002
1003
/* Called whenever a service has been resolved successfully or
1004
timed out */
1005
1006
if(quit_now){
1007
return;
1008
}
1009
1010
switch(event){
1011
default:
1012
case AVAHI_RESOLVER_FAILURE:
1013
fprintf_plus(stderr, "(Avahi Resolver) Failed to resolve service "
1014
"'%s' of type '%s' in domain '%s': %s\n", name, type,
1015
domain,
1016
avahi_strerror(avahi_server_errno(mc.server)));
1017
break;
1018
1019
case AVAHI_RESOLVER_FOUND:
1020
{
1021
char ip[AVAHI_ADDRESS_STR_MAX];
1022
avahi_address_snprint(ip, sizeof(ip), address);
1023
if(debug){
1024
fprintf_plus(stderr, "Mandos server \"%s\" found on %s (%s, %"
1025
PRIdMAX ") on port %" PRIu16 "\n", name,
1026
host_name, ip, (intmax_t)interface, port);
1027
}
1028
int ret = start_mandos_communication(ip, port, interface,
1029
avahi_proto_to_af(proto));
1030
if(ret == 0){
1031
avahi_simple_poll_quit(mc.simple_poll);
1032
} else {
1033
if(not add_server(ip, port, interface,
1034
avahi_proto_to_af(proto))){
1035
fprintf_plus(stderr, "Failed to add server \"%s\" to server"
1036
" list\n", name);
1037
}
1038
}
1039
}
1040
}
1041
avahi_s_service_resolver_free(r);
1042
}
1043
1044
static void browse_callback(AvahiSServiceBrowser *b,
1045
AvahiIfIndex interface,
1046
AvahiProtocol protocol,
1047
AvahiBrowserEvent event,
1048
const char *name,
1049
const char *type,
1050
const char *domain,
1051
AVAHI_GCC_UNUSED AvahiLookupResultFlags
1052
flags,
1053
AVAHI_GCC_UNUSED void* userdata){
1054
assert(b);
1055
1056
/* Called whenever a new services becomes available on the LAN or
1057
is removed from the LAN */
1058
1059
if(quit_now){
1060
return;
1061
}
1062
1063
switch(event){
1064
default:
1065
case AVAHI_BROWSER_FAILURE:
1066
1067
fprintf_plus(stderr, "(Avahi browser) %s\n",
1068
avahi_strerror(avahi_server_errno(mc.server)));
1069
avahi_simple_poll_quit(mc.simple_poll);
1070
return;
1071
1072
case AVAHI_BROWSER_NEW:
1073
/* We ignore the returned Avahi resolver object. In the callback
1074
function we free it. If the Avahi server is terminated before
1075
the callback function is called the Avahi server will free the
1076
resolver for us. */
1077
1078
if(avahi_s_service_resolver_new(mc.server, interface, protocol,
1079
name, type, domain, protocol, 0,
1080
resolve_callback, NULL) == NULL)
1081
fprintf_plus(stderr, "Avahi: Failed to resolve service '%s':"
1082
" %s\n", name,
1083
avahi_strerror(avahi_server_errno(mc.server)));
1084
break;
1085
1086
case AVAHI_BROWSER_REMOVE:
1087
break;
1088
1089
case AVAHI_BROWSER_ALL_FOR_NOW:
1090
case AVAHI_BROWSER_CACHE_EXHAUSTED:
1091
if(debug){
1092
fprintf_plus(stderr, "No Mandos server found, still"
1093
" searching...\n");
1094
}
1095
break;
1096
}
1097
}
1098
1099
/* Signal handler that stops main loop after SIGTERM */
1100
static void handle_sigterm(int sig){
1101
if(quit_now){
1102
return;
1103
}
1104
quit_now = 1;
1105
signal_received = sig;
1106
int old_errno = errno;
1107
/* set main loop to exit */
1108
if(mc.simple_poll != NULL){
1109
avahi_simple_poll_quit(mc.simple_poll);
1110
}
1111
errno = old_errno;
1112
}
1113
1114
bool get_flags(const char *ifname, struct ifreq *ifr){
1115
int ret;
1116
1117
int s = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1118
if(s < 0){
1119
perror_plus("socket");
1120
return false;
1121
}
1122
strcpy(ifr->ifr_name, ifname);
1123
ret = ioctl(s, SIOCGIFFLAGS, ifr);
1124
if(ret == -1){
1125
if(debug){
1126
perror_plus("ioctl SIOCGIFFLAGS");
1127
}
1128
return false;
1129
}
1130
return true;
1131
}
1132
1133
bool good_flags(const char *ifname, const struct ifreq *ifr){
1134
1135
/* Reject the loopback device */
1136
if(ifr->ifr_flags & IFF_LOOPBACK){
1137
if(debug){
1138
fprintf_plus(stderr, "Rejecting loopback interface \"%s\"\n",
1139
ifname);
1140
}
1141
return false;
1142
}
1143
/* Accept point-to-point devices only if connect_to is specified */
1144
if(connect_to != NULL and (ifr->ifr_flags & IFF_POINTOPOINT)){
1145
if(debug){
1146
fprintf_plus(stderr, "Accepting point-to-point interface"
1147
" \"%s\"\n", ifname);
1148
}
1149
return true;
1150
}
1151
/* Otherwise, reject non-broadcast-capable devices */
1152
if(not (ifr->ifr_flags & IFF_BROADCAST)){
1153
if(debug){
1154
fprintf_plus(stderr, "Rejecting non-broadcast interface"
1155
" \"%s\"\n", ifname);
1156
}
1157
return false;
1158
}
1159
/* Reject non-ARP interfaces (including dummy interfaces) */
1160
if(ifr->ifr_flags & IFF_NOARP){
1161
if(debug){
1162
fprintf_plus(stderr, "Rejecting non-ARP interface \"%s\"\n",
1163
ifname);
1164
}
1165
return false;
1166
}
1167
1168
/* Accept this device */
1169
if(debug){
1170
fprintf_plus(stderr, "Interface \"%s\" is good\n", ifname);
1171
}
1172
return true;
1173
}
1174
1175
/*
1176
* This function determines if a directory entry in /sys/class/net
1177
* corresponds to an acceptable network device.
1178
* (This function is passed to scandir(3) as a filter function.)
1179
*/
1180
int good_interface(const struct dirent *if_entry){
1181
if(if_entry->d_name[0] == '.'){
1182
return 0;
1183
}
1184
1185
struct ifreq ifr;
1186
if(not get_flags(if_entry->d_name, &ifr)){
1187
if(debug){
1188
fprintf_plus(stderr, "Failed to get flags for interface "
1189
"\"%s\"\n", if_entry->d_name);
1190
}
1191
return 0;
1192
}
1193
1194
if(not good_flags(if_entry->d_name, &ifr)){
1195
return 0;
1196
}
1197
return 1;
1198
}
1199
1200
/*
1201
* This function determines if a directory entry in /sys/class/net
1202
* corresponds to an acceptable network device which is up.
1203
* (This function is passed to scandir(3) as a filter function.)
1204
*/
1205
int up_interface(const struct dirent *if_entry){
1206
if(if_entry->d_name[0] == '.'){
1207
return 0;
1208
}
1209
1210
struct ifreq ifr;
1211
if(not get_flags(if_entry->d_name, &ifr)){
1212
if(debug){
1213
fprintf_plus(stderr, "Failed to get flags for interface "
1214
"\"%s\"\n", if_entry->d_name);
1215
}
1216
return 0;
1217
}
1218
1219
/* Reject down interfaces */
1220
if(not (ifr.ifr_flags & IFF_UP)){
1221
if(debug){
1222
fprintf_plus(stderr, "Rejecting down interface \"%s\"\n",
1223
if_entry->d_name);
1224
}
1225
return 0;
1226
}
1227
1228
/* Reject non-running interfaces */
1229
if(not (ifr.ifr_flags & IFF_RUNNING)){
1230
if(debug){
1231
fprintf_plus(stderr, "Rejecting non-running interface \"%s\"\n",
1232
if_entry->d_name);
1233
}
1234
return 0;
1235
}
1236
1237
if(not good_flags(if_entry->d_name, &ifr)){
1238
return 0;
1239
}
1240
return 1;
1241
}
1242
1243
int notdotentries(const struct dirent *direntry){
1244
/* Skip "." and ".." */
1245
if(direntry->d_name[0] == '.'
1246
and (direntry->d_name[1] == '\0'
1247
or (direntry->d_name[1] == '.'
1248
and direntry->d_name[2] == '\0'))){
1249
return 0;
1250
}
1251
return 1;
1252
}
1253
1254
/* Is this directory entry a runnable program? */
1255
int runnable_hook(const struct dirent *direntry){
1256
int ret;
1257
size_t sret;
1258
struct stat st;
1259
1260
if((direntry->d_name)[0] == '\0'){
1261
/* Empty name? */
1262
return 0;
1263
}
1264
1265
sret = strspn(direntry->d_name, "ABCDEFGHIJKLMNOPQRSTUVWXYZ"
1266
"abcdefghijklmnopqrstuvwxyz"
1267
"0123456789"
1268
"_-");
1269
if((direntry->d_name)[sret] != '\0'){
1270
/* Contains non-allowed characters */
1271
if(debug){
1272
fprintf_plus(stderr, "Ignoring hook \"%s\" with bad name\n",
1273
direntry->d_name);
1274
}
1275
return 0;
1276
}
1277
1278
char *fullname = NULL;
1279
ret = asprintf(&fullname, "%s/%s", hookdir, direntry->d_name);
1280
if(ret < 0){
1281
perror_plus("asprintf");
1282
return 0;
1283
}
1284
1285
ret = stat(fullname, &st);
1286
if(ret == -1){
1287
if(debug){
1288
perror_plus("Could not stat hook");
1289
}
1290
return 0;
1291
}
1292
if(not (S_ISREG(st.st_mode))){
1293
/* Not a regular file */
1294
if(debug){
1295
fprintf_plus(stderr, "Ignoring hook \"%s\" - not a file\n",
1296
direntry->d_name);
1297
}
1298
return 0;
1299
}
1300
if(not (st.st_mode & (S_IXUSR | S_IXGRP | S_IXOTH))){
1301
/* Not executable */
1302
if(debug){
1303
fprintf_plus(stderr, "Ignoring hook \"%s\" - not executable\n",
1304
direntry->d_name);
1305
}
1306
return 0;
1307
}
1308
if(debug){
1309
fprintf_plus(stderr, "Hook \"%s\" is acceptable\n",
1310
direntry->d_name);
1311
}
1312
return 1;
1313
}
1314
1315
int avahi_loop_with_timeout(AvahiSimplePoll *s, int retry_interval){
1316
int ret;
1317
struct timespec now;
1318
struct timespec waited_time;
1319
intmax_t block_time;
1320
1321
while(true){
1322
if(mc.current_server == NULL){
1323
if (debug){
1324
fprintf_plus(stderr, "Wait until first server is found."
1325
" No timeout!\n");
1326
}
1327
ret = avahi_simple_poll_iterate(s, -1);
1328
} else {
1329
if (debug){
1330
fprintf_plus(stderr, "Check current_server if we should run"
1331
" it, or wait\n");
1332
}
1333
/* the current time */
1334
ret = clock_gettime(CLOCK_MONOTONIC, &now);
1335
if(ret == -1){
1336
perror_plus("clock_gettime");
1337
return -1;
1338
}
1339
/* Calculating in ms how long time between now and server
1340
who we visted longest time ago. Now - last seen. */
1341
waited_time.tv_sec = (now.tv_sec
1342
- mc.current_server->last_seen.tv_sec);
1343
waited_time.tv_nsec = (now.tv_nsec
1344
- mc.current_server->last_seen.tv_nsec);
1345
/* total time is 10s/10,000ms.
1346
Converting to s from ms by dividing by 1,000,
1347
and ns to ms by dividing by 1,000,000. */
1348
block_time = ((retry_interval
1349
- ((intmax_t)waited_time.tv_sec * 1000))
1350
- ((intmax_t)waited_time.tv_nsec / 1000000));
1351
1352
if (debug){
1353
fprintf_plus(stderr, "Blocking for %" PRIdMAX " ms\n",
1354
block_time);
1355
}
1356
1357
if(block_time <= 0){
1358
ret = start_mandos_communication(mc.current_server->ip,
1359
mc.current_server->port,
1360
mc.current_server->if_index,
1361
mc.current_server->af);
1362
if(ret == 0){
1363
avahi_simple_poll_quit(mc.simple_poll);
1364
return 0;
1365
}
1366
ret = clock_gettime(CLOCK_MONOTONIC,
1367
&mc.current_server->last_seen);
1368
if(ret == -1){
1369
perror_plus("clock_gettime");
1370
return -1;
1371
}
1372
mc.current_server = mc.current_server->next;
1373
block_time = 0; /* Call avahi to find new Mandos
1374
servers, but don't block */
1375
}
1376
1377
ret = avahi_simple_poll_iterate(s, (int)block_time);
1378
}
1379
if(ret != 0){
1380
if (ret > 0 or errno != EINTR){
1381
return (ret != 1) ? ret : 0;
1382
}
1383
}
1384
}
1385
}
1386
1387
bool run_network_hooks(const char *mode, const char *interface,
1388
const float delay){
1389
struct dirent **direntries;
1390
struct dirent *direntry;
1391
int ret;
1392
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1393
alphasort);
1394
if(numhooks == -1){
1395
perror_plus("scandir");
1396
} else {
1397
int devnull = open("/dev/null", O_RDONLY);
1398
for(int i = 0; i < numhooks; i++){
1399
direntry = direntries[i];
1400
char *fullname = NULL;
1401
ret = asprintf(&fullname, "%s/%s", hookdir, direntry->d_name);
1402
if(ret < 0){
1403
perror_plus("asprintf");
1404
continue;
1405
}
1406
if(debug){
1407
fprintf_plus(stderr, "Running network hook \"%s\"\n",
1408
direntry->d_name);
1409
}
1410
pid_t hook_pid = fork();
1411
if(hook_pid == 0){
1412
/* Child */
1413
/* Raise privileges */
1414
errno = 0;
1415
ret = seteuid(0);
1416
if(ret == -1){
1417
perror_plus("seteuid");
1418
}
1419
/* Raise privileges even more */
1420
errno = 0;
1421
ret = setuid(0);
1422
if(ret == -1){
1423
perror_plus("setuid");
1424
}
1425
/* Set group */
1426
errno = 0;
1427
ret = setgid(0);
1428
if(ret == -1){
1429
perror_plus("setgid");
1430
}
1431
/* Reset supplementary groups */
1432
errno = 0;
1433
ret = setgroups(0, NULL);
1434
if(ret == -1){
1435
perror_plus("setgroups");
1436
}
1437
dup2(devnull, STDIN_FILENO);
1438
close(devnull);
1439
dup2(STDERR_FILENO, STDOUT_FILENO);
1440
ret = setenv("MANDOSNETHOOKDIR", hookdir, 1);
1441
if(ret == -1){
1442
perror_plus("setenv");
1443
_exit(EX_OSERR);
1444
}
1445
ret = setenv("DEVICE", interface, 1);
1446
if(ret == -1){
1447
perror_plus("setenv");
1448
_exit(EX_OSERR);
1449
}
1450
ret = setenv("VERBOSE", debug ? "1" : "0", 1);
1451
if(ret == -1){
1452
perror_plus("setenv");
1453
_exit(EX_OSERR);
1454
}
1455
ret = setenv("MODE", mode, 1);
1456
if(ret == -1){
1457
perror_plus("setenv");
1458
_exit(EX_OSERR);
1459
}
1460
char *delaystring;
1461
ret = asprintf(&delaystring, "%f", delay);
1462
if(ret == -1){
1463
perror_plus("asprintf");
1464
_exit(EX_OSERR);
1465
}
1466
ret = setenv("DELAY", delaystring, 1);
1467
if(ret == -1){
1468
free(delaystring);
1469
perror_plus("setenv");
1470
_exit(EX_OSERR);
1471
}
1472
free(delaystring);
1473
ret = execl(fullname, direntry->d_name, mode, NULL);
1474
perror_plus("execl");
1475
} else {
1476
int status;
1477
if(TEMP_FAILURE_RETRY(waitpid(hook_pid, &status, 0)) == -1){
1478
perror_plus("waitpid");
1479
free(fullname);
1480
continue;
1481
}
1482
if(WIFEXITED(status)){
1483
if(WEXITSTATUS(status) != 0){
1484
fprintf_plus(stderr, "Warning: network hook \"%s\" exited"
1485
" with status %d\n", direntry->d_name,
1486
WEXITSTATUS(status));
1487
free(fullname);
1488
continue;
1489
}
1490
} else if(WIFSIGNALED(status)){
1491
fprintf_plus(stderr, "Warning: network hook \"%s\" died by"
1492
" signal %d\n", direntry->d_name,
1493
WTERMSIG(status));
1494
free(fullname);
1495
continue;
1496
} else {
1497
fprintf_plus(stderr, "Warning: network hook \"%s\""
1498
" crashed\n", direntry->d_name);
1499
free(fullname);
1500
continue;
1501
}
1502
}
1503
free(fullname);
1504
if(debug){
1505
fprintf_plus(stderr, "Network hook \"%s\" ran successfully\n",
1506
direntry->d_name);
1507
}
1508
}
1509
close(devnull);
1510
}
1511
return true;
1512
}
1513
1514
int main(int argc, char *argv[]){
1515
AvahiSServiceBrowser *sb = NULL;
1516
int error;
1517
int ret;
1518
intmax_t tmpmax;
1519
char *tmp;
1520
int exitcode = EXIT_SUCCESS;
1521
const char *interface = "";
1522
struct ifreq network;
1523
int sd = -1;
1524
bool take_down_interface = false;
1525
uid_t uid;
1526
gid_t gid;
1527
char tempdir[] = "/tmp/mandosXXXXXX";
1528
bool tempdir_created = false;
1529
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
1530
const char *seckey = PATHDIR "/" SECKEY;
1531
const char *pubkey = PATHDIR "/" PUBKEY;
1532
1533
bool gnutls_initialized = false;
1534
bool gpgme_initialized = false;
1535
float delay = 2.5f;
1536
double retry_interval = 10; /* 10s between trying a server and
1537
retrying the same server again */
1538
1539
struct sigaction old_sigterm_action = { .sa_handler = SIG_DFL };
1540
struct sigaction sigterm_action = { .sa_handler = handle_sigterm };
1541
1542
uid = getuid();
1543
gid = getgid();
1544
1545
/* Lower any group privileges we might have, just to be safe */
1546
errno = 0;
1547
ret = setgid(gid);
1548
if(ret == -1){
1549
perror_plus("setgid");
1550
}
1551
1552
/* Lower user privileges (temporarily) */
1553
errno = 0;
1554
ret = seteuid(uid);
1555
if(ret == -1){
1556
perror_plus("seteuid");
1557
}
1558
1559
if(quit_now){
1560
goto end;
1561
}
1562
1563
{
1564
struct argp_option options[] = {
1565
{ .name = "debug", .key = 128,
1566
.doc = "Debug mode", .group = 3 },
1567
{ .name = "connect", .key = 'c',
1568
.arg = "ADDRESS:PORT",
1569
.doc = "Connect directly to a specific Mandos server",
1570
.group = 1 },
1571
{ .name = "interface", .key = 'i',
1572
.arg = "NAME",
1573
.doc = "Network interface that will be used to search for"
1574
" Mandos servers",
1575
.group = 1 },
1576
{ .name = "seckey", .key = 's',
1577
.arg = "FILE",
1578
.doc = "OpenPGP secret key file base name",
1579
.group = 1 },
1580
{ .name = "pubkey", .key = 'p',
1581
.arg = "FILE",
1582
.doc = "OpenPGP public key file base name",
1583
.group = 2 },
1584
{ .name = "dh-bits", .key = 129,
1585
.arg = "BITS",
1586
.doc = "Bit length of the prime number used in the"
1587
" Diffie-Hellman key exchange",
1588
.group = 2 },
1589
{ .name = "priority", .key = 130,
1590
.arg = "STRING",
1591
.doc = "GnuTLS priority string for the TLS handshake",
1592
.group = 1 },
1593
{ .name = "delay", .key = 131,
1594
.arg = "SECONDS",
1595
.doc = "Maximum delay to wait for interface startup",
1596
.group = 2 },
1597
{ .name = "retry", .key = 132,
1598
.arg = "SECONDS",
1599
.doc = "Retry interval used when denied by the mandos server",
1600
.group = 2 },
1601
{ .name = "network-hook-dir", .key = 133,
1602
.arg = "DIR",
1603
.doc = "Directory where network hooks are located",
1604
.group = 2 },
1605
/*
1606
* These reproduce what we would get without ARGP_NO_HELP
1607
*/
1608
{ .name = "help", .key = '?',
1609
.doc = "Give this help list", .group = -1 },
1610
{ .name = "usage", .key = -3,
1611
.doc = "Give a short usage message", .group = -1 },
1612
{ .name = "version", .key = 'V',
1613
.doc = "Print program version", .group = -1 },
1614
{ .name = NULL }
1615
};
1616
1617
error_t parse_opt(int key, char *arg,
1618
struct argp_state *state){
1619
errno = 0;
1620
switch(key){
1621
case 128: /* --debug */
1622
debug = true;
1623
break;
1624
case 'c': /* --connect */
1625
connect_to = arg;
1626
break;
1627
case 'i': /* --interface */
1628
interface = arg;
1629
break;
1630
case 's': /* --seckey */
1631
seckey = arg;
1632
break;
1633
case 'p': /* --pubkey */
1634
pubkey = arg;
1635
break;
1636
case 129: /* --dh-bits */
1637
errno = 0;
1638
tmpmax = strtoimax(arg, &tmp, 10);
1639
if(errno != 0 or tmp == arg or *tmp != '\0'
1640
or tmpmax != (typeof(mc.dh_bits))tmpmax){
1641
argp_error(state, "Bad number of DH bits");
1642
}
1643
mc.dh_bits = (typeof(mc.dh_bits))tmpmax;
1644
break;
1645
case 130: /* --priority */
1646
mc.priority = arg;
1647
break;
1648
case 131: /* --delay */
1649
errno = 0;
1650
delay = strtof(arg, &tmp);
1651
if(errno != 0 or tmp == arg or *tmp != '\0'){
1652
argp_error(state, "Bad delay");
1653
}
1654
case 132: /* --retry */
1655
errno = 0;
1656
retry_interval = strtod(arg, &tmp);
1657
if(errno != 0 or tmp == arg or *tmp != '\0'
1658
or (retry_interval * 1000) > INT_MAX
1659
or retry_interval < 0){
1660
argp_error(state, "Bad retry interval");
1661
}
1662
break;
1663
case 133: /* --network-hook-dir */
1664
hookdir = arg;
1665
break;
1666
/*
1667
* These reproduce what we would get without ARGP_NO_HELP
1668
*/
1669
case '?': /* --help */
1670
argp_state_help(state, state->out_stream,
1671
(ARGP_HELP_STD_HELP | ARGP_HELP_EXIT_ERR)
1672
& ~(unsigned int)ARGP_HELP_EXIT_OK);
1673
case -3: /* --usage */
1674
argp_state_help(state, state->out_stream,
1675
ARGP_HELP_USAGE | ARGP_HELP_EXIT_ERR);
1676
case 'V': /* --version */
1677
fprintf_plus(state->out_stream, "%s\n", argp_program_version);
1678
exit(argp_err_exit_status);
1679
break;
1680
default:
1681
return ARGP_ERR_UNKNOWN;
1682
}
1683
return errno;
1684
}
1685
1686
struct argp argp = { .options = options, .parser = parse_opt,
1687
.args_doc = "",
1688
.doc = "Mandos client -- Get and decrypt"
1689
" passwords from a Mandos server" };
1690
ret = argp_parse(&argp, argc, argv,
1691
ARGP_IN_ORDER | ARGP_NO_HELP, 0, NULL);
1692
switch(ret){
1693
case 0:
1694
break;
1695
case ENOMEM:
1696
default:
1697
errno = ret;
1698
perror_plus("argp_parse");
1699
exitcode = EX_OSERR;
1700
goto end;
1701
case EINVAL:
1702
exitcode = EX_USAGE;
1703
goto end;
1704
}
1705
}
1706
1707
{
1708
/* Work around Debian bug #633582:
1709
<http://bugs.debian.org/633582> */
1710
1711
/* Re-raise priviliges */
1712
errno = 0;
1713
ret = seteuid(0);
1714
if(ret == -1){
1715
perror_plus("seteuid");
1716
} else {
1717
struct stat st;
1718
1719
if(strcmp(seckey, PATHDIR "/" SECKEY) == 0){
1720
int seckey_fd = open(seckey, O_RDONLY);
1721
if(seckey_fd == -1){
1722
perror_plus("open");
1723
} else {
1724
ret = (int)TEMP_FAILURE_RETRY(fstat(seckey_fd, &st));
1725
if(ret == -1){
1726
perror_plus("fstat");
1727
} else {
1728
if(S_ISREG(st.st_mode)
1729
and st.st_uid == 0 and st.st_gid == 0){
1730
ret = fchown(seckey_fd, uid, gid);
1731
if(ret == -1){
1732
perror_plus("fchown");
1733
}
1734
}
1735
}
1736
TEMP_FAILURE_RETRY(close(seckey_fd));
1737
}
1738
}
1739
1740
if(strcmp(pubkey, PATHDIR "/" PUBKEY) == 0){
1741
int pubkey_fd = open(pubkey, O_RDONLY);
1742
if(pubkey_fd == -1){
1743
perror_plus("open");
1744
} else {
1745
ret = (int)TEMP_FAILURE_RETRY(fstat(pubkey_fd, &st));
1746
if(ret == -1){
1747
perror_plus("fstat");
1748
} else {
1749
if(S_ISREG(st.st_mode)
1750
and st.st_uid == 0 and st.st_gid == 0){
1751
ret = fchown(pubkey_fd, uid, gid);
1752
if(ret == -1){
1753
perror_plus("fchown");
1754
}
1755
}
1756
}
1757
TEMP_FAILURE_RETRY(close(pubkey_fd));
1758
}
1759
}
1760
1761
/* Lower privileges */
1762
errno = 0;
1763
ret = seteuid(uid);
1764
if(ret == -1){
1765
perror_plus("seteuid");
1766
}
1767
}
1768
}
1769
1770
/* Run network hooks */
1771
if(not run_network_hooks("start", interface, delay)){
1772
goto end;
1773
}
1774
1775
if(not debug){
421
static AvahiSimplePoll *simple_poll = NULL;
422
static AvahiServer *server = NULL;
423
424
static void resolve_callback(
425
AvahiSServiceResolver *r,
426
AVAHI_GCC_UNUSED AvahiIfIndex interface,
427
AVAHI_GCC_UNUSED AvahiProtocol protocol,
428
AvahiResolverEvent event,
429
const char *name,
430
const char *type,
431
const char *domain,
432
const char *host_name,
433
const AvahiAddress *address,
434
uint16_t port,
435
AvahiStringList *txt,
436
AvahiLookupResultFlags flags,
437
AVAHI_GCC_UNUSED void* userdata) {
438
439
assert(r);
440
441
/* Called whenever a service has been resolved successfully or timed out */
442
443
switch (event) {
444
case AVAHI_RESOLVER_FAILURE:
445
fprintf(stderr, "(Resolver) Failed to resolve service '%s' of type '%s' in domain '%s': %s\n", name, type, domain, avahi_strerror(avahi_server_errno(server)));
446
break;
447
448
case AVAHI_RESOLVER_FOUND: {
449
char ip[AVAHI_ADDRESS_STR_MAX];
450
avahi_address_snprint(ip, sizeof(ip), address);
451
int ret = start_mandos_communcation(ip, port);
452
if (ret == 0){
453
exit(EXIT_SUCCESS);
454
} else {
455
exit(EXIT_FAILURE);
456
}
457
}
458
}
459
avahi_s_service_resolver_free(r);
460
}
461
462
static void browse_callback(
463
AvahiSServiceBrowser *b,
464
AvahiIfIndex interface,
465
AvahiProtocol protocol,
466
AvahiBrowserEvent event,
467
const char *name,
468
const char *type,
469
const char *domain,
470
AVAHI_GCC_UNUSED AvahiLookupResultFlags flags,
471
void* userdata) {
472
473
AvahiServer *s = userdata;
474
assert(b);
475
476
/* Called whenever a new services becomes available on the LAN or is removed from the LAN */
477
478
switch (event) {
479
480
case AVAHI_BROWSER_FAILURE:
481
482
fprintf(stderr, "(Browser) %s\n", avahi_strerror(avahi_server_errno(server)));
483
avahi_simple_poll_quit(simple_poll);
484
return;
485
486
case AVAHI_BROWSER_NEW:
487
/* We ignore the returned resolver object. In the callback
488
function we free it. If the server is terminated before
489
the callback function is called the server will free
490
the resolver for us. */
491
492
if (!(avahi_s_service_resolver_new(s, interface, protocol, name, type, domain, AVAHI_PROTO_INET6, 0, resolve_callback, s)))
493
fprintf(stderr, "Failed to resolve service '%s': %s\n", name, avahi_strerror(avahi_server_errno(s)));
494
495
break;
496
497
case AVAHI_BROWSER_REMOVE:
498
break;
499
500
case AVAHI_BROWSER_ALL_FOR_NOW:
501
case AVAHI_BROWSER_CACHE_EXHAUSTED:
502
break;
503
}
504
}
505
506
int main(AVAHI_GCC_UNUSED int argc, AVAHI_GCC_UNUSED char*argv[]) {
507
AvahiServerConfig config;
508
AvahiSServiceBrowser *sb = NULL;
509
int error;
510
int ret = 1;
511
1776
512
avahi_set_log_function(empty_log);
1777
}
1778
1779
if(interface[0] == '\0'){
1780
struct dirent **direntries;
1781
/* First look for interfaces that are up */
1782
ret = scandir(sys_class_net, &direntries, up_interface,
1783
alphasort);
1784
if(ret == 0){
1785
/* No up interfaces, look for any good interfaces */
1786
free(direntries);
1787
ret = scandir(sys_class_net, &direntries, good_interface,
1788
alphasort);
1789
}
1790
if(ret >= 1){
1791
/* Pick the first interface returned */
1792
interface = strdup(direntries[0]->d_name);
1793
if(debug){
1794
fprintf_plus(stderr, "Using interface \"%s\"\n", interface);
1795
}
1796
if(interface == NULL){
1797
perror_plus("malloc");
1798
free(direntries);
1799
exitcode = EXIT_FAILURE;
1800
goto end;
1801
}
1802
free(direntries);
1803
} else {
1804
free(direntries);
1805
fprintf_plus(stderr, "Could not find a network interface\n");
1806
exitcode = EXIT_FAILURE;
1807
goto end;
1808
}
1809
}
1810
1811
/* Initialize Avahi early so avahi_simple_poll_quit() can be called
1812
from the signal handler */
1813
/* Initialize the pseudo-RNG for Avahi */
1814
srand((unsigned int) time(NULL));
1815
mc.simple_poll = avahi_simple_poll_new();
1816
if(mc.simple_poll == NULL){
1817
fprintf_plus(stderr,
1818
"Avahi: Failed to create simple poll object.\n");
1819
exitcode = EX_UNAVAILABLE;
1820
goto end;
1821
}
1822
1823
sigemptyset(&sigterm_action.sa_mask);
1824
ret = sigaddset(&sigterm_action.sa_mask, SIGINT);
1825
if(ret == -1){
1826
perror_plus("sigaddset");
1827
exitcode = EX_OSERR;
1828
goto end;
1829
}
1830
ret = sigaddset(&sigterm_action.sa_mask, SIGHUP);
1831
if(ret == -1){
1832
perror_plus("sigaddset");
1833
exitcode = EX_OSERR;
1834
goto end;
1835
}
1836
ret = sigaddset(&sigterm_action.sa_mask, SIGTERM);
1837
if(ret == -1){
1838
perror_plus("sigaddset");
1839
exitcode = EX_OSERR;
1840
goto end;
1841
}
1842
/* Need to check if the handler is SIG_IGN before handling:
1843
| [[info:libc:Initial Signal Actions]] |
1844
| [[info:libc:Basic Signal Handling]] |
1845
*/
1846
ret = sigaction(SIGINT, NULL, &old_sigterm_action);
1847
if(ret == -1){
1848
perror_plus("sigaction");
1849
return EX_OSERR;
1850
}
1851
if(old_sigterm_action.sa_handler != SIG_IGN){
1852
ret = sigaction(SIGINT, &sigterm_action, NULL);
1853
if(ret == -1){
1854
perror_plus("sigaction");
1855
exitcode = EX_OSERR;
1856
goto end;
1857
}
1858
}
1859
ret = sigaction(SIGHUP, NULL, &old_sigterm_action);
1860
if(ret == -1){
1861
perror_plus("sigaction");
1862
return EX_OSERR;
1863
}
1864
if(old_sigterm_action.sa_handler != SIG_IGN){
1865
ret = sigaction(SIGHUP, &sigterm_action, NULL);
1866
if(ret == -1){
1867
perror_plus("sigaction");
1868
exitcode = EX_OSERR;
1869
goto end;
1870
}
1871
}
1872
ret = sigaction(SIGTERM, NULL, &old_sigterm_action);
1873
if(ret == -1){
1874
perror_plus("sigaction");
1875
return EX_OSERR;
1876
}
1877
if(old_sigterm_action.sa_handler != SIG_IGN){
1878
ret = sigaction(SIGTERM, &sigterm_action, NULL);
1879
if(ret == -1){
1880
perror_plus("sigaction");
1881
exitcode = EX_OSERR;
1882
goto end;
1883
}
1884
}
1885
1886
/* If the interface is down, bring it up */
1887
if(strcmp(interface, "none") != 0){
1888
if_index = (AvahiIfIndex) if_nametoindex(interface);
1889
if(if_index == 0){
1890
fprintf_plus(stderr, "No such interface: \"%s\"\n", interface);
1891
exitcode = EX_UNAVAILABLE;
1892
goto end;
1893
}
1894
1895
if(quit_now){
1896
goto end;
1897
}
1898
1899
/* Re-raise priviliges */
1900
errno = 0;
1901
ret = seteuid(0);
1902
if(ret == -1){
1903
perror_plus("seteuid");
1904
}
1905
1906
#ifdef __linux__
1907
/* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
1908
messages about the network interface to mess up the prompt */
1909
ret = klogctl(8, NULL, 5);
1910
bool restore_loglevel = true;
1911
if(ret == -1){
1912
restore_loglevel = false;
1913
perror_plus("klogctl");
1914
}
1915
#endif /* __linux__ */
1916
1917
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1918
if(sd < 0){
1919
perror_plus("socket");
1920
exitcode = EX_OSERR;
1921
#ifdef __linux__
1922
if(restore_loglevel){
1923
ret = klogctl(7, NULL, 0);
1924
if(ret == -1){
1925
perror_plus("klogctl");
1926
}
1927
}
1928
#endif /* __linux__ */
1929
/* Lower privileges */
1930
errno = 0;
1931
ret = seteuid(uid);
1932
if(ret == -1){
1933
perror_plus("seteuid");
1934
}
1935
goto end;
1936
}
1937
strcpy(network.ifr_name, interface);
1938
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1939
if(ret == -1){
1940
perror_plus("ioctl SIOCGIFFLAGS");
1941
#ifdef __linux__
1942
if(restore_loglevel){
1943
ret = klogctl(7, NULL, 0);
1944
if(ret == -1){
1945
perror_plus("klogctl");
1946
}
1947
}
1948
#endif /* __linux__ */
1949
exitcode = EX_OSERR;
1950
/* Lower privileges */
1951
errno = 0;
1952
ret = seteuid(uid);
1953
if(ret == -1){
1954
perror_plus("seteuid");
1955
}
1956
goto end;
1957
}
1958
if((network.ifr_flags & IFF_UP) == 0){
1959
network.ifr_flags |= IFF_UP;
1960
take_down_interface = true;
1961
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1962
if(ret == -1){
1963
take_down_interface = false;
1964
perror_plus("ioctl SIOCSIFFLAGS +IFF_UP");
1965
exitcode = EX_OSERR;
1966
#ifdef __linux__
1967
if(restore_loglevel){
1968
ret = klogctl(7, NULL, 0);
1969
if(ret == -1){
1970
perror_plus("klogctl");
1971
}
1972
}
1973
#endif /* __linux__ */
1974
/* Lower privileges */
1975
errno = 0;
1976
ret = seteuid(uid);
1977
if(ret == -1){
1978
perror_plus("seteuid");
1979
}
1980
goto end;
1981
}
1982
}
1983
/* Sleep checking until interface is running.
1984
Check every 0.25s, up to total time of delay */
1985
for(int i=0; i < delay * 4; i++){
1986
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1987
if(ret == -1){
1988
perror_plus("ioctl SIOCGIFFLAGS");
1989
} else if(network.ifr_flags & IFF_RUNNING){
1990
break;
1991
}
1992
struct timespec sleeptime = { .tv_nsec = 250000000 };
1993
ret = nanosleep(&sleeptime, NULL);
1994
if(ret == -1 and errno != EINTR){
1995
perror_plus("nanosleep");
1996
}
1997
}
1998
if(not take_down_interface){
1999
/* We won't need the socket anymore */
2000
ret = (int)TEMP_FAILURE_RETRY(close(sd));
2001
if(ret == -1){
2002
perror_plus("close");
2003
}
2004
}
2005
#ifdef __linux__
2006
if(restore_loglevel){
2007
/* Restores kernel loglevel to default */
2008
ret = klogctl(7, NULL, 0);
2009
if(ret == -1){
2010
perror_plus("klogctl");
2011
}
2012
}
2013
#endif /* __linux__ */
2014
/* Lower privileges */
2015
errno = 0;
2016
/* Lower privileges */
2017
ret = seteuid(uid);
2018
if(ret == -1){
2019
perror_plus("seteuid");
2020
}
2021
}
2022
2023
if(quit_now){
2024
goto end;
2025
}
2026
2027
ret = init_gnutls_global(pubkey, seckey);
2028
if(ret == -1){
2029
fprintf_plus(stderr, "init_gnutls_global failed\n");
2030
exitcode = EX_UNAVAILABLE;
2031
goto end;
2032
} else {
2033
gnutls_initialized = true;
2034
}
2035
2036
if(quit_now){
2037
goto end;
2038
}
2039
2040
if(mkdtemp(tempdir) == NULL){
2041
perror_plus("mkdtemp");
2042
goto end;
2043
}
2044
tempdir_created = true;
2045
2046
if(quit_now){
2047
goto end;
2048
}
2049
2050
if(not init_gpgme(pubkey, seckey, tempdir)){
2051
fprintf_plus(stderr, "init_gpgme failed\n");
2052
exitcode = EX_UNAVAILABLE;
2053
goto end;
2054
} else {
2055
gpgme_initialized = true;
2056
}
2057
2058
if(quit_now){
2059
goto end;
2060
}
2061
2062
if(connect_to != NULL){
2063
/* Connect directly, do not use Zeroconf */
2064
/* (Mainly meant for debugging) */
2065
char *address = strrchr(connect_to, ':');
2066
if(address == NULL){
2067
fprintf_plus(stderr, "No colon in address\n");
2068
exitcode = EX_USAGE;
2069
goto end;
2070
}
2071
2072
if(quit_now){
2073
goto end;
2074
}
2075
2076
uint16_t port;
2077
errno = 0;
2078
tmpmax = strtoimax(address+1, &tmp, 10);
2079
if(errno != 0 or tmp == address+1 or *tmp != '\0'
2080
or tmpmax != (uint16_t)tmpmax){
2081
fprintf_plus(stderr, "Bad port number\n");
2082
exitcode = EX_USAGE;
2083
goto end;
2084
}
2085
2086
if(quit_now){
2087
goto end;
2088
}
2089
2090
port = (uint16_t)tmpmax;
2091
*address = '\0';
2092
/* Colon in address indicates IPv6 */
2093
int af;
2094
if(strchr(connect_to, ':') != NULL){
2095
af = AF_INET6;
2096
/* Accept [] around IPv6 address - see RFC 5952 */
2097
if(connect_to[0] == '[' and address[-1] == ']')
2098
{
2099
connect_to++;
2100
address[-1] = '\0';
2101
}
2102
} else {
2103
af = AF_INET;
2104
}
2105
address = connect_to;
2106
2107
if(quit_now){
2108
goto end;
2109
}
2110
2111
while(not quit_now){
2112
ret = start_mandos_communication(address, port, if_index, af);
2113
if(quit_now or ret == 0){
2114
break;
2115
}
2116
if(debug){
2117
fprintf_plus(stderr, "Retrying in %d seconds\n",
2118
(int)retry_interval);
2119
}
2120
sleep((int)retry_interval);
2121
}
2122
2123
if (not quit_now){
2124
exitcode = EXIT_SUCCESS;
2125
}
2126
2127
goto end;
2128
}
2129
2130
if(quit_now){
2131
goto end;
2132
}
2133
2134
{
2135
AvahiServerConfig config;
2136
/* Do not publish any local Zeroconf records */
513
514
/* Initialize the psuedo-RNG */
515
srand(time(NULL));
516
517
/* Allocate main loop object */
518
if (!(simple_poll = avahi_simple_poll_new())) {
519
fprintf(stderr, "Failed to create simple poll object.\n");
520
goto fail;
521
}
522
523
/* Do not publish any local records */
2137
524
avahi_server_config_init(&config);
2138
525
config.publish_hinfo = 0;
2139
526
config.publish_addresses = 0;
2140
527
config.publish_workstation = 0;
2141
528
config.publish_domain = 0;
529
530
/* /\* Set a unicast DNS server for wide area DNS-SD *\/ */
531
/* avahi_address_parse("193.11.177.11", AVAHI_PROTO_UNSPEC, &config.wide_area_servers[0]); */
532
/* config.n_wide_area_servers = 1; */
533
/* config.enable_wide_area = 1; */
2142
534
2143
535
/* Allocate a new server */
2144
mc.server = avahi_server_new(avahi_simple_poll_get
2145
(mc.simple_poll), &config, NULL,
2146
NULL, &error);
2147
2148
/* Free the Avahi configuration data */
536
server = avahi_server_new(avahi_simple_poll_get(simple_poll), &config, NULL, NULL, &error);
537
538
/* Free the configuration data */
2149
539
avahi_server_config_free(&config);
2150
}
2151
2152
/* Check if creating the Avahi server object succeeded */
2153
if(mc.server == NULL){
2154
fprintf_plus(stderr, "Failed to create Avahi server: %s\n",
2155
avahi_strerror(error));
2156
exitcode = EX_UNAVAILABLE;
2157
goto end;
2158
}
2159
2160
if(quit_now){
2161
goto end;
2162
}
2163
2164
/* Create the Avahi service browser */
2165
sb = avahi_s_service_browser_new(mc.server, if_index,
2166
AVAHI_PROTO_UNSPEC, "_mandos._tcp",
2167
NULL, 0, browse_callback, NULL);
2168
if(sb == NULL){
2169
fprintf_plus(stderr, "Failed to create service browser: %s\n",
2170
avahi_strerror(avahi_server_errno(mc.server)));
2171
exitcode = EX_UNAVAILABLE;
2172
goto end;
2173
}
2174
2175
if(quit_now){
2176
goto end;
2177
}
2178
2179
/* Run the main loop */
2180
2181
if(debug){
2182
fprintf_plus(stderr, "Starting Avahi loop search\n");
2183
}
2184
2185
ret = avahi_loop_with_timeout(mc.simple_poll,
2186
(int)(retry_interval * 1000));
2187
if(debug){
2188
fprintf_plus(stderr, "avahi_loop_with_timeout exited %s\n",
2189
(ret == 0) ? "successfully" : "with error");
2190
}
2191
2192
end:
2193
2194
if(debug){
2195
fprintf_plus(stderr, "%s exiting\n", argv[0]);
2196
}
2197
2198
/* Cleanup things */
2199
if(sb != NULL)
2200
avahi_s_service_browser_free(sb);
2201
2202
if(mc.server != NULL)
2203
avahi_server_free(mc.server);
2204
2205
if(mc.simple_poll != NULL)
2206
avahi_simple_poll_free(mc.simple_poll);
2207
2208
if(gnutls_initialized){
2209
gnutls_certificate_free_credentials(mc.cred);
2210
gnutls_global_deinit();
2211
gnutls_dh_params_deinit(mc.dh_params);
2212
}
2213
2214
if(gpgme_initialized){
2215
gpgme_release(mc.ctx);
2216
}
2217
2218
/* Cleans up the circular linked list of Mandos servers the client
2219
has seen */
2220
if(mc.current_server != NULL){
2221
mc.current_server->prev->next = NULL;
2222
while(mc.current_server != NULL){
2223
server *next = mc.current_server->next;
2224
free(mc.current_server);
2225
mc.current_server = next;
2226
}
2227
}
2228
2229
/* Run network hooks */
2230
run_network_hooks("stop", interface, delay);
2231
2232
/* Re-raise priviliges */
2233
{
2234
errno = 0;
2235
ret = seteuid(0);
2236
if(ret == -1){
2237
perror_plus("seteuid");
2238
}
2239
2240
/* Take down the network interface */
2241
if(take_down_interface and geteuid() == 0){
2242
ret = ioctl(sd, SIOCGIFFLAGS, &network);
2243
if(ret == -1){
2244
perror_plus("ioctl SIOCGIFFLAGS");
2245
} else if(network.ifr_flags & IFF_UP){
2246
network.ifr_flags &= ~(short)IFF_UP; /* clear flag */
2247
ret = ioctl(sd, SIOCSIFFLAGS, &network);
2248
if(ret == -1){
2249
perror_plus("ioctl SIOCSIFFLAGS -IFF_UP");
2250
}
2251
}
2252
ret = (int)TEMP_FAILURE_RETRY(close(sd));
2253
if(ret == -1){
2254
perror_plus("close");
2255
}
2256
}
2257
}
2258
/* Lower privileges permanently */
2259
errno = 0;
2260
ret = setuid(uid);
2261
if(ret == -1){
2262
perror_plus("setuid");
2263
}
2264
2265
/* Removes the GPGME temp directory and all files inside */
2266
if(tempdir_created){
2267
struct dirent **direntries = NULL;
2268
struct dirent *direntry = NULL;
2269
int numentries = scandir(tempdir, &direntries, notdotentries,
2270
alphasort);
2271
if (numentries > 0){
2272
for(int i = 0; i < numentries; i++){
2273
direntry = direntries[i];
2274
char *fullname = NULL;
2275
ret = asprintf(&fullname, "%s/%s", tempdir,
2276
direntry->d_name);
2277
if(ret < 0){
2278
perror_plus("asprintf");
2279
continue;
2280
}
2281
ret = remove(fullname);
2282
if(ret == -1){
2283
fprintf_plus(stderr, "remove(\"%s\"): %s\n", fullname,
2284
strerror(errno));
2285
}
2286
free(fullname);
2287
}
2288
}
2289
2290
/* need to clean even if 0 because man page doesn't specify */
2291
free(direntries);
2292
if (numentries == -1){
2293
perror_plus("scandir");
2294
}
2295
ret = rmdir(tempdir);
2296
if(ret == -1 and errno != ENOENT){
2297
perror_plus("rmdir");
2298
}
2299
}
2300
2301
if(quit_now){
2302
sigemptyset(&old_sigterm_action.sa_mask);
2303
old_sigterm_action.sa_handler = SIG_DFL;
2304
ret = (int)TEMP_FAILURE_RETRY(sigaction(signal_received,
2305
&old_sigterm_action,
2306
NULL));
2307
if(ret == -1){
2308
perror_plus("sigaction");
2309
}
2310
do {
2311
ret = raise(signal_received);
2312
} while(ret != 0 and errno == EINTR);
2313
if(ret != 0){
2314
perror_plus("raise");
2315
abort();
2316
}
2317
TEMP_FAILURE_RETRY(pause());
2318
}
2319
2320
return exitcode;
540
541
/* Check wether creating the server object succeeded */
542
if (!server) {
543
fprintf(stderr, "Failed to create server: %s\n", avahi_strerror(error));
544
goto fail;
545
}
546
547
/* Create the service browser */
548
if (!(sb = avahi_s_service_browser_new(server, if_nametoindex("eth0"), AVAHI_PROTO_INET6, "_mandos._tcp", NULL, 0, browse_callback, server))) {
549
fprintf(stderr, "Failed to create service browser: %s\n", avahi_strerror(avahi_server_errno(server)));
550
goto fail;
551
}
552
553
/* Run the main loop */
554
avahi_simple_poll_loop(simple_poll);
555
556
ret = 0;
557
558
fail:
559
560
/* Cleanup things */
561
if (sb)
562
avahi_s_service_browser_free(sb);
563
564
if (server)
565
avahi_server_free(server);
566
567
if (simple_poll)
568
avahi_simple_poll_free(simple_poll);
569
570
return ret;
2321
571
}
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0