/* Copyright 2012-2013, Sebastian Reichel <sre@ring0.de>
 *
 * Permission to use, copy, modify, and/or distribute this software for any
 * purpose with or without fee is hereby granted, provided that the above
 * copyright notice and this permission notice appear in all copies.
 *
 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 */

[DBus (name = "io.mainframe.shopsystem.AudioPlayer")]
public class AudioPlayerImplementation {
	private dynamic Gst.Element? p;
	string path;

	public signal void end_of_stream();

	private bool bus_callback(Gst.Bus bus, Gst.Message message) {
		switch(message.type) {
			case Gst.MessageType.EOS:
				end_of_stream();
				break;
		}

		return true;
	}

	public AudioPlayerImplementation(string path) throws IOError, DBusError {
		this.path = path;

		var alsa = Gst.ElementFactory.make("alsasink", "alsa");
		if (alsa == null)
			throw new GLib.IOError.FAILED("Cannot find alsa GStreamer plugin");

		p = Gst.ElementFactory.make("playbin", "player");
		if (p == null)
			throw new GLib.IOError.FAILED("Cannot find playbin2 GStreamer plugin");

		p.set("audio-sink", alsa);
		p.get_bus().add_watch(Priority.DEFAULT, bus_callback);
	}

	public void play_system(string file) throws IOError, DBusError {
		p.set_state(Gst.State.NULL);
		p.uri = "file://" + path + "system/" + file;
		p.set_state(Gst.State.PLAYING);
	}

	private string[] get_files(string dir) {
		try {
			var directory = File.new_for_path(dir);
			var enumerator = directory.enumerate_children(FileAttribute.STANDARD_NAME, 0);
			string[] result = {};

			FileInfo file_info;
			while ((file_info = enumerator.next_file ()) != null) {
				result += file_info.get_name();
			}

			return result;
		} catch (Error e) {
			// TODO
			//write_to_log("Error: %s\n", e.message);
			return {};
		}
	}

	private string get_random_file(string dir) {
		var files = get_files(dir);
		var index = Random.int_range(0, files.length);
		return files[index];
	}

	public string get_random_user_theme()  throws IOError, DBusError {
		return get_random_file(path + "user/");
	}

	public string[] get_user_themes()  throws IOError, DBusError {
		return get_files(path + "user/");
	}

	public void play_user(string theme, string type) throws IOError, DBusError {
		p.set_state(Gst.State.NULL);
		var file = get_random_file(path + "user/" + theme+ "/" + type);
		p.uri = "file://" + path + "user/" + theme+ "/" + type + "/" + file;
		p.set_state(Gst.State.PLAYING);
	}
}