/*

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

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

EXPORT_C CNSmlContactsDataStore::CNSmlContactsBufferItem::~CNSmlContactsBufferItem()

	{

	delete iItemData;

	delete iMimeType;

	delete iMimeVersion;

	}

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

// CNSmlContactsDataStore::NewL

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

EXPORT_C 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() 

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

EXPORT_C CNSmlContactsDataStore::CNSmlContactsDataStore() : 

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

	iContactManager(NULL),

	iStore(NULL),

	iIdConverter(NULL),

	iContactViewBase(NULL),

	iSize(NULL),	

	iBuf(NULL),

	iVCardEngine(NULL),

	iContactLnks(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;

	if(iDeleteAllOperation)

	    {

	    delete iDeleteAllOperation;

	    iDeleteAllOperation = NULL;

	    }

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

	}

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

// CNSmlContactsDataStore::ConstructL()

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

EXPORT_C void CNSmlContactsDataStore::ConstructL()

	{

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

	ConstructL( ( VPbkContactStoreUris::DefaultCntDbUri() ), KLegacySymbianDatabase );

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

	}

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

// CNSmlContactsDataStore::ConstructL()

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

EXPORT_C void CNSmlContactsDataStore::ConstructL(

    const TDesC& aStoreName, const TDesC& aLegacyStore )

    {

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

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

    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( aStoreName ));

    iContactManager = CVPbkContactManager::NewL(*uriArray);

    CleanupStack::PopAndDestroy(uriArray);

    //Default store name

    iDefaultStoreName = aStoreName.AllocL();

    //Fill iPacketStoreName buffer with legacy store name

    TBuf<KOldSymbianDBLength> dataBase(aLegacyStore);

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

    TPtr pktStorePtr(iPacketStoreName->Des());

    pktStorePtr.Copy(dataBase);

    iDeleteAllOperation = NULL;

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

    }

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

// CNSmlContactsDataStore::~CNSmlContactsDataStore()

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

EXPORT_C 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;

		iChangeFinder = NULL;

		}

	if(iIdConverter)

		{

		delete iIdConverter;

		iIdConverter = NULL;

		}

	if(iContactLnks)

		{

        delete iContactLnks;

		iContactLnks = NULL;

		}

	if(iContactViewBase)

	    {

	    delete iContactViewBase;

	    iContactViewBase = NULL;

	    }

	if ( iContactsModsFetcher )

		{

		iContactsModsFetcher->CancelRequest(); 

		delete iContactsModsFetcher;

		iContactsModsFetcher = NULL;

		}

	if ( iContactManager )

		{

			if(iStore)

			{

			iStore->Close( *this );	

			}

	    delete iContactManager;

	    iContactManager = NULL;

		}

	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();

	if(iDeleteAllOperation)

	    {

	    delete iDeleteAllOperation;

	    iDeleteAllOperation = NULL;

	    }

	}

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

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

//									    MSmlSyncRelationship& aContext,

//									    TRequestStatus& 	  aStatus)

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

EXPORT_C 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->CancelRequest();

		delete iContactsModsFetcher;

		iContactsModsFetcher = NULL;

		}

	iContactsModsFetcher = CreateModsFetcherL();

#ifdef __NSML_MODULETEST__

	CActiveScheduler::Start();

#endif

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

	}

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

// void CNSmlContactsDataStore::DoCancelRequest()

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

EXPORT_C void CNSmlContactsDataStore::DoCancelRequest()

	{

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

	if(iLastOperation == ENSMLDeleteAllOp)

	    {   

	    if(iDeleteAllOperation)

	        {

	        delete iDeleteAllOperation;

	        iDeleteAllOperation = NULL;

	        }

	    if( iChangeFinder )

	        {

            TRAP_IGNORE(iChangeFinder->ResetL());

	        }

	    iSnapshotRegistered = EFalse;

	    if(iContactLnks)

	        {

	        delete iContactLnks;

	        iContactLnks = NULL;

			iContactLink = NULL;

	        }

	    if(iContactViewBase)

	        {

	        delete iContactViewBase;

	        iContactViewBase = NULL;

	        }

	    User::RequestComplete( iCallerStatus, KErrCancel );  

	    }

		if(iContactsModsFetcher)

		{

		iContactsModsFetcher->CancelRequest();

		}

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

	}

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

// void CNSmlContactsDataStore::DoStoreName()

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

EXPORT_C const TDesC& CNSmlContactsDataStore::DoStoreName() const

	{

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

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

	return *iStoreName;

	}

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

// void CNSmlContactsDataStore::DefaultStoreNameL()

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

EXPORT_C 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()

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

EXPORT_C void CNSmlContactsDataStore::DoBeginTransactionL()

	{

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

	User::Leave( KErrNotSupported );

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

	}

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

// void CNSmlContactsDataStore::DoCommitTransactionL()

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

EXPORT_C 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()

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

EXPORT_C 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()

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

EXPORT_C void CNSmlContactsDataStore::DoBeginBatchL()

	{

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

	iBatchMode = ETrue;			// SUPPORTED on Contacts

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

	}

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

// void CNSmlContactsDataStore::DoCommitBatchL()

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

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

	{

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

	iCallerStatus = &aStatus;

	*iCallerStatus = KRequestPending;

	if( !iBatchMode )

		{

		User::RequestComplete( iCallerStatus, KErrNotReady );