Bunch more control plane work, and shelve old UI -- React FTW.

include/ZeroTierOne.h

@@ -524,6 +524,16 @@ typedef struct
 	 * Is path fixed? (i.e. not learned, static)
 	 */
 	int fixed;
+
+	/**
+	 * Is path active?
+	 */
+	int active;
+
+	/**
+	 * Is path preferred?
+	 */
+	int preferred;
 } ZT1_PeerPhysicalPath;
 
 /**
@@ -796,6 +806,9 @@ enum ZT1_ResultCode ZT1_Node_processBackgroundTasks(ZT1_Node *node,uint64_t now,
  * This may generate calls to the port config callback before it returns,
  * or these may be deffered if a netconf is not available yet.
  *
+ * If we are already a member of the network, nothing is done and OK is
+ * returned.
+ *
  * @param node Node instance
  * @param nwid 64-bit ZeroTier network ID
  * @return OK (0) or error code if a fatal error condition has occurred

make-mac.mk

@@ -63,18 +63,18 @@ selftest: $(OBJS) selftest.o
 	$(CXX) $(CXXFLAGS) -o zerotier-selftest selftest.o $(OBJS) $(LIBS)
 	$(STRIP) zerotier-selftest
 
-testnet: $(TESTNET_OBJS) $(OBJS) testnet.o
+#testnet: $(TESTNET_OBJS) $(OBJS) testnet.o
-	$(CXX) $(CXXFLAGS) -o zerotier-testnet testnet.o $(OBJS) $(TESTNET_OBJS) $(LIBS)
+#	$(CXX) $(CXXFLAGS) -o zerotier-testnet testnet.o $(OBJS) $(TESTNET_OBJS) $(LIBS)
-	$(STRIP) zerotier-testnet
+#	$(STRIP) zerotier-testnet
 
 # Requires that ../Qt be symlinked to the Qt root to use for UI build
-mac-ui: FORCE
+#mac-ui: FORCE
-	mkdir -p build-ZeroTierUI-release
+#	mkdir -p build-ZeroTierUI-release
-	cd build-ZeroTierUI-release ; ../../Qt/bin/qmake ../ZeroTierUI/ZeroTierUI.pro ; make -j 4
+#	cd build-ZeroTierUI-release ; ../../Qt/bin/qmake ../ZeroTierUI/ZeroTierUI.pro ; make -j 4
-	strip "build-ZeroTierUI-release/ZeroTier One.app/Contents/MacOS/ZeroTier One"
+#	strip "build-ZeroTierUI-release/ZeroTier One.app/Contents/MacOS/ZeroTier One"
-	find "build-ZeroTierUI-release/ZeroTier One.app" -type f -name '.DS_Store' -print0 | xargs -0 rm -f
+#	find "build-ZeroTierUI-release/ZeroTier One.app" -type f -name '.DS_Store' -print0 | xargs -0 rm -f
-	$(CODESIGN) -f -s $(CODESIGN_CERT) "build-ZeroTierUI-release/ZeroTier One.app"
+#	$(CODESIGN) -f -s $(CODESIGN_CERT) "build-ZeroTierUI-release/ZeroTier One.app"
-	$(CODESIGN) -vvv "build-ZeroTierUI-release/ZeroTier One.app"
+#	$(CODESIGN) -vvv "build-ZeroTierUI-release/ZeroTier One.app"
 
 clean:
 	rm -rf *.dSYM build-* *.o netconf/*.o service/*.o node/*.o osdep/*.o ext/http-parser/*.o ext/lz4/*.o zerotier-* ZeroTierOneInstaller-* "ZeroTier One.zip" "ZeroTier One.dmg"
@@ -82,7 +82,6 @@ clean:
 # For our use -- builds official signed binary, packages in installer and download DMG
 official: FORCE
 	make -j 4 ZT_OFFICIAL_RELEASE=1
-	make mac-ui ZT_OFFICIAL_RELEASE=1
 	./buildinstaller.sh
 	make mac-dmg ZT_OFFICIAL_RELEASE=1
 

node/Node.cpp

@@ -357,12 +357,15 @@ ZT1_PeerList *Node::peers() const
 		p->role = RR->topology->isSupernode(pi->second->address()) ? ZT1_PEER_ROLE_SUPERNODE : ZT1_PEER_ROLE_LEAF;
 
 		std::vector<Path> paths(pi->second->paths());
+		Path *bestPath = pi->second->getBestPath(_now);
 		p->pathCount = 0;
 		for(std::vector<Path>::iterator path(paths.begin());path!=paths.end();++path) {
 			memcpy(&(p->paths[p->pathCount].address),&(path->address()),sizeof(struct sockaddr_storage));
 			p->paths[p->pathCount].lastSend = path->lastSend();
 			p->paths[p->pathCount].lastReceive = path->lastReceived();
 			p->paths[p->pathCount].fixed = path->fixed() ? 1 : 0;
+			p->paths[p->pathCount].active = path->active(_now) ? 1 : 0;
+			p->paths[p->pathCount].preferred = ((bestPath)&&(*path == *bestPath)) ? 1 : 0;
 			++p->pathCount;
 		}
 	}

node/Peer.cpp

@@ -111,7 +111,7 @@ void Peer::received(
 					 * paths without confirming that a bidirectional link is in
 					 * fact present, but any packet that decodes and authenticates
 					 * correctly is considered valid. */
