/*
* 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 contact operation for commtting multiple contacts
*
*/


// INCLUDE FILES
#include "CCommitContactsOperation.h"

#include <MVPbkBatchOperationObserver.h>
#include <MVPbkStoreContact.h>
#include "VPbkSimStoreError.h"

namespace VPbkSimStore {

// CONSTANTS

// Contacts are commited 1 contact at a time
const TInt KStepSize = 1;

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

// -----------------------------------------------------------------------------
// SendStepFailed
// Send step failed event to given observer.
// -----------------------------------------------------------------------------
//
inline TBool SendStepFailed( CCommitContactsOperation& aOperation, TInt aError,
    MVPbkBatchOperationObserver& aObserver )
    { 
    return aObserver.StepFailed( aOperation, KStepSize, aError );
    }

// -----------------------------------------------------------------------------
// SendStepComplete
// Send step completed event to given observer.
// -----------------------------------------------------------------------------
//
inline void SendStepComplete( CCommitContactsOperation& aOperation,
    MVPbkBatchOperationObserver& aObserver )
    {
    aObserver.StepComplete( aOperation, KStepSize );
    }

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

// -----------------------------------------------------------------------------
// CCommitContactsOperation::CCommitContactsOperation
// C++ default constructor can NOT contain any code, that
// might leave.
// -----------------------------------------------------------------------------
//
CCommitContactsOperation::CCommitContactsOperation( CContactStore& aStore,
    MVPbkBatchOperationObserver& aObserver )
    :   iStore( aStore ),
        iObserver( aObserver )
    {
    }

// -----------------------------------------------------------------------------
// CCommitContactsOperation::ConstructL
// Symbian 2nd phase constructor can leave.
// -----------------------------------------------------------------------------
//
void CCommitContactsOperation::ConstructL( 
    const TArray<MVPbkStoreContact*>& aContacts )
    {
    const TInt count = aContacts.Count();
    for ( TInt i = 0; i < count; ++i )
        {
        iStoreContacts.AppendL( aContacts[i] );
        }
    }

// -----------------------------------------------------------------------------
// CCommitContactsOperation::NewL
// Two-phased constructor.
// -----------------------------------------------------------------------------
//
CCommitContactsOperation* CCommitContactsOperation::NewL( 
    CContactStore& aStore, 
    MVPbkBatchOperationObserver& aObserver,
    const TArray<MVPbkStoreContact*>& aContacts )
    {
    CCommitContactsOperation* self = 
        new( ELeave ) CCommitContactsOperation( aStore, aObserver );
    CleanupStack::PushL( self );
    self->ConstructL( aContacts );
    CleanupStack::Pop( self );
    return self;
    }

    
// Destructor
CCommitContactsOperation::~CCommitContactsOperation()
    {
    iStoreContacts.Close();
    }

// -----------------------------------------------------------------------------
// CCommitContactsOperation::StartL
// -----------------------------------------------------------------------------
//
void CCommitContactsOperation::StartL()
    {
    __ASSERT_DEBUG( iStoreContacts.Count() > 0,
        VPbkSimStore::Panic( VPbkSimStore::EZeroCommitContacts ) );
    iCommitCounter = 0;
    User::LeaveIfError( NextCycle() );
    }

// -----------------------------------------------------------------------------
// CCommitContactsOperation::Cancel
// -----------------------------------------------------------------------------
//
void CCommitContactsOperation::Cancel()
    {
    iCommitCounter = iStoreContacts.Count();
    }

// -----------------------------------------------------------------------------
// CCommitContactsOperation::ContactOperationCompleted
// -----------------------------------------------------------------------------
//
void CCommitContactsOperation::ContactOperationCompleted( 
    TContactOpResult /*aResult*/ )
    {
    if ( iCommitCounter >= iStoreContacts.Count() )
        {
        iObserver.OperationComplete( *this );
        }
    else
        {
        SendStepComplete( *this, iObserver );
        TryCommitNext();
        }
    }
  
// -----------------------------------------------------------------------------
// CCommitContactsOperation::ContactOperationFailed
// -----------------------------------------------------------------------------
//   
void CCommitContactsOperation::ContactOperationFailed( TContactOp /*aOpCode*/, 
    TInt aErrorCode, TBool /*aErrorNotified*/ )
    {
    if ( SendStepFailed( *this, aErrorCode, iObserver ) )
        {
        // Continue only if ETrue is returned. Otherwise this operation might
        // be already deleted.
        TryCommitNext();        
        }
    }

// -----------------------------------------------------------------------------
// CCommitContactsOperation::NextCycle
// -----------------------------------------------------------------------------
//
TInt CCommitContactsOperation::NextCycle()
    {
    TRAPD( result, iStoreContacts[iCommitCounter]->CommitL( *this ) );
    ++iCommitCounter;
    return result;
    }

// -----------------------------------------------------------------------------
// CCommitContactsOperation::TryCommitNext
// -----------------------------------------------------------------------------
//
void CCommitContactsOperation::TryCommitNext()
    {
    const TInt totalCount = iStoreContacts.Count(); 
    TInt result = KErrNone;
    TBool abortedByClient = EFalse;
    do
        {
        result = NextCycle();
        if ( result != KErrNone )
            {
            if ( !SendStepFailed( *this, result, iObserver ) )
                {
                // Set aborted, we can't continue because this operation might
                // be already deleted.
                abortedByClient = ETrue;
                }
            }
        } while ( !abortedByClient &&           // Client is not aborted this operation
                  result != KErrNone && 
                  iCommitCounter < totalCount );
                  
    if ( !abortedByClient && result != KErrNone && iCommitCounter >= totalCount )
        {
        iObserver.OperationComplete( *this );
        }
    }
} // namespace VPbkSimStore
//  End of File