/*

* Copyright (c) 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 <lbs.h>

#include <lbsposition.h>

#include "ctlbssimulationpsypostp400.h"

#include "simulationpsyinternalcrkeys.h"

//Number of tests in this file, increment when a new test is added

const TInt KNrOfTests = 6;

const TInt K30seconds = 30000000;

const TInt K10seconds = 10000000;

const TInt K5seconds = 5000000;

const TInt K0seconds = 0;

// Value for Common Data Set to enable Time Relative Playback

const TInt KTrpModeEnable= 1;

_LIT(KName0, "TP400-0 - TrpMultiClientNmeaStoredFixExist");

_LIT(KName1, "TP400-1 - TrpMultiClientNmeaStoredFixNotExist");

_LIT(KName2, "TP400-2 - TrpMultiClientNmeaNoUpdateAge");

_LIT(KName3, "TP400-3 - TrpMultiClientSpsStoredFixExist");

_LIT(KName4, "TP400-4 - TrpMultiClientSpsStoredFixNotExist");

_LIT(KName5, "TP400-5 - TrpMultiClientSpsNoUpdateAge");

CT_LbsSimulationPsyPosTp400::CT_LbsSimulationPsyPosTp400(CT_LbsServer& aParent,

		TInt aIndex) :

	CT_LbsPortedStepBase(aParent)

	{

	SetTestStepName(GetIndexName(aIndex));

	iIndex = aIndex;

	}

void CT_LbsSimulationPsyPosTp400::StartL()

	{

	// Setup test environment

	iNrOfRequests = 0;

	ConnectL();

	SetupPsyL(iUidSimulationPsy);

	RunTestsL(iIndex);

	}

TVerdict CT_LbsSimulationPsyPosTp400::doTestStepPostambleL()

	{

	SetTrpModeL(iOldTrpMode);

	return CT_LbsPortedStepBase::doTestStepPostambleL();

	}

void CT_LbsSimulationPsyPosTp400::CloseTest()

	{

	Disconnect();

	}

/*

 * Gets the name of an individual test index

 * @param aIndex Indicates which test index name that is asked for.

 */

TPtrC CT_LbsSimulationPsyPosTp400::GetIndexName(TInt aIndex) const

	{

	if (aIndex > KNrOfTests)

		{

		User::Panic(_L("Wrong Test Argument Index"), KErrGeneral);

		}

	const TDesC* names[KNrOfTests] =

		{

		&KName0, &KName1, &KName2, &KName3, &KName4, &KName5

		};

	return *names[aIndex];

	}

/*

 * Contains calls to tests itself. 

 * @param aIndex test number

 */

void CT_LbsSimulationPsyPosTp400::RunTestsL(TInt aIndex)

	{

	_LIT(KStart0, "Testing TrpMultiClientNmeaStoredFixExist() PSY ");

	_LIT(KStart1, "Testing TrpMultiClientNmeaStoredFixNotExist() PSY ");

	_LIT(KStart2, "Testing TrpMultiClientNmeaNoUpdateAge() PSY ");

	_LIT(KStart3, "Testing TrpMultiClientSpsStoredFixExist() PSY ");

	_LIT(KStart4, "Testing TrpMultiClientSpsStoredFixNotExist() PSY ");

	_LIT(KStart5, "Testing TrpMultiClientSpsNoUpdateAge() PSY ");

	_LIT(KEnd0, "TrpMultiClientNmeaStoredFixExist() passed");

	_LIT(KEnd1, "TrpMultiClientNmeaStoredFixNotExist() passed");

	_LIT(KEnd2, "TrpMultiClientNmeaNoUpdateAge() passed");

	_LIT(KEnd3, "TrpMultiClientSpsStoredFixExist() passed");

	_LIT(KEnd4, "TrpMultiClientSpsStoredFixNotExist() passed");

	_LIT(KEnd5, "TrpMultiClientSpsNoUpdateAge() passed");

	switch (aIndex)

		{

		case 0:

			INFO_PRINTF1(KStart0);

			TestTrpMultiClientNmeaStoredFixExistL();

			INFO_PRINTF1(KEnd0);

			break;

		case 1:

			INFO_PRINTF1(KStart1);

			TestTrpMultiClientNmeaStoredFixNotExistL();

			INFO_PRINTF1(KEnd1);

			break;

		case 2:

			INFO_PRINTF1(KStart2);

			TestTrpMultiClientNmeaNoUpdateAgeL();

			INFO_PRINTF1(KEnd2);

			break;

		case 3:

			INFO_PRINTF1(KStart3);

			TestTrpMultiClientSpsStoredFixExistL();

			INFO_PRINTF1(KEnd3);

			break;

		case 4:

			INFO_PRINTF1(KStart4);

			TestTrpMultiClientSpsStoredFixNotExistL();

			INFO_PRINTF1(KEnd4);

			break;

		case 5:

			INFO_PRINTF1(KStart5);

			TestTrpMultiClientSpsNoUpdateAgeL();

			INFO_PRINTF1(KEnd5);

			break;

		default:

			User::Leave(KErrArgument);

		}

	}

