// Copyright (c) 1997-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:

 // Console redirection server 

 // 

 //

 #include "testconsole.h"

 #include <e32svr.h>

 #include <utf.h>

 #include <e32cons.h>

 NONSHARABLE_CLASS(CActiveConsole) : public CActive

 	{

 	public:

 		CActiveConsole();

 		void ConsoleRead();

 		static CActiveConsole* NewLC(CConsoleBase* aConsole, CTestConsole * aStream);

 		static CActiveConsole* NewL(CConsoleBase* aConsole, CTestConsole * aStream);

 		void ConstructL(CConsoleBase* aConsole, CTestConsole * aStream);

 	private:

 		void DoCancel();

 		void RunL();

 		CTestConsole * iStream;

 		CConsoleBase * iConsole;

 	};

 CActiveConsole::CActiveConsole() : CActive(CActive::EPriorityStandard)

 	{

 	}

 void CActiveConsole::DoCancel()

 	{

 	}

 void CActiveConsole::ConsoleRead()

 	{

 	iConsole->Read(iStatus);

 	SetActive();

 	}

 void CActiveConsole::RunL()

 	{

 	iStream->DoneReading(iConsole->KeyCode());

 	}

 CActiveConsole* CActiveConsole::NewLC(CConsoleBase* aConsole, CTestConsole * aStream)

 	{

 	CActiveConsole* self=new (ELeave) CActiveConsole;

 	CleanupStack::PushL(self);

 	self->ConstructL(aConsole, aStream);

 	return self;

 	}

 CActiveConsole* CActiveConsole::NewL(CConsoleBase* aConsole, CTestConsole * aStream)

 	{

 	CActiveConsole* self = NewLC(aConsole, aStream);

 	CleanupStack::Pop();

 	return self;

 	}

 void CActiveConsole::ConstructL(CConsoleBase* aConsole, CTestConsole * aStream)

 	{

 	iConsole = aConsole;

 	iStream = aStream;

 	CActiveScheduler::Add(this);

 	}

 CTestConsole::CTestConsole()

 	{

 #ifdef __MARM

 	TRAPD(r,iConsole=Console::NewL(_L("Redirection Server"),TSize(KConsFullScreen, KConsFullScreen)))

 #else

 	TRAPD(r,iConsole=Console::NewL(_L("Redirection Server"),TSize(KDefaultConsWidth,KDefaultConsHeight)))

 #endif

 	__ASSERT_ALWAYS(r==KErrNone,User::Panic(_L("Redirection Server"),0));

 	//create and add the active object

 	TRAPD(x, iActiveChap=CActiveConsole::NewL(iConsole, this));

 	__ASSERT_ALWAYS(x==KErrNone,User::Panic(_L("Redirection Server"),0));

 	}

 CTestConsole::~CTestConsole()

 	{

 	if (iConsole)

 		{

 		iConsole->Write(_L("Console Closed"));

 		User::After(2*1000000);

 		delete iConsole;

 		}

 	}

  void CTestConsole::Write(TDes8& aDes)

 	{

 	TBuf<256> str;

 	CnvUtfConverter::ConvertToUnicodeFromUtf8(str, aDes);

 	iConsole->Write(str);

 	}

  void CTestConsole::Read(const RMessage2& aMessage)

 	{

 	iMessage = aMessage;

 	iActiveChap->ConsoleRead();		//read from the console

 	}

  void CTestConsole::DoneReading(TKeyCode aKeyCode)

 	{

 	TText8 ch;

 	switch (aKeyCode)

 		{

 		case EKeyEnter:

 			ch = '\n';

 			break;

 		case EKeyBackspace:

 			ch = 0x08;

 			break;

 		default:

 			ch = (TText8)(aKeyCode&0xFF);

 			break;

 		}

 	//append it to the buffer

 	iBuf.Append(ch);

 	Write(iBuf);

 	CompleteRead(iMessage);

 	}

  CStreamBase2* CTestConsoleFactory::GetStream()

 	{

 	return new CTestConsole();

 	}

  void CTestConsoleFactory::Configure()

 	{

 	}

 CTestConsoleFactory* CTestConsoleFactory::NewL()

 	{

 	CTestConsoleFactory* f=new(ELeave) CTestConsoleFactory();

 	return f;

 	}