D-Net

package eu.dnetlib.msro.workers.aggregation.collect.plugins.oaisets;

import java.util.stream.Stream;

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

import org.springframework.stereotype.Component;

import eu.dnetlib.miscutils.streams.DnetStreamSupport;

import eu.dnetlib.msro.workers.aggregation.collect.CollectException;

import eu.dnetlib.msro.workers.aggregation.collect.plugins.CollectorPlugin;

import eu.dnetlib.msro.workers.aggregation.collect.plugins.DnetCollectorPlugin;

import eu.dnetlib.msro.workers.aggregation.collect.plugins.oai.engine.HttpConnector;

import eu.dnetlib.msro.workers.aggregation.objects.InterfaceDescriptor;

@Component

@DnetCollectorPlugin("oai_sets")

public class OaiSetsCollectorPlugin implements CollectorPlugin {

	@Autowired

	private HttpConnector httpConnector;

	@Override

	public Stream<String> collect(final InterfaceDescriptor interfaceDescriptor, final String fromDate, final String untilDate)

			throws CollectException {

		final String baseUrl = interfaceDescriptor.getBaseUrl();

		if ((baseUrl == null) || baseUrl.isEmpty()) { throw new CollectException("Param 'baseurl' is null or empty"); }

		return DnetStreamSupport.stream(new OaiSetsIterator(baseUrl, httpConnector));

	}

}