Added experimental JAXWS based WS integration from Raymond's sandbox as per ML discussion (http://www.mail-archive.com/dev%40tuscany.apache.org/msg11881.html) so we can get more people looking at it

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@926127 13f79535-47bb-0310-9956-ffa450edef68

4 files changed, 454 insertions, 0 deletions

diff --git a/sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingInvoker.java b/sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingInvoker.java
new file mode 100644
index 0000000000..ecb3b4f87b
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingInvoker.java
@@ -0,0 +1,181 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tuscany.sca.binding.ws.jaxws;
+
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.util.Iterator;
+
+import javax.wsdl.Binding;
+import javax.wsdl.BindingOperation;
+import javax.wsdl.extensions.soap.SOAPOperation;
+import javax.wsdl.extensions.soap12.SOAP12Operation;
+import javax.xml.namespace.QName;
+import javax.xml.soap.Detail;
+import javax.xml.soap.DetailEntry;
+import javax.xml.soap.MessageFactory;
+import javax.xml.soap.SOAPBody;
+import javax.xml.soap.SOAPException;
+import javax.xml.soap.SOAPFault;
+import javax.xml.soap.SOAPMessage;
+import javax.xml.soap.SOAPPart;
+import javax.xml.ws.Dispatch;
+import javax.xml.ws.Service;
+import javax.xml.ws.WebServiceException;
+import javax.xml.ws.WebServiceFeature;
+import javax.xml.ws.soap.SOAPFaultException;
+
+import org.apache.tuscany.sca.binding.ws.WebServiceBinding;
+import org.apache.tuscany.sca.interfacedef.Operation;
+import org.apache.tuscany.sca.invocation.DataExchangeSemantics;
+import org.apache.tuscany.sca.invocation.Invoker;
+import org.apache.tuscany.sca.invocation.Message;
+import org.w3c.dom.Node;
+
+/**
+ * Axis2BindingInvoker uses an Axis2 OperationClient to invoke a remote web service
+ *
+ * @version $Rev$ $Date$
+ */
+public class JAXWSBindingInvoker implements Invoker, DataExchangeSemantics {
+    private final static String SCA11_TUSCANY_NS = "http://tuscany.apache.org/xmlns/sca/1.1";
+
+    public static final String TUSCANY_PREFIX = "tuscany";
+    public static final QName CALLBACK_ID_REFPARM_QN = new QName(SCA11_TUSCANY_NS, "CallbackID", TUSCANY_PREFIX);
+    public static final QName CONVERSATION_ID_REFPARM_QN =
+        new QName(SCA11_TUSCANY_NS, "ConversationID", TUSCANY_PREFIX);
+
+    private Dispatch<SOAPMessage> dispatch;
+    private MessageFactory messageFactory;
+    private Operation operation;
+    private WebServiceBinding wsBinding;
+
+    public JAXWSBindingInvoker(Operation operation,
+                               WebServiceFeature[] features,
+                               MessageFactory messageFactory,
+                               WebServiceBinding wsBinding) {
+        this.messageFactory = messageFactory;
+        this.operation = operation;
+        this.wsBinding = wsBinding;
+        this.dispatch = createDispatch(wsBinding);
+    }
+
+    private Dispatch<SOAPMessage> createDispatch(WebServiceBinding wsBinding) {
+        // FIXME: What should we do if the WSDL is generated in memory?
+        URL wsdlLocation = null;
+        try {
+            wsdlLocation = new URL(wsBinding.getWSDLDocument().getDocumentBaseURI());
+        } catch (MalformedURLException e) {
+            try {
+                wsdlLocation = wsBinding.getWSDLDefinition().getLocation().toURL();
+            } catch (MalformedURLException e1) {
+                // TODO Auto-generated catch block
+                e1.printStackTrace();
+            }
+        }
+        Service service = Service.create(wsdlLocation, wsBinding.getServiceName());
+        return service.createDispatch(new QName(wsBinding.getServiceName().getNamespaceURI(), wsBinding.getPortName()),
+                                      SOAPMessage.class,
+                                      Service.Mode.MESSAGE);
+    }
+
+    public Message invoke(Message msg) {
+        try {
+            SOAPMessage resp = invokeTarget(msg);
+            SOAPBody body = resp.getSOAPBody();
+            if (body != null) {
+                SOAPFault fault = body.getFault();
+                if (fault != null) {
+                    setFault(msg, fault);
+                } else {
+                    // The 1st child element
+                    msg.setBody(body.getChildElements().next());
+                }
+
+            }
+        } catch (SOAPFaultException e) {
+            e.printStackTrace();
+            setFault(msg, e.getFault());
+        } catch (WebServiceException e) {
+            msg.setFaultBody(e);
+        } catch (SOAPException e) {
+            msg.setFaultBody(e);
+        } catch (Throwable e) {
+            msg.setFaultBody(e);
+        }
+
+        return msg;
+    }
+
+    private void setFault(Message msg, SOAPFault fault) {
+        Detail detail = fault.getDetail();
+        if (detail == null) {
+            return;
+        }
+        for (Iterator i = detail.getDetailEntries(); i.hasNext();) {
+            DetailEntry entry = (DetailEntry)i.next();
+            msg.setFaultBody(entry);
+        }
+    }
+
+    protected String getSOAPAction(String operationName) {
+        Binding binding = wsBinding.getBinding();
+        if (binding != null) {
+            for (Object o : binding.getBindingOperations()) {
+                BindingOperation bop = (BindingOperation)o;
+                if (bop.getName().equalsIgnoreCase(operationName)) {
+                    for (Object o2 : bop.getExtensibilityElements()) {
+                        if (o2 instanceof SOAPOperation) {
+                            return ((SOAPOperation)o2).getSoapActionURI();
+                        } else if (o2 instanceof SOAP12Operation) {
+                            return ((SOAP12Operation)o2).getSoapActionURI();
+                        }
+                    }
+                }
+            }
+        }
+        return null;
+    }
+
+    protected SOAPMessage invokeTarget(Message msg) throws SOAPException {
+        SOAPMessage soapMessage = messageFactory.createMessage();
+        SOAPPart soapPart = soapMessage.getSOAPPart();
+        javax.xml.soap.SOAPEnvelope envelope = soapPart.getEnvelope();
+        javax.xml.soap.SOAPBody body = envelope.getBody();
+        Object[] args = (Object[])msg.getBody();
+        body.addDocument(((Node)args[0]).getOwnerDocument());
+        soapMessage.saveChanges();
+        if (operation.isNonBlocking()) {
+            dispatch.invokeOneWay(soapMessage);
+            return null;
+        }
+
+        // FIXME: We need to find out the soapAction
+        String action = getSOAPAction(operation.getName());
+        if (action != null) {
+            dispatch.getRequestContext().put(Dispatch.SOAPACTION_URI_PROPERTY, action);
+        }
+        SOAPMessage response = dispatch.invoke(soapMessage);
+        return response;
+    }
+
+    public boolean allowsPassByReference() {
+        return true;
+    }
+}
diff --git a/sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingProviderFactory.java b/sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingProviderFactory.java
new file mode 100644
index 0000000000..54d1ba90a8
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingProviderFactory.java
@@ -0,0 +1,68 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.ws.jaxws;
+
+import java.util.List;
+
+import org.apache.tuscany.sca.binding.ws.WebServiceBinding;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.core.FactoryExtensionPoint;
+import org.apache.tuscany.sca.databinding.DataBindingExtensionPoint;
+import org.apache.tuscany.sca.host.http.ServletHost;
+import org.apache.tuscany.sca.host.http.ServletHostExtensionPoint;
+import org.apache.tuscany.sca.provider.BindingProviderFactory;
+import org.apache.tuscany.sca.provider.ReferenceBindingProvider;
+import org.apache.tuscany.sca.provider.ServiceBindingProvider;
+import org.apache.tuscany.sca.runtime.RuntimeEndpoint;
+import org.apache.tuscany.sca.runtime.RuntimeEndpointReference;
+
+/**
+ * Axis2BindingProviderFactory
+ *
+ * @version $Rev$ $Date$
+ */
+
+public class JAXWSBindingProviderFactory implements BindingProviderFactory<WebServiceBinding> {
+
+    private FactoryExtensionPoint modelFactories;
+    private ServletHost servletHost;
+    private DataBindingExtensionPoint dataBindings;
+
+    public JAXWSBindingProviderFactory(ExtensionPointRegistry extensionPoints) {
+        ServletHostExtensionPoint servletHosts = extensionPoints.getExtensionPoint(ServletHostExtensionPoint.class);
+        List<ServletHost> hosts = servletHosts.getServletHosts();
+        if (!hosts.isEmpty()) {
+            this.servletHost = hosts.get(0);
+        }
+        modelFactories = extensionPoints.getExtensionPoint(FactoryExtensionPoint.class);
+        dataBindings = extensionPoints.getExtensionPoint(DataBindingExtensionPoint.class);
+    }
+
+    public ReferenceBindingProvider createReferenceBindingProvider(RuntimeEndpointReference endpointReference) {
+        return new JAXWSReferenceBindingProvider(endpointReference, modelFactories, dataBindings);
+    }
+
+    public ServiceBindingProvider createServiceBindingProvider(RuntimeEndpoint endpoint) {
+        return new JAXWSServiceBindingProvider(endpoint, servletHost, modelFactories, dataBindings);
+    }
+
+    public Class<WebServiceBinding> getModelType() {
+        return WebServiceBinding.class;
+    }
+}
diff --git a/sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSReferenceBindingProvider.java b/sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSReferenceBindingProvider.java
new file mode 100644
index 0000000000..b8ff7ce475
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSReferenceBindingProvider.java
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tuscany.sca.binding.ws.jaxws;
+
+import org.apache.tuscany.sca.binding.ws.WebServiceBinding;
+import org.apache.tuscany.sca.core.FactoryExtensionPoint;
+import org.apache.tuscany.sca.databinding.DataBindingExtensionPoint;
+import org.apache.tuscany.sca.interfacedef.InterfaceContract;
+import org.apache.tuscany.sca.interfacedef.Operation;
+import org.apache.tuscany.sca.invocation.Invoker;
+import org.apache.tuscany.sca.provider.ReferenceBindingProvider;
+import org.apache.tuscany.sca.runtime.RuntimeEndpointReference;
+import org.oasisopen.sca.ServiceRuntimeException;
+import org.w3c.dom.Node;
+
+public class JAXWSReferenceBindingProvider implements ReferenceBindingProvider {
+
+    private javax.xml.soap.MessageFactory messageFactory;
+    private WebServiceBinding wsBinding;
+
+    public JAXWSReferenceBindingProvider(RuntimeEndpointReference endpointReference,
+                                         FactoryExtensionPoint modelFactories,
+                                         DataBindingExtensionPoint dataBindings) {
+
+        this.messageFactory = modelFactories.getFactory(javax.xml.soap.MessageFactory.class);
+        this.wsBinding = (WebServiceBinding) endpointReference.getBinding();
+
+        // A WSDL document should always be present in the binding
+        if (wsBinding.getWSDLDocument() == null) {
+            throw new ServiceRuntimeException("No WSDL document for " + endpointReference.getURI());
+        }
+
+        // Set to use the Axiom data binding
+        InterfaceContract contract = wsBinding.getBindingInterfaceContract();
+        if (contract.getInterface() != null) {
+            contract.getInterface().resetDataBinding(Node.class.getName());
+        }
+    }
+
+    public void start() {
+    }
+
+    public void stop() {
+    }
+
+    public InterfaceContract getBindingInterfaceContract() {
+        return wsBinding.getBindingInterfaceContract();
+    }
+
+    public boolean supportsOneWayInvocation() {
+        return true;
+    }
+
+    public Invoker createInvoker(Operation operation) {
+        return new JAXWSBindingInvoker(operation, null, messageFactory, wsBinding);
+    }
+
+}
diff --git a/sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSServiceBindingProvider.java b/sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSServiceBindingProvider.java
new file mode 100644
index 0000000000..2be6963e15
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSServiceBindingProvider.java
@@ -0,0 +1,131 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tuscany.sca.binding.ws.jaxws;
+
+import javax.xml.soap.SOAPException;
+import javax.xml.soap.SOAPFactory;
+import javax.xml.soap.SOAPMessage;
+import javax.xml.ws.Endpoint;
+import javax.xml.ws.Provider;
+import javax.xml.ws.ServiceMode;
+import javax.xml.ws.WebServiceProvider;
+import javax.xml.ws.Service.Mode;
+
+import org.apache.tuscany.sca.binding.ws.WebServiceBinding;
+import org.apache.tuscany.sca.core.FactoryExtensionPoint;
+import org.apache.tuscany.sca.databinding.DataBindingExtensionPoint;
+import org.apache.tuscany.sca.host.http.ServletHost;
+import org.apache.tuscany.sca.interfacedef.InterfaceContract;
+import org.apache.tuscany.sca.interfacedef.Operation;
+import org.apache.tuscany.sca.invocation.InvocationChain;
+import org.apache.tuscany.sca.invocation.Message;
+import org.apache.tuscany.sca.invocation.MessageFactory;
+import org.apache.tuscany.sca.provider.ServiceBindingProvider;
+import org.apache.tuscany.sca.runtime.RuntimeEndpoint;
+import org.oasisopen.sca.ServiceRuntimeException;
+import org.w3c.dom.Element;
+import org.w3c.dom.Node;
+
+@WebServiceProvider
+@ServiceMode(Mode.MESSAGE)
+public class JAXWSServiceBindingProvider implements ServiceBindingProvider, Provider<SOAPMessage> {
+    private MessageFactory messageFactory;
+    private RuntimeEndpoint endpoint;
+    private WebServiceBinding wsBinding;
+    private Endpoint wsEndpoint;
+    private javax.xml.soap.MessageFactory soapMessageFactory;
+    private SOAPFactory soapFactory;
+
+    public JAXWSServiceBindingProvider(RuntimeEndpoint endpoint,
+                                       ServletHost servletHost,
+                                       FactoryExtensionPoint modelFactories,
+                                       DataBindingExtensionPoint dataBindings) {
+
+        if (servletHost == null) {
+            throw new ServiceRuntimeException("No Servlet host is avaible for HTTP web services");
+        }
+
+        this.messageFactory = modelFactories.getFactory(MessageFactory.class);
+
+        this.soapMessageFactory = modelFactories.getFactory(javax.xml.soap.MessageFactory.class);
+        this.soapFactory = modelFactories.getFactory(SOAPFactory.class);
+
+        // soapMessageFactory = javax.xml.soap.MessageFactory.newInstance();
+        // soapFactory = SOAPFactory.newInstance();
+
+        this.endpoint = endpoint;
+        this.wsBinding = (WebServiceBinding)endpoint.getBinding();
+
+        // A WSDL document should always be present in the binding
+        if (wsBinding.getWSDLDocument() == null) {
+            throw new ServiceRuntimeException("No WSDL document for " + endpoint.getURI());
+        }
+
+        // Set to use the Axiom data binding
+        InterfaceContract contract = wsBinding.getBindingInterfaceContract();
+        contract.getInterface().resetDataBinding(Node.class.getName());
+
+    }
+
+    public void start() {
+        wsEndpoint = Endpoint.create(this);
+        wsEndpoint.publish("http://localhost:8085" + wsBinding.getURI());
+    }
+
+    public void stop() {
+        wsEndpoint.stop();
+    }
+
+    public InterfaceContract getBindingInterfaceContract() {
+        return wsBinding.getBindingInterfaceContract();
+    }
+
+    public boolean supportsOneWayInvocation() {
+        return true;
+    }
+
+    public SOAPMessage invoke(SOAPMessage request) {
+        try {
+            // Assuming document-literal-wrapper style
+            Node root = request.getSOAPBody().getFirstChild();
+            String operationName = root.getLocalName();
+            Operation operation = null;
+            for (InvocationChain invocationChain : endpoint.getInvocationChains()) {
+                if (operationName.equals(invocationChain.getSourceOperation().getName())) {
+                    operation = invocationChain.getSourceOperation();
+                    break;
+                }
+            }
+            if (operation == null) {
+                throw new SOAPException("Operation not found: " + operationName);
+            }
+
+            Message requestMsg = messageFactory.createMessage();
+            requestMsg.setBody(root);
+            requestMsg.setOperation(operation);
+            Message responseMsg = endpoint.invoke(operation, requestMsg);
+            Element element = responseMsg.getBody();
+            SOAPMessage response = soapMessageFactory.createMessage();
+            response.getSOAPBody().addChildElement(soapFactory.createElement(element));
+            return response;
+        } catch (SOAPException e) {
+            throw new ServiceRuntimeException(e);
+        }
+    }
+}