ServiceDesc.java

package org.objectweb.jonas_ws.deployment.api;

import java.io.File;
import java.io.InputStream;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.HashMap;
import java.util.Hashtable;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.Vector;

import org.objectweb.jonas_lib.I18n;

import org.objectweb.jonas_ws.deployment.lib.MappingFileManager;
import org.objectweb.jonas_ws.deployment.lib.wrapper.MappingFileManagerWrapper;
import org.objectweb.jonas_ws.deployment.xml.JonasPortComponent;
import org.objectweb.jonas_ws.deployment.xml.JonasWebserviceDescription;
import org.objectweb.jonas_ws.deployment.xml.PortComponent;
import org.objectweb.jonas_ws.deployment.xml.WebserviceDescription;

import org.objectweb.jonas.common.Log;

import org.objectweb.util.monolog.api.BasicLevel;
import org.objectweb.util.monolog.api.Logger;

public class ServiceDesc {

    private static I18n i18n = I18n.getInstance(ServiceDesc.class);

    private static Logger logger = Log.getLogger(Log.JONAS_WS_PREFIX);

    private String name;

    private Hashtable namePCDescBindings = new Hashtable();

    private WSDLFile wsdl = null;

    private MappingFile mapping = null;

    private String endpointURI = null;

    private File publicationDirectory = null;

    private URL mappingFileURL;

    private URL localWSDLURL;

    public ServiceDesc(ClassLoader jarCL, WebserviceDescription wsd, JonasWebserviceDescription jwsd) throws WSDeploymentDescException {

        // set name
        name = wsd.getWebserviceDescriptionName();
        if ("".equals(name)) { //$NON-NLS-1$
            throw new WSDeploymentDescException(getI18n().getMessage("ServiceDesc.noServiceName")); //$NON-NLS-1$
        }

        if (jwsd != null) {
            // set endpointURI
            String uri = jwsd.getDefaultEndpointURI();
            if (uri != null && !"".equals(uri)) {
                endpointURI = uri;
            }

            // Set wsdl-publication-directory
            String wsdlPubDir = jwsd.getWsdlPublishDirectory();
            if (wsdlPubDir != null) {
                URL pub;
                try {
                    pub = new URL(wsdlPubDir);
                } catch (MalformedURLException e) {
                    throw new WSDeploymentDescException("Cannot create URL : " + wsdlPubDir, e);
                }
                publicationDirectory = new File(pub.getPath());
            }
        }


        // get ServiceRef WSDLFile name
        String wsdlFileName = wsd.getWsdlFile();

        // wsdl-file element must have a value
        if ("".equals(wsdlFileName)) { //$NON-NLS-1$
            String err = getI18n().getMessage("ServiceDesc.noWSDL", name); //$NON-NLS-1$
            throw new WSDeploymentDescException(err);
        }

        // build the WSDLFile
        wsdl = new WSDLFile(jarCL, wsdlFileName);
        localWSDLURL = jarCL.getResource(wsdlFileName);

        // set mapping file
        String mappingFileName = wsd.getJaxrpcMappingFile();

        // jaxrpc-mapping-file element must have a value
        if (mappingFileName.equals("")) { //$NON-NLS-1$
            String err = getI18n().getMessage("ServiceDesc.noJAXRPCMapping", name); //$NON-NLS-1$
            throw new WSDeploymentDescException(err);
        }

        InputStream isMapping = jarCL.getResourceAsStream(mappingFileName);

        // isMapping must not be null (CL cannot find resource)
        if (isMapping == null) {
            String err = getI18n().getMessage("ServiceDesc.MappingNotFound", mappingFileName, name); //$NON-NLS-1$
            throw new WSDeploymentDescException(err);
        }

        mappingFileURL = jarCL.getResource(mappingFileName);

        // Build Mapping file
        if (isRunningInClientContainer()) {
            // running in Client Container
            mapping = MappingFileManager.getInstance(isMapping, mappingFileName);
        } else {
            // running in server
            mapping = MappingFileManagerWrapper.getMappingFile(isMapping, mappingFileName);
        }

        // links port-components and jonas-port-components
        Map links = associatePCAndJPC(wsd, jwsd);

        // set namePCDescBindings
        List pcl = wsd.getPortComponentList();

        for (int i = 0; i < pcl.size(); i++) {
            // for each port component, build and add a PortComponentDesc Object
            PortComponent pc = (PortComponent) pcl.get(i);
            JonasPortComponent jpc = (JonasPortComponent) links.get(pc.getPortComponentName());

            PortComponentDesc pcd = PortComponentDescFactory.newInstance(jarCL, pc, jpc, this);

            if (!wsdl.hasPort(pcd.getQName())) {
                throw new WSDeploymentDescException(getI18n().getMessage(
                        "ServiceDesc.unknownWSDLPort", pcd.getName(), pcd.getQName())); //$NON-NLS-1$
            }

            if (namePCDescBindings.put(pcd.getName(), pcd) != null) {
                throw new WSDeploymentDescException(getI18n().getMessage(
                        "ServiceDesc.portNameAlreadyUsed", pcd.getName())); //$NON-NLS-1$
            }
        }

        // validate informations :
        List ports = getPortComponents();

        // Ports use Soap bindings
        for (int i = 0; i < ports.size(); i++) {
            if (ports.get(i) != null) {
                PortComponentDesc pcd = (PortComponentDesc) ports.get(i);

                if (!wsdl.hasSOAPBinding(pcd.getQName())) {
                    throw new WSDeploymentDescException(getI18n().getMessage(
                            "ServiceDesc.noSOAPBinding", pcd.getName(), pcd.getQName())); //$NON-NLS-1$
                }
            }
        }
    }

