/*

* Copyright (c) 2005-2009 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of "Eclipse Public License v1.0"

* which accompanies this distribution, and is available

* at the URL "http://www.eclipse.org/legal/epl-v10.html".

*

* Initial Contributors:

* Nokia Corporation - initial contribution.

*

* Contributors:

*

* Description:  

* Filename: CXClient.cpp

* Author: Sanjeet Matharu 

* This is the client side of the protocol which takes name/value pairs and does stuff

* System Includes

*

*/

#include <stdio.h>

#include <stdlib.h>

#include <ctype.h>

#include <memory.h>

#include <string.h>

#include <assert.h>

#ifdef WIN32

#include <winsock2.h>

#include <windows.h>

#else

#include <sys/types.h>

#include <sys/socket.h>

#endif

/*******************************************************************************

 *

 * Local Includes

 *

 ******************************************************************************/

#include "cxclient.h"

#define MAXRETRIES		5

//------------------------------------------------------------------------------

//constructor

CXClient::CXClient()

{

	iClientStatus = SENDING_HELLO;

	sprintf(hellobuffer, "%s", "HELLO");

	sprintf(goodbyebuffer, "%s", "GOODBYE");

}

//------------------------------------------------------------------------------

//destructor

CXClient::~CXClient()

{

}

//------------------------------------------------------------------------------

//this function adds the specified value into the list of name value pairs

int CXClient::OnExecute(int handle, char* cValue, int dim1, int dim2)

{

	int error = 0;

	int localsocket = handle;

	int counter = 0;

	if(localsocket != 0)

	{

		error = SendData(localsocket, hellobuffer);

		//send the hello to the server side first

		if( error != OK_DATATRANSFER)

		{

			//give up and return a message

			printf("There was a problem saying hello...\n");

			return -1;

		}

	}

	else

	{

		printf("There was a problem with the socket...\n");

		return -1;

	}

	//go through the valuebuffer and send the data

	for(counter = 0; counter < dim1; counter++)

	{

		error = SendData(localsocket, &cValue[counter*dim2]);

		if( error != OK_DATATRANSFER)

		{

			//give up and return a message

			printf("There was a problem sending the data...\n");

			return -1;

		}

	}

	//send the goodbye to the server side 

	if(localsocket != 0)

	{

		error = SendData(localsocket, goodbyebuffer);

		if( error != OK_DATATRANSFER )

		{

			//give up and return a message

			printf("There was a problem when saying goodbye...\n");

			return -1;

		}

	}

	else

	{

		printf("There was a problem with the socket...\n");

		return -1;

	}

	return 0;

}

//------------------------------------------------------------------------------

//this sends the hello command to the client over the specified socket to initiate comms

int CXClient::SendData(int handle, char* aValue)

{

	char c;		//this is the buffer that is used to receive the data from across the link

	char receivebuffer[MAXBUFFERLEN];

	int counter = 0;

	int bufferlength = 0;

	int sendcounter = 0;

	int err = -1;

	bool success = false;

	memset(receivebuffer, 0, sizeof(receivebuffer));		//initialise

	bufferlength = strlen(aValue);

	//send the data

	while( sendcounter < MAXRETRIES ) 

	{

		//write to the socket

		err = WriteClient( handle, HT_SOCKET, aValue, bufferlength );

		//if unable to send for some reason (verify that the error code is the length of one char)

		if( err != bufferlength )

		{

			printf("Data %s sending failed %d...\n", aValue, err);

			sendcounter++;

		}

		else	//print ok 

		{

			printf("Data %s sending ok %d chars sent...\n", aValue, bufferlength);

			sendcounter = MAXRETRIES;

			//send an end of string character so the server can evaluate what has been received

			WriteClient( handle, HT_SOCKET, "", 1 );

		}

	}

	//receive the reply ONLY if send has succeeded (hence inside the maxretries limit)

	if( ( sendcounter <= MAXRETRIES ) )

	{

		while( 1 )

		{

			err = ReadClient( handle, HT_SOCKET, &c );

			if( strcmp( &c, "" ) == 0)

			{

				//if there was a problem with the read (i.e. invalid command received from server, knackered link)

				if( ( err <= 0 ) || ( strcmp(receivebuffer, aValue) != 0 ) )

				{

					printf("Data read failed ( device returned %s and receive code was %d )...\n", receivebuffer, err);

					memset(receivebuffer, 0, sizeof(receivebuffer));		//reset

					return ERROR_DATATRANSFER;

				}

				else

				{

					printf("Data read succeeded ( device returned %s )...\n", receivebuffer);

					memset(receivebuffer, 0, sizeof(receivebuffer));		//reset

					counter = 0;	//reset

					break;

				}

			}	//if

			receivebuffer[counter++] = c;

		}		//while

	}

	return OK_DATATRANSFER;

}

//------------------------------------------------------------------------------

int CXClient::ReadClient(int handle, int handletype, char* c)

{

	int err;

	assert( c != NULL );

	// socket handles

	if( handletype == HT_SOCKET ) 

	{

		err = recv( handle, c, 1, 0 );

		if( err != 1 ) //if the single char has not been received

		{

			err = GetLastError();

			return err;

		}

	}

	// success

	return err;

}

//------------------------------------------------------------------------------

int CXClient::WriteClient(int handle, int handletype, char *buff, int bufflen )

{

	int err = 0;

	unsigned long bytes_written = 0;

	assert( buff != NULL );

	// socket handles

	if( handletype == HT_SOCKET ) 

	{

		err = send( handle, buff, bufflen, 0 );

		if( err != bufflen ) 

		{

			err = GetLastError();

			return err;

		}

	}

	return err;	

}

//------------------------------------------------------------------------------