package packets.sidedcomputer;

import java.io.BufferedReader;
import java.io.InputStreamReader;

import packets.data.PacketData;
import packets.reciever.PacketReciever;
import packets.side.Side;

public class ClientReciever extends Thread
{
	public Client client;

	public ClientReciever(Client client)
	{
		this.client = client;
	}

	volatile boolean running = true;

	public void stopRunning()
	{
		running = false;
	}

	@Override
	public void run()
	{
		while(running)
		{
			if(client.clientSocket != null)
			{
				try
				{
					BufferedReader in = new BufferedReader(new InputStreamReader(client.clientSocket.getInputStream()));
					String line;

					while((line = in.readLine()) != null)
					{
						PacketReciever reciever = new PacketReciever();

						PacketData packetData = new PacketData();
						packetData.decodeInto(line);

						reciever.recievePacket(packetData, packetData.packetID, Side.CLIENT, client.clientSocket.getLocalAddress().getHostAddress().toString(), client.clientSocket.getPort() + "");
					}
				}
				catch (Exception e)
				{
					e.printStackTrace();
				}
			}
		}
	}
}