/**

  * 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

  */

 #include "gmyth_remote_util.h"

 #include "gmyth_tvchain.h"

 #include "gmyth_socket.h"

 #include "gmyth_debug.h"

 #include "gmyth_livetv.h"

 #include "gmyth_file_transfer.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; 

 #define GMYTHTV_RECORDER_HEADER         "QUERY_RECORDER"

 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->backend_hostname = NULL;

 	livetv->backend_port = 0;

 	livetv->local_hostname = NULL;

 	livetv->recorder = NULL;

 	livetv->tvchain = NULL;

 	livetv->proginfo = NULL;

 }

 static void

 gmyth_livetv_dispose  (GObject *object)

 {

 	G_OBJECT_CLASS (gmyth_livetv_parent_class)->dispose (object);

 }

 static void

 gmyth_livetv_finalize (GObject *object)

 {

 	g_signal_handlers_destroy (object);

 	GMythLiveTV *livetv = GMYTH_LIVETV (object);

 	gmyth_debug ("[%s] Finalizing livetv", __FUNCTION__);

 	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;

 	}

 	G_OBJECT_CLASS ( gmyth_livetv_parent_class )->finalize ( object );

 }

 GMythLiveTV*

 gmyth_livetv_new ()

 {

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

 	return livetv;

 }

 gboolean

 gmyth_livetv_setup ( GMythLiveTV *livetv, GMythBackendInfo *backend_info )

 {

 	gboolean res = TRUE;

 	char *hostname;

 	GMythSocket *socket = gmyth_socket_new ();

 	// FIME: Implement this at gmyth_socket

 	res = gmyth_socket_connect_to_backend (socket, backend_info->hostname,

 			backend_info->port, TRUE);

 	if (!res) {

 		g_warning ("[%s] LiveTV can not connect to backend", __FUNCTION__);	

 		res = FALSE;

 		goto error;

 	}

 	livetv->is_livetv = TRUE;

 	hostname = gmyth_backend_info_get_hostname(backend_info);

 	livetv->backend_hostname = g_string_new (hostname);

 	livetv->backend_port = gmyth_backend_info_get_port (backend_info);

 	livetv->local_hostname  = gmyth_socket_get_local_hostname ( );

 	if ( livetv->local_hostname == NULL ) {

 		res = FALSE;

 		goto error;

 	}

 	// Gets the recorder num

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

 	gmyth_socket_close_connection (socket);

 	if ( livetv->recorder == NULL ) {

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

 		res = FALSE;

 		goto error;

 	}

 	// Creates livetv chain handler

 	livetv->tvchain = GMYTH_TVCHAIN ( g_object_new(GMYTH_TVCHAIN_TYPE, NULL) );

 	gmyth_tvchain_initialize ( livetv->tvchain, backend_info );

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

 		res = FALSE;

 		goto error;

 	}

 	// Init remote encoder. Opens its control socket.

 	res = gmyth_recorder_setup(livetv->recorder);

 	if ( !res ) {

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

 		res = FALSE;

 		goto error;

 	}

 #if 0

   gint ch = 1011;

   gint idx = 0;  

   for ( ; idx < 5; idx++ ) {

   	if ( gmyth_recorder_check_channel( livetv->recorder, ch ) ) {

 	  	if ( gmyth_recorder_set_channel( livetv->recorder, ch ) ) {

 	  		g_print( "[%s] Channel changed!!! [%d].\n", __FUNCTION__, ch );

 	  		break;

 	  	}

   	}

   	++ch;

   }

 #endif

 	// 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) {

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

 		res = FALSE;

 		goto error;

 	}

 	// 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 ) {

 		g_warning ("[%s] LiveTV not successfully started.\n", __FUNCTION__ );

 		res = FALSE;

 		goto error;

 	} else {

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

 	}

 	return res;

 error:

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

 	if ( livetv->backend_hostname != NULL ) {

 		g_string_free( livetv->backend_hostname, TRUE );

 		res = FALSE;

 	}

 	if ( livetv->local_hostname != NULL ) {

 		g_string_free( livetv->local_hostname, TRUE );

 		res = FALSE;

 	}

 	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;

 }

 gboolean

 gmyth_livetv_next_program_chain ( GMythLiveTV *livetv )

 {

 	gboolean res = TRUE;

 	// 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, -1 );

 	if ( livetv->proginfo == NULL ) {

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

 		res = FALSE;

 		goto error;

 	} else {

 		gmyth_debug ("[%s] GMythLiveTV: All requests to backend to start TV were OK, TV chain changed.\n", __FUNCTION__ );

 	}

 	return res;

 error:

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

 	if ( livetv->backend_hostname != NULL ) {

 		g_string_free( livetv->backend_hostname, TRUE );

 		res = FALSE;

 	}

 	if ( livetv->local_hostname != NULL ) {

 		g_string_free( livetv->local_hostname, TRUE );

 		res = FALSE;

 	}

 	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;

 }

 // FIXME: How to proceed differently between livetv and recorded content

 void

 gmyth_livetv_stop_playing (GMythLiveTV *livetv) 

 {

 	gmyth_debug ("[%s] Stopping the LiveTV...\n", __FUNCTION__);

 	if (livetv->is_livetv) {

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

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

 		}

 	}

 }

 // FIXME: put here just a wrapper function to call gmyth_recorder_is_recording()...

 gboolean

 gmyth_livetv_is_recording ( GMythLiveTV *livetv )

 {

   gboolean ret = TRUE;

   GMythStringList *str_list = gmyth_string_list_new ();

   GString *message = g_string_new ("");

   gmyth_debug ( "[%s]\n", __FUNCTION__ );

   //g_static_mutex_lock (&mutex);

   //

   g_string_printf( message, "%s %d", GMYTHTV_RECORDER_HEADER,

       /* FIXME file_transfer->rec_id >= 0 ? file_transfer->rec_id : file_transfer->card_id );*/

         livetv->recorder->recorder_num);

   gmyth_string_list_append_string (str_list, message);

   gmyth_string_list_append_string (str_list, g_string_new ("IS_RECORDING"));

   gmyth_socket_sendreceive_stringlist ( livetv->recorder->myth_socket, str_list );

   if ( str_list != NULL && gmyth_string_list_length(str_list) > 0 )

   {

     GString *str = NULL;

     if ( ( str = gmyth_string_list_get_string( str_list, 0 ) ) != NULL && strcmp( str->str, "bad" )!= 0 ) {

       gint is_rec = gmyth_string_list_get_int( str_list, 0 );

       if ( is_rec != 0 )

         ret = TRUE;

       else

         ret = FALSE;

     }

   }

   g_print( "[%s] %s, stream is %s being recorded!\n", __FUNCTION__, ret ? "YES" : "NO", ret ? "" : "NOT" );

   //g_static_mutex_unlock (&mutex);

   if ( str_list != NULL )

     g_object_unref (str_list);

   return ret;

 }

 gboolean

 gmyth_livetv_is_playing (GMythLiveTV *livetv)

 {

 	return TRUE;

 }

 void

 gmyth_livetv_start_playing (GMythLiveTV *livetv)

 {

 	// TODO

 }