#include <glib-object.h>

 #include "common.h"

 #include <gmyth/gmyth_uri.h>

 #include <gmyth/gmyth_backendinfo.h>

 #include <gmyth/gmyth_livetv.h>

 #include <gmyth/gmyth_monitor_handler.h>

 #include <gmyth/gmyth_common.h>

 #define URI_DEFAULT	"myth://192.168.3.165:6543/livetv?channel=9"

 /**

  * 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 (NULL in the tests)

  */

 static void

 gmyth_livetv_monitor_signal_handler(GMythMonitorHandler * monitor,

                                     gint msg_code, gchar * message,

                                     gpointer user_data)

 {

     g_debug

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

          message, msg_code, "NULL", user_data != NULL ? "" : "NULL");

 }

 /**

  * 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 

  */

 static          gboolean

 gmyth_test_monitor_handler_start(GMythBackendInfo * backend_info,

                                  GMythMonitorHandler * *monitor)

 {

     gboolean        res = TRUE;

     if (*monitor != NULL) {

         g_object_unref(*monitor);

         *monitor = NULL;

     }

     *monitor = gmyth_monitor_handler_new();

     res =

         gmyth_monitor_handler_open(*monitor,

                                    backend_info->hostname,

                                    backend_info->port);

     if (res == TRUE) {

         g_debug

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

         res = gmyth_monitor_handler_start(*monitor);

         if (res) {

             g_debug

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

             g_signal_connect(G_OBJECT(*monitor), "backend-events-handler",

                              (GCallback)

                              gmyth_livetv_monitor_signal_handler, NULL);

         } else {

             g_debug

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

             goto error;

         }

     }

   error:

     return res;

 }

 static          gboolean

 test_monitor_handler_setup(gchar * uri)

 {

     gboolean        ret = TRUE;

     GMythMonitorHandler *monitor;

     if (NULL == uri)

         uri = g_strdup(URI_DEFAULT);

     GMythURI       *gmyth_uri = gmyth_uri_new_with_value(uri);

     GMythBackendInfo *backend_info = gmyth_backend_info_new_with_uri(uri);

     g_debug("uri = %s", uri);

     ret = gmyth_test_monitor_handler_start(backend_info, &monitor);

     if (ret == FALSE) {

         g_debug("MonitorHandler couldn't start!\n");

         goto init_failed;

     }

   init_failed:

     if (monitor != NULL)

         g_object_unref(monitor);

     if (gmyth_uri != NULL)

         g_object_unref(gmyth_uri);

     if (backend_info != NULL)

         g_object_unref(backend_info);

     return ret;

 }

 gint

 main(gint args, const gchar ** argv)

 {

     gboolean        ret;

     g_type_init();

     g_thread_init(NULL);

     fprintf(stdout, SYNC_STRING);

     fflush(NULL);

     getchar();

     if (args > 1)

         ret = test_monitor_handler_setup(argv[1]);

     else

         ret = test_monitor_handler_setup(NULL);

     if (!ret)

         g_debug("Error when running Monitor Handler setup test script!");

     else

         g_debug("MonitorHandler setup test script setup with success.");

     return (0);

 }