#define example_diameter_launcher_EventOperation_hpp
// Project
-#include <anna/json/json.hpp>
// STL
#include <string>
-using json = nlohmann::json;
+//// 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/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/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>
+//
+//// Process
+//#include <Launcher.hpp>
+//#include <Procedure.hpp>
+//#include <EventOperation.hpp>
+//#include <MyDiameterEngine.hpp>
+//#include <anna/testing/TestManager.hpp>
+//#include <anna/testing/TestCase.hpp>
+
class EventOperation {
+ bool a_http;
+
public:
- static std::string json2piped(const json &j);
+ /**
+ * EventOperation constructor
+ *
+ * @param http Indicates that HTTP interface is used.
+ *
+ * At signal interface, the response is written directly as output, but HTTP
+ * one answers json.
+ *
+ * TODO: xml2json implementation (i.e., https://github.com/Cheedoong/xml2json).
+ * As only 3 operations are going to answer xml content:
+ * - working node report ('node')
+ * - diameter hex decode ('decode')
+ * - reinterpret json into xml ('loadmsg')
+ * the effort does not compensate having them responding full json representation.
+ *
+ * So, base64 encoding will be used for those xml representations.
+ *
+ * Anna Suite used xml natively for many things, json will be only used for
+ * REST API on requests and will be transformed internally.
+ */
+ EventOperation(bool http) : a_http(http) {;}
+
+ // Node management
+ bool node(std::string &response, const std::string & name);
+ bool node_auto(std::string &response);
+
+ // Parsing operations
+ bool code(std::string &response, const std::string & diameterJson);
+ bool decode(std::string &response, const std::string & diameterHex);
+ bool loadmsg(std::string &response, const std::string & diameterJson);
+
+ // Hot changes
+ bool services(std::string &response, const std::string & servicesJson);
+ bool diameterServerSessions(std::string &response, int sessions);
+ bool change_dir(std::string &response, const std::string & directory = "");
+
+ // Client sessions visibility
+ bool visibility(std::string &response, const std::string & action, const std::string &addressPort = "", int socket = -1);
+
+ // Snapshots
+ bool collect(std::string &response);
+ bool context(std::string &response, const std::string & targetFile = "");
+ bool forceCountersRecord(std::string &response);
+ bool log_statistics_samples(std::string &response, const std::string & list);
+ bool show_oam(std::string &response);
+ bool show_stats(std::string &response);
+
+ // Flow operations
+ bool sendmsg2e(std::string &response, const std::string & diameterJson);
+ bool sendmsg2c(std::string &response, const std::string & diameterJson);
+ bool answermsg2e(std::string &response, const std::string & diameterJson);
+ bool answermsg2c(std::string &response, const std::string & diameterJson);
+ bool answermsg2e_action(std::string &response, const std::string & action = "list");
+ bool answermsg2c_action(std::string &response, const std::string & action = "list");
+ bool sendhex2e(std::string &response, const std::string & diameterHex);
+ bool sendhex2c(std::string &response, const std::string & diameterHex);
+
+ // FSM testing
+ // test_id__<command>
+ bool test_id__description(std::string &response, unsigned int id, const std::string & description);
+ bool test_id__ip_limit(std::string &response, unsigned int id, int amount = 1);
+ bool test_id__timeout(std::string &response, unsigned int id, int msecs);
+ bool test_id__sendmsg2e(std::string &response, unsigned int id, const std::string & diameterJson, int stepNumber = -1);
+ bool test_id__sendmsg2c(std::string &response, unsigned int id, const std::string & diameterJson, int stepNumber = -1);
+ bool test_id__delay(std::string &response, unsigned int id, int msecs);
+ bool test_id__sh_command(std::string &response, unsigned int id, const std::string & script);
+ bool test_id__waitfe_hex(std::string &response, unsigned int id, const std::string & hex, bool strict = false);
+ bool test_id__waitfc_hex(std::string &response, unsigned int id, const std::string & hex, bool strict = false);
+ bool test_id__waitfe_msg(std::string &response, unsigned int id, const std::string & diameterJson, bool strict = false);
+ bool test_id__waitfc_msg(std::string &response, unsigned int id, const std::string & diameterJson, bool strict = false);
+ bool test_id__waitfe(std::string &response, unsigned int id, const std::string & condition);
+ bool test_id__waitfc(std::string &response, unsigned int id, const std::string & condition);
+
+ // Testcases execution
+ // test__<command>
+ bool test__ttps(std::string &response, int amount);
+ bool test__next(std::string &response, int syncAmount = 1);
+ bool test__ip_limit(std::string &response, int amount = -2 /* show current ip-limit and in-progress test cases amount */);
+ bool test__goto(std::string &response, int id);
+ bool test__run(std::string &response, int id);
+ bool test__look(std::string &response, int id = -1 /* current */);
+ bool test__state(std::string &response, int id = -1 /* current */);
+ bool test__interact(std::string &response, int amount, unsigned int id = -1 /* current */);
+ bool test__reset(std::string &response, bool soft_hard = true, unsigned int id = -2 /* apply to all the tests */);
+ bool test__repeats(std::string &response, int amount);
+ bool test__auto_reset(std::string &response, bool soft_hard);
+ bool test__initialized(std::string &response);
+ bool test__finished(std::string &response);
+ bool test__clear(std::string &response);
+ bool test__junit(std::string &response, const std::string & targetFile);
+ bool test__summary_counts(std::string &response);
+ bool test__summary_states(std::string &response);
+ bool test__summary(std::string &response);
+ bool test__report(std::string &response,
+ const std::string & state = "all" /* initialized|in-progress|failed|success|[all]|none */, bool enable = true);
+ bool test__report_hex(std::string &response, bool enable = true);
+ bool test__dump_stdout(std::string &response, bool enable = true);
};
#endif
projects / anna.git / blobdiff