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

// implementattion for CSimPacketService Class

// This file contains the implementation of the Similator TSY Packet Service functionality.  

// CSimPacketService class provides a simulated packet-switched connection to a packet 

// (GPRS and CDMA) network.

// 

//

/**

 @file

*/

#include "CSimPacketService.h"

#include "Simlog.h"

#include <pcktcs.h>

#include "CSimPhone.h"

#include "utils.h"

#include "CSimPacketContext.h"

#include "CSimPubSubChange.h"

#include "CSimIncomingContextManager.h"

_LIT(KApn, "ACME INTERNET PROVIDERS LTD");

_LIT(KProtocolAddress, "i-MODE GATEWAY");

_LIT(KUsername, "USER1");

_LIT(KPassword, "PASSWORD1");

_LIT(KChallenge, "CHALLENGE1");

_LIT(KResponse, "RESPONSE1");

_LIT(KPrimaryDNS, "PRIMARYSERVER1");

_LIT(KSecondaryDNS, "SECONDARYSERVER1");

// enum for caps

const TUint KPacketServiceCaps=(RPacketService::KCapsSuspendSupported |

								RPacketService::KCapsMSClassSupported |

								RPacketService::KCapsCDMA2000HighSpeedDataSupported |

								RPacketService::KCapsNetworkAvailabilitySupported |

								RPacketService::KCapsProtocolPPPSupported |

								RPacketService::KCapsHSDPASupported |

								RPacketService::KCapsEGPRSSupported |

								RPacketService::KCapsHSUPASupported );

CSimPacketService* CSimPacketService::NewL(CSimPhone* aPhone)

/**

* Standard two phase constructor

*

* @param aPhone Pointer to the phone object (CSimPhone)

* @return CSimPacketService pointer to the packet service object created.

* @leave Leaves if no memory or object is not created for any reason.

*/

	{

	CSimPacketService* simPacket=new(ELeave) CSimPacketService(aPhone);

	CleanupStack::PushL(simPacket);

	simPacket->ConstructL();

	CleanupStack::Pop();

	return simPacket;

	}

void CSimPacketService::Init()

	{}

CSimPacketService::CSimPacketService(CSimPhone* aPhone)

	: iPhone(aPhone), iContextCount(0), iPrimaryContextNameInc(0),

	  iSecondaryContextNameInc(0), iAttachMode(RPacketService::EAttachWhenNeeded),

	  iCurrentEvent(EPacketEventNone), iPacketReleaseModeIndex(0), 

	  iPcktTimerBool(EFalse), iCurrentPrimaryContextIndex(0)

/**

* Trivial Constructor.  Initialises all the data members

*

* @param aPhone pointer to the phone object that owns this class.

*/

	{

	iState=RPacketService::EStatusUnattached;

	iMSClass = RPacketService::EMSClassSuspensionRequired;

	iNotifyStatusChange.iNotifyPending = EFalse;		

	iNotifyContextAdded.iNotifyPending = EFalse;

	iNotifyChangeOfNtwk.iNotifyPending = EFalse;

	iNotifyMSClassChange.iNotifyPending = EFalse;

	iNotifyChangeOfReleaseMode.iNotifyPending=EFalse;

	iNotifyChangeOfAttachMode.iNotifyPending=EFalse;

	iNotifyDynamicCapsChange.iNotifyPending = EFalse;

	iNotifyMbmsNetworkStatusChange.iNotifyPending = EFalse;

	iNotifyMbmsServAvailChange.iNotifyPending = EFalse;

	iSecondaryContext = EFalse;

	}

void CSimPacketService::ConstructL()

