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

// Contains implementation of CTestUPnPManager class

// Contains implemenatation of CTestUPnPManager, CUPnPObserver, CUPnPTimer, 

// and CAction classes

// 

//

#include "testupnpmanager.h"

/*

  Constructor:

  @internalTechnology

  @test

*/

CTestUPnPManager::CTestUPnPManager()

:	CTestStep()

	{

	iCancelDiscovery = EFalse;

	iExpectedData = EFalse;

	iDiscoverySuccess = EFalse;

	iNotifyCount = 0;

	iPublishCount = 0;

	iDescribeResponseCount = 0;

	iRenewCount = 0;

	iFailedNumUris = 0;

	}

/*

   Initializes all member vaiables.

   @param		None.

   @return		None.

*/

void CTestUPnPManager::InitializeL()

	{

	iScheduler = new (ELeave) CActiveScheduler;

	CActiveScheduler::Install(iScheduler);

	_LIT(KInfoLogFile, "SequenceOperationsL().... \n");

	INFO_PRINTF1(KInfoLogFile);

	TPtrC listOfSequences;

	_LIT(KListOfSequences, "listofsequences");

	GetStringFromConfig(ConfigSection(), KListOfSequences, listOfSequences);

	TokenizeStringL(listOfSequences, iSequenceList);

	iNumOperations = iSequenceList.Count();

	}

/*

   Destructor

   @internalTechnology

   @test

*/

CTestUPnPManager::~CTestUPnPManager()

	{

	}

void CTestUPnPManager::ClosePublisher()

	{

	_LIT(KInfoLogFile, "ClosePublisher....\n");

	INFO_PRINTF1(KInfoLogFile);

	CancelPublish();

	}

void CTestUPnPManager::CloseDiscoverer()

	{

	iControlPoint.Close();

	}

void CTestUPnPManager::CleanUpObserverArray()

	{

	_LIT(KInfoLogFile, "CleanUpObserverArray....\n");

	INFO_PRINTF1(KInfoLogFile);

	if (iObserverArray.Count() > 0 )

		{

		iObserverArray.ResetAndDestroy();

		}

	else

		{

		iObserverArray.Close();

		}

	_LIT(KInfoLogFile1, "CleanUpObserverArray End....\n");

	INFO_PRINTF1(KInfoLogFile1);

	}

void CTestUPnPManager::CleanUpResultsArray()

	{

	_LIT(KInfoLogFile, "CleanUpResultsArray....\n");

	INFO_PRINTF1(KInfoLogFile);

	TInt count = iResultsArray.Count();

		for (TInt index(0); index < count ; index++ )

			{

			iResultsArray[index]->Close();

			}

	iResultsArray.Close();

	_LIT(KInfoLogFile1, "CleanUpResultsArray End....\n");

	INFO_PRINTF1(KInfoLogFile1);

	}

void CTestUPnPManager::DescriptionSuiteCleanUp()

	{

	_LIT(KInfoLogFile, "DescriptionSuiteCleanUp....\n");

	INFO_PRINTF1(KInfoLogFile);

	TInt count = iDescriptionSuiteArray.Count();

	for (TInt index(0); index < count ; index++ )

		{

		iDescriptionSuiteArray[index].iBaseUrl.Close();

		iDescriptionSuiteArray[index].iDescription.Close();

		DeleteSeriveUrlsList(index);

		}

	iDescriptionSuiteArray.Close();

	_LIT(KInfoLogFile1, "DescriptionSuiteCleanUp End...\n");

	INFO_PRINTF1(KInfoLogFile1);

	}

void CTestUPnPManager::ScpdUriArrayCleanUp()

	{

	_LIT(KInfoLogFile, "ScpdUriArrayCleanUp....\n");

	INFO_PRINTF1(KInfoLogFile);

	TInt count = iScpdUriArray.Count();

	for (TInt index(0); index < count ; index++ )

		{

		iScpdUriArray[index].Close();

		}

	iScpdUriArray.Close();

	_LIT(KInfoLogFile1, "ScpdUriArrayCleanUp End....\n");

	INFO_PRINTF1(KInfoLogFile1);

	}

void CTestUPnPManager::EventUriArrayCleanUp()

	{

	_LIT(KInfoLogFile, "EventUriArrayCleanUp....\n");

	INFO_PRINTF1(KInfoLogFile);

	TInt count = iEventUriArray.Count();

	for (TInt index(0); index < count ; index++ )

		{

		iEventUriArray[index].Close();

		}

	iEventUriArray.Close();

	_LIT(KInfoLogFile1, "EventUriArrayCleanUp End....\n");

	INFO_PRINTF1(KInfoLogFile1);

	}

