/*

* 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 dataprovider

*

*/

// INCLUDE FILES

#include <barsc.h>

#include <bautils.h>

#include <e32base.h>

#include <s32strm.h>

#include <e32cmn.h>

#include <e32des16.h>

#include <s32mem.h>

#include <implementationproxy.h>

#include <vtoken.h>

#include <sysutil.h>

#include <NSmlContactsDataStoreFormat_1_1_2.rsg>

#include <NSmlContactsDataStoreFormat_1_2.rsg>

#include <data_caging_path_literals.hrh>

#include <SmlDataFormat.h>

#include <SmlDataProvider.h>

#include <e32property.h>

#include <DataSyncInternalPSKeys.h>

#include <e32hashtab.h>

#include <CVPbkContactStoreUriArray.h>

#include <VPbkContactStoreUris.h>

#include <TVPbkContactStoreUriPtr.h>

#include <MVPbkContactStoreList.h>

#include <MVPbkContactStoreProperties.h>

#include <MVPbkStoreContactProperties.h>

#include <MVPbkViewContact.h>

#include <MVPbkStoreContact.h>

#include <MVPbkStoreContact2.h>

#include <MVPbkFieldType.h>

#include <MVPbkContactFieldTextData.h>

#include <CVPbkContactFieldIterator.h>

#include <CVPbkContactViewDefinition.h>

#include <MVPbkContactLink.h>

#include <s32mem.h>

#include "NSmlContactsDataStore.h"

#include "NSmlContactsModsFetcher.h"

#include "nsmldebug.h"

#include "nsmlconstants.h"

#include "NSmlDataModBase.h"

#include "nsmlcontactsdefs.h"

#include "nsmldsimpluids.h"

#include "nsmlsnapshotitem.h"

#include "nsmlchangefinder.h"

#include <VPbkEng.rsg>

#ifndef __WINS__

// This lowers the unnecessary compiler warning (armv5) to remark.

// "Warning:  #174-D: expression has no effect..." is caused by 

// DBG_ARGS8 macro in no-debug builds.

#pragma diag_remark 174

#endif

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

// CNSmlContactsDataStore::CNSmlContactsBufferItem::~CNSmlContactsBufferItem

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

CNSmlContactsDataStore::CNSmlContactsBufferItem::~CNSmlContactsBufferItem()

	{

	delete iItemData;

	delete iMimeType;

	delete iMimeVersion;

	}

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

// CNSmlContactsDataStore::NewL

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

CNSmlContactsDataStore* CNSmlContactsDataStore::NewL()

	{

	_DBG_FILE("CNSmlContactsDataStore::NewL: BEGIN");

	CNSmlContactsDataStore* self = new ( ELeave ) CNSmlContactsDataStore();

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self); // self

	_DBG_FILE("CNSmlContactsDataStore::NewL: END");

	return self;

	}

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

// CNSmlContactsDataStore::CNSmlContactsDataStore() 

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

CNSmlContactsDataStore::CNSmlContactsDataStore() : 

	iKey( TKeyArrayFix( _FOFF( TNSmlSnapshotItem,ItemId() ),ECmpTInt )),

	iContactManager(NULL),

	iStore(NULL),

	iVCardEngine(NULL),

	iIdConverter(NULL),

	iContactLnks(NULL),

	iContactViewBase(NULL),

	iSize(NULL),	

	iBuf(NULL)

	{

	_DBG_FILE("CNSmlContactsDataStore::CNSmlContactsDataStore(): begin");

	iSyncHistory = EFalse;

	iSnapshotRegistered = EFalse;

	iServerMaxObjectSize = 0; // Maximum size default value 

	iItemPos = -1;

	iModificationCount = KNSmlCompactAfterChanges;

	iState = ENSmlClosed;

	iStoreName = NULL;

	iRetCommand = KErrNone;

	iLastOperation = ENSmlNone;

	_DBG_FILE("CNSmlContactsDataStore::CNSmlContactsDataStore(): end");

	}

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

// CNSmlContactsDataStore::ConstructL()

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

