Add basic ReJSON module support

src/app/models/key-models/keyfactory.cpp

@@ -7,6 +7,7 @@
 #include "sortedsetkey.h"
 #include "hashkey.h"
 #include "listkey.h"
+#include "rejsonkey.h"
 #include <QObject>
 
 KeyFactory::KeyFactory()
@@ -56,6 +57,9 @@ void KeyFactory::loadKey(QSharedPointer<RedisClient::Connection> connection,
 
         result = createModel(type, connection, keyFullPath, dbIndex, ttl);
 
+        if (!result)
+            return callback(result, QString(QObject::tr("Unsupported Redis Data type %1").arg(type)));
+
         callback(result, QString());
 
     }, dbIndex);
@@ -92,6 +96,8 @@ QSharedPointer<ValueEditor::Model> KeyFactory::createModel(QString type, QShared
         return QSharedPointer<ValueEditor::Model>(new SortedSetKeyModel(connection, keyFullPath, dbIndex, ttl));
     } else if (type == "hash") {
         return QSharedPointer<ValueEditor::Model>(new HashKeyModel(connection, keyFullPath, dbIndex, ttl));
+    } else if (type == "ReJSON-RL") {
+        return QSharedPointer<ValueEditor::Model>(new ReJSONKeyModel(connection, keyFullPath, dbIndex, ttl));
     }
 
     return QSharedPointer<ValueEditor::Model>();

src/app/models/key-models/rejsonkey.cpp

@@ -0,0 +1,96 @@
+#include "rejsonkey.h"
+#include <qredisclient/connection.h>
+
+ReJSONKeyModel::ReJSONKeyModel(QSharedPointer<RedisClient::Connection> connection,
+                               QByteArray fullPath, int dbIndex, long long ttl)
+    : KeyModel(connection, fullPath, dbIndex, ttl, false,
+               QByteArray(), QByteArray(), QByteArray())
+{
+}
+
+QString ReJSONKeyModel::getType()
+{
+    return "ReJSON";
+}
+
+QStringList ReJSONKeyModel::getColumnNames()
+{
+    return QStringList(); // Single value type - No columns
+}
+
+QHash<int, QByteArray> ReJSONKeyModel::getRoles()
+{
+    QHash<int, QByteArray> roles;
+    roles[Roles::Value] = "value";
+    return roles;
+}
+
+QVariant ReJSONKeyModel::getData(int rowIndex, int dataRole)
+{
+    if (!isRowLoaded(rowIndex))
+        return QVariant();
+
+    if (dataRole == Roles::Value)
+        return m_rowsCache[rowIndex];
+
+    return QVariant();
+}
+
+void ReJSONKeyModel::updateRow(int rowIndex, const QVariantMap &row)
+{
+    if (rowIndex > 0 || !isRowValid(row)) {
+        qDebug() << "Row is not valid";
+        return;
+    }
+
+    QByteArray value = row.value("value").toByteArray();
+
+    if (value.isEmpty())
+        return;
+
+    RedisClient::Response result;
+    try {
+        result = m_connection->commandSync({"JSON.SET", m_keyFullPath, ".", value}, m_dbIndex);
+    } catch (const RedisClient::Connection::Exception& e) {
+        throw Exception(QObject::tr("Connection error: ") + QString(e.what()));
+    }
+
+    if (result.isOkMessage()) {
+        m_rowsCache.clear();
+        m_rowsCache.addLoadedRange({0, 0}, (QList<QByteArray>() << value));
+        m_notifier->dataLoaded();
+    }
+}
+
+void ReJSONKeyModel::addRow(const QVariantMap &row)
+{
+    updateRow(0, row);
+}
+
+void ReJSONKeyModel::loadRows(unsigned long, unsigned long, std::function<void(const QString&)> callback)
+{
+    try {
+        m_connection->command({"JSON.GET", m_keyFullPath},
+                              getConnector().data(),
+                              [this, callback](RedisClient::Response r, QString e)
+        {
+            if (r.getType() != RedisClient::Response::Bulk || !e.isEmpty()) {
+                return callback(QString("Cannot load value"));
+            }
+
+            m_rowsCache.clear();
+            m_rowsCache.push_back(r.getValue().toByteArray());
+            m_notifier->dataLoaded();
+
+            callback(QString());
+        }, m_dbIndex);
+    } catch (const RedisClient::Connection::Exception& e) {
+        throw Exception(QObject::tr("Connection error: ") + QString(e.what()));
+    }
+}
+
+void ReJSONKeyModel::removeRow(int)
+{
+    m_rowCount--;
+    setRemovedIfEmpty();
+}

