/*
* Copyright (c) 2006 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:  DS contacts adapters 
*
*/


// INCLUDE FILES
#include <e32base.h>
#include <s32strm.h>
#include <cntdb.h>
#include <e32cmn.h>
#include <e32des16.h>
#include <cntitem.h>
#include <cntfield.h>
#include <cntfldst.h>

#include "nsmlcontactsdefs.h"
#include "NSmlContactsModsFetcher.h"
#include "nsmldebug.h"
#include "nsmlsnapshotitem.h"
#include "nsmlchangefinder.h"

#include <CVPbkContactViewDefinition.h>
#include <CVPbkContactIdConverter.h>
#include <CVPbkContactFieldIterator.h>
#include <MVPbkContactStoreProperties.h>
#include <MVPbkStoreContactProperties.h>
#include <MVPbkViewContact.h>
#include <MVPbkFieldType.h>
#include <MVPbkContactFieldTextData.h>
#include <MVPbkStoreContact.h>
#include <MVPbkStoreContact2.h>
#include <MVPbkContactLink.h>
#include <VPbkEng.rsg>


// ------------------------------------------------------------------------------------------------
// CNSmlContactsModsFetcher::CNSmlContactsModsFetcher
// ------------------------------------------------------------------------------------------------
//
CNSmlContactsModsFetcher::CNSmlContactsModsFetcher( TBool& aSnapshotRegistered,CVPbkContactManager& aContactManager,MVPbkContactStore& aStore,TKeyArrayFix& aKey, CNSmlChangeFinder& aChangeFinder ) :
	CActive( EPriorityLow ), 
	iSnapshotRegistered( aSnapshotRegistered ), 
	iKey( aKey ), 
	iChangeFinder( aChangeFinder ),
	iContactManager(aContactManager) ,
	iStore(aStore) ,
	iContactViewBase(NULL)
	{
	_DBG_FILE("CNSmlContactsModsFetcher::CNSmlContactsModsFetcher(): begin");
	CActiveScheduler::Add( this );
	_DBG_FILE("CNSmlContactsModsFetcher::CNSmlContactsModsFetcher(): end");
	}

// ------------------------------------------------------------------------------------------------
// CNSmlContactsModsFetcher::~CNSmlContactsModsFetcher
// ------------------------------------------------------------------------------------------------
//
CNSmlContactsModsFetcher::~CNSmlContactsModsFetcher()
	{
	_DBG_FILE("CNSmlContactsModsFetcher::~CNSmlContactsModsFetcher(): begin");
	
	Cancel();	
	delete iSnapshot;
	delete iContactViewBase;
	
	
	_DBG_FILE("CNSmlContactsModsFetcher::~CNSmlContactsModsFetcher(): end");
	}

// ----------------------------------------------------------------------------
// CNSmlContactsModsFetcher::CancelRequest
// ----------------------------------------------------------------------------
void CNSmlContactsModsFetcher::CancelRequest()
     {
     Cancel();
     }

// ------------------------------------------------------------------------------------------------
// CNSmlContactsModsFetcher::FetchModificationsL
// ------------------------------------------------------------------------------------------------
//
void CNSmlContactsModsFetcher::FetchModificationsL( TRequestStatus& aStatus )
	{
	_DBG_FILE("CNSmlContactsModsFetcher::FetchModificationsL(): begin");
	
	iCallerStatus = &aStatus;
	*iCallerStatus = KRequestPending;
	iContactCount = 0;
	if( !iSnapshot )
		{
		iSnapshot = new (ELeave) CArrayFixSeg<TNSmlSnapshotItem>( KNSmlSnapshotSize );
		}
		
	if(iContactViewBase)
	{
	delete iContactViewBase;
	iContactViewBase = NULL;	
	}
	
	CreateViewL();
	
	_DBG_FILE("CNSmlContactsModsFetcher::FetchModificationsL(): end");
	
	}
	
// ------------------------------------------------------------------------------------------------
// CNSmlContactsModsFetcher::ConstructL
// ------------------------------------------------------------------------------------------------
//
void CNSmlContactsModsFetcher::ConstructL()
	{
	iSnapshot = new (ELeave) CArrayFixSeg<TNSmlSnapshotItem>(KNSmlSnapshotSmallSize);
	
	}
	
// ------------------------------------------------------------------------------------------------
// CNSmlContactsModsFetcher::RunL
// ------------------------------------------------------------------------------------------------	
//
void CNSmlContactsModsFetcher::RunL()
	{
	_DBG_FILE("CNSmlContactsModsFetcher::RunL(): begin");
	
	if ( !iSnapshotRegistered )
		{
		FetchNextContactL();
		}
#ifdef __NSML_MODULETEST__
	else
		{
		CActiveScheduler::Stop();
		}
#endif
	
	_DBG_FILE("CNSmlContactsModsFetcher::RunL(): end");
	}

