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

// Iaptest.cpp

//

#include <biocmtm.h>

#include <bioscmds.h>

#include <bitsids.h>

#include <biouids.h>

#include <bsp.h>

#include "iacp.h"

#include <pop3set.h>

#include <imapset.h>

#include <commsdattypesv1_1.h>

#include <commsdat.h>

using namespace CommsDat;

#include <pop3cmds.h>

#include <iapprefs.h>

#include "iaptest.h"

#include "parsertest.h"

#include "tmsvbioinfo.h"

const TUid KUidMsgTypePop3  = {0x10001029};

CInternetAccessTester::~CInternetAccessTester()

	{

	delete iPop3ClientMtm;

	delete iClientMtmRegistry;

	delete iTimer;

	delete iSelection;

	if(iParsedFieldArray)

		{

		iParsedFieldArray->ResetAndDestroy();

		delete iParsedFieldArray;

		}

	}

CInternetAccessTester* CInternetAccessTester::NewL(CSmsTestUtils& aTestUtils)

	{

	CInternetAccessTester* self = new (ELeave) CInternetAccessTester(aTestUtils);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop();

	return self;

	}

CInternetAccessTester::CInternetAccessTester(CSmsTestUtils& aTestUtils)

: iSmsTest(aTestUtils)

	{

	}

void CInternetAccessTester::StartL(TMsvId aEntryId)

	{

	iEntryId = aEntryId;

	MsvEntry().SetEntryL(aEntryId);

	GetParsedFieldStoreL();

	GetIspAndMailServiceL();

	TestRefreshL();

	TestQuitL();

	}

void CInternetAccessTester::ConstructL()

	{

	iClientMtmRegistry = CClientMtmRegistry::NewL(Session());

	iPop3ClientMtm = (CPop3ClientMtm*) iClientMtmRegistry->NewMtmL(KUidMsgTypePop3);

	CMsvEntry* cEntry = Session().GetEntryL(KMsvGlobalInBoxIndexEntryId);

	iPop3ClientMtm->SetCurrentEntryL(cEntry); // iClientMtm takes ownership on entry

	iTimer = TestUiTimer::NewLC(iSmsTest);

	CleanupStack::Pop();	// iTimer

	}

void CInternetAccessTester::GetParsedFieldStoreL()

	{

	CMsvStore* store = MsvEntry().ReadStoreL();

	CleanupStack::PushL(store);

	// try to get our array of parsed fields

	RMsvReadStream in;

	in.OpenLC( *store, KUidMsvBIODataStream );

	InternalizeL(in);

	CleanupStack::PopAndDestroy(2);

	}

void CInternetAccessTester::InternalizeL(RMsvReadStream& aReadStream)

	{

	if(iParsedFieldArray)

		{

		iParsedFieldArray->ResetAndDestroy();

		delete iParsedFieldArray;

		iParsedFieldArray=NULL;

		}

	iParsedFieldArray = new(ELeave) CArrayPtrSeg<CParsedField>(16);

	CParsedField* parsedField = NULL;

	TInt count = aReadStream.ReadUint8L();

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

		{

		parsedField = new (ELeave) CParsedField();

		TRAPD(err, parsedField->InternalizeL(aReadStream))

		if(err)

			{

			delete parsedField; //deletes the last allocated object, privious ones will be deleted by iParsedFieldArray->ResetAndDestroy()

			User::Leave(err);

			}

		iParsedFieldArray->AppendL(parsedField);

		}

	}

void CInternetAccessTester::GetIspAndMailServiceL()

	{

	HBufC* ispName = NULL;

	HBufC* mailName = NULL;

	TBool mailNameFound = EFalse;

	TBool ispNameFound = EFalse;

	TInt count = iParsedFieldArray->Count();

	for(TInt loop = 0;loop<count && !(ispNameFound && mailNameFound);loop++)

		{

		CParsedField& field = *(*iParsedFieldArray)[loop];

		if(field.FieldName().Compare(KMAIL)==0)

			{

			mailName = field.FieldValue().AllocLC();

			mailNameFound = ETrue;

			}

		else if(field.FieldName().Compare(KINTERNET)==0)

			{

			ispName = field.FieldValue().AllocLC();

			ispNameFound = ETrue;

			}

		}

	if(mailNameFound && ispNameFound)

		{

		GetMailServiceL(*mailName);

		GetIAPL(*ispName);

		}

	else

		User::Leave(KErrNotFound);

	CleanupStack::PopAndDestroy(2);

	}

