/**

 * 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);

}