add websocket wrapper

2026-10-27 06:01:14 +01:00 · 2026-02-01 18:58:57 +01:00
parent b211ebc0c1
commit 36c07e4a6f
3 changed files with 193 additions and 1 deletions
@@ -0,0 +1,130 @@
+#include "web_socket_wrapper.h"
+#include "magic_enum.hpp"
+
+Web_socket_wrapper::Web_socket_wrapper(const QUrl &url, QObject *parent) :
+      QObject(parent),
+      m_web_socket(new QWebSocket("", QWebSocketProtocol::VersionLatest, this))
+{
+    connect(m_web_socket, &QWebSocket::connected, this, &Web_socket_wrapper::m_on_connected);
+    connect(m_web_socket, &QWebSocket::disconnected, this, &Web_socket_wrapper::on_closed);
+    m_web_socket->open(url);
+}
+
+Web_socket_wrapper::~Web_socket_wrapper()
+{
+    close();
+}
+
+void Web_socket_wrapper::send_command(Command command, QString id)
+{
+    json j;
+    switch (command)
+    {
+        case Command::get_UI_element:
+            j["command"]["type"] = magic_enum::enum_name(command).data();
+            j["command"]["id"] = id.toStdString();
+            m_web_socket->sendTextMessage(QString(j.dump().data()));
+            break;
+        case Command::get_UI_elements:
+            j["command"]["type"] = magic_enum::enum_name(command).data();
+            m_web_socket->sendTextMessage(QString(j.dump().data()));
+            break;
+        case Command::get_active_simulator_name:
+            j["command"]["type"] = magic_enum::enum_name(command).data();
+            m_web_socket->sendTextMessage(QString(j.dump().data()));
+            break;
+        case Command::get_simulators:
+            j["command"]["type"] = magic_enum::enum_name(command).data();
+            m_web_socket->sendTextMessage(QString(j.dump().data()));
+            break;
+        case Command::switch_simulator:
+            j["command"]["type"] = magic_enum::enum_name(command).data();
+            j["command"]["name"] = id.toStdString();
+            m_web_socket->sendTextMessage(QString(j.dump().data()));
+            break;
+        default:
+            break;
+    }
+}
+
+void Web_socket_wrapper::send_event(Event event, QString id)
+{
+    json j;
+    switch (event)
+    {
+        case Event::clicked:
+            j["event"]["type"] = magic_enum::enum_name(event).data();
+            j["event"]["id"] = id.toStdString();
+            m_web_socket->sendTextMessage(QString(j.dump().data()));
+            break;
+        default:
+            break;
+    }
+}
+
+void Web_socket_wrapper::send_event(Event event, QString id, double val)
+{
+    json j;
+    switch (event)
+    {
+        case Event::value_changed:
+            j["event"]["type"] = magic_enum::enum_name(event).data();
+            j["event"]["id"] = id.toStdString();
+            j["event"]["value"] = val;
+            m_web_socket->sendTextMessage(QString(j.dump().data()));
+            break;
+        default:
+            break;
+    }
+}
+
+void Web_socket_wrapper::send_event(Event event, QString id, QString val)
+{
+    json j;
+    switch (event)
+    {
+        case Event::text_changed:
+            j["event"]["type"] = magic_enum::enum_name(event).data();
+            j["event"]["id"] = id.toStdString();
+            j["event"]["text"] = val.toStdString();
+            m_web_socket->sendTextMessage(QString(j.dump().data()));
+            break;
+        case Event::selected:
+            j["event"]["type"] = magic_enum::enum_name(event).data();
+            j["event"]["id"] = id.toStdString();
+            j["event"]["selected"] = val.toStdString();
+            m_web_socket->sendTextMessage(QString(j.dump().data()));
+            break;
+        default:
+            break;
+    }
+}
+
+void Web_socket_wrapper::close()
+{
+    if (m_connected)
+        m_web_socket->close();
+}
+
+void Web_socket_wrapper::m_on_connected()
+{
+    m_connected = true;
+    connect(m_web_socket, &QWebSocket::textMessageReceived,
+            this, &Web_socket_wrapper::m_on_received);
+    emit on_connected();
+}
+
+void Web_socket_wrapper::m_on_received(QString message)
+{
+    json j = json::parse(message.toStdString());
+    if (j.contains("response"))
+    {
+        emit on_command_cb(j.at("response"));
+        return;
+    }
+    if (j.contains("event"))
+    {
+        emit on_event_cb(j.at("event"));
+        return;
+    }
+}