/** @file
 * @author Edouard DUPIN 
 * @copyright 2015, Edouard DUPIN, all right reserved
 * @license APACHE v2.0 (see license file)
 */

#include <river/river.h>
#include <river/Manager.h>
#include <river/Interface.h>
#include <etk/etk.h>
#include <unistd.h>


static const std::string configurationRiver =
		"{\n"
		"	speaker:{\n"
		"		io:'output',\n"
		"		map-on:{\n"
		"			interface:'auto',\n"
		"			name:'default',\n"
		"		},\n"
		"		frequency:0,\n"
		"		channel-map:['front-left', 'front-right'],\n"
		"		type:'auto',\n"
		"		nb-chunk:1024,\n"
		"		volume-name:'MASTER'\n"
		"	}\n"
		"}\n";

void onDataNeeded(void* _data,
                  const std11::chrono::system_clock::time_point& _time,
                  size_t _nbChunk,
                  enum audio::format _format,
                  uint32_t _frequency,
                  const std::vector<audio::channel>& _map) {
	static double phase = 0;
	if (_format != audio::format_int16) {
		std::cout << "[ERROR] call wrong type ... (need int16_t)" << std::endl;
	}
	int16_t* data = static_cast<int16_t*>(_data);
	double baseCycle = 2.0*M_PI/(double)48000 * (double)550;
	for (int32_t iii=0; iii<_nbChunk; iii++) {
		for (int32_t jjj=0; jjj<_map.size(); jjj++) {
			data[_map.size()*iii+jjj] = cos(phase) * 30000;
		}
		phase += baseCycle;
		if (phase >= 2*M_PI) {
			phase -= 2*M_PI;
		}
	}
}

int main(int _argc, char **_argv) {
	// the only one init for etk:
	etk::init(_argc, _argv);
	for (int32_t iii=0; iii<_argc ; ++iii) {
		std::string data = _argv[iii];
		if (    data == "-h"
		     || data == "--help") {
			std::cout << "Help : " << std::endl;
			std::cout << "    ./xxx ---" << std::endl;
			exit(0);
		}
	}
	// initialize river interface
	river::initString(configurationRiver);
	// Create the River manager for tha application or part of the application.
	std11::shared_ptr<river::Manager> manager = river::Manager::create("river_sample_read");
	// create interface:
	std11::shared_ptr<river::Interface> interface;
	//Get the generic input:
	interface = manager->createOutput(48000,
	                                  std::vector<audio::channel>(),
	                                  audio::format_int16,
	                                  "speaker");
	if(interface == nullptr) {
		std::cout << "nullptr interface" << std::endl;
		return -1;
	}
	// set callback mode ...
	interface->setOutputCallback(std11::bind(&onDataNeeded,
	                                         std11::placeholders::_1,
	                                         std11::placeholders::_2,
	                                         std11::placeholders::_3,
	                                         std11::placeholders::_4,
	                                         std11::placeholders::_5,
	                                         std11::placeholders::_6));
	// start the stream
	interface->start();
	// wait 10 second ...
	sleep(10);
	// stop the stream
	interface->stop();
	// remove interface and manager.
	interface.reset();
	manager.reset();
	return 0;
}