diff options
author | Timothy Pearson <kb9vqf@pearsoncomputing.net> | 2013-01-26 13:17:50 -0600 |
---|---|---|
committer | Timothy Pearson <kb9vqf@pearsoncomputing.net> | 2013-01-26 13:17:50 -0600 |
commit | b363d2579af0a11b77e698aed2e1021c2233b644 (patch) | |
tree | f4a47b87354b7a6a3b266c8121bd8ddaeb7accaa /kresources/lib/groupwareuploadjob.cpp | |
parent | 61bddfe3a7226b18c68a76124b727c736f431688 (diff) | |
download | tdepim-b363d2579af0a11b77e698aed2e1021c2233b644.tar.gz tdepim-b363d2579af0a11b77e698aed2e1021c2233b644.zip |
Rename a number of libraries and executables to avoid conflicts with KDE4
Diffstat (limited to 'kresources/lib/groupwareuploadjob.cpp')
-rw-r--r-- | kresources/lib/groupwareuploadjob.cpp | 485 |
1 files changed, 0 insertions, 485 deletions
diff --git a/kresources/lib/groupwareuploadjob.cpp b/kresources/lib/groupwareuploadjob.cpp deleted file mode 100644 index cf46571fc..000000000 --- a/kresources/lib/groupwareuploadjob.cpp +++ /dev/null @@ -1,485 +0,0 @@ -/* - This file is part of tdepim. - - Copyright (c) 2004 Cornelius Schumacher <schumacher@kde.org> - Copyright (c) 2004 Till Adam <adam@kde.org> - Copyright (c) 2005 Reinhold Kainhofer <reinhold@kainhofer.com> - - 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 "groupwareuploadjob.h" - -#include "folderlister.h" -#include "groupwaredataadaptor.h" - -#include <libemailfunctions/idmapper.h> -#include <libtdepim/progressmanager.h> - -#include <kdebug.h> -#include <kurl.h> -#include <kio/job.h> - -#include <tqstringlist.h> -#include <tqtimer.h> -#include <klocale.h> - -using namespace KPIM; - -GroupwareUploadJob::GroupwareUploadJob( GroupwareDataAdaptor *adaptor ) - : GroupwareJob( adaptor ), mUploadJob(0), - mDeletionJob(0), mUploadProgress(0) -{ -} - -void GroupwareUploadJob::run() -{ - deleteItem(); - mUploadProgress = KPIM::ProgressManager::instance()->createProgressItem( - KPIM::ProgressManager::getUniqueID(), - adaptor()->uploadProgressMessage() ); - connect( mUploadProgress, - TQT_SIGNAL( progressItemCanceled( KPIM::ProgressItem * ) ), - TQT_SLOT( cancelSave() ) ); - - connect( adaptor(), TQT_SIGNAL( itemDeletionError( const KURL &, const TQString & ) ), - TQT_SLOT( slotItemDeleteError( const KURL &, const TQString & ) ) ); - connect( adaptor(), TQT_SIGNAL( itemUploadError( const KURL &, const TQString & ) ), - TQT_SLOT( slotItemUploadError( const KURL &, const TQString & ) ) ); - connect( adaptor(), TQT_SIGNAL( itemUploadNewError( const TQString &, const TQString & ) ), - TQT_SLOT( slotItemUploadNewError( const TQString &, const TQString & ) ) ); - - connect( adaptor(), TQT_SIGNAL( itemDeleted( const TQString &, const KURL & ) ), - TQT_SLOT( slotItemDeleted( const TQString &, const KURL & ) ) ); - connect( adaptor(), TQT_SIGNAL( itemUploaded( const TQString &, const KURL & ) ), - TQT_SLOT( slotItemUploaded( const TQString &, const KURL & ) ) ); - connect( adaptor(), TQT_SIGNAL( itemUploadedNew( const TQString &, const KURL& ) ), - TQT_SLOT( slotItemUploadedNew( const TQString &, const KURL & ) ) ); - - - mUploadProgress->setTotalItems( mAddedItems.size() + mChangedItems.size() + - ((mChangedItems.isEmpty())?0:1) ); - mUploadProgress->updateProgress(); -} - - - -void GroupwareUploadJob::deleteItem() -{ - kdDebug(5800)<<"GroupwareUploadJob::deleteItem()"<<endl; - if ( mDeletedItems.isEmpty() ) { - TQTimer::singleShot( 0, this, TQT_SLOT( uploadItem() ) ); - } else { - kdDebug(7000) << " Deleting " << mDeletedItems.size() << " items from the server " << endl; - - KURL url( adaptor()->baseURL() ); - adaptor()->adaptUploadUrl( url ); - if ( adaptor()->flags() & KPIM::GroupwareDataAdaptor::GWResBatchDelete ) { -kdDebug() << "Using batch delete " << endl; - mDeletionJob = adaptor()->createRemoveJob( url, mDeletedItems ); - mItemsUploading += mDeletedItems; - mDeletedItems.clear(); - } else { -kdDebug() << "Not using batch delete " << endl; - KPIM::GroupwareUploadItem *item = mDeletedItems.front(); - mDeletionJob = adaptor()->createRemoveJob( url, item ); - mItemsUploading.append( mDeletedItems.front() ); - mDeletedItems.pop_front(); - } - - if ( mDeletionJob ) { - mDeletionJobData = TQString(); - connect( mDeletionJob, TQT_SIGNAL( result( TDEIO::Job* ) ), - TQT_SLOT( slotDeletionJobResult( TDEIO::Job* ) ) ); -// connect( mDeletionJob, TQT_SIGNAL( data( TDEIO::Job *, const TQByteArray & ) ), -// TQT_SLOT( slotDeletionJobData( TDEIO::Job *, const TQByteArray & ) ) ); - } else { - deleteItem(); - } - } -} - - - -void GroupwareUploadJob::slotDeletionJobData( TDEIO::Job *, const TQByteArray &data ) -{ - kdDebug(5800) << "OpenGroupware::slotDeletionData()" << endl; - - mDeletionJobData.append( data.data() ); -} - - - -void GroupwareUploadJob::slotDeletionJobResult( TDEIO::Job *job ) -{ - if ( job && adaptor() ) { - adaptor()->interpretRemoveJob( job, mDeletionJobData ); - } - mDeletionJob = 0; - TQTimer::singleShot( 0, this, TQT_SLOT( deleteItem() ) ); -} - - - -void GroupwareUploadJob::uploadItem() -{ - kdDebug(5800)<<"GroupwareUploadJob::uploadItem()"<<endl; - if ( mChangedItems.isEmpty() ) { - TQTimer::singleShot( 0, this, TQT_SLOT( uploadNewItem() ) ); - } else { - kdDebug(5800)<<"We still have "<<mChangedItems.count()<<" changed items to upload"<<endl; - - KURL url( adaptor()->baseURL() ); - adaptor()->adaptUploadUrl( url ); - if ( adaptor()->flags() & KPIM::GroupwareDataAdaptor::GWResBatchModify ) { -kdDebug() << "Using batch upload " << endl; - mUploadJob = adaptor()->createUploadJob( url, mChangedItems ); - mItemsUploading += mChangedItems; - mChangedItems.clear(); - } else { -kdDebug() << "Not using batch upload " << endl; - KPIM::GroupwareUploadItem *item = mChangedItems.front(); - mUploadJob = adaptor()->createUploadJob( url, item ); - mItemsUploading.append( mChangedItems.front() ); - mChangedItems.pop_front(); - } - - if ( mUploadJob ) { - mUploadJobData = TQString(); - connect( mUploadJob, TQT_SIGNAL( result( TDEIO::Job* ) ), - TQT_SLOT( slotUploadJobResult( TDEIO::Job* ) ) ); - connect( mUploadJob, TQT_SIGNAL( data( TDEIO::Job *, const TQByteArray & ) ), - TQT_SLOT( slotUploadJobData( TDEIO::Job *, const TQByteArray & ) ) ); - } else { - uploadItem(); - } - } -} - - -void GroupwareUploadJob::slotUploadJobData( TDEIO::Job *, const TQByteArray &data ) -{ - kdDebug(5800) << "OpenGroupware::slotUploadData()" << endl; - - mUploadJobData.append( data.data() ); -} - - - -void GroupwareUploadJob::slotUploadJobResult( TDEIO::Job *job ) -{ - if ( job && adaptor() ) { - adaptor()->interpretUploadJob( job, mUploadJobData ); - } - mUploadJob = 0; - TQTimer::singleShot( 0, this, TQT_SLOT( uploadItem() ) ); -} - - - - -void GroupwareUploadJob::uploadNewItem() -{ - kdDebug(5800)<<"GroupwareUploadJob::uploadNewItem()"<<endl; - if ( !mAddedItems.isEmpty() ) { - - if ( adaptor()->flags() & KPIM::GroupwareDataAdaptor::GWResBatchCreate ) { - KURL url( adaptor()->folderLister()->writeDestinationId( FolderLister::All ) ); - adaptor()->adaptUploadUrl( url ); -kdDebug() << "Using batch create to " << url.url() << endl; - mUploadJob = adaptor()->createUploadNewJob( url, mAddedItems ); - mItemsUploading += mAddedItems; - mAddedItems.clear(); - } else { - KPIM::GroupwareUploadItem *item = mAddedItems.front(); - KURL url( adaptor()->folderLister()->writeDestinationId( item->itemType() ) ); - adaptor()->adaptUploadUrl( url ); -kdDebug() << "Not using batch create to " << url.url() << " for item of type " << item->itemType() << endl; - if ( !url.isEmpty() ) { - mUploadJob = adaptor()->createUploadNewJob( url, item ); - mItemsUploading.append( mAddedItems.front() ); - } - mAddedItems.pop_front(); - } - - if ( mUploadJob ) { - mUploadNewJobData = TQString(); - connect( mUploadJob, TQT_SIGNAL( result( TDEIO::Job* ) ), - TQT_SLOT( slotUploadNewJobResult( TDEIO::Job* ) ) ); - connect( mUploadJob, TQT_SIGNAL( data( TDEIO::Job *, const TQByteArray & ) ), - TQT_SLOT( slotUploadNewJobData( TDEIO::Job *, const TQByteArray & ) ) ); - } else { - uploadNewItem(); - } - - } else { - kdDebug(5800)<<"We are finished uploading all items. Setting progress to completed."<<endl; - uploadCompleted(); - } -} - -void GroupwareUploadJob::slotUploadNewJobData( TDEIO::Job *, const TQByteArray &data ) -{ - kdDebug(5800) << "OpenGroupware::slotUploadNewJobData()" << endl; - - mUploadNewJobData.append( data.data() ); -} - - - -void GroupwareUploadJob::slotUploadNewJobResult( TDEIO::Job *job ) -{ - if ( job && adaptor() ) { - adaptor()->interpretUploadNewJob( job, mUploadNewJobData ); - } - mUploadJob = 0; - TQTimer::singleShot( 0, this, TQT_SLOT( uploadNewItem() ) ); -} - - -void GroupwareUploadJob::kill() -{ - cancelSave(); -} - -void GroupwareUploadJob::slotItemDeleted( const TQString &/*localId*/, const KURL &remoteURL ) -{ - kdDebug() << "GroupwareUploadJob::slotItemDeleted, removal successful: "<< remoteURL.url() << endl; - - const TQString &remote = remoteURL.path(); - const TQString &local = adaptor()->idMapper()->localId( remote ); - if ( !local.isEmpty() ) { - // TODO: Is the deleted status reset in the resource? - adaptor()->deleteItem( local ); - } - - KPIM::GroupwareUploadItem::List allit( mDeletedItems ); - allit += mItemsUploading; - allit += mItemsUploadError; - - KPIM::GroupwareUploadItem::List::Iterator it = allit.begin(); - for ( ; it != allit.end(); ++it ) { - if ( (*it)->url().path() == remoteURL.path() ) { -kdDebug()<<"Found it in the list!"<<endl; - KPIM::GroupwareUploadItem *item = (*it); - mDeletedItems.remove( item ); - mItemsUploading.remove( item ); - mItemsUploadError.remove( item ); - mItemsUploaded.append( item ); - } - } - - if ( mUploadProgress ) { - mUploadProgress->incCompletedItems(); - mUploadProgress->updateProgress(); - } -} - - - -void GroupwareUploadJob::slotItemUploaded( const TQString &/*localId*/, const KURL &remoteURL ) -{ - kdDebug() << "GroupwareUploadJob::slotItemUploaded, upload successful: "<< remoteURL.url() << endl; - - const TQString &remote = remoteURL.path(); - const TQString &local = adaptor()->idMapper()->localId( remote ); - if ( !local.isEmpty() ) { - // TODO: Is the deleted status reset in the resource? -// adaptor()->itemUploaded( local, remoteURL ); - } - - KPIM::GroupwareUploadItem::List allit( mChangedItems ); - allit += mAddedItems; - allit += mItemsUploading; - allit += mItemsUploadError; - - - KPIM::GroupwareUploadItem::List::Iterator it = allit.begin(); - for ( ; it != allit.end(); ++it ) { - if ( (*it)->url().path() == remoteURL.path() ) { -kdDebug()<<"Found it in the list!"<<endl; - KPIM::GroupwareUploadItem *item = (*it); - mChangedItems.remove( item ); - mAddedItems.remove( item ); - mItemsUploading.remove( item ); - mItemsUploadError.remove( item ); - mItemsUploaded.append( item ); - } - } - - if ( mUploadProgress ) { - mUploadProgress->incCompletedItems(); - mUploadProgress->updateProgress(); - } -} - - -void GroupwareUploadJob::slotItemUploadedNew( const TQString &localId, const KURL &remoteURL ) -{ - kdDebug() << "GroupwareUploadJob::slotItemUploadedNew, upload successful: "<< remoteURL.url() << endl; - - const TQString &remote = remoteURL.path(); - // TODO: For a new item this won't return anything, so we need to insert the - // local<=>remote id map when creating the upload job... And maybe - const TQString &local = adaptor()->idMapper()->localId( remote ); - if ( !localId.isEmpty() ) { - adaptor()->deleteItem( localId ); - } - if ( !local.isEmpty() ) { -// adaptor()->itemUploadedNew( local, remoteURL ); - } - - KPIM::GroupwareUploadItem::List allit( mChangedItems ); - allit += mAddedItems; - allit += mItemsUploading; - allit += mItemsUploadError; - - - KPIM::GroupwareUploadItem::List::Iterator it = allit.begin(); - for ( ; it != allit.end(); ++it ) { - if ( (*it)->url().path() == remoteURL.path() ) { -kdDebug()<<"Found it in the list!"<<endl; - KPIM::GroupwareUploadItem *item = (*it); - mChangedItems.remove( item ); - mAddedItems.remove( item ); - mItemsUploading.remove( item ); - mItemsUploadError.remove( item ); - mItemsUploaded.append( item ); - } - } - - if ( mUploadProgress ) { - mUploadProgress->incCompletedItems(); - mUploadProgress->updateProgress(); - } -} - -void GroupwareUploadJob::slotItemDeleteError( const KURL &remoteURL, const TQString &/*error*/ ) -{ - // TODO: Add to error list, remove from uploading and toUpload list - kdDebug() << "GroupwareUploadJob::slotItemDeleteError, removal not successful: "<< remoteURL.url() << endl; - KPIM::GroupwareUploadItem::List allit( mDeletedItems ); - allit += mItemsUploading; - allit += mItemsUploaded; - - KPIM::GroupwareUploadItem::List::Iterator it = allit.begin(); - for ( ; it != allit.end(); ++it ) { - if ( (*it)->url().path() == remoteURL.path() ) { -kdDebug()<<"Found it in the list!"<<endl; - KPIM::GroupwareUploadItem *item = (*it); - mDeletedItems.remove( item ); - mItemsUploaded.remove( item ); - mItemsUploading.remove( item ); - mItemsUploadError.append( item ); - } - } - - if ( mUploadProgress ) { - mUploadProgress->incCompletedItems(); - mUploadProgress->updateProgress(); - } -} - -void GroupwareUploadJob::slotItemUploadError( const KURL &remoteURL, const TQString &/*error*/ ) -{ - // TODO: Add to error list, remove from uploading and toUpload list - kdDebug() << "GroupwareUploadJob::slotItemUploadError, removal not successful: "<< remoteURL.url() << endl; - KPIM::GroupwareUploadItem::List allit( mChangedItems ); - allit += mItemsUploading; - allit += mItemsUploaded; - - KPIM::GroupwareUploadItem::List::Iterator it = allit.begin(); - for ( ; it != allit.end(); ++it ) { - if ( (*it)->url().path() == remoteURL.path() ) { -kdDebug()<<"Found it in the list!"<<endl; - KPIM::GroupwareUploadItem *item = (*it); - mChangedItems.remove( item ); - mItemsUploaded.remove( item ); - mItemsUploading.remove( item ); - mItemsUploadError.append( item ); - } - } - - if ( mUploadProgress ) { - mUploadProgress->incCompletedItems(); - mUploadProgress->updateProgress(); - } -} - -void GroupwareUploadJob::slotItemUploadNewError( const TQString &/*localID*/, const TQString &remoteURL ) -{ - kdDebug(5006) << "GroupwareUploadJob::slotItemUploadNewError, removal not successful: "<< remoteURL << endl; - KPIM::GroupwareUploadItem::List allit( mAddedItems ); - allit += mItemsUploading; - allit += mItemsUploaded; - const KURL &url( remoteURL ); - - KPIM::GroupwareUploadItem::List::Iterator it = allit.begin(); - for ( ; it != allit.end(); ++it ) { - if ( (*it)->url().path() == url.path() ) { -kdDebug()<<"Found it in the list!"<<endl; - KPIM::GroupwareUploadItem *item = (*it); - mAddedItems.remove( item ); - mItemsUploaded.remove( item ); - mItemsUploading.remove( item ); - mItemsUploadError.append( item ); - } - } - - if ( mUploadProgress ) { - mUploadProgress->incCompletedItems(); - mUploadProgress->updateProgress(); - } -} - - -void GroupwareUploadJob::cancelSave() -{ - if ( mUploadJob ) mUploadJob->kill(); - mUploadJob = 0; - if ( mUploadProgress ) mUploadProgress->setComplete(); - mUploadProgress = 0; -} - -void GroupwareUploadJob::uploadCompleted() -{ - if ( !mItemsUploadError.isEmpty() ) { - error( i18n("1 item could not be uploaded.", "%n items could not be uploaded.", mItemsUploadError.count() ) ); - } - KPIM::GroupwareUploadItem::List items( mAddedItems ); - items += mChangedItems; - items += mDeletedItems; - items += mItemsUploading; - items += mItemsUploaded; - items += mItemsUploadError; - - mAddedItems.clear(); - mChangedItems.clear(); - mDeletedItems.clear(); - mItemsUploading.clear(); - mItemsUploaded.clear(); - mItemsUploadError.clear(); - items.setAutoDelete( true ); - items.clear(); - - if ( mUploadProgress ) { - mUploadProgress->setComplete(); - mUploadProgress = 0; - } - success(); - -} -#include "groupwareuploadjob.moc" |