/*

* 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:  

* System Includes

*

*/

#include <time.h>

#include <assert.h>

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

 *

 * Local Includes

 *

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

#include "CUCCSCommandProtocol.h"

#include "CFrameBuffer.h"

#include "strncpynt.h"

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

 *

 * Defines

 *

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

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

 *

 * Constructor

 *

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

CUCCSCommandProtocol::CUCCSCommandProtocol()

{

	iPort = NULL;

	iOutput = NULL;

	// Seed the random number generator

	srand( (unsigned)time(NULL) );

}

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

 *

 * Destructor

 *

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

CUCCSCommandProtocol::~CUCCSCommandProtocol()

{

}

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

 *

 * Initialise

 *

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

TCPError CUCCSCommandProtocol::initialise(TRemoteControlTransport aTransport, char* aRemoteHost, IOutput* aOutput)

{

	int ret;

	// Check params are not equal to NULL

	assert (aRemoteHost != NULL);

	assert (strlen(aRemoteHost) < (KMAXPORTNAME -1));

	assert (aOutput != NULL);

	// Assign the params to the relevant member data.

	if ( aTransport == RCI_SERIAL )

	{	

		iPort = &iSerialPort;

	}

	else if ( aTransport == RCI_CONSOLE)

	{

		iPort = &iConsolePort;

	}

	else if ( aTransport == RCI_TCP)

	{

		iPort = &iTcpPort;

	}

	else

	{

		return TCP_INVALIDTRANSPORT;

	}

	// Set the state members 

	STRNCPY_NULL_TERMINATE( iRemoteHost, aRemoteHost, KMAXPORTNAME );

	iOutput = aOutput;

	iRand_UID = (unsigned)rand();

	// Open the serial port

	ret = iPort->OpenPort(iRemoteHost);

	if( ret != 0 ) {

		return TCP_FAILEDTOOPENPORT;

	}

	return TCP_SUCCESS;

}

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

 *

 * Disconnect

 *

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

TCPError CUCCSCommandProtocol::disconnect()				

{

	// Close the serial port.

	iPort->ClosePort();

	iPort = NULL;

	return TCP_SUCCESS;

}

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

 *

 * SendReply

 *

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

TCPError CUCCSCommandProtocol::sendReply( TPCommand aCommand, int aDataSize, void* aData )

{

	int iFrameSize, ret;

	TFBError err;

	if (!isValidCMDID(aCommand))

		return TCP_INVALIDCMDID;

	iFrameSize = KMAXFRAMESIZE;

	err = CFrameBuffer::createSendBuffer( iRand_UID, aCommand, aDataSize, (char*)aData, iFrame, &iFrameSize );

	if ( err != TFB_SUCCESS)

		return TCP_ERRCREATINGBUFFER;

	ret = iPort->SendBytes(iFrame, &iFrameSize);

	if ( ret != 0 )

		return TCP_ERRSENDINGBYTES;

	return TCP_SUCCESS;

}

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

 *

 * ReceiveMessage

 *

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

TCPError CUCCSCommandProtocol::receiveMessage( TPCommand* aCommand, int* aDataLength, void* aData )

{

	int res, len;

	TPHeader header;

	len = sizeof(header);

	// Read the first 12 bytes of header -  the uid, command and the data size.	

	res = iPort->ReceiveBytes((char*)&header, &len );

	if ( res != 0 )

		return TCP_ERRRECVINGBYTES;

	// Decode the response

	iRand_UID = header.iUid;        

	*aCommand = header.iCmdID;       

	*aDataLength = header.iDataLen; 

	// Get the rest

	res = iPort->ReceiveBytes((char*)aData, aDataLength);

	if ( res != 0 )

		return TCP_ERRRECVINGBYTES;

	return TCP_SUCCESS;

}

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

 *

 * Check IDs

 *

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

bool CUCCSCommandProtocol::isValidCMDID(TPCommand aCommand)

{	

	bool ret_val = true;

	switch (aCommand) 

	{

		case CMD_REP_SIGNALID:

			break;

		case CMD_REP_RENDEZVOUSID:

			break;

		case CMD_REP_WAITID:

			break;

		case CMD_REP_STARTUSECASEID:

			break;

		case CMD_REP_ENDUSECASEID:

			break;

		case CMD_REP_GETVARIABLENAMEID:

			break;

		case CMD_QUITID:

			break;

		case CMD_REP_RUNCOMMAND:

			break;

		default:

			ret_val = false;

			break;

   }

	return ret_val;

}