+
+ QSqlQuery deleteBacklogQuery(logDb());
+ deleteBacklogQuery.prepare(queryString("delete_backlog_for_network"));
+ deleteBacklogQuery.bindValue(":networkid", networkId.toInt());
+ safeExec(deleteBacklogQuery);
+ if(!watchQuery(deleteBacklogQuery)) {
+ if(withTransaction)
+ logDb().rollback();
+ return false;
+ }
+
+ QSqlQuery deleteBuffersQuery(logDb());
+ deleteBuffersQuery.prepare(queryString("delete_buffers_for_network"));
+ deleteBuffersQuery.bindValue(":networkid", networkId.toInt());
+ safeExec(deleteBuffersQuery);
+ if(!watchQuery(deleteBuffersQuery)) {
+ if(withTransaction)
+ logDb().rollback();
+ return false;
+ }
+
+ QSqlQuery deleteServersQuery(logDb());
+ deleteServersQuery.prepare(queryString("delete_ircservers_for_network"));
+ deleteServersQuery.bindValue(":networkid", networkId.toInt());
+ safeExec(deleteServersQuery);
+ if(!watchQuery(deleteServersQuery)) {
+ if(withTransaction)
+ logDb().rollback();
+ return false;
+ }
+
+ QSqlQuery deleteNetworkQuery(logDb());
+ deleteNetworkQuery.prepare(queryString("delete_network"));
+ deleteNetworkQuery.bindValue(":networkid", networkId.toInt());
+ safeExec(deleteNetworkQuery);
+ if(!watchQuery(deleteNetworkQuery)) {
+ if(withTransaction)
+ logDb().rollback();
+ return false;
+ }
+
+ logDb().commit();
+ return true;
+}
+
+QList<NetworkInfo> SqliteStorage::networks(UserId user) {
+ QList<NetworkInfo> nets;
+
+ QSqlQuery networksQuery(logDb());
+ networksQuery.prepare(queryString("select_networks_for_user"));
+ networksQuery.bindValue(":userid", user.toInt());
+
+ QSqlQuery serversQuery(logDb());
+ serversQuery.prepare(queryString("select_servers_for_network"));
+
+ safeExec(networksQuery);
+ if(!watchQuery(networksQuery))
+ return nets;
+
+ while(networksQuery.next()) {
+ NetworkInfo net;
+ net.networkId = networksQuery.value(0).toInt();
+ net.networkName = networksQuery.value(1).toString();
+ net.identity = networksQuery.value(2).toInt();
+ net.codecForServer = networksQuery.value(3).toString().toAscii();
+ net.codecForEncoding = networksQuery.value(4).toString().toAscii();
+ net.codecForDecoding = networksQuery.value(5).toString().toAscii();
+ net.useRandomServer = networksQuery.value(6).toInt() == 1 ? true : false;
+ net.perform = networksQuery.value(7).toString().split("\n");
+ net.useAutoIdentify = networksQuery.value(8).toInt() == 1 ? true : false;
+ net.autoIdentifyService = networksQuery.value(9).toString();
+ net.autoIdentifyPassword = networksQuery.value(10).toString();
+ net.useAutoReconnect = networksQuery.value(11).toInt() == 1 ? true : false;
+ net.autoReconnectInterval = networksQuery.value(12).toUInt();
+ net.autoReconnectRetries = networksQuery.value(13).toInt();
+ net.unlimitedReconnectRetries = networksQuery.value(14).toInt() == 1 ? true : false;
+ net.rejoinChannels = networksQuery.value(15).toInt() == 1 ? true : false;
+
+ serversQuery.bindValue(":networkid", net.networkId.toInt());
+ safeExec(serversQuery);
+ if(!watchQuery(serversQuery))
+ return nets;
+
+ Network::ServerList servers;
+ while(serversQuery.next()) {
+ Network::Server server;
+ server.host = serversQuery.value(0).toString();
+ server.port = serversQuery.value(1).toUInt();
+ server.password = serversQuery.value(2).toString();
+ server.useSsl = serversQuery.value(3).toInt() == 1 ? true : false;
+ server.sslVersion = serversQuery.value(4).toInt();
+ server.useProxy = serversQuery.value(5).toInt() == 1 ? true : false;
+ server.proxyType = serversQuery.value(6).toInt();
+ server.proxyHost = serversQuery.value(7).toString();
+ server.proxyPort = serversQuery.value(8).toUInt();
+ server.proxyUser = serversQuery.value(9).toString();
+ server.proxyPass = serversQuery.value(10).toString();
+ servers << server;
+ }
+ net.serverList = servers;
+ nets << net;
+ }
+ return nets;
+}
+
+bool SqliteStorage::isValidNetwork(UserId user, const NetworkId &networkId) {
+ QSqlQuery query(logDb());
+ query.prepare(queryString("select_networkExists"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":networkid", networkId.toInt());
+ safeExec(query);
+
+ watchQuery(query); // there should not occur any errors
+ if(!query.first())
+ return false;
+
+ Q_ASSERT(!query.next());
+ return true;
+}
+
+bool SqliteStorage::isValidBuffer(const UserId &user, const BufferId &bufferId) {
+ QSqlQuery query(logDb());
+ query.prepare(queryString("select_bufferExists"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":bufferid", bufferId.toInt());
+ safeExec(query);
+
+ watchQuery(query);
+ if(!query.first())
+ return false;
+
+ Q_ASSERT(!query.next());
+ return true;
+}
+
+NetworkId SqliteStorage::getNetworkId(UserId user, const QString &network) {
+ QSqlQuery query(logDb());
+ query.prepare("SELECT networkid FROM network "
+ "WHERE userid = :userid AND networkname = :networkname");
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":networkname", network);
+ safeExec(query);
+
+ if(query.first())
+ return query.value(0).toInt();
+ else
+ return NetworkId();
+}
+
+QList<NetworkId> SqliteStorage::connectedNetworks(UserId user) {
+ QList<NetworkId> connectedNets;
+ QSqlQuery query(logDb());
+ query.prepare(queryString("select_connected_networks"));
+ query.bindValue(":userid", user.toInt());
+ safeExec(query);
+ watchQuery(query);
+
+ while(query.next()) {
+ connectedNets << query.value(0).toInt();
+ }
+
+ return connectedNets;
+}
+
+void SqliteStorage::setNetworkConnected(UserId user, const NetworkId &networkId, bool isConnected) {
+ QSqlQuery query(logDb());
+ query.prepare(queryString("update_network_connected"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":networkid", networkId.toInt());
+ query.bindValue(":connected", isConnected ? 1 : 0);
+ safeExec(query);
+ watchQuery(query);
+}
+
+QHash<QString, QString> SqliteStorage::persistentChannels(UserId user, const NetworkId &networkId) {
+ QHash<QString, QString> persistentChans;
+ QSqlQuery query(logDb());
+ query.prepare(queryString("select_persistent_channels"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":networkid", networkId.toInt());
+ safeExec(query);
+ watchQuery(query);