/**

* Second phase of the 2-phase constructor.

* Constructs all the member data and retrieves all the data from the config file specific to this class.

*

* @leave Leaves no memory or any data member does not construct for any reason.

* @panic Panics with SIMTSY EInvalidParameterFormatInConfigFile if an additional param data item is in an invalid format

*/

	{

	LOGPACKET1("CSimPacketService: Entered ConstructL()");

	iTimer = CSimTimer::NewL(iPhone);

	iPcktRegTimer = CSimTimer::NewL(iPhone);

	iNtwkRegTimer = CSimTimer::NewL(iPhone);

	iReleaseModeTimer = CSimTimer::NewL(iPhone);

	iDynamicCapsTimer = CSimTimer::NewL(iPhone);

	iMbmsPcktTimer = CSimTimer::NewL(iPhone);

	iMutex.CreateGlobal(KNullDesC, EOwnerProcess);

	iNtwkRegStatusInfo = new(ELeave) CArrayFixFlat<TNtwkRegStatus>(KGranularity);

	iPcktRegStatusInfo=new(ELeave) CArrayFixFlat<TPacketRegStatus>(KGranularity);

	iPacketReleaseModeArray=new (ELeave) CArrayFixFlat<TPacketReleaseMode>(KGranularity);

	iDynamicCapsArray = new (ELeave) CArrayFixFlat<TPacketDynamicCaps>(KGranularity);

	iSecondaryContextCountArray = new(ELeave)CArrayFixFlat<TInt>(KGranularity);

	iMbmsBroadcastParamsArray = new(ELeave)CArrayFixFlat<TMbmsBroadCastParams>(KGranularity);

	iMbmsMonitorListParamsArray = new(ELeave)CArrayFixFlat<TMbmsMonitorListParams>(KGranularity);

	iMbmsServicesList = new CArrayPtrFlat<CPcktListReadAllAttempt>(1);

	iNtwkRegStatusChangeProperty = CSimPubSub::TPubSubProperty(KUidPSSimTsyCategory, KPSSimtsyPacketServiceNtwkRegStatusChange, KPSSimtsyPacketServiceNtwkRegStatusChangeKeyType);

	iNtwkRegStatusChange =  CSimPubSub::NewL(this,iNtwkRegStatusChangeProperty);

	iNtwkRegStatusChange->Start(); 

	iMbmsActivation = CSimPubSubChange::NewL(this,CSimPubSub::TPubSubProperty(KUidPSSimTsyCategory, KPSSimTsyMbmsService, KPSSimTsyMbmsServiceType));

	const CTestConfigItem* item=NULL;

	TInt ret=KErrNone;

	item=CfgFile()->Item(KAttachPauseDuration); //< Retrieves the attach pause duration number from the config file

	if(item)

		{

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,0,iAttachPause);

		if(ret!=KErrNone)

			iAttachPause = KDefaultPauseDuration;

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,1,iAttachFail);

		if(ret==KErrNotFound)

			iAttachFail = KErrNone;

		}

	item=CfgFile()->Item(KDetachPauseDuration);	//< Retrieves the detach pause duration number from the config file

	if(item)

		{

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,0,iDetachPause);

		if(ret!=KErrNone)

			iDetachPause = KDefaultPauseDuration;

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,1,iDetachFail);

		if(ret==KErrNotFound)

			iDetachFail = KErrNone;

		}

	TInt count=CfgFile()->ItemCount(KPacketRegStatus); //< Retrieves the packet registration info

	item=NULL;

	TInt i;

	for(i=0;i<count;i++)

		{

		item=CfgFile()->Item(KPacketRegStatus,i);

		if(!item)

			break;

		TInt time,regState;

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,0,time);

		if(ret!=KErrNone)

			break;

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,1,regState);

		if(ret!=KErrNone)

			break;

		TPacketRegStatus status;

		status.iDuration=time;

		status.iStatus=(RPacketService::TStatus)regState;

		TRAP_IGNORE(iPcktRegStatusInfo->AppendL(status));

		}

	iNtwkRegStatusNotificationType = ETimer;

	item=CfgFile()->Item(KNetworkRegStatusType);

	if(item)

		{

		TPtrC8 networkRegStatusType;

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,0,networkRegStatusType);

		if(ret==KErrNone && networkRegStatusType.Compare(KNotificationTypePublishSubscribe)==0)

			{

			iNtwkRegStatusNotificationType = EPublishAndSubscribe;

			}

		}

	count=CfgFile()->ItemCount(KNetworkRegStatus); //< Retrieves the packet registration info

	item=NULL;

	for(i=0;i<count;i++)

		{

		item=CfgFile()->Item(KNetworkRegStatus,i);

		if(!item)

			break;

		TInt time,regState;

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,0,time);

		if(ret!=KErrNone)

			break;

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,1,regState);

		if(ret!=KErrNone)

			break;

		TNtwkRegStatus status;

		status.iDuration=time;

		status.iRegStatus=(RPacketService::TRegistrationStatus)regState;

		TRAP_IGNORE(iNtwkRegStatusInfo->AppendL(status));

		}

	if(iPcktRegStatusInfo->Count()!=0)

		{

		iPcktRegStatIndex=0;

		iState=(RPacketService::TStatus)iPcktRegStatusInfo->At(0).iStatus;

		iPcktRegTimer->Start(iPcktRegStatusInfo->At(0).iDuration,this,ETimerIdPcktServPacket);

		}

	if(iNtwkRegStatusInfo->Count()!=0)

		{

		iCurrentRegStatus=(RPacketService::TRegistrationStatus)iNtwkRegStatusInfo->At(0).iRegStatus;

		if (iNtwkRegStatusNotificationType == ETimer)

			{

			iNtwkRegStatIndex=0;

			iNtwkRegTimer->Start(iNtwkRegStatusInfo->At(0).iDuration,this,ETimerIdPcktServNtwkStatusChange);

			}

		}

	//< Read in all dynamic capabilities data

	count = CfgFile()->ItemCount(KDynamicCaps);

	item = NULL;

	for (i = 0; i < count; ++i)

		{

		item = CfgFile()->Item(KDynamicCaps,i);

		if (!item)

			break;

		TInt duration(0); 

		TInt dynamicCaps(0);

		ret = CTestConfig::GetElement(item->Value(),KStdDelimiter,0,duration);

		if (ret != KErrNone)

			break;

		ret = CTestConfig::GetElement(item->Value(),KStdDelimiter,1,dynamicCaps);

		if (ret != KErrNone)

			break;

		TPacketDynamicCaps dynamicCapsData;

		dynamicCapsData.iDuration = duration;

		dynamicCapsData.iDynamicCaps = dynamicCaps;

		TRAP_IGNORE(iDynamicCapsArray->AppendL(dynamicCapsData));

		}

	if (iDynamicCapsArray->Count() != 0)

		{

		iDynamicCapsIndex = 0;

		TPacketDynamicCaps initialCaps = iDynamicCapsArray->At(0);

		iCurrentDynamicCaps = initialCaps.iDynamicCaps;

		iDynamicCapsTimer->Start(initialCaps.iDuration, this, ETimerIdPcktServDynamicCaps);

		}

	// end of dynamic caps simulation setup

	//< Read in all the data for getting the default GPRS configuration parameters

	item = CfgFile()->Item(KDefaultContextparamGPRS);

	if(item) 

		{

		TInt protocolType,pdpCompression, anonymousAccess, useEdge;

		TPtrC8 gsnAddress, protocolAddress;

		TInt protocol;	

		TPtrC8 username,password, challenge, response, primaryDNS, secondaryDNS, iMiscBuffer;

		TInt id, numAdditionalParams;

		iGPRSDefaultConfig.iProtocolConfigOption.iMiscBuffer.Zero();

		TPtr8 pcoPtr(const_cast<TUint8*>(iGPRSDefaultConfig.iProtocolConfigOption.iMiscBuffer.Ptr()), 

			RPacketContext::KMiscProtocolBufferLength);

		// Attach TTlv to the buffer

		TTlvStruct<RPacketContext::TPcoId,RPacketContext::TPcoItemDataLength> tlvStruct(pcoPtr,0);

		RPacketContext::TPcoId pcoId;

		TUint itemOffSet = 0; // Used for nested Addional Param items		

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,0,protocolType);

		if(ret==KErrNone)

			iGPRSDefaultConfig.iProtocolType = protocolType;

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,1,gsnAddress);

		if(ret==KErrNone)

			iGPRSDefaultConfig.iGsnAddress.Set(gsnAddress);

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,2,protocolAddress);

		if(ret==KErrNone)

			iGPRSDefaultConfig.iProtocolAddress.Set(protocolAddress);

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,3,pdpCompression);

		if(ret==KErrNone)

			iGPRSDefaultConfig.iPdpCompression = pdpCompression;

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,4,anonymousAccess);

		if(ret==KErrNone)

			iGPRSDefaultConfig.iAnonymousAccess = anonymousAccess;

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,5,useEdge);

		if(ret==KErrNone)

			iGPRSDefaultConfig.iUseEdge = useEdge;

		// Protocol configuration and DNS server parameters added

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,6,protocol);

		if(ret==KErrNone)

			iGPRSDefaultConfig.iProtocolConfigOption.iAuthProtocol = protocol;

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,7,username);

		if(ret==KErrNone)

			iGPRSDefaultConfig.iProtocolConfigOption.iUsername.Set(username);

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,8,password);

		if(ret==KErrNone)

			iGPRSDefaultConfig.iProtocolConfigOption.iPassword.Set(password);

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,9,challenge);

		if(ret==KErrNone)

			iGPRSDefaultConfig.iProtocolConfigOption.iChallenge.Set(challenge);

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,10,response);

		if(ret==KErrNone)

			iGPRSDefaultConfig.iProtocolConfigOption.iResponse.Set(response);

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,11,primaryDNS);

		if(ret==KErrNone)

			iGPRSDefaultConfig.iProtocolConfigOption.iPrimaryDNS.Set(primaryDNS);

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,12,secondaryDNS);

		if(ret==KErrNone)

			iGPRSDefaultConfig.iProtocolConfigOption.iSecondaryDNS.Set(secondaryDNS);

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,13,id);

		if(ret==KErrNone)

			iGPRSDefaultConfig.iProtocolConfigOption.iId = id;

		//Get the Additional Params List

		//Get the number of items in the Additional Params List

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,14,numAdditionalParams);

		if(ret==KErrNone)

			{

			TInt nestedItemNumber;

			TUint16 digit, format;

			const CTestConfigItem* item2;

			for(nestedItemNumber=itemOffSet; nestedItemNumber<itemOffSet+numAdditionalParams; nestedItemNumber++)

				{

				item2 = CfgFile()->Item(KDefaultGPRSAdditionalParamItem, nestedItemNumber);

				if(item2)

					{

					TPtrC8 additionalParamId, additionalParamContent, additionalParamDataFormat;

					// Get ID

					ret=CTestConfig::GetElement(item2->Value(),KStdDelimiter,0,additionalParamId);

					if(ret==KErrNone)

						{

						if(AsciiToNum(additionalParamId, digit)==KErrNone)

							{

							pcoId.SetId(digit);

							}

						}

					// Read AdditionalParamDataFormat field to find out how

					// to interpret data in the AdditionalParamData field

					ret=CTestConfig::GetElement(item2->Value(),KStdDelimiter,2,additionalParamDataFormat);

					if (ret != KErrNone)

						{

						// AdditionalParamDataFormat not been specified,

						// default to plain ASCII

						LOGPARSERR("AdditionalParamItem::additionalParamDataFormat",ret,2,&KDefaultGPRSAdditionalParamItem);

						format = EConfigDataFormatAscii;

						}

					else

						{

						if (AsciiToNum(additionalParamDataFormat, format) != KErrNone)

							{

							LOGPARSERR("AdditionalParamItem::additionalParamDataFormat",KErrArgument,2,&KDefaultGPRSAdditionalParamItem);

							format = EConfigDataFormatAscii;

							}

						// Check that the AdditionalParamDataFormat value

						// specified in the config file is a valid one,

						// default to ASCII if not.

						if (format >= EMaxConfigDataFormat)

							{

							LOGPARSERR("AdditionalParamItem::additionalParamDataFormat",KErrArgument,2,&KDefaultGPRSAdditionalParamItem);

							format = EConfigDataFormatAscii;

							}

						}

					// Get AdditionalParamData

					ret=CTestConfig::GetElement(item2->Value(),KStdDelimiter,1,additionalParamContent);

					if(ret==KErrNone)

						{

						// Add AdditionalParamData to PCO buffer depending on format

						switch (format)

							{

						case EConfigDataFormatMixedBinaryAndAscii:

							{

							// Parse the string here

							// Will store the parsed data when algorithm has completed

							TBuf8<RPacketContext::KMiscProtocolBufferLength> additionalParamDataBuffer;

							additionalParamDataBuffer.Copy (additionalParamContent);

							if (ParseMixedBinaryAsciiDataL(additionalParamDataBuffer) != KErrNone)

								{

								LOGPARSERR("AdditionalParamItem::additionalParamContent",KErrArgument,1,&KDefaultGPRSAdditionalParamItem);

								SimPanic(EInvalidParameterFormatInConfigFile);

								}

							TPtr8 paramPtr(const_cast<TUint8*>(additionalParamDataBuffer.Ptr()), 

								additionalParamDataBuffer.Length(), additionalParamDataBuffer.Length());

							tlvStruct.AppendItemL(pcoId, paramPtr);

							} // case EAdditionalParamDataFormatMixedBinaryAndAscii

							break;

						case EConfigDataFormatAscii:

						default:

							TPtr8 paramPtr(const_cast<TUint8*>(additionalParamContent.Ptr()), 

								additionalParamContent.Length(), additionalParamContent.Length());

							tlvStruct.AppendItemL(pcoId, paramPtr);

							break;

							} // switch (format)

						iGPRSDefaultConfig.iProtocolConfigOption.iMiscBuffer.SetLength(pcoPtr.Length());						

						} // if (ret == KErrNone)

					}

				}

				itemOffSet= itemOffSet + numAdditionalParams;;

			}

		else

			{

			LOGPARSERR("ProtocolConfigOption::numAdditionalParams",ret,14,&KDefaultContextparamGPRS);	

			} 

		} 

	//< Read in all the data for getting the default UMTS configuration parameters

	item = CfgFile()->Item(KDefaultContextparamRel99);

	if(item)

		{

		TInt protocolType,useEdge;

		TPtrC8 gsnAddress, protocolAddress;

		TInt protocol;

		TPtrC8 username,password, challenge, response, primaryDNS, secondaryDNS, iMiscBuffer;

		TInt id, numAdditionalParams;

		iR99_R4DefaultConfig.iProtocolConfigOption.iMiscBuffer.Zero();

		TPtr8 pcoPtr(const_cast<TUint8*>(iR99_R4DefaultConfig.iProtocolConfigOption.iMiscBuffer.Ptr()), 

			RPacketContext::KMiscProtocolBufferLength);

		// Attach TTlv to the buffer

		TTlvStruct<RPacketContext::TPcoId,RPacketContext::TPcoItemDataLength> tlvStruct(pcoPtr,0);

		RPacketContext::TPcoId pcoId;

		TUint itemOffSet = 0; // Used for nested Addional Param items

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,0,protocolType);

		if(ret==KErrNone)

			iR99_R4DefaultConfig.iProtocolType = protocolType;

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,1,gsnAddress);

		if(ret==KErrNone)

			iR99_R4DefaultConfig.iGsnAddress.Set(gsnAddress);

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,2,protocolAddress);

		if(ret==KErrNone)

			iR99_R4DefaultConfig.iProtocolAddress.Set(protocolAddress);

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,3,useEdge);

		if(ret==KErrNone)

			iR99_R4DefaultConfig.iUseEdge = useEdge;

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,4,protocol);

		if(ret==KErrNone)

			iR99_R4DefaultConfig.iProtocolConfigOption.iAuthProtocol = protocol;

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,5,username);

		if(ret==KErrNone)

			iR99_R4DefaultConfig.iProtocolConfigOption.iUsername.Set(username);

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,6,password);

		if(ret==KErrNone)

			iR99_R4DefaultConfig.iProtocolConfigOption.iPassword.Set(password);

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,7,challenge);

		if(ret==KErrNone)

			iR99_R4DefaultConfig.iProtocolConfigOption.iChallenge.Set(challenge);

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,8,response);

		if(ret==KErrNone)

			iR99_R4DefaultConfig.iProtocolConfigOption.iResponse.Set(response);

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,9,primaryDNS);

		if(ret==KErrNone)

			iR99_R4DefaultConfig.iProtocolConfigOption.iPrimaryDNS.Set(primaryDNS);

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,10,secondaryDNS);

		if(ret==KErrNone)

			iR99_R4DefaultConfig.iProtocolConfigOption.iSecondaryDNS.Set(secondaryDNS);

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,11,id);

		if(ret==KErrNone)

			iR99_R4DefaultConfig.iProtocolConfigOption.iId = id;

		//Get the Additional Params List

		//Get the number of items in the Additional Params List

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,12,numAdditionalParams);

		if(ret==KErrNone)

			{

			TInt nestedItemNumber;

			TUint16 digit, format;