D-Net

package eu.dnetlib.data.claimsDemo;

/**

 * Created by Eri on 18/11/2015.

 */

import com.google.gson.Gson;

import com.google.gson.GsonBuilder;

import com.sun.org.apache.xerces.internal.xs.StringList;

import eu.dnetlib.data.claims.migration.ClaimValidation;

import eu.dnetlib.data.claims.migration.JsonldBuilder;

import eu.dnetlib.data.claims.migration.Migration;

import eu.dnetlib.data.claims.migration.entity.Claim;

import eu.dnetlib.data.claims.migration.entity.Project;

import eu.dnetlib.data.claims.migration.entity.Result;

import eu.dnetlib.data.claims.migration.handler.*;

import eu.dnetlib.data.claims.migration.parser.DMFParser;

import eu.dnetlib.data.claims.migration.parser.ExternalRecordParser;

import org.apache.log4j.BasicConfigurator;

import org.apache.log4j.Logger;

import org.junit.Before;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.context.ApplicationContext;

import org.springframework.context.annotation.PropertySource;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import org.springframework.context.support.PropertySourcesPlaceholderConfigurer;

import org.springframework.core.io.ClassPathResource;

import org.springframework.test.context.ContextConfiguration;

import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import org.xml.sax.SAXException;

import javax.xml.parsers.ParserConfigurationException;

import javax.xml.transform.TransformerException;

import javax.xml.xpath.XPathExpressionException;

import java.io.File;

import java.io.IOException;

import java.math.BigInteger;

import java.security.MessageDigest;

import java.sql.ResultSet;

import java.util.*;

import static junit.framework.Assert.assertNotNull;

/**

 * @author eri

 */

@RunWith(SpringJUnit4ClassRunner.class)

@ContextConfiguration(locations = {"../claims/migration/springContext-claimsDemo.xml"})

@PropertySource("../claims/migration/springContext-claimsDemo.properties")

public class TestClass {

	private Logger log = Logger.getLogger(this.getClass());

	private SqlDAO sqlDAO;

    private SqlStore sqlStore;

    private QueryGenerator queryGenerator;

    RelationHandler relationHandler = null;

    ContextRelationHandler contextRelationHandler = null;

    ProjectHandler projectHandler = null;

    DirectIndexHandler directIndexHandler = null;

    FetchProjectHandler fetchProjectHandler = null;

    DMFContextHandler dmfContextHandler = null;

    DMFResultHandler dmfResultHandler = null;

    IndexResultHandler indexResultHandler = null;

    ExternalRecordHandler externalRecordHandler = null;

    ResultHandler resultHandler = null;

    FetchClaimHandler fetchClaimHandler = null;

    ClaimHandler claimHandler = null;

    ClaimValidation claimValidation = null;

    @Before

	public void init() throws Exception {

		BasicConfigurator.configure();

        ApplicationContext context = new ClassPathXmlApplicationContext("eu/dnetlib/data/claims/migration/springContext-claimsDemo.xml");

        relationHandler = context.getBean(RelationHandler.class);

        directIndexHandler = context.getBean(DirectIndexHandler.class);

        contextRelationHandler = context.getBean(ContextRelationHandler.class);

        projectHandler = context.getBean(ProjectHandler.class);

        fetchProjectHandler = context.getBean(FetchProjectHandler.class);

        dmfContextHandler = context.getBean(DMFContextHandler.class);

        dmfResultHandler = context.getBean(DMFResultHandler.class);

        externalRecordHandler = context.getBean(ExternalRecordHandler.class);

        indexResultHandler = context.getBean(IndexResultHandler.class);

        resultHandler = context.getBean(ResultHandler.class);

        claimHandler = context.getBean(ClaimHandler.class);

        sqlDAO = context.getBean(SqlDAO.class);

        sqlStore = context.getBean(SqlStore.class);

        queryGenerator = context.getBean(QueryGenerator.class);

        fetchClaimHandler = context.getBean(FetchClaimHandler.class);

        claimValidation = context.getBean(ClaimValidation.class);

        assertNotNull(sqlDAO);

	}

    @Test

    public void testRollback(){

        List <String> commands = new ArrayList<String>();

        commands.add("UPDATE claim SET claimedBy = 'argirok1' WHERE  id = 93");

        commands.add("EXCEPTION");

        commands.add("UPDATE claim SET claimedBy = 'argirok2' WHERE  id = 95");

        try {

            sqlStore.executeUpdateWithRollback(commands);

        } catch (Exception e) {

            log.error("",e);

        }

    }

