/*

* Copyright (c) 2004 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:

*

*/

//  CLASS HEADER

#include "T_MVPbkContactStoreComposite.h"

#include <CVPbkContactManager.h>

#include <CVPbkContactViewDefinition.h>

#include <CVPbkSortOrder.h>

#include <CVPbkContactLinkArray.h>

#include <CVPbkContactStoreUriArray.h>

#include <MVPbkContactStoreList.h>

#include <MVPbkContactStore.h>

#include <MVPbkContactViewBase.h>

#include <MVPbkViewContact.h>

#include <MVPbkContactOperationBase.h>

#include <MVPbkStoreContact.h>

#include <MVPbkStoreContactFieldCollection.h>

#include <MVPbkContactFieldTextData.h>

#include <MVPbkContactViewFiltering.h>

#include <TVPbkFieldTypeMapping.h>

#include <TVPbkContactStoreUriPtr.h>

//  EXTERNAL INCLUDES

#include <EUnitMacros.h>

#include <barsc.h>

#include <barsread.h>

#include <s32mem.h>

#include <bautils.h>

//  INTERNAL INCLUDES

// LOCAL

namespace 

    {

#if defined(__WINS__)

    _LIT( KResFile, "z:\\resource\\T_MVPbkContactStore.rsc" );

#else

    _LIT( KResFile, "c:\\resource\\T_MVPbkContactStore.rsc" );

#endif // defined(__WINS__)    

    _LIT( KFNameFieldValue, "Bbbfirstname" );

    _LIT( KLNameFieldValue, "Ccclastname" ); 

    _LIT( KTelNo, "555-1239876543" );

    _LIT( KFNameFieldValue2, "Aaafirstname" );

    _LIT( KLNameFieldValue2, "Bbblastname" );

    _LIT( KTelNo2, "+358959876543" );

    _LIT( KFNameFieldValue3, "Cccfirstname" );

    _LIT( KLNameFieldValue3, "Aaalastname" );

    _LIT( KTelNo3, "04051245652" );

    void StopScheduler( CActiveSchedulerWait& aScheduler )

        {

        if ( aScheduler.IsStarted() )

            {

            aScheduler.AsyncStop();

            }

        }

    _LIT( KFindString, "a" );

    _LIT( KFindStrings, "aa" );

    } // namespace

// CALLBACK

void T_MVPbkContactStoreComposite::StoreReady(MVPbkContactStore& /*aContactStore*/)

    {

    if (iStoreScheduler.IsStarted())

    	{    	

	    iLastError = KErrNone;

	    iLastEvent = EStoreReady;

	    // Event coming straight from the store, so no OpenComplete() expected

	    if ( iFlag ) 

	        {

	        iFlag = EFalse;

	        if (iExpectedStoreEvent == iLastEvent)

	        	{

		        iExpectedStoreResponseFound = ETrue;

	        	}

	        StopScheduler(iStoreScheduler);

	        }

    	}

    }

void T_MVPbkContactStoreComposite::StoreUnavailable

                            (MVPbkContactStore& /*aContactStore*/, TInt aReason)

    {

    if (iStoreScheduler.IsStarted())

    	{    	

	    iLastError = aReason;

	    iLastEvent = EOpenError;

	    // Event coming straight from the store, so no OpenComplete() expected

	    if ( iFlag ) 

	        {

	        iFlag = EFalse;

	        iExpectedStoreResponseFound = ETrue;

 	       StopScheduler(iStoreScheduler);

	        }

    	}

    }

void T_MVPbkContactStoreComposite::HandleStoreEventL(

                MVPbkContactStore& /*aContactStore*/, 

                TVPbkContactStoreEvent /*aStoreEvent*/)

	{

	}

void T_MVPbkContactStoreComposite::OpenComplete()

    {

    if (iStoreScheduler.IsStarted())

    	{    	

	    iLastError = KErrNone;

	    iLastEvent = EOpenComplete;

        if (iExpectedStoreEvent == iLastEvent)

        	{

	        iExpectedStoreResponseFound = ETrue;

        	}

	    StopScheduler(iStoreScheduler);

    	}

    }

void T_MVPbkContactStoreComposite::ContactViewReady(MVPbkContactViewBase& /*aView*/)

    {

    if ( iViewScheduler.IsStarted() )

        {

        iLastError = KErrNone;

        iLastEvent = EContactViewReady;

        if (iExpectedViewEvent == iLastEvent)

        	{

	        iExpectedViewResponseFound = ETrue;

        	}

        StopScheduler(iViewScheduler);

        }

    }

