/*

* Copyright (c) 2010 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:  Implementation of the GPS time updater

*

*/

// INCLUDE FILES

#include <e32base.h>

#include <e32debug.h>

#include "GPSTimeUpdater.h"

#include "DRMClock.h"

#include "drmlog.h"

_LIT(KDRMClockServerName, "DRMClockServer");

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

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

// CGPSTimeUpdater::CGPSTimeUpdater

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

// might leave.

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

//   

CGPSTimeUpdater::CGPSTimeUpdater( RPositionServer &aPosServer, 

                                  const TPositionModuleId& aModuleId,

                                  CDRMClock* aClock ) : 

	CActive(EPriorityHigh),

	iPosServer(aPosServer),

	iModuleId(aModuleId),

	iClock( aClock ),

	iTimeReceived( EFalse )

	{

	CActiveScheduler::Add(this);

	}

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

// CGPSTimeUpdater::~CGPSTimeUpdater

// C++ destructor

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

// 

CGPSTimeUpdater::~CGPSTimeUpdater()

	{

	DRMLOG(_L("CGPSTimeUpdater::~CGPSTimeUpdater"));

	Cancel();

	iPositioner.Close();

	}

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

// CGPSTimeUpdater::New

// Two-phased constructor

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

//

CGPSTimeUpdater* CGPSTimeUpdater::New( RPositionServer &aPosServer, 

                                       const TPositionModuleId& aModuleId,

                                       CDRMClock* aClock )

	{

	CGPSTimeUpdater* self = new CGPSTimeUpdater(aPosServer, aModuleId, aClock);

	if(self)

		{

		TRAPD(err, self->ConstructL());

		if(err!=KErrNone)

			{

			delete self;

			self = 0;

			}

		}

	return self;

	}

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

// CGPSTimeUpdater::ConstructL

// Symbian 2nd phase constructor can leave.

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

//

void CGPSTimeUpdater::ConstructL()

	{

	DRMLOG(_L("CGPSTimeUpdater::ConstructL >>"));

	// Open positioner

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

	User::LeaveIfError(iPositioner.SetRequestor(CRequestor::ERequestorService,

	                   CRequestor::EFormatApplication, 

	                   KDRMClockServerName));

	// Set update options

	TPositionUpdateOptions updateOptions;

	updateOptions.SetAcceptPartialUpdates(ETrue);

	updateOptions.SetMaxUpdateAge(0);

	updateOptions.SetUpdateInterval(TTimeIntervalMicroSeconds(0));

	updateOptions.SetUpdateTimeOut(TTimeIntervalMicroSeconds(30*1000*1000));

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

	// Request position update

	iPositioner.NotifyPositionUpdate(iSatelliteInfo, iStatus);

	SetActive();

	DRMLOG(_L("CGPSTimeUpdater::ConstructL <<"));

	}

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

// CGPSTimeUpdater::RunL

// Inherited from CActive

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

//

void CGPSTimeUpdater::RunL()

	{

	DRMLOG(_L("CGPSTimeUpdater::RunL >>"));

	DRMLOG2(_L("CGPSTimeUpdater::RunL: iStatus=%d"), iStatus.Int());

	if( iStatus == KErrNone || iStatus == KPositionPartialUpdate )

		{

		DRMLOG(_L("CGPSTimeUpdater::RunL: position updated!"));

		DRMLOG2(_L("CGPSTimeUpdater::RunL: satellites used = %d"), iSatelliteInfo.NumSatellitesUsed());

		TTime satelliteTime = iSatelliteInfo.SatelliteTime();

		TDateTime dt = satelliteTime.DateTime();

		DRMLOG7(_L("CGPSTimeUpdater::RunL: satellite time = %02d-%02d-%04d, %02d:%02d:%02d"), dt.Day(), dt.Month(), dt.Year(), dt.Hour(), dt.Minute(), dt.Second());

	    // If the time has not been received yet this function will leave and we re-issue the request from run error:    

		iClock->ResetSecureTimeL( satelliteTime, 0 );    

		// Mark time as received

		iTimeReceived = ETrue;

		}

    // if the call timed out try again		

    if( iStatus == KErrTimedOut ) 

	    {

	    // Request position update

	    iPositioner.NotifyPositionUpdate(iSatelliteInfo, iStatus);

	    SetActive();

	    }	

	else 	

	    {    	

	    iPositioner.Close();

        }

	DRMLOG(_L("CGPSTimeUpdater::RunL <<"));

	}

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

// CGPSTimeUpdater::DoCancel

// Inherited from CActive

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

//	

void CGPSTimeUpdater::DoCancel()

	{

	iPositioner.CancelRequest(EPositionerNotifyPositionUpdate);

	}

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

// CGPSTimeUpdater::RunError

// Inherited from CActive

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

//	

TInt CGPSTimeUpdater::RunError( TInt /*aError*/ )

    {

    // Time received was invalid, wait for more updates

    iPositioner.NotifyPositionUpdate(iSatelliteInfo, iStatus);

    SetActive();

    // ignore errors    

    return KErrNone;    

    }