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