/**

 * GMyth Library

 *

 * @file gmyth/gmyth_livetv.c

 * 

 * @brief <p> GMythLiveTV starts a remote TV session with the MythTV backend.

 *

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

 * @author Rosfran Lins Borges <rosfran.borges@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

       */

#ifdef HAVE_CONFIG_H

#include "config.h"

#endif

#include "gmyth_livetv.h"

#include "gmyth_remote_util.h"

#include "gmyth_tvchain.h"

#include "gmyth_socket.h"

#include "gmyth_backendinfo.h"

#include "gmyth_debug.h"

#include "gmyth_file.h"

#include "gmyth_file_transfer.h"

#include "gmyth_file_local.h"

#include "gmyth_monitor_handler.h"

#include "gmyth_common.h"

#include "gmyth_util.h"

static void gmyth_livetv_class_init (GMythLiveTVClass * klass);

static void gmyth_livetv_init (GMythLiveTV * object);

static void gmyth_livetv_dispose (GObject * object);

static void gmyth_livetv_finalize (GObject * object);

static gint tvchain_curr_index = -1;

/*static GStaticMutex lock = G_STATIC_MUTEX_INIT;*/

#define GMYTHTV_TRANSFER_MAX_WAITS	    100

G_DEFINE_TYPE (GMythLiveTV, gmyth_livetv, G_TYPE_OBJECT)

     static void gmyth_livetv_class_init (GMythLiveTVClass * klass)

{

    GObjectClass *gobject_class;

    gobject_class = (GObjectClass *) klass;

    gobject_class->dispose = gmyth_livetv_dispose;

    gobject_class->finalize = gmyth_livetv_finalize;

}

static void

gmyth_livetv_init (GMythLiveTV * livetv)

{

    livetv->monitor = NULL;

    livetv->backend_info = NULL;

    livetv->local_hostname = NULL;

    livetv->file = NULL;

    livetv->setup_done = FALSE;

    livetv->socket = NULL;

    livetv->recorder = NULL;

    livetv->tvchain = NULL;

    livetv->proginfo = NULL;

    livetv->uri = NULL;

    livetv->mutex = g_mutex_new ();

}

static void

gmyth_livetv_dispose (GObject * object)

{

    GMythLiveTV *livetv = GMYTH_LIVETV (object);

    if (livetv->disposed)

    {

        /* If dispose did already run, return. */

        return;

    }

    /* Make sure dispose does not run twice. */

    livetv->disposed = TRUE;

    if (livetv->monitor != NULL)

    {

        g_object_unref (livetv->monitor);

        livetv->monitor = NULL;

    }

    if (livetv->file != NULL)

    {

        g_object_unref (livetv->file);

        livetv->file = NULL;

    }

    if (livetv->recorder != NULL)

    {

        //gmyth_recorder_close(livetv->recorder);

        g_object_unref (livetv->recorder);

        livetv->recorder = NULL;

    }

    if (livetv->socket != NULL)

    {

        g_object_unref (livetv->socket);

        livetv->socket = NULL;

    }

    if (livetv->tvchain != NULL)

    {

        g_object_unref (livetv->tvchain);

        livetv->tvchain = NULL;

    }

    if (livetv->proginfo != NULL)

    {

        g_object_unref (livetv->proginfo);

        livetv->proginfo = NULL;

    }

    if (livetv->backend_info != NULL)

    {

        g_object_unref (livetv->backend_info);

        livetv->backend_info = NULL;

    }

    if (livetv->uri != NULL)

    {

        g_object_unref (livetv->uri);

        livetv->uri = NULL;

    }

    if (livetv->mutex != NULL)

    {

        g_mutex_free (livetv->mutex);

        livetv->mutex = NULL;

    }

    if (livetv->local_hostname != NULL)

    {

        g_string_free (livetv->local_hostname, TRUE);

        livetv->local_hostname = NULL;

    }

    G_OBJECT_CLASS (gmyth_livetv_parent_class)->dispose (object);

}

static void

gmyth_livetv_finalize (GObject * object)

