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


#ifndef __T_CURRENTDB_H__
#define __T_CURRENTDB_H__

// System includes
#include <cntdb.h>
#include <cntitem.h>
#include <cntfield.h>
#include <cntfldst.h>

// Classes referenced
class RTest;
class CConsoleBase;
class CCntTest;
class CTestBase;
class CTestManager;


////////////////////////////////////////////////////////////////////////////////////
// -------> CTestBase (header)
////////////////////////////////////////////////////////////////////////////////////
class CTestBase : public CActive, public MContactDbObserver
	{
////////////////////////////////////////////////////////////////////////////////////
public:							// ENUMERATIONS SHARED BETWEEN DRIVER & TEST
////////////////////////////////////////////////////////////////////////////////////
	enum
		{
		EStartTests = 0,
		ETest1 = EStartTests,
		ETest2,
		ETest3,
		ETest4,
		ETest5,
		ETest6,
		ETest7,
		ETest8,
		ETest9,
		EEndTests
		};
	
////////////////////////////////////////////////////////////////////////////////////
public:							// STATIC CONSTRUCT / DESTRUCT
////////////////////////////////////////////////////////////////////////////////////
	~CTestBase();

////////////////////////////////////////////////////////////////////////////////////
public:							// ACCESS
////////////////////////////////////////////////////////////////////////////////////
	void						Complete(TInt aReason);
	inline TInt					CurrentTest() const				{ return iCurrentTest; }
	inline RThread&				Thread()						{ return iThread; }
	inline TBool				Waiting() const					{ return iWaiting || iWaitingForAnyEvent; }

////////////////////////////////////////////////////////////////////////////////////
protected:						// INTERNAL CONSTRUCTION
////////////////////////////////////////////////////////////////////////////////////
	CTestBase(CTestManager& aTester, TInt aClientNumber, TThreadPriority aThreadPriority, TInt aPriority);
	virtual void				ConstructL(const TDesC& aName);
	//
	static TInt					ThreadFunction(TAny *aParam);
	void						RunTestsL();

////////////////////////////////////////////////////////////////////////////////////
protected:						// TEST FRAMEWORK
////////////////////////////////////////////////////////////////////////////////////
	virtual void				OpenDatabaseL() = 0;
	virtual TInt				HandleThreadCreationL();
	virtual void				HandleThreadDeletionL();

////////////////////////////////////////////////////////////////////////////////////
protected:						// FROM MContactDbObserver
////////////////////////////////////////////////////////////////////////////////////
	void						HandleDatabaseEventL(TContactDbObserverEvent aEvent);

////////////////////////////////////////////////////////////////////////////////////
private:						// FROM CActive
////////////////////////////////////////////////////////////////////////////////////
	void						RunL();
	void						DoCancel();

////////////////////////////////////////////////////////////////////////////////////
protected:						// TEST RELATED
////////////////////////////////////////////////////////////////////////////////////
	void						ReadyForNextTest();
	void						WaitForContactsEvent(TContactDbObserverEventType aEvent, TInt aTimeInSecondsToWaitFor = 30);
	void						WaitForAnyContactsEvent(TInt aTimeInSecondsToWaitFor = 30);

	virtual void				DoTestL(TInt aTestNumber) = 0;
	void 						OpenSemaphoreL();
	void						CloseSemaphore();

////////////////////////////////////////////////////////////////////////////////////
protected:						// MEMBER DATA
////////////////////////////////////////////////////////////////////////////////////
	CTestManager&				iTestCoordinator;

	// Owned by this class after the thread has been created
	CCntTest*					iContactsTest;
	CConsoleBase*				iConsole;
	RTest*						iTest;

	//
	TInt						iCurrentTest;
	TInt						iClientNumber;
	RThread						iThread;
	TThreadPriority				iThreadPriority;
	
	//
	TBool						iWaiting;
	TBool						iWaitingForAnyEvent;
	TContactDbObserverEventType	iEvent;
	TContactDbObserverEvent		iLastEvent;
	RTimer						iWaitTimer;
	RSemaphore					iSemaphoreOne;
	RSemaphore					iSemaphoreTwo;
	};