void CNSmlContactsDataStore::ConstructL()

	{

	_DBG_FILE("CNSmlContactsDataStore::CNSmlContactsDataStore(): begin");

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

	iUsedMimeType.Set( KNSmlvCard21Name() );

	iUsedMimeVersion.Set( KNSmlvCard21Ver() );

	iStringPool.OpenL();

	// Uid Sets

	iNewUids = new (ELeave) CNSmlDataItemUidSet();

	iDeletedUids = new (ELeave) CNSmlDataItemUidSet();

	iSoftDeletedUids = new (ELeave) CNSmlDataItemUidSet();

	iMovedUids = new (ELeave) CNSmlDataItemUidSet();

	iReplacedUids = new (ELeave) CNSmlDataItemUidSet();

	// Create iDataMod

	// This should be done after OpenL if there are more than one database

	iDataMod = new (ELeave) CNSmlVCardMod();

	SetOwnStoreFormatL();

	// open  contact database

	CVPbkContactStoreUriArray* uriArray = CVPbkContactStoreUriArray::NewLC();

	uriArray->AppendL( TVPbkContactStoreUriPtr(VPbkContactStoreUris::DefaultCntDbUri()));

	iContactManager = CVPbkContactManager::NewL(*uriArray);

	CleanupStack::PopAndDestroy(uriArray);

	//Default store name

	iDefaultStoreName = (VPbkContactStoreUris::DefaultCntDbUri()).AllocL();

	//Fill iPacketStoreName buffer with KLegacySymbianDatabase

    TBuf<KOldSymbianDBLength> dataBase(KLegacySymbianDatabase);

	iPacketStoreName = HBufC::NewL(dataBase.Length());        

	TPtr pktStorePtr(iPacketStoreName->Des());

	pktStorePtr.Copy(dataBase);

	_DBG_FILE("CNSmlContactsDataStore::ConstructL(): end");

	}

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

// CNSmlContactsDataStore::~CNSmlContactsDataStore()

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

CNSmlContactsDataStore::~CNSmlContactsDataStore()

	{

	_DBG_FILE("CNSmlContactsDataStore::~CNSmlContactsDataStore(): begin");

	delete iStoreFormat; // SetOwnStoreFormatL creates

	iStringPool.Close();

	iRfs.Close();

	iWriteStream.Close();

	iReadStream.Close();

	delete iBuf;

	if ( iChangeFinder )

		{

		TRAP_IGNORE( iChangeFinder->CloseL() );

		delete iChangeFinder;

		}

	if(iIdConverter)

		{

		delete iIdConverter;

		}

	if(iContactLnks)

		{

		delete iContactLnks;

		}

	if(iContactLink)

		{

		delete iContactLink;	

		}

	delete iContactViewBase;

	if ( iContactsModsFetcher )

		{

		iContactsModsFetcher->Cancel(); 

		delete iContactsModsFetcher;

		}

	if ( iContactManager )

		{

			if(iStore)

			{

			iStore->Close( *this );	

			}

	    delete iContactManager;

		}

	delete iVCardEngine;

	//  Delete UidSets		

	//

	delete iNewUids;

	delete iDeletedUids;

	delete iSoftDeletedUids;

	delete iMovedUids;

	delete iReplacedUids;

	//

	//	Empty BufferItemList if any

	//

	if ( iContactsBufferItemList.Count() > 0 )

		{

		if ( iContactsBufferItemList[iContactsBufferItemList.Count() - 1]->iItemData == iItemData )

			{

			iItemData = NULL;

			}

		}

	iContactsBufferItemList.ResetAndDestroy();

	delete iDataMod;

	delete iMergeItem;

	if(iItemData)

    	{

	    if(iItemData->Size() > 0 )

	        {

		    delete iItemData;       

	        }

	    }

	if(iItemDataAddBatch != iItemData)

		{

		delete iItemDataAddBatch;	

		}

	delete iDefaultStoreName;

	delete iPacketStoreName;

	delete iStoreName;

	iAddResultArray.Close();

	}

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

// void CNSmlContactsDataStore::DoOpenL(const TDesC& 		  aStoreName, 

//									    MSmlSyncRelationship& aContext,

//									    TRequestStatus& 	  aStatus)

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

