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
|
#include <iostream>
#include <functional>
#include <unordered_map>
#include "crow.h"
#define NULL_STRING std::string("null")
#define EMPTY_STRING std::string("")
#define NO_SUCH_COMMAND std::string("no_such_command")
typedef std::function<crow::json::wvalue(std::string const &arguments, std::string const &session,
void *payload)> handler_func;
struct CommandHandler {
[[nodiscard]] crow::json::wvalue exec(std::string const &arguments, std::string const &session) const {
return func(arguments, session, payload);
}
handler_func func;
void *payload{nullptr};
};
crow::json::wvalue stopHandler(std::string const &arguments, std::string const &session, void *payload);
crow::json::wvalue klingerHandler(std::string const &arguments, std::string const &session, void *payload);
[[maybe_unused]] void decl_me_daddy(int not_an_int) { (void) not_an_int; }
int main() {
crow::SimpleApp app;
// command --> handler
static std::unordered_map<std::string, CommandHandler> const commands{
{"stop", {stopHandler, &app}},
{"klinger", {klingerHandler}}
};
CROW_ROUTE(app, "/")
.methods("POST"_method)
([&app](crow::request const &request) {
auto data = crow::json::load(request.body);
if (!data)
return crow::response(400);
if (!data.count("command"))
return crow::response(400, "malformed request: missing `command` field\n");
std::string command = (data.count("command") ? data["command"].s() : NO_SUCH_COMMAND);
std::string arguments = (data.count("arguments") ? data["arguments"].s() : EMPTY_STRING);
std::string session = (data.count("session") ? data["session"].s() : NULL_STRING);
if (auto itor = commands.find(command); itor != commands.end()) {
auto handler = itor->second;
return crow::response{handler.exec(arguments, session)};
}
crow::json::wvalue response;
return crow::response{"no such command!\n"};
});
app.port(18080).multithreaded().run();
std::cout << "Stopped successfully" << std::endl;
}
crow::json::wvalue klingerHandler(std::string const &arguments, std::string const &session, void *payload) {
(void)payload;
using namespace crow::json;
crow::json::wvalue response(type::Object);
std::vector<wvalue> reply_vec;
std::vector<wvalue> annotation_vec;
wvalue annotation(type::Object);
annotation["type"] = "none";
annotation["extra"] = "";
annotation_vec.push_back(std::move(annotation));
wvalue reply(type::Object);
reply["text"] = "Bonjour!";
reply["annotations"] = std::move(annotation_vec);
reply_vec.push_back(std::move(reply));
response["success"] = true;
response["session"] = NULL_STRING;
response["reply"] = std::move(reply_vec);
return response;
}
crow::json::wvalue stopHandler(std::string const &arguments, std::string const &session, void *payload) {
auto app = (crow::SimpleApp*) payload;
app->stop();
using namespace crow::json;
crow::json::wvalue response(type::Object);
std::vector<wvalue> reply_vec;
std::vector<wvalue> annotation_vec;
wvalue annotation(type::Object);
annotation["type"] = "bold";
annotation["extra"] = "";
annotation_vec.push_back(std::move(annotation));
wvalue reply(type::Object);
reply["text"] = "stopped.";
reply["annotations"] = std::move(annotation_vec);
reply_vec.push_back(std::move(reply));
response["success"] = true;
response["session"] = NULL_STRING;
response["reply"] = std::move(reply_vec);
return response;
}
// curl -d '{"command":"klinger", "b":"12"}' -H "Content-Type: application/json" -X POST http://localhost:18080/
|
