D-Net

package eu.dnetlib.datasource.publisher.clients;

import eu.dnetlib.datasource.publisher.ApiException;

import eu.dnetlib.datasource.publisher.clients.utils.IndexDsInfo;

import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService;

import eu.dnetlib.enabling.locators.UniqueServiceLocator;

import org.apache.commons.io.IOUtils;

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.Value;

import org.springframework.cache.annotation.Cacheable;

import org.springframework.core.io.ClassPathResource;

import org.springframework.http.HttpStatus;

/**

 * Created by claudio on 20/10/2016.

 */

public class ISLookupClient {

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

	@Autowired

	private UniqueServiceLocator serviceLocator;

	@Value(value = "${datasource.publisher.findSolrIndexUrl.xquery}")

	private ClassPathResource findSolrIndexUrl;

	@Value(value = "${datasource.publisher.findIndexDsInfo.xquery}")

	private ClassPathResource findIndexDsInfo;

	@Cacheable("datasources-is-cache")

	public IndexDsInfo calculateCurrentIndexDsInfo() throws ApiException {

		log.warn("calculateCurrentIndexDsInfo(): not using cache");

		try {

			final String queryUrl = IOUtils.toString(findSolrIndexUrl.getInputStream());

			final String queryDs = IOUtils.toString(findIndexDsInfo.getInputStream());

			final ISLookUpService lookUpService = serviceLocator.getService(ISLookUpService.class);

			final String indexBaseUrl = lookUpService.getResourceProfileByQuery(queryUrl);

			final String[] arr = lookUpService.getResourceProfileByQuery(queryDs).split("@@@");

			return new IndexDsInfo(indexBaseUrl, arr[0].trim(), arr[1].trim(), arr[2].trim());

		} catch (Exception e) {

			throw new ApiException(HttpStatus.INTERNAL_SERVER_ERROR.value(), "Error querying information system");

		}

	}

}