From 460c52653ab0dcca6f19a4f492ed2c5e4e963ab0 Mon Sep 17 00:00:00 2001 From: toma Date: Wed, 25 Nov 2009 17:56:58 +0000 Subject: Copy the KDE 3.5 branch to branches/trinity for new KDE 3.5 features. BUG:215923 git-svn-id: svn://anonsvn.kde.org/home/kde/branches/trinity/kdepim@1054174 283d02a7-25f6-0310-bc7c-ecb5cbfe19da --- kmail/listjob.cpp | 255 ++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 255 insertions(+) create mode 100644 kmail/listjob.cpp (limited to 'kmail/listjob.cpp') diff --git a/kmail/listjob.cpp b/kmail/listjob.cpp new file mode 100644 index 000000000..341e934a5 --- /dev/null +++ b/kmail/listjob.cpp @@ -0,0 +1,255 @@ +/* + * Copyright (c) 2004 Carsten Burghardt + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; version 2 of the License + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. + * + * In addition, as a special exception, the copyright holders give + * permission to link the code of this program with any edition of + * the Qt library by Trolltech AS, Norway (or with modified versions + * of Qt that use the same license as Qt), and distribute linked + * combinations including the two. You must obey the GNU General + * Public License in all respects for all of the code used other than + * Qt. If you modify this file, you may extend this exception to + * your version of the file, but you are not obligated to do so. If + * you do not wish to do so, delete this exception statement from + * your version. + */ + +#include "listjob.h" +#include "kmessagebox.h" +#include "kmfolderimap.h" +#include "kmfoldercachedimap.h" +#include "kmacctimap.h" +#include "kmacctcachedimap.h" +#include "folderstorage.h" +#include "kmfolder.h" +#include "progressmanager.h" +using KPIM::ProgressManager; + +#include +#include +#include +#include +#include +#include + +#include + +#include + +using namespace KMail; + +ListJob::ListJob( ImapAccountBase* account, ImapAccountBase::ListType type, + FolderStorage* storage, const QString& path, bool complete, + KPIM::ProgressItem* item ) + : FolderJob( 0, tOther, (storage ? storage->folder() : 0) ), + mStorage( storage ), mAccount( account ), mType( type ), + mComplete( complete ), + mHonorLocalSubscription( false ), mPath( path ), + mParentProgressItem( item ) +{ +} + +ListJob::~ListJob() +{ +} + +void ListJob::execute() +{ + if ( mAccount->makeConnection() == ImapAccountBase::Error ) + { + kdWarning(5006) << "ListJob - got no connection" << endl; + delete this; + return; + } else if ( mAccount->makeConnection() == ImapAccountBase::Connecting ) + { + // We'll wait for the connectionResult signal from the account. + kdDebug(5006) << "ListJob - waiting for connection" << endl; + connect( mAccount, SIGNAL( connectionResult(int, const QString&) ), + this, SLOT( slotConnectionResult(int, const QString&) ) ); + return; + } + // this is needed until we have a common base class for d(imap) + if ( mPath.isEmpty() ) + { + if ( mStorage && mStorage->folderType() == KMFolderTypeImap ) { + mPath = static_cast(mStorage)->imapPath(); + } else if ( mStorage && mStorage->folderType() == KMFolderTypeCachedImap ) { + mPath = static_cast(mStorage)->imapPath(); + } else { + kdError(5006) << "ListJob - no valid path and no folder given" << endl; + delete this; + return; + } + } + if ( mNamespace.isEmpty() && mStorage ) + { + mNamespace = mAccount->namespaceForFolder( mStorage ); + } + // create jobData + ImapAccountBase::jobData jd; + jd.total = 1; jd.done = 0; + jd.cancellable = true; + jd.parent = mDestFolder; + jd.onlySubscribed = ( mType == ImapAccountBase::ListSubscribed || + mType == ImapAccountBase::ListSubscribedNoCheck || + mType == ImapAccountBase::ListFolderOnlySubscribed ); + jd.path = mPath; + jd.curNamespace = mNamespace; + if ( mParentProgressItem ) + { + QString escapedStatus = mDestFolder ? QStyleSheet::escape( mDestFolder->prettyURL() ) + : QString::null; + jd.progressItem = ProgressManager::createProgressItem( + mParentProgressItem, + "ListDir" + ProgressManager::getUniqueID(), + escapedStatus, + i18n("retrieving folders"), + false, + mAccount->useSSL() || mAccount->useTLS() ); + mParentProgressItem->setStatus( escapedStatus ); + } + + // make the URL + QString ltype = "LIST"; + if ( mType == ImapAccountBase::ListSubscribed || + mType == ImapAccountBase::ListFolderOnlySubscribed ) + ltype = "LSUB"; + else if ( mType == ImapAccountBase::ListSubscribedNoCheck ) + ltype = "LSUBNOCHECK"; + + QString section; + if ( mComplete ) + section = ";SECTION=COMPLETE"; + else if ( mType == ImapAccountBase::ListFolderOnly || + mType == ImapAccountBase::ListFolderOnlySubscribed ) + section = ";SECTION=FOLDERONLY"; + + KURL url = mAccount->getUrl(); + url.setPath( mPath + + ";TYPE=" + ltype + + section ); + // go + //kdDebug(5006) << "start listjob for " << url.path() << endl; + KIO::SimpleJob *job = KIO::listDir( url, false ); + KIO::Scheduler::assignJobToSlave( mAccount->slave(), job ); + mAccount->insertJob( job, jd ); + connect( job, SIGNAL(result(KIO::Job *)), + this, SLOT(slotListResult(KIO::Job *)) ); + connect( job, SIGNAL(entries(KIO::Job *, const KIO::UDSEntryList &)), + this, SLOT(slotListEntries(KIO::Job *, const KIO::UDSEntryList &)) ); +} + +void ListJob::slotConnectionResult( int errorCode, const QString& errorMsg ) +{ + Q_UNUSED( errorMsg ); + if ( !errorCode ) + execute(); + else { + if ( mParentProgressItem ) + mParentProgressItem->setComplete(); + delete this; + } +} + +void ListJob::slotListResult( KIO::Job* job ) +{ + ImapAccountBase::JobIterator it = mAccount->findJob( job ); + if ( it == mAccount->jobsEnd() ) + { + delete this; + return; + } + if ( job->error() ) + { + mAccount->handleJobError( job, + i18n( "Error while listing folder %1: " ).arg((*it).path), + true ); + } else + { + // transport the information, include the jobData + emit receivedFolders( mSubfolderNames, mSubfolderPaths, + mSubfolderMimeTypes, mSubfolderAttributes, *it ); + mAccount->removeJob( it ); + } + delete this; +} + +void ListJob::slotListEntries( KIO::Job* job, const KIO::UDSEntryList& uds ) +{ + ImapAccountBase::JobIterator it = mAccount->findJob( job ); + if ( it == mAccount->jobsEnd() ) + { + delete this; + return; + } + if( (*it).progressItem ) + (*it).progressItem->setProgress( 50 ); + QString name; + KURL url; + QString mimeType; + QString attributes; + for ( KIO::UDSEntryList::ConstIterator udsIt = uds.begin(); + udsIt != uds.end(); udsIt++ ) + { + mimeType = QString::null; + attributes = QString::null; + for ( KIO::UDSEntry::ConstIterator eIt = (*udsIt).begin(); + eIt != (*udsIt).end(); eIt++ ) + { + // get the needed information + if ( (*eIt).m_uds == KIO::UDS_NAME ) + name = (*eIt).m_str; + else if ( (*eIt).m_uds == KIO::UDS_URL ) + url = KURL((*eIt).m_str, 106); // utf-8 + else if ( (*eIt).m_uds == KIO::UDS_MIME_TYPE ) + mimeType = (*eIt).m_str; + else if ( (*eIt).m_uds == KIO::UDS_EXTRA ) + attributes = (*eIt).m_str; + } + if ( (mimeType == "inode/directory" || mimeType == "message/digest" + || mimeType == "message/directory") + && name != ".." && (mAccount->hiddenFolders() || name.at(0) != '.') ) + { + if ( mHonorLocalSubscription && mAccount->onlyLocallySubscribedFolders() + && !mAccount->locallySubscribedTo( url.path() ) ) { + continue; + } + + // Some servers send _lots_ of duplicates + // This check is too slow for huge lists + if ( mSubfolderPaths.count() > 100 || + mSubfolderPaths.findIndex(url.path()) == -1 ) + { + mSubfolderNames.append( name ); + mSubfolderPaths.append( url.path() ); + mSubfolderMimeTypes.append( mimeType ); + mSubfolderAttributes.append( attributes ); + } + } + } +} + + +void KMail::ListJob::setHonorLocalSubscription( bool value ) +{ + mHonorLocalSubscription = value; +} + +bool KMail::ListJob::honorLocalSubscription() const +{ + return mHonorLocalSubscription; +} + +#include "listjob.moc" -- cgit v1.2.1