/*

* Copyright (c) 2005-2009 Nokia Corporation and/or its subsidiary(-ies). 

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of the License "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:

*

*/

/**

@test

@internalComponent

This contains CT_FileManData

*/

//	User includes

#include "T_FileManData.h"

#include "T_SfSrvServer.h"

const TInt KMaxFileNameLength		=255;

/*@{*/

///	Parameters

_LIT(KPath,										"path");

_LIT(KFileName,									"filename");

_LIT(KFileFrom,									"filefrom");

_LIT(KFileTo,									"fileto");

_LIT(KOldName,									"oldname");

_LIT(KNewName,									"newname");

_LIT(KRFsObject,								"rfsObject");

_LIT(KRFileObject,								"rfileObject");

_LIT(KUseObserver,								"use_observer");

_LIT(KAsync,									"async");

_LIT(KTime,										"time");

_LIT(KSetMask,									"setmask");

_LIT(KClearMask,								"clearmask");

_LIT(KOperation,								"operation");

_LIT(KCurrentAction,							"current_action");

_LIT(KBytes,									"bytes");

_LIT(KError,									"error");

_LIT(KTarget,									"target");

_LIT(KSource,									"source");

_LIT(KNotifyType,								"notify_type");

_LIT(KReadHistory,								"read_history");

_LIT(KName,										"name");

_LIT(KNullDesCStr,								"KNullDesC");

_LIT(KTotalBytes,								"total_bytes");

_LIT(KFlag,										"flag");

_LIT(KClearHistory,								"clear_history");

_LIT(KSetTcontrol,								"set_tcontrol");

//For searching file names.

_LIT(KPattern, 									"*%S*");

/// Commands

_LIT(KCmdNewL,									"NewL");

_LIT(KCmdAttribs,								"Attribs");

_LIT(KCmdCopy,									"Copy");

_LIT(KCmdMove,									"Move");

_LIT(KCmdDelete,								"Delete");

_LIT(KCmdRename,								"Rename");

_LIT(KCmdRmDir,									"RmDir");

_LIT(KCmdSetObserver,							"SetObserver");

_LIT(KCmdCurrentAction,							"CurrentAction");

_LIT(KCmdGetCurrentTarget,						"GetCurrentTarget");

_LIT(KCmdGetCurrentSource,						"GetCurrentSource");

_LIT(KCmdBytesTransferredByCopyStep,			"BytesTransferredByCopyStep");

_LIT(KCmdCurrentEntry,							"CurrentEntry");

_LIT(KCmdAbbreviatedPath,						"AbbreviatedPath");

_LIT(KCmdFullPath,								"FullPath");

_LIT(KCmdGetLastError,							"GetLastError");

_LIT(KCmdGetMoreInfoAboutError,					"GetMoreInfoAboutError");

_LIT(KCmdDestructor,							"~");

// TActions

_LIT(KENone,									"ENone");

_LIT(KEAttribs,									"EAttribs");

_LIT(KECopy,									"ECopy");

_LIT(KEDelete,									"EDelete");

_LIT(KEMove,									"EMove");

_LIT(KERename,									"ERename");

_LIT(KERmDir,									"ERmDir");

_LIT(KERenameInvalidEntry,						"ERenameInvalidEntry");

_LIT(KECopyFromHandle,							"ECopyFromHandle");

// TSwitch

_LIT(KEOverWrite,								"EOverWrite");

_LIT(KERecurse,									"ERecurse");

// TControl

_LIT(KEContinue,								"EContinue");

_LIT(KEAbort,									"EAbort");

_LIT(KECancel,									"ECancel");

_LIT(KERetry,									"ERetry");

// TFileManError

_LIT(KENoExtraInformation,						"ENoExtraInformation");

_LIT(KEInitializationFailed,					"EInitializationFailed");

_LIT(KEScanNextDirectoryFailed,					"EScanNextDirectoryFailed");

_LIT(KESrcOpenFailed,							"ESrcOpenFailed");

_LIT(KETrgOpenFailed,							"ETrgOpenFailed");

_LIT(KENoFilesProcessed,						"ENoFilesProcessed");

