/*
 *  Kolage
 */

package easycomm;

import java.io.IOException;
import java.io.PrintStream;
import java.net.Socket;

public class ProcessHandler extends Thread {

    int pocMsg; int pocUsr;
    Socket client;

    public ProcessHandler(Socket client) {
        this.client = client;
    }

    @Override
    public void run() {

        pocMsg = Server.messages.size();
        pocUsr = Server.users.size();

        PrintStream out = null;

        try {
            out = new PrintStream(client.getOutputStream());
        }
        catch(IOException e) {
            System.out.println(e.getMessage());
            System.exit(1);
        }

        while (true) {
            if(Server.messages.size() != pocMsg) {
                out.println("UPDATE MESSAGES");
                pocMsg = Server.messages.size();
            }

            if(Server.users.size() != pocUsr) {
                out.println("UPDATE CLIENTS");
                pocUsr = Server.users.size();
            }
            try {
                Thread.sleep(1000);
            }
            catch(InterruptedException e) {
                System.out.println(e.getMessage());
            }
        }
    }
}