package geniusweb.runserver;

import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
import java.util.Map;
import java.util.logging.Level;

import tudelft.utilities.listener.DefaultListenable;
import tudelft.utilities.logging.ReportToLogger;
import tudelft.utilities.logging.Reporter;
import tudelft.utilities.repository.Repository;

/**
 * Central repo for all currently running sessions.
 */
public class RunningNegotiationsRepo extends DefaultListenable<String>
		implements Repository<String, RunningNego> {

	private final Map<String, RunningNego> negotiations;
	private final static RunningNegotiationsRepo instance = new RunningNegotiationsRepo(
			new HashMap<>(), new ReportToLogger("runserver"));
	private final Reporter log;

	/**
	 * Only for testing and internal use
	 * 
	 * @param newnegos the currently running negotiations
	 */
	protected RunningNegotiationsRepo(Map<String, RunningNego> newnegos,
			Reporter reporter) {
		this.negotiations = newnegos;
		this.log = reporter;
	}

	public static RunningNegotiationsRepo instance() {
		return instance;
	}

	@Override
	public RunningNego get(String id) {
		return negotiations.get(id);
	}

	@Override
	public Collection<RunningNego> list() {
		return Collections.unmodifiableCollection(negotiations.values());
	}

	@Override
	public void put(RunningNego entity) {
		if (negotiations.containsKey(entity.getID())) {
			throw new IllegalArgumentException(
					"Negotiation " + entity.getID() + " is already running");
		}
		negotiations.put(entity.getID(), entity);
		notifyListeners(entity.getID());
		log.log(Level.FINEST, "started " + entity.getID());
	}

	@Override
	public void remove(String id) {
		negotiations.remove(id);
		notifyListeners(id);
		log.log(Level.FINEST, "stopped negotiation " + id);
	}

	@Override
	public void replace(RunningNego entity) {
		if (!negotiations.containsKey(entity.getID())) {
			throw new IllegalArgumentException(
					"Negotiation " + entity.getID() + " is not running");
		}
		negotiations.put(entity.getID(), entity);
		notifyListeners(entity.getID());
		log.log(Level.FINEST, "replaced " + entity.getID());

	}

}