    @Test

    public void testJson(){

        Claim claim = new Claim();

        Project project= new Project();

        claim.setDate(Calendar.getInstance().getTime());

        claim.setId("claimId");

        claim.setUserMail("claim mail");

        project.setFunderName("EC");

        project.setOpenaireId("openaireID1234");

        project.setName("PrTitle");

        claim.setSource(project);

        Result result = new Result();

        result.setAccessRights("accessRights");

        result.setCollectedFrom("collectedFrom");

        result.setExternalUrl("external_url");

        result.setOpenaireId("openaire_id");

        result.setTitle("title");

        result.setResultType("type");

        result.setMetadataRecord("xmlString");

        claim.setTarget(result);

        System.out.println("test");

        System.out.println(JsonldBuilder.toJsonld(claim));

    }

    @Test

    public void testFetch() throws Exception {

        try {

            List<Claim> claims = null;

            List<String> types= new ArrayList<String>();

//            types.add(ClaimUtils.CONTEXT);

            types.add(ClaimUtils.PROJECT);

          types.add(ClaimUtils.DATASET);

            types.add(ClaimUtils.PUBLICATION);

//            claims = fetchClaimHandler.fetchClaimsByUser("i.fava@cineca.it",30,0,types);

//            claims = fetchClaimHandler.fetchClaimsByUser("argirok@di.uoa.gr",3,0,null,"claim.claim_date",false,types,false);

//

//            claims = fetchClaimHandler.fetchClaimsByProject("corda_______::ab9c77ce02967b24fc9c1a74276e4677",5,0);

            claims = fetchClaimHandler.fetchClaimsByProject("corda__h2020::94c962e736df90a5075a7f660ba3d7f6",12,0,null, "claim.claim_date",false,types,true);

            //claims = fetchClaimHandler.fetchClaimsByToken("corda__h2020::94c962e736df90a5075a7f660ba3d7f6","argiro@gmail.com",12,0,null, "claim.claim_date",false,types,false);

//            claims = fetchClaimHandler.fetchClaimsByDate("2016-01-14 14:53:50","2016-04-21",10,0);

//            claims = fetchClaimHandler.fetchClaimsByDate("2016-01-14 14:53:50","2017-04-21",10,0,"", "source",true,types, false);

//            // 2016-04-20 14:53:50.276

//            claims = fetchClaimHandler.fetchClaimsByContext("egi::country::gr",5,0,null,"claim.claim_date",false,types);

//            claims = fetchClaimHandler.fetchAllClaims(5,3);

//            claims = fetchClaimHandler.fetchClaimsByResult("od_______233::235960bb401207cb9595a79a1bc8e867",5,0,null, "claim.claim_date",false,types);

//            claims = fetchClaimHandler.fetchClaimsByFunder("fct_________::FCT",5,0);

//            claims= fetchClaimHandler.fetchClaimsByUser("kiatrop@di.uoa.gr",20,0,types);

//            claims = fetchClaimHandler.fetchAllClaims(10,0,"","date",true,types);

            System.out.println(fetchClaimHandler.claims2JSON(claims)+"\n\n\n "+claims.size());

//          Claim claim = fetchClaimHandler.fetchClaimById("5821");

//          System.out.println(fetchClaimHandler.claim2JSON(claim) );

//          System.out.println("ALL:"+fetchClaimHandler.countClaimsByUser("argirok@di.uoa.gr","EGI", types));

//          System.out.println("ALL:"+fetchClaimHandler.countClaimsByContext("egi::country::gr",null,types));

//            System.out.println("ALL:"+fetchClaimHandler.countClaimsByProject("corda_______::ab9c77ce02967b24fc9c1a74276e4677",null,types));

//        System.out.println("ALL:"+fetchClaimHandler.countAllClaims("", types));

//                +"\n Project: "+fetchClaimHandler.countClaimsByProject("corda_______::ab9c77ce02967b24fc9c1a74276e4677")+

//                " \n Result:"+fetchClaimHandler.countClaimsByResult("dedup_wf_001::541b1cef0d38d519e98a3b7a5b60bc75")+" \n Context:"+fetchClaimHandler.countClaimsByContext("egi::country::de")

//        +" \n Date:"+fetchClaimHandler.countClaimsByDate("2014-04-14","2015-04-14")+" \n Funder:"+fetchClaimHandler.countClaimsByFunder("fct_________::FCT"));

        } catch (Exception e) {

            log.error("",e);

        } catch (SQLStoreException e) {

            e.printStackTrace();

        }

    }

