Attachment #66381 for bug #176493

Some Eclipse Foundation services are deprecated, or will be soon. Please ensure you've read this important communication.

Lines 1-28 Link Here

(-)wsexplorer/wsdl/soap_envelope_xml.jsp (-7 / +13 lines)
1	<%	1	<%
2	/*******************************************************************************	2	/*******************************************************************************
3	* Copyright (c) 2001, 2004 IBM Corporation and others.	3	* Copyright (c) 2001, 2007 IBM Corporation and others.
4	* All rights reserved. This program and the accompanying materials	4	* All rights reserved. This program and the accompanying materials
5	* are made available under the terms of the Eclipse Public License v1.0	5	* are made available under the terms of the Eclipse Public License v1.0
6	* which accompanies this distribution, and is available at	6	* which accompanies this distribution, and is available at
7	* http://www.eclipse.org/legal/epl-v10.html	7	* http://www.eclipse.org/legal/epl-v10.html
8	*	8	*
9	* Contributors:	9	* Contributors:
10	* IBM Corporation - initial API and implementation	10	* IBM Corporation - initial API and implementation
		11	* yyyymmdd bug Email and other contact information
		12	* -------- -------- -----------------------------------------------------------
		13	* 20070413 176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
11	*******************************************************************************/	14	*******************************************************************************/
12	%><%@ page contentType="text/xml; charset=UTF-8" import="org.eclipse.wst.ws.internal.explorer.platform.wsdl.perspective.*,	15	%><%@ page contentType="text/xml; charset=UTF-8" import="org.eclipse.wst.ws.internal.explorer.platform.wsdl.perspective.*,
13	org.eclipse.wst.ws.internal.explorer.platform.wsdl.constants.*" %><jsp:useBean id="controller" class="org.eclipse.wst.ws.internal.explorer.platform.perspective.Controller" scope="session"/><%	16	org.eclipse.wst.ws.internal.explorer.platform.wsdl.constants.*,
		17	org.eclipse.wst.ws.internal.explorer.platform.wsdl.datamodel.WSDLOperationElement,
		18	org.eclipse.wst.ws.internal.explorer.transport.*" %><jsp:useBean id="controller" class="org.eclipse.wst.ws.internal.explorer.platform.perspective.Controller" scope="session"/><%
14	int soapEnvelopeType = Integer.parseInt(request.getParameter(WSDLActionInputs.SOAP_ENVELOPE_TYPE));	19	int soapEnvelopeType = Integer.parseInt(request.getParameter(WSDLActionInputs.SOAP_ENVELOPE_TYPE));
15	WSDLPerspective wsdlPerspective = controller.getWSDLPerspective();	20	WSDLPerspective wsdlPerspective = controller.getWSDLPerspective();
16	SOAPMessageQueue soapMessageQueue;	21	WSDLOperationElement operElement = (WSDLOperationElement) wsdlPerspective.getOperationNode().getTreeElement();
		22	ISOAPMessage soapMessage;
17	switch (soapEnvelopeType)	23	switch (soapEnvelopeType)
18	{	24	{
19	case WSDLActionInputs.SOAP_ENVELOPE_TYPE_REQUEST:	25	case WSDLActionInputs.SOAP_ENVELOPE_TYPE_REQUEST:
20	soapMessageQueue = wsdlPerspective.getSOAPRequestQueue();	26	soapMessage = (ISOAPMessage) operElement.getPropertyAsObject(WSDLModelConstants.PROP_SOAP_REQUEST);
21	break;	27	break;
22	case WSDLActionInputs.SOAP_ENVELOPE_TYPE_RESPONSE:	28	case WSDLActionInputs.SOAP_ENVELOPE_TYPE_RESPONSE:
23	default:	29	default:
24	soapMessageQueue = wsdlPerspective.getSOAPResponseQueue();	30	soapMessage = (ISOAPMessage) operElement.getPropertyAsObject(WSDLModelConstants.PROP_SOAP_RESPONSE);
25	break;	31	break;
26	}	32	}
27	String messages = soapMessageQueue.getMessagesFromList();	33	String messages = soapMessage.toXML();
28	%><%=messages%>	34	%><%=messages%>




/*******************************************************************************
 * Copyright (c) 2004, 2005 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 *     IBM Corporation - initial API and implementation
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.util;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;
import javax.xml.transform.OutputKeys;
import javax.xml.transform.Transformer;
import javax.xml.transform.TransformerFactory;
import javax.xml.transform.dom.DOMSource;
import javax.xml.transform.stream.StreamResult;
import org.w3c.dom.Document;
import org.w3c.dom.DocumentFragment;
import org.w3c.dom.Element;
import org.xml.sax.SAXException;

public final class XMLUtils
{
  /**
   * Serialize an XML Element into a String.
   * @param e Element to be serialized.
   * @param omitXMLDeclaration boolean representing whether or not to omit the XML declaration.
   * @return String representation of the XML document fragment.
   */
  public static final String serialize(Element e,boolean omitXMLDeclaration)
  {
    if (e != null)
    {
      try
      {
		DOMSource domSource = new DOMSource(e);
		Transformer serializer = TransformerFactory.newInstance().newTransformer();
		serializer.setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, ((omitXMLDeclaration) ? "yes" : "no"));
		serializer.setOutputProperty(OutputKeys.INDENT, "yes");
		serializer.setOutputProperty(OutputKeys.ENCODING, HTMLUtils.UTF8_ENCODING);
		serializer.setOutputProperty("{http://xml.apache.org/xslt}indent-amount", "2");
		ByteArrayOutputStream baos = new ByteArrayOutputStream();
		serializer.transform(domSource, new	StreamResult(baos));
		baos.close();
		return new String(baos.toByteArray(), HTMLUtils.UTF8_ENCODING);
      }
      catch (Throwable t)
      {
      }
    }
    return null;
  }
    
  /**
   * Serialize an XML Element into a String.
   * @param df DocumentFragment to be serialized.
   * @param omitXMLDeclaration boolean representing whether or not to omit the XML declaration.
   * @return String representation of the XML document fragment.
   */  
  public static final String serialize(DocumentFragment df,boolean omitXMLDeclaration)
  {
    if (df != null)
    {
      try
      {
		DOMSource domSource = new DOMSource(df);
		Transformer serializer = TransformerFactory.newInstance().newTransformer();
		serializer.setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, ((omitXMLDeclaration) ? "yes" : "no"));
		serializer.setOutputProperty(OutputKeys.INDENT, "yes");
		serializer.setOutputProperty(OutputKeys.ENCODING, HTMLUtils.UTF8_ENCODING);
		serializer.setOutputProperty("{http://xml.apache.org/xslt}indent-amount", "2");
		ByteArrayOutputStream baos = new ByteArrayOutputStream();
		serializer.transform(domSource, new	StreamResult(baos));
		baos.close();
		return new String(baos.toByteArray(), HTMLUtils.UTF8_ENCODING);
      }
      catch (Throwable t)
      {
      }
    }
    return null;
  }
  
  /**
   * Create a new XML Document.
   * @param docBuilder DocumentBuilder. Setting this to null will create a new DocumentBuilder.
   * @return Document
   */
  public static final Document createNewDocument(DocumentBuilder docBuilder) throws ParserConfigurationException
  {
    if (docBuilder == null)
    {
      DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
      factory.setNamespaceAware(false);
      factory.setValidating(false);
      docBuilder = factory.newDocumentBuilder();
    }
    Document doc = docBuilder.newDocument();
    return doc;
  }

  /**
   * Convert the String representation of an Element into an Element
   * @param String representation of an Element.
   * @return Element
   */
  public static Element stringToElement(String s) throws ParserConfigurationException, SAXException, UnsupportedEncodingException, IOException {
    return stringToElement(s, false);
  }

  /**
   * Convert the String representation of an Element into an Element
   * @param String representation of an Element.
   * @param boolean set whether the return Element should be namespace aware.
   * @return Element
   */
  public static Element stringToElement(String s, boolean namespaceAware) throws ParserConfigurationException, SAXException, UnsupportedEncodingException, IOException
  {
    return byteArrayToElement(s.getBytes(HTMLUtils.UTF8_ENCODING), namespaceAware);
  }

  /**
   * Convert the byte array representation of an Element into an Element
   * @param byte[] representation of an Element.
   * @param boolean set whether the return Element should be namespace aware.
   * @return Element
   */
  public static Element byteArrayToElement(byte[] b, boolean namespaceAware) throws ParserConfigurationException, SAXException, UnsupportedEncodingException, IOException
  {
    DocumentBuilderFactory docBuilderFactory = DocumentBuilderFactory.newInstance();
    docBuilderFactory.setNamespaceAware(namespaceAware);
    docBuilderFactory.setValidating(false);
    DocumentBuilder docBuilder = docBuilderFactory.newDocumentBuilder();
    Document doc = docBuilder.parse(new ByteArrayInputStream(b));
    return doc.getDocumentElement();
  }
}




/*******************************************************************************
 * Copyright (c) 2005 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 * 
 * Contributors:
 *     IBM Corporation - initial API and implementation
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.util;

import java.io.UnsupportedEncodingException;
import java.net.URLDecoder;
import java.net.URLEncoder;

/**
 * This class contains utility methods for managing URLs
 * as used by the Web Services Explorer Web application.
 * @author cbrealey@ca.ibm.com
 */
public final class URLUtils
{
	/**
	 * Objects of this class should not be constructed.
	 */
	private URLUtils ()
	{
	}

	/**
	 * UTF-8
	 */
	public static final String UTF8 = "UTF-8";

	/**
	 * Equivalent to {@link #encode(String,String)}
	 * with second parameter set to the "UTF-8" encoding.
	 * @param s The string to encode.
	 * @return The encoded string.
	 */
	public static String encode(String s)
	{
		return encode(s,UTF8);
	}
	
	/**
	 * Equivalent to {@link URLEncoder#encode(String,String)},
	 * only throws an unchecked {@link RuntimeException} wrapped
	 * around an {@link UnsupportedEncodingException} instead of
	 * an {@link UnsupportedEncodingException}.
	 * @param s The string to encode.
	 * @param enc The encoding to use.
	 * @return The encoded string.
	 */
	public static String encode(String s, String enc)
	{
		try
		{
			return URLEncoder.encode(s,enc);
		}
		catch (UnsupportedEncodingException e)
		{
			// TODO: MSG_BROKEN_VM_DOES_NOT_SUPPORT_UTF-8
			throw new RuntimeException("%MSG_BROKEN_VM_DOES_NOT_SUPPORT_UTF-8",e);
		}
	}
	
	/**
	 * Equivalent to {@link #decode(String,String)}
	 * with second parameter set to the "UTF-8" encoding.
	 * @param s The string to decode.
	 * @return The decoded string.
	 */
	public static String decode(String s)
	{
		return decode(s,UTF8);
	}
	
	/**
	 * Equivalent to {@link URLEncoder#decode(String,String)},
	 * only throws an unchecked {@link RuntimeException} wrapped
	 * around an {@link UnsupportedEncodingException} instead of
	 * an {@link UnsupportedEncodingException}.
	 * @param s The string to decode.
	 * @param enc The encoding to use.
	 * @return The decoded string.
	 */
	public static String decode(String s, String enc)
	{
		try
		{
			return URLDecoder.decode(s,enc);
		}
		catch (UnsupportedEncodingException e)
		{
			// TODO: MSG_BROKEN_VM_DOES_NOT_SUPPORT_UTF-8
			throw new RuntimeException("%MSG_BROKEN_VM_DOES_NOT_SUPPORT_UTF-8",e);
		}
	}
}




 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070305   117034 makandre@ca.ibm.com - Andrew Mak, Web Services Explorer should support SOAP Headers
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.wsdl.actions;

import java.io.OutputStream;
import java.io.PrintWriter;
import java.util.Hashtable;

import javax.xml.parsers.ParserConfigurationException;
import org.eclipse.wst.ws.internal.explorer.platform.perspective.Controller;
import org.eclipse.wst.ws.internal.explorer.platform.util.MultipartFormDataException;
import org.eclipse.wst.ws.internal.explorer.platform.util.MultipartFormDataParser;
import org.eclipse.wst.ws.internal.explorer.platform.util.XMLUtils;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.constants.FragmentConstants;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.constants.WSDLActionInputs;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.constants.WSDLModelConstants;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.datamodel.WSDLBindingElement;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.datamodel.WSDLElement;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.datamodel.WSDLOperationElement;
import org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.util.SoapHelper;
import org.w3c.dom.Element;
import org.w3c.dom.NodeList;

public class InvokeWSDLSOAPOperationSourceAction extends InvokeWSDLSOAPOperationAction
{
  private boolean newFileSelected_;
  private boolean saveAsSelected_;
  private boolean isHeader_;
  private static final String DUMMY_WRAPPER_START_TAG = "<dummyWrapper>";
  private static final String DUMMY_WRAPPER_END_TAG = "</dummyWrapper>";
  
  public InvokeWSDLSOAPOperationSourceAction(Controller controller)
  {

    return false;
    */
  }
  
  /* (non-Javadoc)
   * @see org.eclipse.wst.ws.internal.explorer.platform.wsdl.actions.InvokeWSDLSOAPOperationAction#getSOAPRequestMessage(org.eclipse.wst.ws.internal.explorer.platform.wsdl.datamodel.WSDLOperationElement)
   */
  protected ISOAPMessage getSOAPRequestMessage(WSDLOperationElement operElement) {	  
	  return (ISOAPMessage) operElement.getPropertyAsObject(WSDLModelConstants.PROP_SOAP_REQUEST_TMP);
  } 

  /* (non-Javadoc)
   * @see org.eclipse.wst.ws.internal.explorer.platform.wsdl.actions.InvokeWSDLSOAPOperationAction#setHeaderContent(java.util.Hashtable, org.eclipse.wst.ws.internal.explorer.platform.wsdl.datamodel.WSDLOperationElement, org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage)
	  Vector headerEntries = new Vector();
      String[] nsDeclarations = (String[])operElement.getPropertyAsObject(WSDLModelConstants.PROP_SOURCE_CONTENT_NAMESPACE);
   	  for (int i = 0; i < nsDeclarations.length; i++)
	  {
	    String[] prefix_ns = SoapHelper.decodeNamespaceDeclaration(nsDeclarations[i]);
	    if (!soapEnvelopeNamespaceTable.contains(prefix_ns[1]))
	      soapEnvelopeNamespaceTable.put(prefix_ns[1], prefix_ns[0]);
	  }
	  StringBuffer sourceContent = new StringBuffer(operElement.getPropertyAsString(WSDLModelConstants.PROP_SOURCE_CONTENT_HEADER));
	  sourceContent.insert(0,DUMMY_WRAPPER_START_TAG).append(DUMMY_WRAPPER_END_TAG);
	  Element dummyWrapperElement = XMLUtils.stringToElement(sourceContent.toString());          
	  NodeList nl = dummyWrapperElement.getChildNodes();
	  for (int i = 0; i < nl.getLength(); i++)
	  {
	    if (nl.item(i) instanceof Element)
	      headerEntries.add(nl.item(i));
	  }
	  
	  return headerEntries;
  }

  /**
   * Generate a Vector of the elements inside the Soap Body.
   * @param soapEnvelopeNamespaceTable - Hashtable containing a map of the namespace URIs to prefixes.
   * @param operElement - WSDLOperationElement encapsulating the WSDL operation.
   */
  protected void setHeaderContent(Hashtable soapEnvelopeNamespaceTable, WSDLOperationElement operElement, ISOAPMessage soapMessage) {	
   	String headerContent = operElement.getPropertyAsString(WSDLModelConstants.PROP_SOURCE_CONTENT_HEADER);
    operElement.getSOAPTransportProvider().newTransport().newDeserializer()
    	.deserialize(ISOAPMessage.HEADER_CONTENT, headerContent, soapMessage);
  }
  
  /* (non-Javadoc)
   * @see org.eclipse.wst.ws.internal.explorer.platform.wsdl.actions.InvokeWSDLSOAPOperationAction#setBodyContent(java.util.Hashtable, org.eclipse.wst.ws.internal.explorer.platform.wsdl.datamodel.WSDLOperationElement, org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage)
   */ 
  protected void setBodyContent(Hashtable soapEnvelopeNamespaceTable, WSDLOperationElement operElement, ISOAPMessage soapMessage) {
    String bodyContent = operElement.getPropertyAsString(WSDLModelConstants.PROP_SOURCE_CONTENT);    
    operElement.getSOAPTransportProvider().newTransport().newDeserializer()
    	.deserialize(ISOAPMessage.BODY_CONTENT, bodyContent, soapMessage);        
    NodeList nl = dummyWrapperElement.getChildNodes();
    for (int i = 0; i < nl.getLength(); i++)
    {
      if (nl.item(i) instanceof Element)
        bodyEntries.add(nl.item(i));
    }
    if (!operElement.isDocumentStyle())
    {
      try
      {
        addRPCWrapper(bodyEntries,(WSDLElement)serviceElement.getParentElement(),operElement,soapEnvelopeNamespaceTable);
      }
      catch (ParserConfigurationException e)
      {
        throw e;
      }
    }
    return bodyEntries;
  }

  public final boolean wasNewFileSelected()




 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070305   117034 makandre@ca.ibm.com - Andrew Mak, Web Services Explorer should support SOAP Headers
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.wsdl.actions;

import java.util.Hashtable;
import java.util.Iterator;
import java.util.Map;

import javax.wsdl.Part;

import org.eclipse.wst.ws.internal.explorer.platform.perspective.Controller;
import org.eclipse.wst.ws.internal.explorer.platform.perspective.Node;
import org.eclipse.wst.ws.internal.explorer.platform.util.MultipartFormDataException;
import org.eclipse.wst.ws.internal.explorer.platform.util.MultipartFormDataParser;
import org.eclipse.wst.ws.internal.explorer.platform.util.XMLUtils;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.constants.FragmentConstants;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.constants.WSDLModelConstants;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.datamodel.WSDLOperationElement;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.fragment.IXSDFragment;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.fragment.impl.SOAPHeaderWrapperFragment;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.perspective.InvokeWSDLOperationTool;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.util.SOAPMessageUtils;
import org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage;
import org.eclipse.wst.wsdl.binding.soap.SOAPHeader;
import org.w3c.dom.Element;
import org.w3c.dom.NodeList;

public class SynchronizeFragmentViewsAction extends WSDLPropertiesFormAction
{

    if (viewID.equals(FragmentConstants.FRAGMENT_VIEW_SWITCH_FORM_TO_SOURCE))
    {
      invokeWSDLOperationTool.setFragmentViewID(FragmentConstants.FRAGMENT_VIEW_SWITCH_FORM_TO_SOURCE);
      operElement.setPropertyAsObject(WSDLModelConstants.PROP_SOURCE_CONTENT_NAMESPACE, null);
      
      return processFormViewParsedResultsHeader(parser, operElement) &		// need to process both header and body 
             processFormViewParsedResults(parser, operElement);
    }
    else
    {
      invokeWSDLOperationTool.setFragmentViewID(FragmentConstants.FRAGMENT_VIEW_SWITCH_SOURCE_TO_FORM);
      String[] nsDeclarations = parser.getParameterValues(FragmentConstants.SOURCE_CONTENT_NAMESPACE);    
      if (nsDeclarations != null)
        operElement.setPropertyAsObject(WSDLModelConstants.PROP_SOURCE_CONTENT_NAMESPACE,nsDeclarations);
      
      ISOAPMessage soapMessage = (ISOAPMessage) operElement.getPropertyAsObject(WSDLModelConstants.PROP_SOAP_REQUEST_TMP);
      boolean rc = processSourceViewParsedResultsHeader(parser, operElement, soapMessage) &	// need to process both header and body
		 		   processSourceViewParsedResults(parser, operElement, soapMessage); 
      operElement.setPropertyAsObject(WSDLModelConstants.PROP_SOAP_REQUEST_TMP, null);
      
      return rc;
    }
  }


  private boolean processFormViewParsedResults(MultipartFormDataParser parser, WSDLOperationElement operElement) throws MultipartFormDataException
  {
    operElement.setPropertyAsObject(WSDLModelConstants.PROP_SOURCE_CONTENT, null);
    operElement.setPropertyAsObject(WSDLModelConstants.PROP_SOURCE_CONTENT_NAMESPACE, null);
    boolean resultsValid = true;
	
    Iterator it = operElement.getOrderedBodyParts().iterator();    

      operElement.setPropertyAsString(WSDLModelConstants.PROP_SOURCE_CONTENT,null);
    return resultsValid;
  }
  
  private boolean processSourceViewParsedResultsHeader(MultipartFormDataParser parser, WSDLOperationElement operElement, ISOAPMessage soapMessage) 
  	throws MultipartFormDataException {
	  
    String sourceContent = parser.getParameter(FragmentConstants.SOURCE_CONTENT_HEADER);
    if (sourceContent != null)
      operElement.setPropertyAsString(WSDLModelConstants.PROP_SOURCE_CONTENT_HEADER, sourceContent);    
           
    if (nsDeclarations != null)
      operElement.setPropertyAsObject(WSDLModelConstants.PROP_SOURCE_CONTENT_NAMESPACE,nsDeclarations);
    
    Iterator it = operElement.getSOAPHeaders().iterator();
    if (!it.hasNext())
      return true;
              
    Hashtable namespaceTable = new Hashtable();
    
    if (nsDeclarations != null) {
      for (int i = 0; i < nsDeclarations.length; i++)
      {
        String[] prefix_ns = SoapHelper.decodeNamespaceDeclaration(nsDeclarations[i]);
        if (!namespaceTable.contains(prefix_ns[1]))
          namespaceTable.put(prefix_ns[1], prefix_ns[0]);
      }
    }
    
    sourceContent = addRootElement(sourceContent);
    try
    {
      operElement.getSOAPTransportProvider().newTransport().newDeserializer()
      	.deserialize(ISOAPMessage.HEADER_CONTENT, sourceContent, soapMessage);  
    	
      Element[] instanceDocuments = soapMessage.getHeaderContent();
      Map namespaceTable = soapMessage.getNamespaceTable();
      // work backwards so that if there are multiple nodes with the same name
      // the topmost one takes precedence
      for (int i = nl.getLength() - 1; i >= 0; i--) {
    	  org.w3c.dom.Node node = nl.item(i);
          if (node != null && node instanceof Element)
        	  elements.put(node.getNodeName(), node);
      }      
      
      boolean sourceElementsValid = true;
      int start = 0;
      while (it.hasNext() && start < instanceDocuments.length)
      {
        SOAPHeader soapHeader = (SOAPHeader)it.next();
        SOAPHeaderWrapperFragment frag = (SOAPHeaderWrapperFragment) operElement.getHeaderFragment(soapHeader);
        
        int pos = SOAPMessageUtils.findFirstMatchingElement(
        		soapHeader.getEPart(),
				instanceDocuments,
				namespaceTable,
				frag.getName(),
				start);
			
		if (pos == -1)
			continue;
			
		Element element = instanceDocuments[pos];
		start = pos + 1;			
        
        if (!frag.setParameterValuesFromInstanceDocument(element, namespaceTable))
          sourceElementsValid = false;
      }
      return sourceElementsValid;

    }    
  }
  
  private boolean processSourceViewParsedResults(MultipartFormDataParser parser, WSDLOperationElement operElement, ISOAPMessage soapMessage)
  	throws MultipartFormDataException {
	  
    String sourceContent = parser.getParameter(FragmentConstants.SOURCE_CONTENT);
    if (sourceContent != null)
      operElement.setPropertyAsString(WSDLModelConstants.PROP_SOURCE_CONTENT, sourceContent);
    
    Iterator it = operElement.getOrderedBodyParts().iterator();    
    
    sourceContent = addRootElement(sourceContent);
    try
    {
      operElement.getSOAPTransportProvider().newTransport().newDeserializer()
      	.deserialize(ISOAPMessage.BODY_CONTENT, sourceContent, soapMessage);      	
    	
      Element[] instanceDocuments = soapMessage.getBodyContent();
      
        org.w3c.dom.Node node = nl.item(i);
        if (node != null && node instanceof Element)
          elementsVector.add(node);
      }
      Element[] instanceDocuments = new Element[elementsVector.size()];
      elementsVector.copyInto(instanceDocuments);
      boolean sourceElementsValid = true;
      while (it.hasNext())
      {

    }
  }

  private String addRootElement(String element)
  {
    StringBuffer sb = new StringBuffer();
    sb.append(FragmentConstants.ROOT_ELEMENT_START_TAG);
    sb.append(element);
    sb.append(FragmentConstants.ROOT_ELEMENT_END_TAG);
    return sb.toString();
  }

  public boolean run() {
    return true;
  }




 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070305   117034 makandre@ca.ibm.com - Andrew Mak, Web Services Explorer should support SOAP Headers
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.wsdl.actions;

import java.io.BufferedReader;
import java.io.IOException;
import java.util.Hashtable;

import java.util.List;
import java.util.Vector;
import javax.servlet.http.HttpServletResponse;
import javax.wsdl.BindingInput;
import javax.wsdl.BindingOperation;
import javax.wsdl.Definition;
import javax.wsdl.Part;
import javax.wsdl.extensions.ExtensibilityElement;
import javax.wsdl.extensions.soap.SOAPBody;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;

import org.eclipse.wst.ws.internal.explorer.platform.perspective.Controller;
import org.eclipse.wst.ws.internal.explorer.platform.perspective.MessageQueue;
import org.eclipse.wst.ws.internal.explorer.platform.util.MultipartFormDataException;
import org.eclipse.wst.ws.internal.explorer.platform.util.MultipartFormDataParser;
import org.eclipse.wst.ws.internal.explorer.platform.util.XMLUtils;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.constants.WSDLActionInputs;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.constants.WSDLModelConstants;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.datamodel.Endpoint;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.datamodel.WSDLBindingElement;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.datamodel.WSDLElement;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.datamodel.WSDLOperationElement;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.datamodel.WSDLServiceElement;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.fragment.IXSDFragment;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.perspective.InvokeWSDLOperationTool;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.perspective.SOAPMessageQueue;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.perspective.WSDLPerspective;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.util.SOAPMessageUtils;
import org.eclipse.wst.ws.internal.explorer.transport.HTTPTransportException;
import org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage;
import org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransportProvider;
import org.eclipse.wst.ws.internal.explorer.transport.TransportException;
import org.w3c.dom.Document;
import org.w3c.dom.Element;

public abstract class InvokeWSDLSOAPOperationAction extends WSDLPropertiesFormAction
{

    return true;
  }

  protected final void addRPCWrapper(Vector bodyEntries,WSDLElement wsdlElement,WSDLOperationElement operElement,Hashtable soapEnvelopeNamespaceTable) throws ParserConfigurationException
  {
    // Must be RPC style.
    String encodingNamespaceURI = null;
    /*
     * WS-I: In a rpc-literal SOAP binding, the serialized child element of the 
     * soap:Body element consists of a wrapper element, whose namespace is the value 
     * of the namespace attribute of the soapbind:body element and whose local name is 
     * either the name of the operation or the name of the operation suffixed 
     * with "Response". The namespace attribute is required, as opposed to being 
     * optional, to ensure that the children of the soap:Body element are namespace-
     * qualified.
     */
    BindingOperation bindingOperation = operElement.getBindingOperation();
    if (bindingOperation != null)
    {
      BindingInput bindingInput = bindingOperation.getBindingInput();
      if (bindingInput != null)
      {
        List extElements = bindingInput.getExtensibilityElements();
        for (Iterator it = extElements.iterator(); it.hasNext();)
        {
          ExtensibilityElement extElement = (ExtensibilityElement)it.next();
          if (extElement instanceof SOAPBody)
          {
            encodingNamespaceURI = ((SOAPBody)extElement).getNamespaceURI();
            break;
          }
        }
      }
    }
    // If the namespace of the soapbind:body element is not set, get it from the operation element
    if (encodingNamespaceURI == null)
      encodingNamespaceURI = operElement.getEncodingNamespace();
    // If the namespace of the operation element is not set, get it from the definition element
    if (encodingNamespaceURI == null)
    {
      Definition definition = wsdlElement.getDefinition();
      encodingNamespaceURI = definition.getTargetNamespace();
    }
    // Generate an RPC style wrapper element.
    Document doc = XMLUtils.createNewDocument(null);
    String encodingStyle = (operElement.isUseLiteral() ? null : operElement.getEncodingStyle());
    Element wrapperElement = SoapHelper.createRPCWrapperElement(doc,soapEnvelopeNamespaceTable,encodingNamespaceURI,operElement.getOperation().getName(),encodingStyle);
    for (int i=0;i<bodyEntries.size();i++)
      wrapperElement.appendChild(doc.importNode((Element)bodyEntries.elementAt(i),true));
    bodyEntries.removeAllElements();
    bodyEntries.addElement(wrapperElement);
  }

  /**
   * Returns an ISOAPMessage to use for the current SOAP operation invocation.
   * 
   * @param operElement The operation element from the WSDL model.
   * 
   * @return An ISOAPMessage, or null if a message cannot be constructed.
   */
  protected ISOAPMessage getSOAPRequestMessage(WSDLOperationElement operElement) {
	  ISOAPTransportProvider provider = operElement.getSOAPTransportProvider();
	  if (provider == null)
		  return null;	  
	  return provider.newTransport().newMessage(operElement.getMessageContext());
    while (it.hasNext())
    {
      SOAPHeader soapHeader = (SOAPHeader) it.next();
      
      StringBuffer encodingStyle = null;
      boolean isUseLiteral = "literal".equals(soapHeader.getUse());      
      
      if (!isUseLiteral) {
	      Iterator encodingStyles = soapHeader.getEncodingStyles().iterator();
	      encodingStyle = new StringBuffer();
	      while (encodingStyles.hasNext()) {
	    	  Object next = encodingStyles.next();
	    	  if (Constants.URI_SOAP11_ENC.equals(next))
	    		  continue;
	    	  encodingStyle.append(" ").append(next);
	      }	              
      }
      
      IXSDFragment frag = (IXSDFragment)operElement.getHeaderFragment(soapHeader);
      Element[] instanceDocuments = frag.genInstanceDocumentsFromParameterValues(!isUseLiteral,soapEnvelopeNamespaceTable, XMLUtils.createNewDocument(null));
      for (int j=0;j<instanceDocuments.length;j++)
      {
        if (instanceDocuments[j] == null)
          continue;
        if (encodingStyle != null && encodingStyle.length() > 0)
          instanceDocuments[j].setAttribute("soapenv:encodingStyle",encodingStyle.substring(1));
        headerEntries.addElement(instanceDocuments[j]);
      }
    }
	
    return headerEntries;
  }
  
  /**
   * Populate the given ISOAPMessage's header using the inputs from WSE
   * 
   * @param soapEnvelopeNamespaceTable Hashtable containing a map of the namespace URIs to prefixes.
   * @param operElement WSDLOperationElement encapsulating the WSDL operation.
   * @param soapMessage The ISOAPMessage to populate 
   */
  protected void setHeaderContent(Hashtable soapEnvelopeNamespaceTable, WSDLOperationElement operElement, ISOAPMessage soapMessage)
    throws ParserConfigurationException {
    SOAPMessageUtils.setHeaderContentFromModel(soapEnvelopeNamespaceTable, operElement, soapMessage);
    boolean isUseLiteral = operElement.isUseLiteral();
    String encodingStyle = operElement.getEncodingStyle();
    boolean addEncodingStyle = (!isUseLiteral && !Constants.URI_SOAP11_ENC.equals(encodingStyle));
    Iterator it = operElement.getOrderedBodyParts().iterator();
    while (it.hasNext())
    {
      Part part = (Part)it.next();
      IXSDFragment frag = (IXSDFragment)operElement.getFragment(part);
      Element[] instanceDocuments = frag.genInstanceDocumentsFromParameterValues(!isUseLiteral,soapEnvelopeNamespaceTable, XMLUtils.createNewDocument(null));
      for (int j=0;j<instanceDocuments.length;j++)
      {
        if (instanceDocuments[j] == null)
          continue;
        if (addEncodingStyle)
          instanceDocuments[j].setAttribute("soapenv:encodingStyle",encodingStyle);
        bodyEntries.addElement(instanceDocuments[j]);
      }
    }

    if (!operElement.isDocumentStyle())
    {
      try
      {
        addRPCWrapper(bodyEntries,(WSDLElement)serviceElement.getParentElement(),operElement,soapEnvelopeNamespaceTable);
      }
      catch (ParserConfigurationException e)
      {
        throw e;
      }
    }
    return bodyEntries;
  }

  protected Element getSOAPEnvelope(Hashtable soapEnvelopeNamespaceTable, Vector bodyEntries) throws ParserConfigurationException
  {
	return getSOAPEnvelope(soapEnvelopeNamespaceTable, null, bodyEntries);
  }
  
  protected Element getSOAPEnvelope(Hashtable soapEnvelopeNamespaceTable, Vector headerEntries, Vector bodyEntries) throws ParserConfigurationException
  {
    DocumentBuilder docBuilder = DocumentBuilderFactory.newInstance().newDocumentBuilder();
    Document doc = XMLUtils.createNewDocument(docBuilder);
    Element soapEnvelopeElement = SoapHelper.createSoapEnvelopeElement(doc,soapEnvelopeNamespaceTable);
    
    if (headerEntries != null && !headerEntries.isEmpty()) {
    	Element soapHeaderElement = SoapHelper.createSoapHeaderElement(doc);
        for (int i=0;i<headerEntries.size();i++)
          soapHeaderElement.appendChild(doc.importNode((Element)headerEntries.elementAt(i),true));
        soapEnvelopeElement.appendChild(soapHeaderElement);        
    }
    
    Element soapBodyElement = SoapHelper.createSoapBodyElement(doc);
    for (int i=0;i<bodyEntries.size();i++)
      soapBodyElement.appendChild(doc.importNode((Element)bodyEntries.elementAt(i),true));
    soapEnvelopeElement.appendChild(soapBodyElement);
    return soapEnvelopeElement;
  }

  private final void recordSoapRequest(SOAPMessageQueue soapRequestQueue,Hashtable soapEnvelopeNamespaceTable,Element soapEnvelope) throws ParserConfigurationException,IOException
  {
    soapRequestQueue.clear();
    soapRequestQueue.addMessage(XMLUtils.serialize(soapEnvelope,false));
  }

  /**
   * Populate the given ISOAPMessage's body using the inputs from WSE
   * 
   * @param soapEnvelopeNamespaceTable Hashtable containing a map of the namespace URIs to prefixes.
   * @param operElement WSDLOperationElement encapsulating the WSDL operation.
   * @param soapMessage The ISOAPMessage to populate 
   */  
  protected void setBodyContent(Hashtable soapEnvelopeNamespaceTable, WSDLOperationElement operElement, ISOAPMessage soapMessage) 
    throws ParserConfigurationException {
	SOAPMessageUtils.setBodyContentFromModel(soapEnvelopeNamespaceTable, operElement, soapMessage);
  }        

