/**

  * GMyth Library

  *

  * @file gmyth/mmyth_tvplayer.c

  * 

  * @brief <p> This component provides playback of the remote A/V using

  * GStreamer.

  * 

  * Copyright (C) 2006 INdT - Instituto Nokia de Tecnologia.

  * @author Hallyson Luiz de Morais Melo <hallyson.melo@indt.org.br>

  *

     *//*

     * 

     * This program 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 of the License, or

     * (at your option) any later version.

     *

     * This program 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 General Public License for more details.

     *

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

     * along with this program; if not, write to the Free Software

     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

     */

 #include "mmyth_tvplayer.h"

 #include <gdk/gdkx.h>

 #include <gmyth/gmyth_remote_util.h>

 #define MYTHTV_VERSION_DEFAULT	30

 typedef struct _GstPlayerWindowStateChange {

     GstElement     *play;

     GstState        old_state,

                     new_state;

     MMythTVPlayer  *tvplayer;

 } GstPlayerWindowStateChange;

 typedef struct _GstPlayerWindowTagFound {

     GstElement     *play;

     GstTagList     *taglist;

     MMythTVPlayer  *tvplayer;

 } GstPlayerWindowTagFound;

 /*

  * static gboolean idle_state (gpointer data); 

  */

 static gboolean bus_call(GstBus * bus, GstMessage * msg, gpointer data);

 static void     mmyth_tvplayer_class_init(MMythTVPlayerClass * klass);

 static void     mmyth_tvplayer_init(MMythTVPlayer * object);

 static void     mmyth_tvplayer_dispose(GObject * object);

 static void     mmyth_tvplayer_finalize(GObject * object);

 G_DEFINE_TYPE(MMythTVPlayer, mmyth_tvplayer, G_TYPE_OBJECT)

     static gboolean mmyth_tvplayer_create_pipeline(MMythTVPlayer *

                                                    tvplayer);

     static void     new_pad_cb(GstElement * element, GstPad * pad,

                                gpointer data);

     static gboolean expose_cb(GtkWidget * widget,

                               GdkEventExpose * event, gpointer user_data);

     static void

                     mmyth_tvplayer_class_init(MMythTVPlayerClass * klass)

 {

     GObjectClass   *gobject_class;

     gobject_class = (GObjectClass *) klass;

     gobject_class->dispose = mmyth_tvplayer_dispose;

     gobject_class->finalize = mmyth_tvplayer_finalize;

 }

 static void

 new_pad_cb(GstElement * element, GstPad * pad, gpointer data)

 {

     MMythTVPlayer  *tvplayer = MMYTH_TVPLAYER(data);

     GstPadLinkReturn ret;

     char           *s;

     s = gst_caps_to_string(pad->caps);

     if (s[0] == 'a') {

         ret =

             gst_pad_link(pad,

                          gst_element_get_pad(tvplayer->audioqueue1,

                                              "sink"));

     } else {

         ret =

             gst_pad_link(pad,

                          gst_element_get_pad(tvplayer->videoqueue1,

                                              "sink"));

     }

     g_free(s);

 }

 static          gboolean

 expose_cb(GtkWidget * widget, GdkEventExpose * event, gpointer user_data)

 {

     MMythTVPlayer  *tvplayer = MMYTH_TVPLAYER(user_data);

     if (tvplayer && tvplayer->videow) {

         gst_x_overlay_set_xwindow_id(GST_X_OVERLAY

                                      (tvplayer->gst_videosink),

                                      GDK_WINDOW_XWINDOW(widget->window));

         return TRUE;

     }

     g_warning("MMythTVPlayer expose called before setting video window\n");

     return FALSE;

 }

 static void

 mmyth_tvplayer_init(MMythTVPlayer * tvplayer)

 {

     tvplayer->gst_pipeline = NULL;

     tvplayer->gst_source = NULL;

     tvplayer->gst_videodec = NULL;

     tvplayer->gst_videosink = NULL;

     tvplayer->gst_videocolortrs = NULL;

     tvplayer->videoqueue1 = NULL;

     tvplayer->videoqueue2 = NULL;

     tvplayer->audioqueue1 = NULL;

     tvplayer->audioqueue2 = NULL;

     /*

      * GTKWidget for rendering the video 

      */

     tvplayer->videow = NULL;

     tvplayer->expose_handler = 0;

     tvplayer->backend_hostname = NULL;

     tvplayer->backend_port = 0;

     tvplayer->local_hostname = NULL;

     tvplayer->recorder = NULL;

     tvplayer->tvchain = NULL;

     tvplayer->proginfo = NULL;

 }

 static void

 mmyth_tvplayer_dispose(GObject * object)

 {

     G_OBJECT_CLASS(mmyth_tvplayer_parent_class)->dispose(object);

 }

 static void

 mmyth_tvplayer_finalize(GObject * object)

 {

     g_signal_handlers_destroy(object);

     MMythTVPlayer  *tvplayer = MMYTH_TVPLAYER(object);

     g_debug("[%s] Finalizing tvplayer", __FUNCTION__);

     if (tvplayer->videow != NULL) {

         if (g_signal_handler_is_connected(tvplayer->videow,

                                           tvplayer->expose_handler)) {

             g_signal_handler_disconnect(tvplayer->videow,

                                         tvplayer->expose_handler);

         }

         g_object_unref(tvplayer->videow);

     }

     if (tvplayer->recorder != NULL)

         g_object_unref(tvplayer->recorder);

     if (tvplayer->tvchain != NULL)

         g_object_unref(tvplayer->tvchain);

     if (tvplayer->proginfo != NULL)

         g_object_unref(tvplayer->proginfo);

     // Release Gstreamer elements

     if (tvplayer->gst_pipeline != NULL)

         g_object_unref(tvplayer->gst_pipeline);

     if (tvplayer->gst_source != NULL)

         g_object_unref(tvplayer->gst_source);

     if (tvplayer->gst_videodec != NULL)

         g_object_unref(tvplayer->gst_videodec);

     if (tvplayer->gst_videocolortrs != NULL)

         g_object_unref(tvplayer->gst_videocolortrs);

     if (tvplayer->gst_videosink != NULL)

         g_object_unref(tvplayer->gst_videosink);

     if (tvplayer->videoqueue1 != NULL)

         g_object_unref(tvplayer->videoqueue1);

     if (tvplayer->videoqueue2 != NULL)

         g_object_unref(tvplayer->videoqueue2);

     if (tvplayer->audioqueue1 != NULL)

         g_object_unref(tvplayer->audioqueue1);

     if (tvplayer->audioqueue2 != NULL)

         g_object_unref(tvplayer->audioqueue2);

     G_OBJECT_CLASS(mmyth_tvplayer_parent_class)->finalize(object);

 }

 /** Creates a new instance of MMythTVPlayer. 

  * 

  * @return a new instance of MMythTVPlayer.

  */

 MMythTVPlayer  *

 mmyth_tvplayer_new()

 {

     MMythTVPlayer  *tvplayer =

         MMYTH_TVPLAYER(g_object_new(MMYTH_TVPLAYER_TYPE, NULL));

     return tvplayer;

 }

 /** Initializes the tv player.

  *

  * @param tvplayer the object instance.

  * @return gboolean TRUE if the pipeline was created 

  * successfully, FALSE otherwise.

  */

 gboolean

 mmyth_tvplayer_initialize(MMythTVPlayer * tvplayer,

                           GMythBackendInfo * backend_info)

 {

     tvplayer->backend_info = backend_info;

     if (!mmyth_tvplayer_create_pipeline(tvplayer)) {

         g_warning

             ("[%s] Error while creating pipeline. TV Player not initialized",

              __FUNCTION__);

         return FALSE;

     } else {

         g_debug("[%s] GStreamer pipeline created", __FUNCTION__);

     }

     return TRUE;

 }

 /** Creates the GStreamer pipeline used by the player.

  *

  * @param tvplayer the object instance.

  * @return gboolean TRUE if the pipeline was created 

  * successfully, FALSE otherwise.

  */

 static          gboolean

 mmyth_tvplayer_create_pipeline(MMythTVPlayer * tvplayer)

 {

     GstElement     *pipeline;

     GstElement     *source,

                    *parser;

     GstElement     *videodec,

                    *videosink;

     GstElement     *videocolortrs;

 #ifndef MAEMO_PLATFORM

     GstElement     *audiodec,

                    *audioconv,

                    *audioqueue2;

 #endif

     GstElement     *audiosink;

     GstElement     *videoqueue1,

                    *videoqueue2,

                    *audioqueue1;

     g_debug("MMythTVPlayer: Setting the Gstreamer pipeline\n");

     pipeline = gst_pipeline_new("video-player");

     source = gst_element_factory_make("mythtvsrc", "myth-source");

     parser = gst_element_factory_make("nuvdemux", "nuv-demux");

     /*

      * Gstreamer Video elements 

      */

     videoqueue1 = gst_element_factory_make("queue", "video-queue1");

     videodec = gst_element_factory_make("ffdec_mpeg4", "video-decoder");

     videoqueue2 = gst_element_factory_make("queue", "video-queue2");

     videocolortrs =

         gst_element_factory_make("ffmpegcolorspace",

                                  "image-color-transforms");

 #ifdef MAEMO_PLATFORM

     videosink = gst_element_factory_make("sdlvideosink", "image-output");

 #else

     videosink = gst_element_factory_make("xvimagesink", "image-output");

 #endif

     /*

      * Gstreamer Audio elements 

      */

     audioqueue1 = gst_element_factory_make("queue", "audio-queue1");

 #ifdef MAEMO_PLATFORM

     audiosink = gst_element_factory_make("dspmp3sink", "audio-output");

 #else

     audioqueue2 = gst_element_factory_make("queue", "audio-queue2");

     audiodec = gst_element_factory_make("mad", "audio-decoder");

     audioconv =

         gst_element_factory_make("audioconvert", "audio-converter");

     audiosink = gst_element_factory_make("alsasink", "audio-output");

 #endif

     if (!(pipeline && source && parser && videodec && videosink) ||

         !(videoqueue1 && videoqueue2 && audioqueue1 && audiosink)) {

         /*

          * FIXME: hanlde the error correctly 

          */

         /*

          * video_alignment is not being created (below) and is causing

          * problems to the ui 

          */

         tvplayer->gst_pipeline = NULL;

         tvplayer->gst_videodec = NULL;

         tvplayer->gst_videosink = NULL;

         tvplayer->gst_videocolortrs = NULL;

         g_warning("GstElement creation error!\n");

         return FALSE;

     }

 #ifndef MAEMO_PLATFORM

     if (!(audiodec && audioconv)) {

         g_warning("GstElement for audio stream creation error!");

         return FALSE;

     }

 #endif

     tvplayer->gst_pipeline = pipeline;

     tvplayer->gst_source = source;

     tvplayer->gst_videodec = videodec;

     tvplayer->gst_videosink = videosink;

     tvplayer->gst_videocolortrs = videocolortrs;

     g_object_ref(tvplayer->gst_pipeline);

     g_object_ref(tvplayer->gst_source);

     g_object_ref(tvplayer->gst_videodec);

     g_object_ref(tvplayer->gst_videosink);

     g_object_ref(tvplayer->gst_videocolortrs);

     tvplayer->videoqueue1 = videoqueue1;

     tvplayer->videoqueue2 = videoqueue2;

     tvplayer->audioqueue1 = audioqueue1;

     g_object_ref(tvplayer->videoqueue1);

     g_object_ref(tvplayer->videoqueue2);

     g_object_ref(tvplayer->audioqueue1);

 #ifndef MAEMO_PLATFORM

     tvplayer->audioqueue2 = audioqueue2;

     g_object_ref(tvplayer->audioqueue2);

 #endif

     // g_object_set (G_OBJECT (videosink), "sync", TRUE, NULL);

     g_object_set(G_OBJECT(audiosink), "sync", FALSE, NULL);

     gst_bus_add_watch(gst_pipeline_get_bus

                       (GST_PIPELINE(tvplayer->gst_pipeline)), bus_call,

                       tvplayer);

     gst_bin_add_many(GST_BIN(pipeline), source, parser, videoqueue1,

                      videodec, videoqueue2, videocolortrs, videosink,

                      NULL);

 #ifndef MAEMO_PLATFORM

     gst_bin_add_many(GST_BIN(pipeline), audioqueue1, audiodec, audioconv,

                      audioqueue2, audiosink, NULL);

 #else

     gst_bin_add_many(GST_BIN(pipeline), audioqueue1, audiosink, NULL);

 #endif

     {

         // GstCaps *rtpcaps = gst_caps_new_simple ("application/x-rtp",

         // NULL);

         // gst_element_link_filtered(source, parser, rtpcaps);

     }

     gst_element_link(source, parser);

     gst_element_link_many(videoqueue1, videodec, videoqueue2,

                           videocolortrs, videosink, NULL);

 #ifndef MAEMO_PLATFORM

     gst_element_link_many(videosink, audioqueue1, audiodec, audioconv,

                           audioqueue2, audiosink, NULL);

 #else

     gst_element_link_many(videosink, audioqueue1, audiosink, NULL);

 #endif

     g_signal_connect(parser, "pad-added", G_CALLBACK(new_pad_cb),

                      tvplayer);

     return TRUE;

 }

 /** Configures the backend and the tv player 

  * for playing the recorded content A/V.

  *

  * FIXME: Change filename to program info or other structure about the recorded

  *

  * @param tvplayer the object instance.

  * @param filename the file uri of the recorded content to be played.

  * @return TRUE if successfull, FALSE if any error happens.

  */

 gboolean

 mmyth_tvplayer_record_setup(MMythTVPlayer * tvplayer,

                             const gchar * filename)

 {

     // FIXME: we should receive the uri instead of filename

     const gchar    *hostname =

         gmyth_backend_info_get_hostname(tvplayer->backend_info);

     const gint      port =

         gmyth_backend_info_get_port(tvplayer->backend_info);

     GString        *fullpath = g_string_new("myth://");

     g_string_append_printf(fullpath, "%s:%d/%s", hostname, port, filename);

     tvplayer->is_livetv = FALSE;

     g_debug("[%s] Setting record uri to gstreamer pipeline to %s",

             __FUNCTION__, fullpath->str);

     g_object_set(G_OBJECT(tvplayer->gst_source), "location",

                  fullpath->str, NULL);

     return TRUE;

 }

 /** Configures the backend and the tv player 

  * for playing the live tv.

  *

  * @param tvplayer the object instance.

  * @return TRUE if successfull, FALSE if any error happens.

  */

 gboolean

 mmyth_tvplayer_livetv_setup(MMythTVPlayer * tvplayer)

 {

     gboolean        res = TRUE;

     tvplayer->livetv = gmyth_livetv_new();

     if (!gmyth_livetv_setup(tvplayer->livetv, tvplayer->backend_info))

         goto error;

     return res;

   error:

     res = FALSE;

     if (tvplayer->livetv != NULL) {

         g_object_unref(tvplayer->livetv);

     }

     if (tvplayer->local_hostname != NULL) {

         g_string_free(tvplayer->local_hostname, TRUE);

     }

     if (tvplayer->recorder != NULL) {

         g_object_unref(tvplayer->recorder);

         tvplayer->recorder = NULL;

     }

     if (tvplayer->tvchain != NULL) {

         g_object_unref(tvplayer->tvchain);

         tvplayer->tvchain = NULL;

     }

     if (tvplayer->proginfo != NULL) {

         g_object_unref(tvplayer->proginfo);

         tvplayer->proginfo = NULL;

     }

     return res;

 }

 /** Sets the GTK video widget for the tv player. 

  *

  * @param tvplayer the object instance.

  * @param videow the GTK video window.

  * @return TRUE if successfull, FALSE if any error happens.

  */

 gboolean

 mmyth_tvplayer_set_widget(MMythTVPlayer * tvplayer, GtkWidget * videow)

 {

     tvplayer->videow = videow;

     g_object_ref(videow);

     g_debug("[%s] Setting widget for tv player render", __FUNCTION__);

     tvplayer->expose_handler =

         g_signal_connect(tvplayer->videow, "expose-event",

                          G_CALLBACK(expose_cb), tvplayer);

     // g_signal_connect(miptv_ui->videow, "size_request",

     // G_CALLBACK(cb_preferred_video_size), miptv_ui);

     return TRUE;

 }

 static          gboolean

 bus_call(GstBus * bus, GstMessage * msg, gpointer data)

 {

     // MMythTVPlayer *tvplayer = MMYTH_TVPLAYER ( data );

     // GMainLoop *loop = tvplayer->loop;

     switch (GST_MESSAGE_TYPE(msg)) {

     case GST_MESSAGE_EOS:

         printf("End of stream\n");

         // g_idle_add ((GSourceFunc) idle_eos, data);

         gst_element_set_state(GST_ELEMENT(GST_MESSAGE_SRC(msg)),

                               GST_STATE_NULL);

         gst_element_set_locked_state(GST_ELEMENT(GST_MESSAGE_SRC(msg)),

                                      TRUE);

         break;

     case GST_MESSAGE_ERROR:

         {

             gchar          *debug;

             GError         *err;

             gst_message_parse_error(msg, &err, &debug);

             g_free(debug);

             printf("Error: %s\n", err->message);

             g_error_free(err);

             // g_main_loop_quit (loop);

         }

         break;

     default:

         printf(gst_message_type_get_name(GST_MESSAGE_TYPE(msg)));

         printf("\n");

         break;

     }

     return TRUE;

 }

 #if 0

 static          gboolean

 idle_state(gpointer data)

 {

     GstPlayerWindowStateChange *st = data;

     if (st->old_state == GST_STATE_PLAYING) {

         if (st->miptv_ui->idle_id != 0) {

             g_source_remove(st->miptv_ui->idle_id);

             st->miptv_ui->idle_id = 0;

         }

     } else if (st->new_state == GST_STATE_PLAYING) {

         if (st->miptv_ui->idle_id != 0)

             g_source_remove(st->miptv_ui->idle_id);

         st->miptv_ui->idle_id = g_idle_add(cb_iterate, st->miptv_ui);

     }

     /*

      * new movie loaded? 

      */

     if (st->old_state == GST_STATE_READY

         && st->new_state > GST_STATE_READY) {

         /*

          * gboolean have_video = FALSE; 

          */

         gtk_widget_show(st->miptv_ui->videow);

         gtk_window_resize(GTK_WINDOW(st->miptv_ui->main_window), 1, 1);

     }

     /*

      * discarded movie? 

      */

     if (st->old_state > GST_STATE_READY

         && st->new_state == GST_STATE_READY) {

         if (st->miptv_ui->tagcache) {

             gst_tag_list_free(st->miptv_ui->tagcache);

             st->miptv_ui->tagcache = NULL;

         }

     }

     gst_object_unref(GST_OBJECT(st->play));

     // g_object_unref (G_OBJECT (st->win));

     g_free(st);

     /*

      * once 

      */

     return FALSE;

 }

 #endif

 /** Stops playing the current A/V.

  *

  * FIXME: How to proceed differently between livetv 

  * and recorded content?

  *

  * @param tvplayer the object instance.

  * @return void 

  */

 void

 mmyth_tvplayer_stop_playing(MMythTVPlayer * tvplayer)

 {

     g_debug("[%s] Setting gstreamer pipeline state to NULL", __FUNCTION__);

     gst_element_set_state(tvplayer->gst_pipeline, GST_STATE_NULL);

     if (tvplayer->is_livetv) {

         if (!gmyth_recorder_stop_livetv(tvplayer->recorder)) {

             g_warning("[%s] Error while stoping remote encoder",

                       __FUNCTION__);

         }

     }

 }

 /** Queries if the tvplayer is active playing A/V content.

  *

  * @param tvplayer the object instance.

  * @return TRUE if the tvplayer is active, FALSE otherwise.

  */

 gboolean

 mmyth_tvplayer_is_playing(MMythTVPlayer * tvplayer)

 {

     return (GST_STATE(tvplayer->gst_pipeline) == GST_STATE_PLAYING);

 }

 /** Static function that sets the tvplayer state to PLAYING.

  *

  * @param tvplayer the object instance.

  * @return TRUE if the tvplayer is active, FALSE otherwise.

  */

 static          gboolean

 idle_play(gpointer data)

 {

     MMythTVPlayer  *tvplayer = MMYTH_TVPLAYER(data);

     g_debug("MMythTVPlayer: Setting pipeline state to PLAYING\n");

     gst_element_set_state(tvplayer->gst_pipeline, GST_STATE_PLAYING);

     return FALSE;

 }

 /** Start playing A/V with the tvplayer attributes.

  *

  * @param tvplayer the object instance.

  */

 void

 mmyth_tvplayer_start_playing(MMythTVPlayer * tvplayer)

 {

     // FIXME: Move this to livetv_setup??

     if (tvplayer->is_livetv) {

 #if 0

         if (!tvplayer || !(tvplayer->proginfo)

             || !(tvplayer->local_hostname)

             || !(tvplayer->gst_source)) {

             g_warning("GMythtvPlayer not ready to start playing\n");

         }

         if (!(tvplayer->proginfo->pathname)) {

             g_warning

                 ("[%s] Playback url is null, could not play the myth content",

                  __FUNCTION__);

             return;

         }

         g_debug("MMythTVPlayer: Start playing %s",

                 tvplayer->proginfo->pathname->str);

 #endif

         g_object_set(G_OBJECT(tvplayer->gst_source), "mythtv-live",

                      TRUE, NULL);

 #if 0

         if (tvplayer->tvchain != NULL) {

             GString        *str_chainid =

                 gmyth_tvchain_get_id(tvplayer->tvchain);

             g_print("[%s]\tCHAIN ID: %s\n", __FUNCTION__,

                     str_chainid->str);

             g_object_set(G_OBJECT(tvplayer->gst_source),

                          "mythtv-live-chainid", g_strdup(str_chainid->str),

                          NULL);

             if (str_chainid != NULL)

                 g_string_free(str_chainid, FALSE);

         }

         if (tvplayer->recorder != NULL)

             g_object_set(G_OBJECT(tvplayer->gst_source), "mythtv-live-id",

                          tvplayer->recorder->recorder_num, NULL);

         g_debug("[%s] Setting location to %s", __FUNCTION__,

                 tvplayer->proginfo->pathname->str);

         /*

          * Sets the gstreamer properties acording to the service access

          * address 

          */

         g_object_set(G_OBJECT(tvplayer->gst_source), "location",

                      tvplayer->proginfo->pathname->str, NULL);

 #endif

     }

     g_object_set(G_OBJECT(tvplayer->gst_source), "mythtv-version",

                  MYTHTV_VERSION_DEFAULT, NULL);

     g_object_set(G_OBJECT(tvplayer->gst_source), "mythtv-debug",

                  TRUE, NULL);

     g_idle_add(idle_play, tvplayer);

 }