// console.cpp

// 

// Copyright (c) 2006 - 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 <e32cons.h>

#include <fshell/ioutils.h>

#include "console.h"

//

// CConsoleReader.

//

CConsoleReader* CConsoleReader::NewL(RIoConsoleReadHandle& aStdin, MConsoleObserver& aObserver)

	{

	CConsoleReader* self = new(ELeave) CConsoleReader(aStdin, aObserver);

	self->Queue();

	return self;

	}

CConsoleReader::~CConsoleReader()

	{

	Cancel();

	}

CConsoleReader::CConsoleReader(RIoConsoleReadHandle& aStdin, MConsoleObserver& aObserver)

	: CActive(CActive::EPriorityStandard), iStdin(aStdin), iObserver(aObserver)

	{

	CActiveScheduler::Add(this);

	}

void CConsoleReader::Queue()

	{

	TInt result = iStdin.AttachedToConsole();

	if (result > 0)

		{

		iRawRead = ETrue;

		iStdin.Read(iRawReadBuf, iStatus);

		}

	else if (result == 0)

		{

		iRawRead = EFalse;

		iStdin.WaitForKey(iStatus);

		}

	else

		{

		// This seems to happen if the console failed to construct

		// [I've seen a E32USER-CBase 45 panic as a result of this call so possibly it's not always the right thing to do (I added this in the first place). -TomS]

		iObserver.CoHandleError(result);

		return;

		}

	SetActive();

	}

void CConsoleReader::RunL()

	{

	TInt err = iStatus.Int();

	if (err)

		{

		iObserver.CoHandleError(err);

		}

	else

		{

		TUint keyCode = iRawRead ? iRawReadBuf[0] : iStdin.KeyCode();

		TUint modifiers = iRawRead ? 0 : iStdin.KeyModifiers();

		iObserver.CoHandleKey(keyCode, modifiers);

		}

	Queue();

	}

void CConsoleReader::DoCancel()

	{

	if (iRawRead)

		{

		iStdin.ReadCancel();

		}

	else

		{

		iStdin.WaitForKeyCancel();

		}

	}