blob: bfca40fe94fef723635c53a9e23d16e3a5423898 (
plain)
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
|
#pragma once
#include "StarThread.hpp"
#include "StarTcp.hpp"
#include "StarMap.hpp"
#include "StarDataStreamDevices.hpp"
namespace Star {
class UniverseServer;
class ServerRconClient : public Thread {
public:
static const uint32_t SERVERDATA_AUTH = 0x03;
static const uint32_t SERVERDATA_EXECCOMMAND = 0x02;
static const uint32_t SERVERDATA_RESPONSE_VALUE = 0x00;
static const uint32_t SERVERDATA_AUTH_RESPONSE = 0x02;
static const uint32_t SERVERDATA_AUTH_FAILURE = 0xffffffff;
ServerRconClient(UniverseServer* universe, TcpSocketPtr socket);
~ServerRconClient();
void start();
void stop();
protected:
virtual void run();
private:
static size_t const MaxPacketSize = 4096;
STAR_EXCEPTION(NoMoreRequests, StarException);
void receive(size_t size);
void send(uint32_t requestId, uint32_t cmd, String str = "");
void sendAuthFailure();
void sendCmdResponse(uint32_t requestId, String response);
void closeSocket();
void processRequest();
String handleCommand(String commandLine);
UniverseServer* m_universe;
TcpSocketPtr m_socket;
DataStreamBuffer m_packetBuffer;
bool m_stop;
bool m_authed;
String m_rconPassword;
};
typedef shared_ptr<ServerRconClient> ServerRconClientPtr;
}
|