90 lines
2.5 KiB
C++
90 lines
2.5 KiB
C++
|
#include "crow.h"
|
||
|
|
#include <string>
|
||
|
|
#include <vector>
|
||
|
|
#include <chrono>
|
||
|
|
|
||
|
|
using namespace std;
|
||
|
|
|
||
|
|
vector<string> msgs;
|
||
|
|
vector<pair<crow::response*, decltype(chrono::steady_clock::now())>> ress;
|
||
|
|
|
||
|
|
void broadcast(const string& msg)
|
||
|
|
{
|
||
|
|
msgs.push_back(msg);
|
||
|
|
crow::json::wvalue x;
|
||
|
|
x["msgs"][0] = msgs.back();
|
||
|
|
x["last"] = msgs.size();
|
||
|
|
string body = x.dump();
|
||
|
|
for (auto p : ress)
|
||
|
|
{
|
||
|
|
auto* res = p.first;
|
||
|
|
CROW_LOG_DEBUG << res << " replied: " << body;
|
||
|
|
res->end(body);
|
||
|
|
}
|
||
|
|
ress.clear();
|
||
|
|
}
|
||
|
|
// To see how it works go on {ip}:40080 but I just got it working with external build (not directly in IDE, I guess a problem with dependency)
|
||
|
|
int main()
|
||
|
|
{
|
||
|
|
crow::SimpleApp app;
|
||
|
|
crow::mustache::set_base(".");
|
||
|
|
|
||
|
|
CROW_ROUTE(app, "/")
|
||
|
|
([] {
|
||
|
|
crow::mustache::context ctx;
|
||
|
|
return crow::mustache::load("example_chat.html").render();
|
||
|
|
});
|
||
|
|
|
||
|
|
CROW_ROUTE(app, "/logs")
|
||
|
|
([] {
|
||
|
|
CROW_LOG_INFO << "logs requested";
|
||
|
|
crow::json::wvalue x;
|
||
|
|
int start = max(0, (int)msgs.size() - 100);
|
||
|
|
for (int i = start; i < (int)msgs.size(); i++)
|
||
|
|
x["msgs"][i - start] = msgs[i];
|
||
|
|
x["last"] = msgs.size();
|
||
|
|
CROW_LOG_INFO << "logs completed";
|
||
|
|
return x;
|
||
|
|
});
|
||
|
|
|
||
|
|
CROW_ROUTE(app, "/logs/<int>")
|
||
|
|
([](const crow::request& /*req*/, crow::response& res, int after) {
|
||
|
|
CROW_LOG_INFO << "logs with last " << after;
|
||
|
|
if (after < (int)msgs.size())
|
||
|
|
{
|
||
|
|
crow::json::wvalue x;
|
||
|
|
for (int i = after; i < (int)msgs.size(); i++)
|
||
|
|
x["msgs"][i - after] = msgs[i];
|
||
|
|
x["last"] = msgs.size();
|
||
|
|
|
||
|
|
res.write(x.dump());
|
||
|
|
res.end();
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
vector<pair<crow::response*, decltype(chrono::steady_clock::now())>> filtered;
|
||
|
|
for (auto p : ress)
|
||
|
|
{
|
||
|
|
if (p.first->is_alive() && chrono::steady_clock::now() - p.second < chrono::seconds(30))
|
||
|
|
filtered.push_back(p);
|
||
|
|
else
|
||
|
|
p.first->end();
|
||
|
|
}
|
||
|
|
ress.swap(filtered);
|
||
|
|
ress.push_back({&res, chrono::steady_clock::now()});
|
||
|
|
CROW_LOG_DEBUG << &res << " stored " << ress.size();
|
||
|
|
}
|
||
|
|
});
|
||
|
|
|
||
|
|
CROW_ROUTE(app, "/send")
|
||
|
|
.methods("GET"_method, "POST"_method)([](const crow::request& req) {
|
||
|
|
CROW_LOG_INFO << "msg from client: " << req.body;
|
||
|
|
broadcast(req.body);
|
||
|
|
return "";
|
||
|
|
});
|
||
|
|
|
||
|
|
app.port(40080)
|
||
|
|
//.multithreaded()
|
||
|
|
.run();
|
||
|
|
}
|