// Copyright (c) 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:

// @file atphbkstorecache.cpp

// This contains CAtPhbkStoreCache which is used to cache phonebook Entries

// 

//system include 

#include <etelmm.h>

#include <ctsy/ltsy/cctsydispatchercallback.h>

#include <mpbutil.h>

#include <cmmgsmphonestorageutility.h>

//user include 

#include "atphbkstorecache.h"

#include "mslogger.h"

//constant defination

_LIT8(KPhbkStoreRead,"AT+CPBR=%d,%d\r");

_LIT8(KSelAdnPhonebook,"AT+CPBS=\"SM\"\r");

_LIT8(KSelFdnPhonebook,"AT+CPBS=\"FD\"\r");

_LIT8(KCPBRMatchString,"+CPBR:*");

_LIT8(KCPBRSResponseString,"+CPBR:");

const TInt KAdnStartIndex = 1;

const TInt KFdnStartIndex = 1;

// ---------------------------------------------------------------------------

// CAtPhbkStoreCache::CAtPhbkStoreCache

// other items were commented in a header

// ---------------------------------------------------------------------------

CAtPhbkStoreCache::CAtPhbkStoreCache(CGlobalPhonemanager& aGloblePhone, 

                                   CCtsyDispatcherCallback& aCtsyDispatcherCallback)

                                   :CAtCommandBase(aGloblePhone,aCtsyDispatcherCallback)

	{

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

	iEndFlag = EFalse;

	}

// ---------------------------------------------------------------------------

// CAtPhbkStoreCache::~CAtPhbkStoreCache

// other items were commented in a header

// ---------------------------------------------------------------------------

CAtPhbkStoreCache::~CAtPhbkStoreCache()

	{

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

	}

// ---------------------------------------------------------------------------

// CAtPhbkStoreCache::NewLC

// other items were commented in a header

// ---------------------------------------------------------------------------

CAtPhbkStoreCache* CAtPhbkStoreCache::NewLC(CGlobalPhonemanager& aGloblePhone, 

                                          CCtsyDispatcherCallback& aCtsyDispatcherCallback)

	{

	CAtPhbkStoreCache* self = new (ELeave)CAtPhbkStoreCache(aGloblePhone, 

                                                          aCtsyDispatcherCallback);

	CleanupStack::PushL(self);

	self->ConstructL();

	return self;

	}

// ---------------------------------------------------------------------------

// CAtPhbkStoreCache::NewL

// other items were commented in a header

// ---------------------------------------------------------------------------

CAtPhbkStoreCache* CAtPhbkStoreCache::NewL(CGlobalPhonemanager& aGloblePhone, 

                                         CCtsyDispatcherCallback& aCtsyDispatcherCallback)

	{

	CAtPhbkStoreCache* self=CAtPhbkStoreCache::NewLC(aGloblePhone, 

                                                   aCtsyDispatcherCallback);

	CleanupStack::Pop(self);

	return self;

	}

// ---------------------------------------------------------------------------

// CAtPhbkStoreCache::ConstructL

// other items were commented in a header

// ---------------------------------------------------------------------------

void CAtPhbkStoreCache::ConstructL()

	{

	CAtCommandBase::ConstructL();

	AddExpectStringL(KLtsyOkString);

	AddExpectStringL(KLtsyErrorString);

	AddExpectStringL(KCPBRMatchString);

	}

// ---------------------------------------------------------------------------

// CAtPhbkStoreCache::SetPhonebookType

// other items were commented in a header

// ---------------------------------------------------------------------------

void CAtPhbkStoreCache::SetPhonebookType(DispatcherPhonebook::TPhonebook aPhonebookType)

	{

	iPhoneBookType = aPhonebookType;

	}

// ---------------------------------------------------------------------------

// CAtPhbkStoreCache::StartRequest

// other items were commented in a header

// ---------------------------------------------------------------------------

void CAtPhbkStoreCache::StartRequest()

	{

	ExecuteCommand();

	}

// ---------------------------------------------------------------------------

// CAtPhbkStoreCache::ExecuteCommand

// other items were commented in a header

// ---------------------------------------------------------------------------