{

    g_signal_handlers_destroy (object);

    G_OBJECT_CLASS (gmyth_livetv_parent_class)->finalize (object);

}

/**

 * Creates a new GMythLiveTV instance

 * 

 * @return a newly allocated GMythLiveTV instance

 */

GMythLiveTV *

gmyth_livetv_new (GMythBackendInfo * backend_info)

{

    GMythLiveTV *livetv = GMYTH_LIVETV (g_object_new (GMYTH_LIVETV_TYPE, NULL));

    livetv->backend_info = backend_info;

    g_object_ref (livetv->backend_info);

    return livetv;

}

/**

 * The GObject signal handler function, from which all status messages 

 * from the Monitor Handler will be advertized, all time it receives

 * LiveTV status messages from the MythTV backend

 * 

 * @param monitor a GMythMonitorHandler instance

 * @param msg_code the MythTV's server numeric status code

 * @param message the message's string description

 * @param user_data pointer to the GMythLiveTV instance

 */

static void

gmyth_livetv_monitor_signal_handler (GMythMonitorHandler * monitor,

                                     gint msg_code, gchar * message,

                                     gpointer user_data)

{

    GMythLiveTV *live_tv = GMYTH_LIVETV (user_data);

    gmyth_debug

        ("LIVETV Signal handler ( msg = %s, code = %d, live_tv param = %s, user_data = %s )\n",

         message, msg_code, live_tv != NULL ? "" : "NULL",

         user_data != NULL ? "" : "NULL");

    if (NULL == live_tv || !IS_GMYTH_FILE_TRANSFER (live_tv->file))

    {

        gmyth_debug ("LiveTV_obj is equals to NULL!!!");

        return;

    }

    switch (msg_code)

    {

        case GMYTH_BACKEND_PROGRAM_INFO_CHANGED:

            {

                gmyth_debug

                    ("LIVETV Program Changed request received [ msg = %s ]. Watching if the new "

                     "TV Chain ID is the same as the old one...\n", message);

                if (g_ascii_strcasecmp

                    (message,

                     (gmyth_tvchain_get_id (live_tv->tvchain))->str) != 0)

                {

                    gmyth_debug

                        ("OK!!! MOVED to the next program chain [actual == %s]!",

                         (gmyth_tvchain_get_id (live_tv->tvchain))->str);

                    /* advertises the FileTransfer about the program info changed */

                    if (live_tv->file != NULL)

                    {

                        gmyth_debug

                            ("Emitting signal to the FileTransfer... [ \"program-info-changed \" ]");

                        gmyth_file_transfer_emit_program_info_changed_signal

                            (GMYTH_FILE_TRANSFER (live_tv->file), msg_code,

                             (gpointer) (live_tv->recorder));

                        /* gmyth_livetv_monitor_handler_stop( live_tv ); */

                    }

                    else

                        gmyth_debug

                            ("LIVETV file_transfer is NULL!!! Cannot move to the next program chain event received.\n");

                }

                break;

            }

        case GMYTH_BACKEND_DONE_RECORDING:

            {

                gmyth_debug

                    ("LIVETV Program Changed request received [ msg = %s ]. Watching if the new "

                     "TV Chain ID is the same as the old one...\n", message);

                if (g_ascii_strcasecmp

                    (message,

                     (gmyth_tvchain_get_id (live_tv->tvchain))->str) != 0)

                {

                    gmyth_debug

                        ("OK!!! MOVED to the next program chain [actual == %s]!",

                         (gmyth_tvchain_get_id (live_tv->tvchain))->str);

                    /* advertises the FileTransfer about the program info changed */

                    if (live_tv->file != NULL)

                    {

                        gmyth_debug

                            ("Emitting signal to the FileTransfer... [ \"backend-done-recording\" ]");

                        gmyth_file_transfer_emit_program_info_changed_signal

                            (GMYTH_FILE_TRANSFER (live_tv->file), msg_code,

                             (gpointer) (live_tv->recorder));

                    }

                    else

                        gmyth_debug

                            ("LIVETV file_transfer is NULL!!! Cannot move to the next program chain event received.\n");

                }

                break;

            }

        case GMYTH_BACKEND_STOP_LIVETV:

            {

                gmyth_debug

                    ("LIVETV Stop LiveTV request received [ msg = %s ]. Going out the "

                     "LiveTV...\n", message);

                /* stops the LiveTV */

                if (live_tv != NULL)

                {

                    gmyth_debug ("Going out the LiveTV... [ \"quit-livetv\" ]");

                    g_object_unref (live_tv);

                }

                else

                    gmyth_debug

                        ("LIVETV file_transfer is NULL!!! Cannot move to the next program chain event received.\n");

                break;

            }

        default:

            break;

    } /* switch (Monitor Handler messages) */

}

