264
262
rc = gpgme_data_new_from_fd(&pgp_data, fd);
265
263
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));
264
fprintf(stderr, "Mandos plugin mandos-client: "
265
"bad gpgme_data_new_from_fd: %s: %s\n",
266
gpgme_strsource(rc), gpgme_strerror(rc));
271
270
rc = gpgme_op_import(mc.ctx, pgp_data);
272
271
if(rc != GPG_ERR_NO_ERROR){
273
fprintf_plus(stderr, "bad gpgme_op_import: %s: %s\n",
274
gpgme_strsource(rc), gpgme_strerror(rc));
272
fprintf(stderr, "Mandos plugin mandos-client: "
273
"bad gpgme_op_import: %s: %s\n",
274
gpgme_strsource(rc), gpgme_strerror(rc));
287
fprintf_plus(stderr, "Initializing GPGME\n");
287
fprintf(stderr, "Mandos plugin mandos-client: "
288
"Initializing GPGME\n");
291
292
gpgme_check_version(NULL);
292
293
rc = gpgme_engine_check_version(GPGME_PROTOCOL_OpenPGP);
293
294
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));
295
fprintf(stderr, "Mandos plugin mandos-client: "
296
"bad gpgme_engine_check_version: %s: %s\n",
297
gpgme_strsource(rc), gpgme_strerror(rc));
299
301
/* Set GPGME home directory for the OpenPGP engine only */
300
302
rc = gpgme_get_engine_info(&engine_info);
301
303
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
fprintf(stderr, "Mandos plugin mandos-client: "
305
"bad gpgme_get_engine_info: %s: %s\n",
306
gpgme_strsource(rc), gpgme_strerror(rc));
306
309
while(engine_info != NULL){
312
315
engine_info = engine_info->next;
314
317
if(engine_info == NULL){
315
fprintf_plus(stderr, "Could not set GPGME home dir to %s\n",
318
fprintf(stderr, "Mandos plugin mandos-client: "
319
"Could not set GPGME home dir to %s\n", tempdir);
320
323
/* Create new GPGME "context" */
321
324
rc = gpgme_new(&(mc.ctx));
322
325
if(rc != GPG_ERR_NO_ERROR){
323
fprintf_plus(stderr, "Mandos plugin mandos-client: "
324
"bad gpgme_new: %s: %s\n", gpgme_strsource(rc),
326
fprintf(stderr, "Mandos plugin mandos-client: "
327
"bad gpgme_new: %s: %s\n", gpgme_strsource(rc),
347
350
ssize_t plaintext_length = 0;
350
fprintf_plus(stderr, "Trying to decrypt OpenPGP data\n");
353
fprintf(stderr, "Mandos plugin mandos-client: "
354
"Trying to decrypt OpenPGP data\n");
353
357
/* Create new GPGME data buffer from memory cryptotext */
354
358
rc = gpgme_data_new_from_mem(&dh_crypto, cryptotext, crypto_size,
356
360
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));
361
fprintf(stderr, "Mandos plugin mandos-client: "
362
"bad gpgme_data_new_from_mem: %s: %s\n",
363
gpgme_strsource(rc), gpgme_strerror(rc));
362
367
/* Create new empty GPGME data buffer for the plaintext */
363
368
rc = gpgme_data_new(&dh_plain);
364
369
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));
370
fprintf(stderr, "Mandos plugin mandos-client: "
371
"bad gpgme_data_new: %s: %s\n",
372
gpgme_strsource(rc), gpgme_strerror(rc));
368
373
gpgme_data_release(dh_crypto);
374
379
rc = gpgme_op_decrypt(mc.ctx, dh_crypto, dh_plain);
375
380
if(rc != GPG_ERR_NO_ERROR){
376
fprintf_plus(stderr, "bad gpgme_op_decrypt: %s: %s\n",
377
gpgme_strsource(rc), gpgme_strerror(rc));
381
fprintf(stderr, "Mandos plugin mandos-client: "
382
"bad gpgme_op_decrypt: %s: %s\n",
383
gpgme_strsource(rc), gpgme_strerror(rc));
378
384
plaintext_length = -1;
380
386
gpgme_decrypt_result_t result;
381
387
result = gpgme_op_decrypt_result(mc.ctx);
382
388
if(result == NULL){
383
fprintf_plus(stderr, "gpgme_op_decrypt_result failed\n");
389
fprintf(stderr, "Mandos plugin mandos-client: "
390
"gpgme_op_decrypt_result failed\n");
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);
392
fprintf(stderr, "Mandos plugin mandos-client: "
393
"Unsupported algorithm: %s\n",
394
result->unsupported_algorithm);
395
fprintf(stderr, "Mandos plugin mandos-client: "
396
"Wrong key usage: %u\n",
397
result->wrong_key_usage);
389
398
if(result->file_name != NULL){
390
fprintf_plus(stderr, "File name: %s\n", result->file_name);
399
fprintf(stderr, "Mandos plugin mandos-client: "
400
"File name: %s\n", result->file_name);
392
402
gpgme_recipient_t recipient;
393
403
recipient = result->recipients;
394
404
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
405
fprintf(stderr, "Mandos plugin mandos-client: "
406
"Public key algorithm: %s\n",
407
gpgme_pubkey_algo_name(recipient->pubkey_algo));
408
fprintf(stderr, "Mandos plugin mandos-client: "
409
"Key ID: %s\n", recipient->keyid);
410
fprintf(stderr, "Mandos plugin mandos-client: "
411
"Secret key available: %s\n",
412
recipient->status == GPG_ERR_NO_SECKEY
402
414
recipient = recipient->next;
501
516
/* OpenPGP credentials */
502
517
ret = gnutls_certificate_allocate_credentials(&mc.cred);
503
518
if(ret != GNUTLS_E_SUCCESS){
504
fprintf_plus(stderr, "GnuTLS memory error: %s\n",
505
safer_gnutls_strerror(ret));
519
fprintf(stderr, "Mandos plugin mandos-client: "
520
"GnuTLS memory error: %s\n", safer_gnutls_strerror(ret));
506
521
gnutls_global_deinit();
511
fprintf_plus(stderr, "Attempting to use OpenPGP public key %s and"
512
" secret key %s as GnuTLS credentials\n",
526
fprintf(stderr, "Mandos plugin mandos-client: "
527
"Attempting to use OpenPGP public key %s and"
528
" secret key %s as GnuTLS credentials\n", pubkeyfilename,
517
532
ret = gnutls_certificate_set_openpgp_key_file
518
533
(mc.cred, pubkeyfilename, seckeyfilename,
519
534
GNUTLS_OPENPGP_FMT_BASE64);
520
535
if(ret != GNUTLS_E_SUCCESS){
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));
537
"Mandos plugin mandos-client: "
538
"Error[%d] while reading the OpenPGP key pair ('%s',"
539
" '%s')\n", ret, pubkeyfilename, seckeyfilename);
540
fprintf(stderr, "Mandos plugin mandos-client: "
541
"The GnuTLS error is: %s\n", safer_gnutls_strerror(ret));
529
545
/* GnuTLS server initialization */
530
546
ret = gnutls_dh_params_init(&mc.dh_params);
531
547
if(ret != GNUTLS_E_SUCCESS){
532
fprintf_plus(stderr, "Error in GnuTLS DH parameter"
533
" initialization: %s\n",
534
safer_gnutls_strerror(ret));
548
fprintf(stderr, "Mandos plugin mandos-client: "
549
"Error in GnuTLS DH parameter initialization:"
550
" %s\n", safer_gnutls_strerror(ret));
537
553
ret = gnutls_dh_params_generate2(mc.dh_params, mc.dh_bits);
538
554
if(ret != GNUTLS_E_SUCCESS){
539
fprintf_plus(stderr, "Error in GnuTLS prime generation: %s\n",
540
safer_gnutls_strerror(ret));
555
fprintf(stderr, "Mandos plugin mandos-client: "
556
"Error in GnuTLS prime generation: %s\n",
557
safer_gnutls_strerror(ret));
729
752
if(if_indextoname((unsigned int)if_index, interface) == NULL){
730
753
perror_plus("if_indextoname");
732
fprintf_plus(stderr, "Connection to: %s%%%s, port %" PRIu16
733
"\n", ip, interface, port);
755
fprintf(stderr, "Mandos plugin mandos-client: "
756
"Connection to: %s%%%s, port %" PRIu16 "\n",
757
ip, interface, port);
736
fprintf_plus(stderr, "Connection to: %s, port %" PRIu16 "\n",
760
fprintf(stderr, "Mandos plugin mandos-client: "
761
"Connection to: %s, port %" PRIu16 "\n", ip, port);
739
763
char addrstr[(INET_ADDRSTRLEN > INET6_ADDRSTRLEN) ?
740
764
INET_ADDRSTRLEN : INET6_ADDRSTRLEN] = "";
1012
1042
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,
1016
avahi_strerror(avahi_server_errno(mc.server)));
1043
fprintf(stderr, "Mandos plugin mandos-client: "
1044
"(Avahi Resolver) Failed to resolve service '%s'"
1045
" of type '%s' in domain '%s': %s\n", name, type, domain,
1046
avahi_strerror(avahi_server_errno(mc.server)));
1019
1049
case AVAHI_RESOLVER_FOUND:
1021
1051
char ip[AVAHI_ADDRESS_STR_MAX];
1022
1052
avahi_address_snprint(ip, sizeof(ip), address);
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);
1054
fprintf(stderr, "Mandos plugin mandos-client: "
1055
"Mandos server \"%s\" found on %s (%s, %"
1056
PRIdMAX ") on port %" PRIu16 "\n", name, host_name,
1057
ip, (intmax_t)interface, port);
1028
1059
int ret = start_mandos_communication(ip, port, interface,
1029
1060
avahi_proto_to_af(proto));
1075
1107
if(avahi_s_service_resolver_new(mc.server, interface, protocol,
1076
1108
name, type, domain, protocol, 0,
1077
1109
resolve_callback, NULL) == NULL)
1078
fprintf_plus(stderr, "Avahi: Failed to resolve service '%s':"
1080
avahi_strerror(avahi_server_errno(mc.server)));
1110
fprintf(stderr, "Mandos plugin mandos-client: "
1111
"Avahi: Failed to resolve service '%s': %s\n",
1112
name, avahi_strerror(avahi_server_errno(mc.server)));
1083
1115
case AVAHI_BROWSER_REMOVE:
1132
1164
/* Reject the loopback device */
1133
1165
if(ifr->ifr_flags & IFF_LOOPBACK){
1135
fprintf_plus(stderr, "Rejecting loopback interface \"%s\"\n",
1167
fprintf(stderr, "Mandos plugin mandos-client: "
1168
"Rejecting loopback interface \"%s\"\n", ifname);
1140
1172
/* Accept point-to-point devices only if connect_to is specified */
1141
1173
if(connect_to != NULL and (ifr->ifr_flags & IFF_POINTOPOINT)){
1143
fprintf_plus(stderr, "Accepting point-to-point interface"
1144
" \"%s\"\n", ifname);
1175
fprintf(stderr, "Mandos plugin mandos-client: "
1176
"Accepting point-to-point interface \"%s\"\n", ifname);
1148
1180
/* Otherwise, reject non-broadcast-capable devices */
1149
1181
if(not (ifr->ifr_flags & IFF_BROADCAST)){
1151
fprintf_plus(stderr, "Rejecting non-broadcast interface"
1152
" \"%s\"\n", ifname);
1183
fprintf(stderr, "Mandos plugin mandos-client: "
1184
"Rejecting non-broadcast interface \"%s\"\n", ifname);
1156
1188
/* Reject non-ARP interfaces (including dummy interfaces) */
1157
1189
if(ifr->ifr_flags & IFF_NOARP){
1159
fprintf_plus(stderr, "Rejecting non-ARP interface \"%s\"\n",
1191
fprintf(stderr, "Mandos plugin mandos-client: "
1192
"Rejecting non-ARP interface \"%s\"\n", ifname);
1165
1197
/* Accept this device */
1167
fprintf_plus(stderr, "Interface \"%s\" is good\n", ifname);
1199
fprintf(stderr, "Mandos plugin mandos-client: "
1200
"Interface \"%s\" is good\n", ifname);
1289
1327
if(not (S_ISREG(st.st_mode))){
1290
1328
/* Not a regular file */
1292
fprintf_plus(stderr, "Ignoring hook \"%s\" - not a file\n",
1330
fprintf(stderr, "Mandos plugin mandos-client: "
1331
"Ignoring hook \"%s\" - not a file\n",
1297
1336
if(not (st.st_mode & (S_IXUSR | S_IXGRP | S_IXOTH))){
1298
1337
/* Not executable */
1300
fprintf_plus(stderr, "Ignoring hook \"%s\" - not executable\n",
1339
fprintf(stderr, "Mandos plugin mandos-client: "
1340
"Ignoring hook \"%s\" - not executable\n",
1306
fprintf_plus(stderr, "Hook \"%s\" is acceptable\n",
1384
bool run_network_hooks(const char *mode, const char *interface,
1386
struct dirent **direntries;
1387
struct dirent *direntry;
1389
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1392
perror_plus("scandir");
1394
int devnull = open("/dev/null", O_RDONLY);
1395
for(int i = 0; i < numhooks; i++){
1396
direntry = direntries[i];
1397
char *fullname = NULL;
1398
ret = asprintf(&fullname, "%s/%s", hookdir, direntry->d_name);
1400
perror_plus("asprintf");
1404
fprintf_plus(stderr, "Running network hook \"%s\"\n",
1407
pid_t hook_pid = fork();
1410
/* Raise privileges */
1414
perror_plus("seteuid");
1416
/* Raise privileges even more */
1420
perror_plus("setuid");
1426
perror_plus("setgid");
1428
/* Reset supplementary groups */
1430
ret = setgroups(0, NULL);
1432
perror_plus("setgroups");
1434
dup2(devnull, STDIN_FILENO);
1436
dup2(STDERR_FILENO, STDOUT_FILENO);
1437
ret = setenv("MANDOSNETHOOKDIR", hookdir, 1);
1439
perror_plus("setenv");
1442
ret = setenv("DEVICE", interface, 1);
1444
perror_plus("setenv");
1447
ret = setenv("VERBOSE", debug ? "1" : "0", 1);
1449
perror_plus("setenv");
1452
ret = setenv("MODE", mode, 1);
1454
perror_plus("setenv");
1458
ret = asprintf(&delaystring, "%f", delay);
1460
perror_plus("asprintf");
1463
ret = setenv("DELAY", delaystring, 1);
1466
perror_plus("setenv");
1470
ret = execl(fullname, direntry->d_name, mode, NULL);
1471
perror_plus("execl");
1474
if(TEMP_FAILURE_RETRY(waitpid(hook_pid, &status, 0)) == -1){
1475
perror_plus("waitpid");
1479
if(WIFEXITED(status)){
1480
if(WEXITSTATUS(status) != 0){
1481
fprintf_plus(stderr, "Warning: network hook \"%s\" exited"
1482
" with status %d\n", direntry->d_name,
1483
WEXITSTATUS(status));
1487
} else if(WIFSIGNALED(status)){
1488
fprintf_plus(stderr, "Warning: network hook \"%s\" died by"
1489
" signal %d\n", direntry->d_name,
1494
fprintf_plus(stderr, "Warning: network hook \"%s\""
1495
" crashed\n", direntry->d_name);
1502
fprintf_plus(stderr, "Network hook \"%s\" ran successfully\n",
1511
1421
int main(int argc, char *argv[]){
1512
1422
AvahiSServiceBrowser *sb = NULL;
1707
1616
/* Work around Debian bug #633582:
1708
1617
<http://bugs.debian.org/633582> */
1710
1620
/* Re-raise priviliges */
1712
1622
ret = seteuid(0);
1714
1624
perror_plus("seteuid");
1627
if(strcmp(seckey, PATHDIR "/" SECKEY) == 0){
1628
int seckey_fd = open(seckey, O_RDONLY);
1629
if(seckey_fd == -1){
1630
perror_plus("open");
1632
ret = (int)TEMP_FAILURE_RETRY(fstat(seckey_fd, &st));
1634
perror_plus("fstat");
1636
if(S_ISREG(st.st_mode) and st.st_uid == 0 and st.st_gid == 0){
1637
ret = fchown(seckey_fd, uid, gid);
1639
perror_plus("fchown");
1643
TEMP_FAILURE_RETRY(close(seckey_fd));
1647
if(strcmp(pubkey, PATHDIR "/" PUBKEY) == 0){
1648
int pubkey_fd = open(pubkey, O_RDONLY);
1649
if(pubkey_fd == -1){
1650
perror_plus("open");
1652
ret = (int)TEMP_FAILURE_RETRY(fstat(pubkey_fd, &st));
1654
perror_plus("fstat");
1656
if(S_ISREG(st.st_mode) and st.st_uid == 0 and st.st_gid == 0){
1657
ret = fchown(pubkey_fd, uid, gid);
1659
perror_plus("fchown");
1663
TEMP_FAILURE_RETRY(close(pubkey_fd));
1667
/* Lower privileges */
1671
perror_plus("seteuid");
1675
/* Find network hooks and run them */
1677
struct dirent **direntries;
1678
struct dirent *direntry;
1679
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1682
perror_plus("scandir");
1718
if(strcmp(seckey, PATHDIR "/" SECKEY) == 0){
1719
int seckey_fd = open(seckey, O_RDONLY);
1720
if(seckey_fd == -1){
1721
perror_plus("open");
1723
ret = (int)TEMP_FAILURE_RETRY(fstat(seckey_fd, &st));
1725
perror_plus("fstat");
1727
if(S_ISREG(st.st_mode)
1728
and st.st_uid == 0 and st.st_gid == 0){
1729
ret = fchown(seckey_fd, uid, gid);
1731
perror_plus("fchown");
1735
TEMP_FAILURE_RETRY(close(seckey_fd));
1739
if(strcmp(pubkey, PATHDIR "/" PUBKEY) == 0){
1740
int pubkey_fd = open(pubkey, O_RDONLY);
1741
if(pubkey_fd == -1){
1742
perror_plus("open");
1744
ret = (int)TEMP_FAILURE_RETRY(fstat(pubkey_fd, &st));
1746
perror_plus("fstat");
1748
if(S_ISREG(st.st_mode)
1749
and st.st_uid == 0 and st.st_gid == 0){
1750
ret = fchown(pubkey_fd, uid, gid);
1752
perror_plus("fchown");
1756
TEMP_FAILURE_RETRY(close(pubkey_fd));
1760
/* Lower privileges */
1764
perror_plus("seteuid");
1684
int devnull = open("/dev/null", O_RDONLY);
1685
for(int i = 0; i < numhooks; i++){
1686
direntry = direntries[0];
1687
char *fullname = NULL;
1688
ret = asprintf(&fullname, "%s/%s", hookdir, direntry->d_name);
1690
perror_plus("asprintf");
1693
pid_t hook_pid = fork();
1696
dup2(devnull, STDIN_FILENO);
1698
dup2(STDERR_FILENO, STDOUT_FILENO);
1699
ret = setenv("MANDOSNETHOOKDIR", hookdir, 1);
1701
perror_plus("setenv");
1704
ret = setenv("DEVICE", interface, 1);
1706
perror_plus("setenv");
1709
ret = setenv("VERBOSE", debug ? "1" : "0", 1);
1711
perror_plus("setenv");
1714
ret = setenv("MODE", "start", 1);
1716
perror_plus("setenv");
1720
ret = asprintf(&delaystring, "%f", delay);
1722
perror_plus("asprintf");
1725
ret = setenv("DELAY", delaystring, 1);
1728
perror_plus("setenv");
1732
ret = execl(fullname, direntry->d_name, "start", NULL);
1733
perror_plus("execl");
1736
if(TEMP_FAILURE_RETRY(waitpid(hook_pid, &status, 0)) == -1){
1737
perror_plus("waitpid");
1741
if(WIFEXITED(status)){
1742
if(WEXITSTATUS(status) != 0){
1743
fprintf(stderr, "Mandos plugin mandos-client: "
1744
"Warning: network hook \"%s\" exited"
1745
" with status %d\n", direntry->d_name,
1746
WEXITSTATUS(status));
1750
} else if(WIFSIGNALED(status)){
1751
fprintf(stderr, "Mandos plugin mandos-client: "
1752
"Warning: network hook \"%s\" died by"
1753
" signal %d\n", direntry->d_name,
1758
fprintf(stderr, "Mandos plugin mandos-client: "
1759
"Warning: network hook \"%s\" crashed\n",
1769
/* Run network hooks */
1770
if(not run_network_hooks("start", interface, delay)){
1775
1775
avahi_set_log_function(empty_log);
2178
2195
/* Run the main loop */
2181
fprintf_plus(stderr, "Starting Avahi loop search\n");
2198
fprintf(stderr, "Mandos plugin mandos-client: "
2199
"Starting Avahi loop search\n");
2184
2202
ret = avahi_loop_with_timeout(mc.simple_poll,
2185
2203
(int)(retry_interval * 1000));
2187
fprintf_plus(stderr, "avahi_loop_with_timeout exited %s\n",
2188
(ret == 0) ? "successfully" : "with error");
2205
fprintf(stderr, "Mandos plugin mandos-client: "
2206
"avahi_loop_with_timeout exited %s\n",
2207
(ret == 0) ? "successfully" : "with error");
2194
fprintf_plus(stderr, "%s exiting\n", argv[0]);
2213
fprintf(stderr, "Mandos plugin mandos-client: "
2214
"%s exiting\n", argv[0]);
2197
2217
/* Cleanup things */