1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
|
#include <bsoncxx/builder/stream/document.hpp>
#include <bsoncxx/json.hpp>
#include <mongocxx/client.hpp>
#include <mongocxx/instance.hpp>
#include <mongocxx/client.hpp>
#include <mongocxx/stdx.hpp>
#include <mongocxx/uri.hpp>
#include <json-c/json.h>
#include <nlohmann/json.hpp>
#include "umosapi.h"
#include "../shared.h"
#include "../db/mongo_access.h"
#include "../db/uobject.h"
mongo_access mongo;
using bsoncxx::builder::stream::close_array;
using bsoncxx::builder::stream::close_document;
using bsoncxx::builder::stream::document;
using bsoncxx::builder::stream::finalize;
using bsoncxx::builder::stream::open_array;
using bsoncxx::builder::stream::open_document;
using json = nlohmann::json;
using namespace std;
using namespace Pistache;
namespace Generic {
void handleReady(const Rest::Request&, Http::ResponseWriter response) {
response.send(Http::Code::Ok, "1");
}
}
UmosapiService::UmosapiService(Address addr)
: httpEndpoint(std::make_shared<Http::Endpoint>(addr))
, desc("Unity Mongo Save API", "0.1")
{ }
void UmosapiService::init(size_t thr = 2) {
auto uri = mongocxx::uri{config["mongoURI"]};
mongo.configure(std::move(uri));
auto opts = Http::Endpoint::options()
.threads(thr);
httpEndpoint->init(opts);
createDescription();
}
void UmosapiService::start(std::string swaggerui) {
router.initFromDescription(desc);
Rest::Swagger swagger(desc);
swagger
.uiPath("/doc")
.uiDirectory(swaggerui)
.apiPath("/api")
.serializer(&Rest::Serializer::rapidJson)
.install(router);
httpEndpoint->setHandler(router.handler());
httpEndpoint->serve();
}
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);
versionPath
.route(desc.del("/:mcollection/:oid"))
.bind(&UmosapiService::UmosapiService::deleteUObject, this)
.produces(MIME(Application, Json))
.parameter<Rest::Type::String>("mcollection", "Name of the collection where the uobjects are located")
.parameter<Rest::Type::String>("oid", "MongoDB oid of the uobject")
.response(Http::Code::Ok, "Uobject deleted")
.response(backendErrorResponse);
versionPath
.route(desc.get("/:mcollection/:key/:value"))
.bind(&UmosapiService::UmosapiService::searchUObjectByKeyValue, this)
.produces(MIME(Application, Json))
.parameter<Rest::Type::String>("mcollection", "Name of the collection where the uobjects are located")
.parameter<Rest::Type::String>("key", "Key of uobject to search, ex.: kil or total.kill")
.parameter<Rest::Type::String>("value", "Value of uobject to search, ex.: 12")
.response(Http::Code::Ok, "Uobject found")
.response(backendErrorResponse);
}
void UmosapiService::retrieveAll(const Rest::Request& request, Http::ResponseWriter response) {
auto jsonObjects = json_object_new_array();
auto json_string = uobject::retrieveAll(request.param(":mcollection").as<string>(), jsonObjects);
json_object_put(jsonObjects);
response.send(Http::Code::Ok, json_string, MIME(Application, Json));
}
void UmosapiService::addUObject(const Rest::Request& request, Http::ResponseWriter response) {
auto jsonObject = json_object_new_object();
auto json_string = uobject::add(request.param(":mcollection").as<string>(), jsonObject, request.body().c_str());
response.send(Http::Code::Ok, json_string, MIME(Application, Json));
json_object_put(jsonObject);
}
void UmosapiService::deleteUObject(const Rest::Request& request, Http::ResponseWriter response) {
auto jsonObjet = json_object_new_object();
auto json_string = uobject::remove(request.param(":mcollection").as<string>(), request.param(":oid").as<string>(), jsonObjet);
response.send(Http::Code::Ok, json_string, MIME(Application, Json));
json_object_put(jsonObjet);
}
void UmosapiService::searchUObjectByKeyValue(const Rest::Request& request, Http::ResponseWriter response) {
auto jsonObject = json_object_new_array();
auto json_string = uobject::searchKeyValue(request.param(":mcollection").as<string>(), request.param(":key").as<string>(), request.param(":value").as<string>(), jsonObject);
response.send(Http::Code::Ok, json_string, MIME(Application, Json));
json_object_put(jsonObject);
}
|
