main.cpp

Go to the documentation of this file.

/*
        Main.cpp For Simple SOAP test Server

        This is the Server driver program for the Simple SOAP Test Server.  This
        server allows you to test compatablility of a Simple SOAP Client with the
        Simple SOAP Server.  The Server assumes 127.0.0.1 with port 8080 as the server
        port.  It responds to requests on the port just like a Simple SOAP Server.

        It prints all of it's requests.

        This Program requires the Simple SOAP server Library from Scott Seeley
        and the Simple Soap TCP Server from Jasen Plietz

        History:

                18-Aug-2003             GJPC    Intial Type in
                09-Sep-2003             GJPC    added set/get logmask

        $Log: main.cpp,v $
        Revision 1.1  2005/03/22 22:30:32  gjpc
        This is the intial check in of the Simple SOAP library.
        
        The code compiles and executes under MSVC .NET and GNU 3.3
        
        It has been run under Debian, SUSE, CYGWIN and WinXP
        
        Revision 1.3  2004/04/23 19:53:32  gjpc
        Re-formatted output to look like client output
        
        Revision 1.2  2004/04/23 16:58:36  gjpc
        expanded the Simple SOAP package to allow RPC's within RPC's
        extended the test client to allow for programable validation
        

*/
#include <iostream>
//#pragma warning( disable: 4786 )
#include "networkApp.h"
#if !defined(SOAPONHTTP_H)
    #include "SOAPonHTTP.h"    
#endif // !defined(SOAPONHTTP_H)
#if !defined(SOAPELEMENT_H)
    #include "SOAPElement.h"
#endif // !defined(SOAPELEMENT_H)
#if !defined(SOAPDISPATCHER_H)
    #include "SOAPDispatcher.h"
#endif // !defined(SOAPDISPATCHER_H)
#if !defined(SOAPFAULT_H)
    #include "SOAPFault.h"
#endif // !defined(SOAPFAULT_H)
#ifndef TSOAPOBJECTCREATOR_H
    #include "TSOAPObjectCreator.h"
#endif // TSOAPOBJECTCREATOR_H
#ifndef __TestSOAP__
        #include "TestSOAP.h"
#endif // __TestSOAP__

#ifdef _MSC_VER
#include <process.h>
#include <windows.h>
#endif

#include <iostream>
#include <fstream>

#define VersionString   "Simple SOAP Test Server V 2.1 build 0"


void registerObjects()
{
    SOAPDispatcher::Instance().registerObject( 
        new TSOAPObjectCreator<TestSOAP>( std::string("SimpleSOAP") ) );
}

void processSocket( TcpSocket& socket )
{
    long nBuffSize = socket.getReceivingBufferSize();
    char* buff = new char[ nBuffSize + 1 ];
    std::string szReply;
    std::string szSOAPMessage("");

    bool bSendingFault = false;
    try
    {
                // handle message longer than the Receive buf size - GJPC
                // not elegant TODO: time out and eject 
        int bytes;
                do
                {
                        bytes = socket.read( buff, nBuffSize ); 
                        buff[bytes] = 0;
                        szSOAPMessage += buff;
                }
                while ( strstr( buff, "</SOAP-ENV:Envelope>" ) == NULL );

    }
    catch( NetworkException& e )
    {
                std::cerr << "Network exception: " << e.what();
    }
    catch( ... )
    {
                std::cerr << "Unknown Exception while getting SOAP msg";
        socket.close();
        return;
    }

        // print out the SOAP request
        std::cout << "\r\n\n================= " << szSOAPMessage.length()  << " byte SOAP Message ===================\r\n\n";
        std::cout << szSOAPMessage << std::endl;
    // Process the SOAP message-- should be the contents of the
    // message from "<SOAP:" to the end of the string.
    SOAPonHTTP soapOnHTTP;
    std::string szObjectName;
    std::string szMethodName;
    SOAPElement theCall;

    if ( soapOnHTTP.getMethodDetails( 
        szSOAPMessage, szObjectName, szMethodName, theCall ) )
    {
        szReply = SOAPDispatcher::Instance().processMessage( 
            szObjectName, szMethodName, theCall, bSendingFault );
    }
    else
    {
        // Create a SOAP fault.  Client error-- the message could not be understood.
                std::cerr << "<<<<<<<<<<<<<<<<<< Couldn't parse this message >>>>>>>>>>>>>" ;
        bSendingFault = true;
        szReply = szObjectName;
    }

    szReply = soapOnHTTP.getSendableResponse( szReply, bSendingFault );
    socket.write( szReply.c_str(), szReply.length() + 1 );
    socket.close();

        // now print the reply on the console
        std::cout << std::endl 
                << "------------------ SOAP Response -------------------------" 
                << std::endl << std::endl ;
    std::cout << szReply << std::endl;

    delete[] buff;
}

//int __cdecl networkAppMain(int argc, char* argv[])
int  networkAppMain(int argc, char* argv[])
{
        std::cout << VersionString << std::endl ;
    // Create connection server with well-known port on local host.
        int port = 8080;
        if ( argc > 1 )
                port = atoi( argv[1] );

        SocketAddress addr( port );
    TcpConnectionServer server( addr );
       
    // Perform registration.
    registerObjects();

    TcpSocket socket;
    while (true) 
    {
        server.accept( socket ); // Accept incoming connection.
        processSocket( socket );
    }
    
    return 0;
}

int main( int argc, char* argv[] )
{
        return NetworkStart( argc, argv, networkAppMain );
}

---