1 files changed, 263 insertions, 0 deletions
diff --git a/sca-java-1.x/tags/java-M1-final/java/sca/bindings/binding.celtix/src/main/java/org/apache/tuscany/binding/celtix/handler/CeltixEntryPointContextImpl.java b/sca-java-1.x/tags/java-M1-final/java/sca/bindings/binding.celtix/src/main/java/org/apache/tuscany/binding/celtix/handler/CeltixEntryPointContextImpl.java
new file mode 100644
index 0000000000..5b2e0df3d6
--- /dev/null
+++ b/sca-java-1.x/tags/java-M1-final/java/sca/bindings/binding.celtix/src/main/java/org/apache/tuscany/binding/celtix/handler/CeltixEntryPointContextImpl.java
@@ -0,0 +1,263 @@
+/**
+ *
+ *  Copyright 2005 The Apache Software Foundation or its licensors, as applicable.
+ *
+ *  Licensed 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.binding.celtix.handler;
+
+import java.lang.reflect.Method;
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.Executor;
+
+import javax.jws.soap.SOAPBinding.Style;
+import javax.wsdl.Binding;
+import javax.wsdl.BindingInput;
+import javax.wsdl.BindingOperation;
+import javax.wsdl.Definition;
+import javax.wsdl.Port;
+import javax.wsdl.extensions.ExtensibilityElement;
+import javax.wsdl.extensions.soap.SOAPAddress;
+import javax.wsdl.extensions.soap.SOAPBody;
+import javax.xml.namespace.QName;
+import javax.xml.ws.WebServiceProvider;
+
+import commonj.sdo.helper.TypeHelper;
+
+import org.apache.tuscany.binding.celtix.assembly.WebServiceBinding;
+import org.apache.tuscany.binding.celtix.handler.io.SCAServerDataBindingCallback;
+import org.apache.tuscany.core.builder.BuilderConfigException;
+import org.apache.tuscany.core.context.ContextInitException;
+import org.apache.tuscany.core.context.CoreRuntimeException;
+import org.apache.tuscany.core.context.impl.EntryPointContextImpl;
+import org.apache.tuscany.core.message.MessageFactory;
+import org.apache.tuscany.core.wire.SourceWireFactory;
+import org.apache.tuscany.model.assembly.EntryPoint;
+import org.objectweb.celtix.Bus;
+import org.objectweb.celtix.bindings.DataBindingCallback;
+import org.objectweb.celtix.bindings.ServerBinding;
+import org.objectweb.celtix.bindings.ServerBindingEndpointCallback;
+import org.objectweb.celtix.bindings.ServerDataBindingCallback;
+import org.objectweb.celtix.bus.bindings.WSDLMetaDataCache;
+import org.objectweb.celtix.bus.bindings.WSDLOperationInfo;
+import org.objectweb.celtix.context.ObjectMessageContext;
+import org.objectweb.celtix.ws.addressing.AttributedURIType;
+import org.objectweb.celtix.ws.addressing.EndpointReferenceType;
+import org.objectweb.celtix.wsdl.EndpointReferenceUtils;
+import org.osoa.sca.annotations.Destroy;
+import org.xmlsoap.schemas.wsdl.http.AddressType;
+
+public class CeltixEntryPointContextImpl extends EntryPointContextImpl
+    implements ServerBindingEndpointCallback {
+    
+    EntryPoint entry;
+    private Bus bus;
+    private Port port;
+    private TypeHelper typeHelper;
+    private WSDLMetaDataCache wsdlCache;
+    private ServerBinding serverBinding;
+    private Object entryPointProxy;
+    private WebServiceBinding wsBinding;
+    
+    private Map<QName, ServerDataBindingCallback> opMap = 
+        new ConcurrentHashMap<QName, ServerDataBindingCallback>(); 
+
+    
+    public CeltixEntryPointContextImpl(EntryPoint entry,
+                                       SourceWireFactory sourceWireFactory,
+                                       MessageFactory messageFactory)
+        throws ContextInitException {
+        
+        super(entry.getName(), sourceWireFactory, messageFactory);
+        this.entry = entry;
+    }
+
+    public void start() throws ContextInitException {
+        super.start();
+        
+        entryPointProxy = getInstance(null);
+        wsBinding = (WebServiceBinding)entry.getBindings().get(0);
+        bus = wsBinding.getBus();
+        typeHelper = wsBinding.getTypeHelper();
+        Definition wsdlDef = wsBinding.getWSDLDefinition();
+        port = wsBinding.getWSDLPort();
+        wsdlCache = new WSDLMetaDataCache(wsdlDef, wsBinding.getWSDLPort());
+        
+        initOperationMap(wsdlDef);
+        
+        String key = wsdlDef.getDocumentBaseURI();
+        URL url;
+        try {
+            url = new URL(key);
+        } catch (MalformedURLException e) {
+            throw new ContextInitException(e);
+        }
+
+        EndpointReferenceType reference = EndpointReferenceUtils.getEndpointReference(url,
+                wsBinding.getWSDLService().getQName(),
+                wsBinding.getWSDLPort().getName());
+        
+        AttributedURIType address = new AttributedURIType();
+
+        String bindingId = null;
+        Binding binding = wsBinding.getWSDLPort().getBinding();
+        if (null != binding) {
+            List list = binding.getExtensibilityElements();
+            if (!list.isEmpty()) {
+                bindingId = ((ExtensibilityElement)list.get(0)).getElementType().getNamespaceURI();
+            }
+        }
+        List<?> list = wsBinding.getWSDLPort().getExtensibilityElements();
+        for (Object ep : list) {
+            ExtensibilityElement ext = (ExtensibilityElement)ep;
+            if (ext instanceof SOAPAddress) {
+                if (bindingId == null) {
+                    bindingId = ((SOAPAddress)ext).getLocationURI();
+                }
+                address.setValue(((SOAPAddress)ext).getLocationURI());
+            }
+            if (ext instanceof AddressType) {
+                if (bindingId == null) {
+                    bindingId = ((AddressType)ext).getLocation();
+                }
+                address.setValue(((AddressType)ext).getLocation());
+            }
+        }
+        if (reference.getAddress() == null) {
+            //REVIST - bug in Celtix that the HTTP transport won't find the address correctly
+            reference.setAddress(address);
+        }
+        
+        try {
+            serverBinding = bus.getBindingManager().getBindingFactory(bindingId).createServerBinding(
+                    reference, this);
+            serverBinding.activate();
+        } catch (Exception e) {
+            throw new ContextInitException(e);
+        }        
+    }
+
+    @Destroy
+    public void stop() throws CoreRuntimeException {
+        System.out.println("In stop");
+        super.stop();
+    }
+
+    private void initOperationMap(Definition def) {
+        List ops = port.getBinding().getBindingOperations();
+        Iterator opIt = ops.iterator();
+        while (opIt.hasNext()) {
+            BindingOperation op = (BindingOperation)opIt.next();
+            BindingInput bindingInput = op.getBindingInput();
+            List elements = bindingInput.getExtensibilityElements();
+            QName qn = new QName(def.getTargetNamespace(), op.getName());
+            for (Iterator i = elements.iterator(); i.hasNext();) {
+                Object element = i.next();
+                if (SOAPBody.class.isInstance(element)) {
+                    SOAPBody body = (SOAPBody)element;
+                    if (body.getNamespaceURI() != null) {
+                        qn = new QName(body.getNamespaceURI(), op.getName());
+                    }
+                }
+            }
+            
+            ServerDataBindingCallback cb = getDataBindingCallback(qn, null,
+                                                                  DataBindingCallback.Mode.PARTS);
+            opMap.put(qn, cb);
+            if (!"".equals(cb.getRequestWrapperQName().getLocalPart())) {
+                opMap.put(cb.getRequestWrapperQName(), cb);
+            }
+        }        
+    }
+    public ServerDataBindingCallback getDataBindingCallback(QName operationName,
+                                                            ObjectMessageContext objContext,
+                                                            DataBindingCallback.Mode mode) {
+        if (opMap.containsKey(operationName)) {
+            return opMap.get(operationName);
+        }
+        WSDLOperationInfo opInfo = wsdlCache.getOperationInfo(operationName.getLocalPart());
+        if (opInfo == null) {
+            //REVISIT - really map the operation name to a WSDL operation
+            for (String opName : wsdlCache.getAllOperationInfo().keySet()) {
+                if (operationName.getLocalPart().equalsIgnoreCase(opName)) {
+                    opInfo = wsdlCache.getOperationInfo(opName);
+                    break;
+                }
+            }
+        }
+        boolean inout = false;
+        
+        
+        Class<?> serviceInterface = getServiceInterface();
+        Method meth = getMethod(serviceInterface, operationName.getLocalPart());
+        
+        return new SCAServerDataBindingCallback(opInfo,
+                                                typeHelper,
+                                                wsBinding.getResourceLoader(),
+                                                inout,
+                                                meth,
+                                                entryPointProxy);
+    }
+    protected Method getMethod(Class<?> serviceInterface, String operationName) {
+        // Note: this doesn't support overloaded operations
+        Method[] methods = serviceInterface.getMethods();
+        for (Method m : methods) {
+            if (m.getName().equals(operationName)) {
+                return m;
+            }
+            // tolerate WSDL with capatalized operation name
+            StringBuilder sb = new StringBuilder(operationName);
+            sb.setCharAt(0, Character.toLowerCase(sb.charAt(0)));
+            if (m.getName().equals(sb.toString())) {
+                return m;
+            }
+        }
+        throw new BuilderConfigException("no operation named " + operationName
+                                         + " found on service interface: " + serviceInterface.getName());
+    }
+
+    
+    public DataBindingCallback getFaultDataBindingCallback(ObjectMessageContext objContext) {
+        // REVISIT - what to do about faults
+        return null;
+    }
+
+    public Map<QName, ? extends DataBindingCallback> getOperations() {
+        return opMap;
+    }
+
+    public Style getStyle() {
+        return wsdlCache.getStyle();
+    }
+    public DataBindingCallback.Mode getServiceMode() {
+        return DataBindingCallback.Mode.PARTS;
+    }
+
+    public WebServiceProvider getWebServiceProvider() {
+        //not needed I think
+        return null;
+    }
+
+    public Executor getExecutor() {
+        //Let the transport handle it (or it goes to the Bus default wq 
+        //if the transport cannot handle it
+        return null;
+    }
+
+}
+