-
Notifications
You must be signed in to change notification settings - Fork 21
Expand file tree
/
Copy pathWebControl.h
More file actions
67 lines (61 loc) · 3.83 KB
/
WebControl.h
File metadata and controls
67 lines (61 loc) · 3.83 KB
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
#pragma once
#include <memory>
#include <chrono>
#include "rbslib/Network.h"
#include "proxy.h"
#include "json/CJsonObject.h"
#include <list>
#include <shared_mutex>
#include "asio/import_asio.h"
/*
* 网页控制服务类，提供利用WebAPI控制服务器的功能
*/
class WebControlServer
{
protected:
RbsLib::Network::HTTP::HTTPServer server;
std::string user_token;
//token过期时间
std::chrono::system_clock::time_point token_expiry_time;
std::shared_ptr<std::string> user_password;
bool is_request_stop = false;
std::list<std::pair<std::time_t, std::string>> logs;
int max_log_size = 100; //最大日志条数
std::shared_mutex log_mutex; //日志互斥锁
asio::io_context io_context;
std::map<std::time_t, uint32_t> time_online_users;
std::shared_mutex time_online_users_mutex;
asio::awaitable<void> TimeTaskUsers(std::shared_ptr<Proxy>& proxy_client);
static void SendErrorResponse(const RbsLib::Network::TCP::TCPConnection& connection, int status_code, const std::string& message = "");
static void SendErrorResponse(const RbsLib::Network::TCP::TCPConnection& connection, const neb::CJsonObject& json, int http_status_code = 200);
static void SendSuccessResponse(const RbsLib::Network::TCP::TCPConnection& connection, const neb::CJsonObject& json);
static bool CheckToken(const std::string& cookie,const std::string& token,const std::chrono::system_clock::time_point& token_expiry_time);
static void GetOnlineUsers(neb::CJsonObject& response, const std::shared_ptr<Proxy>& proxy_client);
static void GetWhiteList(neb::CJsonObject& response, const std::shared_ptr<Proxy>& proxy_client);
static void GetBlackList(neb::CJsonObject& response, const std::shared_ptr<Proxy>& proxy_client);
static bool AddBlacklistUser(neb::CJsonObject& response,const neb::CJsonObject& request, const std::shared_ptr<Proxy>& proxy_client);
static bool RemoveBlacklistUser(neb::CJsonObject& response, const neb::CJsonObject& request, const std::shared_ptr<Proxy>& proxy_client);
static bool AddWhitelistUser(neb::CJsonObject& response, const neb::CJsonObject& request, const std::shared_ptr<Proxy>& proxy_client);
static bool RemoveWhitelistUser(neb::CJsonObject& response, const neb::CJsonObject& request, const std::shared_ptr<Proxy>& proxy_client);
static bool EnableWhitelist(neb::CJsonObject& response, const std::shared_ptr<Proxy>& proxy_client);
static bool DisableWhitelist(neb::CJsonObject& response, const std::shared_ptr<Proxy>& proxy_client);
static void GetUserProxyList(neb::CJsonObject& response, const std::shared_ptr<Proxy>& proxy_client);
static bool SetUserProxy(neb::CJsonObject& response, const neb::CJsonObject& request, const std::shared_ptr<Proxy>& proxy_client);
static bool RemoveUserProxy(neb::CJsonObject& response, const neb::CJsonObject& request, const std::shared_ptr<Proxy>& proxy_client);
//设置最大玩家数，-1表示不限制
static bool SetMaxUsers(neb::CJsonObject& response, const neb::CJsonObject& request, const std::shared_ptr<Proxy>& proxy_client);
static bool KickPlayer(neb::CJsonObject& response, const neb::CJsonObject& request, const std::shared_ptr<Proxy>& proxy_client);
static void GetStartTime(neb::CJsonObject& response, const std::shared_ptr<Proxy>& proxy_client);
bool GetUserNumberList(neb::CJsonObject& response,neb::CJsonObject& request, const std::shared_ptr<Proxy>& proxy_client);
void GetLogs(neb::CJsonObject& response, const std::shared_ptr<Proxy>& proxy_client);
static void GetMotd(neb::CJsonObject& response, const std::shared_ptr<Proxy>& proxy_client);
static bool SetMotd(neb::CJsonObject& response, const neb::CJsonObject& request, const std::shared_ptr<Proxy>& proxy_client);
public:
WebControlServer(const std::string& address, std::uint16_t port);
~WebControlServer() noexcept;
void SetUserPassword(const std::string& password);
//在独立线程上启动服务器
void Start(std::shared_ptr<Proxy>& proxy_client);
//停止服务并等待服务结束
void Stop(void);
};