D-Net

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

import java.util.concurrent.atomic.AtomicLong;

import org.junit.Before;

import org.junit.Ignore;

import org.junit.Test;

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

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

@Ignore

public class FairSharingPluginTest {

	private FairSharingPlugin plugin;

	private InterfaceDescriptor ifcDescr;

	@Before

	public void setUp() throws Exception {

		plugin = new FairSharingPlugin();

		ifcDescr = new InterfaceDescriptor();

		ifcDescr.setBaseUrl("https://api.fairsharing.org");

		ifcDescr.getParams().put("login", "");

		ifcDescr.getParams().put("password", "");

	}

	@Test

	public void testDownload() throws CollectorServiceException {

		final AtomicLong count = new AtomicLong(0);

		plugin.collect(ifcDescr, null, null).forEach(s -> {

			// System.out.println(s);

			final long x = count.incrementAndGet();

			if (x % 100 == 0) {

				System.out.println(x);

			}

		});

		System.out.println("TOTAL: " + count.get());

	}

}