    @Test

    public void testContext(){

        System.out.print(DMFContextHandler.fetchContextById("egi::organisation::uom"));

    }

    @Test

    public void testInsert() throws Exception, SQLStoreException {

 //acm_________::31e0e5e7cbd6e2556336d7e795f55c49

//dedup_wf_001::64ca1e3a4d1590456ad3dd7df8a18cd7

//        String id=claimHandler.buildAndInsertClaim("argirok@di.uoa.gr", "project", "corda_______::2c37878a0cede85dbbd1081bb9b4a2f8", "openaire", "OPEN", null,"dataset", "10.5281/ZENODO.154647", "datacite", "EMBARGO","2017-05-01");

//        String id=claimHandler.buildAndInsertClaim("argirok@di.uoa.gr", "context", "egi::country::gr",

//                "openaire", null, null,"dataset", "10.4225/41/55A111BDE741C", "datacite", "OPEN","2017-05-01");

    }

    @Test

    public void testDelete() throws Exception, SQLStoreException {

//            claimHandler.deleteClaim("argirok@di.uoa.gr","2876");

//        claimHandler.deleteClaim("argirok@di.uoa.gr","3101");

        }

    @Test

	public void testJob() throws Exception, SQLStoreException {

        String selectcountDMFClaims =" Select count(*) from claims  where type='dmf2actions' and xml NOT ILIKE '%<oaf:concept%' ";

        String selectCountConceptClaims =" Select count(*) from claims  where ( type='dmf2actions' or type='updates2actions' ) and xml LIKE '%<oaf:concept%' ";

        String selectCountRelationClaims =" Select count(*) from claims  where type='rels2actions'  ";

        ResultSet rs = sqlDAO.executePreparedQuery(selectCountConceptClaims);

        while(rs.next()) {

            log.info("Concept claims: "+rs.getInt(1));

        }

         rs = sqlDAO.executePreparedQuery(selectCountRelationClaims);

        while(rs.next()) {

            log.info("Relation claims: "+rs.getInt(1));

        }

         rs = sqlDAO.executePreparedQuery("Select count(*) from claim");

        while(rs.next()) {

            log.info("Migrated claims: "+rs.getInt(1));

        }

        rs = sqlDAO.executePreparedQuery("Select count(*) from result");

        while(rs.next()) {

            log.info("Results: "+rs.getInt(1));

        }

	}

    @Test

    public void testHttpRequest() throws Exception {

        SearchUtils searchUtils= new SearchUtils();

        log.info(searchUtils.fetchPublicationXmlFromIndex("doajarticles::eb8a123eb82b25013b0001d0e2d1842b"));

        log.info(searchUtils.fetchDatasetXmlFromIndex("doajarticles::eb8a123eb82b25013b0001d0e2d1842b"));

    }

    @Test

    public void testXpath() throws Exception {

            Result r=indexResultHandler.fetchResultById("dedup_wf_001::88a1eedd1ffce63dccf51d8ce2053c85");

     }

    @Test

