proxies/studio_proxy.c

   1 /* -*- Mode: C ; c-basic-offset: 2 -*- */
   2 /*
   3  * LADI Session Handler (ladish)
   4  *
   5  * Copyright (C) 2009, 2010 Nedko Arnaudov <nedko@arnaudov.name>
   6  *
   7  **************************************************************************
   8  * This file contains implementation of the helper functionality
   9  * for accessing Studio 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 "common.h"
  29
  30 static void (* g_renamed_callback)(const char * new_studio_name) = NULL;
  31 static void (* g_started_callback)(void) = NULL;
  32 static void (* g_stopped_callback)(void) = NULL;
  33 static void (* g_crashed_callback)(void) = NULL;
  34
  35 static void (* g_room_appeared_calback)(const char * opath, const char * name, const char * template) = NULL;
  36 static void (* g_room_disappeared_calback)(const char * opath, const char * name, const char * template) = NULL;
  37 static void (* g_room_changed_calback)(const char * opath, const char * name, const char * template) = NULL;
  38
  39 static void on_studio_renamed(void * context, DBusMessage * message_ptr)
  40 {
  41   char * name;
  42
  43   if (!dbus_message_get_args(message_ptr, &g_dbus_error, DBUS_TYPE_STRING, &name, DBUS_TYPE_INVALID))
  44   {
  45     log_error("Invalid parameters of StudioRenamed signal: %s",  g_dbus_error.message);
  46     dbus_error_free(&g_dbus_error);
  47   }
  48   else
  49   {
  50     log_info("StudioRenamed");
  51
  52     if (g_renamed_callback != NULL)
  53     {
  54       g_renamed_callback(name);
  55     }
  56   }
  57 }
  58
  59 static bool extract_room_info(DBusMessageIter * iter_ptr, const char ** opath, const char ** name, const char ** template)
  60 {
  61   dbus_message_iter_get_basic(iter_ptr, opath);
  62   //log_info("opath is \"%s\"", *opath);
  63   dbus_message_iter_next(iter_ptr);
  64
  65   if (!dbus_iter_get_dict_entry_string(iter_ptr, "name", name))
  66   {
  67     log_error("dbus_iter_get_dict_entry() failed");
  68     return false;
  69   }
  70   //log_info("name is \"%s\"", *name);
  71
  72   if (!dbus_iter_get_dict_entry_string(iter_ptr, "template", template))
  73   {
  74     *template = NULL;
  75   }
  76   //log_info("template is \"%s\"", *template);
  77
  78   return true;
  79 }
  80
  81 static bool extract_room_info_from_signal(DBusMessage * message_ptr, const char ** opath, const char ** name, const char ** template)
  82 {
  83   const char * signature;
  84   DBusMessageIter iter;
  85
  86   signature = dbus_message_get_signature(message_ptr);
  87   if (strcmp(signature, "sa{sv}") != 0)
  88   {
  89     log_error("Invalid signature of room signal");
  90     return false;
  91   }
  92
  93   dbus_message_iter_init(message_ptr, &iter);
  94
  95   return extract_room_info(&iter, opath, name, template);
  96 }
  97
  98 static void on_studio_started(void * context, DBusMessage * message_ptr)
  99 {
 100   log_info("StudioStarted");
 101
 102   if (g_started_callback != NULL)
 103   {
 104     g_started_callback();
 105   }
 106 }
 107
 108 static void on_studio_stopped(void * context, DBusMessage * message_ptr)
 109 {
 110   log_info("StudioStopped");
 111
 112   if (g_stopped_callback != NULL)
 113   {
 114     g_stopped_callback();
 115   }
 116 }
 117
 118 static void on_studio_crashed(void * context, DBusMessage * message_ptr)
 119 {
 120   log_info("StudioCrashed");
 121
 122   if (g_crashed_callback != NULL)
 123   {
 124     g_crashed_callback();
 125   }
 126 }
 127
 128 static void on_room_appeared(void * context, DBusMessage * message_ptr)
 129 {
 130   const char * opath;
 131   const char * name;
 132   const char * template;
 133
 134   log_info("RoomAppeared");
 135
 136   if (g_room_appeared_calback != NULL && extract_room_info_from_signal(message_ptr, &opath, &name, &template))
 137   {
 138     g_room_appeared_calback(opath, name, template);
 139   }
 140 }
 141
 142 static void on_room_disappeared(void * context, DBusMessage * message_ptr)
 143 {
 144   const char * opath;
 145   const char * name;
 146   const char * template;
 147
 148   log_info("RoomDisappeared");
 149
 150   if (g_room_disappeared_calback != NULL && extract_room_info_from_signal(message_ptr, &opath, &name, &template))
 151   {
 152     g_room_disappeared_calback(opath, name, template);
 153   }
 154 }
 155
 156 static void on_room_changed(void * context, DBusMessage * message_ptr)
 157 {
 158   const char * opath;
 159   const char * name;
 160   const char * template;
 161
 162   log_info("RoomChanged");
 163
 164   if (g_room_changed_calback != NULL && extract_room_info_from_signal(message_ptr, &opath, &name, &template))
 165   {
 166     g_room_changed_calback(opath, name, template);
 167   }
 168 }
 169
 170 /* this must be static because it is referenced by the
 171  * dbus helper layer when hooks are active */
 172 static struct dbus_signal_hook g_signal_hooks[] =
 173 {
 174   {"StudioRenamed", on_studio_renamed},
 175   {"StudioStarted", on_studio_started},
 176   {"StudioStopped", on_studio_stopped},
 177   {"StudioCrashed", on_studio_crashed},
 178   {"RoomAppeared", on_room_appeared},
 179   {"RoomDisappeared", on_room_disappeared},
 180   {"RoomChanged", on_room_changed},
 181   {NULL, NULL}
 182 };
 183
 184 bool studio_proxy_init(void)
 185 {
 186   if (!dbus_register_object_signal_hooks(
 187         g_dbus_connection,
 188         SERVICE_NAME,
 189         STUDIO_OBJECT_PATH,
 190         IFACE_STUDIO,
 191         NULL,
 192         g_signal_hooks))
 193   {
 194     log_error("dbus_register_object_signal_hooks() failed");
 195     return false;
 196   }
 197
 198   return true;
 199 }
 200
 201 void studio_proxy_uninit(void)
 202 {
 203   dbus_unregister_object_signal_hooks(g_dbus_connection, SERVICE_NAME, STUDIO_OBJECT_PATH, IFACE_STUDIO);
 204 }
 205
 206 bool studio_proxy_get_name(char ** name_ptr)
 207 {
 208   const char * name;
 209   if (!dbus_call(SERVICE_NAME, STUDIO_OBJECT_PATH, IFACE_STUDIO, "GetName", "", "s", &name))
 210   {
 211     return false;
 212   }
 213
 214   *name_ptr = strdup(name);
 215   if (*name_ptr == NULL)
 216   {
 217     log_error("strdup() failed to duplicate studio name");
 218     return false;
 219   }
 220
 221   return true;
 222 }
 223
 224 bool studio_proxy_rename(const char * name)
 225 {
 226   return dbus_call(SERVICE_NAME, STUDIO_OBJECT_PATH, IFACE_STUDIO, "Rename", "s", &name, "");
 227 }
 228
 229 bool studio_proxy_save(void)
 230 {
 231   return dbus_call(SERVICE_NAME, STUDIO_OBJECT_PATH, IFACE_STUDIO, "Save", "", "");
 232 }
 233
 234 bool studio_proxy_save_as(const char * name)
 235 {
 236   return dbus_call(SERVICE_NAME, STUDIO_OBJECT_PATH, IFACE_STUDIO, "SaveAs", "s", &name, "");
 237 }
 238
 239 bool studio_proxy_unload(void)
 240 {
 241   return dbus_call(SERVICE_NAME, STUDIO_OBJECT_PATH, IFACE_STUDIO, "Unload", "", "");
 242 }
 243
 244 void studio_proxy_set_renamed_callback(void (* callback)(const char * new_studio_name))
 245 {
 246   g_renamed_callback = callback;
 247 }
 248
 249 void studio_proxy_set_startstop_callbacks(void (* started_callback)(void), void (* stopped_callback)(void), void (* crashed_callback)(void))
 250 {
 251   g_started_callback = started_callback;
 252   g_stopped_callback = stopped_callback;
 253   g_crashed_callback = crashed_callback;
 254 }
 255
 256 bool studio_proxy_start(void)
 257 {
 258   return dbus_call(SERVICE_NAME, STUDIO_OBJECT_PATH, IFACE_STUDIO, "Start", "", "");
 259 }
 260
 261 bool studio_proxy_stop(void)
 262 {
 263   return dbus_call(SERVICE_NAME, STUDIO_OBJECT_PATH, IFACE_STUDIO, "Stop", "", "");
 264 }
 265
 266 bool studio_proxy_is_started(bool * is_started_ptr)
 267 {
 268   dbus_bool_t is_started;
 269
 270   if (!dbus_call(SERVICE_NAME, STUDIO_OBJECT_PATH, IFACE_STUDIO, "IsStarted", "", "b", &is_started))
 271   {
 272     return false;
 273   }
 274
 275   *is_started_ptr = is_started;
 276
 277   return true;
 278 }
 279
 280 void
 281 studio_proxy_set_room_callbacks(
 282   void (* appeared)(const char * opath, const char * name, const char * template),
 283   void (* disappeared)(const char * opath, const char * name, const char * template),
 284   void (* changed)(const char * opath, const char * name, const char * template))
 285 {
 286   DBusMessage * reply_ptr;
 287   const char * signature;
 288   DBusMessageIter top_iter;
 289   DBusMessageIter array_iter;
 290   DBusMessageIter struct_iter;
 291   const char * opath;
 292   const char * name;
 293   const char * template;
 294
 295   g_room_appeared_calback = appeared;
 296   g_room_disappeared_calback = disappeared;
 297   g_room_changed_calback = changed;
 298
 299   if (!dbus_call(SERVICE_NAME, STUDIO_OBJECT_PATH, IFACE_STUDIO, "GetRoomList", "", NULL, &reply_ptr))
 300   {
 301     log_error("Cannot fetch studio room list");
 302     return;
 303   }
 304
 305   signature = dbus_message_get_signature(reply_ptr);
 306   if (strcmp(signature, "a(sa{sv})") != 0)
 307   {
 308     log_error("Invalid signature of GetRoomList reply");
 309     goto unref;
 310   }
 311
 312   dbus_message_iter_init(reply_ptr, &top_iter);
 313
 314   for (dbus_message_iter_recurse(&top_iter, &array_iter);
 315        dbus_message_iter_get_arg_type(&array_iter) != DBUS_TYPE_INVALID;
 316        dbus_message_iter_next(&array_iter))
 317   {
 318     dbus_message_iter_recurse(&array_iter, &struct_iter);
 319
 320     if (!extract_room_info(&struct_iter, &opath, &name, &template))
 321     {
 322       log_error("extract_room_info() failed.");
 323       goto unref;
 324     }
 325
 326     g_room_appeared_calback(opath, name, template);
 327   }
 328
 329 unref:
 330   dbus_message_unref(reply_ptr);
 331 }
 332
 333 bool studio_proxy_create_room(const char * name, const char * template)
 334 {
 335   return dbus_call(SERVICE_NAME, STUDIO_OBJECT_PATH, IFACE_STUDIO, "CreateRoom", "ss", &name, &template, "");
 336 }
 337
 338 bool studio_proxy_delete_room(const char * name)
 339 {
 340   return dbus_call(SERVICE_NAME, STUDIO_OBJECT_PATH, IFACE_STUDIO, "DeleteRoom", "s", &name, "");
 341 }