/**

 * Starts the Monitor Handler to this GMythLiveTV session, in order

 * to receive the status messages from the MythTV's backend server 

 * 

 * @param live_tv the GMythLiveTV instance

 * 

 * @return <code>true</code> if the Monitor Handler start-up process

 * 	   had been concluded succcesfully 

 */

gboolean

gmyth_livetv_monitor_handler_start (GMythLiveTV * livetv)

{

    gboolean res = TRUE;

    if (livetv->monitor != NULL)

    {

        g_object_unref (livetv->monitor);

        livetv->monitor = NULL;

    }

    livetv->monitor = gmyth_monitor_handler_new ();

    res =

        gmyth_monitor_handler_open (livetv->monitor,

                                    livetv->backend_info->hostname,

                                    livetv->backend_info->port);

    if (res == TRUE)

    {

        gmyth_debug

            ("Connect MythTV Monitor event socket! Trying to start the message handler...");

        res = gmyth_monitor_handler_start (livetv->monitor);

        if (res)

        {

            gmyth_debug

                ("MythTV Monitor event socket connected and listening!");

            g_signal_connect (G_OBJECT (livetv->monitor),

                              "backend-events-handler",

                              (GCallback) gmyth_livetv_monitor_signal_handler,

                              livetv);

        }

        else

        {

            gmyth_debug

                ("Problems when trying to start MythTV Monitor event socket!");

            goto error;

        }

    }

  error:

    return res;

}

/**

 * Stops the Monitor Handler to this GMythLiveTV session, in order

 * to stop receiving the status messages from the MythTV's backend server 

 * 

 * @param live_tv the GMythLiveTV instance

 * 

 * @return <code>true</code> if the Monitor Handler shutdown process

 * 	   had been concluded succcesfully 

 */

void

gmyth_livetv_monitor_handler_stop (GMythLiveTV * livetv)

{

    if (livetv->monitor != NULL)

    {

        g_object_unref (livetv->monitor);

        livetv->monitor = NULL;

    }

}

#if 0

static gchar *

gmyth_livetv_create_remote_url (GMythLiveTV * livetv)

{

    gchar *uri = g_strdup ("");

    gmyth_backend_info_get_remote_h

        //gmyth_backend(livetv->backend_info)

        return uri;

}

#endif

/**

 * Configures the GMythLiveTV session, sends SPAWN_LIVETV message, 

 * sets the channel name, and gets the first program info about the

 * actual recording 

 * 

 * @param live_tv the GMythLiveTV instance

 * @param channel the channel name (the chan_name field, from the tvchain table)

 * @param backend_info the GMythBackendInfo describing the remote server

 * 

 * @return <code>true</code> if the LiveTV's recorder instance configuration 

 * 				had been concluded succcesfully 

 */

static gboolean

gmyth_livetv_setup_recorder_channel_name (GMythLiveTV * livetv, gchar * channel)

