/*

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

*

*/

#include "T_RSocketData.h"

#include "T_RHostResolverData.h"

#include <e32property.h>

#include <etelmm.h>   // RMobilePhone

#include <etelpckt.h> // RPacketService

const TInt KBufferSize = 1024;

_LIT( KNoFileSave, "NULL" );

const TUint KNoDataDealer = 0;

const TInt KNoDuration = -1;

const TInt KNoSpeedCheck = -1;

// Misc Types

_LIT( KProtocolHTTP,   "HTTP" );

_LIT( KOff,            "Off" );        // Can be used every2*where off is needed

// HSDPA checks

_LIT( KHsdpaIndicator, "Indicator" );  // Operator supports

_LIT( KHsdpaSupported, "Supported" );  // Device supports

_LIT( KHsdpaInUse,     "Used" );       // In use during PSD

// Constants for creating a HTTP request.

_LIT8(KHTTPGET, 		"GET");

_LIT8(KHTTPSeparator, 	" ");

_LIT8(KHTTPSuffix, 		"HTTP/1.0");

_LIT8(KEmptyLine, 		"\r\n\r\n");

const TInt KEmptySize = 4;

const TInt KHTTPSize = 17;

const TInt KMaxTag = 256;

const TInt KHeaderWithoutData=200;

//

// Manually created HTTP Post request is difficult to maintain.

// Request and server responce is logged into file during test run.

_LIT8(KHTTPPOST, "POST");

_LIT8(KLineBreak, "\r\n");

_LIT8(KAhti, "Ahti");

_LIT8(KServerScript, 	"/dy/upload/upfile.php");

_LIT8(KFrom, 			"From:");

_LIT8(KHost, 			"Host:");

_LIT8(KContentType, 	"Content-Type:");

_LIT8(KContentLength, 	"Content-Length:");

_LIT8(KContentDisposition, "Content-Disposition:");

_LIT8(KMultipartType, "multipart/form-data;");

_LIT8(KOctetType,     "application/octet-stream");

_LIT8(KBoundary,      "boundary=---------------------------sg976436h73");

_LIT8(KBoundaryStart, "-----------------------------sg976436h73");

_LIT8(KBoundaryEnd,   "-----------------------------sg976436h73--");

_LIT8(KDisposition,   "form-data; name=\"userfile\"; filename=\"test.bin\"");

_LIT( KPropertyCategory, 		"PropertyCategory");

_LIT( KPropertyKey,				"PropertyKey");

_LIT( KMaxPropertyLength,		"PropertyLength");

//const TInt 

_LIT( KPort,         					"Port" );

_LIT( KAddress,      					"Address" );

_LIT( KProtocol,     					"Protocol" );

_LIT( KFileName,     					"File" );

_LIT( KSaveName,     					"Save" );

_LIT( KDataDealerID, 					"DataDealer" );    // Data dealer ID is given may not be 0

_LIT( KHsdpaCheck,   					"HSDPA" );         // HSDPA check can be done several ways

_LIT( KDuration,     					"Duration" );      // How long should i.e. download last when it is stopped (THRO)

_LIT( KMinimumSpeed, 					"MinSpeed" );      // Data transfer must be faster than MinSpeed

_LIT( KBytes,        					"Bytes" );         // How many bytes are send

_LIT( KResponseLogFile,					"ResponseLogFile");

_LIT( KRequestLogFile,					"RequestLogFile");

//LIT's to read from ini file

_LIT( KDefaultSection,					"Default");

_LIT(KRConnection, 						"RConnection");

_LIT(KRSocketServ,						"RSocketServ");

_LIT(KRHostResolver,					"RHostResolver");

_LIT(KRMobilePhone,						"RMobilePhone");

/*@}*/

/*@{*/

//LIT's for commands

_LIT(KCmdRSocketOpen,							"Open");

_LIT(KCmdRSocketClose,							"Close");

_LIT(KCmdRSocketConnect, 						"Connect");

_LIT(KCmdRSocketShutDown,						"ShutDown");

_LIT(KCmdRSocketWrite,							"Write");

_LIT(KCmdResponseFromServer, 					"ResponseFromServer");

_LIT(KWriteRequest,								"WriteRequest");

_LIT(KCmdUtilityStartFile,						"StartFile");

_LIT(KCmdUtilityStartDealer,					"StartDealer");

_LIT(KCmdUtilityCheckHSDPA,						"CheckHSDPA");

_LIT(KCmdRecvOneOrMore,							"RecvOneOrMore");

_LIT(KCmdUtilityEndFile,						"EndFile");

_LIT(KCmdUtilityCalcDnloadStats,				"CalcDnloadStats");

_LIT(KCmdUtilityBuildRequest,					"BuildRequest");

