// Copyright (c) 2003-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 "commands.h"

#ifndef _NO_IAP_PREFS

#include <iapprefs.h>

#endif

_LIT(K_T_MSG_STRUCT_FILE, "c:\\logs\\email\\Entry_Structure.txt");

_LIT(KErrSelectText, "Error! Cannot find entry '%S'.\n");

const TInt KDefaultWaitTime = 5000000;

class TLineReader : public CBase

	{

private:

	RFile& iFile;

	TBuf8<512> iBuffer;

	TInt iBufferIndex;

	TBool Peek(char& rChar)

		{

		TBool characterFound = ETrue;

		if (iBufferIndex == iBuffer.Size())

			{

			// Refresh buffer

			TInt readError = iFile.Read(iBuffer);

			iBufferIndex = 0;

			if ((readError != KErrNone) || (iBuffer.Size() == 0))

				{

				characterFound = EFalse;

				}

			}

		if (characterFound)

			{

			rChar = iBuffer[iBufferIndex];

			}

		return characterFound;

		};

	TBool GetCharacter(char& rChar)

		{

		TBool characterFound = Peek(rChar);

		if (characterFound)

			{

			iBufferIndex++;

			}

		return characterFound;

		}

public:

	TLineReader(RFile& rFile) : iFile(rFile), iBufferIndex(0)

		{};

	HBufC8* GetLineLC()

		{

		// Find next cr or lf (and ignore subsequent cr's or lf's)

		HBufC8* newLine = HBufC8::NewLC(512);

		char ch;

		TBool characterFound = GetCharacter(ch);

		TBool eolFound = EFalse;

		while ((characterFound) && (!eolFound))

			{

			if ((ch == 0x0d) || (ch == 0x0a))

				// cr or lf found, ignore subsequent cr and lf's

				{

				eolFound = ETrue;

				while ((characterFound) && ((ch == 0x0d) || (ch == 0x0a)))

					{

					characterFound = Peek(ch);

					if ((characterFound) && ((ch == 0x0d) || (ch == 0x0a)))

						{

						characterFound = GetCharacter(ch);

						}

					}

				}

			if ((characterFound) && (!eolFound))

				{

				newLine->Des().Append(ch);

				characterFound = GetCharacter(ch);

				}

			}

		return newLine;

		};

	};

//

//

// CMsvTestCleanMessageFolder

//

EXPORT_C void CCleanMessageFolder::StartL(TRequestStatus& aStatus)

	{

	TRAPD(err, iTestUtils.CleanMessageFolderL());

	TRequestStatus* status = &aStatus;

	User::RequestComplete(status, err);

	}

EXPORT_C CCleanMessageFolder::CCleanMessageFolder(CMsvTestUtils& aTestUtils) : iTestUtils(aTestUtils)

	{

	}

//

//

// CAddComment

//

EXPORT_C CAddComment* CAddComment::NewL(const CDesCArrayFlat& aComment, CMsvTestUtils& aTestUtils)

	{

	CAddComment* self = new (ELeave) CAddComment(aTestUtils);

	CleanupStack::PushL(self);

	self->ConstructL(aComment);

	CleanupStack::Pop(self);

	return self;

	}

void CAddComment::ConstructL(const CDesCArrayFlat& aComment)

	{

	// need to construct one big HBufC string to use as the comment

	//  first, find out size of array...

	TInt commentSize = 0;

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

		commentSize += ((aComment[i]).Length() + _L(" ").Size()); // extra 1 added for padding between words.

	//  second, construct HBufC.... 

	iComment = HBufC::NewL(commentSize);

	//  create a pointer to the HBufC, so that we can add text to it.

	TPtr commentPtr = iComment->Des();

	//  now create string

	for(TInt j = 0; j < aComment.Count(); j++)

		{

		commentPtr.Append((aComment)[j]);

		commentPtr.Append(_L(" ")); // extra 1 added for padding between words.

		}

	//  hopefully everything should be added ok!

	}

EXPORT_C void CAddComment::StartL(TRequestStatus& aStatus)

	{

	// now we have to add the debugging line number which we only know at run time...

	TBuf<7> commentString;

	commentString.Format(_L("[%4d] "), iDebugInfo.LineNumber());

	// create a pointer to the HBufC, realloc size and then insert new data...

	iComment = iComment->ReAllocL(iComment->Size() + commentString.Size());

	TPtr commentPtr = iComment->Des();

	commentPtr.Insert(0, commentString);

	iTestUtils.WriteComment(*iComment);

	TRequestStatus* status = &aStatus;

	User::RequestComplete(status, KErrNone);

	}

CAddComment::CAddComment(CMsvTestUtils& aTestUtils) : iTestUtils(aTestUtils)

	{

	}

EXPORT_C CAddComment::~CAddComment()

	{

	delete iComment;

	}

//

//

// CGoClientSide

//

EXPORT_C void CGoClientSide::StartL(TRequestStatus& aStatus)

	{

	iTestUtils.GoClientSideL();

	TRequestStatus* status = &aStatus;

	User::RequestComplete(status, KErrNone);

	}

