diff options
Diffstat (limited to 'examples/dummyresource/resourcefactory.cpp')
-rw-r--r-- | examples/dummyresource/resourcefactory.cpp | 56 |
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 | ||
46 | DummyResource::DummyResource(const QByteArray &instanceIdentifier, const QSharedPointer<Akonadi2::Pipeline> &pipeline) | 46 | DummyResource::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 | ||
60 | Akonadi2::ApplicationDomain::Event::Ptr DummyResource::createEvent(const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Akonadi2::Storage::Transaction &transaction) | 60 | Sink::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 | ||
71 | Akonadi2::ApplicationDomain::Mail::Ptr DummyResource::createMail(const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Akonadi2::Storage::Transaction &transaction) | 71 | Sink::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 | ||
84 | Akonadi2::ApplicationDomain::Folder::Ptr DummyResource::createFolder(const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Akonadi2::Storage::Transaction &transaction) | 84 | Sink::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 | ||
96 | void 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) | 96 | void 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 | ||
106 | KAsync::Job<void> DummyResource::synchronizeWithSource(Akonadi2::Storage &mainStore, Akonadi2::Storage &synchronizationStore) | 106 | KAsync::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 | ||
125 | KAsync::Job<void> DummyResource::replay(Akonadi2::Storage &synchronizationStore, const QByteArray &type, const QByteArray &key, const QByteArray &value) | 125 | KAsync::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, | |||
131 | void DummyResource::removeFromDisk(const QByteArray &instanceIdentifier) | 131 | void 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 | ||
137 | KAsync::Job<void> DummyResource::inspect(int inspectionType, const QByteArray &inspectionId, const QByteArray &domainType, const QByteArray &entityId, const QByteArray &property, const QVariant &expectedValue) | 137 | KAsync::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 | ||
153 | DummyResourceFactory::DummyResourceFactory(QObject *parent) | 153 | DummyResourceFactory::DummyResourceFactory(QObject *parent) |
154 | : Akonadi2::ResourceFactory(parent) | 154 | : Sink::ResourceFactory(parent) |
155 | { | 155 | { |
156 | 156 | ||
157 | } | 157 | } |
158 | 158 | ||
159 | Akonadi2::Resource *DummyResourceFactory::createResource(const QByteArray &instanceIdentifier) | 159 | Sink::Resource *DummyResourceFactory::createResource(const QByteArray &instanceIdentifier) |
160 | { | 160 | { |
161 | return new DummyResource(instanceIdentifier); | 161 | return new DummyResource(instanceIdentifier); |
162 | } | 162 | } |
163 | 163 | ||
164 | void DummyResourceFactory::registerFacades(Akonadi2::FacadeFactory &factory) | 164 | void 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 | ||