/*
 * channel.c - Source for TfChannel
 * Copyright (C) 2006-2007 Collabora Ltd.
 * Copyright (C) 2006-2007 Nokia Corporation
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
 */

/**
 * SECTION:channel
 * @short_description: Handle the MediaSignalling or Call media interfaces on a
 *  Channel
 *
 * This class handles the
 * org.freedesktop.Telepathy.Channel.Interface.MediaSignalling on a
 * channel using Farstream or the media part of the
 * org.freedesktop.Telepathy.Channel.Type.Call that has HardwareStreaming=FALSE
 */

#include "config.h"

#include <stdlib.h>

#include <telepathy-glib/telepathy-glib.h>
#include <telepathy-glib/telepathy-glib-dbus.h>

#include <farstream/fs-conference.h>


#include "channel.h"
#include "channel-priv.h"
#include "media-signalling-channel.h"
#include "media-signalling-content.h"
#include "call-channel.h"
#include "content.h"


static void channel_async_initable_init (GAsyncInitableIface *asynciface);

G_DEFINE_TYPE_WITH_CODE (TfChannel, tf_channel, G_TYPE_OBJECT,
    G_IMPLEMENT_INTERFACE (G_TYPE_ASYNC_INITABLE, channel_async_initable_init));

struct _TfChannelPrivate
{
  TpChannel *channel_proxy;

  TfMediaSignallingChannel *media_signalling_channel;
  TfCallChannel *call_channel;

  GHashTable *media_signalling_contents;

  gulong channel_invalidated_handler;

  gboolean closed;
};

enum
{
  SIGNAL_CLOSED,
  SIGNAL_FS_CONFERENCE_ADDED,
  SIGNAL_FS_CONFERENCE_REMOVED,
  SIGNAL_CONTENT_ADDED,
  SIGNAL_CONTENT_REMOVED,
  SIGNAL_COUNT
};

static guint signals[SIGNAL_COUNT] = {0};

enum
{
  PROP_CHANNEL = 1,
  PROP_OBJECT_PATH,
  PROP_FS_CONFERENCES
};

static void shutdown_channel (TfChannel *self);

static void channel_fs_conference_added (GObject *chan,
    FsConference *conf, TfChannel *self);
static void channel_fs_conference_removed (GObject *chan,
    FsConference *conf, TfChannel *self);

static void tf_channel_init_async (GAsyncInitable *initable,
    int io_priority,
    GCancellable  *cancellable,
    GAsyncReadyCallback callback,
    gpointer user_data);
static gboolean tf_channel_init_finish (GAsyncInitable *initable,
    GAsyncResult *res,
    GError **error);

static void content_added (GObject *proxy,
    TfContent *content,
    TfChannel *self);
static void content_removed (GObject *proxy,
    TfContent *content,
    TfChannel *self);


static void
tf_channel_init (TfChannel *self)
{
  TfChannelPrivate *priv = G_TYPE_INSTANCE_GET_PRIVATE (self,
      TF_TYPE_CHANNEL, TfChannelPrivate);

  self->priv = priv;
}

static void
channel_async_initable_init (GAsyncInitableIface *asynciface)
{
  asynciface->init_async = tf_channel_init_async;
  asynciface->init_finish = tf_channel_init_finish;
}


static void
tf_channel_get_property (GObject    *object,
                                       guint       property_id,
                                       GValue     *value,
                                       GParamSpec *pspec)
{
  TfChannel *self = TF_CHANNEL (object);

  switch (property_id)
    {
    case PROP_CHANNEL:
      g_value_set_object (value, self->priv->channel_proxy);
      break;
    case PROP_OBJECT_PATH:
      g_value_set_string (value,
          tp_proxy_get_object_path (self->priv->channel_proxy));
      break;
    case PROP_FS_CONFERENCES:
      if (self->priv->call_channel)
        {
          g_object_get_property (G_OBJECT (self->priv->call_channel),
              "fs-conferences", value);
        }
      else if (self->priv->media_signalling_channel &&
               self->priv->media_signalling_channel->session)
        {
          GPtrArray *array =
              g_ptr_array_new_with_free_func ((GDestroyNotify) gst_object_unref);
          FsConference *conf = NULL;

          g_object_get (self->priv->media_signalling_channel->session,
              "farstream-conference", &conf, NULL);
          g_ptr_array_add (array, conf);
          g_value_take_boxed (value, array);
        }

      break;
    default:
      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
      break;
    }
}