  public boolean run()
  {

    MessageQueue messageQueue = wsdlPerspective.getMessageQueue();
    WSDLOperationElement operElement = (WSDLOperationElement)getSelectedNavigatorNode().getTreeElement();
    WSDLBindingElement bindingElement = (WSDLBindingElement)operElement.getParentElement();
    WSDLServiceElement serviceElement = (WSDLServiceElement)bindingElement.getParentElement();
    operElement.setPropertyAsObject(WSDLActionInputs.SOAP_RESPONSE_CACHED, new Boolean(false));
    try
    {

      //    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      //    xmlns:xsd="http://www.w3.org/2001/XMLSchema">
      // ...
      Hashtable soapEnvelopeNamespaceTable = new Hashtable();
      SoapHelper.addDefaultSoapEnvelopeNamespaces(soapEnvelopeNamespaceTable);
      Vector headerEntries = getHeaderEntries(soapEnvelopeNamespaceTable, operElement);
      Vector bodyEntries = getBodyEntries(soapEnvelopeNamespaceTable,operElement,bindingElement,serviceElement);
      Element soapEnvelope = getSOAPEnvelope(soapEnvelopeNamespaceTable, headerEntries, bodyEntries);
      recordSoapRequest(wsdlPerspective.getSOAPRequestQueue(),soapEnvelopeNamespaceTable,soapEnvelope);

	  ISOAPMessage soapMessage = getSOAPRequestMessage(operElement);
	  if (soapMessage == null)
		  throw new TransportException(wsdlPerspective.getMessage("MSG_ERROR_NO_SUITABLE_TRANSPORT"));
	  
	  Hashtable namespaceTable = new Hashtable(soapMessage.getNamespaceTable());	  
	  setHeaderContent(namespaceTable, operElement, soapMessage);
	  setBodyContent(namespaceTable, operElement, soapMessage);      
	  soapMessage.setNamespaceTable(namespaceTable);

	  // store the request
	  operElement.setPropertyAsObject(WSDLModelConstants.PROP_SOAP_REQUEST, soapMessage);  
	  
	  // Execute the SOAP operation.
      if (soapAddressLocation != null)
      {    	
    	soapMessage.setProperty(ISOAPMessage.PROP_SOAP_ACTION, operElement.getSoapAction());
    	String[] authParams = retrieveAuthParams(bindingElement, soapAddressLocation);
    	
    	// invoke!
    	ISOAPMessage soapResponse = operElement.getSOAPTransportProvider().newTransport()
    		.send(soapAddressLocation, authParams[0], authParams[1], soapMessage);
    	
    	// store the response
    	operElement.setPropertyAsObject(WSDLModelConstants.PROP_SOAP_RESPONSE, soapResponse);
    	
        wsdlPerspective.setOperationNode(getSelectedNavigatorNode());
        return true;
      }
      throw new IOException(wsdlPerspective.getMessage("MSG_ERROR_UNABLE_TO_CONNECT",soapAddressLocation));
    }
    catch (HTTPTransportException e) {
      throwHTTPTransportException(bindingElement, soapAddressLocation, e);
      handleUnexpectedException(wsdlPerspective,messageQueue,"ParserConfigurationException",e);
    }
    catch (IOException e)
    {
      handleUnexpectedException(wsdlPerspective,messageQueue,"IOException",e);
    }
    catch (Exception e) {
      Throwable t = e;
      if (e instanceof TransportException && e.getCause() != null)
    	t = e.getCause();
      handleUnexpectedException(wsdlPerspective, messageQueue, t.getClass().getSimpleName(), t);
    {
      handleUnexpectedException(wsdlPerspective,messageQueue,"Exception",e);
    }
    return false;
  }
  
  private void throwHTTPTransportException(WSDLBindingElement bindingElement, String endpointString, HTTPTransportException httpTransportException) throws HTTPTransportException
  {
    if (httpTransportException.getStatusCode() == HttpServletResponse.SC_UNAUTHORIZED)
    {
      Endpoint endpoint = bindingElement.getEndpoint(endpointString);
      if (endpoint != null)

        endpoint.setHttpBasicAuthPassword(null);
      }
    }
    throw httpTransportException;
  }
  
  private String[] retrieveAuthParams(WSDLBindingElement bindingElement, String endpointString)
  {
	String[] authParams = new String[] { null, null };
    Endpoint endpoint = bindingElement.getEndpoint(endpointString);
    if (endpoint != null)
    {

        }
        if (httpBasicAuthUsername != null && httpBasicAuthPassword != null)
        {
          authParams[0] = httpBasicAuthUsername;
          authParams[1] = httpBasicAuthPassword;
        }
      }
    }
    return authParams;
  }
}

Lines 2-7 Link Here

(-)plugin.xml (-1 / +10 lines)
2	<?eclipse version="3.0"?>	2	<?eclipse version="3.0"?>
3		3
4	<plugin>	4	<plugin>
		5	<extension-point id="wseTransportProvider" name="%XP_WSE_TRANSPORT_PROVIDER" schema="schema/wseTransportProvider.exsd"/>
5		6
6		7
7	<!-- ================================================================= -->	8	<!-- ================================================================= -->
Lines 43-47 Link Here
43	</action>	44	</action>
44	</objectContribution>	45	</objectContribution>
45	</extension>	46	</extension>
46		47	<extension
		48	point="org.eclipse.wst.ws.explorer.wseTransportProvider">
		49	<soapTransportProvider
		50	class="org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport.SOAPTransportProvider"
		51	id="org.eclipse.wst.ws.explorer.soapTransportProvider"
		52	name="%SOAP_TRANSPORT_PROVIDER"
		53	namespaceURI="http://schemas.xmlsoap.org/wsdl/soap/"
		54	transportURI="http://schemas.xmlsoap.org/soap/http"/>
		55	</extension>
47	</plugin>	56	</plugin>

Lines 22-28 Link Here

(-)build.properties (-1 / +2 lines)
22	wsexplorer.war,\	22	wsexplorer.war,\
23	META-INF/,\	23	META-INF/,\
24	about.html,\	24	about.html,\
25	wsexplorer-properties.jar	25	wsexplorer-properties.jar,\
		26	schema/
26		27
27		28
28	custom = false	29	custom = false

Lines 1-12 Link Here

(-)plugin.properties (-2 / +13 lines)
1	###############################################################################	1	###############################################################################
2	# Copyright (c) 2001, 2005 IBM Corporation and others.	2	# Copyright (c) 2001, 2007 IBM Corporation and others.
3	# All rights reserved. This program and the accompanying materials	3	# All rights reserved. This program and the accompanying materials
4	# are made available under the terms of the Eclipse Public License v1.0	4	# are made available under the terms of the Eclipse Public License v1.0
5	# which accompanies this distribution, and is available at	5	# which accompanies this distribution, and is available at
6	# http://www.eclipse.org/legal/epl-v10.html	6	# http://www.eclipse.org/legal/epl-v10.html
7	#	7	#
8	# Contributors:	8	# Contributors:
9	# IBM Corporation - initial API and implementation	9	# IBM Corporation - initial API and implementation
		10	# yyyymmdd bug Email and other contact information
		11	# -------- -------- -----------------------------------------------------------
		12	# 20070413 176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
10	###############################################################################	13	###############################################################################
11		14
12	#	15	#
Lines 15-20 Link Here
15	PLUGIN_NAME=Web Services Explorer	18	PLUGIN_NAME=Web Services Explorer
16	PLUGIN_PROVIDER=Eclipse.org	19	PLUGIN_PROVIDER=Eclipse.org
17		20
		21	XP_WSE_TRANSPORT_PROVIDER=Web Services Explorer Transport Provider
		22	SOAP_TRANSPORT_PROVIDER=Default SOAP Transport Provider
		23
18	#	24	#
19	# Messages for the client type extension	25	# Messages for the client type extension
20	#	26	#
Lines 33-35 Link Here
33	#	39	#
34	POPUP_TEST_WSDL=Test with Web Services Explorer	40	POPUP_TEST_WSDL=Test with Web Services Explorer
35		41
		42	#
		43	# SOAP transport messages
		44	#
		45	MSG_ERROR_UNSUPPORTED_BINDING={0} binding is unsupported.
		46	MSG_ERROR_UNSUPPORTED_TRANSPORT={0} transport is unsupported.




/*******************************************************************************
 * Copyright (c) 2001, 2005 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 *     IBM Corporation - initial API and implementation
 *******************************************************************************/

package org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport;

import java.io.FilterInputStream;
import java.io.IOException;
import java.io.InputStream;

public class ChunkedInputStream extends FilterInputStream
{
  protected long chunkSize = 0l;
  protected volatile boolean closed = false;
  private static final int maxCharLong = (Long.toHexString(Long.MAX_VALUE)).toString().length();

  private ChunkedInputStream()
  {
    super(null);
  }

  public ChunkedInputStream(InputStream is)
  {
    super(is);
  }

  public int read() throws IOException
  {
    byte[] d = new byte[1];
    int rc = read(d, 0, 1);
    return rc > 0 ? (d[0] & 0xFF) : rc;
  }

  public int read(byte[] b) throws IOException
  {
    return read(b, 0, b.length);
  }

  public synchronized int read(byte[] b, int off, int len) throws IOException
  {
    if (closed)
      return -1;

    int totalread = 0;
    int bytesread = 0;
    try
    {
      do
      {
        if (chunkSize < 1L)
        {
          if (0l == getChunked())
          {
            if (totalread == 0)
              return -1;
            else
              return totalread;
          }
        }
        bytesread = in.read(b, off + totalread, Math.min(len - totalread, (int) Math.min(chunkSize, Integer.MAX_VALUE)));
        if (bytesread > 0)
        {
          totalread += bytesread;
          chunkSize -= bytesread;
        }
      }
      while (len - totalread > 0 && bytesread > -1);
    }
    catch (IOException e)
    {
      closed = true;
      throw e;
    }
    return totalread;
  }

  public long skip(final long n) throws IOException
  {
    if (closed)
      return 0;
    long skipped = 0l;
    byte[] b = new byte[1024];
    int bread = -1;
    do
    {
      bread = read(b, 0, b.length);
      if (bread > 0)
        skipped += bread;
    }
    while (bread != -1 && skipped < n);
    return skipped;
  }

  public int available() throws IOException
  {
    if (closed)
      return 0;
    int rc = (int) Math.min(chunkSize, Integer.MAX_VALUE);
    return Math.min(rc, in.available());
  }

  protected long getChunked() throws IOException
  {
    //StringBuffer buf= new StringBuffer(1024);
    byte[] buf = new byte[maxCharLong + 2];
    int bufsz = 0;
    chunkSize = -1L;
    int c = -1;
    do
    {
      c = in.read();
      if (c > -1)
      {
        if (c != '\r' && c != '\n' && c != ' ' && c != '\t')
        {
          buf[bufsz++] = ((byte) c);
        }
      }
    }
    while (c > -1 && (c != '\n' || bufsz == 0) && bufsz < buf.length);
    if (c < 0)
    {
      closed = true;
    }
    String sbuf = new String(buf, 0, bufsz);
    if (bufsz > maxCharLong)
    {
      closed = true;
      throw new IOException("Chunked input stream failed to receive valid chunk size:" + sbuf);
    }
    try
    {
      chunkSize = Long.parseLong(sbuf, 16);
    }
    catch (NumberFormatException ne)
    {
      closed = true;
      throw new IOException("'" + sbuf + "' " + ne.getMessage());
    }
    if (chunkSize < 1L)
      closed = true;
    if (chunkSize != 0L && c < 0)
    {
      //If chunk size is zero try and be tolerant that there maybe no cr or lf
      // at the end.
      throw new IOException("HTTP Chunked stream closed in middle of chunk.");
    }
    if (chunkSize < 0L)
      throw new IOException("HTTP Chunk size received " + chunkSize + " is less than zero.");
    return chunkSize;
  }

  public void close() throws IOException
  {
    synchronized (this)
    {
      if (closed)
        return;
      closed = true;
    }
    byte[] b = new byte[1024];
    int bread = -1;
    do
    {
      bread = read(b, 0, b.length);
    }
    while (bread != -1);
  }

  /*
   * public void mark(int readlimit)
   * {
   * }
   */

  public void reset() throws IOException
  {
    throw new IOException("Don't support marked streams");
  }

  public boolean markSupported()
  {
    return false;
  }
}




/*******************************************************************************
 * Copyright (c) 2004, 2005 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 *     IBM Corporation - initial API and implementation
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport;

import java.util.Map;

public class HTTPException extends RuntimeException
{
  /**
	 * Comment for <code>serialVersionUID</code>
	 */
	private static final long serialVersionUID = 3256438105900134961L;
private int statusCode;
  private String statusMessage;
  private Map headers;
  
  public HTTPException(int statusCode, String statusMessage, Map headers)
  {
    super(statusMessage);
    this.statusCode = statusCode;
    this.statusMessage = statusMessage;
    this.headers = headers;
  }
  
  public int getStatusCode()
  {
    return statusCode;
  }
  
  public String getStatusMessage()
  {
    return statusMessage;
  }
  
  public Map getHeaders()
  {
    return headers;
  }
  
  public String getHeader(String key)
  {
    Object value = headers.get(key);
    if (value != null)
      return value.toString();
    else
      return null;
  }
}




/*******************************************************************************
 * Copyright (c) 2004, 2006 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 * 
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20060131   125777 jesper@selskabet.org - Jesper S Moller
 * 20060222   118019 andyzhai@ca.ibm.com - Andy Zhai
 * 20060222   128564 jesper@selskabet.org - Jesper S Moller
 * 20060823    99034 makandre@ca.ibm.com - Andrew Mak, WSE support for basic-authenticating firewalls
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport;

import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;
import java.net.SocketTimeoutException;
import java.net.URL;
import java.net.UnknownHostException;
import java.util.Hashtable;
import javax.net.ssl.SSLSocketFactory;
import org.eclipse.wst.ws.internal.explorer.platform.util.XMLUtils;
import org.w3c.dom.Element;
import sun.misc.BASE64Encoder;

public class HTTPTransport
{
  private final String SYS_PROP_HTTPS_PROXY_HOST = "https.proxyHost";
  private final String SYS_PROP_HTTPS_PROXY_PORT = "https.proxyPort";
  private final String SYS_PROP_HTTPS_NON_PROXY_HOSTS = "https.nonProxyHosts";
  private final String SYS_PROP_HTTP_PROXY_HOST = "http.proxyHost";
  private final String SYS_PROP_HTTP_PROXY_PORT = "http.proxyPort";
  private final String SYS_PROP_HTTP_PROXY_USER_NAME = "http.proxyUserName";
  private final String SYS_PROP_HTTP_PROXY_PASSWORD = "http.proxyPassword";
  private final String SYS_PROP_HTTP_NON_PROXY_HOSTS = "http.nonProxyHosts";
  
  private final String HTTP_METHOD = "POST";
  private final String HTTP_CONNECT = "CONNECT";
  private final String HTTP_VERSION_1_0 = "HTTP/1.0";
  private final String HTTP_VERSION = "HTTP/1.1";
  private final String HTTP_HEADER_SOAP_ACTION = "SOAPAction";
  public static final String HTTP_HEADER_AUTH = "Authorization";
  public static final String HTTP_HEADER_WWW_AUTH = "WWW-Authenticate";
  private final String HTTP_HEADER_PROXY_AUTH = "Proxy-authorization";
  private final String HTTP_HEADER_COOKIE = "Cookie";
  private final String HTTP_HEADER_COOKIE2 = "Cookie2";
  private final String HTTP_HEADER_HOST = "Host";
  private final String HTTP_HEADER_CONTENT_TYPE = "Content-Type";
  public static final String HTTP_HEADER_CONTENT_LENGTH = "Content-Length";
  private final String HTTP_HEADER_ACCEPT = "Accept";
  private final String HTTP_HEADER_USER_AGENT = "User-Agent";
  private final String HTTP_HEADER_CACHE_CONTROL = "Cache-Control";
  private final String HTTP_HEADER_PRAGMA = "Pragma";
  private final String HTTP_HEADER_TRANSFER_ENCODEING = "Transfer-Encoding";
  private final String HTTP_HEADER_CONNECTION = "Connection";
  
  private final int HTTP_CODE_CONTINUE = 100;
  private final int HTTP_CODE_OK = 200;
  private final int HTTP_CODE_EXCEPTION = 300;

  private final String IBM_WEB_SERVICES_EXPLORER = "IBM Web Services Explorer";
  private final String TEXT_XML = "text/xml";
  private final String CONTENT_TYPE_VALUE = "text/xml; charset=utf-8";
  private final String ACCEPT_VALUE = "application/soap+xml, application/dime, multipart/related, text/*";
  public static final String BASIC = "Basic";
  private final String NO_CACHE = "no-cache";
  private final String CHUNKED = "chunked";
  private final String CLOSE = "close";
  private final String HTTPS = "https";
  private final char QUOTE = '\"';
  public static final char COLON = ':';
  private final char SPACE = ' ';
  private final char TAB = '\t';
  private final char R = '\r';
  private final char N = '\n';
  private final char ROOT = '/';
  private final String NEW_LINE = "\r\n";
  private final String EMPTY_STRING = "";

  private final int DEFAULT_HTTP_PORT = 80;
  private final int DEFAULT_HTTPS_PORT = 443;
  private final String DEFAULT_SOAP_ENCODING = "UTF-8";
  private final String DEFAULT_HTTP_HEADER_ENCODING = "iso-8859-1";
  private final boolean DEFAULT_CASE_SENSITIVE_FOR_HOST_NAME = false;

  private String httpBasicAuthUsername;
  private String httpBasicAuthPassword;
  private boolean maintainSession = false;
  private String cookie;
  private String cookie2;
  private HTTPResponse httpResponse;

  public String getHttpBasicAuthUsername()
  {
    return httpBasicAuthUsername;
  }
  
  public void setHttpBasicAuthUsername(String httpBasicAuthUsername)
  {
    this.httpBasicAuthUsername = httpBasicAuthUsername;
  }
  
  public String getHttpBasicAuthPassword()
  {
    return httpBasicAuthPassword;
  }
  
  public void setHttpBasicAuthPassword(String httpBasicAuthPassword)
  {
    this.httpBasicAuthPassword = httpBasicAuthPassword;
  }

  private String getMethod(URL url)
  {
    StringBuffer sb = new StringBuffer(HTTP_METHOD);
    sb.append(SPACE);
    String protocol = url.getProtocol();
    String httpProxyHost = System.getProperty(SYS_PROP_HTTP_PROXY_HOST);
    String httpsProxyHost = System.getProperty(SYS_PROP_HTTPS_PROXY_HOST);
    if (protocol.equalsIgnoreCase("http") && httpProxyHost != null && httpProxyHost.length() > 0)
    {
      sb.append(url.toString());
    }
    else if (protocol.equalsIgnoreCase("https") && httpsProxyHost != null && httpsProxyHost.length() > 0)
    {
      sb.append(url.toString());
    }
    else
    {
      String file = url.getFile();
      if (file != null && file.length() > 0)
        sb.append(file);
      else
        sb.append(ROOT);
    }
    sb.append(SPACE);
    sb.append(HTTP_VERSION);
    sb.append(NEW_LINE);
    return sb.toString();
  }

  private String getHost(URL url)
  {
    StringBuffer sb = new StringBuffer(HTTP_HEADER_HOST);
    sb.append(COLON);
    sb.append(SPACE);
    sb.append(url.getHost());
    sb.append(COLON);
    int port = url.getPort();
    if (port > 0)
      sb.append(String.valueOf(port));
    else if (url.getProtocol().equalsIgnoreCase(HTTPS))
      sb.append(DEFAULT_HTTPS_PORT);
    else
      sb.append(DEFAULT_HTTP_PORT);
    sb.append(NEW_LINE);
    return sb.toString();
  }
  
  private String getContentType()
  {
    return getHTTPHeader(HTTP_HEADER_CONTENT_TYPE, CONTENT_TYPE_VALUE);
  }
  
  private String getContentLength(byte[] payloadAsBytes)
  {
    return getHTTPHeader(HTTP_HEADER_CONTENT_LENGTH, String.valueOf(payloadAsBytes.length));
  }

  private String getSOAPAction(String soapAction)
  {
    StringBuffer sb = new StringBuffer(HTTP_HEADER_SOAP_ACTION);
    sb.append(COLON);
    sb.append(SPACE);
    sb.append(QUOTE);
    if (soapAction != null)
      sb.append(soapAction);
    sb.append(QUOTE);
    sb.append(NEW_LINE);
    return sb.toString();
  }
  
  private String getCookie()
  {
    if (maintainSession)
      return getHTTPHeader(HTTP_HEADER_COOKIE, cookie);
    else
      return EMPTY_STRING;
  }
  
  private String getCookie2()
  {
    if (maintainSession)
      return getHTTPHeader(HTTP_HEADER_COOKIE2, cookie2);
    else
      return EMPTY_STRING;
  }
  
  private String getWWWAuthentication()
  {
    if (httpBasicAuthUsername != null && httpBasicAuthPassword != null)
    {
      StringBuffer sb = new StringBuffer(httpBasicAuthUsername);
      sb.append(COLON);
      sb.append(httpBasicAuthPassword);
      BASE64Encoder encoder = new BASE64Encoder();
      String encodedUserNamePassword = encoder.encode(sb.toString().getBytes());
      sb.setLength(0);
      sb.append(HTTP_HEADER_AUTH);
      sb.append(COLON);
      sb.append(SPACE);
      sb.append(BASIC);
      sb.append(SPACE);
      sb.append(encodedUserNamePassword);
      sb.append(NEW_LINE);
      return sb.toString();
    }
    else
      return EMPTY_STRING;
  }
  
  private String getProxyAuthentication()
  {
    String proxyUserName = System.getProperty(SYS_PROP_HTTP_PROXY_USER_NAME);
    String proxyPassword = System.getProperty(SYS_PROP_HTTP_PROXY_PASSWORD);
    if (proxyUserName != null && proxyPassword != null)
    {
      StringBuffer sb = new StringBuffer(proxyUserName);
      sb.append(COLON);
      sb.append(proxyPassword);
      BASE64Encoder encoder = new BASE64Encoder();
      String encodedUserNamePassword = encoder.encode(sb.toString().getBytes());
      sb.setLength(0);
      sb.append(HTTP_HEADER_PROXY_AUTH);
      sb.append(COLON);
      sb.append(SPACE);
      sb.append(BASIC);
      sb.append(SPACE);
      sb.append(encodedUserNamePassword);
      sb.append(NEW_LINE);
      return sb.toString();
    }
    else
      return EMPTY_STRING;
  }
  
  private String getAccept()
  {
    return getHTTPHeader(HTTP_HEADER_ACCEPT, ACCEPT_VALUE);
  }
  
  private String getUserAgent()
  {
    return getHTTPHeader(HTTP_HEADER_USER_AGENT, IBM_WEB_SERVICES_EXPLORER);
  }
  
  private String getCacheControl()
  {
    return getHTTPHeader(HTTP_HEADER_CACHE_CONTROL, NO_CACHE);
  }
  
  private String getPragma()
  {
    return getHTTPHeader(HTTP_HEADER_PRAGMA, NO_CACHE);
  }
  
  private String getConnection()
  {
    return getHTTPHeader(HTTP_HEADER_CONNECTION, CLOSE);
  }
  
  private String getHTTPHeader(String key, String value)
  {
    if (value != null)
    {
      StringBuffer sb = new StringBuffer(key);
      sb.append(COLON);
      sb.append(SPACE);
      sb.append(value);
      sb.append(NEW_LINE);
      return sb.toString();
    }
    else
      return EMPTY_STRING;
  }

  public void send(URL url, String soapAction, String payload) throws UnknownHostException, IOException
  {
    byte[] payloadAsUTF8 = payload.getBytes(DEFAULT_SOAP_ENCODING);
       
    StringBuffer httpHeader = new StringBuffer();
    httpHeader.append(getMethod(url));
    httpHeader.append(getHost(url));
    httpHeader.append(getContentType());
    httpHeader.append(getContentLength(payloadAsUTF8));
    httpHeader.append(getAccept());
    httpHeader.append(getUserAgent());
    httpHeader.append(getCacheControl());
    httpHeader.append(getPragma());
    httpHeader.append(getSOAPAction(soapAction));
    httpHeader.append(getWWWAuthentication());
    httpHeader.append(getProxyAuthentication());
    httpHeader.append(getCookie());
    httpHeader.append(getCookie2());
    httpHeader.append(getConnection());
    httpHeader.append(NEW_LINE); // new line between the HTTP header and the payload
    Socket socket = buildSocket(url);
    InputStream is = socket.getInputStream();
    OutputStream os = socket.getOutputStream();
    os.write(httpHeader.toString().getBytes(DEFAULT_HTTP_HEADER_ENCODING));
    os.write(payloadAsUTF8);
    os.flush();
    httpResponse = new HTTPResponse();
    readHTTPResponseHeader(is, httpResponse);
    int code = httpResponse.getStatusCode();
    if (code == HTTP_CODE_CONTINUE)
    {
      httpResponse.reset();
      readHTTPResponseHeader(is, httpResponse);
    }
    readHTTPResponsePayload(is, httpResponse);
    os.close();
    is.close();
    socket.close();
    code = httpResponse.getStatusCode();
    String contentType = httpResponse.getHeader(HTTP_HEADER_CONTENT_TYPE.toLowerCase());
    if (code >= HTTP_CODE_EXCEPTION && (contentType == null || contentType.toLowerCase().indexOf(TEXT_XML.toLowerCase()) == -1))
      throw new HTTPException(code, httpResponse.getStatusMessage(), httpResponse.getHeaders());
  }

  private void readHTTPResponseHeader(InputStream is, HTTPResponse resp) throws IOException
  {
    byte b = 0;
    int len = 0;
    int colonIndex = -1;
    String key;
    String value;
    boolean readTooMuch = false;
    ByteArrayOutputStream baos;
    for (baos = new ByteArrayOutputStream(4096);;)
    {
      if (!readTooMuch)
        b = (byte)is.read();
      if (b == -1)
        break;
      readTooMuch = false;
      if ((b != R) && (b != N))
      {
        if ((b == COLON) && (colonIndex == -1))
          colonIndex = len;
        len++;
        baos.write(b);
      }
      else if (b == R)
        continue;
      else // b == N
      {
        if (len == 0)
          break;
        b = (byte)is.read();
        readTooMuch = true;
        // A space or tab at the begining of a line means the header continues.
        if ((b == SPACE) || (b == TAB))
          continue;
        baos.close();
        byte[] bArray = baos.toByteArray();
        baos.reset();
        if (colonIndex != -1)
        {
          key = new String(bArray, 0, colonIndex, DEFAULT_HTTP_HEADER_ENCODING);
          value = new String(bArray, colonIndex + 1, len - 1 - colonIndex, DEFAULT_HTTP_HEADER_ENCODING);
          colonIndex = -1;
        }
        else
        {
          key = new String(bArray, 0, len, DEFAULT_HTTP_HEADER_ENCODING);
          value = EMPTY_STRING;
        }
        if (!resp.isStatusSet())
        {
          // Reader status code
          int start = key.indexOf(SPACE) + 1;
          String s = key.substring(start).trim();
          int end = s.indexOf(SPACE);
          if (end != -1)
            s = s.substring(0, end);
          try
          {
            resp.setStatusCode(Integer.parseInt(s));
          }
          catch (NumberFormatException nfe)
          {
            resp.setStatusCode(-1);
          }
          resp.setStatusMessage(key.substring(start + end + 1));
        }
        else
          resp.addHeader(key.toLowerCase().trim(), value.trim());
        len = 0;
      }
    }
    baos.close();
  }

  private void readHTTPResponsePayload(InputStream is, HTTPResponse resp) throws IOException
  {
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    try
    {
      byte b = (byte)is.read();
      while (b != -1)
      {
        baos.write(b);
        b = (byte)is.read();
      }
    }
    catch (SocketTimeoutException ste)
    {
    }
    baos.close();
    resp.setPayload(baos.toByteArray());
  }

  public BufferedReader receive()
  {
    if (httpResponse != null)
    {
      try
      {
        byte[] payload = httpResponse.getPayload();
        Element soapEnvelope = null;
        if (CHUNKED.equalsIgnoreCase(httpResponse.getHeader(HTTP_HEADER_TRANSFER_ENCODEING.toLowerCase())))
        {
          ByteArrayInputStream bais = new ByteArrayInputStream(payload);
          ChunkedInputStream cis = new ChunkedInputStream(bais);
          ByteArrayOutputStream baos = new ByteArrayOutputStream();
          byte b;
          while ((b = (byte)cis.read()) != -1)
            baos.write(b);
          baos.close();
          cis.close();
          bais.close();
          soapEnvelope = XMLUtils.byteArrayToElement(baos.toByteArray(), false);
        }
        else
        {
          soapEnvelope = XMLUtils.byteArrayToElement(payload, false);
        }
        // remove XML namespace declaration
        if (soapEnvelope != null)
          return new BufferedReader(new InputStreamReader(new ByteArrayInputStream(XMLUtils.serialize(soapEnvelope, true).getBytes(DEFAULT_SOAP_ENCODING)), DEFAULT_SOAP_ENCODING));
      }
      catch (Throwable t)
      {
      }
    }
    return null;
  }

  public Hashtable getHeaders()
  {
    Hashtable headers = new Hashtable();
    if (httpResponse != null)
      headers.putAll(httpResponse.getHeaders());
    return headers;
  }

  /**
   * Builds the first line of a connection request to the proxy server
   * 
   * @param url The URL that we want to ultimately connect to.
   * @return A string of the form "CONNECT &lt;hostname&gt;:&lt;port&gt; HTTP/1.0".
   */
  private StringBuffer getConnectMethod(URL url) {
	
	  StringBuffer sb = new StringBuffer(HTTP_CONNECT);
	  sb.append(SPACE);	  
	  sb.append(url.getHost());
	  sb.append(COLON);
	  sb.append(url.getPort());
	  sb.append(SPACE);
	  sb.append(HTTP_VERSION_1_0);
	  sb.append(NEW_LINE);
	  return sb;
  }
  
  /**
   * Construct a socket to the proxy server which be used to tunnel through.
   * 
   * @param url The URL that we want to ultimately connect to.
   * @param proxyHost The proxy host.
   * @param proxyPort The proxy port.
   * @return A connected socket to the proxy server. 
   * @throws IOException 
   */
  private Socket buildTunnelSocket(URL url, String proxyHost, int proxyPort) throws IOException {

	  StringBuffer httpHeader = new StringBuffer();
	  httpHeader.append(getConnectMethod(url));
	  httpHeader.append(getProxyAuthentication());       
	  httpHeader.append(NEW_LINE);
    
	  Socket tunnel = new Socket(proxyHost, proxyPort);
    
	  InputStream  is = tunnel.getInputStream();
	  OutputStream os = tunnel.getOutputStream();
    
	  os.write(httpHeader.toString().getBytes(DEFAULT_HTTP_HEADER_ENCODING));        
	  os.flush();
    
	  HTTPResponse httpResponse = new HTTPResponse();
	  readHTTPResponseHeader(is, httpResponse);
    
	  int code = httpResponse.getStatusCode();

	  // ensure we are successfully connected to the proxy
	  if (code != HTTP_CODE_OK)
		  throw new HTTPException(code, httpResponse.getStatusMessage(), httpResponse.getHeaders());
	  
	  return tunnel;
  }
  
  private Socket buildSocket(URL url) throws UnknownHostException, IOException
  {
    Socket s = null;
    String host = url.getHost();
    int port = url.getPort();
    String proxyHost = System.getProperty(SYS_PROP_HTTP_PROXY_HOST);
    int proxyPort = Integer.getInteger(SYS_PROP_HTTP_PROXY_PORT, DEFAULT_HTTP_PORT).intValue();
    
    String nonProxyHosts = System.getProperty(SYS_PROP_HTTP_NON_PROXY_HOSTS);

    //  String proxyUserName = System.getProperty(SYS_PROP_HTTP_PROXY_USER_NAME);
    //  String proxyPassword = System.getProperty(SYS_PROP_HTTP_PROXY_PASSWORD);
    if (url.getProtocol().equalsIgnoreCase(HTTPS))
    {
      proxyHost = System.getProperty(SYS_PROP_HTTPS_PROXY_HOST);
      proxyPort = Integer.getInteger(SYS_PROP_HTTPS_PROXY_PORT, DEFAULT_HTTPS_PORT).intValue();
      nonProxyHosts = System.getProperty(SYS_PROP_HTTPS_NON_PROXY_HOSTS);

      if (proxyHost != null && proxyHost.length() > 0 && !isHostInNonProxyHosts(host, nonProxyHosts, DEFAULT_CASE_SENSITIVE_FOR_HOST_NAME))
      {
        // SSL with proxy server
        Socket tunnel = buildTunnelSocket(url, proxyHost, proxyPort);       
        s = ((SSLSocketFactory) SSLSocketFactory.getDefault()).createSocket(tunnel, host, port, true);    	  
      }
      else
        s = SSLSocketFactory.getDefault().createSocket(host, (port > 0 ? port : DEFAULT_HTTPS_PORT));
      // Removing dependency on soap.jar
      //  s = SSLUtils.buildSSLSocket(host, (port > 0 ? port : DEFAULT_HTTPS_PORT), proxyHost, proxyPort);
      // TODO:
      // Build an SSL socket that supports proxyUser and proxyPassword,
      // as demonstrated in the following (original) line of code:
      //  s = SSLUtils.buildSSLSocket(host, (port > 0 ? port : DEFAULT_HTTPS_PORT), proxyHost, proxyPort, proxyUserName, proxyPassword);
    }
    else if (proxyHost != null && proxyHost.length() > 0 && !isHostInNonProxyHosts(host, nonProxyHosts, DEFAULT_CASE_SENSITIVE_FOR_HOST_NAME))
      s = new Socket(proxyHost, proxyPort);
    else
      s = new Socket(host, (port > 0 ? port : DEFAULT_HTTP_PORT));
    return s;
  }
  
  private boolean isHostInNonProxyHosts(String host, String nonProxyHosts, boolean caseSensitive)
  {
  	if (caseSensitive) return host.matches(createPatternFromString(nonProxyHosts));
  	else return host.toLowerCase().matches(createPatternFromString(nonProxyHosts.toLowerCase()));  
  }
  
  /*
   * This method is used to generate a valid regular expression for a 
   * normal java String used in the proxy mechanism. 
   * For example, the http.nonProxyHosts contains following String: 
   * "192.168.2.*|localhost|*.ibm.com" . It would be 
   * transformed into: "192\.168\.2\.\w*|localhost|\w*\.ibm\.com"
   * Thus, following host string would match above pattern:
   * 192.168.2.5 192.168.2. 192.168.2.666 192.168.2.w
   * localhost
   * torolab.ibm.com .ibm.com 123.ibm.com
   * 
   * Two transformations are done:
   * 1. replace all "." into "\." As in regular expression, '.' represents 
   *    any charater.  "\.' represents the real character '.'
   * 2. In order to get the real meaning of "*" used in property 
   *    http.nonProxyHosts, "\w*" is used to replace "*"
   *    "\w" represent a word character: [a-zA-Z_0-9]
   *    
   * Restriction:
   * The validity of address is not checked. 
   * (192.168.2.555 and 192.168.2.com are OK)
   * 
   * TODO check whether * occurs in address or hostname.
   * if it occuus in address representation, replace "*" with "\d*"
   * and check: value < 256 ?
   */
  private String createPatternFromString(String str) 
  {
    /* This is the same as following more understandable way:
	 * return str.replace(".", "\\.").replace("*", "\\w*");
	 * But, replace(CharSequence target, CharSequence replacement) can only be 
	 * supported after j2se 1.5, on the other hand, 
	 * replaceAll(String regex, String replacement) can be supported before 
	 * j2se 1.5.
	 */
    return str == null ? null : str.replaceAll("\\.", "\\.").replaceAll("\\*", "\\w*");
  }
}