void CT_LbsSimulationPsyPosTp400::TestTrpMultiClientNmeaStoredFixExistL()

	{

	_LIT(KTrpMultiClientRequestError, "Error, the fixes are different.");

	if (!TwoClientRequestL(EFalse, K0seconds, K30seconds))

		{

		LogErrorAndLeaveL(KTrpMultiClientRequestError);

		}

	INFO_PRINTF1(_L("The fixes are identical."));

	}

void CT_LbsSimulationPsyPosTp400::TestTrpMultiClientNmeaStoredFixNotExistL()

	{

	_LIT(KTrpMultiClientRequestError, "Error, The fixes are identical.");

	if (TwoClientRequestL(EFalse, K10seconds, K5seconds))

		{

		LogErrorAndLeaveL(KTrpMultiClientRequestError);

		}

	INFO_PRINTF1(_L("The fixes are different."));

	}

void CT_LbsSimulationPsyPosTp400::TestTrpMultiClientNmeaNoUpdateAgeL()

	{

	_LIT(KTrpMultiClientRequestError, "Error, The fixes are identical.");

	if (TwoClientRequestL(EFalse, K0seconds, K0seconds))

		{

		LogErrorAndLeaveL(KTrpMultiClientRequestError);

		}

	INFO_PRINTF1(_L("The fixes are different."));

	}

void CT_LbsSimulationPsyPosTp400::TestTrpMultiClientSpsStoredFixExistL()

	{

	_LIT(KTrpMultiClientRequestError, "Error, the fixes are different.");

	if (!TwoClientRequestL(ETrue, K0seconds, K30seconds))

		{

		LogErrorAndLeaveL(KTrpMultiClientRequestError);

		}

	INFO_PRINTF1(_L("The fixes are identical."));

	}

void CT_LbsSimulationPsyPosTp400::TestTrpMultiClientSpsStoredFixNotExistL()

	{

	_LIT(KTrpMultiClientRequestError, "Error, The fixes are identical.");

	_LIT(KTrpMultiClientDirectionError, "Error, the position differences do not correspond to direction of movement.");

	TReal latitudeDifference;

	TReal longitudeDifference;

	if (TwoClientRequestL(ETrue, K10seconds, K5seconds, &latitudeDifference,

			&longitudeDifference))

		{

		LogErrorAndLeaveL(KTrpMultiClientRequestError);

		}

	//The latitude and longitude difference should be not as bellow 

	//to correspond movement direction specified in SPS file.

	if (latitudeDifference >= 0 || longitudeDifference <= 0)

		{

		LogErrorAndLeaveL(KTrpMultiClientDirectionError);

		}

	INFO_PRINTF3(_L("The fixes are different and Client 2 is further than Client 1.: %d, %d"), longitudeDifference, latitudeDifference);

	}