// ------------------------------------------------------------------------------------------------
// CNSmlContactsModsFetcher::FetchNextContactL
// ------------------------------------------------------------------------------------------------	
//
void CNSmlContactsModsFetcher::FetchNextContactL()
	{
	_DBG_FILE("CNSmlContactsModsFetcher::FetchNextContactL(): begin");
	if(iContactViewBase->ContactCountL() == 0)
		{
		User::RequestComplete( iCallerStatus, KErrNone );
		return;	
		}
	if ( !iSnapshotRegistered )
		{
		const MVPbkViewContact& contact = iContactViewBase->ContactAtL(iContactCount);

		MVPbkContactLink* contactLink = contact.CreateLinkLC();
		iContactManager.RetrieveContactL( *contactLink, *this );
		CleanupStack::PopAndDestroy();	
		}

	_DBG_FILE("CNSmlContactsModsFetcher::FetchNextContactL(): end");
	}

// ------------------------------------------------------------------------------------------------
// CNSmlContactsModsFetcher::DoCancel
// ------------------------------------------------------------------------------------------------	
//
void CNSmlContactsModsFetcher::DoCancel()
	{
	_DBG_FILE("CNSmlContactsModsFetcher::DoCancel(): begin");

	User::RequestComplete( iCallerStatus, KErrCancel );
	
	_DBG_FILE("CNSmlContactsModsFetcher::DoCancel(): end");
	}

// ----------------------------------------------------------------------------
// CNSmlContactsModsFetcher::IsConfidentialL
// ----------------------------------------------------------------------------
//	
TBool CNSmlContactsModsFetcher::IsConfidentialL( MVPbkStoreContact& aItem )
    {
    _DBG_FILE("CNSmlContactsModsFetcher::IsConfidentialL(): begin");
    TBool ret( EFalse );
    
    //find X-CLASS field type
	const MVPbkFieldType* syncclass = 
        iContactManager.FieldTypes().Find(R_VPBK_FIELD_TYPE_SYNCCLASS );
	CVPbkBaseContactFieldTypeIterator* itr = 
        CVPbkBaseContactFieldTypeIterator::NewLC( *syncclass, 
            aItem.Fields() );
	while ( itr->HasNext() )
        {
        const MVPbkBaseContactField* field = itr->Next();
        const MVPbkContactFieldTextData& data = 
        	MVPbkContactFieldTextData::Cast(field->FieldData());
        TPtrC ptr = data.Text();
        //compare the sync type
        if ( ptr.Compare( KNSmlContactSyncNoSync ) == 0 )
            {
            _DBG_FILE("CNSmlContactsModsFetcher::IsConfidentialL(): \
                       find confidential");
            ret = ETrue;
            }
         
        }
	CleanupStack::PopAndDestroy( itr );
    
    _DBG_FILE("CNSmlContactsModsFetcher::IsConfidentialL(): end");
    return ret;
    }


// ----------------------------------------------------------------------------
// CNSmlContactsModsFetcher::RunError
// ----------------------------------------------------------------------------
 TInt CNSmlContactsModsFetcher::RunError( TInt aError )
	{
	DBG_FILE_CODE(aError, _S8("CNSmlContactsModsFetcher::RunError() : error code received "));
	User::RequestComplete( iCallerStatus, aError );
	return KErrNone;
	}
	
// -----------------------------------------------------------------------------
// CNSmlContactsModsFetcher::CreateViewL()
// Create a contact view of the store which is opened
// -----------------------------------------------------------------------------
 
void CNSmlContactsModsFetcher::CreateViewL()
	{
	CVPbkContactViewDefinition* viewDef = CVPbkContactViewDefinition::NewL();
	CleanupStack::PushL( viewDef );
	viewDef->SetType( EVPbkContactsView );

	viewDef->SetUriL(iStore.StoreProperties().Uri().UriDes());

	 iContactViewBase = iContactManager.CreateContactViewLC( 
				                         *this, 
				                         *viewDef, 
				                         iContactManager.FieldTypes()  );
	CleanupStack::Pop();
	CleanupStack::PopAndDestroy(viewDef);

	}