    public void testParsingDMF() throws IOException, SAXException, ParserConfigurationException, XPathExpressionException, TransformerException {

        Result r=DMFParser.dmf2Result("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" +

                "<record xmlns:dc=\"http://purl.org/dc/elements/1.1/\" xmlns:prov=\"http://www.openarchives.org/OAI/2.0/provenance\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:dri=\"http://www.driver-repository.eu/namespace/dri\" xmlns:dr=\"http://www.driver-repository.eu/namespace/dr\" xmlns:oaf=\"http://namespace.openaire.eu/oaf\">\n" +

                "  <header xmlns=\"http://namespace.openaire.eu/\">\n" +

                "    <dri:objIdentifier>crossref____::47593e13b24bcdd0f3d5573499f1d3a9</dri:objIdentifier>\n" +

                "    <dri:recordIdentifier>10.1088/0004-637X/761/1/34</dri:recordIdentifier>\n" +

                "    <dri:dateOfCollection></dri:dateOfCollection>\n" +

                "    <dri:mdFormat></dri:mdFormat>\n" +

                "    <dri:mdFormatInterpretation></dri:mdFormatInterpretation>\n" +

                "    <dri:repositoryId></dri:repositoryId>\n" +

                "    <dr:objectIdentifier></dr:objectIdentifier>\n" +

                "    <dr:dateOfCollection>2014-10-10T14:59:49+00:00</dr:dateOfCollection>\n" +

                "    <oaf:datasourceprefix>crossref____</oaf:datasourceprefix>\n" +

                "  </header>\n" +

                "  <metadata xmlns=\"http://namespace.openaire.eu/\">\n" +

                "      <dc:dateAccepted>2012-01-01T00:00:00Z</dc:dateAccepted>\n" +

                "             <dc:identifier>http://stacks.iop.org/0004-637X/761/i=1/a=34?key=crossref.d14dae8ac205453af63561a69c108e13</dc:identifier>\n" +

                "          <dc:title>A THREE-DIMENSIONAL VIEW OF THE REMNANT OF NOVA PERSEI 1901 (GK Per)</dc:title>\n" +

                "             <oaf:collectedDatasourceid>openaire____::crossref</oaf:collectedDatasourceid>\n" +

                "       <oaf:accessrights></oaf:accessrights>\n" +

                "       <oaf:hostedBy name=\"Unknown Repository\" id=\"openaire____::1256f046-bf1f-4afc-8b47-d0b147148b18\"/>\n" +

                "    <oaf:collectedFrom name=\"Crossref\" id=\"openaire____::crossref\" />\n" +

                "\n" +

                "     <dc:creator>Liimets, T.</dc:creator>\n" +

                "   generateCreateClaimTablesQuery  <dc:creator>Corradi, R. L. M.</dc:creator>\n" +

                "     <dc:creator>Santander-Garc&#237;a, M.</dc:creator>\n" +

                "     <dc:creator>Villaver, E.</dc:creator>\n" +

                "     <dc:creator>Rodr&#237;guez-Gil, P.</dc:creator>\n" +

                "     <dc:creator>Verro, K.</dc:creator>\n" +

                "     <dc:creator>Kolka, I.</dc:creator>\n" +

                "\n" +

                "        <dc:identifier identifierType=\"doi\">10.1088/0004-637X/761/1/34</dc:identifier>\n" +

                "        <dr:CobjIdentifier>10.1088/0004-637X/761/1/34</dr:CobjIdentifier>\n" +

                "  </metadata>\n" +

                "</record>");

        log.info(r.toString());

    }

    @Test

    public void dropClaimTables() throws Exception {

//        sqlDAO.executeUpdateQuery(queryGenerator.generateDeleteClaimTablesQuery());

    }

    @Test

    public void createClaimTables() throws Exception {

//        sqlDAO.executeUpdateQuery(queryGenerator.generateCreateClaimTablesQuery());

    }

    @Test

    public void validDoiTest() throws Exception {

        String doi="10.1523/​JNEUROSCI.2900-11.2012";

        doi="10.1523/​JNEUROSCI.2900-11.2012";

        String tr_doi=doi=dmfResultHandler.checkDoiValidity(doi);

        System.out.println("Initial doi:"+doi+" "+((doi.equals(tr_doi))?"":" Transformed to"+tr_doi));

    }

    @Test

    public void buildProject() throws Exception {

        String id = "arc_________::089188bbc5db213fb2b00a0d93043fc4";

        Project pr = projectHandler.fetchProjectByID(id);

        log.info(pr.toString());

        id="corda_______::404d91e07cd4d32fddd8fc636ad4daf7";

        pr = projectHandler.fetchProjectByID(id);

        log.info(pr.toString());

    }

    @Test

