/* GStreamer

 * Copyright (C) <2007> Wim Taymans <wim.taymans@gmail.com>

 *

 * This library is free software; you can redistribute it and/or

 * modify it under the terms of the GNU Library General Public

 * License as published by the Free Software Foundation; either

 * version 2 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

 * Library General Public License for more details.

 *

 * You should have received a copy of the GNU Library General Public

 * License along with this library; if not, write to the

 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,

 * Boston, MA 02111-1307, USA.

 */

#ifdef HAVE_CONFIG_H

#include "config.h"

#endif

#include <string.h>

#include <gst/gst.h>

#include <gst/gst-i18n-plugin.h>

#include <gst/pbutils/pbutils.h>

#include "gstplaysink.h"

#ifdef __SYMBIAN32__

#include <glib_global.h>

#endif

GST_DEBUG_CATEGORY_STATIC (gst_play_sink_debug);

#define GST_CAT_DEFAULT gst_play_sink_debug

#define VOLUME_MAX_DOUBLE 10.0

/* holds the common data fields for the audio and video pipelines. We keep them

 * in a structure to more easily have all the info available. */

typedef struct

{

  GstPlaySink *playsink;

  GstPad *sinkpad;

  GstElement *bin;

  gboolean added;

  gboolean activated;

} GstPlayChain;

typedef struct

{

  GstPlayChain chain;

  GstElement *queue;

  GstElement *conv;

  GstElement *resample;

  GstElement *volume;           /* element with the volume property */

  GstElement *mute;             /* element with the mute property */

  GstElement *sink;

} GstPlayAudioChain;

typedef struct

{

  GstPlayChain chain;

  GstElement *queue;

  GstElement *conv;

  GstElement *scale;

  GstElement *sink;

  gboolean async;

} GstPlayVideoChain;

typedef struct

{

  GstPlayChain chain;

  GstElement *queue;

  GstElement *conv;

  GstElement *resample;

  GstPad *blockpad;             /* srcpad of resample, used for switching the vis */

  GstPad *vissinkpad;           /* visualisation sinkpad, */

  GstElement *vis;

  GstPad *vissrcpad;            /* visualisation srcpad, */

  GstPad *srcpad;               /* outgoing srcpad, used to connect to the next

                                 * chain */

} GstPlayVisChain;

#define GST_PLAY_SINK_GET_LOCK(playsink) (((GstPlaySink *)playsink)->lock)

#define GST_PLAY_SINK_LOCK(playsink)     g_mutex_lock (GST_PLAY_SINK_GET_LOCK (playsink))

#define GST_PLAY_SINK_UNLOCK(playsink)   g_mutex_unlock (GST_PLAY_SINK_GET_LOCK (playsink))

struct _GstPlaySink

{

  GstBin bin;

  GMutex *lock;

  GstPlayFlags flags;

  GstPlayChain *audiochain;

  GstPlayChain *videochain;

  GstPlayChain *vischain;

  GstPad *audio_pad;

  gboolean audio_pad_raw;

  GstElement *audio_tee;

  GstPad *audio_tee_sink;

  GstPad *audio_tee_asrc;

  GstPad *audio_tee_vissrc;

  GstPad *video_pad;

  gboolean video_pad_raw;

  GstPad *text_pad;

  /* properties */

  GstElement *audio_sink;

  GstElement *video_sink;

  GstElement *visualisation;

  gfloat volume;

  gboolean mute;

  gchar *font_desc;             /* font description */

  guint connection_speed;       /* connection speed in bits/sec (0 = unknown) */

  /* internal elements */

  GstElement *textoverlay_element;

};

struct _GstPlaySinkClass

{

  GstBinClass parent_class;

};

/* props */

enum

{

  PROP_0,

  PROP_AUDIO_SINK,

  PROP_VIDEO_SINK,

  PROP_VIS_PLUGIN,

  PROP_VOLUME,

  PROP_FRAME,

  PROP_FONT_DESC,

  PROP_LAST

};

/* signals */

enum

{

  LAST_SIGNAL

};

static void gst_play_sink_class_init (GstPlaySinkClass * klass);

static void gst_play_sink_init (GstPlaySink * playsink);

static void gst_play_sink_dispose (GObject * object);

static void gst_play_sink_finalize (GObject * object);

