0.9.0-alpha3 (#3762)

- Add Redis Cluster support
- Add Redis Sentinel support
- Fix issues with rendering in connections tree
- Update translations
- Add ability to change language in Settings dialog #3753

Author: uglide

3rdparty/qredisclient

@@ -206,14 +206,24 @@ void Application::initUpdater()
 
 void Application::installTranslator()
 {
-    QString locale = QLocale::system().uiLanguages().first().replace( "-", "_" );
+    QSettings settings;
+    QString preferredLocale = settings.value("app/locale", "system").toString();
+
+    QString locale;
+
+    if (preferredLocale == "system") {
+        settings.setValue("app/locale", "system");
+        locale = QLocale::system().uiLanguages().first().replace( "-", "_" );
 
-    qDebug() << QLocale::system().uiLanguages();
+        qDebug() << QLocale::system().uiLanguages();
 
-    if (locale.isEmpty() || locale == "C")
-        locale = "en_US";
+        if (locale.isEmpty() || locale == "C")
+            locale = "en_US";
 
-    qDebug() << "Detected locale:" << locale;
+        qDebug() << "Detected locale:" << locale;
+    } else {
+        locale = preferredLocale;
+    }
 
     QTranslator* translator = new QTranslator((QObject *)this);
     if (translator->load( QString( ":/translations/rdm_" ) + locale ))

src/app/app.cpp

@@ -34,22 +34,25 @@ void TreeOperations::getDatabases(std::function<void (RedisClient::DatabaseList)
 
     RedisClient::DatabaseList availableDatabeses = m_connection->getKeyspaceInfo();
 
-    //detect all databases
-    RedisClient::Response scanningResp;
-    int dbIndex = (availableDatabeses.size() == 0)? 0 : availableDatabeses.lastKey() + 1;
-
-    while (true) {
-        try {
-            scanningResp = m_connection->commandSync("select", QString::number(dbIndex));
-        } catch (const RedisClient::Connection::Exception& e) {
-            throw ConnectionsTree::Operations::Exception(QObject::tr("Connection error: ") + QString(e.what()));
+    if (m_connection->mode() != RedisClient::Connection::Mode::Cluster) {
+        //detect all databases
+        RedisClient::Response scanningResp;
+        int dbIndex = (availableDatabeses.size() == 0)? 0 : availableDatabeses.lastKey() + 1;
+
+        while (true) {
+            try {
+                scanningResp = m_connection->commandSync("select", QString::number(dbIndex));
+            } catch (const RedisClient::Connection::Exception& e) {
+                throw ConnectionsTree::Operations::Exception(QObject::tr("Connection error: ") + QString(e.what()));
+            }
+
+            if (!scanningResp.isOkMessage())
+                break;
+
+            availableDatabeses.insert(dbIndex, 0);
+            ++dbIndex;
         }
 
-        if (!scanningResp.isOkMessage())
-            break;
-
-        availableDatabeses.insert(dbIndex, 0);
-        ++dbIndex;
     }
 
     emit m_manager.openServerStats(m_connection);
@@ -63,7 +66,11 @@ void TreeOperations::getDatabaseKeys(uint dbIndex, QString filter,
     QString keyPattern = filter.isEmpty() ? static_cast<ServerConfig>(m_connection->getConfig()).keysPattern() : filter;
 
     try {
-        m_connection->getDatabaseKeys(callback, keyPattern, dbIndex);
+        if (m_connection->mode() == RedisClient::Connection::Mode::Cluster) {
+            m_connection->getClusterKeys(callback, keyPattern);
+        } else {
+            m_connection->getDatabaseKeys(callback, keyPattern, dbIndex);
+        }
     } catch (const RedisClient::Connection::Exception& error) {
         callback(RedisClient::Connection::RawKeysList(), QString(QObject::tr("Cannot load keys: %1")).arg(error.what()));
     }
@@ -153,3 +160,14 @@ void TreeOperations::flushDb(int dbIndex, std::function<void(const QString&)> ca
         throw ConnectionsTree::Operations::Exception(QObject::tr("FlushDB error: ") + QString(e.what()));
     }
 }
+
+QString TreeOperations::mode()
+{
+    if (m_connection->mode() == RedisClient::Connection::Mode::Cluster) {
+        return QString("cluster");
+    } else if (m_connection->mode() == RedisClient::Connection::Mode::Sentinel) {
+        return QString("sentinel");
+    } else {
+        return QString("standalone");
+    }
+}

src/app/models/treeoperations.cpp

@@ -40,6 +40,8 @@ class TreeOperations : public QObject, public ConnectionsTree::Operations
 
     virtual void flushDb(int dbIndex, std::function<void(const QString&)> callback) override;
 
+    virtual QString mode() override;
+
 private:
      QSharedPointer<RedisClient::Connection> m_connection;
      ConnectionsManager& m_manager;

src/app/models/treeoperations.h

@@ -170,7 +170,7 @@ void AbstractNamespaceItem::renderChilds()
     QSharedPointer<TreeItem> self = getSelf().toStrongRef();
 
     if (!self) {
-        qDebug() << "Cannot render keys: invalid parent item";
+        qDebug() << "Cannot render keys: invalid parent item";        
         return;
     }        
 

src/modules/connections-tree/items/abstractnamespaceitem.cpp

@@ -24,7 +24,9 @@ class DatabaseItem : public QObject, public AbstractNamespaceItem
 
     QString getIconUrl() const override;
 
-    QString getType() const override { return "database"; }          
+    QString getType() const override { return "database"; }
+
+    int itemDepth() const override { return 1; }
 
     bool isLocked() const override;
 

src/modules/connections-tree/items/databaseitem.h

@@ -22,6 +22,8 @@ class KeyItem : public TreeItem
 
     QString getType() const override { return "key"; }
 
+    int itemDepth() const override { return m_fullPath.count(m_operations->getNamespaceSeparator().toUtf8()) + 2; }
+
     QList<QSharedPointer<TreeItem>> getAllChilds() const override;
 
     bool supportChildItems() const override;

src/modules/connections-tree/items/keyitem.h

@@ -14,15 +14,21 @@ NamespaceItem::NamespaceItem(const QByteArray &fullPath,
                              const KeysTreeRenderer::RenderingSettigns& settings)
     : AbstractNamespaceItem(model, parent, operations, settings),
       m_fullPath(fullPath),
-      m_removed(false)
+      m_removed(false),
+      m_rendering(false)
 {
     m_displayName = m_fullPath.mid(m_fullPath.lastIndexOf(settings.nsSeparator) + 1);
 
     m_eventHandlers.insert("click", [this]() {
-        if (m_childItems.size() != 0)
-            return;
+        if (m_childItems.size() == 0) {
+            m_rendering = true;
+            m_model.itemChanged(getSelf());
 
-        renderChilds();
+            renderChilds();
+
+            m_rendering = false;
+            m_model.itemChanged(getSelf());
+        }
     });
 
     m_eventHandlers.insert("delete", [this]() {
@@ -42,6 +48,7 @@ QByteArray NamespaceItem::getName() const
 
 QString NamespaceItem::getIconUrl() const
 {    
+    if (m_rendering) return QString("qrc:/images/wait.svg");
     return QString("qrc:/images/namespace.svg");
 }
 

src/modules/connections-tree/items/namespaceitem.cpp

@@ -24,6 +24,8 @@ class NamespaceItem : public QObject, public AbstractNamespaceItem
 
     QString getType() const override { return "namespace"; }
 
+    int itemDepth() const override { return m_fullPath.count(m_renderingSettings.nsSeparator.toUtf8()) + 2; }
+
     bool isLocked() const override;
 
     bool isEnabled() const override;    
@@ -36,5 +38,6 @@ class NamespaceItem : public QObject, public AbstractNamespaceItem
     QByteArray m_fullPath;    
     QByteArray m_displayName;
     bool m_removed;
+    bool m_rendering;
 };
 }

src/modules/connections-tree/items/namespaceitem.h

@@ -26,7 +26,7 @@ ServerItem::ServerItem(const QString& name, QSharedPointer<Operations> operation
         if (isDatabaseListLoaded())
             return;
 
-        load();
+        load();        
     });
 
     m_eventHandlers.insert("console", [this]() {
@@ -35,25 +35,26 @@ ServerItem::ServerItem(const QString& name, QSharedPointer<Operations> operation
 
     m_eventHandlers.insert("reload", [this]() {
         reload();
+        emit m_model.itemChanged(getSelf());
     });
 
     m_eventHandlers.insert("unload", [this]() {
-        unload();
+        unload();        
     });
 
     m_eventHandlers.insert("edit", [this]() {
         confirmAction(nullptr, tr("Value and Console tabs related to this "
                                   "connection will be closed. Do you want to continue?"), [this]()
          {
-             unload();
+             unload();             
              emit editActionRequested();
          });
     });
 
     m_eventHandlers.insert("delete", [this]() {
         confirmAction(nullptr, tr("Do you really want delete connection?"), [this]()
          {
-             unload();
+             unload();             
              emit deleteActionRequested();
          });
     });
@@ -71,8 +72,16 @@ QString ServerItem::getDisplayName() const
 QString ServerItem::getIconUrl() const
 {
     if (m_locked)    return QString("qrc:/images/wait.svg");
-    if (isDatabaseListLoaded()) return QString("qrc:/images/server.svg");
-    return QString("qrc:/images/server.svg"); //offline
+    if (isDatabaseListLoaded()) {
+        if (m_operations->mode() == "cluster") {
+            return QString("qrc:/images/cluster.svg");
+        } else if (m_operations->mode() == "sentinel") {
+            return QString("qrc:/images/sentinel.svg");
+        } else {
+            return QString("qrc:/images/server.svg");
+        }
+    }
+    return QString("qrc:/images/server_offline.svg");
 }
 
 QList<QSharedPointer<TreeItem> > ServerItem::getAllChilds() const