#pragma once

#include <filesystem>

#include <forstio/codec/schema_hash.hpp>
#include <forstio/remote/remote.hpp>

namespace saw {
namespace rmt {
struct File {};
}

template<>
class remote_address<rmt::File> {
private:
	std::filesystem::path path_;
public:
	remote_address(const std::filesystem::path& path__):
		path_{path__}
	{}

	std::string get_path_string() const {
		return path_.string();
	}

	const std::filesystem::path& get_path() const {
		return path_;
	}
};

template<>
class remote<rmt::File> {
private:
	SAW_FORBID_COPY(remote);
	SAW_FORBID_MOVE(remote);

	std::map<std::string, ptr<i_data_server<rmt::File>>> registered_data_servers_;
public:
	remote() = default;

	error_or<own<remote_address<rmt::File>>> parse_address(const std::string_view& path_v){
		return heap<remote_address<rmt::File>>(path_v);
	}

	template<typename Schema, typename Encode>
	error_or<own<data_server<Schema, Encode, rmt::File>>> data_listen(ref<remote_address<rmt::File>> addr){
		auto insert_res = registered_data_servers_.emplace(std::make_pair(addr().get_path_string(),ptr<i_data_server<rmt::File>>{}));
		if(!insert_res.second){
			return make_error<err::already_exists>();
		}

		auto dat_srv = heap<data_server<Schema, Encode, rmt::File>>(*this, addr);
		insert_res.first->second = ptr<i_data_server<rmt::File>>{*dat_srv};
		return dat_srv;
	}

	/**
	 * Internal deregister function
	 */
	error_or<void> deregister_data_server(ptr<i_data_server<rmt::File>> srv){
		return make_error<err::not_implemented>();
	}
};
}