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/korn/tdeio_subjects.cpp

177 lines
4.6 KiB

/*
* Copyright (C) 2004, Mart Kelder (mart.kde@hccnet.nl)
*
* 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; either version 2 of the License, or
* (at your option) any later version.
*
* 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
*/
#include "tdeio_subjects.h"
#include "tdeio.h"
#include "tdeio_single_subject.h"
#include "tdeio_proto.h"
#include "mailsubject.h"
#include <tdeio/global.h>
#include <tdeio/scheduler.h>
#include <kdebug.h>
#include <tqptrlist.h>
#include <tqvaluelist.h>
#include <tqstring.h>
TDEIO_Subjects::TDEIO_Subjects( TQObject * parent, const char * name )
: TQObject( parent, name ),
_protocol( 0 ),
_slave( 0 ),
_valid( true )
{
_jobs = new TQPtrList<TDEIO_Single_Subject>;
_kurl = new KURL;
_metadata = new TDEIO::MetaData;
_jobs->setAutoDelete( true );
}
TDEIO_Subjects::~TDEIO_Subjects( )
{
delete _jobs;
delete _kurl;
delete _metadata;
_protocol = 0;
}
void TDEIO_Subjects::doReadSubjects( KKioDrop *drop )
{
TQValueList<KKioDrop::FileInfo>::ConstIterator it;
TQValueList<KKioDrop::FileInfo>::ConstIterator end_it = drop->_mailurls->end();
_tdeio = drop;
_protocol = _tdeio->_protocol;
*_kurl = *_tdeio->_kurl;
*_metadata = *_tdeio->_metadata;
if( _jobs->count() > 0 )
kdWarning() << i18n( "Already a slave pending." ) << endl;
_jobs->clear( );
//Open connection
getConnection( );
//Open jobs for easy item in the list
for( it = _tdeio->_mailurls->begin(); it != end_it; it++ )
startJob( (*it).name, (*it).size );
//close connection for trivial situations (empty list)
disConnect( true );
//passing number of subjects for progress bar.
_tdeio->emitReadSubjectsTotalSteps( _jobs->count() );
}
void TDEIO_Subjects::getConnection( )
{
KURL kurl = *_kurl;
TDEIO::MetaData metadata = *_metadata;
if( _slave )
{
TDEIO::Scheduler::disconnectSlave( _slave );
_slave = 0;
}
if( _protocol->connectionBased( ) )
{
_protocol->readSubjectConnectKURL( kurl, metadata );
if( kurl.port() == 0 )
kurl.setPort( _protocol->defaultPort( _tdeio->_ssl ) );
if( ! ( _slave = TDEIO::Scheduler::getConnectedSlave( kurl, metadata ) ) )
{
kdWarning() << i18n( "Not able to open a tdeio-slave for %1." ).arg( _protocol->configName() );
_tdeio->emitShowPassivePopup( i18n( "Not able to open a tdeio-slave for %1." ).arg( _protocol->configName() ) );
_valid = false;
_tdeio->emitValidChanged();
_slave = 0;
_tdeio->emitReadSubjectsReady( false );
return;
}
}
}
void TDEIO_Subjects::startJob( const TQString &name, const long size )
{
KURL kurl = *_kurl;
TDEIO::MetaData metadata = *_metadata;
TDEIO_Single_Subject *subject;
kurl = name;
_protocol->readSubjectKURL( kurl, metadata );
if( kurl.port() == 0 )
kurl.setPort( _protocol->defaultPort( _tdeio->_ssl ) );
subject = new TDEIO_Single_Subject( this, name.latin1(), kurl, metadata, _protocol, _slave, name, size );
connect( subject, TQ_SIGNAL( readSubject( KornMailSubject* ) ), this, TQ_SLOT( slotReadSubject( KornMailSubject* ) ) );
connect( subject, TQ_SIGNAL( finished( TDEIO_Single_Subject* ) ), this, TQ_SLOT( slotFinished( TDEIO_Single_Subject* ) ) );
_jobs->append( subject );
}
void TDEIO_Subjects::disConnect( bool result )
{
if( _jobs->isEmpty() )
{
if( _slave )
{
TDEIO::Scheduler::disconnectSlave( _slave );
_slave = 0;
}
_tdeio->emitReadSubjectsReady( result );
}
}
void TDEIO_Subjects::cancelled( )
{
_jobs->clear();
//_slave died in cancelJob with is by called from the destructor of TDEIO_Single_Subject,
//withs is by called by _jobs->clear because autoRemove equals true.
_slave = 0;
disConnect( false );
}
void TDEIO_Subjects::slotReadSubject( KornMailSubject* subject )
{
_valid = true;
_tdeio->emitValidChanged();
subject->setMailDrop( _tdeio );
_tdeio->emitReadSubjectsRead( subject );
}
void TDEIO_Subjects::slotFinished( TDEIO_Single_Subject* item )
{
//Remove sender.... I didn't know of the computer gonna like me, but it seems he does :)
_jobs->remove( item );
_tdeio->emitReadSubjectsProgress( _jobs->count( ) );
disConnect( true ); //Only works when all jobs are finished.
}
#include "tdeio_subjects.moc"