/*******************************************************************************
 * Copyright (c) 2004, 2005 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 *     IBM Corporation - initial API and implementation
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport;

import java.util.Hashtable;
import java.util.Map;

public class HTTPResponse
{
  private boolean statusSet;
  private int statusCode;
  private String statusMessage;
  private Hashtable headers;
  private byte[] payload;

  public HTTPResponse()
  {
    reset();
  }

  public void reset()
  {
    statusSet = false;
    statusCode = -1;
    statusMessage = null;
    if (headers != null)
      headers.clear();
    else
      headers = new Hashtable();
    payload = new byte[0];
  }

  public boolean isStatusSet()
  {
    return statusSet;
  }

  public int getStatusCode()
  {
    return statusCode;
  }

  public void setStatusCode(int statusCode)
  {
    statusSet = true;
    this.statusCode = statusCode;
  }

  public String getStatusMessage()
  {
    return statusMessage;
  }

  public void setStatusMessage(String statusMessage)
  {
    this.statusMessage = statusMessage;
  }

  public void addHeader(String key, String value)
  {
    headers.put(key, value);
  }

  public String getHeader(String key)
  {
    return (String) headers.get(key);
  }

  public Map getHeaders()
  {
    return headers;
  }

  public byte[] getPayload()
  {
    return payload;
  }

  public void setPayload(byte[] payload)
  {
    this.payload = payload;
  }
}

Lines 6-12 Link Here

(-)wsexplorer-properties/wsdl.properties (-1 / +7 lines)
6	# http://www.eclipse.org/legal/epl-v10.html	6	# http://www.eclipse.org/legal/epl-v10.html
7	#	7	#
8	# Contributors:	8	# Contributors:
9	# IBM Corporation - initial API and implementation	9	# IBM Corporation - initial API and implementation
		10	# yyyymmdd bug Email and other contact information
		11	# -------- -------- -----------------------------------------------------------
		12	# 20070413 176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
10	###############################################################################	13	###############################################################################
11		14
12	title=WSDL	15	title=WSDL
Lines 160-162 Link Here
160	MSG_ERROR_MIN_OCCURS_VIOLATION=IWAB0391E Minimum occurance is reached.	163	MSG_ERROR_MIN_OCCURS_VIOLATION=IWAB0391E Minimum occurance is reached.
161	MSG_ERROR_CANNOT_MOVE_FIRST_ELEMENT_UP=IWAB0392E Selected element is already the first in the group.	164	MSG_ERROR_CANNOT_MOVE_FIRST_ELEMENT_UP=IWAB0392E Selected element is already the first in the group.
162	MSG_ERROR_CANNOT_MOVE_LAST_ELEMENT_DOWN=IWAB0393E Selected element is already the last in the group.	165	MSG_ERROR_CANNOT_MOVE_LAST_ELEMENT_DOWN=IWAB0393E Selected element is already the last in the group.
		166
		167	# SOAP transport messages
		168	MSG_ERROR_NO_SUITABLE_TRANSPORT=Failed to invoke operation, a suitable transport extension was not found.

Lines 79-85 Link Here

(-)wsexplorer/uddi/forms/authentication_table.jsp (-1 / +1 lines)
79	<td><input type="text" id="<%=tableContainerId+"_input_user_id"%>" name="<%=UDDIActionInputs.QUERY_INPUT_ADVANCED_USERID%>" value="<%=HTMLUtils.charactersToHTMLEntitiesStrict(username)%>" class="textenter"></td>	79	<td><input type="text" id="<%=tableContainerId+"_input_user_id"%>" name="<%=UDDIActionInputs.QUERY_INPUT_ADVANCED_USERID%>" value="<%=HTMLUtils.charactersToHTMLEntitiesStrict(username)%>" class="textenter"></td>
80	</tr>	80	</tr>
81	<tr>	81	<tr>
82	<td class="labels" height=30 valign="bottom"><label for="<%=tableContainerId+"_input_password"%>"><%=uddiPerspective.getMessage("FORM_LABEL_PASSWORD")%></td></label>	82	<td class="labels" height=30 valign="bottom"><label for="<%=tableContainerId+"_input_password"%>"><%=uddiPerspective.getMessage("FORM_LABEL_PASSWORD")%></label></td>
83	</tr>	83	</tr>
84	<tr>	84	<tr>
85	<td><input type="password" id="<%=tableContainerId+"_input_password"%>" name="<%=UDDIActionInputs.QUERY_INPUT_ADVANCED_PASSWORD%>" value="<%=HTMLUtils.charactersToHTMLEntitiesStrict(password)%>" class="textenter"></td>	85	<td><input type="password" id="<%=tableContainerId+"_input_password"%>" name="<%=UDDIActionInputs.QUERY_INPUT_ADVANCED_PASSWORD%>" value="<%=HTMLUtils.charactersToHTMLEntitiesStrict(password)%>" class="textenter"></td>

Lines 11-17 Link Here

(-)META-INF/MANIFEST.MF (-1 / +2 lines)
11	Export-Package: org.eclipse.wst.ws.internal.explorer;x-internal:=true,	11	Export-Package: org.eclipse.wst.ws.internal.explorer;x-internal:=true,
12	org.eclipse.wst.ws.internal.explorer.favorites;x-internal:=true,	12	org.eclipse.wst.ws.internal.explorer.favorites;x-internal:=true,
13	org.eclipse.wst.ws.internal.explorer.plugin;x-internal:=true,	13	org.eclipse.wst.ws.internal.explorer.plugin;x-internal:=true,
14	org.eclipse.wst.ws.internal.explorer.popup;x-internal:=true	14	org.eclipse.wst.ws.internal.explorer.popup;x-internal:=true,
		15	org.eclipse.wst.ws.internal.explorer.transport;x-internal:=true
15	Require-Bundle: org.eclipse.core.runtime;bundle-version="[3.2.0,4.0.0)",	16	Require-Bundle: org.eclipse.core.runtime;bundle-version="[3.2.0,4.0.0)",
16	org.eclipse.core.resources;bundle-version="[3.2.0,3.4.0)",	17	org.eclipse.core.resources;bundle-version="[3.2.0,3.4.0)",
17	org.eclipse.help.appserver;bundle-version="[3.1.100,3.2.0)",	18	org.eclipse.help.appserver;bundle-version="[3.1.100,3.2.0)",

Lines 74-79 Link Here

(-)wsexplorer/wsdl/forms/WSDLServiceDetailsForm.jsp (-1 lines)
74	<%	74	<%
75	}	75	}
76	%>	76	%>
77	</script>
78	</body>	77	</body>
79	</html>	78	</html>




 * 20060222   127443 jesper@selskabet.org - Jesper S Moller
 * 20060726   144824 mahutch@ca.ibm.com - Mark Hutchinson
 * 20070305   117034 makandre@ca.ibm.com - Andrew Mak, Web Services Explorer should support SOAP Headers
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
%>
<%@ page contentType="text/html; charset=UTF-8" import="org.eclipse.wst.ws.internal.explorer.platform.wsdl.perspective.*,

                                                        org.eclipse.wst.ws.internal.explorer.platform.wsdl.util.*,
                                                        org.eclipse.wst.ws.internal.explorer.platform.constants.*,
                                                        org.eclipse.wst.ws.internal.explorer.platform.util.*,
                                                        org.eclipse.wst.ws.internal.explorer.transport.*,
                                                        org.eclipse.wst.wsdl.binding.soap.SOAPHeader,
                                                        org.w3c.dom.*,
                                                        javax.wsdl.*,

<%
   WSDLPerspective wsdlPerspective = controller.getWSDLPerspective();
   WSDLOperationElement operElement = (WSDLOperationElement)(wsdlPerspective.getNodeManager().getSelectedNode().getTreeElement());
   ISOAPTransport soapTransport = operElement.getSOAPTransportProvider().newTransport();
   ISOAPMessage soapMessage = soapTransport.newMessage(operElement.getMessageContext());
   operElement.setPropertyAsObject(WSDLModelConstants.PROP_SOAP_REQUEST_TMP, soapMessage);
   
   Hashtable soapEnvelopeNamespaceTable = new Hashtable(soapMessage.getNamespaceTable());      
   StringBuffer sourceContentHeader = new StringBuffer();
   String cachedSourceContent = operElement.getPropertyAsString(WSDLModelConstants.PROP_SOURCE_CONTENT_HEADER);
   if (cachedSourceContent != null)   
     sourceContentHeader.append(cachedSourceContent);        
   else
   {
     while (it.hasNext())
     {
       SOAPHeader soapHeader = (SOAPHeader)it.next();
       IXSDFragment frag = operElement.getHeaderFragment(soapHeader);
       Element[] instanceDocuments = frag.genInstanceDocumentsFromParameterValues(!operElement.isUseLiteral(), soapEnvelopeNamespaceTable, XMLUtils.createNewDocument(null));
       for (int i = 0; i < instanceDocuments.length; i++)
       {
    	 String serializedFragment = XMLUtils.serialize(instanceDocuments[i], true);
		 if (serializedFragment == null)
		 {
			 // On Some JRE's (Sun java 5) elements with an attribute with the xsi
			 // prefix do not serialize properly because the namespace can not
			 // be found so the string returned comes back as null. To workaround
			 // this problem try adding in the namespace declaration attribute
			 // and retry the serialization (bug 144824)			 
			 instanceDocuments[i].setAttribute("xmlns:xsi","http://www.w3.org/2001/XMLSchema-instance");
			 serializedFragment = XMLUtils.serialize(instanceDocuments[i], true);
		 }
    	 
    	 sourceContentHeader.append(serializedFragment);
         sourceContentHeader.append(HTMLUtils.LINE_SEPARATOR);
       }     
     }
   }
   
   String cachedHeaderContent = operElement.getPropertyAsString(WSDLModelConstants.PROP_SOURCE_CONTENT_HEADER);
   String cachedBodyContent = operElement.getPropertyAsString(WSDLModelConstants.PROP_SOURCE_CONTENT);
   
   // if either header or body has been cached, need to ensure namespace table is updated
   // from the cached copy
   if (cachedHeaderContent != null || cachedBodyContent != null) {
	   if (SOAPMessageUtils.decodeNamespaceTable(soapEnvelopeNamespaceTable, operElement))
		   soapMessage.setNamespaceTable(soapEnvelopeNamespaceTable);
     {
       for (int i = 0; i < nsDeclarations.length; i++)
       {
         String[] prefix_ns = SoapHelper.decodeNamespaceDeclaration(nsDeclarations[i]);
         if (!soapEnvelopeNamespaceTable.contains(prefix_ns[1]))
           soapEnvelopeNamespaceTable.put(prefix_ns[1], prefix_ns[0]);
       }
     }
   }
	            
   String headerContent;
   String bodyContent;
   
   if (cachedHeaderContent != null)
       headerContent = cachedHeaderContent;
   else {
	   try {
	       SOAPMessageUtils.setHeaderContentFromModel(soapEnvelopeNamespaceTable, operElement, soapMessage);
	       
	       // ensure namespace table updated in message before serialize operation
	       soapMessage.setNamespaceTable(soapEnvelopeNamespaceTable);
	       headerContent = soapTransport.newSerializer().serialize(ISOAPMessage.HEADER_CONTENT, soapMessage);
	   }
	   catch (Exception e) {
		   headerContent = "";
	   }
			 instanceDocuments[i].setAttribute("xmlns:xsi","http://www.w3.org/2001/XMLSchema-instance");
			 serializedFragment = XMLUtils.serialize(instanceDocuments[i], true);
		 }
    	 
    	 sourceContent.append(serializedFragment);
         sourceContent.append(HTMLUtils.LINE_SEPARATOR);
       }     
     }
   }
   
   if (cachedBodyContent != null)
	   bodyContent = cachedBodyContent;
   else {
	   try {
	       SOAPMessageUtils.setBodyContentFromModel(soapEnvelopeNamespaceTable, operElement, soapMessage);
	       
	       // ensure namespace table updated in message before serialize operation
	       soapMessage.setNamespaceTable(soapEnvelopeNamespaceTable);
	       bodyContent = soapTransport.newSerializer().serialize(ISOAPMessage.BODY_CONTENT, soapMessage);
	   }
	   catch (Exception e) {
		   bodyContent = "";
	   }
   }      
   
   // cache the namespace table
   Enumeration enm = soapEnvelopeNamespaceTable.keys();
   while (enm.hasMoreElements())
   {

  <tr>
    <td height=30 valign="bottom" class="labels">
<%
	Element soapEnvelopeElement = soapMessage.getEnvelope(false);
    Element soapEnvelopeElement = SoapHelper.createSoapEnvelopeElement(doc,soapEnvelopeNamespaceTable);
    StringBuffer header = new StringBuffer("<");
    header.append(soapEnvelopeElement.getTagName());
    NamedNodeMap attributes = soapEnvelopeElement.getAttributes();

</table>
<%
    }
    
    Element soapHeaderElement = soapMessage.getHeader(false);
    header.setLength(0);
    header.append('<').append(soapHeaderElement.getTagName());
    attributes = soapHeaderElement.getAttributes();

      <img width="16" height="16" src="<%=response.encodeURL(controller.getPathWithContext("images/space.gif"))%>">
    </td>
    <td width="100%">
      <textarea id="soap_header_content" name="<%=FragmentConstants.SOURCE_CONTENT_HEADER%>" class="textareaenter"><%=HTMLUtils.charactersToHTMLEntitiesStrict(headerContent)%></textarea>
    </td>
  </tr>
</table>

  </tr>
</table>
<%
    Element soapBodyElement = soapMessage.getBody(false);
    header.setLength(0);
    header.append('<').append(soapBodyElement.getTagName());
    attributes = soapBodyElement.getAttributes();


    Element wrapperElement = null;
    if (!operElement.isDocumentStyle())
    {      
      // Generate an RPC style wrapper element.      
      wrapperElement = (Element) soapBodyElement.getFirstChild();
      /*
       * WS-I: In a rpc-literal SOAP binding, the serialized child element of the 
       * soap:Body element consists of a wrapper element, whose namespace is the value 
       * of the namespace attribute of the soapbind:body element and whose local name is 
       * either the name of the operation or the name of the operation suffixed 
       * with "Response". The namespace attribute is required, as opposed to being 
       * optional, to ensure that the children of the soap:Body element are namespace-
       * qualified.
       */
      BindingOperation bindingOperation = operElement.getBindingOperation();
      if (bindingOperation != null)
      {
        BindingInput bindingInput = bindingOperation.getBindingInput();
        if (bindingInput != null)
        {
          List extElements = bindingInput.getExtensibilityElements();
          for (Iterator extElementsIt = extElements.iterator(); extElementsIt.hasNext();)
          {
            ExtensibilityElement extElement = (ExtensibilityElement)extElementsIt.next();
            if (extElement instanceof SOAPBody)
            {
              encodingNamespaceURI = ((SOAPBody)extElement).getNamespaceURI();
              break;
            }
          }
        }
      }
      // If the namespace of the soapbind:body element is not set, get it from the operation element
      if (encodingNamespaceURI == null)
        encodingNamespaceURI = operElement.getEncodingNamespace();
      // If the namespace of the operation element is not set, get it from the definition element
      if (encodingNamespaceURI == null)
      {
        WSDLBindingElement bindingElement = (WSDLBindingElement)operElement.getParentElement();
        WSDLServiceElement serviceElement = (WSDLServiceElement)bindingElement.getParentElement();
        WSDLElement wsdlElement = (WSDLElement)serviceElement.getParentElement();
        Definition definition = wsdlElement.getDefinition();
        encodingNamespaceURI = definition.getTargetNamespace();
      }
      // Generate an RPC style wrapper element.
      String encodingStyle = (operElement.isUseLiteral() ? null : operElement.getEncodingStyle());
      wrapperElement = SoapHelper.createRPCWrapperElement(doc,soapEnvelopeNamespaceTable,encodingNamespaceURI,oper.getName(),encodingStyle);
      header.setLength(0);
      header.append('<').append(wrapperElement.getTagName());
      attributes = wrapperElement.getAttributes();

      <img width=<%=sourceContentIndentationImageWidth%> height=16 src="<%=response.encodeURL(controller.getPathWithContext("images/space.gif"))%>">
    </td>
    <td width="100%">
      <textarea id="soap_body_content" name="<%=FragmentConstants.SOURCE_CONTENT%>" class="bigtextareaenter"><%=HTMLUtils.charactersToHTMLEntitiesStrict(bodyContent)%></textarea>
    </td>
  </tr>
</table>




 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070305   117034 makandre@ca.ibm.com - Andrew Mak, Web Services Explorer should support SOAP Headers
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
%>
<%@ page contentType="text/html; charset=UTF-8" import="org.eclipse.wst.ws.internal.explorer.platform.wsdl.perspective.*,

                                                        org.eclipse.wst.ws.internal.explorer.platform.wsdl.xsd.*,
                                                        org.eclipse.wst.ws.internal.explorer.platform.wsdl.fragment.*,
                                                        org.eclipse.wst.ws.internal.explorer.platform.wsdl.fragment.impl.*,
                                                        org.eclipse.wst.ws.internal.explorer.platform.wsdl.util.*,
                                                        org.eclipse.wst.ws.internal.explorer.platform.constants.*,
                                                        org.eclipse.wst.ws.internal.explorer.platform.perspective.Node,
                                                        org.eclipse.wst.ws.internal.explorer.platform.perspective.*,
                                                        org.eclipse.wst.ws.internal.explorer.platform.util.*,
                                                        org.eclipse.wst.ws.internal.explorer.transport.*,
                                                        org.eclipse.wst.wsdl.binding.soap.SOAPHeader,
                                                        org.w3c.dom.*,
                                                        javax.wsdl.*,

<jsp:useBean id="controller" class="org.eclipse.wst.ws.internal.explorer.platform.perspective.Controller" scope="session"/>
<jsp:useBean id="fragID" class="java.lang.StringBuffer" scope="request"/>
<jsp:useBean id="nodeID" class="java.lang.StringBuffer" scope="request"/>

<%!
private Element soapResponse_ = null;
private boolean hasSOAPHeaders = false;

private void checkSOAPHeaders() {
	
	NodeList nl = soapResponse_.getElementsByTagNameNS(FragmentConstants.URI_SOAP_ENV, FragmentConstants.QNAME_LOCAL_NAME_HEADER);    
	if (nl.getLength() == 0)
		return;
	
	Element soapHeader = (Element) nl.item(0);
	NodeList nodes = soapHeader.getChildNodes();
	
	for (int i = 0; i < nodes.getLength(); i++) {
	    if (nodes.item(i) instanceof Element) {
	    	hasSOAPHeaders = true;
	    	return;
	    }
	}
}

private Element[] parseSOAPResponse(SOAPMessageQueue soapMessageQueue, WSDLOperationElement operElement)
{
  String messages = soapMessageQueue.getMessagesFromList();
  try
  {
    soapResponse_ = XMLUtils.stringToElement(messages, true);
    checkSOAPHeaders();
    NodeList nl = soapResponse_.getElementsByTagNameNS(FragmentConstants.URI_SOAP_ENV, FragmentConstants.QNAME_LOCAL_NAME_BODY);
    if (nl.getLength() > 0)
    {
      Element soapBody = (Element)nl.item(0);
      NodeList soapFault = soapBody.getElementsByTagNameNS(FragmentConstants.URI_SOAP_ENV, FragmentConstants.QNAME_LOCAL_NAME_FAULT);
      if (soapFault.getLength() > 0)
        return new Element[0];
      NodeList instanceList;
      if (operElement.isDocumentStyle())
        instanceList = soapBody.getChildNodes();
      else
      {
        NodeList rpcWrapper = soapBody.getElementsByTagNameNS("*", operElement.getOperation().getOutput().getMessage().getQName().getLocalPart());

        /*
        * HACK - Some of the web services out on the internet do not
        * set their RPC wrapper properly.  It should be set to the output
        * message name of the selected operation.  The hack is to
        * assume the first element inside the body element is the
        * RPC wrapper.
        */
        if (rpcWrapper.getLength() <= 0)
          rpcWrapper = soapBody.getElementsByTagNameNS("*", "*");

        if (rpcWrapper.getLength() > 0)
          instanceList = rpcWrapper.item(0).getChildNodes();
        else
          return null;
      }
      return fixSOAPResponse(instanceList, operElement);
    }
  }
  catch (Throwable t) {
    t.printStackTrace();
  }
  return null;
}

/*
* HACK - The root element tag name of the instance document
* is ambiguous.  It lands on a very grey area between the SOAP
* spec and the WSDL spec.  The two specs do not explicitly define
* that the root element tag name must match the name of the
* WSDL part.  The hack is to treat elements with different tag names
* as instances of the WSDL part.
*/
private Element[] fixSOAPResponse(NodeList instanceList, WSDLOperationElement operElement)
{
  Vector instanceVector = new Vector();
  for (int i = 0; i < instanceList.getLength(); i++)
  {
    Object object = instanceList.item(i);
    if (object != null && (object instanceof Element))
      instanceVector.add(object);
  }
  Element[] instanceDocuments = new Element[instanceVector.size()];
  Operation oper = operElement.getOperation();
  Map partsMap = oper.getOutput().getMessage().getParts();
  if (partsMap.size() == 1)
  {
    Iterator it = partsMap.values().iterator();
    IXSDFragment frag = operElement.getFragment((Part)it.next(), false);
    for (int i = 0; i < instanceVector.size(); i++)
    {
      Element element = (Element)instanceVector.get(i);
      if (!element.getTagName().equals(frag.getName()))
      {
        Document doc = element.getOwnerDocument();
        NodeList children = element.getChildNodes();
        NamedNodeMap attributes = element.getAttributes();
        element = doc.createElement(frag.getName());
        for (int j = 0; j < children.getLength(); j++)
        {
          if (children.item(j) != null)
          {
            element.appendChild(children.item(j));
            // When you append a node from one element to another,
            // the original element will lose its reference to this node,
            // therefore, the size of the node list will decrease by 1.
            j--;
          }
        }
        for (int j = 0; j < attributes.getLength(); j++)
        {
          Object attr = attributes.item(j);
          if (attr != null && (attr instanceof Attr))
          {
            Attr attribute = (Attr)attr;
            element.setAttribute(attribute.getName(), attribute.getValue());
          }
        }
      }
      instanceDocuments[i] = element;
    }
  }
  else
    instanceVector.copyInto(instanceDocuments);
  return instanceDocuments;
}
%>

