These checks are no longer necessary

5 files changed, 2 insertions, 15 deletions

diff --git a/common/messagequeue.cpp b/common/messagequeue.cpp
index fd86635..b9f11f8 100644
--- a/common/messagequeue.cpp
+++ b/common/messagequeue.cpp
@@ -112,7 +112,7 @@ KAsync::Job<void> MessageQueue::dequeueBatch(int maxBatchSize, const std::functi
             .openDatabase()
             .scan("",
                 [this, resultHandler, resultCount, &count, maxBatchSize, &waitCondition](const QByteArray &key, const QByteArray &value) -> bool {
-                    if (Sink::Storage::isInternalKey(key) || mPendingRemoval.contains(key)) {
+                    if (mPendingRemoval.contains(key)) {
                         return true;
                     }
                     *resultCount += 1;
@@ -158,7 +158,7 @@ bool MessageQueue::isEmpty()
     if (db) {
         db.scan("",
             [&count, this](const QByteArray &key, const QByteArray &value) -> bool {
-                if (!Sink::Storage::isInternalKey(key) && !mPendingRemoval.contains(key)) {
+                if (!mPendingRemoval.contains(key)) {
                     count++;
                     return false;
                 }
diff --git a/common/queryrunner.cpp b/common/queryrunner.cpp
index b304384..cb8157e 100644
--- a/common/queryrunner.cpp
+++ b/common/queryrunner.cpp
@@ -156,10 +156,6 @@ static inline ResultSet fullScan(const Sink::Storage::Transaction &transaction,
     Storage::mainDatabase(transaction, bufferType)
         .scan(QByteArray(),
             [&](const QByteArray &key, const QByteArray &value) -> bool {
-                // Skip internals
-                if (Sink::Storage::isInternalKey(key)) {
-                    return true;
-                }
                 if (keys.contains(Sink::Storage::uidFromKey(key))) {
                     //Not something that should persist if the replay works, so we keep a message for now.
                     Trace() << "Multiple revisions for key: " << key;
diff --git a/examples/imapresource/imapresource.cpp b/examples/imapresource/imapresource.cpp
index b8129cd..6168fa4 100644
--- a/examples/imapresource/imapresource.cpp
+++ b/examples/imapresource/imapresource.cpp
@@ -141,9 +141,6 @@ public:
                 // auto remoteIds = synchronizationTransaction.openDatabase("rid.mapping." + bufferType, std::function<void(const Sink::Storage::Error &)>(), true);
                 auto mainDatabase = Sink::Storage::mainDatabase(transaction(), bufferType);
                 mainDatabase.scan("", [&](const QByteArray &key, const QByteArray &) {
-                    if (Sink::Storage::isInternalKey(key)) {
-                        return true;
-                    }
                     callback(key);
                     return true;
                 });
diff --git a/examples/maildirresource/maildirresource.cpp b/examples/maildirresource/maildirresource.cpp
index 18f8334..9800f7f 100644
--- a/examples/maildirresource/maildirresource.cpp
+++ b/examples/maildirresource/maildirresource.cpp
@@ -289,9 +289,6 @@ public:
                 // auto remoteIds = synchronizationTransaction.openDatabase("rid.mapping." + bufferType, std::function<void(const Sink::Storage::Error &)>(), true);
                 auto mainDatabase = Sink::Storage::mainDatabase(transaction(), bufferType);
                 mainDatabase.scan("", [&](const QByteArray &key, const QByteArray &) {
-                    if (Sink::Storage::isInternalKey(key)) {
-                        return true;
-                    }
                     callback(key);
                     return true;
                 });
diff --git a/tests/pipelinetest.cpp b/tests/pipelinetest.cpp
index 6cb327f..c6ee9ab 100644
--- a/tests/pipelinetest.cpp
+++ b/tests/pipelinetest.cpp
@@ -34,9 +34,6 @@ 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;
     });