//////////////////////////////////////////////////////////////////////
// This file is part of Remere's Map Editor
//////////////////////////////////////////////////////////////////////
// Remere's Map Editor 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 3 of the License, or
// (at your option) any later version.
//
// Remere's Map Editor 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/>.
//////////////////////////////////////////////////////////////////////

#ifndef _RME_NET_CONNECTION_H_
#define _RME_NET_CONNECTION_H_

#include "position.h"

#include <string>
#include <vector>
#include <cstdint>
#include <thread>
#include <mutex>

struct NetworkMessage {
	NetworkMessage();

	void clear();
	void expand(const size_t length);

	//
	template <typename T>
	T read() {
		// Check if we have enough data left to read
		if (position + sizeof(T) > buffer.size()) {
			throw std::runtime_error("Buffer underflow - attempted to read past buffer end");
		}
		T& value = *reinterpret_cast<T*>(&buffer[position]);
		position += sizeof(T);
		return value;
	}

	template <typename T>
	void write(const T& value) {
		expand(sizeof(T));
		memcpy(&buffer[position], &value, sizeof(T));
		position += sizeof(T);
	}

	//
	std::vector<uint8_t> buffer;
	size_t position;
	size_t size;
};

template <>
std::string NetworkMessage::read<std::string>();
template <>
Position NetworkMessage::read<Position>();
template <>
void NetworkMessage::write<std::string>(const std::string& value);
template <>
void NetworkMessage::write<Position>(const Position& value);

class NetworkConnection {
private:
	NetworkConnection();
	NetworkConnection(const NetworkConnection& copy) = delete;

public:
	~NetworkConnection();

	static NetworkConnection& getInstance();

	bool start();
	void stop();

	boost::asio::io_context& get_service();

private:
	boost::asio::io_context* service;
	std::thread thread;
	bool stopped;
};

#endif