// ==============================================================
//	This file is part of Glest (www.glest.org)
//
//	Copyright (C) 2001-2008 Martio Figueroa
//
//	You can redistribute this code and/or modify it under
//	the terms of the GNU General Public License as published
//	by the Free Software Foundation; either version 2 of the
//	License, or (at your option) any later version
// ==============================================================

#include "sound_renderer.h"

#include "core_data.h"
#include "config.h"
#include "sound_interface.h"
#include "factory_repository.h"
#include "util.h"
#include "leak_dumper.h"

using namespace Shared::Util;
using namespace Shared::Graphics;
using namespace Shared::Sound;

namespace Glest{ namespace Game{

const int SoundRenderer::ambientFade= 6000;
const float SoundRenderer::audibleDist= 50.f;

// =====================================================
// 	class SoundRenderer
// =====================================================

SoundRenderer::SoundRenderer(){
    SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s %d]\n",__FILE__,__FUNCTION__,__LINE__);

    soundPlayer = NULL;
	loadConfig();

	runThreadSafe = false;
	SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s %d]\n",__FILE__,__FUNCTION__,__LINE__);
}

void SoundRenderer::init(Window *window){
    SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s %d]\n",__FILE__,__FUNCTION__,__LINE__);

	SoundInterface &si= SoundInterface::getInstance();
	FactoryRepository &fr= FactoryRepository::getInstance();
	Config &config= Config::getInstance();
	runThreadSafe = config.getBool("ThreadedSoundStream","false");

    //if(soundPlayer == NULL) {
        SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s %d]\n",__FILE__,__FUNCTION__,__LINE__);
        si.setFactory(fr.getSoundFactory(config.getString("FactorySound")));

        stopAllSounds();

        soundPlayer= si.newSoundPlayer();

        SoundPlayerParams soundPlayerParams;
        soundPlayerParams.staticBufferCount= config.getInt("SoundStaticBuffers");
        soundPlayerParams.strBufferCount= config.getInt("SoundStreamingBuffers");
        soundPlayer->init(&soundPlayerParams);
	//}

	SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s %d]\n",__FILE__,__FUNCTION__,__LINE__);
}

SoundRenderer::~SoundRenderer(){
    SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s %d]\n",__FILE__,__FUNCTION__,__LINE__);

    stopAllSounds();

	delete soundPlayer;

	SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s %d]\n",__FILE__,__FUNCTION__,__LINE__);

	soundPlayer = NULL;

	SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s %d]\n",__FILE__,__FUNCTION__,__LINE__);
}

SoundRenderer &SoundRenderer::getInstance(){
	static SoundRenderer soundRenderer;
	return soundRenderer;
}

void SoundRenderer::update(){
    if(soundPlayer != NULL) {
    	if(runThreadSafe == true) mutex.p();
        soundPlayer->updateStreams();
        if(runThreadSafe == true) mutex.v();
    }
}

// ======================= Music ============================

void SoundRenderer::playMusic(StrSound *strSound){
	strSound->setVolume(musicVolume);
	strSound->restart();
	if(soundPlayer != NULL) {
		if(runThreadSafe == true) mutex.p();
        soundPlayer->play(strSound);
        if(runThreadSafe == true) mutex.v();
	}
}

void SoundRenderer::setMusicVolume(StrSound *strSound){
	strSound->setVolume(musicVolume);
}

void SoundRenderer::stopMusic(StrSound *strSound){
    if(soundPlayer != NULL) {
    	if(runThreadSafe == true) mutex.p();
        soundPlayer->stop(strSound);
		if(strSound->getNext() != NULL) {
			soundPlayer->stop(strSound->getNext());
		}
		if(runThreadSafe == true) mutex.v();
    }
}

// ======================= Fx ============================

void SoundRenderer::playFx(StaticSound *staticSound, Vec3f soundPos, Vec3f camPos){
	if(staticSound!=NULL){
		float d= soundPos.dist(camPos);

		if(d < audibleDist){
			float vol= (1.f-d/audibleDist)*fxVolume;
			float correctedVol= log10(log10(vol*9+1)*9+1);
			staticSound->setVolume(correctedVol);

			if(soundPlayer != NULL) {
				if(runThreadSafe == true) mutex.p();
                soundPlayer->play(staticSound);
                if(runThreadSafe == true) mutex.v();
			}
		}
	}
}

void SoundRenderer::playFx(StaticSound *staticSound){
	if(staticSound!=NULL){
		staticSound->setVolume(fxVolume);
		if(soundPlayer != NULL) {
			if(runThreadSafe == true) mutex.p();
            soundPlayer->play(staticSound);
            if(runThreadSafe == true) mutex.v();
		}
	}
}

// ======================= Ambient ============================

void SoundRenderer::playAmbient(StrSound *strSound){
	strSound->setVolume(ambientVolume);
	if(soundPlayer != NULL) {
		if(runThreadSafe == true) mutex.p();
        soundPlayer->play(strSound, ambientFade);
        if(runThreadSafe == true) mutex.v();
	}
}

void SoundRenderer::stopAmbient(StrSound *strSound){
    if(soundPlayer != NULL) {
    	if(runThreadSafe == true) mutex.p();
        soundPlayer->stop(strSound, ambientFade);
        if(runThreadSafe == true) mutex.v();
    }
}

// ======================= Misc ============================

void SoundRenderer::stopAllSounds(){
    if(soundPlayer != NULL) {
    	mutex.p();
        soundPlayer->stopAllSounds();
        mutex.v();
    }
}

void SoundRenderer::loadConfig(){
	Config &config= Config::getInstance();

	fxVolume= config.getInt("SoundVolumeFx")/100.f;
	musicVolume= config.getInt("SoundVolumeMusic")/100.f;
	ambientVolume= config.getInt("SoundVolumeAmbient")/100.f;
}

}}//end namespace