    public void test() throws Exception {

String xml="<?xml version=\"1.0\" encoding=\"UTF-8\"?><response>\t  <header>\t\t    <query>(((deletedbyinference = false) AND (oaftype exact result)) and (resulttypeid exact publication)) and (objidentifier exact od______1266::af81022e9c489007a8f9ab27c2c725cb)</query>\t\t\t\t  <locale>en_GB</locale>\t\t\t\t\t\t<size>10</size>\t\t\t   <page>1</page>\t\t\t   <total>1</total>\t\t\t\t\t</header>\t  <results>\t\t\t\t\t\t\t\t\t<result xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\"              xmlns:dri=\"http://www.driver-repository.eu/namespace/dri\"              xmlns:oaf=\"http://namespace.openaire.eu/oaf\">         <header>            <dri:objIdentifier>od______1266::af81022e9c489007a8f9ab27c2c725cb</dri:objIdentifier>            <dri:dateOfCollection>2015-08-14T07:08:53.549Z</dri:dateOfCollection>            <counters>\t              <counter_authorship value=\"2\"/>               <counter_outcome value=\"1\"/>\t           </counters>         </header>         <metadata>            <oaf:entity xsi:schemaLocation=\"http://namespace.openaire.eu/oaf https://www.openaire.eu/schema/0.3/oaf-0.3.xsd\">\t\t             <oaf:result>\t\t\t               <subject classid=\"keyword\" classname=\"keyword\" schemeid=\"dnet:result_subject\"                           schemename=\"dnet:result_subject\">MATLAB</subject>                  <subject classid=\"keyword\" classname=\"keyword\" schemeid=\"dnet:result_subject\"                           schemename=\"dnet:result_subject\">Lecture</subject>                  <subject classid=\"keyword\" classname=\"keyword\" schemeid=\"dnet:result_subject\"                           schemename=\"dnet:result_subject\">Exercises</subject>                  <subject classid=\"keyword\" classname=\"keyword\" schemeid=\"dnet:result_subject\"                           schemename=\"dnet:result_subject\">Exercises in Linear Vibration Theory</subject>                  <subject classid=\"keyword\" classname=\"keyword\" schemeid=\"dnet:result_subject\"                           schemename=\"dnet:result_subject\">System Conditions</subject>                  <subject classid=\"keyword\" classname=\"keyword\" schemeid=\"dnet:result_subject\"                           schemename=\"dnet:result_subject\">MATLAB</subject>                  <subject classid=\"keyword\" classname=\"keyword\" schemeid=\"dnet:result_subject\"                           schemename=\"dnet:result_subject\">Exercises</subject>                  <subject classid=\"keyword\" classname=\"keyword\" schemeid=\"dnet:result_subject\"                           schemename=\"dnet:result_subject\">Exercises in Linear Vibration Theory</subject>                  <subject classid=\"keyword\" classname=\"keyword\" schemeid=\"dnet:result_subject\"                           schemename=\"dnet:result_subject\">System Conditions</subject>                  <subject classid=\"keyword\" classname=\"keyword\" schemeid=\"dnet:result_subject\"                           schemename=\"dnet:result_subject\">Damping Coefficient</subject>                  <subject classid=\"keyword\" classname=\"keyword\" schemeid=\"dnet:result_subject\"                           schemename=\"dnet:result_subject\">Lecture</subject>                  <title classid=\"main title\" classname=\"main title\" schemeid=\"dnet:dataCite_title\"                         schemename=\"dnet:dataCite_title\">Vibration Theory, Vol. 1B:linear vibration theory, MATLAB exercises</title>                  <dateofacceptance>1996-02-01</dateofacceptance>                  <publisher>Department of Mechanical Engineering, Aalborg University</publisher>                  <resulttype classid=\"publication\" classname=\"publication\" schemeid=\"dnet:result_typologies\"                              schemename=\"dnet:result_typologies\"/>                  <language classid=\"eng\" classname=\"English\" schemeid=\"dnet:languages\"                            schemename=\"dnet:languages\"/>                  <format>application/pdf</format>                  <description>The present collection of MATLAB exercises has been published as a supplement to the textbook, Svingningsteori, Bind 1 and the collection of exercises in Vibration theory, Vol. 1A, Solved Problems. Throughout the exercise references are made to these books.&lt;br/&gt;&lt;br/&gt;The purpose of the MATLAB exercises is to give a better understanding of the physical problems in linear vibration theory and to surpress the mathematical analysis used to solve the problems. For this purpose the MATLAB environment is excellent.</description>                  <description>The present collection of MATLAB exercises has been published as a supplement to the textbook, Svingningsteori, Bind 1 and the collection of exercises in Vibration theory, Vol. 1A, Solved Problems. Throughout the exercise references are made to these books.&lt;br/&gt;&lt;br/&gt;The purpose of the MATLAB exercises is to give a better understanding of the physical problems in linear vibration theory and to surpress the mathematical analysis used to solve the problems. For this purpose the MATLAB environment is excellent.</description>                  <source>Asmussen , J C &amp; Nielsen , S R K 1996 , Vibration Theory, Vol. 1B : linear vibration theory, MATLAB exercises . Department of Mechanical Engineering, Aalborg University , Aalborg . U/ , no. 9601</source>                  <country classid=\"\" classname=\"\" schemeid=\"\" schemename=\"\"/>                  <relevantdate classid=\"\" classname=\"\" schemeid=\"\" schemename=\"\"/>                  <embargoenddate/>                  <fulltext/>                  <storagedate/>                  <resourcetype classid=\"\" classname=\"\" schemeid=\"\" schemename=\"\"/>                  <device/>                  <size/>                  <version/>                  <lastmetadataupdate/>                  <metadataversionnumber/>                  <originalId>oai:pure.atira.dk:publications/0b993280-a86a-11da-8341-000ea68e967b</originalId>                  <collectedfrom name=\"VBN\" id=\"opendoar____::8e2cfdc275761edc592f73a076197c33\"/>                  <pid classid=\"oai\" classname=\"oai\" schemeid=\"dnet:pid_types\"                       schemename=\"dnet:pid_types\">oai:pure.atira.dk:publications/0b993280-a86a-11da-8341-000ea68e967b</pid>                  <bestlicense classid=\"OPEN\" classname=\"Open Access\" schemeid=\"dnet:access_modes\"                               schemename=\"dnet:access_modes\"/>                  <context id=\"FCT\" label=\"Fundação para a Ciência e a Tecnologia, I.P.\" type=\"funding\">                     <category id=\"FCT::3599-PPCDT\" label=\"3599-PPCDT\"/>                  </context>                  <datainfo>                     <inferred>false</inferred>                     <deletedbyinference>false</deletedbyinference>                     <trust>0.9</trust>                     <inferenceprovenance/>                     <provenanceaction classid=\"sysimport:crosswalk:repository\"                                       classname=\"sysimport:crosswalk:repository\"                                       schemeid=\"dnet:provenanceActions\"                                       schemename=\"dnet:provenanceActions\"/>                  </datainfo>\t\t                <rels>\t\t                   <rel inferred=\"false\" trust=\"0.9\" inferenceprovenance=\"\"                          provenanceaction=\"user:claim:search\">\t\t                      <to class=\"isProducedBy\" scheme=\"dnet:result_project_relations\" type=\"project\">fct_________::0432268334291febec6d0dbc1f8bae5d</to>\t\t                      <websiteurl>http://www.fct.pt/apoios/projectos/consulta/vglobal_projecto.phtml.en?idProjecto=83907&amp;idElemConcurso=2612</websiteurl>                        <code>83907</code>                        <acronym>MIT-Pt/BS-CTRM/0051/2008</acronym>                        <title>Smart small-scale devices: systems for controlled delivery of bioactive molecules, cell expansion and for sensing cell environment.</title>                        <contracttype classid=\"UNKNOWN\" classname=\"UNKNOWN\" schemeid=\"fct:contractTypes\"                                      schemename=\"fct:contractTypes\"/>                        <funding>                           <funder id=\"fct_________::FCT\" shortname=\"FCT\"                                   name=\"Fundação para a Ciência e a Tecnologia, I.P.\"                                   jurisdiction=\"PT\"/>                           <funding_level_0 name=\"3599-PPCDT\">fct_________::FCT::3599-PPCDT</funding_level_0>                        </funding>\t\t                   </rel>                     <rel inferred=\"true\" trust=\"0.9\" inferenceprovenance=\"\"                          provenanceaction=\"sysimport:crosswalk:repository\">\t\t                      <to class=\"hasAuthor\" scheme=\"dnet:personroles\" type=\"person\">dedup_wf_001::b3bccc606f9dfe608199defb1f89b4d2</to>\t\t                      <ranking>1</ranking>                        <fullname>Asmussen, J.C.</fullname>\t\t                   </rel>                     <rel inferred=\"true\" trust=\"0.9\" inferenceprovenance=\"\"                          provenanceaction=\"sysimport:crosswalk:repository\">\t\t                      <to class=\"hasAuthor\" scheme=\"dnet:personroles\" type=\"person\">dedup_wf_001::facd63932e76860852cdd2ca9d33f45c</to>\t\t                      <ranking>2</ranking>                        <fullname>Søren R. K. Nielsen</fullname>\t\t                   </rel>\t\t                </rels>\t\t                <children>\t\t\t                  <instance id=\"opendoar____::8e2cfdc275761edc592f73a076197c33\">\t\t\t                     <licence classid=\"OPEN\" classname=\"Open Access\" schemeid=\"dnet:access_modes\"                                 schemename=\"dnet:access_modes\"/>                        <instancetype classid=\"0002\" classname=\"Book\" schemeid=\"dnet:publication_resource\"                                      schemename=\"dnet:publication_resource\"/>                        <hostedby name=\"VBN\" id=\"opendoar____::8e2cfdc275761edc592f73a076197c33\"/>\t\t\t\t                    <webresource>\t\t\t\t                       <url>http://vbn.aau.dk/da/publications/vibration-theory-vol-1b(0b993280-a86a-11da-8341-000ea68e967b).html</url>\t\t\t\t                    </webresource>\t\t\t\t                    <webresource>\t\t\t\t                       <url>http://vbn.aau.dk/ws/files/57794257/vibration_theory_vol._1b_linear_vibration_theory_MATLAB_exercises.pdf</url>\t\t\t\t                    </webresource>\t\t\t                  </instance>\t\t                </children>\t\t             </oaf:result>            </oaf:entity>         </metadata>      </result>\t\t\t\t\t\t</results>\t  <browseResults>\t\t\t</browseResults></response>\n";

        SearchUtils searchUtils = new SearchUtils();

        Integer size=searchUtils.getNumberOfResultsInAPIXML(xml);

        log.info(size);

        xml="<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" +

                "<record xmlns:dc=\"http://purl.org/dc/elements/1.1/\" xmlns:prov=\"http://www.openarchives.org/OAI/2.0/provenance\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:dri=\"http://www.driver-repository.eu/namespace/dri\" xmlns:dr=\"http://www.driver-repository.eu/namespace/dr\" xmlns:oaf=\"http://namespace.openaire.eu/oaf\">\n" +

                "  <header xmlns=\"http://namespace.openaire.eu/\">\n" +

                "    <dri:objIdentifier>orcid_______::4f9638b3f0fecbe3de2f9dde824c36d1</dri:objIdentifier>\n" +

                "    <dri:recordIdentifier>0000-0002-3477-3082-5288651</dri:recordIdentifier>\n" +

                "    <dri:dateOfCollection></dri:dateOfCollection>\n" +

                "    <dri:mdFormat></dri:mdFormat>\n" +

                "    <dri:mdFormatInterpretation></dri:mdFormatInterpretation>\n" +

                "    <dri:repositoryId></dri:repositoryId>\n" +

                "    <dr:objectIdentifier></dr:objectIdentifier>\n" +

                "    <dr:dateOfCollection>2015-08-19T14:40:37+00:00</dr:dateOfCollection>\n" +

                "    <oaf:datasourceprefix>openaire____</oaf:datasourceprefix>\n" +

                "  </header>\n" +

                "  <metadata xmlns=\"http://namespace.openaire.eu/\">\n" +

                "      <dc:dateAccepted>2012-01-01T00:00:00Z</dc:dateAccepted>\n" +

                "             <dc:identifier>http://dx.doi.org/10.1007/978_3_642_27169_4_2</dc:identifier>\n" +

                "          <dc:title>A Survey of Context-Aware Cross-Digital Library Personalization</dc:title>\n" +

                "             <oaf:collectedDatasourceid>openaire____::orcid</oaf:collectedDatasourceid>\n" +

                "       <oaf:accessrights>OPEN</oaf:accessrights>\n" +

                "         <oaf:embargoenddate></oaf:embargoenddate>\n" +

                "       <oaf:hostedBy name=\"Unknown Repository\" id=\"openaire____::1256f046-bf1f-4afc-8b47-d0b147148b18\"/>\n" +

                "    <oaf:collectedFrom name=\"ORCID\" id=\"openaire____::orcid\" />\n" +

                "          \n" +

                "     <dc:creator>Manola, Natalia</dc:creator>\n" +

                "     <dc:creator>Nika, Ana</dc:creator>\n" +

                "     <dc:creator>Catarci, Tiziana</dc:creator>\n" +

                "     <dc:creator>Ioannidis, Yannis</dc:creator>\n" +

                "     <dc:creator>Katifori, Akrivi</dc:creator>\n" +

                "     <dc:creator>Koutrika, Georgia</dc:creator>\n" +

                "     <dc:creator>Manola, Natalia</dc:creator>\n" +

                "     <dc:creator>N&#252;rnberger, Andreas</dc:creator>\n" +

                "     <dc:creator>Thaller, Manfred</dc:creator>\n" +

                " \n" +

                "\n" +

                "        <oaf:identifier identiferType=\"orcidworkid\">0000-0002-3477-3082-5288651</oaf:identifier>\n" +

                "\n" +

                "  </metadata>\n" +

                "</record>";

        dmfResultHandler.fetchAccessRights(xml);

        dmfResultHandler.fetchDoiByDMF(xml);

        dmfResultHandler.fetchEmbargoEndDateByDMF(xml);

        dmfResultHandler.fetchOrcidWorkByDMF(xml);

    }

