// Copyright (c) 2000-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 "ctlbsrequester.h"

#include "mctlbsrequestobserver.h"

// CONSTANTS

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

// Two-phased constructor.

CT_LbsRequester* CT_LbsRequester::NewL(

    TUid                	aPsyUid,

    MCT_LbsRequestObserver*	aObserver,

    CTestExecuteLogger&		aLogger

    )

    {

    CT_LbsRequester* self = new (ELeave) CT_LbsRequester(aObserver);

    CleanupStack::PushL(self);

    self->ConstructL(aPsyUid, aLogger);

    CleanupStack::Pop();

    return self;

    }

// Two-phased constructor.

CT_LbsRequester* CT_LbsRequester::NewL(

    MCT_LbsRequestObserver*   aObserver,

    TTimeIntervalMicroSeconds aInterval,

    CTestExecuteLogger&		aLogger

    )

    {

    CT_LbsRequester* self = new (ELeave) CT_LbsRequester(aObserver);

    CleanupStack::PushL(self);

    self->ConstructL(aInterval, aLogger);

    CleanupStack::Pop();

    return self;

    }

// Destructor

CT_LbsRequester::~CT_LbsRequester()

    {

    iObserver = NULL;

    Cancel();

    iPositioner.Close();

    iPosServer.Close();

    }

// C++ default constructor can NOT contain any code, that

// might leave.

//

CT_LbsRequester::CT_LbsRequester(

    MCT_LbsRequestObserver*   aObserver)

    : CActive(EPriorityStandard), iObserver(aObserver)

    {

    }

// EPOC default constructor can leave.

void CT_LbsRequester::ConstructL(

     TUid        aPsyUid,

     CTestExecuteLogger&		aLogger

     )

	{

    iLogger = aLogger;

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

    iModuleInfo = TPositionInfo();

    iCompletionCode = KErrNone;

    User::LeaveIfError(iPositioner.Open(iPosServer, aPsyUid));

    _LIT(KService, "SAAA");

    iPositioner.SetRequestor(CRequestor::ERequestorService,

                             CRequestor::EFormatApplication,

                             KService);

    CActiveScheduler::Add(this);

    }

void CT_LbsRequester::ConstructL(

    TTimeIntervalMicroSeconds aInterval,

    CTestExecuteLogger&		aLogger

    )

	{

	iLogger = aLogger;

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

    iModuleInfo = TPositionInfo();

    iCompletionCode = KErrNone;

    User::LeaveIfError(iPositioner.Open(iPosServer));

    TPositionUpdateOptions posOption;

	posOption.SetUpdateInterval(aInterval);

    User::LeaveIfError(iPositioner.SetUpdateOptions(posOption));

    _LIT(KService, "SAAA");

    iPositioner.SetRequestor(CRequestor::ERequestorService,

                             CRequestor::EFormatApplication,

                             KService);

    CActiveScheduler::Add(this);

    }

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

// CT_LbsRequester::CompletionTimeUTC

// 

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

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

//

const TTime& CT_LbsRequester::CompletionTimeUTC() const

    {

    return iCompletionTimeUTC;

    }

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

// CT_LbsRequester::CompletionCode

// 

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

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

//

TInt CT_LbsRequester::CompletionCode() const

    {

    return iCompletionCode;

    }

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

// CT_LbsRequester::StartRequest

// 

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

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

//

void CT_LbsRequester::SetUpdateIntervalL(TTimeIntervalMicroSeconds aInterval)

    {	

	TPositionUpdateOptions posOption;

	posOption.SetUpdateInterval(aInterval);	

    User::LeaveIfError(iPositioner.SetUpdateOptions(posOption));

    }

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

// CT_LbsRequester::StartRequest

// 

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

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

void CT_LbsRequester::StartRequest()

    {    

    iPositioner.NotifyPositionUpdate(iModuleInfo, iStatus);

    SetActive();

    }

// LOCAL FUNCTIONS

void CleanOpRequestorStack(TAny* aAnArray)

    {

    // Cleanup function the requestor stack

    RRequestorStack* theStack = reinterpret_cast <RRequestorStack*> (aAnArray);

    theStack->ResetAndDestroy();

    }

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

// CT_LbsRequester::SetRequestorStackL

// 

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

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

//

TInt CT_LbsRequester::SetRequestorStackL(const TDesC& aService, const TDesC& aContact)

	{

	CRequestor* contactId = 

		CRequestor::New(CRequestor::ERequestorContact, CRequestor::EFormatTelephone, 

                    aContact);

    CRequestor* servId = 

        CRequestor::New(CRequestor::ERequestorService, CRequestor::EFormatApplication, 

        aService);

    // Create a requestor stack containing one contact and one service (the service must be last added)

    RRequestorStack stack = RRequestorStack();

    CleanupStack::PushL(TCleanupItem(CleanOpRequestorStack ,&stack));

    stack.Append(contactId);

    stack.Append(servId);

    CleanupStack::PushL(contactId);

    CleanupStack::PushL(servId);

    TInt err = iPositioner.SetRequestor(stack);

    CleanupStack::PopAndDestroy(servId);

    CleanupStack::PopAndDestroy(contactId);

    stack.Close();

    CleanupStack::PopAndDestroy(1); // CleanOpTp226 stack

	return err;

	}

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

// CT_LbsRequester::RunL

// 

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

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

//

void CT_LbsRequester::RunL()

    {

    iCompletionCode = iStatus.Int();

    iCompletionTimeUTC.UniversalTime();

    RequestComplete();

    }

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

// CT_LbsRequester::DoCancel

// 

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

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

//

void CT_LbsRequester::DoCancel()

    {

    iPositioner.CancelRequest(EPositionerNotifyPositionUpdate);

    iCompletionTimeUTC.UniversalTime();

    RequestComplete();

    }

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

// CT_LbsRequester::RequestComplete

// 

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

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

//

void CT_LbsRequester::RequestComplete()

    {

    if (iObserver)

        {

        TRAPD(err, iObserver->RequestCompleteL());

        if(KErrNone != err)

        	{

        	_LIT(KRequestCompleteError, "Error in LbsRequester: %d");

        	ERR_PRINTF2(KRequestCompleteError, err);

        	}

        }

    }

void CT_LbsRequester::GetPositionInfo(

            TPositionInfo& aModuleInfo)

    {

    aModuleInfo = iModuleInfo;

    }

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

// CT_LbsRequester::SetUpdateType

// 

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

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

//

void CT_LbsRequester::SetUpdateType(const TInt& aUpdateType)

    {	

    iModuleInfo.SetUpdateType(aUpdateType); 

    }

//  End of File