// Copyright (c) 2001-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 "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 FILES

#include "ctlbsclientpostp213.h"

#include "ctlbsclientrequestor.h"

#include "ctlbsclienteventtimer.h"

#include <LbsPositionInfo.h>

#include <Lbs.h>

#include <LbsCommon.h>

#include <LbsRequestor.h>

#include <s32file.h>

// CONSTANTS

_LIT(KClient1, "RunL client1");

_LIT(KClient2, "RunL client2");

_LIT(KClient3, "RunL client3");

_LIT(KClient1Default, "RunL client1, default psy");

_LIT(KClient2Default, "RunL client2, default psy");

_LIT(KClient3Default, "RunL client3, default psy");

//Error logs

_LIT( KErrStatusMismatch, "Statuses does not conform to each other!" );

_LIT( KEventReceived, "Client 3 received an event that shouldn't be received!" );

_LIT( KCanceledRequest, "Client 2 didn't receive KErrCancel, but %d!" );

_LIT( KFileNotDeleted, "File created by PSY NOT deleted! PSY really unloaded from memory?" );

//File name. Beware, also declared in EPos_CTestStatusPsy.h!!!!

_LIT(KDummyFileName, "c:\\TestStatusPsyIsNotUnloaded.txt");

// ================= MEMBER FUNCTIONS =======================

// Constructor.

CT_LbsClientPosTp213::CT_LbsClientPosTp213(CT_LbsServer& aParent): CT_LbsPortedStepBase(aParent)

    {  

    _LIT(KTestName, "TP213 - Disabling psy during request");

    SetTestStepName(KTestName); 

    }

// Destructor

CT_LbsClientPosTp213::~CT_LbsClientPosTp213()

    {

    }

// ---------------------------------------------------------

// CT_LbsClientPosTp213::CloseTest

//

// (other items were commented in a header).

// ---------------------------------------------------------

//

void CT_LbsClientPosTp213::CloseTest()

    {

	delete ieventtimer;

	ieventtimer = NULL;

	delete iclient1;

	delete iclient2;

	delete iclient3;

    }

// ---------------------------------------------------------

// CT_LbsClientPosTp213::StartL

//

// (other items were commented in a header).

// ---------------------------------------------------------

//

