/*

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of the License "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: 

* Performs UPS Database Performance Tests

*

*/

/**

 @file

 @test

*/

#include "tupsdbstep.h"

#include <test/testexecutelog.h>

using namespace UserPromptService;

//

// The rest of the code 

CUpsDbStepPerformance::CUpsDbStepPerformance()

	{

     // Destructor Code

    delete iWaiter;

	delete iScheduler;

	}

CUpsDbStepPerformance::~CUpsDbStepPerformance()

	{

	//Constructor Code

	} 

TVerdict CUpsDbStepPerformance::doTestStepPreambleL()

	{

	TBuf<KUpsDescriptionLength> keyNotFound;

	ReadConfigurationFile(keyNotFound);

	if(keyNotFound.Length())

    	{

    	ERR_PRINTF2(_L("Failed to read '%S' key of configuration"),&keyNotFound);

    	SetTestStepResult(EFail);

    	User::Leave(KErrNotFound);	

    	}

      //Create a database name

     User::LeaveIfError(iFs.Connect());

	 User::LeaveIfError(iFs.CreatePrivatePath(EDriveC));

	 User::LeaveIfError(iFs.PrivatePath(iDbLocation));

	 iPerformanceLog.Copy(iDbLocation);

	 iDbLocation.Append(KDbName);

	 iPerformanceLog.Append(KLogName);

	 //Delete the database if left from previous execution

	iFs.Delete(iDbLocation);

	//Open the log file where the performance results are written in CSV format

	TInt err = iFile.Open(iFs,iPerformanceLog,EFileWrite);

	if(KErrNotFound == err)

		{

		User::LeaveIfError(iFile.Replace(iFs,iPerformanceLog,EFileWrite));

		//Write the column headers to the log file

		PrintHeader();

		}

	else if(KErrNone != err)

		{

		User::Leave(err);

		}

	TInt pos = 0;

	iFile.Seek(ESeekEnd, pos);

	iLog = ETrue;

	//Create and install active scheduler 

	iScheduler = new(ELeave) CActiveScheduler;

	CActiveScheduler::Install(iScheduler);

	iWaiter = new(ELeave)CActiveWaiter(Logger());

     return TestStepResult();

	}

