diff options
Diffstat (limited to 'tdenewstuff/provider.cpp')
| -rw-r--r-- | tdenewstuff/provider.cpp | 428 |
1 files changed, 428 insertions, 0 deletions
diff --git a/tdenewstuff/provider.cpp b/tdenewstuff/provider.cpp new file mode 100644 index 000000000..4157c5025 --- /dev/null +++ b/tdenewstuff/provider.cpp @@ -0,0 +1,428 @@ +/* + This file is part of KOrganizer. + Copyright (c) 2002 Cornelius Schumacher <schumacher@kde.org> + Copyright (c) 2014 Timothy Pearson <kb9vqf@pearsoncomputing.net> + + 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 <tdeconfig.h> +#include <kdebug.h> +#include <tdeio/job.h> +#include <tdeglobal.h> +#include <tdemessagebox.h> +#include <tdelocale.h> + +#include <tqptrdict.h> +#include <tqwindowdefs.h> + +#include "provider.h" +#include "provider.moc" + +using namespace KNS; + +// BCI for KDE 3.5 only + +class ProviderPrivate +{ + public: + ProviderPrivate(){} + KURL mDownloadUrlLatest; + KURL mDownloadUrlScore; + KURL mDownloadUrlDownloads; +}; + +static TQPtrDict<ProviderPrivate> *d_ptr_prov = 0; + +static ProviderPrivate *d_prov(const Provider *p) +{ + if(!d_ptr_prov) + { + d_ptr_prov = new TQPtrDict<ProviderPrivate>(); + d_ptr_prov->setAutoDelete(true); + } + ProviderPrivate *ret = d_ptr_prov->find((void*)p); + if(!ret) + { + ret = new ProviderPrivate(); + d_ptr_prov->replace((void*)p, ret); + } + return ret; +} + +KURL Provider::downloadUrlVariant( TQString variant ) const +{ + if((variant == "latest") && (d_prov(this)->mDownloadUrlLatest.isValid())) + return d_prov(this)->mDownloadUrlLatest; + if((variant == "score") && (d_prov(this)->mDownloadUrlScore.isValid())) + return d_prov(this)->mDownloadUrlScore; + if((variant == "downloads") && (d_prov(this)->mDownloadUrlDownloads.isValid())) + return d_prov(this)->mDownloadUrlDownloads; + + return mDownloadUrl; +} + +// BCI part ends here + +Provider::Provider( TQString type, TQWidget* parent ) : mNoUpload( false ), mParent( parent ), mLoaded( false ), mContentType( type ) +{ +} + +Provider::Provider( const TQDomElement &e, TQString type, TQWidget* parent ) : mNoUpload( false ), mParent( parent ), mLoaded( false ), mContentType( type ) +{ + parseDomElement( e ); +} + +Provider::~Provider() +{ + if (d_ptr_prov) + { + ProviderPrivate *p = d_ptr_prov->find(this); + if (p) + d_ptr_prov->remove(p); + + if (d_ptr_prov->isEmpty()) + { + delete d_ptr_prov; + d_ptr_prov = 0L; + } + } +} + +bool Provider::loaded() +{ + return mLoaded; +} + +void Provider::setName( const TQString &name ) +{ + mName = name; +} + +TQString Provider::name() const +{ + return mName; +} + + +void Provider::setIcon( const KURL &url ) +{ + mIcon = url; +} + +KURL Provider::icon() const +{ + return mIcon; +} + + +void Provider::setDownloadUrl( const KURL &url ) +{ + mDownloadUrl = url; +} + +KURL Provider::downloadUrl() const +{ + return mDownloadUrl; +} + + +void Provider::setUploadUrl( const KURL &url ) +{ + mUploadUrl = url; +} + +KURL Provider::uploadUrl() const +{ + return mUploadUrl; +} + + +void Provider::setNoUploadUrl( const KURL &url ) +{ + mNoUploadUrl = url; +} + +KURL Provider::noUploadUrl() const +{ + return mNoUploadUrl; +} + + +void Provider::setNoUpload( bool enabled ) +{ + mNoUpload = enabled; +} + +bool Provider::noUpload() const +{ + return mNoUpload; +} + +void Provider::parseDomElement( const TQDomElement &element ) +{ + bool contentAvailable = false; + + if ( element.tagName() != "provider" ) return; + + TQDomNode n; + for ( n = element.firstChild(); !n.isNull(); n = n.nextSibling() ) { + TQDomElement p = n.toElement(); + + if ( p.tagName() == "location" ) mBaseURL = p.text(); + if ( p.tagName() == "icon" ) { + KURL iconurl( p.text() ); + if(!iconurl.isValid()) iconurl.setPath( p.text() ); + setIcon( iconurl ); + } + + if ( p.tagName() == "noupload" ) setNoUpload( true ); + if ( p.tagName() == "name" ) setName( p.text().stripWhiteSpace() ); + + if ( p.tagName() == "services" ) { + TQDomNode n2; + for ( n2 = p.firstChild(); !n2.isNull(); n2 = n2.nextSibling() ) { + TQDomElement p = n2.toElement(); + + if ( p.tagName() == "content" ) contentAvailable = true; + } + } + } + + if (!mBaseURL.endsWith("/")) { + mBaseURL.append("/"); + } + + if (contentAvailable) { + // Load content type list + KURL contentTypeUrl( mBaseURL + "content/categories" ); + + kdDebug() << "Provider::parseDomElement(): contentTypeUrl: " << contentTypeUrl << endl; + + TDEIO::TransferJob *job = TDEIO::get( KURL( contentTypeUrl ), false, false ); + connect( job, TQT_SIGNAL( result( TDEIO::Job * ) ), + TQT_SLOT( slotJobResult( TDEIO::Job * ) ) ); + connect( job, TQT_SIGNAL( data( TDEIO::Job *, const TQByteArray & ) ), + TQT_SLOT( slotJobData( TDEIO::Job *, const TQByteArray & ) ) ); + } +} + +TQDomElement Provider::createDomElement( TQDomDocument &doc, TQDomElement &parent ) +{ + TQDomElement entry = doc.createElement( "stuff" ); + parent.appendChild( entry ); + + TQDomElement n = doc.createElement( "name" ); + n.appendChild( doc.createTextNode( name() ) ); + entry.appendChild( n ); + + return entry; +} + +void Provider::slotJobData( TDEIO::Job *, const TQByteArray &data ) +{ + kdDebug() << "ProviderLoader::slotJobData()" << endl; + + if ( data.size() == 0 ) return; + + TQCString str( data, data.size() + 1 ); + + mJobData.append( TQString::fromUtf8( str ) ); +} + +void Provider::slotJobResult( TDEIO::Job *job ) +{ + if ( job->error() ) { + if (mParent) { + job->showErrorDialog( mParent ); + } + return; + } + + kdDebug() << "--CONTENT-START--" << endl << mJobData << "--CONT_END--" + << endl; + + TQDomDocument doc; + if ( !doc.setContent( mJobData ) ) { + if (mParent) { + KMessageBox::error( mParent, i18n("Error parsing category list.") ); + } + return; + } + + TQDomElement categories = doc.documentElement(); + + if ( categories.isNull() ) { + kdDebug() << "No document in Content.xml." << endl; + } + + TQStringList desiredCategoryList; + TQString desiredCategories; + + TQDomNode n; + for ( n = categories.firstChild(); !n.isNull(); n = n.nextSibling() ) { + TQDomElement p = n.toElement(); + + if ( p.tagName() == "data" ) { + TQDomNode n2; + for ( n2 = p.firstChild(); !n2.isNull(); n2 = n2.nextSibling() ) { + TQDomElement p = n2.toElement(); + + if ( p.tagName() == "category" ) { + TQDomNode n3; + TQString id; + TQString name; + for ( n3 = p.firstChild(); !n3.isNull(); n3 = n3.nextSibling() ) { + TQDomElement p = n3.toElement(); + + if ( p.tagName() == "id" ) { + id = p.text(); + } + + if ( p.tagName() == "name" ) { + name = p.text(); + } + } + + if (mContentType == "") { + desiredCategoryList.append(id); + } + else { + if (name.lower().contains(mContentType.lower())) { + desiredCategoryList.append(id); + } + } + } + } + } + } + + desiredCategories = desiredCategoryList.join("x"); + + // int maxEntries = 10; + int maxEntries = 50; + + setDownloadUrl( KURL( mBaseURL ) ); + setUploadUrl( KURL( mBaseURL ) ); + setNoUploadUrl( KURL( mBaseURL ) ); + + d_prov(this)->mDownloadUrlLatest = KURL( mBaseURL + "content/data?categories=" + desiredCategories + "&search=&sortmode=new&page=1&pagesize=" + TQString("%1").arg(maxEntries) ); + d_prov(this)->mDownloadUrlScore = KURL( mBaseURL + "content/data?categories=" + desiredCategories + "&search=&sortmode=high&page=1&pagesize=" + TQString("%1").arg(maxEntries) ); + d_prov(this)->mDownloadUrlDownloads = KURL( mBaseURL + "content/data?categories=" + desiredCategories + "&search=&sortmode=down&page=1&pagesize=" + TQString("%1").arg(maxEntries) ); + + mLoaded = true; + emit providerLoaded(); +} + + +ProviderLoader::ProviderLoader( TQWidget *parentWidget ) : + TQObject( parentWidget ) +{ + mProviders.setAutoDelete( true ); +} + +void ProviderLoader::load( const TQString &type, const TQString &providersList ) +{ + kdDebug() << "ProviderLoader::load()" << endl; + + mProviders.clear(); + mJobData = ""; + mContentType = type; + + TDEConfig *cfg = TDEGlobal::config(); + cfg->setGroup("TDENewStuff"); + + TQString providersUrl = providersList; + if( providersUrl.isEmpty() ) + providersUrl = cfg->readEntry( "ProvidersUrl" ); + + if ( providersUrl.isEmpty() ) { + // TODO: Replace the default by the real one. + TQString server = cfg->readEntry( "MasterServer", + "https://www.trinitydesktop.org" ); + + providersUrl = server + "/ocs/" + type + "/providers.xml"; + } + + kdDebug() << "ProviderLoader::load(): providersUrl: " << providersUrl << endl; + + TDEIO::TransferJob *job = TDEIO::get( KURL( providersUrl ), false, false ); + connect( job, TQT_SIGNAL( result( TDEIO::Job * ) ), + TQT_SLOT( slotJobResult( TDEIO::Job * ) ) ); + connect( job, TQT_SIGNAL( data( TDEIO::Job *, const TQByteArray & ) ), + TQT_SLOT( slotJobData( TDEIO::Job *, const TQByteArray & ) ) ); + +// job->dumpObjectInfo(); +} + +void ProviderLoader::slotJobData( TDEIO::Job *, const TQByteArray &data ) +{ + kdDebug() << "ProviderLoader::slotJobData()" << endl; + + if ( data.size() == 0 ) return; + + TQCString str( data, data.size() + 1 ); + + mJobData.append( TQString::fromUtf8( str ) ); +} + +void ProviderLoader::slotJobResult( TDEIO::Job *job ) +{ + if ( job->error() ) { + job->showErrorDialog( TQT_TQWIDGET(parent()) ); + } + + kdDebug() << "--PROVIDERS-START--" << endl << mJobData << "--PROV_END--" + << endl; + + TQDomDocument doc; + if ( !doc.setContent( mJobData ) ) { + KMessageBox::error( TQT_TQWIDGET(parent()), i18n("Error parsing providers list.") ); + return; + } + + TQDomElement providers = doc.documentElement(); + + if ( providers.isNull() ) { + kdDebug() << "No document in Providers.xml." << endl; + } + + TQDomNode n; + for ( n = providers.firstChild(); !n.isNull(); n = n.nextSibling() ) { + TQDomElement p = n.toElement(); + + if ( p.tagName() == "provider" ) { + Provider* prov = new Provider( p, mContentType, TQT_TQWIDGET(parent()) ); + mProviders.append( prov ); + connect( prov, TQT_SIGNAL( providerLoaded() ), this, TQT_SLOT( providerLoaded() ) ); + } + } +} + +void ProviderLoader::providerLoaded() { + Provider* prov = NULL; + bool allLoaded = true; + for ( prov = mProviders.first(); prov; prov = mProviders.next() ) { + if (!prov->loaded()) { + allLoaded = false; + break; + } + } + + if (allLoaded) { + emit providersLoaded( &mProviders ); + } +}
\ No newline at end of file |