summaryrefslogtreecommitdiffstats
path: root/examples/dummyresource/resourcefactory.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'examples/dummyresource/resourcefactory.cpp')
-rw-r--r--examples/dummyresource/resourcefactory.cpp56
1 files changed, 28 insertions, 28 deletions
diff --git a/examples/dummyresource/resourcefactory.cpp b/examples/dummyresource/resourcefactory.cpp
index c43b5e6..31633d7 100644
--- a/examples/dummyresource/resourcefactory.cpp
+++ b/examples/dummyresource/resourcefactory.cpp
@@ -43,24 +43,24 @@
43#define ENTITY_TYPE_MAIL "mail" 43#define ENTITY_TYPE_MAIL "mail"
44#define ENTITY_TYPE_FOLDER "folder" 44#define ENTITY_TYPE_FOLDER "folder"
45 45
46DummyResource::DummyResource(const QByteArray &instanceIdentifier, const QSharedPointer<Akonadi2::Pipeline> &pipeline) 46DummyResource::DummyResource(const QByteArray &instanceIdentifier, const QSharedPointer<Sink::Pipeline> &pipeline)
47 : Akonadi2::GenericResource(instanceIdentifier, pipeline), 47 : Sink::GenericResource(instanceIdentifier, pipeline),
48 mEventAdaptorFactory(QSharedPointer<DummyEventAdaptorFactory>::create()), 48 mEventAdaptorFactory(QSharedPointer<DummyEventAdaptorFactory>::create()),
49 mMailAdaptorFactory(QSharedPointer<DummyMailAdaptorFactory>::create()), 49 mMailAdaptorFactory(QSharedPointer<DummyMailAdaptorFactory>::create()),
50 mFolderAdaptorFactory(QSharedPointer<DummyFolderAdaptorFactory>::create()) 50 mFolderAdaptorFactory(QSharedPointer<DummyFolderAdaptorFactory>::create())
51{ 51{
52 addType(ENTITY_TYPE_MAIL, mMailAdaptorFactory, 52 addType(ENTITY_TYPE_MAIL, mMailAdaptorFactory,
53 QVector<Akonadi2::Preprocessor*>() << new DefaultIndexUpdater<Akonadi2::ApplicationDomain::Mail>); 53 QVector<Sink::Preprocessor*>() << new DefaultIndexUpdater<Sink::ApplicationDomain::Mail>);
54 addType(ENTITY_TYPE_FOLDER, mFolderAdaptorFactory, 54 addType(ENTITY_TYPE_FOLDER, mFolderAdaptorFactory,
55 QVector<Akonadi2::Preprocessor*>() << new DefaultIndexUpdater<Akonadi2::ApplicationDomain::Folder>); 55 QVector<Sink::Preprocessor*>() << new DefaultIndexUpdater<Sink::ApplicationDomain::Folder>);
56 addType(ENTITY_TYPE_EVENT, mEventAdaptorFactory, 56 addType(ENTITY_TYPE_EVENT, mEventAdaptorFactory,
57 QVector<Akonadi2::Preprocessor*>() << new DefaultIndexUpdater<Akonadi2::ApplicationDomain::Event>); 57 QVector<Sink::Preprocessor*>() << new DefaultIndexUpdater<Sink::ApplicationDomain::Event>);
58} 58}
59 59
60Akonadi2::ApplicationDomain::Event::Ptr DummyResource::createEvent(const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Akonadi2::Storage::Transaction &transaction) 60Sink::ApplicationDomain::Event::Ptr DummyResource::createEvent(const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Sink::Storage::Transaction &transaction)
61{ 61{
62 static uint8_t rawData[100]; 62 static uint8_t rawData[100];
63 auto event = Akonadi2::ApplicationDomain::Event::Ptr::create(); 63 auto event = Sink::ApplicationDomain::Event::Ptr::create();
64 event->setProperty("summary", data.value("summary").toString()); 64 event->setProperty("summary", data.value("summary").toString());
65 event->setProperty("remoteId", ridBuffer); 65 event->setProperty("remoteId", ridBuffer);
66 event->setProperty("description", data.value("description").toString()); 66 event->setProperty("description", data.value("description").toString());
@@ -68,9 +68,9 @@ Akonadi2::ApplicationDomain::Event::Ptr DummyResource::createEvent(const QByteAr
68 return event; 68 return event;
69} 69}
70 70
71Akonadi2::ApplicationDomain::Mail::Ptr DummyResource::createMail(const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Akonadi2::Storage::Transaction &transaction) 71Sink::ApplicationDomain::Mail::Ptr DummyResource::createMail(const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Sink::Storage::Transaction &transaction)
72{ 72{
73 auto mail = Akonadi2::ApplicationDomain::Mail::Ptr::create(); 73 auto mail = Sink::ApplicationDomain::Mail::Ptr::create();
74 mail->setProperty("subject", data.value("subject").toString()); 74 mail->setProperty("subject", data.value("subject").toString());
75 mail->setProperty("senderEmail", data.value("senderEmail").toString()); 75 mail->setProperty("senderEmail", data.value("senderEmail").toString());
76 mail->setProperty("senderName", data.value("senderName").toString()); 76 mail->setProperty("senderName", data.value("senderName").toString());
@@ -81,19 +81,19 @@ Akonadi2::ApplicationDomain::Mail::Ptr DummyResource::createMail(const QByteArra
81 return mail; 81 return mail;
82} 82}
83 83
84Akonadi2::ApplicationDomain::Folder::Ptr DummyResource::createFolder(const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Akonadi2::Storage::Transaction &transaction) 84Sink::ApplicationDomain::Folder::Ptr DummyResource::createFolder(const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Sink::Storage::Transaction &transaction)
85{ 85{
86 auto folder = Akonadi2::ApplicationDomain::Folder::Ptr::create(); 86 auto folder = Sink::ApplicationDomain::Folder::Ptr::create();
87 folder->setProperty("name", data.value("name").toString()); 87 folder->setProperty("name", data.value("name").toString());
88 folder->setProperty("icon", data.value("icon").toString()); 88 folder->setProperty("icon", data.value("icon").toString());
89 if (!data.value("parent").toString().isEmpty()) { 89 if (!data.value("parent").toString().isEmpty()) {
90 auto akonadiId = resolveRemoteId(ENTITY_TYPE_FOLDER, data.value("parent").toByteArray(), transaction); 90 auto sinkId = resolveRemoteId(ENTITY_TYPE_FOLDER, data.value("parent").toByteArray(), transaction);
91 folder->setProperty("parent", akonadiId); 91 folder->setProperty("parent", sinkId);
92 } 92 }
93 return folder; 93 return folder;
94} 94}
95 95
96void DummyResource::synchronize(const QByteArray &bufferType, const QMap<QString, QMap<QString, QVariant> > &data, Akonadi2::Storage::Transaction &transaction, Akonadi2::Storage::Transaction &synchronizationTransaction, DomainTypeAdaptorFactoryInterface &adaptorFactory, std::function<Akonadi2::ApplicationDomain::ApplicationDomainType::Ptr(const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Akonadi2::Storage::Transaction &)> createEntity) 96void DummyResource::synchronize(const QByteArray &bufferType, const QMap<QString, QMap<QString, QVariant> > &data, Sink::Storage::Transaction &transaction, Sink::Storage::Transaction &synchronizationTransaction, DomainTypeAdaptorFactoryInterface &adaptorFactory, std::function<Sink::ApplicationDomain::ApplicationDomainType::Ptr(const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Sink::Storage::Transaction &)> createEntity)
97{ 97{
98 //TODO find items to remove 98 //TODO find items to remove
99 for (auto it = data.constBegin(); it != data.constEnd(); it++) { 99 for (auto it = data.constBegin(); it != data.constEnd(); it++) {
@@ -103,26 +103,26 @@ void DummyResource::synchronize(const QByteArray &bufferType, const QMap<QString
103 } 103 }
104} 104}
105 105
106KAsync::Job<void> DummyResource::synchronizeWithSource(Akonadi2::Storage &mainStore, Akonadi2::Storage &synchronizationStore) 106KAsync::Job<void> DummyResource::synchronizeWithSource(Sink::Storage &mainStore, Sink::Storage &synchronizationStore)
107{ 107{
108 Log() << " Synchronizing"; 108 Log() << " Synchronizing";
109 return KAsync::start<void>([this, &mainStore, &synchronizationStore]() { 109 return KAsync::start<void>([this, &mainStore, &synchronizationStore]() {
110 auto transaction = mainStore.createTransaction(Akonadi2::Storage::ReadOnly); 110 auto transaction = mainStore.createTransaction(Sink::Storage::ReadOnly);
111 auto synchronizationTransaction = synchronizationStore.createTransaction(Akonadi2::Storage::ReadWrite); 111 auto synchronizationTransaction = synchronizationStore.createTransaction(Sink::Storage::ReadWrite);
112 synchronize(ENTITY_TYPE_EVENT, DummyStore::instance().events(), transaction, synchronizationTransaction, *mEventAdaptorFactory, [this](const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Akonadi2::Storage::Transaction &synchronizationTransaction) { 112 synchronize(ENTITY_TYPE_EVENT, DummyStore::instance().events(), transaction, synchronizationTransaction, *mEventAdaptorFactory, [this](const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Sink::Storage::Transaction &synchronizationTransaction) {
113 return createEvent(ridBuffer, data, synchronizationTransaction); 113 return createEvent(ridBuffer, data, synchronizationTransaction);
114 }); 114 });
115 synchronize(ENTITY_TYPE_MAIL, DummyStore::instance().mails(), transaction, synchronizationTransaction, *mMailAdaptorFactory, [this](const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Akonadi2::Storage::Transaction &synchronizationTransaction) { 115 synchronize(ENTITY_TYPE_MAIL, DummyStore::instance().mails(), transaction, synchronizationTransaction, *mMailAdaptorFactory, [this](const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Sink::Storage::Transaction &synchronizationTransaction) {
116 return createMail(ridBuffer, data, synchronizationTransaction); 116 return createMail(ridBuffer, data, synchronizationTransaction);
117 }); 117 });
118 synchronize(ENTITY_TYPE_FOLDER, DummyStore::instance().folders(), transaction, synchronizationTransaction, *mFolderAdaptorFactory, [this](const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Akonadi2::Storage::Transaction &synchronizationTransaction) { 118 synchronize(ENTITY_TYPE_FOLDER, DummyStore::instance().folders(), transaction, synchronizationTransaction, *mFolderAdaptorFactory, [this](const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Sink::Storage::Transaction &synchronizationTransaction) {
119 return createFolder(ridBuffer, data, synchronizationTransaction); 119 return createFolder(ridBuffer, data, synchronizationTransaction);
120 }); 120 });
121 Log() << "Done Synchronizing"; 121 Log() << "Done Synchronizing";
122 }); 122 });
123} 123}
124 124
125KAsync::Job<void> DummyResource::replay(Akonadi2::Storage &synchronizationStore, const QByteArray &type, const QByteArray &key, const QByteArray &value) 125KAsync::Job<void> DummyResource::replay(Sink::Storage &synchronizationStore, const QByteArray &type, const QByteArray &key, const QByteArray &value)
126{ 126{
127 Trace() << "Replaying " << key; 127 Trace() << "Replaying " << key;
128 return KAsync::null<void>(); 128 return KAsync::null<void>();
@@ -131,7 +131,7 @@ KAsync::Job<void> DummyResource::replay(Akonadi2::Storage &synchronizationStore,
131void DummyResource::removeFromDisk(const QByteArray &instanceIdentifier) 131void DummyResource::removeFromDisk(const QByteArray &instanceIdentifier)
132{ 132{
133 GenericResource::removeFromDisk(instanceIdentifier); 133 GenericResource::removeFromDisk(instanceIdentifier);
134 Akonadi2::Storage(Akonadi2::storageLocation(), instanceIdentifier + ".synchronization", Akonadi2::Storage::ReadWrite).removeFromDisk(); 134 Sink::Storage(Sink::storageLocation(), instanceIdentifier + ".synchronization", Sink::Storage::ReadWrite).removeFromDisk();
135} 135}
136 136
137KAsync::Job<void> DummyResource::inspect(int inspectionType, const QByteArray &inspectionId, const QByteArray &domainType, const QByteArray &entityId, const QByteArray &property, const QVariant &expectedValue) 137KAsync::Job<void> DummyResource::inspect(int inspectionType, const QByteArray &inspectionId, const QByteArray &domainType, const QByteArray &entityId, const QByteArray &property, const QVariant &expectedValue)
@@ -151,20 +151,20 @@ KAsync::Job<void> DummyResource::inspect(int inspectionType, const QByteArray &i
151} 151}
152 152
153DummyResourceFactory::DummyResourceFactory(QObject *parent) 153DummyResourceFactory::DummyResourceFactory(QObject *parent)
154 : Akonadi2::ResourceFactory(parent) 154 : Sink::ResourceFactory(parent)
155{ 155{
156 156
157} 157}
158 158
159Akonadi2::Resource *DummyResourceFactory::createResource(const QByteArray &instanceIdentifier) 159Sink::Resource *DummyResourceFactory::createResource(const QByteArray &instanceIdentifier)
160{ 160{
161 return new DummyResource(instanceIdentifier); 161 return new DummyResource(instanceIdentifier);
162} 162}
163 163
164void DummyResourceFactory::registerFacades(Akonadi2::FacadeFactory &factory) 164void DummyResourceFactory::registerFacades(Sink::FacadeFactory &factory)
165{ 165{
166 factory.registerFacade<Akonadi2::ApplicationDomain::Event, DummyResourceFacade>(PLUGIN_NAME); 166 factory.registerFacade<Sink::ApplicationDomain::Event, DummyResourceFacade>(PLUGIN_NAME);
167 factory.registerFacade<Akonadi2::ApplicationDomain::Mail, DummyResourceMailFacade>(PLUGIN_NAME); 167 factory.registerFacade<Sink::ApplicationDomain::Mail, DummyResourceMailFacade>(PLUGIN_NAME);
168 factory.registerFacade<Akonadi2::ApplicationDomain::Folder, DummyResourceFolderFacade>(PLUGIN_NAME); 168 factory.registerFacade<Sink::ApplicationDomain::Folder, DummyResourceFolderFacade>(PLUGIN_NAME);
169} 169}
170 170