/* empathy-ft-factory.c */
-#include <glib.h>
-
+#include "config.h"
#include "empathy-ft-factory.h"
-#include "empathy-ft-handler.h"
-#include "empathy-marshal.h"
+
+#include "empathy-request-util.h"
#include "empathy-utils.h"
/**
static EmpathyFTFactory *factory_singleton = NULL;
static guint signals[LAST_SIGNAL] = { 0 };
+/* private structure */
+typedef struct {
+ TpBaseClient *handler;
+} EmpathyFTFactoryPriv;
+
+#define GET_PRIV(obj) EMPATHY_GET_PRIV (obj, EmpathyFTFactory)
+
static GObject *
do_constructor (GType type,
guint n_props,
GObjectConstructParam *props)
{
- GObject *retval;
+ GObject *retval;
+
+ if (factory_singleton != NULL)
+ {
+ retval = g_object_ref (factory_singleton);
+ }
+ else
+ {
+ retval = G_OBJECT_CLASS (empathy_ft_factory_parent_class)->constructor
+ (type, n_props, props);
+
+ factory_singleton = EMPATHY_FT_FACTORY (retval);
+ g_object_add_weak_pointer (retval, (gpointer *) &factory_singleton);
+ }
+
+ return retval;
+}
- if (factory_singleton != NULL) {
- retval = g_object_ref (factory_singleton);
- } else {
- retval = G_OBJECT_CLASS (empathy_ft_factory_parent_class)->constructor
- (type, n_props, props);
+static void
+empathy_ft_factory_dispose (GObject *object)
+{
+ EmpathyFTFactory *self = (EmpathyFTFactory *) object;
+ EmpathyFTFactoryPriv *priv = GET_PRIV (self);
- factory_singleton = EMPATHY_FT_FACTORY (retval);
- g_object_add_weak_pointer (retval, (gpointer *) &factory_singleton);
- }
+ tp_clear_object (&priv->handler);
- return retval;
+ (G_OBJECT_CLASS (empathy_ft_factory_parent_class)->dispose) (object);
}
static void
{
GObjectClass *object_class = G_OBJECT_CLASS (klass);
+ g_type_class_add_private (klass, sizeof (EmpathyFTFactoryPriv));
+
object_class->constructor = do_constructor;
+ object_class->dispose = empathy_ft_factory_dispose;
/**
* EmpathyFTFactory::new-ft-handler
G_TYPE_FROM_CLASS (klass),
G_SIGNAL_RUN_LAST, 0,
NULL, NULL,
- _empathy_marshal_VOID__OBJECT_POINTER,
+ g_cclosure_marshal_generic,
G_TYPE_NONE, 2, EMPATHY_TYPE_FT_HANDLER, G_TYPE_POINTER);
/**
G_TYPE_FROM_CLASS (klass),
G_SIGNAL_RUN_LAST, 0,
NULL, NULL,
- _empathy_marshal_VOID__OBJECT_POINTER,
+ g_cclosure_marshal_generic,
G_TYPE_NONE, 2, EMPATHY_TYPE_FT_HANDLER, G_TYPE_POINTER);
}
static void
-empathy_ft_factory_init (EmpathyFTFactory *self)
+ft_handler_incoming_ready_cb (EmpathyFTHandler *handler,
+ GError *error,
+ gpointer user_data)
{
- /* do nothing */
+ EmpathyFTFactory *factory = user_data;
+
+ g_signal_emit (factory, signals[NEW_INCOMING_TRANSFER], 0, handler, error);
}
static void
-ft_handler_outgoing_ready_cb (EmpathyFTHandler *handler,
- GError *error,
+handle_channels_cb (TpSimpleHandler *handler,
+ TpAccount *account,
+ TpConnection *connection,
+ GList *channels,
+ GList *requests_satisfied,
+ gint64 user_action_time,
+ TpHandleChannelsContext *context,
gpointer user_data)
{
- EmpathyFTFactory *factory = user_data;
+ EmpathyFTFactory *self = user_data;
+ GList *l;
- g_signal_emit (factory, signals[NEW_FT_HANDLER], 0, handler, error);
+ for (l = channels; l != NULL; l = g_list_next (l))
+ {
+ TpChannel *channel = l->data;
+
+ if (tp_proxy_get_invalidated (channel) != NULL)
+ continue;
+
+ if (!TP_IS_FILE_TRANSFER_CHANNEL (channel))
+ continue;
+
+ /* We handle only incoming FT */
+ empathy_ft_handler_new_incoming ((TpFileTransferChannel *) channel,
+ ft_handler_incoming_ready_cb, self);
+ }
+
+
+ tp_handle_channels_context_accept (context);
}
static void
-ft_handler_incoming_ready_cb (EmpathyFTHandler *handler,
+empathy_ft_factory_init (EmpathyFTFactory *self)
+{
+ EmpathyFTFactoryPriv *priv = G_TYPE_INSTANCE_GET_PRIVATE (self,
+ EMPATHY_TYPE_FT_FACTORY, EmpathyFTFactoryPriv);
+ TpAccountManager *am;
+
+ self->priv = priv;
+
+ am = tp_account_manager_dup ();
+
+ priv->handler = tp_simple_handler_new_with_am (am, FALSE, FALSE,
+ EMPATHY_FT_BUS_NAME_SUFFIX, FALSE, handle_channels_cb, self, NULL);
+
+ tp_base_client_take_handler_filter (priv->handler, tp_asv_new (
+ TP_PROP_CHANNEL_CHANNEL_TYPE, G_TYPE_STRING,
+ TP_IFACE_CHANNEL_TYPE_FILE_TRANSFER,
+ TP_PROP_CHANNEL_TARGET_HANDLE_TYPE, G_TYPE_UINT, TP_HANDLE_TYPE_CONTACT,
+ /* Only handle *incoming* channels as outgoing FT channels has to be
+ * handled by the requester. */
+ TP_PROP_CHANNEL_REQUESTED, G_TYPE_BOOLEAN, FALSE,
+ NULL));
+
+ g_object_unref (am);
+}
+
+static void
+ft_handler_outgoing_ready_cb (EmpathyFTHandler *handler,
GError *error,
gpointer user_data)
{
- EmpathyFTFactory *factory = user_data;
+ EmpathyFTFactory *factory = EMPATHY_FT_FACTORY (user_data);
- g_signal_emit (factory, signals[NEW_INCOMING_TRANSFER], 0, handler, error);
+ g_signal_emit (factory, signals[NEW_FT_HANDLER], 0, handler, error);
+
+ g_object_unref (factory);
}
/* public methods */
void
empathy_ft_factory_new_transfer_outgoing (EmpathyFTFactory *factory,
EmpathyContact *contact,
- GFile *source)
+ GFile *source,
+ gint64 action_time)
{
g_return_if_fail (EMPATHY_IS_FT_FACTORY (factory));
g_return_if_fail (EMPATHY_IS_CONTACT (contact));
g_return_if_fail (G_IS_FILE (source));
- empathy_ft_handler_new_outgoing (contact, source,
- ft_handler_outgoing_ready_cb, factory);
-}
-
-/**
- * empathy_ft_factory_claim_channel:
- * @factory: an #EmpathyFTFactory
- * @operation: the #EmpathyDispatchOperation wrapping the channel
- *
- * Let the @factory claim the channel, starting the creation of a new
- * incoming #EmpathyFTHandler.
- */
-void
-empathy_ft_factory_claim_channel (EmpathyFTFactory *factory,
- EmpathyDispatchOperation *operation)
-{
- EmpathyTpFile *tp_file;
-
- g_return_if_fail (EMPATHY_IS_FT_FACTORY (factory));
- g_return_if_fail (EMPATHY_IS_DISPATCH_OPERATION (operation));
-
- /* own a reference to the EmpathyTpFile */
- tp_file = EMPATHY_TP_FILE
- ((empathy_dispatch_operation_get_channel_wrapper (operation)));
-
- empathy_ft_handler_new_incoming (tp_file, ft_handler_incoming_ready_cb,
- factory);
-
- empathy_dispatch_operation_claim (operation);
+ empathy_ft_handler_new_outgoing (contact, source, action_time,
+ ft_handler_outgoing_ready_cb, g_object_ref (factory));
}
/**
g_signal_emit (factory, signals[NEW_FT_HANDLER], 0, handler, NULL);
}
+
+gboolean
+empathy_ft_factory_register (EmpathyFTFactory *self,
+ GError **error)
+{
+ EmpathyFTFactoryPriv *priv = GET_PRIV (self);
+
+ return tp_base_client_register (priv->handler, error);
+}
projects / empathy.git / blobdiff