Fixed pipelinetest

2 files changed, 16 insertions, 2 deletions

diff --git a/common/pipeline.cpp b/common/pipeline.cpp
index a7059c1..100f158 100644
--- a/common/pipeline.cpp
+++ b/common/pipeline.cpp
@@ -228,8 +228,12 @@ KAsync::Job<qint64> Pipeline::modifiedEntity(void const *command, size_t size)
     }
     auto modifyEntity = Commands::GetModifyEntity(command);
     Q_ASSERT(modifyEntity);
-    Q_ASSERT(modifyEntity->modifiedProperties());
-    auto changeset = BufferUtils::fromVector(*modifyEntity->modifiedProperties());
+    QList<QByteArray> changeset;
+    if (modifyEntity->modifiedProperties()) {
+        changeset = BufferUtils::fromVector(*modifyEntity->modifiedProperties());
+    } else {
+        Warning() << "No changeset available";
+    }
     const qint64 baseRevision = modifyEntity->revision();
     const bool replayToSource = modifyEntity->replayToSource();
     // TODO rename modifyEntity->domainType to bufferType
diff --git a/tests/pipelinetest.cpp b/tests/pipelinetest.cpp
index 6ea2041..6cb327f 100644
--- a/tests/pipelinetest.cpp
+++ b/tests/pipelinetest.cpp
@@ -34,6 +34,9 @@ static QList<QByteArray> getKeys(const QByteArray &dbEnv, const QByteArray &name
     auto db = transaction.openDatabase(name, nullptr, false);
     QList<QByteArray> result;
     db.scan("", [&](const QByteArray &key, const QByteArray &value) {
+        if (Sink::Storage::isInternalKey(key)) {
+            return true;
+        }
         result << key;
         return true;
     });
@@ -106,13 +109,18 @@ QByteArray modifyEntityCommand(const flatbuffers::FlatBufferBuilder &entityFbb,
     flatbuffers::FlatBufferBuilder fbb;
     auto type = fbb.CreateString(Sink::ApplicationDomain::getTypeName<Sink::ApplicationDomain::Event>().toStdString().data());
     auto id = fbb.CreateString(std::string(uid.constData(), uid.size()));
+    auto summaryProperty = fbb.CreateString("summary");
+    std::vector<flatbuffers::Offset<flatbuffers::String>> modified;
+    modified.push_back(summaryProperty);
     auto delta = fbb.CreateVector<uint8_t>(entityFbb.GetBufferPointer(), entityFbb.GetSize());
+    auto modifiedProperties = fbb.CreateVector(modified);
     // auto delta = Sink::EntityBuffer::appendAsVector(fbb, buffer.constData(), buffer.size());
     Sink::Commands::ModifyEntityBuilder builder(fbb);
     builder.add_domainType(type);
     builder.add_delta(delta);
     builder.add_revision(revision);
     builder.add_entityId(id);
+    builder.add_modifiedProperties(modifiedProperties);
     auto location = builder.Finish();
     Sink::Commands::FinishModifyEntityBuffer(fbb, location);
 
@@ -207,6 +215,7 @@ private slots:
         pipeline.commit();
 
         auto result = getKeys("org.kde.pipelinetest.instance1", "event.main");
+        qDebug() << result;
         QCOMPARE(result.size(), 1);
     }
 
@@ -349,6 +358,7 @@ private slots:
         pipeline.setResourceType("test");
         pipeline.setPreprocessors("event", QVector<Sink::Preprocessor *>() << &testProcessor);
         pipeline.startTransaction();
+        // pipeline.setAdaptorFactory("event", QSharedPointer<TestEventAdaptorFactory>::create());
 
         // Actual test
         {