package pad.prac2;

public class Connection extends Thread
{
	private MySocket socket;
	private Server serv;
	private boolean sleep, kill;
	
	public Connection(Server s)
	{
		serv = s;
		kill = false;
		sleep = true;
	}
	
	public void sendMessage(String message)
	{
		socket.sendMsg(message);
	}
	
	public void awake()
	{
		synchronized(this)
		{
			sleep = false;
			this.notify();
		}
	}
	
	public void finish()
	{
		kill = true;
		sleep = false;
		socket.close();
		this.notify();
	}
	
	public void setSock(MySocket s)
	{
		socket = s;
	}
	
	public void run()
	{
		while(!kill)
		{
			while(sleep)
			{
				try
				{
					synchronized(this)
					{
						wait();
					}
				} 
				catch (InterruptedException e)
				{
					e.printStackTrace();
				}
			}
			String str = socket.recvMsg();
			serv.addToChatroom(this, str);
			if(!kill)
			{
				while(true)
				{
					str = socket.recvMsg();
					if(str != null)
					{
						if(str == "/disconnect")
						{
							socket.sendMsg("DISC_OK");
							kill = true;
							System.out.println(serv.getNickname(this) + " disconnected");
						}
						else if(str == "/exit")
						{
							socket.sendMsg("EXIT_OK");
							kill = true;
							System.out.println(serv.getNickname(this) + " disconnected");
						}
						else
						{
							System.out.println("FROM " + serv.getNickname(this) + ": " + str);
							serv.sendToChat(this,str);
						}
					}
					else
					{
						break;
					}
				}
				sleep = true;
			}
			serv.finishWorker(this);
		}
	}

}