/*

* Copyright (c) 2008 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 that provides handling of vpbk store

*

*/

// INCLUDE FILES

#include "cvimpststoragevpbkstorehandler.h"

#include "mvimpststoragevpbkstorehandler.h"

//vpbk interfaces

#include <MVPbkContactStoreObserver.h>

#include <CVPbkContactManager.h>

#include <MVPbkContactLink.h>

#include <CVPbkContactStoreUriArray.h>

#include <MVPbkContactOperationBase.h>

#include <MVPbkContactStore.h>

#include <MVPbkContactStoreProperties.h>

#include <MVPbkContactView.h>

#include <MVPbkContactStoreList.h>

#include <MVPbkContactFieldTextData.h>

#include <MVPbkContactFieldUriData.h>

#include <MVPbkContactFieldBinaryData.h>

#include <MVPbkContactFieldData.h>

#include <CVPbkContactViewDefinition.h>

#include <MVPbkViewContact.h>

#include <MVPbkStoreContact.h>

#include <TVPbkContactStoreUriPtr.h>

#include <MVPbkStoreContactFieldCollection.h>

#include <MVPbkStoreContactField.h>

#include <MVPbkFieldType.h>

#include <VPbkEng.rsg>

#include <CVPbkContactLinkArray.h>

#include <CVPbkFieldTypeSelector.h>

#include <CPbk2SortOrderManager.h>

#include <MVPbkContactFieldBinaryData.h>

#include "tvimpstconsts.h"

#include <cntdb.h>

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

// ---------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::

//      CVIMPSTStorageVPbkStoreHandler

// ---------------------------------------------------------------------------

//

CVIMPSTStorageVPbkStoreHandler:: CVIMPSTStorageVPbkStoreHandler( MVIMPSTStorageVPbkStoreHandler& aStoreHandler,TBool aLocalStore  ):

	CActive( CActive::EPriorityIdle ),

	iStoreHandler(aStoreHandler ),

	iStoreEventType( EVPbkUnknownEvent ),

	iFetcingIndex( 0 ),

	iLocalStore( aLocalStore )

	{

    CActiveScheduler::Add( this );

    }

// ---------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::ConstructL

// ---------------------------------------------------------------------------

//

void CVIMPSTStorageVPbkStoreHandler::ConstructL(const TDesC& aStoreName,const TDesC& aServiceName )

    { 

    iAddIdInProgress = NULL;

    iStoreName = aStoreName.AllocL();

    iServiceName = aServiceName.AllocL();

    CVPbkContactStoreUriArray* uriArray = CVPbkContactStoreUriArray::NewLC();

    uriArray->AppendL( TVPbkContactStoreUriPtr( aStoreName ) );    

    if( !uriArray->IsIncluded( TVPbkContactStoreUriPtr( KPhoneBookDbURI ) ) )

	    {

	    uriArray->AppendL( TVPbkContactStoreUriPtr( KPhoneBookDbURI )   );	

	    }

    iContactManager = CVPbkContactManager::NewL( *uriArray, NULL );

    CleanupStack::PopAndDestroy( uriArray );

    iStores = &iContactManager->ContactStoresL();

    iStores->OpenAllL( *this );

    iSortOrderManager = CPbk2SortOrderManager::NewL( iContactManager->FieldTypes(), NULL ); 

    }

// ---------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::NewL

// ---------------------------------------------------------------------------

//

CVIMPSTStorageVPbkStoreHandler* CVIMPSTStorageVPbkStoreHandler::NewL( const TDesC& aContactDb,

																	const TDesC& aServiceName,

													                MVIMPSTStorageVPbkStoreHandler& aStoreHandler,

													                TBool aLocalStore  )

	{

	CVIMPSTStorageVPbkStoreHandler* self = NewLC( aContactDb ,aServiceName, aStoreHandler,aLocalStore );

	CleanupStack::Pop( self );

	return self;

	}

// ---------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::NewLC

// ---------------------------------------------------------------------------

//

