diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-10-05 22:42:53 +0200 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-10-05 22:42:53 +0200 |
commit | 5fa8608e9877eab40336a60ed8ed979aaf3cfbd0 (patch) | |
tree | b13061569d1c9d99f58edd2c31c1c6ba3f86618c /framework/domain/actions/sinkactions.cpp | |
parent | 268eb7207b955bb92e4ae2572996877e7f837325 (diff) | |
download | kube-5fa8608e9877eab40336a60ed8ed979aaf3cfbd0.tar.gz kube-5fa8608e9877eab40336a60ed8ed979aaf3cfbd0.zip |
Adapted to new API
Diffstat (limited to 'framework/domain/actions/sinkactions.cpp')
-rw-r--r-- | framework/domain/actions/sinkactions.cpp | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/framework/domain/actions/sinkactions.cpp b/framework/domain/actions/sinkactions.cpp index e79e79c9..cc8d324e 100644 --- a/framework/domain/actions/sinkactions.cpp +++ b/framework/domain/actions/sinkactions.cpp | |||
@@ -85,7 +85,7 @@ static ActionHandlerHelper synchronizeHandler("org.kde.kube.actions.synchronize" | |||
85 | [](Context *context) { | 85 | [](Context *context) { |
86 | if (auto folder = context->property("folder").value<Folder::Ptr>()) { | 86 | if (auto folder = context->property("folder").value<Folder::Ptr>()) { |
87 | SinkLog() << "Synchronizing resource " << folder->resourceInstanceIdentifier(); | 87 | SinkLog() << "Synchronizing resource " << folder->resourceInstanceIdentifier(); |
88 | Store::synchronize(Query::ResourceFilter(folder->resourceInstanceIdentifier())).exec(); | 88 | Store::synchronize(Query().resourceFilter(folder->resourceInstanceIdentifier())).exec(); |
89 | } else { | 89 | } else { |
90 | SinkLog() << "Synchronizing all"; | 90 | SinkLog() << "Synchronizing all"; |
91 | Store::synchronize(Query()).exec(); | 91 | Store::synchronize(Query()).exec(); |
@@ -106,7 +106,7 @@ static ActionHandlerHelper sendMailHandler("org.kde.kube.actions.sendmail", | |||
106 | 106 | ||
107 | Query query; | 107 | Query query; |
108 | query.containsFilter<ApplicationDomain::SinkResource::Capabilities>(ApplicationDomain::ResourceCapabilities::Mail::transport); | 108 | query.containsFilter<ApplicationDomain::SinkResource::Capabilities>(ApplicationDomain::ResourceCapabilities::Mail::transport); |
109 | query.filter(ApplicationDomain::SinkAccount(accountId)); | 109 | query.filter<SinkResource::Account>(accountId); |
110 | Store::fetchAll<ApplicationDomain::SinkResource>(query) | 110 | Store::fetchAll<ApplicationDomain::SinkResource>(query) |
111 | .then<void, QList<ApplicationDomain::SinkResource::Ptr>>([=](const QList<ApplicationDomain::SinkResource::Ptr> &resources) -> KAsync::Job<void> { | 111 | .then<void, QList<ApplicationDomain::SinkResource::Ptr>>([=](const QList<ApplicationDomain::SinkResource::Ptr> &resources) -> KAsync::Job<void> { |
112 | if (!resources.isEmpty()) { | 112 | if (!resources.isEmpty()) { |
@@ -129,7 +129,7 @@ static ActionHandlerHelper saveAsDraft("org.kde.kube.actions.save-as-draft", | |||
129 | return !accountId.isEmpty() && message; | 129 | return !accountId.isEmpty() && message; |
130 | }, | 130 | }, |
131 | ActionHandlerHelper::JobHandler([](Context *context) -> KAsync::Job<void> { | 131 | ActionHandlerHelper::JobHandler([](Context *context) -> KAsync::Job<void> { |
132 | SinkWarning() << "executing save as draft"; | 132 | SinkLog() << "Executing the save-as-draft action"; |
133 | const auto accountId = context->property("accountId").value<QByteArray>(); | 133 | const auto accountId = context->property("accountId").value<QByteArray>(); |
134 | const auto message = context->property("message").value<KMime::Message::Ptr>(); | 134 | const auto message = context->property("message").value<KMime::Message::Ptr>(); |
135 | auto existingMail = context->property("existingMail").value<Mail>(); | 135 | auto existingMail = context->property("existingMail").value<Mail>(); |
@@ -140,18 +140,18 @@ static ActionHandlerHelper saveAsDraft("org.kde.kube.actions.save-as-draft", | |||
140 | 140 | ||
141 | if (existingMail.identifier().isEmpty()) { | 141 | if (existingMail.identifier().isEmpty()) { |
142 | Query query; | 142 | Query query; |
143 | query.containsFilter<ApplicationDomain::SinkResource::Capabilities>(ApplicationDomain::ResourceCapabilities::Mail::drafts); | 143 | query.containsFilter<SinkResource::Capabilities>(ApplicationDomain::ResourceCapabilities::Mail::drafts); |
144 | query.filter(ApplicationDomain::SinkAccount(accountId)); | 144 | query.filter<SinkResource::Account>(accountId); |
145 | return Store::fetchOne<SinkResource>(query) | 145 | return Store::fetchOne<SinkResource>(query) |
146 | .then<void, SinkResource>([=](const SinkResource &resource) -> KAsync::Job<void> { | 146 | .then<void, SinkResource>([=](const SinkResource &resource) -> KAsync::Job<void> { |
147 | Mail mail(resource.identifier()); | 147 | Mail mail(resource.identifier()); |
148 | mail.setProperty("draft", true); | 148 | mail.setDraft(true); |
149 | mail.setBlobProperty("mimeMessage", message->encodedContent()); | 149 | mail.setMimeMessage(message->encodedContent()); |
150 | return Store::create(mail); | 150 | return Store::create(mail); |
151 | }); | 151 | }); |
152 | } else { | 152 | } else { |
153 | SinkWarning() << "Modifying an existing mail" << existingMail.identifier(); | 153 | SinkWarning() << "Modifying an existing mail" << existingMail.identifier(); |
154 | existingMail.setBlobProperty("mimeMessage", message->encodedContent()); | 154 | existingMail.setMimeMessage(message->encodedContent()); |
155 | return Store::modify(existingMail); | 155 | return Store::modify(existingMail); |
156 | } | 156 | } |
157 | }) | 157 | }) |