/**

 * DJM-Fix

 * Copyright © 2020 František Kučera (Frantovo.cz, GlobalCode.info)

 *

 * This program 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, version 3 of the License.

 *

 * This program 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 this program. If not, see <http://www.gnu.org/licenses/>.

 */

#include <iostream>

#include <stdexcept>

#include <thread>

#include <mutex>

#include <atomic>

#include <alsa/asoundlib.h>

#include "AlsaBridge.h"

namespace djmfix {

namespace alsa {

class AlsaBridgeImpl : public AlsaBridge, private djmfix::MidiSender {

private:

	djmfix::DJMFix* djmFix;

	snd_rawmidi_t* input;

	snd_rawmidi_t* output;

	std::thread receivingThread;

	std::recursive_mutex midiMutex;

	std::atomic<bool> stopped{false};

	void run() {

		while (!stopped) {

			{

				std::lock_guard<std::recursive_mutex> lock(midiMutex);

				// TODO: poll

				uint8_t buffer[256];

				ssize_t length = snd_rawmidi_read(input, buffer, sizeof (buffer));

				if (length > 0 && length <= sizeof (buffer)) {

					// TODO: multiple messages combined together?

					djmFix->receive(MidiMessage(buffer, buffer + length));

				}

			}

			std::this_thread::sleep_for(std::chrono::milliseconds(100));

		}

	}

public:

		if (djmFix == nullptr) throw std::invalid_argument("need a djmFix for AlsaBridge");

		int error = snd_rawmidi_open(&input, &output, deviceName.c_str(), SND_RAWMIDI_NONBLOCK);

		if (error) throw std::invalid_argument("unable to open ALSA device");

		djmFix->setMidiSender(this);

	}

	virtual ~AlsaBridgeImpl() {

		// TODO: do not use raw/exclusive access to the device

		snd_rawmidi_close(input);

		snd_rawmidi_close(output);

		std::cerr << "~AlsaBridgeImpl()" << std::endl; // TODO: do not mess STDIO

	}

	virtual void start() override {

		djmFix->start();

		receivingThread = std::thread(&AlsaBridgeImpl::run, this);

	}

	virtual void stop() override {

		stopped = true;

		receivingThread.join();

		djmFix->stop();

	}

	virtual void send(MidiMessage midiMessage) override {

		std::lock_guard<std::recursive_mutex> lock(midiMutex);

		ssize_t length = snd_rawmidi_write(output, midiMessage.data(), midiMessage.size());

		std::cerr << "AlsaBridgeImpl::send(): length = " << length << std::endl; // TODO: do not mess STDIO

	}

};

AlsaBridge* create(djmfix::DJMFix* djmFix, const std::string& deviceName) {

	return new AlsaBridgeImpl(djmFix, deviceName);

}

}

}