/**
 * projectM -- Milkdrop-esque visualisation SDK
 * Copyright (C)2003-2004 projectM Team
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public
 * License as published by the Free Software Foundation; either
 * 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 General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 * See 'LICENSE.txt' included within this release
 *
 */

#ifndef QPULSE_AUDIO_THREAD
#define QPULSE_AUDIO_THREAD
#include <QObject>
#include <QTimer>
#include <QThread>
#include <QString>
#include <QModelIndex>
#include <QHash>
#include <QtDebug>
#include <QMutex>

extern "C"
{
#include <pulse/introspect.h>
#include <pulse/pulseaudio.h>
}

#include "qprojectm_mainwindow.hpp"
			 

class QPulseAudioThread : public QThread
{	
	Q_OBJECT
	public:		
		typedef QHash<int, QString> SourceContainer;
		QPulseAudioThread () {}
		QPulseAudioThread
				(int _argc, char **_argv, QProjectM_MainWindow * qprojectM_MainWindow);
		virtual ~QPulseAudioThread();
		void run();
		
		QMutex * mutex();

		inline const SourceContainer & devices() {
			return s_sourceList;
		}
		void writeSettings();

		inline const SourceContainer::const_iterator & sourcePosition() {
			return s_sourcePosition;
		}

	public slots:
		
		void cork();
		
		inline void insertSource(int index, const QString & name) {
			s_sourceList[index] = name;
		}

		void cleanup();

		void connectDevice(const QModelIndex & index = QModelIndex());

	signals:
		void deviceChanged();
		void threadCleanedUp();
	private:
	
		QProjectM_MainWindow * m_qprojectM_MainWindow;
		static SourceContainer::const_iterator readSettings();

		static void reconnect(SourceContainer::const_iterator pos);
		
		static SourceContainer::const_iterator scanForPlaybackMonitor();
		static void connectHelper (SourceContainer::const_iterator pos);
		static void pulseQuit ( int ret );
		static void stream_moved_callback(pa_stream *s, void *userdata);
		static void stream_read_callback ( pa_stream *s, size_t length, void *userdata );
		static void stream_state_callback ( pa_stream *s, void *userdata );
		static void context_state_callback ( pa_context *c, void *userdata );
		static void initialize_callbacks ( QPulseAudioThread * pulseThread );
		static void context_drain_complete ( pa_context*c, void *userdata );
		static void stream_drain_complete ( pa_stream*s, int success, void *userdata );
		static void stdout_callback ( pa_mainloop_api*a, pa_io_event *e, int fd, pa_io_event_flags_t f, void *userdata );
		static void exit_signal_callback ( pa_mainloop_api*m, pa_signal_event *e, int sig, void *userdata );
		 static void stream_update_timing_callback ( pa_stream *s, int success, void *userdata );
		 static void sigusr1_signal_callback ( pa_mainloop_api*m, pa_signal_event *e, int sig, void *userdata );
		static void pa_source_info_callback ( pa_context *c, const pa_source_info *i, int eol, void *userdata );
		 static void subscribe_callback ( struct pa_context *c, enum pa_subscription_event_type t, uint32_t index, void *userdata );
		static void time_event_callback ( pa_mainloop_api*m, pa_time_event *e, const struct timeval *tv, void *userdata );
		
		static void pa_stream_success_callback(pa_stream *s, int success, void *userdata);
			
		static QMutex * s_audioMutex;
		static SourceContainer s_sourceList;
		static SourceContainer::const_iterator s_sourcePosition;
		int argc;
		char ** argv;	
		static pa_context *context;
		static pa_stream *stream;
		static pa_mainloop_api *mainloop_api;
		static pa_time_event *time_event;
		static float * buffer;
		static size_t buffer_length, buffer_index;
		static pa_threaded_mainloop * mainloop;
		static pa_io_event * stdio_event;
		static char * server;
		static char * stream_name, *client_name, *device;
		static QProjectM_MainWindow ** s_qprojectM_MainWindowPtr; 

		static int verbose;

		static pa_volume_t volume;

		static pa_channel_map channel_map;
		static int channel_map_set;;
		static pa_sample_spec sample_spec ;
				
				
};
#endif