static void gst_play_sink_set_property (GObject * object, guint prop_id,

    const GValue * value, GParamSpec * spec);

static void gst_play_sink_get_property (GObject * object, guint prop_id,

    GValue * value, GParamSpec * spec);

static gboolean gst_play_sink_send_event (GstElement * element,

    GstEvent * event);

static GstStateChangeReturn gst_play_sink_change_state (GstElement * element,

    GstStateChange transition);

static GstElementClass *parent_class;

/* static guint gst_play_sink_signals[LAST_SIGNAL] = { 0 }; */

static const GstElementDetails gst_play_sink_details =

GST_ELEMENT_DETAILS ("Player Sink",

    "Generic/Bin/Player",

    "Autoplug and play media from an uri",

    "Wim Taymans <wim.taymans@gmail.com>");

#ifdef __SYMBIAN32__

EXPORT_C

#endif

GType

gst_play_sink_get_type (void)

{

  static GType gst_play_sink_type = 0;

  if (!gst_play_sink_type) {

    static const GTypeInfo gst_play_sink_info = {

      sizeof (GstPlaySinkClass),

      NULL,

      NULL,

      (GClassInitFunc) gst_play_sink_class_init,

      NULL,

      NULL,

      sizeof (GstPlaySink),

      0,

      (GInstanceInitFunc) gst_play_sink_init,

      NULL

    };

    gst_play_sink_type = g_type_register_static (GST_TYPE_BIN,

        "GstPlaySink", &gst_play_sink_info, 0);

  }

  return gst_play_sink_type;

}

static void

gst_play_sink_class_init (GstPlaySinkClass * klass)

{

  GObjectClass *gobject_klass;

  GstElementClass *gstelement_klass;

  GstBinClass *gstbin_klass;

  gobject_klass = (GObjectClass *) klass;

  gstelement_klass = (GstElementClass *) klass;

  gstbin_klass = (GstBinClass *) klass;

  parent_class = g_type_class_peek_parent (klass);

  gobject_klass->set_property = gst_play_sink_set_property;

  gobject_klass->get_property = gst_play_sink_get_property;

  gobject_klass->dispose = GST_DEBUG_FUNCPTR (gst_play_sink_dispose);

  gobject_klass->finalize = GST_DEBUG_FUNCPTR (gst_play_sink_finalize);

  g_object_class_install_property (gobject_klass, PROP_VIDEO_SINK,

      g_param_spec_object ("video-sink", "Video Sink",

          "the video output element to use (NULL = default sink)",

          GST_TYPE_ELEMENT, G_PARAM_READWRITE));

  g_object_class_install_property (gobject_klass, PROP_AUDIO_SINK,

      g_param_spec_object ("audio-sink", "Audio Sink",

          "the audio output element to use (NULL = default sink)",

          GST_TYPE_ELEMENT, G_PARAM_READWRITE));

  g_object_class_install_property (gobject_klass, PROP_VIS_PLUGIN,

      g_param_spec_object ("vis-plugin", "Vis plugin",

          "the visualization element to use (NULL = none)",

          GST_TYPE_ELEMENT, G_PARAM_READWRITE));

  g_object_class_install_property (gobject_klass, PROP_VOLUME,

      g_param_spec_double ("volume", "volume", "volume",

          0.0, VOLUME_MAX_DOUBLE, 1.0, G_PARAM_READWRITE));

  g_object_class_install_property (gobject_klass, PROP_FRAME,

      gst_param_spec_mini_object ("frame", "Frame",

          "The last video frame (NULL = no video available)",

          GST_TYPE_BUFFER, G_PARAM_READABLE));

  g_object_class_install_property (gobject_klass, PROP_FONT_DESC,

      g_param_spec_string ("subtitle-font-desc",

          "Subtitle font description",

          "Pango font description of font "

          "to be used for subtitle rendering", NULL, G_PARAM_WRITABLE));

  gst_element_class_set_details (gstelement_klass, &gst_play_sink_details);

  gstelement_klass->change_state =

      GST_DEBUG_FUNCPTR (gst_play_sink_change_state);

  gstelement_klass->send_event = GST_DEBUG_FUNCPTR (gst_play_sink_send_event);

  GST_DEBUG_CATEGORY_INIT (gst_play_sink_debug, "playsink", 0, "play bin");

}

