Rename kiobuffer and KHTML

1 files changed, 176 insertions, 0 deletions

diff --git a/korn/tdeio_subjects.cpp b/korn/tdeio_subjects.cpp
new file mode 100644
index 000000000..f40a86f64
--- /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"