void CTestUPnPManager::ControlUriArrayCleanUp()

	{

	_LIT(KInfoLogFile, "ControlUriArrayCleanUp....\n");

	INFO_PRINTF1(KInfoLogFile);

	TInt count = iControlUriArray.Count();

	for (TInt index(0); index < count ; index++ )

		{

		iControlUriArray[index].Close();

		}

	iControlUriArray.Close();

	_LIT(KInfoLogFile1, "ControlUriArrayCleanUp End....\n");

	INFO_PRINTF1(KInfoLogFile1);

	}

/*

   Implementation of CTestStep base class virtual and this is used for doing all

   initialisation common

    to derived classes here.

   @param  None

   @return TVerdict

 */

TVerdict CTestUPnPManager::doTestStepPreambleL()

	{

	InitializeL();

	SavePreviousLogFileL();

	return CTestStep::doTestStepPreambleL();

	}

/*

 Save the previous log file...if any

*/

void CTestUPnPManager::SavePreviousLogFileL()

	{

	_LIT(KInfoLogFile, "Saving Previous logs If any.... \n");

	INFO_PRINTF1(KInfoLogFile);

	RFs fileserv;

	TInt error = fileserv.Connect();

	if(!error)

		{

		_LIT(KlogFile, "C:\\logs\\log.txt");

		_LIT(KPrefixLog, "C:\\upnplogs\\");

		_LIT(KSuffix, "_UDEB");

		_LIT(KExtn, ".txt");

		CFileMan* fMan = NULL;

		TRAP_IGNORE(fMan = CFileMan::NewL(fileserv));

		if(fMan != NULL)

			{

			CleanupStack::PushL(fMan);

			RBuf newFileName;

			const TInt KTwentyFour = 24;

			newFileName.Create(ConfigSection().Length() + KTwentyFour );

			newFileName.Copy(KPrefixLog);

			//Script file name

			iScriptName.Copy(ConfigSection());

			newFileName.Append(iScriptName);

			newFileName.Append(KSuffix);

			newFileName.Append(KExtn);

			TInt error = fMan->Rename(KlogFile, newFileName);

			if (error != KErrNone)

				{

				_LIT(KErrInfo, "Unable to Save Previous logs...May be NO Previous logs exist \n");

				ERR_PRINTF1(KErrInfo);

				}

			else

				{

				_LIT(KSavingInfo, "<font color=0000ff><b>Saved Previous logs with File Name: <u>%S</u> </b></font> \n");

				INFO_PRINTF2(KSavingInfo, &newFileName);

				}

			CleanupStack::PopAndDestroy(fMan);

			newFileName.Close();

			}

		}

	fileserv.Close();

	_LIT(KInfoLogFile1, "Saving Previous logs End.... \n");

	INFO_PRINTF1(KInfoLogFile1);

	}

/*

 return Script File name..if any

*/

const TDesC& CTestUPnPManager::ScriptFileName()

	{

	return iScriptName;

	}

/*

   Implementation of CTestStep base class virtual and it is used for doing all

   after test treatment common to derived classes in here.

   @return TVerdict

 */

TVerdict CTestUPnPManager::doTestStepPostambleL()

	{

		_LIT(KInfoDesctructorBegin, "Begin: In Destructor CTestUpnPanager....\n");

	INFO_PRINTF1(KInfoDesctructorBegin);

	if(iStringPoolMgr)

		{

		iStringPoolMgr->Release();

		//this will tkae care of clean up of iStringPool

		}

	_LIT(KInfoDesctructorBegin2, "Releasing String Pool Manager....\n");

	INFO_PRINTF1(KInfoDesctructorBegin2);

	CleanUpObserverArray();

	iDeviceLocationArray.Close();

	CleanUpResultsArray();

	DescriptionSuiteCleanUp();

	ScpdUriArrayCleanUp();

	ControlUriArrayCleanUp();

	EventUriArrayCleanUp();

	CloseDiscoverer();

	//#ifdef _DEBUG

		ClosePublisher();

		CActiveScheduler::Install(NULL); //Testing for ONB hangs

		_LIT(KInfoDesctructorBegin1, "Deleting the Active Schedulers....\n");

		INFO_PRINTF1(KInfoDesctructorBegin1);

		delete iScheduler;

		iScheduler = NULL;	

	//#endif //_Debug

	iPublisherObserverMap.Close();	

	_LIT(KInfoDesctructorEnd, "End: ....In Destructor CTestUpnPanager\n");

	INFO_PRINTF1(KInfoDesctructorEnd);

	return CTestStep::doTestStepPostambleL();

	}