static void

gst_play_sink_init (GstPlaySink * playsink)

{

  /* init groups */

  playsink->video_sink = NULL;

  playsink->audio_sink = NULL;

  playsink->visualisation = NULL;

  playsink->textoverlay_element = NULL;

  playsink->volume = 1.0;

  playsink->font_desc = NULL;

  playsink->flags = GST_PLAY_FLAG_SOFT_VOLUME;

  playsink->lock = g_mutex_new ();

}

static void

gst_play_sink_dispose (GObject * object)

{

  GstPlaySink *playsink;

  playsink = GST_PLAY_SINK (object);

  if (playsink->audio_sink != NULL) {

    gst_element_set_state (playsink->audio_sink, GST_STATE_NULL);

    gst_object_unref (playsink->audio_sink);

    playsink->audio_sink = NULL;

  }

  if (playsink->video_sink != NULL) {

    gst_element_set_state (playsink->video_sink, GST_STATE_NULL);

    gst_object_unref (playsink->video_sink);

    playsink->video_sink = NULL;

  }

  if (playsink->visualisation != NULL) {

    gst_element_set_state (playsink->visualisation, GST_STATE_NULL);

    gst_object_unref (playsink->visualisation);

    playsink->visualisation = NULL;

  }

  if (playsink->textoverlay_element != NULL) {

    gst_object_unref (playsink->textoverlay_element);

    playsink->textoverlay_element = NULL;

  }

  g_free (playsink->font_desc);

  playsink->font_desc = NULL;

  G_OBJECT_CLASS (parent_class)->dispose (object);

}

static void

gst_play_sink_finalize (GObject * object)

{

  GstPlaySink *playsink;

  playsink = GST_PLAY_SINK (object);

  g_mutex_free (playsink->lock);

  G_OBJECT_CLASS (parent_class)->finalize (object);

}

#ifdef __SYMBIAN32__

EXPORT_C

#endif

void

gst_play_sink_set_video_sink (GstPlaySink * playsink, GstElement * sink)

{

  GST_OBJECT_LOCK (playsink);

  if (playsink->video_sink)

    gst_object_unref (playsink->video_sink);

  if (sink) {

    gst_object_ref (sink);

    gst_object_sink (sink);

  }

  playsink->video_sink = sink;

  GST_OBJECT_UNLOCK (playsink);

}

#ifdef __SYMBIAN32__

EXPORT_C

#endif

void

gst_play_sink_set_audio_sink (GstPlaySink * playsink, GstElement * sink)

{

  GST_OBJECT_LOCK (playsink);

  if (playsink->audio_sink)

    gst_object_unref (playsink->audio_sink);

  if (sink) {

    gst_object_ref (sink);

    gst_object_sink (sink);

  }

  playsink->audio_sink = sink;

  GST_OBJECT_UNLOCK (playsink);

}

static void

gst_play_sink_vis_unblocked (GstPad * tee_pad, gboolean blocked,

    gpointer user_data)

{

  GstPlaySink *playsink;

  playsink = GST_PLAY_SINK (user_data);

  /* nothing to do here, we need a dummy callback here to make the async call

   * non-blocking. */

  GST_DEBUG_OBJECT (playsink, "vis pad unblocked");

}

static void

gst_play_sink_vis_blocked (GstPad * tee_pad, gboolean blocked,

    gpointer user_data)

