/*

* Copyright (c) 2002-2007 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:  A remote sim store implementation

*

*/

// INCLUDE FILES

#include "CRemoteStore.h"

// From Virtual Phonebook

#include "VPbkSimStoreError.h"

#include "CRemoteView.h"

#include <MVPbkSimStoreObserver.h>

#include <MVPbkSimContactObserver.h>

#include <MVPbkSimFindObserver.h>

#include <VPbkSimServerOpCodes.h>

#include <VPbkSimStoreTemplateFunctions.h>

#include <CVPbkSimContactBuf.h>

#include <MVPbkSimPhoneObserver.h>

#include <CVPbkETelCntConverter.h>

#include <CVPbkSimFieldTypeFilter.h>

#include <MVPbkSimStoreOperation.h>

#include <MVPbkSimCntView.h>

#include <VPbkSimStoreCommonUtil.h>

#include <CVPbkAsyncOperation.h>

#include <CVPbkAsyncCallback.h>

#include <VPbkDebug.h>

// System includes

#include <s32mem.h>

namespace VPbkSimStore {

// CONSTANTS

// The initial buffer size for number match results, 10 indexes

const TInt KInitSimIndexBufSize = 10 * sizeof(TInt);

// The maximum buffer size for number match results if server behaves badly

const TInt KMaxSimIndexBufSize = 100 * KInitSimIndexBufSize;

// ============================= LOCAL FUNCTIONS ============================

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

// SendStoreEventMessage

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

//

template<class Function, class Param>

inline void SendStoreEventMessage(

    RPointerArray<MVPbkSimStoreObserver>& aObservers, Function aFunction,

    Param& aParam )

    {

    const TInt count = aObservers.Count();

    for ( TInt i = count - 1; i >= 0; --i )

        {

        ( aObservers[i]->*aFunction )( aParam );

        }

    }

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

// SendStoreErrorMessage

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

//

inline void SendStoreErrorMessage( 

    RPointerArray<MVPbkSimStoreObserver>& aObservers, MVPbkSimCntStore& aStore,

    TInt aError )

    {

    const TInt count = aObservers.Count();

    for ( TInt i = count - 1; i >= 0; --i )

        {

        aObservers[i]->StoreError( aStore, aError );

        }

    }

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

// SendStoreEventMessage

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

//

inline void SendStoreEventMessage(

    RPointerArray<MVPbkSimStoreObserver>& aObservers,

    void (MVPbkSimStoreObserver::*aEvent)(MVPbkSimStoreObserver::TEvent, TInt),

    MVPbkSimStoreObserver::TEvent aEventType,

    TInt aParam1)

    {

    for (TInt i = aObservers.Count() - 1; i >= 0; --i)

        {

        (aObservers[i]->*aEvent)( aEventType, aParam1 );

        }    

    }    

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

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

// CAsyncSave::CAsyncSave

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

// might leave.

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

//

CAsyncSave::CAsyncSave( RVPbkSimStore& aStore )

:   CActive( EPriorityStandard ),

    iStore( aStore )

    {

    CActiveScheduler::Add( this );

    }

// Destructor

CAsyncSave::~CAsyncSave()

    {

    Cancel();

    }

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

// CAsyncSave::DoRequestL

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

//

void CAsyncSave::DoRequestL( const TDesC8& aData, 

    TInt& aSimIndex, MVPbkSimContactObserver& aObserver )

    {

    VPBK_DEBUG_PRINT(VPBK_DEBUG_STRING(

        "CAsyncSave::DoRequestL: aSimIndex %d"),

        aSimIndex );

    iObserver = &aObserver;

    iStore.SaveL( iStatus, aData, aSimIndex );

    SetActive();

    }

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

// CAsyncSave::RunL

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

//

void CAsyncSave::RunL()

    {

    VPBK_DEBUG_PRINT(VPBK_DEBUG_STRING(

        "CAsyncSave::RunL: iStatus %d"),

        iStatus.Int() );

    TInt result = iStatus.Int();

    if ( result == KErrNone )

        {

        iObserver->ContactEventComplete( MVPbkSimContactObserver::ESave, NULL );

        }

    else

        {

        iObserver->ContactEventError( MVPbkSimContactObserver::ESave, NULL, 

            result );

        }

    }

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

// CAsyncSave::DoCancel

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

//

void CAsyncSave::DoCancel()

    {

    iStore.CancelAsyncRequest( EVPbkSimSrvSaveContact );

    }

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

// CAsyncDelete::CAsyncDelete

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

// might leave.

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

//

CAsyncDelete::CAsyncDelete( RVPbkSimStore& aStore )

:   CActive( EPriorityStandard ),

    iStore( aStore )

    {

    CActiveScheduler::Add( this );

    }

// Destructor

CAsyncDelete::~CAsyncDelete()

