summaryrefslogtreecommitdiffstats
path: root/examples/imapresource/imapresource.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2017-03-26 22:49:36 +0200
committerChristian Mollekopf <chrigi_1@fastmail.fm>2017-03-26 22:49:36 +0200
commit47e467e2c2453cfc72725013d71c4a0797f37733 (patch)
tree58ee11754490bc824d28d210d1416ded889c7532 /examples/imapresource/imapresource.cpp
parentb6593d8f8985018e492346d30c960a03ae41aec7 (diff)
downloadsink-47e467e2c2453cfc72725013d71c4a0797f37733.tar.gz
sink-47e467e2c2453cfc72725013d71c4a0797f37733.zip
SinkTraceCtx
Diffstat (limited to 'examples/imapresource/imapresource.cpp')
-rw-r--r--examples/imapresource/imapresource.cpp40
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] {