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/opensyncdbus/dbusclient.cpp

274 lines
7.1 KiB

/*
This file is part of KDE.
Copyright (c) 2006 Cornelius Schumacher <schumacher@kde.org>
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 "dbusclient.h"
#include <libqopensync/environment.h>
#include <libqopensync/group.h>
#include <dbus/qdbuserror.h>
#include <dbus/qdbusconnection.h>
#include <dbus/qdbusmessage.h>
#include <dbus/qdbusproxy.h>
#include <tqapplication.h>
#include <tqtimer.h>
#include <iostream>
OpenSyncService::OpenSyncService()
: mConnection( 0 )
{
}
void OpenSyncService::setConnection( TQDBusConnection *connection )
{
mConnection = connection;
mConnection->registerObject( "/ABC", this );
}
bool OpenSyncService::handleMethodCall( const TQDBusMessage &message )
{
tqDebug( "OpenSyncService::handleMethodCall()" );
tqDebug( " Interface: %s", message.interface().latin1() );
tqDebug( " Path: %s", message.path().latin1() );
tqDebug( " Member: %s", message.member().latin1() );
tqDebug( " Sender: %s", message.sender().latin1() );
if ( message.interface() != "org.opensync.SyncEngine" ) return false;
TQDBusMessage reply;
TQString function = message.member();
if ( function == "hello" ) {
reply = hello( message );
} else if ( function == "randomNumber" ) {
reply = randomNumber( message );
} else if ( function == "listGroups" ) {
reply = listGroups( message );
} else if ( function == "listPlugins" ) {
reply = listPlugins( message );
} else if ( function == "showGroup" ) {
reply = showGroup( message );
} else if ( function == "showMember" ) {
reply = showMember( message );
} else {
return false;
}
mConnection->send( reply );
return true;
}
TQDBusMessage OpenSyncService::showMember( const TQDBusMessage &message )
{
if ( message.count() != 2 ) {
return error( message, "arg_count",
TQString("Wrong number of arguments. Expected 2, got %1.")
.arg( message.count() ) );
}
TQString groupName = message[ 0 ].toString();
if ( groupName.isEmpty() ) {
return error( message, "missing_arg", "Missing argument: group name." );
}
bool ok;
int memberId = message[ 1 ].toInt( &ok );
if ( !ok ) {
return error( message, "missing_arg", "Missing argument: member id." );
}
TQDBusMessage reply;
QSync::Environment env;
QSync::Result result = env.initialize();
if ( result.isError() ) {
return error( message, result.name(), result.message() );
} else {
reply = TQDBusMessage::methodReply( message );
QSync::Group group = env.groupByName( groupName );
if ( !group.isValid() ) {
return error( message, "group_name", TQString("Unknown group '%1'.")
.arg( groupName ) );
}
QSync::Member member = group.memberById( memberId );
if ( !member.isValid() ) {
return error( message, "member_id",
TQString("Unknown member id '%1' in group '%2'.").arg( groupName )
.arg( memberId ) );
}
reply.append( memberId );
reply.append( member.pluginName() );
env.finalize();
}
return reply;
}
TQDBusMessage OpenSyncService::showGroup( const TQDBusMessage &message )
{
if ( message.count() != 1 ) {
return error( message, "arg_count",
TQString("Wrong number of arguments. Expected 1, got %1")
.arg( message.count() ) );
}
TQString groupName = message[ 0 ].toString();
if ( groupName.isEmpty() ) {
return error( message, "missing_arg", "Missing argument group name." );
}
TQDBusMessage reply;
QSync::Environment env;
QSync::Result result = env.initialize();
if ( result.isError() ) {
return error( message, result.name(), result.message() );
} else {
reply = TQDBusMessage::methodReply( message );
QSync::Group group = env.groupByName( groupName );
if ( !group.isValid() ) {
return error( message, "group_name", TQString("Unknown group '%1'")
.arg( groupName ) );
}
QSync::Group::Iterator it( &group );
for( it = group.begin(); it != group.end(); ++it ) {
QSync::Member member = *it;
reply.append( TQVariant( member.id() ) );
}
env.finalize();
}
return reply;
}
TQDBusMessage OpenSyncService::error( const TQDBusMessage &message,
const TQString &errorCode,
const TQString &errorMessage )
{
TQDBusError error( "org.opensync." + errorCode, errorMessage );
return TQDBusMessage::methodError( message, error );
}
TQDBusMessage OpenSyncService::listPlugins( const TQDBusMessage &message )
{
TQDBusMessage reply;
QSync::Environment env;
QSync::Result result = env.initialize();
if ( result.isError() ) {
TQDBusError error( result.name(), result.message() );
reply = TQDBusMessage::methodError( message, error );
} else {
reply = TQDBusMessage::methodReply( message );
QSync::Environment::PluginIterator it( env.pluginBegin() );
for ( ; it != env.pluginEnd(); ++it ) {
reply.append( TQVariant( (*it).name() ) );
}
env.finalize();
}
return reply;
}
TQDBusMessage OpenSyncService::listGroups( const TQDBusMessage &message )
{
TQDBusMessage reply;
QSync::Environment env;
QSync::Result result = env.initialize();
if ( result.isError() ) {
TQDBusError error( result.name(), result.message() );
reply = TQDBusMessage::methodError( message, error );
} else {
reply = TQDBusMessage::methodReply( message );
QSync::Environment::GroupIterator it( env.groupBegin() );
for ( ; it != env.groupEnd(); ++it ) {
reply.append( TQVariant( (*it).name() ) );
}
env.finalize();
}
return reply;
}
TQDBusMessage OpenSyncService::hello( const TQDBusMessage &message )
{
TQDBusMessage reply = TQDBusMessage::methodReply( message );
// TQDBusError error;
// reply = TQDBusMessage::methodError( message, error );
reply.append( TQVariant( TQString( "Hello!" ) ) );
return reply;
}
TQDBusMessage OpenSyncService::randomNumber( const TQDBusMessage &message )
{
TQDBusMessage reply = TQDBusMessage::methodReply( message );
int number = rand();
reply.append( TQVariant( number ) );
return reply;
}
int main( int argc, char *argv[] )
{
TQApplication app(argc, argv);
std::cout << "Hello" << std::endl;
TQDBusConnection connection = TQDBusConnection::addConnection(
TQDBusConnection::SessionBus );
if ( !connection.isConnected() ) {
tqFatal("Cannot connect to session bus");
}
connection.requestName( "org.opensync.SyncEngine",
TQDBusConnection::NoReplace );
OpenSyncService service;
service.setConnection( &connection );
return app.exec();
}
//#include "dbusclient.moc"