aboutsummaryrefslogtreecommitdiff
path: root/src/server
diff options
context:
space:
mode:
authorJBB <jbb.prv@gmx.de>2020-01-20 00:19:38 +0100
committerLNJ <lnj@kaidan.im>2020-01-20 00:19:38 +0100
commit8557bc3a605e5d2b1a7dae5999501b19c1c99b58 (patch)
treef17fefa61a26e01c99884c7d3e458b8ea70b181b /src/server
parentcccb7675e0eb9d411c736d1ff3f189fb75ef33dd (diff)
Port majority of old-style connects (#237)
This provides more type safety and is future-proof.
Diffstat (limited to 'src/server')
-rw-r--r--src/server/QXmppIncomingClient.cpp22
-rw-r--r--src/server/QXmppIncomingServer.cpp13
-rw-r--r--src/server/QXmppOutgoingServer.cpp26
-rw-r--r--src/server/QXmppPasswordChecker.cpp2
-rw-r--r--src/server/QXmppServer.cpp69
5 files changed, 49 insertions, 83 deletions
diff --git a/src/server/QXmppIncomingClient.cpp b/src/server/QXmppIncomingClient.cpp
index d3cd5cd9..c7da7bfd 100644
--- a/src/server/QXmppIncomingClient.cpp
+++ b/src/server/QXmppIncomingClient.cpp
@@ -77,14 +77,14 @@ void QXmppIncomingClientPrivate::checkCredentials(const QByteArray &response)
QXmppPasswordReply *reply = passwordChecker->checkPassword(request);
reply->setParent(q);
reply->setProperty("__sasl_raw", response);
- QObject::connect(reply, SIGNAL(finished()),
- q, SLOT(onPasswordReply()));
+ QObject::connect(reply, &QXmppPasswordReply::finished,
+ q, &QXmppIncomingClient::onPasswordReply);
} else if (saslServer->mechanism() == "DIGEST-MD5") {
QXmppPasswordReply *reply = passwordChecker->getDigest(request);
reply->setParent(q);
reply->setProperty("__sasl_raw", response);
- QObject::connect(reply, SIGNAL(finished()),
- q, SLOT(onDigestReply()));
+ QObject::connect(reply, &QXmppPasswordReply::finished,
+ q, &QXmppIncomingClient::onDigestReply);
}
}
@@ -107,16 +107,13 @@ QString QXmppIncomingClientPrivate::origin() const
QXmppIncomingClient::QXmppIncomingClient(QSslSocket *socket, const QString &domain, QObject *parent)
: QXmppStream(parent)
{
- bool check;
- Q_UNUSED(check);
d = new QXmppIncomingClientPrivate(this);
d->domain = domain;
if (socket) {
- check = connect(socket, SIGNAL(disconnected()),
- this, SLOT(onSocketDisconnected()));
- Q_ASSERT(check);
+ connect(socket, &QAbstractSocket::disconnected,
+ this, &QXmppIncomingClient::onSocketDisconnected);
setSocket(socket);
}
@@ -126,9 +123,8 @@ QXmppIncomingClient::QXmppIncomingClient(QSslSocket *socket, const QString &doma
// create inactivity timer
d->idleTimer = new QTimer(this);
d->idleTimer->setSingleShot(true);
- check = connect(d->idleTimer, SIGNAL(timeout()),
- this, SLOT(onTimeout()));
- Q_ASSERT(check);
+ connect(d->idleTimer, &QTimer::timeout,
+ this, &QXmppIncomingClient::onTimeout);
}
/// Destroys the current stream.
@@ -465,7 +461,7 @@ void QXmppIncomingClient::onTimeout()
disconnectFromHost();
// make sure disconnected() gets emitted no matter what
- QTimer::singleShot(30, this, SIGNAL(disconnected()));
+ QTimer::singleShot(30, this, &QXmppStream::disconnected);
}
diff --git a/src/server/QXmppIncomingServer.cpp b/src/server/QXmppIncomingServer.cpp
index 1963221b..f121e479 100644
--- a/src/server/QXmppIncomingServer.cpp
+++ b/src/server/QXmppIncomingServer.cpp
@@ -71,16 +71,13 @@ QString QXmppIncomingServerPrivate::origin() const
QXmppIncomingServer::QXmppIncomingServer(QSslSocket *socket, const QString &domain, QObject *parent)
: QXmppStream(parent)
{
- bool check;
- Q_UNUSED(check);
d = new QXmppIncomingServerPrivate(this);
d->domain = domain;
if (socket) {
- check = connect(socket, SIGNAL(disconnected()),
- this, SLOT(slotSocketDisconnected()));
- Q_ASSERT(check);
+ connect(socket, &QAbstractSocket::disconnected,
+ this, &QXmppIncomingServer::slotSocketDisconnected);
setSocket(socket);
}
@@ -160,10 +157,8 @@ void QXmppIncomingServer::handleStanza(const QDomElement &stanza)
// establish dialback connection
auto *stream = new QXmppOutgoingServer(d->domain, this);
- bool check = connect(stream, SIGNAL(dialbackResponseReceived(QXmppDialback)),
- this, SLOT(slotDialbackResponseReceived(QXmppDialback)));
- Q_ASSERT(check);
- Q_UNUSED(check);
+ connect(stream, &QXmppOutgoingServer::dialbackResponseReceived,
+ this, &QXmppIncomingServer::slotDialbackResponseReceived);
stream->setVerify(d->localStreamId, request.key());
stream->connectToHost(domain);
}
diff --git a/src/server/QXmppOutgoingServer.cpp b/src/server/QXmppOutgoingServer.cpp
index 4e2e274c..aec5018a 100644
--- a/src/server/QXmppOutgoingServer.cpp
+++ b/src/server/QXmppOutgoingServer.cpp
@@ -22,8 +22,10 @@
*/
#include <QDomElement>
+#include <QSslError>
#include <QSslKey>
#include <QSslSocket>
+#include <QList>
#include <QTimer>
#include <QDnsLookup>
@@ -57,39 +59,25 @@ QXmppOutgoingServer::QXmppOutgoingServer(const QString &domain, QObject *parent)
: QXmppStream(parent),
d(new QXmppOutgoingServerPrivate)
{
- bool check;
- Q_UNUSED(check);
-
// socket initialisation
auto *socket = new QSslSocket(this);
setSocket(socket);
- check = connect(socket, SIGNAL(disconnected()),
- this, SLOT(_q_socketDisconnected()));
- Q_ASSERT(check);
-
- check = connect(socket, SIGNAL(error(QAbstractSocket::SocketError)),
- this, SLOT(socketError(QAbstractSocket::SocketError)));
- Q_ASSERT(check);
+ connect(socket, &QAbstractSocket::disconnected, this, &QXmppOutgoingServer::_q_socketDisconnected);
+ connect(socket, QOverload<QAbstractSocket::SocketError>::of(&QSslSocket::error), this, &QXmppOutgoingServer::socketError);
// DNS lookups
- check = connect(&d->dns, SIGNAL(finished()),
- this, SLOT(_q_dnsLookupFinished()));
- Q_ASSERT(check);
+ connect(&d->dns, &QDnsLookup::finished, this, &QXmppOutgoingServer::_q_dnsLookupFinished);
d->dialbackTimer = new QTimer(this);
d->dialbackTimer->setInterval(5000);
d->dialbackTimer->setSingleShot(true);
- check = connect(d->dialbackTimer, SIGNAL(timeout()),
- this, SLOT(sendDialback()));
- Q_ASSERT(check);
+ connect(d->dialbackTimer, &QTimer::timeout, this, &QXmppOutgoingServer::sendDialback);
d->localDomain = domain;
d->ready = false;
- check = connect(socket, SIGNAL(sslErrors(QList<QSslError>)),
- this, SLOT(slotSslErrors(QList<QSslError>)));
- Q_ASSERT(check);
+ connect(socket, QOverload<const QList<QSslError> &>::of(&QSslSocket::sslErrors), this, &QXmppOutgoingServer::slotSslErrors);
}
/// Destroys the stream.
diff --git a/src/server/QXmppPasswordChecker.cpp b/src/server/QXmppPasswordChecker.cpp
index 45ce4604..70bfad83 100644
--- a/src/server/QXmppPasswordChecker.cpp
+++ b/src/server/QXmppPasswordChecker.cpp
@@ -128,7 +128,7 @@ void QXmppPasswordReply::finish()
void QXmppPasswordReply::finishLater()
{
- QTimer::singleShot(0, this, SLOT(finish()));
+ QTimer::singleShot(0, this, &QXmppPasswordReply::finish);
}
/// Returns true when the reply has finished.
diff --git a/src/server/QXmppServer.cpp b/src/server/QXmppServer.cpp
index 71a55181..2cf25362 100644
--- a/src/server/QXmppServer.cpp
+++ b/src/server/QXmppServer.cpp
@@ -152,8 +152,6 @@ bool QXmppServerPrivate::routeData(const QString &to, const QByteArray &data)
} else if (!serversForServers.isEmpty()) {
- bool check;
- Q_UNUSED(check);
// look for an outgoing S2S connection
for (auto *conn : qAsConst(outgoingServers)) {
@@ -171,9 +169,8 @@ bool QXmppServerPrivate::routeData(const QString &to, const QByteArray &data)
conn->moveToThread(q->thread());
conn->setParent(q);
- check = QObject::connect(conn, SIGNAL(disconnected()),
- q, SLOT(_q_outgoingServerDisconnected()));
- Q_UNUSED(check);
+ QObject::connect(conn, &QXmppStream::disconnected,
+ q, &QXmppServer::_q_outgoingServerDisconnected);
// add stream
outgoingServers.insert(conn);
@@ -387,22 +384,22 @@ void QXmppServer::setLogger(QXmppLogger *logger)
{
if (logger != d->logger) {
if (d->logger) {
- disconnect(this, SIGNAL(logMessage(QXmppLogger::MessageType,QString)),
- d->logger, SLOT(log(QXmppLogger::MessageType,QString)));
- disconnect(this, SIGNAL(setGauge(QString,double)),
- d->logger, SLOT(setGauge(QString,double)));
- disconnect(this, SIGNAL(updateCounter(QString,qint64)),
- d->logger, SLOT(updateCounter(QString,qint64)));
+ disconnect(this, &QXmppLoggable::logMessage,
+ d->logger, &QXmppLogger::log);
+ disconnect(this, &QXmppLoggable::setGauge,
+ d->logger, &QXmppLogger::setGauge);
+ disconnect(this, &QXmppLoggable::updateCounter,
+ d->logger, &QXmppLogger::updateCounter);
}
d->logger = logger;
if (d->logger) {
- connect(this, SIGNAL(logMessage(QXmppLogger::MessageType,QString)),
- d->logger, SLOT(log(QXmppLogger::MessageType,QString)));
- connect(this, SIGNAL(setGauge(QString,double)),
- d->logger, SLOT(setGauge(QString,double)));
- connect(this, SIGNAL(updateCounter(QString,qint64)),
- d->logger, SLOT(updateCounter(QString,qint64)));
+ connect(this, &QXmppLoggable::logMessage,
+ d->logger, &QXmppLogger::log);
+ connect(this, &QXmppLoggable::setGauge,
+ d->logger, &QXmppLogger::setGauge);
+ connect(this, &QXmppLoggable::updateCounter,
+ d->logger, &QXmppLogger::updateCounter);
}
emit loggerChanged(d->logger);
@@ -540,7 +537,7 @@ void QXmppServer::setPrivateKey(const QSslKey &key)
bool QXmppServer::listenForClients(const QHostAddress &address, quint16 port)
{
bool check;
- Q_UNUSED(check);
+ Q_UNUSED(check)
if (d->domain.isEmpty()) {
d->warning("No domain was specified!");
@@ -604,7 +601,7 @@ void QXmppServer::close()
bool QXmppServer::listenForServers(const QHostAddress &address, quint16 port)
{
bool check;
- Q_UNUSED(check);
+ Q_UNUSED(check)
if (d->domain.isEmpty()) {
d->warning("No domain was specified!");
@@ -672,22 +669,17 @@ bool QXmppServer::sendPacket(const QXmppStanza &packet)
void QXmppServer::addIncomingClient(QXmppIncomingClient *stream)
{
- bool check;
- Q_UNUSED(check);
stream->setPasswordChecker(d->passwordChecker);
- check = connect(stream, SIGNAL(connected()),
- this, SLOT(_q_clientConnected()));
- Q_ASSERT(check);
+ connect(stream, &QXmppStream::connected,
+ this, &QXmppServer::_q_clientConnected);
- check = connect(stream, SIGNAL(disconnected()),
- this, SLOT(_q_clientDisconnected()));
- Q_ASSERT(check);
+ connect(stream, &QXmppStream::disconnected,
+ this, &QXmppServer::_q_clientDisconnected);
- check = connect(stream, SIGNAL(elementReceived(QDomElement)),
- this, SLOT(handleElement(QDomElement)));
- Q_ASSERT(check);
+ connect(stream, &QXmppIncomingClient::elementReceived,
+ this, &QXmppServer::handleElement);
// add stream
d->incomingClients.insert(stream);
@@ -824,8 +816,6 @@ void QXmppServer::_q_outgoingServerDisconnected()
void QXmppServer::_q_serverConnection(QSslSocket *socket)
{
- bool check;
- Q_UNUSED(check);
// check the socket didn't die since the signal was emitted
if (socket->state() != QAbstractSocket::ConnectedState) {
@@ -836,17 +826,14 @@ void QXmppServer::_q_serverConnection(QSslSocket *socket)
auto *stream = new QXmppIncomingServer(socket, d->domain, this);
socket->setParent(stream);
- check = connect(stream, SIGNAL(disconnected()),
- this, SLOT(_q_serverDisconnected()));
- Q_ASSERT(check);
+ connect(stream, &QXmppStream::disconnected,
+ this, &QXmppServer::_q_serverDisconnected);
- check = connect(stream, SIGNAL(dialbackRequestReceived(QXmppDialback)),
- this, SLOT(_q_dialbackRequestReceived(QXmppDialback)));
- Q_ASSERT(check);
+ connect(stream, &QXmppIncomingServer::dialbackRequestReceived,
+ this, &QXmppServer::_q_dialbackRequestReceived);
- check = connect(stream, SIGNAL(elementReceived(QDomElement)),
- this, SLOT(handleElement(QDomElement)));
- Q_ASSERT(check);
+ connect(stream, &QXmppIncomingServer::elementReceived,
+ this, &QXmppServer::handleElement);
// add stream
d->incomingServers.insert(stream);