// Copyright (c) 2008-2009 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:

 //

 #include "pccenrepimpl.h"

 _LIT(KCreExt,".cre");

 _LIT(KTxtExt,".txt");

 _LIT(KOgnExt,".ogn");

 const TInt KExtLength=4;

 const TInt KMinReposFileLength=12;

 //dummy fail transaction cleanup operation

 void CPcRepImpl::FailTransactionCleanupOperation(TAny* /**aRepository*/)

     {

     //do nothing

     }

 CPcRepImpl* CPcRepImpl::NewL(TUid aRepositoryUid,const TDesC& aInFileName,const TDesC& aOutFileName,TBool aAutoLoading)

 	{

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

 	CleanupStack::PushL(self);

 	self->ConstructL(aRepositoryUid,aInFileName,aOutFileName,aAutoLoading);

 	CleanupStack::Pop();

 	return self;

 	}

 void CPcRepImpl::ConstructL(TUid aRepositoryUid,const TDesC& aInFileName,const TDesC& aOutFileName,TBool aAutoLoading)

 	{

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

 	iRepository=CHeapRepository::NewL(aRepositoryUid);

 	TFileName ognFile; // XXXXXXXX.ogn

 	TBool isOriginal;

 	IsOriginalL(aRepositoryUid, aOutFileName, aAutoLoading, ognFile, isOriginal);

 	iRepository->SettingsArray().SetIsDefault(isOriginal);

 	if (!aAutoLoading)

 		{

 		//verify file name must be in format of XXXXXXXX.<cre/txt> that is minimum length is 8+1+3=12

 		if (aInFileName.Length()<KMinReposFileLength || aOutFileName.Length()<KMinReposFileLength)

 			User::Leave(KErrArgument);

 		//verify it is in the format of <path>XXXXXXXX.<cre/txt>

 		TPtrC inFileName(aInFileName.Right(KMinReposFileLength));

 		TPtrC outFileName(aOutFileName.Right(KMinReposFileLength));

 		TUint inRepUid;

 		TLex parser(inFileName.Left(8));

 		TInt ret=parser.Val(inRepUid,EHex);

 		if (ret!=KErrNone)

 			(ret==KErrNoMemory)?User::Leave(ret):User::Leave(KErrArgument);

 		parser.Assign(outFileName.Left(8));

 		TUint outRepUid;

 		ret=parser.Val(outRepUid,EHex);

 		if (ret!=KErrNone)

 			(ret==KErrNoMemory)?User::Leave(ret):User::Leave(KErrArgument);

 		//now finally verify the extension of the output file

 		if (aOutFileName.Right(KExtLength).CompareF(KCreExt())!=0)						

 			User::Leave(KErrArgument);

 		if (aInFileName.Right(KExtLength).CompareF(KTxtExt())==0)

 			{

 			iRepository->SetUid(TUid::Uid(inRepUid));

 			CIniFileIn* iniFile=NULL;

 			ret=CIniFileIn::NewLC(iFs,iniFile,aInFileName);

 			User::LeaveIfError(ret);

 			iRepository->ReloadContentL(*iniFile);

 			CleanupStack::PopAndDestroy();		

 			}

 		else if (aInFileName.Right(KExtLength).CompareF(KCreExt())==0)

 			{

 			iRepository->SetUid(TUid::Uid(inRepUid));

 			iRepository->CreateRepositoryFromCreFileL(iFs,aInFileName);

 			}

 		else

 			User::Leave(KErrArgument);

 		iOutFileName=aOutFileName.AllocL();

 		}

 	else

 		{

 		//auto mode look for CRE first then TXT

 		TFileName crefile;

 		crefile.AppendNumFixedWidth(aRepositoryUid.iUid,EHex,8);

 		crefile.Append(KCreExt());

 		TInt ret=KErrNone;

 		TRAP(ret,iRepository->CreateRepositoryFromCreFileL(iFs,crefile));

 		if (ret!=KErrNone)		

 			{

 			if (ret!=KErrNotFound)

 				User::Leave(ret);

 			//look for TXT now

 			TFileName file;

 			file.AppendNumFixedWidth(aRepositoryUid.iUid,EHex,8);

 			file.Append(KTxtExt());

 			CIniFileIn* iniFile=NULL;

 			ret=CIniFileIn::NewLC(iFs,iniFile,file);

 			User::LeaveIfError(ret);

 			iRepository->ReloadContentL(*iniFile);

 			CleanupStack::PopAndDestroy();

 			}

 		//output is always cre	

 		iOutFileName=crefile.AllocL();

 		}

 	GetSingleMetaArrayL(iSingleMetaArray);

 	if (isOriginal)

 		{

 		// An empty file is generated in the name of <Repository Uid>.ogn when

 		// the repository is loaded for the first time. see IsOriginalL().

 		RFile file;

 		User::LeaveIfError(file.Create(iFs, ognFile, EFileWrite));

 		file.Close();

 		}

 	iInitialised=ETrue;

 	}

 CPcRepImpl::~CPcRepImpl()

 	{

 	/** persist to cre on destructor */	

 	if (iRepository && iInitialised)

 		Flush();

 	iFs.Close();

 	iSingleMetaArray.Close();

 	delete iRepository;

 	delete iOutFileName;

 	}

 TInt CPcRepImpl::Flush()

 	{

 #ifdef SYMBIAN_CENTREP_SUPPORT_MULTIROFS

 	return iRepository->CommitChanges(iFs,KPersistFormatSupportsIndMetaIndicator,*iOutFileName);

 #else	

 	return iRepository->CommitChanges(iFs,KPersistFormatVersion,*iOutFileName);

 #endif		

 	}

 void CPcRepImpl::MoveL(TUint32 aSourcePartialKey, TUint32 aTargetPartialKey,TUint32 aMask, TUint32& aErrorKey)

 	{

 	RSettingPointerArray sourceSettings;

 	CleanupClosePushL(sourceSettings);

 	TInt error=iRepository->SettingsArray().Find(aSourcePartialKey & aMask, aMask, sourceSettings);

 	//dont fail transaction if source settings is empty

 	if (error!=KErrNone)

 		{

 		aErrorKey = aSourcePartialKey;

 		User::Leave(error);				

 		}

 	else if (sourceSettings.Count() == 0)

 		{

 		aErrorKey = aSourcePartialKey;

 		User::Leave(KErrNotFound);				

 		}

 	for (TInt i=0;i<sourceSettings.Count();i++)

 		{

 		TServerSetting* ts=sourceSettings[i];

 		TUint32 sourceKey = ts->Key();

 		TUint32 targetKey = sourceKey ^ ((aSourcePartialKey & aMask) ^ (aTargetPartialKey & aMask));

 		TServerSetting* targetSetting = GetSetting(targetKey);

 		if (targetSetting && !targetSetting->IsDeleted())

 			{

 			aErrorKey=targetKey;

 			User::Leave(KErrAlreadyExists);

 			}

 		}

 	TRAPD(err,error = MOperationLogic::MoveL(aSourcePartialKey,aTargetPartialKey,aMask,aErrorKey, sourceSettings));

 	//the Move operation logic only mark it as deleted, now remove it from the settings list	

 	RemoveAnyMarkDeleted();

 	User::LeaveIfError(err);

 	User::LeaveIfError(error);

 	CleanupStack::PopAndDestroy(&sourceSettings);

 	}

 void CPcRepImpl::DeleteRangeL(TUint32 aPartialKey, TUint32 aMask,TUint32& aErrorKey)

 	{

 	RSettingPointerArray sourceSettings;

 	CleanupClosePushL(sourceSettings);

 	TInt error=FindSettings(aPartialKey & aMask, aMask, sourceSettings);

 	if (error==KErrNotFound)

 		{

 		aErrorKey=aPartialKey;

 		}

 	User::LeaveIfError(error);

 	DeleteSettingsRangeL(sourceSettings,aPartialKey,aErrorKey);

 	RemoveAnyMarkDeleted();

 	CleanupStack::PopAndDestroy(&sourceSettings);		

 	}

 void CPcRepImpl::GetSingleMetaArrayL(RSingleMetaArray& aMetaArray)

 	{	

 	TInt numSettings = iRepository->SettingsArray().Count();

 	aMetaArray.Reset();

 	aMetaArray.ReserveL(numSettings);

 	for (TInt i = 0; i < numSettings; i++)

 		{

 		TUint32 key = iRepository->SettingsArray()[i].Key();

 		TUint32 meta = iRepository->SettingsArray()[i].Meta();

 		TSettingSingleMeta metaItem(key, meta);

 		aMetaArray.AppendL(metaItem);

 		}

 	}

 // This function is used to identify wether the repository is loaded for the first

 // time or not. The purpose of this function is to determine whether entries of a 

 // repository should be set clean during initializing process. At symbian side, this 

 // flag is only set when load from ROM, but at PC side, there is no ROM, so the clean 

 // flag is set when load for the first time to keep consistency with Symbian side Library. 

 void CPcRepImpl::IsOriginalL(TUid aUid, const TDesC& aOutFile, TBool aAutoLoading, TFileName& aOgnFileName, TBool& aIsOriginal)

 	{

 	if (!aAutoLoading)

 		{

 		TInt len = aOutFile.Length();

 		aOgnFileName = aOutFile.Left(len - KExtLength);

 		}

 	else 

 		{

 		aOgnFileName.AppendNumFixedWidth(aUid.iUid,EHex,8);

 		}

 	aOgnFileName.Append(KOgnExt());

 	RFile file;

 	TInt err = file.Open(iFs,aOgnFileName,EFileRead|EFileShareReadersOnly);

 	file.Close();

 	if (err != KErrNone)

 		{

 		if (err == KErrNotFound || err == KErrPathNotFound)

 			{

 			aIsOriginal = ETrue;

 			return;

 			}

 		else

 			User::Leave(err);

 		}

 	aIsOriginal = EFalse;

 	}