These checks are no longer necessary

2 files changed, 2 insertions, 6 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;