// ---------------------------------------------------------------------------
//  CNSmlContactsModsFetcher::UpdateSnapshotL
//  Add the fetched contacts id and timestamp 
//  to the snapshot.
// ---------------------------------------------------------------------------
//
 
 void CNSmlContactsModsFetcher::UpdateSnapshotL(MVPbkStoreContact* aContact)
{
	if(!IsConfidentialL(*aContact))
		{
		CVPbkContactIdConverter* idConverter = CVPbkContactIdConverter::NewL(iStore );
		CleanupStack::PushL( idConverter );

		TInt32 id = idConverter->LinkToIdentifier(
			*iContactViewBase->ContactAtL(iContactCount).CreateLinkLC());
		TNSmlSnapshotItem snap( id);
		
		MVPbkStoreContact2* tempContact = 
		reinterpret_cast<MVPbkStoreContact2*> (aContact->StoreContactExtension (KMVPbkStoreContactExtension2Uid));  
              
		MVPbkStoreContactProperties *contactProterties 
									= tempContact ->PropertiesL();
		CleanupDeletePushL(contactProterties);				
		snap.SetLastChangedDate(contactProterties->LastModifiedL());
		CleanupStack::PopAndDestroy();
				
		iSnapshot->InsertIsqL( snap, iKey );
		iCurrentSnapshotCounter++;
		if ( iCurrentSnapshotCounter > 20 )
			{
			iSnapshot->Compress();
			iCurrentSnapshotCounter = 0;
			}
		CleanupStack::PopAndDestroy();
		CleanupStack::PopAndDestroy(idConverter);	
		}
	
	iContactCount++;
	
	if ( iContactCount == iContactViewBase->ContactCountL() )
		{
		iChangeFinder.SetNewSnapshot( iSnapshot ); // changefinder takes ownership
		iSnapshot = NULL;
		iSnapshotRegistered = ETrue;
		User::RequestComplete( iCallerStatus, KErrNone );
		}

}	
// ---------------------------------------------------------------------------
// CNSmlContactsModsFetcher::ContactViewReady
// Implements the view ready function of MVPbkContactViewObserver
// --------------------------------------------------------------------------- 
void CNSmlContactsModsFetcher::ContactViewReady(
                MVPbkContactViewBase& /*aView*/ ) 
	{
    _DBG_FILE("CNSmlContactsModsFetcher::ContactViewReady(): begin");
	
	SetActive();
	TRequestStatus* status = &iStatus;
	User::RequestComplete( status, KErrNone );	
	
	_DBG_FILE("CNSmlContactsModsFetcher::ContactViewReady(): end");
	}

// ---------------------------------------------------------------------------
// CNSmlContactsModsFetcher::ContactViewUnavailable
// Implements the view unavailable function of MVPbkContactViewObserver
// --------------------------------------------------------------------------- 
void CNSmlContactsModsFetcher::ContactViewUnavailable(
                MVPbkContactViewBase& /*aView*/ )  
{
   

}

// ---------------------------------------------------------------------------
// CNSmlContactsModsFetcher::ContactAddedToView
// Implements the add contact function of MVPbkContactViewObserver
// --------------------------------------------------------------------------- 
void CNSmlContactsModsFetcher::ContactAddedToView(
            MVPbkContactViewBase& /*aView*/, 
            TInt /*aIndex*/, 
            const MVPbkContactLink& /*aContactLink*/ ) 
{
}

// ---------------------------------------------------------------------------
// Implements the remove contact function of MVPbkContactViewObserver
// --------------------------------------------------------------------------- 
void CNSmlContactsModsFetcher::ContactRemovedFromView(
                MVPbkContactViewBase& /*aView*/, 
                TInt /*aIndex*/, 
                const MVPbkContactLink& /*aContactLink*/ )  
{
}

// ---------------------------------------------------------------------------
// CNSmlContactsModsFetcher::ContactViewError
// Implements the view error function of MVPbkContactViewObserver
// --------------------------------------------------------------------------- 
void CNSmlContactsModsFetcher::ContactViewError(
            MVPbkContactViewBase& /*aView*/, 
            TInt aError, 
            TBool /*aErrorNotified*/ )  
{
User::RequestComplete( iCallerStatus, aError );
}

// ---------------------------------------------------------------------------
//  CNSmlContactsModsFetcher::VPbkSingleContactOperationComplete
//  Called when the contact operation is completed.
// ---------------------------------------------------------------------------
//
 void CNSmlContactsModsFetcher::VPbkSingleContactOperationComplete(
		MVPbkContactOperationBase& aOperation,
		MVPbkStoreContact* aContact )
{
	MVPbkContactOperationBase* operation = &aOperation;
	if ( operation )
	{
		delete operation;
		operation = NULL;
	}
	
	TRAPD(error,UpdateSnapshotL(aContact));
	delete aContact;
	if(error!= KErrNone)
	{
	User::RequestComplete( iCallerStatus, error );	
	}
	else
	{
	SetActive();
	TRequestStatus* status = &iStatus;
	User::RequestComplete( status, KErrNone );		
	}
	
}

// ---------------------------------------------------------------------------
//  CNSmlContactsModsFetcher::VPbkSingleContactOperationFailed
//  Called when the contact operation fails
// ---------------------------------------------------------------------------
//
void CNSmlContactsModsFetcher::VPbkSingleContactOperationFailed(
		MVPbkContactOperationBase& aOperation,
		 TInt /*aError*/ )
 {
 	MVPbkContactOperationBase* operation = &aOperation;
	if ( operation )
	{
		delete operation;
		operation = NULL;
	}
 }
// End of File