package cz.frantovo.nekurak.ejb;

import cz.frantovo.nekurak.chat.MistnostPripojena;

import cz.frantovo.nekurak.chat.Nastaveni;

import cz.frantovo.nekurak.chat.Spojeni;

import cz.frantovo.nekurak.chat.SpravceNastaveni;

import cz.frantovo.nekurak.chat.UcetRobota;

import cz.frantovo.nekurak.dto.ZpravaChatu;

import cz.frantovo.nekurak.vyjimky.NekurakVyjimka;

import java.util.ArrayList;

import java.util.Collection;

import java.util.logging.Level;

import java.util.logging.Logger;

import javax.annotation.PostConstruct;

import javax.annotation.PreDestroy;

import javax.ejb.Singleton;

import javax.ejb.Startup;

import javax.naming.NamingException;

/**

 *

 * @author fiki

 */

@Singleton

@Startup

public class ChatEJB implements ChatRemote {

	private static final Logger log = Logger.getLogger(ChatRemote.class.getSimpleName());

	private Nastaveni nastaveni;

	private Collection<Spojeni> spojeni = new ArrayList<Spojeni>();

	@Override

	public void posliZpravu(String mistnost, String prezdivka, String zprava) throws NekurakVyjimka {

		MistnostPripojena mp = najdiMistnost(mistnost);

		if (mp == null) {

			throw new NekurakVyjimka("Místnost s tímto názvem neexistuje", null);

		} else {

			try {

				mp.posliZpravu(new ZpravaChatu(prezdivka, zprava));

			} catch (Exception e) {

				log.log(Level.SEVERE, "Selhalo odesílání zprávy", e);

				throw new NekurakVyjimka("Zprávu se nepodařilo odeslat.", e);

			}

		}

	}

	/**

	 * @param mistnost název místnosti včetně zavináče a serveru

	 * @param poradoveCislo pořadové číslo poslední zprávy, kterou jsme dostali

	 * @return všechny novější zprávy než dané pořadové číslo

	 * @throws NekurakVyjimka

	 */

	@Override

	public Collection<ZpravaChatu> getZpravy(String mistnost, int poradoveCislo) throws NekurakVyjimka {

		MistnostPripojena mp = najdiMistnost(mistnost);

		if (mp == null) {

			throw new NekurakVyjimka("Místnost s tímto názvem neexistuje", null);

		} else {

			return mp.getZpravy(poradoveCislo);

		}

	}

	public ChatEJB() throws NekurakVyjimka {

		/** TODO: vyřešit lépe. */

		nastaveni = new SpravceNastaveni().getNastaveni();

	}

	@PreDestroy

	public void odpoj() {

		for (Spojeni s : spojeni) {

			s.odpoj();

		}

	}

	@PostConstruct

	public void inicializuj() throws NekurakVyjimka, NamingException {

		pripojXMPP();

	}

	private void pripojXMPP() throws NekurakVyjimka {

		try {

			for (UcetRobota u : nastaveni.getUctyRobota()) {

				Spojeni s = new Spojeni(u);

				spojeni.add(s);

			}

		} catch (Exception e) {

			throw new NekurakVyjimka("Chyba při připojování.", e);

		}

	}

	/**

	 * @param nazev Název místnosti, kterou hledáme.

	 * @return nalezená místnost, nebo null, pokud místnost nebyla nalezena.

	 */

	private MistnostPripojena najdiMistnost(String nazev) {

		for (Spojeni s : spojeni) {

			for (MistnostPripojena mp : s.getMistnosti()) {

				if (mp.porovnejNazev(nazev)) {

					return mp;

				}

			}

		}

		return null;

	}

}