aboutsummaryrefslogtreecommitdiff
path: root/umosapi.cpp
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--umosapi.cpp247
1 files changed, 118 insertions, 129 deletions
diff --git a/umosapi.cpp b/umosapi.cpp
index 95831d9..e3052a6 100644
--- a/umosapi.cpp
+++ b/umosapi.cpp
@@ -1,13 +1,11 @@
+#include "umosapi.h"
+
#include <string.h>
#include <filesystem>
#include <unistd.h>
#include <sys/types.h>
#include <pwd.h>
-#include <pistache/http.h>
-#include <pistache/description.h>
-#include <pistache/endpoint.h>
-
#include <pistache/serializer/rapidjson.h>
#include <bsoncxx/builder/stream/document.hpp>
@@ -99,154 +97,145 @@ std::ifstream is_file(config_path);
}
-class UmosapiService {
- public:
-
- UmosapiService(Address addr)
- : httpEndpoint(std::make_shared<Http::Endpoint>(addr))
- , desc("Unity Mongo Save API", "0.1")
- { }
-
- void init(size_t thr = 2) {
- auto opts = Http::Endpoint::options()
- .threads(thr);
- httpEndpoint->init(opts);
- createDescription();
- }
-
- void start(std::string swaggerui) {
- router.initFromDescription(desc);
-
- Rest::Swagger swagger(desc);
- swagger
- .uiPath("/doc")
- .uiDirectory(swaggerui)
- .apiPath("/api")
- .serializer(&Rest::Serializer::rapidJson)
- .install(router);
+UmosapiService::UmosapiService(Address addr)
+ : httpEndpoint(std::make_shared<Http::Endpoint>(addr))
+ , desc("Unity Mongo Save API", "0.1")
+{ }
- httpEndpoint->setHandler(router.handler());
- httpEndpoint->serve();
- }
+void UmosapiService::init(size_t thr = 2) {
+ auto opts = Http::Endpoint::options()
+ .threads(thr);
+ httpEndpoint->init(opts);
+ createDescription();
+}
- private:
- void createDescription() {
- desc
- .info()
- .license("Apache", "https://neodarz.net");
-
- auto backendErrorResponse =
- desc.response(Http::Code::Internal_Server_Error, "Backend is dead, it's the end of the world");
-
- desc
- .schemes(Rest::Scheme::Http)
- .basePath("/v1")
- .produces(MIME(Application, Json))
- .consumes(MIME(Application, Json));
-
- desc
- .route(desc.get("/ready"))
- .bind(&Generic::handleReady)
- .response(Http::Code::Ok, "Api started")
- .response(backendErrorResponse);
-
- auto versionPath = desc.path("/v1");
-
- versionPath
- .route(desc.get("/:mcollection"))
- .bind(&UmosapiService::retrieveAll, this)
- .produces(MIME(Application, Json))
- .parameter<Rest::Type::String>("mcollection", "Name of the collection where the uobjects are located")
- .response(Http::Code::Ok, "List of uobjects")
- .response(backendErrorResponse);
-
- versionPath
- .route(desc.post("/:mcollection"))
- .bind(&UmosapiService::addUObject, this)
- .produces(MIME(Application, Json))
- .parameter<Rest::Type::String>("mcollection", "Name of the collection where the uobjects are located")
- .response(Http::Code::Ok, "Uobject created")
- .response(backendErrorResponse);
- }
+void UmosapiService::start(std::string swaggerui) {
+ router.initFromDescription(desc);
- void retrieveAll(const Rest::Request& request, Http::ResponseWriter response) {
- mongocxx::client conn{mongocxx::uri{config["mongoURI"]}};
+ Rest::Swagger swagger(desc);
+ swagger
+ .uiPath("/doc")
+ .uiDirectory(swaggerui)
+ .apiPath("/api")
+ .serializer(&Rest::Serializer::rapidJson)
+ .install(router);
- auto collection = conn[config["mongo_db"]][request.param(":mcollection").as<string>()];
+ httpEndpoint->setHandler(router.handler());
+ httpEndpoint->serve();
+}
- auto cursor = collection.find({});
+void UmosapiService::createDescription() {
+ desc
+ .info()
+ .license("Apache", "https://neodarz.net");
+
+ auto backendErrorResponse =
+ desc.response(Http::Code::Internal_Server_Error, "Backend is dead, it's the end of the world");
+
+ desc
+ .schemes(Rest::Scheme::Http)
+ .basePath("/v1")
+ .produces(MIME(Application, Json))
+ .consumes(MIME(Application, Json));
+
+ desc
+ .route(desc.get("/ready"))
+ .bind(&Generic::handleReady)
+ .response(Http::Code::Ok, "Api started")
+ .response(backendErrorResponse);
+
+ auto versionPath = desc.path("/v1");
+
+ versionPath
+ .route(desc.get("/:mcollection"))
+ .bind(&UmosapiService::UmosapiService::retrieveAll, this)
+ .produces(MIME(Application, Json))
+ .parameter<Rest::Type::String>("mcollection", "Name of the collection where the uobjects are located")
+ .response(Http::Code::Ok, "List of uobjects")
+ .response(backendErrorResponse);
+
+ versionPath
+ .route(desc.post("/:mcollection"))
+ .bind(&UmosapiService::UmosapiService::addUObject, this)
+ .produces(MIME(Application, Json))
+ .parameter<Rest::Type::String>("mcollection", "Name of the collection where the uobjects are located")
+ .response(Http::Code::Ok, "Uobject created")
+ .response(backendErrorResponse);
+}
- auto jsonObjects = json_object_new_array();
+void UmosapiService::retrieveAll(const Rest::Request& request, Http::ResponseWriter response) {
+ mongocxx::client conn{mongocxx::uri{config["mongoURI"]}};
- for (auto&& doc : cursor) {
- json_object_array_add(jsonObjects, json_tokener_parse(bsoncxx::to_json(doc).c_str()));
- }
+ auto collection = conn[config["mongo_db"]][request.param(":mcollection").as<string>()];
- response.send(Http::Code::Ok, json_object_to_json_string_ext(jsonObjects, JSON_C_TO_STRING_SPACED | JSON_C_TO_STRING_PRETTY), MIME(Application, Json));
- json_object_put(jsonObjects);
- }
+ auto cursor = collection.find({});
- void addUObject(const Rest::Request& request, Http::ResponseWriter response) {
- mongocxx::client conn{mongocxx::uri{config["mongoURI"]}};
+ auto jsonObjects = json_object_new_array();
- auto collection = conn[config["mongo_db"]][request.param(":mcollection").as<string>()];
+ for (auto&& doc : cursor) {
+ json_object_array_add(jsonObjects, json_tokener_parse(bsoncxx::to_json(doc).c_str()));
+ }
- auto document = bsoncxx::from_json(request.body().c_str());
+ response.send(Http::Code::Ok, json_object_to_json_string_ext(jsonObjects, JSON_C_TO_STRING_SPACED | JSON_C_TO_STRING_PRETTY), MIME(Application, Json));
+ json_object_put(jsonObjects);
+}
- auto result = collection.insert_one(document.view());
+void UmosapiService::addUObject(const Rest::Request& request, Http::ResponseWriter response) {
+ mongocxx::client conn{mongocxx::uri{config["mongoURI"]}};
- std::string oid = result->inserted_id().get_oid().value.to_string();
+ auto collection = conn[config["mongo_db"]][request.param(":mcollection").as<string>()];
- auto jsonObject = json_object_new_object();
+ auto document = bsoncxx::from_json(request.body().c_str());
- int stringlen = 0;
- stringlen = strlen( request.body().c_str());
- struct json_tokener *tok = json_tokener_new();
- enum json_tokener_error jerr;
+ auto result = collection.insert_one(document.view());
- json_object *json_datas = NULL;
+ std::string oid = result->inserted_id().get_oid().value.to_string();
- do {
- json_datas = json_tokener_parse_ex(tok, request.body().c_str(), stringlen);
- } while ((jerr = json_tokener_get_error(tok)) == json_tokener_continue);
+ auto jsonObject = json_object_new_object();
- if (jerr != json_tokener_success)
- {
- fprintf(stderr, "Error: %s\n", json_tokener_error_desc(jerr));
- }
+ int stringlen = 0;
+ stringlen = strlen( request.body().c_str());
+ struct json_tokener *tok = json_tokener_new();
+ enum json_tokener_error jerr;
- if (json_object_get_type(json_datas) == json_type_object) {
- /* Create an object with the following template:
- * {
- * "_id": {
- * "$oid": "5d484d371ec4865f767d8424"
- * },
- * "datas": {
- * [...]
- * }
- * }
- */
+ json_object *json_datas = NULL;
- auto json_id = json_object_new_object();
- auto json_oid = json_object_new_string(oid.c_str());
+ do {
+ json_datas = json_tokener_parse_ex(tok, request.body().c_str(), stringlen);
+ } while ((jerr = json_tokener_get_error(tok)) == json_tokener_continue);
- json_object_object_add(json_id, "$oid", json_oid);
- json_object_object_add(jsonObject, "_id", json_id);
- json_object_object_add(jsonObject, "datas", json_datas);
- } else {
- cout << typeid(json_datas).name() << endl;
- cout << "json_datas type: " << json_type_to_name(json_object_get_type(json_datas)) << endl;
- }
- json_tokener_reset(tok);
+ if (jerr != json_tokener_success)
+ {
+ fprintf(stderr, "Error: %s\n", json_tokener_error_desc(jerr));
+ }
- response.send(Http::Code::Ok, json_object_to_json_string_ext(jsonObject, JSON_C_TO_STRING_SPACED | JSON_C_TO_STRING_PRETTY), MIME(Application, Json));
- json_object_put(jsonObject);
- }
+ if (json_object_get_type(json_datas) == json_type_object) {
+ /* Create an object with the following template:
+ * {
+ * "_id": {
+ * "$oid": "5d484d371ec4865f767d8424"
+ * },
+ * "datas": {
+ * [...]
+ * }
+ * }
+ */
+
+ auto json_id = json_object_new_object();
+ auto json_oid = json_object_new_string(oid.c_str());
+
+ json_object_object_add(json_id, "$oid", json_oid);
+ json_object_object_add(jsonObject, "_id", json_id);
+ json_object_object_add(jsonObject, "datas", json_datas);
+ } else {
+ cout << typeid(json_datas).name() << endl;
+ cout << "json_datas type: " << json_type_to_name(json_object_get_type(json_datas)) << endl;
+ }
+ json_tokener_reset(tok);
- std::shared_ptr<Http::Endpoint> httpEndpoint;
- Rest::Description desc;
- Rest::Router router;
-};
+ response.send(Http::Code::Ok, json_object_to_json_string_ext(jsonObject, JSON_C_TO_STRING_SPACED | JSON_C_TO_STRING_PRETTY), MIME(Application, Json));
+ json_object_put(jsonObject);
+}
int main(int argc, char *argv[]) {
generated by cgit v1.2.1 (git 2.18.0) at 2024-11-22 05:33:13 +0000