[sdc/sdc-workflow-designer.git] /

/**\r
 * Copyright (c) 2017 ZTE Corporation.\r
 * All rights reserved. This program and the accompanying materials\r
 * are made available under the Apache License, Version 2.0\r
 * and the Eclipse Public License v1.0 which both accompany this distribution,\r
 * and are available at http://www.eclipse.org/legal/epl-v10.html\r
 * and http://www.apache.org/licenses/LICENSE-2.0\r
 *\r
 * Contributors:\r
 *     ZTE - initial API and implementation and/or initial documentation\r
 */\r
package org.onap.sdc.workflowdesigner.parser;\r
\r
import java.io.IOException;\r
import java.net.MalformedURLException;\r
import java.net.URI;\r
import java.util.ArrayList;\r
import java.util.Iterator;\r
import java.util.List;\r
\r
import org.onap.sdc.workflowdesigner.model.DataObject;\r
import org.onap.sdc.workflowdesigner.model.Element;\r
import org.onap.sdc.workflowdesigner.model.EndEvent;\r
import org.onap.sdc.workflowdesigner.model.IntermediateCatchEvent;\r
import org.onap.sdc.workflowdesigner.model.Parameter;\r
import org.onap.sdc.workflowdesigner.model.Process;\r
import org.onap.sdc.workflowdesigner.model.ScriptTask;\r
import org.onap.sdc.workflowdesigner.model.SequenceFlow;\r
import org.onap.sdc.workflowdesigner.model.StartEvent;\r
import org.slf4j.Logger;\r
import org.slf4j.LoggerFactory;\r
\r
import com.fasterxml.jackson.core.JsonParseException;\r
import com.fasterxml.jackson.databind.DeserializationFeature;\r
import com.fasterxml.jackson.databind.JsonMappingException;\r
import com.fasterxml.jackson.databind.JsonNode;\r
import com.fasterxml.jackson.databind.ObjectMapper;\r
import com.fasterxml.jackson.databind.SerializationFeature;\r
\r
public class Bpmn4ToscaJsonParser {\r
\r
    private static Logger log = LoggerFactory.getLogger(Bpmn4ToscaJsonParser.class);\r
\r
    private static ObjectMapper MAPPER = new ObjectMapper();\r
\r
    static {\r
        MAPPER.enable(SerializationFeature.INDENT_OUTPUT);\r
        MAPPER.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);\r
    }\r
\r
    public Process parse(String processName, URI jsonFileUrl)\r
            throws JsonParseException, JsonMappingException, MalformedURLException, IOException {\r
        Process process = new Process(processName);\r
\r
        JsonNode rootNode = MAPPER.readValue(jsonFileUrl.toURL(), JsonNode.class);\r
\r
        log.debug("Creating Process models...");\r
        JsonNode nodes = rootNode.get(JsonKeys.NODES);\r
        if (nodes == null) {\r
            return process;\r
        }\r
\r
        Iterator<JsonNode> iter = nodes.iterator();\r
        while (iter.hasNext()) {\r
            JsonNode jsonNode = (JsonNode) iter.next();\r
\r
            // get element\r
            Element element = createElementFromJson(jsonNode);\r
            process.getElementList().add(element);\r
\r
            // get sequence flows\r
            List<SequenceFlow> flowList = getSequenceFlows(jsonNode);\r
            process.getSequenceFlowList().addAll(flowList);\r
\r
            // add dataObject\r
            if (element instanceof StartEvent) {\r
                List<DataObject> dataObjects = this.getDataObject((StartEvent) element);\r
                process.getDataObjectList().addAll(dataObjects);\r
            }\r
        }\r
\r
        return process;\r
\r
    }\r
\r
    private List<DataObject> getDataObject(StartEvent startEvent) {\r
        List<DataObject> dataObjects = new ArrayList<DataObject>();\r
\r
        for (Parameter parameter : startEvent.getParameters()) {\r
            DataObject dataObject = new DataObject();\r
            dataObject.setId(parameter.getName());\r
            dataObject.setName(parameter.getName());\r
            dataObject.setValue((String) parameter.getValue());\r
\r
            dataObjects.add(dataObject);\r
        }\r
\r
        return dataObjects;\r
    }\r
\r
    private List<SequenceFlow> getSequenceFlows(JsonNode jsonNode) {\r
        List<SequenceFlow> flowList = new ArrayList<SequenceFlow>();\r
        JsonNode sequenceFlowNodes = jsonNode.get(JsonKeys.SEQUENCE_FLOWS);\r
\r
        Iterator<JsonNode> iter = sequenceFlowNodes.iterator();\r
        while (iter.hasNext()) {\r
            JsonNode connectionEntry = (JsonNode) iter.next();\r
            String sourceRef = getValueFromJsonNode(connectionEntry, JsonKeys.SOURCE_REF);\r
            String targetRef = getValueFromJsonNode(connectionEntry, JsonKeys.TARGET_REF);\r
            String condition = getValueFromJsonNode(connectionEntry, JsonKeys.CONDITION);\r
            SequenceFlow flow = new SequenceFlow();\r
            flow.setId(sourceRef + targetRef);\r
            flow.setSourceRef(sourceRef);\r
            flow.setTargetRef(targetRef);\r
            flow.setCondition(condition);\r
            flowList.add(flow);\r
        }\r
\r
        return flowList;\r
    }\r
\r
    protected Element createElementFromJson(JsonNode jsonNode)\r
            throws JsonParseException, JsonMappingException, IOException {\r
        String jsonObject = jsonNode.toString();\r
        Element element;\r
\r
        String nodeType = getValueFromJsonNode(jsonNode, JsonKeys.TYPE);\r
        switch (nodeType) {\r
        case "startEvent":\r
            element = MAPPER.readValue(jsonObject, StartEvent.class);\r
            break;\r
        case "endEvent":\r
            element = MAPPER.readValue(jsonObject, EndEvent.class);\r
            break;\r
        case "intermediateCatchEvent":\r
            element = MAPPER.readValue(jsonObject, IntermediateCatchEvent.class);\r
            break;\r
        case "scriptTask":\r
            element = MAPPER.readValue(jsonObject, ScriptTask.class);\r
            break;\r
        default:\r
            log.warn("Ignoring node: type '" + nodeType + "' is unkown");\r
            return null;\r
        }\r
\r
        return element;\r
    }\r
\r
    private String getValueFromJsonNode(JsonNode jsonNode, String key) {\r
        return jsonNode.get(key) == null ? null : jsonNode.get(key).asText();\r
    }\r
\r
}\r