/*

 * media-factory.c - Source for GabbleMediaFactory

 * Copyright (C) 2006 Collabora Ltd.

 *

 * 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

 */

#include <stdlib.h>

#include <string.h>

#include <time.h>

#include <glib.h>

#include <dbus/dbus-glib.h>

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

#include "loudmouth/loudmouth.h"

#include "debug.h"

#include "gabble-connection.h"

#include "gabble-media-channel.h"

#include "handles.h"

#include "media-factory.h"

#include "namespaces.h"

#include "telepathy-interfaces.h"

#include "text-mixin.h"

#include "tp-channel-factory-iface.h"

#include "util.h"

static void gabble_media_factory_iface_init (gpointer g_iface, gpointer iface_data);

static LmHandlerResult media_factory_jingle_cb (LmMessageHandler*, LmConnection*, LmMessage*, gpointer);

#ifndef EMULATOR

G_DEFINE_TYPE_WITH_CODE (GabbleMediaFactory, gabble_media_factory, G_TYPE_OBJECT,

    G_IMPLEMENT_INTERFACE (TP_TYPE_CHANNEL_FACTORY_IFACE, gabble_media_factory_iface_init));

#endif

#ifdef EMULATOR

#include "libgabble_wsd_solution.h"

    GET_STATIC_VAR_FROM_TLS(gabble_media_factory_parent_class,media_factory,gpointer)

	#define gabble_media_factory_parent_class (*GET_WSD_VAR_NAME(gabble_media_factory_parent_class,media_factory,s)())

	GET_STATIC_VAR_FROM_TLS(g_define_type_id,media_factory,GType)

	#define g_define_type_id (*GET_WSD_VAR_NAME(g_define_type_id,media_factory,s)())

static void gabble_media_factory_init (GabbleMediaFactory *self); 

static void gabble_media_factory_class_init (GabbleMediaFactoryClass *klass); 

static void gabble_media_factory_class_intern_init (gpointer klass) 

{ 

gabble_media_factory_parent_class = g_type_class_peek_parent (klass);

 gabble_media_factory_class_init ((GabbleMediaFactoryClass*) klass);

}

 EXPORT_C GType gabble_media_factory_get_type (void)

 {

 if ((g_define_type_id == 0)) { static const GTypeInfo g_define_type_info = { sizeof (GabbleMediaFactoryClass), (GBaseInitFunc) ((void *)0), (GBaseFinalizeFunc) ((void *)0), (GClassInitFunc) gabble_media_factory_class_intern_init, (GClassFinalizeFunc) ((void *)0), ((void *)0), sizeof (GabbleMediaFactory), 0, (GInstanceInitFunc) gabble_media_factory_init, ((void *)0) }; g_define_type_id = g_type_register_static ( ((GType) ((20) << (2))), g_intern_static_string ("GabbleMediaFactory"), &g_define_type_info, (GTypeFlags) 0); { { static const GInterfaceInfo g_implement_interface_info = { (GInterfaceInitFunc) gabble_media_factory_iface_init }; g_type_add_interface_static (g_define_type_id, tp_channel_factory_iface_get_type(), &g_implement_interface_info); } ; } } return g_define_type_id; }    ;

#endif

#define DBUS_API_SUBJECT_TO_CHANGE

#define DEBUG_FLAG GABBLE_DEBUG_MEDIA

#ifdef DEBUG_FLAG

//#define DEBUG(format, ...)

#define DEBUGGING 0

#define NODE_DEBUG(n, s)

#endif /* DEBUG_FLAG */

/* properties */

enum

{

  PROP_CONNECTION = 1,

  LAST_PROPERTY

};

typedef struct _GabbleMediaFactoryPrivate GabbleMediaFactoryPrivate;

struct _GabbleMediaFactoryPrivate

{

  GabbleConnection *conn;

  LmMessageHandler *jingle_cb;

  GPtrArray *channels;

  guint channel_index;

  GHashTable *session_chans;

  gboolean dispose_has_run;

};

#define GABBLE_MEDIA_FACTORY_GET_PRIVATE(o)    (G_TYPE_INSTANCE_GET_PRIVATE ((o), GABBLE_TYPE_MEDIA_FACTORY, GabbleMediaFactoryPrivate))

static GObject *gabble_media_factory_constructor (GType type, guint n_props, GObjectConstructParam *props);

static void

gabble_media_factory_init (GabbleMediaFactory *fac)

