// Copyright (c) 2006-2009 Nokia Corporation and/or its subsidiary(-ies).

// All rights reserved.

// This component and the accompanying materials are made available

// under the terms of the License "Symbian Foundation License v1.0"

// which accompanies this distribution, and is available

// at the URL "http://www.symbianfoundation.org/legal/sfl-v10.html".

//

// Initial Contributors:

// Nokia Corporation - initial contribution.

//

// Contributors:

//

// Description:

// @file

// This is the framework class implementation for the Test Msg Server.

// 

//

/* User includes */

#include "T_MsgServer.h"

#include "T_MsgSharedDataBase.h"

#include "mobilitytestpropertyvalue.h"

#include "mobilitytestpropertymap.h"

#include "tmobilitytestpropertymapaccess.h"

/* Header files of Test Steps */

#include "T_StartUp.h"

#include "T_ShutDown.h"

#include "T_RecordCurrentTime.h"

/* epoc includes */

#include <miutset.h>

#include <e32const.h>

/**

  Function : CT_MsgServer

  Description : Constructor

  @return : N/A

*/

CT_MsgServer::CT_MsgServer()

:	CTestServer()

,	iSharedDataBase(NULL)

,	iActiveScheduler(NULL)

	{

	//Raise process priority to allow complete event logging.

	RProcess me;

    me.SetPriority(TProcessPriority(450));

    User::SetPriorityControl(EFalse);

	}

/**

  Function : ~CT_MsgServer

  Description : Destructor

  @return : N/A

*/

CT_MsgServer::~CT_MsgServer()

	{

	}

/**

  Function : StartupServerL

  Description : Creates and installs the active scheduler

  				Creates an object of the Shared Data class

  @return : N/A

*/

void CT_MsgServer::StartupServerL()

	{

	/* Creates the active scheduler, shared data */

	if (iActiveScheduler==NULL)

		{

		/* Installs Active Scheduler */

		iActiveScheduler=new(ELeave) CActiveScheduler;

		CActiveScheduler::Install(iActiveScheduler);

		}

	if (iSharedDataBase==NULL)

		{

		/* Creates the shared data in the re-used thread.*/

		iSharedDataBase = NewSharedDataL();

		}

#ifdef __MOBILITY_TEST_FRAMEWORK

	if (iPropertyWatcher==NULL)

		{

		iPropertyWatcher = CMsgTestPropertyWatcher::NewL(KPropertyCatMsgTestUtilityServer2, EMyPropertyCounter, *this);

		}

#endif //__MOBILITY_TEST_FRAMEWORK

	}

/**

  Function : ShutdownServer

  Description : Deletes the active scheduler and the created shared data object

  @return : N/A

*/

void CT_MsgServer::ShutdownServer()

	{

	if (NULL!=iSharedDataBase)

		{

		delete iSharedDataBase;

		iSharedDataBase=NULL;

		}

	if (NULL!=iActiveScheduler)

		{

		delete iActiveScheduler;

		iActiveScheduler = NULL;			

		}

	if (NULL!=iPropertyWatcher)

		{

		delete iPropertyWatcher;

		iPropertyWatcher = NULL;			

		}

	}

/**

  Function : CreateTestStep

  Description : This method is run in a seperate thread which is re-used 

  				when the -SharedData flag is set.

  @return : A pointer to the CTestStep class

*/

CTestStep* CT_MsgServer::CreateTestStep(const TDesC& aStepName)

	{

	CTestStep* testStep = NULL;

	TRAPD(err,testStep = CreateTestStepL(aStepName));

	if(err)

		{

		ERR_PRINTF1(_L("CT_MsgServer::CreateTestStep() left!"));

		}

	return testStep;

	}

/**

  Function : CreateTestStepL

  Description : This method creates the startup and shut down test steps

  @return : A pointer to the CTestStep class

*/

CTestStep* CT_MsgServer::CreateTestStepL(const TDesC& aStepName)

	{

	CTestStep*	testStep = NULL;

	/* This must be called as the first test step */

	if(aStepName == KStartUp)					

		{

		StartupServerL();

		testStep = new(ELeave) CT_MsgStartUp();

		}

	/* This must be called as the last test step */

	else if(aStepName == KShutDown)				

		{

		ShutdownServer();

		testStep = new(ELeave) CT_MsgShutDown();

		}

	else if(aStepName == KRecordCurrentTime)

		{

		testStep = new(ELeave) CT_MsgRecordCurrentTime();	

		}

	else

		{

		ERR_PRINTF1(_L("CT_MsgServer::CreateTestStep() - Step not found"));	

		}

	return testStep;

	}

#ifdef __MOBILITY_TEST_FRAMEWORK

void CT_MsgServer::HandleEventL(RProperty& aProperty, TUint /*aKey*/)

#else //__MOBILITY_TEST_FRAMEWORK

void CT_MsgServer::HandleEventL(RProperty& /*aProperty*/, TUint /*aKey*/)

#endif //__MOBILITY_TEST_FRAMEWORK

	{

#ifdef __MOBILITY_TEST_FRAMEWORK

	TInt propertyVal = 0;

	User::LeaveIfError(aProperty.Get(propertyVal));

	const TDesC& name = Name(); //Server name.

	const TMsgTestPropertyMapEntry* propertyMap = TMobilityTestPropertyMapAccess::Get(propertyVal);

	if(propertyMap == NULL)

		{

		ERR_PRINTF1(_L("CT_MsgServer::HandleEventL() - Event not found"));

		}

	else

		{

		TBufC8<80> buf8((const unsigned char*)(propertyMap->name));

		TBuf<80> buf;

		buf.Copy(buf8);

		INFO_PRINTF4(_L("%S EVENT [%d %S]"), &name, propertyVal, &buf);

		}

#endif //__MOBILITY_TEST_FRAMEWORK

	}