init code

[vfc/nfvo/wfengine.git] / wso2 / wso2bpel-ext / wso2bpel-core / BPEL4RESTLight / src / main / java / de / unistuttgart / iaas / bpel / util / BpelUtil.java

diff --git a/wso2/wso2bpel-ext/wso2bpel-core/BPEL4RESTLight/src/main/java/de/unistuttgart/iaas/bpel/util/BpelUtil.java b/wso2/wso2bpel-ext/wso2bpel-core/BPEL4RESTLight/src/main/java/de/unistuttgart/iaas/bpel/util/BpelUtil.java
new file mode 100644 (file)
index 0000000..33c0d54
--- /dev/null
+++ b/wso2/wso2bpel-ext/wso2bpel-core/BPEL4RESTLight/src/main/java/de/unistuttgart/iaas/bpel/util/BpelUtil.java
@@ -0,0 +1,102 @@
+/**
+ * Copyright 2011 IAAS University of Stuttgart <br>
+ * <br>
+ * 
+ * @author uwe.breitenbuecher@iaas.uni-stuttgart.de
+ * 
+ */
+package de.unistuttgart.iaas.bpel.util;
+
+import java.io.IOException;
+import java.io.StringReader;
+
+import javax.xml.parsers.DocumentBuilder;
+import javax.xml.parsers.DocumentBuilderFactory;
+import javax.xml.parsers.ParserConfigurationException;
+
+import org.apache.ode.bpel.common.FaultException;
+import org.apache.ode.bpel.evar.ExternalVariableModuleException;
+import org.apache.ode.bpel.o.OScope.Variable;
+import org.apache.ode.bpel.runtime.extension.ExtensionContext;
+import org.w3c.dom.Document;
+import org.w3c.dom.Node;
+import org.xml.sax.InputSource;
+import org.xml.sax.SAXException;
+
+
+public class BpelUtil {
+       
+       /**
+        * This function writes a passed content to a specified processVariable
+        * (referenced by name). The content will be converted into its
+        * DOM-Representation for overwriting the processVariableContent (therefore
+        * it has to be XML-serializable, e.g. for complex data types there have to
+        * be JAX-B Annotations within the corresponding Class)
+        * 
+        * @param context ExtensionContext needed to access the processVariable
+        * @param content New content for the specified processVariable
+        * @param processVariableName Variable whose content has to be overwritten
+        * @throws FaultException
+        */
+       public static void writeContentToBPELVariable(ExtensionContext context, Object content, String processVariableName, String wrapper) throws FaultException {
+               // check the node
+               System.out.println("The content object: " + content + "\n");
+               // small hack for test
+               Node hackNode = null;
+               System.out.println("Trying to parse string to dom: " + ((String) content) + "\n");
+               
+               if (wrapper != null) {
+                       // a hack for simple type wrapper
+                       content = "<" + wrapper + ">" + (String) content + "</" + wrapper + ">";
+               }
+               try {
+                       hackNode = stringToDom((String) content);
+               } catch (ParserConfigurationException e1) {
+                       // TODO Auto-generated catch block
+                       e1.printStackTrace();
+               } catch (SAXException e1) {
+                       // TODO Auto-generated catch block
+                       e1.printStackTrace();
+               } catch (IOException e1) {
+                       // TODO Auto-generated catch block
+                       e1.printStackTrace();
+               }
+               
+               Variable bpelVariable = context.getVisibleVariables().get(processVariableName);
+               if (hackNode == null) {
+                       System.out.println("hackNode is null! \n");
+               }
+               if (bpelVariable == null) {
+                       System.out.println("bpelVariable is null! \n");
+               }
+               try {
+                       // replaced responseAsNode to hackNode
+                       context.writeVariable(bpelVariable, hackNode);
+               } catch (ExternalVariableModuleException e) {
+                       e.printStackTrace();
+               }
+               
+       }
+       
+       /**
+        * This function writes a String to a BPEL Variable of type XSD-String
+        * 
+        * @param context ExtensionContext
+        * @param responsePayload ResponsePayload as String
+        * @param processVariableName Name of the target BPEL variable
+        * @throws FaultException
+        */
+       public static void writeResponsePayloadToVariable(ExtensionContext context, Object responsePayload, String processVariableName, String wrapper) throws FaultException {
+               BpelUtil.writeContentToBPELVariable(context, responsePayload, processVariableName, wrapper);
+       }
+       
+       private static Node stringToDom(String xmlString) throws ParserConfigurationException, SAXException, IOException {
+               DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
+               factory.setNamespaceAware(true);
+               DocumentBuilder builder = factory.newDocumentBuilder();
+               InputSource is = new InputSource(new StringReader(xmlString));
+               Document d = builder.parse(is);
+               return d.getFirstChild();
+       }
+       
+}