EXPORT_C CGoClientSide::CGoClientSide(CMsvTestUtils& aTestUtils) : iTestUtils(aTestUtils)

	{}

//

//

// CGoServerSide

//

EXPORT_C void CGoServerSide::StartL(TRequestStatus& aStatus)

	{

	iTestUtils.GoServerSideL();

	TRequestStatus* status = &aStatus;

	User::RequestComplete(status, KErrNone);

	}

EXPORT_C CGoServerSide::CGoServerSide(CMsvTestUtils& aTestUtils) : iTestUtils(aTestUtils)

	{}

//

//

// CResetMessageServer

//

EXPORT_C void CResetMessageServer::StartL(TRequestStatus& aStatus)

	{

	iParentTestHarness.Reset();

	TRequestStatus* status = &aStatus;

	User::RequestComplete(status, KErrNone);

	}

EXPORT_C CResetMessageServer::CResetMessageServer(CMsvClientTest& aParentTestHarness)

	: iParentTestHarness(aParentTestHarness)

	{}

//

//

// CCheckMessageFolder

//

EXPORT_C void CCheckMessageFolder::StartL(TRequestStatus& aStatus)

	{

	TBool matched = ETrue;

	iTestUtils.FindChildrenL(0x01000, ETrue);

	RFile file1;

	User::LeaveIfError(file1.Open(iTestUtils.FileSession(), K_T_MSG_STRUCT_FILE, EFileShareAny));

	RFile file2;

	User::LeaveIfError(file2.Open(iTestUtils.FileSession(), iFileName, EFileShareAny));

	TLineReader lineReader1(file1);

	TLineReader lineReader2(file2);

	HBufC8* actualLine = lineReader1.GetLineLC();

	HBufC8* expectedLine = lineReader2.GetLineLC();

	while ((actualLine->Des().Size() > 0) && (expectedLine->Des().Size() > 0) && (matched))

		{

		if (actualLine->Des() != expectedLine->Des())

			matched = EFalse;

		CleanupStack::PopAndDestroy(2); // actualLine, expectedLinw

		actualLine = lineReader1.GetLineLC();

		expectedLine = lineReader2.GetLineLC();

		}

	if ((actualLine->Des().Size() != 0)

		|| (expectedLine->Des().Size() != 0))

		{

		matched = EFalse;

		}

	CleanupStack::PopAndDestroy(2); // actualLine, expectedLinw

	if (!matched)

		{

		User::Leave(KErrNotFound);

		}

	file1.Close();

	file2.Close();

	TRequestStatus* status = &aStatus;

	User::RequestComplete(status, KErrNone);

	}

EXPORT_C CCheckMessageFolder::CCheckMessageFolder(const TDesC& aFileName, CMsvTestUtils& aTestUtils) : iTestUtils(aTestUtils)

	{

	iFileName = aFileName;

	}

//

//

// CSelectEntry

//

CSelectEntry::CSelectEntry(const TMsvId& aCurrentFolderId, TMsvId* aEntryId, CMsvTestUtils& aTestUtils) 

: iTestUtils(aTestUtils), 

  iCurrentFolderId(aCurrentFolderId), 

  iEntryId(aEntryId)

	{

	iEntrySelection = NULL;

	}

CSelectEntry::CSelectEntry(const TMsvId& aCurrentFolderId, CMsvEntrySelection* aSelection, CMsvTestUtils& aTestUtils) 

: iTestUtils(aTestUtils),

  iCurrentFolderId(aCurrentFolderId), 

  iEntrySelection(aSelection)

	{

	iEntryId = NULL;

	}

EXPORT_C CSelectEntry* CSelectEntry::NewL(const TDesC& aName, const TMsvId& aCurrentFolderId, TMsvId* aEntryId, CMsvTestUtils& aTestUtils)

	{

	CSelectEntry* self = new (ELeave) CSelectEntry(aCurrentFolderId, aEntryId, aTestUtils);

	CleanupStack::PushL(self);

	self->ConstructL(aName);

	CleanupStack::Pop(self);

	return self;

	}

EXPORT_C CSelectEntry* CSelectEntry::NewL(const TDesC& aName, const TMsvId& aCurrentFolderId, CMsvEntrySelection* aSelection, CMsvTestUtils& aTestUtils)

	{

	CSelectEntry* self = new (ELeave) CSelectEntry(aCurrentFolderId, aSelection, aTestUtils);

	CleanupStack::PushL(self);

	self->ConstructL(aName);

	CleanupStack::Pop(self);

	return self;

	}

void CSelectEntry::ConstructL(const TDesC& aName)

	{

	iEntryName = HBufC::NewL(aName.Length());

	(*iEntryName) = aName;

	}

