aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat
-rw-r--r--libempathy/Makefile.am2
-rw-r--r--libempathy/empathy-server-tls-handler.c265
-rw-r--r--libempathy/empathy-server-tls-handler.h74
3 files changed, 341 insertions, 0 deletions
diff --git a/libempathy/Makefile.am b/libempathy/Makefile.am
index 096985358..2817ae650 100644
--- a/libempathy/Makefile.am
+++ b/libempathy/Makefile.am
@@ -48,6 +48,7 @@ libempathy_headers = \
empathy-irc-server.h \
empathy-location.h \
empathy-message.h \
+ empathy-server-tls-handler.h \
empathy-status-presets.h \
empathy-time.h \
empathy-tls-certificate.h \
@@ -83,6 +84,7 @@ libempathy_la_SOURCES = \
empathy-irc-network.c \
empathy-irc-server.c \
empathy-message.c \
+ empathy-server-tls-handler.c \
empathy-status-presets.c \
empathy-time.c \
empathy-tls-certificate.c \
diff --git a/libempathy/empathy-server-tls-handler.c b/libempathy/empathy-server-tls-handler.c
new file mode 100644
index 000000000..3ca950715
--- /dev/null
+++ b/libempathy/empathy-server-tls-handler.c
@@ -0,0 +1,265 @@
+/*
+ * empathy-server-tls-handler.c - Source for EmpathyServerTLSHandler
+ * Copyright (C) 2010 Collabora Ltd.
+ * @author Cosimo Cecchi <cosimo.cecchi@collabora.co.uk>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2.1 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
+ */
+
+#include "empathy-server-tls-handler.h"
+
+#define DEBUG_FLAG EMPATHY_DEBUG_TLS
+#include "empathy-debug.h"
+#include "empathy-tls-certificate.h"
+#include "empathy-utils.h"
+
+#include "extensions/extensions.h"
+
+static void async_initable_iface_init (GAsyncInitableIface *iface);
+
+enum {
+ PROP_CHANNEL = 1,
+ LAST_PROPERTY,
+};
+
+typedef struct {
+ TpChannel *channel;
+
+ EmpathyTLSCertificate *certificate;
+
+ GSimpleAsyncResult *async_init_res;
+} EmpathyServerTLSHandlerPriv;
+
+G_DEFINE_TYPE_WITH_CODE (EmpathyServerTLSHandler, empathy_server_tls_handler,
+ G_TYPE_OBJECT,
+ G_IMPLEMENT_INTERFACE (G_TYPE_ASYNC_INITABLE, async_initable_iface_init));
+
+#define GET_PRIV(obj) EMPATHY_GET_PRIV (obj, EmpathyServerTLSHandler);
+
+static void
+tls_certificate_constructed_cb (GObject *source,
+ GAsyncResult *result,
+ gpointer user_data)
+{
+ EmpathyTLSCertificate *certificate;
+ EmpathyServerTLSHandler *self = user_data;
+ GError *error = NULL;
+ EmpathyServerTLSHandlerPriv *priv = GET_PRIV (self);
+
+ certificate = empathy_tls_certificate_new_finish (result, &error);
+
+ if (error != NULL)
+ {
+ g_simple_async_result_set_from_error (priv->async_init_res, error);
+ g_error_free (error);
+ }
+ else
+ {
+ priv->certificate = certificate;
+ }
+
+ g_simple_async_result_complete_in_idle (priv->async_init_res);
+}
+
+static void
+server_tls_channel_got_all_cb (TpProxy *proxy,
+ GHashTable *properties,
+ const GError *error,
+ gpointer user_data,
+ GObject *weak_object)
+{
+ EmpathyServerTLSHandler *self = EMPATHY_SERVER_TLS_HANDLER (weak_object);
+ EmpathyServerTLSHandlerPriv *priv = GET_PRIV (self);
+
+ if (error != NULL)
+ {
+ g_simple_async_result_set_from_error (priv->async_init_res, error);
+ g_simple_async_result_complete_in_idle (priv->async_init_res);
+ }
+ else
+ {
+ const gchar *cert_object_path;
+
+ cert_object_path = tp_asv_get_object_path (properties,
+ "ServerCertificate");
+
+ DEBUG ("Creating an EmpathyTLSCertificate for path %s, bus name %s",
+ cert_object_path, tp_proxy_get_bus_name (proxy));
+
+ empathy_tls_certificate_new_async (
+ tp_proxy_get_bus_name (proxy),
+ cert_object_path,
+ tls_certificate_constructed_cb, self);
+ }
+}
+
+static gboolean
+tls_handler_init_finish (GAsyncInitable *initable,
+ GAsyncResult *res,
+ GError **error)
+{
+ gboolean retval = TRUE;
+ EmpathyServerTLSHandler *self = EMPATHY_SERVER_TLS_HANDLER (initable);
+ EmpathyServerTLSHandlerPriv *priv = GET_PRIV (self);
+
+ if (g_simple_async_result_propagate_error (priv->async_init_res, error))
+ retval = FALSE;
+
+ return retval;
+}
+
+static void
+tls_handler_init_async (GAsyncInitable *initable,
+ gint io_priority,
+ GCancellable *cancellable,
+ GAsyncReadyCallback callback,
+ gpointer user_data)
+{
+ EmpathyServerTLSHandler *self = EMPATHY_SERVER_TLS_HANDLER (initable);
+ EmpathyServerTLSHandlerPriv *priv = GET_PRIV (self);
+
+ g_assert (priv->channel != NULL);
+
+ priv->async_init_res = g_simple_async_result_new (G_OBJECT (self),
+ callback, user_data, NULL);
+
+ /* call GetAll() on the channel properties */
+ tp_cli_dbus_properties_call_get_all (priv->channel,
+ -1, EMP_IFACE_CHANNEL_TYPE_SERVER_TLS_CONNECTION,
+ server_tls_channel_got_all_cb, NULL, NULL, G_OBJECT (self));
+}
+
+static void
+async_initable_iface_init (GAsyncInitableIface *iface)
+{
+ iface->init_async = tls_handler_init_async;
+ iface->init_finish = tls_handler_init_finish;
+}
+
+static void
+empathy_server_tls_handler_finalize (GObject *object)
+{
+ EmpathyServerTLSHandlerPriv *priv = GET_PRIV (object);
+
+ if (priv->channel != NULL)
+ g_object_unref (priv->channel);
+
+ G_OBJECT_CLASS (empathy_server_tls_handler_parent_class)->finalize (object);
+}
+
+static void
+empathy_server_tls_handler_get_property (GObject *object,
+ guint property_id,
+ GValue *value,
+ GParamSpec *pspec)
+{
+ EmpathyServerTLSHandlerPriv *priv = GET_PRIV (object);
+
+ switch (property_id)
+ {
+ case PROP_CHANNEL:
+ g_value_set_object (value, priv->channel);
+ break;
+ default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
+ break;
+ }
+}
+
+static void
+empathy_server_tls_handler_set_property (GObject *object,
+ guint property_id,
+ const GValue *value,
+ GParamSpec *pspec)
+{
+ EmpathyServerTLSHandlerPriv *priv = GET_PRIV (object);
+
+ switch (property_id)
+ {
+ case PROP_CHANNEL:
+ priv->channel = g_value_dup_object (value);
+ break;
+ default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
+ break;
+ }
+}
+
+static void
+empathy_server_tls_handler_class_init (EmpathyServerTLSHandlerClass *klass)
+{
+ GObjectClass *oclass = G_OBJECT_CLASS (klass);
+ GParamSpec *pspec;
+
+ oclass->get_property = empathy_server_tls_handler_get_property;
+ oclass->set_property = empathy_server_tls_handler_set_property;
+ oclass->finalize = empathy_server_tls_handler_finalize;
+
+ g_type_class_add_private (klass, sizeof (EmpathyServerTLSHandlerPriv));
+
+ pspec = g_param_spec_object ("channel", "The TpChannel",
+ "The TpChannel this handler is supposed to handle.",
+ TP_TYPE_CHANNEL,
+ G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY | G_PARAM_STATIC_STRINGS);
+ g_object_class_install_property (oclass, PROP_CHANNEL, pspec);
+}
+
+static void
+empathy_server_tls_handler_init (EmpathyServerTLSHandler *self)
+{
+ self->priv = G_TYPE_INSTANCE_GET_PRIVATE (self,
+ EMPATHY_TYPE_SERVER_TLS_HANDLER, EmpathyServerTLSHandlerPriv);
+}
+
+void
+empathy_server_tls_handler_new_async (TpChannel *channel,
+ GAsyncReadyCallback callback,
+ gpointer user_data)
+{
+ g_assert (TP_IS_CHANNEL (channel));
+ g_assert (channel != NULL);
+
+ g_async_initable_new_async (EMPATHY_TYPE_SERVER_TLS_HANDLER,
+ G_PRIORITY_DEFAULT, NULL, callback, user_data,
+ "channel", channel, NULL);
+}
+
+EmpathyServerTLSHandler *
+empathy_server_tls_handler_new_finish (GAsyncResult *result,
+ GError **error)
+{
+ GObject *object, *source_object;
+
+ source_object = g_async_result_get_source_object (result);
+
+ object = g_async_initable_new_finish (G_ASYNC_INITABLE (source_object),
+ result, error);
+ g_object_unref (source_object);
+
+ if (object != NULL)
+ return EMPATHY_SERVER_TLS_HANDLER (object);
+ else
+ return NULL;
+}
+
+EmpathyTLSCertificate *
+empathy_server_tls_handler_get_certificate (EmpathyServerTLSHandler *self)
+{
+ EmpathyServerTLSHandlerPriv *priv = GET_PRIV (self);
+
+ g_assert (priv->certificate != NULL);
+
+ return priv->certificate;
+}
diff --git a/libempathy/empathy-server-tls-handler.h b/libempathy/empathy-server-tls-handler.h
new file mode 100644
index 000000000..558a8512f
--- /dev/null
+++ b/libempathy/empathy-server-tls-handler.h
@@ -0,0 +1,74 @@
+/*
+ * empathy-server-tls-handler.h - Header for EmpathyServerTLSHandler
+ * Copyright (C) 2010 Collabora Ltd.
+ * @author Cosimo Cecchi <cosimo.cecchi@collabora.co.uk>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2.1 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
+ */
+
+#ifndef __EMPATHY_SERVER_TLS_HANDLER_H__
+#define __EMPATHY_SERVER_TLS_HANDLER_H__
+
+#include <glib-object.h>
+#include <gio/gio.h>
+
+#include <telepathy-glib/channel.h>
+
+#include <libempathy/empathy-tls-certificate.h>
+
+G_BEGIN_DECLS
+
+typedef struct _EmpathyServerTLSHandler EmpathyServerTLSHandler;
+typedef struct _EmpathyServerTLSHandlerClass EmpathyServerTLSHandlerClass;
+
+struct _EmpathyServerTLSHandlerClass {
+ GObjectClass parent_class;
+};
+
+struct _EmpathyServerTLSHandler {
+ GObject parent;
+ gpointer priv;
+};
+
+GType empathy_server_tls_handler_get_type (void);
+
+#define EMPATHY_TYPE_SERVER_TLS_HANDLER \
+ (empathy_server_tls_handler_get_type ())
+#define EMPATHY_SERVER_TLS_HANDLER(obj) \
+ (G_TYPE_CHECK_INSTANCE_CAST((obj), EMPATHY_TYPE_SERVER_TLS_HANDLER, \
+ EmpathyServerTLSHandler))
+#define EMPATHY_SERVER_TLS_HANDLER_CLASS(klass) \
+ (G_TYPE_CHECK_CLASS_CAST((klass), EMPATHY_TYPE_SERVER_TLS_HANDLER, \
+ EmpathyServerTLSHandlerClass))
+#define EMPATHY_IS_SERVER_TLS_HANDLER(obj) \
+ (G_TYPE_CHECK_INSTANCE_TYPE((obj), EMPATHY_TYPE_SERVER_TLS_HANDLER))
+#define EMPATHY_IS_SERVER_TLS_HANDLER_CLASS(klass) \
+ (G_TYPE_CHECK_CLASS_TYPE((klass), EMPATHY_TYPE_SERVER_TLS_HANDLER))
+#define EMPATHY_SERVER_TLS_HANDLER_GET_CLASS(obj) \
+ (G_TYPE_INSTANCE_GET_CLASS ((obj), EMPATHY_TYPE_SERVER_TLS_HANDLER, \
+ EmpathyServerTLSHandlerClass))
+
+void empathy_server_tls_handler_new_async (TpChannel *channel,
+ GAsyncReadyCallback callback, gpointer user_data);
+EmpathyServerTLSHandler * empathy_server_tls_handler_new_finish (
+ GAsyncResult *result, GError **error);
+
+EmpathyTLSCertificate * empathy_server_tls_handler_get_certificate (
+ EmpathyServerTLSHandler *self);
+
+
+G_END_DECLS
+
+#endif /* #ifndef __EMPATHY_SERVER_TLS_HANDLER_H__*/
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-08 08:11:07 +0800