void CNSmlContactsDataStore::DoOpenL( const TDesC& aStoreName, 

									MSmlSyncRelationship& aContext, 

									TRequestStatus& aStatus )

	{

	DBG_ARGS(_S("CNSmlContactsDataStore::DoOpenL(): '%S' begin"), &aStoreName);

	iCallerStatus = &aStatus;

	*iCallerStatus = KRequestPending;

	if( iState != ENSmlClosed )

		{

		User::RequestComplete( iCallerStatus, KErrInUse );	

		return;	

		}

	if( RFs::CharToDrive(aStoreName[0], iDrive) != KErrNone )

		{

		RFs::CharToDrive( KNSmlDriveC()[0], iDrive );

		}

	iOpened = EFalse;

	if( iStoreName )

		{

		delete iStoreName;

		iStoreName = NULL;

		}

		if ( iChangeFinder )

		{

		iChangeFinder->CloseL();

		delete iChangeFinder;

		iChangeFinder = NULL;

		}

	// The Change finder maintains a list of all changes to the database.

	iChangeFinder = CNSmlChangeFinder::NewL(

					 aContext, iKey, iSyncHistory, KNSmlContactsAdapterImplUid );

	iState = ENSmlOpenAndWaiting;			

	//find and open the store

	if ( aStoreName == KNSmlContactStoreNameForDefaultDB )

	    {

	iStore = iContactManager->ContactStoresL().Find(

	TVPbkContactStoreUriPtr(*iDefaultStoreName));

	    }

	else

	   {

	    iStore = iContactManager->ContactStoresL().Find(

	TVPbkContactStoreUriPtr(aStoreName));

	    }

	iStore->OpenL(*this);

	iStoreName = aStoreName.AllocL();

	iVCardEngine = CVPbkVCardEng::NewL( *iContactManager );

	iIdConverter = CVPbkContactIdConverter::NewL(*iStore );

	if ( iContactsModsFetcher )

		{

		iContactsModsFetcher->Cancel();

		delete iContactsModsFetcher;

		iContactsModsFetcher = NULL;

		}

	iContactsModsFetcher = new (ELeave) CNSmlContactsModsFetcher( 

							iSnapshotRegistered, *iContactManager,*iStore, iKey, *iChangeFinder );

	iContactsModsFetcher->ConstructL();

#ifdef __NSML_MODULETEST__

	CActiveScheduler::Start();

#endif

	_DBG_FILE("CNSmlContactsDataStore::DoOpenL(): end");

	}

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

// void CNSmlContactsDataStore::DoCancelRequest()

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

void CNSmlContactsDataStore::DoCancelRequest()

	{

	_DBG_FILE("CNSmlContactsDataStore::DoCancelRequest(): begin");

		if(iContactsModsFetcher)

		{

		iContactsModsFetcher->Cancel();

		}

	_DBG_FILE("CNSmlContactsDataStore::DoCancelRequest(): NOT NEEDED end");

	}

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

// void CNSmlContactsDataStore::DoStoreName()

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

const TDesC& CNSmlContactsDataStore::DoStoreName() const

	{

	_DBG_FILE("CNSmlContactsDataStore::DoStoreName(): begin");

	_DBG_FILE("CNSmlContactsDataStore::DoStoreName(): end");

	return *iStoreName;

	}

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

// void CNSmlContactsDataStore::DefaultStoreNameL()

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

const TDesC& CNSmlContactsDataStore::DefaultStoreNameL() const

	{

	_DBG_FILE("CNSmlContactsDataStore::DefaultStoreNameL(): begin");

	if ( !iDefaultStoreName )

		{

		return KNullDesC;

		}

	_DBG_FILE("CNSmlContactsDataStore::DefaultStoreNameL(): end");

	//The engine methods that create syncml packet, use this information in Database fields

	return *iPacketStoreName;

	}

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

// void CNSmlContactsDataStore::DoBeginTransactionL()

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

void CNSmlContactsDataStore::DoBeginTransactionL()

	{

	_DBG_FILE("CNSmlContactsDataStore::DoBeginTransactionL(): begin");

	User::Leave( KErrNotSupported );

	_DBG_FILE("CNSmlContactsDataStore::DoBeginTransactionL(): end");

	}

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

// void CNSmlContactsDataStore::DoCommitTransactionL()

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

void CNSmlContactsDataStore::DoCommitTransactionL(TRequestStatus& aStatus)

	{

	_DBG_FILE("CNSmlContactsDataStore::DoCommitTransactionL(): begin");

	iCallerStatus = &aStatus;

	*iCallerStatus = KRequestPending;

	User::RequestComplete( iCallerStatus, KErrNotSupported );

	_DBG_FILE("CNSmlContactsDataStore::DoCommitTransactionL(): end");

	}

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

