// Copyright (c) 2005-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 <e32test.h>

#include "cntdb.h" 

#include "T_CProgressNotification.h"

/* 

3 steps to create test

======================

1	Derive from MContactUiCompactObserver

2	Get an instance fo the activebase class via - CContactActiveCompress* CContactDatabase::CreateCompressorLC()

3	Call CContactActiveCompress::SetObserver to recieve notifications

*/	

_LIT(KTestDbName, "c:T_CProgressNotification.cdb");

void CProgressNotificationTest::AddContactsL(TInt aNoOfCnts)

	{

	TInt max = KMaxArraySize < aNoOfCnts ? KMaxArraySize : aNoOfCnts;

	// Add contacts

	CContactItem* cntItem = NULL;

	for (TInt ii = 0; ii < max; ++ii)

		{

		cntItem = iCntItemBldr->GetCntItemLC();

		iIDarray[ii] = iCntDb->AddNewContactL(*cntItem);

		CleanupStack::PopAndDestroy(cntItem);

		}

	}

void CProgressNotificationTest::DeleteContactsL(TInt aNoOfCnts)

	{

	TInt max = KMaxArraySize < aNoOfCnts ? KMaxArraySize : aNoOfCnts;

	//Remove the contacts

	for (TInt ii = 0; ii < max; ++ii)

		{

		iCntDb->DeleteContactL(iIDarray[ii]);

		iIDarray[ii] = 0;

		}

	}

void CProgressNotificationTest::HandleError(TInt aError)

	{

	iTest->Printf(_L(" - Received Compress Recover ERROR code:  %d \r\n"), aError);

	(*iTest)(EFalse); //Panic here

	}

void CProgressNotificationTest::Step(TInt aStep)

	{

	iTest->Printf(_L(" - Recieved Compress/Recover Event - Step: %d \r\n"), aStep);

	iSteps = aStep;

	if(aStep > 0 && iActiveCompress != NULL) 

		{

		if(!(iActiveCompress->StepsTogo() > 0 ))

			{

			iTest->Printf(_L(" ---- *****ERROR**** Compress Test Error - StepsTogo should be greater than zero \r\n"));

			(*iTest)(EFalse); //Panic here

			}

		}

	}

void CProgressNotificationTest::RunCompressNotifyTestL()

	{

  	iTest->Start(_L("Compress Test"));

	if (iActiveCompress)

		delete iActiveCompress;

	iActiveCompress = iCntDb->CreateCompressorLC();

	CleanupStack::Pop(iActiveCompress);

	// check if first step is greater than 0; CreateCompressorLC should have started the compression

	if(!(iActiveCompress->StepsTogo() > 0 ))

		{

		iTest->Printf(_L(" ---- *****ERROR**** Compress Test Error - StepsTogo should be greater than zero \r\n"));

		(*iTest)(EFalse); //Panic here

		}

	iActiveCompress->SetObserver(static_cast<MContactUiCompactObserver*>(this));

	while(iActiveCompress->Step()) {};

	iTest->End(); //If we are here test completed with success

	}

void CProgressNotificationTest::RunCompressNotifyCancelTestL()	

	{

  	iTest->Start(_L("Compress CANCEL Test"));

	if (iActiveCompress)

		delete iActiveCompress;

	iActiveCompress = iCntDb->CreateCompressorLC();

	CleanupStack::Pop(iActiveCompress);

	iActiveCompress->SetObserver(static_cast<MContactUiCompactObserver*>(this));

	iActiveCompress->Step();

	TInt halfSteps = iSteps/2;

	while (iSteps > halfSteps)

		{

		iActiveCompress->Step();

		}

	delete iActiveCompress;

	iActiveCompress = NULL;

	iTest->End(); //If we are here test completed with success

	}

