X-Git-Url: https://git.teslayout.com/public/public/public/?a=blobdiff_plain;f=example%2Fdiameter%2Flauncher%2FEventOperation.cpp;h=a3ee7baec4c4ab91cabe5a5a74ef8f15b9fa9d93;hb=8a597c7ccbe2986f505fd70258e4b59ecef4166f;hp=7709fb1864a2087f895531d4c90e1a6eb36f522b;hpb=e688b5354af3a5fe0add859710cae41ffe123f65;p=anna.git

diff --git a/example/diameter/launcher/EventOperation.cpp b/example/diameter/launcher/EventOperation.cpp
index 7709fb1..a3ee7ba 100644
--- a/example/diameter/launcher/EventOperation.cpp
+++ b/example/diameter/launcher/EventOperation.cpp
@@ -12,47 +12,24 @@
 // Process
 #include <EventOperation.hpp>
 #include <Launcher.hpp>
+#include <Procedure.hpp>
+#include <MyDiameterEngine.hpp>
+#include <MyLocalServer.hpp>
+#include <anna/testing/TestManager.hpp>
+
+// Standard
+#include <fstream>
+#include <unistd.h> // chdir
 
 // Project
 #include <anna/diameter.comm/OriginHost.hpp>
-
-
-//// Standard
-//#include <sstream>      // std::istringstream
-//#include <iostream>     // std::cout
-//#include <math.h> // ceil
-//#include <climits>
-#include <unistd.h> // chdir
-//#include <stdio.h>
-//
-//// Project
 #include <anna/json/functions.hpp>
 #include <anna/diameter/codec/Message.hpp>
-//#include <anna/timex/Engine.hpp>
-//#include <anna/statistics/Engine.hpp>
-//#include <anna/diameter/codec/functions.hpp>
-//#include <anna/diameter/codec/Engine.hpp>
-//#include <anna/diameter/codec/EngineManager.hpp>
-//#include <anna/http/Transport.hpp>
-//#include <anna/diameter/stack/Engine.hpp>
 #include <anna/diameter/helpers/base/functions.hpp>
 #include <anna/time/functions.hpp>
 #include <anna/core/functions.hpp>
-//#include <anna/diameter.comm/ApplicationMessageOamModule.hpp>
-//#include <anna/testing/defines.hpp>
 #include <anna/xml/xml.hpp>
-//#include <anna/diameter.comm/OriginHost.hpp>
-//#include <anna/diameter.comm/OriginHostManager.hpp>
 #include <anna/diameter.comm/Message.hpp>
-//
-//// Process
-//#include <Launcher.hpp>
-//#include <Procedure.hpp>
-//#include <EventOperation.hpp>
-#include <MyDiameterEngine.hpp>
-#include <MyLocalServer.hpp>
-#include <anna/testing/TestManager.hpp>
-//#include <anna/testing/TestCase.hpp>
 
 
 /////////////////////
@@ -857,26 +834,59 @@ bool EventOperation::test_id__waitfefc(std::string &response, unsigned int id, b
 bool EventOperation::test__ttps(std::string &response, int amount) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
 
+  bool success = testManager.configureTTPS(amount);
+  if (success) {
+    response = "Assigned new test launch rate to ";
+    response += anna::functions::asString(amount);
+    response += " events per second";
+  }
+  else {
+    response += "unable to configure the test rate provided";
+  }
 
-
-  return true; // OK
+  return success; // OK
 }
 
 bool EventOperation::test__next(std::string &response, int syncAmount) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
+
+  if (syncAmount < 1) {
+    response += "the parameter 'sync-amount' must be a positive integer value";
+    return false;
+  }
 
+  bool success = testManager.execTestCases(syncAmount);
 
+  response = (success ? "P" : "Not completely p" /* completed cycle and no repeats, rare case */);
+  response += "rocessed ";
+  response += anna::functions::asString(syncAmount);
+  response += ((syncAmount > 1) ? " test cases synchronously" : " test case");
 
-  return true; // OK
+  return success;
 }
 
 bool EventOperation::test__ip_limit(std::string &response, int amount) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
 
-
+  if (amount > -2) {
+    testManager.setInProgressLimit(amount);
+    response = "New in-progress limit: ";
+    response += (amount != -1) ? anna::functions::asString(amount) : "<no limit>";
+  }
+  else {
+    response = "In-progress limit amount: ";
+    int limit = testManager.getInProgressLimit();
+    response += (limit != -1) ? anna::functions::asString(limit) : "<no limit>";
+    response += "; currently there are ";
+    response += anna::functions::asString(testManager.getInProgressCount());
+    response += " test cases running";
+  }
 
   return true; // OK
 }
