#include <sys/stat.h>

#include <fcntl.h>

#include <unistd.h>

#include <string.h>

#include <gst/gst.h>

#include <glib.h> 

#include "gmemcoder.h"

//#define FILE_OUT  1

static GMainLoop *mainloop = NULL;

static void

_mencoder_ready_cb (GMencoder *mencoder, gpointer data)

{

    g_mencoder_play_stream (mencoder);

}

static void

_mencoder_eos_cb (GMencoder *mencoder, gpointer data)

{

    g_print ("EOS\n");

    g_main_loop_quit ((GMainLoop *) data);

}

static void

_mencoder_error_cb (GMencoder *mencoder, const gchar* msg, gpointer data)

{

    g_print ("Error: %s\n", msg);

    g_main_loop_quit ((GMainLoop *) data);

}

static gboolean

_io_channel_cb (GIOChannel *ch,

                GIOCondition condition,

                gpointer data)

{

    GString *cmd = g_string_new ("");

    g_io_channel_read_line_string (ch, cmd, NULL, NULL);

    if (strcmp (cmd->str, "PLAY\n") == 0) {

        g_mencoder_play_stream (G_MENCODER (data));

    } else if (strcmp (cmd->str, "PAUSE\n") == 0) {

        g_mencoder_pause_stream (G_MENCODER (data));

    } else if (strcmp (cmd->str, "STOP\n") == 0) {

        g_mencoder_close_stream (G_MENCODER (data));

    } else if (strcmp (cmd->str, "QUIT\n") == 0) {

        g_mencoder_close_stream (G_MENCODER (data));

        g_main_loop_quit (mainloop);

    }

    g_string_free (cmd, TRUE);

    return TRUE;

}

int 

main (int argc, char** argv)

{

    GMencoder *coder;

    GIOChannel *ch;

	g_type_init ();

	gst_init (&argc, &argv);

	g_set_prgname ("gmemcoder");

    coder = g_mencoder_new ();

    ch = g_io_channel_unix_new (0);

#ifdef FILE_OUT

    int fd = open (argv[2], O_WRONLY | O_CREAT | O_TRUNC);

    g_debug ("FD %d", fd);

    g_mencoder_setup_stream (coder, argv[1], 320, 288, fd);

#else

    g_mencoder_setup_stream (coder, argv[1], 320, 288, atoi (argv[2]));

#endif

	mainloop = g_main_loop_new (NULL, FALSE);

    g_io_add_watch (ch, G_IO_IN, _io_channel_cb, coder);    

    g_signal_connect (G_OBJECT (coder),

                        "ready",

                        G_CALLBACK (_mencoder_ready_cb),

                        NULL);

    g_signal_connect (G_OBJECT (coder),

                        "eos",

                        G_CALLBACK (_mencoder_eos_cb),

                        mainloop);

    g_signal_connect (G_OBJECT (coder),

                        "error",

                        G_CALLBACK (_mencoder_error_cb),

                        mainloop);

	g_main_loop_run (mainloop);

#if FILE_OUT

    close (fd);

#endif

	return 0;

}