X-Git-Url: https://git.quassel-irc.org/?a=blobdiff_plain;f=src%2Fcore%2Fcore.h;h=a2a15ae4e61c23d3f2cccddf8d1bd6c86b237c07;hb=eab5c456972d723fb3c67fe366548608f3bbeadc;hp=f32502e739fc5bb83275a65e7c797f88937a0ace;hpb=9a36f8e55bfa485467e093fba669841fdfacda2f;p=quassel.git diff --git a/src/core/core.h b/src/core/core.h index f32502e7..a2a15ae4 100644 --- a/src/core/core.h +++ b/src/core/core.h @@ -27,22 +27,22 @@ #include #include -#ifndef QT_NO_OPENSSL -#include -#include "sslserver.h" +#ifdef HAVE_SSL +# include +# include "sslserver.h" #else -#include -#include +# include +# include #endif #include "bufferinfo.h" #include "message.h" -#include "global.h" #include "sessionthread.h" #include "types.h" class CoreSession; class SessionThread; +class SignalProxy; class Storage; struct NetworkInfo; @@ -59,6 +59,24 @@ class Core : public QObject { /*** Storage access ***/ // These methods are threadsafe. + //! Store a user setting persistently + /** + * \param userId The users Id + * \param settingName The Name of the Setting + * \param data The Value + */ + static void setUserSetting(UserId userId, const QString &settingName, const QVariant &data); + + //! Retrieve a persistent user setting + /** + * \param userId The users Id + * \param settingName The Name of the Setting + * \param default Value to return in case it's unset. + * \return the Value of the Setting or the default value if it is unset. + */ + static QVariant getUserSetting(UserId userId, const QString &settingName, const QVariant &data = QVariant()); + + //! Create a Network in the Storage and store it's Id in the given NetworkInfo /** \note This method is thredsafe. * @@ -67,7 +85,7 @@ class Core : public QObject { * \return true if successfull. */ static bool createNetwork(UserId user, NetworkInfo &info); - + //! Apply the changes to NetworkInfo info to the storage engine /** \note This method is thredsafe. * @@ -85,7 +103,7 @@ class Core : public QObject { * \return true if successfull. */ static bool removeNetwork(UserId user, const NetworkId &networkId); - + //! Returns a list of all NetworkInfos for the given UserId user /** \note This method is thredsafe. * @@ -168,7 +186,7 @@ class Core : public QObject { */ static BufferInfo getBufferInfo(UserId user, const BufferId &bufferId); - + //! Store a Message in the backlog. /** \note This method is threadsafe. * @@ -207,17 +225,24 @@ class Core : public QObject { */ static QList requestMsgRange(UserId user, BufferId buffer, int first, int last); - //! Request a list of all buffers known to a user since a certain point in time. + //! Request a list of all buffers known to a user. /** This method is used to get a list of all buffers we have stored a backlog from. - * Optionally, a QDateTime can be given, so that only buffers are listed that were active - * since that point in time. * \note This method is threadsafe. * * \param user The user whose buffers we request - * \param since If this is defined, older buffers will be ignored * \return A list of the BufferInfos for all buffers as requested */ - static QList requestBuffers(UserId user, QDateTime since = QDateTime()); + static QList requestBuffers(UserId user); + + + //! Request a list of BufferIds for a given NetworkId + /** \note This method is threadsafe. + * + * \param user The user whose buffers we request + * \param networkId The NetworkId of the network in question + * \return List of BufferIds belonging to the Network + */ + static QList requestBufferIdsForNetwork(UserId user, NetworkId networkId); //! Remove permanently a buffer and it's content from the storage backend /** This call cannot be reverted! @@ -257,26 +282,31 @@ class Core : public QObject { */ static QHash bufferLastSeenMsgIds(UserId user); + const QDateTime &startTime() const { return _startTime; } + public slots: //! Make storage data persistent /** \note This method is threadsafe. */ void syncStorage(); - + void setupInternalClientSession(SignalProxy *proxy); signals: //! Sent when a BufferInfo is updated in storage. void bufferInfoUpdated(UserId user, const BufferInfo &info); + //! Relay From CoreSession::sessionState(const QVariant &). Used for internal connection only + void sessionState(const QVariant &); + private slots: - bool startListening(uint port = Global::defaultPort); - void stopListening(); + bool startListening(); + void stopListening(const QString &msg = QString()); void incomingConnection(); void clientHasData(); void clientDisconnected(); bool initStorage(QVariantMap dbSettings, bool setup = false); -#ifndef QT_NO_OPENSSL +#ifdef HAVE_SSL void sslErrors(const QList &errors); #endif void socketError(QAbstractSocket::SocketError); @@ -291,7 +321,8 @@ class Core : public QObject { void setupClientSession(QTcpSocket *socket, UserId uid); void processClientMessage(QTcpSocket *socket, const QVariantMap &msg); //void processCoreSetup(QTcpSocket *socket, QVariantMap &msg); - QString setupCore(const QVariant &setupData); + QString setupCoreForInternalUsage(); + QString setupCore(QVariantMap setupData); bool registerStorageBackend(Storage *); void unregisterStorageBackend(Storage *); @@ -300,18 +331,18 @@ class Core : public QObject { Storage *storage; QTimer _storageSyncTimer; -#ifndef QT_NO_OPENSSL - SslServer server; +#ifdef HAVE_SSL + SslServer _server, _v6server; #else - QTcpServer server; -#endif + QTcpServer _server, _v6server; +#endif QHash blocksizes; QHash clientInfo; QHash _storageBackends; - QDateTime startTime; + QDateTime _startTime; bool configured;