package at.ac.tuwien.infosys.rnue.implementation;

import java.util.Properties;
import at.ac.tuwien.infosys.rnue.helpers.ShareMeException;
import at.ac.tuwien.infosys.rnue.implementation.multicast.HostListImpl;
import at.ac.tuwien.infosys.rnue.implementation.multicast.IsAliveReceiver;
import at.ac.tuwien.infosys.rnue.implementation.multicast.ShutdownListener;
import at.ac.tuwien.infosys.rnue.interfaces.IConstants;
import at.ac.tuwien.infosys.rnue.interfaces.IShareMe;
import at.ac.tuwien.infosys.rnue.interfaces.ISearchResult;
import java.net.InetAddress;
import java.net.UnknownHostException;

public class ShareMeImpl implements IShareMe {

    private Properties prop;
    private ShutdownListener Shutlist;
    private IsAliveReceiver iar;
    private HostListImpl hli;

    public ShareMeImpl(Properties prop) throws ShareMeException {
        this.prop = prop;
        this.hli = new HostListImpl();
        try {
            prop.setProperty(IConstants.RMI_REGISTRY_HOST, InetAddress.getLocalHost().toString());
        } catch (UnknownHostException ex) {
            System.out.println(ex.getMessage());
        }
    }

    public void start() throws ShareMeException{
        System.out.println("vypis z startu");
        Shutlist = new ShutdownListener(this, Integer.parseInt(prop.getProperty(IConstants.SHUTDOWN_PORT)), prop.getProperty(IConstants.SHUTDOWN_PASSWORD));
        iar = new IsAliveReceiver(prop,hli);
        Thread thread = new Thread(Shutlist);
        Thread thread2 = new Thread(iar);
        thread.start();
        thread2.start();
    }

    public void stop() throws ShareMeException{
        iar.stop();
        hli.stopGarbageCollector();
    }

    public ISearchResult search(String searchString) throws ShareMeException {
        throw new ShareMeException("method not yet implemented");
    }
}