package rep.net;

import java.io.IOException;
import java.net.InetSocketAddress;
import rep.REPCommand;
import rep.REPPacketReceive;
import rep.REPPacketSend;
import rep.channel.REPSocketChannel;

public class REPNet {
	private REPSocketChannel<REPCommand> sc;
	public REPPacketReceive repreceive;
	private REPPacketSend repsend;

	public void sm_connect(String host, int port){
		//int port = 8765;
		//String host = "localhost";
		InetSocketAddress addr = new InetSocketAddress(host, port);
		try {
			sc = REPSocketChannel.<REPCommand>create();
			sc.configureBlocking(true);
			sc.connect(addr);
			while(!sc.finishConnect()){
				System.out.println("afro");
			}
		}catch (IOException e) {
			e.printStackTrace();
		}
		repreceive = new REPPacketReceive(sc);
		repsend = new REPPacketSend(sc);
	}

	public void send(REPCommand command) {
		repsend.send(command);
	}
}