package eu.dnetlib.enabling.is.sn;

import java.util.Calendar;
import java.util.List;

import javax.annotation.Resource;
import javax.xml.ws.Endpoint;
import javax.xml.ws.wsaddressing.W3CEndpointReference;

import eu.dnetlib.enabling.is.sn.rmi.ISSNException;
import eu.dnetlib.enabling.is.sn.rmi.ISSNService;
import eu.dnetlib.enabling.tools.AbstractBaseService;
import eu.dnetlib.soap.EndpointReferenceBuilder;

/**
 * implementation of ISSNService.
 * 
 * @author marko
 * 
 */
public class ISSNServiceImpl extends AbstractBaseService implements ISSNService {

	/**
	 * obvious constant.
	 */
	private static final int MILLIS_IN_SECOND = 1000;

	/**
	 * service endpoint.
	 */
	private Endpoint endpoint;

	/**
	 * core business logic.
	 */
	private ISSNServiceCore core;

	/**
	 * injected EPR builder.
	 */
	@Resource(name = "jaxwsEndpointReferenceBuilder")
	private EndpointReferenceBuilder<Endpoint> eprBuilder;

	/**
	 * {@inheritDoc}
	 * 
	 * @see eu.dnetlib.enabling.is.sn.rmi.ISSNService#actionCreatePerformed(java.lang.String, java.lang.String,
	 *      java.lang.String)
	 */
	@Override
	public boolean actionCreatePerformed(final String resourceType, final String profileId, final String profile) throws ISSNException {
		// TODO Auto-generated method stub
		return false;
	}

	/**
	 * {@inheritDoc}
	 * 
	 * @see eu.dnetlib.enabling.is.sn.rmi.ISSNService#actionDeletePerformed(java.lang.String, java.lang.String)
	 */
	@Override
	public boolean actionDeletePerformed(final String resourceType, final String profileId) throws ISSNException {
		// TODO Auto-generated method stub
		return false;
	}

	/**
	 * {@inheritDoc}
	 * 
	 * @see eu.dnetlib.enabling.is.sn.rmi.ISSNService#actionUpdatePerformed(java.lang.String, java.lang.String,
	 *      java.lang.String, java.lang.String)
	 */
	@Override
	public boolean actionUpdatePerformed(final String resourceType, final String profileId, final String profileBefore, final String profileAfter)
			throws ISSNException {
		// TODO Auto-generated method stub
		return false;
	}

	/**
	 * {@inheritDoc}
	 * 
	 * @see eu.dnetlib.enabling.is.sn.rmi.ISSNService#getCurrentMessage(java.lang.String)
	 */
	@Override
	public String getCurrentMessage(final String topic) throws ISSNException {
		// TODO Auto-generated method stub
		return null;
	}

	/**
	 * {@inheritDoc}
	 * 
	 * @see eu.dnetlib.enabling.is.sn.rmi.ISSNService#listSubscriptions()
	 */
	@Override
	public List<String> listSubscriptions() {
		// TODO Auto-generated method stub
		return null;
	}

	/**
	 * {@inheritDoc}
	 * 
	 * @see eu.dnetlib.enabling.is.sn.rmi.ISSNService#pauseSubscription(java.lang.String)
	 */
	@Override
	public boolean pauseSubscription(final String subscrId) throws ISSNException {
		// TODO Auto-generated method stub
		return false;
	}

	/**
	 * {@inheritDoc}
	 * 
	 * @see eu.dnetlib.enabling.is.sn.rmi.ISSNService#renew(java.lang.String, int)
	 */
	@Override
	public boolean renew(final String subscrId, final int terminationTime) throws ISSNException {
		// TODO Auto-generated method stub
		return false;
	}

	/**
	 * {@inheritDoc}
	 * 
	 * @see eu.dnetlib.enabling.is.sn.rmi.ISSNService#resumeSubscription(java.lang.String)
	 */
	@Override
	public boolean resumeSubscription(final String subscrId) throws ISSNException {
		// TODO Auto-generated method stub
		return false;
	}

	/**
	 * {@inheritDoc}
	 * 
	 * @see eu.dnetlib.enabling.is.sn.rmi.ISSNService#subscribe(javax.xml.ws.wsaddressing.W3CEndpointReference,
	 *      java.lang.String, int)
	 */
	@Override
	public String subscribe(final W3CEndpointReference consumerReference, final String topicExpression, final int termTime) throws ISSNException {
		int ttl;
		if (termTime == 0)
			ttl = 0;
		else
			ttl = (int) (termTime - Calendar.getInstance().getTimeInMillis() / MILLIS_IN_SECOND);
		
		final String res = core.subscribe(consumerReference, topicExpression, ttl);
		if (res == null)
			throw new ISSNException("couldn't find a subscription registry for the given topic: " + topicExpression);
		return res;
	}

	/**
	 * {@inheritDoc}
	 * 
	 * @see eu.dnetlib.enabling.is.sn.rmi.ISSNService#unsubscribe(java.lang.String)
	 */
	@Override
	public boolean unsubscribe(final String subscrId) throws ISSNException {
		return core.unsubscribe(subscrId);
	}

	public Endpoint getEndpoint() {
		return endpoint;
	}

	public void setEndpoint(final Endpoint endpoint) {
		this.endpoint = endpoint;
	}

	public ISSNServiceCore getCore() {
		return core;
	}

	public void setCore(final ISSNServiceCore core) {
		this.core = core;
	}

	public EndpointReferenceBuilder<Endpoint> getEprBuilder() {
		return eprBuilder;
	}

	public void setEprBuilder(final EndpointReferenceBuilder<Endpoint> eprBuilder) {
		this.eprBuilder = eprBuilder;
	}

}