// Copyright (c) 2006-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:

// Includes

// Component

// 

//

#include "lbsnetlocmanrequesthandler.h"

#include "lbsnetlocmanlogic.h"

#include "lbsdevloggermacros.h"

//****************************************************************

// Class CNetLocManRequestHandler

//****************************************************************

/** Static constructor.

@param aChannel A reference to the channel identifier

@param aNetLocMan A reference to the parent class

@released

@internalComponent

*/

CNetLocManRequestHandler* CNetLocManRequestHandler::NewL(const RLbsPositionUpdateRequests::TChannelIdentifer& aChannel, CNetLocManLogic& aNetLocMan)

	{

	CNetLocManRequestHandler* self = new(ELeave) CNetLocManRequestHandler (aChannel, aNetLocMan);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop();

	return self;

	}

/** Constructor.

@param aChannel A reference to the channel identifier

@param aNetLocMan A reference to the parent class

@released

@internalComponent

*/

CNetLocManRequestHandler::CNetLocManRequestHandler(const RLbsPositionUpdateRequests::TChannelIdentifer& aChannel, CNetLocManLogic& aNetLocMan) : 

CActive(CActive::EPriorityStandard), iChannel(aChannel), iNetLocMan(aNetLocMan), iTimer(NULL)

	{

	}

/** 

@see CActive::DoCancel

@released

@internalComponent

*/

void CNetLocManRequestHandler::DoCancel()

	{

	// cancel RLbsPositionUpdateRequests async request

	iPosUpdateReq.CancelNotifyPositionUpdateRequestChange();

	}

/** Second phase constructor.

@released

@internalComponent

*/

void CNetLocManRequestHandler::ConstructL()

	{

	iPosUpdateReq.OpenL(iChannel);

	iLocationReq.OpenL(KLbsNetLocManagerUid);

	iTimer = CLbsCallbackTimer::NewL(*this);

	CActiveScheduler::Add(this);

	}

/** Destructor

@released

@internalComponent

*/

CNetLocManRequestHandler::~CNetLocManRequestHandler()

	{

	Cancel();

	iPosUpdateReq.Close();

	iLocationReq.Close();

	if(iTimer)

		{

		iTimer->Cancel();

		delete iTimer;	

		}

	}

/** Subscribe to the position update request property

@released

@internalComponent

*/

void CNetLocManRequestHandler::StartGettingRequests()

	{

	LBSLOG(ELogP2, "CNetLocManRequestHandler::StartGettingRequests:");

	Cancel();

	// subscribe to property from Network Location Manager -> Network Gateway

	iPosUpdateReq.NotifyPositionUpdateRequestChange(iStatus);

	SetActive();	

	}

/** 

@see CActive::RunError

@param aError An error code

@released

@internalComponent

*/

TInt CNetLocManRequestHandler::RunError(TInt aError)

	{

	// handle RunL leaving - in our case we do nothing 

	// as this means we have had encountered a program inconsistency

	// By doing nothing here  causes the main manager thread to exit

	// and the Lbs root process resolves any issues - by stopping and restarting

	// lbs components

 	return aError;

	}

/** Handle requests from the LocServer

This function handles the incomming position requests from the LocServer,

and pass them on to the NetworkGateway

@see CActive::RunL

@released

@internalComponent

*/

void CNetLocManRequestHandler::RunL()

	{

	TInt status = iStatus.Int();

	StartGettingRequests(); // we want further location requests!

	switch (status)

		{

		case KErrNone:

			{

			TLbsPositionUpdateRequestBase updateRequest; 

			User::LeaveIfError(iPosUpdateReq.GetPositionUpdateRequest(updateRequest));

			// when there is a new request forwarded, increase session ID by one

			TLbsNetSessionIdInt sessionId;

			iNetLocMan.GetSessionId(sessionId);

			switch(updateRequest.Type())

				{

				case TLbsPositionUpdateRequestBase::ECancel:

					{

					iTimer->Cancel();

					TLbsNetLocNetworkLocationCancelMsg locCancel(sessionId, 0);

					User::LeaveIfError(iLocationReq.SetNetworkLocationRequest(locCancel));

					break;

					}

				case TLbsPositionUpdateRequestBase::EUpdateRequest:

					{

					// only increment when new update request comes in

					iNetLocMan.IncrementSessionId();

					TLbsPositionUpdateRequest* request = 

						(reinterpret_cast<TLbsPositionUpdateRequest*>(&updateRequest));

					TTime target = request->TargetTime();

					TTime now;

					now.UniversalTime();

					TTimeIntervalMicroSeconds timeout;

					timeout = target.MicroSecondsFrom(now);

					if (timeout < 0)

						timeout = 0;

					iTimer->Cancel();

					iTimer->EventAfter(timeout ,0);

					break;

					}

				}

			break;

			}

		default:

			{

			User::LeaveIfError(status);

			break;

			}

		}

	}

void CNetLocManRequestHandler::OnTimerEventL(TInt /*aTimerId*/)

	{

	TLbsPositionUpdateRequestBase updateRequest; 

	User::LeaveIfError(iPosUpdateReq.GetPositionUpdateRequest(updateRequest));

	TLbsNetSessionIdInt sessionId;

	iNetLocMan.GetSessionId(sessionId);

	TLbsPositionUpdateRequest* request = 

		(reinterpret_cast<TLbsPositionUpdateRequest*>(&updateRequest));

	TLbsNetPosRequestQualityInt quality; 

	quality.SetMaxFixTime(request->RequestQuality().MaxFixTime());

	quality.SetMinHorizontalAccuracy(request->RequestQuality().MinHorizontalAccuracy());

	quality.SetMinVerticalAccuracy(request->RequestQuality().MinVerticalAccuracy());										

	// Set device status to EDeviceActive

	iNetLocMan.UpdateDeviceStatus(TPositionModuleStatus::EDeviceActive);

	TLbsNetLocNetworkLocationRequestMsg locRequest(sessionId, ETrue, quality);

	User::LeaveIfError(iLocationReq.SetNetworkLocationRequest(locRequest));

	}

TInt CNetLocManRequestHandler::OnTimerError(TInt /*aTimerId*/, TInt aError)

	{

	return aError;

	}