/*

* Copyright (c) 2005 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:  CActive derived class for making asynchronous request to TI API

*

*/

#include <lbs/supltiapi.h>

#include <lbscommon.h> // for TPositionModuleInfo

#include "lbssupltiapirequestor.h"

#include "epos_suplterminalconstants.h"

#include "epos_tiapiimpltrace.h"

const TInt KSetBasedBits = 5; // Assisted|Network|Terminal = 101

const TInt KSetAssistedBits = 6;//Assisted|Network|Terminal = 110

const TInt KNetworkBits = 2;//Assisted|Network|Terminal = 010

_LIT(KTraceFileName,"lbssupltiapirequestor.cpp");

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

// CCLbsSuplTiApiRequestor::CCLbsSuplTiApiRequestor

// Other items were commented in a header

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

//

CCLbsSuplTiApiRequestor::CCLbsSuplTiApiRequestor(MLbsSuplTiObserver& aObserver,RSuplTerminalServer& aServer) :CActive(EPriorityStandard), // Standard priority

    iServer(aServer),iObserver(aObserver)

    {    

    }

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

//  CCLbsSuplTiApiRequestor::NewLC

// Other items were commented in a header

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

//

CCLbsSuplTiApiRequestor* CCLbsSuplTiApiRequestor::NewLC(MLbsSuplTiObserver& aObserver,RSuplTerminalServer& aServer)

    {

    CCLbsSuplTiApiRequestor* self = new (ELeave) CCLbsSuplTiApiRequestor(aObserver,aServer);

    CleanupStack::PushL(self);

    self->ConstructL();

    return self;

    }

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

// CCLbsSuplTiApiRequestor::NewL

// Other items were commented in a header

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

//

CCLbsSuplTiApiRequestor* CCLbsSuplTiApiRequestor::NewL(MLbsSuplTiObserver& aObserver,RSuplTerminalServer& aServer)

    {

    CCLbsSuplTiApiRequestor* self = CCLbsSuplTiApiRequestor::NewLC(aObserver,aServer);

    CleanupStack::Pop(); // self;

    return self;

    }

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

// CCLbsSuplTiApiRequestor::ConstructL

// Other items were commented in a header

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

//

void CCLbsSuplTiApiRequestor::ConstructL()

    {

    CActiveScheduler::Add(this); // Add to scheduler    

    iTrace = COMASuplTrace::NewL(); 

    iTrace->Trace(_L("CLbsSuplTiApiImplementation::ConstructL()"), KTraceFileName, __LINE__); 

    }

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

// CCLbsSuplTiApiRequestor::~CCLbsSuplTiApiRequestor

// Other items were commented in a header

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

//

CCLbsSuplTiApiRequestor::~CCLbsSuplTiApiRequestor()

    {

    Cancel(); // Cancel any request, if outstanding

    if(iSubSession.SubSessionHandle() != NULL)

        iSubSession.Close(); // Close sub-session

    if(iTrace)

        {

        iTrace->Trace(_L("CCLbsSuplTiApiRequestor::~CCLbsSuplTiApiRequestor..."), KTraceFileName, __LINE__); 

        delete iTrace;

        iTrace = NULL;

        }

    }

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

// CCLbsSuplTiApiRequestor::DoCancel

// Other items were commented in a header

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

//

void CCLbsSuplTiApiRequestor::DoCancel()

    {

    iTrace->Trace(_L("CLbsSuplTiApiImplementation::DoCancel()"), KTraceFileName, __LINE__);

    if(iSubSession.SubSessionHandle() != NULL)

        {

        iTrace->Trace(_L("CLbsSuplTiApiImplementation::subsession handle not NULL calling cancel runsession)"), KTraceFileName, __LINE__);

        iSubSession.CancelRunSession();

        iObserver.RequestComplete(KErrCancel,iNetSessionId);

        }

    }

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

// CCLbsSuplTiApiRequestor::RequestLocation

// Other items were commented in a header

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

//

void CCLbsSuplTiApiRequestor::RequestLocation(const TLbsNetSessionId& aSessionId, const TLbsNetPosRequestOptionsBase& aOptions, const TLbsNetPosRequestMethod& aMethod)

    {

    iTrace->Trace(_L("CCLbsSuplTiApiRequestor::RequestLocation()"), KTraceFileName, __LINE__);

    Cancel(); // Cancel any request, just to be sure

    iState = EUninitialized;

    iNetSessionId = aSessionId;

    if(iSubSession.SubSessionHandle() == NULL)

        {

        TInt error = iSubSession.Open( iServer );

        //If can't open session signal error to client

        if ( error != KErrNone )

            {

            iStatus = KRequestPending;

            iTrace->Trace(_L("Subsession handle open failed"), KTraceFileName, __LINE__);

            SetActive();

            TRequestStatus* status = &iStatus;

            User::RequestComplete( status, error );

            return;

            }

        iTrace->Trace(_L("Subsession handle open succeeded"), KTraceFileName, __LINE__);

        }

    TInt setCaps = ProcessPosMethods(aMethod);

    if ( setCaps < 0 )

        {

        iStatus = KRequestPending;

        iTrace->Trace(_L("process pos methods failed"), KTraceFileName, __LINE__);

        SetActive();

        TRequestStatus* status = &iStatus;

        User::RequestComplete( status, KErrArgument );

        return;

        }

    else

    	{

    	TBuf<32> setcapsbuf;

    	setcapsbuf.Copy(_L("Final Set Caps = "));

    	setcapsbuf.AppendNum(setCaps);

    	iTrace->Trace(setcapsbuf,KTraceFileName,__LINE__);

    	}

    //convert TLbsNetPosRequestOptions to TSuplTerminalQop

    TLbsNetPosRequestQuality quality;

    TLbsNetPosRequestOptionsBase& optionsbase = const_cast<TLbsNetPosRequestOptionsBase&>(aOptions);

    TLbsNetPosRequestOptions& options = static_cast<TLbsNetPosRequestOptions&>(optionsbase);

    options.GetRequestQuality(quality);

     if(quality.MinHorizontalAccuracy() != 0)//mandatory value has been set, so use RunSession with Qop

        {

        TSuplTerminalQop qop;

        qop.SetHorizontalAccuracy(quality.MinHorizontalAccuracy());

        if(quality.MinVerticalAccuracy() != 0)

            qop.SetVerticalAccuracy(quality.MinVerticalAccuracy());

        TInt maxAge = quality.MaxFixAge().Int64()/1000000;

        if(maxAge != 0)

            qop.SetMaxLocationAge(maxAge);

        TInt delay = quality.MaxFixTime().Int64()/1000000;

        if(delay != 0)

            qop.SetDelay(delay);

        iTrace->Trace(_L("CCLbsSuplTiApiRequestor:Calling RunSession-with qop "), KTraceFileName, __LINE__);

         //use terminal initiation library to make request

         iSubSession.RunSession(iStatus,qop,setCaps,iNetSessionId.SessionNum(),options.NewClientConnected());

         SetActive(); // Tell scheduler a request is active

        }

    else // no qop available so call run session without qop

        {

        iTrace->Trace(_L("CCLbsSuplTiApiRequestor:Calling Run Session-no qop "), KTraceFileName, __LINE__);

        //use terminal initiation library to make request

        iSubSession.RunSession(iStatus,setCaps,iNetSessionId.SessionNum(),options.NewClientConnected());

        SetActive(); // Tell scheduler a request is active

        }

    }

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

