gui/app_supervisor_proxy.c

   1 /* -*- Mode: C ; c-basic-offset: 2 -*- */
   2 /*
   3  * LADI Session Handler (ladish)
   4  *
   5  * Copyright (C) 2009 Nedko Arnaudov <nedko@arnaudov.name>
   6  *
   7  **************************************************************************
   8  * This file contains implementation of code that interfaces
   9  * app supervisor object through D-Bus
  10  **************************************************************************
  11  *
  12  * LADI Session Handler is free software; you can redistribute it and/or modify
  13  * it under the terms of the GNU General Public License as published by
  14  * the Free Software Foundation; either version 2 of the License, or
  15  * (at your option) any later version.
  16  *
  17  * LADI Session Handler is distributed in the hope that it will be useful,
  18  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  19  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  20  * GNU General Public License for more details.
  21  *
  22  * You should have received a copy of the GNU General Public License
  23  * along with LADI Session Handler. If not, see <http://www.gnu.org/licenses/>
  24  * or write to the Free Software Foundation, Inc.,
  25  * 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
  26  */
  27
  28 #include "app_supervisor_proxy.h"
  29 #include "../dbus/helpers.h"
  30 #include "../dbus_constants.h"
  31
  32 struct ladish_app_supervisor_proxy
  33 {
  34   char * service;
  35   char * object;
  36   uint64_t version;
  37
  38   void * context;
  39   void (* app_added)(void * context, uint64_t id, const char * name, bool running, bool terminal, uint8_t level);
  40   void (* app_state_changed)(void * context, uint64_t id, const char * name, bool running, bool terminal, uint8_t level);
  41   void (* app_removed)(void * context, uint64_t id);
  42 };
  43
  44 static const char * g_signals[] =
  45 {
  46   "AppAdded",
  47   "AppRemoved",
  48   "AppStateChanged",
  49   NULL
  50 };
  51
  52 #define proxy_ptr ((struct ladish_app_supervisor_proxy *)proxy)
  53
  54 static
  55 DBusHandlerResult
  56 message_hook(
  57   DBusConnection * connection,
  58   DBusMessage * message,
  59   void * proxy)
  60 {
  61   const char * object_path;
  62   uint64_t new_list_version;
  63   uint64_t id;
  64   const char * name;
  65   dbus_bool_t running;
  66   dbus_bool_t terminal;
  67   uint8_t level;
  68
  69   object_path = dbus_message_get_path(message);
  70   if (object_path == NULL || strcmp(object_path, proxy_ptr->object) != 0)
  71   {
  72     return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
  73   }
  74
  75   if (dbus_message_is_signal(message, IFACE_APP_SUPERVISOR, "AppAdded"))
  76   {
  77     if (!dbus_message_get_args(
  78           message,
  79           &g_dbus_error,
  80           DBUS_TYPE_UINT64, &new_list_version,
  81           DBUS_TYPE_UINT64, &id,
  82           DBUS_TYPE_STRING, &name,
  83           DBUS_TYPE_BOOLEAN, &running,
  84           DBUS_TYPE_BOOLEAN, &terminal,
  85           DBUS_TYPE_BYTE, &level,
  86           DBUS_TYPE_INVALID))
  87     {
  88       log_error("dbus_message_get_args() failed to extract AppAdded signal arguments (%s)", g_dbus_error.message);
  89       dbus_error_free(&g_dbus_error);
  90       return DBUS_HANDLER_RESULT_HANDLED;
  91     }
  92
  93     //log_info("AppAdded signal received. id=%"PRIu64", name='%s', %srunning, %s, level %u", id, name, running ? "" : "not ", terminal ? "terminal" : "shell", (unsigned int)level);
  94     proxy_ptr->app_added(proxy_ptr->context, id, name, running, terminal, level);
  95     return DBUS_HANDLER_RESULT_HANDLED;
  96   }
  97
  98   if (dbus_message_is_signal(message, IFACE_APP_SUPERVISOR, "AppRemoved"))
  99   {
 100     if (!dbus_message_get_args(
 101           message,
 102           &g_dbus_error,
 103           DBUS_TYPE_UINT64, &new_list_version,
 104           DBUS_TYPE_UINT64, &id,
 105           DBUS_TYPE_INVALID))
 106     {
 107       log_error("dbus_message_get_args() failed to extract AppRemoved signal arguments (%s)", g_dbus_error.message);
 108       dbus_error_free(&g_dbus_error);
 109       return DBUS_HANDLER_RESULT_HANDLED;
 110     }
 111
 112     //log_info("AppRemoved signal received, id=%"PRIu64, id);
 113     proxy_ptr->app_removed(proxy_ptr->context, id);
 114     return DBUS_HANDLER_RESULT_HANDLED;
 115   }
 116
 117   if (dbus_message_is_signal(message, IFACE_APP_SUPERVISOR, "AppStateChanged"))
 118   {
 119     if (!dbus_message_get_args(
 120           message,
 121           &g_dbus_error,
 122           DBUS_TYPE_UINT64, &id,
 123           DBUS_TYPE_STRING, &name,
 124           DBUS_TYPE_BOOLEAN, &running,
 125           DBUS_TYPE_BOOLEAN, &terminal,
 126           DBUS_TYPE_BYTE, &level,
 127           DBUS_TYPE_INVALID))
 128     {
 129       log_error("dbus_message_get_args() failed to extract AppStateChanged signal arguments (%s)", g_dbus_error.message);
 130       dbus_error_free(&g_dbus_error);
 131       return DBUS_HANDLER_RESULT_HANDLED;
 132     }
 133
 134     //log_info("AppStateChanged signal received");
 135     proxy_ptr->app_state_changed(proxy_ptr->context, id, name, running, terminal, level);
 136     return DBUS_HANDLER_RESULT_HANDLED;
 137   }
 138
 139   return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
 140 }
 141
 142 #undef proxy_ptr
 143
 144 static void refresh_internal(struct ladish_app_supervisor_proxy * proxy_ptr, bool force)
 145 {
 146   DBusMessage* reply_ptr;
 147   DBusMessageIter iter;
 148   dbus_uint64_t version;
 149   const char * reply_signature;
 150   DBusMessageIter array_iter;
 151   DBusMessageIter struct_iter;
 152   uint64_t id;
 153   const char * name;
 154   dbus_bool_t running;
 155   dbus_bool_t terminal;
 156   uint8_t level;
 157
 158   log_info("refresh_internal() called");
 159
 160   version = proxy_ptr->version;
 161
 162   if (!dbus_call(proxy_ptr->service, proxy_ptr->object, IFACE_APP_SUPERVISOR, "GetAll", "t", &version, NULL, &reply_ptr))
 163   {
 164     log_error("GetAll() failed.");
 165     return;
 166   }
 167
 168   reply_signature = dbus_message_get_signature(reply_ptr);
 169
 170   if (strcmp(reply_signature, "ta(tsbby)") != 0)
 171   {
 172     log_error("GetAll() reply signature mismatch. '%s'", reply_signature);
 173     goto unref;
 174   }
 175
 176   dbus_message_iter_init(reply_ptr, &iter);
 177
 178   //log_info_msg("version " + (char)dbus_message_iter_get_arg_type(&iter));
 179   dbus_message_iter_get_basic(&iter, &version);
 180   dbus_message_iter_next(&iter);
 181
 182   if (!force && version <= proxy_ptr->version)
 183   {
 184     goto unref;
 185   }
 186
 187   //log_info("got new list version %llu", (unsigned long long)version);
 188   proxy_ptr->version = version;
 189
 190   for (dbus_message_iter_recurse(&iter, &array_iter);
 191        dbus_message_iter_get_arg_type(&array_iter) != DBUS_TYPE_INVALID;
 192        dbus_message_iter_next(&array_iter))
 193   {
 194     dbus_message_iter_recurse(&array_iter, &struct_iter);
 195
 196     dbus_message_iter_get_basic(&struct_iter, &id);
 197     dbus_message_iter_next(&struct_iter);
 198
 199     dbus_message_iter_get_basic(&struct_iter, &name);
 200     dbus_message_iter_next(&struct_iter);
 201
 202     dbus_message_iter_get_basic(&struct_iter, &running);
 203     dbus_message_iter_next(&struct_iter);
 204
 205     dbus_message_iter_get_basic(&struct_iter, &terminal);
 206     dbus_message_iter_next(&struct_iter);
 207
 208     dbus_message_iter_get_basic(&struct_iter, &level);
 209     dbus_message_iter_next(&struct_iter);
 210
 211     //log_info("App id=%"PRIu64", name='%s', %srunning, %s, level %u", id, name, running ? "" : "not ", terminal ? "terminal" : "shell", (unsigned int)level);
 212     proxy_ptr->app_added(proxy_ptr->context, id, name, running, terminal, level);
 213
 214     dbus_message_iter_next(&struct_iter);
 215   }
 216
 217 unref:
 218   dbus_message_unref(reply_ptr);
 219 }
 220
 221 bool
 222 ladish_app_supervisor_proxy_create(
 223   const char * service,
 224   const char * object,
 225   void * context,
 226   void (* app_added)(void * context, uint64_t id, const char * name, bool running, bool terminal, uint8_t level),
 227   void (* app_state_changed)(void * context, uint64_t id, const char * name, bool running, bool terminal, uint8_t level),
 228   void (* app_removed)(void * context, uint64_t id),
 229   ladish_app_supervisor_proxy_handle * handle_ptr)
 230 {
 231   struct ladish_app_supervisor_proxy * proxy_ptr;
 232
 233   proxy_ptr = malloc(sizeof(struct ladish_app_supervisor_proxy));
 234   if (proxy_ptr == NULL)
 235   {
 236     log_error("malloc() failed to allocate struct proxy");
 237     goto fail;
 238   }
 239
 240   proxy_ptr->service = strdup(service);
 241   if (proxy_ptr->service == NULL)
 242   {
 243     log_error("strdup() failed too duplicate service name '%s'", service);
 244     goto free_proxy;
 245   }
 246
 247   proxy_ptr->object = strdup(object);
 248   if (proxy_ptr->object == NULL)
 249   {
 250     log_error("strdup() failed too duplicate object name '%s'", object);
 251     goto free_service;
 252   }
 253
 254   proxy_ptr->version = 0;
 255
 256   proxy_ptr->context = context;
 257   proxy_ptr->app_added = app_added;
 258   proxy_ptr->app_state_changed = app_state_changed;
 259   proxy_ptr->app_removed = app_removed;
 260
 261   if (!dbus_register_object_signal_handler(
 262         g_dbus_connection,
 263         proxy_ptr->service,
 264         proxy_ptr->object,
 265         IFACE_APP_SUPERVISOR,
 266         g_signals,
 267         message_hook,
 268         proxy_ptr))
 269   {
 270     return false;
 271   }
 272
 273   refresh_internal(proxy_ptr, true);
 274
 275   *handle_ptr = (ladish_app_supervisor_proxy_handle)proxy_ptr;
 276
 277   return true;
 278
 279 free_service:
 280   free(proxy_ptr->service);
 281
 282 free_proxy:
 283   free(proxy_ptr);
 284
 285 fail:
 286   return false;
 287 }
 288
 289 #define proxy_ptr ((struct ladish_app_supervisor_proxy *)proxy)
 290
 291 void ladish_app_supervisor_proxy_destroy(ladish_app_supervisor_proxy_handle proxy)
 292 {
 293   dbus_unregister_object_signal_handler(
 294     g_dbus_connection,
 295     proxy_ptr->service,
 296     proxy_ptr->object,
 297     IFACE_APP_SUPERVISOR,
 298     g_signals,
 299     message_hook,
 300     proxy_ptr);
 301
 302   free(proxy_ptr->object);
 303   free(proxy_ptr->service);
 304   free(proxy_ptr);
 305 }
 306
 307 bool ladish_app_supervisor_proxy_run_custom(ladish_app_supervisor_proxy_handle proxy, const char * command, const char * name, bool run_in_terminal)
 308 {
 309   dbus_bool_t terminal;
 310
 311   terminal = run_in_terminal;
 312
 313   if (!dbus_call(proxy_ptr->service, proxy_ptr->object, IFACE_APP_SUPERVISOR, "RunCustom", "bss", &terminal, &command, &name, ""))
 314   {
 315     log_error("RunCustom() failed.");
 316     return false;
 317   }
 318
 319   return true;
 320 }
 321
 322 bool ladish_app_supervisor_proxy_start_app(ladish_app_supervisor_proxy_handle proxy, uint64_t id)
 323 {
 324   if (!dbus_call(proxy_ptr->service, proxy_ptr->object, IFACE_APP_SUPERVISOR, "StartApp", "t", &id, ""))
 325   {
 326     log_error("StartApp() failed.");
 327     return false;
 328   }
 329
 330   return true;
 331 }
 332
 333 bool ladish_app_supervisor_proxy_stop_app(ladish_app_supervisor_proxy_handle proxy, uint64_t id)
 334 {
 335   if (!dbus_call(proxy_ptr->service, proxy_ptr->object, IFACE_APP_SUPERVISOR, "StopApp", "t", &id, ""))
 336   {
 337     log_error("StopApp() failed.");
 338     return false;
 339   }
 340
 341   return true;
 342 }
 343
 344 bool ladish_app_supervisor_proxy_kill_app(ladish_app_supervisor_proxy_handle proxy, uint64_t id)
 345 {
 346   if (!dbus_call(proxy_ptr->service, proxy_ptr->object, IFACE_APP_SUPERVISOR, "KillApp", "t", &id, ""))
 347   {
 348     log_error("KillApp() failed.");
 349     return false;
 350   }
 351
 352   return true;
 353 }
 354
 355 bool ladish_app_supervisor_proxy_remove_app(ladish_app_supervisor_proxy_handle proxy, uint64_t id)
 356 {
 357   if (!dbus_call(proxy_ptr->service, proxy_ptr->object, IFACE_APP_SUPERVISOR, "RemoveApp", "t", &id, ""))
 358   {
 359     log_error("RemoveApp() failed.");
 360     return false;
 361   }
 362
 363   return true;
 364 }
 365
 366 #undef proxy_ptr