1 files changed, 105 insertions, 0 deletions
diff --git a/kode/kwsdl/schema/fileprovider.cpp b/kode/kwsdl/schema/fileprovider.cpp
new file mode 100644
index 000000000..642592bf4
--- /dev/null
+++ b/kode/kwsdl/schema/fileprovider.cpp
@@ -0,0 +1,105 @@
+/* 
+    This file is part of KDE Schema Parser
+
+    Copyright (c) 2005 Tobias Koenig <tokoe@kde.org>
+
+    This library is free software; you can redistribute it and/or
+    modify it under the terms of the GNU Library General Public
+    License as published by the Free Software Foundation; either
+    version 2 of the License, or (at your option) any later version.
+
+    This library 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
+    Library General Public License for more details.
+
+    You should have received a copy of the GNU Library General Public License
+    along with this library; see the file COPYING.LIB.  If not, write to
+    the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
+    Boston, MA 02110-1301, USA.
+ */
+
+#include <unistd.h>
+
+#include <qapplication.h>
+#include <qeventloop.h>
+#include <qfile.h>
+
+#include <kio/job.h>
+#include <ktempfile.h>
+
+#include "fileprovider.h"
+
+using namespace Schema;
+
+FileProvider::FileProvider()
+  : QObject( 0 ), mBlocked( false )
+{
+}
+
+bool FileProvider::get( const QString &url, QString &target )
+{
+  if ( !mFileName.isEmpty() )
+    cleanUp();
+
+  if ( target.isEmpty() ) {
+    KTempFile tmpFile;
+    target = tmpFile.name();
+    mFileName = target;
+  }
+
+  mData.truncate( 0 );
+
+  qDebug( "Downloading external schema '%s'", url.latin1() );
+
+  KIO::TransferJob* job = KIO::get( KURL( url ), false, false );
+  connect( job, SIGNAL( data( KIO::Job*, const QByteArray& ) ),
+           this, SLOT( slotData( KIO::Job*, const QByteArray& ) ) );
+  connect( job, SIGNAL( result( KIO::Job* ) ),
+           this, SLOT( slotResult( KIO::Job* ) ) );
+
+  mBlocked = true;
+  while ( mBlocked ) {
+    qApp->eventLoop()->processEvents( QEventLoop::ExcludeUserInput );
+    usleep( 500 );
+  }
+
+  return true;
+}
+
+void FileProvider::cleanUp()
+{
+  ::unlink( QFile::encodeName( mFileName ) );
+  mFileName = QString();
+}
+
+void FileProvider::slotData( KIO::Job*, const QByteArray &data )
+{
+  unsigned int oldSize = mData.size();
+  mData.resize( oldSize + data.size() );
+  memcpy( mData.data() + oldSize, data.data(), data.size() );
+}
+
+void FileProvider::slotResult( KIO::Job *job )
+{
+  if ( job->error() ) {
+    qDebug( "%s", job->errorText().latin1() );
+    return;
+  }
+
+  QFile file( mFileName );
+  if ( !file.open( IO_WriteOnly ) ) {
+    qDebug( "Unable to create temporary file" );
+    return;
+  }
+
+  qDebug( "Download successful" );
+  file.writeBlock( mData );
+  file.close();
+
+  mData.truncate( 0 );
+
+  mBlocked = false;
+}
+
+#include "fileprovider.moc"