/*

* 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 <wlanscaninfo.h>

#include "t_rsocketdata.h"

/*@{*/

// LITs from the ini file

_LIT( KSocketServ,				"socketserv");

_LIT( KConnection,				"connection");

_LIT( KScanInfo,				"scaninfo");

_LIT( KAddress,					"Ip");

_LIT( KPort,					"Port");

_LIT( KFile,					"File");

_LIT( KSave,					"Save");

_LIT( KARates,					"rate");

_LIT( KFileServer,				"FileServer");

/*@}*/

/*@{*/

// Upload

_LIT(KNullFile,				    "KNullDesC");

/*@}*/

/*@{*/

// LITs for the commands

_LIT( KCmdOpen,					"Open");

_LIT( KCmdConnect,				"Connect");

_LIT( KCmdHttpGet,				"HttpGet");

_LIT( KCmdDownloadSendHTTPGet,	"DownloadSendHTTPGet");

_LIT( KCmdRecvOneOrMore,     	"RecvOneOrMore");

_LIT( KCmdUploadSendHTTPPost,	"UploadSendHTTPPost");

_LIT( KCmdCheckSupportedRates,	"CheckSupportedRates");

_LIT( KCmdShutdown,				"Shutdown");

_LIT( KCmdClose,				"Close");

/*@}*/

/*@{*/

// Constants for creating a HTTP request in the command DoCmdDownloadSendHTTPGet

_LIT8( KHTTPGET, 				"GET");

_LIT8( KHTTPSeparator, 			" ");

_LIT8( KHTTPSuffix, 			"HTTP/1.1");

_LIT( KHostS, 					"Host");

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

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

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

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

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

_LIT8( KGETHTTP, 				"GET / HTTP/1.0\r\n\r\n" );

/*@}*/

/*@{*/

// Constants for CreateHTTPHeaderStart

_LIT8(KHTTPPOST, 				"POST");

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

_LIT(KClientID,					"clientID");

_LIT(KServerScript,				"serverScript"); 

_LIT8(KFrom,					"From:");

_LIT8(KHosts,					"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(KDisposition,				"form-data; name=\"userfile\"; filename=");

_LIT8(KBackS,					"\"");

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

/*@}*/

const TInt KHttpHeaderBufferIncrement = 4096;

// Const for supported rates

// The first bit includes information about BSSBasicRateSet,

// mask it out

const TUint32 KBasicRateMask = 0x7F;

// 802.11g supported speed rate

const TUint8 K80211Rate1Mbit = 2;

const TUint8 K80211Rate2Mbit = 4;            

const TUint8 K80211Rate5Mbit = 11;

const TUint8 K80211Rate11Mbit = 22;

const TUint8 K80211Rate12Mbit = 24;

const TUint8 K80211Rate18Mbit = 36;

const TUint8 K80211Rate22Mbit = 44;

const TUint8 K80211Rate24Mbit = 48;

const TUint8 K80211Rate33Mbit = 66;

const TUint8 K80211Rate36Mbit = 72;

const TUint8 K80211Rate48Mbit = 96;

const TUint8 K80211Rate54Mbit = 108;

/**

 * Two phase constructor

 *

 * @leave	system wide error

 */

CT_RSocketData* CT_RSocketData::NewL()

	{

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

	CleanupStack::PushL(ret);

	ret->ConstructL();

	CleanupStack::Pop(ret);

	return ret;

	}

/*

 *RunL method for management Active callbacks

 * @param aActive	param to review which active call back is being fished

 * @param aIndex

 * @return void

 */

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

	{

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

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

    TInt err(KErrNone);

    if(aActive == iActiveCallback)

    	{

        INFO_PRINTF1(_L("active call back for Write Socket."));

    	err = iActiveCallback->iStatus.Int();

    	if(err != KErrNone)

    		{

    		ERR_PRINTF1(_L("iSocket->Write(...) Fail"));

    		SetError(err);

    		}

    	else

    		{

    		INFO_PRINTF2(_L("CT_RSocketData::SendHTTPGet [%d]"), iActiveCallback->iStatus.Int());	

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

    		}    	

    	}

    else if(aActive == iActCallConnectSocket)

    	{

        INFO_PRINTF1(_L("active call back for Connect Socket."));

    	err = iActCallConnectSocket->iStatus.Int();

    	if(err != KErrNone)

    		{

    		ERR_PRINTF1(_L("iSocket->Connect(...) Fail"));

    		SetError(err);

    		}

    	else

    		{

    		INFO_PRINTF1(_L("CT_RSocketData::DoCmdConnect(...) success"));

    		iSocketOpened = ETrue;

    		}

    	}

    else if(aActive == iActCallShutDownSocket)

    	{

        INFO_PRINTF1(_L("active call back for Shutdown Socket."));

    	err = iActCallShutDownSocket->iStatus.Int();

    	if(err != KErrNone)

    		{

    		 ERR_PRINTF2(_L("iSocket->Shutdown(...): [%d] Fail"),iActCallShutDownSocket->iStatus.Int());

    		 SetError(err);

    		}

    	else

    		{

    		INFO_PRINTF1(_L("CT_RSocketData::Shutdown success"));

    		iSocketStarted = EFalse;	

    		}

    	}

    else

    	{

    	ERR_PRINTF1(_L("An unchecked active object completed"));

    	SetBlockResult(EFail);

    	}

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

	}