-					TRACE("got non-confirmation packet from unknown path %s(%s), pinging...",_id.address().toString().c_str(),remoteAddr.toString().c_str());
+					TRACE("got non-confirmation %s from unknown path %s(%s), pinging...",Packet::verbString(verb),_id.address().toString().c_str(),remoteAddr.toString().c_str());
 					attemptToContactAt(RR,remoteAddr,linkDesperation,now);
 				}
 			}

service/ControlPlane.cpp

@@ -36,6 +36,8 @@
 #include "../node/Node.hpp"
 #include "../node/Utils.hpp"
 
+#define ZT_BUILD_IN_WEB_UI
+
 namespace ZeroTier {
 
 static std::string _jsonEscape(const char *s)
@@ -102,7 +104,12 @@ static std::string _jsonEnumerate(const ZT1_PeerPhysicalPath *pp,unsigned int co
 			buf.push_back(',');
 		buf.append("{\"address\":\"");
 		buf.append(_jsonEscape(reinterpret_cast<const InetAddress *>(&(pp[i].address))->toString()));
-		Utils::snprintf(tmp,sizeof(tmp),"\",\"lastSend\":%llu,\"lastReceive\":%llu,\"fixed\":%s}",pp[i].lastSend,pp[i].lastReceive,(pp[i].fixed == 0) ? "falase" : "true");
+		Utils::snprintf(tmp,sizeof(tmp),"\",\"lastSend\":%llu,\"lastReceive\":%llu,\"fixed\":%s,\"active\":%s,\"preferred\":%s}",
+			pp[i].lastSend,
+			pp[i].lastReceive,
+			(pp[i].fixed == 0) ? "false" : "true",
+			(pp[i].active == 0) ? "false" : "true",
+			(pp[i].preferred == 0) ? "false" : "true");
 		buf.append(tmp);
 	}
 	buf.push_back(']');
@@ -186,9 +193,8 @@ static void _jsonAppend(std::string &buf,const ZT1_Peer *peer)
 	buf.append(json);
 }
 
-ControlPlane::ControlPlane(Node *n,const std::set<std::string> atoks) :
+ControlPlane::ControlPlane(Node *n) :
-	_node(n),
+	_node(n)
-	_authTokens(atoks)
 {
 }
 
