package test.editortest;

import java.io.IOException;
import java.util.LinkedList;

import rep.REP;
import rep.REPCommand;
import rep.Session;
import rep.channel.REPSelectionKey;
import rep.channel.REPSocketChannel;
import rep.handler.REPNode;
import rep.handler.Translator;
import rep.optimizers.NullOptimizer;

public class TestMerger extends REPNode{
	Translator trans;
	private int seq;
	private LinkedList<REPCommand> commandList;
	private LinkedList<REPCommand> othersCommandList;
	
	public static void main(String[] args){
		TestMerger test = new TestMerger();
		test.setCommands();
		test.start();
	}

	public TestMerger(){
		eid = 1;
		sid = 1;
		trans = new Translator(eid, new NullOptimizer());
	}
	
	private void setCommands() {
		commandList = new LinkedList<REPCommand>();
		commandList.add(new REPCommand(REP.REPCMD_INSERT, sid, eid, seq++, 10, "AAAAA"));
		commandList.add(new REPCommand(REP.REPCMD_INSERT, sid, eid, seq++, 10, "BBBBB"));
		othersCommandList = new LinkedList<REPCommand>();
		othersCommandList.add(new REPCommand(REP.REPCMD_INSERT, sid, eid+1, seq++, 10, "CCCCC"));
	}

	private void start() {
		for(REPCommand command : commandList){
			trans.transSendCmd(command);
		}
		for(REPCommand command : othersCommandList){
			trans.transSendCmd(command);
		}
		for(int i = 0; i < commandList.size(); i++){
			trans.catchOwnCommand(this);
			System.out.println();
		}
	}

	@Override
	public void cancel(REPSocketChannel<REPCommand> channel1) {
		// TODO Auto-generated method stub
		
	}

	@Override
	public void checkWaitingCommandInMerge() {
		// TODO Auto-generated method stub
		
	}

	@Override
	public void forwardedCommandManage(REPCommand command) {
		// TODO Auto-generated method stub
		
	}

	@Override
	public String getLocalHostName() {
		// TODO Auto-generated method stub
		return null;
	}

	@Override
	public void handle(REPCommand command, REPSelectionKey<REPCommand> key)
			throws IOException {
		// TODO Auto-generated method stub
		
	}

	@Override
	public boolean isMerging() {
		// TODO Auto-generated method stub
		return false;
	}

	@Override
	public void joinAck(REPCommand sendCommand, int sid) {
		// TODO Auto-generated method stub
		
	}

	@Override
	public boolean manage(REPCommand command) {
		// TODO Auto-generated method stub
		return false;
	}

	@Override
	public void selectSession(REPCommand sendCommand, Session session) {
		// TODO Auto-generated method stub
		
	}

	@Override
	public void send(REPCommand command) {
		// TODO Auto-generated method stub
		Logger.print(command);
	}

	@Override
	public void sendWithSeq(REPCommand command) {
		// TODO Auto-generated method stub
		
	}

	@Override
	public int seq() {
		// TODO Auto-generated method stub
		return 0;
	}

	@Override
	public void setQuit2(REPCommand receivedCommand) {
		// TODO Auto-generated method stub
		
	}
}