TVerdict CUpsDbStepPerformance::doTestStepL()

	{

    INFO_PRINTF1(_L("Running Step: Measuring Database Performance"));

	//Create a decision database

	CDecisionDbW* decisionDb = CreateDatabaseLC(iDbLocation, iFs);

	//Fill the table with decision records	

	FillTableL(*decisionDb,iRecordNum,iClientNum,iServiceNum,iServerNum,iEvaluatorNum);

	//Get a set of decision records with ClientSid

	TUid clientId = TUid::Uid(iRetrieveNum%iClientNum + iRecordNum);

	CDecisionFilter* filter = CDecisionFilter::NewLC();

	filter->SetClientSid(clientId,EEqual);

	INFO_PRINTF2(_L("Lookup for ClientSid=%d"),clientId.iUid);

	//Get a set of decision records with EvaluatorId

	TUid evaluatorId = TUid::Uid(iRetrieveNum%iEvaluatorNum + 1000000 + iRecordNum);

	filter = CDecisionFilter::NewLC();

	filter->SetEvaluatorId(evaluatorId,EEqual);

	INFO_PRINTF2(_L("Lookup for EvaluatorId=%d"),evaluatorId.iUid);

	//Get a set of decision records with ServiceId

	TUid serviceId = TUid::Uid(iRetrieveNum%iServiceNum + 10000 + iRecordNum);

	filter = CDecisionFilter::NewLC();

	filter->SetServiceId(serviceId,EEqual);

	INFO_PRINTF2(_L("Lookup for ServiceId=%d"),serviceId.iUid);

	//Get a set of decision records with ServerSid

	TUid serverId = TUid::Uid(iRetrieveNum%iServerNum + 100000 + iRecordNum);

	filter = CDecisionFilter::NewLC();

	filter->SetServerSid(serverId,EEqual);

	INFO_PRINTF2(_L("Lookup for ServerSid=%d"),serverId.iUid);

	//Lookup for Fingerprint

	TBuf8<KDbMaxName>bufFP;

	CMD5* md5FP = CMD5::NewL();

	CleanupStack::PushL(md5FP);

	bufFP.AppendFormat(KFingerprint,iRetrieveNum);

	filter = CDecisionFilter::NewLC();

	filter->SetFingerprintL(md5FP->Hash(bufFP),EEqual);

	INFO_PRINTF1(_L("Lookup for a Fingerprint"));

	//Lookup for ClientEntity

	TBuf8<KDbMaxName>bufCE;

	CMD5* md5CE = CMD5::NewL();

	CleanupStack::PushL(md5CE);

	bufCE.AppendFormat(KClientEntity,iRetrieveNum);

	filter = CDecisionFilter::NewLC();

	filter->SetClientEntityL(md5CE->Hash(bufCE),EEqual);

	INFO_PRINTF1(_L("Lookup for a ClientEntity"));

	//Get a single record

	md5FP->Reset();

	md5CE->Reset();

	filter = CDecisionFilter::NewLC(clientId,evaluatorId,serviceId,serverId,md5FP->Hash(bufFP),md5CE->Hash(bufCE),2);

	INFO_PRINTF1(_L("Lookup for a single,unique record"));

	CDecisionRecord *retRecord (0); 

	retRecord = GetDecisionLC(*decisionDb,*filter);

	CleanupStack::PopAndDestroy(retRecord);

	CleanupStack::PopAndDestroy(filter);

	//Delete a set of records with ClientSid

	filter = CDecisionFilter::NewLC();

	filter->SetClientSid(clientId,EEqual);

	INFO_PRINTF2(_L("Delete a set of records where ClientSid=%d"),clientId.iUid);

	RemoveDecisionsL(*decisionDb,*filter);

	CleanupStack::PopAndDestroy(filter);

	//Delete a set of records with ServiceId

	filter = CDecisionFilter::NewLC();

	filter->SetServiceId(serviceId,EEqual);

	INFO_PRINTF2(_L("Delete a set of records where ServiceId=%d"),serviceId.iUid);

	RemoveDecisionsL(*decisionDb,*filter);

	CleanupStack::PopAndDestroy(filter);

	//Delete a set of records with ServerSid

	filter = CDecisionFilter::NewLC();

	filter->SetServerSid(serverId,EEqual);

	INFO_PRINTF2(_L("Delete a set of records where ServerSid=%d"),serverId.iUid);

	RemoveDecisionsL(*decisionDb,*filter);

	CleanupStack::PopAndDestroy(filter);

	//Insert a record

	TBuf<KDbMaxName>bufDes;

	bufDes.AppendFormat(KDescription,iRetrieveNum);

	CDecisionRecord* record = CDecisionRecord::NewLC(clientId,evaluatorId,serviceId,serverId,md5FP->Hash(bufFP),md5CE->Hash(bufCE),bufDes,1,2,0);

	INFO_PRINTF1(_L("Insert a decision record"));

	InsertRecordL(*decisionDb,*record);

	CleanupStack::PopAndDestroy(record);

	//Delete All Records

	INFO_PRINTF1(_L("Delete all decision records"));

	RemoveAllDecisionsL(*decisionDb, iFs);

	CleanupStack::PopAndDestroy(3,decisionDb);//md5FP, MD5CE & decisionDb

	iFile.Write(_L8("\n"));

    return TestStepResult();

    }

TVerdict CUpsDbStepPerformance::doTestStepPostambleL()

	{

	iFile.Close();

	iFs.Close();

      // Override base class virtual function

	return TestStepResult();

	}

void CUpsDbStepPerformance::PrintHeader()

	{

	iFile.Write(_L8("\"Create Database\";"));

	iFile.Write(_L8("\"Lookup with ClientSid\";"));

	iFile.Write(_L8("\"Lookup with EvaluatorId\";"));

	iFile.Write(_L8("\"Lookup with ServiceId\";"));

	iFile.Write(_L8("\"Lookup with ServerSid\";"));

	iFile.Write(_L8("\"Lookup with Fingerprint\";"));

	iFile.Write(_L8("\"Lookup with ClientEntity\";"));

	iFile.Write(_L8("\"Lookup Single Record\";"));

	iFile.Write(_L8("\"Delete with ClientSid\";"));

	iFile.Write(_L8("\"Delete with ServiceId\";"));

	iFile.Write(_L8("\"Delete with ServerSid\";"));

	iFile.Write(_L8("\"Insert A Record\";"));

	iFile.Write(_L8("\"Delete All Records\";"));

	iFile.Write(_L8("\n"));

	}