summaryrefslogtreecommitdiffstats
path: root/examples
diff options
context:
space:
mode:
Diffstat (limited to 'examples')
-rw-r--r--examples/dummyresource/facade.cpp4
-rw-r--r--examples/dummyresource/facade.h2
-rw-r--r--examples/dummyresource/resourcefacade.cpp16
-rw-r--r--examples/dummyresource/resourcefacade.h8
-rw-r--r--examples/dummyresource/resourcefactory.cpp4
-rw-r--r--examples/dummyresource/resourcefactory.h2
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
130Async::Job<qint64> DummyResourceFacade::load(const Akonadi2::Query &query, const QSharedPointer<Akonadi2::ResultProvider<Akonadi2::ApplicationDomain::Event::Ptr> > &resultProvider, qint64 oldRevision, qint64 newRevision) 130KAsync::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
34public: 34public:
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
39private: 39private:
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
43Async::Job<void> DummyResourceConfigFacade::create(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) 43KAsync::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
50Async::Job<void> DummyResourceConfigFacade::modify(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) 50KAsync::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
60Async::Job<void> DummyResourceConfigFacade::remove(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) 60KAsync::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
67Async::Job<void> DummyResourceConfigFacade::load(const Akonadi2::Query &query, const QSharedPointer<async::ResultProvider<typename Akonadi2::ApplicationDomain::AkonadiResource::Ptr> > &resultProvider) 67KAsync::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
41private: 41private:
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
165Async::Job<void> DummyResource::synchronizeWithSource(Akonadi2::Pipeline *pipeline) 165KAsync::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{
33public: 33public:
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