//Notifys

_LIT(KNotifyStarted,							"started");

_LIT(KNotifyOperation,							"operation");

_LIT(KNotifyEnded,								"ended");

CT_FileManData* CT_FileManData::NewL()

/**

* Two phase constructor

*/

	{

	CT_FileManData* ret = new (ELeave) CT_FileManData();

	CleanupStack::PushL(ret);

	ret->ConstructL();

	CleanupStack::Pop(ret);

	return ret;

	}

CT_FileManData::CT_FileManData()

:	iFileMan(NULL)

,	iAsyncErrorIndex(0)

,	iAsyncCall(EFalse)

,	iFileManObserver(NULL)

,	iUseTControl(EFalse)

/**

* Protected constructor. First phase construction

*/

	{

	}

void CT_FileManData::ConstructL()

/**

* Protected constructor. Second phase construction

*/

	{

	}

CT_FileManData::~CT_FileManData()

/**

* Destructor.

*/

	{

	DoCleanup();

	iAttribs.ResetAndDestroy();

	iCopy.ResetAndDestroy();

	iDelete.ResetAndDestroy();

	iMove.ResetAndDestroy();

	iRename.ResetAndDestroy();

	iRmDir.ResetAndDestroy();

	ClearHistory();

	}

TAny* CT_FileManData::GetObject()

	{

	return iFileMan;

	}

TBool CT_FileManData::DoCommandL(const TTEFFunction& aCommand, const TTEFSectionName& aSection, const TInt aAsyncErrorIndex)

/**

* Process a command read from the ini file

*

* @param aCommand	the command to process

* @param aSection	the section in the ini file requiring the command to be processed

*

* @return ETrue if the command is processed

*/

	{

	TBool retVal = ETrue;

	if (aCommand == KCmdNewL)

		{

		DoCmdNewL(aSection);

		}

	else if (aCommand == KCmdDestructor)

		{

		DoCleanup();

		}

	else if (aCommand == KCmdAttribs)

		{

		DoCmdAttribsL(aSection, aAsyncErrorIndex);

		}

	else if (aCommand == KCmdCopy)

		{ 

		DoCmdCopyL(aSection, aAsyncErrorIndex);

		}

	else if (aCommand == KCmdMove)

		{

		DoCmdMoveL(aSection, aAsyncErrorIndex);

		}

	else if (aCommand == KCmdDelete)

		{

		DoCmdDeleteL(aSection, aAsyncErrorIndex);

		}

	else if (aCommand == KCmdRename)

		{

		DoCmdRenameL(aSection, aAsyncErrorIndex);

		}	

	else if (aCommand == KCmdRmDir)

		{

		DoCmdRmDirL(aSection, aAsyncErrorIndex);

		}

	else if (aCommand == KCmdSetObserver)

		{

		DoCmdSetObserver();

		}

	else if (aCommand == KCmdCurrentAction)

		{

		DoCmdCurrentAction(aSection);

		}

	else if (aCommand == KCmdGetCurrentTarget)

		{

		DoCmdGetCurrentTarget(aSection);

		}

	else if (aCommand == KCmdGetCurrentSource)

		{

		DoCmdGetCurrentSource(aSection);

		}

	else if (aCommand == KCmdBytesTransferredByCopyStep)

		{

		DoCmdBytesTransferredByCopyStep(aSection);

		}

	else if(aCommand == KCmdCurrentEntry)

		{

		DoCmdCurrentEntryL(aSection);

		}

	else if(aCommand == KCmdAbbreviatedPath)

		{

		DoCmdAbbreviatedPath(aSection);

		}

	else if(aCommand == KCmdFullPath)

		{

		DoCmdFullPath(aSection);

		}

	else if(aCommand == KCmdGetLastError)

		{

		DoCmdGetLastError(aSection);

		}

	else if(aCommand == KCmdGetMoreInfoAboutError)

		{

		DoCmdGetMoreInfoAboutError(aSection);

		}

	return retVal;

	}

void CT_FileManData::DoCleanup()

	{

	INFO_PRINTF1(_L("Doing cleanup"));

	if (iFileMan)

		{

		delete(iFileMan);

		iFileMan = NULL;

		}

	ClearHistory();

	}