static void
tf_channel_set_property (GObject      *object,
                                       guint         property_id,
                                       const GValue *value,
                                       GParamSpec   *pspec)
{
  TfChannel *self = TF_CHANNEL (object);

  switch (property_id)
    {
    case PROP_CHANNEL:
      self->priv->channel_proxy = TP_CHANNEL (g_value_dup_object (value));
      break;
    default:
      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
      break;
    }
}

static void channel_invalidated (TpChannel *channel_proxy,
    guint domain, gint code, gchar *message, TfChannel *self);

static void
call_channel_ready (GObject *obj, GAsyncResult *call_res, gpointer user_data)
{
  GError *error = NULL;
  GSimpleAsyncResult *res = user_data;
  TfChannel *self = TF_CHANNEL (
      g_async_result_get_source_object (G_ASYNC_RESULT (res)));

  self->priv->call_channel = TF_CALL_CHANNEL (g_async_initable_new_finish (
          G_ASYNC_INITABLE (obj), call_res, &error));

  if (error)
    {
      shutdown_channel (self);
      g_simple_async_result_set_op_res_gboolean (res, FALSE);
      g_simple_async_result_set_from_error (res, error);
      g_clear_error (&error);
    }
  else
    {
      g_simple_async_result_set_op_res_gboolean (res, TRUE);

      tp_g_signal_connect_object (self->priv->call_channel,
          "fs-conference-added", G_CALLBACK (channel_fs_conference_added),
          self, 0);
      tp_g_signal_connect_object (self->priv->call_channel,
          "fs-conference-removed", G_CALLBACK (channel_fs_conference_removed),
          self, 0);

      tp_g_signal_connect_object (self->priv->call_channel,
          "content_added", G_CALLBACK (content_added),
          self, 0);
      tp_g_signal_connect_object (self->priv->call_channel,
          "content_removed", G_CALLBACK (content_removed),
          self, 0);
    }


  g_simple_async_result_complete (res);
  g_object_unref (res);
  g_object_unref (self);
}

static gboolean
content_remove_all (gpointer key, gpointer value, gpointer user_data)
{
  TfMediaSignallingContent *content = value;
  TfChannel *self = user_data;

  g_signal_emit (self, signals[SIGNAL_CONTENT_REMOVED], 0, content);

  return TRUE;
}

static void
channel_session_invalidated (TfMediaSignallingChannel *media_signalling_channel,
    FsConference *fsconference, FsParticipant *part, TfChannel *self)
{
  g_object_notify (G_OBJECT (self), "fs-conferences");
  g_signal_emit (self, signals[SIGNAL_FS_CONFERENCE_REMOVED], 0,
      fsconference);

  if (self->priv->media_signalling_contents)
    g_hash_table_foreach_remove (self->priv->media_signalling_contents,
        content_remove_all, self);
}

static void
channel_stream_closed (TfStream *stream, TfChannel *self)
{
  TfMediaSignallingContent *content;

  content = g_hash_table_lookup (self->priv->media_signalling_contents, stream);
  g_signal_emit (self, signals[SIGNAL_CONTENT_REMOVED], 0, content);
  g_hash_table_remove (self->priv->media_signalling_contents, stream);
}

static void
channel_stream_created (TfMediaSignallingChannel *media_signalling_channel,
    TfStream *stream, TfChannel *self)
{
  TfMediaSignallingContent *content;

  g_assert (self->priv->media_signalling_contents);

  content = tf_media_signalling_content_new (
      self->priv->media_signalling_channel, stream, 0 /* HANDLE HERE */);

  g_hash_table_insert (self->priv->media_signalling_contents,
      g_object_ref (stream), content);

  tp_g_signal_connect_object (stream, "closed",
      G_CALLBACK (channel_stream_closed), self, 0);

  g_signal_emit (self, signals[SIGNAL_CONTENT_ADDED], 0,
      content);
}

