diff options
Diffstat (limited to 'korn/tdeio_subjects.cpp')
| -rw-r--r-- | korn/tdeio_subjects.cpp | 176 |
1 files changed, 176 insertions, 0 deletions
diff --git a/korn/tdeio_subjects.cpp b/korn/tdeio_subjects.cpp new file mode 100644 index 00000000..f40a86f6 --- /dev/null +++ b/korn/tdeio_subjects.cpp @@ -0,0 +1,176 @@ +/* + * 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 "kio_subjects.h" + +#include "kio.h" +#include "kio_single_subject.h" +#include "kio_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> + +KIO_Subjects::KIO_Subjects( TQObject * parent, const char * name ) + : TQObject( parent, name ), + _protocol( 0 ), + _slave( 0 ), + _valid( true ) +{ + _jobs = new TQPtrList<KIO_Single_Subject>; + _kurl = new KURL; + _metadata = new TDEIO::MetaData; + + _jobs->setAutoDelete( true ); +} + +KIO_Subjects::~KIO_Subjects( ) +{ + delete _jobs; + delete _kurl; + delete _metadata; + _protocol = 0; +} + +void KIO_Subjects::doReadSubjects( KKioDrop *drop ) +{ + TQValueList<KKioDrop::FileInfo>::ConstIterator it; + TQValueList<KKioDrop::FileInfo>::ConstIterator end_it = drop->_mailurls->end(); + + _kio = drop; + _protocol = _kio->_protocol; + *_kurl = *_kio->_kurl; + *_metadata = *_kio->_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 = _kio->_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. + _kio->emitReadSubjectsTotalSteps( _jobs->count() ); +} + +void KIO_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( _kio->_ssl ) ); + + if( ! ( _slave = TDEIO::Scheduler::getConnectedSlave( kurl, metadata ) ) ) + { + kdWarning() << i18n( "Not able to open a kio-slave for %1." ).arg( _protocol->configName() ); + _kio->emitShowPassivePopup( i18n( "Not able to open a kio-slave for %1." ).arg( _protocol->configName() ) ); + _valid = false; + _kio->emitValidChanged(); + _slave = 0; + _kio->emitReadSubjectsReady( false ); + return; + } + } +} + +void KIO_Subjects::startJob( const TQString &name, const long size ) +{ + KURL kurl = *_kurl; + TDEIO::MetaData metadata = *_metadata; + KIO_Single_Subject *subject; + + kurl = name; + + _protocol->readSubjectKURL( kurl, metadata ); + + if( kurl.port() == 0 ) + kurl.setPort( _protocol->defaultPort( _kio->_ssl ) ); + + subject = new KIO_Single_Subject( this, name.latin1(), kurl, metadata, _protocol, _slave, name, size ); + + connect( subject, TQT_SIGNAL( readSubject( KornMailSubject* ) ), this, TQT_SLOT( slotReadSubject( KornMailSubject* ) ) ); + connect( subject, TQT_SIGNAL( finished( KIO_Single_Subject* ) ), this, TQT_SLOT( slotFinished( KIO_Single_Subject* ) ) ); + + _jobs->append( subject ); +} + +void KIO_Subjects::disConnect( bool result ) +{ + if( _jobs->isEmpty() ) + { + if( _slave ) + { + TDEIO::Scheduler::disconnectSlave( _slave ); + _slave = 0; + } + _kio->emitReadSubjectsReady( result ); + } +} + +void KIO_Subjects::cancelled( ) +{ + _jobs->clear(); + //_slave died in cancelJob with is by called from the destructor of KIO_Single_Subject, + //withs is by called by _jobs->clear because autoRemove equals true. + _slave = 0; + disConnect( false ); +} + +void KIO_Subjects::slotReadSubject( KornMailSubject* subject ) +{ + _valid = true; + _kio->emitValidChanged(); + subject->setMailDrop( _kio ); + _kio->emitReadSubjectsRead( subject ); +} + +void KIO_Subjects::slotFinished( KIO_Single_Subject* item ) +{ + //Remove sender.... I didn't know of the computer gonna like me, but it seems he does :) + _jobs->remove( item ); + + _kio->emitReadSubjectsProgress( _jobs->count( ) ); + + disConnect( true ); //Only works when all jobs are finished. +} + +#include "kio_subjects.moc" |