X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcore%2Fsqlitestorage.h;h=9aa70066d2aa87663f5fd5525a9ffa70cc5ad1a4;hp=1c759ab9a7689458e1c32102280f9a3c81caabcf;hb=d60c5028b49a95d3c27c35b2ea1d74cdd7bb0e46;hpb=7b4bac1b744a407d51f0ece67e0d531206ddad0b diff --git a/src/core/sqlitestorage.h b/src/core/sqlitestorage.h index 1c759ab9..9aa70066 100644 --- a/src/core/sqlitestorage.h +++ b/src/core/sqlitestorage.h @@ -48,11 +48,11 @@ public slots: // TODO: Add functions for configuring the backlog handling, i.e. defining auto-cleanup settings etc /* User handling */ - virtual UserId addUser(const QString &user, const QString &password); - virtual void updateUser(UserId user, const QString &password); + virtual bool updateUser(UserId user, const QString &password); virtual void renameUser(UserId user, const QString &newName); virtual UserId validateUser(const QString &user, const QString &password); + virtual UserId getUserId(const QString &username); virtual UserId internalUser(); virtual void delUser(UserId user); virtual void setUserSetting(UserId userId, const QString &settingName, const QVariant &data); @@ -93,6 +93,8 @@ public slots: virtual bool mergeBuffersPermanently(const UserId &user, const BufferId &bufferId1, const BufferId &bufferId2); virtual void setBufferLastSeenMsg(UserId user, const BufferId &bufferId, const MsgId &msgId); virtual QHash bufferLastSeenMsgIds(UserId user); + virtual void setBufferMarkerLineMsg(UserId user, const BufferId &bufferId, const MsgId &msgId); + virtual QHash bufferMarkerLineMsgIds(UserId user); /* Message handling */ virtual bool logMessage(Message &msg); @@ -111,11 +113,13 @@ protected: private: static QString backlogFile(); - bool isValidNetwork(UserId user, const NetworkId &networkId); - bool isValidBuffer(const UserId &user, const BufferId &bufferId); - NetworkId getNetworkId(UserId user, const QString &network); - void createBuffer(UserId user, const NetworkId &networkId, BufferInfo::Type type, const QString &buffer); + void bindNetworkInfo(QSqlQuery &query, const NetworkInfo &info); + void bindServerInfo(QSqlQuery &query, const Network::Server &server); + inline void lockForRead() { _dbLock.lockForRead(); } + inline void lockForWrite() { _dbLock.lockForWrite(); } + inline void unlock() { _dbLock.unlock(); } + QReadWriteLock _dbLock; static int _maxRetryCount; };