X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcore%2Fsqlitestorage.h;h=7ac1cb473817d91bad1b700848ed5e556405fc34;hp=9968ec7123a0194fd014b7843b39c1f5f79272e2;hb=b55d0de3c731948432ddb2851fe728c4edff374c;hpb=9f9d207ecf28dd5470ecef9d4076a3f447662a20 diff --git a/src/core/sqlitestorage.h b/src/core/sqlitestorage.h index 9968ec71..7ac1cb47 100644 --- a/src/core/sqlitestorage.h +++ b/src/core/sqlitestorage.h @@ -49,7 +49,11 @@ public slots: virtual void 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 internalUser(); virtual void delUser(UserId user); + virtual void setUserSetting(UserId userId, const QString &settingName, const QVariant &data); + virtual QVariant getUserSetting(UserId userId, const QString &settingName, const QVariant &defaultData = QVariant()); + /* Network handling */ virtual NetworkId createNetwork(UserId user, const NetworkInfo &info); @@ -67,7 +71,8 @@ public slots: /* Buffer handling */ virtual BufferInfo getBufferInfo(UserId user, const NetworkId &networkId, BufferInfo::Type type, const QString &buffer = ""); virtual BufferInfo getBufferInfo(UserId user, const BufferId &bufferId); - virtual QList requestBuffers(UserId user, QDateTime since = QDateTime()); + virtual QList requestBuffers(UserId user); + virtual QList requestBufferIdsForNetwork(UserId user, NetworkId networkId); virtual bool removeBuffer(const UserId &user, const BufferId &bufferId); virtual BufferId renameBuffer(const UserId &user, const NetworkId &networkId, const QString &newName, const QString &oldName); virtual void setBufferLastSeenMsg(UserId user, const BufferId &bufferId, const MsgId &msgId); @@ -76,16 +81,15 @@ public slots: /* Message handling */ virtual MsgId logMessage(Message msg); - virtual QList requestMsgs(BufferInfo buffer, int lastmsgs = -1, int offset = -1); - virtual QList requestMsgs(BufferInfo buffer, QDateTime since, int offset = -1); - virtual QList requestMsgRange(BufferInfo buffer, int first, int last); + virtual QList requestMsgs(UserId user, BufferId bufferId, int lastmsgs = -1, int offset = -1); + virtual QList requestMsgs(UserId user, BufferId bufferId, QDateTime since, int offset = -1); + virtual QList requestMsgRange(UserId user, BufferId bufferId, int first, int last); protected: inline virtual QString driverName() { return "QSQLITE"; } inline virtual QString databaseName() { return backlogFile(); } virtual int installedSchemaVersion(); - - virtual bool init(const QVariantMap &settings = QVariantMap()); // only needed for migration + bool safeExec(QSqlQuery &query, int retryCount = 0); private: static QString backlogFile(); @@ -93,6 +97,8 @@ private: 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); + + static int _maxRetryCount; }; #endif