diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-01-20 19:07:07 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-01-20 19:07:07 +0100 |
commit | bdb01c2c068df326f5a8328ed1492ab1bea388c5 (patch) | |
tree | 25c2ee1b29bc481b6914c244ed9ca194b1415d16 /common/indexupdater.h | |
parent | 17e7ee40c9185c0505883853345fd6024c675b1a (diff) | |
download | sink-bdb01c2c068df326f5a8328ed1492ab1bea388c5.tar.gz sink-bdb01c2c068df326f5a8328ed1492ab1bea388c5.zip |
Renamed Akonadi2 to Sink
(except for documentation).
Diffstat (limited to 'common/indexupdater.h')
-rw-r--r-- | common/indexupdater.h | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/common/indexupdater.h b/common/indexupdater.h index 48144e6..ced220b 100644 --- a/common/indexupdater.h +++ b/common/indexupdater.h | |||
@@ -21,7 +21,7 @@ | |||
21 | #include <pipeline.h> | 21 | #include <pipeline.h> |
22 | #include <index.h> | 22 | #include <index.h> |
23 | 23 | ||
24 | class IndexUpdater : public Akonadi2::Preprocessor { | 24 | class IndexUpdater : public Sink::Preprocessor { |
25 | public: | 25 | public: |
26 | IndexUpdater(const QByteArray &index, const QByteArray &type, const QByteArray &property) | 26 | IndexUpdater(const QByteArray &index, const QByteArray &type, const QByteArray &property) |
27 | :mIndexIdentifier(index), | 27 | :mIndexIdentifier(index), |
@@ -31,31 +31,31 @@ public: | |||
31 | 31 | ||
32 | } | 32 | } |
33 | 33 | ||
34 | void newEntity(const QByteArray &uid, qint64 revision, const Akonadi2::ApplicationDomain::BufferAdaptor &newEntity, Akonadi2::Storage::Transaction &transaction) Q_DECL_OVERRIDE | 34 | void newEntity(const QByteArray &uid, qint64 revision, const Sink::ApplicationDomain::BufferAdaptor &newEntity, Sink::Storage::Transaction &transaction) Q_DECL_OVERRIDE |
35 | { | 35 | { |
36 | add(newEntity.getProperty(mProperty), uid, transaction); | 36 | add(newEntity.getProperty(mProperty), uid, transaction); |
37 | } | 37 | } |
38 | 38 | ||
39 | void modifiedEntity(const QByteArray &uid, qint64 revision, const Akonadi2::ApplicationDomain::BufferAdaptor &oldEntity, const Akonadi2::ApplicationDomain::BufferAdaptor &newEntity, Akonadi2::Storage::Transaction &transaction) Q_DECL_OVERRIDE | 39 | void modifiedEntity(const QByteArray &uid, qint64 revision, const Sink::ApplicationDomain::BufferAdaptor &oldEntity, const Sink::ApplicationDomain::BufferAdaptor &newEntity, Sink::Storage::Transaction &transaction) Q_DECL_OVERRIDE |
40 | { | 40 | { |
41 | remove(oldEntity.getProperty(mProperty), uid, transaction); | 41 | remove(oldEntity.getProperty(mProperty), uid, transaction); |
42 | add(newEntity.getProperty(mProperty), uid, transaction); | 42 | add(newEntity.getProperty(mProperty), uid, transaction); |
43 | } | 43 | } |
44 | 44 | ||
45 | void deletedEntity(const QByteArray &uid, qint64 revision, const Akonadi2::ApplicationDomain::BufferAdaptor &oldEntity, Akonadi2::Storage::Transaction &transaction) Q_DECL_OVERRIDE | 45 | void deletedEntity(const QByteArray &uid, qint64 revision, const Sink::ApplicationDomain::BufferAdaptor &oldEntity, Sink::Storage::Transaction &transaction) Q_DECL_OVERRIDE |
46 | { | 46 | { |
47 | remove(oldEntity.getProperty(mProperty), uid, transaction); | 47 | remove(oldEntity.getProperty(mProperty), uid, transaction); |
48 | } | 48 | } |
49 | 49 | ||
50 | private: | 50 | private: |
51 | void add(const QVariant &value, const QByteArray &uid, Akonadi2::Storage::Transaction &transaction) | 51 | void add(const QVariant &value, const QByteArray &uid, Sink::Storage::Transaction &transaction) |
52 | { | 52 | { |
53 | if (value.isValid()) { | 53 | if (value.isValid()) { |
54 | Index(mIndexIdentifier, transaction).add(value.toByteArray(), uid); | 54 | Index(mIndexIdentifier, transaction).add(value.toByteArray(), uid); |
55 | } | 55 | } |
56 | } | 56 | } |
57 | 57 | ||
58 | void remove(const QVariant &value, const QByteArray &uid, Akonadi2::Storage::Transaction &transaction) | 58 | void remove(const QVariant &value, const QByteArray &uid, Sink::Storage::Transaction &transaction) |
59 | { | 59 | { |
60 | //TODO hide notfound error | 60 | //TODO hide notfound error |
61 | Index(mIndexIdentifier, transaction).remove(value.toByteArray(), uid); | 61 | Index(mIndexIdentifier, transaction).remove(value.toByteArray(), uid); |
@@ -67,21 +67,21 @@ private: | |||
67 | }; | 67 | }; |
68 | 68 | ||
69 | template<typename DomainType> | 69 | template<typename DomainType> |
70 | class DefaultIndexUpdater : public Akonadi2::Preprocessor { | 70 | class DefaultIndexUpdater : public Sink::Preprocessor { |
71 | public: | 71 | public: |
72 | void newEntity(const QByteArray &uid, qint64 revision, const Akonadi2::ApplicationDomain::BufferAdaptor &newEntity, Akonadi2::Storage::Transaction &transaction) Q_DECL_OVERRIDE | 72 | void newEntity(const QByteArray &uid, qint64 revision, const Sink::ApplicationDomain::BufferAdaptor &newEntity, Sink::Storage::Transaction &transaction) Q_DECL_OVERRIDE |
73 | { | 73 | { |
74 | Akonadi2::ApplicationDomain::TypeImplementation<DomainType>::index(uid, newEntity, transaction); | 74 | Sink::ApplicationDomain::TypeImplementation<DomainType>::index(uid, newEntity, transaction); |
75 | } | 75 | } |
76 | 76 | ||
77 | void modifiedEntity(const QByteArray &uid, qint64 revision, const Akonadi2::ApplicationDomain::BufferAdaptor &oldEntity, const Akonadi2::ApplicationDomain::BufferAdaptor &newEntity, Akonadi2::Storage::Transaction &transaction) Q_DECL_OVERRIDE | 77 | void modifiedEntity(const QByteArray &uid, qint64 revision, const Sink::ApplicationDomain::BufferAdaptor &oldEntity, const Sink::ApplicationDomain::BufferAdaptor &newEntity, Sink::Storage::Transaction &transaction) Q_DECL_OVERRIDE |
78 | { | 78 | { |
79 | Akonadi2::ApplicationDomain::TypeImplementation<DomainType>::removeIndex(uid, oldEntity, transaction); | 79 | Sink::ApplicationDomain::TypeImplementation<DomainType>::removeIndex(uid, oldEntity, transaction); |
80 | Akonadi2::ApplicationDomain::TypeImplementation<DomainType>::index(uid, newEntity, transaction); | 80 | Sink::ApplicationDomain::TypeImplementation<DomainType>::index(uid, newEntity, transaction); |
81 | } | 81 | } |
82 | 82 | ||
83 | void deletedEntity(const QByteArray &uid, qint64 revision, const Akonadi2::ApplicationDomain::BufferAdaptor &oldEntity, Akonadi2::Storage::Transaction &transaction) Q_DECL_OVERRIDE | 83 | void deletedEntity(const QByteArray &uid, qint64 revision, const Sink::ApplicationDomain::BufferAdaptor &oldEntity, Sink::Storage::Transaction &transaction) Q_DECL_OVERRIDE |
84 | { | 84 | { |
85 | Akonadi2::ApplicationDomain::TypeImplementation<DomainType>::removeIndex(uid, oldEntity, transaction); | 85 | Sink::ApplicationDomain::TypeImplementation<DomainType>::removeIndex(uid, oldEntity, transaction); |
86 | } | 86 | } |
87 | }; | 87 | }; |