D-Net

package eu.dnetlib.msro.openaireplus.workflows.nodes;

import com.googlecode.sarasvati.Arc;

import com.googlecode.sarasvati.NodeToken;

import eu.dnetlib.msro.workflows.nodes.SimpleJobNode;

import eu.dnetlib.utils.ontologies.Ontologies;

import eu.dnetlib.utils.ontologies.OntologyLoader;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

public class FetchOntologiesJobNode extends SimpleJobNode {

    private static final Log log = LogFactory.getLog(FetchOntologiesJobNode.class);

    private String paramName;

    @Override

    protected String execute(NodeToken token) throws Exception {

        final Ontologies ontologies = OntologyLoader.loadOntologiesFromIS();

        log.info(String.format("loaded %s ontology profiles", ontologies.size()));

        token.getEnv().setAttribute(getParamName(), ontologies.toJson());

        return Arc.DEFAULT_ARC;

    }

    public String getParamName() {

        return paramName;

    }

    public void setParamName(String paramName) {

        this.paramName = paramName;

    }

}