<%
WSDLPerspective wsdlPerspective = controller.getWSDLPerspective();
wsdlPerspective.setStatusContentType(WSDLPerspective.STATUS_CONTENT_RESULT_FORM);

}
else
{
  ISOAPMessage soapMessage = (ISOAPMessage) operElement.getPropertyAsObject(WSDLModelConstants.PROP_SOAP_RESPONSE);
  Element[] headerContent = soapMessage.getHeaderContent();;
  Element[] bodyContent   = soapMessage.getBodyContent();
  
  boolean cached = ((Boolean)operElement.getPropertyAsObject(WSDLActionInputs.SOAP_RESPONSE_CACHED)).booleanValue();

  if (soapMessage.getBody(false) == null) // body is mandatory
  {
    SOAPMessageQueue soapMessageQueue = wsdlPerspective.getSOAPResponseQueue();
    instanceDocuments = parseSOAPResponse(soapMessageQueue, operElement);
  }
  if (!cached && !hasSOAPHeaders && instanceDocuments == null)
  {
  %>
    <table width="95%" border=0 cellpadding=6 cellspacing=0>

    </table>
  <%
  }
  else if ((headerContent == null || headerContent.length == 0) && 
		   (soapMessage.getFault() != null || bodyContent == null || bodyContent.length == 0))
  {
  %>
    <table width="95%" border=0 cellpadding=6 cellspacing=0>

	
	<div id="<%=headerDivId%>" class="fragarea">
	<%
	boolean hasSOAPHeaders = false;
	if (headerContent != null && headerContent.length > 0) {		
		
		Iterator it = operElement.getSOAPHeaders(false).iterator();
		int start = 0;
		while (it.hasNext() && start < headerContent.length) {
			SOAPHeader soapHeader = (SOAPHeader) it.next();									
			IXSDFragment fragment = operElement.getHeaderFragment(soapHeader, false);
			
			if (!cached) {				
				int pos = SOAPMessageUtils.findFirstMatchingElement(
					soapHeader.getEPart(),
					headerContent,
					soapMessage.getNamespaceTable(),
					fragment.getName(),
					start);
				
				if (pos == -1)
					continue;
				
				Element element = headerContent[pos];
				start = pos + 1;
				
				if (!fragment.setParameterValuesFromInstanceDocuments(new Element[] { element }))
					continue;
			}
			else if (!fragment.validateAllParameterValues())
				continue;
			
			hasSOAPHeaders = true;				
			fragID.delete(0, fragID.length());
			fragID.append(fragment.getID());
			%>
			<jsp:include page="<%=fragment.getReadFragment()%>" flush="true"/>
			<%  
		}		
	}

	
	<div id="<%=bodyDivId%>" class="fragarea">
	<%	
	boolean hasSOAPBody = false;
	if (bodyContent != null && bodyContent.length > 0) {				
		
	    Map partsMap = oper.getOutput().getMessage().getParts();
	    Iterator it = partsMap.values().iterator();
	    Hashtable uriReferences = null;

	        if (!operElement.isUseLiteral() && (fragment instanceof ISOAPEncodingWrapperFragment))
	        {
	          if (uriReferences == null)
	            uriReferences = SOAPEncodingWrapperFragment.parseURIReferences(soapMessage.getEnvelope(true), true);
	          ((ISOAPEncodingWrapperFragment)fragment).setURIReferences(uriReferences);
	        }
	        if (!fragment.setParameterValuesFromInstanceDocuments(bodyContent))
	        	continue;
	      }
	      else if (!fragment.validateAllParameterValues())
			continue;
			
		  hasSOAPBody = true;				
	      fragID.delete(0, fragID.length());
	      fragID.append(fragment.getID());
	      %>

	    }
	    operElement.setPropertyAsObject(WSDLActionInputs.SOAP_RESPONSE_CACHED, new Boolean(true));
	}
	if (!hasSOAPBody) {
		%>
		<table width="95%" border=0 cellpadding=6 cellspacing=0>
	      <tr>

Lines 74-79 Link Here

(-)wsexplorer/uddi/category_content.jsp (+1 lines)
74	<%=uddiPerspective.getMessage("MSG_INFO_NO_CATEGORY_DATA",categoryModel.getDisplayName())%>	74	<%=uddiPerspective.getMessage("MSG_INFO_NO_CATEGORY_DATA",categoryModel.getDisplayName())%>
75	</td>	75	</td>
76	</tr>	76	</tr>
		77	<tr>
77	<td height=10 valign="bottom"> </td>	78	<td height=10 valign="bottom"> </td>
78	</tr>	79	</tr>
79	<tr>	80	<tr>




<%
/*******************************************************************************
 * Copyright (c) 2001, 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 * 
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
%>
<%@ page contentType="text/html; charset=UTF-8" import="org.eclipse.wst.ws.internal.explorer.platform.wsdl.perspective.*,
                                                        org.eclipse.wst.ws.internal.explorer.platform.wsdl.datamodel.*,
                                                        org.eclipse.wst.ws.internal.explorer.platform.wsdl.actions.*,
                                                        org.eclipse.wst.ws.internal.explorer.platform.wsdl.constants.WSDLActionInputs,
                                                        org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport.HTTPException,
                                                        org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport.HTTPTransport,
                                                        org.eclipse.wst.ws.internal.explorer.platform.perspective.*,
                                                        org.eclipse.wst.ws.internal.explorer.platform.constants.*,
                                                        org.eclipse.wst.ws.internal.explorer.transport.HTTPTransportException,
                                                        sun.misc.BASE64Decoder,
                                                        javax.servlet.http.HttpServletResponse,
                                                        javax.wsdl.*"%>

        </html>
<%
      }
      catch (HTTPTransportException httpe)
      {
        int code = httpe.getStatusCode();
        if (code == HttpServletResponse.SC_UNAUTHORIZED)

          MessageQueue messageQueue = wsdlPerspective.getMessageQueue();
          messageQueue.addMessage(controller.getMessage("MSG_ERROR_UNEXPECTED"));
          messageQueue.addMessage(String.valueOf(code));
          messageQueue.addMessage(httpe.getMessage());
          %>
          <jsp:include page="/wsdl/scripts/wsdlpanes.jsp" flush="true"/>
          <html>




<%
/*******************************************************************************
 * Copyright (c) 2001, 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 * 
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
%>
<%@ page contentType="text/html; charset=UTF-8" import="org.eclipse.wst.ws.internal.explorer.platform.wsdl.actions.*,

                                                        org.eclipse.wst.ws.internal.explorer.platform.perspective.MessageQueue,
                                                        org.eclipse.wst.ws.internal.explorer.platform.wsdl.constants.WSDLActionInputs,
                                                        org.eclipse.wst.ws.internal.explorer.platform.wsdl.perspective.WSDLPerspective,
                                                        org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport.HTTPException,
                                                        org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport.HTTPTransport,
                                                        org.eclipse.wst.ws.internal.explorer.transport.HTTPTransportException,
                                                        sun.misc.BASE64Decoder,
                                                        javax.servlet.http.HttpServletResponse"%>


    </html>
<%
  }
  catch (HTTPTransportException httpe)
  {
    int code = httpe.getStatusCode();
    if (code == HttpServletResponse.SC_UNAUTHORIZED)

      MessageQueue messageQueue = wsdlPerspective.getMessageQueue();
      messageQueue.addMessage(controller.getMessage("MSG_ERROR_UNEXPECTED"));
      messageQueue.addMessage(String.valueOf(code));
      messageQueue.addMessage(httpe.getMessage());
      %>
        <jsp:include page="/wsdl/scripts/wsdlpanes.jsp" flush="true"/>
        <html>




/*******************************************************************************
 * Copyright (c) 2002, 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.wsdl.fragment.impl;


          Node child = children.item(i);
          if (child != null)
          {
        	  eCopy.appendChild(child.cloneNode(true));
            // When you append a node from one element to another,
            // the original element will lose its reference to this node,
            // therefore, the size of the node list will decrease by 1.
            i--;
          }
        }
        for (int j = 0; j < attributes.getLength(); j++)




 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070305   117034 makandre@ca.ibm.com - Andrew Mak, Web Services Explorer should support SOAP Headers
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/

package org.eclipse.wst.ws.internal.explorer.platform.wsdl.fragment.impl;

import java.net.URI;
import java.net.URISyntaxException;
import java.util.Hashtable;
import java.util.Map;
import java.util.Vector;

import org.eclipse.wst.ws.internal.explorer.platform.util.MultipartFormDataException;

	}
	
	/**
	 * Sets the values for this SOAP header given an instance document and a namespace table.
	 * 
	 * @param instanceDocument The instance document.
	 * @param namespaceTable The namespace table.
	 * 
	 * @return True if all values extracted from the instance document are valid.
	 */
	public boolean setParameterValuesFromInstanceDocument(Element instanceDocument, Map namespaceTable) {

		Element instanceDocument = (Element) instanceDocuments.get(tagName);
		 
		if (instanceDocument == null)
			return false;
		 
		boolean valid = setParameterValuesFromInstanceDocuments(new Element[] { instanceDocument });		
		 
		String prefix = namespaceTable.get(FragmentConstants.NS_URI_SOAP_ENV) + FragmentConstants.COLON;
		 
		String mustUnderstandValue = instanceDocument.getAttribute(prefix + MUST_UNDERSTAND);
		if ("".equals(mustUnderstandValue))

Lines 42-48 Link Here

(-)wsexplorer/wsdl/fragment/XSDSimpleAtomicEnumFixWFragmentJSP.jsp (-2 / +1 lines)
42	<td class="labels" height=25 valign="bottom" align="left" nowrap>	42	<td class="labels" height=25 valign="bottom" align="left" nowrap>
43	<%=(xsdBuiltInType != null ? xsdBuiltInType.getName() : simpleType.getName())%>	43	<%=(xsdBuiltInType != null ? xsdBuiltInType.getName() : simpleType.getName())%>
44	</td>	44	</td>
45	<td>
46	<%	45	<%
47	if(elementFragment != null && elementFragment.isNillable()){	46	if(elementFragment != null && elementFragment.isNillable()){
48	if(elementFragment.isNil()){	47	if(elementFragment.isNil()){
Lines 57-63 Link Here
57	}	56	}
58	}	57	}
59	%>	58	%>
60		59	<td>
61	<%	60	<%
62	if (!frag.validateParameterValues(frag.getID()))	61	if (!frag.validateParameterValues(frag.getID()))
63	{	62	{




 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070305   117034 makandre@ca.ibm.com - Andrew Mak, Web Services Explorer should support SOAP Headers
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.wsdl.datamodel;


import javax.wsdl.Binding;
import javax.wsdl.BindingInput;
import javax.wsdl.BindingOperation;
import javax.wsdl.Definition;
import javax.wsdl.Input;
import javax.wsdl.Operation;
import javax.wsdl.Output;

import javax.wsdl.extensions.soap.SOAPBinding;
import javax.wsdl.extensions.soap.SOAPBody;
import javax.wsdl.extensions.soap.SOAPOperation;
import org.eclipse.wst.ws.internal.explorer.platform.perspective.TransportProviderRegistry;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.constants.BindingTypes;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.constants.FragmentConstants;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.fragment.IXSDFragment;

import org.eclipse.wst.ws.internal.explorer.platform.wsdl.fragment.XSDToFragmentController;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.fragment.impl.SOAPHeaderWrapperFragment;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.xsd.WSDLPartsToXSDTypeMapper;
import org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransportProvider;
import org.eclipse.wst.ws.internal.explorer.transport.MessageContext;
import org.eclipse.wst.wsdl.binding.soap.SOAPHeader;
import org.eclipse.xsd.XSDNamedComponent;


  private String encodingStyle_;
  private String encodingNamespace_;

  private Map headerCache;
  
  private MessageContext messageContext = null;
  private ISOAPTransportProvider soapTransportProvider = null;  
  
  private final void gatherSoapInformation(WSDLBindingElement bindingElement,SOAPBinding soapBinding)
  {

    setOperation(bindingElement,operation);
  }

  private Definition getDefinition(WSDLBindingElement bindingElement) {
	  WSDLServiceElement serviceElement = (WSDLServiceElement) bindingElement.getParentElement();
      WSDLElement wsdlElement = (WSDLElement) serviceElement.getParentElement();
      return wsdlElement.getDefinition();
  }
  
  private void setMessageContext(WSDLBindingElement bindingElement) {
	  messageContext = new MessageContext();
	  messageContext.setDefinition(getDefinition(bindingElement));
	  messageContext.setBindingOperation(getBindingOperation(bindingElement));
	  messageContext.setBindingProtocol(bindingElement.getBindingExtensibilityElement());
	  messageContext.setDocumentStyle(isDocumentStyle_);
  }
  
  public MessageContext getMessageContext() {
	  return messageContext;
  }
  
  private void setSOAPTransportProvider(SOAPBinding soapBinding) {
	  	  
	  String namespaceURI = soapBinding.getElementType().getNamespaceURI();
	  String transportURI = soapBinding.getTransportURI();
	  	  
	  soapTransportProvider = TransportProviderRegistry.getInstance()
	  	.getSOAPTransportProvider(namespaceURI, transportURI);
  }
  
  public ISOAPTransportProvider getSOAPTransportProvider() {
	  return soapTransportProvider;
  }
  
  public void setOperation(WSDLBindingElement bindingElement,Operation operation) {
    operation_ = operation;
    setDocumentation(operation.getDocumentationElement());

    {
      case BindingTypes.SOAP:
        gatherSoapInformation(bindingElement,(SOAPBinding)bindingExtensibilityElement);
        setMessageContext(bindingElement);
        setSOAPTransportProvider((SOAPBinding) bindingExtensibilityElement);
        headerCache = new Hashtable();
      case BindingTypes.HTTP_GET:
      case BindingTypes.HTTP_POST:
      default:

	else
	  id.append(FragmentConstants.OUTPUT_ID).append(soapHeader.getMessage()).append(FragmentConstants.PART_TOKEN);
	
	return getFragment(part, id, true, isInput); // only wrap input header fragments
  }
  
  public IXSDFragment getFragment(Part part) {

    else
      id.append(FragmentConstants.OUTPUT_ID);

	return getFragment(part, id, false, false);
  }
  
  private IXSDFragment getFragment(Part part, StringBuffer id, boolean isHeader, boolean useSOAPHeaderWrapper) {
    String partName = part.getName();
    id.append(partName);
    XSDToFragmentConfiguration config = new XSDToFragmentConfiguration();
    config.setIsWSDLPart(true);
    config.setWSDLPartName(partName);
    config.setXSDComponent(getSchema(part, id.toString()));
    if (isDocumentStyle() || isHeader)
      config.setStyle(FragmentConstants.STYLE_DOCUMENT);
    else
      config.setStyle(FragmentConstants.STYLE_RPC);




/*******************************************************************************
 * Copyright (c) 2002, 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 * 
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070305   117034 makandre@ca.ibm.com - Andrew Mak, Web Services Explorer should support SOAP Headers
 *******************************************************************************/

package org.eclipse.wst.ws.internal.explorer.platform.wsdl.util;

import java.util.Enumeration;
import java.util.Hashtable;
import org.apache.axis.Constants;
import org.eclipse.wst.ws.internal.explorer.platform.util.URLUtils;
import org.w3c.dom.Document;
import org.w3c.dom.Element;

public class SoapHelper
{
  private static Hashtable defaultSoapEnvelopeNamespaces_ = null;
  
  private static final void initDefaultSoapEnvelopeNamespaces()
  {
    defaultSoapEnvelopeNamespaces_ = new Hashtable();
    defaultSoapEnvelopeNamespaces_.put(Constants.URI_SOAP11_ENV,Constants.NS_PREFIX_SOAP_ENV);
    defaultSoapEnvelopeNamespaces_.put(Constants.URI_2001_SCHEMA_XSI,Constants.NS_PREFIX_SCHEMA_XSI);
    defaultSoapEnvelopeNamespaces_.put(Constants.URI_2001_SCHEMA_XSD,Constants.NS_PREFIX_SCHEMA_XSD);
  }
  
  public static final void addDefaultSoapEnvelopeNamespaces(Hashtable soapEnvelopeNamespaces)
  {
    if (defaultSoapEnvelopeNamespaces_ == null)
      initDefaultSoapEnvelopeNamespaces();
    Enumeration defaultSoapEnvelopeNamespaceURIs = defaultSoapEnvelopeNamespaces_.keys();
    while (defaultSoapEnvelopeNamespaceURIs.hasMoreElements())
    {
      String defaultSoapEnvelopeNamespaceURI = (String)defaultSoapEnvelopeNamespaceURIs.nextElement();
      soapEnvelopeNamespaces.put(defaultSoapEnvelopeNamespaceURI,(String)defaultSoapEnvelopeNamespaces_.get(defaultSoapEnvelopeNamespaceURI));
    }
  }
  
  public static final boolean isDefaultSoapEnvelopeNamespace(String namespaceURI,String namespacePrefix)
  {
    if (defaultSoapEnvelopeNamespaces_ == null)
      initDefaultSoapEnvelopeNamespaces();
    if (defaultSoapEnvelopeNamespaces_.get(namespaceURI) != null)
      return true;
    return false;
  }  
  
  public static final Element createSoapEnvelopeElement(Document doc,Hashtable soapEnvelopeNamespaceTable)
  {
    Element soapEnvelopeElement = doc.createElement("soapenv:Envelope");
    Enumeration e = soapEnvelopeNamespaceTable.keys();
    while (e.hasMoreElements())
    {
      String soapEnvelopeNamespaceURI = (String)e.nextElement();
      StringBuffer soapEnvelopeNamespaceAttr = new StringBuffer("xmlns:");
      soapEnvelopeNamespaceAttr.append((String)soapEnvelopeNamespaceTable.get(soapEnvelopeNamespaceURI));
      soapEnvelopeElement.setAttribute(soapEnvelopeNamespaceAttr.toString(),soapEnvelopeNamespaceURI);      
    }    
    return soapEnvelopeElement;
  }
  
  public static final Element createSoapHeaderElement(Document doc)
  {
    return doc.createElement("soapenv:Header");
  }
  
  public static final Element createSoapBodyElement(Document doc)
  {
    return doc.createElement("soapenv:Body");
  }
  
  public static final Element createRPCWrapperElement(Document doc,Hashtable soapEnvelopeNamespaceTable,String encodingNamespaceURI,String operationName, String encodingStyle)
  {
    int nsId = 0;
    StringBuffer wrapperElementName = new StringBuffer();
    String encodingNamespacePrefix = (String)soapEnvelopeNamespaceTable.get(encodingNamespaceURI);
    if (encodingNamespacePrefix != null)
      wrapperElementName.append(encodingNamespacePrefix);
    else
    {
      // Loop until we generate a unique prefix.
      do
      {
        wrapperElementName.setLength(0);
        wrapperElementName.append("ns").append(nsId);
        if (!soapEnvelopeNamespaceTable.containsValue(wrapperElementName.toString()))
          break;
        nsId++;
      } while (true);
    }    
    String wrapperElementNamePrefix = wrapperElementName.toString();
    wrapperElementName.append(':').append(operationName);
    Element wrapperElement = doc.createElement(wrapperElementName.toString());
    StringBuffer namespaceAttrName = new StringBuffer("xmlns:");
    namespaceAttrName.append(wrapperElementNamePrefix);
    wrapperElement.setAttribute(namespaceAttrName.toString(),encodingNamespaceURI);
    if (encodingStyle != null)
      wrapperElement.setAttribute("soapenv:encodingStyle",encodingStyle);
    return wrapperElement;
  }

  public static final String encodeNamespaceDeclaration(String prefix, String uri)
  {
    StringBuffer sb = new StringBuffer();
    sb.append(prefix);
    sb.append(" ");
    sb.append(uri);
    String result = URLUtils.encode(sb.toString());
    return result;
  }

  public static final String[] decodeNamespaceDeclaration(String s)
  {
    String sCopy = URLUtils.decode(s);
    int index = sCopy.indexOf(" ");
    String[] nsDecl = new String[2];
    if (index != -1)
    {
      nsDecl[0] = sCopy.substring(0, index);
      nsDecl[1] = sCopy.substring(index+1, sCopy.length());
    }
    else
    {
      nsDecl[0] = null;
      nsDecl[1] = sCopy;
    }
    return nsDecl;
  }
}

Lines 37-42 Link Here

(-)wsexplorer/actions/WriteWSDLToWorkbenchActionJSP.jsp (-1 lines)
37	<%	37	<%
38	}	38	}
39	%>	39	%>
40	</script>
41	</body>	40	</body>
42	</html>	41	</html>

Lines 10-15 Link Here

(-)wsexplorer-src/org/eclipse/wst/ws/internal/explorer/platform/wsdl/constants/WSDLModelConstants.java (+6 lines)
10	* yyyymmdd bug Email and other contact information	10	* yyyymmdd bug Email and other contact information
11	* -------- -------- -----------------------------------------------------------	11	* -------- -------- -----------------------------------------------------------
12	* 20070305 117034 makandre@ca.ibm.com - Andrew Mak, Web Services Explorer should support SOAP Headers	12	* 20070305 117034 makandre@ca.ibm.com - Andrew Mak, Web Services Explorer should support SOAP Headers
		13	* 20070413 176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
13	*******************************************************************************/	14	*******************************************************************************/
14		15
15	package org.eclipse.wst.ws.internal.explorer.platform.wsdl.constants;	16	package org.eclipse.wst.ws.internal.explorer.platform.wsdl.constants;
Lines 29-32 Link Here
29	public final static String PROP_SOURCE_CONTENT_HEADER = "propSourceContentHeader";	30	public final static String PROP_SOURCE_CONTENT_HEADER = "propSourceContentHeader";
30	public final static String PROP_SOURCE_CONTENT = "propSourceContent";	31	public final static String PROP_SOURCE_CONTENT = "propSourceContent";
31	public final static String PROP_SOURCE_CONTENT_NAMESPACE = "propSourceContentNS";	32	public final static String PROP_SOURCE_CONTENT_NAMESPACE = "propSourceContentNS";
		33
		34	// Transport
		35	public final static String PROP_SOAP_REQUEST_TMP = "propSOAPRequestTmp";
		36	public final static String PROP_SOAP_REQUEST = "propSOAPRequest";
		37	public final static String PROP_SOAP_RESPONSE = "propSOAPResponse";
32	}	38	}




/*******************************************************************************
 * Copyright (c) 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport;

import org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransport;
import org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransportProvider;

/**
 * WSE's default implementation for ISOAPTransportProvider.
 */
public class SOAPTransportProvider implements ISOAPTransportProvider {	
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransportProvider#newTransport()
	 */
	public ISOAPTransport newTransport() {
		return new SOAPTransport();		
	}
}




/*******************************************************************************
 * Copyright (c) 2004, 2005 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 *     IBM Corporation - initial API and implementation
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.util;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;
import javax.xml.transform.OutputKeys;
import javax.xml.transform.Transformer;
import javax.xml.transform.TransformerFactory;
import javax.xml.transform.dom.DOMSource;
import javax.xml.transform.stream.StreamResult;

import org.w3c.dom.Document;
import org.w3c.dom.DocumentFragment;
import org.w3c.dom.Element;
import org.xml.sax.SAXException;

public final class XMLUtils
{
  public static final String UTF8_ENCODING = "UTF-8"; 
	
  /**
   * Serialize an XML Element into a String.
   * @param e Element to be serialized.
   * @param omitXMLDeclaration boolean representing whether or not to omit the XML declaration.
   * @return String representation of the XML document fragment.
   */
  public static final String serialize(Element e,boolean omitXMLDeclaration)
  {
    if (e != null)
    {
      try
      {
		DOMSource domSource = new DOMSource(e);
		Transformer serializer = TransformerFactory.newInstance().newTransformer();
		serializer.setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, ((omitXMLDeclaration) ? "yes" : "no"));
		serializer.setOutputProperty(OutputKeys.INDENT, "yes");
		serializer.setOutputProperty(OutputKeys.ENCODING, UTF8_ENCODING);
		serializer.setOutputProperty("{http://xml.apache.org/xslt}indent-amount", "2");
		ByteArrayOutputStream baos = new ByteArrayOutputStream();
		serializer.transform(domSource, new	StreamResult(baos));
		baos.close();
		return new String(baos.toByteArray(), UTF8_ENCODING);
      }
      catch (Throwable t)
      {
      }
    }
    return null;
  }
    
  /**
   * Serialize an XML Element into a String.
   * @param df DocumentFragment to be serialized.
   * @param omitXMLDeclaration boolean representing whether or not to omit the XML declaration.
   * @return String representation of the XML document fragment.
   */  
  public static final String serialize(DocumentFragment df,boolean omitXMLDeclaration)
  {
    if (df != null)
    {
      try
      {
		DOMSource domSource = new DOMSource(df);
		Transformer serializer = TransformerFactory.newInstance().newTransformer();
		serializer.setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, ((omitXMLDeclaration) ? "yes" : "no"));
		serializer.setOutputProperty(OutputKeys.INDENT, "yes");
		serializer.setOutputProperty(OutputKeys.ENCODING, UTF8_ENCODING);
		serializer.setOutputProperty("{http://xml.apache.org/xslt}indent-amount", "2");
		ByteArrayOutputStream baos = new ByteArrayOutputStream();
		serializer.transform(domSource, new	StreamResult(baos));
		baos.close();
		return new String(baos.toByteArray(), UTF8_ENCODING);
      }
      catch (Throwable t)
      {
      }
    }
    return null;
  }
  
  /**
   * Create a new XML Document.
   * @param docBuilder DocumentBuilder. Setting this to null will create a new DocumentBuilder.
   * @return Document
   */
  public static final Document createNewDocument(DocumentBuilder docBuilder) throws ParserConfigurationException
  {
    if (docBuilder == null)
    {
      DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
      factory.setNamespaceAware(false);
      factory.setValidating(false);
      docBuilder = factory.newDocumentBuilder();
    }
    Document doc = docBuilder.newDocument();
    return doc;
  }

  /**
   * Convert the String representation of an Element into an Element
   * @param String representation of an Element.
   * @return Element
   */
  public static Element stringToElement(String s) throws ParserConfigurationException, SAXException, UnsupportedEncodingException, IOException {
    return stringToElement(s, false);
  }

  /**
   * Convert the String representation of an Element into an Element
   * @param String representation of an Element.
   * @param boolean set whether the return Element should be namespace aware.
   * @return Element
   */
  public static Element stringToElement(String s, boolean namespaceAware) throws ParserConfigurationException, SAXException, UnsupportedEncodingException, IOException
  {
    return byteArrayToElement(s.getBytes(UTF8_ENCODING), namespaceAware);
  }

  /**
   * Convert the byte array representation of an Element into an Element
   * @param byte[] representation of an Element.
   * @param boolean set whether the return Element should be namespace aware.
   * @return Element
   */
  public static Element byteArrayToElement(byte[] b, boolean namespaceAware) throws ParserConfigurationException, SAXException, UnsupportedEncodingException, IOException
  {
    DocumentBuilderFactory docBuilderFactory = DocumentBuilderFactory.newInstance();
    docBuilderFactory.setNamespaceAware(namespaceAware);
    docBuilderFactory.setValidating(false);
    DocumentBuilder docBuilder = docBuilderFactory.newDocumentBuilder();
    Document doc = docBuilder.parse(new ByteArrayInputStream(b));
    return doc.getDocumentElement();
  }
}




/*******************************************************************************
 * Copyright (c) 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport;

import java.io.IOException;
import java.util.Hashtable;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Vector;

import javax.wsdl.Operation;
import javax.wsdl.Part;
import javax.wsdl.extensions.ExtensibilityElement;
import javax.wsdl.extensions.soap.SOAPBody;
import javax.xml.parsers.ParserConfigurationException;

import org.apache.axis.Constants;
import org.eclipse.wst.ws.internal.explorer.platform.util.XMLUtils;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.util.SoapHelper;
import org.eclipse.wst.ws.internal.explorer.transport.IDeserializer;
import org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage;
import org.eclipse.wst.ws.internal.explorer.transport.ISerializer;
import org.eclipse.wst.ws.internal.explorer.transport.MessageContext;
import org.eclipse.wst.ws.internal.explorer.transport.TransportException;
import org.w3c.dom.Attr;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.w3c.dom.NamedNodeMap;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import org.xml.sax.SAXException;

/**
 * This class provides implementation for WSE default SOAP transport's ISerializer and IDeserializer.
 */
public class SOAPMessageProcessor implements ISerializer, IDeserializer {
	
	private static final String LITERAL = "literal";
	private static final String DEFAULT_SOAP_ENCODING = "UTF-8";	
	private static final String LINE_SEPARATOR = System.getProperties().getProperty("line.separator");
	
	/*
	 * Constructor.
	 */
	SOAPMessageProcessor() {}
	
	/*
	 * Join the encodingStyles into a space separated string
	 */
	private String joinEncodingStyles(List list) {
		
		if (list.isEmpty())
			return null;
		
		StringBuffer sb = new StringBuffer();
		
		Iterator iter = list.iterator();
		while (iter.hasNext())
			sb.append(" ").append(iter.next());
		
		return sb.substring(1).toString();
	}
	
	/*
	 * Retrieves the encoding information from the binding for the selected operation.
	 * This method is called only for RPC style bindings.  Two pieces of information are returned:  
	 * If the use is encoded, this method returns the encoding namespace in element [0] and the 
	 * encoding style(s) in element [1].  If the use is literal, then both values will be null.
	 */
	private String[] getEncodingInfo(MessageContext context) {
		
		String[] info = new String[] { null, null };
		
		Iterator iter = context.getBindingOperation().getBindingInput()
			.getExtensibilityElements().iterator();
				
		// look for the soapbind:body extensilibity element
		while (iter.hasNext()) {
			ExtensibilityElement e = (ExtensibilityElement) iter.next();			
			if (!(e instanceof SOAPBody))
				continue;
			
			SOAPBody soapBody = (SOAPBody) e;
			
			// use="encoded"
			if (!LITERAL.equals(soapBody.getUse())) {
				info[0] = soapBody.getNamespaceURI();
				info[1] = joinEncodingStyles(soapBody.getEncodingStyles());
			}
					
			break;
		}
		
		// namespace not specified on the soapbind:body element, use the definition's
		if (info[0] == null)
			info[0] = context.getDefinition().getTargetNamespace();
		
		return info;
	}
	
	/*
     * WS-I: In a rpc-literal SOAP binding, the serialized child element of the 
     * soap:Body element consists of a wrapper element, whose namespace is the value 
     * of the namespace attribute of the soapbind:body element and whose local name is 
     * either the name of the operation or the name of the operation suffixed 
     * with "Response". The namespace attribute is required, as opposed to being 
     * optional, to ensure that the children of the soap:Body element are namespace-
     * qualified.
     */
	private Element createRPCWrapper(Document document, MessageContext context, Hashtable namespaceTable) {
		
		String encodingNamespaceURI = getEncodingInfo(context)[0];
		
		return SoapHelper.createRPCWrapperElement(
				document, 
				namespaceTable, 
				encodingNamespaceURI, 
				context.getBindingOperation().getOperation().getName(),
				null);
	}
	
	/*
	 * Initializes the contents of new ISOAPMessage.
	 */
	void initMessage(ISOAPMessage message) throws TransportException {
	
		try {
			Document document = XMLUtils.createNewDocument(null);
			
			Hashtable namespaceTable = new Hashtable();
			SoapHelper.addDefaultSoapEnvelopeNamespaces(namespaceTable);
			
			message.setEnvelope(SoapHelper.createSoapEnvelopeElement(document, namespaceTable));
			message.setHeader(SoapHelper.createSoapHeaderElement(document));
			
			Element body = SoapHelper.createSoapBodyElement(document);
			if (!message.getMessageContext().isDocumentStyle()) {
				Element rpcWrapper = createRPCWrapper(document, message.getMessageContext(), namespaceTable);
				body.appendChild(rpcWrapper);
			}			
			message.setBody(body);			
			
			message.setNamespaceTable(namespaceTable);
		}
		catch (ParserConfigurationException e) {
			throw new TransportException(e);
		}		
	}
	
	/*
	 * Returns the first element with the given local name from the soap envelope namespace
	 * This method can be used on elements that are not namespace aware, but we have to give
	 * it a namespace table to look up prefixes.
	 */
	private Element getSOAPElement(Element root, String localName, Map namespaceTable) {
		String prefix = (String) namespaceTable.get(Constants.URI_SOAP11_ENV);
		if (prefix == null)
			return null;
		
		NodeList list = root.getElementsByTagName(prefix + ":" + localName);
		if (list.getLength() == 0)
			return null;
		
		return (Element) list.item(0);
	}
	
	/*
	 * Returns the first element with the given local name from the soap envelope namespace.
	 * This version assume the elements are namespace aware.
	 */
	private Element getSOAPElementNS(Element root, String localName) {
		NodeList list = root.getElementsByTagNameNS(Constants.URI_SOAP11_ENV, localName);
		if (list.getLength() == 0)
			return null;		
	
		return (Element) list.item(0);
	}
	
	/*
	 * Convert a NodeList to a vector of elements, nodes which are not elements are skipped.
	 */
	private Vector toElementVector(NodeList nodes) {
		
		Vector vector = new Vector();
		
		for (int i = 0; i < nodes.getLength(); i++) {
			Node node = nodes.item(i);
			if (node instanceof Element)
		    	vector.add(node);		    
		}
		
		return vector;	
	}
	
	/*
	 * Convert a NodeList to an array of elements, nodes which are not elements are skipped.
	 */
	private Element[] toElementArray(NodeList nodes) {
		Vector vector = toElementVector(nodes);
		Element[] elements = new Element[vector.size()];
		vector.copyInto(elements);
		return elements;
	}
	
	// Serialize ////////////////////////////////////////////////////////////////////////////////////////////////////////////	
	
	/*
	 * adds the encoding style attribute to the each element in the given array.
	 * noop if encodingStyle is null
	 */
	private void addEncodingStyle(Element[] elements, String encodingStyle) {
				
		// encodingStyle is non-null only if use="encoded"
		if (elements == null || encodingStyle == null)
			return;
		
		for (int i=0; i < elements.length; i++) {
	        if (elements[i] == null)
	        	continue;
	    	elements[i].setAttribute(
	    			Constants.NS_PREFIX_SOAP_ENV + ":" + Constants.ATTR_ENCODING_STYLE, encodingStyle);			
		}
	}
	
	/*
	 * Serialize an array of elements
	 */
	private String serializeElements(Element[] elements) {
	
		StringBuffer buffer = new StringBuffer();
		
		for (int i = 0; i < elements.length; i++) {
					
			String serializedFragment = XMLUtils.serialize(elements[i], true);
			if (serializedFragment == null) {
				// On Some JRE's (Sun java 5) elements with an attribute with the xsi
				// prefix do not serialize properly because the namespace can not
				// be found so the string returned comes back as null. To workaround
				// this problem try adding in the namespace declaration attribute
				// and retry the serialization (bug 144824)			 
				elements[i].setAttribute("xmlns:xsi", Constants.URI_2001_SCHEMA_XSI);
				serializedFragment = XMLUtils.serialize(elements[i], true);
			}
			
			buffer.append(serializedFragment);
			buffer.append(LINE_SEPARATOR);
		}
		
		return buffer.toString();
	}

	/*
	 * Determines if the given message is a request message using RPC style
	 */
	private boolean isRPCRequest(ISOAPMessage message) {
		return 
			!message.getMessageContext().isDocumentStyle() &&							// rpc style
			!Boolean.TRUE.equals(message.getProperty(SOAPTransport.PROP_READ_ONLY));	// not read-only
	}
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISerializer#serialize(int, org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage)
	 */
	public String serialize(int part, ISOAPMessage message) throws TransportException {

		switch (part) {
			case ISOAPMessage.ENVELOPE:
				Element envelope = message.getEnvelope(true);
				
				if (isRPCRequest(message)) {					
					Element body = getSOAPElementNS(envelope, Constants.ELEM_BODY);
					if (body == null)
						body = getSOAPElement(envelope, Constants.ELEM_BODY, message.getNamespaceTable());
					
					if (body != null) {
						Element[] bodyContent = toElementArray(body.getFirstChild().getChildNodes());
						addEncodingStyle(bodyContent, getEncodingInfo(message.getMessageContext())[1]);
					}
				}
				
				String xml = XMLUtils.serialize(envelope, true);
				if (xml == null)
					xml = new String((byte[]) message.getProperty(SOAPTransport.PROP_RAW_BYTES));
				
				return xml;
				
			case ISOAPMessage.HEADER_CONTENT:
				return serializeElements(message.getHeaderContent());
				
			case ISOAPMessage.BODY_CONTENT:				
				Element[] bodyContent = message.getBodyContent();
				
				if (isRPCRequest(message))
					addEncodingStyle(bodyContent, getEncodingInfo(message.getMessageContext())[1]);
				
				return serializeElements(bodyContent);
		}
		
		return "";
	}
	
	// Deserialize //////////////////////////////////////////////////////////////////////////////////////////////////////////		
		
	/*
	 * Retrieve the soap header from the envelope and populate the given message
	 */
	private void processHeader(Element envelope, ISOAPMessage message) {
		
		Element header = getSOAPElementNS(envelope, Constants.ELEM_HEADER);
		if (header == null)
			return;
		
		message.setHeader(header);
		message.setHeaderContent(toElementArray(header.getChildNodes()));
	}
	
	/*
	 * HACK - The root element tag name of the instance document
	 * is ambiguous.  It lands on a very grey area between the SOAP
	 * spec and the WSDL spec.  The two specs do not explicitly define
	 * that the root element tag name must match the name of the
	 * WSDL part.  The hack is to treat elements with different tag names
	 * as instances of the WSDL part.
	 */
	private Element[] fixSOAPResponse(NodeList instanceList, MessageContext context) {
		
		Vector instanceVector = toElementVector(instanceList);		
		Element[] instanceDocuments = new Element[instanceVector.size()];
		
		Operation oper = context.getBindingOperation().getOperation();		
		Map partsMap = oper.getOutput().getMessage().getParts();
		
		if (partsMap.size() == 1) {
			Iterator it = partsMap.values().iterator();
			Part part = (Part) it.next();
			
			String fragName;
			if (part.getElementName() != null)
				fragName = part.getElementName().getLocalPart();
			else
				fragName = part.getName();
		    
		    for (int i = 0; i < instanceVector.size(); i++) {
		    	Element element = (Element) instanceVector.get(i);
		    	
		    	if (!element.getTagName().equals(fragName)) {
		    		Document doc = element.getOwnerDocument();
		    		NodeList children = element.getChildNodes();
		    		NamedNodeMap attributes = element.getAttributes();
		    		element = doc.createElement(fragName);
		    		
		    		for (int j = 0; j < children.getLength(); j++) {
		    			if (children.item(j) != null) {
		    				element.appendChild(children.item(j));
				            // When you append a node from one element to another,
				            // the original element will lose its reference to this node,
				            // therefore, the size of the node list will decrease by 1.
				            j--;
		    			}
		    		}
		    		
		    		for (int j = 0; j < attributes.getLength(); j++) {
		    			Object attr = attributes.item(j);
		    			if (attr != null && (attr instanceof Attr)) {
		    				Attr attribute = (Attr)attr;
		    				element.setAttribute(attribute.getName(), attribute.getValue());
		    			}
		    		}
		    	}
		    	instanceDocuments[i] = element;
		    }
		}
		else
			instanceVector.copyInto(instanceDocuments);
		
		return instanceDocuments;
	}
	
	/*
	 * Retrieve the soap header from the envelope and populate the given message
	 */
	private void processBody(Element envelope, ISOAPMessage message) {
		
		Element body = getSOAPElementNS(envelope, Constants.ELEM_BODY);
		if (body == null)
			return;				
		
		message.setBody(body);
		
		// check for soap fault
		Element fault = getSOAPElementNS(body, Constants.ELEM_FAULT);
	    if (fault != null) {
	    	message.setFault(fault);
	    	return;
	    }
	        	        
	    NodeList instanceList;
	    
	    if (message.getMessageContext().isDocumentStyle())
	    	instanceList = body.getChildNodes();
	    else {
	        NodeList rpcWrapper = body.getElementsByTagNameNS("*", 
	        		message.getMessageContext().getBindingOperation().getOperation().getOutput().getMessage().getQName().getLocalPart());

	        /*
	        * HACK - Some of the web services out on the internet do not
	        * set their RPC wrapper properly.  It should be set to the output
	        * message name of the selected operation.  The hack is to
	        * assume the first element inside the body element is the
	        * RPC wrapper.
	        */
	        if (rpcWrapper.getLength() <= 0)
	        	rpcWrapper = body.getElementsByTagNameNS("*", "*");

	        if (rpcWrapper.getLength() > 0)
	        	instanceList = rpcWrapper.item(0).getChildNodes();
	        else
	        	return;
	    }
	    
	    message.setBodyContent(fixSOAPResponse(instanceList, message.getMessageContext()));
	}
	
	/*
	 * Deserialize the byte array into the given soap message.  The part parameters tells
	 * the method whether the input is the whole envelop or just the contents of the
	 * header or body. 
	 */
	void deserialize(int part, byte[] xml, ISOAPMessage message) throws		
		ParserConfigurationException,
		SAXException,
		IOException {
		
		Element root = XMLUtils.byteArrayToElement(xml, true);		
		
		switch (part) {
			case ISOAPMessage.ENVELOPE:				 
				message.setEnvelope(root);
				processHeader(root, message);
				processBody(root, message);
				break;
			case ISOAPMessage.HEADER_CONTENT:
				message.setHeaderContent(toElementArray(root.getChildNodes()));
				break;
			case ISOAPMessage.BODY_CONTENT:
				message.setBodyContent(toElementArray(root.getChildNodes()));
				break;
		}
	}
	
	/*
	 * Tack on a root element the string which represents a series of elements.
	 * This is needed to deserialize the string.
	 */
	private String addRootElement(String xml, Map namespaceTable) {
		StringBuffer sb = new StringBuffer();
	    sb.append("<root");
	    
	    Iterator iter = namespaceTable.keySet().iterator();
	    while (iter.hasNext()) {
	    	Object uri = iter.next();
	    	Object prefix = namespaceTable.get(uri);
	    	sb.append(" ").append("xmlns:").append(prefix).append("=\"").append(uri).append("\"");
	    }	    
	    
	    sb.append(">").append(xml).append("</root>");
	    return sb.toString();
	}
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.IDeserializer#deserialize(int, java.lang.String, org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage)
	 */
	public void deserialize(int part, String xml, ISOAPMessage message) throws TransportException {
		
		if (part != ISOAPMessage.ENVELOPE)
			xml = addRootElement(xml, message.getNamespaceTable());
		
		try {
			deserialize(part, xml.getBytes(DEFAULT_SOAP_ENCODING), message);
		}
		catch (Exception e) {
			throw new TransportException(e);
		}
	}
}




/*******************************************************************************
 * Copyright (c) 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.transport;

/**
 * An general purpose exception to indicate a problem has occurred when
 * invoking a web service.
 */
public class TransportException extends RuntimeException {

	private static final long serialVersionUID = -1502247230726021403L;

	/**
	 * Constructor.
	 * 
	 * @param message A message about the problem that occurred.
	 */
	public TransportException(String message) {
		super(message);
	}
	
	/**
	 * Constructor that accepts a message and a cause.
	 * 
	 * @param message A message about the problem that occurred.
	 * @param cause The cause for this exception.
	 */
	public TransportException(String message, Throwable cause) {
		super(message, cause);
	}
	
	/**
	 * Constructor that accepts a cause.
	 * 
	 * @param cause The cause for this exception.
	 */
	public TransportException(Throwable cause) {
		super(cause);
	}
}




/*******************************************************************************
 * Copyright (c) 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.transport;

/**
 * ISOAPTransportProvider is a factory for creating ISOAPTransport objects.
 * Anyone who wishes to extend the org.eclipse.wst.ws.explorer.wseTransportProvider
 * extension-point must provide an implementation for this interface. 
 */
public interface ISOAPTransportProvider {

	/**
	 * Method for obtaining a new ISOAPTransport from this provider.
	 * This method should never return null.
	 * 
	 * @return A new ISOAPTransport object.
	 */
	public ISOAPTransport newTransport();
}




/*******************************************************************************
 * Copyright (c) 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.wsdl.util;

import java.util.Hashtable;
import java.util.Iterator;
import java.util.Map;
import java.util.Vector;

import javax.wsdl.Part;
import javax.xml.parsers.ParserConfigurationException;

import org.eclipse.wst.ws.internal.explorer.platform.wsdl.constants.WSDLModelConstants;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.datamodel.WSDLOperationElement;
import org.eclipse.wst.ws.internal.explorer.platform.wsdl.fragment.IXSDFragment;
import org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage;
import org.eclipse.wst.wsdl.binding.soap.SOAPHeader;
import org.w3c.dom.Element;

/**
 * This class has some common routines used by the Web Services explorer to work with ISOAPMessages.
 */
public class SOAPMessageUtils {
	
	/**
	 * Decodes namespace declarations that have been encoded by WSE into the operation element of the WSDL model.
	 * The decoded declarations will be added to the given namespace table.
	 *  
	 * @param soapEnvelopeNamespaceTable The namespace table to populate.
	 * @param operElement The operation element with the encoded namespace declarations.
	 * @return True if new namespace declarations are found and added to the namespace table, false otherwise.
	 */
	public static boolean decodeNamespaceTable(Hashtable soapEnvelopeNamespaceTable, WSDLOperationElement operElement) {
			
		boolean updated = false;

		String[] nsDeclarations = (String[]) operElement.getPropertyAsObject(WSDLModelConstants.PROP_SOURCE_CONTENT_NAMESPACE);
		if (nsDeclarations == null)
			return false;

		// each namespace declaration is decoded into 2 parts: the prefix 
		// in element [0] and the namespace uri in element [1].
		for (int i = 0; i < nsDeclarations.length; i++) {
			String[] prefix_ns = SoapHelper.decodeNamespaceDeclaration(nsDeclarations[i]);
			
			// check if the namespace uri is already a key in the namespace table
			// if it is, don't add it
			if (!soapEnvelopeNamespaceTable.containsKey(prefix_ns[1])) {
			    soapEnvelopeNamespaceTable.put(prefix_ns[1], prefix_ns[0]);
			    updated = true;
			}
		}
		
		return updated;
	}

