LADI
/
ladish
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
ladish/src/lash_proxy.cpp

399 lines
10 KiB
C++
Raw Blame History

// -*- Mode: C++ ; indent-tabs-mode: t -*-
/* This file is part of Patchage.
* Copyright (C) 2008 Nedko Arnaudov <nedko@arnaudov.name>
*
* Patchage 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.
*
* Patchage 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 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 St, Fifth Floor, Boston, MA 02110-1301, USA
*/
#include <boost/format.hpp>
#include "lash_proxy.hpp"
#include "session.hpp"
#define LASH_SERVICE "org.nongnu.LASH"
#define LASH_OBJECT "/"
#define LASH_IFACE_CONTROL "org.nongnu.LASH.Control"
using namespace std;
lash_proxy::lash_proxy(
Patchage* app,
session * session_ptr)
: _app(app)
, _session_ptr(session_ptr)
, _server_responding(false)
{
list<string> projects;
dbus_bus_add_match(_app->_dbus_connection, "type='signal',interface='" DBUS_INTERFACE_DBUS "',member=NameOwnerChanged,arg0='" LASH_SERVICE "'", NULL);
dbus_bus_add_match(_app->_dbus_connection, "type='signal',interface='" LASH_IFACE_CONTROL "',member=ProjectAdded", NULL);
dbus_bus_add_match(_app->_dbus_connection, "type='signal',interface='" LASH_IFACE_CONTROL "',member=ProjectClosed", NULL);
dbus_bus_add_match(_app->_dbus_connection, "type='signal',interface='" LASH_IFACE_CONTROL "',member=ProjectNameChanged", NULL);
dbus_connection_add_filter(_app->_dbus_connection, dbus_message_hook, this, NULL);
// get initial list of projects
// calling any method to updates server responding status
// this also actiavtes lash object if it not activated already
get_loaded_projects(projects);
for (list<string>::iterator iter = projects.begin(); iter != projects.end(); iter++)
{
session_ptr->project_add(*iter);
}
_app->set_lash_availability(_server_responding);
}
lash_proxy::~lash_proxy()
{
}
void
lash_proxy::error_msg(const std::string& msg) const
{
_app->error_msg((std::string)"[LASH] " + msg);
}
void
lash_proxy::info_msg(const std::string& msg) const
{
_app->info_msg((std::string)"[LASH] " + msg);
}
DBusHandlerResult
lash_proxy::dbus_message_hook(
DBusConnection * connection,
DBusMessage * message,
void * proxy)
{
const char * project_name;
const char * new_project_name;
const char * object_name;
const char * old_owner;
const char * new_owner;
assert(proxy);
lash_proxy * me = reinterpret_cast<lash_proxy *>(proxy);
assert(me->_app->_dbus_connection);
//me->info_msg("dbus_message_hook() called.");
// Handle signals we have subscribed for in attach()
if (dbus_message_is_signal(message, DBUS_INTERFACE_DBUS, "NameOwnerChanged"))
{
if (!dbus_message_get_args(
message, &me->_app->_dbus_error,
DBUS_TYPE_STRING, &object_name,
DBUS_TYPE_STRING, &old_owner,
DBUS_TYPE_STRING, &new_owner,
DBUS_TYPE_INVALID))
{
me->error_msg(str(boost::format("dbus_message_get_args() failed to extract NameOwnerChanged signal arguments (%s)") % me->_app->_dbus_error.message));
dbus_error_free(&me->_app->_dbus_error);
return DBUS_HANDLER_RESULT_HANDLED;
}
if ((string)object_name != LASH_SERVICE)
{
return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
}
if (old_owner[0] == '\0')
{
me->info_msg((string)"LASH activated.");
me->_app->set_lash_availability(true);
}
else if (new_owner[0] == '\0')
{
me->info_msg((string)"LASH deactivated.");
me->_app->set_lash_availability(false);
}
return DBUS_HANDLER_RESULT_HANDLED;
}
if (dbus_message_is_signal(message, LASH_IFACE_CONTROL, "ProjectAdded"))
{
if (!dbus_message_get_args( message, &me->_app->_dbus_error,
DBUS_TYPE_STRING, &project_name,
DBUS_TYPE_INVALID))
{
me->error_msg(str(boost::format("dbus_message_get_args() failed to extract ProjectAdded signal arguments (%s)") % me->_app->_dbus_error.message));
dbus_error_free(&me->_app->_dbus_error);
return DBUS_HANDLER_RESULT_HANDLED;
}
me->info_msg((string)"Project '" + project_name + "' added.");
me->_session_ptr->project_add(project_name);
return DBUS_HANDLER_RESULT_HANDLED;
}
if (dbus_message_is_signal(message, LASH_IFACE_CONTROL, "ProjectClosed"))
{
if (!dbus_message_get_args(
message, &me->_app->_dbus_error,
DBUS_TYPE_STRING, &project_name,
DBUS_TYPE_INVALID))
{
me->error_msg(str(boost::format("dbus_message_get_args() failed to extract ProjectClosed signal arguments (%s)") % me->_app->_dbus_error.message));
dbus_error_free(&me->_app->_dbus_error);
return DBUS_HANDLER_RESULT_HANDLED;
}
me->info_msg((string)"Project '" + project_name + "' closed.");
me->_session_ptr->project_close(project_name);
return DBUS_HANDLER_RESULT_HANDLED;
}
if (dbus_message_is_signal(message, LASH_IFACE_CONTROL, "ProjectNameChanged"))
{
if (!dbus_message_get_args(
message, &me->_app->_dbus_error,
DBUS_TYPE_STRING, &project_name,
DBUS_TYPE_STRING, &new_project_name,
DBUS_TYPE_INVALID))
{
me->error_msg(str(boost::format("dbus_message_get_args() failed to extract ProjectNameChanged signal arguments (%s)") % me->_app->_dbus_error.message));
dbus_error_free(&me->_app->_dbus_error);
return DBUS_HANDLER_RESULT_HANDLED;
}
me->info_msg((string)"Project '" + project_name + "' renamed to '" + new_project_name + "'.");
//me->_app->on_project_renamed(project_name, new_project_name);
return DBUS_HANDLER_RESULT_HANDLED;
}
return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
}
bool
lash_proxy::call(
bool response_expected,
const char* iface,
const char* method,
DBusMessage ** reply_ptr_ptr,
int in_type,
...)
{
va_list ap;
va_start(ap, in_type);
_server_responding = _app->dbus_call(
response_expected,
LASH_SERVICE,
LASH_OBJECT,
iface,
method,
reply_ptr_ptr,
in_type,
ap);
va_end(ap);
return _server_responding;
}
void
lash_proxy::get_loaded_projects(
list<string>& projects)
{
DBusMessage* reply_ptr;
const char * reply_signature;
DBusMessageIter iter;
DBusMessageIter array_iter;
const char * project_name;
if (!call(true, LASH_IFACE_CONTROL, "GetLoadedProjects", &reply_ptr, DBUS_TYPE_INVALID)) {
return;
}
reply_signature = dbus_message_get_signature(reply_ptr);
if (strcmp(reply_signature, "as") != 0)
{
error_msg((string)"GetLoadedProjects() reply signature mismatch. " + reply_signature);
goto unref;
}
dbus_message_iter_init(reply_ptr, &iter);
for (dbus_message_iter_recurse(&iter, &array_iter);
dbus_message_iter_get_arg_type(&array_iter) != DBUS_TYPE_INVALID;
dbus_message_iter_next(&array_iter))
{
dbus_message_iter_get_basic(&array_iter, &project_name);
projects.push_back(project_name);
}
unref:
dbus_message_unref(reply_ptr);
}
void
lash_proxy::get_available_projects(
list<lash_project_info>& projects)
{
DBusMessage * reply_ptr;
const char * reply_signature;
DBusMessageIter iter;
DBusMessageIter array_iter;
DBusMessageIter struct_iter;
DBusMessageIter dict_iter;
DBusMessageIter dict_entry_iter;
DBusMessageIter variant_iter;
const char * project_name;
const char * key;
const char * value_type;
dbus_uint32_t value_uint32;
lash_project_info project_info;
if (!call(true, LASH_IFACE_CONTROL, "GetProjects", &reply_ptr, DBUS_TYPE_INVALID))
{
return;
}
reply_signature = dbus_message_get_signature(reply_ptr);
if (strcmp(reply_signature, "a(sa{sv})") != 0)
{
error_msg((string)"GetLoadedProjects() reply signature mismatch. " + reply_signature);
goto unref;
}
dbus_message_iter_init(reply_ptr, &iter);
for (dbus_message_iter_recurse(&iter, &array_iter);
dbus_message_iter_get_arg_type(&array_iter) != DBUS_TYPE_INVALID;
dbus_message_iter_next(&array_iter))
{
dbus_message_iter_recurse(&array_iter, &struct_iter);
dbus_message_iter_get_basic(&struct_iter, &project_name);
project_info.name = project_name;
project_info.modification_time = 0;
dbus_message_iter_next(&struct_iter);
for (dbus_message_iter_recurse(&struct_iter, &dict_iter);
dbus_message_iter_get_arg_type(&dict_iter) != DBUS_TYPE_INVALID;
dbus_message_iter_next(&dict_iter))
{
dbus_message_iter_recurse(&dict_iter, &dict_entry_iter);
dbus_message_iter_get_basic(&dict_entry_iter, &key);
dbus_message_iter_next(&dict_entry_iter);
dbus_message_iter_recurse(&dict_entry_iter, &variant_iter);
value_type = dbus_message_iter_get_signature(&variant_iter);
if (value_type[0] != 0 && value_type[1] == 0)
{
switch (*value_type)
{
case DBUS_TYPE_UINT32:
dbus_message_iter_get_basic(&variant_iter, &value_uint32);
project_info.modification_time = value_uint32;
break;
}
}
}
projects.push_back(project_info);
}
unref:
dbus_message_unref(reply_ptr);
}
void
lash_proxy::load_project(
const string& project_name)
{
DBusMessage * reply_ptr;
const char * project_name_cstr;
project_name_cstr = project_name.c_str();
if (!call(true, LASH_IFACE_CONTROL, "LoadProject", &reply_ptr, DBUS_TYPE_STRING, &project_name_cstr, DBUS_TYPE_INVALID))
{
return;
}
dbus_message_unref(reply_ptr);
}
void
lash_proxy::save_all_projects()
{
DBusMessage * reply_ptr;
if (!call(true, LASH_IFACE_CONTROL, "Save", &reply_ptr, DBUS_TYPE_INVALID))
{
return;
}
dbus_message_unref(reply_ptr);
}
void
lash_proxy::save_project(
const string& project_name)
{
DBusMessage * reply_ptr;
const char * project_name_cstr;
project_name_cstr = project_name.c_str();
if (!call(true, LASH_IFACE_CONTROL, "SaveProject", &reply_ptr, DBUS_TYPE_STRING, &project_name_cstr, DBUS_TYPE_INVALID))
{
return;
}
dbus_message_unref(reply_ptr);
}
void
lash_proxy::close_project(
const string& project_name)
{
DBusMessage * reply_ptr;
const char * project_name_cstr;
project_name_cstr = project_name.c_str();
if (!call(true, LASH_IFACE_CONTROL, "CloseProject", &reply_ptr, DBUS_TYPE_STRING, &project_name_cstr, DBUS_TYPE_INVALID))
{
return;
}
dbus_message_unref(reply_ptr);
}
void
lash_proxy::close_all_projects()
{
DBusMessage * reply_ptr;
if (!call(true, LASH_IFACE_CONTROL, "Clear", &reply_ptr, DBUS_TYPE_INVALID))
{
return;
}
dbus_message_unref(reply_ptr);
}
Reference in New Issue View Git Blame Copy Permalink