CVIMPSTStorageVPbkStoreHandler* CVIMPSTStorageVPbkStoreHandler::NewLC( const TDesC& aContactDb,

																	const TDesC& aServiceName,

																	MVIMPSTStorageVPbkStoreHandler& aStoreHandler,

																	TBool aLocalStore   )

    {

    CVIMPSTStorageVPbkStoreHandler* self =

        new (ELeave) CVIMPSTStorageVPbkStoreHandler( aStoreHandler ,aLocalStore );

    CleanupStack::PushL( self );

    self->ConstructL( aContactDb,aServiceName );

    return self;

    }

// ---------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::

//      ~CVIMPSTStorageVPbkStoreHandler

// ---------------------------------------------------------------------------

//

CVIMPSTStorageVPbkStoreHandler:: ~CVIMPSTStorageVPbkStoreHandler()

    {

    if( iWait.IsStarted() )

	    {

	    iWait.AsyncStop();	

	    }

   	Cancel();

   	ResetAndDestroyRArray();

   	iUnCommittedVPbkContacts.ResetAndDestroy();

   	delete iAddIdInProgress;

   	delete iContactOperation;

    delete iContactLink;

    delete iStoreContact;

    delete iContactView;

    if ( iContactManager )

        {

        TRAP_IGNORE( iContactManager->ContactStoresL().CloseAll( *this ) );

        delete iContactManager;

        }

    delete iStoreName;

    delete iSortOrderManager;

    delete iServiceName;

    }

 // ---------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::ContactViewReady

// ---------------------------------------------------------------------------

//

void CVIMPSTStorageVPbkStoreHandler::ContactViewReady( 

    MVPbkContactViewBase& aView )

    {

    if ( iContactView == &aView && ( iStoreEventType == EVPbkUnknownEvent ) )

        { 

        iStoreEventType = EVPbkContactReading ;          

        TRAP_IGNORE( HandleContactViewReadyL( *iContactView ) );

        }

    }

// ---------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::ContactViewUnavailable

// ---------------------------------------------------------------------------

//

void CVIMPSTStorageVPbkStoreHandler::ContactViewUnavailable( 

    MVPbkContactViewBase& /*aView*/ )

    {

    }

// ---------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::ContactAddedToView

// ---------------------------------------------------------------------------

//

void CVIMPSTStorageVPbkStoreHandler::ContactAddedToView( 

    MVPbkContactViewBase& /*aView*/, 

    TInt /*aIndex*/, const MVPbkContactLink& /*aContactLink*/ )

    {

    }

// ---------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::ContactRemovedFromView

// ---------------------------------------------------------------------------

//

void CVIMPSTStorageVPbkStoreHandler::ContactRemovedFromView( 

    MVPbkContactViewBase& /*aView*/, 

    TInt /*aIndex*/, const MVPbkContactLink& /*aContactLink*/ )

    {

    }

// ---------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::ContactViewError

// ---------------------------------------------------------------------------

//

void CVIMPSTStorageVPbkStoreHandler::ContactViewError( 

    MVPbkContactViewBase& /*aView*/, 

    TInt /*aError*/, TBool /*aErrorNotified*/ )

    {

    }

// ---------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::StoreReady

// ---------------------------------------------------------------------------

//

void CVIMPSTStorageVPbkStoreHandler::StoreReady( 

    MVPbkContactStore& /*aContactStore*/ )

    {

    }

// ---------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::StoreUnavailable

// ---------------------------------------------------------------------------

//

void CVIMPSTStorageVPbkStoreHandler::StoreUnavailable( 

    MVPbkContactStore& /*aContactStore*/, 

    TInt /*aReason*/ )

    {

    }

// ---------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::HandleStoreEventL

// ---------------------------------------------------------------------------

//

MVPbkContactStore* CVIMPSTStorageVPbkStoreHandler::GetDefaultStoreL( const TDesC& aUri )

	 {

	 return iStores->Find( TVPbkContactStoreUriPtr( aUri ) );	

	 }

