D-Net

import eu.dnetlib.data.resultSet.ResultSetFactory;

import eu.dnetlib.data.resultSet.ResultSetIterator;

package eu.dnetlib.data.resultSet;

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

import org.springframework.core.io.Resource;

import com.google.common.base.Function;

import eu.dnetlib.enabling.datastructures.CleaningRule;

import eu.dnetlib.enabling.datastructures.TransformationRule;

import eu.dnetlib.miscutils.ApplyXslt;

import eu.dnetlib.rmi.objects.resultSet.ResultSet;

public class ResultSetFactory {

	private ResultSetServiceImpl service;

	private ResultSetRegistry registry;

	public <T> ResultSet<T> createResultSet(final ResultSetIterator<T> iter) {

		final String rsId = registry.registerIterator(iter);

		final String protocol = service.getMainProtocol();

		return new ResultSet<T>(rsId, protocol, service.getProtocols().get(protocol));

	}

	public <T, K> ResultSet<T> transform(final ResultSet<K> rs, final Function<K, T> function) {

		// TODO

		return null;

	}

	public ResultSet<String> transform(final ResultSet<String> rs, final String ruleId) {

		// TODO

		return null;

	}

	public ResultSet<String> transform(final ResultSet<String> rs, final TransformationRule rule) {

		// TODO

		return null;

	}

	public ResultSet<String> applyXslt(final ResultSet<String> rs, final String xslt) {

		return transform(rs, new ApplyXslt(xslt));

	}

	public ResultSet<String> applyXslt(final ResultSet<String> rs, final Resource xslt) {

		return transform(rs, new ApplyXslt(xslt));

	}

	public ResultSet<String> clean(final ResultSet<String> rs, final String ruleId) {

		// TODO

		return null;

	}

	public ResultSet<String> clean(final ResultSet<String> rs, final CleaningRule rule) {

		// TODO

		return null;

	}

	public ResultSetServiceImpl getService() {

		return service;

	}

	@Required

	public void setService(final ResultSetServiceImpl service) {

		this.service = service;

	}

	public ResultSetRegistry getRegistry() {

		return registry;

	}

	@Required

	public void setRegistry(final ResultSetRegistry registry) {

		this.registry = registry;

	}

}

package eu.dnetlib.data.resultSet;

import java.util.UUID;

import javax.annotation.PostConstruct;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

import com.google.common.cache.Cache;

import com.google.common.cache.CacheBuilder;

import com.google.common.cache.RemovalListener;

import com.google.common.cache.RemovalNotification;

import eu.dnetlib.rmi.soap.exceptions.ResultSetException;

public class ResultSetRegistry {

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

	private CacheBuilder<String, ResultSetIterator<?>> cacheBuilder;

	private Cache<String, ResultSetIterator<?>> cache;

	@PostConstruct

	public void initCache() {

		cache = cacheBuilder.removalListener(new RemovalListener<String, ResultSetIterator<?>>() {

			@Override

			public void onRemoval(final RemovalNotification<String, ResultSetIterator<?>> notification) {

				log.info("Deleting old resultset: " + notification.getKey() + " - finished: " + notification.getValue().isFinished());

			}

		}).build();

	}

	public ResultSetIterator<?> findIterator(final String rsId) throws ResultSetException {

		final ResultSetIterator<?> iter = cache.getIfPresent(rsId);

		if (iter != null) {

			return iter;

		} else {

			log.error("Resultset not found, id = " + rsId);

			throw new ResultSetException("ResultSet not found, id = " + rsId);

		}

	}

	public String registerIterator(final ResultSetIterator<?> iter) {

		final String rsId = "rs-" + UUID.randomUUID();

		cache.put(rsId, iter);

		return rsId;

	}

	public CacheBuilder<String, ResultSetIterator<?>> getCacheBuilder() {

		return cacheBuilder;

	}

	@Required

	public void setCacheBuilder(final CacheBuilder<String, ResultSetIterator<?>> cacheBuilder) {

		this.cacheBuilder = cacheBuilder;

	}

}

package eu.dnetlib.data.resultSet;

import java.util.List;

public interface ResultSetIterator<T> {

	int position();

	boolean isFinished();

	int getTotal();

	List<T> getNextElements(int n);

}

package eu.dnetlib.data.resultSet;

import java.util.List;

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

import org.springframework.web.bind.annotation.PathVariable;

import com.google.common.collect.Lists;

import com.google.gson.Gson;

import eu.dnetlib.rmi.objects.resultSet.ResultSetResponse;

import eu.dnetlib.rmi.soap.exceptions.ResultSetException;

public class ResultSetServiceCore {

	private ResultSetRegistry registry;