void T_MVPbkContactStoreComposite::ContactViewUnavailable(MVPbkContactViewBase& /*aView*/)

    {

    if ( iViewScheduler.IsStarted() )

        {

        iLastError = KErrNone;

        iLastEvent = EContactViewUnavailable;

        if (iExpectedViewEvent == iLastEvent)

        	{

	        iExpectedViewResponseFound = ETrue;

        	}

        StopScheduler(iViewScheduler);

        }

    }

void T_MVPbkContactStoreComposite::ContactAddedToView

        (MVPbkContactViewBase& /*aView*/, TInt /*aIndex*/, const MVPbkContactLink& /*aLink*/)

    {

    if ( iViewScheduler.IsStarted() )

        {

        iLastError = KErrNone;

        iLastEvent = EContactAddedToView;

        if (iExpectedViewEvent == iLastEvent)

        	{

	        iExpectedViewResponseFound = ETrue;

        	}

        StopScheduler(iViewScheduler);

        }

    }

void T_MVPbkContactStoreComposite::ContactRemovedFromView

        (MVPbkContactViewBase& /*aView*/, TInt /*aIndex*/, const MVPbkContactLink& /*aLink*/)

    {

    if ( iViewScheduler.IsStarted() )

        {

        iLastError = KErrNone;

        iLastEvent = EContactRemovedFromView;

        if (iExpectedViewEvent == iLastEvent)

        	{

	        iExpectedViewResponseFound = ETrue;

        	}

        StopScheduler(iViewScheduler);

        }

    }

void T_MVPbkContactStoreComposite::ContactViewError

        (MVPbkContactViewBase& /*aView*/, TInt aError, TBool /*aErrorNotified*/)

    {

    if ( iViewScheduler.IsStarted() )

        {

        iLastError = aError;

        iLastEvent = EContactViewError;

        iExpectedViewResponseFound = ETrue;

        StopScheduler(iViewScheduler);

        }

    }

void T_MVPbkContactStoreComposite::StepComplete(MVPbkContactOperationBase& /*aOperation*/,

                                  TInt /*aStepSize*/)

    {

    iLastError = KErrNone;

    iLastEvent = EStepComplete;

    }

TBool T_MVPbkContactStoreComposite::StepFailed(

        MVPbkContactOperationBase& /*aOperation*/,

        TInt /*aStepSize*/,

        TInt aError)

    {

    iLastError = aError;

    iLastEvent = EStepFailed;

    CActiveScheduler::Stop();

    return EFalse;

    }

void T_MVPbkContactStoreComposite::OperationComplete(MVPbkContactOperationBase& /*aOperation*/)

    {

    iLastError = KErrNone;

    iLastEvent = EOperationComplete;

    CActiveScheduler::Stop();

    }

void T_MVPbkContactStoreComposite::ContactOperationCompleted(TContactOpResult aResult)

    {

    if (iContactScheduler.IsStarted())

    	{

		iLastError = KErrNone;

		iLastEvent = EContactOperationCompleted;

		if ( aResult.iOpCode == EContactReadAndLock || 

		     aResult.iOpCode == EContactRead )

		    {

		    iStoreContact = aResult.iStoreContact;

		    }

        if (iExpectedContactEvent == iLastEvent)

        	{

	        iExpectedContactResponseFound = ETrue;

        	}

		StopScheduler(iContactScheduler);

    	}

    }

void T_MVPbkContactStoreComposite::ContactOperationFailed

    (TContactOp /*aOpCode*/, TInt aErrorCode, TBool /*aErrorNotified*/)

    {

    iLastError = aErrorCode;

    iLastEvent = EContactOperationFailed;

    iExpectedContactResponseFound = ETrue;

	StopScheduler(iContactScheduler);

    }

// CONSTRUCTION

T_MVPbkContactStoreComposite* T_MVPbkContactStoreComposite::NewL(const RArray<TVPbkContactStoreUriPtr>& aUriList)

    {

    T_MVPbkContactStoreComposite* self = T_MVPbkContactStoreComposite::NewLC(aUriList); 

    CleanupStack::Pop();

    return self;

    }

T_MVPbkContactStoreComposite* 

T_MVPbkContactStoreComposite::NewLC(const RArray<TVPbkContactStoreUriPtr>& aUriList)

    {

    T_MVPbkContactStoreComposite* self = 

        new( ELeave ) T_MVPbkContactStoreComposite();

    CleanupStack::PushL( self );

	self->ConstructL(aUriList); 

    return self;

    }