TVerdict CTestUPnPManager::doTestStepL()

	{

	SequenceOperationsL();

	return TestStepResult();

	}

/*

   This function performs operations based on sequence specified in the ini file

   @param  None

   @return None

*/

void CTestUPnPManager::SequenceOperationsL()

	{

	for(TInt i(0); i < iNumOperations; i++)

		{

		SetCurrentSection(iSequenceList[i]);

		TPtrC operationType;

		_LIT(KOperationType, "operationtype");

		GetStringFromConfig(iSequenceList[i], KOperationType, operationType);

		PerformDesiredOperationsL(iSequenceList[i], operationType);

		}

	}

/*

   This function performs desired operations specified as a parameter

   @param  aOperation string representing operation to be performed

   @return None

*/

void CTestUPnPManager::PerformDesiredOperationsL(const TDesC& aOperation, const TDesC& operationType)

	{

	const TInt KMatch = 0;

//	TPtrC operationType;

//	_LIT(KOperationType, "operationtype");

//	GetStringFromConfig(aOperation, KOperationType, operationType);

	if(operationType.Compare(KOpenDiscoverer) == KMatch)

		{

		DoTestOOML(EOpenDiscover);

		}

	else if(operationType.Compare(KDiscovery) == KMatch)

		{

		TPtrC listOfServiceTypes;

		TPtrC listOfMxTimes;

		_LIT(KListOfServiceTypes, "listofservicetypes");

		_LIT(KListOfMxTimes, "listofmxtimes");

		if(!GetStringFromConfig(GetCurrentSection(), KListOfServiceTypes, listOfServiceTypes)

			|| !GetStringFromConfig(GetCurrentSection(), KListOfMxTimes, listOfMxTimes))

			{

			_LIT(KErrInfo, "Problem in reading values from ini. \n Expected fields are: \n%S, \n%S \n");

			ERR_PRINTF3( KErrInfo, &KListOfServiceTypes, &KListOfMxTimes );

			//SetTestStepResult(EFail);

			return;

			}

		TokenizeStringL(listOfServiceTypes, iServiceTypeList);

		TokenizeStringL(listOfMxTimes, iMxTimeList);

		DoTestOOML(EDiscover);

		}

	else if(operationType.Compare(KCancelDiscover) == KMatch)

		{

		CancelDiscoverL(aOperation);

		}

	else if(operationType.Compare(KCancelDescribe) == KMatch)

		{

		CancelDescribeL(aOperation);

		}

	else if(operationType.Compare(KPublishService) == KMatch)

		{

		TPtrC iServiceType;

		GetStringFromConfig(aOperation, KServiceType, iServiceType);

		TPtrC iUsn;

		GetStringFromConfig(aOperation, KUSN, iUsn);

		TInt iDuration;

		GetIntFromConfig(aOperation, KCacheControl, iDuration);

		TPtrC iDescription;

		GetStringFromConfig(aOperation, KDescription, iDescription);

		TPtrC descriptionPath;

		_LIT(KDescriptionPath, "Description_Path");

		GetStringFromConfig(aOperation, KDescriptionPath, iDescriptionPath);

		DoTestOOML(EPublishService);

//		PublishServiceL(aOperation);

		}

	else if(operationType.Compare(KPublishDevice) == KMatch)

		{

		GetStringFromConfig(aOperation, KParentDeviceUid, iParentdeviceuid);

		GetStringFromConfig(aOperation, KDeviceType, iDevicetype);

		GetStringFromConfig(aOperation, KFriendlyName, iFriendlyname);

		GetStringFromConfig(aOperation, KManufacturer, iManufacturer);

		GetStringFromConfig(aOperation, KManufacturerURL, iManufacturerurl);

		GetStringFromConfig(aOperation, KModelDescription, iModeldescription);

		GetStringFromConfig(aOperation, KModelName, iModelname);

		GetStringFromConfig(aOperation, KModelNumber, iModelnumber);

		GetStringFromConfig(aOperation, KModelURL, iModelurl);

		GetStringFromConfig(aOperation, KPresentationURL, iPresentationurl);

		GetStringFromConfig(aOperation, KSerialNumber, iSerialnumber);

		GetStringFromConfig(aOperation, KUDN, iUdn);

		GetStringFromConfig(aOperation, KUPC, iUpc);

		GetIntFromConfig(aOperation, KCacheControl, iDuration);

		DoTestOOML(EPublishDevice);

		}

	else if(operationType.Compare(KDescribe) == 0)

		{

		DescribeL();

		}

	else if(operationType.Compare(KDescribeService) == 0)

		{

		DescribeServiceL();

		}

	else if(operationType.Compare(KSubscribe) == 0)

		{

		SubscribeForStateChangeNotificationsL();

		}

	else if(operationType.Compare(KUnsubscribe) == 0)

		{

		UnsubscribeForStateChangeNotificationsL(aOperation);

		}

	else if(operationType.Compare(KRegisterAnnouncement) == KMatch)

		{

		RegisterForAnnouncementsL(aOperation);

		}

	else if(operationType.Compare(KCancelNotify) == KMatch)

		{

		CancelNotifyAnnouncementL(aOperation);

		}

	else if(operationType.Compare(KInitiateControl) == KMatch)

		{

		InitiateActionL(aOperation);

		}

	else if(operationType.Compare(KStartScheduler) == KMatch)

		{

		CActiveScheduler::Start();

		}

	else if(operationType.Compare(KStopScheduler) == KMatch)

		{

		CActiveScheduler::Stop();

		}

	else if(operationType.Compare(KStartTimer) == KMatch)

		{

		StartTimerL(aOperation);

		}

	else if(operationType.Compare(KPrintResults) == 0)

		{

		PrintAndValidateResultsL(aOperation);

		}

	}

