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.
424 lines
11 KiB
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, TQ_SIGNAL( timeout() ), TQ_SLOT( slotKABCReload() ) );
|
|
connect( &mKABCSaveTimer, TQ_SIGNAL( timeout() ), TQ_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"
|