+
+ db.commit();
+ unlock();
+ return connectedNets;
+}
+
+void SqliteStorage::setNetworkConnected(UserId user, const NetworkId &networkId, bool isConnected) {
+ QSqlDatabase db = logDb();
+ db.transaction();
+
+ QSqlQuery query(db);
+ query.prepare(queryString("update_network_connected"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":networkid", networkId.toInt());
+ query.bindValue(":connected", isConnected ? 1 : 0);
+
+ lockForWrite();
+ safeExec(query);
+ watchQuery(query);
+ db.commit();
+ unlock();
+}
+
+QHash<QString, QString> SqliteStorage::persistentChannels(UserId user, const NetworkId &networkId) {
+ QHash<QString, QString> persistentChans;
+
+ QSqlDatabase db = logDb();
+ db.transaction();
+
+ QSqlQuery query(db);
+ query.prepare(queryString("select_persistent_channels"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":networkid", networkId.toInt());
+
+ lockForRead();
+ safeExec(query);
+ watchQuery(query);
+ while(query.next()) {
+ persistentChans[query.value(0).toString()] = query.value(1).toString();
+ }
+ unlock();
+
+ return persistentChans;
+}
+
+void SqliteStorage::setChannelPersistent(UserId user, const NetworkId &networkId, const QString &channel, bool isJoined) {
+ QSqlDatabase db = logDb();
+ db.transaction();
+
+ QSqlQuery query(db);
+ 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);
+
+ lockForWrite();
+ safeExec(query);
+ watchQuery(query);
+ db.commit();
+ unlock();
+}
+
+void SqliteStorage::setPersistentChannelKey(UserId user, const NetworkId &networkId, const QString &channel, const QString &key) {
+ QSqlDatabase db = logDb();
+ db.transaction();
+
+ QSqlQuery query(db);
+ 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);
+
+ lockForWrite();
+ safeExec(query);
+ watchQuery(query);
+ db.commit();
+ unlock();
+}
+
+QString SqliteStorage::awayMessage(UserId user, NetworkId networkId) {
+ QSqlDatabase db = logDb();
+ db.transaction();
+
+ QSqlQuery query(db);
+ query.prepare(queryString("select_network_awaymsg"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":networkid", networkId.toInt());
+
+ lockForRead();
+ safeExec(query);
+ watchQuery(query);
+ QString awayMsg;
+ if(query.first())
+ awayMsg = query.value(0).toString();
+ db.commit();
+ unlock();
+
+ return awayMsg;
+}
+
+void SqliteStorage::setAwayMessage(UserId user, NetworkId networkId, const QString &awayMsg) {
+ QSqlDatabase db = logDb();
+ db.transaction();
+
+ QSqlQuery query(db);
+ query.prepare(queryString("update_network_set_awaymsg"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":networkid", networkId.toInt());
+ query.bindValue(":awaymsg", awayMsg);
+
+ lockForWrite();
+ safeExec(query);
+ watchQuery(query);
+ db.commit();
+ unlock();
+}
+
+QString SqliteStorage::userModes(UserId user, NetworkId networkId) {
+ QSqlDatabase db = logDb();
+ db.transaction();
+
+ QSqlQuery query(db);
+ query.prepare(queryString("select_network_usermode"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":networkid", networkId.toInt());
+
+ lockForRead();
+ safeExec(query);
+ watchQuery(query);
+ QString modes;
+ if(query.first())
+ modes = query.value(0).toString();
+ db.commit();
+ unlock();
+
+ return modes;
+}
+
+void SqliteStorage::setUserModes(UserId user, NetworkId networkId, const QString &userModes) {
+ QSqlDatabase db = logDb();
+ db.transaction();
+
+ QSqlQuery query(db);
+ query.prepare(queryString("update_network_set_usermode"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":networkid", networkId.toInt());
+ query.bindValue(":usermode", userModes);
+
+ lockForWrite();
+ safeExec(query);
+ watchQuery(query);
+ db.commit();
+ unlock();
+}
+
+BufferInfo SqliteStorage::bufferInfo(UserId user, const NetworkId &networkId, BufferInfo::Type type, const QString &buffer, bool create) {
+ QSqlDatabase db = logDb();
+ db.transaction();
+
+ QSqlQuery query(db);
+ query.prepare(queryString("select_bufferByName"));
+ query.bindValue(":networkid", networkId.toInt());
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":buffercname", buffer.toLower());
+
+ lockForRead();
+ safeExec(query);
+
+ if(query.first()) {
+ BufferInfo bufferInfo = BufferInfo(query.value(0).toInt(), networkId, (BufferInfo::Type)query.value(1).toInt(), 0, buffer);
+ if(query.next()) {
+ qCritical() << "SqliteStorage::getBufferInfo(): received more then one Buffer!";
+ qCritical() << " Query:" << query.lastQuery();
+ qCritical() << " bound Values:";
+ QList<QVariant> list = query.boundValues().values();
+ for (int i = 0; i < list.size(); ++i)
+ qCritical() << i << ":" << list.at(i).toString().toAscii().data();
+ Q_ASSERT(false);
+ }
+ db.commit();
+ unlock();
+ return bufferInfo;
+ } else if(create) {
+ // let's create the buffer
+ QSqlQuery createQuery(db);
+ createQuery.prepare(queryString("insert_buffer"));
+ createQuery.bindValue(":userid", user.toInt());
+ createQuery.bindValue(":networkid", networkId.toInt());
+ createQuery.bindValue(":buffertype", (int)type);
+ createQuery.bindValue(":buffername", buffer);
+ createQuery.bindValue(":buffercname", buffer.toLower());
+
+ unlock();
+ lockForWrite();
+ safeExec(createQuery);
+ watchQuery(createQuery);
+ BufferInfo bufferInfo = BufferInfo(createQuery.lastInsertId().toInt(), networkId, type, 0, buffer);
+ db.commit();
+ unlock();
+ return bufferInfo;
+ }
+
+ // neither found the buffer nor is its creation requested
+ db.commit();
+ unlock();
+ return BufferInfo();
+}
+
+BufferInfo SqliteStorage::getBufferInfo(UserId user, const BufferId &bufferId) {
+ QSqlDatabase db = logDb();
+ db.transaction();
+
+ QSqlQuery query(db);
+ query.prepare(queryString("select_buffer_by_id"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":bufferid", bufferId.toInt());
+
+ lockForRead();
+ safeExec(query);
+ if(!watchQuery(query) || !query.first()) {
+ db.commit();
+ unlock();
+ 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());
+ db.commit();
+ unlock();
+ return bufferInfo;
+}
+
+QList<BufferInfo> SqliteStorage::requestBuffers(UserId user) {
+ QList<BufferInfo> bufferlist;
+
+ QSqlDatabase db = logDb();
+ db.transaction();
+
+ QSqlQuery query(db);
+ query.prepare(queryString("select_buffers"));
+ query.bindValue(":userid", user.toInt());
+
+ lockForRead();
+ safeExec(query);
+ 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());
+ }
+ db.commit();
+ unlock();
+