/**	Inform the observer that an operation is about to start **/

MFileManObserver::TControl CT_FileManData::NotifyFileManStarted()

	{		

	THistoryData *record = new THistoryData();

	CreateHistoryRecord(*record);

	iStartedHistory.Append(record);

	if(record->iLastError != KErrNone)

		{

		if(iAsyncCall)

			{

			SetAsyncError(iAsyncErrorIndex, record->iLastError);

			iAsyncCall = EFalse;

			}

		else

			{

			SetError(record->iLastError);

			}

		}

	TControl ret = EContinue;	

	//Check if we need to return TControl value specified in INI.

	if(iUseTControl && iObserverNotifyType == ENotifyStarted)

		{

		TBuf<KMaxFileNameLength> buffer;

		buffer.Format(KPattern(), &iNotifyFileName);

		//Check if we need to return TControl for this file.

		if(record->iCurrentSource.Match(buffer) != KErrNotFound)

			{

			iUseTControl = EFalse;

			ret = iTControl;

			}

		}

	return ret;

	}

/**	Informs the observer that an operation, i.e. a copy or a move, is proceeding.	**/	

MFileManObserver::TControl CT_FileManData::NotifyFileManOperation()

	{	

	THistoryData *record = new THistoryData();

	CreateHistoryRecord(*record);

	iOperationHistory.Append(record);

	if(record->iLastError != KErrNone)

		{

		if(iAsyncCall)

			{

			SetAsyncError(iAsyncErrorIndex, record->iLastError);

			iAsyncCall = EFalse;

			}

		else

			{

			SetError(record->iLastError);

			}

		}

	TControl ret = EContinue;

	//Check if we need to return TControl value specified in INI.

	if(iUseTControl && iObserverNotifyType == ENotifyOperation)

		{

		TBuf<KMaxFileNameLength> buffer;

		buffer.Format(KPattern(), &iNotifyFileName);

		//Check if we need to return TControl for this file.

		if(record->iCurrentSource.Match(buffer) != KErrNotFound)

			{

			iUseTControl = EFalse;

			ret = iTControl;

			}

		}

	return ret;

	}

/**	Informs the observer that an operation is complete.	**/	

MFileManObserver::TControl CT_FileManData::NotifyFileManEnded()

	{

	THistoryData *record = new THistoryData();

	CreateHistoryRecord(*record);

	iEndedHistory.Append(record);

	if(record->iLastError != KErrNone)

		{

		if(iAsyncCall)

			{

			SetAsyncError(iAsyncErrorIndex, record->iLastError);

			iAsyncCall = EFalse;

			}

		else

			{

			SetError(record->iLastError);

			}

		}

	TControl ret = EContinue;

	//Check if we need to return TControl value specified in INI.

	if(iUseTControl && iObserverNotifyType == ENotifyEnded)

		{

		TBuf<KMaxFileNameLength> buffer;

		buffer.Format(KPattern(), &iNotifyFileName);

		//Check if we need to return TControl for this file.

		if(record->iCurrentSource.Match(buffer) != KErrNotFound)

			{

			iUseTControl = EFalse;

			ret = iTControl;

			}

		}

	return ret; 

	}

void CT_FileManData::DoCmdNewL(const TDesC& aSection)

	{	

	DoCleanup();

	TBool useObserver = EFalse;

	GET_OPTIONAL_BOOL_PARAMETER(KUseObserver, aSection, useObserver);

	TPtrC	rfsObjectName;

	RFs*	rfsObject = NULL;

	if (GET_MANDATORY_STRING_PARAMETER(KRFsObject, aSection, rfsObjectName))

		{

		rfsObject = (RFs*)GetDataObjectL(rfsObjectName);

		}

	TInt err = KErrNone;

	if(useObserver)

		{

		INFO_PRINTF1(_L("CFileMan::NewL(RFs, MFileManObserver)"));

		TRAP(err, iFileMan = CFileMan::NewL(*rfsObject, iFileManObserver));

		}

	else

		{

		INFO_PRINTF1(_L("CFileMan::NewL(RFs)"));

		TRAP(err, iFileMan = CFileMan::NewL(*rfsObject));

		}

	if (err != KErrNone)

		{

		ERR_PRINTF1(_L("CFileMan object is not created"));

		SetBlockResult(EFail);

		}

	}