void CAtPhbkStoreCache::ExecuteCommand()

	{

	LOGTEXT(_L8("CAtPhbkStoreCache::ExecuteCommand called"));

	iState = ESetStoreName;

	iTxBuffer.Zero();	

	if( iPhoneBookType == DispatcherPhonebook::EIccAdn )

		{

		iTxBuffer.Copy(KSelAdnPhonebook);

		}

	else if( iPhoneBookType == DispatcherPhonebook::EIccFdn )

		{

		iTxBuffer.Copy(KSelFdnPhonebook);

		}

	Write();

	}

// ---------------------------------------------------------------------------

// CAtPhbkStoreCache::ReadEntry

// other items were commented in a header

// ---------------------------------------------------------------------------

void CAtPhbkStoreCache::ReadEntry()

	{

	LOGTEXT(_L8("CAtPhbkStoreCache::ReadEntry callded"));

	iPhoneGlobals.iEventSignalActive = ETrue;

	iTxBuffer.Zero();

	TInt totalEntries(KErrNone);

	if( iPhoneBookType == DispatcherPhonebook::EIccAdn )

		{

		totalEntries = iPhoneGlobals.iPhonebookStoreInfo.iAdnTotalEntries;

		iTxBuffer.Format(KPhbkStoreRead,KAdnStartIndex,totalEntries);

		}

	else if( iPhoneBookType == DispatcherPhonebook::EIccFdn )

		{

		totalEntries = iPhoneGlobals.iPhonebookStoreInfo.iFdnTotalEntries; 

		iTxBuffer.Format(KPhbkStoreRead,KFdnStartIndex,totalEntries);

		}

	Write();

	}

// ---------------------------------------------------------------------------

// CAtPhbkStoreCache::EventSignal

// other items were commented in a header

// ---------------------------------------------------------------------------

void CAtPhbkStoreCache::EventSignal(TAtEventSource aEventSource, TInt aStatus)

	{

	LOGTEXT3(_L8("CAtPhbkStoreCache::EventSignal aStatus=%D iSource=%D"),aStatus,aEventSource);

	if(aStatus != KErrNone)

		{

		Complete();

		iPhoneGlobals.iEventSignalActive = EFalse;

		iCtsyDispatcherCallback.CallbackPhonebookStoreCacheComp(aStatus,iPhoneBookType,iPhbkData);

		}

	else

		{

		if( aEventSource== EWriteCompletion )

			{

			if( iState==ESetStoreName )

				{

				iState = ESetStoreNameComplete;

				}

			else if( iState==EReadEntry )

				{

				iState = EReadEntryComplete;

				}

			}

		else 

			{

			if( iState==ESetStoreNameComplete )

				{

				Complete();

				iPhoneGlobals.iEventSignalActive = EFalse;

				if(iError == KErrNone)

					{

					ClearBuffer();

					iState = EReadEntry;

					ReadEntry();

					}

				else 

					{

					iCtsyDispatcherCallback.CallbackPhonebookStoreCacheComp(iError,iPhoneBookType,iPhbkData);

					}

				}

			else if( iState==EReadEntryComplete )

				{

				//encounter OK or ERROR

				if( iEndFlag )

					{

					ClearBuffer();

					iPhbkData.Zero();

					Complete();

					iPhoneGlobals.iEventSignalActive = EFalse;

					iCtsyDispatcherCallback.CallbackPhonebookStoreCacheComp(iError,iPhoneBookType,iPhbkData);

					}

				else 

					{

					if( iError==KErrNone )

						{

						TRAPD(err, GeneratePhbkDataL());

						iCtsyDispatcherCallback.CallbackPhonebookStoreCacheComp(err,iPhoneBookType,iPhbkData);

						ClearCurrentLine();

						}

					else 

						{

						iCtsyDispatcherCallback.CallbackPhonebookStoreCacheComp(iError,iPhoneBookType,iPhbkData);

						ClearCurrentLine();

						}

					}

				}

			}

		}

	}

// ---------------------------------------------------------------------------

// CAtPhbkStoreCache::ParseResponseL

// other items were commented in a header

// ---------------------------------------------------------------------------