/*

 * public destructor

 */

CT_RSocketData::~CT_RSocketData()

	{

	if (iSocketStarted)

		{

		INFO_PRINTF1(_L("CT_RSocketData: Shutting down socket"));

		Shutdown();

		}

	if (iSocketOpened)

		{

		Close();

		}

	if (iDownloadBuffer)

		{

		delete iDownloadBuffer;

		iDownloadBuffer = NULL;

		}

	if (iSocket)

		{

		delete iSocket;

		iSocket = NULL;	

		}

	if (iActiveCallback)

		{

		delete iActiveCallback;

		iActiveCallback = NULL;	

		}

	if (iActCallShutDownSocket)

		{

		delete iActCallShutDownSocket;

		iActCallShutDownSocket = NULL;

		}

	if (iActCallConnectSocket)

		{

		delete iActCallConnectSocket;

		iActCallConnectSocket =	 NULL;

		}

	iFs.Close();

	if (iUploadBuffer)

		{

		delete iUploadBuffer;

		iUploadBuffer = NULL;

		}

	}

/**

 * Private constructor. First phase construction

 * 

 */

CT_RSocketData::CT_RSocketData()

:	iSocket(NULL),

	iActiveCallback(NULL),

	iActCallConnectSocket(NULL),

	iActCallShutDownSocket(NULL),	

	iSocketOpened(EFalse),

	iSocketStarted(EFalse),	

	iAsyncErrorIndex(0),

	iDownloadBuffer(NULL),

	iUploadBuffer(NULL),

	iHttpResponseHeader(),

	iDownloadThroughput(0.0),	

	iFs(),

	iUploadThroughput(0.0),

	itotalReceived(0)

	{

	}

/**

 * Second phase construction

 *

 * @internalComponent

 *

 * @return	N/A

 *

 * @pre		None

 * @post	None

 *

 * @leave	system wide error

 */

void CT_RSocketData::ConstructL()

	{	 

   	 const TInt KDefaultBufferSize = 4096;

   	 TInt err(KErrNone);

   	 iSocket = new (ELeave) RSocket(); 

	 iActiveCallback = CActiveCallback::NewL(*this);

	 iActCallConnectSocket = CActiveCallback::NewL(*this);

	 iActCallShutDownSocket = CActiveCallback::NewL(*this);		

	 iDownloadBuffer = HBufC8::NewL( KDefaultBufferSize);		

	 iUploadBuffer = HBufC8::NewL(KDefaultBufferSize);		 

	 err = iFs.Connect();

	 if(err != KErrNone)

		 {

		 SetError(err);

		 }

	}

/**

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

	}

/**

 * Process a command read from the Ini file

 * @param aCommand 			The command to process

 * @param aSection			The section get from the *.ini file of the project T_Wlan

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

 * @return TBool			ETrue if the command is process

 * @leave					system wide error

 * 

 */	

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

	{

	TBool ret =  ETrue;		

	if(aCommand == KCmdOpen )

		{

		DoCmdOpen(aSection);

		}

	else if(aCommand == KCmdConnect)

		{

		DoCmdConnect(aSection,aAsyncErrorIndex);

		}

	else if(aCommand == KCmdDownloadSendHTTPGet)

		{

		DoCmdDownloadSendHTTPGet(aSection,aAsyncErrorIndex);

		}

	else if(aCommand == KCmdRecvOneOrMore)

		{

		DoCmdRecvOneOrMore(aSection);

		}

	else if(aCommand == KCmdUploadSendHTTPPost)

		{

		DoCmdUploadSendHTTPPost(aSection);

		}

	else if(aCommand == KCmdShutdown)

		{

		DoCmdShutdown(aAsyncErrorIndex);

		}

	else if(aCommand == KCmdClose)

		{

		DoCmdClose();

		}

	else if(aCommand == KCmdHttpGet)

		{

		DoCmdHttpGet();

		}

	else if(aCommand == KCmdCheckSupportedRates)

		{

		DoCmdCheckSupportedRates(aSection);

		}	

	else

		{

		ERR_PRINTF1(_L("Unknown command."));

		ret = EFalse;

		}

	return ret;

	}

/**

 * Open the Socket from RSocket. The errors are management with SetError() and SetBlockResult().

 * @param aSection				Section in the ini file for this command.

 * @return 

 */

void CT_RSocketData::DoCmdOpen(const TTEFSectionName& aSection)

	{

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

	TBool dataOk = ETrue;

	TPtrC connectionName;

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

		{

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

		SetBlockResult(EFail);

		dataOk = EFalse;

		}

	TPtrC socketServName;

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

		{

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

		SetBlockResult(EFail);

		dataOk = EFalse;

		}

	if (dataOk)

		{

		INFO_PRINTF1(_L("Opening a TCP/IP socket"));

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

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

		if(rConnection != NULL && rSocketServ != NULL)

			{

			TInt error = iSocket->Open( *rSocketServ, KAfInet, KSockStream, KProtocolInetTcp, *rConnection );

			if(error == KErrNone)

				{

				iSocketOpened = ETrue;

				}

			else

				{

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

				SetError(error);

				}

			}

		else

			{

			if(rConnection == NULL)

				{

				ERR_PRINTF2(_L("rConnection is NULL: %S"),rConnection);

				SetBlockResult(EFail);

				}

			if(rSocketServ == NULL) 

				{

				INFO_PRINTF2(_L("rSocketServ is NULL: %S"),rSocketServ);

				SetBlockResult(EFail);

				}

			}

		}

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

	}

/**

 * Command to Connect a Socket of RSocket.

 * @param aSection				Section to read from the ini file

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

 * @return

 */

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

	{

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

	TBool dataOk = ETrue;

	//Getting from the .ini the IP Address

	TPtrC aIpAddr;

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

    	{

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

    	SetBlockResult(EFail);

    	dataOk = EFalse;

    	}

	//Getting the port from the file ini

	TInt aPort;

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

    	{

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

    	SetBlockResult(EFail);

    	dataOk = EFalse;

    	}

	if(dataOk)

		{

		// Set the IP Address

		TInetAddr inetAddr;

		TInt err = inetAddr.Input( aIpAddr ) ;

		if(err == KErrNone)

			{

			INFO_PRINTF2(_L("Remote IP: %S"), &aIpAddr );

			INFO_PRINTF2( _L("Port: %d"), aPort );

			// Set the port

			inetAddr.SetPort( aPort );	

			// Connect an IP through the Port 80

			iSocket->Connect( inetAddr, iActCallConnectSocket->iStatus );

			iActCallConnectSocket->Activate(aAsyncErrorIndex);

			IncOutstanding();

			}

		else

			{

			 ERR_PRINTF2(_L("inetAddr.Input( aIpAddr ) Failed with error %d"), err);

			 SetError(err);

			}

		}

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

	}

/**

 * Command to send the HTTP Get, using the socket Write.

 * @param aSection				Section to read from the ini file

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

 * @return 

 */

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

	{

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

	TBool dataOk = ETrue;

	// Read params from the ini file

	TPtrC aHost;	

	if(!GetStringFromConfig( aSection, KHostS, aHost))

		{

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

    	SetBlockResult(EFail);

    	dataOk = EFalse;

		}

	TPtrC aFilename;

	if(!GetStringFromConfig( aSection, KFile, aFilename ))

    	{

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

    	SetBlockResult(EFail);

    	dataOk = EFalse;

    	}

	if (dataOk)

		{

		const TInt KMaxHostNameLength(256);

		if( aHost.Length() > KMaxHostNameLength )

			{

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

	    	SetBlockResult(EFail);

			}

		else if( aFilename.Length() > KMaxFileName )

			{

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

	    	SetBlockResult(EFail);

			}

		else