/*

   Parses a comma separated string and constructs a list out of the values

   @param	aString a reference to a string to be tokenized

   @param	aList is an out parameter to store a list of tokens in an arry

   @param	aSeparator is a character used to delimit the tokens

  */

void CTestUPnPManager::TokenizeStringL(const TDesC& aString, RArray<TPtrC>& aList, TChar aSeparator)

	{

	TLex lexer(aString);

	while(!lexer.Eos())

		{

		lexer.SkipSpaceAndMark();

		while(!lexer.Eos() && lexer.Get() != aSeparator)

			{

			}

		if(!lexer.Eos())

			{

			lexer.UnGet();

			}

		aList.AppendL(lexer.MarkedToken());

		lexer.Inc();

		}

	}

/*

   Starts a timer for a wait time and triggers CallBack function as timer expires.

   @param	None

   @return	None

 */

void CTestUPnPManager::StartTimerL(const TDesC& aOperationType)

	{

	_LIT(KInfoLogFile, "StartTimerL.... \n");

	INFO_PRINTF1(KInfoLogFile);

	_LIT(KWaitTime,"waittime");

	TInt waitTime = 0;

	GetIntFromConfig(aOperationType, KWaitTime, waitTime);

//	TTimeIntervalMicroSeconds32 interval(waitTime);

	CUPnPTimer* timer = CUPnPTimer::NewL(this);

	CleanupStack::PushL(timer);

	timer->IssueRequestL(waitTime);

	CActiveScheduler::Start();

	CleanupStack::PopAndDestroy(timer);

	_LIT(KInfoLogFile1, "StartTimerL End.... \n");

	INFO_PRINTF1(KInfoLogFile1);

	}

/*

   Sets the current config section.

   @param	aCurrentSection - a reference string that represent current config section

   @return	None

 */

void CTestUPnPManager::SetCurrentSection(const TDesC& aCurrentSection)

	{

	iCurrentSection = aCurrentSection;

	}

/*

   Retrieve the current config section.

   @param

   @return	Reference to current config section

 */

TDesC& CTestUPnPManager::GetCurrentSection()

	{

	return	iCurrentSection;

	}

/*

	Tests whether discovering services/devices is performing as specified in UPnP specifications.

	@param		aOperationType is reference to a section name in ini file where required parameters

				needs to be referred for this operation.

	@return		None.

 */

void CTestUPnPManager::DiscoverL()

	{

	CUPnPObserver* upnpObserver = CUPnPObserver::NewL(this);

	iObserverArray.AppendL(upnpObserver);

	CPnPParameterBundle* pnpBundle = CPnPParameterBundle::NewL( );

	CleanupClosePushL( *pnpBundle );

	pnpBundle->SetPnPObserver((MPnPObserver*)upnpObserver);

	CUPnPParameterFamily* pnpFamily = CUPnPParameterFamily::NewL ( *pnpBundle , EUPnPDiscoverRequestParamSet );

	TInt numUris = iServiceTypeList.Count();

	iFailedNumUris = iServiceTypeList.Count(); //This should be of Unique Uri's count

	TInt numMxs = iMxTimeList.Count();

	TLex responseTimeObj;

	RBuf8 buf;

	buf.CreateL(KMaxUriSize);

	for(TInt i(0); i < numUris; i++)

		{

		CUPnPDiscoverRequestParamSet* discoverParamSet = CUPnPDiscoverRequestParamSet::NewL(pnpFamily );