From b363d2579af0a11b77e698aed2e1021c2233b644 Mon Sep 17 00:00:00 2001 From: Timothy Pearson Date: Sat, 26 Jan 2013 13:17:50 -0600 Subject: Rename a number of libraries and executables to avoid conflicts with KDE4 --- tderesources/lib/groupwaredownloadjob.cpp | 300 ++++++++++++++++++++++++++++++ 1 file changed, 300 insertions(+) create mode 100644 tderesources/lib/groupwaredownloadjob.cpp (limited to 'tderesources/lib/groupwaredownloadjob.cpp') diff --git a/tderesources/lib/groupwaredownloadjob.cpp b/tderesources/lib/groupwaredownloadjob.cpp new file mode 100644 index 000000000..9104da847 --- /dev/null +++ b/tderesources/lib/groupwaredownloadjob.cpp @@ -0,0 +1,300 @@ +/* + This file is part of tdepim. + + Copyright (c) 2004 Cornelius Schumacher + Copyright (c) 2004 Till Adam + Copyright (c) 2005 Reinhold Kainhofer + + 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 "groupwaredownloadjob.h" + +#include "folderlister.h" +#include "groupwaredataadaptor.h" + +#include +#include +#include +#include +#include +#include + +using namespace KPIM; + +GroupwareDownloadJob::GroupwareDownloadJob( GroupwareDataAdaptor *adaptor ) + : GroupwareJob( adaptor ), mProgress(0), + mDownloadJob(0), mListEventsJob(0) +{ +} + +void GroupwareDownloadJob::run() +{ + kdDebug(5800) << "GroupwareDownloadJob::run()" << endl; + + if ( !adaptor() ) { + error( i18n("Unable to initialize the download job.") ); + return; + } + + if ( adaptor()->folderLister() ){ + mFoldersForDownload = adaptor()->folderLister()->activeFolderIds(); + } else { + // TODO: If we don't have a folder lister, use the base URL (e.g. if all + // communication goes through one script on the server + } + + mItemsForDownload.clear(); + mCurrentlyOnServer.clear(); + connect( adaptor(), TQT_SIGNAL( itemToDownload( const KURL &, KPIM::FolderLister::ContentType ) ), + TQT_SLOT( slotItemToDownload( const KURL &, KPIM::FolderLister::ContentType ) ) ); + connect( adaptor(), TQT_SIGNAL( itemOnServer( const KURL & ) ), + TQT_SLOT( slotItemOnServer( const KURL & ) ) ); + connect( adaptor(), TQT_SIGNAL( itemDownloaded( const TQString &, const KURL &, const TQString & ) ), + TQT_SLOT( slotItemDownloaded( const TQString &, const KURL &, const TQString & ) ) ); + connect( adaptor(), TQT_SIGNAL( itemDownloadError( const KURL &, const TQString & ) ), + TQT_SLOT( slotItemDownloadError( const KURL &, const TQString & ) ) ); + + mProgress = KPIM::ProgressManager::instance()->createProgressItem( + KPIM::ProgressManager::getUniqueID(), + adaptor()->downloadProgressMessage() ); + connect( mProgress, + TQT_SIGNAL( progressItemCanceled( KPIM::ProgressItem * ) ), + TQT_SLOT( cancelLoad() ) ); + + listItems(); +} + +void GroupwareDownloadJob::listItems() +{ + if ( mFoldersForDownload.isEmpty() ) { + if ( mProgress ) { + mProgress->setTotalItems( mItemsForDownload.count() + 1 ); + mProgress->setCompletedItems( 1 ); + mProgress->updateProgress(); + } + + /* Delete incidences no longer present on the server */ + deleteIncidencesGoneFromServer(); + downloadItem(); + } else { + + //kdDebug(7000) << "props: " << props.toString() << endl; + KURL url = mFoldersForDownload.front(); + mFoldersForDownload.pop_front(); + kdDebug(5800) << "listItems: " << url.url() << endl; + + adaptor()->adaptDownloadUrl( url ); + kdDebug(5800) << "listItems, after adaptDownloadUrl: " << url.url() << endl; + + kdDebug(5800) << "OpenGroupware::listIncidences(): " << url << endl; + + mListItemsData = TQString(); + mListEventsJob = adaptor()->createListItemsJob( url ); + + connect( mListEventsJob, TQT_SIGNAL( result( TDEIO::Job * ) ), + TQT_SLOT( slotListItemsResult( TDEIO::Job * ) ) ); + connect( mListEventsJob, TQT_SIGNAL( data( TDEIO::Job *, const TQByteArray & ) ), + TQT_SLOT( slotListItemsData( TDEIO::Job *, const TQByteArray & ) ) ); + } +} + + +void GroupwareDownloadJob::slotListItemsData( TDEIO::Job *, const TQByteArray &data ) +{ + kdDebug(5800) << "OpenGroupware::slotListItemsData()" << endl; + + mListItemsData.append( data.data() ); +} + + +void GroupwareDownloadJob::slotListItemsResult( TDEIO::Job *job ) +{ + kdDebug(5800) << "GroupwareDownloadJob::slotListItemsResult(): " << endl; + + if ( job->error() ) { + if ( mProgress ) { + mProgress->setComplete(); + mProgress = 0; + } + error( job->errorString() ); + } else { + adaptor()->interpretListItemsJob( job, mListItemsData ); + } + + mListItemsData = TQString(); + mListEventsJob = 0; + + listItems(); +} + +void GroupwareDownloadJob::deleteIncidencesGoneFromServer() +{ + TQMap remoteIds( adaptor()->idMapper()->remoteIdMap() ); + KURL::List::ConstIterator it = mCurrentlyOnServer.begin(); + while ( it != mCurrentlyOnServer.end() ) { + remoteIds.remove( (*it).path() ); + ++it; + } + TQMap::ConstIterator it2; + for (it2 = remoteIds.begin(); it2 != remoteIds.end(); ++it2) { + adaptor()->deleteItem( remoteIds[ it2.key() ] ); + } +} + +void GroupwareDownloadJob::downloadItem() +{ + kdDebug(7000) << " downloadItem " << endl; + if ( mItemsForDownload.isEmpty() ) { + if ( mProgress ) mProgress->setComplete(); + + mItemsForDownload.clear(); + mItemsDownloading.clear(); + mItemsDownloaded.clear(); + mItemsDownloadError.clear(); + + mProgress = 0; + success(); + } else { + if ( adaptor()->flags() & KPIM::GroupwareDataAdaptor::GWResBatchRequest ) { + mDownloadItemsData = TQString(); + mDownloadJob = adaptor()->createDownloadJob( mItemsForDownload ); + mItemsDownloading = mItemsForDownload; + mItemsForDownload.clear(); + } else { + // Download the first item of the list + TQMap::Iterator it = mItemsForDownload.begin(); + KURL href( it.key() ); + KPIM::FolderLister::ContentType ctype = it.data(); + mItemsDownloading.insert( it.key(), it.data() ); + mItemsForDownload.remove( it.key() ); + + adaptor()->adaptDownloadUrl( href ); + mDownloadItemsData = TQString(); + + mDownloadJob = adaptor()->createDownloadJob( href, ctype ); + } + connect( mDownloadJob, TQT_SIGNAL( result( TDEIO::Job * ) ), + TQT_SLOT( slotDownloadItemResult( TDEIO::Job * ) ) ); + connect( mDownloadJob, TQT_SIGNAL( data( TDEIO::Job *, const TQByteArray & ) ), + TQT_SLOT( slotDownloadItemData( TDEIO::Job *, const TQByteArray & ) ) ); + } +} + +void GroupwareDownloadJob::slotDownloadItemResult( TDEIO::Job *job ) +{ + kdDebug(5800) << "GroupwareDownloadJob::slotDownloadItemResult(): " << endl; + + TDEIO::TransferJob *trfjob = dynamic_cast(job); + if ( !trfjob ) return; + + if ( job->error() ) { + error( job->errorString() ); + } else { + adaptor()->interpretDownloadItemsJob( job, mDownloadItemsData ); + } + + if ( mProgress ) { + mProgress->incCompletedItems(); + mProgress->updateProgress(); + } + mDownloadItemsData = TQString(); + mDownloadJob = 0; + + downloadItem(); +} + +void GroupwareDownloadJob::slotDownloadItemData( TDEIO::Job *, const TQByteArray &data ) +{ + kdDebug(5800) << "OpenGroupware::slotDownloadItemData()" << endl; + + mDownloadItemsData.append( TQString::fromUtf8( data.data(), data.size() ) ); +} + +void GroupwareDownloadJob::slotItemToDownload( const KURL &remoteURL, + KPIM::FolderLister::ContentType type ) +{ + KURL url( remoteURL ); + adaptor()->adaptDownloadUrl( url ); + if ( !mItemsForDownload.contains( url ) && + !mItemsDownloading.contains( url ) && + !mItemsDownloaded.contains( url ) ) { + mItemsForDownload.insert( url, type ); + } +} + + +void GroupwareDownloadJob::slotItemOnServer( const KURL &remoteURL ) +{ +kdDebug()<<"GroupwareDownloadJob::slotItemOnServer( " << remoteURL.url() << ")" << endl; + if ( !mCurrentlyOnServer.contains( remoteURL ) ) { + mCurrentlyOnServer.append( remoteURL ); + } +} + + +void GroupwareDownloadJob::slotItemDownloadError( const KURL &remoteURL, const TQString &/*error*/ ) +{ + // TODO: Error handling! + if ( mItemsDownloading.contains( remoteURL ) ) { + mItemsDownloadError[ remoteURL ] = mItemsDownloading[ remoteURL ]; + } else if ( mItemsForDownload.contains( remoteURL ) ) { + mItemsDownloadError[ remoteURL ] = mItemsForDownload[ remoteURL ]; + } +} + + +void GroupwareDownloadJob::slotItemDownloaded( const TQString &localID, + const KURL &remoteURL, const TQString &fingerprint ) +{ +kdDebug()<<"GroupwareDownloadJob::slotItemDownloaded( " << localID << ", " << remoteURL.url() << ", " << fingerprint << ")" << endl; + if ( mItemsForDownload.contains( remoteURL ) ) { + mItemsDownloaded[ remoteURL ] = mItemsForDownload[ remoteURL ]; + mItemsForDownload.remove( remoteURL ); + } + if ( mItemsDownloading.contains( remoteURL ) ) { + mItemsDownloaded[ remoteURL ] = mItemsDownloading[ remoteURL ]; + mItemsDownloading.remove( remoteURL ); + } + if ( !mItemsDownloaded.contains( remoteURL ) ) { + mItemsDownloaded[ remoteURL ] = KPIM::FolderLister::Unknown; + } + adaptor()->idMapper()->setRemoteId( localID, remoteURL.path() ); + adaptor()->idMapper()->setFingerprint( localID, fingerprint ); +} + + + +void GroupwareDownloadJob::kill() +{ + cancelLoad(); +} + + + +void GroupwareDownloadJob::cancelLoad() +{ + if ( mDownloadJob ) mDownloadJob->kill(); + mDownloadJob = 0; + if ( mListEventsJob ) mListEventsJob->kill(); + mListEventsJob = 0; + if ( mProgress ) mProgress->setComplete(); + + + mProgress = 0; +} + +#include "groupwaredownloadjob.moc" -- cgit v1.2.1