package ie.tcd.group2.crystallise;

import ie.tcd.group2.network.Packet;

import java.util.concurrent.ArrayBlockingQueue;

public class ReceiverThread implements Runnable {
	private GameClass gameClassReference;
	private ArrayBlockingQueue<Packet> receiverQ;

	public ReceiverThread(GameClass gameClass) {
		this.gameClassReference = gameClass;
	}

	@Override
	public void run() {
		while(true){
			try {
			System.out.println("debug: ReceiverThread Run");
			Packet packet=	this.receiverQ.take();

			if(packet.getPacketInformation().getPacketType().equals("JOIN")){
				//do something to get a person to join the game
				join(packet);}

			else if (packet.getPacketInformation().getPacketType().equals("DUAL")){

				// do something to start the dual
					dual();}

			else if (packet.getPacketInformation().getPacketType().equals("STATE")){

				// do something to start the dual
					state();}

			else if (packet.getPacketInformation().getPacketType().equals("UPDATE")){

					{// do something to update all info
						update();}

			}
			System.out.println("debug:"+packet.getPacketInformation().getPacketType());
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
	private void state() {
		// TODO Auto-generated method stub

	}

	private void update() {
		// TODO Auto-generated method stub
	}
	private void join(Packet p) {
		String ip=p.getIpInformation().getSenderIp() ;
		JoinInformation info = p.getJoinInformation();
		String playerType = info.getPlayerType();
		int x = info.getXPosition();
		int y = info.getYPosition();
		this.gameClassReference.playerJoin(ip,playerType,x,y);
		// TODO Auto-generated method stub
	}
	private Object dual() {
		// TODO Auto-generated method stub
	}
}