/*

 * Copyright (C) 2010 Igalia S.L.

 *

 * Contact: mswl-dm-2009@igalia.com

 *

 * This library 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; version 2.1 of

 * the License, or (at your option) any later version.

 *

 * This library 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

 * Lesser General Public License for more details.

 *

 * You should have received a copy of the GNU Lesser General Public

 * License along with this library; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA

 * 02110-1301 USA

 *

 */

#include <stdio.h>

#include <glib.h>

#include <gst/gst.h>

#include <signal.h>

#include <string.h>

#include <glib/gi18n.h>

#include "config.h"

#include "jmp-mplayer.h"

static gchar *uri = "/usr/share/sounds/ubuntu/stereo/desktop-login.ogg";

static guint change_volume = -1;

static guint query_playback = -1;

static guint stop_after = -1;

static GMainLoop *loop;

static GOptionEntry entries[] = {

        { "uri", 'u', 0, G_OPTION_ARG_STRING, &uri, "uri", "u" },

        { "change-volume-time", 'v', 0, G_OPTION_ARG_INT, &change_volume,

                        "Change volume time", "nanosecs" },

        { "stop-after", 's', 0, G_OPTION_ARG_INT, &stop_after,

                        "Stop after", "nanosecs" },

        { NULL }

};

JmpMplayer *jmplayer;

static gboolean

change_volume_callback (gpointer user_data)

{

        JmpMplayer *jmplayer = JMP_MPLAYER (user_data);

        gdouble current_volume;

        current_volume = jmp_mplayer_get_volume (jmplayer);

        jmp_mplayer_set_volume (jmplayer, 0.5 * current_volume);

        return TRUE;

}

static void

end_of_stream_callback (JmpMplayer *jmplayer, gpointer user_data)

{

        g_message (_("The sound has ended!"));

        g_main_loop_quit(loop);

}

static void

error_callback (JmpMplayer *jmplayer, gchar *message, gpointer user_data)

{

        g_critical (_("An error has occurred: %s"), message);

        g_main_loop_quit (loop);

}

static void

tick_callback (JmpMplayer *jmplayer, gint64 position, gint64 duration,

               gpointer user_data)

{

        g_print (_("PLAYBACK: %" G_GINT64_FORMAT "/%" G_GINT64_FORMAT "\n"),

                 position, duration);

}

static gboolean

stop_after_callback (gpointer user_data)

{

        JmpMplayer *jmplayer = JMP_MPLAYER (user_data);

        jmp_mplayer_stop (jmplayer);

        g_main_loop_quit (loop);

}

static void

play_handler (int signum)

{

        switch (signum) {

                case SIGUSR1:

                        g_message (_("Caught SIGUSR1 - Play request"));

                        jmp_mplayer_play (jmplayer);

                        break;

                case SIGUSR2:

                        g_message (_("Caught SIGUSR2 - Pause request"));

                        jmp_mplayer_pause (jmplayer);

                        break;

        }

}

static void

play_signal_setup(void)

{

          struct sigaction action;

          memset (&action, 0, sizeof (action));

          action.sa_handler = play_handler;

          sigaction (SIGUSR1, &action, NULL);

          sigaction (SIGUSR2, &action, NULL);

}

int

main (int argc, char **argv)

{

        GError *error = NULL;

        GOptionContext *context;

        GOptionGroup *gst_option_group;

        char *uritmp;

        if (!g_thread_supported ())

                g_thread_init (NULL);

        context = g_option_context_new (_(" - Tests jmp-mplayer behavior"));

        gst_option_group = gst_init_get_option_group ();

        g_option_context_add_main_entries (context, entries, NULL);

        g_option_context_add_group (context, gst_option_group);

        if (!g_option_context_parse (context, &argc, &argv, &error)) {

                g_critical (_("option parsing failed: %s"), error->message);

                return -1;

        }

        g_printf (_("JAMP Media Player Test:\n"));

        g_printf (_("Send USR1 signal to play and USR2 to pause (pid: %d)\n"), getpid());

        g_printf (_("kill -USR1 %d ====== kill -USR2 %d\n"), getpid(), getpid());

        loop = g_main_loop_new (NULL, FALSE);

        jmplayer = jmp_mplayer_new ();

        g_signal_connect (jmplayer, "end-of-stream",

                          G_CALLBACK (end_of_stream_callback), NULL);

        g_signal_connect (jmplayer, "error",

                          G_CALLBACK (error_callback), NULL);

        g_signal_connect (jmplayer, "playback-tick",

                          G_CALLBACK (tick_callback), NULL);

        play_signal_setup();

        if (!g_strrstr (uri, "://")) {

                uritmp = g_filename_to_uri(uri, NULL, &error);

                if (uritmp) {

                        uri = uritmp;

                }

        }

        jmp_mplayer_set_uri (jmplayer, uri);

        jmp_mplayer_play (jmplayer);

        if (change_volume != -1) {

                g_timeout_add (change_volume, change_volume_callback,

                                jmplayer);

        }

        if (stop_after != -1) {

                g_timeout_add (stop_after, stop_after_callback, jmplayer);

        }

        g_main_loop_run (loop);

        g_object_unref (jmplayer);

        g_option_context_free (context);

        g_main_loop_unref (loop);

        return 0;

}