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/kitchensync/libqopensync/group.cpp

293 lines
5.9 KiB

/*
This file is part of libqopensync.
Copyright (c) 2005 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.
*/
/** hack includes **/
#include <tqdom.h>
#include <tqfile.h>
/** hack includes **/
#include <opensync/opensync.h>
#include "conversion.h"
#include "group.h"
using namespace QSync;
/**
This class is a quick hack for OpenSync 0.19 and 0.20 because
the engine doesn't stores the filter settings itself when calling
osync_group_set_objtype_enabled(), so we have to store it for every
group in a separated config file. This class encapsulates it.
*/
GroupConfig::GroupConfig()
: mGroup( 0 )
{
}
TQStringList GroupConfig::activeObjectTypes() const
{
Q_ASSERT( mGroup );
const TQString fileName = TQString( "%1/filter.conf" ).arg( osync_group_get_configdir( mGroup ) );
TQFile file( fileName );
if ( !file.open( IO_ReadOnly ) )
return TQStringList();
TQDomDocument document;
TQString message;
if ( !document.setContent( &file, &message ) ) {
qDebug( "Error on loading %s: %s", fileName.latin1(), message.latin1() );
return TQStringList();
}
file.close();
TQStringList objectTypes;
TQDomElement element = document.documentElement();
TQDomNode node = element.firstChild();
while ( !node.isNull() ) {
TQDomElement childElement = node.toElement();
if ( !childElement.isNull() )
objectTypes.append( childElement.tagName() );
node = node.nextSibling();
}
return objectTypes;
}
void GroupConfig::setActiveObjectTypes( const TQStringList &objectTypes )
{
Q_ASSERT( mGroup );
TQDomDocument document( "Filter" );
document.appendChild( document.createProcessingInstruction(
"xml", "version=\"1.0\" encoding=\"UTF-8\"" ) );
TQDomElement element = document.createElement( "filter" );
document.appendChild( element );
for ( uint i = 0; i < objectTypes.count(); ++i ) {
TQDomElement entry = document.createElement( objectTypes[ i ] );
element.appendChild( entry );
}
const TQString fileName = TQString( "%1/filter.conf" ).arg( osync_group_get_configdir( mGroup ) );
TQFile file( fileName );
if ( !file.open( IO_WriteOnly ) )
return;
TQTextStream s( &file );
s.setEncoding( TQTextStream::UnicodeUTF8 );
s << document.toString();
file.close();
}
Group::Group()
: mGroup( 0 )
{
}
Group::~Group()
{
}
bool Group::isValid() const
{
return ( mGroup != 0 );
}
Group::Iterator Group::begin()
{
Iterator it( this );
it.mPos = 0;
return it;
}
Group::Iterator Group::end()
{
Iterator it( this );
it.mPos = memberCount();
return it;
}
void Group::setName( const TQString &name )
{
Q_ASSERT( mGroup );
osync_group_set_name( mGroup, name.latin1() );
}
TQString Group::name() const
{
Q_ASSERT( mGroup );
return TQString::tqfromLatin1( osync_group_get_name( mGroup ) );
}
void Group::setLastSynchronization( const TQDateTime &dateTime )
{
Q_ASSERT( mGroup );
if ( dateTime.isValid() )
osync_group_set_last_synchronization( mGroup, dateTime.toTime_t() );
}
TQDateTime Group::lastSynchronization() const
{
Q_ASSERT( mGroup );
TQDateTime dateTime;
time_t time = osync_group_get_last_synchronization( mGroup );
if ( time != 0 )
dateTime.setTime_t( time );
return dateTime;
}
Group::LockType Group::lock()
{
Q_ASSERT( mGroup );
OSyncLockState state = osync_group_lock( mGroup );
switch ( state ) {
default:
case OSYNC_LOCK_OK:
return LockOk;
break;
case OSYNC_LOCKED:
return Locked;
break;
case OSYNC_LOCK_STALE:
return LockStale;
break;
}
}
void Group::unlock( bool removeFile )
{
Q_ASSERT( mGroup );
osync_group_unlock( mGroup, removeFile );
}
Member Group::addMember()
{
Q_ASSERT( mGroup );
OSyncMember *omember = osync_member_new( mGroup );
Member member;
member.mMember = omember;
save();
return member;
}
void Group::removeMember( const Member &member )
{
Q_ASSERT( mGroup );
osync_group_remove_member( mGroup, member.mMember );
}
int Group::memberCount() const
{
Q_ASSERT( mGroup );
return osync_group_num_members( mGroup );
}
Member Group::memberAt( int pos ) const
{
Q_ASSERT( mGroup );
Member member;
if ( pos < 0 || pos >= memberCount() )
return member;
member.mMember = osync_group_nth_member( mGroup, pos );
return member;
}
int Group::filterCount() const
{
Q_ASSERT( mGroup );
return osync_group_num_filters( mGroup );
}
Filter Group::filterAt( int pos )
{
Q_ASSERT( mGroup );
Filter filter;
if ( pos < 0 || pos >= filterCount() )
return filter;
filter.mFilter = osync_group_nth_filter( mGroup, pos );
return filter;
}
Result Group::save()
{
Q_ASSERT( mGroup );
OSyncError *error = 0;
if ( !osync_group_save( mGroup, &error ) )
return Result( &error );
else
return Result();
}
void Group::setObjectTypeEnabled( const TQString &objectType, bool enabled )
{
Q_ASSERT( mGroup );
osync_group_set_objtype_enabled( mGroup, objectType.utf8(), enabled );
}
bool Group::isObjectTypeEnabled( const TQString &objectType ) const
{
return osync_group_objtype_enabled( mGroup, objectType.utf8() );
}
GroupConfig Group::config() const
{
Q_ASSERT( mGroup );
GroupConfig config;
config.mGroup = mGroup;
return config;
}