D-Net

package eu.dnetlib.enabling.tools.registration;

import java.util.ArrayList;

import java.util.List;

import javax.annotation.PostConstruct;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Required;

import eu.dnetlib.clients.ISLookUpClient;

import eu.dnetlib.conf.ContainerConfiguration;

import eu.dnetlib.services.BaseService;

public class ServiceRegistrationManager {

	private static final Log log = LogFactory.getLog(ServiceRegistrationManager.class);

	@Autowired

	private ISLookUpClient isLookup;

	private ServiceRegistrator registrator;

	private boolean disabled = false;

	@Autowired(required = false)

	private List<BaseService> services = new ArrayList<>();

	@Autowired

	private ContainerConfiguration containerConfiguration;

	@PostConstruct

	public void registerAllServices() {

		if (disabled) { return; }

		disabled = true;

		services.stream()

				.filter(this::filterService)

				.forEach(this::registerService);

	}

	/**

	 * check if we have already a registered service profile for this service.

	 *

	 * @throws

	 */

	private boolean filterService(final BaseService service) {

		try {

			final String query = "for $x in //RESOURCE_PROFILE[.//RESOURCE_URI/@value='" + containerConfiguration.getUrl() + "']"

					+ " where contains($x//RESOURCE_TYPE/@value/string(), 'Service') return $x//RESOURCE_IDENTIFIER/@value/string()";

			final List<String> profIds = isLookup.find(query);

			if (profIds.isEmpty()) {

				log.debug("there is no service registered for service: " + service.getServiceType());

				return true;

			} else {

				service.setProfileId(profIds.get(0));

				return false;

			}

		} catch (final Throwable e) {

			log.error("Error filtering endpoint", e);

			disabled = false;

			return false;

		}

	}

	private void registerService(final BaseService service) {

		try {

			final String profId = registrator.registerService(service, containerConfiguration.getUrl());

			service.setProfileId(profId);

		} catch (final Throwable e) {

			log.error("Error registering endpoint", e);

			disabled = false;

		}

	}

	public ServiceRegistrator getRegistrator() {

		return registrator;

	}

	@Required

	public void setRegistrator(final ServiceRegistrator registrator) {

		this.registrator = registrator;

	}

	public boolean isDisabled() {

		return disabled;

	}

}