1 files changed, 275 insertions, 0 deletions

diff --git a/src/lib/common/gnunet_dbus_lib_interface.c b/src/lib/common/gnunet_dbus_lib_interface.c
new file mode 100644
index 0000000..bbc3467
--- /dev/null
+++ b/src/lib/common/gnunet_dbus_lib_interface.c
@@ -0,0 +1,275 @@
+#include "config.h"
+
+#include <dbus/dbus.h>
+
+#include <gnunet/platform.h>
+#include <gnunet/gnunet_common.h>
+#include <gnunet/gnunet_container_lib.h>
+
+#include "gnunet_dbus_lib.h"
+
+#define LOG(kind, ...) GNUNET_log_from (kind, "dbus-interface", __VA_ARGS__)
+
+struct GNUNET_DBUS_Interface
+{
+  struct GNUNET_DBUS_MethodIterator *methods_front;
+  struct GNUNET_DBUS_MethodIterator *methods_back;
+
+  struct GNUNET_DBUS_SignalIterator *signals_front;
+  struct GNUNET_DBUS_SignalIterator *signals_back;
+
+  char *name;
+  unsigned ref_count;
+};
+
+struct GNUNET_DBUS_Interface *
+GNUNET_DBUS_interface_create (
+    const char *name)
+{
+  LOG (GNUNET_ERROR_TYPE_DEBUG, "Creating interface %s\n", name);
+
+  struct GNUNET_DBUS_Interface *interface = GNUNET_new (struct GNUNET_DBUS_Interface);
+
+  interface->methods_front = NULL;
+  interface->methods_back = NULL;
+  interface->name = GNUNET_strdup (name);
+  interface->ref_count = 1;
+
+  return interface;
+};
+
+void
+GNUNET_DBUS_interface_ref (
+    struct GNUNET_DBUS_Interface *interface)
+{
+  interface->ref_count++;
+};
+
+void
+GNUNET_DBUS_interface_unref (
+    struct GNUNET_DBUS_Interface *interface)
+{
+  if (interface->ref_count == 0)
+  {
+    LOG (GNUNET_ERROR_TYPE_ERROR, "Tried to unreference interface with ref count 0\n");
+    GNUNET_abort_ ();
+  };
+  if (0 == --(interface->ref_count))
+  {
+    LOG (GNUNET_ERROR_TYPE_DEBUG, "Destroying interface %s\n", interface->name);
+
+    struct GNUNET_DBUS_MethodIterator *methods_iter = interface->methods_front;
+    while (methods_iter)
+    {
+      struct GNUNET_DBUS_MethodIterator *next = methods_iter->next;
+      GNUNET_DBUS_method_unref (methods_iter->method);
+      GNUNET_free (methods_iter);
+      methods_iter = next;
+    };
+
+    GNUNET_free (interface->name);
+    GNUNET_free (interface);
+  }
+};
+
+void
+GNUNET_DBUS_interface_add_method (
+    struct GNUNET_DBUS_Interface *interface,
+    struct GNUNET_DBUS_Method *method)
+{
+  struct GNUNET_DBUS_MethodIterator *meth_it = GNUNET_new (struct GNUNET_DBUS_MethodIterator);
+  meth_it->method = method;
+  GNUNET_DBUS_method_ref (method);
+
+  GNUNET_CONTAINER_DLL_insert (interface->methods_front,
+                               interface->methods_back,
+                               meth_it);
+};
+
+void
+GNUNET_DBUS_interface_add_signal (
+    struct GNUNET_DBUS_Interface *interface,
+    struct GNUNET_DBUS_Signal *signal)
+{
+  struct GNUNET_DBUS_SignalIterator *sig_it = GNUNET_new (struct GNUNET_DBUS_SignalIterator);
+  sig_it->signal = signal;
+  GNUNET_DBUS_signal_ref (signal);
+
+  GNUNET_CONTAINER_DLL_insert (interface->signals_front,
+                               interface->signals_back,
+                               sig_it);
+};
+
+const char *
+GNUNET_DBUS_interface_get_name (
+    const struct GNUNET_DBUS_Interface *interface)
+{
+  return interface->name;
+};
+
+const struct GNUNET_DBUS_MethodIterator *
+GNUNET_DBUS_interface_iterate_methods (
+    const struct GNUNET_DBUS_Interface *interface)
+{
+  return interface->methods_front;
+};
+
+const struct GNUNET_DBUS_SignalIterator *
+GNUNET_DBUS_interface_iterate_signals (
+    const struct GNUNET_DBUS_Interface *interface)
+{
+  return interface->signals_front;
+}
+
+static void
+introspectable_introspect (
+    struct GNUNET_DBUS_MethodContext *mc)
+{
+  char *data = NULL;
+  char *new_data = NULL;
+
+  LOG (GNUNET_ERROR_TYPE_DEBUG, "Introspecting\n");
+  struct GNUNET_DBUS_Object *object = mc->object;
+
+  GNUNET_asprintf (&data, "%s", DBUS_INTROSPECT_1_0_XML_DOCTYPE_DECL_NODE);
+  GNUNET_asprintf (&new_data, "%s<node>\n", data);
+  GNUNET_free (data); data = new_data;
+
+  const struct GNUNET_DBUS_InterfaceIterator *int_it = GNUNET_DBUS_object_iterate_interfaces (object);
+  while (int_it)
+  {
+    struct GNUNET_DBUS_Interface *interface = int_it->interface;
+    const char *interface_name = GNUNET_DBUS_interface_get_name (interface);
+    GNUNET_asprintf (&new_data, "%s  <interface name='%s'>\n", data, interface_name);
+    GNUNET_free (data); data = new_data;
+    const struct GNUNET_DBUS_MethodIterator *meth_it = GNUNET_DBUS_interface_iterate_methods (interface);
+    while (meth_it)
+    {
+      struct GNUNET_DBUS_Method *method = meth_it->method;
+      const char *method_name = GNUNET_DBUS_method_get_name (method);
+      GNUNET_asprintf (&new_data, "%s    <method name='%s'>\n", data, method_name);
+      GNUNET_free (data); data = new_data;
+      const struct GNUNET_DBUS_ArgIterator *arg_it = GNUNET_DBUS_method_iterate_args (method);
+      while (arg_it)
+      {
+        struct GNUNET_DBUS_Arg *arg = arg_it->arg;
+        const char *arg_name = GNUNET_DBUS_arg_get_name (arg);
+        const char *signature = GNUNET_DBUS_arg_get_signature (arg);
+        GNUNET_asprintf (
+            &new_data, 
+            "%s      <arg name='%s' type='%s' direction='in'/>\n",
+              data,
+              arg_name,
+              signature);
+        GNUNET_free (data); data = new_data;
+        arg_it = arg_it->next;
+      };
+
+      arg_it = GNUNET_DBUS_method_iterate_return_args (method);
+      while (arg_it)
+      {
+        struct GNUNET_DBUS_Arg *arg = arg_it->arg;
+        const char *arg_name = GNUNET_DBUS_arg_get_name (arg);
+        const char *signature = GNUNET_DBUS_arg_get_signature (arg);
+        GNUNET_asprintf (
+            &new_data, 
+            "%s      <arg name='%s' type='%s' direction='out'/>\n",
+              data,
+              arg_name,
+              signature);
+        GNUNET_free (data); data = new_data;
+        arg_it = arg_it->next;
+      };
+      GNUNET_asprintf (&new_data, "%s    </method>\n", data);
+      GNUNET_free (data); data = new_data;
+      meth_it = meth_it->next;
+    };
+    const struct GNUNET_DBUS_SignalIterator *sig_it = GNUNET_DBUS_interface_iterate_signals (interface);
+    while (sig_it)
+    {
+      struct GNUNET_DBUS_Signal *signal = sig_it->signal;
+      const char *signal_name = GNUNET_DBUS_signal_get_name (signal);
+      GNUNET_asprintf (&new_data, "%s    <signal name='%s'>\n", data, signal_name);
+      GNUNET_free (data); data = new_data;
+      const struct GNUNET_DBUS_ArgIterator *arg_it = GNUNET_DBUS_signal_iterate_args (signal);
+      while (arg_it)
+      {
+        struct GNUNET_DBUS_Arg *arg = arg_it->arg;
+        const char *arg_name = GNUNET_DBUS_arg_get_name (arg);
+        const char *signature = GNUNET_DBUS_arg_get_signature (arg);
+        GNUNET_asprintf (
+          &new_data,
+          "%s      <arg name='%s' type='%s'/>\n",
+            data,
+            arg_name,
+            signature);
+        GNUNET_free (data); data = new_data;
+        arg_it = arg_it->next;
+      }
+      GNUNET_asprintf (&new_data, "%s    </signal>\n", data);
+      GNUNET_free (data); data = new_data;
+      sig_it = sig_it->next;
+    };
+    GNUNET_asprintf (&new_data, "%s  </interface>\n", data);
+    GNUNET_free (data); data = new_data;
+    int_it = int_it->next;
+  };
+  const struct GNUNET_DBUS_ObjectIterator *obj_it = GNUNET_DBUS_object_iterate_subobjects (object);
+  while (obj_it)
+  {
+    const char *obj_name = GNUNET_DBUS_object_get_name (obj_it->object);
+    GNUNET_asprintf (&new_data, "%s  <node name='%s'/>\n", data, obj_name);
+    GNUNET_free (data); data = new_data;
+    obj_it = obj_it->next;
+  }
+  GNUNET_asprintf (&new_data, "%s</node>\n", data);
+  GNUNET_free (data); data = new_data;
+
+  DBusMessage *reply = GNUNET_DBUS_method_context_create_reply (mc);
+  DBusMessageIter reply_iter;
+  dbus_message_iter_init_append (reply, &reply_iter);
+  GNUNET_DBUS_push_string (reply, &reply_iter, (const char *const *)&data);
+  GNUNET_DBUS_method_context_send_reply (mc, reply);
+  GNUNET_free (data);
+};
+
+struct GNUNET_DBUS_Interface *interface_introspectable;
+
+static void construct_interface_introspectable ()
+  __attribute__((constructor));
+
+static void destruct_interface_introspectable ()
+  __attribute__((destructor));
+
+static void construct_interface_introspectable ()
+{
+  interface_introspectable = GNUNET_DBUS_interface_create ("org.freedesktop.DBus.Introspectable");
+  struct GNUNET_DBUS_Method *introspect = GNUNET_DBUS_method_create ("Introspect", introspectable_introspect);
+  GNUNET_DBUS_method_add_return_arg (introspect, "data", GNUNET_DBUS_SIGNATURE_STRING);
+  GNUNET_DBUS_interface_add_method (interface_introspectable, introspect);
+}
+
+static void destruct_interface_introspectable ()
+{
+  GNUNET_DBUS_interface_unref (interface_introspectable);
+}
+
+struct GNUNET_DBUS_Interface *
+GNUNET_DBUS_interface_introspectable ()
+{
+  return interface_introspectable;
+};
+
+const struct GNUNET_DBUS_InterfaceIterator *
+GNUNET_DBUS_interface_find (
+    const struct GNUNET_DBUS_InterfaceIterator *int_it,
+    const char *name)
+{
+  for (; int_it; int_it = int_it->next)
+  {
+    if (! strcmp (name, int_it->interface->name))
+      return int_it;
+  }
+  return NULL;
+}
+