void CT_LbsSimulationPsyPosTp400::TestTrpMultiClientSpsNoUpdateAgeL()

	{

	_LIT(KTrpMultiClientRequestError, "Error, The fixes are identical.");

	_LIT(KTrpMultiClientDirectionError, "Error, the position differences doesn't correspond direction of movement.");

	TReal latitudeDifference;

	TReal longitudeDifference;

	if (TwoClientRequestL(ETrue, K0seconds, K0seconds, &latitudeDifference,

			&longitudeDifference))

		{

		LogErrorAndLeaveL(KTrpMultiClientRequestError);

		}

	//The latitude and longitude difference should be positive 

	//to correspond movement direction specified in SPS file.

	if (latitudeDifference >= 0 || longitudeDifference <= 0)

		{

		LogErrorAndLeaveL(KTrpMultiClientDirectionError);

		}

	INFO_PRINTF3(_L("The fixes are different and Client 2 is further than Client 1.: %d/%d"), longitudeDifference, latitudeDifference);

	}

/*

 * Make two client sessions. First client request position and waits for time of aDelay. 

 * Next set Max Update Age of second client and issue position request of second client. 

 * If aLatitudeDiff and aLongitudeDiff parameters are set method will use them to

 * return calculated difference of client positions.

 * @param aIsSps set to ETrue if function should use SPS simulation mode, EFalse for NMEA simulation mode.

 * @param aSecondClientDelay is delay in milliseconds of second positioner request.

 * @param aMaxUpdateAge value in milliseconds that will be set to Max Update Age option of second positioner.

 * @param aLatitudeDiff this parameter will store difference of latitude between clients position.

 * @param aLongitudeDiff this parameter will store difference of longitude between clients position.

 * @return ETrue if clients positions are equal. Otherwise EFalse.

 */

TBool CT_LbsSimulationPsyPosTp400::TwoClientRequestL(TBool aIsSps,

		TInt aSecondClientDelay, TInt aMaxUpdateAge, TReal* aLatitudeDiff,

		TReal* aLongitudeDiff)

	{

	_LIT(KErrorRequestingPosition, "Position Request Error.");

	_LIT(KGetUpdateOptionsErr, "Error %d when getting update options.");

	_LIT(KSetUpdateOptionsErr, "Error %d when setting Max Update Age option.");

#ifdef __WINS__

	_LIT(KTrpNmeaFile, "z:\\system\\test\\testdata\\trpnmeadatafile.nme");

	_LIT(KTrpSpsFile, "z:\\system\\test\\testdata\\trpspsdatafile.sps");

#else

	_LIT(KTrpNmeaFile, "c:\\system\\test\\testdata\\trpnmeadatafile.nme");

	_LIT(KTrpSpsFile, "c:\\system\\test\\testdata\\trpspsdatafile.sps");

#endif

	iOldTrpMode = TrpModeL();

	SetTrpModeL(KTrpModeEnable);

	//Creating client subsessions to position server.

	RPositioner positioner1;

	RPositioner positioner2;

	if (aIsSps)

		{

		OpenNewSourceFileLC(KTrpSpsFile, positioner1);

		OpenNewSourceFileLC(KTrpSpsFile, positioner2);

		}

	else

		{

		OpenNewSourceFileLC(KTrpNmeaFile, positioner1);

		OpenNewSourceFileLC(KTrpNmeaFile, positioner2);

		}

	//Seting Max Update Age option for second Positioner.

	TPositionUpdateOptions posOption;

	TInt err = positioner2.GetUpdateOptions(posOption);

	AssertTrueL(err == KErrNone, KGetUpdateOptionsErr, err);

	posOption.SetMaxUpdateAge(aMaxUpdateAge);

	err = positioner2.SetUpdateOptions(posOption);

	AssertTrueL(err == KErrNone, KSetUpdateOptionsErr, err);

	TPositionInfo fix1;

	TPositionInfo fix2;

	//Position request of First client.

	err = PerformSyncRequest(fix1, positioner1);

	AssertTrueL(err == KErrNone, KErrorRequestingPosition, err);

	//Delay of second positioner.

	User::After(aSecondClientDelay);

	//Position request of Second client.

	err = PerformSyncRequest(fix2, positioner2);

	AssertTrueL(err == KErrNone, KErrorRequestingPosition, err);

	//Getting fixed positions.

	TPosition pos1;

	fix1.GetPosition(pos1);

	TPosition pos2;

	fix2.GetPosition(pos2);

	//Closing positioners

	CleanupStack::PopAndDestroy(&positioner2);

	CleanupStack::PopAndDestroy(&positioner1);

	//Seting longitude and latitude difference.

	if (aLatitudeDiff != NULL)

		{

		*aLatitudeDiff = pos2.Latitude() - pos1.Latitude();

		}

	if (aLongitudeDiff != NULL)

		{

		*aLongitudeDiff = pos2.Longitude() - pos1.Longitude();

		}

	return pos1.Latitude() == pos2.Latitude() && pos1.Longitude() == pos2.Longitude();

	}

