package rep;

import java.util.LinkedList;
import java.util.List;
import rep.channel.REPSocketChannel;
import rep.handler.PacketSet;
import rep.optimizers.*;
import rep.translator.Translator;
import rep.translator.TranslatorImpl;

public class Editor extends Forwarder {

	private Translator translator;
	private List<REPCommand> sentList = new LinkedList<REPCommand>();
	// REPCommands we are going to send to the next editor
	private REPCommandOptimizer optimizer;
	//private REPCommand quit2 = null;
	private SessionManager manager;
	private REPCommand quit2=null;

	public Editor(SessionManager manager,boolean doOptimize,int editorNo){
		super(manager);
		this.manager = manager;
		eid = editorNo;
		translator = new TranslatorImpl(eid);
		if (doOptimize) optimizer = new DeleteInsertOptimizer(); //タカノがつくったおぷてぃまいざ
		else            optimizer = new NullOptimizer();         //なにもしないけどOptimizer.
		
	}

	public Editor(SessionManager manager,int editorNo, REPSocketChannel<REPCommand> channel){
		this(manager,false,editorNo);
		this.channel = channel;
		setHostAndPort(channel);
	}

	public void translate(Editor nextEditor, REPCommand command){
		if(command.eid == nextEditor.getEID()){
			nextEditor.checkReturnedCommand(command);
		} else if(command.eid == eid){
			//エディタからの新たな編集コマンド
			sentList.add(command);
			assert(sentList.size()<limit);
			translator.transSendCmd(command);
			nextEditor.send(command);
			return;
		}else if(command.eid == REP.MERGE_EID.id){
			//マージコマンドが返ってきた
			if(translator.checkMergeConflict(command)){
				//マージ中にエディタからの割り込みがあった場合
				if (optimizedSend(translator.getMergeAgain())) {
					endMerge();
					return;
				}
			} else
				endMerge();
		}else{
			//他のエディタからの編集コマンド
			if(!isMerging()) {
				translator.transReceiveCmd(nextEditor,command);
				return;
			}
			manager.addWaitingCommand(new PacketSet(getChannel(), this, command));
		}
		return;
	}

	boolean merge(REPCommand command) {
		REPCommand prev = translator.prev();
		if(prev==null) return false;
		assert(prev.eid==command.eid);
		//マージして送信
		return translator.catchOwnCommand(this);
	}

	void checkReturnedCommand(REPCommand command) {
		if(sentList.size() > 0){
			if(sentList.get(0).seq == command.seq){
				sentList.remove(0);
				if (quit2!=null&&sentList.size()==0) {
					send(quit2);
					manager.remove(this);
				}
			}else{
				System.out.println("Editor.checkReturnedCommand() : command = " + command);
				assert(false);
			}
		}
		// START_MERGE を送る
		REPCommand cmd = new REPCommand(REP.SMCMD_START_MERGE,command.sid,REP.SM_EID.id,seq(),0,"");
		send(cmd);
		// Session Manager 側で、このeditorへの他のeditorからの
		// 入力を止めて、merge にそなえる。merge は、eidtor 側から
		// ACKが来てから始まる。
		translator.startMerge(cmd);
		return;
	}

	@Override
	public void setQuit2(REPCommand cmd) {
		if (sentList.size()==0) {
			send(cmd);
			manager.remove(this);
		}
		// do not send quit2 until we received all pending
		// command
		quit2 = cmd;
	}
	
	private void setHostAndPort(REPSocketChannel<REPCommand> myChannel2) {
		//host = myChannel2.socket().getRemoteSocketAddress().toString();
		
	}




	@Override
	public void setEID(int eid) {
		this.eid = eid;
		translator.setEid(eid);
	}
	
	public String toString(){
		return ("Editor eid="+eid+" sid="+sid+" " + host  + ":" + file);
	}

	public boolean isMerging() {
		return translator.isMerging();
	}

	
	/**
	 * Sent optimized merged command list
	 * @param output
	 * @return if any sent commands output 
	 */
	public boolean optimizedSend(LinkedList<REPCommand> output) {
		List<REPCommand> output1 = optimizer.optimize(output);
		if (output1.size()==0) return false;
		for(REPCommand c:output1) {
			REPCommand m = new REPCommand(c);
			m.setEID(REP.MERGE_EID.id);
			m.setSEQID(seq());
			send(m);
		}				
		return true;
	}

	void endMerge() {
		if(translator.isMerging()) return;
		REPCommand mergeEnd = new REPCommand(REP.SMCMD_END_MERGE,eid,sid,seq(),0,"");
		send(mergeEnd);
		translator.endMerge();
	}

	@Override
	public boolean manage(REPCommand receivedCommand) {
	
		switch(receivedCommand.cmd){
		// Editor Command
		
		case REPCMD_DELETE:
		case REPCMD_INSERT:
		case REPCMD_NOP:
		{
			translate((Editor)next, receivedCommand);
			break;
		}

		case SMCMD_START_MERGE_ACK:
		{
			// マージの処理と次のエディタへコマンドを送信する処理
			translator.mergeAck();
			if (!merge(receivedCommand)) {
				// nothing to do, send END_MERGE
				endMerge();
			}
			break;
		}
		case SMCMD_QUIT:
		{
			next.send(receivedCommand);
			break;
		}
		case SMCMD_QUIT_2:
		{
			Forwarder editor1 = getNextForwarder();
			// don't send quit2 to the editor until all pending
			// merge is processed.
			editor1.setQuit2(receivedCommand);
			break;
		}
		default:
			return false;
		}
		return true;
	}
	
	
}