package onetomany.bargainingchipsgame.players;

import java.util.concurrent.BlockingQueue;

import onetomany.bargainingchipsgame.interactions.Offer;

public class Seller extends BilateralAgent
{
	int k;
	
	public Seller(String name, BlockingQueue<Offer> in,	BlockingQueue<Offer> out) 
	{
		super(name, in, out);
		k = 1;
	}
	
	@Override
	public void run() 
	{
		while (true)
		{
			Offer o;
			try 
			{
				// Wait for incoming offer
				o = in.take();
				receiveOffer(o);
				Offer sendOffer = sendOffer();
				out.put(sendOffer);
			} 
			catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	}

	@Override
	protected void receiveOffer(Offer o) 
	{
		System.out.println(this + " received " + o);
		
	}

	@Override
	protected Offer sendOffer() 
	{
		Offer sampleOffer = Offer.getSampleOffer("Green", k);
		k++;
		
		System.out.println(this + " is sending " + sampleOffer);
		return sampleOffer;
	}
	
	@Override
	protected Offer sendOpeningOffer() 
	{
		return null;
	}
	
	

}