_LIT(KCmdSendBytesToSocket,						"SendBytesToSocket");

_LIT(KCmdUtilityEndRequest,						"EndRequest");

_LIT(KCmdInfo,									"Info");

/*@}*/

/**

 * Two phase constructor

 */

CT_RSocketData* CT_RSocketData::NewL()

	{

	CT_RSocketData*	ret=new (ELeave) CT_RSocketData();

	CleanupStack::PushL(ret);

	ret->ConstructL();	

	CleanupStack::Pop(ret);

	return ret;

	}

/**

* Protected constructor. First phase construction

*/

CT_RSocketData::CT_RSocketData():

	iSocket(NULL),    

	iActiveCallback(NULL),

	iBreathSaver(NULL)

	{

	}

CT_RSocketData::~CT_RSocketData()

	{

	if(iBreathSaver)

		{

		delete iBreathSaver;

		iBreathSaver = NULL;

		}

	if(iActiveCallback)

		{

		delete iActiveCallback;

		iActiveCallback = NULL;

		}	

	if(iSocket)

		{

		delete iSocket;

		iSocket = NULL;

		}

	}

void CT_RSocketData::ConstructL()

	{

	iActiveCallback = CActiveCallback::NewL(*this);

	iBreathSaver = CBreathSaver::NewL();

	iSocket = new (ELeave)RSocket();

	}

void CT_RSocketData::InitialiseL()

	{

	CDataWrapperBase::InitialiseL();

	TInt propertyCategory;

	GetHexFromConfig(KDefaultSection, KPropertyCategory, propertyCategory);

	iPropertyCategory.iUid = propertyCategory;

	TInt propertyKey;

	GetIntFromConfig(KDefaultSection, KPropertyKey, propertyKey );

	iPropertyKey =(TUint)propertyKey;

	GetIntFromConfig(KDefaultSection, KMaxPropertyLength, iMaxPropertyLength );

	}

/**

	* Process a command read from the ini file

	*

	* @param aCommand			The command to process

	* @param aSection			The section in the ini containing data for the command

	* @param aAsyncErrorIndex	Command index for async calls to return errors to

	*

	* @return					ETrue if the command is processed

	*

	* @leave					System wide error

	*/

TBool CT_RSocketData::DoCommandL(const TTEFFunction& aCommand, const TTEFSectionName& aSection, const TInt aAsyncErrorIndex)

	{

	TBool retVal=ETrue;

	if (aCommand==KCmdRSocketOpen)

		{	

		DoCmdOpenL(aSection);

		}

	else if (aCommand==KCmdRSocketConnect)

		{

		DoCmdConnectL(aSection, aAsyncErrorIndex);

		}

	else if (aCommand==KCmdRSocketShutDown)

		{

		DoCmdShutDown(aAsyncErrorIndex);

		}

	else if (aCommand==KCmdRSocketClose)

		{

		DoCmdClose();

		}

	else if ( aCommand == KWriteRequest )

		{		

		DoCmdWriteRequest(aSection, aAsyncErrorIndex);

		}

	else if ( aCommand == KCmdUtilityStartFile )

		{

		DoCmdUtilityStartFile(aSection);

		}

	else if (aCommand == KCmdUtilityStartDealer )

		{

		DoCmdUtilityStartDealer(aSection);

		}

	else if (aCommand == KCmdUtilityCheckHSDPA )

		{

		DoCmdUtilityCheckHSDPAL(aSection);

		}

	else if (aCommand==KCmdRecvOneOrMore)

		{

		DoCmdRecvOneOrMore(aSection);

		}

	else if (aCommand == KCmdUtilityEndFile )

		{

		DoCmdUtilityEndFile(aSection);		

		}

	else if (aCommand == KCmdUtilityCalcDnloadStats )

		{

		DoCmdUtilityCalculateDownloadStats(aSection);		

		}

	else if (aCommand==KCmdUtilityBuildRequest)

		{

		DoCmdUtilityBuildRequest(aSection);

		}

	else if (aCommand==KCmdRSocketWrite)

		{

		DoCmdWrite(aAsyncErrorIndex);

		}

	else if (aCommand==KCmdSendBytesToSocket)

		{

		DoCmdSendBytesToSocket(aSection);

		}

	else if (aCommand==KCmdResponseFromServer)

		{

		DoCmdResponseFromServer(aSection);

		}

	else if (aCommand==KCmdUtilityEndRequest)

		{

		DoCmdUtilityEndRequest();

		}

	else if (aCommand==KCmdInfo)

		{

		DoCmdInfoL(aSection);

		}

	else

		{

		ERR_PRINTF1(_L("Unknown command"));

		retVal=EFalse;

		}

	return retVal;

	}

