// 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 "tcsy.h"

// ----------------------------------------------------------------------------
//							CActiveConsoleBase
// ----------------------------------------------------------------------------


CActiveConsoleBase::CActiveConsoleBase(CConsoleBase& aConsole)
: CActive(EPriorityStandard), iConsole(aConsole)
	{
	CActiveScheduler::Add(this);
	}

CActiveConsoleBase::~CActiveConsoleBase()
	{
	Cancel();
	}

void CActiveConsoleBase::DoCancel()
	{
	iConsole.ReadCancel();
	}

void CActiveConsoleBase::RequestKey()
	{
	DrawCursor();
	iConsole.Read(iStatus);
	SetActive();
	}

void CActiveConsoleBase::DrawCursor()
	{
	iConsole.Printf(_L(">>"));
	}


TInt CActiveConsoleBase::RunError(TInt /*aError*/)
	{
	__DEBUGGER();
	return KErrNone;
	}

// ----------------------------------------------------------------------------
//							CActiveRootConsole
// ----------------------------------------------------------------------------

void CActiveRootConsole::DrawMenu()
	{
	iConsole.Printf(_L("Choose action...\n\n"));
	iConsole.Printf(_L("n.\t\tStart RComm\n"));
	iConsole.Printf(_L("x.\t\tDelete all RComm\n"));
	iConsole.Printf(_L("a.\t\tAuto\n"));
	iConsole.Printf(_L("e.\t\tStart exclusive session\n"));
	iConsole.Printf(_L("f.\t\tStop exclusive session\n"));
	iConsole.Printf(_L("u.\t\tMark C32 User Heap\n"));
	iConsole.Printf(_L("v.\t\tMark-end C32 User Heap\n"));
	iConsole.Printf(_L("0.\t\tAccess Violation\n"));
	iConsole.Printf(_L("P.\t\tPanic\n"));
	iConsole.Printf(_L("T.\t\tHTTP Get\n"));
	iConsole.Printf(_L("Esc.\tStop\n"));
	RequestKey();
	}


CActiveRootConsole::CActiveRootConsole(CConsoleBase& aConsole, CCSYApp& aApp)
: CActiveConsoleBase(aConsole), iApp(aApp)
	{
	}

CActiveRootConsole* CActiveRootConsole::NewL(CConsoleBase& aConsole, CCSYApp& aApp)
	{
	CActiveRootConsole* console = new (ELeave) CActiveRootConsole(aConsole, aApp);
//	CleanupStack::PushL(console);
//	console->ConstructL();
//	CleanupStack::Pop();
	console->DrawMenu();
	return console;
	}


void CActiveRootConsole::RunL()
	{
	// key has been pressed

	TChar ch = iConsole.KeyCode();
	switch (ch)
		{
	case 'n':
		TimePrint();
		iConsole.Printf(_L("Starting RComm...\n"));
		iApp.NewCSYL();
		break;

	case 'x':
		TimePrint();
		iConsole.Printf(_L("Deleting all RComm...\n"));
		iApp.DeleteAllConnections();
		break;

	case 'a':
		TimePrint();
		iConsole.Printf(_L("Auto mode...\n"));
		iApp.AutoMode();
		break;

	case 'e':
		{
		TimePrint();
		iConsole.Printf(_L("Starting an exclusive session\n"));
		iApp.StartExclusiveSessionL();
		break;
		}

	case 'f':
		{
		TimePrint();
		iConsole.Printf(_L("Stopping the exclusive session\n"));
		iApp.StopExclusiveSession();
		break;
		}

	case 'u':
		{
		TimePrint();
		iConsole.Printf(_L("Mark C32 User Heap\n"));
		iApp.C32UHeapMark();
		break;
		}

	case 'v':
		{
		TimePrint();
		iConsole.Printf(_L("Mark-end C32 User Heap\n"));
		iApp.C32UHeapMarkEnd();
		break;
		}

	case '0':
		{
		iConsole.Printf(_L("Deref-ing NULL...\n"));
		TInt* boom = NULL;
		TInt detritus = *boom;
		(void)(detritus != NULL); // keep the compiler happy by taking detritus as an r-value
		break;
		}

	case 'P':
		{
		iConsole.Printf(_L("Panic!\n"));
		User::Panic(_L("PANIC!!"), 0x1234);
		}

	case 'T':
		{
		iConsole.Printf(_L("Doing a HTTP Get...\n"));
		iApp.FetchWebPageL();
		}

	case EKeyEscape:
		{
		iApp.Stop();
		goto end;
		}


	default:
		iConsole.Printf(_L("Unknown command\r\n"));
		}
	// schedule another key press
	RequestKey();

end:
	return;
	}




// ----------------------------------------------------------------------------
//							CActiveCommConsole
// ----------------------------------------------------------------------------

CActiveCommConsole::CActiveCommConsole(CConsoleBase& aConsole, CCSY& aCSY)
: CActiveConsoleBase(aConsole), iComm(aCSY)
	{
	}


CActiveCommConsole* CActiveCommConsole::NewL(CConsoleBase& aConsole, CCSY& aCSY)
	{
	CActiveCommConsole* console = new (ELeave) CActiveCommConsole(aConsole, aCSY);
//	CleanupStack::PushL(console);
//	console->ConstructL();
//	CleanupStack::Pop();
	console->DrawMenu();
	return console;
	}

void CActiveCommConsole::RunL()
	{
	// key has been pressed

	TChar ch = iConsole.KeyCode();
	TBool reque = ETrue;

	switch (ch)
		{
	case 'c':
		iConsole.Printf(_L("Cancel RComm...\n"));
//		iComm.CancelCSY();
		break;

	case 'r':
		iConsole.Printf(_L("RComm::Read...\n"));
		iComm.Read();
		break;

	case 'w':
		iConsole.Printf(_L("RComm::Write...\n"));
		break;

	case 'x':
		iComm.Destroy();
		reque = EFalse;
		break;


	default:
		iConsole.Printf(_L("Unknown command\r\n"));
		}
	if (reque)
		RequestKey();	// schedule another key press
	return;
	}

void CActiveCommConsole::DrawMenu()
	{
	iConsole.Printf(_L("c.\t\tCancel RComm \n"));
	iConsole.Printf(_L("r.\t\tRComm::Read\n"));
	iConsole.Printf(_L("w.\t\tRComm::Write\n"));
	iConsole.Printf(_L("q.\t\tRComm::Close\n"));

	iConsole.Printf(_L("x.\t\tDelete RComm\n"));
	RequestKey();
	}


void CActiveConsoleBase::TimePrint()
	{
	TBuf<16> time;

	iTime.HomeTime();

	TRAPD(err, iTime.FormatL(time, KDateFormatter));
	__ASSERT_ALWAYS(err==KErrNone, User::Panic(_L("Test thread"), 0x666));

	iConsole.Printf(_L("%S: "), &time);
	}