@@ -197,6 +203,7 @@ ControlPlane::~ControlPlane()
 }
 
 unsigned int ControlPlane::handleRequest(
+	const InetAddress &fromAddress,
 	unsigned int httpMethod,
 	const std::string &path,
 	const std::map<std::string,std::string> &headers,
@@ -209,11 +216,13 @@ unsigned int ControlPlane::handleRequest(
 	std::vector<std::string> ps(Utils::split(path.c_str(),"/","",""));
 	std::map<std::string,std::string> urlArgs;
 
+	if (!((fromAddress.ipsEqual(InetAddress::LO4))||(fromAddress.ipsEqual(InetAddress::LO6))))
+		return 403; // Forbidden: we only allow access from localhost right now
+
 	/* Note: this is kind of restricted in what it'll take. It does not support
 	 * URL encoding, and /'s in URL args will screw it up. But the only URL args
 	 * it really uses in ?jsonp=funcionName, and otherwise it just takes simple
 	 * paths to simply-named resources. */
-
 	if (ps.size() > 0) {
 		std::size_t qpos = ps[ps.size() - 1].find('?');
 		if (qpos != std::string::npos) {
@@ -228,112 +237,202 @@ unsigned int ControlPlane::handleRequest(
 			}
 		}
 	} else {
-		ps.push_back(std::string("index"));
+		ps.push_back(std::string("index.html"));
 	}
 
+	bool isAuth = true; // TODO: auth tokens
+
 	if (httpMethod == HTTP_GET) {
-		if (ps[0] == "index") {
+
-			responseContentType = "text/html";
+		std::string ext;
+		std::size_t dotIdx = ps[0].find_last_of('.');
+		if (dotIdx != std::string::npos)
+			ext = ps[0].substr(dotIdx);
+
+		if ((ps.size() == 1)&&(ext.length() >= 2)&&(ext[0] == '.')) {
+#ifdef ZT_BUILD_IN_WEB_UI
+			// .anything == static page -- also the only thing you can get without isAuth == true
+			if (ext == ".html")
+				responseContentType = "text/html";
+			else if (ext == ".js")
+				responseContentType = "application/javascript";
+			else if (ext == ".json")
+				responseContentType = "application/json";
+			else if (ext == ".css")
+				responseContentType = "text/css";
+			else if (ext == ".png")
+				responseContentType = "image/png";
+			else if (ext == ".jpg")
+				responseContentType = "image/jpeg";
+			else if (ext == ".gif")
+				responseContentType = "image/gif";
+			else if (ext == ".txt")
+				responseContentType = "text/plain";
+			else if (ext == ".xml")
+				responseContentType = "text/xml";
+			else if (ext == ".svg")
+				responseContentType = "image/svg+xml";
+			else responseContentType = "application/octet-stream";
 			responseBody = "<html><body>Hello World!</body></html>";
 			scode = 200;
-		} else if (ps[0] == "status") {
+#endif // ZT_BUILD_IN_WEB_UI
-			responseContentType = "application/json";
+		} else if (isAuth) {
-			ZT1_NodeStatus status;
+			if (ps[0] == "status") {
-			_node->status(&status);
+				responseContentType = "application/json";
-			Utils::snprintf(json,sizeof(json),
+				ZT1_NodeStatus status;
-				"{"
+				_node->status(&status);
-				"\"address\":\"%.10llx\","
+				Utils::snprintf(json,sizeof(json),
-				"\"publicIdentity\":\"%s\","
+					"{"
-				"\"online\":%s,"
+					"\"address\":\"%.10llx\","
-				"\"versionMajor\":%d,"
+					"\"publicIdentity\":\"%s\","
-				"\"versionMinor\":%d,"
+					"\"online\":%s,"
-				"\"versionRev\":%d,"
+					"\"versionMajor\":%d,"
-				"\"version\":\"%d.%d.%d\""
+					"\"versionMinor\":%d,"
-				"}",
+					"\"versionRev\":%d,"
-				status.address,
+					"\"version\":\"%d.%d.%d\""
-				status.publicIdentity,
+					"}",
-				(status.online) ? "true" : "false",
+					status.address,
-				ZEROTIER_ONE_VERSION_MAJOR,
+					status.publicIdentity,
-				ZEROTIER_ONE_VERSION_MINOR,
+					(status.online) ? "true" : "false",
-				ZEROTIER_ONE_VERSION_REVISION,
+					ZEROTIER_ONE_VERSION_MAJOR,
-				ZEROTIER_ONE_VERSION_MAJOR,ZEROTIER_ONE_VERSION_MINOR,ZEROTIER_ONE_VERSION_REVISION);
+					ZEROTIER_ONE_VERSION_MINOR,
-			responseBody = json;
+					ZEROTIER_ONE_VERSION_REVISION,
-			scode = 200;
+					ZEROTIER_ONE_VERSION_MAJOR,ZEROTIER_ONE_VERSION_MINOR,ZEROTIER_ONE_VERSION_REVISION);
-		} else if (ps[0] == "config") {
+				responseBody = json;
-			responseContentType = "application/json";
+				scode = 200;
-			responseBody = "{}"; // TODO
+			} else if (ps[0] == "config") {
-			scode = 200;
+				responseContentType = "application/json";
-		} else if (ps[0] == "network") {
+				responseBody = "{}"; // TODO
-			ZT1_VirtualNetworkList *nws = _node->networks();
+				scode = 200;
-			if (nws) {
+			} else if (ps[0] == "network") {
-				if (ps.size() == 1) {
+				if ((ps.size() > 1)&&(ps[1] == "controller")) {
-					// Return [array] of all networks
+					// TODO
-					responseContentType = "application/json";
+				} else {
-					responseBody = "[";
+					ZT1_VirtualNetworkList *nws = _node->networks();
-					for(unsigned long i=0;i<nws->networkCount;++i) {
+					if (nws) {
-						if (i > 0)
+						if (ps.size() == 1) {
-							responseBody.push_back(',');
+							// Return [array] of all networks
-						_jsonAppend(responseBody,&(nws->networks[i]));
-					}
-					responseBody.push_back(']');
-					scode = 200;
-				} else if (ps.size() == 2) {
-					// Return a single network by ID or 404 if not found
-					uint64_t wantnw = Utils::hexStrToU64(ps[1].c_str());
-					for(unsigned long i=0;i<nws->networkCount;++i) {
-						if (nws->networks[i].nwid == wantnw) {
 							responseContentType = "application/json";
-							_jsonAppend(responseBody,&(nws->networks[i]));
+							responseBody = "[";
+							for(unsigned long i=0;i<nws->networkCount;++i) {
+								if (i > 0)
+									responseBody.push_back(',');
+								_jsonAppend(responseBody,&(nws->networks[i]));
+							}
+							responseBody.push_back(']');
 							scode = 200;
-							break;
+						} else if (ps.size() == 2) {
-						}
+							// Return a single network by ID or 404 if not found
-					}
+							uint64_t wantnw = Utils::hexStrToU64(ps[1].c_str());
-				} // else 404
+							for(unsigned long i=0;i<nws->networkCount;++i) {
-				_node->freeQueryResult((void *)nws);
+								if (nws->networks[i].nwid == wantnw) {
-			} else {
+									responseContentType = "application/json";
-				scode = 500;
+									_jsonAppend(responseBody,&(nws->networks[i]));
-			}
+									scode = 200;
-		} else if (ps[0] == "peer") {
+									break;
-			ZT1_PeerList *pl = _node->peers();
+								}
-			if (pl) {
+							}
-				if (ps.size() == 1) {
+						} // else 404
-					// Return [array] of all peers
+						_node->freeQueryResult((void *)nws);
-					responseContentType = "application/json";
+					} else scode = 500;
-					responseBody = "[";
+				}
-					for(unsigned long i=0;i<pl->peerCount;++i) {
+			} else if (ps[0] == "peer") {
-						if (i > 0)
+				ZT1_PeerList *pl = _node->peers();
-							responseBody.push_back(',');
+				if (pl) {
-						_jsonAppend(responseBody,&(pl->peers[i]));
+					if (ps.size() == 1) {
-					}
+						// Return [array] of all peers
-					responseBody.push_back(']');
+						responseContentType = "application/json";
-					scode = 200;
+						responseBody = "[";
-				} else if (ps.size() == 2) {
+						for(unsigned long i=0;i<pl->peerCount;++i) {
-					// Return a single peer by ID or 404 if not found
+							if (i > 0)
-					uint64_t wantp = Utils::hexStrToU64(ps[1].c_str());
+								responseBody.push_back(',');
-					for(unsigned long i=0;i<pl->peerCount;++i) {
-						if (pl->peers[i].address == wantp) {
-							responseContentType = "application/json";
 							_jsonAppend(responseBody,&(pl->peers[i]));
-							scode = 200;
-							break;
 						}
-					}
+						responseBody.push_back(']');
-				} // else 404
+						scode = 200;
-				_node->freeQueryResult((void *)pl);
+					} else if (ps.size() == 2) {
-			} else {
+						// Return a single peer by ID or 404 if not found
-				scode = 500;
+						uint64_t wantp = Utils::hexStrToU64(ps[1].c_str());
-			}
+						for(unsigned long i=0;i<pl->peerCount;++i) {
-		}
+							if (pl->peers[i].address == wantp) {
-	} else if ((httpMethod == HTTP_POST)||(httpMethod == HTTP_PUT)) { // PUT is weird in REST but we'll take it anyway
+								responseContentType = "application/json";
+								_jsonAppend(responseBody,&(pl->peers[i]));
+								scode = 200;
+								break;
+							}
+						}
+					} // else 404
+					_node->freeQueryResult((void *)pl);
+				} else scode = 500;
+			} // else 404
+		} else scode = 401; // isAuth == false
+
+	} else if ((httpMethod == HTTP_POST)||(httpMethod == HTTP_PUT)) {
+
+		if (isAuth) {
+			if (ps[0] == "config") {
+				// TODO
+			} else if (ps[0] == "network") {
+				if ((ps.size() > 1)&&(ps[1] == "controller")) {
+					// TODO
+				} else {
+					if (ps.size() == 2) {
+						uint64_t wantnw = Utils::hexStrToU64(ps[1].c_str());
+						_node->join(wantnw); // does nothing if we are a member
+						ZT1_VirtualNetworkList *nws = _node->networks();
+						if (nws) {
+							for(unsigned long i=0;i<nws->networkCount;++i) {
+								if (nws->networks[i].nwid == wantnw) {
+									responseContentType = "application/json";
+									_jsonAppend(responseBody,&(nws->networks[i]));
+									scode = 200;
+									break;
+								}
+							}
+							_node->freeQueryResult((void *)nws);
+						} else scode = 500;
+					} // else 404
+				}
+			} // else 404
+		} else scode = 401; // isAuth == false
+
 	} else if (httpMethod == HTTP_DELETE) {
+
+		if (isAuth) {
+			if (ps[0] == "config") {
+				// TODO
+			} else if (ps[0] == "network") {
+				if ((ps.size() > 1)&&(ps[1] == "controller")) {
+					// TODO
+				} else {
+					ZT1_VirtualNetworkList *nws = _node->networks();
+					if (nws) {
+						if (ps.size() == 2) {
+							uint64_t wantnw = Utils::hexStrToU64(ps[1].c_str());
+							for(unsigned long i=0;i<nws->networkCount;++i) {
+								if (nws->networks[i].nwid == wantnw) {
+									_node->leave(wantnw);
+									responseBody = "true";
+									responseContentType = "application/json";
+									scode = 200;
+									break;
+								}
+							}
+						} // else 404
+						_node->freeQueryResult((void *)nws);
+					} else scode = 500;
+				}
+			} // else 404
+		} else scode = 401; // isAuth = false
+
 	} else {
 		scode = 400;
-		responseBody = "Method not supported for resource ";
+		responseBody = "Method not supported.";
-		responseBody.append(path);
 	}
 
+	// Wrap result in jsonp function call if the user included a jsonp= url argument
 	std::map<std::string,std::string>::const_iterator jsonp(urlArgs.find("jsonp"));
-	if (jsonp != urlArgs.end()) {
+	if ((jsonp != urlArgs.end())&&(responseContentType == "application/json")) {
 		if (responseBody.length() > 0)
 			responseBody = jsonp->second + "(" + responseBody + ");";
 		else responseBody = jsonp->second + "(null);";

service/ControlPlane.hpp

@@ -37,6 +37,7 @@
 namespace ZeroTier {
 
 class Node;
+struct InetAddress;
 
 /**
  * HTTP control plane and static web server
@@ -44,12 +45,13 @@ class Node;
 class ControlPlane
 {
 public:
-	ControlPlane(Node *n,const std::set<std::string> atoks);
+	ControlPlane(Node *n);
 	~ControlPlane();
 
 	/**
 	 * Handle HTTP request
 	 *
+	 * @param fromAddress Originating IP address of request
 	 * @param httpMethod HTTP method (as defined in ext/http-parser/http_parser.h)
 	 * @param path Request path
 	 * @param headers Request headers
@@ -59,6 +61,7 @@ public:
 	 * @return HTTP response code
 	 */
 	unsigned int handleRequest(
+		const InetAddress &fromAddress,
 		unsigned int httpMethod,
 		const std::string &path,
 		const std::map<std::string,std::string> &headers,

service/One.cpp

@@ -189,7 +189,7 @@ public:
 			if (_master)
 				_node->setNetconfMaster((void *)_master);
 
-			_controlPlane = new ControlPlane(_node,std::set<std::string>());
+			_controlPlane = new ControlPlane(_node);
 
 			_nextBackgroundTaskDeadline = 0;
 			for(;;) {
@@ -454,16 +454,12 @@ public:
 		std::string contentType("text/plain"); // default if not changed in handleRequest()
 		unsigned int scode = 404;
 
-		if ((htc->from.ipsEqual(InetAddress::LO4))||(htc->from.ipsEqual(InetAddress::LO6))) {
+		try {
-			try {
+			if (_controlPlane)
-				if (_controlPlane)
+				scode = _controlPlane->handleRequest(htc->from,htc->parser.method,htc->url,htc->headers,htc->body,data,contentType);
-					scode = _controlPlane->handleRequest(htc->parser.method,htc->url,htc->headers,htc->body,data,contentType);
+			else scode = 500;
-			} catch ( ... ) {
+		} catch ( ... ) {
-				scode = 500;
+			scode = 500;
-			}
-		} else {
-			scode = 403;
-			htc->shouldKeepAlive = false;
 		}
 
 		const char *scodestr;