mirror of
https://github.com/WarmUpTill/SceneSwitcher.git
synced 2026-04-18 16:17:23 -05:00
82 lines
2.1 KiB
C++
82 lines
2.1 KiB
C++
#pragma once
|
|
|
|
#include <set>
|
|
#include <QtCore/QObject>
|
|
#include <QtCore/QMutex>
|
|
#include <QtCore/QSharedPointer>
|
|
#include <QtCore/QVariantHash>
|
|
#include <QtCore/QThreadPool>
|
|
#include <mutex>
|
|
#include <condition_variable>
|
|
#include <functional>
|
|
#include <QRunnable>
|
|
|
|
#include <websocketpp/config/asio_no_tls_client.hpp>
|
|
#include <websocketpp/config/asio_no_tls.hpp>
|
|
#include <websocketpp/server.hpp>
|
|
#include <websocketpp/client.hpp>
|
|
|
|
#include <obs.hpp>
|
|
|
|
namespace advss {
|
|
|
|
using websocketpp::connection_hdl;
|
|
typedef websocketpp::server<websocketpp::config::asio> server;
|
|
typedef websocketpp::client<websocketpp::config::asio_client> client;
|
|
|
|
constexpr char VendorName[] = "AdvancedSceneSwitcher";
|
|
constexpr char VendorRequest[] = "AdvancedSceneSwitcherMessage";
|
|
constexpr char VendorEvent[] = "AdvancedSceneSwitcherEvent";
|
|
|
|
void ClearWebsocketMessages();
|
|
void SendWebsocketEvent(const std::string &);
|
|
|
|
class WSConnection : public QObject {
|
|
public:
|
|
explicit WSConnection();
|
|
virtual ~WSConnection();
|
|
|
|
void Connect(const std::string &uri, const std::string &pass,
|
|
bool _reconnect, int reconnectDelay = 10);
|
|
void Disconnect();
|
|
void SendRequest(const std::string &msg);
|
|
std::vector<std::string> &Events() { return _messages; }
|
|
std::string GetFail() { return _failMsg; }
|
|
|
|
enum class Status {
|
|
DISCONNECTED,
|
|
CONNECTING,
|
|
CONNECTED,
|
|
AUTHENTICATED,
|
|
};
|
|
Status GetStatus() const;
|
|
|
|
private:
|
|
void OnOpen(connection_hdl hdl);
|
|
void OnMessage(connection_hdl hdl, client::message_ptr message);
|
|
void OnClose(connection_hdl hdl);
|
|
void Send(const std::string &);
|
|
void ConnectThread();
|
|
void HandleHello(obs_data_t *helloMsg);
|
|
void HandleEvent(obs_data_t *event);
|
|
void HandleResponse(obs_data_t *response);
|
|
|
|
client _client;
|
|
std::string _uri = "";
|
|
std::string _password = "";
|
|
connection_hdl _connection;
|
|
std::thread _thread;
|
|
bool _reconnect = false;
|
|
int _reconnectDelay = 10;
|
|
std::mutex _waitMtx;
|
|
std::mutex _connectMtx;
|
|
std::condition_variable _cv;
|
|
std::string _failMsg = "";
|
|
std::atomic<Status> _status = {Status::DISCONNECTED};
|
|
std::atomic_bool _disconnect{false};
|
|
|
|
std::vector<std::string> _messages;
|
|
};
|
|
|
|
} // namespace advss
|