diff options
Diffstat (limited to 'korn/tdeio_delete.cpp')
| -rw-r--r-- | korn/tdeio_delete.cpp | 201 |
1 files changed, 201 insertions, 0 deletions
diff --git a/korn/tdeio_delete.cpp b/korn/tdeio_delete.cpp new file mode 100644 index 000000000..a73b0dd40 --- /dev/null +++ b/korn/tdeio_delete.cpp @@ -0,0 +1,201 @@ +/* + * 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_delete.h" + +#include "mailid.h" +#include "stringid.h" +#include "kio.h" +#include "kio_proto.h" + +#include <kdebug.h> +#include <klocale.h> +#include <kurl.h> +#include <tdeio/global.h> +#include <tdeio/jobclasses.h> +#include <tdeio/scheduler.h> + +#include <tqptrlist.h> + +KIO_Delete::KIO_Delete( TQObject * parent, const char * name ) : TQObject( parent, name ), + _kio( 0 ), + _total( 0 ), + _jobs( 0 ), + _slave( 0 ), + _valid( true ) +{ + _jobs = new TQPtrList< TDEIO::Job >; +} + +KIO_Delete::~KIO_Delete( ) +{ + disConnect( ); + delete _jobs; +} + +bool KIO_Delete::deleteMails( TQPtrList< const KornMailId > * ids, KKioDrop *drop ) +{ + KURL kurl = *drop->_kurl; + TDEIO::MetaData metadata = *drop->_metadata; + + _kio = drop; + _valid = true; + + //disConnect earlier operations + disConnect( ); + if( _kio->_protocol->connectionBased( ) ) + { + if( ! setupSlave( kurl, metadata, _kio->_protocol ) ) + { + _valid = false; + return false; + } + } + + _total = ids->count( ); + + for( const KornMailId * item = ids->first(); item; item = ids->next() ) + deleteItem( item, kurl, metadata, _kio->_protocol ); + + if( _jobs->count() == 0 ) + { + _kio->emitDeleteMailsReady( true ); + disConnect( ); + return true; + } + + if( _kio->_protocol->commitDelete() ) + commitDelete( kurl, metadata, _kio->_protocol ); + + _kio->emitDeleteMailsTotalSteps( _total ); + + return true; +} + +void KIO_Delete::disConnect( ) +{ + _jobs->clear( ); + + if( _slave ) + { + TDEIO::Scheduler::disconnectSlave( _slave ); + _slave = 0; + } +} + +bool KIO_Delete::setupSlave( KURL kurl, TDEIO::MetaData metadata, const KIO_Protocol *& protocol ) +{ + protocol->deleteMailConnectKURL( kurl, metadata ); + + if( kurl.port() == 0 ) + kurl.setPort( protocol->defaultPort( _kio->_ssl ) ); + + if( ! ( _slave = TDEIO::Scheduler::getConnectedSlave( kurl, metadata ) ) ) + { + kdWarning() << i18n( "Could not get a connected slave; I cannot delete this way..." ) << endl; + _valid = false; + return false; + } + + return true; +} + +void KIO_Delete::deleteItem( const KornMailId *item, KURL kurl, TDEIO::MetaData metadata, const KIO_Protocol *& protocol ) +{ + TDEIO::Job* job = 0; + + kurl = dynamic_cast<const KornStringId*>( item )->getId(); + + protocol->deleteMailKURL( kurl, metadata ); + + if( kurl.port() == 0 ) + kurl.setPort( protocol->defaultPort( _kio->_ssl ) ); + + if( protocol->deleteFunction() == KIO_Protocol::get ) + { + job = TDEIO::get( kurl, true, false ); + + if( protocol->connectionBased() ) + TDEIO::Scheduler::assignJobToSlave( _slave, dynamic_cast< TDEIO::SimpleJob* >( job ) ); + else + TDEIO::Scheduler::scheduleJob( dynamic_cast< TDEIO::SimpleJob* >( job ) ); + } + else if( protocol->deleteFunction() == KIO_Protocol::del ) + { + job = TDEIO::del( kurl, false, false ); + } + else + return; //Unknown deleteFunction + + connect( job, TQT_SIGNAL( result( TDEIO::Job* ) ), this, TQT_SLOT( slotResult( TDEIO::Job* ) ) ); + + job->addMetaData( metadata ); + + _jobs->append( dynamic_cast< TDEIO::Job* >( job ) ); +} + +/* + * Some protocols needs to a command to commit protocols. + */ +void KIO_Delete::commitDelete( KURL kurl, TDEIO::MetaData metadata, const KIO_Protocol *& protocol ) +{ + protocol->deleteCommitKURL( kurl, metadata ); + + if( kurl.port() == 0 ) + kurl.setPort( protocol->defaultPort( _kio->_ssl ) ); + + TDEIO::TransferJob *job = TDEIO::get( kurl, true, false ); + job->addMetaData( metadata ); + connect( job, TQT_SIGNAL( result( TDEIO::Job* ) ), this, TQT_SLOT( slotResult( TDEIO::Job* ) ) ); + + _jobs->append( dynamic_cast< TDEIO::Job* >( job ) ); + + if( protocol->connectionBased() ) + TDEIO::Scheduler::assignJobToSlave( _slave, job ); + else + TDEIO::Scheduler::scheduleJob( job ); + + _total++; +} + +void KIO_Delete::canceled( ) +{ + disConnect( ); +} + +void KIO_Delete::slotResult( TDEIO::Job* job ) +{ + if( job->error() ) + { + kdWarning() << i18n( "An error occurred when deleting email: %1." ).arg( job->errorString() ) << endl; + _valid = false; + } + + _jobs->remove( job ); + + _kio->emitDeleteMailsProgress( _total - _jobs->count() ); + + if( _jobs->isEmpty() ) + { + _kio->emitDeleteMailsReady( _valid ); + disConnect(); + } +} + + +#include "kio_delete.moc" |