2
0

EmbeddedNetworkController.cpp 58 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638
  1. /*
  2. * ZeroTier One - Network Virtualization Everywhere
  3. * Copyright (C) 2011-2015 ZeroTier, Inc->
  4. *
  5. * This program is free software: you can redistribute it and/or modify
  6. * it under the terms of the GNU General Public License as published by
  7. * the Free Software Foundation, either version 3 of the License, or
  8. * (at your option) any later version.
  9. *
  10. * This program is distributed in the hope that it will be useful,
  11. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  13. * GNU General Public License for more details.
  14. *
  15. * You should have received a copy of the GNU General Public License
  16. * along with this program. If not, see <http://www.gnu.org/licenses/>.
  17. */
  18. #include <stdint.h>
  19. #include <stdio.h>
  20. #include <stdlib.h>
  21. #include <string.h>
  22. #include <time.h>
  23. #ifndef _WIN32
  24. #include <sys/time.h>
  25. #endif
  26. #include <sys/types.h>
  27. #include <algorithm>
  28. #include <utility>
  29. #include <stdexcept>
  30. #include <map>
  31. #include <thread>
  32. #include <memory>
  33. #include "../include/ZeroTierOne.h"
  34. #include "../node/Constants.hpp"
  35. #include "EmbeddedNetworkController.hpp"
  36. #include "../node/Node.hpp"
  37. #include "../node/Utils.hpp"
  38. #include "../node/CertificateOfMembership.hpp"
  39. #include "../node/NetworkConfig.hpp"
  40. #include "../node/Dictionary.hpp"
  41. #include "../node/InetAddress.hpp"
  42. #include "../node/MAC.hpp"
  43. #include "../node/Address.hpp"
  44. using json = nlohmann::json;
  45. // API version reported via JSON control plane
  46. #define ZT_NETCONF_CONTROLLER_API_VERSION 3
  47. // Number of requests to remember in member history
  48. #define ZT_NETCONF_DB_MEMBER_HISTORY_LENGTH 2
  49. // Min duration between requests for an address/nwid combo to prevent floods
  50. #define ZT_NETCONF_MIN_REQUEST_PERIOD 1000
  51. namespace ZeroTier {
  52. static json _renderRule(ZT_VirtualNetworkRule &rule)
  53. {
  54. char tmp[128];
  55. json r = json::object();
  56. const ZT_VirtualNetworkRuleType rt = (ZT_VirtualNetworkRuleType)(rule.t & 0x3f);
  57. switch(rt) {
  58. case ZT_NETWORK_RULE_ACTION_DROP:
  59. r["type"] = "ACTION_DROP";
  60. break;
  61. case ZT_NETWORK_RULE_ACTION_ACCEPT:
  62. r["type"] = "ACTION_ACCEPT";
  63. break;
  64. case ZT_NETWORK_RULE_ACTION_TEE:
  65. r["type"] = "ACTION_TEE";
  66. r["address"] = Address(rule.v.fwd.address).toString(tmp);
  67. r["flags"] = (unsigned int)rule.v.fwd.flags;
  68. r["length"] = (unsigned int)rule.v.fwd.length;
  69. break;
  70. case ZT_NETWORK_RULE_ACTION_WATCH:
  71. r["type"] = "ACTION_WATCH";
  72. r["address"] = Address(rule.v.fwd.address).toString(tmp);
  73. r["flags"] = (unsigned int)rule.v.fwd.flags;
  74. r["length"] = (unsigned int)rule.v.fwd.length;
  75. break;
  76. case ZT_NETWORK_RULE_ACTION_REDIRECT:
  77. r["type"] = "ACTION_REDIRECT";
  78. r["address"] = Address(rule.v.fwd.address).toString(tmp);
  79. r["flags"] = (unsigned int)rule.v.fwd.flags;
  80. break;
  81. case ZT_NETWORK_RULE_ACTION_BREAK:
  82. r["type"] = "ACTION_BREAK";
  83. break;
  84. default:
  85. break;
  86. }
  87. if (r.size() == 0) {
  88. switch(rt) {
  89. case ZT_NETWORK_RULE_MATCH_SOURCE_ZEROTIER_ADDRESS:
  90. r["type"] = "MATCH_SOURCE_ZEROTIER_ADDRESS";
  91. r["zt"] = Address(rule.v.zt).toString(tmp);
  92. break;
  93. case ZT_NETWORK_RULE_MATCH_DEST_ZEROTIER_ADDRESS:
  94. r["type"] = "MATCH_DEST_ZEROTIER_ADDRESS";
  95. r["zt"] = Address(rule.v.zt).toString(tmp);
  96. break;
  97. case ZT_NETWORK_RULE_MATCH_VLAN_ID:
  98. r["type"] = "MATCH_VLAN_ID";
  99. r["vlanId"] = (unsigned int)rule.v.vlanId;
  100. break;
  101. case ZT_NETWORK_RULE_MATCH_VLAN_PCP:
  102. r["type"] = "MATCH_VLAN_PCP";
  103. r["vlanPcp"] = (unsigned int)rule.v.vlanPcp;
  104. break;
  105. case ZT_NETWORK_RULE_MATCH_VLAN_DEI:
  106. r["type"] = "MATCH_VLAN_DEI";
  107. r["vlanDei"] = (unsigned int)rule.v.vlanDei;
  108. break;
  109. case ZT_NETWORK_RULE_MATCH_MAC_SOURCE:
  110. r["type"] = "MATCH_MAC_SOURCE";
  111. OSUtils::ztsnprintf(tmp,sizeof(tmp),"%.2x:%.2x:%.2x:%.2x:%.2x:%.2x",(unsigned int)rule.v.mac[0],(unsigned int)rule.v.mac[1],(unsigned int)rule.v.mac[2],(unsigned int)rule.v.mac[3],(unsigned int)rule.v.mac[4],(unsigned int)rule.v.mac[5]);
  112. r["mac"] = tmp;
  113. break;
  114. case ZT_NETWORK_RULE_MATCH_MAC_DEST:
  115. r["type"] = "MATCH_MAC_DEST";
  116. OSUtils::ztsnprintf(tmp,sizeof(tmp),"%.2x:%.2x:%.2x:%.2x:%.2x:%.2x",(unsigned int)rule.v.mac[0],(unsigned int)rule.v.mac[1],(unsigned int)rule.v.mac[2],(unsigned int)rule.v.mac[3],(unsigned int)rule.v.mac[4],(unsigned int)rule.v.mac[5]);
  117. r["mac"] = tmp;
  118. break;
  119. case ZT_NETWORK_RULE_MATCH_IPV4_SOURCE:
  120. r["type"] = "MATCH_IPV4_SOURCE";
  121. r["ip"] = InetAddress(&(rule.v.ipv4.ip),4,(unsigned int)rule.v.ipv4.mask).toString(tmp);
  122. break;
  123. case ZT_NETWORK_RULE_MATCH_IPV4_DEST:
  124. r["type"] = "MATCH_IPV4_DEST";
  125. r["ip"] = InetAddress(&(rule.v.ipv4.ip),4,(unsigned int)rule.v.ipv4.mask).toString(tmp);
  126. break;
  127. case ZT_NETWORK_RULE_MATCH_IPV6_SOURCE:
  128. r["type"] = "MATCH_IPV6_SOURCE";
  129. r["ip"] = InetAddress(rule.v.ipv6.ip,16,(unsigned int)rule.v.ipv6.mask).toString(tmp);
  130. break;
  131. case ZT_NETWORK_RULE_MATCH_IPV6_DEST:
  132. r["type"] = "MATCH_IPV6_DEST";
  133. r["ip"] = InetAddress(rule.v.ipv6.ip,16,(unsigned int)rule.v.ipv6.mask).toString(tmp);
  134. break;
  135. case ZT_NETWORK_RULE_MATCH_IP_TOS:
  136. r["type"] = "MATCH_IP_TOS";
  137. r["mask"] = (unsigned int)rule.v.ipTos.mask;
  138. r["start"] = (unsigned int)rule.v.ipTos.value[0];
  139. r["end"] = (unsigned int)rule.v.ipTos.value[1];
  140. break;
  141. case ZT_NETWORK_RULE_MATCH_IP_PROTOCOL:
  142. r["type"] = "MATCH_IP_PROTOCOL";
  143. r["ipProtocol"] = (unsigned int)rule.v.ipProtocol;
  144. break;
  145. case ZT_NETWORK_RULE_MATCH_ETHERTYPE:
  146. r["type"] = "MATCH_ETHERTYPE";
  147. r["etherType"] = (unsigned int)rule.v.etherType;
  148. break;
  149. case ZT_NETWORK_RULE_MATCH_ICMP:
  150. r["type"] = "MATCH_ICMP";
  151. r["icmpType"] = (unsigned int)rule.v.icmp.type;
  152. if ((rule.v.icmp.flags & 0x01) != 0)
  153. r["icmpCode"] = (unsigned int)rule.v.icmp.code;
  154. else r["icmpCode"] = json();
  155. break;
  156. case ZT_NETWORK_RULE_MATCH_IP_SOURCE_PORT_RANGE:
  157. r["type"] = "MATCH_IP_SOURCE_PORT_RANGE";
  158. r["start"] = (unsigned int)rule.v.port[0];
  159. r["end"] = (unsigned int)rule.v.port[1];
  160. break;
  161. case ZT_NETWORK_RULE_MATCH_IP_DEST_PORT_RANGE:
  162. r["type"] = "MATCH_IP_DEST_PORT_RANGE";
  163. r["start"] = (unsigned int)rule.v.port[0];
  164. r["end"] = (unsigned int)rule.v.port[1];
  165. break;
  166. case ZT_NETWORK_RULE_MATCH_CHARACTERISTICS:
  167. r["type"] = "MATCH_CHARACTERISTICS";
  168. OSUtils::ztsnprintf(tmp,sizeof(tmp),"%.16llx",rule.v.characteristics);
  169. r["mask"] = tmp;
  170. break;
  171. case ZT_NETWORK_RULE_MATCH_FRAME_SIZE_RANGE:
  172. r["type"] = "MATCH_FRAME_SIZE_RANGE";
  173. r["start"] = (unsigned int)rule.v.frameSize[0];
  174. r["end"] = (unsigned int)rule.v.frameSize[1];
  175. break;
  176. case ZT_NETWORK_RULE_MATCH_RANDOM:
  177. r["type"] = "MATCH_RANDOM";
  178. r["probability"] = (unsigned long)rule.v.randomProbability;
  179. break;
  180. case ZT_NETWORK_RULE_MATCH_TAGS_DIFFERENCE:
  181. r["type"] = "MATCH_TAGS_DIFFERENCE";
  182. r["id"] = rule.v.tag.id;
  183. r["value"] = rule.v.tag.value;
  184. break;
  185. case ZT_NETWORK_RULE_MATCH_TAGS_BITWISE_AND:
  186. r["type"] = "MATCH_TAGS_BITWISE_AND";
  187. r["id"] = rule.v.tag.id;
  188. r["value"] = rule.v.tag.value;
  189. break;
  190. case ZT_NETWORK_RULE_MATCH_TAGS_BITWISE_OR:
  191. r["type"] = "MATCH_TAGS_BITWISE_OR";
  192. r["id"] = rule.v.tag.id;
  193. r["value"] = rule.v.tag.value;
  194. break;
  195. case ZT_NETWORK_RULE_MATCH_TAGS_BITWISE_XOR:
  196. r["type"] = "MATCH_TAGS_BITWISE_XOR";
  197. r["id"] = rule.v.tag.id;
  198. r["value"] = rule.v.tag.value;
  199. break;
  200. case ZT_NETWORK_RULE_MATCH_TAGS_EQUAL:
  201. r["type"] = "MATCH_TAGS_EQUAL";
  202. r["id"] = rule.v.tag.id;
  203. r["value"] = rule.v.tag.value;
  204. break;
  205. case ZT_NETWORK_RULE_MATCH_TAG_SENDER:
  206. r["type"] = "MATCH_TAG_SENDER";
  207. r["id"] = rule.v.tag.id;
  208. r["value"] = rule.v.tag.value;
  209. break;
  210. case ZT_NETWORK_RULE_MATCH_TAG_RECEIVER:
  211. r["type"] = "MATCH_TAG_RECEIVER";
  212. r["id"] = rule.v.tag.id;
  213. r["value"] = rule.v.tag.value;
  214. break;
  215. default:
  216. break;
  217. }
  218. if (r.size() > 0) {
  219. r["not"] = ((rule.t & 0x80) != 0);
  220. r["or"] = ((rule.t & 0x40) != 0);
  221. }
  222. }
  223. return r;
  224. }
  225. static bool _parseRule(json &r,ZT_VirtualNetworkRule &rule)
  226. {
  227. if (!r.is_object())
  228. return false;
  229. const std::string t(OSUtils::jsonString(r["type"],""));
  230. memset(&rule,0,sizeof(ZT_VirtualNetworkRule));
  231. if (OSUtils::jsonBool(r["not"],false))
  232. rule.t = 0x80;
  233. else rule.t = 0x00;
  234. if (OSUtils::jsonBool(r["or"],false))
  235. rule.t |= 0x40;
  236. bool tag = false;
  237. if (t == "ACTION_DROP") {
  238. rule.t |= ZT_NETWORK_RULE_ACTION_DROP;
  239. return true;
  240. } else if (t == "ACTION_ACCEPT") {
  241. rule.t |= ZT_NETWORK_RULE_ACTION_ACCEPT;
  242. return true;
  243. } else if (t == "ACTION_TEE") {
  244. rule.t |= ZT_NETWORK_RULE_ACTION_TEE;
  245. rule.v.fwd.address = Utils::hexStrToU64(OSUtils::jsonString(r["address"],"0").c_str()) & 0xffffffffffULL;
  246. rule.v.fwd.flags = (uint32_t)(OSUtils::jsonInt(r["flags"],0ULL) & 0xffffffffULL);
  247. rule.v.fwd.length = (uint16_t)(OSUtils::jsonInt(r["length"],0ULL) & 0xffffULL);
  248. return true;
  249. } else if (t == "ACTION_WATCH") {
  250. rule.t |= ZT_NETWORK_RULE_ACTION_WATCH;
  251. rule.v.fwd.address = Utils::hexStrToU64(OSUtils::jsonString(r["address"],"0").c_str()) & 0xffffffffffULL;
  252. rule.v.fwd.flags = (uint32_t)(OSUtils::jsonInt(r["flags"],0ULL) & 0xffffffffULL);
  253. rule.v.fwd.length = (uint16_t)(OSUtils::jsonInt(r["length"],0ULL) & 0xffffULL);
  254. return true;
  255. } else if (t == "ACTION_REDIRECT") {
  256. rule.t |= ZT_NETWORK_RULE_ACTION_REDIRECT;
  257. rule.v.fwd.address = Utils::hexStrToU64(OSUtils::jsonString(r["address"],"0").c_str()) & 0xffffffffffULL;
  258. rule.v.fwd.flags = (uint32_t)(OSUtils::jsonInt(r["flags"],0ULL) & 0xffffffffULL);
  259. return true;
  260. } else if (t == "ACTION_BREAK") {
  261. rule.t |= ZT_NETWORK_RULE_ACTION_BREAK;
  262. return true;
  263. } else if (t == "MATCH_SOURCE_ZEROTIER_ADDRESS") {
  264. rule.t |= ZT_NETWORK_RULE_MATCH_SOURCE_ZEROTIER_ADDRESS;
  265. rule.v.zt = Utils::hexStrToU64(OSUtils::jsonString(r["zt"],"0").c_str()) & 0xffffffffffULL;
  266. return true;
  267. } else if (t == "MATCH_DEST_ZEROTIER_ADDRESS") {
  268. rule.t |= ZT_NETWORK_RULE_MATCH_DEST_ZEROTIER_ADDRESS;
  269. rule.v.zt = Utils::hexStrToU64(OSUtils::jsonString(r["zt"],"0").c_str()) & 0xffffffffffULL;
  270. return true;
  271. } else if (t == "MATCH_VLAN_ID") {
  272. rule.t |= ZT_NETWORK_RULE_MATCH_VLAN_ID;
  273. rule.v.vlanId = (uint16_t)(OSUtils::jsonInt(r["vlanId"],0ULL) & 0xffffULL);
  274. return true;
  275. } else if (t == "MATCH_VLAN_PCP") {
  276. rule.t |= ZT_NETWORK_RULE_MATCH_VLAN_PCP;
  277. rule.v.vlanPcp = (uint8_t)(OSUtils::jsonInt(r["vlanPcp"],0ULL) & 0xffULL);
  278. return true;
  279. } else if (t == "MATCH_VLAN_DEI") {
  280. rule.t |= ZT_NETWORK_RULE_MATCH_VLAN_DEI;
  281. rule.v.vlanDei = (uint8_t)(OSUtils::jsonInt(r["vlanDei"],0ULL) & 0xffULL);
  282. return true;
  283. } else if (t == "MATCH_MAC_SOURCE") {
  284. rule.t |= ZT_NETWORK_RULE_MATCH_MAC_SOURCE;
  285. const std::string mac(OSUtils::jsonString(r["mac"],"0"));
  286. Utils::unhex(mac.c_str(),(unsigned int)mac.length(),rule.v.mac,6);
  287. return true;
  288. } else if (t == "MATCH_MAC_DEST") {
  289. rule.t |= ZT_NETWORK_RULE_MATCH_MAC_DEST;
  290. const std::string mac(OSUtils::jsonString(r["mac"],"0"));
  291. Utils::unhex(mac.c_str(),(unsigned int)mac.length(),rule.v.mac,6);
  292. return true;
  293. } else if (t == "MATCH_IPV4_SOURCE") {
  294. rule.t |= ZT_NETWORK_RULE_MATCH_IPV4_SOURCE;
  295. InetAddress ip(OSUtils::jsonString(r["ip"],"0.0.0.0").c_str());
  296. rule.v.ipv4.ip = reinterpret_cast<struct sockaddr_in *>(&ip)->sin_addr.s_addr;
  297. rule.v.ipv4.mask = Utils::ntoh(reinterpret_cast<struct sockaddr_in *>(&ip)->sin_port) & 0xff;
  298. if (rule.v.ipv4.mask > 32) rule.v.ipv4.mask = 32;
  299. return true;
  300. } else if (t == "MATCH_IPV4_DEST") {
  301. rule.t |= ZT_NETWORK_RULE_MATCH_IPV4_DEST;
  302. InetAddress ip(OSUtils::jsonString(r["ip"],"0.0.0.0").c_str());
  303. rule.v.ipv4.ip = reinterpret_cast<struct sockaddr_in *>(&ip)->sin_addr.s_addr;
  304. rule.v.ipv4.mask = Utils::ntoh(reinterpret_cast<struct sockaddr_in *>(&ip)->sin_port) & 0xff;
  305. if (rule.v.ipv4.mask > 32) rule.v.ipv4.mask = 32;
  306. return true;
  307. } else if (t == "MATCH_IPV6_SOURCE") {
  308. rule.t |= ZT_NETWORK_RULE_MATCH_IPV6_SOURCE;
  309. InetAddress ip(OSUtils::jsonString(r["ip"],"::0").c_str());
  310. memcpy(rule.v.ipv6.ip,reinterpret_cast<struct sockaddr_in6 *>(&ip)->sin6_addr.s6_addr,16);
  311. rule.v.ipv6.mask = Utils::ntoh(reinterpret_cast<struct sockaddr_in6 *>(&ip)->sin6_port) & 0xff;
  312. if (rule.v.ipv6.mask > 128) rule.v.ipv6.mask = 128;
  313. return true;
  314. } else if (t == "MATCH_IPV6_DEST") {
  315. rule.t |= ZT_NETWORK_RULE_MATCH_IPV6_DEST;
  316. InetAddress ip(OSUtils::jsonString(r["ip"],"::0").c_str());
  317. memcpy(rule.v.ipv6.ip,reinterpret_cast<struct sockaddr_in6 *>(&ip)->sin6_addr.s6_addr,16);
  318. rule.v.ipv6.mask = Utils::ntoh(reinterpret_cast<struct sockaddr_in6 *>(&ip)->sin6_port) & 0xff;
  319. if (rule.v.ipv6.mask > 128) rule.v.ipv6.mask = 128;
  320. return true;
  321. } else if (t == "MATCH_IP_TOS") {
  322. rule.t |= ZT_NETWORK_RULE_MATCH_IP_TOS;
  323. rule.v.ipTos.mask = (uint8_t)(OSUtils::jsonInt(r["mask"],0ULL) & 0xffULL);
  324. rule.v.ipTos.value[0] = (uint8_t)(OSUtils::jsonInt(r["start"],0ULL) & 0xffULL);
  325. rule.v.ipTos.value[1] = (uint8_t)(OSUtils::jsonInt(r["end"],0ULL) & 0xffULL);
  326. return true;
  327. } else if (t == "MATCH_IP_PROTOCOL") {
  328. rule.t |= ZT_NETWORK_RULE_MATCH_IP_PROTOCOL;
  329. rule.v.ipProtocol = (uint8_t)(OSUtils::jsonInt(r["ipProtocol"],0ULL) & 0xffULL);
  330. return true;
  331. } else if (t == "MATCH_ETHERTYPE") {
  332. rule.t |= ZT_NETWORK_RULE_MATCH_ETHERTYPE;
  333. rule.v.etherType = (uint16_t)(OSUtils::jsonInt(r["etherType"],0ULL) & 0xffffULL);
  334. return true;
  335. } else if (t == "MATCH_ICMP") {
  336. rule.t |= ZT_NETWORK_RULE_MATCH_ICMP;
  337. rule.v.icmp.type = (uint8_t)(OSUtils::jsonInt(r["icmpType"],0ULL) & 0xffULL);
  338. json &code = r["icmpCode"];
  339. if (code.is_null()) {
  340. rule.v.icmp.code = 0;
  341. rule.v.icmp.flags = 0x00;
  342. } else {
  343. rule.v.icmp.code = (uint8_t)(OSUtils::jsonInt(code,0ULL) & 0xffULL);
  344. rule.v.icmp.flags = 0x01;
  345. }
  346. return true;
  347. } else if (t == "MATCH_IP_SOURCE_PORT_RANGE") {
  348. rule.t |= ZT_NETWORK_RULE_MATCH_IP_SOURCE_PORT_RANGE;
  349. rule.v.port[0] = (uint16_t)(OSUtils::jsonInt(r["start"],0ULL) & 0xffffULL);
  350. rule.v.port[1] = (uint16_t)(OSUtils::jsonInt(r["end"],(uint64_t)rule.v.port[0]) & 0xffffULL);
  351. return true;
  352. } else if (t == "MATCH_IP_DEST_PORT_RANGE") {
  353. rule.t |= ZT_NETWORK_RULE_MATCH_IP_DEST_PORT_RANGE;
  354. rule.v.port[0] = (uint16_t)(OSUtils::jsonInt(r["start"],0ULL) & 0xffffULL);
  355. rule.v.port[1] = (uint16_t)(OSUtils::jsonInt(r["end"],(uint64_t)rule.v.port[0]) & 0xffffULL);
  356. return true;
  357. } else if (t == "MATCH_CHARACTERISTICS") {
  358. rule.t |= ZT_NETWORK_RULE_MATCH_CHARACTERISTICS;
  359. if (r.count("mask")) {
  360. json &v = r["mask"];
  361. if (v.is_number()) {
  362. rule.v.characteristics = v;
  363. } else {
  364. std::string tmp = v;
  365. rule.v.characteristics = Utils::hexStrToU64(tmp.c_str());
  366. }
  367. }
  368. return true;
  369. } else if (t == "MATCH_FRAME_SIZE_RANGE") {
  370. rule.t |= ZT_NETWORK_RULE_MATCH_FRAME_SIZE_RANGE;
  371. rule.v.frameSize[0] = (uint16_t)(OSUtils::jsonInt(r["start"],0ULL) & 0xffffULL);
  372. rule.v.frameSize[1] = (uint16_t)(OSUtils::jsonInt(r["end"],(uint64_t)rule.v.frameSize[0]) & 0xffffULL);
  373. return true;
  374. } else if (t == "MATCH_RANDOM") {
  375. rule.t |= ZT_NETWORK_RULE_MATCH_RANDOM;
  376. rule.v.randomProbability = (uint32_t)(OSUtils::jsonInt(r["probability"],0ULL) & 0xffffffffULL);
  377. return true;
  378. } else if (t == "MATCH_TAGS_DIFFERENCE") {
  379. rule.t |= ZT_NETWORK_RULE_MATCH_TAGS_DIFFERENCE;
  380. tag = true;
  381. } else if (t == "MATCH_TAGS_BITWISE_AND") {
  382. rule.t |= ZT_NETWORK_RULE_MATCH_TAGS_BITWISE_AND;
  383. tag = true;
  384. } else if (t == "MATCH_TAGS_BITWISE_OR") {
  385. rule.t |= ZT_NETWORK_RULE_MATCH_TAGS_BITWISE_OR;
  386. tag = true;
  387. } else if (t == "MATCH_TAGS_BITWISE_XOR") {
  388. rule.t |= ZT_NETWORK_RULE_MATCH_TAGS_BITWISE_XOR;
  389. tag = true;
  390. } else if (t == "MATCH_TAGS_EQUAL") {
  391. rule.t |= ZT_NETWORK_RULE_MATCH_TAGS_EQUAL;
  392. tag = true;
  393. } else if (t == "MATCH_TAG_SENDER") {
  394. rule.t |= ZT_NETWORK_RULE_MATCH_TAG_SENDER;
  395. tag = true;
  396. } else if (t == "MATCH_TAG_RECEIVER") {
  397. rule.t |= ZT_NETWORK_RULE_MATCH_TAG_RECEIVER;
  398. tag = true;
  399. }
  400. if (tag) {
  401. rule.v.tag.id = (uint32_t)(OSUtils::jsonInt(r["id"],0ULL) & 0xffffffffULL);
  402. rule.v.tag.value = (uint32_t)(OSUtils::jsonInt(r["value"],0ULL) & 0xffffffffULL);
  403. return true;
  404. }
  405. return false;
  406. }
  407. EmbeddedNetworkController::EmbeddedNetworkController(Node *node,const char *dbPath) :
  408. _startTime(OSUtils::now()),
  409. _running(true),
  410. _db(dbPath),
  411. _node(node)
  412. {
  413. }
  414. EmbeddedNetworkController::~EmbeddedNetworkController()
  415. {
  416. std::vector<Thread> t;
  417. {
  418. Mutex::Lock _l(_threads_m);
  419. _running = false;
  420. t = _threads;
  421. }
  422. if (t.size() > 0) {
  423. _queue.stop();
  424. for(std::vector<Thread>::iterator i(t.begin());i!=t.end();++i)
  425. Thread::join(*i);
  426. }
  427. }
  428. void EmbeddedNetworkController::init(const Identity &signingId,Sender *sender)
  429. {
  430. this->_sender = sender;
  431. this->_signingId = signingId;
  432. }
  433. void EmbeddedNetworkController::request(
  434. uint64_t nwid,
  435. const InetAddress &fromAddr,
  436. uint64_t requestPacketId,
  437. const Identity &identity,
  438. const Dictionary<ZT_NETWORKCONFIG_METADATA_DICT_CAPACITY> &metaData)
  439. {
  440. if (((!_signingId)||(!_signingId.hasPrivate()))||(_signingId.address().toInt() != (nwid >> 24))||(!_sender))
  441. return;
  442. _startThreads();
  443. _RQEntry *qe = new _RQEntry;
  444. qe->nwid = nwid;
  445. qe->requestPacketId = requestPacketId;
  446. qe->fromAddr = fromAddr;
  447. qe->identity = identity;
  448. qe->metaData = metaData;
  449. qe->type = _RQEntry::RQENTRY_TYPE_REQUEST;
  450. _queue.post(qe);
  451. }
  452. unsigned int EmbeddedNetworkController::handleControlPlaneHttpGET(
  453. const std::vector<std::string> &path,
  454. const std::map<std::string,std::string> &urlArgs,
  455. const std::map<std::string,std::string> &headers,
  456. const std::string &body,
  457. std::string &responseBody,
  458. std::string &responseContentType)
  459. {
  460. if ((path.size() > 0)&&(path[0] == "network")) {
  461. if ((path.size() >= 2)&&(path[1].length() == 16)) {
  462. const uint64_t nwid = Utils::hexStrToU64(path[1].c_str());
  463. json network;
  464. if (!_db.getNetwork(nwid,network))
  465. return 404;
  466. if (path.size() >= 3) {
  467. if (path[2] == "member") {
  468. if (path.size() >= 4) {
  469. // Get member
  470. const uint64_t address = Utils::hexStrToU64(path[3].c_str());
  471. json member;
  472. if (!_db.getNetworkMember(nwid,address,member))
  473. return 404;
  474. _addMemberNonPersistedFields(nwid,address,member,OSUtils::now());
  475. responseBody = OSUtils::jsonDump(member);
  476. responseContentType = "application/json";
  477. } else {
  478. // List members and their revisions
  479. responseBody = "{";
  480. responseBody.reserve((_db.memberCount(nwid) + 1) * 32);
  481. _db.eachMember(nwid,[&responseBody](uint64_t networkId,uint64_t nodeId,const json &member) {
  482. if ((member.is_object())&&(member.size() > 0)) {
  483. char tmp[128];
  484. OSUtils::ztsnprintf(tmp,sizeof(tmp),"%s%.10llx\":%llu",(responseBody.length() > 1) ? ",\"" : "\"",(unsigned long long)nodeId,(unsigned long long)OSUtils::jsonInt(member["revision"],0));
  485. responseBody.append(tmp);
  486. }
  487. });
  488. responseBody.push_back('}');
  489. responseContentType = "application/json";
  490. }
  491. return 200;
  492. } // else 404
  493. } else {
  494. // Get network
  495. const uint64_t now = OSUtils::now();
  496. JSONDB::NetworkSummaryInfo ns;
  497. _db.getNetworkSummaryInfo(nwid,ns);
  498. _addNetworkNonPersistedFields(network,now,ns);
  499. responseBody = OSUtils::jsonDump(network);
  500. responseContentType = "application/json";
  501. return 200;
  502. }
  503. } else if (path.size() == 1) {
  504. // List networks
  505. std::vector<uint64_t> networkIds(_db.networkIds());
  506. char tmp[64];
  507. responseBody = "[";
  508. responseBody.reserve((networkIds.size() + 1) * 24);
  509. for(std::vector<uint64_t>::const_iterator i(networkIds.begin());i!=networkIds.end();++i) {
  510. if (responseBody.length() > 1)
  511. responseBody.push_back(',');
  512. OSUtils::ztsnprintf(tmp,sizeof(tmp),"\"%.16llx\"",(unsigned long long)*i);
  513. responseBody.append(tmp);
  514. }
  515. responseBody.push_back(']');
  516. responseContentType = "application/json";
  517. return 200;
  518. } // else 404
  519. } else {
  520. // Controller status
  521. char tmp[4096];
  522. OSUtils::ztsnprintf(tmp,sizeof(tmp),"{\n\t\"controller\": true,\n\t\"apiVersion\": %d,\n\t\"clock\": %llu\n}\n",ZT_NETCONF_CONTROLLER_API_VERSION,(unsigned long long)OSUtils::now());
  523. responseBody = tmp;
  524. responseContentType = "application/json";
  525. return 200;
  526. }
  527. return 404;
  528. }
  529. unsigned int EmbeddedNetworkController::handleControlPlaneHttpPOST(
  530. const std::vector<std::string> &path,
  531. const std::map<std::string,std::string> &urlArgs,
  532. const std::map<std::string,std::string> &headers,
  533. const std::string &body,
  534. std::string &responseBody,
  535. std::string &responseContentType)
  536. {
  537. if (path.empty())
  538. return 404;
  539. json b;
  540. try {
  541. b = OSUtils::jsonParse(body);
  542. if (!b.is_object()) {
  543. responseBody = "{ \"message\": \"body is not a JSON object\" }";
  544. responseContentType = "application/json";
  545. return 400;
  546. }
  547. } catch ( ... ) {
  548. responseBody = "{ \"message\": \"body JSON is invalid\" }";
  549. responseContentType = "application/json";
  550. return 400;
  551. }
  552. const uint64_t now = OSUtils::now();
  553. if (path[0] == "network") {
  554. if ((path.size() >= 2)&&(path[1].length() == 16)) {
  555. uint64_t nwid = Utils::hexStrToU64(path[1].c_str());
  556. char nwids[24];
  557. OSUtils::ztsnprintf(nwids,sizeof(nwids),"%.16llx",(unsigned long long)nwid);
  558. if (path.size() >= 3) {
  559. if ((path.size() == 4)&&(path[2] == "member")&&(path[3].length() == 10)) {
  560. uint64_t address = Utils::hexStrToU64(path[3].c_str());
  561. char addrs[24];
  562. OSUtils::ztsnprintf(addrs,sizeof(addrs),"%.10llx",(unsigned long long)address);
  563. json member;
  564. _db.getNetworkMember(nwid,address,member);
  565. json origMember(member); // for detecting changes
  566. _initMember(member);
  567. try {
  568. if (b.count("activeBridge")) member["activeBridge"] = OSUtils::jsonBool(b["activeBridge"],false);
  569. if (b.count("noAutoAssignIps")) member["noAutoAssignIps"] = OSUtils::jsonBool(b["noAutoAssignIps"],false);
  570. if (b.count("authorized")) {
  571. const bool newAuth = OSUtils::jsonBool(b["authorized"],false);
  572. if (newAuth != OSUtils::jsonBool(member["authorized"],false)) {
  573. member["authorized"] = newAuth;
  574. member[((newAuth) ? "lastAuthorizedTime" : "lastDeauthorizedTime")] = now;
  575. json ah;
  576. ah["a"] = newAuth;
  577. ah["by"] = "api";
  578. ah["ts"] = now;
  579. ah["ct"] = json();
  580. ah["c"] = json();
  581. member["authHistory"].push_back(ah);
  582. // Member is being de-authorized, so spray Revocation objects to all online members
  583. if (!newAuth) {
  584. Revocation rev((uint32_t)_node->prng(),nwid,0,now,ZT_REVOCATION_FLAG_FAST_PROPAGATE,Address(address),Revocation::CREDENTIAL_TYPE_COM);
  585. rev.sign(_signingId);
  586. Mutex::Lock _l(_memberStatus_m);
  587. for(auto i=_memberStatus.begin();i!=_memberStatus.end();++i) {
  588. if ((i->first.networkId == nwid)&&(i->second.online(now)))
  589. _node->ncSendRevocation(Address(i->first.nodeId),rev);
  590. }
  591. }
  592. }
  593. }
  594. if (b.count("ipAssignments")) {
  595. json &ipa = b["ipAssignments"];
  596. if (ipa.is_array()) {
  597. json mipa(json::array());
  598. for(unsigned long i=0;i<ipa.size();++i) {
  599. std::string ips = ipa[i];
  600. InetAddress ip(ips.c_str());
  601. if ((ip.ss_family == AF_INET)||(ip.ss_family == AF_INET6)) {
  602. char tmpip[64];
  603. mipa.push_back(ip.toIpString(tmpip));
  604. }
  605. }
  606. member["ipAssignments"] = mipa;
  607. }
  608. }
  609. if (b.count("tags")) {
  610. json &tags = b["tags"];
  611. if (tags.is_array()) {
  612. std::map<uint64_t,uint64_t> mtags;
  613. for(unsigned long i=0;i<tags.size();++i) {
  614. json &tag = tags[i];
  615. if ((tag.is_array())&&(tag.size() == 2))
  616. mtags[OSUtils::jsonInt(tag[0],0ULL) & 0xffffffffULL] = OSUtils::jsonInt(tag[1],0ULL) & 0xffffffffULL;
  617. }
  618. json mtagsa = json::array();
  619. for(std::map<uint64_t,uint64_t>::iterator t(mtags.begin());t!=mtags.end();++t) {
  620. json ta = json::array();
  621. ta.push_back(t->first);
  622. ta.push_back(t->second);
  623. mtagsa.push_back(ta);
  624. }
  625. member["tags"] = mtagsa;
  626. }
  627. }
  628. if (b.count("capabilities")) {
  629. json &capabilities = b["capabilities"];
  630. if (capabilities.is_array()) {
  631. json mcaps = json::array();
  632. for(unsigned long i=0;i<capabilities.size();++i) {
  633. mcaps.push_back(OSUtils::jsonInt(capabilities[i],0ULL));
  634. }
  635. std::sort(mcaps.begin(),mcaps.end());
  636. mcaps.erase(std::unique(mcaps.begin(),mcaps.end()),mcaps.end());
  637. member["capabilities"] = mcaps;
  638. }
  639. }
  640. } catch ( ... ) {
  641. responseBody = "{ \"message\": \"exception while processing parameters in JSON body\" }";
  642. responseContentType = "application/json";
  643. return 400;
  644. }
  645. member["id"] = addrs;
  646. member["address"] = addrs; // legacy
  647. member["nwid"] = nwids;
  648. _removeMemberNonPersistedFields(member);
  649. if (member != origMember) {
  650. json &revj = member["revision"];
  651. member["revision"] = (revj.is_number() ? ((uint64_t)revj + 1ULL) : 1ULL);
  652. _db.saveNetworkMember(nwid,address,member);
  653. // Push update to member if online
  654. try {
  655. Mutex::Lock _l(_memberStatus_m);
  656. _MemberStatus &ms = _memberStatus[_MemberStatusKey(nwid,address)];
  657. if ((ms.online(now))&&(ms.lastRequestMetaData))
  658. request(nwid,InetAddress(),0,ms.identity,ms.lastRequestMetaData);
  659. } catch ( ... ) {}
  660. }
  661. _addMemberNonPersistedFields(nwid,address,member,now);
  662. responseBody = OSUtils::jsonDump(member);
  663. responseContentType = "application/json";
  664. return 200;
  665. } // else 404
  666. } else {
  667. // POST to network ID
  668. // Magic ID ending with ______ picks a random unused network ID
  669. if (path[1].substr(10) == "______") {
  670. nwid = 0;
  671. uint64_t nwidPrefix = (Utils::hexStrToU64(path[1].substr(0,10).c_str()) << 24) & 0xffffffffff000000ULL;
  672. uint64_t nwidPostfix = 0;
  673. for(unsigned long k=0;k<100000;++k) { // sanity limit on trials
  674. Utils::getSecureRandom(&nwidPostfix,sizeof(nwidPostfix));
  675. uint64_t tryNwid = nwidPrefix | (nwidPostfix & 0xffffffULL);
  676. if ((tryNwid & 0xffffffULL) == 0ULL) tryNwid |= 1ULL;
  677. if (!_db.hasNetwork(tryNwid)) {
  678. nwid = tryNwid;
  679. break;
  680. }
  681. }
  682. if (!nwid)
  683. return 503;
  684. }
  685. OSUtils::ztsnprintf(nwids,sizeof(nwids),"%.16llx",(unsigned long long)nwid);
  686. json network;
  687. _db.getNetwork(nwid,network);
  688. json origNetwork(network); // for detecting changes
  689. _initNetwork(network);
  690. try {
  691. if (b.count("name")) network["name"] = OSUtils::jsonString(b["name"],"");
  692. if (b.count("private")) network["private"] = OSUtils::jsonBool(b["private"],true);
  693. if (b.count("enableBroadcast")) network["enableBroadcast"] = OSUtils::jsonBool(b["enableBroadcast"],false);
  694. if (b.count("allowPassiveBridging")) network["allowPassiveBridging"] = OSUtils::jsonBool(b["allowPassiveBridging"],false);
  695. if (b.count("multicastLimit")) network["multicastLimit"] = OSUtils::jsonInt(b["multicastLimit"],32ULL);
  696. if (b.count("mtu")) network["mtu"] = std::max(std::min((unsigned int)OSUtils::jsonInt(b["mtu"],ZT_DEFAULT_MTU),(unsigned int)ZT_MAX_MTU),(unsigned int)ZT_MIN_MTU);
  697. if (b.count("v4AssignMode")) {
  698. json nv4m;
  699. json &v4m = b["v4AssignMode"];
  700. if (v4m.is_string()) { // backward compatibility
  701. nv4m["zt"] = (OSUtils::jsonString(v4m,"") == "zt");
  702. } else if (v4m.is_object()) {
  703. nv4m["zt"] = OSUtils::jsonBool(v4m["zt"],false);
  704. } else nv4m["zt"] = false;
  705. network["v4AssignMode"] = nv4m;
  706. }
  707. if (b.count("v6AssignMode")) {
  708. json nv6m;
  709. json &v6m = b["v6AssignMode"];
  710. if (!nv6m.is_object()) nv6m = json::object();
  711. if (v6m.is_string()) { // backward compatibility
  712. std::vector<std::string> v6ms(OSUtils::split(OSUtils::jsonString(v6m,"").c_str(),",","",""));
  713. std::sort(v6ms.begin(),v6ms.end());
  714. v6ms.erase(std::unique(v6ms.begin(),v6ms.end()),v6ms.end());
  715. nv6m["rfc4193"] = false;
  716. nv6m["zt"] = false;
  717. nv6m["6plane"] = false;
  718. for(std::vector<std::string>::iterator i(v6ms.begin());i!=v6ms.end();++i) {
  719. if (*i == "rfc4193")
  720. nv6m["rfc4193"] = true;
  721. else if (*i == "zt")
  722. nv6m["zt"] = true;
  723. else if (*i == "6plane")
  724. nv6m["6plane"] = true;
  725. }
  726. } else if (v6m.is_object()) {
  727. if (v6m.count("rfc4193")) nv6m["rfc4193"] = OSUtils::jsonBool(v6m["rfc4193"],false);
  728. if (v6m.count("zt")) nv6m["zt"] = OSUtils::jsonBool(v6m["zt"],false);
  729. if (v6m.count("6plane")) nv6m["6plane"] = OSUtils::jsonBool(v6m["6plane"],false);
  730. } else {
  731. nv6m["rfc4193"] = false;
  732. nv6m["zt"] = false;
  733. nv6m["6plane"] = false;
  734. }
  735. network["v6AssignMode"] = nv6m;
  736. }
  737. if (b.count("routes")) {
  738. json &rts = b["routes"];
  739. if (rts.is_array()) {
  740. json nrts = json::array();
  741. for(unsigned long i=0;i<rts.size();++i) {
  742. json &rt = rts[i];
  743. if (rt.is_object()) {
  744. json &target = rt["target"];
  745. json &via = rt["via"];
  746. if (target.is_string()) {
  747. InetAddress t(target.get<std::string>().c_str());
  748. InetAddress v;
  749. if (via.is_string()) v.fromString(via.get<std::string>().c_str());
  750. if ( ((t.ss_family == AF_INET)||(t.ss_family == AF_INET6)) && (t.netmaskBitsValid()) ) {
  751. json tmp;
  752. char tmp2[64];
  753. tmp["target"] = t.toString(tmp2);
  754. if (v.ss_family == t.ss_family)
  755. tmp["via"] = v.toIpString(tmp2);
  756. else tmp["via"] = json();
  757. nrts.push_back(tmp);
  758. }
  759. }
  760. }
  761. }
  762. network["routes"] = nrts;
  763. }
  764. }
  765. if (b.count("ipAssignmentPools")) {
  766. json &ipp = b["ipAssignmentPools"];
  767. if (ipp.is_array()) {
  768. json nipp = json::array();
  769. for(unsigned long i=0;i<ipp.size();++i) {
  770. json &ip = ipp[i];
  771. if ((ip.is_object())&&(ip.count("ipRangeStart"))&&(ip.count("ipRangeEnd"))) {
  772. InetAddress f(OSUtils::jsonString(ip["ipRangeStart"],"").c_str());
  773. InetAddress t(OSUtils::jsonString(ip["ipRangeEnd"],"").c_str());
  774. if ( ((f.ss_family == AF_INET)||(f.ss_family == AF_INET6)) && (f.ss_family == t.ss_family) ) {
  775. json tmp = json::object();
  776. char tmp2[64];
  777. tmp["ipRangeStart"] = f.toIpString(tmp2);
  778. tmp["ipRangeEnd"] = t.toIpString(tmp2);
  779. nipp.push_back(tmp);
  780. }
  781. }
  782. }
  783. network["ipAssignmentPools"] = nipp;
  784. }
  785. }
  786. if (b.count("rules")) {
  787. json &rules = b["rules"];
  788. if (rules.is_array()) {
  789. json nrules = json::array();
  790. for(unsigned long i=0;i<rules.size();++i) {
  791. json &rule = rules[i];
  792. if (rule.is_object()) {
  793. ZT_VirtualNetworkRule ztr;
  794. if (_parseRule(rule,ztr))
  795. nrules.push_back(_renderRule(ztr));
  796. }
  797. }
  798. network["rules"] = nrules;
  799. }
  800. }
  801. if (b.count("authTokens")) {
  802. json &authTokens = b["authTokens"];
  803. if (authTokens.is_array()) {
  804. json nat = json::array();
  805. for(unsigned long i=0;i<authTokens.size();++i) {
  806. json &token = authTokens[i];
  807. if (token.is_object()) {
  808. std::string tstr = token["token"];
  809. if (tstr.length() > 0) {
  810. json t = json::object();
  811. t["token"] = tstr;
  812. t["expires"] = OSUtils::jsonInt(token["expires"],0ULL);
  813. t["maxUsesPerMember"] = OSUtils::jsonInt(token["maxUsesPerMember"],0ULL);
  814. nat.push_back(t);
  815. }
  816. }
  817. }
  818. network["authTokens"] = nat;
  819. }
  820. }
  821. if (b.count("capabilities")) {
  822. json &capabilities = b["capabilities"];
  823. if (capabilities.is_array()) {
  824. std::map< uint64_t,json > ncaps;
  825. for(unsigned long i=0;i<capabilities.size();++i) {
  826. json &cap = capabilities[i];
  827. if (cap.is_object()) {
  828. json ncap = json::object();
  829. const uint64_t capId = OSUtils::jsonInt(cap["id"],0ULL);
  830. ncap["id"] = capId;
  831. ncap["default"] = OSUtils::jsonBool(cap["default"],false);
  832. json &rules = cap["rules"];
  833. json nrules = json::array();
  834. if (rules.is_array()) {
  835. for(unsigned long i=0;i<rules.size();++i) {
  836. json &rule = rules[i];
  837. if (rule.is_object()) {
  838. ZT_VirtualNetworkRule ztr;
  839. if (_parseRule(rule,ztr))
  840. nrules.push_back(_renderRule(ztr));
  841. }
  842. }
  843. }
  844. ncap["rules"] = nrules;
  845. ncaps[capId] = ncap;
  846. }
  847. }
  848. json ncapsa = json::array();
  849. for(std::map< uint64_t,json >::iterator c(ncaps.begin());c!=ncaps.end();++c)
  850. ncapsa.push_back(c->second);
  851. network["capabilities"] = ncapsa;
  852. }
  853. }
  854. if (b.count("tags")) {
  855. json &tags = b["tags"];
  856. if (tags.is_array()) {
  857. std::map< uint64_t,json > ntags;
  858. for(unsigned long i=0;i<tags.size();++i) {
  859. json &tag = tags[i];
  860. if (tag.is_object()) {
  861. json ntag = json::object();
  862. const uint64_t tagId = OSUtils::jsonInt(tag["id"],0ULL);
  863. ntag["id"] = tagId;
  864. json &dfl = tag["default"];
  865. if (dfl.is_null())
  866. ntag["default"] = dfl;
  867. else ntag["default"] = OSUtils::jsonInt(dfl,0ULL);
  868. ntags[tagId] = ntag;
  869. }
  870. }
  871. json ntagsa = json::array();
  872. for(std::map< uint64_t,json >::iterator t(ntags.begin());t!=ntags.end();++t)
  873. ntagsa.push_back(t->second);
  874. network["tags"] = ntagsa;
  875. }
  876. }
  877. } catch ( ... ) {
  878. responseBody = "{ \"message\": \"exception occurred while parsing body variables\" }";
  879. responseContentType = "application/json";
  880. return 400;
  881. }
  882. network["id"] = nwids;
  883. network["nwid"] = nwids; // legacy
  884. _removeNetworkNonPersistedFields(network);
  885. if (network != origNetwork) {
  886. json &revj = network["revision"];
  887. network["revision"] = (revj.is_number() ? ((uint64_t)revj + 1ULL) : 1ULL);
  888. _db.saveNetwork(nwid,network);
  889. // Send an update to all members of the network that are online
  890. Mutex::Lock _l(_memberStatus_m);
  891. for(auto i=_memberStatus.begin();i!=_memberStatus.end();++i) {
  892. if ((i->first.networkId == nwid)&&(i->second.online(now))&&(i->second.lastRequestMetaData))
  893. request(nwid,InetAddress(),0,i->second.identity,i->second.lastRequestMetaData);
  894. }
  895. }
  896. JSONDB::NetworkSummaryInfo ns;
  897. _db.getNetworkSummaryInfo(nwid,ns);
  898. _addNetworkNonPersistedFields(network,now,ns);
  899. responseBody = OSUtils::jsonDump(network);
  900. responseContentType = "application/json";
  901. return 200;
  902. } // else 404
  903. } // else 404
  904. } else if (path[0] == "ping") {
  905. _startThreads();
  906. _RQEntry *qe = new _RQEntry;
  907. qe->type = _RQEntry::RQENTRY_TYPE_PING;
  908. _queue.post(qe);
  909. char tmp[64];
  910. OSUtils::ztsnprintf(tmp,sizeof(tmp),"{\"clock\":%llu,\"ping\":%s}",(unsigned long long)now,OSUtils::jsonDump(b).c_str());
  911. responseBody = tmp;
  912. responseContentType = "application/json";
  913. return 200;
  914. }
  915. return 404;
  916. }
  917. unsigned int EmbeddedNetworkController::handleControlPlaneHttpDELETE(
  918. const std::vector<std::string> &path,
  919. const std::map<std::string,std::string> &urlArgs,
  920. const std::map<std::string,std::string> &headers,
  921. const std::string &body,
  922. std::string &responseBody,
  923. std::string &responseContentType)
  924. {
  925. if (path.empty())
  926. return 404;
  927. if (path[0] == "network") {
  928. if ((path.size() >= 2)&&(path[1].length() == 16)) {
  929. const uint64_t nwid = Utils::hexStrToU64(path[1].c_str());
  930. if (path.size() >= 3) {
  931. if ((path.size() == 4)&&(path[2] == "member")&&(path[3].length() == 10)) {
  932. const uint64_t address = Utils::hexStrToU64(path[3].c_str());
  933. json member = _db.eraseNetworkMember(nwid,address);
  934. {
  935. Mutex::Lock _l(_memberStatus_m);
  936. _memberStatus.erase(_MemberStatusKey(nwid,address));
  937. }
  938. if (!member.size())
  939. return 404;
  940. responseBody = OSUtils::jsonDump(member);
  941. responseContentType = "application/json";
  942. return 200;
  943. }
  944. } else {
  945. json network = _db.eraseNetwork(nwid);
  946. {
  947. Mutex::Lock _l(_memberStatus_m);
  948. for(auto i=_memberStatus.begin();i!=_memberStatus.end();) {
  949. if (i->first.networkId == nwid)
  950. _memberStatus.erase(i++);
  951. else ++i;
  952. }
  953. }
  954. if (!network.size())
  955. return 404;
  956. responseBody = OSUtils::jsonDump(network);
  957. responseContentType = "application/json";
  958. return 200;
  959. }
  960. } // else 404
  961. } // else 404
  962. return 404;
  963. }
  964. void EmbeddedNetworkController::threadMain()
  965. throw()
  966. {
  967. _RQEntry *qe = (_RQEntry *)0;
  968. while ((_running)&&(_queue.get(qe))) {
  969. try {
  970. if (qe->type == _RQEntry::RQENTRY_TYPE_REQUEST) {
  971. _request(qe->nwid,qe->fromAddr,qe->requestPacketId,qe->identity,qe->metaData);
  972. } else if (qe->type == _RQEntry::RQENTRY_TYPE_PING) {
  973. const uint64_t now = OSUtils::now();
  974. bool first = true;
  975. std::string pong("{\"memberStatus\":{");
  976. {
  977. Mutex::Lock _l(_memberStatus_m);
  978. pong.reserve(48 * (_memberStatus.size() + 1));
  979. _db.eachId([this,&pong,&now,&first](uint64_t networkId,uint64_t nodeId) {
  980. char tmp[64];
  981. uint64_t lrt = 0ULL;
  982. auto ms = this->_memberStatus.find(_MemberStatusKey(networkId,nodeId));
  983. if (ms != _memberStatus.end())
  984. lrt = ms->second.lastRequestTime;
  985. OSUtils::ztsnprintf(tmp,sizeof(tmp),"%s\"%.16llx-%.10llx\":%llu",
  986. (first) ? "" : ",",
  987. (unsigned long long)networkId,
  988. (unsigned long long)nodeId,
  989. (unsigned long long)lrt);
  990. pong.append(tmp);
  991. first = false;
  992. });
  993. }
  994. char tmp2[256];
  995. OSUtils::ztsnprintf(tmp2,sizeof(tmp2),"},\"clock\":%llu,\"startTime\":%llu}",(unsigned long long)now,(unsigned long long)_startTime);
  996. pong.append(tmp2);
  997. _db.writeRaw("pong",pong);
  998. }
  999. } catch ( ... ) {}
  1000. delete qe;
  1001. }
  1002. }
  1003. void EmbeddedNetworkController::_request(
  1004. uint64_t nwid,
  1005. const InetAddress &fromAddr,
  1006. uint64_t requestPacketId,
  1007. const Identity &identity,
  1008. const Dictionary<ZT_NETWORKCONFIG_METADATA_DICT_CAPACITY> &metaData)
  1009. {
  1010. char nwids[24];
  1011. JSONDB::NetworkSummaryInfo ns;
  1012. json network,member,origMember;
  1013. if (((!_signingId)||(!_signingId.hasPrivate()))||(_signingId.address().toInt() != (nwid >> 24))||(!_sender))
  1014. return;
  1015. const uint64_t now = OSUtils::now();
  1016. if (requestPacketId) {
  1017. Mutex::Lock _l(_memberStatus_m);
  1018. _MemberStatus &ms = _memberStatus[_MemberStatusKey(nwid,identity.address().toInt())];
  1019. if ((now - ms.lastRequestTime) <= ZT_NETCONF_MIN_REQUEST_PERIOD)
  1020. return;
  1021. ms.lastRequestTime = now;
  1022. }
  1023. OSUtils::ztsnprintf(nwids,sizeof(nwids),"%.16llx",nwid);
  1024. if (!_db.getNetworkAndMember(nwid,identity.address().toInt(),network,member,ns)) {
  1025. _sender->ncSendError(nwid,requestPacketId,identity.address(),NetworkController::NC_ERROR_OBJECT_NOT_FOUND);
  1026. return;
  1027. }
  1028. origMember = member;
  1029. const bool newMember = ((!member.is_object())||(member.size() == 0));
  1030. _initMember(member);
  1031. {
  1032. std::string haveIdStr(OSUtils::jsonString(member["identity"],""));
  1033. if (haveIdStr.length() > 0) {
  1034. // If we already know this member's identity perform a full compare. This prevents
  1035. // a "collision" from being able to auth onto our network in place of an already
  1036. // known member.
  1037. try {
  1038. if (Identity(haveIdStr.c_str()) != identity) {
  1039. _sender->ncSendError(nwid,requestPacketId,identity.address(),NetworkController::NC_ERROR_ACCESS_DENIED);
  1040. return;
  1041. }
  1042. } catch ( ... ) {
  1043. _sender->ncSendError(nwid,requestPacketId,identity.address(),NetworkController::NC_ERROR_ACCESS_DENIED);
  1044. return;
  1045. }
  1046. } else {
  1047. // If we do not yet know this member's identity, learn it.
  1048. char idtmp[1024];
  1049. member["identity"] = identity.toString(false,idtmp);
  1050. }
  1051. }
  1052. // These are always the same, but make sure they are set
  1053. {
  1054. char tmpid[128];
  1055. const std::string addrs(identity.address().toString(tmpid));
  1056. member["id"] = addrs;
  1057. member["address"] = addrs;
  1058. member["nwid"] = nwids;
  1059. }
  1060. // Determine whether and how member is authorized
  1061. const char *authorizedBy = (const char *)0;
  1062. bool autoAuthorized = false;
  1063. json autoAuthCredentialType,autoAuthCredential;
  1064. if (OSUtils::jsonBool(member["authorized"],false)) {
  1065. authorizedBy = "memberIsAuthorized";
  1066. } else if (!OSUtils::jsonBool(network["private"],true)) {
  1067. authorizedBy = "networkIsPublic";
  1068. json &ahist = member["authHistory"];
  1069. if ((!ahist.is_array())||(ahist.size() == 0))
  1070. autoAuthorized = true;
  1071. } else {
  1072. char presentedAuth[512];
  1073. if (metaData.get(ZT_NETWORKCONFIG_REQUEST_METADATA_KEY_AUTH,presentedAuth,sizeof(presentedAuth)) > 0) {
  1074. presentedAuth[511] = (char)0; // sanity check
  1075. // Check for bearer token presented by member
  1076. if ((strlen(presentedAuth) > 6)&&(!strncmp(presentedAuth,"token:",6))) {
  1077. const char *const presentedToken = presentedAuth + 6;
  1078. json &authTokens = network["authTokens"];
  1079. if (authTokens.is_array()) {
  1080. for(unsigned long i=0;i<authTokens.size();++i) {
  1081. json &token = authTokens[i];
  1082. if (token.is_object()) {
  1083. const uint64_t expires = OSUtils::jsonInt(token["expires"],0ULL);
  1084. const uint64_t maxUses = OSUtils::jsonInt(token["maxUsesPerMember"],0ULL);
  1085. std::string tstr = OSUtils::jsonString(token["token"],"");
  1086. if (((expires == 0ULL)||(expires > now))&&(tstr == presentedToken)) {
  1087. bool usable = (maxUses == 0);
  1088. if (!usable) {
  1089. uint64_t useCount = 0;
  1090. json &ahist = member["authHistory"];
  1091. if (ahist.is_array()) {
  1092. for(unsigned long j=0;j<ahist.size();++j) {
  1093. json &ah = ahist[j];
  1094. if ((OSUtils::jsonString(ah["ct"],"") == "token")&&(OSUtils::jsonString(ah["c"],"") == tstr)&&(OSUtils::jsonBool(ah["a"],false)))
  1095. ++useCount;
  1096. }
  1097. }
  1098. usable = (useCount < maxUses);
  1099. }
  1100. if (usable) {
  1101. authorizedBy = "token";
  1102. autoAuthorized = true;
  1103. autoAuthCredentialType = "token";
  1104. autoAuthCredential = tstr;
  1105. }
  1106. }
  1107. }
  1108. }
  1109. }
  1110. }
  1111. }
  1112. }
  1113. // If we auto-authorized, update member record
  1114. if ((autoAuthorized)&&(authorizedBy)) {
  1115. member["authorized"] = true;
  1116. member["lastAuthorizedTime"] = now;
  1117. json ah;
  1118. ah["a"] = true;
  1119. ah["by"] = authorizedBy;
  1120. ah["ts"] = now;
  1121. ah["ct"] = autoAuthCredentialType;
  1122. ah["c"] = autoAuthCredential;
  1123. member["authHistory"].push_back(ah);
  1124. json &revj = member["revision"];
  1125. member["revision"] = (revj.is_number() ? ((uint64_t)revj + 1ULL) : 1ULL);
  1126. }
  1127. if (authorizedBy) {
  1128. // Update version info and meta-data if authorized and if this is a genuine request
  1129. if (requestPacketId) {
  1130. const uint64_t vMajor = metaData.getUI(ZT_NETWORKCONFIG_REQUEST_METADATA_KEY_NODE_MAJOR_VERSION,0);
  1131. const uint64_t vMinor = metaData.getUI(ZT_NETWORKCONFIG_REQUEST_METADATA_KEY_NODE_MINOR_VERSION,0);
  1132. const uint64_t vRev = metaData.getUI(ZT_NETWORKCONFIG_REQUEST_METADATA_KEY_NODE_REVISION,0);
  1133. const uint64_t vProto = metaData.getUI(ZT_NETWORKCONFIG_REQUEST_METADATA_KEY_PROTOCOL_VERSION,0);
  1134. member["vMajor"] = vMajor;
  1135. member["vMinor"] = vMinor;
  1136. member["vRev"] = vRev;
  1137. member["vProto"] = vProto;
  1138. {
  1139. Mutex::Lock _l(_memberStatus_m);
  1140. _MemberStatus &ms = _memberStatus[_MemberStatusKey(nwid,identity.address().toInt())];
  1141. ms.vMajor = (int)vMajor;
  1142. ms.vMinor = (int)vMinor;
  1143. ms.vRev = (int)vRev;
  1144. ms.vProto = (int)vProto;
  1145. ms.lastRequestMetaData = metaData;
  1146. ms.identity = identity;
  1147. if (fromAddr)
  1148. ms.physicalAddr = fromAddr;
  1149. char tmpip[64];
  1150. if (ms.physicalAddr)
  1151. member["physicalAddr"] = ms.physicalAddr.toString(tmpip);
  1152. }
  1153. }
  1154. } else {
  1155. // If they are not authorized, STOP!
  1156. _removeMemberNonPersistedFields(member);
  1157. if (origMember != member)
  1158. _db.saveNetworkMember(nwid,identity.address().toInt(),member);
  1159. _sender->ncSendError(nwid,requestPacketId,identity.address(),NetworkController::NC_ERROR_ACCESS_DENIED);
  1160. return;
  1161. }
  1162. // -------------------------------------------------------------------------
  1163. // If we made it this far, they are authorized.
  1164. // -------------------------------------------------------------------------
  1165. uint64_t credentialtmd = ZT_NETWORKCONFIG_DEFAULT_CREDENTIAL_TIME_MAX_MAX_DELTA;
  1166. if (now > ns.mostRecentDeauthTime) {
  1167. // If we recently de-authorized a member, shrink credential TTL/max delta to
  1168. // be below the threshold required to exclude it. Cap this to a min/max to
  1169. // prevent jitter or absurdly large values.
  1170. const uint64_t deauthWindow = now - ns.mostRecentDeauthTime;
  1171. if (deauthWindow < ZT_NETWORKCONFIG_DEFAULT_CREDENTIAL_TIME_MIN_MAX_DELTA) {
  1172. credentialtmd = ZT_NETWORKCONFIG_DEFAULT_CREDENTIAL_TIME_MIN_MAX_DELTA;
  1173. } else if (deauthWindow < (ZT_NETWORKCONFIG_DEFAULT_CREDENTIAL_TIME_MAX_MAX_DELTA + 5000ULL)) {
  1174. credentialtmd = deauthWindow - 5000ULL;
  1175. }
  1176. }
  1177. std::auto_ptr<NetworkConfig> nc(new NetworkConfig());
  1178. nc->networkId = nwid;
  1179. nc->type = OSUtils::jsonBool(network["private"],true) ? ZT_NETWORK_TYPE_PRIVATE : ZT_NETWORK_TYPE_PUBLIC;
  1180. nc->timestamp = now;
  1181. nc->credentialTimeMaxDelta = credentialtmd;
  1182. nc->revision = OSUtils::jsonInt(network["revision"],0ULL);
  1183. nc->issuedTo = identity.address();
  1184. if (OSUtils::jsonBool(network["enableBroadcast"],true)) nc->flags |= ZT_NETWORKCONFIG_FLAG_ENABLE_BROADCAST;
  1185. if (OSUtils::jsonBool(network["allowPassiveBridging"],false)) nc->flags |= ZT_NETWORKCONFIG_FLAG_ALLOW_PASSIVE_BRIDGING;
  1186. Utils::scopy(nc->name,sizeof(nc->name),OSUtils::jsonString(network["name"],"").c_str());
  1187. nc->mtu = std::max(std::min((unsigned int)OSUtils::jsonInt(network["mtu"],ZT_DEFAULT_MTU),(unsigned int)ZT_MAX_MTU),(unsigned int)ZT_MIN_MTU);
  1188. nc->multicastLimit = (unsigned int)OSUtils::jsonInt(network["multicastLimit"],32ULL);
  1189. for(std::vector<Address>::const_iterator ab(ns.activeBridges.begin());ab!=ns.activeBridges.end();++ab)
  1190. nc->addSpecialist(*ab,ZT_NETWORKCONFIG_SPECIALIST_TYPE_ACTIVE_BRIDGE);
  1191. json &v4AssignMode = network["v4AssignMode"];
  1192. json &v6AssignMode = network["v6AssignMode"];
  1193. json &ipAssignmentPools = network["ipAssignmentPools"];
  1194. json &routes = network["routes"];
  1195. json &rules = network["rules"];
  1196. json &capabilities = network["capabilities"];
  1197. json &tags = network["tags"];
  1198. json &memberCapabilities = member["capabilities"];
  1199. json &memberTags = member["tags"];
  1200. if (metaData.getUI(ZT_NETWORKCONFIG_REQUEST_METADATA_KEY_RULES_ENGINE_REV,0) <= 0) {
  1201. // Old versions with no rules engine support get an allow everything rule.
  1202. // Since rules are enforced bidirectionally, newer versions *will* still
  1203. // enforce rules on the inbound side.
  1204. nc->ruleCount = 1;
  1205. nc->rules[0].t = ZT_NETWORK_RULE_ACTION_ACCEPT;
  1206. } else {
  1207. if (rules.is_array()) {
  1208. for(unsigned long i=0;i<rules.size();++i) {
  1209. if (nc->ruleCount >= ZT_MAX_NETWORK_RULES)
  1210. break;
  1211. if (_parseRule(rules[i],nc->rules[nc->ruleCount]))
  1212. ++nc->ruleCount;
  1213. }
  1214. }
  1215. std::map< uint64_t,json * > capsById;
  1216. if (!memberCapabilities.is_array())
  1217. memberCapabilities = json::array();
  1218. if (capabilities.is_array()) {
  1219. for(unsigned long i=0;i<capabilities.size();++i) {
  1220. json &cap = capabilities[i];
  1221. if (cap.is_object()) {
  1222. const uint64_t id = OSUtils::jsonInt(cap["id"],0ULL) & 0xffffffffULL;
  1223. capsById[id] = &cap;
  1224. if ((newMember)&&(OSUtils::jsonBool(cap["default"],false))) {
  1225. bool have = false;
  1226. for(unsigned long i=0;i<memberCapabilities.size();++i) {
  1227. if (id == (OSUtils::jsonInt(memberCapabilities[i],0ULL) & 0xffffffffULL)) {
  1228. have = true;
  1229. break;
  1230. }
  1231. }
  1232. if (!have)
  1233. memberCapabilities.push_back(id);
  1234. }
  1235. }
  1236. }
  1237. }
  1238. for(unsigned long i=0;i<memberCapabilities.size();++i) {
  1239. const uint64_t capId = OSUtils::jsonInt(memberCapabilities[i],0ULL) & 0xffffffffULL;
  1240. std::map< uint64_t,json * >::const_iterator ctmp = capsById.find(capId);
  1241. if (ctmp != capsById.end()) {
  1242. json *cap = ctmp->second;
  1243. if ((cap)&&(cap->is_object())&&(cap->size() > 0)) {
  1244. ZT_VirtualNetworkRule capr[ZT_MAX_CAPABILITY_RULES];
  1245. unsigned int caprc = 0;
  1246. json &caprj = (*cap)["rules"];
  1247. if ((caprj.is_array())&&(caprj.size() > 0)) {
  1248. for(unsigned long j=0;j<caprj.size();++j) {
  1249. if (caprc >= ZT_MAX_CAPABILITY_RULES)
  1250. break;
  1251. if (_parseRule(caprj[j],capr[caprc]))
  1252. ++caprc;
  1253. }
  1254. }
  1255. nc->capabilities[nc->capabilityCount] = Capability((uint32_t)capId,nwid,now,1,capr,caprc);
  1256. if (nc->capabilities[nc->capabilityCount].sign(_signingId,identity.address()))
  1257. ++nc->capabilityCount;
  1258. if (nc->capabilityCount >= ZT_MAX_NETWORK_CAPABILITIES)
  1259. break;
  1260. }
  1261. }
  1262. }
  1263. std::map< uint32_t,uint32_t > memberTagsById;
  1264. if (memberTags.is_array()) {
  1265. for(unsigned long i=0;i<memberTags.size();++i) {
  1266. json &t = memberTags[i];
  1267. if ((t.is_array())&&(t.size() == 2))
  1268. memberTagsById[(uint32_t)(OSUtils::jsonInt(t[0],0ULL) & 0xffffffffULL)] = (uint32_t)(OSUtils::jsonInt(t[1],0ULL) & 0xffffffffULL);
  1269. }
  1270. }
  1271. if (tags.is_array()) { // check network tags array for defaults that are not present in member tags
  1272. for(unsigned long i=0;i<tags.size();++i) {
  1273. json &t = tags[i];
  1274. if (t.is_object()) {
  1275. const uint32_t id = (uint32_t)(OSUtils::jsonInt(t["id"],0) & 0xffffffffULL);
  1276. json &dfl = t["default"];
  1277. if ((dfl.is_number())&&(memberTagsById.find(id) == memberTagsById.end())) {
  1278. memberTagsById[id] = (uint32_t)(OSUtils::jsonInt(dfl,0) & 0xffffffffULL);
  1279. json mt = json::array();
  1280. mt.push_back(id);
  1281. mt.push_back(dfl);
  1282. memberTags.push_back(mt); // add default to member tags if not present
  1283. }
  1284. }
  1285. }
  1286. }
  1287. for(std::map< uint32_t,uint32_t >::const_iterator t(memberTagsById.begin());t!=memberTagsById.end();++t) {
  1288. if (nc->tagCount >= ZT_MAX_NETWORK_TAGS)
  1289. break;
  1290. nc->tags[nc->tagCount] = Tag(nwid,now,identity.address(),t->first,t->second);
  1291. if (nc->tags[nc->tagCount].sign(_signingId))
  1292. ++nc->tagCount;
  1293. }
  1294. }
  1295. if (routes.is_array()) {
  1296. for(unsigned long i=0;i<routes.size();++i) {
  1297. if (nc->routeCount >= ZT_MAX_NETWORK_ROUTES)
  1298. break;
  1299. json &route = routes[i];
  1300. json &target = route["target"];
  1301. json &via = route["via"];
  1302. if (target.is_string()) {
  1303. const InetAddress t(target.get<std::string>().c_str());
  1304. InetAddress v;
  1305. if (via.is_string()) v.fromString(via.get<std::string>().c_str());
  1306. if ((t.ss_family == AF_INET)||(t.ss_family == AF_INET6)) {
  1307. ZT_VirtualNetworkRoute *r = &(nc->routes[nc->routeCount]);
  1308. *(reinterpret_cast<InetAddress *>(&(r->target))) = t;
  1309. if (v.ss_family == t.ss_family)
  1310. *(reinterpret_cast<InetAddress *>(&(r->via))) = v;
  1311. ++nc->routeCount;
  1312. }
  1313. }
  1314. }
  1315. }
  1316. const bool noAutoAssignIps = OSUtils::jsonBool(member["noAutoAssignIps"],false);
  1317. if ((v6AssignMode.is_object())&&(!noAutoAssignIps)) {
  1318. if ((OSUtils::jsonBool(v6AssignMode["rfc4193"],false))&&(nc->staticIpCount < ZT_MAX_ZT_ASSIGNED_ADDRESSES)) {
  1319. nc->staticIps[nc->staticIpCount++] = InetAddress::makeIpv6rfc4193(nwid,identity.address().toInt());
  1320. nc->flags |= ZT_NETWORKCONFIG_FLAG_ENABLE_IPV6_NDP_EMULATION;
  1321. }
  1322. if ((OSUtils::jsonBool(v6AssignMode["6plane"],false))&&(nc->staticIpCount < ZT_MAX_ZT_ASSIGNED_ADDRESSES)) {
  1323. nc->staticIps[nc->staticIpCount++] = InetAddress::makeIpv66plane(nwid,identity.address().toInt());
  1324. nc->flags |= ZT_NETWORKCONFIG_FLAG_ENABLE_IPV6_NDP_EMULATION;
  1325. }
  1326. }
  1327. bool haveManagedIpv4AutoAssignment = false;
  1328. bool haveManagedIpv6AutoAssignment = false; // "special" NDP-emulated address types do not count
  1329. json ipAssignments = member["ipAssignments"]; // we want to make a copy
  1330. if (ipAssignments.is_array()) {
  1331. for(unsigned long i=0;i<ipAssignments.size();++i) {
  1332. if (!ipAssignments[i].is_string())
  1333. continue;
  1334. std::string ips = ipAssignments[i];
  1335. InetAddress ip(ips.c_str());
  1336. // IP assignments are only pushed if there is a corresponding local route. We also now get the netmask bits from
  1337. // this route, ignoring the netmask bits field of the assigned IP itself. Using that was worthless and a source
  1338. // of user error / poor UX.
  1339. int routedNetmaskBits = 0;
  1340. for(unsigned int rk=0;rk<nc->routeCount;++rk) {
  1341. if ( (!nc->routes[rk].via.ss_family) && (reinterpret_cast<const InetAddress *>(&(nc->routes[rk].target))->containsAddress(ip)) )
  1342. routedNetmaskBits = reinterpret_cast<const InetAddress *>(&(nc->routes[rk].target))->netmaskBits();
  1343. }
  1344. if (routedNetmaskBits > 0) {
  1345. if (nc->staticIpCount < ZT_MAX_ZT_ASSIGNED_ADDRESSES) {
  1346. ip.setPort(routedNetmaskBits);
  1347. nc->staticIps[nc->staticIpCount++] = ip;
  1348. }
  1349. if (ip.ss_family == AF_INET)
  1350. haveManagedIpv4AutoAssignment = true;
  1351. else if (ip.ss_family == AF_INET6)
  1352. haveManagedIpv6AutoAssignment = true;
  1353. }
  1354. }
  1355. } else {
  1356. ipAssignments = json::array();
  1357. }
  1358. if ( (ipAssignmentPools.is_array()) && ((v6AssignMode.is_object())&&(OSUtils::jsonBool(v6AssignMode["zt"],false))) && (!haveManagedIpv6AutoAssignment) && (!noAutoAssignIps) ) {
  1359. for(unsigned long p=0;((p<ipAssignmentPools.size())&&(!haveManagedIpv6AutoAssignment));++p) {
  1360. json &pool = ipAssignmentPools[p];
  1361. if (pool.is_object()) {
  1362. InetAddress ipRangeStart(OSUtils::jsonString(pool["ipRangeStart"],"").c_str());
  1363. InetAddress ipRangeEnd(OSUtils::jsonString(pool["ipRangeEnd"],"").c_str());
  1364. if ( (ipRangeStart.ss_family == AF_INET6) && (ipRangeEnd.ss_family == AF_INET6) ) {
  1365. uint64_t s[2],e[2],x[2],xx[2];
  1366. memcpy(s,ipRangeStart.rawIpData(),16);
  1367. memcpy(e,ipRangeEnd.rawIpData(),16);
  1368. s[0] = Utils::ntoh(s[0]);
  1369. s[1] = Utils::ntoh(s[1]);
  1370. e[0] = Utils::ntoh(e[0]);
  1371. e[1] = Utils::ntoh(e[1]);
  1372. x[0] = s[0];
  1373. x[1] = s[1];
  1374. for(unsigned int trialCount=0;trialCount<1000;++trialCount) {
  1375. if ((trialCount == 0)&&(e[1] > s[1])&&((e[1] - s[1]) >= 0xffffffffffULL)) {
  1376. // First see if we can just cram a ZeroTier ID into the higher 64 bits. If so do that.
  1377. xx[0] = Utils::hton(x[0]);
  1378. xx[1] = Utils::hton(x[1] + identity.address().toInt());
  1379. } else {
  1380. // Otherwise pick random addresses -- this technically doesn't explore the whole range if the lower 64 bit range is >= 1 but that won't matter since that would be huge anyway
  1381. Utils::getSecureRandom((void *)xx,16);
  1382. if ((e[0] > s[0]))
  1383. xx[0] %= (e[0] - s[0]);
  1384. else xx[0] = 0;
  1385. if ((e[1] > s[1]))
  1386. xx[1] %= (e[1] - s[1]);
  1387. else xx[1] = 0;
  1388. xx[0] = Utils::hton(x[0] + xx[0]);
  1389. xx[1] = Utils::hton(x[1] + xx[1]);
  1390. }
  1391. InetAddress ip6((const void *)xx,16,0);
  1392. // Check if this IP is within a local-to-Ethernet routed network
  1393. int routedNetmaskBits = 0;
  1394. for(unsigned int rk=0;rk<nc->routeCount;++rk) {
  1395. if ( (!nc->routes[rk].via.ss_family) && (nc->routes[rk].target.ss_family == AF_INET6) && (reinterpret_cast<const InetAddress *>(&(nc->routes[rk].target))->containsAddress(ip6)) )
  1396. routedNetmaskBits = reinterpret_cast<const InetAddress *>(&(nc->routes[rk].target))->netmaskBits();
  1397. }
  1398. // If it's routed, then try to claim and assign it and if successful end loop
  1399. if ( (routedNetmaskBits > 0) && (!std::binary_search(ns.allocatedIps.begin(),ns.allocatedIps.end(),ip6)) ) {
  1400. char tmpip[64];
  1401. ipAssignments.push_back(ip6.toIpString(tmpip));
  1402. member["ipAssignments"] = ipAssignments;
  1403. ip6.setPort((unsigned int)routedNetmaskBits);
  1404. if (nc->staticIpCount < ZT_MAX_ZT_ASSIGNED_ADDRESSES)
  1405. nc->staticIps[nc->staticIpCount++] = ip6;
  1406. haveManagedIpv6AutoAssignment = true;
  1407. break;
  1408. }
  1409. }
  1410. }
  1411. }
  1412. }
  1413. }
  1414. if ( (ipAssignmentPools.is_array()) && ((v4AssignMode.is_object())&&(OSUtils::jsonBool(v4AssignMode["zt"],false))) && (!haveManagedIpv4AutoAssignment) && (!noAutoAssignIps) ) {
  1415. for(unsigned long p=0;((p<ipAssignmentPools.size())&&(!haveManagedIpv4AutoAssignment));++p) {
  1416. json &pool = ipAssignmentPools[p];
  1417. if (pool.is_object()) {
  1418. InetAddress ipRangeStartIA(OSUtils::jsonString(pool["ipRangeStart"],"").c_str());
  1419. InetAddress ipRangeEndIA(OSUtils::jsonString(pool["ipRangeEnd"],"").c_str());
  1420. if ( (ipRangeStartIA.ss_family == AF_INET) && (ipRangeEndIA.ss_family == AF_INET) ) {
  1421. uint32_t ipRangeStart = Utils::ntoh((uint32_t)(reinterpret_cast<struct sockaddr_in *>(&ipRangeStartIA)->sin_addr.s_addr));
  1422. uint32_t ipRangeEnd = Utils::ntoh((uint32_t)(reinterpret_cast<struct sockaddr_in *>(&ipRangeEndIA)->sin_addr.s_addr));
  1423. if ((ipRangeEnd < ipRangeStart)||(ipRangeStart == 0))
  1424. continue;
  1425. uint32_t ipRangeLen = ipRangeEnd - ipRangeStart;
  1426. // Start with the LSB of the member's address
  1427. uint32_t ipTrialCounter = (uint32_t)(identity.address().toInt() & 0xffffffff);
  1428. for(uint32_t k=ipRangeStart,trialCount=0;((k<=ipRangeEnd)&&(trialCount < 1000));++k,++trialCount) {
  1429. uint32_t ip = (ipRangeLen > 0) ? (ipRangeStart + (ipTrialCounter % ipRangeLen)) : ipRangeStart;
  1430. ++ipTrialCounter;
  1431. if ((ip & 0x000000ff) == 0x000000ff)
  1432. continue; // don't allow addresses that end in .255
  1433. // Check if this IP is within a local-to-Ethernet routed network
  1434. int routedNetmaskBits = -1;
  1435. for(unsigned int rk=0;rk<nc->routeCount;++rk) {
  1436. if (nc->routes[rk].target.ss_family == AF_INET) {
  1437. uint32_t targetIp = Utils::ntoh((uint32_t)(reinterpret_cast<const struct sockaddr_in *>(&(nc->routes[rk].target))->sin_addr.s_addr));
  1438. int targetBits = Utils::ntoh((uint16_t)(reinterpret_cast<const struct sockaddr_in *>(&(nc->routes[rk].target))->sin_port));
  1439. if ((ip & (0xffffffff << (32 - targetBits))) == targetIp) {
  1440. routedNetmaskBits = targetBits;
  1441. break;
  1442. }
  1443. }
  1444. }
  1445. // If it's routed, then try to claim and assign it and if successful end loop
  1446. const InetAddress ip4(Utils::hton(ip),0);
  1447. if ( (routedNetmaskBits > 0) && (!std::binary_search(ns.allocatedIps.begin(),ns.allocatedIps.end(),ip4)) ) {
  1448. char tmpip[64];
  1449. ipAssignments.push_back(ip4.toIpString(tmpip));
  1450. member["ipAssignments"] = ipAssignments;
  1451. if (nc->staticIpCount < ZT_MAX_ZT_ASSIGNED_ADDRESSES) {
  1452. struct sockaddr_in *const v4ip = reinterpret_cast<struct sockaddr_in *>(&(nc->staticIps[nc->staticIpCount++]));
  1453. v4ip->sin_family = AF_INET;
  1454. v4ip->sin_port = Utils::hton((uint16_t)routedNetmaskBits);
  1455. v4ip->sin_addr.s_addr = Utils::hton(ip);
  1456. }
  1457. haveManagedIpv4AutoAssignment = true;
  1458. break;
  1459. }
  1460. }
  1461. }
  1462. }
  1463. }
  1464. }
  1465. // Issue a certificate of ownership for all static IPs
  1466. if (nc->staticIpCount) {
  1467. nc->certificatesOfOwnership[0] = CertificateOfOwnership(nwid,now,identity.address(),1);
  1468. for(unsigned int i=0;i<nc->staticIpCount;++i)
  1469. nc->certificatesOfOwnership[0].addThing(nc->staticIps[i]);
  1470. nc->certificatesOfOwnership[0].sign(_signingId);
  1471. nc->certificateOfOwnershipCount = 1;
  1472. }
  1473. CertificateOfMembership com(now,credentialtmd,nwid,identity.address());
  1474. if (com.sign(_signingId)) {
  1475. nc->com = com;
  1476. } else {
  1477. _sender->ncSendError(nwid,requestPacketId,identity.address(),NetworkController::NC_ERROR_INTERNAL_SERVER_ERROR);
  1478. return;
  1479. }
  1480. _removeMemberNonPersistedFields(member);
  1481. if (member != origMember)
  1482. _db.saveNetworkMember(nwid,identity.address().toInt(),member);
  1483. _sender->ncSendConfig(nwid,requestPacketId,identity.address(),*(nc.get()),metaData.getUI(ZT_NETWORKCONFIG_REQUEST_METADATA_KEY_VERSION,0) < 6);
  1484. }
  1485. } // namespace ZeroTier