@@ -884,26 +894,64 @@ bool EventOperation::test__ip_limit(std::string &response, int amount) {
 bool EventOperation::test__goto(std::string &response, int id) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
 
+  bool success = testManager.gotoTestCase(id);
 
+  if (success) {
+    response = "Position updated for id provided (";
+  }
+  else {
+    response += "cannot found test id (";
+  }
+  response += anna::functions::asString(id);
+  response += ")";
 
-  return true; // OK
+  return success;
 }
 
 bool EventOperation::test__run(std::string &response, int id) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
 
+  bool success = testManager.runTestCase(id);
 
+  if (success) {
+    response = "Test executed for id provided (";
+  }
+  else {
+    response += "cannot found test id (";
+  }
+  response += anna::functions::asString(id);
+  response += ")";
 
-  return true; // OK
+  return success;
 }
 
 bool EventOperation::test__look(std::string &response, int id) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
+
+  anna::testing::TestCase *testCase = testManager.findTestCase(id);
+  if (!testCase) {
+    if (id == -1) {
+       response += "no current test case detected (testing started ?)";
+    }
+    else {
+      response += "cannot found test id (";
+      response += anna::functions::asString(id);
+      response += ")";
+    }
 
+    return false;
+  }
 
+  if (a_http)
+    response = anna::functions::encodeBase64(testCase->asXMLString());
+  else
+    response = testCase->asXMLString();
 
   return true; // OK
 }
@@ -911,26 +959,89 @@ bool EventOperation::test__look(std::string &response, int id) {
 bool EventOperation::test__state(std::string &response, int id) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
 
+  anna::testing::TestCase *testCase = testManager.findTestCase(id);
+  if (!testCase) {
+    if (id == -1) {
+       response += "no current test case detected (testing started ?)";
+    }
+    else {
+      response += "cannot found test id (";
+      response += anna::functions::asString(id);
+      response += ")";
+    }
 
+    return false;
+  }
 
-  return true; // OK
+  response = anna::testing::TestCase::asText(testCase->getState());
+  return testCase->isSuccess();
 }
 
 bool EventOperation::test__interact(std::string &response, int amount, unsigned int id) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
 
+  if (amount < -1) {
+    response += "interactive amount must be -1 (to disable interactive mode) or a positive number.";
+    return false;
+  }
 
+  anna::testing::TestCase *testCase = testManager.findTestCase(id);
+  if (testCase) {
+    if (amount == -1) {
+      testCase->makeInteractive(false);
+      response = "Interactive mode disabled";
+    }
+    else {
+      testCase->addInteractiveAmount(amount);
+      response = "Added interactive amount of ";
+      response += anna::functions::asString(amount);
+      response += " units";
+      if (amount == 0) response += " (0: freezing a non-interactive testcase, no effect on already interactive)";
+    }
+    response += " for test case id ";
+    response += anna::functions::asString(id);
+  }
+  else {
+    response += "cannot found test id (";
+    response += anna::functions::asString(id);
+    response += ")";
+    return false;
+  }
 
   return true; // OK
 }
 
-bool EventOperation::test__reset(std::string &response, bool soft_hard, unsigned int id) {
+bool EventOperation::test__reset(std::string &response, bool soft_hard, int id) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
 
-
+  anna::testing::TestCase *testCase = ((id != -1) ? testManager.findTestCase(id) : NULL);
+  if (testCase) {
+    bool done = testCase->reset(!soft_hard);
+    response = "Test ";
+    response += (soft_hard ? "soft":"hard");
+    response += " reset for id ";
+    response += anna::functions::asString(id);
+    response += done ? ": done": ": not done";
+  }
+  else {
+    if (id == -1) {
+      bool anyReset = testManager.resetPool(!soft_hard);
+      response = (soft_hard ? "Soft":"Hard");
+      response += " reset have been sent to all programmed tests: "; response += anyReset ? "some/all have been reset" : "nothing was reset";
+    }
+    else {
+      response += "cannot found test id (";
+      response += anna::functions::asString(id);
+      response += ")";
+      return false;
+    }
+  }
 
   return true; // OK
 }
@@ -938,8 +1049,12 @@ bool EventOperation::test__reset(std::string &response, bool soft_hard, unsigned
 bool EventOperation::test__repeats(std::string &response, int amount) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
 
-
+  if (amount < 0) amount = -1;
+  testManager.setPoolRepeats(amount);
+  std::string nolimit = (amount != -1) ? "":" [no limit]";
+  response = anna::functions::asString("Pool repeats: %d%s (current cycle: %d)", amount, nolimit.c_str(), testManager.getPoolCycle());
 
   return true; // OK
 }
@@ -947,8 +1062,10 @@ bool EventOperation::test__repeats(std::string &response, int amount) {
 bool EventOperation::test__auto_reset(std::string &response, bool soft_hard) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
 
-
+  testManager.setAutoResetHard(!soft_hard);
+  response = anna::functions::asString("Auto-reset configured to '%s'", (soft_hard ? "soft":"hard"));
 
   return true; // OK
 }
