package test.sematest;


import java.util.LinkedList;

import rep.REP;
import rep.REPCommand;
import rep.SessionManager;
import rep.SessionManagerEvent;
import rep.channel.REPServerSocketChannel;

public class TestInterManagerSession extends TestSessionManager {

	/*
	 * All test is performed in localhost, so all session manager
	 * should have differenct port number each other.
	 * Test Pattern List
	 *    Connect port for each editor
	 *    Master/client flag for each editor
	 *    Editor or slave session manager must be started by
	 *      master session managers using syncExec.
	 */

	public int slavePort[] = {masterPort,masterPort,masterPort};
	public int editorPort[] = {masterPort,masterPort+1,masterPort+2};
	public boolean editorMaster[] = {true,false,false,false};	
	private LinkedList<REPCommand> editorStartCmds;

	private SessionManagerEvent ev2[] = {
			new SessionManagerEvent() {
				public void exec(SessionManager manager) {	
					for(TestEditor editor:editors) {
						if(editor.getPort()==manager.getPort()) {
							logger.writeLog("Start client "+editor);
							editor.start();
						}
					}
					int i = sessionManagers.length;
					for(SessionManager slave:slaveSessionManagers) {
						if (slave.getParentPort()==masterPort) {
							logger.writeLog("Start slave "+slave);
							i = startSessionManager(slave,i,masterPort + i);
						}
					}
				}
			},
			new SessionManagerEvent() {
				public void exec(SessionManager manager) {	
					manager.connectSession(host);
					for(TestEditor editor:editors) {
						if(editor.getPort()==manager.getPort()) {
							logger.writeLog("Start client "+editor);
							editor.start();
						}
					}
				}
			},
			new SessionManagerEvent() {
				public void exec(SessionManager manager) {	
					manager.connectSession(host);
					for(TestEditor editor:editors) {
						if(editor.getPort()==manager.getPort()) {
							logger.writeLog("Start client "+editor);
							editor.start();		
							editors[0].setCommand(editorStartCmds);
						}
					}
				}
			}
	};

	/*
	 * Create all editors, master session managers and slave session 
	 * managers with specified port. All instances are not started yet.
	 */

	public TestInterManagerSession(int sm, int ss, int e) {
		super(sm,ss,e);

		sessionManagers = new SessionManager[sm];
		slaveSessionManagers = new SessionManager[ss];
		editors = new TestEditor[e];
		for(int i=0;i<sm;i++) {
			sessionManagers[i] = new SessionManager(); 	
		}
		for(int i=0;i<ss;i++) {
			int port = slavePort[i%slavePort.length];
			slaveSessionManagers[i] = new SessionManager(); 
			slaveSessionManagers[i].setParentPort(port);
		}
		for(int i=0;i<e;i++) {
			int port = editorPort[i%editorPort.length];
			boolean master = editorMaster[i%editorMaster.length];
			// TestEditor extends Thread
			editors[i] = new TestEditor("Editor"+i,host,port,master);
		}
		setupEditor0();
	}

	private void setupEditor0() {
		/*
		 * do not startup Editor0 until SessionManagers are ready.
		 * Define pending command and set null command for now.
		 */
		LinkedList<REPCommand>cmds = new LinkedList<REPCommand>();
		cmds.add(new REPCommand(REP.SMCMD_PUT,0,0,0,0,"Editor0-file"));
		cmds.add(new REPCommand(REP.REPCMD_INSERT,0,0,0,0,"m0"));
		cmds.add(new REPCommand(REP.REPCMD_DELETE,0,0,0,0,"m0"));
		editorStartCmds = cmds;
		LinkedList<REPCommand>nullcmds = new LinkedList<REPCommand>();
		editors[0].setCommand(nullcmds);
	}

	@Override
	public void setSMEvent(SessionManager s,int i) {
		if (i<ev2.length) {
			s.syncExec(ev2[i]);
		}
		return ;
	}

	@Override
	protected void startTest() {
		int i = 0;
		for(SessionManager master:sessionManagers) {
			logger.writeLog("Start master "+master);
			i = startSessionManager(master,i, masterPort + i);
		}
	}
	
	public static void main(String[] args){
		/*
		 * set simulation mode
		 *    isSimulation=true     thread base simulation for PathFinder
		 *    isSimulation=false    socket based communication mode
		 */
		REPServerSocketChannel.isSimulation = true;
		// At least 3 TestEditors are required.
		TestInterManagerSession test = new TestInterManagerSession(1, 2, 3);
		logger.setLogLevel(5);
		test.startTest();
	}


}