summaryrefslogtreecommitdiff
path: root/controller
diff options
context:
space:
mode:
authorAdam Ierymenko <adam.ierymenko@gmail.com>2015-09-08 11:35:55 -0700
committerAdam Ierymenko <adam.ierymenko@gmail.com>2015-09-08 11:35:55 -0700
commit0d386f1c3119b869197bafd5f2ad75ba2179850f (patch)
tree492eb9d67b1e57f9898022ec883ed142e7b15d47 /controller
parent85b90f122a826510491e15a1bfd6c1fe75dfe069 (diff)
downloadinfinitytier-0d386f1c3119b869197bafd5f2ad75ba2179850f.tar.gz
infinitytier-0d386f1c3119b869197bafd5f2ad75ba2179850f.zip
Add a bit of useful testing instrumentation to SqliteNetworkController.
Diffstat (limited to 'controller')
-rw-r--r--controller/SqliteNetworkController.cpp43
-rw-r--r--controller/SqliteNetworkController.hpp1
2 files changed, 40 insertions, 4 deletions
diff --git a/controller/SqliteNetworkController.cpp b/controller/SqliteNetworkController.cpp
index 2a004bda..6a786ce4 100644
--- a/controller/SqliteNetworkController.cpp
+++ b/controller/SqliteNetworkController.cpp
@@ -301,7 +301,7 @@ SqliteNetworkController::~SqliteNetworkController()
}
}
-NetworkController::ResultCode SqliteNetworkController::doNetworkConfigRequest(const InetAddress &fromAddr,const Identity &signingId,const Identity &identity,uint64_t nwid,const Dictionary &metaData,uint64_t haveRevision,Dictionary &netconf)
+NetworkController::ResultCode SqliteNetworkController::doNetworkConfigRequest(const InetAddress &fromAddr,const Identity &signingId,const Identity &identity,uint64_t nwid,const Dictionary &metaData,Dictionary &netconf)
{
// Decode some stuff from metaData
const unsigned int clientMajorVersion = (unsigned int)metaData.getHexUInt(ZT_NETWORKCONFIG_REQUEST_METADATA_KEY_NODE_MAJOR_VERSION,0);
@@ -1355,8 +1355,44 @@ unsigned int SqliteNetworkController::_doCPGet(
sqlite3_bind_text(_sGetMember2,1,nwids,16,SQLITE_STATIC);
sqlite3_bind_text(_sGetMember2,2,addrs,10,SQLITE_STATIC);
if (sqlite3_step(_sGetMember2) == SQLITE_ROW) {
+ const char *memberIdStr = (const char *)sqlite3_column_text(_sGetMember2,3);
+
+ // If testSingingId is included in the URL or X-ZT1-TestSigningId in the headers
+ // and if it contains an identity with a secret portion, the resturned JSON
+ // will contain an extra field called _testConf. This will contain several
+ // fields that report the result of doNetworkConfigRequest() for this member.
+ std::string testFields;
+ {
+ Identity testOutputSigningId;
+ std::map<std::string,std::string>::const_iterator sid(urlArgs.find("testSigningId"));
+ if (sid != urlArgs.end()) {
+ testOutputSigningId.fromString(sid->second.c_str());
+ } else {
+ sid = headers.find("x-zt1-testsigningid");
+ if (sid != headers.end())
+ testOutputSigningId.fromString(sid->second.c_str());
+ }
+
+ if ((testOutputSigningId.hasPrivate())&&(memberIdStr)) {
+ Dictionary testNetconf;
+ NetworkController::ResultCode rc = this->doNetworkConfigRequest(
+ InetAddress(),
+ testOutputSigningId,
+ Identity(memberIdStr),
+ nwid,
+ Dictionary(), // TODO: allow passing of meta-data for testing
+ testNetconf);
+ char rcs[16];
+ Utils::snprintf(rcs,sizeof(rcs),"%d",(int)rc);
+ testFields.append("\t\"_test\": {\n");
+ testFields.append("\t\t\"resultCode\": "); testFields.append(rcs); testFields.append(",\n");
+ testFields.append("\t\t\"result\": \""); testFields.append(_jsonEscape(testNetconf.toString().c_str()).c_str()); testFields.append("\"");
+ testFields.append("\t}\n");
+ }
+ }
+
Utils::snprintf(json,sizeof(json),
- "{\n"
+ "{\n%s"
"\t\"nwid\": \"%s\",\n"
"\t\"address\": \"%s\",\n"
"\t\"controllerInstanceId\": \"%s\",\n"
@@ -1366,6 +1402,7 @@ unsigned int SqliteNetworkController::_doCPGet(
"\t\"clock\": %llu,\n"
"\t\"identity\": \"%s\",\n"
"\t\"ipAssignments\": [",
+ testFields.c_str(),
nwids,
addrs,
_instanceId.c_str(),
@@ -1373,7 +1410,7 @@ unsigned int SqliteNetworkController::_doCPGet(
(sqlite3_column_int(_sGetMember2,1) > 0) ? "true" : "false",
(unsigned long long)sqlite3_column_int64(_sGetMember2,2),
(unsigned long long)OSUtils::now(),
- _jsonEscape((const char *)sqlite3_column_text(_sGetMember2,3)).c_str());
+ _jsonEscape(memberIdStr).c_str());
responseBody = json;
sqlite3_reset(_sGetIpAssignmentsForNode2);
diff --git a/controller/SqliteNetworkController.hpp b/controller/SqliteNetworkController.hpp
index adfe0991..26a06968 100644
--- a/controller/SqliteNetworkController.hpp
+++ b/controller/SqliteNetworkController.hpp
@@ -54,7 +54,6 @@ public:
const Identity &identity,
uint64_t nwid,
const Dictionary &metaData,
- uint64_t haveRevision,
Dictionary &netconf);
unsigned int handleControlPlaneHttpGET(