/* -*- Mode: C++; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
/* vim: set et sw=2 ts=2: */
/***************************************************************************
 *            soundplayer.cc
 *
 *  Fri Sep  5 17:31:28 CEST 2014
 *  Copyright 2014 Bent Bisballe Nyeng
 *  deva@aasimon.org
 ****************************************************************************/

/*
 *  This file is part of Kaiman.
 *
 *  Kaiman 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 of the License, or
 *  (at your option) any later version.
 *
 *  Kaiman 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 General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with Kaiman; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA.
 */
#include "soundplayer.h"

#include <ao/ao.h>
#include <sndfile.h>
#include <samplerate.h>

#define BUFSZ 512

SoundPlayer::SoundPlayer()
{
	start();
}

SoundPlayer::~SoundPlayer()
{
	running = false;
	wait();
}

void SoundPlayer::run()
{
	printf("SoundPlayer running\n");

	ao_initialize();

	ao_sample_format sf;
	memset(&sf, 0, sizeof(sf));
	sf.bits = 16;
	sf.rate = 48000;
	sf.channels = 2;
	sf.byte_format = AO_FMT_NATIVE;

	ao_device *dev = ao_open_live(ao_default_driver_id(), &sf, 0);

	running = true;

	short s[BUFSZ];
	while(running)
	{
		{ // Check for new Selection.
			QMutexLocker lock(&mutex);
			while(queue.size())
			{
				active.append(queue.front());
				queue.pop_front();
			}
		}

		memset(s, 0, BUFSZ * sizeof(short));

		QList<QueueItem>::iterator it = active.begin();
		while(it != active.end())
		{
			QueueItem &item = *it;

			for(size_t i = 0; i < BUFSZ; i++)
			{
				if(item.pos >= item.size)
				{
					it = active.erase(it);
					goto nextitem;
				}
				s[i] += item.samples[item.pos] * 32536 * 0.5;
				item.pos++;
			}

			it++;

		nextitem:
			int a = 1;(void)a;
		}

		ao_play(dev, (char*)s, BUFSZ * sizeof(short));
	}

	ao_close(dev);
	ao_shutdown();
}

void SoundPlayer::playFile(QString file)
{
	printf(" - playFile(%s)\n", file.toStdString().c_str());

	SNDFILE *fh;
	SF_INFO sf_info;

	fh = sf_open(file.toStdString().c_str(), SFM_READ, &sf_info);
	if(!fh)
	{
		printf("Load error '%s'\n", file.toStdString().c_str());
		return;
	}

	size_t size = sf_info.frames * sf_info.channels;
	float *data = new float[size];
	sf_read_float(fh, data, size);
	sf_close(fh);

	if(sf_info.channels != 2)
	{
		float* stereo_data = new float[sf_info.frames * 2];
		for(int i = 0; i < sf_info.frames; ++i)
		{
			int c = 0;
			for(;c < sf_info.channels && c < 2; ++c)
			{
				stereo_data[i * 2 + c] = data[i * sf_info.channels + c];
			}
			int last = c - 1;
			for(;c < 2; ++c)
			{
				stereo_data[i * 2 + c] = data[i * sf_info.channels + last];
			}
		}
		delete[] data;
		data = stereo_data;
		size = sf_info.frames * 2;
	}

	if(sf_info.samplerate != 48000)
	{
		double ratio = 48000.0 / sf_info.samplerate;
		std::size_t resampled_size = sf_info.frames * 2 * ratio;
		float *resampled_data = new float[resampled_size + 1];

		SRC_DATA s{};
		s.data_in = data;
		s.input_frames = sf_info.frames;

		s.data_out = resampled_data;
		s.output_frames = resampled_size + 1;

		s.src_ratio = ratio;

		src_simple(&s, SRC_SINC_BEST_QUALITY, 2);
		delete[] data;
		data = resampled_data;
		size = s.output_frames_gen * 2;
		printf("size: %d\n", (int)size);
	}

	QueueItem qi;
	qi.samples = data;
	qi.pos = 0;
	qi.size = size;

	{
		QMutexLocker lock(&mutex);
		queue.append(qi);
	}
}