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   DispatcherRequestData *request_data = (DispatcherRequestData *) user_data;
1298   EmpathyDispatcher *dispatcher =
1299       EMPATHY_DISPATCHER (request_data->dispatcher);
1300
1301   dispatcher_connection_new_requested_channel (dispatcher,
1302     request_data, object_path, NULL, error);
1303 }
1304
1305 static void
1306 dispatcher_request_channel (DispatcherRequestData *request_data)
1307 {
1308   if (tp_proxy_has_interface_by_id (TP_PROXY (request_data->connection),
1309       TP_IFACE_QUARK_CONNECTION_INTERFACE_REQUESTS))
1310     {
1311       /* Extend the request_data to be a valid request */
1312       g_assert (request_data->request == NULL);
1313       request_data->request = tp_asv_new (
1314         TP_IFACE_CHANNEL ".ChannelType",
1315           G_TYPE_STRING, request_data->channel_type,
1316         TP_IFACE_CHANNEL ".TargetHandleType",
1317           G_TYPE_UINT, request_data->handle_type,
1318         NULL);
1319
1320       if (request_data->handle_type != TP_HANDLE_TYPE_NONE)
1321         tp_asv_set_uint32 (request_data->request,
1322           TP_IFACE_CHANNEL ".TargetHandle", request_data->handle);
1323
1324       empathy_dispatcher_call_create_or_ensure_channel (
1325         request_data->dispatcher, request_data);
1326     }
1327   else
1328     {
1329       request_data->pending_call = tp_cli_connection_call_request_channel (
1330         request_data->connection, -1,
1331         request_data->channel_type,
1332         request_data->handle_type,
1333         request_data->handle,
1334         TRUE, dispatcher_request_channel_cb,
1335         request_data, NULL, NULL);
1336     }
1337 }
1338
1339 void
1340 empathy_dispatcher_chat_with_contact (EmpathyContact *contact,
1341                                       EmpathyDispatcherRequestCb *callback,
1342                                       gpointer user_data)
1343 {
1344   EmpathyDispatcher *dispatcher;
1345   EmpathyDispatcherPriv *priv;
1346   TpConnection *connection;
1347   ConnectionData *connection_data;
1348   DispatcherRequestData *request_data;
1349
1350   g_return_if_fail (EMPATHY_IS_CONTACT (contact));
1351
1352   dispatcher = empathy_dispatcher_dup_singleton ();
1353   priv = GET_PRIV (dispatcher);
1354
1355   connection = empathy_contact_get_connection (contact);
1356   connection_data = g_hash_table_lookup (priv->connections, connection);
1357
1358   /* The contact handle might not be known yet */
1359   request_data = new_dispatcher_request_data (dispatcher, connection,
1360     TP_IFACE_CHANNEL_TYPE_TEXT, TP_HANDLE_TYPE_CONTACT,
1361     empathy_contact_get_handle (contact), NULL, contact, callback, user_data);
1362   request_data->should_ensure = TRUE;
1363
1364   connection_data->outstanding_requests = g_list_prepend
1365     (connection_data->outstanding_requests, request_data);
1366
1367   dispatcher_request_channel (request_data);
1368
1369   g_object_unref (dispatcher);
1370 }
1371
1372 typedef struct
1373 {
1374   EmpathyDispatcher *dispatcher;
1375   EmpathyDispatcherRequestCb *callback;
1376   gpointer user_data;
1377 } ChatWithContactIdData;
1378
1379 static void
1380 dispatcher_chat_with_contact_id_cb (EmpathyTpContactFactory *factory,
1381                                     EmpathyContact          *contact,
1382                                     const GError            *error,
1383                                     gpointer                 user_data,
1384                                     GObject                 *weak_object)
1385 {
1386   ChatWithContactIdData *data = user_data;
1387
1388   if (error)
1389     {
1390       /* FIXME: Should call data->callback with the error */
1391       DEBUG ("Error: %s", error->message);
1392     }
1393   else
1394     {
1395       empathy_dispatcher_chat_with_contact (contact, data->callback,
1396           data->user_data);
1397     }
1398
1399   g_object_unref (data->dispatcher);
1400   g_slice_free (ChatWithContactIdData, data);
1401 }
1402
1403 void
1404 empathy_dispatcher_chat_with_contact_id (TpConnection *connection,
1405                                          const gchar *contact_id,
1406                                          EmpathyDispatcherRequestCb *callback,
1407                                          gpointer user_data)
1408 {
1409   EmpathyDispatcher *dispatcher;
1410   EmpathyTpContactFactory *factory;
1411   ChatWithContactIdData *data;
1412
1413   g_return_if_fail (TP_IS_CONNECTION (connection));
1414   g_return_if_fail (!EMP_STR_EMPTY (contact_id));
1415
1416   dispatcher = empathy_dispatcher_dup_singleton ();
1417   factory = empathy_tp_contact_factory_dup_singleton (connection);
1418   data = g_slice_new0 (ChatWithContactIdData);
1419   data->dispatcher = dispatcher;
1420   data->callback = callback;
1421   data->user_data = user_data;
1422   empathy_tp_contact_factory_get_from_id (factory, contact_id,
1423       dispatcher_chat_with_contact_id_cb, data, NULL, NULL);
1424
1425   g_object_unref (factory);
1426 }
1427
1428 static void
1429 dispatcher_request_handles_cb (TpConnection *connection,
1430                                const GArray *handles,
1431                                const GError *error,
1432                                gpointer user_data,
1433                                GObject *object)
1434 {
1435   DispatcherRequestData *request_data = (DispatcherRequestData *) user_data;
1436
1437   if (error != NULL)
1438     {
1439       EmpathyDispatcher *dispatcher = EMPATHY_DISPATCHER (object);
1440       EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
1441       ConnectionData *cd;
1442
1443       cd = g_hash_table_lookup (priv->connections, request_data->connection);
1444
1445       if (request_data->cb)
1446         request_data->cb (NULL, error, request_data->user_data);
1447
1448       cd->outstanding_requests = g_list_remove (cd->outstanding_requests,
1449         request_data);
1450
1451       free_dispatcher_request_data (request_data);
1452
1453       dispatcher_flush_outstanding_operations (dispatcher, cd);
1454       return;
1455     }
1456
1457   request_data->handle = g_array_index (handles, guint, 0);
1458   dispatcher_request_channel (request_data);
1459 }
1460
1461 void
1462 empathy_dispatcher_join_muc (TpConnection *connection,
1463                              const gchar *roomname,
1464                              EmpathyDispatcherRequestCb *callback,
1465                              gpointer user_data)
1466 {
1467   EmpathyDispatcher *dispatcher;
1468   EmpathyDispatcherPriv *priv;
1469   DispatcherRequestData *request_data;
1470   ConnectionData *connection_data;
1471   const gchar *names[] = { roomname, NULL };
1472
1473   g_return_if_fail (TP_IS_CONNECTION (connection));
1474   g_return_if_fail (!EMP_STR_EMPTY (roomname));
1475
1476   dispatcher = empathy_dispatcher_dup_singleton ();
1477   priv = GET_PRIV (dispatcher);
1478
1479   connection_data = g_hash_table_lookup (priv->connections, connection);
1480
1481   /* Don't know the room handle yet */
1482   request_data  = new_dispatcher_request_data (dispatcher, connection,
1483     TP_IFACE_CHANNEL_TYPE_TEXT, TP_HANDLE_TYPE_ROOM, 0, NULL,
1484     NULL, callback, user_data);
1485
1486   connection_data->outstanding_requests = g_list_prepend
1487     (connection_data->outstanding_requests, request_data);
1488
1489   request_data->pending_call = tp_cli_connection_call_request_handles (
1490     connection, -1,
1491     TP_HANDLE_TYPE_ROOM, names,
1492     dispatcher_request_handles_cb, request_data, NULL, NULL);
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   DispatcherRequestData *request_data = (DispatcherRequestData *) user_data;
1506   EmpathyDispatcher *dispatcher =
1507       EMPATHY_DISPATCHER (request_data->dispatcher);
1508
1509   dispatcher_connection_new_requested_channel (dispatcher,
1510     request_data, object_path, properties, error);
1511 }
1512
1513 static void
1514 dispatcher_ensure_channel_cb (TpConnection *connect,
1515                               gboolean is_ours,
1516                               const gchar *object_path,
1517                               GHashTable *properties,
1518                               const GError *error,
1519                               gpointer user_data,
1520                               GObject *weak_object)
1521 {
1522   DispatcherRequestData *request_data = (DispatcherRequestData *) user_data;
1523   EmpathyDispatcher *dispatcher =
1524       EMPATHY_DISPATCHER (request_data->dispatcher);
1525
1526   dispatcher_connection_new_requested_channel (dispatcher,
1527     request_data, object_path, properties, error);
1528 }
1529
1530 static void
1531 empathy_dispatcher_call_create_or_ensure_channel (
1532     EmpathyDispatcher *dispatcher,
1533     DispatcherRequestData *request_data)
1534 {
1535   if (request_data->should_ensure)
1536     {
1537       request_data->pending_call =
1538           tp_cli_connection_interface_requests_call_ensure_channel (
1539           request_data->connection, -1,
1540           request_data->request, dispatcher_ensure_channel_cb,
1541           request_data, NULL, NULL);
1542     }
1543   else
1544     {
1545       request_data->pending_call =
1546           tp_cli_connection_interface_requests_call_create_channel (
1547           request_data->connection, -1,
1548           request_data->request, dispatcher_create_channel_cb,
1549           request_data, NULL, NULL);
1550     }
1551 }
1552
1553 void
1554 empathy_dispatcher_create_channel (EmpathyDispatcher *dispatcher,
1555                                    TpConnection *connection,
1556                                    GHashTable *request,
1557                                    EmpathyDispatcherRequestCb *callback,
1558                                    gpointer user_data)
1559 {
1560   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
1561   ConnectionData *connection_data;
1562   DispatcherRequestData *request_data;
1563   const gchar *channel_type;
1564   guint handle_type;
1565   guint handle;
1566   gboolean valid;
1567
1568   g_return_if_fail (EMPATHY_IS_DISPATCHER (dispatcher));
1569   g_return_if_fail (TP_IS_CONNECTION (connection));
1570   g_return_if_fail (request != NULL);
1571
1572   connection_data = g_hash_table_lookup (priv->connections, connection);
1573   g_assert (connection_data != NULL);
1574
1575   channel_type = tp_asv_get_string (request, TP_IFACE_CHANNEL ".ChannelType");
1576
1577   handle_type = tp_asv_get_uint32 (request,
1578     TP_IFACE_CHANNEL ".TargetHandleType", &valid);
1579   if (!valid)
1580     handle_type = TP_UNKNOWN_HANDLE_TYPE;
1581
1582   handle = tp_asv_get_uint32 (request, TP_IFACE_CHANNEL ".TargetHandle", NULL);
1583
1584   request_data  = new_dispatcher_request_data (dispatcher, connection,
1585     channel_type, handle_type, handle, request,
1586     NULL, callback, user_data);
1587
1588   connection_data->outstanding_requests = g_list_prepend
1589     (connection_data->outstanding_requests, request_data);
1590
1591   empathy_dispatcher_call_create_or_ensure_channel (dispatcher, request_data);
1592 }
1593
1594 static gboolean
1595 channel_class_matches (GValueArray *class,
1596                        const char *channel_type,
1597                        guint handle_type,
1598                        GArray *fixed_properties)
1599 {
1600   GHashTable *fprops;
1601   GValue *v;
1602   const char *c_type;
1603   guint h_type;
1604   gboolean valid;
1605
1606   v = g_value_array_get_nth (class, 0);
1607
1608   /* if the class doesn't match channel type discard it. */
1609   fprops = g_value_get_boxed (v);
1610   c_type = tp_asv_get_string (fprops, TP_IFACE_CHANNEL ".ChannelType");
1611
1612   if (tp_strdiff (channel_type, c_type))
1613     return FALSE;
1614
1615   /* we have the right channel type, see if the handle type matches */
1616   h_type = tp_asv_get_uint32 (fprops,
1617                               TP_IFACE_CHANNEL ".TargetHandleType", &valid);
1618
1619   if (!valid || handle_type != h_type)
1620     return FALSE;
1621
1622   if (fixed_properties != NULL)
1623     {
1624       gpointer h_key, h_val;
1625       int idx;
1626       GHashTableIter iter;
1627       gboolean found;
1628
1629       g_hash_table_iter_init (&iter, fprops);
1630
1631       while (g_hash_table_iter_next (&iter, &h_key, &h_val))
1632         {
1633           /* discard ChannelType and TargetHandleType, as we already
1634            * checked them.
1635            */
1636           if (!tp_strdiff ((char *) h_key, TP_IFACE_CHANNEL ".ChannelType") ||
1637               !tp_strdiff
1638                 ((char *) h_key, TP_IFACE_CHANNEL ".TargetHandleType"))
1639             continue;
1640
1641           found = FALSE;
1642
1643           for (idx = 0; idx < fixed_properties->len; idx++)
1644             {
1645               /* if |key| doesn't exist in |fixed_properties|, discard
1646                * the class.
1647                */
1648               if (!tp_strdiff
1649                     ((char *) h_key,
1650                      g_array_index (fixed_properties, char *, idx)))
1651                 {
1652                   found = TRUE;
1653                   /* exit the for() loop */
1654                   break;
1655                 }
1656             }
1657
1658           if (!found)
1659             return FALSE;
1660         }
1661     }
1662   else
1663     {
1664       /* if no fixed_properties are specified, discard the classes
1665        * with some fixed properties other than the two we already
1666        * checked.
1667        */
1668       if (g_hash_table_size (fprops) > 2)
1669         return FALSE;
1670     }
1671
1672   return TRUE;
1673 }
1674
1675 static GList *
1676 empathy_dispatcher_find_channel_classes (EmpathyDispatcher *dispatcher,
1677                                          TpConnection *connection,
1678                                          const gchar *channel_type,
1679                                          guint handle_type,
1680                                          GArray *fixed_properties)
1681 {
1682   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
1683   GValueArray *class;
1684   GPtrArray *classes;
1685   GList *matching_classes;
1686   int i;
1687   ConnectionData *cd;
1688
1689   g_return_val_if_fail (channel_type != NULL, NULL);
1690   g_return_val_if_fail (handle_type != 0, NULL);
1691
1692   cd = g_hash_table_lookup (priv->connections, connection);
1693
1694   if (cd == NULL)
1695     return NULL;
1696
1697   classes = cd->requestable_channels;
1698   if (classes == NULL)
1699     return NULL;
1700
1701   matching_classes = NULL;
1702
1703   for (i = 0; i < classes->len; i++)
1704     {
1705       class = g_ptr_array_index (classes, i);
1706
1707       if (!channel_class_matches
1708           (class, channel_type, handle_type, fixed_properties))
1709         continue;
1710
1711       matching_classes = g_list_prepend (matching_classes, class);
1712     }
1713
1714   return matching_classes;
1715 }
1716
1717 static gboolean
1718 find_channel_class_idle_cb (gpointer user_data)
1719 {
1720   GList *retval;
1721   GList *requests;
1722   FindChannelRequest *request = user_data;
1723   ConnectionData *cd;
1724   gboolean is_ready = TRUE;
1725   EmpathyDispatcherPriv *priv = GET_PRIV (request->dispatcher);
1726
1727   g_hash_table_remove (priv->request_channel_class_async_ids, request);
1728
1729   cd = g_hash_table_lookup (priv->connections, request->connection);
1730
1731   if (cd == NULL)
1732     is_ready = FALSE;
1733   else if (cd->requestable_channels == NULL)
1734     is_ready = FALSE;
1735
1736   if (is_ready)
1737     {
1738       retval = empathy_dispatcher_find_channel_classes (request->dispatcher,
1739           request->connection, request->channel_type, request->handle_type,
1740           request->properties);
1741
1742       request->callback (retval, request->user_data);
1743       free_find_channel_request (request);
1744       g_list_free (retval);
1745
1746       return FALSE;
1747     }
1748
1749   requests = g_hash_table_lookup (priv->outstanding_classes_requests,
1750       request->connection);
1751   requests = g_list_prepend (requests, request);
1752
1753   g_hash_table_insert (priv->outstanding_classes_requests,
1754       request->connection, requests);
1755
1756   return FALSE;
1757 }
1758
1759 static GArray *
1760 setup_varargs (va_list var_args,
1761                const char *channel_namespace,
1762                const char *first_property_name)
1763 {
1764   const char *name;
1765   char *name_full;
1766   GArray *properties;
1767
1768   if (first_property_name == NULL)
1769     return NULL;
1770
1771   name = first_property_name;
1772   properties = g_array_new (TRUE, TRUE, sizeof (char *));
1773
1774   while (name != NULL)
1775     {
1776       name_full = g_strdup (name);
1777       properties = g_array_append_val (properties, name_full);
1778       name = va_arg (var_args, char *);
1779     }
1780
1781   return properties;
1782 }
1783
1784 /**
1785  * empathy_dispatcher_find_requestable_channel_classes:
1786  * @dispatcher: an #EmpathyDispatcher
1787  * @connection: a #TpConnection
1788  * @channel_type: a string identifying the type of the channel to lookup
1789  * @handle_type: the handle type for the channel
1790  * @first_property_name: %NULL, or the name of the first fixed property,
1791  * followed optionally by more names, followed by %NULL.
1792  *
1793  * Returns all the channel classes that a client can request for the connection
1794  * @connection, of the type identified by @channel_type, @handle_type and the
1795  * fixed properties list.
1796  * The classes which are compatible with a fixed properties list (i.e. those
1797  * that will be returned by this function) are intended as those that do not
1798  * contain any fixed property other than those in the list; note that this
1799  * doesn't guarantee that all the classes compatible with the list will contain
1800  * all the requested fixed properties, so the clients will have to filter
1801  * the returned list themselves.
1802  * If @first_property_name is %NULL, only the classes with no other fixed
1803  * properties than ChannelType and TargetHandleType will be returned.
1804  * Note that this function may return %NULL without performing any lookup if
1805  * @connection is not ready. To ensure that @connection is always ready,
1806  * use the empathy_dispatcher_find_requestable_channel_classes_async() variant.
1807  *
1808  * Return value: a #GList of #GValueArray objects, where the first element in
1809  * the array is a #GHashTable of the fixed properties, and the second is
1810  * a #GStrv of the allowed properties for the class. The list should be free'd
1811  * with g_list_free() when done, but the objects inside the list are owned
1812  * by the #EmpathyDispatcher and must not be modified.
1813  */
1814 GList *
1815 empathy_dispatcher_find_requestable_channel_classes
1816                                  (EmpathyDispatcher *dispatcher,
1817                                   TpConnection *connection,
1818                                   const gchar *channel_type,
1819                                   guint handle_type,
1820                                   const char *first_property_name,
1821                                   ...)
1822 {
1823   va_list var_args;
1824   GArray *properties;
1825   EmpathyDispatcherPriv *priv;
1826   GList *retval;
1827   int idx;
1828   char *str;
1829
1830   g_return_val_if_fail (EMPATHY_IS_DISPATCHER (dispatcher), NULL);
1831   g_return_val_if_fail (TP_IS_CONNECTION (connection), NULL);
1832   g_return_val_if_fail (channel_type != NULL, NULL);
1833   g_return_val_if_fail (handle_type != 0, NULL);
1834
1835   priv = GET_PRIV (dispatcher);
1836
1837   va_start (var_args, first_property_name);
1838
1839   properties = setup_varargs (var_args, channel_type, first_property_name);
1840
1841   va_end (var_args);
1842
1843   retval = empathy_dispatcher_find_channel_classes (dispatcher, connection,
1844     channel_type, handle_type, properties);
1845
1846   if (properties != NULL)
1847     {
1848       /* free the properties array */
1849       for (idx = 0; idx < properties->len ; idx++)
1850         {
1851           str = g_array_index (properties, char *, idx);
1852           g_free (str);
1853         }
1854
1855       g_array_free (properties, TRUE);
1856     }
1857
1858   return retval;
1859 }
1860
1861 /**
1862  * empathy_dispatcher_find_requestable_channel_classes_async:
1863  * @dispatcher: an #EmpathyDispatcher
1864  * @connection: a #TpConnection
1865  * @channel_type: a string identifying the type of the channel to lookup
1866  * @handle_type: the handle type for the channel
1867  * @callback: the callback to call when @connection is ready
1868  * @user_data: the user data to pass to @callback
1869  * @first_property_name: %NULL, or the name of the first fixed property,
1870  * followed optionally by more names, followed by %NULL.
1871  *
1872  * Please see the documentation of
1873  * empathy_dispatcher_find_requestable_channel_classes() for a detailed
1874  * description of this function.
1875  */
1876 void
1877 empathy_dispatcher_find_requestable_channel_classes_async
1878                                  (EmpathyDispatcher *dispatcher,
1879                                   TpConnection *connection,
1880                                   const gchar *channel_type,
1881                                   guint handle_type,
1882                                   EmpathyDispatcherFindChannelClassCb callback,
1883                                   gpointer user_data,
1884                                   const char *first_property_name,
1885                                   ...)
1886 {
1887   va_list var_args;
1888   GArray *properties;
1889   FindChannelRequest *request;
1890   EmpathyDispatcherPriv *priv;
1891   guint source_id;
1892
1893   g_return_if_fail (EMPATHY_IS_DISPATCHER (dispatcher));
1894   g_return_if_fail (TP_IS_CONNECTION (connection));
1895   g_return_if_fail (channel_type != NULL);
1896   g_return_if_fail (handle_type != 0);
1897
1898   priv = GET_PRIV (dispatcher);
1899
1900   va_start (var_args, first_property_name);
1901
1902   properties = setup_varargs (var_args, channel_type, first_property_name);
1903
1904   va_end (var_args);
1905
1906   /* append another request for this connection */
1907   request = g_slice_new0 (FindChannelRequest);
1908   request->dispatcher = g_object_ref (dispatcher);
1909   request->channel_type = g_strdup (channel_type);
1910   request->handle_type = handle_type;
1911   request->connection = connection;
1912   request->callback = callback;
1913   request->user_data = user_data;
1914   request->properties = properties;
1915
1916   source_id = g_idle_add (find_channel_class_idle_cb, request);
1917
1918   g_hash_table_insert (priv->request_channel_class_async_ids,
1919     request, GUINT_TO_POINTER (source_id));
1920 }
1921
1922 static GList *
1923 empathy_dispatcher_get_channels (EmpathyHandler *handler,
1924   gpointer user_data)
1925 {
1926   EmpathyDispatcher *dispatcher = EMPATHY_DISPATCHER (user_data);
1927   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
1928
1929   return priv->channels;
1930 }
1931
1932 static gboolean
1933 empathy_dispatcher_handle_channels (EmpathyHandler *handler,
1934     const gchar *account_path,
1935     const gchar *connection_path,
1936     const GPtrArray *channels,
1937     const GPtrArray *requests_satisfied,
1938     guint64 timestamp,
1939     GHashTable *handler_info,
1940     gpointer user_data,
1941     GError **error)
1942 {
1943   EmpathyDispatcher *dispatcher = EMPATHY_DISPATCHER (user_data);
1944   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
1945   int i;
1946   EmpathyAccount *account;
1947   TpConnection *connection;
1948
1949   account = empathy_account_manager_ensure_account (priv->account_manager,
1950     account_path);
1951   g_assert (account != NULL);
1952
1953   connection = empathy_account_get_connection_for_path (account,
1954       connection_path);
1955   if (connection == NULL)
1956     {
1957       g_set_error_literal (error, TP_ERRORS, TP_ERROR_INVALID_ARGUMENT,
1958         "Invalid connection argument");
1959       return FALSE;
1960     }
1961
1962   for (i = 0; i < channels->len ; i++)
1963     {
1964       GValueArray *arr = g_ptr_array_index (channels, i);
1965       const gchar *object_path;
1966       GHashTable *properties;
1967
1968       object_path = g_value_get_boxed (g_value_array_get_nth (arr, 0));
1969       properties = g_value_get_boxed (g_value_array_get_nth (arr, 1));
1970
1971       dispatcher_connection_new_channel_with_properties (dispatcher,
1972         connection, object_path, properties);
1973     }
1974
1975   return TRUE;
1976 }
1977
1978
1979 EmpathyHandler *
1980 empathy_dispatcher_add_handler (EmpathyDispatcher *dispatcher,
1981     const gchar *name,
1982     GPtrArray *filters,
1983     GStrv capabilities)
1984 {
1985   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
1986   EmpathyHandler *handler;
1987
1988   handler = empathy_handler_new (name, filters, capabilities);
1989   priv->handlers = g_list_prepend (priv->handlers, handler);
1990
1991   /* Only set the handle_channels function, the Channel property on the main
1992    * handler will always report all dispatched channels even if they came from
1993    * a different Handler */
1994   empathy_handler_set_handle_channels_func (handler,
1995     empathy_dispatcher_handle_channels,
1996     dispatcher);
1997
1998   return handler;
1999 }
2000
2001 void
2002 empathy_dispatcher_remove_handler (EmpathyDispatcher *dispatcher,
2003   EmpathyHandler *handler)
2004 {
2005   EmpathyDispatcherPriv *priv = GET_PRIV (dispatcher);
2006   GList *h;
2007
2008   h = g_list_find (priv->handlers, handler);
2009   g_return_if_fail (h != NULL);
2010
2011   priv->handlers = g_list_delete_link (priv->handlers, h);
2012
2013   g_object_unref (handler);
2014 }