From 336020937897e39bb890924010440d1a780d8b77 Mon Sep 17 00:00:00 2001
From: Nedko Arnaudov <nedko@arnaudov.name>
Date: Thu, 23 Jul 2009 01:37:53 +0300
Subject: [PATCH] Watch for dbus signals

---
 daemon/common.h     |   1 +
 daemon/jack_proxy.c | 141 +++++++++++++++++++++++++++++++++++++++++++-
 daemon/main.c       |   9 +++
 3 files changed, 150 insertions(+), 1 deletion(-)

diff --git a/daemon/common.h b/daemon/common.h
index 93b91b94..f2ce9ea9 100644
--- a/daemon/common.h
+++ b/daemon/common.h
@@ -106,6 +106,7 @@ struct studio
 };
 
 extern service_t * g_dbus_service;
+#define g_dbus_connection (g_dbus_service->connection)
 extern bool g_quit;
 
 #endif /* #ifndef COMMON_H__CFDC869A_31AE_4FA3_B2D3_DACA8488CA55__INCLUDED */
diff --git a/daemon/jack_proxy.c b/daemon/jack_proxy.c
index ac84149d..f925619d 100644
--- a/daemon/jack_proxy.c
+++ b/daemon/jack_proxy.c
@@ -8,17 +8,156 @@
 
 #include "jack_proxy.h"
 
+#define JACKDBUS_SERVICE         "org.jackaudio.service"
+#define JACKDBUS_OBJECT          "/org/jackaudio/Controller"
+#define JACKDBUS_IFACE_CONTROL   "org.jackaudio.JackControl"
+#define JACKDBUS_IFACE_PATCHBAY  "org.jackaudio.JackPatchbay"
+
+static
+DBusHandlerResult
+dbus_signal_handler(
+  DBusConnection * connection_ptr,
+  DBusMessage * message_ptr,
+  void * data)
+{
+  const char * object_path;
+  const char * interface;
+  const char * signal_name;
+
+  /* Non-signal messages are ignored */
+  if (dbus_message_get_type(message_ptr) != DBUS_MESSAGE_TYPE_SIGNAL)
+  {
+    return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
+  }
+
+  interface = dbus_message_get_interface(message_ptr);
+  if (interface == NULL)
+  {
+    /* Signals with no interface are ignored */
+    return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
+  }
+
+  object_path = dbus_message_get_path(message_ptr);
+
+  signal_name = dbus_message_get_member(message_ptr);
+  if (signal_name == NULL)
+  {
+    lash_error("Received signal with NULL member");
+    return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
+  }
+
+  lash_info("'%s' sent signal '%s'::'%s'", object_path, interface, signal_name);
+
+#if 0
+  /* Handle JACK patchbay and control interface signals */
+  if (object_path != NULL && strcmp(object_path, JACKDBUS_OBJECT) == 0)
+  {
+    if (strcmp(interface, JACKDBUS_IFACE_PATCHBAY) == 0)
+    {
+      lashd_jackdbus_handle_patchbay_signal(message_ptr);
+      return DBUS_HANDLER_RESULT_HANDLED;
+    }
+
+    if (strcmp(interface, JACKDBUS_IFACE_CONTROL) == 0)
+    {
+      lashd_jackdbus_handle_control_signal(message_ptr);
+      return DBUS_HANDLER_RESULT_HANDLED;
+    }
+
+    return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
+  }
+
+  /* Handle session bus signals to track JACK service alive state */
+  if (strcmp(interface, DBUS_INTERFACE_DBUS) == 0)
+  {
+    return lashd_jackdbus_handle_bus_signal(message_ptr);
+  }
+#endif
+
+  /* Let everything else pass through */
+  return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
+}
+
 bool
 jack_proxy_init(
   void)
 {
-  return false;
+  DBusError err;
+  char rule[1024];
+  const char ** signal;
+
+  const char * patchbay_signals[] = {
+    "ClientAppeared",
+    "ClientDisappeared",
+    "PortAppeared",
+    "PortsConnected",
+    "PortsDisconnected",
+    NULL};
+
+  const char * control_signals[] = {
+    "ServerStarted",
+    "ServerStopped",
+    NULL};
+
+  dbus_bus_add_match(
+    g_dbus_connection,
+    "type='signal',interface='"DBUS_INTERFACE_DBUS"',member=NameOwnerChanged,arg0='"JACKDBUS_SERVICE"'",
+    &err);
+  if (dbus_error_is_set(&err))
+  {
+    lash_error("Failed to add D-Bus match rule: %s", err.message);
+    dbus_error_free(&err);
+    return false;
+  }
+
+  for (signal = patchbay_signals; *signal != NULL; signal++)
+  {
+    snprintf(
+      rule,
+      sizeof(rule),
+      "type='signal',sender='"JACKDBUS_SERVICE"',path='"JACKDBUS_OBJECT"',interface='"JACKDBUS_IFACE_PATCHBAY"',member='%s'",
+      *signal);
+
+    dbus_bus_add_match(g_dbus_connection, rule, &err);
+    if (dbus_error_is_set(&err))
+    {
+      lash_error("Failed to add D-Bus match rule: %s", err.message);
+      dbus_error_free(&err);
+      return false;
+    }
+  }
+
+  for (signal = control_signals; *signal != NULL; signal++)
+  {
+    snprintf(
+      rule,
+      sizeof(rule),
+      "type='signal',sender='"JACKDBUS_SERVICE"',path='"JACKDBUS_OBJECT"',interface='"JACKDBUS_IFACE_CONTROL"',member='%s'",
+      *signal);
+
+    dbus_bus_add_match(g_dbus_connection, rule, &err);
+    if (dbus_error_is_set(&err))
+    {
+      lash_error("Failed to add D-Bus match rule: %s", err.message);
+      dbus_error_free(&err);
+      return false;
+    }
+  }
+
+  if (!dbus_connection_add_filter(g_dbus_connection, dbus_signal_handler, NULL, NULL))
+  {
+    lash_error("Failed to add D-Bus filter");
+    return false;
+  }
+
+  return true;
 }
 
 void
 jack_proxy_uninit(
   void)
 {
+  dbus_connection_remove_filter(g_dbus_connection, dbus_signal_handler, NULL);
 }
 
 bool
diff --git a/daemon/main.c b/daemon/main.c
index 6cf1aed4..8b6604a0 100644
--- a/daemon/main.c
+++ b/daemon/main.c
@@ -31,6 +31,7 @@
 #include "loader.h"
 #include "sigsegv.h"
 #include "dbus_iface_control.h"
+#include "jack.h"
 
 bool g_quit;
 service_t * g_dbus_service;
@@ -215,6 +216,11 @@ int main(int argc, char ** argv, char ** envp)
   /* setup our SIGSEGV magic that prints nice stack in our logfile */ 
   setup_sigsegv();
 
+  if (!jack_init())
+  {
+    goto uninit_dbus;
+  }
+
   while (!g_quit)
   {
     dbus_connection_read_write_dispatch(g_dbus_service->connection, 50);
@@ -225,6 +231,9 @@ int main(int argc, char ** argv, char ** envp)
 
   lash_debug("Finished, cleaning up");
 
+uninit_dbus:
+  jack_uninit();
+
   service_destroy(g_dbus_service);
 
 uninit_loader: