// Copyright (c) 2001-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 "gprs.h"

#include "Gprscontext.h"

#include "mSLOGGER.H"

#include <pcktcs.h>

#include "ATGprsConfig.h"

#include "ATIO.H"

#include <etelpckt.h>

#include "NOTIFY.H"

#include "Matstd.h"

_LIT8(KGetCGDCONTCommand,"AT+CGDCONT?\r");

_LIT8(KIPType4	, "IP");

_LIT8(KIPType6	, "IP");

_LIT8(KX25		, "X25");

 /**

 * @file

 * This file implements the CATGPRSSetConfig class and the CATGPRSGetConfig. These two classes are used by the 

 * GPRS AT TSY library. 

 * This state machine uses "AT+CGQREQ" "AT+CGDCONT" "AT+CGQMIN" commands.

 */

CATGPRSSetConfig* CATGPRSSetConfig::NewL(TInt aCid, CATIO* aIo, CTelObject* aTelObject, CATInit* aInit, CPhoneGlobals* aPhoneGlobals)

/**

 *  Standard 2 phase constructor.

 * @param aIo pointer to communication object.

 * @param aTelObject pointer to parent.

 * @param aInit pointer to AT phone init object.

 * @param aPhoneGlobals pointer to phone global wide states.

 */

	{

	CATGPRSSetConfig* p=new(ELeave) CATGPRSSetConfig(aCid, aIo, aTelObject, aInit, aPhoneGlobals);

	CleanupStack::PushL(p);

	p->ConstructL();

	CleanupStack::Pop();

	return p;

	}

void CATGPRSSetConfig::ConstructL()

/**

 * Construct all objects that can leave.

 */

	{

	CATCommands::ConstructL();

	}

CATGPRSSetConfig::CATGPRSSetConfig(TInt aCid, CATIO* aIo, CTelObject *aTelObject, CATInit* aInit, CPhoneGlobals* aPhoneGlobals)	

	: CATCommands(aIo, aTelObject, aInit, aPhoneGlobals), iCid(aCid)

/**

 * Constructor.

 *

 * @param aIo pointer to communication object.

 * @param aTelObject pointer to parent.

 * @param aPhoneGlobals pointer to phone global wide states.

 */

	{

	LOGTEXT(_L8("CATGprsClass::CATGprsClass called"));

	}

CATGPRSSetConfig::~CATGPRSSetConfig()

/**

 * Destructor.

 */ 

	{

	LOGTEXT(_L8("CATGPRSSetConfig::~CATGPRSSetConfig called"));

	}

void CATGPRSSetConfig::Start(TTsyReqHandle aTsyReqHandle, TAny* aConfig)

/**

 * This starts the sending of the set commands.

 *

 * @param aConfig config package.

 * @param aTsyReqHandle handle to the client.

 */

	{

	iReqHandle = aTsyReqHandle;

	TPckg<RPacketContext::TContextConfigGPRS>* contextConfigV1Pckg = (TPckg<RPacketContext::TContextConfigGPRS>*)aConfig;

	iContextConfigGPRS= &(*contextConfigV1Pckg)();

	TInt ret=MakeupCGDCONT();

	if(ret)

		{

		Complete(KErrNotSupported,ETimeOutCompletion);

		return;

		}

	LOGTEXT(_L8("CATGPRSSetConfig:\tCATConfigGPRS::Start function called in TSY"));

	__ASSERT_ALWAYS(iIo->AddExpectString(this,KNotifyMeIfErrorString) != NULL, Panic(EGeneral));

	iState=EWaitForSetCGDCONTComplete;

	Write(KGprsCommandTimeOut);	

	}

void CATGPRSSetConfig::Stop(TTsyReqHandle aTsyReqHandle)

/**

 * This function cancels the outstanding read and sets the state to EWaitForDSR.

 *

 * @param aTsyReqHandle handle to the client.

 */

	{

	LOGTEXT(_L8("CATGPRSSetConfig::Stop called"));

	if(iState!=EATNotInProgress && aTsyReqHandle==iReqHandle)

		{

		LOGTEXT(_L8("CATGPRSSetConfig::Stop Completing client request with KErrCancel"));

		Complete(KErrCancel,ETimeOutCompletion);

		}

	}

void CATGPRSSetConfig::CompleteWithIOError(TEventSource aSource,TInt aStatus)

/**

 * This Function completes the command from the client whith an error.

 *

 * @param aSource source of event from communication class.

 * @param aStatus status of event.

 */

	{

	Complete(aStatus, aSource);

	}

void CATGPRSSetConfig::Complete(TInt aErr, TEventSource aSource)

/**

 * This Function completes the get or set command from the client.

 * @param aErr an error code to relay to client.

 */

	{

	LOGTEXT(_L8("CATGPRSSetConfig::Complete"));

	RemoveStdExpectStrings();

	iIo->WriteAndTimerCancel(this);

	iIo->RemoveExpectStrings(this); 

	if (aErr == KErrNone)

		{

		((CGprsContext*)iTelObject)->SetConfig(iContextConfigGPRS);

		iPhoneGlobals->iNotificationStore->CheckNotification(iTelObject, EPacketContextConfigChanged);

		}

	// Allow our base class to do its thing and then complete the client request

	CATCommands::Complete(aErr,aSource);		

	iTelObject->ReqCompleted(iReqHandle, aErr);

	iState = EATNotInProgress;

	}

void CATGPRSSetConfig::EventSignal(TEventSource aSource)

/**

 * This function contains the state machine for the command.  The states flow consecutively in 

 * get and set states and are described below.

 *	

 * @par  aSource Source of function call.

 *

 * @par EWaitForDSR

 * Wait for the DSR command to complete. Also sends AT+CGDCONT set or get command to the phone.

 *

 * @par	EWaitForSetCGDCONTComplete,

 * Wait for response from the phone on the set command. 

 *

 * @par		EWaitForSetCGDCONTOK,

 * Validate phone response and send set AT+CGQMIN command.

 * 

 *

 */

	{

	LOGTEXT2(_L8("CATGPRSSetConfig::EventSignal with iState %d"),iState);

	if ((aSource==ETimeOutCompletion))

		{

		LOGTEXT(_L8("CATGPRSSetConfig:\tTimeout Error during Config"));

		Complete(KErrTimedOut,aSource);

		return;

		}

	switch(iState)

		{

		case EWaitForSetCGDCONTComplete:

			LOGTEXT(_L8("CATGPRSSetConfig::EventSignal, EWaitForSetCGDCONTComplete"));

			StandardWriteCompletionHandler(aSource, KGprsCommandTimeOut);

			iState = EWaitForSetCGDCONTOK;

			break;

		case EWaitForSetCGDCONTOK:

			{

			// Called when OK is received

			LOGTEXT(_L8("CATGPRSSetConfig::EventSignal, EWaitForSetCGDCONTOK"));

			__ASSERT_ALWAYS(aSource==EReadCompletion,Panic(EATCommand_IllegalCompletionReadExpected));

			TInt ret = ValidateExpectString();

			Complete(ret, aSource);

			}

			break;

		case EATNotInProgress:

			break;

		default:

			LOGTEXT(_L8("CATGPRSSetConfig::EventSignal, default. Panic"));

			Panic(EIllegalEvent);

			break;

		}			

	}

TInt CATGPRSSetConfig::MakeupCGDCONT()

/**

 * This Function creates the at set string for the AT+CGDCONT command.

 */

	{

	const TInt KPDPTypeIdent=5;

	TBuf8<KPDPTypeIdent>						pdpType;		// PDP Type identifier

	TBuf8<RPacketContext::KGSNNameLength>		gsnName;			// Access point Name

	TBuf8<RPacketContext::KMaxPDPAddressLength>	pdpAddress;	// PDP pre-assigned address

	switch(iContextConfigGPRS->iPdpType)

		{

		case RPacketContext::EPdpTypeIPv4:

			pdpType.Format(KIPType4);

		break;

		case RPacketContext::EPdpTypeIPv6:

			pdpType.Format(KIPType6);

		break;

		case RPacketContext::EPdpTypeX25:

			pdpType.Format(KX25);

		break;

		default:

			return KErrUnknown;

		}

	gsnName.Copy(iContextConfigGPRS->iAccessPointName);

	pdpAddress.Copy(iContextConfigGPRS->iPdpAddress);

	const TBool dataCompression=iContextConfigGPRS->iPdpCompression & RPacketContext::KPdpDataCompression;

	const TBool headerCompression=iContextConfigGPRS->iPdpCompression & RPacketContext::KPdpHeaderCompression;

	iTxBuffer.Format(_L8("AT+CGDCONT=%d,\"%S\",\"%S\",\"%S\",%d,%d\r"), iCid, &pdpType,

			&gsnName, &pdpAddress,dataCompression,headerCompression);

	return KErrNone;

	}

CATGPRSGetConfig* CATGPRSGetConfig::NewL(TInt aCid, CATIO* aIo, CTelObject* aTelObject, CATInit* aInit, CPhoneGlobals* aPhoneGlobals)

/**

 *  Standard 2 phase constructor.

 *

 * @param aIo pointer to communication object.

 * @param aTelObject pointer to parent.

 * @param aPhoneGlobals pointer to phone global wide states.

 */

	{

	CATGPRSGetConfig* p=new(ELeave) CATGPRSGetConfig(aCid, aIo, aTelObject, aInit, aPhoneGlobals);

	CleanupStack::PushL(p);

	p->ConstructL();

	CleanupStack::Pop();

	return p;

	}

void CATGPRSGetConfig::ConstructL()

/**

 * Construct all objects that can leave.

 */

	{

	CATCommands::ConstructL();

	}

CATGPRSGetConfig::CATGPRSGetConfig(TInt aCid, CATIO* aIo, CTelObject *aTelObject, CATInit* aInit, CPhoneGlobals* aPhoneGlobals)	

	: CATCommands(aIo, aTelObject, aInit, aPhoneGlobals), iCid(aCid)

/**

 * Constructor.

 *

 * @param aIo pointer to communication object.

 * @param aTelObject pointer to parent.

 * @param aPhoneGlobals pointer to phone global wide states.

 */

	{}

CATGPRSGetConfig::~CATGPRSGetConfig()

/**

 * Destructor.

 */

	{}

void CATGPRSGetConfig::Start(TTsyReqHandle aTsyReqHandle, TAny* aConfig)

/**

 * This starts the sending of the get commands.

 * 

 * @param aTsyReqHandle handle to the client.

 * @param aConfig Pointer to a RPacketContext::TContextConfigGPRS. 

 */

	{

	LOGTEXT(_L8("CATGPRSGetConfig::Start called"));

	TPckg<RPacketContext::TContextConfigGPRS>* contextConfigV1Pckg = (TPckg<RPacketContext::TContextConfigGPRS>*)aConfig;

	iContextConfigV1 = &(*contextConfigV1Pckg)();

	__ASSERT_ALWAYS(iIo->AddExpectString(this,KNotifyMeIfErrorString) != NULL, Panic(EGeneral));

	iReqHandle = aTsyReqHandle;

	iState=EWaitForGetCGDCONTComplete;

	Write(KGetCGDCONTCommand, KGprsCommandTimeOut);

	}

void CATGPRSGetConfig::Stop(TTsyReqHandle aTsyReqHandle)

/**

 * This function cancels the outstanding read and sets the state to EWaitForDSR.

 * @param aTsyReqHandle handle to the client.

 */

	{

	LOGTEXT(_L8("CATGPRSGetConfig::Stop called"));

	if(iState!=EATNotInProgress && aTsyReqHandle==iReqHandle)

		{

		LOGTEXT(_L8("CATGPRSGetConfig::Stop Completing client request with KErrCancel"));

		Complete(KErrCancel,ETimeOutCompletion);

		}

	}

void CATGPRSGetConfig::Complete(TInt aErr, TEventSource	aSource)

/**

 * This Function completes the get or set command from the client.

 * @param aErr and error to relay to the client.

 */

	{

	LOGTEXT(_L8("CATGPRSGetConfig::Complete"));

	RemoveStdExpectStrings();

	iIo->WriteAndTimerCancel(this);

	iIo->RemoveExpectStrings(this); 

	if(aErr == KErrNone)		

		{

		((CGprsContext*)iTelObject)->SetConfig(iContextConfigV1);

		}

	// Allow our base class to do its thing and then complete the client request

	CATCommands::Complete(aErr,aSource);		

	iTelObject->ReqCompleted(iReqHandle, aErr);

	iState = EATNotInProgress;

	}

void CATGPRSGetConfig::CompleteWithIOError(TEventSource aSource,TInt aStatus)

/**

 * This Function completes the command from the client whith an error.

 * @param aSource source of event from communication class.

 * @param aStatus status of event.

 */

	{

	Complete(aStatus, aSource);

	}

void CATGPRSGetConfig::EventSignal(TEventSource aSource)

/**

 * This function contains the state machine for the command.  The states flow consecutively in 

 * get and set states and are described below.

 *	

 * @par  aSource Source of function call. 

 *

 *

 * @par		EWaitForGetCGDCONTComplete,

 * Wait for response from the phone on the set command.

 *

 * @par		EWaitForGetCGDCONTOK,

 * Validate phone response and send set AT+CGQMIN command.

 *

 */

	{

	LOGTEXT2(_L8("CATGPRSGetConfig::EventSignal with iState %d"),iState);

	if ((aSource==ETimeOutCompletion))

		{

		LOGTEXT(_L8("CATGPRSGetConfig:\tTimeout Error during Config"));

		Complete(KErrTimedOut,aSource);

		return;

		}

	switch(iState)

		{

		case EWaitForGetCGDCONTComplete:

				{

				iIo->WriteAndTimerCancel(this);

				StandardWriteCompletionHandler(aSource, KGprsCommandTimeOut);

				iState = EWaitForGetCGDCONTOK;

				}

			break;

		case EWaitForGetCGDCONTOK:

				{

				// Called when OK is received

				__ASSERT_ALWAYS(aSource==EReadCompletion,Panic(EATCommand_IllegalCompletionReadExpected));

				TInt ret = ValidateExpectString();

				if(ret)

					{	

					Complete(ret, aSource);

					return;

					}

				TRAP_IGNORE(ParseCGDCONTResponseL());

				Complete(ret, aSource);

				}

			break;

		case EATNotInProgress:

			break;

		default:

				{

				LOGTEXT(_L8("CATGPRSGetConfig::EventSignal, Default, panic"));

				Panic(EIllegalEvent);

				}

			break;

		}			

	}

void CATGPRSGetConfig::ParseCGDCONTResponseL()

/**

 * This Function parses the response from the get AT+CGDCONT? command to the phone

 */

	{

	ParseBufferLC();

	CATParamListEntry* entry;

	TDblQueIter<CATParamListEntry> iter(iRxResults);

	while(entry = iter++,entry!=NULL)

		{

		if (entry->iResultPtr.MatchF(KCGDCONTResponseString)!=0)

			continue;

		entry = iter++;

		if(entry == NULL)

			User::Leave(KErrNotFound);

		TLex8 lex(entry->iResultPtr);

		TInt val;

		(void)User::LeaveIfError(lex.Val(val));

		if(iCid == val)

			{

			entry = iter++;

			break;

			}

		}

	if(entry == NULL)

		User::Leave(KErrNotFound);

	// we are now pointing to the correct context, just parse the values

	// Get the pdp type

	TPtrC8 result(entry->iResultPtr);

	if(result == KIPType4)	

		iContextConfigV1->iPdpType = RPacketContext::EPdpTypeIPv4;

	else if(result == KIPType6)//EPdpTypeIPv6,

		iContextConfigV1->iPdpType = RPacketContext::EPdpTypeIPv6;

	else if(result == KX25)

		iContextConfigV1->iPdpType = RPacketContext::EPdpTypeX25;

	else

		User::Leave(KErrNotSupported);		

	//Get the gsnName

	entry = iter++;

	if(entry == NULL)

		User::Leave(KErrNotFound);

	result.Set(entry->iResultPtr);

	iContextConfigV1->iAccessPointName.Copy(result);

	// Get pdp address

	entry = iter++;

	if(entry == NULL)

		User::Leave(KErrNotFound);

	result.Set(entry->iResultPtr);

	iContextConfigV1->iPdpAddress.Copy(result);

	// get compression

	entry = iter++;

	if(entry == NULL)

		User::Leave(KErrGeneral);

	iContextConfigV1->iPdpCompression = CATParamListEntry::EntryValL(entry);

	CleanupStack::PopAndDestroy();

	}