/*** block a  from ../../../docs/manual/advanced-autoplugging.xml ***/

#include <gst/gst_global.h>

#include <gst/gst.h>

#include <gst/check/gstcheck.h>

#define LOG_FILE "c:\\logs\\typefind_logs.txt" 

#include "std_log_result.h" 

#define LOG_FILENAME_LINE __FILE__, __LINE__

void create_xml(int result)

{

    if(result)

        assert_failed = 1;

    testResultXml(xmlfile);

    close_log_file();

}

/*** block b  from ../../../docs/manual/advanced-autoplugging.xml ***/

static gboolean

my_bus_callback (GstBus     *bus,

                 GstMessage *message,

                 gpointer    data)

{

  GMainLoop *loop = data;

  switch (GST_MESSAGE_TYPE (message)) {

    case GST_MESSAGE_ERROR: {

      GError *err;

      gchar *debug;

      gst_message_parse_error (message, &err, &debug);

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

      g_error_free (err);

      g_free (debug);

      g_main_loop_quit (loop);

      break;

    }

    case GST_MESSAGE_EOS:

      /* end-of-stream */

      g_main_loop_quit (loop);

      break;

    default:

      break;

  }

  /* remove from queue */

  return TRUE;

}

/*** block c  from ../../../docs/manual/advanced-autoplugging.xml ***/

static gboolean

idle_exit_loop (gpointer data)

{

  g_main_loop_quit ((GMainLoop *) data);

  /* once */

  return FALSE;

}

static void

cb_typefound (GstElement *typefind,

	      guint       probability,

	      GstCaps    *caps,

	      gpointer    data)

{

  GMainLoop *loop = data;

  gchar *type;

  type = gst_caps_to_string (caps);

  g_print ("Media type %s found, probability %d%%\n", type, probability);

  g_free (type);

  /* since we connect to a signal in the pipeline thread context, we need

   * to set an idle handler to exit the main loop in the mainloop context.

   * Normally, your app should not need to worry about such things. */

  g_idle_add (idle_exit_loop, loop);

}

gint 

main (gint   argc,

      gchar *argv[])

{

  GMainLoop *loop;

  GstElement *pipeline, *filesrc, *typefind;

  GstBus *bus;

  xmlfile = "typefind";

  std_log(LOG_FILENAME_LINE, "Test Started typefind");

  /* init GStreamer */

  gst_init (&argc, &argv);

  loop = g_main_loop_new (NULL, FALSE);

  /* check args */

  if (argc != 2) {

    g_print ("Usage: %s <filename>\n", argv[0]);

    return -1;

  }

  /* create a new pipeline to hold the elements */

  pipeline = gst_pipeline_new ("pipe");

  fail_unless (pipeline != NULL);

  bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));  

  fail_unless (bus != NULL);  

  gst_bus_add_watch (bus, my_bus_callback, loop);

  gst_object_unref (bus);

  /* create file source and typefind element */

  filesrc = gst_element_factory_make ("filesrc", "source");

  g_object_set (G_OBJECT (filesrc), "location", argv[1], NULL);

  typefind = gst_element_factory_make ("typefind", "typefinder");

  g_signal_connect (typefind, "have-type", G_CALLBACK (cb_typefound), loop);

  fail_unless (filesrc !=NULL || typefind !=NULL );

  /* setup */

  gst_bin_add_many (GST_BIN (pipeline), filesrc, typefind, NULL);

  gst_element_link (filesrc, typefind);

  gst_element_set_state (GST_ELEMENT (pipeline), GST_STATE_PLAYING);

  g_main_loop_run (loop);

  /* unset */

  gst_element_set_state (GST_ELEMENT (pipeline), GST_STATE_NULL);

  gst_object_unref (GST_OBJECT (pipeline));

  std_log(LOG_FILENAME_LINE, "Test Successful");

  create_xml(0);

  return 0;

}