diff options
Diffstat (limited to 'examples/mailtransportresource/mailtransportresource.cpp')
-rw-r--r-- | examples/mailtransportresource/mailtransportresource.cpp | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/examples/mailtransportresource/mailtransportresource.cpp b/examples/mailtransportresource/mailtransportresource.cpp index f215643..75d9898 100644 --- a/examples/mailtransportresource/mailtransportresource.cpp +++ b/examples/mailtransportresource/mailtransportresource.cpp | |||
@@ -54,7 +54,7 @@ public: | |||
54 | 54 | ||
55 | KAsync::Job<void> send(const ApplicationDomain::Mail &mail, const MailtransportResource::Settings &settings) | 55 | KAsync::Job<void> send(const ApplicationDomain::Mail &mail, const MailtransportResource::Settings &settings) |
56 | { | 56 | { |
57 | return KAsync::start<void>([=] { | 57 | return KAsync::start([=] { |
58 | if (!syncStore().readValue(mail.identifier()).isEmpty()) { | 58 | if (!syncStore().readValue(mail.identifier()).isEmpty()) { |
59 | SinkLog() << "Mail is already sent: " << mail.identifier(); | 59 | SinkLog() << "Mail is already sent: " << mail.identifier(); |
60 | return KAsync::null(); | 60 | return KAsync::null(); |
@@ -105,9 +105,8 @@ public: | |||
105 | query.filter<ApplicationDomain::SinkResource::Account>(resource.getAccount()); | 105 | query.filter<ApplicationDomain::SinkResource::Account>(resource.getAccount()); |
106 | return Store::fetchOne<ApplicationDomain::SinkResource>(query) | 106 | return Store::fetchOne<ApplicationDomain::SinkResource>(query) |
107 | .then([this, modifiedMail](const ApplicationDomain::SinkResource &resource) { | 107 | .then([this, modifiedMail](const ApplicationDomain::SinkResource &resource) { |
108 | //First modify the mail to have the sent property set to true | 108 | //Modify the mail to have the sent property set to true, and move it to the new resource. |
109 | modify(modifiedMail, resource.identifier(), true); | 109 | modify(modifiedMail, resource.identifier(), true); |
110 | return KAsync::null<void>(); | ||
111 | }); | 110 | }); |
112 | }); | 111 | }); |
113 | } | 112 | } |
@@ -117,12 +116,10 @@ public: | |||
117 | return KAsync::start<void>([this]() { | 116 | return KAsync::start<void>([this]() { |
118 | QList<ApplicationDomain::Mail> toSend; | 117 | QList<ApplicationDomain::Mail> toSend; |
119 | SinkLog() << "Looking for mails to send."; | 118 | SinkLog() << "Looking for mails to send."; |
120 | store().readAll<ApplicationDomain::Mail>([&](const ApplicationDomain::Mail &mail) -> bool { | 119 | store().readAll<ApplicationDomain::Mail>([&](const ApplicationDomain::Mail &mail) { |
121 | SinkTrace() << "Found mail: " << mail.identifier(); | ||
122 | if (!mail.getSent()) { | 120 | if (!mail.getSent()) { |
123 | toSend << mail; | 121 | toSend << mail; |
124 | } | 122 | } |
125 | return true; | ||
126 | }); | 123 | }); |
127 | SinkLog() << "Found " << toSend.size() << " mails to send"; | 124 | SinkLog() << "Found " << toSend.size() << " mails to send"; |
128 | auto job = KAsync::null<void>(); | 125 | auto job = KAsync::null<void>(); |