////////////////////////////////////////////////////////////////////////////////////
// -------> CTestThreadOne (header)
////////////////////////////////////////////////////////////////////////////////////
class CTestThreadOne : public CTestBase
	{
////////////////////////////////////////////////////////////////////////////////////
public:							// FROM CTestBase
////////////////////////////////////////////////////////////////////////////////////
	static CTestThreadOne*		NewL(TInt aClientNumber, const TDesC& aName, CTestManager& aTester, TThreadPriority aThreadPriority = EPriorityNormal, TInt aPriority = EPriorityStandard);
	void						DoTestL(TInt aTestNumber);
	void						OpenDatabaseL();
	
////////////////////////////////////////////////////////////////////////////////////
private:						// INTERNAL
////////////////////////////////////////////////////////////////////////////////////
	CTestThreadOne(CTestManager& aTester, TInt aClientNumber, TThreadPriority aThreadPriority, TInt aPriority);
	//
	void						DoTest1L();
	void						DoTest2L();
	void						DoTest3L();
	void						DoTest4L();
	void						DoTest5L();
	void						DoTest6L();
	void						DoTest7L();
	void						DoTest8L();
	void						DoTest9L();
	};


////////////////////////////////////////////////////////////////////////////////////
// -------> CTestThreadTwo (header)
////////////////////////////////////////////////////////////////////////////////////
class CTestThreadTwo : public CTestBase
	{
////////////////////////////////////////////////////////////////////////////////////
public:							// FROM CTestBase
////////////////////////////////////////////////////////////////////////////////////
	static CTestThreadTwo*		NewL(TInt aClientNumber, const TDesC& aName, CTestManager& aTester, TThreadPriority aThreadPriority, TInt aPriority = EPriorityStandard);
	void						DoTestL(TInt aTestNumber);
	void						OpenDatabaseL();
	
////////////////////////////////////////////////////////////////////////////////////
private:						// INTERNAL
////////////////////////////////////////////////////////////////////////////////////
	CTestThreadTwo(CTestManager& aTester, TInt aClientNumber, TThreadPriority aThreadPriority, TInt aPriority);
	//
	void						DoTest1L();
	void						DoTest2L();
	void						DoTest3L();
	void						DoTest4L();
	void						DoTest5L();
	void						DoTest6L();
	void						DoTest7L();
	void						DoTest8L();
	void						DoTest9L();
	};


////////////////////////////////////////////////////////////////////////////////////
// -------> CTestManager (header)
////////////////////////////////////////////////////////////////////////////////////
class CTestManager : public CTimer
	{
////////////////////////////////////////////////////////////////////////////////////
public:							// STATIC CONSTRUCT
////////////////////////////////////////////////////////////////////////////////////
	static CTestManager*		NewLC();
	static CTestManager*		NewL();
	~CTestManager();

////////////////////////////////////////////////////////////////////////////////////
private:						// INTERNAL CONSTRUCT
////////////////////////////////////////////////////////////////////////////////////
	CTestManager(TInt aPriority = EPriorityStandard);
	void						ConstructL();

////////////////////////////////////////////////////////////////////////////////////
private:						// FROM CActive
////////////////////////////////////////////////////////////////////////////////////
	void						RunL();

////////////////////////////////////////////////////////////////////////////////////
private:						// NEW FUNCTIONS
////////////////////////////////////////////////////////////////////////////////////
	void						IssueTimerRequest();

////////////////////////////////////////////////////////////////////////////////////
private:						// MEMBER DATA
////////////////////////////////////////////////////////////////////////////////////
    TInt						iTestNumber;
	//
	CTestThreadOne*				iClient1;
	CTestThreadTwo*				iClient2;
	};



#endif