libempathy/empathy-dispatcher.c

   1 /* * Copyright (C) 2007-2009 Collabora Ltd.
   2  *
   3  * This library is free software; you can redistribute it and/or
   4  * modify it under the terms of the GNU Lesser General Public
   5  * License as published by the Free Software Foundation; either
   6  * version 2.1 of the License, or (at your option) any later version.
   7  *
   8  * This library is distributed in the hope that it will be useful,
   9  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  10  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  11  * Lesser General Public License for more details.
  12  *
  13  * You should have received a copy of the GNU Lesser General Public
  14  * License along with this library; if not, write to the Free Software
  15  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
  16  *
  17  * Authors: Xavier Claessens <xclaesse@gmail.com>
  18  *          Sjoerd Simons <sjoerd.simons@collabora.co.uk>
  19  *          Cosimo Cecchi <cosimo.cecchi@collabora.co.uk>
  20  */
  21
  22 #define DISPATCHER_BUS_NAME TP_CLIENT_BUS_NAME_BASE "Empathy"
  23 #define DISPATCHER_OBJECT_PATH TP_CLIENT_OBJECT_PATH_BASE "Empathy"
  24
  25 #include <config.h>
  26
  27 #include <string.h>
  28
  29 #include <glib/gi18n-lib.h>
  30
  31 #include <telepathy-glib/enums.h>
  32 #include <telepathy-glib/connection.h>
  33 #include <telepathy-glib/util.h>
  34 #include <telepathy-glib/dbus.h>
  35 #include <telepathy-glib/proxy-subclass.h>
  36 #include <telepathy-glib/gtypes.h>
  37 #include <telepathy-glib/defs.h>
  38 #include <telepathy-glib/svc-client.h>
  39 #include <telepathy-glib/svc-generic.h>
  40 #include <telepathy-glib/interfaces.h>
  41
  42 #include <extensions/extensions.h>
  43
  44 #include "empathy-dispatcher.h"
  45 #include "empathy-handler.h"
  46 #include "empathy-utils.h"
  47 #include "empathy-tube-handler.h"
  48 #include "empathy-account-manager.h"
  49 #include "empathy-tp-contact-factory.h"
  50 #include "empathy-chatroom-manager.h"
  51 #include "empathy-utils.h"
  52
  53 #define DEBUG_FLAG EMPATHY_DEBUG_DISPATCHER
  54 #include <libempathy/empathy-debug.h>
  55
  56 #define GET_PRIV(obj) EMPATHY_GET_PRIV (obj, EmpathyDispatcher)
  57 typedef struct
  58 {
  59   gboolean dispose_has_run;
  60
  61   EmpathyAccountManager *account_manager;
  62   /* connection to connection data mapping */
  63   GHashTable *connections;
  64   GHashTable *outstanding_classes_requests;
  65   gpointer token;
  66   GSList *tubes;
  67
  68   /* channels which the dispatcher is listening "invalidated" */
  69   GList *channels;
  70   GPtrArray *array;
  71
  72   /* main handler */
  73   EmpathyHandler *handler;
  74
  75   /* extra handlers */
  76   GList *handlers;
  77
  78   GHashTable *request_channel_class_async_ids;
  79 } EmpathyDispatcherPriv;
  80
  81 static GList *
  82 empathy_dispatcher_get_channels (EmpathyHandler *handler,
  83     gpointer user_data);
  84
  85 static gboolean
  86 empathy_dispatcher_handle_channels (EmpathyHandler *handler,
  87     const gchar *account_path,
  88     const gchar *connection_path,
  89     const GPtrArray *channels,
  90     const GPtrArray *requests_satisfied,
  91     guint64 timestamp,
  92     GHashTable *handler_info,
  93     gpointer user_data,
  94     GError **error);
  95
  96 G_DEFINE_TYPE (EmpathyDispatcher, empathy_dispatcher, G_TYPE_OBJECT);
  97
  98 enum
  99 {
 100   PROP_INTERFACES = 1,
 101   PROP_HANDLER,
 102 };
 103
 104 enum
 105 {
 106   OBSERVE,
 107   APPROVE,
 108   DISPATCH,
 109   LAST_SIGNAL
 110 };
 111
 112 static guint signals[LAST_SIGNAL];
 113 static EmpathyDispatcher *dispatcher = NULL;
 114
 115 static void dispatcher_init_connection_if_needed (
 116     EmpathyDispatcher *dispatcher,
 117     TpConnection *connection);
 118
 119 static GList * empathy_dispatcher_find_channel_classes
 120   (EmpathyDispatcher *dispatcher, TpConnection *connection,
 121    const gchar *channel_type, guint handle_type, GArray *fixed_properties);
 122
 123
 124 typedef struct
 125 {
 126   EmpathyDispatcher *dispatcher;
 127   EmpathyDispatchOperation *operation;
 128   TpConnection *connection;
 129   gboolean should_ensure;
 130   gchar *channel_type;
 131   guint handle_type;
 132   guint handle;
 133   EmpathyContact *contact;
 134   TpProxyPendingCall *pending_call;
 135
 136   /* Properties to pass to the channel when requesting it */
 137   GHashTable *request;
 138   EmpathyDispatcherRequestCb *cb;
 139   gpointer user_data;
 140   gpointer *request_data;
 141 } DispatcherRequestData;
 142
 143 typedef struct
 144 {
 145   TpChannel *channel;
 146   /* Channel type specific wrapper object */
 147   GObject *channel_wrapper;
 148 } DispatchData;
 149
 150 typedef struct
 151 {
 152   /* ObjectPath => DispatchData.. */
 153   GHashTable *dispatched_channels;
 154   /* ObjectPath -> EmpathyDispatchOperations */
 155   GHashTable *dispatching_channels;
 156
 157   /* ObjectPath -> EmpathyDispatchOperations
 158    *
 159    * This holds channels which were announced with NewChannel while we have an
 160    * outstanding channel request for a channel of this type. On the Requests
 161    * interface, CreateChannel and EnsureChannel are guaranteed by the spec to
 162    * return before NewChannels is emitted, but there was no guarantee of the
 163    * ordering of RequestChannel vs. NewChannel. So if necessary, channels are
 164    * held in limbo here until we know whether they were requested.
 165    */
 166   GHashTable *outstanding_channels;
 167   /* List of DispatcherRequestData */
 168   GList *outstanding_requests;
 169   /* List of requestable channel classes */
 170   GPtrArray *requestable_channels;
 171 } ConnectionData;
 172
 173 typedef struct
 174 {
 175   EmpathyDispatcher *dispatcher;
 176   TpConnection *connection;
 177   char *channel_type;
 178   guint handle_type;
 179   GArray *properties;
 180   EmpathyDispatcherFindChannelClassCb *callback;
 181   gpointer user_data;
 182 } FindChannelRequest;
 183
 184 static void
 185 empathy_dispatcher_call_create_or_ensure_channel (
 186     EmpathyDispatcher *dispatcher,
 187     DispatcherRequestData *request_data);
 188
 189 static DispatchData *
 190 new_dispatch_data (TpChannel *channel,
 191                    GObject *channel_wrapper)
 192 {
 193   DispatchData *d = g_slice_new0 (DispatchData);
 194   d->channel = g_object_ref (channel);
 195   if (channel_wrapper != NULL)
 196     d->channel_wrapper = g_object_ref (channel_wrapper);
 197
 198   return d;
 199 }
 200
 201 static void
 202 free_dispatch_data (DispatchData *data)
 203 {
 204   g_object_unref (data->channel);
 205   if (data->channel_wrapper != NULL)
 206     g_object_unref (data->channel_wrapper);
 207
 208   g_slice_free (DispatchData, data);
 209 }
 210
 211 static DispatcherRequestData *
 212 new_dispatcher_request_data (EmpathyDispatcher *dispatcher,
 213                              TpConnection *connection,
 214                              const gchar *channel_type,
 215                              guint handle_type,
 216                              guint handle,
 217                              GHashTable *request,
 218                              EmpathyContact *contact,
 219                              EmpathyDispatcherRequestCb *cb,
 220                              gpointer user_data)
 221 {
 222   DispatcherRequestData *result = g_slice_new0 (DispatcherRequestData);
 223
 224   result->dispatcher = g_object_ref (dispatcher);
 225   result->connection = connection;
 226
 227   result->should_ensure = FALSE;
 228
 229   result->channel_type = g_strdup (channel_type);
 230   result->handle_type = handle_type;
 231   result->handle = handle;
 232   result->request = request;
 233
 234   if (contact != NULL)
 235     result->contact = g_object_ref (contact);
 236
 237   result->cb = cb;
 238   result->user_data = user_data;
 239
 240   return result;
 241 }
 242
 243 static void
 244 free_dispatcher_request_data (DispatcherRequestData *r)
 245 {
 246   g_free (r->channel_type);
 247
 248   if (r->dispatcher != NULL)
 249     g_object_unref (r->dispatcher);
 250
 251   if (r->contact != NULL)
 252     g_object_unref (r->contact);
 253
 254   if (r->request != NULL)
 255     g_hash_table_unref (r->request);
 256
 257   g_slice_free (DispatcherRequestData, r);
 258 }
 259
 260 static ConnectionData *
 261 new_connection_data (void)
 262 {
 263   ConnectionData *cd = g_slice_new0 (ConnectionData);
 264
 265   cd->dispatched_channels = g_hash_table_new_full (g_str_hash, g_str_equal,
 266       g_free, (GDestroyNotify) free_dispatch_data);
 267
 268   cd->dispatching_channels = g_hash_table_new_full (g_str_hash, g_str_equal,
 269       g_free, g_object_unref);
 270
 271   cd->outstanding_channels = g_hash_table_new_full (g_str_hash, g_str_equal,
 272       g_free, NULL);
 273
 274   return cd;
 275 }
 276
 277 static void
 278 free_connection_data (ConnectionData *cd)
 279 {
 280   GList *l;
 281
 282   g_hash_table_destroy (cd->dispatched_channels);
 283   g_hash_table_destroy (cd->dispatching_channels);
 284   int i;
 285
 286   for (l = cd->outstanding_requests ; l != NULL; l = g_list_delete_link (l,l))
 287     {
 288       DispatcherRequestData *data = l->data;
 289       tp_proxy_pending_call_cancel (data->pending_call);
 290       free_dispatcher_request_data (l->data);
 291     }
 292
 293   if (cd->requestable_channels  != NULL)
 294     {
 295       for (i = 0 ; i < cd->requestable_channels->len ; i++)
 296           g_value_array_free (
 297             g_ptr_array_index (cd->requestable_channels, i));
 298       g_ptr_array_free (cd->requestable_channels, TRUE);
 299     }
 300 }
 301
 302 static void
 303 free_find_channel_request (FindChannelRequest *r)
 304 {
 305   int idx;
 306   char *str;
 307
 308   g_object_unref (r->dispatcher);
 309   g_free (r->channel_type);
 310
 311   if (r->properties != NULL)
 312     {
 313       for (idx = 0; idx < r->properties->len ; idx++)
 314         {
 315           str = g_array_index (r->properties, char *, idx);
 316           g_free (str);
 317         }
 318
 319       g_array_free (r->properties, TRUE);
 320     }
 321
 322   g_slice_free (FindChannelRequest, r);
 323 }
 324
 325 static void
 326 dispatcher_connection_invalidated_cb (TpConnection *connection,
 327                                       guint domain,
 328                                       gint code,
 329                                       gchar *message,
 330                                       EmpathyDispatcher *dispatcher)
 331 {
 332   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
 333
 334   DEBUG ("Error: %s", message);
 335   g_hash_table_remove (priv->connections, connection);
 336 }
 337
 338 static gboolean
 339 dispatcher_operation_can_start (EmpathyDispatcher *self,
 340                                 EmpathyDispatchOperation *operation,
 341                                 ConnectionData *cd)
 342 {
 343   GList *l;
 344   const gchar *channel_type =
 345     empathy_dispatch_operation_get_channel_type (operation);
 346
 347   for (l = cd->outstanding_requests; l != NULL; l = g_list_next (l))
 348     {
 349       DispatcherRequestData *d = (DispatcherRequestData *) l->data;
 350
 351       if (d->operation == NULL && !tp_strdiff (d->channel_type, channel_type))
 352         {
 353           return FALSE;
 354         }
 355     }
 356
 357   return TRUE;
 358 }
 359
 360 static void
 361 dispatch_operation_flush_requests (EmpathyDispatcher *dispatcher,
 362                                    EmpathyDispatchOperation *operation,
 363                                    GError *error,
 364                                    ConnectionData *cd)
 365 {
 366   GList *l;
 367
 368   l = cd->outstanding_requests;
 369   while (l != NULL)
 370     {
 371       DispatcherRequestData *d = (DispatcherRequestData *) l->data;
 372       GList *lt = l;
 373
 374       l = g_list_next (l);
 375
 376       if (d->operation == operation)
 377         {
 378           if (d->cb != NULL)
 379             {
 380               if (error != NULL)
 381                 d->cb (NULL, error, d->user_data);
 382               else
 383                 d->cb (operation, NULL, d->user_data);
 384             }
 385
 386           cd->outstanding_requests = g_list_delete_link
 387             (cd->outstanding_requests, lt);
 388
 389           free_dispatcher_request_data (d);
 390         }
 391     }
 392 }
 393
 394 static void
 395 dispatcher_channel_invalidated_cb (TpProxy *proxy,
 396                                    guint domain,
 397                                    gint code,
 398                                    gchar *message,
 399                                    EmpathyDispatcher *dispatcher)
 400 {
 401   /* Channel went away... */
 402   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
 403   TpConnection *connection;
 404   EmpathyDispatchOperation *operation;
 405   ConnectionData *cd;
 406   const gchar *object_path;
 407
 408   connection = tp_channel_borrow_connection (TP_CHANNEL (proxy));
 409
 410   cd = g_hash_table_lookup (priv->connections, connection);
 411   /* Connection itself invalidated? */
 412   if (cd == NULL)
 413     return;
 414
 415   object_path = tp_proxy_get_object_path (proxy);
 416
 417   DEBUG ("Channel %s invalidated", object_path);
 418
 419   g_hash_table_remove (cd->dispatched_channels, object_path);
 420   g_hash_table_remove (cd->dispatching_channels, object_path);
 421
 422   priv->channels = g_list_remove (priv->channels, proxy);
 423
 424   operation = g_hash_table_lookup (cd->outstanding_channels, object_path);
 425   if (operation != NULL)
 426     {
 427       GError error = { domain, code, message };
 428       dispatch_operation_flush_requests (dispatcher, operation, &error, cd);
 429       g_hash_table_remove (cd->outstanding_channels, object_path);
 430       g_object_unref (operation);
 431     }
 432 }
 433
 434 static void
 435 dispatch_operation_approved_cb (EmpathyDispatchOperation *operation,
 436                                 EmpathyDispatcher *dispatcher)
 437 {
 438   g_assert (empathy_dispatch_operation_is_incoming (operation));
 439   DEBUG ("Send of for dispatching: %s",
 440     empathy_dispatch_operation_get_object_path (operation));
 441   g_signal_emit (dispatcher, signals[DISPATCH], 0, operation);
 442 }
 443
 444 static void
 445 dispatch_operation_claimed_cb (EmpathyDispatchOperation *operation,
 446                                EmpathyDispatcher *dispatcher)
 447 {
 448   /* Our job is done, remove the dispatch operation and mark the channel as
 449    * dispatched */
 450   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
 451   TpConnection *connection;
 452   ConnectionData *cd;
 453   const gchar *object_path;
 454
 455   connection = empathy_dispatch_operation_get_tp_connection (operation);
 456   cd = g_hash_table_lookup (priv->connections, connection);
 457   g_assert (cd != NULL);
 458
 459   object_path = empathy_dispatch_operation_get_object_path (operation);
 460
 461   if (g_hash_table_lookup (cd->dispatched_channels, object_path) == NULL)
 462     {
 463       DispatchData *d;
 464       d = new_dispatch_data (
 465         empathy_dispatch_operation_get_channel (operation),
 466         empathy_dispatch_operation_get_channel_wrapper (operation));
 467       g_hash_table_insert (cd->dispatched_channels,
 468         g_strdup (object_path), d);
 469     }
 470   g_hash_table_remove (cd->dispatching_channels, object_path);
 471
 472   DEBUG ("Channel claimed: %s", object_path);
 473 }
 474
 475 static void
 476 dispatch_operation_ready_cb (EmpathyDispatchOperation *operation,
 477                              EmpathyDispatcher *dispatcher)
 478 {
 479   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
 480   TpConnection *connection;
 481   ConnectionData *cd;
 482   EmpathyDispatchOperationState status;
 483
 484   g_signal_connect (operation, "approved",
 485     G_CALLBACK (dispatch_operation_approved_cb), dispatcher);
 486
 487   g_signal_connect (operation, "claimed",
 488     G_CALLBACK (dispatch_operation_claimed_cb), dispatcher);
 489
 490   /* Signal the observers */
 491   DEBUG ("Send to observers: %s",
 492     empathy_dispatch_operation_get_object_path (operation));
 493   g_signal_emit (dispatcher, signals[OBSERVE], 0, operation);
 494
 495   empathy_dispatch_operation_start (operation);
 496
 497   /* Signal potential requestors */
 498   connection =  empathy_dispatch_operation_get_tp_connection (operation);
 499   cd = g_hash_table_lookup (priv->connections, connection);
 500   g_assert (cd != NULL);
 501
 502   g_object_ref (operation);
 503   g_object_ref (dispatcher);
 504
 505   dispatch_operation_flush_requests (dispatcher, operation, NULL, cd);
 506   status = empathy_dispatch_operation_get_status (operation);
 507   g_object_unref (operation);
 508
 509   if (status == EMPATHY_DISPATCHER_OPERATION_STATE_CLAIMED)
 510     return;
 511
 512   if (status == EMPATHY_DISPATCHER_OPERATION_STATE_APPROVING)
 513     {
 514       DEBUG ("Send to approvers: %s",
 515         empathy_dispatch_operation_get_object_path (operation));
 516       g_signal_emit (dispatcher, signals[APPROVE], 0, operation);
 517     }
 518   else
 519     {
 520       g_assert (status == EMPATHY_DISPATCHER_OPERATION_STATE_DISPATCHING);
 521       DEBUG ("Send of for dispatching: %s",
 522         empathy_dispatch_operation_get_object_path (operation));
 523       g_signal_emit (dispatcher, signals[DISPATCH], 0, operation);
 524     }
 525
 526   g_object_unref (dispatcher);
 527 }
 528
 529 static void
 530 dispatcher_start_dispatching (EmpathyDispatcher *self,
 531                               EmpathyDispatchOperation *operation,
 532                               ConnectionData *cd)
 533 {
 534   const gchar *object_path =
 535     empathy_dispatch_operation_get_object_path (operation);
 536
 537   DEBUG ("Dispatching process started for %s", object_path);
 538
 539   if (g_hash_table_lookup (cd->dispatching_channels, object_path) == NULL)
 540     {
 541       g_assert (g_hash_table_lookup (cd->outstanding_channels,
 542         object_path) == NULL);
 543
 544       g_hash_table_insert (cd->dispatching_channels,
 545         g_strdup (object_path), operation);
 546
 547       switch (empathy_dispatch_operation_get_status (operation))
 548         {
 549           case EMPATHY_DISPATCHER_OPERATION_STATE_PREPARING:
 550             g_signal_connect (operation, "ready",
 551               G_CALLBACK (dispatch_operation_ready_cb), dispatcher);
 552             break;
 553           case EMPATHY_DISPATCHER_OPERATION_STATE_PENDING:
 554             dispatch_operation_ready_cb (operation, dispatcher);
 555             break;
 556           default:
 557             g_assert_not_reached ();
 558         }
 559
 560     }
 561   else if (empathy_dispatch_operation_get_status (operation) >=
 562       EMPATHY_DISPATCHER_OPERATION_STATE_PENDING)
 563     {
 564       /* Already dispatching and the operation is pending, thus the observers
 565        * have seen it (if applicable), so we can flush the request right away.
 566        */
 567       dispatch_operation_flush_requests (self, operation, NULL, cd);
 568     }
 569 }
 570
 571 static void
 572 dispatcher_flush_outstanding_operations (EmpathyDispatcher *self,
 573                                          ConnectionData *cd)
 574 {
 575   GHashTableIter iter;
 576   gpointer value;
 577
 578   g_hash_table_iter_init (&iter, cd->outstanding_channels);
 579   while (g_hash_table_iter_next (&iter, NULL, &value))
 580     {
 581       EmpathyDispatchOperation *operation = EMPATHY_DISPATCH_OPERATION (value);
 582
 583       if (dispatcher_operation_can_start (self, operation, cd))
 584         {
 585           g_hash_table_iter_remove (&iter);
 586           dispatcher_start_dispatching (dispatcher, operation, cd);
 587         }
 588     }
 589 }
 590
 591 static void
 592 dispatcher_connection_new_channel (EmpathyDispatcher *dispatcher,
 593                                    TpConnection *connection,
 594                                    const gchar *object_path,
 595                                    const gchar *channel_type,
 596                                    guint handle_type,
 597                                    guint handle,
 598                                    GHashTable *properties,
 599                                    gboolean incoming)
 600 {
 601   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
 602   TpChannel         *channel;
 603   ConnectionData *cd;
 604   EmpathyDispatchOperation *operation;
 605   int i;
 606   /* Channel types we never want to dispatch because they're either deprecated
 607    * or can't sensibly be dispatch (e.g. channels that should always be
 608    * requested) */
 609   const char *blacklist[] = {
 610     TP_IFACE_CHANNEL_TYPE_CONTACT_LIST,
 611     TP_IFACE_CHANNEL_TYPE_TUBES,
 612     TP_IFACE_CHANNEL_TYPE_ROOM_LIST,
 613     NULL
 614   };
 615
 616   dispatcher_init_connection_if_needed (dispatcher, connection);
 617
 618   cd = g_hash_table_lookup (priv->connections, connection);
 619
 620   /* Don't bother with channels we have already dispatched or are dispatching
 621    * currently. This can happen when NewChannel(s) is fired after
 622    * RequestChannel/CreateChannel/EnsureChannel */
 623   if (g_hash_table_lookup (cd->dispatched_channels, object_path) != NULL)
 624     return;
 625
 626   if (g_hash_table_lookup (cd->dispatching_channels, object_path) != NULL)
 627     return;
 628
 629   /* Should never occur, but just in case a CM fires spurious NewChannel(s)
 630    * signals */
 631   if (g_hash_table_lookup (cd->outstanding_channels, object_path) != NULL)
 632     return;
 633
 634   /* Only pick up non-requested text and file channels. For all other it
 635    * doesn't make sense to handle it if we didn't request it. The same goes
 636    * for channels we discovered by the Channels property or ListChannels */
 637   if (!incoming && tp_strdiff (channel_type, TP_IFACE_CHANNEL_TYPE_TEXT)
 638         && tp_strdiff (channel_type, TP_IFACE_CHANNEL_TYPE_FILE_TRANSFER))
 639     {
 640       DEBUG ("Ignoring incoming channel of type %s on %s",
 641         channel_type, object_path);
 642       return;
 643     }
 644
 645   for (i = 0 ; blacklist[i] != NULL; i++)
 646     {
 647       if (!tp_strdiff (channel_type, blacklist[i]))
 648         {
 649           DEBUG ("Ignoring blacklisted channel type %s on %s",
 650             channel_type, object_path);
 651           return;
 652         }
 653     }
 654
 655   DEBUG ("New channel of type %s on %s", channel_type, object_path);
 656
 657   if (properties == NULL)
 658     channel = tp_channel_new (connection, object_path, channel_type,
 659       handle_type, handle, NULL);
 660   else
 661     channel = tp_channel_new_from_properties (connection, object_path,
 662       properties, NULL);
 663
 664   g_signal_connect (channel, "invalidated",
 665     G_CALLBACK (dispatcher_channel_invalidated_cb),
 666     dispatcher);
 667
 668   priv->channels = g_list_prepend (priv->channels, channel);
 669
 670   operation = empathy_dispatch_operation_new (connection, channel, NULL,
 671     incoming);
 672
 673   g_object_unref (channel);
 674
 675   if (incoming)
 676     {
 677       /* Request could either be by us or by a remote party. If there are no
 678        * outstanding requests for this channel type we can assume it's remote.
 679        * Otherwise we wait untill they are all satisfied */
 680       if (dispatcher_operation_can_start (dispatcher, operation, cd))
 681         dispatcher_start_dispatching (dispatcher, operation, cd);
 682       else
 683         g_hash_table_insert (cd->outstanding_channels,
 684           g_strdup (object_path), operation);
 685     }
 686   else
 687     {
 688       dispatcher_start_dispatching (dispatcher, operation, cd);
 689     }
 690 }
 691
 692 static void
 693 dispatcher_connection_new_channel_with_properties (
 694     EmpathyDispatcher *dispatcher,
 695     TpConnection *connection,
 696     const gchar *object_path,
 697     GHashTable *properties)
 698 {
 699   const gchar *channel_type;
 700   guint handle_type;
 701   guint handle;
 702   gboolean requested;
 703   gboolean valid;
 704
 705
 706   channel_type = tp_asv_get_string (properties,
 707     TP_IFACE_CHANNEL ".ChannelType");
 708   if (channel_type == NULL)
 709     {
 710       g_message ("%s had an invalid ChannelType property", object_path);
 711       return;
 712     }
 713
 714   handle_type = tp_asv_get_uint32 (properties,
 715     TP_IFACE_CHANNEL ".TargetHandleType", &valid);
 716   if (!valid)
 717     {
 718       g_message ("%s had an invalid TargetHandleType property", object_path);
 719       return;
 720     }
 721
 722   handle = tp_asv_get_uint32 (properties,
 723     TP_IFACE_CHANNEL ".TargetHandle", &valid);
 724   if (!valid)
 725     {
 726       g_message ("%s had an invalid TargetHandle property", object_path);
 727       return;
 728     }
 729
 730   /* We assume there is no channel dispather, so we're the only one dispatching
 731    * it. Which means that a requested channel it is outgoing one */
 732   requested = tp_asv_get_boolean (properties,
 733     TP_IFACE_CHANNEL ".Requested", &valid);
 734   if (!valid)
 735     {
 736       g_message ("%s had an invalid Requested property", object_path);
 737       requested = FALSE;
 738     }
 739
 740   dispatcher_connection_new_channel (dispatcher, connection,
 741     object_path, channel_type, handle_type, handle, properties, !requested);
 742 }
 743
 744 static void
 745 dispatcher_connection_got_all (TpProxy *proxy,
 746                                GHashTable *properties,
 747                                const GError *error,
 748                                gpointer user_data,
 749                                GObject *object)
 750 {
 751   EmpathyDispatcher *dispatcher = EMPATHY_DISPATCHER (object);
 752   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
 753   GPtrArray *requestable_channels;
 754   GPtrArray *existing_channels;
 755
 756   if (error) {
 757     DEBUG ("Error: %s", error->message);
 758     return;
 759   }
 760
 761   requestable_channels = tp_asv_get_boxed (properties,
 762     "RequestableChannelClasses", TP_ARRAY_TYPE_REQUESTABLE_CHANNEL_CLASS_LIST);
 763
 764   if (requestable_channels == NULL)
 765     DEBUG ("No RequestableChannelClasses property !?! on connection");
 766   else
 767     {
 768       ConnectionData *cd;
 769       GList *requests, *l;
 770       FindChannelRequest *request;
 771       GList *retval;
 772
 773       cd = g_hash_table_lookup (priv->connections, proxy);
 774       g_assert (cd != NULL);
 775
 776       cd->requestable_channels = g_boxed_copy (
 777         TP_ARRAY_TYPE_REQUESTABLE_CHANNEL_CLASS_LIST, requestable_channels);
 778
 779       requests = g_hash_table_lookup (priv->outstanding_classes_requests,
 780           proxy);
 781
 782       for (l = requests; l != NULL; l = l->next)
 783         {
 784           request = l->data;
 785
 786           retval = empathy_dispatcher_find_channel_classes (dispatcher,
 787               TP_CONNECTION (proxy), request->channel_type,
 788               request->handle_type, request->properties);
 789           request->callback (retval, request->user_data);
 790
 791           free_find_channel_request (request);
 792           g_list_free (retval);
 793         }
 794
 795       g_list_free (requests);
 796
 797       g_hash_table_remove (priv->outstanding_classes_requests, proxy);
 798     }
 799
 800   existing_channels = tp_asv_get_boxed (properties,
 801       "Channels", TP_ARRAY_TYPE_CHANNEL_DETAILS_LIST);
 802
 803   if (existing_channels != NULL)
 804     {
 805       int idx;
 806
 807       for (idx = 0; idx < existing_channels->len; idx++)
 808         {
 809           GValueArray *values = g_ptr_array_index (existing_channels, idx);
 810           const gchar *object_path;
 811           GHashTable *properties;
 812
 813           object_path = g_value_get_boxed (g_value_array_get_nth (values, 0));
 814           properties = g_value_get_boxed (g_value_array_get_nth (values, 1));
 815
 816           if (tp_strdiff (tp_asv_get_string (properties,
 817                       TP_IFACE_CHANNEL ".ChannelType"),
 818                   TP_IFACE_CHANNEL_TYPE_TEXT))
 819             continue;
 820
 821           dispatcher_connection_new_channel_with_properties (dispatcher,
 822               TP_CONNECTION (proxy), object_path, properties);
 823         }
 824     }
 825 }
 826
 827 static void
 828 dispatcher_connection_advertise_capabilities_cb (TpConnection    *connection,
 829                                                  const GPtrArray *capabilities,
 830                                                  const GError    *error,
 831                                                  gpointer         user_data,
 832                                                  GObject         *dispatcher)
 833 {
 834   if (error)
 835     DEBUG ("Error: %s", error->message);
 836 }
 837
 838 static void
 839 dispatcher_init_connection_if_needed (EmpathyDispatcher *dispatcher,
 840     TpConnection *connection)
 841 {
 842   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
 843   GPtrArray   *capabilities;
 844   GType        cap_type;
 845   GValue       cap = {0, };
 846   const gchar *remove = NULL;
 847
 848   if (g_hash_table_lookup (priv->connections, connection) != NULL)
 849     return;
 850
 851   g_hash_table_insert (priv->connections, g_object_ref (connection),
 852     new_connection_data ());
 853
 854   g_signal_connect (connection, "invalidated",
 855     G_CALLBACK (dispatcher_connection_invalidated_cb), dispatcher);
 856
 857   if (tp_proxy_has_interface_by_id (TP_PROXY (connection),
 858       TP_IFACE_QUARK_CONNECTION_INTERFACE_REQUESTS))
 859     {
 860       tp_cli_dbus_properties_call_get_all (connection, -1,
 861         TP_IFACE_CONNECTION_INTERFACE_REQUESTS,
 862         dispatcher_connection_got_all,
 863         NULL, NULL, G_OBJECT (dispatcher));
 864     }
 865
 866   /* Advertise VoIP capabilities */
 867   capabilities = g_ptr_array_sized_new (1);
 868   cap_type = dbus_g_type_get_struct ("GValueArray", G_TYPE_STRING,
 869     G_TYPE_UINT, G_TYPE_INVALID);
 870   g_value_init (&cap, cap_type);
 871   g_value_take_boxed (&cap, dbus_g_type_specialized_construct (cap_type));
 872   dbus_g_type_struct_set (&cap,
 873         0, TP_IFACE_CHANNEL_TYPE_STREAMED_MEDIA,
 874         1, TP_CHANNEL_MEDIA_CAPABILITY_AUDIO |
 875            TP_CHANNEL_MEDIA_CAPABILITY_VIDEO |
 876            TP_CHANNEL_MEDIA_CAPABILITY_NAT_TRAVERSAL_STUN  |
 877            TP_CHANNEL_MEDIA_CAPABILITY_NAT_TRAVERSAL_GTALK_P2P |
 878            TP_CHANNEL_MEDIA_CAPABILITY_NAT_TRAVERSAL_ICE_UDP,
 879            G_MAXUINT);
 880   g_ptr_array_add (capabilities, g_value_get_boxed (&cap));
 881
 882   tp_cli_connection_interface_capabilities_call_advertise_capabilities (
 883     connection, -1, capabilities, &remove,
 884     dispatcher_connection_advertise_capabilities_cb,
 885     NULL, NULL, G_OBJECT (dispatcher));
 886
 887   g_value_unset (&cap);
 888   g_ptr_array_free (capabilities, TRUE);
 889 }
 890
 891 static void
 892 dispatcher_new_connection_cb (EmpathyAccountManager *manager,
 893                               TpConnection *connection,
 894                               EmpathyDispatcher *dispatcher)
 895 {
 896   dispatcher_init_connection_if_needed (dispatcher, connection);
 897 }
 898
 899 static void
 900 remove_idle_handlers (gpointer key,
 901                       gpointer value,
 902                       gpointer user_data)
 903 {
 904   guint source_id;
 905
 906   source_id = GPOINTER_TO_UINT (value);
 907   g_source_remove (source_id);
 908 }
 909
 910 static GObject *
 911 dispatcher_constructor (GType type,
 912                         guint n_construct_params,
 913                         GObjectConstructParam *construct_params)
 914 {
 915   GObject *retval;
 916   EmpathyDispatcherPriv *priv;
 917
 918   if (dispatcher != NULL)
 919     return g_object_ref (dispatcher);
 920
 921   retval = G_OBJECT_CLASS (empathy_dispatcher_parent_class)->constructor
 922     (type, n_construct_params, construct_params);
 923
 924   dispatcher = EMPATHY_DISPATCHER (retval);
 925   g_object_add_weak_pointer (retval, (gpointer) &dispatcher);
 926
 927   priv = GET_PRIV (dispatcher);
 928
 929   if (priv->handler == NULL)
 930     priv->handler = empathy_handler_new (NULL, NULL, NULL);
 931
 932   empathy_handler_set_handle_channels_func (priv->handler,
 933     empathy_dispatcher_handle_channels,
 934     dispatcher);
 935
 936   empathy_handler_set_channels_func (priv->handler,
 937     empathy_dispatcher_get_channels,
 938     dispatcher);
 939
 940   return retval;
 941 }
 942
 943 static void
 944 dispatcher_dispose (GObject *object)
 945 {
 946   EmpathyDispatcherPriv *priv = GET_PRIV (object);
 947   GList *l;
 948
 949   if (priv->dispose_has_run)
 950     return;
 951
 952   priv->dispose_has_run = TRUE;
 953
 954   for (l = priv->handlers ; l != NULL; l = g_list_next (l))
 955     g_object_unref (G_OBJECT (l->data));
 956
 957   g_list_free (priv->handlers);
 958   priv->handlers = NULL;
 959
 960   if (priv->handler != NULL)
 961     g_object_unref (priv->handler);
 962   priv->handler = NULL;
 963
 964   G_OBJECT_CLASS (empathy_dispatcher_parent_class)->dispose (object);
 965 }
 966
 967 static void
 968 dispatcher_finalize (GObject *object)
 969 {
 970   EmpathyDispatcherPriv *priv = GET_PRIV (object);
 971   GList *l;
 972   GHashTableIter iter;
 973   gpointer connection;
 974   GList *list;
 975
 976   if (priv->request_channel_class_async_ids != NULL)
 977     {
 978       g_hash_table_foreach (priv->request_channel_class_async_ids,
 979         remove_idle_handlers, NULL);
 980       g_hash_table_destroy (priv->request_channel_class_async_ids);
 981     }
 982
 983   g_signal_handlers_disconnect_by_func (priv->account_manager,
 984       dispatcher_new_connection_cb, object);
 985
 986   for (l = priv->channels; l; l = l->next)
 987     {
 988       g_signal_handlers_disconnect_by_func (l->data,
 989           dispatcher_channel_invalidated_cb, object);
 990     }
 991
 992   g_list_free (priv->channels);
 993
 994   g_hash_table_iter_init (&iter, priv->connections);
 995   while (g_hash_table_iter_next (&iter, &connection, NULL))
 996     {
 997       g_signal_handlers_disconnect_by_func (connection,
 998           dispatcher_connection_invalidated_cb, object);
 999     }
1000
1001   g_hash_table_iter_init (&iter, priv->outstanding_classes_requests);
1002   while (g_hash_table_iter_next (&iter, &connection, (gpointer *) &list))
1003     {
1004       g_list_foreach (list, (GFunc) free_find_channel_request, NULL);
1005       g_list_free (list);
1006     }
1007
1008   g_object_unref (priv->account_manager);
1009
1010   g_hash_table_destroy (priv->connections);
1011   g_hash_table_destroy (priv->outstanding_classes_requests);
1012 }
1013
1014 static void
1015 dispatcher_set_property (GObject *object,
1016   guint property_id,
1017   const GValue *value,
1018   GParamSpec *pspec)
1019 {
1020   EmpathyDispatcher *dispatcher = EMPATHY_DISPATCHER (object);
1021   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
1022
1023   switch (property_id)
1024     {
1025       case PROP_HANDLER:
1026         priv->handler = g_value_dup_object (value);
1027         break;
1028       default:
1029         G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
1030         break;
1031     }
1032 }
1033
1034 static void
1035 dispatcher_get_property (GObject *object,
1036   guint property_id,
1037   GValue *value,
1038   GParamSpec *pspec)
1039 {
1040   EmpathyDispatcher *dispatcher = EMPATHY_DISPATCHER (object);
1041   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
1042
1043   switch (property_id)
1044     {
1045       case PROP_HANDLER:
1046         g_value_set_object (value, priv->handler);
1047         break;
1048       default:
1049         G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
1050         break;
1051     }
1052 }
1053
1054 static void
1055 empathy_dispatcher_class_init (EmpathyDispatcherClass *klass)
1056 {
1057   GObjectClass *object_class = G_OBJECT_CLASS (klass);
1058   GParamSpec *param_spec;
1059
1060   object_class->dispose = dispatcher_dispose;
1061   object_class->finalize = dispatcher_finalize;
1062   object_class->constructor = dispatcher_constructor;
1063
1064   object_class->get_property = dispatcher_get_property;
1065   object_class->set_property = dispatcher_set_property;
1066
1067   param_spec = g_param_spec_object ("handler", "handler",
1068     "The main Telepathy Client Hander object",
1069     EMPATHY_TYPE_HANDLER,
1070     G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS | G_PARAM_CONSTRUCT_ONLY);
1071   g_object_class_install_property (object_class,
1072     PROP_HANDLER, param_spec);
1073
1074   signals[OBSERVE] =
1075     g_signal_new ("observe",
1076       G_TYPE_FROM_CLASS (klass),
1077       G_SIGNAL_RUN_LAST,
1078       0,
1079       NULL, NULL,
1080       g_cclosure_marshal_VOID__OBJECT,
1081       G_TYPE_NONE,
1082       1, EMPATHY_TYPE_DISPATCH_OPERATION);
1083
1084   signals[APPROVE] =
1085     g_signal_new ("approve",
1086       G_TYPE_FROM_CLASS (klass),
1087       G_SIGNAL_RUN_LAST,
1088       0,
1089       NULL, NULL,
1090       g_cclosure_marshal_VOID__OBJECT,
1091       G_TYPE_NONE,
1092       1, EMPATHY_TYPE_DISPATCH_OPERATION);
1093
1094   signals[DISPATCH] =
1095     g_signal_new ("dispatch",
1096       G_TYPE_FROM_CLASS (klass),
1097       G_SIGNAL_RUN_LAST,
1098       0,
1099       NULL, NULL,
1100       g_cclosure_marshal_VOID__OBJECT,
1101       G_TYPE_NONE,
1102       1, EMPATHY_TYPE_DISPATCH_OPERATION);
1103
1104
1105   g_type_class_add_private (object_class, sizeof (EmpathyDispatcherPriv));
1106 }
1107
1108 static void
1109 empathy_dispatcher_init (EmpathyDispatcher *dispatcher)
1110 {
1111   GList *connections, *l;
1112   EmpathyDispatcherPriv *priv = G_TYPE_INSTANCE_GET_PRIVATE (dispatcher,
1113     EMPATHY_TYPE_DISPATCHER, EmpathyDispatcherPriv);
1114
1115   dispatcher->priv = priv;
1116   priv->account_manager = empathy_account_manager_dup_singleton ();
1117
1118   g_signal_connect (priv->account_manager, "new-connection",
1119     G_CALLBACK (dispatcher_new_connection_cb),
1120     dispatcher);
1121
1122   priv->connections = g_hash_table_new_full (g_direct_hash, g_direct_equal,
1123     g_object_unref, (GDestroyNotify) free_connection_data);
1124
1125   priv->outstanding_classes_requests = g_hash_table_new_full (g_direct_hash,
1126     g_direct_equal, g_object_unref, NULL);
1127
1128   priv->channels = NULL;
1129
1130   connections = empathy_account_manager_dup_connections (
1131       priv->account_manager);
1132   for (l = connections; l; l = l->next)
1133     {
1134       dispatcher_new_connection_cb (priv->account_manager, l->data,
1135           dispatcher);
1136       g_object_unref (l->data);
1137     }
1138   g_list_free (connections);
1139
1140   priv->request_channel_class_async_ids = g_hash_table_new (g_direct_hash,
1141     g_direct_equal);
1142 }
1143
1144 EmpathyDispatcher *
1145 empathy_dispatcher_new (const gchar *name,
1146   GPtrArray *filters,
1147   GStrv capabilities)
1148 {
1149   g_assert (dispatcher == NULL);
1150   EmpathyHandler *handler;
1151   EmpathyDispatcher *ret;
1152
1153   handler = empathy_handler_new (name, filters, capabilities);
1154
1155   ret = EMPATHY_DISPATCHER (
1156     g_object_new (EMPATHY_TYPE_DISPATCHER,
1157       "handler", handler,
1158       NULL));
1159   g_object_unref (handler);
1160
1161   return ret;
1162 }
1163
1164 EmpathyDispatcher *
1165 empathy_dispatcher_dup_singleton (void)
1166 {
1167   return EMPATHY_DISPATCHER (g_object_new (EMPATHY_TYPE_DISPATCHER, NULL));
1168 }
1169
1170 static void
1171 dispatcher_request_failed (EmpathyDispatcher *dispatcher,
1172                            DispatcherRequestData *request_data,
1173                            const GError *error)
1174 {
1175   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
1176   ConnectionData *conn_data;
1177
1178   conn_data = g_hash_table_lookup (priv->connections,
1179       request_data->connection);
1180   if (request_data->cb != NULL)
1181     request_data->cb (NULL, error, request_data->user_data);
1182
1183   if (conn_data != NULL)
1184     {
1185       conn_data->outstanding_requests =
1186           g_list_remove (conn_data->outstanding_requests, request_data);
1187     }
1188   /* else Connection has been invalidated */
1189
1190   free_dispatcher_request_data (request_data);
1191 }
1192
1193 static void
1194 dispatcher_connection_new_requested_channel (EmpathyDispatcher *dispatcher,
1195   DispatcherRequestData *request_data,
1196   const gchar *object_path,
1197   GHashTable *properties,
1198   const GError *error)
1199 {
1200   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
1201   EmpathyDispatchOperation *operation = NULL;
1202   ConnectionData *conn_data;
1203
1204   conn_data = g_hash_table_lookup (priv->connections,
1205     request_data->connection);
1206
1207   if (error)
1208     {
1209       DEBUG ("Channel request failed: %s", error->message);
1210
1211       dispatcher_request_failed (dispatcher, request_data, error);
1212
1213       goto out;
1214     }
1215
1216   operation = g_hash_table_lookup (conn_data->outstanding_channels,
1217     object_path);
1218
1219   if (operation != NULL)
1220     g_hash_table_remove (conn_data->outstanding_channels, object_path);
1221   else
1222     operation = g_hash_table_lookup (conn_data->dispatching_channels,
1223         object_path);
1224
1225   if (operation == NULL)
1226     {
1227       DispatchData *data = g_hash_table_lookup (conn_data->dispatched_channels,
1228         object_path);
1229
1230       if (data != NULL)
1231         {
1232           operation = empathy_dispatch_operation_new_with_wrapper (
1233             request_data->connection,
1234             data->channel, request_data->contact, FALSE,
1235             data->channel_wrapper);
1236         }
1237       else
1238         {
1239           TpChannel *channel;
1240
1241           if (properties != NULL)
1242             channel = tp_channel_new_from_properties (request_data->connection,
1243               object_path, properties, NULL);
1244           else
1245             channel = tp_channel_new (request_data->connection, object_path,
1246               request_data->channel_type, request_data->handle_type,
1247               request_data->handle, NULL);
1248
1249           g_signal_connect (channel, "invalidated",
1250             G_CALLBACK (dispatcher_channel_invalidated_cb),
1251             request_data->dispatcher);
1252
1253           priv->channels = g_list_prepend (priv->channels, channel);
1254
1255           operation = empathy_dispatch_operation_new (request_data->connection,
1256              channel, request_data->contact, FALSE);
1257           g_object_unref (channel);
1258         }
1259     }
1260   else
1261     {
1262       /* Already existed set potential extra information */
1263       g_object_set (G_OBJECT (operation),
1264         "contact", request_data->contact,
1265         NULL);
1266     }
1267
1268   request_data->operation = operation;
1269
1270   /* (pre)-approve this right away as we requested it
1271    * This might cause the channel to be claimed, in which case the operation
1272    * will disappear. So ref it, and check the status before starting the
1273    * dispatching */
1274
1275   g_object_ref (operation);
1276   empathy_dispatch_operation_approve (operation);
1277
1278    if (empathy_dispatch_operation_get_status (operation) <
1279      EMPATHY_DISPATCHER_OPERATION_STATE_APPROVING)
1280       dispatcher_start_dispatching (request_data->dispatcher, operation,
1281           conn_data);
1282
1283   g_object_unref (operation);
1284
1285 out:
1286   dispatcher_flush_outstanding_operations (request_data->dispatcher,
1287     conn_data);
1288 }
1289
1290 static void
1291 dispatcher_request_channel_cb (TpConnection *connection,
1292                                const gchar  *object_path,
1293                                const GError *error,
1294                                gpointer user_data,
1295                                GObject *weak_object)
1296 {
1297   EmpathyDispatcher *dispatcher = EMPATHY_DISPATCHER (weak_object);
1298   DispatcherRequestData *request_data = (DispatcherRequestData *) user_data;
1299
1300   dispatcher_connection_new_requested_channel (dispatcher,
1301     request_data, object_path, NULL, error);
1302 }
1303
1304 static void
1305 dispatcher_request_channel (DispatcherRequestData *request_data)
1306 {
1307   if (tp_proxy_has_interface_by_id (TP_PROXY (request_data->connection),
1308       TP_IFACE_QUARK_CONNECTION_INTERFACE_REQUESTS))
1309     {
1310       /* Extend the request_data to be a valid request */
1311       g_assert (request_data->request == NULL);
1312       request_data->request = tp_asv_new (
1313         TP_IFACE_CHANNEL ".ChannelType",
1314           G_TYPE_STRING, request_data->channel_type,
1315         TP_IFACE_CHANNEL ".TargetHandleType",
1316           G_TYPE_UINT, request_data->handle_type,
1317         NULL);
1318
1319       if (request_data->handle_type != TP_HANDLE_TYPE_NONE)
1320         tp_asv_set_uint32 (request_data->request,
1321           TP_IFACE_CHANNEL ".TargetHandle", request_data->handle);
1322
1323       empathy_dispatcher_call_create_or_ensure_channel (
1324         request_data->dispatcher, request_data);
1325     }
1326   else
1327     {
1328       request_data->pending_call = tp_cli_connection_call_request_channel (
1329         request_data->connection, -1,
1330         request_data->channel_type,
1331         request_data->handle_type,
1332         request_data->handle,
1333         TRUE, dispatcher_request_channel_cb,
1334         request_data, NULL, G_OBJECT (request_data->dispatcher));
1335     }
1336 }
1337
1338 void
1339 empathy_dispatcher_chat_with_contact (EmpathyContact *contact,
1340                                       EmpathyDispatcherRequestCb *callback,
1341                                       gpointer user_data)
1342 {
1343   EmpathyDispatcher *dispatcher;
1344   EmpathyDispatcherPriv *priv;
1345   TpConnection *connection;
1346   ConnectionData *connection_data;
1347   DispatcherRequestData *request_data;
1348
1349   g_return_if_fail (EMPATHY_IS_CONTACT (contact));
1350
1351   dispatcher = empathy_dispatcher_dup_singleton ();
1352   priv = GET_PRIV (dispatcher);
1353
1354   connection = empathy_contact_get_connection (contact);
1355   connection_data = g_hash_table_lookup (priv->connections, connection);
1356
1357   /* The contact handle might not be known yet */
1358   request_data = new_dispatcher_request_data (dispatcher, connection,
1359     TP_IFACE_CHANNEL_TYPE_TEXT, TP_HANDLE_TYPE_CONTACT,
1360     empathy_contact_get_handle (contact), NULL, contact, callback, user_data);
1361   request_data->should_ensure = TRUE;
1362
1363   connection_data->outstanding_requests = g_list_prepend
1364     (connection_data->outstanding_requests, request_data);
1365
1366   dispatcher_request_channel (request_data);
1367
1368   g_object_unref (dispatcher);
1369 }
1370
1371 typedef struct
1372 {
1373   EmpathyDispatcher *dispatcher;
1374   EmpathyDispatcherRequestCb *callback;
1375   gpointer user_data;
1376 } ChatWithContactIdData;
1377
1378 static void
1379 dispatcher_chat_with_contact_id_cb (EmpathyTpContactFactory *factory,
1380                                     EmpathyContact          *contact,
1381                                     const GError            *error,
1382                                     gpointer                 user_data,
1383                                     GObject                 *weak_object)
1384 {
1385   ChatWithContactIdData *data = user_data;
1386
1387   if (error)
1388     {
1389       /* FIXME: Should call data->callback with the error */
1390       DEBUG ("Error: %s", error->message);
1391     }
1392   else
1393     {
1394       empathy_dispatcher_chat_with_contact (contact, data->callback,
1395           data->user_data);
1396     }
1397
1398   g_object_unref (data->dispatcher);
1399   g_slice_free (ChatWithContactIdData, data);
1400 }
1401
1402 void
1403 empathy_dispatcher_chat_with_contact_id (TpConnection *connection,
1404                                          const gchar *contact_id,
1405                                          EmpathyDispatcherRequestCb *callback,
1406                                          gpointer user_data)
1407 {
1408   EmpathyDispatcher *dispatcher;
1409   EmpathyTpContactFactory *factory;
1410   ChatWithContactIdData *data;
1411
1412   g_return_if_fail (TP_IS_CONNECTION (connection));
1413   g_return_if_fail (!EMP_STR_EMPTY (contact_id));
1414
1415   dispatcher = empathy_dispatcher_dup_singleton ();
1416   factory = empathy_tp_contact_factory_dup_singleton (connection);
1417   data = g_slice_new0 (ChatWithContactIdData);
1418   data->dispatcher = dispatcher;
1419   data->callback = callback;
1420   data->user_data = user_data;
1421   empathy_tp_contact_factory_get_from_id (factory, contact_id,
1422       dispatcher_chat_with_contact_id_cb, data, NULL, NULL);
1423
1424   g_object_unref (factory);
1425 }
1426
1427 static void
1428 dispatcher_request_handles_cb (TpConnection *connection,
1429                                const GArray *handles,
1430                                const GError *error,
1431                                gpointer user_data,
1432                                GObject *object)
1433 {
1434   DispatcherRequestData *request_data = (DispatcherRequestData *) user_data;
1435
1436   if (error != NULL)
1437     {
1438       EmpathyDispatcher *dispatcher = EMPATHY_DISPATCHER (object);
1439       EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
1440       ConnectionData *cd;
1441
1442       cd = g_hash_table_lookup (priv->connections, request_data->connection);
1443
1444       if (request_data->cb)
1445         request_data->cb (NULL, error, request_data->user_data);
1446
1447       cd->outstanding_requests = g_list_remove (cd->outstanding_requests,
1448         request_data);
1449
1450       free_dispatcher_request_data (request_data);
1451
1452       dispatcher_flush_outstanding_operations (dispatcher, cd);
1453       return;
1454     }
1455
1456   request_data->handle = g_array_index (handles, guint, 0);
1457   dispatcher_request_channel (request_data);
1458 }
1459
1460 void
1461 empathy_dispatcher_join_muc (TpConnection *connection,
1462                              const gchar *roomname,
1463                              EmpathyDispatcherRequestCb *callback,
1464                              gpointer user_data)
1465 {
1466   EmpathyDispatcher *dispatcher;
1467   EmpathyDispatcherPriv *priv;
1468   DispatcherRequestData *request_data;
1469   ConnectionData *connection_data;
1470   const gchar *names[] = { roomname, NULL };
1471
1472   g_return_if_fail (TP_IS_CONNECTION (connection));
1473   g_return_if_fail (!EMP_STR_EMPTY (roomname));
1474
1475   dispatcher = empathy_dispatcher_dup_singleton ();
1476   priv = GET_PRIV (dispatcher);
1477
1478   connection_data = g_hash_table_lookup (priv->connections, connection);
1479
1480   /* Don't know the room handle yet */
1481   request_data  = new_dispatcher_request_data (dispatcher, connection,
1482     TP_IFACE_CHANNEL_TYPE_TEXT, TP_HANDLE_TYPE_ROOM, 0, NULL,
1483     NULL, callback, user_data);
1484
1485   connection_data->outstanding_requests = g_list_prepend
1486     (connection_data->outstanding_requests, request_data);
1487
1488   request_data->pending_call = tp_cli_connection_call_request_handles (
1489     connection, -1,
1490     TP_HANDLE_TYPE_ROOM, names,
1491     dispatcher_request_handles_cb, request_data, NULL,
1492     G_OBJECT (dispatcher));
1493
1494   g_object_unref (dispatcher);
1495 }
1496
1497 static void
1498 dispatcher_create_channel_cb (TpConnection *connect,
1499                               const gchar *object_path,
1500                               GHashTable *properties,
1501                               const GError *error,
1502                               gpointer user_data,
1503                               GObject *weak_object)
1504 {
1505   EmpathyDispatcher *dispatcher = EMPATHY_DISPATCHER (weak_object);
1506   DispatcherRequestData *request_data = (DispatcherRequestData *) user_data;
1507
1508   dispatcher_connection_new_requested_channel (dispatcher,
1509     request_data, object_path, properties, error);
1510 }
1511
1512 static void
1513 dispatcher_ensure_channel_cb (TpConnection *connect,
1514                               gboolean is_ours,
1515                               const gchar *object_path,
1516                               GHashTable *properties,
1517                               const GError *error,
1518                               gpointer user_data,
1519                               GObject *weak_object)
1520 {
1521   EmpathyDispatcher *dispatcher = EMPATHY_DISPATCHER (weak_object);
1522   DispatcherRequestData *request_data = (DispatcherRequestData *) user_data;
1523
1524   dispatcher_connection_new_requested_channel (dispatcher,
1525     request_data, object_path, properties, error);
1526 }
1527
1528 static void
1529 empathy_dispatcher_call_create_or_ensure_channel (
1530     EmpathyDispatcher *dispatcher,
1531     DispatcherRequestData *request_data)
1532 {
1533   if (request_data->should_ensure)
1534     {
1535       request_data->pending_call =
1536           tp_cli_connection_interface_requests_call_ensure_channel (
1537           request_data->connection, -1,
1538           request_data->request, dispatcher_ensure_channel_cb,
1539           request_data, NULL, G_OBJECT (request_data->dispatcher));
1540     }
1541   else
1542     {
1543       request_data->pending_call =
1544           tp_cli_connection_interface_requests_call_create_channel (
1545           request_data->connection, -1,
1546           request_data->request, dispatcher_create_channel_cb,
1547           request_data, NULL, G_OBJECT (request_data->dispatcher));
1548     }
1549 }
1550
1551 void
1552 empathy_dispatcher_create_channel (EmpathyDispatcher *dispatcher,
1553                                    TpConnection *connection,
1554                                    GHashTable *request,
1555                                    EmpathyDispatcherRequestCb *callback,
1556                                    gpointer user_data)
1557 {
1558   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
1559   ConnectionData *connection_data;
1560   DispatcherRequestData *request_data;
1561   const gchar *channel_type;
1562   guint handle_type;
1563   guint handle;
1564   gboolean valid;
1565
1566   g_return_if_fail (EMPATHY_IS_DISPATCHER (dispatcher));
1567   g_return_if_fail (TP_IS_CONNECTION (connection));
1568   g_return_if_fail (request != NULL);
1569
1570   connection_data = g_hash_table_lookup (priv->connections, connection);
1571   g_assert (connection_data != NULL);
1572
1573   channel_type = tp_asv_get_string (request, TP_IFACE_CHANNEL ".ChannelType");
1574
1575   handle_type = tp_asv_get_uint32 (request,
1576     TP_IFACE_CHANNEL ".TargetHandleType", &valid);
1577   if (!valid)
1578     handle_type = TP_UNKNOWN_HANDLE_TYPE;
1579
1580   handle = tp_asv_get_uint32 (request, TP_IFACE_CHANNEL ".TargetHandle", NULL);
1581
1582   request_data  = new_dispatcher_request_data (dispatcher, connection,
1583     channel_type, handle_type, handle, request,
1584     NULL, callback, user_data);
1585
1586   connection_data->outstanding_requests = g_list_prepend
1587     (connection_data->outstanding_requests, request_data);
1588
1589   empathy_dispatcher_call_create_or_ensure_channel (dispatcher, request_data);
1590 }
1591
1592 static gboolean
1593 channel_class_matches (GValueArray *class,
1594                        const char *channel_type,
1595                        guint handle_type,
1596                        GArray *fixed_properties)
1597 {
1598   GHashTable *fprops;
1599   GValue *v;
1600   const char *c_type;
1601   guint h_type;
1602   gboolean valid;
1603
1604   v = g_value_array_get_nth (class, 0);
1605
1606   /* if the class doesn't match channel type discard it. */
1607   fprops = g_value_get_boxed (v);
1608   c_type = tp_asv_get_string (fprops, TP_IFACE_CHANNEL ".ChannelType");
1609
1610   if (tp_strdiff (channel_type, c_type))
1611     return FALSE;
1612
1613   /* we have the right channel type, see if the handle type matches */
1614   h_type = tp_asv_get_uint32 (fprops,
1615                               TP_IFACE_CHANNEL ".TargetHandleType", &valid);
1616
1617   if (!valid || handle_type != h_type)
1618     return FALSE;
1619
1620   if (fixed_properties != NULL)
1621     {
1622       gpointer h_key, h_val;
1623       int idx;
1624       GHashTableIter iter;
1625       gboolean found;
1626
1627       g_hash_table_iter_init (&iter, fprops);
1628
1629       while (g_hash_table_iter_next (&iter, &h_key, &h_val))
1630         {
1631           /* discard ChannelType and TargetHandleType, as we already
1632            * checked them.
1633            */
1634           if (!tp_strdiff ((char *) h_key, TP_IFACE_CHANNEL ".ChannelType") ||
1635               !tp_strdiff
1636                 ((char *) h_key, TP_IFACE_CHANNEL ".TargetHandleType"))
1637             continue;
1638
1639           found = FALSE;
1640
1641           for (idx = 0; idx < fixed_properties->len; idx++)
1642             {
1643               /* if |key| doesn't exist in |fixed_properties|, discard
1644                * the class.
1645                */
1646               if (!tp_strdiff
1647                     ((char *) h_key,
1648                      g_array_index (fixed_properties, char *, idx)))
1649                 {
1650                   found = TRUE;
1651                   /* exit the for() loop */
1652                   break;
1653                 }
1654             }
1655
1656           if (!found)
1657             return FALSE;
1658         }
1659     }
1660   else
1661     {
1662       /* if no fixed_properties are specified, discard the classes
1663        * with some fixed properties other than the two we already
1664        * checked.
1665        */
1666       if (g_hash_table_size (fprops) > 2)
1667         return FALSE;
1668     }
1669
1670   return TRUE;
1671 }
1672
1673 static GList *
1674 empathy_dispatcher_find_channel_classes (EmpathyDispatcher *dispatcher,
1675                                          TpConnection *connection,
1676                                          const gchar *channel_type,
1677                                          guint handle_type,
1678                                          GArray *fixed_properties)
1679 {
1680   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
1681   GValueArray *class;
1682   GPtrArray *classes;
1683   GList *matching_classes;
1684   int i;
1685   ConnectionData *cd;
1686
1687   g_return_val_if_fail (channel_type != NULL, NULL);
1688   g_return_val_if_fail (handle_type != 0, NULL);
1689
1690   cd = g_hash_table_lookup (priv->connections, connection);
1691
1692   if (cd == NULL)
1693     return NULL;
1694
1695   classes = cd->requestable_channels;
1696   if (classes == NULL)
1697     return NULL;
1698
1699   matching_classes = NULL;
1700
1701   for (i = 0; i < classes->len; i++)
1702     {
1703       class = g_ptr_array_index (classes, i);
1704
1705       if (!channel_class_matches
1706           (class, channel_type, handle_type, fixed_properties))
1707         continue;
1708
1709       matching_classes = g_list_prepend (matching_classes, class);
1710     }
1711
1712   return matching_classes;
1713 }
1714
1715 static gboolean
1716 find_channel_class_idle_cb (gpointer user_data)
1717 {
1718   GList *retval;
1719   GList *requests;
1720   FindChannelRequest *request = user_data;
1721   ConnectionData *cd;
1722   gboolean is_ready = TRUE;
1723   EmpathyDispatcherPriv *priv = GET_PRIV (request->dispatcher);
1724
1725   g_hash_table_remove (priv->request_channel_class_async_ids, request);
1726
1727   cd = g_hash_table_lookup (priv->connections, request->connection);
1728
1729   if (cd == NULL)
1730     is_ready = FALSE;
1731   else if (cd->requestable_channels == NULL)
1732     is_ready = FALSE;
1733
1734   if (is_ready)
1735     {
1736       retval = empathy_dispatcher_find_channel_classes (request->dispatcher,
1737           request->connection, request->channel_type, request->handle_type,
1738           request->properties);
1739
1740       request->callback (retval, request->user_data);
1741       free_find_channel_request (request);
1742       g_list_free (retval);
1743
1744       return FALSE;
1745     }
1746
1747   requests = g_hash_table_lookup (priv->outstanding_classes_requests,
1748       request->connection);
1749   requests = g_list_prepend (requests, request);
1750
1751   g_hash_table_insert (priv->outstanding_classes_requests,
1752       request->connection, requests);
1753
1754   return FALSE;
1755 }
1756
1757 static GArray *
1758 setup_varargs (va_list var_args,
1759                const char *channel_namespace,
1760                const char *first_property_name)
1761 {
1762   const char *name;
1763   char *name_full;
1764   GArray *properties;
1765
1766   if (first_property_name == NULL)
1767     return NULL;
1768
1769   name = first_property_name;
1770   properties = g_array_new (TRUE, TRUE, sizeof (char *));
1771
1772   while (name != NULL)
1773     {
1774       name_full = g_strdup (name);
1775       properties = g_array_append_val (properties, name_full);
1776       name = va_arg (var_args, char *);
1777     }
1778
1779   return properties;
1780 }
1781
1782 /**
1783  * empathy_dispatcher_find_requestable_channel_classes:
1784  * @dispatcher: an #EmpathyDispatcher
1785  * @connection: a #TpConnection
1786  * @channel_type: a string identifying the type of the channel to lookup
1787  * @handle_type: the handle type for the channel
1788  * @first_property_name: %NULL, or the name of the first fixed property,
1789  * followed optionally by more names, followed by %NULL.
1790  *
1791  * Returns all the channel classes that a client can request for the connection
1792  * @connection, of the type identified by @channel_type, @handle_type and the
1793  * fixed properties list.
1794  * The classes which are compatible with a fixed properties list (i.e. those
1795  * that will be returned by this function) are intended as those that do not
1796  * contain any fixed property other than those in the list; note that this
1797  * doesn't guarantee that all the classes compatible with the list will contain
1798  * all the requested fixed properties, so the clients will have to filter
1799  * the returned list themselves.
1800  * If @first_property_name is %NULL, only the classes with no other fixed
1801  * properties than ChannelType and TargetHandleType will be returned.
1802  * Note that this function may return %NULL without performing any lookup if
1803  * @connection is not ready. To ensure that @connection is always ready,
1804  * use the empathy_dispatcher_find_requestable_channel_classes_async() variant.
1805  *
1806  * Return value: a #GList of #GValueArray objects, where the first element in
1807  * the array is a #GHashTable of the fixed properties, and the second is
1808  * a #GStrv of the allowed properties for the class. The list should be free'd
1809  * with g_list_free() when done, but the objects inside the list are owned
1810  * by the #EmpathyDispatcher and must not be modified.
1811  */
1812 GList *
1813 empathy_dispatcher_find_requestable_channel_classes
1814                                  (EmpathyDispatcher *dispatcher,
1815                                   TpConnection *connection,
1816                                   const gchar *channel_type,
1817                                   guint handle_type,
1818                                   const char *first_property_name,
1819                                   ...)
1820 {
1821   va_list var_args;
1822   GArray *properties;
1823   EmpathyDispatcherPriv *priv;
1824   GList *retval;
1825   int idx;
1826   char *str;
1827
1828   g_return_val_if_fail (EMPATHY_IS_DISPATCHER (dispatcher), NULL);
1829   g_return_val_if_fail (TP_IS_CONNECTION (connection), NULL);
1830   g_return_val_if_fail (channel_type != NULL, NULL);
1831   g_return_val_if_fail (handle_type != 0, NULL);
1832
1833   priv = GET_PRIV (dispatcher);
1834
1835   va_start (var_args, first_property_name);
1836
1837   properties = setup_varargs (var_args, channel_type, first_property_name);
1838
1839   va_end (var_args);
1840
1841   retval = empathy_dispatcher_find_channel_classes (dispatcher, connection,
1842     channel_type, handle_type, properties);
1843
1844   if (properties != NULL)
1845     {
1846       /* free the properties array */
1847       for (idx = 0; idx < properties->len ; idx++)
1848         {
1849           str = g_array_index (properties, char *, idx);
1850           g_free (str);
1851         }
1852
1853       g_array_free (properties, TRUE);
1854     }
1855
1856   return retval;
1857 }
1858
1859 /**
1860  * empathy_dispatcher_find_requestable_channel_classes_async:
1861  * @dispatcher: an #EmpathyDispatcher
1862  * @connection: a #TpConnection
1863  * @channel_type: a string identifying the type of the channel to lookup
1864  * @handle_type: the handle type for the channel
1865  * @callback: the callback to call when @connection is ready
1866  * @user_data: the user data to pass to @callback
1867  * @first_property_name: %NULL, or the name of the first fixed property,
1868  * followed optionally by more names, followed by %NULL.
1869  *
1870  * Please see the documentation of
1871  * empathy_dispatcher_find_requestable_channel_classes() for a detailed
1872  * description of this function.
1873  */
1874 void
1875 empathy_dispatcher_find_requestable_channel_classes_async
1876                                  (EmpathyDispatcher *dispatcher,
1877                                   TpConnection *connection,
1878                                   const gchar *channel_type,
1879                                   guint handle_type,
1880                                   EmpathyDispatcherFindChannelClassCb callback,
1881                                   gpointer user_data,
1882                                   const char *first_property_name,
1883                                   ...)
1884 {
1885   va_list var_args;
1886   GArray *properties;
1887   FindChannelRequest *request;
1888   EmpathyDispatcherPriv *priv;
1889   guint source_id;
1890
1891   g_return_if_fail (EMPATHY_IS_DISPATCHER (dispatcher));
1892   g_return_if_fail (TP_IS_CONNECTION (connection));
1893   g_return_if_fail (channel_type != NULL);
1894   g_return_if_fail (handle_type != 0);
1895
1896   priv = GET_PRIV (dispatcher);
1897
1898   va_start (var_args, first_property_name);
1899
1900   properties = setup_varargs (var_args, channel_type, first_property_name);
1901
1902   va_end (var_args);
1903
1904   /* append another request for this connection */
1905   request = g_slice_new0 (FindChannelRequest);
1906   request->dispatcher = g_object_ref (dispatcher);
1907   request->channel_type = g_strdup (channel_type);
1908   request->handle_type = handle_type;
1909   request->connection = connection;
1910   request->callback = callback;
1911   request->user_data = user_data;
1912   request->properties = properties;
1913
1914   source_id = g_idle_add (find_channel_class_idle_cb, request);
1915
1916   g_hash_table_insert (priv->request_channel_class_async_ids,
1917     request, GUINT_TO_POINTER (source_id));
1918 }
1919
1920 static GList *
1921 empathy_dispatcher_get_channels (EmpathyHandler *handler,
1922   gpointer user_data)
1923 {
1924   EmpathyDispatcher *dispatcher = EMPATHY_DISPATCHER (user_data);
1925   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
1926
1927   return priv->channels;
1928 }
1929
1930 static gboolean
1931 empathy_dispatcher_handle_channels (EmpathyHandler *handler,
1932     const gchar *account_path,
1933     const gchar *connection_path,
1934     const GPtrArray *channels,
1935     const GPtrArray *requests_satisfied,
1936     guint64 timestamp,
1937     GHashTable *handler_info,
1938     gpointer user_data,
1939     GError **error)
1940 {
1941   EmpathyDispatcher *dispatcher = EMPATHY_DISPATCHER (user_data);
1942   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
1943   int i;
1944   EmpathyAccount *account;
1945   TpConnection *connection;
1946
1947   account = empathy_account_manager_ensure_account (priv->account_manager,
1948     account_path);
1949   g_assert (account != NULL);
1950
1951   connection = empathy_account_get_connection_for_path (account,
1952       connection_path);
1953   if (connection == NULL)
1954     {
1955       g_set_error_literal (error, TP_ERRORS, TP_ERROR_INVALID_ARGUMENT,
1956         "Invalid connection argument");
1957       return FALSE;
1958     }
1959
1960   for (i = 0; i < channels->len ; i++)
1961     {
1962       GValueArray *arr = g_ptr_array_index (channels, i);
1963       const gchar *object_path;
1964       GHashTable *properties;
1965
1966       object_path = g_value_get_boxed (g_value_array_get_nth (arr, 0));
1967       properties = g_value_get_boxed (g_value_array_get_nth (arr, 1));
1968
1969       dispatcher_connection_new_channel_with_properties (dispatcher,
1970         connection, object_path, properties);
1971     }
1972
1973   return TRUE;
1974 }
1975
1976
1977 EmpathyHandler *
1978 empathy_dispatcher_add_handler (EmpathyDispatcher *dispatcher,
1979     const gchar *name,
1980     GPtrArray *filters,
1981     GStrv capabilities)
1982 {
1983   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
1984   EmpathyHandler *handler;
1985
1986   handler = empathy_handler_new (name, filters, capabilities);
1987   priv->handlers = g_list_prepend (priv->handlers, handler);
1988
1989   /* Only set the handle_channels function, the Channel property on the main
1990    * handler will always report all dispatched channels even if they came from
1991    * a different Handler */
1992   empathy_handler_set_handle_channels_func (handler,
1993     empathy_dispatcher_handle_channels,
1994     dispatcher);
1995
1996   return handler;
1997 }
1998
1999 void
2000 empathy_dispatcher_remove_handler (EmpathyDispatcher *dispatcher,
2001   EmpathyHandler *handler)
2002 {
2003   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
2004   GList *h;
2005
2006   h = g_list_find (priv->handlers, handler);
2007   g_return_if_fail (h != NULL);
2008
2009   priv->handlers = g_list_delete_link (priv->handlers, h);
2010
2011   g_object_unref (handler);
2012 }