Add tests for join/invite errors
[tinc] / src / invitation.c
index c008be2..a95a324 100644 (file)
@@ -35,6 +35,7 @@
 #include "utils.h"
 #include "xalloc.h"
 #include "random.h"
+#include "pidfile.h"
 
 #include "ed25519/sha512.h"
 
@@ -80,8 +81,10 @@ static void scan_for_hostname(const char *filename, char **hostname, char **port
                p[strcspn(p, "\t ")] = 0;
 
                if(!*port && !strcasecmp(line, "Port")) {
+                       free(*port);
                        *port = xstrdup(q);
                } else if(!*hostname && !strcasecmp(line, "Address")) {
+                       free(*hostname);
                        *hostname = xstrdup(q);
 
                        if(*p) {
@@ -98,7 +101,7 @@ static void scan_for_hostname(const char *filename, char **hostname, char **port
        fclose(f);
 }
 
-static char *get_my_hostname(void) {
+static bool get_my_hostname(char **out_address, char **out_port) {
        char *hostname = NULL;
        char *port = NULL;
        char *hostport = NULL;
@@ -115,6 +118,19 @@ static char *get_my_hostname(void) {
        free(name);
        name = NULL;
 
+       if(!port || (is_decimal(port) && atoi(port) == 0)) {
+               pidfile_t *pidfile = read_pidfile();
+
+               if(pidfile) {
+                       free(port);
+                       port = xstrdup(pidfile->port);
+                       free(pidfile);
+               } else {
+                       fprintf(stderr, "tincd is using a dynamic port and is not running. Please start tincd or set the Port option to a non-zero value.\n");
+                       goto exit;
+               }
+       }
+
        if(hostname) {
                goto done;
        }
@@ -186,7 +202,7 @@ static char *get_my_hostname(void) {
                if(!hostname) {
                        fprintf(stderr, "Could not determine the external address or hostname. Please set Address manually.\n");
                        free(port);
-                       return NULL;
+                       return false;
                }
 
                goto save;
@@ -205,7 +221,7 @@ again:
                fprintf(stderr, "Error while reading stdin: %s\n", strerror(errno));
                free(hostname);
                free(port);
-               return NULL;
+               return false;
        }
 
        if(!rstrip(line)) {
@@ -257,12 +273,25 @@ done:
                }
        }
 
+exit:
        free(hostname);
+
+       if(hostport && port) {
+               *out_address = hostport;
+               *out_port = port;
+               return true;
+       }
+
+       free(hostport);
        free(port);
-       return hostport;
+       return false;
 }
 
-static bool fcopy(FILE *out, const char *filename) {
+// Copy host configuration file, replacing Port with the value passed here. Host
+// configs may contain this clause: `Port = 0`, which means 'ask the operating
+// system to allocate any available port'. This obviously won't do for invitation
+// files, so replace it with an actual port we've obtained previously.
+static bool copy_config_replacing_port(FILE *out, const char *filename, const char *port) {
        FILE *in = fopen(filename, "r");
 
        if(!in) {
@@ -270,23 +299,45 @@ static bool fcopy(FILE *out, const char *filename) {
                return false;
        }
 
-       char buf[1024];
-       size_t len;
+       char line[1024];
+
+       while(fgets(line, sizeof(line), in)) {
+               const char *var_beg = line + strspn(line, "\t ");
+               const char *var_end = var_beg + strcspn(var_beg, "\t ");
 
-       while((len = fread(buf, 1, sizeof(buf), in))) {
-               fwrite(buf, len, 1, out);
+               // Check the name of the variable we've read. If it's Port, replace it with
+               // a port we'll use in invitation URL. Otherwise, just copy the line.
+               if(var_end > var_beg && !strncasecmp(var_beg, "Port", var_end - var_beg)) {
+                       fprintf(out, "Port = %s\n", port);
+               } else {
+                       fprintf(out, "%s", line);
+               }
        }
 
+       memzero(line, sizeof(line));
        fclose(in);
        return true;
 }
 
+static bool append_host_config(FILE *f, const char *nodename, const char *port) {
+       char path[PATH_MAX];
+       snprintf(path, sizeof(path), "%s" SLASH "hosts" SLASH "%s", confbase, nodename);
+       bool success = copy_config_replacing_port(f, path, port);
+       fclose(f);
+       return success;
+}
+
 int cmd_invite(int argc, char *argv[]) {
        if(argc < 2) {
                fprintf(stderr, "Not enough arguments!\n");
                return 1;
        }
 
+       if(argc > 2) {
+               fprintf(stderr, "Too many arguments!\n");
+               return 1;
+       }
+
        // Check validity of the new node's name
        if(!check_id(argv[1])) {
                fprintf(stderr, "Invalid name for node.\n");
@@ -476,6 +527,7 @@ int cmd_invite(int argc, char *argv[]) {
        int ifd = open(filename, O_RDWR | O_CREAT | O_EXCL, 0600);
 
        if(!ifd) {
+               memzero(cookie, sizeof(cookie));
                fprintf(stderr, "Could not create invitation file %s: %s\n", filename, strerror(errno));
                return 1;
        }
@@ -487,7 +539,20 @@ int cmd_invite(int argc, char *argv[]) {
        }
 
        // Get the local address
-       char *address = get_my_hostname();
+       char *address = NULL;
+       char *port = NULL;
+
+       if(!get_my_hostname(&address, &port)) {
+               memzero(cookie, sizeof(cookie));
+               return 1;
+       }
+
+       // Create an URL from the local address, key hash and cookie
+       char *url;
+       xasprintf(&url, "%s/%s%s", address, hash, cookie);
+
+       memzero(cookie, sizeof(cookie));
+       free(address);
 
        // Fill in the details.
        fprintf(f, "Name = %s\n", argv[1]);
@@ -522,14 +587,14 @@ int cmd_invite(int argc, char *argv[]) {
        fprintf(f, "#---------------------------------------------------------------#\n");
        fprintf(f, "Name = %s\n", myname);
 
-       char filename2[PATH_MAX];
-       snprintf(filename2, sizeof(filename2), "%s" SLASH "hosts" SLASH "%s", confbase, myname);
-       fcopy(f, filename2);
-       fclose(f);
+       bool appended = append_host_config(f, myname, port);
+       free(port);
 
-       // Create an URL from the local address, key hash and cookie
-       char *url;
-       xasprintf(&url, "%s/%s%s", address, hash, cookie);
+       if(!appended) {
+               fprintf(stderr, "Could not append my config to invitation file: %s.\n", strerror(errno));
+               free_string(url);
+               return 1;
+       }
 
        // Call the inviation-created script
        environment_t env;
@@ -541,8 +606,7 @@ int cmd_invite(int argc, char *argv[]) {
        environment_exit(&env);
 
        puts(url);
-       free(url);
-       free(address);
+       free_string(url);
 
        return 0;
 }
@@ -614,7 +678,7 @@ static char *get_value(const char *data, const char *var) {
 }
 
 static char *grep(const char *data, const char *var) {
-       static char value[1024];
+       char value[1024];
 
        const char *p = data;
        size_t varlen = strlen(var);
@@ -654,7 +718,7 @@ static char *grep(const char *data, const char *var) {
 
        memcpy(value, p, e - p);
        value[e - p] = 0;
-       return value;
+       return xstrdup(value);
 }
 
 static bool finalize_join(void) {
@@ -671,11 +735,15 @@ static bool finalize_join(void) {
        }
 
        if(!netname) {
-               netname = xstrdup(grep(data, "NetName"));
+               char *net = grep(data, "NetName");
 
-               if(netname && !check_netname(netname, true)) {
-                       fprintf(stderr, "Unsafe NetName found in invitation!\n");
-                       return false;
+               if(net) {
+                       netname = net;
+
+                       if(!check_netname(netname, true)) {
+                               fprintf(stderr, "Unsafe NetName found in invitation!\n");
+                               return false;
+                       }
                }
        }
 
@@ -914,9 +982,9 @@ make_names:
                return false;
        }
 
-       char *b64key = ecdsa_get_base64_public_key(key);
+       char *b64_pubkey = ecdsa_get_base64_public_key(key);
 
-       if(!b64key) {
+       if(!b64_pubkey) {
                return false;
        }
 
@@ -936,10 +1004,10 @@ make_names:
 
        fclose(f);
 
-       fprintf(fh, "Ed25519PublicKey = %s\n", b64key);
+       fprintf(fh, "Ed25519PublicKey = %s\n", b64_pubkey);
 
-       sptps_send_record(&sptps, 1, b64key, strlen(b64key));
-       free(b64key);
+       sptps_send_record(&sptps, 1, b64_pubkey, strlen(b64_pubkey));
+       free(b64_pubkey);
        ecdsa_free(key);
 
 #ifndef DISABLE_LEGACY
@@ -1180,7 +1248,7 @@ int cmd_join(int argc, char *argv[]) {
 
                if(!fgets(line, sizeof(line), stdin)) {
                        fprintf(stderr, "Error while reading stdin: %s\n", strerror(errno));
-                       return false;
+                       return 1;
                }
 
                invitation = line;
@@ -1241,13 +1309,13 @@ int cmd_join(int argc, char *argv[]) {
                return 1;
        }
 
-       char *b64key = ecdsa_get_base64_public_key(key);
+       char *b64_pubkey = ecdsa_get_base64_public_key(key);
 
        // Connect to the tinc daemon mentioned in the URL.
        struct addrinfo *ai = str2addrinfo(address, port, SOCK_STREAM);
 
        if(!ai) {
-               free(b64key);
+               free(b64_pubkey);
                ecdsa_free(key);
                return 1;
        }
@@ -1262,7 +1330,7 @@ next:
 
                if(!aip) {
                        freeaddrinfo(ai);
-                       free(b64key);
+                       free(b64_pubkey);
                        ecdsa_free(key);
                        return 1;
                }
@@ -1288,13 +1356,13 @@ next:
        fprintf(stderr, "Connected to %s port %s...\n", address, port);
 
        // Tell him we have an invitation, and give him our throw-away key.
-       ssize_t len = snprintf(line, sizeof(line), "0 ?%s %d.%d\n", b64key, PROT_MAJOR, PROT_MINOR);
+       ssize_t len = snprintf(line, sizeof(line), "0 ?%s %d.%d\n", b64_pubkey, PROT_MAJOR, PROT_MINOR);
 
        if(len <= 0 || (size_t)len >= sizeof(line)) {
                abort();
        }
 
-       if(!sendline(sock, "0 ?%s %d.%d", b64key, PROT_MAJOR, 1)) {
+       if(!sendline(sock, "0 ?%s %d.%d", b64_pubkey, PROT_MAJOR, 1)) {
                fprintf(stderr, "Error sending request to %s port %s: %s\n", address, port, strerror(errno));
                closesocket(sock);
                goto next;
@@ -1313,8 +1381,8 @@ next:
        ai = NULL;
        aip = NULL;
 
-       free(b64key);
-       b64key = NULL;
+       free(b64_pubkey);
+       b64_pubkey = NULL;
 
        // Check if the hash of the key he gave us matches the hash in the URL.
        char *fingerprint = line + 2;