// void CNSmlContactsDataStore::DoRevertTransaction()

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

void CNSmlContactsDataStore::DoRevertTransaction(TRequestStatus& aStatus)

	{

	_DBG_FILE("CNSmlContactsDataStore::DoRevertTransaction(): begin");

	iCallerStatus = &aStatus;

	*iCallerStatus = KRequestPending;

	User::RequestComplete( iCallerStatus, KErrNotSupported );

	_DBG_FILE("CNSmlContactsDataStore::DoRevertTransaction(): end");

	}

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

// void CNSmlContactsDataStore::DoBeginBatchL()

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

void CNSmlContactsDataStore::DoBeginBatchL()

	{

	_DBG_FILE("CNSmlContactsDataStore::DoBeginBatchL(): begin");

	iBatchMode = ETrue;			// SUPPORTED on Contacts

	_DBG_FILE("CNSmlContactsDataStore::DoBeginBatchL(): end");

	}

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

// void CNSmlContactsDataStore::DoCommitBatchL()

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

void CNSmlContactsDataStore::DoCommitBatchL( RArray<TInt>& aResultArray, TRequestStatus& aStatus )

	{

	_DBG_FILE("CNSmlContactsDataStore::DoCommitBatchL(): begin");

	iCallerStatus = &aStatus;

	*iCallerStatus = KRequestPending;

	if( !iBatchMode )

		{

		User::RequestComplete( iCallerStatus, KErrNotReady );

		_DBG_FILE("CNSmlContactsDataStore::DoCommitBatchL(): NOT ON BATCH MODE end");

		return;

		}

//		

// Go through Buffer and execute all commands return aResultArray

//

	iResultArray = &aResultArray;

	iIndex = 0;

	TRAPD( leavecode,ExecuteBufferL() );

	if( leavecode != KErrNone )

		{

		User::RequestComplete( iCallerStatus, leavecode );

		}

	_DBG_FILE("CNSmlContactsDataStore::DoCommitBatchL(): end");

	}

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

// void CNSmlContactsDataStore::ExecuteBufferL()

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

void CNSmlContactsDataStore::ExecuteBufferL() 

	{

	_DBG_FILE("CNSmlContactsDataStore::ExecuteBufferL(): begin");

	TInt  retCommand( KErrNone );

	//

	// Loop through buffered commands

	//

		if( iIndex < iContactsBufferItemList.Count())

		{

		if( iContactsBufferItemList[iIndex]->iStatus!= KNSmlNoError )

			{

			retCommand = iContactsBufferItemList[iIndex]->iStatus;

			}

		else if( iContactsBufferItemList[iIndex]->iModType == ENSmlCntItemAdd )

			{

			retCommand = ExecuteAddL();

			}

		else if( iContactsBufferItemList[iIndex]->iModType == ENSmlCntItemReplace )

			{

			ExecuteUpdateL();		

			}

		else if( iContactsBufferItemList[iIndex]->iModType == ENSmlCntItemMove )

			{

			ExecuteMoveL();

			}

		else if( iContactsBufferItemList[iIndex]->iModType == ENSmlCntItemDelete ||

				 iContactsBufferItemList[iIndex]->iModType == ENSmlCntItemSoftDelete )

			{

			ExecuteDeleteL();

			}

		//

		//	Set allready set commands from iContactsBufferItemList

		//

		if( ( iContactsBufferItemList[iIndex]->iModType == ENSmlCntItemAdd     ||

		      iContactsBufferItemList[iIndex]->iModType == ENSmlCntItemReplace ||

		      iContactsBufferItemList[iIndex]->iModType == ENSmlCntItemDelete  ||

		      iContactsBufferItemList[iIndex]->iModType == ENSmlCntItemSoftDelete ) &&

		      iContactsBufferItemList[iIndex]->iStatus  != KNSmlNoError )

			{

			retCommand = iContactsBufferItemList[iIndex]->iStatus;

			}

		//if an error occurs when performing any operation

		//return the error status 

			else if(retCommand!=KErrNone)

			{

			User::RequestComplete( iCallerStatus, retCommand );	

			}

			iRetCommand = retCommand;