void CT_LbsClientPosTp213::StartL()

    {

	TBool usedefaultpsy = FALSE; // Indicating if the default psy should be used

	iNoFurtherEvents = FALSE;	// Client should receive events!

	iErrorDuringExecution = FALSE;  // True if an error occurs 

	//Enable PSY 

	CPosModules* idb = CPosModules::OpenL();

	CleanupStack::PushL(idb);

	_LIT(KEnablePSY, "Enabling Test Status PSY");

	INFO_PRINTF1(KEnablePSY);

    EnablePsyL(*idb, iUidTestStatusPsy);

	// Event timer

	ieventtimer = CT_LbsClientEventTimer::NewL(Logger());

	ieventtimer->SetObserver(this);

	// 3 clients

	iclient1 = CT_LbsClientRequestor::NewL(iUidTestStatusPsy, this, KClient1, Logger());

	iclient2 = CT_LbsClientRequestor::NewL(iUidTestStatusPsy, this, KClient2, Logger());

	iclient3 = CT_LbsClientRequestor::NewL(iUidTestStatusPsy, this, KClient3, Logger());

	// Make a request with client 2

	_LIT(KRequestClient2, "Calling StartRequestL for client2");

	INFO_PRINTF1(KRequestClient2);

	iclient2->StartRequestL(usedefaultpsy);

	// Make client3 listen for status events

	iclient3->RequestModuleStatusEvent();

	// Disable Psy 3

	User::After(100000); //a small delay

	_LIT(KDisablePSY, "Disabling Test Status PSY");

	INFO_PRINTF1(KDisablePSY);

	DisablePsyL(*idb, iUidTestStatusPsy);

	// Client1 reads Module Status

	// Client API

	TInt clientapistatus = iclient1->ReadModuleStatusClientApi(iUidTestStatusPsy);

	_LIT(KClientApi, "Module Status from Client API: %d.");

	TBuf<100> bufclientapi;

	bufclientapi.Format(KClientApi, clientapistatus);

	INFO_PRINTF1(bufclientapi);

	// Modules API

	TInt modulesapistatus = iclient1->ReadModuleStatusModulesApi(idb, iUidTestStatusPsy);

	_LIT(KModulesApi, "Module Status from Module API: (IsAvailable=) %d.");

	TBuf<100> bufmodulesapi;

	bufmodulesapi.Format(KModulesApi, modulesapistatus);

	INFO_PRINTF1(bufmodulesapi);

	// Compare received statuses

	if ( !((modulesapistatus == 0) && (clientapistatus == TPositionModuleStatus::EDeviceDisabled)) )

		{

		iErrorDuringExecution = TRUE;

		ERR_PRINTF1(KErrStatusMismatch);

		}

	iclient2->ClosePositioner();

	delete iclient1;

	delete iclient2;

	delete iclient3; 

	///////////////////// Default PSY /////////////////////////////////////

	// Do the same as before but now use the default PSY

	iNoFurtherEvents = FALSE;	// Client should receive events!

	_LIT(KDefaultPsyStart, "****** Testing Default PSY ******");

	INFO_PRINTF1(KDefaultPsyStart);

	// Enable Psy

	INFO_PRINTF1(KEnablePSY);

	EnablePsyL(*idb, iUidTestStatusPsy);

	// 3 clients

	iclient1 = CT_LbsClientRequestor::NewL(iUidTestStatusPsy, this, KClient1Default, Logger());

	iclient2 = CT_LbsClientRequestor::NewL(iUidTestStatusPsy, this, KClient2Default, Logger());

	iclient3 = CT_LbsClientRequestor::NewL(iUidTestStatusPsy, this, KClient3Default, Logger());

	// Make a request with client 2

	INFO_PRINTF1(KRequestClient2);

	iclient2->StartRequestL(usedefaultpsy);

	// Make client3 listen for status events

	iclient3->RequestModuleStatusEvent();

	// Disable Psy 3

	User::After(1000000); //A small delay

	usedefaultpsy = TRUE; //Use default PSY

	INFO_PRINTF1(KDisablePSY);

	DisablePsyL(*idb, iUidTestStatusPsy);

	// Client1 reads Module Status

	// Client API

	clientapistatus = iclient1->ReadModuleStatusClientApi(iUidTestStatusPsy);

	bufclientapi.Format(KClientApi, clientapistatus);

	INFO_PRINTF1(bufclientapi);

	// Modules API

	modulesapistatus = iclient1->ReadModuleStatusModulesApi(idb, iUidTestStatusPsy);

	bufmodulesapi.Format(KModulesApi, modulesapistatus);

	INFO_PRINTF1(bufmodulesapi);

	// Compare received statuses

	if ( !((modulesapistatus == 0) && (clientapistatus == TPositionModuleStatus::EDeviceDisabled)) )	

		{

		iErrorDuringExecution = TRUE;

		ERR_PRINTF1(KErrStatusMismatch);

		}

	iclient2->ClosePositioner();

	delete iclient1;

    iclient1 = NULL;

	delete iclient2;

    iclient2 = NULL;

	delete iclient3;

    iclient3 = NULL;

	// Connect to EPos

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

	// Enable Psy

	INFO_PRINTF1(KEnablePSY);

	EnablePsyL(*idb, iUidTestStatusPsy);

    // Open subsession to Status Psy that still is disabled!!!

	_LIT(KInfoStatusPSY, "Calling OpenPositionerByName for Test Status PSY");

    INFO_PRINTF1(KInfoStatusPSY);  

	TInt err = OpenPositionerByName(iUidTestStatusPsy);

	User::After(100000); //A small delay

	if (err != KErrNone)

		{

		_LIT(KErrorRequest, "OpenPositionerByName failed, errCode = %d");

		TBuf<100> buf;

		buf.Format(KErrorRequest, err);

		LogErrorAndLeaveL(buf);

		}

	// Make a position request

	_LIT(KService, "service");

	TPositionInfo positionInfo = TPositionInfo();

	_LIT(KPerformSyncRequest, "Calling PerformSyncRequest");

	INFO_PRINTF1(KPerformSyncRequest);

    err = PerformSyncRequest(KService, &positionInfo);

    if (err != KErrNone)

        {

        _LIT(KErrorRequest, "The last request was not completed with KErrorNone, errCode = %d");

		TBuf<100> buf;

		buf.Format(KErrorRequest, err);

        LogErrorAndLeaveL(buf);

        }

	//Close Positioner

	ClosePositioner();

	//Disconnect from Epos

	Disconnect();

	CleanupStack::PopAndDestroy(idb);

	//Checking if any errors occured during execution

	if (iErrorDuringExecution)

		{

		_LIT(KErrorAndLeave, "Error(s) occured during execution, closing test!");

		LogErrorAndLeaveL(KErrorAndLeave);

		}

	}

// ---------------------------------------------------------

// CT_LbsClientPosTp213::EnablePsyL

