/*

* 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 "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 "T_ActiveCallbackIO.h"

/*@{*/

_LIT(KStrNull,								" ");

_LIT(KLogErrorFileNotFound,					"File '%S' Not Found. Error %d");

_LIT(KLogErrorFileNotOpened,				"File '%S' Not Opened. Error %d");

_LIT(KLogErrorFormatError,					"Format Error");

/*@}*/

CT_ActiveCallbackIO* CT_ActiveCallbackIO::NewL(CDataWrapperBase& aCallback, TInt aPriority)

	{

	CT_ActiveCallbackIO*	self=new(ELeave) CT_ActiveCallbackIO(aCallback, aPriority);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop();

	return self;

	}

CT_ActiveCallbackIO::~CT_ActiveCallbackIO()

	{

	delete iBuffer;

	iBuffer=NULL;

	}

CT_ActiveCallbackIO::CT_ActiveCallbackIO(CDataWrapperBase& aCallback, TInt aPriority)

:	CActiveCallbackBase(aCallback, aPriority)

,	iBuffer(NULL)

	{

	}

TInt CT_ActiveCallbackIO::BufferLength()

	{

	return iBuffer->Length();

	}

const TDesC8& CT_ActiveCallbackIO::Buffer()

	{

	return *iBuffer;

	}

void CT_ActiveCallbackIO::PrepareFromStringL(TInt aRepeat, const TDesC& aString)

	{

	delete iBuffer;

	iBuffer=NULL;

	TInt	bufferLength=aString.Length()*aRepeat;

	iBuffer=HBufC8::NewL(bufferLength);

	iBuffer->Des().Copy(aString);

	ConvertAndRepeatBuffer(aRepeat);

	}

void CT_ActiveCallbackIO::PrepareFromFileL(TInt aRepeat, const TDesC& aFilename)

	{

	delete iBuffer;

	iBuffer=NULL;

	TFindFile	findFile(iDataWrapperBase.FileServer());

	TInt		err=findFile.FindByDir(aFilename, KStrNull);

	if ( err!=KErrNone )

		{

		iDataWrapperBase.ERR_PRINTF3(KLogErrorFileNotFound, &aFilename, err);

		iDataWrapperBase.SetBlockResult(EFail);

		}

	else

		{

		const TDesC&	fileName=findFile.File();

		RFile			file;

		err=file.Open(iDataWrapperBase.FileServer(), fileName, EFileRead|EFileShareAny);

		if ( err!=KErrNone )

			{

			iDataWrapperBase.ERR_PRINTF3(KLogErrorFileNotOpened, &aFilename, err);

			iDataWrapperBase.SetBlockResult(EFail);

			}

		else

			{

			CleanupClosePushL(file);

			iDataWrapperBase.INFO_PRINTF1(_L("File Opened."));

			// get size

			TInt	bufferLength;

			User::LeaveIfError(file.Size(bufferLength));

			bufferLength*=aRepeat;

			iDataWrapperBase.INFO_PRINTF2(_L("File Size=%d."), bufferLength);

			// read file

			iBuffer=HBufC8::NewL(bufferLength);

			iDataWrapperBase.INFO_PRINTF1(_L("Buffer created."));

			TPtr8	fileData = iBuffer->Des();

			User::LeaveIfError(file.Read(fileData));

			CleanupStack::PopAndDestroy(&file);

			ConvertAndRepeatBuffer(aRepeat);

			}

		}

	}

void CT_ActiveCallbackIO::ConvertAndRepeatBuffer(TInt aRepeat)

	{

	ConvertEscapeChars(iBuffer->Des());

	TPtr8	ptr=iBuffer->Des();

	for ( TInt index=1; index<aRepeat; ++index )

		{

		iBuffer->Des().Append(ptr);

		}

	}

void CT_ActiveCallbackIO::ConvertEscapeChars(TPtr8 aBuffer)

	{

	TInt	ret=KErrNone;

	TInt	length=aBuffer.Length();

	TInt	position=0;

	TBool	escapeFound=EFalse;

	for ( TInt index=0; index<length; ++index )

		{

		TChar	nextChar=aBuffer[index];

		if ( escapeFound )

			{

			switch ( nextChar )

				{

			case 'x':

				{

				//	Check that we have a further 2 characters

				if ( (index+2)<length )

					{

					++index;

					TUint charCode = 0;

					TLex8 lex(aBuffer.Mid(index,2));

					ret = lex.Val(charCode ,EHex);

					aBuffer[position++]=TChar(charCode);

					++index;

					nextChar = aBuffer[index];

					}

				else

					{

					ret=KErrArgument;

					}

				escapeFound=EFalse;

				}

				break;

			case 'n':

				//	\n found newline

				{

				aBuffer[position++]='\n';

				escapeFound=EFalse;

				}

				break;

			case 't':

				//	\t found horizontal tab

				{

				aBuffer[position++]='\t';

				escapeFound=EFalse;

				}

				break;

			case 'v':

				//	\v found vertical tab

				{

				aBuffer[position++]='\v';

				escapeFound=EFalse;

				}

				break;

			case 'b':

				//	\b found backspace

				{

				aBuffer[position++]='\b';

				escapeFound=EFalse;

				}

				break;

			case 'r':

				//	\r found carriage return

				{

				aBuffer[position++]='\r';

				escapeFound=EFalse;

				}

				break;

			case 'f':

				//	\f found form feed

				{

				aBuffer[position++]='\f';

				escapeFound=EFalse;

				}

				break;

			case 'a':

				//	\a found audible alert (bell)

				{

				aBuffer[position++]='\a';

				escapeFound=EFalse;

				}

				break;

			default:

				aBuffer[position++]=nextChar;

				escapeFound=EFalse;

				break;

				}

			}

		else

			{

			if ( aBuffer[index]=='\\' )

				{

				escapeFound=ETrue;

				}

			else

				{

				aBuffer[position++]=aBuffer[index];

				}

			}

		}

	if ( ret!=KErrNone )

		{

		iDataWrapperBase.ERR_PRINTF1(KLogErrorFormatError);

		iDataWrapperBase.SetBlockResult(EFail);

		}

	aBuffer.SetLength(position);

	}