// ---------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::HandleStoreEventL

// ---------------------------------------------------------------------------

//

void CVIMPSTStorageVPbkStoreHandler::HandleStoreEventL( 

    MVPbkContactStore& aContactStore , 

    TVPbkContactStoreEvent aStoreEvent )

    {

    if( iStore == &aContactStore )

	    {

	  	switch( aStoreEvent.iEventType )

		    {

		    case TVPbkContactStoreEvent::EContactAdded:

			    {

			    delete iContactLink;

			    iContactLink = NULL;

				MVPbkContactLink* contactLink = aStoreEvent.iContactLink->CloneLC();

			 	iContactLink = 	contactLink;

				CleanupStack::Pop(); // contactLink

				IssueRequest(); // complete the request	

			    break;	

			    }

			case TVPbkContactStoreEvent::EContactDeleted:

			    {

			   	MVPbkContactLink* contactLink = aStoreEvent.iContactLink->CloneLC();

			   	delete iContactLink;

		    	iContactLink = NULL;

		 		iContactLink = 	contactLink;

		 		CleanupStack::Pop(); // contactLink

				TVIMPSTVPbkStoreEvent storeEvent(EVPbkContactDeleted, iContactLink );

		    	iStoreHandler.HandleVPbkStoreEventL( storeEvent ) ;	

			    break;	

			    }

			case TVPbkContactStoreEvent::EContactChanged:

				{

				delete iContactLink;

				iContactLink = NULL;

				MVPbkContactLink* contactLink = aStoreEvent.iContactLink->CloneLC();

				iContactLink = 	contactLink;

				CleanupStack::Pop(); // contactLink

				iStoreEventType = EVPbkContactChanged;

				IssueRequest(); // complete the request which will begin retriving the iContactLink

				break;	

				}

			case TVPbkContactStoreEvent::EUnknownChanges:

			    {

			    iStoreEventType = EVPbkUnknownChanges;

			    TVIMPSTVPbkStoreEvent storeEvent(iStoreEventType);

			    iStoreHandler.HandleVPbkStoreEventL( storeEvent ) ;

			    break;	

			    }

		    default:

			 	break;

		    }

	    }

    }

// ---------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::OpenComplete

// ---------------------------------------------------------------------------

//

void CVIMPSTStorageVPbkStoreHandler::OpenComplete()

    {

    // stores OpenAll completed

    TRAP_IGNORE( DoHnadleOpenCompleteL() );

    }

// ---------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::DoHnadleOpenCompleteL

// ---------------------------------------------------------------------------

//

void CVIMPSTStorageVPbkStoreHandler::DoHnadleOpenCompleteL()

    {

    iStore = GetDefaultStoreL( *iStoreName ) ;

    CVPbkContactViewDefinition* viewDefinition = 

        				CVPbkContactViewDefinition::NewL();

    CleanupStack::PushL( viewDefinition );    

    viewDefinition->SetType( EVPbkContactsView );

    viewDefinition->SetUriL( *iStoreName );

    if ( iStore )

        {

        MVPbkContactView* tmpView = iStore->CreateViewLC(

						            *viewDefinition,

						            *this,

						            iSortOrderManager->SortOrder() );        

        CleanupStack::Pop(); // tmpView            

        iContactView = tmpView;

        }

    CleanupStack::PopAndDestroy();  //viewDefinition, can not pop ny name

    }

// ---------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::ContactOperationCompleted

// ---------------------------------------------------------------------------

//

void CVIMPSTStorageVPbkStoreHandler::ContactOperationCompleted(

    TContactOpResult /*aResult*/ )

    {

    // called when contact commit is successful

    iOperationError = KErrNone;

    if( iWait.IsStarted() )

	    {

	    iWait.AsyncStop();	

	    }

    TRAP_IGNORE( CommitNextPendingContactsL() );

	}

// ---------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::ContactOperationFailed

// ---------------------------------------------------------------------------

//

