D-Net

import com.google.common.collect.Lists;

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

import eu.dnetlib.data.transform.Column;

import eu.dnetlib.data.transform.Row;

import eu.dnetlib.data.transform.XsltRowTransformerFactoryTest;

import org.dom4j.Document;

import org.dom4j.io.DocumentResult;

import org.dom4j.io.DocumentSource;

import org.dom4j.io.SAXReader;

import javax.xml.transform.Transformer;

import javax.xml.transform.TransformerFactory;

import java.io.*;

import java.util.Map;

public class DOIBoostToActionsTest extends XsltRowTransformerFactoryTest {

    private final static String xslt =

            "<xsl:stylesheet version=\"1.0\" xmlns:xsl=\"http://www.w3.org/1999/XSL/Transform\">\n"

                    + "  <xsl:template match=\"@*|node()\">\n"

                    + "    <xsl:copy>\n"

                    + "      <xsl:apply-templates select=\"@*|node()\"/>\n"

                    + "    </xsl:copy>\n"

                    + "  </xsl:template>\n"

                    + "</xsl:stylesheet>";

    private Transformer transformer;

        doTestSingleDOIBoostAction("/eu/dnetlib/data/mapreduce/actions/broken");

    public void testDOIBoostActionToXML() throws Exception {

        doTestSingleDOIBoostActionToXML("/eu/dnetlib/data/mapreduce/actions/broken");

    }

    @Test

    private void doTestSingleDOIBoostActionToXML(final String filePath) throws Exception {

        final List<Row> rows = Lists.newArrayList();

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

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

        String line = in.readLine();

        final JsonParser parser = new JsonParser();

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

        List<AtomicAction> actions = DOIBoostToActions.generatePublicationActionsFromDump(root, new ActionFactory(), setName, agent, false, false);

        if (actions!= null) {

            actions.forEach(action-> {

                if (action.getTargetColumn().equals("body") && action.getTargetColumnFamily().equals("result"))

                {

                    Column<String, byte[]> col = new Column<>("body" , action.getTargetValue());

                    rows.add(new Row("result",action.getTargetRowKey() , Lists.newArrayList(col)));

                }

            });

        }

        Map<String, XmlRecordFactory> stringXmlRecordFactoryMap = mapAll(buildTable(rows));

        transformer = TransformerFactory.newInstance().newTransformer(new DocumentSource((new SAXReader()).read(new StringReader(xslt))));

        final SAXReader saxReader = new SAXReader();

        stringXmlRecordFactoryMap.values().forEach(it -> {

            try {

                final DocumentResult result = new DocumentResult();

                final Document document = saxReader.read(new StringReader(it.build()));

                transformer.transform(new DocumentSource(document), result);

                System.out.println(result.getDocument().asXML());

            }

            catch (Exception e) {

                e.printStackTrace();

            }

            });

    }

        List<AtomicAction> actions = DOIBoostToActions.generatePublicationActionsFromDump(root, new ActionFactory(), setName, agent, false, false);