{

    gboolean res = TRUE;

    g_return_val_if_fail (livetv != NULL, FALSE);

    if (NULL == livetv->socket)

    {

        livetv->socket = gmyth_socket_new ();

        /* FIME: Implement this at gmyth_socket */

        res =

            gmyth_socket_connect_to_backend (livetv->socket,

                                             livetv->backend_info->hostname,

                                             livetv->backend_info->port, TRUE);

        if (!res)

        {

            gmyth_debug ("[%s] LiveTV can not connect to backend",

                         __FUNCTION__);

            res = FALSE;

            goto error;

        }

    }

    g_mutex_lock (livetv->mutex);

    livetv->is_livetv = TRUE;

    livetv->local_hostname = gmyth_socket_get_local_hostname ();

    if (livetv->local_hostname == NULL)

    {

        g_warning ("livetv could not retrieve the local hostname");

        res = FALSE;

        goto error;

    } else {

        gmyth_debug ("Local hostname: %s", livetv->local_hostname->str);

    }

    if (livetv->recorder != NULL)

    {

        g_object_unref (livetv->recorder);

        livetv->recorder = NULL;

    }

    if (gmyth_remote_util_get_free_recorder_count (livetv->socket) <= 0)

    {

        gmyth_debug ("No free remote encoder available.");

        res = FALSE;

        goto error;

    }

    /* Gets the recorder num */

    livetv->recorder = remote_request_next_free_recorder (livetv->socket, -1);

    gmyth_socket_close_connection (livetv->socket);

    if (NULL == livetv->recorder)

    {

        gmyth_debug ("[%s] None remote encoder available", __FUNCTION__);

        res = FALSE;

        goto error;

    }

    /* Init remote encoder. Opens its control socket. */

    res = gmyth_recorder_setup (livetv->recorder);

    if (!res)

    {

        gmyth_debug ("[%s] Fail while setting remote encoder\n", __FUNCTION__);

        res = FALSE;

        goto error;

    }

    /* Creates livetv chain handler */

    livetv->tvchain = gmyth_tvchain_new ();

    gmyth_tvchain_initialize (livetv->tvchain, livetv->backend_info);

    if (livetv->tvchain == NULL || livetv->tvchain->tvchain_id == NULL)

    {

        res = FALSE;

        goto error;

    }

    // Spawn live tv. Uses the socket to send mythprotocol data to start livetv in the backend (remotelly)

    res = gmyth_recorder_spawntv (livetv->recorder,

                                  gmyth_tvchain_get_id (livetv->tvchain));

    if (!res)

    {

        gmyth_debug ("[%s] Fail while spawn tv\n", __FUNCTION__);

        res = FALSE;

        goto error;

    }

    if (res == TRUE)

    {

        /* loop finished, set the max tries variable to zero again... */

        gint wait_to_transfer = 0;

        while (wait_to_transfer++ < GMYTHTV_TRANSFER_MAX_WAITS &&

               (gmyth_recorder_is_recording (livetv->recorder) == FALSE))

            g_usleep (300);

        if (channel != NULL)

        {

            /* Pauses remote encoder. */

            res = gmyth_recorder_pause_recording (livetv->recorder);

            if (!res)

            {

                gmyth_debug ("[%s] Fail while pausing remote encoder\n",

                             __FUNCTION__);

                res = FALSE;

                goto error;

            }

            if (gmyth_recorder_check_channel_name (livetv->recorder, channel))

            {

                if (gmyth_recorder_set_channel_name (livetv->recorder, channel))

                {

                    gmyth_debug ("Channel changed!!! [%s].\n", channel);

                }

            }

        }                       /* if - changes the channel number */

        /* sleep (5); *//* FIXME: this is evil (tpm) */

    }

    /* DEBUG message */

    GMythProgramInfo *prog_info =

        gmyth_recorder_get_current_program_info (livetv->recorder);

    if (NULL == prog_info)

    {

        gmyth_debug ("ProgramInfo is equals to NULL!!!");

        gint i;

        gchar *channame = NULL;

        gmyth_debug ("Problem getting current proginfo!\n");

        /*

         * mythbackend must not be tuned in to a channel, so keep

         * changing channels until we find a valid one, or until

         * we decide to give up.

         */

        for (i = 1; i < 1000; i++)

        {

            if (channame != NULL)

                g_free (channame);

            channame = g_strdup_printf ("%d", i);

            if (gmyth_recorder_set_channel_name (livetv->recorder, channame) <

                0)

            {

                continue;

            }

            prog_info =

                gmyth_recorder_get_next_program_info (livetv->recorder,

                                                      BROWSE_DIRECTION_UP);

            gmyth_program_info_print (prog_info);

            if (prog_info != NULL)

                break;

        }

    }                           /* if - Program Info */

    /* prints program info data text */

    gmyth_debug ("New ProgramInfo...\n");

    gmyth_program_info_print (prog_info);

    /* check if the program chain could be obtained from the MythTV protocol message */

    if (prog_info != NULL)

    {

        gmyth_backend_info_set_username (livetv->tvchain->backend_info,

                                         "mythtv");

        gmyth_backend_info_set_password (livetv->tvchain->backend_info,

                                         "mythtv");

        gmyth_backend_info_set_db_name (livetv->tvchain->backend_info,

                                        "mythconverg");

        GList *prog_list =

            gmyth_tvchain_get_program_info_from_channel (livetv->tvchain,

                                                         channel);

        GMythProgramInfo *ch_prog = NULL;

        if (prog_list != NULL && g_list_length (prog_list) > 0)

        {

            ch_prog = (GMythProgramInfo *) g_list_nth_data (prog_list, 0);

            gmyth_debug ("Channel program info (from a list with size = %d)!",

                         g_list_length (prog_list));

            gmyth_program_info_print (ch_prog);

        }

        gmyth_debug ("Program Info: %s\n",

                     gmyth_program_info_to_string (prog_info));

        livetv->proginfo = prog_info;

        /* testing change channel */

        //gmyth_recorder_spawntv_no_tvchain( livetv->recorder );

    }

    else

    {

        /* check for the program info in the TV program chain could be obtained 

           from the MythTV MySQL database */

        /* Reload all TV chain from Mysql database. */

        gmyth_tvchain_reload_all (livetv->tvchain);

        if (livetv->tvchain == NULL)

        {

            res = FALSE;

            goto error;

        }

        /* Get program info from database using chanid and starttime */

        livetv->proginfo =

            gmyth_tvchain_get_program_at (livetv->tvchain,

                                          tvchain_curr_index++);

        if (livetv->proginfo == NULL)

        {

            gmyth_debug ("LiveTV not successfully started.\n");

            res = FALSE;

            goto error;

        }

        else

        {

            res = TRUE;

            gmyth_debug

                ("GMythLiveTV: All requests to backend to start TV were OK. [%s]\n",

                 livetv->proginfo->pathname->str);

        }

    }

    livetv->uri =

        (GMythURI *) gmyth_backend_info_get_uri (livetv->backend_info);

    g_mutex_unlock (livetv->mutex);

    if (!gmyth_livetv_monitor_handler_start (livetv))

    {

        res = FALSE;

        gmyth_debug ("LiveTV MONITOR handler error on setup!");

        goto error;

    }

    livetv->setup_done = TRUE;

    return res;

  error:

    gmyth_debug ("[%s] ERROR running LiveTV setup.\n", __FUNCTION__);

    res = FALSE;

    if (livetv->local_hostname != NULL)

        g_string_free (livetv->local_hostname, TRUE);

    if (livetv->recorder != NULL)

    {

        g_object_unref (livetv->recorder);

        livetv->recorder = NULL;

    }

    if (livetv->tvchain != NULL)

    {

        g_object_unref (livetv->tvchain);

        livetv->tvchain = NULL;

    }

    if (livetv->proginfo != NULL)

    {

        g_object_unref (livetv->proginfo);

        livetv->proginfo = NULL;

    }

    if (livetv->monitor != NULL)

    {

        g_object_unref (livetv->monitor);

        livetv->monitor = NULL;

    }

    return res;

}

