An index implementation.

1 files changed, 30 insertions, 0 deletions

diff --git a/common/index.cpp b/common/index.cpp
new file mode 100644
index 0000000..7b0c682
--- /dev/null
+++ b/common/index.cpp
@@ -0,0 +1,30 @@
+#include "index.h"
+#include <QDebug>
+
+Index::Index(const QString &storageRoot, const QString &name, Akonadi2::Storage::AccessMode mode)
+    : mStorage(storageRoot, name, mode, true)
+{
+
+}
+
+void Index::add(const QByteArray &key, const QByteArray &value)
+{
+    mStorage.startTransaction(Akonadi2::Storage::ReadWrite);
+    mStorage.write(key.data(), key.size(), value.data(), value.size());
+    mStorage.commitTransaction();
+}
+
+void Index::lookup(const QByteArray &key, const std::function<void(const QByteArray &value)> &resultHandler,
+                                          const std::function<void(const Error &error)> &errorHandler)
+{
+    mStorage.scan(key.data(), key.size(), [this, resultHandler](void *keyPtr, int keySize, void *valuePtr, int valueSize) -> bool {
+        resultHandler(QByteArray(static_cast<char*>(valuePtr), valueSize));
+        return true;
+    },
+    [errorHandler](const Akonadi2::Storage::Error &error) {
+        qDebug() << "Error while retrieving value" << QString::fromStdString(error.message);
+        errorHandler(Error(error.store, error.code, error.message));
+    }
+    );
+}
+