D-Net

package eu.dnetlib.data.mapreduce.actions;

import com.google.gson.JsonObject;

import com.google.gson.JsonParser;

import eu.dnetlib.actionmanager.actions.ActionFactory;

import eu.dnetlib.actionmanager.actions.AtomicAction;

import eu.dnetlib.data.mapreduce.hbase.dataimport.CrossRefToActions;

import eu.dnetlib.data.mapreduce.hbase.dataimport.ScholixToActions;

import eu.dnetlib.data.mapreduce.util.StreamUtils;

import eu.dnetlib.miscutils.datetime.DateUtils;

import org.apache.commons.lang3.StringUtils;

import org.junit.Test;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.util.List;

public class CrossRefToActionTest {

    @Test

    public void testSingleScholixAction2() throws IOException {

        doTestSingleCrossRefAction("/eu/dnetlib/data/mapreduce/actions/part-06036");

    }

    @Test

    public void testAllScholixAction() throws IOException {

        doTestAllCrossRefAction("/eu/dnetlib/data/mapreduce/actions/part-06036");

    }

    private void doTestSingleCrossRefAction(final String filePath) throws IOException {

        final InputStream is = this.getClass().getResourceAsStream(filePath);

        final BufferedReader in = new BufferedReader(new InputStreamReader(is));

        String line = in.readLine();

        System.out.println(line);

        final JsonParser parser = new JsonParser();

        JsonObject root = parser.parse(line).getAsJsonObject();

        List<AtomicAction> actions = CrossRefToActions.generateActionsFromDump(root, new ActionFactory());

    }

    private void doTestAllCrossRefAction(final String filePath) throws IOException {

        final InputStream is = this.getClass().getResourceAsStream(filePath);

        final BufferedReader in = new BufferedReader(new InputStreamReader(is));

        String line = in.readLine();

        while(StringUtils.isNotBlank(line)) {

            final JsonParser parser = new JsonParser();

            JsonObject root = parser.parse(line).getAsJsonObject();

            try {

                List<AtomicAction> actions = CrossRefToActions.generateActionsFromDump(root, new ActionFactory());

            } catch (Throwable e) {

                System.out.println(line);

                throw new RuntimeException(e);

            }

            line= in.readLine();

        }

    }

}