	/**
	 * Populate the header content of the given ISOAPMessage using the values from WSE's fragment model
	 * 
	 * @param soapEnvelopeNamespaceTable A namespace table to use during this operation.
	 * @param operElement Access WSE's fragments via this operation element. 
	 * @param soapMessage The ISOAPMessage to populate.
	 * @throws ParserConfigurationException
	 */
	public static void setHeaderContentFromModel(Hashtable soapEnvelopeNamespaceTable, WSDLOperationElement operElement, ISOAPMessage soapMessage)
		throws ParserConfigurationException {
	    
		Vector headerEntries = new Vector();
	    
	    Iterator it = operElement.getSOAPHeaders().iterator();
	    while (it.hasNext()) {
	    	SOAPHeader soapHeader = (SOAPHeader) it.next();
	    	boolean isUseLiteral = "literal".equals(soapHeader.getUse());           
	    	IXSDFragment frag = (IXSDFragment) operElement.getHeaderFragment(soapHeader);
	    	Element[] instanceDocuments = frag.genInstanceDocumentsFromParameterValues(
	    			!isUseLiteral, soapEnvelopeNamespaceTable, soapMessage.getEnvelope(false).getOwnerDocument());
	    	for (int i = 0; i < instanceDocuments.length; i++) {
	    		if (instanceDocuments[i] == null)
	    			continue;
	    		headerEntries.addElement(instanceDocuments[i]);
	    	}
	    }

	    Element[] headerContent = new Element[headerEntries.size()];
	    headerEntries.copyInto(headerContent);
	    
	    soapMessage.setHeaderContent(headerContent);
	}

	/**
	 * Populate the body content of the given ISOAPMessage using the values from WSE's fragment model
	 * 
	 * @param soapEnvelopeNamespaceTable A namespace table to use during this operation.
	 * @param operElement Access WSE's fragments via this operation element. 
	 * @param soapMessage The ISOAPMessage to populate.
	 * @throws ParserConfigurationException
	 */
	public static void setBodyContentFromModel(Hashtable soapEnvelopeNamespaceTable, WSDLOperationElement operElement, ISOAPMessage soapMessage)
		throws ParserConfigurationException {
		
	    Vector bodyEntries = new Vector();
	    boolean isUseLiteral = operElement.isUseLiteral();

	    Iterator it = operElement.getOrderedBodyParts().iterator();
	    while (it.hasNext()) {
	    	Part part = (Part)it.next();
	    	IXSDFragment frag = (IXSDFragment) operElement.getFragment(part);
	    	Element[] instanceDocuments = frag.genInstanceDocumentsFromParameterValues(
	    			 !isUseLiteral, soapEnvelopeNamespaceTable, soapMessage.getEnvelope(false).getOwnerDocument());
	    	for (int i = 0; i < instanceDocuments.length; i++) {
	    		if (instanceDocuments[i] == null)
	    			continue;
	    		bodyEntries.addElement(instanceDocuments[i]);
	    	}
	    }

	    Element[] bodyContent = new Element[bodyEntries.size()];
	    bodyEntries.copyInto(bodyContent);
	    
	    soapMessage.setBodyContent(bodyContent);
	}
	
	/**
	 * Given an array of elements, this method will return the index of the first element that matches
	 * the given Part.  A match is determined by comparing the fully qualified names of the Part and Elements.
	 * 
	 * @param part The Part 
	 * @param elements The array of Elements
	 * @param namespaceTable A namespace table for looking up namespace prefixes.
	 * @param fragName Name of the Part's fragment (essentially the Part's local name).
	 * @param start The index to begin the search.
	 * @return The index of the first matching element, or -1 if no match is found.
	 */
	public static int findFirstMatchingElement(Part part, Element[] elements, Map namespaceTable, String fragName, int start) {
		
		String namespaceURI = null;
		String prefix = null;
		
		// try to get the prefix
		if (part.getElementName() != null) {
			namespaceURI = part.getElementName().getNamespaceURI();
			prefix = (String) namespaceTable.get(namespaceURI);					
		}
		
		for (int i = start; i < elements.length; i++) {			
			Element element = elements[i];
			String name = element.getTagName();
			
			// try to get prefix again, the namespace declaration can be directly on the element
			if (prefix == null && namespaceURI != null)
				prefix = element.lookupPrefix(namespaceURI);
			
			if (prefix == null && name.equals(fragName))
				return i;
			else if (prefix != null && name.equals(prefix + ":" + fragName))
				return i;
		}
				
		return -1;
	}
}




/*******************************************************************************
 * Copyright (c) 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.transport;

import javax.wsdl.BindingOperation;
import javax.wsdl.Definition;
import javax.wsdl.extensions.ExtensibilityElement;

/**
 * A MessageContext object holds information about the message that is to be
 * sent on a web service invocation.  This information is passed to the
 * ISOAPTransport so that it can construct an appropriate ISOAPMessage to
 * handle the invocation.
 */
public class MessageContext {
	
	private Definition definition;
	private ExtensibilityElement bindingProtocol;
	private BindingOperation bindingOperation;	
	private boolean documentStyle;			
	
	/**
	 * Sets a reference to the WSDL definition.
	 * 
	 * @param definition The WSDL definition.
	 */
	public void setDefinition(Definition definition) {
		this.definition = definition;
	}
	
	/**
	 * Returns the WSDL definition.
	 * 
	 * @return The WSDL definition.
	 */
	public Definition getDefinition() {
		return definition;
	}
	
	/**
	 * Sets a reference to the binding extensibility element in the WSDL document.
	 * For a web service that uses the SOAP protocol, this will be an instance of
	 * javax.wsdl.extensions.soap.SOAPBinding
	 * 
	 * @param bindingProtocol The binding extensibility element.
	 */
	public void setBindingProtocol(ExtensibilityElement bindingProtocol) {
		this.bindingProtocol = bindingProtocol;		
	}
	
	/**
	 * Returns the binding extensibility element.
	 * 
	 * @return The binding extensibility element.
	 */
	public ExtensibilityElement getBindingProtocol() {
		return bindingProtocol;
	}
	
	/**
	 * Sets a reference to the binding operation element in the WSDL document.
	 * 
	 * @param bindingOperation The binding operation element.
	 */
	public void setBindingOperation(BindingOperation bindingOperation) {
		this.bindingOperation = bindingOperation;
	}
	
	/**
	 * Returns the binding operation element.
	 * 
	 * @return The binding operation element.
	 */
	public BindingOperation getBindingOperation() {
		return bindingOperation;
	}		
		
	/**
	 * Sets the flag on whether the message created from this MessageContext
	 * is document style or not.
	 * 
	 * @param documentStyle True for document style, false otherwise.
	 */
	public void setDocumentStyle(boolean documentStyle) {
		this.documentStyle = documentStyle;
	}
	
	/**
	 * Returns the document style property.
	 * 
	 * @return The document style property.
	 */
	public boolean isDocumentStyle() {
		return documentStyle;
	}
}




/*******************************************************************************
 * Copyright (c) 2001, 2005 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 *     IBM Corporation - initial API and implementation
 *******************************************************************************/

package org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport;

import java.io.FilterInputStream;
import java.io.IOException;
import java.io.InputStream;

public class ChunkedInputStream extends FilterInputStream
{
  protected long chunkSize = 0l;
  protected volatile boolean closed = false;
  private static final int maxCharLong = (Long.toHexString(Long.MAX_VALUE)).toString().length();

  private ChunkedInputStream()
  {
    super(null);
  }

  public ChunkedInputStream(InputStream is)
  {
    super(is);
  }

  public int read() throws IOException
  {
    byte[] d = new byte[1];
    int rc = read(d, 0, 1);
    return rc > 0 ? (d[0] & 0xFF) : rc;
  }

  public int read(byte[] b) throws IOException
  {
    return read(b, 0, b.length);
  }

  public synchronized int read(byte[] b, int off, int len) throws IOException
  {
    if (closed)
      return -1;

    int totalread = 0;
    int bytesread = 0;
    try
    {
      do
      {
        if (chunkSize < 1L)
        {
          if (0l == getChunked())
          {
            if (totalread == 0)
              return -1;
            else
              return totalread;
          }
        }
        bytesread = in.read(b, off + totalread, Math.min(len - totalread, (int) Math.min(chunkSize, Integer.MAX_VALUE)));
        if (bytesread > 0)
        {
          totalread += bytesread;
          chunkSize -= bytesread;
        }
      }
      while (len - totalread > 0 && bytesread > -1);
    }
    catch (IOException e)
    {
      closed = true;
      throw e;
    }
    return totalread;
  }

  public long skip(final long n) throws IOException
  {
    if (closed)
      return 0;
    long skipped = 0l;
    byte[] b = new byte[1024];
    int bread = -1;
    do
    {
      bread = read(b, 0, b.length);
      if (bread > 0)
        skipped += bread;
    }
    while (bread != -1 && skipped < n);
    return skipped;
  }

  public int available() throws IOException
  {
    if (closed)
      return 0;
    int rc = (int) Math.min(chunkSize, Integer.MAX_VALUE);
    return Math.min(rc, in.available());
  }

  protected long getChunked() throws IOException
  {
    //StringBuffer buf= new StringBuffer(1024);
    byte[] buf = new byte[maxCharLong + 2];
    int bufsz = 0;
    chunkSize = -1L;
    int c = -1;
    do
    {
      c = in.read();
      if (c > -1)
      {
        if (c != '\r' && c != '\n' && c != ' ' && c != '\t')
        {
          buf[bufsz++] = ((byte) c);
        }
      }
    }
    while (c > -1 && (c != '\n' || bufsz == 0) && bufsz < buf.length);
    if (c < 0)
    {
      closed = true;
    }
    String sbuf = new String(buf, 0, bufsz);
    if (bufsz > maxCharLong)
    {
      closed = true;
      throw new IOException("Chunked input stream failed to receive valid chunk size:" + sbuf);
    }
    try
    {
      chunkSize = Long.parseLong(sbuf, 16);
    }
    catch (NumberFormatException ne)
    {
      closed = true;
      throw new IOException("'" + sbuf + "' " + ne.getMessage());
    }
    if (chunkSize < 1L)
      closed = true;
    if (chunkSize != 0L && c < 0)
    {
      //If chunk size is zero try and be tolerant that there maybe no cr or lf
      // at the end.
      throw new IOException("HTTP Chunked stream closed in middle of chunk.");
    }
    if (chunkSize < 0L)
      throw new IOException("HTTP Chunk size received " + chunkSize + " is less than zero.");
    return chunkSize;
  }

  public void close() throws IOException
  {
    synchronized (this)
    {
      if (closed)
        return;
      closed = true;
    }
    byte[] b = new byte[1024];
    int bread = -1;
    do
    {
      bread = read(b, 0, b.length);
    }
    while (bread != -1);
  }

  /*
   * public void mark(int readlimit)
   * {
   * }
   */

  public void reset() throws IOException
  {
    throw new IOException("Don't support marked streams");
  }

  public boolean markSupported()
  {
    return false;
  }
}




/*******************************************************************************
 * Copyright (c) 2005 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 * 
 * Contributors:
 *     IBM Corporation - initial API and implementation
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.util;

import java.io.UnsupportedEncodingException;
import java.net.URLDecoder;
import java.net.URLEncoder;

/**
 * This class contains utility methods for managing URLs
 * as used by the Web Services Explorer Web application.
 * @author cbrealey@ca.ibm.com
 */
public final class URLUtils
{
	/**
	 * Objects of this class should not be constructed.
	 */
	private URLUtils ()
	{
	}

	/**
	 * UTF-8
	 */
	public static final String UTF8 = "UTF-8";

	/**
	 * Equivalent to {@link #encode(String,String)}
	 * with second parameter set to the "UTF-8" encoding.
	 * @param s The string to encode.
	 * @return The encoded string.
	 */
	public static String encode(String s)
	{
		return encode(s,UTF8);
	}
	
	/**
	 * Equivalent to {@link URLEncoder#encode(String,String)},
	 * only throws an unchecked {@link RuntimeException} wrapped
	 * around an {@link UnsupportedEncodingException} instead of
	 * an {@link UnsupportedEncodingException}.
	 * @param s The string to encode.
	 * @param enc The encoding to use.
	 * @return The encoded string.
	 */
	public static String encode(String s, String enc)
	{
		try
		{
			return URLEncoder.encode(s,enc);
		}
		catch (UnsupportedEncodingException e)
		{
			// TODO: MSG_BROKEN_VM_DOES_NOT_SUPPORT_UTF-8
			throw new RuntimeException("%MSG_BROKEN_VM_DOES_NOT_SUPPORT_UTF-8",e);
		}
	}
	
	/**
	 * Equivalent to {@link #decode(String,String)}
	 * with second parameter set to the "UTF-8" encoding.
	 * @param s The string to decode.
	 * @return The decoded string.
	 */
	public static String decode(String s)
	{
		return decode(s,UTF8);
	}
	
	/**
	 * Equivalent to {@link URLEncoder#decode(String,String)},
	 * only throws an unchecked {@link RuntimeException} wrapped
	 * around an {@link UnsupportedEncodingException} instead of
	 * an {@link UnsupportedEncodingException}.
	 * @param s The string to decode.
	 * @param enc The encoding to use.
	 * @return The decoded string.
	 */
	public static String decode(String s, String enc)
	{
		try
		{
			return URLDecoder.decode(s,enc);
		}
		catch (UnsupportedEncodingException e)
		{
			// TODO: MSG_BROKEN_VM_DOES_NOT_SUPPORT_UTF-8
			throw new RuntimeException("%MSG_BROKEN_VM_DOES_NOT_SUPPORT_UTF-8",e);
		}
	}
}




/*******************************************************************************
 * Copyright (c) 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.transport;

import java.util.Map;

/**
 * A type of TransportException that can be thrown when the transport protocol
 * is HTTP.  The status code of the HTTP response is captured in this
 * exception and passed up to the Web Services Explorer.
 */
public class HTTPTransportException extends TransportException {

	private static final long serialVersionUID = 8277180731798858877L;
	
	private int statusCode;
	private Map headers;
	
	/**
	 * Constructor.
	 * 
	 * @param statusCode The HTTP status code.
	 * @param message A message about the problem that occurred.
	 * @param headers A map of the HTTP headers.
	 */
	public HTTPTransportException(int statusCode, String message, Map headers) {
		super(message);
		this.statusCode = statusCode;
		this.headers = headers;
	}
	
	/**
	 * Returns the HTTP status code used to create this exception.
	 * 
	 * @return The HTTP status code.
	 */
	public int getStatusCode() {
		return statusCode;
	}
	
	/**
	 * Retrieve the HTTP header for the given key
	 * 
	 * @param key The key value.
	 * @return The HTTP header value for key, or null if there is no such header.
	 */
	public String getHeader(String key) {
	    Object value = headers.get(key);
	    if (value != null)
	    	return value.toString();
	    else
	    	return null;
	}
}




/*******************************************************************************
 * Copyright (c) 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.transport;

import java.util.Map;

import org.w3c.dom.Element;

/**
 * The ISOAPMessage represents a SOAP message in a web service invocation made by the
 * Web Services Explorer's transport stack.
 * <br/>
 * <br/>
 * The setters of ISOAPMessage are called by Web Services Explorer to populate the
 * message before sending.  WSE does not guarantee that all message elements it sets
 * will have the same owner document.
 */
public interface ISOAPMessage {

	/**
	 * ISOAPMessage defines this property for storing the SOAP action value in
	 * a web service invocation.  This property will be set by Web Services Explorer
	 * prior to passing the message to {@link ISOAPTransport#send(String, String, String, ISOAPMessage)}
	 */
	String PROP_SOAP_ACTION = "prop_soap_action";
	
	/**
	 * This value is used when serializing and deserializing a message.  It indicates the operation
	 * is working with the entire SOAP envelope element. 
	 */
	int ENVELOPE = 0;
	
	/**
	 * This value is used when serializing and deserializing a message.  It indicates the operation
	 * is working with the elements inside the SOAP header element.
	 */
	int HEADER_CONTENT = 1;
	
	/**
	 * This value is used when serializing and deserializing a message.  It indicates the operation
	 * is working with the elements inside the SOAP body element.
	 */
	int BODY_CONTENT = 2;

	/**
	 * Returns the MessageContext associated with this message.  The MessageContext is created
	 * by the Web Services Explorer and passed to the transport stack during message creation.  
	 * Implementers of ISOAPMessage should store a reference to the MessageContext.
	 * 
	 * @return The MessageContext encasulating information about the web service operation. 
	 * @see ISOAPTransport#newMessage(MessageContext)
	 */
	public MessageContext getMessageContext();

	/**
	 * Sets a property in this ISOAPMessage.
	 * 
	 * @param key The key (name) of the property
	 * @param value The value of the property.
	 */
	public void setProperty(String key, Object value);

	/**
	 * Retrieves a property from this ISOAPMessage.
	 * 
	 * @param key The key (name) of the property to retrieve.
	 * @return The value assoicated with the given key, or null if there's no such property.
	 */
	public Object getProperty(String key);

	/**
	 * The namespace table holds the namespace declaraions that are on the envelope element
	 * of the SOAP message.  The table's keys are the namespace URIs and the values are the
	 * associated namespace prefixes.
	 * <br/>
	 * <br/>
	 * The effect of calling this method is that the declarations in the namespace table
	 * argument should add to or replace the declarations on the envelope.  This API does
	 * not specify what happens to existing declarations on the envelope which are not
	 * in the namespace table passed in.
	 * 
	 * @param namespaceTable The namespace table
	 */
	public void setNamespaceTable(Map namespaceTable);

	/**
	 * Returns a table of the namespace declarations that are on the envelope element of the
	 * SOAP message.  The table's keys are the namespace URIs and the values are the
	 * associated namespace prefixes.
	 * <br/>
	 * <br/>
	 * The namespace table returned by this method may be modified by the Web Services
	 * Explorer and later updated back to the message via the setNamesapceTable() method.
	 * 
	 * @return A table of namespace URIs to prefixes on the SOAP envelope.
	 */
	public Map getNamespaceTable();

	/**
	 * Sets the envelope element of this message.
	 * 
	 * @param envelope The envelope element.
	 */
	public void setEnvelope(Element envelope);

	/**
	 * Returns the envelope element of this message.  The deep parameter dictates whether
	 * the method returns the whole envelope with all its descendants or just the envelope 
	 * element itself.
	 * 
	 * @param deep If true, the envelope and its descendants are returned, otherwise only
	 * the envelope element itself is returned.
	 * @return An element.
	 */
	public Element getEnvelope(boolean deep);

	/**
	 * Sets the header element of this message.
	 * 
	 * @param header The header element.
	 */
	public void setHeader(Element header);

	/**
	 * Returns the header element of this message.  The deep parameter dictates whether
	 * the method returns the whole header with all its descendants or just the header 
	 * element itself.
	 * 
	 * @param deep If true, the header and its descendants are returned, otherwise only
	 * the header element itself is returned.
	 * @return An element.
	 */
	public Element getHeader(boolean deep);

	/**
	 * Sets an array of elements that goes into the message's header.
	 * 
	 * @param headerContent An array of elements.
	 */
	public void setHeaderContent(Element[] headerContent);

	/**
	 * Returns the array of elements that are inside the message's header.
	 * 
	 * @return An array of elements.
	 */
	public Element[] getHeaderContent();

	/**
	 * Sets the body element of this message.  For an RPC style message, the first child
	 * element of the body should be the RPC wrapper element.
	 * 
	 * @param body The body element.
	 */
	public void setBody(Element body);

	/**
	 * Returns the body of this message.  The deep parameter dictates whether
	 * the method returns the whole body with all its descendants elements or just the
	 * body.  For an RPC style message, the first child element of the 
	 * body should be the RPC wrapper element, regardless of the value of the deep
	 * parameter.
	 * 
	 * @param deep If true, the body and its descendants are returned, otherwise only
	 * the body (and the RPC wrapper element if the message is RPC style) is returned.
	 * @return An element.
	 */	
	public Element getBody(boolean deep);

	/**
	 * Sets an array of elements that goes into the message's body.  For an RPC style
	 * message, the body contents are the elements inside the RPC wrapper element.
	 * 
	 * @param bodyContent An array of elements.
	 */
	public void setBodyContent(Element[] bodyContent);

	/**
	 * Returns the array of elements that are inside the message's body.  For an RPC style
	 * message, the body contents are the elements inside the RPC wrapper element.
	 * 
	 * @return An array of elements.
	 */
	public Element[] getBodyContent();

	/**
	 * Set the fault element for this message, if any.
	 * 
	 * @param fault A fault element.
	 */
	public void setFault(Element fault);

	/**
	 * Returns the fault element, if any.
	 * 
	 * @return The fault element or null if no fault has occurred.
	 */
	public Element getFault();

	/**
	 * Returns the XML serialized form of this ISOAPMessage.
	 * 
	 * @return An XML string.
	 * @see ISerializer
	 * @throws TransportException 
	 */
	public String toXML() throws TransportException;

}




/*******************************************************************************
 * Copyright (c) 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport;

import javax.wsdl.extensions.ExtensibilityElement;
import javax.wsdl.extensions.soap.SOAPBinding;

import org.apache.axis.Constants;
import org.eclipse.wst.ws.internal.explorer.plugin.ExplorerPlugin;
import org.eclipse.wst.ws.internal.explorer.transport.IDeserializer;
import org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage;
import org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransport;
import org.eclipse.wst.ws.internal.explorer.transport.ISerializer;
import org.eclipse.wst.ws.internal.explorer.transport.MessageContext;
import org.eclipse.wst.ws.internal.explorer.transport.SOAPMessage;
import org.eclipse.wst.ws.internal.explorer.transport.TransportException;
import org.eclipse.wst.ws.internal.parser.discovery.NetUtils;

/**
 * WSE's default implementation of ISOAPTransport
 */
public class SOAPTransport implements ISOAPTransport {

	static final String PROP_READ_ONLY = "prop_read_only";
	static final String PROP_RAW_BYTES = "prop_raw_bytes";
	
	/*
	 * Constructor.
	 */
	SOAPTransport() {}

	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransport#newSerializer()
	 */
	public ISerializer newSerializer() {		
		return new SOAPMessageProcessor();
	}
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransport#newDeserializer()
	 */
	public IDeserializer newDeserializer() {
		return new SOAPMessageProcessor();
	}

	/*
	 * Check if the binding is supported
	 */
	private void checkBinding(ExtensibilityElement binding) throws TransportException {
		
		String bindingURI = binding.getElementType().getNamespaceURI();
		
		// looking for SOAP 1.1 binding
		if (!(binding instanceof SOAPBinding) ||
			!Constants.URI_WSDL11_SOAP.equals(bindingURI))
			throw new TransportException(ExplorerPlugin.getMessage("%MSG_ERROR_UNSUPPORTED_BINDING", new String[] { bindingURI }));
	}
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransport#newMessage(org.eclipse.wst.ws.internal.explorer.transport.MessageContext)
	 */
	public ISOAPMessage newMessage(MessageContext context) throws TransportException {
		
		checkBinding(context.getBindingProtocol());
		
		SOAPMessageProcessor processor = new SOAPMessageProcessor();
		ISOAPMessage message = new SOAPMessage(context, processor);
		processor.initMessage(message);			
		return message;				
	}
	
	/*
	 * Check if the message uses a binding and transport that we support.
	 */
	private void checkMessage(ISOAPMessage message) throws TransportException {
		
		ExtensibilityElement binding = message.getMessageContext().getBindingProtocol(); 
		checkBinding(binding);
		
		SOAPBinding soapBinding = (SOAPBinding) binding; 
			
		if (!Constants.URI_SOAP11_HTTP.equals(soapBinding.getTransportURI()))
			throw new TransportException(ExplorerPlugin.getMessage("%MSG_ERROR_UNSUPPORTED_TRANSPORT", new String[] { soapBinding.getTransportURI() }));
	}
		
	/*
	 * Create an HTTPTransport for internal use.
	 */
	private HTTPTransport createInternalTransport(String username, String password) {

		HTTPTransport internalTransport = new HTTPTransport();
		    
		if (username != null && password != null) {
			internalTransport.setHttpBasicAuthUsername(username);
			internalTransport.setHttpBasicAuthPassword(password);
		}
		
		return internalTransport;
	}	
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransport#send(java.lang.String, java.lang.String, java.lang.String, org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage)
	 */
	public ISOAPMessage send(String url, String username, String password, ISOAPMessage message) throws TransportException {
		
		checkMessage(message);			
								
		try {
			HTTPTransport internalTransport = createInternalTransport(username, password);
			internalTransport.send(NetUtils.createURL(url), (String) message.getProperty(ISOAPMessage.PROP_SOAP_ACTION), message.toXML());
			
			SOAPMessageProcessor processor = new SOAPMessageProcessor();
			ISOAPMessage reply = new SOAPMessage(message.getMessageContext(), processor);
			reply.setProperty(PROP_READ_ONLY, Boolean.TRUE);
			
			byte[] rawBytes = internalTransport.receiveBytes();
			
			try { 
				processor.deserialize(ISOAPMessage.ENVELOPE, rawBytes, reply);
			}
			catch (Exception e) {
				// if error occurs during deserialization, we want to save a copy of the actual raw bytes
				reply.setProperty(PROP_RAW_BYTES, rawBytes);
			}
					
			return reply;
		}
		catch (TransportException e) {
			throw e;
	    }
	    catch (Exception e) {
	    	throw new TransportException(e);
	    }			
	}		
}




/*******************************************************************************
 * Copyright (c) 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.transport;

/**
 * The ISOAPTransport is the core piece of the Web Services Explorer transport stack.
 * It is responsible for invoking the web service and it also acts as the factory for
 * creating ISerialier, IDeserializer, and ISOAPMessage instances which make up the
 * rest of the WSE transport.
 */
public interface ISOAPTransport {		

	/**
	 * Factory method for ISerializer.
	 * 
	 * @return An instance of ISerializer.
	 */
	public ISerializer newSerializer();
	
	/**
	 * Factory method for IDeserializer.
	 * 
	 * @return An instance of IDeserializer.
	 */
	public IDeserializer newDeserializer();
	
	/**
	 * Factory method for ISOAPMessage.
	 * 
	 * @param context MessageContext encapsulating information about the web service operation.
	 * @return An instance of ISOAPMessage.
	 * @throws TransportException
	 */
	public ISOAPMessage newMessage(MessageContext context) throws TransportException;
	
	/**
	 * Invokes the web service operation by sending the SOAP message, then parsing the results
	 * into a response ISOAPMessage.
	 * 
	 * @param url The endpoint URL.
	 * @param username Username to use for basic auth protected endpoints.  Set to null if not required.  
	 * @param password Password to use for basic auth protected endpoints.  Set to null if not required.
	 * @param message The SOAP request message.
	 * @return An ISOAPMesage representing the response from the web service invocation.
	 * @throws TransportException
	 */
	public ISOAPMessage send(String url, String username, String password, ISOAPMessage message) throws TransportException;
}




