D-Net

package eu.dnetlib.openaire.exporter.funders;

import java.io.IOException;

import java.util.Date;

import java.util.List;

import java.util.Map;

import java.util.stream.Collectors;

import com.google.common.collect.Lists;

import eu.dnetlib.openaire.exporter.datasource.clients.ISLookupClient;

import eu.dnetlib.openaire.exporter.datasource.clients.MongoLoggerClient;

import eu.dnetlib.openaire.exporter.funders.context.Context;

import eu.dnetlib.openaire.exporter.funders.context.MappingUtils;

import eu.dnetlib.openaire.exporter.funders.model.ExtendedFunderDetails;

import eu.dnetlib.openaire.exporter.funders.model.FunderDetails;

import org.apache.commons.collections.MapUtils;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

import org.springframework.cache.annotation.CacheEvict;

import org.springframework.cache.annotation.Cacheable;

import org.springframework.stereotype.Component;

@Component

public class FunderDao {

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

	@Autowired

	private ISLookupClient isLookupClient;

	@Autowired

	private MongoLoggerClient mongoLoggerClient;

	@Cacheable("funders-cache")

	public ExtendedFunderDetails getExtendedFunderDetails(final String funderId) throws FundersApiException {

		log.info(String.format("cache miss for getFunderDetails('%s')", funderId));

		final Context c = getContext(funderId);

		final ExtendedFunderDetails details = MappingUtils.asExtendedFunderDetails(c);

		details.setLastUpdateDate(getLastUpdateDate(c.getId()));

		details.setRegistrationDate(getRegistrationDate(c.getId()));

		return details;

	}

	public List<FunderDetails> listFunderDetails() throws FundersApiException {

		try {

			return isLookupClient.getContextMap().values().stream()

					.map(c -> asFunderDetails(c))

					.collect(Collectors.toList());

		} catch (IOException e) {

			throw new FundersApiException(e);

		}

	}

	public List<String> listFunderIds() throws FundersApiException {

		try {

			return Lists.newArrayList(isLookupClient.getContextMap().keySet());

		} catch (IOException e) {

			throw new FundersApiException(e);

		}

	}

	@CacheEvict(cacheNames = "funders-cache", allEntries = true)

	public void dropCache() {

		log.info("dropped funders info cache");

	}

	/* HELPERS */

	private FunderDetails asFunderDetails(final Context c) {

		return MappingUtils.asFunderDetails(c)

				.setLastUpdateDate(getLastUpdateDate(c.getId()))

				.setRegistrationDate(getRegistrationDate(c.getId()));

	}

	private Date getLastUpdateDate(final String id) {

		return null;

	}

	private Date getRegistrationDate(final String id) {

		return null;

	}

	private Context getContext(final String funderId) throws FundersApiException {

		try {

			final Map<String, Context> contextMap = isLookupClient.getContextMap();

			if (MapUtils.isEmpty(contextMap)) {

				throw new FundersApiException("Unable to find any context profile");

			}

			final Context context = contextMap.get(funderId);

			if (context == null) {

				throw new FundersApiException("Unexising funder id " + funderId);

			}

			return context;

		} catch (IOException e) {

			throw new FundersApiException(e);

		}

	}

}