diff options
Diffstat (limited to 'examples/imapresource/imapresource.cpp')
-rw-r--r-- | examples/imapresource/imapresource.cpp | 40 |
1 files changed, 20 insertions, 20 deletions
diff --git a/examples/imapresource/imapresource.cpp b/examples/imapresource/imapresource.cpp index 535a35c..ed4b7f8 100644 --- a/examples/imapresource/imapresource.cpp +++ b/examples/imapresource/imapresource.cpp | |||
@@ -100,7 +100,7 @@ public: | |||
100 | QByteArray createFolder(const Imap::Folder &f) | 100 | QByteArray createFolder(const Imap::Folder &f) |
101 | { | 101 | { |
102 | const auto parentFolderRid = parentRid(f); | 102 | const auto parentFolderRid = parentRid(f); |
103 | SinkTrace() << "Creating folder: " << f.name() << parentFolderRid; | 103 | SinkTraceCtx(mLogCtx) << "Creating folder: " << f.name() << parentFolderRid; |
104 | 104 | ||
105 | const auto remoteId = folderRid(f); | 105 | const auto remoteId = folderRid(f); |
106 | Sink::ApplicationDomain::Folder folder; | 106 | Sink::ApplicationDomain::Folder folder; |
@@ -123,7 +123,7 @@ public: | |||
123 | 123 | ||
124 | void synchronizeFolders(const QVector<Folder> &folderList) | 124 | void synchronizeFolders(const QVector<Folder> &folderList) |
125 | { | 125 | { |
126 | SinkTrace() << "Found folders " << folderList.size(); | 126 | SinkTraceCtx(mLogCtx) << "Found folders " << folderList.size(); |
127 | 127 | ||
128 | scanForRemovals(ENTITY_TYPE_FOLDER, | 128 | scanForRemovals(ENTITY_TYPE_FOLDER, |
129 | [&folderList](const QByteArray &remoteId) -> bool { | 129 | [&folderList](const QByteArray &remoteId) -> bool { |
@@ -164,14 +164,14 @@ public: | |||
164 | { | 164 | { |
165 | auto time = QSharedPointer<QTime>::create(); | 165 | auto time = QSharedPointer<QTime>::create(); |
166 | time->start(); | 166 | time->start(); |
167 | SinkTrace() << "Importing new mail." << folderRid; | 167 | SinkTraceCtx(mLogCtx) << "Importing new mail." << folderRid; |
168 | 168 | ||
169 | const auto folderLocalId = syncStore().resolveRemoteId(ENTITY_TYPE_FOLDER, folderRid); | 169 | const auto folderLocalId = syncStore().resolveRemoteId(ENTITY_TYPE_FOLDER, folderRid); |
170 | 170 | ||
171 | const auto remoteId = assembleMailRid(folderLocalId, message.uid); | 171 | const auto remoteId = assembleMailRid(folderLocalId, message.uid); |
172 | 172 | ||
173 | Q_ASSERT(message.msg); | 173 | Q_ASSERT(message.msg); |
174 | SinkTrace() << "Found a mail " << remoteId << message.msg->subject(true)->asUnicodeString() << message.flags; | 174 | SinkTraceCtx(mLogCtx) << "Found a mail " << remoteId << message.msg->subject(true)->asUnicodeString() << message.flags; |
175 | 175 | ||
176 | auto mail = Sink::ApplicationDomain::Mail::create(mResourceInstanceIdentifier); | 176 | auto mail = Sink::ApplicationDomain::Mail::create(mResourceInstanceIdentifier); |
177 | mail.setFolder(folderLocalId); | 177 | mail.setFolder(folderLocalId); |
@@ -181,7 +181,7 @@ public: | |||
181 | 181 | ||
182 | createOrModify(ENTITY_TYPE_MAIL, remoteId, mail); | 182 | createOrModify(ENTITY_TYPE_MAIL, remoteId, mail); |
183 | // const auto elapsed = time->elapsed(); | 183 | // const auto elapsed = time->elapsed(); |
184 | // SinkTrace() << "Synchronized " << count << " mails in " << folderRid << Sink::Log::TraceTime(elapsed) << " " << elapsed/qMax(count, 1) << " [ms/mail]"; | 184 | // SinkTraceCtx(mLogCtx) << "Synchronized " << count << " mails in " << folderRid << Sink::Log::TraceTime(elapsed) << " " << elapsed/qMax(count, 1) << " [ms/mail]"; |
185 | } | 185 | } |
186 | 186 | ||
187 | void synchronizeRemovals(const QByteArray &folderRid, const QSet<qint64> &messages) | 187 | void synchronizeRemovals(const QByteArray &folderRid, const QSet<qint64> &messages) |
@@ -194,7 +194,7 @@ public: | |||
194 | return; | 194 | return; |
195 | } | 195 | } |
196 | 196 | ||
197 | SinkTrace() << "Finding removed mail: " << folderLocalId << " remoteId: " << folderRid; | 197 | SinkTraceCtx(mLogCtx) << "Finding removed mail: " << folderLocalId << " remoteId: " << folderRid; |
198 | 198 | ||
199 | int count = 0; | 199 | int count = 0; |
200 | 200 | ||
@@ -667,11 +667,11 @@ public: | |||
667 | if (!folder.getParent().isEmpty()) { | 667 | if (!folder.getParent().isEmpty()) { |
668 | parentFolder = syncStore().resolveLocalId(ENTITY_TYPE_FOLDER, folder.getParent()); | 668 | parentFolder = syncStore().resolveLocalId(ENTITY_TYPE_FOLDER, folder.getParent()); |
669 | } | 669 | } |
670 | SinkTrace() << "Creating a new folder: " << parentFolder << folder.getName(); | 670 | SinkTraceCtx(mLogCtx) << "Creating a new folder: " << parentFolder << folder.getName(); |
671 | auto rid = QSharedPointer<QByteArray>::create(); | 671 | auto rid = QSharedPointer<QByteArray>::create(); |
672 | auto createFolder = login.then(imap->createSubfolder(parentFolder, folder.getName())) | 672 | auto createFolder = login.then(imap->createSubfolder(parentFolder, folder.getName())) |
673 | .then([imap, rid](const QString &createdFolder) { | 673 | .then([this, imap, rid](const QString &createdFolder) { |
674 | SinkTrace() << "Finished creating a new folder: " << createdFolder; | 674 | SinkTraceCtx(mLogCtx) << "Finished creating a new folder: " << createdFolder; |
675 | *rid = createdFolder.toUtf8(); | 675 | *rid = createdFolder.toUtf8(); |
676 | }); | 676 | }); |
677 | if (folder.getSpecialPurpose().isEmpty()) { | 677 | if (folder.getSpecialPurpose().isEmpty()) { |
@@ -687,19 +687,19 @@ public: | |||
687 | specialPurposeFolders->insert(SpecialPurpose::getSpecialPurposeType(folder.name()), folder.path()); | 687 | specialPurposeFolders->insert(SpecialPurpose::getSpecialPurposeType(folder.name()), folder.path()); |
688 | }; | 688 | }; |
689 | })) | 689 | })) |
690 | .then([specialPurposeFolders, folder, imap, parentFolder, rid]() -> KAsync::Job<void> { | 690 | .then([this, specialPurposeFolders, folder, imap, parentFolder, rid]() -> KAsync::Job<void> { |
691 | for (const auto &purpose : folder.getSpecialPurpose()) { | 691 | for (const auto &purpose : folder.getSpecialPurpose()) { |
692 | if (specialPurposeFolders->contains(purpose)) { | 692 | if (specialPurposeFolders->contains(purpose)) { |
693 | auto f = specialPurposeFolders->value(purpose); | 693 | auto f = specialPurposeFolders->value(purpose); |
694 | SinkTrace() << "Merging specialpurpose folder with: " << f << " with purpose: " << purpose; | 694 | SinkTraceCtx(mLogCtx) << "Merging specialpurpose folder with: " << f << " with purpose: " << purpose; |
695 | *rid = f.toUtf8(); | 695 | *rid = f.toUtf8(); |
696 | return KAsync::null<void>(); | 696 | return KAsync::null<void>(); |
697 | } | 697 | } |
698 | } | 698 | } |
699 | SinkTrace() << "No match found for merging, creating a new folder"; | 699 | SinkTraceCtx(mLogCtx) << "No match found for merging, creating a new folder"; |
700 | return imap->createSubfolder(parentFolder, folder.getName()) | 700 | return imap->createSubfolder(parentFolder, folder.getName()) |
701 | .then([imap, rid](const QString &createdFolder) { | 701 | .then([this, imap, rid](const QString &createdFolder) { |
702 | SinkTrace() << "Finished creating a new folder: " << createdFolder; | 702 | SinkTraceCtx(mLogCtx) << "Finished creating a new folder: " << createdFolder; |
703 | *rid = createdFolder.toUtf8(); | 703 | *rid = createdFolder.toUtf8(); |
704 | }); | 704 | }); |
705 | 705 | ||
@@ -710,18 +710,18 @@ public: | |||
710 | return mergeJob; | 710 | return mergeJob; |
711 | } | 711 | } |
712 | } else if (operation == Sink::Operation_Removal) { | 712 | } else if (operation == Sink::Operation_Removal) { |
713 | SinkTrace() << "Removing a folder: " << oldRemoteId; | 713 | SinkTraceCtx(mLogCtx) << "Removing a folder: " << oldRemoteId; |
714 | return login.then(imap->remove(oldRemoteId)) | 714 | return login.then(imap->remove(oldRemoteId)) |
715 | .then([oldRemoteId, imap] { | 715 | .then([this, oldRemoteId, imap] { |
716 | SinkTrace() << "Finished removing a folder: " << oldRemoteId; | 716 | SinkTraceCtx(mLogCtx) << "Finished removing a folder: " << oldRemoteId; |
717 | return QByteArray(); | 717 | return QByteArray(); |
718 | }); | 718 | }); |
719 | } else if (operation == Sink::Operation_Modification) { | 719 | } else if (operation == Sink::Operation_Modification) { |
720 | SinkTrace() << "Renaming a folder: " << oldRemoteId << folder.getName(); | 720 | SinkTraceCtx(mLogCtx) << "Renaming a folder: " << oldRemoteId << folder.getName(); |
721 | auto rid = QSharedPointer<QByteArray>::create(); | 721 | auto rid = QSharedPointer<QByteArray>::create(); |
722 | return login.then(imap->renameSubfolder(oldRemoteId, folder.getName())) | 722 | return login.then(imap->renameSubfolder(oldRemoteId, folder.getName())) |
723 | .then([imap, rid](const QString &createdFolder) { | 723 | .then([this, imap, rid](const QString &createdFolder) { |
724 | SinkTrace() << "Finished renaming a folder: " << createdFolder; | 724 | SinkTraceCtx(mLogCtx) << "Finished renaming a folder: " << createdFolder; |
725 | *rid = createdFolder.toUtf8(); | 725 | *rid = createdFolder.toUtf8(); |
726 | }) | 726 | }) |
727 | .then([rid] { | 727 | .then([rid] { |