    @Test

    public void buildOpenaireResult() throws Exception {

        Migration migration= new Migration();

        Result r=migration.buildOpenaireResult("datacite____::ddbd5c4c76598f27793bccf4a99843f7","");

        log.info(r);

    }

    @Test

    public void buildOpenaireProject() throws Exception {

        String projetcId = "corda_______::2c37878a0cede85dbbd1081bb9b4a2f8";

        Migration migration= new Migration();

        Project r=migration.buildProject(projetcId,"");

        log.info(r);

//        this.fetchProjectHandler.updateContactEmailsByProjectId(projetcId,r.getContactEmails());

    }

    @Test

    public void testProject() throws Exception, SQLStoreException {

//        List<String> mails = new ArrayList<String>();

//        mails.add("test1@mail.com");

//        mails.add("test2@mail.com");

//        mails.add("test3@mail.com");

//        sqlDAO.executePreparedQuery(queryGenerator.generateInsertProjectQuery("123","test project","TEstP","","","",mails));

        System.out.println("\n"+this.fetchProjectHandler.fetchContactEmailsByProjectId("corda__h2020::94c962e736df90a5075a7f660ba3d7f6")+"\n");

        List<String> mails = new ArrayList<String>();

        mails.add("test11111@mail.com");

        mails.add("test122222@mail.com");

        this.projectHandler.updateContactEmailsByProjectId("123",mails);

//        System.out.println("\n"+this.projectHandler.fetchContactEmailsByProjectId("123")+"\n");

//        String token = UUID.randomUUID().toString();

//        this.projectHandler.updateTokenByProjectId("123",token);

    }

