D-Net

package eu.dnetlib.data.mapreduce.hbase.dataexport.linkinganalysis.publicationsoftware;

import eu.dnetlib.data.bulktag.Pair;

import org.apache.hadoop.io.Text;

import org.elasticsearch.hadoop.util.Assert;

import org.junit.Test;

import java.io.IOException;

import java.util.ArrayList;

import java.util.List;

public class PubSfwLinkTest {

    List<Text> list;

    ValueList vl;

    @Test

    public void test1() throws IOException {

        ValueList vl = new ValueList("linking1.json");

        list  = vl.getValueToText();//new ArrayList<>(Arrays.asList(new Text(Value.newInstance( "p1,p2,p3","0.9", PropagationConstants.Type.fromsemrel).toJson()),new Text(Value.newInstance( "p1,p2","0.9", PropagationConstants.Type.fromresult).toJson()) ));

        ReturnedValues rv = new ReturnedValues();

        rv.setOpenAireId("pippo");

            PubSfwLinkIterator it = new PubSfwLinkIterator(list, "pippo");

            Assert.isTrue(it.hasNext());

            while(it.hasNext()){

                Pair<Constants.Type, Object> p = it.next();

                if(p.getFst()== Constants.Type.publication){

                    rv.addPublicationId((Identifier)p.getSnd());

                }else{

                    rv.addLinkedSoftware((SoftwareResource)p.getSnd());

                }

            }

        System.out.print(rv.toJson());

    }

    @Test

    public void test2(){

        Identifier id = new Identifier();

        id.setPid("pid1").setPidtype("doi");

        System.out.println("id.toJson() = " + id.toJson());

        SoftwareResource sr = new SoftwareResource().setOpenAireId("oaSwId");

        List<String> urls = new ArrayList<String>(){{add("url1");add("url2");add("url3");}};

        List<Identifier> pids = new ArrayList<Identifier>(){{

            add(new Identifier().setPid("doi1").setPidtype("doi"));

            add(new Identifier().setPid("doi2").setPidtype("doi"));

        }};

        sr.setSoftwarePIDs(pids).setUrls(urls);

        System.out.println("sr.toJson() = " + sr.toJson());

    }

    @Test

    public void test3(){

        String json = "{\"pidtype\":\"doi\",\"pid\":\"pid1\"}";

        Identifier id = Identifier.fromJson(json);

        System.out.println("id.getPid() = " + id.getPid());

        System.out.println("id.getPidtype() = " + id.getPidtype());

    }

}

package eu.dnetlib.data.mapreduce.hbase.dataexport.linkinganalysis.publicationsoftware;

import com.google.gson.Gson;

import org.apache.commons.io.IOUtils;

import org.apache.hadoop.io.Text;

import java.io.IOException;

import java.util.List;

import java.util.stream.Collectors;

public class ValueList {

    private String jsonFile;

    public ValueList(String jsonFile) {

        this.jsonFile=jsonFile;

    }

    public List<Value> getValueList() {

            return valueList;

        }

        public void setValueList(List<Value> valueList) {

            this.valueList = valueList;

        }

        private List<Value> valueList ;

        public List<Text> getValueToText() throws IOException {

            ValueList tmp = new Gson().fromJson(IOUtils.toString(getClass().getResourceAsStream(jsonFile)), ValueList.class);

            //IOUtils.toString(getClass().getResourceAsStream("community_configuration.xml"));

            return tmp.getValueList().stream().map(Value::toJson).map(Text::new).collect(Collectors.toList());

        }

    }

{"valueList":[

  {"value":"{openAireId:oaSwId,softwarePIDs:[{pidtype:doi,pid:doi1},{pidtype:doi,pid:doi2}],urls:[url1,url2,url3]}","type":"software"},

  {"value":"{pidtype:doi,pid:pid1}","type":"publication"}

]}