/*******************************************************************************
 * Copyright (c) 2004, 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 * 
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20060131   125777 jesper@selskabet.org - Jesper S Moller
 * 20060222   118019 andyzhai@ca.ibm.com - Andy Zhai
 * 20060222   128564 jesper@selskabet.org - Jesper S Moller
 * 20060823    99034 makandre@ca.ibm.com - Andrew Mak, WSE support for basic-authenticating firewalls
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport;

import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;
import java.net.SocketTimeoutException;
import java.net.URL;
import java.net.UnknownHostException;
import java.util.Hashtable;
import javax.net.ssl.SSLSocketFactory;

import org.eclipse.wst.ws.internal.explorer.platform.util.XMLUtils;
import org.eclipse.wst.ws.internal.explorer.transport.HTTPTransportException;
import org.w3c.dom.Element;
import sun.misc.BASE64Encoder;

public class HTTPTransport
{
  private final String SYS_PROP_HTTPS_PROXY_HOST = "https.proxyHost";
  private final String SYS_PROP_HTTPS_PROXY_PORT = "https.proxyPort";
  private final String SYS_PROP_HTTPS_NON_PROXY_HOSTS = "https.nonProxyHosts";
  private final String SYS_PROP_HTTP_PROXY_HOST = "http.proxyHost";
  private final String SYS_PROP_HTTP_PROXY_PORT = "http.proxyPort";
  private final String SYS_PROP_HTTP_PROXY_USER_NAME = "http.proxyUserName";
  private final String SYS_PROP_HTTP_PROXY_PASSWORD = "http.proxyPassword";
  private final String SYS_PROP_HTTP_NON_PROXY_HOSTS = "http.nonProxyHosts";
  
  private final String HTTP_METHOD = "POST";
  private final String HTTP_CONNECT = "CONNECT";
  private final String HTTP_VERSION_1_0 = "HTTP/1.0";
  private final String HTTP_VERSION = "HTTP/1.1";
  private final String HTTP_HEADER_SOAP_ACTION = "SOAPAction";
  public static final String HTTP_HEADER_AUTH = "Authorization";
  public static final String HTTP_HEADER_WWW_AUTH = "WWW-Authenticate";
  private final String HTTP_HEADER_PROXY_AUTH = "Proxy-authorization";
  private final String HTTP_HEADER_COOKIE = "Cookie";
  private final String HTTP_HEADER_COOKIE2 = "Cookie2";
  private final String HTTP_HEADER_HOST = "Host";
  private final String HTTP_HEADER_CONTENT_TYPE = "Content-Type";
  public static final String HTTP_HEADER_CONTENT_LENGTH = "Content-Length";
  private final String HTTP_HEADER_ACCEPT = "Accept";
  private final String HTTP_HEADER_USER_AGENT = "User-Agent";
  private final String HTTP_HEADER_CACHE_CONTROL = "Cache-Control";
  private final String HTTP_HEADER_PRAGMA = "Pragma";
  private final String HTTP_HEADER_TRANSFER_ENCODEING = "Transfer-Encoding";
  private final String HTTP_HEADER_CONNECTION = "Connection";
  
  private final int HTTP_CODE_CONTINUE = 100;
  private final int HTTP_CODE_OK = 200;
  private final int HTTP_CODE_EXCEPTION = 300;

  private final String IBM_WEB_SERVICES_EXPLORER = "IBM Web Services Explorer";
  private final String TEXT_XML = "text/xml";
  private final String CONTENT_TYPE_VALUE = "text/xml; charset=utf-8";
  private final String ACCEPT_VALUE = "application/soap+xml, application/dime, multipart/related, text/*";
  public static final String BASIC = "Basic";
  private final String NO_CACHE = "no-cache";
  private final String CHUNKED = "chunked";
  private final String CLOSE = "close";
  private final String HTTPS = "https";
  private final char QUOTE = '\"';
  public static final char COLON = ':';
  private final char SPACE = ' ';
  private final char TAB = '\t';
  private final char R = '\r';
  private final char N = '\n';
  private final char ROOT = '/';
  private final String NEW_LINE = "\r\n";
  private final String EMPTY_STRING = "";

  private final int DEFAULT_HTTP_PORT = 80;
  private final int DEFAULT_HTTPS_PORT = 443;
  private final String DEFAULT_SOAP_ENCODING = "UTF-8";
  private final String DEFAULT_HTTP_HEADER_ENCODING = "iso-8859-1";
  private final boolean DEFAULT_CASE_SENSITIVE_FOR_HOST_NAME = false;

  private String httpBasicAuthUsername;
  private String httpBasicAuthPassword;
  private boolean maintainSession = false;
  private String cookie;
  private String cookie2;
  private HTTPResponse httpResponse;

  public String getHttpBasicAuthUsername()
  {
    return httpBasicAuthUsername;
  }
  
  public void setHttpBasicAuthUsername(String httpBasicAuthUsername)
  {
    this.httpBasicAuthUsername = httpBasicAuthUsername;
  }
  
  public String getHttpBasicAuthPassword()
  {
    return httpBasicAuthPassword;
  }
  
  public void setHttpBasicAuthPassword(String httpBasicAuthPassword)
  {
    this.httpBasicAuthPassword = httpBasicAuthPassword;
  }

  private String getMethod(URL url)
  {
    StringBuffer sb = new StringBuffer(HTTP_METHOD);
    sb.append(SPACE);
    String protocol = url.getProtocol();
    String httpProxyHost = System.getProperty(SYS_PROP_HTTP_PROXY_HOST);
    String httpsProxyHost = System.getProperty(SYS_PROP_HTTPS_PROXY_HOST);
    if (protocol.equalsIgnoreCase("http") && httpProxyHost != null && httpProxyHost.length() > 0)
    {
      sb.append(url.toString());
    }
    else if (protocol.equalsIgnoreCase("https") && httpsProxyHost != null && httpsProxyHost.length() > 0)
    {
      sb.append(url.toString());
    }
    else
    {
      String file = url.getFile();
      if (file != null && file.length() > 0)
        sb.append(file);
      else
        sb.append(ROOT);
    }
    sb.append(SPACE);
    sb.append(HTTP_VERSION);
    sb.append(NEW_LINE);
    return sb.toString();
  }

  private String getHost(URL url)
  {
    StringBuffer sb = new StringBuffer(HTTP_HEADER_HOST);
    sb.append(COLON);
    sb.append(SPACE);
    sb.append(url.getHost());
    sb.append(COLON);
    int port = url.getPort();
    if (port > 0)
      sb.append(String.valueOf(port));
    else if (url.getProtocol().equalsIgnoreCase(HTTPS))
      sb.append(DEFAULT_HTTPS_PORT);
    else
      sb.append(DEFAULT_HTTP_PORT);
    sb.append(NEW_LINE);
    return sb.toString();
  }
  
  private String getContentType()
  {
    return getHTTPHeader(HTTP_HEADER_CONTENT_TYPE, CONTENT_TYPE_VALUE);
  }
  
  private String getContentLength(byte[] payloadAsBytes)
  {
    return getHTTPHeader(HTTP_HEADER_CONTENT_LENGTH, String.valueOf(payloadAsBytes.length));
  }

  private String getSOAPAction(String soapAction)
  {
    StringBuffer sb = new StringBuffer(HTTP_HEADER_SOAP_ACTION);
    sb.append(COLON);
    sb.append(SPACE);
    sb.append(QUOTE);
    if (soapAction != null)
      sb.append(soapAction);
    sb.append(QUOTE);
    sb.append(NEW_LINE);
    return sb.toString();
  }
  
  private String getCookie()
  {
    if (maintainSession)
      return getHTTPHeader(HTTP_HEADER_COOKIE, cookie);
    else
      return EMPTY_STRING;
  }
  
  private String getCookie2()
  {
    if (maintainSession)
      return getHTTPHeader(HTTP_HEADER_COOKIE2, cookie2);
    else
      return EMPTY_STRING;
  }
  
  private String getWWWAuthentication()
  {
    if (httpBasicAuthUsername != null && httpBasicAuthPassword != null)
    {
      StringBuffer sb = new StringBuffer(httpBasicAuthUsername);
      sb.append(COLON);
      sb.append(httpBasicAuthPassword);
      BASE64Encoder encoder = new BASE64Encoder();
      String encodedUserNamePassword = encoder.encode(sb.toString().getBytes());
      sb.setLength(0);
      sb.append(HTTP_HEADER_AUTH);
      sb.append(COLON);
      sb.append(SPACE);
      sb.append(BASIC);
      sb.append(SPACE);
      sb.append(encodedUserNamePassword);
      sb.append(NEW_LINE);
      return sb.toString();
    }
    else
      return EMPTY_STRING;
  }
  
  private String getProxyAuthentication()
  {
    String proxyUserName = System.getProperty(SYS_PROP_HTTP_PROXY_USER_NAME);
    String proxyPassword = System.getProperty(SYS_PROP_HTTP_PROXY_PASSWORD);
    if (proxyUserName != null && proxyPassword != null)
    {
      StringBuffer sb = new StringBuffer(proxyUserName);
      sb.append(COLON);
      sb.append(proxyPassword);
      BASE64Encoder encoder = new BASE64Encoder();
      String encodedUserNamePassword = encoder.encode(sb.toString().getBytes());
      sb.setLength(0);
      sb.append(HTTP_HEADER_PROXY_AUTH);
      sb.append(COLON);
      sb.append(SPACE);
      sb.append(BASIC);
      sb.append(SPACE);
      sb.append(encodedUserNamePassword);
      sb.append(NEW_LINE);
      return sb.toString();
    }
    else
      return EMPTY_STRING;
  }
  
  private String getAccept()
  {
    return getHTTPHeader(HTTP_HEADER_ACCEPT, ACCEPT_VALUE);
  }
  
  private String getUserAgent()
  {
    return getHTTPHeader(HTTP_HEADER_USER_AGENT, IBM_WEB_SERVICES_EXPLORER);
  }
  
  private String getCacheControl()
  {
    return getHTTPHeader(HTTP_HEADER_CACHE_CONTROL, NO_CACHE);
  }
  
  private String getPragma()
  {
    return getHTTPHeader(HTTP_HEADER_PRAGMA, NO_CACHE);
  }
  
  private String getConnection()
  {
    return getHTTPHeader(HTTP_HEADER_CONNECTION, CLOSE);
  }
  
  private String getHTTPHeader(String key, String value)
  {
    if (value != null)
    {
      StringBuffer sb = new StringBuffer(key);
      sb.append(COLON);
      sb.append(SPACE);
      sb.append(value);
      sb.append(NEW_LINE);
      return sb.toString();
    }
    else
      return EMPTY_STRING;
  }

  public void send(URL url, String soapAction, String payload) throws UnknownHostException, IOException
  {
    byte[] payloadAsUTF8 = payload.getBytes(DEFAULT_SOAP_ENCODING);
       
    StringBuffer httpHeader = new StringBuffer();
    httpHeader.append(getMethod(url));
    httpHeader.append(getHost(url));
    httpHeader.append(getContentType());
    httpHeader.append(getContentLength(payloadAsUTF8));
    httpHeader.append(getAccept());
    httpHeader.append(getUserAgent());
    httpHeader.append(getCacheControl());
    httpHeader.append(getPragma());
    httpHeader.append(getSOAPAction(soapAction));
    httpHeader.append(getWWWAuthentication());
    httpHeader.append(getProxyAuthentication());
    httpHeader.append(getCookie());
    httpHeader.append(getCookie2());
    httpHeader.append(getConnection());
    httpHeader.append(NEW_LINE); // new line between the HTTP header and the payload
    Socket socket = buildSocket(url);
    InputStream is = socket.getInputStream();
    OutputStream os = socket.getOutputStream();
    os.write(httpHeader.toString().getBytes(DEFAULT_HTTP_HEADER_ENCODING));
    os.write(payloadAsUTF8);
    os.flush();
    httpResponse = new HTTPResponse();
    readHTTPResponseHeader(is, httpResponse);
    int code = httpResponse.getStatusCode();
    if (code == HTTP_CODE_CONTINUE)
    {
      httpResponse.reset();
      readHTTPResponseHeader(is, httpResponse);
    }
    readHTTPResponsePayload(is, httpResponse);
    os.close();
    is.close();
    socket.close();
    code = httpResponse.getStatusCode();
    String contentType = httpResponse.getHeader(HTTP_HEADER_CONTENT_TYPE.toLowerCase());
    if (code >= HTTP_CODE_EXCEPTION && (contentType == null || contentType.toLowerCase().indexOf(TEXT_XML.toLowerCase()) == -1))
      throw new HTTPTransportException(code, httpResponse.getStatusMessage(), httpResponse.getHeaders());
  }

  private void readHTTPResponseHeader(InputStream is, HTTPResponse resp) throws IOException
  {
    byte b = 0;
    int len = 0;
    int colonIndex = -1;
    String key;
    String value;
    boolean readTooMuch = false;
    ByteArrayOutputStream baos;
    for (baos = new ByteArrayOutputStream(4096);;)
    {
      if (!readTooMuch)
        b = (byte)is.read();
      if (b == -1)
        break;
      readTooMuch = false;
      if ((b != R) && (b != N))
      {
        if ((b == COLON) && (colonIndex == -1))
          colonIndex = len;
        len++;
        baos.write(b);
      }
      else if (b == R)
        continue;
      else // b == N
      {
        if (len == 0)
          break;
        b = (byte)is.read();
        readTooMuch = true;
        // A space or tab at the begining of a line means the header continues.
        if ((b == SPACE) || (b == TAB))
          continue;
        baos.close();
        byte[] bArray = baos.toByteArray();
        baos.reset();
        if (colonIndex != -1)
        {
          key = new String(bArray, 0, colonIndex, DEFAULT_HTTP_HEADER_ENCODING);
          value = new String(bArray, colonIndex + 1, len - 1 - colonIndex, DEFAULT_HTTP_HEADER_ENCODING);
          colonIndex = -1;
        }
        else
        {
          key = new String(bArray, 0, len, DEFAULT_HTTP_HEADER_ENCODING);
          value = EMPTY_STRING;
        }
        if (!resp.isStatusSet())
        {
          // Reader status code
          int start = key.indexOf(SPACE) + 1;
          String s = key.substring(start).trim();
          int end = s.indexOf(SPACE);
          if (end != -1)
            s = s.substring(0, end);
          try
          {
            resp.setStatusCode(Integer.parseInt(s));
          }
          catch (NumberFormatException nfe)
          {
            resp.setStatusCode(-1);
          }
          resp.setStatusMessage(key.substring(start + end + 1));
        }
        else
          resp.addHeader(key.toLowerCase().trim(), value.trim());
        len = 0;
      }
    }
    baos.close();
  }

  private void readHTTPResponsePayload(InputStream is, HTTPResponse resp) throws IOException
  {
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    try
    {
      byte b = (byte)is.read();
      while (b != -1)
      {
        baos.write(b);
        b = (byte)is.read();
      }
    }
    catch (SocketTimeoutException ste)
    {
    }
    baos.close();
    resp.setPayload(baos.toByteArray());
  }

  /**
   * Receives the bytes from the last web service invocation.  This is used by WSE's default
   * SOAP transport.
   * 
   * @return A byte array.
   * @throws IOException
   */
  byte[] receiveBytes() throws IOException
  {
    if (httpResponse != null)
    {
        byte[] payload = httpResponse.getPayload();
        if (CHUNKED.equalsIgnoreCase(httpResponse.getHeader(HTTP_HEADER_TRANSFER_ENCODEING.toLowerCase())))
        {
          ByteArrayInputStream bais = new ByteArrayInputStream(payload);
          ChunkedInputStream cis = new ChunkedInputStream(bais);
          ByteArrayOutputStream baos = new ByteArrayOutputStream();
          byte b;
          while ((b = (byte)cis.read()) != -1)
            baos.write(b);
          baos.close();
          cis.close();
          bais.close();
          return baos.toByteArray();
        }
        else
        {
          return payload;
        }
    }
    return null;
  }
  
  /**
   * This method is deprecated after WSE swtiches to using a pluggable transport via enhancement 176493.
   * The core functionality of this method is refactored to the receiveBytes() method. 
   * 
   * @deprecated
   */
  public BufferedReader receive()
  {
    try
    {
      byte[] payload = receiveBytes();
      if (payload != null) {
    	Element soapEnvelope = XMLUtils.byteArrayToElement(payload, false);
        // remove XML namespace declaration
        if (soapEnvelope != null)
          return new BufferedReader(new InputStreamReader(new ByteArrayInputStream(XMLUtils.serialize(soapEnvelope, true).getBytes(DEFAULT_SOAP_ENCODING)), DEFAULT_SOAP_ENCODING)); 
      }
    }
    catch (Throwable t)
    {
    }
    return null;
  }

  public Hashtable getHeaders()
  {
    Hashtable headers = new Hashtable();
    if (httpResponse != null)
      headers.putAll(httpResponse.getHeaders());
    return headers;
  }

  /**
   * Builds the first line of a connection request to the proxy server
   * 
   * @param url The URL that we want to ultimately connect to.
   * @return A string of the form "CONNECT &lt;hostname&gt;:&lt;port&gt; HTTP/1.0".
   */
  private StringBuffer getConnectMethod(URL url) {
	
	  StringBuffer sb = new StringBuffer(HTTP_CONNECT);
	  sb.append(SPACE);	  
	  sb.append(url.getHost());
	  sb.append(COLON);
	  sb.append(url.getPort());
	  sb.append(SPACE);
	  sb.append(HTTP_VERSION_1_0);
	  sb.append(NEW_LINE);
	  return sb;
  }
  
  /**
   * Construct a socket to the proxy server which be used to tunnel through.
   * 
   * @param url The URL that we want to ultimately connect to.
   * @param proxyHost The proxy host.
   * @param proxyPort The proxy port.
   * @return A connected socket to the proxy server. 
   * @throws IOException 
   */
  private Socket buildTunnelSocket(URL url, String proxyHost, int proxyPort) throws IOException {

	  StringBuffer httpHeader = new StringBuffer();
	  httpHeader.append(getConnectMethod(url));
	  httpHeader.append(getProxyAuthentication());       
	  httpHeader.append(NEW_LINE);
    
	  Socket tunnel = new Socket(proxyHost, proxyPort);
    
	  InputStream  is = tunnel.getInputStream();
	  OutputStream os = tunnel.getOutputStream();
    
	  os.write(httpHeader.toString().getBytes(DEFAULT_HTTP_HEADER_ENCODING));        
	  os.flush();
    
	  HTTPResponse httpResponse = new HTTPResponse();
	  readHTTPResponseHeader(is, httpResponse);
    
	  int code = httpResponse.getStatusCode();

	  // ensure we are successfully connected to the proxy
	  if (code != HTTP_CODE_OK)
		  throw new HTTPTransportException(code, httpResponse.getStatusMessage(), httpResponse.getHeaders());
	  
	  return tunnel;
  }
  
  private Socket buildSocket(URL url) throws UnknownHostException, IOException
  {
    Socket s = null;
    String host = url.getHost();
    int port = url.getPort();
    String proxyHost = System.getProperty(SYS_PROP_HTTP_PROXY_HOST);
    int proxyPort = Integer.getInteger(SYS_PROP_HTTP_PROXY_PORT, DEFAULT_HTTP_PORT).intValue();
    
    String nonProxyHosts = System.getProperty(SYS_PROP_HTTP_NON_PROXY_HOSTS);

    //  String proxyUserName = System.getProperty(SYS_PROP_HTTP_PROXY_USER_NAME);
    //  String proxyPassword = System.getProperty(SYS_PROP_HTTP_PROXY_PASSWORD);
    if (url.getProtocol().equalsIgnoreCase(HTTPS))
    {
      proxyHost = System.getProperty(SYS_PROP_HTTPS_PROXY_HOST);
      proxyPort = Integer.getInteger(SYS_PROP_HTTPS_PROXY_PORT, DEFAULT_HTTPS_PORT).intValue();
      nonProxyHosts = System.getProperty(SYS_PROP_HTTPS_NON_PROXY_HOSTS);

      if (proxyHost != null && proxyHost.length() > 0 && !isHostInNonProxyHosts(host, nonProxyHosts, DEFAULT_CASE_SENSITIVE_FOR_HOST_NAME))
      {
        // SSL with proxy server
        Socket tunnel = buildTunnelSocket(url, proxyHost, proxyPort);       
        s = ((SSLSocketFactory) SSLSocketFactory.getDefault()).createSocket(tunnel, host, port, true);    	  
      }
      else
        s = SSLSocketFactory.getDefault().createSocket(host, (port > 0 ? port : DEFAULT_HTTPS_PORT));
      // Removing dependency on soap.jar
      //  s = SSLUtils.buildSSLSocket(host, (port > 0 ? port : DEFAULT_HTTPS_PORT), proxyHost, proxyPort);
      // TODO:
      // Build an SSL socket that supports proxyUser and proxyPassword,
      // as demonstrated in the following (original) line of code:
      //  s = SSLUtils.buildSSLSocket(host, (port > 0 ? port : DEFAULT_HTTPS_PORT), proxyHost, proxyPort, proxyUserName, proxyPassword);
    }
    else if (proxyHost != null && proxyHost.length() > 0 && !isHostInNonProxyHosts(host, nonProxyHosts, DEFAULT_CASE_SENSITIVE_FOR_HOST_NAME))
      s = new Socket(proxyHost, proxyPort);
    else
      s = new Socket(host, (port > 0 ? port : DEFAULT_HTTP_PORT));
    return s;
  }
  
  private boolean isHostInNonProxyHosts(String host, String nonProxyHosts, boolean caseSensitive)
  {
  	if (caseSensitive) return host.matches(createPatternFromString(nonProxyHosts));
  	else return host.toLowerCase().matches(createPatternFromString(nonProxyHosts.toLowerCase()));  
  }
  
  /*
   * This method is used to generate a valid regular expression for a 
   * normal java String used in the proxy mechanism. 
   * For example, the http.nonProxyHosts contains following String: 
   * "192.168.2.*|localhost|*.ibm.com" . It would be 
   * transformed into: "192\.168\.2\.\w*|localhost|\w*\.ibm\.com"
   * Thus, following host string would match above pattern:
   * 192.168.2.5 192.168.2. 192.168.2.666 192.168.2.w
   * localhost
   * torolab.ibm.com .ibm.com 123.ibm.com
   * 
   * Two transformations are done:
   * 1. replace all "." into "\." As in regular expression, '.' represents 
   *    any charater.  "\.' represents the real character '.'
   * 2. In order to get the real meaning of "*" used in property 
   *    http.nonProxyHosts, "\w*" is used to replace "*"
   *    "\w" represent a word character: [a-zA-Z_0-9]
   *    
   * Restriction:
   * The validity of address is not checked. 
   * (192.168.2.555 and 192.168.2.com are OK)
   * 
   * TODO check whether * occurs in address or hostname.
   * if it occuus in address representation, replace "*" with "\d*"
   * and check: value < 256 ?
   */
  private String createPatternFromString(String str) 
  {
    /* This is the same as following more understandable way:
	 * return str.replace(".", "\\.").replace("*", "\\w*");
	 * But, replace(CharSequence target, CharSequence replacement) can only be 
	 * supported after j2se 1.5, on the other hand, 
	 * replaceAll(String regex, String replacement) can be supported before 
	 * j2se 1.5.
	 */
    return str == null ? null : str.replaceAll("\\.", "\\.").replaceAll("\\*", "\\w*");
  }
}




/*******************************************************************************
 * Copyright (c) 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.perspective;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.Hashtable;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import org.eclipse.core.runtime.CoreException;
import org.eclipse.core.runtime.IConfigurationElement;
import org.eclipse.core.runtime.IExtensionRegistry;
import org.eclipse.core.runtime.Platform;
import org.eclipse.core.runtime.Preferences;
import org.eclipse.wst.ws.internal.explorer.plugin.ExplorerPlugin;
import org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransportProvider;

/**
 * This class is responsible for loading the Web Services Explorer's transport provider
 * extensions and instantiating them when needed. 
 */
public class TransportProviderRegistry {

	private static final String PREF_TRANSPORT_PROVIDERS = "TRANSPORT_PROVIDERS";	
	private static final String EXTENSION_NAME           = "wseTransportProvider";
	private static final String SOAP_TRANSPORT_PROVIDER  = "soapTransportProvider";
	private static final String NAMESPACE_URI            = "namespaceURI";
	private static final String TRANSPORT_URI            = "transportURI";
	
	private static TransportProviderRegistry instance = null;
	
	private List preferredIDs        = null; 
	private Map soapProviderElements = null;
	private Map soapProviderCache    = null;
	
	/**
	 * Returns a singleton instance of this TransportProviderRegistry.
	 *  
	 * @return An instance of this class.
	 */
	public synchronized static TransportProviderRegistry getInstance() {
		if (instance == null)
			instance = new TransportProviderRegistry();
		return instance;
	}
	
	/*
	 * Constructor.
	 */
	private TransportProviderRegistry() {		
		
		// get the preference value
		Preferences preferences = ExplorerPlugin.getInstance().getPluginPreferences();
		String transportProviders = preferences.getString(PREF_TRANSPORT_PROVIDERS).replaceAll("\\s", "");
		
		// split it into a list of preferred transport provider IDs
		if (transportProviders.length() == 0)
			preferredIDs = new ArrayList();
		else			
			preferredIDs = Arrays.asList(transportProviders.split(","));
		
		// now find all extenders
		IExtensionRegistry registry = Platform.getExtensionRegistry();
	    IConfigurationElement[] configs = 
	    	registry.getConfigurationElementsFor(ExplorerPlugin.ID, EXTENSION_NAME); 

	    // currently we only have one type of providers: SOAP transport providers
	    soapProviderElements = new Hashtable();	    
	    for (int i = 0; i < configs.length; i++) {	    		    	
    		if (SOAP_TRANSPORT_PROVIDER.equals(configs[i].getName())) {	    			
    			String id = configs[i].getAttribute("id");
    			soapProviderElements.put(id, configs[i]);    			    				
    		}	    		    	
	    }
	    
	    soapProviderCache = new Hashtable();
	}		
	
	/*
	 * Determine if the URIs match.
	 */
	private boolean uriMatch(String required, String supported) {
		
		// not specified mean support everything
		if (supported == null)
			return true;
				
		if (!required.endsWith("/"))  required += "/";
		if (!supported.endsWith("/")) supported += "/";
		
		return required.equals(supported);
	}
	
	/*
	 * Create the extension for the given key, but only if it supports the binding namespace and transport
	 */
	private ISOAPTransportProvider createExtension(Object key, String namespaceURI, String transportURI) {
		
		IConfigurationElement element = (IConfigurationElement) soapProviderElements.get(key);						
		if (element == null)
			return null;
		
		boolean supportsNamespace = uriMatch(namespaceURI, element.getAttribute(NAMESPACE_URI));
		boolean supportsTransport = uriMatch(transportURI, element.getAttribute(TRANSPORT_URI));			
		
		if (supportsNamespace && supportsTransport) {			
			
			String providerClassID = element.getAttribute("class");
			Object obj = null;
			
			try {
				// check if we already have the transport provider cached,
				// if not, then create one
				synchronized (soapProviderCache) {
					obj = soapProviderCache.get(providerClassID); 					
					if (obj == null) {					
						obj = element.createExecutableExtension("class");
						soapProviderCache.put(providerClassID, obj);
					}					
				}
				return (ISOAPTransportProvider) obj;
			}
			catch (CoreException e) {}					
		}
		
		return null;
	}
	
	/**
	 * Get an ISOAPTransportProvider that supports the binding namespace and transport.  This method will
	 * first look for preferred IDs defined using the TRANSPORT_PROVIDERS preference key.  If a suitable
	 * provider is not found, it will then look at all other extenders in non-deterministic order.
	 * 
	 * @param namespaceURI The binding namespace URI
	 * @param transportURI The binding transport URI
	 * 
	 * @return Returns a suitable ISOAPTranportProvider for the given binding information, or null
	 * if there's no match.
	 */
	public ISOAPTransportProvider getSOAPTransportProvider(String namespaceURI, String transportURI) {
	
		ISOAPTransportProvider provider = null;
		
		Iterator iter = preferredIDs.iterator();
		
		// check preferred IDs first
		while (iter.hasNext()) {
			provider = createExtension(iter.next(), namespaceURI, transportURI);
			if (provider != null)
				return provider;
		}
		
		iter = soapProviderElements.keySet().iterator();
		
		// check rest of the providers
		while (iter.hasNext()) {
			Object key = iter.next();
		
			// already checked the preferred IDs
			if (preferredIDs.contains(key))
				continue;
			
			provider = createExtension(key, namespaceURI, transportURI);
			if (provider != null)
				return provider;			
		}
		
		return null;
	}
}




/*******************************************************************************
 * Copyright (c) 2004, 2005 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 *     IBM Corporation - initial API and implementation
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport;

import java.util.Hashtable;
import java.util.Map;

public class HTTPResponse
{
  private boolean statusSet;
  private int statusCode;
  private String statusMessage;
  private Hashtable headers;
  private byte[] payload;

  public HTTPResponse()
  {
    reset();
  }

  public void reset()
  {
    statusSet = false;
    statusCode = -1;
    statusMessage = null;
    if (headers != null)
      headers.clear();
    else
      headers = new Hashtable();
    payload = new byte[0];
  }

  public boolean isStatusSet()
  {
    return statusSet;
  }

  public int getStatusCode()
  {
    return statusCode;
  }

  public void setStatusCode(int statusCode)
  {
    statusSet = true;
    this.statusCode = statusCode;
  }

  public String getStatusMessage()
  {
    return statusMessage;
  }

  public void setStatusMessage(String statusMessage)
  {
    this.statusMessage = statusMessage;
  }

  public void addHeader(String key, String value)
  {
    headers.put(key, value);
  }

  public String getHeader(String key)
  {
    return (String) headers.get(key);
  }

  public Map getHeaders()
  {
    return headers;
  }

  public byte[] getPayload()
  {
    return payload;
  }

  public void setPayload(byte[] payload)
  {
    this.payload = payload;
  }
}




<?xml version='1.0' encoding='UTF-8'?>
<!-- Schema file written by PDE -->
<schema targetNamespace="org.eclipse.wst.ws.explorer">
<annotation>
      <appInfo>
         <meta.schema plugin="org.eclipse.wst.ws.explorer" id="wseTransportProvider" name="Web Services Explorer Transport Provider"/>
      </appInfo>
      <documentation>
         [Enter description of this extension point.]
      </documentation>
   </annotation>

   <element name="extension">
      <complexType>
         <sequence minOccurs="1" maxOccurs="unbounded">
            <element ref="soapTransportProvider"/>
         </sequence>
         <attribute name="point" type="string" use="required">
            <annotation>
               <documentation>
                  A fully qualified identifier of the target extension point
               </documentation>
            </annotation>
         </attribute>
         <attribute name="id" type="string">
            <annotation>
               <documentation>
                  An optional identifier for this extension instance
               </documentation>
            </annotation>
         </attribute>
         <attribute name="name" type="string">
            <annotation>
               <documentation>
                  An optional name this extension instance
               </documentation>
               <appInfo>
                  <meta.attribute translatable="true"/>
               </appInfo>
            </annotation>
         </attribute>
      </complexType>
   </element>

   <element name="soapTransportProvider">
      <annotation>
         <documentation>
            This extension point entry allows an extender to plug in a new factory for creating org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransport instances.  The ISOAPTranport is used by the Web Services Explorer for invoking web services operations that uses the SOAP message protocol.
         </documentation>
      </annotation>
      <complexType>
         <attribute name="class" type="string" use="required">
            <annotation>
               <documentation>
                  This class must implement the org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransportProvider interface.
               </documentation>
               <appInfo>
                  <meta.attribute kind="java" basedOn="org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransportProvider"/>
               </appInfo>
            </annotation>
         </attribute>
         <attribute name="id" type="string" use="required">
            <annotation>
               <documentation>
                  This id uniquely identifies this soapTransportProvider element.
               </documentation>
            </annotation>
         </attribute>
         <attribute name="name" type="string" use="required">
            <annotation>
               <documentation>
                  The name of this soapTransportProvider element.
               </documentation>
               <appInfo>
                  <meta.attribute translatable="true"/>
               </appInfo>
            </annotation>
         </attribute>
         <attribute name="namespaceURI" type="string">
            <annotation>
               <documentation>
                  The namespace URI of the soap:binding element that this transport provider claims support for.  For example, if this transport provider supports the SOAP 1.1 binding, the value of this attribute would be http://schemas.xmlsoap.org/wsdl/soap/.  If unspecified, this transport provider claims support for all SOAP bindings.
               </documentation>
            </annotation>
         </attribute>
         <attribute name="transportURI" type="string">
            <annotation>
               <documentation>
                  The transport protocol URI of the soap:binding element that this transport provider claims support for.  For example, if this transport provider supports SOAP over HTTP, the value of this attribute would be http://schemas.xmlsoap.org/soap/http.  If unspecified, this transport provider claims support for all transport protocols.
               </documentation>
            </annotation>
         </attribute>
      </complexType>
   </element>

   <annotation>
      <appInfo>
         <meta.section type="since"/>
      </appInfo>
      <documentation>
         &lt;b&gt;This extension point is part of an interim API that is still under development and expected to change significantly before reaching stability. It is being made available at this early stage to solicit feedback from pioneering adopters on the understanding that any code that uses this API will almost certainly be broken (repeatedly) as the API evolves.&lt;/b&gt;
      </documentation>
   </annotation>

   <annotation>
      <appInfo>
         <meta.section type="examples"/>
      </appInfo>
      <documentation>
         [Enter extension point usage example here.]
      </documentation>
   </annotation>

   <annotation>
      <appInfo>
         <meta.section type="apiInfo"/>
      </appInfo>
      <documentation>
         [Enter API information here.]
      </documentation>
   </annotation>

   <annotation>
      <appInfo>
         <meta.section type="implementation"/>
      </appInfo>
      <documentation>
         [Enter information about supplied implementation of this extension point.]
      </documentation>
   </annotation>

   <annotation>
      <appInfo>
         <meta.section type="copyright"/>
      </appInfo>
      <documentation>
         Copyright (c) 2007 IBM Corporation and others.&lt;br&gt;
All rights reserved. This program and the accompanying materials are made 
available under the terms of the Eclipse Public License v1.0 which accompanies 
this distribution, and is available at &lt;a
href=&quot;http://www.eclipse.org/legal/epl-v10.html&quot;&gt;http://www.eclipse.org/legal/epl-v10.html&lt;/a&gt;
      </documentation>
   </annotation>

</schema>




/*******************************************************************************
 * Copyright (c) 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.transport;

/**
 * The ISerializer is responsible for taking an ISOAPMessage and serializing it
 * into an XML string.
 */
public interface ISerializer {

	/**
	 * Serialize the ISOAPMessage into an XML string.  The part parameter tells the method
	 * which part of the message (the envelope or the contents of the header or body) to
	 * serialize.  Note that "contents" refers to the list of elements inside the header
	 * or body, and not the header or body element itself.
	 * 
	 * @param part One of {@link ISOAPMessage#ENVELOPE}, {@link ISOAPMessage#HEADER_CONTENT}, or
	 * {@link ISOAPMessage#BODY_CONTENT}.
	 * @param message The ISOAPMessage to serialize.
	 * @return An XML string. 
	 * @throws TransportException
	 */
	public String serialize(int part, ISOAPMessage message) throws TransportException;
}




/*******************************************************************************
 * Copyright (c) 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.transport;

import java.util.Hashtable;
import java.util.Iterator;
import java.util.Map;

import org.w3c.dom.Attr;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.w3c.dom.NamedNodeMap;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;

/**
 * This is a default implementation of the ISOAPMessage interface that extenders of the Web
 * Services Explorer transport can use if they do not wish to implement their own message.  
 * This class is  implemented as a collection of loose pieces of the SOAP message, and each 
 * piece must be set individually (for example, setting the envelope element will not 
 * automatically populate the header or body elements).
 * <br/>
 * <br/>
 * This class does not know how to serialize itself.  It depends on an ISerializer provided by
 * the transport extender. 
 */
public final class SOAPMessage implements ISOAPMessage {
	
	private MessageContext context;
	private ISerializer serializer;
		
	private Map properties = new Hashtable();	
	
	private Element envelope = null;
	
	private Element header = null;
	private Element[] headerContent = null;
	
	private Element body = null;
	private Element[] bodyContent = null;	
		
	private Element fault = null;
		
	private String xml = null;
	
	/**
	 * Constructor.
	 * 
	 * @param context The MessageContext.
	 * @param serializer An ISerializer to use to serialize this message.
	 */
	public SOAPMessage(MessageContext context, ISerializer serializer) {
		this.context = context;
		this.serializer = serializer;
	}
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage#getMessageContext()
	 */
	public MessageContext getMessageContext() {
		return context;
	}
		
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage#setProperty(java.lang.String, java.lang.Object)
	 */
	public void setProperty(String key, Object value) {
		properties.put(key, value);
	}
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage#getProperty(java.lang.String)
	 */
	public Object getProperty(String key) {
		return properties.get(key);
	}
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage#setNamespaceTable(java.util.Map)
	 */
	public synchronized void setNamespaceTable(Map namespaceTable) {
		if (namespaceTable == null || envelope == null)
			return;
	
		Iterator iter = namespaceTable.entrySet().iterator();
		
		while (iter.hasNext()) {
			Map.Entry entry = (Map.Entry) iter.next();
			String name = "xmlns:" + entry.getValue();			
			envelope.setAttribute(name, entry.getKey().toString());			
		}
		
		xml = null;
	}
	
	/*
	 * If the attribute is a namespace declaration, the namespace prefix is returned.
	 * Otherwise null is returned.
	 */
	private String getNSPrefix(Attr attribute) {
		String name = attribute.getName();
		if (name.startsWith("xmlns:"))
			return name.substring(6);
		return null;
	}
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage#getNamespaceTable()
	 */
	public Map getNamespaceTable() {
		
		Hashtable namespaceTable = new Hashtable();
		
		if (envelope != null) {
			NamedNodeMap attributes = envelope.getAttributes();
			for (int i = 0; i < attributes.getLength(); i++) {
				Attr attribute = (Attr) attributes.item(i);
				String prefix = getNSPrefix(attribute);
				if (prefix != null)
					namespaceTable.put(attribute.getValue(), prefix);
			}			
		}		
		
		return namespaceTable;
	}
	
	/*
	 * Appends a child node to a parent node, takes care of importing
	 * the child node if neccessary.
	 */
	private void appendNode(Node parent, Node child) {
		if (parent == null || child == null)
			return;
		
		Document owner = parent.getOwnerDocument();
		
		if (!owner.equals(child.getOwnerDocument()))
			child = owner.importNode(child, true);
		
		parent.appendChild(child);
	}
	
	/*
	 * Adds an array of elements to the parent element as child elements.
	 */
	private void appendChildren(Element parent, Element[] children) {
		if (parent == null || children == null)
			return;
		
		for (int i = 0; i < children.length; i++) {
			if (children[i] == null)
				continue;
			appendNode(parent, children[i]);
		}
	}		
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage#setEnvelope(org.w3c.dom.Element)
	 */
	public synchronized void setEnvelope(Element envelope) {
		if (envelope == null)
			this.envelope = envelope;
		else
			this.envelope = (Element) envelope.cloneNode(false);
					
		xml = null;
	}
		
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage#getEnvelope(boolean)
	 */
	public Element getEnvelope(boolean deep) {
		if (!deep)
			return envelope;
		
		synchronized (this) {
			if (envelope == null)
				return null;
			
			Element clonedEnvelope = (Element) envelope.cloneNode(false);
			
			if (headerContent != null && headerContent.length > 0)
				appendNode(clonedEnvelope, getHeader(true));
				
			appendNode(clonedEnvelope, getBody(true));
			
			return clonedEnvelope;	
		}
	}
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage#setHeader(org.w3c.dom.Element)
	 */
	public synchronized void setHeader(Element header) {
		if (header == null)
			this.header = null;			
		else
			this.header = (Element) header.cloneNode(false);

		xml = null;
	}
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage#getHeader(boolean)
	 */
	public Element getHeader(boolean deep) {
		if (!deep)
			return header;
		
		synchronized (this) {
			if (header == null)
				return null;
			
			Element clonedHeader = (Element) header.cloneNode(false);
			appendChildren(clonedHeader, headerContent);				
			return clonedHeader;
		}				
	}
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage#setHeaderContent(org.w3c.dom.Element[])
	 */
	public synchronized void setHeaderContent(Element[] headerContent) {
		this.headerContent = headerContent;
		xml = null;
	}
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage#getHeaderContent()
	 */
	public Element[] getHeaderContent() {
		return headerContent;
	}
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage#setBody(org.w3c.dom.Element)
	 */
	public synchronized void setBody(Element body) {		
		if (body == null)
			this.body = null;
		else {
			this.body = (Element) body.cloneNode(false);
			
			if (!context.isDocumentStyle() && fault == null) {
				NodeList childElements = body.getElementsByTagName("*");
				if (childElements.getLength() > 0)
					this.body.appendChild(childElements.item(0).cloneNode(false));
			}
		}		
		xml = null;
	}
					
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage#getBody(boolean)
	 */
	public Element getBody(boolean deep) {
		if (!deep)
			return body;
		
		synchronized (this) {
			if (body == null)
				return null;
		
			// copy the rpc wrapper element as well, if any
			Element clonedBody = (Element) body.cloneNode(true);		
			
			if (fault != null)
				appendNode(clonedBody, fault);
			else {
				Element target = clonedBody;
				
				// check for rpc wrapper
				if (clonedBody.getFirstChild() != null)
					target = (Element) clonedBody.getFirstChild();
				
				appendChildren(target, bodyContent);
			}
				
			return clonedBody;		
		}
	}
				
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage#setBodyContent(org.w3c.dom.Element[])
	 */
	public synchronized void setBodyContent(Element[] bodyContent) {
		this.bodyContent = bodyContent;
		if (bodyContent != null)
			fault = null;
		xml = null;
	}
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage#getBodyContent()
	 */
	public Element[] getBodyContent() {
		return bodyContent;
	}
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage#setFault(org.w3c.dom.Element)
	 */
	public synchronized void setFault(Element fault) {
		this.fault = fault;
		if (fault != null) {
			if (body != null && body.getFirstChild() != null)
				body.removeChild(body.getFirstChild());
			bodyContent = null;
		}
		xml = null;
	}
	
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage#getFault()
	 */
	public Element getFault() {
		return fault;
	}
		
