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



#include <e32math.h>
#include <e32std.h>

#include "CProtocolTypes.h"
#include "CSerialTransport.h"
#include "CTCPTransport.h"
#include "CUCCSDeviceProtocol.h"
#include "assert.h"


/*****************************************************************************
 *
 *	Constructor
 *
 ****************************************************************************/
CUCCSDeviceProtocol::CUCCSDeviceProtocol()
{		
	iTransport = NULL;
	iStatus = TDP_IDLE;

	// Seed the random number generator - this requires a 64 bit seed
	TTime now;
	now.HomeTime();
	iRandomSeed = now.Int64();
}


/*****************************************************************************
 *
 *	Destructor 
 *
 ****************************************************************************/
CUCCSDeviceProtocol::~CUCCSDeviceProtocol()
{
	assert ( iStatus == TDP_IDLE );
	assert ( iTransport == NULL );
}


/*****************************************************************************
 *
 *	Initialise 
 *
 ****************************************************************************/
TDPError CUCCSDeviceProtocol::initialise(TBufC16<40> aRemoteHost, TDPTransport aTransportType)
	{	
	// Check the state
	assert ( iStatus == TDP_IDLE );

	// Check params
	assert (aRemoteHost.Length() > 0);
	
	// Set the member data
	iRand_UID = Math::Rand( iRandomSeed );
	iRemoteHost = aRemoteHost;

	// Initialise the serial transport
	if( iTransport == NULL )
		{
		TInt r = 0;
		if( aTransportType == TDP_SERIAL )
			{
			TRAP ( r, iTransport = CSerialTransport::NewL(_L("ECUART")) );
			}
		else if( aTransportType == TDP_TCP )
			{
			TRAP ( r, iTransport = new (ELeave) CTCPTransport() );
			
			}
		else
			{
			return TDP_ERRINTIALISING;
			}

		if ( r != KErrNone)
			return TDP_ERRINTIALISING;
		
		TRAPD ( s,iTransport->InitialiseL() );
		if ( s != KErrNone)
			{	
			iTransport->Release();
			delete iTransport;
			iTransport = NULL;
			return TDP_ERRINTIALISING;
			}

		TRAPD ( t, iTransport->ConnectL(&iRemoteHost) );
		if ( t != KErrNone)
			{
			iTransport->Disconnect();
			iTransport->Release();
			delete iTransport;
			iTransport = NULL;
			return TDP_ERRINTIALISING;
			}
		}

	iStatus = TDP_CONNECTED;
	return TDP_SUCCESS;
	}


/*****************************************************************************
 *
 *	Disconnect 
 *
 ****************************************************************************/
TDPError CUCCSDeviceProtocol::disconnect()
{
	// check the state
	if( iStatus == TDP_IDLE ) {
		return TDP_SUCCESS;
	}
	assert ( iStatus == TDP_CONNECTED );

	// if the serial transport is up then bring it down
	if( iTransport != NULL ) {
		iTransport->Disconnect();
		iTransport->Release();	
		delete iTransport;
		iTransport = NULL;
	}

	// update the state and return
	iStatus = TDP_IDLE;
	return TDP_SUCCESS;
}


/*****************************************************************************
 *
 *	Receive Message 
 *
 ****************************************************************************/
TDPError CUCCSDeviceProtocol::receiveMessage(TPCommand* aCmd, int* aDataLength, void* aData)
{
	TPHeader header;
	TInt ret;
	int bufferLen;

	// Check the state
	assert ( iStatus == TDP_CONNECTED );

	// Check params
	assert( aCmd != NULL );
	assert( aDataLength != NULL );
	assert( aData != NULL );

	// Record the original length of the aData buffer b4 it gets overwritten
	bufferLen = *aDataLength;

	// Read the header
	TPtr8 p( (TUint8*)&header,sizeof(header), sizeof(header) );
	ret = iTransport->RequestReceive( &p, p.Size());	
	if ( ret != KErrNone)
		return TDP_RECVERROR;

	// Check that this is a response to our last message
	if ( header.iUid != iRand_UID)
		return TDP_UIDMISMATCH;

	// Extract the header information
	*aCmd = header.iCmdID;
	*aDataLength = header.iDataLen;

	// Now read the rest of the data
	TPtr8 q( (TUint8*)aData, bufferLen, bufferLen);
	ret = iTransport->RequestReceive( &q, q.Size());	
	if ( ret != KErrNone)
		return TDP_RECVERROR;

	// Increment the UID for next time
	iRand_UID += 1;
	return TDP_SUCCESS;
}


/*****************************************************************************
 *
 *	Send Message 
 *
 ****************************************************************************/
TDPError CUCCSDeviceProtocol::sendMessage(TPCommand aCmd, int aDataLength, void *aData)
{
	TPHeader header;
	TInt ret;

	// Check the state
	assert ( iStatus == TDP_CONNECTED );

	// Check params
	assert( aData != NULL );

	if( isValidCMDID(aCmd) == 0 ) 
	{
		return TDP_INVALIDCMDID;
	}

	// Create the header
	header.iCmdID = aCmd;
	header.iDataLen = aDataLength;
	header.iUid = (int)iRand_UID;
	
	// Send the header first
	TPtrC8 p( (unsigned char*)&header , sizeof(header) );
	ret = iTransport->RequestSend( &p, p.Size());

	if (ret != KErrNone)
		return TDP_SENDERROR;

	// Now send the rest of the data
	TPtrC8 q( (unsigned char*)aData , aDataLength );
	ret = iTransport->RequestSend( &q , q.Size());
	if (ret != KErrNone)
		return TDP_SENDERROR;

	return TDP_SUCCESS;
}


/**********************************************************************************************
 *
 * Check IDs
 *
 *********************************************************************************************/	
bool CUCCSDeviceProtocol::isValidCMDID(TPCommand aCommand)
{	
	bool ret_val = true;

	switch (aCommand) 
	{
		case CMD_REQ_SIGNALID:
			break;

		case CMD_REQ_RENDEZVOUSID:
			break;

		case CMD_REQ_WAITID:
			break;
   
		case CMD_REQ_STARTUSECASEID:
			break;

		case CMD_REQ_ENDUSECASEID:
			break;
	
		case CMD_REQ_GETVARIABLENAMEID:
			break;

		case CMD_QUITID:
			break;

		case CMD_REQ_RUNCOMMAND:
			break;

		default:
			ret_val = false;
			break;
   }

	return ret_val;
}