/*

 * Set new source file in central repository and open new RPositioner session.

 * Opened session will be left on cleanup stack. 

 * @param aName Name of file to set in central repository.

 * @param aPositioner reference to constructed but unopened RPositioner that will use data from this particular file.

 * 		This parameter will opened and the session will be left on cleanup stack.	

 */

void CT_LbsSimulationPsyPosTp400::OpenNewSourceFileLC(const TDesC& aName,

		RPositioner& aPositioner)

	{

	_LIT(KOpenPositionerErr, "Error when opening positioner,  %d");

	_LIT(KSettingRequestorErr, "Error when setting requester,  %d");

	TInt err = KErrNone;

	SetSimDataFileL(aName);

	err = aPositioner.Open(iPosServer, iUidSimulationPsy);

	AssertTrueL(err == KErrNone, KOpenPositionerErr, err);

	CleanupClosePushL(aPositioner);

	_LIT(KService, "service");

	err = aPositioner.SetRequestor(CRequestor::ERequestorService,

			CRequestor::EFormatApplication, KService);

	AssertTrueL(err == KErrNone, KSettingRequestorErr, err);

	}

/*

 * @return value of Common Data Set in Central Repository.

 */

TInt CT_LbsSimulationPsyPosTp400::TrpModeL() const

	{

	// Get the Common Data Set setting from Central Repository

	CRepository* repository = CRepository::NewLC(KCRUidSimulationPSY);

	TInt commonDataSet = 0;

	User::LeaveIfError(repository->Get(KCRKeySimPSYCommonDataSet, commonDataSet));

	CleanupStack::PopAndDestroy(repository);

	return commonDataSet;

	}

/*

 * This method sets Common Data Set in Central Repository.

 * @param aNewValue new value for Common Data Set.

 */

void CT_LbsSimulationPsyPosTp400::SetTrpModeL(TInt aNewValue)

	{

	// Set Time Related Playback behaviour in the Central Repository.

	CRepository* repository = CRepository::NewLC(KCRUidSimulationPSY);

	User::LeaveIfError(repository->Set(KCRKeySimPSYCommonDataSet, aNewValue));

	CleanupStack::PopAndDestroy(repository);

	}

/*

 * Perform a synchronous position request and return error code.

 * @param aModuleInfo position information is returned in this object.

 * @param aPositioner reference to RPositioner that will be used to obtain position request.

 * @return Symbian system error code.

 */

TInt CT_LbsSimulationPsyPosTp400::PerformSyncRequest(TPositionInfoBase& aModuleInfo, const RPositioner& aPositioner) const

	{

	TRequestStatus status = KRequestPending;

	aPositioner.NotifyPositionUpdate(aModuleInfo, status);

	User::WaitForRequest(status);

	return status.Int();

	}