/**

	* Return a pointer to the object that the data wraps

	*

	* @return pointer to the object that the data wraps

	*/

TAny* CT_RSocketData::GetObject()

	{

	return iSocket;

	}

void CT_RSocketData::RunL(CActive* aActive, TInt aIndex)

	{

	INFO_PRINTF1(_L("*START* CT_RSocketData::RunL"));

	DecOutstanding(); // One of the async calls has completed 

	if(aActive == iActiveCallback)

		{

		INFO_PRINTF1(_L("Asynchronous task has completed. RunL  called"));

		}

	else

		{ 

		ERR_PRINTF1(_L("Stray RunL signal"));

		TInt err = aActive->iStatus.Int(); 

		if( err != KErrNone )

			{

	        ERR_PRINTF2(_L("RunL Error %d"), err); 

	        SetAsyncError( aIndex, err );

			}

		}

	INFO_PRINTF1(_L("*END* CT_RSocketData::RunL"));

	}

/**

 * Opens a socket.

 * @param aSection - Section in config file to get a RSocketServer and RConnection

 * Sets TEF error if not successful.

 */	

void CT_RSocketData::DoCmdOpenL(const TTEFSectionName& aSection)

	{

	INFO_PRINTF1(_L("*START* CT_RSocketData::DoCmdOpenL"));

	TBool dataOk = ETrue;

	TPtrC connectionName;

	if ( !GetStringFromConfig(aSection, KRConnection(), connectionName) )

		{

		ERR_PRINTF2(_L("Error in getting parameter %S from INI file"), &KRConnection);

		SetBlockResult(EFail);

		dataOk = EFalse;

		}

	TPtrC socketServName;

	if ( !GetStringFromConfig(aSection, KRSocketServ(), socketServName) )

		{

		ERR_PRINTF2(_L("Error in getting parameter %S from INI file"), &KRSocketServ);

		SetBlockResult(EFail);

		dataOk = EFalse;

		}

	if (dataOk)

		{

		INFO_PRINTF1(_L("Create a RConnection for iSocket"));

		RConnection* connection = static_cast<RConnection*>(GetDataObjectL(connectionName));

		INFO_PRINTF1(_L("Create a RSocketServ for iSocket"));

		RSocketServ* socketServ = static_cast<RSocketServ*>(GetDataObjectL(socketServName));

		TInt error = iSocket->Open(*socketServ, KAfInet, KSockStream, KProtocolInetTcp, *connection);

		if (error == KErrNone)

			{

			INFO_PRINTF1(_L("Socket opening succeeded"));

			}

		else

			{

			ERR_PRINTF2(_L("Socket opening failed [%d]"), error);

			SetError(error);

			}

		}

	INFO_PRINTF1(_L("*END* CT_RSocketData::DoCmdOpenL"));

	}

/**

 * Connects socket with a given address and port.

 * @param aSection			- The section in config file to look for the address, port and RHostResolver

 * @param aAsyncErrorIndex	- Command index for async calls to return errors to	

 */

void CT_RSocketData::DoCmdConnectL(const TTEFSectionName& aSection, const TInt aAsyncErrorIndex)

	{

	INFO_PRINTF1(_L("*START* CT_RSocketData::DoCmdConnectL"));

	TBool dataOk = ETrue;

	TInt port;

    if(!GetIntFromConfig( aSection, KPort, port ))

    	{

    	ERR_PRINTF2(_L("Error in getting parameter %S from INI file"), &KPort);

    	SetBlockResult(EFail);

    	dataOk = EFalse;

    	}

    TPtrC address;

    if(!GetStringFromConfig( aSection, KAddress, address ))

    	{

    	ERR_PRINTF2(_L("Error in getting parameter %S from INI file"), &KAddress);

    	SetBlockResult(EFail);

    	dataOk = EFalse;

    	}

	// Connect ready socket to given host and port number

	TPtrC hostResolverName;

	if(	!GetStringFromConfig(aSection, KRHostResolver, hostResolverName) )

		{

		ERR_PRINTF2(_L("Error in getting parameter %S from INI file"), &KRHostResolver);

    	SetBlockResult(EFail);

    	dataOk = EFalse;

		}

	if (dataOk)

		{

		INFO_PRINTF3(_L("Connecting socket to server \"%S\" at port [%d]"), &address, port);

		CT_RHostResolverData* hostResolver = static_cast<CT_RHostResolverData*>(GetDataWrapperL(hostResolverName));

		iNameEntry = hostResolver->GetNameEntry();

		iNameEntry().iAddr.SetPort(port);

		iSocket->Connect(iNameEntry().iAddr, iActiveCallback->iStatus);

		iActiveCallback->Activate(aAsyncErrorIndex);

	    IncOutstanding();

		}

    INFO_PRINTF1(_L("*END* CT_RSocketData::DoCmdConnectL"));

    }

