diff options
Diffstat (limited to 'common/domain/event.cpp')
-rw-r--r-- | common/domain/event.cpp | 10 |
1 files changed, 2 insertions, 8 deletions
diff --git a/common/domain/event.cpp b/common/domain/event.cpp index dfbcb61..118ffa3 100644 --- a/common/domain/event.cpp +++ b/common/domain/event.cpp | |||
@@ -52,11 +52,6 @@ static TypeIndex &getIndex() | |||
52 | return *index; | 52 | return *index; |
53 | } | 53 | } |
54 | 54 | ||
55 | ResultSet TypeImplementation<Event>::queryIndexes(const Sink::Query &query, const QByteArray &resourceInstanceIdentifier, QSet<QByteArray> &appliedFilters, QByteArray &appliedSorting, Sink::Storage::Transaction &transaction) | ||
56 | { | ||
57 | return getIndex().query(query, appliedFilters, appliedSorting, transaction); | ||
58 | } | ||
59 | |||
60 | void TypeImplementation<Event>::index(const QByteArray &identifier, const BufferAdaptor &bufferAdaptor, Sink::Storage::Transaction &transaction) | 55 | void TypeImplementation<Event>::index(const QByteArray &identifier, const BufferAdaptor &bufferAdaptor, Sink::Storage::Transaction &transaction) |
61 | { | 56 | { |
62 | return getIndex().add(identifier, bufferAdaptor, transaction); | 57 | return getIndex().add(identifier, bufferAdaptor, transaction); |
@@ -87,11 +82,10 @@ QSharedPointer<WritePropertyMapper<TypeImplementation<Event>::BufferBuilder> > T | |||
87 | return propertyMapper; | 82 | return propertyMapper; |
88 | } | 83 | } |
89 | 84 | ||
90 | DataStoreQuery TypeImplementation<Event>::prepareQuery(const Sink::Query &query, Sink::Storage::Transaction &transaction) | 85 | DataStoreQuery::Ptr TypeImplementation<Event>::prepareQuery(const Sink::Query &query, Sink::Storage::Transaction &transaction) |
91 | { | 86 | { |
92 | |||
93 | auto mapper = initializeReadPropertyMapper(); | 87 | auto mapper = initializeReadPropertyMapper(); |
94 | return DataStoreQuery(query, ApplicationDomain::getTypeName<Event>(), transaction, getIndex(), [mapper](const Sink::Entity &entity, const QByteArray &property) { | 88 | return DataStoreQuery::Ptr::create(query, ApplicationDomain::getTypeName<Event>(), transaction, getIndex(), [mapper](const Sink::Entity &entity, const QByteArray &property) { |
95 | 89 | ||
96 | const auto localBuffer = Sink::EntityBuffer::readBuffer<Buffer>(entity.local()); | 90 | const auto localBuffer = Sink::EntityBuffer::readBuffer<Buffer>(entity.local()); |
97 | return mapper->getProperty(property, localBuffer); | 91 | return mapper->getProperty(property, localBuffer); |