void CInternetAccessTester::GetMailServiceL(const TDesC& aServiceName)

	{		

	TBool serviceFound = EFalse;

	// Get list of children IDs

	MsvEntry().SetEntryL(KMsvRootIndexEntryId);

	CMsvEntrySelection* msvSelection = MsvEntry().ChildrenWithTypeL(KUidMsvServiceEntry);

	CleanupStack::PushL(msvSelection);

	TMsvEntry entry;

	TInt count = msvSelection->Count(); 

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

		{

		MsvEntry().SetEntryL((*msvSelection)[j]);

		// set context to service entry

		entry = MsvEntry().Entry(); 

		if (entry.iType == KUidMsvServiceEntry)

		    if(entry.iDetails.Compare(aServiceName)==0)

				if((entry.iMtm == KUidMsgTypePOP3 || entry.iMtm == KUidMsgTypeIMAP4) && entry.iDetails.CompareF(aServiceName)==0 )

					{

					iServiceId = entry.Id();

					serviceFound = ETrue;

					break;

					}

		}

	CleanupStack::PopAndDestroy();//msvSelection

	if(serviceFound==EFalse)

		User::Leave(KErrNotFound);

	}

void CInternetAccessTester::GetIAPL(const TDesC& aIspName)

	{

	CMDBSession* iDBSession = CMDBSession::NewL(CMDBSession::LatestVersion());

	CCDIAPRecord *iapRecord = (CCDIAPRecord*)CCDRecordBase::RecordFactoryL(KCDTIdIAPRecord);

	CleanupStack::PushL(iapRecord);

	iapRecord->iRecordName.SetMaxLengthL(aIspName.Length());

	iapRecord->iRecordName = aIspName;

	if(iapRecord->FindL(*iDBSession))

		iIap = iapRecord->iRecordTag.RecordId();	

	else 

		User::Leave(KErrNotFound);

	CleanupStack::PopAndDestroy(iapRecord);

	delete iDBSession;

	iDBSession= NULL;

	}

void CInternetAccessTester::TestRefreshL()

	{

	// try and refresh

	delete iSelection;

	iSelection = NULL;

	iSelection = new(ELeave)CMsvEntrySelection;

	iSelection->AppendL(iServiceId);

	TBuf8<1> dummyParam;

	CMsvOperationWait* wait = CMsvOperationWait::NewLC();

	wait->iStatus = KRequestPending;

	CMsvOperation* operation = iPop3ClientMtm->InvokeAsyncFunctionL( KPOP3MTMConnect, *iSelection, dummyParam, wait->iStatus);

	iTimer->SetOperation(operation);

	iTimer->IssueRequest();

	wait->Start();

	CActiveScheduler::Start();

	TInt error = operation->iStatus.Int();

	iTimer->Cancel();

	CleanupStack::PopAndDestroy();	// wait

	if(error !=KErrNone)

		User::Leave(error);

	}

void CInternetAccessTester::TestQuitL()

	{

	TBuf8<1> dummyParam;

	CMsvOperationWait* wait = CMsvOperationWait::NewLC();

	wait->iStatus = KRequestPending;

	CMsvOperation* operation = iPop3ClientMtm->InvokeAsyncFunctionL( KPOP3MTMDisconnect, *iSelection, dummyParam, wait->iStatus);

	iTimer->SetOperation(operation);

	iTimer->IssueRequest();

	wait->Start();

	CActiveScheduler::Start();

	TInt error = operation->iStatus.Int();

	iTimer->Cancel();

	CleanupStack::PopAndDestroy();	// wait

	if(error !=KErrNone)

		User::Leave(error);

	}