/*Server.java*/
import java.io.*;//importing io classes
import java.net.*;//importing networking classes
class Server {
    private static Client clients[];//array storing clients
	private static Client clientsTmp[];
	private static int noOfClients = 0;
	private static ServerSocket server;
	private static Socket client;
	private static Sender sender;
	private static PrintWriter outStream;
	private static BufferedReader buffer;
	private static String keyboardInput;
    public static void main(String argc[]) {
		try {
		    server = new ServerSocket(2000);
			sender = new Sender();
		    while(true) {
				System.out.println("New client connected...\nClients connected - "+noOfClients);
                client = server.accept();
				addClient(client);
			}
		} catch(Exception e) {
		    System.out.println("Could not create server..."+e);
			System.exit(-1);
		}
	}
	static void addClient(Socket client) {//adds new client
	    try {
	        clientsTmp = new Client[++noOfClients];
			int i = 0;
			while(i<noOfClients - 1) {
		       clientsTmp[i] = clients[i];
			   i++;
			}
		    clientsTmp[noOfClients - 1] = new Client(client);
            clients = clientsTmp.clone();
        } catch(Exception e) {
		    System.out.println("Some problem occured " + e);
        }
	}
	static class Client {
	    Socket client;
		PrintWriter outputStream;
		Client(Socket clientSocket) {
		    client = clientSocket;
			try {
			    outputStream = new PrintWriter(client.getOutputStream());
			} catch(Exception e) {
			    System.out.println("Could not initialise client output stream");
			}
		}
		void print(String str) {
		    try {
		        outputStream.println(str);
		        outputStream.flush();
				System.out.println("Sent");
			} catch(Exception e) {
			     System.out.println("Could not send to client" + e);
			}

		}
		void close() {
		    try {
		        client.close();
			    outputStream.close();
			} catch(Exception e) {
			    System.out.println("Could not close client");
			}
		}
	}
	static class Sender extends Thread{
	    Sender() {
		     super("Sender Thread");
			 try {
			     buffer = new BufferedReader(new InputStreamReader(System.in));
				 System.out.println("Starting broadcast...");
				 start();
			 } catch(Exception e) {
			    System.out.println("Could not start sender thread");
			    System.exit(-1);
			 }
		}
		public void run() {
		    try {
			    int i = 0;
			    while(!(keyboardInput = buffer.readLine()).equals("stop")) {
				    while(i < noOfClients) {
					    System.out.println("Sending to client "+i);
					    clients[i++].print(keyboardInput);
                    }
                    System.out.println("Packets containing "+ keyboardInput +"sent.Waiting for next broadcast...");
				}
			} catch(Exception e) {
			     System.out.println("Could not send");
				 System.exit(-1);
			}
		}
	}
}