// Destructor (virtual by CBase)

T_MVPbkContactStoreComposite::~T_MVPbkContactStoreComposite()

    {

    delete iFindStrings;

    delete iUriArray;

    delete iStorePaths;

    iFs.Close();

    }

// Default constructor

T_MVPbkContactStoreComposite::T_MVPbkContactStoreComposite()

: iFlag(EFalse)

    {

    }

// Second phase construct

void T_MVPbkContactStoreComposite::ConstructL(

        const RArray<TVPbkContactStoreUriPtr>& aUriList)

    {

    // The ConstructL from the base class CEUnitTestSuiteClass must be called.

    // It generates the test case table.

    CEUnitTestSuiteClass::ConstructL();

    User::LeaveIfError( iFs.Connect() );

    TInt count( aUriList.Count() );

    iStorePaths = new (ELeave) CDesCArrayFlat( count );

    iUriArray = CVPbkContactStoreUriArray::NewL();

    for ( TInt i = 0; i < count; ++i )

        {

        iStorePaths->AppendL( aUriList[ i ].UriDes() );

        iUriArray->AppendL( TVPbkContactStoreUriPtr(iStorePaths->MdcaPoint( i ) ));

        }

    }

//  METHODS

void T_MVPbkContactStoreComposite::SetupL(  )   

    {

    iFlag = EFalse;

    iContactManager = CVPbkContactManager::NewL( *iUriArray, &iFs );

    iExpectedStoreResponseFound = EFalse;

    iExpectedContactResponseFound = EFalse;    

    }

void T_MVPbkContactStoreComposite::SetupEmptyL()

    {

    iFlag = EFalse;

    CVPbkContactStoreUriArray* uriArray = CVPbkContactStoreUriArray::NewLC();

    iContactManager = CVPbkContactManager::NewL( *uriArray, &iFs );

    CleanupStack::PopAndDestroy(uriArray);

    }

void T_MVPbkContactStoreComposite::SetupStoreL()

    {

    SetupL();

    ReplaceAllStoresL();

    PopulateStoresL();

    }

void T_MVPbkContactStoreComposite::SetupViewL(TInt aViewDefResId, TInt aSortOrderResId)

    {

    TFileName path;        

    // NearestLanguageFile takes only TFileName

    path.Zero();

    path.Append( KResFile() );

    if ( path.Length() != 0 )

        {

        BaflUtils::NearestLanguageFile( iFs, path );

        }

    RResourceFile resFile;

    CleanupClosePushL(resFile);

    resFile.OpenL( iFs, path );

    TResourceReader reader;

    HBufC8* buffer = resFile.AllocReadLC(aViewDefResId);

    reader.SetBuffer(buffer);

    CVPbkContactViewDefinition* def = CVPbkContactViewDefinition::NewL(reader);

    CleanupStack::PopAndDestroy(buffer);

    CleanupStack::PushL(def);

    CVPbkSortOrder* sortOrder = CreateSortOrderLC( aSortOrderResId );

    iView = iContactManager->CreateContactViewLC( *this, *def, *sortOrder );

    CleanupStack::Pop(); // iView

    EUNIT_ASSERT( iView );

    CleanupStack::PopAndDestroy(3); // sortOrder, def, resFile

    StartViewSchedulerAndDecideToLeaveL(EContactViewReady);

    EUNIT_ASSERT( iLastError == KErrNone );

    EUNIT_ASSERT( iLastEvent == iExpectedViewEvent );

    }

void T_MVPbkContactStoreComposite::SetupOrderedFlatCompositeViewL()

    {

    SetupStoreL();

    SetupCreateFindStringsL();

    SetupViewL(R_ORDERED_FLAT_COMPOSITE_CONTACT_VIEW, R_SORTORDER_LASTNAME_FIRSTNAME);

    }

void T_MVPbkContactStoreComposite::SetupOrderedComplexCompositeViewL()

    {

    SetupStoreL();

    SetupCreateFindStringsL();

    SetupViewL(R_ORDERED_COMPLEX_COMPOSITE_CONTACT_VIEW, R_SORTORDER_LASTNAME_FIRSTNAME);

    }

void T_MVPbkContactStoreComposite::SetupSortedFlatCompositeViewL()

    {

    SetupStoreL();

    SetupCreateFindStringsL();

    SetupViewL(R_SORTED_FLAT_COMPOSITE_CONTACT_VIEW, R_SORTORDER_LASTNAME_FIRSTNAME);

    }

