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
|
// #define _WEBSOCKETPP_CPP11_INTERNAL_
// #define ASIO_STANDALONE
// #include <websocketpp/config/asio_no_tls_client.hpp>
// #include <websocketpp/client.hpp>
// using client = websocketpp::client<websocketpp::config::asio_client>;
#include "mongoose.h"
#include "json.hpp"
using json = nlohmann::json;
#include <string>
namespace ws
{
// client c;
// void on_message(websocketpp::connection_hdl hdl, client::message_ptr msg) {
// auto j = json::parse(msg->get_payload());
// int op = j["op"].get<int>();
// if (op == 0) {
// json response = { { "op", 1 },
// { "d", {
// { "rpcVersion", 1 },
// } } };
// auto responseStr = response.dump();
// websocketpp::lib::error_code ec;
// c.send(hdl, responseStr, websocketpp::frame::opcode::TEXT, ec);
// if (ec)
// MessageBoxA(NULL, ec.message().c_str(), "error", MB_OK);
// } else if (op == 2) {
// MessageBoxA(NULL, "hura", "connected", MB_OK);
// }
// }
// void init()
// {
// c.set_access_channels(websocketpp::log::alevel::all);
// c.clear_access_channels(websocketpp::log::alevel::frame_payload);
// c.set_error_channels(websocketpp::log::elevel::all);
// // Initialize ASIO
// c.init_asio();
// // Register our message handler
// c.set_message_handler(&on_message);
// }
// void connect(std::string address)
// {
// websocketpp::lib::error_code ec;
// client::connection_ptr con = c.get_connection(address, ec);
// if (ec) {
// std::cout << "could not create connection because: " << ec.message() << std::endl;
// return;
// }
// c.connect(con);
// }
// void update()
// {
// c.run_one();
// }
mg_mgr mgr;
mg_connection *c = nullptr;
bool done = false;
static void cb(struct mg_connection *c, int ev, void *ev_data, void *fn_data) {
if (ev == MG_EV_ERROR || ev == MG_EV_CLOSE) {
MessageBoxA(NULL, "", "Error", MB_OK);
} else if (ev == MG_EV_WS_OPEN) {
//mg_ws_send(c, "hello", 5, WEBSOCKET_OP_TEXT);
} else if (ev == MG_EV_WS_MSG) {
struct mg_ws_message *wm = (struct mg_ws_message *) ev_data;
std::string jsonStr(wm->data.ptr, wm->data.len);
auto msg = json::parse(jsonStr);
int op = msg["op"].get<int>();
if (op == 0) {
json response = {
{"op", 1},
{"d", {
{"rpcVersion", 1},
}}
};
auto responseStr = response.dump();
MessageBoxA(NULL,
(std::string("is_client") + std::to_string(c->is_client) +
std::string(" is_accepted") + std::to_string(c->is_accepted) +
std::string(" is_readable") + std::to_string(c->is_readable) +
std::string(" is_writable") + std::to_string(c->is_writable)).c_str(),
"", MB_OK);
mg_ws_send(c, "{\"op\":1,\"d\":{\"rpcVersion\":1}}", 29, WEBSOCKET_OP_TEXT);
}
else if (op == 2)
{
MessageBoxA(NULL, "hura", "connected", MB_OK);
}
}
if (ev == MG_EV_ERROR || ev == MG_EV_CLOSE) {
done = true;
}
}
void init()
{
mg_mgr_init(&mgr);
}
void connect(std::string address)
{
c = mg_ws_connect(&mgr, address.c_str(), cb, nullptr, nullptr);
}
void update()
{
if (c && !done)
mg_mgr_poll(&mgr, 10);
else
MessageBoxA(NULL, "cant update", "Nio", MB_OK);
}
void identify()
{
MessageBoxA(NULL,
(std::string("is_client") + std::to_string(c->is_client) +
std::string(" is_accepted") + std::to_string(c->is_accepted) +
std::string(" is_readable") + std::to_string(c->is_readable) +
std::string(" is_writable") + std::to_string(c->is_writable)).c_str(),
"", MB_OK);
mg_ws_send(c, "{\"op\":1,\"d\":{\"rpcVersion\":1}}", 29, WEBSOCKET_OP_TEXT);
}
}
|
