D-Net

package eu.dnetlib.dli.collector.plugin;

import org.antlr.stringtemplate.StringTemplate;

import org.apache.commons.io.IOUtils;

import org.apache.http.HttpEntity;

import org.apache.http.client.ResponseHandler;

import org.apache.http.client.config.RequestConfig;

import org.apache.http.client.methods.CloseableHttpResponse;

import org.apache.http.client.methods.HttpGet;

import org.apache.http.impl.client.CloseableHttpClient;

import org.apache.http.impl.client.HttpClientBuilder;

import org.apache.http.util.EntityUtils;

import org.junit.Ignore;

import org.junit.Test;

import java.io.IOException;

import java.io.InputStream;

public class CrossRefIteratorTest {

    @Test

    @Ignore

    public void CrossRefIteratorTest() throws IOException {

        final InputStream resourceAsStream = getClass().getResourceAsStream("/eu/dnetlib/dli/templates/Scholixv1.st");

        final String template = IOUtils.toString(resourceAsStream);

        final StringTemplate st = new StringTemplate(template);

        CrossRefIterator ci = new CrossRefIterator(st);

        int i =0;

        while (ci.hasNext()){

            ci.next();

            i++;

            if (i % 100 ==0 ) {

                System.out.println("Read "+i);

            }

        }

    }

    private static ResponseHandler<String> responseHandler = response -> {

        int status = response.getStatusLine().getStatusCode();

        if (status >= 200 && status < 300) {

            HttpEntity entity = response.getEntity();

            return entity != null ? EntityUtils.toString(entity) : null;

        } else {

            System.out.println("Unexpected response status: " + status);

            return null;

        }

    };

    @Test

    public void testGettingRequest() throws IOException {

        final String url ="https://api.eventdata.crossref.org/v1/events/scholix?mailto=sandro.labruzzo@isti.cnr.it&rows=100";

        int timeout = 300;

        RequestConfig config = RequestConfig.custom()

                .setConnectTimeout(timeout * 1000)

                .setConnectionRequestTimeout(timeout * 1000)

                .setSocketTimeout(timeout * 1000).build();

        final CloseableHttpClient httpclient = HttpClientBuilder.create().setDefaultRequestConfig(config).build();

        HttpGet httpGet = new HttpGet(url);

        String s = httpclient.execute(httpGet, responseHandler);

        System.out.println(s);

    }

}