added iterator (untested)

Author: Skycoder42

src/datasync/asyncdatastore.cpp

@@ -69,6 +69,17 @@ Task AsyncDataStore::search(int dataMetaTypeId, int listMetaTypeId, const QStrin
 	return internalSearch(dataMetaTypeId, listMetaTypeId, searchQuery);
 }
 
+void AsyncDataStore::iterate(int metaTypeId, const std::function<bool(QVariant)> &iterator, const std::function<void(const QException &)> &onExcept)
+{
+	keys(metaTypeId).onResult([=](QStringList keys) {
+		if(!keys.isEmpty()) {
+			load(metaTypeId, keys[0]).onResult([=](QVariant result) {
+				internalIterate(metaTypeId, keys, 0, result, iterator, onExcept);
+			}, onExcept);
+		}
+	}, onExcept);
+}
+
 QFutureInterface<QVariant> AsyncDataStore::internalCount(int metaTypeId)
 {
 	QFutureInterface<QVariant> interface;
@@ -160,3 +171,14 @@ QFutureInterface<QVariant> AsyncDataStore::internalSearch(int dataMetaTypeId, in
 							  Q_ARG(QVariant, data));
 	return interface;
 }
+
+void AsyncDataStore::internalIterate(int metaTypeId, const QStringList &keys, int index, QVariant res, const std::function<bool (QVariant)> &iterator, const std::function<void (const QException &)> &onExcept)
+{
+	if(iterator(res)) {
+		if(++index < keys.size()) {
+			load(metaTypeId, keys[index]).onResult([=](QVariant result) {
+				internalIterate(metaTypeId, keys, index, result, iterator, onExcept);
+			}, onExcept);
+		}
+	}
+}

src/datasync/asyncdatastore.h

@@ -7,6 +7,7 @@
 #include <QtCore/qobject.h>
 #include <QtCore/qfuture.h>
 #include <QtCore/qmetaobject.h>
+#include <functional>
 
 namespace QtDataSync {
 
@@ -44,6 +45,10 @@ class Q_DATASYNC_EXPORT AsyncDataStore : public QObject
 	Task remove(int metaTypeId, const QVariant &key);
 	//! @copybrief AsyncDataStore::search(const QString &)
 	Task search(int dataMetaTypeId, int listMetaTypeId, const QString &query);
+	//! @copybrief AsyncDataStore::iterate(const std::function<bool(T)> &, const std::function<void(const QException &)> &)
+	void iterate(int metaTypeId,
+				 const std::function<bool(QVariant)> &iterator,
+				 const std::function<void(const QException &)> &onExcept);
 
 	//! Counts the number of datasets for the given type
 	template<typename T>
@@ -72,6 +77,10 @@ class Q_DATASYNC_EXPORT AsyncDataStore : public QObject
 	//! Searches the store for datasets of the given type where the key matches the query
 	template<typename T>
 	GenericTask<QList<T>> search(const QString &query);
+	//! Asynchronously iterates over all existing datasets of the given types
+	template<typename T>
+	void iterate(const std::function<bool(T)> &iterator,
+				 const std::function<void(const QException &)> &onExcept);
 
 	//! Loads the dataset with the given key for the given type into the existing object by updating it's properties
 	template<typename T>
@@ -96,6 +105,13 @@ class Q_DATASYNC_EXPORT AsyncDataStore : public QObject
 	QFutureInterface<QVariant> internalSave(int metaTypeId, const QVariant &value);
 	QFutureInterface<QVariant> internalRemove(int metaTypeId, const QString &key);
 	QFutureInterface<QVariant> internalSearch(int dataMetaTypeId, int listMetaTypeId, const QString &query);
+
+	void internalIterate(int metaTypeId,
+						 const QStringList &keys,
+						 int index,
+						 QVariant res,
+						 const std::function<bool(QVariant)> &iterator,
+						 const std::function<void(const QException &)> &onExcept);
 };
 
 template<typename T>
@@ -152,6 +168,14 @@ GenericTask<QList<T>> AsyncDataStore::search(const QString &query)
 	return internalSearch(qMetaTypeId<T>(), qMetaTypeId<QList<T>>(), query);
 }
 
+template<typename T>
+void AsyncDataStore::iterate(const std::function<bool(T)> &iterator, const std::function<void(const QException &)> &onExcept)
+{
+	return iterate(qMetaTypeId<T>(), [iterator](QVariant variant) {
+		return iterator(variant.template value<T>());
+	}, onExcept);
+}
+
 template<typename T>
 UpdateTask<T> AsyncDataStore::loadInto(const QString &key, const T &object)
 {

src/datasync/storageengine.cpp

@@ -231,7 +231,7 @@ void StorageEngine::clearAuthError()
 {
 	if(!currentAuthError.isNull()) {
 		currentAuthError.clear();
-		emit authenticationErrorChanged(currentAuthError);
+		emit authenticationErrorChanged({});
 	}
 }