{

  GabbleMediaFactoryPrivate *priv = GABBLE_MEDIA_FACTORY_GET_PRIVATE (fac);

  priv->channels = g_ptr_array_sized_new (1);

  priv->channel_index = 0;

  priv->jingle_cb = NULL;

  priv->conn = NULL;

  priv->dispose_has_run = FALSE;

  priv->session_chans = g_hash_table_new_full (g_str_hash, g_str_equal,

                                               g_free, NULL);

}

static GObject *

gabble_media_factory_constructor (GType type, guint n_props,

                               GObjectConstructParam *props)

{

  GObject *obj;

  GabbleMediaFactoryPrivate *priv;

  obj = G_OBJECT_CLASS (gabble_media_factory_parent_class)->

           constructor (type, n_props, props);

  priv = GABBLE_MEDIA_FACTORY_GET_PRIVATE (obj);

  return obj;

}

static void

gabble_media_factory_dispose (GObject *object)

{

  GabbleMediaFactory *fac = GABBLE_MEDIA_FACTORY (object);

  GabbleMediaFactoryPrivate *priv = GABBLE_MEDIA_FACTORY_GET_PRIVATE (fac);

  if (priv->dispose_has_run)

    return;

  gabble_debug (DEBUG_FLAG, "dispose called");

  priv->dispose_has_run = TRUE;

  tp_channel_factory_iface_close_all (TP_CHANNEL_FACTORY_IFACE (object));

  g_assert (priv->channels == NULL);

  if (priv->session_chans)

    {

      g_assert (g_hash_table_size (priv->session_chans) == 0);

      g_hash_table_destroy (priv->session_chans);

      priv->session_chans = NULL;

    }

  if (G_OBJECT_CLASS (gabble_media_factory_parent_class)->dispose)

    G_OBJECT_CLASS (gabble_media_factory_parent_class)->dispose (object);

}

static void

gabble_media_factory_get_property (GObject    *object,

                                   guint       property_id,

                                   GValue     *value,

                                   GParamSpec *pspec)

{

  GabbleMediaFactory *fac = GABBLE_MEDIA_FACTORY (object);

  GabbleMediaFactoryPrivate *priv = GABBLE_MEDIA_FACTORY_GET_PRIVATE (fac);

  switch (property_id) {

    case PROP_CONNECTION:

      g_value_set_object (value, priv->conn);

      break;

    default:

      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);

      break;

  }

}

static void

gabble_media_factory_set_property (GObject      *object,

                                   guint         property_id,

                                   const GValue *value,

                                   GParamSpec   *pspec)

{

  GabbleMediaFactory *fac = GABBLE_MEDIA_FACTORY (object);

  GabbleMediaFactoryPrivate *priv = GABBLE_MEDIA_FACTORY_GET_PRIVATE (fac);

  switch (property_id) {

    case PROP_CONNECTION:

      priv->conn = g_value_get_object (value);

      break;

    default:

      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);

      break;

  }

}

static void

gabble_media_factory_class_init (GabbleMediaFactoryClass *gabble_media_factory_class)

{

  GObjectClass *object_class = G_OBJECT_CLASS (gabble_media_factory_class);

  GParamSpec *param_spec;

  g_type_class_add_private (gabble_media_factory_class, sizeof (GabbleMediaFactoryPrivate));

  object_class->constructor = gabble_media_factory_constructor;

  object_class->dispose = gabble_media_factory_dispose;

  object_class->get_property = gabble_media_factory_get_property;

  object_class->set_property = gabble_media_factory_set_property;

  param_spec = g_param_spec_object ("connection", "GabbleConnection object",

                                    "Gabble connection object that owns this "

                                    "media channel factory object.",

                                    GABBLE_TYPE_CONNECTION,

                                    G_PARAM_CONSTRUCT_ONLY |

                                    G_PARAM_READWRITE |

                                    G_PARAM_STATIC_NICK |

                                    G_PARAM_STATIC_BLURB);

  g_object_class_install_property (object_class, PROP_CONNECTION, param_spec);

}

static gboolean _gabble_media_factory_sid_in_use (GabbleMediaFactory *fac, const gchar *sid);

static GabbleMediaChannel *new_media_channel (GabbleMediaFactory *fac, GabbleHandle handle);

static void media_channel_closed_cb (GabbleMediaChannel *chan, gpointer user_data);

/**

 * media_factory_jingle_cb

 *

 * Called by loudmouth when we get an incoming <iq>. This handler

 * is concerned only with jingle session queries, and allows other

 * handlers to be called for other queries.

 */

static LmHandlerResult

media_factory_jingle_cb (LmMessageHandler *handler,

                         LmConnection *lmconn,

                         LmMessage *message,

                         gpointer user_data)

