/*
 *   Copyright 2003-2004 The Apache Software Foundation.
 *
 *   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.
 */

/*
 * This software consists of voluntary contributions made by many
 * individuals on behalf of the Apache Software Foundation.  For more
 * information on the Apache Software Foundation, please see
 * <http://www.apache.org/>.
 *
 * @author Samisa Abeysinghe (sabeysinghe@virtusa.com)
 */
#include <string>
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>

#include <axis/Axis.hpp>

using namespace std;

#include "gen_src/InteropTestPortType.h"

#define ARRAYSIZE 2

#define MACRO_NUM_THREADS 4*1
int NUM_THREADS = MACRO_NUM_THREADS;

extern "C" int initialize_module (int bServer);
extern "C" int uninitialize_module ();

extern "C" STORAGE_CLASS_INFO void initializeLibrary(void);
const char *server = "localhost";
const char *port = "8080";
char endpoint[256];

void *
run(void *arg)
{
    int x;
    char buffer1[100];
    
    //sprintf(endpoint, "http://%s:%s/axis/base", server, port);
    //endpoint for Axis Java sample
    sprintf(endpoint, "http://%s:%s/axis/services/echo", server, port);


    InteropTestPortType *ws;
    try
    {
    if (arg == NULL)
	ws = new InteropTestPortType(endpoint);
    else
	ws = (InteropTestPortType *) arg;

    ws->setTransportTimeout(10);

    //printf("invoking echoString...\n");
    //testing echoString 
    string bigstring;
    for (int ii = 0; ii < 2; ii++)
    {
	bigstring += "hello world ";
    }
    strcpy(buffer1, bigstring.c_str());
    if (0 != strcmp(ws->echoString("hello world"), "hello world"))
	printf("echoString failed\n");
    
    // testing echoStringArray 
    xsd__string_Array arrstr;
    arrstr.m_Array = new char *[ARRAYSIZE];
    arrstr.m_Size = ARRAYSIZE;
    sprintf(buffer1, "%dth element of string array", 0);
    //sprintf(buffer2, "%dth element of string array", 1);
    for (int i = 0; i < ARRAYSIZE; i++)
    {
	arrstr.m_Array[i] = buffer1;
    }
    //arrstr.m_Array[1] = buffer2;
    //printf("invoking echoStringArray...\n");
    if (ws->echoStringArray(arrstr).m_Array == NULL)
	printf("echoStringArray failed\n");

    /*/ testing echoInteger 
    //printf("invoking echoInteger...\n");
    if (ws->echoInteger(56) != 56)
	printf("echoInteger failed\n");

    // testing echoIntegerArray 
    xsd__int_Array arrint;
    arrint.m_Array = new int[ARRAYSIZE];
    arrint.m_Size = ARRAYSIZE;
    for (x = 0; x < ARRAYSIZE; x++)
    {
	arrint.m_Array[x] = x;
    }
    //printf("invoking echoIntegerArray...\n");
    if (ws->echoIntegerArray(arrint).m_Array == NULL)
	printf("echoIntegerArray failed\n");

    // testing echoFloat 
    //printf("invoking echoFloat...\n");
    float fvalue = 1.4214;
    float retVal = ws->echoFloat(fvalue);
    if ( retVal < 1.42 || retVal > 1.43 )
	printf("echoFloat failed\n");

    // testing echoFloat 
    xsd__float_Array arrfloat;
    arrfloat.m_Array = new float[ARRAYSIZE];
    arrfloat.m_Size = ARRAYSIZE;
    for (x = 0; x < ARRAYSIZE; x++)
    {
	arrfloat.m_Array[x] = 1.1111 * x;
    }
    //printf("invoking echoFloatArray...\n");
    if (ws->echoFloatArray(arrfloat).m_Array == NULL)
	printf("echoFloatArray failed\n");

    // testing echo Struct
    SOAPStruct stct;
    stct.varFloat = 12345.7346345;
    stct.varInt = 5000;
    stct.varString = strdup("This is string in SOAPStruct");
    //printf("invoking echoStruct...\n");
    if (ws->echoStruct(&stct) == NULL)
	printf("echoStruct failed\n");

    //testing echo Array of Struct
    SOAPStruct_Array arrstct;
    arrstct.m_Array = new SOAPStruct[ARRAYSIZE];
    arrstct.m_Size = ARRAYSIZE;
    for (x = 0; x < ARRAYSIZE; x++)
    {
	arrstct.m_Array[x].varFloat = 1.1111 * x;
	arrstct.m_Array[x].varInt = x;
	sprintf(buffer1, "varString of %dth element of SOAPStruct array", x);
	arrstct.m_Array[x].varString = buffer1;
    }
    //testing echo Struct Array
    //printf("invoking echoStructArray...\n");
    if (ws->echoStructArray(arrstct).m_Array == NULL)
	printf("echoStructArray failed\n");

    //testing echo void
    //printf("invoking echoVoid...\n");
    ws->echoVoid();
    //testing echo base 64 binary

    const char *bstr =
	"some string that is sent encoded to either base64Binary or hexBinary";

    //printf("invoking echoBase64...\n");
    xsd__base64Binary bb;
    bb.__ptr = (unsigned char *) strdup(bstr);
    bb.__size = strlen(bstr);
    if (bb.__size != ws->echoBase64(bb).__size)
	printf("echoBase64 failed\n");

    time_t tim;
    time(&tim);
    tm *lt = gmtime(&tim);
    //printf("invoking echoDate...\n");
    if (memcmp(&ws->echoDate(*lt), lt, sizeof(tm)) != 0)
	printf("echoDate failed\n");

    //testing echo hex binary
    //printf("invoking echoHexBinary...\n");
    xsd__hexBinary hb;
    hb.__ptr = (unsigned char *) strdup(bstr);
    hb.__size = strlen(bstr);
    if (hb.__size != ws->echoHexBinary(hb).__size)
	printf("echoHexBinary failed\n");

    //testing echo decimal
    //printf("invoking echoDecimal...\n");
    retVal = ws->echoDecimal(1234.567890);
    if (retVal < 1234.56 || retVal > 1234.57 )
	printf("echoDecimal failed\n");

    //testing echo boolean
    //printf("invoking echoBoolean...\n");
    if (ws->echoBoolean(true_) != true_)
	printf("echoBoolean failed\n");
*/
    printf( "%ld Done\n", pthread_self() );
    }
    catch(AxisException& e)
    {
        printf("Exception : %s\n", e.what());
    }
    catch(exception& e)
    {
        printf("Unknown exception has occured: %s\n", e.what());
    }
    catch(...)
    {
        printf("Unknown exception has occured\n");
    }
    
    //delete ws;
    return 0;
}