void CT_FileManData::DoCmdAttribsL(const TDesC& aSection, TInt aAsyncErrorIndex)

	{

	INFO_PRINTF1(_L("Setting attributes!"));

	TBool dataOk = ETrue;

	//Reading path for file or files.	

	TPtrC	fileName;

	if (!GET_MANDATORY_STRING_PARAMETER(KFileName, aSection, fileName))

		{

		dataOk = EFalse;

		}

	//Reading new TTime from ini

	TPtrC inputTime;

	TTime iniTime;

	if(GET_MANDATORY_STRING_PARAMETER(KTime, aSection, inputTime))

		{	

		TInt err = iniTime.Set(inputTime);

		if (err != KErrNone)

			{

			ERR_PRINTF3(_L("Cannot convert (%S) to time. Error: %d"), &inputTime ,err);

			dataOk = EFalse;

			SetBlockResult(EFail);

			}

		}

	else

		{

		dataOk = EFalse;

		}

	//Reading Async parameter (True/False)	

	TBool async = EFalse;

	if(!GET_MANDATORY_BOOL_PARAMETER(KAsync, aSection, async))

		{

		dataOk = EFalse;

		}

	//Read SetMask attribute

	TUint setMask;

	if(!FileserverUtil::GetAttMask(*this, aSection, KSetMask(), setMask))

		{

		dataOk = EFalse;

		}

	//Read ClearMask attribute

	TUint clearMask;

	if(!FileserverUtil::GetAttMask(*this, aSection, KClearMask(), clearMask))

		{

		dataOk = EFalse;

		}

	//Read operation TSwitch

	TUint operation;

	if(!GetOperationFromConfig(KOperation(), aSection, operation))

		{

		dataOk = EFalse;

		}

	if(dataOk)

		{

		TInt error = KErrNone;

		if(async)

			{

			CActiveCallback* active = CActiveCallback::NewLC(*this);

			iAttribs.AppendL(active);

			CleanupStack::Pop(active);

			error = iFileMan->Attribs(fileName, setMask, clearMask, iniTime, operation, active->iStatus);

			if(error == KErrNone)

				{

				active->Activate(aAsyncErrorIndex);

				iAsyncErrorIndex = aAsyncErrorIndex;

				iAsyncCall = ETrue;

				IncOutstanding();

				}

			}

		else

			{

			error = iFileMan->Attribs(fileName, setMask, clearMask, iniTime, operation);

			}

		if (error != KErrNone)

			{

			ERR_PRINTF3(_L("Attribs(%S) Error: %d"), &fileName, error);

			SetError(error);

			}

		else

			{

			INFO_PRINTF2(_L("Attribs operation on (%S) is successfull!"), &fileName);

			}

		}

	}

void CT_FileManData::DoCmdCopyL(const TDesC& aSection, TInt aAsyncErrorIndex)

	{

	TBool clearHistory = EFalse;

	GET_OPTIONAL_BOOL_PARAMETER(KClearHistory, aSection, clearHistory);

	if(clearHistory)

		{

		ClearHistory();

		}

	TBool setTControl = EFalse;

	GET_OPTIONAL_BOOL_PARAMETER(KSetTcontrol, aSection, setTControl);

	if(setTControl)

		{

		ReadTControl(aSection);

		}

	INFO_PRINTF1(_L("Coping files!"));	

	TBool dataOk = ETrue;

	TPtrC oldName;

	TPtrC rfileObjectName;

	RFile*	rfileObject = NULL;

	if (!GET_OPTIONAL_STRING_PARAMETER(KOldName, aSection, oldName))

		{

		if (GET_OPTIONAL_STRING_PARAMETER(KRFileObject, aSection, rfileObjectName))

			{

			rfileObject = (RFile*)GetDataObjectL(rfileObjectName);

			}

		else

			{