// CCLbsSuplTiApiRequestor::RunL

// Other items were commented in a header

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

//

void CCLbsSuplTiApiRequestor::RunL()

    {

    if (iState == EUninitialized)

        {

        iState = EInitialized;

        iTrace->Trace(_L("CCLbsSuplTiApiRequestor :Run Session completed"), KTraceFileName, __LINE__);

        iObserver.RequestComplete(iStatus.Int(),iNetSessionId);

        }

    }

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

// CCLbsSuplTiApiRequestor::RunError

// Other items were commented in a header

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

//

TInt CCLbsSuplTiApiRequestor::RunError(TInt aError)

    {

    iTrace->Trace(_L("CCLbsSuplTiApiRequestor :RunError called"), KTraceFileName, __LINE__);

    iObserver.RequestComplete(aError,iNetSessionId);

    return aError;

    }

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

// CCLbsSuplTiApiRequestor::GetPosition

// Other items were commented in a header

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

//

TInt CCLbsSuplTiApiRequestor::GetPosition(TPositionInfoBase& aPositionInfo)

    {

    // if run session was called before calling GetPosition and completed successfully

    if(iState == EInitialized && iStatus.Int() == KErrNone) 

        {

        //Runsession has completed, so call get position and return the position

        iTrace->Trace(_L("CCLbsSuplTiApiRequestor :Calling get position"), KTraceFileName, __LINE__);

        return iSubSession.GetPosition(aPositionInfo);

        }

    else

        {

        iTrace->Trace(_L("CCLbsSuplTiApiRequestor::GetPosition returning -1"), KTraceFileName, __LINE__);

        return KErrNotFound; //Check this error code

        }

    }

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

// CCLbsSuplTiApiRequestor::GetSessionId

// Other items were commented in a header

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

//

TLbsNetSessionId CCLbsSuplTiApiRequestor::GetSessionId()

    {

    return iNetSessionId;

    }

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

// CCLbsSuplTiApiRequestor::ProcessPosMethods

// Other items were commented in a header

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

//

TInt CCLbsSuplTiApiRequestor::ProcessPosMethods( const TLbsNetPosRequestMethod& aMethod)

    {

    TInt setcaps = 0;

    TInt numOfPosMethods = aMethod.NumPosMethods();

    if(numOfPosMethods == 0)

        {

        iTrace->Trace(_L("CCLbsSuplTiApiRequestor::ProcessPosMethods pos methods zero"), KTraceFileName, __LINE__);

        return KErrArgument;

        }

    TInt methods = 0;

    for(TInt methodIter = 0; methodIter < numOfPosMethods; methodIter++)

        {

        TLbsNetPosMethod posMethod;

        aMethod.GetPosMethod(methodIter,posMethod);

        methods |= posMethod.PosMode();

        }

    if(methods == KSetBasedBits)

        {

        iTrace->Trace(_L("CCLbsSuplTiApiRequestor::ProcessPosMethods Recieved SET Based"), KTraceFileName, __LINE__);

        setcaps |= KGpsSETBased;

        }

    else if(methods == KSetAssistedBits)

        {

        iTrace->Trace(_L("CCLbsSuplTiApiRequestor::ProcessPosMethods Recieved SET Assisted"), KTraceFileName, __LINE__);

        setcaps |= KGpsSETAssisted;

        }

    else if(methods == KNetworkBits)

        {

        iTrace->Trace(_L("CCLbsSuplTiApiRequestor::ProcessPosMethods Recieved only Network"), KTraceFileName, __LINE__);

        setcaps |= KAutonomousGps|KAFLT |KECID|KEOTD|KOTDOA;

        }

    else

        {

        iTrace->Trace(_L("CCLbsSuplTiApiRequestor::ProcessPosMethods enabling all"), KTraceFileName, __LINE__);

        setcaps |= KGpsSETAssisted | KGpsSETBased | KAutonomousGps|KAFLT |  

                       KECID|KEOTD|KOTDOA;

        }

    return setcaps;

    }