void CAtPhbkStoreCache::ParseResponseL(const TDesC8& /*aResponseBuf*/)

	{

	if( iState == ESetStoreNameComplete )

	    {

		if (CurrentLine().Match(KLtsyOkString) == 0)

			{

			iError = KErrNone;

			}

		else

			{

			iError = KErrGeneral;

			}

	    }

	else if( iState == EReadEntryComplete )

		{

		/**

		* Here is an Example 

		* at+CPBR=1,250    

		*+CPBR: 1,"1234001",129,""

		*+CPBR: 2,"123456002",129,"TelNo 002"

		*+CPBR: 3,"123456003",129,"TelNo 003"

		*+CPBR: 4,"123456004",129,"TelNo 004"

		*OK

		*/

		RArray<TPtrC8> array;

		CleanupClosePushL(array);

		iParser->ParseRespondedBuffer(array,Buffer());

		// remove the string of AT+CPBR=..

		if(array[0].MatchF(KAnyATCommand) != KErrNotFound)

			{

			array.Remove(0);

			}

		TInt count = array.Count();

#ifdef _DEBUG		

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

			{

			LOGTEXT3(_L8("CAtPhbkStoreCache::ParseResponseL\tarray[%d]=%S"),i,&array[i]);  

			}

#endif		

		if((array[1].Match(KLtsyOkString) == KErrNone))

			{

			CleanupStack::PopAndDestroy();

			iError = KErrNone;

			iEndFlag = ETrue;

			return; 

			}

		else if((array[1].Match(KLtsyErrorString) == KErrNone))

			{

			CleanupStack::PopAndDestroy();

			iError = KErrGeneral;

			iEndFlag = ETrue;

			return; 

			}

		iError = KErrNone;

		//remove number line if it has 

		if( array[0].MatchF(KCPBRSResponseString) == KErrNotFound )

			{

			array.Remove(0);

			}

		if( array[0].MatchF(KCPBRSResponseString) == KErrNotFound )

			{

			CleanupStack::PopAndDestroy();

			iError = KErrNotFound;

			return;

			}

		//parse index

		TLex8 lex(array[1]);

		TUint16 val;

		TInt ret = lex.Val(val,EDecimal);

		if(ret != KErrNone)

			{

			CleanupStack::PopAndDestroy();

			iError = ret;

			return;

			}

		//Index  

		iReadEntry.iIndex = val;             

		iReadEntry.iNumber.Copy(array[2]);   

		//Parse TON/NPI

		TLex8 lex1(array[3]);

		TUint16 val1;

		ret = lex1.Val(val1,EDecimal);

		if(ret != KErrNone)

			{

			CleanupStack::PopAndDestroy();

			iError = ret;

			return;

			}

		 //TON/NPI

		iReadEntry.iTon = (TUint8)val1;  

		iReadEntry.iText.Copy(array[4]);

		CleanupStack::PopAndDestroy();

		} 

  	}

// ---------------------------------------------------------------------------

// CAtPhbkStoreCache::GeneratePhbkData

// other items were commented in a header

// ---------------------------------------------------------------------------

TInt CAtPhbkStoreCache::GeneratePhbkDataL()

	{

	CPhoneBookBuffer* pbBuffer = new(ELeave) CPhoneBookBuffer(); // used to write phonebook data

	iPhbkData.Zero();

	 // Set it to point to the Client buffer

	pbBuffer->Set(&iPhbkData);

	pbBuffer->AddNewEntryTag();

	TInt ret = pbBuffer->PutTagAndValue(RMobilePhoneBookStore::ETagPBAdnIndex,iReadEntry.iIndex);

	if( ret!=KErrNone )

		{

		delete pbBuffer;

		return ret;

		}

	ret=pbBuffer->PutTagAndValue(RMobilePhoneBookStore::ETagPBNumber, iReadEntry.iNumber);

	if( ret!=KErrNone )

		{

		delete pbBuffer;

		return ret;

		}

	ret=pbBuffer->PutTagAndValue(RMobilePhoneBookStore::ETagPBTonNpi, iReadEntry.iTon);

	if(ret!=KErrNone)

		{

		delete pbBuffer;

		return ret;

		}

	ret=pbBuffer->PutTagAndValue(RMobilePhoneBookStore::ETagPBText, iReadEntry.iText);

	if(ret != KErrNone)

		{

		delete pbBuffer;

		return ret;

		}

	delete pbBuffer;

	return KErrNone;

	}

//End of file