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

//

/**

 @file

 @InternalComponent

*/

#include "cagpsdatabus.h"

#include "lbsdevloggermacros.h"

#include "mdatabusobserver.h"

#include <lbs/lbsextendedsatellite.h>

#ifdef _DEBUG

_LIT(KLocDataBus, "CAgpsDataBus");

#endif

/**

Create a location data bus, this should be called from the location cache

@return The pointer to the location data bus

@see CLocationCache

*/

CAgpsDataBus* CAgpsDataBus::NewL(MDataBusObserver& aObserver, const TUid& aModuleId)	

	{

	CAgpsDataBus* self = new (ELeave) CAgpsDataBus(aObserver, aModuleId);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	} 

/**

constructor, note the location data bus is owned by location cache and used by CRequestQ, and it is a module-based CActive object.

Set the data bus as standard priority by default.

Add itself to Active Scheduler

@param aModuleId Position module Id

@see CRequestQ

@see CLocationCache

*/

CAgpsDataBus::CAgpsDataBus(MDataBusObserver& aObserver, const TUid& aModuleId) : CActive(CActive::EPriorityStandard), iModuleId(aModuleId), iObs(aObserver)

	{

	CActiveScheduler::Add(this);

	}

/**

Open the RProperty object wrappered by the data bus.

Location data bus is implemented as Publish & Subscribe mechanism.

*/

void CAgpsDataBus::ConstructL()

	{

	iAGPSDataBus.OpenL(iModuleId);

	}

/**

Cancel any outstanding request to the CActive object.

Close the RProperty.

*/

CAgpsDataBus::~CAgpsDataBus()

	{

	Cancel();

	iAGPSDataBus.Close();

	}

/**

Subscribe to the data bus. It will be called by objects which listen to the data bus.

It will eventually call RProperty::Subscribe()

Set active the data bus active object

Panic if there are no data bus observers already set.

*/

void CAgpsDataBus::Subscribe()

	{

	if(!IsActive())

		{

		iAGPSDataBus.NotifyPositionUpdate(iStatus);

		SetActive();

		}

	}

/**

Cancel the subscribe to the data bus. Cancel any outstanding request to the CActive object.

Panic if there are no data bus observers already set.

*/

void CAgpsDataBus::UnSubscribe()

	{

	Cancel();

	}

/**

Get the last position from the bus 

 */

TInt CAgpsDataBus::GetLastPositionInfo(TPositionSatelliteInfo& aSatelliteInfo, TTime& aActualTime, TUint& aAttributes, TUint& aMode)

	{

	TBool conflictControl;

	TTime targetTime;

	TInt error = iAGPSDataBus.GetPositionInfo(conflictControl, &aSatelliteInfo, aSatelliteInfo.PositionClassSize(), targetTime, aActualTime, aAttributes, aMode);

	return error;

	}

/**

from CActive, the main event processing loop

Whenever there is a new event, i.e. the position info data is published to the data bus, notify the data bus observer by LocationDataAvailableL()

*/

void CAgpsDataBus::RunL()

	{

	TTime actualTime;

	TPositionExtendedSatelliteInfo satelliteInfo;

	TUint attributes = 0;

	TUint mode = 0;

	TInt error = GetLastPositionInfo(satelliteInfo, actualTime, attributes, mode);	

	iObs.DataUpdate(satelliteInfo, iStatus.Int(), error, actualTime, attributes, mode);

	}

/**

from CActive

Cancels the request for position update notification

It will eventually cancel an outstanding subscription request for this property handle.

*/

void CAgpsDataBus::DoCancel()

	{

	iAGPSDataBus.CancelNotifyPositionUpdate();

	}

/**

from CActive

Simply fwds any errors to the observers

*/

TInt CAgpsDataBus::RunError(TInt aError)

	{

	return iObs.DataError(aError, iStatus.Int());

	}