+ persistentChans[query.value(0).toString()] = query.value(1).toString();
+ }
+
+ return persistentChans;
+}
+
+void SqliteStorage::setChannelPersistent(UserId user, const NetworkId &networkId, const QString &channel, bool isJoined) {
+ QSqlQuery query(logDb());
+ query.prepare(queryString("update_buffer_persistent_channel"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":networkId", networkId.toInt());
+ query.bindValue(":buffercname", channel.toLower());
+ query.bindValue(":joined", isJoined ? 1 : 0);
+ query.exec();
+ watchQuery(&query);
+}
+
+void SqliteStorage::setPersistentChannelKey(UserId user, const NetworkId &networkId, const QString &channel, const QString &key) {
+ QSqlQuery query(logDb());
+ query.prepare(queryString("update_buffer_set_channel_key"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":networkId", networkId.toInt());
+ query.bindValue(":buffercname", channel.toLower());
+ query.bindValue(":key", key);
+ query.exec();
+ watchQuery(&query);
+}
+
+
+void SqliteStorage::createBuffer(UserId user, const NetworkId &networkId, BufferInfo::Type type, const QString &buffer) {
+ QSqlQuery *query = cachedQuery("insert_buffer");
+ query->bindValue(":userid", user.toInt());
+ query->bindValue(":networkid", networkId.toInt());
+ query->bindValue(":buffertype", (int)type);
+ query->bindValue(":buffername", buffer);
+ query->bindValue(":buffercname", buffer.toLower());
+ query->exec();
+
+ watchQuery(query);
+}
+
+BufferInfo SqliteStorage::getBufferInfo(UserId user, const NetworkId &networkId, BufferInfo::Type type, const QString &buffer) {
+ QSqlQuery *query = cachedQuery("select_bufferByName");
+ query->bindValue(":networkid", networkId.toInt());
+ query->bindValue(":userid", user.toInt());
+ query->bindValue(":buffercname", buffer.toLower());
+ query->exec();
+
+ if(!query->first()) {
+ createBuffer(user, networkId, type, buffer);
+ query->exec();
+ if(!query->first()) {
+ watchQuery(query);
+ qWarning() << "unable to create BufferInfo for:" << user << networkId << buffer;
+ return BufferInfo();
+ }
+ }
+
+ BufferInfo bufferInfo = BufferInfo(query->value(0).toInt(), networkId, (BufferInfo::Type)query->value(1).toInt(), 0, buffer);
+ if(query->next()) {
+ qWarning() << "SqliteStorage::getBufferInfo(): received more then one Buffer!";
+ qWarning() << " Query:" << query->lastQuery();
+ qWarning() << " bound Values:" << query->boundValues();
+ Q_ASSERT(false);
+ }
+
+ return bufferInfo;
+}
+
+BufferInfo SqliteStorage::getBufferInfo(UserId user, const BufferId &bufferId) {
+ QSqlQuery query(logDb());
+ query.prepare(queryString("select_buffer_by_id"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":bufferid", bufferId.toInt());
+ query.exec();
+ if(!watchQuery(&query))
+ return BufferInfo();
+
+ if(!query.first())
+ return BufferInfo();
+
+ BufferInfo bufferInfo(query.value(0).toInt(), query.value(1).toInt(), (BufferInfo::Type)query.value(2).toInt(), 0, query.value(4).toString());
+ Q_ASSERT(!query.next());
+
+ return bufferInfo;
+}
+
+QList<BufferInfo> SqliteStorage::requestBuffers(UserId user, QDateTime since) {
+ uint time = 0;
+ if(since.isValid())
+ time = since.toTime_t();
+
+ QList<BufferInfo> bufferlist;
+ QSqlQuery query(logDb());
+ query.prepare(queryString("select_buffers"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":time", time);
+
+ query.exec();
+ watchQuery(&query);
+ while(query.next()) {
+ bufferlist << BufferInfo(query.value(0).toInt(), query.value(1).toInt(), (BufferInfo::Type)query.value(2).toInt(), query.value(3).toInt(), query.value(4).toString());