java()
local RpcLuan = require "java:luan.modules.RpcLuan"
local Luan = require "luan:Luan.luan"
local error = Luan.error
local set_metatable = Luan.set_metatable or error()
local Io = require "luan:Io.luan"
local Thread = require "luan:Thread.luan"


local M = {}

M.port = 9101

M.call = RpcLuan.call  -- Rpc.call(socket,fn_name,...)

M.functions = {}

function M.respond(socket,fns)
	RpcLuan.respond( socket, fns or M.functions )
end

function M.remote_socket(socket_uri)
	local mt = {}
	function mt.__index(_,key)
		return function(...)
			local socket = Io.uri(socket_uri)
			return M.call(socket,key,...)
		end
	end
	local t = {}
	set_metatable(t,mt)
	return t
end

function M.remote(domain)
	local socket = "socket:" .. domain .. ":" .. M.port
	return M.remote_socket(socket)
end

function M.responder(fns)
	local server = Io.socket_server(M.port)
	return function()
		local socket = server()
		M.respond(socket,fns)
	end
end

--[[
function M.serve(port,fns)
	local server = Io.socket_server(port)
	while true do
		local socket = server()
		Thread.fork(function() M.respond(socket,fns) end)
	end
end
]]

return M