tubes: add approver

This is a small external process designed to prompt the user for
incoming LibreOffice-flavoured D-Bus tubes.

Right now it is not service-activatable, but soon it will be…

4 files changed, 287 insertions, 0 deletions

diff --git a/Repository.mk b/Repository.mk
index 558998a3c63b..9d5a11c9e346 100644
--- a/Repository.mk
+++ b/Repository.mk
@@ -138,6 +138,7 @@ $(eval $(call gb_Helper_register_executables,OOO,\
     soffice.bin \
     unopkg.bin \
     gengal.bin \
+    liboapprover \
 ))
 
 ifeq ($(OS),MACOSX)
diff --git a/tubes/Executable_liboapprover.mk b/tubes/Executable_liboapprover.mk
new file mode 100644
index 000000000000..63f81770de95
--- /dev/null
+++ b/tubes/Executable_liboapprover.mk
@@ -0,0 +1,47 @@
+# -*- Mode: makefile-gmake; tab-width: 4; indent-tabs-mode: t -*-
+# Version: MPL 1.1 / GPLv3+ / LGPLv3+
+#
+# The contents of this file are subject to the Mozilla Public License Version
+# 1.1 (the "License"); you may not use this file except in compliance with
+# the License or as specified alternatively below. You may obtain a copy of
+# the License at http://www.mozilla.org/MPL/
+#
+# Software distributed under the License is distributed on an "AS IS" basis,
+# WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
+# for the specific language governing rights and limitations under the
+# License.
+#
+# Major Contributor(s):
+# Copyright (C) 2012 Collabora Ltd.
+#
+# All Rights Reserved.
+#
+# For minor contributions see the git repository.
+#
+# Alternatively, the contents of this file may be used under the terms of
+# either the GNU General Public License Version 3 or later (the "GPLv3+"), or
+# the GNU Lesser General Public License Version 3 or later (the "LGPLv3+"),
+# in which case the provisions of the GPLv3+ or the LGPLv3+ are applicable
+# instead of those above.
+
+$(eval $(call gb_Executable_Executable,liboapprover))
+
+$(eval $(call gb_Executable_set_targettype_gui,liboapprover,YES))
+
+$(eval $(call gb_Executable_set_include,liboapprover,\
+    $$(INCLUDE) \
+    $(GTK_CFLAGS) \
+    $(TELEPATHY_CFLAGS) \
+    -I$(realpath $(SRCDIR)/tubes/inc) \
+))
+
+$(eval $(call gb_Executable_add_libs,liboapprover,\
+    $(GTK_LIBS) \
+    $(TELEPATHY_LIBS) \
+))
+
+$(eval $(call gb_Executable_add_cobjects,liboapprover,\
+    tubes/source/approver \
+))
+
+# vim: set ts=4 sw=4 et:
diff --git a/tubes/Module_tubes.mk b/tubes/Module_tubes.mk
index 9ed4a483d2b8..fb1c9d719ff0 100644
--- a/tubes/Module_tubes.mk
+++ b/tubes/Module_tubes.mk
@@ -31,6 +31,7 @@ ifeq ($(ENABLE_TELEPATHY),TRUE)
 
 $(eval $(call gb_Module_add_targets,tubes,\
 	Library_tubes \
+	Executable_liboapprover \
 ))
 
 $(eval $(call gb_Module_add_check_targets,tubes,\
diff --git a/tubes/source/approver.c b/tubes/source/approver.c
new file mode 100644
index 000000000000..fdf0799bbff2
--- /dev/null
+++ b/tubes/source/approver.c
@@ -0,0 +1,238 @@
+/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
+/*
+ * Version: MPL 1.1 / GPLv3+ / LGPLv3+
+ *
+ * The contents of this file are subject to the Mozilla Public License Version
+ * 1.1 (the "License"); you may not use this file except in compliance with
+ * the License or as specified alternatively below. You may obtain a copy of
+ * the License at http://www.mozilla.org/MPL/
+ *
+ * Software distributed under the License is distributed on an "AS IS" basis,
+ * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
+ * for the specific language governing rights and limitations under the
+ * License.
+ *
+ * Major Contributor(s):
+ * Copyright (C) 2010-2012 Collabora Ltd.
+ *
+ * All Rights Reserved.
+ *
+ * For minor contributions see the git repository.
+ *
+ * Alternatively, the contents of this file may be used under the terms of
+ * either the GNU General Public License Version 3 or later (the "GPLv3+"), or
+ * the GNU Lesser General Public License Version 3 or later (the "LGPLv3+"),
+ * in which case the provisions of the GPLv3+ or the LGPLv3+ are applicable
+ * instead of those above.
+ */
+
+#include <glib.h>
+#include <stdio.h>
+
+#include <gtk/gtk.h>
+
+#include <telepathy-glib/telepathy-glib.h>
+#include <telepathy-glib/debug.h>
+#include <telepathy-glib/simple-approver.h>
+
+#include <tubes/constants.h>
+
+GMainLoop *mainloop = NULL;
+
+static void
+handle_with_cb (GObject *source,
+    GAsyncResult *result,
+    gpointer user_data)
+{
+  TpChannelDispatchOperation *cdo = TP_CHANNEL_DISPATCH_OPERATION (source);
+  GError *error;
+
+  if (!tp_channel_dispatch_operation_handle_with_finish (cdo, result, &error))
+    {
+      g_print ("HandleWith() failed: %s\n", error->message);
+      g_error_free (error);
+      return;
+    }
+
+  g_print ("HandleWith() succeeded\n");
+}
+
+static void
+close_cb (GObject *source,
+    GAsyncResult *result,
+    gpointer user_data)
+
+{
+  TpChannelDispatchOperation *cdo = TP_CHANNEL_DISPATCH_OPERATION (source);
+  GError *error;
+
+  if (!tp_channel_dispatch_operation_close_channels_finish (cdo, result, &error))
+    {
+      g_print ("Rejecting channels failed: %s\n", error->message);
+      g_error_free (error);
+      return;
+    }
+
+  g_print ("Rejected all the things!\n");
+}
+
+static void
+dialog_response_cb (
+    GtkWidget *dialog,
+    gint response_id,
+    gpointer user_data)
+{
+    TpSimpleApprover *self = TP_SIMPLE_APPROVER (g_object_get_data (dialog, "client"));
+    TpChannelDispatchOperation *cdo = TP_CHANNEL_DISPATCH_OPERATION (user_data);
+
+    if (response_id == GTK_RESPONSE_ACCEPT)
+    {
+        g_print ("Approve channels\n");
+
+        tp_channel_dispatch_operation_handle_with_async (cdo, NULL,
+            handle_with_cb, NULL);
+    }
+    else
+    {
+        g_print ("Reject channels\n");
+
+        tp_channel_dispatch_operation_close_channels_async (cdo, close_cb, NULL);
+    }
+
+    gtk_widget_destroy (dialog);
+    g_object_unref (cdo);
+}
+
+static void
+show_dialog (
+    TpSimpleApprover *self,
+    TpChannelDispatchOperation *cdo,
+    TpContact *target)
+{
+    GFile *avatar_file = tp_contact_get_avatar_file (target);
+    GtkWidget *dialog = gtk_message_dialog_new_with_markup (NULL,
+        0, /* flags */
+        GTK_MESSAGE_QUESTION,
+        GTK_BUTTONS_NONE,
+        "<b>%s</b> (<i>%s</i>) would like to edit a spreadsheet in LibreOffice "
+        "with you.",
+        tp_contact_get_alias (target),
+        tp_contact_get_identifier (target));
+
+    if (avatar_file != NULL)
+    {
+        GtkWidget *avatar = gtk_image_new_from_file (g_file_get_path (avatar_file));
+
+        gtk_message_dialog_set_image (dialog, avatar);
+    }
+
+    gtk_dialog_add_buttons (dialog,
+        "_Reject", GTK_RESPONSE_REJECT,
+        "_Accept", GTK_RESPONSE_ACCEPT,
+        NULL);
+
+    g_object_set_data_full (dialog, "client", g_object_ref (self), g_object_unref);
+    g_signal_connect (dialog, "response", dialog_response_cb, g_object_ref (cdo));
+
+    gtk_window_set_skip_taskbar_hint (dialog, FALSE);
+
+    gtk_widget_show_all (dialog);
+}
+
+static void
+add_dispatch_operation_cb (TpSimpleApprover *self,
+    TpAccount *account,
+    TpConnection *connection,
+    GList *channels,
+    TpChannelDispatchOperation *cdo,
+    TpAddDispatchOperationContext *context,
+    gpointer user_data)
+{
+    TpContact *target = NULL;
+    GList *l;
+
+    g_print ("Approving this batch of channels:\n");
+
+    for (l = channels; l != NULL; l = g_list_next (l))
+    {
+        TpChannel *channel = l->data;
+
+        if (TP_IS_DBUS_TUBE_CHANNEL (channel))
+        {
+            target = tp_channel_get_target_contact (channel);
+            break;
+        }
+    }
+
+    if (target == NULL)
+    {
+        g_critical ("Hmm. No 1-1 D-Bus tube in cdo %s, so why did we get it?",
+            tp_proxy_get_object_path (cdo));
+        g_return_if_reached ();
+    }
+
+    tp_add_dispatch_operation_context_accept (context);
+    show_dialog (self, cdo, target);
+}
+
+int
+main (int argc,
+      char **argv)
+{
+  TpAccountManager *manager;
+  TpSimpleClientFactory *factory;
+  TpBaseClient *approver;
+  GError *error = NULL;
+
+  gtk_init (&argc, &argv);
+  tp_debug_set_flags (g_getenv ("LIBO_APPROVER_DEBUG"));
+
+  manager = tp_account_manager_dup ();
+
+    factory = tp_proxy_get_factory (manager);
+    /* We want the target contact on channels to be available... */
+    tp_simple_client_factory_add_channel_features_varargs (factory,
+        TP_CHANNEL_FEATURE_CONTACTS,
+        0);
+    /* ...and for it to have its alias and avatar available */
+    tp_simple_client_factory_add_contact_features_varargs (factory,
+        TP_CONTACT_FEATURE_ALIAS,
+        TP_CONTACT_FEATURE_AVATAR_DATA,
+        TP_CONTACT_FEATURE_INVALID);
+
+  approver = tp_simple_approver_new_with_am (manager, "LibreOfficeApprover",
+      FALSE, add_dispatch_operation_cb, NULL, NULL);
+
+  tp_base_client_take_approver_filter (approver, tp_asv_new (
+        TP_PROP_CHANNEL_CHANNEL_TYPE, G_TYPE_STRING,
+          TP_IFACE_CHANNEL_TYPE_DBUS_TUBE,
+        TP_PROP_CHANNEL_TARGET_HANDLE_TYPE, G_TYPE_UINT,
+          TP_HANDLE_TYPE_CONTACT,
+        TP_PROP_CHANNEL_TYPE_DBUS_TUBE_SERVICE_NAME, G_TYPE_STRING,
+          LIBO_DTUBE_SERVICE,
+        NULL));
+
+  if (!tp_base_client_register (approver, &error))
+    {
+      g_warning ("Failed to register Approver: %s\n", error->message);
+      g_error_free (error);
+      goto out;
+    }
+
+  g_print ("Start approving\n");
+
+  mainloop = g_main_loop_new (NULL, FALSE);
+  g_main_loop_run (mainloop);
+  /* TODO: time out after 5 seconds of inactivity? */
+
+  if (mainloop != NULL)
+    g_main_loop_unref (mainloop);
+
+out:
+  g_object_unref (manager);
+  g_object_unref (approver);
+
+  return 0;
+}
+
+/* vim:set shiftwidth=4 softtabstop=4 expandtab: */