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.
tdepim/kresources/lib/kabc_resourcegroupwarebase.cpp

263 lines
7.0 KiB

/*
This file is part of kdepim.
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 program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 of the License, or
(at your option) any later version.
This program 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 General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
*/
#include "kabc_resourcegroupwarebase.h"
#include "kresources_groupwareprefs.h"
#include "folderlister.h"
#include "addressbookadaptor.h"
#include "groupwaredownloadjob.h"
#include "groupwareuploadjob.h"
#include <kabc/addressee.h>
#include <kabc/vcardconverter.h>
#include <klocale.h>
using namespace KABC;
ResourceGroupwareBase::ResourceGroupwareBase( const KConfig *config )
: ResourceCached( config ),
mPrefs(0), mFolderLister(0), mAdaptor(0), mDownloadJob(0), mUploadJob(0)
{
if ( config ) readConfig( config );
}
ResourceGroupwareBase::~ResourceGroupwareBase()
{
delete mPrefs;
mPrefs = 0;
}
KPIM::GroupwareDownloadJob *ResourceGroupwareBase::createDownloadJob(
AddressBookAdaptor *adaptor )
{
return new KPIM::GroupwareDownloadJob( adaptor );
}
KPIM::GroupwareUploadJob *ResourceGroupwareBase::createUploadJob(
AddressBookAdaptor *adaptor )
{
return new KPIM::GroupwareUploadJob( adaptor );
}
void ResourceGroupwareBase::setPrefs( KPIM::GroupwarePrefsBase *newprefs )
{
if ( !newprefs ) return;
if ( mPrefs ) delete mPrefs;
mPrefs = newprefs;
mPrefs->addGroupPrefix( identifier() );
mPrefs->readConfig();
if ( mFolderLister ) mFolderLister->readConfig( mPrefs );
}
void ResourceGroupwareBase::setFolderLister( KPIM::FolderLister *folderLister )
{
if ( !folderLister ) return;
if ( mFolderLister ) delete mFolderLister;
mFolderLister = folderLister;
if ( mPrefs ) mFolderLister->readConfig( mPrefs );
if ( mAdaptor ) {
mAdaptor->setFolderLister( mFolderLister );
mFolderLister->setAdaptor( mAdaptor );
}
}
void ResourceGroupwareBase::setAdaptor( AddressBookAdaptor *adaptor )
{
if ( !adaptor ) return;
if ( mAdaptor ) delete mAdaptor;
mAdaptor = adaptor;
mAdaptor->setFolderLister( mFolderLister );
if ( mFolderLister ) mFolderLister->setAdaptor( mAdaptor );
mAdaptor->setDownloadProgressMessage( i18n("Downloading addressbook") );
mAdaptor->setUploadProgressMessage( i18n("Uploading addressbook") );
if ( prefs() ) {
mAdaptor->setBaseURL( prefs()->url() );
mAdaptor->setUser( prefs()->user() );
mAdaptor->setPassword( prefs()->password() );
}
mAdaptor->setIdMapper( &idMapper() );
mAdaptor->setResource( this );
}
void ResourceGroupwareBase::init()
{
mDownloadJob = 0;
}
KPIM::GroupwarePrefsBase *ResourceGroupwareBase::createPrefs()
{
return new KPIM::GroupwarePrefsBase();
}
void ResourceGroupwareBase::readConfig( const KConfig */*config*/ )
{
kdDebug(5700) << "KABC::ResourceGroupwareBase::readConfig()" << endl;
// ResourceCached::readConfig( config );
if ( mPrefs ) {
mPrefs->readConfig();
if ( mFolderLister )
mFolderLister->readConfig( mPrefs );
}
}
void ResourceGroupwareBase::writeConfig( KConfig *config )
{
Resource::writeConfig( config );
if ( mPrefs ) {
if ( mFolderLister )
mFolderLister->writeConfig( mPrefs );
mPrefs->writeConfig();
}
}
Ticket *ResourceGroupwareBase::requestSaveTicket()
{
if ( !addressBook() ) {
kdDebug(5700) << "no addressbook" << endl;
return 0;
}
return createTicket( this );
}
void ResourceGroupwareBase::releaseSaveTicket( Ticket *ticket )
{
delete ticket;
}
bool ResourceGroupwareBase::doOpen()
{
return true;
}
void ResourceGroupwareBase::doClose()
{
kdDebug(5800) << "ResourceGroupwareBase::doClose()" << endl;
if ( mDownloadJob ) mDownloadJob->kill();
}
bool ResourceGroupwareBase::load()
{
return asyncLoad();
}
bool ResourceGroupwareBase::asyncLoad()
{
if ( mDownloadJob ) {
kdWarning() << "Download still in progress" << endl;
return false;
}
mAddrMap.clear();
loadCache();
mDownloadJob = createDownloadJob( mAdaptor );
connect( mDownloadJob, TQT_SIGNAL( result( KPIM::GroupwareJob * ) ),
TQT_SLOT( slotDownloadJobResult( KPIM::GroupwareJob * ) ) );
return true;
}
void ResourceGroupwareBase::slotDownloadJobResult( KPIM::GroupwareJob *job )
{
kdDebug(5800) << "ResourceGroupwareBase::slotJobResult(): " << endl;
if ( job->error() ) {
kdError() << "job failed: " << job->errorString() << endl;
} else {
emit loadingFinished( this );
if ( addressBook() )
addressBook()->emitAddressBookChanged();
}
mDownloadJob = 0;
}
bool ResourceGroupwareBase::save( Ticket *ticket )
{
return asyncSave( ticket );
}
bool ResourceGroupwareBase::asyncSave( Ticket* )
{
if ( mUploadJob ) {
// FIXME: If the user cancels, need to reset the mUploadJob variable to 0.
kdWarning() << "Upload still in progress." << endl;
return false;
}
mUploadJob = createUploadJob( mAdaptor );
connect( mUploadJob, TQT_SIGNAL( result( KPIM::GroupwareJob * ) ),
TQT_SLOT( slotUploadJobResult( KPIM::GroupwareJob * ) ) );
KABC::Addressee::List addr;
KABC::Addressee::List::Iterator it;
KPIM::GroupwareUploadItem::List addedItems, changedItems, deletedItems;
addr = addedAddressees();
for( it = addr.begin(); it != addr.end(); ++it ) {
addedItems.append( adaptor()->newUploadItem( *it,
KPIM::GroupwareUploadItem::Added ) );
}
// TODO: Check if the item has changed on the server...
// In particular, check if the version we based our change on is still current
// on the server
addr = changedAddressees();
for( it = addr.begin(); it != addr.end(); ++it ) {
changedItems.append( adaptor()->newUploadItem( *it,
KPIM::GroupwareUploadItem::Changed ) );
}
addr = deletedAddressees();
for( it = addr.begin(); it != addr.end(); ++it ) {
deletedItems.append( adaptor()->newUploadItem( *it,
KPIM::GroupwareUploadItem::Deleted ) );
}
mUploadJob->setAddedItems( addedItems );
mUploadJob->setChangedItems( changedItems );
mUploadJob->setDeletedItems( deletedItems );
return true;
}
void ResourceGroupwareBase::slotUploadJobResult( KPIM::GroupwareJob *job )
{
kdDebug(5800) << "ResourceGroupwareBase::slotJobResult(): " << endl;
if ( job->error() ) {
kdError() << "job failed: " << job->errorString() << endl;
} else {
// FIXME
}
mUploadJob = 0;
}
#include "kabc_resourcegroupwarebase.moc"