// 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 <cntdb.h>
#include "NbCntTestLib.h"
#include "T_CAsyncTest.h"


enum Tests
	{
	EOpenAndCancelPart1,
	EOpenAndCancelPart2,
	EOpenAndCancel,
	EOpenUnnamed,
	ETestOpenUnnamed,
	EOpenNamed,
	ETestOpenNamed
	};

namespace nsAsyncTest
	{
	_LIT(KFile,"C:CONTACTS.CDB");
	}



//===========================================================
// CAsyncTest Class
//===========================================================


CAsyncTest* CAsyncTest::NewLC()
	{
	CAsyncTest* self = new (ELeave) CAsyncTest();
	CleanupStack::PushL(self);
	self->ConstructL();
	return self;
	}


CAsyncTest::~CAsyncTest()
	{
	delete iOpenOp;
	iTest->End();
	iTest->Close();
	delete iTest;		
	}
	
	
CAsyncTest::CAsyncTest():CActive(EPriorityIdle), iTestNo(0)
	{
	CActiveScheduler::Add(this);
	}

void CAsyncTest::ConstructL()
	{	
	TPtrC name(RThread().Name());
	iTest = new(ELeave) RTest(name);	
	iTest->Start(_L("T_CAsyncTest"));
	CreateNamedDbL();
	TRequestStatus *pS = &iStatus;
	User::RequestComplete(pS, KErrNone);
	SetActive();
	CActiveScheduler::Start();
	}


void CAsyncTest::CreateNamedDbL()
	{
	CContactDatabase* db = NULL;
	TRAPD(err, db = CContactDatabase::OpenL(nsAsyncTest::KFile));
	if (err == KErrNotFound)
		{
		TRAPD(err, db = CContactDatabase::ReplaceL(nsAsyncTest::KFile));
		if (err == KErrInUse)
			{
			User::After(1000);
			CreateNamedDbL();	
			}
		else
			{
			User::LeaveIfError(err);
			}
		}
		
	delete db;
	db = NULL;
	}

void CAsyncTest::DoCancel()
	{
	}

TInt CAsyncTest::RunError(TInt aError)
	{
	return aError;
	}
	

void CAsyncTest::RunL()
	{
	switch (iTestNo)
		{
		case EOpenAndCancelPart1:
			OpenUnnamedDatabaseTestL();
			User::After(100000); // Give other threads a chance to run during concurrent tests
			SetActive();
			++iTestNo;
			break;
		case EOpenAndCancelPart2:// Allow the database to open before cancelling
			CancelDatabaseTestL();
			NextTest();
			++iTestNo;
			break;
		case EOpenAndCancel:
			OpenAndCancelDatabaseTestL();
			SetActive();
			++iTestNo;
			break;
		case EOpenUnnamed:
			OpenUnnamedDatabaseTestL();
			SetActive();
			++iTestNo;
			break;
		case ETestOpenUnnamed:
			User::LeaveIfError(iStatus.Int());
			TestResultL();
			NextTest();
			++iTestNo;			
			break;			
		case EOpenNamed:
			User::LeaveIfError(iStatus.Int());
			OpenNamedDatabaseTestL();
			User::After(1000);
			SetActive();
			++iTestNo;			
			break;
		case ETestOpenNamed:
			{
			TestResultL();
			RThread thread;
			if(thread.RequestCount()!=0)
				User::Leave(KErrBadHandle);
			CActiveScheduler::Stop();
			iTest->Next(_L("Test Completed OK\n"));
			break;
			}
		default:
			ASSERT(EFalse);
			break;
		}
	}



void CAsyncTest::TestResultL()
	{
	CContactDatabase* db = iOpenOp->TakeDatabase();
	if(db == NULL)
		User::Leave(KErrNotFound);
	

	// Test adding a contact
	CContactItemViewDef* matchAll = CContactItemViewDef::NewLC(CContactItemViewDef::EIncludeFields,CContactItemViewDef::EIncludeHiddenFields);
	matchAll->AddL(KUidContactFieldMatchAll);
	CContactItem* cntTemplate = db->ReadContactL(0, *matchAll);
	CleanupStack::PopAndDestroy(matchAll);
	CleanupStack::PushL(cntTemplate);

	CCntItemBuilder* cntItemBldr = CCntItemBuilder::NewLC(static_cast<CContactTemplate&>(*cntTemplate));
	CContactItem* tempCntItem = cntItemBldr->GetCntItemLC();
	db->AddNewContactL(*tempCntItem);

	CleanupStack::PopAndDestroy(tempCntItem);
	CleanupStack::PopAndDestroy(cntItemBldr);
	CleanupStack::PopAndDestroy(cntTemplate);
	delete iOpenOp;
	delete db;
	iOpenOp = NULL;
	db 		= NULL;
	
	iTest->Next(_L("Read data from Database\n"));
	
	}

void CAsyncTest::NextTest()
	{
	TRequestStatus* status = &iStatus;
	User::RequestComplete(status, KErrNone);
	SetActive();
	}


void CAsyncTest::OpenUnnamedDatabaseTestL()
	{
   	iTest->Next(_L("Open Unnamed Database\n"));
	iOpenOp = CContactDatabase::Open(iStatus, CContactDatabase::ESingleThread);
	}


void CAsyncTest::CancelDatabaseTestL()
	{
	iTest->Next(_L("Cancel Open Database\n"));
	delete iOpenOp;
	iOpenOp = NULL;
	}

void CAsyncTest::OpenAndCancelDatabaseTestL()
	{
	iTest->Next(_L("Open And Cancel Database\n"));
	iOpenOp = CContactDatabase::Open(iStatus, CContactDatabase::ESingleThread);
	delete iOpenOp;
	iOpenOp = NULL;
	}

void CAsyncTest::OpenNamedDatabaseTestL()
	{
   	iTest->Next(_L("Open Named Database\n"));
	iOpenOp = CContactDatabase::Open(nsAsyncTest::KFile, iStatus, CContactDatabase::ESingleThread);
	}