From 8cf5dc45bedcc2e186839b590f5e915a88c36507 Mon Sep 17 00:00:00 2001
From: Linus Jahn <lnj@kaidan.im>
Date: Sun, 13 Mar 2022 01:23:33 +0100
Subject: server: Add missing emit on signals

---
 src/server/QXmppIncomingClient.cpp | 12 ++++++------
 src/server/QXmppServer.cpp         | 12 ++++++------
 2 files changed, 12 insertions(+), 12 deletions(-)

(limited to 'src/server')

diff --git a/src/server/QXmppIncomingClient.cpp b/src/server/QXmppIncomingClient.cpp
index 227c8ca5..de27d3e2 100644
--- a/src/server/QXmppIncomingClient.cpp
+++ b/src/server/QXmppIncomingClient.cpp
@@ -274,7 +274,7 @@ void QXmppIncomingClient::handleStanza(const QDomElement &nodeRecv)
                 // authentication succeeded
                 d->jid = QString("%1@%2").arg(d->saslServer->username(), d->domain);
                 info(QString("Authentication succeeded for '%1' from %2").arg(d->jid, d->origin()));
-                updateCounter("incoming-client.auth.success");
+                emit updateCounter("incoming-client.auth.success");
                 sendPacket(QXmppSaslSuccess());
                 handleStart();
             } else {
@@ -359,7 +359,7 @@ void QXmppIncomingClient::onDigestReply()
 
     if (reply->error() == QXmppPasswordReply::TemporaryError) {
         warning(QString("Temporary authentication failure for '%1' from %2").arg(d->saslServer->username(), d->origin()));
-        updateCounter("incoming-client.auth.temporary-auth-failure");
+        emit updateCounter("incoming-client.auth.temporary-auth-failure");
         sendPacket(QXmppSaslFailure("temporary-auth-failure"));
         disconnectFromHost();
         return;
@@ -371,7 +371,7 @@ void QXmppIncomingClient::onDigestReply()
     QXmppSaslServer::Response result = d->saslServer->respond(reply->property("__sasl_raw").toByteArray(), challenge);
     if (result != QXmppSaslServer::Challenge) {
         warning(QString("Authentication failed for '%1' from %2").arg(d->saslServer->username(), d->origin()));
-        updateCounter("incoming-client.auth.not-authorized");
+        emit updateCounter("incoming-client.auth.not-authorized");
         sendPacket(QXmppSaslFailure("not-authorized"));
         disconnectFromHost();
         return;
@@ -393,19 +393,19 @@ void QXmppIncomingClient::onPasswordReply()
     case QXmppPasswordReply::NoError:
         d->jid = jid;
         info(QString("Authentication succeeded for '%1' from %2").arg(d->jid, d->origin()));
-        updateCounter("incoming-client.auth.success");
+        emit updateCounter("incoming-client.auth.success");
         sendPacket(QXmppSaslSuccess());
         handleStart();
         break;
     case QXmppPasswordReply::AuthorizationError:
         warning(QString("Authentication failed for '%1' from %2").arg(jid, d->origin()));
-        updateCounter("incoming-client.auth.not-authorized");
+        emit updateCounter("incoming-client.auth.not-authorized");
         sendPacket(QXmppSaslFailure("not-authorized"));
         disconnectFromHost();
         break;
     case QXmppPasswordReply::TemporaryError:
         warning(QString("Temporary authentication failure for '%1' from %2").arg(jid, d->origin()));
-        updateCounter("incoming-client.auth.temporary-auth-failure");
+        emit updateCounter("incoming-client.auth.temporary-auth-failure");
         sendPacket(QXmppSaslFailure("temporary-auth-failure"));
         disconnectFromHost();
         break;
diff --git a/src/server/QXmppServer.cpp b/src/server/QXmppServer.cpp
index 18cbb485..793b9b60 100644
--- a/src/server/QXmppServer.cpp
+++ b/src/server/QXmppServer.cpp
@@ -154,7 +154,7 @@ bool QXmppServerPrivate::routeData(const QString &to, const QByteArray &data)
 
         // add stream
         outgoingServers.insert(conn);
-        q->setGauge("outgoing-server.count", outgoingServers.size());
+        emit q->setGauge("outgoing-server.count", outgoingServers.size());
 
         // queue data and connect to remote server
         QMetaObject::invokeMethod(conn, "queueData", Q_ARG(QByteArray, data));
@@ -669,7 +669,7 @@ void QXmppServer::addIncomingClient(QXmppIncomingClient *stream)
 
     // add stream
     d->incomingClients.insert(stream);
-    setGauge("incoming-client.count", d->incomingClients.size());
+    emit setGauge("incoming-client.count", d->incomingClients.size());
 }
 
 /// Handle a new incoming TCP connection from a client.
@@ -745,7 +745,7 @@ void QXmppServer::_q_clientDisconnected()
             emit clientDisconnected(jid);
 
         // update counter
-        setGauge("incoming-client.count", d->incomingClients.size());
+        emit setGauge("incoming-client.count", d->incomingClients.size());
     }
 }
 
@@ -791,7 +791,7 @@ void QXmppServer::_q_outgoingServerDisconnected()
 
     if (d->outgoingServers.remove(outgoing)) {
         outgoing->deleteLater();
-        setGauge("outgoing-server.count", d->outgoingServers.size());
+        emit setGauge("outgoing-server.count", d->outgoingServers.size());
     }
 }
 
@@ -822,7 +822,7 @@ void QXmppServer::_q_serverConnection(QSslSocket *socket)
 
     // add stream
     d->incomingServers.insert(stream);
-    setGauge("incoming-server.count", d->incomingServers.size());
+    emit setGauge("incoming-server.count", d->incomingServers.size());
 }
 
 /// Handle a stream disconnection for an incoming server.
@@ -835,7 +835,7 @@ void QXmppServer::_q_serverDisconnected()
 
     if (d->incomingServers.remove(incoming)) {
         incoming->deleteLater();
-        setGauge("incoming-server.count", d->incomingServers.size());
+        emit setGauge("incoming-server.count", d->incomingServers.size());
     }
 }
 
-- 
cgit v1.2.3