    {

    Cancel();

    }

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

// CAsyncDelete::DoRequestL

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

//

void CAsyncDelete::DoRequestL( 

        RVPbkStreamedIntArray& aSimIndexes, 

        MVPbkSimContactObserver& aObserver )

    {

    iObserver = &aObserver;

    iStore.DeleteL( iStatus, aSimIndexes );

    SetActive();

    }

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

// CAsyncDelete::RunL

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

//

void CAsyncDelete::RunL()

    {

    TInt result = iStatus.Int();

    if ( result == KErrNone )

        {

        iObserver->ContactEventComplete( MVPbkSimContactObserver::EDelete, 

            NULL );

        }

    else

        {

        iObserver->ContactEventError( MVPbkSimContactObserver::EDelete, 

            NULL, result );

        }

    }

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

// CAsyncDelete::DoCancel

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

//

void CAsyncDelete::DoCancel()

    {

    iStore.CancelAsyncRequest( EVPbkSimSrvDeleteContact );

    }

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

// CRemoteStore::CNumberMatchOperation::CNumberMatchOperation

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

// might leave.

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

//

CRemoteStore::CNumberMatchOperation::CNumberMatchOperation( 

    CRemoteStore& aStore, const TDesC& aPhoneNumber, 

    TInt aMaxMatchDigits, MVPbkSimFindObserver& aObserver )

    :   CActive( EPriorityStandard ),

        iStore( aStore ),

        iPhoneNumber( aPhoneNumber ),

        iMaxMatchDigits( aMaxMatchDigits ),

        iObserver( aObserver ),

        iSimIndexBufPtr( NULL, 0 )

    {

    }

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

// CRemoteStore::CNumberMatchOperation::ConstructL

// Symbian 2nd phase constructor can leave.

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

//

void CRemoteStore::CNumberMatchOperation::ConstructL()

    {

    CActiveScheduler::Add( this );

    iSimIndexBuf = HBufC8::NewL( KInitSimIndexBufSize );

    iSimIndexBufPtr.Set( iSimIndexBuf->Des() );

    }

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

// CRemoteStore::CNumberMatchOperation::NewL

// Two-phased constructor.

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

//

CRemoteStore::CNumberMatchOperation* CRemoteStore::CNumberMatchOperation::NewL( 

    CRemoteStore& aStore, const TDesC& aPhoneNumber, 

    TInt aMaxMatchDigits, MVPbkSimFindObserver& aObserver )

    {

    CNumberMatchOperation* self = new( ELeave ) CNumberMatchOperation( aStore, 

        aPhoneNumber, aMaxMatchDigits, aObserver );

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    return self;

    }

// Destructor

CRemoteStore::CNumberMatchOperation::~CNumberMatchOperation()

    {

    Cancel();

    delete iSimIndexBuf;

    }

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

// CRemoteStore::CNumberMatchOperation::Activate

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

//

void CRemoteStore::CNumberMatchOperation::Activate()

    {

    iStore.StoreSession().MatchPhoneNumber( iStatus, iPhoneNumber, 

        iMaxMatchDigits, iSimIndexBufPtr );

    SetActive();

    }

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

// CRemoteStore::CNumberMatchOperation::RunL

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

//

void CRemoteStore::CNumberMatchOperation::RunL()

    {

    RVPbkStreamedIntArray matchedIndexes;

    CleanupClosePushL( matchedIndexes );

    TInt result = iStatus.Int();

    switch ( result )

        {

        case KErrNone:

            {

            RDesReadStream stream( iSimIndexBufPtr );

            CleanupClosePushL( stream );

            stream >> matchedIndexes;

            CleanupStack::PopAndDestroy(); // stream

            iObserver.FindCompleted( iStore, matchedIndexes );

            break;

            }

        case KErrNotFound:

            {

            iObserver.FindCompleted( iStore, matchedIndexes );

            break;

            }

        case KErrOverflow:

            {

            TInt newLength = 2 * iSimIndexBufPtr.MaxLength();

            if ( newLength > KMaxSimIndexBufSize )

                {

                iObserver.FindError( iStore, result );

                }

            else

                {

                VPbkSimStoreImpl::CheckAndUpdateBufferSizeL( iSimIndexBuf, 

                    iSimIndexBufPtr, newLength );

                Activate();

                }

            break;

            }

        default:

            {

            iObserver.FindError( iStore, result );

            break;

            }

        }

    CleanupStack::PopAndDestroy(); // matchedIndexes

    }

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

// CRemoteStore::CNumberMatchOperation::DoCancel

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

//

void CRemoteStore::CNumberMatchOperation::DoCancel()

    {

    iStore.StoreSession().CancelAsyncRequest( EVPbkSimSrvMatchPhoneNumber );

    }

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

// CRemoteStore::CNumberMatchOperation::RunError

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

//

TInt CRemoteStore::CNumberMatchOperation::RunError( TInt aError )

