/*

* 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 <nsmlcontactsdatastoreextension.h>

#include <NSmlDataModBase.h>

#include "NSmlContactsDataStore.h"

#include "nsmldebug.h"

#include "nsmlconstants.h"

#include "nsmldsimpluids.h"

#include "nsmlsnapshotitem.h"

#include "nsmlchangefinder.h"

#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

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

	return self;

	}

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

// CNSmlContactsDataStore::CNSmlContactsDataStore() 

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

EXPORT_C CNSmlContactsDataStore::CNSmlContactsDataStore() : iKey( TKeyArrayFix( _FOFF( TNSmlSnapshotItem,ItemId() ),ECmpTInt ))

	{

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

	iSyncHistory = EFalse;

	iSnapshotRegistered = EFalse;

	iServerMaxObjectSize = 0; // Maximum size default value

	iItemPos = -1;

	iModificationCount = KNSmlCompactAfterChanges;

	iState = ENSmlClosed;

	iStoreName = NULL;

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

	}

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

// CNSmlContactsDataStore::ConstructL()

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

EXPORT_C void CNSmlContactsDataStore::ConstructL()

	{

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

	ConstructL( KNSmlContactStoreNameForDefaultDB );		

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

	}

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

// CNSmlContactsDataStore::ConstructL()

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

EXPORT_C void CNSmlContactsDataStore::ConstructL( const TDesC& aStoreName )

    {

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

    //TODO: NOT RESPECTING THE aStoreName VALUE FOR 10.1

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

    iContactsDataStoreExtension = NULL;

    SetOwnStoreFormatL();

    // TODO: Determine the Default StoreName

    iDefaultStoreName = HBufC::NewL(KNSmlDefaultStoreNameMaxSize);

    *iDefaultStoreName = KNSmlContactStoreNameForDefaultDB;

    iSnapshot = new (ELeave) CArrayFixSeg<TNSmlSnapshotItem>(KNSmlContactsGranularity);

    iCntUidList = new(ELeave) CArrayFixFlat<TUid>(KNSmlContactsGranularity);

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

    }

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

// CNSmlContactsDataStore::~CNSmlContactsDataStore()

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

EXPORT_C CNSmlContactsDataStore::~CNSmlContactsDataStore()

	{

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

	delete iStoreFormat; // SetOwnStoreFormatL creates

	iStringPool.Close();

	iRfs.Close();

	if ( iChangeFinder )

		{

		TRAP_IGNORE( iChangeFinder->CloseL() );

		delete iChangeFinder;

		}

	if( iContactsDataStoreExtension )

	    {

        delete iContactsDataStoreExtension;

        iContactsDataStoreExtension = NULL;

	    }

	delete iNewUids;

	delete iDeletedUids;

	delete iSoftDeletedUids;

	delete iMovedUids;

	delete iReplacedUids;

	delete iSnapshot;

    delete iCntUidList;

//

//	Empty BufferItemList if any

//

  if ( iContactsBufferItemList.Count() > 0 )

  {

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

      {

      iItemData = NULL;

      }

  }

	iContactsBufferItemList.ResetAndDestroy();

	delete iDataMod;

	if(iItemData)

    	{

	    if(iItemData->Size() > 0 )

	        {

		    delete iItemData;       

	        }

	    }

	if(iItemDataAddBatch != iItemData)

		{

		delete iItemDataAddBatch;	

		}

	delete iDefaultStoreName;

	delete iStoreName;

	iAddResultArray.Close();

	}

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

// 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 ( iContactsDataStoreExtension )

		{

		delete iContactsDataStoreExtension;

		iContactsDataStoreExtension = NULL;

		}

	TInt err( KErrNone );

	// TODO:Change the storename later	

	TRAP( err, iContactsDataStoreExtension = CNsmlContactsDataStoreExtension::NewL( KNSmlContactStoreNameForDefaultDB() ) );

	if( err == KErrNone )

		{

		iOpened = ETrue;

		iStoreName = aStoreName.AllocL();

		iOpenedStoreId = iContactsDataStoreExtension->MachineIdL();

		}

	else

		{

		DBG_ARGS(_S("CNSmlContactsDataStore::DoOpenL(): result = %d"), err); // Cnt open = err

		iOpened = EFalse;

		delete iStoreName;

		iStoreName = NULL;

		iOpenedStoreId = 0;

		User::RequestComplete( iCallerStatus, err );

		_DBG_FILE("CNSmlContactsDataStore::DoOpenL(): CONTACTS FILE NOTFOUND end");

		return;

		}

	if ( iChangeFinder )

		{

		iChangeFinder->CloseL();

		delete iChangeFinder;

		iChangeFinder = NULL;

		}

	iChangeFinder = CNSmlChangeFinder::NewL( aContext, iKey, iSyncHistory, KNSmlContactsAdapterImplUid );

	iState = ENSmlOpenAndWaiting;		

	err = FetchModificationsL();

	DBG_ARGS(_S("CNSmlContactsDataStore::DoOpenL(): Error: %d"), err);

	User::RequestComplete( iCallerStatus, err );

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

	}

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

// void CNSmlContactsDataStore::DoCancelRequest()

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

EXPORT_C void CNSmlContactsDataStore::DoCancelRequest()

	{

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

	_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");

	return *iDefaultStoreName;

	}

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

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

	if( iItemDataAddBatch )

		{

		iItemDataAddBatch->Reset();

		}

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

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

		return;

		}

//		

// Go through Buffer and execute all commands return aResultArray

// If none of commands succeeds KErrGeneral returned as status otherwise KErrNone returned

//

	TInt err = KErrNone;

	TRAPD( leavecode, err = ExecuteBufferL(aResultArray) );

	if( leavecode != KErrNone )

		{

		err = leavecode;

		}

//

// Empty Buffer

//	

	iContactsBufferItemList.ResetAndDestroy();

	if( iItemDataAddBatch )

		{

		iItemDataAddBatch->Reset();

		}

	iBatchMode = EFalse; // All data handled

	User::RequestComplete( iCallerStatus, err );

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

	}

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

// void CNSmlContactsDataStore::ExecuteBufferL()

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

EXPORT_C TInt CNSmlContactsDataStore::ExecuteBufferL(RArray<TInt>& aResultArray) 

    {

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

    return DoExecuteBufferL( aResultArray );

    }

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

// void CNSmlContactsDataStore::DoCancelBatch()

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

EXPORT_C void CNSmlContactsDataStore::DoCancelBatch()

	{

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

	if( iBatchMode )

		{

		iBatchMode = EFalse;

	//

	//	Empty BufferItemList if any

	//

		iContactsBufferItemList.ResetAndDestroy();

		iItemData = NULL;

		}

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

	}

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

// void CNSmlContactsDataStore::DoSetRemoteStoreFormatL()

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

EXPORT_C void CNSmlContactsDataStore::DoSetRemoteStoreFormatL( const CSmlDataStoreFormat& aServerDataStoreFormat )

	{

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

	TBool foundMime = EFalse;

	//

	// KErrNotSupported is returned if server does not support same mime type 

	// and same mime type version as Data Provider.

	TInt i=0;

	while( i< aServerDataStoreFormat.MimeFormatCount() && !foundMime )

		{

		if( iUsedMimeType.MatchF(aServerDataStoreFormat.MimeFormat(i).MimeType().DesC())      ==0 &&

		    iUsedMimeVersion.MatchF(aServerDataStoreFormat.MimeFormat(i).MimeVersion().DesC())==0 )

			{

			foundMime = ETrue;

			iServerMimeType    = aServerDataStoreFormat.MimeFormat(i).MimeType();

			iServerMimeVersion = aServerDataStoreFormat.MimeFormat(i).MimeVersion();

			}

		i++;

		}

	if( !foundMime )

		{

		_DBG_FILE("CNSmlContactsDataStore::DoSetRemoteStoreFormatL(): SERVER MIMETYPE NOTSUPPORTED end");

		User::Leave( KErrNotSupported );

		}

	iDataMod->SetPartnerStoreFormat( (CSmlDataStoreFormat&) aServerDataStoreFormat );

	SetOwnStoreFormatL();

	TInt error = iDataMod->SetUsedMimeType( iServerMimeType, iServerMimeVersion );

	User::LeaveIfError( error );

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

	return;

	}

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

// void CNSmlContactsDataStore::SetOwnStoreFormatL()

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

EXPORT_C void CNSmlContactsDataStore::SetOwnStoreFormatL()

	{

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

	if( !iStoreFormat )

		{

		TFileName fileName;

		TParse parse;

		fileName = parse.FullName();

		RResourceFile resourceFile;