/////////////////////////////////////////////////////////


import java.awt.*;
import java.io.*;
import java.util.*;
import java.net.*;

public class Server extends Frame
{
    MenuBar ControlBar;
    Menu Connection, Task;
    MenuItem openServer, closeServer, actionClose;
	public Server()
	{
        super("Checker Server");
		setLayout(null);
		setVisible(false);
		Connection = new Menu("Connection");
		closeServer =  new MenuItem( "Close server");
		openServer =  new MenuItem( "Open server");
		Connection.add(openServer);
		Connection.add(closeServer);

		actionClose = new MenuItem( "Close users" );

		Task = new Menu("Task");
		Task.add(actionClose);
		ControlBar = new MenuBar();
		ControlBar.add( Connection);
		ControlBar.add( Task);
		setMenuBar(ControlBar);
		closeServer.setEnabled(false);

		setSize(insets().left+insets().right+430, insets().top+insets().bottom+300);
		setBackground(new Color(-8355776));
		console = new java.awt.TextArea("",0,0,TextArea.SCROLLBARS_VERTICAL_ONLY);
		console.setEditable(false);
		console.setBounds(insets().left + 12,insets().top + 56,276,216);
		console.setForeground(new Color(255));
		console.setBackground(new Color(16777215));
		add(console);
		userList = new java.awt.TextArea();
		userList.setEditable(false);
		userList.setBounds(insets().left + 300,insets().top + 58,108,120);
		userList.setForeground(new Color(255));
		userList.setBackground(new Color(16777215));
		add(userList);
		startbtn = new java.awt.Button();
		startbtn.setActionCommand("button");
		startbtn.setLabel("Start Server");
		startbtn.setBounds(insets().left + 300,insets().top + 188,108,40);
		startbtn.setBackground(new Color(12632256));
		add(startbtn);
		stopbtn = new java.awt.Button();
		stopbtn.setActionCommand("button");
		stopbtn.setLabel("Stop Server");
		stopbtn.setBounds(insets().left + 300,insets().top + 236,108,40);
		stopbtn.setBackground(new Color(12632256));
		stopbtn.enable(false);
		add(stopbtn);
		SymWindow aSymWindow = new SymWindow();
		this.addWindowListener(aSymWindow);
	}

	TextArea console;
	TextArea userList;
	Button startbtn;
	Button stopbtn;
	static Vector v= new Vector();
	CheckerServer c;

	class SymWindow extends java.awt.event.WindowAdapter
	{
		public void windowClosing(java.awt.event.WindowEvent event)
		{
			Object object = event.getSource();
			if (object == Server.this)
				Server_WindowClosing(event);
		}
	}

	void Server_WindowClosing(java.awt.event.WindowEvent event)
	{
	    c.stopServer();
		hide();		 // hide the Frame
		dispose();
		System.exit(0);

	}


	///////////////////////////////////////////////////////////////////////////
	class CheckerServer extends Thread
	{
		Connection c;
		Socket sock;
		ServerSocket listen;
		CheckerServer()
		{
			start();
		}
		public void removeUsers()
		{
		    for( int i=0; i<v.size(); i++ )
		    {
		        Connection con = (Connection)v.elementAt(i);
		        con.sentData(Protocol.R);      //"Remove" on user's side
		    }
		    userList.setText("Empty");
		}

		public void stopServer()
		{
		    Connection con;
			this.stop();
			System.out.println("Server thread has stopped");
			try
			{
				listen.close();
			}
			catch(IOException e) {}
			for(int i=0; i<v.size(); i++)
			{

			    con= (Connection)v.elementAt(i);
			    con.sentData("Disconnect");
			    con.stop();
			    try
			    {
			        con.pout.close();
			        con.din.close();
			        con.sock.close();
			    }
			    catch(IOException ex){
			        System.out.println("Can't close connection with clients"); }
			    v.removeElementAt(i);
			}
		}
		public void run()
		{
			System.out.println("Server thread started");
			console.setText("Checker Server started." + "\n");
			try
			{
				listen= new ServerSocket(5166);
				while(true)
				{
					c= new Connection(listen.accept(), this);
					System.out.println("Connection accepted");
				}
			}
			catch(UnknownHostException e) { System.out.println("can't find host");}
			catch(IOException e){System.out.println("Error connecting to host");}
		}

		synchronized void clientListUpdate()
        {
            Connection con;
        	String list= Protocol.U; //"update";
       		String s;
       		for(int i=0; i< v.size(); i++)
       		{
       		    con= (Connection)v.elementAt(i);
       		    s= con.getId();
           		list= list + " " + s;
           	}
       		for(int j=0; j<v.size(); j++)
       		{
       			con= (Connection)v.elementAt(j);
           		con.sentData(list);
           	}
      	}
        synchronized void addUser(Connection user)
        {
            v.addElement(user);
        }