/**

 * Shuts down a connected socket - asynchronous.

 * This method is asynchronous as non emergency shutdown may take a while.

 * The shut down method allows input and output to be individually stopped for a protocol endpoint. 

 * @param aAsyncErrorIndex - Command index for async calls to return errors to

 */

void CT_RSocketData::DoCmdShutDown(const TInt aAsyncErrorIndex)

    {

    INFO_PRINTF1(_L("*START* CT_RSocketData::DoCmdShutDownSocket"));

	// Shutdown the socket.

	iSocket->Shutdown(RSocket::ENormal, iActiveCallback->iStatus);

	iActiveCallback->Activate(aAsyncErrorIndex);

    IncOutstanding();

    INFO_PRINTF1(_L("*END* CT_RSocketData::DoCmdShutDownSocket"));

    }

/**

 * Closes a socket.

 * If a socket has been opened using Open() then it should be closed using Close(). 

 * This will ensure all associated resources are released. 

 * Closing serves two distinct purposes: 

 * - To release resources associated with the IPC channel to the socket server. 

 * - To disconnect a socket if it is connected. 

 */

void CT_RSocketData::DoCmdClose()

	{

	INFO_PRINTF1(_L("*START* CT_RSocketData::DoCmdCloseSocket"));

	iSocket->Close(); // Close does not return error code

    INFO_PRINTF1(_L("*END* CT_RSocketData::DoCmdCloseSocket"));

    }

/**

 * Builds an HTTP Get request

 * @param  aSection - The section in config file to look for address, port, protocol, filename and save path.

 * @param aAsyncErrorIndex - Command index for async calls to return errors to

 */

void CT_RSocketData::DoCmdWriteRequest(const TTEFSectionName& aSection, const TInt aAsyncErrorIndex)

	{

	INFO_PRINTF1(_L("*START* CT_RSocketData::DoCmdWriteRequest"));

	TBool dataOk = ETrue;

	TPtrC filename; 

	if(!GetStringFromConfig(aSection, KFileName, filename ))

		{

		ERR_PRINTF2(_L("Error in getting parameter %S from INI file"), &KFileName);

    	SetBlockResult(EFail);

    	dataOk = EFalse;

		}

	TPtrC protocol; 

    if(!GetStringFromConfig(aSection, KProtocol, protocol ))

    	{

    	ERR_PRINTF2(_L("Error in getting parameter %S from INI file"), &KProtocol);

    	SetBlockResult(EFail);

    	dataOk = EFalse;

    	}

    // Send http get request

    if (dataOk && protocol != KProtocolHTTP)

        {

        ERR_PRINTF2(_L("Protocol \"%S\" is unknown"), &protocol);

        SetBlockResult(EFail);

        dataOk = EFalse;

        }

    if (dataOk && filename.Length() > KMaxTag)

        {

        ERR_PRINTF1(_L("Filename is too long, cannot send HTTP request"));

        SetBlockResult(EFail);

        dataOk = EFalse;

        }

    if (dataOk)

    	{

        INFO_PRINTF1(_L("Sending HTTP request"));

    	// Buffer that will hold the request.

    	TBuf8<KHTTPSize + KMaxTag> request;

    	// Construct the final request.

    	request.Append(KHTTPGET);

    	request.Append(KHTTPSeparator);

    	request.Append(filename);

    	request.Append(KHTTPSeparator);

    	request.Append(KHTTPSuffix);

    	request.Append(KEmptyLine);

        // Send the request through socket

    	iSocket->Write(request, iActiveCallback->iStatus);

    	iActiveCallback->Activate(aAsyncErrorIndex);

        IncOutstanding();

    	}

	INFO_PRINTF1(_L("*END* CT_RSocketData::DoCmdWriteRequest"));

	}

/**

 * Uses helper class BreathSaver to generate a file and save downloaded data in a given path.

 * @param  aSection - The section in config file to look for address, port, protocol, filename and save path.

 * Sets TEF error if not successful.

 */

void CT_RSocketData::DoCmdUtilityStartFile(const TTEFSectionName& aSection)

	{

	INFO_PRINTF1(_L("*START* CT_RSocketData::DoCmdUtilityStartFile"));

	TBool dataOk = ETrue;

    TPtrC savename( KNoFileSave );

    if(!GetStringFromConfig(aSection, KSaveName, savename))

    	{

    	ERR_PRINTF2(_L("Error in getting parameter %S from INI file"), &KSaveName);

    	SetBlockResult(EFail);

    	dataOk = EFalse;