D-Net

package eu.dnetlib.functionality.index.resultset;

import java.util.List;

public class ResultsCache {

	private List<String> cache;

	private int from;

	private int to;

	public ResultsCache(List<String> cache, int from, int to) {

		this.cache = cache;

		this.from = from;

		this.to = to;

	}

	public boolean resultInCache(int from, int to) {

		return from >= this.from && to <= this.to;

	}

	public List<String> get(int from, int to) {

		return cache.subList(from - 1, to);

	}

}

package eu.dnetlib.functionality.index.resultset.factory;

import java.util.List;

import eu.dnetlib.data.provision.index.rmi.IndexServiceException;

import eu.dnetlib.enabling.resultset.ResultSetListener;

import eu.dnetlib.functionality.index.IndexServerDAO;

import eu.dnetlib.functionality.index.query.IndexQuery;

import eu.dnetlib.functionality.index.query.QueryLanguage;

import eu.dnetlib.functionality.index.resultset.LookupResultSetListener;

import eu.dnetlib.functionality.index.utils.MetadataReference;

/**

 * A factory for creating LookupResultSetListener objects.

 *

 * @author claudio

 * @author Sandro

 */

public class LookupResultSetListenerFactory extends IndexResultSetListenerFactory {

	/**

	 * {@inheritDoc}

	 *

	 * @see eu.dnetlib.functionality.index.resultset.factory.IndexResultSetListenerFactory#getListener(eu.dnetlib.functionality.index.query.QueryLanguage,

	 *      java.lang.String, eu.dnetlib.functionality.index.utils.MetadataReference, java.lang.String[])

	 */

	@Override

	public ResultSetListener getListener(final IndexServerDAO dao,

			final QueryLanguage lang,

			final String query,

			final MetadataReference mdRef,

			final List<String> dsIds) throws IndexServiceException {

		final IndexQuery indexQuery = dao.getIndexQueryFactory().getIndexQuery(lang, query, dao, dsIds, mdRef);

		return new LookupResultSetListener(indexQuery, mdRef, dao.getIndexCollection(mdRef));

	}

}

package eu.dnetlib.functionality.index.resultset.factory;

import java.util.List;

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

import eu.dnetlib.data.provision.index.rmi.BrowsingRow;

import eu.dnetlib.data.provision.index.rmi.IndexServiceException;

import eu.dnetlib.enabling.resultset.ResultSetListener;

import eu.dnetlib.functionality.index.IndexServerDAO;

import eu.dnetlib.functionality.index.query.IndexQuery;

import eu.dnetlib.functionality.index.query.QueryLanguage;

import eu.dnetlib.functionality.index.resultset.BrowsingResultSetListener;

import eu.dnetlib.functionality.index.utils.MetadataReference;

import eu.dnetlib.miscutils.jaxb.JaxbFactory;

/**

 * A factory for creating BrowsingResultSetListener objects.

 *

 * @author claudio

 */

public class BrowsingResultSetListenerFactory extends IndexResultSetListenerFactory {

	/** The jaxb factory. */

	private JaxbFactory<BrowsingRow> jaxbFactory;

	/** The max browse results. */

	private int maxBrowseResults;

	/**

	 * {@inheritDoc}

	 *

	 * @see eu.dnetlib.functionality.index.resultset.factory.IndexResultSetListenerFactory#getListener(eu.dnetlib.functionality.index.query.QueryLanguage,

	 *      java.lang.String, eu.dnetlib.functionality.index.utils.MetadataReference, java.lang.String[])

	 */

	@Override

	public ResultSetListener getListener(final IndexServerDAO dao,

			final QueryLanguage lang,

			final String query,

			final MetadataReference mdRef,

			final List<String> dsIds) throws IndexServiceException {

		final IndexQuery indexQuery = dao.getIndexQueryFactory().getIndexQuery(lang, query, dao, dsIds, mdRef);

		return new BrowsingResultSetListener(indexQuery, mdRef, dao.getIndexCollection(mdRef), getJaxbFactory());

	}

	/**

	 * Gets the jaxb factory.

	 *

	 * @return the jaxb factory

	 */

	public JaxbFactory<BrowsingRow> getJaxbFactory() {

		return jaxbFactory;

	}

	/**

	 * Sets the jaxb factory.

	 *

	 * @param jaxbFactory

	 *            the new jaxb factory

	 */

	@Required

	public void setJaxbFactory(final JaxbFactory<BrowsingRow> jaxbFactory) {

		this.jaxbFactory = jaxbFactory;

	}

	/**

	 * Sets the max browse results.

	 *

	 * @param maxBrowseResults

	 *            the new max browse results

	 */

	@Required

	public void setMaxBrowseResults(final int maxBrowseResults) {

		this.maxBrowseResults = maxBrowseResults;

	}

	/**

	 * Gets the max browse results.

	 *

	 * @return the max browse results

	 */

	public int getMaxBrowseResults() {

		return maxBrowseResults;

	}

}

package eu.dnetlib.functionality.index.resultset.factory;

