diff options
Diffstat (limited to 'examples')
-rw-r--r-- | examples/dummyresource/facade.cpp | 4 | ||||
-rw-r--r-- | examples/dummyresource/facade.h | 2 | ||||
-rw-r--r-- | examples/dummyresource/resourcefacade.cpp | 16 | ||||
-rw-r--r-- | examples/dummyresource/resourcefacade.h | 8 | ||||
-rw-r--r-- | examples/dummyresource/resourcefactory.cpp | 4 | ||||
-rw-r--r-- | examples/dummyresource/resourcefactory.h | 2 |
6 files changed, 18 insertions, 18 deletions
diff --git a/examples/dummyresource/facade.cpp b/examples/dummyresource/facade.cpp index 176d489..c0143c0 100644 --- a/examples/dummyresource/facade.cpp +++ b/examples/dummyresource/facade.cpp | |||
@@ -127,9 +127,9 @@ void DummyResourceFacade::readValue(QSharedPointer<Akonadi2::Storage> storage, c | |||
127 | }); | 127 | }); |
128 | } | 128 | } |
129 | 129 | ||
130 | Async::Job<qint64> DummyResourceFacade::load(const Akonadi2::Query &query, const QSharedPointer<Akonadi2::ResultProvider<Akonadi2::ApplicationDomain::Event::Ptr> > &resultProvider, qint64 oldRevision, qint64 newRevision) | 130 | KAsync::Job<qint64> DummyResourceFacade::load(const Akonadi2::Query &query, const QSharedPointer<Akonadi2::ResultProvider<Akonadi2::ApplicationDomain::Event::Ptr> > &resultProvider, qint64 oldRevision, qint64 newRevision) |
131 | { | 131 | { |
132 | return Async::start<qint64>([=]() { | 132 | return KAsync::start<qint64>([=]() { |
133 | //Now that the sync is complete we can execute the query | 133 | //Now that the sync is complete we can execute the query |
134 | const auto preparedQuery = prepareQuery(query); | 134 | const auto preparedQuery = prepareQuery(query); |
135 | 135 | ||
diff --git a/examples/dummyresource/facade.h b/examples/dummyresource/facade.h index d0af487..41fb3f3 100644 --- a/examples/dummyresource/facade.h +++ b/examples/dummyresource/facade.h | |||
@@ -34,7 +34,7 @@ class DummyResourceFacade : public Akonadi2::GenericFacade<Akonadi2::Application | |||
34 | public: | 34 | public: |
35 | DummyResourceFacade(); | 35 | DummyResourceFacade(); |
36 | virtual ~DummyResourceFacade(); | 36 | virtual ~DummyResourceFacade(); |
37 | Async::Job<qint64> load(const Akonadi2::Query &query, const QSharedPointer<Akonadi2::ResultProvider<Akonadi2::ApplicationDomain::Event::Ptr> > &resultProvider, qint64 oldRevision, qint64 newRevision) Q_DECL_OVERRIDE; | 37 | KAsync::Job<qint64> load(const Akonadi2::Query &query, const QSharedPointer<Akonadi2::ResultProvider<Akonadi2::ApplicationDomain::Event::Ptr> > &resultProvider, qint64 oldRevision, qint64 newRevision) Q_DECL_OVERRIDE; |
38 | 38 | ||
39 | private: | 39 | private: |
40 | void readValue(QSharedPointer<Akonadi2::Storage> storage, const QByteArray &key, const std::function<void(const Akonadi2::ApplicationDomain::Event::Ptr &)> &resultCallback, std::function<bool(const std::string &key, DummyCalendar::DummyEvent const *buffer, Akonadi2::ApplicationDomain::Buffer::Event const *local)>); | 40 | void readValue(QSharedPointer<Akonadi2::Storage> storage, const QByteArray &key, const std::function<void(const Akonadi2::ApplicationDomain::Event::Ptr &)> &resultCallback, std::function<bool(const std::string &key, DummyCalendar::DummyEvent const *buffer, Akonadi2::ApplicationDomain::Buffer::Event const *local)>); |
diff --git a/examples/dummyresource/resourcefacade.cpp b/examples/dummyresource/resourcefacade.cpp index 870bea2..af293d4 100644 --- a/examples/dummyresource/resourcefacade.cpp +++ b/examples/dummyresource/resourcefacade.cpp | |||
@@ -40,38 +40,38 @@ QSharedPointer<QSettings> DummyResourceConfigFacade::getSettings() | |||
40 | return QSharedPointer<QSettings>::create(QStandardPaths::writableLocation(QStandardPaths::GenericDataLocation) + "/akonadi2/" + "org.kde." + instanceIdentifier + "/settings.ini", QSettings::IniFormat); | 40 | return QSharedPointer<QSettings>::create(QStandardPaths::writableLocation(QStandardPaths::GenericDataLocation) + "/akonadi2/" + "org.kde." + instanceIdentifier + "/settings.ini", QSettings::IniFormat); |
41 | } | 41 | } |
42 | 42 | ||
43 | Async::Job<void> DummyResourceConfigFacade::create(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) | 43 | KAsync::Job<void> DummyResourceConfigFacade::create(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) |
44 | { | 44 | { |
45 | //TODO create resource instance | 45 | //TODO create resource instance |
46 | //This can be generalized in a base implementation | 46 | //This can be generalized in a base implementation |
47 | return Async::null<void>(); | 47 | return KAsync::null<void>(); |
48 | } | 48 | } |
49 | 49 | ||
50 | Async::Job<void> DummyResourceConfigFacade::modify(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) | 50 | KAsync::Job<void> DummyResourceConfigFacade::modify(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) |
51 | { | 51 | { |
52 | //modify configuration | 52 | //modify configuration |
53 | //This part is likely resource specific, but could be partially generalized | 53 | //This part is likely resource specific, but could be partially generalized |
54 | return Async::start<void>([domainObject, this]() { | 54 | return KAsync::start<void>([domainObject, this]() { |
55 | auto settings = getSettings(); | 55 | auto settings = getSettings(); |
56 | //TODO Write properties to file | 56 | //TODO Write properties to file |
57 | }); | 57 | }); |
58 | } | 58 | } |
59 | 59 | ||
60 | Async::Job<void> DummyResourceConfigFacade::remove(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) | 60 | KAsync::Job<void> DummyResourceConfigFacade::remove(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) |
61 | { | 61 | { |
62 | //TODO remove resource instance | 62 | //TODO remove resource instance |
63 | //This can be generalized in a base implementation | 63 | //This can be generalized in a base implementation |
64 | return Async::null<void>(); | 64 | return KAsync::null<void>(); |
65 | } | 65 | } |
66 | 66 | ||
67 | Async::Job<void> DummyResourceConfigFacade::load(const Akonadi2::Query &query, const QSharedPointer<async::ResultProvider<typename Akonadi2::ApplicationDomain::AkonadiResource::Ptr> > &resultProvider) | 67 | KAsync::Job<void> DummyResourceConfigFacade::load(const Akonadi2::Query &query, const QSharedPointer<async::ResultProvider<typename Akonadi2::ApplicationDomain::AkonadiResource::Ptr> > &resultProvider) |
68 | { | 68 | { |
69 | //Read configuration and list all available instances. | 69 | //Read configuration and list all available instances. |
70 | //This includes runtime information about runing instances etc. | 70 | //This includes runtime information about runing instances etc. |
71 | //Part of this is generic, and part is accessing the resource specific configuration. | 71 | //Part of this is generic, and part is accessing the resource specific configuration. |
72 | //FIXME this currently does not support live queries (because we're not inheriting from GenericFacade) | 72 | //FIXME this currently does not support live queries (because we're not inheriting from GenericFacade) |
73 | //FIXME only read what was requested in the query? | 73 | //FIXME only read what was requested in the query? |
74 | return Async::start<void>([resultProvider, this]() { | 74 | return KAsync::start<void>([resultProvider, this]() { |
75 | auto settings = getSettings(); | 75 | auto settings = getSettings(); |
76 | auto memoryAdaptor = QSharedPointer<Akonadi2::ApplicationDomain::MemoryBufferAdaptor>::create(); | 76 | auto memoryAdaptor = QSharedPointer<Akonadi2::ApplicationDomain::MemoryBufferAdaptor>::create(); |
77 | //TODO copy settings to adaptor | 77 | //TODO copy settings to adaptor |
diff --git a/examples/dummyresource/resourcefacade.h b/examples/dummyresource/resourcefacade.h index 0ba60ab..82ac41e 100644 --- a/examples/dummyresource/resourcefacade.h +++ b/examples/dummyresource/resourcefacade.h | |||
@@ -30,13 +30,13 @@ public: | |||
30 | DummyResourceConfigFacade(); | 30 | DummyResourceConfigFacade(); |
31 | ~DummyResourceConfigFacade(); | 31 | ~DummyResourceConfigFacade(); |
32 | //Create an instance | 32 | //Create an instance |
33 | Async::Job<void> create(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) Q_DECL_OVERRIDE; | 33 | KAsync::Job<void> create(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) Q_DECL_OVERRIDE; |
34 | //Modify configuration | 34 | //Modify configuration |
35 | Async::Job<void> modify(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) Q_DECL_OVERRIDE; | 35 | KAsync::Job<void> modify(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) Q_DECL_OVERRIDE; |
36 | //Remove instance | 36 | //Remove instance |
37 | Async::Job<void> remove(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) Q_DECL_OVERRIDE; | 37 | KAsync::Job<void> remove(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) Q_DECL_OVERRIDE; |
38 | //Read configuration and available instances | 38 | //Read configuration and available instances |
39 | Async::Job<void> load(const Akonadi2::Query &query, const QSharedPointer<async::ResultProvider<typename Akonadi2::ApplicationDomain::AkonadiResource::Ptr> > &resultProvider) Q_DECL_OVERRIDE; | 39 | KAsync::Job<void> load(const Akonadi2::Query &query, const QSharedPointer<async::ResultProvider<typename Akonadi2::ApplicationDomain::AkonadiResource::Ptr> > &resultProvider) Q_DECL_OVERRIDE; |
40 | 40 | ||
41 | private: | 41 | private: |
42 | QSharedPointer<QSettings> getSettings(); | 42 | QSharedPointer<QSettings> getSettings(); |
diff --git a/examples/dummyresource/resourcefactory.cpp b/examples/dummyresource/resourcefactory.cpp index a4cd68d..e16a693 100644 --- a/examples/dummyresource/resourcefactory.cpp +++ b/examples/dummyresource/resourcefactory.cpp | |||
@@ -162,9 +162,9 @@ void findByRemoteId(QSharedPointer<Akonadi2::Storage> storage, const QString &ri | |||
162 | }); | 162 | }); |
163 | } | 163 | } |
164 | 164 | ||
165 | Async::Job<void> DummyResource::synchronizeWithSource(Akonadi2::Pipeline *pipeline) | 165 | KAsync::Job<void> DummyResource::synchronizeWithSource(Akonadi2::Pipeline *pipeline) |
166 | { | 166 | { |
167 | return Async::start<void>([this, pipeline](Async::Future<void> &f) { | 167 | return KAsync::start<void>([this, pipeline](KAsync::Future<void> &f) { |
168 | //TODO use a read-only transaction during the complete sync to sync against a defined revision | 168 | //TODO use a read-only transaction during the complete sync to sync against a defined revision |
169 | auto storage = QSharedPointer<Akonadi2::Storage>::create(Akonadi2::Store::storageLocation(), "org.kde.dummy"); | 169 | auto storage = QSharedPointer<Akonadi2::Storage>::create(Akonadi2::Store::storageLocation(), "org.kde.dummy"); |
170 | for (auto it = s_dataSource.constBegin(); it != s_dataSource.constEnd(); it++) { | 170 | for (auto it = s_dataSource.constBegin(); it != s_dataSource.constEnd(); it++) { |
diff --git a/examples/dummyresource/resourcefactory.h b/examples/dummyresource/resourcefactory.h index 7b7783e..751f2d8 100644 --- a/examples/dummyresource/resourcefactory.h +++ b/examples/dummyresource/resourcefactory.h | |||
@@ -32,7 +32,7 @@ class DummyResource : public Akonadi2::GenericResource | |||
32 | { | 32 | { |
33 | public: | 33 | public: |
34 | DummyResource(); | 34 | DummyResource(); |
35 | Async::Job<void> synchronizeWithSource(Akonadi2::Pipeline *pipeline) Q_DECL_OVERRIDE; | 35 | KAsync::Job<void> synchronizeWithSource(Akonadi2::Pipeline *pipeline) Q_DECL_OVERRIDE; |
36 | void configurePipeline(Akonadi2::Pipeline *pipeline) Q_DECL_OVERRIDE; | 36 | void configurePipeline(Akonadi2::Pipeline *pipeline) Q_DECL_OVERRIDE; |
37 | }; | 37 | }; |
38 | 38 | ||