src/app/models/key-models/rejsonkey.h

@@ -0,0 +1,25 @@
+#pragma once
+#include "abstractkey.h"
+
+class ReJSONKeyModel : public KeyModel<QByteArray>
+{
+public:
+    ReJSONKeyModel(QSharedPointer<RedisClient::Connection> connection,
+                   QByteArray fullPath, int dbIndex, long long ttl);
+
+    QString getType() override;
+    QStringList getColumnNames() override;
+    QHash<int, QByteArray> getRoles() override;
+    QVariant getData(int rowIndex, int dataRole) override;
+
+    void addRow(const QVariantMap&) override;
+    virtual void updateRow(int rowIndex, const QVariantMap& row) override;
+    void loadRows(unsigned long, unsigned long, std::function<void(const QString&)> callback) override;
+    void removeRow(int) override;
+
+protected:
+    void addLoadedRowsToCache(const QVariantList&, int) override {}
+
+private:
+    enum Roles { Value = Qt::UserRole + 1 };
+};

src/qml/value-editor/ValueTabs.qml

@@ -296,7 +296,7 @@ Repeater {
                                     elide: styleData.elideMode
                                     text: {
 
-                                        if (styleData.value === "" || keyType === "string") {
+                                        if (styleData.value === "" || keyType === "string" || keyType === "ReJSON") {
                                             return ""
                                         }
 
@@ -337,7 +337,7 @@ Repeater {
 
                                     console.log(keyType)
 
-                                    if (keyType === "string") {
+                                    if (keyType === "string" || keyType === "ReJSON") {
                                         valueEditor.loadRowValue(0)
                                     } else {
                                         var columns = columnNames

src/qml/value-editor/editors/editor.js

@@ -12,6 +12,8 @@ function getEditorByTypeString(keyType) {
         return "./editors/SortedSetItemEditor.qml"
     } else if (keyType === "hash") {
         return "./editors/HashItemEditor.qml"
+    } else if (keyType === "ReJSON") {
+        return "./editors/SingleItemEditor.qml"
     } else {
         console.error("Editor for type " + keyType + " is not defined!")
     }

tests/unit_tests/testcases/app/app-tests.pri

@@ -17,6 +17,7 @@ HEADERS  += \
     $$APP_SRC_DIR/models/key-models/setkey.h \
     $$APP_SRC_DIR/models/key-models/sortedsetkey.h \
     $$APP_SRC_DIR/models/key-models/hashkey.h \            
+    $$APP_SRC_DIR/models/key-models/rejsonkey.h \
 
 SOURCES += \
     $$PWD/test_*.cpp \
@@ -30,7 +31,8 @@ SOURCES += \
     $$APP_SRC_DIR/models/key-models/listlikekey.cpp \
     $$APP_SRC_DIR/models/key-models/setkey.cpp \
     $$APP_SRC_DIR/models/key-models/sortedsetkey.cpp \
-    $$APP_SRC_DIR/models/key-models/hashkey.cpp \            
+    $$APP_SRC_DIR/models/key-models/hashkey.cpp \
+    $$APP_SRC_DIR/models/key-models/rejsonkey.cpp \
 
 OTHER_FILES += \
     connections.xml