summaryrefslogtreecommitdiffstats
path: root/src/LashProxy.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/LashProxy.cpp')
-rw-r--r--src/LashProxy.cpp781
1 files changed, 781 insertions, 0 deletions
diff --git a/src/LashProxy.cpp b/src/LashProxy.cpp
new file mode 100644
index 0000000..1d1580d
--- /dev/null
+++ b/src/LashProxy.cpp
@@ -0,0 +1,781 @@
+// -*- 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 <string.h>
+#include <boost/shared_ptr.hpp>
+#include <boost/format.hpp>
+
+#include "LashProxy.hpp"
+#include "Session.hpp"
+#include "Project.hpp"
+#include "LashClient.hpp"
+#include "DBus.hpp"
+
+#define LASH_SERVICE "org.nongnu.LASH"
+#define LASH_OBJECT "/"
+#define LASH_IFACE_CONTROL "org.nongnu.LASH.Control"
+
+using namespace std;
+using boost::shared_ptr;
+
+struct LashProxyImpl {
+ void init(Patchage* app);
+
+ void fetch_loaded_projects();
+ void fetch_project_clients(shared_ptr<Project> project);
+
+ void error_msg(const std::string& msg);
+ void info_msg(const std::string& msg);
+
+ static
+ DBusHandlerResult
+ dbus_message_hook(
+ DBusConnection* connection,
+ DBusMessage* message,
+ void* proxy);
+
+ bool
+ call(
+ bool response_expected,
+ const char* iface,
+ const char* method,
+ DBusMessage** reply_ptr,
+ int in_type,
+ ...);
+
+ shared_ptr<Project>
+ on_project_added(const string& name);
+
+ shared_ptr<LashClient>
+ on_client_added(
+ shared_ptr<Project> project,
+ string id,
+ string name);
+
+ bool _server_responding;
+ Session* _session;
+ LashProxy* _interface;
+ Patchage* _app;
+};
+
+LashProxy::LashProxy(Patchage* app, Session* session)
+{
+ _impl = new LashProxyImpl;
+ _impl->_interface = this;
+ _impl->_session = session;
+ _impl->_app = app;
+ _impl->init(app);
+}
+
+LashProxy::~LashProxy()
+{
+ delete _impl;
+}
+
+void
+LashProxyImpl::init(Patchage* app)
+{
+ _server_responding = false;
+
+ 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=ProjectAppeared", NULL);
+ dbus_bus_add_match(app->dbus()->connection(), "type='signal',interface='" LASH_IFACE_CONTROL "',member=ProjectDisappeared", NULL);
+ dbus_bus_add_match(app->dbus()->connection(), "type='signal',interface='" LASH_IFACE_CONTROL "',member=ProjectNameChanged", NULL);
+ dbus_bus_add_match(app->dbus()->connection(), "type='signal',interface='" LASH_IFACE_CONTROL "',member=ProjectModifiedStatusChanged", NULL);
+ dbus_bus_add_match(app->dbus()->connection(), "type='signal',interface='" LASH_IFACE_CONTROL "',member=ProjectDescriptionChanged", NULL);
+ dbus_bus_add_match(app->dbus()->connection(), "type='signal',interface='" LASH_IFACE_CONTROL "',member=ProjectNotesChanged", NULL);
+ dbus_bus_add_match(app->dbus()->connection(), "type='signal',interface='" LASH_IFACE_CONTROL "',member=ClientAppeared", NULL);
+ dbus_bus_add_match(app->dbus()->connection(), "type='signal',interface='" LASH_IFACE_CONTROL "',member=ClientDisappeared", NULL);
+ dbus_bus_add_match(app->dbus()->connection(), "type='signal',interface='" LASH_IFACE_CONTROL "',member=ClientNameChanged", 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
+ fetch_loaded_projects();
+
+ app->set_lash_available(_server_responding);
+}
+
+void
+LashProxyImpl::error_msg(const std::string& msg)
+{
+ _app->error_msg((std::string)"[LASH] " + msg);
+}
+
+void
+LashProxyImpl::info_msg(const std::string& msg)
+{
+ _app->info_msg((std::string)"[LASH] " + msg);
+}
+
+DBusHandlerResult
+LashProxyImpl::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;
+ const char* value_string;
+ const char* client_id;
+ const char* client_name;
+ dbus_bool_t modified_status;
+ shared_ptr<Project> project;
+ shared_ptr<LashClient> client;
+
+ assert(proxy);
+ LashProxyImpl* me = reinterpret_cast<LashProxyImpl*>(proxy);
+ assert(me->_app->dbus()->connection());
+
+ Patchage* const app = me->_app;
+
+ //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, &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)") % app->dbus()->error().message));
+ dbus_error_free(&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("LASH activated.");
+ app->set_lash_available(true);
+ } else if (new_owner[0] == '\0') {
+ me->info_msg((string)"LASH deactivated.");
+ app->set_lash_available(false);
+ }
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ if (dbus_message_is_signal(message, LASH_IFACE_CONTROL, "ProjectAppeared")) {
+ if (!dbus_message_get_args( message, &app->dbus()->error(),
+ DBUS_TYPE_STRING, &project_name,
+ DBUS_TYPE_INVALID)) {
+ me->error_msg(str(boost::format("dbus_message_get_args() failed to extract ProjectAppeared signal arguments (%s)") % app->dbus()->error().message));
+ dbus_error_free(&app->dbus()->error());
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ me->info_msg((string)"Project '" + project_name + "' appeared.");
+ me->on_project_added(project_name);
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ if (dbus_message_is_signal(message, LASH_IFACE_CONTROL, "ProjectDisappeared")) {
+ if (!dbus_message_get_args(
+ message, &app->dbus()->error(),
+ DBUS_TYPE_STRING, &project_name,
+ DBUS_TYPE_INVALID)) {
+ me->error_msg(str(boost::format("dbus_message_get_args() failed to extract ProjectDisappeared signal arguments (%s)") % app->dbus()->error().message));
+ dbus_error_free(&app->dbus()->error());
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ me->info_msg((string)"Project '" + project_name + "' disappeared.");
+ me->_session->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, &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)") % app->dbus()->error().message));
+ dbus_error_free(&app->dbus()->error());
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ me->info_msg((string)"Project '" + project_name + "' renamed to '" + new_project_name + "'.");
+
+ project = me->_session->find_project_by_name(project_name);
+ if (project) {
+ project->on_name_changed(new_project_name);
+ }
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ if (dbus_message_is_signal(message, LASH_IFACE_CONTROL, "ProjectModifiedStatusChanged")) {
+ if (!dbus_message_get_args(
+ message, &app->dbus()->error(),
+ DBUS_TYPE_STRING, &project_name,
+ DBUS_TYPE_BOOLEAN, &modified_status,
+ DBUS_TYPE_INVALID)) {
+ me->error_msg(str(boost::format("dbus_message_get_args() failed to extract ProjectModifiedStatusChanged signal arguments (%s)") % app->dbus()->error().message));
+ dbus_error_free(&app->dbus()->error());
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ me->info_msg((string)"Project '" + project_name + "' modified status changed to '" + (modified_status ? "true" : "false") + "'.");
+
+ project = me->_session->find_project_by_name(project_name);
+ if (project) {
+ project->on_modified_status_changed(modified_status);
+ }
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ if (dbus_message_is_signal(message, LASH_IFACE_CONTROL, "ProjectDescriptionChanged")) {
+ if (!dbus_message_get_args(
+ message, &app->dbus()->error(),
+ DBUS_TYPE_STRING, &project_name,
+ DBUS_TYPE_STRING, &value_string,
+ DBUS_TYPE_INVALID)) {
+ me->error_msg(str(boost::format("dbus_message_get_args() failed to extract ProjectDescriptionChanged signal arguments (%s)") % app->dbus()->error().message));
+ dbus_error_free(&app->dbus()->error());
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ me->info_msg((string)"Project '" + project_name + "' description changed.");
+
+ project = me->_session->find_project_by_name(project_name);
+ if (project) {
+ project->on_description_changed(value_string);
+ }
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ if (dbus_message_is_signal(message, LASH_IFACE_CONTROL, "ProjectNotesChanged")) {
+ if (!dbus_message_get_args(
+ message, &app->dbus()->error(),
+ DBUS_TYPE_STRING, &project_name,
+ DBUS_TYPE_STRING, &value_string,
+ DBUS_TYPE_INVALID)) {
+ me->error_msg(str(boost::format("dbus_message_get_args() failed to extract ProjectNotesChanged signal arguments (%s)") % app->dbus()->error().message));
+ dbus_error_free(&app->dbus()->error());
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ me->info_msg((string)"Project '" + project_name + "' notes changed.");
+
+ project = me->_session->find_project_by_name(project_name);
+ if (project) {
+ project->on_notes_changed(value_string);
+ }
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ if (dbus_message_is_signal(message, LASH_IFACE_CONTROL, "ClientAppeared")) {
+ if (!dbus_message_get_args(
+ message, &app->dbus()->error(),
+ DBUS_TYPE_STRING, &client_id,
+ DBUS_TYPE_STRING, &project_name,
+ DBUS_TYPE_STRING, &client_name,
+ DBUS_TYPE_INVALID)) {
+ me->error_msg(str(boost::format("dbus_message_get_args() failed to extract ClientAppeared signal arguments (%s)") % app->dbus()->error().message));
+ dbus_error_free(&app->dbus()->error());
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ me->info_msg((string)"Client '" + client_id + "':'" + client_name + "' appeared in project '" + project_name + "'.");
+
+ project = me->_session->find_project_by_name(project_name);
+ if (project) {
+ me->on_client_added(project, client_id, client_name);
+ }
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ if (dbus_message_is_signal(message, LASH_IFACE_CONTROL, "ClientDisappeared")) {
+ if (!dbus_message_get_args(
+ message, &app->dbus()->error(),
+ DBUS_TYPE_STRING, &client_id,
+ DBUS_TYPE_STRING, &project_name,
+ DBUS_TYPE_INVALID)) {
+ me->error_msg(str(boost::format("dbus_message_get_args() failed to extract ClientDisappeared signal arguments (%s)") % app->dbus()->error().message));
+ dbus_error_free(&app->dbus()->error());
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ me->info_msg((string)"Client '" + client_id + "' of project '" + project_name + "' disappeared.");
+
+ client = me->_session->find_client_by_id(client_id);
+ if (client) {
+ client->get_project()->on_client_removed(client_id);
+ me->_session->client_remove(client_id);
+ }
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ if (dbus_message_is_signal(message, LASH_IFACE_CONTROL, "ClientNameChanged")) {
+ if (!dbus_message_get_args(
+ message, &app->dbus()->error(),
+ DBUS_TYPE_STRING, &client_id,
+ DBUS_TYPE_STRING, &client_name,
+ DBUS_TYPE_INVALID)) {
+ me->error_msg(str(boost::format("dbus_message_get_args() failed to extract ClientNameChanged signal arguments (%s)") % app->dbus()->error().message));
+ dbus_error_free(&app->dbus()->error());
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ me->info_msg((string)"Client '" + client_id + "' name changed to '" + client_name + "'.");
+
+ client = me->_session->find_client_by_id(client_id);
+ if (client) {
+ client->on_name_changed(client_name);
+ }
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
+}
+
+bool
+LashProxyImpl::call(
+ bool response_expected,
+ const char* iface,
+ const char* method,
+ DBusMessage** reply_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,
+ in_type,
+ ap);
+
+ va_end(ap);
+ return _server_responding;
+}
+
+void
+LashProxyImpl::fetch_loaded_projects()
+{
+ DBusMessage* reply_ptr;
+ const char* reply_signature;
+ DBusMessageIter iter;
+ DBusMessageIter array_iter;
+ const char* project_name;
+ shared_ptr<Project> project;
+
+ if (!call(true, LASH_IFACE_CONTROL, "ProjectsGet", &reply_ptr, DBUS_TYPE_INVALID)) {
+ return;
+ }
+
+ reply_signature = dbus_message_get_signature(reply_ptr);
+
+ if (strcmp(reply_signature, "as") != 0) {
+ error_msg((string)"ProjectsGet() 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);
+ project = on_project_added(project_name);
+ fetch_project_clients(project);
+ }
+
+unref:
+ dbus_message_unref(reply_ptr);
+}
+
+void
+LashProxyImpl::fetch_project_clients(shared_ptr<Project> project)
+{
+ DBusMessage* reply_ptr;
+ const char* reply_signature;
+ DBusMessageIter iter;
+ DBusMessageIter array_iter;
+ DBusMessageIter struct_iter;
+ const char* client_id;
+ const char* client_name;
+
+ const string& project_name = project->get_name();
+ const char* const project_name_cstr = project_name.c_str();
+
+ if (!call(
+ true,
+ LASH_IFACE_CONTROL,
+ "ProjectGetClients",
+ &reply_ptr,
+ DBUS_TYPE_STRING, &project_name_cstr,
+ DBUS_TYPE_INVALID)) {
+ return;
+ }
+
+ reply_signature = dbus_message_get_signature(reply_ptr);
+
+ if (strcmp(reply_signature, "a(ss)") != 0) {
+ error_msg((string)"ProjectGetClients() 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, &client_id);
+ dbus_message_iter_next(&struct_iter);
+ dbus_message_iter_get_basic(&struct_iter, &client_name);
+ dbus_message_iter_next(&struct_iter);
+
+ on_client_added(project, client_id, client_name);
+ }
+
+unref:
+ dbus_message_unref(reply_ptr);
+}
+
+shared_ptr<Project>
+LashProxyImpl::on_project_added(const string& name)
+{
+ shared_ptr<Project> project(new Project(_interface, name));
+
+ _session->project_add(project);
+
+ return project;
+}
+
+shared_ptr<LashClient>
+LashProxyImpl::on_client_added(
+ shared_ptr<Project> project,
+ string id,
+ string name)
+{
+ shared_ptr<LashClient> client(
+ new LashClient(
+ _interface,
+ project.get(),
+ id,
+ name));
+
+ project->on_client_added(client);
+ _session->client_add(client);
+
+ return client;
+}
+
+void
+LashProxy::get_available_projects(list<ProjectInfo>& 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;
+ const char* value_string;
+ ProjectInfo project_info;
+
+ if (!_impl->call(true, LASH_IFACE_CONTROL, "ProjectsGetAvailable", &reply_ptr, DBUS_TYPE_INVALID)) {
+ return;
+ }
+
+ reply_signature = dbus_message_get_signature(reply_ptr);
+
+ if (strcmp(reply_signature, "a(sa{sv})") != 0) {
+ _impl->error_msg((string)"ProjectsGetAvailable() 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;
+ project_info.description.erase();
+
+ 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:
+ if (strcmp(key, "Modification Time") == 0) {
+ dbus_message_iter_get_basic(&variant_iter, &value_uint32);
+ project_info.modification_time = value_uint32;
+ }
+ break;
+ case DBUS_TYPE_STRING:
+ if (strcmp(key, "Description") == 0) {
+ dbus_message_iter_get_basic(&variant_iter, &value_string);
+ project_info.description = value_string;
+ }
+ break;
+ }
+ }
+ }
+
+ projects.push_back(project_info);
+ }
+
+unref:
+ dbus_message_unref(reply_ptr);
+}
+
+void
+LashProxy::load_project(const string& project_name)
+{
+ DBusMessage* reply_ptr;
+ const char* const project_name_cstr = project_name.c_str();
+
+ if (!_impl->call(true, LASH_IFACE_CONTROL, "ProjectOpen", &reply_ptr, DBUS_TYPE_STRING, &project_name_cstr, DBUS_TYPE_INVALID)) {
+ return;
+ }
+
+ dbus_message_unref(reply_ptr);
+}
+
+void
+LashProxy::save_all_projects()
+{
+ DBusMessage* reply_ptr;
+
+ if (!_impl->call(true, LASH_IFACE_CONTROL, "ProjectsSaveAll", &reply_ptr, DBUS_TYPE_INVALID)) {
+ return;
+ }
+
+ dbus_message_unref(reply_ptr);
+}
+
+void
+LashProxy::save_project(const string& project_name)
+{
+ DBusMessage* reply_ptr;
+ const char* const project_name_cstr = project_name.c_str();
+
+ if (!_impl->call(true, LASH_IFACE_CONTROL, "ProjectSave", &reply_ptr, DBUS_TYPE_STRING, &project_name_cstr, DBUS_TYPE_INVALID)) {
+ return;
+ }
+
+ dbus_message_unref(reply_ptr);
+}
+
+void
+LashProxy::close_project(const string& project_name)
+{
+ DBusMessage* reply_ptr;
+ const char* const project_name_cstr = project_name.c_str();
+
+ if (!_impl->call(true, LASH_IFACE_CONTROL, "ProjectClose", &reply_ptr, DBUS_TYPE_STRING, &project_name_cstr, DBUS_TYPE_INVALID)) {
+ return;
+ }
+
+ dbus_message_unref(reply_ptr);
+}
+
+void
+LashProxy::close_all_projects()
+{
+ DBusMessage* reply_ptr;
+
+ if (!_impl->call(true, LASH_IFACE_CONTROL, "ProjectsCloseAll", &reply_ptr, DBUS_TYPE_INVALID)) {
+ return;
+ }
+
+ dbus_message_unref(reply_ptr);
+}
+
+void
+LashProxy::project_rename(const string& old_name, const string& new_name)
+{
+ DBusMessage* reply_ptr;
+ const char* const old_name_cstr = old_name.c_str();
+ const char* const new_name_cstr = new_name.c_str();
+
+ if (!_impl->call(
+ true,
+ LASH_IFACE_CONTROL,
+ "ProjectRename",
+ &reply_ptr,
+ DBUS_TYPE_STRING, &old_name_cstr,
+ DBUS_TYPE_STRING, &new_name_cstr,
+ DBUS_TYPE_INVALID)) {
+ return;
+ }
+
+ dbus_message_unref(reply_ptr);
+}
+
+void
+LashProxy::get_loaded_project_properties(
+ const string& name,
+ LoadedProjectProperties& properties)
+{
+ DBusMessage* reply_ptr;
+ const char* reply_signature;
+ DBusMessageIter iter;
+ DBusMessageIter dict_iter;
+ DBusMessageIter dict_entry_iter;
+ DBusMessageIter variant_iter;
+ const char* key;
+ const char* value_type;
+ dbus_bool_t value_bool;
+ const char* value_string;
+
+ const char* const project_name_cstr = name.c_str();
+
+ if (!_impl->call(
+ true,
+ LASH_IFACE_CONTROL,
+ "ProjectGetProperties",
+ &reply_ptr,
+ DBUS_TYPE_STRING, &project_name_cstr,
+ DBUS_TYPE_INVALID)) {
+ return;
+ }
+
+ reply_signature = dbus_message_get_signature(reply_ptr);
+
+ if (strcmp(reply_signature, "a{sv}") != 0) {
+ _impl->error_msg((string)"ProjectGetProperties() reply signature mismatch. " + reply_signature);
+ goto unref;
+ }
+
+ dbus_message_iter_init(reply_ptr, &iter);
+
+ for (dbus_message_iter_recurse(&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_BOOLEAN:
+ if (strcmp(key, "Modified Status") == 0) {
+ dbus_message_iter_get_basic(&variant_iter, &value_bool);
+ properties.modified_status = value_bool;
+ }
+ break;
+ case DBUS_TYPE_STRING:
+ if (strcmp(key, "Description") == 0) {
+ dbus_message_iter_get_basic(&variant_iter, &value_string);
+ properties.description = value_string;
+ } else if (strcmp(key, "Notes") == 0) {
+ dbus_message_iter_get_basic(&variant_iter, &value_string);
+ properties.notes = value_string;
+ }
+ break;
+ }
+ }
+ }
+
+unref:
+ dbus_message_unref(reply_ptr);
+}
+
+void
+LashProxy::project_set_description(const string& project_name, const string& description)
+{
+ DBusMessage* reply_ptr;
+ const char* const project_name_cstr = project_name.c_str();
+ const char* const description_cstr = description.c_str();
+
+ if (!_impl->call(
+ true,
+ LASH_IFACE_CONTROL,
+ "ProjectSetDescription",
+ &reply_ptr,
+ DBUS_TYPE_STRING, &project_name_cstr,
+ DBUS_TYPE_STRING, &description_cstr,
+ DBUS_TYPE_INVALID)) {
+ return;
+ }
+
+ dbus_message_unref(reply_ptr);
+}
+
+void
+LashProxy::project_set_notes(
+ const string& project_name,
+ const string& notes)
+{
+ DBusMessage* reply_ptr;
+ const char* const project_name_cstr = project_name.c_str();
+ const char* const notes_cstr = notes.c_str();
+
+ if (!_impl->call(
+ true,
+ LASH_IFACE_CONTROL,
+ "ProjectSetNotes",
+ &reply_ptr,
+ DBUS_TYPE_STRING, &project_name_cstr,
+ DBUS_TYPE_STRING, &notes_cstr,
+ DBUS_TYPE_INVALID)) {
+ return;
+ }
+
+ dbus_message_unref(reply_ptr);
+}
+
generated by cgit v1.2.1 (git 2.18.0) at 2024-11-11 06:37:43 +0000