summaryrefslogtreecommitdiffstats
path: root/examples
diff options
context:
space:
mode:
Diffstat (limited to 'examples')
-rw-r--r--examples/dummyresource/CMakeLists.txt2
-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.h11
-rw-r--r--examples/dummyresource/resourcefactory.cpp4
-rw-r--r--examples/dummyresource/resourcefactory.h5
7 files changed, 23 insertions, 21 deletions
diff --git a/examples/dummyresource/CMakeLists.txt b/examples/dummyresource/CMakeLists.txt
index 5e911d2..36b8e54 100644
--- a/examples/dummyresource/CMakeLists.txt
+++ b/examples/dummyresource/CMakeLists.txt
@@ -3,9 +3,9 @@ project(akonadi2_resource_dummy)
3add_definitions(-DQT_PLUGIN) 3add_definitions(-DQT_PLUGIN)
4include_directories(${CMAKE_CURRENT_SOURCE_DIR} ${CMAKE_CURRENT_BINARY_DIR}) 4include_directories(${CMAKE_CURRENT_SOURCE_DIR} ${CMAKE_CURRENT_BINARY_DIR})
5 5
6generate_flatbuffers(dummycalendar)
7 6
8add_library(${PROJECT_NAME} SHARED facade.cpp resourcefactory.cpp domainadaptor.cpp resourcefacade.cpp) 7add_library(${PROJECT_NAME} SHARED facade.cpp resourcefactory.cpp domainadaptor.cpp resourcefacade.cpp)
8generate_flatbuffers(${PROJECT_NAME} dummycalendar)
9qt5_use_modules(${PROJECT_NAME} Core Network) 9qt5_use_modules(${PROJECT_NAME} Core Network)
10target_link_libraries(${PROJECT_NAME} akonadi2common) 10target_link_libraries(${PROJECT_NAME} akonadi2common)
11 11
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..5d0291c 100644
--- a/examples/dummyresource/resourcefacade.h
+++ b/examples/dummyresource/resourcefacade.h
@@ -20,7 +20,8 @@
20#pragma once 20#pragma once
21 21
22#include "common/clientapi.h" 22#include "common/clientapi.h"
23#include "async/src/async.h" 23
24#include <Async/Async>
24 25
25class QSettings; 26class QSettings;
26 27
@@ -30,13 +31,13 @@ public:
30 DummyResourceConfigFacade(); 31 DummyResourceConfigFacade();
31 ~DummyResourceConfigFacade(); 32 ~DummyResourceConfigFacade();
32 //Create an instance 33 //Create an instance
33 Async::Job<void> create(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) Q_DECL_OVERRIDE; 34 KAsync::Job<void> create(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) Q_DECL_OVERRIDE;
34 //Modify configuration 35 //Modify configuration
35 Async::Job<void> modify(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) Q_DECL_OVERRIDE; 36 KAsync::Job<void> modify(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) Q_DECL_OVERRIDE;
36 //Remove instance 37 //Remove instance
37 Async::Job<void> remove(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) Q_DECL_OVERRIDE; 38 KAsync::Job<void> remove(const Akonadi2::ApplicationDomain::AkonadiResource &domainObject) Q_DECL_OVERRIDE;
38 //Read configuration and available instances 39 //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; 40 KAsync::Job<void> load(const Akonadi2::Query &query, const QSharedPointer<async::ResultProvider<typename Akonadi2::ApplicationDomain::AkonadiResource::Ptr> > &resultProvider) Q_DECL_OVERRIDE;
40 41
41private: 42private:
42 QSharedPointer<QSettings> getSettings(); 43 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..f5caf61 100644
--- a/examples/dummyresource/resourcefactory.h
+++ b/examples/dummyresource/resourcefactory.h
@@ -20,9 +20,10 @@
20#pragma once 20#pragma once
21 21
22#include "common/genericresource.h" 22#include "common/genericresource.h"
23#include "async/src/async.h"
24#include "common/messagequeue.h" 23#include "common/messagequeue.h"
25 24
25#include <Async/Async>
26
26#include <flatbuffers/flatbuffers.h> 27#include <flatbuffers/flatbuffers.h>
27 28
28//TODO: a little ugly to have this in two places, once here and once in Q_PLUGIN_METADATA 29//TODO: a little ugly to have this in two places, once here and once in Q_PLUGIN_METADATA
@@ -32,7 +33,7 @@ class DummyResource : public Akonadi2::GenericResource
32{ 33{
33public: 34public:
34 DummyResource(); 35 DummyResource();
35 Async::Job<void> synchronizeWithSource(Akonadi2::Pipeline *pipeline) Q_DECL_OVERRIDE; 36 KAsync::Job<void> synchronizeWithSource(Akonadi2::Pipeline *pipeline) Q_DECL_OVERRIDE;
36 void configurePipeline(Akonadi2::Pipeline *pipeline) Q_DECL_OVERRIDE; 37 void configurePipeline(Akonadi2::Pipeline *pipeline) Q_DECL_OVERRIDE;
37}; 38};
38 39