mirror of
https://github.com/Sani7/remote-ui.git
synced 2026-10-27 06:01:14 +01:00
sani7
ee185b68e6
Implements a check to ensure a simulator is active before processing commands. This prevents errors and unexpected behavior when commands are sent without an active simulator. The check is performed at the beginning of the command parsing, and logs an error if no simulator is active, returning an empty JSON object.
75 lines
1.9 KiB
C++
75 lines
1.9 KiB
C++
#pragma once
|
|
#include <QObject>
|
|
#include <map>
|
|
#include <memory>
|
|
#include <mutex>
|
|
#include <nlohmann/json.hpp>
|
|
|
|
#define INSERT_SIMULATOR(type) \
|
|
m_simulators.insert(std::make_pair(type(&m_com).name(), std::make_unique<type>(&m_com, this)));
|
|
|
|
Q_FORWARD_DECLARE_OBJC_CLASS(QThread);
|
|
Q_FORWARD_DECLARE_OBJC_CLASS(Websocket);
|
|
Q_FORWARD_DECLARE_OBJC_CLASS(CAN_Wrapper);
|
|
Q_FORWARD_DECLARE_OBJC_CLASS(QSerialPort);
|
|
Q_FORWARD_DECLARE_OBJC_CLASS(Simulator_base);
|
|
Q_FORWARD_DECLARE_OBJC_CLASS(Communication);
|
|
|
|
using json = nlohmann::json;
|
|
|
|
class Simulators : public QObject
|
|
{
|
|
Q_OBJECT
|
|
public:
|
|
enum class Command
|
|
{
|
|
get_UI_element,
|
|
get_UI_elements,
|
|
switch_simulator,
|
|
get_active_simulator_name,
|
|
get_simulators,
|
|
end,
|
|
begin = 0
|
|
};
|
|
|
|
enum class Event
|
|
{
|
|
clicked,
|
|
value_changed,
|
|
text_changed,
|
|
selected,
|
|
can_send,
|
|
can_clear,
|
|
ui_changed,
|
|
end,
|
|
begin = 0
|
|
};
|
|
|
|
Simulators(uint16_t port, QString can_dev, QString uart_dev, QObject *parent = nullptr);
|
|
~Simulators();
|
|
std::string active_simulator_name() const;
|
|
void run();
|
|
void stop();
|
|
void switch_simulator(std::string name);
|
|
std::vector<std::string> list_simulators() const;
|
|
bool is_not_active() const;
|
|
Simulator_base *invoke_active_simulator();
|
|
json changed_UI_items();
|
|
|
|
// parsing of websocket messages
|
|
QString message_parser(QString message);
|
|
json command_parser(json command);
|
|
void event_handler(json event);
|
|
|
|
private:
|
|
QThread *m_server_thread;
|
|
Websocket *m_server;
|
|
CAN_Wrapper *m_can_wrapper;
|
|
QSerialPort *m_serial;
|
|
Communication *m_com;
|
|
std::map<std::string, std::unique_ptr<Simulator_base>> m_simulators;
|
|
std::string m_current_simulator = "";
|
|
std::mutex m_mutex;
|
|
json m_before;
|
|
};
|