    @Test

    public void testMD5() throws Exception {

        String id = "10.1016/j.engstruct.2013.03.014";

        String createdId = ExternalRecordParser.createOpenaireId(id);

        String openaireId = "userclaim___::07ec9eb2278a11e352e3fa93a621411d";

        System.out.println(createdId );

    }

    @Test

    public void testCuration() throws Exception, SQLStoreException {

//        boolean updated = claimHandler.updateClaimCurationInfo("argiro@gmail.com","1",true);

//        System.out.println(updated);

    }

    @Test

    public void testFetchProjectIdByToken() throws Exception, SQLStoreException {

        String openaireId = this.fetchProjectHandler.fetchProjectIdByToken("dedc6979-1967-4ea2-a2ad-5135f95285ae", "test11111@mail.com");

        System.out.println(openaireId);

    }

    @Test

    public void directIndexClaim() throws Exception {

        System.out.println(this.claimValidation.getPathToSaveReport());

        String json = "{\"originalId\":\"userclaim____::d1e668dc81fa714aa98a558d9ce515fa\",\"title\":\"Expression of Ik6 and Ik8 Isoforms and Their Association with Relapse and Death in Mexican Children with Acute Lymphoblastic Leukemia\",\"authors\":[\"Reyes-León Adriana\",\"Juárez-Velázquez Rocío\",\"Medrano-Hernández Alma\",\"Cuenca-Roldán Teresa\",\"Salas-Labadía Consuelo\",\"del Pilar Navarrete-Meneses María\",\"Rivera-Luna Roberto\",\"López-Hernández Gerardo\",\"Paredes-Aguilera Rogelio\",\"Pérez-Vera Patricia\"],\"publisher\":\"Public Library of Science (PLoS)\",\"type\":\"publication\",\"pids\":[{\"type\":\"doi\",\"value\":\"10.1371/journal.pone.0130756\"}],\"licenseCode\":\"OPEN\",\"resourceType\":\"0001\",\"url\":\"http://dx.doi.org/10.1371/journal.pone.0130756\",\"hostedById\":\"openaire____::1256f046-bf1f-4afc-8b47-d0b147148b18\",\"collectedFromId\":\"openaire____::crossref\",\"contexts\":[\"egi::country::gr\"]}";

//        System.out.println("\n\nFeed Response is: "+directIndexHandler.insertRecord(json));

//        System.out.println("\n\nDelete Response is: "+directIndexHandler.deleteRecord("userclaim___::d1e668dc81fa714aa98a558d9ce515fa","openaire____::crossref"));

    }

}