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/libtdepim/tdeabcresourcecached.cpp

424 lines
11 KiB

/*
This file is part of libtdepim.
Copyright (c) 2004 Tobias Koenig <tokoe@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 <tqfile.h>
#include <tdeabc/vcardconverter.h>
#include <kdebug.h>
#include <tdelocale.h>
#include <kstandarddirs.h>
#include "tdeabcresourcecached.h"
using namespace TDEABC;
ResourceCached::ResourceCached( const TDEConfig *config )
: TDEABC::Resource( config ), mIdMapper( "tdeabc/uidmaps/" ),
mReloadPolicy( ReloadInterval ), mReloadInterval( 10 ),
mKABCReloadTimer( 0, "mKABCReloadTimer" ), mReloaded( false ),
mSavePolicy( SaveDelayed ), mSaveInterval( 10 ),
mKABCSaveTimer( 0, "mKABCSaveTimer" )
{
connect( &mKABCReloadTimer, TQT_SIGNAL( timeout() ), TQT_SLOT( slotKABCReload() ) );
connect( &mKABCSaveTimer, TQT_SIGNAL( timeout() ), TQT_SLOT( slotKABCSave() ) );
if (config)
this->readConfig(const_cast<TDEConfig *>(config));
}
ResourceCached::~ResourceCached()
{
}
void ResourceCached::setReloadPolicy( int i )
{
mReloadPolicy = i;
setupReloadTimer();
}
int ResourceCached::reloadPolicy() const
{
return mReloadPolicy;
}
void ResourceCached::setReloadInterval( int minutes )
{
mReloadInterval = minutes;
}
int ResourceCached::reloadInterval() const
{
return mReloadInterval;
}
void ResourceCached::setSavePolicy( int i )
{
mSavePolicy = i;
setupSaveTimer();
}
int ResourceCached::savePolicy() const
{
return mSavePolicy;
}
void ResourceCached::setSaveInterval( int minutes )
{
mSaveInterval = minutes;
}
int ResourceCached::saveInterval() const
{
return mSaveInterval;
}
void ResourceCached::writeConfig( TDEConfig *config )
{
config->writeEntry( "ReloadPolicy", mReloadPolicy );
config->writeEntry( "ReloadInterval", mReloadInterval );
config->writeEntry( "SavePolicy", mSavePolicy );
config->writeEntry( "SaveInterval", mSaveInterval );
config->writeEntry( "LastLoad", mLastLoad );
config->writeEntry( "LastSave", mLastSave );
TDEABC::Resource::writeConfig( config );
}
void ResourceCached::readConfig( TDEConfig *config )
{
mReloadPolicy = config->readNumEntry( "ReloadPolicy", ReloadNever );
mReloadInterval = config->readNumEntry( "ReloadInterval", 10 );
mSaveInterval = config->readNumEntry( "SaveInterval", 10 );
mSavePolicy = config->readNumEntry( "SavePolicy", SaveNever );
mLastLoad = config->readDateTimeEntry( "LastLoad" );
mLastSave = config->readDateTimeEntry( "LastSave" );
setupSaveTimer();
setupReloadTimer();
}
void ResourceCached::setupSaveTimer()
{
if ( mSavePolicy == SaveInterval ) {
kdDebug(5800) << "ResourceCached::setSavePolicy(): start save timer (interval "
<< mSaveInterval << " minutes)." << endl;
mKABCSaveTimer.start( mSaveInterval * 60 * 1000 ); // n minutes
} else {
mKABCSaveTimer.stop();
}
}
void ResourceCached::setupReloadTimer()
{
if ( mReloadPolicy == ReloadInterval ) {
kdDebug(5800) << "ResourceCached::setSavePolicy(): start reload timer "
"(interval " << mReloadInterval << " minutes)" << endl;
mKABCReloadTimer.start( mReloadInterval * 60 * 1000 ); // n minutes
} else {
mKABCReloadTimer.stop();
}
}
void ResourceCached::slotKABCReload()
{
if ( !isActive() ) return;
kdDebug(5800) << "ResourceCached::slotKABCReload()" << endl;
load();
}
void ResourceCached::slotKABCSave()
{
if ( !isActive() ) return;
kdDebug(5800) << "ResourceCached::slotKABCSave()" << endl;
TDEABC::Ticket *ticket = requestSaveTicket();
if ( ticket ) {
save( ticket );
}
}
void ResourceCached::insertAddressee( const Addressee &addr )
{
if ( !mAddrMap.contains( addr.uid() ) ) { // new contact
if ( mDeletedAddressees.contains( addr.uid() ) ) {
// it was first removed, then added, so it's an update...
mDeletedAddressees.remove( addr.uid() );
mAddrMap.insert( addr.uid(), addr );
mChangedAddressees.insert( addr.uid(), addr );
return;
}
mAddrMap.insert( addr.uid(), addr );
mAddedAddressees.insert( addr.uid(), addr );
} else {
TDEABC::Addressee oldAddressee = mAddrMap.find( addr.uid() ).data();
if ( oldAddressee != addr ) {
mAddrMap.remove( addr.uid() );
mAddrMap.insert( addr.uid(), addr );
mChangedAddressees.insert( addr.uid(), addr );
}
}
}
void ResourceCached::removeAddressee( const Addressee &addr )
{
if ( mAddedAddressees.contains( addr.uid() ) ) {
mAddedAddressees.remove( addr.uid() );
return;
}
if ( mDeletedAddressees.find( addr.uid() ) == mDeletedAddressees.end() )
mDeletedAddressees.insert( addr.uid(), addr );
mAddrMap.remove( addr.uid() );
}
void ResourceCached::loadCache()
{
mAddrMap.clear();
setIdMapperIdentifier();
mIdMapper.load();
// load cache
TQFile file( cacheFile() );
if ( !file.open( IO_ReadOnly ) )
return;
TDEABC::VCardConverter converter;
#if defined(KABC_VCARD_ENCODING_FIX)
TDEABC::Addressee::List list = converter.parseVCardsRaw( file.readAll().data() );
#else
TQTextStream s( &file );
s.setEncoding( TQTextStream::UnicodeUTF8 );
TDEABC::Addressee::List list = converter.parseVCards( s.read() );
#endif
TDEABC::Addressee::List::Iterator it;
for ( it = list.begin(); it != list.end(); ++it ) {
(*it).setResource( this );
(*it).setChanged( false );
mAddrMap.insert( (*it).uid(), *it );
}
file.close();
}
void ResourceCached::saveCache()
{
setIdMapperIdentifier();
mIdMapper.save();
// save cache
TQFile file( cacheFile() );
if ( !file.open( IO_WriteOnly ) )
return;
TDEABC::Addressee::List list = mAddrMap.values();
TDEABC::VCardConverter converter;
#if defined(KABC_VCARD_ENCODING_FIX)
TQCString vCard = converter.createVCardsRaw( list );
file.writeBlock( vCard, vCard.length() );
#else
TQString vCard = converter.createVCards( list );
file.writeBlock( vCard.utf8(), vCard.utf8().length() );
#endif
file.close();
}
void ResourceCached::clearCache()
{
// TEST ME
mAddrMap.clear();
}
void ResourceCached::cleanUpCache( const TDEABC::Addressee::List &addrList )
{
// load cache
TQFile file( cacheFile() );
if ( !file.open( IO_ReadOnly ) )
return;
TDEABC::VCardConverter converter;
#if defined(KABC_VCARD_ENCODING_FIX)
TDEABC::Addressee::List list = converter.parseVCardsRaw( file.readAll().data() );
#else
TQTextStream s( &file );
s.setEncoding( TQTextStream::UnicodeUTF8 );
TDEABC::Addressee::List list = converter.parseVCards( s.read() );
#endif
TDEABC::Addressee::List::Iterator cacheIt;
TDEABC::Addressee::List::ConstIterator it;
for ( cacheIt = list.begin(); cacheIt != list.end(); ++cacheIt ) {
bool found = false;
for ( it = addrList.begin(); it != addrList.end(); ++it ) {
if ( (*it).uid() == (*cacheIt).uid() )
found = true;
}
if ( !found ) {
mIdMapper.removeRemoteId( mIdMapper.remoteId( (*cacheIt).uid() ) );
mAddrMap.remove( (*cacheIt).uid() );
}
}
file.close();
}
KPIM::IdMapper& ResourceCached::idMapper()
{
return mIdMapper;
}
bool ResourceCached::hasChanges() const
{
return !( mAddedAddressees.isEmpty() &&
mChangedAddressees.isEmpty() &&
mDeletedAddressees.isEmpty() );
}
void ResourceCached::clearChanges()
{
mAddedAddressees.clear();
mChangedAddressees.clear();
mDeletedAddressees.clear();
}
void ResourceCached::clearChange( const TDEABC::Addressee &addr )
{
mAddedAddressees.remove( addr.uid() );
mChangedAddressees.remove( addr.uid() );
mDeletedAddressees.remove( addr.uid() );
}
void ResourceCached::clearChange( const TQString &uid )
{
mAddedAddressees.remove( uid );
mChangedAddressees.remove( uid );
mDeletedAddressees.remove( uid );
}
TDEABC::Addressee::List ResourceCached::addedAddressees() const
{
return mAddedAddressees.values();
}
TDEABC::Addressee::List ResourceCached::changedAddressees() const
{
return mChangedAddressees.values();
}
TDEABC::Addressee::List ResourceCached::deletedAddressees() const
{
return mDeletedAddressees.values();
}
TQString ResourceCached::cacheFile() const
{
return locateLocal( "cache", "tdeabc/tderesources/" + identifier() );
}
TQString ResourceCached::changesCacheFile( const TQString &type ) const
{
return locateLocal( "cache", "tdeabc/changescache/" + identifier() + "_" + type );
}
void ResourceCached::saveChangesCache( const TQMap<TQString, TDEABC::Addressee> &map, const TQString &type )
{
TQFile file( changesCacheFile( type ) );
const TDEABC::Addressee::List list = map.values();
if ( list.isEmpty() ) {
file.remove();
} else {
if ( !file.open( IO_WriteOnly ) ) {
kdError() << "Can't open changes cache file '" << file.name() << "' for saving." << endl;
return;
}
TDEABC::VCardConverter converter;
#if defined(KABC_VCARD_ENCODING_FIX)
const TQCString vCards = converter.createVCardsRaw( list );
file.writeBlock( vCards, vCards.length() );
#else
const TQString vCards = converter.createVCards( list );
TQCString content = vCards.utf8();
file.writeBlock( content, content.length() );
#endif
}
}
void ResourceCached::saveChangesCache()
{
saveChangesCache( mAddedAddressees, "added" );
saveChangesCache( mDeletedAddressees, "deleted" );
saveChangesCache( mChangedAddressees, "changed" );
}
void ResourceCached::loadChangesCache( TQMap<TQString, TDEABC::Addressee> &map, const TQString &type )
{
TQFile file( changesCacheFile( type ) );
if ( !file.open( IO_ReadOnly ) )
return;
TDEABC::VCardConverter converter;
#if defined(KABC_VCARD_ENCODING_FIX)
const TDEABC::Addressee::List list = converter.parseVCardsRaw( file.readAll().data() );
#else
TQTextStream s( &file );
s.setEncoding( TQTextStream::UnicodeUTF8 );
const TDEABC::Addressee::List list = converter.parseVCards( s.read() );
#endif
TDEABC::Addressee::List::ConstIterator it;
for ( it = list.begin(); it != list.end(); ++it )
map.insert( (*it).uid(), *it );
file.close();
}
void ResourceCached::loadChangesCache()
{
loadChangesCache( mAddedAddressees, "added" );
loadChangesCache( mDeletedAddressees, "deleted" );
loadChangesCache( mChangedAddressees, "changed" );
}
void ResourceCached::setIdMapperIdentifier()
{
mIdMapper.setIdentifier( type() + "_" + identifier() );
}
#include "tdeabcresourcecached.moc"