        synchronized void removeUser(String user)
        {
    	    String s;
    	    Connection con;
    	    for(int i=0; i<v.size(); i++)
    	    {
    	        con= (Connection)v.elementAt(i);
        		s= con.getId();
    		    if(s.equals(user))
    		    {
    		       v.removeElementAt(i);
    		       break;
    		    }
		   }
		}

    	synchronized Connection getOpponent(String user)
    	{
    	    String s;
    	    Connection con;
    	    for(int i=0; i<v.size(); i++)
    	    {
    	        con= (Connection)v.elementAt(i);
        		s= con.getId();
        		if(s.equals(user))
    		    {
    		         return (Connection)v.elementAt(i);
    		    }

    	     }
    	     return null;
    	}
    	synchronized void serverListUpdate()
        {
            userList.setText("");
            String s;
            Connection con;
            for(int i=0; i< v.size(); i++)
            {
                con= (Connection)v.elementAt(i);
        		s= con.getId();
        	    userList.appendText(s + "\n");
            }
        }
    }
    ///////////////////////////////////////////////////////////////////////
	class Connection extends Thread
	{
	    InputStream in;
	    OutputStream out;
	    DataInputStream din;
	    PrintStream pout;
	    Socket sock;
	    CheckerServer obj;
	    Connection connection;
	    Connection opponent;
	    String id, enemy;
	    Connection(Socket sock, CheckerServer obj)
	    {
	    	this.sock= sock;
	    	this.obj= obj;
	        start();
	    }
	    public String getId() { return id;}
	    public void run()
	    {
	        String msg;
	        System.out.println("Connection thread started");
	        try
	        {
                in= sock.getInputStream();
                out= sock.getOutputStream();
                pout= new PrintStream(out);
                din= new DataInputStream(in);
    			System.out.println("I/O streams with client opened");
	            while(true)
	            {
	              	msg= din.readLine();
	                if(msg != null)
	              	{
	               		formatMsg(msg);
	               	}
	            }
	        }
	        catch(UnknownHostException e)
	            { System.out.println("Can't find host");}
	        catch(IOException e)
	        {
	            this.stop();
	            v.removeElement(this);
	            System.out.println("Client disconnect");
                obj.serverListUpdate();
	            try
	            { this.sock.close();}
	            catch(IOException excep ) {}

	         }
	   }

       public void sentData(String s)
	   {
	       pout.println(s);
	   }
       void formatMsg(String msg)
       {
            StringTokenizer token= new StringTokenizer(msg);
            String first= token.nextToken();
	        String second;
            if(first.equals(Protocol.C))        // "New" user
            {
                second= token.nextToken();
                id= second;
		        obj.addUser(this);
                obj.serverListUpdate();
                obj.clientListUpdate();
            }
            else if(first.equals(Protocol.D))   //"Disconnect"
            {
                System.out.println("Disconnect");
                second= token.nextToken();
                obj.removeUser(second);
                obj.serverListUpdate();
                obj.clientListUpdate();
                if(opponent !=null)
                    opponent.sentData("Disconnect");
                this.stop();
            }
            else if(first.equals(Protocol.N))   //"New game"
            {
                System.out.println("New game");
                opponent.sentData(Protocol.N);
                opponent.opponent = null;
                opponent = null;
                System.out.println("Check!!!!");
            }
            else if(first.equals(Protocol.P))   //"Play"
            {
                second= token.nextToken();
        		opponent= obj.getOpponent(second);
        		opponent.sentData( msg ); //Protocol.P + " " + id);
        		opponent.opponent = this;
            }
        	else if(first.equals(Protocol.S))      //"Start"
        	{
        		//opponent.sentData("Start");
        		opponent.sentData(msg);
        	}
        	else if(first.equals(Protocol.M))       //"Move"
        	{
        		second= token.nextToken();
        		System.out.println(msg);
        		opponent.sentData(msg);
        	}
	  }

    }

    ///////////////////////////////////////////////////////////////
    public boolean action(Event e, Object o)
    {
        if(e.target==startbtn || e.target==openServer)
        {
            c= new CheckerServer();
            stopbtn.setEnabled(true);
            startbtn.setEnabled(false);
            openServer.setEnabled(false);
            closeServer.setEnabled(true);

        }
        if(e.target==stopbtn || e.target==closeServer)
        {
            console.setText("Server stopped. All connection Closed" + "\n");
            c.removeUsers();
            c.stopServer();
            stopbtn.setEnabled(false);
            closeServer.setEnabled(false);
            startbtn.setEnabled(true);
            openServer.setEnabled(true);
            userList.setText("");
        }
        if(e.target==actionClose)
        {
            c.removeUsers();
        }

        return true;
    }

    public static void main(String[] args)
    {
	    Server s= new Server();
	    s.show();
    }
}