// 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 "ctlbsportedstepbase.h"
#include "ctlbsclientrequestor.h"
#include "mctlbsrequestobserver.h"

// CONSTANTS

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

// Two-phased constructor.
CT_LbsClientRequestor* CT_LbsClientRequestor::NewL(
	TUid                	aPsyUid,
	MCT_LbsRequestObserver*	aObserver,
	const TDesC&			aClientName,
    CTestExecuteLogger&		aLogger
    )
	{
    CT_LbsClientRequestor* self = new (ELeave) CT_LbsClientRequestor(aObserver, aPsyUid);
    CleanupStack::PushL(self);
    self->ConstructL(aClientName, aLogger);
    CleanupStack::Pop();
    return self;
    }

// Destructor
CT_LbsClientRequestor::~CT_LbsClientRequestor()
    {
    iObserver = NULL;
    Cancel();
    iPosServer.Close();
    }

// C++ default constructor can NOT contain any code, that
// might leave.
//
CT_LbsClientRequestor::CT_LbsClientRequestor(
	MCT_LbsRequestObserver*   aObserver,
	TUid				aPsyUid)
    : CActive(EPriorityStandard), iObserver(aObserver), iCompletionCode(KNoEvent),
	iPsyUid(aPsyUid), iContinueEventRequesting(FALSE)
    {
    }

// EPOC default constructor can leave.
void CT_LbsClientRequestor::ConstructL(
	const TDesC& aClientName,
    CTestExecuteLogger&		aLogger
    )
	{
	iName = aClientName;
    iLogger = aLogger;
    User::LeaveIfError(iPosServer.Connect());
    iModuleInfo = TPositionInfo();
    CActiveScheduler::Add(this);
    }

// ---------------------------------------------------------
// CRequester::CompletionTimeUTC
// 
// (other items were commented in a header).
// ---------------------------------------------------------
//
const TTime& CT_LbsClientRequestor::CompletionTimeUTC() const
    {
    return iCompletionTimeUTC;
    }

// ---------------------------------------------------------
// CRequester::CompletionCode
// 
// (other items were commented in a header).
// ---------------------------------------------------------
//
TInt CT_LbsClientRequestor::CompletionCode() const
    {
    return iCompletionCode;
    }

// ---------------------------------------------------------
// CT_LbsClientRequestor::ResetCompletionCode
// 
// (other items were commented in a header).
// ---------------------------------------------------------
//
void CT_LbsClientRequestor::ResetCompletionCode()
	{
	iCompletionCode = KNoEvent;
	}

// ---------------------------------------------------------
// CRequester::StartRequest
// 
// (other items were commented in a header).
// ---------------------------------------------------------
//
void CT_LbsClientRequestor::StartRequestL(TBool aDefaultPsy)
    {    
    _LIT(KService, "SAAA");
	if (aDefaultPsy == FALSE)
		{
		User::LeaveIfError(iPositioner.Open(iPosServer, iPsyUid));    
		}
	else 
		{
		User::LeaveIfError(iPositioner.Open(iPosServer));
		}
	
	
	iPositioner.SetRequestor(CRequestor::ERequestorService,
                             CRequestor::EFormatApplication,
                             KService);

    iPositioner.NotifyPositionUpdate(iModuleInfo, iStatus);
    SetActive();
    }

// ---------------------------------------------------------
// CRequester::RunL
// 
// (other items were commented in a header).
// ---------------------------------------------------------
//
void CT_LbsClientRequestor::RunL()
    {
    iCompletionCode = iStatus.Int();
    RequestComplete();
	if (iContinueEventRequesting)
		{
		iContinueEventRequesting = FALSE;
		RequestModuleStatusEvent();
		}
    }

// ---------------------------------------------------------
// CT_LbsClientRequestor::DoCancel
// 
// (other items were commented in a header).
// ---------------------------------------------------------
//
void CT_LbsClientRequestor::DoCancel()
    {
	iPosServer.CancelRequest(EPositionServerNotifyModuleStatusEvent/*EPositionServerGetModuleStatus*/);
    }

// ---------------------------------------------------------
// CT_LbsClientRequestor::RequestComplete
// 
// (other items were commented in a header).
// ---------------------------------------------------------
//
void CT_LbsClientRequestor::RequestComplete()
    {
	if (iObserver)
        {
        TRAPD(err, iObserver->RequestCompleteL());
        if(KErrNone != err)
        	{
        	_LIT(KClientRequestor, "Error in LbsClientRequestor: %d");
        	ERR_PRINTF2(KClientRequestor, err);
        	}
        }
    }

// ---------------------------------------------------------
// CT_LbsClientRequestor::RequestModuleStatusEvent
// 
// (other items were commented in a header).
// ---------------------------------------------------------
//
void CT_LbsClientRequestor::RequestModuleStatusEvent()
	{
	istatusEvent.SetRequestedEvents(TPositionModuleStatusEvent::EEventAll);
	iPosServer.NotifyModuleStatusEvent(istatusEvent, iStatus, iPsyUid);
	if (!IsActive())
		{
		SetActive();
		}
	}

// ---------------------------------------------------------
// CT_LbsClientRequestor::CancelModuleStatusEvent
// 
// (other items were commented in a header).
// ---------------------------------------------------------
//
void CT_LbsClientRequestor::CancelModuleStatusEvent()
	{
	iPosServer.CancelRequest(EPositionServerGetModuleStatus);
	}

// ---------------------------------------------------------
// CT_LbsClientRequestor::ReadModuleStatusEvent
// 
// (other items were commented in a header).
// ---------------------------------------------------------
//
TInt CT_LbsClientRequestor::ReadModuleStatusEvent()
	{
	TPositionModuleStatus modstatus = TPositionModuleStatus();
	istatusEvent.GetModuleStatus(modstatus);
	return modstatus.DeviceStatus();
	}

// ---------------------------------------------------------
// CT_LbsClientRequestor::ReadModuleStatusClientApi
// 
// (other items were commented in a header).
// ---------------------------------------------------------
//
TInt CT_LbsClientRequestor::ReadModuleStatusClientApi(TPositionModuleId aModuleId)
	{
	//Module status from Client API
	TPositionModuleStatus moduleStatus = TPositionModuleStatus();
	iPosServer.GetModuleStatus(moduleStatus, aModuleId);
	return moduleStatus.DeviceStatus();
	}

// ---------------------------------------------------------
// CT_LbsClientRequestor::ReadModuleStatusModulesApi
// 
// (other items were commented in a header).
// ---------------------------------------------------------
//
TBool CT_LbsClientRequestor::ReadModuleStatusModulesApi(CPosModules* aDb, TPositionModuleId aModuleId)
	{
	//Module info from Modules API
	TPositionModuleInfo moduleInfo;
	CPosModuleIdList* prioList = aDb->ModuleIdListLC();
	TInt modnr = prioList->Find(aModuleId);
	aDb->GetModuleInfoL(prioList->At(modnr), moduleInfo);
	CleanupStack::PopAndDestroy(prioList);
	return moduleInfo.IsAvailable();
	}

// ---------------------------------------------------------
// CT_LbsClientRequestor::ContinueRequesting
// 
// (other items were commented in a header).
// ---------------------------------------------------------
//
void CT_LbsClientRequestor::ContinueRequesting()
	{
	iContinueEventRequesting = TRUE;;
	}

// ---------------------------------------------------------
// CT_LbsClientRequestor::ClosePositioner
// 
// (other items were commented in a header).
// ---------------------------------------------------------
//
void CT_LbsClientRequestor::ClosePositioner()
	{
	iPositioner.Close();
	}

//  End of File