summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--common/datastorequery.cpp4
-rw-r--r--common/datastorequery.h4
-rw-r--r--common/domain/event.cpp2
-rw-r--r--common/domain/folder.cpp2
-rw-r--r--common/domain/mail.cpp2
5 files changed, 6 insertions, 8 deletions
diff --git a/common/datastorequery.cpp b/common/datastorequery.cpp
index d4a83b1..8897c29 100644
--- a/common/datastorequery.cpp
+++ b/common/datastorequery.cpp
@@ -300,8 +300,8 @@ public:
300 } 300 }
301}; 301};
302 302
303DataStoreQuery::DataStoreQuery(const Sink::Query &query, const QByteArray &type, EntityStore::Ptr store, TypeIndex &typeIndex, std::function<QVariant(const Sink::Entity &entity, const QByteArray &property)> getProperty) 303DataStoreQuery::DataStoreQuery(const Sink::Query &query, const QByteArray &type, EntityStore::Ptr store, std::function<QVariant(const Sink::Entity &entity, const QByteArray &property)> getProperty)
304 : mQuery(query), mType(type), mTypeIndex(typeIndex), mGetProperty(getProperty), mStore(store) 304 : mQuery(query), mType(type), mGetProperty(getProperty), mStore(store)
305{ 305{
306 setupQuery(); 306 setupQuery();
307} 307}
diff --git a/common/datastorequery.h b/common/datastorequery.h
index 4cf25b2..77c8ed5 100644
--- a/common/datastorequery.h
+++ b/common/datastorequery.h
@@ -21,7 +21,6 @@
21#include "query.h" 21#include "query.h"
22#include "storage.h" 22#include "storage.h"
23#include "resultset.h" 23#include "resultset.h"
24#include "typeindex.h"
25#include "query.h" 24#include "query.h"
26#include "entitybuffer.h" 25#include "entitybuffer.h"
27#include "log.h" 26#include "log.h"
@@ -36,7 +35,7 @@ class DataStoreQuery {
36public: 35public:
37 typedef QSharedPointer<DataStoreQuery> Ptr; 36 typedef QSharedPointer<DataStoreQuery> Ptr;
38 37
39 DataStoreQuery(const Sink::Query &query, const QByteArray &type, Sink::Storage::EntityStore::Ptr store, TypeIndex &typeIndex, std::function<QVariant(const Sink::Entity &entity, const QByteArray &property)> getProperty); 38 DataStoreQuery(const Sink::Query &query, const QByteArray &type, Sink::Storage::EntityStore::Ptr store, std::function<QVariant(const Sink::Entity &entity, const QByteArray &property)> getProperty);
40 ResultSet execute(); 39 ResultSet execute();
41 ResultSet update(qint64 baseRevision); 40 ResultSet update(qint64 baseRevision);
42 41
@@ -58,7 +57,6 @@ private:
58 57
59 Sink::Query mQuery; 58 Sink::Query mQuery;
60 const QByteArray mType; 59 const QByteArray mType;
61 TypeIndex &mTypeIndex;
62 std::function<QVariant(const Sink::Entity &entity, const QByteArray &property)> mGetProperty; 60 std::function<QVariant(const Sink::Entity &entity, const QByteArray &property)> mGetProperty;
63 bool mInitialQuery; 61 bool mInitialQuery;
64 QSharedPointer<FilterBase> mCollector; 62 QSharedPointer<FilterBase> mCollector;
diff --git a/common/domain/event.cpp b/common/domain/event.cpp
index d801592..6717187 100644
--- a/common/domain/event.cpp
+++ b/common/domain/event.cpp
@@ -91,7 +91,7 @@ QSharedPointer<WritePropertyMapper<TypeImplementation<Event>::BufferBuilder> > T
91DataStoreQuery::Ptr TypeImplementation<Event>::prepareQuery(const Sink::Query &query, Sink::Storage::EntityStore::Ptr store) 91DataStoreQuery::Ptr TypeImplementation<Event>::prepareQuery(const Sink::Query &query, Sink::Storage::EntityStore::Ptr store)
92{ 92{
93 auto mapper = initializeReadPropertyMapper(); 93 auto mapper = initializeReadPropertyMapper();
94 return DataStoreQuery::Ptr::create(query, ApplicationDomain::getTypeName<Event>(), store, getIndex(), [mapper](const Sink::Entity &entity, const QByteArray &property) { 94 return DataStoreQuery::Ptr::create(query, ApplicationDomain::getTypeName<Event>(), store, [mapper](const Sink::Entity &entity, const QByteArray &property) {
95 95
96 const auto localBuffer = Sink::EntityBuffer::readBuffer<Buffer>(entity.local()); 96 const auto localBuffer = Sink::EntityBuffer::readBuffer<Buffer>(entity.local());
97 return mapper->getProperty(property, localBuffer); 97 return mapper->getProperty(property, localBuffer);
diff --git a/common/domain/folder.cpp b/common/domain/folder.cpp
index f04a3e7..34e59f6 100644
--- a/common/domain/folder.cpp
+++ b/common/domain/folder.cpp
@@ -95,7 +95,7 @@ QSharedPointer<WritePropertyMapper<TypeImplementation<Folder>::BufferBuilder> >
95DataStoreQuery::Ptr TypeImplementation<Folder>::prepareQuery(const Sink::Query &query, Sink::Storage::EntityStore::Ptr store) 95DataStoreQuery::Ptr TypeImplementation<Folder>::prepareQuery(const Sink::Query &query, Sink::Storage::EntityStore::Ptr store)
96{ 96{
97 auto mapper = initializeReadPropertyMapper(); 97 auto mapper = initializeReadPropertyMapper();
98 return DataStoreQuery::Ptr::create(query, ApplicationDomain::getTypeName<Folder>(), store, getIndex(), [mapper](const Sink::Entity &entity, const QByteArray &property) { 98 return DataStoreQuery::Ptr::create(query, ApplicationDomain::getTypeName<Folder>(), store, [mapper](const Sink::Entity &entity, const QByteArray &property) {
99 const auto localBuffer = Sink::EntityBuffer::readBuffer<Buffer>(entity.local()); 99 const auto localBuffer = Sink::EntityBuffer::readBuffer<Buffer>(entity.local());
100 return mapper->getProperty(property, localBuffer); 100 return mapper->getProperty(property, localBuffer);
101 }); 101 });
diff --git a/common/domain/mail.cpp b/common/domain/mail.cpp
index 1b46e28..9e3a824 100644
--- a/common/domain/mail.cpp
+++ b/common/domain/mail.cpp
@@ -228,7 +228,7 @@ QSharedPointer<WritePropertyMapper<TypeImplementation<Mail>::BufferBuilder> > Ty
228DataStoreQuery::Ptr TypeImplementation<Mail>::prepareQuery(const Sink::Query &query, Sink::Storage::EntityStore::Ptr store) 228DataStoreQuery::Ptr TypeImplementation<Mail>::prepareQuery(const Sink::Query &query, Sink::Storage::EntityStore::Ptr store)
229{ 229{
230 auto mapper = initializeReadPropertyMapper(); 230 auto mapper = initializeReadPropertyMapper();
231 return DataStoreQuery::Ptr::create(query, ApplicationDomain::getTypeName<Mail>(), store, getIndex(), [mapper, store](const Sink::Entity &entity, const QByteArray &property) -> QVariant { 231 return DataStoreQuery::Ptr::create(query, ApplicationDomain::getTypeName<Mail>(), store, [mapper, store](const Sink::Entity &entity, const QByteArray &property) -> QVariant {
232 if (property == Mail::ThreadId::name) { 232 if (property == Mail::ThreadId::name) {
233 const auto localBuffer = Sink::EntityBuffer::readBuffer<Buffer>(entity.local()); 233 const auto localBuffer = Sink::EntityBuffer::readBuffer<Buffer>(entity.local());
234 Q_ASSERT(localBuffer); 234 Q_ASSERT(localBuffer);