    private boolean isRunningInClientContainer() {
        return (System.getProperty("jonas.base") == null);
    }

    private Map associatePCAndJPC(WebserviceDescription wsd, JonasWebserviceDescription jwsd) {
        Map res = new HashMap();
        // for each port-component
        for (Iterator i = wsd.getPortComponentList().iterator(); i.hasNext();) {
            PortComponent pc = (PortComponent) i.next();
            res.put(pc.getPortComponentName(), null);
        }
        // jonas-port-component(s)
        if (jwsd != null) {

            // get all port-component.name
            Set keys = res.keySet();

            // for each jonas-port-component
            for (Iterator i = jwsd.getJonasPortComponentList().iterator(); i.hasNext();) {
                JonasPortComponent jpc = (JonasPortComponent) i.next();
                String pcName = jpc.getPortComponentName();

                if (keys.contains(pcName)) {
                    // jonas-port-component linked to port-component
                    res.put(pcName, jpc);
                } else {
                    String err = "jonas-port-component '" + pcName + "' is not linked to any port-component. It will be ignored."; //getI18n().getMessage("WSDeploymentDesc.wsdlDeclareUnknownPort", wsdlf.getName());
                    logger.log(BasicLevel.WARN, err);
                }
            }
        }
        return res;
    }

    public String getName() {
        return name;
    }

    public MappingFile getMapping() {
        return mapping;
    }

    public WSDLFile getWSDL() {
        return wsdl;
    }

    public String getEndpointURI() {
        return endpointURI;
    }

    public List getPortComponents() {
        return new Vector(namePCDescBindings.values());
    }

    public PortComponentDesc getPortComponent(String pcName) {
        return (PortComponentDesc) namePCDescBindings.get(pcName);
    }

    public String toString() {
        StringBuffer sb = new StringBuffer();

        sb.append("\n" + getClass().getName()); //$NON-NLS-1$
        sb.append("\ngetName()=" + getName()); //$NON-NLS-1$
        sb.append("\ngetMapping()=" + getMapping()); //$NON-NLS-1$
        sb.append("\ngetWSDL()=" + getWSDL()); //$NON-NLS-1$

        for (Iterator i = getPortComponents().iterator(); i.hasNext();) {
            sb.append("\ngetPortComponents()=" + ((PortComponentDesc) i.next()).toString()); //$NON-NLS-1$
        }

        return sb.toString();
    }

    protected static I18n getI18n() {
        return i18n;
    }

    public File getPublicationDirectory() {
        return publicationDirectory;
    }

    public URL getMappingFileURL() {
        return mappingFileURL;
    }

    public URL getLocalWSDLURL() {
        return localWSDLURL;
    }
}

---