/*
* 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:  The virtual phonebook find operation
*
*/



#include "CFindOperation.h"
#include "CContactLink.h"
#include "CContactStore.h"
#include "CFieldFactory.h"
#include <cntfield.h>

#include <MVPbkFieldType.h>
#include <MVPbkContactFindObserver.h>

namespace VPbkCntModel {

CFindOperation::CFindOperation(
        CContactStore& aContactStore, 
        MVPbkContactFindObserver& aObserver ) :
    CActive( CActive::EPriorityIdle ),
    iContactStore( aContactStore),
    iObserver( aObserver )
    {
    CActiveScheduler::Add( this );
    }

inline void CFindOperation::ConstructL(
        const TDesC& aSearchString, 
        const MVPbkFieldTypeList& aFieldTypes )
    {
    iSearchString = aSearchString.AllocL();
    iFieldDef = new ( ELeave ) CContactItemFieldDef;
    
    const TInt fieldCount = aFieldTypes.FieldTypeCount();
    iFieldDef->SetReserveL( fieldCount );
    for ( TInt i = 0; i < fieldCount; ++i )
        {
        const CContactItemField* field = 
            iContactStore.FieldFactory().FindField( aFieldTypes.FieldTypeAt(i) );
        if ( field )
            {
            iFieldDef->AppendL( field->ContentType().FieldType(0) );
            }
        }
    iResults = CVPbkContactLinkArray::NewL();
    }

CFindOperation* CFindOperation::NewL(
        CContactStore& aContactStore, 
        const TDesC& aSearchString, 
        const MVPbkFieldTypeList& aFieldTypes,
        MVPbkContactFindObserver& aObserver )
    {
	CFindOperation* self = new ( ELeave ) CFindOperation(
        aContactStore, aObserver );
    CleanupStack::PushL( self );
    self->ConstructL( aSearchString, aFieldTypes );
    CleanupStack::Pop( self );
	return self;
	}

CFindOperation::~CFindOperation()
    {
    Cancel();
    
    delete iSearchString;
    delete iResults;
    delete iAsyncFinder;
    delete iContactIds;
    delete iFieldDef;
    }

void CFindOperation::IssueRequest()
    {
    TRequestStatus* status = &iStatus;
    User::RequestComplete( status, KErrNone );
    SetActive();
    }

void CFindOperation::DoCancel()
    {
    iState = ECancelled;
    if ( !IsActive() )
        {
        IssueRequest();
        }
    }

void CFindOperation::RunL()
    {
    switch ( iState )
        {
        case EBuildLinks:
            {
            if ( iContactIds->Count() > 0 )
                {
                CContactLink* link = CContactLink::NewLC( iContactStore, 
                                                    (*iContactIds)[0] );
                iContactIds->Remove( 0 );
                iResults->AppendL( link );
                CleanupStack::Pop( link );
                IssueRequest();
                }
            else
                {
                delete iContactIds;
                iContactIds = NULL;
                iState = EComplete;
                IssueRequest();
                }
            break;
            }
        case EComplete:
            {
            // gives ownership to observer
            CVPbkContactLinkArray* results = iResults;
            iResults = NULL;
            iObserver.FindCompleteL( results );
            break;
            }
        case ECancelled:
            {
            iObserver.FindFailed( KErrCancel );
            break;
            }
        }

    }

TInt CFindOperation::RunError( TInt aError )
    {
    iObserver.FindFailed( aError );
    return KErrNone;
    }

void CFindOperation::StartL()
    {
    iAsyncFinder = iContactStore.NativeDatabase().FindAsyncL(
        *iSearchString, iFieldDef, this );
	}
	
void CFindOperation::IdleFindCallback()
    {
    if ( iAsyncFinder->IsComplete() )
        {
        iState = EBuildLinks;
        iContactIds = iAsyncFinder->TakeContactIds();
        IssueRequest();
        }
    }

void CFindOperation::Cancel()
    {
    CActive::Cancel();
	}

} // namespace VPbkCntModel