// 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);

	}

/*

   Destructor

   @internalTechnology

   @test

*/

CTestUPnPManager::~CTestUPnPManager()

	{

	_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);

	//iConnection.Close ();

	//iSocketServ.Close ();

	}

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();

	count = iIconUriArray.Count ();

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

		{

		iIconUriArray[index].Close();

		}

	iIconUriArray.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, traceFileName ;

			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);

				//btracelog

				_LIT(KBtracelogFile, "C:\\logs\\btrace.log");

				_LIT(KBTrace, "btrace.log");				

				traceFileName.Create(KPrefixLog().Length() + iScriptName.Length() + KBTrace().Length() );

	  			traceFileName.Copy(KPrefixLog);

	  			traceFileName.Append(iScriptName);

	  			traceFileName.Append(KBTrace);	  			

	  			error = fMan->Rename(KBtracelogFile, traceFileName);				

	  			if ( error == KErrNone )

		  			{

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

					INFO_PRINTF2(KBtraceInfo, &traceFileName);

		  			}				

				}

			CleanupStack::PopAndDestroy(fMan);

			newFileName.Close();

			traceFileName.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()

	{

	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()

	{

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

	INFO_PRINTF1(KInfoLogFile);

	RArray<TPtrC> sequenceList;

	CleanupClosePushL(sequenceList);

	TPtrC listOfSequences;

	_LIT(KListOfSequences, "listofsequences");

	GetStringFromConfig(ConfigSection(), KListOfSequences, listOfSequences);

	TokenizeStringL(listOfSequences, sequenceList);

	TInt numOperations = sequenceList.Count();

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

		{

		SetCurrentSection(sequenceList[i]);

		PerformDesiredOperationsL(sequenceList[i]);

		}

	CleanupStack::PopAndDestroy(); 

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

	INFO_PRINTF1(KInfoLogFile1);

	}

void TestUtils::LoadESockL ( RSocketServ& aSocketServ, RConnection& aConnection )

	{

	User::LeaveIfError ( aSocketServ.Connect () );

	User::LeaveIfError ( aConnection.Open ( aSocketServ ) );

	TRequestStatus status;

	aConnection.Start ( status );

	User::WaitForRequest ( status );

	User::LeaveIfError ( status.Int () );

	aConnection.CancelAllInterfaceNotification ();

	aConnection.CancelProgressNotification ();

	aConnection.CancelServiceChangeNotification ();

	aConnection.CancelAllSubConnectionNotification ();

	}

/*

   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 TInt KMatch = 0;

	TPtrC operationType;

	_LIT(KOperationType, "operationtype");

	GetStringFromConfig(aOperation, KOperationType, operationType);

	/*if ( iConnection.SubSessionHandle () == 0 )

		{

		TestUtils::LoadESockL ( iSocketServ, iConnection );

		}*/

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

		{

		OpenDiscovererL();

		}

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

		{

		OpenMultiplePublisherL();

		}

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

		{

		DiscoverL(aOperation);

		}

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

		{

		CancelDiscoverL(aOperation);

		}

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

		{

		CancelDescribeL(aOperation);

		}

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

		{

		PublishServiceL(aOperation);

		}

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

		{

		PublishDeviceL(aOperation);

		}

	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(KDescribeIcon) == KMatch)

		{

		DescribeIconL();

		}

	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(const TDesC& aOperationType)

	{

	RArray<TPtrC> serviceTypeList;

	RArray<TPtrC> mxTimeList;

	TPtrC listOfServiceTypes;

	TPtrC listOfMxTimes;

	_LIT(KListOfServiceTypes, "listofservicetypes");

	_LIT(KListOfMxTimes, "listofmxtimes");

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

	INFO_PRINTF1(KInfoLogFile);

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