/**

 * Setup the GMythLiveTV session, sends SPAWN_LIVETV message, 

 * sets the channel name, and gets the first program info about the

 * actual recording 

 * 

 * @param live_tv the GMythLiveTV instance

 * @param channel the channel name, in numerical format

 * @param backend_info the GMythBackendInfo describing the remote server

 * 

 * @return <code>true</code> if the LiveTV's recorder instance configuration 

 * 				had been concluded succcesfully 

 */

static gboolean

gmyth_livetv_setup_recorder (GMythLiveTV * livetv, gint channel)

{

    return gmyth_livetv_setup_recorder_channel_name (livetv, (channel != -1) ?

                                                     g_strdup_printf ("%d",

                                                                      channel) :

                                                     NULL);

}

/**

 * Setup the GMythLiveTV session, sends SPAWN_LIVETV message, 

 * sets the channel name (numerical format), and gets the first program info about the

 * actual recording 

 * 

 * @param live_tv the GMythLiveTV instance

 * @param channel the channel name, in numerical format

 * @param backend_info the GMythBackendInfo describing the remote server

 * 

 * @return <code>true</code> if the LiveTV's recorder instance configuration 

 * 				had been concluded succcesfully 

 */

gboolean

gmyth_livetv_channel_setup (GMythLiveTV * livetv, gint channel)