{

  GstPlaySink *playsink;

  GstPlayVisChain *chain;

  playsink = GST_PLAY_SINK (user_data);

  GST_PLAY_SINK_LOCK (playsink);

  GST_DEBUG_OBJECT (playsink, "vis pad blocked");

  /* now try to change the plugin in the running vis chain */

  if (!(chain = (GstPlayVisChain *) playsink->vischain))

    goto done;

  /* unlink the old plugin and unghost the pad */

  gst_pad_unlink (chain->blockpad, chain->vissinkpad);

  gst_ghost_pad_set_target (GST_GHOST_PAD_CAST (chain->srcpad), NULL);

  /* set the old plugin to NULL and remove */

  gst_element_set_state (chain->vis, GST_STATE_NULL);

  gst_bin_remove (GST_BIN_CAST (chain->chain.bin), chain->vis);

  /* add new plugin and set state to playing */

  chain->vis = gst_object_ref (playsink->visualisation);

  gst_bin_add (GST_BIN_CAST (chain->chain.bin), chain->vis);

  gst_element_set_state (chain->vis, GST_STATE_PLAYING);

  /* get pads */

  chain->vissinkpad = gst_element_get_pad (chain->vis, "sink");

  chain->vissrcpad = gst_element_get_pad (chain->vis, "src");

  /* link pads */

  gst_pad_link (chain->blockpad, chain->vissinkpad);

  gst_ghost_pad_set_target (GST_GHOST_PAD_CAST (chain->srcpad),

      chain->vissrcpad);

done:

  /* Unblock the pad */

  gst_pad_set_blocked_async (tee_pad, FALSE, gst_play_sink_vis_unblocked,

      playsink);

  GST_PLAY_SINK_UNLOCK (playsink);

}

#ifdef __SYMBIAN32__

EXPORT_C

#endif

void

gst_play_sink_set_vis_plugin (GstPlaySink * playsink, GstElement * vis)

{

  GstPlayVisChain *chain;

  GST_PLAY_SINK_LOCK (playsink);

  /* first store the new vis */

  if (playsink->visualisation)

    gst_object_unref (playsink->visualisation);

  playsink->visualisation = gst_object_ref (vis);

  /* now try to change the plugin in the running vis chain, if we have no chain,

   * we don't bother, any future vis chain will be created with the new vis

   * plugin. */

  if (!(chain = (GstPlayVisChain *) playsink->vischain))

    goto done;

  /* block the pad, the next time the callback is called we can change the

   * visualisation. It's possible that this never happens or that the pad was

   * already blocked. */

  GST_DEBUG_OBJECT (playsink, "blocking vis pad");

  gst_pad_set_blocked_async (chain->blockpad, TRUE, gst_play_sink_vis_blocked,

      playsink);

done:

  GST_PLAY_SINK_UNLOCK (playsink);

  return;

}

#ifdef __SYMBIAN32__

EXPORT_C

#endif

void

gst_play_sink_set_volume (GstPlaySink * playsink, gdouble volume)

{

  GstPlayAudioChain *chain;

  GST_PLAY_SINK_LOCK (playsink);

  playsink->volume = volume;

  chain = (GstPlayAudioChain *) playsink->audiochain;

  if (chain && chain->volume) {

    g_object_set (chain->volume, "volume", volume, NULL);

  }

  GST_PLAY_SINK_UNLOCK (playsink);

}

#ifdef __SYMBIAN32__

EXPORT_C

#endif

gdouble

gst_play_sink_get_volume (GstPlaySink * playsink)

{

  gdouble result;

  GstPlayAudioChain *chain;

  GST_PLAY_SINK_LOCK (playsink);

  chain = (GstPlayAudioChain *) playsink->audiochain;

  if (chain && chain->volume) {

    g_object_get (chain->volume, "volume", &result, NULL);

    playsink->volume = result;

  } else {

    result = playsink->volume;

  }

  GST_PLAY_SINK_UNLOCK (playsink);

  return result;

}

#ifdef __SYMBIAN32__

EXPORT_C

#endif

void

gst_play_sink_set_mute (GstPlaySink * playsink, gboolean mute)

{

  GstPlayAudioChain *chain;

  GST_PLAY_SINK_LOCK (playsink);

  playsink->mute = mute;

  chain = (GstPlayAudioChain *) playsink->audiochain;

  if (chain && chain->mute) {

    g_object_set (chain->mute, "mute", mute, NULL);

  }

  GST_PLAY_SINK_UNLOCK (playsink);

}

#ifdef __SYMBIAN32__

EXPORT_C

#endif

gboolean

gst_play_sink_get_mute (GstPlaySink * playsink)

{

  gboolean result;

  GstPlayAudioChain *chain;

  GST_PLAY_SINK_LOCK (playsink);

  chain = (GstPlayAudioChain *) playsink->audiochain;

  if (chain && chain->mute) {

    g_object_get (chain->mute, "mute", &result, NULL);

    playsink->mute = result;

  } else {

    result = playsink->mute;

  }

  GST_PLAY_SINK_UNLOCK (playsink);

  return result;

}

static void