import java.util.List;

import javax.xml.ws.wsaddressing.W3CEndpointReference;

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

import eu.dnetlib.data.provision.index.rmi.IndexServiceException;

import eu.dnetlib.enabling.resultset.ResultSetFactory;

import eu.dnetlib.functionality.index.IndexServerDAO;

import eu.dnetlib.functionality.index.query.QueryLanguage;

import eu.dnetlib.functionality.index.utils.MetadataReference;

/**

 * 

 * @author claudio

 * 

 */

public class IndexResultSetFactory {

	/**

	 * resultSetListener factory for lookup.

	 */

	private LookupResultSetListenerFactory lookupResultSetListenerFactory;

	/**

	 * resultSetListener factory for browsing.

	 */

	private BrowsingResultSetListenerFactory browsingResultSetListenerFactory;

	/**

	 * resultSet factory

	 */

	private ResultSetFactory resultsetFactory;

	/**

	 * Gets the lookup result set.

	 * 

	 * @param collection

	 *            the collection

	 * @param lang

	 *            the lang

	 * @param query

	 *            the query

	 * @param mdRef

	 *            the md ref

	 * @param dsId

	 *            the ds id

	 * @return the lookup result set

	 * @throws IndexServiceException

	 *             the index service exception

	 */

	public W3CEndpointReference getLookupResultSet(final IndexServerDAO dao,

			final QueryLanguage lang,

			final String query,

			final MetadataReference mdRef,

			final List<String> dsIds) throws IndexServiceException {

		return resultsetFactory.createResultSet(lookupResultSetListenerFactory.getListener(dao, lang, query, mdRef, dsIds));

	}

	public W3CEndpointReference getBrowsingResultSet(final IndexServerDAO dao,

			final QueryLanguage lang,

			final String query,

			final MetadataReference mdRef,

			final List<String> dsIds) throws IndexServiceException {

		return resultsetFactory.createResultSet(browsingResultSetListenerFactory.getListener(dao, lang, query, mdRef, dsIds));

	}

	// /////////////////////////////////// setters

	@Required

	public void setLookupResultSetListenerFactory(final LookupResultSetListenerFactory lookupResultSetListenerFactory) {

		this.lookupResultSetListenerFactory = lookupResultSetListenerFactory;

	}

	@Required

	public void setBrowsingResultSetListenerFactory(final BrowsingResultSetListenerFactory browsingResultSetListenerFactory) {

		this.browsingResultSetListenerFactory = browsingResultSetListenerFactory;

	}

	@Required

	public void setResultsetFactory(final ResultSetFactory resultsetFactory) {

		this.resultsetFactory = resultsetFactory;

	}

}

package eu.dnetlib.functionality.index.resultset.factory;

import java.util.List;

import eu.dnetlib.data.provision.index.rmi.IndexServiceException;

import eu.dnetlib.enabling.resultset.ResultSetListener;

import eu.dnetlib.functionality.index.IndexServerDAO;

import eu.dnetlib.functionality.index.query.QueryLanguage;

import eu.dnetlib.functionality.index.utils.MetadataReference;

/**

 *

 *

 * @author claudio

 *

 */

public abstract class IndexResultSetListenerFactory {

	/**

	 * Factory method.

	 *

	 * @param indexServer

	 *            the index server

	 * @param lang

	 *            the lang

	 * @param query

	 *            the query

	 * @param mdRef

	 *            the md ref

	 * @param dsId

	 *            the ds id

	 * @return the listener

	 * @throws IndexServiceException

	 *             the index service exception

	 */

	public abstract ResultSetListener getListener(final IndexServerDAO dao,

			final QueryLanguage lang,

			final String query,

			final MetadataReference mdRef,

			final List<String> dsIds) throws IndexServiceException;

}

package eu.dnetlib.functionality.index.resultset;

import java.util.List;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import eu.dnetlib.data.provision.index.rmi.IndexServiceException;

import eu.dnetlib.enabling.resultset.ResultSetListener;

import eu.dnetlib.functionality.index.IndexCollection;

import eu.dnetlib.functionality.index.query.IndexQuery;

import eu.dnetlib.functionality.index.query.QueryResponseParser;

import eu.dnetlib.functionality.index.utils.MetadataReference;

/**

 * The listener interface for receiving indexResultSet events. The class that is interested in processing a indexResultSet event implements

 * this interface, and the object created with that class is registered with a component using the component's

 * <code>addIndexResultSetListener<code> method. When

 * the indexResultSet event occurs, that object's appropriate

 * method is invoked.

 * 

 * @see IndexResultSetEvent

 */

public abstract class IndexResultSetListener implements ResultSetListener {

	/**

	 * logger.

	 */

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

	/**

	 * ResultSet size.

	 */

	protected Long size = null;

	/**

	 * the query to be performed.

	 */

	protected IndexQuery indexQuery;

	/** The md ref. */

	protected MetadataReference mdRef;

	/**

	 * SolrIndexServer instance.

	 */

	protected IndexCollection indexServer;