EXPORT_C void CSelectEntry::StartL(TRequestStatus& aStatus)

	{

	// Select current folder

	CMsvEntry& entry = *(iTestUtils.iMsvEntry);

	entry.SetEntryL(iCurrentFolderId);

	// show the invisible folders.....

	TMsvSelectionOrdering order;

	order.SetShowInvisibleEntries(ETrue);

	entry.SetSortTypeL(order);

	CMsvEntrySelection* tempSelection = entry.ChildrenL();

	CleanupStack::PushL(tempSelection);

	// Check each child entry for a matching string

	TBool found = EFalse;

	TInt entryIndex = tempSelection->Count();

	while ((!found) && (entryIndex-- != 0))

		{

		entry.SetEntryL((*tempSelection)[entryIndex]);

		if (iEntryName->CompareF(entry.Entry().iDescription) == 0)

			{

			found = ETrue;

			}

		else if (iEntryName->CompareF(entry.Entry().iDetails) == 0)

			{

			found = ETrue;

			}

		}

	if (found)

		{

		// decide if its a Selection thats required, or an Entry

		if(iEntryId)

			{

			*iEntryId = entry.Entry().Id();

			}

		else

			{

			(*iEntrySelection).Reset();

			(*iEntrySelection).AppendL(entry.Entry().Id());

			}

		TRequestStatus* status = &aStatus;

		User::RequestComplete(status, KErrNone);

		}

	else

		{

		TBuf<256> errorString;

		errorString.Format(KErrSelectText, iEntryName);

		HBufC* errorStringHBufC = HBufC::NewLC(errorString.Length());

		(errorStringHBufC->Des()).Copy(errorString);

		iTestUtils.WriteComment(*errorStringHBufC);

		CleanupStack::PopAndDestroy();

		TRequestStatus* status = &aStatus;

		User::RequestComplete(status, KErrNotFound);

		}

	CleanupStack::PopAndDestroy(tempSelection);

	}

EXPORT_C CSelectEntry::~CSelectEntry()

	{

	delete iEntryName;

	}

/*

CSelectEntry::CSelectEntry(const TMsvId& aCurrentFolderId, TMsvId& aEntryId, CMsvTestUtils& aTestUtils) : iCurrentFolderId(aCurrentFolderId), iTestUtils(aTestUtils), iEntryId(aEntryId)

	{

	}

CSelectEntry* CSelectEntry::NewL(const TDesC& aName, const TMsvId& aCurrentFolderId, TMsvId& aEntryId, CMsvTestUtils& aTestUtils)

	{

	CSelectEntry* self = new (ELeave) CSelectEntry(aCurrentFolderId, aEntryId, aTestUtils);

	CleanupStack::PushL(self);

	self->ConstructL(aName);

	CleanupStack::Pop(self);

	return self;

	}

void CSelectEntry::ConstructL(const TDesC& aName)

	{

	iEntryName = HBufC::NewL(aName.Length());

	(*iEntryName) = aName;

	}

void CSelectEntry::StartL(TRequestStatus& aStatus)

	{

	// Select current folder

	CMsvEntry& entry = *(iTestUtils.iMsvEntry);

	entry.SetEntryL(iCurrentFolderId);

	// show the invisible folders.....

	TMsvSelectionOrdering order;

	order.SetShowInvisibleEntries(ETrue);

	entry.SetSortTypeL(order);

	CMsvEntrySelection* tempSelection = entry.ChildrenL();

	CleanupStack::PushL(tempSelection);

	// Check each child entry for a matching string

	TBool found = EFalse;

	TInt entryIndex = tempSelection->Count();

	while ((!found) && (entryIndex-- != 0))

		{

		entry.SetEntryL((*tempSelection)[entryIndex]);

		if (iEntryName->CompareF(entry.Entry().iDescription) == 0)

			{

			found = ETrue;

			}

		else if (iEntryName->CompareF(entry.Entry().iDetails) == 0)

			{

			found = ETrue;

			}

		}

	if (found)

		{

		iEntryId = entry.Entry().Id();

		TRequestStatus* status = &aStatus;

		User::RequestComplete(status, KErrNone);

		}

	else

		{

		TBuf<256> errorString;

		errorString.Format(KErrSelectText, iEntryName);

		HBufC* errorStringHBufC = HBufC::NewLC(errorString.Length());

		(errorStringHBufC->Des()).Copy(errorString);

		iTestUtils.WriteComment(*errorStringHBufC);

		CleanupStack::PopAndDestroy();

		TRequestStatus* status = &aStatus;

		User::RequestComplete(status, KErrNotFound);

		}

	CleanupStack::PopAndDestroy(tempSelection);

	}

CSelectEntry::~CSelectEntry()

	{

	delete iEntryName;

	}

*/

//

//

// CDumpMessageStore

//

EXPORT_C void CDumpMessageStore::StartL(TRequestStatus& aStatus)

	{

	iTestUtils.FindChildrenL(KMsvRootIndexEntryId);

	TRequestStatus* status = &aStatus;

	User::RequestComplete(status, KErrNone);

	}

EXPORT_C CDumpMessageStore::CDumpMessageStore(CMsvTestUtils& aTestUtils) : iTestUtils(aTestUtils)

	{

	}

//

//