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
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
|
/*
RailControl - Model Railway Control Software
Copyright (c) 2017-2025 by Teddy / Dominik Mahrer - www.railcontrol.org
RailControl is free software; you can redistribute it and/or modify it
under the terms of the GNU General Public License as published by the
Free Software Foundation; either version 3, or (at your option) any
later version.
RailControl is distributed in the hope that it will be useful, but
WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
See the GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with RailControl; see the file LICENCE. If not see
<http://www.gnu.org/licenses/>.
*/
#pragma once
#include <map>
#include <mutex>
#include <sstream>
#include <vector>
#include "ControlInterface.h"
#include "DataModel/AccessoryBase.h"
#include "Logger/Logger.h"
#include "Manager.h"
#include "Network/TcpServer.h"
namespace Server { namespace Web
{
class WebClient;
class WebServer : public ControlInterface, private Network::TcpServer
{
public:
WebServer() = delete;
WebServer(const WebServer&) = delete;
WebServer& operator=(const WebServer&) = delete;
WebServer(Manager& manager, const std::string& webserveraddress, const unsigned short port);
~WebServer();
void Start() override;
void Stop() override;
void Work(Network::TcpConnection* connection) override;
bool NextUpdate(unsigned int& updateIDClient, std::string& s);
inline const std::string& GetName() const override
{
static const std::string WebserverName("WebServer");
return WebserverName;
}
void AccessoryDelete(const AccessoryID accessoryID, const std::string& name, const std::string& matchKey) override;
void AccessorySettings(const AccessoryID accessoryID, const std::string& name, const std::string& matchkey) override;
void AccessoryState(const ControlType controlType, const DataModel::Accessory* accessory) override;
void Booster(const ControlType controlType, const BoosterState status) override;
void FeedbackDelete(const FeedbackID feedbackID, const std::string& name) override;
void FeedbackSettings(const FeedbackID feedbackID, const std::string& name) override;
void FeedbackState(const std::string& name, const FeedbackID feedbackID, const DataModel::Feedback::FeedbackState state) override;
void LayerDelete(const LayerID layerID, const std::string& name) override;
void LayerSettings(const LayerID layerID, const std::string& name) override;
void LocoBaseDestinationReached(const DataModel::LocoBase* loco,
const DataModel::Route* route,
const DataModel::Track* track) override;
void LocoBaseOrientation(const ControlType controlType,
const DataModel::LocoBase* loco,
const Orientation direction) override;
void LocoBaseFunction(const ControlType controlType,
const DataModel::LocoBase* loco,
const DataModel::LocoFunctionNr function,
const DataModel::LocoFunctionState on) override;
void LocoBaseRelease(const DataModel::LocoBase* loco) override;
void LocoBaseSpeed(const ControlType controlType,
const DataModel::LocoBase* loco,
const Speed speed) override;
void LocoBaseStart(const DataModel::LocoBase* loco) override;
void LocoBaseStop(const DataModel::LocoBase* loco) override;
void LocoSettings(const LocoID locoID,
const std::string& name,
const std::string& matchKey) override;
void LocoDelete(const LocoID locoID,
const std::string& name,
const std::string& matchKey) override;
void MultipleUnitSettings(const MultipleUnitID multipleUnitID,
const std::string& name,
const std::string& matchKey) override;
void MultipleUnitDelete(const MultipleUnitID multipleUnitID,
const std::string& name,
const std::string& matchkey) override;
void RouteDelete(const RouteID routeID, const std::string& name) override;
void RouteRelease(const RouteID routeID) override;
void RouteSettings(const RouteID routeID, const std::string& name) override;
void SwitchDelete(const SwitchID switchID, const std::string& name, const std::string& matchKey) override;
void SwitchSettings(const SwitchID switchID, const std::string& name, const std::string& matchKey) override;
void SwitchState(const ControlType controlType, const DataModel::Switch* mySwitch) override;
void TrackDelete(const TrackID trackID, const std::string& name) override;
void TrackSettings(const TrackID trackID, const std::string& name) override;
void TrackState(const DataModel::Track* track) override;
void SignalDelete(const SignalID signalID, const std::string& name, const std::string& matchKey) override;
void SignalSettings(const SignalID signalID, const std::string& name, const std::string& matchKey) override;
void SignalState(const ControlType controlType, const DataModel::Signal* signal) override;
void ClusterDelete(const ClusterID clusterID, const std::string& name) override;
void ClusterSettings(const ClusterID clusterID, const std::string& name) override;
void TextDelete(const TextID textID, const std::string& name) override;
void TextSettings(const TextID textID, const std::string& name) override;
void CounterDelete(const CounterID counterID, const std::string& name) override;
void CounterSettings(const CounterID counterID, const std::string& name) override;
void CounterState(const DataModel::Counter* const counter);
void ProgramValue(const CvNumber cv, const CvValue value) override;
inline bool UpdateAvailable()
{
return updateAvailable;
}
inline void AddUpdate(const std::string& command, const Languages::TextSelector status)
{
AddUpdate(command, Languages::GetText(status));
}
private:
template<typename... Args>
inline void AddUpdate(const std::string& command, const Languages::TextSelector text, Args... args)
{
AddUpdate(command, Logger::Logger::Format(Languages::GetText(text), args...));
}
inline void AddUpdate(const std::string& command, const std::string& status)
{
AddUpdate("data: command=" + command + ";status=" + status + "\r\n\r\n");
}
inline void AddUpdate(const Languages::TextSelector status)
{
AddUpdate(std::string("data: status=") + Languages::GetText(status) + "\r\n\r\n");
}
void AddUpdate(const std::string& data);
void LogBrowserInfo(const std::string& webserveraddress, const unsigned short port);
Logger::Logger* logger;
unsigned int lastClientID;
std::vector<WebClient*> clients;
Manager& manager;
std::map<unsigned int,std::string> updates;
std::mutex updateMutex;
unsigned int updateID;
bool updateAvailable;
static const unsigned int MaxUpdates = 10;
};
}} // namespace Server::Web
|