	/**

	 * Gets the contextual result.

	 * 

	 * @param responseParser

	 *            the response parser

	 * @param from

	 *            the from

	 * @param to

	 *            the to

	 * @return the contextual result

	 */

	protected abstract List<String> getContextualResult(QueryResponseParser responseParser, int from, int to);

	/**

	 * Gets the contextual query.

	 * 

	 * @param indexQuery

	 *            the index query

	 * @param from

	 *            the from

	 * @param to

	 *            the to

	 * @return the contextual query

	 */

	protected abstract IndexQuery getContextualQuery(IndexQuery indexQuery, int from, int to);

	/**

	 * Gets the contextual size.

	 * 

	 * @return the contextual size

	 */

	protected abstract int getContextualSize();

	/**

	 * Instantiates a new index result set listener.

	 * 

	 * @param indexQuery

	 *            the index query

	 * @param mdRef

	 *            the md ref

	 * @param indexServer

	 *            the index server

	 * @throws IndexServiceException

	 *             the index service exception

	 */

	protected IndexResultSetListener(final IndexQuery indexQuery, final MetadataReference mdRef, final IndexCollection indexServer)

			throws IndexServiceException {

		this.indexQuery = indexQuery;

		this.mdRef = mdRef;

		this.indexServer = indexServer;

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @see eu.dnetlib.enabling.resultset.TypedResultSetListener#getResult(int, int)

	 */

	@Override

	public List<String> getResult(final int from, final int to) {

		return getContextualResult(performQuery(from, to), from, to);

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @see eu.dnetlib.enabling.resultset.TypedResultSetListener#getSize()

	 */

	@Override

	public int getSize() {

		return getContextualSize();

	}

	/**

	 * Perform query.

	 * 

	 * @param from

	 *            the from

	 * @param to

	 *            the to

	 * @return the query response parser

	 */

	protected QueryResponseParser performQuery(final int from, final int to) {

		try {

			return indexServer.lookup(getContextualQuery(indexQuery, from, to), mdRef);

		} catch (Exception e) {

			log.error("ops... cannot perform query", e);

			throw new RuntimeException(e);

		}

	}

}

package eu.dnetlib.functionality.index.resultset;

import java.util.List;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import eu.dnetlib.data.provision.index.rmi.IndexServiceException;

import eu.dnetlib.functionality.index.IndexCollection;

import eu.dnetlib.functionality.index.query.IndexQuery;

import eu.dnetlib.functionality.index.query.QueryResponseParser;

import eu.dnetlib.functionality.index.utils.MetadataReference;

/**

 * The listener interface for receiving lookupResultSet events. The class that is interested in processing a lookupResultSet event

 * implements this interface, and the object created with that class is registered with a component using the component's

 * <code>addLookupResultSetListener<code> method. When

 * the lookupResultSet event occurs, that object's appropriate

 * method is invoked.

 *

 * @see LookupResultSetEvent

 */

public class LookupResultSetListener extends IndexResultSetListener {

	/**

	 * logger.

	 */

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

	/*

	 * (non-Javadoc)

	 *

	 * @see

	 * eu.dnetlib.functionality.index.resultset.IndexResultSetListener#getContextualQuery(eu.dnetlib.functionality.index.query.IndexQuery,

	 * int, int)

	 */

	@Override

	protected IndexQuery getContextualQuery(final IndexQuery indexQuery, final int from, final int to) {

		if (log.isDebugEnabled()) {

			log.debug("getContextualResult LOOKUP - from:" + from + " to: " + to);

			log.debug("indexQuery.setStart(" + (from - 1) + ").setRows(" + ((to - from) + 1) + ")");

		}

		indexQuery.setQueryOffset(from - 1).setQueryLimit((to - from) + 1);

		return indexQuery;

	}

	/*

	 * (non-Javadoc)

	 *

	 * @see eu.dnetlib.functionality.index.resultset.IndexResultSetListener#getContextualSize()

	 */

	@Override

	protected int getContextualSize() {

		if (size == null) {

			try {

				if (log.isDebugEnabled()) {

					log.debug("setting LookupResultSetListener size with query: " + indexQuery.toString());

				}

				indexQuery.setQueryLimit(0);

				size = indexServer.lookup(indexQuery, mdRef).getNumFound();

			} catch (Throwable e) {

				log.error("ops getResult", e);

				throw new RuntimeException(e);

			}

		}

		return size.intValue();

	}

	/**

	 * Instantiates a new lookup result set listener.

	 *

	 * @param indexQuery

	 *            the index query

	 * @param mdRef

	 *            the md ref

	 * @param indexServer

	 *            the index server

	 * @throws IndexServiceException

	 *             the index service exception

	 */

	public LookupResultSetListener(final IndexQuery indexQuery, final MetadataReference mdRef, final IndexCollection indexServer) throws IndexServiceException {

		super(indexQuery, mdRef, indexServer);

		log.debug("LookupResultSetListener is up!");

	}

	/*

	 * (non-Javadoc)

	 *

	 * @see eu.dnetlib.functionality.index.resultset.IndexResultSetListener#getContextualResult(eu.dnetlib.functionality.index.query.

	 * QueryResponseParser, int, int)

	 */

	@Override

	protected List<String> getContextualResult(final QueryResponseParser responseParser, final int from, final int to) {

		return responseParser.getResults();

	}

}

package eu.dnetlib.functionality.index.resultset;

import java.util.List;

import javax.xml.bind.JAXBException;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import eu.dnetlib.data.provision.index.rmi.BrowsingRow;

import eu.dnetlib.data.provision.index.rmi.IndexServiceException;

import eu.dnetlib.functionality.index.IndexCollection;

import eu.dnetlib.functionality.index.query.IndexQuery;

import eu.dnetlib.functionality.index.query.QueryResponseParser;

import eu.dnetlib.functionality.index.utils.MetadataReference;

import eu.dnetlib.miscutils.collections.MappedCollection;

import eu.dnetlib.miscutils.functional.UnaryFunction;

import eu.dnetlib.miscutils.jaxb.JaxbFactory;

/**

 * The listener interface for receiving browsingResultSet events. The class that is interested in processing a browsingResultSet event

 * implements this interface, and the object created with that class is registered with a component using the component's

 * <code>addBrowsingResultSetListener<code> method. When

 * the browsingResultSet event occurs, that object's appropriate

 * method is invoked.

 * 

 * @see BrowsingResultSetEvent

 */

public class BrowsingResultSetListener extends IndexResultSetListener {

	/**

	 * logger.

	 */

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

	/** The jaxb factory. */

	private JaxbFactory<BrowsingRow> jaxbFactory;

	/**

	 * Instantiates a new browsing result set listener.

	 * 

	 * @param indexQuery

	 *            the index query

	 * @param mdRef

	 *            the md ref

	 * @param indexServer

	 *            the index server

	 * @param jaxbFactory

	 *            the jaxb factory

	 * @throws IndexServiceException

	 *             the index service exception

	 */

	public BrowsingResultSetListener(final IndexQuery indexQuery, final MetadataReference mdRef, final IndexCollection indexServer,

			final JaxbFactory<BrowsingRow> jaxbFactory) throws IndexServiceException {

		super(indexQuery, mdRef, indexServer);

		this.jaxbFactory = jaxbFactory;

		log.debug("BrowsingResultSetListener is up!");

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @see eu.dnetlib.functionality.index.resultset.IndexResultSetListener#getContextualQuery(eu.dnetlib.functionality.index.query.IndexQuery,

	 *      int, int)

	 */

	@Override

	protected IndexQuery getContextualQuery(final IndexQuery indexQuery, final int from, final int to) {

		if (log.isDebugEnabled()) {

			log.debug("getContextualResult BROWSING - from:" + from + " to: " + to);

			log.debug("indexQuery.setFacetLimit(" + ((to - from) + 1) + ").set(\"facet.offset\", " + (from - 1) + ")");

		}

		// indexQuery.setFacetSort("count");

		indexQuery.setQueryFacetLimit((to - from) + 1).setQueryFacetOffset(from - 1);

		return indexQuery;

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @see eu.dnetlib.functionality.index.resultset.IndexResultSetListener#getContextualSize()

	 */

	@Override

	protected int getContextualSize() {

		if (size == null) {

			try {

				if (log.isDebugEnabled()) {

					log.debug("setting BrowsingResultSetListener size with query: " + indexQuery.toString());

				}

				indexQuery.setQueryLimit(0); // .setFacetSort("index");

				QueryResponseParser lookup = indexServer.lookup(indexQuery, mdRef);

				size = lookup.getNumberOfBrowsingResults();

			} catch (Throwable e) {

				log.error("ops", e);

				throw new RuntimeException(e);

			}

		}

		// TODO if (size >= maxBrowseResults) { return maxBrowseResults; }

		return size.intValue();

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @see eu.dnetlib.functionality.index.resultset.IndexResultSetListener#getContextualResult(eu.dnetlib.functionality.index.query.QueryResponseParser,

	 *      int, int)

	 */

	@Override

	protected List<String> getContextualResult(final QueryResponseParser responseParser, final int from, final int to) {

		return wrappedResults(responseParser.getBrowsingResults());

	}

	/**

	 * Wrapped results.

	 * 

	 * @param browsingResults

	 *            the browsing results

	 * @return the list

	 */

	private List<String> wrappedResults(final List<BrowsingRow> browsingResults) {

		return MappedCollection.listMap(browsingResults, new UnaryFunction<String, BrowsingRow>() {

			@Override

			public String evaluate(final BrowsingRow value) {

				try {

					return jaxbFactory.serialize(value);

				} catch (final JAXBException e) {

					log.error("cannot serialize ", e);

					throw new RuntimeException(e);

				}

			}

		});

	}

}

package eu.dnetlib.functionality.index.model;

import eu.dnetlib.functionality.index.model.impl.DefaultDataFactoryImpl;

/**

 * Helper class to decouple Any and Record interfaces better from default implementation.

 */

public final class DataFactoryCreator {

	/**

	 * Private default constructor to avoid instance creation.

	 */

	private DataFactoryCreator() {

	}

	/**

	 * @return instance of the default DataFactory.

	 */

	public static DataFactory newInstance() {

		return new DefaultDataFactoryImpl();

	}

}

package eu.dnetlib.functionality.index.model.impl;

import java.util.ArrayList;

import java.util.Collection;

import java.util.Date;

import java.util.Iterator;

import java.util.List;

import java.util.ListIterator;

import eu.dnetlib.functionality.index.model.Any;

import eu.dnetlib.functionality.index.model.AnyMap;

import eu.dnetlib.functionality.index.model.AnySeq;

import eu.dnetlib.functionality.index.model.InvalidValueTypeException;

import eu.dnetlib.functionality.index.model.Value;

/**

 * Sequence of Any objects.

 */

public final class AnySeqImpl extends AbstractAny implements AnySeq {

	/** version. */

	private static final long serialVersionUID = 1L;

	/** holds the Any objects of this AnySeq. */

	private final List<Any> _anyList;

	/**

	 * constructs a new instance of AnySeqImpl.

	 */

	AnySeqImpl() {

		super(ValueType.SEQ);

		_anyList = new ArrayList<Any>();

	}

	/** {@inheritDoc} */

	@Override

	public boolean add(final Any value) {

		if (value == null) {

			throw new IllegalArgumentException("The value of any Any must not be null.");

		}

		return _anyList.add(value);

	}

	/** {@inheritDoc} */

	@Override

	public boolean add(final String e) {

		return add(new ValueImpl(ValueType.STRING, e));

	}

	/** {@inheritDoc} */

	@Override

	public boolean add(final Number n) {

		if (n instanceof Double) {

			return add(new ValueImpl(ValueType.DOUBLE, n));

		} else if (n instanceof Long) {

			return add(new ValueImpl(ValueType.LONG, n));

		} else if (n instanceof Integer || n instanceof Short || n instanceof Byte) {

			return add(new ValueImpl(ValueType.LONG, Long.valueOf(n.longValue())));

		} else { // default: DOUBLE

			return add(new ValueImpl(ValueType.DOUBLE, Double.valueOf(n.doubleValue())));

		}

	}

	/** {@inheritDoc} */

	@Override

	public void add(final int index, final Any element) {

		if (element == null) {

			throw new IllegalArgumentException("The value of any Any must not be null.");

		}

		_anyList.add(index, element);

	}

	/** {@inheritDoc} */

	@Override

	public boolean addAll(final Collection<? extends Any> c) {

		return _anyList.addAll(c);

	}

	/** {@inheritDoc} */

	@Override

	public boolean addAll(final int index, final Collection<? extends Any> c) {

		return _anyList.addAll(index, c);

	}

	/** {@inheritDoc} */

	@Override

	public void clear() {

		_anyList.clear();

	}

	/** {@inheritDoc} */

	@Override

	public boolean contains(final Object o) {

		return _anyList.contains(o);

	}

	/** {@inheritDoc} */

	@Override

	public boolean containsAll(final Collection<?> c) {

		return _anyList.containsAll(c);

	}

	/** {@inheritDoc} */

	@Override

	public Any get(final int index) {

		return _anyList.get(index);

	}

	/** {@inheritDoc} */

	@Override

	public Any set(final int index, final Any element) {

		if (element == null) {

			throw new IllegalArgumentException("The value of any Any must not be null.");

		}

		return _anyList.set(index, element);

	}

	/** {@inheritDoc} */

	@Override

	public int indexOf(final Object o) {

		return _anyList.indexOf(o);

	}

	/** {@inheritDoc} */

	@Override

	public boolean isEmpty() {

		return _anyList.isEmpty();

	}

	/** {@inheritDoc} */

	@Override

	public Iterator<Any> iterator() {

		return _anyList.iterator();

	}

	/** {@inheritDoc} */

	@Override

	public int lastIndexOf(final Object o) {

		return _anyList.lastIndexOf(o);

	}

	/** {@inheritDoc} */

	@Override

	public ListIterator<Any> listIterator() {

		return _anyList.listIterator();

	}

	/** {@inheritDoc} */

	@Override

	public ListIterator<Any> listIterator(final int index) {

		return _anyList.listIterator(index);

	}

	/** {@inheritDoc} */

	@Override

	public Any remove(final int index) {

		return _anyList.remove(index);

	}

	/** {@inheritDoc} */

	@Override

	public boolean remove(final Object o) {

		return _anyList.remove(o);

	}

	/** {@inheritDoc} */

	@Override

	public boolean removeAll(final Collection<?> c) {

		return _anyList.removeAll(c);

	}

	/** {@inheritDoc} */

	@Override

	public boolean retainAll(final Collection<?> c) {

		return _anyList.retainAll(c);

	}

	/** {@inheritDoc} */

	@Override

	public int size() {

		return _anyList.size();

	}

	/** {@inheritDoc} */

	@Override

	public List<Any> subList(final int fromIndex, final int toIndex) {

		return _anyList.subList(fromIndex, toIndex);

	}

	/** {@inheritDoc} */

	@Override

	public Object[] toArray() {

		return _anyList.toArray();

	}

	/** {@inheritDoc} */

	@Override

	public <T> T[] toArray(final T[] a) {

		return _anyList.toArray(a);

	}

	/** {@inheritDoc} */

	@Override

	public AnyMap getMap(final int index) {

		final Any anyValue = get(index);

		if (anyValue != null) {

			if (anyValue.isMap()) {

				return (AnyMap) anyValue;

			} else {

				throw new InvalidValueTypeException("Cannot convert value of type '" + anyValue.getValueType() + "' to AnyMap.");

			}

		}

		return null;

	}

	/** {@inheritDoc} */

	@Override

	public AnySeq getSeq(final int index) {

		final Any anyValue = get(index);

		if (anyValue != null) {

			if (anyValue.isSeq()) {

				return (AnySeq) anyValue;

			} else {

				throw new InvalidValueTypeException("Cannot convert value of type '" + anyValue.getValueType() + "' to AnySeq.");

			}

		}

		return null;

	}

	/** {@inheritDoc} */

	@Override

	public Value getValue(final int index) {

		final Any anyValue = get(index);

		if (anyValue != null) {

			if (anyValue instanceof Value) {

				return (Value) anyValue;

			} else {

				throw new InvalidValueTypeException("Cannot convert value of type '" + anyValue.getValueType() + "' to Value.");

			}

		}

		return null;

	}

	/** {@inheritDoc} */

	@Override

	public String getStringValue(final int index) {

		final Any anyValue = get(index);

		if (anyValue != null) {

			if (anyValue instanceof Value) {

				return ((Value) anyValue).asString();

			} else {

				throw new InvalidValueTypeException("Cannot convert value of type '" + anyValue.getValueType() + "' to String.");

			}

		}

		return null;

	}

	/** {@inheritDoc} */

	@Override

	public Double getDoubleValue(final int index) {

		final Any anyValue = get(index);

		if (anyValue != null) {

			if (anyValue instanceof Value) {

				return ((Value) anyValue).asDouble();

			} else {

				throw new InvalidValueTypeException("Cannot convert value of type '" + anyValue.getValueType() + "' to double.");

			}

		}

		return null;

	}

	/** {@inheritDoc} */

	@Override

	public Long getLongValue(final int index) {

		final Any anyValue = get(index);

		if (anyValue != null) {

			if (anyValue instanceof Value) {

				return ((Value) anyValue).asLong();

			} else {

				throw new InvalidValueTypeException("Cannot convert value of type '" + anyValue.getValueType() + "' to long.");

			}

		}

		return null;

	}

	/** {@inheritDoc} */

	@Override

	public Boolean getBooleanValue(final int index) {

		final Any anyValue = get(index);

		if (anyValue != null) {

			if (anyValue instanceof Value) {

				return ((Value) anyValue).asBoolean();

			} else {

				throw new InvalidValueTypeException("Cannot convert value of type '" + anyValue.getValueType() + "' to boolean.");

			}

		}

		return null;

	}

	/** {@inheritDoc} */

	@Override

	public Date getDateValue(final int index) {

		final Any anyValue = get(index);

		if (anyValue != null) {

			if (anyValue instanceof Value) {

				return ((Value) anyValue).asDate();

			} else {

				throw new InvalidValueTypeException("Cannot convert value of type '" + anyValue.getValueType() + "' to Date.");

			}

		}

		return null;

	}

	/** {@inheritDoc} */

	@Override

	public Date getDateTimeValue(final int index) {

		final Any anyValue = get(index);

		if (anyValue != null) {

			if (anyValue instanceof Value) {

				return ((Value) anyValue).asDateTime();

			} else {

				throw new InvalidValueTypeException("Cannot convert value of type '" + anyValue.getValueType() + "' to DateTime.");

			}

		}

		return null;

	}

	/** {@inheritDoc} */

	@Override

	public int hashCode() {

		final int prime = 31;

		int result = 1;

		result = prime * result + (_anyList == null ? 0 : _anyList.hashCode());

		return result;

	}

	/** {@inheritDoc} */

	@Override

	public boolean equals(final Object obj) {

		if (this == obj) {

			return true;

		}

		if (obj == null) {

			return false;

		}

		if (!(obj instanceof AnySeqImpl)) {

			return false;

		}

		final AnySeqImpl other = (AnySeqImpl) obj;

		if (_anyList == null) {

			if (other._anyList != null) {

				return false;

			}

		} else if (!_anyList.equals(other._anyList)) {

			return false;

		}

		return true;

	}

	/**

	 * {@inheritDoc}

	 */

	@Override

	public String toString() {

		return _anyList.toString();

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @see org.eclipse.smila.datamodel.Any#asSeq()

	 */

	@Override

	public AnySeq asSeq() {

		return this;

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @see org.eclipse.smila.datamodel.AnySeq#asStrings()

	 */

	@Override

	public List<String> asStrings() {

		final List<String> values = new ArrayList<String>(_anyList.size());

		for (final Any any : _anyList) {

			values.add(any.asValue().asString());

		}

		return values;

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @see org.eclipse.smila.datamodel.AnySeq#asLongs()

	 */

	@Override

	public List<Long> asLongs() {

		final List<Long> values = new ArrayList<Long>(_anyList.size());

		for (final Any any : _anyList) {

			values.add(any.asValue().asLong());

		}

		return values;

	}

}

package eu.dnetlib.functionality.index.model.impl;

import java.util.Collection;

import java.util.Date;

import java.util.Iterator;

import java.util.LinkedHashMap;

import java.util.Map;

import java.util.Set;

import eu.dnetlib.functionality.index.model.Any;

import eu.dnetlib.functionality.index.model.AnyMap;

import eu.dnetlib.functionality.index.model.AnySeq;

import eu.dnetlib.functionality.index.model.InvalidValueTypeException;

import eu.dnetlib.functionality.index.model.Value;

/**

 * Class implementing AnyMap.

 */

public final class AnyMapImpl extends AbstractAny implements AnyMap {

	/** version. */

	private static final long serialVersionUID = 1L;

	/** internal representation of the AnyMap. */

	private final Map<String, Any> _anyMap;

	/** Constructs a new AnyMapImpl. */

	AnyMapImpl() {

		super(ValueType.MAP);

		_anyMap = new LinkedHashMap<String, Any>();

	}

	/** {@inheritDoc} */

	@Override

	public void add(final String key, final Any value) {

		final Any any = _anyMap.get(key);

		AnySeq anySeq = null;

		if (any == null) {

			anySeq = getFactory().createAnySeq();

			_anyMap.put(key, anySeq);

		} else if (any.isValue() || any.isMap()) {

			anySeq = getFactory().createAnySeq();

			anySeq.add(any);

			_anyMap.put(key, anySeq);

		} else { // any.isSeq()

			anySeq = (AnySeq) any;

		}

		anySeq.add(value);

	}

	/** {@inheritDoc} */

	@Override

	public void clear() {

		_anyMap.clear();

	}

	/** {@inheritDoc} */

	@Override

	public boolean isEmpty() {

		return _anyMap.isEmpty();

	}

	/** {@inheritDoc} */

	@Override

	public Set<String> keySet() {

		return _anyMap.keySet();

	}

	/** {@inheritDoc} */

	@Override

	public Any put(final String key, final String value) {

		try {

			return put(key, new ValueImpl(ValueType.STRING, value));

		} catch (final Exception e) {

			throw new IllegalArgumentException("cannot add value for key: " + key, e);

		}

	}

	/** {@inheritDoc} */

	@Override

	public Any put(final String key, final Number value) {

		if (value == null) {

			throw new IllegalArgumentException("The value of any Any must not be null.");

		}

		if (value instanceof Double) {

			return put(key, new ValueImpl(ValueType.DOUBLE, value));

		} else if (value instanceof Long) {

			return put(key, new ValueImpl(ValueType.LONG, value));

		} else if (value instanceof Integer) {

			return put(key, new ValueImpl(ValueType.LONG, Long.valueOf(value.longValue())));

		} else if (value instanceof Short) {

			return put(key, new ValueImpl(ValueType.LONG, Long.valueOf(value.longValue())));

		} else if (value instanceof Byte) {

			return put(key, new ValueImpl(ValueType.LONG, Long.valueOf(value.longValue())));

		} else { // default: DOUBLE

			return put(key, new ValueImpl(ValueType.DOUBLE, Double.valueOf(value.doubleValue())));

		}

	}

	/** {@inheritDoc} */

	@Override

	public Any put(final String key, final Boolean value) {

		return put(key, new ValueImpl(ValueType.BOOLEAN, value));

	}

	/** {@inheritDoc} */

	@Override

	public Any put(final String key, final Any value) {

		if (value == null) {

			throw new IllegalArgumentException("The value of any Any must not be null.");

		}

		return _anyMap.put(key, value);

	}

	/** {@inheritDoc} */

	@Override

	public int size() {

		return _anyMap.size();

	}

	/** {@inheritDoc} */

	@Override

	public Collection<Any> values() {

		return _anyMap.values();

	}

	/** {@inheritDoc} */

	@Override

	public Iterator<Any> iterator() {

		return _anyMap.values().iterator();

	}

	/** {@inheritDoc} */

	@Override

	public AnyMap getMap(final String key) {

		final Any anyValue = get(key);

		if (anyValue != null) {

			if (anyValue.isMap()) {

				return (AnyMap) anyValue;

			} else {

				throw new InvalidValueTypeException("Cannot convert value of type '" + anyValue.getValueType() + "' to AnyMap.");

			}

		}

		return null;

	}

	/** {@inheritDoc} */

	@Override

	public AnySeq getSeq(final String key) {

		final Any anyValue = get(key);

		if (anyValue != null) {

			if (anyValue.isSeq()) {

				return (AnySeq) anyValue;

			} else {

				throw new InvalidValueTypeException("Cannot convert value of type '" + anyValue.getValueType() + "' to AnySeq.");

			}

		}

		return null;

	}

	/** {@inheritDoc} */

	@Override

	public Value getValue(final String key) {

		final Any anyValue = get(key);

		if (anyValue != null) {

			if (anyValue instanceof Value) {

				return (Value) anyValue;

			} else {

				throw new InvalidValueTypeException("Cannot convert value of type '" + anyValue.getValueType() + "' to Value.");

			}

		}

		return null;

	}

	/** {@inheritDoc} */

	@Override

	public String getStringValue(final String key) {

		final Any anyValue = get(key);

		if (anyValue != null) {

			if (anyValue instanceof Value) {

				return ((Value) anyValue).asString();

			} else {

				throw new InvalidValueTypeException("Cannot convert value of type '" + anyValue.getValueType() + "' to String.");

			}

		}

		return null;

	}

	/** {@inheritDoc} */

	@Override

	public Double getDoubleValue(final String key) {

		final Any anyValue = get(key);

		if (anyValue != null) {

			if (anyValue instanceof Value) {

				return ((Value) anyValue).asDouble();

			} else {

				throw new InvalidValueTypeException("Cannot convert value of type '" + anyValue.getValueType() + "' to double.");

			}

		}

		return null;

	}

	/** {@inheritDoc} */

	@Override

	public Long getLongValue(final String key) {

		final Any anyValue = get(key);

		if (anyValue != null) {

			if (anyValue instanceof Value) {

				return ((Value) anyValue).asLong();

			} else {

				throw new InvalidValueTypeException("Cannot convert value of type '" + anyValue.getValueType() + "' to long.");

			}

		}

		return null;

	}

	/** {@inheritDoc} */

	@Override

	public Boolean getBooleanValue(final String key) {

		final Any anyValue = get(key);

		if (anyValue != null) {

			if (anyValue instanceof Value) {

				return ((Value) anyValue).asBoolean();

			} else {

				throw new InvalidValueTypeException("Cannot convert value of type '" + anyValue.getValueType() + "' to boolean.");

			}

		}

		return null;

	}

	/** {@inheritDoc} */

	@Override

	public Date getDateValue(final String key) {

		final Any anyValue = get(key);

		if (anyValue != null) {

			if (anyValue instanceof Value) {

				return ((Value) anyValue).asDate();

			} else {

				throw new InvalidValueTypeException("Cannot convert value of type '" + anyValue.getValueType() + "' to Date.");

			}

		}

		return null;

	}

	/** {@inheritDoc} */

	@Override

	public Date getDateTimeValue(final String key) {

		final Any anyValue = get(key);

		if (anyValue != null) {

			if (anyValue instanceof Value) {

				return ((Value) anyValue).asDateTime();

			} else {

				throw new InvalidValueTypeException("Cannot convert value of type '" + anyValue.getValueType() + "' to DateTime.");

			}

		}

		return null;

	}

	/** {@inheritDoc} */

	@Override

	public int hashCode() {

		final int prime = 31;

		int result = 1;

		result = prime * result + (_anyMap == null ? 0 : _anyMap.hashCode());

		return result;

	}

	/** {@inheritDoc} */

	@Override

	public boolean equals(final Object obj) {

		if (this == obj) {

			return true;

		}

		if (obj == null) {

			return false;

		}

		if (getClass() != obj.getClass()) {

			return false;

		}

		final AnyMapImpl other = (AnyMapImpl) obj;

		if (_anyMap == null) {

			if (other._anyMap != null) {

				return false;

			}

		} else if (!_anyMap.equals(other._anyMap)) {

			return false;

		}

		return true;

	}

	/**

	 * {@inheritDoc}

	 */

	@Override

	public String toString() {

		return _anyMap.toString();

	}

	/** {@inheritDoc} */

	@Override

	public boolean containsKey(final Object key) {

		return _anyMap.containsKey(key);

	}

	/** {@inheritDoc} */

	@Override

	public boolean containsValue(final Object value) {

		return _anyMap.containsValue(value);

	}

	/** {@inheritDoc} */

	@Override

	public Any get(final Object key) {

		return _anyMap.get(key);

	}

	/** {@inheritDoc} */

	@Override

	public void putAll(final Map<? extends String, ? extends Any> map) {

		_anyMap.putAll(map);

	}

	/** {@inheritDoc} */

	@Override

	public Any remove(final Object key) {

		return _anyMap.remove(key);

	}

	/** {@inheritDoc} */

	@Override

	public Set<java.util.Map.Entry<String, Any>> entrySet() {

		return _anyMap.entrySet();

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @see org.eclipse.smila.datamodel.impl.AbstractAny#asMap()

	 */

	@Override

	public AnyMap asMap() {

		return this;

	}

	/**

	 * {@inheritDoc}