D-Net

package eu.dnetlib.data.collector.plugins.datacite;

import eu.dnetlib.data.collector.plugin.AbstractCollectorPlugin;

import eu.dnetlib.data.collector.plugin.CollectorPlugin;

import eu.dnetlib.data.collector.rmi.CollectorServiceException;

import eu.dnetlib.data.collector.rmi.InterfaceDescriptor;

import eu.dnetlib.miscutils.datetime.DateUtils;

import org.apache.commons.lang3.StringUtils;

import java.util.Date;

public class DataciteCollectorPlugin extends AbstractCollectorPlugin implements CollectorPlugin {

    @Override

    public Iterable<String> collect(InterfaceDescriptor interfaceDescriptor, String fromDate, String untilDate) throws CollectorServiceException {

        long timestamp= 0;

        if (StringUtils.isNotBlank(fromDate)) {

            Date parsed = new DateUtils().parse(fromDate);

            timestamp =parsed.getTime() /1000;

        }

        final long finalTimestamp = timestamp;

        return () -> {

            try {

                return new DataciteESIterator(finalTimestamp);

            } catch (Exception e) {

                throw new RuntimeException(e );

            }

        };

    }

}