// console.cpp
// 
// Copyright (c) 2008 - 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 <e32debug.h>
#include "console.h"
#include <fshell/consoleextensions.h>

_LIT(KWin32ConsPanic, "Win32Console");
#define PANIC() User::Panic(KWin32ConsPanic, 0);

//_____________________________________________________________________________
//					CWin32Console
CWin32Console::CWin32Console()
	{
	}

CWin32Console::~CWin32Console()
	{
	iWin32.FreeConsole();
	// when call FreeConsole(), it should cause the reader thread to exit as the
	// console read handle will become invalid, and windows will complete the
	// ReadRequest with an error
	if (iReaderThread.Handle())
		{
		TRequestStatus stat;
		iReaderThread.Logon(stat);
		User::WaitForRequest(stat);
		}
	iReaderThread.Close();
	iKeyQueue.Close();
	iThreadParams.iOwner.Close();
	}

TInt CWin32Console::Create(const TDesC& aTitle, TSize /*aSize*/)
	{
	int r = iWin32.AttachConsole();
	if (r==0)
		{
		return KErrCouldNotConnect; // suitable error code??
		}
	SetTitle(aTitle);
	
	_LIT(KReadThreadName, "Win32ConsReader");
	
	TInt err = iKeyQueue.CreateLocal(4);
	if (err!=KErrNone) return err;
	
	err = iThreadParams.iOwner.Open(RThread().Id());
	if (err!=KErrNone) return err;
	iThreadParams.iWin32 = &iWin32;
	iThreadParams.iKeyQueue = iKeyQueue;
	err = iReaderThread.Create(KReadThreadName, ReaderThread, 0x800, KMinHeapSize, KMinHeapSize*4, &iThreadParams);
	if (err!=KErrNone) return err;
	iReaderThread.Resume();	
	
	return KErrNone;
	}

void CWin32Console::Read(TRequestStatus& aStatus)
	{
	iReadKp = EFalse;
	iKeyQueue.NotifyDataAvailable(aStatus);
	}

void CWin32Console::ReadCancel()
	{
	iKeyQueue.CancelDataAvailable();
	}

void CWin32Console::Write(const TDesC& aDes)
	{
	iWin32.Write(aDes.Ptr(), aDes.Length());
	}
	
void CWin32Console::WriteStdErr(const TDesC& aDes)
	{
	iWin32.WriteStdErr(aDes.Ptr(), aDes.Length());
	}

TPoint CWin32Console::CursorPos() const
	{
	TPoint pos;
	iWin32.GetCursorPos(pos.iX, pos.iY);
	return pos;
	}

void CWin32Console::SetCursorPosAbs(const TPoint& aPoint)
	{
	iWin32.SetCursorPos(aPoint.iX, aPoint.iY);
	}

void CWin32Console::SetCursorPosRel(const TPoint& aPoint)
	{
	iWin32.SetCursorPosRel(aPoint.iX, aPoint.iY);
	}

void CWin32Console::SetCursorHeight(TInt aPercentage)
	{
	iWin32.SetCursorHeight(aPercentage);
	}

void CWin32Console::SetTitle(const TDesC& aTitle)
	{
	RBuf8 title;
	TInt err = title.Create(aTitle.Length()+1);
	if (err==KErrNone)
		{
		title.Copy(aTitle);
		iWin32.SetTitle((const char*)title.PtrZ());
		title.Close();
		}
	}

void CWin32Console::ClearScreen()
	{
	iWin32.ClearScreen();
	}

void CWin32Console::ClearToEndOfLine()
	{
	iWin32.ClearToEndOfLine();
	}

TSize CWin32Console::ScreenSize() const
	{
	TSize size;
	iWin32.GetScreenSize(size.iWidth, size.iHeight);
	return size;
	}

TKeyCode CWin32Console::KeyCode() const
	{
	if (!iReadKp)
		{
		iKeyQueue.Receive(iKp);
		iReadKp = ETrue;
		}
	return iKp.iCode;
	}

TUint CWin32Console::KeyModifiers() const
	{
	if (!iReadKp)
		{
		iKeyQueue.Receive(iKp);
		iReadKp = ETrue;
		}
	return iKp.iModifiers;
	}

TInt CWin32Console::Extension_(TUint aExtensionId, TAny*& a0, TAny* a1)
	{
	if (aExtensionId == ConsoleStdErr::KWriteStdErrConsoleExtension)
		{
		TDesC* des = (TDesC*)a1;
		WriteStdErr(*des);
		return KErrNone;
		}
	else if (aExtensionId == ConsoleAttributes::KSetConsoleAttributesExtension)
		{
		ConsoleAttributes::TAttributes* attributes = (ConsoleAttributes::TAttributes*)a1;
		int res = iWin32.SetAttributes(attributes->iAttributes, (TWin32Console::TColor)attributes->iForegroundColor, (TWin32Console::TColor)attributes->iBackgroundColor);
		return res ? KErrNone : KErrGeneral; // Yay for KErrGeneral!
		}
	else
		{
		return CConsoleBase::Extension_(aExtensionId, a0, a1);
		}
	
	}

//_____________________________________________________________________________
//					Reader thread

static int ReaderThread(TAny* aParams)
	{
	TReaderThreadParams params = *(TReaderThreadParams*)aParams;
	
	RMsgQueue<TKeyPress> keyQueue = params.iKeyQueue;
	TInt err = keyQueue.Duplicate(params.iOwner);
	
	while (err==KErrNone)
		{
		TKeyPress kp;
		err = params.iWin32->ReadKey(kp.iCode, kp.iModifiers);
		
		if (err==KErrNone)
			{
			keyQueue.SendBlocking(kp);
			}

		};
	
	keyQueue.Close();
	
	return err;
	}

//_____________________________________________________________________________
//					Debugging stuff
EXPORT_C TAny* NewConsole()
	{
	return new CWin32Console;
	}

class TOverflowTruncate8 : public TDes8Overflow
	{
public:
	virtual void Overflow(TDes8&) {}
	};

class TOverflowTruncate16 : public TDes16Overflow
	{
public:
	virtual void Overflow(TDes16&) {}
	};

void DebugMsg(const char* aMsg, ...)
	{
	VA_LIST list;
	VA_START(list, aMsg);
	TBuf8<0x100> buf;
	TOverflowTruncate8 overflow;
	buf.AppendFormatList(_L8(aMsg), list, &overflow);

	RDebug::Printf((const char*)buf.PtrZ());
	}

void DebugMsg(const TUint16* aMsg, ...)
	{
	VA_LIST list;
	VA_START(list, aMsg);
	TBuf16<0x100> buf;
	TOverflowTruncate16 overflow;
	buf.AppendFormatList(TPtrC((const TText16*)aMsg), list, &overflow);

	RDebug::Print(buf);
	}


#ifndef EKA2
GLDEF_C TInt E32Dll(TDllReason)
	{
	return(KErrNone);
	}
#endif