static void
channel_prepared (GObject *obj,
    GAsyncResult *proxy_res,
    gpointer user_data)
{
  TpChannel *channel_proxy = TP_CHANNEL (obj);
  TpProxy *as_proxy = (TpProxy *) channel_proxy;
  GSimpleAsyncResult *res = user_data;
  GError *error = NULL;
  TfChannel *self = TF_CHANNEL (
      g_async_result_get_source_object (G_ASYNC_RESULT (res)));

  if (!tp_proxy_prepare_finish (channel_proxy, proxy_res, &error))
    {
      g_simple_async_result_propagate_error (res, &error);
      shutdown_channel (self);
      goto error;
    }

  if (self->priv->closed)
    {
      g_simple_async_result_set_error (res, TP_ERROR, TP_ERROR_CANCELLED,
          "Channel already closed");
      goto error;
    }

  if (tp_proxy_has_interface_by_id (as_proxy,
        TP_IFACE_QUARK_CHANNEL_INTERFACE_MEDIA_SIGNALLING))
    {
      self->priv->media_signalling_channel =
          tf_media_signalling_channel_new (channel_proxy);

      self->priv->media_signalling_contents = g_hash_table_new_full (
          g_direct_hash, g_direct_equal, g_object_unref, g_object_unref);

      tp_g_signal_connect_object (self->priv->media_signalling_channel,
          "session-created", G_CALLBACK (channel_fs_conference_added),
          self, 0);
      tp_g_signal_connect_object (self->priv->media_signalling_channel,
          "session-invalidated", G_CALLBACK (channel_session_invalidated),
          self, 0);
      tp_g_signal_connect_object (self->priv->media_signalling_channel,
          "stream-created", G_CALLBACK (channel_stream_created),
          self, 0);
      g_simple_async_result_set_op_res_gboolean (res, TRUE);
      g_simple_async_result_complete (res);
    }
  else if (tp_proxy_has_interface_by_id (as_proxy,
          TP_IFACE_QUARK_CHANNEL_TYPE_CALL))
    {
      if (!TP_IS_CALL_CHANNEL (channel_proxy))
        {
          g_simple_async_result_set_error (res, TP_ERROR,
              TP_ERROR_INVALID_ARGUMENT,
              "You must pass a TpCallChannel object if its a Call channel");
          g_simple_async_result_set_op_res_gboolean (res, FALSE);
          g_simple_async_result_complete (res);
        }
      else
        {
          tf_call_channel_new_async (channel_proxy, call_channel_ready, res);

          self->priv->channel_invalidated_handler = g_signal_connect (
              self->priv->channel_proxy,
              "invalidated", G_CALLBACK (channel_invalidated), self);
        }
    }
  else
    {
      g_simple_async_result_set_error (res, TP_ERROR, TP_ERROR_NOT_IMPLEMENTED,
          "Channel does not implement "
          TP_IFACE_CHANNEL_INTERFACE_MEDIA_SIGNALLING " or "
          TP_IFACE_CHANNEL_TYPE_CALL);
      goto error;
    }

  g_object_unref (self);
  return;

error:
  g_simple_async_result_set_op_res_gboolean (res, FALSE);
  g_simple_async_result_complete (res);

  g_object_unref (res);
  g_object_unref (self);
}


static void
tf_channel_init_async (GAsyncInitable *initable,
    int io_priority,
    GCancellable  *cancellable,
    GAsyncReadyCallback callback,
    gpointer user_data)
{
  TfChannel *self = TF_CHANNEL (initable);
  GSimpleAsyncResult *res;

  if (cancellable != NULL)
    {
      g_simple_async_report_error_in_idle (G_OBJECT (self), callback, user_data,
          G_IO_ERROR, G_IO_ERROR_NOT_INITIALIZED,
          "TfChannel initialisation does not support cancellation");
      return;
    }

  res = g_simple_async_result_new (G_OBJECT (self), callback, user_data,
      tf_channel_init_async);
  tp_proxy_prepare_async (self->priv->channel_proxy, NULL,
      channel_prepared, res);
}

static gboolean
tf_channel_init_finish (GAsyncInitable *initable,
    GAsyncResult *res,
    GError **error)
{
  GSimpleAsyncResult *simple_res;

  g_return_val_if_fail (g_simple_async_result_is_valid (res,
          G_OBJECT (initable), tf_channel_init_async), FALSE);
  simple_res = G_SIMPLE_ASYNC_RESULT (res);

  g_simple_async_result_propagate_error (simple_res, error);

  return g_simple_async_result_get_op_res_gboolean (simple_res);
}


