You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
tdepim/kmail/listjob.cpp

256 lines
8.1 KiB

/*
* Copyright (c) 2004 Carsten Burghardt <burghardt@kde.org>
*
* 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 TQt library by Trolltech AS, Norway (or with modified versions
* of TQt that use the same license as TQt), 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
* TQt. 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 <kdebug.h>
#include <kurl.h>
#include <kio/scheduler.h>
#include <kio/job.h>
#include <kio/global.h>
#include <klocale.h>
#include <tqstylesheet.h>
#include <stdlib.h>
using namespace KMail;
ListJob::ListJob( ImapAccountBase* account, ImapAccountBase::ListType type,
FolderStorage* storage, const TQString& 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, TQT_SIGNAL( connectionResult(int, const TQString&) ),
this, TQT_SLOT( slotConnectionResult(int, const TQString&) ) );
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<KMFolderImap*>(mStorage)->imapPath();
} else if ( mStorage && mStorage->folderType() == KMFolderTypeCachedImap ) {
mPath = static_cast<KMFolderCachedImap*>(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 )
{
TQString escapedStatus = mDestFolder ? TQStyleSheet::escape( mDestFolder->prettyURL() )
: TQString();
jd.progressItem = ProgressManager::createProgressItem(
mParentProgressItem,
"ListDir" + ProgressManager::getUniqueID(),
escapedStatus,
i18n("retrieving folders"),
false,
mAccount->useSSL() || mAccount->useTLS() );
mParentProgressItem->setStatus( escapedStatus );
}
// make the URL
TQString ltype = "LIST";
if ( mType == ImapAccountBase::ListSubscribed ||
mType == ImapAccountBase::ListFolderOnlySubscribed )
ltype = "LSUB";
else if ( mType == ImapAccountBase::ListSubscribedNoCheck )
ltype = "LSUBNOCHECK";
TQString 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;
TDEIO::SimpleJob *job = TDEIO::listDir( url, false );
TDEIO::Scheduler::assignJobToSlave( mAccount->slave(), job );
mAccount->insertJob( job, jd );
connect( job, TQT_SIGNAL(result(TDEIO::Job *)),
this, TQT_SLOT(slotListResult(TDEIO::Job *)) );
connect( job, TQT_SIGNAL(entries(TDEIO::Job *, const TDEIO::UDSEntryList &)),
this, TQT_SLOT(slotListEntries(TDEIO::Job *, const TDEIO::UDSEntryList &)) );
}
void ListJob::slotConnectionResult( int errorCode, const TQString& errorMsg )
{
Q_UNUSED( errorMsg );
if ( !errorCode )
execute();
else {
if ( mParentProgressItem )
mParentProgressItem->setComplete();
delete this;
}
}
void ListJob::slotListResult( TDEIO::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( TDEIO::Job* job, const TDEIO::UDSEntryList& uds )
{
ImapAccountBase::JobIterator it = mAccount->findJob( job );
if ( it == mAccount->jobsEnd() )
{
delete this;
return;
}
if( (*it).progressItem )
(*it).progressItem->setProgress( 50 );
TQString name;
KURL url;
TQString mimeType;
TQString attributes;
for ( TDEIO::UDSEntryList::ConstIterator udsIt = uds.begin();
udsIt != uds.end(); udsIt++ )
{
mimeType = TQString();
attributes = TQString();
for ( TDEIO::UDSEntry::ConstIterator eIt = (*udsIt).begin();
eIt != (*udsIt).end(); eIt++ )
{
// get the needed information
if ( (*eIt).m_uds == TDEIO::UDS_NAME )
name = (*eIt).m_str;
else if ( (*eIt).m_uds == TDEIO::UDS_URL )
url = KURL((*eIt).m_str, 106); // utf-8
else if ( (*eIt).m_uds == TDEIO::UDS_MIME_TYPE )
mimeType = (*eIt).m_str;
else if ( (*eIt).m_uds == TDEIO::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"