/*
    * Created on 15/Jan/2004
    */
   package replica.server;
   
   import java.io.IOException;
   import java.net.InetAddress;
   import java.net.Socket;
   
  import org.springframework.context.support.ClassPathXmlApplicationContext;
  import org.springframework.context.support.StaticApplicationContext;
  
  import junit.framework.TestCase;
  
  /***
   * @author Pedro Costa
   */
  public class ListenerTest extends TestCase {
  	
  	String configFileLocation = "replica/server/test-applicationContext.xml";
  
  	/***
  	 * Constructor for ListenerTest.
  	 * @param name
  	 */
  	public ListenerTest(String name) {
  		super(name);
  	}
  	
  	Listener getNewListener(){
  		
  		ClassPathXmlApplicationContext appContext = new ClassPathXmlApplicationContext(configFileLocation);
  		
  		StaticApplicationContext staticApp = (StaticApplicationContext)appContext.getBean("applicationContext");
  		
  		staticApp.setParent( appContext );
  		
  		staticApp.getBeanFactory().setParentBeanFactory( appContext.getBeanFactory() );
  		
  		return (Listener)staticApp.getBean("serverListener");
  	}
  
  	public void testCreateNewServerProcess() {
  		
  		Listener l = getNewListener();
  			
  		Thread lt = new Thread( l );
  		
  		try{
  			lt.start();
  			
  			try{ Thread.sleep( 500 ); }catch(InterruptedException e){ }
  			
  			Socket s = new Socket( InetAddress.getLocalHost(), l.getPort() );
  				
  			try{ Thread.sleep( 500 ); }catch(InterruptedException e){ }
  			
  			assertEquals(1, l.getServerProcesses().size());
  				
  			Thread t = (Thread)l.getServerProcesses().get(0);
  				
  			assertNotNull( t );
  				
  			assertEquals(true, t.isAlive() );
  				
  			try{ s.close(); }catch(IOException e){ }
  				
  			try{ t.join(); }catch(InterruptedException e){}
  				
  			try{ Thread.sleep( 500 ); }catch(InterruptedException e){ }
  			
  			assertEquals(0, l.getServerProcesses().size());
  		}
  		catch(IOException e){
  			e.printStackTrace();
  		}
  		finally{
  			l.stop();
  			try{ lt.join(); }catch(InterruptedException e){}
  		}
  	}
  	
  	public void testInitializeServerProcessesList(){
  		
  		Listener l = new Listener();
  		
  		assertNotNull( l.getServerProcesses() );
  		
  		assertEquals(0, l.getServerProcesses().size());
  	}
  
  	public void testGetNewServerProcess() {
  		
  		Listener l = getNewListener();
  		
  		Socket s = new Socket();
  		ServerProcess sp = l.getNewServerProcess(s);
  		
  		assertNotNull(sp);
 		assertEquals(s, sp.getSocket());
 	}
 	
 	public void testStartListener(){
 		
 		Listener l = new Listener();
 		Thread t = new Thread( l );
 		t.start();
 
 		try{
 			Thread.sleep(500);
 		}
 		catch(InterruptedException e){
 		}
 		
 		Socket s = null;
 		try{
 			s = new Socket(InetAddress.getByName("localhost"), l.getPort());
 			
 			assertEquals(true, s.isConnected());
 		}
 		catch(IOException e){
 			e.printStackTrace();
 		}
 		finally{
 			if( s != null ){
 				try{
 					s.close();
 				}
 				catch(IOException e){
 				}
 			}
 		}
 		
 		synchronized(l.getServerProcesses()){
 			if( l.getServerProcesses().size() > 0 ){
 				try{
 					((Thread)l.getServerProcesses().get(0)).join();
 				}
 				catch(InterruptedException e){
 				}
 			}
 		}
 		
 		l.stop();
 		
 		try{ t.join(1000); }catch(InterruptedException e){ }
 		
 	}
 	
 	public void testStopListener() {
 		Listener l = new Listener();
 		Thread t = new Thread( l );
 		t.start();
 		
 		assertEquals(true, t.isAlive() );
 		
 		try{
 			Thread.sleep(500);
 		}
 		catch(InterruptedException e){
 		}
 		
 		l.stop();
 
 		try{
 			Thread.sleep(500);
 		}
 		catch(InterruptedException e){
 		}
 		
 		assertEquals(false, t.isAlive() );
 		
 		// Check that the server socket is closed when the listener ends
 		if( l.server != null ){
 			assertEquals(true, l.server.isClosed() );
 		}
 	}
 }