/*
* Copyright (c) 2006-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 find operation that uses
*                CContactDataBase::FindInTextDefAsyncL
*
*/


#include "CFindInTextDefOperation.h"

// VPbkCntModel internal
#include "CContactStore.h"
#include "CFieldFactory.h"
#include "CContactLink.h"

// Virtual Phonebook
#include <MVPbkFieldType.h>
#include <MVPbkContactFindFromStoresObserver.h>
#include <CVPbkContactLinkArray.h>

// Other system includes
#include <cntfield.h>

namespace VPbkCntModel {

// Set a limit to the contact id conversion. If for some reason
// the result is huge.
const TInt KMaxConversionInOneStep = 100;
const TInt KContinueIdle = 1;
const TInt KDontContinueIdle = 0;
const TInt KGranularity( 2 );

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

// ---------------------------------------------------------------------------
// CFindInTextDefOperation::CFindInTextDefOperation
// ---------------------------------------------------------------------------
//
CFindInTextDefOperation::CFindInTextDefOperation( CContactStore& aContactStore,
        MVPbkContactFindFromStoresObserver& aObserver,
        const TCallBack& aWordParserCallBack )
        :   iStore( aContactStore ),
            iObserver( aObserver ),
            iWordParserCallBack( aWordParserCallBack )
    {

    }

// ---------------------------------------------------------------------------
// CFindInTextDefOperation::ConstructL
// ---------------------------------------------------------------------------
//
void CFindInTextDefOperation::ConstructL( const MDesC16Array& aSearchStrings,
        const MVPbkFieldTypeList& aFieldTypes )
    {
    // Copy search strings
    const TInt stringCount = aSearchStrings.MdcaCount();
    TInt granularity = stringCount;
    if ( stringCount == 0 )
        {
        // default granularity
        granularity = KGranularity;
        }

    iSearchStrings = new( ELeave ) CDesCArrayFlat( granularity );
    for ( TInt i = 0; i < stringCount; ++i )
        {
        iSearchStrings->AppendL( aSearchStrings.MdcaPoint( i ) );
        }

    // Convert fieldtypes to contact model text definitions
    iTextDefs = CContactTextDef::NewL();
    const TInt typeCount = aFieldTypes.FieldTypeCount();
    for ( TInt j = 0; j < typeCount; ++j )
        {
        const MVPbkFieldType& fieldType = aFieldTypes.FieldTypeAt( j );
        const CContactItemField* field =
            iStore.FieldFactory().FindField( fieldType );
        if ( field )
            {
            iTextDefs->AppendL(
                TContactTextDefItem( field->ContentType().FieldType(0) ) );
            }
        }

    iIdle = CIdle::NewL( CActive::EPriorityStandard );
    iResults = CVPbkContactLinkArray::NewL();
    }

// ---------------------------------------------------------------------------
// CFindInTextDefOperation::NewL
// ---------------------------------------------------------------------------
//
CFindInTextDefOperation* CFindInTextDefOperation::NewL(
        CContactStore& aContactStore,
        const MDesC16Array& aSearchStrings,
        const MVPbkFieldTypeList& aFieldTypes,
        MVPbkContactFindFromStoresObserver& aObserver,
        const TCallBack& aWordParserCallBack )
    {
    CFindInTextDefOperation* self = new( ELeave ) CFindInTextDefOperation(
        aContactStore, aObserver, aWordParserCallBack );
    CleanupStack::PushL( self );
    self->ConstructL( aSearchStrings, aFieldTypes );
    CleanupStack::Pop( self );
    return self;
    }

// ---------------------------------------------------------------------------
// CFindInTextDefOperation::~CFindInTextDefOperation
// ---------------------------------------------------------------------------
//
CFindInTextDefOperation::~CFindInTextDefOperation()
    {
    Cancel();
    delete iAsyncFinder;
    delete iIdle;
    delete iResults;
    delete iContactIds;
    delete iSearchStrings;
    delete iTextDefs;
    }

// ---------------------------------------------------------------------------
// From class MVPbkContactOperation.
// CFindInTextDefOperation::StartL
// ---------------------------------------------------------------------------
//
void CFindInTextDefOperation::StartL()
    {
    if ( iTextDefs->Count() == 0 || iSearchStrings->Count() == 0 )
        {
        iIdle->Start( TCallBack( ConvertResults, this ) );
        }
    else
        {
        iAsyncFinder = iStore.NativeDatabase().FindInTextDefAsyncL(
            *iSearchStrings, iTextDefs, this, iWordParserCallBack );
        }
    }

// ---------------------------------------------------------------------------
// From class MVPbkContactOperation.
// CFindInTextDefOperation::Cancel
// ---------------------------------------------------------------------------
//
void CFindInTextDefOperation::Cancel()
    {
    if ( iAsyncFinder )
        {
        iAsyncFinder->Cancel();
        delete iAsyncFinder;
        iAsyncFinder = NULL;
        }

    if ( iIdle )
        {
        iIdle->Cancel();
        }
    }

// ---------------------------------------------------------------------------
// From class MIdleFindObserver.
// CFindInTextDefOperation::IdleFindCallback
// ---------------------------------------------------------------------------
//
void CFindInTextDefOperation::IdleFindCallback()
    {
    if ( iAsyncFinder->IsComplete() )
        {
        iContactIds = iAsyncFinder->TakeContactIds();
        iIdle->Start( TCallBack( ConvertResults, this ) );
        }
    }

// ---------------------------------------------------------------------------
// CFindInTextDefOperation::ConvertResults
// ---------------------------------------------------------------------------
//
TInt CFindInTextDefOperation::ConvertResults( TAny* aThis )
    {
    CFindInTextDefOperation* self =
        static_cast<CFindInTextDefOperation*>( aThis );
    TInt continueIdle = KDontContinueIdle;
    TRAPD( res, continueIdle = self->ConvertResultsL() );
    if ( res != KErrNone )
        {
        self->HandleError( res );
        }
    return continueIdle;
    }

// ---------------------------------------------------------------------------
// CFindInTextDefOperation::ConvertResultsL
// ---------------------------------------------------------------------------
//
TInt CFindInTextDefOperation::ConvertResultsL()
    {
    TInt convertedIds = 0;
    const TInt firstContact = 0;
    // Convert only reasonable amount of ids in one cycle
    if ( iContactIds )
        {
        while ( iContactIds->Count() > 0 &&
            convertedIds < KMaxConversionInOneStep )
            {
            CContactLink* link = CContactLink::NewLC( iStore,
                (*iContactIds)[firstContact] );
            iContactIds->Remove( firstContact );
            iResults->AppendL( link );
            CleanupStack::Pop(); // link
            ++convertedIds;
            }
        }

    // iContactIds not necessary exists if find wasn't done in StartL
    if ( !iContactIds || iContactIds->Count() == 0 )
        {
        // Results are ready.
        MVPbkContactLinkArray* results = iResults;
        iResults = NULL;
        iObserver.FindFromStoreSucceededL( iStore, results );
        iObserver.FindFromStoresOperationComplete();
        return KDontContinueIdle;
        }
    return KContinueIdle;
    }

// ---------------------------------------------------------------------------
// CFindInTextDefOperation::HandleError
// ---------------------------------------------------------------------------
//
void CFindInTextDefOperation::HandleError( TInt aError )
    {
    if ( aError != KErrNone )
        {
        iObserver.FindFromStoreFailed( iStore, aError );
        iObserver.FindFromStoresOperationComplete();
        }
    }
} // namespace VPbkCntModel