void CVIMPSTStorageVPbkStoreHandler::ContactOperationFailed( 

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

    {

    // called when contact commit is unsuccessful

    iOperationError = aErrorCode;

    if( iWait.IsStarted() )

	    {

	    iWait.AsyncStop();	

	    }

    TRAP_IGNORE( CommitNextPendingContactsL() );

    }    

// --------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::StepComplete

// --------------------------------------------------------------------------

//

void CVIMPSTStorageVPbkStoreHandler::StepComplete(

        MVPbkContactOperationBase& /*aOperation*/,

        TInt /*aStepSize*/ )

    {

    // called when batch operation call

    iOperationError = KErrNone;

    }

// --------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::StepFailed

// --------------------------------------------------------------------------

//

TBool CVIMPSTStorageVPbkStoreHandler::StepFailed(

        MVPbkContactOperationBase& /*aOperation*/,

        TInt /*aStepSize*/,

        TInt aError )

    {

    // called when batch operation call

    iOperationError = aError;

   	return EFalse;

    }

// --------------------------------------------------------------------------

// CVIMPSTStorageVPbkStoreHandler::OperationComplete

// --------------------------------------------------------------------------

//

void CVIMPSTStorageVPbkStoreHandler::OperationComplete(

        MVPbkContactOperationBase& aOperation )

    {

    // called when batch operation call for opening the multiple store

    if ( &aOperation == iContactOperation )

        {

        delete iContactOperation;

        iContactOperation = NULL;

        }

    iOperationError = KErrNone;

    if( iWait.IsStarted() )

	    {

	    iWait.AsyncStop();	

	    }

    }   

//----------------------------------------------------------------------

//CVIMPSTStorageVPbkStoreHandler::VPbkSingleContactOperationComplete()

//----------------------------------------------------------------------

void CVIMPSTStorageVPbkStoreHandler::VPbkSingleContactOperationComplete( MVPbkContactOperationBase& aOperation,

                                            				MVPbkStoreContact* aContact )

    {  

    // called when contact details is retrived

    TRAP_IGNORE( DoHnadleSingleContactOperationCompleteL( aOperation, aContact ) );

    }

//----------------------------------------------------------------------

//CVIMPSTStorageVPbkStoreHandler::DoHnadleSingleContactOperationCompleteL()

//----------------------------------------------------------------------

void CVIMPSTStorageVPbkStoreHandler::DoHnadleSingleContactOperationCompleteL( MVPbkContactOperationBase& aOperation,

                                            								 MVPbkStoreContact* aContact )

    {  

    // called when contact details is retrived

    if( iStoreContact )

        {

        delete 	iStoreContact;

        iStoreContact = NULL;

        }

    iStoreContact = aContact ; // iStoreContact  owns thea Contact

    if( ( &aOperation == iContactOperation) && iStoreContact )

        {

        if( iWait.IsStarted() )

		    {

		    iWait.AsyncStop();

		    }

        delete iContactOperation;

        iContactOperation = NULL;

        iCommitOperationInProgress = EFalse;

        if( iStoreEventType != EVPbkUpdatingAvatar )

            {

            if( !iLocalStore && iStoreEventType == EVPbkContactRetriving )

                {

		    	RetriveFieldDataAndSendEventL( *iStoreContact );

			   }

            else 

                {

                HBufC* userId = GetContactFieldDataLC( *iStoreContact, R_VPBK_FIELD_TYPE_IMPP );

                HBufC* firstname = GetContactFieldDataLC( *iStoreContact,R_VPBK_FIELD_TYPE_FIRSTNAME );

                HBufC* lastname = GetContactFieldDataLC( *iStoreContact,R_VPBK_FIELD_TYPE_LASTNAME );

                HBufC* disname = NULL;

                /*

                 *	There are three scenarios where I can form the Display name.

                 *	1. First and last name are present. 

                 *	2. First name is present but no last name is present.

                 *	3. Lastname is there and no first name.

                 *	4. if none, then assigning NULL 

                 */

                if ( firstname && lastname )