X-Git-Url: https://git.quassel-irc.org/?a=blobdiff_plain;f=src%2Fcore%2Fcore.h;h=beb7b891675c4c278b0d3c4915b0509ed581ffcb;hb=17fa448705597f9cd7f24a03a630f0cad69d29ee;hp=f32502e739fc5bb83275a65e7c797f88937a0ace;hpb=9a36f8e55bfa485467e093fba669841fdfacda2f;p=quassel.git diff --git a/src/core/core.h b/src/core/core.h index f32502e7..beb7b891 100644 --- a/src/core/core.h +++ b/src/core/core.h @@ -27,17 +27,16 @@ #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" @@ -59,6 +58,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 +84,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 +102,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 +185,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 +224,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,18 +281,20 @@ 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(); - + signals: //! Sent when a BufferInfo is updated in storage. void bufferInfoUpdated(UserId user, const BufferInfo &info); private slots: - bool startListening(uint port = Global::defaultPort); + bool startListening(); void stopListening(); void incomingConnection(); void clientHasData(); @@ -276,7 +302,7 @@ class Core : public QObject { bool initStorage(QVariantMap dbSettings, bool setup = false); -#ifndef QT_NO_OPENSSL +#ifdef HAVE_SSL void sslErrors(const QList &errors); #endif void socketError(QAbstractSocket::SocketError); @@ -300,18 +326,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;