	public ResultSetResponse getNextResults(@PathVariable final String rsId, @PathVariable final int n) throws ResultSetException {

		final ResultSetIterator<?> iter = registry.findIterator(rsId);

		final int from = iter.position();

		final Gson gson = new Gson();

		final List<String> elements = Lists.newArrayList();

		for (Object o : iter.getNextElements(n)) {

			elements.add(gson.toJson(o));

		}

		final int to = iter.position();

		final boolean end = iter.isFinished();

		final int total = iter.getTotal();

		return new ResultSetResponse(from, to, end, total, elements);

	}

	public ResultSetRegistry getRegistry() {

		return registry;

	}

	@Required

	public void setRegistry(final ResultSetRegistry registry) {

		this.registry = registry;

	}

}

package eu.dnetlib.data.resultSet;

import javax.annotation.Resource;

import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RestController;

import eu.dnetlib.rmi.objects.resultSet.ResultSetResponse;

import eu.dnetlib.rmi.rest.ResultSetService;

import eu.dnetlib.rmi.soap.exceptions.ResultSetException;

@RestController

@RequestMapping("/rest/rs")

public class ResultSetRestController implements ResultSetService {

	@Resource

	private ResultSetServiceCore core;

	@Override

	@RequestMapping(value = "/{rsId}/{n}", method = RequestMethod.GET)

	public ResultSetResponse getNextResults(@PathVariable final String rsId, @PathVariable final int n) throws ResultSetException {

		return core.getNextResults(rsId, n);

	}

}

package eu.dnetlib.data.resultSet;

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

import eu.dnetlib.common.services.AbstractBaseService;

import eu.dnetlib.rmi.objects.resultSet.ResultSetResponse;

import eu.dnetlib.rmi.soap.ResultSetService;

import eu.dnetlib.rmi.soap.exceptions.ResultSetException;

public class ResultSetServiceImpl extends AbstractBaseService implements ResultSetService {

	private ResultSetServiceCore core;

	@Override

	public ResultSetResponse getNextResults(final String rsId, final int n) throws ResultSetException {

		return core.getNextResults(rsId, n);

	}

	public ResultSetServiceCore getCore() {

		return core;

	}

	@Required

	public void setCore(final ResultSetServiceCore core) {

		this.core = core;

	}

}

dnet.resultsets.cache.conf = maximumSize=300, expireAfterAccess=10m, expireAfterWrite=1h

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxws="http://cxf.apache.org/jaxws"

	xmlns:sec="http://cxf.apache.org/configuration/security" xmlns:wsa="http://cxf.apache.org/ws/addressing"

	xmlns:p="http://www.springframework.org/schema/p" xmlns:http="http://cxf.apache.org/transports/http/configuration"

	xmlns:t="http://dnetlib.eu/springbeans/t" xmlns:template="http://dnetlib.eu/springbeans/template"

	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd

                                    http://cxf.apache.org/ws/addressing http://cxf.apache.org/schemas/ws-addr-conf.xsd

                                    http://cxf.apache.org/configuration/security http://cxf.apache.org/schemas/configuration/security.xsd

                                    http://cxf.apache.org/transports/http/configuration http://cxf.apache.org/schemas/configuration/http-conf.xsd

                            http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd

                            http://dnetlib.eu/springbeans/template http://dnetlib.eu/springbeans/template.xsd">

	<!-- service beans -->

	<bean id="newResultSetService" 

		class="eu.dnetlib.data.resultSet.ResultSetServiceImpl"

		p:core-ref="newResultSetCore"

		p:mainProtocol="REST">

		<property name="protocols">

			<map>

				<entry key="SOAP" value="http://${container.hostname}:${container.port}/${container.context}/services/rs"/>

				<entry key="REST" value="http://${container.hostname}:${container.port}/${container.context}/mvc/rest/rs"/>				

			</map>

		</property>

	</bean>

	<!-- endpoints -->

	<jaxws:endpoint id="newResultSetServiceEndpoint" implementor="#newResultSetService"

		implementorClass="eu.dnetlib.rmi.soap.ResultSetService"

		address="/rs" />

	<!-- Other beans -->

	<bean id="newResultSetCore"

		class="eu.dnetlib.data.resultSet.ResultSetServiceCore"

		p:registry-ref="newResultSetRegistry" />

	<bean id="newResultSetRegistry"

		class="eu.dnetlib.data.resultSet.ResultSetRegistry">

		<property name="cacheBuilder">

			<bean class="com.google.common.cache.CacheBuilder" factory-method="from">

				<constructor-arg value="${dnet.resultsets.cache.conf}" />

			</bean>

		</property>

	</bean>

	<bean id="newResultSetFactory"

		class="eu.dnetlib.data.resultSet.ResultSetFactory"

		p:registry-ref="newResultSetRegistry"

		p:service-ref="newResultSetService" />

</beans>

		<config>src/main/resources/eu/dnetlib/data/resultSet/applicationContext-resultSet-service.xml</config>