// t_ioread.cpp

// 

// Copyright (c) 2009 - 2010 Accenture. All rights reserved.

// This component and the accompanying materials are made available

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

// Accenture - Initial contribution

//

#include <fshell/ioutils.h>

using namespace IoUtils;

// enum corresponding to RIoReadHandle::TReadMode

_LIT(KReadModeEnum, "full,line,oneormore");

static const TInt KDefaultReadSize = 0x100;

class CIoReadTest : public CCommandBase

	{

public:

	static CCommandBase* NewLC();

	~CIoReadTest();

private:

	CIoReadTest();

	void ReadFileL();

private: // From CCommandBase.

	virtual const TDesC& Name() const;

	virtual const TDesC& Description() const;

	virtual void DoRunL();

	virtual void ArgumentsL(RCommandArgumentList& aArguments);

	virtual void OptionsL(RCommandOptionList& aOptions);

private:

	TFileName2 iFile;

	TInt iReadSize;

	RIoReadHandle::TReadMode iReadMode;

	RBuf iFileContents;

	RIoFile iIoFile;

	RIoReadHandle iFileReader;

	RBuf iReadBuf;

	CTextBuffer* iFileBuffer;

	};

CCommandBase* CIoReadTest::NewLC()

	{

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

	CleanupStack::PushL(self);

	self->BaseConstructL();

	return self;

	}

CIoReadTest::~CIoReadTest()

	{

	iFileContents.Close();

	iIoFile.Close();

	iFileReader.Close();

	iReadBuf.Close();

	delete iFileBuffer;

	}

CIoReadTest::CIoReadTest()

	: iReadSize(KDefaultReadSize)

	{

	}

const TDesC& CIoReadTest::Name() const

	{

	_LIT(KName, "t_ioread");	

	return KName;

	}

const TDesC& CIoReadTest::Description() const

	{

	_LIT(KDescription, "Test harness for iosrv file reading functionality");

	return KDescription;

	}

void CIoReadTest::ReadFileL()

	{

	RFile file;

	LeaveIfErr(file.Open(Fs(), iFile, EFileRead | EFileShareExclusive), _L("Cannot open file '%S'"), &iFile);

	CleanupClosePushL(file);

	TInt fileSize;

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

	RBuf8 contents;

	contents.CreateL(fileSize);

	CleanupClosePushL(contents);

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

	// convert data to 16-bit which is how it'll come out of the io server

	iFileContents.CreateL(fileSize);

	iFileContents.Copy(contents); // copy & expand

	CleanupStack::PopAndDestroy(2, &file); // contents, file

	}

void CIoReadTest::DoRunL()

	{

	// read the file into memory

	ReadFileL();

	LeaveIfErr(iIoFile.Create(IoSession(), iFile, RIoFile::ERead), _L("Cannot create file end point for '%S'"), &iFile);

	iFileReader.CreateL(IoSession());

	iIoFile.AttachL(iFileReader, RIoEndPoint::EForeground);

	iFileReader.SetReadModeL(iReadMode);

	iReadBuf.CreateL(iReadSize);

	iFileBuffer = CTextBuffer::NewL(0x20);

	TInt err;

	do

		{

		iReadBuf.Zero();

		err = iFileReader.Read(iReadBuf);

		iFileBuffer->AppendL(iReadBuf);

		} while (err == KErrNone);

	if (err!=KErrEof) LeaveIfErr(err, _L("Unexpected error from RIoReadHandle::Read"));

	TInt completion = 0;

	if (iFileBuffer->Length() != iFileContents.Length())

		{

		PrintWarning(_L("Amount of data read from file (%d) differs from file size (%d)."), iFileBuffer->Length(), iFileContents.Length());

		completion = 1;

		}

	if (iFileBuffer->Descriptor().Compare(iFileContents) != 0)

		{

		PrintWarning(_L("Data read from file differs from file contents."));

		completion = 1;

		}

	Complete(completion);

	}

void CIoReadTest::ArgumentsL(RCommandArgumentList& aArguments)

	{

	_LIT(KFile, "file");

	_LIT(KFileDescription, "File to test with");

	aArguments.AppendFileNameL(iFile, KFile, KFileDescription);

	}

void CIoReadTest::OptionsL(RCommandOptionList& aOptions)

	{

	_LIT(KReadSize, "size");

	_LIT(KReadSizeDescription, "The size of each read to issue");

	aOptions.AppendIntL(iReadSize, 's', KReadSize, KReadSizeDescription);

	_LIT(KReadMode, "mode");

	_LIT(KReadModeDescription, "The type of read to issue");

	aOptions.AppendEnumL((TInt&)iReadMode, 'm', KReadMode, KReadModeDescription, KReadModeEnum);

	}

EXE_BOILER_PLATE(CIoReadTest)