D-Net

	@Test

	public void andsResolverTest() throws Exception {

        Assert.assertNotNull(doi);

		Assert.assertNotNull(doi.getTitles());

		Assert.assertNotNull(doi.getDatasourceProvenance());

	@Test

	public void pubmedResolverTest() throws Exception {

        Assert.assertNotNull(pubmedObject);

		Assert.assertNotNull(pubmedObject.getAuthors());

		Assert.assertNotNull(pubmedObject.getTitles());

	@Test

	public void openaireResolverTest() throws Exception {

        System.out.println("pubmedObject = " + pubmedObject);

		Assert.assertNotNull(pubmedObject);

		Assert.assertNotNull(pubmedObject.getAuthors());

	@Test

	public void crossRefResolverTest() throws Exception {

        Assert.assertNotNull(pubmedObject);

		Assert.assertNotNull(pubmedObject.getAuthors());

		Assert.assertNotNull(pubmedObject.getTitles());

	@Test

	public void rcsbResolverTest() throws Exception {

        Assert.assertNotNull(pubmedObject);

		Assert.assertNotNull(pubmedObject.getAuthors());

		Assert.assertNotNull(pubmedObject.getTitles());

    @Test

    public void enaResolverTest() throws java.lang.Exception {

        Assert.assertNotNull(enaObject);

        Assert.assertNotNull(enaObject.getAuthors());

        Assert.assertNotNull(enaObject.getTitles());

				"10.6085/AA/TPT006_061MXTI061R00_20020806.50.3", "10013/epic.26895.d001" };

		int k = 0;

		double average_sum = 0.0f;

        Assert.assertNotNull(object);

        Assert.assertNotNull(object);

		log.info(object);

		log.info(object.getSubjects());

    private DLIResolvedObject resolveRelation(final PID currentPid, final ObjectProvenance provenance) {

        for (PIDResolver resolver : pluginResolver) {

            if (currentIdentifier != null &&

                    !StringUtils.isBlank(currentIdentifier.getPid()) &&

public class DLIRecordResolverFactory implements RecordResolverFactory {

    @Override

    }

    @Override

        final DLIRecordResolver resolver = new DLIRecordResolver(System.currentTimeMillis());

        resolver.setInputQueue(queue);

        resolver.setOutputCollection(outputCollection);

        resolver.setSerializer(serializer);

        resolver.setPluginResolver(pluginResolver);

        return resolver;

    }

}

		log.debug("tryToResolveRelation " + currentPid);

		for (PIDResolver resolver : pluginResolver) {

            if (currentIdentifier != null && !StringUtils.isBlank(currentIdentifier.getPid()) && currentIdentifier.getPid().toLowerCase().equals(currentPid.getId().toLowerCase())) {

    private boolean tryToResolveRecord(final DLIResolvedObject object) {

		for (PIDResolver resolver : pluginResolver) {

            if (resolvedObject != null &&

					resolvedObject.getCompletionStatus() != null &&

                    resolvedObject.getCompletionStatus().equals(CompletionStatus.complete.toString())) {

	 */

	private final static String baseUrlCrossref = "http://api.crossref.org/works/";

	/**

	 * The parser.

	 */

			return iterator.next().toJson();

		}

		return null;

}

	      p:cacheManager-ref="dliCacheManager" p:cacheName="dliResolverCache"/>

		<property name="cache" ref="dliResolverCache"/>

	</bean>

	<bean id="rcsbParser" class="eu.dnetlib.dli.resolver.RCSBParser"/>

		<property name="cache" ref="dliResolverCache"/>

	</bean>

        <property name="cache" ref="dliResolverCache"/>

    </bean>

		<property name="cache" ref="dliResolverCache"/>

	</bean>

		<property name="cache" ref="dliResolverCache"/>

	</bean>

		<property name="cache" ref="dliResolverCache"/>

	</bean>

		<property name="cache" ref="dliResolverCache"/>

	</bean>

	<bean id="crossrefRecordParserJSON" class="eu.dnetlib.dli.resolver.CrossRefParserJSON"/>

    <bean id="openaireResolver" class="eu.dnetlib.dli.resolver.OpenaireResolver" p:order="0"

	<bean id="dliResolverPlugin" class="eu.dnetlib.pid.resolver.mdstore.plugin.ResolverMDStorePlugin"/>

        <WORKFLOW_FAMILY>aggregator</WORKFLOW_FAMILY>

        <WORKFLOW_PRIORITY>$priority$</WORKFLOW_PRIORITY>

        <DATASOURCE id="$dsId$" interface="$interface$" />

        <CONFIGURATION status="WAIT_SYS_SETTINGS" start="MANUAL">

            <PARAMETERS>

            	<PARAM name="collMdstoreId"                     description="Store for collected records"           required="true" managedBy="system" category="MDSTORE_ID"/>

            	<PARAM name="unknownMdstoreId"                  description="Store for unknown records"             required="true" managedBy="system" category="MDSTORE_ID"/>

            	<PARAM name="cleanTransformationRuleId"         description="Transformation Rule Identifier"        required="true" managedBy="user"   category="TRANSFORMATION_RULE_ID" type="string" function="listProfiles('TransformationRuleDSResourceType', '//TITLE', 'DLI:')"/>

            	<PARAM description="Type of Transformation" function="validValues(['simpleTransform', 'transformAndUnpack'])" managedBy="user" name="typeOfTransform" required="true" type="string">simpleTransform</PARAM>

            </PARAMETERS>

            <WORKFLOW>

                <NODE isStart="true" name="collection" type="LaunchWorkflowTemplate">

                                    <ENTRY key="interface"              value="$interface$" />

                                    <ENTRY key="collMdstoreId"          ref="collMdstoreId" />

                                    <ENTRY key="cleanMdstoreId"         ref="cleanMdstoreId" />

                                </MAP>

                            </PARAM>

                        </PARAMETERS>

				<PARAM name="interface" description="Datasource Interface" required="true" type="string"/>

				<PARAM name="collMdstoreId" description="Store for collected records" required="true" type="string"/>

				<PARAM name="cleanMdstoreId" description="Store for cleaned records" required="true" type="string"/>

			</PARAMETERS>

			<WORKFLOW>

						<PARAM name="mdStoreId" ref="cleanMdstoreId"/>

						<PARAM name="pluginName" value="dliResolverPlugin"/>

                        <PARAM name="numberOfThreads" ref="numberOfThreads"/>

                    </PARAMETERS>

					<ARCS>

						<ARC to="UPDATE_INFO"/>

    @Test

    public void testDLIResolvePublication() throws Exception {

        final ResolvedObject doi_stored = store.getRecord("10.1016/j.quascirev.2011.06.004", "doi");

        assertNotNull(doi_stored);

    @Test

    public void testOpenAireResolvePublication() throws Exception {

        assertNotNull(openaire);

        System.out.println(openaire.toJsonString());

        final ResolvedObject doi_stored = store.getRecord("10.1126/science.1141038", "doi");

    @Test

    public void testSerializationResolvedPublication() throws Exception {

        assertNotNull(openaire);

        openaire.addDate("IMPORTANT DATE", "20-09-1982");

public class WDSRecordResolverFactory implements RecordResolverFactory {

    @Override

    }

    @Override

        final WDSRecordResolver resolver = new WDSRecordResolver(System.currentTimeMillis());

        resolver.setInputQueue(queue);

        resolver.setOutputCollection(outputCollection);

        resolver.setSerializer(serializer);

        resolver.setPluginResolver(pluginResolver);

        return resolver;

    }

}

import com.mongodb.client.MongoCollection;

import eu.dnetlib.pid.resolver.PIDResolver;

import eu.dnetlib.pid.resolver.mdstore.plugin.AbstractRecordResolver;

import eu.dnetlib.pid.resolver.mdstore.plugin.ResolverSerializer;

import eu.dnetlib.pid.resolver.model.ObjectType;

import eu.dnetlib.pid.resolver.model.PID;

import eu.dnetlib.wds.parser.WDSParser;

import eu.dnetlib.wds.utils.WDSUtils;

import org.antlr.stringtemplate.StringTemplate;

import org.apache.commons.lang3.StringUtils;

import java.util.HashMap;

import java.util.List;

        log.debug("tryToResolveRelation " + currentPid);

        for (PIDResolver resolver : pluginResolver) {

            if (currentIdentifier != null && !StringUtils.isBlank(currentIdentifier.getPid()) && currentIdentifier.getPid().toLowerCase().equals(currentPid.getId().toLowerCase())) {

	protected String name;

	protected int order;

	@Autowired

	private ResolverStore storeManager;

//    public abstract void setDatasourceProvenance(final ObjectProvenance provenance, final String namespacePrefix);

		if (!canResolvePid(pidType)) return null;

        final String dnetIdentifier = storeManager.generateDNetIdentifier(pid, pidType);

        final Element item = cache.get(dnetIdentifier);

		return null;

	}

		if (!canResolvePid(pidType)) return null;

		final String dnetIdentifier = storeManager.generateDNetIdentifier(pid, pidType);

		final Element item = cache.get(dnetIdentifier);

	public int compareTo(PIDResolver o) {

		return Integer.compare(getOrder(), o.getOrder());

	}

}

    protected BlockingQueue<DBObject> inputQueue;

    protected MongoCollection<DBObject> outputCollection;

    protected ResolverSerializer serializer;

    public AbstractRecordResolver(final long ts) {

        this.timestamp = ts;

    @Override

    public Boolean call() throws Exception {

        DBObject currentObject = inputQueue.take();

        int i = 0;

    }

    protected abstract Map<String, ObjectType> tryToResolveRelation(PID targetPID);

}

public interface RecordResolverFactory {

}

import java.util.ArrayList;

import java.util.List;

import java.util.Map;

import java.util.concurrent.*;

import static com.mongodb.client.model.Filters.eq;

		try {

			final String id = params.get("mdStoreId");

            int numberOfThreads = 4;

            final long ts = System.currentTimeMillis();

            for (int i = 0; i < numberOfThreads; i++) {

				responses.add(executor.submit(resolver));

			}

	 * @param pidType the type of persistent identifier to resolve

	 * @return the DLIObject resolved if exists, null otherwise

	 */

	/**

	 * Resolve and return the Dnet Identifier

	 * @return the Dnet Identifier of the DLI Object resolved if exists, null otherwise

	 */

}

    private String numberOfThreads;

	public String getPluginName() {

		return this.pluginName;

	}

		job.getParameters().put("mdStoreId", getMdStoreId());

        if (!StringUtils.isEmpty(getNumberOfThreads()))

            job.getParameters().put("numberOfThreads", getNumberOfThreads());

    }

    public String getNumberOfThreads() {

    }

}