{

    return gmyth_livetv_setup_recorder (livetv, channel);

}

/**

 * Setup the GMythLiveTV session, sends SPAWN_LIVETV message, 

 * sets the channel name (string format), and gets the first program info about the

 * actual recording 

 * 

 * @param live_tv the GMythLiveTV instance

 * @param channel the channel name, in numerical format

 * @param backend_info the GMythBackendInfo describing the remote server

 * 

 * @return <code>true</code> if the LiveTV's recorder instance configuration 

 * 				had been concluded succcesfully 

 */

gboolean

gmyth_livetv_channel_name_setup (GMythLiveTV * livetv, gchar * channel)

{

    return gmyth_livetv_setup_recorder_channel_name (livetv, channel);

}

/**

 * Setup the GMythLiveTV session, sends SPAWN_LIVETV message, 

 * and gets the first program info about the actual recording

 * (doesn't changes the channel). 

 * 

 * @param live_tv the GMythLiveTV instance

 * @param backend_info the GMythBackendInfo describing the remote server

 * 

 * @return <code>true</code> if the LiveTV's recorder instance configuration 

 * 				had been concluded succcesfully 

 */

gboolean

gmyth_livetv_setup (GMythLiveTV * livetv)

{

    return gmyth_livetv_setup_recorder (livetv, -1);

}

/**

 * Gets the next program info from this GMythLiveTV session.

 * 

 * @param live_tv the GMythLiveTV instance

 * 

 * @return <code>true</code> if the next program info could be got 

 */

gboolean

gmyth_livetv_next_program_chain (GMythLiveTV * livetv)

{

    gboolean res = TRUE;

    GMythProgramInfo *prog_info = NULL;

    if (!livetv->setup_done)

    {

        gmyth_debug ("Call the setup function first!");

        goto error;

    }

    gmyth_debug ("Current ProgramInfo...\n");

    prog_info = gmyth_recorder_get_current_program_info (livetv->recorder);

    if (prog_info != NULL)

    {

        livetv->proginfo = prog_info;

    }

    else

    {

        gmyth_debug

            ("ProgramInfo equals to NULL!!! Getting the next program info...");

        prog_info =

            gmyth_recorder_get_next_program_info (livetv->recorder,

                                                  BROWSE_DIRECTION_RIGHT);

        livetv->proginfo = prog_info;

    }

    /* prints program info data text */

    gmyth_program_info_print (prog_info);

    if (prog_info != NULL)

    {

        res = TRUE;

        livetv->proginfo = prog_info;

        gmyth_debug

            ("GMythLiveTV: All requests to backend to start TV were OK, program info changed.");

    }

    else

    {

        gmyth_debug

            ("[%s] LiveTV not successfully started on the next program chain.\n",

             __FUNCTION__);

        goto error;

    }

    livetv->setup_done = TRUE;

    return res;

  error:

    gmyth_debug ("ERROR running LiveTV setup.\n");

    res = FALSE;

    g_string_free (livetv->local_hostname, TRUE);

    if (livetv->recorder != NULL)

    {

        g_object_unref (livetv->recorder);

        livetv->recorder = NULL;

    }

    if (livetv->tvchain != NULL)

    {

        g_object_unref (livetv->tvchain);

        livetv->tvchain = NULL;

    }

    if (livetv->proginfo != NULL)

    {

        g_object_unref (livetv->proginfo);

        livetv->proginfo = NULL;

    }

    return res;

}