void CProgressNotificationTest::RunRecoverNotifyCancelTestL()

	{

	iTest->Start(_L("Recover CANCEL Test"));

	iCntDb->DamageDatabaseL(0x666);

	if (iCntDb->IsDamaged() == EFalse)

		{

		iTest->Printf(_L(" ---- DATABASE IS NOT DAMAGED For Test ---- \r\n"));	

#ifndef __SYMBIAN_CNTMODEL_USE_SQLITE__		

		(*iTest)(EFalse); //Panic here

#else

		return;  // test has no meaning with SQLite

#endif		

		}

	if (iActiveRecover)

		delete iActiveRecover;

	iActiveRecover = iCntDb->CreateRecoverLC();

	CleanupStack::Pop(iActiveRecover);

	iActiveRecover->SetObserver(static_cast<MContactUiCompactObserver*>(this));

	//do only one step

	iActiveRecover->Step();

	if (iCntDb->IsDamaged() == EFalse)

		{

		iTest->Printf(_L(" ---- DATABASE IS NOT DAMAGED For Test ---- \r\n"));	

		(*iTest)(EFalse); //Panic here

		}

	TRAPD(err, AddContactsL(1));

	if(err == KErrNone)

		{

		iTest->Printf(_L(" ---- *****ERROR**** recover cancellation does not works ---- \r\n"));	

		(*iTest)(EFalse); //Panic here

		}

	//recover stop in destructor

	delete iActiveRecover;

	iActiveRecover = NULL;	

	iCntDb->RecoverL();

	iTest->End(); //If we are here test completed with success

	}

void CProgressNotificationTest::RunRecoverNotifyTestL()

	{

	iTest->Start(_L("Recover Test"));

	iCntDb->DamageDatabaseL(0x666);

	if (iCntDb->IsDamaged())

		{

		iTest->Printf(_L(" ---- DATABASE IS DAMAGED ---- \r\n"));	

		}

  	if (iActiveRecover)

		delete iActiveRecover;

	iActiveRecover = iCntDb->CreateRecoverLC();

	CleanupStack::Pop(iActiveRecover);

	iActiveRecover->SetObserver(static_cast<MContactUiCompactObserver*>(this));

	while(iActiveRecover->Step()) {};	

	if (iCntDb->IsDamaged())

		{

		iTest->Printf(_L(" ----*****ERROR**** DATABASE IS STILL DAMAGED ---- \r\n"));	

		(*iTest)(EFalse); //Panic here

		}

	iTest->End(); //If we are here test completed with success

	}

CProgressNotificationTest* CProgressNotificationTest::NewLC()

	{

	CProgressNotificationTest* self = new (ELeave) CProgressNotificationTest();

	CleanupStack::PushL(self);

	self->ConstructL();

	return self;		

	}

CProgressNotificationTest::CProgressNotificationTest()

	{}

void CProgressNotificationTest::ConstructL()

	{

	// For multi-threaded test harness.

	iTest = new(ELeave) RTest(_L(""));

	iCntDb = CContactDatabase::ReplaceL(KTestDbName); // Default Database.

	const CContactTemplate& sysTempl(GetSysTemplateL() );

	iCntItemBldr = CCntItemBuilder::NewLC(sysTempl);

	CleanupStack::Pop(iCntItemBldr);

	}

CProgressNotificationTest::~CProgressNotificationTest()

	{

	iTest->Close();

	delete iTest;

	delete iCntDb;

	delete iGoldenTemplate;

	delete iCntItemBldr;

	delete iActiveCompress;

	delete iActiveRecover;

	TRAP_IGNORE(CContactDatabase::DeleteDatabaseL(KTestDbName));

	}

const CContactTemplate& CProgressNotificationTest::GetSysTemplateL()

	{

	if (!iGoldenTemplate)

		{

		CContactItemViewDef* matchAll = CContactItemViewDef::NewLC(CContactItemViewDef::EIncludeFields,CContactItemViewDef::EIncludeHiddenFields);

		matchAll->AddL(KUidContactFieldMatchAll);

		iGoldenTemplate = static_cast<CContactTemplate*>(iCntDb->ReadContactL(iCntDb->TemplateId(), *matchAll));

		CleanupStack::PopAndDestroy(matchAll);

		}

	return *iGoldenTemplate;

	}