libempathy/empathy-dispatch-operation.c

   1 /*
   2  * empathy-dispatch-operation.c - Source for EmpathyDispatchOperation
   3  * Copyright (C) 2008 Collabora Ltd.
   4  * @author Sjoerd Simons <sjoerd.simons@collabora.co.uk>
   5  *
   6  * This library is free software; you can redistribute it and/or
   7  * modify it under the terms of the GNU Lesser General Public
   8  * License as published by the Free Software Foundation; either
   9  * version 2.1 of the License, or (at your option) any later version.
  10  *
  11  * This library is distributed in the hope that it will be useful,
  12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  14  * Lesser General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU Lesser General Public
  17  * License along with this library; if not, write to the Free Software
  18  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
  19  */
  20
  21
  22 #include <stdio.h>
  23 #include <stdlib.h>
  24
  25 #include "empathy-dispatch-operation.h"
  26 #include <libempathy/empathy-enum-types.h>
  27 #include <libempathy/empathy-tp-contact-factory.h>
  28 #include <libempathy/empathy-tp-chat.h>
  29 #include <libempathy/empathy-tp-call.h>
  30 #include <libempathy/empathy-tp-file.h>
  31
  32 #include "empathy-marshal.h"
  33
  34 #include "extensions/extensions.h"
  35
  36 #define DEBUG_FLAG EMPATHY_DEBUG_DISPATCHER
  37 #include <libempathy/empathy-debug.h>
  38
  39 G_DEFINE_TYPE(EmpathyDispatchOperation, empathy_dispatch_operation,
  40   G_TYPE_OBJECT)
  41
  42 static void empathy_dispatch_operation_set_status (
  43   EmpathyDispatchOperation *self, EmpathyDispatchOperationState status);
  44 static void empathy_dispatch_operation_channel_ready_cb (TpChannel *channel,
  45   const GError *error, gpointer user_data);
  46
  47 /* signal enum */
  48 enum
  49 {
  50     /* Ready for dispatching */
  51     READY,
  52     /* Approved by an approver, can only happens on incoming operations */
  53     APPROVED,
  54     /* Claimed by a handler */
  55     CLAIMED,
  56     /* Error, channel went away, inspecting it failed etc */
  57     INVALIDATED,
  58     LAST_SIGNAL
  59 };
  60
  61 static guint signals[LAST_SIGNAL] = {0};
  62
  63 /* properties */
  64 enum {
  65   PROP_CONNECTION = 1,
  66   PROP_CHANNEL,
  67   PROP_CHANNEL_WRAPPER,
  68   PROP_CONTACT,
  69   PROP_INCOMING,
  70   PROP_STATUS,
  71 };
  72
  73 /* private structure */
  74 typedef struct _EmpathyDispatchOperationPriv \
  75   EmpathyDispatchOperationPriv;
  76
  77 struct _EmpathyDispatchOperationPriv
  78 {
  79   gboolean dispose_has_run;
  80   TpConnection *connection;
  81   TpChannel *channel;
  82   GObject *channel_wrapper;
  83   EmpathyContact *contact;
  84   EmpathyDispatchOperationState status;
  85   gboolean incoming;
  86   gboolean approved;
  87   gulong invalidated_handler;
  88   gulong ready_handler;
  89 };
  90
  91 #define GET_PRIV(o)  \
  92   (G_TYPE_INSTANCE_GET_PRIVATE ((o), EMPATHY_TYPE_DISPATCH_OPERATION, \
  93     EmpathyDispatchOperationPriv))
  94
  95 static void
  96 empathy_dispatch_operation_init (EmpathyDispatchOperation *obj)
  97 {
  98   //EmpathyDispatchOperationPriv *priv =
  99   //  GET_PRIV (obj);
 100
 101   /* allocate any data required by the object here */
 102 }
 103
 104 static void empathy_dispatch_operation_dispose (GObject *object);
 105 static void empathy_dispatch_operation_finalize (GObject *object);
 106
 107 static void
 108 empathy_dispatch_operation_set_property (GObject *object,
 109   guint property_id, const GValue *value, GParamSpec *pspec)
 110 {
 111   EmpathyDispatchOperation *operation = EMPATHY_DISPATCH_OPERATION (object);
 112   EmpathyDispatchOperationPriv *priv = GET_PRIV (operation);
 113
 114   switch (property_id)
 115     {
 116       case PROP_CONNECTION:
 117         priv->connection = g_value_dup_object (value);
 118         break;
 119       case PROP_CHANNEL:
 120         priv->channel = g_value_dup_object (value);
 121         break;
 122       case PROP_CHANNEL_WRAPPER:
 123         priv->channel_wrapper = g_value_dup_object (value);
 124         break;
 125       case PROP_CONTACT:
 126         if (priv->contact != NULL)
 127           g_object_unref (priv->contact);
 128         priv->contact = g_value_dup_object (value);
 129         break;
 130       case PROP_INCOMING:
 131         priv->incoming = g_value_get_boolean (value);
 132         break;
 133     }
 134 }
 135
 136 static void
 137 empathy_dispatch_operation_get_property (GObject *object,
 138   guint property_id, GValue *value, GParamSpec *pspec)
 139 {
 140   EmpathyDispatchOperation *operation = EMPATHY_DISPATCH_OPERATION (object);
 141   EmpathyDispatchOperationPriv *priv = GET_PRIV (operation);
 142
 143   switch (property_id)
 144     {
 145       case PROP_CONNECTION:
 146         g_value_set_object (value, priv->connection);
 147         break;
 148       case PROP_CHANNEL:
 149         g_value_set_object (value, priv->channel);
 150         break;
 151       case PROP_CHANNEL_WRAPPER:
 152         g_value_set_object (value, priv->channel_wrapper);
 153         break;
 154       case PROP_CONTACT:
 155         g_value_set_object (value, priv->contact);
 156         break;
 157       case PROP_INCOMING:
 158         g_value_set_boolean (value, priv->incoming);
 159         break;
 160       case PROP_STATUS:
 161         g_value_set_enum (value, priv->status);
 162         break;
 163     }
 164 }
 165
 166 static void
 167 empathy_dispatch_operation_invalidated (TpProxy *proxy, guint domain,
 168   gint code, char *message, EmpathyDispatchOperation *self)
 169 {
 170   empathy_dispatch_operation_set_status (self,
 171     EMPATHY_DISPATCHER_OPERATION_STATE_INVALIDATED);
 172
 173   g_signal_emit (self, signals[INVALIDATED], 0, domain, code, message);
 174 }
 175
 176 static void
 177 dispatcher_operation_got_contact_cb (EmpathyTpContactFactory *factory,
 178                                      GList *contacts,
 179                                      gpointer user_data,
 180                                      GObject *self)
 181 {
 182   EmpathyDispatchOperationPriv *priv = GET_PRIV (self);
 183
 184   if (priv->contact != NULL)
 185     g_object_unref (priv->contact);
 186   priv->contact = g_object_ref (contacts->data);
 187   g_object_notify (G_OBJECT (self), "contact");
 188
 189   tp_channel_call_when_ready (priv->channel,
 190     empathy_dispatch_operation_channel_ready_cb, self);
 191 }
 192
 193 static void
 194 empathy_dispatch_operation_constructed (GObject *object)
 195 {
 196   EmpathyDispatchOperation *self = EMPATHY_DISPATCH_OPERATION (object);
 197   EmpathyDispatchOperationPriv *priv = GET_PRIV (self);
 198   TpHandle handle;
 199   TpHandleType handle_type;
 200
 201   empathy_dispatch_operation_set_status (self,
 202     EMPATHY_DISPATCHER_OPERATION_STATE_PREPARING);
 203
 204   priv->invalidated_handler =
 205     g_signal_connect (priv->channel, "invalidated",
 206       G_CALLBACK (empathy_dispatch_operation_invalidated), self);
 207
 208   handle = tp_channel_get_handle (priv->channel, &handle_type);
 209
 210   if (handle_type == TP_CONN_HANDLE_TYPE_CONTACT && priv->contact == NULL)
 211     {
 212       EmpathyTpContactFactory *factory;
 213
 214       factory = empathy_tp_contact_factory_dup_singleton (priv->connection);
 215       empathy_tp_contact_factory_get_from_handles (factory, 1, &handle,
 216         dispatcher_operation_got_contact_cb, NULL, NULL, object);
 217       g_object_unref (factory);
 218       return;
 219     }
 220
 221   tp_channel_call_when_ready (priv->channel,
 222     empathy_dispatch_operation_channel_ready_cb, self);
 223 }
 224
 225 static void
 226 empathy_dispatch_operation_class_init (
 227   EmpathyDispatchOperationClass *empathy_dispatch_operation_class)
 228 {
 229   GObjectClass *object_class =
 230     G_OBJECT_CLASS (empathy_dispatch_operation_class);
 231   GParamSpec *param_spec;
 232
 233   g_type_class_add_private (empathy_dispatch_operation_class,
 234     sizeof (EmpathyDispatchOperationPriv));
 235
 236   object_class->set_property = empathy_dispatch_operation_set_property;
 237   object_class->get_property = empathy_dispatch_operation_get_property;
 238
 239   object_class->dispose = empathy_dispatch_operation_dispose;
 240   object_class->finalize = empathy_dispatch_operation_finalize;
 241   object_class->constructed = empathy_dispatch_operation_constructed;
 242
 243   signals[READY] = g_signal_new ("ready",
 244     G_OBJECT_CLASS_TYPE(empathy_dispatch_operation_class),
 245       G_SIGNAL_RUN_LAST,
 246       0,
 247       NULL, NULL,
 248       g_cclosure_marshal_VOID__VOID,
 249       G_TYPE_NONE, 0);
 250
 251   signals[APPROVED] = g_signal_new ("approved",
 252     G_OBJECT_CLASS_TYPE(empathy_dispatch_operation_class),
 253       G_SIGNAL_RUN_LAST,
 254       0,
 255       NULL, NULL,
 256       g_cclosure_marshal_VOID__VOID,
 257       G_TYPE_NONE, 0);
 258
 259   signals[CLAIMED] = g_signal_new ("claimed",
 260     G_OBJECT_CLASS_TYPE(empathy_dispatch_operation_class),
 261       G_SIGNAL_RUN_LAST,
 262       0,
 263       NULL, NULL,
 264       g_cclosure_marshal_VOID__VOID,
 265       G_TYPE_NONE, 0);
 266
 267   signals[INVALIDATED] = g_signal_new ("invalidated",
 268     G_OBJECT_CLASS_TYPE(empathy_dispatch_operation_class),
 269       G_SIGNAL_RUN_LAST,
 270       0,
 271       NULL, NULL,
 272       _empathy_marshal_VOID__UINT_INT_STRING,
 273       G_TYPE_NONE, 3, G_TYPE_UINT, G_TYPE_INT, G_TYPE_STRING);
 274
 275   param_spec = g_param_spec_object ("connection",
 276     "connection", "The telepathy connection",
 277     TP_TYPE_CONNECTION,
 278     G_PARAM_CONSTRUCT_ONLY |
 279     G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS);
 280   g_object_class_install_property (object_class, PROP_CONNECTION,
 281                                   param_spec);
 282
 283   param_spec = g_param_spec_object ("channel",
 284     "channel", "The telepathy channel",
 285     TP_TYPE_CHANNEL,
 286     G_PARAM_CONSTRUCT_ONLY |
 287     G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS);
 288   g_object_class_install_property (object_class, PROP_CHANNEL,
 289                                   param_spec);
 290
 291   param_spec = g_param_spec_object ("channel-wrapper",
 292     "channel wrapper", "The empathy specific channel wrapper",
 293     G_TYPE_OBJECT,
 294     G_PARAM_CONSTRUCT_ONLY | G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS);
 295   g_object_class_install_property (object_class, PROP_CHANNEL_WRAPPER,
 296                                   param_spec);
 297
 298   param_spec = g_param_spec_object ("contact",
 299     "contact", "The empathy contact",
 300     EMPATHY_TYPE_CONTACT,
 301     G_PARAM_CONSTRUCT | G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS);
 302   g_object_class_install_property (object_class, PROP_CONTACT,
 303                                   param_spec);
 304
 305   param_spec = g_param_spec_boolean ("incoming",
 306     "incoming", "Whether or not the channel is incoming",
 307     FALSE,
 308     G_PARAM_CONSTRUCT_ONLY |
 309     G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS);
 310   g_object_class_install_property (object_class, PROP_INCOMING,
 311                                   param_spec);
 312
 313   param_spec = g_param_spec_enum ("status",
 314     "status", "Status of the dispatch operation",
 315     EMPATHY_TYPE_DISPATCH_OPERATION_STATE, 0,
 316     G_PARAM_READABLE | G_PARAM_STATIC_STRINGS);
 317   g_object_class_install_property (object_class, PROP_STATUS, param_spec);
 318 }
 319
 320 void
 321 empathy_dispatch_operation_dispose (GObject *object)
 322 {
 323   EmpathyDispatchOperation *self = EMPATHY_DISPATCH_OPERATION (object);
 324   EmpathyDispatchOperationPriv *priv =
 325     GET_PRIV (self);
 326
 327   if (priv->dispose_has_run)
 328     return;
 329
 330   priv->dispose_has_run = TRUE;
 331
 332   g_object_unref (priv->connection);
 333
 334   if (priv->channel_wrapper != NULL)
 335     g_object_unref (priv->channel_wrapper);
 336
 337   if (priv->ready_handler != 0)
 338     g_signal_handler_disconnect (priv->channel_wrapper,
 339       priv->invalidated_handler);
 340
 341
 342   g_signal_handler_disconnect (priv->channel, priv->invalidated_handler);
 343   g_object_unref (priv->channel);
 344
 345
 346   if (priv->contact != NULL)
 347     g_object_unref (priv->contact);
 348
 349   if (G_OBJECT_CLASS (empathy_dispatch_operation_parent_class)->dispose)
 350     G_OBJECT_CLASS (empathy_dispatch_operation_parent_class)->dispose (object);
 351 }
 352
 353 void
 354 empathy_dispatch_operation_finalize (GObject *object)
 355 {
 356   /* free any data held directly by the object here */
 357   G_OBJECT_CLASS (empathy_dispatch_operation_parent_class)->finalize (object);
 358 }
 359
 360 static void
 361 empathy_dispatch_operation_set_status (EmpathyDispatchOperation *self,
 362   EmpathyDispatchOperationState status)
 363 {
 364   EmpathyDispatchOperationPriv *priv = GET_PRIV (self);
 365
 366   g_assert (status >= priv->status);
 367
 368
 369   if (priv->status != status)
 370     {
 371       DEBUG ("Dispatch operation %s status: %d -> %d",
 372         empathy_dispatch_operation_get_object_path (self),
 373         priv->status, status);
 374
 375       priv->status = status;
 376       g_object_notify (G_OBJECT (self), "status");
 377
 378       if (status == EMPATHY_DISPATCHER_OPERATION_STATE_PENDING)
 379         g_signal_emit (self, signals[READY], 0);
 380     }
 381 }
 382
 383 static void
 384 empathy_dispatcher_operation_tp_chat_ready_cb (GObject *object,
 385   GParamSpec *spec, gpointer user_data)
 386 {
 387   EmpathyDispatchOperation *self = EMPATHY_DISPATCH_OPERATION (user_data);
 388   EmpathyDispatchOperationPriv *priv = GET_PRIV (self);
 389
 390   if (!empathy_tp_chat_is_ready (EMPATHY_TP_CHAT (priv->channel_wrapper)))
 391     return;
 392
 393   g_signal_handler_disconnect (priv->channel_wrapper, priv->ready_handler);
 394   priv->ready_handler = 0;
 395
 396   empathy_dispatch_operation_set_status (self,
 397     EMPATHY_DISPATCHER_OPERATION_STATE_PENDING);
 398 }
 399
 400 static void
 401 empathy_dispatcher_operation_tp_file_ready_cb (GObject *object,
 402   GParamSpec *spec, gpointer user_data)
 403 {
 404   EmpathyDispatchOperation *self = EMPATHY_DISPATCH_OPERATION (user_data);
 405   EmpathyDispatchOperationPriv *priv = GET_PRIV (self);
 406
 407   if (!empathy_tp_file_is_ready (EMPATHY_TP_FILE (priv->channel_wrapper)))
 408     return;
 409
 410   g_signal_handler_disconnect (priv->channel_wrapper, priv->ready_handler);
 411   priv->ready_handler = 0;
 412
 413   empathy_dispatch_operation_set_status (self,
 414     EMPATHY_DISPATCHER_OPERATION_STATE_PENDING);
 415 }
 416
 417 static void
 418 empathy_dispatch_operation_channel_ready_cb (TpChannel *channel,
 419   const GError *error, gpointer user_data)
 420 {
 421   EmpathyDispatchOperation *self = EMPATHY_DISPATCH_OPERATION (user_data);
 422   EmpathyDispatchOperationPriv *priv = GET_PRIV (self);
 423   GQuark channel_type;
 424
 425   /* The error will be handled in empathy_dispatch_operation_invalidated */
 426   if (error != NULL)
 427     return;
 428
 429   g_assert (channel == priv->channel);
 430
 431   /* If the channel wrapper is defined, we assume it's ready */
 432   if (priv->channel_wrapper != NULL)
 433     goto ready;
 434
 435   channel_type = tp_channel_get_channel_type_id (channel);
 436
 437   if (channel_type == TP_IFACE_QUARK_CHANNEL_TYPE_TEXT)
 438     {
 439       EmpathyTpChat *chat= empathy_tp_chat_new (channel);
 440       priv->channel_wrapper = G_OBJECT (chat);
 441
 442       if (!empathy_tp_chat_is_ready (chat))
 443         {
 444           priv->ready_handler = g_signal_connect (chat, "notify::ready",
 445             G_CALLBACK (empathy_dispatcher_operation_tp_chat_ready_cb), self);
 446           return;
 447         }
 448     }
 449   else if (channel_type == TP_IFACE_QUARK_CHANNEL_TYPE_STREAMED_MEDIA)
 450     {
 451       EmpathyTpCall *call = empathy_tp_call_new (channel);
 452       priv->channel_wrapper = G_OBJECT (call);
 453     }
 454   else if (channel_type == TP_IFACE_QUARK_CHANNEL_TYPE_FILE_TRANSFER)
 455     {
 456       EmpathyTpFile *file = empathy_tp_file_new (channel);
 457       priv->channel_wrapper = G_OBJECT (file);
 458
 459       if (!empathy_tp_file_is_ready (file))
 460         {
 461           priv->ready_handler = g_signal_connect (file, "notify::ready",
 462             G_CALLBACK (empathy_dispatcher_operation_tp_file_ready_cb), self);
 463           return;
 464         }
 465     }
 466
 467 ready:
 468   empathy_dispatch_operation_set_status (self,
 469     EMPATHY_DISPATCHER_OPERATION_STATE_PENDING);
 470 }
 471
 472 EmpathyDispatchOperation *
 473 empathy_dispatch_operation_new (TpConnection *connection, TpChannel *channel,
 474   EmpathyContact *contact, gboolean incoming)
 475 {
 476   return empathy_dispatch_operation_new_with_wrapper (connection, channel,
 477     contact, incoming, NULL);
 478 }
 479
 480 EmpathyDispatchOperation *
 481 empathy_dispatch_operation_new_with_wrapper (TpConnection *connection,
 482   TpChannel *channel, EmpathyContact *contact, gboolean incoming,
 483   GObject *wrapper)
 484 {
 485   g_return_val_if_fail (connection != NULL, NULL);
 486   g_return_val_if_fail (channel != NULL, NULL);
 487
 488   return EMPATHY_DISPATCH_OPERATION (
 489     g_object_new (EMPATHY_TYPE_DISPATCH_OPERATION,
 490       "connection", connection,
 491       "channel", channel,
 492       "channel-wrapper", wrapper,
 493       "contact", contact,
 494       "incoming", incoming,
 495       NULL));
 496 }
 497
 498 void
 499 empathy_dispatch_operation_start (EmpathyDispatchOperation *operation)
 500 {
 501   EmpathyDispatchOperationPriv *priv;
 502
 503   g_return_if_fail (EMPATHY_IS_DISPATCH_OPERATION (operation));
 504
 505   priv = GET_PRIV (operation);
 506
 507   g_return_if_fail (
 508     priv->status == EMPATHY_DISPATCHER_OPERATION_STATE_PENDING);
 509
 510   if (priv->incoming && !priv->approved)
 511     empathy_dispatch_operation_set_status (operation,
 512       EMPATHY_DISPATCHER_OPERATION_STATE_APPROVING);
 513   else
 514     empathy_dispatch_operation_set_status (operation,
 515       EMPATHY_DISPATCHER_OPERATION_STATE_DISPATCHING);
 516 }
 517
 518 void
 519 empathy_dispatch_operation_approve (EmpathyDispatchOperation *operation)
 520 {
 521   EmpathyDispatchOperationPriv *priv;
 522
 523   g_return_if_fail (EMPATHY_IS_DISPATCH_OPERATION (operation));
 524
 525   priv = GET_PRIV (operation);
 526
 527   if (priv->status == EMPATHY_DISPATCHER_OPERATION_STATE_APPROVING)
 528     {
 529       DEBUG ("Approving operation %s",
 530         empathy_dispatch_operation_get_object_path (operation));
 531
 532       empathy_dispatch_operation_set_status (operation,
 533         EMPATHY_DISPATCHER_OPERATION_STATE_DISPATCHING);
 534
 535       g_signal_emit (operation, signals[APPROVED], 0);
 536     }
 537   else if (priv->status < EMPATHY_DISPATCHER_OPERATION_STATE_APPROVING)
 538     {
 539       DEBUG ("Pre-approving operation %s",
 540         empathy_dispatch_operation_get_object_path (operation));
 541       priv->approved = TRUE;
 542     }
 543   else
 544     {
 545       DEBUG (
 546         "Ignoring approval for %s as it's already past the approval stage",
 547         empathy_dispatch_operation_get_object_path (operation));
 548     }
 549 }
 550
 551 /* Returns whether or not the operation was successfully claimed */
 552 gboolean
 553 empathy_dispatch_operation_claim (EmpathyDispatchOperation *operation)
 554 {
 555   EmpathyDispatchOperationPriv *priv;
 556
 557   g_return_val_if_fail (EMPATHY_IS_DISPATCH_OPERATION (operation), FALSE);
 558
 559   priv = GET_PRIV (operation);
 560
 561   if (priv->status == EMPATHY_DISPATCHER_OPERATION_STATE_CLAIMED)
 562     return FALSE;
 563
 564   empathy_dispatch_operation_set_status (operation,
 565     EMPATHY_DISPATCHER_OPERATION_STATE_CLAIMED);
 566
 567   g_signal_emit (operation, signals[CLAIMED], 0);
 568
 569   return TRUE;
 570 }
 571
 572 TpConnection *
 573 empathy_dispatch_operation_get_tp_connection (
 574   EmpathyDispatchOperation *operation)
 575 {
 576   EmpathyDispatchOperationPriv *priv;
 577
 578   g_return_val_if_fail (EMPATHY_IS_DISPATCH_OPERATION (operation), NULL);
 579
 580   priv = GET_PRIV (operation);
 581
 582   return g_object_ref (priv->connection);
 583 }
 584
 585 TpChannel *
 586 empathy_dispatch_operation_get_channel (EmpathyDispatchOperation *operation)
 587 {
 588   EmpathyDispatchOperationPriv *priv;
 589
 590   g_return_val_if_fail (EMPATHY_IS_DISPATCH_OPERATION (operation), NULL);
 591
 592   priv = GET_PRIV (operation);
 593
 594   return priv->channel;
 595 }
 596
 597 GObject *
 598 empathy_dispatch_operation_get_channel_wrapper (
 599   EmpathyDispatchOperation *operation)
 600 {
 601   EmpathyDispatchOperationPriv *priv;
 602
 603   g_return_val_if_fail (EMPATHY_IS_DISPATCH_OPERATION (operation), NULL);
 604
 605   priv = GET_PRIV (operation);
 606
 607   return priv->channel_wrapper;
 608 }
 609
 610 const gchar *
 611 empathy_dispatch_operation_get_channel_type (
 612   EmpathyDispatchOperation *operation)
 613 {
 614   EmpathyDispatchOperationPriv *priv;
 615
 616   g_return_val_if_fail (EMPATHY_IS_DISPATCH_OPERATION (operation), NULL);
 617
 618   priv = GET_PRIV (operation);
 619
 620   return tp_channel_get_channel_type (priv->channel);
 621 }
 622
 623 GQuark
 624 empathy_dispatch_operation_get_channel_type_id (
 625   EmpathyDispatchOperation *operation)
 626 {
 627   EmpathyDispatchOperationPriv *priv;
 628
 629   g_return_val_if_fail (EMPATHY_IS_DISPATCH_OPERATION (operation), 0);
 630
 631   priv = GET_PRIV (operation);
 632
 633   return tp_channel_get_channel_type_id (priv->channel);
 634 }
 635
 636 const gchar *
 637 empathy_dispatch_operation_get_object_path (
 638   EmpathyDispatchOperation *operation)
 639 {
 640   EmpathyDispatchOperationPriv *priv;
 641
 642   g_return_val_if_fail (EMPATHY_IS_DISPATCH_OPERATION (operation), NULL);
 643
 644   priv = GET_PRIV (operation);
 645
 646   return tp_proxy_get_object_path (TP_PROXY (priv->channel));
 647 }
 648
 649 EmpathyDispatchOperationState
 650 empathy_dispatch_operation_get_status (EmpathyDispatchOperation *operation)
 651 {
 652   EmpathyDispatchOperationPriv *priv;
 653
 654   g_return_val_if_fail (EMPATHY_IS_DISPATCH_OPERATION (operation),
 655     EMPATHY_DISPATCHER_OPERATION_STATE_PREPARING);
 656
 657   priv = GET_PRIV (operation);
 658
 659   return priv->status;
 660 }
 661
 662 gboolean
 663 empathy_dispatch_operation_is_incoming (EmpathyDispatchOperation *operation)
 664 {
 665   EmpathyDispatchOperationPriv *priv;
 666
 667   g_return_val_if_fail (EMPATHY_IS_DISPATCH_OPERATION (operation), FALSE);
 668
 669   priv = GET_PRIV (operation);
 670
 671   return priv->incoming;
 672 }