/**

 * Creates a File Transfer session, using all configuration information

 * got from the actual program info.

 * 

 * @param live_tv the GMythLiveTV instance

 * 

 * @return the actual GMythFileTransfer instance, generated using the

 * 		data got from the actual program info.

 */

GMythFile *

gmyth_livetv_create_file_transfer (GMythLiveTV * livetv)

{

    //GMythURI* uri = NULL;

    if (NULL == livetv)

        goto done;

    if (!livetv->setup_done)

    {

        gmyth_debug

            ("Error: You must do the LiveTV setup, just before generating the FileTransfer from LiveTV source!");

        goto done;

    }

    if (livetv->proginfo != NULL)

        gmyth_debug ("URI path (from program info) = %s.\n",

                     livetv->proginfo->pathname->str);

    else

        gmyth_debug ("URI path (from URI) = %s.\n", livetv->uri->uri->str);

    g_mutex_lock (livetv->mutex);

    if (livetv->file != NULL)

    {

        /*gmyth_file_transfer_close( livetv->file ); */

        g_object_unref (livetv->file);

        livetv->file = NULL;

    }

    if (livetv->uri != NULL)

    {

        gmyth_debug

            ("URI is not NULL, creating from the ProgramInfo pathname... (%s)",

             livetv->proginfo->pathname->str);

        livetv->uri->path = g_string_erase (livetv->uri->path, 0, -1);

        livetv->uri->path =

            g_string_new (g_strrstr (livetv->proginfo->pathname->str, "/"));

    }

    else

    {

        gmyth_debug

            ("URI is NULL, creating from the ProgramInfo pathname... (%s)",

             livetv->proginfo->pathname->str);

        livetv->uri =

            gmyth_uri_new_with_value (livetv->proginfo->pathname->str);

    }

    if (NULL == livetv->uri)

    {

        gmyth_debug ("Couldn't parse the URI to start LiveTV! [ uri = %s ]",

                     livetv->proginfo->pathname->str);

        goto done;

    }

    if (gmyth_uri_is_local_file (livetv->uri))

        livetv->file = GMYTH_FILE (gmyth_file_local_new (livetv->backend_info));

    else

    {

        livetv->file =

            GMYTH_FILE (gmyth_file_transfer_new (livetv->backend_info));

        /* gmyth_file_transfer_settimeout( GMYTH_FILE_TRANSFER(livetv->file), TRUE ); */

    }

    if (NULL == livetv->file)

    {

        gmyth_debug

            ("Error: couldn't create the FileTransfer from LiveTV source!");

        goto done;

    }

    g_object_ref (livetv->file);

    g_mutex_unlock (livetv->mutex);

    /* Do some locking procedure with the Monitor Handler messages... */

  done:

    /*

       if ( uri != NULL )

       {

       g_object_unref( uri );

       uri = NULL;

       }

     */

    return livetv->file;

}

/**

 * Stops this LiveTV session.

 * 

 * @param live_tv the GMythLiveTV instance

 */

void

gmyth_livetv_stop_playing (GMythLiveTV * livetv)

{

    gmyth_debug ("Stopping the LiveTV...\n");

    if (livetv->is_livetv)

    {

        if (!gmyth_recorder_stop_livetv (livetv->recorder))

        {

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

                         __FUNCTION__);

        }

        if (!gmyth_recorder_finish_recording (livetv->recorder))

        {

            gmyth_debug

                ("[%s] Error while finishing recording on remote encoder",

                 __FUNCTION__);

        }

    }

}

gboolean

gmyth_livetv_is_playing (GMythLiveTV * livetv)

{

    return TRUE;

}

void

gmyth_livetv_start_playing (GMythLiveTV * livetv)

{

    // TODO

}