void cleanup(void*arg);

int
main(int argc, char *argv[])
{
    if( argc > 1 )
      NUM_THREADS = atoi(argv[1]);

    if (argc > 3)
    {
	server = argv[2];
	port = argv[3];
    }

    InteropTestPortType *ws = NULL;;
    /*
    sprintf(endpoint, "http://%s:%s/axis/services/echo", server, port);
    ws = new InteropTestPortType(endpoint); //Samisa: this is an ugly hack to init the LibWWW lib
    ws = NULL; 
    */

    // initialize Axis client platform
    //initialize_module(0);
    Axis::initialize(false);

    pthread_t thread[NUM_THREADS];
    pthread_attr_t attr;
    int rc, t, status = 0;

    /* Initialize and set thread detached attribute */
    pthread_attr_init(&attr);
    pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE);

    for (t = 0; t < NUM_THREADS; t++)
    {
	printf("Creating thread %d\n", t);
	rc = pthread_create(&thread[t], &attr, run, NULL);
	if (rc)
	{
	    printf("ERROR; return code from pthread_create() is %d\n", rc);
            printf("error:%s\n", strerror(rc));
	    //exit(-1);
	}
	printf("Created thread %ld\n", thread[t]);
    }

    /* Free attribute and wait for the other threads */
    pthread_attr_destroy(&attr);

    //Axis::startTransportEventLoop();
    
    //for (t = 0; t < NUM_THREADS; t++)
    //{
	rc = pthread_join(thread[NUM_THREADS-1], (void **)&status);
	//rc = pthread_detach(thread[t]);
	if (rc)
	{
	    printf("ERROR return code from pthread_join() is %d\n", rc);
            printf("error:%s\n", strerror(rc));
	    //exit(-1);
	}
	printf("Joined thread %ld\n", thread[t-1]);
    //}*/

    printf( "about to clean\n");
    pthread_cleanup_push(cleanup, NULL);
    printf( "about to exit\n");
    pthread_exit(NULL);
}
}

void cleanup(void*arg)
{
    //Axis::stopTransportEventLoop();
    printf( "about to clean up\n");
    // Axis plaform terminate
    //Axis::terminate();
    printf( "Done clean up\n");
}