1 files changed, 212 insertions, 0 deletions
diff --git a/sca-java-1.x/tags/java-stable-20060304/sca/model/src/main/java/org/apache/tuscany/model/types/wsdl/impl/WSDLServiceContractImpl.java b/sca-java-1.x/tags/java-stable-20060304/sca/model/src/main/java/org/apache/tuscany/model/types/wsdl/impl/WSDLServiceContractImpl.java
new file mode 100644
index 0000000000..262503feb0
--- /dev/null
+++ b/sca-java-1.x/tags/java-stable-20060304/sca/model/src/main/java/org/apache/tuscany/model/types/wsdl/impl/WSDLServiceContractImpl.java
@@ -0,0 +1,212 @@
+/**
+ *
+ *  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.model.types.wsdl.impl;
+
+import static org.objectweb.asm.Opcodes.ACC_ABSTRACT;
+import static org.objectweb.asm.Opcodes.ACC_INTERFACE;
+import static org.objectweb.asm.Opcodes.ACC_PUBLIC;
+import static org.objectweb.asm.Opcodes.V1_5;
+
+import java.util.List;
+
+import javax.wsdl.Definition;
+import javax.wsdl.Operation;
+import javax.wsdl.PortType;
+import javax.xml.namespace.QName;
+
+import org.apache.tuscany.common.resource.ResourceLoader;
+import org.apache.tuscany.model.assembly.AssemblyModelContext;
+import org.apache.tuscany.model.assembly.impl.ServiceContractImpl;
+import org.apache.tuscany.model.assembly.loader.AssemblyModelLoader;
+import org.apache.tuscany.model.types.wsdl.WSDLServiceContract;
+import org.apache.tuscany.model.util.XMLNameUtil;
+import org.objectweb.asm.ClassWriter;
+import org.objectweb.asm.Type;
+
+import commonj.sdo.DataObject;
+
+/**
+ * An implementation of WSDLServiceContract.
+ */
+public class WSDLServiceContractImpl extends ServiceContractImpl implements WSDLServiceContract {
+
+    private PortType portType;
+    private PortType callbackPortType;
+    private String portTypeURI;
+    private String callbackPortTypeURI;
+    
+    /**
+     * Constructor
+     */
+    public WSDLServiceContractImpl() {
+    }
+
+    /**
+     * @see org.apache.tuscany.model.types.wsdl.WSDLServiceContract#getPortType()
+     */
+    public PortType getPortType() {
+        return portType;
+    }
+    
+    /**
+     * @see org.apache.tuscany.model.types.wsdl.WSDLServiceContract#setPortType(javax.wsdl.PortType)
+     */
+    public void setPortType(PortType portType) {
+        checkNotFrozen();
+        this.portType=portType;
+    }
+
+    /**
+     * @see org.apache.tuscany.model.types.wsdl.WSDLServiceContract#getCallbackPortType()
+     */
+    public PortType getCallbackPortType() {
+        return callbackPortType;
+    }
+    
+    /**
+     * @see org.apache.tuscany.model.types.wsdl.WSDLServiceContract#setCallbackPortType(javax.wsdl.PortType)
+     */
+    public void setCallbackPortType(PortType portType) {
+        checkNotFrozen();
+        callbackPortType=portType;
+    }
+
+    /**
+     * @param portTypeURI The portTypeURI to set.
+     */
+    public void setPortTypeURI(String portTypeURI) {
+        this.portTypeURI = portTypeURI;
+    }
+    
+    /**
+     * @param callbackPortTypeURI The callbackPortTypeURI to set.
+     */
+    public void setCallbackPortTypeURI(String callbackPortTypeURI) {
+        this.callbackPortTypeURI = callbackPortTypeURI;
+    }
+    
+    /**
+     * @see org.apache.tuscany.model.assembly.impl.ExtensibleImpl#initialize(org.apache.tuscany.model.assembly.AssemblyModelContext)
+     */
+    public void initialize(AssemblyModelContext modelContext) {
+        if (isInitialized())
+            return;
+        super.initialize(modelContext);
+        
+        // Resolve the WSDL portType and callback portType
+        AssemblyModelLoader modelLoader=modelContext.getAssemblyLoader();
+        if (portTypeURI!=null && portType==null) {
+            portType=getPortType(modelLoader, portTypeURI);
+        }
+        if (callbackPortTypeURI!=null && callbackPortType==null) {
+            callbackPortType=getPortType(modelLoader, callbackPortTypeURI);
+        }
+
+        // Load the Java interface for the portType 
+        if (portType!=null && getInterface()==null) {
+            QName qname=portType.getQName();
+            String interfaceName=XMLNameUtil.getFullyQualifiedClassNameFromQName(qname.getNamespaceURI(), qname.getLocalPart());
+            Class interfaceClass;
+            try {
+                // Load the interface
+                interfaceClass=modelContext.getApplicationResourceLoader().loadClass(interfaceName);
+            } catch (ClassNotFoundException e) {
+                // Generate the interface on the fly
+                interfaceClass=generateJavaInterface(modelContext.getApplicationResourceLoader(), portType, interfaceName);
+            }
+            super.setInterface(interfaceClass);
+        }
+
+        // Load the Java interface for the callback portType 
+        if (callbackPortType!=null && getCallbackInterface()==null) {
+            QName qname=callbackPortType.getQName();
+            String interfaceName=XMLNameUtil.getFullyQualifiedClassNameFromQName(qname.getNamespaceURI(), qname.getLocalPart());
+            Class interfaceClass;
+            try {
+                // Load the interface
+                interfaceClass=modelContext.getApplicationResourceLoader().loadClass(interfaceName);
+            } catch (ClassNotFoundException e) {
+                // Generate the interface on the fly
+                interfaceClass=generateJavaInterface(modelContext.getApplicationResourceLoader(), portType, interfaceName);
+            }
+            super.setCallbackInterface(interfaceClass);
+        }
+    }
+
+    /**
+     * Get a portType from the given uri
+     * @param loader
+     * @param uri
+     * @return
+     */
+    private PortType getPortType(AssemblyModelLoader loader, String uri) {
+
+        // Get the WSDL port namespace and name
+        int h=uri.indexOf('#');
+        String namespace=uri.substring(0,h);
+        String name=uri.substring(h+1);
+        QName qname=new QName(namespace, name);
+
+        // Load the WSDL definitions for the given namespace
+        List<Definition> definitions=loader.loadDefinitions(namespace);
+        if (definitions==null)
+            throw new IllegalArgumentException("Cannot find WSDL definition for "+namespace);
+        for (Definition definition: definitions) {
+
+            // Find the port with the given name
+            PortType portType=definition.getPortType(qname);
+            return portType;
+        }
+        throw new IllegalArgumentException("Cannot find WSDL portType "+uri);
+    }
+    
+    /**
+     * Generate a Java interface from a WSDL portType.
+     * @param portType
+     * @param interfaceName
+     * @return
+     */
+    private Class generateJavaInterface(ResourceLoader resourceLoader, PortType portType, String interfaceName) {
+        ClassWriter cw=new ClassWriter(false);
+        
+        // Generate the interface
+        interfaceName=interfaceName.replace('.', '/');
+        cw.visit(V1_5, ACC_PUBLIC + ACC_ABSTRACT + ACC_INTERFACE, interfaceName, null, "java/lang/Object", new String[0]);
+        
+        
+        // Generate methods from the WSDL operations
+        for (Operation operation : (List<Operation>)portType.getOperations()) {
+            String methodName=XMLNameUtil.getJavaNameFromXMLName(operation.getName(), false);
+            
+            //FIXME integrate XSD to Java type mapping here
+            String inputType = Type.getDescriptor(String.class);
+            String outputType = Type.getDescriptor(String.class);
+            
+            cw.visitMethod(ACC_PUBLIC + ACC_ABSTRACT, methodName, "("+inputType+")"+outputType, null, null).visitEnd();
+        }
+
+        // Generate the bytecodes
+        cw.visitEnd();
+        byte[] bytes=cw.toByteArray();
+        
+        // Add the class to the resource loader
+        Class interfaceClass=(Class)resourceLoader.addClass(bytes);
+        
+        return interfaceClass; 
+    }
+    
+}