@@ -956,8 +1073,9 @@ bool EventOperation::test__auto_reset(std::string &response, bool soft_hard) {
 bool EventOperation::test__initialized(std::string &response) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
 
-
+  response = anna::functions::asString("%lu", testManager.getInitializedCount());
 
   return true; // OK
 }
@@ -965,8 +1083,9 @@ bool EventOperation::test__initialized(std::string &response) {
 bool EventOperation::test__finished(std::string &response) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
 
-
+  response = anna::functions::asString("%lu", testManager.getFinishedCount());
 
   return true; // OK
 }
@@ -976,28 +1095,30 @@ bool EventOperation::test__clear(std::string &response) {
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
   anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
 
-  try {
-    if (testManager.clearPool()) {
-      response = "All the programmed test cases have been dropped";
-    }
-    else {
-      response = "There are not programmed test cases to be removed";
-    }
-  }
-  catch(anna::RuntimeException &ex) {
-    ex.trace();
-    response += "failed";
-    return false;
-  }
-
-  return true; // OK
+  return testManager.clearPool(response);
 }
 
 bool EventOperation::test__junit(std::string &response, const std::string & targetFile) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
+
+  std::ofstream out;
+  out.open(targetFile.c_str());
+
+  if(out.is_open() == false) {
+    response += "error opening '";
+    response += targetFile;
+    response += "'";
+    return false;
+  }
 
+  out << testManager.junitAsXMLString() << std::endl;
+  out.close();
 
+  response = "Junit report written on '";
+  response += targetFile;
+  response += "'";
 
   return true; // OK
 }
@@ -1005,8 +1126,9 @@ bool EventOperation::test__junit(std::string &response, const std::string & targ
 bool EventOperation::test__summary_counts(std::string &response) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
 
-
+  response = anna::functions::encodeBase64(testManager.summaryCounts());
 
   return true; // OK
 }
@@ -1014,8 +1136,9 @@ bool EventOperation::test__summary_counts(std::string &response) {
 bool EventOperation::test__summary_states(std::string &response) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
 
-
+  response = anna::functions::encodeBase64(testManager.summaryStates());
 
   return true; // OK
 }
@@ -1023,8 +1146,9 @@ bool EventOperation::test__summary_states(std::string &response) {
 bool EventOperation::test__summary(std::string &response) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
 
-
+  response = anna::functions::encodeBase64(testManager.asXMLString());
 
   return true; // OK
 }
@@ -1032,8 +1156,36 @@ bool EventOperation::test__summary(std::string &response) {
 bool EventOperation::test__report(std::string &response, const std::string & state, bool enable) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
 
+  std::string _state = state;
+
+  if(_state == "initialized")
+    testManager.setDumpInitializedReports(enable);
+  else if(_state == "in-progress")
+    testManager.setDumpInProgressReports(enable);
+  else if(_state == "failed")
+    testManager.setDumpFailedReports(enable);
+  else if(_state == "success")
+    testManager.setDumpSuccessReports(enable);
+  else if(_state == "all") {
+    _state = "any";
+    testManager.setDumpAllReports(enable);
+  }
+  else if(_state == "none") {
+    enable = !enable;
+    _state = "any";
+    testManager.setDumpAllReports(enable);
+  }
+  else {
+    response += "invalid state (allowed: initialized|in-progress|failed|success|[all]|none)";
+    return false;
+  }
 
+  response = (enable ? "Report enabled " : "Report disabled ");
+  response += "for tests in '";
+  response += _state;
+  response += "' state";
 
   return true; // OK
 }
@@ -1041,8 +1193,10 @@ bool EventOperation::test__report(std::string &response, const std::string & sta
 bool EventOperation::test__report_hex(std::string &response, bool enable) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
 
-
+  testManager.setDumpHex(enable);
+  response = (testManager.getDumpHex() ? "Report includes hexadecimal messages" : "Report excludes hexadecimal messages");
 
   return true; // OK
 }
@@ -1050,8 +1204,27 @@ bool EventOperation::test__report_hex(std::string &response, bool enable) {
 bool EventOperation::test__dump_stdout(std::string &response, bool enable) {
 
   Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+  anna::testing::TestManager &testManager = anna::testing::TestManager::instantiate();
+
+  testManager.setDumpStdout(enable);
+  response = (testManager.getDumpStdout() ? "Test manager dumps progress into stdout" : "Test manager does not dump progress into stdout");
+
+  return true; // OK
+}
 
+bool EventOperation::test__dynamic(std::string &response, const nlohmann::json &arguments) {
 
+  Launcher& my_app = static_cast <Launcher&>(anna::app::functions::getApp());
+
+  Procedure p(&my_app);
+  try {
+    p.execute(arguments, response);
+  }
+  catch(anna::RuntimeException &ex) {
+    ex.trace();
+    response += ex.asString();
+    return false;
+  }
 
   return true; // OK
 }