824
821
int main(int argc, char *argv[]){
825
AvahiSServiceBrowser *sb = NULL;
830
int exitcode = EXIT_SUCCESS;
831
const char *interface = "eth0";
832
struct ifreq network;
836
char *connect_to = NULL;
837
char tempdir[] = "/tmp/mandosXXXXXX";
838
bool tempdir_created = false;
839
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
840
const char *seckey = PATHDIR "/" SECKEY;
841
const char *pubkey = PATHDIR "/" PUBKEY;
843
mandos_context mc = { .simple_poll = NULL, .server = NULL,
844
.dh_bits = 1024, .priority = "SECURE256"
845
":!CTYPE-X.509:+CTYPE-OPENPGP" };
846
bool gnutls_initialized = false;
847
bool gpgme_initialized = false;
851
struct argp_option options[] = {
852
{ .name = "debug", .key = 128,
853
.doc = "Debug mode", .group = 3 },
854
{ .name = "connect", .key = 'c',
855
.arg = "ADDRESS:PORT",
856
.doc = "Connect directly to a specific Mandos server",
858
{ .name = "interface", .key = 'i',
860
.doc = "Interface that will be used to search for Mandos"
863
{ .name = "seckey", .key = 's',
865
.doc = "OpenPGP secret key file base name",
867
{ .name = "pubkey", .key = 'p',
869
.doc = "OpenPGP public key file base name",
871
{ .name = "dh-bits", .key = 129,
873
.doc = "Bit length of the prime number used in the"
874
" Diffie-Hellman key exchange",
876
{ .name = "priority", .key = 130,
878
.doc = "GnuTLS priority string for the TLS handshake",
880
{ .name = "delay", .key = 131,
882
.doc = "Maximum delay to wait for interface startup",
887
error_t parse_opt(int key, char *arg,
888
struct argp_state *state){
890
case 128: /* --debug */
893
case 'c': /* --connect */
896
case 'i': /* --interface */
899
case 's': /* --seckey */
902
case 'p': /* --pubkey */
905
case 129: /* --dh-bits */
906
ret = sscanf(arg, "%" SCNdMAX "%n", &tmpmax, &numchars);
907
if(ret < 1 or tmpmax != (typeof(mc.dh_bits))tmpmax
908
or arg[numchars] != '\0'){
909
fprintf(stderr, "Bad number of DH bits\n");
912
mc.dh_bits = (typeof(mc.dh_bits))tmpmax;
914
case 130: /* --priority */
917
case 131: /* --delay */
918
ret = sscanf(arg, "%lf%n", &delay, &numchars);
919
if(ret < 1 or arg[numchars] != '\0'){
920
fprintf(stderr, "Bad delay\n");
929
return ARGP_ERR_UNKNOWN;
934
struct argp argp = { .options = options, .parser = parse_opt,
936
.doc = "Mandos client -- Get and decrypt"
937
" passwords from a Mandos server" };
938
ret = argp_parse(&argp, argc, argv, 0, 0, NULL);
939
if(ret == ARGP_ERR_UNKNOWN){
940
fprintf(stderr, "Unknown error while parsing arguments\n");
941
exitcode = EXIT_FAILURE;
946
/* If the interface is down, bring it up */
949
/* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
950
messages to mess up the prompt */
951
ret = klogctl(8, NULL, 5);
957
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
960
exitcode = EXIT_FAILURE;
962
ret = klogctl(7, NULL, 0);
969
strcpy(network.ifr_name, interface);
970
ret = ioctl(sd, SIOCGIFFLAGS, &network);
972
perror("ioctl SIOCGIFFLAGS");
974
ret = klogctl(7, NULL, 0);
979
exitcode = EXIT_FAILURE;
982
if((network.ifr_flags & IFF_UP) == 0){
983
network.ifr_flags |= IFF_UP;
984
ret = ioctl(sd, SIOCSIFFLAGS, &network);
986
perror("ioctl SIOCSIFFLAGS");
987
exitcode = EXIT_FAILURE;
989
ret = klogctl(7, NULL, 0);
997
/* sleep checking until interface is running */
998
for(int i=0; i < delay * 4; i++){
822
AvahiSServiceBrowser *sb = NULL;
827
int exitcode = EXIT_SUCCESS;
828
const char *interface = "eth0";
829
struct ifreq network;
833
char *connect_to = NULL;
834
char tempdir[] = "/tmp/mandosXXXXXX";
835
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
836
const char *seckey = PATHDIR "/" SECKEY;
837
const char *pubkey = PATHDIR "/" PUBKEY;
839
mandos_context mc = { .simple_poll = NULL, .server = NULL,
840
.dh_bits = 1024, .priority = "SECURE256"
841
":!CTYPE-X.509:+CTYPE-OPENPGP" };
842
bool gnutls_initialized = false;
843
bool gpgme_initialized = false;
846
struct argp_option options[] = {
847
{ .name = "debug", .key = 128,
848
.doc = "Debug mode", .group = 3 },
849
{ .name = "connect", .key = 'c',
850
.arg = "ADDRESS:PORT",
851
.doc = "Connect directly to a specific Mandos server",
853
{ .name = "interface", .key = 'i',
855
.doc = "Interface that will be used to search for Mandos"
858
{ .name = "seckey", .key = 's',
860
.doc = "OpenPGP secret key file base name",
862
{ .name = "pubkey", .key = 'p',
864
.doc = "OpenPGP public key file base name",
866
{ .name = "dh-bits", .key = 129,
868
.doc = "Bit length of the prime number used in the"
869
" Diffie-Hellman key exchange",
871
{ .name = "priority", .key = 130,
873
.doc = "GnuTLS priority string for the TLS handshake",
878
error_t parse_opt(int key, char *arg,
879
struct argp_state *state) {
881
case 128: /* --debug */
884
case 'c': /* --connect */
887
case 'i': /* --interface */
890
case 's': /* --seckey */
893
case 'p': /* --pubkey */
896
case 129: /* --dh-bits */
897
ret = sscanf(arg, "%" SCNdMAX "%n", &tmpmax, &numchars);
898
if(ret < 1 or tmpmax != (typeof(mc.dh_bits))tmpmax
899
or arg[numchars] != '\0'){
900
fprintf(stderr, "Bad number of DH bits\n");
903
mc.dh_bits = (typeof(mc.dh_bits))tmpmax;
905
case 130: /* --priority */
913
return ARGP_ERR_UNKNOWN;
918
struct argp argp = { .options = options, .parser = parse_opt,
920
.doc = "Mandos client -- Get and decrypt"
921
" passwords from a Mandos server" };
922
ret = argp_parse(&argp, argc, argv, 0, 0, NULL);
923
if(ret == ARGP_ERR_UNKNOWN){
924
fprintf(stderr, "Unknown error while parsing arguments\n");
925
exitcode = EXIT_FAILURE;
930
/* If the interface is down, bring it up */
932
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
935
exitcode = EXIT_FAILURE;
938
strcpy(network.ifr_name, interface);
999
939
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1001
941
perror("ioctl SIOCGIFFLAGS");
1002
} else if(network.ifr_flags & IFF_RUNNING){
1005
struct timespec sleeptime = { .tv_nsec = 250000000 };
1006
ret = nanosleep(&sleeptime, NULL);
1007
if(ret == -1 and errno != EINTR){
1008
perror("nanosleep");
1011
ret = (int)TEMP_FAILURE_RETRY(close(sd));
1016
/* Restores kernel loglevel to default */
1017
ret = klogctl(7, NULL, 0);
1037
ret = init_gnutls_global(&mc, pubkey, seckey);
1039
fprintf(stderr, "init_gnutls_global failed\n");
1040
exitcode = EXIT_FAILURE;
1043
gnutls_initialized = true;
1046
if(mkdtemp(tempdir) == NULL){
1050
tempdir_created = true;
1052
if(not init_gpgme(&mc, pubkey, seckey, tempdir)){
1053
fprintf(stderr, "init_gpgme failed\n");
1054
exitcode = EXIT_FAILURE;
1057
gpgme_initialized = true;
1060
if_index = (AvahiIfIndex) if_nametoindex(interface);
1062
fprintf(stderr, "No such interface: \"%s\"\n", interface);
1063
exitcode = EXIT_FAILURE;
1067
if(connect_to != NULL){
1068
/* Connect directly, do not use Zeroconf */
1069
/* (Mainly meant for debugging) */
1070
char *address = strrchr(connect_to, ':');
1071
if(address == NULL){
1072
fprintf(stderr, "No colon in address\n");
1073
exitcode = EXIT_FAILURE;
1077
ret = sscanf(address+1, "%" SCNdMAX "%n", &tmpmax, &numchars);
1078
if(ret < 1 or tmpmax != (uint16_t)tmpmax
1079
or address[numchars+1] != '\0'){
1080
fprintf(stderr, "Bad port number\n");
1081
exitcode = EXIT_FAILURE;
1084
port = (uint16_t)tmpmax;
1086
address = connect_to;
1087
ret = start_mandos_communication(address, port, if_index, &mc);
1089
exitcode = EXIT_FAILURE;
1091
exitcode = EXIT_SUCCESS;
1097
avahi_set_log_function(empty_log);
1100
/* Initialize the pseudo-RNG for Avahi */
1101
srand((unsigned int) time(NULL));
1103
/* Allocate main Avahi loop object */
1104
mc.simple_poll = avahi_simple_poll_new();
1105
if(mc.simple_poll == NULL){
1106
fprintf(stderr, "Avahi: Failed to create simple poll object.\n");
1107
exitcode = EXIT_FAILURE;
1112
AvahiServerConfig config;
1113
/* Do not publish any local Zeroconf records */
1114
avahi_server_config_init(&config);
1115
config.publish_hinfo = 0;
1116
config.publish_addresses = 0;
1117
config.publish_workstation = 0;
1118
config.publish_domain = 0;
1120
/* Allocate a new server */
1121
mc.server = avahi_server_new(avahi_simple_poll_get
1122
(mc.simple_poll), &config, NULL,
1125
/* Free the Avahi configuration data */
1126
avahi_server_config_free(&config);
1129
/* Check if creating the Avahi server object succeeded */
1130
if(mc.server == NULL){
1131
fprintf(stderr, "Failed to create Avahi server: %s\n",
1132
avahi_strerror(error));
1133
exitcode = EXIT_FAILURE;
1137
/* Create the Avahi service browser */
1138
sb = avahi_s_service_browser_new(mc.server, if_index,
1139
AVAHI_PROTO_INET6, "_mandos._tcp",
1140
NULL, 0, browse_callback, &mc);
1142
fprintf(stderr, "Failed to create service browser: %s\n",
1143
avahi_strerror(avahi_server_errno(mc.server)));
1144
exitcode = EXIT_FAILURE;
1148
/* Run the main loop */
1151
fprintf(stderr, "Starting Avahi loop search\n");
1154
avahi_simple_poll_loop(mc.simple_poll);
942
exitcode = EXIT_FAILURE;
945
if((network.ifr_flags & IFF_UP) == 0){
946
network.ifr_flags |= IFF_UP;
947
ret = ioctl(sd, SIOCSIFFLAGS, &network);
949
perror("ioctl SIOCSIFFLAGS");
950
exitcode = EXIT_FAILURE;
954
ret = (int)TEMP_FAILURE_RETRY(close(sd));
973
ret = init_gnutls_global(&mc, pubkey, seckey);
975
fprintf(stderr, "init_gnutls_global failed\n");
976
exitcode = EXIT_FAILURE;
979
gnutls_initialized = true;
982
if(mkdtemp(tempdir) == NULL){
988
if(not init_gpgme(&mc, pubkey, seckey, tempdir)){
989
fprintf(stderr, "init_gpgme failed\n");
990
exitcode = EXIT_FAILURE;
993
gpgme_initialized = true;
996
if_index = (AvahiIfIndex) if_nametoindex(interface);
998
fprintf(stderr, "No such interface: \"%s\"\n", interface);
1002
if(connect_to != NULL){
1003
/* Connect directly, do not use Zeroconf */
1004
/* (Mainly meant for debugging) */
1005
char *address = strrchr(connect_to, ':');
1006
if(address == NULL){
1007
fprintf(stderr, "No colon in address\n");
1008
exitcode = EXIT_FAILURE;
1012
ret = sscanf(address+1, "%" SCNdMAX "%n", &tmpmax, &numchars);
1013
if(ret < 1 or tmpmax != (uint16_t)tmpmax
1014
or address[numchars+1] != '\0'){
1015
fprintf(stderr, "Bad port number\n");
1016
exitcode = EXIT_FAILURE;
1019
port = (uint16_t)tmpmax;
1021
address = connect_to;
1022
ret = start_mandos_communication(address, port, if_index, &mc);
1024
exitcode = EXIT_FAILURE;
1026
exitcode = EXIT_SUCCESS;
1032
avahi_set_log_function(empty_log);
1035
/* Initialize the pseudo-RNG for Avahi */
1036
srand((unsigned int) time(NULL));
1038
/* Allocate main Avahi loop object */
1039
mc.simple_poll = avahi_simple_poll_new();
1040
if(mc.simple_poll == NULL) {
1041
fprintf(stderr, "Avahi: Failed to create simple poll"
1043
exitcode = EXIT_FAILURE;
1048
AvahiServerConfig config;
1049
/* Do not publish any local Zeroconf records */
1050
avahi_server_config_init(&config);
1051
config.publish_hinfo = 0;
1052
config.publish_addresses = 0;
1053
config.publish_workstation = 0;
1054
config.publish_domain = 0;
1056
/* Allocate a new server */
1057
mc.server = avahi_server_new(avahi_simple_poll_get
1058
(mc.simple_poll), &config, NULL,
1061
/* Free the Avahi configuration data */
1062
avahi_server_config_free(&config);
1065
/* Check if creating the Avahi server object succeeded */
1066
if(mc.server == NULL) {
1067
fprintf(stderr, "Failed to create Avahi server: %s\n",
1068
avahi_strerror(error));
1069
exitcode = EXIT_FAILURE;
1073
/* Create the Avahi service browser */
1074
sb = avahi_s_service_browser_new(mc.server, if_index,
1076
"_mandos._tcp", NULL, 0,
1077
browse_callback, &mc);
1079
fprintf(stderr, "Failed to create service browser: %s\n",
1080
avahi_strerror(avahi_server_errno(mc.server)));
1081
exitcode = EXIT_FAILURE;
1085
/* Run the main loop */
1088
fprintf(stderr, "Starting Avahi loop search\n");
1091
avahi_simple_poll_loop(mc.simple_poll);
1159
fprintf(stderr, "%s exiting\n", argv[0]);
1162
/* Cleanup things */
1164
avahi_s_service_browser_free(sb);
1166
if(mc.server != NULL)
1167
avahi_server_free(mc.server);
1169
if(mc.simple_poll != NULL)
1170
avahi_simple_poll_free(mc.simple_poll);
1172
if(gnutls_initialized){
1173
gnutls_certificate_free_credentials(mc.cred);
1174
gnutls_global_deinit();
1175
gnutls_dh_params_deinit(mc.dh_params);
1178
if(gpgme_initialized){
1179
gpgme_release(mc.ctx);
1182
/* Removes the temp directory used by GPGME */
1183
if(tempdir_created){
1185
struct dirent *direntry;
1186
d = opendir(tempdir);
1188
if(errno != ENOENT){
1193
direntry = readdir(d);
1194
if(direntry == NULL){
1197
/* Skip "." and ".." */
1198
if(direntry->d_name[0] == '.'
1199
and (direntry->d_name[1] == '\0'
1200
or (direntry->d_name[1] == '.'
1201
and direntry->d_name[2] == '\0'))){
1204
char *fullname = NULL;
1205
ret = asprintf(&fullname, "%s/%s", tempdir,
1211
ret = remove(fullname);
1213
fprintf(stderr, "remove(\"%s\"): %s\n", fullname,
1220
ret = rmdir(tempdir);
1221
if(ret == -1 and errno != ENOENT){
1096
fprintf(stderr, "%s exiting\n", argv[0]);
1099
/* Cleanup things */
1101
avahi_s_service_browser_free(sb);
1103
if(mc.server != NULL)
1104
avahi_server_free(mc.server);
1106
if(mc.simple_poll != NULL)
1107
avahi_simple_poll_free(mc.simple_poll);
1109
if(gnutls_initialized){
1110
gnutls_certificate_free_credentials(mc.cred);
1111
gnutls_global_deinit();
1112
gnutls_dh_params_deinit(mc.dh_params);
1115
if(gpgme_initialized){
1116
gpgme_release(mc.ctx);
1119
/* Removes the temp directory used by GPGME */
1120
if(tempdir[0] != '\0'){
1122
struct dirent *direntry;
1123
d = opendir(tempdir);
1125
if(errno != ENOENT){
1130
direntry = readdir(d);
1131
if(direntry == NULL){
1134
/* Skip "." and ".." */
1135
if(direntry->d_name[0] == '.'
1136
and (direntry->d_name[1] == '\0'
1137
or (direntry->d_name[1] == '.'
1138
and direntry->d_name[2] == '\0'))){
1141
char *fullname = NULL;
1142
ret = asprintf(&fullname, "%s/%s", tempdir,
1148
ret = remove(fullname);
1150
fprintf(stderr, "remove(\"%s\"): %s\n", fullname,
1157
ret = rmdir(tempdir);
1158
if(ret == -1 and errno != ENOENT){