	/* (non-Javadoc)
	 * @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPMessage#toXML()
	 */
	public synchronized String toXML() throws TransportException {
		if (xml == null)
			xml = serializer.serialize(ENVELOPE, this);
		return xml;		
	}		
}




/*******************************************************************************
 * Copyright (c) 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/
package org.eclipse.wst.ws.internal.explorer.transport;

/**
 * The IDeserializer is responsible for taking an XML string and deserializing it
 * into values to populate an ISOAPMessage.
 */
public interface IDeserializer {
	
	/**
	 * Deserialize the XML string into the ISOAPMessage.  The part parameter tells the method
	 * which part of the message (the envelope or the contents of the header or body) the XML
	 * string represents.  Note that "contents" refers to the list of elements inside the header
	 * or body, and not the header or body element itself.
	 * 
	 * @param part One of {@link ISOAPMessage#ENVELOPE}, {@link ISOAPMessage#HEADER_CONTENT}, or
	 * {@link ISOAPMessage#BODY_CONTENT}.
	 * @param xml The XML string to deserialize.
	 * @param message The ISOAPMessage to deserialize into.
	 * @throws TransportException
	 */
	public void deserialize(int part, String xml, ISOAPMessage message) throws TransportException;		
}




/*******************************************************************************
 * Copyright (c) 2002, 2007 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 * 
 * Contributors:
 * IBM Corporation - initial API and implementation
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20070305   117034 makandre@ca.ibm.com - Andrew Mak, Web Services Explorer should support SOAP Headers
 * 20070413   176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
 *******************************************************************************/

package org.eclipse.wst.ws.internal.explorer.platform.wsdl.util;

import java.util.Enumeration;
import java.util.Hashtable;
import org.apache.axis.Constants;
import org.eclipse.wst.ws.internal.explorer.platform.util.URLUtils;
import org.w3c.dom.Document;
import org.w3c.dom.Element;

public class SoapHelper
{
  private static Hashtable defaultSoapEnvelopeNamespaces_ = null;
  
  private static final void initDefaultSoapEnvelopeNamespaces()
  {
    defaultSoapEnvelopeNamespaces_ = new Hashtable();
    defaultSoapEnvelopeNamespaces_.put(Constants.URI_SOAP11_ENV,Constants.NS_PREFIX_SOAP_ENV);
    defaultSoapEnvelopeNamespaces_.put(Constants.URI_2001_SCHEMA_XSI,Constants.NS_PREFIX_SCHEMA_XSI);
    defaultSoapEnvelopeNamespaces_.put(Constants.URI_2001_SCHEMA_XSD,Constants.NS_PREFIX_SCHEMA_XSD);
  }
  
  public static final void addDefaultSoapEnvelopeNamespaces(Hashtable soapEnvelopeNamespaces)
  {
    if (defaultSoapEnvelopeNamespaces_ == null)
      initDefaultSoapEnvelopeNamespaces();
    Enumeration defaultSoapEnvelopeNamespaceURIs = defaultSoapEnvelopeNamespaces_.keys();
    while (defaultSoapEnvelopeNamespaceURIs.hasMoreElements())
    {
      String defaultSoapEnvelopeNamespaceURI = (String)defaultSoapEnvelopeNamespaceURIs.nextElement();
      soapEnvelopeNamespaces.put(defaultSoapEnvelopeNamespaceURI,(String)defaultSoapEnvelopeNamespaces_.get(defaultSoapEnvelopeNamespaceURI));
    }
  }
  
  public static final boolean isDefaultSoapEnvelopeNamespace(String namespaceURI,String namespacePrefix)
  {
    if (defaultSoapEnvelopeNamespaces_ == null)
      initDefaultSoapEnvelopeNamespaces();
    if (defaultSoapEnvelopeNamespaces_.get(namespaceURI) != null)
      return true;
    return false;
  }  
  
  public static final Element createSoapEnvelopeElement(Document doc,Hashtable soapEnvelopeNamespaceTable)
  {
    Element soapEnvelopeElement = doc.createElement("soapenv:Envelope");
    Enumeration e = soapEnvelopeNamespaceTable.keys();
    while (e.hasMoreElements())
    {
      String soapEnvelopeNamespaceURI = (String)e.nextElement();
      StringBuffer soapEnvelopeNamespaceAttr = new StringBuffer("xmlns:");
      soapEnvelopeNamespaceAttr.append((String)soapEnvelopeNamespaceTable.get(soapEnvelopeNamespaceURI));
      soapEnvelopeElement.setAttribute(soapEnvelopeNamespaceAttr.toString(),soapEnvelopeNamespaceURI);      
    }    
    return soapEnvelopeElement;
  }
  
  public static final Element createSoapHeaderElement(Document doc)
  {
    return doc.createElement("soapenv:Header");
  }
  
  public static final Element createSoapBodyElement(Document doc)
  {
    return doc.createElement("soapenv:Body");
  }
  
  public static final Element createRPCWrapperElement(Document doc,Hashtable soapEnvelopeNamespaceTable,String encodingNamespaceURI,String operationName, String encodingStyle)
  {
    int nsId = 0;
    StringBuffer wrapperElementName = new StringBuffer();
    String encodingNamespacePrefix = (String)soapEnvelopeNamespaceTable.get(encodingNamespaceURI);
    if (encodingNamespacePrefix != null)
      wrapperElementName.append(encodingNamespacePrefix);
    else
    {
      // Loop until we generate a unique prefix.
      do
      {
        wrapperElementName.setLength(0);
        wrapperElementName.append("ns").append(nsId);
        if (!soapEnvelopeNamespaceTable.containsValue(wrapperElementName.toString()))
          break;
        nsId++;
      } while (true);
      
      // need to ensure whatever prefix we choose is added to the namespace table
      // so that it will not be reused lated on
      soapEnvelopeNamespaceTable.put(encodingNamespaceURI, wrapperElementName.toString());
    }    
    String wrapperElementNamePrefix = wrapperElementName.toString();
    wrapperElementName.append(':').append(operationName);
    Element wrapperElement = doc.createElement(wrapperElementName.toString());
    StringBuffer namespaceAttrName = new StringBuffer("xmlns:");
    namespaceAttrName.append(wrapperElementNamePrefix);
    wrapperElement.setAttribute(namespaceAttrName.toString(),encodingNamespaceURI);
    if (encodingStyle != null)
      wrapperElement.setAttribute("soapenv:encodingStyle",encodingStyle);
    return wrapperElement;
  }

  public static final String encodeNamespaceDeclaration(String prefix, String uri)
  {
    StringBuffer sb = new StringBuffer();
    sb.append(prefix);
    sb.append(" ");
    sb.append(uri);
    String result = URLUtils.encode(sb.toString());
    return result;
  }

  public static final String[] decodeNamespaceDeclaration(String s)
  {
    String sCopy = URLUtils.decode(s);
    int index = sCopy.indexOf(" ");
    String[] nsDecl = new String[2];
    if (index != -1)
    {
      nsDecl[0] = sCopy.substring(0, index);
      nsDecl[1] = sCopy.substring(index+1, sCopy.length());
    }
    else
    {
      nsDecl[0] = null;
      nsDecl[1] = sCopy;
    }
    return nsDecl;
  }
}

Return to bug 176493

Removed Link Here

(-)wsexplorer-src/org/eclipse/wst/ws/internal/explorer/platform/util/XMLUtils.java (-145 lines)
1	/*******************************************************************************
2	* Copyright (c) 2004, 2005 IBM Corporation and others.
3	* All rights reserved. This program and the accompanying materials
4	* are made available under the terms of the Eclipse Public License v1.0
5	* which accompanies this distribution, and is available at
6	* http://www.eclipse.org/legal/epl-v10.html
7	*
8	* Contributors:
9	* IBM Corporation - initial API and implementation
10	*******************************************************************************/
11	package org.eclipse.wst.ws.internal.explorer.platform.util;
12
13	import java.io.ByteArrayInputStream;
14	import java.io.ByteArrayOutputStream;
15	import java.io.IOException;
16	import java.io.UnsupportedEncodingException;
17	import javax.xml.parsers.DocumentBuilder;
18	import javax.xml.parsers.DocumentBuilderFactory;
19	import javax.xml.parsers.ParserConfigurationException;
20	import javax.xml.transform.OutputKeys;
21	import javax.xml.transform.Transformer;
22	import javax.xml.transform.TransformerFactory;
23	import javax.xml.transform.dom.DOMSource;
24	import javax.xml.transform.stream.StreamResult;
25	import org.w3c.dom.Document;
26	import org.w3c.dom.DocumentFragment;
27	import org.w3c.dom.Element;
28	import org.xml.sax.SAXException;
29
30	public final class XMLUtils
31	{
32	/**
33	* Serialize an XML Element into a String.
34	* @param e Element to be serialized.
35	* @param omitXMLDeclaration boolean representing whether or not to omit the XML declaration.
36	* @return String representation of the XML document fragment.
37	*/
38	public static final String serialize(Element e,boolean omitXMLDeclaration)
39	{
40	if (e != null)
41	{
42	try
43	{
44	DOMSource domSource = new DOMSource(e);
45	Transformer serializer = TransformerFactory.newInstance().newTransformer();
46	serializer.setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, ((omitXMLDeclaration) ? "yes" : "no"));
47	serializer.setOutputProperty(OutputKeys.INDENT, "yes");
48	serializer.setOutputProperty(OutputKeys.ENCODING, HTMLUtils.UTF8_ENCODING);
49	serializer.setOutputProperty("{http://xml.apache.org/xslt}indent-amount", "2");
50	ByteArrayOutputStream baos = new ByteArrayOutputStream();
51	serializer.transform(domSource, new StreamResult(baos));
52	baos.close();
53	return new String(baos.toByteArray(), HTMLUtils.UTF8_ENCODING);
54	}
55	catch (Throwable t)
56	{
57	}
58	}
59	return null;
60	}
61
62	/**
63	* Serialize an XML Element into a String.
64	* @param df DocumentFragment to be serialized.
65	* @param omitXMLDeclaration boolean representing whether or not to omit the XML declaration.
66	* @return String representation of the XML document fragment.
67	*/
68	public static final String serialize(DocumentFragment df,boolean omitXMLDeclaration)
69	{
70	if (df != null)
71	{
72	try
73	{
74	DOMSource domSource = new DOMSource(df);
75	Transformer serializer = TransformerFactory.newInstance().newTransformer();
76	serializer.setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, ((omitXMLDeclaration) ? "yes" : "no"));
77	serializer.setOutputProperty(OutputKeys.INDENT, "yes");
78	serializer.setOutputProperty(OutputKeys.ENCODING, HTMLUtils.UTF8_ENCODING);
79	serializer.setOutputProperty("{http://xml.apache.org/xslt}indent-amount", "2");
80	ByteArrayOutputStream baos = new ByteArrayOutputStream();
81	serializer.transform(domSource, new StreamResult(baos));
82	baos.close();
83	return new String(baos.toByteArray(), HTMLUtils.UTF8_ENCODING);
84	}
85	catch (Throwable t)
86	{
87	}
88	}
89	return null;
90	}
91
92	/**
93	* Create a new XML Document.
94	* @param docBuilder DocumentBuilder. Setting this to null will create a new DocumentBuilder.
95	* @return Document
96	*/
97	public static final Document createNewDocument(DocumentBuilder docBuilder) throws ParserConfigurationException
98	{
99	if (docBuilder == null)
100	{
101	DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
102	factory.setNamespaceAware(false);
103	factory.setValidating(false);
104	docBuilder = factory.newDocumentBuilder();
105	}
106	Document doc = docBuilder.newDocument();
107	return doc;
108	}
109
110	/**
111	* Convert the String representation of an Element into an Element
112	* @param String representation of an Element.
113	* @return Element
114	*/
115	public static Element stringToElement(String s) throws ParserConfigurationException, SAXException, UnsupportedEncodingException, IOException {
116	return stringToElement(s, false);
117	}
118
119	/**
120	* Convert the String representation of an Element into an Element
121	* @param String representation of an Element.
122	* @param boolean set whether the return Element should be namespace aware.
123	* @return Element
124	*/
125	public static Element stringToElement(String s, boolean namespaceAware) throws ParserConfigurationException, SAXException, UnsupportedEncodingException, IOException
126	{
127	return byteArrayToElement(s.getBytes(HTMLUtils.UTF8_ENCODING), namespaceAware);
128	}
129
130	/**
131	* Convert the byte array representation of an Element into an Element
132	* @param byte[] representation of an Element.
133	* @param boolean set whether the return Element should be namespace aware.
134	* @return Element
135	*/
136	public static Element byteArrayToElement(byte[] b, boolean namespaceAware) throws ParserConfigurationException, SAXException, UnsupportedEncodingException, IOException
137	{
138	DocumentBuilderFactory docBuilderFactory = DocumentBuilderFactory.newInstance();
139	docBuilderFactory.setNamespaceAware(namespaceAware);
140	docBuilderFactory.setValidating(false);
141	DocumentBuilder docBuilder = docBuilderFactory.newDocumentBuilder();
142	Document doc = docBuilder.parse(new ByteArrayInputStream(b));
143	return doc.getDocumentElement();
144	}
145	}

Removed Link Here

(-)wsexplorer-src/org/eclipse/wst/ws/internal/explorer/platform/util/URLUtils.java (-101 lines)
1	/*******************************************************************************
2	* Copyright (c) 2005 IBM Corporation and others.
3	* All rights reserved. This program and the accompanying materials
4	* are made available under the terms of the Eclipse Public License v1.0
5	* which accompanies this distribution, and is available at
6	* http://www.eclipse.org/legal/epl-v10.html
7	*
8	* Contributors:
9	* IBM Corporation - initial API and implementation
10	*******************************************************************************/
11	package org.eclipse.wst.ws.internal.explorer.platform.util;
12
13	import java.io.UnsupportedEncodingException;
14	import java.net.URLDecoder;
15	import java.net.URLEncoder;
16
17	/**
18	* This class contains utility methods for managing URLs
19	* as used by the Web Services Explorer Web application.
20	* @author cbrealey@ca.ibm.com
21	*/
22	public final class URLUtils
23	{
24	/**
25	* Objects of this class should not be constructed.
26	*/
27	private URLUtils ()
28	{
29	}
30
31	/**
32	* UTF-8
33	*/
34	public static final String UTF8 = "UTF-8";
35
36	/**
37	* Equivalent to {@link #encode(String,String)}
38	* with second parameter set to the "UTF-8" encoding.
39	* @param s The string to encode.
40	* @return The encoded string.
41	*/
42	public static String encode(String s)
43	{
44	return encode(s,UTF8);
45	}
46
47	/**
48	* Equivalent to {@link URLEncoder#encode(String,String)},
49	* only throws an unchecked {@link RuntimeException} wrapped
50	* around an {@link UnsupportedEncodingException} instead of
51	* an {@link UnsupportedEncodingException}.
52	* @param s The string to encode.
53	* @param enc The encoding to use.
54	* @return The encoded string.
55	*/
56	public static String encode(String s, String enc)
57	{
58	try
59	{
60	return URLEncoder.encode(s,enc);
61	}
62	catch (UnsupportedEncodingException e)
63	{
64	// TODO: MSG_BROKEN_VM_DOES_NOT_SUPPORT_UTF-8
65	throw new RuntimeException("%MSG_BROKEN_VM_DOES_NOT_SUPPORT_UTF-8",e);
66	}
67	}
68
69	/**
70	* Equivalent to {@link #decode(String,String)}
71	* with second parameter set to the "UTF-8" encoding.
72	* @param s The string to decode.
73	* @return The decoded string.
74	*/
75	public static String decode(String s)
76	{
77	return decode(s,UTF8);
78	}
79
80	/**
81	* Equivalent to {@link URLEncoder#decode(String,String)},
82	* only throws an unchecked {@link RuntimeException} wrapped
83	* around an {@link UnsupportedEncodingException} instead of
84	* an {@link UnsupportedEncodingException}.
85	* @param s The string to decode.
86	* @param enc The encoding to use.
87	* @return The decoded string.
88	*/
89	public static String decode(String s, String enc)
90	{
91	try
92	{
93	return URLDecoder.decode(s,enc);
94	}
95	catch (UnsupportedEncodingException e)
96	{
97	// TODO: MSG_BROKEN_VM_DOES_NOT_SUPPORT_UTF-8
98	throw new RuntimeException("%MSG_BROKEN_VM_DOES_NOT_SUPPORT_UTF-8",e);
99	}
100	}
101	}

Removed Link Here

(-)wsexplorer-src/org/eclipse/wst/ws/internal/explorer/platform/wsdl/transport/ChunkedInputStream.java (-192 lines)
1	/*******************************************************************************
2	* Copyright (c) 2001, 2005 IBM Corporation and others.
3	* All rights reserved. This program and the accompanying materials
4	* are made available under the terms of the Eclipse Public License v1.0
5	* which accompanies this distribution, and is available at
6	* http://www.eclipse.org/legal/epl-v10.html
7	*
8	* Contributors:
9	* IBM Corporation - initial API and implementation
10	*******************************************************************************/
11
12	package org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport;
13
14	import java.io.FilterInputStream;
15	import java.io.IOException;
16	import java.io.InputStream;
17
18	public class ChunkedInputStream extends FilterInputStream
19	{
20	protected long chunkSize = 0l;
21	protected volatile boolean closed = false;
22	private static final int maxCharLong = (Long.toHexString(Long.MAX_VALUE)).toString().length();
23
24	private ChunkedInputStream()
25	{
26	super(null);
27	}
28
29	public ChunkedInputStream(InputStream is)
30	{
31	super(is);
32	}
33
34	public int read() throws IOException
35	{
36	byte[] d = new byte[1];
37	int rc = read(d, 0, 1);
38	return rc > 0 ? (d[0] & 0xFF) : rc;
39	}
40
41	public int read(byte[] b) throws IOException
42	{
43	return read(b, 0, b.length);
44	}
45
46	public synchronized int read(byte[] b, int off, int len) throws IOException
47	{
48	if (closed)
49	return -1;
50
51	int totalread = 0;
52	int bytesread = 0;
53	try
54	{
55	do
56	{
57	if (chunkSize < 1L)
58	{
59	if (0l == getChunked())
60	{
61	if (totalread == 0)
62	return -1;
63	else
64	return totalread;
65	}
66	}
67	bytesread = in.read(b, off + totalread, Math.min(len - totalread, (int) Math.min(chunkSize, Integer.MAX_VALUE)));
68	if (bytesread > 0)
69	{
70	totalread += bytesread;
71	chunkSize -= bytesread;
72	}
73	}
74	while (len - totalread > 0 && bytesread > -1);
75	}
76	catch (IOException e)
77	{
78	closed = true;
79	throw e;
80	}
81	return totalread;
82	}
83
84	public long skip(final long n) throws IOException
85	{
86	if (closed)
87	return 0;
88	long skipped = 0l;
89	byte[] b = new byte[1024];
90	int bread = -1;
91	do
92	{
93	bread = read(b, 0, b.length);
94	if (bread > 0)
95	skipped += bread;
96	}
97	while (bread != -1 && skipped < n);
98	return skipped;
99	}
100
101	public int available() throws IOException
102	{
103	if (closed)
104	return 0;
105	int rc = (int) Math.min(chunkSize, Integer.MAX_VALUE);
106	return Math.min(rc, in.available());
107	}
108
109	protected long getChunked() throws IOException
110	{
111	//StringBuffer buf= new StringBuffer(1024);
112	byte[] buf = new byte[maxCharLong + 2];
113	int bufsz = 0;
114	chunkSize = -1L;
115	int c = -1;
116	do
117	{
118	c = in.read();
119	if (c > -1)
120	{
121	if (c != '\r' && c != '\n' && c != ' ' && c != '\t')
122	{
123	buf[bufsz++] = ((byte) c);
124	}
125	}
126	}
127	while (c > -1 && (c != '\n' \|\| bufsz == 0) && bufsz < buf.length);
128	if (c < 0)
129	{
130	closed = true;
131	}
132	String sbuf = new String(buf, 0, bufsz);
133	if (bufsz > maxCharLong)
134	{
135	closed = true;
136	throw new IOException("Chunked input stream failed to receive valid chunk size:" + sbuf);
137	}
138	try
139	{
140	chunkSize = Long.parseLong(sbuf, 16);
141	}
142	catch (NumberFormatException ne)
143	{
144	closed = true;
145	throw new IOException("'" + sbuf + "' " + ne.getMessage());
146	}
147	if (chunkSize < 1L)
148	closed = true;
149	if (chunkSize != 0L && c < 0)
150	{
151	//If chunk size is zero try and be tolerant that there maybe no cr or lf
152	// at the end.
153	throw new IOException("HTTP Chunked stream closed in middle of chunk.");
154	}
155	if (chunkSize < 0L)
156	throw new IOException("HTTP Chunk size received " + chunkSize + " is less than zero.");
157	return chunkSize;
158	}
159
160	public void close() throws IOException
161	{
162	synchronized (this)
163	{
164	if (closed)
165	return;
166	closed = true;
167	}
168	byte[] b = new byte[1024];
169	int bread = -1;
170	do
171	{
172	bread = read(b, 0, b.length);
173	}
174	while (bread != -1);
175	}
176
177	/*
178	* public void mark(int readlimit)
179	* {
180	* }
181	*/
182
183	public void reset() throws IOException
184	{
185	throw new IOException("Don't support marked streams");
186	}
187
188	public boolean markSupported()
189	{
190	return false;
191	}
192	}

Lines 13-18 Link Here

(-)wsexplorer/wsdl/forms/FragmentsSoapView.jsp (-128 / +57 lines)
13	* 20060222 127443 jesper@selskabet.org - Jesper S Moller	13	* 20060222 127443 jesper@selskabet.org - Jesper S Moller
14	* 20060726 144824 mahutch@ca.ibm.com - Mark Hutchinson	14	* 20060726 144824 mahutch@ca.ibm.com - Mark Hutchinson
15	* 20070305 117034 makandre@ca.ibm.com - Andrew Mak, Web Services Explorer should support SOAP Headers	15	* 20070305 117034 makandre@ca.ibm.com - Andrew Mak, Web Services Explorer should support SOAP Headers
		16	* 20070413 176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
16	*******************************************************************************/	17	*******************************************************************************/
17	%>	18	%>
18	<%@ page contentType="text/html; charset=UTF-8" import="org.eclipse.wst.ws.internal.explorer.platform.wsdl.perspective.*,	19	<%@ page contentType="text/html; charset=UTF-8" import="org.eclipse.wst.ws.internal.explorer.platform.wsdl.perspective.*,
Lines 22-27 Link Here
22	org.eclipse.wst.ws.internal.explorer.platform.wsdl.util.*,	23	org.eclipse.wst.ws.internal.explorer.platform.wsdl.util.*,
23	org.eclipse.wst.ws.internal.explorer.platform.constants.*,	24	org.eclipse.wst.ws.internal.explorer.platform.constants.*,
24	org.eclipse.wst.ws.internal.explorer.platform.util.*,	25	org.eclipse.wst.ws.internal.explorer.platform.util.*,
		26	org.eclipse.wst.ws.internal.explorer.transport.*,
