/*
* 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: Operation for reading partial landmarks.
*
*
*/


// INCLUDE FILES
#include    <eposlmasyncops.rsg>
#include    <EPos_LandmarksErrors.h>
#include    <epos_cposlmresourcereader.h>
#include    <EPos_PosLmImplExtension.h>
#include    <epos_poslmlandmarkhandler.h>
#include    <epos_cposlmlocaldbaccess.h>
#include    "EPos_CPosLmLocalReadPartialLmOp.h"
#include    "EPos_LocalLandmarks.h"
#include    "epos_cposlmlocaldatabase.h"

//CONSTANTS
const TInt KGranularity = 5;
const TReal32 KOperationDone = 1;

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

// -----------------------------------------------------------------------------
// CPosLmLocalReadPartialLmOp::CPosLmLocalReadPartialLmOp
// C++ default constructor can NOT contain any code, that
// might leave.
// -----------------------------------------------------------------------------
//
CPosLmLocalReadPartialLmOp::CPosLmLocalReadPartialLmOp(
    CPosLmLocalDatabase& aDb) :
    CPosLmLocalOperation(aDb),
    iStatusFlag(KPosLmOperationNotComplete)
    {
    }

// -----------------------------------------------------------------------------
// CPosLmLocalReadPartialLmOp::ConstructL
// Symbian 2nd phase constructor can leave.
// -----------------------------------------------------------------------------
//
void CPosLmLocalReadPartialLmOp::ConstructL(
    const RArray<TPosLmItemId>& aLandmarkIdArray,
    CPosLmPartialReadParameters* aPartialSettings)
    {
    BaseConstructL();

    if (aLandmarkIdArray.Count() == 0)
        {
        User::Leave(KErrArgument);
        }

    iPartialSettings = CPosLmPartialReadParameters::NewLC();
    CleanupStack::Pop(iPartialSettings);

    iDb->CopyPartialSettingsL(*aPartialSettings, *iPartialSettings);

    for (TInt i = 0; i < aLandmarkIdArray.Count(); i++)
        {
        User::LeaveIfError(iLandmarkIdArray.Append(aLandmarkIdArray[i]));
        }

    iLmArray = new (ELeave) CArrayPtrFlat<CPosLandmark>(KGranularity);

    ReadInfoFromResourceFileL();
    AquireLockL(CPosLmLocalDatabase::EReadLock);
    }

// -----------------------------------------------------------------------------
// CPosLmLocalReadPartialLmOp::NewL
// Two-phased constructor.
// -----------------------------------------------------------------------------
//
CPosLmLocalReadPartialLmOp* CPosLmLocalReadPartialLmOp::NewL(
    CPosLmLocalDatabase& aDb,
    const RArray<TPosLmItemId>& aLandmarkIdArray,
    CPosLmPartialReadParameters* aPartialSettings)
    {
    CPosLmLocalReadPartialLmOp* self = new (ELeave)
        CPosLmLocalReadPartialLmOp(aDb);

    CleanupStack::PushL(self);
    self->ConstructL(aLandmarkIdArray, aPartialSettings);
    CleanupStack::Pop(self);

    return self;
    }

// Destructor
CPosLmLocalReadPartialLmOp::~CPosLmLocalReadPartialLmOp()
    {
    delete iPartialSettings;
    iLandmarkIdArray.Close();
    if (iLmArray)
        {
        iLmArray->ResetAndDestroy();
        delete iLmArray;
        }
    }

// -----------------------------------------------------------------------------
// CPosLmLocalReadPartialLmOp::NextStepL
//
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
TInt CPosLmLocalReadPartialLmOp::NextStepL(
    TReal32& aProgress)
    {
    for (TInt i = 0; i < iRequestCounter &&
        iCurrent < iLandmarkIdArray.Count(); i++)
        {
        AddLandmarkToArrayL(iCurrent++);
        }

    if (iCurrent == iLandmarkIdArray.Count())
        {
        iStatusFlag = KErrNone;
        aProgress = KOperationDone;
        ReleaseLock();
        }
    else
        {
        aProgress = TReal32(iCurrent)/iLandmarkIdArray.Count();
        }

    return iStatusFlag;
    }

// -----------------------------------------------------------------------------
// CPosLmLocalReadPartialLmOp::HandleError
//
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void CPosLmLocalReadPartialLmOp::HandleError(
    TInt& aError)
    {
    iStatusFlag = aError;

    ReleaseLock();
    }

// -----------------------------------------------------------------------------
// CPosLmLocalReadPartialLmOp::GetResultL
//
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
CArrayPtr<CPosLandmark>* CPosLmLocalReadPartialLmOp::GetResultL()
    {
    if (!iLmArray || iStatusFlag == KPosLmOperationNotComplete)
        {
        User::Leave(KErrNotFound);
        }

    for (TInt i = iCurrent; i < iLandmarkIdArray.Count(); i++)
        {
        iLmArray->AppendL(NULL);
        }

    CArrayPtr<CPosLandmark>* result = iLmArray;
    iLmArray = NULL;
    return result;
    }

// -----------------------------------------------------------------------------
// CPosLmLocalReadPartialLmOp::AddLandmarkToArrayL
//
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void CPosLmLocalReadPartialLmOp::AddLandmarkToArrayL(TInt aIndex)
    {
    CPosLandmark* landmark = CPosLandmark::NewLC();
    PosLmImplExtension::SetLandmarkIdL(*landmark, iLandmarkIdArray[aIndex]);

    TRAPD(err, PosLmLandmarkHandler::ReadPartialLandmarkL(
        *iDb->DatabaseAccess(), *landmark, *iPartialSettings));

    if (err == KErrNone)
        {
        iLmArray->AppendL(landmark);
        CleanupStack::Pop(landmark); // Transfer ownership to array
        }
    else if (err == KErrNotFound)
        {
        iLmArray->AppendL(NULL);
        CleanupStack::PopAndDestroy(landmark);
        }
    else
        {
        User::Leave(err);
        }
    }

// -----------------------------------------------------------------------------
// CPosLmLocalReadPartialLmOp::ReadInfoFromResourceFileL
//
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void CPosLmLocalReadPartialLmOp::ReadInfoFromResourceFileL()
    {
    CPosLmResourceReader* resources =
        CPosLmResourceReader::NewLC(KPosLocalSuboperationResourceFile);

    iRequestCounter = resources->ReadInt32L(
        R_POS_LM_LOCAL_READ_PARTIAL_LMS_OP);

    if (iRequestCounter <= 0)
        {
        Panic(KPosLandmarksClientPanic,
            EPosInvalidValueSpecifiedInResourceFile);
        }

    CleanupStack::PopAndDestroy(resources);
    }

//  End of File