sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-04-28 12:22:22 +02:00
Code Issues Packages Projects Releases Wiki Activity

New REST interface

Browse Source
This commit is contained in:
babic_a
2019-04-23 16:40:16 +02:00
parent 7cd11be183
commit 4fddd37974
2 changed files with 27 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/src/RestApi.cpp
+26 -13
View File
@@ -6,26 +6,34 @@
using namespace std;
void RestApi::start_rest_api(crow::SimpleApp app, WriterManager& writer_manager, uint16_t port)
const unordered_map<string, DATA_TYPE> RestApi::rest_start_parameters =
{
{"n_frames", NX_INT},
{"user_id", NX_INT},
{"output_file", NX_CHAR}
};
void RestApi::start_rest_api(WriterManager& writer_manager, uint16_t port)
{
#ifdef DEBUG_OUTPUT
cout << "[rest_interface::start_rest_api] Starting rest interface on port " << port << endl;
cout << "[rest_interface::start_rest_api] Starting rest interface on port ";
cout << port << endl;
cout << "[rest_interface::start_rest_api] Accepting start parameters:" << endl;
for (const auto& item : rest_start_parameters) {
cout << "\t " << item.key() << endl;
}
#endif
CROW_ROUTE(app, "/kill")([&](){
writer_manager.kill();
crow::json::wvalue result;
result["status"] = writer_manager.get_status();
return result;
});
crow::SimpleApp app;
CROW_ROUTE(app, "/stop")([&](){
writer_manager.stop();
crow::json::wvalue result;
result["state"] = "ok";
result["status"] = writer_manager.get_status();
return result;
@@ -33,6 +41,7 @@ void RestApi::start_rest_api(crow::SimpleApp app, WriterManager& writer_manager,
CROW_ROUTE (app, "/status") ([&](){
crow::json::wvalue result;
result["state"] = "ok";
result["status"] = writer_manager.get_status();
return result;
@@ -45,6 +54,7 @@ void RestApi::start_rest_api(crow::SimpleApp app, WriterManager& writer_manager,
result[item.first] = item.second;
}
result["state"] = "ok";
result["status"] = writer_manager.get_status();
return result;
@@ -74,7 +84,8 @@ void RestApi::start_rest_api(crow::SimpleApp app, WriterManager& writer_manager,
stringstream error_message;
using namespace date;
error_message << "[" << std::chrono::system_clock::now() << "]";
error_message << "[RestApi::start(post)] No NX type mapping for parameter " << parameter_name << endl;
error_message << "[RestApi::start(post)] No NX type mapping ";
error_message << "for parameter " << parameter_name << endl;
throw runtime_error(error_message.str());
}
@@ -83,7 +94,8 @@ void RestApi::start_rest_api(crow::SimpleApp app, WriterManager& writer_manager,
stringstream error_message;
using namespace date;
error_message << "[" << std::chrono::system_clock::now() << "]";
error_message << "[RestApi::start(post)] No type mapping for received parameter " << parameter_name << " in file format."<< endl;
error_message << "[RestApi::start(post)] No type mapping ";
error_message << "for received parameter " << parameter_name << endl;
throw runtime_error(error_message.str());
@@ -91,7 +103,8 @@ void RestApi::start_rest_api(crow::SimpleApp app, WriterManager& writer_manager,
stringstream error_message;
using namespace date;
error_message << "[" << std::chrono::system_clock::now() << "]";
error_message << "[RestApi::start(post)] Cannot cast parameter " << parameter_name << " into specified type." << endl;
error_message << "[RestApi::start(post)] Cannot cast parameter ";
error_message << parameter_name << " into specified type." << endl;
throw runtime_error(error_message.str());
lib/src/RestApi.hpp
+1
View File
@@ -7,6 +7,7 @@
namespace RestApi
{
extern const std::unordered_map<std::string, DATA_TYPE> rest_start_parameters;
void start_rest_api(WriterManager& writer_manager, uint16_t port);
}