mirror of
https://github.com/Sani7/remote-ui.git
synced 2026-10-26 21:51:13 +01:00
server websocket
Removes unnecessary debug and trace logging statements from the websocket server implementation to reduce verbosity. Also removes unused binary message processing.
This commit is contained in:
@@ -12,7 +12,6 @@ Websocket::Websocket(uint16_t port, QObject *parent)
|
|||||||
{
|
{
|
||||||
if (m_pWebSocketServer->listen(QHostAddress::Any, port))
|
if (m_pWebSocketServer->listen(QHostAddress::Any, port))
|
||||||
{
|
{
|
||||||
SPDLOG_DEBUG("Server listening on port {}", port);
|
|
||||||
connect(m_pWebSocketServer, &QWebSocketServer::newConnection, this, &Websocket::onNewConnection);
|
connect(m_pWebSocketServer, &QWebSocketServer::newConnection, this, &Websocket::onNewConnection);
|
||||||
connect(m_pWebSocketServer, &QWebSocketServer::closed, this, &Websocket::closed);
|
connect(m_pWebSocketServer, &QWebSocketServer::closed, this, &Websocket::closed);
|
||||||
}
|
}
|
||||||
@@ -37,7 +36,6 @@ Websocket::Websocket(uint16_t port, QString key_file, QString cert_file, QObject
|
|||||||
m_pWebSocketServer->setSslConfiguration(sslConfiguration);
|
m_pWebSocketServer->setSslConfiguration(sslConfiguration);
|
||||||
if (m_pWebSocketServer->listen(QHostAddress::Any, port))
|
if (m_pWebSocketServer->listen(QHostAddress::Any, port))
|
||||||
{
|
{
|
||||||
SPDLOG_DEBUG("Server listening on port {}", port);
|
|
||||||
connect(m_pWebSocketServer, &QWebSocketServer::newConnection, this, &Websocket::onNewConnection);
|
connect(m_pWebSocketServer, &QWebSocketServer::newConnection, this, &Websocket::onNewConnection);
|
||||||
connect(m_pWebSocketServer, &QWebSocketServer::closed, this, &Websocket::closed);
|
connect(m_pWebSocketServer, &QWebSocketServer::closed, this, &Websocket::closed);
|
||||||
}
|
}
|
||||||
@@ -60,7 +58,6 @@ void Websocket::broadcast(QString message)
|
|||||||
void Websocket::send(QWebSocket *conn, QString message)
|
void Websocket::send(QWebSocket *conn, QString message)
|
||||||
{
|
{
|
||||||
conn->sendTextMessage(message);
|
conn->sendTextMessage(message);
|
||||||
SPDLOG_TRACE("sending message: {}", message.toStdString());
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void Websocket::onNewConnection()
|
void Websocket::onNewConnection()
|
||||||
@@ -68,32 +65,20 @@ void Websocket::onNewConnection()
|
|||||||
QWebSocket *pSocket = m_pWebSocketServer->nextPendingConnection();
|
QWebSocket *pSocket = m_pWebSocketServer->nextPendingConnection();
|
||||||
|
|
||||||
connect(pSocket, &QWebSocket::textMessageReceived, this, &Websocket::processTextMessage);
|
connect(pSocket, &QWebSocket::textMessageReceived, this, &Websocket::processTextMessage);
|
||||||
connect(pSocket, &QWebSocket::binaryMessageReceived, this, &Websocket::processBinaryMessage);
|
|
||||||
connect(pSocket, &QWebSocket::disconnected, this, &Websocket::socketDisconnected);
|
connect(pSocket, &QWebSocket::disconnected, this, &Websocket::socketDisconnected);
|
||||||
|
|
||||||
m_clients << pSocket;
|
m_clients << pSocket;
|
||||||
SPDLOG_DEBUG("socket connected");
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void Websocket::processTextMessage(QString message)
|
void Websocket::processTextMessage(QString message)
|
||||||
{
|
{
|
||||||
QWebSocket *pClient = qobject_cast<QWebSocket *>(sender());
|
QWebSocket *pClient = qobject_cast<QWebSocket *>(sender());
|
||||||
SPDLOG_TRACE("Message received: {}", message.toStdString());
|
|
||||||
emit on_message(pClient, message);
|
emit on_message(pClient, message);
|
||||||
}
|
}
|
||||||
|
|
||||||
void Websocket::processBinaryMessage(QByteArray message)
|
|
||||||
{
|
|
||||||
QWebSocket *pClient = qobject_cast<QWebSocket *>(sender());
|
|
||||||
SPDLOG_TRACE("Binary Message received: {}", message.data());
|
|
||||||
Q_UNUSED(message);
|
|
||||||
Q_UNUSED(pClient);
|
|
||||||
}
|
|
||||||
|
|
||||||
void Websocket::socketDisconnected()
|
void Websocket::socketDisconnected()
|
||||||
{
|
{
|
||||||
QWebSocket *pClient = qobject_cast<QWebSocket *>(sender());
|
QWebSocket *pClient = qobject_cast<QWebSocket *>(sender());
|
||||||
SPDLOG_DEBUG("socket Disconnected");
|
|
||||||
if (pClient)
|
if (pClient)
|
||||||
{
|
{
|
||||||
m_clients.removeAll(pClient);
|
m_clients.removeAll(pClient);
|
||||||
|
|||||||
@@ -24,7 +24,6 @@ class Websocket : public QObject
|
|||||||
private slots:
|
private slots:
|
||||||
void onNewConnection();
|
void onNewConnection();
|
||||||
void processTextMessage(QString message);
|
void processTextMessage(QString message);
|
||||||
void processBinaryMessage(QByteArray message);
|
|
||||||
void socketDisconnected();
|
void socketDisconnected();
|
||||||
|
|
||||||
private:
|
private:
|
||||||
|
|||||||
Reference in New Issue
Block a user