static void
tf_channel_dispose (GObject *object)
{
  TfChannel *self = TF_CHANNEL (object);

  g_debug (G_STRFUNC);


  if (self->priv->media_signalling_contents != NULL)
    {
      g_hash_table_unref (self->priv->media_signalling_contents);
      self->priv->media_signalling_contents = NULL;
    }

  tp_clear_object (&self->priv->media_signalling_channel);
  tp_clear_object (&self->priv->call_channel);

  if (self->priv->channel_proxy)
    {
      TpChannel *tmp;

      if (self->priv->channel_invalidated_handler != 0)
        g_signal_handler_disconnect (self->priv->channel_proxy,
            self->priv->channel_invalidated_handler);

      tmp = self->priv->channel_proxy;
      self->priv->channel_proxy = NULL;
      g_object_unref (tmp);
    }

  if (G_OBJECT_CLASS (tf_channel_parent_class)->dispose)
    G_OBJECT_CLASS (tf_channel_parent_class)->dispose (object);
}

static void
tf_channel_class_init (TfChannelClass *klass)
{
  GObjectClass *object_class = G_OBJECT_CLASS (klass);

  g_type_class_add_private (klass, sizeof (TfChannelPrivate));

  object_class->set_property = tf_channel_set_property;
  object_class->get_property = tf_channel_get_property;

  object_class->dispose = tf_channel_dispose;

  g_object_class_install_property (object_class, PROP_CHANNEL,
      g_param_spec_object ("channel",
          "TpChannel object",
          "Telepathy channel object which this media channel should operate on",
          TP_TYPE_CHANNEL,
          G_PARAM_CONSTRUCT_ONLY | G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));

  g_object_class_install_property (object_class, PROP_OBJECT_PATH,
      g_param_spec_string ("object-path",
          "channel object path",
          "D-Bus object path of the Telepathy channel which this channel"
          " operates on",
          NULL,
          G_PARAM_READABLE | G_PARAM_STATIC_STRINGS));


  g_object_class_install_property (object_class, PROP_FS_CONFERENCES,
      g_param_spec_boxed ("fs-conferences",
          "Farstream FsConferences objects",
          "GPtrArray of Farstream FsConferences for this channel",
          G_TYPE_PTR_ARRAY,
          G_PARAM_READABLE | G_PARAM_STATIC_STRINGS));

  /**
   * TfChannel::closed:
   *
   * This function is called after a channel is closed, either because
   * it has been closed by the connection manager or because we had a locally
   * generated error.
   */

  signals[SIGNAL_CLOSED] =
      g_signal_new ("closed",
          G_OBJECT_CLASS_TYPE (klass),
          G_SIGNAL_RUN_LAST,
          0,
          NULL, NULL, NULL,
          G_TYPE_NONE, 0);

  /**
   * TfChannel::fs-conference-added:
   * @tfchannel: the #TfChannel
   * @conf: a #FsConference
   *
   * When this signal is emitted, the conference should be added to the
   * application's pipeline.
   */

  signals[SIGNAL_FS_CONFERENCE_ADDED] = g_signal_new ("fs-conference-added",
      G_OBJECT_CLASS_TYPE (klass),
      G_SIGNAL_RUN_LAST,
      0, NULL, NULL, NULL,
      G_TYPE_NONE, 1, FS_TYPE_CONFERENCE);

  /**
   * TfChannel::fs-conference-removed:
   * @tfchannel: the #TfChannel
   * @conf: a #FsConference
   *
   * When this signal is emitted, the conference should be remove from the
   * application's pipeline.
   */

  signals[SIGNAL_FS_CONFERENCE_REMOVED] = g_signal_new ("fs-conference-removed",
      G_OBJECT_CLASS_TYPE (klass),
      G_SIGNAL_RUN_LAST,
      0, NULL, NULL, NULL,
      G_TYPE_NONE, 1, FS_TYPE_CONFERENCE);


  /**
   * TfChannel::content-added:
   * @tfchannel: the #TfChannel
   * @content: a #TfContent
   *
   * Tells the application that a content has been added. In the callback for
   * this signal, the application should set its preferred codecs, and hook
   * up to any signal from #TfContent it cares about. Special care should be
   * made to connect #TfContent::src-pad-added as well
   * as the #TfContent::start-sending and #TfContent::stop-sending signals.
   */

  signals[SIGNAL_CONTENT_ADDED] = g_signal_new ("content-added",
      G_OBJECT_CLASS_TYPE (klass),
      G_SIGNAL_RUN_LAST,
      0, NULL, NULL, NULL,
      G_TYPE_NONE, 1, TF_TYPE_CONTENT);

  /**
   * TfChannel::content-removed:
   * @tfchannel: the #TfChannel
   * @content: a #TfContent
   *
   * Tells the application that a content is being removed.
   */

  signals[SIGNAL_CONTENT_REMOVED] = g_signal_new ("content-removed",
      G_OBJECT_CLASS_TYPE (klass),
      G_SIGNAL_RUN_LAST,
      0, NULL, NULL, NULL,
      G_TYPE_NONE, 1, TF_TYPE_CONTENT);
}

