/*

* Copyright (c) 2006-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 <e32twin.h>

#include <e32svr.h>

#include "activeconsole.h"

#include "testbase.h"

#include "tests.h"

CActiveConsole::CActiveConsole(CConsoleBase& aConsole)

 :	CActive(CActive::EPriorityStandard),

	iConsole(aConsole)

	{

	CActiveScheduler::Add(this);

	}

CActiveConsole* CActiveConsole::NewLC(CConsoleBase& aConsole)

	{

	CActiveConsole* self = new(ELeave) CActiveConsole(aConsole);

	CleanupStack::PushL(self);

	self->ConstructL();

	self->DisplayMainMenu();

	return self;

	}

void CActiveConsole::ConstructL()

	{

	// Launch of FDTest test.

	iTest = gTestDefinitions[0].iFactoryL(*this);

	}

CActiveConsole::~CActiveConsole()

	{

	Cancel();

	StopCurrentTest();

	}

void CActiveConsole::DoCancel()

	{

	iConsole.ReadCancel();

	}

void CActiveConsole::StopCurrentTest()

	{

	delete iTest;

	iTest = NULL;

	}

void CActiveConsole::RunL()

// Only process when we get a return, otherwise cache- i.e. support multi-character selections

	{

	DoActionKeyL(iConsole.KeyCode());

	// Repost asynchronous request.

	RequestCharacter();

	}

void CActiveConsole::DoActionKeyL(TKeyCode aKeyCode)

	{

	WriteNoReturn(_L8("%c"), aKeyCode);

	// Examine the key that just came in.

	switch ( TUint(aKeyCode) )

		{

	case EKeyEscape:

		{

		Write(_L8("Exiting"));

		CActiveScheduler::Stop();

		return;

		}

	case EKeyEnter:

		// Tell the test about what's in the buffer so far, if anything.

		Write(_L8("You entered \'%S\'"), &iInputBuffer);

		switch ( iInputBuffer.Length() )

			{

		case 0:

			// Don't pass anything on- nothing to pass on.

			break;

		case 1:

			if ( 	iInputBuffer == _L8("S") 

				||	iInputBuffer == _L8("s") 

				)

				{

				StopCurrentTest();

				}

			else

				{

				// Tell the test via the old 'single character' interface.

				// If there is a test, then let it process the key. If there isn't a 

				// test, we process it to (possibly) create and run a new test object.

				if ( iTest )

					{

					TRAPD(err, iTest->ProcessKeyL((TKeyCode)iInputBuffer[0]));

					if ( err )

						{

						Write(_L8("CTestBase::ProcessKeyL left with %d"), err);

						StopCurrentTest();

						}

					}

				else

					{

					SelectTestL();

					}

				}

			iInputBuffer = KNullDesC8();

			break;

		default:

			// Tell the test via the new 'multi character' interface.

			// If there is a test, then let it process the key. If there isn't a 

			// test, we process it to (possibly) create and run a new test object.

			if ( iTest )

				{

				TRAPD(err, iTest->ProcessKeyL(iInputBuffer));

				if ( err )

					{

					Write(_L8("CTestBase::ProcessKeyL left with %d"), err);

					StopCurrentTest();

					}

				}

			else

				{

				SelectTestL();

				}

			iInputBuffer = KNullDesC8();

			break;

			}

		DisplayMainMenu();

		break;

	default:

		iInputBuffer.Append(aKeyCode);

		break;

		}

	}

void CActiveConsole::RequestCharacter()

	{

	iConsole.Read(iStatus);

	SetActive();

	}

void CActiveConsole::DisplayMainMenu()

	{

	Write(KNullDesC8);

	// If there's a current test, display its step menu. Otherwise, display 

	// all the available tests.

	if ( iTest )

		{

		iTest->DisplayTestSpecificMenu();

		Write(_L8("s - stop and close current test"));

		}

	else

		{

		const TUint numberOfTests = sizeof(gTestDefinitions) / sizeof(TTestDefinition);

		for ( TUint ii = 0 ; ii < numberOfTests ; ii ++ )

			{

			Write(_L8("%d - %S"), ii, &gTestDefinitions[ii].iDescription);

			}

		}

	Write(_L8("Escape - exit program"));

	Write(KNullDesC8);

 	}

void CActiveConsole::Write(TRefByValue<const TDesC8> aFmt, ...)

	{

	VA_LIST list;

	VA_START(list, aFmt);

	TBuf8<0x100> buf;

	buf.AppendFormatList(aFmt, list);

	TBuf<0x100> wideBuf;

	wideBuf.Copy(buf);

	iConsole.Write(wideBuf);

	iConsole.Write(_L("\n"));

	RDebug::Print(wideBuf);

	}

void CActiveConsole::WriteNoReturn(TRefByValue<const TDesC8> aFmt, ...)

	{

	VA_LIST list;

	VA_START(list, aFmt);

	TBuf8<0x100> buf;

	buf.AppendFormatList(aFmt, list);

	TBuf<0x100> wideBuf;

	wideBuf.Copy(buf);

	iConsole.Write(wideBuf);

	RDebug::Print(wideBuf);

	}

TKeyCode CActiveConsole::Getch()

	{

	return iConsole.Getch();

	}

void CActiveConsole::SelectTestL()

	{

	StopCurrentTest();

	// Pick a test out of the global array of tests.

	const TUint numberOfTests = sizeof(gTestDefinitions) / sizeof (TTestDefinition);

	TLex8 lex(iInputBuffer);

	TUint index;

	TInt err = lex.Val(index);

	if (	err == KErrNone

		&&	index < numberOfTests

		)

		{

		iTest = gTestDefinitions[index].iFactoryL(*this);

		}

	else

		{

		Write(_L8("Unknown selection"));

		}

	}

void CActiveConsole::TestFinished()

/**

 * Called by the test when it has finished. Results in the destruction of the 

 * test.

 */

	{

	StopCurrentTest();

	}

