SqliteNetworkController.cpp 42 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944
  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. * --
  19. *
  20. * ZeroTier may be used and distributed under the terms of the GPLv3, which
  21. * are available at: http://www.gnu.org/licenses/gpl-3.0.html
  22. *
  23. * If you would like to embed ZeroTier into a commercial application or
  24. * redistribute it in a modified binary form, please contact ZeroTier Networks
  25. * LLC. Start here: http://www.zerotier.com/
  26. */
  27. #include <stdint.h>
  28. #include <stdio.h>
  29. #include <stdlib.h>
  30. #include <string.h>
  31. #include <time.h>
  32. #include <sys/time.h>
  33. #include <sys/types.h>
  34. #include <algorithm>
  35. #include <utility>
  36. #include <stdexcept>
  37. #include <set>
  38. #include "../include/ZeroTierOne.h"
  39. #include "../node/Constants.hpp"
  40. #include "../ext/json-parser/json.h"
  41. #include "SqliteNetworkController.hpp"
  42. #include "../node/Utils.hpp"
  43. #include "../node/CertificateOfMembership.hpp"
  44. #include "../node/NetworkConfig.hpp"
  45. #include "../node/InetAddress.hpp"
  46. #include "../node/MAC.hpp"
  47. #include "../node/Address.hpp"
  48. #include "../osdep/OSUtils.hpp"
  49. // Include ZT_NETCONF_SCHEMA_SQL constant to init database
  50. #include "schema.sql.c"
  51. // Stored in database as schemaVersion key in Config.
  52. // If not present, database is assumed to be empty and at the current schema version
  53. // and this key/value is added automatically.
  54. #define ZT_NETCONF_SQLITE_SCHEMA_VERSION 1
  55. #define ZT_NETCONF_SQLITE_SCHEMA_VERSION_STR "1"
  56. // Maximum age in ms for a cached netconf before we regenerate anyway (one hour)
  57. #define ZT_CACHED_NETCONF_MAX_AGE (60 * 60 * 1000)
  58. namespace ZeroTier {
  59. namespace {
  60. static std::string _jsonEscape(const char *s)
  61. {
  62. if (!s)
  63. return std::string();
  64. std::string buf;
  65. for(const char *p=s;(*p);++p) {
  66. switch(*p) {
  67. case '\t': buf.append("\\t"); break;
  68. case '\b': buf.append("\\b"); break;
  69. case '\r': buf.append("\\r"); break;
  70. case '\n': buf.append("\\n"); break;
  71. case '\f': buf.append("\\f"); break;
  72. case '"': buf.append("\\\""); break;
  73. case '\\': buf.append("\\\\"); break;
  74. case '/': buf.append("\\/"); break;
  75. default: buf.push_back(*p); break;
  76. }
  77. }
  78. return buf;
  79. }
  80. static std::string _jsonEscape(const std::string &s) { return _jsonEscape(s.c_str()); }
  81. struct MemberRecord {
  82. int64_t rowid;
  83. char nodeId[16];
  84. int cachedNetconfBytes;
  85. const void *cachedNetconf;
  86. uint64_t cachedNetconfRevision;
  87. uint64_t cachedNetconfTimestamp;
  88. uint64_t clientReportedRevision;
  89. bool authorized;
  90. bool activeBridge;
  91. };
  92. struct NetworkRecord {
  93. char id[24];
  94. const char *name;
  95. const char *v4AssignMode;
  96. const char *v6AssignMode;
  97. bool isPrivate;
  98. bool enableBroadcast;
  99. bool allowPassiveBridging;
  100. int multicastLimit;
  101. uint64_t creationTime;
  102. uint64_t revision;
  103. };
  104. } // anonymous namespace
  105. SqliteNetworkController::SqliteNetworkController(const char *dbPath) :
  106. _dbPath(dbPath),
  107. _db((sqlite3 *)0)
  108. {
  109. if (sqlite3_open_v2(dbPath,&_db,SQLITE_OPEN_READWRITE|SQLITE_OPEN_CREATE,(const char *)0) != SQLITE_OK)
  110. throw std::runtime_error("SqliteNetworkController cannot open database file");
  111. sqlite3_busy_timeout(_db,10000);
  112. sqlite3_stmt *s = (sqlite3_stmt *)0;
  113. if ((sqlite3_prepare_v2(_db,"SELECT v FROM Config WHERE k = 'schemaVersion';",-1,&s,(const char **)0) == SQLITE_OK)&&(s)) {
  114. int schemaVersion = -1234;
  115. if (sqlite3_step(s) == SQLITE_ROW) {
  116. schemaVersion = sqlite3_column_int(s,0);
  117. }
  118. sqlite3_finalize(s);
  119. if (schemaVersion == -1234) {
  120. sqlite3_close(_db);
  121. throw std::runtime_error("SqliteNetworkController schemaVersion not found in Config table (init failure?)");
  122. } else if (schemaVersion != ZT_NETCONF_SQLITE_SCHEMA_VERSION) {
  123. // Note -- this will eventually run auto-upgrades so this isn't how it'll work going forward
  124. sqlite3_close(_db);
  125. throw std::runtime_error("SqliteNetworkController database schema version mismatch");
  126. }
  127. } else {
  128. // Prepare statement will fail if Config table doesn't exist, which means our DB
  129. // needs to be initialized.
  130. if (sqlite3_exec(_db,ZT_NETCONF_SCHEMA_SQL"INSERT INTO Config (k,v) VALUES ('schemaVersion',"ZT_NETCONF_SQLITE_SCHEMA_VERSION_STR");",0,0,0) != SQLITE_OK) {
  131. sqlite3_close(_db);
  132. throw std::runtime_error("SqliteNetworkController cannot initialize database and/or insert schemaVersion into Config table");
  133. }
  134. }
  135. if (
  136. (sqlite3_prepare_v2(_db,"SELECT name,private,enableBroadcast,allowPassiveBridging,v4AssignMode,v6AssignMode,multicastLimit,creationTime,revision FROM Network WHERE id = ?",-1,&_sGetNetworkById,(const char **)0) != SQLITE_OK)
  137. ||(sqlite3_prepare_v2(_db,"SELECT rowid,cachedNetconf,cachedNetconfRevision,cachedNetconfTimestamp,clientReportedRevision,authorized,activeBridge FROM Member WHERE networkId = ? AND nodeId = ?",-1,&_sGetMember,(const char **)0) != SQLITE_OK)
  138. ||(sqlite3_prepare_v2(_db,"INSERT INTO Member (networkId,nodeId,cachedNetconfRevision,clientReportedRevision,authorized,activeBridge) VALUES (?,?,0,0,?,0)",-1,&_sCreateMember,(const char **)0) != SQLITE_OK)
  139. ||(sqlite3_prepare_v2(_db,"SELECT identity FROM Node WHERE id = ?",-1,&_sGetNodeIdentity,(const char **)0) != SQLITE_OK)
  140. ||(sqlite3_prepare_v2(_db,"INSERT INTO Node (id,identity,lastAt,lastSeen,firstSeen) VALUES (?,?,?,?,?)",-1,&_sCreateNode,(const char **)0) != SQLITE_OK)
  141. ||(sqlite3_prepare_v2(_db,"UPDATE Node SET lastAt = ?,lastSeen = ? WHERE id = ?",-1,&_sUpdateNode,(const char **)0) != SQLITE_OK)
  142. ||(sqlite3_prepare_v2(_db,"UPDATE Node SET lastSeen = ? WHERE id = ?",-1,&_sUpdateNode2,(const char **)0) != SQLITE_OK)
  143. ||(sqlite3_prepare_v2(_db,"UPDATE Member SET clientReportedRevision = ? WHERE rowid = ?",-1,&_sUpdateMemberClientReportedRevision,(const char **)0) != SQLITE_OK)
  144. ||(sqlite3_prepare_v2(_db,"SELECT etherType FROM Rule WHERE networkId = ? AND \"action\" = 'accept'",-1,&_sGetEtherTypesFromRuleTable,(const char **)0) != SQLITE_OK)
  145. ||(sqlite3_prepare_v2(_db,"SELECT mgMac,mgAdi,preload,maxBalance,accrual FROM MulticastRate WHERE networkId = ?",-1,&_sGetMulticastRates,(const char **)0) != SQLITE_OK)
  146. ||(sqlite3_prepare_v2(_db,"SELECT nodeId FROM Member WHERE networkId = ? AND activeBridge > 0 AND authorized > 0",-1,&_sGetActiveBridges,(const char **)0) != SQLITE_OK)
  147. ||(sqlite3_prepare_v2(_db,"SELECT ip,ipNetmaskBits FROM IpAssignment WHERE networkId = ? AND nodeId = ? AND ipVersion = ?",-1,&_sGetIpAssignmentsForNode,(const char **)0) != SQLITE_OK)
  148. ||(sqlite3_prepare_v2(_db,"SELECT ipNetwork,ipNetmaskBits FROM IpAssignmentPool WHERE networkId = ? AND ipVersion = ? AND active > 0",-1,&_sGetIpAssignmentPools,(const char **)0) != SQLITE_OK)
  149. ||(sqlite3_prepare_v2(_db,"SELECT 1 FROM IpAssignment WHERE networkId = ? AND ip = ? AND ipVersion = ?",-1,&_sCheckIfIpIsAllocated,(const char **)0) != SQLITE_OK)
  150. ||(sqlite3_prepare_v2(_db,"INSERT INTO IpAssignment (networkId,nodeId,ip,ipNetmaskBits,ipVersion) VALUES (?,?,?,?,?)",-1,&_sAllocateIp,(const char **)0) != SQLITE_OK)
  151. ||(sqlite3_prepare_v2(_db,"UPDATE Member SET cachedNetconf = ?,cachedNetconfRevision = ? WHERE rowid = ?",-1,&_sCacheNetconf,(const char **)0) != SQLITE_OK)
  152. ||(sqlite3_prepare_v2(_db,"SELECT nodeId,phyAddress FROM Relay WHERE networkId = ?",-1,&_sGetRelays,(const char **)0) != SQLITE_OK)
  153. ||(sqlite3_prepare_v2(_db,"SELECT id FROM Network ORDER BY id ASC",-1,&_sListNetworks,(const char **)0) != SQLITE_OK)
  154. ||(sqlite3_prepare_v2(_db,"SELECT m.authorized,m.activeBridge,n.id,n.lastAt,n.lastSeen,n.firstSeen FROM Member AS m,Node AS n WHERE m.networkId = ? AND n.id = m.nodeId ORDER BY n.id ASC",-1,&_sListNetworkMembers,(const char **)0) != SQLITE_OK)
  155. ||(sqlite3_prepare_v2(_db,"SELECT m.authorized,m.activeBridge,n.identity,n.lastAt,n.lastSeen,n.firstSeen FROM Member AS m,Node AS n WHERE m.networkId = ? AND m.nodeId = ?",-1,&_sGetMember2,(const char **)0) != SQLITE_OK)
  156. ||(sqlite3_prepare_v2(_db,"SELECT ipNetwork,ipNetmaskBits,ipVersion,active FROM IpAssignmentPool WHERE networkId = ? ORDER BY ipNetwork ASC",-1,&_sGetIpAssignmentPools2,(const char **)0) != SQLITE_OK)
  157. ||(sqlite3_prepare_v2(_db,"SELECT ruleId,nodeId,vlanId,vlanPcp,etherType,macSource,macDest,ipSource,ipDest,ipTos,ipProtocol,ipSourcePort,ipDestPort,\"action\" FROM Rule WHERE networkId = ? ORDER BY ruleId ASC",-1,&_sListRules,(const char **)0) != SQLITE_OK)
  158. ||(sqlite3_prepare_v2(_db,"DELETE FROM Rule WHERE networkId = ? AND ruleId = ?",-1,&_sDeleteRule,(const char **)0) != SQLITE_OK)
  159. ||(sqlite3_prepare_v2(_db,"INSERT INTO Rule (networkId,ruleId,nodeId,vlanId,vlanPcP,etherType,macSource,macDest,ipSource,ipDest,ipTos,ipProtocol,ipSourcePort,ipDestPort,\"action\") VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)",-1,&_sCreateRule,(const char **)0) != SQLITE_OK)
  160. ||(sqlite3_prepare_v2(_db,"INSERT INTO Network (networkId,name,creationTime,revision) VALUES (?,?,?,1)",-1,&_sCreateNetwork,(const char **)0) != SQLITE_OK)
  161. ||(sqlite3_prepare_v2(_db,"UPDATE Network SET ? = ? WHERE networkId = ?",-1,&_sUpdateNetworkField,(const char **)0) != SQLITE_OK)
  162. ||(sqlite3_prepare_v2(_db,"SELECT revision FROM Network WHERE id = ?",-1,&_sGetNetworkRevision,(const char **)0) != SQLITE_OK)
  163. ) {
  164. sqlite3_close(_db);
  165. throw std::runtime_error("SqliteNetworkController unable to initialize one or more prepared statements");
  166. }
  167. }
  168. SqliteNetworkController::~SqliteNetworkController()
  169. {
  170. Mutex::Lock _l(_lock);
  171. if (_db) {
  172. sqlite3_finalize(_sGetNetworkById);
  173. sqlite3_finalize(_sGetMember);
  174. sqlite3_finalize(_sCreateMember);
  175. sqlite3_finalize(_sGetNodeIdentity);
  176. sqlite3_finalize(_sCreateNode);
  177. sqlite3_finalize(_sUpdateNode);
  178. sqlite3_finalize(_sUpdateNode2);
  179. sqlite3_finalize(_sUpdateMemberClientReportedRevision);
  180. sqlite3_finalize(_sGetEtherTypesFromRuleTable);
  181. sqlite3_finalize(_sGetMulticastRates);
  182. sqlite3_finalize(_sGetActiveBridges);
  183. sqlite3_finalize(_sGetIpAssignmentsForNode);
  184. sqlite3_finalize(_sGetIpAssignmentPools);
  185. sqlite3_finalize(_sCheckIfIpIsAllocated);
  186. sqlite3_finalize(_sAllocateIp);
  187. sqlite3_finalize(_sCacheNetconf);
  188. sqlite3_finalize(_sGetRelays);
  189. sqlite3_finalize(_sListNetworks);
  190. sqlite3_finalize(_sListNetworkMembers);
  191. sqlite3_finalize(_sGetMember2);
  192. sqlite3_finalize(_sGetIpAssignmentPools2);
  193. sqlite3_finalize(_sListRules);
  194. sqlite3_finalize(_sDeleteRule);
  195. sqlite3_finalize(_sCreateRule);
  196. sqlite3_finalize(_sCreateNetwork);
  197. sqlite3_finalize(_sUpdateNetworkField);
  198. sqlite3_finalize(_sGetNetworkRevision);
  199. sqlite3_close(_db);
  200. }
  201. }
  202. NetworkController::ResultCode SqliteNetworkController::doNetworkConfigRequest(const InetAddress &fromAddr,const Identity &signingId,const Identity &identity,uint64_t nwid,const Dictionary &metaData,uint64_t haveRevision,Dictionary &netconf)
  203. {
  204. Mutex::Lock _l(_lock);
  205. // Note: we can't reuse prepared statements that return const char * pointers without
  206. // making our own copy in e.g. a std::string first.
  207. if ((!signingId)||(!signingId.hasPrivate())) {
  208. netconf["error"] = "signing identity invalid or lacks private key";
  209. return NetworkController::NETCONF_QUERY_INTERNAL_SERVER_ERROR;
  210. }
  211. NetworkRecord network;
  212. memset(&network,0,sizeof(network));
  213. Utils::snprintf(network.id,sizeof(network.id),"%.16llx",(unsigned long long)nwid);
  214. MemberRecord member;
  215. memset(&member,0,sizeof(member));
  216. Utils::snprintf(member.nodeId,sizeof(member.nodeId),"%.10llx",(unsigned long long)identity.address().toInt());
  217. // Create/update Node record and check identity fully -- identities are first-come-first-claim
  218. sqlite3_reset(_sGetNodeIdentity);
  219. sqlite3_bind_text(_sGetNodeIdentity,1,member.nodeId,10,SQLITE_STATIC);
  220. if (sqlite3_step(_sGetNodeIdentity) == SQLITE_ROW) {
  221. try {
  222. Identity alreadyKnownIdentity((const char *)sqlite3_column_text(_sGetNodeIdentity,0));
  223. if (alreadyKnownIdentity == identity) {
  224. char lastSeen[64];
  225. Utils::snprintf(lastSeen,sizeof(lastSeen),"%llu",(unsigned long long)OSUtils::now());
  226. if (fromAddr) {
  227. std::string lastAt(fromAddr.toString());
  228. sqlite3_reset(_sUpdateNode);
  229. sqlite3_bind_text(_sUpdateNode,1,lastAt.c_str(),-1,SQLITE_STATIC);
  230. sqlite3_bind_text(_sUpdateNode,2,lastSeen,-1,SQLITE_STATIC);
  231. sqlite3_bind_text(_sUpdateNode,3,member.nodeId,10,SQLITE_STATIC);
  232. sqlite3_step(_sUpdateNode);
  233. } else { // fromAddr is empty, which means this was a relayed packet -- so don't update lastAt
  234. sqlite3_reset(_sUpdateNode2);
  235. sqlite3_bind_text(_sUpdateNode2,1,lastSeen,-1,SQLITE_STATIC);
  236. sqlite3_bind_text(_sUpdateNode2,2,member.nodeId,10,SQLITE_STATIC);
  237. sqlite3_step(_sUpdateNode2);
  238. }
  239. } else {
  240. return NetworkController::NETCONF_QUERY_ACCESS_DENIED;
  241. }
  242. } catch ( ... ) { // identity stored in database is not valid or is NULL
  243. return NetworkController::NETCONF_QUERY_ACCESS_DENIED;
  244. }
  245. } else {
  246. std::string idstr(identity.toString(false));
  247. std::string lastAt;
  248. if (fromAddr)
  249. lastAt = fromAddr.toString();
  250. char lastSeen[64];
  251. Utils::snprintf(lastSeen,sizeof(lastSeen),"%llu",(unsigned long long)OSUtils::now());
  252. sqlite3_reset(_sCreateNode);
  253. sqlite3_bind_text(_sCreateNode,1,member.nodeId,10,SQLITE_STATIC);
  254. sqlite3_bind_text(_sCreateNode,2,idstr.c_str(),-1,SQLITE_STATIC);
  255. sqlite3_bind_text(_sCreateNode,3,lastAt.c_str(),-1,SQLITE_STATIC);
  256. sqlite3_bind_text(_sCreateNode,4,lastSeen,-1,SQLITE_STATIC);
  257. sqlite3_bind_text(_sCreateNode,5,lastSeen,-1,SQLITE_STATIC);
  258. if (sqlite3_step(_sCreateNode) != SQLITE_DONE) {
  259. netconf["error"] = "unable to create new node record";
  260. return NetworkController::NETCONF_QUERY_INTERNAL_SERVER_ERROR;
  261. }
  262. }
  263. // Fetch Network record
  264. sqlite3_reset(_sGetNetworkById);
  265. sqlite3_bind_text(_sGetNetworkById,1,network.id,16,SQLITE_STATIC);
  266. if (sqlite3_step(_sGetNetworkById) == SQLITE_ROW) {
  267. network.name = (const char *)sqlite3_column_text(_sGetNetworkById,0);
  268. network.isPrivate = (sqlite3_column_int(_sGetNetworkById,1) > 0);
  269. network.enableBroadcast = (sqlite3_column_int(_sGetNetworkById,2) > 0);
  270. network.allowPassiveBridging = (sqlite3_column_int(_sGetNetworkById,3) > 0);
  271. network.v4AssignMode = (const char *)sqlite3_column_text(_sGetNetworkById,4);
  272. network.v6AssignMode = (const char *)sqlite3_column_text(_sGetNetworkById,5);
  273. network.multicastLimit = sqlite3_column_int(_sGetNetworkById,6);
  274. network.creationTime = (uint64_t)sqlite3_column_int64(_sGetNetworkById,7);
  275. network.revision = (uint64_t)sqlite3_column_int64(_sGetNetworkById,8);
  276. } else return NetworkController::NETCONF_QUERY_OBJECT_NOT_FOUND;
  277. // Fetch Member record
  278. bool foundMember = false;
  279. sqlite3_reset(_sGetMember);
  280. sqlite3_bind_text(_sGetMember,1,network.id,16,SQLITE_STATIC);
  281. sqlite3_bind_text(_sGetMember,2,member.nodeId,10,SQLITE_STATIC);
  282. if (sqlite3_step(_sGetMember) == SQLITE_ROW) {
  283. foundMember = true;
  284. member.rowid = (int64_t)sqlite3_column_int64(_sGetMember,0);
  285. member.cachedNetconfBytes = sqlite3_column_bytes(_sGetMember,1);
  286. member.cachedNetconf = sqlite3_column_blob(_sGetMember,1);
  287. member.cachedNetconfRevision = (uint64_t)sqlite3_column_int64(_sGetMember,2);
  288. member.cachedNetconfTimestamp = (uint64_t)sqlite3_column_int64(_sGetMember,3);
  289. member.clientReportedRevision = (uint64_t)sqlite3_column_int64(_sGetMember,4);
  290. member.authorized = (sqlite3_column_int(_sGetMember,5) > 0);
  291. member.activeBridge = (sqlite3_column_int(_sGetMember,6) > 0);
  292. }
  293. // Create Member record for unknown nodes, auto-authorizing if network is public
  294. if (!foundMember) {
  295. member.cachedNetconfBytes = 0;
  296. member.cachedNetconfRevision = 0;
  297. member.clientReportedRevision = 0;
  298. member.authorized = (network.isPrivate ? false : true);
  299. member.activeBridge = false;
  300. sqlite3_reset(_sCreateMember);
  301. sqlite3_bind_text(_sCreateMember,1,network.id,16,SQLITE_STATIC);
  302. sqlite3_bind_text(_sCreateMember,2,member.nodeId,10,SQLITE_STATIC);
  303. sqlite3_bind_int(_sCreateMember,3,(member.authorized ? 0 : 1));
  304. if ( (sqlite3_step(_sCreateMember) != SQLITE_DONE) && ((member.rowid = (int64_t)sqlite3_last_insert_rowid(_db)) > 0) ) {
  305. netconf["error"] = "unable to create new member record";
  306. return NetworkController::NETCONF_QUERY_INTERNAL_SERVER_ERROR;
  307. }
  308. }
  309. // Check member authorization
  310. if (!member.authorized)
  311. return NetworkController::NETCONF_QUERY_ACCESS_DENIED;
  312. // Update client's currently reported haveRevision in Member record
  313. if (member.rowid > 0) {
  314. sqlite3_reset(_sUpdateMemberClientReportedRevision);
  315. sqlite3_bind_int64(_sUpdateMemberClientReportedRevision,1,(sqlite3_int64)haveRevision);
  316. sqlite3_bind_int64(_sUpdateMemberClientReportedRevision,2,member.rowid);
  317. sqlite3_step(_sUpdateMemberClientReportedRevision);
  318. }
  319. // If netconf is unchanged from client reported revision, just tell client they're up to date
  320. if ((haveRevision > 0)&&(haveRevision == network.revision))
  321. return NetworkController::NETCONF_QUERY_OK_BUT_NOT_NEWER;
  322. // Generate or retrieve cached netconf
  323. netconf.clear();
  324. if ( (member.cachedNetconfBytes > 0)&&
  325. (member.cachedNetconfRevision == network.revision)&&
  326. ((OSUtils::now() - member.cachedNetconfTimestamp) < ZT_CACHED_NETCONF_MAX_AGE) ) {
  327. // Use cached copy
  328. std::string tmp((const char *)member.cachedNetconf,member.cachedNetconfBytes);
  329. netconf.fromString(tmp);
  330. } else {
  331. // Create and sign a new netconf, and save in database to re-use in the future
  332. char tss[24],rs[24];
  333. Utils::snprintf(tss,sizeof(tss),"%.16llx",(unsigned long long)OSUtils::now());
  334. Utils::snprintf(rs,sizeof(rs),"%.16llx",(unsigned long long)network.revision);
  335. netconf[ZT_NETWORKCONFIG_DICT_KEY_TIMESTAMP] = tss;
  336. netconf[ZT_NETWORKCONFIG_DICT_KEY_REVISION] = rs;
  337. netconf[ZT_NETWORKCONFIG_DICT_KEY_NETWORK_ID] = network.id;
  338. netconf[ZT_NETWORKCONFIG_DICT_KEY_ISSUED_TO] = member.nodeId;
  339. netconf[ZT_NETWORKCONFIG_DICT_KEY_PRIVATE] = network.isPrivate ? "1" : "0";
  340. netconf[ZT_NETWORKCONFIG_DICT_KEY_NAME] = (network.name) ? network.name : "";
  341. netconf[ZT_NETWORKCONFIG_DICT_KEY_ENABLE_BROADCAST] = network.enableBroadcast ? "1" : "0";
  342. netconf[ZT_NETWORKCONFIG_DICT_KEY_ALLOW_PASSIVE_BRIDGING] = network.allowPassiveBridging ? "1" : "0";
  343. {
  344. std::vector<int> allowedEtherTypes;
  345. sqlite3_reset(_sGetEtherTypesFromRuleTable);
  346. sqlite3_bind_text(_sGetEtherTypesFromRuleTable,1,network.id,16,SQLITE_STATIC);
  347. while (sqlite3_step(_sGetEtherTypesFromRuleTable) == SQLITE_ROW) {
  348. int et = sqlite3_column_int(_sGetEtherTypesFromRuleTable,0);
  349. if ((et >= 0)&&(et <= 0xffff))
  350. allowedEtherTypes.push_back(et);
  351. }
  352. std::sort(allowedEtherTypes.begin(),allowedEtherTypes.end());
  353. std::unique(allowedEtherTypes.begin(),allowedEtherTypes.end());
  354. std::string allowedEtherTypesCsv;
  355. for(std::vector<int>::const_iterator i(allowedEtherTypes.begin());i!=allowedEtherTypes.end();++i) {
  356. if (allowedEtherTypesCsv.length())
  357. allowedEtherTypesCsv.push_back(',');
  358. char tmp[16];
  359. Utils::snprintf(tmp,sizeof(tmp),"%.4x",(unsigned int)*i);
  360. allowedEtherTypesCsv.append(tmp);
  361. }
  362. netconf[ZT_NETWORKCONFIG_DICT_KEY_ALLOWED_ETHERNET_TYPES] = allowedEtherTypesCsv;
  363. }
  364. {
  365. std::string multicastRates;
  366. sqlite3_reset(_sGetMulticastRates);
  367. sqlite3_bind_text(_sGetMulticastRates,1,network.id,16,SQLITE_STATIC);
  368. while (sqlite3_step(_sGetMulticastRates) == SQLITE_ROW) {
  369. const char *mac = (const char *)sqlite3_column_text(_sGetMulticastRates,0);
  370. if ((mac)&&(strlen(mac) == 12)) {
  371. unsigned long adi = ((unsigned long)sqlite3_column_int64(_sGetMulticastRates,1)) & 0xffffffff;
  372. char tmp[256];
  373. Utils::snprintf(tmp,sizeof(tmp),"%s/%.4lx=%x,%x,%x\n",mac,adi,sqlite3_column_int(_sGetMulticastRates,2),sqlite3_column_int(_sGetMulticastRates,3),sqlite3_column_int(_sGetMulticastRates,4));
  374. multicastRates.append(tmp);
  375. }
  376. }
  377. if (multicastRates.length() > 0)
  378. netconf[ZT_NETWORKCONFIG_DICT_KEY_MULTICAST_RATES] = multicastRates;
  379. if (network.multicastLimit > 0) {
  380. char ml[16];
  381. Utils::snprintf(ml,sizeof(ml),"%lx",(unsigned long)network.multicastLimit);
  382. netconf[ZT_NETWORKCONFIG_DICT_KEY_MULTICAST_LIMIT] = ml;
  383. }
  384. }
  385. {
  386. std::string activeBridges;
  387. sqlite3_reset(_sGetActiveBridges);
  388. sqlite3_bind_text(_sGetActiveBridges,1,network.id,16,SQLITE_STATIC);
  389. while (sqlite3_step(_sGetActiveBridges) == SQLITE_ROW) {
  390. const char *ab = (const char *)sqlite3_column_text(_sGetActiveBridges,0);
  391. if ((ab)&&(strlen(ab) == 10)) {
  392. if (activeBridges.length())
  393. activeBridges.push_back(',');
  394. activeBridges.append(ab);
  395. }
  396. if (activeBridges.length() > 1024) // sanity check -- you can't have too many active bridges at the moment
  397. break;
  398. }
  399. if (activeBridges.length())
  400. netconf[ZT_NETWORKCONFIG_DICT_KEY_ACTIVE_BRIDGES] = activeBridges;
  401. }
  402. {
  403. std::string relays;
  404. sqlite3_reset(_sGetRelays);
  405. sqlite3_bind_text(_sGetRelays,1,network.id,16,SQLITE_STATIC);
  406. while (sqlite3_step(_sGetRelays) == SQLITE_ROW) {
  407. const char *n = (const char *)sqlite3_column_text(_sGetRelays,0);
  408. const char *a = (const char *)sqlite3_column_text(_sGetRelays,1);
  409. if ((n)&&(a)) {
  410. Address node(n);
  411. InetAddress addr(a);
  412. if ((node)&&(addr)) {
  413. if (relays.length())
  414. relays.push_back(',');
  415. relays.append(node.toString());
  416. relays.push_back(';');
  417. relays.append(addr.toString());
  418. }
  419. }
  420. }
  421. if (relays.length())
  422. netconf[ZT_NETWORKCONFIG_DICT_KEY_RELAYS] = relays;
  423. }
  424. if ((network.v4AssignMode)&&(!strcmp(network.v4AssignMode,"zt"))) {
  425. std::string v4s;
  426. sqlite3_reset(_sGetIpAssignmentsForNode);
  427. sqlite3_bind_text(_sGetIpAssignmentsForNode,1,network.id,16,SQLITE_STATIC);
  428. sqlite3_bind_text(_sGetIpAssignmentsForNode,2,member.nodeId,10,SQLITE_STATIC);
  429. sqlite3_bind_int(_sGetIpAssignmentsForNode,3,4); // 4 == IPv4
  430. while (sqlite3_step(_sGetIpAssignmentsForNode) == SQLITE_ROW) {
  431. const unsigned char *ip = (const unsigned char *)sqlite3_column_blob(_sGetIpAssignmentsForNode,0);
  432. int ipNetmaskBits = sqlite3_column_int(_sGetIpAssignmentsForNode,1);
  433. if ((ip)&&(sqlite3_column_bytes(_sGetIpAssignmentsForNode,0) >= 4)&&(ipNetmaskBits > 0)&&(ipNetmaskBits <= 32)) {
  434. char tmp[32];
  435. Utils::snprintf(tmp,sizeof(tmp),"%d.%d.%d.%d/%d",(int)ip[0],(int)ip[1],(int)ip[2],(int)ip[3],ipNetmaskBits);
  436. if (v4s.length())
  437. v4s.push_back(',');
  438. v4s.append(tmp);
  439. }
  440. }
  441. if (!v4s.length()) {
  442. // Attempt to auto-assign an IPv4 address from an available pool if one isn't assigned already
  443. sqlite3_reset(_sGetIpAssignmentPools);
  444. sqlite3_bind_text(_sGetIpAssignmentPools,1,network.id,16,SQLITE_STATIC);
  445. sqlite3_bind_int(_sGetIpAssignmentPools,2,4); // 4 == IPv4
  446. while ((!v4s.length())&&(sqlite3_step(_sGetIpAssignmentPools) == SQLITE_ROW)) {
  447. const void *ipNetwork = sqlite3_column_blob(_sGetIpAssignmentPools,0);
  448. int ipNetmaskBits = sqlite3_column_int(_sGetIpAssignmentPools,1);
  449. if ((ipNetwork)&&(sqlite3_column_bytes(_sGetIpAssignmentPools,0) >= 4)&&(ipNetmaskBits > 0)&&(ipNetmaskBits < 32)) {
  450. uint32_t n = Utils::ntoh(*((const uint32_t *)ipNetwork)); // network in host byte order e.g. 192.168.0.0
  451. uint32_t m = 0xffffffff << (32 - ipNetmaskBits); // netmask e.g. 0xffffff00 for '24' since 32 - 24 == 8
  452. n &= m; // sanity check -- ipNetwork bits right of netmask bit count should be zero
  453. uint32_t im = ~m; // inverse mask, e.g. 0x000000ff for a netmask of 0xffffff00
  454. uint32_t abits = (uint32_t)(identity.address().toInt() & 0xffffffff); // least significant bits of member ZT address
  455. for(uint32_t k=0;k<=im;++k) { // try up to the number of IPs possible in this network
  456. uint32_t ip = ( ((abits + k) & im) | n ); // build IP using bits from ZT address of member + k
  457. if ((ip & 0xffffff00) == 0) continue; // no IPs ending in .0
  458. if (ip == n) continue; // no IPs equal to the network e.g. 10.0.0.0 for 10.0.0.0/255.255.255.0
  459. if (ip == (n | im)) continue; // broadcast address e.g. 10.0.0.255 for 10.0.0.0/255.255.255.0
  460. uint32_t nip = Utils::hton(ip); // IP in big-endian "network" byte order
  461. sqlite3_reset(_sCheckIfIpIsAllocated);
  462. sqlite3_bind_text(_sCheckIfIpIsAllocated,1,network.id,16,SQLITE_STATIC);
  463. sqlite3_bind_blob(_sCheckIfIpIsAllocated,2,(const void *)&nip,4,SQLITE_STATIC);
  464. sqlite3_bind_int(_sCheckIfIpIsAllocated,3,4); // 4 == IPv4
  465. if (sqlite3_step(_sCheckIfIpIsAllocated) != SQLITE_ROW) {
  466. // No rows returned, so the IP is available
  467. sqlite3_reset(_sAllocateIp);
  468. sqlite3_bind_text(_sAllocateIp,1,network.id,16,SQLITE_STATIC);
  469. sqlite3_bind_text(_sAllocateIp,2,member.nodeId,10,SQLITE_STATIC);
  470. sqlite3_bind_blob(_sAllocateIp,3,(const void *)&nip,4,SQLITE_STATIC);
  471. sqlite3_bind_int(_sAllocateIp,4,ipNetmaskBits);
  472. sqlite3_bind_int(_sAllocateIp,5,4); // 4 == IPv4
  473. if (sqlite3_step(_sAllocateIp) == SQLITE_DONE) {
  474. char tmp[32];
  475. Utils::snprintf(tmp,sizeof(tmp),"%d.%d.%d.%d/%d",(int)((ip >> 24) & 0xff),(int)((ip >> 16) & 0xff),(int)((ip >> 8) & 0xff),(int)(ip & 0xff),ipNetmaskBits);
  476. if (v4s.length())
  477. v4s.push_back(',');
  478. v4s.append(tmp);
  479. break; // IP found and reserved! v4s containing something will cause outer while() to break.
  480. }
  481. }
  482. }
  483. }
  484. }
  485. }
  486. if (v4s.length())
  487. netconf[ZT_NETWORKCONFIG_DICT_KEY_IPV4_STATIC] = v4s;
  488. }
  489. // TODO: IPv6 auto-assign once it's supported in UI
  490. if (network.isPrivate) {
  491. CertificateOfMembership com(network.revision,ZT1_CERTIFICATE_OF_MEMBERSHIP_REVISION_MAX_DELTA,nwid,identity.address());
  492. if (com.sign(signingId)) // basically can't fail unless our identity is invalid
  493. netconf[ZT_NETWORKCONFIG_DICT_KEY_CERTIFICATE_OF_MEMBERSHIP] = com.toString();
  494. else {
  495. netconf["error"] = "unable to sign COM";
  496. return NETCONF_QUERY_INTERNAL_SERVER_ERROR;
  497. }
  498. }
  499. if (!netconf.sign(signingId,OSUtils::now())) {
  500. netconf["error"] = "unable to sign netconf dictionary";
  501. return NETCONF_QUERY_INTERNAL_SERVER_ERROR;
  502. }
  503. // Save serialized netconf for future re-use
  504. std::string netconfSerialized(netconf.toString());
  505. if (netconfSerialized.length() < 4096) { // sanity check
  506. sqlite3_reset(_sCacheNetconf);
  507. sqlite3_bind_blob(_sCacheNetconf,1,(const void *)netconfSerialized.data(),netconfSerialized.length(),SQLITE_STATIC);
  508. sqlite3_bind_int64(_sCacheNetconf,2,(sqlite3_int64)network.revision);
  509. sqlite3_bind_int64(_sCacheNetconf,3,member.rowid);
  510. sqlite3_step(_sCacheNetconf);
  511. }
  512. }
  513. return NetworkController::NETCONF_QUERY_OK;
  514. }
  515. unsigned int SqliteNetworkController::handleControlPlaneHttpGET(
  516. const std::vector<std::string> &path,
  517. const std::map<std::string,std::string> &urlArgs,
  518. const std::map<std::string,std::string> &headers,
  519. const std::string &body,
  520. std::string &responseBody,
  521. std::string &responseContentType)
  522. {
  523. char json[16384];
  524. if (path.empty())
  525. return 404;
  526. Mutex::Lock _l(_lock);
  527. if (path[0] == "network") {
  528. if ((path.size() >= 2)&&(path[1].length() == 16)) {
  529. uint64_t nwid = Utils::hexStrToU64(path[1].c_str());
  530. char nwids[24];
  531. Utils::snprintf(nwids,sizeof(nwids),"%.16llx",(unsigned long long)nwid);
  532. if (path.size() >= 3) {
  533. if ((path.size() == 4)&&(path[2] == "member")&&(path[3].length() == 10)) {
  534. uint64_t address = Utils::hexStrToU64(path[3].c_str());
  535. char addrs[24];
  536. Utils::snprintf(addrs,sizeof(addrs),"%.10llx",address);
  537. sqlite3_reset(_sGetMember2);
  538. sqlite3_bind_text(_sGetMember2,1,nwids,16,SQLITE_STATIC);
  539. sqlite3_bind_text(_sGetMember2,2,addrs,10,SQLITE_STATIC);
  540. if (sqlite3_step(_sGetMember2) == SQLITE_ROW) {
  541. Utils::snprintf(json,sizeof(json),
  542. "{\n"
  543. "\taddress: \"%s\""
  544. "\tauthorized: %s,"
  545. "\tactiveBridge: %s,\n"
  546. "\tlastAt: \"%s\",\n"
  547. "\tlastSeen: %llu,\n"
  548. "\tfirstSeen: %llu,\n"
  549. "\tidentity: \"%s\"\n"
  550. "}\n",
  551. addrs,
  552. (sqlite3_column_int(_sGetMember2,0) > 0) ? "true" : "false",
  553. (sqlite3_column_int(_sGetMember2,1) > 0) ? "true" : "false",
  554. _jsonEscape((const char *)sqlite3_column_text(_sGetMember2,3)).c_str(),
  555. (unsigned long long)sqlite3_column_int64(_sGetMember2,4),
  556. (unsigned long long)sqlite3_column_int64(_sGetMember2,5),
  557. _jsonEscape((const char *)sqlite3_column_text(_sGetMember2,2)).c_str());
  558. responseBody = json;
  559. responseContentType = "application/json";
  560. return 200;
  561. } // else 404
  562. } // else 404
  563. } else {
  564. // get network info
  565. sqlite3_reset(_sGetNetworkById);
  566. sqlite3_bind_text(_sGetNetworkById,1,nwids,16,SQLITE_STATIC);
  567. if (sqlite3_step(_sGetNetworkById) == SQLITE_ROW) {
  568. Utils::snprintf(json,sizeof(json),
  569. "{\n"
  570. "\tnwid: \"%s\",\n"
  571. "\tname: \"%s\",\n"
  572. "\tprivate: %s,\n"
  573. "\tenableBroadcast: %s,\n"
  574. "\tallowPassiveBridging: %s,\n"
  575. "\tv4AssignMode: \"%s\",\n"
  576. "\tv6AssignMode: \"%s\",\n"
  577. "\tmulticastLimit: %d,\n"
  578. "\tcreationTime: %llu,\n",
  579. "\trevision: %llu,\n"
  580. "\tmembers: [",
  581. nwids,
  582. _jsonEscape((const char *)sqlite3_column_text(_sGetNetworkById,0)).c_str(),
  583. (sqlite3_column_int(_sGetNetworkById,1) > 0) ? "true" : "false",
  584. (sqlite3_column_int(_sGetNetworkById,2) > 0) ? "true" : "false",
  585. (sqlite3_column_int(_sGetNetworkById,3) > 0) ? "true" : "false",
  586. _jsonEscape((const char *)sqlite3_column_text(_sGetNetworkById,4)).c_str(),
  587. _jsonEscape((const char *)sqlite3_column_text(_sGetNetworkById,5)).c_str(),
  588. sqlite3_column_int(_sGetNetworkById,6),
  589. (unsigned long long)sqlite3_column_int64(_sGetNetworkById,7),
  590. (unsigned long long)sqlite3_column_int64(_sGetNetworkById,8));
  591. responseBody = json;
  592. sqlite3_reset(_sListNetworkMembers);
  593. sqlite3_bind_text(_sListNetworkMembers,1,nwids,16,SQLITE_STATIC);
  594. bool firstMember = true;
  595. while (sqlite3_step(_sListNetworkMembers) == SQLITE_ROW) {
  596. Utils::snprintf(json,sizeof(json),
  597. "%s{\n"
  598. "\t\taddress: \"%s\",\n"
  599. "\t\tauthorized: %s,\n"
  600. "\t\tactiveBridge: %s,\n"
  601. "\t\tlastAt: \"%s\",\n"
  602. "\t\tlastSeen: %llu,\n"
  603. "\t\tfirstSeen: %llu\n"
  604. "\t}",
  605. firstMember ? "\n\t" : ",",
  606. (const char *)sqlite3_column_text(_sListNetworkMembers,2),
  607. (sqlite3_column_int(_sListNetworkMembers,0) > 0) ? "true" : "false",
  608. (sqlite3_column_int(_sListNetworkMembers,1) > 0) ? "true" : "false",
  609. _jsonEscape((const char *)sqlite3_column_text(_sListNetworkMembers,3)).c_str(),
  610. (unsigned long long)sqlite3_column_int64(_sListNetworkMembers,4),
  611. (unsigned long long)sqlite3_column_int64(_sListNetworkMembers,5));
  612. responseBody.append(json);
  613. firstMember = false;
  614. }
  615. responseBody.append("],\n\trelays: [");
  616. sqlite3_reset(_sGetRelays);
  617. sqlite3_bind_text(_sGetRelays,1,nwids,16,SQLITE_STATIC);
  618. bool firstRelay = true;
  619. while (sqlite3_step(_sGetRelays) == SQLITE_ROW) {
  620. responseBody.append(firstRelay ? "\n\t\t" : ",\n\t\t");
  621. firstRelay = false;
  622. responseBody.append("{address:\"");
  623. responseBody.append((const char *)sqlite3_column_text(_sGetRelays,0));
  624. responseBody.append("\",phyAddress:\"");
  625. responseBody.append(_jsonEscape((const char *)sqlite3_column_text(_sGetRelays,1)));
  626. responseBody.append("\"}");
  627. }
  628. responseBody.append("],\n\tipAssignmentPools: [");
  629. sqlite3_reset(_sGetIpAssignmentPools2);
  630. sqlite3_bind_text(_sGetIpAssignmentPools2,1,nwids,16,SQLITE_STATIC);
  631. bool firstIpAssignmentPool = true;
  632. while (sqlite3_step(_sGetIpAssignmentPools2) == SQLITE_ROW) {
  633. responseBody.append(firstIpAssignmentPool ? "\n\t\t" : ",\n\t\t");
  634. firstIpAssignmentPool = false;
  635. InetAddress ipp((const void *)sqlite3_column_blob(_sGetIpAssignmentPools2,0),(sqlite3_column_int(_sGetIpAssignmentPools2,2) == 6) ? 16 : 4,(unsigned int)sqlite3_column_int(_sGetIpAssignmentPools2,1));
  636. Utils::snprintf(json,sizeof(json),"{ipNetwork:\"%s\",ipNetmaskBits:%u,ipVersion:%d,active:%s}",
  637. _jsonEscape(ipp.toIpString()).c_str(),
  638. ipp.netmaskBits(),
  639. sqlite3_column_int(_sGetIpAssignmentPools2,2),
  640. (sqlite3_column_int(_sGetIpAssignmentPools2,3) > 0) ? "true" : "false");
  641. responseBody.append(json);
  642. }
  643. responseBody.append("],\n\trules: [");
  644. sqlite3_reset(_sListRules);
  645. sqlite3_bind_text(_sListRules,1,nwids,16,SQLITE_STATIC);
  646. bool firstRule = true;
  647. while (sqlite3_step(_sListRules) == SQLITE_ROW) {
  648. responseBody.append(firstRule ? "\n\t{\n" : ",{\n");
  649. Utils::snprintf(json,sizeof(json),"\t\truleId: %lld,\n",sqlite3_column_int64(_sListRules,0));
  650. responseBody.append(json);
  651. if (sqlite3_column_type(_sListRules,1) != SQLITE_NULL) {
  652. Utils::snprintf(json,sizeof(json),"\t\tnodeId: \"%s\",\n",(const char *)sqlite3_column_text(_sListRules,1));
  653. responseBody.append(json);
  654. }
  655. if (sqlite3_column_type(_sListRules,2) != SQLITE_NULL) {
  656. Utils::snprintf(json,sizeof(json),"\t\tvlanId: %d,\n",sqlite3_column_int(_sListRules,2));
  657. responseBody.append(json);
  658. }
  659. if (sqlite3_column_type(_sListRules,3) != SQLITE_NULL) {
  660. Utils::snprintf(json,sizeof(json),"\t\tvlanPcp: %d,\n",sqlite3_column_int(_sListRules,3));
  661. responseBody.append(json);
  662. }
  663. if (sqlite3_column_type(_sListRules,4) != SQLITE_NULL) {
  664. Utils::snprintf(json,sizeof(json),"\t\tetherType: %d,\n",sqlite3_column_int(_sListRules,4));
  665. responseBody.append(json);
  666. }
  667. if (sqlite3_column_type(_sListRules,5) != SQLITE_NULL) {
  668. Utils::snprintf(json,sizeof(json),"\t\tmacSource: \"%s\",\n",MAC((const char *)sqlite3_column_text(_sListRules,5)).toString().c_str());
  669. responseBody.append(json);
  670. }
  671. if (sqlite3_column_type(_sListRules,6) != SQLITE_NULL) {
  672. Utils::snprintf(json,sizeof(json),"\t\tmacDest: \"%s\",\n",MAC((const char *)sqlite3_column_text(_sListRules,6)).toString().c_str());
  673. responseBody.append(json);
  674. }
  675. if (sqlite3_column_type(_sListRules,7) != SQLITE_NULL) {
  676. Utils::snprintf(json,sizeof(json),"\t\tipSource: \"%s\",\n",_jsonEscape((const char *)sqlite3_column_text(_sListRules,7)).c_str());
  677. responseBody.append(json);
  678. }
  679. if (sqlite3_column_type(_sListRules,8) != SQLITE_NULL) {
  680. Utils::snprintf(json,sizeof(json),"\t\tipDest: \"%s\",\n",_jsonEscape((const char *)sqlite3_column_text(_sListRules,8)).c_str());
  681. responseBody.append(json);
  682. }
  683. if (sqlite3_column_type(_sListRules,9) != SQLITE_NULL) {
  684. Utils::snprintf(json,sizeof(json),"\t\tipTos: %d,\n",sqlite3_column_int(_sListRules,9));
  685. responseBody.append(json);
  686. }
  687. if (sqlite3_column_type(_sListRules,10) != SQLITE_NULL) {
  688. Utils::snprintf(json,sizeof(json),"\t\tipProtocol: %d,\n",sqlite3_column_int(_sListRules,10));
  689. responseBody.append(json);
  690. }
  691. if (sqlite3_column_type(_sListRules,11) != SQLITE_NULL) {
  692. Utils::snprintf(json,sizeof(json),"\t\tipSourcePort: %d,\n",sqlite3_column_int(_sListRules,11));
  693. responseBody.append(json);
  694. }
  695. if (sqlite3_column_type(_sListRules,12) != SQLITE_NULL) {
  696. Utils::snprintf(json,sizeof(json),"\t\tipDestPort: %d,\n",sqlite3_column_int(_sListRules,12));
  697. responseBody.append(json);
  698. }
  699. responseBody.append("\t\taction: \"");
  700. responseBody.append(_jsonEscape((const char *)sqlite3_column_text(_sListRules,13)));
  701. responseBody.append("\"\n\t}");
  702. }
  703. responseBody.append("]\n}\n");
  704. responseContentType = "application/json";
  705. return 200;
  706. } // else 404
  707. }
  708. } else if (path.size() == 1) {
  709. // list networks
  710. sqlite3_reset(_sListNetworks);
  711. responseContentType = "application/json";
  712. responseBody = "[";
  713. bool first = true;
  714. while (sqlite3_step(_sListNetworks) == SQLITE_ROW) {
  715. if (first) {
  716. first = false;
  717. responseBody.push_back('"');
  718. } else responseBody.append(",\"");
  719. responseBody.append((const char *)sqlite3_column_text(_sListNetworks,0));
  720. responseBody.push_back('"');
  721. }
  722. responseBody.push_back(']');
  723. return 200;
  724. } // else 404
  725. } // else 404
  726. return 404;
  727. }
  728. unsigned int SqliteNetworkController::handleControlPlaneHttpPOST(
  729. const std::vector<std::string> &path,
  730. const std::map<std::string,std::string> &urlArgs,
  731. const std::map<std::string,std::string> &headers,
  732. const std::string &body,
  733. std::string &responseBody,
  734. std::string &responseContentType)
  735. {
  736. if (path.empty())
  737. return 404;
  738. Mutex::Lock _l(_lock);
  739. if (path[0] == "network") {
  740. if ((path.size() >= 2)&&(path[1].length() == 16)) {
  741. uint64_t nwid = Utils::hexStrToU64(path[1].c_str());
  742. char nwids[24];
  743. Utils::snprintf(nwids,sizeof(nwids),"%.16llx",(unsigned long long)nwid);
  744. int64_t revision = 0;
  745. sqlite3_reset(_sGetNetworkRevision);
  746. sqlite3_bind_text(_sGetNetworkRevision,1,nwids,16,SQLITE_STATIC);
  747. if (sqlite3_step(_sGetNetworkRevision) == SQLITE_ROW)
  748. revision = sqlite3_column_int64(_sGetNetworkRevision,0);
  749. if (path.size() >= 3) {
  750. if ((path.size() == 4)&&(path[2] == "member")&&(path[3].length() == 10)) {
  751. uint64_t address = Utils::hexStrToU64(path[3].c_str());
  752. char addrs[24];
  753. Utils::snprintf(addrs,sizeof(addrs),"%.10llx",address);
  754. return handleControlPlaneHttpGET(path,urlArgs,headers,body,responseBody,responseContentType);
  755. } // else 404
  756. } else {
  757. if (revision <= 0) {
  758. sqlite3_reset(_sCreateNetwork);
  759. sqlite3_bind_text(_sCreateNetwork,1,nwids,16,SQLITE_STATIC);
  760. sqlite3_bind_text(_sCreateNetwork,2,nwids,16,SQLITE_STATIC); // default name, will be changed below if a name is specified in JSON
  761. sqlite3_bind_int64(_sCreateNetwork,3,(long long)OSUtils::now());
  762. if (sqlite3_step(_sCreateNetwork) != SQLITE_DONE)
  763. return 500;
  764. }
  765. json_value *j = json_parse(body.c_str(),body.length());
  766. if (j) {
  767. if (j->type == json_object) {
  768. for(unsigned int k=0;k<j->u.object.length;++k) {
  769. sqlite3_reset(_sUpdateNetworkField);
  770. sqlite3_bind_text(_sUpdateNetworkField,3,nwids,16,SQLITE_STATIC);
  771. if (!strcmp(j->u.object.values[k].name,"name")) {
  772. if ((j->u.object.values[k].value->type == json_string)&&(j->u.object.values[k].value->u.string.ptr[0])) {
  773. sqlite3_bind_text(_sUpdateNetworkField,1,"name",-1,SQLITE_STATIC);
  774. sqlite3_bind_text(_sUpdateNetworkField,2,j->u.object.values[k].value->u.string.ptr,-1,SQLITE_STATIC);
  775. sqlite3_step(_sUpdateNetworkField);
  776. } else return 400;
  777. }
  778. if (!strcmp(j->u.object.values[k].name,"private")) {
  779. if (j->u.object.values[k].value->type == json_boolean) {
  780. sqlite3_bind_text(_sUpdateNetworkField,1,"private",-1,SQLITE_STATIC);
  781. sqlite3_bind_int(_sUpdateNetworkField,2,(j->u.object.values[k].value->u.boolean == 0) ? 0 : 1);
  782. sqlite3_step(_sUpdateNetworkField);
  783. } else return 400;
  784. }
  785. if (!strcmp(j->u.object.values[k].name,"enableBroadcast")) {
  786. if (j->u.object.values[k].value->type == json_boolean) {
  787. sqlite3_bind_text(_sUpdateNetworkField,1,"enableBroadcast",-1,SQLITE_STATIC);
  788. sqlite3_bind_int(_sUpdateNetworkField,2,(j->u.object.values[k].value->u.boolean == 0) ? 0 : 1);
  789. sqlite3_step(_sUpdateNetworkField);
  790. } else return 400;
  791. }
  792. if (!strcmp(j->u.object.values[k].name,"allowPassiveBridging")) {
  793. if (j->u.object.values[k].value->type == json_boolean) {
  794. sqlite3_bind_text(_sUpdateNetworkField,1,"allowPassiveBridging",-1,SQLITE_STATIC);
  795. sqlite3_bind_int(_sUpdateNetworkField,2,(j->u.object.values[k].value->u.boolean == 0) ? 0 : 1);
  796. sqlite3_step(_sUpdateNetworkField);
  797. } else return 400;
  798. }
  799. if (!strcmp(j->u.object.values[k].name,"v4AssignMode")) {
  800. if (j->u.object.values[k].value->type == json_string) {
  801. sqlite3_bind_text(_sUpdateNetworkField,1,"v4AssignMode",-1,SQLITE_STATIC);
  802. sqlite3_bind_text(_sUpdateNetworkField,2,j->u.object.values[k].value->u.string.ptr,-1,SQLITE_STATIC);
  803. sqlite3_step(_sUpdateNetworkField);
  804. } else return 400;
  805. }
  806. if (!strcmp(j->u.object.values[k].name,"v6AssignMode")) {
  807. if (j->u.object.values[k].value->type == json_string) {
  808. sqlite3_bind_text(_sUpdateNetworkField,1,"v6AssignMode",-1,SQLITE_STATIC);
  809. sqlite3_bind_text(_sUpdateNetworkField,2,j->u.object.values[k].value->u.string.ptr,-1,SQLITE_STATIC);
  810. sqlite3_step(_sUpdateNetworkField);
  811. } else return 400;
  812. }
  813. if (!strcmp(j->u.object.values[k].name,"multicastLimit")) {
  814. if (j->u.object.values[k].value->type == json_integer) {
  815. sqlite3_bind_text(_sUpdateNetworkField,1,"multicastLimit",-1,SQLITE_STATIC);
  816. sqlite3_bind_int(_sUpdateNetworkField,2,(int)j->u.object.values[k].value->u.integer);
  817. sqlite3_step(_sUpdateNetworkField);
  818. } else return 400;
  819. }
  820. if (!strcmp(j->u.object.values[k].name,"relays")) {
  821. if (j->u.object.values[k].value->type == json_array) {
  822. } else return 400;
  823. }
  824. if (!strcmp(j->u.object.values[k].name,"ipAssignmentPools")) {
  825. if (j->u.object.values[k].value->type == json_array) {
  826. } else return 400;
  827. }
  828. if (!strcmp(j->u.object.values[k].name,"rules")) {
  829. if (j->u.object.values[k].value->type == json_array) {
  830. } else return 400;
  831. }
  832. }
  833. }
  834. json_value_free(j);
  835. }
  836. return handleControlPlaneHttpGET(path,urlArgs,headers,body,responseBody,responseContentType);
  837. }
  838. } // else 404
  839. } // else 404
  840. return 404;
  841. }
  842. unsigned int SqliteNetworkController::handleControlPlaneHttpDELETE(
  843. const std::vector<std::string> &path,
  844. const std::map<std::string,std::string> &urlArgs,
  845. const std::map<std::string,std::string> &headers,
  846. const std::string &body,
  847. std::string &responseBody,
  848. std::string &responseContentType)
  849. {
  850. if (path.empty())
  851. return 404;
  852. Mutex::Lock _l(_lock);
  853. return 404;
  854. }
  855. } // namespace ZeroTier