X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcore%2Fidentserver.h;h=3723c2528b428c39e6762d084c4ac8672106c06b;hp=cff24b7727151d0093f2decfa719daa275887cf0;hb=c194ed5fb3d15e14b9364f9796d3521910dc72fe;hpb=4e6582c9640179cb195126d7f7ee363faf9fe42e diff --git a/src/core/identserver.h b/src/core/identserver.h index cff24b77..3723c252 100644 --- a/src/core/identserver.h +++ b/src/core/identserver.h @@ -20,45 +20,55 @@ #pragma once +#include + +#include +#include +#include +#include #include #include #include "coreidentity.h" -struct Request { - QTcpSocket *socket; +struct Request +{ + QPointer socket; uint16_t localPort; QString query; qint64 transactionId; qint64 requestId; friend bool operator==(const Request &a, const Request &b); + + void respondSuccess(const QString &user); + void respondError(const QString &error); }; -class IdentServer : public QObject { -Q_OBJECT + +class IdentServer : public QObject +{ + Q_OBJECT + public: - IdentServer(bool strict, QObject *parent); - ~IdentServer() override; + IdentServer(QObject *parent = nullptr); bool startListening(); void stopListening(const QString &msg); qint64 addWaitingSocket(); + public slots: - bool addSocket(const CoreIdentity *identity, const QHostAddress &localAddress, quint16 localPort, const QHostAddress &peerAddress, quint16 peerPort, qint64 socketId); - bool removeSocket(const CoreIdentity *identity, const QHostAddress &localAddress, quint16 localPort, const QHostAddress &peerAddress, quint16 peerPort, qint64 socketId); + void addSocket(const CoreIdentity *identity, const QHostAddress &localAddress, quint16 localPort, const QHostAddress &peerAddress, quint16 peerPort, qint64 socketId); + void removeSocket(const CoreIdentity *identity, const QHostAddress &localAddress, quint16 localPort, const QHostAddress &peerAddress, quint16 peerPort, qint64 socketId); private slots: void incomingConnection(); void respond(); private: - bool responseAvailable(Request request); - void responseUnavailable(Request request); - - QString sysIdentForIdentity(const CoreIdentity *identity) const; + bool responseAvailable(Request request) const; - qint64 lowestSocketId(); + qint64 lowestSocketId() const; void processWaiting(qint64 socketId); @@ -66,11 +76,9 @@ private: QTcpServer _server, _v6server; - bool _strict; - QHash _connections; std::list _requestQueue; std::list _waiting; - qint64 _socketId; - qint64 _requestId; + qint64 _socketId{0}; + qint64 _requestId{0}; };