#include "./sycl_basic.hpp"
#include <forstio/codec/schema.hpp>

int main(){
	saw::remote<saw::rmt::Sycl> remote_ctx;

	saw::own<saw::remote_address<saw::rmt::Sycl>> rmt_addr{};
	
	saw::event_loop loop;
	saw::wait_scope wait{loop};

	remote_ctx.resolve_address().then([&](auto addr){
		rmt_addr = std::move(addr);
	}).detach();

	wait.poll();
	if(!rmt_addr){
		return -1;
	}

	auto rpc_server = listen_basic_sycl(remote_ctx, *rmt_addr);
	saw::rpc_client<schema::BasicInterface, saw::encode::Native, saw::rmt::Sycl> client{rpc_server};

	saw::id<schema::Array<schema::UInt64>> id_zero{0u};
	saw::data<schema::Array<schema::UInt64>, saw::encode::Native> ex_data{1u};
	ex_data.at(0u).set(50u);
	{
		auto eov = client.template call<"increment">(
			ex_data
		);
		if(eov.is_error()){
			auto& err = eov.get_error();
			std::cerr<<"Error: "<<err.get_category()<<" : "<<err.get_message()<<std::endl;
			return -2;
		}
		id_zero = eov.get_value();
	}
	{
		auto rmt_data = rpc_server.template request_data<schema::Array<schema::UInt64>>(id_zero);
		auto eo_rd = rmt_data.wait();
		if(eo_rd.is_error()){
			auto& err = eo_rd.get_error();
			std::cerr<<"Error: "<<err.get_category()<<" : "<<err.get_message()<<std::endl;
			return -2;
		}

		auto& val = eo_rd.get_value();
		std::cout<<"Values: "<<val.size()<<"\n";
		for(uint64_t i = 0; i < val.size(); ++i){
			std::cout<<val.at(i).get()<<'\t';
		}
		std::cout<<std::endl;
	}
	saw::id<schema::Array<schema::UInt64>> id_one{1u};
	{
		auto eov = client.template call<"increment">(id_zero);
		if(eov.is_error()){
			auto& err = eov.get_error();
			std::cerr<<"Error: "<<err.get_category()<<" : "<<err.get_message()<<std::endl;
			return -2;
		}
		id_one = eov.get_value();
	}
	{
		auto rmt_data = rpc_server.template request_data<schema::Array<schema::UInt64>>(id_one);
		auto eo_rd = rmt_data.wait();
		if(eo_rd.is_error()){
			auto& err = eo_rd.get_error();
			std::cerr<<"Error: "<<err.get_category()<<" : "<<err.get_message()<<std::endl;
			return -2;
		}

		auto& val = eo_rd.get_value();
		std::cout<<"Values: "<<val.size()<<"\n";
		for(uint64_t i = 0; i < val.size(); ++i){
			std::cout<<val.at(i).get()<<'\t';
		}
		std::cout<<std::endl;
	}

	return 0;
}