{

  GabbleMediaFactory *fac = GABBLE_MEDIA_FACTORY (user_data);

  GabbleMediaFactoryPrivate *priv = GABBLE_MEDIA_FACTORY_GET_PRIVATE (fac);

  LmMessageNode *iq_node, *session_node;

  const gchar *from, *id, *action, *sid;

  gchar *resource;

  GabbleHandle handle;

  GabbleMediaChannel *chan = NULL;

  gboolean chan_is_new = FALSE;

  GError *error = NULL;

  g_assert (lmconn == priv->conn->lmconn);

  /* all jingle actions are sets */

  if (LM_MESSAGE_SUB_TYPE_SET != lm_message_get_sub_type (message))

    return LM_HANDLER_RESULT_ALLOW_MORE_HANDLERS;

  /* is it for us? */

  iq_node = lm_message_get_node (message);

  session_node = lm_message_node_get_child_with_namespace (message->node,

      "jingle", NS_JINGLE);

  if (session_node != NULL)

    {

      action = lm_message_node_get_attribute (session_node, "action");

    }

  else

    {

      session_node = lm_message_node_get_child_with_namespace (iq_node,

          "session", NS_GOOGLE_SESSION);

      if (session_node == NULL)

        return LM_HANDLER_RESULT_ALLOW_MORE_HANDLERS;

      action = lm_message_node_get_attribute (session_node, "type");

    }

  if (action == NULL)

    {

      NODE_DEBUG (iq_node, "session action not found");

      goto BAD_REQUEST;

    }

  from = lm_message_node_get_attribute (iq_node, "from");

  if (from == NULL)

    {

      NODE_DEBUG (iq_node, "'from' attribute not found");

      goto BAD_REQUEST;

    }

  handle = gabble_handle_for_contact (priv->conn->handles, from, FALSE);

  if (handle == 0)

    {

      NODE_DEBUG (iq_node, "unable to get handle for sender");

      goto BAD_REQUEST;

    }

  id = lm_message_node_get_attribute (iq_node, "id");

  if (id == NULL)

    {

      NODE_DEBUG (iq_node, "'id' attribute not found");

      goto BAD_REQUEST;

    }

  /* does the session exist? */

  sid = lm_message_node_get_attribute (session_node, "sid");

  if (sid == NULL)

    sid = lm_message_node_get_attribute (session_node, "id");

  if (sid == NULL)

    {

      NODE_DEBUG (iq_node, "unable to get session id");

      goto BAD_REQUEST;

    }

  if (_gabble_media_factory_sid_in_use (fac, sid))

    {

      /* if it's media session, we should have it in here */

      chan = g_hash_table_lookup (priv->session_chans, sid);

    }

  /* it's a new session */

  if (chan == NULL)

    {

      /* if the session is unknown, the only allowed action is "initiate" */

      if (g_strdiff (action, "initiate") &&

          g_strdiff (action, "session-initiate"))

        {

          NODE_DEBUG (iq_node,

              "action is not \"initiate\" or \"session-initiate\", rejecting");

          goto BAD_REQUEST;

        }

      gabble_debug (DEBUG_FLAG, "creating media channel");

      chan = new_media_channel (fac, handle);

      chan_is_new = TRUE;

    }

  g_assert (chan != NULL);

  gabble_debug (DEBUG_FLAG, "dispatching to session %s", sid);

  g_object_ref (chan);

  gabble_decode_jid (from, NULL, NULL, &resource);

  if (_gabble_media_channel_dispatch_session_action (chan, handle, resource,

        sid, message, session_node, action, &error))

    {

      if (chan_is_new)

        g_signal_emit_by_name (fac, "new-channel", chan);

    }

  else

    {

      if (chan_is_new)

        gabble_media_channel_close (chan, NULL);

      g_assert (error != NULL);

      _gabble_connection_send_iq_error (priv->conn, message, error->code,

          error->message);

    }

  g_object_unref (chan);

  g_free (resource);

  return LM_HANDLER_RESULT_REMOVE_MESSAGE;

BAD_REQUEST:

  _gabble_connection_send_iq_error (

    priv->conn, message, XMPP_ERROR_BAD_REQUEST, NULL);

  return LM_HANDLER_RESULT_REMOVE_MESSAGE;

}

static const gchar *

_gabble_media_factory_get_unique_sid (GabbleMediaFactory *fac)

{

  GabbleMediaFactoryPrivate *priv = GABBLE_MEDIA_FACTORY_GET_PRIVATE (fac);

  guint32 val;

  gchar *sid = NULL;

  gboolean unique = FALSE;

  while (!unique)

    {

      val = g_random_int_range (1000000, G_MAXINT);

      g_free (sid);

      sid = g_strdup_printf ("%u", val);

      unique = !_gabble_media_factory_sid_in_use (fac, sid);

    }

  g_hash_table_insert (priv->session_chans, sid, NULL);

  return sid;

}

