/*
 * Name        : Position.cpp
 * Description : Position helper class
 * Project     : This file is part of OpenMAR, an Open Mobile Augmented Reality browser
 * Website     : http://OpenMAR.org
 *
 * Copyright (c) 2010 David Caabeiro
 *
 * All rights reserved. This program and the accompanying materials are made available 
 * under the terms of the Eclipse Public License v1.0 which accompanies this 
 * distribution, and is available at http://www.eclipse.org/legal/epl-v10.html
 *
 */

#include "Position.h"

#include "Logger.h"

CPosition* CPosition::NewL(MPositionObserver& aObserver)
{
    CPosition* self = new(ELeave) CPosition(aObserver);
    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop(self);

    return self;
}

CPosition::~CPosition()
{
    Cancel();

    iPositioner.Close();
    iServer.Close();
}

CPosition::CPosition(MPositionObserver& aObserver)
    : CActive(CActive::EPriorityStandard), iObserver(aObserver), iState(EUnknown)
{
    CActiveScheduler::Add(this);
}

void CPosition::ConstructL()
{
    User::LeaveIfError(iServer.Connect());
    User::LeaveIfError(iPositioner.Open(iServer));

    _LIT(KRequestor, "OpenMAR" );
    User::LeaveIfError(iPositioner.SetRequestor(CRequestor::ERequestorService, CRequestor::EFormatApplication, KRequestor));

    const TInt KSecond = 1000000;
    TPositionUpdateOptions updateOptions;
    updateOptions.SetUpdateInterval(TTimeIntervalMicroSeconds(10 * KSecond));
    updateOptions.SetUpdateTimeOut(TTimeIntervalMicroSeconds(30 * KSecond));
    updateOptions.SetMaxUpdateAge(TTimeIntervalMicroSeconds(1 * KSecond));
    updateOptions.SetAcceptPartialUpdates(EFalse);

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

void CPosition::Request()
{
    if (IsActive())
        Cancel();

    iPositioner.GetLastKnownPosition(iPositionInfo, iStatus);
    SetActive();

    iState = ECache;
}

void CPosition::RunL()
{
    TPosition position;
    iPositionInfo.GetPosition(position);

    TTime now;
    now.UniversalTime();

    TTimeIntervalSeconds interval = 0;
    now.SecondsFrom(position.Time(), interval);

    LOGARG("Interval between retrieved position and current time: %d secs", interval.Int());

    // Compare that retrieved data is not outdated
    if (iStatus == KErrNone && interval.Int() < 300)
    {
        iObserver.PositionUpdateL(iStatus.Int(), position);
    }
    else if (iStatus == KErrTimedOut)
    {
        iObserver.PositionUpdateL(iStatus.Int(), position);
    }
    else
    {
        iPositioner.NotifyPositionUpdate(iPositionInfo, iStatus);
        SetActive();

        iState = EGps;
    }
}

void CPosition::DoCancel()
{
    switch (iState)
    {
        case ECache:
            iPositioner.CancelRequest(EPositionerGetLastKnownPosition);
            break;

        case EGps:
            iPositioner.CancelRequest(EPositionerNotifyPositionUpdate);
            break;

        default:
            break;
    };
}

TInt CPosition::RunError(TInt aError)
{
    return KErrNone;
}