static void
shutdown_channel (TfChannel *self)
{
  if (self->priv->media_signalling_channel)
    {
      g_object_unref (self->priv->media_signalling_channel);
      self->priv->media_signalling_channel = NULL;
    }

  tp_clear_object (&self->priv->call_channel);

  if (self->priv->channel_proxy != NULL)
    {
      if (self->priv->channel_invalidated_handler)
        {
          g_signal_handler_disconnect (
            self->priv->channel_proxy, self->priv->channel_invalidated_handler);
          self->priv->channel_invalidated_handler = 0;
        }
    }

  g_signal_emit (self, signals[SIGNAL_CLOSED], 0);

  self->priv->closed = TRUE;
}

static void
channel_invalidated (TpChannel *channel_proxy,
    guint domain,
    gint code,
    gchar *message,
    TfChannel *self)
{
  shutdown_channel (self);
}

/**
 * tf_channel_new_async:
 * @channel_proxy: a #TpChannel proxy
 * @callback: a #GAsyncReadyCallback to call when the channel is ready
 * @user_data: the data to pass to callback function
 *
 * Creates a new #TfChannel from an existing channel proxy, the new
 * TfChannel object will be return in the async callback.
 *
 * The user must call tf_channel_new_finish() in the callback
 * to get the finished object.
 */

void
tf_channel_new_async (TpChannel *channel_proxy,
    GAsyncReadyCallback callback,
    gpointer user_data)
{
  g_return_if_fail (channel_proxy != NULL);
  g_return_if_fail (callback != NULL);

  return g_async_initable_new_async (TF_TYPE_CHANNEL,
      0, NULL, callback, user_data,
      "channel", channel_proxy,
      NULL);
}

/**
 * tf_channel_bus_message:
 * @channel: A #TfChannel
 * @message: A #GstMessage received from the bus
 *
 * You must call this function on call messages received on the async bus.
 * #GstMessages are not modified.
 *
 * Returns: %TRUE if the message has been handled, %FALSE otherwise
 */

gboolean
tf_channel_bus_message (TfChannel *channel,
    GstMessage *message)
{
  g_return_val_if_fail (channel != NULL, FALSE);
  g_return_val_if_fail (message != NULL, FALSE);

  if (channel->priv->media_signalling_channel)
    return tf_media_signalling_channel_bus_message (
        channel->priv->media_signalling_channel, message);
  else if (channel->priv->call_channel)
    return tf_call_channel_bus_message (channel->priv->call_channel,
      message);

  return FALSE;
}

static void
channel_fs_conference_added (GObject *proxy, FsConference *conf,
    TfChannel *self)
{
  g_object_notify (G_OBJECT (self), "fs-conferences");
  g_signal_emit (self, signals[SIGNAL_FS_CONFERENCE_ADDED], 0,
      conf);
}

static void
channel_fs_conference_removed (GObject *proxy, FsConference *conf,
    TfChannel *self)
{
  g_object_notify (G_OBJECT (self), "fs-conferences");
  g_signal_emit (self, signals[SIGNAL_FS_CONFERENCE_REMOVED], 0,
      conf);
}

static void
content_added (GObject *proxy, TfContent *content, TfChannel *self)
{
  g_signal_emit (self, signals[SIGNAL_CONTENT_ADDED], 0, content);
}

static void
content_removed (GObject *proxy, TfContent *content, TfChannel *self)
{
  g_signal_emit (self, signals[SIGNAL_CONTENT_REMOVED], 0, content);
}

/**
 * tf_channel_new_finish:
 * @object: The #GObject
 * @result: a #GAsyncResult
 * @error: the location of a #GError or %NULL to ignore it
 *
 * Completes the construction of a TfChannel.
 *
 * Returns: a #TfChannel or %NULL if there was an error
 * Since: 0.2.2
 */

TfChannel *
tf_channel_new_finish (GObject *object,
    GAsyncResult *result,
    GError **error)
{
  return (TfChannel *) g_async_initable_new_finish (G_ASYNC_INITABLE (object),
      result, error);
}