static gboolean

_gabble_media_factory_sid_in_use (GabbleMediaFactory *fac, const gchar *sid)

{

  GabbleMediaFactoryPrivate *priv = GABBLE_MEDIA_FACTORY_GET_PRIVATE (fac);

  gpointer key, value;

  return g_hash_table_lookup_extended (priv->session_chans, sid, &key, &value);

}

const gchar *

_gabble_media_factory_allocate_sid (GabbleMediaFactory *fac, GabbleMediaChannel *chan)

{

  const gchar *sid = _gabble_media_factory_get_unique_sid (fac);

  g_return_val_if_fail (sid, NULL);

  return _gabble_media_factory_register_sid (fac, sid, chan);

}

const gchar *

_gabble_media_factory_register_sid (GabbleMediaFactory *fac,

                                    const gchar *sid,

                                    GabbleMediaChannel *chan)

{

  GabbleMediaFactoryPrivate *priv = GABBLE_MEDIA_FACTORY_GET_PRIVATE (fac);

  gchar *sid_copy = g_strdup (sid);

  g_hash_table_replace (priv->session_chans, sid_copy, chan);

  return sid_copy;

}

void

_gabble_media_factory_free_sid (GabbleMediaFactory *fac, const gchar *sid)

{

  GabbleMediaFactoryPrivate *priv = GABBLE_MEDIA_FACTORY_GET_PRIVATE (fac);

  if (g_hash_table_lookup (priv->session_chans, sid))

    {

      g_hash_table_remove (priv->session_chans, sid);

    }

}

static gboolean

_remove_sid_mapping (gpointer key, gpointer value, gpointer user_data)

{

  GabbleMediaChannel *chan = GABBLE_MEDIA_CHANNEL (value);

  GabbleMediaChannel *target_chan = GABBLE_MEDIA_CHANNEL (user_data);

  if (chan == target_chan) return TRUE;

  return FALSE;

}

/**

 * media_channel_closed_cb:

 *

 * Signal callback for when a media channel is closed. Removes the references

 * that #GabbleMediaFactory holds to them. Also removes all the sessions for

 * the closed channel.

 */

static void

media_channel_closed_cb (GabbleMediaChannel *chan, gpointer user_data)

{

  GabbleMediaFactory *fac = GABBLE_MEDIA_FACTORY (user_data);

  GabbleMediaFactoryPrivate *priv = GABBLE_MEDIA_FACTORY_GET_PRIVATE (fac);

  if (priv->channels)

    {

      gabble_debug (DEBUG_FLAG, "removing media channel %p with ref count %d",

          chan, G_OBJECT (chan)->ref_count);

      g_ptr_array_remove (priv->channels, chan);

      g_object_unref (chan);

    }

  if (priv->session_chans)

    {

      g_hash_table_foreach_remove (priv->session_chans, _remove_sid_mapping, chan);

    }

}

/**

 * new_media_channel

 *

 * Creates a new empty GabbleMediaChannel.

 */

static GabbleMediaChannel *

new_media_channel (GabbleMediaFactory *fac, GabbleHandle creator)

{

  GabbleMediaFactoryPrivate *priv;

  GabbleMediaChannel *chan;

  gchar *object_path;

  g_assert (GABBLE_IS_MEDIA_FACTORY (fac));

  priv = GABBLE_MEDIA_FACTORY_GET_PRIVATE (fac);

  object_path = g_strdup_printf ("%s/MediaChannel%u", priv->conn->object_path,

                                 priv->channel_index);

  priv->channel_index += 1;

  chan = g_object_new (GABBLE_TYPE_MEDIA_CHANNEL,

                       "connection", priv->conn,

                       "factory", fac,

                       "object-path", object_path,

                       "creator", creator,

                       NULL);

  gabble_debug (DEBUG_FLAG, "object path %s", object_path);

  g_signal_connect (chan, "closed", (GCallback) media_channel_closed_cb, fac);

  g_ptr_array_add (priv->channels, chan);

  g_free (object_path);

  return chan;

}

static void

gabble_media_factory_iface_close_all (TpChannelFactoryIface *iface)

{

  GabbleMediaFactory *fac = GABBLE_MEDIA_FACTORY (iface);

  GabbleMediaFactoryPrivate *priv = GABBLE_MEDIA_FACTORY_GET_PRIVATE (fac);

  guint i;

  gabble_debug (DEBUG_FLAG, "closing channels");