#pragma once

#include "transfer.hpp"

#include <forstio/error.hpp>

namespace saw {
namespace easy {
template<typename Sch, typename FileEnc, typename Enc = FORSTIO_DEFAULT_DATA_ENCODING>
error_or<void> encode_and_write_file(const std::filesystem::path& p_, const data<Sch,Enc>& data_){
	data<Sch, FileEnc> dat;
	{
		codec<Sch, FileEnc> cdc;
		auto eov = cdc.encode(data_,dat);
		if(eov.is_error()){
			return eov;
		}
	}

	remote<rmt::File> file_remote;
	auto eo_addr = file_remote.parse_address(p_);
	if(eo_addr.is_error()){
		return std::move(eo_addr.get_error());
	}
	auto& addr = eo_addr.get_value();

	auto eo_srv = file_remote.template data_listen<Sch,FileEnc>({*addr});
	if(eo_srv.is_error()){
		return std::move(eo_srv.get_error());
	}
	auto& srv = eo_srv.get_value();
	id<Sch> fid{0u};

	auto eo_write = srv->send(dat, fid);
	if(eo_write.is_error()){
		return eo_write;
	}

	return make_void();
}

template<typename Sch, typename FileEnc, typename Enc = FORSTIO_DEFAULT_DATA_ENCODING>
error_or<data<Sch,Enc>> read_and_decode_file(const std::filesystem::path& p_){
	data<Sch, Enc> dat;

	remote<rmt::File> file_remote;
	auto eo_addr = file_remote.parse_address(p_);
	if(eo_addr.is_error()){
		return std::move(eo_addr.get_error());
	}
	auto& addr = eo_addr.get_value();

	auto eo_srv = file_remote.template data_listen<Sch,FileEnc>({*addr});
	if(eo_srv.is_error()){
		return std::move(eo_srv.get_error());
	}
	auto& srv = eo_srv.get_value();
	id<Sch> fid{0u};

	auto eo_read = srv->receive(fid);
	if(eo_read.is_error()){
		return std::move(eo_read.get_error());
	}
	auto& read = eo_read.get_value();

	{
		codec<Sch, FileEnc> cdc;
		auto eov = cdc.decode(read,dat);
		if(eov.is_error()){
			return std::move(eov.get_error());
		}
	}

	return dat;
}

}
}