void T_MVPbkContactStoreComposite::SetupSortedComplexCompositeViewL()

    {

    SetupStoreL();

    SetupCreateFindStringsL();

    SetupViewL(R_SORTED_COMPLEX_COMPOSITE_CONTACT_VIEW, R_SORTORDER_LASTNAME_FIRSTNAME);

    }

void T_MVPbkContactStoreComposite::SetupStoreWithContactsL()

    {

    SetupStoreL();

    PopulateStoresL();

    }

void T_MVPbkContactStoreComposite::SetupCreateFindStringsL()

    {

    iFindStrings = new(ELeave)CDesCArrayFlat( 2 );

    }

void T_MVPbkContactStoreComposite::Teardown(  )

    {

    delete iFindStrings;

    iFindStrings = NULL;

    delete iStoreContact; iStoreContact = NULL;

    delete iView; iView = NULL;

    if ( iStoreList )

        {

        iStoreList->CloseAll( *this );

        }

    iStoreList = NULL;

    delete iContactManager; iContactManager = NULL;

    }

// TESTS

void T_MVPbkContactStoreComposite::TestGetStoreListL()

    {

    iStoreList = &iContactManager->ContactStoresL();

    EUNIT_ASSERT( iStoreList->Count() == iUriArray->Count() );

    }

void T_MVPbkContactStoreComposite::TestLoadContactStoreL()

    {

    const TInt count = iUriArray->Count();

    for ( TInt i = 0; i < count; ++i )

        {

        iContactManager->LoadContactStoreL( (*iUriArray)[i] );

        }

    iStoreList = &iContactManager->ContactStoresL();

    EUNIT_ASSERT( iStoreList->Count() == count );

    }

void T_MVPbkContactStoreComposite::TestOpeningAllStoresL(  )

    {

    iStoreList = &iContactManager->ContactStoresL();

    TInt storeCount ( iStoreList->Count() );

    EUNIT_ASSERT_EQUALS_DESC( storeCount, 4, "Store count check failed." );

    // Try to open all stores.

    iStoreList->OpenAllL( *this );

    // We have to get EOpenComplete event.

    StartStoreSchedulerAndDecideToLeaveL(EOpenComplete);

    EUNIT_ASSERT( iLastError == KErrNone );

    EUNIT_ASSERT( iLastEvent == iExpectedStoreEvent );

    }

void T_MVPbkContactStoreComposite::TestViewContactCountL()

    {

    // There is at least 3 * storecount contacts available

    EUNIT_ASSERT( iView->ContactCountL() >= ( iUriArray->Count() * 3 ) );

    }

void T_MVPbkContactStoreComposite::TestCommitMultipleContactsL()

    {

    TInt cntCount( iView->ContactCountL() );

    RArray<MVPbkStoreContact*> storeCnts;

    CleanupClosePushL( storeCnts );

    iView->ContactAtL( 0 ).ReadAndLockL( *this );

    StartContactSchedulerAndDecideToLeaveL(EContactOperationCompleted);

    EUNIT_ASSERT( iLastError == KErrNone );

    EUNIT_ASSERT( iLastEvent == iExpectedContactEvent );

    iExpectedContactResponseFound = EFalse;

    MVPbkStoreContact* cnt1 = iStoreContact;

    iStoreContact = NULL;

    CleanupDeletePushL( cnt1 );

    storeCnts.Append( cnt1 );

    // get last contact from view

    iView->ContactAtL( cntCount - 1 ).ReadAndLockL( *this ); 

    StartContactSchedulerAndDecideToLeaveL(EContactOperationCompleted);

    EUNIT_ASSERT( iLastError == KErrNone );

    EUNIT_ASSERT( iLastEvent == iExpectedContactEvent );

    iExpectedContactResponseFound = EFalse;

    MVPbkStoreContact* cnt2 = iStoreContact;

    iStoreContact = NULL;

    CleanupDeletePushL( cnt2 );

    storeCnts.Append( cnt2 );

    MVPbkContactOperationBase* op = 

        iContactManager->CommitContactsL( storeCnts.Array(), *this );

    CleanupDeletePushL( op );

    StartSchedulerAndDecideToLeaveL();

    EUNIT_ASSERT( iLastError == KErrNone );

    EUNIT_ASSERT( iLastEvent == EOperationComplete );

    EUNIT_ASSERT( iView->ContactCountL() == cntCount );

    CleanupStack::PopAndDestroy( 4 ); // op, cnt2, cnt1, storeCnts

    }