package luan.lib.rpc;

import java.net.Socket;
import java.util.List;
import java.util.ArrayList;


public class RpcServer extends RpcCon {

	public RpcServer(Socket socket)
		throws RpcError
	{
		super(socket);
	}

	public RpcCall read()
		throws RpcError
	{
		List list = readJson();
		String cmd = (String)list.remove(0);
		Object[] args = list.toArray();
		return new RpcCall(inBinary,lenBinary,cmd,args);
	}

	public void write(RpcResult result)
		throws RpcError
	{
		List list = new ArrayList();
		list.add(true);
		for( Object val : result.returnValues ) {
			list.add(val);
		}
		write(result.in,result.lenIn,list);
	}

	public void write(RpcException ex)
		throws RpcError
	{
		List list = new ArrayList();
		list.add(false);
		for( Object val : ex.values ) {
			list.add(val);
		}
		write(ex.in,ex.lenIn,list);
	}

}