//

// (other items were commented in a header).

// ---------------------------------------------------------

//

void CT_LbsClientPosTp213::EnablePsyL(

    CPosModules&   aDb,

    TUid             aPsy)

    {

    CPosModuleUpdate* moduleUpdate = CPosModuleUpdate::NewLC();

    // Enable Psy

    moduleUpdate->SetUpdateAvailability(ETrue);

    aDb.UpdateModuleL(aPsy, *moduleUpdate);

    CleanupStack::PopAndDestroy(moduleUpdate);

    }

// ---------------------------------------------------------

// CT_LbsClientPosTp213::DisablePsyL

//

// (other items were commented in a header).

// ---------------------------------------------------------

//

void CT_LbsClientPosTp213::DisablePsyL(

    CPosModules&   aDb,

    TUid             aPsy)

    {

    CPosModuleUpdate* moduleUpdate = CPosModuleUpdate::NewLC();

    // Disable Psy

    moduleUpdate->SetUpdateAvailability(EFalse);

    aDb.UpdateModuleL(aPsy, *moduleUpdate);

    CleanupStack::PopAndDestroy(moduleUpdate);

    }

// ---------------------------------------------------------

// CT_LbsClientPosTp213::RequestCompleteL

//

// (other items were commented in a header).

// ---------------------------------------------------------

//

void CT_LbsClientPosTp213::RequestCompleteL()

    {

	if (iclient2->CompletionCode() != KNoEvent)

		{

		_LIT(KClient2Compl, "Client 2 request completed with %d.");

		TBuf<100> bufclient2comp;

		bufclient2comp.Format(KClient2Compl, iclient2->CompletionCode());

		INFO_PRINTF1(bufclient2comp);

		if (iclient2->CompletionCode() != KErrCancel)

			{

			TBuf<80> errorMessage;

			errorMessage.Format( KCanceledRequest, iclient2->CompletionCode() );

			ERR_PRINTF1( errorMessage );

			}

		/*Testing if PSY is unloaded from memory. PSY created a temp-file that only should 

			exist during its lifespan. */

		User::After(5000000);

		RFs fileserver;

		RFile file;

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

		TInt err = file.Open(fileserver, KDummyFileName, EFileWrite);

		if (err == KErrNone || err == KErrInUse) 

            {

            ERR_PRINTF1(KFileNotDeleted);

            }

		file.Close();

		fileserver.Close();

		iclient2->ClosePositioner();

		iclient2->ResetCompletionCode();

		}

	else if (iclient3->CompletionCode() != KNoEvent)

		{	

		iclient3->ResetCompletionCode();

		_LIT(KClient3Compl, "Client 3 request completed, ");

		INFO_PRINTF1(KClient3Compl);

		if (iNoFurtherEvents) //Client 3 received event but should NOT have!

			{	

			iErrorDuringExecution = TRUE;

			ERR_PRINTF1(KEventReceived);

			}

		//Read what event was received!

		TInt eventReading = iclient3->ReadModuleStatusEvent();

		if (eventReading != TPositionModuleStatus::EDeviceDisabled) //NO Disable Event!

			{	

			_LIT(KClientStatusRead, "Event received by client not EDeviceDisabled, but %d.");

			TBuf<100> bufstatusread;

			bufstatusread.Format(KClientStatusRead, eventReading);

			INFO_PRINTF1(bufstatusread);

			//Make client3 listen for status events again!!

			iclient3->ContinueRequesting();

			}

		else //A Disable Event!

			{

			_LIT(KClient3ComplDisabled, "Client 3 received EDeviceDisabled event!");

			INFO_PRINTF1(KClient3ComplDisabled);

			//Make client3 listen for status events again!!

			iclient3->ContinueRequesting();

			/*Wait 5 s for events before halting the scheduler. 

				No further events for client 3 should be received! */

			ieventtimer->Start(5000000);

			iNoFurtherEvents = TRUE;

			//Start Timer

			_LIT(KStartTiming, "Start Timer, 5 s.");

			INFO_PRINTF1(KStartTiming);

			}

		}

	else if (ieventtimer->CompletionCode() != KNoEvent) //Time-out

		{

		ieventtimer->ResetCompletionCode() ;

		//Stop Scheduler

		_LIT(KTimeOut, "Timer Stopped.");

		INFO_PRINTF1(KTimeOut);

		CActiveScheduler::Stop();

		}

	else 

		{

		_LIT(KUnknownEvent, "Unknown request was completed!");

		LogErrorAndLeaveL(KUnknownEvent);

		}

    }

// End of File