summaryrefslogtreecommitdiffstats
path: root/kitchensync/opensyncdbus/dbusclient.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'kitchensync/opensyncdbus/dbusclient.cpp')
-rw-r--r--kitchensync/opensyncdbus/dbusclient.cpp273
1 files changed, 0 insertions, 273 deletions
diff --git a/kitchensync/opensyncdbus/dbusclient.cpp b/kitchensync/opensyncdbus/dbusclient.cpp
deleted file mode 100644
index 21d4f798..00000000
--- a/kitchensync/opensyncdbus/dbusclient.cpp
+++ /dev/null
@@ -1,273 +0,0 @@
-/*
- 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"