graveyard/src/transport/axis2/Axis2Transport.h - axis-axis1-c - Git at Google

 /*
  *   Copyright 2003-2004 The Apache Software Foundation.
 // (c) Copyright IBM Corp. 2004, 2005 All Rights Reserved
  *
  *   Licensed under the Apache License, Version 2.0 (the "License");
  *   you may not use this file except in compliance with the License.
  *   You may obtain a copy of the License at
  *
  *       http://www.apache.org/licenses/LICENSE-2.0
  *
  *   Unless required by applicable law or agreed to in writing, software
  *   distributed under the License is distributed on an "AS IS" BASIS,
  *   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  *   See the License for the specific language governing permissions and
  *   limitations under the License.
  */

 /*
  * @author Samisa Abeysinghe (sabeysinghe@virtusa.com)
  */


 #if !defined(_AXIS_AXIS_TRANSPORT_HPP)
 #define _AXIS_AXIS_TRANSPORT_HPP

 #include "../SOAPTransport.h"
 #include "Channel.h"
 #include "SecureChannel.hpp"
 #include "ChannelFactory.hpp"
 #include <string>
 #include <vector>

 AXIS_CPP_NAMESPACE_USE using namespace std;

 int axtoi (char *hexStg);

 class Axis2Transport:public SOAPTransport
 {
   public:
     Axis2Transport ();
     virtual ~ Axis2Transport ();

   /**
     * Sets the endpoint URI.
     * Keeps track of the changes made to the URI. (Because if the URI changes,
     * we cannot reuse the opned socket)
     * @param pcEndPointURI End point URI of the service to connect to.
     *                       e.g. http://localhost:8080/axis/services/echo
     */
     void setEndpointUri (const char *) throw (AxisTransportException);
     int openConnection ();
     void closeConnection ();
     AXIS_TRANSPORT_STATUS sendBytes (const char *, const void *);

     AXIS_TRANSPORT_STATUS getBytes (char *, int *) throw (AxisException,
 							  AxisTransportException);
     int setTransportProperty (AXIS_TRANSPORT_INFORMATION_TYPE,
 			       const char *) throw (AxisTransportException);
     const char *getTransportProperty (AXIS_TRANSPORT_INFORMATION_TYPE)
 	throw (AxisTransportException);
     int setTransportProperty (const char *,
 			       const char *) throw (AxisTransportException);
     const char *getTransportProperty (const char *pcKey, bool response=true)
 	throw (AxisTransportException);
     void setAttachment (const char *pcAttachmentId, const char *pcAttachment) {};

     ISoapAttachment* getAttachment (const char *pcAttachmentId) { return NULL;};

     void setSessionId (const char *pcSessionId);

     const char *getSessionId ();

     const char *getServiceName ();
     AXIS_PROTOCOL_TYPE getProtocol ();
     int setProtocol(AXIS_PROTOCOL_TYPE eProtocol);
     int getSubProtocol ();
     AXIS_TRANSPORT_STATUS flushOutput () throw (AxisTransportException);

   /**
     * Set proxy server and port for transport.
     *
     * @param pcProxyHost Host name of proxy server
     * @param uiProxyPort Port of proxy server
     */
     void setProxy (const char *pcProxyHost, unsigned int uiProxyPort);

   /**
     * Set transport timeout.
     *
     * @param lSeconds Timeout in seconds
     */
     void setTimeout (const long lSeconds);

   /**
     * @return HTTP protocol in use - HTTP/1.1 or HTTP/1.0
     */
     const char *getHTTPProtocol ();

   /**
     * @return HTTP Method in use - POST, GET etc.
     */
     const char *getHTTPMethod ();

   /**
     * Set HTTP Method to use
     * @param cpMethod - Possible values POST, GET, etc.
     *        Only POST is handled correctly at the moment
     */
     void setHTTPMethod (const char *);

     const char *getHTTPHeaders ();

     // This is used by SimpleAxisServer
     void setSocket (unsigned int);

     /**
     * Iterator initiatior for transport property keys
     *
     * This method must be called first to initiate access to the list of
     * transport property keys.
     *
     * @return First transport property key. If there are no transport
     * properties set, returns NULL.
     */
     const char* getFirstTransportPropertyKey();

   /**
     * Iterator for transport property keys
     *
     * getFirstTransportPropertyKey() method must have been called at least once
     * before this method is called. If not behaviour is undefined.
     *
     * This method advances the iterator by one position.
     * Repeated calls always retuen the next value.
     *
     * @return Next transport property key. If there are no transport
     * properties set or if iterator is at the end of the list, returns NULL.
     */
     const char* getNextTransportPropertyKey();

   /**
     * Accessor for transport property keys.
     *
     * This method gives access to the key corresponding to the transport key
     * currently being pointed by transport property key iterator.
     *
     * getFirstTransportPropertyKey() method must have been called at least once
     * before this method is called. If not behaviour is undefined.
     *
     * This method does not advance the iterator.
     * Repeated calls always retuen the same key unless
     * getNextTransportPropertyKey() is called in between.
     *
     * @return Current transport property key. If there are no transport
     * properties set or if iterator is at the end of the list, returns NULL.
     */
     const char* getCurrentTransportPropertyKey();

   /**
     * Accessor for transport property values.
     *
     * This method gives access to the value corresponding to the transport key
     * currently being pointed by transport property key iterator.
     * As keys and values are treated as paires, access to the value field is
     * based on the access to the key field.
     *
     * getFirstTransportPropertyKey() method must have been called at least once
     * before this method is called. If not behaviour is undefined.
     *
     * This method does not advance the iterator.
     * Repeated calls always retuen the same value unless
     * getNextTransportPropertyKey() is called in between.
     *
     * @return Current transport property value. If there are no transport
     * properties set or if iterator is at the end of the list, returns NULL.
     */
     const char* getCurrentTransportPropertyValue();

   /**
     * Deletes the transport property key:value pair currently pointed to by
     * the iterator.
     */
     void deleteCurrentTransportProperty();

   /**
     * Deletes the given occerance of the transport property key:value pair
     * corresponding to the given key.
     *
     * This method does not advance the iterator in line with the deletes done.
     * In case you want to access the transport properties after using this
     * method, it is advisable to reinitialize the iterator using
     * getFirstTransportPropertyKey();
     * However you can use this method despite where the iterator is
     * pointing currently.
     *
     * @param pcKey Key of the transport property key:value pair to be deleted
     *              If the given key is not set currently, nothing will happen.
     * @param uiOccurance Which occerance of the key to be deleted, because
     *                    there can be multiple values for the same key.
     *                    Default is to delete the first occurance.
     *                    Count starts from 1.
     */
     void deleteTransportProperty(char* pcKey, unsigned int uiOccurance = 1);

   /**
     * Set whether to Maitain session with service ot not.
     * @param bSession - true is session should be maintained. False otherwise.
     */
     virtual void setMaintainSession(bool bSession);

     char* getIncomingSOAPMimeHeaders() {return NULL;}


   protected:
     void processResponseHTTPHeaders ();
     void processRootMimeBody ();
     void processMimeHeader ();
     void processMimeBody();
     void getAttachment(char* pStrAttachment, int* pIntSize, int intAttachmentId);
     int FindTransportPropertyIndex (std::string);

   /**
     * Keeps track of if we need to reopen connection.
     * Set true by setEndpointUri.
     * Set false when a socket connection is established with the enpoint and
     * when there is no need renew (that is close and open again) an existing connection.
     */
     bool m_bReopenConnection;

   /**
     * Message string to be sent.
     */
     std::string m_strBytesToSend;

   /**
     * Message header to be sent.
     */
     std::string m_strHeaderToSend;

   /**
     * Vector to hold HTTP header key/value pairs
     */
     std::vector < std::pair < std::string, std::string > >m_vHTTPHeaders;

   /**
     * Transport header iterator
     */
     vector <std::pair < std::string, std::string > >::iterator m_viCurrentHeader;

   /**
     * HTTP protocol (1.1 or 1.0). Default is HTTP/1.1
     */
     std::string m_strHTTPProtocol;
   /**
     * HTTP method (POST, GET etc.)  - Only support POST at the moment
     */
     std::string m_strHTTPMethod;

   /**
     * Bytes left in the payload buffer to be read
     */
     int m_iBytesLeft;

   /**
     * Payload lenght
     */
     unsigned int m_iContentLength;

   /**
     * Is the message chunked
     */
     int m_bChunked;

   /**
     * String holding what we received over the channel
     */
     std::string m_strReceived;

   /**
     * Have we read past HTTP headers?
     */
     bool m_bReadPastHTTPHeaders;

   /**
     * Payload buffer
     */
     const char *m_pcReceived;

   /**
     * Proxy server name.
     */
     std::string m_strProxyHost;
   /**
     * Proxy server port.
     */
     unsigned int m_uiProxyPort;
   /**
     * Use Proxy or not?
     */
     bool m_bUseProxy;
   /**
     * HTTP headers in response
     */
     std::string m_strResponseHTTPHeaders;
   /**
     * HTTP protocol (1.1 or 1.0). Default is HTTP/1.1
     */
     std::string m_strResponseHTTPProtocol;
   /**
     * HTTP status code
     */
     int m_iResponseHTTPStatusCode;
   /**
     * HTTP status code
     */
     std::string m_strResponseHTTPStatusMessage;
   /**
     * Vector to hold response HTTP header key/value pairs
     */
     std::vector < std::pair < std::string,
 	std::string > >m_vResponseHTTPHeaders;

   /**
     * Channel used for communication
     */
     Channel *m_pChannel;

     bool m_bChannelSecure;

   /**
     * Message header string to be sent.
     */
     std::string m_strHeaderBytesToSend;

   /**
     * Should the Stub maintain session with service?
     */
     bool m_bMaintainSession;

   /**
     * Session key sent by service
     */
     std::string m_strSessionKey;

   /**
     * Content-Type holder
     */
     std::string m_strContentType;

   /**
     * Mime Boundary value
     */
     std::string m_strMimeBoundary;

   /**
     * Mime type value
     */
     std::string m_strMimeType;

   /**
     * Mime start value
     */
     std::string m_strMimeStart;

   /**
     * Received payload is a mime struct
     */
     bool m_bMimeTrue;

     bool m_bReadPastRootMimeHeader;
     std::string m_strMimeContentType;
     std::string m_strMimeContentTransferEncoding;
     std::string m_strMimeContentID;
     std::string m_strMimeContentLocation;
     std::string m_strMimeReceived;
     ChannelFactory* m_pFactory;
 };

 #endif
	/*
	* Copyright 2003-2004 The Apache Software Foundation.
	// (c) Copyright IBM Corp. 2004, 2005 All Rights Reserved
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software
	* distributed under the License is distributed on an "AS IS" BASIS,
	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	* See the License for the specific language governing permissions and
	* limitations under the License.
	*/

	/*
	* @author Samisa Abeysinghe (sabeysinghe@virtusa.com)
	*/


	#if !defined(_AXIS_AXIS_TRANSPORT_HPP)
	#define _AXIS_AXIS_TRANSPORT_HPP

	#include "../SOAPTransport.h"
	#include "Channel.h"
	#include "SecureChannel.hpp"
	#include "ChannelFactory.hpp"
	#include <string>
	#include <vector>

	AXIS_CPP_NAMESPACE_USE using namespace std;

	int axtoi (char *hexStg);

	class Axis2Transport:public SOAPTransport
	{
	public:
	Axis2Transport ();
	virtual ~ Axis2Transport ();

	/**
	* Sets the endpoint URI.
	* Keeps track of the changes made to the URI. (Because if the URI changes,
	* we cannot reuse the opned socket)
	* @param pcEndPointURI End point URI of the service to connect to.
	* e.g. http://localhost:8080/axis/services/echo
	*/
	void setEndpointUri (const char *) throw (AxisTransportException);
	int openConnection ();
	void closeConnection ();
	AXIS_TRANSPORT_STATUS sendBytes (const char , const void );

	AXIS_TRANSPORT_STATUS getBytes (char , int ) throw (AxisException,
	AxisTransportException);
	int setTransportProperty (AXIS_TRANSPORT_INFORMATION_TYPE,
	const char *) throw (AxisTransportException);
	const char *getTransportProperty (AXIS_TRANSPORT_INFORMATION_TYPE)
	throw (AxisTransportException);
	int setTransportProperty (const char *,
	const char *) throw (AxisTransportException);
	const char getTransportProperty (const char pcKey, bool response=true)
	throw (AxisTransportException);
	void setAttachment (const char pcAttachmentId, const char pcAttachment) {};

	ISoapAttachment* getAttachment (const char *pcAttachmentId) { return NULL;};

	void setSessionId (const char *pcSessionId);

	const char *getSessionId ();

	const char *getServiceName ();
	AXIS_PROTOCOL_TYPE getProtocol ();
	int setProtocol(AXIS_PROTOCOL_TYPE eProtocol);
	int getSubProtocol ();
	AXIS_TRANSPORT_STATUS flushOutput () throw (AxisTransportException);

	/**
	* Set proxy server and port for transport.
	*
	* @param pcProxyHost Host name of proxy server
	* @param uiProxyPort Port of proxy server
	*/
	void setProxy (const char *pcProxyHost, unsigned int uiProxyPort);

	/**
	* Set transport timeout.
	*
	* @param lSeconds Timeout in seconds
	*/
	void setTimeout (const long lSeconds);

	/**
	* @return HTTP protocol in use - HTTP/1.1 or HTTP/1.0
	*/
	const char *getHTTPProtocol ();

	/**
	* @return HTTP Method in use - POST, GET etc.
	*/
	const char *getHTTPMethod ();

	/**
	* Set HTTP Method to use
	* @param cpMethod - Possible values POST, GET, etc.
	* Only POST is handled correctly at the moment
	*/
	void setHTTPMethod (const char *);

	const char *getHTTPHeaders ();

	// This is used by SimpleAxisServer
	void setSocket (unsigned int);

	/**
	* Iterator initiatior for transport property keys
	*
	* This method must be called first to initiate access to the list of
	* transport property keys.
	*
	* @return First transport property key. If there are no transport
	* properties set, returns NULL.
	*/
	const char* getFirstTransportPropertyKey();

	/**
	* Iterator for transport property keys
	*
	* getFirstTransportPropertyKey() method must have been called at least once
	* before this method is called. If not behaviour is undefined.
	*
	* This method advances the iterator by one position.
	* Repeated calls always retuen the next value.
	*
	* @return Next transport property key. If there are no transport
	* properties set or if iterator is at the end of the list, returns NULL.
	*/
	const char* getNextTransportPropertyKey();

	/**
	* Accessor for transport property keys.
	*
	* This method gives access to the key corresponding to the transport key
	* currently being pointed by transport property key iterator.
	*
	* getFirstTransportPropertyKey() method must have been called at least once
	* before this method is called. If not behaviour is undefined.
	*
	* This method does not advance the iterator.
	* Repeated calls always retuen the same key unless
	* getNextTransportPropertyKey() is called in between.
	*
	* @return Current transport property key. If there are no transport
	* properties set or if iterator is at the end of the list, returns NULL.
	*/
	const char* getCurrentTransportPropertyKey();

	/**
	* Accessor for transport property values.
	*
	* This method gives access to the value corresponding to the transport key
	* currently being pointed by transport property key iterator.
	* As keys and values are treated as paires, access to the value field is
	* based on the access to the key field.
	*
	* getFirstTransportPropertyKey() method must have been called at least once
	* before this method is called. If not behaviour is undefined.
	*
	* This method does not advance the iterator.
	* Repeated calls always retuen the same value unless
	* getNextTransportPropertyKey() is called in between.
	*
	* @return Current transport property value. If there are no transport
	* properties set or if iterator is at the end of the list, returns NULL.
	*/
	const char* getCurrentTransportPropertyValue();

	/**
	* Deletes the transport property key:value pair currently pointed to by
	* the iterator.
	*/
	void deleteCurrentTransportProperty();

	/**
	* Deletes the given occerance of the transport property key:value pair
	* corresponding to the given key.
	*
	* This method does not advance the iterator in line with the deletes done.
	* In case you want to access the transport properties after using this
	* method, it is advisable to reinitialize the iterator using
	* getFirstTransportPropertyKey();
	* However you can use this method despite where the iterator is
	* pointing currently.
	*
	* @param pcKey Key of the transport property key:value pair to be deleted
	* If the given key is not set currently, nothing will happen.
	* @param uiOccurance Which occerance of the key to be deleted, because
	* there can be multiple values for the same key.
	* Default is to delete the first occurance.
	* Count starts from 1.
	*/
	void deleteTransportProperty(char* pcKey, unsigned int uiOccurance = 1);

	/**
	* Set whether to Maitain session with service ot not.
	* @param bSession - true is session should be maintained. False otherwise.
	*/
	virtual void setMaintainSession(bool bSession);

	char* getIncomingSOAPMimeHeaders() {return NULL;}


	protected:
	void processResponseHTTPHeaders ();
	void processRootMimeBody ();
	void processMimeHeader ();
	void processMimeBody();
	void getAttachment(char* pStrAttachment, int* pIntSize, int intAttachmentId);
	int FindTransportPropertyIndex (std::string);

	/**
	* Keeps track of if we need to reopen connection.
	* Set true by setEndpointUri.
	* Set false when a socket connection is established with the enpoint and
	* when there is no need renew (that is close and open again) an existing connection.
	*/
	bool m_bReopenConnection;

	/**
	* Message string to be sent.
	*/
	std::string m_strBytesToSend;

	/**
	* Message header to be sent.
	*/
	std::string m_strHeaderToSend;

	/**
	* Vector to hold HTTP header key/value pairs
	*/
	std::vector < std::pair < std::string, std::string > >m_vHTTPHeaders;

	/**
	* Transport header iterator
	*/
	vector <std::pair < std::string, std::string > >::iterator m_viCurrentHeader;

	/**
	* HTTP protocol (1.1 or 1.0). Default is HTTP/1.1
	*/
	std::string m_strHTTPProtocol;
	/**
	* HTTP method (POST, GET etc.) - Only support POST at the moment
	*/
	std::string m_strHTTPMethod;

	/**
	* Bytes left in the payload buffer to be read
	*/
	int m_iBytesLeft;

	/**
	* Payload lenght
	*/
	unsigned int m_iContentLength;

	/**
	* Is the message chunked
	*/
	int m_bChunked;

	/**
	* String holding what we received over the channel
	*/
	std::string m_strReceived;

	/**
	* Have we read past HTTP headers?
	*/
	bool m_bReadPastHTTPHeaders;

	/**
	* Payload buffer
	*/
	const char *m_pcReceived;

	/**
	* Proxy server name.
	*/
	std::string m_strProxyHost;
	/**
	* Proxy server port.
	*/
	unsigned int m_uiProxyPort;
	/**
	* Use Proxy or not?
	*/
	bool m_bUseProxy;
	/**
	* HTTP headers in response
	*/
	std::string m_strResponseHTTPHeaders;
	/**
	* HTTP protocol (1.1 or 1.0). Default is HTTP/1.1
	*/
	std::string m_strResponseHTTPProtocol;
	/**
	* HTTP status code
	*/
	int m_iResponseHTTPStatusCode;
	/**
	* HTTP status code
	*/
	std::string m_strResponseHTTPStatusMessage;
	/**
	* Vector to hold response HTTP header key/value pairs
	*/
	std::vector < std::pair < std::string,
	std::string > >m_vResponseHTTPHeaders;

	/**
	* Channel used for communication
	*/
	Channel *m_pChannel;

	bool m_bChannelSecure;

	/**
	* Message header string to be sent.
	*/
	std::string m_strHeaderBytesToSend;

	/**
	* Should the Stub maintain session with service?
	*/
	bool m_bMaintainSession;

	/**
	* Session key sent by service
	*/
	std::string m_strSessionKey;

	/**
	* Content-Type holder
	*/
	std::string m_strContentType;

	/**
	* Mime Boundary value
	*/
	std::string m_strMimeBoundary;

	/**
	* Mime type value
	*/
	std::string m_strMimeType;

	/**
	* Mime start value
	*/
	std::string m_strMimeStart;

	/**
	* Received payload is a mime struct
	*/
	bool m_bMimeTrue;

	bool m_bReadPastRootMimeHeader;
	std::string m_strMimeContentType;
	std::string m_strMimeContentTransferEncoding;
	std::string m_strMimeContentID;
	std::string m_strMimeContentLocation;
	std::string m_strMimeReceived;
	ChannelFactory* m_pFactory;
	};

	#endif