25	org.eclipse.wst.wsdl.binding.soap.SOAPHeader,	27	org.eclipse.wst.wsdl.binding.soap.SOAPHeader,
26	org.w3c.dom.*,	28	org.w3c.dom.*,
27	javax.wsdl.*,	29	javax.wsdl.*,
Lines 34-119 Link Here
34	<%	36	<%
35	WSDLPerspective wsdlPerspective = controller.getWSDLPerspective();	37	WSDLPerspective wsdlPerspective = controller.getWSDLPerspective();
36	WSDLOperationElement operElement = (WSDLOperationElement)(wsdlPerspective.getNodeManager().getSelectedNode().getTreeElement());	38	WSDLOperationElement operElement = (WSDLOperationElement)(wsdlPerspective.getNodeManager().getSelectedNode().getTreeElement());
37	Operation oper = operElement.getOperation();	39	ISOAPTransport soapTransport = operElement.getSOAPTransportProvider().newTransport();
38	Hashtable soapEnvelopeNamespaceTable = new Hashtable();	40	ISOAPMessage soapMessage = soapTransport.newMessage(operElement.getMessageContext());
39	SoapHelper.addDefaultSoapEnvelopeNamespaces(soapEnvelopeNamespaceTable);	41	operElement.setPropertyAsObject(WSDLModelConstants.PROP_SOAP_REQUEST_TMP, soapMessage);
40		42
41	Iterator it = operElement.getSOAPHeaders().iterator();	43	Hashtable soapEnvelopeNamespaceTable = new Hashtable(soapMessage.getNamespaceTable());
42	StringBuffer sourceContentHeader = new StringBuffer();
43	String cachedSourceContent = operElement.getPropertyAsString(WSDLModelConstants.PROP_SOURCE_CONTENT_HEADER);
44	if (cachedSourceContent != null)
45	sourceContentHeader.append(cachedSourceContent);
46	else
47	{
48	while (it.hasNext())
49	{
50	SOAPHeader soapHeader = (SOAPHeader)it.next();
51	IXSDFragment frag = operElement.getHeaderFragment(soapHeader);
52	Element[] instanceDocuments = frag.genInstanceDocumentsFromParameterValues(!operElement.isUseLiteral(), soapEnvelopeNamespaceTable, XMLUtils.createNewDocument(null));
53	for (int i = 0; i < instanceDocuments.length; i++)
54	{
55	String serializedFragment = XMLUtils.serialize(instanceDocuments[i], true);
56	if (serializedFragment == null)
57	{
58	// On Some JRE's (Sun java 5) elements with an attribute with the xsi
59	// prefix do not serialize properly because the namespace can not
60	// be found so the string returned comes back as null. To workaround
61	// this problem try adding in the namespace declaration attribute
62	// and retry the serialization (bug 144824)
63	instanceDocuments[i].setAttribute("xmlns:xsi","http://www.w3.org/2001/XMLSchema-instance");
64	serializedFragment = XMLUtils.serialize(instanceDocuments[i], true);
65	}
66
67	sourceContentHeader.append(serializedFragment);
68	sourceContentHeader.append(HTMLUtils.LINE_SEPARATOR);
69	}
70	}
71	}
72		44
73	it = operElement.getOrderedBodyParts().iterator();	45	String cachedHeaderContent = operElement.getPropertyAsString(WSDLModelConstants.PROP_SOURCE_CONTENT_HEADER);
74	StringBuffer sourceContent = new StringBuffer();	46	String cachedBodyContent = operElement.getPropertyAsString(WSDLModelConstants.PROP_SOURCE_CONTENT);
75	cachedSourceContent = operElement.getPropertyAsString(WSDLModelConstants.PROP_SOURCE_CONTENT);	47
76	if (cachedSourceContent != null)	48	// if either header or body has been cached, need to ensure namespace table is updated
77	{	49	// from the cached copy
78	sourceContent.append(cachedSourceContent);	50	if (cachedHeaderContent != null \|\| cachedBodyContent != null) {
79	String[] nsDeclarations = (String[])operElement.getPropertyAsObject(WSDLModelConstants.PROP_SOURCE_CONTENT_NAMESPACE);	51	if (SOAPMessageUtils.decodeNamespaceTable(soapEnvelopeNamespaceTable, operElement))
80	if (nsDeclarations != null)	52	soapMessage.setNamespaceTable(soapEnvelopeNamespaceTable);
81	{
82	for (int i = 0; i < nsDeclarations.length; i++)
83	{
84	String[] prefix_ns = SoapHelper.decodeNamespaceDeclaration(nsDeclarations[i]);
85	if (!soapEnvelopeNamespaceTable.contains(prefix_ns[1]))
86	soapEnvelopeNamespaceTable.put(prefix_ns[1], prefix_ns[0]);
87	}
88	}
89	}	53	}
90	else	54
91	{	55	String headerContent;
92	while (it.hasNext())	56	String bodyContent;
93	{	57
94	Part part = (Part)it.next();	58	if (cachedHeaderContent != null)
95	IXSDFragment frag = operElement.getFragment(part);	59	headerContent = cachedHeaderContent;
96	Element[] instanceDocuments = frag.genInstanceDocumentsFromParameterValues(!operElement.isUseLiteral(), soapEnvelopeNamespaceTable, XMLUtils.createNewDocument(null));	60	else {
97	for (int i = 0; i < instanceDocuments.length; i++)	61	try {
98	{	62	SOAPMessageUtils.setHeaderContentFromModel(soapEnvelopeNamespaceTable, operElement, soapMessage);
99	String serializedFragment = XMLUtils.serialize(instanceDocuments[i], true);	63
100	if (serializedFragment == null)	64	// ensure namespace table updated in message before serialize operation
101	{	65	soapMessage.setNamespaceTable(soapEnvelopeNamespaceTable);
102	// On Some JRE's (Sun java 5) elements with an attribute with the xsi	66	headerContent = soapTransport.newSerializer().serialize(ISOAPMessage.HEADER_CONTENT, soapMessage);
103	// prefix do not serialize properly because the namespace can not	67	}
104	// be found so the string returned comes back as null. To workaround	68	catch (Exception e) {
105	// this problem try adding in the namespace declaration attribute	69	headerContent = "";
106	// and retry the serialization (bug 144824)	70	}
107	instanceDocuments[i].setAttribute("xmlns:xsi","http://www.w3.org/2001/XMLSchema-instance");
108	serializedFragment = XMLUtils.serialize(instanceDocuments[i], true);
109	}
110
111	sourceContent.append(serializedFragment);
112	sourceContent.append(HTMLUtils.LINE_SEPARATOR);
113	}
114	}
115	}	71	}
116		72
		73	if (cachedBodyContent != null)
		74	bodyContent = cachedBodyContent;
		75	else {
		76	try {
		77	SOAPMessageUtils.setBodyContentFromModel(soapEnvelopeNamespaceTable, operElement, soapMessage);
		78
		79	// ensure namespace table updated in message before serialize operation
		80	soapMessage.setNamespaceTable(soapEnvelopeNamespaceTable);
		81	bodyContent = soapTransport.newSerializer().serialize(ISOAPMessage.BODY_CONTENT, soapMessage);
		82	}
		83	catch (Exception e) {
		84	bodyContent = "";
		85	}
		86	}
		87
		88	// cache the namespace table
117	Enumeration enm = soapEnvelopeNamespaceTable.keys();	89	Enumeration enm = soapEnvelopeNamespaceTable.keys();
118	while (enm.hasMoreElements())	90	while (enm.hasMoreElements())
119	{	91	{
Lines 129-136 Link Here
129	<tr>	101	<tr>
130	<td height=30 valign="bottom" class="labels">	102	<td height=30 valign="bottom" class="labels">
131	<%	103	<%
132	Document doc = XMLUtils.createNewDocument(null);	104	Element soapEnvelopeElement = soapMessage.getEnvelope(false);
133	Element soapEnvelopeElement = SoapHelper.createSoapEnvelopeElement(doc,soapEnvelopeNamespaceTable);
134	StringBuffer header = new StringBuffer("<");	105	StringBuffer header = new StringBuffer("<");
135	header.append(soapEnvelopeElement.getTagName());	106	header.append(soapEnvelopeElement.getTagName());
136	NamedNodeMap attributes = soapEnvelopeElement.getAttributes();	107	NamedNodeMap attributes = soapEnvelopeElement.getAttributes();
Lines 163-170 Link Here
163	</table>	134	</table>
164	<%	135	<%
165	}	136	}
166		137
167	Element soapHeaderElement = SoapHelper.createSoapHeaderElement(doc);	138	Element soapHeaderElement = soapMessage.getHeader(false);
168	header.setLength(0);	139	header.setLength(0);
169	header.append('<').append(soapHeaderElement.getTagName());	140	header.append('<').append(soapHeaderElement.getTagName());
170	attributes = soapHeaderElement.getAttributes();	141	attributes = soapHeaderElement.getAttributes();
Lines 226-232 Link Here
226	<img width="16" height="16" src="<%=response.encodeURL(controller.getPathWithContext("images/space.gif"))%>">	197	<img width="16" height="16" src="<%=response.encodeURL(controller.getPathWithContext("images/space.gif"))%>">
227	</td>	198	</td>
228	<td width="100%">	199	<td width="100%">
229	<textarea id="soap_header_content" name="<%=FragmentConstants.SOURCE_CONTENT_HEADER%>" class="textareaenter"><%=HTMLUtils.charactersToHTMLEntitiesStrict(sourceContentHeader.toString())%></textarea>	200	<textarea id="soap_header_content" name="<%=FragmentConstants.SOURCE_CONTENT_HEADER%>" class="textareaenter"><%=HTMLUtils.charactersToHTMLEntitiesStrict(headerContent)%></textarea>
230	</td>	201	</td>
231	</tr>	202	</tr>
232	</table>	203	</table>
Lines 245-251 Link Here
245	</tr>	216	</tr>
246	</table>	217	</table>
247	<%	218	<%
248	Element soapBodyElement = SoapHelper.createSoapBodyElement(doc);	219	Element soapBodyElement = soapMessage.getBody(false);
249	header.setLength(0);	220	header.setLength(0);
250	header.append('<').append(soapBodyElement.getTagName());	221	header.append('<').append(soapBodyElement.getTagName());
251	attributes = soapBodyElement.getAttributes();	222	attributes = soapBodyElement.getAttributes();
Lines 287-337 Link Here
287		258
288	Element wrapperElement = null;	259	Element wrapperElement = null;
289	if (!operElement.isDocumentStyle())	260	if (!operElement.isDocumentStyle())
290	{	261	{
291	// Must be RPC style.	262	// Generate an RPC style wrapper element.
292	String encodingNamespaceURI = null;	263	wrapperElement = (Element) soapBodyElement.getFirstChild();
293	/*
294	* WS-I: In a rpc-literal SOAP binding, the serialized child element of the
295	* soap:Body element consists of a wrapper element, whose namespace is the value
296	* of the namespace attribute of the soapbind:body element and whose local name is
297	* either the name of the operation or the name of the operation suffixed
298	* with "Response". The namespace attribute is required, as opposed to being
299	* optional, to ensure that the children of the soap:Body element are namespace-
300	* qualified.
301	*/
302	BindingOperation bindingOperation = operElement.getBindingOperation();
303	if (bindingOperation != null)
304	{
305	BindingInput bindingInput = bindingOperation.getBindingInput();
306	if (bindingInput != null)
307	{
308	List extElements = bindingInput.getExtensibilityElements();
309	for (Iterator extElementsIt = extElements.iterator(); extElementsIt.hasNext();)
310	{
311	ExtensibilityElement extElement = (ExtensibilityElement)extElementsIt.next();
312	if (extElement instanceof SOAPBody)
313	{
314	encodingNamespaceURI = ((SOAPBody)extElement).getNamespaceURI();
315	break;
316	}
317	}
318	}
319	}
320	// If the namespace of the soapbind:body element is not set, get it from the operation element
321	if (encodingNamespaceURI == null)
322	encodingNamespaceURI = operElement.getEncodingNamespace();
323	// If the namespace of the operation element is not set, get it from the definition element
324	if (encodingNamespaceURI == null)
325	{
326	WSDLBindingElement bindingElement = (WSDLBindingElement)operElement.getParentElement();
327	WSDLServiceElement serviceElement = (WSDLServiceElement)bindingElement.getParentElement();
328	WSDLElement wsdlElement = (WSDLElement)serviceElement.getParentElement();
329	Definition definition = wsdlElement.getDefinition();
330	encodingNamespaceURI = definition.getTargetNamespace();
331	}
332	// Generate an RPC style wrapper element.
333	String encodingStyle = (operElement.isUseLiteral() ? null : operElement.getEncodingStyle());
334	wrapperElement = SoapHelper.createRPCWrapperElement(doc,soapEnvelopeNamespaceTable,encodingNamespaceURI,oper.getName(),encodingStyle);
335	header.setLength(0);	264	header.setLength(0);
336	header.append('<').append(wrapperElement.getTagName());	265	header.append('<').append(wrapperElement.getTagName());
337	attributes = wrapperElement.getAttributes();	266	attributes = wrapperElement.getAttributes();
Lines 398-404 Link Here
398	<img width=<%=sourceContentIndentationImageWidth%> height=16 src="<%=response.encodeURL(controller.getPathWithContext("images/space.gif"))%>">	327	<img width=<%=sourceContentIndentationImageWidth%> height=16 src="<%=response.encodeURL(controller.getPathWithContext("images/space.gif"))%>">
399	</td>	328	</td>
400	<td width="100%">	329	<td width="100%">
401	<textarea id="soap_body_content" name="<%=FragmentConstants.SOURCE_CONTENT%>" class="bigtextareaenter"><%=HTMLUtils.charactersToHTMLEntitiesStrict(sourceContent.toString())%></textarea>	330	<textarea id="soap_body_content" name="<%=FragmentConstants.SOURCE_CONTENT%>" class="bigtextareaenter"><%=HTMLUtils.charactersToHTMLEntitiesStrict(bodyContent)%></textarea>
402	</td>	331	</td>
403	</tr>	332	</tr>
404	</table>	333	</table>

Lines 11-16 Link Here

(-)wsexplorer/wsdl/forms/ReadOnlyFragmentsFormView.jsp (-157 / +45 lines)
11	* yyyymmdd bug Email and other contact information	11	* yyyymmdd bug Email and other contact information
12	* -------- -------- -----------------------------------------------------------	12	* -------- -------- -----------------------------------------------------------
13	* 20070305 117034 makandre@ca.ibm.com - Andrew Mak, Web Services Explorer should support SOAP Headers	13	* 20070305 117034 makandre@ca.ibm.com - Andrew Mak, Web Services Explorer should support SOAP Headers
		14	* 20070413 176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
14	*******************************************************************************/	15	*******************************************************************************/
15	%>	16	%>
16	<%@ page contentType="text/html; charset=UTF-8" import="org.eclipse.wst.ws.internal.explorer.platform.wsdl.perspective.*,	17	<%@ page contentType="text/html; charset=UTF-8" import="org.eclipse.wst.ws.internal.explorer.platform.wsdl.perspective.*,
Lines 19-28 Link Here
19	org.eclipse.wst.ws.internal.explorer.platform.wsdl.xsd.*,	20	org.eclipse.wst.ws.internal.explorer.platform.wsdl.xsd.*,
20	org.eclipse.wst.ws.internal.explorer.platform.wsdl.fragment.*,	21	org.eclipse.wst.ws.internal.explorer.platform.wsdl.fragment.*,
21	org.eclipse.wst.ws.internal.explorer.platform.wsdl.fragment.impl.*,	22	org.eclipse.wst.ws.internal.explorer.platform.wsdl.fragment.impl.*,
		23	org.eclipse.wst.ws.internal.explorer.platform.wsdl.util.*,
22	org.eclipse.wst.ws.internal.explorer.platform.constants.*,	24	org.eclipse.wst.ws.internal.explorer.platform.constants.*,
23	org.eclipse.wst.ws.internal.explorer.platform.perspective.Node,	25	org.eclipse.wst.ws.internal.explorer.platform.perspective.Node,
24	org.eclipse.wst.ws.internal.explorer.platform.perspective.*,	26	org.eclipse.wst.ws.internal.explorer.platform.perspective.*,
25	org.eclipse.wst.ws.internal.explorer.platform.util.*,	27	org.eclipse.wst.ws.internal.explorer.platform.util.*,
		28	org.eclipse.wst.ws.internal.explorer.transport.*,
26	org.eclipse.wst.wsdl.binding.soap.SOAPHeader,	29	org.eclipse.wst.wsdl.binding.soap.SOAPHeader,
27	org.w3c.dom.*,	30	org.w3c.dom.*,
28	javax.wsdl.*,	31	javax.wsdl.*,
Lines 32-167 Link Here
32	<jsp:useBean id="controller" class="org.eclipse.wst.ws.internal.explorer.platform.perspective.Controller" scope="session"/>	35	<jsp:useBean id="controller" class="org.eclipse.wst.ws.internal.explorer.platform.perspective.Controller" scope="session"/>
33	<jsp:useBean id="fragID" class="java.lang.StringBuffer" scope="request"/>	36	<jsp:useBean id="fragID" class="java.lang.StringBuffer" scope="request"/>
34	<jsp:useBean id="nodeID" class="java.lang.StringBuffer" scope="request"/>	37	<jsp:useBean id="nodeID" class="java.lang.StringBuffer" scope="request"/>
35
36	<%!
37	private Element soapResponse_ = null;
38	private boolean hasSOAPHeaders = false;
39
40	private void checkSOAPHeaders() {
41
42	NodeList nl = soapResponse_.getElementsByTagNameNS(FragmentConstants.URI_SOAP_ENV, FragmentConstants.QNAME_LOCAL_NAME_HEADER);
43	if (nl.getLength() == 0)
44	return;
45
46	Element soapHeader = (Element) nl.item(0);
47	NodeList nodes = soapHeader.getChildNodes();
48
49	for (int i = 0; i < nodes.getLength(); i++) {
50	if (nodes.item(i) instanceof Element) {
51	hasSOAPHeaders = true;
52	return;
53	}
54	}
55	}
56
57	private Element[] parseSOAPResponse(SOAPMessageQueue soapMessageQueue, WSDLOperationElement operElement)
58	{
59	String messages = soapMessageQueue.getMessagesFromList();
60	try
61	{
62	soapResponse_ = XMLUtils.stringToElement(messages, true);
63	checkSOAPHeaders();
64	NodeList nl = soapResponse_.getElementsByTagNameNS(FragmentConstants.URI_SOAP_ENV, FragmentConstants.QNAME_LOCAL_NAME_BODY);
65	if (nl.getLength() > 0)
66	{
67	Element soapBody = (Element)nl.item(0);
68	NodeList soapFault = soapBody.getElementsByTagNameNS(FragmentConstants.URI_SOAP_ENV, FragmentConstants.QNAME_LOCAL_NAME_FAULT);
69	if (soapFault.getLength() > 0)
70	return new Element[0];
71	NodeList instanceList;
72	if (operElement.isDocumentStyle())
73	instanceList = soapBody.getChildNodes();
74	else
75	{
76	NodeList rpcWrapper = soapBody.getElementsByTagNameNS("*", operElement.getOperation().getOutput().getMessage().getQName().getLocalPart());
77
78	/*
79	* HACK - Some of the web services out on the internet do not
80	* set their RPC wrapper properly. It should be set to the output
81	* message name of the selected operation. The hack is to
82	* assume the first element inside the body element is the
83	* RPC wrapper.
84	*/
85	if (rpcWrapper.getLength() <= 0)
86	rpcWrapper = soapBody.getElementsByTagNameNS("", "");
87
88	if (rpcWrapper.getLength() > 0)
89	instanceList = rpcWrapper.item(0).getChildNodes();
90	else
91	return null;
92	}
93	return fixSOAPResponse(instanceList, operElement);
94	}
95	}
96	catch (Throwable t) {
97	t.printStackTrace();
98	}
99	return null;
100	}
101
102	/*
103	* HACK - The root element tag name of the instance document
104	* is ambiguous. It lands on a very grey area between the SOAP
105	* spec and the WSDL spec. The two specs do not explicitly define
106	* that the root element tag name must match the name of the
107	* WSDL part. The hack is to treat elements with different tag names
108	* as instances of the WSDL part.
109	*/
110	private Element[] fixSOAPResponse(NodeList instanceList, WSDLOperationElement operElement)
111	{
112	Vector instanceVector = new Vector();
113	for (int i = 0; i < instanceList.getLength(); i++)
114	{
115	Object object = instanceList.item(i);
116	if (object != null && (object instanceof Element))
117	instanceVector.add(object);
118	}
119	Element[] instanceDocuments = new Element[instanceVector.size()];
120	Operation oper = operElement.getOperation();
121	Map partsMap = oper.getOutput().getMessage().getParts();
122	if (partsMap.size() == 1)
123	{
124	Iterator it = partsMap.values().iterator();
125	IXSDFragment frag = operElement.getFragment((Part)it.next(), false);
126	for (int i = 0; i < instanceVector.size(); i++)
127	{
128	Element element = (Element)instanceVector.get(i);
129	if (!element.getTagName().equals(frag.getName()))
130	{
131	Document doc = element.getOwnerDocument();
132	NodeList children = element.getChildNodes();
133	NamedNodeMap attributes = element.getAttributes();
134	element = doc.createElement(frag.getName());
135	for (int j = 0; j < children.getLength(); j++)
136	{
137	if (children.item(j) != null)
138	{
139	element.appendChild(children.item(j));
140	// When you append a node from one element to another,
141	// the original element will lose its reference to this node,
142	// therefore, the size of the node list will decrease by 1.
143	j--;
144	}
145	}
146	for (int j = 0; j < attributes.getLength(); j++)
147	{
148	Object attr = attributes.item(j);
149	if (attr != null && (attr instanceof Attr))
150	{
151	Attr attribute = (Attr)attr;
152	element.setAttribute(attribute.getName(), attribute.getValue());
153	}
154	}
155	}
156	instanceDocuments[i] = element;
157	}
158	}
159	else
160	instanceVector.copyInto(instanceDocuments);
161	return instanceDocuments;
162	}
163	%>
164
165	<%	38	<%
166	WSDLPerspective wsdlPerspective = controller.getWSDLPerspective();	39	WSDLPerspective wsdlPerspective = controller.getWSDLPerspective();
167	wsdlPerspective.setStatusContentType(WSDLPerspective.STATUS_CONTENT_RESULT_FORM);	40	wsdlPerspective.setStatusContentType(WSDLPerspective.STATUS_CONTENT_RESULT_FORM);
Lines 184-197 Link Here
184	}	57	}
185	else	58	else
186	{	59	{
		60	ISOAPMessage soapMessage = (ISOAPMessage) operElement.getPropertyAsObject(WSDLModelConstants.PROP_SOAP_RESPONSE);
		61	Element[] headerContent = soapMessage.getHeaderContent();;
		62	Element[] bodyContent = soapMessage.getBodyContent();
		63
187	boolean cached = ((Boolean)operElement.getPropertyAsObject(WSDLActionInputs.SOAP_RESPONSE_CACHED)).booleanValue();	64	boolean cached = ((Boolean)operElement.getPropertyAsObject(WSDLActionInputs.SOAP_RESPONSE_CACHED)).booleanValue();
188	Element[] instanceDocuments = null;	65
189	if (!cached)	66	if (soapMessage.getBody(false) == null) // body is mandatory
190	{
191	SOAPMessageQueue soapMessageQueue = wsdlPerspective.getSOAPResponseQueue();
192	instanceDocuments = parseSOAPResponse(soapMessageQueue, operElement);
193	}
194	if (!cached && !hasSOAPHeaders && instanceDocuments == null)
195	{	67	{
196	%>	68	%>
197	<table width="95%" border=0 cellpadding=6 cellspacing=0>	69	<table width="95%" border=0 cellpadding=6 cellspacing=0>
Lines 203-209 Link Here
203	</table>	75	</table>
204	<%	76	<%
205	}	77	}
206	else if (!cached && !hasSOAPHeaders && instanceDocuments.length <= 0)	78	else if ((headerContent == null \|\| headerContent.length == 0) &&
		79	(soapMessage.getFault() != null \|\| bodyContent == null \|\| bodyContent.length == 0))
207	{	80	{
208	%>	81	%>
209	<table width="95%" border=0 cellpadding=6 cellspacing=0>	82	<table width="95%" border=0 cellpadding=6 cellspacing=0>
Lines 237-267 Link Here
237		110
238	<div id="<%=headerDivId%>" class="fragarea">	111	<div id="<%=headerDivId%>" class="fragarea">
239	<%	112	<%
240	if (cached \|\| hasSOAPHeaders) {	113	boolean hasSOAPHeaders = false;
241	hasSOAPHeaders = false;	114	if (headerContent != null && headerContent.length > 0) {
		115
242	Iterator it = operElement.getSOAPHeaders(false).iterator();	116	Iterator it = operElement.getSOAPHeaders(false).iterator();
243	while (it.hasNext()) {	117	int start = 0;
244	SOAPHeader soapHeader = (SOAPHeader) it.next();	118	while (it.hasNext() && start < headerContent.length) {
245	String ns = soapHeader.getEPart().getElementDeclaration().getTargetNamespace();	119	SOAPHeader soapHeader = (SOAPHeader) it.next();
246	IXSDFragment frag = operElement.getHeaderFragment(soapHeader, false);	120	IXSDFragment fragment = operElement.getHeaderFragment(soapHeader, false);
247		121
248	if (!cached) {	122	if (!cached) {
249	NodeList nl = soapResponse_.getElementsByTagNameNS(ns, frag.getName());	123	int pos = SOAPMessageUtils.findFirstMatchingElement(
250	if (nl.getLength() == 0)	124	soapHeader.getEPart(),
		125	headerContent,
		126	soapMessage.getNamespaceTable(),
		127	fragment.getName(),
		128	start);
		129
		130	if (pos == -1)
251	continue;	131	continue;
252		132
253	Element element = (Element) nl.item(0);	133	Element element = headerContent[pos];
254	if (!frag.setParameterValuesFromInstanceDocuments(new Element[] { element }))	134	start = pos + 1;
		135
		136	if (!fragment.setParameterValuesFromInstanceDocuments(new Element[] { element }))
255	continue;	137	continue;
256	}	138	}
257	else if (!frag.validateAllParameterValues())	139	else if (!fragment.validateAllParameterValues())
258	continue;	140	continue;
259		141
260	hasSOAPHeaders = true;	142	hasSOAPHeaders = true;
261	fragID.delete(0, fragID.length());	143	fragID.delete(0, fragID.length());
262	fragID.append(frag.getID());	144	fragID.append(fragment.getID());
263	%>	145	%>
264	<jsp:include page="<%=frag.getReadFragment()%>" flush="true"/>	146	<jsp:include page="<%=fragment.getReadFragment()%>" flush="true"/>
265	<%	147	<%
266	}	148	}
267	}	149	}
Lines 294-301 Link Here
294		176
295	<div id="<%=bodyDivId%>" class="fragarea">	177	<div id="<%=bodyDivId%>" class="fragarea">
296	<%	178	<%
297	if (cached \|\| (instanceDocuments != null && instanceDocuments.length > 0)) {	179	boolean hasSOAPBody = false;
298		180	if (bodyContent != null && bodyContent.length > 0) {
		181
299	Map partsMap = oper.getOutput().getMessage().getParts();	182	Map partsMap = oper.getOutput().getMessage().getParts();
300	Iterator it = partsMap.values().iterator();	183	Iterator it = partsMap.values().iterator();
301	Hashtable uriReferences = null;	184	Hashtable uriReferences = null;
Lines 307-317 Link Here
307	if (!operElement.isUseLiteral() && (fragment instanceof ISOAPEncodingWrapperFragment))	190	if (!operElement.isUseLiteral() && (fragment instanceof ISOAPEncodingWrapperFragment))
308	{	191	{
309	if (uriReferences == null)	192	if (uriReferences == null)
310	uriReferences = SOAPEncodingWrapperFragment.parseURIReferences(soapResponse_, true);	193	uriReferences = SOAPEncodingWrapperFragment.parseURIReferences(soapMessage.getEnvelope(true), true);
311	((ISOAPEncodingWrapperFragment)fragment).setURIReferences(uriReferences);	194	((ISOAPEncodingWrapperFragment)fragment).setURIReferences(uriReferences);
312	}	195	}
313	fragment.setParameterValuesFromInstanceDocuments(instanceDocuments);	196	if (!fragment.setParameterValuesFromInstanceDocuments(bodyContent))
		197	continue;
314	}	198	}
		199	else if (!fragment.validateAllParameterValues())
		200	continue;
		201
		202	hasSOAPBody = true;
315	fragID.delete(0, fragID.length());	203	fragID.delete(0, fragID.length());
316	fragID.append(fragment.getID());	204	fragID.append(fragment.getID());
317	%>	205	%>
Lines 320-326 Link Here
320	}	208	}
321	operElement.setPropertyAsObject(WSDLActionInputs.SOAP_RESPONSE_CACHED, new Boolean(true));	209	operElement.setPropertyAsObject(WSDLActionInputs.SOAP_RESPONSE_CACHED, new Boolean(true));
322	}	210	}
323	else {	211	if (!hasSOAPBody) {
324	%>	212	%>
325	<table width="95%" border=0 cellpadding=6 cellspacing=0>	213	<table width="95%" border=0 cellpadding=6 cellspacing=0>
326	<tr>	214	<tr>

Lines 1-23 Link Here

(-)wsexplorer/wsdl/actions/InvokeWSDLSOAPOperationSourceActionJSP.jsp (-5 / +8 lines)
1	<%	1	<%
2	/*******************************************************************************	2	/*******************************************************************************
3	* Copyright (c) 2001, 2004 IBM Corporation and others.	3	* Copyright (c) 2001, 2007 IBM Corporation and others.
4	* All rights reserved. This program and the accompanying materials	4	* All rights reserved. This program and the accompanying materials
5	* are made available under the terms of the Eclipse Public License v1.0	5	* are made available under the terms of the Eclipse Public License v1.0
6	* which accompanies this distribution, and is available at	6	* which accompanies this distribution, and is available at
7	* http://www.eclipse.org/legal/epl-v10.html	7	* http://www.eclipse.org/legal/epl-v10.html
8	*	8	*
9	* Contributors:	9	* Contributors:
10	* IBM Corporation - initial API and implementation	10	* IBM Corporation - initial API and implementation
		11	* yyyymmdd bug Email and other contact information
		12	* -------- -------- -----------------------------------------------------------
		13	* 20070413 176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
11	*******************************************************************************/	14	*******************************************************************************/
12	%>	15	%>
13	<%@ page contentType="text/html; charset=UTF-8" import="org.eclipse.wst.ws.internal.explorer.platform.wsdl.perspective.*,	16	<%@ page contentType="text/html; charset=UTF-8" import="org.eclipse.wst.ws.internal.explorer.platform.wsdl.perspective.*,
14	org.eclipse.wst.ws.internal.explorer.platform.wsdl.datamodel.*,	17	org.eclipse.wst.ws.internal.explorer.platform.wsdl.datamodel.*,
15	org.eclipse.wst.ws.internal.explorer.platform.wsdl.actions.*,	18	org.eclipse.wst.ws.internal.explorer.platform.wsdl.actions.*,
16	org.eclipse.wst.ws.internal.explorer.platform.wsdl.constants.WSDLActionInputs,	19	org.eclipse.wst.ws.internal.explorer.platform.wsdl.constants.WSDLActionInputs,
17	org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport.HTTPException,
18	org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport.HTTPTransport,	20	org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport.HTTPTransport,
19	org.eclipse.wst.ws.internal.explorer.platform.perspective.*,	21	org.eclipse.wst.ws.internal.explorer.platform.perspective.*,
20	org.eclipse.wst.ws.internal.explorer.platform.constants.*,	22	org.eclipse.wst.ws.internal.explorer.platform.constants.*,
		23	org.eclipse.wst.ws.internal.explorer.transport.HTTPTransportException,
21	sun.misc.BASE64Decoder,	24	sun.misc.BASE64Decoder,
22	javax.servlet.http.HttpServletResponse,	25	javax.servlet.http.HttpServletResponse,
23	javax.wsdl.*"%>	26	javax.wsdl.*"%>
Lines 128-134 Link Here
128	</html>	131	</html>
129	<%	132	<%
130	}	133	}
131	catch (HTTPException httpe)	134	catch (HTTPTransportException httpe)
132	{	135	{
133	int code = httpe.getStatusCode();	136	int code = httpe.getStatusCode();
134	if (code == HttpServletResponse.SC_UNAUTHORIZED)	137	if (code == HttpServletResponse.SC_UNAUTHORIZED)
Lines 148-154 Link Here
148	MessageQueue messageQueue = wsdlPerspective.getMessageQueue();	151	MessageQueue messageQueue = wsdlPerspective.getMessageQueue();
149	messageQueue.addMessage(controller.getMessage("MSG_ERROR_UNEXPECTED"));	152	messageQueue.addMessage(controller.getMessage("MSG_ERROR_UNEXPECTED"));
150	messageQueue.addMessage(String.valueOf(code));	153	messageQueue.addMessage(String.valueOf(code));
151	messageQueue.addMessage(httpe.getStatusMessage());	154	messageQueue.addMessage(httpe.getMessage());
152	%>	155	%>
153	<jsp:include page="/wsdl/scripts/wsdlpanes.jsp" flush="true"/>	156	<jsp:include page="/wsdl/scripts/wsdlpanes.jsp" flush="true"/>
154	<html>	157	<html>

Removed Link Here

(-)wsexplorer-src/org/eclipse/wst/ws/internal/explorer/platform/wsdl/util/SoapHelper.java (-138 lines)
1	/*******************************************************************************
2	* Copyright (c) 2002, 2007 IBM Corporation and others.
3	* All rights reserved. This program and the accompanying materials
4	* are made available under the terms of the Eclipse Public License v1.0
5	* which accompanies this distribution, and is available at
6	* http://www.eclipse.org/legal/epl-v10.html
7	*
8	* Contributors:
9	* IBM Corporation - initial API and implementation
10	* yyyymmdd bug Email and other contact information
11	* -------- -------- -----------------------------------------------------------
12	* 20070305 117034 makandre@ca.ibm.com - Andrew Mak, Web Services Explorer should support SOAP Headers
13	*******************************************************************************/
14
15	package org.eclipse.wst.ws.internal.explorer.platform.wsdl.util;
16
17	import java.util.Enumeration;
18	import java.util.Hashtable;
19	import org.apache.axis.Constants;
20	import org.eclipse.wst.ws.internal.explorer.platform.util.URLUtils;
21	import org.w3c.dom.Document;
22	import org.w3c.dom.Element;
23
24	public class SoapHelper
25	{
26	private static Hashtable defaultSoapEnvelopeNamespaces_ = null;
27
28	private static final void initDefaultSoapEnvelopeNamespaces()
29	{
30	defaultSoapEnvelopeNamespaces_ = new Hashtable();
31	defaultSoapEnvelopeNamespaces_.put(Constants.URI_SOAP11_ENV,Constants.NS_PREFIX_SOAP_ENV);
32	defaultSoapEnvelopeNamespaces_.put(Constants.URI_2001_SCHEMA_XSI,Constants.NS_PREFIX_SCHEMA_XSI);
33	defaultSoapEnvelopeNamespaces_.put(Constants.URI_2001_SCHEMA_XSD,Constants.NS_PREFIX_SCHEMA_XSD);
34	}
35
36	public static final void addDefaultSoapEnvelopeNamespaces(Hashtable soapEnvelopeNamespaces)
37	{
38	if (defaultSoapEnvelopeNamespaces_ == null)
39	initDefaultSoapEnvelopeNamespaces();
40	Enumeration defaultSoapEnvelopeNamespaceURIs = defaultSoapEnvelopeNamespaces_.keys();
41	while (defaultSoapEnvelopeNamespaceURIs.hasMoreElements())
42	{
43	String defaultSoapEnvelopeNamespaceURI = (String)defaultSoapEnvelopeNamespaceURIs.nextElement();
44	soapEnvelopeNamespaces.put(defaultSoapEnvelopeNamespaceURI,(String)defaultSoapEnvelopeNamespaces_.get(defaultSoapEnvelopeNamespaceURI));
45	}
46	}
47
48	public static final boolean isDefaultSoapEnvelopeNamespace(String namespaceURI,String namespacePrefix)
49	{
50	if (defaultSoapEnvelopeNamespaces_ == null)
51	initDefaultSoapEnvelopeNamespaces();
52	if (defaultSoapEnvelopeNamespaces_.get(namespaceURI) != null)
53	return true;
54	return false;
55	}
56
57	public static final Element createSoapEnvelopeElement(Document doc,Hashtable soapEnvelopeNamespaceTable)
58	{
59	Element soapEnvelopeElement = doc.createElement("soapenv:Envelope");
60	Enumeration e = soapEnvelopeNamespaceTable.keys();
61	while (e.hasMoreElements())
62	{
63	String soapEnvelopeNamespaceURI = (String)e.nextElement();
64	StringBuffer soapEnvelopeNamespaceAttr = new StringBuffer("xmlns:");
65	soapEnvelopeNamespaceAttr.append((String)soapEnvelopeNamespaceTable.get(soapEnvelopeNamespaceURI));
66	soapEnvelopeElement.setAttribute(soapEnvelopeNamespaceAttr.toString(),soapEnvelopeNamespaceURI);
67	}
68	return soapEnvelopeElement;
69	}
70
71	public static final Element createSoapHeaderElement(Document doc)
72	{
73	return doc.createElement("soapenv:Header");
74	}
75
76	public static final Element createSoapBodyElement(Document doc)
77	{
78	return doc.createElement("soapenv:Body");
79	}
80
81	public static final Element createRPCWrapperElement(Document doc,Hashtable soapEnvelopeNamespaceTable,String encodingNamespaceURI,String operationName, String encodingStyle)
82	{
83	int nsId = 0;
84	StringBuffer wrapperElementName = new StringBuffer();
85	String encodingNamespacePrefix = (String)soapEnvelopeNamespaceTable.get(encodingNamespaceURI);
86	if (encodingNamespacePrefix != null)
87	wrapperElementName.append(encodingNamespacePrefix);
88	else
89	{
90	// Loop until we generate a unique prefix.
91	do
92	{
93	wrapperElementName.setLength(0);
94	wrapperElementName.append("ns").append(nsId);
95	if (!soapEnvelopeNamespaceTable.containsValue(wrapperElementName.toString()))
96	break;
97	nsId++;
98	} while (true);
99	}
100	String wrapperElementNamePrefix = wrapperElementName.toString();
101	wrapperElementName.append(':').append(operationName);
102	Element wrapperElement = doc.createElement(wrapperElementName.toString());
103	StringBuffer namespaceAttrName = new StringBuffer("xmlns:");
104	namespaceAttrName.append(wrapperElementNamePrefix);
105	wrapperElement.setAttribute(namespaceAttrName.toString(),encodingNamespaceURI);
106	if (encodingStyle != null)
107	wrapperElement.setAttribute("soapenv:encodingStyle",encodingStyle);
108	return wrapperElement;
109	}
110
111	public static final String encodeNamespaceDeclaration(String prefix, String uri)
112	{
113	StringBuffer sb = new StringBuffer();
114	sb.append(prefix);
115	sb.append(" ");
116	sb.append(uri);
117	String result = URLUtils.encode(sb.toString());
118	return result;
119	}
120
121	public static final String[] decodeNamespaceDeclaration(String s)
122	{
123	String sCopy = URLUtils.decode(s);
124	int index = sCopy.indexOf(" ");
125	String[] nsDecl = new String[2];
126	if (index != -1)
127	{
128	nsDecl[0] = sCopy.substring(0, index);
129	nsDecl[1] = sCopy.substring(index+1, sCopy.length());
130	}
131	else
132	{
133	nsDecl[0] = null;
134	nsDecl[1] = sCopy;
135	}
136	return nsDecl;
137	}
138	}

Added Link Here

(-)src/org/eclipse/wst/ws/internal/explorer/platform/wsdl/transport/SOAPTransportProvider.java (+30 lines)
1	/*******************************************************************************
2	* Copyright (c) 2007 IBM Corporation and others.
3	* All rights reserved. This program and the accompanying materials
4	* are made available under the terms of the Eclipse Public License v1.0
5	* which accompanies this distribution, and is available at
6	* http://www.eclipse.org/legal/epl-v10.html
7	*
8	* Contributors:
9	* IBM Corporation - initial API and implementation
10	* yyyymmdd bug Email and other contact information
11	* -------- -------- -----------------------------------------------------------
12	* 20070413 176493 makandre@ca.ibm.com - Andrew Mak, WSE: Make message/transport stack pluggable
13	*******************************************************************************/
14	package org.eclipse.wst.ws.internal.explorer.platform.wsdl.transport;
15
16	import org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransport;
17	import org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransportProvider;
18
19	/**
20	* WSE's default implementation for ISOAPTransportProvider.
21	*/
22	public class SOAPTransportProvider implements ISOAPTransportProvider {
23
24	/* (non-Javadoc)
25	* @see org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransportProvider#newTransport()
26	*/
27	public ISOAPTransport newTransport() {
28	return new SOAPTransport();
29	}
30	}

Added Link Here

(-)schema/wseTransportProvider.exsd (+145 lines)
1	<?xml version='1.0' encoding='UTF-8'?>
2	<!-- Schema file written by PDE -->
3	<schema targetNamespace="org.eclipse.wst.ws.explorer">
4	<annotation>
5	<appInfo>
6	<meta.schema plugin="org.eclipse.wst.ws.explorer" id="wseTransportProvider" name="Web Services Explorer Transport Provider"/>
7	</appInfo>
8	<documentation>
9	[Enter description of this extension point.]
10	</documentation>
11	</annotation>
12
13	<element name="extension">
14	<complexType>
15	<sequence minOccurs="1" maxOccurs="unbounded">
16	<element ref="soapTransportProvider"/>
17	</sequence>
18	<attribute name="point" type="string" use="required">
19	<annotation>
20	<documentation>
21	A fully qualified identifier of the target extension point
22	</documentation>
23	</annotation>
24	</attribute>
25	<attribute name="id" type="string">
26	<annotation>
27	<documentation>
28	An optional identifier for this extension instance
29	</documentation>
30	</annotation>
31	</attribute>
32	<attribute name="name" type="string">
33	<annotation>
34	<documentation>
35	An optional name this extension instance
36	</documentation>
37	<appInfo>
38	<meta.attribute translatable="true"/>
39	</appInfo>
40	</annotation>
41	</attribute>
42	</complexType>
43	</element>
44
45	<element name="soapTransportProvider">
46	<annotation>
47	<documentation>
48	This extension point entry allows an extender to plug in a new factory for creating org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransport instances. The ISOAPTranport is used by the Web Services Explorer for invoking web services operations that uses the SOAP message protocol.
49	</documentation>
50	</annotation>
51	<complexType>
52	<attribute name="class" type="string" use="required">
53	<annotation>
54	<documentation>
55	This class must implement the org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransportProvider interface.
56	</documentation>
57	<appInfo>
58	<meta.attribute kind="java" basedOn="org.eclipse.wst.ws.internal.explorer.transport.ISOAPTransportProvider"/>
59	</appInfo>
60	</annotation>
61	</attribute>
62	<attribute name="id" type="string" use="required">
63	<annotation>
64	<documentation>
65	This id uniquely identifies this soapTransportProvider element.
66	</documentation>
67	</annotation>
68	</attribute>
69	<attribute name="name" type="string" use="required">
70	<annotation>
71	<documentation>
72	The name of this soapTransportProvider element.
73	</documentation>
74	<appInfo>
75	<meta.attribute translatable="true"/>
76	</appInfo>
77	</annotation>
78	</attribute>
79	<attribute name="namespaceURI" type="string">
80	<annotation>
81	<documentation>
82	The namespace URI of the soap:binding element that this transport provider claims support for. For example, if this transport provider supports the SOAP 1.1 binding, the value of this attribute would be http://schemas.xmlsoap.org/wsdl/soap/. If unspecified, this transport provider claims support for all SOAP bindings.
83	</documentation>
84	</annotation>
85	</attribute>
86	<attribute name="transportURI" type="string">
87	<annotation>
88	<documentation>
89	The transport protocol URI of the soap:binding element that this transport provider claims support for. For example, if this transport provider supports SOAP over HTTP, the value of this attribute would be http://schemas.xmlsoap.org/soap/http. If unspecified, this transport provider claims support for all transport protocols.
90	</documentation>
91	</annotation>
92	</attribute>
93	</complexType>
94	</element>
95
96	<annotation>
97	<appInfo>
98	<meta.section type="since"/>
99	</appInfo>
100	<documentation>
101	<b>This extension point is part of an interim API that is still under development and expected to change significantly before reaching stability. It is being made available at this early stage to solicit feedback from pioneering adopters on the understanding that any code that uses this API will almost certainly be broken (repeatedly) as the API evolves.</b>
102	</documentation>
103	</annotation>
104
105	<annotation>
106	<appInfo>
107	<meta.section type="examples"/>
108	</appInfo>
109	<documentation>
110	[Enter extension point usage example here.]
111	</documentation>
112	</annotation>
113
114	<annotation>
115	<appInfo>
116	<meta.section type="apiInfo"/>
117	</appInfo>
118	<documentation>
119	[Enter API information here.]
120	</documentation>
121	</annotation>
122
123	<annotation>
124	<appInfo>
125	<meta.section type="implementation"/>
126	</appInfo>
127	<documentation>
128	[Enter information about supplied implementation of this extension point.]
129	</documentation>
130	</annotation>
131
132	<annotation>
133	<appInfo>
134	<meta.section type="copyright"/>
135	</appInfo>
136	<documentation>
137	Copyright (c) 2007 IBM Corporation and others.<br>
138	All rights reserved. This program and the accompanying materials are made
139	available under the terms of the Eclipse Public License v1.0 which accompanies
140	this distribution, and is available at <a
141	href="http://www.eclipse.org/legal/epl-v10.html">http://www.eclipse.org/legal/epl-v10.html</a>
142	</documentation>
143	</annotation>
144
145	</schema>