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.
421 lines
13 KiB
421 lines
13 KiB
/*
|
|
This file is part of KOrganizer.
|
|
Copyright (c) 2002 Cornelius Schumacher <schumacher@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 <tqcstring.h>
|
|
#include <tqdom.h>
|
|
#include <tqfileinfo.h>
|
|
|
|
#include <kapplication.h>
|
|
#include <kdebug.h>
|
|
#include <tdeio/job.h>
|
|
#include <klocale.h>
|
|
#include <kmessagebox.h>
|
|
#include <kstandarddirs.h>
|
|
|
|
#include "knewstuff.h"
|
|
#include "downloaddialog.h"
|
|
#include "uploaddialog.h"
|
|
#include "providerdialog.h"
|
|
|
|
#include "engine.h"
|
|
#include "engine.moc"
|
|
|
|
using namespace KNS;
|
|
|
|
Engine::Engine( KNewStuff *newStuff, const TQString &type,
|
|
TQWidget *parentWidget ) :
|
|
mParentWidget( parentWidget ), mDownloadDialog( 0 ),
|
|
mUploadDialog( 0 ), mProviderDialog( 0 ), mUploadProvider( 0 ),
|
|
mNewStuff( newStuff ), mType( type )
|
|
{
|
|
mProviderLoader = new ProviderLoader( mParentWidget );
|
|
|
|
mNewStuffList.setAutoDelete( true );
|
|
}
|
|
|
|
Engine::Engine( KNewStuff *newStuff, const TQString &type,
|
|
const TQString &providerList, TQWidget *parentWidget ) :
|
|
mParentWidget( parentWidget ),
|
|
mDownloadDialog( 0 ), mUploadDialog( 0 ),
|
|
mProviderDialog( 0 ), mUploadProvider( 0 ),
|
|
mProviderList( providerList ), mNewStuff( newStuff ),
|
|
mType( type )
|
|
{
|
|
mProviderLoader = new ProviderLoader( mParentWidget );
|
|
mNewStuffList.setAutoDelete( true );
|
|
}
|
|
|
|
Engine::~Engine()
|
|
{
|
|
delete mProviderLoader;
|
|
|
|
delete mUploadDialog;
|
|
delete mDownloadDialog;
|
|
}
|
|
|
|
void Engine::download()
|
|
{
|
|
kdDebug(5850) << "Engine::download()" << endl;
|
|
|
|
connect( mProviderLoader,
|
|
TQT_SIGNAL( providersLoaded( Provider::List * ) ),
|
|
TQT_SLOT( getMetaInformation( Provider::List * ) ) );
|
|
mProviderLoader->load( mType, mProviderList );
|
|
}
|
|
|
|
void Engine::getMetaInformation( Provider::List *providers )
|
|
{
|
|
mProviderLoader->disconnect();
|
|
|
|
mNewStuffJobData.clear();
|
|
|
|
if ( !mDownloadDialog ) {
|
|
mDownloadDialog = new DownloadDialog( this, mParentWidget );
|
|
mDownloadDialog->show();
|
|
}
|
|
mDownloadDialog->clear();
|
|
|
|
Provider *p;
|
|
for ( p = providers->first(); p; p = providers->next() ) {
|
|
if ( p->downloadUrl().isEmpty() ) continue;
|
|
|
|
TDEIO::TransferJob *job = TDEIO::get( p->downloadUrl() );
|
|
connect( job, TQT_SIGNAL( result( TDEIO::Job * ) ),
|
|
TQT_SLOT( slotNewStuffJobResult( TDEIO::Job * ) ) );
|
|
connect( job, TQT_SIGNAL( data( TDEIO::Job *, const TQByteArray & ) ),
|
|
TQT_SLOT( slotNewStuffJobData( TDEIO::Job *, const TQByteArray & ) ) );
|
|
|
|
mNewStuffJobData.insert( job, "" );
|
|
mProviderJobs[ job ] = p;
|
|
}
|
|
}
|
|
|
|
void Engine::slotNewStuffJobData( TDEIO::Job *job, const TQByteArray &data )
|
|
{
|
|
if ( data.isEmpty() ) return;
|
|
|
|
kdDebug(5850) << "Engine:slotNewStuffJobData()" << endl;
|
|
|
|
TQCString str( data, data.size() + 1 );
|
|
|
|
mNewStuffJobData[ job ].append( TQString::fromUtf8( str ) );
|
|
}
|
|
|
|
void Engine::slotNewStuffJobResult( TDEIO::Job *job )
|
|
{
|
|
if ( job->error() ) {
|
|
kdDebug(5850) << "Error downloading new stuff descriptions." << endl;
|
|
job->showErrorDialog( mParentWidget );
|
|
} else {
|
|
TQString knewstuffDoc = mNewStuffJobData[ job ];
|
|
|
|
kdDebug(5850) << "---START---" << endl << knewstuffDoc << "---END---" << endl;
|
|
|
|
mDownloadDialog->addProvider( mProviderJobs[ job ] );
|
|
|
|
TQDomDocument doc;
|
|
if ( !doc.setContent( knewstuffDoc ) ) {
|
|
kdDebug(5850) << "Error parsing knewstuff.xml." << endl;
|
|
return;
|
|
} else {
|
|
TQDomElement knewstuff = doc.documentElement();
|
|
|
|
if ( knewstuff.isNull() ) {
|
|
kdDebug(5850) << "No document in knewstuffproviders.xml." << endl;
|
|
} else {
|
|
TQDomNode p;
|
|
for ( p = knewstuff.firstChild(); !p.isNull(); p = p.nextSibling() ) {
|
|
TQDomElement stuff = p.toElement();
|
|
if ( stuff.tagName() != "stuff" ) continue;
|
|
if ( stuff.attribute("type", mType) != mType ) continue;
|
|
|
|
Entry *entry = new Entry( stuff );
|
|
mNewStuffList.append( entry );
|
|
|
|
mDownloadDialog->show();
|
|
|
|
mDownloadDialog->addEntry( entry );
|
|
|
|
kdDebug(5850) << "KNEWSTUFF: " << entry->name() << endl;
|
|
|
|
kdDebug(5850) << " SUMMARY: " << entry->summary() << endl;
|
|
kdDebug(5850) << " VERSION: " << entry->version() << endl;
|
|
kdDebug(5850) << " RELEASEDATE: " << entry->releaseDate().toString() << endl;
|
|
kdDebug(5850) << " RATING: " << entry->rating() << endl;
|
|
|
|
kdDebug(5850) << " LANGS: " << entry->langs().join(", ") << endl;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
mNewStuffJobData.remove( job );
|
|
mProviderJobs.remove( job );
|
|
|
|
if ( mNewStuffJobData.count() == 0 ) {
|
|
mDownloadDialog->show();
|
|
mDownloadDialog->raise();
|
|
}
|
|
}
|
|
|
|
void Engine::download( Entry *entry )
|
|
{
|
|
kdDebug(5850) << "Engine::download(entry)" << endl;
|
|
|
|
KURL source = entry->payload();
|
|
mDownloadDestination = mNewStuff->downloadDestination( entry );
|
|
|
|
if ( mDownloadDestination.isEmpty() ) {
|
|
kdDebug(5850) << "Empty downloadDestination. Cancelling download." << endl;
|
|
return;
|
|
}
|
|
|
|
KURL destination = KURL( mDownloadDestination );
|
|
|
|
kdDebug(5850) << " SOURCE: " << source.url() << endl;
|
|
kdDebug(5850) << " DESTINATION: " << destination.url() << endl;
|
|
|
|
TDEIO::FileCopyJob *job = TDEIO::file_copy( source, destination, -1, true );
|
|
connect( job, TQT_SIGNAL( result( TDEIO::Job * ) ),
|
|
TQT_SLOT( slotDownloadJobResult( TDEIO::Job * ) ) );
|
|
}
|
|
|
|
void Engine::slotDownloadJobResult( TDEIO::Job *job )
|
|
{
|
|
if ( job->error() ) {
|
|
kdDebug(5850) << "Error downloading new stuff payload." << endl;
|
|
job->showErrorDialog( mParentWidget );
|
|
return;
|
|
}
|
|
|
|
if ( mNewStuff->install( mDownloadDestination ) ) {
|
|
if ( !mIgnoreInstallResult ) {
|
|
KMessageBox::information( mParentWidget,
|
|
i18n("Successfully installed hot new stuff.") );
|
|
}
|
|
} else
|
|
if ( !mIgnoreInstallResult ){
|
|
KMessageBox::error( mParentWidget,
|
|
i18n("Failed to install hot new stuff.") );
|
|
}
|
|
}
|
|
|
|
void Engine::upload(const TQString &fileName, const TQString &previewName )
|
|
{
|
|
mUploadFile = fileName;
|
|
mPreviewFile = previewName;
|
|
|
|
connect( mProviderLoader,
|
|
TQT_SIGNAL( providersLoaded( Provider::List * ) ),
|
|
TQT_SLOT( selectUploadProvider( Provider::List * ) ) );
|
|
mProviderLoader->load( mType );
|
|
}
|
|
|
|
void Engine::selectUploadProvider( Provider::List *providers )
|
|
{
|
|
kdDebug(5850) << "Engine:selectUploadProvider()" << endl;
|
|
|
|
mProviderLoader->disconnect();
|
|
|
|
if ( !mProviderDialog ) {
|
|
mProviderDialog = new ProviderDialog( this, mParentWidget );
|
|
}
|
|
|
|
mProviderDialog->clear();
|
|
|
|
mProviderDialog->show();
|
|
mProviderDialog->raise();
|
|
|
|
for( Provider *p = providers->first(); p; p = providers->next() ) {
|
|
mProviderDialog->addProvider( p );
|
|
}
|
|
}
|
|
|
|
void Engine::requestMetaInformation( Provider *provider )
|
|
{
|
|
mUploadProvider = provider;
|
|
|
|
if ( !mUploadDialog ) {
|
|
mUploadDialog = new UploadDialog( this, mParentWidget );
|
|
}
|
|
mUploadDialog->setPreviewFile( mPreviewFile );
|
|
mUploadDialog->show();
|
|
mUploadDialog->raise();
|
|
}
|
|
|
|
void Engine::upload( Entry *entry )
|
|
{
|
|
if ( mUploadFile.isNull()) {
|
|
mUploadFile = entry->fullName();
|
|
mUploadFile = locateLocal( "data", TQString(kapp->instanceName()) + "/upload/" + mUploadFile );
|
|
|
|
if ( !mNewStuff->createUploadFile( mUploadFile ) ) {
|
|
KMessageBox::error( mParentWidget, i18n("Unable to create file to upload.") );
|
|
emit uploadFinished( false );
|
|
return;
|
|
}
|
|
}
|
|
|
|
TQString lang = entry->langs().first();
|
|
TQFileInfo fi( mUploadFile );
|
|
entry->setPayload( KURL::fromPathOrURL( fi.fileName() ), lang );
|
|
|
|
if ( !createMetaFile( entry ) ) {
|
|
emit uploadFinished( false );
|
|
return;
|
|
}
|
|
|
|
TQString text = i18n("The files to be uploaded have been created at:\n");
|
|
text.append( i18n("Data file: %1\n").arg( mUploadFile) );
|
|
if (!mPreviewFile.isEmpty()) {
|
|
text.append( i18n("Preview image: %1\n").arg( mPreviewFile) );
|
|
}
|
|
text.append( i18n("Content information: %1\n").arg( mUploadMetaFile) );
|
|
text.append( i18n("Those files can now be uploaded.\n") );
|
|
text.append( i18n("Beware that any people might have access to them at any time.") );
|
|
|
|
TQString caption = i18n("Upload Files");
|
|
|
|
if ( mUploadProvider->noUpload() ) {
|
|
KURL noUploadUrl = mUploadProvider->noUploadUrl();
|
|
if ( noUploadUrl.isEmpty() ) {
|
|
text.append( i18n("Please upload the files manually.") );
|
|
KMessageBox::information( mParentWidget, text, caption );
|
|
} else {
|
|
int result = KMessageBox::questionYesNo( mParentWidget, text, caption,
|
|
i18n("Upload Info"),
|
|
KStdGuiItem::close() );
|
|
if ( result == KMessageBox::Yes ) {
|
|
kapp->invokeBrowser( noUploadUrl.url() );
|
|
}
|
|
}
|
|
} else {
|
|
int result = KMessageBox::questionYesNo( mParentWidget, text, caption,
|
|
i18n("&Upload"), KStdGuiItem::cancel() );
|
|
if ( result == KMessageBox::Yes ) {
|
|
KURL destination = mUploadProvider->uploadUrl();
|
|
destination.setFileName( fi.fileName() );
|
|
|
|
TDEIO::FileCopyJob *job = TDEIO::file_copy( KURL::fromPathOrURL( mUploadFile ), destination );
|
|
connect( job, TQT_SIGNAL( result( TDEIO::Job * ) ),
|
|
TQT_SLOT( slotUploadPayloadJobResult( TDEIO::Job * ) ) );
|
|
} else {
|
|
emit uploadFinished( false );
|
|
}
|
|
}
|
|
}
|
|
|
|
bool Engine::createMetaFile( Entry *entry )
|
|
{
|
|
TQDomDocument doc("knewstuff");
|
|
doc.appendChild( doc.createProcessingInstruction(
|
|
"xml", "version=\"1.0\" encoding=\"UTF-8\"" ) );
|
|
TQDomElement de = doc.createElement("knewstuff");
|
|
doc.appendChild( de );
|
|
|
|
entry->setType(type());
|
|
de.appendChild( entry->createDomElement( doc, de ) );
|
|
|
|
kdDebug(5850) << "--DOM START--" << endl << doc.toString()
|
|
<< "--DOM_END--" << endl;
|
|
|
|
if ( mUploadMetaFile.isNull() ) {
|
|
mUploadMetaFile = entry->fullName() + ".meta";
|
|
mUploadMetaFile = locateLocal( "data", TQString(kapp->instanceName()) + "/upload/" + mUploadMetaFile );
|
|
}
|
|
|
|
TQFile f( mUploadMetaFile );
|
|
if ( !f.open( IO_WriteOnly ) ) {
|
|
mUploadMetaFile = TQString();
|
|
return false;
|
|
}
|
|
|
|
TQTextStream ts( &f );
|
|
ts.setEncoding( TQTextStream::UnicodeUTF8 );
|
|
ts << doc.toString();
|
|
|
|
f.close();
|
|
|
|
return true;
|
|
}
|
|
|
|
void Engine::slotUploadPayloadJobResult( TDEIO::Job *job )
|
|
{
|
|
if ( job->error() ) {
|
|
kdDebug(5850) << "Error uploading new stuff payload." << endl;
|
|
job->showErrorDialog( mParentWidget );
|
|
emit uploadFinished( false );
|
|
return;
|
|
}
|
|
|
|
if (mPreviewFile.isEmpty()) {
|
|
slotUploadPreviewJobResult(job);
|
|
return;
|
|
}
|
|
|
|
TQFileInfo fi( mPreviewFile );
|
|
|
|
KURL previewDestination = mUploadProvider->uploadUrl();
|
|
previewDestination.setFileName( fi.fileName() );
|
|
|
|
TDEIO::FileCopyJob *newJob = TDEIO::file_copy( KURL::fromPathOrURL( mPreviewFile ), previewDestination );
|
|
connect( newJob, TQT_SIGNAL( result( TDEIO::Job * ) ),
|
|
TQT_SLOT( slotUploadPreviewJobResult( TDEIO::Job * ) ) );
|
|
}
|
|
|
|
void Engine::slotUploadPreviewJobResult( TDEIO::Job *job )
|
|
{
|
|
if ( job->error() ) {
|
|
kdDebug(5850) << "Error uploading new stuff preview." << endl;
|
|
job->showErrorDialog( mParentWidget );
|
|
emit uploadFinished( true );
|
|
return;
|
|
}
|
|
|
|
TQFileInfo fi( mUploadMetaFile );
|
|
|
|
KURL metaDestination = mUploadProvider->uploadUrl();
|
|
metaDestination.setFileName( fi.fileName() );
|
|
|
|
TDEIO::FileCopyJob *newJob = TDEIO::file_copy( KURL::fromPathOrURL( mUploadMetaFile ), metaDestination );
|
|
connect( newJob, TQT_SIGNAL( result( TDEIO::Job * ) ),
|
|
TQT_SLOT( slotUploadMetaJobResult( TDEIO::Job * ) ) );
|
|
}
|
|
|
|
void Engine::slotUploadMetaJobResult( TDEIO::Job *job )
|
|
{
|
|
mUploadMetaFile = TQString();
|
|
if ( job->error() ) {
|
|
kdDebug(5850) << "Error uploading new stuff metadata." << endl;
|
|
job->showErrorDialog( mParentWidget );
|
|
emit uploadFinished( false );
|
|
return;
|
|
}
|
|
|
|
KMessageBox::information( mParentWidget,
|
|
i18n("Successfully uploaded new stuff.") );
|
|
emit uploadFinished( true );
|
|
}
|
|
|
|
void Engine::ignoreInstallResult(bool ignore)
|
|
{
|
|
mIgnoreInstallResult = ignore;
|
|
}
|