/*
* Copyright (c) 2005-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:  An implementation for find operation. Can be used e.g
*                in store domain implementation to handle Find -operations
*                from stores.
*
*/


#include "CVPbkContactFindOperation.h"

#include <CVPbkContactLinkArray.h>
#include <MVPbkContactLink.h>

CVPbkContactFindOperation::CVPbkContactFindOperation(
        MVPbkContactFindObserver& aObserver) :
    iObserver(aObserver)
    {
    }

inline void CVPbkContactFindOperation::ConstructL()
    {
    }

EXPORT_C CVPbkContactFindOperation* CVPbkContactFindOperation::NewLC(
        MVPbkContactFindObserver& aObserver)
    {
    CVPbkContactFindOperation* self = new(ELeave) CVPbkContactFindOperation(aObserver);
    CleanupStack::PushL(self);
    self->ConstructL();
    return self;
    }

CVPbkContactFindOperation::~CVPbkContactFindOperation()
    {
    delete iResults;
    }

void CVPbkContactFindOperation::HandleZeroSuboperations()
    {
    // If no suboperations then complete find with empty array.
    // If completing leaves then call FindFailed 
    TRAPD( res, HandleZeroSuboperationsL() );
    if ( res != KErrNone )
        {
        iObserver.FindFailed( res );
        }
    }
    
void CVPbkContactFindOperation::FindCompleteL(MVPbkContactLinkArray* aResults)
    {
    ++iCompleteCount;

    // take ownership of aResults immediately
    MVPbkContactLinkArray* passedResults = aResults;
    CleanupDeletePushL(passedResults);

    // lazy creation of result array
    if (!iResults)
        {
        iResults = CVPbkContactLinkArray::NewL();
        }

    if (aResults)
        {
        // append results to this operations array
        for (TInt i = aResults->Count() - 1; i >= 0; --i)
            {
            MVPbkContactLink* link = aResults->At(i).CloneLC();
            iResults->AppendL(link);
            CleanupStack::Pop(); // link
            }
        }
    CleanupStack::PopAndDestroy(passedResults);

    // notify clients if all suboperations have completed
    if (iCompleteCount >= SubOperationCount())
        {
        // takes ownership of results
        CVPbkContactLinkArray* results = iResults;
        iResults = NULL;
        iObserver.FindCompleteL(results);
        }
    }

void CVPbkContactFindOperation::FindFailed(TInt aError)
    {
    ++iCompleteCount;

    // notify clients if all suboperations have completed
    if (iCompleteCount >= SubOperationCount())
        {
        // if there are results give them to the client
        if (iResults)
            {
            // the observer takes ownership of results
            CVPbkContactLinkArray* results = iResults;
            iResults = NULL;
            TRAPD(err, iObserver.FindCompleteL(results));
            if (err)
                {
                // client must take ownership of results before it can leave
                iObserver.FindFailed(aError);
                }
            }
        else
            {
            // otherwise inform find failure
            iObserver.FindFailed(aError);
            }
        }
    }
    
// -----------------------------------------------------------------------------
// CVPbkContactFindOperation::HandleZeroSuboperationsL
// -----------------------------------------------------------------------------
//     
void CVPbkContactFindOperation::HandleZeroSuboperationsL()
    {
    CVPbkContactLinkArray* emptyResults = CVPbkContactLinkArray::NewL();
    // Client takes the ownership of the results
    iObserver.FindCompleteL( emptyResults );
    }
// End of File