264
254
rc = gpgme_data_new_from_fd(&pgp_data, fd);
265
255
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));
256
fprintf(stderr, "Mandos plugin mandos-client: "
257
"bad gpgme_data_new_from_fd: %s: %s\n",
258
gpgme_strsource(rc), gpgme_strerror(rc));
271
262
rc = gpgme_op_import(mc.ctx, pgp_data);
272
263
if(rc != GPG_ERR_NO_ERROR){
273
fprintf_plus(stderr, "bad gpgme_op_import: %s: %s\n",
274
gpgme_strsource(rc), gpgme_strerror(rc));
264
fprintf(stderr, "Mandos plugin mandos-client: "
265
"bad gpgme_op_import: %s: %s\n",
266
gpgme_strsource(rc), gpgme_strerror(rc));
287
fprintf_plus(stderr, "Initializing GPGME\n");
279
fprintf(stderr, "Mandos plugin mandos-client: "
280
"Initializing GPGME\n");
291
284
gpgme_check_version(NULL);
292
285
rc = gpgme_engine_check_version(GPGME_PROTOCOL_OpenPGP);
293
286
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));
287
fprintf(stderr, "Mandos plugin mandos-client: "
288
"bad gpgme_engine_check_version: %s: %s\n",
289
gpgme_strsource(rc), gpgme_strerror(rc));
299
293
/* Set GPGME home directory for the OpenPGP engine only */
300
294
rc = gpgme_get_engine_info(&engine_info);
301
295
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));
296
fprintf(stderr, "Mandos plugin mandos-client: "
297
"bad gpgme_get_engine_info: %s: %s\n",
298
gpgme_strsource(rc), gpgme_strerror(rc));
306
301
while(engine_info != NULL){
312
307
engine_info = engine_info->next;
314
309
if(engine_info == NULL){
315
fprintf_plus(stderr, "Could not set GPGME home dir to %s\n",
310
fprintf(stderr, "Mandos plugin mandos-client: "
311
"Could not set GPGME home dir to %s\n", tempdir);
320
315
/* Create new GPGME "context" */
321
316
rc = gpgme_new(&(mc.ctx));
322
317
if(rc != GPG_ERR_NO_ERROR){
323
fprintf_plus(stderr, "Mandos plugin mandos-client: "
324
"bad gpgme_new: %s: %s\n", gpgme_strsource(rc),
318
fprintf(stderr, "Mandos plugin mandos-client: "
319
"bad gpgme_new: %s: %s\n", gpgme_strsource(rc),
347
342
ssize_t plaintext_length = 0;
350
fprintf_plus(stderr, "Trying to decrypt OpenPGP data\n");
345
fprintf(stderr, "Mandos plugin mandos-client: "
346
"Trying to decrypt OpenPGP data\n");
353
349
/* Create new GPGME data buffer from memory cryptotext */
354
350
rc = gpgme_data_new_from_mem(&dh_crypto, cryptotext, crypto_size,
356
352
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));
353
fprintf(stderr, "Mandos plugin mandos-client: "
354
"bad gpgme_data_new_from_mem: %s: %s\n",
355
gpgme_strsource(rc), gpgme_strerror(rc));
362
359
/* Create new empty GPGME data buffer for the plaintext */
363
360
rc = gpgme_data_new(&dh_plain);
364
361
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));
362
fprintf(stderr, "Mandos plugin mandos-client: "
363
"bad gpgme_data_new: %s: %s\n",
364
gpgme_strsource(rc), gpgme_strerror(rc));
368
365
gpgme_data_release(dh_crypto);
374
371
rc = gpgme_op_decrypt(mc.ctx, dh_crypto, dh_plain);
375
372
if(rc != GPG_ERR_NO_ERROR){
376
fprintf_plus(stderr, "bad gpgme_op_decrypt: %s: %s\n",
377
gpgme_strsource(rc), gpgme_strerror(rc));
373
fprintf(stderr, "Mandos plugin mandos-client: "
374
"bad gpgme_op_decrypt: %s: %s\n",
375
gpgme_strsource(rc), gpgme_strerror(rc));
378
376
plaintext_length = -1;
380
378
gpgme_decrypt_result_t result;
381
379
result = gpgme_op_decrypt_result(mc.ctx);
382
380
if(result == NULL){
383
fprintf_plus(stderr, "gpgme_op_decrypt_result failed\n");
381
fprintf(stderr, "Mandos plugin mandos-client: "
382
"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);
384
fprintf(stderr, "Mandos plugin mandos-client: "
385
"Unsupported algorithm: %s\n",
386
result->unsupported_algorithm);
387
fprintf(stderr, "Mandos plugin mandos-client: "
388
"Wrong key usage: %u\n",
389
result->wrong_key_usage);
389
390
if(result->file_name != NULL){
390
fprintf_plus(stderr, "File name: %s\n", result->file_name);
391
fprintf(stderr, "Mandos plugin mandos-client: "
392
"File name: %s\n", result->file_name);
392
394
gpgme_recipient_t recipient;
393
395
recipient = result->recipients;
394
396
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
397
fprintf(stderr, "Mandos plugin mandos-client: "
398
"Public key algorithm: %s\n",
399
gpgme_pubkey_algo_name(recipient->pubkey_algo));
400
fprintf(stderr, "Mandos plugin mandos-client: "
401
"Key ID: %s\n", recipient->keyid);
402
fprintf(stderr, "Mandos plugin mandos-client: "
403
"Secret key available: %s\n",
404
recipient->status == GPG_ERR_NO_SECKEY
402
406
recipient = recipient->next;
501
508
/* OpenPGP credentials */
502
509
ret = gnutls_certificate_allocate_credentials(&mc.cred);
503
510
if(ret != GNUTLS_E_SUCCESS){
504
fprintf_plus(stderr, "GnuTLS memory error: %s\n",
505
safer_gnutls_strerror(ret));
511
fprintf(stderr, "Mandos plugin mandos-client: "
512
"GnuTLS memory error: %s\n", safer_gnutls_strerror(ret));
506
513
gnutls_global_deinit();
511
fprintf_plus(stderr, "Attempting to use OpenPGP public key %s and"
512
" secret key %s as GnuTLS credentials\n",
518
fprintf(stderr, "Mandos plugin mandos-client: "
519
"Attempting to use OpenPGP public key %s and"
520
" secret key %s as GnuTLS credentials\n", pubkeyfilename,
517
524
ret = gnutls_certificate_set_openpgp_key_file
518
525
(mc.cred, pubkeyfilename, seckeyfilename,
519
526
GNUTLS_OPENPGP_FMT_BASE64);
520
527
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));
529
"Mandos plugin mandos-client: "
530
"Error[%d] while reading the OpenPGP key pair ('%s',"
531
" '%s')\n", ret, pubkeyfilename, seckeyfilename);
532
fprintf(stderr, "Mandos plugin mandos-client: "
533
"The GnuTLS error is: %s\n", safer_gnutls_strerror(ret));
529
537
/* GnuTLS server initialization */
530
538
ret = gnutls_dh_params_init(&mc.dh_params);
531
539
if(ret != GNUTLS_E_SUCCESS){
532
fprintf_plus(stderr, "Error in GnuTLS DH parameter"
533
" initialization: %s\n",
534
safer_gnutls_strerror(ret));
540
fprintf(stderr, "Mandos plugin mandos-client: "
541
"Error in GnuTLS DH parameter initialization:"
542
" %s\n", safer_gnutls_strerror(ret));
537
545
ret = gnutls_dh_params_generate2(mc.dh_params, mc.dh_bits);
538
546
if(ret != GNUTLS_E_SUCCESS){
539
fprintf_plus(stderr, "Error in GnuTLS prime generation: %s\n",
540
safer_gnutls_strerror(ret));
547
fprintf(stderr, "Mandos plugin mandos-client: "
548
"Error in GnuTLS prime generation: %s\n",
549
safer_gnutls_strerror(ret));
729
744
if(if_indextoname((unsigned int)if_index, interface) == NULL){
730
745
perror_plus("if_indextoname");
732
fprintf_plus(stderr, "Connection to: %s%%%s, port %" PRIu16
733
"\n", ip, interface, port);
747
fprintf(stderr, "Mandos plugin mandos-client: "
748
"Connection to: %s%%%s, port %" PRIu16 "\n",
749
ip, interface, port);
736
fprintf_plus(stderr, "Connection to: %s, port %" PRIu16 "\n",
752
fprintf(stderr, "Mandos plugin mandos-client: "
753
"Connection to: %s, port %" PRIu16 "\n", ip, port);
739
755
char addrstr[(INET_ADDRSTRLEN > INET6_ADDRSTRLEN) ?
740
756
INET_ADDRSTRLEN : INET6_ADDRSTRLEN] = "";
1012
1034
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)));
1035
fprintf(stderr, "Mandos plugin mandos-client: "
1036
"(Avahi Resolver) Failed to resolve service '%s'"
1037
" of type '%s' in domain '%s': %s\n", name, type, domain,
1038
avahi_strerror(avahi_server_errno(mc.server)));
1019
1041
case AVAHI_RESOLVER_FOUND:
1021
1043
char ip[AVAHI_ADDRESS_STR_MAX];
1022
1044
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);
1046
fprintf(stderr, "Mandos plugin mandos-client: "
1047
"Mandos server \"%s\" found on %s (%s, %"
1048
PRIdMAX ") on port %" PRIu16 "\n", name, host_name,
1049
ip, (intmax_t)interface, port);
1028
1051
int ret = start_mandos_communication(ip, port, interface,
1029
1052
avahi_proto_to_af(proto));
1075
1099
if(avahi_s_service_resolver_new(mc.server, interface, protocol,
1076
1100
name, type, domain, protocol, 0,
1077
1101
resolve_callback, NULL) == NULL)
1078
fprintf_plus(stderr, "Avahi: Failed to resolve service '%s':"
1080
avahi_strerror(avahi_server_errno(mc.server)));
1102
fprintf(stderr, "Mandos plugin mandos-client: "
1103
"Avahi: Failed to resolve service '%s': %s\n",
1104
name, avahi_strerror(avahi_server_errno(mc.server)));
1083
1107
case AVAHI_BROWSER_REMOVE:
1132
1156
/* Reject the loopback device */
1133
1157
if(ifr->ifr_flags & IFF_LOOPBACK){
1135
fprintf_plus(stderr, "Rejecting loopback interface \"%s\"\n",
1159
fprintf(stderr, "Mandos plugin mandos-client: "
1160
"Rejecting loopback interface \"%s\"\n", ifname);
1140
1164
/* Accept point-to-point devices only if connect_to is specified */
1141
1165
if(connect_to != NULL and (ifr->ifr_flags & IFF_POINTOPOINT)){
1143
fprintf_plus(stderr, "Accepting point-to-point interface"
1144
" \"%s\"\n", ifname);
1167
fprintf(stderr, "Mandos plugin mandos-client: "
1168
"Accepting point-to-point interface \"%s\"\n", ifname);
1148
1172
/* Otherwise, reject non-broadcast-capable devices */
1149
1173
if(not (ifr->ifr_flags & IFF_BROADCAST)){
1151
fprintf_plus(stderr, "Rejecting non-broadcast interface"
1152
" \"%s\"\n", ifname);
1175
fprintf(stderr, "Mandos plugin mandos-client: "
1176
"Rejecting non-broadcast interface \"%s\"\n", ifname);
1156
1180
/* Reject non-ARP interfaces (including dummy interfaces) */
1157
1181
if(ifr->ifr_flags & IFF_NOARP){
1159
fprintf_plus(stderr, "Rejecting non-ARP interface \"%s\"\n",
1183
fprintf(stderr, "Mandos plugin mandos-client: "
1184
"Rejecting non-ARP interface \"%s\"\n", ifname);
1165
1189
/* Accept this device */
1167
fprintf_plus(stderr, "Interface \"%s\" is good\n", ifname);
1191
fprintf(stderr, "Mandos plugin mandos-client: "
1192
"Interface \"%s\" is good\n", ifname);
1289
1319
if(not (S_ISREG(st.st_mode))){
1290
1320
/* Not a regular file */
1292
fprintf_plus(stderr, "Ignoring hook \"%s\" - not a file\n",
1322
fprintf(stderr, "Mandos plugin mandos-client: "
1323
"Ignoring hook \"%s\" - not a file\n",
1297
1328
if(not (st.st_mode & (S_IXUSR | S_IXGRP | S_IXOTH))){
1298
1329
/* Not executable */
1300
fprintf_plus(stderr, "Ignoring hook \"%s\" - not executable\n",
1331
fprintf(stderr, "Mandos plugin mandos-client: "
1332
"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
1413
int main(int argc, char *argv[]){
1512
1414
AvahiSServiceBrowser *sb = NULL;
1707
1608
/* Work around Debian bug #633582:
1708
1609
<http://bugs.debian.org/633582> */
1710
1612
/* Re-raise priviliges */
1712
1614
ret = seteuid(0);
1714
1616
perror_plus("seteuid");
1619
if(strcmp(seckey, PATHDIR "/" SECKEY) == 0){
1620
int seckey_fd = open(seckey, O_RDONLY);
1621
if(seckey_fd == -1){
1622
perror_plus("open");
1624
ret = (int)TEMP_FAILURE_RETRY(fstat(seckey_fd, &st));
1626
perror_plus("fstat");
1628
if(S_ISREG(st.st_mode) and st.st_uid == 0 and st.st_gid == 0){
1629
ret = fchown(seckey_fd, uid, gid);
1631
perror_plus("fchown");
1635
TEMP_FAILURE_RETRY(close(seckey_fd));
1639
if(strcmp(pubkey, PATHDIR "/" PUBKEY) == 0){
1640
int pubkey_fd = open(pubkey, O_RDONLY);
1641
if(pubkey_fd == -1){
1642
perror_plus("open");
1644
ret = (int)TEMP_FAILURE_RETRY(fstat(pubkey_fd, &st));
1646
perror_plus("fstat");
1648
if(S_ISREG(st.st_mode) and st.st_uid == 0 and st.st_gid == 0){
1649
ret = fchown(pubkey_fd, uid, gid);
1651
perror_plus("fchown");
1655
TEMP_FAILURE_RETRY(close(pubkey_fd));
1659
/* Lower privileges */
1663
perror_plus("seteuid");
1667
/* Find network hooks and run them */
1669
struct dirent **direntries;
1670
struct dirent *direntry;
1671
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1674
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");
1676
int devnull = open("/dev/null", O_RDONLY);
1677
for(int i = 0; i < numhooks; i++){
1678
direntry = direntries[0];
1679
char *fullname = NULL;
1680
ret = asprintf(&fullname, "%s/%s", hookdir, direntry->d_name);
1682
perror_plus("asprintf");
1685
pid_t hook_pid = fork();
1688
dup2(devnull, STDIN_FILENO);
1690
dup2(STDERR_FILENO, STDOUT_FILENO);
1691
ret = setenv("MANDOSNETHOOKDIR", hookdir, 1);
1693
perror_plus("setenv");
1696
ret = setenv("DEVICE", interface, 1);
1698
perror_plus("setenv");
1701
ret = setenv("VERBOSE", debug ? "1" : "0", 1);
1703
perror_plus("setenv");
1706
ret = setenv("MODE", "start", 1);
1708
perror_plus("setenv");
1712
ret = asprintf(&delaystring, "%f", delay);
1714
perror_plus("asprintf");
1717
ret = setenv("DELAY", delaystring, 1);
1720
perror_plus("setenv");
1724
ret = execl(fullname, direntry->d_name, "start", NULL);
1725
perror_plus("execl");
1728
if(TEMP_FAILURE_RETRY(waitpid(hook_pid, &status, 0)) == -1){
1729
perror_plus("waitpid");
1733
if(WIFEXITED(status)){
1734
if(WEXITSTATUS(status) != 0){
1735
fprintf(stderr, "Mandos plugin mandos-client: "
1736
"Warning: network hook \"%s\" exited"
1737
" with status %d\n", direntry->d_name,
1738
WEXITSTATUS(status));
1742
} else if(WIFSIGNALED(status)){
1743
fprintf(stderr, "Mandos plugin mandos-client: "
1744
"Warning: network hook \"%s\" died by"
1745
" signal %d\n", direntry->d_name,
1750
fprintf(stderr, "Mandos plugin mandos-client: "
1751
"Warning: network hook \"%s\" crashed\n",
1769
/* Run network hooks */
1770
if(not run_network_hooks("start", interface, delay)){
1775
1767
avahi_set_log_function(empty_log);
2178
2187
/* Run the main loop */
2181
fprintf_plus(stderr, "Starting Avahi loop search\n");
2190
fprintf(stderr, "Mandos plugin mandos-client: "
2191
"Starting Avahi loop search\n");
2184
2194
ret = avahi_loop_with_timeout(mc.simple_poll,
2185
2195
(int)(retry_interval * 1000));
2187
fprintf_plus(stderr, "avahi_loop_with_timeout exited %s\n",
2188
(ret == 0) ? "successfully" : "with error");
2197
fprintf(stderr, "Mandos plugin mandos-client: "
2198
"avahi_loop_with_timeout exited %s\n",
2199
(ret == 0) ? "successfully" : "with error");
2194
fprintf_plus(stderr, "%s exiting\n", argv[0]);
2205
fprintf(stderr, "Mandos plugin mandos-client: "
2206
"%s exiting\n", argv[0]);
2197
2209
/* Cleanup things */