Fixed index removals

1 files changed, 9 insertions, 5 deletions

diff --git a/common/index.cpp b/common/index.cpp
index f3d05f1..f09e265 100644
--- a/common/index.cpp
+++ b/common/index.cpp
@@ -18,22 +18,26 @@ Index::Index(const QByteArray &name, Sink::Storage::DataStore::Transaction &tran
 
 void Index::add(const QByteArray &key, const QByteArray &value)
 {
-    mDb.write(key, value);
+    mDb.write(key, value, [&] (const Sink::Storage::DataStore::Error &error) {
+        SinkWarning() << "Error while writing value" << error;
+    });
 }
 
 void Index::remove(const QByteArray &key, const QByteArray &value)
 {
-    mDb.remove(key, value);
+    mDb.remove(key, value, [&] (const Sink::Storage::DataStore::Error &error) {
+        SinkWarning() << "Error while removing value: " << key << value << error << error.store;
+    });
 }
 
 void Index::lookup(const QByteArray &key, const std::function<void(const QByteArray &value)> &resultHandler, const std::function<void(const Error &error)> &errorHandler, bool matchSubStringKeys)
 {
     mDb.scan(key,
-        [this, resultHandler](const QByteArray &key, const QByteArray &value) -> bool {
+        [&](const QByteArray &key, const QByteArray &value) -> bool {
             resultHandler(value);
             return true;
         },
-        [this, errorHandler](const Sink::Storage::DataStore::Error &error) {
+        [&](const Sink::Storage::DataStore::Error &error) {
             SinkWarning() << "Error while retrieving value" << error.message;
             errorHandler(Error(error.store, error.code, error.message));
         },
@@ -44,6 +48,6 @@ QByteArray Index::lookup(const QByteArray &key)
 {
     QByteArray result;
     //We have to create a deep copy, otherwise the returned data may become invalid when the transaction ends.
-    lookup(key, [&result](const QByteArray &value) { result = QByteArray(value.constData(), value.size()); }, [this](const Index::Error &error) { SinkWarning() << "Error while retrieving value" << error.message; });
+    lookup(key, [&](const QByteArray &value) { result = QByteArray(value.constData(), value.size()); }, [this](const Index::Error &error) { SinkWarning() << "Error while retrieving value" << error.message; });
     return result;
 }