    {

    iObserver.FindError( iStore, aError );

    return KErrNone;

    }

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

// CRemoteStore::CFindOperation::CFindOperation

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

// might leave.

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

//

CRemoteStore::CFindOperation::CFindOperation( CRemoteStore& aStore,

    const TDesC& aStringToFind, MVPbkSimFindObserver& aObserver )

:   CActive( EPriorityStandard ),

    iStore( aStore ),

    iStringToFind( aStringToFind ),

    iObserver( aObserver ),

    iSimIndexBufPtr( NULL, 0 )

    {

    }

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

// CRemoteStore::CFindOperation::ConstructL

// Symbian 2nd phase constructor can leave.

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

//

void CRemoteStore::CFindOperation::ConstructL( 

    RVPbkSimFieldTypeArray& aFieldTypes )

    {

    CActiveScheduler::Add( this );

    iFieldTypes = ExternalizeArrayLC( aFieldTypes );

    CleanupStack::Pop( iFieldTypes );

    iSimIndexBuf = HBufC8::NewL( KInitSimIndexBufSize );

    iSimIndexBufPtr.Set( iSimIndexBuf->Des() );

    }

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

// CRemoteStore::CFindOperation::NewL

// Two-phased constructor.

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

//

CRemoteStore::CFindOperation* CRemoteStore::CFindOperation::NewL( 

    CRemoteStore& aStore, const TDesC& aStringToFind, 

    MVPbkSimFindObserver& aObserver, RVPbkSimFieldTypeArray& aFieldTypes )

    {

    CFindOperation* self = 

        new( ELeave ) CFindOperation( aStore, aStringToFind, aObserver );

    CleanupStack::PushL( self );

    self->ConstructL( aFieldTypes );

    CleanupStack::Pop( self );

    return self;

    }

// Destructor

CRemoteStore::CFindOperation::~CFindOperation()

    {

    Cancel();

    delete iSimIndexBuf;

    delete iFieldTypes;

    }

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

// CRemoteStore::CFindOperation::Activate

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

//

void CRemoteStore::CFindOperation::Activate()

    {

    iStore.StoreSession().Find( iStatus, iStringToFind, 

        *iFieldTypes, iSimIndexBufPtr );

    SetActive();

    }

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

// CRemoteStore::CFindOperation::RunL

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

//

void CRemoteStore::CFindOperation::RunL()

    {

    RVPbkStreamedIntArray matchedIndexes;

    CleanupClosePushL( matchedIndexes );

    TInt result = iStatus.Int();

    switch ( result )

        {

        case KErrNone:

            {

            RDesReadStream stream( iSimIndexBufPtr );

            CleanupClosePushL( stream );

            stream >> matchedIndexes;

            CleanupStack::PopAndDestroy(); // stream

            iObserver.FindCompleted( iStore, matchedIndexes );

            break;

            }

        case KErrNotFound:

            {

            iObserver.FindCompleted( iStore, matchedIndexes );

            break;

            }

        case KErrOverflow:

            {

            TInt newLength = 2 * iSimIndexBufPtr.MaxLength();

            if ( newLength > KMaxSimIndexBufSize )

                {

                iObserver.FindError( iStore, result );

                }

            else

                {

                VPbkSimStoreImpl::CheckAndUpdateBufferSizeL( iSimIndexBuf, 

                    iSimIndexBufPtr, newLength );

                Activate();

                }

            break;

            }

        default:

            {

            iObserver.FindError( iStore, result );

            break;

            }

        }

    CleanupStack::PopAndDestroy(); // matchedIndexes

    }

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

// CRemoteStore::CFindOperation::DoCancel

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

//

void CRemoteStore::CFindOperation::DoCancel()

    {

    iStore.StoreSession().CancelAsyncRequest( EVPbkSimSrvFind );

    }

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

// CRemoteStore::CFindOperation::RunError

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

//

TInt CRemoteStore::CFindOperation::RunError( TInt aError )

    {

    iObserver.FindError( iStore, aError );

    return KErrNone;

    }

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

// CRemoteStore::CRemoteStore

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

// might leave.

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

//

CRemoteStore::CRemoteStore( TVPbkSimStoreIdentifier aIdentifier )

:   CActive( EPriorityStandard ),

    iIdentifier( aIdentifier ),

    iCurrentState( EVPbkSimUnknown )

    {

    }

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

// CRemoteStore::ConstructL

// Symbian 2nd phase constructor can leave.

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

//

void CRemoteStore::ConstructL()

    {

    CActiveScheduler::Add( this );

    iContactConverter = CVPbkETelCntConverter::NewL();

    iCurrentETelContact = CVPbkSimContactBuf::NewL( *this );

    iCurrentContact = CVPbkSimContactBuf::NewL( *this );

    iSystemPhoneNumberMaxLength = 

        VPbkSimStoreCommonUtil::SystemMaxPhoneNumberLengthL();