1 files changed, 0 insertions, 147 deletions
diff --git a/wso2bpel-ext/wso2bpel-core/BPEL4RESTLight/src/main/java/de/unistuttgart/iaas/bpel/extensions/bpel4restlight/Bpel4RestLightOperation.java b/wso2bpel-ext/wso2bpel-core/BPEL4RESTLight/src/main/java/de/unistuttgart/iaas/bpel/extensions/bpel4restlight/Bpel4RestLightOperation.java
deleted file mode 100644
index 2335f49..0000000
--- a/wso2bpel-ext/wso2bpel-core/BPEL4RESTLight/src/main/java/de/unistuttgart/iaas/bpel/extensions/bpel4restlight/Bpel4RestLightOperation.java
+++ /dev/null
@@ -1,147 +0,0 @@
-package de.unistuttgart.iaas.bpel.extensions.bpel4restlight;
-
-import java.io.File;
-import java.io.FileInputStream;
-import java.io.InputStream;
-import java.util.Properties;
-
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.apache.ode.bpel.common.FaultException;
-import org.apache.ode.bpel.runtime.extension.AbstractSyncExtensionOperation;
-import org.apache.ode.bpel.runtime.extension.ExtensionContext;
-import org.opentosca.bpel4restlight.rest.HighLevelRestApi;
-import org.opentosca.bpel4restlight.rest.HttpMethod;
-import org.opentosca.bpel4restlight.rest.HttpResponseMessage;
-/**
- * 
- * Copyright 2011 IAAS University of Stuttgart <br>
- * <br>
- * 
- * This class provides 4 BPEL4RestLight ExtensionActivity-operations which
- * correspond to the 4 typical REST-Operations GET, PUT, POST and Delete.
- * 
- * @author uwe.breitenbuecher@iaas.uni-stuttgart.de
- * 
- */
-import org.w3c.dom.Element;
-
-import de.unistuttgart.iaas.bpel.extensions.bpel4restlight.util.Bpel4RestLightUtil;
-import de.unistuttgart.iaas.bpel.util.BPELVariableInjectionUtil;
-import de.unistuttgart.iaas.bpel.util.BpelUtil;
-
-
-public class Bpel4RestLightOperation extends AbstractSyncExtensionOperation {
-  protected static final Log log = LogFactory.getLog(Bpel4RestLightOperation.class);
-  private static final String EXT_PROPERTIES = "wso2bps-ext.properties"; // extra properties setting
-  private static final String MSB_URL = "MSB_URL";  // http://msb:port, ext property msb url, if exist replace the request url 
-  
-  
-	public static String wrapper = "temporary-simple-type-wrapper";
-	private static String msbUrl = null;
-	
-	static {
-      
-      try {
-          File file = new File(EXT_PROPERTIES);
-          if(file.exists()) {
-              Properties p=new Properties();
-              InputStream inputStream = new FileInputStream(file);
-              p.load(inputStream);
-              inputStream.close();
-              msbUrl = p.getProperty(MSB_URL);
-          }
-          
-      } catch (Exception e) {
-          e.printStackTrace();
-      }
-      
-  }
-	
-	
-	private void processResponseMessage(HttpResponseMessage responseMessage, ExtensionContext context, Element element) throws FaultException {
-		// Write responsePayload to designated variable
-		String responsePayloadVariableName = Bpel4RestLightUtil.getMethodAttributeValue(element, MethodAttribute.RESPONSEPAYLOADVARIABLE);
-		String statusCodeVariableName = Bpel4RestLightUtil.getMethodAttributeValue(element, MethodAttribute.STATUSCODEVARIABLE);
-		
-		if (responsePayloadVariableName != null && !responsePayloadVariableName.equals("")) {
-			BpelUtil.writeResponsePayloadToVariable(context, responseMessage.getResponseBody(), responsePayloadVariableName, Bpel4RestLightOperation.wrapper);
-		}
-		
-		if (statusCodeVariableName != null && !statusCodeVariableName.equals("")) {
-			String StatusCode = "" + responseMessage.getStatusCode();  // int can not be casted to String
-			
-			BpelUtil.writeResponsePayloadToVariable(context, StatusCode, statusCodeVariableName, Bpel4RestLightOperation.wrapper);
-			
-		}
-	}
-	
-	/** {@inheritDoc} */
-	@Override
-	protected void runSync(ExtensionContext context, Element element) throws FaultException {
-		element = BPELVariableInjectionUtil.replaceExtensionVariables(context, element);
-		log.debug("LocalName of edited element: " + element.getLocalName());
-		String httpMethod = element.getLocalName();
-		
-		// Extract requestUri
-		String requestUri = getRequestUrl(element);
-		
-		HttpResponseMessage responseMessage = null;
-		String acceptHeader = Bpel4RestLightUtil.extractAcceptHeader(context, element);
-		String contentTypeHeader = Bpel4RestLightUtil.extractContentTypeHeader(context, element);
-		String requestPayload = Bpel4RestLightUtil.extractRequestPayload(context, element);
-		
-		// Execute corresponding HttpMethod via the HighLevelRestApi
-		switch (HttpMethod.valueOf(httpMethod)) {
-		
-			case PUT: {
-				responseMessage = HighLevelRestApi.Put(requestUri, requestPayload, acceptHeader, contentTypeHeader);
-				break;
-			}
-
-			case POST: {
-				responseMessage = HighLevelRestApi.Post(requestUri, requestPayload, acceptHeader, contentTypeHeader);
-				break;
-			}
-			
-			case GET: {
-				responseMessage = HighLevelRestApi.Get(requestUri, acceptHeader, contentTypeHeader);
-				break;
-			}
-			
-			case DELETE: {
-				responseMessage = HighLevelRestApi.Delete(requestUri, acceptHeader, contentTypeHeader);
-				break;
-			}
-		}
-		
-		processResponseMessage(responseMessage, context, element);
-		// Bpel4RestLightOperation.wrapper = null;
-	}
-	
-	
-	/**
-	 * getRequestUrl
-	 * get request url from element, if exists msbUrl property, then replace the ip and port
-	 * @param element
-	 * @return
-	 */
-	private String getRequestUrl(Element element) {
-	  String requestUri = Bpel4RestLightUtil.getMethodAttributeValue(element, MethodAttribute.REQUESTURI);
-	  log.debug("original url:" + requestUri);
-      if(msbUrl == null || "".equals(msbUrl) || "http://msb:port".equals(msbUrl)) {
-          return requestUri;
-      } else {
-          requestUri = requestUri.substring(requestUri.indexOf("//") + 2);
-          int index = requestUri.indexOf("/");
-          if(index == -1) {
-              
-          } else {
-              requestUri = requestUri.substring(index);
-          }
-          requestUri = msbUrl + requestUri;
-          log.debug("changed url:" + requestUri);
-          return requestUri;
-      }
-  }
-}