TInt CActiveConsole::RunError(TInt aError)

/**

 * Called by the Active Scheduler when a RunL in this active object leaves.

 */

	{

	// This actually happens when a test object fails to construct properly.

	Write(_L8("Error creating test object: %d"), aError);

	iInputBuffer = KNullDesC8();

	DisplayMainMenu();

	// It's OK to carry on with the program itself, so repost asynchronous 

	// request.

	RequestCharacter();

	return KErrNone;

	}

void CActiveConsole::GetNumberL(TUint& aNumber)

	{

	TBuf<12> addrAsText;

	addrAsText.Zero();

	if ( aNumber != 0 )

		{

		addrAsText.Format(_L("%d"), aNumber);

		}

	WriteNoReturn(_L8("Enter a number: "));

	if ( addrAsText.Length() > 0 )

		{

		TBuf8<100> narrowBuf;

		narrowBuf.Copy(addrAsText);

		WriteNoReturn(narrowBuf);

		}

	TKeyCode code;

	TBuf<1> character;

	FOREVER

		{

		code = Getch();

		character.SetLength(0);

		character.Append(code);

		// If <CR> finish editing string

		if (code == 0x0d)

			break;

		// if <BS> remove last character

		if ((code == 0x08)&&(addrAsText.Length() != 0))

			{

			WriteNoReturn(_L8("%S"),&character);

			addrAsText.SetLength((addrAsText.Length()-1));

			}

		else

			{

			if (addrAsText.Length() < addrAsText.MaxLength())

				{

				WriteNoReturn(_L8("%S"),&character);

				addrAsText.Append(code);

				}

			}

		}

	//now extract the new address from the string...

	if( !addrAsText.Length() )

		{

		addrAsText.Append('0'); //null string causes TLex::Val to return an error

		}

	TLex lex(addrAsText);

	TInt err = lex.Val(aNumber, EDecimal);

	User::LeaveIfError(err);

	}