package rep.handler;

import java.io.IOException;

import rep.REPCommand;
import rep.ServerMainLoop;
import rep.Session;
import rep.SessionManager;
import rep.channel.REPSelectionKey;
import rep.channel.REPSocketChannel;

public class FirstConnector extends Forwarder {

	public FirstConnector(SessionManager manager) {
		super(manager);
	}
	
	public void cancel(REPSocketChannel<REPCommand> socketChannel) {
		manager.remove(socketChannel);
	}

	public void handle(REPSelectionKey<REPCommand> key) throws IOException {
		/*
		 * 接続要求は、EditorかSlave Editorで、
		 * 　　　join, put, sm_join
		 * が来る。それ以外はエラー。master もありか?
		 *      sm_join_ack
		 */
		REPNode fw;
		REPSocketChannel<REPCommand> channel = key.channel1();
		REPCommand command = channel.read();
		ServerMainLoop.logger.writeLog("FirstConnector: command = " + command);
		switch(command.cmd) {
		case SMCMD_JOIN: 
		{
			//どのSessionにも属さないエディタをリストに追加
			//エディタとchannelは1対1 (ではないかも)
			//エディタが新しくputする場合は新しくソケットを作る
			//   1対1でない場合は、multiplexerを挿めば良い
			REPNode editor = manager.newEditor(channel);
			editor.setHost(manager.myHost());
			command.eid = editor.eid;
			command.sid = -1;
			editor.setSID(-1);
			fw = editor;
			break;
		}
		case SMCMD_PUT:
		{
			//  新しいeditorとsessionをここで作る。eid,sidは、
			//  session manager IDが付いているので、global unique
			REPNode editor = manager.newEditor(channel);
			Session session = manager.newSession(editor);
			session.setName(command.string);
			editor.setName(command.string);
			editor.setSID(session.getSID());
			command.eid = editor.eid;
			command.sid = editor.sid;
			fw = editor;
			break;
		}
		case SMCMD_SM_JOIN:
		{
			fw = new Dispatcher(manager);
			manager.addWaitingSessionManager(fw, command);
			break;
		}
		case SMCMD_SM_JOIN_ACK:
			manager.setSessionManagerID(command.sid);
			manager.afterConnect();
			fw = new Dispatcher(manager);
			manager.setParent(fw);
			break;
		default: throw new IOException();
		}
		//myHost を設定。
		//立ち上げ時にやるとlocalhostしか取れない
		if(manager.myHost() == null) manager.setMyHostName(getLocalHostName());
		fw.setMode(command.cmd);
		fw.setHost(manager.myHost());
		manager.registerChannel(channel, fw);
		manager.sessionManage(fw, command);
	
	}

}