D-Net

                "10.1594/pangaea.230638");

package eu.dnetlib.dli.collector.plugin;

import org.antlr.stringtemplate.StringTemplate;

import org.apache.commons.io.IOUtils;

import org.junit.Test;

import java.io.IOException;

import java.io.InputStream;

public class CrossRefIteratorTest {

    @Test

    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);

            }

        }

    }

}

<link xmlns="http://www.scholix.org">

    $if(object.date)$<publicationDate>$object.date$</publicationDate>$endif$

    <linkProvider>

        $object.datasourceProvenance:{

        <name>$it.datasource$</name>

        <identifiers>

            <identifier>$it.datasourceId$</identifier>

        </identifiers>

    </linkProvider>

    }$

    $object.relations:{

    <relashionship>

        <name>$it.relationSemantics$</name>

        <schema>datacite</schema>

        $if(it.inverseRelation)$

        <inverseRelashionship>$it.inverseRelation$</inverseRelashionship>

        $endif$

    </relashionship>

    }$

    <source>

        <identifier>

            <identifier>$object.pid$</identifier>

            <schema>$object.type$</schema>

        </identifier>

        <objectType>

            <type>$object.type$</type>

        </objectType>

    </source>

    <target>

        $object.relations:{

        <identifier>

            <identifier>$it.targetPID.id$</identifier>

            <schema>$it.targetPID.type$</schema>

        </identifier>

        <objectType>

            <type>$it.targetType$</type>

        </objectType>

        }$

    </target>

</link>

			shouldUpdate = tryToResolveRecord(inputObject);

import eu.dnetlib.dli.resolver.model.CompletionStatus;

import org.springframework.beans.factory.annotation.Required;

import java.util.Objects;

            log.error("Error on getting item with Pid: " +  pid, e);

                    .map(this::createSubjectType)

                    .filter(Objects::nonNull)

        dli.setDatasourceProvenance(A);

        dli.setCompletionStatus(CompletionStatus.complete.toString());

    private SubjectType createSubjectType(final JsonObject item){

        if (item.has("term") && !item.get("term").isJsonNull())

            return new SubjectType(item.get("scheme").getAsString(), item.get("term").getAsString());

        else {

            return null;

        }

    }

    @Required

        try {

            final DLIResolvedObject object = new DLIResolvedObject();

            final String id = item.get("Source").getAsJsonObject().get("Identifier").getAsJsonObject().get("ID").getAsString();

            final String id_type = item.get("Source").getAsJsonObject().get("Identifier").getAsJsonObject().get("IDScheme").getAsString();

            object.setPid(id);

            object.setPidType(id_type);

            final String type = item.get("Source").getAsJsonObject().get("Type").getAsJsonObject().get("Name").isJsonNull()?"unknownw":item.get("Source").getAsJsonObject().get("Type").getAsJsonObject().get("Name").getAsString();

            object.setType(type.equals("literature") ? ObjectType.publication : ObjectType.dataset);

            final String relType = item.get("RelationshipType").getAsJsonObject().get("Name").getAsString();

            object.setDatasourceProvenance(Collections.singletonList(new DLIObjectProvenance().setDatasource("Crossref").setDatasourceId("dli_________::crossref")));

            DLIObjectRelation relation = new DLIObjectRelation();

            relation.setRelationSemantics(relType);

            final String t_id = item.get("Target").getAsJsonObject().get("Identifier").getAsJsonObject().get("ID").getAsString();

            final String t_id_type = item.get("Target").getAsJsonObject().get("Identifier").getAsJsonObject().get("IDScheme").getAsString();

            final String t_type = item.get("Target").getAsJsonObject().get("Type").getAsJsonObject().get("Name").isJsonNull()?"unknown":item.get("Target").getAsJsonObject().get("Type").getAsJsonObject().get("Name").getAsString();

            relation.setTargetPID(new PID(t_id, t_id_type));

            relation.setTargetType(t_type.equals("literature") ? ObjectType.publication : ObjectType.dataset);

            object.setRelations(Collections.singletonList(relation));

            relation.setCompletionStatus("incomplete");

            relation.setRelationProvenance(Collections.singletonList(new DLIObjectProvenance().setDatasource("Crossref").setDatasourceId("dli_________::crossref")));

            try {

                StringWriter writer = new StringWriter(16);

                NoIndentWriter out = new NoIndentWriter(writer);

                resolverSerializer.removeAttribute("object");

                resolverSerializer.setAttribute("object", object);

                resolverSerializer.write(out);

                String result = writer.toString();

                writer.close();

                return result;

            } catch (Throwable e) {

                throw new RuntimeException(e);

            }

        }catch (Throwable e) {

            System.out.println(item.toString());

                if (message.has("next-cursor") && !message.get("next-cursor").isJsonNull())

                    nextCursor = message.get("next-cursor").getAsString();

                else

                    nextCursor = null;

                return nextCursor!=null;

    <bean id="dataciteOfflineResolver"

		  class="eu.dnetlib.dli.resolver.DataciteOfflineResolver"

		  p:order="0" p:availableOffline="true"

		  p:mongoClient-ref="mongoClient">

            <identifier>$object.escapedXMLPid$</identifier>

            <schema>$object.pidType$</schema>

            <identifier>$it.targetPID.escapeXMLId$</identifier>

	<packaging>jar</packaging>