#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::id<schema::UInt64> next_id{0u};
	{
		auto eov = rpc_server.template call<"increment">(saw::data<schema::UInt64>{1u});
		if(eov.is_error()){
			auto& err = eov.get_error();
			std::cerr<<"Error: "<<err.get_category()<<" : "<<err.get_message()<<std::endl;
			return -2;
		}
		next_id = eov.get_value();
	}
	{
		auto eov = rpc_server.template call<"increment">(next_id);
		if(eov.is_error()){
			auto& err = eov.get_error();
			std::cerr<<"Error: "<<err.get_category()<<" : "<<err.get_message()<<std::endl;
			return -2;
		}
		auto& val = eov.get_value();
		std::cout<<"Value: "<<val.get_value()<<std::endl;
	}

	return 0;
}