// 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;
	}