github-wownero/wowlet
1
0
Fork 0
mirror of https://github.com/wownero/wowlet.git synced 2026-10-21 17:18:43 +02:00
Code Issues Packages Projects Releases Wiki Activity

Websocket: add fallback

Browse Source
This commit is contained in:
tobtoht
2022-02-24 00:42:06 +01:00
parent b8018d61a2
commit c10a6a3829
3 changed files with 39 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/utils/WebsocketClient.cpp
+28 -1
View File
@@ -9,6 +9,7 @@
WebsocketClient::WebsocketClient(QObject *parent)
: QObject(parent)
{
connect(&webSocket, &QWebSocket::stateChanged, this, &WebsocketClient::onStateChanged);
connect(&webSocket, &QWebSocket::connected, this, &WebsocketClient::onConnected);
connect(&webSocket, &QWebSocket::disconnected, this, &WebsocketClient::onDisconnected);
connect(&webSocket, QOverload<QAbstractSocket::SocketError>::of(&QWebSocket::error), this, &WebsocketClient::onError);
@@ -23,6 +24,11 @@ WebsocketClient::WebsocketClient(QObject *parent)
});
m_pingTimer.setInterval(30 * 1000);
m_pingTimer.start();
connect(&m_connectionTimeout, &QTimer::timeout, this, &WebsocketClient::onConnectionTimeout);
m_websocketUrlIndex = QRandomGenerator::global()->bounded(constants::websocketUrls.length());
this->nextWebsocketUrl();
}
void WebsocketClient::sendMsg(const QByteArray &data) {
@@ -48,9 +54,19 @@ void WebsocketClient::onConnected() {
void WebsocketClient::onDisconnected() {
qDebug() << "WebSocket disconnected";
this->nextWebsocketUrl();
QTimer::singleShot(1000, [this]{this->start();});
}
void WebsocketClient::onStateChanged(QAbstractSocket::SocketState state) {
if (state == QAbstractSocket::ConnectingState) {
m_connectionTimeout.start(m_timeout*1000);
}
else if (state == QAbstractSocket::ConnectedState) {
m_connectionTimeout.stop();
}
}
void WebsocketClient::onError(QAbstractSocket::SocketError error) {
qCritical() << "WebSocket error: " << error;
auto state = webSocket.state();
@@ -59,8 +75,19 @@ void WebsocketClient::onError(QAbstractSocket::SocketError error) {
}
}
void WebsocketClient::nextWebsocketUrl() {
m_url = constants::websocketUrls[m_websocketUrlIndex];
m_websocketUrlIndex = (m_websocketUrlIndex+1)%constants::websocketUrls.length();
}
void WebsocketClient::onConnectionTimeout() {
qWarning() << "Websocket connection timeout";
m_timeout = std::min(m_timeout + 5, 60);
this->onDisconnected();
}
void WebsocketClient::onbinaryMessageReceived(const QByteArray &message) {
qDebug() << "WebSocket received:" << message;
// qDebug() << "WebSocket received:" << message;
if (!Utils::validateJSON(message)) {
qCritical() << "Could not interpret WebSocket message as JSON";